From c6b6d7723a2ca2d6fb9d940e5ff10a6a2d111c70 Mon Sep 17 00:00:00 2001 From: Jay <csj123456> Date: 星期四, 27 三月 2025 10:50:31 +0800 Subject: [PATCH] 压缩空气班次指标累积评价修改参数长度 --- shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinish2Consumer.java | 5 ++--- 1 files changed, 2 insertions(+), 3 deletions(-) diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinish2Consumer.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinish2Consumer.java index 8b11383..7d4439b 100644 --- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinish2Consumer.java +++ b/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); -- Gitblit v1.9.3