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