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
new file mode 100644
index 00000000..b7064803
--- /dev/null
+++ b/cash-common/cash-common-service/src/main/java/com/czg/product/entity/ProductStockFlow.java
@@ -0,0 +1,98 @@
+package com.czg.product.entity;
+
+import com.mybatisflex.annotation.Column;
+import com.mybatisflex.annotation.Id;
+import com.mybatisflex.annotation.KeyType;
+import com.mybatisflex.annotation.Table;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+/**
+ * 商品库存变动记录
+ *
+ * @author Tankaikai tankaikai@aliyun.com
+ * @since 1.0 2025-02-21
+ */
+@Data
+@Table("tb_product_stock_flow")
+public class ProductStockFlow implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @Id(keyType = KeyType.Auto)
+    private Long id;
+    /**
+     * 店铺id
+     */
+    private Long shopId;
+    /**
+     * 出入库类型 in-入库 out-出库
+     */
+    private String inOutType;
+    /**
+     * 出入库名目 manual-in:手动入库 manual-out:手动出库 win-in:盘盈入库 loss-out:盘亏出库 order-in:订单退款入库 order-out:订单消费出库 damage-out:损耗出库
+     */
+    private String inOutItem;
+    /**
+     * 出入库日期
+     */
+    private LocalDate inOutDate;
+    /**
+     * 商品id
+     */
+    private Long productId;
+    /**
+     * 商品名称
+     */
+    private String productName;
+    /**
+     * 单位
+     */
+    private String unitName;
+    /**
+     * 变动前的库存
+     */
+    private BigDecimal beforeNumber;
+    /**
+     * 出入库数量
+     */
+    private BigDecimal inOutNumber;
+    /**
+     * 变动后的库存
+     */
+    private BigDecimal afterNumber;
+    /**
+     * 商品订单id
+     */
+    private Long orderId;
+    /**
+     * 相关图片urls，json数组
+     */
+    private String imgUrls;
+    /**
+     * 创建人id
+     */
+    private Long createUserId;
+    /**
+     * 创建人name
+     */
+    private String createUserName;
+    /**
+     * 创建时间
+     */
+    @Column(onInsertValue = "now()")
+    private LocalDateTime createTime;
+    /**
+     * 备注
+     */
+    private String remark;
+}
\ No newline at end of file
diff --git a/cash-common/cash-common-service/src/main/java/com/czg/product/param/ProductInfoParam.java b/cash-common/cash-common-service/src/main/java/com/czg/product/param/ProductInfoParam.java
new file mode 100644
index 00000000..eb260c26
--- /dev/null
+++ b/cash-common/cash-common-service/src/main/java/com/czg/product/param/ProductInfoParam.java
@@ -0,0 +1,40 @@
+package com.czg.product.param;
+
+import com.alibaba.fastjson2.annotation.JSONField;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+/**
+ * 商品出入库数据统计入参
+ * @author tankaikai
+ * @since 2025-03-12 17:30
+ */
+@Data
+public class ProductInfoParam implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+    /**
+     * 商品id
+     */
+    private Long id;
+    /**
+     * 商品分类id
+     */
+    private Long categoryId;
+    /**
+     * 商品类型 single-单规格商品 sku-多规格商品 package-套餐商品  weight-称重商品 coupon-团购券
+     */
+    private String type;
+    /**
+     * 商品名称
+     */
+    private String name;
+    /**
+     * 店铺id
+     */
+    @JSONField(serialize = false)
+    private Long shopId;
+}
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
new file mode 100644
index 00000000..3a7d1c1d
--- /dev/null
+++ b/cash-common/cash-common-service/src/main/java/com/czg/product/param/ProductStockFlowParam.java
@@ -0,0 +1,30 @@
+package com.czg.product.param;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+/**
+ * 商品出入库流水查询
+ * @author tankaikai
+ * @since 2025-03-13 15:59
+ */
+@Data
+public class ProductStockFlowParam implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+    /**
+     * 商品id
+     */
+    private Long productId;
+    /**
+     * 出入库类型 in-增加 out-减少
+     */
+    private String inOutType;
+    /**
+     * 出入库名目 win-in:手动增加 order-in:退货 loss-out:手动减少 order-out:销售量 damage-out:报损
+     */
+    private String inOutItem;
+}
diff --git a/cash-common/cash-common-service/src/main/java/com/czg/product/vo/ProductStatisticsVo.java b/cash-common/cash-common-service/src/main/java/com/czg/product/vo/ProductStatisticsVo.java
new file mode 100644
index 00000000..200ce700
--- /dev/null
+++ b/cash-common/cash-common-service/src/main/java/com/czg/product/vo/ProductStatisticsVo.java
@@ -0,0 +1,48 @@
+package com.czg.product.vo;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * 商品统计
+ * @author tankaikai
+ * @since 2025-03-12 17:34
+ */
+@Data
+public class ProductStatisticsVo implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 增加数量
+     */
+    private BigDecimal inSumTotal = BigDecimal.ZERO;
+    /**
+     * 盘盈增加数量（手动增加）
+     */
+    private BigDecimal winInNum = BigDecimal.ZERO;
+    /**
+     * 退货数量
+     */
+    private BigDecimal refundInNum = BigDecimal.ZERO;
+    /**
+     * 减少数量
+     */
+    private BigDecimal outSumTotal = BigDecimal.ZERO;
+    /**
+     * 盘亏减少数量（手动减少）
+     */
+    private BigDecimal lossOutNum = BigDecimal.ZERO;
+    /**
+     * 销售数量
+     */
+    private BigDecimal salesNum = BigDecimal.ZERO;
+    /**
+     * 报损数量
+     */
+    private BigDecimal damageNum = BigDecimal.ZERO;
+}
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
new file mode 100644
index 00000000..d3ee3088
--- /dev/null
+++ b/cash-service/product-service/src/main/java/com/czg/service/product/mapper/ProductStockFlowMapper.java
@@ -0,0 +1,18 @@
+package com.czg.service.product.mapper;
+
+import com.czg.product.entity.ProductStockFlow;
+import com.czg.product.param.ProductInfoParam;
+import com.czg.product.vo.ProductStatisticsVo;
+import com.mybatisflex.core.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 商品库存变动记录
+ *
+ * @author Tankaikai tankaikai@aliyun.com
+ * @since 1.0 2025-02-21
+ */
+@Mapper
+public interface ProductStockFlowMapper extends BaseMapper<ProductStockFlow> {
+    ProductStatisticsVo getProductStatistics(ProductInfoParam param);
+}
\ No newline at end of file
diff --git a/cash-service/product-service/src/main/resources/mapper/ProductStockFlowMapper.xml b/cash-service/product-service/src/main/resources/mapper/ProductStockFlowMapper.xml
new file mode 100644
index 00000000..73201e2a
--- /dev/null
+++ b/cash-service/product-service/src/main/resources/mapper/ProductStockFlowMapper.xml
@@ -0,0 +1,32 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.czg.service.product.mapper.ProductStockFlowMapper">
+
+    <select id="getProductStatistics" resultType="com.czg.product.vo.ProductStatisticsVo">
+        SELECT
+            sum( CASE WHEN t1.in_out_type = 'in' then t1.in_out_number end) AS inSumTotal,
+            sum( CASE WHEN t1.in_out_item = 'win-in' THEN t1.in_out_number END ) AS winInNum,
+            sum( CASE WHEN t1.in_out_item = 'order-in' THEN t1.in_out_number END ) AS refundInNum,
+            sum( CASE WHEN t1.in_out_type = 'out' then abs(t1.in_out_number) end) AS outSumTotal,
+            sum( CASE WHEN t1.in_out_item = 'loss-out' THEN abs(t1.in_out_number) END ) AS lossOutNum,
+            sum( CASE WHEN t1.in_out_item = 'order-out' THEN abs(t1.in_out_number) END ) AS salesNum,
+            sum( CASE WHEN t1.in_out_item = 'damage-out' THEN abs(t1.in_out_number) END ) AS damageNum
+        FROM
+            tb_product_stock_flow t1
+        LEFT JOIN tb_product t2 on t1.product_id = t2.id
+        where t1.shop_id = #{shopId}
+        <if test="id != null">
+            and t1.product_id = #{id}
+        </if>
+        <if test="categoryId != null">
+            and t2.category_id = #{categoryId}
+        </if>
+        <if test="name != null and name != ''">
+            and t2.name like concat('%', #{name}, '%') or t1.product_name like concat('%', #{name}, '%')
+        </if>
+        <if test="type != null and type != ''">
+            and t2.type = #{type}
+        </if>
+    </select>
+</mapper>
\ No newline at end of file