|
|
@@ -2102,6 +2102,7 @@ func (this *CalculateController) BatchSaveMulti() {
|
|
|
var wg sync.WaitGroup
|
|
|
// 校验参数
|
|
|
for _, item := range req.EdbList {
|
|
|
+
|
|
|
calculateId := item.CalculateId
|
|
|
//加入缓存机制，避免创建同一个名称的指标 start
|
|
|
redisKey := fmt.Sprint("edb_info:calculate:batch:save:", req.AdminId, ":", req.Source, ":", calculateId)
|
|
|
@@ -2138,9 +2139,10 @@ func (this *CalculateController) BatchSaveMulti() {
|
|
|
MaxEmptyType: req.MaxEmptyType,
|
|
|
Extra: req.Extra,
|
|
|
}
|
|
|
- var errMsg string
|
|
|
+
|
|
|
var edbInfo *models.EdbInfo
|
|
|
uniqueCode := ""
|
|
|
+ errMsg := ""
|
|
|
go func() {
|
|
|
defer func() {
|
|
|
// todo 批量报错处理
|
|
|
@@ -2170,11 +2172,6 @@ func (this *CalculateController) BatchSaveMulti() {
|
|
|
}()
|
|
|
}
|
|
|
wg.Wait()
|
|
|
- if err != nil {
|
|
|
- br.Msg = "批量指标计算，保存失败"
|
|
|
- br.ErrMsg = "批量指标计算，保存失败，Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
br.Ret = 200
|
|
|
br.Success = true
|
|
|
br.Msg = "保存成功"
|
