钢联化工汇总统计调整

controllers/edb_info_stat.go

@@ -21,8 +21,8 @@ func (this *EdbInfoStatController) SetEdbSourceStat() {
 		this.ServeJSON()
 	}()
 	// 钢联终端统计汇总
-	_ = services.SetMysteelChemicalEdbInfoUpdateStat()
-	_ = services.SetEdbSourceStat()
+	_ = services.SetMysteelChemicalEdbInfoUpdateStat(true)
+	_ = services.SetEdbSourceStat(true)
 
 	br.Ret = 200
 	br.Success = true

services/base_from_mysteel_chemical.go

@@ -23,8 +23,8 @@ func HandleMysteelIndex(req *models.HandleMysteelIndexResp) (err error) {
 
 	go func() {
 		// 钢联终端统计汇总
-		_ = SetMysteelChemicalEdbInfoUpdateStat()
-		_ = SetEdbSourceStat()
+		_ = SetMysteelChemicalEdbInfoUpdateStat(false)
+		_ = SetEdbSourceStat(false)
 	}()
 	return
 }

services/edb_info_stat.go

@@ -56,7 +56,7 @@ func AddEdbInfoUpdateLog(edbInfoId int, updateResult int, updateFailedReason str
 }
 
 // SetMysteelChemicalEdbInfoUpdateStat 定时统计钢联化工的数据源明细表
-func SetMysteelChemicalEdbInfoUpdateStat() (err error) {
+func SetMysteelChemicalEdbInfoUpdateStat(needStat bool) (err error) {
 	defer func() {
 		if err != nil {
 			tips := fmt.Sprintf("钢联数据刷新-ETA指标刷新统计异常 Err: %s", err.Error())
@@ -82,6 +82,9 @@ func SetMysteelChemicalEdbInfoUpdateStat() (err error) {
 		err = fmt.Errorf("查询钢联化工指标终端更新日志报错，err: %s", err)
 		return
 	}
+	if !needStat && len(updateLogList) == 0 {
+		return
+	}
 	updateLogMap := make(map[int]*data_stat.EdbInfoUpdateLog)
 	if len(updateLogList) > 0 {
 		for _, v := range updateLogList {
@@ -205,7 +208,7 @@ func checkMySteelEdbInfoNeedRefresh(frequency string) (needRefresh int, err erro
 }
 
 // SetEdbSourceStat 定时统计数据源汇总表
-func SetEdbSourceStat() (err error) {
+func SetEdbSourceStat(needStat bool) (err error) {
 	defer func() {
 		if err != nil {
 			tips := fmt.Sprintf("钢联数据刷新-ETA指标刷新统计异常 Err: %s", err.Error())
@@ -226,6 +229,9 @@ func SetEdbSourceStat() (err error) {
 		err = fmt.Errorf("查询钢联化工数据源明细记录统计报错，err: %s", err)
 		return
 	}
+	if !needStat && len(updateStatList) == 0 {
+		return
+	}
 	updateStatMap := make(map[string][]*data_stat.EdbInfoUpdateStat)
 	if len(updateStatList) > 0 {
 		for _, v := range updateStatList {