From fe879975a3e8a0a1aa280fb839e02d159bfbcff8 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 27 八月 2019 18:04:38 +0800
Subject: [PATCH] 金币任务多次获取bug修改

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/msg/UserMoneyMsgNotificationServiceImpl.java |  196 +++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 158 insertions(+), 38 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/msg/UserMoneyMsgNotificationServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/msg/UserMoneyMsgNotificationServiceImpl.java
index 96ab050..accdf62 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/msg/UserMoneyMsgNotificationServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/msg/UserMoneyMsgNotificationServiceImpl.java
@@ -1,17 +1,23 @@
 package com.yeshi.fanli.service.impl.msg;
 
 import java.math.BigDecimal;
+import java.util.Date;
 
 import javax.annotation.Resource;
 
 import org.springframework.stereotype.Service;
 
+import com.yeshi.fanli.dto.push.PushContentDTO;
 import com.yeshi.fanli.entity.bus.msg.MsgMoneyDetail;
 import com.yeshi.fanli.entity.bus.user.AlipayAccountValidNormalHistory;
 import com.yeshi.fanli.entity.bus.user.Extract;
+import com.yeshi.fanli.entity.config.push.PushMsgFactory;
+import com.yeshi.fanli.exception.PushException;
 import com.yeshi.fanli.exception.msg.MsgMoneyDetailException;
 import com.yeshi.fanli.service.inter.msg.MsgMoneyDetailService;
 import com.yeshi.fanli.service.inter.msg.UserMoneyMsgNotificationService;
+import com.yeshi.fanli.service.inter.push.PushService;
+import com.yeshi.fanli.util.Constant;
 import com.yeshi.fanli.util.factory.msg.MsgMoneyDetailFactory;
 
 @Service
@@ -19,6 +25,8 @@
 
 	@Resource
 	private MsgMoneyDetailService msgMoneyDetailService;
+	@Resource
+	private PushService pushService;
 
 	@Override
 	public void extractApplay(Extract extract) {
@@ -41,6 +49,15 @@
 			e.printStackTrace();
 		}
 
+		PushContentDTO dto = PushMsgFactory.createmoneyExtractFail(new Date(extract.getExtractTime()),
+				extract.getMoney(), extract.getAccount());
+		try {
+			pushService.pushZNX(extract.getUserInfo().getId(), dto.getTitle(), dto.getContent(), null, null);
+		} catch (NumberFormatException e) {
+			e.printStackTrace();
+		} catch (PushException e) {
+			e.printStackTrace();
+		}
 	}
 
 	@Override
@@ -52,65 +69,61 @@
 		} catch (MsgMoneyDetailException e) {
 			e.printStackTrace();
 		}
-
+		PushContentDTO dto = PushMsgFactory.createMoneyExtractSuccess(new Date(extract.getExtractTime()),
+				extract.getMoney(), extract.getAccount());
+		try {
+			pushService.pushZNX(extract.getUserInfo().getId(), dto.getTitle(), dto.getContent(), null, null);
+		} catch (NumberFormatException e) {
+			e.printStackTrace();
+		} catch (PushException e) {
+			e.printStackTrace();
+		}
 	}
 
 	@Override
 	public void alipayAccountValid(AlipayAccountValidNormalHistory history) {
 		MsgMoneyDetail detail = MsgMoneyDetailFactory.createAlipayAccountValidMsg(history, history.getUid(),
-				"閲嶅簡灏忓奖璁扮鎶�鏈夐檺鍏徃", new BigDecimal("0.1"), null);
-		try {
-			msgMoneyDetailService.addMsgMoneyDetail(detail);
-		} catch (MsgMoneyDetailException e) {
-			e.printStackTrace();
-		}
-	}
-
-	@Override
-	public void fanliOrderReceived(Long uid, String orderId, int goodsCount, BigDecimal money, BigDecimal balance) {
-		MsgMoneyDetail detail = MsgMoneyDetailFactory.createFailiMsg(money, balance, orderId, goodsCount, uid, null);
+				Constant.systemCommonConfig.getProjectChineseName(), new BigDecimal("0.1"), null);
 		try {
 			msgMoneyDetailService.addMsgMoneyDetail(detail);
 		} catch (MsgMoneyDetailException e) {
 			e.printStackTrace();
 		}
 
-	}
-
-	@Override
-	public void fanliOrderWeiQuan(Long uid, String orderId, BigDecimal money, BigDecimal balance) {
-		MsgMoneyDetail detail = MsgMoneyDetailFactory.createFailiWeiQuanMsg(uid, orderId, money, balance, null);
+		PushContentDTO dto = PushMsgFactory.createAlipayAccountValid(history.getAccount(), new BigDecimal("0.1"));
 		try {
-			msgMoneyDetailService.addMsgMoneyDetail(detail);
-		} catch (MsgMoneyDetailException e) {
+			pushService.pushZNX(history.getUid(), dto.getTitle(), dto.getContent(), null, null);
+		} catch (NumberFormatException e) {
+			e.printStackTrace();
+		} catch (PushException e) {
 			e.printStackTrace();
 		}
 	}
 
 	@Override
-	public void shareOrderReceived(Long uid, int orderCount, int goodsCount, BigDecimal money, BigDecimal balance) {
-		MsgMoneyDetail detail = MsgMoneyDetailFactory.createShareMsg(money, balance, orderCount, goodsCount, uid, null);
-		try {
-			msgMoneyDetailService.addMsgMoneyDetail(detail);
-		} catch (MsgMoneyDetailException e) {
-			e.printStackTrace();
-		}
-	}
-
-	@Override
-	public void shareOrderWeiQuan(Long uid, String orderId, BigDecimal money, BigDecimal balance) {
-		MsgMoneyDetail detail = MsgMoneyDetailFactory.createShareWeiQuanMsg(uid, orderId, money, balance, null);
+	public void fanliOrderReceived(Long uid, String orderId, int orderType, int goodsCount, BigDecimal money,
+			BigDecimal balance) {
+		MsgMoneyDetail detail = MsgMoneyDetailFactory.createFailiMsg(money, balance, orderId, orderType, goodsCount,
+				uid, null);
 		try {
 			msgMoneyDetailService.addMsgMoneyDetail(detail);
 		} catch (MsgMoneyDetailException e) {
 			e.printStackTrace();
 		}
 
+		PushContentDTO dto = PushMsgFactory.createMoneyFanliRecieved(orderType, orderId, money);
+		try {
+			pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);
+		} catch (NumberFormatException e) {
+			e.printStackTrace();
+		} catch (PushException e) {
+			e.printStackTrace();
+		}
 	}
 
 	@Override
-	public void inviteOrderReceived(Long uid, int orderCount, int goodsCount, BigDecimal money, BigDecimal balance) {
-		MsgMoneyDetail detail = MsgMoneyDetailFactory.createInviteMsg(money, balance, orderCount, goodsCount, uid,
+	public void fanliOrderWeiQuan(Long uid, String orderId, int orderType, BigDecimal money, BigDecimal balance) {
+		MsgMoneyDetail detail = MsgMoneyDetailFactory.createFailiWeiQuanMsg(uid, orderId, orderType, money, balance,
 				null);
 		try {
 			msgMoneyDetailService.addMsgMoneyDetail(detail);
@@ -118,28 +131,135 @@
 			e.printStackTrace();
 		}
 
+		// TODO 闇�瑕佷紶鍏ユ槸鍚﹂儴鍒嗙淮鏉�
+		PushContentDTO dto = PushMsgFactory.createMoneyOrderFanLiWeiquan(orderType, orderId, false, money);
+		try {
+			pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);
+		} catch (NumberFormatException e) {
+			e.printStackTrace();
+		} catch (PushException e) {
+			e.printStackTrace();
+		}
 	}
 
 	@Override
-	public void inviteOrderWeiQuan(Long uid, String orderId, BigDecimal money, BigDecimal balance) {
-		MsgMoneyDetail detail = MsgMoneyDetailFactory.createInviteWeiQuanMsg(uid, orderId, money, balance, null);
+	public void shareOrderReceived(Long uid, int orderType, int orderCount, int goodsCount, BigDecimal money,
+			BigDecimal balance) {
+		MsgMoneyDetail detail = MsgMoneyDetailFactory.createShareMsg(money, balance, orderType, orderCount, goodsCount,
+				uid, null);
+		try {
+			msgMoneyDetailService.addMsgMoneyDetail(detail);
+		} catch (MsgMoneyDetailException e) {
+			e.printStackTrace();
+		}
+		PushContentDTO dto = PushMsgFactory.createMoneyShareRecieved(orderType, money);
+		try {
+			pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);
+		} catch (NumberFormatException e) {
+			e.printStackTrace();
+		} catch (PushException e) {
+			e.printStackTrace();
+		}
+	}
+
+	@Override
+	public void shareOrderWeiQuan(Long uid, String orderId, int orderType, BigDecimal money, BigDecimal balance) {
+		MsgMoneyDetail detail = MsgMoneyDetailFactory.createShareWeiQuanMsg(uid, orderId, orderType, money, balance,
+				null);
 		try {
 			msgMoneyDetailService.addMsgMoneyDetail(detail);
 		} catch (MsgMoneyDetailException e) {
 			e.printStackTrace();
 		}
 
+		PushContentDTO dto = PushMsgFactory.createMoneyOrderShareOrInviteWeiquan(orderType, orderId, false, money);
+		try {
+			pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);
+		} catch (NumberFormatException e) {
+			e.printStackTrace();
+		} catch (PushException e) {
+			e.printStackTrace();
+		}
+
 	}
 
 	@Override
-	public void orderReward(Long uid, String orderId, BigDecimal money, BigDecimal balance) {
-		MsgMoneyDetail detail = MsgMoneyDetailFactory.createOrderRewardMsg(uid, orderId, money, balance, null);
+	public void inviteOrderReceived(Long uid, int orderType, int orderCount, int goodsCount, BigDecimal money,
+			BigDecimal balance) {
+		MsgMoneyDetail detail = MsgMoneyDetailFactory.createInviteMsg(money, balance, orderType, orderCount, goodsCount,
+				uid, null);
 		try {
 			msgMoneyDetailService.addMsgMoneyDetail(detail);
 		} catch (MsgMoneyDetailException e) {
 			e.printStackTrace();
 		}
-		
+
+		PushContentDTO dto = PushMsgFactory.createMoneyInviteRecieved(orderType, money);
+		try {
+			pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);
+		} catch (NumberFormatException e) {
+			e.printStackTrace();
+		} catch (PushException e) {
+			e.printStackTrace();
+		}
+	}
+
+	@Override
+	public void inviteOrderWeiQuan(Long uid, String orderId, int orderType, BigDecimal money, BigDecimal balance) {
+		MsgMoneyDetail detail = MsgMoneyDetailFactory.createInviteWeiQuanMsg(uid, orderId, orderType, money, balance,
+				null);
+		try {
+			msgMoneyDetailService.addMsgMoneyDetail(detail);
+		} catch (MsgMoneyDetailException e) {
+			e.printStackTrace();
+		}
+		PushContentDTO dto = PushMsgFactory.createMoneyOrderShareOrInviteWeiquan(orderType, orderId, false, money);
+		try {
+			pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);
+		} catch (NumberFormatException e) {
+			e.printStackTrace();
+		} catch (PushException e) {
+			e.printStackTrace();
+		}
+	}
+
+	@Override
+	public void orderReward(Long uid, String orderId, int orderType, BigDecimal money, BigDecimal balance) {
+		MsgMoneyDetail detail = MsgMoneyDetailFactory.createOrderRewardMsg(uid, orderId, orderType, money, balance,
+				null);
+		try {
+			msgMoneyDetailService.addMsgMoneyDetail(detail);
+		} catch (MsgMoneyDetailException e) {
+			e.printStackTrace();
+		}
+
+		PushContentDTO dto = PushMsgFactory.createMoneySystemReward("浣跨敤杩斿埄濂栧姳鍒�", money);
+		try {
+			pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);
+		} catch (NumberFormatException e) {
+			e.printStackTrace();
+		} catch (PushException e) {
+			e.printStackTrace();
+		}
+	}
+
+	@Override
+	public void systemEqualize(Long uid, String reason, BigDecimal money, BigDecimal balance) {
+		MsgMoneyDetail detail = MsgMoneyDetailFactory.createSystemEqualizeMsg(uid, reason, money, balance, null);
+		try {
+			msgMoneyDetailService.addMsgMoneyDetail(detail);
+		} catch (MsgMoneyDetailException e) {
+			e.printStackTrace();
+		}
+
+		PushContentDTO dto = PushMsgFactory.createMoneySystemCompensate(reason, money);
+		try {
+			pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);
+		} catch (NumberFormatException e) {
+			e.printStackTrace();
+		} catch (PushException e) {
+			e.printStackTrace();
+		}
 	}
 
 }

--
Gitblit v1.8.0