From 733281fcb5f1ab01e1196b542b7e07b49b3e44c4 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 25 十月 2019 17:02:55 +0800
Subject: [PATCH] 订单消息,返利消息,返利券使用,邀请订单补贴

---
 fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java |   24 ++++++++++++++++++++++--
 1 files changed, 22 insertions(+), 2 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 c6543ec..4c17f81 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
@@ -743,6 +743,12 @@
 								HongBaoV2 hongBaoV2 = hongBaoV2Service.selectByPrimaryKey(hongBaoId);
 								if (hongBaoV2 != null && hongBaoV2.getState() == HongBaoV2.STATE_YILINGQU
 										&& hongBaoV2.getMoney().compareTo(new BigDecimal(0)) > 0) {
+									// 鍒拌处閫侀噾甯�
+									fanliGetIntegral(hongBaoV2);
+									HongBaoRecieveCMQManager.getInstance()
+											.deleteQueueMsg(HongBaoRecieveCMQManager.QUEUE_INTEGRAL, key);
+									
+									//杩斿埄涓嶈冻0.01鍏冮�侀噾甯�
 									if (hongBaoV2.getType() == HongBaoV2.TYPE_ZIGOU) {// 鑷喘
 										// 鍒ゆ柇鏄惁涓鸿鐢ㄦ埛鐨勯绗旂孩鍖�
 										List<Integer> typeList = new ArrayList<>();
@@ -876,8 +882,7 @@
 										}
 									}
 								}
-								HongBaoRecieveCMQManager.getInstance()
-										.deleteQueueMsg(HongBaoRecieveCMQManager.QUEUE_INTEGRAL, key);
+
 							} catch (Exception e) {
 								try {
 									LogHelper.errorDetailInfo(e);
@@ -894,6 +899,21 @@
 		});
 	}
 
+	private void fanliGetIntegral(HongBaoV2 hongBaoV2) {
+		if (hongBaoV2 != null && hongBaoV2.getState() == HongBaoV2.STATE_YILINGQU
+				&& hongBaoV2.getMoney().compareTo(new BigDecimal(0)) > 0) {
+			if (hongBaoV2.getType() == HongBaoV2.TYPE_ZIGOU) {// 鑷喘璁㈠崟
+				integralGetService.addRebateOrder(hongBaoV2.getUserInfo().getId());
+			} else if (hongBaoV2.getType() == HongBaoV2.TYPE_SHARE_GOODS) {// 鍒嗕韩璁㈠崟
+				integralGetService.addShareOrder(hongBaoV2.getUserInfo().getId());
+			} else if (hongBaoV2.getType() == HongBaoV2.TYPE_YIJI || hongBaoV2.getType() == HongBaoV2.TYPE_SHARE_YIJI) {// 涓�绾ч個璇�
+				integralGetService.addInviteOrderLevelOne(hongBaoV2.getUserInfo().getId());
+			} else if (hongBaoV2.getType() == HongBaoV2.TYPE_ERJI || hongBaoV2.getType() == HongBaoV2.TYPE_SHARE_ERJI) {// 浜岀骇閭�璇�
+				integralGetService.addInviteOrderLevelTwo(hongBaoV2.getUserInfo().getId());
+			}
+		}
+	}
+
 	private boolean isFirstValidOrder(String orderId, int sourceType, Long uid) {
 		CommonOrder commonOrder = commonOrderService.selectLatestValidByUid(uid);
 		if (commonOrder != null && commonOrder.getOrderNo().equalsIgnoreCase(orderId)

--
Gitblit v1.8.0