【情报二期】数据域服务 - 用户域数据同步代码开发

src/main/java/com/hhwy/qbeqsjy/controller/CtrlController.java

@@ -176,6 +176,40 @@ public class CtrlController {
     }
 
 
+    /**
+     * 保存用户域提交的布控任务对应的线索人员信息
+     * @param reqBody
+     * @return
+     *
+     * 请求参数：
+     * {
+     *     "taskId":"59275350793392128",
+     *     "clueList":[
+     *            {
+     *             "ryxm":"xxx",
+     *             "zjlxdm":"xxx",
+     *             "zjhm":"xxx",
+     * 				......
+     * 			  }
+     *      ]
+     * }
+     */
+    @PostMapping("/saveCtrlClueInfo")
+    public AjaxResult saveCtrlClueInfo(@RequestBody JSONObject reqBody){
+        String taskId = reqBody.getString("taskId");
+        JSONArray clueList = reqBody.getJSONArray("clueList");
+        if(StringUtils.isBlank(taskId) || clueList == null || clueList.size() == 0){
+            return AjaxResult.error(Constants.PARAMS_EMPTY_MSG);
+        }
+        try{
+            return ctrlService.saveCtrlClueInfo(taskId, clueList)? AjaxResult.success() : AjaxResult.error();
+        } catch (Exception e){
+            log.error("保存任务线索人员信息发生异常", e);
+        }
+        return AjaxResult.error(Constants.SERVER_ERROR_MSG);
+    }
+
+
 
 
 

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

@@ -176,7 +176,7 @@ public class CtrlDao {
      */
     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 = ?";
+        String sql = "select * from t_ctrl_clue_info where rwbh = ? and clue = ?";
         try {
             clueInfoDetailList = gaussDBJdbcTemplate.queryForList(sql, taskId, clue);
         } catch (Exception e){
@@ -186,6 +186,23 @@ public class CtrlDao {
     }
 
 
+    /**
+     * 批量插入布控任务线索人员数据
+     * @param clueInfoList
+     * @return
+     */
+    public boolean batchInsertCtrlClueInfo(List<Object[]> clueInfoList){
+        String sql = "insert into t_ctrl_clue_info (rwbh, ryxm, zjlxdm, zjhm, hjd, sjh, xswjbh, xswjm, yzzt, yzztmc, xszt, rylb, rybq, gkjb, gkjbmc, cjsj) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
+        try {
+            int[] insertRows = gaussDBJdbcTemplate.batchUpdate(sql, clueInfoList);
+            return insertRows.length == clueInfoList.size();
+        } catch (Exception e){
+            log.error("【批量插入布控任务线索人员数据发生异常】 异常信息：", e);
+        }
+        return false;
+    }
+
+
 
 
 

src/main/java/com/hhwy/qbeqsjy/service/CtrlService.java

@@ -503,6 +503,41 @@ public class CtrlService {
     }
 
 
+    /**
+     * 保存布控任务对应线索人员信息
+     * @param taskId
+     * @param clueList
+     * @return
+     */
+    @Transactional
+    public boolean saveCtrlClueInfo(String taskId, JSONArray clueList){
+        List<Object[]> ctrlClueInfoList = new ArrayList<>();
+        Date createTime = new Date();
+        for (Object item : clueList) {
+            JSONObject clueObj = (JSONObject) item;
+            if(!clueObj.isEmpty()){
+                String ryxm = clueObj.getString("ryxm");
+                String zjlxdm = clueObj.getString("zjlxdm");
+                String zjhm = clueObj.getString("zjhm");
+                String hjd = clueObj.getString("hjd");
+                String sjh = clueObj.getString("sjh");
+                String xswjbh = clueObj.getString("xswjbh");
+                String xswjm = clueObj.getString("xswjm");
+                Integer yzzt = clueObj.getInteger("yzzt");
+                String yzztmc = clueObj.getString("yzztmc");
+                Integer xszt = clueObj.getInteger("xszt");
+                String rylb = clueObj.getString("rylb");
+                String rybq = clueObj.getString("rybq");
+                String gkjb = clueObj.getString("gkjb");
+                String gkjbmc = clueObj.getString("gkjbmc");
+                Object[] ctrlClueInfo = new Object[]{taskId, ryxm, zjlxdm, zjhm, hjd, sjh, xswjbh, xswjm, yzzt, yzztmc, xszt, rylb, rybq, gkjb, gkjbmc, createTime};
+                ctrlClueInfoList.add(ctrlClueInfo);
+            }
+        }
+        return ctrlDao.batchInsertCtrlClueInfo(ctrlClueInfoList);
+    }
+
+
     /**
      * 条件查询布控任务预警结果数据
      * @param queryDTO