告警计划 添加 mqtt 通知 las

portal-service-common/src/main/java/com/hfln/portal/common/request/event/AlarmPlanEnableReq.java

@@ -14,7 +14,7 @@ public class AlarmPlanEnableReq extends BaseVO {
 
     @Schema(description = "告警计划ID")
     @NotNull(message = "告警计划ID不能为空")
-    private Integer alarmPlanId;
+    private Integer id;
 
     @Schema(description = "是否启用 1:启用 0:禁用")
     @NotNull(message = "是否启用不能为空")

portal-service-infrastructure/src/main/java/com/hfln/portal/infrastructure/gateway/impl/AlarmGatewayImpl.java

@@ -126,7 +126,7 @@ public class AlarmGatewayImpl implements AlarmGateway {
     @Transactional
     public void enablePlan(AlarmPlanEnableReq req) {
 
-        AlarmPlan alarmPlan = alarmPlanService.getById(req.getAlarmPlanId());
+        AlarmPlan alarmPlan = alarmPlanService.getById(req.getId());
         if (alarmPlan == null) {
             throw new BizException(ErrorEnum.ALARM_PLAN_NOT_EXIST.getErrorCode(), ErrorEnum.ALARM_PLAN_NOT_EXIST.getErrorMessage());
         }
@@ -134,7 +134,7 @@ public class AlarmGatewayImpl implements AlarmGateway {
         alarmPlanService.updateById(alarmPlan);
 
         mqttSend.sendAlarmPlanToLas(alarmPlan.getUuid(), "update");
-        log.info("告警计划alarmPlanId:{}, set enable = {}", req.getAlarmPlanId(), req.getEnable());
+        log.info("告警计划alarmPlanId:{}, set enable = {}", req.getId(), req.getEnable());
     }
 
     @Override

portal-service-infrastructure/src/main/java/com/hfln/portal/infrastructure/service/impl/AlarmPlanServiceImpl.java

@@ -16,7 +16,7 @@ public class AlarmPlanServiceImpl extends ServiceImpl<AlarmPlanMapper, AlarmPlan
     public List<AlarmPlan> queryByClientId(String clientId) {
         LambdaQueryWrapper<AlarmPlan> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(AlarmPlan::getClientId, clientId);
-        wrapper.eq(AlarmPlan::getEnable, 1);
+//        wrapper.eq(AlarmPlan::getEnable, 1);
         return this.baseMapper.selectList(wrapper);
     }