jiaxin.lin
/
i3plus-mes-yfai
forked from I3-YF/i3plus-mes-yfai
1
0
Fork 0
Code Pull Requests Activity

注释掉obs相关接口，使用原有的文件管理系统

Browse Source
tags/yfai-mes-ext-v1.0
臧学普 12 months ago
parent f49cf4bbdb
commit acded409ab
1 changed files with 311 additions and 311 deletions
Show Stats Download Patch File Download Diff File

622
modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/controller/base/MesMediaFileCfgController.java
Unescape Escape View File

@ -1,305 +1,228 @@
package cn.estsh.i3plus.ext.mes.apiservice.controller.base; //package cn.estsh.i3plus.ext.mes.apiservice.controller.base;
//
import cn.estsh.i3plus.ext.mes.api.base.IMesMediaFileCfgService; //import cn.estsh.i3plus.ext.mes.api.base.IMesMediaFileCfgService;
import cn.estsh.i3plus.ext.mes.apiservice.config.HuaWeiCloudObsConfig; //import cn.estsh.i3plus.ext.mes.apiservice.config.HuaWeiCloudObsConfig;
import cn.estsh.i3plus.ext.mes.apiservice.utils.HuaWeiOBSUtil; //import cn.estsh.i3plus.ext.mes.apiservice.utils.HuaWeiOBSUtil;
import cn.estsh.i3plus.ext.mes.pojo.constant.MesCommonConstant; //import cn.estsh.i3plus.ext.mes.pojo.constant.MesCommonConstant;
import cn.estsh.i3plus.icloud.core.sdk.ICoreSysFileCloud; //import cn.estsh.i3plus.icloud.core.sdk.ICoreSysFileCloud;
import cn.estsh.i3plus.platform.common.exception.ImppExceptionEnum; //import cn.estsh.i3plus.platform.common.exception.ImppExceptionEnum;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil; //import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil; //import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.mes.bean.MesMediaFileCfg; //import cn.estsh.i3plus.pojo.mes.bean.MesMediaFileCfg;
import cn.estsh.i3plus.pojo.mes.repository.MesMediaFileCfgRepository; //import cn.estsh.i3plus.pojo.mes.repository.MesMediaFileCfgRepository;
import cn.estsh.impp.framework.boot.exception.ImppBusiException; //import cn.estsh.impp.framework.boot.exception.ImppBusiException;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder; //import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.fileservice.ImppFileService; //import cn.estsh.impp.framework.boot.fileservice.ImppFileService;
import cn.estsh.impp.framework.boot.util.ResultBean; //import cn.estsh.impp.framework.boot.util.ResultBean;
import com.obs.services.ObsClient; //import com.obs.services.ObsClient;
import com.obs.services.exception.ObsException; //import com.obs.services.exception.ObsException;
import com.obs.services.model.*; //import com.obs.services.model.*;
import io.swagger.annotations.Api; //import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; //import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger; //import org.slf4j.Logger;
import org.slf4j.LoggerFactory; //import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; //import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; //import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile; //import org.springframework.web.multipart.MultipartFile;
//
import javax.servlet.http.HttpServletResponse; //import javax.servlet.http.HttpServletResponse;
import java.io.File; //import java.io.File;
import java.io.FileInputStream; //import java.io.FileInputStream;
import java.io.InputStream; //import java.io.InputStream;
import java.io.OutputStream; //import java.io.OutputStream;
import java.net.URLEncoder; //import java.net.URLEncoder;
import java.util.ArrayList; //import java.util.ArrayList;
import java.util.List; //import java.util.List;
import java.util.UUID; //import java.util.UUID;
//
/** ///**
* @Description: 媒体文件维护 // * @Description: 媒体文件维护
* @CreateDate 2024/6/6 // * @CreateDate 2024/6/6
* @Author gsz // * @Author gsz
*/ // */
@Api("媒体文件维护") //@Api("媒体文件维护")
@RestController //@RestController
@RequestMapping(MesCommonConstant.MES_YANFEN + "/mesMediaFileCfg") //@RequestMapping(MesCommonConstant.MES_YANFEN + "/mesMediaFileCfg")
public class MesMediaFileCfgController extends BaseMesController<MesMediaFileCfg> { //public class MesMediaFileCfgController extends BaseMesController<MesMediaFileCfg> {
public static final Logger LOGGER = LoggerFactory.getLogger(MesMediaFileCfgController.class); // public static final Logger LOGGER = LoggerFactory.getLogger(MesMediaFileCfgController.class);
@Autowired // @Autowired
private MesMediaFileCfgRepository mediaFileCfgRepository; // private MesMediaFileCfgRepository mediaFileCfgRepository;
//
@Autowired // @Autowired
private ICoreSysFileCloud coreSysFileCloud; // private ICoreSysFileCloud coreSysFileCloud;
//
@Autowired // @Autowired
HuaWeiCloudObsConfig obsConfig; // HuaWeiCloudObsConfig obsConfig;
//
@Autowired // @Autowired
private IMesMediaFileCfgService mediaFileCfgService; // private IMesMediaFileCfgService mediaFileCfgService;
/** // /**
* fastDfs客户端 // * fastDfs客户端
*/ // */
@Autowired // @Autowired
private ImppFileService fileService; // private ImppFileService fileService;
//默认大小 // //默认大小
private static final long FILE_SIZE = 1024 * 1024; // private static final long FILE_SIZE = 1024 * 1024;
//
@PostMapping(value = "/obs/upload") // @PostMapping(value = "/obs/upload")
@ApiOperation(value = "上传媒体文件") // @ApiOperation(value = "上传媒体文件")
public ResultBean obsUploadFile(@RequestParam("file") MultipartFile file, MesMediaFileCfg mesMediaFileCfg) { // public ResultBean obsUploadFile(@RequestParam("file") MultipartFile file, MesMediaFileCfg mesMediaFileCfg) {
try { // try {
//
if (file.isEmpty()) { // if (file.isEmpty()) {
throw ImppExceptionBuilder.newInstance() // throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.REPORT.getCode()) // .setSystemID(CommonEnumUtil.SOFT_TYPE.REPORT.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode()) // .setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("不允许上传空文件") // .setErrorDetail("不允许上传空文件")
.build(); // .build();
} // }
// 校验文件大小 // // 校验文件大小
long size = file.getSize(); // long size = file.getSize();
if (size > FILE_SIZE) { // if (size > FILE_SIZE) {
throw ImppExceptionBuilder.newInstance() // throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.REPORT.getCode()) // .setSystemID(CommonEnumUtil.SOFT_TYPE.REPORT.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode()) // .setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("文件过大，请重新上传！") // .setErrorDetail("文件过大，请重新上传！")
.build(); // .build();
} // }
String fileName = file.getOriginalFilename(); // String fileName = file.getOriginalFilename();
//
PutObjectResult putObjectResult = HuaWeiOBSUtil.putObjectByMultipartFile(MesCommonConstant.OBS_BUCKET_NAME, fileName, file); // PutObjectResult putObjectResult = HuaWeiOBSUtil.putObjectByMultipartFile(MesCommonConstant.OBS_BUCKET_NAME, fileName, file);
//
String objectUrl = putObjectResult.getObjectUrl(); // String objectUrl = putObjectResult.getObjectUrl();
//
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(putObjectResult); // return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(putObjectResult);
} catch (ImppBusiException imppException) { // } catch (ImppBusiException imppException) {
LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException); // LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException);
return ResultBean.fail(imppException); // return ResultBean.fail(imppException);
} catch (Exception e) { // } catch (Exception e) {
return ImppExceptionBuilder.newInstance().buildExceptionResult(e); // return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
} // }
} // }
//
@ApiOperation("下载文件") // @ApiOperation("下载文件")
@GetMapping("/obs/download") // @GetMapping("/obs/download")
public ResultBean obsDownloadFile(@RequestParam("filePath") String filePath, HttpServletResponse response, MesMediaFileCfg mesMediaFileCfg) { // public ResultBean obsDownloadFile(@RequestParam("filePath") String filePath, HttpServletResponse response, MesMediaFileCfg mesMediaFileCfg) {
InputStream inputStream = null; // InputStream inputStream = null;
OutputStream outputStream = null; // OutputStream outputStream = null;
try { // try {
// 读取文件 // // 读取文件
inputStream = HuaWeiOBSUtil.getObject(MesCommonConstant.OBS_BUCKET_NAME, mesMediaFileCfg.getFileName()); // inputStream = HuaWeiOBSUtil.getObject(MesCommonConstant.OBS_BUCKET_NAME, mesMediaFileCfg.getFileName());
outputStream = response.getOutputStream(); // outputStream = response.getOutputStream();
response.setContentType("application/octet-stream"); // response.setContentType("application/octet-stream");
response.setHeader("Content-Disposition", "attachment; filename=" + URLEncoder.encode(mesMediaFileCfg.getFileName(), "UTF-8")); // response.setHeader("Content-Disposition", "attachment; filename=" + URLEncoder.encode(mesMediaFileCfg.getFileName(), "UTF-8"));
byte[] buffer = new byte[4096]; // byte[] buffer = new byte[4096];
int bytesRead; // int bytesRead;
while ((bytesRead = inputStream.read(buffer)) != -1) { // while ((bytesRead = inputStream.read(buffer)) != -1) {
outputStream.write(buffer, 0, bytesRead); // outputStream.write(buffer, 0, bytesRead);
} // }
outputStream.flush(); // outputStream.flush();
inputStream.close(); // inputStream.close();
outputStream.close(); // outputStream.close();
return ResultBean.success("下载成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); // return ResultBean.success("下载成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException imppException) { // } catch (ImppBusiException imppException) {
LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException); // LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException);
return ResultBean.fail(imppException); // return ResultBean.fail(imppException);
} catch (Exception e) { // } catch (Exception e) {
return ImppExceptionBuilder.newInstance().buildExceptionResult(e); // return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
} // }
//
} // }
//
//
@ApiOperation("查看文件") // @ApiOperation("查看文件")
@GetMapping("/obs/query-file") // @GetMapping("/obs/query-file")
public ResultBean queryObjectFile(HttpServletResponse response, MesMediaFileCfg mesMediaFileCfg) { // public ResultBean queryObjectFile(HttpServletResponse response, MesMediaFileCfg mesMediaFileCfg) {
//
InputStream inputStream = null; // InputStream inputStream = null;
OutputStream outputStream = null; // OutputStream outputStream = null;
try { // try {
//
// InputStream object = HuaWeiOBSUtil.getObject(MesCommonConstant.OBS_END_POINT, mesMediaFileCfg.getFileName()); //// InputStream object = HuaWeiOBSUtil.getObject(MesCommonConstant.OBS_END_POINT, mesMediaFileCfg.getFileName());
// 列举桶 // // 列举桶
ListBucketsRequest request = new ListBucketsRequest(); // ListBucketsRequest request = new ListBucketsRequest();
request.setQueryLocation(true); // request.setQueryLocation(true);
ObsClient obsClient = obsConfig.getObsClient(); // ObsClient obsClient = obsConfig.getObsClient();
List<ObsBucket> buckets = obsClient.listBuckets(request); // List<ObsBucket> buckets = obsClient.listBuckets(request);
for (ObsBucket bucket : buckets) { // for (ObsBucket bucket : buckets) {
LOGGER.info("BucketName：{},Location{}", bucket.getBucketName(),bucket.getLocation()); // LOGGER.info("BucketName：{},Location{}", bucket.getBucketName(),bucket.getLocation());
} // }
//
return ResultBean.success("下载成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); // return ResultBean.success("下载成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException imppException) { // } catch (ImppBusiException imppException) {
LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException); // LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException);
return ResultBean.fail(imppException); // return ResultBean.fail(imppException);
} catch (Exception e) { // } catch (Exception e) {
return ImppExceptionBuilder.newInstance().buildExceptionResult(e); // return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
} // }
//
} // }
//
@ApiOperation("创建桶") // @ApiOperation("创建桶")
@GetMapping("/obs/createMesBucket") // @GetMapping("/obs/createMesBucket")
public ResultBean CreateMesBucket() { // public ResultBean CreateMesBucket() {
//
try { // try {
CreateBucketRequest request = new CreateBucketRequest(); // CreateBucketRequest request = new CreateBucketRequest();
ObsClient obsClient = obsConfig.getObsClient(); // ObsClient obsClient = obsConfig.getObsClient();
ListBucketsRequest bucketsRequest = new ListBucketsRequest(); // ListBucketsRequest bucketsRequest = new ListBucketsRequest();
bucketsRequest.setQueryLocation(true); // bucketsRequest.setQueryLocation(true);
List<ObsBucket> buckets = obsClient.listBuckets(bucketsRequest); // List<ObsBucket> buckets = obsClient.listBuckets(bucketsRequest);
for (ObsBucket bucket : buckets) { // for (ObsBucket bucket : buckets) {
if(bucket.getBucketName().equals(MesCommonConstant.OBS_BUCKET_NAME)){ // if(bucket.getBucketName().equals(MesCommonConstant.OBS_BUCKET_NAME)){
return ResultBean.success("已创建桶【mesbucket】").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); // return ResultBean.success("已创建桶【mesbucket】").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} // }
} // }
//示例桶名 // //示例桶名
String exampleBucket = MesCommonConstant.OBS_BUCKET_NAME; // String exampleBucket = MesCommonConstant.OBS_BUCKET_NAME;
//示例桶区域位置 // //示例桶区域位置
String exampleLocation = MesCommonConstant.OBS_LOCATION; // String exampleLocation = MesCommonConstant.OBS_LOCATION;
request.setBucketName(exampleBucket); // request.setBucketName(exampleBucket);
// 设置桶访问权限为私有读写，默认也是私有读写 // // 设置桶访问权限为私有读写，默认也是私有读写
request.setAcl(AccessControlList.REST_CANNED_PRIVATE); // request.setAcl(AccessControlList.REST_CANNED_PRIVATE);
// 设置桶的存储类别为标准存储 // // 设置桶的存储类别为标准存储
request.setBucketStorageClass(StorageClassEnum.STANDARD); // request.setBucketStorageClass(StorageClassEnum.STANDARD);
// 设置桶区域位置(以区域为中国-上海为例)，location 需要与 endpoint的位置信息一致 // // 设置桶区域位置(以区域为中国-上海为例)，location 需要与 endpoint的位置信息一致
request.setLocation(exampleLocation); // request.setLocation(exampleLocation);
// 指定创建多AZ桶，如果不设置，默认创建单AZ桶 // // 指定创建多AZ桶，如果不设置，默认创建单AZ桶
request.setAvailableZone(AvailableZoneEnum.MULTI_AZ); // request.setAvailableZone(AvailableZoneEnum.MULTI_AZ);
// 创建桶 // // 创建桶
ObsBucket bucket = obsClient.createBucket(request); // ObsBucket bucket = obsClient.createBucket(request);
//
} catch (ObsException e) { // } catch (ObsException e) {
LOGGER.error("Error Message：{}", e.getErrorMessage()); // LOGGER.error("Error Message：{}", e.getErrorMessage());
} catch (Exception e) { // } catch (Exception e) {
e.printStackTrace(); // e.printStackTrace();
} // }
//
return ResultBean.success("创建成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); // return ResultBean.success("创建成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
//
} // }
//
@ApiOperation("列举桶") // @ApiOperation("列举桶")
@GetMapping("/obs/getObsClient") // @GetMapping("/obs/getObsClient")
public ResultBean getObsClient() { // public ResultBean getObsClient() {
List<ObsBucket> buckets=new ArrayList<>(); // List<ObsBucket> buckets=new ArrayList<>();
try { // try {
ObsClient obsClient = obsConfig.getObsClient(); // ObsClient obsClient = obsConfig.getObsClient();
// 列举桶 // // 列举桶
ListBucketsRequest request = new ListBucketsRequest(); // ListBucketsRequest request = new ListBucketsRequest();
request.setQueryLocation(true); // request.setQueryLocation(true);
buckets = obsClient.listBuckets(request); // buckets = obsClient.listBuckets(request);
} catch (ObsException e) { // } catch (ObsException e) {
LOGGER.error("Error Message：{}", e.getErrorMessage()); // LOGGER.error("Error Message：{}", e.getErrorMessage());
} catch (Exception e) { // } catch (Exception e) {
e.printStackTrace(); // e.printStackTrace();
} // }
return ResultBean.success("创建成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultList(buckets); // return ResultBean.success("创建成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultList(buckets);
//
} // }
//
@PostMapping(value = "/media-file/insert") // @PostMapping(value = "/media-file/insert")
@ApiOperation(value = "上传媒体文件") // @ApiOperation(value = "上传媒体文件")
public ResultBean insertProduceCtgyPicture(@RequestParam("file") MultipartFile file, MesMediaFileCfg mesMediaFileCfg) { // public ResultBean insertProduceCtgyPicture(@RequestParam("file") MultipartFile file, MesMediaFileCfg mesMediaFileCfg) {
try {
if (file.isEmpty()) {
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.REPORT.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("不允许上传空文件")
.build();
}
// 校验文件大小
long size = file.getSize();
if (size > FILE_SIZE) {
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.REPORT.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("文件过大，请重新上传！")
.build();
}
String fileName = file.getOriginalFilename();
String newName = UUID.randomUUID().toString() + fileName.substring(fileName.indexOf("."));
String path = "/tmp/media-file/";
File saveFile = new File(path + newName);
if (!saveFile.getParentFile().exists()) {
saveFile.getParentFile().mkdirs();
}
file.transferTo(saveFile);
MesMediaFileCfg mesMediaFileCfg1 = new MesMediaFileCfg();
mesMediaFileCfg1.setFileName(fileName);
mesMediaFileCfg1.setFileUrl(saveFile.getPath());
mesMediaFileCfg1.setFileType(mesMediaFileCfg.getFileType());
mediaFileCfgRepository.save(mesMediaFileCfg1);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(mesMediaFileCfg1);
} catch (ImppBusiException imppException) {
LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException);
return ResultBean.fail(imppException);
} catch (Exception e) {
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@ApiOperation("下载文件")
@GetMapping("/download")
public ResultBean download(@RequestParam("filePath") String filePath, HttpServletResponse response) {
InputStream inputStream = null;
OutputStream outputStream = null;
try {
// 读取文件
File file = new File(filePath);
inputStream = new FileInputStream(file);
outputStream = response.getOutputStream();
response.setContentType("application/octet-stream");
response.setHeader("Content-Disposition", "attachment; filename=" + URLEncoder.encode(file.getName(), "UTF-8"));
byte[] buffer = new byte[4096];
int bytesRead;
while ((bytesRead = inputStream.read(buffer)) != -1) {
outputStream.write(buffer, 0, bytesRead);
}
outputStream.flush();
inputStream.close();
outputStream.close();
return ResultBean.success("下载成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException imppException) {
LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException);
return ResultBean.fail(imppException);
} catch (Exception e) {
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
// @PostMapping(value = "/sys-upload")
// @ApiOperation(value = "系统导入")
// public ResultBean insertPartFurnace(@RequestParam("file") MultipartFile file, MesMediaFileCfg mesMediaFileCfg) {
// try { // try {
//
// if (file.isEmpty()) { // if (file.isEmpty()) {
// throw ImppExceptionBuilder.newInstance() // throw ImppExceptionBuilder.newInstance()
// .setSystemID(CommonEnumUtil.SOFT_TYPE.REPORT.getCode()) // .setSystemID(CommonEnumUtil.SOFT_TYPE.REPORT.getCode())
@ -307,26 +230,103 @@ public class MesMediaFileCfgController extends BaseMesController<MesMediaFileCfg
// .setErrorDetail("不允许上传空文件") // .setErrorDetail("不允许上传空文件")
// .build(); // .build();
// } // }
// SysFile sysFile = fileService.upload(file, CommonEnumUtil.SOFT_TYPE.MES.getValue()); // // 校验文件大小
//// MesFile mesFile = fileService.uploadMesFile(file, AuthUtil.getOrganizeCode(), AuthUtil.getSessionUser().getUserName()); // long size = file.getSize();
// if (size > FILE_SIZE) {
// throw ImppExceptionBuilder.newInstance()
// .setSystemID(CommonEnumUtil.SOFT_TYPE.REPORT.getCode())
// .setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
// .setErrorDetail("文件过大，请重新上传！")
// .build();
// }
//
// String fileName = file.getOriginalFilename();
// String newName = UUID.randomUUID().toString() + fileName.substring(fileName.indexOf("."));
// //
// //属性验证 // String path = "/tmp/media-file/";
// ValidatorBean.beginValid(mesMediaFileCfg) //
// .notNull("modelNo", mesMediaFileCfg.getFileType()); // File saveFile = new File(path + newName);
// if (!saveFile.getParentFile().exists()) {
// saveFile.getParentFile().mkdirs();
// }
// file.transferTo(saveFile);
// //
// MesMediaFileCfg mesMediaFileCfg1 = new MesMediaFileCfg(); // MesMediaFileCfg mesMediaFileCfg1 = new MesMediaFileCfg();
// mesMediaFileCfg1.setFileName(sysFile.getDfsFileName()); // mesMediaFileCfg1.setFileName(fileName);
// mesMediaFileCfg1.setFileUrl(sysFile.getFilePath()); // mesMediaFileCfg1.setFileUrl(saveFile.getPath());
// mesMediaFileCfg1.setFileType(mesMediaFileCfg.getFileType()); // mesMediaFileCfg1.setFileType(mesMediaFileCfg.getFileType());
// mediaFileCfgRepository.save(mesMediaFileCfg1); // mediaFileCfgRepository.save(mesMediaFileCfg1);
// //
// return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); // return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(mesMediaFileCfg1);
// } catch (ImppBusiException imppException) {
// LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException);
// return ResultBean.fail(imppException);
// } catch (Exception e) {
// return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
// }
// }
//
// @ApiOperation("下载文件")
// @GetMapping("/download")
// public ResultBean download(@RequestParam("filePath") String filePath, HttpServletResponse response) {
//
// InputStream inputStream = null;
// OutputStream outputStream = null;
// try {
// // 读取文件
// File file = new File(filePath);
// inputStream = new FileInputStream(file);
// outputStream = response.getOutputStream();
// response.setContentType("application/octet-stream");
// response.setHeader("Content-Disposition", "attachment; filename=" + URLEncoder.encode(file.getName(), "UTF-8"));
// byte[] buffer = new byte[4096];
// int bytesRead;
// while ((bytesRead = inputStream.read(buffer)) != -1) {
// outputStream.write(buffer, 0, bytesRead);
// }
// outputStream.flush();
// inputStream.close();
// outputStream.close();
// return ResultBean.success("下载成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
// } catch (ImppBusiException imppException) { // } catch (ImppBusiException imppException) {
// LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException); // LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException);
// return ResultBean.fail(imppException); // return ResultBean.fail(imppException);
// } catch (Exception e) { // } catch (Exception e) {
// return ImppExceptionBuilder.newInstance().buildExceptionResult(e); // return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
// } // }
//
// } // }
//// @PostMapping(value = "/sys-upload")
} //// @ApiOperation(value = "系统导入")
//// public ResultBean insertPartFurnace(@RequestParam("file") MultipartFile file, MesMediaFileCfg mesMediaFileCfg) {
//// try {
//// if (file.isEmpty()) {
//// throw ImppExceptionBuilder.newInstance()
//// .setSystemID(CommonEnumUtil.SOFT_TYPE.REPORT.getCode())
//// .setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
//// .setErrorDetail("不允许上传空文件")
//// .build();
//// }
//// SysFile sysFile = fileService.upload(file, CommonEnumUtil.SOFT_TYPE.MES.getValue());
////// MesFile mesFile = fileService.uploadMesFile(file, AuthUtil.getOrganizeCode(), AuthUtil.getSessionUser().getUserName());
////
//// //属性验证
//// ValidatorBean.beginValid(mesMediaFileCfg)
//// .notNull("modelNo", mesMediaFileCfg.getFileType());
////
//// MesMediaFileCfg mesMediaFileCfg1 = new MesMediaFileCfg();
//// mesMediaFileCfg1.setFileName(sysFile.getDfsFileName());
//// mesMediaFileCfg1.setFileUrl(sysFile.getFilePath());
//// mesMediaFileCfg1.setFileType(mesMediaFileCfg.getFileType());
//// mediaFileCfgRepository.save(mesMediaFileCfg1);
////
//// return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
//// } catch (ImppBusiException imppException) {
//// LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException);
//// return ResultBean.fail(imppException);
//// } catch (Exception e) {
//// return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
//// }
//// }
//
//}

Write Preview
Loading…
Cancel
Save