package com.vci.web.service.impl;

import com.vci.frameworkcore.compatibility.ISmFunctionQueryService;
import com.vci.starter.web.enumpck.DataSecretEnum;
import com.vci.starter.web.exception.VciBaseException;
import com.vci.starter.web.properties.VciSessionProperties;
import com.vci.starter.web.util.ApplicationContextProvider;
import com.vci.web.properties.WebProperties;
import com.vci.web.service.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

import java.util.Collections;
import java.util.HashMap;
import java.util.Map;

/**
 * 初始化后的处理缓存的服务
 * @author weidy
 * @date 2022-1-12
 */
@Component
public class WebInitServiceImpl {

    /**
     * 业务类型
     */
    @Autowired
    private OsBtmServiceI btmService;

    /**
     * 链接类型
     */
    @Autowired
    private OsLinkTypeServiceI linkTypeService;

    /**
     * UI
     */
    @Autowired
    private UIEngineServiceI uiEngineService;

    /**
     * 菜单
     */
    @Autowired
    private ISmFunctionQueryService functionQueryService;
    /**
     * 密级服务
     */
    @Autowired
    private WebSecretServiceI webSecretService;

    /**
     * 状态的服务
     */
    @Autowired
    private OsStatusServiceI statusService;

    /**
     * 生命周期的服务
     */
    @Autowired
    private OsLifeCycleServiceI lifeCycleService;

    /**
     * 枚举的服务
     */
    @Autowired
    private OsEnumServiceI enumService;

    /**
     * 规则的服务
     */
    @Autowired
    private OsRevisionRuleServiceI revisionRuleService;

    /**
     * 属性的服务
     */
    @Autowired
    private OsAttributeServiceI attributeService;

    /**
     * 会话的信息
     */
    @Autowired(required = false)
    private VciSessionProperties sessionProperties;

    /**
     * web相关配置
     */
    @Autowired
    private WebProperties webProperties;

    /**
     * 业务类型的服务
     */
    @Autowired
    private WebBoServiceI boService;

    /**
     * 主服务是否在执行缓存
     * @return true表示没有执行，执行中会抛出异常
     */
    public boolean checkMainServerUnCache(){
        //看看主服务在执行刷新缓存没有
        boolean finishInitCache = false;
        for(int i = 0 ; i < 10 ; i++){
            if(boService.queryCountBySql("select count(*) from plcachetemp",new HashMap<>()) ==0){
                finishInitCache = true;
                break;
            }else{
                //说明主服务在执行
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
        if(!finishInitCache){
            throw new VciBaseException("暂时不能刷新，因为主服务还正在执行初始化缓存");
        }
        return finishInitCache;
    }

    /**
     * 清除所有的缓存
     */
    public void clearAllCache(){
        Map<String, OsBaseServiceI> beans = ApplicationContextProvider.getApplicationContext().getBeansOfType(OsBaseServiceI.class);
        if(!CollectionUtils.isEmpty(beans)){
            beans.forEach((name,bean)->{
                bean.clearCache();
            });
        }
    }

    /**
     *  初始化服务端的缓存
     * @throws Exception 查询的时候出现错误的时候
     */
    public void initServerCache(){
        long currentTime = System.currentTimeMillis();
        System.out.println("开始启动状态池的缓存，时间有点长，请耐心等待");
        statusService.selectAllStatusMap();
        System.out.println("状态池的刷新完成,耗时" + (System.currentTimeMillis()-currentTime) + ",开始刷新生命周期");
        currentTime = System.currentTimeMillis();
        lifeCycleService.selectAllLifeCycleMap();
        System.out.println("生命周期刷新完成,耗时" + (System.currentTimeMillis()-currentTime) + ",开始刷新枚举");
        currentTime = System.currentTimeMillis();
        enumService.selectAllEnumMap();

        System.out.println(DataSecretEnum.NONE.getValue());
        System.out.println("枚举刷新完成,耗时" + (System.currentTimeMillis()-currentTime) + ",开始刷新版本规则");
        currentTime = System.currentTimeMillis();
        revisionRuleService.selectAllRevisionMap();
        System.out.println("版本规则刷新完成,耗时" + (System.currentTimeMillis()-currentTime) + ",开始刷新属性");
        currentTime = System.currentTimeMillis();
        attributeService.selectAllAttributeMap();
        System.out.println("属性刷新完成,耗时" + (System.currentTimeMillis()-currentTime) + ",开始刷新业务类型");
        currentTime = System.currentTimeMillis();
        btmService.selectAllBtmMap();
        System.out.println("业务类型刷新完成,耗时" + (System.currentTimeMillis()-currentTime) + ",开始刷新链接类型");
        currentTime = System.currentTimeMillis();
        linkTypeService.selectAllLinkMap();
        System.out.println("链接类型刷新完成,耗时" + (System.currentTimeMillis()-currentTime) + ",开始刷新UI上下文");
        currentTime = System.currentTimeMillis();
        if(webProperties.isCacheUIOnInit()) {
            uiEngineService.selectAllFormMap();
        }
        uiEngineService.selectAllActionMap();
        System.out.println("UI上下文刷新完成,耗时" + (System.currentTimeMillis()-currentTime) );
        currentTime = System.currentTimeMillis();
        functionQueryService.selectAllFunctionMap();
        System.out.println("菜单刷新,耗时" + (System.currentTimeMillis()-currentTime) );
    }
}