|
|
|
@ -159,12 +159,12 @@ public class MailSourceTask {
|
|
|
|
|
saveClue(taskName, byTaskName, task, taskId, tagList, decryptList, path, unzipPath);
|
|
|
|
|
}
|
|
|
|
|
if (byTaskName.getType() == DefaultNumberConstants.THREE_NUMBER) {
|
|
|
|
|
sendRequest(taskName, byTaskName, decryptList, path);
|
|
|
|
|
sendRequest(taskName, tagList, decryptList, path, unzipPath);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (byTaskName.getType() == DefaultNumberConstants.TWO_NUMBER) {
|
|
|
|
|
downResource(taskName, tagList, decryptList, path, unzipPath);
|
|
|
|
|
downResource(taskName, byTaskName, decryptList, path);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
@ -173,14 +173,14 @@ public class MailSourceTask {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private void sendRequest(String taskName, DeliveryRecord byTaskName, List<String> decryptList, String path) {
|
|
|
|
|
private void downResource(String taskName, DeliveryRecord byTaskName, List<String> decryptList, String path) {
|
|
|
|
|
log.info("========================= the path as {} =========================", path);
|
|
|
|
|
String filePath = path.substring(path.lastIndexOf(StrPool.SLASH) + DefaultNumberConstants.ONE_NUMBER);
|
|
|
|
|
deliveryRecordService.updateStatusByTaskName(DefaultNumberConstants.ONE_NUMBER, decryptList.size(), taskName);
|
|
|
|
|
downRecordClient.updatePath(deliveryProperties.getDmpDownPath().concat(filePath), byTaskName.getId(), SecurityConstants.FROM_IN);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private void downResource(String taskName, List<String> tagList, List<String> decryptList, String path, String unzipPath) {
|
|
|
|
|
private void sendRequest(String taskName, List<String> tagList, List<String> decryptList, String path, String unzipPath) {
|
|
|
|
|
Map<String, Object> map = Maps.newHashMap();
|
|
|
|
|
List<DmpDataDTO> arrayList = Lists.newArrayList();
|
|
|
|
|
DmpResponse dmpResponse = new DmpResponse();
|
|
|
|
|