|
|
@ -23,7 +23,7 @@ public class WarehouseNodeWorkServiceImpl implements IWarehouseNodeWorkService { |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void returnToTheWarehouse(NodeFanoutMsg<RetentionDataByScanVO> nodeFanoutMsg, BladeUser user) { |
|
|
|
public void returnToTheWarehouse(NodeFanoutMsg<RetentionDataByScanVO> nodeFanoutMsg, BladeUser user) { |
|
|
|
try { |
|
|
|
try { |
|
|
|
if(user != null){ |
|
|
|
if(nodeFanoutMsg != null){ |
|
|
|
rabbitTemplate.convertAndSend(FanoutConstants.distribution.DeliveryAndReturnWarehouse.EXCHANGE, null, com.alibaba.fastjson.JSONObject.toJSONString(nodeFanoutMsg)); |
|
|
|
rabbitTemplate.convertAndSend(FanoutConstants.distribution.DeliveryAndReturnWarehouse.EXCHANGE, null, com.alibaba.fastjson.JSONObject.toJSONString(nodeFanoutMsg)); |
|
|
|
} |
|
|
|
} |
|
|
|
} catch (AmqpException e) { |
|
|
|
} catch (AmqpException e) { |
|
|
|