From 42e02d5ad8e405951c1b4e00321daf265d5d8c44 Mon Sep 17 00:00:00 2001 From: gongbiao Date: Mon, 26 Nov 2018 13:21:33 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1][?= =?UTF-8?q?=E4=BF=AE=E6=94=B9][=E8=8E=B7=E5=8F=96=E5=AE=A2=E6=B5=81TOKEN?= =?UTF-8?q?=E6=97=B6=E9=97=B430=E5=88=86=E9=92=9F=E4=B8=80=E6=AC=A1]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/iformall/schedule/WiwideTokenSchedule.java | 8 ++++++-- .../main/java/com/iformall/utils/WiwideUtil.java | 14 ++++++++++++-- 2 files changed, 18 insertions(+), 4 deletions(-) diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/WiwideTokenSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/WiwideTokenSchedule.java index 6b8905c41..e26f543bb 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/WiwideTokenSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/WiwideTokenSchedule.java @@ -25,13 +25,17 @@ public class WiwideTokenSchedule { @Autowired private WxWiwideInfoMapper wxWiwideInfoMapper; - @Scheduled(cron = "0 0/45 * * * ?") + @Scheduled(cron = "0 0/30 * * * ?") public void requestToken() { List list = wxWiwideInfoMapper.findList(null); for (int i = 0, size = list.size(); i < size; i++) { WxWiWideInfo wxWiWideInfo = list.get(i); String data = WiwideUtil.queryToken(wxWiWideInfo); String token = (String) JSONObject.parseObject(data).get("data"); + if(token==null){ + logger.error("商场:"+wxWiWideInfo.getTenantId()+",token为空"); + continue; + } updateToken(wxWiWideInfo, token); } @@ -47,7 +51,7 @@ public class WiwideTokenSchedule { try { wxWiwideInfoMapper.updateToken(record); } catch (MallinkException e) { - logger.info("更新TOKEN失败:商场" + wxWiWideInfo.getTenantId()); + logger.error("更新TOKEN失败:商场" + wxWiWideInfo.getTenantId()); } } diff --git a/mallinkService/src/main/java/com/iformall/utils/WiwideUtil.java b/mallinkService/src/main/java/com/iformall/utils/WiwideUtil.java index db620e2e0..9993a27f8 100644 --- a/mallinkService/src/main/java/com/iformall/utils/WiwideUtil.java +++ b/mallinkService/src/main/java/com/iformall/utils/WiwideUtil.java @@ -2,9 +2,9 @@ package com.iformall.utils; import com.alibaba.fastjson.JSONObject; import com.iformall.common.ErrorCode; -import com.iformall.domain.po.WxMall; import com.iformall.domain.po.WxWiWideInfo; import com.iformall.exception.MallinkException; +import org.apache.commons.lang3.StringUtils; import org.apache.shiro.codec.Base64; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -135,7 +135,17 @@ public class WiwideUtil { logger.info("获取TOKEN"); String username = wiWideInfo.getWiwideId(); String authVal = WiwideUtil.encrypt(wiWideInfo.getWiwideKey()); - Map params = new HashMap<>(); + if(StringUtils.isEmpty(username)){ + logger.error("商场:" + wiWideInfo.getTenantId() + ",wiwideId为空" ); + return null; + } + + if(StringUtils.isEmpty(authVal)){ + logger.error("商场:" + wiWideInfo.getTenantId() + ",wiwideKey为空" ); + return null; + } + + Map params = new HashMap<>(2); params.put("username", username); params.put("authVal", authVal); String wiwideUrl = wiWideInfo.getWiwideUrl();