修改发送数量

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<TaskImei> downList, Long updateId) {

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<Map<Long, String>> resourceList = clueService.queryUnconvertedResource
-                (DefaultNumberConstants.ZERO_NUMBER, DefaultNumberConstants.FIVE_THOUSAND);
+                (DefaultNumberConstants.ZERO_NUMBER, DefaultNumberConstants.TEN_THOUSAND);
         if (CollUtil.isNotEmpty(resourceList)) {
             // 对应转换
             List<QueryClueDTO> list = Convert.toList(QueryClueDTO.class, resourceList);

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<String> tagList, List<String> decryptList, String path, String unzipPath) {
+    private void saveClue(String taskName, DeliveryRecord byTaskName, Task task, Long taskId, List<String> tagList, List<String> decryptList, String path, String unzipPath, File parseFile) {
         List<String> isNotblackList = IsBlackUtil.getNotblackList(decryptList);
         // 将imei转为线索
         Integer saveNumer = clueService.saveClue