KKSU
2024-04-17 829f629756e5402bcd3e9f6ef1f9c6dbffbabb11
src/main/java/com/xcong/excoin/rabbit/init/OrderProducerInit.java
@@ -129,18 +129,10 @@
        }
        // 全仓持仓
        List<HashMap<String, Object>> wholeHoldOrders = contractHoldOrderDao.selectAllWholeOrderMemberIdAndSymbol();
        List<Long> wholeHoldOrders = contractHoldOrderDao.selectAllWholeOrderMemberId();
        if (CollUtil.isNotEmpty(wholeHoldOrders)) {
            MemberEntity memberEntity = null;
            for (HashMap<String, Object> wholeHoldOrder : wholeHoldOrders) {
                Long memberId = (Long) wholeHoldOrder.get("member_id");
                String symbol = (String) wholeHoldOrder.get("symbol");
                if (memberEntity == null || !memberId.equals(memberEntity.getId())) {
                    memberEntity = memberDao.selectById(memberId);
                }
//                ThreadPoolUtils.sendWholeForceClosingPrice(symbol, memberEntity);
                CalculateUtil.getForceSetPriceForWhole(null, memberEntity);
            for (Long memberId : wholeHoldOrders) {
                ThreadPoolUtils.sendWholePrice(memberId);
            }
        }