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;
			String uuid = request.getParameter(CoreConst.UUID);
			String onlineView = request.getParameter(CmnConst.NEED_ONLINE_VIEW);

			if (StringUtils.isEmpty(uuid)) {
				SpringMVCContextHolder.getSystemLogger().error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
				return this.error(FileCode.FORM_NODATA.getValue(), FileCode.FORM_NODATA.getText());
			}
			fse = new FieldSetEntity();
			fse.setTableName(CmnConst.PRODUCT_SYS_ATTACHMENTS);
			fse.setValue(CoreConst.UUID, uuid);
			fse.setValue(CmnConst.NEED_ONLINE_VIEW, onlineView);
			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());
		}
	}
}