添加预案告警推送

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/action/ContingencyAction.java

@@ -17,6 +17,7 @@ import com.yeejoin.amos.fas.business.action.result.ActionResult;
 import com.yeejoin.amos.fas.business.action.result.SafteyPlanResult;
 import com.yeejoin.amos.fas.business.action.result.message.AbstractActionResultMessage;
 import com.yeejoin.amos.fas.business.action.util.ContingencyLogPublisher;
+import com.yeejoin.amos.fas.business.bo.FirePlanAlarmBo;
 import com.yeejoin.amos.fas.business.dao.repository.IPlanDetailDao;
 import com.yeejoin.amos.fas.business.dao.repository.IPlanOperationRecordDao;
 import com.yeejoin.amos.fas.business.feign.IDutyModeServer;
@@ -300,6 +301,20 @@ public class ContingencyAction implements CustomerAction {
                     String msg = JSON.toJSONString(event);
                     log.info("RocketMQ发送的主题是: " + rocketTopic + ", 消息体是: " + msg + "！");
                     try {
+                    	FirePlanAlarmBo fpab = new FirePlanAlarmBo();
+                    	fpab.setDeviceId(ro.getEquipmentCode());
+                    	fpab.setDeviceName(ro.getEquipmentName());
+                    	fpab.setFiredeviceId(ro.getFireEquipmentCode());
+                    	fpab.setFiredeviceName(ro.getFireEquipmentName());
+                    	fpab.setStationId("00602");
+                    	fpab.setWarningId(ro.getBatchNo());
+                    	fpab.setWarningInfo(ro.getFireEquipmentName()+"发生火灾报警");
+                    	fpab.setWarningTime(DateUtil.getLongCurrentDate());
+                    	List<FirePlanAlarmBo> list = new ArrayList<FirePlanAlarmBo>();
+                    	list.add(fpab);
+                    	
+                    	rocketMQTemplate.convertAndSend("/topic/fire/equip-alarm", JSON.toJSONString(list));
+                    	
                         rocketMQTemplate.convertAndSend(rocketTopic, msg);
                     } catch (Exception e) {
                         throw new RuntimeException("RocketMQ消息发送失败！");

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/bo/FirePlanAlarmBo.java

+package com.yeejoin.amos.fas.business.bo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+@ApiModel(description = "消防整改 单据修改实体类")
+public class FirePlanAlarmBo {
+   
+	/**
+	 * 报警id
+	 */
+    private String warningId;
+	/**
+	 * 站编码
+	 */
+    private String stationId;
+    /**
+     * 一次设备编码（电力设备）
+     */
+    private String deviceId;
+    /**
+     * 电力设备名称
+     */
+    private String deviceName;
+    /**
+     * 消防设备编码
+     */
+    private String FiredeviceId;
+    /**
+     * 消防设备名称
+     */
+    private String FiredeviceName;
+    /**
+     * 报警内容
+     */
+    private String warningInfo;
+    /**
+     * 报警时间
+     */
+    private String warningTime;
+}

YeeAmosFireAutoSysStart/src/main/resources/application-dev.properties

@@ -54,7 +54,7 @@ emqx.password=public
 rocketmq.name-server=172.16.3.51:9876
 rocketmq.producer.group=my-group
 rocketmq.producer.sendMessageTimeout=300000
-rocket-plan-topic=template_topic
+rocket-plan-topic=/topic/fire/emergency-plan
 
 #文件服务器地址
 file.downLoad.url=http://172.16.11.201:9000/