From a5bc9c4e52f98032b287a42fd243c2ffcb7d58f6 Mon Sep 17 00:00:00 2001 From: yujian <yujian@163.com> Date: 星期一, 13 四月 2020 09:52:16 +0800 Subject: [PATCH] 消息 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/UserAccountMsgNotificationServiceImpl.java | 178 ++++++++++++++++++++-------------------------------------- 1 files changed, 62 insertions(+), 116 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/UserAccountMsgNotificationServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/UserAccountMsgNotificationServiceImpl.java index b156b9f..0306633 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/UserAccountMsgNotificationServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/UserAccountMsgNotificationServiceImpl.java @@ -3,6 +3,7 @@ import javax.annotation.Resource; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import com.yeshi.fanli.entity.bus.msg.MsgAccountDetail; import com.yeshi.fanli.entity.bus.msg.MsgExtra; @@ -22,32 +23,72 @@ private MsgExtraService msgExtraService; @Override + @Transactional(rollbackFor = Exception.class) public void bindingSuccess(Long uid, int type) { - MsgAccountDetail detail = MsgAccountDetailFactory.createBindSuccess(uid, type, MsgAccountDetailFactory.WAY_BIND); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - // 娑堟伅鍐呭 - msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } + saveDetail(MsgAccountDetailFactory.createBindSuccess(uid, type, MsgAccountDetailFactory.WAY_BIND)); } @Override + @Transactional(rollbackFor = Exception.class) public void unBindingSuccess(Long uid, int type) { - MsgAccountDetail detail = MsgAccountDetailFactory.createBindSuccess(uid, type, MsgAccountDetailFactory.WAY_UNBIND); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - // 娑堟伅鍐呭 - msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } + saveDetail(MsgAccountDetailFactory.createBindSuccess(uid, type, MsgAccountDetailFactory.WAY_UNBIND)); } @Override + @Transactional(rollbackFor = Exception.class) public void changeBindingSuccess(Long uid, int type) { - MsgAccountDetail detail = MsgAccountDetailFactory.createBindSuccess(uid, type, MsgAccountDetailFactory.WAY_CHANGE); + saveDetail(MsgAccountDetailFactory.createBindSuccess(uid, type, MsgAccountDetailFactory.WAY_CHANGE)); + } + + + @Override + @Transactional(rollbackFor = Exception.class) + public void taoBaoAuthFail(Long uid, String taoBaoNickName, String reason) { + saveDetail(MsgAccountDetailFactory.createBindFail(uid, MsgAccountDetailFactory.TYPE_TB, + MsgAccountDetailFactory.WAY_CHANGE, reason)); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public void createChangeInviteCode(Long uid, String oldCode, String newCode) { + saveDetail(MsgAccountDetailFactory.createChangeInviteCode(uid, oldCode, newCode)); + } + + + @Override + @Transactional(rollbackFor = Exception.class) + public void vipPreUpgrade(Long uid, String originalName, String upName, int days, long targetNum1, Long targetNum2,Integer type) { + saveDetail( MsgAccountDetailFactory.vipPreUpgrade(uid, originalName, upName, days, targetNum1, + targetNum2, type, null)); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public void vipUpgradeSuccess(Long uid, int days) { + saveDetail(MsgAccountDetailFactory.vipUpgradeSuccess(uid, days)); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public void vipUpgradeFail(Long uid, String reason) { + saveDetail(MsgAccountDetailFactory.vipUpgradeFail(uid, reason)); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public void teacherInvite(Long uid, String nickname,String kefuName, String kefuWX) { + saveDetail(MsgAccountDetailFactory.teacherInvite(uid, nickname, kefuName, kefuWX)); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public void teacherSuccess(Long uid, int days, String kefuName, String kefuWX) { + saveDetail(MsgAccountDetailFactory.teacherSuccess(uid, days, kefuName, kefuWX)); + } + + + @Transactional(rollbackFor = Exception.class) + private void saveDetail(MsgAccountDetail detail) { try { msgAccountDetailService.addMsgAccountDetail(detail); // 娑堟伅鍐呭 @@ -59,108 +100,13 @@ @Override public void connectSuccess(Long uid, Long lessUid) { - MsgAccountDetail detail = MsgAccountDetailFactory.createConnectAccount(uid, lessUid); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } + // TODO Auto-generated method stub + } @Override public void userRank(Long uid, String orderType, int orderCount, String rankName) { - MsgAccountDetail detail = MsgAccountDetailFactory.createUserRank(uid, orderType, orderCount, rankName); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } - } - - @Override - public void taoBaoAuthFail(Long uid, String taoBaoNickName, String reason) { - MsgAccountDetail detail = MsgAccountDetailFactory.createBindFail(uid, MsgAccountDetailFactory.TYPE_TB, - MsgAccountDetailFactory.WAY_CHANGE, reason); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - // 娑堟伅鍐呭 - msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } - } - - @Override - public void createChangeInviteCode(Long uid, String oldCode, String newCode) { - MsgAccountDetail detail = MsgAccountDetailFactory.createChangeInviteCode(uid, oldCode, newCode); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - // 娑堟伅鍐呭 - msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } - } - - - @Override - public void vipPreUpgrade(Long uid, String originalName, String upName, int days, long targetNum1, Long targetNum2,Integer type) { - MsgAccountDetail detail = MsgAccountDetailFactory.vipPreUpgrade(uid, originalName, upName, days, targetNum1, - targetNum2, type, null); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - // 娑堟伅鍐呭 - msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } - } - - @Override - public void vipUpgradeSuccess(Long uid, int days) { - MsgAccountDetail detail = MsgAccountDetailFactory.vipUpgradeSuccess(uid, days); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - // 娑堟伅鍐呭 - msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } - } - - @Override - public void vipUpgradeFail(Long uid, String reason) { - MsgAccountDetail detail = MsgAccountDetailFactory.vipUpgradeFail(uid, reason); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - // 娑堟伅鍐呭 - msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } - } - - @Override - public void teacherInvite(Long uid, String nickname,String kefuName, String kefuWX) { - MsgAccountDetail detail = MsgAccountDetailFactory.teacherInvite(uid, nickname, kefuName, kefuWX); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - // 娑堟伅鍐呭 - msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } - } - - @Override - public void teacherSuccess(Long uid, int days, String kefuName, String kefuWX) { - MsgAccountDetail detail = MsgAccountDetailFactory.teacherSuccess(uid, days, kefuName, kefuWX); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - // 娑堟伅鍐呭 - msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } + // TODO Auto-generated method stub + } } -- Gitblit v1.8.0