From 2b9a977204bbd06e9d040f7653d780770580fb73 Mon Sep 17 00:00:00 2001 From: zhangyanduan Date: Wed, 6 Jul 2022 09:23:47 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E4=BC=98=E5=8C=96=E6=96=87=E6=A1=A3?= =?UTF-8?q?=E8=BD=AC=E6=8D=A2=E7=BB=84=E4=BB=B6=E7=9A=84=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E9=98=9F=E5=88=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/adc/da/convert/mq/SendConvertMQService.java | 7 +++++-- .../src/main/java/com/adc/da/mq/CreateMQService.java | 5 +++-- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/adc-da-convert/src/main/java/com/adc/da/convert/mq/SendConvertMQService.java b/adc-da-convert/src/main/java/com/adc/da/convert/mq/SendConvertMQService.java index dd32104f..0aa837a6 100644 --- a/adc-da-convert/src/main/java/com/adc/da/convert/mq/SendConvertMQService.java +++ b/adc-da-convert/src/main/java/com/adc/da/convert/mq/SendConvertMQService.java @@ -20,6 +20,7 @@ import com.adc.da.util.http.ResponseMessage; import com.adc.da.util.http.Result; import com.adc.da.util.utils.StringUtils; import com.adc.da.util.utils.UUID; +import com.alibaba.fastjson.JSONObject; import com.rabbitmq.client.Channel; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -40,7 +41,7 @@ import java.util.Map; @Component public class SendConvertMQService { - // 文档转换远程服务IP地址s + // 文档转换远程服务IP地址 @Value("${convert.host}") private String convertHost; @@ -74,9 +75,11 @@ public class SendConvertMQService { value = @Queue(value = "createConvertStandMQ_SQ_GSAR_RELEASE", durable = "true"), exchange = @Exchange(value = "convert-exchange_SQ_GSAR_RELEASE", ignoreDeclarationExceptions = "true"), key = "convert-key_SQ_GSAR_RELEASE")) - public void createMQ(Map convertInfo, Message message, Channel channel) throws Exception{ + public void createMQ(Message message, Channel channel) throws Exception{ try{ try{ + String messagePayload = (String) message.getPayload(); + Map convertInfo = JSONObject.parseObject(messagePayload, Map.class); Thread.sleep(5000); insertConvertMsg(convertInfo); }catch(InterruptedException e){ diff --git a/adc-da-slrs/src/main/java/com/adc/da/mq/CreateMQService.java b/adc-da-slrs/src/main/java/com/adc/da/mq/CreateMQService.java index 5e6c6f22..ac3db538 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/mq/CreateMQService.java +++ b/adc-da-slrs/src/main/java/com/adc/da/mq/CreateMQService.java @@ -3,6 +3,7 @@ package com.adc.da.mq; import com.adc.da.slrs.otConvertMq.dao.OtConvertMqDao; import com.adc.da.slrs.otConvertMq.entity.OtConvertMq; import com.adc.da.util.UUIDUtils; +import com.alibaba.fastjson.JSONObject; import org.apache.commons.lang3.StringUtils; import org.springframework.amqp.core.AmqpTemplate; import org.springframework.beans.factory.annotation.Autowired; @@ -69,9 +70,9 @@ public class CreateMQService { convertInfo.put("standFilePdfId", convert.getPdfId()); convertInfo.put("againNum",convert.getAgainNum()); } - + String body = JSONObject.toJSONString(convertInfo); //发送消息队列 - this.rabbitTemplate.convertAndSend("convert-exchange_SQ_GSAR_RELEASE", "convert-key_SQ_GSAR_RELEASE", convertInfo); + this.rabbitTemplate.convertAndSend("convert-exchange_SQ_GSAR_RELEASE", "convert-key_SQ_GSAR_RELEASE", body); } }