产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liyong
2026-05-15 0578c6c76f13e367b5dc7d0882efe3c69ca4cb0e 
 src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java


@@ -9,12 +9,10 @@


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


import com.ruoyi.basic.mapper.ProductMapper;


import com.ruoyi.basic.mapper.ProductModelMapper;


import com.ruoyi.basic.pojo.Customer;


import com.ruoyi.basic.utils.FileUtil;


@@ -49,6 +47,7 @@


import lombok.extern.slf4j.Slf4j;


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;


@@ -82,11 +81,13 @@


    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;


@@ -94,14 +95,29 @@


    private final InvoiceLedgerMapper invoiceLedgerMapper;


    private final InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;


    private final InvoiceRegistrationMapper invoiceRegistrationMapper;


    private final ProductModelMapper productModelMapper;


    private final ProductionProductMainMapper productionProductMainMapper;


    private final ProductionProductOutputMapper productionProductOutputMapper;


    private final ProductionProductInputMapper productionProductInputMapper;


    private final QualityInspectMapper qualityInspectMapper;


    private final RedisTemplate<String, String> redisTemplate;


    private final SysDeptMapper sysDeptMapper;


    private final ProductionProductMainService productionProductMainService;


    private final PurchaseReturnOrderProductsMapper purchaseReturnOrderProductsMapper;


    private final SysUserMapper sysUserMapper;


    private final CustomerPrivatePoolMapper customerPrivatePoolMapper;


    private final FileUtil fileUtil;


    @Autowired


    private SysDeptMapper sysDeptMapper;


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


    private String uploadDir;


    @Autowired


    private ProductModelMapper productModelMapper;




    @Autowired


    private ProductMapper productMapper;


    @Autowired


    private ProductionProductMainService productionProductMainService;


    @Autowired


    private PurchaseReturnOrderProductsMapper purchaseReturnOrderProductsMapper;


    ;


    @Autowired


    private SysUserMapper sysUserMapper;


    @Autowired


    private FileUtil fileUtil;




    @Override


    public List<SalesLedger> selectSalesLedgerList(SalesLedgerDto salesLedgerDto) {


@@ -185,9 +201,6 @@


            resultDto.setProductData(products);


            resultDto.setSalesLedgerFiles(salesLedgerFiles);


        }


        // 5. 查询附件


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


        resultDto.setStorageBlobVOs(StorageBlobVOs);


        return resultDto;


    }




@@ -474,6 +487,12 @@


        return salesLedgerDtoIPage;


    }




    @Override


    public Boolean delLdgerFile(Long[] ids) {


        fileUtil.deleteStorageBlobsByStorageAttachmentIds(List.of(ids));


        return true;


    }




    /**


     * 下划线命名转驼峰命名


     */


@@ -514,7 +533,7 @@


        List<Long> productIds = products.stream()


                .map(SalesLedgerProduct::getId)


                .collect(Collectors.toList());


        //删除生产计划


        //删除生产数据


        salesLedgerProductServiceImpl.deleteProductionData(productIds);




        // 批量删除产品子表


@@ -570,7 +589,7 @@


    @Transactional(rollbackFor = Exception.class)


    public int addOrUpdateSalesLedger(SalesLedgerDto salesLedgerDto) {


        // 1. 校验客户信息


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


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


        if (customer == null) {


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


        }


@@ -601,14 +620,15 @@


            );


        }




        // 5. 保存文件


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


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


        }


        //业务和附件绑定


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


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


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


//            }


        return 1;


    }




    // 文件迁移方法






    @Override


    public void handleSalesLedgerProducts(Long salesLedgerId, List<SalesLedgerProduct> products, SaleEnum type) {