|
|
@ -220,7 +220,7 @@ public class DmpCallbackServiceImpl implements DmpCallbackService {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@SneakyThrows(value = ZipException.class)
|
|
|
|
@SneakyThrows(value = ZipException.class)
|
|
|
|
private void downReceptionResource(String bathNo, DeliveryRecord byTaskName, List<String> responseList) {
|
|
|
|
private void downReceptionResource(String bathNo, DeliveryRecord byTaskName, List<List<String>> originalList) {
|
|
|
|
String uuid = IdUtil.fastSimpleUUID();
|
|
|
|
String uuid = IdUtil.fastSimpleUUID();
|
|
|
|
String format = DateUtil.format(DateUtil.date(), DatePattern.NORM_DATE_PATTERN);
|
|
|
|
String format = DateUtil.format(DateUtil.date(), DatePattern.NORM_DATE_PATTERN);
|
|
|
|
String file = deliveryProperties.getFileUrl().concat(StrPool.SLASH).concat(uuid);
|
|
|
|
String file = deliveryProperties.getFileUrl().concat(StrPool.SLASH).concat(uuid);
|
|
|
@ -269,7 +269,7 @@ public class DmpCallbackServiceImpl implements DmpCallbackService {
|
|
|
|
deliveryRecordService.updateStatusByTaskName(DefaultNumberConstants.ONE_NUMBER, stringSet.size(), bathNo);
|
|
|
|
deliveryRecordService.updateStatusByTaskName(DefaultNumberConstants.ONE_NUMBER, stringSet.size(), bathNo);
|
|
|
|
deliveryRecordClient.savePathAndSetDateStr(byTaskName.getUserId(), stringSet.size(), zipPath, downUrl, format, SecurityConstants.FROM_IN);
|
|
|
|
deliveryRecordClient.savePathAndSetDateStr(byTaskName.getUserId(), stringSet.size(), zipPath, downUrl, format, SecurityConstants.FROM_IN);
|
|
|
|
redisUtils.set(CacheKey.DMP_TRIPARTITE_URL.concat(format), zipPath, DefaultNumberConstants.ONE_NUMBER, TimeUnit.DAYS);
|
|
|
|
redisUtils.set(CacheKey.DMP_TRIPARTITE_URL.concat(format), zipPath, DefaultNumberConstants.ONE_NUMBER, TimeUnit.DAYS);
|
|
|
|
redisUtils.set(CacheKey.DMP_TRIPARTITE_NUM.concat(format), responseList.size(), DefaultNumberConstants.ONE_NUMBER, TimeUnit.DAYS);
|
|
|
|
redisUtils.set(CacheKey.DMP_TRIPARTITE_NUM.concat(format), originalList.size(), DefaultNumberConstants.ONE_NUMBER, TimeUnit.DAYS);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private static void aggregateData(InterfaceResponseDTO responseDTO, DeliveryRecord byTaskName,
|
|
|
|
private static void aggregateData(InterfaceResponseDTO responseDTO, DeliveryRecord byTaskName,
|
|
|
|