From c8a99ed8218fe034e9c33236969fcbec9eac75bb Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 24 七月 2019 14:23:25 +0800 Subject: [PATCH] 调整淘宝订单与维权订单爬取 --- fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java | 36 ++++++++++++++++++++++++++++-------- 1 files changed, 28 insertions(+), 8 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java index b04e71d..6d68adf 100644 --- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java +++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java @@ -16,12 +16,11 @@ import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; +import com.yeshi.fanli.dto.taobao.WeiQuanOrderResult; import com.yeshi.fanli.entity.bus.user.LostOrder; import com.yeshi.fanli.entity.bus.user.Order; import com.yeshi.fanli.entity.order.CommonOrder; -import com.yeshi.fanli.entity.taobao.PidUser; import com.yeshi.fanli.entity.taobao.TaoBaoOrder; -import com.yeshi.fanli.entity.taobao.TaoBaoUnionConfig; import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.common.DataMonitorService; @@ -392,14 +391,35 @@ public void doTaoBaoWeiQuan() { if (!Constant.IS_TASK) return; - List<TaoBaoUnionConfig> configList = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID); - List<TaoBaoWeiQuanOrder> orderList = TaoBaoOrderUtil.getWeiQuanOrders( - System.currentTimeMillis() - 1000 * 60 * 60 * 24 * 60L, System.currentTimeMillis(), configList.get(0)); - if (orderList != null) + // 鏂扮増缁存潈璁㈠崟澶勭悊 + for (int i = 0; i < 60; i++) { + List<TaoBaoWeiQuanOrder> orderList = new ArrayList<>(); + WeiQuanOrderResult result = TaoKeOrderApiUtil + .getTaoBaoSpecialWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp( + TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"), + "yyyy-MM-dd")), 1, false); + orderList.addAll(result.orderList); + + result = TaoKeOrderApiUtil.getTaoBaoSpecialWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp( + TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"), + "yyyy-MM-dd")), 1, true); + orderList.addAll(result.orderList); + + result = TaoKeOrderApiUtil.getTaoBaoRelationWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp( + TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"), + "yyyy-MM-dd")), 1, false); + orderList.addAll(result.orderList); + + result = TaoKeOrderApiUtil.getTaoBaoRelationWeiQuanOrderList(new Date(TimeUtil.convertToTimeTemp( + TimeUtil.getGernalTime(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * i, "yyyy-MM-dd"), + "yyyy-MM-dd")), 1, true); + orderList.addAll(result.orderList); + for (TaoBaoWeiQuanOrder order : orderList) taoBaoWeiQuanOrderService.addWeiQuanOrder(order);// 娣诲姞缁存潈璁㈠崟鍒版暟鎹簱 - // 澶勭悊缁存潈璁㈠崟 - orderProcessService.weiQuanOrder(orderList); + // 澶勭悊缁存潈璁㈠崟 + orderProcessService.weiQuanOrder(orderList); + } } // 姣�6涓皬鏃舵墽琛屼竴娆� -- Gitblit v1.8.0