feat: 打通销售采购财务闭环并完成累计业务优化

gaoluyang

6 天以前 d39e4f7d839167c16425086dfa2f8747bccfdff9

 yudao-module-crm/src/main/java/cn/iocoder/yudao/module/crm/dal/mysql/invoice/CrmInvoiceMapper.java

@@ -34,10 +34,32 @@
        return selectOne(CrmInvoiceDO::getNo, no);
    }

    /**
     * 清空发票录入人、录入时间（updateById 默认忽略 null 字段，清空需显式 update）
     */
    default void clearEntryInfo(Long id) {
        update(null, new com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper<CrmInvoiceDO>()
                .eq(CrmInvoiceDO::getId, id)
                .set(CrmInvoiceDO::getEntryStatus, 0)
                .set(CrmInvoiceDO::getEntryUserId, null)
                .set(CrmInvoiceDO::getEntryTime, null));
    }

    /**
     * 按发票号码查询未被删除的开票（发票号码允许同一张发票多次开票时，返回第一条）
     */
    default CrmInvoiceDO selectByInvoiceNo(String invoiceNo) {
        return selectOne(new LambdaQueryWrapperX<CrmInvoiceDO>()
                .eq(CrmInvoiceDO::getInvoiceNo, invoiceNo)
                .orderByAsc(CrmInvoiceDO::getId)
                .last("LIMIT 1"));
    }

    default PageResult<CrmInvoiceDO> selectPageByCustomerId(CrmInvoicePageReqVO reqVO) {
        return selectPage(reqVO, new LambdaQueryWrapperX<CrmInvoiceDO>()
                .eq(CrmInvoiceDO::getCustomerId, reqVO.getCustomerId()) // 必须传递
                .eqIfPresent(CrmInvoiceDO::getNo, reqVO.getNo())
                .likeIfPresent(CrmInvoiceDO::getInvoiceNo, reqVO.getInvoiceNo())
                .eqIfPresent(CrmInvoiceDO::getContractId, reqVO.getContractId())
                .orderByDesc(CrmInvoiceDO::getId));
    }
@@ -50,6 +72,7 @@
        // 拼接自身的查询条件
        query.selectAll(CrmInvoiceDO.class)
                .eqIfPresent(CrmInvoiceDO::getNo, pageReqVO.getNo())
                .likeIfPresent(CrmInvoiceDO::getInvoiceNo, pageReqVO.getInvoiceNo())
                .eqIfPresent(CrmInvoiceDO::getContractId, pageReqVO.getContractId())
                .eqIfPresent(CrmInvoiceDO::getAuditStatus, pageReqVO.getAuditStatus())
                .orderByDesc(CrmInvoiceDO::getId);
@@ -76,10 +99,11 @@
        if (CollUtil.isEmpty(contractIds)) {
            return Collections.emptyMap();
        }
        // SQL sum 查询
        // SQL sum 查询（审批通过 + 审批中，与开票防超校验口径一致）
        List<Map<String, Object>> result = selectMaps(new QueryWrapper<CrmInvoiceDO>()
                .select("contract_id, SUM(price) AS total_price")
                .eq("audit_status", CrmAuditStatusEnum.APPROVE.getStatus())
                .in("audit_status", CrmAuditStatusEnum.APPROVE.getStatus(),
                        CrmAuditStatusEnum.PROCESS.getStatus())
                .groupBy("contract_id")
                .in("contract_id", contractIds));
        // 获得金额
@@ -90,4 +114,31 @@
        return selectCount(CrmInvoiceDO::getContractId, contractId);
    }

    /**
     * 查询指定销售订单下、指定审批状态的开票
     */
    default List<CrmInvoiceDO> selectListBySaleOrderIdAndStatus(Long saleOrderId, Collection<Integer> auditStatuses) {
        return selectList(new LambdaQueryWrapperX<CrmInvoiceDO>()
                .eq(CrmInvoiceDO::getSaleOrderId, saleOrderId)
                .in(CrmInvoiceDO::getAuditStatus, auditStatuses));
    }

    /**
     * 查询指定销售出库单下、指定审批状态的开票
     */
    default List<CrmInvoiceDO> selectListBySaleOutIdAndStatus(Long saleOutId, Collection<Integer> auditStatuses) {
        return selectList(new LambdaQueryWrapperX<CrmInvoiceDO>()
                .eq(CrmInvoiceDO::getSaleOutId, saleOutId)
                .in(CrmInvoiceDO::getAuditStatus, auditStatuses));
    }

    /**
     * 查询合同下的全部开票（导入去重用）
     */
    default List<CrmInvoiceDO> selectListByContractId(Long contractId) {
        return selectList(new LambdaQueryWrapperX<CrmInvoiceDO>()
                .eq(CrmInvoiceDO::getContractId, contractId)
                .orderByAsc(CrmInvoiceDO::getId));
    }

}