From 9d145836d4469f3fb46387fbae21f1e51d442d8e Mon Sep 17 00:00:00 2001 From: bynt Date: Thu, 13 Apr 2023 13:24:29 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E9=82=AE=E4=BB=B6=E6=94=B6?= =?UTF-8?q?=E5=8F=91=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/baiye/task/MailSourceTask.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/MailSourceTask.java b/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/MailSourceTask.java index 61807fa0..ec19a330 100644 --- a/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/MailSourceTask.java +++ b/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/MailSourceTask.java @@ -159,12 +159,12 @@ public class MailSourceTask { saveClue(taskName, byTaskName, task, taskId, tagList, decryptList, path, unzipPath); } if (byTaskName.getType() == DefaultNumberConstants.THREE_NUMBER) { - sendRequest(taskName, byTaskName, decryptList, path); + sendRequest(taskName, tagList, decryptList, path, unzipPath); } } } if (byTaskName.getType() == DefaultNumberConstants.TWO_NUMBER) { - downResource(taskName, tagList, decryptList, path, unzipPath); + downResource(taskName, byTaskName, decryptList, path); } } } @@ -173,14 +173,14 @@ public class MailSourceTask { } } - private void sendRequest(String taskName, DeliveryRecord byTaskName, List decryptList, String path) { + private void downResource(String taskName, DeliveryRecord byTaskName, List decryptList, String path) { log.info("========================= the path as {} =========================", path); String filePath = path.substring(path.lastIndexOf(StrPool.SLASH) + DefaultNumberConstants.ONE_NUMBER); deliveryRecordService.updateStatusByTaskName(DefaultNumberConstants.ONE_NUMBER, decryptList.size(), taskName); downRecordClient.updatePath(deliveryProperties.getDmpDownPath().concat(filePath), byTaskName.getId(), SecurityConstants.FROM_IN); } - private void downResource(String taskName, List tagList, List decryptList, String path, String unzipPath) { + private void sendRequest(String taskName, List tagList, List decryptList, String path, String unzipPath) { Map map = Maps.newHashMap(); List arrayList = Lists.newArrayList(); DmpResponse dmpResponse = new DmpResponse();