产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liyong
2 天以前 bd02d873d7bbcae36a2a1262d921f2fc6b0cce09 
 src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java


@@ -9,10 +9,15 @@


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


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


import com.ruoyi.account.service.AccountIncomeService;


import com.ruoyi.basic.dto.CustomerPrivatePoolDto;


import com.ruoyi.basic.dto.StorageBlobVO;


import com.ruoyi.basic.enums.ApplicationTypeEnum;


import com.ruoyi.basic.enums.RecordTypeEnum;


import com.ruoyi.basic.mapper.CustomerMapper;


import com.ruoyi.basic.mapper.ProductMapper;


import com.ruoyi.basic.mapper.CustomerPrivatePoolMapper;


import com.ruoyi.basic.mapper.ProductModelMapper;


import com.ruoyi.basic.pojo.Customer;


import com.ruoyi.basic.utils.FileUtil;


import com.ruoyi.common.enums.FileNameType;


import com.ruoyi.common.enums.SaleEnum;


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


@@ -24,8 +29,9 @@


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.production.mapper.*;


import com.ruoyi.production.mapper.ProductionProductInputMapper;


import com.ruoyi.production.mapper.ProductionProductMainMapper;


import com.ruoyi.production.mapper.ProductionProductOutputMapper;


import com.ruoyi.production.service.ProductionProductMainService;


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


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


@@ -38,12 +44,11 @@


import com.ruoyi.sales.mapper.*;


import com.ruoyi.sales.pojo.*;


import com.ruoyi.sales.service.ISalesLedgerService;


import com.ruoyi.sales.vo.SalesLedgerVo;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.io.FilenameUtils;


import org.jetbrains.annotations.Nullable;


import org.springframework.beans.BeanUtils;


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


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


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


import org.springframework.data.redis.core.script.DefaultRedisScript;


@@ -51,15 +56,10 @@


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.multipart.MultipartFile;




import java.io.IOException;


import java.io.InputStream;


import java.lang.reflect.Field;


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.YearMonth;


@@ -82,52 +82,26 @@


    private static final String LOCK_PREFIX = "contract_no_lock:";


    private static final long LOCK_WAIT_TIMEOUT = 10; // 锁等待超时时间（秒）


    private static final long LOCK_EXPIRE_TIME = 30;  // 锁自动过期时间（秒）


    private final AccountIncomeService accountIncomeService;


    private final SalesLedgerMapper salesLedgerMapper;


    private final CustomerMapper customerMapper;


    private final SalesLedgerProductMapper salesLedgerProductMapper;


    private final SalesLedgerProductServiceImpl salesLedgerProductServiceImpl;


    private final CommonFileMapper commonFileMapper;


    private final TempFileMapper tempFileMapper;


    private final ReceiptPaymentMapper receiptPaymentMapper;


    private final ShippingInfoServiceImpl shippingInfoServiceImpl;


    private final CommonFileServiceImpl commonFileService;


    private final ShippingInfoMapper shippingInfoMapper;


    private final InvoiceLedgerMapper invoiceLedgerMapper;


    private final SalesLedgerSchedulingMapper salesLedgerSchedulingMapper;


    private final SalesLedgerWorkMapper salesLedgerWorkMapper;


    private final SalesLedgerProductionAccountingMapper salesLedgerProductionAccountingMapper;


    private final InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;


    private final InvoiceRegistrationMapper invoiceRegistrationMapper;


    private final ProductOrderMapper productOrderMapper;


    private final ProcessRouteMapper processRouteMapper;


    private final ProductProcessRouteMapper productProcessRouteMapper;


    private final ProcessRouteItemMapper processRouteItemMapper;


    private final ProductProcessRouteItemMapper productProcessRouteItemMapper;


    private final ProductWorkOrderMapper productWorkOrderMapper;


    private final ProductionProductMainMapper productionProductMainMapper;


    private final ProductionProductOutputMapper productionProductOutputMapper;


    private final ProductionProductInputMapper productionProductInputMapper;


    private final QualityInspectMapper qualityInspectMapper;


    private final ProductModelMapper productModelMapper;


    private final RedisTemplate<String, String> redisTemplate;


    @Autowired


    private SysDeptMapper sysDeptMapper;


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


    private String uploadDir;


    @Autowired


    private ProductModelMapper productModelMapper;




    @Autowired


    private ProductMapper productMapper;


    @Autowired


    private ProductStructureMapper productStructureMapper;


    @Autowired


    private ProductionProductMainService productionProductMainService;


    @Autowired


    private PurchaseReturnOrderProductsMapper purchaseReturnOrderProductsMapper;


    ;


    @Autowired


    private SysUserMapper sysUserMapper;


    private final SysDeptMapper sysDeptMapper;


    private final ProductionProductMainService productionProductMainService;


    private final PurchaseReturnOrderProductsMapper purchaseReturnOrderProductsMapper;


    private final SysUserMapper sysUserMapper;


    private final CustomerPrivatePoolMapper customerPrivatePoolMapper;


    private final FileUtil fileUtil;




    @Override


    public List<SalesLedger> selectSalesLedgerList(SalesLedgerDto salesLedgerDto) {


@@ -211,6 +185,9 @@


            resultDto.setProductData(products);


            resultDto.setSalesLedgerFiles(salesLedgerFiles);


        }


        // 5. 查询附件


        List<StorageBlobVO> StorageBlobVOs = fileUtil.getStorageBlobVOsByRecordTypeAndRecordId(RecordTypeEnum.SALES_LEDGER, salesLedger.getId());


        resultDto.setStorageBlobVOs(StorageBlobVOs);


        return resultDto;


    }




@@ -334,7 +311,7 @@


    }




    @Override


    public IPage<SalesLedger> selectSalesLedgerListPage(Page page, SalesLedgerDto salesLedgerDto) {


    public IPage<SalesLedgerVo> selectSalesLedgerListPage(Page page, SalesLedgerDto salesLedgerDto) {


        return salesLedgerMapper.selectSalesLedgerListPage(page, salesLedgerDto);


    }




@@ -479,6 +456,8 @@


                        .eq(ShippingInfo::getSalesLedgerProductId, product.getId())


                        .orderByDesc(ShippingInfo::getCreateTime)


                        .last("limit 1"));


                product.setShippingCarNumber(shippingInfo.getShippingCarNumber());


                product.setShippingDate(shippingInfo.getShippingDate());


                if (shippingInfo != null) {


                    product.setShippingStatus(shippingInfo.getStatus());


                }


@@ -535,7 +514,7 @@


        List<Long> productIds = products.stream()


                .map(SalesLedgerProduct::getId)


                .collect(Collectors.toList());


        //删除生产数据


        //删除生产计划


        salesLedgerProductServiceImpl.deleteProductionData(productIds);




        // 批量删除产品子表


@@ -590,122 +569,43 @@


    @Override


    @Transactional(rollbackFor = Exception.class)


    public int addOrUpdateSalesLedger(SalesLedgerDto salesLedgerDto) {


        try {


            // 1. 校验客户信息


            Customer customer = customerMapper.selectById(salesLedgerDto.getCustomerId());


            if (customer == null) {


                throw new BaseException("客户不存在");


            }




            // 2. DTO转Entity


            SalesLedger salesLedger = convertToEntity(salesLedgerDto);


            salesLedger.setCustomerName(customer.getCustomerName());


            salesLedger.setTenantId(customer.getTenantId());


            // 3. 新增或更新主表


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


                String contractNo = generateSalesContractNo();


                salesLedger.setSalesContractNo(contractNo);


                salesLedgerMapper.insert(salesLedger);


            } else {


                salesLedgerMapper.updateById(salesLedger);


            }




            // 4. 处理子表数据


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


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


                handleSalesLedgerProducts(salesLedger.getId(), productList, EnumUtil.fromCode(SaleEnum.class, salesLedgerDto.getType()));


                updateMainContractAmount(


                        salesLedger.getId(),


                        productList,


                        SalesLedgerProduct::getTaxInclusiveTotalPrice,


                        salesLedgerMapper,


                        SalesLedger.class


                );


            }




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


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


                migrateTempFilesToFormal(salesLedger.getId(), salesLedgerDto.getTempFileIds());


            }


            return 1;


        } catch (IOException e) {


            throw new BaseException("文件迁移失败: " + e.getMessage());


        }


    }




    /**


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


     *


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


     * @param tempFileIds 临时文件ID列表


     * @throws IOException 文件操作异常


     */


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


        if (CollectionUtils.isEmpty(tempFileIds)) {


            return;


        // 1. 校验客户信息


        CustomerPrivatePoolDto customer = customerPrivatePoolMapper.selectInfo(salesLedgerDto.getCustomerId());


        if (customer == null) {


            throw new BaseException("客户不存在");


        }




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


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




        Path formalDirPath = Paths.get(formalDir);




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


        if (!Files.exists(formalDirPath)) {


            Files.createDirectories(formalDirPath);


        // 2. DTO转Entity


        SalesLedger salesLedger = convertToEntity(salesLedgerDto);


        salesLedger.setCustomerName(customer.getCustomerName());


        salesLedger.setTenantId(customer.getTenantId());


        // 3. 新增或更新主表


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


            String contractNo = generateSalesContractNo();


            salesLedger.setSalesContractNo(contractNo);


            salesLedgerMapper.insert(salesLedger);


        } else {


            salesLedgerMapper.updateById(salesLedger);


        }




        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.SALE.getValue());


                commonFileMapper.insert(fileRecord);




                // 删除临时文件记录


                tempFileMapper.deleteById(tempFile);




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


            } catch (IOException e) {


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


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


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


            }


        // 4. 处理子表数据


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


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


            handleSalesLedgerProducts(salesLedger.getId(), productList, EnumUtil.fromCode(SaleEnum.class, salesLedgerDto.getType()));


            updateMainContractAmount(


                    salesLedger.getId(),


                    productList,


                    SalesLedgerProduct::getTaxInclusiveTotalPrice,


                    salesLedgerMapper,


                    SalesLedger.class


            );


        }




        // 5. 保存文件


        if (salesLedgerDto.getStorageBlobDTOs() != null && !salesLedgerDto.getStorageBlobDTOs().isEmpty()) {


            fileUtil.saveStorageAttachment(ApplicationTypeEnum.FILE, RecordTypeEnum.SALES_LEDGER, salesLedger.getId(), salesLedgerDto.getStorageBlobDTOs());


        }


        return 1;


    }




    // 文件迁移方法