唯品会链接解析升级

admin

2024-04-26 5e7b0ed4a154ad067cbcf4aa1a1c7cce32f9864c

 fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java

@@ -13,7 +13,6 @@
import com.yeshi.fanli.entity.push.PushQueueRecord;
import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
import com.yeshi.fanli.util.mq.cmq.TDMQUtil;
import org.yeshi.utils.CMQUtil;

import java.util.ArrayList;
import java.util.HashMap;
@@ -24,7 +23,6 @@
    private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
    private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
    private static CMQManager cmqManager;
    private static CMQUtil cmqUtil;
    private static TDMQUtil tdmqUtil;
    // 订单处理队列
    public static String QUEUENAME_ORDER = "fanli-orders";
@@ -60,20 +58,6 @@

    static {

        if (Constant.IS_TEST) {
            QUEUENAME_ORDER = "test-" + QUEUENAME_ORDER;
            QUEUENAME_NEW_ORDER = "test-" + QUEUENAME_NEW_ORDER;
            EXTRACT_RESULT = "test-" + EXTRACT_RESULT;
            PUSH_IOS = "test-" + PUSH_IOS;
            FANLI_ORDER = "test-" + FANLI_ORDER;
            FANLI_ORDER_NEW = "test-" + FANLI_ORDER_NEW;

            ORDER_WEIQUAN = "test-" + ORDER_WEIQUAN;
            IMPORTANT_GOODS_UPDATE = "test-" + IMPORTANT_GOODS_UPDATE;
            TEJIA_VIP = "test-" + TEJIA_VIP;
            FANLI_SHARE_ORDER = "test-" + FANLI_SHARE_ORDER;
        }

        QUEUENAME_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        QUEUENAME_NEW_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        EXTRACT_RESULT += "-" + Constant.systemCommonConfig.getProjectName();
@@ -85,7 +69,6 @@
        FANLI_SHARE_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        TEJIA_VIP += "-" + Constant.systemCommonConfig.getProjectName();

        cmqUtil = CMQUtil.getInstance(secretId, secretKey);
        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);
        tdmqUtil = TDMQUtil.getInstance();
        // 最大消息为1M
@@ -128,18 +111,14 @@
     */
    public List<String> consumeTaoBaoOrderMsg(int count) {
        List<String> resultList = new ArrayList<>();
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, QUEUENAME_ORDER) : cmqUtil.recieveMsg(count, QUEUENAME_ORDER);
        List<Message> list = tdmqUtil.recieveMsg(count, QUEUENAME_ORDER);

        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                resultList.add(result);
                // 删除消息
                if (Constant.TDMQ_CONSUMER) {
                    tdmqUtil.deleteMsg(QUEUENAME_ORDER, msg.receiptHandle);
                } else {
                    cmqUtil.deleteMsg(QUEUENAME_ORDER, msg.receiptHandle);
                }
                tdmqUtil.deleteMsg(QUEUENAME_ORDER, msg.receiptHandle);
            }
        return resultList;
    }
@@ -150,11 +129,9 @@
     * @param receiptHandle
     */
    public void deleteTaoBaoOrderMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(QUEUENAME_ORDER, receiptHandle);
        } else {
            cmqUtil.deleteMsg(QUEUENAME_ORDER, receiptHandle);
        }

        tdmqUtil.deleteMsg(QUEUENAME_ORDER, receiptHandle);

    }

    /**
@@ -175,18 +152,14 @@
     */
    public List<String> consumeTaoBaoNewOrderMsg(int count) {
        List<String> resultList = new ArrayList<>();
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, QUEUENAME_NEW_ORDER) : cmqUtil.recieveMsg(count, QUEUENAME_NEW_ORDER);
        List<Message> list = tdmqUtil.recieveMsg(count, QUEUENAME_NEW_ORDER);

        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                resultList.add(result);
                // 删除消息
                if (Constant.TDMQ_CONSUMER) {
                    tdmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, msg.receiptHandle);
                } else {
                    cmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, msg.receiptHandle);
                }
                tdmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, msg.receiptHandle);
            }
        return resultList;
    }
@@ -198,11 +171,9 @@
     * @param receiptHandle
     */
    public void deleteTaoBaoNewOrderMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, receiptHandle);
        } else {
            cmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, receiptHandle);
        }

        tdmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, receiptHandle);

    }

    /**
@@ -224,7 +195,7 @@
     * @return
     */
    public Map<String, AlipayTransferResultInfo> consumeExtractResultMsg(int count) {
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, EXTRACT_RESULT) : cmqUtil.recieveMsg(count, EXTRACT_RESULT);
        List<Message> list = tdmqUtil.recieveMsg(count, EXTRACT_RESULT);
        Map<String, AlipayTransferResultInfo> map = new HashMap<>();

        if (list != null)
@@ -245,11 +216,9 @@
     * @param receiptHandle
     */
    public void deleteExtractResultMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(EXTRACT_RESULT, receiptHandle);
        } else {
            cmqUtil.deleteMsg(EXTRACT_RESULT, receiptHandle);
        }

        tdmqUtil.deleteMsg(EXTRACT_RESULT, receiptHandle);

    }

    // 订单返利
@@ -265,7 +234,7 @@
    }

    public Map<String, HongBao> consumeFanLiMsg(int count) {
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, FANLI_ORDER) : cmqUtil.recieveMsg(count, FANLI_ORDER);
        List<Message> list = tdmqUtil.recieveMsg(count, FANLI_ORDER);
        Map<String, HongBao> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -279,7 +248,7 @@
    }

    public Map<String, HongBaoV2> consumeFanLiMsgNew(int count) {
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, FANLI_ORDER_NEW) : cmqUtil.recieveMsg(count, FANLI_ORDER_NEW);
        List<Message> list = tdmqUtil.recieveMsg(count, FANLI_ORDER_NEW);
        Map<String, HongBaoV2> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -293,19 +262,15 @@
    }

    public void deleteFanLiMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(FANLI_ORDER, receiptHandle);
        } else {
            cmqUtil.deleteMsg(FANLI_ORDER, receiptHandle);
        }

        tdmqUtil.deleteMsg(FANLI_ORDER, receiptHandle);

    }

    public void deleteFanLiMsgNew(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);
        } else {
            cmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);
        }

        tdmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);

    }


@@ -315,7 +280,7 @@
    }

    public Map<String, UidDateDTO> consumeFanLiShareMsg(int count) {
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, FANLI_SHARE_ORDER) : cmqUtil.recieveMsg(count, FANLI_SHARE_ORDER);
        List<Message> list = tdmqUtil.recieveMsg(count, FANLI_SHARE_ORDER);
        Map<String, UidDateDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
@@ -329,11 +294,7 @@
    }

    public void deleteFanLiShareMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(FANLI_SHARE_ORDER, receiptHandle);
        } else {
            cmqUtil.deleteMsg(FANLI_SHARE_ORDER, receiptHandle);
        }
        tdmqUtil.deleteMsg(FANLI_SHARE_ORDER, receiptHandle);
    }

    // 维权订单
@@ -342,7 +303,7 @@
    }

    public Map<String, TaoBaoWeiQuanOrder> consumeWeiQuanOrderMsg(int count) {
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, ORDER_WEIQUAN) : cmqUtil.recieveMsg(count, ORDER_WEIQUAN);
        List<Message> list = tdmqUtil.recieveMsg(count, ORDER_WEIQUAN);
        Map<String, TaoBaoWeiQuanOrder> map = new HashMap<>();
        Gson gson = new Gson();
        if (list != null)
@@ -356,11 +317,7 @@
    }

    public void deleteWeiQuanOrderMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(ORDER_WEIQUAN, receiptHandle);
        } else {
            cmqUtil.deleteMsg(ORDER_WEIQUAN, receiptHandle);
        }
        tdmqUtil.deleteMsg(ORDER_WEIQUAN, receiptHandle);
    }

    /**
@@ -380,7 +337,7 @@
     * @param count
     */
    public Map<String, PushQueueRecord> consumeIOSPushMsg(int count) {
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, PUSH_IOS) : cmqUtil.recieveMsg(count, PUSH_IOS);
        List<Message> list = tdmqUtil.recieveMsg(count, PUSH_IOS);
        if (list == null) {
            return null;
        }
@@ -405,11 +362,7 @@
     * @param receiptHandle
     */
    public void deleteIOSPushMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(PUSH_IOS, receiptHandle);
        } else {
            cmqUtil.deleteMsg(PUSH_IOS, receiptHandle);
        }
        tdmqUtil.deleteMsg(PUSH_IOS, receiptHandle);
    }

    /**
@@ -417,7 +370,7 @@
     *
     * @param goodsId
     */
    public void addNeedUpdateTaoBaoGoodsId(Long goodsId) {
    public void addNeedUpdateTaoBaoGoodsId(String goodsId) {
        tdmqUtil.sendMsg(GOODS_UPDATE, goodsId + "");
    }

@@ -426,17 +379,17 @@
     *
     * @param count
     */
    public Map<String, Long> consumeNeedUpdateTaoBaoGoodsIdMsg(int count) {
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, GOODS_UPDATE) : cmqUtil.recieveMsg(count, GOODS_UPDATE);
    public Map<String, String> consumeNeedUpdateTaoBaoGoodsIdMsg(int count) {
        List<Message> list = tdmqUtil.recieveMsg(count, GOODS_UPDATE);
        if (list == null) {
            return null;
        }

        Map<String, Long> map = new HashMap<>();
        Map<String, String> map = new HashMap<>();
        for (Message msg : list) {
            String result = msg.msgBody;
            if (!StringUtil.isNullOrEmpty(result)) {
                map.put(msg.receiptHandle, Long.parseLong(result));
                map.put(msg.receiptHandle, result);
            }

        }
@@ -450,11 +403,9 @@
     * @param receiptHandle
     */
    public void deleteNeedUpdateTaoBaoGoodsIdMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(GOODS_UPDATE, receiptHandle);
        } else {
            cmqUtil.deleteMsg(GOODS_UPDATE, receiptHandle);
        }

        tdmqUtil.deleteMsg(GOODS_UPDATE, receiptHandle);

    }

    /**
@@ -462,7 +413,7 @@
     *
     * @param actionId
     */
    public void addTBImpGoodsUpdate(Long actionId) {
    public void addTBImpGoodsUpdate(String actionId) {
        tdmqUtil.sendMsg(IMPORTANT_GOODS_UPDATE, actionId + "");
    }

@@ -472,17 +423,17 @@
     * @param count
     * @return
     */
    public Map<String, Long> consumeTBImpGoodsUpdateMsg(int count) {
        List<Message> list = Constant.TDMQ_CONSUMER ? tdmqUtil.recieveMsg(count, IMPORTANT_GOODS_UPDATE) : cmqUtil.recieveMsg(count, IMPORTANT_GOODS_UPDATE);
    public Map<String, String> consumeTBImpGoodsUpdateMsg(int count) {
        List<Message> list = tdmqUtil.recieveMsg(count, IMPORTANT_GOODS_UPDATE);
        if (list == null) {
            return null;
        }

        Map<String, Long> map = new HashMap<>();
        Map<String, String> map = new HashMap<>();
        for (Message msg : list) {
            String result = msg.msgBody;
            if (!StringUtil.isNullOrEmpty(result)) {
                map.put(msg.receiptHandle, Long.parseLong(result));
                map.put(msg.receiptHandle, result);
            }
        }
        return map;
@@ -494,11 +445,7 @@
     * @param receiptHandle
     */
    public void deleteTBImpGoodsUpdateMsg(String receiptHandle) {
        if (Constant.TDMQ_CONSUMER) {
            tdmqUtil.deleteMsg(IMPORTANT_GOODS_UPDATE, receiptHandle);
        } else {
            cmqUtil.deleteMsg(IMPORTANT_GOODS_UPDATE, receiptHandle);
        }
        tdmqUtil.deleteMsg(IMPORTANT_GOODS_UPDATE, receiptHandle);
    }

}