diff --git a/start/src/main/resources/templates/iotalarm.html b/start/src/main/resources/templates/iotalarm.html index 96d44c6..7469d4b 100644 --- a/start/src/main/resources/templates/iotalarm.html +++ b/start/src/main/resources/templates/iotalarm.html @@ -1,4 +1,4 @@ ---
\ No newline at end of file + })();
\ No newline at end of file diff --git a/web-app/src/main/java/com/zcloud/command/AlarmDisposeAssignExe.java b/web-app/src/main/java/com/zcloud/command/AlarmDisposeAssignExe.java index eab6474..be79cbb 100644 --- a/web-app/src/main/java/com/zcloud/command/AlarmDisposeAssignExe.java +++ b/web-app/src/main/java/com/zcloud/command/AlarmDisposeAssignExe.java @@ -5,11 +5,12 @@ import cn.hutool.json.JSONUtil; import com.alibaba.cola.dto.SingleResponse; import com.alibaba.cola.exception.BizException; import com.alibaba.fastjson.JSONObject; +import com.jjb.saas.framework.auth.utils.AuthContext; import com.jjb.saas.message.client.message.facede.MessageFacade; import com.jjb.saas.message.client.message.request.MessageSendCmd; import com.jjb.saas.message.client.message.request.MessageTargetCmd; import com.zcloud.domain.config.MessageTemplateConfig; -import com.zcloud.domain.gateway.AlarmDisposeLogGateway; +import com.zcloud.domain.enums.AlarmRecordStatusEnum; import com.zcloud.domain.gateway.AlarmRecordGateway; import com.zcloud.domain.model.AlarmRecordE; import com.zcloud.dto.AlarmDisposeAssignCmd; @@ -18,8 +19,6 @@ import com.zcloud.gbscommon.todolistmq.event.TodoListAddBatchEvent; import com.zcloud.gbscommon.todolistmq.event.TodoListAddEvent; import com.zcloud.gbscommon.utils.Tools; import com.zcloud.gbscommon.utils.UuidUtil; -import com.zcloud.service.AlarmMessageService; -import com.zcloud.service.AlarmTodoService; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.dubbo.config.annotation.DubboReference; @@ -43,18 +42,22 @@ import java.util.List; public class AlarmDisposeAssignExe { private final AlarmRecordGateway alarmRecordGateway; - private final AlarmDisposeLogGateway alarmDisposeLogGateway; - private final AlarmMessageService alarmMessageService; - private final AlarmTodoService alarmTodoService; - private final MessageTemplateConfig messageTemplateConfig; private final TodoListEventPusherUtil todoListEventPusherUtil; + + /** + * 处置分配报警记录，外部消息和待办发送失败不影响分配主流程。 + * + * @param cmd 处置分配参数 + * @return 分配处理结果 + */ @Transactional(rollbackFor = Exception.class) public SingleResponse execute(AlarmDisposeAssignCmd cmd) { List ids = cmd.getIds(); if (Tools.isEmpty(ids)) { throw new BizException("请选择要处置的报警记录"); } + checkAssignStatus(cmd.getStatus()); // 获取当前时间的LocalDateTime "yyyy-MM-dd HH:mm:ss" LocalDateTime assignTime = LocalDateTime.now(); @@ -67,27 +70,27 @@ public class AlarmDisposeAssignExe { } // 检查状态：只有待研判(10)状态可以分配 - if (alarmRecord.getStatus() != 10) { - return SingleResponse.buildFailure("报警编码为"+alarmRecord.getAlarmNo()+"报警记录状态不是待处置;"); + if (!AlarmRecordStatusEnum.PENDING_REVIEW.sameStatus(alarmRecord.getStatus())) { + return SingleResponse.buildFailure("报警编码为" + alarmRecord.getAlarmNo() + "报警记录状态不是待研判;"); } // 更新报警记录状态和处置人 AlarmRecordE updateEntity = new AlarmRecordE(); BeanUtil.copyProperties(cmd, updateEntity); - updateEntity.setId( id); + updateEntity.setId(id); updateEntity.setAssignTime(assignTime); - updateEntity.setAssignTime(LocalDateTime.now()); + updateEntity.setAssignUserId(AuthContext.getUserId()); alarmRecordGateway.update(updateEntity); - if (cmd.getStatus() == 20){ + if (AlarmRecordStatusEnum.PENDING_DISPOSE.sameStatus(cmd.getStatus())) { // 发送站内信 - sendMessage(messageTemplateConfig.getDispose(), alarmRecord.getDisposeUserId()); + sendMessage(messageTemplateConfig.getDispose(), cmd.getDisposeUserId()); //待排查 待办 TodoListAddEvent event = new TodoListAddEvent(); event.setTitle("您有一条【物联网报警】待处置"); event.setContent("您有一条报警信息，请及时进行处置。"); event.setForeignKey(alarmRecord.getId()); // 业务表ID -申请 event.setForeignSubsidiaryKey(alarmRecord.getId()); // 业务附表ID 没有附表时为foreignKey的值 - event.setReceiveUser(alarmRecord.getDisposeUserId());// user表ID + event.setReceiveUser(cmd.getDisposeUserId());// user表ID event.setPcFlag(0); // 是否PC端待办 1是 0否 event.setAppFlag(1); // 是否APP端待办 1是 0否 event.setOtherParams(new JSONObject()); @@ -95,12 +98,8 @@ public class AlarmDisposeAssignExe { } } - if (cmd.getStatus() == 20){ - TodoListAddBatchEvent event3 = new TodoListAddBatchEvent(); - event3.setTodoListAddEventList(todoListAddEventList); - log.info("【物联网报警】待处置,请求：{}", JSONUtil.toJsonStr(event3)); - boolean b = todoListEventPusherUtil.sendMessageAddBatchEvent(event3); - log.info("【物联网报警】待处置,结果：{}",b); + if (AlarmRecordStatusEnum.PENDING_DISPOSE.sameStatus(cmd.getStatus()) && !todoListAddEventList.isEmpty()) { + sendTodoBatch(todoListAddEventList); } return SingleResponse.buildSuccess(); } @@ -108,6 +107,26 @@ public class AlarmDisposeAssignExe { @DubboReference private MessageFacade messageFacade; + + private void checkAssignStatus(Integer status) { + if (!AlarmRecordStatusEnum.PENDING_DISPOSE.sameStatus(status) + && !AlarmRecordStatusEnum.FALSE_ALARM.sameStatus(status)) { + throw new BizException("报警确认状态不合法"); + } + } + + private void sendTodoBatch(List todoListAddEventList) { + try { + TodoListAddBatchEvent event = new TodoListAddBatchEvent(); + event.setTodoListAddEventList(todoListAddEventList); + log.info("【物联网报警】待处置,请求：{}", JSONUtil.toJsonStr(event)); + boolean sendResult = todoListEventPusherUtil.sendMessageAddBatchEvent(event); + log.info("【物联网报警】待处置,结果：{}", sendResult); + } catch (Exception e) { + log.error("处置分配待办发送失败，不影响分配主流程，错误：{}", e.getMessage(), e); + } + } + private void sendMessage(String template, Long userId) { try { MessageSendCmd messageSendCmd = new MessageSendCmd(); @@ -122,7 +141,7 @@ public class AlarmDisposeAssignExe { SingleResponse result = messageFacade.send(messageSendCmd); log.info("发送站内信结果：{}", result.toString()); } catch (Exception e){ - e.printStackTrace(); + log.error("处置分配站内信发送失败，不影响分配主流程，接收人ID：{}，错误：{}", userId, e.getMessage(), e); } } diff --git a/web-app/src/main/java/com/zcloud/command/AlarmDisposeBatchAssignExe.java b/web-app/src/main/java/com/zcloud/command/AlarmDisposeBatchAssignExe.java index 56e5b62..475d8ac 100644 --- a/web-app/src/main/java/com/zcloud/command/AlarmDisposeBatchAssignExe.java +++ b/web-app/src/main/java/com/zcloud/command/AlarmDisposeBatchAssignExe.java @@ -1,6 +1,8 @@ package com.zcloud.command; import com.alibaba.cola.exception.BizException; +import com.jjb.saas.framework.auth.utils.AuthContext; +import com.zcloud.domain.enums.AlarmRecordStatusEnum; import com.zcloud.domain.gateway.AlarmRecordGateway; import com.zcloud.domain.gateway.AlarmDisposeLogGateway; import com.zcloud.domain.model.AlarmRecordE; @@ -51,18 +53,20 @@ public class AlarmDisposeBatchAssignExe { } // 检查状态：只有待研判(10)状态可以分配 - if (alarmRecord.getStatus() != 10) { + if (!AlarmRecordStatusEnum.PENDING_REVIEW.sameStatus(alarmRecord.getStatus())) { continue; // 跳过非待研判状态的记录 } // 更新报警记录状态和处置人 AlarmRecordE updateEntity = new AlarmRecordE(); updateEntity.setId(id); - updateEntity.setStatus(20); // 待处置 + updateEntity.setStatus(AlarmRecordStatusEnum.PENDING_DISPOSE.getStatus()); // 待处置 updateEntity.setManagerId(cmd.getDisposeUserId()); updateEntity.setDisposeUserId(cmd.getDisposeUserId()); // updateEntity.setAssignTime(assignTime); updateEntity.setTenantId(cmd.getTenantId()); + updateEntity.setAssignTime(LocalDateTime.now()); + updateEntity.setAssignUserId(AuthContext.getUserId()); updateEntity.setOrgId(cmd.getOrgId()); alarmRecordGateway.update(updateEntity); @@ -73,8 +77,8 @@ public class AlarmDisposeBatchAssignExe { log.setAlarmId(id); log.setAlarmNo(alarmRecord.getAlarmNo()); log.setActionType("MANUAL_ASSIGN"); - log.setBeforeStatus(10); - log.setAfterStatus(20); + log.setBeforeStatus(AlarmRecordStatusEnum.PENDING_REVIEW.getStatus()); + log.setAfterStatus(AlarmRecordStatusEnum.PENDING_DISPOSE.getStatus()); log.setOperatorId(cmd.getDisposeUserId()); log.setActionDesc("批量分配处置"); // log.setActionTime(assignTime); diff --git a/web-app/src/main/java/com/zcloud/command/AlarmDisposeInvalidExe.java b/web-app/src/main/java/com/zcloud/command/AlarmDisposeInvalidExe.java index ce3e266..3da1511 100644 --- a/web-app/src/main/java/com/zcloud/command/AlarmDisposeInvalidExe.java +++ b/web-app/src/main/java/com/zcloud/command/AlarmDisposeInvalidExe.java @@ -2,6 +2,7 @@ package com.zcloud.command; import cn.hutool.core.util.StrUtil; import com.alibaba.cola.exception.BizException; +import com.zcloud.domain.enums.AlarmRecordStatusEnum; import com.zcloud.domain.gateway.AlarmRecordGateway; import com.zcloud.domain.gateway.AlarmDisposeLogGateway; import com.zcloud.domain.model.AlarmRecordE; @@ -41,7 +42,8 @@ public class AlarmDisposeInvalidExe { } // 检查状态：只有待研判(10)或待处置(20)状态可以标记为无效 - if (alarmRecord.getStatus() != 10 && alarmRecord.getStatus() != 20) { + if (!AlarmRecordStatusEnum.PENDING_REVIEW.sameStatus(alarmRecord.getStatus()) + && !AlarmRecordStatusEnum.PENDING_DISPOSE.sameStatus(alarmRecord.getStatus())) { throw new BizException("该报警已处置或已消警，无法标记为无效"); } @@ -50,9 +52,9 @@ public class AlarmDisposeInvalidExe { // 更新报警记录状态 AlarmRecordE updateEntity = new AlarmRecordE(); updateEntity.setId(cmd.getId()); - updateEntity.setStatus(40); // 误报 + updateEntity.setStatus(AlarmRecordStatusEnum.FALSE_ALARM.getStatus()); // 误报 updateEntity.setDisposeTime(LocalDateTime.now()); - updateEntity.setDisposeResult("误报"); + updateEntity.setDisposeResult(AlarmRecordStatusEnum.FALSE_ALARM.getDesc()); if (StrUtil.isNotBlank(cmd.getInvalidReason())) { updateEntity.setDisposeRemark(cmd.getInvalidReason()); } @@ -71,7 +73,7 @@ public class AlarmDisposeInvalidExe { log.setAlarmNo(alarmRecord.getAlarmNo()); log.setActionType("INVALID"); log.setBeforeStatus(beforeStatus); - log.setAfterStatus(40); + log.setAfterStatus(AlarmRecordStatusEnum.FALSE_ALARM.getStatus()); log.setActionDesc("标记为无效报警"); if (StrUtil.isNotBlank(cmd.getInvalidReason())) { log.setResultText(cmd.getInvalidReason()); diff --git a/web-app/src/main/java/com/zcloud/command/AppAlarmDisposeSubmitExe.java b/web-app/src/main/java/com/zcloud/command/AppAlarmDisposeSubmitExe.java index ee1ab3e..79dc9d9 100644 --- a/web-app/src/main/java/com/zcloud/command/AppAlarmDisposeSubmitExe.java +++ b/web-app/src/main/java/com/zcloud/command/AppAlarmDisposeSubmitExe.java @@ -3,21 +3,19 @@ package com.zcloud.command; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.cola.exception.BizException; +import com.zcloud.domain.enums.AlarmRecordStatusEnum; import com.zcloud.domain.gateway.AlarmRecordGateway; -import com.zcloud.domain.gateway.AlarmDisposeLogGateway; import com.zcloud.domain.model.AlarmRecordE; -import com.zcloud.domain.model.AlarmDisposeLogE; import com.zcloud.dto.AppAlarmDisposeSubmitCmd; import com.zcloud.gbscommon.utils.Tools; -import com.zcloud.gbscommon.utils.UuidUtil; import com.zcloud.service.AlarmTodoService; import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; import java.time.LocalDateTime; -import java.time.format.DateTimeFormatter; /** * AppAlarmDisposeSubmitExe - APP报警处置执行器 @@ -27,12 +25,20 @@ import java.time.format.DateTimeFormatter; @Component @RequiredArgsConstructor @RefreshScope +@Slf4j public class AppAlarmDisposeSubmitExe { private final AlarmRecordGateway alarmRecordGateway; + private final AlarmTodoService alarmTodoService; + /** + * APP提交报警处置结果，主流程成功后发送待办完成事件。 + * + * @param cmd APP处置提交参数 + */ @Transactional(rollbackFor = Exception.class) public void execute(AppAlarmDisposeSubmitCmd cmd) { + checkSubmitStatus(cmd.getStatus()); // 查询报警记录 AlarmRecordE alarmRecord = alarmRecordGateway.getById(cmd.getId()); if (Tools.isEmpty(alarmRecord)) { @@ -40,7 +46,7 @@ public class AppAlarmDisposeSubmitExe { } // 检查状态：只有待处置(20)状态可以提交处置 - if (alarmRecord.getStatus() != 20) { + if (!AlarmRecordStatusEnum.PENDING_DISPOSE.sameStatus(alarmRecord.getStatus())) { throw new BizException("该报警已处置或状态异常，无法提交处置结果"); } @@ -48,11 +54,39 @@ public class AppAlarmDisposeSubmitExe { // 更新报警记录 AlarmRecordE updateEntity = new AlarmRecordE(); BeanUtil.copyProperties(cmd, updateEntity); - updateEntity.init(); + updateEntity.setStatus(cmd.getStatus()); + updateEntity.setDisposeResult(buildDisposeResult(cmd)); + updateEntity.setDisposeTime(LocalDateTime.now()); Boolean res = alarmRecordGateway.update(updateEntity); if (!res) { throw new BizException("处置提交失败"); } + completeTodo(cmd.getId()); + } + + private void checkSubmitStatus(Integer status) { + if (!AlarmRecordStatusEnum.RESOLVED.sameStatus(status) + && !AlarmRecordStatusEnum.FALSE_ALARM.sameStatus(status)) { + throw new BizException("处置状态不合法"); + } + } + + private String buildDisposeResult(AppAlarmDisposeSubmitCmd cmd) { + if (StrUtil.isNotBlank(cmd.getDisposeResult())) { + return StrUtil.trim(cmd.getDisposeResult()); + } + if (AlarmRecordStatusEnum.FALSE_ALARM.sameStatus(cmd.getStatus())) { + return AlarmRecordStatusEnum.FALSE_ALARM.getDesc(); + } + return AlarmRecordStatusEnum.RESOLVED.getDesc(); + } + + private void completeTodo(Long alarmId) { + try { + alarmTodoService.completeTodo(alarmId); + } catch (Exception e) { + log.error("APP处置提交后发送待办完成失败，不影响处置主流程，报警ID：{}，错误：{}", alarmId, e.getMessage(), e); + } } } diff --git a/web-app/src/main/java/com/zcloud/command/SensorDeviceRemoveExe.java b/web-app/src/main/java/com/zcloud/command/SensorDeviceRemoveExe.java index 517d748..02597e1 100644 --- a/web-app/src/main/java/com/zcloud/command/SensorDeviceRemoveExe.java +++ b/web-app/src/main/java/com/zcloud/command/SensorDeviceRemoveExe.java @@ -3,6 +3,7 @@ package com.zcloud.command; import com.alibaba.cola.exception.BizException; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.zcloud.domain.gateway.SensorDeviceGateway; +import com.zcloud.domain.model.SensorDeviceE; import com.zcloud.persistence.dataobject.AlarmRecordDO; import com.zcloud.persistence.dataobject.RegionSensorRelDO; import com.zcloud.persistence.repository.AlarmRecordRepository; @@ -29,19 +30,23 @@ public class SensorDeviceRemoveExe { @Transactional(rollbackFor = Exception.class) public boolean execute(Long id) { -// LambdaQueryWrapper relWrapper = new LambdaQueryWrapper<>(); -// relWrapper.eq(RegionSensorRelDO::getSensorId, id) -// .eq(RegionSensorRelDO::getDeleteEnum, "FALSE"); -// if (regionSensorRelRepository.count(relWrapper) > 0) { -// throw new BizException("该传感器已被使用，不可删除"); -// } -// -// LambdaQueryWrapper alarmWrapper = new LambdaQueryWrapper<>(); -// alarmWrapper.eq(AlarmRecordDO::getSensorId, id) -// .eq(AlarmRecordDO::getDeleteEnum, "FALSE"); -// if (alarmRecordRepository.count(alarmWrapper) > 0) { -// throw new BizException("该传感器已被使用，不可删除"); -// } + SensorDeviceE sensorDeviceE = sensorDeviceGateway.getById(id); + if (sensorDeviceE==null) { + throw new BizException("该传感器不存在"); + } + LambdaQueryWrapper relWrapper = new LambdaQueryWrapper<>(); + relWrapper.eq(RegionSensorRelDO::getSensorDeviceId, sensorDeviceE.getSensorDeviceId()) + .eq(RegionSensorRelDO::getDeleteEnum, "FALSE"); + if (regionSensorRelRepository.count(relWrapper) > 0) { + throw new BizException("该传感器已被使用,不可删除"); + } + + /* LambdaQueryWrapper alarmWrapper = new LambdaQueryWrapper<>(); + alarmWrapper.eq(AlarmRecordDO::getId, id) + .eq(AlarmRecordDO::getDeleteEnum, "FALSE"); + if (alarmRecordRepository.count(alarmWrapper) > 0) { + throw new BizException("该传感器已被使用,不可删除"); + }*/ boolean res = sensorDeviceGateway.deleteById(id); if (!res) { diff --git a/web-app/src/main/java/com/zcloud/command/SensorDeviceUpdateExe.java b/web-app/src/main/java/com/zcloud/command/SensorDeviceUpdateExe.java index fb93a9e..819968b 100644 --- a/web-app/src/main/java/com/zcloud/command/SensorDeviceUpdateExe.java +++ b/web-app/src/main/java/com/zcloud/command/SensorDeviceUpdateExe.java @@ -25,6 +25,10 @@ public class SensorDeviceUpdateExe { @Transactional(rollbackFor = Exception.class) public boolean execute(SensorDeviceUpdateCmd cmd) { + SensorDeviceE bySensorCode = sensorDeviceGateway.getBySensorCode(cmd.getSensorCode()); + if (bySensorCode != null && !bySensorCode.getId().equals(cmd.getId())) { + throw new BizException("传感器编码已存在"); + } SensorDeviceE entity = new SensorDeviceE(); BeanUtils.copyProperties(cmd, entity); diff --git a/web-app/src/main/java/com/zcloud/service/AlarmTodoService.java b/web-app/src/main/java/com/zcloud/service/AlarmTodoService.java index 2ca10cb..6520957 100644 --- a/web-app/src/main/java/com/zcloud/service/AlarmTodoService.java +++ b/web-app/src/main/java/com/zcloud/service/AlarmTodoService.java @@ -1,6 +1,7 @@ package com.zcloud.service; import com.alibaba.fastjson.JSONObject; +import com.zcloud.domain.enums.AlarmRecordStatusEnum; import com.zcloud.domain.model.AlarmRecordE; import com.zcloud.gbscommon.todolistmq.TodoListEventPusherUtil; import com.zcloud.gbscommon.todolistmq.event.TodoListAddEvent; @@ -45,6 +46,10 @@ public class AlarmTodoService { log.warn("新增负责人待办参数不完整，跳过发送"); return; } + if (isFalseAlarm(alarmRecord)) { + log.info("报警为误报状态，跳过负责人待办发送，报警ID: {}", alarmRecord.getId()); + return; + } if (todoPusherUnavailable()) { return; } @@ -78,6 +83,10 @@ public class AlarmTodoService { log.warn("新增处置人待办参数不完整，跳过发送"); return; } + if (isFalseAlarm(alarmRecord)) { + log.info("报警为误报状态，跳过处置人待办发送，报警ID: {}", alarmRecord.getId()); + return; + } if (todoPusherUnavailable()) { return; } @@ -101,6 +110,10 @@ public class AlarmTodoService { } } + private boolean isFalseAlarm(AlarmRecordE alarmRecord) { + return AlarmRecordStatusEnum.FALSE_ALARM.sameStatus(alarmRecord.getStatus()); + } + /** * 完成待办 * @param alarmId 报警主表ID diff --git a/web-client/src/main/java/com/zcloud/dto/AlarmRecordPageQry.java b/web-client/src/main/java/com/zcloud/dto/AlarmRecordPageQry.java index ee8fb01..a6c9029 100644 --- a/web-client/src/main/java/com/zcloud/dto/AlarmRecordPageQry.java +++ b/web-client/src/main/java/com/zcloud/dto/AlarmRecordPageQry.java @@ -4,6 +4,8 @@ import com.alibaba.cola.dto.PageQuery; import io.swagger.annotations.ApiModelProperty; import lombok.Data; +import java.util.List; + /** * AlarmRecordPageQry - 报警记录查询 * @Author wangyan @@ -21,8 +23,10 @@ public class AlarmRecordPageQry extends PageQuery { @ApiModelProperty(value = "处置人姓名") private String disposeUserName; - @ApiModelProperty(value = "当前状态 10待研判/20待处置/30已消警/40误报") + @ApiModelProperty(value = "当前状态 10报警中/20未处置/30已消警/40误报") private Integer status; + @ApiModelProperty(value = "当前状态 10报警中/20未处置/30已消警/40误报") + private List statusList; @ApiModelProperty(value = "报警时间开始") private String alarmTimeStart; diff --git a/web-client/src/main/java/com/zcloud/dto/AppAlarmDisposeSubmitCmd.java b/web-client/src/main/java/com/zcloud/dto/AppAlarmDisposeSubmitCmd.java index 334a57b..f01367f 100644 --- a/web-client/src/main/java/com/zcloud/dto/AppAlarmDisposeSubmitCmd.java +++ b/web-client/src/main/java/com/zcloud/dto/AppAlarmDisposeSubmitCmd.java @@ -7,7 +7,7 @@ import lombok.EqualsAndHashCode; import lombok.NoArgsConstructor; import lombok.AllArgsConstructor; -import javax.validation.constraints.NotEmpty; +import javax.validation.constraints.NotNull; /** * AppAlarmDisposeSubmitCmd - APP报警处置命令 @@ -23,8 +23,11 @@ public class AppAlarmDisposeSubmitCmd extends Command { @ApiModelProperty(value = "报警ID", name = "id", required = true) private Long id; - @ApiModelProperty(value = "处置结果（已消警/误报）", name = "disposeResult", required = true) - @NotEmpty(message = "处置结果不能为空") + @ApiModelProperty(value = "处置状态 30已消警/40误报", name = "status", required = true) + @NotNull(message = "处置状态不能为空") + private Integer status; + + @ApiModelProperty(value = "处置结果快照", name = "disposeResult") private String disposeResult; @ApiModelProperty(value = "处置视频地址", name = "videoUrl") diff --git a/web-client/src/main/java/com/zcloud/dto/clientobject/AlarmRecordCO.java b/web-client/src/main/java/com/zcloud/dto/clientobject/AlarmRecordCO.java index 46b497b..f98d44d 100644 --- a/web-client/src/main/java/com/zcloud/dto/clientobject/AlarmRecordCO.java +++ b/web-client/src/main/java/com/zcloud/dto/clientobject/AlarmRecordCO.java @@ -100,7 +100,7 @@ public class AlarmRecordCO extends ClientObject { @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") private LocalDateTime alarmTime; - @ApiModelProperty(value = "当前状态 10待研判/20待处置/30已消警/40误报") + @ApiModelProperty(value = "当前状态 10报警中/20未处置/30已消警/40误报") private Integer status; @ApiModelProperty(value = "分配时间") @@ -109,6 +109,9 @@ public class AlarmRecordCO extends ClientObject { @ApiModelProperty(value = "分配人ID") private Long assignUserId; + @ApiModelProperty(value = "分配人姓名") + private String assignUserName; + @ApiModelProperty(value = "处置时间") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") private LocalDateTime disposeTime; diff --git a/web-client/src/main/java/com/zcloud/dto/clientobject/DeviceRegionCO.java b/web-client/src/main/java/com/zcloud/dto/clientobject/DeviceRegionCO.java index d7c60aa..19ea4bc 100644 --- a/web-client/src/main/java/com/zcloud/dto/clientobject/DeviceRegionCO.java +++ b/web-client/src/main/java/com/zcloud/dto/clientobject/DeviceRegionCO.java @@ -32,6 +32,9 @@ public class DeviceRegionCO extends ClientObject { @ApiModelProperty(value = "外部消防区域编码") private String fireRegionCode; + @ApiModelProperty(value = "负责企业ID") + private Long corpinfoId; + @ApiModelProperty(value = "负责部门ID") private Long departmentId; diff --git a/web-domain/src/main/java/com/zcloud/domain/enums/AlarmRecordStatusEnum.java b/web-domain/src/main/java/com/zcloud/domain/enums/AlarmRecordStatusEnum.java new file mode 100644 index 0000000..9e0c3ca --- /dev/null +++ b/web-domain/src/main/java/com/zcloud/domain/enums/AlarmRecordStatusEnum.java @@ -0,0 +1,35 @@ +package com.zcloud.domain.enums; + +import lombok.Getter; + +import java.util.Arrays; + +/** + * 报警记录状态枚举 + */ +@Getter +public enum AlarmRecordStatusEnum { + PENDING_REVIEW(10, "报警中"), + PENDING_DISPOSE(20, "待处置"), + RESOLVED(30, "已消警"), + FALSE_ALARM(40, "误报"); + + private final Integer status; + private final String desc; + + AlarmRecordStatusEnum(Integer status, String desc) { + this.status = status; + this.desc = desc; + } + + public boolean sameStatus(Integer status) { + return this.status.equals(status); + } + + public static AlarmRecordStatusEnum getByStatus(Integer status) { + return Arrays.stream(values()) + .filter(item -> item.sameStatus(status)) + .findFirst() + .orElse(null); + } +} diff --git a/web-domain/src/main/java/com/zcloud/domain/model/AlarmRecordE.java b/web-domain/src/main/java/com/zcloud/domain/model/AlarmRecordE.java index fa0f89c..38690e2 100644 --- a/web-domain/src/main/java/com/zcloud/domain/model/AlarmRecordE.java +++ b/web-domain/src/main/java/com/zcloud/domain/model/AlarmRecordE.java @@ -1,5 +1,6 @@ package com.zcloud.domain.model; +import com.zcloud.domain.enums.AlarmRecordStatusEnum; import com.jjb.saas.framework.domain.model.BaseE; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -123,6 +124,7 @@ public class AlarmRecordE extends BaseE { * 分配时间 */ private LocalDateTime assignTime; + private Long assignUserId; /** * 处置时间 @@ -180,7 +182,7 @@ public class AlarmRecordE extends BaseE { private Long orgId; public void init(){ - this.setStatus(30); + this.setStatus(AlarmRecordStatusEnum.RESOLVED.getStatus()); this.setDisposeTime(LocalDateTime.now()); } } diff --git a/web-infrastructure/src/main/java/com/zcloud/persistence/dataobject/AlarmRecordDO.java b/web-infrastructure/src/main/java/com/zcloud/persistence/dataobject/AlarmRecordDO.java index 6831d98..b7047ff 100644 --- a/web-infrastructure/src/main/java/com/zcloud/persistence/dataobject/AlarmRecordDO.java +++ b/web-infrastructure/src/main/java/com/zcloud/persistence/dataobject/AlarmRecordDO.java @@ -98,13 +98,16 @@ public class AlarmRecordDO extends BaseDO { @ApiModelProperty(value = "报警时间") private LocalDateTime alarmTime; - @ApiModelProperty(value = "当前状态 10待研判/20待处置/30已消警/40误报") + @ApiModelProperty(value = "当前状态 10报警中/20未处置/30已消警/40误报") private Integer status; @ApiModelProperty(value = "分配时间") private LocalDateTime assignTime; @ApiModelProperty(value = "分配人ID") private Long assignUserId; + @TableField(exist = false) + @ApiModelProperty(value = "分配人姓名") + private String assignUserName; @ApiModelProperty(value = "处置时间") private LocalDateTime disposeTime; diff --git a/web-infrastructure/src/main/java/com/zcloud/persistence/dataobject/DeviceRegionDO.java b/web-infrastructure/src/main/java/com/zcloud/persistence/dataobject/DeviceRegionDO.java index d17a808..547baab 100644 --- a/web-infrastructure/src/main/java/com/zcloud/persistence/dataobject/DeviceRegionDO.java +++ b/web-infrastructure/src/main/java/com/zcloud/persistence/dataobject/DeviceRegionDO.java @@ -30,6 +30,9 @@ public class DeviceRegionDO extends BaseDO { @ApiModelProperty(value = "外部消防区域编码") private String fireRegionCode; + @ApiModelProperty(value = "负责企业ID") + private Long corpinfoId; + @ApiModelProperty(value = "负责部门ID") private Long departmentId; diff --git a/web-infrastructure/src/main/resources/mapper/AlarmRecordMapper.xml b/web-infrastructure/src/main/resources/mapper/AlarmRecordMapper.xml index d57d3ba..b7e872b 100644 --- a/web-infrastructure/src/main/resources/mapper/AlarmRecordMapper.xml +++ b/web-infrastructure/src/main/resources/mapper/AlarmRecordMapper.xml @@ -10,6 +10,8 @@ dep.name AS departmentName, mgr.name AS managerName, sd.sensor_name AS sensorName, + + assign.name AS assignUserName, u.name AS disposeUserName @@ -21,6 +23,7 @@ LEFT JOIN iot_alarm_sensor_device sd ON ar.sensor_device_id = sd.sensor_device_id AND sd.delete_enum = 'FALSE' LEFT JOIN user u ON ar.dispose_user_id = u.id + LEFT JOIN user assign ON ar.assign_user_id = assign.id diff --git a/web-infrastructure/src/main/resources/mapper/SensorDeviceMapper.xml b/web-infrastructure/src/main/resources/mapper/SensorDeviceMapper.xml index 71ef6fa..6c86d77 100644 --- a/web-infrastructure/src/main/resources/mapper/SensorDeviceMapper.xml +++ b/web-infrastructure/src/main/resources/mapper/SensorDeviceMapper.xml @@ -7,7 +7,8 @@