reactor：移除 erp 的 api 包

YunaiV
1 parent 7944d57e
Showing 236 changed files with 922 additions and 987 deletions
yudao-module-erp/pom.xml
yudao-module-erp/yudao-module-erp-api/src/main/java/cn/iocoder/yudao/module/erp/enums/ErpAuditStatus.java → yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/enums/ErpAuditStatus.java
yudao-module-erp/yudao-module-erp-biz/src/main/java/cn/iocoder/yudao/module/erp/framework/package-info.java → yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/framework/package-info.java
yudao-module-erp/yudao-module-erp-biz/src/main/java/cn/iocoder/yudao/module/erp/package-info.java → yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/package-info.java
yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/stock/ErpStockCheckService.java
yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/stock/ErpStockInService.java
yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/stock/ErpStockMoveService.java
yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/stock/ErpStockOutService.java
yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/stock/ErpStockRecordServiceImpl.java
yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/stock/ErpStockService.java
yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/stock/ErpStockServiceImpl.java
yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/stock/ErpWarehouseService.java
yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/stock/ErpWarehouseServiceImpl.java
yudao-module-erp/src/main/java/cn/iocoder/yudao/module/erp/service/stock/bo/ErpStockRecordCreateReqBO.java
yudao-module-erp/src/main/resources/mapper/statistics/ErpPurchaseStatisticsMapper.xml
yudao-module-erp/src/main/resources/mapper/statistics/ErpSaleStatisticsMapper.xml
yudao-module-erp/yudao-module-erp-api/pom.xml
yudao-module-erp/yudao-module-erp-api/src/main/java/cn/iocoder/yudao/module/erp/api/package-info.java
yudao-module-erp/yudao-module-erp-biz/pom.xml
yudao-module-erp/yudao-module-erp-biz/src/main/java/cn/iocoder/yudao/module/erp/service/stock/ErpStockCheckService.java
@@ -7,13 +7,9 @@
         <artifactId>yudao</artifactId>
         <version>${revision}</version>
     </parent>
-    <modules>
-        <module>yudao-module-erp-api</module>
-        <module>yudao-module-erp-biz</module>
-    </modules>
     <modelVersion>4.0.0</modelVersion>
     <artifactId>yudao-module-erp</artifactId>
-    <packaging>pom</packaging>
+    <packaging>jar</packaging>
     <name>${project.artifactId}</name>
     <description>
@@ -21,4 +17,49 @@
         例如说：采购、销售、库存、财务、产品等等
     </description>
+    <dependencies>
+        <dependency>
+            <groupId>cn.iocoder.boot</groupId>
+            <artifactId>yudao-module-system</artifactId>
+            <version>${revision}</version>
+        </dependency>
+
+        <!-- 业务组件 -->
+
+        <!-- Web 相关 -->
+        <dependency>
+            <groupId>cn.iocoder.boot</groupId>
+            <artifactId>yudao-spring-boot-starter-web</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>cn.iocoder.boot</groupId>
+            <artifactId>yudao-spring-boot-starter-security</artifactId>
+        </dependency>
+
+        <!-- DB 相关 -->
+        <dependency>
+            <groupId>cn.iocoder.boot</groupId>
+            <artifactId>yudao-spring-boot-starter-mybatis</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>cn.iocoder.boot</groupId>
+            <artifactId>yudao-spring-boot-starter-redis</artifactId>
+        </dependency>
+
+        <!-- 工具类相关 -->
+        <dependency>
+            <groupId>cn.iocoder.boot</groupId>
+            <artifactId>yudao-spring-boot-starter-excel</artifactId>
+        </dependency>
+
+        <!-- Test 测试相关 -->
+        <dependency>
+            <groupId>cn.iocoder.boot</groupId>
+            <artifactId>yudao-spring-boot-starter-test</artifactId>
+        </dependency>
+
+    </dependencies>
+
 </project>
 \ No newline at end of file
+package cn.iocoder.yudao.module.erp.service.stock;
+
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.check.ErpStockCheckPageReqVO;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.check.ErpStockCheckSaveReqVO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockCheckDO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockCheckItemDO;
+import jakarta.validation.Valid;
+
+import java.util.Collection;
+import java.util.List;
+
+/**
+ * ERP 库存盘点单 Service 接口
+ *
+ * @author 芋道源码
+ */
+public interface ErpStockCheckService {
+
+    /**
+     * 创建库存盘点单
+     *
+     * @param createReqVO 创建信息
+     * @return 编号
+     */
+    Long createStockCheck(@Valid ErpStockCheckSaveReqVO createReqVO);
+
+    /**
+     * 更新库存盘点单
+     *
+     * @param updateReqVO 更新信息
+     */
+    void updateStockCheck(@Valid ErpStockCheckSaveReqVO updateReqVO);
+
+    /**
+     * 更新库存盘点单的状态
+     *
+     * @param id 编号
+     * @param status 状态
+     */
+    void updateStockCheckStatus(Long id, Integer status);
+
+    /**
+     * 删除库存盘点单
+     *
+     * @param ids 编号数组
+     */
+    void deleteStockCheck(List<Long> ids);
+
+    /**
+     * 获得库存盘点单
+     *
+     * @param id 编号
+     * @return 库存盘点单
+     */
+    ErpStockCheckDO getStockCheck(Long id);
+
+    /**
+     * 获得库存盘点单分页
+     *
+     * @param pageReqVO 分页查询
+     * @return 库存盘点单分页
+     */
+    PageResult<ErpStockCheckDO> getStockCheckPage(ErpStockCheckPageReqVO pageReqVO);
+
+    // ==================== 盘点项 ====================
+
+    /**
+     * 获得库存盘点单项列表
+     *
+     * @param checkId 盘点编号
+     * @return 库存盘点单项列表
+     */
+    List<ErpStockCheckItemDO> getStockCheckItemListByCheckId(Long checkId);
+
+    /**
+     * 获得库存盘点单项 List
+     *
+     * @param checkIds 盘点编号数组
+     * @return 库存盘点单项 List
+     */
+    List<ErpStockCheckItemDO> getStockCheckItemListByCheckIds(Collection<Long> checkIds);
+
+}
 \ No newline at end of file
+package cn.iocoder.yudao.module.erp.service.stock;
+
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.in.ErpStockInPageReqVO;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.in.ErpStockInSaveReqVO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockInDO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockInItemDO;
+import jakarta.validation.Valid;
+
+import java.util.Collection;
+import java.util.List;
+
+/**
+ * ERP 其它入库单 Service 接口
+ *
+ * @author 芋道源码
+ */
+public interface ErpStockInService {
+
+    /**
+     * 创建其它入库单
+     *
+     * @param createReqVO 创建信息
+     * @return 编号
+     */
+    Long createStockIn(@Valid ErpStockInSaveReqVO createReqVO);
+
+    /**
+     * 更新其它入库单
+     *
+     * @param updateReqVO 更新信息
+     */
+    void updateStockIn(@Valid ErpStockInSaveReqVO updateReqVO);
+
+    /**
+     * 更新其它入库单的状态
+     *
+     * @param id 编号
+     * @param status 状态
+     */
+    void updateStockInStatus(Long id, Integer status);
+
+    /**
+     * 删除其它入库单
+     *
+     * @param ids 编号数组
+     */
+    void deleteStockIn(List<Long> ids);
+
+    /**
+     * 获得其它入库单
+     *
+     * @param id 编号
+     * @return 其它入库单
+     */
+    ErpStockInDO getStockIn(Long id);
+
+    /**
+     * 获得其它入库单分页
+     *
+     * @param pageReqVO 分页查询
+     * @return 其它入库单分页
+     */
+    PageResult<ErpStockInDO> getStockInPage(ErpStockInPageReqVO pageReqVO);
+
+    // ==================== 入库项 ====================
+
+    /**
+     * 获得其它入库单项列表
+     *
+     * @param inId 入库编号
+     * @return 其它入库单项列表
+     */
+    List<ErpStockInItemDO> getStockInItemListByInId(Long inId);
+
+    /**
+     * 获得其它入库单项 List
+     *
+     * @param inIds 入库编号数组
+     * @return 其它入库单项 List
+     */
+    List<ErpStockInItemDO> getStockInItemListByInIds(Collection<Long> inIds);
+
+}
 \ No newline at end of file
+package cn.iocoder.yudao.module.erp.service.stock;
+
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.move.ErpStockMovePageReqVO;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.move.ErpStockMoveSaveReqVO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockMoveDO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockMoveItemDO;
+import jakarta.validation.Valid;
+
+import java.util.Collection;
+import java.util.List;
+
+/**
+ * ERP 库存调拨单 Service 接口
+ *
+ * @author 芋道源码
+ */
+public interface ErpStockMoveService {
+
+    /**
+     * 创建库存调拨单
+     *
+     * @param createReqVO 创建信息
+     * @return 编号
+     */
+    Long createStockMove(@Valid ErpStockMoveSaveReqVO createReqVO);
+
+    /**
+     * 更新库存调拨单
+     *
+     * @param updateReqVO 更新信息
+     */
+    void updateStockMove(@Valid ErpStockMoveSaveReqVO updateReqVO);
+
+    /**
+     * 更新库存调拨单的状态
+     *
+     * @param id 编号
+     * @param status 状态
+     */
+    void updateStockMoveStatus(Long id, Integer status);
+
+    /**
+     * 删除库存调拨单
+     *
+     * @param ids 编号数组
+     */
+    void deleteStockMove(List<Long> ids);
+
+    /**
+     * 获得库存调拨单
+     *
+     * @param id 编号
+     * @return 库存调拨单
+     */
+    ErpStockMoveDO getStockMove(Long id);
+
+    /**
+     * 获得库存调拨单分页
+     *
+     * @param pageReqVO 分页查询
+     * @return 库存调拨单分页
+     */
+    PageResult<ErpStockMoveDO> getStockMovePage(ErpStockMovePageReqVO pageReqVO);
+
+    // ==================== 调拨项 ====================
+
+    /**
+     * 获得库存调拨单项列表
+     *
+     * @param moveId 调拨编号
+     * @return 库存调拨单项列表
+     */
+    List<ErpStockMoveItemDO> getStockMoveItemListByMoveId(Long moveId);
+
+    /**
+     * 获得库存调拨单项 List
+     *
+     * @param moveIds 调拨编号数组
+     * @return 库存调拨单项 List
+     */
+    List<ErpStockMoveItemDO> getStockMoveItemListByMoveIds(Collection<Long> moveIds);
+
+}
 \ No newline at end of file
+package cn.iocoder.yudao.module.erp.service.stock;
+
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.out.ErpStockOutPageReqVO;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.out.ErpStockOutSaveReqVO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockOutDO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockOutItemDO;
+import jakarta.validation.Valid;
+
+import java.util.Collection;
+import java.util.List;
+
+/**
+ * ERP 其它出库单 Service 接口
+ *
+ * @author 芋道源码
+ */
+public interface ErpStockOutService {
+
+    /**
+     * 创建其它出库单
+     *
+     * @param createReqVO 创建信息
+     * @return 编号
+     */
+    Long createStockOut(@Valid ErpStockOutSaveReqVO createReqVO);
+
+    /**
+     * 更新其它出库单
+     *
+     * @param updateReqVO 更新信息
+     */
+    void updateStockOut(@Valid ErpStockOutSaveReqVO updateReqVO);
+
+    /**
+     * 更新其它出库单的状态
+     *
+     * @param id 编号
+     * @param status 状态
+     */
+    void updateStockOutStatus(Long id, Integer status);
+
+    /**
+     * 删除其它出库单
+     *
+     * @param ids 编号数组
+     */
+    void deleteStockOut(List<Long> ids);
+
+    /**
+     * 获得其它出库单
+     *
+     * @param id 编号
+     * @return 其它出库单
+     */
+    ErpStockOutDO getStockOut(Long id);
+
+    /**
+     * 获得其它出库单分页
+     *
+     * @param pageReqVO 分页查询
+     * @return 其它出库单分页
+     */
+    PageResult<ErpStockOutDO> getStockOutPage(ErpStockOutPageReqVO pageReqVO);
+
+    // ==================== 出库项 ====================
+
+    /**
+     * 获得其它出库单项列表
+     *
+     * @param outId 出库编号
+     * @return 其它出库单项列表
+     */
+    List<ErpStockOutItemDO> getStockOutItemListByOutId(Long outId);
+
+    /**
+     * 获得其它出库单项 List
+     *
+     * @param outIds 出库编号数组
+     * @return 其它出库单项 List
+     */
+    List<ErpStockOutItemDO> getStockOutItemListByOutIds(Collection<Long> outIds);
+
+}
 \ No newline at end of file
+package cn.iocoder.yudao.module.erp.service.stock;
+
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.record.ErpStockRecordPageReqVO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockRecordDO;
+import cn.iocoder.yudao.module.erp.dal.mysql.stock.ErpStockRecordMapper;
+import cn.iocoder.yudao.module.erp.service.stock.bo.ErpStockRecordCreateReqBO;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.validation.annotation.Validated;
+
+import java.math.BigDecimal;
+
+/**
+ * ERP 产品库存明细 Service 实现类
+ *
+ * @author 芋道源码
+ */
+@Service
+@Validated
+public class ErpStockRecordServiceImpl implements ErpStockRecordService {
+
+    @Resource
+    private ErpStockRecordMapper stockRecordMapper;
+
+    @Resource
+    private ErpStockService stockService;
+
+    @Override
+    public ErpStockRecordDO getStockRecord(Long id) {
+        return stockRecordMapper.selectById(id);
+    }
+
+    @Override
+    public PageResult<ErpStockRecordDO> getStockRecordPage(ErpStockRecordPageReqVO pageReqVO) {
+        return stockRecordMapper.selectPage(pageReqVO);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void createStockRecord(ErpStockRecordCreateReqBO createReqBO) {
+        // 1. 更新库存
+        BigDecimal totalCount = stockService.updateStockCountIncrement(
+                createReqBO.getProductId(), createReqBO.getWarehouseId(), createReqBO.getCount());
+        // 2. 创建库存明细
+        ErpStockRecordDO stockRecord = BeanUtils.toBean(createReqBO, ErpStockRecordDO.class)
+                .setTotalCount(totalCount);
+        stockRecordMapper.insert(stockRecord);
+    }
+
+}
 \ No newline at end of file
+package cn.iocoder.yudao.module.erp.service.stock;
+
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.stock.ErpStockPageReqVO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockDO;
+
+import java.math.BigDecimal;
+
+/**
+ * ERP 产品库存 Service 接口
+ *
+ * @author 芋道源码
+ */
+public interface ErpStockService {
+
+    /**
+     * 获得产品库存
+     *
+     * @param id 编号
+     * @return 库存
+     */
+    ErpStockDO getStock(Long id);
+
+    /**
+     * 基于产品 + 仓库，获得产品库存
+     *
+     * @param productId 产品编号
+     * @param warehouseId 仓库编号
+     * @return 产品库存
+     */
+    ErpStockDO getStock(Long productId, Long warehouseId);
+
+    /**
+     * 获得产品库存数量
+     *
+     * 如果不存在库存记录，则返回 0
+     *
+     * @param productId 产品编号
+     * @return 产品库存数量
+     */
+    BigDecimal getStockCount(Long productId);
+
+    /**
+     * 获得产品库存分页
+     *
+     * @param pageReqVO 分页查询
+     * @return 库存分页
+     */
+    PageResult<ErpStockDO> getStockPage(ErpStockPageReqVO pageReqVO);
+
+    /**
+     * 增量更新产品库存数量
+     *
+     * @param productId 产品编号
+     * @param warehouseId 仓库编号
+     * @param count 增量数量：正数，表示增加；负数，表示减少
+     * @return 更新后的库存
+     */
+    BigDecimal updateStockCountIncrement(Long productId, Long warehouseId, BigDecimal count);
+
+}
 \ No newline at end of file
+package cn.iocoder.yudao.module.erp.service.stock;
+
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.stock.ErpStockPageReqVO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockDO;
+import cn.iocoder.yudao.module.erp.dal.mysql.stock.ErpStockMapper;
+import cn.iocoder.yudao.module.erp.service.product.ErpProductService;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.validation.annotation.Validated;
+
+import java.math.BigDecimal;
+
+import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.iocoder.yudao.module.erp.enums.ErrorCodeConstants.STOCK_COUNT_NEGATIVE;
+import static cn.iocoder.yudao.module.erp.enums.ErrorCodeConstants.STOCK_COUNT_NEGATIVE2;
+
+/**
+ * ERP 产品库存 Service 实现类
+ *
+ * @author 芋道源码
+ */
+@Service
+@Validated
+public class ErpStockServiceImpl implements ErpStockService {
+
+    /**
+     * 允许库存为负数
+     *
+     * TODO 芋艿：后续做成 db 配置
+     */
+    private static final Boolean NEGATIVE_STOCK_COUNT_ENABLE = false;
+
+    @Resource
+    private ErpProductService productService;
+    @Resource
+    private ErpWarehouseService warehouseService;
+
+    @Resource
+    private ErpStockMapper stockMapper;
+
+    @Override
+    public ErpStockDO getStock(Long id) {
+        return stockMapper.selectById(id);
+    }
+
+    @Override
+    public ErpStockDO getStock(Long productId, Long warehouseId) {
+        return stockMapper.selectByProductIdAndWarehouseId(productId, warehouseId);
+    }
+
+    @Override
+    public BigDecimal getStockCount(Long productId) {
+        BigDecimal count = stockMapper.selectSumByProductId(productId);
+        return count != null ? count : BigDecimal.ZERO;
+    }
+
+    @Override
+    public PageResult<ErpStockDO> getStockPage(ErpStockPageReqVO pageReqVO) {
+        return stockMapper.selectPage(pageReqVO);
+    }
+
+    @Override
+    public BigDecimal updateStockCountIncrement(Long productId, Long warehouseId, BigDecimal count) {
+        // 1.1 查询当前库存
+        ErpStockDO stock = stockMapper.selectByProductIdAndWarehouseId(productId, warehouseId);
+        if (stock == null) {
+            stock = new ErpStockDO().setProductId(productId).setWarehouseId(warehouseId).setCount(BigDecimal.ZERO);
+            stockMapper.insert(stock);
+        }
+        // 1.2 校验库存是否充足
+        if (!NEGATIVE_STOCK_COUNT_ENABLE && stock.getCount().add(count).compareTo(BigDecimal.ZERO) < 0) {
+            throw exception(STOCK_COUNT_NEGATIVE, productService.getProduct(productId).getName(),
+                    warehouseService.getWarehouse(warehouseId).getName(), stock.getCount(), count);
+        }
+
+        // 2. 库存变更
+        int updateCount = stockMapper.updateCountIncrement(stock.getId(), count, NEGATIVE_STOCK_COUNT_ENABLE);
+        if (updateCount == 0) {
+            // 此时不好去查询最新库存，所以直接抛出该提示，不提供具体库存数字
+            throw exception(STOCK_COUNT_NEGATIVE2, productService.getProduct(productId).getName(),
+                    warehouseService.getWarehouse(warehouseId).getName());
+        }
+
+        // 3. 返回最新库存
+        return stock.getCount().add(count);
+    }
+
+}
 \ No newline at end of file
+package cn.iocoder.yudao.module.erp.service.stock;
+
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.warehouse.ErpWarehouseSaveReqVO;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.warehouse.ErpWarehousePageReqVO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpWarehouseDO;
+import jakarta.validation.Valid;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.Map;
+
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertMap;
+
+/**
+ * ERP 仓库 Service 接口
+ *
+ * @author 芋道源码
+ */
+public interface ErpWarehouseService {
+
+    /**
+     * 创建仓库
+     *
+     * @param createReqVO 创建信息
+     * @return 编号
+     */
+    Long createWarehouse(@Valid ErpWarehouseSaveReqVO createReqVO);
+
+    /**
+     * 更新ERP 仓库
+     *
+     * @param updateReqVO 更新信息
+     */
+    void updateWarehouse(@Valid ErpWarehouseSaveReqVO updateReqVO);
+
+    /**
+     * 更新仓库默认状态
+     *
+     * @param id     编号
+     * @param defaultStatus 默认状态
+     */
+    void updateWarehouseDefaultStatus(Long id, Boolean defaultStatus);
+
+    /**
+     * 删除仓库
+     *
+     * @param id 编号
+     */
+    void deleteWarehouse(Long id);
+
+    /**
+     * 获得仓库
+     *
+     * @param id 编号
+     * @return 仓库
+     */
+    ErpWarehouseDO getWarehouse(Long id);
+
+    /**
+     * 校验仓库列表的有效性
+     *
+     * @param ids 编号数组
+     * @return 仓库列表
+     */
+    List<ErpWarehouseDO> validWarehouseList(Collection<Long> ids);
+
+    /**
+     * 获得指定状态的仓库列表
+     *
+     * @param status 状态
+     * @return 仓库列表
+     */
+    List<ErpWarehouseDO> getWarehouseListByStatus(Integer status);
+
+    /**
+     * 获得仓库列表
+     *
+     * @param ids 编号数组
+     * @return 仓库列表
+     */
+    List<ErpWarehouseDO> getWarehouseList(Collection<Long> ids);
+
+    /**
+     * 获得仓库 Map
+     *
+     * @param ids 编号数组
+     * @return 仓库 Map
+     */
+    default Map<Long, ErpWarehouseDO> getWarehouseMap(Collection<Long> ids) {
+        return convertMap(getWarehouseList(ids), ErpWarehouseDO::getId);
+    }
+
+    /**
+     * 获得仓库分页
+     *
+     * @param pageReqVO 分页查询
+     * @return 仓库分页
+     */
+    PageResult<ErpWarehouseDO> getWarehousePage(ErpWarehousePageReqVO pageReqVO);
+
+}
 \ No newline at end of file
+package cn.iocoder.yudao.module.erp.service.stock;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.warehouse.ErpWarehouseSaveReqVO;
+import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.warehouse.ErpWarehousePageReqVO;
+import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpWarehouseDO;
+import cn.iocoder.yudao.module.erp.dal.mysql.stock.ErpWarehouseMapper;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.validation.annotation.Validated;
+
+import java.util.Collection;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+
+import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertMap;
+import static cn.iocoder.yudao.module.erp.enums.ErrorCodeConstants.*;
+
+/**
+ * ERP 仓库 Service 实现类
+ *
+ * @author 芋道源码
+ */
+@Service
+@Validated
+public class ErpWarehouseServiceImpl implements ErpWarehouseService {
+
+    @Resource
+    private ErpWarehouseMapper warehouseMapper;
+
+    @Override
+    public Long createWarehouse(ErpWarehouseSaveReqVO createReqVO) {
+        // 插入
+        ErpWarehouseDO warehouse = BeanUtils.toBean(createReqVO, ErpWarehouseDO.class);
+        warehouseMapper.insert(warehouse);
+        // 返回
+        return warehouse.getId();
+    }
+
+    @Override
+    public void updateWarehouse(ErpWarehouseSaveReqVO updateReqVO) {
+        // 校验存在
+        validateWarehouseExists(updateReqVO.getId());
+        // 更新
+        ErpWarehouseDO updateObj = BeanUtils.toBean(updateReqVO, ErpWarehouseDO.class);
+        warehouseMapper.updateById(updateObj);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void updateWarehouseDefaultStatus(Long id, Boolean defaultStatus) {
+        // 1. 校验存在
+        validateWarehouseExists(id);
+
+        // 2.1 如果开启，则需要关闭所有其它的默认
+        if (defaultStatus) {
+            ErpWarehouseDO warehouse = warehouseMapper.selectByDefaultStatus();
+            if (warehouse != null) {
+                warehouseMapper.updateById(new ErpWarehouseDO().setId(warehouse.getId()).setDefaultStatus(false));
+            }
+        }
+        // 2.2 更新对应的默认状态
+        warehouseMapper.updateById(new ErpWarehouseDO().setId(id).setDefaultStatus(defaultStatus));
+    }
+
+    @Override
+    public void deleteWarehouse(Long id) {
+        // 校验存在
+        validateWarehouseExists(id);
+        // 删除
+        warehouseMapper.deleteById(id);
+    }
+
+    private void validateWarehouseExists(Long id) {
+        if (warehouseMapper.selectById(id) == null) {
+            throw exception(WAREHOUSE_NOT_EXISTS);
+        }
+    }
+
+    @Override
+    public ErpWarehouseDO getWarehouse(Long id) {
+        return warehouseMapper.selectById(id);
+    }
+
+    @Override
+    public List<ErpWarehouseDO> validWarehouseList(Collection<Long> ids) {
+        if (CollUtil.isEmpty(ids)) {
+            return Collections.emptyList();
+        }
+        List<ErpWarehouseDO> list = warehouseMapper.selectBatchIds(ids);
+        Map<Long, ErpWarehouseDO> warehouseMap = convertMap(list, ErpWarehouseDO::getId);
+        for (Long id : ids) {
+            ErpWarehouseDO warehouse = warehouseMap.get(id);
+            if (warehouseMap.get(id) == null) {
+                throw exception(WAREHOUSE_NOT_EXISTS);
+            }
+            if (CommonStatusEnum.isDisable(warehouse.getStatus())) {
+                throw exception(WAREHOUSE_NOT_ENABLE, warehouse.getName());
+            }
+        }
+        return list;
+    }
+
+    @Override
+    public List<ErpWarehouseDO> getWarehouseListByStatus(Integer status) {
+        return warehouseMapper.selectListByStatus(status);
+    }
+
+    @Override
+    public List<ErpWarehouseDO> getWarehouseList(Collection<Long> ids) {
+        return warehouseMapper.selectBatchIds(ids);
+    }
+
+    @Override
+    public PageResult<ErpWarehouseDO> getWarehousePage(ErpWarehousePageReqVO pageReqVO) {
+        return warehouseMapper.selectPage(pageReqVO);
+    }
+
+}
 \ No newline at end of file
+package cn.iocoder.yudao.module.erp.service.stock.bo;
+
+import jakarta.validation.constraints.NotNull;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.math.BigDecimal;
+
+/**
+ * 库存明细的创建 Request BO
+ *
+ * @author 芋道源码
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class ErpStockRecordCreateReqBO {
+
+    /**
+     * 产品编号
+     */
+    @NotNull(message = "产品编号不能为空")
+    private Long productId;
+    /**
+     * 仓库编号
+     */
+    @NotNull(message = "仓库编号不能为空")
+    private Long warehouseId;
+    /**
+     * 出入库数量
+     *
+     * 正数，表示入库；负数，表示出库
+     */
+    @NotNull(message = "出入库数量不能为空")
+    private BigDecimal count;
+
+    /**
+     * 业务类型
+     */
+    @NotNull(message = "业务类型不能为空")
+    private Integer bizType;
+    /**
+     * 业务编号
+     */
+    @NotNull(message = "业务编号不能为空")
+    private Long bizId;
+    /**
+     * 业务项编号
+     */
+    @NotNull(message = "业务项编号不能为空")
+    private Long bizItemId;
+    /**
+     * 业务单号
+     */
+    @NotNull(message = "业务单号不能为空")
+    private String bizNo;
+
+}
+<?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="cn.iocoder.yudao.module.erp.dal.mysql.statistics.ErpPurchaseStatisticsMapper">
+
+    <select id="getPurchasePrice" resultType="java.math.BigDecimal">
+        SELECT
+            (SELECT IFNULL(SUM(total_price), 0)
+             FROM erp_purchase_in
+             WHERE in_time >= #{beginTime}
+               <if test="endTime != null">
+                   AND in_time &lt; #{endTime}
+               </if>
+               AND tenant_id = ${@cn.iocoder.yudao.framework.tenant.core.context.TenantContextHolder@getRequiredTenantId()}
+               AND deleted = 0) -
+            (SELECT IFNULL(SUM(total_price), 0)
+                FROM erp_purchase_return
+                WHERE return_time >= #{beginTime}
+                <if test="endTime != null">
+                    AND return_time &lt; #{endTime}
+                </if>
+                AND tenant_id = ${@cn.iocoder.yudao.framework.tenant.core.context.TenantContextHolder@getRequiredTenantId()}
+                AND deleted = 0)
+    </select>
+
+</mapper>
 \ No newline at end of file
+<?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="cn.iocoder.yudao.module.erp.dal.mysql.statistics.ErpSaleStatisticsMapper">
+
+    <select id="getSalePrice" resultType="java.math.BigDecimal">
+        SELECT
+            (SELECT IFNULL(SUM(total_price), 0)
+             FROM erp_sale_out
+             WHERE out_time >= #{beginTime}
+               <if test="endTime != null">
+                   AND out_time &lt; #{endTime}
+               </if>
+               AND tenant_id = ${@cn.iocoder.yudao.framework.tenant.core.context.TenantContextHolder@getRequiredTenantId()}
+               AND deleted = 0) -
+            (SELECT IFNULL(SUM(total_price), 0)
+                FROM erp_sale_return
+                WHERE return_time >= #{beginTime}
+                <if test="endTime != null">
+                    AND return_time &lt; #{endTime}
+                </if>
+                AND tenant_id = ${@cn.iocoder.yudao.framework.tenant.core.context.TenantContextHolder@getRequiredTenantId()}
+                AND deleted = 0)
+    </select>
+
+</mapper>
 \ No newline at end of file
-<?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <parent>
-        <groupId>cn.iocoder.boot</groupId>
-        <artifactId>yudao-module-erp</artifactId>
-        <version>${revision}</version>
-    </parent>
-    <modelVersion>4.0.0</modelVersion>
-    <artifactId>yudao-module-erp-api</artifactId>
-    <packaging>jar</packaging>
-
-    <name>${project.artifactId}</name>
-    <description>
-        erp 模块 API，暴露给其它模块调用
-    </description>
-
-    <dependencies>
-        <dependency>
-            <groupId>cn.iocoder.boot</groupId>
-            <artifactId>yudao-common</artifactId>
-        </dependency>
-
-        <!-- 参数校验 -->
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-validation</artifactId>
-            <optional>true</optional>
-        </dependency>
-    </dependencies>
-
-</project>
 \ No newline at end of file
-/**
- * erp API 包，定义暴露给其它模块的 API
- */
-package cn.iocoder.yudao.module.erp.api;
-<?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <parent>
-        <groupId>cn.iocoder.boot</groupId>
-        <artifactId>yudao-module-erp</artifactId>
-        <version>${revision}</version>
-    </parent>
-    <modelVersion>4.0.0</modelVersion>
-    <artifactId>yudao-module-erp-biz</artifactId>
-
-    <name>${project.artifactId}</name>
-    <description>
-        erp 包下，企业资源管理（Enterprise Resource Planning）。
-        例如说：采购、销售、库存、财务、产品等等
-    </description>
-
-    <dependencies>
-        <dependency>
-            <groupId>cn.iocoder.boot</groupId>
-            <artifactId>yudao-module-system-api</artifactId>
-            <version>${revision}</version>
-        </dependency>
-        <dependency>
-            <groupId>cn.iocoder.boot</groupId>
-            <artifactId>yudao-module-erp-api</artifactId>
-            <version>${revision}</version>
-        </dependency>
-
-        <!-- 业务组件 -->
-
-        <!-- Web 相关 -->
-        <dependency>
-            <groupId>cn.iocoder.boot</groupId>
-            <artifactId>yudao-spring-boot-starter-web</artifactId>
-        </dependency>
-
-        <dependency>
-            <groupId>cn.iocoder.boot</groupId>
-            <artifactId>yudao-spring-boot-starter-security</artifactId>
-        </dependency>
-
-        <!-- DB 相关 -->
-        <dependency>
-            <groupId>cn.iocoder.boot</groupId>
-            <artifactId>yudao-spring-boot-starter-mybatis</artifactId>
-        </dependency>
-
-        <dependency>
-            <groupId>cn.iocoder.boot</groupId>
-            <artifactId>yudao-spring-boot-starter-redis</artifactId>
-        </dependency>
-
-        <!-- 工具类相关 -->
-        <dependency>
-            <groupId>cn.iocoder.boot</groupId>
-            <artifactId>yudao-spring-boot-starter-excel</artifactId>
-        </dependency>
-
-        <!-- Test 测试相关 -->
-        <dependency>
-            <groupId>cn.iocoder.boot</groupId>
-            <artifactId>yudao-spring-boot-starter-test</artifactId>
-        </dependency>
-
-    </dependencies>
-
-</project>
 \ No newline at end of file
-package cn.iocoder.yudao.module.erp.service.stock;
-
-import cn.iocoder.yudao.framework.common.pojo.PageResult;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.check.ErpStockCheckPageReqVO;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.check.ErpStockCheckSaveReqVO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockCheckDO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockCheckItemDO;
-import jakarta.validation.Valid;
-
-import java.util.Collection;
-import java.util.List;
-
-/**
- * ERP 库存盘点单 Service 接口
- *
- * @author 芋道源码
- */
-public interface ErpStockCheckService {
-
-    /**
-     * 创建库存盘点单
-     *
-     * @param createReqVO 创建信息
-     * @return 编号
-     */
-    Long createStockCheck(@Valid ErpStockCheckSaveReqVO createReqVO);
-
-    /**
-     * 更新库存盘点单
-     *
-     * @param updateReqVO 更新信息
-     */
-    void updateStockCheck(@Valid ErpStockCheckSaveReqVO updateReqVO);
-
-    /**
-     * 更新库存盘点单的状态
-     *
-     * @param id 编号
-     * @param status 状态
-     */
-    void updateStockCheckStatus(Long id, Integer status);
-
-    /**
-     * 删除库存盘点单
-     *
-     * @param ids 编号数组
-     */
-    void deleteStockCheck(List<Long> ids);
-
-    /**
-     * 获得库存盘点单
-     *
-     * @param id 编号
-     * @return 库存盘点单
-     */
-    ErpStockCheckDO getStockCheck(Long id);
-
-    /**
-     * 获得库存盘点单分页
-     *
-     * @param pageReqVO 分页查询
-     * @return 库存盘点单分页
-     */
-    PageResult<ErpStockCheckDO> getStockCheckPage(ErpStockCheckPageReqVO pageReqVO);
-
-    // ==================== 盘点项 ====================
-
-    /**
-     * 获得库存盘点单项列表
-     *
-     * @param checkId 盘点编号
-     * @return 库存盘点单项列表
-     */
-    List<ErpStockCheckItemDO> getStockCheckItemListByCheckId(Long checkId);
-
-    /**
-     * 获得库存盘点单项 List
-     *
-     * @param checkIds 盘点编号数组
-     * @return 库存盘点单项 List
-     */
-    List<ErpStockCheckItemDO> getStockCheckItemListByCheckIds(Collection<Long> checkIds);
-
-}
 \ No newline at end of file
-package cn.iocoder.yudao.module.erp.service.stock;
-
-import cn.iocoder.yudao.framework.common.pojo.PageResult;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.in.ErpStockInPageReqVO;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.in.ErpStockInSaveReqVO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockInDO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockInItemDO;
-import jakarta.validation.Valid;
-
-import java.util.Collection;
-import java.util.List;
-
-/**
- * ERP 其它入库单 Service 接口
- *
- * @author 芋道源码
- */
-public interface ErpStockInService {
-
-    /**
-     * 创建其它入库单
-     *
-     * @param createReqVO 创建信息
-     * @return 编号
-     */
-    Long createStockIn(@Valid ErpStockInSaveReqVO createReqVO);
-
-    /**
-     * 更新其它入库单
-     *
-     * @param updateReqVO 更新信息
-     */
-    void updateStockIn(@Valid ErpStockInSaveReqVO updateReqVO);
-
-    /**
-     * 更新其它入库单的状态
-     *
-     * @param id 编号
-     * @param status 状态
-     */
-    void updateStockInStatus(Long id, Integer status);
-
-    /**
-     * 删除其它入库单
-     *
-     * @param ids 编号数组
-     */
-    void deleteStockIn(List<Long> ids);
-
-    /**
-     * 获得其它入库单
-     *
-     * @param id 编号
-     * @return 其它入库单
-     */
-    ErpStockInDO getStockIn(Long id);
-
-    /**
-     * 获得其它入库单分页
-     *
-     * @param pageReqVO 分页查询
-     * @return 其它入库单分页
-     */
-    PageResult<ErpStockInDO> getStockInPage(ErpStockInPageReqVO pageReqVO);
-
-    // ==================== 入库项 ====================
-
-    /**
-     * 获得其它入库单项列表
-     *
-     * @param inId 入库编号
-     * @return 其它入库单项列表
-     */
-    List<ErpStockInItemDO> getStockInItemListByInId(Long inId);
-
-    /**
-     * 获得其它入库单项 List
-     *
-     * @param inIds 入库编号数组
-     * @return 其它入库单项 List
-     */
-    List<ErpStockInItemDO> getStockInItemListByInIds(Collection<Long> inIds);
-
-}
 \ No newline at end of file
-package cn.iocoder.yudao.module.erp.service.stock;
-
-import cn.iocoder.yudao.framework.common.pojo.PageResult;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.move.ErpStockMovePageReqVO;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.move.ErpStockMoveSaveReqVO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockMoveDO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockMoveItemDO;
-import jakarta.validation.Valid;
-
-import java.util.Collection;
-import java.util.List;
-
-/**
- * ERP 库存调拨单 Service 接口
- *
- * @author 芋道源码
- */
-public interface ErpStockMoveService {
-
-    /**
-     * 创建库存调拨单
-     *
-     * @param createReqVO 创建信息
-     * @return 编号
-     */
-    Long createStockMove(@Valid ErpStockMoveSaveReqVO createReqVO);
-
-    /**
-     * 更新库存调拨单
-     *
-     * @param updateReqVO 更新信息
-     */
-    void updateStockMove(@Valid ErpStockMoveSaveReqVO updateReqVO);
-
-    /**
-     * 更新库存调拨单的状态
-     *
-     * @param id 编号
-     * @param status 状态
-     */
-    void updateStockMoveStatus(Long id, Integer status);
-
-    /**
-     * 删除库存调拨单
-     *
-     * @param ids 编号数组
-     */
-    void deleteStockMove(List<Long> ids);
-
-    /**
-     * 获得库存调拨单
-     *
-     * @param id 编号
-     * @return 库存调拨单
-     */
-    ErpStockMoveDO getStockMove(Long id);
-
-    /**
-     * 获得库存调拨单分页
-     *
-     * @param pageReqVO 分页查询
-     * @return 库存调拨单分页
-     */
-    PageResult<ErpStockMoveDO> getStockMovePage(ErpStockMovePageReqVO pageReqVO);
-
-    // ==================== 调拨项 ====================
-
-    /**
-     * 获得库存调拨单项列表
-     *
-     * @param moveId 调拨编号
-     * @return 库存调拨单项列表
-     */
-    List<ErpStockMoveItemDO> getStockMoveItemListByMoveId(Long moveId);
-
-    /**
-     * 获得库存调拨单项 List
-     *
-     * @param moveIds 调拨编号数组
-     * @return 库存调拨单项 List
-     */
-    List<ErpStockMoveItemDO> getStockMoveItemListByMoveIds(Collection<Long> moveIds);
-
-}
 \ No newline at end of file
-package cn.iocoder.yudao.module.erp.service.stock;
-
-import cn.iocoder.yudao.framework.common.pojo.PageResult;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.out.ErpStockOutPageReqVO;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.out.ErpStockOutSaveReqVO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockOutDO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockOutItemDO;
-import jakarta.validation.Valid;
-
-import java.util.Collection;
-import java.util.List;
-
-/**
- * ERP 其它出库单 Service 接口
- *
- * @author 芋道源码
- */
-public interface ErpStockOutService {
-
-    /**
-     * 创建其它出库单
-     *
-     * @param createReqVO 创建信息
-     * @return 编号
-     */
-    Long createStockOut(@Valid ErpStockOutSaveReqVO createReqVO);
-
-    /**
-     * 更新其它出库单
-     *
-     * @param updateReqVO 更新信息
-     */
-    void updateStockOut(@Valid ErpStockOutSaveReqVO updateReqVO);
-
-    /**
-     * 更新其它出库单的状态
-     *
-     * @param id 编号
-     * @param status 状态
-     */
-    void updateStockOutStatus(Long id, Integer status);
-
-    /**
-     * 删除其它出库单
-     *
-     * @param ids 编号数组
-     */
-    void deleteStockOut(List<Long> ids);
-
-    /**
-     * 获得其它出库单
-     *
-     * @param id 编号
-     * @return 其它出库单
-     */
-    ErpStockOutDO getStockOut(Long id);
-
-    /**
-     * 获得其它出库单分页
-     *
-     * @param pageReqVO 分页查询
-     * @return 其它出库单分页
-     */
-    PageResult<ErpStockOutDO> getStockOutPage(ErpStockOutPageReqVO pageReqVO);
-
-    // ==================== 出库项 ====================
-
-    /**
-     * 获得其它出库单项列表
-     *
-     * @param outId 出库编号
-     * @return 其它出库单项列表
-     */
-    List<ErpStockOutItemDO> getStockOutItemListByOutId(Long outId);
-
-    /**
-     * 获得其它出库单项 List
-     *
-     * @param outIds 出库编号数组
-     * @return 其它出库单项 List
-     */
-    List<ErpStockOutItemDO> getStockOutItemListByOutIds(Collection<Long> outIds);
-
-}
 \ No newline at end of file
-package cn.iocoder.yudao.module.erp.service.stock;
-
-import cn.iocoder.yudao.framework.common.pojo.PageResult;
-import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.record.ErpStockRecordPageReqVO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockRecordDO;
-import cn.iocoder.yudao.module.erp.dal.mysql.stock.ErpStockRecordMapper;
-import cn.iocoder.yudao.module.erp.service.stock.bo.ErpStockRecordCreateReqBO;
-import jakarta.annotation.Resource;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-import org.springframework.validation.annotation.Validated;
-
-import java.math.BigDecimal;
-
-/**
- * ERP 产品库存明细 Service 实现类
- *
- * @author 芋道源码
- */
-@Service
-@Validated
-public class ErpStockRecordServiceImpl implements ErpStockRecordService {
-
-    @Resource
-    private ErpStockRecordMapper stockRecordMapper;
-
-    @Resource
-    private ErpStockService stockService;
-
-    @Override
-    public ErpStockRecordDO getStockRecord(Long id) {
-        return stockRecordMapper.selectById(id);
-    }
-
-    @Override
-    public PageResult<ErpStockRecordDO> getStockRecordPage(ErpStockRecordPageReqVO pageReqVO) {
-        return stockRecordMapper.selectPage(pageReqVO);
-    }
-
-    @Override
-    @Transactional(rollbackFor = Exception.class)
-    public void createStockRecord(ErpStockRecordCreateReqBO createReqBO) {
-        // 1. 更新库存
-        BigDecimal totalCount = stockService.updateStockCountIncrement(
-                createReqBO.getProductId(), createReqBO.getWarehouseId(), createReqBO.getCount());
-        // 2. 创建库存明细
-        ErpStockRecordDO stockRecord = BeanUtils.toBean(createReqBO, ErpStockRecordDO.class)
-                .setTotalCount(totalCount);
-        stockRecordMapper.insert(stockRecord);
-    }
-
-}
 \ No newline at end of file
-package cn.iocoder.yudao.module.erp.service.stock;
-
-import cn.iocoder.yudao.framework.common.pojo.PageResult;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.stock.ErpStockPageReqVO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockDO;
-
-import java.math.BigDecimal;
-
-/**
- * ERP 产品库存 Service 接口
- *
- * @author 芋道源码
- */
-public interface ErpStockService {
-
-    /**
-     * 获得产品库存
-     *
-     * @param id 编号
-     * @return 库存
-     */
-    ErpStockDO getStock(Long id);
-
-    /**
-     * 基于产品 + 仓库，获得产品库存
-     *
-     * @param productId 产品编号
-     * @param warehouseId 仓库编号
-     * @return 产品库存
-     */
-    ErpStockDO getStock(Long productId, Long warehouseId);
-
-    /**
-     * 获得产品库存数量
-     *
-     * 如果不存在库存记录，则返回 0
-     *
-     * @param productId 产品编号
-     * @return 产品库存数量
-     */
-    BigDecimal getStockCount(Long productId);
-
-    /**
-     * 获得产品库存分页
-     *
-     * @param pageReqVO 分页查询
-     * @return 库存分页
-     */
-    PageResult<ErpStockDO> getStockPage(ErpStockPageReqVO pageReqVO);
-
-    /**
-     * 增量更新产品库存数量
-     *
-     * @param productId 产品编号
-     * @param warehouseId 仓库编号
-     * @param count 增量数量：正数，表示增加；负数，表示减少
-     * @return 更新后的库存
-     */
-    BigDecimal updateStockCountIncrement(Long productId, Long warehouseId, BigDecimal count);
-
-}
 \ No newline at end of file
-package cn.iocoder.yudao.module.erp.service.stock;
-
-import cn.iocoder.yudao.framework.common.pojo.PageResult;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.stock.ErpStockPageReqVO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpStockDO;
-import cn.iocoder.yudao.module.erp.dal.mysql.stock.ErpStockMapper;
-import cn.iocoder.yudao.module.erp.service.product.ErpProductService;
-import jakarta.annotation.Resource;
-import org.springframework.stereotype.Service;
-import org.springframework.validation.annotation.Validated;
-
-import java.math.BigDecimal;
-
-import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
-import static cn.iocoder.yudao.module.erp.enums.ErrorCodeConstants.STOCK_COUNT_NEGATIVE;
-import static cn.iocoder.yudao.module.erp.enums.ErrorCodeConstants.STOCK_COUNT_NEGATIVE2;
-
-/**
- * ERP 产品库存 Service 实现类
- *
- * @author 芋道源码
- */
-@Service
-@Validated
-public class ErpStockServiceImpl implements ErpStockService {
-
-    /**
-     * 允许库存为负数
-     *
-     * TODO 芋艿：后续做成 db 配置
-     */
-    private static final Boolean NEGATIVE_STOCK_COUNT_ENABLE = false;
-
-    @Resource
-    private ErpProductService productService;
-    @Resource
-    private ErpWarehouseService warehouseService;
-
-    @Resource
-    private ErpStockMapper stockMapper;
-
-    @Override
-    public ErpStockDO getStock(Long id) {
-        return stockMapper.selectById(id);
-    }
-
-    @Override
-    public ErpStockDO getStock(Long productId, Long warehouseId) {
-        return stockMapper.selectByProductIdAndWarehouseId(productId, warehouseId);
-    }
-
-    @Override
-    public BigDecimal getStockCount(Long productId) {
-        BigDecimal count = stockMapper.selectSumByProductId(productId);
-        return count != null ? count : BigDecimal.ZERO;
-    }
-
-    @Override
-    public PageResult<ErpStockDO> getStockPage(ErpStockPageReqVO pageReqVO) {
-        return stockMapper.selectPage(pageReqVO);
-    }
-
-    @Override
-    public BigDecimal updateStockCountIncrement(Long productId, Long warehouseId, BigDecimal count) {
-        // 1.1 查询当前库存
-        ErpStockDO stock = stockMapper.selectByProductIdAndWarehouseId(productId, warehouseId);
-        if (stock == null) {
-            stock = new ErpStockDO().setProductId(productId).setWarehouseId(warehouseId).setCount(BigDecimal.ZERO);
-            stockMapper.insert(stock);
-        }
-        // 1.2 校验库存是否充足
-        if (!NEGATIVE_STOCK_COUNT_ENABLE && stock.getCount().add(count).compareTo(BigDecimal.ZERO) < 0) {
-            throw exception(STOCK_COUNT_NEGATIVE, productService.getProduct(productId).getName(),
-                    warehouseService.getWarehouse(warehouseId).getName(), stock.getCount(), count);
-        }
-
-        // 2. 库存变更
-        int updateCount = stockMapper.updateCountIncrement(stock.getId(), count, NEGATIVE_STOCK_COUNT_ENABLE);
-        if (updateCount == 0) {
-            // 此时不好去查询最新库存，所以直接抛出该提示，不提供具体库存数字
-            throw exception(STOCK_COUNT_NEGATIVE2, productService.getProduct(productId).getName(),
-                    warehouseService.getWarehouse(warehouseId).getName());
-        }
-
-        // 3. 返回最新库存
-        return stock.getCount().add(count);
-    }
-
-}
 \ No newline at end of file
-package cn.iocoder.yudao.module.erp.service.stock;
-
-import cn.iocoder.yudao.framework.common.pojo.PageResult;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.warehouse.ErpWarehouseSaveReqVO;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.warehouse.ErpWarehousePageReqVO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpWarehouseDO;
-import jakarta.validation.Valid;
-
-import java.util.Collection;
-import java.util.List;
-import java.util.Map;
-
-import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertMap;
-
-/**
- * ERP 仓库 Service 接口
- *
- * @author 芋道源码
- */
-public interface ErpWarehouseService {
-
-    /**
-     * 创建仓库
-     *
-     * @param createReqVO 创建信息
-     * @return 编号
-     */
-    Long createWarehouse(@Valid ErpWarehouseSaveReqVO createReqVO);
-
-    /**
-     * 更新ERP 仓库
-     *
-     * @param updateReqVO 更新信息
-     */
-    void updateWarehouse(@Valid ErpWarehouseSaveReqVO updateReqVO);
-
-    /**
-     * 更新仓库默认状态
-     *
-     * @param id     编号
-     * @param defaultStatus 默认状态
-     */
-    void updateWarehouseDefaultStatus(Long id, Boolean defaultStatus);
-
-    /**
-     * 删除仓库
-     *
-     * @param id 编号
-     */
-    void deleteWarehouse(Long id);
-
-    /**
-     * 获得仓库
-     *
-     * @param id 编号
-     * @return 仓库
-     */
-    ErpWarehouseDO getWarehouse(Long id);
-
-    /**
-     * 校验仓库列表的有效性
-     *
-     * @param ids 编号数组
-     * @return 仓库列表
-     */
-    List<ErpWarehouseDO> validWarehouseList(Collection<Long> ids);
-
-    /**
-     * 获得指定状态的仓库列表
-     *
-     * @param status 状态
-     * @return 仓库列表
-     */
-    List<ErpWarehouseDO> getWarehouseListByStatus(Integer status);
-
-    /**
-     * 获得仓库列表
-     *
-     * @param ids 编号数组
-     * @return 仓库列表
-     */
-    List<ErpWarehouseDO> getWarehouseList(Collection<Long> ids);
-
-    /**
-     * 获得仓库 Map
-     *
-     * @param ids 编号数组
-     * @return 仓库 Map
-     */
-    default Map<Long, ErpWarehouseDO> getWarehouseMap(Collection<Long> ids) {
-        return convertMap(getWarehouseList(ids), ErpWarehouseDO::getId);
-    }
-
-    /**
-     * 获得仓库分页
-     *
-     * @param pageReqVO 分页查询
-     * @return 仓库分页
-     */
-    PageResult<ErpWarehouseDO> getWarehousePage(ErpWarehousePageReqVO pageReqVO);
-
-}
 \ No newline at end of file
-package cn.iocoder.yudao.module.erp.service.stock;
-
-import cn.hutool.core.collection.CollUtil;
-import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
-import cn.iocoder.yudao.framework.common.pojo.PageResult;
-import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.warehouse.ErpWarehouseSaveReqVO;
-import cn.iocoder.yudao.module.erp.controller.admin.stock.vo.warehouse.ErpWarehousePageReqVO;
-import cn.iocoder.yudao.module.erp.dal.dataobject.stock.ErpWarehouseDO;
-import cn.iocoder.yudao.module.erp.dal.mysql.stock.ErpWarehouseMapper;
-import jakarta.annotation.Resource;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-import org.springframework.validation.annotation.Validated;
-
-import java.util.Collection;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
-
-import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
-import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertMap;
-import static cn.iocoder.yudao.module.erp.enums.ErrorCodeConstants.*;
-
-/**
- * ERP 仓库 Service 实现类
- *
- * @author 芋道源码
- */
-@Service
-@Validated
-public class ErpWarehouseServiceImpl implements ErpWarehouseService {
-
-    @Resource
-    private ErpWarehouseMapper warehouseMapper;
-
-    @Override
-    public Long createWarehouse(ErpWarehouseSaveReqVO createReqVO) {
-        // 插入
-        ErpWarehouseDO warehouse = BeanUtils.toBean(createReqVO, ErpWarehouseDO.class);
-        warehouseMapper.insert(warehouse);
-        // 返回
-        return warehouse.getId();
-    }
-
-    @Override
-    public void updateWarehouse(ErpWarehouseSaveReqVO updateReqVO) {
-        // 校验存在
-        validateWarehouseExists(updateReqVO.getId());
-        // 更新
-        ErpWarehouseDO updateObj = BeanUtils.toBean(updateReqVO, ErpWarehouseDO.class);
-        warehouseMapper.updateById(updateObj);
-    }
-
-    @Override
-    @Transactional(rollbackFor = Exception.class)
-    public void updateWarehouseDefaultStatus(Long id, Boolean defaultStatus) {
-        // 1. 校验存在
-        validateWarehouseExists(id);
-
-        // 2.1 如果开启，则需要关闭所有其它的默认
-        if (defaultStatus) {
-            ErpWarehouseDO warehouse = warehouseMapper.selectByDefaultStatus();
-            if (warehouse != null) {
-                warehouseMapper.updateById(new ErpWarehouseDO().setId(warehouse.getId()).setDefaultStatus(false));
-            }
-        }
-        // 2.2 更新对应的默认状态
-        warehouseMapper.updateById(new ErpWarehouseDO().setId(id).setDefaultStatus(defaultStatus));
-    }
-
-    @Override
-    public void deleteWarehouse(Long id) {
-        // 校验存在
-        validateWarehouseExists(id);
-        // 删除
-        warehouseMapper.deleteById(id);
-    }
-
-    private void validateWarehouseExists(Long id) {
-        if (warehouseMapper.selectById(id) == null) {
-            throw exception(WAREHOUSE_NOT_EXISTS);
-        }
-    }
-
-    @Override
-    public ErpWarehouseDO getWarehouse(Long id) {
-        return warehouseMapper.selectById(id);
-    }
-
-    @Override
-    public List<ErpWarehouseDO> validWarehouseList(Collection<Long> ids) {
-        if (CollUtil.isEmpty(ids)) {
-            return Collections.emptyList();
-        }
-        List<ErpWarehouseDO> list = warehouseMapper.selectBatchIds(ids);
-        Map<Long, ErpWarehouseDO> warehouseMap = convertMap(list, ErpWarehouseDO::getId);
-        for (Long id : ids) {
-            ErpWarehouseDO warehouse = warehouseMap.get(id);
-            if (warehouseMap.get(id) == null) {
-                throw exception(WAREHOUSE_NOT_EXISTS);
-            }
-            if (CommonStatusEnum.isDisable(warehouse.getStatus())) {
-                throw exception(WAREHOUSE_NOT_ENABLE, warehouse.getName());
-            }
-        }
-        return list;
-    }
-
-    @Override
-    public List<ErpWarehouseDO> getWarehouseListByStatus(Integer status) {
-        return warehouseMapper.selectListByStatus(status);
-    }
-
-    @Override
-    public List<ErpWarehouseDO> getWarehouseList(Collection<Long> ids) {
-        return warehouseMapper.selectBatchIds(ids);
-    }
-
-    @Override
-    public PageResult<ErpWarehouseDO> getWarehousePage(ErpWarehousePageReqVO pageReqVO) {
-        return warehouseMapper.selectPage(pageReqVO);
-    }
-
-}
 \ No newline at end of file
-package cn.iocoder.yudao.module.erp.service.stock.bo;
-
-import jakarta.validation.constraints.NotNull;
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.math.BigDecimal;
-
-/**
- * 库存明细的创建 Request BO
- *
- * @author 芋道源码
- */
-@Data
-@NoArgsConstructor
-@AllArgsConstructor
-public class ErpStockRecordCreateReqBO {
-
-    /**
-     * 产品编号
-     */
-    @NotNull(message = "产品编号不能为空")
-    private Long productId;
-    /**
-     * 仓库编号
-     */
-    @NotNull(message = "仓库编号不能为空")
-    private Long warehouseId;
-    /**
-     * 出入库数量
-     *
-     * 正数，表示入库；负数，表示出库
-     */
-    @NotNull(message = "出入库数量不能为空")
-    private BigDecimal count;
-
-    /**
-     * 业务类型
-     */
-    @NotNull(message = "业务类型不能为空")
-    private Integer bizType;
-    /**
-     * 业务编号
-     */
-    @NotNull(message = "业务编号不能为空")
-    private Long bizId;
-    /**
-     * 业务项编号
-     */
-    @NotNull(message = "业务项编号不能为空")
-    private Long bizItemId;
-    /**
-     * 业务单号
-     */
-    @NotNull(message = "业务单号不能为空")
-    private String bizNo;
-
-}
-<?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="cn.iocoder.yudao.module.erp.dal.mysql.statistics.ErpPurchaseStatisticsMapper">
-
-    <select id="getPurchasePrice" resultType="java.math.BigDecimal">
-        SELECT
-            (SELECT IFNULL(SUM(total_price), 0)
-             FROM erp_purchase_in
-             WHERE in_time >= #{beginTime}
-               <if test="endTime != null">
-                   AND in_time &lt; #{endTime}
-               </if>
-               AND tenant_id = ${@cn.iocoder.yudao.framework.tenant.core.context.TenantContextHolder@getRequiredTenantId()}
-               AND deleted = 0) -
-            (SELECT IFNULL(SUM(total_price), 0)
-                FROM erp_purchase_return
-                WHERE return_time >= #{beginTime}
-                <if test="endTime != null">
-                    AND return_time &lt; #{endTime}
-                </if>
-                AND tenant_id = ${@cn.iocoder.yudao.framework.tenant.core.context.TenantContextHolder@getRequiredTenantId()}
-                AND deleted = 0)
-    </select>
-
-</mapper>
 \ No newline at end of file
-<?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="cn.iocoder.yudao.module.erp.dal.mysql.statistics.ErpSaleStatisticsMapper">
-
-    <select id="getSalePrice" resultType="java.math.BigDecimal">
-        SELECT
-            (SELECT IFNULL(SUM(total_price), 0)
-             FROM erp_sale_out
-             WHERE out_time >= #{beginTime}
-               <if test="endTime != null">
-                   AND out_time &lt; #{endTime}
-               </if>
-               AND tenant_id = ${@cn.iocoder.yudao.framework.tenant.core.context.TenantContextHolder@getRequiredTenantId()}
-               AND deleted = 0) -
-            (SELECT IFNULL(SUM(total_price), 0)
-                FROM erp_sale_return
-                WHERE return_time >= #{beginTime}
-                <if test="endTime != null">
-                    AND return_time &lt; #{endTime}
-                </if>
-                AND tenant_id = ${@cn.iocoder.yudao.framework.tenant.core.context.TenantContextHolder@getRequiredTenantId()}
-                AND deleted = 0)
-    </select>
-
-</mapper>
 \ No newline at end of file
@@ -97,7 +97,7 @@
         <!-- ERP 相关模块。默认注释，保证编译速度 -->
 <!--        <dependency>-->
 <!--            <groupId>cn.iocoder.boot</groupId>-->
-<!--            <artifactId>yudao-module-erp-biz</artifactId>-->
+<!--            <artifactId>yudao-module-erp</artifactId>-->
 <!--            <version>${revision}</version>-->
 <!--        </dependency>-->