From 2b36f99c273afa78432abb1bc13a74bc60d9e7de Mon Sep 17 00:00:00 2001 From: bynt Date: Mon, 5 Jun 2023 11:30:03 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=8F=91=E9=80=81=E6=95=B0?= =?UTF-8?q?=E9=87=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/baiye/timed/DeliveryBalanceTask.java | 2 ++ .../src/main/java/com/baiye/task/GenderConversionTask.java | 2 +- .../src/main/java/com/baiye/task/MailSourceTask.java | 4 ++-- 3 files changed, 5 insertions(+), 3 deletions(-) diff --git a/ad-platform-manage/ad-platform-management/src/main/java/com/baiye/timed/DeliveryBalanceTask.java b/ad-platform-manage/ad-platform-management/src/main/java/com/baiye/timed/DeliveryBalanceTask.java index 03506131..ae695eaa 100644 --- a/ad-platform-manage/ad-platform-management/src/main/java/com/baiye/timed/DeliveryBalanceTask.java +++ b/ad-platform-manage/ad-platform-management/src/main/java/com/baiye/timed/DeliveryBalanceTask.java @@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollUtil; import cn.hutool.core.convert.Convert; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; +import cn.hutool.core.io.FileUtil; import cn.hutool.core.text.CharSequenceUtil; import cn.hutool.core.text.StrPool; import cn.hutool.core.util.IdUtil; @@ -240,6 +241,7 @@ public class DeliveryBalanceTask { zipPath, filePath, DefaultNumberConstants.ONE_NUMBER); // 修改状态 taskImeiService.updateBath(taskId, CharSequenceUtil.EMPTY, DefaultNumberConstants.ONE_NUMBER, minId, maxId); + FileUtil.del(csvPath); } private static Long getaLong(Optional downList, Long updateId) { diff --git a/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/GenderConversionTask.java b/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/GenderConversionTask.java index 476c4eb9..a35f055e 100644 --- a/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/GenderConversionTask.java +++ b/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/GenderConversionTask.java @@ -61,7 +61,7 @@ public class GenderConversionTask { String fileUrl = deliveryProperties.getFileUrl(); // 单次查询10000 List> resourceList = clueService.queryUnconvertedResource - (DefaultNumberConstants.ZERO_NUMBER, DefaultNumberConstants.FIVE_THOUSAND); + (DefaultNumberConstants.ZERO_NUMBER, DefaultNumberConstants.TEN_THOUSAND); if (CollUtil.isNotEmpty(resourceList)) { // 对应转换 List list = Convert.toList(QueryClueDTO.class, resourceList); 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 71db4ed3..737f1d48 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 @@ -128,7 +128,7 @@ public class MailSourceTask { log.info("=================== the decryptList size as {} =====================", decryptList.size()); if (byTaskName.getType() == DefaultNumberConstants.ONE_NUMBER) { CommonLog.info("接收邮件,当前tag值为".concat(tagList.get(DefaultNumberConstants.ZERO_NUMBER))); - saveClue(taskName, byTaskName, task, taskId, tagList, decryptList, path, unzipPath); + saveClue(taskName, byTaskName, task, taskId, tagList, decryptList, path, unzipPath, parseFile); } if (byTaskName.getType() == DefaultNumberConstants.TWO_NUMBER) { downResource(taskName, byTaskName, decryptList, path, data.getRows(), parseFile); @@ -168,7 +168,7 @@ public class MailSourceTask { log.info("============== message parsing succeeded file path as {} unzip path as {} ===============", path, unzipPath); } - private void saveClue(String taskName, DeliveryRecord byTaskName, Task task, Long taskId, List tagList, List decryptList, String path, String unzipPath) { + private void saveClue(String taskName, DeliveryRecord byTaskName, Task task, Long taskId, List tagList, List decryptList, String path, String unzipPath, File parseFile) { List isNotblackList = IsBlackUtil.getNotblackList(decryptList); // 将imei转为线索 Integer saveNumer = clueService.saveClue