From f77b296544517db3f2cb56aab9c754d4810cc35d Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 13 八月 2019 15:44:58 +0800
Subject: [PATCH] 大淘客新版数据修正

---
 fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java |   46 +++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 45 insertions(+), 1 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java b/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
index 1019125..9119ec3 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
@@ -24,6 +24,7 @@
 import com.yeshi.fanli.entity.jd.JDOrder;
 import com.yeshi.fanli.entity.pdd.PDDOrder;
 import com.yeshi.fanli.entity.push.PushQueueRecord;
+import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
 import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
 import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
 import com.yeshi.fanli.exception.TaoBaoWeiQuanException;
@@ -45,6 +46,7 @@
 import com.yeshi.fanli.util.cmq.PDDOrderCMQManager;
 import com.yeshi.fanli.util.cmq.ThreeSaleCMQManager;
 import com.yeshi.fanli.util.cmq.UserMoneyChangeCMQManager;
+import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
 
 /**
  * 绯荤粺鍒濆鍖�
@@ -130,10 +132,12 @@
 			doThreeSaleUserCouponJob();// 澶勭悊閭�璇烽槦鍒�
 			doUserMoneyDebtJob();// 鍊哄姟鍋胯繕
 			initScheduler();// 鍚姩鍟嗗搧鏇存柊瀹氭椂浠诲姟
-			doUpdateGoodsJob(); // 鏇存柊鍟嗗搧闃熷垪			
+			doUpdateGoodsJob(); // 鏇存柊鍟嗗搧闃熷垪
 			doJDOrderJob();// 浜笢璁㈠崟澶勭悊
 			doPDDOrderJob();// 鎷煎澶氳鍗曞鐞�
+			doImportantTaoBaoGoodsUpdateJob();// 娣樺疂閲嶈鍟嗗搧鐨勪俊鎭洿鏂�
 		}
+
 	}
 
 	/**
@@ -647,4 +651,44 @@
 		});
 
 	}
+
+	/**
+	 * 閲嶈鐨勬窐瀹濆晢鍝佷俊鎭洿鏂�
+	 */
+	public void doImportantTaoBaoGoodsUpdateJob() {
+		// 寮�鍚�2涓嚎绋嬪仛鏇存柊
+		for (int i = 0; i < 2; i++)
+			executor.execute(new Runnable() {
+				@Override
+				public void run() {
+					while (true) {
+						Map<String, Long> map = CMQManager.getInstance().consumeTBImpGoodsUpdateMsg(16);
+						if (map != null) {
+							Iterator<String> its = map.keySet().iterator();
+							while (its.hasNext()) {
+								String key = its.next();
+								try {
+									long startTime = System.currentTimeMillis();
+									TaoBaoGoodsBrief goods = TaoKeApiUtil.searchGoodsDetail(map.get(key));
+									// 鏇存柊涓�鏉℃暟鎹渶瑕佺殑鏃堕棿
+									taoBaoGoodsUpdateService.updateTaoBaoGoods(goods);
+									long time = System.currentTimeMillis() - startTime;
+									LogHelper.test("娣樺疂閲嶈鍟嗗搧搴撴洿鏂版椂闂�:" + time);
+								} catch (Exception e) {
+									try {
+										LogHelper.errorDetailInfo(e);
+									} catch (Exception e1) {
+										e1.printStackTrace();
+									}
+								} finally {
+									CMQManager.getInstance().deleteTBImpGoodsUpdateMsg(key);
+								}
+							}
+						}
+					}
+				}
+			});
+
+	}
+
 }

--
Gitblit v1.8.0