From 58ab6e6d9363ef5566bb7fbb7d8712149305a83b Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Mon, 03 Aug 2020 17:06:08 +0800
Subject: [PATCH] modify

---
 src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java |   21 ++++++++++++++++-----
 1 files changed, 16 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java b/src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java
index 8f7b81f..bb3a3a8 100644
--- a/src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java
@@ -18,6 +18,7 @@
 import com.xcong.excoin.modules.documentary.dao.FollowFollowerProfitDao;
 import com.xcong.excoin.modules.documentary.dao.FollowFollowerSettingDao;
 import com.xcong.excoin.modules.documentary.dao.FollowTraderInfoDao;
+import com.xcong.excoin.modules.documentary.entity.FollowFollowerOrderRelationEntity;
 import com.xcong.excoin.modules.documentary.entity.FollowFollowerProfitEntity;
 import com.xcong.excoin.modules.documentary.entity.FollowFollowerSettingEntity;
 import com.xcong.excoin.modules.documentary.entity.FollowTraderInfoEntity;
@@ -71,6 +72,7 @@
     @Resource
     private FollowTraderInfoDao followTraderInfoDao;
 
+
     @Override
     public void addFollowerOrder(Long id) {
         log.info("进入跟单处理逻辑");
@@ -78,7 +80,6 @@
         ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectById(id);
 
         List<FollowFollowerSettingEntity> followerSettings = followFollowerSettingDao.selectAllFollowerSettingByTradeMemberId(holdOrderEntity.getMemberId());
-        log.info("---->{}, {}", followerSettings.size(), holdOrderEntity.getMemberId());
         // 开仓价
         BigDecimal openPrice = holdOrderEntity.getOpeningPrice();
         PlatformTradeSettingEntity tradeSettingEntity = cacheSettingUtils.getTradeSetting();
@@ -109,6 +110,7 @@
                     }
 
                     if (symbolCnt <= 0) {
+//                        LogRecordUtils.insertFollowerNotice(memberEntity.getId(), NoticeConstant.OPEN_ORDER_TITLE, StrUtil.format(NoticeConstant.OPEN_ORDER_CONTENT, holdOrderEntity.getSymbol() + "开空", openPrice, followTraderInfoEntity.getNickname()));
                         continue;
                     }
                 }
@@ -160,16 +162,25 @@
                 followHoldOrder.setBondAmount(bondAmount.add(openFeePrice));
                 followHoldOrder.setOperateNo(1);
                 // 设置合约类型
-                holdOrderEntity.setContractType(ContractOrderEntity.CONTRACTTYPE_DOCUMENTARY);
+                followHoldOrder.setContractType(ContractOrderEntity.CONTRACTTYPE_DOCUMENTARY);
 
-                ContractOrderEntity contractOrderEntity = ContractHoldOrderEntityMapper.INSTANCE.holdOrderToOrder(holdOrderEntity);
+                ContractOrderEntity contractOrderEntity = ContractHoldOrderEntityMapper.INSTANCE.holdOrderToOrder(followHoldOrder);
                 contractOrderEntity.setOpeningTime(new Date());
-                contractHoldOrderDao.insert(holdOrderEntity);
+                contractHoldOrderDao.insert(followHoldOrder);
                 int i = contractOrderDao.insert(contractOrderEntity);
-
                 if (i > 0) {
                     memberWalletContractDao.increaseWalletContractBalanceById(prePaymentAmount.negate(), openFeePrice.negate(), null, walletContract.getId());
 
+                    FollowFollowerOrderRelationEntity relationEntity = new FollowFollowerOrderRelationEntity();
+                    relationEntity.setIsShow(FollowFollowerOrderRelationEntity.IS_SHOW_Y);
+                    relationEntity.setMemberId(followHoldOrder.getMemberId());
+                    relationEntity.setOrderId(followHoldOrder.getId());
+                    relationEntity.setOrderType(FollowFollowerOrderRelationEntity.ORDER_TYPE_HOLD);
+                    relationEntity.setTradeId(followTraderInfoEntity.getId());
+                    relationEntity.setTradeMemberId(followTraderInfoEntity.getMemberId());
+                    relationEntity.setTradeOrderId(id);
+                    followFollowerOrderRelationDao.insert(relationEntity);
+
                     // 发送爆仓消息
                     sendOrderBombMsg(holdOrderEntity.getId(), holdOrderEntity.getOpeningType(), forceClosingPrice, holdOrderEntity.getSymbol(), holdOrderEntity.getOperateNo());
 

--
Gitblit v1.9.1