From 4c31405418bdd063605f1e5821d99f85be02f23c Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期五, 19 七月 2019 15:54:12 +0800
Subject: [PATCH] Merge branch 'div' of ssh://193.112.35.168:29418/fanli-server into div

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/tlj/UserTaoLiJinOriginServiceImpl.java |   60 ++++++++++++++++++++++++++++++++++++------------------------
 1 files changed, 36 insertions(+), 24 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/tlj/UserTaoLiJinOriginServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/tlj/UserTaoLiJinOriginServiceImpl.java
index 5e8164d..23d9c0f 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/tlj/UserTaoLiJinOriginServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/tlj/UserTaoLiJinOriginServiceImpl.java
@@ -404,31 +404,43 @@
 
 	@Override
 	public void overdueHongBao(Long uid) {
-		// 15澶╁墠杩囨湡
-		Date date = null;
+		if (uid == null) {
+			return;
+		}
+		
+		// 15澶╁墠杩囨湡- 闈炵瓑绾х孩鍖�
 		try {
-			date = DateUtil.reduceDay(14, new Date());
+			Date date = DateUtil.reduceDay(14, new Date());
+			List<UserTaoLiJinOrigin> list = userTaoLiJinOriginMapper.getOverdueTaoLiJin(uid, date);
+			executeOverdueHongBao(uid, date, list);
 		} catch (ParseException e) {
 			e.printStackTrace();
 		}
 		
-		if (date == null) {
-			return;
+		// 30澶╁墠杩囨湡 - 绛夌骇绾㈠寘
+		try {
+			Date date = DateUtil.reduceDay(29, new Date());
+			List<UserTaoLiJinOrigin> list = userTaoLiJinOriginMapper.getOverdueTaoLiJinByRank(uid, date);
+			executeOverdueHongBao(uid, date, list);
+		} catch (ParseException e) {
+			e.printStackTrace();
 		}
-		
-		List<UserTaoLiJinOrigin> list = userTaoLiJinOriginMapper.getOverdueTaoLiJin(uid, date);
+	}
+
+	
+	public void executeOverdueHongBao(Long uid, Date date, List<UserTaoLiJinOrigin> list) {
 		if (list == null || list.size() == 0) {
 			return;
 		}
-		
+
 		BigDecimal total = new BigDecimal(0);
-		for (UserTaoLiJinOrigin userTaoLiJinOrigin: list) {
+		for (UserTaoLiJinOrigin userTaoLiJinOrigin : list) {
 			SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH.mm");
-			String time = sd.format(userTaoLiJinOrigin.getCreateTime());	
-			
+			String time = sd.format(userTaoLiJinOrigin.getCreateTime());
+
 			BigDecimal moneySurplus = userTaoLiJinOrigin.getMoneySurplus();
 			total = MoneyBigDecimalUtil.add(total, moneySurplus);
-			
+
 			String rightsId = null;
 			boolean refund = false;
 			TaoLiJinOriginEnum originEnum = userTaoLiJinOrigin.getOrigin();
@@ -436,13 +448,13 @@
 				refund = true;
 				rightsId = userTaoLiJinOrigin.getRightsId();
 			}
-			
+
 			UserTaoLiJinOrigin origin = new UserTaoLiJinOrigin();
 			origin.setId(userTaoLiJinOrigin.getId());
 			origin.setMoneySurplus(new BigDecimal(0));
 			origin.setUpdateTime(new Date());
 			userTaoLiJinOriginMapper.updateByPrimaryKeySelective(origin);
-			
+
 			if (refund) {
 				UserTaoLiJinReport report = userTaoLiJinReportService.selectByPrimaryKey(rightsId);
 				Date shareTime = null;
@@ -451,17 +463,17 @@
 				} else {
 					shareTime = report.getCreateTime();
 				}
-				
+
 				// 娑堟伅
 				MsgOtherTaoLiJinContentDTO content = new MsgOtherTaoLiJinContentDTO();
 				content.setState("绾㈠寘鏀跺洖");
-				content.setSource("浜嶽"+ sd.format(shareTime) + "]鍒涘缓鐨勫垎浜湭琚鍙栭儴鍒�");
+				content.setSource("浜嶽" + sd.format(shareTime) + "]鍒涘缓鐨勫垎浜湭琚鍙栭儴鍒�");
 				content.setTimeDesc("閫�鍥炰簬" + time);
 				content.setMoney(moneySurplus);
 				content.setReason("鏈瑪閫�鍥炴帹骞跨孩鍖呬粠閫�鍥炴棩璧疯嚦浠婂苟鏈骇鐢熷垎浜褰�");
 				content.setResult("闀挎湡鏈娇鐢ㄦ敹鍥�");
 				userOtherMsgNotificationService.taoLiJinMsg(uid, "濡傛湁鐤戦棶璇疯仈绯讳汉宸ュ鏈�", content);
-				
+
 			} else {
 				// 娑堟伅
 				MsgOtherTaoLiJinContentDTO content = new MsgOtherTaoLiJinContentDTO();
@@ -474,16 +486,16 @@
 				userOtherMsgNotificationService.taoLiJinMsg(uid, "濡傛湁鐤戦棶璇疯仈绯讳汉宸ュ鏈�", content);
 			}
 		}
-		
+
 		// 鐢ㄦ埛鍓╀綑娣樼ぜ閲�
 		UserMoneyExtra userMoneyExtra = userMoneyExtraService.selectByPrimaryKey(uid);
 		if (userMoneyExtra == null || userMoneyExtra.getTlj() == null) {
 			return;
 		}
-		
+
 		UserMoneyExtra updateExtra = new UserMoneyExtra();
 		updateExtra.setUid(uid);
-		
+
 		BigDecimal tljSelf = userMoneyExtra.getTljSelf();
 		if (tljSelf != null && tljSelf.compareTo(new BigDecimal(0)) > 0) { // 鍓╀綑娣樼ぜ閲�-- 鑷喘
 			BigDecimal sub = MoneyBigDecimalUtil.sub(tljSelf, total);
@@ -492,12 +504,11 @@
 			} else {
 				updateExtra.setTljSelf(new BigDecimal(0));
 			}
-		} 
+		}
 		updateExtra.setTlj(MoneyBigDecimalUtil.sub(userMoneyExtra.getTlj(), total));
 		updateExtra.setUpdateTime(new Date());
 		userMoneyExtraService.updateByPrimaryKeySelective(updateExtra);
-		
-		
+
 		// 鎻掑叆鏄庣粏
 		UserTaoLiJinDetail detail = new UserTaoLiJinDetail();
 		detail.setUid(uid);
@@ -507,7 +518,8 @@
 		detail.setCreateTime(new Date());
 		userTaoLiJinDetailService.insertSelective(detail);
 	}
-
+	
+	
 	@Override
 	public List<UserTaoLiJinOrigin> getSurplusLiJin(long uid) {
 		return userTaoLiJinOriginMapper.getSurplusLiJin(uid);

--
Gitblit v1.8.0