|
|
@ -243,10 +243,13 @@ public class DmpCallbackServiceImpl implements DmpCallbackService {
|
|
|
|
str.get(DefaultNumberConstants.ZERO_NUMBER)).collect(Collectors.toSet());
|
|
|
|
str.get(DefaultNumberConstants.ZERO_NUMBER)).collect(Collectors.toSet());
|
|
|
|
log.info("=============== the addition the data {} ===============", strings.size());
|
|
|
|
log.info("=============== the addition the data {} ===============", strings.size());
|
|
|
|
FileZipUtil.writeToCsv(Lists.newArrayList(strings), parseFile.getPath(), Boolean.TRUE);
|
|
|
|
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);
|
|
|
|
CompressUtil.decryptionCompression(path, parseFile.getPath(), null);
|
|
|
|
deliveryRecordService.updateStatusByTaskName(DefaultNumberConstants.ONE_NUMBER, originalList.size(), bathNo);
|
|
|
|
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);
|
|
|
|
FileUtil.del(unzipPath);
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|