From c2554f457599099581785faafd4da8d858be27c2 Mon Sep 17 00:00:00 2001 From: bynt <13586541001@163.com> Date: Mon, 13 Nov 2023 09:41:16 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=BD=E5=8A=A0=E6=95=B0=E9=87=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../baiye/module/service/impl/DmpCallbackServiceImpl.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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 34267f5e..69ca55f8 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 @@ -243,10 +243,13 @@ public class DmpCallbackServiceImpl implements DmpCallbackService { str.get(DefaultNumberConstants.ZERO_NUMBER)).collect(Collectors.toSet()); log.info("=============== the addition the data {} ===============", strings.size()); FileZipUtil.writeToCsv(Lists.newArrayList(strings), parseFile.getPath(), Boolean.TRUE); + Integer size = ObjectUtil.isNotNull(downNum) && ValidationUtil.isInteger(downNum.toString()) ? + Integer.parseInt(downNum.toString()) + strings.size() : strings.size(); // 设置压缩文件 CompressUtil.decryptionCompression(path, parseFile.getPath(), null); deliveryRecordService.updateStatusByTaskName(DefaultNumberConstants.ONE_NUMBER, originalList.size(), bathNo); - deliveryRecordClient.updateOriginAndSize(byTaskName.getUserId(), format, strings.size(), SecurityConstants.FROM_IN); + deliveryRecordClient.updateOriginAndSize(byTaskName.getUserId(), format, size, SecurityConstants.FROM_IN); + redisUtils.set(CacheKey.DMP_TRIPARTITE_NUM.concat(format), size, DefaultNumberConstants.ONE_NUMBER, TimeUnit.DAYS); FileUtil.del(unzipPath); return; }