From 17e98d7bcc27072f97976d24eb504abb02914891 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期六, 11 四月 2020 09:20:14 +0800
Subject: [PATCH] 消息

---
 fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java |   25 ++++++++++++++++++++-----
 1 files changed, 20 insertions(+), 5 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 751df38..efc0d44 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
@@ -327,7 +327,8 @@
 								try {
 									HongBaoV2 hongbao = map.get(handler);
 									if (hongbao != null) {
-										String key = "hongbao-fanli-" + hongbao.getId();
+										String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.hongBaoFanLi,
+												hongbao.getId() + "");
 										if (StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) {
 											// 澶勭悊涔嬪悗瑕侀殧2灏忔椂鍐嶆杩涜澶勭悊
 											redisManager.cacheCommonString(key, "1", 60 * 60 * 2);
@@ -840,14 +841,28 @@
 	private void fanliGetIntegral(HongBaoV2 hongBaoV2) {
 		if (hongBaoV2 != null && hongBaoV2.getState() == HongBaoV2.STATE_YILINGQU
 				&& hongBaoV2.getMoney().compareTo(new BigDecimal(0)) > 0) {
+			// 鏌ヨ瀵瑰簲鐨勮鍗曞彿
+			Long mainHongBaoId = hongBaoV2.getId();
+			if (hongBaoV2.getParent() != null && hongBaoV2.getParent().getId() != null)
+				mainHongBaoId = hongBaoV2.getParent().getId();
+
+			HongBaoOrder hongbaoOrder = hongBaoOrderService.selectDetailByHongBaoId(mainHongBaoId);
+			if (hongbaoOrder == null || hongbaoOrder.getCommonOrder() == null)
+				return;
+			CommonOrder commonOrder = hongbaoOrder.getCommonOrder();
+
 			if (hongBaoV2.getType() == HongBaoV2.TYPE_ZIGOU) {// 鑷喘璁㈠崟
-				integralGetService.addRebateOrder(hongBaoV2.getUserInfo().getId());
+				integralGetService.addRebateOrder(hongBaoV2.getUserInfo().getId(), commonOrder.getOrderNo(),
+						commonOrder.getSourceType());
 			} else if (hongBaoV2.getType() == HongBaoV2.TYPE_SHARE_GOODS) {// 鍒嗕韩璁㈠崟
-				integralGetService.addShareOrder(hongBaoV2.getUserInfo().getId());
+				integralGetService.addShareOrder(hongBaoV2.getUserInfo().getId(), commonOrder.getOrderNo(),
+						commonOrder.getSourceType());
 			} else if (hongBaoV2.getType() == HongBaoV2.TYPE_YIJI || hongBaoV2.getType() == HongBaoV2.TYPE_SHARE_YIJI) {// 涓�绾ч個璇�
-				integralGetService.addInviteOrderLevelOne(hongBaoV2.getUserInfo().getId());
+				integralGetService.addInviteOrderLevelOne(hongBaoV2.getUserInfo().getId(), commonOrder.getOrderNo(),
+						commonOrder.getSourceType());
 			} else if (hongBaoV2.getType() == HongBaoV2.TYPE_ERJI || hongBaoV2.getType() == HongBaoV2.TYPE_SHARE_ERJI) {// 浜岀骇閭�璇�
-				integralGetService.addInviteOrderLevelTwo(hongBaoV2.getUserInfo().getId());
+				integralGetService.addInviteOrderLevelTwo(hongBaoV2.getUserInfo().getId(), commonOrder.getOrderNo(),
+						commonOrder.getSourceType());
 			}
 		}
 	}

--
Gitblit v1.8.0