From cdd852f8e8eff7eb2e8f7c3fceaa955b9fc3f9d3 Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期一, 29 七月 2019 10:46:32 +0800
Subject: [PATCH] 订单商品类型处理
---
fanli/src/main/java/com/yeshi/fanli/job/UpdateRelationAndSpecialOrderJob.java | 125 ++++++++++++++++-------------------------
1 files changed, 48 insertions(+), 77 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UpdateRelationAndSpecialOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UpdateRelationAndSpecialOrderJob.java
index 55c8e93..3de8384 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateRelationAndSpecialOrderJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateRelationAndSpecialOrderJob.java
@@ -18,7 +18,7 @@
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TimeUtil;
import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;
-import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
+import com.yeshi.fanli.util.taobao.TaoKeOrderApiUtil;
/**
* 娣樺疂娓犻亾璁㈠崟鏇存柊
@@ -36,62 +36,38 @@
private RedisManager redisManager;
/**
- * 鏇存柊娓犻亾璁㈠崟(鏈�澶�20鍒嗛挓)
+ * 鏇存柊娓犻亾璁㈠崟
*
- * @param startTime
+ * @param fromPage
+ * 寮�濮嬮〉鐮�
+ * @param toPage
+ * 缁撴潫椤电爜锛堟瘡椤�100鏉℃暟鎹級
*/
- private void updateRelationOrder(long startTime) {
- String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss");
- List<TaoBaoOrder> orderList = TaoKeApiUtil.getTaoBaoRelationOrder(startTimeStr, Constant.TAOBAO_AUTH_APPKEY,
- Constant.TAOBAO_AUTH_APPSECRET);
- addRelationAndSpecialOrder(orderList);
- }
+ public void updateRelationAndSpecialOrder(long startTime, long endTime) {
+ List<TaoBaoOrder> list = TaoKeOrderApiUtil.getSpecialOrder(startTime, endTime);
+ List<TaoBaoOrder> list1 = TaoKeOrderApiUtil.getThirdSpecialOrder(startTime, endTime);
+ List<TaoBaoOrder> list2 = TaoKeOrderApiUtil.getRelationOrder(startTime, endTime);
+ List<TaoBaoOrder> list3 = TaoKeOrderApiUtil.getThirdRelationOrder(startTime, endTime);
+ if (list1 != null && list1.size() > 0)
+ list.addAll(list1);
+ if (list2 != null && list2.size() > 0)
+ list.addAll(list2);
+ if (list3 != null && list3.size() > 0)
+ list.addAll(list3);
+ // 鐖彇鍒扮殑璁㈠崟鍙�
+ if (list != null)
+ for (TaoBaoOrder order : list) {
+ LogHelper.orderInfo("鐖彇鍒扮殑璁㈠崟鍙�:" + order.getOrderId());
+ }
- /**
- * 鎸夊ぉ鏇存柊
- *
- * @param day
- */
- private void updateRelationOrderByDay(String day) {
- long timestamp = TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd");
- for (int i = 0; i < 72; i++) {
- updateRelationOrder(timestamp + 1000 * 60 * 20L * i);
- }
- }
-
- /**
- * 鏇存柊浼氬憳璁㈠崟(鏈�澶�20鍒嗛挓)
- *
- * @param startTime
- */
- private void updateSpecialOrder(long startTime) {
- String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss");
- List<TaoBaoOrder> orderList = TaoKeApiUtil.getTaoBaoSpecialOrder(startTimeStr, Constant.TAOBAO_AUTH_APPKEY,
- Constant.TAOBAO_AUTH_APPSECRET);
- addRelationAndSpecialOrder(orderList);
- }
-
- /**
- * 鎸夊ぉ鏇存柊
- *
- * @param day
- */
- private void updateSpecialOrderByDay(String day) {
- long timestamp = TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd");
- for (int i = 0; i < 72; i++) {
- updateSpecialOrder(timestamp + 1000 * 60 * 20L * i);
- }
+ addRelationAndSpecialOrder(list);
}
private void addRelationAndSpecialOrder(List<TaoBaoOrder> orderList) {
try {
taoBaoOrderService.addTaoBaoOrderList(orderList);
} catch (Exception e) {
- try {
- LogHelper.errorDetailInfo(e);
- } catch (Exception e1) {
- e1.printStackTrace();
- }
+ LogHelper.errorDetailInfo(e);
}
try {
@@ -112,7 +88,13 @@
}
- CMQManager.getInstance().addTaoBaoOrderMsg(key, orders);
+ LogHelper.orderInfo("娣诲姞鍒伴槦鍒�:" + key);
+ if (orders != null && orders.size() > 0 && System.currentTimeMillis()
+ - TimeUtil.convertToTimeTemp(orders.get(0).getCreateTime(), "yyyy-MM-dd HH:mm:ss") < 1000
+ * 60 * 10L)// 10鍒嗛挓鍐呬骇鐢熺殑鍗曚綔涓烘柊璁㈠崟澶勭悊
+ CMQManager.getInstance().addTaoBaoNewOrderMsg(key);
+ else
+ CMQManager.getInstance().addTaoBaoOrderMsg(key);
try {
// 20鍒嗛挓鍐呬笉鍐嶅鐞�
@@ -123,11 +105,7 @@
}
}
} catch (Exception e) {
- try {
- LogHelper.errorDetailInfo(e);
- } catch (Exception e1) {
- e1.printStackTrace();
- }
+ LogHelper.errorDetailInfo(e);
}
}
@@ -136,40 +114,33 @@
public void doJob1() {
if (!Constant.IS_TASK)
return;
- long currentTime = System.currentTimeMillis();
- // 鐖彇21鍒嗛挓涔嬪墠鍒扮幇鍦ㄧ殑
- updateRelationOrder(currentTime - 1000 * 60 * 20L);
- updateSpecialOrder(currentTime - 1000 * 60 * 20L);
+ // 鐖彇杩�20鍒嗛挓鐨勬暟鎹�
+ LogHelper.orderInfo("鐖崟:30s鐖彇涓�娆″崟");
+ long endTime = System.currentTimeMillis();
+ updateRelationAndSpecialOrder(endTime - 1000 * 60 * 20L, endTime);
}
- // 姣�16鍒嗛挓鏇存柊涓�娆′竴澶╃殑锛堟瘡澶╁彲鏇存柊杩�90澶╃殑鏁版嵁锛�
- @Scheduled(cron = "0 0/16 * * * ? ")
+ // 姣�5鍒嗛挓鏇存柊锛堣繎1澶╂暟鎹級
+ @Scheduled(cron = "0 0/5 * * * ? ")
public void doJob2() {
if (!Constant.IS_TASK)
return;
- long currentTime = System.currentTimeMillis();
- long dayStartTime = TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(currentTime, "yyyy-MM-dd"), "yyyy-MM-dd");
- int pos = (int) ((currentTime - dayStartTime) / 1000 * 60 * 16L);
-
- long time = dayStartTime - (pos + 1) * 1000 * 60 * 60 * 24L;
-
- // 鍙兘鏇存柊鏈�杩�90澶╃殑
- if (currentTime - time > 1000 * 60 * 60 * 24L * 90)
- return;
- updateRelationOrderByDay(TimeUtil.getGernalTime(time, "yyyy-MM-dd"));
- updateSpecialOrderByDay(TimeUtil.getGernalTime(time, "yyyy-MM-dd"));
+ long endTime = System.currentTimeMillis();
+ updateRelationAndSpecialOrder(endTime - 1000 * 60 * 60 * 24L, endTime);
}
- // 姣忎釜灏忔椂鏇存柊鏈�杩�1澶╃殑鏁版嵁
+ // 姣忎釜灏忔椂鏇存柊
@Scheduled(cron = "0 0 0/1 * * ? ")
public void doJob3() {
if (!Constant.IS_TASK)
return;
- long startTime = System.currentTimeMillis() - 1000 * 60 * 60 * 24L;
- for (int i = 0; i < 71; i++) {
- updateRelationOrder(startTime + 1000 * 60 * 20L * i);
- updateSpecialOrder(startTime + 1000 * 60 * 20L * i);
- }
+ // Calendar calendar = Calendar.getInstance();
+ // int h = calendar.get(Calendar.HOUR_OF_DAY);
+ // // 姣忎釜灏忔椂鏇存柊100椤垫暟鎹�
+ // int fromPage = h * 100;
+ // if (fromPage <= 0)
+ // fromPage = 11;
+ // int toPage = h * 100 + 100;
}
}
--
Gitblit v1.8.0