粮油商务网-指标库领取状态修改

controllers/data_manage/base_from_ly_index_controller.go

@@ -310,7 +310,6 @@ func (this *BaseFromLyIndexController) LyIndexAdd() {
 			continue
 		}
 
-		// todo 下面两段代码能否抽离出来？？？
 		// 试用平台更新用户累计新增指标数
 		if utils.BusinessCode == utils.BusinessCodeSandbox {
 			go func() {

services/data/base_from_ly_index_service.go

@@ -56,6 +56,16 @@ func GetIndexPage(classifyId string, searchParam string, currentIndex, pageSize
 		lyDataMap[v.IndexCode] = v
 	}
 
+	// 查询指标库是否已添加  不做另外补偿维护index表中的edb_exist字段，直接去查，因为维护会改变指标库指标添加代码结构
+	edbInfoList, err := data_manage.GetEdbInfoByEdbCodeList(utils.DATA_SOURCE_LY, indexCodes)
+	if err != nil {
+		return nil, err
+	}
+	edbInfoMap := make(map[string]*data_manage.EdbInfo)
+	for _, v := range edbInfoList {
+		edbInfoMap[v.EdbCode] = v
+	}
+
 	if len(lyIndexData) > 0 {
 		for _, v := range lyIndexList {
 			if lyIndexDataMap[v.IndexCode] != nil {
@@ -65,6 +75,9 @@ func GetIndexPage(classifyId string, searchParam string, currentIndex, pageSize
 			if lyDataMap[v.IndexCode] != nil {
 				v.Value = lyDataMap[v.IndexCode].Value
 			}
+			if edbInfoMap[v.IndexCode] != nil {
+				v.EdbExist = utils.IS_YES
+			}
 		}
 	}
 
@@ -223,13 +236,13 @@ func LyIndexAdd(req LyIndexAddReq, lang string) (edb *data_manage.EdbInfo, err e
 	edb = edbInfo
 
 	// 标记原始指标为已添加
-	err = data_manage.UpdateLyIndexEdbExist(req.EdbCode, utils.IS_YES)
+	/*err = data_manage.UpdateLyIndexEdbExist(req.EdbCode, utils.IS_YES)
 	if err != nil {
 		err = fmt.Errorf("BaseIndex: 标记已添加指标库失败, err: %s", err.Error())
 		return
-	}
+	}*/
 
-	// todo EdbInfoAdd方法已经新增es，这里不需要再新增？？？
+	// EdbInfoAdd方法已经新增es，这里不需要再新增？？？
 	// 新增es
 	// go AddOrEditEdbInfoToEs(edbInfo.EdbInfoId)
 	return

services/data/edb_classify.go

@@ -903,16 +903,6 @@ func Delete(classifyId, edbInfoId int, sysUser *system.Admin, requestBody, reque
 			return
 		}
 
-		// 维护粮油数据源指标领取状态
-		if edbInfo.Source == utils.DATA_SOURCE_LY {
-			tmpErr = data_manage.UpdateLyIndexEdbExist(edbInfo.EdbCode, utils.IS_NO)
-			if err != nil {
-				errMsg = "删除失败"
-				err = errors.New("删除失败，Err:" + tmpErr.Error())
-				return
-			}
-		}
-
 		// 如果是同花顺高频数据或类似数据, 还需要删除base_from_edb_mapping对应关系
 		baseMappingOb := new(data_manage.BaseFromEdbMapping)
 		{