| | |
|---|
| | | import cc.mrbird.febs.common.utils.SpringContextHolder; |
|---|
| | | import cc.mrbird.febs.pay.util.WechatConfigure; |
|---|
| | | import cn.hutool.core.util.StrUtil; |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | 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; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.io.IOException; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.Map; |
|---|
| | | |
|---|
| | | @Slf4j |
|---|
| | | @Component |
|---|
| | | @ConditionalOnProperty(prefix = "system", name = "job", havingValue = "true") |
|---|
| | | public class WxxcxJob { |
|---|
| | | |
|---|
| | | private final XcxProperties xcxProperties = SpringContextHolder.getBean(XcxProperties.class); |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private RedisUtils redisUtils; |
|---|
| | | @Resource |
|---|
| | | RestTemplate restTemplate; |
|---|
| | | @Autowired |
|---|
| | | private SpringContextHolder springContextHolder; |
|---|
| | | /** |
|---|
| | | * 获取access_token |
|---|
| | | * 有效期两小时 |
|---|
| | | */ |
|---|
| | | @Scheduled(cron = "0 0/5 * * * ? ") |
|---|
| | | @Scheduled(cron = "0 0 0/1 * * ? ") |
|---|
| | | public void getAccessToken() throws IOException { |
|---|
| | | |
|---|
| | | String appId = xcxProperties.getXcxAppid(); |
|---|
| | | String appSecret = xcxProperties.getXcxSecret(); |
|---|
| | | String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appId + "&secret=" + appSecret; |
|---|
| | | String jsonStr = restTemplate.getForObject(url, String.class); |
|---|
| | | |
|---|
| | | Map<String,String> params = new HashMap<>(); |
|---|
| | | params.put("grant_type","client_credential"); |
|---|
| | | params.put("appid",appId); |
|---|
| | | params.put("secret",appSecret); |
|---|
| | | |
|---|
| | | //发送请求 |
|---|
| | | String result = HttpCurlUtil.sendGetHttp(WechatConfigure.WX_ACCESS_TOKEN , params); |
|---|
| | | /** |
|---|
| | | * 返回结果 |
|---|
| | | * {"access_token":"ACCESS_TOKEN","expires_in":7200} |
|---|
| | | */ |
|---|
| | | if (!jsonStr.contains("access_token")) { |
|---|
| | | System.out.println("获取微信access_token失败"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | String accessTokenKey = WechatConfigure.WX_ACCESS_TOKEN_REDIS_KEY; |
|---|
| | | JSONObject jsonObject = JSONObject.parseObject(result); |
|---|
| | | JSONObject jsonObject = JSONObject.parseObject(jsonStr); |
|---|
| | | String accessToken = jsonObject.getString(accessTokenKey); |
|---|
| | | if (StrUtil.isEmpty(accessToken)) { |
|---|
| | | log.error("获取access token失败: {}" , jsonObject.getString("errmsg")); |
|---|
