From 456a06d365dcc73d2d0e2d2a4b177d875152380b Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期四, 17 四月 2025 11:49:31 +0800 Subject: [PATCH] 代码初始化 --- server/src/main/java/com/doumee/api/common/PublicCloudController.java | 71 +++++++++++++++++++++++++++++++++++ 1 files changed, 70 insertions(+), 1 deletions(-) diff --git a/server/src/main/java/com/doumee/api/common/PublicCloudController.java b/server/src/main/java/com/doumee/api/common/PublicCloudController.java index e787119..c6105c1 100644 --- a/server/src/main/java/com/doumee/api/common/PublicCloudController.java +++ b/server/src/main/java/com/doumee/api/common/PublicCloudController.java @@ -66,7 +66,76 @@ @ApiOperation(value = "鎵归噺涓婁紶鏂囦欢鍒癋TP") @RequestMapping(method= RequestMethod.POST,value="/uploadBatch") @ResponseBody - public void uploadBatch(HttpServletRequest request, HttpServletResponse response, String folder) throws Exception { + public void uploadBatch(@RequestParam("files") MultipartFile[] fileList,HttpServletRequest request, HttpServletResponse response, String folder) throws Exception { + if(Objects.isNull(folder)){ + throw new BusinessException(ResponseStatus.BAD_REQUEST); + } + if(Objects.isNull(fileList)){ + throw new BusinessException(ResponseStatus.BAD_REQUEST); + } + SystemDictData folderData = systemDictDataBiz.queryByCode(Constants.FTP,folder); + if(Objects.isNull(folderData)||StringUtils.isBlank(folderData.getCode())){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鐩爣鏂囦欢澶归敊璇�"); + } + folder = systemDictDataBiz.queryByCode(Constants.FTP,folder).getCode(); + String prefixPath = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode(); + response.setCharacterEncoding("UTF-8"); + response.setContentType("text/html;charset=UTF-8"); + Map<String, Object> context = new HashMap<>(); + try { + if(ftp == null){ + ftp = new FtpUtil(systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_HOST).getCode(), + Integer.parseInt(systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_PORT).getCode()), + systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_USERNAME).getCode(), + systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_PWD).getCode()); + }else{ + ftp.connect(); + } + + context.put("success", true); + context.put("code", 200); + context.put("errno",0); + JSONArray jsonArray = new JSONArray(); + if (fileList.length > 0) { + //閬嶅巻鏂囦欢鍒楄〃 + Integer index = Constants.ONE; + for (MultipartFile file :fileList) { + //鑾峰緱姣忎竴涓枃浠� + String originname = file.getOriginalFilename(); + InputStream is = file.getInputStream(); + String endType = originname.substring(originname.lastIndexOf("."), originname.length()); + String date = DateUtil.getNowShortDate(); + String fName = date + "/" + UUID.randomUUID() + endType; + String fileName = folder + fName; + boolean r = ftp.uploadInputstreamBatch(is, fileName, Constants.equalsInteger(index ,fileList.length),index); + if (r) { + JSONObject fileJSON = new JSONObject(); + fileJSON.put("url", prefixPath + fileName); + fileJSON.put("imgaddr", fName); + fileJSON.put("imgname", fileName); + fileJSON.put("originname", originname); + jsonArray.add(fileJSON); + } + index = index + 1; + } + context.put("data",jsonArray); + } + } catch (Exception e) { + log.error("銆愪笂浼燜TP澶辫触銆�======================"+e.getMessage()); + context.put("code", 0); + context.put("message", "涓婁紶澶辫触"); + context.put("errno",0); + writerJson(response, context); + return; + + } + writerJson(response, context); + return; + } + @ApiOperation(value = "鎵归噺涓婁紶鏂囦欢鍒癋TP") + @RequestMapping(method= RequestMethod.POST,value="/uploadBatchOld") + @ResponseBody + public void uploadBatchOld( HttpServletRequest request, HttpServletResponse response, String folder) throws Exception { if(Objects.isNull(folder)){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } -- Gitblit v1.9.3