From 011f596d2a72c8532940d4d1033a3da52df76f57 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Mon, 03 Aug 2020 15:53:39 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java | 9 +++++++-- 1 files changed, 7 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java b/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java index 6d5518b..95137e1 100644 --- a/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java +++ b/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java @@ -150,8 +150,8 @@ // 判断是否开启了带单 boolean isOpenFollow = false; - if (memberEntity.getIsTrader().equals(MemberEntity.IS_TRADER_Y)) { - FollowTraderInfoEntity tradeInfo = followTraderInfoDao.selectFollowTraderInfoEntityBytreaderId(memberEntity.getId()); + if (MemberEntity.IS_TRADER_Y.equals(memberEntity.getIsTrader())) { + FollowTraderInfoEntity tradeInfo = followTraderInfoDao.selectTraderInfoByMemberId(memberEntity.getId()); if (tradeInfo.getIsOpen().equals(FollowTraderInfoEntity.ISOPEN_Y)) { isOpenFollow = true; } @@ -198,6 +198,11 @@ } else { LogRecordUtils.insertMemberAccountFlow(memberEntity.getId(), prePaymentAmount, walletContract.getAvailableBalance().subtract(prePaymentAmount), submitOrderDto.getSymbol(), "买跌持仓", "买跌:" + submitOrderDto.getSymbol()); } + + // 若该用户为交易员且开启带单模式,则发送带单异步 + if (isOpenFollow) { + ThreadPoolUtils.sendFollowOrderTask(holdOrderEntity.getId()); + } return Result.ok("提交成功"); } return Result.fail("提交失败"); -- Gitblit v1.9.1