product-inventory-management-after.git

			@@ -10,12 +10,12 @@
			import com.ruoyi.procurementrecord.dto.*;
			import com.ruoyi.procurementrecord.mapper.ProcurementRecordMapper;
			import com.ruoyi.procurementrecord.mapper.ProcurementRecordOutMapper;
			import com.ruoyi.procurementrecord.pojo.ProcurementRecord;
			import com.ruoyi.procurementrecord.pojo.ProcurementRecordStorage;
			import com.ruoyi.procurementrecord.pojo.ProcurementRecordOut;
			import com.ruoyi.procurementrecord.service.ProcurementRecordService;
			import com.ruoyi.quality.pojo.QualityInspect;
			import com.ruoyi.project.system.domain.SysUser;
			import com.ruoyi.project.system.mapper.SysUserMapper;
			import com.ruoyi.sales.mapper.SalesLedgerProductMapper;
			import com.ruoyi.sales.pojo.SalesLedgerProduct;
			import lombok.RequiredArgsConstructor;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.stereotype.Service;
			@@ -23,8 +23,10 @@

			import javax.servlet.http.HttpServletResponse;
			import java.math.BigDecimal;
			import java.time.LocalDate;
			import java.time.LocalDateTime;
			import java.util.List;
			import java.time.format.DateTimeFormatter;
			import java.util.*;
			import java.util.stream.Collectors;

			/**
			@@ -34,7 +36,7 @@
			@Service
			@RequiredArgsConstructor
			@Slf4j
			public class ProcurementRecordServiceImpl extends ServiceImpl<ProcurementRecordMapper, ProcurementRecord> implements ProcurementRecordService {
			public class ProcurementRecordServiceImpl extends ServiceImpl<ProcurementRecordMapper, ProcurementRecordStorage> implements ProcurementRecordService {

			private final ProcurementRecordMapper procurementRecordMapper;

			@@ -51,16 +53,16 @@
			if(CollectionUtils.isEmpty( collect)){
			return procurementDtos;
			}
			LambdaQueryWrapper<ProcurementRecord> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
			procurementRecordLambdaQueryWrapper.in(ProcurementRecord::getSalesLedgerProductId, collect);
			List<ProcurementRecord> procurementRecords = procurementRecordMapper.selectList(procurementRecordLambdaQueryWrapper);
			if(CollectionUtils.isEmpty( procurementRecords)){
			LambdaQueryWrapper<ProcurementRecordStorage> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
			procurementRecordLambdaQueryWrapper.in(ProcurementRecordStorage::getSalesLedgerProductId, collect);
			List<ProcurementRecordStorage> procurementRecordStorages = procurementRecordMapper.selectList(procurementRecordLambdaQueryWrapper);
			if(CollectionUtils.isEmpty(procurementRecordStorages)){
			return procurementDtos;
			}
			for (ProcurementDto dto : procurementDtos) {
			// 根据采购台账ID筛选对应的入库记录
			List<ProcurementRecord> collect1 = procurementRecords.stream()
			.filter(procurementRecord -> procurementRecord.getSalesLedgerProductId().equals(dto.getId()))
			List<ProcurementRecordStorage> collect1 = procurementRecordStorages.stream()
			.filter(procurementRecordStorage -> procurementRecordStorage.getSalesLedgerProductId().equals(dto.getId()))
			.collect(Collectors.toList());

			// 如果没有相关的入库记录，跳过该条数据
			@@ -71,7 +73,7 @@

			// 计算已入库数量总和，并设置待入库数量
			BigDecimal totalInboundNum = collect1.stream()
			.map(ProcurementRecord::getInboundNum)
			.map(ProcurementRecordStorage::getInboundNum)
			.reduce(BigDecimal.ZERO, BigDecimal::add);

			// 待入库数量 = 总数量 - 已入库数量
			@@ -80,33 +82,35 @@
			return procurementDtos;
			}

			public ProcurementRecord getProcurementRecordById(Integer id){
			ProcurementRecord procurementRecord = procurementRecordMapper.selectById(id);
			if(procurementRecord == null) {
			public ProcurementRecordStorage getProcurementRecordById(Integer id){
			ProcurementRecordStorage procurementRecordStorage = procurementRecordMapper.selectById(id);
			if(procurementRecordStorage == null) {
			throw new RuntimeException("未找到该采购入库记录");
			}
			return procurementRecord;
			return procurementRecordStorage;
			}

			public List<ProcurementRecord> getProcurementRecordByIds(List<Integer> id){
			List<ProcurementRecord> procurementRecord = procurementRecordMapper.selectBatchIds(id);
			if(procurementRecord == null) {
			public List<ProcurementRecordStorage> getProcurementRecordByIds(List<Integer> id){
			List<ProcurementRecordStorage> procurementRecordStorage = procurementRecordMapper.selectBatchIds(id);
			if(procurementRecordStorage == null) {
			throw new RuntimeException("未找到该采购入库记录");
			}
			return procurementRecord;
			return procurementRecordStorage;
			}

			@Override
			public int updatePro(ProcurementUpdateDto procurementDto) {
			ProcurementRecord procurementRecordById = getProcurementRecordById(procurementDto.getId());
			procurementRecordById.setInboundNum(procurementDto.getQuantityStock());
			return procurementRecordMapper.updateById(procurementRecordById);
			ProcurementRecordStorage procurementRecordStorageById = getProcurementRecordById(procurementDto.getId());
			procurementRecordStorageById.setInboundNum(procurementDto.getQuantityStock());
			procurementRecordStorageById.setUpdateUser(SecurityUtils.getLoginUser().getUserId());
			procurementRecordStorageById.setUpdateTime(LocalDateTime.now());
			return procurementRecordMapper.updateById(procurementRecordStorageById);
			}

			@Override
			public int deletePro(ProcurementUpdateDto procurementDto) {
			List<ProcurementRecord> procurementRecordById = getProcurementRecordByIds(procurementDto.getIds());
			procurementRecordMapper.deleteBatchIds(procurementRecordById.stream().map(ProcurementRecord::getId).collect(Collectors.toList()));
			List<ProcurementRecordStorage> procurementRecordStorageById = getProcurementRecordByIds(procurementDto.getIds());
			procurementRecordMapper.deleteBatchIds(procurementRecordStorageById.stream().map(ProcurementRecordStorage::getId).collect(Collectors.toList()));
			// 删除所有对应的出库记录
			LambdaQueryWrapper<ProcurementRecordOut> procurementRecordOutLambdaQueryWrapper = new LambdaQueryWrapper<>();
			procurementRecordOutLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, procurementDto.getIds());
			@@ -120,8 +124,207 @@
			@Override
			public void export(HttpServletResponse response) {
			List<ProcurementPageDto> list =procurementRecordMapper.list();
			// 计算待入库数量
			// 查询采购记录已入库数量
			List<Integer> collect = list.stream().map(ProcurementPageDto::getId).collect(Collectors.toList());
			if(CollectionUtils.isEmpty( collect)){
			ExcelUtil<ProcurementPageDto> util = new ExcelUtil<ProcurementPageDto>(ProcurementPageDto.class);
			util.exportExcel(response, list, "入库台账");
			return;
			}
			LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
			procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, collect);
			List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);
			if(CollectionUtils.isEmpty( procurementRecords)){
			ExcelUtil<ProcurementPageDto> util = new ExcelUtil<ProcurementPageDto>(ProcurementPageDto.class);
			util.exportExcel(response, list, "入库台账");
			return;
			}
			for (ProcurementPageDto dto : list) {
			// 根据采购台账ID筛选对应的出库记录
			List<ProcurementRecordOut> collect1 = procurementRecords.stream()
			.filter(ProcurementRecordOut -> ProcurementRecordOut.getProcurementRecordStorageId().equals(dto.getId()))
			.collect(Collectors.toList());

			// 如果没有相关的出库记录，跳过该条数据
			if(CollectionUtils.isEmpty(collect1)){
			dto.setInboundNum0(dto.getInboundNum());
			continue;
			}

			// 计算已出库数量总和，并设置待出库数量
			BigDecimal totalInboundNum = collect1.stream()
			.map(ProcurementRecordOut::getInboundNum)
			.reduce(BigDecimal.ZERO, BigDecimal::add);

			// 待出库数量 = 总数量 - 已出库数量
			dto.setInboundNum0(dto.getInboundNum().subtract(totalInboundNum));
			}
			ExcelUtil<ProcurementPageDto> util = new ExcelUtil<ProcurementPageDto>(ProcurementPageDto.class);
			util.exportExcel(response, list, "入库台账");
			}

			private final SysUserMapper sysUserMapper;

			@Override
			public int updateManagement(ProcurementManagementUpdateDto procurementDto) {
			LoginUser loginUser = SecurityUtils.getLoginUser();
			SysUser sysUser = sysUserMapper.selectUserById(procurementDto.getCreateUser());
			if(sysUser == null){
			throw new RuntimeException("入库人不存在");
			}
			DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
			String entryDateStr = procurementDto.getEntryDate() + " 00:00:00";
			String createTimeStr = procurementDto.getCreateTime() + " 00:00:00";
			ProcurementRecordStorage procurementRecordStorageById = getProcurementRecordById(procurementDto.getId());
			procurementRecordStorageById.setCreateBy(sysUser.getNickName());
			procurementRecordStorageById.setCreateUser(sysUser.getUserId());
			procurementRecordStorageById.setUpdateTime(LocalDateTime.parse(entryDateStr,df));
			procurementRecordStorageById.setUpdateUser(loginUser.getUserId());
			procurementRecordStorageById.setCreateTime(LocalDateTime.parse(createTimeStr,df));
			procurementRecordMapper.updateById(procurementRecordStorageById);
			return 0;
			}

			@Override
			public void exportCopy(HttpServletResponse response) {
			List<ProcurementPageDtoCopy> list =procurementRecordMapper.listCopy();
			// 计算待入库数量
			// 查询采购记录已入库数量
			List<Integer> collect = list.stream().map(ProcurementPageDtoCopy::getId).collect(Collectors.toList());
			if(CollectionUtils.isEmpty( collect)){
			ExcelUtil<ProcurementPageDtoCopy> util = new ExcelUtil<ProcurementPageDtoCopy>(ProcurementPageDtoCopy.class);
			util.exportExcel(response, list, "库存管理");
			return;
			}
			LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
			procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, collect);
			List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);
			if(CollectionUtils.isEmpty( procurementRecords)){
			ExcelUtil<ProcurementPageDtoCopy> util = new ExcelUtil<ProcurementPageDtoCopy>(ProcurementPageDtoCopy.class);
			util.exportExcel(response, list, "库存管理");
			return;
			}
			for (ProcurementPageDtoCopy dto : list) {
			// 根据采购台账ID筛选对应的出库记录
			List<ProcurementRecordOut> collect1 = procurementRecords.stream()
			.filter(ProcurementRecordOut -> ProcurementRecordOut.getProcurementRecordStorageId().equals(dto.getId()))
			.collect(Collectors.toList());

			// 如果没有相关的出库记录，跳过该条数据
			if(CollectionUtils.isEmpty(collect1)){
			dto.setInboundNum0(dto.getInboundNum());
			continue;
			}

			// 计算已出库数量总和，并设置待出库数量
			BigDecimal totalInboundNum = collect1.stream()
			.map(ProcurementRecordOut::getInboundNum)
			.reduce(BigDecimal.ZERO, BigDecimal::add);

			// 待出库数量 = 总数量 - 已出库数量
			dto.setInboundNum0(dto.getInboundNum().subtract(totalInboundNum));
			}
			ExcelUtil<ProcurementPageDtoCopy> util = new ExcelUtil<ProcurementPageDtoCopy>(ProcurementPageDtoCopy.class);
			util.exportExcel(response, list, "库存管理");
			}

			@Override
			public Map<String, Object> getReportList(Page page, ProcurementPageDto procurementDto) {
			// 构建报表数据结构
			Map<String, Object> reportData = new HashMap<>();
			// 2. 构建图表数据
			Map<String, Object> chartData = new HashMap<>();

			IPage<ProcurementPageDtoCopy> procurementPageDtoCopyIPage = procurementRecordMapper.listPageCopy(page, procurementDto);
			List<ProcurementPageDtoCopy> procurementPageDtoCopyList = procurementPageDtoCopyIPage.getRecords();
			// 计算待入库数量
			reportData.put("tableData", procurementPageDtoCopyList);
			// 查询采购记录已入库数量
			List<Integer> collect = procurementPageDtoCopyList.stream().map(ProcurementPageDtoCopy::getId).collect(Collectors.toList());
			if(CollectionUtils.isEmpty(collect)){
			return reportData;
			}
			LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
			procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, collect);
			List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);
			if(CollectionUtils.isEmpty( procurementRecords)){
			return reportData;
			}
			int totalIn =0;
			int totalOut =0;
			int currentStock =0;
			int turnoverRate =0;
			List<String> dates = new ArrayList<>();
			List<Integer> values = new ArrayList<>();
			List<String> comparisonDates = new ArrayList<>();
			List<Integer> inValues = new ArrayList<>();
			List<Integer> outValues = new ArrayList<>();
			// 定义日期格式化器，指定为yyyy-MM-dd格式
			DateTimeFormatter dateFormatter = DateTimeFormatter.ISO_LOCAL_DATE;
			for (ProcurementPageDtoCopy dto : procurementPageDtoCopyList) {
			dates.add(dto.getCreateTime().format(dateFormatter));
			comparisonDates.add(dto.getCreateTime().format(dateFormatter));

			// 根据采购台账ID筛选对应的出库记录
			List<ProcurementRecordOut> collect1 = procurementRecords.stream()
			.filter(ProcurementRecordOut -> ProcurementRecordOut.getProcurementRecordStorageId().equals(dto.getId()))
			.collect(Collectors.toList());

			// 如果没有相关的出库记录，跳过该条数据
			if(CollectionUtils.isEmpty(collect1)){
			dto.setInboundNum0(dto.getInboundNum());
			continue;
			}

			// 计算已出库数量总和，并设置待出库数量
			BigDecimal totalInboundNum = collect1.stream()
			.map(ProcurementRecordOut::getInboundNum)
			.reduce(BigDecimal.ZERO, BigDecimal::add);

			// 待出库数量 = 总数量 - 已出库数量
			dto.setInboundNum0(dto.getInboundNum().subtract(totalInboundNum));

			// 计算总入库数量
			totalIn += dto.getInboundNum().intValue();
			inValues.add(totalIn);
			// 计算总出库数量
			totalOut += totalInboundNum.intValue();
			outValues.add(totalOut);
			// 计算当前库存
			currentStock += dto.getInboundNum().intValue() - totalInboundNum.intValue();
			values.add(currentStock);
			// 计算周转率
			if(totalIn > 0){
			turnoverRate = totalOut * 100 / totalIn;
			}
			}


			// 1. 构建汇总数据
			Map<String, Object> summary = new HashMap<>();
			summary.put("totalIn", totalIn); // 总入库量，实际应从数据计算
			summary.put("totalOut", totalOut); // 总出库量，实际应从数据计算
			summary.put("currentStock", currentStock); // 当前库存量，实际应从数据计算
			summary.put("turnoverRate", turnoverRate); // 周转率，实际应从数据计算
			reportData.put("summary", summary);

			// 2. 构建图表数据
			// Map<String, Object> chartData = new HashMap<>();
			// List<String> dates = Arrays.asList("2025-09-15", "2025-09-16", "2025-09-17", "2025-09-18", "2025-09-19");
			// List<Integer> values = Arrays.asList(300, 350, 400, 380, 420);

			chartData.put("dates", dates);
			chartData.put("values", values);
			chartData.put("comparisonDates", comparisonDates); // 实际应从数据计算
			chartData.put("inValues", inValues); // 实际应从数据计算
			chartData.put("outValues", outValues); // 实际应从数据计算
			reportData.put("chartData", chartData);

			// 3. 设置表格数据
			reportData.put("tableData", procurementPageDtoCopyList);

			return reportData;
			}

			@Override
			@@ -130,17 +333,18 @@
			// 批量新增
			for (Details detail : procurementDto.getDetails()) {
			// 查询采购入库数量
			LambdaQueryWrapper<ProcurementRecord> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
			procurementRecordLambdaQueryWrapper.eq(ProcurementRecord::getSalesLedgerProductId, detail.getId());
			LambdaQueryWrapper<ProcurementRecordStorage> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
			procurementRecordLambdaQueryWrapper.eq(ProcurementRecordStorage::getSalesLedgerProductId, detail.getId());
			Long aLong = procurementRecordMapper.selectCount(procurementRecordLambdaQueryWrapper);

			ProcurementRecord.ProcurementRecordBuilder procurementRecordBuilder = ProcurementRecord.builder()
			ProcurementRecordStorage.ProcurementRecordStorageBuilder procurementRecordBuilder = ProcurementRecordStorage.builder()
			.salesLedgerProductId(detail.getId())
			.inboundBatches(aLong.equals(0L) ? "第1批次" : "第"+ (aLong + 1) + "批次")
			.inboundNum(detail.getInboundQuantity())
			.createDate(LocalDateTime.now())
			.userId(loginUser.getUserId())
			.tenantId(loginUser.getTenantId())
			.createTime(LocalDateTime.now())
			.createUser(loginUser.getUserId())
			.updateTime(LocalDateTime.now())
			.updateUser(loginUser.getUserId())
			.createBy(procurementDto.getNickName());
			this.save(procurementRecordBuilder.build());
			// 入库成功减掉采购数量
			@@ -195,4 +399,44 @@
			return procurementPageDtoIPage;
			}

			@Override
			public IPage<ProcurementPageDtoCopy> listPageCopy(Page page, ProcurementPageDto procurementDto) {
			IPage<ProcurementPageDtoCopy> procurementPageDtoCopyIPage = procurementRecordMapper.listPageCopy(page, procurementDto);
			List<ProcurementPageDtoCopy> procurementPageDtoCopyList = procurementPageDtoCopyIPage.getRecords();
			// 计算待入库数量
			// 查询采购记录已入库数量
			List<Integer> collect = procurementPageDtoCopyList.stream().map(ProcurementPageDtoCopy::getId).collect(Collectors.toList());
			if(CollectionUtils.isEmpty( collect)){
			return procurementPageDtoCopyIPage;
			}
			LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
			procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, collect);
			List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);
			if(CollectionUtils.isEmpty( procurementRecords)){
			return procurementPageDtoCopyIPage;
			}
			for (ProcurementPageDtoCopy dto : procurementPageDtoCopyList) {
			// 根据采购台账ID筛选对应的出库记录
			List<ProcurementRecordOut> collect1 = procurementRecords.stream()
			.filter(ProcurementRecordOut -> ProcurementRecordOut.getProcurementRecordStorageId().equals(dto.getId()))
			.collect(Collectors.toList());

			// 如果没有相关的出库记录，跳过该条数据
			if(CollectionUtils.isEmpty(collect1)){
			dto.setInboundNum0(dto.getInboundNum());
			continue;
			}

			// 计算已出库数量总和，并设置待出库数量
			BigDecimal totalInboundNum = collect1.stream()
			.map(ProcurementRecordOut::getInboundNum)
			.reduce(BigDecimal.ZERO, BigDecimal::add);
			// 出库数量 = 总数量 - 待出库数量
			dto.setTotalInboundNum(totalInboundNum);
			// 待出库数量 = 总数量 - 已出库数量
			dto.setInboundNum0(dto.getInboundNum().subtract(totalInboundNum));
			}
			return procurementPageDtoCopyIPage;
			}

			}