package services import ( "eta/eta_index_lib/models" "eta/eta_index_lib/models/data_stat" "fmt" "time" ) // AddEdbInfoUpdateLog 添加指标编辑/刷新日志 func AddEdbInfoUpdateLog(edbInfoId int, updateResult int, updateFailedReason string, sourceUpdateResult int, sourceUpdateFailedReason string, sourceUpdateTime string) (err error) { var edbInfo *models.EdbInfo if edbInfoId > 0 { // 获取指标详情 edbInfo, err = models.GetEdbInfoById(edbInfoId) if err != nil { err = fmt.Errorf("指标不存在") return } log := new(data_stat.EdbInfoUpdateLog) log.EdbInfoId = edbInfo.EdbInfoId log.SourceName = edbInfo.SourceName log.Source = edbInfo.Source log.EdbCode = edbInfo.EdbCode log.EdbName = edbInfo.EdbName log.EdbNameSource = edbInfo.EdbNameSource log.Frequency = edbInfo.Frequency log.Unit = edbInfo.Unit log.StartDate = edbInfo.StartDate log.EndDate = edbInfo.EndDate log.SysUserId = edbInfo.SysUserId log.SysUserRealName = edbInfo.SysUserRealName log.UniqueCode = edbInfo.UniqueCode log.EdbCreateTime = edbInfo.CreateTime log.EdbModifyTime = edbInfo.ModifyTime log.CreateTime = time.Now() log.UpdateTime = time.Now() log.LatestDate = edbInfo.LatestDate log.LatestValue = edbInfo.LatestValue log.TerminalCode = edbInfo.TerminalCode log.UpdateResult = updateResult log.UpdateFailedReason = updateFailedReason log.DataUpdateTime = edbInfo.DataUpdateTime log.ErDataUpdateDate = edbInfo.ErDataUpdateDate log.SourceUpdateResult = sourceUpdateResult log.SourceUpdateTime = sourceUpdateTime log.SourceUpdateFailedReason = sourceUpdateFailedReason _, err = data_stat.AddEdbUpdateLog(log) if err != nil { err = fmt.Errorf("新增指标更新日志失败,Err: %s", err) return } } return }