src/main/java/com/xcong/excoin/common/contants/AppContants.java
@@ -88,5 +88,6 @@ public static final String WHOLE_BOMB_PREFIX = "whole_bomb_"; public static final String HOLD_BOND_RATIO = "hold_bond_ratio"; public static final String WHOLE_BOMB_MAP = "whole_bomb_map"; } src/main/java/com/xcong/excoin/rabbit/pricequeue/OrderOperatePriceService.java
@@ -1,8 +1,11 @@ package com.xcong.excoin.rabbit.pricequeue; import com.alibaba.fastjson.JSONObject; import com.xcong.excoin.common.contants.AppContants; import com.xcong.excoin.rabbit.pricequeue.whole.WholeDataQueue; import com.xcong.excoin.rabbit.pricequeue.whole.WholePriceDataModel; import com.xcong.excoin.utils.RedisUtils; import com.xcong.excoin.utils.SpringContextHolder; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections.CollectionUtils; @@ -132,6 +135,8 @@ } public static void wholePriceDataOperation(WholePriceDataModel wholePriceData) { RedisUtils redisUtils = SpringContextHolder.getBean(RedisUtils.class); Map<String, WholePriceDataModel> dataModelMap = WholeDataQueue.MAP; WholePriceDataModel isExistData = dataModelMap.get(wholePriceData.getMemberId().toString()); @@ -140,6 +145,8 @@ } dataModelMap.put(wholePriceData.getMemberId().toString(), wholePriceData); redisUtils.set(AppContants.WHOLE_BOMB_MAP, JSONObject.toJSONString(dataModelMap)); } } src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java
@@ -2,6 +2,7 @@ import cn.hutool.core.collection.CollUtil; 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.dao.ContractOrderDao; @@ -110,6 +111,7 @@ public void run() { log.info("全仓操作价格"); ContractHoldOrderDao contractHoldOrderDao = SpringContextHolder.getBean(ContractHoldOrderDao.class); RedisUtils redisUtils = SpringContextHolder.getBean(RedisUtils.class); MemberWalletContractDao memberWalletContractDao = SpringContextHolder.getBean(MemberWalletContractDao.class); List<ContractHoldOrderEntity> holdOrders = contractHoldOrderDao.selectHoldOrderListByMemberId(memberId);