Explorar o código

优化计算指标刷新

longyu %!s(int64=2) %!d(string=hai) anos
pai
achega
f50acc63a6
Modificáronse 1 ficheiros con 7 adicións e 2 borrados
  1. 7 2
      services/data/edb_info.go

+ 7 - 2
services/data/edb_info.go

@@ -602,6 +602,7 @@ func CheckThsDataInterface(cont context.Context) (err error) {
 
 // RefreshDataFromCalculateAll 刷新所有计算指标
 func RefreshDataFromCalculateAll() (err error) {
+	var errmsg string
 	defer func() {
 		if err != nil {
 			utils.FileLog.Info("RefreshDataFromCalculateAll Err:" + err.Error())
@@ -852,12 +853,16 @@ func RefreshDataFromCalculateAll() (err error) {
 		fmt.Println("RefreshEdbCalculateData", v.EdbInfoId, v.EdbCode, startDate)
 		result, err := RefreshEdbCalculateData(v.EdbInfoId, v.EdbCode, startDate)
 		if err != nil {
+			errmsg += v.EdbCode + ","
 			err = errors.New("RefreshEdbCalculateData Err:" + err.Error())
-			return err
+			//return err
+			continue
 		}
 		if result.Ret != 200 {
+			errmsg += v.EdbCode + ","
 			err = errors.New("RefreshEdbCalculateData err;msg:" + result.Msg + ";errMsg:" + result.ErrMsg)
-			return err
+			//return err
+			continue
 		}
 
 		//maxAndMinItem, err := data_manage.GetEdbInfoMaxAndMinInfo(source, edbCode)