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


@@ -1,5 +1,11 @@


package com.ruoyi.sales.service.impl;




import cn.hutool.core.bean.BeanUtil;


import cn.hutool.core.convert.Convert;


import cn.hutool.core.date.LocalDateTimeUtil;


import cn.hutool.core.io.FileUtil;


import cn.hutool.core.lang.Assert;


import cn.hutool.core.util.StrUtil;


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


import com.baomidou.mybatisplus.core.mapper.BaseMapper;


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


@@ -8,8 +14,10 @@


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


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


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


import com.deepoove.poi.XWPFTemplate;


import com.deepoove.poi.config.Configure;


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


import com.ruoyi.account.service.AccountIncomeService;


import com.ruoyi.aftersalesservice.pojo.AfterSalesService;


import com.ruoyi.basic.mapper.CustomerMapper;


import com.ruoyi.basic.mapper.ProductMapper;


import com.ruoyi.basic.mapper.ProductModelMapper;


@@ -17,31 +25,26 @@


import com.ruoyi.common.enums.FileNameType;


import com.ruoyi.common.enums.SaleEnum;


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


import com.ruoyi.common.utils.DateUtils;


import com.ruoyi.common.utils.EnumUtil;


import com.ruoyi.common.utils.SecurityUtils;


import com.ruoyi.common.utils.StringUtils;


import com.ruoyi.common.utils.*;


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


import com.ruoyi.production.pojo.*;


import com.ruoyi.production.service.ProductionProductMainService;


import com.ruoyi.production.service.impl.ProductionProductMainServiceImpl;


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.quality.pojo.QualityInspect;


import com.ruoyi.sales.dto.*;


import com.ruoyi.sales.mapper.*;


import com.ruoyi.sales.pojo.*;


import com.ruoyi.sales.service.ISalesLedgerProductService;


import com.ruoyi.sales.service.ISalesLedgerService;


import com.ruoyi.sales.vo.ExportProcessContractVo;


import lombok.RequiredArgsConstructor;


import lombok.SneakyThrows;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.io.FilenameUtils;


import org.springframework.beans.BeanUtils;


@@ -51,8 +54,12 @@


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


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.context.request.RequestContextHolder;


import org.springframework.web.context.request.ServletRequestAttributes;


import org.springframework.web.multipart.MultipartFile;




import javax.servlet.http.HttpServletResponse;


import javax.validation.constraints.NotNull;


import java.io.IOException;


import java.io.InputStream;


import java.lang.reflect.Field;


@@ -81,69 +88,41 @@


@RequiredArgsConstructor


@Slf4j


public class SalesLedgerServiceImpl extends ServiceImpl<SalesLedgerMapper, SalesLedger> implements ISalesLedgerService {


    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;




    @Autowired


    private SysDeptMapper sysDeptMapper;




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


    private String uploadDir;




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


    @Autowired


    private SysDeptMapper sysDeptMapper;


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


    private String uploadDir;


    @Autowired


    private ProductModelMapper productModelMapper;




@@ -154,14 +133,15 @@


    @Autowired


    private ProductionProductMainService productionProductMainService;


    ;


    @Autowired


    private SysUserMapper sysUserMapper;




    @Override


    public List<SalesLedger> selectSalesLedgerList(SalesLedgerDto salesLedgerDto) {


        return salesLedgerMapper.selectSalesLedgerList(salesLedgerDto);


    }






    public List<SalesLedgerProduct> getSalesLedgerProductListByRelateId(Long relateId, SaleEnum type){


    public List<SalesLedgerProduct> getSalesLedgerProductListByRelateId(Long relateId, SaleEnum type) {


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


        productWrapper.eq(SalesLedgerProduct::getSalesLedgerId, relateId);


        productWrapper.eq(SalesLedgerProduct::getType, type.getCode());


@@ -339,9 +319,6 @@


        return salesLedgerMapper.selectSalesLedgerListPage(page, salesLedgerDto);


    }




    @Autowired


    private SysUserMapper sysUserMapper;




    @Override


    @Transactional(rollbackFor = Exception.class)


    public AjaxResult importData(MultipartFile file) {


@@ -497,35 +474,90 @@


        return salesLedgerDtoIPage;


    }




    @Override


    public void exportProcessContract(Long id) {


        //加工承揽合同


        ExportProcessContractVo exportProcessContract = new ExportProcessContractVo();


        exportProcessContract.setId(id);


        SalesLedger salesLedger = salesLedgerMapper.selectById(id);


        // 查询客户公司信息


        Customer customer = customerMapper.selectById(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(""));




    // 内部类用于存储聚合结果


    private static class GroupedCustomer {


        private final Long customerId;


        private final String customerName;


        private BigDecimal totalAmount = BigDecimal.ZERO;


        // 填写甲方信息


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


        exportProcessContract.setPartyAClientName(customer.getCustomerName());


        exportProcessContract.setPartyA(partyA);




        public GroupedCustomer(Long customerId, String customerName) {


            this.customerId = customerId;


            this.customerName = customerName;


        // 填写乙方信息


        ExportProcessContractVo.Customer partyB = new ExportProcessContractVo.Customer();


        exportProcessContract.setPartyBClientName("");//todo@ 乙方公司名称


        exportProcessContract.setPartyB(partyB);




        // 填写商品信息


        final BigDecimal[] totalAmount = {BigDecimal.ZERO}; // 总金额


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


        productWrapper.eq(SalesLedgerProduct::getSalesLedgerId, salesLedger.getId());


        productWrapper.eq(SalesLedgerProduct::getType, 1);


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


        List<ExportProcessContractVo.SaleProduct> productList = products.stream().map(it -> {


            ExportProcessContractVo.SaleProduct saleProduct = BeanUtil.copyProperties(it, ExportProcessContractVo.SaleProduct.class);


            // 计算总价格


            totalAmount[0] = totalAmount[0].add(Optional.ofNullable(saleProduct.getTaxInclusiveTotalPrice()).orElse(BigDecimal.ZERO));


            return saleProduct;


        }).collect(Collectors.toList());


        // 第一个设置 合同编号


        if (!productList.isEmpty()) {


            productList.get(0).setSalesContractNo(salesLedger.getSalesContractNo());


        }


        // 查看税率 理论上税率单一，如果多税率为空


        Map<BigDecimal, Long> rateMap = productList.stream().map(product -> product.getTaxRate()).filter(Objects::nonNull)


                .collect(Collectors.groupingBy(Function.identity(), Collectors.counting()));


        String taxRateStr = rateMap.size() == 1 ? rateMap.keySet().iterator().next().toString() + " %" : "";


        exportProcessContract.setTaxRate(taxRateStr);


        exportProcessContract.setSaleProducts(productList);// 商品信息


        // 设置大写的总价格


        exportProcessContract.setTotalAmountZh(Convert.digitToChinese(totalAmount[0].doubleValue()));




        exportProcessContractToWord(exportProcessContract);


    }




    @SneakyThrows


    private void exportProcessContractToWord(@NotNull ExportProcessContractVo exportProcessContract){


        // 确保 saleProducts 不为 null


        if (exportProcessContract.getSaleProducts() == null) {


            exportProcessContract.setSaleProducts(new ArrayList<>());


        }




        public void addAmount(BigDecimal amount) {


            if (amount != null) {


                this.totalAmount = this.totalAmount.add(amount);


            }


        }


        // 模板输入流


        InputStream inputStream = this.getClass().getResourceAsStream("/static/contract_tmp.docx");


        Assert.isTrue(inputStream != null, "模板不存在");




        public Long getCustomerId() {


            return customerId;


        }


        // 转 Map


        Map<String, Object> dataMap = BeanUtil.beanToMap(exportProcessContract);




        public String getCustomerName() {


            return customerName;


        }


        // 绑定循环策略


        Configure configure = Configure.builder()


                .bind("saleProducts", new LoopRowTableRenderPolicy())


                .build();




        public BigDecimal getTotalAmount() {


            return totalAmount;


        }


        // 渲染模板


        XWPFTemplate template = XWPFTemplate.compile(inputStream, configure)


                .render(dataMap);


//        template.write(FileUtil.getOutputStream("/Users/ONEX/Downloads/a.docx"));




        // 输出到浏览器


        HttpServletResponse response =


                ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes()))


                        .getResponse();


        response.setContentType("application/vnd.openxmlformats-officedocument.wordprocessingml.document");


        response.setHeader("Content-Disposition", "attachment;filename="+ StrUtil.format("{}-{}",exportProcessContract.getPartyAClientName(),exportProcessContract.getCreateTime()) +"合同.docx");




        template.write(response.getOutputStream());


        template.close();


        response.flushBuffer();


    }




    /**


@@ -646,7 +678,7 @@


            // 4. 处理子表数据


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


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


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


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


                updateMainContractAmount(


                        salesLedger.getId(),


                        productList,


@@ -665,8 +697,6 @@


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


        }


    }




    // 文件迁移方法




    /**


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


@@ -743,6 +773,7 @@


        }


    }




    // 文件迁移方法




    @Override


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


@@ -884,4 +915,34 @@


            throw new RuntimeException("动态更新主表金额失败", e);


        }


    }




    // 内部类用于存储聚合结果


    private static class GroupedCustomer {


        private final Long customerId;


        private final String customerName;


        private BigDecimal totalAmount = BigDecimal.ZERO;




        public GroupedCustomer(Long customerId, String customerName) {


            this.customerId = customerId;


            this.customerName = customerName;


        }




        public void addAmount(BigDecimal amount) {


            if (amount != null) {


                this.totalAmount = this.totalAmount.add(amount);


            }


        }




        public Long getCustomerId() {


            return customerId;


        }




        public String getCustomerName() {


            return customerName;


        }




        public BigDecimal getTotalAmount() {


            return totalAmount;


        }


    }


}