From af66f9797b42ae81f831d1fbf91a59463a569956 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期四, 17 十一月 2022 19:29:36 +0800 Subject: [PATCH] 拼多多接口修改 --- fanli/src/main/java/com/yeshi/fanli/job/order/suning/UpdateSuningOrderJob.java | 4 +++- 1 files changed, 3 insertions(+), 1 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/job/order/suning/UpdateSuningOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/order/suning/UpdateSuningOrderJob.java index a2ef61d..ea9ebd3 100644 --- a/fanli/src/main/java/com/yeshi/fanli/job/order/suning/UpdateSuningOrderJob.java +++ b/fanli/src/main/java/com/yeshi/fanli/job/order/suning/UpdateSuningOrderJob.java @@ -6,7 +6,9 @@ import javax.annotation.Resource; +import com.yeshi.fanli.dto.mq.order.body.CommonOrderMQMsg; import com.yeshi.fanli.util.Constant; +import com.yeshi.fanli.util.mq.cmq.order.OrdersCMQManager; import org.springframework.stereotype.Component; import com.xxl.job.core.biz.model.ReturnT; @@ -53,7 +55,7 @@ String result = redisManager.getCommonString(key); // 鍒ゆ柇 if (StringUtil.isNullOrEmpty(result)) { - SuningOrderCMQManager.getInstance().addSuningOrder(order.getOrderCode() + ""); + OrdersCMQManager.getInstance().addOrder(new CommonOrderMQMsg(order.getOrderCode() + "",Constant.SOURCE_TYPE_SUNING)); redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2灏忔椂鍐呬笉鍐嶆洿鏂� } } catch (SuningOrderException e) { -- Gitblit v1.8.0