package com.vci.ubcs.code.service.impl;

import com.vci.ubcs.code.entity.GroupMapAttrXML;
import com.vci.ubcs.code.service.IGroupMapAttrXMLService;
import com.vci.ubcs.code.util.gennerAttrMapUtil;
import com.vci.ubcs.code.vo.GroupMapAttrXMLVO;
import com.vci.ubcs.code.vo.webserviceModel.attrmap.ClsfAttrMappingDO;
import com.vci.ubcs.code.vo.webserviceModel.attrmap.LibraryClsfDO;
import com.vci.ubcs.code.vo.webserviceModel.attrmap.LibraryDO;
import com.vci.ubcs.code.webService.config.AttributeMapConfig;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.Func;
import org.springblade.core.tool.utils.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.EnvironmentAware;
import org.springframework.core.env.Environment;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import org.xml.sax.SAXException;
import javax.xml.parsers.ParserConfigurationException;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.rmi.ServerException;
import java.security.acl.Group;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 集团属性映射xml配置管理
 * @author ludc
 * @date 2024/1/8 9:40
 */
@Service
@Slf4j
public class GroupMapAttrXMLServiceImpl implements IGroupMapAttrXMLService,EnvironmentAware {

	@Autowired
	private AttributeMapConfig attributeMapConfig;

	@Value("${code.universalinterface.attrconfig.attrmap_parent_path:/data1/ubcs/ubcs-server/xml}")
	private String ATTRMAP_PARENT_PATH;

	/**
	 * 当前操作系统，是否为windows系统
	 */
	private String separator = "\\";

	/**
	 * 根据当前运行的环境，匹配分隔符
	 * @param environment
	 */
	@Override
	public void setEnvironment(Environment environment) {
		String os = environment.getProperty("os.name").toLowerCase();
		if (!os.contains("win")) {
			this.separator = "/";
		}
	}

	/**
	 * 获取xml文件的详细信息
	 * @param groupMapAttrXML
	 * @return
	 * @throws IOException
	 */
	@Override
	public GroupMapAttrXML getGroupMapXMLInfo(GroupMapAttrXML groupMapAttrXML) throws ServerException {
		if(Func.isEmpty(groupMapAttrXML.getAttrMapPath())){
			throw new ServiceException("属性映射文件路径不能为空！");
		}
		File file = new File(groupMapAttrXML.getAttrMapPath());
		Map<String, String> stringStringMap = attributeMapConfig.getSystem_attrmap();
		GroupMapAttrXML data = new GroupMapAttrXML();
		if (file.exists() && file.isFile()) {
			data.setGroupMapAttrName(file.getName());
			data.setAttrMapPath(file.getPath());
			if(!stringStringMap.isEmpty() && stringStringMap.containsKey(file.getName().replace(".xml",""))){
				groupMapAttrXML.setIsEnable(true);
			}else {
				groupMapAttrXML.setIsEnable(false);
			}
			data.setGroupMapAttrContent(getXMLContent(file.getPath()));
		}
		return data;
	}

	/**
	 * 获取所有配置在nacos上的xml文件内容，（也就是在启用的xml映射文件）
	 * @return
	 */
	@Override
	public List<GroupMapAttrXML> getGroupMapXMLList() {
		// 获取到已在nacos上配置的的xml映射文件
		Map<String, String> stringStringMap = attributeMapConfig.getSystem_attrmap();
		List<GroupMapAttrXML> groupMapAttrXMLList = new ArrayList<>();
		// 获取到父路径下的文件信息
		File fileDir = new File(ATTRMAP_PARENT_PATH);
		File[] childDir = fileDir.listFiles();
		if(Func.isNotEmpty(childDir) && childDir.length > 0){
			Arrays.stream(childDir).forEach(file->{
				GroupMapAttrXML groupMapAttrXML = new GroupMapAttrXML();
				if(!stringStringMap.isEmpty() && stringStringMap.containsKey(file.getName().replace(".xml",""))){
					groupMapAttrXML.setIsEnable(true);
				}else {
					groupMapAttrXML.setIsEnable(false);
				}
				groupMapAttrXML.setGroupMapAttrName(file.getName());
				groupMapAttrXML.setAttrMapPath(file.getPath());
				try {
					groupMapAttrXML.setGroupMapAttrContent(getXMLContent(file.getPath()));
				} catch (ServerException e) {
					throw new ServiceException(e.getMessage());
				}
				groupMapAttrXMLList.add(groupMapAttrXML);
			});
		}
		return groupMapAttrXMLList;
	}

	/**
	 * 修改属性映射文件
	 * @param groupMapAttrXMLVO
	 * @return
	 */
	public R updateGroupMapXML(GroupMapAttrXMLVO groupMapAttrXMLVO) throws IOException {
		if(Func.isEmpty(groupMapAttrXMLVO.getAttrMapPath())){
			throw new ServiceException("属性映射文件路径不能为空！");
		}
		File file = new File(groupMapAttrXMLVO.getAttrMapPath());
		// 文件名相同，就只需要修改内容
		if(groupMapAttrXMLVO.getGroupMapAttrName().equals(groupMapAttrXMLVO.getUpdateXMLName())){
			if(!file.exists()){
				return R.fail("被修改的"+groupMapAttrXMLVO.getGroupMapAttrName()+"文件不存在！");
			}
			FileWriter writer = null;
			try{
				writer = new FileWriter(file);
				writer.write(groupMapAttrXMLVO.getGroupMapAttrContent());
			}catch (IOException e) {
				e.printStackTrace();
				throw new ServerException("文件内容修改失败，原因："+e.getMessage());
			}finally {
				writer.close();
			}
		}else{
			//修改了文件名,就需要将文件名和内容进行修改
			File newFile = new File(groupMapAttrXMLVO.getAttrMapPath().replace(groupMapAttrXMLVO.getGroupMapAttrName(),groupMapAttrXMLVO.getUpdateXMLName()));
			FileWriter writer = null;
			try {
				writer = new FileWriter(newFile);
				writer.write(groupMapAttrXMLVO.getGroupMapAttrContent());
			} catch (IOException e) {
				e.printStackTrace();
				throw new ServerException("属性映射文件修改失败，原因："+e.getMessage());
			}finally {
				writer.close();
			}
			if (!file.delete()) {
				R.fail("属性映射文件名修改失败，请检查文件名是否重复！");
			}
		}
		Map<String, String> stringStringMap = attributeMapConfig.getSystem_attrmap();
		if (!stringStringMap.containsKey(groupMapAttrXMLVO.getUpdateXMLName().replace(".xml",""))) {
			return R.success("修改成功，修改属性映射文件名之后，未在nacos上找到相关配置，请及时更新nacos上的配置！");
		}
		return R.success("属性映射文件修改成功！");
	}

	@Override
	public R addGroupMapXML(GroupMapAttrXML groupMapAttrXML) throws IOException {
		if(Func.isEmpty(groupMapAttrXML.getGroupMapAttrName())){
			throw new ServiceException("属性映射文件名称不能为空！");
		}
		// 创建一个新文件
		File file = new File(ATTRMAP_PARENT_PATH);
		if(!file.exists()){
			return R.fail("nacos上xml属性映射文件，父路径配置有误，请检查！");
		}
		File[] files = file.listFiles();
		if(files.length>0){
			List<File> repeatNameFile = Arrays.stream(files).filter(item -> {
				if (item.getName().equals(groupMapAttrXML.getGroupMapAttrName())) {
					return true;
				}
				return false;
			}).collect(Collectors.toList());
			if (!repeatNameFile.isEmpty()) {
				return R.fail("新增的属性映射xml文件名已存在！");
			}
		}
		File addXMLFile = new File(ATTRMAP_PARENT_PATH + separator + groupMapAttrXML.getGroupMapAttrName());
		FileWriter writer = null;
		try {
			// 向文件中写入指定内容
			writer = new FileWriter(addXMLFile);
			writer.write(groupMapAttrXML.getGroupMapAttrContent());
		} catch (IOException e) {
			e.printStackTrace();
			throw new ServerException("文件内容写入失败，原因："+e.getMessage());
		}finally {
			writer.close();
		}
		Map<String, String> stringStringMap = attributeMapConfig.getSystem_attrmap();
		if (!stringStringMap.containsKey(groupMapAttrXML.getGroupMapAttrName().replace(".xml",""))) {
			groupMapAttrXML.setIsEnable(false);
			return R.success("新增成功，但新增的属性映射文件名，未在nacos上找到相关配置，请及时更新nacos上的配置！");
		}else {
			groupMapAttrXML.setIsEnable(true);
			return R.success("新增成功！");
		}
	}

	/**
	 * 获取xml文件中内容
	 * @return
	 */
	private String getXMLContent(String xmlPath) throws ServerException {
		try {
			File file = new File(xmlPath);
			byte[] bytes = Files.readAllBytes(Paths.get(file.toURI()));
			return new String(bytes);
		} catch (Exception e) {
			throw new ServerException(StringUtil.format("读取%s路径下的xml文件失败，原因：%s",xmlPath,e.getMessage()));
		}
	}

}