Login.php
11.8 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
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
<?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');
// if ($post['type'] == 1) {
// $encryptedData = urldecode($encryptedData);
// $iv = urldecode($iv);
// }
$url = "https://api.weixin.qq.com/sns/jscode2session?appid=" . $appid . "&secret=" . $AppSecret . "&js_code=" . $code . "&grant_type=authorization_code";
// file_put_contents("ccc.txt", "授权1:" . date("Y-m-d H:i:s") ."：" . $url . PHP_EOL, FILE_APPEND);
$res = json_decode(http_request($url), true);
if (!$res) {
$res = json_decode(send_post($url), true);
}
$sessionKey = $res['session_key'];
$openid = $res['openid'];//获取用户openid
$unionid = $res['unionid'];//获取用户openid
file_put_contents("ccc.txt", "授权0:" . date("Y-m-d H:i:s") ."：" . json_encode($post,JSON_UNESCAPED_UNICODE) . PHP_EOL, FILE_APPEND);
file_put_contents("ccc.txt", "授权1:" . date("Y-m-d H:i:s") . "：" . json_encode($res, JSON_UNESCAPED_UNICODE) . PHP_EOL, FILE_APPEND);
require_once '../extend/lib/WXBizDataCrypt.class.php';
$pc = new WXBizDataCrypt($appid, $sessionKey);
$errCode = $pc->decryptData($encryptedData, $iv, $data);
$data = json_decode($data, true);
file_put_contents("ccc.txt", "授权2:" . date("Y-m-d H:i:s") . "：" . $errCode . PHP_EOL, FILE_APPEND);
file_put_contents("ccc.txt", "授权3:" . date("Y-m-d H:i:s") ."：". json_encode($data,JSON_UNESCAPED_UNICODE) . PHP_EOL, FILE_APPEND);
if ($errCode != 0) {
$ajax['code'] = 0;
$ajax['info'] = $errCode;
$errCode = $errCode == "-41001" || $errCode == "-41003" ? "授权失败，请尝试重新授权" : $errCode;
$this->error($errCode);
}
if ($openid) {
$openid_info = [
"openid" => $openid,
"unionid" => $unionid,
"from" => "wx",
];
if (!empty($data['nickName'])) {
$openid_info['nickName'] = $data['nickName'];
}
if (!empty($data['gender'])) {
$openid_info['gender'] = $data['gender'];
}
if (!empty($data['avatarUrl'])) {
$openid_info['avatarUrl'] = $data['avatarUrl'];
}
if (!empty($data['country'])) {
$openid_info['country'] = $data['country'];
}
if (!empty($data['province'])) {
$openid_info['province'] = $data['province'];
}
if (!empty($data['city'])) {
$openid_info['city'] = $data['city'];
}
if (!empty($data['phoneNumber'])) {
$openid_info['phoneNumber'] = $data['phoneNumber'];
}
insert_openid_info($openid_info);//更新下微信用户信息到数据库
}
//直接通过unionid 查找用户信息
$userres = Db::name("user")->where("wx_xcx_openid", $openid)->order("id desc")->find();
if (empty($userres)) {
//如果通过小程序openid找不到会员
//注册处理
$extend_data = [
"nickname" => $openid_info['nickName'],
"avatar" => $openid_info["avatarUrl"]?$openid_info["avatarUrl"]:"/default.png",
"wx_xcx_openid" => $openid,
"unionid" => $unionid,
];
$username = $openid ? $openid : suiji_num("TY");
$ret = $this->auth->register($username, "a123456", '', $data['phoneNumber'], $extend_data);
if ($ret) {
$return_data = $this->auth->getUserinfo();
$is_mng_user = 0;//是否是农场管理员 0不是 1是
$mng_area = [];//管辖区域（多个）
$area = Db::name("farm_manager")->alias("a")
->join("farm_farm b", "b.id=a.farm_farm_id")
->where("a.mng_user_id", $return_data['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", $return_data['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;
if (empty($return_data['mobile'])) {
$this->success("授权成功，请继续认证手机号后才能正常使用", $return_data, 2);
} else {
//[农场]这里是新注册用户，有手机号，需要判断下手机号有没有在食堂中存在，若存在就将id绑定过去
$bind = Db::name("farm_manager")->where("mng_admin_phone", $return_data['mobile'])->order("id desc")->find();
if (!empty($bind)) {
Db::name("farm_manager")->where("mng_admin_phone", $return_data['mobile'])->update(["mng_user_id" => $return_data['id']]);
if ($bind['mng_admin_name']) {
//将管理员姓名更新到用户表中
Db::name("user")->where("id", $return_data['id'])->update(["username" => $bind['mng_admin_name']]);
}
}
//[食堂]这里是新注册用户，有手机号，需要判断下手机号有没有在食堂管理员中存在，若存在就将id绑定过去
$bind2 = Db::name("farm_canteenmanager")->where("mng_admin_phone", $return_data['mobile'])->order("id desc")->find();
if (!empty($bind2)) {
Db::name("farm_canteenmanager")->where("mng_admin_phone", $return_data['mobile'])->update(["mng_user_id" => $return_data['id']]);
if ($bind2['mng_admin_name']) {
//将管理员姓名更新到用户表中
Db::name("user")->where("id", $return_data['id'])->update(["username" => $bind2['mng_admin_name']]);
}
}
}
$return_data['avatar'] =full_image($return_data['avatar']);
$this->success("登录成功！", $return_data);
} else {
$this->error($this->auth->getError());
}
} else {
//小程序openid找到了会员
$update_data = [];
$update_data['logintime'] = time();
if (empty($userres['mobile']) && !empty($openid_info['phoneNumber'])) {
$update_data['mobile'] = $openid_info['phoneNumber'];
}
// if (!empty($openid_info['phoneNumber'])) {
// $update_data['username'] = $openid_info['phoneNumber'];
// }
if (!empty($openid_info['nickName']) && $openid_info['nickName']!="微信用户") {
$update_data['nickname'] = $openid_info['nickName'];
}
if(!empty($unionid)){
$update_data['unionid'] = $unionid;
}
if (!empty($openid_info['phoneNumber'])) {
//[农场]这里是已注册过的用户，有手机号，需要判断下手机号有没有在食堂中存在，若存在就将id绑定过去
$bind = Db::name("farm_manager")->where("mng_admin_phone", $openid_info['phoneNumber'])->order("id desc")->find();
if (!empty($bind)) {
Db::name("farm_manager")->where("mng_admin_phone", $openid_info['phoneNumber'])->update(["mng_user_id" => $userres['id']]);
if ($bind['mng_admin_name']) {
//将管理员姓名更新到用户表中
Db::name("user")->where("id", $userres['id'])->update(["username" => $bind['mng_admin_name']]);
}
}
//[食堂]这里是已注册过的用户，有手机号，需要判断下手机号有没有在食堂管理员中存在，若存在就将id绑定过去
$bind2 = Db::name("farm_canteenmanager")->where("mng_admin_phone", $openid_info['phoneNumber'])->order("id desc")->find();
if (!empty($bind2)) {
Db::name("farm_canteenmanager")->where("mng_admin_phone", $openid_info['phoneNumber'])->update(["mng_user_id" => $userres['id']]);
if ($bind2['mng_admin_name']) {
//将管理员姓名更新到用户表中
Db::name("user")->where("id", $userres['id'])->update(["username" => $bind2['mng_admin_name']]);
}
}
}
Db::name("user")->where("wx_xcx_openid", $openid)->update($update_data);
$this->auth->direct($userres['id']);
$return_data = $this->auth->getUserinfo();
$is_mng_user = 0;//是否是农场管理员 0不是 1是
$mng_area = [];//管辖区域（多个）
$area = Db::name("farm_manager")->alias("a")
->join("farm_farm b", "b.id=a.farm_farm_id")
->where("a.mng_user_id", $return_data['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", $return_data['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']);
$this->success(__('登录成功'), $return_data);
}
}
/**
* 给后台添加用户时自动注册用
*/
public function auto_regist_user($username, $password = "a123456", $email = "", $mobile, $extend_data)
{
$ret = $this->auth->register($username, $password, '', $mobile, $extend_data);
if ($ret) {
$return_data = $this->auth->getUserinfo();
return array_callback(true, "用户添加成功", $return_data['id']);
} else {
return array_callback(false, $this->auth->getError());
}
}
}