【情报二期】数据域服务 - 新增线索人员关联查询数据回填功能

src/main/java/com/hhwy/qbeqsjy/dao/CtrlDao.java

@@ -169,6 +169,23 @@ public class CtrlDao {
     }
 
 
+    /**
+     * 根据 任务编号、线索值 查询布控任务对应的线索信息
+     * @param taskId
+     * @return
+     */
+    public List<Map<String, Object>> queryClueDetailInfo(String taskId, String clue){
+        List<Map<String, Object>> clueInfoDetailList = new ArrayList<>();
+        String sql = "select * from t_ctrl_clue_info where taskId = ? and clue = ?";
+        try {
+            clueInfoDetailList = gaussDBJdbcTemplate.queryForList(sql, taskId, clue);
+        } catch (Exception e){
+            log.error("【查询布控任务对应线索详情信息发生异常】 异常信息：", e);
+        }
+        return clueInfoDetailList;
+    }
+
+
 
 
 

src/main/java/com/hhwy/qbeqsjy/kafka/service/ConsumeService.java

@@ -25,6 +25,8 @@ import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 /**
  * 布控命中数据处理
@@ -48,17 +50,17 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
     // IOC容器刷新完成后就会发布ContextRefreshedEvent事件
     @Override
     public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {
-        /*ExecutorService executor = Executors.newFixedThreadPool(1);
+        ExecutorService executor = Executors.newFixedThreadPool(1);
         executor.execute(() -> {
             if (contextRefreshedEvent.getApplicationContext().getParent() == null) {
                 try {
-                    this.dataConsumeAndProduce();
+                    this.dataConsume();
                 } catch (Exception e) {
                     log.error("【QBEQSJYCTRL】 数据处理服务启动异常", e);
                 }
             }
         });
-        executor.shutdown();*/
+        executor.shutdown();
     }
 
     public void dataConsume() {