From f4e5da604604308b9f754de7e863c180fcedd8c9 Mon Sep 17 00:00:00 2001
From: xusd <330628789@qq.com>
Date: Tue, 24 Jun 2025 21:03:12 +0800
Subject: [PATCH] fix:超时办件优化
---
dyh-service/dyh-sys/src/main/java/cn/huge/module/timer/GridCityCaseTimer.java | 371 ++++++++++++++++++++++++++--------------------------
1 files changed, 187 insertions(+), 184 deletions(-)
diff --git a/dyh-service/dyh-sys/src/main/java/cn/huge/module/timer/GridCityCaseTimer.java b/dyh-service/dyh-sys/src/main/java/cn/huge/module/timer/GridCityCaseTimer.java
index 2442725..a21f981 100644
--- a/dyh-service/dyh-sys/src/main/java/cn/huge/module/timer/GridCityCaseTimer.java
+++ b/dyh-service/dyh-sys/src/main/java/cn/huge/module/timer/GridCityCaseTimer.java
@@ -73,6 +73,7 @@
Date nowDate = DateUtils.getNowDate();
List<String> canalSecondList = new ArrayList<>();
canalSecondList.add("12");
+ canalSecondList.add("13");
canalSecondList.add("07");
// 获取东八区的当前时间
ZonedDateTime now = ZonedDateTime.now(TARGET_ZONE);
@@ -147,7 +148,7 @@
String fxdj = "";
String zrmj = "";
String zrga = "";
- String jyff="";
+ String jyff = "";
String tcr = "";
String tcqk = "";
String tcjg = "";
@@ -155,101 +156,93 @@
String certiNo = "";
String plaintiffs = "";
String phone = "";
- if ("07".equals(canalSecond)) {
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getLinkman())) {
- uploadPolice = AesUtils.decrypt(gridCaseInfoDTO.getLinkman(), "W90akz7tA7tyMn5tNTynG69YM2E8jGfF");
- }
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getContactTel())) {
- uploadPolicePhone = AesUtils.decrypt(gridCaseInfoDTO.getContactTel(), "W90akz7tA7tyMn5tNTynG69YM2E8jGfF");
- }
- } else if ("12".equals(canalSecond)) {
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getLinkman())) {
- uploadPolice = AesUtils.decrypt(gridCaseInfoDTO.getLinkman(), "W90akz7tA7tyMn5tNTynG69YM2E8jGfF");
- }
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getContactTel())) {
- uploadPolicePhone = AesUtils.decrypt(gridCaseInfoDTO.getContactTel(), "W90akz7tA7tyMn5tNTynG69YM2E8jGfF");
- }
- try {
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getExtInfo())) {
- JSONObject jsonObject = JSON.parseObject(gridCaseInfoDTO.getExtInfo());
- zrga = jsonObject.get("tcdwMc").toString();
- zrmj = jsonObject.get("zrmj").toString();
- fxdj = jsonObject.get("fxdj").toString();
- jfmc = jsonObject.get("jfmc").toString();
- registerSaveDTO.setGridHandle(zrga + "--" + zrmj);
- }
- } catch (Exception e) {
- log.error("解析extInfo失败，事件id：{" + gridCaseInfoDTO.getId() + "}; 解析内容：" + gridCaseInfoDTO.getExtInfo() + "失败原因：" + e.getMessage());
- }
- try {
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getExtInfoTcqk())) {
- List<Map<String, Object>> expInfoTcqkMapList = JSON.parseObject(gridCaseInfoDTO.getExtInfoTcqk(),
- new TypeReference<List<Map<String, Object>>>() {
- });
- for (Map expInfoMap : expInfoTcqkMapList) {
- tcr = expInfoMap.get("tcr").toString();
- tcqk = expInfoMap.get("tcqk").toString();
- tcjg = expInfoMap.get("tcjgMc").toString();
- tcfa = expInfoMap.get("tcfa").toString();
- }
- }
- } catch (Exception e) {
- log.error("解析extInfo失败，事件id：{" + gridCaseInfoDTO.getId() + "}; 解析内容：" + gridCaseInfoDTO.getExtInfo() + "失败原因：" + e.getMessage());
- }
- registerSaveDTO.setTcqk(uploadPolice+" -- "+uploadPolicePhone+" -- "+fxdj+" -- "+zrmj+" -- "+tcr+" -- "+tcfa+" -- "+tcqk);
- try {
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getExtInfoRisk())) {
- List<Map<String, Object>> expInfoMapList = JSON.parseObject(gridCaseInfoDTO.getExtInfoRisk(),
- new TypeReference<List<Map<String, Object>>>() {
- });
- List<CasePersonDTO> casePersonDTOList = new ArrayList<>();
- for (Map expInfoMap : expInfoMapList) {
- CasePersonDTO casePersonDTO = new CasePersonDTO();
- String name = "";
- certiNo = "";
- String mobile = "";
- if (StringUtils.isNotBlank(expInfoMap.get("cardNumber").toString())) {
- certiNo = expInfoMap.get("cardNumber").toString();
- }
- if (StringUtils.isNotBlank(expInfoMap.get("name").toString())) {
- name = expInfoMap.get("name").toString();
- }
- if (StringUtils.isNotBlank(expInfoMap.get("contactPhone").toString())) {
- mobile = expInfoMap.get("contactPhone").toString();
- }
- casePersonDTO.setMobile(mobile);
- casePersonDTO.setTrueName(name);
- casePersonDTO.setCertiNo(certiNo);
- casePersonDTOList.add(casePersonDTO);
- gridEvent.setCertiNo(certiNo);
- if (StringUtils.isNotBlank(plaintiffs)) {
- if (!plaintiffs.contains(name))
- plaintiffs = plaintiffs + "," + name;
- } else {
- plaintiffs = name;
- }
- if (StringUtils.isNotBlank(phone)) {
- if (!phone.contains(mobile))
- phone = phone + "," + mobile;
- } else {
- phone = mobile;
- }
- if (StringUtils.isNotBlank(gridEvent.getCertiNo())) {
- gridEvent.setCertiNo(gridEvent.getCertiNo() + "," + certiNo);
- } else {
- gridEvent.setCertiNo(certiNo);
- }
- }
- registerSaveDTO.setPersonList(casePersonDTOList);
- }
- } catch (Exception e) {
- log.error("解析extInfo失败，事件id：{" + gridCaseInfoDTO.getId() + "}; 解析内容：" + gridCaseInfoDTO.getExtInfo() + "失败原因：" + e.getMessage());
+ if (StringUtils.isNotBlank(gridCaseInfoDTO.getLinkman())) {
+ uploadPolice = AesUtils.decrypt(gridCaseInfoDTO.getLinkman(), "W90akz7tA7tyMn5tNTynG69YM2E8jGfF");
+ }
+ if (StringUtils.isNotBlank(gridCaseInfoDTO.getContactTel())) {
+ uploadPolicePhone = AesUtils.decrypt(gridCaseInfoDTO.getContactTel(), "W90akz7tA7tyMn5tNTynG69YM2E8jGfF");
+ }
+ try {
+ if (StringUtils.isNotBlank(gridCaseInfoDTO.getExtInfo())) {
+ JSONObject jsonObject = JSON.parseObject(gridCaseInfoDTO.getExtInfo());
+ zrga = jsonObject.get("tcdwMc").toString();
+ zrmj = jsonObject.get("zrmj").toString();
+ fxdj = jsonObject.get("fxdj").toString();
+ jfmc = jsonObject.get("jfmc").toString();
+ registerSaveDTO.setGridHandle(zrga + "--" + zrmj);
}
+ } catch (Exception e) {
+ log.error("解析extInfo失败，事件id：{" + gridCaseInfoDTO.getId() + "}; 解析内容：" + gridCaseInfoDTO.getExtInfo() + "失败原因：" + e.getMessage());
+ }
+ try {
+ if (StringUtils.isNotBlank(gridCaseInfoDTO.getExtInfoTcqk())) {
+ List<Map<String, Object>> expInfoTcqkMapList = JSON.parseObject(gridCaseInfoDTO.getExtInfoTcqk(),
+ new TypeReference<List<Map<String, Object>>>() {
+ });
+ for (Map expInfoMap : expInfoTcqkMapList) {
+ tcr = expInfoMap.get("tcr").toString();
+ tcqk = expInfoMap.get("tcqk").toString();
+ tcjg = expInfoMap.get("tcjgMc").toString();
+ tcfa = expInfoMap.get("tcfa").toString();
+ }
+ }
+ } catch (Exception e) {
+ log.error("解析extInfo失败，事件id：{" + gridCaseInfoDTO.getId() + "}; 解析内容：" + gridCaseInfoDTO.getExtInfo() + "失败原因：" + e.getMessage());
+ }
+ registerSaveDTO.setTcqk(uploadPolice + " -- " + uploadPolicePhone + " -- " + fxdj + " -- " + zrmj + " -- " + tcr + " -- " + tcfa + " -- " + tcqk);
+ try {
+ if (StringUtils.isNotBlank(gridCaseInfoDTO.getExtInfoRisk())) {
+ List<Map<String, Object>> expInfoMapList = JSON.parseObject(gridCaseInfoDTO.getExtInfoRisk(),
+ new TypeReference<List<Map<String, Object>>>() {
+ });
+ List<CasePersonDTO> casePersonDTOList = new ArrayList<>();
+ for (Map expInfoMap : expInfoMapList) {
+ CasePersonDTO casePersonDTO = new CasePersonDTO();
+ String name = "";
+ certiNo = "";
+ String mobile = "";
+ if (StringUtils.isNotBlank(expInfoMap.get("cardNumber").toString())) {
+ certiNo = expInfoMap.get("cardNumber").toString();
+ }
+ if (StringUtils.isNotBlank(expInfoMap.get("name").toString())) {
+ name = expInfoMap.get("name").toString();
+ }
+ if (StringUtils.isNotBlank(expInfoMap.get("contactPhone").toString())) {
+ mobile = expInfoMap.get("contactPhone").toString();
+ }
+ casePersonDTO.setMobile(mobile);
+ casePersonDTO.setTrueName(name);
+ casePersonDTO.setCertiNo(certiNo);
+ casePersonDTOList.add(casePersonDTO);
+ gridEvent.setCertiNo(certiNo);
+
+ if (StringUtils.isNotBlank(plaintiffs)) {
+ if (!plaintiffs.contains(name))
+ plaintiffs = plaintiffs + "," + name;
+ } else {
+ plaintiffs = name;
+ }
+ if (StringUtils.isNotBlank(phone)) {
+ if (!phone.contains(mobile))
+ phone = phone + "," + mobile;
+ } else {
+ phone = mobile;
+ }
+ if (StringUtils.isNotBlank(gridEvent.getCertiNo())) {
+ gridEvent.setCertiNo(gridEvent.getCertiNo() + "," + certiNo);
+ } else {
+ gridEvent.setCertiNo(certiNo);
+ }
+ }
+ registerSaveDTO.setPersonList(casePersonDTOList);
+ }
+ } catch (Exception e) {
+ log.error("解析extInfo失败，事件id：{" + gridCaseInfoDTO.getId() + "}; 解析内容：" + gridCaseInfoDTO.getExtInfo() + "失败原因：" + e.getMessage());
}
registerSaveDTO.setId(IdUtils.getNewTimeId());
BeanUtils.copyProperties(gridCaseInfoDTO, gridEvent);
- registerSaveDTO.setCreateTime(DateUtils.StringToDate(gridCaseInfoDTO.getCreateTime(),"yyyy-MM-dd HH:mm:ss"));
+ registerSaveDTO.setCreateTime(DateUtils.StringToDate(gridCaseInfoDTO.getCreateTime(), "yyyy-MM-dd HH:mm:ss"));
gridEvent.setLinkman(uploadPolice);
gridEvent.setSystemId(gridCaseInfoDTO.getSystemId());
gridEvent.setContactTel(uploadPolicePhone);
@@ -261,9 +254,18 @@
log.info("xsd保存事件：{}" + gridEvent);
//设置二级事件来源
if (canalSecond.equals("12")) {
+ registerSaveDTO.setCanal(CaseBaseConstsEnum.CASE_CANAL_4.getIndex());
+ registerSaveDTO.setCanalName(CaseBaseConstsEnum.CASE_CANAL_4.getDes());
registerSaveDTO.setCanalSecond(CaseBaseConstsEnum.CASE_CANAL_SECOND_1.getIndex());
registerSaveDTO.setCanalSecondName(CaseBaseConstsEnum.CASE_CANAL_SECOND_1.getDes());
+ } else if (canalSecond.equals("13")) {
+ registerSaveDTO.setCanal(CaseBaseConstsEnum.CASE_CANAL_3.getIndex());
+ registerSaveDTO.setCanalName(CaseBaseConstsEnum.CASE_CANAL_3.getDes());
+ registerSaveDTO.setCanalSecond(CaseBaseConstsEnum.CASE_CANAL_SECOND_7.getIndex());
+ registerSaveDTO.setCanalSecondName(CaseBaseConstsEnum.CASE_CANAL_SECOND_7.getDes());
} else {
+ registerSaveDTO.setCanal(CaseBaseConstsEnum.CASE_CANAL_3.getIndex());
+ registerSaveDTO.setCanalName(CaseBaseConstsEnum.CASE_CANAL_3.getDes());
registerSaveDTO.setCanalSecond(CaseBaseConstsEnum.CASE_CANAL_SECOND_2.getIndex());
registerSaveDTO.setCanalSecondName(CaseBaseConstsEnum.CASE_CANAL_SECOND_2.getDes());
}
@@ -320,7 +322,6 @@
registerSaveDTO.setPhone(phone);
String dyhUnitId = gridCaseTaskService.getGridUnitIdByUnitId(gridCode);
if (StringUtils.isNotBlank(dyhUnitId)) {
- registerSaveDTO.setWantUnitId(dyhUnitId);
} else {
log.info("网格组织查询不到对应组织：" + gridCode);
}
@@ -352,7 +353,7 @@
if (parts.length == 3) {
return parts[0] + parts[1] + parts[2];
} else if (parts.length >= 4) {
- return parts[0] + parts[1] + parts[2]+"-"+parts[3];
+ return parts[0] + parts[1] + parts[2] + "-" + parts[3];
} else {
return input; // 或抛出异常
}
@@ -368,6 +369,7 @@
Date nowDate = DateUtils.getNowDate();
List<String> canalSecondList = new ArrayList<>();
canalSecondList.add("12");
+ canalSecondList.add("13");
canalSecondList.add("07");
log.info("startTime:" + startTime);
log.info("endTime:" + endTime);
@@ -430,7 +432,7 @@
String fxdj = "";
String zrmj = "";
String zrga = "";
- String jyff="";
+ String jyff = "";
String tcr = "";
String tcqk = "";
String tcjg = "";
@@ -438,100 +440,92 @@
String certiNo = "";
String plaintiffs = "";
String phone = "";
- if ("07".equals(canalSecond)) {
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getLinkman())) {
- uploadPolice = AesUtils.decrypt(gridCaseInfoDTO.getLinkman(), "W90akz7tA7tyMn5tNTynG69YM2E8jGfF");
- }
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getContactTel())) {
- uploadPolicePhone = AesUtils.decrypt(gridCaseInfoDTO.getContactTel(), "W90akz7tA7tyMn5tNTynG69YM2E8jGfF");
- }
- } else if ("12".equals(canalSecond)) {
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getLinkman())) {
- uploadPolice = AesUtils.decrypt(gridCaseInfoDTO.getLinkman(), "W90akz7tA7tyMn5tNTynG69YM2E8jGfF");
- }
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getContactTel())) {
- uploadPolicePhone = AesUtils.decrypt(gridCaseInfoDTO.getContactTel(), "W90akz7tA7tyMn5tNTynG69YM2E8jGfF");
- }
- try {
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getExtInfo())) {
- JSONObject jsonObject = JSON.parseObject(gridCaseInfoDTO.getExtInfo());
- zrga = jsonObject.get("tcdwMc").toString();
- zrmj = jsonObject.get("zrmj").toString();
- fxdj = jsonObject.get("fxdj").toString();
- jfmc = jsonObject.get("jfmc").toString();
- registerSaveDTO.setGridHandle(zrga + "--" + zrmj);
- }
- } catch (Exception e) {
- log.error("解析extInfo失败，事件id：{" + gridCaseInfoDTO.getId() + "}; 解析内容：" + gridCaseInfoDTO.getExtInfo() + "失败原因：" + e.getMessage());
- }
- try {
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getExtInfoTcqk())) {
- List<Map<String, Object>> expInfoTcqkMapList = JSON.parseObject(gridCaseInfoDTO.getExtInfoTcqk(),
- new TypeReference<List<Map<String, Object>>>() {
- });
- for (Map expInfoMap : expInfoTcqkMapList) {
- tcr = expInfoMap.get("tcr").toString();
- tcqk = expInfoMap.get("tcqk").toString();
- tcjg = expInfoMap.get("tcjgMc").toString();
- tcfa = expInfoMap.get("tcfa").toString();
- }
- }
- } catch (Exception e) {
- log.error("解析extInfo失败，事件id：{" + gridCaseInfoDTO.getId() + "}; 解析内容：" + gridCaseInfoDTO.getExtInfo() + "失败原因：" + e.getMessage());
- }
- registerSaveDTO.setTcqk(uploadPolice+" -- "+uploadPolicePhone+" -- "+fxdj+" -- "+zrmj+" -- "+tcr+" -- "+tcfa+" -- "+tcqk);
- try {
- if (StringUtils.isNotBlank(gridCaseInfoDTO.getExtInfoRisk())) {
- List<Map<String, Object>> expInfoMapList = JSON.parseObject(gridCaseInfoDTO.getExtInfoRisk(),
- new TypeReference<List<Map<String, Object>>>() {
- });
- List<CasePersonDTO> casePersonDTOList = new ArrayList<>();
- for (Map expInfoMap : expInfoMapList) {
- CasePersonDTO casePersonDTO = new CasePersonDTO();
- String name = "";
- certiNo = "";
- String mobile = "";
- if (StringUtils.isNotBlank(expInfoMap.get("cardNumber").toString())) {
- certiNo = expInfoMap.get("cardNumber").toString();
- }
- if (StringUtils.isNotBlank(expInfoMap.get("name").toString())) {
- name = expInfoMap.get("name").toString();
- }
- if (StringUtils.isNotBlank(expInfoMap.get("contactPhone").toString())) {
- mobile = expInfoMap.get("contactPhone").toString();
- }
- casePersonDTO.setMobile(mobile);
- casePersonDTO.setTrueName(name);
- casePersonDTO.setCertiNo(certiNo);
- casePersonDTOList.add(casePersonDTO);
- gridEvent.setCertiNo(certiNo);
- if (StringUtils.isNotBlank(plaintiffs)) {
- if (!plaintiffs.contains(name))
- plaintiffs = plaintiffs + "," + name;
- } else {
- plaintiffs = name;
- }
- if (StringUtils.isNotBlank(phone)) {
- if (!phone.contains(mobile))
- phone = phone + "," + mobile;
- } else {
- phone = mobile;
- }
- if (StringUtils.isNotBlank(gridEvent.getCertiNo())) {
- gridEvent.setCertiNo(gridEvent.getCertiNo() + "," + certiNo);
- } else {
- gridEvent.setCertiNo(certiNo);
- }
- }
- registerSaveDTO.setPersonList(casePersonDTOList);
- }
- } catch (Exception e) {
- log.error("解析extInfo失败，事件id：{" + gridCaseInfoDTO.getId() + "}; 解析内容：" + gridCaseInfoDTO.getExtInfo() + "失败原因：" + e.getMessage());
+ if (StringUtils.isNotBlank(gridCaseInfoDTO.getLinkman())) {
+ uploadPolice = AesUtils.decrypt(gridCaseInfoDTO.getLinkman(), "W90akz7tA7tyMn5tNTynG69YM2E8jGfF");
+ }
+ if (StringUtils.isNotBlank(gridCaseInfoDTO.getContactTel())) {
+ uploadPolicePhone = AesUtils.decrypt(gridCaseInfoDTO.getContactTel(), "W90akz7tA7tyMn5tNTynG69YM2E8jGfF");
+ }
+ try {
+ if (StringUtils.isNotBlank(gridCaseInfoDTO.getExtInfo())) {
+ JSONObject jsonObject = JSON.parseObject(gridCaseInfoDTO.getExtInfo());
+ zrga = jsonObject.get("tcdwMc").toString();
+ zrmj = jsonObject.get("zrmj").toString();
+ fxdj = jsonObject.get("fxdj").toString();
+ jfmc = jsonObject.get("jfmc").toString();
+ registerSaveDTO.setGridHandle(zrga + "--" + zrmj);
}
+ } catch (Exception e) {
+ log.error("解析extInfo失败，事件id：{" + gridCaseInfoDTO.getId() + "}; 解析内容：" + gridCaseInfoDTO.getExtInfo() + "失败原因：" + e.getMessage());
+ }
+ try {
+ if (StringUtils.isNotBlank(gridCaseInfoDTO.getExtInfoTcqk())) {
+ List<Map<String, Object>> expInfoTcqkMapList = JSON.parseObject(gridCaseInfoDTO.getExtInfoTcqk(),
+ new TypeReference<List<Map<String, Object>>>() {
+ });
+ for (Map expInfoMap : expInfoTcqkMapList) {
+ tcr = expInfoMap.get("tcr").toString();
+ tcqk = expInfoMap.get("tcqk").toString();
+ tcjg = expInfoMap.get("tcjgMc").toString();
+ tcfa = expInfoMap.get("tcfa").toString();
+ }
+ }
+ } catch (Exception e) {
+ log.error("解析extInfo失败，事件id：{" + gridCaseInfoDTO.getId() + "}; 解析内容：" + gridCaseInfoDTO.getExtInfo() + "失败原因：" + e.getMessage());
+ }
+ registerSaveDTO.setTcqk(uploadPolice + " -- " + uploadPolicePhone + " -- " + fxdj + " -- " + zrmj + " -- " + tcr + " -- " + tcfa + " -- " + tcqk);
+ try {
+ if (StringUtils.isNotBlank(gridCaseInfoDTO.getExtInfoRisk())) {
+ List<Map<String, Object>> expInfoMapList = JSON.parseObject(gridCaseInfoDTO.getExtInfoRisk(),
+ new TypeReference<List<Map<String, Object>>>() {
+ });
+ List<CasePersonDTO> casePersonDTOList = new ArrayList<>();
+ for (Map expInfoMap : expInfoMapList) {
+ CasePersonDTO casePersonDTO = new CasePersonDTO();
+ String name = "";
+ certiNo = "";
+ String mobile = "";
+ if (StringUtils.isNotBlank(expInfoMap.get("cardNumber").toString())) {
+ certiNo = expInfoMap.get("cardNumber").toString();
+ }
+ if (StringUtils.isNotBlank(expInfoMap.get("name").toString())) {
+ name = expInfoMap.get("name").toString();
+ }
+ if (StringUtils.isNotBlank(expInfoMap.get("contactPhone").toString())) {
+ mobile = expInfoMap.get("contactPhone").toString();
+ }
+ casePersonDTO.setMobile(mobile);
+ casePersonDTO.setTrueName(name);
+ casePersonDTO.setCertiNo(certiNo);
+ casePersonDTOList.add(casePersonDTO);
+ gridEvent.setCertiNo(certiNo);
+
+ if (StringUtils.isNotBlank(plaintiffs)) {
+ if (!plaintiffs.contains(name))
+ plaintiffs = plaintiffs + "," + name;
+ } else {
+ plaintiffs = name;
+ }
+ if (StringUtils.isNotBlank(phone)) {
+ if (!phone.contains(mobile))
+ phone = phone + "," + mobile;
+ } else {
+ phone = mobile;
+ }
+ if (StringUtils.isNotBlank(gridEvent.getCertiNo())) {
+ gridEvent.setCertiNo(gridEvent.getCertiNo() + "," + certiNo);
+ } else {
+ gridEvent.setCertiNo(certiNo);
+ }
+ }
+ registerSaveDTO.setPersonList(casePersonDTOList);
+ }
+ } catch (Exception e) {
+ log.error("解析extInfo失败，事件id：{" + gridCaseInfoDTO.getId() + "}; 解析内容：" + gridCaseInfoDTO.getExtInfo() + "失败原因：" + e.getMessage());
}
registerSaveDTO.setId(IdUtils.getNewTimeId());
- registerSaveDTO.setCreateTime(DateUtils.StringToDate(gridCaseInfoDTO.getCreateTime(),"yyyy-MM-dd HH:mm:ss"));
+ registerSaveDTO.setCreateTime(DateUtils.StringToDate(gridCaseInfoDTO.getCreateTime(), "yyyy-MM-dd HH:mm:ss"));
BeanUtils.copyProperties(gridCaseInfoDTO, gridEvent);
gridEvent.setSystemId(gridCaseInfoDTO.getSystemId());
gridEvent.setLinkman(uploadPolice);
@@ -544,9 +538,18 @@
log.info("xsd保存事件：{}" + gridEvent);
//设置二级事件来源
if (canalSecond.equals("12")) {
+ registerSaveDTO.setCanal(CaseBaseConstsEnum.CASE_CANAL_4.getIndex());
+ registerSaveDTO.setCanalName(CaseBaseConstsEnum.CASE_CANAL_4.getDes());
registerSaveDTO.setCanalSecond(CaseBaseConstsEnum.CASE_CANAL_SECOND_1.getIndex());
registerSaveDTO.setCanalSecondName(CaseBaseConstsEnum.CASE_CANAL_SECOND_1.getDes());
+ } else if (canalSecond.equals("13")) {
+ registerSaveDTO.setCanal(CaseBaseConstsEnum.CASE_CANAL_3.getIndex());
+ registerSaveDTO.setCanalName(CaseBaseConstsEnum.CASE_CANAL_3.getDes());
+ registerSaveDTO.setCanalSecond(CaseBaseConstsEnum.CASE_CANAL_SECOND_7.getIndex());
+ registerSaveDTO.setCanalSecondName(CaseBaseConstsEnum.CASE_CANAL_SECOND_7.getDes());
} else {
+ registerSaveDTO.setCanal(CaseBaseConstsEnum.CASE_CANAL_3.getIndex());
+ registerSaveDTO.setCanalName(CaseBaseConstsEnum.CASE_CANAL_3.getDes());
registerSaveDTO.setCanalSecond(CaseBaseConstsEnum.CASE_CANAL_SECOND_2.getIndex());
registerSaveDTO.setCanalSecondName(CaseBaseConstsEnum.CASE_CANAL_SECOND_2.getDes());
}
--
Gitblit v1.8.0