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