|
|
@ -0,0 +1,78 @@
|
|
|
package com.yihu.jw.entrance.file_upload;
|
|
|
|
|
|
import com.yihu.jw.file_upload.FileUploadService;
|
|
|
import com.yihu.jw.restmodel.iot.common.UploadVO;
|
|
|
import com.yihu.jw.restmodel.web.ObjEnvelop;
|
|
|
import com.yihu.jw.restmodel.web.endpoint.EnvelopRestEndpoint;
|
|
|
import com.yihu.jw.rm.base.BaseRequestMapping;
|
|
|
import io.swagger.annotations.Api;
|
|
|
import io.swagger.annotations.ApiOperation;
|
|
|
import io.swagger.annotations.ApiParam;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.web.bind.annotation.PostMapping;
|
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
import org.springframework.web.bind.annotation.RequestParam;
|
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
|
import org.springframework.web.multipart.MultipartFile;
|
|
|
|
|
|
import java.io.InputStream;
|
|
|
import java.util.Map;
|
|
|
|
|
|
/**
|
|
|
* 文件上传公共类
|
|
|
*/
|
|
|
@RestController
|
|
|
@RequestMapping(BaseRequestMapping.FileUpload.PREFIX)
|
|
|
@Api(tags = "文件上传相关操作", description = "文件上传相关操作")
|
|
|
public class FileUploadEndpoint extends EnvelopRestEndpoint {
|
|
|
|
|
|
@Value("${fastDFS.fastdfs_file_url}")
|
|
|
private String fastdfs_file_url;
|
|
|
@Autowired
|
|
|
FileUploadService fileUploadService;
|
|
|
|
|
|
@PostMapping(value = BaseRequestMapping.FileUpload.UPLOAD_STREAM_IMG)
|
|
|
@ApiOperation(value = "文件流上传图片", notes = "文件流上传图片")
|
|
|
public ObjEnvelop<UploadVO> uploadImg(@ApiParam(value = "文件", required = true)
|
|
|
@RequestParam(value = "file", required = true) MultipartFile file) throws Exception{
|
|
|
// 得到文件的完整名称 xxx.txt
|
|
|
String originalFilename = file.getOriginalFilename();
|
|
|
InputStream inputStream = file.getInputStream();
|
|
|
UploadVO uploadVO = fileUploadService.uploadImg(inputStream,originalFilename,file.getSize(),fastdfs_file_url);
|
|
|
return success("上传成功", uploadVO);
|
|
|
}
|
|
|
|
|
|
|
|
|
@PostMapping(value = BaseRequestMapping.FileUpload.UPLOAD_STREAM_ATTACHMENT)
|
|
|
@ApiOperation(value = "文件流上传附件", notes = "文件流上传附件")
|
|
|
public ObjEnvelop<UploadVO> uploadAttachment(@ApiParam(value = "文件", required = true)
|
|
|
@RequestParam(value = "file", required = true) MultipartFile file) throws Exception{
|
|
|
String originalFilename = file.getOriginalFilename();
|
|
|
InputStream inputStream = file.getInputStream();
|
|
|
UploadVO uploadVO = fileUploadService.uploadAttachment(inputStream,originalFilename,file.getSize(),fastdfs_file_url);
|
|
|
return success("上传成功", uploadVO);
|
|
|
}
|
|
|
|
|
|
@PostMapping(value = BaseRequestMapping.FileUpload.UPLOAD_STREAM)
|
|
|
@ApiOperation(value = "文件流上传文件", notes = "文件流上传文件")
|
|
|
public ObjEnvelop<UploadVO> uploadStream(@ApiParam(value = "文件", required = true)
|
|
|
@RequestParam(value = "file", required = true) MultipartFile file) throws Exception{
|
|
|
UploadVO uploadVO = new UploadVO();
|
|
|
// 得到文件的完整名称 xxx.txt
|
|
|
String originalFilename = file.getOriginalFilename();
|
|
|
InputStream inputStream = file.getInputStream();
|
|
|
uploadVO = fileUploadService.uploadStream(inputStream,originalFilename,fastdfs_file_url);
|
|
|
|
|
|
return success("上传成功", uploadVO);
|
|
|
}
|
|
|
|
|
|
@PostMapping(value = BaseRequestMapping.FileUpload.UPLOAD_STRING)
|
|
|
@ApiOperation(value = "base64上传图片",notes = "base64上传图片")
|
|
|
public ObjEnvelop<UploadVO> uploadImages(@ApiParam(name = "jsonData", value = "头像转化后的输入流")
|
|
|
@RequestParam(value = "jsonData", required = true) String jsonData) throws Exception {
|
|
|
UploadVO uploadVO = fileUploadService.uploadImages(jsonData,fastdfs_file_url);
|
|
|
return success("上传成功", uploadVO);
|
|
|
}
|
|
|
|
|
|
}
|
