xiangduilun/application/api/controller/Common.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use app\common\exception\UploadException;
use app\common\library\Upload;
use app\common\model\Area;
use app\common\model\Category;
use app\common\model\Selection;
use app\common\model\Version;
use fast\Random;
use think\Config;
use think\Hook;

/**
 * 公共接口
 */
class Common extends Api
{
    protected $noNeedLogin = '*';
    protected $noNeedRight = '*';

    /**
     * 加载初始化
     *
     * @param string $version 版本号
     * @param string $lng     经度
     * @param string $lat     纬度
     */
    public function init()
    {
        if ($version = $this->request->request('version')) {
            $lng = $this->request->request('lng');
            $lat = $this->request->request('lat');

            //配置信息
            $upload = Config::get('upload');
            //如果非服务端中转模式需要修改为中转
            if ($upload['storage'] != 'local' && isset($upload['uploadmode']) && $upload['uploadmode'] != 'server') {
                //临时修改上传模式为服务端中转
                set_addon_config($upload['storage'], ["uploadmode" => "server"], false);

                $upload = \app\common\model\Config::upload();
                // 上传信息配置后
                Hook::listen("upload_config_init", $upload);

                $upload = Config::set('upload', array_merge(Config::get('upload'), $upload));
            }

            $upload['cdnurl'] = $upload['cdnurl'] ? $upload['cdnurl'] : cdnurl('', true);
            $upload['uploadurl'] = preg_match("/^((?:[a-z]+:)?\/\/)(.*)/i", $upload['uploadurl']) ? $upload['uploadurl'] : url($upload['storage'] == 'local' ? '/api/common/upload' : $upload['uploadurl'], '', false, true);

            $content = [
                'citydata'    => Area::getCityFromLngLat($lng, $lat),
                'versiondata' => Version::check($version),
                'uploaddata'  => $upload,
                'coverdata'   => Config::get("cover"),
            ];
            $this->success('', $content);
        } else {
            $this->error(__('Invalid parameters'));
        }
    }

    /**
     * 上传文件
     * @ApiMethod (POST)
     * @param File $file 文件流
     */
    public function upload()
    {
        Config::set('default_return_type', 'json');
        //必须设定cdnurl为空,否则cdnurl函数计算错误
        Config::set('upload.cdnurl', '');
        $chunkid = $this->request->post("chunkid");
        if ($chunkid) {
            if (!Config::get('upload.chunking')) {
                $this->error(__('Chunk file disabled'));
            }
            $action = $this->request->post("action");
            $chunkindex = $this->request->post("chunkindex/d");
            $chunkcount = $this->request->post("chunkcount/d");
            $filename = $this->request->post("filename");
            $method = $this->request->method(true);
            if ($action == 'merge') {
                $attachment = null;
                //合并分片文件
                try {
                    $upload = new Upload();
                    $attachment = $upload->merge($chunkid, $chunkcount, $filename);
                } catch (UploadException $e) {
                    $this->error($e->getMessage());
                }
                $this->success(__('Uploaded successful'), ['url' => $attachment->url, 'fullurl' => cdnurl($attachment->url, true)]);
            } elseif ($method == 'clean') {
                //删除冗余的分片文件
                try {
                    $upload = new Upload();
                    $upload->clean($chunkid);
                } catch (UploadException $e) {
                    $this->error($e->getMessage());
                }
                $this->success();
            } else {
                //上传分片文件
                //默认普通上传文件
                $file = $this->request->file('file');
                try {
                    $upload = new Upload($file);
                    $upload->chunk($chunkid, $chunkindex, $chunkcount);
                } catch (UploadException $e) {
                    $this->error($e->getMessage());
                }
                $this->success();
            }
        } else {
            $attachment = null;
            //默认普通上传文件
            $file = $this->request->file('file');
            try {
                $upload = new Upload($file);
                $attachment = $upload->upload();
            } catch (UploadException $e) {
                $this->error($e->getMessage());
            }

            $this->success(__('Uploaded successful'), ['url' => $attachment->url, 'fullurl' => cdnurl($attachment->url, true)]);
        }

    }

    /**
     * 获取系统配置
     * @ApiParams (name='site',description='officialwx官方微信 money狗粮充值配置 score喜欢数量充值配置 PrivacyAgreement隐私协议 VerifyAuthorization验证授权书 用户服务协议UserServiceAgreement 关于我们AboutUs 狗粮用户协议DogFoodUserAgreement 公众号图片
    official_account_img 公众号文本
    official_account_text')
     */
    public function system_configuration(){
        $this->success('请求成功',config('site.'.input('site')));
    }

    /**
     * 获取分类
     * @ApiParams (name='type',description='education学历分类 tag标签 reason_cancellation注销列表')
     */
    public function category(){
        $this->success('请求成功',Category::where('type',input('type'))->select());
    }

    /**
     * 生成订单号
     * @return string
     */
    function getOrderId()
    {
        return date('Ymd') . str_pad(mt_rand(1, 99999), 5, '0', STR_PAD_LEFT);
    }

    /**
     * 获取openid(已废弃)
     * @ApiParams (name="code")
     */
    function getOpenid($code_ = ''){
        $code = $code_;
        $appid = 'wx5e111b790c719cae';
        $secret = 'a4e2a6d2a4fd06bd9e4ba279fd95e2d8';
        $get_token_url = 'https://api.weixin.qq.com/sns/oauth2/access_token?appid='.$appid.'&secret='.$secret.'&code='.$code.'&grant_type=authorization_code';
        $ch = curl_init();
        curl_setopt($ch,CURLOPT_URL,$get_token_url);
        curl_setopt($ch,CURLOPT_HEADER,0);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1 );
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);
        $res = curl_exec($ch);
        curl_close($ch);
        $json_obj = json_decode($res,true);
        if($json_obj['openid']){
            return $json_obj['openid'];
        }else{
            $this->error('请重新登录');
        }
        $this->error('0',$json_obj);
    }

    /**
     * 拉取wx用户信息
     */
    function getUserinfo($code_ = ''){
        $code = $code_;
        $appid = 'wx5e111b790c719cae';
        $secret = 'a4e2a6d2a4fd06bd9e4ba279fd95e2d8';
        //获取access_token openid
        $get_token_url = 'https://api.weixin.qq.com/sns/oauth2/access_token?appid='.$appid.'&secret='.$secret.'&code='.$code.'&grant_type=authorization_code';
        $wx_info_json_obj = json_decode(self::curl($get_token_url),true);
        //获取用户信息
        $get_userinfo_url = 'https://api.weixin.qq.com/sns/userinfo?access_token='.$wx_info_json_obj['access_token'].'&openid='.$wx_info_json_obj['openid'].'&lang=zh_CN';
        $get_userinfo_json_obj = json_decode(self::curl($get_userinfo_url),true);
        if($get_userinfo_json_obj){
            return $get_userinfo_json_obj;
        }else{
            $this->error('请重新登录');
        }
        $this->error('0',$get_userinfo_json_obj);
    }

    /**
     * curl
     */
    function curl($url = ''){
        $ch = curl_init();
        curl_setopt($ch,CURLOPT_URL,$url);
        curl_setopt($ch,CURLOPT_HEADER,0);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1 );
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);
        $res = curl_exec($ch);
        curl_close($ch);
        return $res;
    }

    /**
     * 选择项
     * @ApiParams  (name="type",description="1年龄 2身高 3计划结婚")
     */
    public function selection(){
        $this->success('',Selection::all(['type'=>input('type'),'status'=>1]));
    }

    /**
     * 获取所有地区
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getAllArea()
    {
        $field = ['id', 'pid', 'shortname', 'name', 'first'];
        $list = Area::with(['children' => function ($query) use ($field) {
            $query->field($field)->with(['children' => function ($query) use ($field) {
                $query->field($field);
            }]);
        }])
            ->where('pid', 0)->field($field)->select();

        $this->success('获取成功', $list);
    }

    /**
     * 获取所有的省市
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function get_area_city()
    {

        $field = ['id', 'pid', 'shortname', 'name', 'first'];
        $list = Area::with(['children' => function ($query) use ($field) {
            $query->field($field);
        }])
            ->where('pid', 0)->field($field)->select();

        $this->success('获取成功', $list);
    }

    /**
     * 根据城市id获取下一级
     * @ApiMethod (GET)
     * @ApiParams (name="pid", type="string",  description="城市id")
     */
    public function get_area()
    {
        $pid = $this->request->get('pid', 0);
        $field = ['id', 'pid', 'shortname', 'name'];
        $list = Area::where('pid', $pid)->field($field)->select();

        $this->success('获取成功', $list);
    }

    /**
     * 生成32随机字符串
     */
    function getRandomString($len, $chars=null)
    {
        if (is_null($chars)) {
            $chars = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
        }
        mt_srand(10000000*(double)microtime());
        for ($i = 0, $str = '', $lc = strlen($chars)-1; $i < $len; $i++) {
            $str .= $chars[mt_rand(0, $lc)];
        }
        return $str;
    }

    /**
     * 微信配置分享
     * @ApiMethod (POST)
     * @ApiParams (name='url')
     * @return void
     */
    public function get_sign(){
        // 微信 JS 接口签名校验工具: https://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=jsapisign
        $appid = 'wx5e111b790c719cae';
        $secret = 'a4e2a6d2a4fd06bd9e4ba279fd95e2d8';
        // 获取token
        $token_data = file_get_contents(__DIR__.'/wechat_token.txt');
        $time = 7200;
        if (!empty($token_data)) {
            $token_data = json_decode($token_data, true);
            $time  = time() - $token_data['time'];
        }
        if ($time > 3600) {
            $token_url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$appid}&secret={$secret}";
            $token_res = $this->https_request($token_url);
            $token_res = json_decode($token_res, true);
            $token = $token_res['access_token'];
            $data = array(
                'time' =>time(),
                'token' =>$token
            );

            $res = file_put_contents(__DIR__.'wechat_token.txt', json_encode($data));
//            if ($res) {
//                echo '更新 token 成功';
//            }
        } else {
            $token = $token_data['token'];
        }
        // 获取ticket
        $ticket_data = file_get_contents(__DIR__.'/wechat_ticket.txt');
        $time1 = 7200;
        if (!empty($ticket_data)) {
            $ticket_data = json_decode($ticket_data, true);
            $time1  = time() - $ticket_data['time'];
        }
        if ($time1 > 3600) {
            $ticket_url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token={$token}&type=jsapi";
            $ticket_res = $this->https_request($ticket_url);
            $ticket_res = json_decode($ticket_res, true);
            $ticket = $ticket_res['ticket'];
            $data = array(
                'time'    =>time(),
                'ticket'  =>$ticket
            );
            $res = file_put_contents(__DIR__.'wechat_ticket.txt', json_encode($data));
//            if ($res) {
//                echo '更新 ticket 成功';
//            }
        } else {
            $ticket = $ticket_data['ticket'];
        }
        // 进行sha1签名
        $timestamp = time();
        $nonceStr = $this->createNonceStr();
        // 注意 URL 动态获取(也可以写死).
        $protocol = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off' || $_SERVER['SERVER_PORT'] == 443) ? "https://" : "http://";

//        $url = "$protocol$_SERVER[HTTP_HOST]$_SERVER[REQUEST_URI]"; // 调用JSSDK的页面地址
        $this->request->post('url')?$url = $this->request->post('url'):$this->error('参数缺失');

        //$url = $_SERVER['HTTP_REFERER']; // 前后端分离的, 获取请求地址(此值不准确时可以通过其他方式解决)
        $str = "jsapi_ticket={$ticket}&noncestr={$nonceStr}&timestamp={$timestamp}&url={$url}";
        $sha_str = sha1($str);

        $signPackage = array(
            "appId" =>  $appid,
            "nonceStr" => $nonceStr,
            "timestamp" => $timestamp,
            "signature" => $sha_str,
        );

        $this->success($signPackage);
    }
    //随机字符串
    public function createNonceStr($length = 16) {
        $chars = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
        $str = "";
        for ($i = 0; $i < $length; $i++) {
            $str .= substr($chars, mt_rand(0, strlen($chars) - 1), 1);
        }
        return $str;
    }
    // 模拟 http 请求
    public function https_request($url, $data = null){
        // curl 初始化
        $curl = curl_init();
        // curl 设置
        curl_setopt($curl, CURLOPT_URL, $url);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);
        // 判断 $data get  or post
        if ( !empty($data) ) {
            curl_setopt($curl, CURLOPT_POST, 1);
            curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
        }
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
        // 执行
        $res = curl_exec($curl);
        curl_close($curl);
        return $res;
    }

    public function fasong(){
        echo Date('Y-m-d H:i:s',time());
    }

    /**
     * 发送微信模板消息
     * @param $order_id
     * @param $template
     * @return false|string|\think\response\Json
     */
    public function sendWechatMessage($openid,$template_id,$data,$url)
    {
        $data = array(
            "touser"        =>  $openid,        //openid
            "template_id"   =>  $template_id,             //模板id
            "url"           =>  $url,
            "data"          =>  $data      //模板数据
        );
        //下单用户发送
        $access_token = $this->access_token();
        if ($access_token == 400){
            return ['code'=>0,'message'=>'获取access_token失败'];
        }
        $urls = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=".$access_token;
        $result = $this->http_post_json($urls,json_encode($data));//发送请求
        if($result[0] == 200){
            return ['code'=>1,'data'=>'推送成功'];
        }
        return ['code'=>0,'message'=>$result[1]['errmsg']];
    }


    public function http_post_json($url, $jsonStr)
    {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $jsonStr);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_HTTPHEADER, array(
                'Content-Type: application/json; charset=utf-8',
                'Content-Length: ' . strlen($jsonStr)
            )
        );
        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);
        return [$httpCode,$response];
        // return json_encode(array($httpCode, $response),true);
        //"[200,"{\"errcode\":0,\"errmsg\":\"ok\",\"msgid\":2696398438942572550}"]"
    }

    //获取access_token
    public function access_token(){
        $appId = 'wx5e111b790c719cae';
        $appSecret = 'a4e2a6d2a4fd06bd9e4ba279fd95e2d8';
        $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=".$appId."&secret=".$appSecret;
        $ch = curl_init();//初始化curl
        curl_setopt($ch, CURLOPT_URL,$url); //要访问的地址
        curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);//跳过证书验证
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); // 从证书中检查SSL加密算法是否存在
        $data = json_decode(curl_exec($ch),true);
        if(curl_errno($ch)){
            var_dump(curl_error($ch)); //打印错误信息
        }
        curl_close($ch);//关闭curl
        return $data['access_token'];
    }

    //根据身份证号码获取生日

    function get_birthday($idcard) {
        if(empty($idcard)) return null;
        $bir = substr($idcard, 6, 8);
        $year = (int) substr($bir, 0, 4);
        $month = (int) substr($bir, 4, 2);
        $day = (int) substr($bir, 6, 2);
        return $year . '-' . $month . '-'  . $day;
}

}