【政策配置通知采集】

src/main/java/com/zzsn/event/controller/SubjectManageController.java

@@ -418,6 +418,7 @@ public class SubjectManageController {
             configurationMessageService.bindInfoSourceSend(subject.getId());
             configurationMessageService.bindKeyWordsSend(subject.getId());
             configurationMessageService.subjectEnterpriseSourceSync(subject.getId());
+            configurationMessageService.subjectPolicySourceSync(subject.getId());
         }
         try {
             String res = caiJiCenterHttpService.subjectStatusEdit(subject.getStatus(), subject.getId());

src/main/java/com/zzsn/event/service/impl/CaiJiCenterHttpService.java

@@ -33,7 +33,8 @@ public class CaiJiCenterHttpService {
     private String delSubjectUrl;
     @Value("${caiji.subjectEnterpriseSource.url:http://1.95.79.85:8823/baseSourceInfo/api/subject/saveCompanyData}")
     private String subjectEnterpriseSourceUrl;
-
+    @Value("${caiji.subjectPolicySource.url:http://1.95.79.85:8823/baseSourceInfo/api/subject/savePoliciesData}")
+    private String subjectPolicySourceUrl;
 
     @Value("${caiji.projectCode:zzsn_test}")
     private String projectCode;
@@ -75,7 +76,12 @@ public class CaiJiCenterHttpService {
         return post.execute().body();
     }
 
-
+    /**专题政策来源数据配置通知采集*/
+    public String subjectPolicySource(Map<String,Object> map) {
+        log.info("专题政策来源数据配置通知采集{}-{}",subjectPolicySourceUrl,JSONUtil.toJsonStr(map));
+        HttpRequest post = post(subjectPolicySourceUrl,map);
+        return post.execute().body();
+    }
     /**编辑关键词通知采集*/
     public String keyWordsEditUrl(Map<String,Object> map) {
         log.info("编辑关键词通知采集{}-{}",keyWordsEditUrl,JSONUtil.toJsonStr(map));

src/main/java/com/zzsn/event/service/impl/ConfigurationMessageService.java

@@ -707,7 +707,63 @@ public class ConfigurationMessageService {
         return JSONUtil.toJsonStr(param);
 
     }
+    public void subjectPolicySourceSync(String subjectId){
+        Subject subject = subjectService.getById(subjectId);
+        if (subject == null || subject.getStatus() == null || subject.getStatus() != 1) {
+            log.info("未查询到专题或专题未启用");
+            return;
+        }
+        try {
+            remoteModelService.delSubjectCache(subjectId);
+        } catch (Exception e) {
+            log.error("删除专题缓存失败{}",e.getMessage(),e);
+        }
+        List<SubjectAddition> resu = new ArrayList<>();
 
+        //获取专题配置的政策来源
+        List<SubjectAddition> subjectAdditionsPolicy = subjectAdditionMapper.selectList(Wrappers.<SubjectAddition>lambdaQuery()
+                .eq(SubjectAddition::getSubjectId, subject.getId())
+                .eq(SubjectAddition::getAdditionType, 3));
+
+        if (CollectionUtil.isNotEmpty(subjectAdditionsPolicy)) {
+            resu.addAll(subjectAdditionsPolicy);
+        }
+
+
+        List<String> labelIds = resu.stream().map(SubjectAddition::getAdditionRelationId).distinct().collect(Collectors.toList());
+
+        Map<String, Object> policyParam = getPolicyParam(subject, labelIds);
+
+        String post = caiJiCenterHttpService.subjectPolicySource(policyParam);
+
+        JSONObject entries = JSONUtil.parseObj(post);
+        //获取code状态码
+        Integer code = entries.getInt("code");
+        if (ObjectUtil.isEmpty(code) ||  code != 200) {
+            log.error("专题政策来源配置通知采集失败{}",post);
+            throw new RuntimeException("专题政策来源配置通知采集失败");
+        }
+        log.info("{}专题政策来源配置通知采集结束",subject.getSubjectName());
+    }
+
+    private  Map<String,Object> getPolicyParam(Subject subject, List<String> labelIds) {
+        Map<String,Object> param = new HashMap<>();
+        param.put("subjectSign",subject.getId());
+        param.put("subjectName",subject.getSubjectName());
+        param.put("customerSign",caiJiCenterHttpService.getProjectCode());
+        param.put("customerName",caiJiCenterHttpService.getProjectName());
+//        param.put("additionDataType",subject.getAdditionDataType());
+        param.put("organs",labelIds);
+        if (ObjectUtil.isNotNull(subject.getTimeEnable())) {
+            param.put("startTime", DateUtil.format(subject.getTimeEnable(),"yyyy-MM-dd HH:mm:ss"));
+        }else {
+            param.put("startTime",DateUtil.format(getPreviousMonths(LocalDateTime.now(),6),"yyyy-MM-dd HH:mm:ss"));
+        }
+        if (ObjectUtil.isNotNull(subject.getTimeDisable())) {
+            param.put("endTime",DateUtil.format(subject.getTimeDisable(),"yyyy-MM-dd HH:mm:ss"));
+        }
+        return param;
+    }
 
     //日期往前推 num 个月
     public static LocalDateTime getPreviousMonths(LocalDateTime date , int num) {