Commit 47131e39 by 张晋雄

用户模块基本功能

parent 7c0d2717
......@@ -17,6 +17,11 @@ import org.springframework.stereotype.Service;
@Service
public class UserBlacklistServiceImpl extends ServiceImpl<UserBlacklistMapper, UserBlacklist> implements IUserBlacklistService {
/**
* 拉黑
* @param blackId 拉黑用户的id
* @param userId
*/
@Override
public void blacklist(String blackId, String userId) {
UserBlacklist userBlacklist = new UserBlacklist();
......
......@@ -6,6 +6,7 @@ import cn.meteor.beyondclouds.modules.user.mapper.IUserFollowMapper;
import cn.meteor.beyondclouds.modules.user.service.IUserFollowService;
import cn.meteor.beyondclouds.modules.user.service.IUserService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
......@@ -27,36 +28,58 @@ public class UserFollowServiceImpl extends ServiceImpl<IUserFollowMapper, UserFo
this.userService = userService;
}
/**
* 关注
* @param userId 被关注用户的userId
* @param myUserId 当前用户的userId
*/
@Override
public void follower(String userId, String myUserId) {
UserFollow userFollow = new UserFollow();
//1.查询被关注用户的基本信息
User user = userService.getById(userId);
//2.查询我的基本信息
User myUser = userService.getById(myUserId);
UserFollow userFollow = new UserFollow();
userFollow.setFollowedId(userId);
userFollow.setFollowedNick(user.getNickName());
userFollow.setFollowedAvatar(user.getUserAvatar());
//2.查询我的基本信息
User myUser = userService.getById(myUserId);
userFollow.setFollowerId(myUserId);
userFollow.setFollowerNick(myUser.getNickName());
userFollow.setFollowerAvatar(myUser.getUserAvatar());
userFollow.setFollowStatus(0);
save(userFollow);
}
/**
* 取消关注
* @param userId 被关注用户的userId
* @param myUserId 当前用户的userId
*/
@Override
public void delFollower(String userId, String myUserId) {
QueryWrapper queryWrapper = new QueryWrapper<>();
queryWrapper.eq("follower_id", myUserId);
queryWrapper.eq("followed_id", userId);
//1.查找符合条件的关注信息
UpdateWrapper updateWrapper = new UpdateWrapper();
updateWrapper.eq("follower_id", myUserId);
updateWrapper.eq("followed_id", userId);
remove(queryWrapper);
//2.将关注状态设置为-1并保存
updateWrapper.set("follow_status",-1);
update(updateWrapper);
}
/**
* 查询粉丝列表
* @param pageNumber
* @param pageSize
* @param userId 要查询用户的userId
* @return
*/
@Override
public IPage<UserFollow> getFansPage(Integer pageNumber, Integer pageSize, String userId) {
IPage<UserFollow> page = new Page<>(pageNumber, pageSize);
......@@ -65,6 +88,13 @@ public class UserFollowServiceImpl extends ServiceImpl<IUserFollowMapper, UserFo
return page(page, projectQueryWrapper);
}
/**
* 查询关注列表
* @param pageNumber
* @param pageSize
* @param userId 要查询用户的userId
* @return
*/
@Override
public IPage<UserFollow> getFollowersPage(Integer pageNumber, Integer pageSize, String userId) {
IPage<UserFollow> page = new Page<>(pageNumber, pageSize);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment