package cn.gistack.resource.feign;
|
|
import cn.gistack.resource.builder.oss.OssBuilder;
|
import cn.gistack.resource.entity.FormateTuEntity;
|
import cn.gistack.resource.entity.QieTuEntity;
|
import cn.gistack.resource.panoramaUtils.QietuResult;
|
import com.alibaba.fastjson.JSON;
|
import lombok.AllArgsConstructor;
|
import org.apache.commons.io.FileUtils;
|
import org.springblade.core.oss.model.BladeFile;
|
import org.springblade.core.tenant.annotation.NonDS;
|
import org.springblade.core.tool.api.R;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.io.FileNotFoundException;
|
import java.io.IOException;
|
import java.nio.file.Path;
|
import java.nio.file.Paths;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Set;
|
|
/**
|
* @author kelu
|
*/
|
@NonDS
|
@RestController
|
@AllArgsConstructor
|
public class OssClient implements IOssClient{
|
|
/**
|
* 对象存储构建类
|
*/
|
private final OssBuilder ossBuilder;
|
@Override
|
@PostMapping(UPLOAD_QIETU)
|
public R uploadQietu(QieTuEntity qieTuEntity) throws IOException {
|
HashMap<String,String> qietuHashMap = qieTuEntity.getQietuHashMap();
|
// System.err.println("切图的路径："+qietuHashMap);
|
|
String resGuid = qieTuEntity.getResGuid();
|
|
List<String> qieTuUrlList = new ArrayList<String>();
|
String urlHead = null;
|
Set<String> mapKey = qietuHashMap.keySet();
|
if(qietuHashMap != null && qietuHashMap.size()>0) {
|
for (String picQName : mapKey) {
|
String url = qietuHashMap.get(picQName);
|
Path qietuPath = Paths.get(url);
|
File qietufile = qietuPath.toFile();
|
FileInputStream fileInputStream = new FileInputStream(qietufile);
|
BladeFile bladeFile = ossBuilder.templateByPrefixPathPanorama("panorama", resGuid).putFile(picQName, fileInputStream);
|
fileInputStream.close(); // 关闭文件流
|
|
String link = bladeFile.getLink();
|
qieTuUrlList.add(link);// 上传后的图片路径
|
urlHead = link.replace(picQName,"");
|
|
// 切图上传完成后删除
|
if (qietufile.exists()) {
|
// 删除指定文件，不存在报异常
|
FileUtils.forceDelete(qietufile);
|
}
|
}
|
}
|
|
|
String jsonString = JSON.toJSONString(qieTuUrlList);
|
|
|
HashMap<String, String> stringStringHashMap = new HashMap<>();
|
stringStringHashMap.put("qturlList",jsonString);
|
stringStringHashMap.put("urlHead", urlHead);
|
|
QieTuEntity result = new QieTuEntity();
|
result.setQietuHashMap(stringStringHashMap);
|
|
return R.data(result);
|
}
|
|
@Override
|
@PostMapping(UPLOAD_FORMATETU)
|
public R uploadFormate(QieTuEntity qieTuEntity) throws IOException {
|
|
ArrayList<FormateTuEntity> list = qieTuEntity.getList();
|
|
|
// Set<String> mapKey = qietuHashMap.keySet();
|
if(list != null && list.size()>0) {
|
for (FormateTuEntity item : list) {
|
|
String picName = item.getPicName();
|
String url = item.getLinshiUrl();
|
Path qietuPath = Paths.get(url);
|
File qietufile = qietuPath.toFile();
|
FileInputStream fileInputStream = new FileInputStream(qietufile);
|
BladeFile bladeFile = ossBuilder.template().putFile(picName, fileInputStream);
|
fileInputStream.close(); // 关闭文件流
|
|
String link = bladeFile.getLink();
|
|
// 格式化后的临时图片上传完成后删除临时文件
|
if (qietufile.exists()) {
|
// 删除指定文件，不存在报异常
|
FileUtils.forceDelete(qietufile);
|
}
|
|
|
item.setLinshiUrl(link);
|
|
}
|
}
|
QieTuEntity result = new QieTuEntity();
|
result.setList(list);
|
|
return R.data(result);
|
}
|
|
@PostMapping(value = UPLOAD_FILE)
|
public String uploadFile(String fileName, MultipartFile file) throws Exception{
|
|
// InputStream inputStream = new ByteArrayInputStream(bytes);
|
|
BladeFile bladeFile = ossBuilder.template().putFile(fileName, file.getInputStream());
|
|
String link = bladeFile.getLink();
|
if (link.indexOf("http://10.42.6.251:8082") != -1) {
|
link= link.replace("http://10.42.6.251:8082", "https://sk.hubeishuiyi.cn/gminio");
|
}
|
return link;
|
}
|
}
|
