|
|
@@ -1,14 +1,18 @@
|
|
|
package cn.qinys.platform.mobile.service.impl;
|
|
|
+
|
|
|
import cn.qinys.platform.base.security.utils.CurrentUtils;
|
|
|
import cn.qinys.platform.entity.wishing.UserWish;
|
|
|
import cn.qinys.platform.entity.wishing.WishingTree;
|
|
|
import cn.qinys.platform.mobile.mapper.UserWishMapper;
|
|
|
import cn.qinys.platform.mobile.mapper.WishingTreeMapper;
|
|
|
import cn.qinys.platform.mobile.req.WishCreateReq;
|
|
|
+import cn.qinys.platform.mobile.req.WishPageReq;
|
|
|
import cn.qinys.platform.mobile.resp.WishDetailResp;
|
|
|
import cn.qinys.platform.mobile.resp.WishListResp;
|
|
|
+import cn.qinys.platform.mobile.resp.WishPageResp;
|
|
|
import cn.qinys.platform.mobile.service.UserWishService;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
|
import com.fasterxml.jackson.core.type.TypeReference;
|
|
|
@@ -28,40 +32,30 @@ public class UserWishServiceImpl implements UserWishService {
|
|
|
private UserWishMapper wishMapper;
|
|
|
|
|
|
@Resource
|
|
|
- private WishingTreeMapper wishingTreeMapper;
|
|
|
+ private WishingTreeMapper treeMapper;
|
|
|
|
|
|
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
|
|
|
|
|
|
@Override
|
|
|
- public WishListResp listByTree(Long treeId, Integer page, Integer pageSize) {
|
|
|
- Page<UserWish> mpPage = wishMapper.selectPage(
|
|
|
- new Page<>(page, pageSize),
|
|
|
- new LambdaQueryWrapper<UserWish>()
|
|
|
- .eq(UserWish::getTreeId, treeId)
|
|
|
- .eq(UserWish::getIsPublic, 1)
|
|
|
- .eq(UserWish::getStatus, 0)
|
|
|
- .orderByDesc(UserWish::getCreatedAt)
|
|
|
- );
|
|
|
-
|
|
|
- WishListResp resp = new WishListResp();
|
|
|
- resp.setList(mpPage.getRecords().stream().map(this::toDetailResp).toList());
|
|
|
- resp.setTotal(mpPage.getTotal());
|
|
|
- return resp;
|
|
|
+ public Page<WishPageResp> pageByTree(Integer treeId, WishPageReq req) {
|
|
|
+ Page<UserWish> pageResp = new Page<>(req.getPage(), req.getPageSize());
|
|
|
+ QueryWrapper<UserWish> wrapper = new QueryWrapper<>();
|
|
|
+ wrapper.eq("tree_id", treeId)
|
|
|
+ .eq("is_public", 1)
|
|
|
+ .eq("is_deleted", 0)
|
|
|
+ .orderByDesc("created_at");
|
|
|
+ return wishMapper.selectWishPage(pageResp, wrapper);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public WishListResp listMyWishes(String userId, Integer page, Integer pageSize) {
|
|
|
- Page<UserWish> mpPage = wishMapper.selectPage(
|
|
|
- new Page<>(page, pageSize),
|
|
|
- new LambdaQueryWrapper<UserWish>()
|
|
|
- .eq(UserWish::getUserId, userId)
|
|
|
- .orderByDesc(UserWish::getCreatedAt)
|
|
|
- );
|
|
|
-
|
|
|
- WishListResp resp = new WishListResp();
|
|
|
- resp.setList(mpPage.getRecords().stream().map(this::toDetailResp).toList());
|
|
|
- resp.setTotal(mpPage.getTotal());
|
|
|
- return resp;
|
|
|
+ public Page<WishPageResp> pageByUser(WishPageReq req) {
|
|
|
+ String userId = CurrentUtils.getCurrentUserId();
|
|
|
+ Page<UserWish> pageResp = new Page<>(req.getPage(), req.getPageSize());
|
|
|
+ QueryWrapper<UserWish> wrapper = new QueryWrapper<>();
|
|
|
+ wrapper.eq("user_id", userId)
|
|
|
+ .eq("is_deleted", 0)
|
|
|
+ .orderByDesc("created_at");
|
|
|
+ return wishMapper.selectWishPage(pageResp, wrapper);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
@@ -72,7 +66,7 @@ public class UserWishServiceImpl implements UserWishService {
|
|
|
|
|
|
@Override
|
|
|
public WishDetailResp create(WishCreateReq req) {
|
|
|
- WishingTree tree = wishingTreeMapper.selectById(req.getTreeId());
|
|
|
+ WishingTree tree = treeMapper.selectById(req.getTreeId());
|
|
|
|
|
|
UserWish wish = new UserWish();
|
|
|
wish.setTreeId(req.getTreeId());
|
|
|
@@ -143,7 +137,8 @@ public class UserWishServiceImpl implements UserWishService {
|
|
|
private List<String> parseJsonList(String json) {
|
|
|
if (json == null || json.isBlank()) return new ArrayList<>();
|
|
|
try {
|
|
|
- return OBJECT_MAPPER.readValue(json, new TypeReference<List<String>>() {});
|
|
|
+ return OBJECT_MAPPER.readValue(json, new TypeReference<List<String>>() {
|
|
|
+ });
|
|
|
} catch (Exception e) {
|
|
|
log.error("parseJsonList error", e);
|
|
|
return new ArrayList<>();
|