删除数据、启用专题逻辑修改

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

@@ -324,11 +324,12 @@ public class SubjectManageController {
     @PostMapping("/updateStatus")
     public Result<?> updateStatus(@RequestBody Subject subject) {
         subjectService.updateStatus(subject);
+        Subject byId = subjectService.getById(subject.getId());
         xxlJobInfoService.update(Wrappers.<XxlJobInfo>lambdaUpdate()
-                .eq(XxlJobInfo::getInfoSourceCode, subject.getSubjectCode())
-                .set(XxlJobInfo::getTriggerStatus, subject.getStatus()));
+                .eq(XxlJobInfo::getInfoSourceCode, byId.getSubjectCode())
+                .set(XxlJobInfo::getTriggerStatus, byId.getStatus()));
         if (subject.getStatus() == 1) {
-            kafkaTemplate.send(SUBJECT_MODEL_KAFKA_CHANNEL, subject.getSubjectCode());
+            kafkaTemplate.send(SUBJECT_MODEL_KAFKA_CHANNEL, byId.getSubjectCode());
         }
         return Result.OK();
     }

src/main/java/com/zzsn/event/feign/api/RemoteModelService.java

@@ -29,5 +29,5 @@ public interface RemoteModelService {
      * @date 2025/2/7
      */
     @GetMapping("/modelArrange/clbBiz/delMiddelDataBySubjectId")
-    String removeMiddleDataRequest(@RequestParam("subjectId") String subjectId,@RequestHeader HttpHeaders headers);
+    String removeMiddleDataRequest(@RequestParam("subjectId") String subjectId);
 }

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

@@ -442,13 +442,8 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
             boolQuery.must(QueryBuilders.termQuery("subjectId.keyword", subjectId));
             esOpUtil.docDeleteByQuery(Constants.SUBJECT_INDEX, boolQuery);
         });
-        UserVo loginUser = UserUtil.getLoginUser();
-        CompletableFuture.runAsync(() ->{
-            HttpHeaders headers = new HttpHeaders();
-            headers.set("loginUser", JSON.toJSONString(loginUser));
-            remoteModelService.removeMiddleDataRequest(subjectId, headers);
-            log.info("专题-{}，删除中间库数据请求发送成功", subjectId);
-        });
+        remoteModelService.removeMiddleDataRequest(subjectId);
+        log.info("专题-{}，删除中间库数据请求发送成功", subjectId);
     }
 
     //目标集合按照另一个集合的顺序排序