eta_task/models/data_manage/edb_inspection/edb_inspection_config.go

package edb_inspection

import (
	"eta/eta_task/global"
	"eta/eta_task/utils"
	"time"
)

// EdbInspectionConfig
// @Description: 数据源巡检配置表
type EdbInspectionConfig struct {
	ConfigId          int64     `gorm:"column:config_id;primaryKey;autoIncrement"`
	Source           int       `gorm:"column:source"`
	TerminalCode     string    `gorm:"column:terminal_code"`
	DateType   int8      `gorm:"column:date_type"`
	StartTime        string    `gorm:"column:start_time"`
	IntervalTime     int       `gorm:"column:interval_time"`
	NotifyUsers      string    `gorm:"column:notify_users"`
	Status           int8      `gorm:"column:status"`
	CreateTime       time.Time `gorm:"column:create_time"`
	ModifyTime       time.Time `gorm:"column:modify_time"`
	InspectionTime   string    `gorm:"-"` // 用于显示巡检时间，不存储到数据库
}

type EdbInspectionConfigList struct {
	EdbInspectionConfig
	TerminalName string 
}
// Add
// @Description: 添加巡检配置
// @receiver m
// @return err error
func (m *EdbInspectionConfig) Add() (err error) {
	m.CreateTime = time.Now()
	m.ModifyTime = time.Now()
	err = global.DbMap[utils.DbNameIndex].Create(m).Error
	return
}

// Update
// @Description: 更新巡检配置
// @receiver m
// @param cols []string
// @return err error
func (m *EdbInspectionConfig) Update(cols []string) (err error) {
	m.ModifyTime = time.Now()
	err = global.DbMap[utils.DbNameIndex].Select(cols).Updates(m).Error
	return
}

// Delete
// @Description: 删除巡检配置
// @receiver m
// @return err error
func (m *EdbInspectionConfig) Delete() (err error) {
	sql := `DELETE FROM edb_inspection_config WHERE config_id = ?`
	err = global.DbMap[utils.DbNameIndex].Exec(sql, m.ConfigId).Error
	return
}

// UpdateStatus
// @Description: 更新巡检配置状态
// @receiver m
// @param status int8
// @return err error
func (m *EdbInspectionConfig) UpdateStatus(status int8) (err error) {
	sql := `UPDATE edb_inspection_config SET status = ?, modify_time = ? WHERE config_id = ?`
	err = global.DbMap[utils.DbNameIndex].Exec(sql, status, time.Now(), m.ConfigId).Error
	return
}

// GetListByTerminalCode
// @Description: 根据终端编码获取巡检配置列表
// @param terminalCode string
// @return list []*EdbInspectionConfig
// @return err error
func GetListByTerminalCode(terminalCode string) (list []*EdbInspectionConfig, err error) {
	sql := `SELECT * FROM edb_inspection_config WHERE terminal_code = ? ORDER BY config_id ASC`
	err = global.DbMap[utils.DbNameIndex].Raw(sql, terminalCode).Find(&list).Error
	return
}

// GetById
// @Description: 根据ID获取巡检配置
// @param configId int64
// @return item *EdbInspectionConfig
// @return err error
func GetById(configId int64) (item *EdbInspectionConfig, err error) {
	sql := `SELECT * FROM edb_inspection_config WHERE config_id = ?`
	err = global.DbMap[utils.DbNameIndex].Raw(sql, configId).First(&item).Error
	return
}

// GetListBySource
// @Description: 根据来源获取巡检配置列表
// @param source int
// @return list []*EdbInspectionConfig
// @return err error
func GetListBySource(source int) (list []*EdbInspectionConfig, err error) {
	sql := `SELECT * FROM edb_inspection_config WHERE source = ? ORDER BY config_id ASC`
	err = global.DbMap[utils.DbNameIndex].Raw(sql, source).Find(&list).Error
	return
}

// 获取所有启用的配置项
func GetAllEnabledConfigs() (list []*EdbInspectionConfigList, err error) {
	sql := `SELECT c.*, t.name AS terminal_name FROM edb_inspection_config c left join edb_terminal t on c.terminal_code = t.terminal_code WHERE c.status = 1 and t.status = 1 ORDER BY c.modify_time DESC`
	err = global.DbMap[utils.DbNameIndex].Raw(sql).Find(&list).Error
	return
}

func GetConfigListBySourceAndTerminalCode(source int, terminalCode string) (list []*EdbInspectionConfigItem, err error) {
	condition := " c.source = ? "
	var pars []interface{}
	pars = append(pars, source)

	if terminalCode != "" {
		condition += " AND c.terminal_code = ? "
		pars = append(pars, terminalCode)
	}

	sql := `SELECT c.*, t.name AS terminal_name, s.source_name FROM edb_inspection_config c left join edb_terminal t on c.terminal_code = t.terminal_code left join edb_source s on c.source = s.edb_source_id WHERE ` + condition + ` ORDER BY c.modify_time DESC`
	err = global.DbMap[utils.DbNameIndex].Raw(sql, pars...).Find(&list).Error
	return
}

type EdbInspectionConfigAddReq struct {
	ConfigId          int64    
	Source           int       
	TerminalCode     string    
	NotifyUsers         string `description:"通知用户"`
	//Status              int8   `description:"状态"` 
	DateType   int8      
	StartTime         string 
	IntervalTime      int   
	List      []InspectionConfigReq `description:"刷新配置项"`
}

// @Description: 刷新时间配置项
type InspectionConfigReq struct {
	InspectionFrequency string `description:"巡检频率"`
	InspectionFrequencyDay        int    `description:"具体刷新的日期"`
	InspectionDate      string `description:"巡检日期"`
	InspectionTime      string `description:"巡检时间"`
}

type EdbInspectionConfigDetailResp struct {
	*EdbInspectionConfig
	List      []InspectionConfigReq `description:"刷新配置项"`
}

type EdbInspectionConfigItem struct {
	ConfigId          int64    
	Source           int       
	SourceName       string
	TerminalCode     string    
	TerminalName     string
	StartTime        string `description:"开始时间"`
	IntervalTime     int    `description:"间隔时间"`
	NotifyUsers         string `description:"通知用户"`
	NotifyUsersName   string `description:"通知用户名称"`
	Status              int8   `description:"状态"` 
	DateType   int8      
	InspectionTime   string `description:"巡检时间"`
}

type EdbInspectionConfigStatusReq struct {
	ConfigId int64 `description:"配置ID"`
	Status   int8  `description:"状态"`
}

type EdbInspectionConfigDeleteReq struct {
	ConfigId int64 `description:"配置ID"`
}