package org.jeecg.config.init;

import org.jeecg.common.constant.CommonCacheConstant;
import org.jeecg.common.util.RedisUtil;
import org.jeecg.modules.system.entity.SysTenant;
import org.jeecg.modules.system.service.ISysTenantService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.event.ApplicationStartedEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;

import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

@Component
public class RedisInitListener  implements ApplicationListener<ApplicationStartedEvent> {
    @Autowired
    private RedisUtil redisUtil;
    @Autowired
    private ISysTenantService sysTenantService;

    @Override
    public void onApplicationEvent(ApplicationStartedEvent event) {
        //查询所有租户信息并缓存至redis
        List<SysTenant> tenantList = sysTenantService.list();
        //list转map
        Map<String, Object> tenantMap = tenantList.stream()
                .collect(Collectors.toMap(t -> String.valueOf(t.getId()),  t -> (Object) t.getName(), (existingValue, newValue) -> existingValue));
        redisUtil.hmset(CommonCacheConstant.SYS_CACHE_TENANT,tenantMap);
    }
}