From d36d06ce89c06637acd622d77cb52208b3d03c10 Mon Sep 17 00:00:00 2001
From: YXY <932687738@qq.com>
Date: Mon, 31 Jul 2023 21:44:09 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8A=A5=E9=94=99=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java  | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java
index c6c5429..74ee3c6 100644
--- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java
+++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java
@@ -182,6 +182,7 @@ public abstract class SyncAccountsJobAbstract {
      * @param context
      */
     protected void sync(CJTJobContext context) {
+        String errorMessage = null;
         CJTRequest cjtRequest = null;
         CJTRequestBody cjtRequestBody = null;
         Integer page = 0;
@@ -216,11 +217,14 @@ public abstract class SyncAccountsJobAbstract {
                 }
             } catch (Exception e) {
                 log.error("{} exception", this.getClassName(), e);
-                throw new RuntimeException(buildErrorBody(cjtRequest, e.getMessage()));
+                errorMessage = buildErrorBody(cjtRequest, e.getMessage());
             } finally {
                 page++;
             }
         }while (!CollectionUtils.isEmpty(rows));
+        if (!StringUtils.isEmpty(errorMessage)){
+            throw new RuntimeException(errorMessage);
+        }
     }
 
     private List<String> getUniqueKey(List<String> keyList,List<List<String>> rows) {