From e782b2bcfd89f7ce2e3079c7ebb0867bb00124a7 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 01 四月 2019 18:54:27 +0800
Subject: [PATCH] 爬单修改
---
fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java | 35 ++++++++++++++++++++++-------------
1 files changed, 22 insertions(+), 13 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java
index 4b946c0..99b781d 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java
@@ -10,19 +10,18 @@
import org.springframework.scheduling.annotation.Scheduled;
+import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoOrderMapper;
import com.yeshi.fanli.entity.bus.user.Order;
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.common.DataMonitorService;
-import com.yeshi.fanli.service.inter.hongbao.HongBaoService;
-import com.yeshi.fanli.service.inter.hongbao.ThreeSaleGiftService;
import com.yeshi.fanli.service.inter.order.LostOrderService;
-import com.yeshi.fanli.service.inter.order.OrderItemServcie;
import com.yeshi.fanli.service.inter.order.OrderProcessService;
import com.yeshi.fanli.service.inter.order.OrderService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanOrderService;
+import com.yeshi.fanli.util.BeanUtil;
import com.yeshi.fanli.util.CMQManager;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.RedisManager;
@@ -38,15 +37,6 @@
public UpdateCommonOrderJob() {
System.out.println("鍒濆鍖�:UpdateOrderJob");
}
-
- @Resource
- private OrderItemServcie orderItemServcie;
-
- @Resource
- private ThreeSaleGiftService threeSaleGiftService;
-
- @Resource
- private HongBaoService hongBaoService;
@Resource
private OrderProcessService orderProcessService;
@@ -74,6 +64,9 @@
@Resource
private OrderService orderService;
+
+ @Resource
+ private TaoBaoOrderMapper taoBaoOrderMapper;
/**
* 鏂扮増鑾峰彇鏅�氳鍗�
@@ -205,7 +198,7 @@
- (1000 * 60 * 60 * 24L * (90 - pos));
long endTime = startTime + 1000 * 60 * 60 * 24L;
LogHelper.orderInfo("姝ｅ湪鎵ц璁㈠崟鐖彇...");
-// updateOrder(startTime, endTime);
+ // updateOrder(startTime, endTime);
}
// 娣樺疂鎺ㄥ箍璁㈠崟 姣忛殧30绉掓墽琛屼竴娆�
@@ -219,4 +212,20 @@
addOrderNew(orderList);
}
+ // 姣忔櫄10鐐规墽琛屾紡鍗�
+ @Scheduled(cron = "0 0 22 * * ? ")
+ public void doJob3() {
+ List<TaoBaoOrder> orderList = taoBaoOrderMapper.listLongTimeNoUpdateOrders(0, 10);
+ List<TaoBaoOrder> updateOrderList = new ArrayList<>();
+ for (TaoBaoOrder order : orderList) {
+ List<TaoBaoOrder> newList = TaoKeOrderApiUtil.getTaoBaoAllOrder(order.getCreateTime(), 60, 1,
+ Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET);
+ for (TaoBaoOrder o : newList) {
+ if (o.getOrderId().equalsIgnoreCase(order.getOrderId()))
+ updateOrderList.add(o);
+ }
+ }
+ addOrderNew(updateOrderList);
+ }
+
}
--
Gitblit v1.8.0