增加项目启动缓存刷新

czt

2026-01-12 82e3be7117a57a4abec0e1c49a5b3bcffb588e81

增加项目启动缓存刷新

 fzzy-igdss-core/src/main/java/com/fzzy/igds/service/InoutConfService.java

@@ -106,7 +106,7 @@
        inoutSysConf.setProgressOut("REGISTER-WEIGHT_EMPTY-HANDLE-WEIGHT_FULL-RECORD");
        this.saveSysConfData(inoutSysConf);

        this.flushInoutSysConfCache(inoutSysConf);
        this.flushInoutSysConfCache();
    }

    /**
@@ -138,17 +138,22 @@
            inoutSysConfMapper.update(data, new UpdateWrapper<InoutSysConf>().eq("dept_id", data.getDeptId()));
        }

        this.flushInoutSysConfCache(data);
        this.flushInoutSysConfCache();
    }

    /**
     * è®¾ç½®ç¼“å­˜
     *
     * @param data
     */
    public void flushInoutSysConfCache(InoutSysConf data) {
        String key = RedisConst.buildKey(data.getDeptId(), Constant.CACHE_INOUT_SYS_CONF);
        redisCache.setCacheObject(key, data);
    public void flushInoutSysConfCache() {
        List<InoutSysConf> list = getSysConfData();
        if(null == list || list.isEmpty()){
            return;
        }
        for (InoutSysConf conf : list) {
            String key = RedisConst.buildKey(conf.getDeptId(), Constant.CACHE_INOUT_SYS_CONF);
            redisCache.setCacheObject(key, conf);
        }
    }

    /**
@@ -163,7 +168,7 @@
        InoutSysConf conf = (InoutSysConf) redisCache.getCacheObject(key);
        if (null == conf) {
            conf = getInoutSysConf(deptId);
            flushInoutSysConfCache(conf);
            flushInoutSysConfCache();
        }
        return conf;
    }

 fzzy-igdss-view/src/main/java/com/fzzy/igds/InoutSysConfPR.java

@@ -53,13 +53,7 @@
     */
    @Expose
    public void flushCache() {

        List<InoutSysConf> list = getSysConfData();
        if(null != list && list.size() > 0){
            for (InoutSysConf inoutSysConf : list) {
                inoutConfService.flushInoutSysConfCache(inoutSysConf);
            }
        }
        inoutConfService.flushInoutSysConfCache();
    }

}

 fzzy-igdss-web/src/main/java/com/fzzy/init/SystemRunner.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,102 @@
package com.fzzy.init;

import com.fzzy.igds.domain.Dept;
import com.fzzy.igds.service.*;
import com.ruoyi.system.service.ISysCompanyService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.CommandLineRunner;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;

/**
 * é…ç½®ç³»ç»Ÿçº§åˆ«çš„项目启动初始化信息
 *
 * @author Andy
 */
@Service
@Slf4j
@Order(value = 1)
public class SystemRunner implements CommandLineRunner {

    @Resource
    private ISysCompanyService iSysCompanyService;
    @Resource
    private SysDeptService sysDeptService;
    @Resource
    private CoreDeptService coreDeptService;
    @Resource
    private DicService dicService;
    @Resource
    private DepotService depotService;
    @Resource
    private DepotConfService depotConfService;
    @Resource
    private DeviceSerService deviceSerService;
    @Resource
    private InoutConfService inoutConfService;
    @Resource
    private SecCameraService secCameraService;
    @Resource
    private SnapConfService snapConfService;


    @Override
    public void run(String... args) throws Exception {
        //组织信息放入缓存
        iSysCompanyService.resetCompanyCache();
        List<Dept> list = coreDeptService.listDept(null, null, null);

        for (Dept dept : list) {

            flushCache(dept.getCompanyId(),dept.getId(), "系统调用");
        }
    }

    /**
     * åˆ†ç»„织初始化
     *
     * @param companyId
     * @param name
     */
    public void flushCache(String companyId,String deptId, String name) {

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

        //初始化常用字典到内存
        dicService.initDicMap(companyId);

        //初始化流程配置
        inoutConfService.flushInoutSysConfCache();

        //初始设备配置
        inoutConfService.flushInoutConfCache(companyId, deptId);

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

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

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

        //刷新分机到缓存
        deviceSerService.refreshCache(companyId);

        secCameraService.refreshCache(companyId);

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


}