文件存储 MinIO、阿里云、腾讯云、七牛云

/**
 * 文件上传本地磁盘 v4.0.7+
 * @author ThinkGem
 * @version 2018年8月17日
 */
@Service
public class FileUploadServiceExtendImpl extends FileUploadServiceExtendSupport{
	
	/**
	 * 验证文件是否真实的存在
	 * @param fileEntity 文件实体信息
	 * @return 文件存在true，不存在false
	 */
	public boolean fileExists(FileEntity fileEntity){
		String path = fileEntity.getFileRealPath();
		File localFile = new File(path);
		return localFile.exists();
	}

	/**
	 * 上传文件，首次上传文件都调用（保存到文件实体表之前调用） v4.1.6
	 * 
	 * ※ 提示：需要分片上传时可重写本方法，若不需要分片可删除此方法。
	 * 
	 * @param fileEntity 文件实体信息
	 * @param fileEntity.fileRealPath 文件实际磁盘路径
	 * @param params.file 要上传的文件，params.* 其它相关的参数
	 * @return 如果上传异常或有问题，则返回错误信息数据 {result:"false", message:"文件格式错误"}
	 */
	public Map<String, Object> uploadFile(FileEntity fileEntity, FileUploadParams params){

		// 因为此方法比较复杂，建议使用 uploadFile(FileEntity fileEntity) 方法 处理第三方存储，这个比较方便

		// 若不想让文件存储到本地，直接存储到文件服务器，可以实现此方法【否则，不要重写，请删除此函数】

		Map<String, Object> dataMap = MapUtils.newHashMap();
		
		try {
			// 如果是分片上传
			Long chunks = params.getChunks(); 		// 共多少片
			Long chunk = params.getChunk();			// 当前分片
			Long chunkSize = params.getChunkSize();	// 分片大小
			Long size = params.getSize();			// 文件大小
			MultipartFile file = params.getFile();	// 上传的文件

			//System.out.println("文件信息：chunks="+chunks+", chunk="+chunk
			//		+", chunkSize="+chunkSize+", size="+size);
	        if (chunks != null && chunk != null && chunkSize != null && size != null) {

	        	// 如果总共一片（文件较小，只有一片）
	        	if (chunks.longValue() == 1 && chunk.longValue() == 0){

					//System.out.println("总共一片");

	        		InputStream inputStream = file.getInputStream(); 	// 当前分片数据（文件流方式）
	        		byte[] bytes = file.getBytes(); 					// 当前分片数据（字节方式方式）

					// Step1：上传文件到文件服务器

	        	}
	        	// 上传分片数据
	        	else{

					long offset = chunk * chunkSize;					// 偏移位置（当前分片的字节起始位置）
	        		InputStream inputStream = file.getInputStream(); 	// 当前分片数据（文件流方式）
	        		byte[] bytes = file.getBytes(); 					// 当前分片数据（字节方式方式）

					// Step2：根据当前分片上传数据（自己根据需求实现存储）
					File currentFile = 当前已上传的文件对象;

        			// 如果全部上传完成，将临时文件转换为正式文件
        			if (currentFile.length() == size.longValue()){

						//System.out.println("最后一片：tmpSize="+tmpFile.length()
						//		+", size="+size.longValue()+",  "+tmpFile+"  "+localFile);
        				
						// Step3：通知文件所有文件分片已经上传完成
        				
        			}else{
						//System.out.println("当前分片："+String.valueOf(chunk + 1)+"/"+String.valueOf(chunks));
						dataMap.put("message", Global.getText("sys.file.chunkUploading",
		        						String.valueOf(chunk + 1), String.valueOf(chunks)));
						dataMap.put("result", Global.TRUE);
						return dataMap;
        			}
	        	}
	        }else{
				//System.out.println("不是分片上传");

				InputStream inputStream = file.getInputStream(); 	// 当前分片数据（文件流方式）
				byte[] bytes = file.getBytes(); 					// 当前分片数据（字节方式方式）

				// Step4：上传文件到文件服务器

	        }
		} catch (IOException e) {
			logger.error("文件保存失败：" + fileEntity.getFileUrl(), e);
		}

		// 这里可以写一些代码，处理文件信息。

		// 比如：文件内容类型的验证；图像压缩；图像数据存储 

		// 存储文件附加信息：fileEntity.setFileMetaMap(map);

		return null;
	}

	/**
	 * 上传文件，首次上传文件都调用（保存到文件实体表之前调用）
	 * @param fileEntity 文件实体信息
	 * @param fileEntity.getFileRealPath() 文件实际磁盘路径
	 * @exception 支持抛出 throw ServiceException("文件不符合要求") v4.1.5
	 */
	public void uploadFile(FileEntity fileEntity){

		// 当前上传的文件磁盘路径
		String fileName = fileEntity.getFileRealPath();

		try {
			// 这里写上传到文件服务器的代码

		} catch (Exception e) {
			throw ExceptionUtils.unchecked(e);
		} finally {
			// 文件上传后删除临时文件
			FileUtils.deleteFile(fileName);
		}
	}
	
	/**
	 * 保存上传文件信息，每次上传都调用（保存文件和用户关系数据之前调用）
	 * @param fileUpload 文件上传信息，包括文件实体
	 * @exception 支持抛出 throw ServiceException("文件不符合要求") v4.1.5
	 */
	public void saveUploadFile(FileUpload fileUpload){
		// 如果想上传后，即保存业务关联的信息，可以打开如下注释
		//FileEntity fileEntity = fileUpload.getFileEntity();
		//FileUploadParams params = fileEntity.getFileUploadParams();
		//fileUpload.setBizKey(params.getBizKey());
		//fileUpload.setBizType(params.getBizType());
	}
	
	/**
	 * 获取访问文件的URL地址
	 * @param fileUpload 文件上传的信息，包括文件实体
	 * @return 无文件下载地址，则返回null，方便后续处理
	 */
	public String getFileUrl(FileUpload fileUpload){
		return fileUpload.getFileEntity().getFileUrl();
	}
	
	/**
	 * 下载文件到浏览器
	 * @param fileUpload 文件上传的信息
	 * @param request 请求对象，可能断点续传用
	 * @param response 响应对象，输出文件流使用
	 * @return 如果不是文件流数据，也可返回文件的URL地址进行跳转，如果文件不存在返回404字符串
	 */
	public String downFile(FileUpload fileUpload, HttpServletRequest request, HttpServletResponse response){
		FileEntity fileEntity = fileUpload.getFileEntity();
		File file = new File(fileEntity.getFileRealPath());
		if (file.exists()){
			FileUtils.downFile(file, request, response, fileUpload.getFileName());
			return null;
		}
		return "404";
	}
	
}