diff --git a/service/src/main/java/com/hfkj/service/user/impl/BsUserServiceImpl.java b/service/src/main/java/com/hfkj/service/user/impl/BsUserServiceImpl.java index 8cccaad..7444632 100644 --- a/service/src/main/java/com/hfkj/service/user/impl/BsUserServiceImpl.java +++ b/service/src/main/java/com/hfkj/service/user/impl/BsUserServiceImpl.java @@ -10,7 +10,9 @@ import com.hfkj.common.utils.RedisUtil; import com.hfkj.dao.BsUserMapper; import com.hfkj.entity.*; import com.hfkj.model.UserSessionObject; +import com.hfkj.service.message.BsMessageService; import com.hfkj.service.user.*; +import com.hfkj.sysenum.message.MessageTypeEnum; import com.hfkj.sysenum.user.*; import org.apache.catalina.User; import org.apache.commons.collections4.MapUtils; @@ -52,6 +54,8 @@ public class BsUserServiceImpl implements BsUserService { @Resource private BsUserGradeService userGradeService; @Resource + private BsMessageService msgService; + @Resource private BsUserPlatformAuthorizeService userPlatformAuthorizeService; private final static String CACHE_KEY = "USER"; @@ -140,6 +144,9 @@ public class BsUserServiceImpl implements BsUserService { userParentRel.setUserId(userId); userParentRelService.editData(userParentRel); + // 消息 + msgService.createUserMsg(MessageTypeEnum.type3, userParentRel.getParentUserId(), "好友绑定", "用户ID:"+user.getId()+",用户名称:"+user.getName()+",绑定了您账户!"); + user.setInviteUserId(inviteUseId); user.setInviteTime(new Date()); updateInfo(user); @@ -367,6 +374,8 @@ public class BsUserServiceImpl implements BsUserService { userParentRel.setParentUserGrade(inviteUser.getGrade()); userParentRel.setUserId(user.getId()); userParentRelService.editData(userParentRel); + // 消息 + msgService.createUserMsg(MessageTypeEnum.type3, userParentRel.getParentUserId(), "好友绑定", "用户ID:"+user.getId()+",用户名称:"+user.getName()+",绑定了您账户!"); } // 创建账户