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


@@ -12,24 +12,31 @@


import com.ruoyi.account.pojo.AccountIncome;


import com.ruoyi.account.service.AccountIncomeService;


import com.ruoyi.basic.mapper.CustomerMapper;


import com.ruoyi.basic.mapper.ProductMapper;


import com.ruoyi.basic.mapper.ProductModelMapper;


import com.ruoyi.basic.pojo.Customer;


import com.ruoyi.basic.pojo.Product;


import com.ruoyi.basic.pojo.ProductModel;


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.production.dto.ProductStructureDto;


import com.ruoyi.production.mapper.*;


import com.ruoyi.production.pojo.*;


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


import com.ruoyi.sales.dto.SalesLedgerDto;


import com.ruoyi.sales.dto.*;


import com.ruoyi.sales.mapper.*;


import com.ruoyi.sales.pojo.*;


import com.ruoyi.sales.service.ISalesLedgerProductService;


@@ -44,10 +51,13 @@


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


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


@@ -85,6 +95,12 @@


    private final TempFileMapper tempFileMapper;




    private final ReceiptPaymentMapper receiptPaymentMapper;




    private final ShippingInfoServiceImpl shippingInfoServiceImpl;




    private final CommonFileServiceImpl commonFileService;




    private final ShippingInfoMapper shippingInfoMapper;




    private final InvoiceLedgerMapper invoiceLedgerMapper;




@@ -130,6 +146,9 @@


    private final RedisTemplate<String, String> redisTemplate;


    @Autowired


    private ProductModelMapper productModelMapper;




    @Autowired


    private ProductMapper productMapper;


    @Autowired


    private ProductStructureMapper productStructureMapper;




@@ -219,8 +238,8 @@


        // 查询原始数据


        LambdaQueryWrapper<SalesLedger> queryWrapper = Wrappers.lambdaQuery();


        queryWrapper.select(SalesLedger::getCustomerId,


                SalesLedger::getCustomerName,


                SalesLedger::getContractAmount)


                        SalesLedger::getCustomerName,


                        SalesLedger::getContractAmount)


                .orderByDesc(SalesLedger::getContractAmount);


        List<SalesLedger> records = salesLedgerMapper.selectList(queryWrapper);




@@ -228,7 +247,7 @@


        Map<Long, GroupedCustomer> groupedMap = new LinkedHashMap<>(); // 使用LinkedHashMap保持排序


        for (SalesLedger record : records) {


            groupedMap.computeIfAbsent(record.getCustomerId(),


                    k -> new GroupedCustomer(record.getCustomerId(), record.getCustomerName()))


                            k -> new GroupedCustomer(record.getCustomerId(), record.getCustomerName()))


                    .addAmount(record.getContractAmount());


        }




@@ -324,6 +343,129 @@


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


        return salesLedgerMapper.selectSalesLedgerListPage(page, salesLedgerDto);


    }




    @Autowired


    private SysUserMapper sysUserMapper;




    @Override


    @Transactional(rollbackFor = Exception.class)


    public AjaxResult importData(MultipartFile file) {


        LoginUser loginUser = SecurityUtils.getLoginUser();


        try {


            InputStream inputStream = file.getInputStream();


            ExcelUtil<SalesLedgerImportDto> salesLedgerImportDtoExcelUtil = new ExcelUtil<>(SalesLedgerImportDto.class);


            Map<String, List<SalesLedgerImportDto>> stringListMap = salesLedgerImportDtoExcelUtil.importExcelMultiSheet(Arrays.asList("销售台账数据", "销售产品数据"), inputStream, 0);


            if (CollectionUtils.isEmpty(stringListMap)) return AjaxResult.error("销售表格为空！");


            // 业务层合并


            List<SalesLedgerImportDto> salesLedgerImportDtoList = stringListMap.get("销售台账数据");


            if (CollectionUtils.isEmpty(salesLedgerImportDtoList)) return AjaxResult.error("销售台账数据为空！");


            List<SalesLedgerImportDto> salesLedgerProductImportDtoList = stringListMap.get("销售产品数据");


            if (CollectionUtils.isEmpty(salesLedgerProductImportDtoList)) return AjaxResult.error("销售产品数据为空！");


            // 客户数据


            List<Customer> customers = customerMapper.selectList(new LambdaQueryWrapper<Customer>().in(Customer::getCustomerName,


                    salesLedgerImportDtoList.stream().map(SalesLedgerImportDto::getCustomerName).collect(Collectors.toList())));


//            // 规格型号数据


//            List<ProductModel> productModels = productModelMapper.selectList(new LambdaQueryWrapper<ProductModel>().in(ProductModel::getModel,


//                    salesLedgerProductImportDtoList.stream().map(SalesLedgerImportDto::getSpecificationModel).collect(Collectors.toList())));


//            // 产品大类数据


//            List<Product> productList = productMapper.selectList(new LambdaQueryWrapper<Product>().in(Product::getProductName,


//                    salesLedgerProductImportDtoList.stream().map(SalesLedgerImportDto::getProductCategory).collect(Collectors.toList())));


            List<Map<String,Object>> list = productModelMapper.getProductAndModelList();


            // 录入人数据


            List<SysUser> sysUsers = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>().in(SysUser::getNickName,


                    salesLedgerImportDtoList.stream().map(SalesLedgerImportDto::getEntryPerson).collect(Collectors.toList())));


            for (SalesLedgerImportDto salesLedgerImportDto : salesLedgerImportDtoList) {


                SalesLedger salesLedger1 = salesLedgerMapper.selectOne(new LambdaQueryWrapper<SalesLedger>()


                        .eq(SalesLedger::getSalesContractNo, salesLedgerImportDto.getSalesContractNo())


                        .last("LIMIT 1"));


                if(salesLedger1 != null){


                    continue;


                }


                SalesLedger salesLedger = new SalesLedger();


                BeanUtils.copyProperties(salesLedgerImportDto, salesLedger);


                salesLedger.setExecutionDate(DateUtils.toLocalDate(salesLedgerImportDto.getExecutionDate()));


                // 通过客户名称查询客户ID，客户合同号


                salesLedger.setCustomerId(customers.stream()


                        .filter(customer -> customer.getCustomerName().equals(salesLedger.getCustomerName()))


                        .findFirst()


                        .map(Customer::getId)


                        .orElse(null));


                salesLedger.setCustomerContractNo(customers.stream()


                        .filter(customer -> customer.getCustomerName().equals(salesLedger.getCustomerName()))


                        .findFirst()


                        .map(Customer::getTaxpayerIdentificationNumber)


                        .orElse(null));


                Long aLong = sysUsers.stream()


                        .filter(sysUser -> sysUser.getNickName().equals(salesLedger.getEntryPerson()))


                        .findFirst()


                        .map(SysUser::getUserId)


                        .orElse(null);


                if (aLong == null)


                    throw new RuntimeException("录入人:" + salesLedger.getEntryPerson() + ",无对应用户！");


                salesLedger.setEntryPerson(aLong.toString());


                // 销售产品数据绑定，通过销售单号获取对应销售产品数据


                List<SalesLedgerProductImportDto> salesLedgerProductImportDtos = salesLedgerProductImportDtoList.stream()


                        .filter(salesLedgerProductImportDto -> salesLedgerProductImportDto.getSalesContractNo().equals(salesLedger.getSalesContractNo()))


                        .collect(Collectors.toList());


                if (CollectionUtils.isEmpty(salesLedgerProductImportDtos))


                    throw new RuntimeException("销售单号:" + salesLedgerImportDto.getSalesContractNo() + ",无对应产品数据！");


                salesLedger.setContractAmount(salesLedgerProductImportDtos.stream()


                        .map(SalesLedgerProductImportDto::getTaxInclusiveTotalPrice)


                        .reduce(BigDecimal.ZERO,BigDecimal::add));


                salesLedgerMapper.insert(salesLedger);






                for (SalesLedgerProductImportDto salesLedgerProductImportDto : salesLedgerProductImportDtos) {


                    SalesLedgerProduct salesLedgerProduct = new SalesLedgerProduct();


                    BeanUtils.copyProperties(salesLedgerProductImportDto, salesLedgerProduct);


                    salesLedgerProduct.setSalesLedgerId(salesLedger.getId());


                    salesLedgerProduct.setType(1);


                    // 计算不含税总价


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


                    salesLedgerProduct.setNoInvoiceNum(salesLedgerProduct.getQuantity());


                    salesLedgerProduct.setNoInvoiceAmount(salesLedgerProduct.getTaxExclusiveTotalPrice());


                    list.stream()


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


                            .findFirst()


                            .ifPresent(map -> {


                                salesLedgerProduct.setProductModelId(Long.parseLong(map.get("modelId").toString()));


                                salesLedgerProduct.setProductId(Long.parseLong(map.get("id").toString()));


                            });


//                    salesLedgerProduct.setProductId(productList.stream()


//                            .filter(product -> product.getProductName().equals(salesLedgerProduct.getProductCategory()))


//                            .findFirst()


//                            .map(Product::getId)


//                            .orElse(null));


//                    salesLedgerProduct.setProductModelId(productModels.stream()


//                            .filter(productModel -> productModel.getModel().equals(salesLedgerProduct.getSpecificationModel()))


//                            .findFirst()


//                            .map(ProductModel::getId)


//                            .orElse(null));


                    salesLedgerProduct.setRegister(loginUser.getNickName());


                    salesLedgerProduct.setRegisterDate(LocalDateTime.now());


                    salesLedgerProduct.setApproveStatus(0);


                    salesLedgerProduct.setPendingInvoiceTotal(salesLedgerProductImportDto.getTaxInclusiveTotalPrice());


                    salesLedgerProductMapper.insert(salesLedgerProduct);


                }


            }




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


        } catch (Exception e) {


            e.printStackTrace();


        }


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


    }




    @Override


    public List<LossProductModelDto> getSalesLedgerWithProductsLoss(Long salesLedgerId) {






        List<LossProductModelDto> lossProductModelDtos = salesLedgerProductMapper.selectProductBomStructure(salesLedgerId);






        return lossProductModelDtos;


    }






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


    private static class GroupedCustomer {


@@ -426,6 +568,14 @@


            wrapperTree.in(ReceiptPayment::getInvoiceLedgerId, invoiceLedgerIds);


            receiptPaymentMapper.delete(wrapperTree);


        }


        // 删除发货台账记录


        List<ShippingInfo> shippingInfos = shippingInfoMapper.selectList(new LambdaQueryWrapper<ShippingInfo>()


                .eq(ShippingInfo::getSalesLedgerId, idList));


        if(CollectionUtils.isNotEmpty(shippingInfos)){


            shippingInfoServiceImpl.delete(shippingInfos.stream().map(ShippingInfo::getId).collect(Collectors.toList()));


        }


        // 删除附件表


        commonFileService.deleteByBusinessIds(idList, FileNameType.SALE.getValue());




        // 删除生产管控数据


        // 删除生产订单数据


@@ -458,39 +608,13 @@


            SalesLedger salesLedger = convertToEntity(salesLedgerDto);


            salesLedger.setCustomerName(customer.getCustomerName());


            salesLedger.setTenantId(customer.getTenantId());




            AccountIncome accountIncome = new AccountIncome();


            accountIncome.setIncomeDate(salesLedger.getEntryDate());


            accountIncome.setIncomeType("0");


            accountIncome.setCustomerName(customer.getCustomerName());


            accountIncome.setIncomeMoney(salesLedger.getContractAmount());


            accountIncome.setIncomeMethod("0");


            accountIncome.setInputTime(new Date());


            accountIncome.setInputUser(salesLedger.getEntryPerson());


            // 3. 新增或更新主表


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


                String contractNo = generateSalesContractNo();


                salesLedger.setSalesContractNo(contractNo);


                salesLedgerMapper.insert(salesLedger);


                accountIncome.setIncomeDescribed("销售合同：" + salesLedger.getSalesContractNo());


                accountIncome.setInvoiceNumber(salesLedger.getSalesContractNo());


                accountIncomeService.save(accountIncome);


            } else {


                salesLedgerMapper.updateById(salesLedger);


                SalesLedger salesLedgerDB = salesLedgerMapper.selectById(salesLedger.getId());


                List<AccountIncome> accountIncomeDBs = accountIncomeService.getByInvoiceNumberList(salesLedger.getSalesContractNo());


                if (!org.springframework.util.CollectionUtils.isEmpty(accountIncomeDBs)) {


                    accountIncomeDBs.forEach(accountIncomeDB -> {


                        accountIncomeDB.setCustomerName(salesLedgerDB.getCustomerName());


                        accountIncomeDB.setIncomeMoney(salesLedgerDB.getContractAmount());


                        accountIncomeDB.setIncomeDescribed("销售合同：" + salesLedgerDB.getSalesContractNo());


                        accountIncomeDB.setInvoiceNumber(salesLedgerDB.getSalesContractNo());


                        accountIncomeDB.setInputTime(new Date());


                        accountIncomeDB.setInputUser(salesLedgerDB.getEntryPerson());


                        accountIncomeService.updateById(accountIncomeDB);


                    });


                }




            }




            // 4. 处理子表数据


@@ -616,6 +740,7 @@


                salesLedgerProduct.setType(type);


                salesLedgerProduct.setNoInvoiceNum(salesLedgerProduct.getQuantity());


                salesLedgerProduct.setNoInvoiceAmount(salesLedgerProduct.getTaxInclusiveTotalPrice());


                salesLedgerProduct.setPendingInvoiceTotal(salesLedgerProduct.getTaxInclusiveTotalPrice());


                salesLedgerProductMapper.insert(salesLedgerProduct);


                // 添加生产数据


                salesLedgerProductServiceImpl.addProductionData(salesLedgerProduct);