From b90c2f738f64df608ae9f9277c7a3ab35c46498a Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 16 八月 2019 16:27:32 +0800
Subject: [PATCH] 金币获得事件上传
---
fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java | 46 ++++++++++++++++++++++++++--------------------
1 files changed, 26 insertions(+), 20 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 e9bbe03..9119ec3 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
@@ -656,32 +656,38 @@
* 閲嶈鐨勬窐瀹濆晢鍝佷俊鎭洿鏂�
*/
public void doImportantTaoBaoGoodsUpdateJob() {
- 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 {
- TaoBaoGoodsBrief goods = TaoKeApiUtil.searchGoodsDetail(map.get(key));
- taoBaoGoodsUpdateService.updateTaoBaoGoods(goods);
- } catch (Exception e) {
+ // 寮�鍚�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 {
- LogHelper.errorDetailInfo(e);
- } catch (Exception e1) {
- e1.printStackTrace();
+ 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);
}
- } finally {
- CMQManager.getInstance().deleteTBImpGoodsUpdateMsg(key);
}
}
}
}
- }
- });
+ });
}
--
Gitblit v1.8.0