| | |
| | | import com.gkhy.safePlatform.account.rpc.apimodel.AccountAuthService; |
| | | import com.gkhy.safePlatform.account.rpc.apimodel.AccountDepartmentService; |
| | | import com.gkhy.safePlatform.account.rpc.apimodel.model.resp.DepInfoRPCRespDTO; |
| | | import com.gkhy.safePlatform.commons.co.ContextCacheUser; |
| | | import com.gkhy.safePlatform.commons.enums.ResultCodes; |
| | | import com.gkhy.safePlatform.commons.query.PageQuery; |
| | | import com.gkhy.safePlatform.commons.utils.BeanCopyUtils; |
| | |
| | | } |
| | | |
| | | @Override |
| | | public ResultVO addAccidentExpress(Long uid, AccidentExpressReqDTO accidentExpressReqDTO) { |
| | | public ResultVO<AccidentExpressDetailRespDTO> addAccidentExpress(ContextCacheUser contextCacheUser, AccidentExpressReqDTO accidentExpressReqDTO) { |
| | | Long uid = contextCacheUser.getUid(); |
| | | String uName = contextCacheUser.getRealName(); |
| | | //必填项验证 |
| | | checkRequired(accidentExpressReqDTO); |
| | | |
| | | Date nowDate = new Date(); |
| | | //1.新增应急队伍 |
| | | //1.新增事故快报 |
| | | AccidentExpressInfo accidentExpressInfo = new AccidentExpressInfo(); |
| | | BeanUtils.copyProperties(accidentExpressReqDTO, accidentExpressInfo); |
| | | accidentExpressInfo.setDelFlag(false); |
| | | accidentExpressInfo.setCreateUid(uid); |
| | | accidentExpressInfo.setCreateName(uName); |
| | | accidentExpressInfo.setGmtCreate(nowDate); |
| | | accidentExpressInfoService.addAccidentExpress(accidentExpressInfo); |
| | | //2.新增应急队伍附件 |
| | | //2.新增事故快报附件 |
| | | if (!CollectionUtils.isEmpty(accidentExpressReqDTO.getFileList())){ |
| | | addAccidentExpressFile(accidentExpressInfo.getId(),uid,nowDate,accidentExpressReqDTO.getFileList()); |
| | | } |
| | | return new ResultVO(ResultCodes.OK); |
| | | |
| | | AccidentExpressDetailRespDTO accidentExpressDetailRespDTO = new AccidentExpressDetailRespDTO(); |
| | | BeanUtils.copyProperties(accidentExpressInfo,accidentExpressDetailRespDTO); |
| | | return new ResultVO<>(ResultCodes.OK,accidentExpressDetailRespDTO); |
| | | } |
| | | |
| | | private void addAccidentExpressFile(Long accidentExpressId ,Long uid , Date nowDate , List<AccidentExpressFileReqDTO> AccidentExpressFileReqDTOList){ |
| | |
| | | accidentExpressInfo.setUpdateUid(uid); |
| | | accidentExpressInfo.setGmtModitify(nowDate); |
| | | accidentExpressInfoService.updateAccidentExpress(accidentExpressInfo); |
| | | //修改应急队伍附件 |
| | | //修改事故快报附件 |
| | | updateAccidentExpressFile(uid,accidentExpressReqDTO.getId(),nowDate,accidentExpressReqDTO.getFileList()); |
| | | return new ResultVO(ResultCodes.OK); |
| | | } |
| | |
| | | |
| | | |
| | | @Override |
| | | public ResultVO batchDeleteAccidentExpress(String ids) { |
| | | if (StringUtils.isBlank(ids)){ |
| | | public ResultVO batchDeleteAccidentExpress(Long[] ids) { |
| | | if (ids == null || ids.length==0){ |
| | | throw new AccidentException(AccidentResultCodes.ACCIDENT_EXPRESS_NULL); |
| | | }else{ |
| | | String[] idArr = ids.split(","); |
| | | for (String id : idArr) { |
| | | deleteAccidentExpress(Long.valueOf(id)); |
| | | for (Long id : ids){ |
| | | deleteAccidentExpress(id); |
| | | } |
| | | return new ResultVO(ResultCodes.OK); |
| | | } |
| | |
| | | accidentExpressInfoService.deleteAccidentExpressById(id); |
| | | //删除附件 |
| | | accidentExpressFileInfoService.deleteAccidentExpressFileByAccidentExpressId(id); |
| | | //删除伤亡 |
| | | accidentExpressCasualtyInfoService.deleteAccidentExpressCasualtyByAccidentExpressId(id); |
| | | } |
| | | } |
| | | |