From d960fdbfe07a65cb80ccb764bfb15ce78ebfd84a Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期五, 10 四月 2020 18:21:04 +0800 Subject: [PATCH] 消息修改 --- fanli/src/main/java/com/yeshi/fanli/service/impl/money/msg/UserMoneyMsgNotificationServiceImpl.java | 152 ++++++++++++++++++++++++++++++++------------------ 1 files changed, 98 insertions(+), 54 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/money/msg/UserMoneyMsgNotificationServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/money/msg/UserMoneyMsgNotificationServiceImpl.java index 3b8be1c..76559b3 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/money/msg/UserMoneyMsgNotificationServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/money/msg/UserMoneyMsgNotificationServiceImpl.java @@ -9,6 +9,7 @@ import org.springframework.stereotype.Service; import com.yeshi.fanli.dto.push.PushContentDTO; +import com.yeshi.fanli.entity.bus.msg.MsgExtra; import com.yeshi.fanli.entity.bus.msg.MsgMoneyDetail; import com.yeshi.fanli.entity.bus.msg.MsgMoneyDetail.MsgTypeMoneyTypeEnum; import com.yeshi.fanli.entity.bus.user.AlipayAccountValidNormalHistory; @@ -20,6 +21,7 @@ import com.yeshi.fanli.exception.push.PushException; import com.yeshi.fanli.service.inter.money.msg.MsgMoneyDetailService; import com.yeshi.fanli.service.inter.money.msg.UserMoneyMsgNotificationService; +import com.yeshi.fanli.service.inter.msg.MsgExtraService; import com.yeshi.fanli.service.inter.push.PushService; import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.factory.msg.MsgMoneyDetailFactory; @@ -31,35 +33,32 @@ private MsgMoneyDetailService msgMoneyDetailService; @Resource private PushService pushService; + + @Resource + private MsgExtraService msgExtraService; @Override public void extractApplay(Extract extract) { - MsgMoneyDetail detail = MsgMoneyDetailFactory.createExtractApplyMsg(extract, extract.getUserInfo().getId(), - null); + MsgMoneyDetail detail = MsgMoneyDetailFactory.createExtractMsg("浜哄伐瀹℃牳涓�", extract.getUserInfo().getId(), + extract, null, null); try { msgMoneyDetailService.addMsgMoneyDetail(detail); + // 娑堟伅鍐呭 + msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } catch (MsgMoneyDetailException e) { e.printStackTrace(); } } - @Async - @Override - public void extractAuto(ExtractWeiXinRecord extractRecord, String stateDesc, String desc, String beiZhu) { - MsgMoneyDetail detail = MsgMoneyDetailFactory.createExtractAutoMsg(extractRecord, stateDesc, desc, beiZhu); - try { - msgMoneyDetailService.addMsgMoneyDetail(detail); - } catch (MsgMoneyDetailException e) { - e.printStackTrace(); - } - } @Override - public void extractFail(Extract extract, String stateDesc) { - MsgMoneyDetail detail = MsgMoneyDetailFactory.createExtractFailMsg(extract, extract.getUserInfo().getId(), - stateDesc); + public void extractFail(Extract extract, String reason) { + MsgMoneyDetail detail = MsgMoneyDetailFactory.createExtractMsg("鎻愮幇澶辫触", extract.getUserInfo().getId(), + extract, reason, null); try { msgMoneyDetailService.addMsgMoneyDetail(detail); + // 娑堟伅鍐呭 + msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } catch (MsgMoneyDetailException e) { e.printStackTrace(); } @@ -76,11 +75,13 @@ } @Override - public void extractSuccess(Extract extract) { - MsgMoneyDetail detail = MsgMoneyDetailFactory.createExtractSuccessMsg(extract, extract.getUserInfo().getId(), - null); + public void extractSuccess(Extract extract, String alipayNo) { + MsgMoneyDetail detail = MsgMoneyDetailFactory.createExtractMsg("鎻愮幇鎴愬姛", extract.getUserInfo().getId(), + extract, null, alipayNo); try { msgMoneyDetailService.addMsgMoneyDetail(detail); + // 娑堟伅鍐呭 + msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } catch (MsgMoneyDetailException e) { e.printStackTrace(); } @@ -96,11 +97,13 @@ } @Override - public void alipayAccountValid(AlipayAccountValidNormalHistory history) { + public void alipayAccountValid(AlipayAccountValidNormalHistory history, String limitDay, boolean change) { MsgMoneyDetail detail = MsgMoneyDetailFactory.createAlipayAccountValidMsg(history, history.getUid(), - Constant.systemCommonConfig.getProjectChineseName(), new BigDecimal("0.1"), null); + Constant.systemCommonConfig.getProjectChineseName(), new BigDecimal("0.1"), limitDay, change); try { msgMoneyDetailService.addMsgMoneyDetail(detail); + // 娑堟伅鍐呭 + msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } catch (MsgMoneyDetailException e) { e.printStackTrace(); } @@ -115,13 +118,30 @@ } } + @Override - 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, "鑻ラ渶鍐嶈繑璇蜂娇鐢ㄨ繑鍒╁鍔卞埜"); + public void alipayAccountValidFail(AlipayAccountValidNormalHistory history, int limitDay, boolean change) { + MsgMoneyDetail detail = MsgMoneyDetailFactory.createAlipayAccountValidFail(history, history.getUid(), + Constant.systemCommonConfig.getProjectChineseName(), new BigDecimal("0.1"), limitDay, change); try { msgMoneyDetailService.addMsgMoneyDetail(detail); + // 娑堟伅鍐呭 + msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); + } catch (MsgMoneyDetailException e) { + e.printStackTrace(); + } + } + + + @Override + public void fanliOrderReceived(Long uid, String orderId, int orderType, int goodsCount, BigDecimal money, + BigDecimal balance, Date downTime) { + MsgMoneyDetail detail = MsgMoneyDetailFactory.createOrderReceivedMsg(money, balance, orderId, orderType, goodsCount, + uid, Constant.TYPE_REBATE, downTime, false); + try { + msgMoneyDetailService.addMsgMoneyDetail(detail); + // 娑堟伅鍐呭 + msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } catch (MsgMoneyDetailException e) { e.printStackTrace(); } @@ -137,11 +157,14 @@ } @Override - public void fanliOrderWeiQuan(Long uid, String orderId, int orderType, BigDecimal money, BigDecimal balance) { - MsgMoneyDetail detail = MsgMoneyDetailFactory.createFailiWeiQuanMsg(uid, orderId, orderType, money, balance, - null); + public void fanliOrderWeiQuan(Long uid, String orderId, int orderType, BigDecimal money, BigDecimal fanliMoney, + int goodsCount, Date downTime) { + MsgMoneyDetail detail = MsgMoneyDetailFactory.createOrderWeiQuanMsg(uid, orderId, orderType, money, fanliMoney, + goodsCount, downTime, Constant.TYPE_REBATE); try { msgMoneyDetailService.addMsgMoneyDetail(detail); + // 娑堟伅鍐呭 + msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } catch (MsgMoneyDetailException e) { e.printStackTrace(); } @@ -159,14 +182,17 @@ @Override 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); + BigDecimal balance, String orderId, Date downTime) { + MsgMoneyDetail detail = MsgMoneyDetailFactory.createOrderReceivedMsg(money, balance, orderId, orderType, goodsCount, + uid, Constant.TYPE_SHAER, downTime, false); try { msgMoneyDetailService.addMsgMoneyDetail(detail); + // 娑堟伅鍐呭 + msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } catch (MsgMoneyDetailException e) { e.printStackTrace(); } + PushContentDTO dto = PushMsgFactory.createMoneyShareRecieved(orderType, money); try { pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null); @@ -178,11 +204,14 @@ } @Override - public void shareOrderWeiQuan(Long uid, String orderId, int orderType, BigDecimal money, BigDecimal balance) { - MsgMoneyDetail detail = MsgMoneyDetailFactory.createShareWeiQuanMsg(uid, orderId, orderType, money, balance, - null); + public void shareOrderWeiQuan(Long uid, String orderId, int orderType, BigDecimal money, BigDecimal fanliMoney, + int goodsCount, Date downTime) { + MsgMoneyDetail detail = MsgMoneyDetailFactory.createOrderWeiQuanMsg(uid, orderId, orderType, money, fanliMoney, + goodsCount, downTime, Constant.TYPE_SHAER); try { msgMoneyDetailService.addMsgMoneyDetail(detail); + // 娑堟伅鍐呭 + msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } catch (MsgMoneyDetailException e) { e.printStackTrace(); } @@ -195,30 +224,31 @@ } catch (PushException e) { e.printStackTrace(); } - } @Override 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(); - } +// MsgMoneyDetail detail = MsgMoneyDetailFactory.createInviteReceivedMsg(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, @@ -286,7 +316,7 @@ e.printStackTrace(); } } - + @Override public void redPackMsg(Long uid, MsgTypeMoneyTypeEnum type, String content, String beiZhu) { MsgMoneyDetail detail = MsgMoneyDetailFactory.createRedPackMsg(uid, type, content, beiZhu); @@ -296,9 +326,9 @@ e.printStackTrace(); } } - + @Override - public void teamRedPackRewardMsg(Long uid, MsgTypeMoneyTypeEnum type,BigDecimal money, String stateDesc, + public void teamRedPackRewardMsg(Long uid, MsgTypeMoneyTypeEnum type, BigDecimal money, String stateDesc, String content) { MsgMoneyDetail detail = new MsgMoneyDetail(); detail.setRead(false); @@ -318,7 +348,8 @@ @Override public void inviteOrderSubSidy(Long uid, Date date, String from, BigDecimal money, BigDecimal balance) { - MsgMoneyDetail detail = MsgMoneyDetailFactory.createInviteOrderSubSidyMsg(uid, date, from, money, balance, null); + MsgMoneyDetail detail = MsgMoneyDetailFactory.createInviteOrderSubSidyMsg(uid, date, from, money, balance, + null); try { msgMoneyDetailService.addMsgMoneyDetail(detail); } catch (MsgMoneyDetailException e) { @@ -326,4 +357,17 @@ } } + @Override + public void teamReceive(Long uid, BigDecimal money, BigDecimal balance, Date receivedDate) { + MsgMoneyDetail detail = MsgMoneyDetailFactory.createTeamReceivedMsg(uid, money, balance, receivedDate); + try { + msgMoneyDetailService.addMsgMoneyDetail(detail); + // 娑堟伅鍐呭 + msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); + } catch (MsgMoneyDetailException e) { + e.printStackTrace(); + } + } + + } -- Gitblit v1.8.0