From 3299baa6401189bb6cc24508043609c143c62fe4 Mon Sep 17 00:00:00 2001
From: zhenghaoyu <zhenghaoyu@superbgrace.com>
Date: Fri, 29 Mar 2024 11:22:32 +0800
Subject: [PATCH] =?UTF-8?q?1.=E5=8F=B8=E6=9C=BA=E5=AF=BC=E5=85=A5=E4=BB=93?=
 =?UTF-8?q?=E5=BA=93=E4=BF=A1=E6=81=AFbug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mapper/BasicdataDriverArteryMapper.xml    |  1 +
 .../BasicdataDriverArteryServiceImpl.java     | 45 +++++++++++++++----
 2 files changed, 38 insertions(+), 8 deletions(-)

diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataDriverArteryMapper.xml b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataDriverArteryMapper.xml
index 3769fe9ef..3364c88b2 100644
--- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataDriverArteryMapper.xml
+++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataDriverArteryMapper.xml
@@ -173,6 +173,7 @@
         from logpm_basicdata_driver_artery lbda
         left join logpm_basicdata_driver_warehouse lbdw on lbdw.driver_id = lbda.id
         where lbdw.warehouse_id = #{warehouseId}
+        and lbda.is_deleted = 0
     </select>
 
     <select id="findEntityByPhone" resultType="com.logpm.basicdata.entity.BasicdataDriverArteryEntity">
diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataDriverArteryServiceImpl.java b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataDriverArteryServiceImpl.java
index bf12252ca..a6b14f372 100644
--- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataDriverArteryServiceImpl.java
+++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataDriverArteryServiceImpl.java
@@ -16,6 +16,7 @@
  */
 package com.logpm.basicdata.service.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
@@ -218,15 +219,28 @@ public class BasicdataDriverArteryServiceImpl extends BaseServiceImpl<BasicdataD
 						datum.setCarrierId(basicdataCarrierEntities.get(0).getId());
 					}
 				}
+				List<JSONObject> warehouseList = new ArrayList<>();
 				if (!ObjectUtils.isEmpty(datum.getWarehouseName())) {
-					//在数据库找到仓库名字对应
-					BasicdataWarehouseEntity byName = warehouseClient.findByName(datum.getWarehouseName());
-					if (ObjectUtils.isEmpty(byName)) {
-//					log.error("未找到仓库");
-//					continue;
-						throw new ServiceException("未找到仓库！");
-					} else {
-						datum.setWarehouseId(String.valueOf(byName.getId()));
+					String warehouseNames = datum.getWarehouseName();
+					warehouseNames = warehouseNames.replaceAll("，",",");
+					List<String> warehouseNameList = new ArrayList<>();
+					if(warehouseNames.contains(",")){
+						warehouseNameList = Arrays.asList(warehouseNames.split(","));
+					}else{
+						warehouseNameList.add(warehouseNames);
+					}
+
+					for (String wn : warehouseNameList) {
+						//在数据库找到仓库名字对应
+						BasicdataWarehouseEntity byName = warehouseClient.findByName(wn);
+						if (ObjectUtils.isEmpty(byName)) {
+							throw new ServiceException("未找到仓库！");
+						} else {
+							JSONObject jsonObject = new JSONObject();
+							jsonObject.put("warehouseId",byName.getId());
+							jsonObject.put("warehouseName",wn);
+							warehouseList.add(jsonObject);
+						}
 					}
 				}
 				//根据手机号去重  如果有手机号相同 就删除老数据
@@ -246,6 +260,21 @@ public class BasicdataDriverArteryServiceImpl extends BaseServiceImpl<BasicdataD
 				log.info("复制后>>>>>>>>>>>>{}", copy);
 
 				this.save(copy);
+
+				List<BasicdataDriverWarehouseEntity> driverWarehouseEntities = new ArrayList<>();
+				for (JSONObject jsonObject : warehouseList) {
+					Long warehouseId = jsonObject.getLong("warehouseId");
+					BasicdataDriverWarehouseEntity basicdataDriverWarehouseEntity = new BasicdataDriverWarehouseEntity();
+					basicdataDriverWarehouseEntity.setTenantId(AuthUtil.getTenantId());
+					basicdataDriverWarehouseEntity.setCreateUser(AuthUtil.getUserId());
+					basicdataDriverWarehouseEntity.setUpdateUser(AuthUtil.getUserId());
+					basicdataDriverWarehouseEntity.setCreateDept(Func.firstLong(AuthUtil.getDeptId()));
+					basicdataDriverWarehouseEntity.setDriverId(copy.getId());
+					basicdataDriverWarehouseEntity.setWarehouseId(warehouseId);
+					driverWarehouseEntities.add(basicdataDriverWarehouseEntity);
+				}
+				basicdataDriverWarehouseService.saveBatch(driverWarehouseEntities);
+
 				//车辆和司机绑定关系
 				for (BasicdataDrivermiddleEntity basicdataDrivermiddleEntity : driverMiddleEntity) {
 					basicdataDrivermiddleEntity.setDriverId(copy.getId());