wms-master.git - Gitblit

			@@ -104,10 +104,11 @@


			/**
			* @param
			* @return
			* 完成入库，更新库位明细、组托状态，并在此统一执行 9.1 入/出库结果上报云仓。
			* 与 RCS 回调形成闭环：RCS 上报任务结束后仅将任务状态置为 COMPLETE_IN（见 WcsServiceImpl.receiveExMsg），
			* 本定时任务扫描 COMPLETE_IN 并执行 complateInTask（库位、组托、9.1 上报云仓）。
			*
			* @author Ryan
			* @description 完成入库，更新库存
			* @time 2025/4/2 12:37
			*/
			@Scheduled(cron = "0/3 * * * * ?")
			@@ -122,10 +123,12 @@
			}

			/**
			* 完成出库任务，更新库位/出库单，并在此统一执行 9.1 入/出库结果上报云仓。
			* 与 RCS 回调形成闭环：RCS 上报 END 后仅将出库任务状态置为 COMPLETE_OUT（见 WcsServiceImpl.receiveExMsg），
			* 本定时任务扫描 COMPLETE_OUT 并执行 completeTask（扣库位、更新出库单、9.1 上报云仓）。
			*
			* @author Ryan
			* @date 2025/5/20
			* @description: 完成出库任务，更新库存
			* @version 1.0
			*/
			@Scheduled(cron = "0/5 * * * * ? ")
			@Transactional(rollbackFor = Exception.class)
			@@ -251,7 +254,7 @@
			@Scheduled(cron = "0/35 * * * * ? ")
			@Transactional(rollbackFor = Exception.class)
			public void pubTaskToWcs() {
			log.info("定时任务开始执行：任务下发到RCS");
			log.debug("定时任务开始执行：任务下发到RCS");
			Long loginUserId = SystemAuthUtils.getLoginUserId();
			List<Integer> list = Arrays.asList(
			TaskType.TASK_TYPE_LOC_MOVE.type
			@@ -271,7 +274,7 @@
			.in(Task::getTaskType, list)
			.in(Task::getTaskStatus, integers)
			.orderByDesc(Task::getSort));
			log.info("查询到待下发任务数量：{}", tasks.size());
			log.debug("查询到待下发任务数量：{}", tasks.size());
			if (tasks.isEmpty()) {
			log.debug("没有待下发的任务，定时任务结束");
			return;
			@@ -295,9 +298,9 @@
			// }
			// }
			/*下发普通站点任务，报错回滚，不再往下执行/
			log.info("开始下发{}个任务到RCS", tasks.size());
			log.debug("开始下发{}个任务到RCS", tasks.size());
			taskService.pubTaskToWcs(tasks);
			log.info("定时任务执行完成：任务下发到RCS");
			log.debug("定时任务执行完成：任务下发到RCS");
			}

			/**
			@@ -616,60 +619,48 @@
			}
			} else if ((task.getTaskType() >= TaskType.TASK_TYPE_OUT.type && task.getTaskType() <= TaskType.TASK_TYPE_EMPITY_OUT.type)
			\|\| task.getTaskType().equals(TaskType.TASK_TYPE_PICK_IN.type)) {
			/判断单据是否完成/
			// 只有波次类型的任务才需要查询波次关联单
			/*判断单据是否完成：波次下发、按单下发（点击下发任务）完成后均将出库单置为完结/
			Set<Long> orderIdsToDone = new HashSet<>();
			if (task.getResource() != null && task.getResource().equals(TaskResouceType.TASK_RESOUCE_WAVE_TYPE.val)) {
			Set<Long> longSet = taskItems.stream()
			.map(TaskItem::getSourceId)
			.filter(Objects::nonNull)
			.collect(Collectors.toSet());

			if (longSet.isEmpty()) {
			logger.warn("任务{}的任务明细中没有有效的sourceId，跳过波次关联单查询。任务编码：{}，任务类型：{}",
			task.getId(), task.getTaskCode(), task.getTaskType());
			} else {
			if (!longSet.isEmpty()) {
			List<WaveOrderRela> waveOrderRelas = waveOrderRelaService.list(new LambdaQueryWrapper<WaveOrderRela>()
			.in(WaveOrderRela::getWaveId, longSet));
			if (Cools.isEmpty(waveOrderRelas)) {
			logger.warn("任务{}的波次对应关联单未找到，可能是数据不一致或任务不是通过波次创建的。任务编码：{}，sourceIds：{}",
			task.getId(), task.getTaskCode(), longSet);
			} else {
			Set<Long> orderIds = waveOrderRelas.stream().map(WaveOrderRela::getOrderId).collect(Collectors.toSet());
			List<WkOrder> wkOrders = asnOrderService.listByIds(orderIds);
			if (wkOrders.isEmpty()) {
			logger.warn("任务{}的关联单据不存在。任务编码：{}，orderIds：{}",
			task.getId(), task.getTaskCode(), orderIds);
			} else {
			Config allowChang = configService.getOne(new LambdaQueryWrapper<Config>().eq(Config::getFlag, GlobalConfigCode.ALLOW_OVER_CHANGE));

			wkOrders.forEach(order -> {
			//判断是否允许超收，不允许超收添加拒收判断
			if (!Objects.isNull(allowChang)) {
			if (!Boolean.parseBoolean(allowChang.getVal())) {
			if (order.getAnfme().compareTo(order.getQty()) == 0) {
			order.setExceStatus(AsnExceStatus.OUT_STOCK_STATUS_TASK_DONE.val);
			if (!asnOrderService.updateById(order)) {
			logger.error("出库单更新状态失败。订单ID：{}，订单编码：{}", order.getId(), order.getCode());
			}
			}
			} else {
			if (order.getAnfme().compareTo(order.getQty()) <= 0) {
			order.setExceStatus(AsnExceStatus.OUT_STOCK_STATUS_TASK_DONE.val);
			if (!asnOrderService.updateById(order)) {
			logger.error("出库单更新状态失败。订单ID：{}，订单编码：{}", order.getId(), order.getCode());
			}
			}
			}
			}
			//检查单据是否完成

			});
			}
			if (!Cools.isEmpty(waveOrderRelas)) {
			orderIdsToDone.addAll(waveOrderRelas.stream().map(WaveOrderRela::getOrderId).collect(Collectors.toSet()));
			}
			}
			} else {
			logger.debug("任务{}不是波次类型任务（资源类型：{}），跳过波次关联单查询。任务编码：{}",
			task.getId(), task.getResource(), task.getTaskCode());
			} else if (task.getResource() != null && task.getResource().equals(TaskResouceType.TASK_RESOUCE_ORDER_TYPE.val)) {
			// 按单下发：任务明细 sourceId 为出库单ID
			Set<Long> ids = taskItems.stream()
			.map(TaskItem::getSourceId)
			.filter(Objects::nonNull)
			.collect(Collectors.toSet());
			orderIdsToDone.addAll(ids);
			}
			if (!orderIdsToDone.isEmpty()) {
			List<WkOrder> wkOrders = asnOrderService.listByIds(orderIdsToDone);
			if (!wkOrders.isEmpty()) {
			Config allowChang = configService.getOne(new LambdaQueryWrapper<Config>().eq(Config::getFlag, GlobalConfigCode.ALLOW_OVER_CHANGE));
			wkOrders.forEach(order -> {
			if (order.getAnfme() == null) return;
			boolean canDone = Boolean.TRUE.equals(allowChang != null && Boolean.parseBoolean(allowChang.getVal()))
			? (order.getQty() != null && order.getAnfme().compareTo(order.getQty()) <= 0)
			: (order.getQty() != null && order.getAnfme().compareTo(order.getQty()) == 0);
			if (canDone) {
			order.setExceStatus(AsnExceStatus.OUT_STOCK_STATUS_TASK_DONE.val);
			if (order.getQty() == null \|\| order.getQty().compareTo(0.0) == 0) {
			order.setQty(order.getWorkQty() != null ? order.getWorkQty() : 0.0);
			}
			if (!asnOrderService.updateById(order)) {
			logger.error("出库单更新状态失败。订单ID：{}，订单编码：{}", order.getId(), order.getCode());
			}
			}
			});
			}
			}

			//出库单上报RCS修改库位状态