Merge branch 'debug' of http://8.136.199.33:3000/eta_server/eta_index_lib into debug

services/base_from_mysteel_chemical.go

@@ -196,47 +196,47 @@ func handleIndex(indexItem *models.HandleMysteelIndex) (err error) {
 		}
 	}
 	// 同步刷新图库钢联的指标
-	go func() {
-		var indexErr error
-		var lErr error
-		defer func() {
-			if indexErr != nil {
-				tips := fmt.Sprintf("钢联数据刷新-ETA指标刷新异常, 指标编码: %s, err: %s", indexObj.IndexCode, indexErr.Error())
-				alarm_msg.SendAlarmMsg(tips, 3)
-			}
-
-			if lErr != nil {
-				tips := fmt.Sprintf("钢联数据刷新-ETA指标刷新统计异常, 指标编码: %s, err: %s", indexObj.IndexCode, lErr.Error())
-				alarm_msg.SendAlarmMsg(tips, 3)
-			}
-		}()
+	//go func() {
+	var indexErr error
+	var lErr error
+	defer func() {
+		if indexErr != nil {
+			tips := fmt.Sprintf("钢联数据刷新-ETA指标刷新异常, 指标编码: %s, err: %s", indexObj.IndexCode, indexErr.Error())
+			alarm_msg.SendAlarmMsg(tips, 3)
+		}
 
-		edbInfo, e := models.GetEdbInfoByEdbCode(utils.DATA_SOURCE_MYSTEEL_CHEMICAL, indexObj.IndexCode)
-		if e != nil && e.Error() != utils.ErrNoRow() {
-			indexErr = e
-			return
+		if lErr != nil {
+			tips := fmt.Sprintf("钢联数据刷新-ETA指标刷新统计异常, 指标编码: %s, err: %s", indexObj.IndexCode, lErr.Error())
+			alarm_msg.SendAlarmMsg(tips, 3)
 		}
+	}()
 
-		if edbInfo != nil {
-			dataUpdateResult := 2
-			dataUpdateFailedReason := "服务异常"
-			_, logErrMsg, logErr := logic.RefreshBaseEdbInfo(edbInfo, ``)
-			if logErr != nil {
-				lErr = AddEdbInfoUpdateLog(edbInfo.EdbInfoId, 2, logErrMsg+err.Error(), dataUpdateResult, dataUpdateFailedReason, 1)
-				return
-			}
+	edbInfo, e := models.GetEdbInfoByEdbCode(utils.DATA_SOURCE_MYSTEEL_CHEMICAL, indexObj.IndexCode)
+	if e != nil && e.Error() != utils.ErrNoRow() {
+		indexErr = e
+		return
+	}
 
-			if hasUpdate {
-				dataUpdateResult = 1
-				dataUpdateFailedReason = ""
-			} else {
-				dataUpdateFailedReason = "未刷新到数据"
-			}
+	if edbInfo != nil {
+		dataUpdateResult := 2
+		dataUpdateFailedReason := "服务异常"
+		_, logErrMsg, logErr := logic.RefreshBaseEdbInfo(edbInfo, ``)
+		if logErr != nil {
+			lErr = AddEdbInfoUpdateLog(edbInfo.EdbInfoId, 2, logErrMsg+err.Error(), dataUpdateResult, dataUpdateFailedReason, 1)
+			return
+		}
 
-			// 添加刷新成功日志
-			lErr = AddEdbInfoUpdateLog(edbInfo.EdbInfoId, 1, "", dataUpdateResult, dataUpdateFailedReason, 1)
+		if hasUpdate {
+			dataUpdateResult = 1
+			dataUpdateFailedReason = ""
+		} else {
+			dataUpdateFailedReason = "未刷新到数据"
 		}
-	}()
+
+		// 添加刷新成功日志
+		lErr = AddEdbInfoUpdateLog(edbInfo.EdbInfoId, 1, "", dataUpdateResult, dataUpdateFailedReason, 1)
+	}
+	//}()
 
 	return
 }