|
|
@@ -97,6 +97,8 @@ public class CorrforeService extends ServiceImpl<CorrforeStMapper, CorrforeSt> {
|
|
|
if (isFile) {
|
|
|
minioUtilService.downloadObject(bucketName, downfileName, station.getLocalFilePath() + File.separatorChar + downfileName.split("/")[1]);
|
|
|
record.setState(StatusEnum.SUCCESS.getSign());
|
|
|
+ }else{
|
|
|
+ record.setState(StatusEnum.FILE_NULL.getSign());
|
|
|
}
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
@@ -206,6 +208,7 @@ public class CorrforeService extends ServiceImpl<CorrforeStMapper, CorrforeSt> {
|
|
|
/**************检测解析数据完整性*******************/
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
record.setState(StatusEnum.CONNECT_RESPONSE_FORMAT_ERROR.getSign());
|
|
|
record.setStateContent("解析短期或生成文件失败");
|
|
|
log.error("========== 解析短期或生成文件失败 ");
|
|
|
@@ -426,11 +429,11 @@ public class CorrforeService extends ServiceImpl<CorrforeStMapper, CorrforeSt> {
|
|
|
os.write(writer.toString().getBytes("UTF-8"));
|
|
|
os.flush();
|
|
|
} else {
|
|
|
- log.warn(station.getStationCode() + " 生成minlo文件失败");
|
|
|
+ log.warn(station.getStationCode() + " 生成修正DQ文件失败");
|
|
|
}
|
|
|
} catch (IOException e) {
|
|
|
e.printStackTrace();
|
|
|
- log.warn(station.getStationCode() + " 创建minlo文件失败");
|
|
|
+ log.warn(station.getStationCode() + " 创建修正DQ失败");
|
|
|
} finally {
|
|
|
if (os != null) {
|
|
|
try {
|
|
|
@@ -439,6 +442,7 @@ public class CorrforeService extends ServiceImpl<CorrforeStMapper, CorrforeSt> {
|
|
|
log.error("文件生成关闭流失败", e);
|
|
|
}
|
|
|
}
|
|
|
+ log.info("执行生成文件完毕："+station.getLocalFilePath() + File.separatorChar + fileName);
|
|
|
}
|
|
|
|
|
|
}
|
yuanhao