|
|
|
@ -42,14 +42,14 @@ public class AmpliDownloadTask {
|
|
|
|
|
public void downloadAll() {
|
|
|
|
|
List<RemoteConfig> configList = configService.listAll();
|
|
|
|
|
if (!CollectionUtils.isEmpty(configList)) {
|
|
|
|
|
log.info("SftpDownloadTask.downloadAll 开始.");
|
|
|
|
|
log.info("AmpliDownloadTask.downloadAll 开始.");
|
|
|
|
|
try {
|
|
|
|
|
for (RemoteConfig config : configList) {
|
|
|
|
|
this.downloadServer(config);
|
|
|
|
|
}
|
|
|
|
|
log.info("SftpDownloadTask.downloadAll 结束.");
|
|
|
|
|
log.info("AmpliDownloadTask.downloadAll 结束.");
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("SftpDownloadTask.downloadAll error.", e);
|
|
|
|
|
log.error("AmpliDownloadTask.downloadAll error.", e);
|
|
|
|
|
String str = "SFTP下载文件异常: " + e.getMessage();
|
|
|
|
|
webSocketServer.sendMessage(str);
|
|
|
|
|
dingTalkPushUtil.pushText(str);
|
|
|
|
@ -74,7 +74,7 @@ public class AmpliDownloadTask {
|
|
|
|
|
this.downloadPath(remotePath, config, sftpTool);
|
|
|
|
|
}
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error("SftpDownloadTask.downloadServer error.", e);
|
|
|
|
|
log.error("AmpliDownloadTask.downloadServer error.", e);
|
|
|
|
|
String str = "SFTP下载文件异常: " + e.getMessage();
|
|
|
|
|
webSocketServer.sendMessage(str);
|
|
|
|
|
dingTalkPushUtil.pushText(str);
|
|
|
|
|