xuanchen/water-back
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

阶段更新

Browse Source
This commit is contained in:
徐永宾
2023-01-12 14:47:38 +08:00
parent 088dd64b2f
commit 5b8901281c
626 changed files with 39326 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
modules/User/Http/Controllers/Api/Socialite/Controller.php Normal file
View File

@@ -0,0 +1,14 @@
<?php
namespace Modules\User\Http\Controllers\Api\Socialite;
use Illuminate\Http\Request;
abstract class Controller extends \App\Api\Controllers\Controller
{
abstract public function app(Request $request);
abstract public function query(Request $request);
}

93
modules/User/Http/Controllers/Api/Socialite/UniCloudController.php Normal file
View File

@@ -0,0 +1,93 @@
<?php
namespace Modules\User\Http\Controllers\Api\Socialite;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Validator;
use Jason\Api\Api;
use Modules\User\Events\UserLoginSuccess;
use Modules\User\Models\User;
class UniCloudController extends Controller
{
public function app(Request $request)
{
$validator = Validator::make($request->all(), [
'access_token' => 'required',
'openid' => 'required',
], [
'access_token.required' => 'access_token必须填写',
'openid.required' => 'openid必须填写',
]);
if ($validator->fails()) {
return $this->failed($validator->errors()->first(), 422);
}
$data = [
'access_token' => $request->access_token,
'openid' => $request->openid,
];
$secret = config('user.socialite.unicloud.self_secret', '');
$domain = config('user.socialite.unicloud.domain', '');
$url = config('user.socialite.unicloud.cloud_function_url.one_key', '');
if (! $secret || ! $domain || ! $url) {
return $this->failed('过程参数存在错误');
}
ksort($data);
$signString = urldecode(http_build_query($data));
$sign = hash_hmac('sha256', $signString, $secret);
$params = $signString.'&sign='.$sign;
$url = $domain.$url.'?'.$params;
$res = json_decode(file_get_contents($url));
if ($res->success) {
$user = User::firstOrCreate([
'username' => $res->phoneNumber,
], [
'password' => 111111,
]);
$token = Api::login($user);
event(new UserLoginSuccess($user, $request, '本机一键登录'));
return $this->success([
'token_type' => 'Bearer',
'access_token' => $token,
'is_new' => $user->wasRecentlyCreated,
]);
} else {
return $this->failed('一键登录失败');
}
}
public function query(Request $request)
{
$validator = Validator::make($request->all(), [
'mobile' => 'required',
], [
'mobile.required' => '请传入手机号',
]);
if ($validator->fails()) {
return $this->failed($validator->errors()->first(), 422);
}
$user = User::firstOrCreate([
'username' => $request->mobile,
], [
'password' => 111111,
]);
$token = Api::login($user);
event(new UserLoginSuccess($user, $request, '本机一键登录'));
return $this->success([
'token_type' => 'Bearer',
'access_token' => $token,
'is_new' => $user->wasRecentlyCreated,
]);
}
}

489
modules/User/Http/Controllers/Api/Socialite/WeChatController.php Normal file
View File

@@ -0,0 +1,489 @@
<?php
namespace Modules\User\Http\Controllers\Api\Socialite;
use App\Models\AreaCode;
use EasyWeChat\Factory;
use EasyWeChat\Kernel\Exceptions\InvalidConfigException;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Validator;
use Jason\Api\Api;
use Modules\User\Events\UserLoginSuccess;
use Modules\User\Facades\Sms;
use Modules\User\Http\Requests\WechatMiniRequest;
use Modules\User\Models\User;
use Modules\User\Models\UserSubscribe;
use Modules\User\Models\UserWechat;
use Modules\User\Traits\WechatTrait;
use Vinkla\Hashids\Facades\Hashids;
class WeChatController extends Controller
{
use WechatTrait;
protected array $config = [];
/**
* Notes : APP 登录
*
* @Date : 2021/6/10 3:40 下午
* @Author : Mr.wang
* @param Request $request
* @return JsonResponse
*/
public function app(Request $request): JsonResponse
{
$validator = Validator::make($request->all(), [
'union_id' => 'required',
'mobileNo' => 'required|phone:CN,mobile',
'code' => 'required',
], [
'union_id.required' => 'unionId必须填写',
'mobileNo.required' => '手机号码必须填写',
'mobileNo.phone' => '手机号码格式不正确',
'code.required' => '验证码必须填写',
]);
if ($validator->fails()) {
return $this->failed($validator->errors()->first(), 422);
}
$unionId = $request->union_id;
$wechat = UserWechat::where('unionid', $unionId)->first();
if (empty($wechat)) {
$mobileNo = $request->mobileNo;
$code = $request->code;
$check = Sms::checkCode($mobileNo, $code);
if ($check == false) {
return $this->failed('验证码不正确', 422);
}
$user = User::firstOrCreate([
'username' => $mobileNo,
], [
'password' => 111111,
]);
$wechat = $user->wechat()->firstOrcreate([
'unionid' => $unionId,
'nickname' => $request->nickname ?? '',
'avatar' => $request->avatar ?? '',
'sex' => $request->gender ?? 0,
'country' => $request->country ?? '',
'province' => $request->province ?? '',
'city' => $request->city ?? '',
]);
$wechat->app()->firstOrcreate([
'openid' => $request->open_id ?? '',
]);
$user->info()->update([
'nickname' => $request->nickname ?? $user->info->nickname,
'avatar' => $request->avatar ?? '',
]);
$token = Api::login($user);
return $this->success([
'token_type' => 'Bearer',
'access_token' => $token,
'is_new' => $user->wasRecentlyCreated,
]);
} else {
$token = Api::login($wechat->user);
event(new UserLoginSuccess(Api::user(), $request, '微信授权'));
return $this->success([
'token_type' => 'Bearer',
'access_token' => $token,
'is_new' => false,
]);
}
}
/**
* Notes : 小程序手机号登录
*
* @Date : 2021/7/29 17:21
* @Author : Mr.wang
* @param WechatMiniRequest $request
* @return JsonResponse
* @throws InvalidConfigException
*/
public function mini(WechatMiniRequest $request): JsonResponse
{
$code = $request->code;
$weChat = app('wechat.mini_program');
$session = $weChat->auth->session($code);
if ($session->errcode) {
return $this->failed($session->errmsg);
}
try {
$decryptedData = $weChat->encryptor->decryptData(
$session->session_key,
$request->iv,
$request->encryptedData
);
$mobile = $decryptedData['purePhoneNumber'];
$user = User::where('username', $mobile)->first();
if (! $user) {
$user = User::create([
'username' => $mobile,
'password' => 111111,
]);
$user->info()->create([
'nickname' => $request->nickname ?? '',
'avatar' => $request->avatar ?? '',
]);
}
$token = Api::login($user);
event(new UserLoginSuccess(Api::user(), $request, '微信授权'));
return $this->success([
'token_type' => 'Bearer',
'access_token' => $token,
'is_new' => $user->wasRecentlyCreated,
]);
} catch (\Exception $exception) {
return $this->failed($exception->getMessage());
}
}
/**
* Notes : 公众号登录
*
* @Date : 2021/5/26 3:14 下午
* @Author : < Jason.C >
*/
public function official()
{
}
public function query(Request $request): JsonResponse
{
$unionId = $request->union_id ?? '';
if (empty($unionId)) {
return $this->failed('', 404);
}
$wechat = UserWechat::where('unionid', $unionId)->first();
if (empty($wechat)) {
return $this->success([
'union_id' => $unionId,
]);
} else {
$token = Api::login($wechat->user);
event(new UserLoginSuccess(Api::user(), $request, '微信授权'));
return $this->success([
'token_type' => 'Bearer',
'access_token' => $token,
]);
}
}
/**
* Notes: 入库微信信息
*
* @Author: 玄尘
* @Date: 2022/8/2 11:16
*/
public function addWechatUser(): JsonResponse
{
try {
$user = Api::user();
if (! $user) {
throw new \Exception('操作失败请登录。');
}
$wechatUser = $user->wechat;
$weUser = $this->getUserFromCode();
$openid = $weUser->getId();
$baseUser = $this->getWechatUser($openid);
$unionid = '';
$raw = $weUser->getRaw();
if (isset($raw['unionid'])) {
$unionid = $raw['unionid'];
}
if (! $openid) {
if ($raw && $raw['errmsg']) {
throw new \Exception($raw['errmsg']);
}
throw new \Exception('code解密失败');
}
if (! $user->info->avatar) {
//更新头像
$user->info->update([
'avatar' => $weUser->getAvatar(),
]);
}
if (! $wechatUser) {
$wechatUser = $user->wechat()
->firstOrCreate([
'unionid' => $unionid,
'nickname' => $weUser->getNickname(),
'avatar' => $weUser->getAvatar(),
]);
} elseif (empty($wechatUser['unionid']) && ! empty($unionid)) {
$wechatUser->update([
'unionid' => $unionid,
]);
}
if (! $wechatUser->official) {
$wechatUser->official()->firstOrCreate([
'openid' => $weUser->getId(),
'subscribe' => $baseUser->subscribe
]);
} else {
$wechatUser->official()->update([
'subscribe' => $baseUser->subscribe
]);
}
//设置关注状态
if ($unionid) {
$this->setUserSubscribe($unionid, $openid, $baseUser->subscribe);
}
return $this->success([
'openid' => $openid,
'subscribe' => $baseUser->subscribe,
]);
} catch (\Exception $exception) {
return $this->failed($exception->getMessage());
}
}
/**
* Notes: 小程序入库
*
* @Author: 玄尘
* @Date: 2022/9/23 14:46
* @param Request $request
* @return JsonResponse|mixed
*/
public function miniAddWechatUser(Request $request)
{
$user = Api::user();
$validator = \Validator::make($request->all(), [
'code' => 'required',
'iv' => 'required',
'encryptedData' => 'required',
], [
'code.required' => '缺少参数：code',
'iv.required' => '缺少参数：iv',
'encryptedData.mobile' => '缺少参数：encryptedData',
]);
if ($validator->fails()) {
return $this->failed($validator->errors()->first());
}
try {
$code = $request->code;
$unionid = '';
$weChat = app('wechat.mini_program');
$session = $weChat->auth->session($code);
if (isset($session->unionid)) {
$unionid = $session->unionid;
}
if (isset($session->errcode)) {
return $this->failed($session->errmsg);
}
$openid = $session->openid;
$wechatUser = $user->wechat;
$decryptedData = $weChat->encryptor->decryptData(
$session->session_key,
$request->iv,
$request->encryptedData
);
if (! $wechatUser) {
$wechatUser = $user->wechat()
->firstOrCreate([
'unionid' => $unionid,
'nickname' => $decryptedData['nickName'] ?? '',
'avatar' => $decryptedData['avatarUrl'] ?? '',
]);
} elseif (empty($wechatUser['unionid']) && ! empty($unionid)) {
$wechatUser->update([
'unionid' => $unionid,
]);
}
if (! $wechatUser->mini) {
$wechatUser->mini()->firstOrCreate([
'openid' => $openid,
]);
}
$userSubscribe = UserSubscribe::query()
->where('unionid', $unionid)
->where('subscribe', 1)
->first();
if ($userSubscribe && ! $wechatUser->official) {
if (! $wechatUser->official) {
$wechatUser->official()
->firstOrCreate([
'openid' => $userSubscribe->openid,
'subscribe' => $userSubscribe->subscribe
]);
} else {
$wechatUser->official()->update([
'subscribe' => $userSubscribe->subscribe
]);
}
}
return $this->success([
'openid' => $openid,
'subscribe' => $userSubscribe ? 1 : 0,
]);
} catch (\Exception $e) {
return $this->failed($e->getMessage());
}
}
/**
* Notes: 小程序登录加注册
*
* @Author: 玄尘
* @Date: 2023/1/12 8:53
* @param Request $request
* @return JsonResponse|mixed
*/
public function miniLoginAndReg(Request $request)
{
$validator = \Validator::make($request->all(), [
'code' => 'required',
'iv' => 'required',
'encryptedData' => 'required',
], [
'code.required' => '缺少参数：code',
'iv.required' => '缺少参数：iv',
'encryptedData.mobile' => '缺少参数：encryptedData',
]);
if ($validator->fails()) {
return $this->failed($validator->errors()->first());
}
try {
$code = $request->code;
$invite_code = $request->invite ?? '';//推荐码
$weChat = app('wechat.mini_program');
$session = $weChat->auth->session($code);
if (isset($session->errcode)) {
return $this->failed($session->errmsg);
}
$decryptedData = $weChat->encryptor->decryptData(
$session->session_key,
$request->iv,
$request->encryptedData
);
$user = User::query()->where('username', $decryptedData['phoneNumber'])->first();
if (! $user) {
$parent = 0;
if ($invite_code) {
$invite = Hashids::connection('code')->decode($invite_code);
if (empty($invite)) {
return $this->failed('邀请码不正确');
}
$parent = $invite[0];
}
$user = User::query()
->firstOrCreate([
'username' => $decryptedData['phoneNumber'],
], [
'parent_id' => $parent,
'password' => 111111,
]);
}
$token = Api::login($user);
return $this->success([
'token_type' => 'Bearer',
'access_token' => $token,
]);
} catch (\Exception $e) {
return $this->failed($e->getMessage());
}
}
/**
* Notes: description
*
* @Author: 玄尘
* @Date: 2023/1/12 10:48
*/
public function updateUserData(Request $request)
{
$user = Api::user();
$delivery_code = $request->delivery_code ?? '';//提货码
$name = $request->name ?? '';//提货码
$validator = \Validator::make($request->all(), [
'delivery_code' => 'required',
'name' => 'required',
], [
'delivery_code.required' => '缺少提货码',
'name.required' => '缺少姓名',
]);
if ($validator->fails()) {
return $this->failed($validator->errors()->first());
}
if ($name) {
$user->info->update([
'nickname' => $name
]);
}
if ($delivery_code) {
if (! $user->info->delivery_code) {
$areaCode = AreaCode::query()->where('code', $delivery_code)->first();
if ($areaCode->user_id) {
return $this->failed('当前提货码已被别人使用');
}
$user->info->update([
'delivery_code' => $delivery_code
]);
$areaCode->update([
'user_id' => $user->id
]);
} else {
if ($user->info->delivery_code && $user->info->delivery_code != $delivery_code) {
return $this->failed('您已经绑定过提货码，不能重复绑定');
}
}
}
return $this->success('更新成功');
}
}