diff --git a/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitPublisher.java b/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitPublisher.java index a1c7fa3bb..f32b8c776 100644 --- a/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitPublisher.java +++ b/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitPublisher.java @@ -7,7 +7,6 @@ import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; -import java.util.HashMap; import java.util.Map; /** @@ -161,21 +160,21 @@ public class RabbitPublisher { public void sendOtherPrintMsg(Long shopId, Object data, String printType) { String exchange = activeProfile + "-" + RabbitConstants.Exchange.CASH_EXCHANGE; String queueName = activeProfile + "-" + RabbitConstants.Queue.OTHER_PRINT_QUEUE; - Map msg = new HashMap<>(); - msg.put("shopId", shopId); - msg.put("data", data); - msg.put("printTypeEnum", printType); - rabbitTemplate.convertAndSend(exchange, queueName, JSONObject.toJSONString(msg)); + JSONObject jsonObject = new JSONObject(); + jsonObject.put("shopId", shopId); + jsonObject.put("data", data); + jsonObject.put("printTypeEnum", printType); + rabbitTemplate.convertAndSend(exchange, queueName, jsonObject.toString()); } public void sendOtherPrintLocalMsg(Long shopId, String printType, Long dataId) { String exchange = activeProfile + "-" + RabbitConstants.Exchange.CASH_EXCHANGE; String queueName = activeProfile + "-" + RabbitConstants.Queue.OTHER_PRINT_LOCAL_QUEUE; - Map msg = new HashMap<>(); - msg.put("shopId", shopId); - msg.put("dataId", dataId); - msg.put("printType", printType); - rabbitTemplate.convertAndSend(exchange, queueName, msg); + JSONObject jsonObject = new JSONObject(); + jsonObject.put("shopId", shopId); + jsonObject.put("dataId", dataId); + jsonObject.put("printType", printType); + rabbitTemplate.convertAndSend(exchange, queueName, jsonObject.toString()); } }