From f89696928c3bae01187d96cdc42ebec6ac1f6420 Mon Sep 17 00:00:00 2001 From: zhenghaoyu Date: Sun, 15 Oct 2023 10:38:38 +0800 Subject: [PATCH] =?UTF-8?q?1.=E6=AD=A3=E5=BC=8F=E7=BD=91=E5=8F=AA=E8=8E=B7?= =?UTF-8?q?=E5=8F=96=E8=8D=86=E9=97=A8=E4=BB=93=E7=9A=84=E5=85=A5=E5=BA=93?= =?UTF-8?q?=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../comfac/controller/FactoryCommonController.java | 4 ++-- .../logpm/factory/receiver/DealWithDataHandler.java | 10 ++++++---- 2 files changed, 8 insertions(+), 6 deletions(-) diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/controller/FactoryCommonController.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/controller/FactoryCommonController.java index 33a033181..43927134f 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/controller/FactoryCommonController.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/controller/FactoryCommonController.java @@ -96,8 +96,8 @@ public class FactoryCommonController { map.put("flagType", "OrderStatusLog"); //将消息携带绑定键值 rabbitTemplate.convertAndSend(RabbitConstant.ORDER_STATUS_EXCHANGE, RabbitConstant.ORDER_STATUS_ROUTING, map); -// map.put("type", "DealWith"); -// rabbitTemplate.convertAndSend(RabbitConstant.DEAL_WITH_EXCHANGE, RabbitConstant.DEAL_WITH_ROUTING, map); + map.put("type", "DealWith"); + rabbitTemplate.convertAndSend(RabbitConstant.DEAL_WITH_EXCHANGE, RabbitConstant.DEAL_WITH_ROUTING, map); // R r = factoryDataService.handleStatusData(orderStatusDTO); diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/DealWithDataHandler.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/DealWithDataHandler.java index d1f9b4289..fe4711287 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/DealWithDataHandler.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/DealWithDataHandler.java @@ -62,10 +62,12 @@ public class DealWithDataHandler { // channel.basicAck(deliveryTag,false); } else { //真正的处理需要的数据 - try { - panFactoryDataService.handleDataToPlatform(unitNo, operationTime); - } catch (Exception e) { - e.printStackTrace(); + if("38".equals(currentWarehouseId)){ + try { + panFactoryDataService.handleDataToPlatform(unitNo, operationTime); + } catch (Exception e) { + e.printStackTrace(); + } } } }