From 8974f56bbf256982b32b65f731d13815cddd17ed Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期三, 29 五月 2019 18:02:18 +0800
Subject: [PATCH] 限时秒杀
---
fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java | 33 +++++++--------------------------
1 files changed, 7 insertions(+), 26 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 f80adc8..2d9a8e4 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
@@ -1,7 +1,6 @@
package com.yeshi.fanli.util;
import java.math.BigDecimal;
-import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
@@ -116,9 +115,7 @@
doThreeSaleUserCouponJob();// 澶勭悊閭�璇烽槦鍒�
doUpdateGoodsJob();
doUserMoneyDebtJob();// 鍊哄姟鍋胯繕
- } else if (!Constant.IS_TEST) {
initScheduler();// 鍚姩瀹氭椂浠诲姟
- //
}
}
@@ -387,43 +384,27 @@
boutiqueAutoRuleService.startScheduler();
}
+
+ /**
+ * 鏇存柊绮鹃�夊簱鍟嗗搧
+ */
public void doUpdateGoodsJob() {
-
- // 閲囩敤4涓嚎绋嬪仛鏇存柊
- for (int i = 0; i < 4; i++)
+ for (int i = 0; i < 1; i++)
executor.execute(new Runnable() {
@Override
public void run() {
-
while (true) {
try {
-
Map<String, Long> map = CMQManager.getInstance().consumeNeedUpdateTaoBaoGoodsIdMsg(16);
-
if (map != null) {
-
Iterator<String> its = map.keySet().iterator();
while (its.hasNext()) {
-
- String key = its.next();
- try {
- Long goodsId = map.get(key);
- List<Long> list = new ArrayList<>();
- list.add(goodsId);
- qualityFactoryService.updateGoodsFactory(list);
- CMQManager.getInstance().deleteNeedUpdateTaoBaoGoodsIdMsg(key);
- } catch (Exception e) {
- try {
- LogHelper.errorDetailInfo(e);
- } catch (Exception e1) {
- e1.printStackTrace();
- }
- }
+ qualityFactoryService.updateQualityGoods(map.get(its.next()));
+ CMQManager.getInstance().deleteNeedUpdateTaoBaoGoodsIdMsg(its.next());
}
}
} catch (Exception e) {
LogHelper.error("鏇存柊鍟嗗搧鍑洪敊:" + e.getMessage());
-
}
}
}
--
Gitblit v1.8.0