Browse Source

update content-service/disk

reghao 6 months ago
parent
commit
be4816aa20

+ 1 - 0
content/content-service/src/main/java/cn/reghao/tnb/content/app/config/mybatis/SqlSessionConfig.java

@@ -23,6 +23,7 @@ import java.util.Map;
 @Configuration
 @MapperScan(basePackages = {
         "cn.reghao.tnb.content.app.vod.db.mapper",
+        "cn.reghao.tnb.content.app.disk.db.mapper",
         "cn.reghao.tnb.content.app.data.db.mapper",
         "cn.reghao.tnb.content.app.chat.db.mapper",
         "cn.reghao.tnb.content.app.exam.db.mapper",

+ 1 - 1
content/content-service/src/main/java/cn/reghao/tnb/content/app/disk/controller/CamController.java

@@ -25,7 +25,7 @@ import java.util.List;
  */
 @Tag(name = "摄像头接口")
 @RestController
-@RequestMapping("/api/disk/cam")
+@RequestMapping("/api/content/disk/cam")
 public class CamController {
     private final CamService camService;
     private final CamRecordService camRecordService;

+ 3 - 3
content/content-service/src/main/java/cn/reghao/tnb/content/app/disk/controller/NetDiskController.java

@@ -26,7 +26,7 @@ import java.util.List;
  */
 @Tag(name = "网盘接口")
 @RestController
-@RequestMapping("/api/disk")
+@RequestMapping("/api/content/disk")
 public class NetDiskController {
     private final NetDiskQuery netDiskQuery;
     private final NetDiskService netDiskService;
@@ -64,7 +64,7 @@ public class NetDiskController {
             pid = diskFile.getFileId();
         }
 
-        PageList<FileInfo> page = netDiskQuery.findByPid(pageSize, pageNumber, pid);
+        PageList<FileInfo> pageList = netDiskQuery.findByPid(pageSize, pageNumber, pid);
         List<NamePath> pathList = netDiskService.getPathList(path);
 
         int showTitle = 3;
@@ -75,7 +75,7 @@ public class NetDiskController {
         model.addAttribute("uploadPage", uploadPage);
         model.addAttribute("showTitle", showTitle);
         model.addAttribute("query", queryParams);*/
-        return WebResult.success();
+        return WebResult.success(pageList);
     }
 
     @Operation(summary = "图片文件列表页面", description = "N")

+ 1 - 1
content/content-service/src/main/java/cn/reghao/tnb/content/app/disk/db/mapper/NetDiskMapper.java

@@ -18,5 +18,5 @@ import java.util.List;
 public interface NetDiskMapper extends BaseMapper<NetDisk> {
     List<NetDiskCount> findFileTypeCountByGroup(long owner);
     int countByDiskQuery(DiskQuery diskQuery);
-    List<NetDisk> findDiskQueryByPage(@Param("diskQuery") DiskQuery diskQuery, @Param("page") Page page);
+    List<NetDisk> findDiskQueryByPage(@Param("page") Page page, @Param("diskQuery") DiskQuery diskQuery);
 }

+ 8 - 8
content/content-service/src/main/java/cn/reghao/tnb/content/app/disk/service/NetDiskQuery.java

@@ -41,7 +41,7 @@ public class NetDiskQuery {
                 .build();
 
         Page page = new Page(1, 1000);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         Map<String, FolderTree> map = netDiskList.stream()
                 .map(FolderTree::new)
                 .collect(Collectors.toMap(FolderTree::getFileId, diskFile -> diskFile));
@@ -72,7 +72,7 @@ public class NetDiskQuery {
                 .owner(owner)
                 .build();
         Page page = new Page(1, 10);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         return netDiskList.isEmpty() ? null : netDiskList.get(0);
     }
 
@@ -85,8 +85,8 @@ public class NetDiskQuery {
                 .owner(loginUser)
                 .build();
 
-        Page page = new Page(pageSize, pageNumber);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        Page page = new Page(pageNumber, pageSize);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
 
         List<FileInfo> list = netDiskList.stream().map(netDisk -> {
             String sizeStr = byteConverter.convert(ByteType.Bytes, netDisk.getSize());
@@ -107,7 +107,7 @@ public class NetDiskQuery {
                 .build();
 
         Page page = new Page(pageSize, pageNumber);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         List<FileInfo> list = netDiskList.stream().map(netDisk -> {
             String sizeStr = byteConverter.convert(ByteType.Bytes, netDisk.getSize());
             return new FileInfo(netDisk, sizeStr);
@@ -126,7 +126,7 @@ public class NetDiskQuery {
                 .build();
 
         Page page = new Page(pageSize, pageNumber);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         List<DiskFileInfo> list = netDiskList.stream().map(netDisk -> {
             String fileId = netDisk.getFileId();
             String filename = netDisk.getFilename();
@@ -153,7 +153,7 @@ public class NetDiskQuery {
                 .build();
 
         Page page = new Page(1, 10);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         if (!netDiskList.isEmpty()) {
             NetDisk netDisk = netDiskList.get(0);
             long owner = netDisk.getOwner();
@@ -180,7 +180,7 @@ public class NetDiskQuery {
 
 
         Page page = new Page(1, 10);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         return netDiskList.isEmpty() ? null : netDiskList.get(0);
     }
 

+ 13 - 13
content/content-service/src/main/java/cn/reghao/tnb/content/app/disk/service/NetDiskService.java

@@ -58,7 +58,7 @@ public class NetDiskService {
                 .owner(owner)
                 .build();
         Page page = new Page(1, 10);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         if (!netDiskList.isEmpty()) {
             return netDiskList.get(0).getFileId();
         }
@@ -80,7 +80,7 @@ public class NetDiskService {
                     .path(parent)
                     .owner(owner)
                     .build();
-            netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+            netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
             if (!netDiskList.isEmpty()) {
                 pid = netDiskList.get(0).getFileId();
             } else {
@@ -96,7 +96,7 @@ public class NetDiskService {
                 .path(savedDirPath)
                 .owner(owner)
                 .build();
-        netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         return netDiskList.get(0).getFileId();
     }
 
@@ -111,7 +111,7 @@ public class NetDiskService {
                 .owner(owner)
                 .build();
         Page page = new Page(1, 10);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         return !netDiskList.isEmpty();
     }
 
@@ -153,7 +153,7 @@ public class NetDiskService {
                     .path(parent)
                     .build();
             Page page = new Page(1, 10);
-            List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+            List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
             parentFile = netDiskList.get(0);
         } else {
             DiskQuery diskQuery = new DiskQuery.Builder()
@@ -161,7 +161,7 @@ public class NetDiskService {
                     .owner(owner)
                     .build();
             Page page = new Page(1, 10);
-            List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+            List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
             parentFile = netDiskList.get(0);
         }
 
@@ -183,7 +183,7 @@ public class NetDiskService {
                 .fileId(fileId)
                 .build();
         Page page = new Page(1, 10);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         NetDisk current = netDiskList.get(0);
         if (current == null) {
             String msg = String.format("file %s not exist", fileId);
@@ -198,7 +198,7 @@ public class NetDiskService {
                 .path(newPath)
                 .build();
         page = new Page(1, 10);
-        netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         NetDisk netDisk = netDiskList.get(0);
         if (netDisk != null) {
             String msg = String.format("filename %s exist", newFilename);
@@ -239,7 +239,7 @@ public class NetDiskService {
                 .fileId(pid)
                 .build();
         Page page = new Page(1, 10);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         NetDisk parentFile = netDiskList.get(0);
         if (parentFile == null) {
             String msg = "文件被移动/复制到的位置不存在";
@@ -259,7 +259,7 @@ public class NetDiskService {
                     .fileId(pid1)
                     .build();
             page = new Page(1, 10);
-            netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+            netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
             pid1 = netDiskList.get(0).getPid();
             parents.add(pid1);
         }
@@ -323,7 +323,7 @@ public class NetDiskService {
                 .fileId(pid)
                 .build();
         Page page = new Page(1, 10);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         NetDisk parentFile = netDiskList.get(0);
         if (parentFile == null) {
             String msg = "文件被移动/复制到的位置不存在";
@@ -343,7 +343,7 @@ public class NetDiskService {
                     .fileId(pid1)
                     .build();
             page = new Page(1, 10);
-            netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+            netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
             pid1 = netDiskList.get(0).getPid();
             parents.add(pid1);
         }
@@ -563,7 +563,7 @@ public class NetDiskService {
                 .path(path)
                 .build();
         Page page = new Page(1, 10);
-        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(diskQuery, page);
+        List<NetDisk> netDiskList = netDiskMapper.findDiskQueryByPage(page, diskQuery);
         NetDisk diskFile = netDiskList.get(0);
         if (diskFile != null) {
             filename = getNewFilename(filename);

+ 1 - 1
content/content-service/src/main/resources/mapper/disk/NetDiskMapper.xml

@@ -47,7 +47,7 @@
             </if>
         </where>
     </select>
-    <select id="findAllByDiskQuery" resultType="cn.reghao.tnb.content.app.disk.model.po.NetDisk">
+    <select id="findDiskQueryByPage" resultType="cn.reghao.tnb.content.app.disk.model.po.NetDisk">
         select *
         from my_net_disk
         <where>