产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liyong
6 天以前 9d66bfbfcda297f628e6a857e343f98422f4534a 
 src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java


@@ -1,36 +1,35 @@


package com.ruoyi.purchase.service.impl;




import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;


import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ruoyi.account.pojo.AccountExpense;


import com.ruoyi.account.pojo.AccountIncome;


import com.ruoyi.account.service.AccountExpenseService;


import com.ruoyi.account.service.AccountIncomeService;


import com.ruoyi.approve.bean.dto.ApprovalInstanceDto;


import com.ruoyi.approve.bean.vo.ApproveProcessVO;


import com.ruoyi.approve.mapper.ApprovalTemplateMapper;


import com.ruoyi.approve.pojo.ApprovalInstance;


import com.ruoyi.approve.pojo.ApproveProcess;


import com.ruoyi.approve.service.ApprovalInstanceService;


import com.ruoyi.approve.service.impl.ApproveProcessServiceImpl;


import com.ruoyi.approve.vo.ApproveProcessVO;


import com.ruoyi.basic.enums.ApplicationTypeEnum;


import com.ruoyi.basic.enums.RecordTypeEnum;


import com.ruoyi.basic.mapper.ProductMapper;


import com.ruoyi.basic.mapper.ProductModelMapper;


import com.ruoyi.basic.mapper.SupplierManageMapper;


import com.ruoyi.basic.pojo.Customer;


import com.ruoyi.basic.pojo.Product;


import com.ruoyi.basic.pojo.ProductModel;


import com.ruoyi.basic.pojo.SupplierManage;


import com.ruoyi.basic.utils.FileUtil;


import com.ruoyi.common.enums.FileNameType;


import com.ruoyi.common.exception.base.BaseException;


import com.ruoyi.common.utils.DateUtils;


import com.ruoyi.common.utils.SecurityUtils;


import com.ruoyi.common.utils.StringUtils;


import com.ruoyi.common.utils.poi.ExcelUtil;


import com.ruoyi.framework.security.LoginUser;


import com.ruoyi.framework.web.domain.AjaxResult;


import com.ruoyi.other.mapper.TempFileMapper;


import com.ruoyi.other.pojo.TempFile;


import com.ruoyi.procurementrecord.mapper.ProcurementRecordMapper;


import com.ruoyi.procurementrecord.pojo.ProcurementRecordStorage;


import com.ruoyi.project.system.domain.SysUser;


@@ -38,37 +37,35 @@


import com.ruoyi.purchase.dto.PurchaseLedgerDto;


import com.ruoyi.purchase.dto.PurchaseLedgerImportDto;


import com.ruoyi.purchase.dto.PurchaseLedgerProductImportDto;


import com.ruoyi.purchase.mapper.*;


import com.ruoyi.purchase.pojo.*;


import com.ruoyi.purchase.mapper.PurchaseLedgerMapper;


import com.ruoyi.purchase.pojo.PurchaseLedger;


import com.ruoyi.purchase.service.IPurchaseLedgerService;


import com.ruoyi.quality.mapper.*;


import com.ruoyi.quality.pojo.*;


import com.ruoyi.sales.dto.SalesLedgerImportDto;


import com.ruoyi.sales.dto.SalesLedgerProductImportDto;


import com.ruoyi.sales.mapper.*;


import com.ruoyi.quality.mapper.QualityInspectMapper;


import com.ruoyi.quality.mapper.QualityInspectParamMapper;


import com.ruoyi.quality.mapper.QualityTestStandardMapper;


import com.ruoyi.quality.mapper.QualityTestStandardParamMapper;


import com.ruoyi.quality.pojo.QualityInspect;


import com.ruoyi.quality.pojo.QualityInspectParam;


import com.ruoyi.quality.pojo.QualityTestStandard;


import com.ruoyi.quality.pojo.QualityTestStandardParam;


import com.ruoyi.sales.mapper.CommonFileMapper;


import com.ruoyi.sales.mapper.SalesLedgerMapper;


import com.ruoyi.sales.mapper.SalesLedgerProductMapper;


import com.ruoyi.sales.pojo.CommonFile;


import com.ruoyi.sales.pojo.InvoiceRegistrationProduct;


import com.ruoyi.sales.pojo.SalesLedger;


import com.ruoyi.sales.pojo.SalesLedgerProduct;


import com.ruoyi.sales.service.impl.CommonFileServiceImpl;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.io.FilenameUtils;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.data.redis.core.StringRedisTemplate;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.multipart.MultipartFile;




import java.io.IOException;


import java.io.InputStream;


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.nio.file.Files;


import java.nio.file.Path;


import java.nio.file.Paths;


import java.nio.file.StandardCopyOption;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.ZoneId;


@@ -84,54 +81,31 @@


 * @date 2025-05-09


 */


@Service


@RequiredArgsConstructor


@Slf4j


@RequiredArgsConstructor


public class PurchaseLedgerServiceImpl extends ServiceImpl<PurchaseLedgerMapper, PurchaseLedger> implements IPurchaseLedgerService {


    private final AccountExpenseService accountExpenseService;


    private final PurchaseLedgerMapper purchaseLedgerMapper;




    private final PurchaseLedgerMapper purchaseLedgerMapper;


    private final SalesLedgerMapper salesLedgerMapper;


    private final SalesLedgerProductMapper salesLedgerProductMapper;




    private final SysUserMapper userMapper;




    private final TempFileMapper tempFileMapper;




    private final CommonFileMapper commonFileMapper;




    private final SupplierManageMapper supplierManageMapper;




    private final ProductMapper productMapper;




    private final ProductModelMapper productModelMapper;




    private final SysUserMapper sysUserMapper;




    private final TicketRegistrationMapper ticketRegistrationMapper;




    private final ProductRecordMapper productRecordMapper;




    private final PaymentRegistrationMapper paymentRegistrationMapper;




    private final InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;




    private final StringRedisTemplate redisTemplate;


    private final QualityInspectMapper qualityInspectMapper;


    private final CommonFileServiceImpl commonFileService;


    private final QualityTestStandardBindingMapper qualityTestStandardBindingMapper;


    private final QualityTestStandardParamMapper qualityTestStandardParamMapper;


    private final QualityTestStandardMapper qualityTestStandardMapper;


    private final QualityInspectParamMapper qualityInspectParamMapper;




    private final ApproveProcessServiceImpl approveProcessService;




    private final ProcurementRecordMapper procurementRecordStorageMapper;




    private final PurchaseLedgerTemplateMapper purchaseLedgerTemplateMapper;




    private final SalesLedgerProductTemplateMapper salesLedgerProductTemplateMapper;


    @Value("${file.upload-dir}")


    private String uploadDir;


    private final FileUtil fileUtil;


    private final ApprovalInstanceService approvalInstanceService;


    private final ApprovalTemplateMapper approvalTemplateMapper;




    @Override


    public List<PurchaseLedger> selectPurchaseLedgerList(PurchaseLedger purchaseLedger) {


@@ -139,22 +113,35 @@


        if (StringUtils.isNotBlank(purchaseLedger.getPurchaseContractNumber())) {


            queryWrapper.like(PurchaseLedger::getPurchaseContractNumber, purchaseLedger.getPurchaseContractNumber());


        }


        if(purchaseLedger.getSupplierId()!=null){


            queryWrapper.eq(PurchaseLedger::getSupplierId, purchaseLedger.getSupplierId());


        }


        if (purchaseLedger.getApprovalStatus() != null) {


            queryWrapper.eq(PurchaseLedger::getApprovalStatus, purchaseLedger.getApprovalStatus());


        }


        return purchaseLedgerMapper.selectList(queryWrapper);


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public int addOrEditPurchase(PurchaseLedgerDto purchaseLedgerDto) throws Exception {




        PurchaseLedger purchaseLedger = new PurchaseLedger();


        // DTO转Entity


        BeanUtils.copyProperties(purchaseLedgerDto, purchaseLedger);


        SalesLedger salesLedger = salesLedgerMapper.selectById(purchaseLedgerDto.getSalesLedgerId());


        //录入人


        SysUser sysUser = userMapper.selectUserById(purchaseLedgerDto.getRecorderId());


        if (ObjectUtils.isNotEmpty(sysUser)) {


            purchaseLedger.setRecorderName(sysUser.getNickName());


            purchaseLedger.setPhoneNumber(sysUser.getPhonenumber());


        }else {


            purchaseLedger.setRecorderName(SecurityUtils.getLoginUser().getNickName());


            SysUser sysUser1 = userMapper.selectUserById(SecurityUtils.getUserId());


            purchaseLedger.setPhoneNumber(sysUser1.getPhonenumber());


        }




        SupplierManage supplierManage = supplierManageMapper.selectById(purchaseLedgerDto.getSupplierId());




        // DTO转Entity


        PurchaseLedger purchaseLedger = new PurchaseLedger();


        BeanUtils.copyProperties(purchaseLedgerDto, purchaseLedger);


        LoginUser loginUser = SecurityUtils.getLoginUser();


        if (ObjectUtils.isNotEmpty(loginUser) && null != loginUser.getTenantId()) {


            purchaseLedger.setTenantId(loginUser.getTenantId());


@@ -163,14 +150,13 @@


        purchaseLedger.setSalesLedgerId(ObjectUtils.isNotEmpty(salesLedger) ? salesLedger.getId() : -1);


        purchaseLedger.setSupplierName(supplierManage.getSupplierName());


        purchaseLedger.setRecorderId(purchaseLedgerDto.getRecorderId());


        purchaseLedger.setRecorderName(sysUser.getNickName());


        purchaseLedger.setPhoneNumber(sysUser.getPhonenumber());




        purchaseLedger.setApprovalStatus(1);


        // 3. 新增或更新主表


        if (purchaseLedger.getId() == null) {


            purchaseLedgerMapper.insert(purchaseLedger);


        } else {


            // 删除采购审核，重新提交


//            // 删除采购审核，重新提交


            ApproveProcess one = approveProcessService.getOne(new LambdaQueryWrapper<ApproveProcess>()


                    .eq(ApproveProcess::getApproveType, 5)


                    .eq(ApproveProcess::getApproveReason, purchaseLedger.getPurchaseContractNumber())


@@ -180,32 +166,36 @@


                approveProcessService.delByIds(Collections.singletonList(one.getId()));


            }


            purchaseLedgerMapper.updateById(purchaseLedger);


            //删除新采购审批


            approvalInstanceService.remove(new LambdaQueryWrapper<ApprovalInstance>().eq(ApprovalInstance::getBusinessId, purchaseLedger.getId()).eq(ApprovalInstance::getBusinessType, 5));


        }


        // 6.采购审核新增


        addApproveByPurchase(loginUser, purchaseLedger);




        //新采购审批


        ApprovalInstanceDto approvalInstanceDto = new ApprovalInstanceDto();


        approvalInstanceDto.setTemplateId(purchaseLedger.getTemplateId());


        approvalInstanceDto.setBusinessId(purchaseLedger.getId());


        approvalInstanceDto.setBusinessType(5L);


        approvalInstanceDto.setTitle("采购合同号：" + purchaseLedger.getPurchaseContractNumber());


        approvalInstanceDto.setApplicantId(SecurityUtils.getUserId());


        approvalInstanceDto.setTemplateId(purchaseLedger.getTemplateId());


        approvalInstanceDto.setTemplateName(approvalTemplateMapper.selectById(purchaseLedger.getTemplateId()).getTemplateName());


        approvalInstanceDto.setApplicantName(SecurityUtils.getLoginUser().getNickName());


        approvalInstanceDto.setApplyTime(LocalDateTime.now());


        approvalInstanceService.add(approvalInstanceDto);


        // 4. 处理子表数据


        List<SalesLedgerProduct> productList = purchaseLedgerDto.getProductData();


        if (productList != null && !productList.isEmpty()) {


            handleSalesLedgerProducts(purchaseLedger.getId(), productList, purchaseLedgerDto.getType());


        }


        //新增原材料检验


        if (productList != null) {


            for (SalesLedgerProduct saleProduct : productList) {


                //是否推送质检，如果true就添加


                if (saleProduct.getIsChecked()) {


                    addQualityInspect(purchaseLedger, saleProduct);


                }


            }


        }


        // 6.采购审核新增；审批管理未配置采购审批人时，审批服务会自动置为审批通过。


        addApproveByPurchase(loginUser, purchaseLedger);


        // 5. 迁移临时文件到正式目录


        if (purchaseLedgerDto.getTempFileIds() != null && !purchaseLedgerDto.getTempFileIds().isEmpty()) {


            migrateTempFilesToFormal(purchaseLedger.getId(), purchaseLedgerDto.getTempFileIds());


        }


        fileUtil.saveStorageAttachment(ApplicationTypeEnum.FILE, RecordTypeEnum.PURCHASE_LEDGER, purchaseLedger.getId(), purchaseLedgerDto.getStorageBlobDTOS());


        return 1;


    }




    private void addQualityInspect(PurchaseLedger purchaseLedger, SalesLedgerProduct saleProduct) {




    public void addQualityInspect(PurchaseLedger purchaseLedger, SalesLedgerProduct saleProduct) {


        QualityInspect qualityInspect = new QualityInspect();


        qualityInspect.setInspectType(0);


        qualityInspect.setSupplier(purchaseLedger.getSupplierName());


@@ -237,6 +227,7 @@


        if (products == null || products.isEmpty()) {


            throw new BaseException("产品信息不存在");


        }


        Integer ledgerType = type == null ? 2 : type;




        // 提前收集所有需要查询的ID


        Set<Long> productIds = products.stream()


@@ -288,21 +279,18 @@


        // 执行更新操作


        if (!updateList.isEmpty()) {


            for (SalesLedgerProduct product : updateList) {


                product.setType(type);


                product.setType(ledgerType);


                salesLedgerProductMapper.updateById(product);


            }


        }


        // 执行插入操作


        if (!insertList.isEmpty()) {


            for (SalesLedgerProduct salesLedgerProduct : insertList) {


                salesLedgerProduct.setType(type);


                salesLedgerProduct.setType(ledgerType);


                Date entryDate = purchaseLedger.getEntryDate();




                LocalDateTime localDateTime = entryDate.toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime();


                salesLedgerProduct.setRegisterDate(localDateTime);


                salesLedgerProduct.setFutureTickets(salesLedgerProduct.getQuantity());


                salesLedgerProduct.setFutureTicketsAmount(salesLedgerProduct.getTaxInclusiveTotalPrice());


                salesLedgerProduct.setPendingTicketsTotal(salesLedgerProduct.getTaxInclusiveTotalPrice());


                salesLedgerProductMapper.insert(salesLedgerProduct);


            }


        }


@@ -320,85 +308,17 @@


        }


    }




    /**


     * 将临时文件迁移到正式目录


     *


     * @param businessId  业务ID（销售台账ID）


     * @param tempFileIds 临时文件ID列表


     * @throws IOException 文件操作异常


     */


    private void migrateTempFilesToFormal(Long businessId, List<String> tempFileIds) throws IOException {


        if (CollectionUtils.isEmpty(tempFileIds)) {


            return;


        }




        // 构建正式目录路径（按业务类型和日期分组）


        String formalDir = uploadDir + LocalDate.now().format(DateTimeFormatter.ISO_LOCAL_DATE);




        Path formalDirPath = Paths.get(formalDir);




        // 确保正式目录存在（递归创建）


        if (!Files.exists(formalDirPath)) {


            Files.createDirectories(formalDirPath);


        }




        for (String tempFileId : tempFileIds) {


            // 查询临时文件记录


            TempFile tempFile = tempFileMapper.selectById(tempFileId);


            if (tempFile == null) {


                log.warn("临时文件不存在，跳过处理: {}", tempFileId);


                continue;


            }




            // 构建正式文件名（包含业务ID和时间戳，避免冲突）


            String originalFilename = tempFile.getOriginalName();


            String fileExtension = FilenameUtils.getExtension(originalFilename);


            String formalFilename = businessId + "_" +


                    System.currentTimeMillis() + "_" +


                    UUID.randomUUID().toString().substring(0, 8) +


                    (StringUtils.hasText(fileExtension) ? "." + fileExtension : "");




            Path formalFilePath = formalDirPath.resolve(formalFilename);




            try {


                // 执行文件迁移（使用原子操作确保安全性）


//                Files.move(


//                        Paths.get(tempFile.getTempPath()),


//                        formalFilePath,


//                        StandardCopyOption.REPLACE_EXISTING,


//                        StandardCopyOption.ATOMIC_MOVE


//                );


                // 原子移动失败，使用复制+删除


                Files.copy(Paths.get(tempFile.getTempPath()), formalFilePath, StandardCopyOption.REPLACE_EXISTING);


                Files.deleteIfExists(Paths.get(tempFile.getTempPath()));


                log.info("文件迁移成功: {} -> {}", tempFile.getTempPath(), formalFilePath);




                // 更新文件记录（关联到业务ID）


                CommonFile fileRecord = new CommonFile();


                fileRecord.setCommonId(businessId);


                fileRecord.setName(originalFilename);


                fileRecord.setUrl(formalFilePath.toString());


                fileRecord.setCreateTime(LocalDateTime.now());


                fileRecord.setType(FileNameType.PURCHASE.getValue());


                commonFileMapper.insert(fileRecord);




                // 删除临时文件记录


                tempFileMapper.deleteById(tempFile);




                log.info("文件迁移成功: {} -> {}", tempFile.getTempPath(), formalFilePath);


            } catch (IOException e) {


                log.error("文件迁移失败: {}", tempFile.getTempPath(), e);


                // 可选择回滚事务或记录失败文件


                throw new IOException("文件迁移异常", e);


            }


        }


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public int deletePurchaseLedgerByIds(Long[] ids) {


        if (ids == null || ids.length == 0) {


           throw new BaseException("请选中至少一条数据");


        }


        for (Long id : ids) {


            PurchaseLedger purchaseLedger = purchaseLedgerMapper.selectById(id);


            if (purchaseLedger.getApprovalStatus().equals(3)) {


                throw new BaseException(purchaseLedger.getPurchaseContractNumber()+"已经审批通过，不允许删除");


            }


        }


        // 批量删除关联的采购入库记录


        LambdaQueryWrapper<SalesLedgerProduct> salesLedgerProductQueryWrapper = new LambdaQueryWrapper<>();


@@ -418,18 +338,6 @@


        queryWrapper.in(SalesLedgerProduct::getSalesLedgerId, ids)


                .eq(SalesLedgerProduct::getType, 2);


        salesLedgerProductMapper.delete(queryWrapper);


        // 批量删除关联的采购台账的来票登记


        LambdaQueryWrapper<TicketRegistration> ticketRegistrationLambdaQueryWrapper = new LambdaQueryWrapper<>();


        ticketRegistrationLambdaQueryWrapper.in(TicketRegistration::getPurchaseLedgerId,ids);


        ticketRegistrationMapper.delete(ticketRegistrationLambdaQueryWrapper);


        // 批量删除关联的采购台账的来票登记记录


        LambdaQueryWrapper<ProductRecord> productRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();


        productRecordLambdaQueryWrapper.in(ProductRecord::getPurchaseLedgerId,ids);


        productRecordMapper.delete(productRecordLambdaQueryWrapper);


        // 批量删除付款登记


        LambdaQueryWrapper<PaymentRegistration> paymentRegistrationLambdaQueryWrapper = new LambdaQueryWrapper<>();


        paymentRegistrationLambdaQueryWrapper.in(PaymentRegistration::getPurchaseLedgerId, ids);


        paymentRegistrationMapper.delete(paymentRegistrationLambdaQueryWrapper);


        //批量删除检验标准


        LambdaQueryWrapper<QualityInspect> materialInspectLambdaQueryWrapper = new LambdaQueryWrapper<>();


        materialInspectLambdaQueryWrapper.in(QualityInspect::getPurchaseLedgerId, ids);


@@ -485,11 +393,6 @@


                .eq(SalesLedgerProduct::getType, purchaseLedgerDto.getType());


        List<SalesLedgerProduct> products = salesLedgerProductMapper.selectList(productWrapper);




        // 3.查询上传文件


        LambdaQueryWrapper<CommonFile> salesLedgerFileWrapper = new LambdaQueryWrapper<>();


        salesLedgerFileWrapper.eq(CommonFile::getCommonId, purchaseLedger.getId())


                .eq(CommonFile::getType,FileNameType.PURCHASE.getValue());


        List<CommonFile> salesLedgerFiles = commonFileMapper.selectList(salesLedgerFileWrapper);




        // 4. 转换 DTO


        PurchaseLedgerDto resultDto = new PurchaseLedgerDto();


@@ -497,7 +400,7 @@


        if (!products.isEmpty()) {


            resultDto.setHasChildren(true);


            resultDto.setProductData(products);


            resultDto.setSalesLedgerFiles(salesLedgerFiles);


            resultDto.setStorageBlobVOS(fileUtil.getStorageBlobVOsByApplicationAndRecordTypeAndRecordId(ApplicationTypeEnum.FILE, RecordTypeEnum.PURCHASE_LEDGER, purchaseLedger.getId()));


        }


        return resultDto;


    }


@@ -537,14 +440,6 @@


        queryWrapper.eq(SalesLedgerProduct::getSalesLedgerId, purchaseLedger.getId())


                .eq(SalesLedgerProduct::getType, 2);


        List<SalesLedgerProduct> productList = salesLedgerProductMapper.selectList(queryWrapper);


        productList.forEach(product -> {


            product.setFutureTickets(product.getFutureTickets() != null ? product.getFutureTickets() : product.getQuantity());


            product.setFutureTicketsAmount(product.getFutureTicketsAmount() != null ? product.getFutureTicketsAmount() : product.getTaxInclusiveTotalPrice());


            product.setTicketsNum(null);


            product.setTicketsAmount(null);


            product.setTempFutureTickets(product.getFutureTickets());


            product.setTempFutureTicketsAmount(product.getFutureTicketsAmount());


        });


        resultDto.setProductData(productList);


        return resultDto;


    }


@@ -571,35 +466,36 @@


        PurchaseLedger purchaseLedger = purchaseLedgerMapper.selectById(id);




        BeanUtils.copyProperties(purchaseLedger, purchaseLedgerDto);


//        TicketRegistration ticketRegistration = ticketRegistrationMapper.selectOne(new LambdaQueryWrapper<TicketRegistration>().eq(TicketRegistration::getPurchaseLedgerId, id));


//        if (ticketRegistration != null) {


//            purchaseLedgerDto.setInvoiceNumber(ticketRegistration.getInvoiceNumber());


//            purchaseLedgerDto.setInvoiceAmount(ticketRegistration.getInvoiceAmount());


//            purchaseLedgerDto.setTicketRegistrationId(ticketRegistration.getId());


//        }


        return purchaseLedgerDto;


    }




    @Override


    public IPage<PurchaseLedgerDto> selectPurchaseLedgerListPage(IPage ipage, PurchaseLedgerDto purchaseLedger) {


        IPage<PurchaseLedgerDto> purchaseLedgerDtoIPage = purchaseLedgerMapper.selectPurchaseLedgerListPage(ipage, purchaseLedger);


        purchaseLedgerDtoIPage.getRecords().forEach(purchaseLedgerDto -> {


            List<CommonFile> commonFiles = commonFileMapper.selectList(new LambdaQueryWrapper<CommonFile>().eq(CommonFile::getCommonId, purchaseLedgerDto.getId()).eq(CommonFile::getType, FileNameType.PURCHASE.getValue()));


            purchaseLedgerDto.setSalesLedgerFiles(commonFiles);


        });


        return purchaseLedgerDtoIPage;


    }




    @Override


    public List<InvoiceRegistrationProduct> getProductBySalesNo(Long id) {


        List<InvoiceRegistrationProduct> invoiceRegistrationProducts = invoiceRegistrationProductMapper.selectList(new LambdaQueryWrapper<InvoiceRegistrationProduct>()


                .select(InvoiceRegistrationProduct::getId, InvoiceRegistrationProduct::getProductCategory, InvoiceRegistrationProduct::getSpecificationModel,


                        InvoiceRegistrationProduct::getUnit, InvoiceRegistrationProduct::getQuantity)


                .eq(InvoiceRegistrationProduct::getSalesLedgerId, id));


        if (invoiceRegistrationProducts.isEmpty()) {


            return new ArrayList<>();


        List<PurchaseLedgerDto> records = purchaseLedgerDtoIPage.getRecords();


        if (records == null || records.isEmpty()) {


            return purchaseLedgerDtoIPage;


        }


        return invoiceRegistrationProducts;




        // 批量查询文件，避免 N+1 问题


        List<Long> ledgerIds = records.stream()


                .map(PurchaseLedgerDto::getId)


                .filter(Objects::nonNull)


                .collect(Collectors.toList());




        if (!ledgerIds.isEmpty()) {


            List<CommonFile> allFiles = commonFileMapper.selectList(


                    new LambdaQueryWrapper<CommonFile>()


                            .in(CommonFile::getCommonId, ledgerIds)


                            .eq(CommonFile::getType, FileNameType.PURCHASE.getValue())


            );




            Map<Long, List<CommonFile>> fileMap = allFiles.stream()


                    .collect(Collectors.groupingBy(CommonFile::getCommonId));




            records.forEach(dto -> dto.setSalesLedgerFiles(fileMap.getOrDefault(dto.getId(), new ArrayList<>())));


        }


        return purchaseLedgerDtoIPage;


    }




    @Override


@@ -682,20 +578,21 @@


                if(salesLedger1 != null){


                    salesLedger.setSalesLedgerId(salesLedger1.getId());


                }


                // 采购审核


                // 通过昵称获取用户ID


                String[] split = salesLedger.getApproveUserIds().split("，");


                List<Long> ids = new ArrayList<>();


                for (int i = 0; i < split.length; i++) {


                    SysUser sysUser = sysUserMapper.selectOne(new LambdaQueryWrapper<SysUser>().eq(SysUser::getNickName, split[i])


                            .last("LIMIT 1"));


                    if (sysUser != null) {


                        ids.add(sysUser.getUserId());


                if (StringUtils.hasText(salesLedger.getApproveUserIds())) {


                    // 采购审核：历史导入模板传审批人姓名时，继续兼容转换为用户ID。


                    String[] split = salesLedger.getApproveUserIds().split("，");


                    List<Long> ids = new ArrayList<>();


                    for (int i = 0; i < split.length; i++) {


                        SysUser sysUser = sysUserMapper.selectOne(new LambdaQueryWrapper<SysUser>().eq(SysUser::getNickName, split[i])


                                .last("LIMIT 1"));


                        if (sysUser != null) {


                            ids.add(sysUser.getUserId());


                        }


                    }


                    // 将集合转为字符串，隔开


                    String collect = ids.stream().map(Object::toString).collect(Collectors.joining(","));


                    salesLedger.setApproveUserIds(collect);


                }


                // 将集合转为字符串，隔开


                String collect = ids.stream().map(Object::toString).collect(Collectors.joining(","));


                salesLedger.setApproveUserIds(collect);


                purchaseLedgerMapper.insert(salesLedger);




                for (PurchaseLedgerProductImportDto salesLedgerProductImportDto : salesLedgerProductImportDtos) {


@@ -705,8 +602,6 @@


                    salesLedgerProduct.setType(2);


                    // 计算不含税总价


                    salesLedgerProduct.setTaxExclusiveTotalPrice(salesLedgerProduct.getTaxInclusiveTotalPrice().divide(new BigDecimal(1).add(salesLedgerProduct.getTaxRate().divide(new BigDecimal(100))), 2, RoundingMode.HALF_UP));


                    salesLedgerProduct.setFutureTickets(salesLedgerProduct.getQuantity());


                    salesLedgerProduct.setFutureTicketsAmount(salesLedgerProduct.getTaxExclusiveTotalPrice());


                    list.stream()


                            .filter(map -> map.get("productName").equals(salesLedgerProduct.getProductCategory()) && map.get("model").equals(salesLedgerProduct.getSpecificationModel()))


                            .findFirst()


@@ -717,7 +612,6 @@


                    salesLedgerProduct.setRegister(loginUser.getNickName());


                    salesLedgerProduct.setRegisterDate(LocalDateTime.now());


                    salesLedgerProduct.setApproveStatus(0);


                    salesLedgerProduct.setPendingTicketsTotal(salesLedgerProductImportDto.getTaxInclusiveTotalPrice());


                    // 是否质检判断


                    salesLedgerProduct.setIsChecked(salesLedgerProductImportDto.getIsChecked() == 1);


                    if(salesLedgerProductImportDto.getIsChecked() == 1){


@@ -731,9 +625,9 @@




            return AjaxResult.success("导入成功");


        } catch (Exception e) {


            e.printStackTrace();


            log.error("PurchaseLedgerServiceImpl importData error", e);


            return AjaxResult.error("导入失败: " + e.getMessage());


        }


        return AjaxResult.success("导入失败");


    }




    @Override


@@ -763,6 +657,9 @@


    }




    public void addApproveByPurchase(LoginUser loginUser,PurchaseLedger purchaseLedger) throws Exception {


        if (loginUser == null) {


            return;


        }


        ApproveProcessVO approveProcessVO = new ApproveProcessVO();


        approveProcessVO.setApproveType(5);


        approveProcessVO.setApproveDeptId(loginUser.getCurrentDeptId());