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

import com.vci.ubcs.log.service.ILogSystemService;
import com.vci.ubcs.log.entity.SystemLog;
import org.springblade.core.log.exception.ServiceException;
import com.vci.ubcs.omd.cache.EnumCache;
import com.vci.ubcs.omd.enums.EnumEnum;
import com.vci.ubcs.resource.bo.FileObjectBO;
import org.springblade.core.tool.utils.Func;
import org.springframework.stereotype.Service;
import java.io.File;
import java.io.IOException;
import java.nio.file.FileSystems;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.attribute.BasicFileAttributes;
import java.rmi.ServerException;
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * 本地系统日志
 * @author ludc
 * @date 2023/10/31 15:39
 */
@Service
public class LogSystemServiceImpl implements ILogSystemService{

	/**
	 * 各个服务存放的的父路径
	 */
	private final String parentPath = "/data1/ubcs/ubcs-server";

	/**
	 * 各个服务的日志具体的目录路径
	 */
	//@Value("#{'${ip-whitelist.ip}'.split(',')}")
	private List<String> serviceDirNames = new ArrayList<>(Arrays.asList("/ubcs_code/target/log","/ubcs_omd/target/log","/ubcs_system/target/log"));

	/**
	 * 获取本地日志列表
	 * @param logParentPath
	 * @return
	 */
	@Override
	public List<SystemLog> getSystemLogList(String logParentPath) {
		List<SystemLog> systemLogs = new ArrayList<>();
		// 不为空说明是加载当前这个服务路径下的日志文件
		if(Func.isNotEmpty(logParentPath)){
			File file = new File(logParentPath);
			if (file.isDirectory()) {
				File[] files = file.listFiles();
				Arrays.stream(files).forEach(item->{
					// 组建日志文件对象
					SystemLog systemLog = new SystemLog();
					systemLog.setLogName(item.getName());
					systemLog.setLogType(getLogType(item.getName()));
					systemLog.setCreateTime(getLastModifiedOrCreatTime(false,logParentPath));
					systemLog.setLastmodifier(getLastModifiedOrCreatTime(true,logParentPath));
					systemLog.setLogPath(logParentPath);
					String serviceId = getServiceId(logParentPath);
					systemLog.setServiceId(serviceId);
					systemLog.setServiceName(getServiceName(serviceId));
					systemLogs.add(systemLog);
				});
			}
		}else {
			serviceDirNames.stream().forEach(serviceDirName->{
				File file = new File(parentPath+serviceDirName);
				SystemLog systemLog = new SystemLog();
				systemLog.setLastmodifier(getLastModifiedOrCreatTime(true,parentPath+serviceDirName));
				systemLog.setCreateTime(getLastModifiedOrCreatTime(false,parentPath+serviceDirName));
				systemLog.setLogPath(parentPath+serviceDirName);
				String serviceId = getServiceId(logParentPath);
				systemLog.setServiceId(serviceId);
				systemLog.setServiceName(getServiceName(serviceId));
				systemLogs.add(systemLog);
			});
		}
		return systemLogs;
	}

	/**
	 * 获取文件最后修改或者创建时间
	 * @param isModifier
	 * @return
	 */
	private String getLastModifiedOrCreatTime(boolean isModifier,String pathStr) {
		Path path = FileSystems.getDefault().getPath(pathStr);
		String date = "";
		try {
			BasicFileAttributes attr = Files.readAttributes(path, BasicFileAttributes.class);
			SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			// 是获取最后修改时间
			if(isModifier){
				date = dateFormat.format(new Date(attr.lastModifiedTime().toMillis()));
			}else {
				date = dateFormat.format(new Date(attr.creationTime().toMillis()));
			}
		} catch (IOException e) {
			throw new ServiceException("Error reading file date attributes: " + e.getMessage());
		}
		return date;
	}

	/**
	 * 获取日志类型
	 * @param fileName
	 * @return
	 */
	private String getLogType(String fileName){
		//判断日志的的类型
		if (fileName.contains("error")) {
			return "Error";
		} else if (fileName.contains("info")) {
			return "Info";
		} else if (fileName.contains("warning")) {
			return "Warning";
		} else {
			return "Unknown";
		}
	}

	/**
	 * 获取服务ID
	 * @param servciePath
	 * @return
	 */
	private String getServiceId(String servciePath){
		String[] parts = servciePath.split("/");
		String extractedString = parts[parts.length - 2];
		return extractedString;
	}

	/**
	 * 获取服务名称
	 * @param serViceId
	 * @return
	 */
	private String getServiceName(String serViceId){
		return EnumCache.getValue(EnumEnum.SERCIVE_NAME_ROLE, serViceId);
	}

	/**
	 * 下载日志文件
	 * @param condition 查询条件map
	 * @return
	 * @throws ServerException
	 */
	@Override
	public FileObjectBO downloadLogByServiceNameAndFileName(Map<String, String> condition) throws ServerException {
		return null;
	}

	/**
	 * 删除日志文件
	 * @param condition 主键集合
	 * @throws ServerException
	 */
	@Override
	public void deleteLogFile(Map<String, String> condition) throws ServerException {

	}

}