package com.qianwen.smartman.common.cache.cps;

import java.util.List;
import java.util.Map;
import org.apache.commons.compress.utils.Lists;
import com.qianwen.smartman.common.constant.ExtCacheConstant;
import com.qianwen.core.cache.utils.CacheUtil;
import com.qianwen.core.redis.cache.BladeRedis;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.core.tool.utils.SpringUtil;
import com.qianwen.core.tool.utils.StringUtil;
import com.qianwen.smartman.modules.smis.convert.EmployeeConvert;
import com.qianwen.smartman.modules.smis.dto.EmployeeDTO;
import com.qianwen.smartman.modules.smis.entity.Employee;
import com.qianwen.smartman.modules.smis.service.IEmployeeService;

public class EmployeeCache {
    private static final BladeRedis BLADE_REDIS = (BladeRedis) SpringUtil.getBean(BladeRedis.class);
    private static final IEmployeeService EMPLOYEE_SERVICE = (IEmployeeService) SpringUtil.getBean(IEmployeeService.class);
    private static final String EMPLOYEE_ALL = "employee:all";
    private static final String WORK = "workstation:id:{}:employee";
    private static final long EMPLOYEE_EXPIRE = 86400;

    public static Map<String, EmployeeDTO> getEmployees() {
        String redisKey = ExtCacheConstant.CPS_CACHE.concat("::").concat(EMPLOYEE_ALL);
        Map<String, EmployeeDTO> map = BLADE_REDIS.hGetAll(redisKey);
        if (Func.isEmpty(map)) {
            return setEmployees();
        }
        return map;
    }

    private static Map<String, EmployeeDTO> setEmployees() {
        List<Employee> list = EMPLOYEE_SERVICE.list();
        String redisKey = ExtCacheConstant.CPS_CACHE.concat("::").concat(EMPLOYEE_ALL);
        if (Func.isNotEmpty(list)) {
            list.forEach(employee -> {
                EmployeeDTO employeeDTO = EmployeeConvert.INSTANCE.convertToDTO(employee);
                BLADE_REDIS.hSet(redisKey, employeeDTO.getId(), employeeDTO);
            });
            BLADE_REDIS.expire(redisKey, 86400L);
        }
        return BLADE_REDIS.hGetAll(redisKey);
    }

    public static Boolean clearEmployeeCache() {
        WorkstationCache.clearWorkstationCache();
        CacheUtil.clear("blade:sys");
        CacheUtil.clear("blade:sys", Boolean.FALSE);
        return true;
    }

    public static void clearPerfCache(List<Long> workstationIds) {
        List<String> keys = Lists.newArrayList();
        workstationIds.forEach(wId -> {
            String redisKey = StringUtil.format(ExtCacheConstant.COLLECT_WORKSTATION.concat("::").concat(WORK), new Object[]{wId});
            keys.add(redisKey);
        });
        BLADE_REDIS.del(keys);
    }
}