From bf68aa759bc3c0a858d80cb3d1ae1f1682cd6c94 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 06 Apr 2021 15:38:42 +0800
Subject: [PATCH] Merge branch 'activity' of http://120.27.238.55:7000/r/exchange into activity
---
src/main/java/com/xcong/excoin/rabbit/consumer/FollowConsumer.java | 17 +++++++++++++++++
1 files changed, 17 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/rabbit/consumer/FollowConsumer.java b/src/main/java/com/xcong/excoin/rabbit/consumer/FollowConsumer.java
index d3c140b..d206b1b 100644
--- a/src/main/java/com/xcong/excoin/rabbit/consumer/FollowConsumer.java
+++ b/src/main/java/com/xcong/excoin/rabbit/consumer/FollowConsumer.java
@@ -1,5 +1,6 @@
package com.xcong.excoin.rabbit.consumer;
+import com.alibaba.fastjson.JSONObject;
import com.rabbitmq.client.Channel;
import com.xcong.excoin.configurations.RabbitMqConfig;
import com.xcong.excoin.modules.documentary.service.FollowOrderOperationService;
@@ -9,6 +10,10 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
+import org.web3j.abi.datatypes.Int;
+
+import java.math.BigDecimal;
+import java.util.Map;
/**
* @author wzy
@@ -26,6 +31,18 @@
public void addFollowOrder(Message message, Channel channel) {
String content = new String(message.getBody());
log.info("==收到跟单下单消息 : {}", content);
+
followOrderOperationService.addFollowerOrder(Long.parseLong(content));
}
+
+// @RabbitListener(queues = RabbitMqConfig.QUEUE_FOLLOW_CHANGE_BOND)
+ public void changeFollowOrderBond(Message message, Channel channel) {
+ String content = new String(message.getBody());
+ log.info("==收到跟单保证金调整消息 : {}", content);
+ Map map = JSONObject.parseObject(content, Map.class);
+ Integer id = (Integer) map.get("id");
+ BigDecimal bond = (BigDecimal) map.get("bond");
+ Integer type = (Integer) map.get("type");
+ followOrderOperationService.changeFollowOrdersBond(id.longValue(), bond, type);
+ }
}
--
Gitblit v1.9.1