From 81a2c8e297787cc7dc405d6db4972cb917cd80b5 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 17 一月 2020 16:50:57 +0800
Subject: [PATCH] 无用代码删除,单品分享接口修改

---
 fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java |   14 ++++++++------
 1 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java
index 9407c2f..233ebd5 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java
@@ -17,6 +17,7 @@
 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;
 import com.yeshi.fanli.util.cmq.JDOrderCMQManager;
 import com.yeshi.fanli.util.jd.JDApiUtil;
@@ -42,9 +43,9 @@
 			if (order.getValidCode() == 15)// 杩囨护鎺夊緟浠樻
 				continue;
 
-			//闃叉澶氫釜鍟嗗搧鎷嗗崟闂锛岀埇鍙�
+			// 闃叉澶氫釜鍟嗗搧鎷嗗崟闂锛岀埇鍙�
 			if (order.getOrderItemList().size() > 1
-					&& order.getOrderTime() > System.currentTimeMillis() - 1000 * 60 * 2L) {
+					&& order.getOrderTime() > System.currentTimeMillis() - 1000 * 60 * 3L) {
 				continue;
 			}
 
@@ -53,12 +54,13 @@
 				/**
 				 * 鍋氶鐜囬檺鍒�
 				 */
-				String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.JDOrder,  order.getOrderId() + "" );
+				String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.JDOrder, order.getOrderId() + "");
 				String result = redisManager.getCommonString(key);
 				// 鍒ゆ柇
-
-				JDOrderCMQManager.getInstance().addJDOrder(order.getOrderId() + "");
-				redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2灏忔椂鍐呬笉鍐嶆洿鏂�
+				if (StringUtil.isNullOrEmpty(result)) {
+					JDOrderCMQManager.getInstance().addJDOrder(order.getOrderId() + "");
+					redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2灏忔椂鍐呬笉鍐嶆洿鏂�
+				}
 			} catch (JDOrderException e) {
 				e.printStackTrace();
 			}

--
Gitblit v1.8.0