From be44007f1ffdd4d391fd360dce24a3423e37bcc6 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 15 七月 2019 15:29:11 +0800
Subject: [PATCH] 修复订单异常处理中产生的bug

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java |   65 ++++++++++++++++++++------------
 1 files changed, 41 insertions(+), 24 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 51259e6..8f77d93 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
@@ -143,18 +143,19 @@
 				} else if (!StringUtil.isNullOrEmpty(list.get(0).getRelationId())) {
 					shareOrderMap.put(orderId, list);
 				} else {
+					// 閫氳繃绾㈠寘鏌ヨ
+					CommonOrder commonOrder = commonOrderService
+							.selectBySourceTypeAndTradeId(Constant.SOURCE_TYPE_TAOBAO, list.get(0).getTradeId());
 
-					PidUser pidUser = null;// pidUserMapper.selectByPid(pid);
-					if (pidUser != null && pidUser.getType() == PidUser.TYPE_SHARE_GOODS) {// 鍟嗗搧鍒嗕韩璁㈠崟
-						// List<PidOrder> pidOrderList = new ArrayList<>();
-						// for (TaoBaoOrder order : list) {
-						// pidOrderList.add(TaoBaoOrderUtil.convertToPidOrder(order));
-						// }
-						// sharePidOrderMap.put(orderId, pidOrderList);
-						shareOrderMap.put(orderId, list);
-					} else {// 鏅�氳繑鍒╄鍗�
-						fanliOrderMap.put(orderId, list);
+					if (commonOrder != null) {
+						HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByCommonOrderId(commonOrder.getId());
+						if (hongBaoOrder != null && hongBaoOrder.getHongBaoV2() != null
+								&& hongBaoOrder.getHongBaoV2().getType() == HongBaoV2.TYPE_SHARE_GOODS) {
+							shareOrderMap.put(orderId, list);
+							continue;
+						}
 					}
+					fanliOrderMap.put(orderId, list);
 				}
 			}
 		}
@@ -295,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(
@@ -385,7 +390,7 @@
 			}
 
 			// 绔欏唴淇�+鎺ㄩ��
-			UserInfo user = userInfoMapper.selectByPrimaryKey(uid);
+			UserInfo user = userInfoMapper.selectByPKey(uid);
 			try {
 				userNotificationService.orderFanliRecieved(uid, hongBaoOrder.getCommonOrder().getOrderNo(),
 						userGoodsCount.get(uid), user.getMyHongBao(), money);
@@ -412,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
@@ -827,7 +831,6 @@
 					orderMapper.insertSelective(order);
 					oldOrder = order;
 				} else {
-
 					Long targetUid = null;
 					if (pid.equalsIgnoreCase(TaoBaoConstant.TAOBAO_RELATION_AS_SPECIAL_PID)
 							&& !StringUtil.isNullOrEmpty(orderList.get(0).getRelationId())) {
@@ -924,6 +927,20 @@
 			}
 
 			// 灏氭湭鎵惧埌鍜孭ID瀵瑰簲鐨勭敤鎴�
+			if (uid == null) {
+				// 閫氳繃绾㈠寘鏌ヨ
+				CommonOrder commonOrder = commonOrderService.selectBySourceTypeAndTradeId(Constant.SOURCE_TYPE_TAOBAO,
+						orderList.get(0).getTradeId());
+
+				if (commonOrder != null) {
+					HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByCommonOrderId(commonOrder.getId());
+					if (hongBaoOrder != null && hongBaoOrder.getHongBaoV2() != null
+							&& hongBaoOrder.getHongBaoV2().getType() == HongBaoV2.TYPE_SHARE_GOODS) {
+						uid = hongBaoOrder.getHongBaoV2().getUserInfo().getId();
+					}
+				}
+			}
+
 			if (uid == null)
 				return;
 

--
Gitblit v1.8.0