~admin/kidgrow-microservices-platform.git

			@@ -9,7 +9,6 @@
			import com.kidgrow.common.model.PageResult;
			import com.kidgrow.common.model.ResultBody;
			import com.kidgrow.common.utils.DateUtil;
			import com.kidgrow.common.utils.MultipartFileUtils;
			import com.kidgrow.common.utils.RandomValueUtils;
			import com.kidgrow.common.utils.StringUtils;
			import com.kidgrow.filecenter.mapper.FileMapper;
			@@ -19,12 +18,16 @@
			import lombok.extern.slf4j.Slf4j;
			import net.coobird.thumbnailator.Thumbnails;
			import org.apache.commons.collections4.MapUtils;
			import org.springframework.web.multipart.MultipartFile;
			import sun.misc.BASE64Decoder;
			import org.slf4j.Logger;
			import org.slf4j.LoggerFactory;
			import org.springframework.beans.factory.annotation.Value;
			import org.springframework.web.multipart.MultipartFile;
			import sun.misc.BASE64Decoder;
			import sun.misc.BASE64Encoder;

			import java.io.*;
			import java.net.HttpURLConnection;
			import java.net.URL;
			import java.util.*;

			/**
			@@ -40,6 +43,10 @@
			private static final String FILE_SPLIT = ".";
			private static Logger logger = LoggerFactory.getLogger(AbstractIFileService.class);

			@Value("${kidgrow.file-server.oss.domain}")
			private String DOMAIN;
			@Value("${spring.profiles.active}")
			private String OssPathEn;
			@Override
			public FileInfo upload(MultipartFile file) throws Exception {
			FileInfo fileInfo = FileUtil.getFileInfo(file);
			@@ -94,7 +101,7 @@
			*/
			protected abstract void uploadFile(MultipartFile file, FileInfo fileInfo) throws Exception;
			protected abstract void fileUpLoadOss(FileInfo fileInfo,String newFilePath, InputStream fileStream);
			protected abstract String FilePath(String imgType,String folderByDate);
			protected abstract String FilePath(String imgType,String folderByDate,String hospitalId,String departmentId);
			protected abstract OSSObject down(String url);

			/**
			@@ -154,7 +161,7 @@
			//将生成的文件转换为流
			InputStream inputStream=new FileInputStream(thuFile);
			String folderByDate = DateUtil.formatDate(new Date());
			String filefloder=this.FilePath(imgType,folderByDate);
			String filefloder=this.FilePath(imgType,folderByDate,null,null);
			FileInfo newfileInfo=new FileInfo();
			newfileInfo.setName(newFileName);
			newfileInfo.setId(IdUtil.fastSimpleUUID());
			@@ -184,7 +191,7 @@
			}

			@Override
			public FileInfo baseUplaod(String file, String imgType) {
			public FileInfo baseUplaod(String file, String imgType, String hospitalId, String departmentId) {
			if(file==null\|\|"".equals(file.trim())){
			return null;
			}
			@@ -209,7 +216,9 @@
			newfileInfo.setSource("aliyun");
			newfileInfo.setImgType(imgType);
			newfileInfo.setCreateTime(new Date());
			this.fileUpLoadOss(newfileInfo,"HospitalLogo/"+newFileName,input);
			String folderByDate =DateUtil.formatDate(new Date());
			String filePath = FilePath(imgType, folderByDate, hospitalId, departmentId);
			this.fileUpLoadOss(newfileInfo,filePath+newFileName,input);
			input.close();
			baseMapper.insert(newfileInfo);
			return newfileInfo;
			@@ -221,40 +230,140 @@

			@Override
			public ResultBody baseDownLoad(Map<String, Object> map) throws Exception {
			List<FileInfo> fileInfos = baseMapper.selectByMap(map);
			if(fileInfos.size()>0){
			FileInfo fileInfo = fileInfos.get(0);
			OSSObject down1 = this.down(fileInfo.getUrl().replace("https://kidgrow.oss-accelerate.aliyuncs.com/",""));
			InputStream objectContent = down1.getObjectContent();
			//返回Base64编码过的字节数组字符串
			byte[] data = null;
			// 读取图片字节数组
			String urlDiZhi=MapUtils.getString(map,"url");
			if(!urlDiZhi.contains(DOMAIN)){
			ByteArrayOutputStream outPut = new ByteArrayOutputStream();
			byte[] data = new byte[1024];
			try {
			ByteArrayOutputStream swapStream = new ByteArrayOutputStream();
			byte[] buff = new byte[100];
			int rc = 0;
			while ((rc = objectContent.read(buff, 0, 100)) > 0) {
			swapStream.write(buff, 0, rc);
			// 创建URL
			URL url = new URL(urlDiZhi);
			// 创建链接
			HttpURLConnection conn = (HttpURLConnection) url.openConnection();
			conn.setRequestMethod("GET");
			conn.setConnectTimeout(10 * 1000);
			InputStream inStream = conn.getInputStream();
			int len = -1;
			while ((len = inStream.read(data)) != -1) {
			outPut.write(data, 0, len);
			}
			data = swapStream.toByteArray();
			inStream.close();
			} catch (IOException e) {
			e.printStackTrace();
			} finally {
			if (objectContent != null) {
			try {
			objectContent.close();
			down1.close();
			} catch (IOException e) {
			throw new Exception("输入流关闭异常");
			}
			String substring = urlDiZhi.substring(urlDiZhi.lastIndexOf(".") + 1, urlDiZhi.length());
			String str="data:image/" + substring + ";base64,";
			// 对字节数组Base64编码
			BASE64Encoder encoder = new BASE64Encoder();
			System.out.println(encoder.encode(outPut.toByteArray()));
			return ResultBody.ok().data(str+encoder.encode(outPut.toByteArray()).replaceAll("\n", "").replaceAll("\r", ""));
			}else {
			List<FileInfo> fileInfos = baseMapper.selectByMap(map);
			if (fileInfos.size() > 0) {
			FileInfo fileInfo = fileInfos.get(0);
			OSSObject down = this.down(fileInfo.getUrl().replace(DOMAIN, ""));
			InputStream objectContent = down.getObjectContent();
			//返回Base64编码过的字节数组字符串
			byte[] data = null;
			// 读取图片字节数组
			try {
			ByteArrayOutputStream swapStream = new ByteArrayOutputStream();
			byte[] buff = new byte[100];
			int rc = 0;
			while ((rc = objectContent.read(buff, 0, 100)) > 0) {
			swapStream.write(buff, 0, rc);
			}
			data = swapStream.toByteArray();
			} catch (IOException e) {
			e.printStackTrace();
			} finally {
			if (objectContent != null) {
			try {
			objectContent.close();
			down.close();
			} catch (IOException e) {
			throw new Exception("输入流关闭异常");
			}
			}
			}
			String encode = "data:" + fileInfo.getContentType() + ";base64," + Base64.getEncoder().encodeToString(data);
			return ResultBody.ok().data(encode);
			} else {
			return ResultBody.failed("获取数据失败");
			}
			String encode="data:"+fileInfo.getContentType()+";base64,"+Base64.getEncoder().encodeToString(data);
			return ResultBody.ok().data(encode);
			}else {
			return ResultBody.failed("获取数据失败");
			}
			}

			public static void main(String[] args) {

			ByteArrayOutputStream outPut = new ByteArrayOutputStream();
			byte[] data = new byte[1024];
			try {
			// 创建URL
			URL url = new URL("http://192.168.2.25:8008/123/J-1.jpg");
			// 创建链接
			HttpURLConnection conn = (HttpURLConnection) url.openConnection();
			conn.setRequestMethod("GET");
			conn.setConnectTimeout(10 * 1000);
			InputStream inStream = conn.getInputStream();
			int len = -1;
			while ((len = inStream.read(data)) != -1) {
			outPut.write(data, 0, len);
			}
			inStream.close();
			} catch (IOException e) {
			e.printStackTrace();
			}
			// 对字节数组Base64编码
			BASE64Encoder encoder = new BASE64Encoder();
			System.out.println(encoder.encode(outPut.toByteArray()));

			}

			@Override
			public FileInfo byteUplaod(String fileName, InputStream inputStream,int size) {
			String houzhui=fileName.substring(fileName.lastIndexOf(".")+1);
			String newFileName= RandomValueUtils.uuid()+"."+houzhui;
			FileInfo newfileInfo=new FileInfo();
			newfileInfo.setName(newFileName);
			newfileInfo.setId(IdUtil.fastSimpleUUID());
			newfileInfo.setSize(size);
			newfileInfo.setIsImg(false);
			newfileInfo.setContentType("byte[]");
			newfileInfo.setSource("aliyun");
			newfileInfo.setImgType(houzhui);
			newfileInfo.setCreateTime(new Date());
			this.fileUpLoadOss(newfileInfo,"pdf/"+newFileName,inputStream);
			baseMapper.insert(newfileInfo);
			return newfileInfo;
			}

			@Override
			public FileInfo feignUploadHosIdAndDepId(MultipartFile file, String imgType, String hospitalId, String departmentId) throws Exception {
			List<String> lassStr= Arrays.asList("png","bmp","dib","gif","jfif","jpe","jpeg","jpg","tif","tiff","ico");
			String suffix=file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf(".")+1);
			if(!lassStr.contains(suffix)){
			return null;
			}
			String name = file.getOriginalFilename();
			String fileName= UUID.randomUUID().toString().replaceAll("-","");
			//image/jpeg;base64
			String newFileName=fileName+name.substring(name.lastIndexOf("."));
			FileInfo newfileInfo=new FileInfo();
			newfileInfo.setName(newFileName);
			newfileInfo.setId(IdUtil.fastSimpleUUID());
			newfileInfo.setSize(file.getSize());
			newfileInfo.setIsImg(true);
			newfileInfo.setContentType("image/jpeg");
			newfileInfo.setSource("aliyun");
			newfileInfo.setImgType(imgType);
			newfileInfo.setCreateTime(new Date());
			String folderByDate =DateUtil.formatDate(new Date());
			String filePath = FilePath(imgType, folderByDate, hospitalId, departmentId);
			InputStream inputStream = file.getInputStream();
			this.fileUpLoadOss(newfileInfo,filePath+newFileName,inputStream);
			inputStream.close();
			baseMapper.insert(newfileInfo);
			return newfileInfo;
			}
			}