|
|
|
@@ -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())); |
|
|
|
|