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


@@ -2,6 +2,7 @@




import cn.hutool.core.bean.BeanUtil;


import cn.hutool.core.convert.Convert;


import cn.hutool.core.date.DateUtil;


import cn.hutool.core.date.LocalDateTimeUtil;


import cn.hutool.core.lang.Assert;


import cn.hutool.core.util.StrUtil;


@@ -17,10 +18,14 @@


import com.deepoove.poi.config.Configure;


import com.deepoove.poi.plugin.table.LoopRowTableRenderPolicy;


import com.ruoyi.account.service.AccountIncomeService;


import com.ruoyi.basic.dto.CustomerPrivatePoolDto;


import com.ruoyi.basic.dto.ProductModelAnticlockwiseDto;


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.service.IProductModelService;


import com.ruoyi.common.enums.FileNameType;


import com.ruoyi.common.enums.SaleEnum;


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


@@ -33,13 +38,12 @@


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


import com.ruoyi.production.service.ProductionProductMainService;


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


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


import com.ruoyi.project.system.mapper.SysDeptMapper;


import com.ruoyi.project.system.mapper.SysUserMapper;


import com.ruoyi.quality.mapper.QualityInspectMapper;


import com.ruoyi.sales.dto.*;


import com.ruoyi.sales.mapper.*;


import com.ruoyi.sales.pojo.*;


@@ -52,6 +56,7 @@


import org.springframework.beans.BeanUtils;


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


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


import org.springframework.context.annotation.Lazy;


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


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


import org.springframework.stereotype.Service;


@@ -107,21 +112,8 @@


    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 RedisTemplate<String, String> redisTemplate;


    @Autowired


    private SysDeptMapper sysDeptMapper;


@@ -135,10 +127,15 @@


    @Autowired


    private ProductStructureMapper productStructureMapper;


    @Autowired


    @Lazy


    private ProductionProductMainService productionProductMainService;


    ;




    @Autowired


    private SysUserMapper sysUserMapper;


    @Autowired


    private CustomerPrivatePoolMapper customerPrivatePoolMapper;


    @Autowired


    private IProductModelService productModelService;




    @Override


    public List<SalesLedger> selectSalesLedgerList(SalesLedgerDto salesLedgerDto) {


@@ -485,14 +482,15 @@


        exportProcessContract.setId(id);


        SalesLedger salesLedger = salesLedgerMapper.selectById(id);


        // 查询客户公司信息


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


        CustomerPrivatePoolDto customerPrivatePoolDto = customerPrivatePoolMapper.selectInfo(salesLedger.getCustomerId());




        exportProcessContract.setCreateTime(LocalDateTimeUtil.format(Optional.ofNullable(salesLedger.getExecutionDate()).orElse(LocalDate.now()), "yyyy年MM月dd日"));


        exportProcessContract.setRemark(Optional.ofNullable(salesLedger.getRemarks()).orElse("无")); // 备注


        exportProcessContract.setPlaceOfSinging(Optional.ofNullable(salesLedger.getPlaceOfSinging()).orElse(""));




        // 填写甲方信息


        ExportProcessContractVo.Customer partyA = ExportProcessContractVo.Customer.getCustomer(customer);


        exportProcessContract.setPartyAClientName(customer.getCustomerName());


        ExportProcessContractVo.Customer partyA = ExportProcessContractVo.Customer.getCustomer(customerPrivatePoolDto);


        exportProcessContract.setPartyAClientName(customerPrivatePoolDto.getCustomerName());


        exportProcessContract.setPartyA(partyA);




        // 填写乙方信息


@@ -668,28 +666,48 @@


    @Override


    @Transactional(rollbackFor = Exception.class)


    public int addOrUpdateSalesLedger(SalesLedgerDto salesLedgerDto) {


        try {


            // 1. 校验客户信息


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


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


            if (customer == null) {


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


            }


            // 必须填写销售合同号


//            Assert.notNull(salesLedgerDto.getSalesContractNo(), "销售合同号不能为空");




            // 2. DTO转Entity


            SalesLedger salesLedger = convertToEntity(salesLedgerDto);


            salesLedger.setCustomerName(customer.getCustomerName());


            salesLedger.setTenantId(customer.getTenantId());




            // 3. 新增或更新主表


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


                String contractNo = generateSalesContractNo();


                // 为空 自动生成


                String contractNo =StrUtil.isBlank(salesLedgerDto.getSalesContractNo())? generateSalesContractNoBy8Date():salesLedgerDto.getSalesContractNo();


                // 不能有重复数据的合同号


               Assert.isTrue(salesLedgerMapper.selectOne(new LambdaQueryWrapper<SalesLedger>()


                        .eq(SalesLedger::getSalesContractNo, contractNo)


                        .last("limit 1")) == null, contractNo+"合同号已存在");


                salesLedger.setSalesContractNo(contractNo);


                salesLedgerMapper.insert(salesLedger);


            } else {


                salesLedger.setSalesContractNo(null);


                salesLedgerMapper.updateById(salesLedger);


            }




            // 4. 处理子表数据


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


            for (SalesLedgerProduct product : productList) {


                //空的先新增基础数据  非空直接往下走


                if (ObjectUtils.isEmpty(product.getProductModelId())) {


                    ProductModelAnticlockwiseDto  productModelAnticlockwiseDto =  new ProductModelAnticlockwiseDto();


                    productModelAnticlockwiseDto.setModel(product.getSpecificationModel());


                    productModelAnticlockwiseDto.setProductName(product.getProductCategory());


                    productModelAnticlockwiseDto.setUnit(product.getUnit());


                    productModelAnticlockwiseDto.setSubUnit(product.getUnit());


                    Long productModelId = productModelService.productModelAnticlockwise(productModelAnticlockwiseDto);


                    product.setProductModelId(productModelId);


                }


            }


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


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


                updateMainContractAmount(


@@ -700,6 +718,7 @@


                        SalesLedger.class


                );


            }


        try {




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


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


@@ -825,6 +844,20 @@


        return entity;


    }




    public String generateSalesContractNoBy8Date(){


        String yyMM = DateUtil.format(new Date(), "yyMM");


        // 查询一个月有多少订单


        Date begin = DateUtil.beginOfMonth(new Date());


        Date end = DateUtil.endOfMonth(new Date());


        LambdaQueryWrapper<SalesLedger> queryWrapper = new LambdaQueryWrapper<>();


        queryWrapper.between(SalesLedger::getEntryDate, begin, end);


        long count = salesLedgerMapper.selectCount(queryWrapper);


        Long seq = Optional.of(count).orElse(0L) + 1;


        return String.format("%s%04d", yyMM, seq);


    }








    @Transactional(readOnly = true)


    public String generateSalesContractNo() {


        LocalDate currentDate = LocalDate.now();