From 487b30b77565d9b12f203a1234a93b80a8c59177 Mon Sep 17 00:00:00 2001 From: chenrui <1187576398@qq.com> Date: 星期二, 20 五月 2025 13:58:00 +0800 Subject: [PATCH] 回款台账 --- src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java | 456 +++++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 443 insertions(+), 13 deletions(-) diff --git a/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java b/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java index 769cfe9..9163f8b 100644 --- a/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java +++ b/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java @@ -1,15 +1,54 @@ package com.ruoyi.sales.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.basic.mapper.CustomerMapper; +import com.ruoyi.basic.pojo.Customer; +import com.ruoyi.common.exception.base.BaseException; +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.other.mapper.TempFileMapper; +import com.ruoyi.other.pojo.TempFile; +import com.ruoyi.sales.dto.SalesLedgerDto; +import com.ruoyi.sales.mapper.CommonFileMapper; +import com.ruoyi.sales.mapper.InvoiceRegistrationProductMapper; import com.ruoyi.sales.mapper.SalesLedgerMapper; +import com.ruoyi.sales.mapper.SalesLedgerProductMapper; +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 com.ruoyi.sales.service.ISalesLedgerService; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.io.FilenameUtils; +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; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.util.ObjectUtils; -import java.util.Arrays; -import java.util.List; +import java.io.IOException; +import java.lang.reflect.Field; +import java.math.BigDecimal; +import java.nio.file.Files; +import java.nio.file.Path; +import java.nio.file.Paths; +import java.nio.file.StandardCopyOption; +import java.time.LocalDate; +import java.time.LocalDateTime; +import java.time.YearMonth; +import java.time.format.DateTimeFormatter; +import java.util.*; +import java.util.concurrent.TimeUnit; +import java.util.function.Function; +import java.util.stream.Collectors; /** * 閿�鍞彴璐ervice涓氬姟灞傚鐞� @@ -18,32 +57,423 @@ * @date 2025-05-08 */ @Service +@RequiredArgsConstructor +@Slf4j public class SalesLedgerServiceImpl extends ServiceImpl<SalesLedgerMapper, SalesLedger> implements ISalesLedgerService { + + private final SalesLedgerMapper salesLedgerMapper; + + private final CustomerMapper customerMapper; + + private final SalesLedgerProductMapper salesLedgerProductMapper; + + private final CommonFileMapper commonFileMapper; + + private final TempFileMapper tempFileMapper; + @Autowired - private SalesLedgerMapper salesLedgerMapper; + private InvoiceRegistrationProductMapper invoiceRegistrationProductMapper; + + @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 RedisTemplate<String, String> redisTemplate; @Override - public List<SalesLedger> selectSalesLedgerList(SalesLedger salesLedger) { - return salesLedgerMapper.selectList(new LambdaQueryWrapper<>()); + public List<SalesLedger> selectSalesLedgerList(SalesLedgerDto salesLedgerDto) { + LambdaQueryWrapper<SalesLedger> queryWrapper = new LambdaQueryWrapper<>(); + if (StringUtils.isNotBlank(salesLedgerDto.getCustomerName())) { + queryWrapper.eq(SalesLedger::getCustomerName, salesLedgerDto.getCustomerName()); + } + return salesLedgerMapper.selectList(queryWrapper); + } + + public SalesLedgerDto getSalesLedgerWithProducts(SalesLedgerDto salesLedgerDto) { + // 1. 鏌ヨ涓昏〃 + SalesLedger salesLedger = salesLedgerMapper.selectById(salesLedgerDto.getId()); + if (salesLedger == null) { + throw new BaseException("鍙拌处涓嶅瓨鍦�"); + } + + // 2. 鏌ヨ瀛愯〃 + LambdaQueryWrapper<SalesLedgerProduct> productWrapper = new LambdaQueryWrapper<>(); + productWrapper.eq(SalesLedgerProduct::getSalesLedgerId, salesLedger.getId()); + List<SalesLedgerProduct> products = salesLedgerProductMapper.selectList(productWrapper); + // 鏌ヨ鏈紑绁ㄩ噾棰�/鏈紑绁ㄦ暟 + if (CollectionUtils.isNotEmpty(products)) { + QueryWrapper<InvoiceRegistrationProduct> productQueryWrapper = new QueryWrapper<>(); + List<Long> productIds = products.stream().map(SalesLedgerProduct::getId).collect(Collectors.toList()); + productQueryWrapper.in("sales_ledger_product_id", productIds); + List<InvoiceRegistrationProduct> invoiceRegistrationProductList = invoiceRegistrationProductMapper.selectList(productQueryWrapper); + if(CollectionUtils.isNotEmpty(invoiceRegistrationProductList)){ + for (SalesLedgerProduct product : products) { + for (InvoiceRegistrationProduct invoiceRegistrationProduct : invoiceRegistrationProductList) { + Integer salesLedgerProductId = invoiceRegistrationProduct.getSalesLedgerProductId(); + Long id = product.getId(); + if( null != id && null != salesLedgerProductId && id == salesLedgerProductId.longValue()){ + product.setFutureTickets(Long.valueOf(invoiceRegistrationProduct.getNoInvoiceNum())); + product.setFutureTicketsAmount(invoiceRegistrationProduct.getNoInvoiceAmount()); + } + } + } + }else { + for (SalesLedgerProduct product : products) { + product.setFutureTickets(product.getQuantity().longValue()); + product.setFutureTicketsAmount(product.getTaxInclusiveTotalPrice()); + } + } + } + + // 3.鏌ヨ涓婁紶鏂囦欢 + LambdaQueryWrapper<CommonFile> salesLedgerFileWrapper = new LambdaQueryWrapper<>(); + salesLedgerFileWrapper.eq(CommonFile::getCommonId, salesLedger.getId()); + List<CommonFile> salesLedgerFiles = commonFileMapper.selectList(salesLedgerFileWrapper); + + // 4. 杞崲 DTO + SalesLedgerDto resultDto = new SalesLedgerDto(); + BeanUtils.copyProperties(salesLedger, resultDto); + if (!products.isEmpty()) { + resultDto.setHasChildren(true); + resultDto.setProductData(products); + resultDto.setSalesLedgerFiles(salesLedgerFiles); + } + return resultDto; } @Override - public SalesLedger selectSalesLedgerById(Long id) { - return salesLedgerMapper.selectById(id); + public List<Map<String, Object>> getSalesNo() { + LambdaQueryWrapper<SalesLedger> queryWrapper = Wrappers.lambdaQuery(); + queryWrapper.select(SalesLedger::getId, SalesLedger::getSalesContractNo); + + // 鑾峰彇鍘熷鏌ヨ缁撴灉 + List<Map<String, Object>> result = salesLedgerMapper.selectMaps(queryWrapper); + + // 灏嗕笅鍒掔嚎鍛藉悕杞崲涓洪┘宄板懡鍚� + return result.stream().map(map -> map.entrySet().stream() + .collect(Collectors.toMap( + entry -> underlineToCamel(entry.getKey()), + Map.Entry::getValue)) + ).collect(Collectors.toList()); } @Override + public BigDecimal getContractAmount() { + LocalDate now = LocalDate.now(); + YearMonth currentMonth = YearMonth.from(now); + + // 鍒涘缓LambdaQueryWrapper + LambdaQueryWrapper<SalesLedger> queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.ge(SalesLedger::getEntryDate, currentMonth.atDay(1).atStartOfDay()) // 澶т簬绛変簬鏈湀绗竴澶� + .lt(SalesLedger::getEntryDate, currentMonth.plusMonths(1).atDay(1).atStartOfDay()); // 灏忎簬涓嬫湀绗竴澶� + + // 鎵ц鏌ヨ骞惰绠楁�诲拰 + List<SalesLedger> salesLedgers = salesLedgerMapper.selectList(queryWrapper); + + BigDecimal totalContractAmount = salesLedgers.stream() + .map(SalesLedger::getContractAmount) + .filter(Objects::nonNull) + .reduce(BigDecimal.ZERO, BigDecimal::add); + + return totalContractAmount; + } + + @Override + public List getTopFiveList() { + + return null; + } + + /** + * 涓嬪垝绾垮懡鍚嶈浆椹煎嘲鍛藉悕 + */ + private String underlineToCamel(String param) { + if (param == null || "".equals(param.trim())) { + return ""; + } + int len = param.length(); + StringBuilder sb = new StringBuilder(len); + for (int i = 0; i < len; i++) { + char c = param.charAt(i); + if (c == '_') { + if (++i < len) { + sb.append(Character.toUpperCase(param.charAt(i))); + } + } else { + sb.append(Character.toLowerCase(c)); + } + } + return sb.toString(); + } + + @Override + @Transactional(rollbackFor = Exception.class) public int deleteSalesLedgerByIds(Long[] ids) { - return salesLedgerMapper.deleteBatchIds(Arrays.asList(ids)); + List<Long> idList = Arrays.stream(ids) + .filter(Objects::nonNull) + .collect(Collectors.toList()); + + if (CollectionUtils.isEmpty(idList)) { + return 0; + } + // 1. 鍏堝垹闄ゅ瓙琛ㄦ暟鎹� + LambdaQueryWrapper<SalesLedgerProduct> productWrapper = new LambdaQueryWrapper<>(); + productWrapper.in(SalesLedgerProduct::getSalesLedgerId, idList); + salesLedgerProductMapper.delete(productWrapper); + + // 2. 鍐嶅垹闄や富琛ㄦ暟鎹� + return salesLedgerMapper.deleteBatchIds(idList); } @Override - public int insertSalesLedger(SalesLedger salesLedger) { - return salesLedgerMapper.insert(salesLedger); + @Transactional(rollbackFor = Exception.class) + public int addOrUpdateSalesLedger(SalesLedgerDto salesLedgerDto) { + try { + // 1. 鏍¢獙瀹㈡埛淇℃伅 + Customer customer = customerMapper.selectById(salesLedgerDto.getCustomerId()); + if (customer == null) { + throw new BaseException("瀹㈡埛涓嶅瓨鍦�"); + } + + // 2. DTO杞珽ntity + SalesLedger salesLedger = convertToEntity(salesLedgerDto); + salesLedger.setCustomerName(customer.getCustomerName()); + salesLedger.setTenantId(customer.getTenantId()); + + // 3. 鏂板鎴栨洿鏂颁富琛� + if (salesLedger.getId() == null) { + String contractNo = generateSalesContractNo(); + salesLedger.setSalesContractNo(contractNo); + salesLedgerMapper.insert(salesLedger); + } else { + salesLedgerMapper.updateById(salesLedger); + } + + // 4. 澶勭悊瀛愯〃鏁版嵁 + List<SalesLedgerProduct> productList = salesLedgerDto.getProductData(); + if (productList != null && !productList.isEmpty()) { + handleSalesLedgerProducts(salesLedger.getId(), productList, salesLedgerDto.getType()); + updateMainContractAmount( + salesLedger.getId(), + productList, + SalesLedgerProduct::getTaxInclusiveTotalPrice, + salesLedgerMapper, + SalesLedger.class + ); + } + + // 5. 杩佺Щ涓存椂鏂囦欢鍒版寮忕洰褰� + if (salesLedgerDto.getTempFileIds() != null && !salesLedgerDto.getTempFileIds().isEmpty()) { + migrateTempFilesToFormal(salesLedger.getId(), salesLedgerDto.getTempFileIds()); + } + return 1; + } catch (IOException e) { + throw new BaseException("鏂囦欢杩佺Щ澶辫触: " + e.getMessage()); + } } - @Override - public int updateSalesLedger(SalesLedger salesLedger) { - return salesLedgerMapper.updateById(salesLedger); + // 鏂囦欢杩佺Щ鏂规硶 + + /** + * 灏嗕复鏃舵枃浠惰縼绉诲埌姝e紡鐩綍 + * + * @param businessId 涓氬姟ID锛堥攢鍞彴璐D锛� + * @param tempFileIds 涓存椂鏂囦欢ID鍒楄〃 + * @throws IOException 鏂囦欢鎿嶄綔寮傚父 + */ + private void migrateTempFilesToFormal(Long businessId, List<String> tempFileIds) throws IOException { + if (CollectionUtils.isEmpty(tempFileIds)) { + return; + } + + // 鏋勫缓姝e紡鐩綍璺緞锛堟寜涓氬姟绫诲瀷鍜屾棩鏈熷垎缁勶級 + String formalDir = uploadDir + LocalDate.now().format(DateTimeFormatter.ISO_LOCAL_DATE); + + Path formalDirPath = Paths.get(formalDir); + + // 纭繚姝e紡鐩綍瀛樺湪锛堥�掑綊鍒涘缓锛� + if (!Files.exists(formalDirPath)) { + Files.createDirectories(formalDirPath); + } + + for (String tempFileId : tempFileIds) { + // 鏌ヨ涓存椂鏂囦欢璁板綍 + TempFile tempFile = tempFileMapper.selectById(tempFileId); + if (tempFile == null) { + log.warn("涓存椂鏂囦欢涓嶅瓨鍦紝璺宠繃澶勭悊: {}", tempFileId); + continue; + } + + // 鏋勫缓姝e紡鏂囦欢鍚嶏紙鍖呭惈涓氬姟ID鍜屾椂闂存埑锛岄伩鍏嶅啿绐侊級 + String originalFilename = tempFile.getOriginalName(); + String fileExtension = FilenameUtils.getExtension(originalFilename); + String formalFilename = businessId + "_" + + System.currentTimeMillis() + "_" + + UUID.randomUUID().toString().substring(0, 8) + + (StringUtils.hasText(fileExtension) ? "." + fileExtension : ""); + + Path formalFilePath = formalDirPath.resolve(formalFilename); + + try { + // 鎵ц鏂囦欢杩佺Щ锛堜娇鐢ㄥ師瀛愭搷浣滅‘淇濆畨鍏ㄦ�э級 + Files.move( + Paths.get(tempFile.getTempPath()), + formalFilePath, + StandardCopyOption.REPLACE_EXISTING, + StandardCopyOption.ATOMIC_MOVE + ); + log.info("鏂囦欢杩佺Щ鎴愬姛: {} -> {}", tempFile.getTempPath(), formalFilePath); + + // 鏇存柊鏂囦欢璁板綍锛堝叧鑱斿埌涓氬姟ID锛� + CommonFile fileRecord = new CommonFile(); + fileRecord.setCommonId(businessId); + fileRecord.setName(originalFilename); + fileRecord.setUrl(formalFilePath.toString()); + fileRecord.setCreateTime(LocalDateTime.now()); + fileRecord.setType("1"); + commonFileMapper.insert(fileRecord); + + // 鍒犻櫎涓存椂鏂囦欢璁板綍 + tempFileMapper.deleteById(tempFile); + + log.info("鏂囦欢杩佺Щ鎴愬姛: {} -> {}", tempFile.getTempPath(), formalFilePath); + } catch (IOException e) { + log.error("鏂囦欢杩佺Щ澶辫触: {}", tempFile.getTempPath(), e); + // 鍙�夋嫨鍥炴粴浜嬪姟鎴栬褰曞け璐ユ枃浠� + throw new IOException("鏂囦欢杩佺Щ寮傚父", e); + } + } + } + + + private void handleSalesLedgerProducts(Long salesLedgerId, List<SalesLedgerProduct> products, Integer type) { + // 鎸塈D鍒嗙粍锛屽尯鍒嗘柊澧炲拰鏇存柊鐨勮褰� + Map<Boolean, List<SalesLedgerProduct>> partitionedProducts = products.stream() + .peek(p -> p.setSalesLedgerId(salesLedgerId)) + .collect(Collectors.partitioningBy(p -> p.getId() != null)); + + List<SalesLedgerProduct> updateList = partitionedProducts.get(true); + List<SalesLedgerProduct> insertList = partitionedProducts.get(false); + + // 鎵ц鏇存柊鎿嶄綔 + if (!updateList.isEmpty()) { + for (SalesLedgerProduct product : updateList) { + product.setType(type); + salesLedgerProductMapper.updateById(product); + } + } + // 鎵ц鎻掑叆鎿嶄綔 + if (!insertList.isEmpty()) { + for (SalesLedgerProduct salesLedgerProduct : insertList) { + salesLedgerProduct.setType(type); + salesLedgerProductMapper.insert(salesLedgerProduct); + } + } + } + + private SalesLedger convertToEntity(SalesLedgerDto dto) { + SalesLedger entity = new SalesLedger(); + BeanUtils.copyProperties(dto, entity); + return entity; + } + + @Transactional(readOnly = true) + public String generateSalesContractNo() { + LocalDate currentDate = LocalDate.now(); + String datePart = currentDate.format(DateTimeFormatter.BASIC_ISO_DATE); + String lockKey = LOCK_PREFIX + datePart; + String lockValue = Thread.currentThread().getId() + "-" + System.nanoTime(); // 鍞竴鏍囪瘑閿佹寔鏈夎�� + + try { + // 1. 灏濊瘯鑾峰彇鍒嗗竷寮忛攣锛堝惊鐜洿鍒拌秴鏃讹級 + long startWaitTime = System.currentTimeMillis(); + while (System.currentTimeMillis() - startWaitTime < LOCK_WAIT_TIMEOUT * 1000) { + // SET key value NX PX 30000锛氫粎褰撻攣涓嶅瓨鍦ㄦ椂鑾峰彇锛岃缃�30绉掕繃鏈� + Boolean locked = redisTemplate.opsForValue().setIfAbsent(lockKey, lockValue, LOCK_EXPIRE_TIME, TimeUnit.SECONDS); + if (Boolean.TRUE.equals(locked)) { + break; // 鎴愬姛鑾峰彇閿� + } + // 鐭殏浼戠湢閬垮厤蹇欑瓑寰� + try { + Thread.sleep(100); + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); + throw new RuntimeException("鑾峰彇閿佹椂琚腑鏂�", e); + } + } + + if (!redisTemplate.hasKey(lockKey)) { + throw new RuntimeException("鑾峰彇鍚堝悓缂栧彿鐢熸垚閿佸け璐ワ細瓒呮椂"); + } + + // 2. 鏌ヨ褰撳ぉ宸插瓨鍦ㄧ殑搴忓垪鍙凤紙涓庡師閫昏緫涓�鑷达級 + List<Integer> existingSequences = salesLedgerMapper.selectSequencesByDate(datePart); + int nextSequence = findFirstMissingSequence(existingSequences); + + return datePart + String.format("%02d", nextSequence); + } finally { + // 3. 閲婃斁閿侊紙浣跨敤Lua鑴氭湰淇濊瘉鍘熷瓙鎬э紝閬垮厤璇垹鍏朵粬绾跨▼鐨勯攣锛� + String luaScript = "if redis.call('GET', KEYS[1]) == ARGV[1] then return redis.call('DEL', KEYS[1]) else return 0 end"; + redisTemplate.execute( + new DefaultRedisScript<>(luaScript, Long.class), + Collections.singletonList(lockKey), + lockValue // 鍙湁鎸佹湁鐩稿悓鍊肩殑绾跨▼鎵嶈兘鍒犻櫎閿� + ); + } + } + + private int findFirstMissingSequence(List<Integer> sequences) { + if (sequences.isEmpty()) { + return 1; + } + // 鎺掑簭鍚庢煡鎵剧涓�涓己澶辩殑姝f暣鏁帮紙涓庡師閫昏緫涓�鑷达級 + sequences.sort(Integer::compareTo); + int next = 1; + for (int seq : sequences) { + if (seq == next) { + next++; + } else if (seq > next) { + break; + } + } + return next; + } + + public <T, S> void updateMainContractAmount( + Long mainId, + List<T> subList, + Function<T, BigDecimal> amountGetter, + BaseMapper<S> mainMapper, + Class<S> mainEntityClass) { + + if (mainId == null || subList == null || subList.isEmpty()) { + return; + } + + // 璁$畻瀛愯〃閲戦鎬诲拰 + BigDecimal totalAmount = subList.stream() + .map(amountGetter) + .filter(Objects::nonNull) + .reduce(BigDecimal.ZERO, BigDecimal::add); + + // 鏋勯�犱富琛ㄦ洿鏂板璞★紙鏀寔浠绘剰涓昏〃绫诲瀷锛� + try { + S entity = mainEntityClass.getDeclaredConstructor().newInstance(); + Field idField = mainEntityClass.getDeclaredField("id"); + idField.setAccessible(true); + idField.set(entity, mainId); + + // 璁剧疆 contractAmount 瀛楁锛屾敞鎰忚繖閲屽亣璁惧瓧娈靛悕涓� "contractAmount" + Field amountField = mainEntityClass.getDeclaredField("contractAmount"); + amountField.setAccessible(true); + amountField.set(entity, totalAmount); + + mainMapper.updateById(entity); + } catch (Exception e) { + throw new RuntimeException("鍔ㄦ�佹洿鏂颁富琛ㄩ噾棰濆け璐�", e); + } } } -- Gitblit v1.9.3