From 4114e871bcb3dce771b6aed64a1027d0bbb95ca6 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 16 五月 2019 15:28:37 +0800
Subject: [PATCH] 增加动态用户
---
fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java | 29 ++++++++++++++++++++++++-----
1 files changed, 24 insertions(+), 5 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 c251ce5..1c68f15 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateCommonOrderJob.java
@@ -10,21 +10,23 @@
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.ThreeSaleGiftService;
import com.yeshi.fanli.service.inter.order.LostOrderService;
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;
import com.yeshi.fanli.util.StringUtil;
+import com.yeshi.fanli.util.TaoBaoConstant;
import com.yeshi.fanli.util.TimeUtil;
import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;
import com.yeshi.fanli.util.taobao.TaoKeOrderApiUtil;
@@ -37,8 +39,6 @@
System.out.println("鍒濆鍖�:UpdateOrderJob");
}
- @Resource
- private ThreeSaleGiftService threeSaleGiftService;
@Resource
private OrderProcessService orderProcessService;
@@ -66,6 +66,9 @@
@Resource
private OrderService orderService;
+ @Resource
+ private TaoBaoOrderMapper taoBaoOrderMapper;
+
/**
* 鏂扮増鑾峰彇鏅�氳鍗�
*
@@ -77,11 +80,11 @@
int page = 1;
String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss");
List<TaoBaoOrder> orderList = TaoKeOrderApiUtil.getTaoBaoAllOrder(startTimeStr, span, page,
- Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET);
+ TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
while (orderList.size() == 100 * page) {
page++;
List<TaoBaoOrder> tempOrderList = TaoKeOrderApiUtil.getTaoBaoAllOrder(startTimeStr, span, page,
- Constant.TAOBAO_AUTH_APPKEY, Constant.TAOBAO_AUTH_APPSECRET);
+ TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
if (tempOrderList != null && tempOrderList.size() > 0)
orderList.addAll(tempOrderList);
}
@@ -210,4 +213,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,
+ TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
+ for (TaoBaoOrder o : newList) {
+ if (o.getOrderId().equalsIgnoreCase(order.getOrderId()))
+ updateOrderList.add(o);
+ }
+ }
+ addOrderNew(updateOrderList);
+ }
+
}
--
Gitblit v1.8.0