diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/WeChatAccessTokenSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/WeChatAccessTokenSchedule.java index 7f8317e2a..e7d435cc2 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/WeChatAccessTokenSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/WeChatAccessTokenSchedule.java @@ -14,6 +14,8 @@ import org.springframework.stereotype.Component; import java.util.Date; import java.util.List; +import java.util.Map; +import java.util.stream.Collectors; @Component public class WeChatAccessTokenSchedule { @@ -38,10 +40,15 @@ public class WeChatAccessTokenSchedule { WxAppinfo appinfoQ = new WxAppinfo(); List appList = wxAppinfoMapper.findList(appinfoQ); + Map> collect = appList.stream().collect(Collectors.groupingBy(WxAppinfo::getAppId, Collectors.toList())); - for (WxAppinfo appinfo : appList) { - resetAccessToken(appinfo); + for (String appId:collect.keySet()) { + List wxAppinfoList = collect.get(appId); + resetAccessToken(wxAppinfoList.get(0)); } +// for (WxAppinfo appinfo : appList) { +// resetAccessToken(appinfo); +// } } logger.info("微信访问AccessToken获取定时任务结束");