add:增加配送回库作业节点

blade-biz-common/src/main/java/org/springblade/common/constant/broadcast/FanoutConstants.java

@@ -307,6 +307,18 @@ public abstract class FanoutConstants {
 			}
 		}
 
+		/**
+		 * 配送回库
+		 *
+		 * @see org.springblade.common.model.workNode.RetentionDataByScanVO
+		 */
+		interface DeliveryAndReturnWarehouse {
+
+			String EXCHANGE = "fanout.distribution.ReturnWarehouse" + ModuleNameConstant.DEVAUTH;
+			interface QUEUE {
+			}
+		}
+
 
 		/**
 		 * 车次完成

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseNodeWorkServiceImpl.java

@@ -24,10 +24,10 @@ public class WarehouseNodeWorkServiceImpl implements IWarehouseNodeWorkService {
 	public void returnToTheWarehouse(NodeFanoutMsg<RetentionDataByScanVO> nodeFanoutMsg, BladeUser user) {
 		try {
 			if(user != null){
-				rabbitTemplate.convertAndSend(FanoutConstants.reservation.OwnReservation.EXCHANGE, null, com.alibaba.fastjson.JSONObject.toJSONString(nodeFanoutMsg));
+				rabbitTemplate.convertAndSend(FanoutConstants.distribution.DeliveryAndReturnWarehouse.EXCHANGE, null, com.alibaba.fastjson.JSONObject.toJSONString(nodeFanoutMsg));
 			}
 		} catch (AmqpException e) {
-			log.error(">>>>>>>>>>>>>>>>>>>>>>>>>> 消息推送失败~ 请联系管理员！ ", e);
+			log.error(">>>>>>>>>>>>>>>>>>>>>>>>>> 回库消息推送失败~ 请联系管理员！ ", e);
 		}
 	}
 }