From f4a0f2acc63d7785eab108419a4e16f5f688cb95 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期六, 18 一月 2020 12:06:27 +0800
Subject: [PATCH] 用户注册信息

---
 fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateOrderJob.java |   23 +++++++++++++++--------
 1 files changed, 15 insertions(+), 8 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateOrderJob.java
index a269c36..d30cc62 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateOrderJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateOrderJob.java
@@ -16,6 +16,8 @@
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.annotation.XxlJob;
 import com.yeshi.fanli.dto.taobao.WeiQuanOrderResult;
 import com.yeshi.fanli.entity.bus.user.LostOrder;
 import com.yeshi.fanli.entity.bus.user.Order;
@@ -33,6 +35,7 @@
 import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;
 import com.yeshi.fanli.util.CMQManager;
 import com.yeshi.fanli.util.Constant;
+import com.yeshi.fanli.util.RedisKeyEnum;
 import com.yeshi.fanli.util.RedisManager;
 import com.yeshi.fanli.util.StringUtil;
 import com.yeshi.fanli.util.TimeUtil;
@@ -204,7 +207,7 @@
 				Iterator<String> its = map.keySet().iterator();
 				while (its.hasNext()) {
 					String key = its.next();
-					String redisKey = "addorderqueue-" + key;
+					String redisKey = RedisKeyEnum.getRedisKey(RedisKeyEnum.addOrderQueue, key);
 					// redis鍋氶鐜囬檺鍒�
 					try {
 						if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(redisKey))) {
@@ -322,9 +325,9 @@
 	// 姣�15鍒嗛挓鐖彇涓�娆�
 	@Scheduled(cron = "0 0/15 * * * ? ")
 	public void pullCommonOrder() {
-		LogHelper.job("姝ｅ湪鎵ц15min璁㈠崟鐖彇");
 		if (!Constant.IS_TASK)
 			return;
+		LogHelper.job("姝ｅ湪鎵ц15min璁㈠崟鐖彇");
 		long currentTime = System.currentTimeMillis() - 1000 * 60;
 		String h = TimeUtil.getGernalTime(currentTime, "HH");
 		String m = TimeUtil.getGernalTime(currentTime, "mm");
@@ -368,11 +371,14 @@
 	}
 
 	// 姣忔湀25鍙�9鐐规墽琛岃繑鍒�
-	@Scheduled(cron = "0 0 9 25 * ? ")
-	public void fanliInvaiteAndShare() {
-		if (!Constant.IS_TASK)
-			return;
-		orderProcessService.fanliInvaiteAndShare();
+	// @Scheduled(cron = "0 0 9 25 * ? ")
+	@XxlJob("fanliInvaiteAndShareHandler")
+	public ReturnT<String> fanliInvaiteAndShareHandler(String param) throws Exception {
+		if (StringUtil.isNullOrEmpty(param))
+			orderProcessService.fanliInvaiteAndShare();
+		else
+			orderProcessService.fanliInvaiteAndShare(Long.parseLong(param));
+		return ReturnT.SUCCESS;
 	}
 
 	// 缁存潈璁㈠崟澶勭悊-澶勭悊鏈�杩�60澶╃殑
@@ -407,7 +413,8 @@
 				List<TaoBaoOrder> taoBaoOrderList = taoBaoOrderService.getTaoBaoOrderByOrderId(lo.getOrderId());
 				// 娓呴櫎棰戠巼闄愬埗
 				if (taoBaoOrderList != null && taoBaoOrderList.size() > 0) {
-					String key = "addorderqueue-" + lo.getOrderId();
+					String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.addOrderQueue, lo.getOrderId());
+
 					redisManager.removeCommonString(key);
 					addOrder(taoBaoOrderList);
 					LogHelper.test("鑷姩澶勭悊娣樺疂璁㈠崟:" + lo.getOrderId());

--
Gitblit v1.8.0