exchange.git - Gitblit

			@@ -1,7 +1,9 @@
			package com.xcong.excoin.modules.contract.service.impl;

			import cn.hutool.core.collection.CollUtil;
			import cn.hutool.core.util.ObjectUtil;
			import com.alibaba.fastjson.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			import com.xcong.excoin.common.contants.AppContants;
			import com.xcong.excoin.common.enumerates.CoinTypeEnum;
			import com.xcong.excoin.modules.coin.dao.MemberAccountFlowEntityDao;
			@@ -16,6 +18,10 @@
			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.dao.FollowFollowerProfitDao;
			import com.xcong.excoin.modules.documentary.dao.FollowFollowerSettingDao;
			import com.xcong.excoin.modules.documentary.entity.FollowFollowerSettingEntity;
			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;
			@@ -59,6 +65,12 @@
			MemberWalletContractService memberWalletContractService;

			@Resource
			FollowFollowerProfitDao followFollowerProfitDao;

			@Resource
			FollowFollowerSettingDao followFollowerSettingDao;

			@Resource
			CacheSettingUtils cacheSettingUtils;

			@Resource
			@@ -80,7 +92,8 @@
			private ContractEntrustOrderDao contractEntrustOrderDao;
			@Resource
			private RedisUtils redisUtils;

			@Resource
			private FollowOrderOperationService followOrderOperationService;

			public void dealOrderFromMq(List<OrderModel> list, Integer type) {
			if (CollectionUtils.isNotEmpty(list)) {
			@@ -195,7 +208,7 @@
			contractOrderEntity.setId(null);

			// 本次平仓数量
			int currentFlat = order.getSymbolCnt();
			int currentFlat = order.getSymbolCntSale();
			BigDecimal symbolSku = cacheSettingUtils.getSymbolSku(order.getSymbol());
			// 盈亏额度= (当前的币种的平仓价-下单时的建仓价)购买的手数/规格倍率
			BigDecimal profitLossPrice = (closePrice
			@@ -244,6 +257,7 @@

			// 全仓模式，止盈/止损删除委托平仓
			if (ContractEntrustOrderEntity.POSITION_TYPE_ALL == order.getPositionType()) {
			ThreadPoolUtils.sendWholePrice(memberId);
			deleteEntrustCloseOrder(order.getOrderNo());
			}
			}
			@@ -295,7 +309,7 @@
			contractOrderEntity.setId(null);

			// 本次平仓数量
			int currentFlat = order.getSymbolCnt();
			int currentFlat = order.getSymbolCntSale();
			BigDecimal symbolSku = cacheSettingUtils.getSymbolSku(order.getSymbol());
			// 盈亏额度= (当前的币种的平仓价-下单时的建仓价)购买的手数/规格倍率
			BigDecimal profitLossPrice = (order.getOpeningPrice()
			@@ -344,6 +358,7 @@

			// 全仓模式，止盈/止损删除委托平仓
			if (ContractEntrustOrderEntity.POSITION_TYPE_ALL == order.getPositionType()) {
			ThreadPoolUtils.sendWholePrice(memberId);
			deleteEntrustCloseOrder(order.getOrderNo());
			}
			}
			@@ -396,7 +411,7 @@
			contractOrderEntity.setId(null);

			// 本次平仓数量
			int currentFlat = order.getSymbolCnt();
			int currentFlat = order.getSymbolCntSale();
			BigDecimal symbolSku = cacheSettingUtils.getSymbolSku(order.getSymbol());
			// 盈亏额度= (当前的币种的平仓价-下单时的建仓价)购买的手数/规格倍率
			BigDecimal profitLossPrice = (closePrice
			@@ -442,6 +457,7 @@

			// 全仓模式，止盈/止损删除委托平仓
			if (ContractEntrustOrderEntity.POSITION_TYPE_ALL == order.getPositionType()) {
			ThreadPoolUtils.sendWholePrice(memberId);
			deleteEntrustCloseOrder(order.getOrderNo());
			}
			}
			@@ -493,7 +509,7 @@
			contractOrderEntity.setId(null);

			// 本次平仓数量
			int currentFlat = order.getSymbolCnt();
			int currentFlat = order.getSymbolCntSale();
			BigDecimal symbolSku = cacheSettingUtils.getSymbolSku(order.getSymbol());
			// 盈亏额度= (当前的币种的平仓价-下单时的建仓价)购买的手数/规格倍率
			BigDecimal profitLossPrice = (order.getOpeningPrice()
			@@ -539,6 +555,7 @@

			// 全仓模式，止盈/止损删除委托平仓
			if (ContractEntrustOrderEntity.POSITION_TYPE_ALL == order.getPositionType()) {
			ThreadPoolUtils.sendWholePrice(memberId);
			deleteEntrustCloseOrder(order.getOrderNo());
			}
			}
			@@ -619,6 +636,7 @@
			contractHoldOrderEntity.setOpeningPrice(entrustPrice);
			contractHoldOrderEntity.setTradeType(ContractHoldOrderEntity.TRADE_TYPE_LIMIT);
			contractHoldOrderEntity.setOperateNo(1);
			contractHoldOrderEntity.setSymbolCntSale(contractHoldOrderEntity.getSymbolCnt());
			contractHoldOrderService.save(contractHoldOrderEntity);

			// 需要一个历史插入
			@@ -700,6 +718,7 @@
			holdOrderEntity.setOperateNo(1);
			// 设置合约类型
			holdOrderEntity.setContractType(ContractOrderEntity.CONTRACTTYPE_NORMAL);
			holdOrderEntity.setHoldBond(CalculateUtil.calMemberHoldBond(holdOrderEntity));

			ContractOrderEntity contractOrderEntity = ContractHoldOrderEntityMapper.INSTANCE.holdOrderToOrder(holdOrderEntity);
			contractOrderEntity.setOpeningTime(new Date());
			@@ -710,6 +729,8 @@
			if (isSuccess) {
			contractEntrustOrderService.removeById(entrustOrder.getId());
			memberWalletContractService.increaseWalletContractBalanceById(null, openFeePrice.negate(), entrustOrder.getBondAmount().negate(), wallet.getId());

			ThreadPoolUtils.sendWholePrice(member.getId());

			// 发送强平价
			ThreadPoolUtils.sendWholeForceClosingPrice(entrustOrder.getSymbol(), member);
			@@ -764,6 +785,7 @@
			*
			* @param
			*/
			@Transactional(rollbackFor = Exception.class)
			public void dealCoinOut(List<ContractHoldOrderEntity> orderList, List<OrderModel> orderModels) {
			if (CollectionUtils.isNotEmpty(orderList)) {
			Map<Long, Integer> modelMap = new HashMap<Long, Integer>();
			@@ -785,6 +807,7 @@
			continue;
			}

			// 仅逐仓有用
			if (ContractEntrustOrderEntity.POSITION_TYPE_ADD == coinsOrder.getPositionType()) {
			bombOrder(coinsOrder);
			} else {
			@@ -794,7 +817,7 @@
			bombOrder(holdOrderEntity);
			}

			MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(coinsOrder.getMemberId(), CoinTypeConvert.convertContractTypeToCoin(coinsOrder.getSymbol()));
			MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(coinsOrder.getMemberId(), CoinTypeEnum.USDT.name());

			// 流水记录 TODO
			MemberAccountFlowEntity record = new MemberAccountFlowEntity();
			@@ -855,7 +878,7 @@
			contractOrderService.save(contractOrderEntity);

			//更新用户钱包数据
			MemberWalletContractEntity usdt = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memId, "USDT");
			MemberWalletContractEntity usdt = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memId, CoinTypeEnum.USDT.name());

			// 减去的时候用负数
			BigDecimal totalPrice = coinsOrder.getBondAmount().negate();
			@@ -871,8 +894,25 @@
			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());
			}
			// 如果不是交易员，那么需要更新他的个人跟随者收益记录
			if (ContractOrderEntity.CONTRACTTYPE_DOCUMENTARY == coinsOrder.getContractType() && !MemberEntity.IS_TRADER_Y.equals(memberEntity.getIsTrader())) {
			//获取当前的跟单设置（一次只允许跟单一个人）,获取交易员MemberId
			QueryWrapper<FollowFollowerSettingEntity> queryWrapper = new QueryWrapper<>();
			queryWrapper.eq("member_id",coinsOrder.getMemberId());
			FollowFollowerSettingEntity followFollowerSettingEntity = followFollowerSettingDao.selectOne(queryWrapper);
			if(ObjectUtil.isNotEmpty(followFollowerSettingEntity)){
			Long traderMemberId = followFollowerSettingEntity.getTraderMemberId();
			followFollowerProfitDao.updateFollowerProfitByTradeMemberId(coinsOrder.getBondAmount().negate(), coinsOrder.getBondAmount().negate(), traderMemberId, memberEntity.getId());
			}
			}
			} else {
			MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memId, CoinTypeConvert.convertContractTypeToCoin(coinsOrder.getSymbol()));
			MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memId, "USDT");

			// BigDecimal rewardRatio = BigDecimal.ZERO;
			// // 开多