Browse Source

【情报二期】数据域服务 - 新增布控资源表消费逻辑、更新配置文件

peifj 1 month ago
parent
commit
f82af733b7

+ 453 - 31
src/main/java/com/hhwy/qbeqsjy/kafka/service/ConsumeService.java

@@ -50,6 +50,16 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
     private String resCodeWbsw;
     @Value("${res.code.ky}")
     private String resCodeKy;
+    @Value("${res.code.dt}")
+    private String resCodeDt;
+    @Value("${res.code.sjrd}")
+    private String resCodeSjrd;
+    @Value("${res.code.xlpc}")
+    private String resCodeXlpc;
+    @Value("${res.code.zdjc}")
+    private String resCodeZdjc;
+    @Value("${res.code.dzwl}")
+    private String resCodeDzwl;
     @Resource
     private CtrlDao ctrlDao;
     private SnowflakeIdGenerator generator = new SnowflakeIdGenerator(1);
@@ -149,8 +159,7 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
                         String zrmjlxfs = String.valueOf(ctrlTaskInfo.get("zrmjlxfs"));
                         String zrdwbm = String.valueOf(ctrlTaskInfo.get("zrdwbm"));
                         String zrbmbm = String.valueOf(ctrlTaskInfo.get("zrbmbm"));
-                        // AUTH认证数据
-                        if(resCodeAUTH.equals(resourceCode)){
+                        if(resCodeAUTH.equals(resourceCode)){   // =========== AUTH认证数据
                             // 1. ========================= 过滤基站号、经纬度为空的数据
                             String baseStationId = oriField.getString("BASE_STATION_ID");
                             String lonBD = oriField.getString("LONGITUDE");
@@ -216,47 +225,74 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
                                 yjxxsm.setLength(0);
                             }
                             yjxxsm.setLength(0);
-                        } else if(resCodeKy.equals(resourceCode)){   // 客运数据
-                            String cphm = oriField.getString("TRAIN_TIC_NO");             // 票号
-                            String xm = oriField.getString("PASS_NAME");                  // 姓名
-                            String sfzh = oriField.getString("PASS_CRED_NUM");            // 身份证号
-                            String sjh = StringUtils.isBlank(oriField.getString("PASS_MOB"))? yjrySjh : oriField.getString("PASS_MOB");   // 手机
+                        } else if(resCodeKy.equals(resourceCode)){   // =========== 客运数据
+                            String ph = oriField.getString("TRAIN_TIC_NO");               // 票号
+                            String lkXm = oriField.getString("PASS_NAME");                // 旅客姓名
+                            String lkSfzh = oriField.getString("PASS_CRED_NUM");          // 旅客身份证号
+                            String lkSjh = StringUtils.isBlank(oriField.getString("PASS_MOB"))? yjrySjh : oriField.getString("PASS_MOB");// 旅客手机
                             String ccrq = oriField.getString("RIDING_DATE");              // 乘车日期
                             String jpsj = oriField.getString("CHETIC_TIME");              // 检票时间
-                            String sfdzdmc = oriField.getString("DEP_ADDR_STATI_NAME");   // 始发地站点名称
-                            String mddzdmc = oriField.getString("DEST_STATI_NAME");       // 目的地站点名称
-                            String captureTime = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("CAPTURE_TIME")));
+                            String jpkyz = oriField.getString("CHETIC_PASSTA_NAME");      // 检票客运站
+                            String jpcch = oriField.getString("CHETIC_TRAIN_NO");         // 检票车次号
+                            String bc = oriField.getString("SHIFT");                      // 班次
+                            String zh = oriField.getString("SEAT_NO");                    // 座号
+                            String pj = oriField.getString("VEHTIC_PRIC");                // 票价
+                            String zffs = oriField.getString("PAYM_METH_NAME");           // 支付方式
+                            String cph = oriField.getString("VEH_PLATE_NUM");             // 车牌号
+                            String sfdzdmc = oriField.getString("DEP_ADDR_STATI_NAME");   // 始发地站点
+                            String mddzdmc = oriField.getString("DEST_STATI_NAME");       // 目的地站点
                             String dpsj = oriField.getString("BOOTIC_TIME");              // 订票时间
+                            String dpfs = oriField.getString("BOOTIC_METH");              // 订票方式
                             String fcsj = oriField.getString("DEP_TIME");                 // 发车时间
                             String ddsj = oriField.getString("ARR_TIME");                 // 到达时间
-                            yjxxsm.append(xm);
-                            yjxxsm.append("(身份证号:");
-                            yjxxsm.append(sfzh);
-                            yjxxsm.append(",手机号:");
-                            if(StringUtils.isNotBlank(sjh)){
-                                yjxxsm.append(sjh);
-                            }else {
-                                yjxxsm.append("暂无");
-                            }
-                            yjxxsm.append(")于");
+                            String lxrXm = oriField.getString("CTCT_PERSON_NAME");        // 联系人姓名
+                            String lxrLxdh = oriField.getString("CTCT_PERSON_CTCT_TEL");  // 联系人联系电话
+                            String captureTimeKy = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("CAPTURE_TIME")));
+                            yjxxsm.append("客运数据 - 票号:");
+                            yjxxsm.append(ph);
+                            yjxxsm.append(",旅客姓名:");
+                            yjxxsm.append(lkXm);
+                            yjxxsm.append(",旅客身份证号:");
+                            yjxxsm.append(lkSfzh);
+                            yjxxsm.append(",旅客手机号:");
+                            yjxxsm.append(lkSjh);
+                            yjxxsm.append(",订票时间:");
                             yjxxsm.append(dpsj);
-                            yjxxsm.append("购买客车车票,乘车日期:");
+                            yjxxsm.append(",乘车日期:");
                             yjxxsm.append(ccrq);
-                            yjxxsm.append(",车票号码:");
-                            yjxxsm.append(cphm);
+                            yjxxsm.append(",订票方式:");
+                            yjxxsm.append(dpfs);
                             yjxxsm.append(",始发站:");
                             yjxxsm.append(sfdzdmc);
                             yjxxsm.append(",目的站:");
                             yjxxsm.append(mddzdmc);
                             yjxxsm.append(",检票时间:");
                             yjxxsm.append(jpsj);
+                            yjxxsm.append(",检票客运站:");
+                            yjxxsm.append(jpkyz);
+                            yjxxsm.append(",检票车次号:");
+                            yjxxsm.append(jpcch);
+                            yjxxsm.append(",班次:");
+                            yjxxsm.append(bc);
+                            yjxxsm.append(",座号:");
+                            yjxxsm.append(zh);
+                            yjxxsm.append(",票价:");
+                            yjxxsm.append(pj);
+                            yjxxsm.append(",支付方式:");
+                            yjxxsm.append(zffs);
+                            yjxxsm.append(",车牌号:");
+                            yjxxsm.append(cph);
                             yjxxsm.append(",发车时间:");
                             yjxxsm.append(fcsj);
                             yjxxsm.append(",到达时间:");
                             yjxxsm.append(ddsj);
-                            warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, xm, sfzh, sjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTime, 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});
+                            yjxxsm.append(",联系人姓名:");
+                            yjxxsm.append(lxrXm);
+                            yjxxsm.append(",联系人联系电话:");
+                            yjxxsm.append(lxrLxdh);
+                            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});
                             yjxxsm.setLength(0);
-                        } else if (resCodeTldp.equals(resourceCode)) {   // 铁路订票数据
+                        } else if (resCodeTldp.equals(resourceCode)) {   // =========== 铁路订票数据
                             String ph = oriField.getString("TRAIN_TIC_NO");               // 票号
                             String ccrXm = oriField.getString("NAME");                    // 乘车人姓名
                             String ccrSfzh = oriField.getString("CRED_NUM");              // 乘车人身份证号
@@ -266,7 +302,6 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
                             String zwh = oriField.getString("SEAT_NO");                   // 座位号
                             String fzmc = oriField.getString("DEP_STAT_DESIG");           // 发站名称
                             String dzmc = oriField.getString("ARR_STAT_DESIG");           // 到站名称
-                            String captureTime = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("CAPTURE_TIME")));
                             String spsj = oriField.getString("TIC_DATE");                 // 售票时间
                             String ccrq = oriField.getString("RIDING_DATE");              // 乘车日期
                             String fcsj = oriField.getString("DEP_TIME");                 // 发车时间
@@ -280,12 +315,13 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
                             String lxrXm = oriField.getString("CTCT_PERSON_NAME");        // 联系人姓名
                             String lxrLxdh = oriField.getString("CTCT_PERSON_CTCT_TEL");  // 联系人联系电话
                             String hcz = oriField.getString("TRASTA_NAME");               // 火车站
-                            yjxxsm.append("订票人(身份证号:");
+                            String captureTimeTldp = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("CAPTURE_TIME")));
+                            yjxxsm.append("铁路订票 - 票号:");
+                            yjxxsm.append(ph);
+                            yjxxsm.append(",订票人身份证号:");
                             yjxxsm.append(dprSfzh);
-                            yjxxsm.append(")购买");
+                            yjxxsm.append(",车次:");
                             yjxxsm.append(cc);
-                            yjxxsm.append("次列车车票,票号:");
-                            yjxxsm.append(ph);
                             yjxxsm.append(",售票时间:");
                             yjxxsm.append(spsj);
                             yjxxsm.append(",售票方式:");
@@ -324,7 +360,393 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
                             yjxxsm.append(lxrLxdh);
                             yjxxsm.append(",火车站:");
                             yjxxsm.append(hcz);
-                            warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, ccrXm, ccrSfzh, ccrSjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTime, 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});
+                            warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, ccrXm, ccrSfzh, ccrSjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, captureTimeTldp, 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});
+                            yjxxsm.setLength(0);
+                        } else if (resCodeMhdp.equals(resourceCode)) {   // =========== 民航订票数据
+                            String dzjlbh = oriField.getString("ORDSEAT_RECO_NO");             // 订座记录编号
+                            String dph = oriField.getString("BOOTIC_NO");                      // 订票号
+                            String lkzwm = oriField.getString("PASS_NAME");                    // 旅客中文名
+                            String zjhm = oriField.getString("CRED_NUM");                      // 旅客证件号码
+                            String lklxdh = oriField.getString("PASS_CTCT_TEL");               // 旅客联系电话
+                            String cyhkgs = oriField.getString("CARR_ORGA_AIRLINE_NAME");      // 承运航空公司
+                            String zrhkgs = oriField.getString("RESP_UNIT_AIRLINE_NAME");      // 责任航空公司
+                            String hbh = oriField.getString("FLINUM");                         // 航班号
+                            String qfjc = oriField.getString("FLY_INIT_NRT_AIRPORT_NAME");     // 起飞机场
+                            String qfzcs = oriField.getString("FLY_INIT_ADDR_CITY_NAME");      // 起飞站城市
+                            String ddjc = oriField.getString("ARR_AT_AIR_AIRPORT_NAME");       // 到达机场
+                            String ddzcs = oriField.getString("ARR_ADDR_CITY_NAME");           // 到达站城市
+                            String cfrq = oriField.getString("STAOFF_DATE");                   // 出发日期
+                            String cfsj = oriField.getString("STAOFF_TIME");                   // 出发时间
+                            String ddrq = oriField.getString("ARR_DATE");                      // 到达日期
+                            String ddsj = oriField.getString("ARR_TIME");                      // 到达时间
+                            String kpzt = oriField.getString("ELE_TIC_STAT_NAME");             // 客票状态
+                            String cw = oriField.getString("CHISHI_SEAT");                     // 舱位
+                            String dpsj = oriField.getString("BOOTIC_TIME");                   // 订票时间
+                            String captureTimeMhdp = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("CAPTURE_TIME")));
+                            yjxxsm.append("民航订票 - 订座记录编号:");
+                            yjxxsm.append(dzjlbh);
+                            yjxxsm.append(",订票号:");
+                            yjxxsm.append(dph);
+                            yjxxsm.append(",订票时间:");
+                            yjxxsm.append(dpsj);
+                            yjxxsm.append(",旅客中文名:");
+                            yjxxsm.append(lkzwm);
+                            yjxxsm.append(",旅客证件号码:");
+                            yjxxsm.append(zjhm);
+                            yjxxsm.append(",旅客联系电话:");
+                            yjxxsm.append(lklxdh);
+                            yjxxsm.append(",承运航空公司:");
+                            yjxxsm.append(cyhkgs);
+                            yjxxsm.append(",责任航空公司:");
+                            yjxxsm.append(zrhkgs);
+                            yjxxsm.append(",航班号:");
+                            yjxxsm.append(hbh);
+                            yjxxsm.append(",舱位:");
+                            yjxxsm.append(cw);
+                            yjxxsm.append(",出发时间:");
+                            yjxxsm.append(cfsj);
+                            yjxxsm.append(",到达时间:");
+                            yjxxsm.append(ddsj);
+                            yjxxsm.append(",起飞机场:");
+                            yjxxsm.append(qfjc);
+                            yjxxsm.append(",起飞站城市:");
+                            yjxxsm.append(qfzcs);
+                            yjxxsm.append(",到达机场:");
+                            yjxxsm.append(ddjc);
+                            yjxxsm.append(",到达站城市:");
+                            yjxxsm.append(ddzcs);
+                            yjxxsm.append(",客票状态:");
+                            yjxxsm.append(kpzt);
+                            warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, lkzwm, zjhm, lklxdh, 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});
+                            yjxxsm.setLength(0);
+                        } else if (resCodeJnryzs.equals(resourceCode)) {   // =========== 境内人员住宿数据
+                            String lgbh = oriField.getString("HOTEL_NO");                       // 旅馆编号
+                            String lgmc = oriField.getString("HOTE_NAME");                      // 旅馆名称
+                            String lgdz = oriField.getString("HOTEL_ADDR_ADDR_NAME");           // 旅馆地址
+                            String lgjd = oriField.getString("HOTEL_LON");                      // 旅馆经度
+                            String lgwd = oriField.getString("HOTEL_LAT");                      // 旅馆纬度
+                            String lglx = oriField.getString("HOTE_TYPE_NAME");                 // 旅馆类型
+                            String rzrXm = oriField.getString("NAME");                          // 姓名
+                            String rzrSfzh = oriField.getString("CERT_NO");                     // 身份证号
+                            String rzrLxdh = oriField.getString("CTCT_TEL");                    // 旅客联系电话
+                            String rylx = oriField.getString("PER_CLAS_NAME");                  // 人员类型
+                            String gj = oriField.getString("NATION_NAME");                      // 国籍
+                            String hjdz = oriField.getString("DOMIC_ADDR_NAME");                // 户籍地址
+                            String rzsj = oriField.getString("ADMI_TIME");                      // 入住时间
+                            String tfsj = oriField.getString("CHOUT_TIME");                     // 退房时间
+                            String zsts = oriField.getString("LODG_DAY_NUM");                   // 住宿天数
+                            String fjh = oriField.getString("ROOM_NO");                         // 房间号
+                            String rzrs = oriField.getString("ADMISSION_PER_NUM");              // 入住人数
+                            String ywsxcl = oriField.getString("THER_ACCO_VEHI_JUDGE_FLAG");    // 有无随行车辆
+                            String sxclhp = oriField.getString("ACCO_VEH_VEH_PLATE_NUM");       // 随行车辆号牌
+                            String wypt = oriField.getString("PLAT_NAME");                      // 网约平台
+                            String ydrXm = oriField.getString("APPO_PER_NAME");                 // 预定人姓名
+                            String ydrSfzh = oriField.getString("APPO_PER_CERT_NO");            // 预定人身份证号
+                            String ydrSjh = oriField.getString("APPO_PER_CTCT_TEL");            // 预定人手机号
+                            String rzr2Xm = oriField.getString("ADMIS_PER_TWO_NAME");           // 入住人2姓名
+                            String rzr2Sfzh = oriField.getString("ADMIS_PER_TWO_CERT_NO");      // 入住人2身份证号
+                            String rzr2Lxfs = oriField.getString("ADMIS_PER_TWO_CTCT_TEL");     // 入住人2联系方式
+                            String captureTimeJnryzs = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("CAPTURE_TIME")));
+                            yjxxsm.append("旅馆住宿 - 旅馆编号:");
+                            yjxxsm.append(lgbh);
+                            yjxxsm.append(",旅馆名称:");
+                            yjxxsm.append(lgmc);
+                            yjxxsm.append(",旅馆地址:");
+                            yjxxsm.append(lgdz);
+                            yjxxsm.append(",旅馆类型:");
+                            yjxxsm.append(lglx);
+                            yjxxsm.append(",预定人姓名:");
+                            yjxxsm.append(ydrXm);
+                            yjxxsm.append(",预定人身份证号:");
+                            yjxxsm.append(ydrSfzh);
+                            yjxxsm.append(",预定人手机号:");
+                            yjxxsm.append(ydrSjh);
+                            yjxxsm.append(",网约平台:");
+                            yjxxsm.append(wypt);
+                            yjxxsm.append(",入住人姓名:");
+                            yjxxsm.append(rzrXm);
+                            yjxxsm.append(",入住人身份证号:");
+                            yjxxsm.append(rzrSfzh);
+                            yjxxsm.append(",入住人联系电话:");
+                            yjxxsm.append(rzrLxdh);
+                            yjxxsm.append(",人员类型:");
+                            yjxxsm.append(rylx);
+                            yjxxsm.append(",国籍:");
+                            yjxxsm.append(gj);
+                            yjxxsm.append(",户籍地址:");
+                            yjxxsm.append(hjdz);
+                            yjxxsm.append(",入住时间:");
+                            yjxxsm.append(rzsj);
+                            yjxxsm.append(",退房时间:");
+                            yjxxsm.append(tfsj);
+                            yjxxsm.append(",房间号:");
+                            yjxxsm.append(fjh);
+                            yjxxsm.append(",住宿天数:");
+                            yjxxsm.append(zsts);
+                            yjxxsm.append(",入住人数:");
+                            yjxxsm.append(rzrs);
+                            yjxxsm.append(",有无随行车辆:");
+                            yjxxsm.append(ywsxcl);
+                            yjxxsm.append(",随行车辆号牌:");
+                            yjxxsm.append(sxclhp);
+                            yjxxsm.append(",入住人2姓名:");
+                            yjxxsm.append(rzr2Xm);
+                            yjxxsm.append(",入住人2身份证号:");
+                            yjxxsm.append(rzr2Sfzh);
+                            yjxxsm.append(",入住人2联系电话:");
+                            yjxxsm.append(rzr2Lxfs);
+                            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, rzr2Xm, rzr2Sfzh, rzr2Lxfs});
+                            yjxxsm.setLength(0);
+                        } else if (resCodeWbsw.equals(resourceCode)) {   // =========== 网吧上网数据
+                            String swryXm = oriField.getString("INTE_PER_NAME");        // 上网人员姓名
+                            String swrySfzh = oriField.getString("CRED_NUM");           // 上网人员身份证号
+                            String swryLxdh = oriField.getString("CTCT_TEL");           // 上网人员联系电话
+                            String swzdbh = oriField.getString("INTENET_TERM_NO");      // 上网终端编号
+                            String ip = oriField.getString("MAIENG_IP");                // IP地址
+                            String zdmc = oriField.getString("TERM_DESIG");             // 终端名称
+                            String zdmac = oriField.getString("TERM_MAC");              // 终端mac地址
+                            String swkssj = oriField.getString("INTENET_START_TIME");   // 上网开始时间
+                            String swjssj = oriField.getString("INTENET_END_TIME");     // 上网结束时间
+                            String swsc = oriField.getString("INTENET_TIME_LENGTH");    // 上网时长
+                            String yycsbh = oriField.getString("PREM_NO");              // 营业场所编号
+                            String yycsmc = oriField.getString("PREM_DESIG");           // 营业场所名称
+                            String dzmc = oriField.getString("ADDR_NAME");              // 地址名称
+                            String jd = oriField.getString("LON");                      // 经度
+                            String wd = oriField.getString("LAT");                      // 纬度
+                            String frXm = oriField.getString("LEGAL_NAME");             // 法人姓名
+                            String frSfzh = oriField.getString("LEGAL_CRED_NUM");       // 法人身份证号
+                            String frLxdh = oriField.getString("LEGAL_CTCT_TEL");       // 法人联系电话
+                            String captureTimeWbsw = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("CAPTURE_TIME")));
+                            yjxxsm.append("网吧上网 - 上网人员姓名:");
+                            yjxxsm.append(swryXm);
+                            yjxxsm.append(",上网人员身份证号:");
+                            yjxxsm.append(swrySfzh);
+                            yjxxsm.append(",上网人员联系电话:");
+                            yjxxsm.append(swryLxdh);
+                            yjxxsm.append(",上网终端编号:");
+                            yjxxsm.append(swzdbh);
+                            yjxxsm.append(",IP:");
+                            yjxxsm.append(ip);
+                            yjxxsm.append(",终端名称:");
+                            yjxxsm.append(zdmc);
+                            yjxxsm.append(",终端mac:");
+                            yjxxsm.append(zdmac);
+                            yjxxsm.append(",上网开始时间:");
+                            yjxxsm.append(swkssj);
+                            yjxxsm.append(",上网结束时间:");
+                            yjxxsm.append(swjssj);
+                            yjxxsm.append(",上网时长:");
+                            yjxxsm.append(swsc);
+                            yjxxsm.append(",营业场所编号:");
+                            yjxxsm.append(yycsbh);
+                            yjxxsm.append(",营业场所名称:");
+                            yjxxsm.append(yycsmc);
+                            yjxxsm.append(",地址:");
+                            yjxxsm.append(dzmc);
+                            yjxxsm.append(",法人姓名:");
+                            yjxxsm.append(frXm);
+                            yjxxsm.append(",法人身份证号:");
+                            yjxxsm.append(frSfzh);
+                            yjxxsm.append(",法人联系电话:");
+                            yjxxsm.append(frLxdh);
+                            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, jd, wd, currentTime, currentTime, frXm, frSfzh, frLxdh});
+                            yjxxsm.setLength(0);
+                        } else if (resCodeDt.equals(resourceCode)) {   // =========== 地铁数据
+                            String ckXm = oriField.getString("XM");               // 乘客姓名
+                            String ckSfzh = oriField.getString("ZJHM");           // 乘客身份证号
+                            String ckLxdh = oriField.getString("YDDH");           // 乘客联系电话
+                            String skkh = oriField.getString("KH_XXBH");          // 刷卡卡号
+                            String sksj = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("SHK_JDSJ"))); // 刷卡时间
+                            String czmc = oriField.getString("CZM_MC");           // 车站名称
+                            String flmc = oriField.getString("FL_MC");            // 分类名称
+                            String jczbsmc = oriField.getString("JCZ_BS_MC");     // 进出站标识名称
+                            String jylxmc = oriField.getString("JY_LEX_MC");      // 交易类型名称
+                            String zjh = oriField.getString("ZHJH_JYQK");         // 闸机号
+                            String dtxlxx = oriField.getString("DTXLXX");         // 地铁线路信息
+                            String captureTimeDt = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("CAPTURE_TIME")));
+                            yjxxsm.append("地铁数据 - 乘客姓名:");
+                            yjxxsm.append(ckXm);
+                            yjxxsm.append(",乘客身份证号:");
+                            yjxxsm.append(ckSfzh);
+                            yjxxsm.append(",乘客联系电话:");
+                            yjxxsm.append(ckLxdh);
+                            yjxxsm.append(",刷卡卡号:");
+                            yjxxsm.append(skkh);
+                            yjxxsm.append(",刷卡时间:");
+                            yjxxsm.append(sksj);
+                            yjxxsm.append(",车站名称:");
+                            yjxxsm.append(czmc);
+                            yjxxsm.append(",分类名称:");
+                            yjxxsm.append(flmc);
+                            yjxxsm.append(",进出站标识名称:");
+                            yjxxsm.append(jczbsmc);
+                            yjxxsm.append(",交易类型名称:");
+                            yjxxsm.append(jylxmc);
+                            yjxxsm.append(",闸机号:");
+                            yjxxsm.append(zjh);
+                            yjxxsm.append(",地铁线路信息:");
+                            yjxxsm.append(dtxlxx);
+                            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});
+                            yjxxsm.setLength(0);
+                        } else if (resCodeSjrd.equals(resourceCode)) {   // =========== 手机热点
+                            String yddh = oriField.getString("YDDH");                  // 移动电话
+                            String cjsbxxbh = oriField.getString("CHJI_SBE_XXBH");     // 城际设备信息编号
+                            String imsi = oriField.getString("GJYDYHSBM");             // 国际移动用户识别码,IMSI
+                            String imei = oriField.getString("GJYDSBSFDM");            // 国际移动设备识别码,IMEI
+                            String jhjxxbh = oriField.getString("JHJ_XXBH");           // 交换机信息编号
+                            String wzqyxxbh = oriField.getString("WZH_QUY_XXBH");      // 位置区域信息编号
+                            String xqxxbh = oriField.getString("XIQ_XXBH");            // 小区信息编号
+                            String jd = oriField.getString("DQJD");                    // 经度
+                            String wd = oriField.getString("DQWD");                    // 纬度
+                            String glsj = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("JDSJ")));   // 关联时间
+                            String captureTimeSjrd = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("CAPTURE_TIME")));
+                            yjxxsm.append("手机热点 - 移动电话:");
+                            yjxxsm.append(yddh);
+                            yjxxsm.append(",城际设备信息编号:");
+                            yjxxsm.append(cjsbxxbh);
+                            yjxxsm.append(",IMSI:");
+                            yjxxsm.append(imsi);
+                            yjxxsm.append(",IMEI:");
+                            yjxxsm.append(imei);
+                            yjxxsm.append(",交换机信息编号:");
+                            yjxxsm.append(jhjxxbh);
+                            yjxxsm.append(",位置区域信息编号:");
+                            yjxxsm.append(wzqyxxbh);
+                            yjxxsm.append(",小区信息编号:");
+                            yjxxsm.append(xqxxbh);
+                            yjxxsm.append(",关联时间:");
+                            yjxxsm.append(glsj);
+                            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});
+                            yjxxsm.setLength(0);
+                        } else if (resCodeXlpc.equals(resourceCode)) {   // =========== 巡逻盘查(人员)
+                            String kkxxId = oriField.getString("KAK_XXID");                  // 卡口信息ID
+                            String kkmc = oriField.getString("KAK_MC");                      // 卡口名称
+                            String zdxh = oriField.getString("ZHD_XH");                      // 终端型号
+                            String kkssdwmc = oriField.getString("KAK_SS_DAW_MC");           // 卡口所属单位名称
+                            String pcsj = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("PAC_JDSJ")));   // 盘查时间
+                            String xm = oriField.getString("XM");                            // 人员姓名
+                            String sfzh = oriField.getString("GMSFHM");                      // 人员身份证号
+                            String lxdh = oriField.getString("LXDH");                        // 人员联系电话
+                            String rybq = oriField.getString("REY_BQI_MC");                  // 人员标签
+                            String jg = oriField.getString("JG_XZQHMC");                     // 籍贯
+                            String mz = oriField.getString("MZMZWZ");                        // 民族
+                            String jzdxxdz = oriField.getString("JZD_QHNXXDZ");              // 居住地区划内详细地址
+                            String pcmjXm = oriField.getString("PAC_MJ_XM");                 // 盘查民警姓名
+                            String pcmjJh = oriField.getString("PAC_MJ_JH");                 // 盘查民警警号
+                            String pcmjZh = oriField.getString("PAC_MJ_ZH");                 // 盘查民警账号
+                            String pcmjSsdwmc = oriField.getString("PAC_MJ_SS_DWMC");        // 盘查民警所属单位名称
+                            String pccljg = oriField.getString("PAC_CHL_JGU_MC");            // 盘查处理结果
+                            String pcclyjdwmc = oriField.getString("PAC_CHL_YIJ_DWMC");      // 盘查处理移交单位名称
+                            String pcdJd = oriField.getString("PCD_DQJD");                   // 盘查地经度
+                            String pcdWd = oriField.getString("PCD_DQWD");                   // 盘查地纬度
+                            String captureTimeXlpc = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("CAPTURE_TIME")));
+                            yjxxsm.append("巡逻盘查 - 人员姓名:");
+                            yjxxsm.append(xm);
+                            yjxxsm.append(",人员身份证号:");
+                            yjxxsm.append(sfzh);
+                            yjxxsm.append(",人员联系电话:");
+                            yjxxsm.append(lxdh);
+                            yjxxsm.append(",人员标签:");
+                            yjxxsm.append(rybq);
+                            yjxxsm.append(",籍贯:");
+                            yjxxsm.append(jg);
+                            yjxxsm.append(",民族:");
+                            yjxxsm.append(mz);
+                            yjxxsm.append(",居住地详细地址:");
+                            yjxxsm.append(jzdxxdz);
+                            yjxxsm.append(",盘查时间:");
+                            yjxxsm.append(pcsj);
+                            yjxxsm.append(",卡口信息ID:");
+                            yjxxsm.append(kkxxId);
+                            yjxxsm.append(",卡口名称:");
+                            yjxxsm.append(kkmc);
+                            yjxxsm.append(",终端型号:");
+                            yjxxsm.append(zdxh);
+                            yjxxsm.append(",卡口所属单位名称:");
+                            yjxxsm.append(kkssdwmc);
+                            yjxxsm.append(",盘查民警姓名:");
+                            yjxxsm.append(pcmjXm);
+                            yjxxsm.append(",盘查民警警号:");
+                            yjxxsm.append(pcmjJh);
+                            yjxxsm.append(",盘查民警账号:");
+                            yjxxsm.append(pcmjZh);
+                            yjxxsm.append(",盘查民警所属单位名称:");
+                            yjxxsm.append(pcmjSsdwmc);
+                            yjxxsm.append(",盘查处理结果:");
+                            yjxxsm.append(pccljg);
+                            yjxxsm.append(",盘查处理移交单位名称:");
+                            yjxxsm.append(pcclyjdwmc);
+                            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});
+                            yjxxsm.setLength(0);
+                        } else if (resCodeZdjc.equals(resourceCode)) {   // =========== 站点检查(人员)
+                            String xm = oriField.getString("XM");                            // 人员姓名
+                            String sfzh = oriField.getString("GMSFHM");                      // 人员身份证号
+                            String mz = oriField.getString("MZMZWZ");                        // 民族
+                            String dz = oriField.getString("DZMC");                          // 地址
+                            String fzjg = oriField.getString("FZJG_MC");                     // 发证机关
+                            String zjyxqsrq = oriField.getString("ZJYXQ_KS_RQ");             // 证件有效起始日期
+                            String zjyxzzrq = oriField.getString("ZJYXQ_JSH_RQ");            // 证件有效终止日期
+                            String jybh = oriField.getString("JYU_BH");                      // 警员编号
+                            String jczmc = oriField.getString("JICZ_MC");                    // 检查站名称
+                            String jcsj = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("JIC_JDSJ")));   // 检查时间
+                            String captureTimeZdjc = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("CAPTURE_TIME")));
+                            yjxxsm.append("站点检查 - 人员姓名:");
+                            yjxxsm.append(xm);
+                            yjxxsm.append(",人员身份证号:");
+                            yjxxsm.append(sfzh);
+                            yjxxsm.append(",民族:");
+                            yjxxsm.append(mz);
+                            yjxxsm.append(",地址:");
+                            yjxxsm.append(dz);
+                            yjxxsm.append(",检查时间:");
+                            yjxxsm.append(jcsj);
+                            yjxxsm.append(",发证机关:");
+                            yjxxsm.append(fzjg);
+                            yjxxsm.append(",证件有效起始日期:");
+                            yjxxsm.append(zjyxqsrq);
+                            yjxxsm.append(",证件有效终止日期:");
+                            yjxxsm.append(zjyxzzrq);
+                            yjxxsm.append(",警员编号:");
+                            yjxxsm.append(jybh);
+                            yjxxsm.append(",检查站名称:");
+                            yjxxsm.append(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});
+                            yjxxsm.setLength(0);
+                        } else if (resCodeDzwl.equals(resourceCode)) {   // =========== 电子围栏(火车站)
+                            String yddh = oriField.getString("MOB");                         // 移动电话
+                            String imsi = oriField.getString("IMSI");                        // 国际移动用户识别码
+                            String imei = oriField.getString("IMEI");                        // 国际移动设备识别码
+                            String sjMac = oriField.getString("MOBPHO_MAC");                 // 手机MAC地址
+                            String yysmc = oriField.getString("SP_NAME");                    // 运营商名称
+                            String sbbh = oriField.getString("EQUIPMENT_NO");                // 设备编号
+                            String szdqbh = oriField.getString("IN_THE_AREA_NO");            // 所在地区编号
+                            String csbh = oriField.getString("COMP_NO");                     // 厂商编号
+                            String wllxmc = oriField.getString("NET_TYPE_NAME");             // 网络类型名称
+                            String pd = oriField.getString("FREPOI");                        // 频点
+                            String jzdqJd = oriField.getString("BASSTA_LON");                // 基站地球经度
+                            String jzdqWd = oriField.getString("BASSTA_LAT");                // 基站地球纬度
+                            String captureTimeDzwl = TimeTool.timeStampToDateString(Long.valueOf(oriField.getString("CAPTURE_TIME")));
+                            yjxxsm.append("电子围栏(火车站) - 移动电话:");
+                            yjxxsm.append(yddh);
+                            yjxxsm.append(",IMSI:");
+                            yjxxsm.append(imsi);
+                            yjxxsm.append(",IMEI:");
+                            yjxxsm.append(imei);
+                            yjxxsm.append(",手机MAC地址:");
+                            yjxxsm.append(sjMac);
+                            yjxxsm.append(",运营商名称:");
+                            yjxxsm.append(yysmc);
+                            yjxxsm.append(",设备编号:");
+                            yjxxsm.append(sbbh);
+                            yjxxsm.append(",所在地区编号:");
+                            yjxxsm.append(szdqbh);
+                            yjxxsm.append(",厂商编号:");
+                            yjxxsm.append(csbh);
+                            yjxxsm.append(",网络类型名称:");
+                            yjxxsm.append(wllxmc);
+                            yjxxsm.append(",频点:");
+                            yjxxsm.append(pd);
+                            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});
                             yjxxsm.setLength(0);
                         }
                     }

+ 19 - 2
src/main/resources/application.properties

@@ -84,6 +84,8 @@ query.max.count=10000
 # \u6570\u636E\u8D44\u6E90\u4E1A\u52A1\u7F16\u53F7=\u70FD\u706B\u6570\u636E\u8D44\u6E90\u7F16\u7801
 # AUTH\u8BA4\u8BC1\u6570\u636E
 res.code.auth=134B102
+# \u5BA2\u8FD0\u6570\u636E
+res.code.ky=991C1516
 # \u94C1\u8DEF\u8BA2\u7968
 res.code.tldp=991C1398
 # \u6C11\u822A\u8BA2\u7968
@@ -92,8 +94,23 @@ res.code.mhdp=991C1233
 res.code.jnryzs=991C1223
 # \u7F51\u5427\u4E0A\u7F51
 res.code.wbsw=991C1071
-# \u5BA2\u8FD0\u6570\u636E
-res.code.ky=991C1516
+# \u5730\u94C1\u6570\u636E
+res.code.dt=01C1200002598
+# \u624B\u673A\u70ED\u70B9
+res.code.sjrd=01C1200002597
+# \u5DE1\u903B\u76D8\u67E5\uFF08\u4EBA\u5458\uFF09
+res.code.xlpc=01C1200001942
+# \u7AD9\u70B9\u68C0\u67E5\uFF08\u4EBA\u5458\uFF09
+res.code.zdjc=01C1200002316
+# \u7535\u5B50\u56F4\u680F\uFF08\u706B\u8F66\u7AD9\uFF09
+res.code.dzwl=991C1356
+
+
+# \u706B\u8F66\u7AD9\uFF08\u5929\u6D25\u7AD9\uFF09\u533A\u57DF\u7ECF\u7EAC\u5EA6\u96C6\u5408
+center.lon.hcz=
+center.lat.hcz=
+# \u534A\u5F84\uFF0C\u5355\u4F4D\uFF1A\u7C73
+radius.hcz=