From 8e30aa7c1f0384f09278699318b4902b815b42a7 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期五, 26 四月 2019 18:01:25 +0800 Subject: [PATCH] 维权返利初步修改,拼多多初步增加 --- fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java | 14 +++++++++++++- 1 files changed, 13 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 ec535c2..d52222a 100644 --- a/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java +++ b/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java @@ -33,6 +33,7 @@ import com.yeshi.fanli.service.inter.user.ExtractService; import com.yeshi.fanli.service.inter.user.UserInfoService; import com.yeshi.fanli.service.inter.user.UserSystemCouponService; +import com.yeshi.fanli.util.cmq.ThreeSaleCMQManager; /** * 绯荤粺鍒濆鍖� @@ -75,6 +76,9 @@ @Resource private TaoBaoOrderService taoBaoOrderService; + + @Resource + private RedisManager redisManager; private static boolean isInited = false; @@ -215,7 +219,15 @@ while (its.hasNext()) { String handler = its.next(); try { - orderProcessService.fanli(map.get(handler)); + HongBaoV2 hongbao = map.get(handler); + if (hongbao != null) { + String key = "hongbao-fanli-" + hongbao.getId(); + if (StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) { + // 澶勭悊涔嬪悗瑕侀殧2灏忔椂鍐嶆杩涜澶勭悊 + redisManager.cacheCommonString(key, "1", 60 * 60 * 2); + orderProcessService.fanli(map.get(handler)); + } + } CMQManager.getInstance().deleteFanLiMsgNew(handler); } catch (TaoBaoWeiQuanException e) { try { -- Gitblit v1.8.0