客户初始化分类、标签方法调整

epmet-module/gov-issue/gov-issue-server/pom.xml

@@ -102,6 +102,12 @@
             <version>2.0.0</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>com.epmet</groupId>
+            <artifactId>oper-crm-client</artifactId>
+            <version>2.0.0</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 
     <build>

epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueProjectCategoryDictServiceImpl.java

@@ -30,10 +30,7 @@ import com.epmet.commons.tools.utils.Result;
 import com.epmet.dao.IssueCategoryDao;
 import com.epmet.dao.IssueProjectCategoryDictDao;
 import com.epmet.dao.IssueProjectRelationDao;
-import com.epmet.dto.IssueCategoryDTO;
-import com.epmet.dto.IssueDTO;
-import com.epmet.dto.IssueProjectCategoryDictDTO;
-import com.epmet.dto.ProjectCategoryDTO;
+import com.epmet.dto.*;
 import com.epmet.dto.form.*;
 import com.epmet.dto.result.CustomerCategoryListResultDTO;
 import com.epmet.dto.result.ProjectCategoryDTOResultDTO;
@@ -42,6 +39,7 @@ import com.epmet.dto.result.ProjectIssueDTOResultDTO;
 import com.epmet.entity.IssueProjectCategoryDictEntity;
 import com.epmet.entity.IssueProjectTagDictEntity;
 import com.epmet.feign.GovProjectOpenFeignClient;
+import com.epmet.feign.OperCrmOpenFeignClient;
 import com.epmet.project.dto.result.ProjectCategoryDictResultDTO;
 import com.epmet.redis.IssueProjectCategoryDictRedis;
 import com.epmet.service.IssueProjectCategoryDictService;
@@ -76,11 +74,12 @@ public class IssueProjectCategoryDictServiceImpl extends BaseServiceImpl<IssuePr
     private IssueProjectRelationDao issueProjectRelationDao;
     @Autowired
     private IssueProjectTagDictService issueProjectTagDictService;
-
     @Autowired
     private IssueCategoryDao issueCategoryDao;
     @Autowired
     private GovProjectOpenFeignClient govProjectOpenFeignClient;
+    @Autowired
+    private OperCrmOpenFeignClient operCrmOpenFeignClient;
 
     @Override
     public PageData<IssueProjectCategoryDictDTO> page(Map<String, Object> params) {
@@ -199,21 +198,35 @@ public class IssueProjectCategoryDictServiceImpl extends BaseServiceImpl<IssuePr
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void init(CategoryTagInitFormDTO formDTO) {
-        List<IssueProjectCategoryDictEntity> list = baseDao.selectCategoryListByCustomer(formDTO.getCustomerId());
-        if (CollectionUtils.isEmpty(list)) {
-            //分类初始化
-            List<IssueProjectCategoryDictEntity> categoryList = baseDao.selectCategoryListByCustomer("default");
-            categoryList.forEach(item -> {
-                item.setCustomerId(formDTO.getCustomerId());
-            });
-            this.insertBatch(categoryList);
-            //标签初始化
-            List<IssueProjectTagDictEntity> tagList = issueProjectTagDictService.getTagListByCustomer("default");
-            tagList.forEach(item -> {
-                item.setCustomerId(formDTO.getCustomerId());
-            });
-            issueProjectTagDictService.insertBatch(tagList);
+        //2021.3.23 sun  不传客户Id时默认查询所有有效客户列表 循环添加
+        List<String> customerIdList = new ArrayList<>();
+        if(StringUtils.isBlank(formDTO.getCustomerId())){
+            Result<List<CustomerDTO>> resultList = operCrmOpenFeignClient.getAllCustomerList();
+            if(!resultList.success()){
+                throw new RuntimeException("crm库获取有效客户列表失败！");
+            }
+            customerIdList = resultList.getData().stream().map(cu->cu.getId()).collect(Collectors.toList());
+        }else {
+            customerIdList.add(formDTO.getCustomerId());
         }
+        //end  sun
+        customerIdList.forEach(cu->{
+            List<IssueProjectCategoryDictEntity> list = baseDao.selectCategoryListByCustomer(formDTO.getCustomerId());
+            if (CollectionUtils.isEmpty(list)) {
+                //分类初始化
+                List<IssueProjectCategoryDictEntity> categoryList = baseDao.selectCategoryListByCustomer("default");
+                categoryList.forEach(item -> {
+                    item.setCustomerId(formDTO.getCustomerId());
+                });
+                this.insertBatch(categoryList);
+                //标签初始化
+                List<IssueProjectTagDictEntity> tagList = issueProjectTagDictService.getTagListByCustomer("default");
+                tagList.forEach(item -> {
+                    item.setCustomerId(formDTO.getCustomerId());
+                });
+                issueProjectTagDictService.insertBatch(tagList);
+            }
+        });
     }
 
     /**

epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueProjectCategoryDictDao.xml

@@ -46,6 +46,7 @@
             ID,
             PID,
             PIDS,
+            PARENT_CATEGORY_CODE,
             CATEGORY_CODE,
             CATEGORY_NAME,
             CATEGORY_TYPE,