考生端代码重构及性能优化

examcloud-task-service/src/main/java/cn/com/qmth/examcloud/task/service/job/DisposePublishingNoticeTask.java

@@ -44,33 +44,33 @@ public class DisposePublishingNoticeTask extends AbstractTask {
             int loopTimes = 0;
             Long lastMaxUserId = getLastMaxUserId(progress.getNoticeReceiverRuleType(), progress);
             while (true) {
-                try {
-                    loopTimes++;
-                    if (lastMaxUserId != null) {
-                        startUserId = lastMaxUserId + 1;
-                    }
-                    DisposePublishingUserNoticeReq disposeReq = new DisposePublishingUserNoticeReq();
-                    disposeReq.setStartUserId(startUserId);
-                    disposeReq.setNoticeRulePublishProgress(progress);
-                    DisposePublishingUserNoticeResp disposeResp = noticeCloudService.disposePublishingUserNotice(disposeReq);
-                    Long nextUserId = disposeResp.getNextUserId();
+//                try {
+                loopTimes++;
+                if (lastMaxUserId != null) {
+                    startUserId = lastMaxUserId + 1;
+                }
+                DisposePublishingUserNoticeReq disposeReq = new DisposePublishingUserNoticeReq();
+                disposeReq.setStartUserId(startUserId);
+                disposeReq.setNoticeRulePublishProgress(progress);
+                DisposePublishingUserNoticeResp disposeResp = noticeCloudService.disposePublishingUserNotice(disposeReq);
+                Long nextUserId = disposeResp.getNextUserId();
 
-                    if (nextUserId.equals(startUserId)) {
+                if (nextUserId.equals(startUserId)) {
+                    updateNoticeStatus(progress.getNoticeId(), NoticeStatus.PUBLISHED);
+                    break;
+                } else {
+                    startUserId = nextUserId;
+                    //处理中的状态只需更新一次
+                    if (loopTimes == 1) {
                         updateNoticeStatus(progress.getNoticeId(), NoticeStatus.PUBLISHED);
-                        break;
-                    } else {
-                        startUserId = nextUserId;
-                        //处理中的状态只需更新一次
-                        if (loopTimes == 1) {
-                            updateNoticeStatus(progress.getNoticeId(), NoticeStatus.PUBLISHED);
-                        }
                     }
-                } catch (Exception e) {
-                    // 特殊处理：此处为了不影响自动服务的其它正常数据，所以吃掉了异常
-                    log.error("[DISPOSE-NOTICE]:处理用户通知任务出现异常，rootOrgId=" + progress.getRootOrgId() + ",noticeId="
-                            + progress.getNoticeId(), e);
-                    break;
                 }
+//                } catch (Exception e) {
+//                    // 特殊处理：此处为了不影响自动服务的其它正常数据，所以吃掉了异常
+//                    log.error("[DISPOSE-NOTICE]:处理用户通知任务出现异常，rootOrgId=" + progress.getRootOrgId() + ",noticeId="
+//                            + progress.getNoticeId(), e);
+//                    break;
+//                }
             }
         }