增加项目启动缓存刷新

czt

2026-01-13 0d82853185362b6546202556fafd49507c7e6365

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

@@ -2,14 +2,19 @@

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fzzy.igds.constant.RedisConst;
import com.fzzy.igds.data.QuantityParam;
import com.fzzy.igds.domain.Quantity;
import com.fzzy.igds.domain.QuantityConf;
import com.fzzy.igds.mapper.QuantityConfMapper;
import com.fzzy.igds.mapper.QuantityMapper;
import com.fzzy.igds.utils.ContextUtil;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.utils.StringUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Collection;
@@ -29,6 +34,76 @@
    private QuantityConfMapper quantityConfMapper;
    @Resource
    private RedisCache redisCache;
    @Resource
    private QuantityMapper  quantityMapper;


    /**
     * 分页查询质量检测数据
     *
     * @author sgj
     * @date 2025/12/18
     */
    public void listPageQuantity(Page<Quantity> page, QuantityParam param) {
        QueryWrapper<Quantity> queryWrapper = new QueryWrapper<>();

        param.setCompanyId(ContextUtil.getCompanyId());
        queryWrapper.eq("company_id", param.getCompanyId());
        //库区检索
        if (StringUtils.isNotBlank(param.getDeptId())) {
            queryWrapper.like("dept_id", param.getDeptId());
        }
        //仓库检索
        if (StringUtils.isNotBlank(param.getDepotId())) {
            queryWrapper.eq("depot_id", param.getDepotId());
        }
        //时间检索
        if(param.getStart() != null){
            queryWrapper.ge("receive_date", param.getStart());
        }
        if(param.getEnd() != null){
            queryWrapper.le("receive_date", param.getEnd());
        }
        queryWrapper.orderByAsc("receive_date");
        quantityMapper.selectPage(page, queryWrapper);

    }

    /**
     * 查询数据列表
     * @param depotId
     * @param limit    查询条数
     * @return
     */
    public List<Quantity> getQuantityList(String depotId, Integer limit) {
        if (StringUtils.isEmpty(depotId)) {
            return null;
        }

        QueryWrapper<Quantity> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("depot_id", depotId);
        queryWrapper.orderByDesc("receive_date");
        queryWrapper.last("LIMIT " + limit);

        return quantityMapper.selectList(queryWrapper);
    }

    /**
     * 保存数据
     *
     * @param data
     */
    public void saveData(Quantity data) {

        data.setUpdateBy(ContextUtil.getLoginUserName());
        data.setUpdateTime(new Date());

        if(StringUtils.isBlank(data.getCreateBy())){
            data.setCreateBy(ContextUtil.getLoginUserName());
            data.setCreateTime(new Date());
        }
        quantityMapper.insert(data);
    }

    /**
     * 查询配置信息，根据库区编码获取
@@ -44,10 +119,10 @@
        if (StringUtils.isEmpty(deptId)) {
            deptId = ContextUtil.subDeptId(null);
        }
        

        QueryWrapper<QuantityConf> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("company_id", companyId);
        if(StringUtils.isNotBlank(deptId)){
        if (StringUtils.isNotBlank(deptId)) {
            queryWrapper.eq("dept_id", deptId);
        }
        queryWrapper.orderByAsc("order_num");
@@ -56,7 +131,7 @@
    }

    /**
     *  - 查询配置信息，根据组织编码获取
     * - 查询配置信息，根据组织编码获取
     *
     * @param companyId
     * @return
@@ -70,7 +145,7 @@
    }

    /**
     *  - 更新保存数据
     * - 更新保存数据
     *
     * @param conf
     */
@@ -90,7 +165,7 @@
            conf.setUpdateBy(ContextUtil.getLoginUserName());
            conf.setUpdateTime(new Date());
            quantityConfMapper.insert(conf);
        }else {
        } else {
            conf.setUpdateBy(ContextUtil.getLoginUserName());
            conf.setUpdateTime(new Date());
            quantityConfMapper.update(conf, new UpdateWrapper<QuantityConf>().eq("depot_id", conf.getDepotId()));
@@ -115,7 +190,7 @@
    }

    /**
     *  - 删除数据
     * - 删除数据
     *
     * @param conf
     * @return