From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 16 十月 2024 14:28:37 +0800 Subject: [PATCH] 将CMQ替换为rabbitmq --- fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java | 32 ++++++++++++++------------------ 1 files changed, 14 insertions(+), 18 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java index b2b0164..11697e8 100644 --- a/fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java +++ b/fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java @@ -1,34 +1,30 @@ package com.yeshi.fanli.job.order.jd; -import java.util.*; - -import javax.annotation.Resource; - -import com.yeshi.fanli.dao.jd.JDOrderBackUpDao; -import com.yeshi.fanli.dto.jd.JDOrderForBackUpResult; -import com.yeshi.fanli.dto.mq.order.body.CommonOrderMQMsg; -import com.yeshi.fanli.entity.jd.JDBackUpOrder; -import com.yeshi.fanli.entity.order.CommonOrder; -import com.yeshi.fanli.service.inter.order.CommonOrderService; -import com.yeshi.fanli.util.Constant; -import com.yeshi.fanli.util.annotation.JobMonitor; -import com.yeshi.fanli.util.mq.cmq.order.OrdersCMQManager; -import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager; -import org.springframework.stereotype.Component; - import com.xxl.job.core.biz.model.ReturnT; import com.xxl.job.core.handler.annotation.XxlJob; +import com.yeshi.fanli.dao.jd.JDOrderBackUpDao; +import com.yeshi.fanli.dto.jd.JDOrderForBackUpResult; import com.yeshi.fanli.dto.jd.JDOrderResult; +import com.yeshi.fanli.dto.mq.order.body.CommonOrderMQMsg; +import com.yeshi.fanli.entity.jd.JDBackUpOrder; import com.yeshi.fanli.entity.jd.JDOrder; +import com.yeshi.fanli.entity.order.CommonOrder; import com.yeshi.fanli.exception.jd.JDOrderException; import com.yeshi.fanli.log.LogHelper; +import com.yeshi.fanli.service.inter.order.CommonOrderService; import com.yeshi.fanli.service.inter.order.jd.JDOrderService; +import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.RedisKeyEnum; import com.yeshi.fanli.util.RedisManager; import com.yeshi.fanli.util.StringUtil; -import org.yeshi.utils.TimeUtil; +import com.yeshi.fanli.util.annotation.JobMonitor; import com.yeshi.fanli.util.jd.JDApiUtil; -import com.yeshi.fanli.util.mq.cmq.order.JDOrderCMQManager; +import com.yeshi.fanli.util.mq.cmq.order.OrdersCMQManager; +import org.springframework.stereotype.Component; +import org.yeshi.utils.TimeUtil; + +import javax.annotation.Resource; +import java.util.*; //浠庢窐瀹濈埇鍘昏鍗曟洿鏂� @Component -- Gitblit v1.8.0