diff --git a/cash-common/cash-common-service/src/main/java/com/czg/product/entity/ProductStockFlow.java b/cash-common/cash-common-service/src/main/java/com/czg/product/entity/ProductStockFlow.java index b7064803c..4937d64e6 100644 --- a/cash-common/cash-common-service/src/main/java/com/czg/product/entity/ProductStockFlow.java +++ b/cash-common/cash-common-service/src/main/java/com/czg/product/entity/ProductStockFlow.java @@ -95,4 +95,9 @@ public class ProductStockFlow implements Serializable { * 备注 */ private String remark; + /** + * 商品订单编号 + */ + @Column(ignore = true) + private String orderNo; } \ No newline at end of file diff --git a/cash-common/cash-common-service/src/main/java/com/czg/product/param/ProductStockFlowParam.java b/cash-common/cash-common-service/src/main/java/com/czg/product/param/ProductStockFlowParam.java index 3a7d1c1d4..0abbc2153 100644 --- a/cash-common/cash-common-service/src/main/java/com/czg/product/param/ProductStockFlowParam.java +++ b/cash-common/cash-common-service/src/main/java/com/czg/product/param/ProductStockFlowParam.java @@ -1,5 +1,6 @@ package com.czg.product.param; +import com.alibaba.fastjson2.annotation.JSONField; import lombok.Data; import java.io.Serial; @@ -27,4 +28,9 @@ public class ProductStockFlowParam implements Serializable { * 出入库名目 win-in:手动增加 order-in:退货 loss-out:手动减少 order-out:销售量 damage-out:报损 */ private String inOutItem; + /** + * 门店id + */ + @JSONField(serialize = false) + private Long shopId; } diff --git a/cash-service/product-service/src/main/java/com/czg/service/product/mapper/ProductStockFlowMapper.java b/cash-service/product-service/src/main/java/com/czg/service/product/mapper/ProductStockFlowMapper.java index d3ee30886..a15b6edc8 100644 --- a/cash-service/product-service/src/main/java/com/czg/service/product/mapper/ProductStockFlowMapper.java +++ b/cash-service/product-service/src/main/java/com/czg/service/product/mapper/ProductStockFlowMapper.java @@ -2,10 +2,13 @@ package com.czg.service.product.mapper; import com.czg.product.entity.ProductStockFlow; import com.czg.product.param.ProductInfoParam; +import com.czg.product.param.ProductStockFlowParam; import com.czg.product.vo.ProductStatisticsVo; import com.mybatisflex.core.BaseMapper; import org.apache.ibatis.annotations.Mapper; +import java.util.List; + /** * 商品库存变动记录 * @@ -15,4 +18,6 @@ import org.apache.ibatis.annotations.Mapper; @Mapper public interface ProductStockFlowMapper extends BaseMapper { ProductStatisticsVo getProductStatistics(ProductInfoParam param); + + List getProductStockFlowList(ProductStockFlowParam param); } \ No newline at end of file diff --git a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java index 8cc7ee1ce..2f38305aa 100644 --- a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java +++ b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java @@ -223,6 +223,7 @@ public class ProductRpcServiceImpl implements ProductRpcService { flow.setAfterNumber(NumberUtil.add(NumberUtil.toBigDecimal(product.getStockNumber()), NumberUtil.toBigDecimal(dto.getNum()))); flow.setInOutType(InOutTypeEnum.IN.value()); flow.setInOutItem(InOutItemEnum.ORDER_IN.value()); + flow.setOrderId(orderId); productStockFlowMapper.insert(flow); // 查询商品绑定耗材信息 List relationList = prodConsRelationMapper.selectListByQuery(QueryWrapper.create().eq(ProdConsRelation::getProductId, dto.getProductId())); diff --git a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductServiceImpl.java b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductServiceImpl.java index 3ef29bc46..b8cd0e8da 100644 --- a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductServiceImpl.java +++ b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductServiceImpl.java @@ -25,6 +25,8 @@ import com.czg.product.vo.ProductStatisticsVo; import com.czg.sa.StpKit; import com.czg.service.product.mapper.*; import com.czg.utils.PageUtil; +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; import com.mybatisflex.core.paginate.Page; import com.mybatisflex.core.query.QueryWrapper; import com.mybatisflex.core.update.UpdateChain; @@ -501,18 +503,8 @@ public class ProductServiceImpl extends ServiceImpl impl @Override public Page findProductStockFlowPage(ProductStockFlowParam param) { Long shopId = StpKit.USER.getShopId(0L); - QueryWrapper queryWrapper = QueryWrapper.create(); - queryWrapper.eq(ProductStockFlow::getShopId, shopId); - if (StrUtil.isNotBlank(param.getInOutType())) { - queryWrapper.eq(ProductStockFlow::getInOutType, param.getInOutType()); - } - if (StrUtil.isNotBlank(param.getInOutItem())) { - queryWrapper.eq(ProductStockFlow::getInOutItem, param.getInOutItem()); - } - if (ObjUtil.isNotNull(param.getProductId())) { - queryWrapper.eq(ProductStockFlow::getProductId, param.getProductId()); - } - queryWrapper.orderBy(ProductStockFlow::getId, false); - return productStockFlowMapper.paginate(PageUtil.buildPage(), queryWrapper); + param.setShopId(shopId); + PageHelper.startPage(PageUtil.buildPageHelp()); + return PageUtil.convert(new PageInfo<>(productStockFlowMapper.getProductStockFlowList(param))); } } diff --git a/cash-service/product-service/src/main/resources/mapper/ProductStockFlowMapper.xml b/cash-service/product-service/src/main/resources/mapper/ProductStockFlowMapper.xml index 73201e2a9..92486cb97 100644 --- a/cash-service/product-service/src/main/resources/mapper/ProductStockFlowMapper.xml +++ b/cash-service/product-service/src/main/resources/mapper/ProductStockFlowMapper.xml @@ -29,4 +29,22 @@ and t2.type = #{type} + \ No newline at end of file