package com.doumee.cloud.common;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.doumee.api.BaseController;
|
import com.doumee.biz.system.SystemDictDataBiz;
|
import com.doumee.core.annotation.trace.Trace;
|
import com.doumee.core.constants.ResponseStatus;
|
import com.doumee.core.exception.BusinessException;
|
import com.doumee.core.haikang.model.HKConstants;
|
import com.doumee.core.haikang.model.param.BaseResponse;
|
import com.doumee.core.haikang.model.param.request.FacePictureCheckRequest;
|
import com.doumee.core.haikang.model.param.respose.FacePictureCheckResponse;
|
import com.doumee.core.haikang.service.HKService;
|
import com.doumee.core.utils.Constants;
|
import com.doumee.core.utils.DateUtil;
|
import com.doumee.core.utils.FtpUtil;
|
import com.doumee.core.utils.aliyun.ALiYunUtil;
|
import com.doumee.dao.system.model.SystemDict;
|
import com.doumee.dao.system.model.SystemDictData;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.multipart.MultipartFile;
|
import org.springframework.web.multipart.MultipartHttpServletRequest;
|
import org.springframework.web.multipart.commons.CommonsMultipartResolver;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.File;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.io.PrintWriter;
|
import java.util.*;
|
|
/**
|
* @author Eva.Caesar Liu
|
* @date 2023/02/14 11:14
|
*/
|
@Api(tags = "公共上传接口")
|
@Trace(exclude = true)
|
@RestController
|
@RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/public")
|
@Slf4j
|
public class PublicCloudController extends BaseController {
|
@Autowired
|
private SystemDictDataBiz systemDictDataBiz;
|
|
|
|
public static FtpUtil ftp = null;
|
|
@ApiOperation(value = "批量上传文件到FTP")
|
@RequestMapping(method= RequestMethod.POST,value="/uploadBatch")
|
@ResponseBody
|
public void uploadBatch(HttpServletRequest request, HttpServletResponse response, String folder) throws Exception {
|
if(Objects.isNull(folder)){
|
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);
|
CommonsMultipartResolver multipartResovler = new CommonsMultipartResolver();
|
if (multipartResovler.isMultipart(request)) {
|
MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
|
List<MultipartFile> fileList = multipartRequest.getFiles("file");
|
Iterator<String> it = multipartRequest.getFileNames();
|
JSONArray jsonArray = new JSONArray();
|
|
if (fileList.size() > 0) {
|
//遍历文件列表
|
Iterator<MultipartFile> fileIte = fileList.iterator();
|
Integer index = Constants.ONE;
|
while (fileIte.hasNext()) {
|
//获得每一个文件
|
MultipartFile file = fileIte.next();
|
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.size()),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;
|
}
|
|
}
|
|
// while (it.hasNext()) {
|
// MultipartFile file = multipartRequest.getFile(it.next());
|
// String originname = file.getOriginalFilename();
|
// 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.uploadInputstream(is,fileName);
|
// 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);
|
// }
|
// }
|
context.put("data",jsonArray);
|
}
|
} catch (Exception e) {
|
log.error("【上传FTP失败】======================"+e.getMessage());
|
context.put("code", 0);
|
context.put("message", "上传失败");
|
context.put("errno",0);
|
writerJson(response, context);
|
return;
|
|
}
|
writerJson(response, context);
|
return;
|
}
|
|
@ApiOperation(value = "上传文件到FTP")
|
@RequestMapping(method= RequestMethod.POST,value="/upload")
|
@ResponseBody
|
public void upload(HttpServletRequest request, HttpServletResponse response, String folder,Integer isFace) throws Exception {
|
// folder = systemDictDataBiz.queryByCode(Constants.FTP,folder).getCode();
|
Date d1 = new Date();
|
log.error("总得上传文件成功=============开始========="+DateUtil.getPlusTime2(d1));
|
folder =StringUtils.defaultString(folder).replace("/", "");
|
String prefixPath = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode();
|
InputStream is = null;
|
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();
|
}
|
|
CommonsMultipartResolver multipartResovler = new CommonsMultipartResolver();
|
if (multipartResovler.isMultipart(request)) {
|
MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
|
Iterator<String> it = multipartRequest.getFileNames();
|
while (it.hasNext()) {
|
MultipartFile file = multipartRequest.getFile(it.next());
|
String originname = file.getOriginalFilename();
|
is = file.getInputStream();
|
String endType = ".jpg";
|
if(originname.indexOf(".")>0){
|
endType=originname.substring(originname.lastIndexOf("."),originname.length());
|
}
|
String date = DateUtil.getNowShortDate();
|
String fName = date+"/"+ UUID.randomUUID()+endType;
|
String fileName = folder+"/"+fName;
|
boolean r = ftp.uploadInputstream(is,fileName);
|
if(r){
|
if(Objects.nonNull(isFace) && Constants.equalsInteger(isFace,Constants.ZERO)){
|
//验证人脸评分
|
//人脸评分
|
FacePictureCheckRequest param = new FacePictureCheckRequest();
|
String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode();
|
param.setFacePicUrl(prefixUrl + fileName);
|
BaseResponse<FacePictureCheckResponse> responseBaseResponse = HKService.facePictureCheck(param);
|
if(responseBaseResponse == null || !StringUtils.equals(responseBaseResponse.getCode(), HKConstants.RESPONSE_SUCCEE)){
|
context.put("code", 0);
|
context.put("message", "对不起，人脸评分获取数据失败~");
|
context.put("errno",0);
|
writerJson(response, context);
|
return;
|
}
|
FacePictureCheckResponse facePictureCheckResponse = responseBaseResponse.getData();
|
if(Objects.isNull(facePictureCheckResponse) || Objects.isNull(facePictureCheckResponse.getCheckResult())){
|
context.put("code", 0);
|
context.put("message", "对不起，人脸评分获取数据失败~");
|
context.put("errno",0);
|
writerJson(response, context);
|
return;
|
}
|
if(!facePictureCheckResponse.getCheckResult()){
|
context.put("code", 0);
|
context.put("message", facePictureCheckResponse.getStatusMessage());
|
context.put("errno",0);
|
writerJson(response, context);
|
return;
|
}
|
|
}
|
|
context.put("success", true);
|
context.put("code", 200);
|
context.put("errno",0);
|
JSONObject fileJSON = new JSONObject();
|
// fileJSON.put("prefixPath", prefixPath);
|
// fileJSON.put("folder", folder);
|
fileJSON.put("url", prefixPath+fileName);
|
fileJSON.put("imgaddr", fName);
|
fileJSON.put("imgname", fileName);
|
fileJSON.put("originname", originname);
|
context.put("data",fileJSON);
|
context.put("message","请求成功");
|
writerJson(response, context);
|
Date d2= new Date();
|
log.error("总的上传文件成功=============结束========="+DateUtil.getPlusTime2(d2) +"耗时秒："+( (d2.getTime()-d1.getTime()) /1000));
|
return;
|
}
|
}
|
}
|
} catch (Exception e) {
|
log.error("【上传FTP失败】======================"+e.getMessage());
|
}
|
context.put("code", 0);
|
context.put("message", "上传失败");
|
context.put("errno",0);
|
writerJson(response, context);
|
return;
|
}
|
|
public void upload(HttpServletRequest request, HttpServletResponse response, String folder, String bucketName,
|
String access_id, String access_key, String resourcePath, String endpoint) throws Exception {
|
response.setCharacterEncoding("UTF-8");
|
response.setContentType("text/html;charset=UTF-8");
|
Map<String, Object> context = new HashMap<>();
|
CommonsMultipartResolver multipartResovler = new CommonsMultipartResolver();
|
if (multipartResovler.isMultipart(request)) {
|
MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
|
Iterator<String> it = multipartRequest.getFileNames();
|
while (it.hasNext()) {
|
MultipartFile file = multipartRequest.getFile((String) it.next());// file
|
// multipartRequest.getFile((String)
|
// it.next());
|
if (file != null) {
|
// 1、上传到服务器临时文件夹
|
String uploadFileName = file.getOriginalFilename();
|
String originname = uploadFileName;
|
if (originname.lastIndexOf("/") >= 0) {
|
originname = originname.substring(originname.lastIndexOf("/") + 1);
|
}
|
String nfix = "";// 后缀名
|
if (StringUtils.isNotBlank(uploadFileName)) {
|
nfix = uploadFileName.substring(uploadFileName.lastIndexOf("."));
|
}
|
if (StringUtils.equalsIgnoreCase(nfix, ".exe")) {
|
context.put("code", 4000);
|
context.put("message", "对不起，文件格式\".exe\"上传有误！");
|
return;
|
}
|
if (StringUtils.equalsIgnoreCase(nfix, ".dll")) {
|
context.put("code", 4000);
|
context.put("message", "对不起，文件格式\".dll\"上传有误！");
|
return;
|
}
|
String nowDate = DateUtil.getNowShortDate();// 当前时间（年月日）
|
String fileName = UUID.randomUUID().toString() + nfix;
|
String tempFileName = nowDate + "/" + fileName;
|
String key = folder + tempFileName;// 文件名
|
ALiYunUtil obs = new ALiYunUtil(endpoint,access_id, access_key);
|
if (obs.uploadOnlineObject(file.getInputStream(),bucketName, key,null)) {
|
// 移动成功,返回文件名
|
// sendSuccessMessage(response, resourcePath+key);
|
context.put("success", true);
|
context.put("code", 200);
|
context.put("errno",0);
|
JSONObject fileJSON = new JSONObject();
|
fileJSON.put("url", resourcePath + key);
|
fileJSON.put("imgaddr", tempFileName);
|
fileJSON.put("imgname", fileName);
|
fileJSON.put("originname", originname);
|
context.put("data",fileJSON);
|
context.put("message","请求成功");
|
writerJson(response, context);
|
return;
|
} else {
|
// 移动失败
|
context.put("code", 0);
|
context.put("message", "上传失败");
|
writerJson(response, context);
|
return;
|
}
|
}
|
|
}
|
}
|
context.put("code", 0);
|
context.put("message", "上传失败");
|
context.put("errno",0);
|
writerJson(response, context);
|
return;
|
}
|
|
public static void writerJson(HttpServletResponse response, Object object) {
|
response.setContentType("application/json");
|
writer(response, JSONObject.toJSONString(object));
|
}
|
|
private static void writer(HttpServletResponse response, String str) {
|
try {
|
StringBuffer result = new StringBuffer();
|
//设置页面不缓存
|
response.setHeader("Pragma", "No-cache");
|
response.setHeader("Cache-Control", "no-cache");
|
response.setCharacterEncoding("UTF-8");
|
PrintWriter out = null;
|
out = response.getWriter();
|
out.print(str);
|
out.flush();
|
out.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
|
public void uploadFileLocal(HttpServletRequest request, String folder, HttpServletResponse response, String rootPath,String dir) throws Exception {
|
response.setCharacterEncoding("UTF-8");
|
response.setContentType("text/html;charset=UTF-8");
|
CommonsMultipartResolver multipartResovler = new CommonsMultipartResolver();
|
Map<String, Object> context = new HashMap<>();
|
if (multipartResovler.isMultipart(request)) {
|
MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
|
Iterator<String> it = multipartRequest.getFileNames();
|
while (it.hasNext()) {
|
MultipartFile file = multipartRequest.getFile((String) it.next());// file
|
// =
|
// (CommonsMultipartFile)
|
// multipartRequest.getFile((String)
|
// it.next());
|
if (file != null) {
|
if (file.getSize() > 200 * 1024 * 1024L) {
|
context.put("code", 4000);
|
context.put("message", "上传文件过大");
|
return;
|
}
|
System.out.println(file.getOriginalFilename());
|
if (file.getOriginalFilename() == null) {
|
context.put("code", 4000);
|
context.put("message", "文件名不可为空");
|
return;
|
}
|
/*
|
* if(file.getOriginalFilename().contains(",")||file.getOriginalFilename().
|
* contains(" ")){ sendFailureMessage(response,"文件名称有误,不可含有逗号等特殊字符"); }
|
*/
|
|
String nowDate = DateUtil.getNowShortDate();
|
folder += nowDate + "/";
|
String strDirPath = rootPath + folder;
|
File dirPath = new File(strDirPath);
|
if (!dirPath.exists()) {
|
dirPath.mkdirs();
|
}
|
String uploadFileName = file.getOriginalFilename();
|
String x = UUID.randomUUID().toString().replace("-", "")
|
+ uploadFileName.substring(uploadFileName.lastIndexOf("."));
|
String fileName = folder + x;
|
String fileNames = nowDate + "/" + x;
|
uploadFileName = uploadFileName.replace(" ", "");
|
uploadFileName = uploadFileName.replace("，", ",");
|
uploadFileName = uploadFileName.replaceAll(",", "-");
|
System.err.println("R:" + fileName);
|
String fileAndPath = dir + fileName;
|
System.err.println("A:" + fileAndPath);
|
// 判断如果临时目录中存在相同名称的文件先删除，在上传
|
File tempFile = new File(rootPath + fileName);
|
if (tempFile.isFile() && tempFile.exists()) {
|
tempFile.getAbsoluteFile().delete();
|
}
|
// 上传到服务器临时文件夹
|
file.transferTo(tempFile);
|
// 转移到FTP服务器
|
String nfix = "";
|
if (null != uploadFileName) {
|
nfix = uploadFileName.substring(uploadFileName.lastIndexOf("."));
|
}
|
|
if (StringUtils.equalsIgnoreCase(nfix, ".exe")) {
|
context.put("code", 4000);
|
context.put("message", "对不起，文件格式\".exe\"上传有误！");
|
return;
|
}
|
if (StringUtils.equalsIgnoreCase(nfix, ".dll")) {
|
context.put("code", 4000);
|
context.put("message", "对不起，文件格式\".dll\"上传有误！");
|
return;
|
}
|
|
String remoteName = fileName;
|
String remoteFileName = fileAndPath;
|
|
/* Map map = new HashMap();
|
map.put("url", remoteFileName);
|
map.put("alt", uploadFileName);
|
map.put("href", remoteFileName);
|
List maps = Arrays.asList(remoteFileName);*/
|
|
if (true) {
|
// 关闭FTP流
|
// 移动成功,返回文件名
|
|
/*context.put("error", 0);
|
context.put("url", remoteFileName);
|
context.put("fullurl", remoteFileName);
|
context.put("fname", uploadFileName);
|
context.put("data", maps);
|
context.put("halfurl", fileNames);*/
|
|
context.put("success", true);
|
context.put("code", 200);
|
context.put("errno",0);
|
JSONObject fileJSON = new JSONObject();
|
fileJSON.put("url", remoteFileName);
|
fileJSON.put("imgaddr", fileNames);
|
fileJSON.put("imgname", uploadFileName);
|
fileJSON.put("originname", uploadFileName);
|
context.put("data",fileJSON);
|
context.put("message","请求成功");
|
|
writerJson(response, context);
|
return;
|
} else {
|
// 移动失败
|
context.put("code", 0);
|
context.put("message", "上传失败");
|
writerJson(response, context);
|
}
|
}
|
context.put("code", 0);
|
context.put("message", "上传失败");
|
writerJson(response, context);
|
return;
|
}
|
}
|
context.put("code", 0);
|
context.put("message", "上传失败");
|
writerJson(response, context);
|
return;
|
}
|
}
|
