新增事件配置全量同步接口（通知采集）

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

@@ -39,6 +39,7 @@ import org.springframework.http.HttpHeaders;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
+import sun.security.pkcs10.PKCS10;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
@@ -68,6 +69,8 @@ public class SubjectManageController {
     @Autowired
     private SubjectService subjectService;
     @Autowired
+    private IEventService eventService;
+    @Autowired
     private ISubjectKeywordsMapService subjectKeywordsMapService;
     @Autowired
     private IXxlJobInfoService xxlJobInfoService;
@@ -431,9 +434,9 @@ public class SubjectManageController {
      * @author lkg
      * @date 2025/1/9
      */
-    @PostMapping("/updateAllToCaiji")
-    public Result<?> updateAllToCaiji() {
-        List<Subject> list = subjectService.list();
+    @PostMapping("/updateSubjectAllToCaiji")
+    public Result<?> updateSubjectAllToCaiji() {
+        List<Subject> list = subjectService.list(Wrappers.<Subject>lambdaQuery().eq(Subject::getSubjectType,1));
         for (int i = 0; i < list.size(); i++) {
             Subject subject = list.get(i);
             log.info("专题状态同步采集{},index:{},total:{}",subject.getSubjectName(),i,list.size());
@@ -449,6 +452,29 @@ public class SubjectManageController {
         }
         return Result.OK();
     }
+    /**
+     * 更新状态
+     *
+     * @author lkg
+     * @date 2025/1/9
+     */
+    @PostMapping("/updateEventAllToCaiji")
+    public Result<?> updateEventAllToCaiji() {
+        List<Event> list = eventService.list();
+        for (int i = 0; i < list.size(); i++) {
+            Event event = list.get(i);
+            log.info("事件状态同步采集{},index:{},total:{}",event.getEventName(),i,list.size());
+            if (event.getStatus()!=null && event.getStatus() == 1) {
+                configurationMessageService.bindKeyWordsEventSend(event.getId());
+                caiJiCenterHttpService.subjectStatusEdit(event.getStatus(), event.getId());
+                log.info("事件配置信息同步采集成功:{}",event.getEventName());
+            }else{
+                caiJiCenterHttpService.delSubject(event.getId());
+                log.info("通知采集删除事件成功:{}",event.getEventName());
+            }
+        }
+        return Result.OK();
+    }
 
     /**
      * 通过id删除