From 51ef60e5b65b3a00c4d9697a01c976997539fccc Mon Sep 17 00:00:00 2001 From: bynt <13586541001@163.com> Date: Mon, 13 Nov 2023 09:54:23 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BC=82=E6=AD=A5=E6=96=B9=E5=BC=8F=E5=8F=91?= =?UTF-8?q?=E9=80=81=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../module/service/impl/DmpCallbackServiceImpl.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/ad-platform-services/ad-platform-source/src/main/java/com/baiye/module/service/impl/DmpCallbackServiceImpl.java b/ad-platform-services/ad-platform-source/src/main/java/com/baiye/module/service/impl/DmpCallbackServiceImpl.java index 69ca55f8..8778f6f4 100644 --- a/ad-platform-services/ad-platform-source/src/main/java/com/baiye/module/service/impl/DmpCallbackServiceImpl.java +++ b/ad-platform-services/ad-platform-source/src/main/java/com/baiye/module/service/impl/DmpCallbackServiceImpl.java @@ -47,6 +47,7 @@ import java.io.File; import java.util.List; import java.util.Objects; import java.util.Set; +import java.util.concurrent.CompletableFuture; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; @@ -118,10 +119,12 @@ public class DmpCallbackServiceImpl implements DmpCallbackService { saveClue(bathNo, byTaskName, taskId, tagList, responseList); } if (byTaskName.getType() == DefaultNumberConstants.TWO_NUMBER) { - downResource(bathNo, byTaskName, originalList, responseList); + // 异步方式下载 + List finalResponseList = responseList; + CompletableFuture.runAsync(() -> downResource(bathNo, byTaskName, originalList, finalResponseList)); } if (byTaskName.getType() == DefaultNumberConstants.FOUR_NUMBER) { - downReceptionResource(bathNo, byTaskName, originalList); + CompletableFuture.runAsync(() -> downReceptionResource(bathNo, byTaskName, originalList)); } } // 兑换结果失败也将结果返回 @@ -220,7 +223,7 @@ public class DmpCallbackServiceImpl implements DmpCallbackService { } @SneakyThrows(value = ZipException.class) - private void downReceptionResource(String bathNo, DeliveryRecord byTaskName, List> originalList) { + private void downReceptionResource(String bathNo, DeliveryRecord byTaskName, List> originalList) { String uuid = IdUtil.fastSimpleUUID(); String format = DateUtil.format(DateUtil.date(), DatePattern.NORM_DATE_PATTERN); String file = deliveryProperties.getFileUrl().concat(StrPool.SLASH).concat(uuid);