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