|
|
@@ -144,6 +144,8 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
String yjxxbh = String.valueOf(generator.nextId());
|
|
|
// 预警状态默认为0（未读）
|
|
|
Integer yjzt = 0;
|
|
|
+ // 预警类型默认为1（单人预警）
|
|
|
+ Integer yjlx = 1;
|
|
|
Date currentTime = new Date();
|
|
|
// 根据clueId中的任务编号、线索值、线索类型查询对应的布控任务相关信息（包含任务信息、数据资源信息、区域信息、线索信息）
|
|
|
List<Map<String, Object>> ctrlTaskInfoList = ctrlDao.queryCtrlTaskInfo(rwbh, clue, clueType);
|
|
|
@@ -175,6 +177,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
String zrbmbm = String.valueOf(ctrlTaskInfo.get("zrbmbm"));
|
|
|
// 根据任务编号查询对应的模型配置信息
|
|
|
List<Map<String, Object>> modelInfoList = ctrlDao.queryCtrlTaskModelInfo(rwbh);
|
|
|
+
|
|
|
if(resCodeAUTH.equals(resourceCode)){ // =========== AUTH认证数据
|
|
|
// 1. ========================= 过滤基站号、经纬度为空的数据
|
|
|
String baseStationId = oriField.getString("BASE_STATION_ID");
|
|
|
@@ -216,7 +219,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
if(GeoUtils.isPointInCircle(Double.valueOf(lat84), Double.valueOf(lon84), Double.valueOf(centerLat84), Double.valueOf(centerLon84), Double.valueOf(radius))){
|
|
|
yjxxsm.append("，所在区域：");
|
|
|
yjxxsm.append(areaName);
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, currentTime, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lon84, lat84, currentTime, currentTime, null, null, null, areaName, addressName});
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, currentTime, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lon84, lat84, currentTime, currentTime, null, null, null, areaName, addressName, yjlx, Constants.YJLX_DRYJ});
|
|
|
yjxxsm.setLength(0);
|
|
|
break;
|
|
|
}
|
|
|
@@ -231,22 +234,23 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
if(GeoUtils.isPointInPolygon(coordinates, new Coordinate(Double.valueOf(lon84), Double.valueOf(lat84)))){
|
|
|
yjxxsm.append("，所在区域：");
|
|
|
yjxxsm.append(areaName);
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, currentTime, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lon84, lat84, currentTime, currentTime, null, null, null, areaName, addressName});
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, currentTime, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lon84, lat84, currentTime, currentTime, null, null, null, areaName, addressName, yjlx, Constants.YJLX_DRYJ});
|
|
|
yjxxsm.setLength(0);
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
} else { // 如果不存在布控区域信息，则默认布控区域范围为全天津市，预警数据直接入库
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, currentTime, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lon84, lat84, currentTime, currentTime, null, null, null, "天津市", addressName});
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, currentTime, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(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});
|
|
|
yjxxsm.setLength(0);
|
|
|
}
|
|
|
- yjxxsm.setLength(0);
|
|
|
} else if(resCodeKy.equals(resourceCode)){ // =========== 客运数据
|
|
|
// 票号
|
|
|
- String ph = oriField.getString("TRAIN_TIC_NO");
|
|
|
+ String trainTicNo = oriField.getString("TRAIN_TIC_NO");
|
|
|
+ String ph = StringUtils.isNotBlank(trainTicNo)? trainTicNo : "暂无";
|
|
|
// 旅客姓名
|
|
|
- String lkXm = oriField.getString("PASS_NAME");
|
|
|
+ String passName = oriField.getString("PASS_NAME");
|
|
|
+ String lkXm = StringUtils.isNotBlank(passName)? passName : yjryXm;
|
|
|
// 旅客身份证号
|
|
|
String lkSfzh = oriField.getString("PASS_CRED_NUM");
|
|
|
// 旅客手机
|
|
|
@@ -315,14 +319,12 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
yjxxsm.append(cph);
|
|
|
for (Map<String, Object> modelInfoMap : modelInfoList) {
|
|
|
String mxbh = (String) modelInfoMap.get("mxbh");
|
|
|
- if("DRYJ-BSJJ-KYCC".equals(mxbh)){ // 单人预警-本市进京-客运乘车
|
|
|
- if(StringUtils.isNotBlank(sfdxzqhdm) && StringUtils.isNotBlank(mddxzqhdm)){
|
|
|
+ if(Constants.MODEL_CODE_BSJJ_KYCC.equals(mxbh)){ // 单人预警-本市进京-客运乘车
|
|
|
+ if(StringUtils.isNotBlank(sfdxzqhdm) && StringUtils.isNotBlank(mddxzqhdm) && "12".equals(sfdxzqhdm.substring(0, 2)) && "11".equals(mddxzqhdm.substring(0, 2))){
|
|
|
// 业务需求：始发地：天津，目的地：北京
|
|
|
- if("12".equals(sfdxzqhdm.substring(0, 2)) && "11".equals(mddxzqhdm.substring(0, 2))){
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkXm, lkSfzh, lkSjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeKy, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, null});
|
|
|
- yjxxsm.setLength(0);
|
|
|
- break;
|
|
|
- }
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkXm, lkSfzh, lkSjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeKy, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, null, yjlx, Constants.YJLX_DRYJ});
|
|
|
+ yjxxsm.setLength(0);
|
|
|
+ break;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -397,24 +399,20 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
yjxxsm.append(ddsj);
|
|
|
for (Map<String, Object> modelInfoMap : modelInfoList) {
|
|
|
String mxbh = (String) modelInfoMap.get("mxbh");
|
|
|
- if("DRYJ-WSLJ-MHDP".equals(mxbh)){ // 单人预警-外省来津-民航订票
|
|
|
- if(StringUtils.isNotBlank(ddjcdm)){
|
|
|
+ if(Constants.MODEL_CODE_WSLJ_MHDP.equals(mxbh)){ // 单人预警-外省来津-民航订票
|
|
|
+ if(StringUtils.isNotBlank(ddjcdm) && "TSN".equals(ddjcdm.trim())){
|
|
|
// 业务需求：到达机场代码为TSN（天津滨海国际机场）
|
|
|
- if("TSN".equals(ddjcdm.trim())){
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkzwm, zjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeMhdp, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, ddjcmc});
|
|
|
- yjxxsm.setLength(0);
|
|
|
- break;
|
|
|
- }
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkzwm, zjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeMhdp, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, ddjcmc, yjlx, Constants.YJLX_DRYJ});
|
|
|
+ yjxxsm.setLength(0);
|
|
|
+ break;
|
|
|
}
|
|
|
- } else if ("DRYJ-KSGJ-MHDP".equals(mxbh)) { // 单人预警-跨省轨迹-民航订票
|
|
|
- if(StringUtils.isNotBlank(qfjcdm) && StringUtils.isNotBlank(ddjcmc)){
|
|
|
- String mddShi = (String) modelInfoMap.get("mdd_shi");
|
|
|
+ } else if (Constants.MODEL_CODE_KSGJ_MHDP.equals(mxbh)) { // 单人预警-跨省轨迹-民航订票
|
|
|
+ String mddShi = (String) modelInfoMap.get("mdd_shi");
|
|
|
+ if(StringUtils.isNotBlank(qfjcdm) && StringUtils.isNotBlank(ddjcmc) && "TSN".equals(qfjcdm.trim()) && ddjcmc.trim().contains(mddShi)){
|
|
|
// 业务需求：起飞机场代码为TSN（天津滨海国际机场），到达机场须属于当前任务所记录的目的地市
|
|
|
- if("TSN".equals(qfjcdm.trim()) && ddjcmc.trim().contains(mddShi)){
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkzwm, zjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeMhdp, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, ddjcmc});
|
|
|
- yjxxsm.setLength(0);
|
|
|
- break;
|
|
|
- }
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkzwm, zjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeMhdp, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, ddjcmc, yjlx, Constants.YJLX_DRYJ});
|
|
|
+ yjxxsm.setLength(0);
|
|
|
+ break;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -489,11 +487,11 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
String mxbh = (String) modelInfoMap.get("mxbh");
|
|
|
/*if("DRYJ-BSJJ-LKZD".equals(mxbh)){ // 单人预警-本市进京-旅客住店
|
|
|
// --- todo
|
|
|
- // 该需求不合理，待定
|
|
|
+ // 用户域实现
|
|
|
}
|
|
|
else*/
|
|
|
// 业务需求：线索人员所住旅馆位置须在当前任务所记录的布控区域范围内
|
|
|
- if("DRYJ-BSMGQY-LKZD".equals(mxbh)){ // 单人预警-本市敏感区域-旅客住店
|
|
|
+ if(Constants.MODEL_CODE_BSMGQY_LKZD.equals(mxbh)){ // 单人预警-本市敏感区域-旅客住店
|
|
|
JSONArray areaInfoList = JSON.parseArray(bkqyxx);
|
|
|
for (Object obj : areaInfoList) {
|
|
|
JSONObject ctrlAreaInfo = (JSONObject) obj;
|
|
|
@@ -508,7 +506,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
String centerLat84 = loc.getString("lat");
|
|
|
String radius = loc.getString("radius");
|
|
|
if(GeoUtils.isPointInCircle(Double.valueOf(lgwd), Double.valueOf(lgjd), Double.valueOf(centerLat84), Double.valueOf(centerLon84), Double.valueOf(radius))){
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, rzrXm, rzrSfzh, rzrLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeJnryzs, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lgjd, lgwd, currentTime, currentTime, null, null, null, qymc, lgdz});
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, rzrXm, rzrSfzh, rzrLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeJnryzs, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lgjd, lgwd, currentTime, currentTime, null, null, null, qymc, lgdz, yjlx, Constants.YJLX_DRYJ});
|
|
|
yjxxsm.setLength(0);
|
|
|
break;
|
|
|
}
|
|
|
@@ -521,7 +519,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
coordinates.add(new Coordinate(Double.valueOf(vertexLon84), Double.valueOf(vertexLat84)));
|
|
|
}
|
|
|
if(GeoUtils.isPointInPolygon(coordinates, new Coordinate(Double.valueOf(lgjd), Double.valueOf(lgwd)))){
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, rzrXm, rzrSfzh, rzrLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeJnryzs, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lgjd, lgwd, currentTime, currentTime, null, null, null, qymc, lgdz});
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, rzrXm, rzrSfzh, rzrLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeJnryzs, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, lgjd, lgwd, currentTime, currentTime, null, null, null, qymc, lgdz, yjlx, Constants.YJLX_DRYJ});
|
|
|
yjxxsm.setLength(0);
|
|
|
break;
|
|
|
}
|
|
|
@@ -583,11 +581,10 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
yjxxsm.append(yycsmc);
|
|
|
for (Map<String, Object> modelInfoMap : modelInfoList) {
|
|
|
String mxbh = (String) modelInfoMap.get("mxbh");
|
|
|
- if("DRYJ-BSMGQY-WBSW".equals(mxbh)){ // 单人预警-本市敏感区域-网吧上网
|
|
|
- // --- todo
|
|
|
+ if(Constants.MODEL_CODE_BSMGQY_WBSW.equals(mxbh)){ // 单人预警-本市敏感区域-网吧上网
|
|
|
// 表中无经、纬度数据，无法判断是否出现在布控区域
|
|
|
// 暂时不做过滤处理
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, swryXm, swrySfzh, swryLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeWbsw, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, yycsmc});
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, swryXm, swrySfzh, swryLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeWbsw, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, yycsmc, yjlx, Constants.YJLX_DRYJ});
|
|
|
yjxxsm.setLength(0);
|
|
|
break;
|
|
|
}
|
|
|
@@ -650,11 +647,10 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
yjxxsm.append(dtxlxx);
|
|
|
for (Map<String, Object> modelInfoMap : modelInfoList) {
|
|
|
String mxbh = (String) modelInfoMap.get("mxbh");
|
|
|
- if("DRYJ-BSMGQY-DT".equals(mxbh)){ // 单人预警-本市敏感区域-地铁
|
|
|
- // --- todo
|
|
|
+ if(Constants.MODEL_CODE_BSMGQY_DT.equals(mxbh)){ // 单人预警-本市敏感区域-地铁
|
|
|
// 表中无经、纬度数据，无法判断是否出现在布控区域
|
|
|
// 暂时不做过滤处理
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, ckXm, ckSfzh, ckLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeDt, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, czmc});
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, ckXm, ckSfzh, ckLxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeDt, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, czmc, yjlx, Constants.YJLX_DRYJ});
|
|
|
yjxxsm.setLength(0);
|
|
|
break;
|
|
|
}
|
|
|
@@ -716,9 +712,9 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
yjxxsm.append(StringUtils.isNotBlank(addressName)? addressName : "暂无");
|
|
|
for (Map<String, Object> modelInfoMap : modelInfoList) {
|
|
|
String mxbh = (String) modelInfoMap.get("mxbh");
|
|
|
- if("DRYJ-BSJJ-SJRD".equals(mxbh)){ // 单人预警-本市进京-手机热点
|
|
|
+ if(Constants.MODEL_CODE_BSJJ_SJRD.equals(mxbh)){ // 单人预警-本市进京-手机热点
|
|
|
// 不做过滤处理
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yddh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeSjrd, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, null, addressName});
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yddh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeSjrd, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, null, addressName, yjlx, Constants.YJLX_DRYJ});
|
|
|
yjxxsm.setLength(0);
|
|
|
break;
|
|
|
}
|
|
|
@@ -832,9 +828,9 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
yjxxsm.append(StringUtils.isNotBlank(addressName)? addressName : "暂无");
|
|
|
for (Map<String, Object> modelInfoMap : modelInfoList) {
|
|
|
String mxbh = (String) modelInfoMap.get("mxbh");
|
|
|
- if("DRYJ-BSJJ-XLPC".equals(mxbh)){ // 单人预警-本市进京-巡逻盘查
|
|
|
+ if(Constants.MODEL_CODE_BSJJ_XLPC.equals(mxbh)){ // 单人预警-本市进京-巡逻盘查
|
|
|
// 不做过滤处理
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, xm, sfzh, lxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeXlpc, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, pcdJd, pcdWd, currentTime, currentTime, null, null, null, null, addressName});
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, xm, sfzh, lxdh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeXlpc, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, pcdJd, pcdWd, currentTime, currentTime, null, null, null, null, addressName, yjlx, Constants.YJLX_DRYJ});
|
|
|
yjxxsm.setLength(0);
|
|
|
break;
|
|
|
}
|
|
|
@@ -899,9 +895,9 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
yjxxsm.append(jczmc);
|
|
|
for (Map<String, Object> modelInfoMap : modelInfoList) {
|
|
|
String mxbh = (String) modelInfoMap.get("mxbh");
|
|
|
- if("DRYJ-BSJJ-ZDJC".equals(mxbh)){ // 单人预警-本市进京-站点检查
|
|
|
+ if(Constants.MODEL_CODE_BSJJ_ZDJC.equals(mxbh)){ // 单人预警-本市进京-站点检查
|
|
|
// 不做过滤处理
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, xm, sfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeZdjc, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, jczmc});
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, xm, sfzh, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeZdjc, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, null, null, currentTime, currentTime, null, null, null, null, jczmc, yjlx, Constants.YJLX_DRYJ});
|
|
|
yjxxsm.setLength(0);
|
|
|
break;
|
|
|
}
|
|
|
@@ -960,17 +956,17 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
yjxxsm.append(sbbh);
|
|
|
for (Map<String, Object> modelInfoMap : modelInfoList) {
|
|
|
String mxbh = (String) modelInfoMap.get("mxbh");
|
|
|
- if("DRYJ-BSJJ-HCZDW".equals(mxbh)){ // 单人预警-本市进京-火车站电围
|
|
|
+ if(Constants.MODEL_CODE_BSJJ_HCZDW.equals(mxbh)){ // 单人预警-本市进京-火车站电围
|
|
|
// 业务需求：只保留命中点位在火车站区域内的数据
|
|
|
if(GeoUtils.isPointInCircle(Double.valueOf(jzdqWd), Double.valueOf(jzdqJd), Double.valueOf(centerPointLatHcz), Double.valueOf(centerPointLonHcz), Double.valueOf(radiusHcz))){
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yddh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeDzwl, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jzdqJd, jzdqWd, currentTime, currentTime, null, null, null, "火车站", addressName});
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, yjrySfzh, yddh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeDzwl, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jzdqJd, jzdqWd, currentTime, currentTime, null, null, null, Constants.QYMC_HCZ, addressName, yjlx, Constants.YJLX_DRYJ});
|
|
|
yjxxsm.setLength(0);
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
yjxxsm.setLength(0);
|
|
|
- } else if (resCodeRlgz.equals(resourceCode)) { // =========== 人脸感知（火车站）
|
|
|
+ } else if (resCodeRlgz.equals(resourceCode)) { // =========== 人脸感知（火车站/本市）
|
|
|
// 抓拍机编号
|
|
|
String snashoMachNo = oriField.getString("SNASHO_MACH_NO");
|
|
|
String zpjbh = StringUtils.isNotBlank(snashoMachNo)? snashoMachNo : "暂无";
|
|
|
@@ -1005,74 +1001,85 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
|
|
|
JSONObject rspJSONObj = JSON.parseObject(rspStr);
|
|
|
addressName = rspJSONObj.getString("fullAddress");
|
|
|
}
|
|
|
- yjxxsm.append("火车站人脸感知 - 抓拍机编号：");
|
|
|
- yjxxsm.append(zpjbh);
|
|
|
- yjxxsm.append("，抓拍机名称：");
|
|
|
- yjxxsm.append(zpjmc);
|
|
|
- yjxxsm.append("，告警人员证件号码：");
|
|
|
- yjxxsm.append(gjryZjhm);
|
|
|
- yjxxsm.append("，告警时间：");
|
|
|
- yjxxsm.append(gjsj);
|
|
|
- yjxxsm.append("，人脸图片文件路径：");
|
|
|
- yjxxsm.append(rltpwjlj);
|
|
|
for (Map<String, Object> modelInfoMap : modelInfoList) {
|
|
|
String mxbh = (String) modelInfoMap.get("mxbh");
|
|
|
- if("DRYJ-BSJJ-HCZRLGZ".equals(mxbh)){ // 单人预警-本市进京-火车站人脸感知
|
|
|
+ if(Constants.MODEL_CODE_BSJJ_HCZRLGZ.equals(mxbh)){ // 单人预警-本市进京-火车站人脸感知
|
|
|
// 业务需求：只保留命中点位在火车站区域内的数据
|
|
|
if(GeoUtils.isPointInCircle(Double.valueOf(wd), Double.valueOf(jd), Double.valueOf(centerPointLatHcz), Double.valueOf(centerPointLonHcz), Double.valueOf(radiusHcz))){
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, "火车站", addressName});
|
|
|
+ yjxxsm.append("火车站人脸感知 - 抓拍机编号：");
|
|
|
+ yjxxsm.append(zpjbh);
|
|
|
+ yjxxsm.append("，抓拍机名称：");
|
|
|
+ yjxxsm.append(zpjmc);
|
|
|
+ yjxxsm.append("，告警人员证件号码：");
|
|
|
+ yjxxsm.append(gjryZjhm);
|
|
|
+ yjxxsm.append("，告警时间：");
|
|
|
+ yjxxsm.append(gjsj);
|
|
|
+ yjxxsm.append("，人脸图片文件路径：");
|
|
|
+ yjxxsm.append(rltpwjlj);
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, Constants.QYMC_HCZ, addressName, yjlx, Constants.YJLX_DRYJ});
|
|
|
+ yjxxsm.setLength(0);
|
|
|
+ }
|
|
|
+ } else if (Constants.MODEL_CODE_BSMGQY_BSRL.equals(mxbh)) { // 单人预警-本市敏感区域-本市人脸
|
|
|
+ // 业务需求：只保留命中点位在当前任务记录的布控区域内的数据
|
|
|
+ yjxxsm.append("本市人脸 - 抓拍机编号：");
|
|
|
+ yjxxsm.append(zpjbh);
|
|
|
+ yjxxsm.append("，抓拍机名称：");
|
|
|
+ yjxxsm.append(zpjmc);
|
|
|
+ yjxxsm.append("，告警人员证件号码：");
|
|
|
+ yjxxsm.append(gjryZjhm);
|
|
|
+ yjxxsm.append("，告警时间：");
|
|
|
+ yjxxsm.append(gjsj);
|
|
|
+ yjxxsm.append("，人脸图片文件路径：");
|
|
|
+ yjxxsm.append(rltpwjlj);
|
|
|
+ // 过滤不在布控区域范围的数据
|
|
|
+ JSONArray areaInfoList = JSON.parseArray(bkqyxx);
|
|
|
+ if(areaInfoList != null && areaInfoList.size() > 0){
|
|
|
+ for (Object obj : areaInfoList) {
|
|
|
+ JSONObject ctrlAreaInfo = (JSONObject) obj;
|
|
|
+ String areaName = (String) ctrlAreaInfo.get("qymc");
|
|
|
+ Integer geoType = (Integer) ctrlAreaInfo.get("qyjhlx");
|
|
|
+ JSONObject locationJSONObj = JSON.parseObject(String.valueOf(ctrlAreaInfo.get("qyfwjwdjhFh")));
|
|
|
+ JSONArray locationSet = locationJSONObj.getJSONArray("location");
|
|
|
+ // 如果出现多个布控区域范围存在重叠，并且命中点位也恰巧出现在重叠区域的极端情况，目前则只保存命中第一个布控区域时的一份数据，不再继续判断
|
|
|
+ if(Constants.NUM_0 == geoType){
|
|
|
+ JSONObject loc = locationSet.getJSONObject(0);
|
|
|
+ String centerLon84 = loc.getString("lon");
|
|
|
+ String centerLat84 = loc.getString("lat");
|
|
|
+ String radius = loc.getString("radius");
|
|
|
+ if(GeoUtils.isPointInCircle(Double.valueOf(wd), Double.valueOf(jd), Double.valueOf(centerLat84), Double.valueOf(centerLon84), Double.valueOf(radius))){
|
|
|
+ yjxxsm.append("，所在区域：");
|
|
|
+ yjxxsm.append(areaName);
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, areaName, addressName, yjlx, Constants.YJLX_DRYJ});
|
|
|
+ yjxxsm.setLength(0);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ List<Coordinate> coordinates = new ArrayList<>();
|
|
|
+ for (Object item : locationSet) {
|
|
|
+ JSONObject loc = (JSONObject) item;
|
|
|
+ String vertexLon84 = loc.getString("lon");
|
|
|
+ String vertexLat84 = loc.getString("lat");
|
|
|
+ coordinates.add(new Coordinate(Double.valueOf(vertexLon84), Double.valueOf(vertexLat84)));
|
|
|
+ }
|
|
|
+ if(GeoUtils.isPointInPolygon(coordinates, new Coordinate(Double.valueOf(jd), Double.valueOf(wd)))){
|
|
|
+ yjxxsm.append("，所在区域：");
|
|
|
+ yjxxsm.append(areaName);
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, areaName, addressName, yjlx, Constants.YJLX_DRYJ});
|
|
|
+ yjxxsm.setLength(0);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, Constants.QYMC_TJS, addressName, yjlx, Constants.YJLX_DRYJ});
|
|
|
yjxxsm.setLength(0);
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
yjxxsm.setLength(0);
|
|
|
- } else if (resCodeGmszy.equals(resourceCode)) { // =========== 购买散装油 todo
|
|
|
- // 抓拍机编号
|
|
|
- String snashoMachNo = oriField.getString("SNASHO_MACH_NO");
|
|
|
- String zpjbh = StringUtils.isNotBlank(snashoMachNo)? snashoMachNo : "暂无";
|
|
|
- // 抓拍机名称
|
|
|
- String snashoMachDesig = oriField.getString("SNASHO_MACH_DESIG");
|
|
|
- String zpjmc = StringUtils.isNotBlank(snashoMachDesig)? snashoMachDesig : "暂无";
|
|
|
- // 证件号码
|
|
|
- String credNum = oriField.getString("CRED_NUM");
|
|
|
- String gjryZjhm = StringUtils.isNotBlank(credNum)? credNum : "暂无";
|
|
|
- // 告警时间 ---样例：20250329061228
|
|
|
- String alarmTime = oriField.getString("ALARM_TIME");
|
|
|
- String gjsj = StringUtils.isNotBlank(alarmTime)? TimeTool.timeStampToDateString(TimeTool.dateStringToTimeStamp3(alarmTime)) : "暂无";
|
|
|
- // 人脸图片文件路径
|
|
|
- String perFacePictureFilePath = oriField.getString("PER_FACE_PICTURE_FILE_PATH");
|
|
|
- String rltpwjlj = StringUtils.isNotBlank(perFacePictureFilePath)? perFacePictureFilePath : "暂无";
|
|
|
- // 经度
|
|
|
- String jd = oriField.getString("LON");
|
|
|
- // 纬度
|
|
|
- String wd = oriField.getString("LAT");
|
|
|
- String addressName = null;
|
|
|
- if(StringUtils.isNotBlank(wd) && StringUtils.isNotBlank(jd)){
|
|
|
- double[] jwdBD = GpsCoordinateUtils.calWGS84toBD09(Double.valueOf(wd), Double.valueOf(jd));
|
|
|
- String rspStr = httpClient.sendGetRequst(addressQueryUrl.replace("x", String.valueOf(jwdBD[1])).replace("y", String.valueOf(jwdBD[0])), null);
|
|
|
- JSONObject rspJSONObj = JSON.parseObject(rspStr);
|
|
|
- addressName = rspJSONObj.getString("fullAddress");
|
|
|
- }
|
|
|
- yjxxsm.append("购买散装油 - 抓拍机编号：");
|
|
|
- yjxxsm.append(zpjbh);
|
|
|
- yjxxsm.append("，抓拍机名称：");
|
|
|
- yjxxsm.append(zpjmc);
|
|
|
- yjxxsm.append("，告警人员证件号码：");
|
|
|
- yjxxsm.append(gjryZjhm);
|
|
|
- yjxxsm.append("，告警时间：");
|
|
|
- yjxxsm.append(gjsj);
|
|
|
- yjxxsm.append("，人脸图片文件路径：");
|
|
|
- yjxxsm.append(rltpwjlj);
|
|
|
- for (Map<String, Object> modelInfoMap : modelInfoList) {
|
|
|
- String mxbh = (String) modelInfoMap.get("mxbh");
|
|
|
- if("DRYJ-FXXW-GMSZY".equals(mxbh)){ // 单人预警-风险行为-购买散装油
|
|
|
- warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKey(zrdwbm), zrbmbm, CommonUtil.getConfValueByKey(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, "火车站", addressName});
|
|
|
- yjxxsm.setLength(0);
|
|
|
- break;
|
|
|
- }
|
|
|
- }
|
|
|
- yjxxsm.setLength(0);
|
|
|
+ } else if (resCodeGmszy.equals(resourceCode)) { // =========== 购买散装油
|
|
|
+ // ------ todo
|
|
|
}
|
|
|
}
|
|
|
}
|
