对接比亚迪相关接口异常处理.

This commit is contained in:
wangzhijiang
2024-03-12 09:30:55 +08:00
parent ebce167e64
commit 6c553affd6
3 changed files with 89 additions and 70 deletions
@@ -345,6 +345,7 @@ public class DocumentSplitServiceImpl implements IDocumentSplitService {
if(count == -1){
successful = 0;
}
try {
// 推送拆分结果
RestTemplate restTemplate = new RestTemplate();
HttpHeaders headers = new HttpHeaders();
@@ -364,8 +365,13 @@ public class DocumentSplitServiceImpl implements IDocumentSplitService {
ResponseEntity<String> responseEntity = restTemplate.postForEntity(bydSplitResultUrl, requestEntity, String.class);
String body = responseEntity.getBody();
JSONObject jsonObject = JSONObject.parseObject(body);
log.info("拆分结果回调结束=========================================================");
log.info("拆分结果回调结果:" + body);
}catch (Exception ex) {
ex.printStackTrace();
log.error("拆分结果回调结果失败:" + ex.getMessage());
}
log.info("拆分结果回调结束=========================================================");
}
if(count == -1){
@@ -530,6 +530,7 @@ public class OnlyOfficeController {
logger.info("更新基线信息结束==========================================");
logger.info("推送保存基线版本文件信息开始==========================================");
try {
// 推送保存基线版本文件信息
RestTemplate restTemplate = new RestTemplate();
HttpHeaders headers = new HttpHeaders();
@@ -547,18 +548,18 @@ public class OnlyOfficeController {
ResponseEntity<String> responseEntity = restTemplate.postForEntity(bydSaveBaseLineDocIdUrl, requestEntity, String.class);
String body = responseEntity.getBody();
logger.info("推送保存基线版本文件信息结果:" + body);
}catch (Exception ex){
ex.printStackTrace();
logger.error("推送保存基线版本文件信息失败:" + ex.getMessage());
}
logger.info("推送保存基线版本文件信息结束==========================================");
// 将这个文件上传至比亚迪文件系统.并将该接口返回的data中的文件id,更新到该条数据中.
logger.info("基线版本文件上传接口开始==========================================");
try {
RestTemplate restTemplate2 = new RestTemplate();
// // 添加 FormHttpMessageConverter,用于处理文件上传
// List<HttpMessageConverter<?>> messageConverters = new ArrayList<>();
// messageConverters.add(new FormHttpMessageConverter());
// restTemplate2.setMessageConverters(messageConverters);
HttpHeaders headers2 = new HttpHeaders();
headers2.setContentType(MediaType.MULTIPART_FORM_DATA);
@@ -582,6 +583,10 @@ public class OnlyOfficeController {
String data = jsonObject2.getString("data");
createTimeLatestOnlineFileLog.setBydJxFileId(data);
logger.info("基线版本文件上传接口结果:" + body2);
}catch (Exception ex){
ex.printStackTrace();
logger.error("基线版本文件上传失败:" + ex.getMessage());
}
logger.info("基线版本文件上传接口结束==========================================");
this.onlineFileLogDao.updateById(createTimeLatestOnlineFileLog);
@@ -192,6 +192,8 @@ public class FileSpiltService {
}
splitFileIs = MinioUtil.download(readFilePath);
} else {
log.info("下载文档开始=========================================================");
try {
// 根据byd传过来的文件下载路径获取文件。
RestTemplate restTemplate = new RestTemplate();
HttpHeaders headers = new HttpHeaders();
@@ -209,6 +211,12 @@ public class FileSpiltService {
ResponseEntity<byte[]> responseEntity = restTemplate.postForEntity(bydDownLoadFileUrl, requestEntity, byte[].class);
// 获取文件流
splitFileIs = new ByteArrayInputStream(responseEntity.getBody());
}catch (Exception ex){
ex.printStackTrace();
log.error("调用比亚迪下载文档接口失败:" + ex.getMessage());
throw new JeroBootException("调用比亚迪下载文档接口失败!");
}
log.info("下载文档结束=========================================================");
}
try (InputStream is = splitFileIs;InputStream is1 = splitFileIs) {