From 70d2a5d0f9c6951b2d4cac954041ed73582ff7eb Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期一, 09 六月 2025 11:54:00 +0800
Subject: [PATCH] 6.9新增登录失败冻结逻辑
---
springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/WxXCXTempSend.java | 43 ++++---------------------------------------
1 files changed, 4 insertions(+), 39 deletions(-)
diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/WxXCXTempSend.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/WxXCXTempSend.java
index 9cd9df1..904c51c 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/WxXCXTempSend.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/WxXCXTempSend.java
@@ -109,9 +109,6 @@
public String getAccessToken(String appId) throws Exception {
String accessToken = "";
accessToken = wxXCXTempSend.stringRedisTemplate.boundValueOps("access_token:access_token:" + appId).get();
- if (appId.equals(APP_ID)) {
- accessToken = validAccessToken(accessToken, appId, APP_SECRET);
- }
return accessToken;
}
@@ -140,57 +137,25 @@
String accessTokenUrl = ACCESS_TOKEN_URL + "&appid=" + appId + "&secret=" + appSecret;
String result = HttpClientUtil.httpGet(accessTokenUrl, null, null);
Map<String, Object> resultMap = JSON.parseObject(result, Map.class);
+ StringRedisTemplate redisTemplate = wxXCXTempSend.stringRedisTemplate;
if (resultMap.containsKey("access_token")) {
accessToken = resultMap.get("access_token").toString();
- wxXCXTempSend.stringRedisTemplate.opsForValue().set("access_token:access_token:" + appId, accessToken);
+ redisTemplate.opsForValue().set("access_token:access_token:" + appId, accessToken);
}
HttpServletRequest request = ServletUtils.getRequest();
String requestURI = request.getRequestURI();
//加上时间戳
String datetime = new SimpleDateFormat("yyyyMMdd").format(new Date());
//这里是 Redis key的前缀，如: sys:tabieId:表名 如果不需要去掉表名也可以
- String key = MessageFormat.format("{0}:{1}:{2}", "request_incr",datetime,requestURI);
+ String key = MessageFormat.format("{0}:{1}:{2}", "access_token_request_incr",datetime,requestURI);
//查询 key 是否存在， 不存在返回 1 ，存在的话则自增加1
- wxXCXTempSend.stringRedisTemplate.opsForValue().increment(key, 1);
+ redisTemplate.opsForValue().increment(key, 1);
} catch (IOException ioe) {
log.error("小程序http请求异常");
ioe.printStackTrace();
}
return accessToken;
- }
-
- /**
- * 发布消息时重新设置access_token 防止过期
- *
- * @param appId
- * @param appSecret
- * @throws Exception
- */
- public void setAppAccessTokenToCache(String appId, String appSecret) throws Exception {
- String accessToken = "0";
- try {
- log.info("获取微信token参数：appid=" + appId + "，appSecret=" + appSecret);
- String accessTokenUrl = ACCESS_TOKEN_URL + "&appid=" + appId + "&secret=" + appSecret;
- String result = HttpClientUtil.httpGet(accessTokenUrl, null, null);
- Map<String, Object> resultMap = JSON.parseObject(result, Map.class);
- if (resultMap.containsKey("access_token")) {
- accessToken = resultMap.get("access_token").toString();
- wxXCXTempSend.stringRedisTemplate.opsForValue().set("access_token:access_token:" + appId, accessToken, EXPIRE_TIME, TimeUnit.HOURS);
- }
- } catch (IOException ioe) {
- log.error("小程序http请求异常");
- ioe.printStackTrace();
- }
- }
-
- public String getAccessTokenValid(String appId, Integer index) throws Exception {
- if (index % 1000 == 0) {
- return getAccessToken(appId);
- } else {
- return wxXCXTempSend.stringRedisTemplate.boundValueOps("access_token:access_token:" + appId).get();
- }
-
}
public String getWsAccessToken() throws Exception {
--
Gitblit v1.7.1