From 89dfa27310651f6d9a2648f976687ca335c5c6ab Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Tue, 01 Jun 2021 11:07:39 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/rabbit/producer/OtcProducter.java | 11 +++++++++--
1 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/rabbit/producer/OtcProducter.java b/src/main/java/com/xcong/excoin/rabbit/producer/OtcProducter.java
index 7d530f3..e52c731 100644
--- a/src/main/java/com/xcong/excoin/rabbit/producer/OtcProducter.java
+++ b/src/main/java/com/xcong/excoin/rabbit/producer/OtcProducter.java
@@ -2,6 +2,7 @@
import cn.hutool.core.util.IdUtil;
+import com.alibaba.fastjson.JSONObject;
import com.xcong.excoin.configurations.RabbitMqConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.AmqpException;
@@ -15,6 +16,8 @@
import org.springframework.stereotype.Component;
import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
@Slf4j
@Component
@@ -32,10 +35,14 @@
rabbitTemplate.setConfirmCallback(this);
}
- public void sendMarketBussinessMsg(String content) {
+ public void sendMarketBussinessMsg(Long entrustOrderId, Integer status) {
log.info("发送市商消息");
CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
- rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_ONE, RabbitMqConfig.ROUTINGKEY_MARKET_BUSSINESS, content, correlationData);
+ Map<String, Object> map = new HashMap<>();
+ map.put("entrustOrderId", entrustOrderId);
+ map.put("status", status);
+ String s = JSONObject.toJSONString(map);
+ rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_ONE, RabbitMqConfig.ROUTINGKEY_MARKET_BUSSINESS, s, correlationData);
}
public void sendDelayOrderMsg(String content) {
--
Gitblit v1.9.1