|
|
|
@ -443,7 +443,7 @@ public class SpsSyncDownloadService {
|
|
|
|
|
return true;
|
|
|
|
|
}
|
|
|
|
|
try {
|
|
|
|
|
String fileFullPath = writeFile(filePath, BasicExportTypeEnum.BASIC_DATA.getRemark(), JsonUtils.toJsonString(jsonMap));
|
|
|
|
|
String fileFullPath = writeFile(filePath, BasicExportTypeEnum.OTHER_DATA.getRemark(), JsonUtils.toJsonString(jsonMap));
|
|
|
|
|
//计算总数
|
|
|
|
|
int total = 0;
|
|
|
|
|
for (List l : jsonMap.values()) {
|
|
|
|
@ -455,21 +455,21 @@ public class SpsSyncDownloadService {
|
|
|
|
|
.set(BasicExportStatusEntity::getStatus, BasicExportStatusEnum.WAIT_SYNC.getCode())
|
|
|
|
|
.set(BasicExportStatusEntity::getUpdateTime, new Date())
|
|
|
|
|
.set(BasicExportStatusEntity::getCacheFilePath, fileFullPath)
|
|
|
|
|
.set(BasicExportStatusEntity::getRemark, String.format("%s: %s条", BasicExportTypeEnum.BASIC_DATA.getRemark(), total))
|
|
|
|
|
.eq(BasicExportStatusEntity::getType, BasicExportTypeEnum.BASIC_DATA.getRemark())
|
|
|
|
|
.set(BasicExportStatusEntity::getRemark, String.format("%s: %s条", BasicExportTypeEnum.OTHER_DATA.getRemark(), total))
|
|
|
|
|
.eq(BasicExportStatusEntity::getType, BasicExportTypeEnum.OTHER_DATA.getRemark())
|
|
|
|
|
.eq(BasicExportStatusEntity::getStatus, BasicExportStatusEnum.WAIT_BUILT.getCode())
|
|
|
|
|
.isNull(BasicExportStatusEntity::getCacheFilePath)
|
|
|
|
|
);
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
// 异常回滚
|
|
|
|
|
this.exportTimeRollback(totalTimeMap, BasicExportTypeEnum.BASIC_DATA, fileFullPath);
|
|
|
|
|
this.exportTimeRollback(totalTimeMap, BasicExportTypeEnum.OTHER_DATA, fileFullPath);
|
|
|
|
|
}
|
|
|
|
|
return true;
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
logger.error(String.format("syncIdcSps----process------------生成[%s]文件及更改库操作异常,异常信息<%s>"
|
|
|
|
|
, BasicExportTypeEnum.BASIC_DATA.getRemark(), e.getMessage()));
|
|
|
|
|
, BasicExportTypeEnum.OTHER_DATA.getRemark(), e.getMessage()));
|
|
|
|
|
// 异常回滚
|
|
|
|
|
this.exportTimeRollback(totalTimeMap, BasicExportTypeEnum.BASIC_DATA, null);
|
|
|
|
|
this.exportTimeRollback(totalTimeMap, BasicExportTypeEnum.OTHER_DATA, null);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return false;
|
|
|
|
|