fix(mall): 修复会员提现状态更新逻辑

KKSU

2024-12-20 19c3da86d8c6adcb91baccac6981c63307e3dba1

 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);
//        }
//    }

}