|
@@ -41,9 +41,9 @@ public class DisposePublishingNoticeTask extends AbstractTask {
|
|
|
return;
|
|
|
}
|
|
|
Long startUserId = 0L;
|
|
|
- int loopTimes = 0;
|
|
|
+
|
|
|
for (NoticeRulePublishProgressBean progress : progressList) {
|
|
|
- loopTimes++;
|
|
|
+ int loopTimes = 0;
|
|
|
Long lastMaxUserId = getLastMaxUserId(progress.getNoticeReceiverRuleType(), progress);
|
|
|
if (lastMaxUserId != null) {
|
|
|
startUserId = lastMaxUserId + 1;
|
|
@@ -59,12 +59,13 @@ public class DisposePublishingNoticeTask extends AbstractTask {
|
|
|
updateNoticeStatus(progress.getNoticeId(), NoticeStatus.PUBLISHED);
|
|
|
break;
|
|
|
} else {
|
|
|
- startUserId = nextUserId;
|
|
|
+ startUserId = nextUserId+1;
|
|
|
//处理中的状态只需更新一次
|
|
|
if (loopTimes == 1) {
|
|
|
updateNoticeStatus(progress.getNoticeId(), NoticeStatus.PUBLISHING);
|
|
|
}
|
|
|
}
|
|
|
+ loopTimes++;
|
|
|
}
|
|
|
}
|
|
|
|