结算日志添加

admin

2022-09-30 ffc56f912da5d6d842142ae4ea1856bc56f8bcb9

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

@@ -5,6 +5,8 @@
import com.yeshi.makemoney.app.dto.mq.AddGoldCornMQMsg;
import com.yeshi.makemoney.app.dto.mq.ExtractTransferResultMQMsg;
import com.yeshi.makemoney.app.dto.mq.GoldCornSettleMQMsg;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.yeshi.utils.StringUtil;
import org.yeshi.utils.mq.TDMQUtil;

@@ -19,6 +21,7 @@
 * @date 2022/4/1 17:06
 */
public class CMQManager {
    Logger logger= LoggerFactory.getLogger(CMQManager.class);
    private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
    private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
    private static CMQManager cmqManager;
@@ -94,6 +97,7 @@

    public void addAddGoldCornMsg(AddGoldCornMQMsg msg) {
        String content = new Gson().toJson(msg);

        tdmqUtil.sendMsg(QUEUE_ADD_GOLDCORN, content);
    }

@@ -123,7 +127,10 @@
     **/
    public void addGoldCornSettleMsg(GoldCornSettleMQMsg msg) {
        String content = new Gson().toJson(msg);
        logger.debug("添加结算消息开始：",content);
        TDMQUtil.getInstance().sendMsg(QUEUE_GOLDCORN_SETTLE, content);
        //添加日志
        logger.debug("添加结算消息结束：{}",content);
    }

    public Map<String, GoldCornSettleMQMsg> consumeGoldCornSettleMsg(int count) {