【情报二期】数据域服务 - 解决任务信息同步问题

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

@@ -86,7 +86,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
         executor.execute(() -> {
             if (contextRefreshedEvent.getApplicationContext().getParent() == null) {
                 try {
-                    this.dataConsume();
+//                    this.dataConsume();
                 } catch (Exception e) {
                     log.error("【QBEQSJYCTRL】 数据消费服务发生异常", e);
                 }

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

@@ -541,6 +541,7 @@ public class CtrlService {
                 String sjh = clueObj.getString("sjh");
                 Integer yzzt = clueObj.getInteger("yzzt");
                 Integer xszt = clueObj.getInteger("xszt");
+                String lxdh = clueObj.getString("lxdh");
                 String rylb = clueObj.getString("rylb");
                 String rybq = clueObj.getString("rybq");
                 String gkjb = clueObj.getString("gkjb");
@@ -552,7 +553,7 @@ public class CtrlService {
                 String zrmjlxfs = clueObj.getString("zrmjlxfs");
                 String zrdwbm = clueObj.getString("zrdwbm");
                 String zrbmbm = clueObj.getString("zrbmbm");
-                ctrlTaskInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, bkkssj, bkjssj, JSON.toJSONString(resourceCodeList), areaInfo.toJSONString(), sftsed, sftssd, ryxm, zjlxdm, zjhm, hjd, sjh, yzzt, xszt, rylb, rybq, gkjb, gkjbmc, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, zrbmbm, cjsj});
+                ctrlTaskInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, bkkssj, bkjssj, JSON.toJSONString(resourceCodeList), areaInfo.toJSONString(), sftsed, sftssd, ryxm, zjlxdm, zjhm, hjd, sjh, yzzt, xszt, lxdh, rylb, rybq, gkjb, gkjbmc, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, zrbmbm, cjsj});
             }
         }
         for (Object item : modelInfo) {