Merge remote-tracking branch 'origin/dev' into dev

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

@@ -183,9 +183,6 @@ public interface RabbitConstant {
 
 	/****************库内入库推送商家数据start *************************/
 
-	String IN_WAREHOUSE_TO_BUSINESS_DATA_QUEUE = "in_warehouse_to_business_data_queue" + ModuleNameConstant.DEVAUTH;
-	String IN_WAREHOUSE_TO_BUSINESS_DATA_EXCHANGE = "in_warehouse_to_business_data_exchange" + ModuleNameConstant.DEVAUTH;
-	String IN_WAREHOUSE_TO_BUSINESS_DATA_ROUTING = "in_warehouse_to_business_data_routing" + ModuleNameConstant.DEVAUTH;
 
 
 	/****************库内入库推送商家数据end *************************/

blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/entity/DistributionStockArticleEntity.java

@@ -475,6 +475,8 @@ public class DistributionStockArticleEntity extends TenantEntity {
 		String consigneePerson = distributionStockArticleEntity.getConsigneePerson();
 		String consigneeMobile = distributionStockArticleEntity.getConsigneeMobile();
 		String consigneeAddress = distributionStockArticleEntity.getConsigneeAddress();
+		String consigneeUnit = distributionStockArticleEntity.getConsigneeUnit();
+		String mallName = distributionStockArticleEntity.getMallName();
 
 		StringBuilder stringBuilder = new StringBuilder();
 		boolean nameFlag = ObjectUtil.equals(this.customerName, customerName);
@@ -501,6 +503,14 @@ public class DistributionStockArticleEntity extends TenantEntity {
 		if(!consigneeAddressFlag){
 			stringBuilder.append("运单收货地址：["+this.consigneeAddress+"]修改为["+consigneeAddress+"]；");
 		}
+		boolean consigneeUnitFlag = ObjectUtil.equals(this.consigneeUnit, consigneeUnit);
+		if(!consigneeUnitFlag){
+			stringBuilder.append("运单收货单位：["+this.consigneeUnit+"]修改为["+consigneeUnit+"]；");
+		}
+		boolean mallNameFlag = ObjectUtil.equals(this.mallName, mallName);
+		if(!mallNameFlag){
+			stringBuilder.append("运单收货单位：["+this.mallName+"]修改为["+mallName+"]；");
+		}
 
 		return stringBuilder.toString();
 	}

blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataClientMapper.xml

@@ -169,7 +169,7 @@
         DESC
     </select>
     <select id="getFinallyClientCode" resultType="java.lang.String">
-        SELECT client_code FROM `logpm_basicdata_client` WHERE is_deleted = 0 AND client_code LIKE 'HT%' AND LENGTH(client_code) = 9 ORDER BY client_code DESC
+        SELECT client_code FROM `logpm_basicdata_client` WHERE is_deleted = 0 AND client_code LIKE 'HT00%' AND LENGTH(client_code) = 9 ORDER BY client_code DESC
     </select>
 
 </mapper>

blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataClientServiceImpl.java

@@ -196,10 +196,12 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
 			if (ObjectUtils.isNotNull(basicdataClient1)) {
 				throw new ServiceException("客户编码或客户名称已存在");
 			}
-
 			//添加
-			this.save(basicdataClient);
-//			//绑定客户账号和客户关系
+			boolean save = this.save(basicdataClient);
+			if (save){
+				//进行redis的设置
+				redis.set(RedisKeyConstant.FINAL_CLIENT_CODE + AuthUtil.getTenantId(), basicdataClient.getClientCode());
+			}
 
 			//添加联系人
 			BasicdataStoreContactEntity basicdataStoreContactEntity = new BasicdataStoreContactEntity();

blade-service/logpm-business/src/main/java/com/logpm/business/config/RabbitMqConfiguration.java

@@ -173,23 +173,6 @@ public class RabbitMqConfiguration {
 
 
 
-
-
-	@Bean
-	public Queue businessInConversionQueue() {
-		return new Queue(RabbitConstant.BUSINESS_IN_CONVERSION_DATA_QUEUE, true);
-	}
-	@Bean
-	public CustomExchange businessInConversionExchange() {
-		Map<String, Object> args = Maps.newHashMap();
-		args.put("x-delayed-type", "direct");
-		return new CustomExchange(RabbitConstant.BUSINESS_IN_CONVERSION_DATA_EXCHANGE, "x-delayed-message", true, false, args);
-	}
-	@Bean
-	public Binding businessInConversionBinding(Queue businessInConversionQueue, CustomExchange businessInConversionExchange) {
-		return BindingBuilder.bind(businessInConversionQueue).to(businessInConversionExchange).with(RabbitConstant.BUSINESS_IN_CONVERSION_DATA_ROUTING).noargs();
-	}
-
 	@Bean
 	public Queue selfPickupScanQueue() {
 		return new Queue(RabbitConstant.SELF_PICKUP_SCAN_QUEUE, true);

blade-service/logpm-business/src/main/java/com/logpm/business/receiver/BusinessInOrderDataQueueHandler.java

@@ -1,5 +1,7 @@
 package com.logpm.business.receiver;
 
+import com.alibaba.fastjson.JSONObject;
+import com.logpm.business.service.IBusinessPreOrderService;
 import com.rabbitmq.client.Channel;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -12,7 +14,7 @@ import org.springframework.stereotype.Component;
 import java.util.Map;
 
 /**
- * 商家完结订单
+ * 送货师傅签收完结商家端数据
  */
 @Slf4j
 @RabbitListener(queues = RabbitConstant.BUSINESS_IN_CONVERSION_DATA_QUEUE)
@@ -20,11 +22,46 @@ import java.util.Map;
 @AllArgsConstructor
 public class BusinessInOrderDataQueueHandler {
 
+	private final IBusinessPreOrderService businessPreOrderService;
+
 	@RabbitHandler
 	public void businessInOrderDataHandler(Map map, Message message, Channel channel) {
+		// 获取
+		JSONObject o = (JSONObject) map.get("messageData");
 
+		String orderPackageCode = o.getString("orderPackageCode");
+		String reservationCode = o.getString("reservationCode");
+		String distrCarNumber = o.getString("distrCarNumber");
+		String vehicleName = o.getString("vehicleName");
+		String driverName = o.getString("driverName");
+		String userName = o.getString("userName");
+		Long warehouseId = o.getLong("warehouseId");
+		String tenantId = o.getString("tenantId");
 
+		//验证参数是否为null或者空串
+		if (orderPackageCode == null || orderPackageCode.equals("")) {
+			log.error("orderPackageCode is null");
+			return;
+		}
+		if (reservationCode == null || reservationCode.equals("")) {
+			log.error("reservationCode is null");
+			return;
+		}
+		if (distrCarNumber == null || distrCarNumber.equals("")) {
+			log.error("distrCarNumber is null");
+			return;
+		}
+		if (vehicleName == null || vehicleName.equals("")) {
+			log.error("vehicleName is null");
+			return;
+		}
+		if (driverName == null || driverName.equals("")) {
+			log.error("driverName is null");
+			return;
+		}
 
+		// 如果师傅签收 以师傅签收的车次为准
+		businessPreOrderService.scanOrderPackageCodeByMaster(orderPackageCode, reservationCode, distrCarNumber, vehicleName, driverName, userName, warehouseId, tenantId);
 
 
 	}

blade-service/logpm-business/src/main/java/com/logpm/business/receiver/InWarehourseToBusinessHandler.java

@@ -1,53 +0,0 @@
-package com.logpm.business.receiver;
-
-import com.alibaba.fastjson.JSONObject;
-import com.logpm.business.service.IBusinessPreOrderService;
-import com.rabbitmq.client.Channel;
-import lombok.AllArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springblade.common.constant.RabbitConstant;
-import org.springframework.amqp.rabbit.annotation.RabbitHandler;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.messaging.Message;
-import org.springframework.stereotype.Component;
-
-import java.util.Map;
-
-/**
- * 码半
- * 入库扫描
- * 触发商家的入库数据
- */
-
-@Slf4j
-@AllArgsConstructor
-@Component
-@RabbitListener(queues = RabbitConstant.IN_WAREHOUSE_TO_BUSINESS_DATA_QUEUE)
-public class InWarehourseToBusinessHandler {
-
-	private final IBusinessPreOrderService businessPreOrderService;
-	@RabbitHandler
-	public void inWarehourseToBusinessDataHandler(Map map, Message message, Channel channel) {
-
-		extracted(map);
-
-
-	}
-
-	private void extracted(Map map) {
-		log.info("入库扫描-触发商家的入库数据-入参：{}", map);
-
-		JSONObject o = (JSONObject) map.get("messageData");
-
-		String orderPackageCode = o.getString("orderPackageCode");
-		String carNum = o.getString("carNum");
-		if(carNum==null){
-			carNum="";
-		}
-
-		Integer i = businessPreOrderService.inOrderByOrderPackageCode(orderPackageCode, carNum);
-		log.info(">>>>>>>>>>>>>>>>>> 入库操作 执行 {}",i);
-
-	}
-
-}

blade-service/logpm-business/src/main/java/com/logpm/business/service/IBusinessPreOrderService.java

@@ -77,4 +77,29 @@ public interface IBusinessPreOrderService extends BaseService<BusinessPreOrderEn
 	 * @return
 	 */
 	R incomingPackage(InComingDTO inComingDTO);
+
+
+	/**
+	 * 师傅的签收扫描作业
+	 *
+	 * @param reservationCode 预约单
+	 * @param orderPackageCode  包条码
+	 * @param distrCarNumber 配送车次号
+	 * @param driverName 司机名称
+	 * @param vehicleName 车牌号码
+	 * @param warehouseId  当前作业仓库ID
+	 * @param tenantId  当前作业的租户
+	 * @param userName 作业用户
+	 * @return
+	 */
+	R scanOrderPackageCodeByMaster(String orderPackageCode,
+								   String reservationCode,
+								   String distrCarNumber,
+								   String vehicleName,
+								   String driverName,
+								   String userName,
+								   Long warehouseId,
+								   String tenantId
+	);
+
 }

blade-service/logpm-business/src/main/java/com/logpm/business/service/impl/BusinessPreOrderServiceImpl.java

@@ -15,6 +15,8 @@ import com.logpm.business.entity.BusinessPreOrderEntity;
 import com.logpm.business.mapper.BusinessPreOrderMapper;
 import com.logpm.business.service.IBusinessPreOrderService;
 import com.logpm.business.vo.*;
+import com.logpm.distribution.entity.DistributionParcelListEntity;
+import com.logpm.distribution.feign.IDistributionParcelListClient;
 import com.logpm.trunkline.dto.InComingDTO;
 import com.logpm.trunkline.entity.TrunklineAdvanceDetailEntity;
 import com.logpm.trunkline.feign.IInComingClient;
@@ -34,6 +36,7 @@ import org.springblade.core.tool.utils.StringUtil;
 import org.springframework.stereotype.Service;
 
 import java.util.*;
+import java.util.concurrent.atomic.AtomicReference;
 import java.util.stream.Collectors;
 
 @Service
@@ -45,6 +48,7 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 	private final IInComingClient inComingClient;
 	private final ITrunklineAdvanceDetailClient trunklineAdvanceDetailClient;
 	private final BladeRedis bladeRedis;
+	private final IDistributionParcelListClient distributionParcelListClient;
 
 
 
@@ -446,12 +450,6 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 
 
 
-
-
-
-
-
-
 		// 调用feign 进行托盘半固定入库
 		R r = inComingClient.incomingPackageByTaryCode(inComingDTO);
 
@@ -464,6 +462,61 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 
 
 
-		return null;
+		return r;
+	}
+
+
+	@Override
+	public R scanOrderPackageCodeByMaster(String orderPackageCode,
+										  String reservationCode,
+										  String  distrCarNumber,
+										  String vehicleName,
+										  String driverName,
+										  String userName,
+										  Long warehouseId,
+										  String tenantId) {
+
+		// 判断当前的包条码是否和当前作业的车次相同
+		LambdaQueryWrapper<BusinessPreOrderEntity> queryWrapper1 = new LambdaQueryWrapper<>();
+		queryWrapper1.eq(BusinessPreOrderEntity::getOrderPackageCode, orderPackageCode);
+		queryWrapper1.eq(BusinessPreOrderEntity::getIsDeleted, 0);
+		List<BusinessPreOrderEntity> list1 = baseMapper.selectList(queryWrapper1);
+		BusinessPreOrderEntity data =null;
+		if (list1.isEmpty()) {
+			// 新增改车次的预入库信息
+			DistributionParcelListEntity byPacketBarCodeAndWarehouseId = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(orderPackageCode, warehouseId);
+			data = BeanUtil.copy(byPacketBarCodeAndWarehouseId, BusinessPreOrderEntity.class);
+			data.setDriverName(driverName);
+			data.setVehicleName(vehicleName);
+			data.setDistrCarNumber(distrCarNumber);
+			data.setFromTenantId(tenantId);
+			data.setOperationStatus(0);
+			data.setInWarehouse(1);
+			data.setId(null);
+			data.setTenantId(null);
+			data.setReservationCode(reservationCode);
+			baseMapper.insert(data);
+		} else {
+			// 判断当前的包条码是否和当前作业的预约单号相同
+			for (int i = 0; i < list1.size(); i++) {
+				if(list1.get(i).getDistrCarNumber().equals(distrCarNumber)){
+					data=list1.get(i);
+					data.setInWarehouse(1);
+				}
+			}
+			if(data==null){
+				// 如果没有找到 则标识当前的车次和作业车次不一致
+				data=list1.get(0);
+				data.setDistrCarNumber(distrCarNumber);
+			}
+            baseMapper.updateById(data);
+
+        }
+
+		BusinessSanDTO businessSanDTO = new BusinessSanDTO();
+		businessSanDTO.setOrderPackageCode(data.getOrderPackageCode());
+		R r = inOrderWarehourse(businessSanDTO);
+
+		return r;
 	}
 }

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionStockArticleController.java

@@ -391,10 +391,13 @@ public class DistributionStockArticleController extends BladeController {
 				newStockArticle.setConsigneePerson(consigneePerson);
 				newStockArticle.setConsigneeMobile(stockArticleEntity.getConsigneeMobile());
 				newStockArticle.setConsigneeAddress(stockArticleEntity.getConsigneeAddress());
-			}else{
+			}else if (StringUtil.isNotBlank(customerName)){
 				newStockArticle.setCustomerName(customerName);
 				newStockArticle.setCustomerTelephone(stockArticleEntity.getCustomerTelephone());
 				newStockArticle.setCustomerAddress(stockArticleEntity.getCustomerAddress());
+			}else {
+				newStockArticle.setMallName(customerName);
+				newStockArticle.setConsigneeUnit(customerName);
 			}
 			String content = oldStockArticle.compareCustomerInfo(newStockArticle);
 			if(StringUtil.isNotBlank(content)){

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.xml

@@ -1584,7 +1584,7 @@
         ldpl.quantity AS quantity,
         ldpl.train_number AS tranNumber,
         ldpl.waybill_number AS waybillNumber,
-        ldbl.create_time AS nodeTime,
+        ldbp.create_time AS nodeTime,
         ldbl.create_user AS nodeControlsUserId,
         '自提配送' AS nodeName,
         lwt.pallet_name,
@@ -1637,7 +1637,7 @@
         ldpl.quantity AS quantity,
         ldpl.train_number AS tranNumber,
         ldpl.waybill_number AS waybillNumber,
-        ldbl.update_time AS nodeTime,
+        ldbp.update_time AS nodeTime,
         ldbl.update_user AS nodeControlsUserId,
         '自提取消' AS nodeName,
         lwt.pallet_name,

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java

@@ -778,51 +778,55 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 				//查找出该包件信息
 				DistributionParcelListEntity parcelListEntity = distributionParcelListService.getOne(Wrappers.<DistributionParcelListEntity>query().lambda().eq(DistributionParcelListEntity::getOrderPackageCode, distrilbutionloadingscanDTO.getBarcode()).eq(DistributionParcelListEntity::getWarehouseId, myCurrentWarehouse.getId()));
 				List<DistributionReservationEntity> reservationEntityList = distributionDeliveryListMapper.selectReservationByDeliveryListId(distrilbutionloadingscanDTO.getDeliveryId());
-				boolean shangpeiFlag = reservationEntityList.stream().allMatch(r -> r.getDeliveryType().equals(DistributionTypeConstant.shipie.getValue()));
-				if (Func.isEmpty(parcelListEntity)) {
-					return Resp.scanFail("无包件信息", "无包件信息");
-				}
-				DistributionStockArticleEntity stockArticleEntity = distributionStockArticleMapper.selectById(parcelListEntity.getStockArticleId());
-				if (shangpeiFlag) {
-					List<DistributionReservationEntity> reservationEntities = reservationEntityList.stream().filter(r -> Func.isNotEmpty(r.getConsignee()) && r.getConsignee().equals(stockArticleEntity.getCustomerName()) && r.getDeliveryAddress().equals(stockArticleEntity.getCustomerAddress()) && r.getDeliveryPhone().equals(stockArticleEntity.getCustomerTelephone()) && r.getMallName().equals(stockArticleEntity.getMallName()) && r.getId().equals(distrilbutionloadingscanDTO.getReservationId())).collect(Collectors.toList());
-					//查看是否存在满足条件的预约单
-					//存在多个，操作人指定具体客户即可
-					if (!reservationEntities.isEmpty()) {
-						if (Func.isEmpty(distrilbutionloadingscanDTO.getReservationId())) {
-							log.info("异常装车未指定客户");
-							return Resp.scanFail("请指定客户进行异常装车", "请指定客户进行异常装车");
-						}
-						return R.fail(5000, "异常装车");
-//						return Resp.scanFail("装车失败","程序出错，请联系彪桑");
-					} else {
-						if (parcelListEntity.getConditions() == 2) {
-							return Resp.scanFail("此包件不是订制品", "此包件不是订制品");
-
-						} else {
-							return Resp.scanFail("窜货", "窜货");
-						}
+				if (!reservationEntityList.isEmpty()){
+					boolean shangpeiFlag = reservationEntityList.stream().allMatch(r -> r.getDeliveryType().equals(DistributionTypeConstant.shipie.getValue()));
+					if (Func.isEmpty(parcelListEntity)) {
+						return Resp.scanFail("无包件信息", "无包件信息");
 					}
-				} else {
-
-					shangpeiFlag = reservationEntityList.stream().allMatch(r -> r.getDeliveryType().equals(DistributionTypeConstant.shangpei.getValue()));
+					DistributionStockArticleEntity stockArticleEntity = distributionStockArticleMapper.selectById(parcelListEntity.getStockArticleId());
 					if (shangpeiFlag) {
-						List<DistributionReservationEntity> reservationEntities = reservationEntityList.stream().filter(r -> r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) && r.getMallName().equals(stockArticleEntity.getMallName()) && r.getId().equals(distrilbutionloadingscanDTO.getReservationId())).collect(Collectors.toList());
-						//查询是否满足商配异常装车
-						boolean flag = reservationEntities.stream().anyMatch(r -> r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) && r.getMallName().equals(stockArticleEntity.getMallName()));
-						if (flag){
+						List<DistributionReservationEntity> reservationEntities = reservationEntityList.stream().filter(r -> Func.isNotEmpty(r.getConsignee()) && r.getConsignee().equals(stockArticleEntity.getCustomerName()) && r.getDeliveryAddress().equals(stockArticleEntity.getCustomerAddress()) && r.getDeliveryPhone().equals(stockArticleEntity.getCustomerTelephone()) && r.getMallName().equals(stockArticleEntity.getMallName()) && r.getId().equals(distrilbutionloadingscanDTO.getReservationId())).collect(Collectors.toList());
+						//查看是否存在满足条件的预约单
+						reservationEntities = reservationEntities.stream().filter(r -> r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) && r.getMallName().equals(stockArticleEntity.getMallName())).collect(Collectors.toList());
+
+						//存在多个，操作人指定具体客户即可
+						if (!reservationEntities.isEmpty() && reservationEntities.size() == 1) {
+							if (Func.isEmpty(distrilbutionloadingscanDTO.getReservationId())) {
+								log.info("异常装车未指定客户");
+								return Resp.scanFail("请指定客户进行异常装车", "请指定客户进行异常装车");
+							}
 							return R.fail(5000, "异常装车");
+//						return Resp.scanFail("装车失败","程序出错，请联系彪桑");
+						} else {
+							if (parcelListEntity.getConditions() == 2) {
+								return Resp.scanFail("此包件不是订制品", "此包件不是订制品");
 
-						}else {
-							if (Func.isEmpty(distrilbutionloadingscanDTO.getReservationId())){
-								return Resp.scanFail("请指定客户进行异常装车", "请指定客户进行异常装车");
-							}else {
+							} else {
 								return Resp.scanFail("窜货", "窜货");
 							}
 						}
 					} else {
-						log.error("配送计划预约类型错误:{}", reservationEntityList);
+						shangpeiFlag = reservationEntityList.stream().allMatch(r -> r.getDeliveryType().equals(DistributionTypeConstant.shangpei.getValue()));
+						if (shangpeiFlag) {
+							List<DistributionReservationEntity> reservationEntities = reservationEntityList.stream().filter(r -> r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) && r.getMallName().equals(stockArticleEntity.getMallName()) && r.getId().equals(distrilbutionloadingscanDTO.getReservationId())).collect(Collectors.toList());
+							//查询是否满足商配异常装车
+							boolean flag = reservationEntities.stream().anyMatch(r -> r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) && r.getMallName().equals(stockArticleEntity.getMallName()));
+							if (flag){
+								return R.fail(5000, "异常装车");
+
+							}else {
+								if (Func.isEmpty(distrilbutionloadingscanDTO.getReservationId())){
+									return Resp.scanFail("请指定客户进行异常装车", "请指定客户进行异常装车");
+								}else {
+									return Resp.scanFail("窜货", "窜货");
+								}
+							}
+						} else {
+							log.error("配送计划预约类型错误:{}", reservationEntityList);
+						}
 					}
 				}
+
 				log.info("异常装车判定成功>>>>>>packageCode:{},reservationId:{}", distrilbutionloadingscanDTO.getBarcode(), distrilbutionloadingscanDTO.getReservationId());
 			}
 		} else if (distrilbutionloadingscanDTO.getType() == 2) {

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/config/RabbitMqConfiguration.java

@@ -119,20 +119,7 @@ public class RabbitMqConfiguration {
 		return BindingBuilder.bind(openWaybillToBusinessQueue).to(openWaybillToBusinessExchange).with(RabbitConstant.OPEN_WAYBILL_TO_BUSINESS_DATA_ROUTING).noargs();
 	}
 
-	@Bean
-	public Queue inWarehouseToBusinessQueue() {
-		return new Queue(RabbitConstant.IN_WAREHOUSE_TO_BUSINESS_DATA_QUEUE, true);
-	}
-	@Bean
-	public CustomExchange inWarehouseToBusinessExchange() {
-		Map<String, Object> args = Maps.newHashMap();
-		args.put("x-delayed-type", "direct");
-		return new CustomExchange(RabbitConstant.IN_WAREHOUSE_TO_BUSINESS_DATA_EXCHANGE, "x-delayed-message", true, false, args);
-	}
-	@Bean
-	public Binding inWarehouseToBusinessBinding(Queue inWarehouseToBusinessQueue, CustomExchange inWarehouseToBusinessExchange) {
-		return BindingBuilder.bind(inWarehouseToBusinessQueue).to(inWarehouseToBusinessExchange).with(RabbitConstant.IN_WAREHOUSE_TO_BUSINESS_DATA_ROUTING).noargs();
-	}
+