合并分支 'event_fusion_dev' 到 'event_fusion'

资讯审核增加央企舆情重大模型逻辑

查看合并请求 !28

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

@@ -849,10 +849,28 @@ public class InformationServiceImpl implements InformationService {
                     dataCheckLog = DataLifecycleLog.createDataCheckLog(subjectdatabase, operateUser, sourceName, EnumHandlerStatus.TEMPORARY);
                 }
                 kafkaTemplate.send("data_lifecycle_log_data_check", JSONUtil.toJsonStr(dataCheckLog));
+                //其他项目对接逻辑
+                //央企舆情重大舆情 labelMark = important  说明是重大舆情
+                try {
+                    if (checkStatus == 1) {
+                        List<Label> labels = subjectdatabase.getLabels();
+                        Optional<Label> important = labels.stream().filter(label -> label.getLabelMark().equals("important")).findAny();
+                        if (important.isPresent()) {
+                            String articleId = subjectdatabase.getId();
+                            Map<String, String> params = new HashMap<>();
+                            params.put("articleId", articleId);
+                            HttpUtil.doGet("http://1.95.72.34:7051/yqyq/majorPublicOpinionSync", params,null, "utf-8");
+                            log.info("央企舆情-重大舆情推送接口调用成功,{}", articleId);
+                        }
+                    }
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
                 //评价中心审核逻辑
                 if (subjectdatabase.getSubjectId().equals("1933103248232779778")) {
                     subjectdatabase.setDbIndex(index);
                     kafkaTemplate.send("gzjg_information", JSONUtil.toJsonStr(subjectdatabase));
+                    log.info("评价中心数据推送kafka成功,{}", subjectdatabase.getId());
                 }
             });
         }