package com.zhrd.bussinss.platform.scheduled;

import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import com.zhrd.bussinss.platform.constants.WeiXinId;
import com.zhrd.bussinss.platform.service.AccessTokenService;

import net.sf.json.JSONObject;

@Component
@Lazy(false)
public class GetWeiXinAccessTokenScheduled {
 
 /**

   * 獲得ACCESS_TOKEN

   *

   * @Title: getAccess_token

   * @Description: 獲得ACCESS_TOKEN

   * @param @return 設(shè)定文件

   * @return String 返回類型

   * @throws

   */
 
 @Autowired
 private AccessTokenService accessTokenServiceImpl;
 
 
 @Scheduled(fixedRateString = "${weixin.token.fixedRate.in.milliseconds}"
  , initialDelayString = "${weixin.token.initialDelay.in.milliseconds}")
  public void getAccessToken() {
  
  System.out.println("====================獲取token開始==============================");

    String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid="

        + WeiXinId.APPID+ "&secret=" + WeiXinId.APPSECRET;

    String accessToken = null;
    String expiresIn = null;

    try {

      URL urlGet = new URL(url);

      HttpURLConnection http = (HttpURLConnection) urlGet.openConnection();

      http.setRequestMethod("GET"); // 必須是get方式請求

      http.setRequestProperty("Content-Type",

          "application/x-www-form-urlencoded");

      http.setDoOutput(true);

      http.setDoInput(true);

      http.connect();

      InputStream is = http.getInputStream();

      int size = is.available();

      byte[] jsonBytes = new byte[size];

      is.read(jsonBytes);

      String message = new String(jsonBytes, "UTF-8");

      JSONObject demoJson = JSONObject.fromObject(message);

      accessToken = demoJson.getString("access_token");
      expiresIn = demoJson.getString("expires_in");

      System.out.println("accessToken===="+accessToken);
      System.out.println("expiresIn==="+expiresIn);
      accessTokenServiceImpl.addToken(accessToken,expiresIn);
      System.out.println("====================獲取token結(jié)束==============================");

      is.close();

    } catch (Exception e) {

      e.printStackTrace();

    }

//    return accessToken;

  }
 
}