Browse Source

1.正式网只获取荆门仓的入库数据

newStockUp
zhenghaoyu 1 year ago
parent
commit
f89696928c
  1. 4
      blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/controller/FactoryCommonController.java
  2. 2
      blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/DealWithDataHandler.java

4
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);

2
blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/DealWithDataHandler.java

@ -62,6 +62,7 @@ public class DealWithDataHandler {
// channel.basicAck(deliveryTag,false);
} else {
//真正的处理需要的数据
if("38".equals(currentWarehouseId)){
try {
panFactoryDataService.handleDataToPlatform(unitNo, operationTime);
} catch (Exception e) {
@ -69,6 +70,7 @@ public class DealWithDataHandler {
}
}
}
}
} else {
log.info("##############dealWithDataHandler: 不用处理的状态 status={}", status);
}

Loading…
Cancel
Save