|
|
@ -67,6 +67,7 @@ import com.elink.esua.epdc.gird.shibei.dto.SearchCaseProcessByTaskIdItemDto; |
|
|
|
import com.elink.esua.epdc.gird.shibei.dto.form.*; |
|
|
|
import com.elink.esua.epdc.gird.shibei.dto.result.EventProcessHisResultDto; |
|
|
|
import com.elink.esua.epdc.gird.shibei.dto.result.EventProcessResultDto; |
|
|
|
import com.elink.esua.epdc.gird.shibei.dto.result.EventRejectDoResultDto; |
|
|
|
import com.elink.esua.epdc.gird.shibei.dto.result.SendEventResultDto; |
|
|
|
import com.elink.esua.epdc.gird.shibei.util.XstreamUtil; |
|
|
|
import com.elink.esua.epdc.modules.async.IssueOverseeResultsTask; |
|
|
@ -399,7 +400,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
itemEntity.setIsPeople("1");//诉求上报
|
|
|
|
itemEntity.setPeopleFlag("2");//执法诉求
|
|
|
|
// 流水号
|
|
|
|
itemEntity.setSerialNum(getSerialNum("zf")); |
|
|
|
itemEntity.setSerialNum(getSerialNum("ZF")); |
|
|
|
baseDao.insert(itemEntity); |
|
|
|
//插入项目部门关联表
|
|
|
|
itemDeptService.savePeopleSubmitInfo(itemEntity); |
|
|
@ -1394,6 +1395,13 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
return false; |
|
|
|
} |
|
|
|
|
|
|
|
private ItemGridPlatformEntity getReport(String id) { |
|
|
|
QueryWrapper<ItemGridPlatformEntity> wrapper = new QueryWrapper<>(); |
|
|
|
wrapper.eq("REFERENCE_ID", id); |
|
|
|
ItemGridPlatformEntity gridEntity = itemGridPlatformDao.selectOne(wrapper); |
|
|
|
return gridEntity; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 项目流转校验 |
|
|
|
* |
|
|
@ -1640,6 +1648,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
return sendResult; |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
* 保存接口调用日志 |
|
|
|
* |
|
|
@ -1827,16 +1836,39 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
List<String> handleImagesList = new ArrayList<>(); |
|
|
|
log.info("处理项目-获取进度开始"); |
|
|
|
List<EventHandleListFormDto> handleList = getHandleList(itemEntity.getId(),handleImagesList); |
|
|
|
log.info("事件进度图片:"+handleImagesList); |
|
|
|
log.info("处理项目-获取进度结束"); |
|
|
|
sendDto.setHandleList(handleList); |
|
|
|
//图片
|
|
|
|
List<String> images = getImageFileNew(itemEntity.getEventId() == null?itemEntity.getId():itemEntity.getEventId(),handleImagesList);//事件图片+处理流程图片
|
|
|
|
log.info("图片组装结束:"+images); |
|
|
|
//时间处理进度图片
|
|
|
|
sendDto.setIMAGES(images); |
|
|
|
log.info("处理项目-返回组装数据"); |
|
|
|
return sendDto; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* @describe: 组装驳回重办数据 |
|
|
|
* @author wangtong |
|
|
|
* @date 2022/9/13 13:47 |
|
|
|
* @params [itemEntity] |
|
|
|
* @return com.elink.esua.epdc.gird.shibei.dto.form.EventRejectReDoFormDto |
|
|
|
*/ |
|
|
|
private EventRejectReDoFormDto packeageSendRejectReInfo(ItemEntity itemEntity) throws Exception { |
|
|
|
EventRejectReDoFormDto result = new EventRejectReDoFormDto(); |
|
|
|
//事件处理进度
|
|
|
|
List<String> handleImagesList = new ArrayList<>(); |
|
|
|
List<EventHandleListFormDto> handleList = getHandleList(itemEntity.getId(),handleImagesList); |
|
|
|
log.info("事件进度图片:"+handleImagesList); |
|
|
|
result.setHandleList(handleList); |
|
|
|
//图片
|
|
|
|
List<String> images = getImageFileNew(itemEntity.getEventId() == null?itemEntity.getId():itemEntity.getEventId(),handleImagesList);//事件图片+处理流程图片
|
|
|
|
//时间处理进度图片
|
|
|
|
result.setIMAGES(images); |
|
|
|
return result; |
|
|
|
} |
|
|
|
|
|
|
|
private String getItemLawNote(String itemId) { |
|
|
|
QueryWrapper<ItemLawEntity> wrapper = new QueryWrapper<>(); |
|
|
|
wrapper.eq("item_id", itemId); |
|
|
@ -1973,9 +2005,8 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
} |
|
|
|
//替换了诉求上传接口,现在无需压缩
|
|
|
|
// List<String> imgUrlList = this.getUploadDTOListNew(handleImagesList);
|
|
|
|
return handleImagesList; |
|
|
|
} |
|
|
|
return null; |
|
|
|
return handleImagesList; |
|
|
|
} |
|
|
|
|
|
|
|
// 组装事件图片
|
|
|
@ -2091,6 +2122,29 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
gridPlatformHandleLogService.insert(logEntity); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* @describe: 保存项目驳回上报信息 |
|
|
|
* @author wangtong |
|
|
|
* @date 2022/9/13 10:52 |
|
|
|
* @params [gridEntity, handleProcessEntity] |
|
|
|
* @return void |
|
|
|
*/ |
|
|
|
private void saveItemRejectReDoInfo(ItemGridPlatformEntity gridEntity, ItemHandleProcessEntity handleProcessEntity) { |
|
|
|
UserDetail user = SecurityUser.getUser(); |
|
|
|
gridEntity.setRejectDoTime(new Date()); |
|
|
|
itemGridPlatformService.updateById(gridEntity); |
|
|
|
|
|
|
|
GridPlatformHandleLogEntity logEntity = new GridPlatformHandleLogEntity(); |
|
|
|
logEntity.setItemGridPlatformId(gridEntity.getId()); |
|
|
|
logEntity.setStatus(handleProcessEntity.getState()); |
|
|
|
logEntity.setItemHandleProcessId(handleProcessEntity.getItemId()); |
|
|
|
logEntity.setHandler(null == user?handleProcessEntity.getHandlerDept():user.getRealName()); |
|
|
|
logEntity.setHandlingOpinions(handleProcessEntity.getHandleAdvice()); |
|
|
|
logEntity.setHandlingDept(handleProcessEntity.getHandlerDept()); |
|
|
|
logEntity.setHandlingTime(handleProcessEntity.getCreatedTime()); |
|
|
|
gridPlatformHandleLogService.insert(logEntity); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Transactional(rollbackFor = Exception.class) |
|
|
@ -2169,7 +2223,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
try { |
|
|
|
for (EventProcessResultDto dto : |
|
|
|
progressList) { |
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm"); |
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
|
|
|
Date insertTime = sdf.parse(dto.getCREATEDATE()); |
|
|
|
// 拉取的记录增加30秒,防止出现排序问题
|
|
|
|
insertTime.setTime(insertTime.getTime() + 55000); |
|
|
@ -2500,9 +2554,9 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
entity.setItemCode("PT" + System.currentTimeMillis());//项目编号
|
|
|
|
entity.setIsPeople("1");//诉求上报
|
|
|
|
if (NumConstant.ZERO_STR.equals(formDto.getPeopleFlag())) { |
|
|
|
entity.setSerialNum(getSerialNum("ms")); |
|
|
|
entity.setSerialNum(getSerialNum("MS")); |
|
|
|
} else if (NumConstant.ONE_STR.equals(formDto.getPeopleFlag())) { |
|
|
|
entity.setSerialNum(getSerialNum("fz")); |
|
|
|
entity.setSerialNum(getSerialNum("FZ")); |
|
|
|
} |
|
|
|
baseDao.insert(entity); |
|
|
|
//插入项目部门关联表
|
|
|
@ -2665,8 +2719,8 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
result.setLawDetail(ConvertUtils.sourceToTarget(itemLaw, ItemAppealLawDetailResultDTO.class)); |
|
|
|
} |
|
|
|
// 满意度评价部门
|
|
|
|
// List<ItemEvaluateDeptDTO> evaluateDeptDTOS = itemDeptService.listOfEvaluateDepts(resultDTO.getId(), deptId);
|
|
|
|
// resultDTO.setEvaluateDeptDTOS(evaluateDeptDTOS);
|
|
|
|
// List<ItemEvaluateDeptDTO> evaluateDeptDTOS = itemDeptService.listOfEvaluateDepts(result.getId(), deptId);
|
|
|
|
// result.setEvaluateDeptDTOS(evaluateDeptDTOS);
|
|
|
|
return new Result<ItemAppealDetailResultDTO>().ok(result); |
|
|
|
} |
|
|
|
|
|
|
@ -2736,10 +2790,23 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
*/ |
|
|
|
@Transactional(rollbackFor = Exception.class) |
|
|
|
public void sendItemToDsf(ItemHandleSubmitFormDTO dto,ItemHandleProcessEntity process){ |
|
|
|
boolean reportFlag = this.checkReport(dto.getId()); |
|
|
|
if (reportFlag) { |
|
|
|
throw new RenException("当前项目已上报网格化平台"); |
|
|
|
ItemGridPlatformEntity gridEntity = this.getReport(dto.getId()); |
|
|
|
if (null != gridEntity) { |
|
|
|
//驳回重办
|
|
|
|
EventRejectDoResultDto reDoResult = null; |
|
|
|
try { |
|
|
|
reDoResult = this.eventsRejectDo(dto,gridEntity.getTaskid()); |
|
|
|
} catch (Exception e) { |
|
|
|
throw new RenException("上报驳回重办失败" + reDoResult.getMessage()); |
|
|
|
} |
|
|
|
if (null == reDoResult || !("0").equals(reDoResult.getCode())) { |
|
|
|
// 接口没有返回信息,也没有异常信息
|
|
|
|
throw new RenException("上报驳回重办失败" + reDoResult.getMessage()); |
|
|
|
} |
|
|
|
//记录平台上报信息
|
|
|
|
this.saveItemRejectReDoInfo(gridEntity,process); |
|
|
|
} else { |
|
|
|
//事件第一次上报
|
|
|
|
SendEventResultDto sendResult = null; |
|
|
|
try { |
|
|
|
sendResult = this.reportCaseNew(dto); |
|
|
@ -2753,6 +2820,28 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
// 记录平台上报信息
|
|
|
|
this.saveItemGridPlatformInfo(sendResult, process); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
private EventRejectDoResultDto eventsRejectDo(ItemHandleSubmitFormDTO dto,String recid) throws Exception { |
|
|
|
ItemEntity entity = baseDao.selectById(dto.getId()); |
|
|
|
// 组装上报信息(图片和处理流程)
|
|
|
|
EventRejectReDoFormDto rejectReDoDTO = packeageSendRejectReInfo(entity); |
|
|
|
rejectReDoDTO.setRECID(recid); |
|
|
|
// 接口请求返回实体,getCode 1失败 0成功(非空)
|
|
|
|
log.info("处理项目-进入上报驳回重办-发送"); |
|
|
|
EventRejectDoResultDto sendResult = shiBeiCityGridApi.sendReDoEvent(rejectReDoDTO); |
|
|
|
log.info("处理项目-进入上报驳回重办-结束:"+sendResult); |
|
|
|
// 保存接口调用日志
|
|
|
|
String successFlag = YesOrNoEnum.NO.value(); |
|
|
|
if (NumConstant.ZERO_STR.equals(sendResult.getCode())) { |
|
|
|
successFlag = YesOrNoEnum.YES.value(); |
|
|
|
} |
|
|
|
this.saveInterfaceLog(dto.getId(), InterfaceLogBusinessTypeEnum.REJECT_RE_DO.getValue(), |
|
|
|
ApiConstants.sendEventUrl, successFlag, XstreamUtil.objectToXml(rejectReDoDTO), |
|
|
|
XstreamUtil.objectToXml(sendResult)); |
|
|
|
log.info("处理项目-进入上报驳回重办-存储日志结束"); |
|
|
|
return sendResult; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 民生诉求流水号 |
|
|
@ -2762,7 +2851,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
* @author zhy |
|
|
|
* @date 2022/9/5 18:17 |
|
|
|
*/ |
|
|
|
private String getSerialNum(String prefix) { |
|
|
|
public String getSerialNum(String prefix) { |
|
|
|
String serialNum = prefix; |
|
|
|
String dateStr = DateUtils.format(new Date(), DateUtils.DATE_TIME_HOUR); |
|
|
|
serialNum = serialNum + dateStr; |
|
|
@ -2802,10 +2891,13 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
if("0".equals(formDto.getState())){ |
|
|
|
ItemEntity item = baseDao.selectById(itemPlat.getReferenceId()); |
|
|
|
itemHandleProcessDto.setState(ItemGridPlatformHandleStatusEnum.HANDLE_JA.getValue()); |
|
|
|
//判断最后一条处理进展是吹哨还是结案,结案:取第一条处置意见;吹哨:取最后一条处置意见
|
|
|
|
if("1".equals(item.getPeopleFlag()) || "2".equals(item.getPeopleFlag()) || getItemIsCs(itemPlat.getReferenceId())){ |
|
|
|
//判断最后一条处理进展是吹哨还是结案,结案:取第一条处置意见;吹哨:取平台处置意见
|
|
|
|
if("1".equals(item.getPeopleFlag()) || "2".equals(item.getPeopleFlag())){ |
|
|
|
//执法和发展填写网格化平台的意见
|
|
|
|
itemHandleProcessDto.setOutHandleAdvice(formDto.getHandleAdvice()); |
|
|
|
}else if(getItemIsCs(itemPlat.getReferenceId())){ |
|
|
|
//吹哨
|
|
|
|
itemHandleProcessDto.setOutHandleAdvice(formDto.getHandleAdvice()+"h_s办理人:"+item.getHandlePeopleName()+",联系电话:"+item.getHandlePeopleMobile()); |
|
|
|
}else{ |
|
|
|
//内容组成:第一个发起结案申请+办理人:XXX+办理电话:XXX。换行(前端处理) 感谢您的支持,“北尚诉办”全程为您服务!
|
|
|
|
ItemHandleProcessEntity firsthandleProcess = baseDao.selectFirstHandleProcessByItemId(itemPlat.getReferenceId()); |
|
|
@ -2850,7 +2942,6 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem |
|
|
|
return 0 == process.getState()?true:15 == process.getState(); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
* 领域类别处理 |
|
|
|
* |
|
|
|