From 754171542b923911569d58dd1a9f4c73e1eb52ef Mon Sep 17 00:00:00 2001
From: PigBaoBei <2739175034@qq.com>
Date: Thu, 16 May 2024 10:46:47 +0800
Subject: [PATCH 1/2] =?UTF-8?q?=E5=95=86=E5=AE=B6=E7=AB=AF=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E4=BF=9D=E5=AD=98=E3=80=81=E5=88=A0=E9=99=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../DistributionBusinessPreOrderEntity.java   |  3 ++
 .../DistributionBusinessPreOrderMapper.java   |  7 +++
 .../DistributionBusinessPreOrderMapper.xml    |  8 ++++
 .../BusinessPreOrderDataQueueHandler.java     | 47 +++++++++++++++----
 .../IDistributionBusinessPreOrderService.java | 12 ++++-
 ...stributionBusinessPreOrderServiceImpl.java |  6 +++
 6 files changed, 71 insertions(+), 12 deletions(-)

diff --git a/blade-service-api/logpm-business-conversion-api/src/main/java/com/logpm/business/entity/DistributionBusinessPreOrderEntity.java b/blade-service-api/logpm-business-conversion-api/src/main/java/com/logpm/business/entity/DistributionBusinessPreOrderEntity.java
index 7e6360ac3..0a329e679 100644
--- a/blade-service-api/logpm-business-conversion-api/src/main/java/com/logpm/business/entity/DistributionBusinessPreOrderEntity.java
+++ b/blade-service-api/logpm-business-conversion-api/src/main/java/com/logpm/business/entity/DistributionBusinessPreOrderEntity.java
@@ -267,6 +267,9 @@ public class DistributionBusinessPreOrderEntity extends TenantEntity {
 	@ApiModelProperty(value = "配送车次号")
 	private String distrCarNumber;
 
+	@ApiModelProperty(value = "预约单号")
+	private String reservationCode;
+
 	@ApiModelProperty(value = "是否入库 0 没有入库  1 已入库")
 	private Integer inWarehouse;//
 
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionBusinessPreOrderMapper.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionBusinessPreOrderMapper.java
index c09d49906..98de031f8 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionBusinessPreOrderMapper.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionBusinessPreOrderMapper.java
@@ -50,4 +50,11 @@ public interface DistributionBusinessPreOrderMapper extends BaseMapper<Distribut
 	 */
     IPage<DistributionBusinessPreOrderVO> pageList(IPage<DistributionBusinessPreOrderVO> page, DistributionBusinessPreOrderDTO param);
 
+	/**
+	 * 删除商家端数据
+	 * @param k
+	 * @param deletedPackageList
+	 * @return
+	 */
+    Integer deleteBusinessPreOrder(String reservationCode, List<String> deletedPackageList);
 }
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionBusinessPreOrderMapper.xml b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionBusinessPreOrderMapper.xml
index 1b2e5308a..5f44b8143 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionBusinessPreOrderMapper.xml
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionBusinessPreOrderMapper.xml
@@ -1,6 +1,14 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.logpm.distribution.mapper.DistributionBusinessPreOrderMapper">
+    <delete id="deleteBusinessPreOrder">
+        DELETE FROM logpm_business_pre_order WHERE reservation_code = #{reservationCode}
+        AND order_package_code IN
+        <foreach
+        collection="orderPackageList" item="orderPackageCode" open="(" separator="," close=")">
+            #{orderPackageCode}
+        </foreach>
+    </delete>
 
 
     <select id="pageList" resultType="com.logpm.business.vo.DistributionBusinessPreOrderVO">
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/BusinessPreOrderDataQueueHandler.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/BusinessPreOrderDataQueueHandler.java
index 39f6cb357..47eafaa34 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/BusinessPreOrderDataQueueHandler.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/BusinessPreOrderDataQueueHandler.java
@@ -14,6 +14,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springblade.common.constant.RabbitConstant;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.BeanUtil;
+import org.springblade.core.tool.utils.Func;
 import org.springblade.core.tool.utils.ObjectUtil;
 import org.springblade.system.entity.Tenant;
 import org.springblade.system.feign.ISysClient;
@@ -25,6 +26,8 @@ import org.springframework.stereotype.Component;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
 
 @Slf4j
 @RabbitListener(queues = RabbitConstant.BUSINESS_PRE_CONVERSION_DATA_QUEUE)
@@ -114,7 +117,7 @@ public class BusinessPreOrderDataQueueHandler {
 	}
 
 	public void saveOtherDataBase(List<DistributionBusinessPreOrderEntity> dataResult, String maillName) {
-
+		String method = "########################saveOtherDataBase";
 		R<Tenant> tenantByName = sysClient.getTenantByName(maillName);
 		if(tenantByName.isSuccess()){
 			Tenant tenant = tenantByName.getData();
@@ -122,18 +125,42 @@ public class BusinessPreOrderDataQueueHandler {
 				log.info(">>>>>>>>>>>>> BusinessPreOrderDataQueueHandler 租户不存在");
 				return;
 			}
-
-			for (DistributionBusinessPreOrderEntity distributionBusinessPreOrderEntity : dataResult) {
-				distributionBusinessPreOrderEntity.setTenantId(tenant.getTenantId());
+			if (dataResult.isEmpty()) {
+				log.info(method+"dataResult 参数错误");
 			}
+			Map<Integer, List<DistributionBusinessPreOrderEntity>> map = dataResult.stream().collect(Collectors.groupingBy(DistributionBusinessPreOrderEntity::getInWarehouse));
+			if (Func.isNotEmpty(map.get(1))){
+				//存在需要进行删除的数据
+				List<DistributionBusinessPreOrderEntity> deleteList = map.get(1);
+				if (!deleteList.isEmpty()) {
+					Map<String, List<DistributionBusinessPreOrderEntity>> deletedMap = deleteList.stream().collect(Collectors.groupingBy(DistributionBusinessPreOrderEntity::getReservationCode));
+					deletedMap.forEach((k,v)->{
+						List<String> deletedPackageList = v.stream().map(DistributionBusinessPreOrderEntity::getOrderPackageCode).collect(Collectors.toList());
+						log.info("删除商家端数据>>>>reservationCode:{}",deletedPackageList);
+						if (!deletedPackageList.isEmpty()){
+							//进行删除
+							Integer row = distributionBusinessPreOrderService.deleteBusinessPreOrder(k,deletedPackageList);
+							log.info("删除商家端数据>>>>row:{}",row);
+						}
+					});
+				}
+			}
+			if (Func.isNotEmpty(map.get(2))){
+				//存在可能变更的数据
+				List<DistributionBusinessPreOrderEntity> mapList =  map.get(2);
+				for (DistributionBusinessPreOrderEntity distributionBusinessPreOrderEntity : mapList) {
+					distributionBusinessPreOrderEntity.setTenantId(tenant.getTenantId());
 
-			DynamicDataSourceContextHolder.push(tenant.getTenantId());
-
-			List<DistributionBusinessPreOrderEntity> list = distributionBusinessPreOrderService.list();
-
-			distributionBusinessPreOrderService.saveBatch(dataResult);
-			DynamicDataSourceContextHolder.poll();
+				}
+				DynamicDataSourceContextHolder.push(tenant.getTenantId());
+				distributionBusinessPreOrderService.saveBatch(mapList);
+				DynamicDataSourceContextHolder.poll();
+			}
 
+//			for (DistributionBusinessPreOrderEntity distributionBusinessPreOrderEntity : dataResult) {
+//				distributionBusinessPreOrderEntity.setTenantId(tenant.getTenantId());
+//			}
+//			DynamicDataSourceContextHolder.push(tenant.getTenantId());
 
 		}
 
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionBusinessPreOrderService.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionBusinessPreOrderService.java
index 7b0ce2add..9ab11b7f6 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionBusinessPreOrderService.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionBusinessPreOrderService.java
@@ -7,6 +7,7 @@ import com.logpm.distribution.entity.DistributionBillLadingScanEntity;
 import org.springblade.core.mp.base.BaseService;
 import org.springblade.core.mp.support.Query;
 
+import java.util.List;
 import java.util.Map;
 
 public interface IDistributionBusinessPreOrderService extends BaseService<DistributionBusinessPreOrderEntity> {
@@ -20,10 +21,17 @@ public interface IDistributionBusinessPreOrderService extends BaseService<Distri
 
 	/**
 	 * 查询DistributionBusinessPreOrder列表
-	 * @param distributionBusinessPreOrderEntity
-	 * @param query
+	 * @param distributionBusinessPreOrderDTO
+	 * @param page
 	 * @return
 	 */
 	IPage<DistributionBusinessPreOrderVO> pacgeList(Map<String, Object> distributionBusinessPreOrderDTO, IPage<DistributionBusinessPreOrderVO> page);
 
+	/**
+	 * 删除商家端数据
+	 * @param k
+	 * @param deletedPackageList
+	 * @return
+	 */
+	Integer deleteBusinessPreOrder(String k, List<String> deletedPackageList);
 }
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/IDistributionBusinessPreOrderServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/IDistributionBusinessPreOrderServiceImpl.java
index 60e2dfb64..1123a4259 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/IDistributionBusinessPreOrderServiceImpl.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/IDistributionBusinessPreOrderServiceImpl.java
@@ -38,6 +38,12 @@ public class IDistributionBusinessPreOrderServiceImpl extends BaseServiceImpl<Di
 		return baseMapper.pageList(page,param);
 	}
 
+	@Override
+	public Integer deleteBusinessPreOrder(String k, List<String> deletedPackageList) {
+
+		return baseMapper.deleteBusinessPreOrder(k,deletedPackageList);
+	}
+
 	/**
 	 * 处理包条码到当前租户对应的数据库
 	 * @param codes

From 49992551c9f8ef4b98cad6741910413c04296f29 Mon Sep 17 00:00:00 2001
From: PigBaoBei <2739175034@qq.com>
Date: Thu, 16 May 2024 11:17:11 +0800
Subject: [PATCH 2/2] =?UTF-8?q?=E5=95=86=E5=AE=B6=E7=AB=AF=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E4=BF=9D=E5=AD=98=E5=92=8C=E5=88=A0=E9=99=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../BusinessPreOrderDataQueueHandler.java     | 38 +++++++++++++------
 1 file changed, 27 insertions(+), 11 deletions(-)

diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/BusinessPreOrderDataQueueHandler.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/BusinessPreOrderDataQueueHandler.java
index 47eafaa34..8e3678f35 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/BusinessPreOrderDataQueueHandler.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/BusinessPreOrderDataQueueHandler.java
@@ -2,6 +2,7 @@ package com.logpm.distribution.receiver;
 
 import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.logpm.business.entity.DistributionBusinessPreOrderEntity;
 import com.logpm.distribution.entity.DistributionDeliveryListEntity;
 import com.logpm.distribution.entity.DistributionParcelListEntity;
@@ -128,6 +129,7 @@ public class BusinessPreOrderDataQueueHandler {
 			if (dataResult.isEmpty()) {
 				log.info(method+"dataResult 参数错误");
 			}
+			DynamicDataSourceContextHolder.push(tenant.getTenantId());
 			Map<Integer, List<DistributionBusinessPreOrderEntity>> map = dataResult.stream().collect(Collectors.groupingBy(DistributionBusinessPreOrderEntity::getInWarehouse));
 			if (Func.isNotEmpty(map.get(1))){
 				//存在需要进行删除的数据
@@ -148,19 +150,33 @@ public class BusinessPreOrderDataQueueHandler {
 			if (Func.isNotEmpty(map.get(2))){
 				//存在可能变更的数据
 				List<DistributionBusinessPreOrderEntity> mapList =  map.get(2);
-				for (DistributionBusinessPreOrderEntity distributionBusinessPreOrderEntity : mapList) {
-					distributionBusinessPreOrderEntity.setTenantId(tenant.getTenantId());
-
+				Map<String, List<DistributionBusinessPreOrderEntity>> saveData = mapList.stream().collect(Collectors.groupingBy(DistributionBusinessPreOrderEntity::getReservationCode));
+				List<DistributionBusinessPreOrderEntity> existData= new ArrayList<>();
+				if (!saveData.isEmpty()) {
+					//查询是否存在重复
+					saveData.forEach((k,v)->{
+						List<DistributionBusinessPreOrderEntity> list = distributionBusinessPreOrderService.list(Wrappers.<DistributionBusinessPreOrderEntity>query().lambda()
+							.eq(DistributionBusinessPreOrderEntity::getReservationCode, k)
+							.in(DistributionBusinessPreOrderEntity::getOrderPackageCode, v.stream().map(DistributionBusinessPreOrderEntity::getOrderPackageCode).collect(Collectors.toList()))
+						);
+						if (!list.isEmpty()) {
+							//已经存在数据
+							existData.addAll(list);
+						}
+					});
+				}
+				if (!existData.isEmpty()){
+					//二者比较取差集
+					mapList = mapList.stream().filter(m -> !existData.stream().map(DistributionBusinessPreOrderEntity::getOrderPackageCode).collect(Collectors.toList()).contains(m.getOrderPackageCode())).collect(Collectors.toList());
+				}
+				if (!mapList.isEmpty()){
+					for (DistributionBusinessPreOrderEntity distributionBusinessPreOrderEntity : mapList) {
+						distributionBusinessPreOrderEntity.setTenantId(tenant.getTenantId());
+					}
+					distributionBusinessPreOrderService.saveBatch(mapList);
 				}
-				DynamicDataSourceContextHolder.push(tenant.getTenantId());
-				distributionBusinessPreOrderService.saveBatch(mapList);
-				DynamicDataSourceContextHolder.poll();
 			}
-
-//			for (DistributionBusinessPreOrderEntity distributionBusinessPreOrderEntity : dataResult) {
-//				distributionBusinessPreOrderEntity.setTenantId(tenant.getTenantId());
-//			}
-//			DynamicDataSourceContextHolder.push(tenant.getTenantId());
+			DynamicDataSourceContextHolder.poll();
 
 		}