|
|
@ -44,6 +44,7 @@ public class DealWithDataHandler { |
|
|
|
// 如果手动ACK,消息会被监听消费,但是消息在队列中依旧存在,如果 未配置 acknowledge-mode 默认是会在消费完毕后自动ACK掉
|
|
|
|
// 如果手动ACK,消息会被监听消费,但是消息在队列中依旧存在,如果 未配置 acknowledge-mode 默认是会在消费完毕后自动ACK掉
|
|
|
|
|
|
|
|
|
|
|
|
OrderStatusDTO orderStatusDTO = (OrderStatusDTO) map.get("messageData"); |
|
|
|
OrderStatusDTO orderStatusDTO = (OrderStatusDTO) map.get("messageData"); |
|
|
|
|
|
|
|
log.info("############dealWithDataHandler: 处理在库订单数据到新系统 {}",orderStatusDTO); |
|
|
|
String status = orderStatusDTO.getStatus(); |
|
|
|
String status = orderStatusDTO.getStatus(); |
|
|
|
String unitNo = orderStatusDTO.getUnitNo(); |
|
|
|
String unitNo = orderStatusDTO.getUnitNo(); |
|
|
|
String operationTime = orderStatusDTO.getOperationTime(); |
|
|
|
String operationTime = orderStatusDTO.getOperationTime(); |
|
|
@ -55,7 +56,7 @@ public class DealWithDataHandler { |
|
|
|
sourceName = "汇通"; |
|
|
|
sourceName = "汇通"; |
|
|
|
} |
|
|
|
} |
|
|
|
log.info("##################dealWithDataHandler: 处理在库订单数据到新系统 来源:{} 品牌:{}",sourceName,orderStatusDTO.getBrandName()); |
|
|
|
log.info("##################dealWithDataHandler: 处理在库订单数据到新系统 来源:{} 品牌:{}",sourceName,orderStatusDTO.getBrandName()); |
|
|
|
if("汇通".equals(orderStatusDTO.getSourceName())){ |
|
|
|
if("汇通".equals(sourceName)){ |
|
|
|
factoryCommonService.extracted(status, unitNo, currentWarehouseId, operationTime, trayId); |
|
|
|
factoryCommonService.extracted(status, unitNo, currentWarehouseId, operationTime, trayId); |
|
|
|
}else{ |
|
|
|
}else{ |
|
|
|
log.warn(">>>> 不是汇通的数据 不进入汇通入库数据"); |
|
|
|
log.warn(">>>> 不是汇通的数据 不进入汇通入库数据"); |
|
|
|