From 7202e07a127936d008d6a26a8a6655bbe4a61d1c Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期六, 15 一月 2022 10:26:50 +0800
Subject: [PATCH] 上传修改

---
 springcloud_k8s_panzhihuazhihuishequ/applets_backstage/src/main/java/com/panzhihua/applets_backstage/api/CommunityConvenientApi.java |   43 ++++++++++++++++++++++++++++++-------------
 1 files changed, 30 insertions(+), 13 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/applets_backstage/src/main/java/com/panzhihua/applets_backstage/api/CommunityConvenientApi.java b/springcloud_k8s_panzhihuazhihuishequ/applets_backstage/src/main/java/com/panzhihua/applets_backstage/api/CommunityConvenientApi.java
index 01a42df..4d41df5 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/applets_backstage/src/main/java/com/panzhihua/applets_backstage/api/CommunityConvenientApi.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/applets_backstage/src/main/java/com/panzhihua/applets_backstage/api/CommunityConvenientApi.java
@@ -1,15 +1,20 @@
 package com.panzhihua.applets_backstage.api;
 
+import java.io.File;
 import java.io.IOException;
 import java.io.InputStream;
 import java.time.Instant;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.UUID;
+import java.util.concurrent.atomic.AtomicBoolean;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import javax.validation.Valid;
 
+import com.panzhihua.common.model.vos.UploadFilesVO;
 import org.apache.commons.io.FilenameUtils;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.validation.annotation.Validated;
@@ -220,20 +225,32 @@
 
     @ApiOperation(value = "上传文件")
     @PostMapping(value = "/upload/file", consumes = "multipart/*", headers = "content-type=multipart/form-date")
-    public R uploadImage(@RequestParam MultipartFile file, HttpServletRequest request) {
-        String extension = FilenameUtils.getExtension(file.getOriginalFilename());
-        String name = UUID.randomUUID().toString().replaceAll("-", "") + "." + extension;
-        try {
-            SFTPUtil sftp = new SFTPUtil(userName, password, host, port);
-            sftp.login();
-            InputStream is = file.getInputStream();
-            sftp.uploadMore(FtpConstants.FTPFILEPATH_IDCARD, name, is);
-            sftp.logout();
-            return R.ok(url + "/idcard/" + name);
-        } catch (Exception e) {
-            log.error("上传照片失败【{}】", e.getMessage());
-            return R.fail();
+    public R uploadImage(@RequestParam MultipartFile[] files, HttpServletRequest request) {
+        List<UploadFilesVO> urlList = new ArrayList<>();
+        SFTPUtil sftp = new SFTPUtil(userName, password, host, port);
+        sftp.login();
+        for (MultipartFile file : files) {
+            String fileExtension = FilenameUtils.getExtension(file.getOriginalFilename());
+            String name = UUID.randomUUID().toString().replaceAll("-", "") + fileExtension;
+            try {
+                InputStream is = file.getInputStream();
+                String fileName =
+                         UUID.randomUUID().toString().replace("-", "") + fileExtension;
+                File file1 = new File(fileName);
+                file.transferTo(file1);
+                boolean delete = file1.delete();
+                log.info("临时文件删除【{}】", delete);
+                sftp.uploadMore(FtpConstants.FTPFILEPATH_IDCARD, name, is);
+                UploadFilesVO fileVO = new UploadFilesVO();
+                fileVO.setUrl(url + "idcard/" + name);
+                urlList.add(fileVO);
+            } catch (Exception e) {
+                log.error("上传文件失败【{}】", e.getMessage());
+                return R.fail();
+            }
         }
+        sftp.logout();
+        return R.ok(urlList);
     }
 
     @ApiOperation(value = "新上传照片接口")

--
Gitblit v1.7.1