From f71ae35c5b20e51c5fba91284cc436076c9c73df Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 03 十一月 2020 19:28:19 +0800
Subject: [PATCH] 淘宝订单备份
---
fanli/src/main/java/com/yeshi/fanli/job/order/vipshop/UpdateVipShopOrderJob.java | 212 ++++++++++++++++++++++++++++------------------------
1 files changed, 114 insertions(+), 98 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 fa2b433..1ce809a 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
@@ -26,117 +26,133 @@
@Component
public class UpdateVipShopOrderJob {
- @Resource
- private VipShopOrderService vipShopOrderService;
+ @Resource
+ private VipShopOrderService vipShopOrderService;
- @Resource
- private RedisManager redisManager;
+ @Resource
+ private RedisManager redisManager;
- /**
- * 淇濆瓨璁㈠崟
- *
- * @param VipShopOrderList
- */
- public void saveVipShopOrders(List<VipShopOrder> vipShopOrderList) {
- //5鍒嗛挓涓嶆洿鏂板氨鎶ヨ
- try {
- redisManager.cacheCommonString(RedisKeyEnum.monitor.getKey() + Constant.SOURCE_TYPE_VIP, "1", 60 * 5);
- } catch (Exception e) {
- }
- for (VipShopOrder order : vipShopOrderList) {
- try {
- vipShopOrderService.addOrder(order);
- /**
- * 鍋氶鐜囬檺鍒�
- */
- String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.VIPShopOrder, order.getOrderSn() + "");
- String result = redisManager.getCommonString(key);
- // 鍒ゆ柇
+ /**
+ * 淇濆瓨璁㈠崟
+ *
+ * @param vipShopOrderList
+ */
+ public void saveVipShopOrders(List<VipShopOrder> vipShopOrderList) {
+ //5鍒嗛挓涓嶆洿鏂板氨鎶ヨ
+ try {
+ redisManager.cacheCommonString(RedisKeyEnum.monitor.getKey() + Constant.SOURCE_TYPE_VIP, "1", 60 * 5);
+ } catch (Exception e) {
+ }
+ for (VipShopOrder order : vipShopOrderList) {
+ try {
+ vipShopOrderService.addOrder(order);
+ /**
+ * 鍋氶鐜囬檺鍒�
+ */
+ String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.VIPShopOrder, order.getOrderSn() + "");
+ String result = redisManager.getCommonString(key);
+ // 鍒ゆ柇
// if (StringUtil.isNullOrEmpty(result)) {
- VipShopOrderCMQManager.getInstance().addVipShopOrder(order.getOrderSn() + "");
- redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2灏忔椂鍐呬笉鍐嶆洿鏂�
- LogHelper.test("鍞搧浼氳鍗曟秷鎭彂閫佹垚鍔�");
+ VipShopOrderCMQManager.getInstance().addVipShopOrder(order.getOrderSn() + "");
+ redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2灏忔椂鍐呬笉鍐嶆洿鏂�
+ LogHelper.test("鍞搧浼氳鍗曟秷鎭彂閫佹垚鍔�");
// }else{
// LogHelper.test("鍞搧浼氳鍗曢鐜囬檺鍒�");
// }
- } catch (VipShopOrderException e) {
- e.printStackTrace();
- LogHelper.errorDetailInfo(e);
- }
- }
- }
+ } catch (VipShopOrderException e) {
+ e.printStackTrace();
+ LogHelper.errorDetailInfo(e);
+ }
+ }
+ }
- /**
- * 蹇�熻鍗曟洿鏂帮紙鐖彇鏈皬鏃跺唴鐨勫崟,姣忓垎閽熶竴娆★級
- */
- @XxlJob("updateVipShopOrderHandler")
- public ReturnT<String> updateVipShopSoonOrder(String param) throws Exception {
- LogHelper.test("updateVipShopOrderHandler:"+param);
- long endTime = System.currentTimeMillis();
- if ("1hour".equalsIgnoreCase(param)) {// 鏇存柊1灏忔椂鍐呯殑璁㈠崟
- 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);
- }
- /*
- * else if ("3day".equalsIgnoreCase(param)) {// 鏇存柊鏈�杩�3澶╂洿鏂扮殑鏁版嵁
- * updateByOrderTime(endTime - 1000 * 60 * 60 * 24 * 3L, endTime);
- * updateByUpdateTime(endTime - 1000 * 60 * 60 * 24 * 3L, endTime); }
- */
- return ReturnT.SUCCESS;
- }
+ /**
+ * 蹇�熻鍗曟洿鏂帮紙鐖彇鏈皬鏃跺唴鐨勫崟,姣忓垎閽熶竴娆★級
+ */
+ @XxlJob("updateVipShopOrderHandler")
+ public ReturnT<String> updateVipShopSoonOrder(String param) throws Exception {
+ LogHelper.test("updateVipShopOrderHandler:" + param);
+ long endTime = System.currentTimeMillis();
+ if ("1hour".equalsIgnoreCase(param)) {// 鏇存柊1灏忔椂鍐呯殑璁㈠崟
+ 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);
+ }
+ /*
+ * else if ("3day".equalsIgnoreCase(param)) {// 鏇存柊鏈�杩�3澶╂洿鏂扮殑鏁版嵁
+ * updateByOrderTime(endTime - 1000 * 60 * 60 * 24 * 3L, endTime);
+ * updateByUpdateTime(endTime - 1000 * 60 * 60 * 24 * 3L, endTime); }
+ */
+ return ReturnT.SUCCESS;
+ }
- /**
- * 鎸変笅鍗曟椂闂存洿鏂�
- * @Title: updateByOrderTime
- * @Description:
- * @param startTime
- * @param endTime
- * void 杩斿洖绫诲瀷
- * @throws
- */
- public void updateByOrderTime(long startTime, long endTime) {
- List<VipShopOrder> vipShopOrderList = new ArrayList<>();
- int page = 1;
- VipShopQueryOrderResultDTO result = VipShopApiUtil
- .getOrderList(VipShopOrderQueryModel.createOrderTime(startTime, endTime, null, page));
- while (result != null && result.getOrderList().size() > 0) {
- page++;
- vipShopOrderList.addAll(result.getOrderList());
- result = VipShopApiUtil
- .getOrderList(VipShopOrderQueryModel.createOrderTime(startTime, endTime, null, page));
- }
+ //鏍规嵁璁㈠崟鍙锋洿鏂�
+ @XxlJob("order-vip-updateByOrderSn")
+ public ReturnT<String> updateByOrderSn(String param) throws Exception {
+ List<VipShopOrder> orders = vipShopOrderService.listByOrderSn(param);
+ if (orders == null || orders.size() == 0)
+ throw new Exception("璁㈠崟涓嶅瓨鍦�");
- saveVipShopOrders(vipShopOrderList);
- }
+ VipShopQueryOrderResultDTO result = VipShopApiUtil
+ .getOrderList(VipShopOrderQueryModel.createOrderTime(orders.get(0).getOrderTime(), orders.get(0).getOrderTime() + 1000, null, 1));
+ saveVipShopOrders(result.getOrderList());
+ return ReturnT.SUCCESS;
+ }
- /**
- * 鎸夋洿鏂版椂闂存洿鏂�
- * @Title: updateByOrderTime
- * @Description:
- * @param startTime
- * @param endTime
- * void 杩斿洖绫诲瀷
- * @throws
- */
+ /**
+ * 鎸変笅鍗曟椂闂存洿鏂�
+ *
+ * @param startTime
+ * @param endTime void 杩斿洖绫诲瀷
+ * @throws
+ * @Title: updateByOrderTime
+ * @Description:
+ */
- public void updateByUpdateTime(long startTime, long endTime) {
- List<VipShopOrder> vipShopOrderList = new ArrayList<>();
- int page = 1;
- VipShopQueryOrderResultDTO result = VipShopApiUtil
- .getOrderList(VipShopOrderQueryModel.createUpdateTime(startTime, endTime, null, page));
+ public void updateByOrderTime(long startTime, long endTime) {
+ List<VipShopOrder> vipShopOrderList = new ArrayList<>();
+ int page = 1;
+ VipShopQueryOrderResultDTO result = VipShopApiUtil
+ .getOrderList(VipShopOrderQueryModel.createOrderTime(startTime, endTime, null, page));
- while (result != null && result.getOrderList().size() > 0) {
- page++;
- vipShopOrderList.addAll(result.getOrderList());
- result = VipShopApiUtil
- .getOrderList(VipShopOrderQueryModel.createUpdateTime(startTime, endTime, null, page));
- }
- saveVipShopOrders(vipShopOrderList);
- }
+ while (result != null && result.getOrderList().size() > 0) {
+ page++;
+ vipShopOrderList.addAll(result.getOrderList());
+ result = VipShopApiUtil
+ .getOrderList(VipShopOrderQueryModel.createOrderTime(startTime, endTime, null, page));
+ }
+
+ saveVipShopOrders(vipShopOrderList);
+ }
+
+ /**
+ * 鎸夋洿鏂版椂闂存洿鏂�
+ *
+ * @param startTime
+ * @param endTime void 杩斿洖绫诲瀷
+ * @throws
+ * @Title: updateByOrderTime
+ * @Description:
+ */
+
+ public void updateByUpdateTime(long startTime, long endTime) {
+ List<VipShopOrder> vipShopOrderList = new ArrayList<>();
+ int page = 1;
+ VipShopQueryOrderResultDTO result = VipShopApiUtil
+ .getOrderList(VipShopOrderQueryModel.createUpdateTime(startTime, endTime, null, page));
+
+ while (result != null && result.getOrderList().size() > 0) {
+ page++;
+ vipShopOrderList.addAll(result.getOrderList());
+ result = VipShopApiUtil
+ .getOrderList(VipShopOrderQueryModel.createUpdateTime(startTime, endTime, null, page));
+ }
+ saveVipShopOrders(vipShopOrderList);
+ }
+
}
--
Gitblit v1.8.0