modify

Helius

2020-08-03 d61072f997839b4564ce35132d5902a1b6f7d54f

modify

 src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java

@@ -22,7 +22,9 @@
import com.xcong.excoin.modules.contract.parameter.dto.*;
import com.xcong.excoin.modules.contract.parameter.vo.*;
import com.xcong.excoin.modules.contract.service.ContractHoldOrderService;
import com.xcong.excoin.modules.documentary.dao.FollowFollowerOrderRelationDao;
import com.xcong.excoin.modules.documentary.dao.FollowTraderInfoDao;
import com.xcong.excoin.modules.documentary.entity.FollowFollowerOrderRelationEntity;
import com.xcong.excoin.modules.documentary.entity.FollowTraderInfoEntity;
import com.xcong.excoin.modules.member.dao.MemberDao;
import com.xcong.excoin.modules.member.dao.MemberLevelRateDao;
@@ -87,6 +89,8 @@
    
    @Resource
    private FollowTraderInfoDao followTraderInfoDao;
    @Resource
    private FollowFollowerOrderRelationDao followFollowerOrderRelationDao;

    @Transactional(rollbackFor = Exception.class)
    @Override
@@ -150,8 +154,9 @@

        // 判断是否开启了带单
        boolean isOpenFollow = false;
        FollowTraderInfoEntity tradeInfo = null;
        if (MemberEntity.IS_TRADER_Y.equals(memberEntity.getIsTrader())) {
            FollowTraderInfoEntity tradeInfo = followTraderInfoDao.selectTraderInfoByMemberId(memberEntity.getId());
            tradeInfo = followTraderInfoDao.selectTraderInfoByMemberId(memberEntity.getId());
            if (tradeInfo.getIsOpen().equals(FollowTraderInfoEntity.ISOPEN_Y)) {
                isOpenFollow = true;
            }
@@ -201,6 +206,16 @@

            // 若该用户为交易员且开启带单模式，则发送带单异步
            if (isOpenFollow) {
                FollowFollowerOrderRelationEntity relationEntity = new FollowFollowerOrderRelationEntity();
                relationEntity.setIsShow(FollowFollowerOrderRelationEntity.IS_SHOW_Y);
                relationEntity.setMemberId(holdOrderEntity.getMemberId());
                relationEntity.setOrderId(holdOrderEntity.getId());
                relationEntity.setOrderType(FollowFollowerOrderRelationEntity.ORDER_TYPE_HOLD);
                relationEntity.setTradeId(tradeInfo.getId());
                relationEntity.setTradeMemberId(tradeInfo.getMemberId());
                relationEntity.setTradeOrderId(id);
                followFollowerOrderRelationDao.insert(relationEntity);

                ThreadPoolUtils.sendFollowOrderTask(holdOrderEntity.getId());
            }
            return Result.ok("提交成功");