diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserTagsSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserTagsSchedule.java index 8a6011f40..1cb4d290e 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserTagsSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserTagsSchedule.java @@ -22,7 +22,7 @@ public class WxCUserTagsSchedule { @Autowired WxCUserBasicInfoService wxCUserBasicInfoService; - @Scheduled(cron = "0 0 1 25 * ?") // 每月25日凌晨01:00对会员列表扫描补录标签 + @Scheduled(cron = "0 0 0 25 * ?") // 每月25日凌晨01:00对会员列表扫描补录标签 //@Scheduled(cron = "0 */5 * * * ?") // 测试1分钟一次 public void wxCUserTagsSchedule() { WxCUserBasicInfo wxCUserBasicInfo = new WxCUserBasicInfo(); @@ -33,7 +33,7 @@ public class WxCUserTagsSchedule { PageInfo page; do{ page = wxCUserBasicInfoService.listAsPage(wxCUserBasicInfo, pageIndex++, pageSize); - page.getList().parallelStream().forEach(cubi -> { + page.getList().stream().forEach(cubi -> { wxCUserTagsService.triggerAssignTags(EnumAssignTagsTrigger.ASSIGN_TAGS_TRIGGER_SCAN, cubi); }); } while ((page.isHasNextPage()));