514 lines
19 KiB
PHP
514 lines
19 KiB
PHP
<?php
|
||
|
||
namespace App\Services;
|
||
|
||
use App\Constants\DoctorTitleCode;
|
||
use App\Constants\HttpEnumCode;
|
||
use App\Model\User as UserModel;
|
||
use App\Model\UserDoctor as UserDoctorModel;
|
||
use App\Model\UserPatient as UserPatientModel;
|
||
use App\Model\UserPharmacist as UserPharmacistModel;
|
||
use App\Utils\Http;
|
||
use App\Utils\Jwt;
|
||
use App\Utils\Log;
|
||
use Extend\TencentIm\Account;
|
||
use Extend\Wechat\Wechat;
|
||
use Hyperf\DbConnection\Db;
|
||
use Hyperf\Redis\Redis;
|
||
use Psr\Container\ContainerExceptionInterface;
|
||
use Psr\Container\NotFoundExceptionInterface;
|
||
use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
|
||
use Symfony\Contracts\HttpClient\Exception\DecodingExceptionInterface;
|
||
use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
|
||
use Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface;
|
||
use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
|
||
|
||
class LoginService extends BaseService
|
||
{
|
||
/**
|
||
* 微信登陆
|
||
* @return array
|
||
* @throws ContainerExceptionInterface
|
||
* @throws NotFoundExceptionInterface
|
||
*/
|
||
public function wechatMobileLogin(): array
|
||
{
|
||
$phone_code = $this->request->input('phone_code');
|
||
$wx_code = $this->request->input('wx_code');
|
||
$user_type = $this->request->input('user_type');
|
||
|
||
$weChat = new Wechat($user_type);
|
||
|
||
// 获取手机号
|
||
$phone_info = $weChat->getPhone($phone_code);
|
||
|
||
if (empty($phone_info) || empty($phone_info['phone_info']) || empty($phone_info['phone_info']['purePhoneNumber'])){
|
||
return fail(HttpEnumCode::GET_WX_ERROR);
|
||
}
|
||
// $phone_info['phone_info']['purePhoneNumber'] = "18221234162";
|
||
|
||
// 获取用户openid
|
||
$wx_info_data = $weChat->codeToSession($wx_code);
|
||
// $wx_info_data = array(
|
||
// "session_key" => "SWfpkHtKZRq/G0ONoxigaQ==",
|
||
// "openid" => "o9gYG441zEAHuYoNX7lwFKiQBzKE",
|
||
// );
|
||
if (empty($wx_info_data['session_key']) || empty($wx_info_data['openid'])) {
|
||
return fail(HttpEnumCode::GET_WX_ERROR);
|
||
}
|
||
|
||
Db::beginTransaction();
|
||
|
||
try {
|
||
// 获取用户信息
|
||
$params = array();
|
||
$params['mobile'] = $phone_info['phone_info']['purePhoneNumber'];
|
||
$user = UserModel::getOne($params);
|
||
if (empty($user)) {
|
||
// 处理药师特殊情况，后台添加，前台不允许注册
|
||
if ($user_type == 3) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::HTTP_ERROR,"账号不存在，请联系客服");
|
||
}
|
||
|
||
// 新增用户表
|
||
$data = array();
|
||
$data['user_name'] = substr($phone_info['phone_info']['purePhoneNumber'],-4);
|
||
$data['mobile'] = $phone_info['phone_info']['purePhoneNumber'];
|
||
$data['wx_mobile'] = $phone_info['phone_info']['purePhoneNumber'];
|
||
$data['user_type'] = $user_type;
|
||
$data['register_method'] = 1;//注册方式（1:小程序授权 2:手机号 ）
|
||
$data['login_ip'] = (new Http())->getIp() ?? "";// 登陆ip
|
||
$data['last_login_at'] = date('Y-m-d H:i:s', time());// 最后登陆时间
|
||
$user = UserModel::addUser($data);
|
||
if (empty($user)) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
|
||
// 新增对应用户数据表
|
||
$data = array();
|
||
$data['user_id'] = $user->user_id;
|
||
$data['user_name'] = $user['user_name'];
|
||
$data['open_id'] = $wx_info_data['openid'];
|
||
$data['union_id'] = $wx_info_data['unionid'] ?? "";
|
||
$data['wx_session_key'] = $wx_info_data['session_key'];
|
||
$data['status'] = 1;
|
||
|
||
if ($user['user_type'] == 1) {
|
||
// 患者
|
||
$user_patient = UserPatientModel::addUserPatient($data);
|
||
if (empty($user_patient)) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
$client_user_id = $user_patient['patient_id'];
|
||
|
||
// 发放用户优惠卷
|
||
$CouponService = new CouponService();
|
||
|
||
$res = $CouponService->DistributeCoupon(1,$user->user_id,$user_patient['patient_id']);
|
||
if (!$res){
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
} elseif ($user['user_type'] == 2) {
|
||
// 新增医生表
|
||
$user_doctor = UserDoctorModel::addUserDoctor($data);
|
||
if (empty($user_doctor)) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
|
||
$client_user_id = $user_doctor['doctor_id'];
|
||
}
|
||
|
||
// 创建im账号
|
||
$account = new Account();
|
||
// 创建单个账号
|
||
$account->createAccount($user->user_id,$user->user_name,"");
|
||
} else {
|
||
// 已注册用户
|
||
// 重复注册不同端
|
||
if ($user_type != $user['user_type']) {
|
||
Db::rollBack();
|
||
$result = UserTypeToString($user['user_type']);
|
||
return fail(HttpEnumCode::GET_WX_ERROR, "手机号已在" . $result . "注册");
|
||
}
|
||
|
||
// 获取对应端用户信息
|
||
$params = array();
|
||
$params['user_id'] = $user->user_id;
|
||
if ($user['user_type'] == 1) {
|
||
$result = UserPatientModel::getOne($params);
|
||
if (!empty($result)){
|
||
$client_user_id = $result['patient_id'];
|
||
}
|
||
} elseif ($user['user_type'] == 2) {
|
||
$result = UserDoctorModel::getOne($params);
|
||
if (!empty($result)){
|
||
$client_user_id = $result['doctor_id'];
|
||
}
|
||
} elseif ($user['user_type'] == 3) {
|
||
$result = UserPharmacistModel::getOne($params);
|
||
if (!empty($result)){
|
||
$client_user_id = $result['pharmacist_id'];
|
||
}
|
||
}
|
||
|
||
if (empty($result)) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
|
||
// 判断用户状态
|
||
if ($result['status'] != 1) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::USER_STATUS_ERROR);
|
||
}
|
||
|
||
// 更新session_key
|
||
$data = array();
|
||
if ($wx_info_data['session_key'] != $result['session_key']) {
|
||
$data['wx_session_key'] = $wx_info_data['session_key'];
|
||
}
|
||
$data['updated_at'] = date('Y-m-d H:i:s', time());
|
||
|
||
$params = array();
|
||
if ($user['user_type'] == 1) {
|
||
$params['patient_id'] = $result['patient_id'];
|
||
$res = UserPatientModel::editUserPatient($params, $data);
|
||
} elseif ($user['user_type'] == 2) {
|
||
$params['doctor_id'] = $result['doctor_id'];
|
||
$res = UserDoctorModel::editUserDoctor($params, $data);
|
||
} elseif ($user['user_type'] == 3) {
|
||
$params['pharmacist_id'] = $result['pharmacist_id'];
|
||
$res = UserPharmacistModel::editUserPharmacist($params, $data);
|
||
}
|
||
|
||
if (!$res) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
}
|
||
|
||
// 记录用户登陆记录
|
||
$Http = new Http();
|
||
$login_ip = $Http->getIp();
|
||
$params = array();
|
||
$params['user_id'] = $user['user_id'];
|
||
|
||
$data = array();
|
||
$data['login_ip'] = $login_ip ?? "";
|
||
$data['last_login_at'] = date('Y-m-d H:i:s', time());
|
||
|
||
UserModel::editUser($params,$data);
|
||
// 组合生成token的数据
|
||
$token_user_data = array();
|
||
$token_user_data['user_id'] = $user['user_id']; // 用户id
|
||
$token_user_data['user_type'] = $user['user_type'];// 用户类型
|
||
$token_user_data['open_id'] = $wx_info_data['openid'];// open_id
|
||
$token_user_data['client_user_id'] = $client_user_id;// 对应客户端id
|
||
|
||
// 发放token
|
||
$Jwt = new Jwt();
|
||
$token = $Jwt->encode($token_user_data);
|
||
|
||
// 组合返回数据
|
||
$data = array();
|
||
$data['token'] = $token;
|
||
$data['user_id'] = $user['user_id'];
|
||
$data['client_user_id'] = $client_user_id;
|
||
|
||
Db::commit();
|
||
return success($data);
|
||
|
||
} catch (\Exception $e) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR, $e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 手机号登陆
|
||
* @return array
|
||
* @throws ContainerExceptionInterface
|
||
* @throws NotFoundExceptionInterface
|
||
*/
|
||
public function mobileLogin(): array
|
||
{
|
||
$code = $this->request->input('code');
|
||
$phone = $this->request->input('phone');
|
||
$user_type = $this->request->input('user_type');
|
||
$wx_code = $this->request->input('wx_code');
|
||
|
||
$redis = $this->container->get(Redis::class);
|
||
// 验证验证码
|
||
$sms_code = $redis->get("login_code" . $phone);
|
||
if (empty($sms_code)){
|
||
return fail(HttpEnumCode::CODE_EXPIRED);
|
||
}
|
||
|
||
if ($sms_code != $code){
|
||
return fail(HttpEnumCode::CODE_ERROR);
|
||
}
|
||
|
||
try {
|
||
$weChat = new Wechat($user_type);
|
||
|
||
// 获取用户openid
|
||
$wx_info_data = $weChat->codeToSession($wx_code);
|
||
$session_key = $wx_info_data['session_key'] ?? "";
|
||
$open_id = $wx_info_data['openid'] ?? "";
|
||
} catch (\Exception $e) {
|
||
// 此处不进行处理
|
||
Log::getInstance()->info($e->getMessage());
|
||
}
|
||
|
||
Db::beginTransaction();
|
||
|
||
try {
|
||
// 获取用户信息
|
||
$params = array();
|
||
$params['mobile'] = $phone;
|
||
$user = UserModel::getOne($params);
|
||
if (empty($user)) {
|
||
// 处理药师特殊情况，后台添加，前台不允许注册
|
||
if ($user_type == 3) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::HTTP_ERROR,"账号不存在，请联系客服");
|
||
}
|
||
|
||
// 新增用户表
|
||
$data = array();
|
||
$data['user_name'] = substr($phone,-4);
|
||
$data['mobile'] = $phone;
|
||
$data['wx_mobile'] = $phone;
|
||
$data['user_type'] = $user_type;
|
||
$data['register_method'] = 2;
|
||
$data['login_ip'] = (new Http())->getIp() ?? "";// 登陆ip
|
||
$data['last_login_at'] = date('Y-m-d H:i:s', time());// 最后登陆时间
|
||
$user = UserModel::addUser($data);
|
||
if (empty($user)) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
|
||
// 新增对应用户数据表
|
||
$data = array();
|
||
$data['user_id'] = $user->user_id;
|
||
$data['user_name'] = $user['user_name'];
|
||
$data['status'] = 1;
|
||
$data['open_id'] = $open_id ?? '';
|
||
$data['wx_session_key'] = $session_key ?? "";
|
||
|
||
if ($user['user_type'] == 1) {
|
||
// 患者
|
||
$user_patient = UserPatientModel::addUserPatient($data);
|
||
if (empty($user_patient)) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
$client_user_id = $user_patient['patient_id'];
|
||
|
||
// 发放用户优惠卷
|
||
$CouponService = new CouponService();
|
||
|
||
$res = $CouponService->DistributeCoupon(1,$user->user_id,$user_patient['patient_id']);
|
||
if (!$res){
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
} elseif ($user['user_type'] == 2) {
|
||
// 新增医生表
|
||
$user_doctor = UserDoctorModel::addUserDoctor($data);
|
||
if (empty($user_doctor)) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
$client_user_id = $user_doctor['doctor_id'];
|
||
}elseif($user['user_type'] == 3){
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}else{
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
} else {
|
||
// 已注册用户
|
||
if ($user_type != $user['user_type']) {
|
||
Db::rollBack();
|
||
$result = UserTypeToString($user['user_type']);
|
||
return fail(HttpEnumCode::HTTP_ERROR, "手机号为" . $result . "账号");
|
||
}
|
||
|
||
$params = array();
|
||
$params['user_id'] = $user->user_id;
|
||
if ($user['user_type'] == 1) {
|
||
$result = UserPatientModel::getOne($params);
|
||
if (!empty($result)){
|
||
$client_user_id = $result['patient_id'];
|
||
}
|
||
} elseif ($user['user_type'] == 2) {
|
||
$result = UserDoctorModel::getOne($params);
|
||
if (!empty($result)){
|
||
$client_user_id = $result['doctor_id'];
|
||
}
|
||
} elseif ($user['user_type'] == 3) {
|
||
$result = UserPharmacistModel::getOne($params);
|
||
if (!empty($result)){
|
||
$client_user_id = $result['pharmacist_id'];
|
||
}
|
||
}else{
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
|
||
if (empty($result)) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
|
||
// 判断用户状态
|
||
if ($result['status'] != 1) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::USER_STATUS_ERROR);
|
||
}
|
||
}
|
||
|
||
// 记录用户登陆记录
|
||
$Http = new Http();
|
||
$login_ip = $Http->getIp();
|
||
$params = array();
|
||
$params['user_id'] = $user['user_id'];
|
||
|
||
$data = array();
|
||
$data['login_ip'] = $login_ip ?? "";
|
||
$data['last_login_at'] = date('Y-m-d H:i:s', time());
|
||
UserModel::editUser($params,$data);
|
||
|
||
// 组合生成token的数据
|
||
$token_user_data = array();
|
||
$token_user_data['user_id'] = $user['user_id']; // 用户id
|
||
$token_user_data['user_type'] = $user['user_type'];// 用户类型
|
||
$token_user_data['open_id'] = $open_id ?? "";// open_id
|
||
$token_user_data['client_user_id'] = $client_user_id;// 对应客户端id
|
||
|
||
// 发放token
|
||
$Jwt = new Jwt();
|
||
$token = $Jwt->encode($token_user_data);
|
||
|
||
// 登录成功，删除验证码
|
||
// $redis->del("login_code" . $phone);
|
||
|
||
// 组合返回数据
|
||
$data = array();
|
||
$data['token'] = $token;
|
||
$data['user_id'] = $user['user_id'];
|
||
$data['client_user_id'] = $client_user_id;
|
||
|
||
Db::commit();
|
||
return success($data);
|
||
|
||
} catch (\Exception $e) {
|
||
Db::rollBack();
|
||
return fail(HttpEnumCode::HTTP_ERROR, $e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 微信授权接口
|
||
* @return array
|
||
* @throws ContainerExceptionInterface
|
||
* @throws NotFoundExceptionInterface
|
||
* @throws ClientExceptionInterface
|
||
* @throws DecodingExceptionInterface
|
||
* @throws RedirectionExceptionInterface
|
||
* @throws ServerExceptionInterface
|
||
* @throws TransportExceptionInterface
|
||
*/
|
||
public function wxAuthorize(): array
|
||
{
|
||
$user_info = $this->request->getAttribute("userInfo") ?? [];
|
||
$wx_code = $this->request->input('wx_code');
|
||
|
||
if (empty($user_info)){
|
||
return fail(HttpEnumCode::GET_WX_ERROR);
|
||
}
|
||
|
||
// 获取用户数据
|
||
$params = array();
|
||
$params['user_id'] = $user_info['user_id'];
|
||
$user = UserModel::getOne($params);
|
||
if (empty($user)){
|
||
return fail();
|
||
}
|
||
|
||
try {
|
||
$weChat = new Wechat($user['user_type']);
|
||
|
||
// 获取用户openid
|
||
$wx_info_data = $weChat->codeToSession($wx_code);
|
||
if (empty($wx_info_data['session_key']) || empty($wx_info_data['openid'])) {
|
||
return fail(HttpEnumCode::GET_WX_ERROR);
|
||
}
|
||
|
||
// 获取对应端用户信息
|
||
$params = array();
|
||
$params['user_id'] = $user['user_id'];
|
||
if ($user['user_type'] == 1) {
|
||
$result = UserPatientModel::getOne($params);
|
||
} elseif ($user['user_type'] == 2) {
|
||
$result = UserDoctorModel::getOne($params);
|
||
} elseif ($user['user_type'] == 3) {
|
||
$result = UserPharmacistModel::getOne($params);
|
||
}
|
||
|
||
if (empty($result)) {
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
|
||
// 判断用户状态
|
||
if ($result['status'] != 1) {
|
||
return fail(HttpEnumCode::USER_STATUS_ERROR);
|
||
}
|
||
|
||
// 更新session_key
|
||
$data = array();
|
||
if ($wx_info_data['session_key'] != $result['session_key']) {
|
||
$data['wx_session_key'] = $wx_info_data['session_key'];
|
||
}
|
||
|
||
if ($wx_info_data['openid'] != $result['open_id']) {
|
||
$data['open_id'] = $wx_info_data['openid'];
|
||
}
|
||
|
||
if (!empty($data)){
|
||
$data['updated_at'] = date('Y-m-d H:i:s', time());
|
||
|
||
$params = array();
|
||
if ($user['user_type'] == 1) {
|
||
$params['patient_id'] = $result['patient_id'];
|
||
$res = UserPatientModel::editUserPatient($params, $data);
|
||
} elseif ($user['user_type'] == 2) {
|
||
$params['doctor_id'] = $result['doctor_id'];
|
||
$res = UserDoctorModel::editUserDoctor($params, $data);
|
||
} elseif ($user['user_type'] == 3) {
|
||
$params['pharmacist_id'] = $result['pharmacist_id'];
|
||
$res = UserPharmacistModel::editUserPharmacist($params, $data);
|
||
}else{
|
||
$res = false;
|
||
}
|
||
|
||
if (!$res) {
|
||
return fail(HttpEnumCode::SERVER_ERROR);
|
||
}
|
||
}
|
||
} catch (\Exception $e) {
|
||
// 此处不进行处理
|
||
return fail(HttpEnumCode::GET_WX_ERROR,$e->getMessage());
|
||
}
|
||
|
||
return success();
|
||
}
|
||
} |