admin
2020-04-10 d960fdbfe07a65cb80ccb764bfb15ce78ebfd84a
fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/UserAccountMsgNotificationServiceImpl.java
@@ -5,7 +5,9 @@
import org.springframework.stereotype.Service;
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,12 +17,17 @@
   @Resource
   private MsgAccountDetailService msgAccountDetailService;
   @Resource
   private MsgExtraService msgExtraService;
   @Override
   public void bindingSuccess(Long uid, int type) {
      MsgAccountDetail detail = MsgAccountDetailFactory.createBindingAccount(uid, 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();
      }
@@ -28,9 +35,11 @@
   @Override
   public void unBindingSuccess(Long uid, int type) {
      MsgAccountDetail detail = MsgAccountDetailFactory.createUnBindingAccount(uid, 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();
      }
@@ -38,9 +47,11 @@
   @Override
   public void changeBindingSuccess(Long uid, int type) {
      MsgAccountDetail detail = MsgAccountDetailFactory.createChangeBindingAccount(uid, type);
      MsgAccountDetail detail = MsgAccountDetailFactory.createBindSuccess(uid, type, MsgAccountDetailFactory.WAY_CHANGE);
      try {
         msgAccountDetailService.addMsgAccountDetail(detail);
         // 消息内容
         msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT);
      } catch (MsgAccountDetailException e) {
         e.printStackTrace();
      }
@@ -68,12 +79,88 @@
   @Override
   public void taoBaoAuthFail(Long uid, String taoBaoNickName, String reason) {
      MsgAccountDetail detail = MsgAccountDetailFactory.createTaoBaoAuthFail(uid, taoBaoNickName, 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();
      }
   }
}