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;
         }