package service

import (
	"github.com/jinzhu/copier"
	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/bean/entity"
	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/bean/vo/request"
	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/bean/vo/response"
	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/common/conf"
	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/pkg/beagle/jsontime"
	"go.uber.org/zap"
	"xorm.io/xorm"
)

type AlertListSvc struct {
	User entity.SystemUserInfo
}

func (a *AlertListSvc) Update(session *xorm.Session, req request.UpdateAlertList) error {
	now := jsontime.Now()
	data := entity.AlertList{
		UpdatedBy: a.User.SystemAccount,
		UpdatedAt: now,
	}
	_ = copier.Copy(&data, &req)
	_, err := session.Cols("class_name", "updated_by", "updated_at").ID(data.ClassId).Update(&data)
	if err != nil {
		return err
	}
	return nil
}

func (a *AlertListSvc) BatchPushAlertList(session *xorm.Session, req request.BatchPushAlertList) error {
	now := jsontime.Now()
	_ = now
	// TODO 批量推送用户告警
	conf.Logger.Info("batch push", zap.Any("payload", req))
	return nil
}

func (a *AlertListSvc) BatchCloseAlertList(session *xorm.Session, req request.BatchCloseAlertList) error {
	now := jsontime.Now()
	_ = now
	// TODO 批量推送用户告警
	conf.Logger.Info("batch close", zap.Any("payload", req))
	return nil
}

func (a *AlertListSvc) GetDataById(req request.DetailAlertList) (resp response.AlertListItem, err error) {
	now := jsontime.Now()
	data := response.AlertListItem{
		AlertList: entity.AlertList{
			Id:                123,
			AlertPoint:        "容器云/kube-apiserver",
			AlertRulesId:      "762ed641-6c0e-4c39-bf7c-7463abb0f8a2",
			RiskLevel:         4,
			AlertTime:         now,
			ClassId:           14,
			ClassParentName:   "预警分类",
			ClassName:         "预警对象",
			MetricConfigId:    "d773b37b-dbb4-4a7b-be11-ab40f8acc00e",
			MetricConfigName:  "CPU负载过高",
			AlertRuleType:     "51a2cc1e-eb24-4b16-b106-3dc9db963a49",
			CurrentValue:      85,
			NotificationCount: 3,
			PushCount:         3,
			LastPushTime:      now,
			Status:            2,
			IsDisposed:        1,
			DisposalContent:   "已处置完毕，已做恢复操作",
			CreatedBy:         "admin",
			CreatedAt:         now,
			UpdatedBy:         "admin",
			UpdatedAt:         now,
		},
		AlertCondition: entity.AlertCondition{
			ThresholdsMax: 100,
			ThresholdsMin: 80,
			RiskLevel:     4,
		},
	}
	resp = data
	return
}

func (a *AlertListSvc) List(req request.ListAlertList) (resp response.AlertListList, err error) {
	now := jsontime.Now()
	data1 := response.AlertListItem{
		AlertList: entity.AlertList{
			Id:                123,
			AlertPoint:        "容器云/kube-apiserver",
			AlertRulesId:      "762ed641-6c0e-4c39-bf7c-7463abb0f8a2",
			RiskLevel:         4,
			AlertTime:         now,
			ClassId:           14,
			ClassParentName:   "预警分类",
			ClassName:         "预警对象",
			MetricConfigId:    "d773b37b-dbb4-4a7b-be11-ab40f8acc00e",
			MetricConfigName:  "磁盘空间不足",
			AlertRuleType:     "51a2cc1e-eb24-4b16-b106-3dc9db963a49",
			CurrentValue:      85,
			NotificationCount: 3,
			PushCount:         3,
			LastPushTime:      now,
			Status:            2,
			IsDisposed:        1,
			DisposalContent:   "处置为未恢复",
			CreatedBy:         "admin",
			CreatedAt:         now,
			UpdatedBy:         "admin",
			UpdatedAt:         now,
		},
		AlertCondition: entity.AlertCondition{
			ThresholdsMax: 100,
			ThresholdsMin: 80,
			RiskLevel:     4,
		},
	}
	data2 := response.AlertListItem{
		AlertList: entity.AlertList{
			Id:                125,
			AlertPoint:        "容器云/apaas",
			AlertRulesId:      "762ed641-6c0e-4c39-bf7c-7463abb0f8a2",
			RiskLevel:         3,
			AlertTime:         now,
			ClassId:           14,
			ClassParentName:   "预警分类",
			ClassName:         "预警对象",
			MetricConfigId:    "d773b37b-dbb4-4a7b-be11-ab40f8acc00e",
			MetricConfigName:  "响应时间超时",
			AlertRuleType:     "51a2cc1e-eb24-4b16-b106-3dc9db963a49",
			CurrentValue:      85,
			NotificationCount: 1,
			PushCount:         1,
			LastPushTime:      now,
			Status:            1,
			IsDisposed:        1,
			DisposalContent:   "处置内容为已恢复",
			CreatedBy:         "admin",
			CreatedAt:         now,
			UpdatedBy:         "admin",
			UpdatedAt:         now,
		},
		AlertCondition: entity.AlertCondition{
			ThresholdsMax: 80,
			ThresholdsMin: 50,
			RiskLevel:     3,
		},
	}
	resp.List = append(resp.List, data1, data2)
	resp.TotalCount = int64(len(resp.List))
	return
}