调整基础配置信息查询方式，取消jpa

czt

2025-12-01 096296cd7485c5583c8194d88cca700e3c4d84a0

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

@@ -1,8 +1,10 @@
package com.fzzy.igds.service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.fzzy.igds.constant.RedisConst;
import com.fzzy.igds.domain.QuantityConf;
import com.fzzy.igds.repository.QuantityConfRepository;
import com.fzzy.igds.mapper.QuantityConfMapper;
import com.fzzy.igds.utils.ContextUtil;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.utils.StringUtils;
@@ -24,12 +26,12 @@
public class QuantityService {

    @Resource
    private QuantityConfRepository quantityConfRepository;
    private QuantityConfMapper quantityConfMapper;
    @Resource
    private RedisCache redisCache;

    /**
     * JPA - 查询配置信息，根据库区编码获取
     * 查询配置信息，根据库区编码获取
     *
     * @param companyId
     * @param deptId
@@ -39,15 +41,22 @@
        if (StringUtils.isEmpty(companyId)) {
            companyId = ContextUtil.getCompanyId();
        }

        if (StringUtils.isEmpty(deptId)) {
            deptId = ContextUtil.subDeptId(null);
        }
        return quantityConfRepository.listQuantityConf(companyId, deptId);
        
        QueryWrapper<QuantityConf> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("company_id", companyId);
        if(StringUtils.isNotBlank(deptId)){
            queryWrapper.eq("dept_id", deptId);
        }
        queryWrapper.orderByAsc("order_num");

        return quantityConfMapper.selectList(queryWrapper);
    }

    /**
     * JPA - 查询配置信息，根据组织编码获取
     *  - 查询配置信息，根据组织编码获取
     *
     * @param companyId
     * @return
@@ -57,11 +66,11 @@
            companyId = ContextUtil.getCompanyId();
        }

        return quantityConfRepository.listQuantityConf(companyId);
        return this.getConfList(companyId, null);
    }

    /**
     * JPA - 更新保存数据
     *  - 更新保存数据
     *
     * @param conf
     */
@@ -69,41 +78,50 @@
        if (StringUtils.isEmpty(conf.getDepotId())) {
            return;
        }
        if (StringUtils.isEmpty(conf.getCompanyId())) {
        if (StringUtils.isBlank(conf.getCompanyId())) {
            conf.setCompanyId(ContextUtil.getCompanyId());
        }
        if (StringUtils.isEmpty(conf.getDeptId())) {
        if (StringUtils.isBlank(conf.getDeptId())) {
            conf.setDeptId(ContextUtil.subDeptId(null));
        }
        if (null == conf.getUpdateBy()) {
            conf.setCreateBy(ContextUtil.getLoginUserName());
            conf.setCreateTime(new Date());
            conf.setUpdateBy(ContextUtil.getLoginUserName());
            conf.setUpdateTime(new Date());
            quantityConfMapper.insert(conf);
        }else {
            conf.setUpdateBy(ContextUtil.getLoginUserName());
            conf.setUpdateTime(new Date());
            quantityConfMapper.updateById(conf);
        }
        conf.setUpdateBy(ContextUtil.getLoginUserName());
        conf.setUpdateTime(new Date());
        quantityConfRepository.save(conf);

        //刷新缓存
        setCacheQuantityConf(conf);
        this.setCacheQuantityConf(conf);
    }

    /**
     * JPA- 更新配置咋混个太
     * 更新信息
     *
     * @param conf
     */
    public void updateQuantityConfBySn(QuantityConf conf) {
        //更新状态
        quantityConfRepository.updateConfStatus(conf.getIp(), conf.getPort(), conf.getStatus(), conf.getSn());

        setCacheQuantityConf(conf);
        UpdateWrapper<QuantityConf> updateWrapper = new UpdateWrapper<>();
        updateWrapper.eq("sn", conf.getSn()).set("ip", conf.getIp()).set("port", conf.getPort()).set("status", conf.getStatus());
        quantityConfMapper.update(null, updateWrapper);

        this.setCacheQuantityConf(conf);
    }

    /**
     * JPA - 删除数据
     *  - 删除数据
     *
     * @param conf
     * @return
     */
    public String delQuantityConf(QuantityConf conf) {
        quantityConfRepository.delete(conf);
        quantityConfMapper.deleteById(conf);
        //删除配置信息

        flushConfCache(conf.getCompanyId(), conf.getDeptId());