Bläddra i källkod

修改钢联化工更新统计bug

xyxie 1 år sedan
förälder
incheckning
673c84c137
2 ändrade filer med 4 tillägg och 3 borttagningar
  1. 3 2
      models/data_stat/edb_info_update_stat.go
  2. 1 1
      services/base_from_mysteel_chemical.go

+ 3 - 2
models/data_stat/edb_info_update_stat.go

@@ -71,7 +71,8 @@ data_update_result = ?,
 data_update_failed_reason = ?,
 data_update_time = ?, 
 update_result = ?,
-update_failed_reason = ?
+update_failed_reason = ?,
+update_time = ?
 WHERE
 	id = ?`
 	p, err := o.Raw(sql).Prepare()
@@ -82,7 +83,7 @@ WHERE
 		_ = p.Close() // 别忘记关闭 statement
 	}()
 	for _, v := range list {
-		_, err = p.Exec(v.EdbName, v.EdbNameSource, v.Frequency, v.Unit, v.StartDate, v.EndDate, v.EdbModifyTime, v.LatestDate, v.LatestValue, v.TerminalCode, v.ModifyTime, v.ErDataUpdateDate, v.IsAdd, v.NeedRefresh, v.HasRefresh, v.DataUpdateResult, v.DataUpdateFailedReason, v.DataUpdateTime, v.UpdateResult, v.UpdateFailedReason, v.Id)
+		_, err = p.Exec(v.EdbName, v.EdbNameSource, v.Frequency, v.Unit, v.StartDate, v.EndDate, v.EdbModifyTime, v.LatestDate, v.LatestValue, v.TerminalCode, v.ModifyTime, v.ErDataUpdateDate, v.IsAdd, v.NeedRefresh, v.HasRefresh, v.DataUpdateResult, v.DataUpdateFailedReason, v.DataUpdateTime, v.UpdateResult, v.UpdateFailedReason, v.UpdateTime, v.Id)
 		if err != nil {
 			return
 		}

+ 1 - 1
services/base_from_mysteel_chemical.go

@@ -162,7 +162,6 @@ func handleIndex(indexItem *models.HandleMysteelIndex) (err error) {
 				dataItem.CreateTime = time.Now()
 				dataItem.ModifyTime = time.Now()
 				addDataList = append(addDataList, *dataItem)
-				hasUpdate = true
 			}
 		} else {
 			if findData != nil && findData.Value != value && !strings.Contains(value, "#N/A") { //修改数据
@@ -229,6 +228,7 @@ func handleIndex(indexItem *models.HandleMysteelIndex) (err error) {
 
 			if hasUpdate {
 				dataUpdateResult = 1
+				dataUpdateFailedReason = ""
 			} else {
 				dataUpdateFailedReason = "未刷新到数据"
 			}