From 1be32ab61d7ed248f190eead478bdd7f8b83edbe Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 29 七月 2019 18:26:19 +0800
Subject: [PATCH] 添加判断京东/拼多多是否参与推广

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java |   41 ++++++++++++++++++++++-------------------
 1 files changed, 22 insertions(+), 19 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java
index 6ab12bd..3cfc172 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java
@@ -296,16 +296,20 @@
 			LogHelper.error("杩斿埄澶辫触:" + hb1.getId());
 			return;
 		}
-		// 缁存潈涓殑涓嶈繑鍒�
-		List<TaoBaoWeiQuanOrder> taoBaoWeiQuanList = taoBaoWeiQuanOrderMapper
-				.selectListByOrderIdAndState(hongBaoOrder.getCommonOrder().getOrderNo(), "缁存潈鍒涘缓");
-		if (taoBaoWeiQuanList != null && taoBaoWeiQuanList.size() > 0)
-			return;
 
-		taoBaoWeiQuanList = taoBaoWeiQuanOrderMapper
-				.selectListByOrderIdAndState(hongBaoOrder.getCommonOrder().getOrderNo(), "绛夊緟澶勭悊");
-		if (taoBaoWeiQuanList != null && taoBaoWeiQuanList.size() > 0)
-			return;
+		if (hongBaoOrder.getCommonOrder() != null
+				&& hongBaoOrder.getCommonOrder().getSourceType() == Constant.SOURCE_TYPE_TAOBAO) {
+			// 缁存潈涓殑涓嶈繑鍒�
+			List<TaoBaoWeiQuanOrder> taoBaoWeiQuanList = taoBaoWeiQuanOrderMapper
+					.selectListByOrderIdAndState(hongBaoOrder.getCommonOrder().getOrderNo(), "缁存潈鍒涘缓");
+			if (taoBaoWeiQuanList != null && taoBaoWeiQuanList.size() > 0)
+				return;
+
+			taoBaoWeiQuanList = taoBaoWeiQuanOrderMapper
+					.selectListByOrderIdAndState(hongBaoOrder.getCommonOrder().getOrderNo(), "绛夊緟澶勭悊");
+			if (taoBaoWeiQuanList != null && taoBaoWeiQuanList.size() > 0)
+				return;
+		}
 
 		// 鏌ヨ鍚屼竴璁㈠崟鍙风殑绾㈠寘
 		List<CommonOrder> orderList = commonOrderService.listBySourceTypeAndOrderId(
@@ -399,7 +403,7 @@
 			}
 
 			// 鏂扮増閫氱煡
-			userMoneyMsgNotificationService.fanliOrderReceived(uid, hongBaoOrder.getCommonOrder().getOrderNo(),
+			userMoneyMsgNotificationService.fanliOrderReceived(uid, hongBaoOrder.getCommonOrder().getOrderNo(),hongBaoOrder.getCommonOrder().getSourceType(),
 					userGoodsCount.get(uid), money, user.getMyHongBao());
 		}
 		// 閫氱煡鍏嶅崟鍒拌处
@@ -413,9 +417,8 @@
 		if (hongBaoOrder.getCommonOrder().getSettleTime() != null && hongBaoOrder.getCommonOrder().getSettleTime()
 				.getTime() >= TimeUtil.convertToTimeTemp("2018-08-05", "yyyy-MM-dd")) {
 			try {
-
-				taoBaoWeiQuanDrawBackService.doWeiQuanFanli(hongBaoOrder.getCommonOrder().getOrderNo());
-
+				if (hongBaoOrder.getCommonOrder().getSourceType() == Constant.SOURCE_TYPE_TAOBAO)
+					taoBaoWeiQuanDrawBackService.doWeiQuanFanli(hongBaoOrder.getCommonOrder().getOrderNo());
 			} catch (TaoBaoWeiQuanException e) {
 				if (e.getCode() == TaoBaoWeiQuanException.CODE_NEDD_UPDATE_ORDER) {
 					List<TaoBaoOrder> olist = taoBaoOrderService
@@ -454,7 +457,7 @@
 	public void weiQuanOrder(List<TaoBaoWeiQuanOrder> orderList) {
 		if (orderList != null)
 			for (TaoBaoWeiQuanOrder order : orderList) {
-				if (order.getState().equalsIgnoreCase("缁存潈鎴愬姛")) {
+				if (order.getState().contains("缁存潈鎴愬姛")) {
 					CMQManager.getInstance().addWeiQuanOrderMsg(order);
 				}
 			}
@@ -658,7 +661,7 @@
 				long invalidCount = hongBaoV2Mapper.countInviteOrderCountByUidAndSettleTime(uid, CommonOrder.STATE_SX,
 						minDate, maxDate);
 
-				UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createInvite(uid, (int) validCount,
+				UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createInvite(uid,Constant.SOURCE_TYPE_TAOBAO, (int) validCount,
 						(int) weiQuanCount, (int) invalidCount, invitemoney, new Date());
 
 				// 澧炲姞璧勯噾
@@ -683,7 +686,7 @@
 			}
 
 			// 鏂扮増閫氱煡
-			userMoneyMsgNotificationService.inviteOrderReceived(uid, inviteOrders.size(), inviteGoodsCount, invitemoney,
+			userMoneyMsgNotificationService.inviteOrderReceived(uid,Constant.SOURCE_TYPE_TAOBAO, inviteOrders.size(), inviteGoodsCount, invitemoney,
 					userInfoMapper.selectByPKey(uid).getMyHongBao());
 
 			for (String orderId : drawBackOrders)
@@ -757,7 +760,7 @@
 				long invalidCount = commonOrderService.countByUidAndOrderStateWithOrderBalanceTime(uid,
 						CommonOrder.STATE_SX, minDate, maxDate);
 
-				UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createShare(uid, (int) validCount,
+				UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createShare(uid,Constant.SOURCE_TYPE_TAOBAO, (int) validCount,
 						(int) weiQuanCount, (int) invalidCount, sharemoney, new Date());
 				// 娣诲姞璧勯噾
 				userMoneyService.addUserMoney(uid, sharemoney, userMoneyDetail);
@@ -782,7 +785,7 @@
 			}
 
 			// 鏂扮増閫氱煡
-			userMoneyMsgNotificationService.shareOrderReceived(uid, shareOrders.size(), shareGoodsCount, sharemoney,
+			userMoneyMsgNotificationService.shareOrderReceived(uid,Constant.SOURCE_TYPE_TAOBAO, shareOrders.size(), shareGoodsCount, sharemoney,
 					userInfoMapper.selectByPrimaryKey(uid).getMyHongBao());
 
 			for (String orderId : drawBackOrders)
@@ -937,7 +940,7 @@
 					}
 				}
 			}
-			
+
 			if (uid == null)
 				return;
 

--
Gitblit v1.8.0