package com.iailab.module.shasteel.mq.consumer;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.iailab.framework.common.util.date.DateUtils;
|
import com.iailab.module.model.api.mcs.McsApi;
|
import com.iailab.module.model.api.mcs.dto.AlarmConfigRespDTO;
|
import com.iailab.module.model.api.mcs.dto.AlarmMessageRespDTO;
|
import com.iailab.module.model.api.mcs.dto.PreDataJsonReqVO;
|
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.CollectionUtils;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @author lirm
|
* @Description
|
* @createTime 2024年11月27日
|
*/
|
@Component
|
@RabbitListener(queues = AlarmMessage.ALARM_ROUTING_KEY)
|
public class AlarmConsumer {
|
|
@Resource
|
private RabbitTemplate rabbitTemplate;
|
|
public void process(AlarmMessage alarmMessage) throws InterruptedException {
|
rabbitTemplate.convertAndSend(AlarmMessage.EXCHANGE, AlarmMessage.ALARM_ROUTING_KEY, alarmMessage);
|
}
|
}
|
