商家端数据保存、删除

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;//
 

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);
 }

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">

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());
 
 		}
 

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);
 }

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