From c93dfa3912f0fed74faa2f5f3ef42c318a04a7a2 Mon Sep 17 00:00:00 2001 From: yujian <yujian@163.com> Date: 星期一, 13 四月 2020 11:04:14 +0800 Subject: [PATCH] 消息 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/UserAccountMsgNotificationServiceImpl.java | 100 ++++++++++++++++++++++++++++++------------------- 1 files changed, 61 insertions(+), 39 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 4ebf50c..29628c8 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,9 +3,12 @@ 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; import com.yeshi.fanli.exception.msg.MsgAccountDetailException; +import com.yeshi.fanli.service.inter.msg.MsgExtraService; import com.yeshi.fanli.service.inter.user.msg.MsgAccountDetailService; import com.yeshi.fanli.service.inter.user.msg.UserAccountMsgNotificationService; import com.yeshi.fanli.util.factory.msg.MsgAccountDetailFactory; @@ -15,65 +18,84 @@ @Resource private MsgAccountDetailService msgAccountDetailService; + + @Resource + private MsgExtraService msgExtraService; @Override + @Transactional(rollbackFor = Exception.class) public void bindingSuccess(Long uid, int type) { - MsgAccountDetail detail = MsgAccountDetailFactory.createBindingAccount(uid, type); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - } 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.createUnBindingAccount(uid, type); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - } 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.createChangeBindingAccount(uid, type); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } + saveDetail(MsgAccountDetailFactory.createBindSuccess(uid, type, MsgAccountDetailFactory.WAY_CHANGE)); } - @Override - public void connectSuccess(Long uid, Long lessUid) { - MsgAccountDetail detail = MsgAccountDetailFactory.createConnectAccount(uid, lessUid); - try { - msgAccountDetailService.addMsgAccountDetail(detail); - } catch (MsgAccountDetailException e) { - e.printStackTrace(); - } - } @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 + @Transactional(rollbackFor = Exception.class) public void taoBaoAuthFail(Long uid, String taoBaoNickName, String reason) { - MsgAccountDetail detail = MsgAccountDetailFactory.createTaoBaoAuthFail(uid, taoBaoNickName, 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); + // 娑堟伅鍐呭 + msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT); } catch (MsgAccountDetailException e) { e.printStackTrace(); } } - + } -- Gitblit v1.8.0