package com.ld.igds.init;

import com.bstek.bdf2.core.model.DefaultCompany;
import com.bstek.dorado.annotation.Expose;
import com.ld.igds.common.CoreCommonService;
import com.ld.igds.common.CoreSerService;
import com.ld.igds.sys.service.DicTriggerService;
import com.ld.igds.sys.service.SysCompanyService;
import com.ld.igds.sys.service.SysDeptService;
import com.ld.igds.sys.service.SystemService;
import com.ld.igds.view.service.BuildingService;
import com.ld.igds.view.service.HDepotService;
import com.ld.igds.view.service.DeviceService;
import com.ld.igds.view.service.SysConfService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * 配置系统级别的项目启动初始化信息
 *
 * @author Andy
 */
@Service
@Slf4j
@Order(value = 1)
public class SystemRunner implements CommandLineRunner {

    @Autowired
    private DicTriggerService dicService;
    @Autowired
    private CoreSerService coreSerService;
    @Autowired
    private HDepotService depotService;
    @Autowired
    private BuildingService buildingService;
    @Autowired
    private DeviceService deviceService;
    @Autowired
    private SysConfService sysConfService;
    @Autowired
    private SysDeptService sysDeptService;
    @Autowired
    private SysCompanyService companyService;
    @Autowired
    private SystemService systemService;
    @Autowired
    private CoreCommonService coreCommonService;

    @Override
    public void run(String... args) throws Exception {

        List<DefaultCompany> list = companyService.getAll();
        //放入缓存
        coreCommonService.setCacheCompany(list);

        for (DefaultCompany company : list) {
            flushCache(company.getId(), company.getName());
        }

        //初始化用户部门内存
        sysDeptService.initUserDeptMap();

        // 刷新菜单
        systemService.refreshUrlCache();
    }

    public void flushCache(String companyId, String name) throws Exception {

        // 设置分机全部掉线
        coreSerService.allOffLine(companyId);

        // 初始化缓存
        dicService.refreshCache(companyId);

        //分机
        coreSerService.refreshCache(companyId);

        //初始化仓库
        depotService.flushCache(companyId);

        //系统配置
        sysConfService.flushCacheSysConf(companyId);

        // 需要先刷新仓库缓存后刷新配置
        Thread.sleep(500);

        //参数配置
        depotService.flushConfCache(companyId);

        //建筑物
        buildingService.refreshCache(companyId);

        //设备配置
        deviceService.refreshCache(companyId);

        //子部门配置
        sysDeptService.flushDeptCache(companyId);

        //初始化控制柜仓库的虚拟用户
        depotService.initUserDeptMap(companyId);

        log.info("* ");
        log.info("* ========================");
        log.info("* ");
        log.info("* 组织={}，初始化缓存完成…………", companyId);
        log.info("* ");
        log.info("* ========================");
        log.info("* ");
    }


    /**
     * 刷新所有缓存，包括菜单
     *
     * @param companyId
     * @throws Exception
     */
    @Expose
    public void flushAllCache(String companyId) throws Exception {

        flushCache(companyId, "手动调用");
        //公司信息放入缓存
        List<DefaultCompany> list = companyService.getAll();
        coreCommonService.setCacheCompany(list);

        // 刷新菜单
        systemService.refreshUrlCache();
    }
}