From 4cb586238c078799d91e4f22a662aa00fea24eef Mon Sep 17 00:00:00 2001
From: 6c <420680616@qq.com>
Date: 星期五, 17 十月 2025 17:27:45 +0800
Subject: [PATCH] 适配存储到数据库的文件; 不需要存储到数据库的，若是集群，那么同步到集群的其他节点； 若是失败，定时任务重试，至多3次
---
src/main/java/com/product/file/controller/FileManagerController.java | 858 ++++++++++++++++++++++++++-------------------------------
1 files changed, 393 insertions(+), 465 deletions(-)
diff --git a/src/main/java/com/product/file/controller/FileManagerController.java b/src/main/java/com/product/file/controller/FileManagerController.java
index 5caf7b9..d09ef13 100644
--- a/src/main/java/com/product/file/controller/FileManagerController.java
+++ b/src/main/java/com/product/file/controller/FileManagerController.java
@@ -8,6 +8,7 @@
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;
@@ -31,401 +32,403 @@
@RestController
public class FileManagerController extends AbstractBaseController {
- @Autowired
- public FileManagerService fileManagerService;
+ @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 = "/upgrade-download/{version}", method = RequestMethod.GET)
+ @ApiVersion(1)
+ public String getAppFileContents(@RequestParam("uuid") String uuid,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) {
+ fse=new FieldSetEntity();
+ fse.setTableName("product_sys_attachments");
+ fse.setValue("uuid",uuid);
+ fse.setValue("needOnlineView", 0);
+ 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 ,true);
+ 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.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 = "";
+// 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());
+ }
+ }
/**
- * @param uuid
- * @param response
- * @return
+ * 闆嗙兢鏂囦欢鍚屾鏂规硶-鎺ユ敹
+ *
+ * @return 缁撴灉
*/
- @GetMapping("/get-static-file/{version}")
+ @RequestMapping(value = "/cluster-file-sync/{version}", method = RequestMethod.POST)
@ApiVersion(1)
- public String getStaticFile(@RequestParam("uuid") String uuid, HttpServletResponse response) {
+ public String clusterFileSync(HttpServletRequest request, HttpServletResponse response) {
try {
- // 娌℃湁鐧诲綍锛岀櫧鍚嶅崟涓� 璇ユ帴鍙ｄ腑涓嶈兘鑾峰彇 token 鍜� 褰撳墠鐢ㄦ埛
- fileManagerService.getStaticFile(uuid, response);
+ Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
+ RequestParameterEntity rpe = (RequestParameterEntity) bean;
+ fileManagerService.clusterFileSyncAccept(rpe);
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 = "/add-file-record-plan/{version}", method = RequestMethod.POST)
- @ApiVersion(1)
- public String addFileRecordPlan(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());
- }
- FieldSetEntity fs = fileManagerService.addFileRecordPlan(fse);
- return fs != null ? this.OK_List(fs) : this.error(FileCode.ADD_FILE_RECORD_FAIL.getValue(), FileCode.ADD_FILE_RECORD_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.ADD_FILE_RECORD_FAIL.getValue(), FileCode.ADD_FILE_RECORD_FAIL.getText());
- }
- }
-
- /**
- * 鏂囦欢璁板綍-鏂囦欢鏂板缁撴灉鍥炶皟
- *
- * @param request 璇锋眰
- * @return 缁撴灉
- */
- @RequestMapping(value = "/add-file-callback/{version}", method = RequestMethod.POST)
- @ApiVersion(1)
- public String addFileCallback(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());
- }
- JSONObject data = fileManagerService.addFileCallback(fse);
- 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.ADD_FILE_CALLBACK_FAIL.getValue(), FileCode.ADD_FILE_CALLBACK_FAIL.getText());
- }
- }
-
- /**
- * 鏂囦欢璁板綍-鍒犻櫎鍑嗗锛堢姸鎬佷慨鏀癸級
- *
- * @param request 璇锋眰
- * @return 缁撴灉
- */
- @RequestMapping(value = "/del-file-record-plan/{version}", method = RequestMethod.POST)
- @ApiVersion(1)
- public String delFileRecordPlan(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());
- }
- FieldSetEntity fs = fileManagerService.delFileRecordPlan(fse);
-
- return fs != null ? this.OK_List(fs) : this.error(FileCode.DELETE_FILE_PLAN_FIAL.getValue(), FileCode.DELETE_FILE_PLAN_FIAL.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.DELETE_FILE_PLAN_FIAL.getValue(), FileCode.DELETE_FILE_PLAN_FIAL.getText());
- }
- }
-
- /**
- * 鏂囦欢璁板綍-鏂囦欢鏂板缁撴灉鍥炶皟
- *
- * @param request 璇锋眰
- * @return 缁撴灉
- */
- @RequestMapping(value = "/del-file-callback/{version}", method = RequestMethod.POST)
- @ApiVersion(1)
- public String delFileCallback(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());
- }
- JSONObject data = fileManagerService.delFileCallback(fse);
- 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.DELETE_FILE_CALLBACK_FIAL.getValue(), FileCode.DELETE_FILE_CALLBACK_FIAL.getText());
- }
- }
-
- /**
- * 鑾峰彇瀹㈡埛涓婁紶鐨勬枃浠舵�诲ぇ灏�
- *
- * @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());
- }
- }
-
- /**
- * 鑾峰彇鏂囦欢璁板綍淇℃伅
- *
- * @return 缁撴灉
- */
- @RequestMapping(value = "/get-file-info/{version}", method = RequestMethod.POST)
- @ApiVersion(1)
- public String getFileInfo(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.getFileInfo(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());
- }
- }
-
- /**
- * 鏂囦欢鍒櫎
- *
- * @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();
@@ -433,82 +436,7 @@
} 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.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 (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());
+ return error(FileCode.CLUSTER_FILE_SYNC_ACCEPT_FAIL.getValue(), FileCode.CLUSTER_FILE_SYNC_ACCEPT_FAIL.getText() + ":" + BaseUtil.getErrorInfo(e).substring(0, 500));
}
}
}
--
Gitblit v1.9.2