From 37b697351e8e0a9200eee1276c4081c07588dc10 Mon Sep 17 00:00:00 2001 From: liyong <18434998025@163.com> Date: 星期二, 17 六月 2025 20:39:48 +0800 Subject: [PATCH] 未回款金额(元)为NaN修复 --- src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java | 109 +++++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 91 insertions(+), 18 deletions(-) diff --git a/src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java b/src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java index c2bef5b..ffe7f4f 100644 --- a/src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java +++ b/src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java @@ -1,7 +1,9 @@ package com.ruoyi.purchase.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; +import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.basic.mapper.ProductMapper; @@ -11,21 +13,24 @@ import com.ruoyi.basic.pojo.ProductModel; import com.ruoyi.basic.pojo.SupplierManage; import com.ruoyi.common.exception.base.BaseException; +import com.ruoyi.common.utils.SecurityUtils; import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.framework.security.LoginUser; import com.ruoyi.other.mapper.TempFileMapper; import com.ruoyi.other.pojo.TempFile; import com.ruoyi.project.system.domain.SysUser; import com.ruoyi.project.system.mapper.SysUserMapper; import com.ruoyi.purchase.dto.PurchaseLedgerDto; +import com.ruoyi.purchase.mapper.ProductRecordMapper; import com.ruoyi.purchase.mapper.PurchaseLedgerMapper; import com.ruoyi.purchase.mapper.TicketRegistrationMapper; +import com.ruoyi.purchase.pojo.ProductRecord; import com.ruoyi.purchase.pojo.PurchaseLedger; import com.ruoyi.purchase.pojo.TicketRegistration; import com.ruoyi.purchase.service.IPurchaseLedgerService; -import com.ruoyi.sales.mapper.CommonFileMapper; -import com.ruoyi.sales.mapper.SalesLedgerMapper; -import com.ruoyi.sales.mapper.SalesLedgerProductMapper; +import com.ruoyi.sales.mapper.*; import com.ruoyi.sales.pojo.CommonFile; +import com.ruoyi.sales.pojo.InvoiceRegistrationProduct; import com.ruoyi.sales.pojo.SalesLedger; import com.ruoyi.sales.pojo.SalesLedgerProduct; import lombok.RequiredArgsConstructor; @@ -33,6 +38,7 @@ import org.apache.commons.io.FilenameUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Value; +import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Service; import java.io.IOException; @@ -45,6 +51,7 @@ import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.*; +import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; /** @@ -77,6 +84,12 @@ private final TicketRegistrationMapper ticketRegistrationMapper; + private final ProductRecordMapper productRecordMapper; + + private final InvoiceRegistrationProductMapper invoiceRegistrationProductMapper; + + private final StringRedisTemplate redisTemplate; + @Value("${file.upload-dir}") private String uploadDir; @@ -93,10 +106,6 @@ public int addOrEditPurchase(PurchaseLedgerDto purchaseLedgerDto) throws IOException { SalesLedger salesLedger = salesLedgerMapper.selectById(purchaseLedgerDto.getSalesLedgerId()); - - if (salesLedger == null) { - throw new BaseException("閿�鍞彴璐︿笉瀛樺湪"); - } //褰曞叆浜� SysUser sysUser = userMapper.selectUserById(purchaseLedgerDto.getRecorderId()); @@ -105,8 +114,11 @@ // DTO杞珽ntity PurchaseLedger purchaseLedger = new PurchaseLedger(); BeanUtils.copyProperties(purchaseLedgerDto, purchaseLedger); - purchaseLedger.setTenantId(salesLedger.getTenantId()); - purchaseLedger.setSalesContractNo(salesLedger.getSalesContractNo()); + LoginUser loginUser = SecurityUtils.getLoginUser(); + if(ObjectUtils.isNotEmpty(loginUser) && null != loginUser.getTenantId()) { + purchaseLedger.setTenantId(loginUser.getTenantId()); + } + purchaseLedger.setSalesContractNo(ObjectUtils.isNotEmpty(salesLedger) ? salesLedger.getSalesContractNo() : null); purchaseLedger.setSupplierName(supplierManage.getSupplierName()); purchaseLedger.setRecorderId(purchaseLedgerDto.getRecorderId()); purchaseLedger.setRecorderName(sysUser.getNickName()); @@ -285,6 +297,23 @@ @Override public int deletePurchaseLedgerByIds(Long[] ids) { + if (ids == null || ids.length == 0) { + throw new BaseException("璇烽�変腑鑷冲皯涓�鏉℃暟鎹�"); + } + // 鎵归噺鍒犻櫎鍏宠仈鐨勯噰璐彴璐︿骇鍝� + LambdaQueryWrapper<SalesLedgerProduct> queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.in(SalesLedgerProduct::getSalesLedgerId, ids) + .eq(SalesLedgerProduct::getType, "2"); + salesLedgerProductMapper.delete(queryWrapper); + // 鎵归噺鍒犻櫎鍏宠仈鐨勯噰璐彴璐︾殑鏉ョエ鐧昏 + LambdaQueryWrapper<TicketRegistration> ticketRegistrationLambdaQueryWrapper = new LambdaQueryWrapper<>(); + ticketRegistrationLambdaQueryWrapper.in(TicketRegistration::getSalesLedgerId,ids); + ticketRegistrationMapper.delete(ticketRegistrationLambdaQueryWrapper); + // 鎵归噺鍒犻櫎鍏宠仈鐨勯噰璐彴璐︾殑鏉ョエ鐧昏璁板綍 + LambdaQueryWrapper<ProductRecord> productRecordLambdaQueryWrapper = new LambdaQueryWrapper<>(); + productRecordLambdaQueryWrapper.in(ProductRecord::getPurchaseLedgerId,ids); + productRecordMapper.delete(productRecordLambdaQueryWrapper); + // 鎵归噺鍒犻櫎閲囪喘鍙拌处 return purchaseLedgerMapper.deleteBatchIds(Arrays.asList(ids)); } @@ -353,11 +382,14 @@ .eq(SalesLedgerProduct::getType, 2); List<SalesLedgerProduct> productList = salesLedgerProductMapper.selectList(queryWrapper); productList.forEach(product -> { - product.setFutureTickets(product.getFutureTickets() != null ? product.getFutureTickets() : product.getQuantity().longValue()); + product.setFutureTickets(product.getFutureTickets() != null ? product.getFutureTickets() : product.getQuantity()); product.setFutureTicketsAmount(product.getFutureTicketsAmount() != null ? product.getFutureTicketsAmount() : product.getTaxInclusiveTotalPrice()); + product.setTicketsNum(null); + product.setTicketsAmount(null); + product.setTempFutureTickets(product.getFutureTickets()); + product.setTempFutureTicketsAmount(product.getFutureTicketsAmount()); }); resultDto.setProductData(productList); - return resultDto; } @@ -381,16 +413,57 @@ public PurchaseLedgerDto getPurchaseNoById(Long id) { PurchaseLedgerDto purchaseLedgerDto = new PurchaseLedgerDto(); PurchaseLedger purchaseLedger = purchaseLedgerMapper.selectById(id); - BeanUtils.copyProperties(purchaseLedger,purchaseLedgerDto); - TicketRegistration ticketRegistration = ticketRegistrationMapper.selectOne(new LambdaQueryWrapper<TicketRegistration>().eq(TicketRegistration::getPurchaseLedgerId, id)); - if (ticketRegistration != null) { - purchaseLedgerDto.setInvoiceNumber(ticketRegistration.getInvoiceNumber()); - purchaseLedgerDto.setInvoiceAmount(ticketRegistration.getInvoiceAmount()); - purchaseLedgerDto.setTicketRegistrationId(ticketRegistration.getId()); - } + BeanUtils.copyProperties(purchaseLedger, purchaseLedgerDto); +// TicketRegistration ticketRegistration = ticketRegistrationMapper.selectOne(new LambdaQueryWrapper<TicketRegistration>().eq(TicketRegistration::getPurchaseLedgerId, id)); +// if (ticketRegistration != null) { +// purchaseLedgerDto.setInvoiceNumber(ticketRegistration.getInvoiceNumber()); +// purchaseLedgerDto.setInvoiceAmount(ticketRegistration.getInvoiceAmount()); +// purchaseLedgerDto.setTicketRegistrationId(ticketRegistration.getId()); +// } return purchaseLedgerDto; } + @Override + public IPage<PurchaseLedger> selectPurchaseLedgerListPage(IPage ipage, PurchaseLedger purchaseLedger) { + LambdaQueryWrapper<PurchaseLedger> queryWrapper = new LambdaQueryWrapper<>(); + if (StringUtils.isNotBlank(purchaseLedger.getPurchaseContractNumber())) { + queryWrapper.like(PurchaseLedger::getPurchaseContractNumber, purchaseLedger.getPurchaseContractNumber()); + } + return purchaseLedgerMapper.selectPage(ipage, queryWrapper); + } + + @Override + public List<InvoiceRegistrationProduct> getProductBySalesNo(Long id) { + List<InvoiceRegistrationProduct> invoiceRegistrationProducts = invoiceRegistrationProductMapper.selectList(new LambdaQueryWrapper<InvoiceRegistrationProduct>() + .select(InvoiceRegistrationProduct::getId, InvoiceRegistrationProduct::getProductCategory, InvoiceRegistrationProduct::getSpecificationModel, + InvoiceRegistrationProduct::getUnit, InvoiceRegistrationProduct::getQuantity) + .eq(InvoiceRegistrationProduct::getSalesLedgerId, id)); + if (invoiceRegistrationProducts.isEmpty()) { + return new ArrayList<>(); + } + return invoiceRegistrationProducts; + } + + @Override + public String getPurchaseNo() { + // 鐢熸垚鏃ユ湡鍓嶇紑锛堜緥濡傦細CG20250405锛� + String purchaseNo = "CG" + LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd")); + + // 鏋勫缓 Redis Key锛堟寜澶╁垎闅旓級 + String redisKey = "purchase_no:" + LocalDate.now().format(DateTimeFormatter.ISO_LOCAL_DATE); + + // 鑾峰彇褰撳墠搴忓彿骞堕�掑锛堝師瀛愭搷浣滐級 + Long sequence = redisTemplate.opsForValue().increment(redisKey); + + // 璁剧疆杩囨湡鏃堕棿锛堟鏃ュけ鏁堬紝闃叉鍐椾綑鏁版嵁锛� + if (sequence == 1) { + redisTemplate.expire(redisKey, 1, TimeUnit.DAYS); + } + + // 杩斿洖瀹屾暣缂栧彿锛堝 CG202504050001锛� + return purchaseNo + String.format("%03d", sequence); + } + /** * 涓嬪垝绾垮懡鍚嶈浆椹煎嘲鍛藉悕 */ -- Gitblit v1.9.3