modify

Helius

2021-01-28 2383ba4c69409ffe6d0d8fcf4e5102de5dc97085

 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));
    }

}