package com.java110.front.listener;

import com.java110.front.core.PackageScanner;
import com.java110.front.core.VueComponentTemplate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.io.ClassPathResource;
import org.springframework.util.StringUtils;

import java.io.*;
import java.util.HashMap;
import java.util.Map;

public class ReloadComponentFileListener extends PackageScanner implements Runnable {

    private Logger logger = LoggerFactory.getLogger(ReloadComponentFileListener.class);

    /**
     * 默认扫描组件路径
     */
    private static final String DEFAULT_COMPONENT_PACKAGE_PATH = "components";


    /**
     * js 文件
     */
    public static final String COMPONENT_JS = "js";

    /**
     * css 文件
     */
    public static final String COMPONENT_CSS = "css";

    /**
     * html 文件
     */
    public static final String COMPONENT_HTML = "html";


    private static final Map<String,Long> commentInfo = new HashMap<String,Long>();

    /**
     * 心跳加载组件信息 标志 true 为定时加载组件信息
     */
    private static boolean RELOAD_COMPONENT_FLAG = false;

    /**
     * 心跳时间，默认为5秒
     */
    private static long HEARTBEAT_TIME = 5 * 1000;

    public ReloadComponentFileListener() {

    }

    public ReloadComponentFileListener(boolean flag) {
        RELOAD_COMPONENT_FLAG = flag;
    }

    public ReloadComponentFileListener(boolean flag, long time) {
        RELOAD_COMPONENT_FLAG = flag;
        HEARTBEAT_TIME = time;
    }

    @Override
    public void run() {
        while (RELOAD_COMPONENT_FLAG) {
            try {
                reloadComponent();
                Thread.sleep(HEARTBEAT_TIME);//线程休息
            } catch (Throwable e) {
                logger.error("加载组件失败：", e);
            }
        }

    }

    private void reloadComponent() {
        logger.debug("开始扫描是否有组件添加或修改");
        VueComponentTemplate vueComponentTemplate = new VueComponentTemplate();
        vueComponentTemplate.packageScanner(DEFAULT_COMPONENT_PACKAGE_PATH, COMPONENT_JS);
        vueComponentTemplate.packageScanner(DEFAULT_COMPONENT_PACKAGE_PATH, COMPONENT_HTML);
        vueComponentTemplate.packageScanner(DEFAULT_COMPONENT_PACKAGE_PATH, COMPONENT_CSS);
        logger.debug("扫描完成是否有组件添加或修改");

    }

    @Override
    protected void handleResource(String filePath) {

        File componentFile = new File(filePath);
        Long lastModified = componentFile.lastModified();
        if(!commentInfo.containsKey(componentFile.getName())){
            commentInfo.put(componentFile.getName(), lastModified);
            reloadComponentContext(filePath);
        }
        Long prevModified = commentInfo.get(componentFile.getName());
        if (lastModified > prevModified) {
            reloadComponentContext(filePath);
            commentInfo.put(componentFile.getName(), lastModified);
        }
    }

    private void reloadComponentContext(String filePath){
        Reader reader = null;
        String sb = "";
        try {
            InputStream inputStream = new ClassPathResource(filePath).getInputStream();
            //InputStream inputStream = this.getClass().getClassLoader().getResourceAsStream(File.separator + filePath);
            reader = new InputStreamReader(inputStream, "UTF-8");
            int tempChar;
            StringBuffer b = new StringBuffer();
            while ((tempChar = reader.read()) != -1) {
                b.append((char) tempChar);
            }
            sb = b.toString();
            if (StringUtils.isEmpty(sb)) {
                return;
            }
            String componentKey = "";
            //这里在window 读取jar包中文件时，也是 / 但是直接启动时 为\这个 所以不能用 File.separator
            if (filePath.contains("/")) {
                componentKey = filePath.substring(filePath.lastIndexOf("/") + 1, filePath.length());
            } else {
                componentKey = filePath.substring(filePath.lastIndexOf("\\") + 1, filePath.length());
            }
            VueComponentTemplate.refreshComponent(componentKey, sb);

        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (reader != null) {
                try {
                    reader.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}