Merge branch 'pre-production'

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

@@ -0,0 +1,44 @@
+package org.springblade.common.constant.basiccode;
+
+import lombok.Data;
+
+/**
+ * 租户编码姐
+ * 类型码表
+ */
+public enum BasicCodeShowConstant {
+
+	/**
+	 * 二维码
+	 */
+	QR_CODE("qr_code",1),
+
+	/**
+	 * 条形码
+	 */
+	BAR_CODE("bar_code",2);
+
+
+	/**
+	 * 状态
+	 */
+	private String name;
+
+	/**
+	 * 值
+	 */
+	private Integer value;
+
+	BasicCodeShowConstant(String name, Integer value) {
+		this.name = name;
+		this.value = value;
+	}
+
+	public String getName() {
+		return name;
+	}
+
+	public Integer getValue() {
+		return value;
+	}
+}

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

@@ -0,0 +1,68 @@
+package org.springblade.common.constant.basiccode;
+
+/**
+ * 租户编码姐
+ * 类型码表
+ */
+public enum BasicCodeTypeConstant {
+
+
+	waybill_code("运单码","1"),
+	ORDER_CODE("订单码","2"),
+	ORDER_PACKAGE_CODE("包件码","3"),
+//	仓库码
+	WAREHOUSE_CODE("仓库码","4"),
+	// 货区码
+	AREA_CODE("货区码","5"),
+	// 货架码
+	SHELF_CODE("货架码","6"),
+	// 货位码
+	POSITION_CODE("货位码","7"),
+	// 托盘码
+	TRAY_CODE("托盘码","8"),
+	// 客户编码
+	CLIENT_CODE("客户编码","9"),
+	// 提货单 配载计划 三方中转 直发商家签收单
+	// 提货单码
+	PICKUP_CODE("提货单码","10"),
+	// 配载计划码
+	ALLOCATION_CODE("配载计划码","11"),
+	// 三方中转码
+	THIRD_TRANSFER_CODE("三方中转码","12"),
+	// 直发商家签收单码
+	DIRECT_SIGN_CODE("直发商家签收单码","13"),
+
+
+	//配送计划 自提单 预约单 备货码
+	DELIVERY_PLAN_CODE("配送计划码","20"),
+	// 自提单码
+	PICKUP_ORDER_CODE("自提单码","21"),
+	// 预约单码
+	APPOINTMENT_CODE("预约单码","22"),
+	// 备货码
+	STOCK_CODE("备货码","23");
+
+
+	/**
+	 * 状态
+	 */
+	private String name;
+
+	/**
+	 * 值
+	 */
+	private String value;
+
+	BasicCodeTypeConstant(String name, String value) {
+		this.name = name;
+		this.value = value;
+	}
+
+	public String getName() {
+		return name;
+	}
+
+	public String getValue() {
+		return value;
+	}
+}

blade-service-api/logpm-basic-api/src/main/java/com/logpm/basic/entity/BasicTenantCodeEntity.java

@@ -39,13 +39,7 @@ import java.io.Serializable;
 public class BasicTenantCodeEntity  extends TenantEntity implements Serializable{
 
 	private static final long serialVersionUID = 1L;
-//	/**
-//	 * 主键
-//	 */
-//	@JsonSerialize(using = ToStringSerializer.class)
-//	@ApiModelProperty(value = "主键")
-//	@TableId(value = "id", type = IdType.ASSIGN_ID)
-//	private Long id;
+
 
 	/**
 	 * 编码类型
@@ -53,7 +47,7 @@ public class BasicTenantCodeEntity  extends TenantEntity implements Serializable
 	@JsonSerialize(using = ToStringSerializer.class)
 	@ApiModelProperty(value = "编码类型")
 	@TableField(value = "code_type")
-	private Integer codeType;
+	private String codeType;
 
 	/**
 	 * 编码展示类型
@@ -63,7 +57,6 @@ public class BasicTenantCodeEntity  extends TenantEntity implements Serializable
 	@TableField(value = "show_type")
 	private Integer showType;
 
-//	private Integer isDeleted;
 
 	/***
 	 * 编码

blade-service-api/logpm-basic-api/src/main/java/com/logpm/basic/feign/IBasicTenantCodeClient.java

@@ -64,5 +64,9 @@ public interface IBasicTenantCodeClient {
 	 */
 	@GetMapping(TOP+"/shelfCode")
 	String shelfCode(@RequestParam String tenantId,@RequestParam String codeType);
+	@GetMapping(TOP+"/findBasicTenantCodeByCodeAndShowType")
+	BasicTenantCodeEntity findBasicTenantCodeByCodeAndShowType(@RequestParam("codeType") String codeType,@RequestParam("showType")Integer showType);
+
+
 
 }

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

@@ -83,6 +83,12 @@ public class DistrilbutionBillLadingEntity extends TenantEntity {
 	@ApiModelProperty(value = "提货人")
 	private String consignee;
 
+	/**
+	 * 收货单位
+	 */
+	@ApiModelProperty(value = "收货单位")
+	private String consigneeUnit;
+
 	@ApiModelProperty(value = "提货人电话")
 	private String consigneePhone;
 	/**

blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionReservationClient.java

@@ -61,6 +61,8 @@ public interface IDistributionReservationClient {
 	 */
 	@GetMapping(TOP+"/getReservationList")
     List<DistributionReservationEntity> getReservationList(@RequestParam("reservationIds") String reservationIds);
+	@GetMapping(TOP+"/getReservationByCodeAndWarehouseId")
+    DistributionReservationEntity getReservationByCodeAndWarehouseId(@RequestParam("reservationCode") String reservationCode,@RequestParam("warehouseId") String warehouseId);
 
 
 	/**

blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/DistributionSignforStockArticleVO.java

@@ -266,6 +266,18 @@ public class DistributionSignforStockArticleVO implements Serializable {
 	@ApiModelProperty(value = "签收时间")
 	private Date signinTime;
 
+	/**
+	 * 签收ID
+	 */
+	@ApiModelProperty(value = "签收ID")
+	private Long signforId;
+
+	/**
+	 * 配送ID
+	 */
+	@ApiModelProperty(value = "配送ID")
+	private Long deliveryId;
+
 
 	/**
 	 * 创建时间

blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/vo/app/DistributionAppDeliveryListVO.java

@@ -134,6 +134,8 @@ public class DistributionAppDeliveryListVO extends DistributionDeliveryListEntit
 
 
 
+
+
 	/**
 	 * 预约客户数据
 	 */

blade-service-api/logpm-statisticsdata-api/src/main/java/com/logpm/statistics/entity/StatisticsDistributionPackageEntity.java

@@ -84,6 +84,12 @@ public class StatisticsDistributionPackageEntity extends TenantEntity {
 	@ApiModelProperty(value = "品类名称")
 	private String productName;
 
+	/**
+	 * 品类名称
+	 */
+	@ApiModelProperty(value = "品类Id")
+	private String productId;
+
 	/**
 	 * 件数
 	 */

blade-service-api/logpm-statisticsdata-api/src/main/java/com/logpm/statistics/entity/StatisticsTrunklinePackageEntity.java

@@ -83,6 +83,12 @@ public class StatisticsTrunklinePackageEntity extends TenantEntity {
 	@ApiModelProperty(value = "品类名称")
 	private String productName;
 
+	/**
+	 * 品类名称
+	 */
+	@ApiModelProperty(value = "品类id")
+	private String productId;
+
 	/**
 	 * 件数
 	 */

blade-service-api/logpm-statisticsdata-api/src/main/java/com/logpm/statistics/entity/StatisticsWarehousePackageEntity.java

@@ -84,6 +84,12 @@ public class StatisticsWarehousePackageEntity extends TenantEntity {
 	@ApiModelProperty(value = "品类名称")
 	private String productName;
 
+	/**
+	 * 品类名称
+	 */
+	@ApiModelProperty(value = "品类id")
+	private String productId;
+
 	/**
 	 * 件数
 	 */

blade-service/logpm-basic/src/main/java/com/logpm/basic/feign/BasicTenantCodeClient.java

@@ -67,5 +67,8 @@ public class BasicTenantCodeClient implements IBasicTenantCodeClient {
 		return shelfCode;
 	}
 
-
+	@Override
+	public BasicTenantCodeEntity findBasicTenantCodeByCodeAndShowType(String codeType, Integer showType) {
+		return basicTenantCodeService.findBasicTenantCodeByCodeAndShowType(codeType,showType);
+	}
 }

blade-service/logpm-basic/src/main/java/com/logpm/basic/service/IBasicTenantCodeService.java

@@ -68,4 +68,6 @@ public interface IBasicTenantCodeService extends BaseService<BasicTenantCodeEnti
 	BasicTenantCodeEntity gerOne(Long id);
 
     String shelfCode(String tenantId,String codeType);
+
+    BasicTenantCodeEntity findBasicTenantCodeByCodeAndShowType(String codeType, Integer showType);
 }

blade-service/logpm-basic/src/main/java/com/logpm/basic/service/impl/BasicTenantCodeServiceImpl.java

@@ -17,6 +17,7 @@
 package com.logpm.basic.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.logpm.basic.entity.BasicTenantCodeEntity;
 import com.logpm.basic.excel.BasicTenantCodeExcel;
@@ -42,11 +43,10 @@ import java.util.Map;
 @AllArgsConstructor
 public class BasicTenantCodeServiceImpl extends BaseServiceImpl<BasicTenantCodeMapper, BasicTenantCodeEntity> implements IBasicTenantCodeService {
 
-	private BasicTenantCodeMapper basicTenantCodeMapper;
 
 	@Override
 	public IPage<BasicTenantCodeEntity> list(Map<String, Object> basicTenantCode, IPage<BasicTenantCodeEntity> page) {
-		IPage<BasicTenantCodeEntity> basicTenantCodeEntityIPage = basicTenantCodeMapper.selectTenantCodeList(page,basicTenantCode);
+		IPage<BasicTenantCodeEntity> basicTenantCodeEntityIPage = baseMapper.selectTenantCodeList(page,basicTenantCode);
 		return basicTenantCodeEntityIPage;
 	}
 
@@ -54,7 +54,7 @@ public class BasicTenantCodeServiceImpl extends BaseServiceImpl<BasicTenantCodeM
 	public BasicTenantCodeEntity gerOne(Long id) {
 		BasicTenantCodeEntity basicTenantCodeEntity = new BasicTenantCodeEntity();
 		if (id!=null){
-			 basicTenantCodeEntity = basicTenantCodeMapper.selectTenantCodeDetail(id);
+			 basicTenantCodeEntity = baseMapper.selectTenantCodeDetail(id);
 		}
 		return basicTenantCodeEntity;
 	}
@@ -64,7 +64,7 @@ public class BasicTenantCodeServiceImpl extends BaseServiceImpl<BasicTenantCodeM
 		Map<String,String> map = new HashMap<>();
 		map.put("tenantId",tenantId);
 		map.put("codeType",codeType);
-		String shelfCode = basicTenantCodeMapper.shelfCode(map);
+		String shelfCode = baseMapper.shelfCode(map);
 		return shelfCode;
 	}
 
@@ -83,14 +83,23 @@ public class BasicTenantCodeServiceImpl extends BaseServiceImpl<BasicTenantCodeM
 		return basicTenantCodeList;
 	}
 
+	@Override
+	public BasicTenantCodeEntity findBasicTenantCodeByCodeAndShowType(String codeType, Integer showType) {
+
+		BasicTenantCodeEntity basicTenantCodeEntity = baseMapper.selectOne(new QueryWrapper<BasicTenantCodeEntity>().eq("code_type", codeType).eq("show_type", showType).eq("is_deleted",0));
+
+
+		return basicTenantCodeEntity;
+	}
+
 	@Override
 	public boolean save(BasicTenantCodeEntity entity) {
 		String code = entity.getCode();
-		Integer codeType = entity.getCodeType();
-		if (Func.isBlank(code)){
-			code = "DA--00"+codeType;
-			entity.setCode(code);
-		}
+		String codeType = entity.getCodeType();
+//		if (Func.isBlank(code)){
+//			code = "DA--00"+codeType;
+//			entity.setCode(code);
+//		}
 		return super.save(entity);
 	}
 }

blade-service/logpm-basic/src/main/resources/application-test.yml

@@ -52,3 +52,13 @@ spring:
           url: ${blade.datasource.basic.695224.url}
           username: ${blade.datasource.basic.695224.username}
           password: ${blade.datasource.basic.695224.password}
+
+        645789:
+          druid:
+            #独立校验配置
+            validation-query: select 1
+            #oracle校验
+            #validation-query: select 1 from dual
+          url: ${blade.datasource.basic.645789.url}
+          username: ${blade.datasource.basic.645789.username}
+          password: ${blade.datasource.basic.645789.password}

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

@@ -75,6 +75,6 @@ public interface BasicdataClientMapper extends BaseMapper<BasicdataClientEntity>
 	 * 查询规则生成的客户编码列表
 	 * @return
 	 */
-    List<String> getFinallyClientCode();
+    List<String> getFinallyClientCode(@Param("tenantCode")String tenantCode);
 
 }

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 'HT00%' 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 CONCAT(#{tenantCode},'%') AND LENGTH(client_code) = 9 AND is_deleted = 0  ORDER BY client_code DESC
     </select>
 
 </mapper>

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

@@ -26,6 +26,8 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.logpm.basic.entity.BasicTenantCodeEntity;
+import com.logpm.basic.feign.IBasicTenantCodeClient;
 import com.logpm.basicdata.entity.BasicdataBrandEntity;
 import com.logpm.basicdata.entity.BasicdataClientEntity;
 import com.logpm.basicdata.entity.BasicdataHistoricalContractEntity;
@@ -51,6 +53,8 @@ import com.logpm.basicdata.vo.ClientInfoVO;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.common.constant.DictBizConstant;
 import org.springblade.common.constant.RedisKeyConstant;
+import org.springblade.common.constant.basiccode.BasicCodeShowConstant;
+import org.springblade.common.constant.basiccode.BasicCodeTypeConstant;
 import org.springblade.common.model.dto.NameDTO;
 import org.springblade.core.log.exception.ServiceException;
 import org.springblade.core.mp.base.BaseServiceImpl;
@@ -101,6 +105,10 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
 	private IBasicdataWarehouseService warehouseService;
 //	private final IBasicdataClientUserService basicdataClientUserService;
 
+
+	@Autowired
+	private IBasicTenantCodeClient basicTenantCodeClient;
+
 	@Autowired
 	private IUserClient userClient;
 
@@ -669,15 +677,30 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
 
 	@Override
 	public String getFinallyClientCode() {
+
+		String tenantCode ="HT";
+		BasicTenantCodeEntity basicTenantCodeByCodeAndShowType = basicTenantCodeClient.findBasicTenantCodeByCodeAndShowType(BasicCodeTypeConstant.CLIENT_CODE.getValue(), BasicCodeShowConstant.QR_CODE.getValue());
+		if (ObjectUtils.isNull(basicTenantCodeByCodeAndShowType)) {
+			log.error("获取货区码失败");
+		}else{
+			tenantCode = basicTenantCodeByCodeAndShowType.getCode();
+		}
+
 		String finaClientCode = redis.get(RedisKeyConstant.FINAL_CLIENT_CODE + AuthUtil.getTenantId());
 		if (StringUtils.isBlank(finaClientCode)) {
-			List<String> str = baseMapper.getFinallyClientCode();
-			finaClientCode = str.get(0);
+			List<String> str = baseMapper.getFinallyClientCode(tenantCode);
+			if(!str.isEmpty()){
+				finaClientCode = str.get(0);
+			}else{
+				finaClientCode =tenantCode+"0000000";
+			}
 			redis.set(RedisKeyConstant.FINAL_CLIENT_CODE + AuthUtil.getTenantId(), finaClientCode);
+
 		}
-		String num = finaClientCode.replaceAll("HT", "");
+		String num = finaClientCode.replaceAll(tenantCode, "");
 		int anInt = Integer.parseInt(num) + 1;
-		return "HT00" + anInt;
+		String formattedNum = String.format("%07d", anInt);
+		return tenantCode + formattedNum;
 	}
 
 	@Override

blade-service/logpm-basicdata/src/main/resources/application-test.yml

@@ -46,3 +46,7 @@ spring:
           url: ${blade.datasource.basicdata.695224.url}
           username: ${blade.datasource.basicdata.695224.username}
           password: ${blade.datasource.basicdata.695224.password}
+        645789:
+          url: ${blade.datasource.basicdata.645789.url}
+          username: ${blade.datasource.basicdata.645789.username}
+          password: ${blade.datasource.basicdata.645789.password}

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

@@ -1,16 +1,23 @@
 package com.logpm.business.receiver;
 
+import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.logpm.business.service.IBusinessPreOrderService;
+import com.logpm.distribution.entity.DistributionReservationEntity;
+import com.logpm.distribution.feign.IDistributionReservationClient;
 import com.rabbitmq.client.Channel;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.common.constant.RabbitConstant;
+import org.springblade.core.tool.api.R;
+import org.springblade.system.entity.Tenant;
+import org.springblade.system.feign.ISysClient;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitHandler;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -23,7 +30,8 @@ import java.util.Map;
 public class BusinessInOrderDataQueueHandler {
 
 	private final IBusinessPreOrderService businessPreOrderService;
-
+	private final IDistributionReservationClient distributionReservationClient;
+	private final ISysClient sysClient;
 	@RabbitHandler
 	public void businessInOrderDataHandler(Map map, Message message, Channel channel) {
 		// 获取
@@ -35,7 +43,9 @@ public class BusinessInOrderDataQueueHandler {
 		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或者空串
@@ -59,9 +69,26 @@ public class BusinessInOrderDataQueueHandler {
 			log.error("driverName is null");
 			return;
 		}
+		// 判断目标租户
+		DistributionReservationEntity reservationByCodeAndWarehouseId = distributionReservationClient.getReservationByCodeAndWarehouseId(reservationCode, warehouseId.toString());
+
+		// 判断是否存在租户
+		R<List<Tenant>> tenantList = sysClient.getTenantList();
+		Tenant tenant = null;
+		if (tenantList.isSuccess()) {
+			List<Tenant> data = tenantList.getData();
+			for (Tenant datum : data) {
+				if (datum.getTenantType() == 2 && datum.getTenantName().equals(reservationByCodeAndWarehouseId.getMallName().trim())) {
+					tenant = datum;
+					break;
+				}
+			}
+		}
+		if(!ObjectUtil.isEmpty(tenant)){
+			// 如果师傅签收 以师傅签收的车次为准
+			businessPreOrderService.scanOrderPackageCodeByMaster(orderPackageCode, reservationCode, distrCarNumber, vehicleName, driverName, userName, warehouseId,tenant.getTenantId(),tenant.getTenantName(),tenantId);
+		}
 
-		// 如果师傅签收 以师傅签收的车次为准
-		businessPreOrderService.scanOrderPackageCodeByMaster(orderPackageCode, reservationCode, distrCarNumber, vehicleName, driverName, userName, warehouseId, tenantId);
 
 
 	}

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

@@ -10,6 +10,7 @@ import com.logpm.trunkline.dto.InComingDTO;
 import org.springblade.core.log.exception.ServiceException;
 import org.springblade.core.mp.base.BaseService;
 import org.springblade.core.tool.api.R;
+import org.springblade.system.entity.Tenant;
 
 import java.util.List;
 import java.util.Map;
@@ -88,8 +89,9 @@ public interface IBusinessPreOrderService extends BaseService<BusinessPreOrderEn
 	 * @param driverName 司机名称
 	 * @param vehicleName 车牌号码
 	 * @param warehouseId  当前作业仓库ID
-	 * @param tenantId  当前作业的租户
+	 * @param tenantId  目标租户
 	 * @param userName 作业用户
+	 * @param sourceTenantId 来源租户
 	 * @return
 	 */
 	R scanOrderPackageCodeByMaster(String orderPackageCode,
@@ -99,7 +101,9 @@ public interface IBusinessPreOrderService extends BaseService<BusinessPreOrderEn
 								   String driverName,
 								   String userName,
 								   Long warehouseId,
-								   String tenantId
+								   String tenantId,
+								   String tenantName,
+								   String sourceTenantId
 	);
 
 }

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

@@ -23,6 +23,7 @@ import com.logpm.trunkline.feign.IInComingClient;
 import com.logpm.trunkline.feign.ITrunklineAdvanceDetailClient;
 import lombok.AllArgsConstructor;
 import org.jetbrains.annotations.Nullable;
+import org.springblade.common.annotations.ChangeAsync;
 import org.springblade.common.constant.IncomingTypeEnum;
 import org.springblade.common.constant.RedisKeyConstant;
 import org.springblade.common.exception.CustomerException;
@@ -169,13 +170,12 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 
 	private R inOrderWarehourseByFeign(BusinessSanDTO businessSanDTO) {
 		InComingDTO inComingDTO = new InComingDTO();
-		BasicdataWarehouseEntity myCurrentWarehouse = basicdataWarehouseClient.getMyCurrentWarehouse();
 		inComingDTO.setOrderPackageCode(businessSanDTO.getOrderPackageCode());
 		inComingDTO.setIncomingType(IncomingTypeEnum.LINE_INCOMING.getCode());
-		inComingDTO.setWarehouseId(myCurrentWarehouse.getId());
 		inComingDTO.setTrayCode(businessSanDTO.getTrayCode());
 		inComingDTO.setTrayType(businessSanDTO.getTrayType());
-		inComingDTO.setWarehouseName(myCurrentWarehouse.getName());
+		inComingDTO.setWarehouseName(businessSanDTO.getWarehouseName());
+		inComingDTO.setWarehouseId(businessSanDTO.getWarehouseId());
 
 		R r = inComingClient.incomingPackageByTaryCode(inComingDTO);
 		return r;
@@ -187,6 +187,9 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 
 
 		try {
+			BasicdataWarehouseEntity myCurrentWarehouse = basicdataWarehouseClient.getMyCurrentWarehouse();
+			businessSanDTO.setWarehouseId(myCurrentWarehouse.getId());
+			businessSanDTO.setWarehouseName(myCurrentWarehouse.getName());
 			String orderPackageCode = businessSanDTO.getOrderPackageCode();
 			String distrCarNumber = businessSanDTO.getDistrCarNumber();
 
@@ -466,6 +469,7 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 	}
 
 
+	@ChangeAsync
 	@Override
 	public R scanOrderPackageCodeByMaster(String orderPackageCode,
 										  String reservationCode,
@@ -474,7 +478,16 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 										  String driverName,
 										  String userName,
 										  Long warehouseId,
-										  String tenantId) {
+										  String tenantId,
+										  String tenantName,
+										  String sourceTenantId) {
+
+
+		BasicdataWarehouseEntity warehouseEntity = basicdataWarehouseClient.findByName(tenantName + "仓");
+		if(ObjectUtils.isNull(warehouseEntity)){
+			return R.fail("仓库信息不存在");
+		}
+
 
 		// 判断当前的包条码是否和当前作业的车次相同
 		LambdaQueryWrapper<BusinessPreOrderEntity> queryWrapper1 = new LambdaQueryWrapper<>();
@@ -484,14 +497,22 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 		BusinessPreOrderEntity data =null;
 		if (list1.isEmpty()) {
 			// 新增改车次的预入库信息
-			DistributionParcelListEntity byPacketBarCodeAndWarehouseId = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(orderPackageCode, warehouseId);
-			data = BeanUtil.copy(byPacketBarCodeAndWarehouseId, BusinessPreOrderEntity.class);
+			TrunklineAdvanceDetailEntity entityByOrderPackageCode = trunklineAdvanceDetailClient.findEntityByOrderPackageCode(orderPackageCode);
+
+
+			data = BeanUtil.copy(entityByOrderPackageCode, BusinessPreOrderEntity.class);
+			data.setWaybillNumber(entityByOrderPackageCode.getWaybillNo());
+			data.setFirsts(entityByOrderPackageCode.getFirstPackName());
+			data.setSecond(entityByOrderPackageCode.getSecondPackName());
+			data.setThirdProduct(entityByOrderPackageCode.getThirdPackName());
+			data.setBrandName(entityByOrderPackageCode.getBrand());
+			data.setConditions(1);
+			data.setInWarehouse(0);
 			data.setDriverName(driverName);
 			data.setVehicleName(vehicleName);
 			data.setDistrCarNumber(distrCarNumber);
-			data.setFromTenantId(tenantId);
+			data.setFromTenantId(sourceTenantId);
 			data.setOperationStatus(0);
-			data.setInWarehouse(1);
 			data.setId(null);
 			data.setTenantId(null);
 			data.setReservationCode(reservationCode);
@@ -513,9 +534,15 @@ public class BusinessPreOrderServiceImpl extends BaseServiceImpl<BusinessPreOrde
 
         }
 
+		// 通过目标租户确认 目标租户对应的仓库
+
 		BusinessSanDTO businessSanDTO = new BusinessSanDTO();
 		businessSanDTO.setOrderPackageCode(data.getOrderPackageCode());
-		R r = inOrderWarehourse(businessSanDTO);
+		businessSanDTO.setDistrCarNumber(distrCarNumber);
+		businessSanDTO.setInWarehouseException(0);
+		businessSanDTO.setWarehouseName(warehouseEntity.getName());
+		businessSanDTO.setWarehouseId(warehouseEntity.getId());
+		R r = inOrderWarehourseByFeign(businessSanDTO);
 
 		return r;
 	}

blade-service/logpm-business/src/main/resources/application-dev.yml

@@ -1,6 +1,6 @@
 #服务器端口
 server:
-  port: 17020
+  port: 16010
 
 #数据源配置
 #spring:

blade-service/logpm-business/src/main/resources/application-prod.yml

@@ -1,6 +1,6 @@
 #服务器端口
 server:
-  port: 17020
+  port: 16010
 
 #数据源配置
 #spring:

blade-service/logpm-business/src/main/resources/application-test.yml

@@ -1,6 +1,6 @@
 #服务器端口
 server:
-  port: 17020
+  port: 16010
 
 #数据源配置
 #spring:
@@ -22,13 +22,22 @@ spring:
       primary: master
       datasource:
         master:
-          url: ${blade.datasource.warehouse.master.url}
-          username: ${blade.datasource.warehouse.master.username}
-          password: ${blade.datasource.warehouse.master.password}
+          url: ${blade.datasource.business.master.url}
+          username: ${blade.datasource.business.master.username}
+          password: ${blade.datasource.business.master.password}
         627683:
-          url: ${blade.datasource.warehouse.627683.url}
-          username: ${blade.datasource.warehouse.627683.username}
-          password: ${blade.datasource.warehouse.627683.password}
+          url: ${blade.datasource.business.627683.url}
+          username: ${blade.datasource.business.627683.username}
+          password: ${blade.datasource.business.627683.password}
+        645789:
+          druid:
+            #独立校验配置
+            validation-query: select 1
+            #oracle校验
+            #validation-query: select 1 from dual
+          url: ${blade.datasource.business.645789.url}
+          username: ${blade.datasource.business.645789.username}
+          password: ${blade.datasource.business.645789.password}
   #rabbitmq配置
   rabbitmq:
     host: 192.168.2.110

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

@@ -137,7 +137,13 @@ public class DistributionDeliveryAppController {
 	@ApiOperationSupport(order = 6)
 	@ApiOperation(value = "装车扫描", notes = "传入DistrilbutionloadingscanDTO")
 	public R loadingscan(@Valid @RequestBody DistrilbutionloadingscanDTO distrilbutionloadingscanDTO) {
-		R msg = distributionDeliveryListService.loadingscan(distrilbutionloadingscanDTO);
+		R msg = null;
+		try{
+			 msg = distributionDeliveryListService.loadingscan(distrilbutionloadingscanDTO);
+
+		}catch (Exception e){
+			e.printStackTrace();
+		}
 
 		return msg;
 	}

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

@@ -423,8 +423,8 @@ public class DistributionDeliveryListController extends BladeController {
 	@GetMapping("/judgmentOrderRemove")
 	@ApiOperationSupport(order = 2)
 	@ApiOperation(value = "判断是否可以在商配计划中移除", notes = "customArgs")
-	public R<Boolean> judgmentOrderRemove(@RequestParam Long deliveryId,@RequestParam Long orderId) {
-		boolean result = distributionDeliveryListService.judgmentOrderRemove(deliveryId,orderId);
+	public R<Boolean> judgmentOrderRemove(@RequestParam Long deliveryId,@RequestParam String orderIds) {
+		boolean result = distributionDeliveryListService.judgmentOrderRemove(deliveryId,orderIds);
 		return R.data(result);
 	}
 

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

@@ -111,6 +111,7 @@ public class DistributionReservationController extends BladeController {
 			List<Long> ids = Func.toLongList(",", excludeId);
 			lambda.notIn(DistributionReservationEntity::getId,ids);
 		}
+		lambda.orderByDesc(DistributionReservationEntity::getCreateTime);
 		IPage<DistributionReservationEntity> pages = reservationService.page(Condition.getPage(query),lambda );
 		pages.getRecords().forEach(i ->{
 			R<User> userR = userClient.userInfoById(i.getCreateUser());

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

@@ -387,6 +387,8 @@ public class DistributionStockArticleController extends BladeController {
 			BeanUtil.copy(oldStockArticle,newStockArticle);
 			String consigneePerson = stockArticleEntity.getConsigneePerson();
 			String customerName = stockArticleEntity.getCustomerName();
+			String mallName = stockArticleEntity.getMallName();
+			String consigneeUnit = stockArticleEntity.getConsigneeUnit();
 			if(StringUtil.isNotBlank(consigneePerson)){
 				newStockArticle.setConsigneePerson(consigneePerson);
 				newStockArticle.setConsigneeMobile(stockArticleEntity.getConsigneeMobile());
@@ -396,8 +398,8 @@ public class DistributionStockArticleController extends BladeController {
 				newStockArticle.setCustomerTelephone(stockArticleEntity.getCustomerTelephone());
 				newStockArticle.setCustomerAddress(stockArticleEntity.getCustomerAddress());
 			}else {
-				newStockArticle.setMallName(customerName);
-				newStockArticle.setConsigneeUnit(customerName);
+				newStockArticle.setMallName(mallName);
+				newStockArticle.setConsigneeUnit(consigneeUnit);
 			}
 			String content = oldStockArticle.compareCustomerInfo(newStockArticle);
 			if(StringUtil.isNotBlank(content)){

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/dto/DistrilbutionBillLadingDTO.java

@@ -74,10 +74,6 @@ public class DistrilbutionBillLadingDTO extends DistrilbutionBillLadingEntity {
 	 * 运单号
 	 */
 	private  String waybillNumber;
-	/**
-	 * 收货单位
-	 */
-	private  String consigneeUnit;
 	/**
 	 * 收货人
 	 */
@@ -152,7 +148,6 @@ public class DistrilbutionBillLadingDTO extends DistrilbutionBillLadingEntity {
 	 */
 	private  String stockupCode;
 
-
 	/**
 	 * 库存品
 	 */

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionReservationClient.java

@@ -60,6 +60,11 @@ public class DistributionReservationClient implements IDistributionReservationCl
 		return reservationService.getRetentionReservationList(reservationIds);
 	}
 
+	@Override
+	public DistributionReservationEntity getReservationByCodeAndWarehouseId(String reservationCode, String warehouseId) {
+		return reservationService.selectByReservationCode(reservationCode);
+	}
+
 	/**
 	 * @param warehouseId
 	 * @return

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

@@ -562,7 +562,7 @@
     <select id="selectAppcustomListPage" resultType="com.logpm.distribution.vo.app.DistributionAppReservationVO">
        SELECT DISTINCT
 	ldr.id id,
-	ldr.consignee consignee,
+        GROUP_CONCAT(DISTINCT CONCAT(ldr.receiving_unit,'(',ldr.consignee),')') AS  consignee,
 <!--	COALESCE ( lds.loaded_number + lds.loadedin_number, 0 ) loadingNub,-->
 	COALESCE ( ldr.reservation_num + ldr.reservation_stock_list_num, 0 ) reservationNum,
 	(

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

@@ -1046,7 +1046,8 @@
         (SELECT COALESCE(sum(lds.loaded_number+lds.loadedin_number), 0) FROM logpm_distribution_signfor lds WHERE
         lddl.id = lds.delivery_id) scannedNumber,
         (
-        select GROUP_CONCAT(ldr.consignee)
+        select
+        group_concat(CONCAT(ldr.mall_name ,'(',ldr.consignee,')'))
         from logpm_distribution_reservation ldr
         where ldr.id in
         (select lds.reservation_id

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

@@ -543,7 +543,7 @@
         LEFT JOIN logpm_warehouse_tray_goods lwtg on lwtg.association_id = ldpl.id and lwtg.association_type = '3'
         LEFT JOIN logpm_warehouse_tray lwt on lwtg.tray_id = lwt.id
         <where>
-            ldsi.stockup_id =#{id} and ldpl.order_package_code is not null and ldsi.stock_status != 4
+            ldsi.stockup_id =#{id} and ldpl.order_package_code is not null and ldsi.stock_status != 4 AND ldrp.packet_bar_status != 2
         </where>
     </select>
     <select id="getPageVOList" resultType="com.logpm.distribution.entity.DistributionParcelListEntity">

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

@@ -458,6 +458,9 @@
             <if test=" param.orderCodeNumLike != '' and param.orderCodeNumLike != null  ">and ldsa.order_code like
                 concat('%',#{param.orderCodeNumLike},'%')
             </if>
+            <if test=" param.brand != '' and param.brand != null  ">and ldsa.brand like
+                concat(#{param.brand},'%')
+            </if>
             <if test=" param.reservation != '' and param.reservation != null  ">
                 and ldsa.reservation_status in (10,20) and ldpl.order_package_reservation_status = 10
             </if>
@@ -1492,7 +1495,9 @@
         lds.sjsigning_time AS sjsigningTime,
         lddl.train_number AS trainNumber,
         lddl.vehicle_name AS vehicleName,
-        lddl.driver_name AS driverName
+        lddl.driver_name AS driverName,
+        lds.id AS signforId,
+        lds.delivery_id AS deliveryId
         FROM
         logpm_distribution_reservation_stockarticle AS ldrs
         LEFT JOIN logpm_distribution_reservation AS ldr ON ldrs.reservation_id = ldr.id

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

@@ -1020,6 +1020,7 @@
             ldsi.stockup_id = #{ id }
             AND ldsi.is_deleted = 0
             AND ldsi.stock_status != 4
+            AND ldrs.stock_article_status != 2
         </where>
 
     </select>

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

@@ -461,6 +461,7 @@
         lad.`conditions` `conditions`,
         lad.Pick_up_plate pickUpPlate,
         lad.consignee consignee,
+        lad.consignee_unit consigneeUnit,
         lad.create_time,
         lad.pick_up_time,
         lad.stock_article_id stockArticleId

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionDeliveryListService.java

@@ -401,7 +401,7 @@ public interface IDistributionDeliveryListService extends BaseService<Distributi
 	 * @param orderId
 	 * @return
 	 */
-	boolean judgmentOrderRemove(Long deliveryId, Long orderId);
+	boolean judgmentOrderRemove(Long deliveryId, String orderIds);
 
 	/**
 	 * 维护配送任务的配送数量

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

@@ -577,6 +577,8 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 	@Transactional(isolation = Isolation.READ_COMMITTED, rollbackFor = Exception.class)
 //	synchronized
 	public R loadingscan(DistrilbutionloadingscanDTO distrilbutionloadingscanDTO) {
+
+
 		//查询该包件是否能够从库存品包件表中查到
 		String now = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
 
@@ -642,6 +644,9 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 			if (Func.isEmpty(parcelList)) {
 				return Resp.scanFail("系统无编码", "系统无编码");
 			}
+			if (parcelList.getConditions().equals(2)) {
+				return Resp.scanFail("此包件不是订制品", "此包件不是订制品");
+			}
 			if (!Objects.isNull(parcelList)) {
 				if (OrderPackageStatusConstant.yiqianshou.getValue().equals(parcelList.getOrderPackageStatus())) {
 					return Resp.scanFail("包件已签收", "包件已签收");
@@ -787,21 +792,17 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 					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());
 						//查看是否存在满足条件的预约单
-						reservationEntities = reservationEntities.stream().filter(r -> r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) && r.getMallName().equals(stockArticleEntity.getMallName())).collect(Collectors.toList());
+						boolean flag = reservationEntityList.stream().anyMatch(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()));
 
 						//存在多个，操作人指定具体客户即可
-						if (!reservationEntities.isEmpty() && reservationEntities.size() == 1) {
-							if (Func.isEmpty(distrilbutionloadingscanDTO.getReservationId())) {
-								log.info("异常装车未指定客户");
-								return Resp.scanFail("请指定客户进行异常装车", "请指定客户进行异常装车");
-							}
+						if ( reservationEntities.size() == 1  && flag) {
 							return R.fail(5000, "异常装车");
-//						return Resp.scanFail("装车失败","程序出错，请联系彪桑");
 						} else {
-							if (parcelListEntity.getConditions() == 2) {
-								return Resp.scanFail("此包件不是订制品", "此包件不是订制品");
-
-							} else {
+							if (flag){
+								if (reservationEntities.isEmpty()){
+									return Resp.scanFail("请指定客户进行异常装车", "请指定客户进行异常装车");
+								}
+							}else {
 								return Resp.scanFail("窜货", "窜货");
 							}
 						}
@@ -810,15 +811,18 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 						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){
+							boolean flag = reservationEntityList.stream().anyMatch(r -> r.getReceivingUnit().equals(stockArticleEntity.getConsigneeUnit()) && r.getMallName().equals(stockArticleEntity.getMallName()));
+							if (reservationEntities.size() == 1 && flag){
 								return R.fail(5000, "异常装车");
 
 							}else {
-								if (Func.isEmpty(distrilbutionloadingscanDTO.getReservationId())){
-									return Resp.scanFail("请指定客户进行异常装车", "请指定客户进行异常装车");
+								if (flag){
+									if (reservationEntities.isEmpty()){
+										return Resp.scanFail("请指定客户进行异常装车", "请指定客户进行异常装车");
+									}
 								}else {
 									return Resp.scanFail("窜货", "窜货");
+
 								}
 							}
 						} else {
@@ -2438,19 +2442,6 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 				reservationStockarticleEntityList.forEach(rs -> {
 					DistributionStockArticleEntity stockArticleEntity = distributionStockArticleService.getById(rs.getStockArticleId());
 					DistributionStockArticleVO distributionStockArticleVO = DistributionStockArticleWrapper.build().entityVO(stockArticleEntity);
-//					if (rs.getIsZero().equals(IsOrNoConstant.no.getValue())) {
-////						List<DistributionReservationPackageEntity> reservationPackageEntityList = distributionReservationPackageService.list(Wrappers.<DistributionReservationPackageEntity>query().lambda().eq(DistributionReservationPackageEntity::getReservationId, rs.getReservationId()).eq(DistributionReservationPackageEntity::getStockArticleId, stockArticleEntity.getId()).ne(DistributionReservationPackageEntity::getPacketBarStatus, ReservationPackageStatusConstant.quxiao.getValue()));
-////						if (Func.isNotEmpty(reservationPackageEntityList)) {
-////							ArrayList<DistributionParcelListVO> distributionParcelListVOS = new ArrayList<>();
-////							reservationPackageEntityList.forEach(rp -> {
-////								DistributionParcelListEntity parcelListEntity = distributionParcelListService.getById(rp.getParceListId());
-////								DistributionParcelListVO distributionParcelListVO = DistributionParcelListWrapper.build().entityVO(parcelListEntity);
-////								distributionParcelListVOS.add(distributionParcelListVO);
-////							});
-////							distributionStockArticleVO.setPackageList(distributionParcelListVOS);
-////							distributionStockArticleVO.setParcelListVOS(DistributionParcelListWrapper.build().listVO(distributionParcelListService.getBaseMapper().selectList(Wrappers.<DistributionParcelListEntity>query().lambda().eq(DistributionParcelListEntity::getStockArticleId, rs.getStockArticleId()))));
-////						}
-//					}
 					distributionStockArticleVO.setReservationNum(rs.getReservationNum());
 					distributionStockArticleVOS.add(distributionStockArticleVO);
 				});
@@ -4589,7 +4580,7 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 
 		}
 		// 推送数据
-		return Resp.scanFail("发车成功", builder.toString());
+		return Resp.scanSuccess("发车成功", builder.toString());
 	}
 
 	@Override
@@ -7011,14 +7002,15 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 	}
 
 	@Override
-	public boolean judgmentOrderRemove(Long deliveryId, Long orderId) {
+	public boolean judgmentOrderRemove(Long deliveryId, String orderIds) {
+		List<Long> list = Func.toLongList(orderIds);
 		List<DistributionLoadscanEntity> loadscanEntityList = distributionLoadscanService.list(Wrappers.<DistributionLoadscanEntity>query().lambda()
 			.eq(DistributionLoadscanEntity::getDeliveryId, deliveryId)
+			.in(DistributionLoadscanEntity::getOrderId, list)
 			.ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue())
 		);
 		if (Func.isNotEmpty(loadscanEntityList)) {
-			Map<Long, DistributionLoadscanEntity> loadingOrderMap = loadscanEntityList.stream().collect(Collectors.toMap(DistributionLoadscanEntity::getOrderId, Function.identity(), (k1, k2) -> k2));
-            return !Func.isNotEmpty(loadingOrderMap.get(orderId));
+            return false;
 		}
 		return true;
 	}
@@ -7209,6 +7201,7 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 			return Resp.scanFail("该任务已完结！", "该任务已完结!");
 		}
 		String loadingId = distrilbutionloadingscanDTO.getLoadingId();
+
 		Boolean b = false;
 		if ("1".equals(distributionDeliveryListEntity.getKind())) {
 			b = distributionDeliverySelfService.update(new UpdateWrapper<DistributionDeliverySelfEntity>().lambda()

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

@@ -2589,7 +2589,12 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
 			//查询备货任务
 			DistributionStockupEntity stockupEntity = distributionStockupMapper.selectById(distributionStockupInfoEntities.get(0).getStockupId());
 			if (Func.isNotEmpty(stockupEntity)) {
-				if (stockupEntity.getAssignStatus().equals(StockAssignStatusConstant.weizhipai.getValue())) {
+				//查询此备货任务有多少
+				List<DistributionStockupInfoEntity> entityList = distributionStockupInfoService.list(Wrappers.<DistributionStockupInfoEntity>query().lambda()
+					.eq(DistributionStockupInfoEntity::getStockupId, stockupEntity.getId())
+					.ne(DistributionStockupInfoEntity::getStockStatus, "4")
+				);
+				if (stockupEntity.getAssignStatus().equals(StockAssignStatusConstant.weizhipai.getValue()) && entityList.size() == 1) {
 					//物理删除关于预约的所有信息
 					distributionReservationStocklistMapper.deleteReservationStocklist(reservationEntity.getId());
 					distributionReservationPackageMapper.deleteReservationPackage(reservationEntity.getId());

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

@@ -16,6 +16,8 @@
  */
 package com.logpm.distribution.service.impl;
 
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -43,6 +45,7 @@ import com.logpm.distribution.vo.app.*;
 import com.logpm.distribution.wrapper.DistributionParcelListAppWrapper;
 import com.logpm.distribution.wrapper.DistributionParcelListWrapper;
 import com.logpm.distribution.wrapper.DistributionStockArticleWrapper;
+import com.logpm.factory.comfac.dto.OrderStatusDTO;
 import com.logpm.oldproject.dto.SignPushDataContactDTO;
 import com.logpm.oldproject.dto.SignPushDataDTO;
 import com.logpm.oldproject.dto.SignPushDataUnitDTO;
@@ -2404,6 +2407,21 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 		if (Objects.isNull(myCurrentWarehouse)) {
 			return R.fail(403, "配送任务错误");
 		}
+		//查询是否完成复核
+		DistributionSignforEntity signforEntity = this.getOne(Wrappers.<DistributionSignforEntity>query().lambda()
+			.eq(DistributionSignforEntity::getReservationId, distrilbutionloadingscanDTO.getReservationId())
+		);
+		if (Objects.isNull(signforEntity)){
+			//查询签收信息错误
+			log.error("签收扫描查询签收表信息错误reservationId:{}",distrilbutionloadingscanDTO.getReservationId());
+			return R.fail(403, "配送任务错误");
+		}
+		if (SignforStatusConstant.yiqianshou.getValue().equals(signforEntity.getSigningStatus())){
+			return Resp.scanFail("此任务已完成复核", "此任务已完成复核");
+		}
+
+
+
 		List<Long> packageLockIds = new ArrayList<>();
 		try {
 
@@ -2665,6 +2683,14 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 			distributionDeliveryListService.maintenanceDeliveryInfo(distrilbutionloadingscanDTO.getDeliveryId());
 
 			trunklinePackageTrackLogClient.addPackageTrackLog(aaa);
+
+			// 推送
+			sendMessage(distrilbutionloadingscanDTO.getBarcode(), distributionReservationEntity.getReservationCode(),
+				deliveryListEntity.getTrainNumber(),deliveryListEntity.getVehicleName(),deliveryListEntity.getDriverName(),
+				AuthUtil.getUserName(),myCurrentWarehouse.getId(),AuthUtil.getTenantId());
+
+
+
 			return Resp.scanSuccessWithData("签收成功", str, orderPackageCodes);
 		} catch (Exception e) {
 			log.error(">>>>> 签收异常报错", e);
@@ -2672,6 +2698,49 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 		}
 	}
 
+	/**
+	 *
+	 * @param orderPackageCode
+	 * @param reservationCode
+	 * @param distrCarNumber
+	 * @param vehicleName
+	 * @param driverName
+	 * @param userName
+	 * @param warehouseId
+	 * @param tenantId 当前的租户
+	 *
+	 */
+	private void sendMessage(String orderPackageCode,
+							 String reservationCode,
+							 String distrCarNumber,
+							 String vehicleName,
+							 String driverName,
+							 String userName,
+							 Long warehouseId,
+							 String tenantId
+		){
+		try {
+			JSONObject jsonObject = new JSONObject();
+			jsonObject.put("orderPackageCode",orderPackageCode);
+			jsonObject.put("reservationCode",reservationCode);
+			jsonObject.put("distrCarNumber",distrCarNumber);
+			jsonObject.put("vehicleName",vehicleName);
+			jsonObject.put("driverName",driverName);
+			jsonObject.put("userName",userName);
+			jsonObject.put("warehouseId",warehouseId);
+			jsonObject.put("tenantId",tenantId);
+			// 发送入库消息
+			Map mapState = new HashMap();
+			mapState.put("messageId", CommonUtil.getUUID());
+			mapState.put("createTime", System.currentTimeMillis());
+			Map<String, Object> map = new HashMap<>();
+			map.put("messageData", jsonObject);
+			rabbitTemplate.convertAndSend(RabbitConstant.BUSINESS_IN_CONVERSION_DATA_EXCHANGE, RabbitConstant.BUSINESS_IN_CONVERSION_DATA_ROUTING, map);
+		} catch (Exception e) {
+			log.error("签收商家推送：{}", e);
+		}
+	}
+
 	@Override
 	@Transactional(rollbackFor = Exception.class)
 	public R signforPC(DistrilbutionAppsignforDTO distrilbutionloadingscanDTO) {
@@ -3704,8 +3773,10 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 
 	@Override
 	public List<DistributionAppStockArticleVO> getAppDeliveryorderListPage(DistributionAppDeliveryListDTO distributionDeliveryList) {
+		List<DistributionAppStockArticleVO> orderVos = new ArrayList<>();
 		if (Func.isEmpty(distributionDeliveryList.getReservationId())) {
 			log.error("参数缺失reservationId:{}", distributionDeliveryList.getReservationId());
+			return orderVos;
 		}
 
 		//查询该客户装车
@@ -3731,32 +3802,40 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 		}
 		Map<Long, List<DistributionReservationStockarticleEntity>> reservationOrderMap = reservationStockarticleEntityList.stream().collect(Collectors.groupingBy(DistributionReservationStockarticleEntity::getStockArticleId));
 		Map<Long, List<DistributionLoadscanEntity>> loadingOrderMap = distributionLoadscanEntities.stream().collect(Collectors.groupingBy(DistributionLoadscanEntity::getOrderId));
-		List<DistributionAppStockArticleVO> orderVos = new ArrayList<>();
+
 		if (Func.isNotEmpty(orderIds)) {
 			orderIds = orderIds.stream().distinct().collect(Collectors.toList());
-			for (Long orderId : orderIds) {
-				DistributionStockArticleEntity stockArticleEntity = distributionStockArticleService.getById(orderId);
-				DistributionAppStockArticleVO distributionAppStockArticleVO = Func.copy(stockArticleEntity, DistributionAppStockArticleVO.class);
-				distributionAppStockArticleVO.setTotalNumber(stockArticleEntity.getTotalNumber());
-				distributionAppStockArticleVO.setStockArticleId(stockArticleEntity.getId());
-				distributionAppStockArticleVO.setLoadingNub(0);
+
+			List<DistributionStockArticleEntity> distributionStockArticleEntities = distributionStockArticleService.listByIds(orderIds);
+
+
+
+			List<DistributionReservationStockarticleEntity> reservationOrders = distributionReservationStockarticleService.list(Wrappers.<DistributionReservationStockarticleEntity>query().lambda()
+				.eq(DistributionReservationStockarticleEntity::getReservationId, distributionDeliveryList.getReservationId())
+				.in(DistributionReservationStockarticleEntity::getStockArticleId, orderIds)
+				.ne(DistributionReservationStockarticleEntity::getStockArticleStatus, ReservationOrderStatusConstant.quxiao.getValue())
+			);
+
+			for (DistributionStockArticleEntity distributionStockArticleEntity : distributionStockArticleEntities) {
+
+
+//				DistributionStockArticleEntity stockArticleEntity = distributionStockArticleService.getById(orderId);
+				DistributionAppStockArticleVO distributionAppStockArticleVO = Func.copy(distributionStockArticleEntity, DistributionAppStockArticleVO.class);
+                assert distributionAppStockArticleVO != null;
+                distributionAppStockArticleVO.setLoadingNub(0);
 				distributionAppStockArticleVO.setSignforNub(0);
 				distributionAppStockArticleVO.setReservationNum(0);
 				//查询预约该订单计划数量
-				DistributionReservationStockarticleEntity reservationOrder = distributionReservationStockarticleService.getOne(Wrappers.<DistributionReservationStockarticleEntity>query().lambda()
-					.eq(DistributionReservationStockarticleEntity::getReservationId, distributionDeliveryList.getReservationId())
-					.eq(DistributionReservationStockarticleEntity::getStockArticleId, orderId)
-					.ne(DistributionReservationStockarticleEntity::getStockArticleStatus, ReservationOrderStatusConstant.quxiao.getValue())
-				);
+				DistributionReservationStockarticleEntity reservationOrder = findReservationOrders(reservationOrders, distributionStockArticleEntity.getId());
 				if (Func.isNotEmpty(reservationOrder)) {
 					distributionAppStockArticleVO.setReservationNum(reservationOrder.getReservationNum());
 				}
-				if (stockArticleEntity.getIsZero().equals(IsOrNoConstant.no.getValue())) {
+				if (distributionStockArticleEntity.getIsZero().equals(IsOrNoConstant.no.getValue())) {
 					//判断此订单是是否是异常装车
 
-					if (Func.isEmpty(reservationOrderMap.get(orderId))) {
+					if (Func.isEmpty(reservationOrderMap.get(distributionStockArticleEntity.getId()))) {
 						//不存在计划之中的订单装车
-						List<DistributionLoadscanEntity> loadscanEntityList = loadingOrderMap.get(orderId);
+						List<DistributionLoadscanEntity> loadscanEntityList = loadingOrderMap.get(distributionStockArticleEntity.getId());
 						List<Long> abnormalPackageIds = loadscanEntityList.stream().map(DistributionLoadscanEntity::getPackageId).collect(Collectors.toList());
 						List<DistributionParcelListEntity> distributionParcelListEntities = distributionParcelListService.listByIds(abnormalPackageIds);
 						List<DistributionAppParcelListVO> distributionAppParcelListVOS = DistributionParcelListAppWrapper.build().listVO(distributionParcelListEntities);
@@ -3778,7 +3857,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 						//查询此预约该订单下的包件信息
 						List<DistributionReservationPackageEntity> reservationPackage = distributionReservationPackageService.list(Wrappers.<DistributionReservationPackageEntity>query().lambda()
 							.eq(DistributionReservationPackageEntity::getReservationId, distributionDeliveryList.getReservationId())
-							.eq(DistributionReservationPackageEntity::getStockArticleId, orderId)
+							.eq(DistributionReservationPackageEntity::getStockArticleId, distributionStockArticleEntity.getId())
 							.ne(DistributionReservationPackageEntity::getPacketBarStatus, ReservationPackageStatusConstant.quxiao.getValue())
 						);
 						List<Long> packageIds = new ArrayList<>();
@@ -3788,8 +3867,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 						}
 
 						Map<Long, DistributionLoadscanEntity> collect = null;
-						if (Func.isNotEmpty(loadingOrderMap.get(orderId))) {
-							List<DistributionLoadscanEntity> loadscanEntityList = loadingOrderMap.get(orderId);
+						if (Func.isNotEmpty(loadingOrderMap.get(distributionStockArticleEntity.getId()))) {
+							List<DistributionLoadscanEntity> loadscanEntityList = loadingOrderMap.get(distributionStockArticleEntity.getId());
 							List<Long> loadingPackageIds = loadscanEntityList.stream().map(DistributionLoadscanEntity::getPackageId).collect(Collectors.toList());
 							packageIds.addAll(loadingPackageIds);
 							collect = loadscanEntityList.stream().collect(Collectors.toMap(DistributionLoadscanEntity::getPackageId, Function.identity(), (k1, k2) -> k2));
@@ -3801,11 +3880,13 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 						List<DistributionAppParcelListVO> packageVOS = new ArrayList<>();
 						if (Func.isNotEmpty(packageIds)) {
 							packageIds = packageIds.stream().distinct().collect(Collectors.toList());
-							for (Long packageId : packageIds) {
-								DistributionParcelListEntity parcelListEntity = distributionParcelListService.getById(packageId);
+
+							List<DistributionParcelListEntity> parcelListEntitys = distributionParcelListService.listByIds(packageIds);
+							for (DistributionParcelListEntity parcelListEntity : parcelListEntitys) {
+//								DistributionParcelListEntity parcelListEntity = distributionParcelListService.getById(packageId);
 								DistributionAppParcelListVO distributionAppParcelListVO = DistributionParcelListAppWrapper.build().entityVO(parcelListEntity);
 								if (Func.isNotEmpty(collect)) {
-									DistributionLoadscanEntity distributionLoadscanEntity = collect.get(packageId);
+									DistributionLoadscanEntity distributionLoadscanEntity = collect.get(parcelListEntity.getId());
 									if (Func.isNotEmpty(distributionLoadscanEntity)) {
 										distributionAppParcelListVO.setMaterialName(parcelListEntity.getMaterialName());
 										if (distributionLoadscanEntity.getIsAbnormalLoading().equals(2)) {
@@ -3832,16 +3913,16 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 
 					List<DistributionReservationZeroPackageEntity> reservationZeroPackageEntityList = distributionReservationZeroPackageService.list(Wrappers.<DistributionReservationZeroPackageEntity>query().lambda()
 						.eq(DistributionReservationZeroPackageEntity::getReservationId, distributionDeliveryList.getReservationId())
-						.eq(DistributionReservationZeroPackageEntity::getStockArticleId, orderId)
+						.eq(DistributionReservationZeroPackageEntity::getStockArticleId, distributionStockArticleEntity.getId())
 						.ne(DistributionReservationZeroPackageEntity::getZeroPackageStatus, ReservationPackageStatusConstant.quxiao.getValue()));
 					if (Func.isNotEmpty(reservationZeroPackageEntityList)) {
 						int reservationTotal = reservationZeroPackageEntityList.stream().mapToInt(DistributionReservationZeroPackageEntity::getQuantity).sum();
 						distributionAppStockArticleVO.setReservationNum(reservationTotal);
-						List<DistributionParcelNumberVO> parcelNumberVOS = distributionReservationMapper.selectReservationZeroOrderDetail(orderId, Long.parseLong(distributionDeliveryList.getReservationId()));
+						List<DistributionParcelNumberVO> parcelNumberVOS = distributionReservationMapper.selectReservationZeroOrderDetail(distributionStockArticleEntity.getId(), Long.parseLong(distributionDeliveryList.getReservationId()));
 						distributionAppStockArticleVO.setSignforNub(0);
 						if (Func.isNotEmpty(parcelNumberVOS)) {
 							parcelNumberVOS.forEach(p -> {
-								DistributionLoadscanEntity loadscanEntity = distributionLoadscanService.getOne(Wrappers.<DistributionLoadscanEntity>query().lambda().eq(DistributionLoadscanEntity::getReservationId, distributionDeliveryList.getReservationId()).eq(DistributionLoadscanEntity::getOrderId, orderId).eq(DistributionLoadscanEntity::getPackageId, p.getParcelListId()).ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue()));
+								DistributionLoadscanEntity loadscanEntity = distributionLoadscanService.getOne(Wrappers.<DistributionLoadscanEntity>query().lambda().eq(DistributionLoadscanEntity::getReservationId, distributionDeliveryList.getReservationId()).eq(DistributionLoadscanEntity::getOrderId, distributionStockArticleEntity.getId()).eq(DistributionLoadscanEntity::getPackageId, p.getParcelListId()).ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue()));
 								p.setLoadingNum(0);
 								p.setSigningNum(0);
 								if (Func.isNotEmpty(loadscanEntity)) {
@@ -3866,6 +3947,16 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 
 	}
 
+	/**
+	 * 寻找预约单中订单
+	 * @param reservationOrders
+	 * @param id
+	 * @return
+	 */
+	private DistributionReservationStockarticleEntity findReservationOrders(List<DistributionReservationStockarticleEntity> reservationOrders , Long id) {
+		return reservationOrders.stream().filter(f -> f.getStockArticleId().equals(id)).findFirst().orElse(null);
+	}
+
 
 //			Map<Long, List<DistributionLoadscanEntity>> orderMap = distributionLoadscanEntities.stream().collect(Collectors.groupingBy(DistributionLoadscanEntity::getOrderId));
 //		List<DistributionAppStockArticleVO> distributionAppStockArticleVOS = new ArrayList<>();

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

@@ -310,8 +310,6 @@ public class DistributionStockupServiceImpl extends BaseServiceImpl<Distribution
 			//商  市
 			return baseMapper.pageList(page, distributionStockupEntity);
 		}
-
-
 	}
 
 	@Override

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

@@ -479,7 +479,6 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl<Distrilb
 								if (!list1.isEmpty()) {
 									deliveryDetails.setStockStatus("2");
 								}
-
 							}
 							distributionDeliveryDetailsService.updateById(deliveryDetails);
 						}
@@ -493,8 +492,6 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl<Distrilb
 						deliveryDetails.setStockStatus("1");
 						distributionDeliveryDetailsService.save(deliveryDetails);
 						distributionAsyncService.getInventoryNumUpdate(deliveryDetails.getStockListId(), deliveryDetails.getQuantity(), 1);
-
-
 						//增加
 						List<DisStockListDetailEntity> disStockListDetailEntities = new ArrayList<>();
 						for (int i1 = 0; i1 < deliveryDetails.getQuantity(); i1++) {
@@ -2300,7 +2297,6 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl<Distrilb
 			for (DistrilbutionBillLadingAppVO vo : records) {
 				//有可能存在多个订单所以需要拆分
 				String stockArticleId = vo.getStockArticleId();
-
 				Integer orderNum = 0; //订单总数
 				Integer planNum = 0; //预约数量
 				Integer signedNum = 0; //签收数量
@@ -2400,7 +2396,10 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl<Distrilb
 						Map<String,Object> map = new HashMap<>();
 						map.put("orderPackageCode",p.getOrderPackageCode());
 						map.put("isSign",p.getOrderPackageStatus().equals(OrderPackageStatusConstant.yiqianshou.getValue()));
-						map.put("category",p.getSecond());
+						map.put("thirdProduct",p.getThirdProduct());
+						map.put("fisrt",p.getThirdProduct());
+						map.put("second",p.getSecond());
+						map.put("materiel",p.getMaterialName());
 						map.put("orderId",p.getStockArticleId());
 						map.put("num",p.getQuantity());
 						mapList.add(map);

blade-service/logpm-distribution/src/main/resources/application-test.yml

@@ -78,3 +78,12 @@ spring:
           url: ${blade.datasource.distribution.695224.url}
           username: ${blade.datasource.distribution.695224.username}
           password: ${blade.datasource.distribution.695224.password}
+        645789:
+          druid:
+            #独立校验配置
+            validation-query: select 1
+            #oracle校验
+            #validation-query: select 1 from dual
+          url: ${blade.datasource.distribution.645789.url}
+          username: ${blade.datasource.distribution.645789.username}
+          password: ${blade.datasource.distribution.645789.password}

blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/WaybillFanoutListener.java

@@ -87,6 +87,7 @@ public class WaybillFanoutListener {
 			statisticsTrunklinePackageEntity.setOrderCode(json.getStr("orderCode"));
 			statisticsTrunklinePackageEntity.setOrderPackageCode(json.getStr("orderPackageCode"));
 			statisticsTrunklinePackageEntity.setProductName(json.getStr("productName"));
+			statisticsTrunklinePackageEntity.setProductId(json.getStr("productId"));
 			statisticsTrunklinePackageEntity.setTotalNum(json.getInt("totalNum"));
 			statisticsTrunklinePackageEntity.setTotalWeight(totalWeight);
 			statisticsTrunklinePackageEntity.setTotalVolume(totalVolume);
@@ -135,6 +136,7 @@ public class WaybillFanoutListener {
 			statisticsWarehousePackageEntity.setOrderCode(json.getStr("orderCode"));
 			statisticsWarehousePackageEntity.setOrderPackageCode(json.getStr("orderPackageCode"));
 			statisticsWarehousePackageEntity.setProductName(json.getStr("productName"));
+			statisticsWarehousePackageEntity.setProductId(json.getStr("productId"));
 			statisticsWarehousePackageEntity.setTotalNum(json.getInt("totalNum"));
 			statisticsWarehousePackageEntity.setTotalWeight(totalWeight);
 			statisticsWarehousePackageEntity.setTotalVolume(totalVolume);
@@ -170,6 +172,7 @@ public class WaybillFanoutListener {
 			statisticsDistributionPackageEntity.setOrderCode(json.getStr("orderCode"));
 			statisticsDistributionPackageEntity.setOrderPackageCode(json.getStr("orderPackageCode"));
 			statisticsDistributionPackageEntity.setProductName(json.getStr("productName"));
+			statisticsDistributionPackageEntity.setProductId(json.getStr("productId"));
 			statisticsDistributionPackageEntity.setTotalNum(json.getInt("totalNum"));
 			statisticsDistributionPackageEntity.setTotalWeight(totalWeight);
 			statisticsDistributionPackageEntity.setTotalVolume(totalVolume);

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderAsyncServiceImpl.java

@@ -552,6 +552,7 @@ public class OpenOrderAsyncServiceImpl implements IOpenOrderAsyncService {
 				json.put("orderPackageCode",detail.getProductName());
 				json.put("orderCode",waybillNo);
 				json.put("productName",detail.getProductName());
+				json.put("productId",detail.getProductId());
 				json.put("totalNum",num);
 				json.put("totalWeight",detail.getWeight());
 				json.put("totalVolume",detail.getVolume());

blade-service/logpm-trunkline/src/main/resources/application-test.yml

@@ -59,3 +59,7 @@ spring:
           url: ${blade.datasource.trunkline.695224.url}
           username: ${blade.datasource.trunkline.695224.username}
           password: ${blade.datasource.trunkline.695224.password}
+        645789:
+          url: ${blade.datasource.trunkline.645789.url}
+          username: ${blade.datasource.trunkline.645789.username}
+          password: ${blade.datasource.trunkline.645789.password}

blade-service/logpm-warehouse/src/main/resources/application-test.yml

@@ -33,6 +33,10 @@ spring:
           url: ${blade.datasource.warehouse.695224.url}
           username: ${blade.datasource.warehouse.695224.username}
           password: ${blade.datasource.warehouse.695224.password}
+        645789:
+          url: ${blade.datasource.warehouse.645789.url}
+          username: ${blade.datasource.warehouse.645789.username}
+          password: ${blade.datasource.warehouse.645789.password}
   #rabbitmq配置
   rabbitmq:
     host: 192.168.2.110