summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorwangwei <[email protected]>2022-11-28 11:23:39 +0800
committerwangwei <[email protected]>2023-03-14 16:57:17 +0800
commit85bd4e26276eee10e5d8d9a12c0938b184f46854 (patch)
treee35c3dcd82ff0d3dfb8372be5f66a3e21b3f723b
parentf33a01ca54840b637572c13ddc8a9b50582c4552 (diff)
fix(knowledge): 避免下载失败覆盖本地正常文件
-rw-r--r--src/main/java/com/mesalab/qgw/listener/KnowledgeListener.java4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/main/java/com/mesalab/qgw/listener/KnowledgeListener.java b/src/main/java/com/mesalab/qgw/listener/KnowledgeListener.java
index fc3f87f4..4b92793b 100644
--- a/src/main/java/com/mesalab/qgw/listener/KnowledgeListener.java
+++ b/src/main/java/com/mesalab/qgw/listener/KnowledgeListener.java
@@ -137,6 +137,10 @@ public class KnowledgeListener {
try {
Header header = new BasicHeader(KnowledgeConstant.TOKEN, hosConfig.getToken());
inputStream = httpClientService.httpGetInputStream(knowledgeBase.getPath(), httpConfig.getServerResponseTimeOut(), header);
+ if (inputStream == null) {
+ log.error("download file error, skip this update, knowledge is: {}", knowledgeBase);
+ return;
+ }
outputStream = new FileOutputStream(KnowledgeConstant.DAT.concat(File.separator).concat(knowledgeBase.getName()).concat(".").concat(knowledgeBase.getFormat()));
IoUtil.copy(inputStream, outputStream);
log.info("knowledge download name: {}, version: {}", knowledgeBase.getName(), knowledgeBase.getVersion());