youfeng/app/Service/Weixin/WeixinService.php

<?php

namespace App\Service\Weixin;

use App\Service\Service;
use Illuminate\Support\Facades\Redis;

class WeixinService extends Service
{
    const APPID = 'wxe048bcdcc21aae6e';
    const APPSECRET = '191789c5b4ef2b3d5b9e79bb62428092';
    const ACCESS_URL = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s';
    const OPENID = '';
    const TOKEN = '';
    const KEY = 'weixintnine';

    const STABLE_TOKEN_URL = 'https://api.weixin.qq.com/cgi-bin/stable_token'; // 稳定版接口
    const KEY_STABLE = 'weixinMessage';

    public function getToken(){
        $token_key = self::KEY.'_'.'token';
        $token = Redis::get($token_key);
        if(! $token){
            $url = sprintf(self::ACCESS_URL,self::APPID,self::APPSECRET);
            $res = $this->curlOpen($url);
            $res = json_decode($res,true);
            if(isset($res['errmsg'])) return [false,$res['errmsg']];
            if(!isset($res['access_token'])) return [false,'request error'];
            $token = $res['access_token'];
            $expire_time = $res['expires_in']-300;
            Redis::set($token_key,$token);
            Redis::expire($token_key, $expire_time);
            return [true,$token];
        }
        return [true,$token];
    }

    public function getTokenSTABLE() {
        $token_key = self::KEY_STABLE . '_token';
        $token = Redis::get($token_key);

        // 缓存存在且有效
        if ($token) return [true, $token];

        // 构建 POST 请求体
        $postData = json_encode([
            'grant_type' => 'client_credential',
            'appid' => self::APPID,
            'secret' => self::APPSECRET,
            // 可选：'force_refresh' => true 强制刷新
        ]);

        list($status, $res) = $this->post_helper(self::STABLE_TOKEN_URL, $postData);
        if(! $status) return [false, $res];

        // 错误处理
        if (isset($res['errcode']) && $res['errcode'] != 0) return [false, "{$res['errcode']}: {$res['errmsg']}"];
        if (empty($res['access_token']))  return [false, 'access_token missing'];

        // 缓存 Token（有效期7200秒，提前300秒刷新）
        $token = $res['access_token'];
        $expire = $res['expires_in'] - 300; // 实际6900秒(1小时55分)
        Redis::setex($token_key, $expire, $token);

        return [true, $token];
    }

    public function getOpenid($data){
        if(empty($data['code'])) return [false, 'code不能为空'];
        $code = $data['code'];
        $url = 'https://api.weixin.qq.com/sns/oauth2/access_token?appid=%s&secret=%s&code=%s&grant_type=authorization_code';
        $url = sprintf($url,self::APPID,self::APPSECRET,$code);
        $res = $this->curlOpen($url);
        $res = json_decode($res,true);
        if(!isset($res['openid'])) return [false,$res['errmsg']??'request error'];
        $openid = $res['openid'];
        return [true,['openid' => $openid]];
    }

    public function setWebHook($data){
//        file_put_contents('22.txt',json_encode($data));
        $uri = isset($data['uri']) ? $data['uri'] : '';
        $url = "https://open.weixin.qq.com/connect/oauth2/authorize?appid=%s&redirect_uri=%s&response_type=code&scope=snsapi_userinfo&state=STATE#wechat_redirect";
        $param = isset($data['param']) ? $data['param'] : '';
        $redirect_uri = urlencode('https://t9api.qingyaokeji.com/wxapi/getUnionid?uri='.$uri.'&param='.$param);
        $url = sprintf($url,self::APPID,$redirect_uri);
        header("Location:".$url);exit;
        echo 'ok';die;
    }

    public function getUnionid($data){
        file_put_contents('22.txt',date('YmdHis').json_encode($data));
//        echo $data['code'];

        if(isset($data['code'])) {
            list($status,$openid) = $this->getOpenid($data);
            file_put_contents('222.txt',date('YmdHis').json_encode($openid));
            if(!$status) return [false,$openid];
            $uri = $data['uri'];
            $openid = $openid['openid'];
            $param = isset($data['param']) ? $data['param'] : '';
            $url = 'https://t9.qingyaokeji.com/#/wxGet?uri='.$uri.'&openid='.$openid.'&param='.$param;
            header('Location:'.$url);exit();
        }
    }

//    public function sendTmpMsg($data){
//        //        $openid = 'okXNa69ggEX61KvHUhCq9PcGrPKI';
//        $data = [
//            'openid' => 'o7B4f68DuDlBSevGdctFyP8MD-nw',
//            'tempid' => '5azHlaoAu6MgRzkxn_HL6ygFt_wIkXEz9CklPWEdP70',
//            'reload_url' => '',
//            'first' => '工资发放',
//            'remark' => '请查收',
//            'detail' => [
//                'thing2' => '姓名',
//                'thing6' => '10',
//                'time4' => '2023-09-01',
//                'character_string3' => 'st.1231',
//                'thing1' => '类型',
//            ]
//        ];
//        if(!isset($data['detail'])) return [false,'invalid detail'];
//        if(!isset($data['openid'])) return [false,'invalid openid'];
//        if(!isset($data['tempid'])) return [false,'invalid tempid'];
//        if(!isset($data['reload_url'])) return [false,'invalid reload_url'];
//        $templateID = $data['tempid'];
//        $reload_url = $data['reload_url'];
//        list($status,$token) = $this->getToken();
//        if(!$status) return [false,$token];
//        $url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=".$token;
//        $post = '{
//           "touser":"'.$data['openid'].'",
//           "template_id":"'.$templateID.'",
//           "url":"'.$reload_url.'",
//           "data":{
//                   "first": {
//                       "value":"'.$data['first'].'",
//                       "color":"#173177"
//                   },
//                   %s
//                   "remark":{
//                       "value":"'.$data['remark'].'",
//                       "color":"#173177"
//                   }
//           }
//       }';
//        $content = "";
//        foreach ($data['detail'] as $k=>$v){
//
//            $content .= '"'.$k.'": {
//                       "value":"'.$v.'",
//                       "color":"#173177"
//                   },';
//        }
//        $post = sprintf($post,$content);
////        var_dump($post);
////        var_dump(json_decode($post));die;
////        var_dump($url);
////        var_dump(json_encode(json_decode($post)));
//        $res = $this->curlOpen($url,['post'=>$post]);
//        $res = json_decode($res,true);
//        if(isset($res['errcode'])&&$res['errcode'] != 0) return [false,$res['errmsg']];
//        if(isset($res['errcode'])&&$res['errcode'] === 0) return [true,''];
//        return [false,json_encode($res)];
//
//    }
}