product-inventory-management-after.git

			@@ -1,6 +1,7 @@
			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.metadata.IPage;
			import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
			@@ -9,12 +10,10 @@
			import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.ruoyi.account.service.AccountIncomeService;
			import com.ruoyi.basic.dto.CustomerPrivatePoolDto;
			import com.ruoyi.basic.dto.StorageBlobVO;
			import com.ruoyi.basic.enums.ApplicationTypeEnum;
			import com.ruoyi.basic.enums.RecordTypeEnum;
			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.utils.FileUtil;
			@@ -27,7 +26,7 @@
			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.framework.web.domain.R;
			import com.ruoyi.other.mapper.TempFileMapper;
			import com.ruoyi.production.mapper.ProductionProductInputMapper;
			import com.ruoyi.production.mapper.ProductionProductMainMapper;
			@@ -49,6 +48,7 @@
			import lombok.extern.slf4j.Slf4j;
			import org.jetbrains.annotations.Nullable;
			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;
			@@ -82,11 +82,13 @@
			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;
			@@ -94,14 +96,29 @@
			private final InvoiceLedgerMapper invoiceLedgerMapper;
			private final InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;
			private final InvoiceRegistrationMapper invoiceRegistrationMapper;
			private final ProductModelMapper productModelMapper;
			private final ProductionProductMainMapper productionProductMainMapper;
			private final ProductionProductOutputMapper productionProductOutputMapper;
			private final ProductionProductInputMapper productionProductInputMapper;
			private final QualityInspectMapper qualityInspectMapper;
			private final RedisTemplate<String, String> redisTemplate;
			private final SysDeptMapper sysDeptMapper;
			private final ProductionProductMainService productionProductMainService;
			private final PurchaseReturnOrderProductsMapper purchaseReturnOrderProductsMapper;
			private final SysUserMapper sysUserMapper;
			private final CustomerPrivatePoolMapper customerPrivatePoolMapper;
			private final FileUtil fileUtil;

			@Autowired
			private SysDeptMapper sysDeptMapper;
			@Value("${file.upload-dir}")
			private String uploadDir;
			@Autowired
			private ProductModelMapper productModelMapper;

			@Autowired
			private ProductMapper productMapper;
			@Autowired
			private ProductionProductMainService productionProductMainService;
			@Autowired
			private PurchaseReturnOrderProductsMapper purchaseReturnOrderProductsMapper;
			;
			@Autowired
			private SysUserMapper sysUserMapper;

			@Override
			public List<SalesLedger> selectSalesLedgerList(SalesLedgerDto salesLedgerDto) {
			@@ -126,14 +143,14 @@
			List<SalesLedgerProduct> salesLedgerProducts = salesLedgerProductMapper.selectList(productWrapper);
			if (type.equals(SaleEnum.PURCHASE)) {
			// 查询退货信息
			List<Long> productIds = salesLedgerProducts.stream().map(SalesLedgerProduct::getId).collect(Collectors.toList());
			List<Long> productIds = salesLedgerProducts.stream().map(SalesLedgerProduct::getProductModelId).collect(Collectors.toList());
			List<SimpleReturnOrderGroupDto> groupListByProductIds = new ArrayList<>();
			if(CollectionUtils.isNotEmpty(productIds)){
			groupListByProductIds = purchaseReturnOrderProductsMapper.getReturnOrderGroupListByProductIds(productIds);
			}
			Map<Long, BigDecimal> returnOrderGroupDtoMap = groupListByProductIds.stream().collect(Collectors.toMap(SimpleReturnOrderGroupDto::getSalesLedgerProductId, SimpleReturnOrderGroupDto::getSumReturnQuantity));
			Map<Long, BigDecimal> returnOrderGroupDtoMap = groupListByProductIds.stream().collect(Collectors.toMap(SimpleReturnOrderGroupDto::getProductModelId, SimpleReturnOrderGroupDto::getSumReturnQuantity));
			salesLedgerProducts.forEach(item -> {
			BigDecimal returnQuality = returnOrderGroupDtoMap.getOrDefault(item.getId(), BigDecimal.ZERO);
			BigDecimal returnQuality = returnOrderGroupDtoMap.getOrDefault(item.getProductModelId(), BigDecimal.ZERO);
			item.setReturnQuality(returnQuality);
			item.setAvailableQuality(item.getQuantity().subtract(returnQuality));
			});
			@@ -185,9 +202,6 @@
			resultDto.setProductData(products);
			resultDto.setSalesLedgerFiles(salesLedgerFiles);
			}
			// 5. 查询附件
			List<StorageBlobVO> StorageBlobVOs = fileUtil.getStorageBlobVOsByRecordTypeAndRecordId(RecordTypeEnum.SALES_LEDGER, salesLedger.getId());
			resultDto.setStorageBlobVOs(StorageBlobVOs);
			return resultDto;
			}

			@@ -317,21 +331,29 @@

			@Override
			@Transactional(rollbackFor = Exception.class)
			public AjaxResult importData(MultipartFile file) {
			public R<?> 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("销售表格为空！");
			if (CollectionUtils.isEmpty(stringListMap)) return R.fail("销售表格为空！");
			// 业务层合并
			List<SalesLedgerImportDto> salesLedgerImportDtoList = stringListMap.get("销售台账数据");
			if (CollectionUtils.isEmpty(salesLedgerImportDtoList)) return AjaxResult.error("销售台账数据为空！");
			if (CollectionUtils.isEmpty(salesLedgerImportDtoList)) return R.fail("销售台账数据为空！");
			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())));
			if (CollectionUtils.isEmpty(salesLedgerProductImportDtoList)) return R.fail("销售产品数据为空！");
			// 客户数据 - 参考 listPage 查询私海客户（type = 0）
			// type = 0（私海客户）或者 type = 1（公海客户）且已被分配，并且是自己领用、自己创建或者共享给自己的客户
			Long loginUserId = loginUser.getUser().getUserId();
			List<Customer> customers = customerMapper.selectList(new QueryWrapper<Customer>()
			.in("customer_name", salesLedgerImportDtoList.stream()
			.map(SalesLedgerImportDto::getCustomerName).collect(Collectors.toList()))
			.and(wrapper -> wrapper.eq("type", 0)
			.or(wrapper2 -> wrapper2.eq("type", 1).eq("is_assigned", 1)))
			.and(wrapper -> wrapper.eq("usage_user", loginUserId)
			.or(wrapper2 -> wrapper2.eq("create_user", loginUserId)
			.or(wrapper3 -> wrapper3.exists("select 1 from customer_user cu where cu.customer_id = customer.id and cu.user_id = " + loginUserId)))));
			// // 规格型号数据
			// List<ProductModel> productModels = productModelMapper.selectList(new LambdaQueryWrapper<ProductModel>().in(ProductModel::getModel,
			// salesLedgerProductImportDtoList.stream().map(SalesLedgerImportDto::getSpecificationModel).collect(Collectors.toList())));
			@@ -352,17 +374,16 @@
			SalesLedger salesLedger = new SalesLedger();
			BeanUtils.copyProperties(salesLedgerImportDto, salesLedger);
			salesLedger.setExecutionDate(DateUtils.toLocalDate(salesLedgerImportDto.getExecutionDate()));
			salesLedger.setDeliveryDate(DateUtils.toLocalDate(salesLedgerImportDto.getDeliveryDate()));
			// 通过客户名称查询客户ID，客户合同号
			salesLedger.setCustomerId(customers.stream()
			Optional<Customer> customerOptional = 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));
			.findFirst();
			if (customerOptional.isEmpty()) {
			throw new RuntimeException("客户:" + salesLedger.getCustomerName() + "不存在！或者非私海用户");
			}
			salesLedger.setCustomerId(customerOptional.get().getId());
			salesLedger.setCustomerContractNo(customerOptional.get().getTaxpayerIdentificationNumber());
			Long aLong = sysUsers.stream()
			.filter(sysUser -> sysUser.getNickName().equals(salesLedger.getEntryPerson()))
			.findFirst()
			@@ -392,13 +413,16 @@
			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()));
			});
			// 校验产品规格是否存在
			Optional<Map<String, Object>> productModelOptional = list.stream()
			.filter(map -> Objects.equals(map.get("productName"), salesLedgerProduct.getProductCategory()) && Objects.equals(map.get("model"), salesLedgerProduct.getSpecificationModel()))
			.findFirst();
			if (productModelOptional.isEmpty()) {
			throw new RuntimeException("产品大类:" + salesLedgerProduct.getProductCategory() + ",规格型号:" + salesLedgerProduct.getSpecificationModel() + "不存在！");
			}
			Map<String, Object> productModelMap = productModelOptional.get();
			salesLedgerProduct.setProductModelId(Long.parseLong(productModelMap.get("modelId").toString()));
			salesLedgerProduct.setProductId(Long.parseLong(productModelMap.get("id").toString()));
			// salesLedgerProduct.setProductId(productList.stream()
			// .filter(product -> product.getProductName().equals(salesLedgerProduct.getProductCategory()))
			// .findFirst()
			@@ -413,17 +437,19 @@
			salesLedgerProduct.setRegisterDate(LocalDateTime.now());
			salesLedgerProduct.setApproveStatus(0);
			salesLedgerProduct.setPendingInvoiceTotal(salesLedgerProductImportDto.getTaxInclusiveTotalPrice());
			salesLedgerProduct.setIsProduction(salesLedgerProductImportDto.getIsProduction() == 1);
			salesLedgerProductMapper.insert(salesLedgerProduct);
			// 添加生产数据
			salesLedgerProductServiceImpl.addProductionData(salesLedgerProduct);
			}
			}

			return AjaxResult.success("导入成功");
			return R.ok(null, "导入成功");
			} catch (Exception e) {
			e.printStackTrace();
			return R.fail("导入失败：" + e.getMessage());
			}
			return AjaxResult.success("导入失败");
			return R.ok(null, "导入失败");
			}

			@Override
			@@ -514,7 +540,7 @@
			List<Long> productIds = products.stream()
			.map(SalesLedgerProduct::getId)
			.collect(Collectors.toList());
			//删除生产计划
			//删除生产数据
			salesLedgerProductServiceImpl.deleteProductionData(productIds);

			// 批量删除产品子表
			@@ -570,7 +596,7 @@
			@Transactional(rollbackFor = Exception.class)
			public int addOrUpdateSalesLedger(SalesLedgerDto salesLedgerDto) {
			// 1. 校验客户信息
			CustomerPrivatePoolDto customer = customerPrivatePoolMapper.selectInfo(salesLedgerDto.getCustomerId());
			Customer customer = customerMapper.selectById(salesLedgerDto.getCustomerId());
			if (customer == null) {
			throw new BaseException("客户不存在");
			}
			@@ -588,6 +614,7 @@
			salesLedgerMapper.updateById(salesLedger);
			}


			// 4. 处理子表数据
			List<SalesLedgerProduct> productList = salesLedgerDto.getProductData();
			if (productList != null && !productList.isEmpty()) {
			@@ -601,14 +628,11 @@
			);
			}

			// 5. 保存文件
			if (salesLedgerDto.getStorageBlobDTOs() != null && !salesLedgerDto.getStorageBlobDTOs().isEmpty()) {
			fileUtil.saveStorageAttachment(ApplicationTypeEnum.FILE, RecordTypeEnum.SALES_LEDGER, salesLedger.getId(), salesLedgerDto.getStorageBlobDTOs());
			}
			// 5. 保存销售台账附件
			fileUtil.saveStorageAttachment(ApplicationTypeEnum.FILE, RecordTypeEnum.SALES_LEDGER, salesLedger.getId(), salesLedgerDto.getStorageBlobDTOs());

			return 1;
			}

			// 文件迁移方法

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