package com.xcong.excoin.common.initialization; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.StrUtil; import com.xcong.excoin.common.contants.AppContants; import com.xcong.excoin.common.system.dao.DataDictionaryCustomDao; import com.xcong.excoin.common.system.entity.DataDictionaryCustom; import com.xcong.excoin.modules.fish.dao.CannonSettingDao; import com.xcong.excoin.modules.fish.entity.CannonSetting; import com.xcong.excoin.utils.RedisUtils; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import javax.annotation.PostConstruct; import java.util.HashMap; import java.util.List; import java.util.Map; /** * @author wzy * @date 2021-11-26 **/ @Slf4j @Component public class InitJob { @Autowired private RedisUtils redisUtils; @Autowired private DataDictionaryCustomDao dictionaryCustomDao; @Autowired private CannonSettingDao cannonSettingDao; @PostConstruct public void init() { log.info("####项目初始化数据####"); // 初始化鱼类数据到redis缓存 List fishTypes = dictionaryCustomDao.selectDicByType(AppContants.DICTIONARY_TYPE_FISH); if (CollUtil.isNotEmpty(fishTypes)) { Map map = new HashMap<>(); for (DataDictionaryCustom fishType : fishTypes) { Integer cnt = StrUtil.isEmpty(fishType.getValue()) ? 0 : Integer.parseInt(fishType.getValue()); map.put(fishType.getCode(), cnt); redisUtils.hmset(AppContants.DICTIONARY_TYPE_FISH, map); } } // 初始化大炮数据到redis缓存 List settings = cannonSettingDao.selectByMap(null); if (CollUtil.isNotEmpty(settings)) { Map map = new HashMap<>(); for (CannonSetting setting : settings) { map.put(setting.getCode(), setting.getGoldConsume()); redisUtils.hmset(AppContants.CANNON_TYPE, map); } } } }