package cn.lili.modules.lmk.service.impl;
|
|
import cn.lili.common.security.context.UserContext;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import cn.lili.modules.lmk.domain.entity.MySubscribe;
|
import cn.lili.modules.lmk.mapper.MySubscribeMapper;
|
import cn.lili.modules.lmk.service.MySubscribeService;
|
import cn.lili.base.Result;
|
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
|
import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import cn.lili.modules.lmk.domain.vo.MySubscribeVO;
|
import cn.lili.modules.lmk.domain.query.MySubscribeQuery;
|
import org.springframework.stereotype.Service;
|
import lombok.RequiredArgsConstructor;
|
import cn.lili.utils.PageUtil;
|
|
import java.util.List;
|
|
/**
|
* 我的关注 服务实现类
|
*
|
* @author xp
|
* @since 2025-05-27
|
*/
|
@Service
|
@RequiredArgsConstructor
|
public class MySubscribeServiceImpl extends ServiceImpl<MySubscribeMapper, MySubscribe> implements MySubscribeService {
|
|
private final MySubscribeMapper mySubscribeMapper;
|
|
/**
|
* 分页查询
|
* @param query
|
* @return
|
*/
|
@Override
|
public Result page(MySubscribeQuery query) {
|
query.setUserId(UserContext.getCurrentUserId());
|
IPage<MySubscribeVO> page = PageUtil.getPage(query, MySubscribeVO.class);
|
baseMapper.getPage(page, query);
|
return Result.ok().data(page.getRecords()).total(page.getTotal());
|
}
|
|
@Override
|
public Result subscribe(String userId) {
|
boolean exists = new LambdaQueryChainWrapper<>(baseMapper)
|
.eq(MySubscribe::getSubscribeUserId, userId)
|
.eq(MySubscribe::getUserId, UserContext.getCurrentUserId())
|
.exists();
|
if (!exists) {
|
MySubscribe mySubscribe = new MySubscribe();
|
mySubscribe.setUserId(UserContext.getCurrentUserId());
|
mySubscribe.setSubscribeUserId(userId);
|
baseMapper.insert(mySubscribe);
|
}
|
return Result.ok().data("关注成功");
|
}
|
|
@Override
|
public Result unSubscribe(String userId) {
|
new LambdaUpdateChainWrapper<>(baseMapper)
|
.eq(MySubscribe::getUserId, UserContext.getCurrentUserId())
|
.eq(MySubscribe::getSubscribeUserId, userId)
|
.remove();
|
return Result.ok().data("已取消关注");
|
}
|
|
@Override
|
public List<String> getSubscribesByUserId(String userId) {
|
return baseMapper.getSubscribesByUserId(userId);
|
}
|
}
|
