exchange.git - Gitblit

			@@ -16,6 +16,7 @@
			import com.xcong.excoin.modules.contract.service.ContractEntrustOrderService;
			import com.xcong.excoin.modules.contract.service.ContractHoldOrderService;
			import com.xcong.excoin.modules.contract.service.ContractOrderService;
			import com.xcong.excoin.modules.documentary.service.FollowOrderOperationService;
			import com.xcong.excoin.modules.member.dao.AgentReturnDao;
			import com.xcong.excoin.modules.member.dao.MemberSettingDao;
			import com.xcong.excoin.modules.member.entity.AgentReturnEntity;
			@@ -80,7 +81,8 @@
			private ContractEntrustOrderDao contractEntrustOrderDao;
			@Resource
			private RedisUtils redisUtils;

			@Resource
			private FollowOrderOperationService followOrderOperationService;

			public void dealOrderFromMq(List<OrderModel> list, Integer type) {
			if (CollectionUtils.isNotEmpty(list)) {
			@@ -794,6 +796,7 @@
			continue;
			}

			// 仅逐仓有用
			if (ContractEntrustOrderEntity.POSITION_TYPE_ADD == coinsOrder.getPositionType()) {
			bombOrder(coinsOrder);
			} else {
			@@ -880,6 +883,12 @@
			record.setSymbol(coinsOrder.getSymbol());
			record.setPrice(coinsOrder.getBondAmount());
			memberAccountFlowEntityDao.insert(record);

			MemberEntity memberEntity = memberService.getById(memId);
			// 如果订单为交易员的订单，爆仓了，则旗下的所有跟单都进行平仓
			if (ContractOrderEntity.CONTRACTTYPE_DOCUMENTARY == coinsOrder.getContractType() && MemberEntity.IS_TRADER_Y.equals(memberEntity.getIsTrader())) {
			followOrderOperationService.closingFollowOrders(coinsOrder.getOrderNo());
			}
			} else {
			MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memId, "USDT");

			@@ -88,10 +88,11 @@
			@Override
			@Transactional(rollbackFor = Exception.class)
			public void addFollowerOrder(Long id) {
			log.info("进入跟单处理逻辑");
			log.info("进入跟单处理逻辑:{}", id);
			// 查询交易员订单
			ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectById(id);

			log.info("----->{}", holdOrderEntity);
			log.info("---->{}", holdOrderEntity.getMemberId());
			List<FollowFollowerSettingEntity> followerSettings = followFollowerSettingDao.selectAllFollowerSettingByTradeMemberId(holdOrderEntity.getMemberId());
			log.info("进入跟单处理逻辑---跟单人数"+followerSettings.size());
			// 开仓价

	src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java	11 ●●●●● patch \| view \| raw \| blame \| history
	src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java	5 ●●●●● patch \| view \| raw \| blame \| history