新版

src/main/java/com/peanut/modules/book/controller/BookController.java

@@ -3,7 +3,10 @@ import java.util.*;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.github.yulichang.wrapper.MPJLambdaWrapper;
 import com.peanut.common.utils.ReadProvinceUtil;
+import com.peanut.modules.book.dao.BookDao;
 import com.peanut.modules.book.entity.*;
 import com.peanut.modules.book.service.*;
 import com.peanut.modules.book.vo.BookIndexVo;
@@ -47,6 +50,8 @@ public class BookController {
     private CountyService countyService;
     @Autowired
     private  UserEbookBuyService userEbookBuyService;
+    @Autowired
+    private BookDao bookDao;
     final ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10);
 
     /**
@@ -187,6 +192,26 @@ public class BookController {
         return R.ok();
     }
 
+    /**
+     * 获取用户未拥有的可听图书
+     * @return
+     */
+    @RequestMapping("/getUserNobuyBooks")
+    public R getUserNobuyBooks(@RequestParam Integer userId,@RequestParam Integer limit,@RequestParam Integer page){
+        List<UserEbookBuyEntity> bookids = userEbookBuyService.getBaseMapper().selectList(new QueryWrapper<UserEbookBuyEntity>()
+                .select("book_id").eq("user_id", userId));
+        List bids = new ArrayList();
+        for (UserEbookBuyEntity b :bookids){
+            bids.add(b.getBookId());
+        }
+        Integer start = (page-1)*limit;
+        QueryWrapper<BookEntity> wrapper = new QueryWrapper<>();
+        wrapper.eq("t.can_listen",1);
+        wrapper.notIn("t1.Book_id",bids);
+        List<BookEntity> bookEntities = bookDao.queryUserListenBooksNobuy(wrapper,start,limit);
+        Integer count = bookDao.queryUserListenBooksNobuyCount(wrapper);
+        return R.ok().put("books",bookEntities).put("count",count);
+    }
 
     /**
      * 修改

src/main/java/com/peanut/modules/book/controller/UserEbookBuyController.java

@@ -1,9 +1,6 @@
 package com.peanut.modules.book.controller;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.github.yulichang.base.MPJBaseMapper;
-import com.github.yulichang.base.mapper.MPJJoinMapper;
-import com.github.yulichang.toolkit.MPJWrappers;
 import com.github.yulichang.wrapper.MPJLambdaWrapper;
 import com.peanut.common.utils.PageUtils;
 import com.peanut.common.utils.R;
@@ -113,6 +110,15 @@ public class UserEbookBuyController {
 
     }
 
+    /**
+     * 获取用户可听书列表
+     * @return
+     */
+    @RequestMapping("/getUserCanlistenBooks")
+    public R getUserCanlistenBooks(@RequestParam Integer userId,@RequestParam Integer limit,@RequestParam Integer page){
+        return R.ok();
+    }
+
     @RequestMapping("/buylist")
     public R buylist(@RequestParam Map<String, Object> params){
         String userId = (String) params.get("id");

src/main/java/com/peanut/modules/book/dao/BookDao.java

@@ -1,9 +1,13 @@
 package com.peanut.modules.book.dao;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.github.yulichang.base.MPJBaseMapper;
 import com.peanut.modules.book.entity.BookEntity;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
 
 import java.util.List;
 import java.util.Map;
@@ -20,4 +24,10 @@ public interface BookDao extends MPJBaseMapper<BookEntity> {
 
     List<BookEntity> queryBookInOther(String publisherName,String authorName);
 
+
+    @Select("select t.* from book t left join user_ebook_buy t1 on t.id = t1.book_id ${ew.customSqlSegment} limit #{start},#{limit}")
+    List<BookEntity> queryUserListenBooksNobuy(@Param("ew") QueryWrapper<BookEntity> wrapper,@Param("start") int start,@Param("limit") int limit);
+
+    @Select("select count(*) as sum from book t left join user_ebook_buy t1 on t.id = t1.book_id ${ew.customSqlSegment}")
+    Integer queryUserListenBooksNobuyCount(@Param("ew") QueryWrapper<BookEntity> wrapper);
 }

src/main/java/com/peanut/modules/book/dao/UserEbookBuyDao.java

@@ -1,5 +1,6 @@
 package com.peanut.modules.book.dao;
 
+import com.github.yulichang.base.MPJBaseMapper;
 import com.peanut.modules.book.entity.UserEbookBuyEntity;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
@@ -12,6 +13,6 @@ import org.apache.ibatis.annotations.Mapper;
  * @date 2022-10-18 16:28:20
  */
 @Mapper
-public interface UserEbookBuyDao extends BaseMapper<UserEbookBuyEntity> {
+public interface UserEbookBuyDao extends MPJBaseMapper<UserEbookBuyEntity> {
 	
 }