Przeglądaj źródła

飞书看课-优化飞书记录错误日志2

cgp 5 dni temu
rodzic
commit
92cc1c1db3

+ 6 - 2
fs-admin/src/main/java/com/fs/his/task/Task.java

@@ -3431,9 +3431,11 @@ public class Task {
                         log.warn("个人账号[{}]被禁用,尝试下一个", account.getAppId());
                     } else if (code != null && (FeishuErrorCode.isRateLimit(code) || FeishuErrorCode.isInternalRetryable(code))) {
                         log.warn("个人账号[{}]可重试错误,切换下一个", account.getAppId());
-                    } else {
+                    } else if (code != null) {
                         recordLinkError(video.getVideoId(), companyId, video.getCourseId(), companyUserId, "定时生成的缓存docId", e.getMessage(), 1, code);
                         return null;
+                    } else {
+                        log.warn("个人账号[{}]临时异常,切换下一个: {}", account.getAppId(), e.getMessage());
                     }
                 }
             }
@@ -3458,9 +3460,11 @@ public class Task {
                     log.warn("公共账号被禁用,尝试下一个");
                 } else if (code != null && (FeishuErrorCode.isRateLimit(code) || FeishuErrorCode.isInternalRetryable(code))) {
                     log.warn("公共账号可重试错误,切换下一个");
-                } else {
+                } else if (code != null) {
                     recordLinkError(video.getVideoId(), companyId, video.getCourseId(), companyUserId, "定时生成的缓存docId", e.getMessage(), 1, code);
                     return null;
+                } else {
+                    log.warn("公共账号临时异常,切换下一个: {}", e.getMessage());
                 }
             }
         }

+ 6 - 2
fs-qw-task/src/main/java/com/fs/app/taskService/impl/SopLogsTaskServiceImpl.java

@@ -1892,9 +1892,11 @@ public class SopLogsTaskServiceImpl implements SopLogsTaskService {
                         log.warn("个人账号[{}]被禁用,尝试下一个", account.getAppId());
                     } else if (code != null && (FeishuErrorCode.isRateLimit(code) || FeishuErrorCode.isInternalRetryable(code))) {
                         log.warn("个人账号[{}]可重试错误,切换下一个", account.getAppId());
-                    } else {
+                    } else if (code != null) {
                         recordLinkError(video.getVideoId(), companyId, video.getCourseId(), companyUserId, "定时生成的缓存docId", e.getMessage(), 1, code);
                         return null;
+                    } else {
+                        log.warn("个人账号[{}]临时异常,切换下一个: {}", account.getAppId(), e.getMessage());
                     }
                 }
             }
@@ -1919,9 +1921,11 @@ public class SopLogsTaskServiceImpl implements SopLogsTaskService {
                     log.warn("公共账号被禁用,尝试下一个");
                 } else if (code != null && (FeishuErrorCode.isRateLimit(code) || FeishuErrorCode.isInternalRetryable(code))) {
                     log.warn("公共账号可重试错误,切换下一个");
-                } else {
+                } else if (code != null) {
                     recordLinkError(video.getVideoId(), companyId, video.getCourseId(), companyUserId, "定时生成的缓存docId", e.getMessage(), 1, code);
                     return null;
+                } else {
+                    log.warn("公共账号临时异常,切换下一个: {}", e.getMessage());
                 }
             }
         }

+ 20 - 4
fs-service/src/main/java/com/fs/feishu/service/FeiShuService.java

@@ -166,10 +166,14 @@ public class FeiShuService {
                         log.warn("个人账号[{}]被禁用,尝试下一个", account.getAppId());
                     } else if (code != null && (FeishuErrorCode.isRateLimit(code) || FeishuErrorCode.isInternalRetryable(code))) {
                         log.warn("个人账号[{}]可重试错误,切换下一个", account.getAppId());
-                    } else {
+                    } else if (code != null) {
+                        // 明确的业务错误码,终止
                         recordLinkError(param.getVideoId(), param.getCompanyId(), param.getCourseId(),
                                 param.getCompanyUserId(), param.getLink(), e.getMessage(), 2, code);
                         return null;
+                    } else {
+                        // code == null,SDK/网络层临时异常,换账号重试
+                        log.warn("个人账号[{}]临时异常,切换下一个: {}", account.getAppId(), e.getMessage());
                     }
                 }
             }
@@ -205,10 +209,14 @@ public class FeiShuService {
                     log.warn("公共账号被禁用,尝试下一个");
                 } else if (code != null && (FeishuErrorCode.isRateLimit(code) || FeishuErrorCode.isInternalRetryable(code))) {
                     log.warn("公共账号可重试错误,切换下一个");
-                } else {
+                } else if (code != null) {
+                    // 明确的业务错误码,终止
                     recordLinkError(param.getVideoId(), param.getCompanyId(), param.getCourseId(),
                             param.getCompanyUserId(), param.getLink(), e.getMessage(), 2, code);
                     return null;
+                } else {
+                    // code == null,SDK/网络层临时异常,换账号重试
+                    log.warn("公共账号临时异常,切换下一个: {}", e.getMessage());
                 }
             }
         }
@@ -263,10 +271,14 @@ public class FeiShuService {
                         log.warn("个人账号[{}]被禁用,尝试下一个", account.getAppId());
                     } else if (code != null && (FeishuErrorCode.isRateLimit(code) || FeishuErrorCode.isInternalRetryable(code))) {
                         log.warn("个人账号[{}]可重试错误,切换下一个", account.getAppId());
-                    } else {
+                    } else if (code != null) {
+                        // 明确的业务错误码,终止
                         recordLinkError(param.getVideoId(), param.getCompanyId(), param.getCourseId(),
                                 param.getCompanyUserId(), param.getLink(), e.getMessage(), 2, code);
                         throw new CustomException(e.getMessage());
+                    } else {
+                        // code == null,SDK/网络层临时异常,换账号重试
+                        log.warn("个人账号[{}]临时异常,切换下一个: {}", account.getAppId(), e.getMessage());
                     }
                 }
             }
@@ -295,10 +307,14 @@ public class FeiShuService {
                     log.warn("公共账号被禁用,尝试下一个");
                 } else if (code != null && (FeishuErrorCode.isRateLimit(code) || FeishuErrorCode.isInternalRetryable(code))) {
                     log.warn("公共账号可重试错误,切换下一个");
-                } else {
+                } else if (code != null) {
+                    // 明确的业务错误码,终止
                     recordLinkError(param.getVideoId(), param.getCompanyId(), param.getCourseId(),
                             param.getCompanyUserId(), param.getLink(), e.getMessage(), 2, code);
                     throw new CustomException(e.getMessage());
+                } else {
+                    // code == null,SDK/网络层临时异常,换账号重试
+                    log.warn("公共账号临时异常,切换下一个: {}", e.getMessage());
                 }
             }
         }