|
@@ -86,7 +86,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
executor.execute(() -> {
|
|
executor.execute(() -> {
|
|
if (contextRefreshedEvent.getApplicationContext().getParent() == null) {
|
|
if (contextRefreshedEvent.getApplicationContext().getParent() == null) {
|
|
try {
|
|
try {
|
|
-// this.dataConsume();
|
|
|
|
|
|
+ this.dataConsume();
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
log.error("【QBEQSJYCTRL】 数据消费服务发生异常", e);
|
|
log.error("【QBEQSJYCTRL】 数据消费服务发生异常", e);
|
|
}
|
|
}
|
|
@@ -172,6 +172,11 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
String zrmjid = String.valueOf(ctrlTaskInfo.get("zrmjid"));
|
|
String zrmjid = String.valueOf(ctrlTaskInfo.get("zrmjid"));
|
|
String zrmjxm = String.valueOf(ctrlTaskInfo.get("zrmjxm"));
|
|
String zrmjxm = String.valueOf(ctrlTaskInfo.get("zrmjxm"));
|
|
String zrmjjh = String.valueOf(ctrlTaskInfo.get("zrmjjh"));
|
|
String zrmjjh = String.valueOf(ctrlTaskInfo.get("zrmjjh"));
|
|
|
|
+ String zrmjsfzh = null;
|
|
|
|
+ List<Map<String, Object>> userInfoList = ctrlDao.queryUserInfo(zrmjjh);
|
|
|
|
+ if(!userInfoList.isEmpty()){
|
|
|
|
+ zrmjsfzh = (String) userInfoList.get(0).get("idcard");
|
|
|
|
+ }
|
|
String zrmjlxfs = String.valueOf(ctrlTaskInfo.get("zrmjlxfs"));
|
|
String zrmjlxfs = String.valueOf(ctrlTaskInfo.get("zrmjlxfs"));
|
|
String zrdwbm = String.valueOf(ctrlTaskInfo.get("zrdwbm"));
|
|
String zrdwbm = String.valueOf(ctrlTaskInfo.get("zrdwbm"));
|
|
String zrbmbm = String.valueOf(ctrlTaskInfo.get("zrbmbm"));
|
|
String zrbmbm = String.valueOf(ctrlTaskInfo.get("zrbmbm"));
|
|
@@ -236,7 +241,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh(areaCode);
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh(areaCode);
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lon84, lat84, currentTime, currentTime, null, null, null, areaName, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lon84, lat84, currentTime, currentTime, null, null, null, areaName, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
} else { // 布控区域是一般多边形
|
|
} else { // 布控区域是一般多边形
|
|
@@ -266,7 +271,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh(areaCode);
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh(areaCode);
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lon84, lat84, currentTime, currentTime, null, null, null, areaName, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lon84, lat84, currentTime, currentTime, null, null, null, areaName, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -280,7 +285,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
yjxxsm.append(captureTimeStr);
|
|
yjxxsm.append(captureTimeStr);
|
|
yjxxsm.append("出现在");
|
|
yjxxsm.append("出现在");
|
|
yjxxsm.append(addressName);
|
|
yjxxsm.append(addressName);
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lon84, lat84, currentTime, currentTime, null, null, null, Constants.QYMC_TJS, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lon84, lat84, currentTime, currentTime, null, null, null, Constants.QYMC_TJS, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd, zrmjsfzh});
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else if(resCodeKy.equals(resourceCode)){ // =========== 客运数据
|
|
} else if(resCodeKy.equals(resourceCode)){ // =========== 客运数据
|
|
@@ -353,7 +358,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
yjxxsm.append(zh);
|
|
yjxxsm.append(zh);
|
|
yjxxsm.append(",车牌号:");
|
|
yjxxsm.append(",车牌号:");
|
|
yjxxsm.append(cph);
|
|
yjxxsm.append(cph);
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkXm, lkSfzh, lkSjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, dpsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, null, yjlx, Constants.YJLX_DRYJ, seatNo, null, null, null, null, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkXm, lkSfzh, lkSjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, dpsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, null, yjlx, Constants.YJLX_DRYJ, seatNo, null, null, null, null, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -427,7 +432,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
yjxxsm.append(StringUtils.isNotBlank(ddjcmc)? ddjcmc : "暂无");
|
|
yjxxsm.append(StringUtils.isNotBlank(ddjcmc)? ddjcmc : "暂无");
|
|
yjxxsm.append(",到达时间:");
|
|
yjxxsm.append(",到达时间:");
|
|
yjxxsm.append(ddsj);
|
|
yjxxsm.append(ddsj);
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkzwm, zjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeMhdpDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, ddjcmc, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkzwm, zjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeMhdpDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, ddjcmc, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
} else if (Constants.MODEL_CODE_KSGJ_MHDP.equals(mxbh)) { // 单人预警-跨省轨迹-民航订票
|
|
} else if (Constants.MODEL_CODE_KSGJ_MHDP.equals(mxbh)) { // 单人预警-跨省轨迹-民航订票
|
|
@@ -451,7 +456,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
yjxxsm.append(StringUtils.isNotBlank(ddjcmc)? ddjcmc : "暂无");
|
|
yjxxsm.append(StringUtils.isNotBlank(ddjcmc)? ddjcmc : "暂无");
|
|
yjxxsm.append(",到达时间:");
|
|
yjxxsm.append(",到达时间:");
|
|
yjxxsm.append(ddsj);
|
|
yjxxsm.append(ddsj);
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkzwm, zjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeMhdpDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, ddjcmc, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkzwm, zjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeMhdpDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, ddjcmc, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -551,7 +556,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh(areaCode);
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh(areaCode);
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, rzrXm, rzrSfzh, rzrLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, rzsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lgjd, lgwd, currentTime, currentTime, null, null, null, qymc, lgdz, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, rzrXm, rzrSfzh, rzrLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, rzsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lgjd, lgwd, currentTime, currentTime, null, null, null, qymc, lgdz, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
} else { // 多边形区域
|
|
} else { // 多边形区域
|
|
@@ -586,7 +591,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh(areaCode);
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh(areaCode);
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, rzrXm, rzrSfzh, rzrLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, rzsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lgjd, lgwd, currentTime, currentTime, null, null, null, qymc, lgdz, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, rzrXm, rzrSfzh, rzrLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, rzsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lgjd, lgwd, currentTime, currentTime, null, null, null, qymc, lgdz, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -651,7 +656,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
yjxxsm.append(swjssj);
|
|
yjxxsm.append(swjssj);
|
|
yjxxsm.append(",营业场所名称:");
|
|
yjxxsm.append(",营业场所名称:");
|
|
yjxxsm.append(yycsmc);
|
|
yjxxsm.append(yycsmc);
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, swryXm, swrySfzh, swryLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, swkssjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, yycsmc, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, swryXm, swrySfzh, swryLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, swkssjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, yycsmc, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -715,7 +720,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
yjxxsm.append(zjh);
|
|
yjxxsm.append(zjh);
|
|
yjxxsm.append(",地铁线路信息:");
|
|
yjxxsm.append(",地铁线路信息:");
|
|
yjxxsm.append(dtxlxx);
|
|
yjxxsm.append(dtxlxx);
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, ckXm, ckSfzh, ckLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, sksjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, czmc, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, ckXm, ckSfzh, ckLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, sksjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, czmc, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -777,7 +782,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
yjxxsm.append(glsj);
|
|
yjxxsm.append(glsj);
|
|
yjxxsm.append(",位置信息:");
|
|
yjxxsm.append(",位置信息:");
|
|
yjxxsm.append(StringUtils.isNotBlank(addressName)? addressName : "暂无");
|
|
yjxxsm.append(StringUtils.isNotBlank(addressName)? addressName : "暂无");
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yddh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, glsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, null, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yddh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, glsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, null, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -889,7 +894,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
yjxxsm.append(ywlx);
|
|
yjxxsm.append(ywlx);
|
|
yjxxsm.append(",盘查地位置信息:");
|
|
yjxxsm.append(",盘查地位置信息:");
|
|
yjxxsm.append(StringUtils.isNotBlank(addressName)? addressName : "暂无");
|
|
yjxxsm.append(StringUtils.isNotBlank(addressName)? addressName : "暂无");
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, xm, sfzh, lxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, pcsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, pcdJd, pcdWd, currentTime, currentTime, null, null, null, null, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, xm, sfzh, lxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, pcsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, pcdJd, pcdWd, currentTime, currentTime, null, null, null, null, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -959,7 +964,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
yjxxsm.append(zjyxqsrq);
|
|
yjxxsm.append(zjyxqsrq);
|
|
yjxxsm.append(",证件有效终止日期:");
|
|
yjxxsm.append(",证件有效终止日期:");
|
|
yjxxsm.append(zjyxzzrq);
|
|
yjxxsm.append(zjyxzzrq);
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, xm, sfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, jcsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, jczmc, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, xm, sfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, jcsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, jczmc, yjlx, Constants.YJLX_DRYJ, null, null, null, null, null, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -1024,7 +1029,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh("TJZ");
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh("TJZ");
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yddh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeDzwlDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jzdqJd, jzdqWd, currentTime, currentTime, null, null, null, Constants.QYMC_TJZ, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yddh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeDzwlDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jzdqJd, jzdqWd, currentTime, currentTime, null, null, null, Constants.QYMC_TJZ, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -1085,7 +1090,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
Map<String, String> tjzFxmjxxMap = ctrlDao.queryFxmjxxByQybh("TJZ");
|
|
Map<String, String> tjzFxmjxxMap = ctrlDao.queryFxmjxxByQybh("TJZ");
|
|
String edFxmjSfzh = tjzFxmjxxMap.get("edFxmjSfzh");
|
|
String edFxmjSfzh = tjzFxmjxxMap.get("edFxmjSfzh");
|
|
String sdFxmjSfzh = tjzFxmjxxMap.get("sdFxmjSfzh");
|
|
String sdFxmjSfzh = tjzFxmjxxMap.get("sdFxmjSfzh");
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, Constants.QYMC_TJZ, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, Constants.QYMC_TJZ, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd, zrmjsfzh});
|
|
}
|
|
}
|
|
} else if (Constants.MODEL_CODE_BSMGQY_BSRL.equals(mxbh)) { // 单人预警-本市敏感区域-本市人脸
|
|
} else if (Constants.MODEL_CODE_BSMGQY_BSRL.equals(mxbh)) { // 单人预警-本市敏感区域-本市人脸
|
|
// 业务需求:只保留命中点位在当前任务记录的布控区域内的数据
|
|
// 业务需求:只保留命中点位在当前任务记录的布控区域内的数据
|
|
@@ -1129,7 +1134,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh(areaCode);
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh(areaCode);
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, areaName, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, areaName, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|
|
@@ -1164,7 +1169,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh(areaCode);
|
|
Map<String, String> fxmjxxMap = ctrlDao.queryFxmjxxByQybh(areaCode);
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String edFxmjSfzh = fxmjxxMap.get("edFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
String sdFxmjSfzh = fxmjxxMap.get("sdFxmjSfzh");
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, areaName, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd});
|
|
|
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, areaName, addressName, yjlx, Constants.YJLX_DRYJ, null, null, null, edFxmjSfzh, sdFxmjSfzh, sftsed, sftssd, zrmjsfzh});
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|