From 651f2856e9ae10aacbfb8327d967aacbb6d58333 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 12 四月 2023 18:13:58 +0800
Subject: [PATCH] 大淘客API修复/唯品会订单爬取策略修改
---
fanli/src/main/java/com/yeshi/fanli/job/order/UpdateCommonOrderJob.java | 21 ++++++++++++++-------
1 files changed, 14 insertions(+), 7 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/order/UpdateCommonOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/order/UpdateCommonOrderJob.java
index 8318e04..f365e59 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/order/UpdateCommonOrderJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/order/UpdateCommonOrderJob.java
@@ -5,6 +5,8 @@
import com.yeshi.fanli.dto.mq.order.body.CommonOrderMQMsg;
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.StringUtil;
import com.yeshi.fanli.util.mq.cmq.order.OrdersCMQManager;
import org.springframework.stereotype.Component;
@@ -27,14 +29,19 @@
@XxlJob("order-update-pay-state")
public ReturnT<String> updatePayState(String param) throws Exception {
//鏇存柊20-25澶╀箣鍓嶇殑鏈鐞嗚鍗�
- List<CommonOrder> resultList = commonOrderService.listPayStateOrder(null,new Date(System.currentTimeMillis() - 1000*60*60*24L*25),new Date(System.currentTimeMillis() - 1000*60*60*24L*20),1,500);
- for(CommonOrder co : resultList){
- OrdersCMQManager.getInstance().addOrder(new CommonOrderMQMsg(co.getOrderNo(),co.getSourceType()));
+ List<CommonOrder> resultList = null;
+ if (!StringUtil.isNullOrEmpty(param)) {
+ if (param.length() > 1) {
+ resultList = commonOrderService.getByOrderNo(null, param);
+ } else {
+ resultList = commonOrderService.listPayStateOrder(Integer.parseInt(param), new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 25), new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 10), 1, 500);
+ }
+ } else {
+ resultList = commonOrderService.listPayStateOrder(null, new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 25), new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 20), 1, 500);
+ }
+ for (CommonOrder co : resultList) {
+ OrdersCMQManager.getInstance().addOrder(new CommonOrderMQMsg(co.getOrderNo(), co.getSourceType()));
}
return ReturnT.SUCCESS;
}
-
-
-
-
}
--
Gitblit v1.8.0