Parcourir la source

//

release_toaliyun_real
xhxu il y a 3 ans
Parent
révision
d542d40af0
1 fichiers modifiés avec 9 ajouts et 2 suppressions
  1. +9
    -2
      mallinkSchedule/src/main/java/com/iformall/schedule/WeChatAccessTokenSchedule.java

+ 9
- 2
mallinkSchedule/src/main/java/com/iformall/schedule/WeChatAccessTokenSchedule.java Voir le fichier

@@ -14,6 +14,8 @@ import org.springframework.stereotype.Component;


import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;


@Component @Component
public class WeChatAccessTokenSchedule { public class WeChatAccessTokenSchedule {
@@ -38,10 +40,15 @@ public class WeChatAccessTokenSchedule {


WxAppinfo appinfoQ = new WxAppinfo(); WxAppinfo appinfoQ = new WxAppinfo();
List<WxAppinfo> appList = wxAppinfoMapper.findList(appinfoQ); List<WxAppinfo> appList = wxAppinfoMapper.findList(appinfoQ);
Map<String, List<WxAppinfo>> collect = appList.stream().collect(Collectors.groupingBy(WxAppinfo::getAppId, Collectors.toList()));


for (WxAppinfo appinfo : appList) {
resetAccessToken(appinfo);
for (String appId:collect.keySet()) {
List<WxAppinfo> wxAppinfoList = collect.get(appId);
resetAccessToken(wxAppinfoList.get(0));
} }
// for (WxAppinfo appinfo : appList) {
// resetAccessToken(appinfo);
// }
} }


logger.info("微信访问AccessToken获取定时任务结束"); logger.info("微信访问AccessToken获取定时任务结束");


Chargement…
Annuler
Enregistrer