Login.php
7.3 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
<?php
/**
* Created by PhpStorm.
* Login: Kevin
* Date: 2023/03/22
* Time: 14:10
*/
namespace app\api\controller\v1;
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 = $this->AppID;
$AppSecret = $this->AppSecret;
$post = $this->request->post();
$code = $post['code'];// I('post.code');
$encryptedData = $post['encryptedData'];//I('post.encryptedData');
$iv = $post['iv'];//I('post.iv');
$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);
$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();
$this->success(__('登录成功'), $return_data);
//查询到了用户信息
//$this->bind($user['id'],$user['moblie']);
}else{
//未查询到用户信息 添加用户信息
$username = $res['openid'] ? $res['openid'] : suiji_num("TY");
$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 = $this->AppID;
$AppSecret = $this->AppSecret;
$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]);
$this->bind($user_id,$moblie);
}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);
}
}