#
chen.lin
22 小时以前 8cc33897f386038a77e94b89109e054e2bb14dd9
#
1个文件已修改
11 ■■■■ 已修改文件
rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java 11 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java
@@ -1908,7 +1908,7 @@
            } catch (org.springframework.web.client.ResourceAccessException e) {
                long endTime = System.currentTimeMillis();
                log.error("========== RCS任务下发资源访问异常 ==========");
                log.error("请求RCS-资源访问异常(可能包含连接超时),耗时:{}ms,任务编码:{}", (endTime - startTime), task.getTaskCode(), e);
                log.error("请求RCS-资源访问异常,耗时:{}ms,任务编码:{}", (endTime - startTime), task.getTaskCode(), e);
                log.error("请求RCS-请求地址:{}", pubTakUrl);
                log.error("请求RCS-请求参数:{}", JSONObject.toJSONString(taskParams));
                // 检查是否是连接超时异常
@@ -1925,16 +1925,15 @@
            } catch (Exception e) {
                long endTime = System.currentTimeMillis();
                log.error("========== RCS任务下发异常 ==========");
                log.error("请求RCS-异常,耗时:{}ms,任务编码:{}", (endTime - startTime), task.getTaskCode(), e);
                log.error("请求RCS-地址:{}", pubTakUrl);
                log.error("请求RCS-参数:{}", JSONObject.toJSONString(taskParams));
                String errorMsg = e.getMessage();
                // 检查是否是连接超时相关的异常
                if (errorMsg != null && (errorMsg.contains("Connection timed out") || errorMsg.contains("timed out") || errorMsg.contains("timeout"))) {
                    log.error("RCS连接超时,任务下发失败!任务编码:{},错误信息:{}", task.getTaskCode(), errorMsg);
                log.error("请求RCS-连接超时异常,耗时:{}ms,任务编码:{},错误信息:{}-{}", (endTime - startTime), task.getTaskCode(), e, errorMsg);
                } else {
                    log.error("RCS任务下发异常!任务编码:{},错误信息:{}", task.getTaskCode(), errorMsg);
                log.error("请求RCS-异常,耗时:{}ms,任务编码:{},错误信息:{}-{}", (endTime - startTime), task.getTaskCode(), e, errorMsg);
                }
                log.error("请求RCS-地址:{}", pubTakUrl);
                log.error("请求RCS-参数:{}", JSONObject.toJSONString(taskParams));
                continue;
            }