<?php
/**
 * Created by PhpStorm.
 * Login: Kevin
 * Date: 2023/03/22
 * Time: 14:10
 */

namespace app\api\controller\v1;

use app\api\controller\inspection\Task;
use lib\WXBizDataCrypt;
use think\Db;
use think\Request;

header('Access-Control-Allow-Origin:*');
header("Access-Control-Allow-Headers: Origin, X-Requested-With, Content-Type, Accept");
header('Access-Control-Allow-Methods: GET, POST, PUT');

class Login extends Base
{
    /**
     * 1、小程序授权注册用户、返回用户信息
     */
    public function get_user_by_shouquan()
    {
        $appid = "wx58ceff4e93cfc523";
        $AppSecret = "baf744d21875280a5e98611f66adaf91";
        $post = $this->request->post();
        $code = $post['code'];// I('post.code');
        $encryptedData = $post['encryptedData'];//I('post.encryptedData');
        $iv = $post['iv'];//I('post.iv');
        //file_put_contents("ccc_v2.txt", "授权0-提交的内容:" . date("Y-m-d H:i:s") . json_encode($post) . PHP_EOL, FILE_APPEND);
        $url = "https://api.weixin.qq.com/sns/jscode2session?appid=" . $appid . "&secret=" . $AppSecret . "&js_code=" . $code . "&grant_type=authorization_code";
        //file_put_contents("1.txt","8-1. ".($code)."\r\n",FILE_APPEND);
        $result = http_request($url);
        //file_put_contents("111111111111222.txt","3-1. ".($result)."\r\n",FILE_APPEND);
        $res = json_decode($result, true);
        if (!$res) {
            $this->error("授权失败，请尝试重新授权");
            //$res = json_decode(send_post($url), true);
        }else{
            //查询到openid 通过openid查询到用户
            $user=Db::name("user")->where('wx_xcx_openid',$res['openid'])->find();
            if($user){
                $res=$this->auth->direct($user['id']);
                $return_data = $this->auth->getUserinfo();

                //判断是否是司机
                $driver=Db::name("driver")->where("user_id",$user['id'])->find();
                $return_data['driver_type']=0;
                if($driver){
                    $return_data['driver_type']=1;
                }
                $this->success('查询用户信息成功',$return_data);
                //查询到了用户信息
                //$this->bind($user['id'],$user['moblie']);
            }else{
                //未查询到用户信息 添加用户信息
                $username = "微信用户";
                $extend_data = [
                    "avatar" => "/default.png",
                    "wx_xcx_openid" =>  $res['openid'],
                ];
                $ret = $this->auth->register($username, "a123456", '','', $extend_data);
                if($ret){
                    $return_data = $this->auth->getUserinfo();
                    $this->success('查询用户信息成功2',$return_data);
                }
            }
        }

    }

    public function getuserphonenumber()
    {
        $user_id=$this->auth->id;
        $appid = "wx58ceff4e93cfc523";
        $AppSecret = "baf744d21875280a5e98611f66adaf91";
        $post = $this->request->post();
        $code = $post['code'];// I('post.code');
        $AccessToken=$this->getwxAccessToken($appid,$AppSecret);
        $phone=$this->getwxPhoneNumber($code,$AccessToken);
        $phone=json_decode($phone,true);
        $moblie=$phone['phoneNumber'];
        if($moblie){
            Db::name("user")->where("id", $user_id)->update(["mobile" => $moblie]);
            $res=$this->auth->direct($user_id);
            $return_data = $this->auth->getUserinfo();
            $this->success('查询用户信息成功',$return_data);
        }else{
            $this->error("无法获取手机号，登录失败");
        }
    }




    //获取accesstoken
    function getwxAccessToken($appid,$AppSecret){
        $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=".$appid."&secret=".$AppSecret."";
        $res = json_decode(http_request($url), true);
        return $res;
    }
    //获取手机号
    function getwxPhoneNumber($code,$token)
    {
        $token =$token['access_token'];
        $data['code'] = $code;//前端获取code
        $url = "https://api.weixin.qq.com/wxa/business/getuserphonenumber?access_token=$token";
        $info = $this->Post(json_encode($data),$url);
        // 一定要注意转json，否则汇报47001错误
        $tmpinfo = json_decode($info);



        $code = $tmpinfo->errcode;
        $phone_info = $tmpinfo->phone_info;
        //手机号
        $phoneNumber = $phone_info->phoneNumber ;
        if ($code == '0') {
            return json_encode(['code' => 1, 'msg' => '请求成功', 'phoneNumber' => $phoneNumber]);
        } else {
            return json_encode($tmpinfo);
        }
    }

    function Post($curlPost, $url, $ssl = false)
    {
        $curl = curl_init();

        curl_setopt($curl, CURLOPT_URL, $url);
        curl_setopt($curl, CURLOPT_HEADER, false);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($curl, CURLOPT_NOBODY, true);
        curl_setopt($curl, CURLOPT_POST, true);
        curl_setopt($curl, CURLOPT_POSTFIELDS, $curlPost);
        if (!$ssl) {
            curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
            curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
        }
        $return_str = curl_exec($curl);
        curl_close($curl);
        return $return_str;
    }

    //查询权限
    public function bind($user_id,$phoneNumber){
        //跟新手机号
        Db::name("user")->where("id", $user_id)->update(["mobile" => $phoneNumber]);

        //[农场]这里是已注册过的用户，有手机号，需要判断下手机号有没有在食堂中存在，若存在就将id绑定过去
        $bind = Db::name("farm_manager")->where("mng_admin_phone", $phoneNumber)->order("id desc")->find();

        if (!empty($bind)) {
            Db::name("farm_manager")->where("mng_admin_phone", $phoneNumber)->update(["mng_user_id" =>$user_id]);
            if ($bind['mng_admin_name']) {
                //将管理员姓名更新到用户表中
                Db::name("user")->where("id", $user_id)->update(["username" => $bind['mng_admin_name']]);
            }
        }

        //[食堂]这里是已注册过的用户，有手机号，需要判断下手机号有没有在食堂管理员中存在，若存在就将id绑定过去
        $bind2 = Db::name("farm_canteenmanager")->where("mng_admin_phone", $phoneNumber)->order("id desc")->find();

        if (!empty($bind2)) {
            Db::name("farm_canteenmanager")->where("mng_admin_phone", $phoneNumber)->update(["mng_user_id" => $user_id]);
            if ($bind2['mng_admin_name']) {
                //将管理员姓名更新到用户表中
                Db::name("user")->where("id", $user_id)->update(["username" => $bind2['mng_admin_name']]);
            }
        }



        $is_mng_user = 0;//是否是农场管理员 0不是 1是
        $mng_area = [];//管辖区域（多个）
        $area = Db::name("farm_manager")->alias("a")
            ->join("farm_farm_list b", "b.id=a.farm_farm_list_id")
            ->where("a.mng_user_id", $user_id)->field("b.id as code,b.name")->select();
        if (!empty($area)) {
            $is_mng_user = 1;
            $mng_area = $area;
        }
        $return_data['is_mng_user'] = $is_mng_user;
        $return_data['mng_area'] = $mng_area;

        $is_mng_user2 = 0;//是否是食堂管理员 0不是 1是
        $mng_area2 = [];//管辖区域（多个）
        $area2 = Db::name("farm_canteenmanager")->alias("a")
            ->join("farm_canteen b", "b.id=a.farm_canteen_id")
            ->where("a.mng_user_id", $user_id)->field("b.id as code,b.name")->select();
        if (!empty($area2)) {
            $is_mng_user2 = 1;
            $mng_area2 = $area2;
        }
        $return_data['is_mng_user2'] = $is_mng_user2;
        $return_data['mng_area2'] = $mng_area2;

        $return_data['avatar'] =full_image($return_data['avatar']);
        $res=$this->auth->direct($user_id);
        $return_data = $this->auth->getUserinfo();
        $this->success(__('登录成功'), $return_data);
    }

    /**
     * 修改微信名称
     * @return void
     */
    public function updateusername(){
        $username=$this->request->param("username");
        $user_id=$this->auth->id;
        Db::name("user")
            ->where("id", $user_id)
            ->update([
                "username" => $username,
                "nickname" => $username,
            ]);
        $this->success("请求成功");
    }

    /**
     * 修改微信头像
     * @return void
     */
    public function updateuseravatar(){
        $avatar=$this->request->param("avatar");
        $avatar=$this->uploadBase64($avatar);
        $user_id=$this->auth->id;
        Db::name("user")
            ->where("id", $user_id)
            ->update([
                "avatar" => $avatar['fileurl'],
            ]);
        $this->success("请求成功");
    }
    public function uploadBase64($base64Str)
    {
        // 将Base64字符串转换为文件并保存
        if ($base64Str) {
            // 获取Base64字符串的类型
            preg_match('/^data:image\/(.*);base64/', $base64Str, $match);
            $ext = $match[1];
            // 生成文件名
            $fileName = uniqid() . '.' . $ext;
            // 获取项目根目录
            //$rootPath =  root_path();
            // 保存文件路径
            $filePath = ROOT_PATH . 'public/uploads/' . $fileName;
            // 保存文件
            file_put_contents($filePath, base64_decode(str_replace($match[0], '', $base64Str)));
            $task=new Task();
            $res=$task->fileUpload($fileName);
            return $res;

    }
    }
}