|
@@ -19,10 +19,12 @@ import com.sooka.sponest.event.eventAttach.domain.EventAttach;
|
|
|
import com.sooka.sponest.event.eventAttach.mapper.EventAttachMapper;
|
|
|
import com.sooka.sponest.event.eventAttach.service.EventAttachService;
|
|
|
import com.sooka.sponest.event.eventDept.service.EventDeptService;
|
|
|
+import com.sooka.sponest.event.eventFireContingencyPlan.service.EventFireContingencyPlanService;
|
|
|
import com.sooka.sponest.event.eventLog.domain.EventLog;
|
|
|
import com.sooka.sponest.event.eventLog.service.EventLogService;
|
|
|
import com.sooka.sponest.event.eventMessage.domain.*;
|
|
|
import com.sooka.sponest.event.eventProcess.domain.BO.EventInfoBO;
|
|
|
+import com.sooka.sponest.event.eventFireContingencyPlan.domain.EventFireContingencyPlan;
|
|
|
import com.sooka.sponest.event.eventProcess.domain.EventInfo;
|
|
|
import com.sooka.sponest.event.eventProcess.domain.VO.EventProcess;
|
|
|
import com.sooka.sponest.event.eventProcess.domain.VO.EventUnconfirmed;
|
|
@@ -76,6 +78,9 @@ public class EventProcessServiceImpl extends BaseServiceImpl implements EventPro
|
|
|
@Resource
|
|
|
private EventAttachMapper eventAttachMapper;
|
|
|
|
|
|
+ @Resource
|
|
|
+ private EventFireContingencyPlanService contingencyPlanService;
|
|
|
+
|
|
|
private final Lock lock = new ReentrantLock(true); // 公平锁
|
|
|
|
|
|
/**
|
|
@@ -664,28 +669,63 @@ public class EventProcessServiceImpl extends BaseServiceImpl implements EventPro
|
|
|
* 协同处理事件部门
|
|
|
*/
|
|
|
@Override
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
public AjaxResult cooperateDeptList(EventInfo eventInfo) {
|
|
|
- if (!eventInfo.getDeptIdList().isEmpty()) {
|
|
|
- LoginUser loginUser = SecurityUtils.getLoginUser();
|
|
|
- //业务代码
|
|
|
- if (null == loginUser) {
|
|
|
- return AjaxResult.error(EventEnum.USER_NOT_FOUND.getDescribe());
|
|
|
- }
|
|
|
- SysUser sysUser = loginUser.getSysUser();
|
|
|
+ try{
|
|
|
+ if (!eventInfo.getDeptIdList().isEmpty()) {
|
|
|
+ LoginUser loginUser = SecurityUtils.getLoginUser();
|
|
|
+ //业务代码
|
|
|
+ if (null == loginUser) {
|
|
|
+ return AjaxResult.error(EventEnum.USER_NOT_FOUND.getDescribe());
|
|
|
+ }
|
|
|
+ SysUser sysUser = loginUser.getSysUser();
|
|
|
|
|
|
+ EventInfo eventProcessDetail = eventProcessMapper.getProcessEventDetail(eventInfo);
|
|
|
+ if (null == eventProcessDetail || (!EVENT_STATUS_2.equals(eventProcessDetail.getEventStatus()) && !EVENT_STATUS_3.equals(eventProcessDetail.getEventStatus()))) {
|
|
|
+ return AjaxResult.error(EventEnum.EVENT_NOT_FOUND.getDescribe());
|
|
|
+ }
|
|
|
+
|
|
|
+ List<CenterdataTAidevicedept> listDept = new ArrayList<>();
|
|
|
+ eventInfo.getDeptIdList().forEach(deptId -> listDept.add(new CenterdataTAidevicedept(deptId, "")));
|
|
|
+ eventDeptService.insertEventDept(eventInfo.getEventId(), listDept);
|
|
|
+
|
|
|
+ eventLogService.insertEventLog(eventInfo.getEventId(), sysUser.getDeptNames() + sysUser.getNickName() + EventEnum.COOPERATE_DEPT.getDescribe(), EVENT_LOG_TYPE_100, EVENT_LOG_SOURCE_99, String.valueOf(sysUser.getUserId()), DateUtils.getNowDate());
|
|
|
|
|
|
- EventInfo eventProcessDetail = eventProcessMapper.getProcessEventDetail(eventInfo);
|
|
|
- if (null == eventProcessDetail || (!EVENT_STATUS_2.equals(eventProcessDetail.getEventStatus()) && !EVENT_STATUS_3.equals(eventProcessDetail.getEventStatus()))) {
|
|
|
- return AjaxResult.error(EventEnum.EVENT_NOT_FOUND.getDescribe());
|
|
|
}
|
|
|
+ return AjaxResult.success();
|
|
|
+ }catch (Exception e){
|
|
|
+ logger.error("cooperateDeptList --> 添加协同部门失败!");
|
|
|
+ return AjaxResult.error("添加协同部门失败!");
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
- eventLogService.insertEventLog(eventInfo.getEventId(), sysUser.getDeptNames() + sysUser.getNickName() + EventEnum.COOPERATE_DEPT.getDescribe(), EVENT_LOG_TYPE_100, EVENT_LOG_SOURCE_99, String.valueOf(sysUser.getUserId()), DateUtils.getNowDate());
|
|
|
+ @Override
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ public AjaxResult updateContingencyPlan(EventInfo eventInfo) {
|
|
|
+ try{
|
|
|
+ if(eventInfo.getEventFireContingencyPlan() != null){
|
|
|
+ LoginUser loginUser = SecurityUtils.getLoginUser();
|
|
|
+ //业务代码
|
|
|
+ if (null == loginUser) {
|
|
|
+ return AjaxResult.error(EventEnum.USER_NOT_FOUND.getDescribe());
|
|
|
+ }
|
|
|
+ SysUser sysUser = loginUser.getSysUser();
|
|
|
|
|
|
- List<CenterdataTAidevicedept> listDept = new ArrayList<>();
|
|
|
- eventInfo.getDeptIdList().forEach(deptId -> listDept.add(new CenterdataTAidevicedept(deptId, "")));
|
|
|
- eventDeptService.insertEventDept(eventInfo.getEventId(), listDept);
|
|
|
+ EventInfo eventProcessDetail = eventProcessMapper.getProcessEventDetail(eventInfo);
|
|
|
+ if (null == eventProcessDetail || (!EVENT_STATUS_2.equals(eventProcessDetail.getEventStatus()) && !EVENT_STATUS_3.equals(eventProcessDetail.getEventStatus()))) {
|
|
|
+ return AjaxResult.error(EventEnum.EVENT_NOT_FOUND.getDescribe());
|
|
|
+ }
|
|
|
+
|
|
|
+ EventFireContingencyPlan eventFireContingencyPlan = eventInfo.getEventFireContingencyPlan();
|
|
|
+ contingencyPlanService.updateContingencyPlan(eventFireContingencyPlan);
|
|
|
+
|
|
|
+ eventLogService.insertEventLog(eventInfo.getEventId(), sysUser.getDeptNames() + sysUser.getNickName() + EventEnum.CONTINGENCY_PLAN.getDescribe() + "预案编号: " + eventFireContingencyPlan.getReserveName(), EVENT_LOG_TYPE_100, EVENT_LOG_SOURCE_99, String.valueOf(sysUser.getUserId()), DateUtils.getNowDate());
|
|
|
+ }
|
|
|
+ return AjaxResult.success();
|
|
|
+ }catch (Exception e){
|
|
|
+ logger.error("updateContingencyPlan --> 变更应急预案失败!");
|
|
|
+ return AjaxResult.error("变更应急预案失败!");
|
|
|
}
|
|
|
- return AjaxResult.success();
|
|
|
}
|
|
|
|
|
|
@Override
|