【删除命中词的同时删除es中的命中词】

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

@@ -2,14 +2,21 @@ package com.zzsn.event.service.impl;
 
 
 import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.zzsn.event.entity.ClbSubjectHitwordsMap;
 import com.zzsn.event.mapper.ClbSubjectHitwordsMapMapper;
 import com.zzsn.event.service.ClbSubjectHitwordsMapService;
+import com.zzsn.event.service.InformationService;
+import com.zzsn.event.vo.InfoDataSearchCondition;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
+import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.CompletableFuture;
 
 /**
  * <p>
@@ -20,14 +27,34 @@ import java.util.List;
  * @since 2025-04-23
  */
 @Service
+@Slf4j
 public class ClbSubjectHitwordsMapServiceImpl extends ServiceImpl<ClbSubjectHitwordsMapMapper, ClbSubjectHitwordsMap> implements ClbSubjectHitwordsMapService {
 
+    @Autowired
+    private InformationService informationService;
+
     @Override
     public void delEs(List<ClbSubjectHitwordsMap> clbSubjectHitwordsMaps) {
-        //TODO
+        if (CollectionUtils.isEmpty(clbSubjectHitwordsMaps)) {
+            return;
+        }
+        String subjectId = clbSubjectHitwordsMaps.get(0).getSubjectId();
+
+        InfoDataSearchCondition searchCondition = new InfoDataSearchCondition();
+        searchCondition.setSubjectId(subjectId);
+        searchCondition.setStatus(0);
+        searchCondition.setKeywordList(new ArrayList<>());
         if (CollectionUtil.isNotEmpty(clbSubjectHitwordsMaps)) {
 
+            for (ClbSubjectHitwordsMap clbSubjectHitwordsMap : clbSubjectHitwordsMaps) {
+                if (StrUtil.isNotBlank(clbSubjectHitwordsMap.getWordName())) {
+                    searchCondition.getKeywordList().add(clbSubjectHitwordsMap.getWordName());
+                }
+            }
 
         }
+        log.info("delEs:{}",searchCondition);
+        CompletableFuture.runAsync(()-> informationService.removeWordLabel(searchCondition));
+
     }
 }