Ver código fonte

minio修改类名

master
chenchaod 1 semana atrás
pai
commit
07a6062d46

gly-base-core/src/main/java/cn/com/taiji/core/manager/tools/minio/MinioUtile.java → gly-base-core/src/main/java/cn/com/taiji/core/manager/tools/minio/MinioUtil.java Ver arquivo

import java.io.FileInputStream; import java.io.FileInputStream;
import java.io.InputStream; import java.io.InputStream;
import java.net.URL; import java.net.URL;
import java.net.URLEncoder;
import java.util.Date; import java.util.Date;
import java.util.UUID; import java.util.UUID;


* @description: * @description:
*/ */
@Component @Component
public class MinioUtile extends CommonAbstract {
public class MinioUtil extends CommonAbstract {


@Value("${vmi-minio.url}") @Value("${vmi-minio.url}")
private String url; //内网访问地址 private String url; //内网访问地址
} }
public File getFileByUrl(String excelUrl) throws ManagerException { public File getFileByUrl(String excelUrl) throws ManagerException {
// minioDownloadUrl = "https://qtzl.etcjz.cn"; // minioDownloadUrl = "https://qtzl.etcjz.cn";
String urlStr = url + "/" + excelUrl;
String urlStr = url + StrUtil.SLASH + excelUrl;
// String[] split = excelUrl.split("/"); // String[] split = excelUrl.split("/");
// for (int i = 0; i < split.length; i++) { // for (int i = 0; i < split.length; i++) {
// if (i == 0) { // if (i == 0) {
throw new ManagerException("MinIo 上传文件失败...请联系管理员"); throw new ManagerException("MinIo 上传文件失败...请联系管理员");
} }
file.delete(); file.delete();
return bucketName + "/" + uuidFileName;
return bucketName + StrUtil.SLASH + uuidFileName;
} }


//生成随机文件名 //生成随机文件名

+ 6
- 6
zhywpt-app-userw/src/main/java/cn/com/taiji/userw/manager/serviceHall/ServiceHallManagerImpl.java Ver arquivo

import cn.com.taiji.core.entity.basic.QtkServicehallLocation; import cn.com.taiji.core.entity.basic.QtkServicehallLocation;
import cn.com.taiji.core.entity.dict.BucketFileBus; import cn.com.taiji.core.entity.dict.BucketFileBus;
import cn.com.taiji.core.entity.user.Staff; import cn.com.taiji.core.entity.user.Staff;
import cn.com.taiji.core.manager.tools.minio.MinioUtile;
import cn.com.taiji.core.manager.tools.minio.MinioUtil;
import cn.com.taiji.core.repo.jpa.basic.QtkAgencyRepo; import cn.com.taiji.core.repo.jpa.basic.QtkAgencyRepo;
import cn.com.taiji.core.repo.jpa.basic.QtkServicehallLocationRepo; import cn.com.taiji.core.repo.jpa.basic.QtkServicehallLocationRepo;
import cn.com.taiji.core.repo.jpa.basic.QtkServicehallMapRepo; import cn.com.taiji.core.repo.jpa.basic.QtkServicehallMapRepo;
@Autowired @Autowired
private ServiceHallRegisterFullBatchListener listener; private ServiceHallRegisterFullBatchListener listener;
@Autowired @Autowired
private MinioUtile minioUtile;
private MinioUtil minioUtil;
@Override @Override
public Pagination query(ServiceHallPageRequestDTO reqDto) { public Pagination query(ServiceHallPageRequestDTO reqDto) {
ServiceHallPageRequest request = copyProperties(reqDto, new ServiceHallPageRequest()); ServiceHallPageRequest request = copyProperties(reqDto, new ServiceHallPageRequest());
public String registerFullBath(ServiceHallRegisterFullBatchRequestDTO reqDto) throws ManagerException { public String registerFullBath(ServiceHallRegisterFullBatchRequestDTO reqDto) throws ManagerException {
String path = null; String path = null;
File tempFile = null; File tempFile = null;
tempFile = minioUtile.getFileByUrl(reqDto.getExcelFileUrl());
tempFile = minioUtil.getFileByUrl(reqDto.getExcelFileUrl());
//获取文件流 //获取文件流
InputStream fileInputStream = null; InputStream fileInputStream = null;
try { try {
} }
EasyExcel.write(upFile, ServiceHallRegisterData.class).sheet() EasyExcel.write(upFile, ServiceHallRegisterData.class).sheet()
.doWrite(errors); .doWrite(errors);
path = minioUtile.fileUploadHttp(upFile, BucketFileBus.SERVICEHALL);
path = minioUtil.fileUploadHttp(upFile, BucketFileBus.SERVICEHALL);
} }
//删除临时文件 //删除临时文件
FileUtil.del(tempFile); FileUtil.del(tempFile);
throw new ManagerException("网点信息不存在"); throw new ManagerException("网点信息不存在");
} }
String path = null; String path = null;
File tempFile = minioUtile.getFileByUrl(reqDto.getExcelFileUrl());
File tempFile = minioUtil.getFileByUrl(reqDto.getExcelFileUrl());
//获取文件流 //获取文件流
InputStream fileInputStream = null; InputStream fileInputStream = null;
try { try {
} }
EasyExcel.write(upFile, ServiceLocationRegisterData.class).sheet() EasyExcel.write(upFile, ServiceLocationRegisterData.class).sheet()
.doWrite(errors); .doWrite(errors);
path = minioUtile.fileUploadHttp(upFile, BucketFileBus.SERVICEHALL);
path = minioUtil.fileUploadHttp(upFile, BucketFileBus.SERVICEHALL);
} }


//删除临时文件 //删除临时文件

Carregando…
Cancelar
Salvar