| | |
| | | |
| | | // 若该用户为交易员且开启带单模式,则发送带单异步 |
| | | 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.setTradeOrderNo(holdOrderEntity.getOrderNo()); |
| | | followFollowerOrderRelationDao.insert(relationEntity); |
| | | |
| | | followProducer.sendAddFollowOrder(holdOrderEntity.getId()); |
| | | sendFollowOrder(tradeInfo, holdOrderEntity); |
| | | // ThreadPoolUtils.sendFollowOrderTask(holdOrderEntity.getId()); |
| | | } |
| | | // 提交成功 |
| | |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0067")); |
| | | } |
| | | |
| | | @Override |
| | | public void sendFollowOrder(FollowTraderInfoEntity tradeInfo, ContractHoldOrderEntity holdOrderEntity) { |
| | | 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.setTradeOrderNo(holdOrderEntity.getOrderNo()); |
| | | followFollowerOrderRelationDao.insert(relationEntity); |
| | | |
| | | followProducer.sendAddFollowOrder(holdOrderEntity.getId()); |
| | | } |
| | | |
| | | /** |
| | | * 全仓模式--若当前已经存在持仓,则合并当前持仓 |