exchange.git - Gitblit

			@@ -1,16 +1,26 @@
			package com.xcong.excoin.rabbit.pricequeue;

			import cn.hutool.core.collection.CollUtil;
			import cn.hutool.core.util.StrUtil;
			import com.alibaba.fastjson.JSONObject;
			import com.xcong.excoin.common.contants.AppContants;
			import com.xcong.excoin.common.enumerates.CoinTypeEnum;
			import com.xcong.excoin.modules.contract.dao.ContractHoldOrderDao;
			import com.xcong.excoin.modules.contract.entity.ContractHoldOrderEntity;
			import com.xcong.excoin.modules.member.dao.MemberDao;
			import com.xcong.excoin.modules.member.dao.MemberWalletContractDao;
			import com.xcong.excoin.modules.member.entity.MemberEntity;
			import com.xcong.excoin.modules.member.entity.MemberWalletContractEntity;
			import com.xcong.excoin.rabbit.producer.OrderProducer;
			import com.xcong.excoin.utils.*;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.collections.CollectionUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.stereotype.Component;

			import java.util.ArrayList;
			import java.util.Date;
			import java.util.List;
			import java.util.Map;
			import javax.annotation.Resource;
			import java.math.BigDecimal;
			import java.util.*;
			import java.util.concurrent.PriorityBlockingQueue;

			@Slf4j
			@@ -19,7 +29,14 @@

			@Autowired
			OrderProducer orderProducer;

			@Resource
			private RedisUtils redisUtils;
			@Resource
			private ContractHoldOrderDao contractHoldOrderDao;
			@Resource
			private MemberDao memberDao;
			@Resource
			private MemberWalletContractDao memberWalletContractDao;
			/**
			* @param symbol
			* @param price
			@@ -74,6 +91,19 @@

			}

			private void addExecType(OrderModel model) {
			List<Object> orderTypes = redisUtils.lGet(AppContants.RABBIT_TYPE + model.getOrderId(), 0, -1);
			if (CollUtil.isNotEmpty(orderTypes)) {
			orderTypes.add(model.getType());
			} else {
			orderTypes = new ArrayList<>();
			orderTypes.add(model.getType());
			}

			redisUtils.lSet(AppContants.RABBIT_TYPE + model.getOrderId(), orderTypes, 10);
			redisUtils.lSet(AppContants.MEMBER_TYPE + model.getMemberId(), orderTypes, 5);
			}

			// 处理消息正序的包括
			// 1：买入委托2：开多3:开空4：平多5：平空6:爆仓平多7:爆仓平空8:撤单9:止盈平多10：止盈平空11：止损平多12：止损平空
			public void dealAscPriceOrderAndSenMq(List<AscBigDecimal> list, String symbol) {
			@@ -97,12 +127,18 @@
			if (CollectionUtils.isEmpty(orderModelList)) {
			return;
			}
			System.out.println("本次执行的列表ASC");
			System.out.println(JSONObject.toJSONString(orderModelList));
			log.info("本次执行的列表ASC");
			// 根据订单的类型发送消息
			// 3:开空 7:爆仓平空
			// 9:止盈平多 12：止损平空
			for (OrderModel model : orderModelList) {
			/*
			问题: 1、逐仓: 当行情大时，若设置的止损点与爆仓过于接近，则可能会出现直接爆仓，而不止损的情况
			2、全仓: 止盈价/止损价设置的与委托平仓价相同，需优先处理止盈/止损
			解决: 将订单ID作为Key, 该订单执行的队列类型集合作为value, 用于在执行爆仓、委托平仓时，是否存在止盈/止损，若存在则不执行该爆仓和委托平仓
			*/
			addExecType(model);

			// 止损平空
			List<OrderModel> kkzsList = new ArrayList<OrderModel>();
			// 止盈平多
			@@ -178,12 +214,18 @@
			if (CollectionUtils.isEmpty(orderModelList)) {
			return;
			}
			System.out.println("本次执行的列表Desc");
			System.out.println(JSONObject.toJSONString(orderModelList));
			log.info("本次执行的列表Desc");
			// 根据订单的类型发送消息
			// 2：开多6:爆仓平多
			// 10：止盈平空11：止损平多
			for (OrderModel model : orderModelList) {
			/*
			问题: 1、逐仓: 当行情大时，若设置的止损点与爆仓过于接近，则可能会出现直接爆仓，而不止损的情况
			2、全仓: 止盈价/止损价设置的与委托平仓价相同，需优先处理止盈/止损
			解决: 将订单ID作为Key, 该订单执行的队列类型集合作为value, 用于在执行爆仓、委托平仓时，是否存在止盈/止损，若存在则不执行该爆仓和委托平仓
			*/
			addExecType(model);

			// 开空止盈
			List<OrderModel> kkzyList = new ArrayList<OrderModel>();
			// 开多止损
			@@ -236,4 +278,50 @@
			}
			}


			public void wholeBomb(String symbol, String price) {
			List<Long> memberIds = contractHoldOrderDao.selectMemberHasWholeOrder();
			CacheSettingUtils cacheSettingUtils = SpringContextHolder.getBean(CacheSettingUtils.class);

			if (CollUtil.isNotEmpty(memberIds)) {
			for (Long memberId : memberIds) {
			List<ContractHoldOrderEntity> holdOrderEntities = contractHoldOrderDao.selectHoldOrderListByMemberId(memberId);
			MemberEntity memberEntity = memberDao.selectById(memberId);

			if (CollUtil.isNotEmpty(holdOrderEntities)) {
			BigDecimal totalProfitOrLess = BigDecimal.ZERO;
			String currentPrice = null;
			for (ContractHoldOrderEntity holdOrderEntity : holdOrderEntities) {
			if (symbol.equalsIgnoreCase(holdOrderEntity.getSymbol())) {
			currentPrice = price;
			} else {
			currentPrice = redisUtils.getString(CoinTypeConvert.convertToKey(holdOrderEntity.getSymbol()));
			}
			BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(holdOrderEntity.getSymbol());
			BigDecimal profitOrLess = CalculateUtil.calOrderProfitOrLess(holdOrderEntity.getOpeningType(), new BigDecimal(currentPrice), holdOrderEntity.getOpeningPrice(), lotNumber, holdOrderEntity.getSymbolCntSale(), memberEntity.getIsProfit());
			totalProfitOrLess = totalProfitOrLess.add(profitOrLess);
			}
			MemberWalletContractEntity wallet = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberId, CoinTypeEnum.USDT.name());

			BigDecimal sub = wallet.getTotalBalance().add(totalProfitOrLess);
			// log.info("sub : {}, memberId : {}", sub, memberId);
			if (sub.compareTo(BigDecimal.ZERO) <= 0) {
			List<OrderModel> list = new ArrayList<>();
			OrderModel orderModel = new OrderModel(null, 0, price, symbol, memberId);
			list.add(orderModel);
			String content = JSONObject.toJSONString(list);

			String key = AppContants.WHOLE_BOMB_PREFIX + memberId;
			String value = redisUtils.getString(key);
			if (StrUtil.isBlank(value)) {
			orderProducer.sendWholeBomb(content);
			contractHoldOrderDao.updateMemberAllHoldOrderClosingStatus(memberId);

			redisUtils.set(key, memberId);
			}
			}
			}
			}
			}
			}
			}