| | |
| | | import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX; |
| | | import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX; |
| | | import cn.iocoder.yudao.framework.mybatis.core.query.MPJLambdaWrapperX; |
| | | import cn.iocoder.yudao.module.wms.api.inventory.dto.WmsInventoryQueryReqDTO; |
| | | import cn.iocoder.yudao.module.wms.controller.admin.inventory.vo.WmsInventoryListReqVO; |
| | | import cn.iocoder.yudao.module.wms.controller.admin.inventory.vo.WmsInventoryPageReqVO; |
| | | import cn.iocoder.yudao.module.wms.dal.dataobject.inventory.WmsInventoryDO; |
| | |
| | | } |
| | | return selectList(new LambdaQueryWrapperX<WmsInventoryDO>() |
| | | .in(WmsInventoryDO::getId, ids) |
| | | .orderByAsc(WmsInventoryDO::getId) |
| | | .last("FOR UPDATE")); |
| | | } |
| | | |
| | |
| | | return; |
| | | } |
| | | throw new IllegalArgumentException("未知库存统计维度:" + type); |
| | | } |
| | | |
| | | /** |
| | | * 根据 API 查询条件查询库存列表 |
| | | */ |
| | | default List<WmsInventoryDO> selectListByQuery(WmsInventoryQueryReqDTO reqDTO) { |
| | | LambdaQueryWrapperX<WmsInventoryDO> query = new LambdaQueryWrapperX<WmsInventoryDO>() |
| | | .inIfPresent(WmsInventoryDO::getSkuId, reqDTO.getSkuIds()) |
| | | .inIfPresent(WmsInventoryDO::getWarehouseId, reqDTO.getWarehouseIds()); |
| | | if (Boolean.TRUE.equals(reqDTO.getOnlyPositive())) { |
| | | query.gt(WmsInventoryDO::getQuantity, BigDecimal.ZERO); |
| | | } |
| | | return selectList(query); |
| | | } |
| | | |
| | | } |