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