|
@@ -239,10 +239,10 @@ func edbInfoRefreshAll(refreshAll bool, newBaseEdbInfoArr, newBasePredictEdbInfo
|
|
//source := bv.Source
|
|
//source := bv.Source
|
|
//edbInfoId := bv.EdbInfoId
|
|
//edbInfoId := bv.EdbInfoId
|
|
//edbCode := bv.EdbCode
|
|
//edbCode := bv.EdbCode
|
|
- fmt.Println(bv.StartDate)
|
|
|
|
- if utils.TimeToFormatDate(bv.StartDate) == "0000-00-00" {
|
|
|
|
- continue
|
|
|
|
- }
|
|
|
|
|
|
+ //fmt.Println(bv.StartDate)
|
|
|
|
+ //if utils.TimeToFormatDate(bv.StartDate) == "0000-00-00" {
|
|
|
|
+ // continue
|
|
|
|
+ //}
|
|
//开始时间
|
|
//开始时间
|
|
startDate = ``
|
|
startDate = ``
|
|
if refreshAll { //刷新所有数据,那么就是从配置的开始时间开始刷新
|
|
if refreshAll { //刷新所有数据,那么就是从配置的开始时间开始刷新
|
|
@@ -284,7 +284,7 @@ func edbInfoRefreshAll(refreshAll bool, newBaseEdbInfoArr, newBasePredictEdbInfo
|
|
return fmt.Errorf("刷新失败, err:", errmsg)
|
|
return fmt.Errorf("刷新失败, err:", errmsg)
|
|
}
|
|
}
|
|
|
|
|
|
- fmt.Println("end newBaseEdbInfoArr:", bv, time.Now())
|
|
|
|
|
|
+ //fmt.Println("end newBaseEdbInfoArr:", bv, time.Now())
|
|
}
|
|
}
|
|
|
|
|
|
//刷新相关普通计算指标
|
|
//刷新相关普通计算指标
|
|
@@ -395,7 +395,6 @@ func edbInfoRefreshAll(refreshAll bool, newBaseEdbInfoArr, newBasePredictEdbInfo
|
|
for _, v := range newBasePredictEdbInfoArr {
|
|
for _, v := range newBasePredictEdbInfoArr {
|
|
predictEdbInfoIdList = append(predictEdbInfoIdList, v.EdbInfoId)
|
|
predictEdbInfoIdList = append(predictEdbInfoIdList, v.EdbInfoId)
|
|
}
|
|
}
|
|
- fmt.Println("predictEdbConfCalculateMappingDetailList:", predictEdbInfoIdList)
|
|
|
|
predictEdbConfCalculateMappingDetailList, err := data_manage.GetPredictEdbConfCalculateMappingDetailListByEdbInfoId(predictEdbInfoIdList)
|
|
predictEdbConfCalculateMappingDetailList, err := data_manage.GetPredictEdbConfCalculateMappingDetailListByEdbInfoId(predictEdbInfoIdList)
|
|
if err != nil {
|
|
if err != nil {
|
|
errmsg = fmt.Sprint("更新动态环差值时,获取数据失败:" + err.Error())
|
|
errmsg = fmt.Sprint("更新动态环差值时,获取数据失败:" + err.Error())
|
|
@@ -413,7 +412,7 @@ func edbInfoRefreshAll(refreshAll bool, newBaseEdbInfoArr, newBasePredictEdbInfo
|
|
errmsg = fmt.Sprint(bv.EdbInfoId, "RefreshBasePredictEdbData err;msg:", result.Msg, ";errMsg:", result.ErrMsg)
|
|
errmsg = fmt.Sprint(bv.EdbInfoId, "RefreshBasePredictEdbData err;msg:", result.Msg, ";errMsg:", result.ErrMsg)
|
|
return fmt.Errorf("刷新失败, err:%s", errmsg)
|
|
return fmt.Errorf("刷新失败, err:%s", errmsg)
|
|
}
|
|
}
|
|
- fmt.Println("end predictEdbConfCalculateMappingDetailList:", bv, time.Now())
|
|
|
|
|
|
+ //fmt.Println("end predictEdbConfCalculateMappingDetailList:", bv, time.Now())
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -632,7 +631,7 @@ func EdbInfoRefresh(edbInfo *data_manage.EdbInfoView, refreshAll bool) (err erro
|
|
errmsg = fmt.Sprint(bv.EdbInfoId, "RefreshBasePredictEdbData err;msg:", result.Msg, ";errMsg:", result.ErrMsg)
|
|
errmsg = fmt.Sprint(bv.EdbInfoId, "RefreshBasePredictEdbData err;msg:", result.Msg, ";errMsg:", result.ErrMsg)
|
|
return fmt.Errorf("刷新失败, err:%s", errmsg)
|
|
return fmt.Errorf("刷新失败, err:%s", errmsg)
|
|
}
|
|
}
|
|
- fmt.Println("end predictEdbConfCalculateMappingDetailList:", bv, time.Now())
|
|
|
|
|
|
+ //fmt.Println("end predictEdbConfCalculateMappingDetailList:", bv, time.Now())
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|