Browse Source

结案审批需要成功推送才行

feature/dangjian
zhangyuan 3 years ago
parent
commit
369ddc05f0
  1. 20
      esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java

20
esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java

@ -2263,12 +2263,12 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
// 先查询网格对应街道id
Result<CompleteDeptDTO> completeDeptDTOResult = adminFeignClient.getCompleteDept(itemEntity.getGridId());
if (!completeDeptDTOResult.success()) {
throw new Exception("根据网格ID获取所有上级机构信息失败" + completeDeptDTOResult.getMsg());
throw new Exception("根据网格ID获取所有上级机构信息失败" + completeDeptDTOResult.getMsg());
}
// 根据街道id查询对应平台的deptCode、streetCode
Result<DeptGridPlatformDTO> deptGridPlatformDTOResult = adminFeignClient.getDeptGridPlatformDTO(completeDeptDTOResult.getData().getStreetId().toString());
if (!deptGridPlatformDTOResult.success() || null == deptGridPlatformDTOResult.getData()) {
throw new Exception("根据街道查询平台部门信息失败" + deptGridPlatformDTOResult.getMsg());
throw new Exception("根据街道查询平台部门信息失败" + deptGridPlatformDTOResult.getMsg());
}
//外系统编码 必填!!!!!!!
formDto.setDeptCode(deptGridPlatformDTOResult.getData().getDeptCode());// 130099
@ -2317,7 +2317,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
Result<SysDeptDTO> streetResult = adminFeignClient.getSysDeptInfo(itemEntity.getGridId());
SysDeptDTO deptInfo = streetResult.getData();
if (deptInfo == null) {
throw new RenException("根据街道ID获取对应的街道编码失败" + streetResult.getMsg());
throw new RenException("根据街道ID获取对应的街道编码失败" + streetResult.getMsg());
}
//所属街道
sendDto.setSSJD(deptInfo.getAreaCode());
@ -2345,7 +2345,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
DeptInfoCodeDTO deptInfo = deptResult.getData();
if (deptInfo == null) {
throw new RenException("根据网格ID获取对应的社区编码、街道编码失败" + deptResult.getMsg());
throw new RenException("根据网格ID获取对应的社区编码、街道编码失败" + deptResult.getMsg());
}
//所属街道
sendDto.setSSJD(deptInfo.getStreetInfoCode());
@ -2942,7 +2942,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
try {
sendInfoToCity(itemHandleProcessDto);
} catch (Exception e) {
log.error("定时任务-根据相应的操作推送数据到市中心失败" + e.getMessage());
log.error("定时任务-根据相应的操作推送数据到市中心失败" + e.getMessage());
e.printStackTrace();
}
@ -3781,11 +3781,11 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
try {
reDoResult = this.eventsRejectDo(dto, gridEntity.getTaskid());
} catch (Exception e) {
throw new RenException("上报驳回重办失败" + reDoResult.getMessage());
throw new RenException("上报驳回重办失败" + reDoResult.getMessage());
}
if (!"0".equals(reDoResult.getCode())) {
// 接口没有返回信息,也没有异常信息
throw new RenException("上报驳回重办失败" + reDoResult.getMessage());
throw new RenException("上报驳回重办失败" + reDoResult.getMessage());
}
//记录平台上报信息
this.saveItemRejectReDoInfo(gridEntity, process);
@ -3795,12 +3795,12 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
try {
sendResult = this.reportCaseNew(dto);
} catch (Exception e) {
log.error("上报网格化平台接口失败:" + e.getMessage());
throw new RenException("上报网格化平台接口失败" + sendResult.getMessage());
log.error("上报网格化平台接口失败" + e.getMessage());
throw new RenException("上报网格化平台接口失败" + sendResult.getMessage());
}
if (!"0".equals(sendResult.getCode())) {
// 接口没有返回信息,也没有异常信息
throw new RenException("上报网格化平台接口失败" + sendResult.getMessage());
throw new RenException("上报网格化平台接口失败" + sendResult.getMessage());
}
// 记录平台上报信息
this.saveItemGridPlatformInfo(sendResult, process);

Loading…
Cancel
Save