定制专题 通知采集逻辑优化

src/main/java/com/zzsn/event/external/controller/ExternalController.java

 package com.zzsn.event.external.controller;
 
+import cn.hutool.json.JSONUtil;
 import cn.hutool.poi.excel.ExcelReader;
 import cn.hutool.poi.excel.ExcelUtil;
 import com.alibaba.fastjson2.JSON;
@@ -20,6 +21,8 @@ import com.zzsn.event.service.CommonService;
 import com.zzsn.event.service.InformationService;
 import com.zzsn.event.service.SubjectService;
 import com.zzsn.event.service.SubjectSimpleService;
+import com.zzsn.event.service.impl.CaiJiCenterHttpService;
+import com.zzsn.event.service.impl.ConfigurationMessageService;
 import com.zzsn.event.util.HttpUtil;
 import com.zzsn.event.util.ObjectUtil;
 import com.zzsn.event.util.RedisUtil;
@@ -28,6 +31,7 @@ import com.zzsn.event.vo.SubjectDetailVO;
 import com.zzsn.event.vo.SubjectSimpleVO;
 import com.zzsn.event.vo.TranslateVO;
 import com.zzsn.event.vo.es.DisplayInfo;
+import com.zzsn.event.xxljob.entity.XxlJobInfo;
 import com.zzsn.event.xxljob.service.IXxlJobInfoService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
@@ -35,10 +39,12 @@ import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 import org.springframework.web.multipart.MultipartHttpServletRequest;
 
+import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
@@ -74,11 +80,19 @@ public class ExternalController {
     private RedisUtil redisUtil;
     @Autowired
     SubjectService subjectService;
+    @Resource
+    private KafkaTemplate<String, String> kafkaTemplate;
+    @Autowired
+    private CaiJiCenterHttpService caiJiCenterHttpService;
+    @Autowired
+    private ConfigurationMessageService configurationMessageService;
 
     @Value("${caiji.keywordCrawler.url:}")
     private String keywordCrawlerUrl;
     @Value("${translate.url:}")
     private String TRANSLATE_URL;
+    @Value("${kafka.topic.subject.run:}")
+    private String SUBJECT_MODEL_KAFKA_CHANNEL;
 
     /**
      * 创建专题
@@ -116,6 +130,46 @@ public class ExternalController {
         return Result.OK();
     }
 
+
+    /**
+     * 更新状态
+     *
+     * @param subject
+     * @author lkg
+     * @date 2025/1/9
+     */
+    @PostMapping("/updateStatus")
+    public Result<?> updateStatus(@RequestBody Subject subject) {
+        subjectService.updateStatus(subject);
+        Subject byId = subjectService.getById(subject.getId());
+        List<XxlJobInfo> list = xxlJobInfoService.list(Wrappers.<XxlJobInfo>lambdaQuery().eq(XxlJobInfo::getInfoSourceCode, byId.getSubjectCode()));
+        if (CollectionUtils.isNotEmpty(list)) {
+            xxlJobInfoService.update(Wrappers.<XxlJobInfo>lambdaUpdate()
+                    .eq(XxlJobInfo::getInfoSourceCode, byId.getSubjectCode())
+                    .set(XxlJobInfo::getTriggerStatus, byId.getStatus()));
+        } else {
+            xxlJobInfoService.subjectInsert(byId);
+        }
+        if (subject.getStatus() == 1) {
+            kafkaTemplate.send(SUBJECT_MODEL_KAFKA_CHANNEL, byId.getSubjectCode());
+            configurationMessageService.bindKeyWordsSend(subject.getId(),1);
+        }
+        try {
+            String res = caiJiCenterHttpService.subjectStatusEdit(subject.getStatus(), subject.getId());
+            cn.hutool.json.JSONObject entries = JSONUtil.parseObj(res);
+            //获取code状态码
+            Integer code = entries.getInt("code");
+            if (cn.hutool.core.util.ObjectUtil.isEmpty(code) || code != 200) {
+                log.error("专题状态同步采集失败{}", res);
+            }
+        } catch (Exception e) {
+            log.error("专题状态同步采集失败{}", e.getMessage(), e);
+        }
+        return Result.OK();
+    }
+
+
+
     /**
      * 采集词推荐
      *

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

@@ -151,7 +151,7 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
         if (CollectionUtils.isNotEmpty(keywords)) {
             modifyKeyword(subjectId, subject.getSubjectName(), keywords);
             //同步配置到采集
-            configurationMessageService.bindKeyWordsSend(subjectId,1);
+            //configurationMessageService.bindKeyWordsSend(subjectId,1);
             //默认绑定tpu流程
             ClbModelArrangeSubjectMap tpu = new ClbModelArrangeSubjectMap();
             tpu.setSubjectId(subject.getId());