批量添加结算消息

admin

2022-10-28 0e9b6603d4ae9d11c1fbc90257ce816c5807b8ff

 app/src/main/java/com/yeshi/makemoney/app/utils/mq/CMQManager.java

@@ -10,6 +10,7 @@
import org.yeshi.utils.StringUtil;
import org.yeshi.utils.mq.TDMQUtil;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -132,6 +133,19 @@
        //添加日志
        logger.debug("添加结算消息结束：{}",content);
    }
    /**
     * 批量添加
     **/
    public void addGoldCornSettleMsg(List<GoldCornSettleMQMsg> msgList) throws Exception {
        List<String> contentList=new ArrayList<>();
        for(GoldCornSettleMQMsg msg:msgList) {
            contentList.add(new Gson().toJson(msg));
        }
        logger.debug("添加结算消息开始：{}",msgList.size());
        TDMQUtil.getInstance().batchSendMsg(QUEUE_GOLDCORN_SETTLE, contentList);
        //添加日志
        logger.debug("添加结算消息结束：{}",msgList.size());
    }

    public Map<String, GoldCornSettleMQMsg> consumeGoldCornSettleMsg(int count) {
        List<Message> list =  TDMQUtil.getInstance().recieveMsg(count, QUEUE_GOLDCORN_SETTLE);