From d403c1ff86d0f40c7554f07215a8f3942901018c Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期日, 20 十一月 2022 10:50:51 +0800
Subject: [PATCH] 1

---
 src/main/java/com/lf/server/controller/data/DataUploadController.java |   58 ++++++++++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 52 insertions(+), 6 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 5543f74..6c51d39 100644
--- a/src/main/java/com/lf/server/controller/data/DataUploadController.java
+++ b/src/main/java/com/lf/server/controller/data/DataUploadController.java
@@ -1,11 +1,23 @@
 package com.lf.server.controller.data;
 
-import com.lf.server.controller.all.BaseController;
-import com.lf.server.service.sys.TokenService;
+import com.lf.server.annotation.SysLog;
+import com.lf.server.controller.all.BaseUploadController;
+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.sys.UserEntity;
+import com.lf.server.helper.StringHelper;
+import com.lf.server.helper.WebHelper;
+import com.lf.server.service.data.DataUploadService;
 import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.Date;
 
 /**
  * 鏁版嵁涓婁紶
@@ -14,7 +26,41 @@
 @Api(tags = "鏁版嵁绠$悊\\鏁版嵁涓婁紶")
 @RestController
 @RequestMapping("/dataUpload")
-public class DataUploadController extends BaseController {
+public class DataUploadController extends BaseUploadController {
     @Autowired
-    TokenService tokenService;
+    DataUploadService dataUploadService;
+
+    @SysLog()
+    @ApiOperation(value = "鎻掑叆鏂囦欢")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "entity", value = "涓婁紶瀹炰綋绫�", dataType = "UploadEntity", paramType = "body")
+    })
+    @ResponseBody
+    @PostMapping(value = "/insertFiles")
+    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);
+            }
+
+            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