package com.product.file.controller;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.product.common.lang.StringUtils;
|
import com.product.core.config.CoreConst;
|
import com.product.core.controller.support.AbstractBaseController;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.entity.RequestParameterEntity;
|
import com.product.core.exception.BaseException;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.file.config.CmnConst;
|
import com.product.file.config.FileCode;
|
import com.product.file.service.FileManagerService;
|
import com.product.module.sys.version.ApiVersion;
|
import com.product.util.BaseUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
|
/**
|
* Copyright LX-BASE
|
*
|
* @Title: FileManagerController
|
* @Project: LX-BASE-SERVER
|
* @Date: 2020-06-17 16:54
|
* @Author: LiuChao
|
* @Description: 文件管理
|
*/
|
@RequestMapping("/api/fileManager")
|
@RestController
|
public class FileManagerController extends AbstractBaseController {
|
|
@Autowired
|
public FileManagerService fileManagerService;
|
|
|
/**
|
* @param uuid
|
* @param response
|
* @return
|
*/
|
@GetMapping("/get-static-file/{version}")
|
@ApiVersion(1)
|
public String getStaticFile(@RequestParam("uuid") String uuid, HttpServletResponse response) {
|
try {
|
// 没有登录，白名单中 该接口中不能获取 token 和 当前用户
|
fileManagerService.getStaticFile(uuid, response);
|
return OK();
|
} catch (BaseException e) {
|
e.printStackTrace();
|
return error(e);
|
} catch (Exception e) {
|
e.printStackTrace();
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return error(FileCode.GET_FILE_FAIL);
|
}
|
}
|
|
|
/**
|
* 获取客户上传的文件总大小
|
*
|
* @param request 请求
|
* @return 结果
|
*/
|
@RequestMapping(value = "/find-client-file-uesd-capacity/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String findClientFileUsedCapacity(HttpServletRequest request) {
|
try {
|
FieldSetEntity fse = null;
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
RequestParameterEntity rpe = (RequestParameterEntity) bean;
|
if (null != rpe && null != rpe.getFormData()) {
|
fse = rpe.getFormData();
|
}
|
if (fse == null) {
|
SpringMVCContextHolder.getSystemLogger().error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
return this.error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
}
|
|
long usedCapacity = fileManagerService.findClientFileUsedCapacity(fse.getString("client_uuid"));
|
JSONObject data = new JSONObject();
|
data.put("used_capacity", String.valueOf(usedCapacity));
|
JSONObject result = new JSONObject();
|
result.put("data", data);
|
result.put("msg", FileCode.SUCCESS.getText());
|
result.put("code", "200");
|
result.put("status", "success");
|
return result.toString();
|
} catch (BaseException e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(e.getCode(), e.getMessageInfo());
|
} catch (Exception e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
e.printStackTrace();
|
return error(FileCode.GET_DATA_FAIL.getValue(), FileCode.GET_DATA_FAIL.getText());
|
}
|
}
|
|
/**
|
* 获取客户剩余的文件总大小
|
*
|
* @param request 请求
|
* @return 结果
|
*/
|
@RequestMapping(value = "/find-client-file-residue-capacity/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String findClientFileResidueCapacity(HttpServletRequest request) {
|
try {
|
FieldSetEntity fse = null;
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
RequestParameterEntity rpe = (RequestParameterEntity) bean;
|
if (null != rpe && null != rpe.getFormData()) {
|
fse = rpe.getFormData();
|
}
|
if (fse == null) {
|
SpringMVCContextHolder.getSystemLogger().error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
return this.error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
}
|
|
long residueCapacity = fileManagerService.findClientFileResidueCapacity(fse.getString("client_uuid"));
|
JSONObject data = new JSONObject();
|
data.put("residue_capacity", String.valueOf(residueCapacity));
|
JSONObject result = new JSONObject();
|
result.put("data", data);
|
result.put("msg", FileCode.SUCCESS.getText());
|
result.put("code", "200");
|
result.put("status", "success");
|
return result.toString();
|
} catch (BaseException e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(e.getCode(), e.getMessageInfo());
|
} catch (Exception e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
e.printStackTrace();
|
return error(FileCode.GET_DATA_FAIL.getValue(), FileCode.GET_DATA_FAIL.getText());
|
}
|
}
|
|
/**
|
* 验证是否允许上传的文件类型
|
*
|
* @param request 请求
|
* @return 结果
|
*/
|
@RequestMapping(value = "/check-is-allowed-file-type/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String checkIsAllowedFileType(HttpServletRequest request) {
|
try {
|
FieldSetEntity fse = null;
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
RequestParameterEntity rpe = (RequestParameterEntity) bean;
|
if (null != rpe && null != rpe.getFormData()) {
|
fse = rpe.getFormData();
|
}
|
if (fse == null) {
|
SpringMVCContextHolder.getSystemLogger().error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
return this.error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
}
|
|
boolean f = fileManagerService.checkIsAllowedFileType(fse.getString("attachment_name"));
|
return f ? this.OK() : this.error(FileCode.CHECK_FAIL.getValue(), FileCode.CHECK_FAIL.getText());
|
} catch (BaseException e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(e.getCode(), e.getMessageInfo());
|
} catch (Exception e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
e.printStackTrace();
|
return error(FileCode.CHECK_FAIL.getValue(), FileCode.CHECK_FAIL.getText());
|
}
|
}
|
|
/**
|
* 获取原始域名
|
*
|
* @return 结果
|
*/
|
@RequestMapping(value = "/find-source-domain/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String findSourceDomain() {
|
try {
|
String sourceDomain = fileManagerService.findSourceDomain();
|
|
JSONObject data = new JSONObject();
|
data.put("source_domain", sourceDomain);
|
JSONObject result = new JSONObject();
|
result.put("data", data);
|
result.put("msg", FileCode.SUCCESS.getText());
|
result.put("code", "200");
|
result.put("status", "success");
|
return result.toString();
|
} catch (Exception e) {
|
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
e.printStackTrace();
|
return error(FileCode.FIND_SOURCE_DOMAIN_FAIL.getValue(), FileCode.FIND_SOURCE_DOMAIN_FAIL.getText());
|
}
|
}
|
|
/**
|
* 手动触发无用数据清空
|
*
|
* @return 结果
|
*/
|
@RequestMapping(value = "/clear-no-used-data/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String clearNoUsedData() {
|
try {
|
boolean reuslt = fileManagerService.autoClearNoUsedData();
|
JSONObject result = new JSONObject();
|
result.put("msg", FileCode.SUCCESS.getText());
|
result.put("code", "200");
|
result.put("status", reuslt);
|
return result.toString();
|
} catch (Exception e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
e.printStackTrace();
|
return error(FileCode.CLEAR_NO_USED_DATA_FAIL.getValue(), FileCode.CLEAR_NO_USED_DATA_FAIL.getText());
|
}
|
}
|
|
|
/**
|
* 文件刪除
|
*
|
* @param request
|
* @return
|
*/
|
@RequestMapping(value = "/delete-file/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String deleteFile(HttpServletRequest request) {
|
try {
|
FieldSetEntity fse = null;
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
RequestParameterEntity rpe = (RequestParameterEntity) bean;
|
if (null != rpe && null != rpe.getFormData()) {
|
fse = rpe.getFormData();
|
}
|
if (fse == null) {
|
SpringMVCContextHolder.getSystemLogger().error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
return this.error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
}
|
return BaseUtil.success(fileManagerService.delFiles(fse), null);
|
} catch (Exception e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
e.printStackTrace();
|
return error(FileCode.CLEAR_NO_USED_DATA_FAIL.getValue(), FileCode.CLEAR_NO_USED_DATA_FAIL.getText());
|
}
|
}
|
|
|
/**
|
* 上传文件
|
*
|
* @return 结果
|
*/
|
@RequestMapping(value = "/upload-file/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String uploadFile(HttpServletRequest request) {
|
try {
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
RequestParameterEntity rpe = (RequestParameterEntity) bean;
|
FieldSetEntity fieldSetEntity = fileManagerService.uploadFile(rpe);
|
return OK_List(fieldSetEntity);
|
} catch (BaseException e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
e.printStackTrace();
|
return error(e.getCode(), e.getMessage());
|
} catch (Exception e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
e.printStackTrace();
|
return error(FileCode.UPLOAD_FILE_FAIL.getValue(), FileCode.UPLOAD_FILE_FAIL.getText());
|
}
|
}
|
|
/**
|
* 下载文件或者在线预览
|
*
|
* @return 结果
|
*/
|
@RequestMapping(value = "/get-file-content/{version}", method = RequestMethod.GET)
|
@ApiVersion(1)
|
public String getFileContents(HttpServletRequest request, HttpServletResponse response) {
|
try {
|
FieldSetEntity fse = null;
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
RequestParameterEntity rpe = (RequestParameterEntity) bean;
|
if (null != rpe && null != rpe.getFormData()) {
|
fse = rpe.getFormData();
|
}
|
if (fse == null) {
|
SpringMVCContextHolder.getSystemLogger().error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
return this.error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
}
|
SpringMVCContextHolder.getSystemLogger().info("通过GET请求获取附件内容");
|
// 正式代码
|
fileManagerService.getFileContent(fse, response);
|
return OK();
|
} catch (Exception e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
e.printStackTrace();
|
return error(FileCode.GET_FILE_CONTENT_FAIL.getValue(), FileCode.GET_FILE_CONTENT_FAIL.getText());
|
}
|
}
|
|
/**
|
* 下载文件或者在线预览
|
*
|
* @return 结果
|
*/
|
@RequestMapping(value = "/get-file-content/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String getFileContent(HttpServletRequest request, HttpServletResponse response) {
|
try {
|
FieldSetEntity fse = null;
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
RequestParameterEntity rpe = (RequestParameterEntity) bean;
|
if (null != rpe && null != rpe.getFormData()) {
|
fse = rpe.getFormData();
|
}
|
if (fse == null) {
|
SpringMVCContextHolder.getSystemLogger().error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
return this.error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
}
|
// 正式代码
|
fileManagerService.getFileContent(fse, response);
|
/*===test-start===*/
|
// String tempPath = fse.getString("tempPath");
|
// File file = new File(tempPath);
|
// OutputStream sos = new FileOutputStream(file);
|
// fileManagerService.getFileContent(fse, sos);
|
// sos.close();
|
/*===test-start===*/
|
return OK();
|
} catch (BaseException e) {
|
e.printStackTrace();
|
return error(e);
|
} catch (Exception e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
e.printStackTrace();
|
return error(FileCode.GET_FILE_CONTENT_FAIL.getValue(), FileCode.GET_FILE_CONTENT_FAIL.getText());
|
}
|
}
|
|
/**
|
* 批量打包下载
|
*
|
* @return 结果
|
*/
|
@RequestMapping(value = "/download-file-zip/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String downLoadFileZip(HttpServletRequest request, HttpServletResponse response) {
|
try {
|
FieldSetEntity fse = null;
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
RequestParameterEntity rpe = (RequestParameterEntity) bean;
|
if (null != rpe && null != rpe.getFormData()) {
|
fse = rpe.getFormData();
|
}
|
if (fse == null) {
|
SpringMVCContextHolder.getSystemLogger().error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
return this.error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
|
}
|
|
response.setContentType("multipart/form-data");
|
// 正式代码
|
fileManagerService.downLoadFileZip(fse, response);
|
|
/*===test-start===*/
|
// String tempPath ="D:\\Desktop\\ccc.zip";
|
// File file = new File(tempPath);
|
// OutputStream sssos = new FileOutputStream(file);
|
// fileManagerService.downLoadFileZip(fse, sssos);
|
// sssos.close();
|
/*===test-start===*/
|
return OK();
|
} catch (Exception e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
e.printStackTrace();
|
return error(FileCode.GET_FILE_CONTENT_FAIL.getValue(), FileCode.GET_FILE_CONTENT_FAIL.getText());
|
}
|
}
|
}
|
