package com.dy.pipIrrGlobal.dyFile;

import com.dy.common.util.NumUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;
import org.springframework.web.multipart.MultipartFile;

import java.util.Arrays;
import java.util.List;

@Component
public class FileOperate {
	
	@Autowired
	private RestTemplate restTemplate ;

	/**
	 * 拆分上载文件的名称
	 * @param file
	 * @return
	 */
	public String[] splitFileName(MultipartFile file){
		String[] grp = new String[2] ;
		if(file != null) {
			String fileName = file.getOriginalFilename();
			int lastDotIndex = fileName.lastIndexOf('.');
			if (lastDotIndex >= 0) {
				grp[0] = fileName.substring(0, lastDotIndex);
				grp[1] = fileName.substring(lastDotIndex + 1);
				if(grp[0].trim().equals("")){
					grp[0] = "匿名" ;
				}
			}
		}
		return grp ;
	}

	/**
	 * 得到上载的文件扩展名
	 * @param file
	 * @return
	 */
	public String getFileExtName(MultipartFile file){
		String fileExtName = null ;
		if(file != null) {
			String filename = file.getOriginalFilename();
			int lastDotIndex = filename.lastIndexOf('.');
			if (lastDotIndex >= 0) {
				fileExtName = filename.substring(lastDotIndex + 1);
			}
		}
		return fileExtName ;
	}

	/**
	 * 得到上载的文件主名
	 * @param fileName
	 * @return
	 */
	public String getFileMainName(String fileName){
		String fileMainName = null ;
		if(fileName != null) {
			int lastDotIndex = fileName.lastIndexOf('.');
			if (lastDotIndex >= 0) {
				fileMainName =  fileName.substring(0, lastDotIndex);
			}
		}
		if(fileMainName == null){
			fileMainName = "noName" ;
		}
		return fileMainName ;
	}

	/**
	 * 通过照片路径，得到对应缩略图的路径
	 * @param imgPath
	 * @return
	 */
	public String getImgFileZipPath(String imgPath){
		String path_ = null ;
		String prePath = null ;
		String tailPath = null ;
		if(imgPath != null && !imgPath.trim().equals("")) {
			int lastDotIndex = imgPath.lastIndexOf('.');
			if (lastDotIndex >= 0) {
				prePath = imgPath.substring(0, lastDotIndex);
				tailPath = imgPath.substring(lastDotIndex);
				path_ = prePath + "_" + tailPath ;
			}
		}
		if(path_ == null){
			path_ = imgPath ;
		}
		return path_ ;
	}

	/**
	 * web分布式文件系统保存文件
	 * @param file
	 * @param fmUrl
	 * @param fileCtrlRqMp
	 * @param fileMethodMp
	 * @param regionNum
	 * @param fileExtName
	 * @param json
	 * @return
	 * @throws Exception
	 */
	public FileRestVo saveFile(MultipartFile file,
							   String fmUrl,
							   String fileCtrlRqMp,
							   String fileMethodMp,
							   String regionNum,
							   String fileExtName,
							   String json) throws Exception{
		FileRestVo rvo  = null ;
		if(file != null && file.getBytes() != null && file.getBytes().length > 0){
			rvo = this.restCreateFileName(fmUrl, fileExtName) ;
			if(rvo != null){
				String relativeFilePath = this.restSaveFile(fileCtrlRqMp, fileMethodMp, file, regionNum, json, rvo);
				rvo.fileWebPath = relativeFilePath ;
				//if(relativeFilePath != null){
				//	rvo.createFilePath(relativeFilePath, rvo.fileNameHash);
				//}
			}
		}
		return rvo ;
	}

	/**
	 * 生成文件名称
	 * @return
	 */
	private FileRestVo restCreateFileName(String fmUrl, String fileExtName) throws Exception{
		// 准备请求数据
		MultiValueMap<String, Object> multipartRequestData = new LinkedMultiValueMap<>();
		multipartRequestData.add(FileConstant.fmPostMapping_create_paramName, fileExtName);

		// 设置请求头部，这里假设服务器接收multipart/form-data类型的数据
		HttpHeaders headers = new HttpHeaders();
		headers.setContentType(MediaType.MULTIPART_FORM_DATA);

		// 封装请求体
		HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(multipartRequestData, headers);

		String webUrl = fmUrl + "/" + FileConstant.fmRequestMapping + "/" + FileConstant.fmPostMapping_create;
		// 发送POST请求
		FileRestVo rvo = restTemplate.postForObject(webUrl, requestEntity, FileRestVo.class);

		return rvo ;
	}

	/**
	 * 把文件存储到文件系统中
	 * @param file
	 * @param regionNum
	 * @param json json数据
	 * @param rvo
	 * @return
	 * @throws Exception
	 */
	private String restSaveFile(String fileCtrlRqMp,
								String fileMethodMp,
								MultipartFile file,
								String regionNum,
								String json,
								FileRestVo rvo) throws Exception{
		// 准备请求数据
		MultiValueMap<String, Object> multipartRequestData = new LinkedMultiValueMap<>();
		multipartRequestData.add(FileConstant.filePostMapping_paramName_file, file.getResource());
		multipartRequestData.add(FileConstant.filePostMapping_paramName_regionNum, regionNum);
		multipartRequestData.add(FileConstant.filePostMapping_paramName_json, (json==null?"":json));
		multipartRequestData.add(FileConstant.filePostMapping_paramName_absolutePath, rvo.fileSysAbsolutePath);
		multipartRequestData.add(FileConstant.filePostMapping_paramName_relativePath, rvo.fileSysRelativePath);
		multipartRequestData.add(FileConstant.filePostMapping_paramName_fileName, rvo.fileName);

		// 设置请求头部，这里假设服务器接收multipart/form-data类型的数据
		HttpHeaders headers = new HttpHeaders();
		headers.setContentType(MediaType.MULTIPART_FORM_DATA);
		//headers.setContentLength(file.getSize());

		// 封装请求体
		HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(multipartRequestData, headers);

		String fileRestUrl = rvo.fileSysRestUrl ;
		if(!fileRestUrl.endsWith("/") && !fileRestUrl.endsWith("\\\\")){
			fileRestUrl += "/" ;
		}
		fileRestUrl += (fileCtrlRqMp + "/" + fileMethodMp) ;

		// 发送POST请求
		return restTemplate.postForObject(fileRestUrl, requestEntity, Object.class).toString();
	}

	/**
	 * 解析文件名称
	 * @param fmUrl
	 * @param filePath
	 * @return
	 */
	public FileRestVo parse(String fmUrl, String filePath){
		// 准备请求数据
		MultiValueMap<String, Object> multipartRequestData = new LinkedMultiValueMap<>();
		multipartRequestData.add(FileConstant.fmPostMapping_parsePath_paramName, filePath);

		// 设置请求头部，这里假设服务器接收multipart/form-data类型的数据
		HttpHeaders headers = new HttpHeaders();
		headers.setContentType(MediaType.MULTIPART_FORM_DATA);

		// 封装请求体
		HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(multipartRequestData, headers);

		String webUrl = fmUrl + "/" + FileConstant.fmRequestMapping + "/" + FileConstant.fmPostMapping_parsePath;
		// 发送POST请求
		FileRestVo rvo = restTemplate.postForObject(webUrl, requestEntity, FileRestVo.class);

		return rvo ;
	}


	/**
	 * 解析文件名称
	 * @param fmUrl
	 * @param filePaths
	 * @return
	 */
	public List<FileRestVo> parse(String fmUrl, List<String> filePaths) throws Exception{
		List<FileRestVo> rList = null ;
		if(filePaths != null && filePaths.size() > 0) {
			MultiValueMap<String, Object> multipartRequestData = new LinkedMultiValueMap<>();
			multipartRequestData.add(FileConstant.fmPostMapping_parsePathList_paramName, filePaths);

			// 设置请求头部，这里假设服务器接收multipart/form-data类型的数据
			HttpHeaders headers = new HttpHeaders();
			headers.setContentType(MediaType.MULTIPART_FORM_DATA);

			// 封装请求体
			HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(multipartRequestData, headers);

			String webUrl = fmUrl + "/" + FileConstant.fmRequestMapping + "/" + FileConstant.fmPostMapping_parsePathList;
			// 发送POST请求
			FileRestVo[] rvos = restTemplate.postForObject(webUrl, requestEntity, FileRestVo[].class);
			rList = Arrays.asList(rvos) ;
		}
		return rList ;
	}

	/**
	 * 解析文件哈希值
	 * @param fmUrl
	 * @param hashcode
	 * @return
	 */
	public FileRestVo parseHashcode(String fmUrl, Integer hashcode){
		// 准备请求数据
		MultiValueMap<String, Object> multipartRequestData = new LinkedMultiValueMap<>();
		multipartRequestData.add(FileConstant.fmPostMapping_parseHashcode_paramName, hashcode);

		// 设置请求头部，这里假设服务器接收multipart/form-data类型的数据
		HttpHeaders headers = new HttpHeaders();
		headers.setContentType(MediaType.MULTIPART_FORM_DATA);

		// 封装请求体
		HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(multipartRequestData, headers);

		String webUrl = fmUrl + "/" + FileConstant.fmRequestMapping + "/" + FileConstant.fmPostMapping_parseHashcode;
		// 发送POST请求
		FileRestVo rvo = restTemplate.postForObject(webUrl, requestEntity, FileRestVo.class);

		return rvo ;
	}

	/**
	 * 解析文件文件路径中的哈希值并返回图片完整路径
	 * @param fmUrl
	 * @param filePath
	 * @return
	 */
	public String getFilePath(String fmUrl, String filePath){
		FileRestVo rvo = null ;
		if(filePath != null && !filePath.trim().equals("")){
			String[] strs = filePath.split("\\?") ;
			String hashValStr = strs[strs.length - 1] ;
			if(hashValStr != null && !hashValStr.trim().equals("") && NumUtil.isPlusIntNumber(hashValStr)){
				int hashVal = Integer.valueOf(hashValStr) ;
				rvo = parseHashcode(fmUrl, hashVal) ;
			}
		}
		if(rvo != null){
			return rvo.getFileWebUrl() + filePath ;
		}
		return null ;
	}

}