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/vipshop/UpdateVipShopOrderJob.java |   19 +++++++++++++++----
 1 files changed, 15 insertions(+), 4 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/job/order/vipshop/UpdateVipShopOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/order/vipshop/UpdateVipShopOrderJob.java
index 12a7291..343e89f 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/order/vipshop/UpdateVipShopOrderJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/order/vipshop/UpdateVipShopOrderJob.java
@@ -60,7 +60,7 @@
                 String result = redisManager.getCommonString(key);
                 // 鍒ゆ柇
 //				if (StringUtil.isNullOrEmpty(result)) {
-                OrdersCMQManager.getInstance().addOrder(new CommonOrderMQMsg(order.getOrderSn() + "",Constant.SOURCE_TYPE_VIP));
+                OrdersCMQManager.getInstance().addOrder(new CommonOrderMQMsg(order.getOrderSn() + "", Constant.SOURCE_TYPE_VIP));
                 redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2灏忔椂鍐呬笉鍐嶆洿鏂�
                 LogHelper.test("鍞搧浼氳鍗曟秷鎭彂閫佹垚鍔�");
 //				}else{
@@ -84,8 +84,19 @@
             updateByOrderTime(endTime - 1000 * 60 * 60 * 1L, endTime);
             updateByUpdateTime(endTime - 1000 * 60 * 60 * 1L, endTime);
         } else if ("1day".equalsIgnoreCase(param)) {// 鏇存柊鏈�杩�1澶╂洿鏂扮殑鏁版嵁
-            updateByOrderTime(endTime - 1000 * 60 * 60 * 24L, endTime);
-            updateByUpdateTime(endTime - 1000 * 60 * 60 * 24L, endTime);
+            Long startT = endTime - 1000 * 60 * 60 * 24L;
+            for(long start= startT;start<startT +1000 * 60 * 60 * 24L;start+=1000 * 60 * 60 ) {
+                updateByOrderTime(start, start + 1000 * 60 * 60 );
+                updateByUpdateTime(start, start + 1000 * 60 * 60 );
+            }
+        } else if ("1month".equalsIgnoreCase(param)) {// 鏇存柊鏈�杩�1涓湀鐨勬暟鎹�
+            for (int i = 0; i < 30; i++) {
+                Long startT = endTime - 1000 * 60 * 60 * 24L*(i+1);
+               for(long start= startT;start<startT +1000 * 60 * 60 * 24L;start+=1000 * 60 * 60 ) {
+                   updateByOrderTime(start, start + 1000 * 60 * 60 );
+                   updateByUpdateTime(start, start + 1000 * 60 * 60 );
+               }
+            }
         }
         /*
          * else if ("3day".equalsIgnoreCase(param)) {// 鏇存柊鏈�杩�3澶╂洿鏂扮殑鏁版嵁
@@ -129,7 +140,7 @@
     @XxlJob("order-vip-updateByLongTimeNoUpdate")
     public ReturnT<String> updateByLongTimeNoUpdate(String param) throws Exception {
 
-        List<CommonOrder> commonOrders = commonOrderService.listPayStateOrder(Constant.SOURCE_TYPE_VIP, new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 60), new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 10),1,200);
+        List<CommonOrder> commonOrders = commonOrderService.listPayStateOrder(Constant.SOURCE_TYPE_VIP, new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 60), new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 10), 1, 200);
         if (commonOrders == null || commonOrders.size() == 0) {
             throw new Exception("娌℃湁闇�瑕佹洿鏂扮殑璁㈠崟");
         }

--
Gitblit v1.8.0