wms-master.git - Gitblit

			@@ -70,7 +70,8 @@
			public void InStockToLog() {
			List<WkOrder> wkOrders = asnOrderService.list(new LambdaQueryWrapper<WkOrder>()
			.eq(WkOrder::getType, OrderType.ORDER_IN.type)
			.eq(WkOrder::getExceStatus, AsnExceStatus.ASN_EXCE_STATUS_TASK_EXCE.val));
			.eq(WkOrder::getExceStatus, AsnExceStatus.ASN_EXCE_STATUS_TASK_DONE.val)
			);
			if (wkOrders.isEmpty()) {
			return;
			}
			@@ -94,8 +95,8 @@
			public void outStockComplete() {
			List<WkOrder> wkOrders = asnOrderService.list(new LambdaQueryWrapper<WkOrder>()
			.eq(WkOrder::getType, OrderType.ORDER_OUT.type)
			.eq(WkOrder::getExceStatus, AsnExceStatus.OUT_STOCK_STATUS_TASK_WORKING.val)
			.apply("anfme = qty")
			.eq(WkOrder::getExceStatus, AsnExceStatus.OUT_STOCK_STATUS_TASK_DONE.val)

			);
			if (wkOrders.isEmpty()) {
			return;
			@@ -182,13 +183,20 @@
			});
			params.setData(reportData);

			R reported = reportMsgService.reportOrders(params);
			R reported = reportMsgService.uploadReportOrders(params);
			if (reported.get("code").equals(200)) {
			order.setNtyStatus(1);
			if (!asnOrderService.updateById(order)) {
			throw new CoolException("上报状态修改失败！！");
			}
			}
			try {
			//休眠3秒
			Thread.sleep(3000);
			} catch (InterruptedException e) {
			throw new RuntimeException(e);
			}

			});
			}

			@@ -204,8 +212,8 @@
			@Transactional(rollbackFor = Exception.class)
			public void moveOrderToLog(List<WkOrder> wkOrders, String type) {
			//上报已完成订单至ERP、MES等三方系统
			reportOrders(wkOrders);

			// reportOrders(wkOrders);
			//
			Set<Long> longSet = wkOrders.stream().map(WkOrder::getId).collect(Collectors.toSet());
			List<WkOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>()
			.in(WkOrderItem::getOrderId, longSet));