admin
2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe
fanli/src/main/java/com/yeshi/fanli/job/order/dy/UpdateDYOrderJob.java
@@ -15,6 +15,7 @@
import com.yeshi.fanli.util.goods.douyin.vo.DYOrderFilter;
import com.yeshi.fanli.util.goods.douyin.vo.DYOrderResult;
import com.yeshi.fanli.util.mq.cmq.order.OrdersCMQManager;
import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
@@ -29,6 +30,9 @@
    @Resource
    private RedisManager redisManager;
    @Resource
    private OrdersCMQManager ordersCMQManager;
    /**
@@ -54,7 +58,7 @@
                String result = redisManager.getCommonString(key);
                // 判断
                if (StringUtil.isNullOrEmpty(result)) {
                    OrdersCMQManager.getInstance().addOrder(new CommonOrderMQMsg(order.getOrder_id() + "", Constant.SOURCE_TYPE_DY));
                    ordersCMQManager.addOrder(new CommonOrderMQMsg(order.getOrder_id() + "", Constant.SOURCE_TYPE_DY));
                    redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2小时内不再更新
                }
            } catch (DYOrderException e) {