From 32185e7f8501b2cd1db3dede0bb555b4039c5ac2 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Thu, 19 Dec 2024 10:05:09 +0800 Subject: [PATCH] feat(mall): 添加跑腿会员系统设置功能 --- src/main/java/cc/mrbird/febs/mall/quartz/BaiduJob.java | 77 ++++++++++++++++++-------------------- 1 files changed, 36 insertions(+), 41 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/mall/quartz/BaiduJob.java b/src/main/java/cc/mrbird/febs/mall/quartz/BaiduJob.java index d9c2125..2f9ada8 100644 --- a/src/main/java/cc/mrbird/febs/mall/quartz/BaiduJob.java +++ b/src/main/java/cc/mrbird/febs/mall/quartz/BaiduJob.java @@ -1,14 +1,9 @@ package cc.mrbird.febs.mall.quartz; import cc.mrbird.febs.common.utils.RedisUtils; -import cc.mrbird.febs.pay.util.WechatConfigure; -import cn.hutool.core.util.StrUtil; -import com.alibaba.fastjson.JSONObject; -import com.baomidou.mybatisplus.extension.exceptions.ApiException; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; -import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.web.client.RestTemplate; @@ -24,41 +19,41 @@ @Resource RestTemplate restTemplate; - @Scheduled(cron = "0 0 1 * * ? ") - public void getAccessToken(){ - // 官网获取的 API Key 更新为你注册的 - String clientId = "MPHXcBxkGLIDOmoaahS9pIB7"; - // 官网获取的 Secret Key 更新为你注册的 - String clientSecret = "f5ueNY65fE9C6FzFTVKc6Imo8NdZSWMw"; - String authHost = "https://aip.baidubce.com/oauth/2.0/token?"; - String getAccessTokenUrl = authHost - // 1. grant_type为固定参数 - + "grant_type=client_credentials" - // 2. 官网获取的 API Key - + "&client_id=" + clientId - // 3. 官网获取的 Secret Key - + "&client_secret=" + clientSecret; - String jsonStr = restTemplate.getForObject(getAccessTokenUrl, String.class); - - /** - * 返回结果 - * {"access_token":"ACCESS_TOKEN","expires_in":7200} - */ - if (!jsonStr.contains("access_token")) { - System.out.println("获取access_token失败"); - } - JSONObject jsonObject = JSONObject.parseObject(jsonStr); - String accessToken = jsonObject.getString("access_token"); - - String accessTokenKey = WechatConfigure.BAIDU_ACCESS_TOKEN_REDIS_KEY; - if (StrUtil.isEmpty(accessToken)) { - log.error("获取baidu access_token失败: {}" , jsonObject.getString("errmsg")); - throw new ApiException("获取access token失败"); - } else { - log.info("baidu access_token : {}",accessToken); - System.out.println(accessToken); - redisUtils.set(accessTokenKey,accessToken); - } - } +// @Scheduled(cron = "0 0 1 * * ? ") +// public void getAccessToken(){ +// // 官网获取的 API Key 更新为你注册的 +// String clientId = "MPHXcBxkGLIDOmoaahS9pIB7"; +// // 官网获取的 Secret Key 更新为你注册的 +// String clientSecret = "f5ueNY65fE9C6FzFTVKc6Imo8NdZSWMw"; +// String authHost = "https://aip.baidubce.com/oauth/2.0/token?"; +// String getAccessTokenUrl = authHost +// // 1. grant_type为固定参数 +// + "grant_type=client_credentials" +// // 2. 官网获取的 API Key +// + "&client_id=" + clientId +// // 3. 官网获取的 Secret Key +// + "&client_secret=" + clientSecret; +// String jsonStr = restTemplate.getForObject(getAccessTokenUrl, String.class); +// +// /** +// * 返回结果 +// * {"access_token":"ACCESS_TOKEN","expires_in":7200} +// */ +// if (!jsonStr.contains("access_token")) { +// System.out.println("获取access_token失败"); +// } +// JSONObject jsonObject = JSONObject.parseObject(jsonStr); +// String accessToken = jsonObject.getString("access_token"); +// +// String accessTokenKey = WechatConfigure.BAIDU_ACCESS_TOKEN_REDIS_KEY; +// if (StrUtil.isEmpty(accessToken)) { +// log.error("获取baidu access_token失败: {}" , jsonObject.getString("errmsg")); +// throw new ApiException("获取access token失败"); +// } else { +// log.info("baidu access_token : {}",accessToken); +// System.out.println(accessToken); +// redisUtils.set(accessTokenKey,accessToken); +// } +// } } -- Gitblit v1.9.1