客户需求优化调整4

czt

2026-02-07 2ebf9333d0a53949ff647444064a4c2b73c52fd3

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

@@ -4,6 +4,7 @@
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.fzzy.igds.constant.RedisConst;
import com.fzzy.igds.domain.Depot;
import com.fzzy.igds.domain.DepotStore;
import com.fzzy.igds.mapper.DepotMapper;
import com.fzzy.igds.utils.ContextUtil;
import com.ruoyi.common.core.redis.RedisCache;
@@ -55,6 +56,17 @@
        }

        return depotMapper.selectList(queryWrapper);
    }

    /**
     * 根据库存表信息，更新仓库库存
     * @param data
     */
    public void updateByDepotStore(DepotStore data) {
        UpdateWrapper<Depot> updateWrapper = new UpdateWrapper<>();
        updateWrapper.eq("id", data.getDepotId()).set("storage_real", data.getStorageReal());

        depotMapper.update(null, updateWrapper);
    }

    /**
@@ -187,25 +199,25 @@
        if (StringUtils.isEmpty(companyId)) {
            companyId = ContextUtil.getCompanyId();
        }
        String patten = RedisConst.buildKey(companyId, RedisConst.KEY_DEPOT) + "*";

        Collection<String> keys = redisCache.keys(patten);
        if (null == keys) {
            return null;
        }

        List<Depot> list = new ArrayList<>();
        for (String key : keys) {
            list.add((Depot) redisCache.getCacheObject(key));

        String patten = RedisConst.buildKey(companyId, RedisConst.KEY_DEPOT) + "*";
        Collection<String> keys = redisCache.keys(patten);
        if (null != keys) {
            for (String key : keys) {
                list.add((Depot) redisCache.getCacheObject(key));
            }
        }

        //缓存获取为空，则查询数据库
        if (list.size() < 1) {
        if (list.isEmpty()) {
            list = this.getData(companyId,null, false);
            setCacheDepotList(list, companyId);
        }

        //重新排序
        Collections.sort(list, (p1, p2) -> p1.getOrderNum() - p2.getOrderNum());
        if(!list.isEmpty()){
            //重新排序
            Collections.sort(list, (p1, p2) -> p1.getOrderNum() - p2.getOrderNum());
        }
        return list;
    }

@@ -230,8 +242,10 @@
                result.add(depot);
            }
        }
        //重新排序
        Collections.sort(result, (p1, p2) -> p1.getOrderNum() - p2.getOrderNum());
        if(!result.isEmpty()){
            //重新排序
            Collections.sort(list, (p1, p2) -> p1.getOrderNum() - p2.getOrderNum());
        }
        return result;
    }

@@ -257,4 +271,30 @@
        }
        return depot;
    }

    /**
     * 获取仓库信息-根据仓库名称获取仓库ID
     *
     * @param deptId
     * @return
     */
    public String getDepotId(String deptId, String depotName) {
        if (StringUtils.isEmpty(deptId)) {
            return null;
        }
        if (StringUtils.isEmpty(depotName)) {
            return null;
        }

        List<Depot> depotList = getCacheDepotList(ContextUtil.getCompanyId(), deptId);
        if(null == depotList || depotList.isEmpty()){
            return null;
        }
        for (Depot depot : depotList) {
            if(depotName.equals(depot.getName())){
                return depot.getId();
            }
        }
        return null;
    }
}