From ab849f796bdc17236a95ea5fe5c166fb8f24a75c Mon Sep 17 00:00:00 2001
From: sws <15810472099@163.com>
Date: 星期六, 26 十一月 2022 16:12:02 +0800
Subject: [PATCH] 1
---
src/main/java/com/lf/server/service/all/CommonsFileuploadService.java | 116 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 116 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/lf/server/service/all/CommonsFileuploadService.java b/src/main/java/com/lf/server/service/all/CommonsFileuploadService.java
new file mode 100644
index 0000000..540c25c
--- /dev/null
+++ b/src/main/java/com/lf/server/service/all/CommonsFileuploadService.java
@@ -0,0 +1,116 @@
+package com.lf.server.service.all;
+
+import com.lf.server.entity.ctrl.FileInfoEntity;
+import com.lf.server.entity.sys.UserEntity;
+import com.lf.server.helper.PathHelper;
+import com.lf.server.helper.StringHelper;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.tomcat.util.http.fileupload.FileItem;
+import org.apache.tomcat.util.http.fileupload.disk.DiskFileItemFactory;
+import org.apache.tomcat.util.http.fileupload.servlet.ServletFileUpload;
+import org.apache.tomcat.util.http.fileupload.servlet.ServletRequestContext;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.File;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * CommonsFileupload涓婁紶鏈嶅姟
+ * @author WWW
+ */
+@Service
+public class CommonsFileuploadService {
+ @Autowired
+ PathHelper pathHelper;
+
+ private final static Log log = LogFactory.getLog(CommonsFileuploadService.class);
+
+ public Object fileUpload(HttpServletRequest req, HttpServletResponse res) throws Exception {
+ List<FileItem> items = getFileItem(req, res);
+
+ return copeFileItems(items, req);
+ }
+
+ /**
+ * 鑾峰彇鏂囦欢椤�
+ */
+ private List<FileItem> getFileItem(HttpServletRequest req, HttpServletResponse res) throws Exception {
+ // 澶勭悊涓枃涔辩爜闂
+ req.setCharacterEncoding("utf-8");
+ // text/html;charset=utf-8
+ res.setContentType("application/json;charset=utf-8");
+
+ // 妫�鏌ヨ姹傛槸/鍚︿负multipart/form-data绫诲瀷
+ if (!ServletFileUpload.isMultipartContent(req)) {
+ throw new RuntimeException("琛ㄥ崟鐨別nctype灞炴�т笉鏄痬ultipart/form-data绫诲瀷");
+ }
+
+ // 鍒涘缓涓婁紶鎵�闇�瑕佺殑涓や釜瀵硅薄锛氱鐩樻枃浠跺璞�+鏂囦欢涓婁紶瀵硅薄
+ DiskFileItemFactory factory = new DiskFileItemFactory();
+ ServletFileUpload sfu = new ServletFileUpload(factory);
+ ServletRequestContext ctx = new ServletRequestContext(req);
+
+ // 璁剧疆缂栫爜鏂瑰紡
+ sfu.setHeaderEncoding("utf-8");
+ factory.setSizeThreshold(4096);
+
+ // 鑾峰彇琛ㄥ崟涓殑鎵�鏈夋暟鎹俊鎭�
+ List<FileItem> list = sfu.parseRequest(ctx);
+
+ return list;
+ }
+
+ /**
+ * 澶勭悊瑙ｆ瀽鍐呭锛氬鐞嗘櫘閫氳〃鍗曞煙鍜屾枃浠惰〃鍗曞煙
+ */
+ private Object copeFileItems(List<FileItem> items, HttpServletRequest req) throws Exception {
+ Map<String, String> map = new HashMap<String, String>(3);
+ List<FileInfoEntity> list = new ArrayList<FileInfoEntity>();
+
+ String path = pathHelper.getTempPath();
+ for (FileItem item : items) {
+ if (item.isFormField()) {
+ String key = item.getFieldName();
+ String value = item.getString("utf-8");
+ map.put(key, value);
+ continue;
+ }
+
+ FileInfoEntity fi = copeFile(item, path, req);
+ if (fi != null) {
+ list.add(fi);
+ }
+ }
+
+ return map;
+ }
+
+ /**
+ * 澶勭悊鏂囦欢
+ */
+ private FileInfoEntity copeFile(FileItem item, String path, HttpServletRequest req) {
+ try {
+ // 鑾峰彇鏂囦欢鍚嶏紝鍒ゆ柇鏄惁鍚堟硶
+ FileInfoEntity fi = new FileInfoEntity(item.getName());
+ if (StringHelper.isEmpty(fi.getFileName())) {
+ return null;
+ }
+
+ fi.setSize(item.getSize());
+ fi.setPath(path + File.separator + fi.getFileName());
+ item.write(new File(fi.getPath()));
+
+ return fi;
+ } catch (Exception ex) {
+ log.error(ex.getMessage(), ex);
+ return null;
+ }
+ }
+}
--
Gitblit v1.9.3