From 0b2de8c74823749cd184d0708cee17c49593ef39 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期六, 19 十一月 2022 14:18:22 +0800
Subject: [PATCH] 1

---
 src/main/java/com/lf/server/controller/data/DataUploadController.java |   69 ++++++++++++++++++++++++++++++----
 1 files changed, 60 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/lf/server/controller/data/DataUploadController.java b/src/main/java/com/lf/server/controller/data/DataUploadController.java
index dbf53a2..6c662b2 100644
--- a/src/main/java/com/lf/server/controller/data/DataUploadController.java
+++ b/src/main/java/com/lf/server/controller/data/DataUploadController.java
@@ -3,9 +3,13 @@
 import com.lf.server.annotation.SysLog;
 import com.lf.server.controller.all.BaseController;
 import com.lf.server.entity.all.ResponseMsg;
+import com.lf.server.entity.ctrl.UploadEntity;
+import com.lf.server.entity.data.MetaEntity;
 import com.lf.server.entity.data.MetaFileEntity;
 import com.lf.server.entity.sys.UserEntity;
-import com.lf.server.service.data.UploaderService;
+import com.lf.server.helper.StringHelper;
+import com.lf.server.helper.WebHelper;
+import com.lf.server.service.data.DataUploadService;
 import com.lf.server.service.sys.TokenService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
@@ -16,6 +20,7 @@
 
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -30,7 +35,36 @@
     TokenService tokenService;
 
     @Autowired
-    UploaderService uploaderService;
+    DataUploadService dataUploadService;
+
+    @SysLog()
+    @ApiOperation(value = "鏌ヨ鐩綍")
+    @GetMapping(value = "/selectPath")
+    public ResponseMsg<String> selectPath() {
+        try {
+            String pathName = dataUploadService.selectPath();
+
+            return success(pathName);
+        } catch (Exception ex) {
+            return fail(ex.getMessage(), null);
+        }
+    }
+
+    @SysLog()
+    @ApiOperation(value = "鏌ヨ鏂囦欢")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "path", value = "璺緞", dataType = "String", paramType = "query")
+    })
+    @GetMapping(value = "/selectFiles")
+    public ResponseMsg<List<MetaFileEntity>> selectFiles(String path) {
+        try {
+            List<MetaFileEntity> list = dataUploadService.selectFiles(path);
+
+            return success(list);
+        } catch (Exception ex) {
+            return fail(ex.getMessage(), null);
+        }
+    }
 
     @SysLog()
     @ApiOperation(value = "涓婁紶鏂囦欢")
@@ -46,12 +80,12 @@
                 return fail("鐢ㄦ埛鏈櫥褰�", null);
             }
 
-            List<MetaFileEntity> list = uploaderService.uploadData(null, path, req, res);
+            List<MetaFileEntity> list = dataUploadService.uploadData(null, path, req, res);
             if (null == list || list.isEmpty()) {
                 return fail("娌℃湁鎵惧埌涓婁紶鏂囦欢", null);
             }
 
-            return success(list);
+            return success(list.size());
         } catch (Exception ex) {
             return fail(ex.getMessage(), null);
         }
@@ -74,7 +108,7 @@
                 return fail("娌℃湁鎵惧埌鏂囦欢", null);
             }
 
-            int rows = uploaderService.deleteFiles(list);
+            int rows = dataUploadService.deleteFiles(list);
 
             return success("鎴愬姛", rows);
         } catch (Exception ex) {
@@ -85,15 +119,32 @@
     @SysLog()
     @ApiOperation(value = "鎻掑叆鏂囦欢")
     @ApiImplicitParams({
-            @ApiImplicitParam(name = "list", value = "瀹炰綋绫婚泦鍚�", dataType = "MetaFileEntity", paramType = "body")
+            @ApiImplicitParam(name = "entity", value = "涓婁紶瀹炰綋绫�", dataType = "UploadEntity", paramType = "body")
     })
     @ResponseBody
     @PostMapping(value = "/insertFiles")
-    public ResponseMsg<Object> insertFiles(@RequestBody List<MetaFileEntity> list, HttpServletRequest req) {
+    public ResponseMsg<Object> insertFiles(@RequestBody UploadEntity entity, HttpServletRequest req) {
         try {
-            //
+            UserEntity ue = tokenService.getCurrentUser(req);
+            if (ue == null) {
+                return fail("鐢ㄦ埛鏈櫥褰�", null);
+            }
+            if (null == entity || null == entity.getMetaEntity()) {
+                return fail("鍏冩暟鎹俊鎭负绌�", null);
+            }
 
-            return null;
+            if (null == entity.getFileEntities() || entity.getFileEntities().isEmpty()) {
+                return fail("娌℃湁鎵惧埌涓婁紶鏂囦欢", null);
+            }
+
+            MetaEntity me = entity.getMetaEntity();
+            me.setCreateTime(WebHelper.getCurrentTimestamp());
+            me.setBatch(StringHelper.YMDHMS_FORMAT.format(new Date(me.getCreateTime().getTime())));
+            me.setCreateUser(ue.getId());
+
+            int rows = dataUploadService.insertFiles(me, entity.getFileEntities());
+
+            return success("鎴愬姛", rows);
         } catch (Exception ex) {
             return fail(ex.getMessage(), null);
         }

--
Gitblit v1.9.3