尝试解决欧派数据推送 重复推送的问题 1.2

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/DistributionErrorQueueHandler.java

@@ -1,6 +1,7 @@
 package com.logpm.distribution.receiver;
 
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
 import com.logpm.distribution.entity.DistributionStockEntity;
 import com.logpm.distribution.service.IDistributionStockService;
 import com.rabbitmq.client.Channel;
@@ -35,6 +36,11 @@ public class DistributionErrorQueueHandler {
 		final long deliveryTag = message.getMessageProperties().getDeliveryTag();
 		try {
 			Long logId = (Long) map.get("logId");
+			if(ObjectUtils.isNull(logId)){
+				// 没有备货任务ID
+				channel.basicAck(deliveryTag, false);
+				return;
+			}
 			UpdateWrapper<DistributionStockEntity> updateWrapper = new UpdateWrapper<>();
 			updateWrapper.set("conditions",2)
 				.eq("id",logId);

blade-service/logpm-distribution/src/test/java/com/logpm/distribution/TestService.java

@@ -1,6 +1,8 @@
 package com.logpm.distribution;
 
+import com.logpm.distribution.dto.DistributionSignforDTO;
 import com.logpm.distribution.service.IDistributionDeliveryListService;
+import com.logpm.distribution.service.IDistributionSignforService;
 import com.logpm.distribution.vo.print.PrintPreviewVO;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
@@ -11,12 +13,15 @@ import org.springframework.beans.factory.annotation.Autowired;
 import java.util.List;
 
 @ExtendWith(BladeSpringExtension.class)
-@BladeBootTest(appName = "logpm-distribution-tjj", enableLoader = true)
+@BladeBootTest(appName = "logpm-distribution-pref", enableLoader = true)
 public class TestService {
 
 	@Autowired
 	private IDistributionDeliveryListService distributionDeliveryListService;
 
+	@Autowired
+	private IDistributionSignforService iDistributionSignforService;
+
 	@Test
 	public void test2() throws Exception {
 
@@ -37,6 +42,17 @@ public class TestService {
 
 
 
+	}
+	@Test
+	public void test4(){
+
+		// 测试推送数据
+		DistributionSignforDTO dto = new DistributionSignforDTO();
+		iDistributionSignforService.updateSign(dto);
+
+
+
+
 	}
 
 }