沙钢智慧能源系统后端代码
dongyukun
8 天以前 a3bb1815c3eb6b0f0cfe9d9d2ba5ee48279e26ed
shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinish2Consumer.java
@@ -1,6 +1,5 @@
package com.iailab.module.shasteel.mq.consumer;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.iailab.framework.common.util.date.DateUtils;
import com.iailab.module.model.api.mcs.McsApi;
@@ -20,7 +19,6 @@
import org.springframework.util.CollectionUtils;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
@@ -36,6 +34,7 @@
@Component
public class ModelPredictFinish2Consumer {
    @Resource
    private McsApi mcsApi;
@@ -47,7 +46,7 @@
     *
     * @param message
     */
    @RabbitListener(queues = QueuePredictFinishConfig.QUEUE_NAME)
    @RabbitListener(queues = QueuePredictFinishConfig.QUEUE_NAME2)
    public void listen(Message message) {
        String routingKey = message.getMessageProperties().getReceivedRoutingKey();
        log.info("routingKey:" + routingKey);