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