From 2e17d2cd714c047196915b37935e82b9d3d0bc80 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Tue, 13 Oct 2020 21:28:39 +0800
Subject: [PATCH] modify

---
 src/main/java/com/xcong/excoin/trade/CoinTrader.java |   13 ++++++++++---
 1 files changed, 10 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/trade/CoinTrader.java b/src/main/java/com/xcong/excoin/trade/CoinTrader.java
index e4d34f0..3e249f0 100644
--- a/src/main/java/com/xcong/excoin/trade/CoinTrader.java
+++ b/src/main/java/com/xcong/excoin/trade/CoinTrader.java
@@ -2,6 +2,7 @@
 
 import com.alibaba.fastjson.JSON;
 
+import com.alibaba.fastjson.JSONObject;
 import com.xcong.excoin.modules.coin.entity.OrderCoinsEntity;
 import com.xcong.excoin.modules.coin.service.OrderCoinService;
 import com.xcong.excoin.rabbit.producer.ExchangeProducer;
@@ -139,9 +140,16 @@
             return;
         }
         // 如果
-        if (exchangeOrder.getEntrustAmount().compareTo(BigDecimal.ZERO) <= 0 || exchangeOrder.getEntrustAmount().subtract(exchangeOrder.getDealAmount()).compareTo(BigDecimal.ZERO) <= 0) {
-            return;
+        if(OrderCoinsEntity.ORDERTYPE_BUY==exchangeOrder.getOrderType()){
+            if (exchangeOrder.getEntrustAmount().compareTo(BigDecimal.ZERO) <= 0 || exchangeOrder.getEntrustAmount().subtract(exchangeOrder.getDealAmount()).compareTo(BigDecimal.ZERO) <= 0) {
+                return;
+            }
+        }else{
+            if (exchangeOrder.getEntrustCnt().compareTo(BigDecimal.ZERO) <= 0 || exchangeOrder.getEntrustCnt().subtract(exchangeOrder.getDealCnt()).compareTo(BigDecimal.ZERO) <= 0) {
+                return;
+            }
         }
+
 
         TreeMap<BigDecimal, MergeOrder> limitPriceOrderList;
         LinkedList<OrderCoinsEntity> marketPriceOrderList;
@@ -253,7 +261,6 @@
             while (iterator.hasNext()) {
                 OrderCoinsEntity matchOrder = iterator.next();
                 ExchangeTrade trade = processMatch(focusedOrder, matchOrder);
-                logger.info(">>>>>" + trade);
                 if (trade != null) {
                     exchangeTrades.add(trade);
                 }

--
Gitblit v1.9.1