package com.iailab.module.shasteel.mq.consumer;
|
|
import com.iailab.module.model.api.mcs.McsApi;
|
import com.iailab.module.shasteel.mq.config.QueueModelAlarmConfig;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.amqp.core.Message;
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
/**
|
* 监听报警信息
|
*
|
* @author PanZhibao
|
* @Description
|
* @createTime 2024年12月11日
|
*/
|
@Slf4j
|
@Component
|
public class ModelAlarmConsumer {
|
|
@Resource
|
private McsApi mcsApi;
|
|
/**
|
* 事件标识
|
*/
|
private final String EVENT_FLAG = "GasAlarm";
|
|
/**
|
* 监听报警信息，执行调度
|
*
|
* @param message
|
*/
|
@RabbitListener(queues = QueueModelAlarmConfig.QUEUE_NAME)
|
public void listen(Message message) {
|
// 查找需要执行的调度方案
|
|
|
// 开始执行调度方案
|
|
// 根据模型返回结果，保存调度建议
|
|
}
|
}
|
