WeixinService.php 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110
  1. <?php
  2. namespace App\Service\Weixin;
  3. use App\Service\Service;
  4. use Illuminate\Support\Facades\Redis;
  5. class WeixinService extends Service
  6. {
  7. public $appid = '';
  8. public $secret = '';
  9. const ACCESS_URL = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s';
  10. const KEY = '';
  11. const STABLE_TOKEN_URL = 'https://api.weixin.qq.com/cgi-bin/stable_token'; // 稳定版接口
  12. const KEY_STABLE = 'weixinsupplymarketing';
  13. public function __construct()
  14. {
  15. $this->appid = config("wx_msg.f_appid");
  16. $this->secret = config("wx_msg.f_appSecret");
  17. }
  18. public function getToken(){
  19. $token_key = self::KEY.'_'.'token';
  20. $token = Redis::get($token_key);
  21. if(! $token){
  22. $url = sprintf(self::ACCESS_URL,$this->appid, $this->secret);
  23. $res = $this->curlOpen($url);
  24. $res = json_decode($res,true);
  25. if(isset($res['errmsg'])) return [false,$res['errmsg']];
  26. if(!isset($res['access_token'])) return [false,'request error'];
  27. $token = $res['access_token'];
  28. $expire_time = $res['expires_in']-300;
  29. Redis::set($token_key,$token);
  30. Redis::expire($token_key, $expire_time);
  31. return [true,$token];
  32. }
  33. return [true,$token];
  34. }
  35. public function getTokenSTABLE() {
  36. $token_key = self::KEY_STABLE . '_token';
  37. $token = Redis::get($token_key);
  38. // 缓存存在且有效
  39. if ($token) return [true, $token];
  40. // 构建 POST 请求体
  41. $postData = json_encode([
  42. 'grant_type' => 'client_credential',
  43. 'appid' => $this->appid,
  44. 'secret' => $this->secret,
  45. // 可选:'force_refresh' => true 强制刷新
  46. ]);
  47. list($status, $res) = $this->post_helper(self::STABLE_TOKEN_URL, $postData);
  48. if(! $status) return [false, $res];
  49. // 错误处理
  50. if (isset($res['errcode']) && $res['errcode'] != 0) return [false, "{$res['errcode']}: {$res['errmsg']}"];
  51. if (empty($res['access_token'])) return [false, 'access_token missing'];
  52. // 缓存 Token(有效期7200秒,提前300秒刷新)
  53. $token = $res['access_token'];
  54. $expire = $res['expires_in'] - 300; // 实际6900秒(1小时55分)
  55. Redis::setex($token_key, $expire, $token);
  56. return [true, $token];
  57. }
  58. public function setWebHook($data){
  59. // file_put_contents('22.txt',json_encode($data));
  60. $uri = isset($data['uri']) ? $data['uri'] : '';
  61. $url = "https://open.weixin.qq.com/connect/oauth2/authorize?appid=%s&redirect_uri=%s&response_type=code&scope=snsapi_userinfo&state=STATE#wechat_redirect";
  62. $param = isset($data['param']) ? $data['param'] : '';
  63. $redirect_uri = urlencode('https://t9api.qingyaokeji.com/wxapi/getUnionid?uri='.$uri.'&param='.$param);
  64. $url = sprintf($url,$this->appid,$redirect_uri);
  65. header("Location:".$url);exit;
  66. echo 'ok';die;
  67. }
  68. public function getUnionid($data){
  69. // file_put_contents('22.txt',date('YmdHis').json_encode($data));
  70. // echo $data['code'];
  71. if(isset($data['code'])) {
  72. list($status,$openid) = $this->getOpenid($data);
  73. // file_put_contents('222.txt',date('YmdHis').json_encode($openid));
  74. if(!$status) return [false,$openid];
  75. $uri = $data['uri'];
  76. $openid = $openid['openid'];
  77. $param = isset($data['param']) ? $data['param'] : '';
  78. $url = 'https://t9.qingyaokeji.com/#/wxGet?uri='.$uri.'&openid='.$openid.'&param='.$param;
  79. header('Location:'.$url);exit();
  80. }
  81. }
  82. public function getOpenid($data){
  83. if(empty($data['code'])) return [false, 'code不能为空'];
  84. $code = $data['code'];
  85. $url = 'https://api.weixin.qq.com/sns/oauth2/access_token?appid=%s&secret=%s&code=%s&grant_type=authorization_code';
  86. $url = sprintf($url,$this->appid,$this->secret,$code);
  87. $res = $this->curlOpen($url);
  88. $res = json_decode($res,true);
  89. if(!isset($res['openid'])) return [false,$res['errmsg']??'request error'];
  90. $openid = $res['openid'];
  91. return [true,['openid' => $openid]];
  92. }
  93. }