LoginController.php 10.0 KB
<?php
/**
 * @remark :
 * @name   :LoginController.php
 * @author :lyh
 * @method :post
 * @time   :2023/8/19 9:11
 */

namespace App\Http\Controllers\Bside;

use App\Enums\Common\Code;
use App\Events\WebSocketMessage;
use App\Events\WebSocketMessageSent;
use App\Helper\Arr;
use App\Helper\Common;
use App\Helper\Socket;
use App\Helper\Translate;
use App\Helper\Wechat;
use App\Http\Logic\Bside\User\UserLoginLogic;
use App\Models\File\Image;
use App\Models\Project\Project;
use App\Models\Service\Service;
use App\Models\Sms\SmsLog;
use App\Models\Template\Template;
use App\Models\Template\TemplateModule;
use App\Models\User\User as UserModel;
use App\Utils\EncryptUtils;
use \Illuminate\Support\Facades\Cache;
use Mrgoon\AliSms\AliSms;

class LoginController extends BaseController
{

    /**
     * @remark :登录
     * @name   :login
     * @author :lyh
     * @method :post
     * @time   :2023/8/19 9:12
     */
    public function login(){
        $this->request->validate([
            'mobile'=>['required', 'regex:/^1[3-9]\d{9}$/'],
            'password'=>['required'],
        ],[
            'mobile.required'=>'电话号码必须填写',
            'password.required'=>'内容必须填写',
            'mobile.regex' => '请输入正确的手机号码',
        ]);
        $userLogic = new UserLoginLogic();
        $project = $userLogic->login();
        $this->response('success',Code::SUCCESS,$project);
    }

    /**
     * @remark :根据选择的项目id登录
     * @name   :projectLogin
     * @author :lyh
     * @method :post
     * @time   :2023/8/29 15:21
     */
    public function projectLogin(){
        $this->request->validate([
            'project_id' => 'required',
            'mobile' => 'required'
        ],[
            'project_id.required' => '请选择项目',
            'mobile.required' => '参数错误',
        ]);
        $userLogic = new UserLoginLogic();
        $info = $userLogic->projectLogin();
        $this->response('success',Code::SUCCESS,$info);
    }

    /**
     * @remark :自动登录
     * @name   :autologin
     * @author :lyh
     * @method :post
     * @time   :2023/8/19 9:12
     */
    public function autologin(UserLoginLogic $logic, EncryptUtils $encrypt)
    {
        $serviceSettingModel = new Service();
        $info = $serviceSettingModel->read(['type'=>4]);
        if($info === false){
            $this->response('当前访问地址不存在',Code::USER_ERROR);
        }
        $data = $encrypt->unlock_url($this->param['code'], $info['values']);
        $data = json_decode($data, true);
        if(!isset($data['project_id']) && !isset($data['user_id'])){
            $this->response('无效Code',Code::USER_ERROR);
        }
        $res = $logic->autologin($data);
        $this->response('success',Code::SUCCESS, $res);
    }


    /**
     * @remark :发送验证码
     * @name   :sendLoginSms
     * @author :lyh
     * @method :post
     * @time   :2023/8/19 9:13
     */
    public function sendLoginSms()
    {
        $this->request->validate([
            'mobile'=>['required', 'regex:/^1[3-9]\d{9}$/'],
        ],[
            'mobile.required' => '手机号码不能为空',
            'mobile.regex' => '请输入正确的手机号码',
        ]);
        $mobile = $this->param['mobile'];
        $user = UserModel::where(['mobile' => $mobile])->first();
        if (empty($user)) {
            $this->response('请输入正确的手机号码!', Code::USER_LOGIN_ERROE);
        }
        $last_sms = SmsLog::getLastLog($mobile, SmsLog::TYPE_LOGIN);
        if ($last_sms && $last_sms->use = SmsLog::USE_USABLE && time() - strtotime($last_sms->created_at) < 60) {
            $this->response('请不要重复发送短信!', Code::USER_LOGIN_ERROE);
        }
        $template = config('aliyunsms.login_sms_temp');
        $code['code'] = rand(100000,999999);
        $ali_sms = new AliSms();
        $send = $ali_sms->sendSms(strval($mobile), $template, $code);
        if (empty($send->Code) && $send->Code != 'OK') {
            $this->response('发送失败, 请稍后重试!', Code::USER_LOGIN_ERROE);
        }
        SmsLog::createLog($mobile, $code['code']);
        $this->response('success');
    }

    /**
     * @remark :根据关键字生成链接
     * @name   :pubLink
     * @author :lyh
     * @method :post
     * @time   :2023/6/28 16:13
     */
    public function stringTranslation(){
        $str = Translate::tran($this->param['str'], 'en');
        $this->response('success',Code::SUCCESS,strtolower($str));
    }

    /**
     * @remark :微信登录
     * @name   :wechatLogin
     * @author :lyh
     * @method :post
     * @time   :2023/8/23 18:46
     */
    public function qrcode(){
        $this->request->validate([
            'type' => 'required',
        ],[
            'type.required' => '请选择项目',
        ]);
        if(!isset($this->param['id'])){
            $this->param['id'] = 0;
        }
        $wechat = new Wechat();
        $accessToken = $wechat->getAccessToken();
        $data = $wechat->setQrcode('global-v6_'.$this->param['type'].'_'.$this->param['id'],$accessToken);
        if(!empty($data)){
            $data['url'] = "https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=".$data['ticket'];
        }
        $this->response('success',Code::SUCCESS,$data);
    }

    /**
     * @remark :微信回调方法
     * @name   :wechatLogin
     * @author :lyh
     * @method :post
     * @time   :2023/8/24 9:30
     */
    public function eventMessage(){
        $message = file_get_contents("php://input");
        $message = simplexml_load_string($message, 'SimpleXMLElement', LIBXML_NOCDATA | LIBXML_NOERROR);
        $jsonData = json_encode($message);
        $arrayData = json_decode($jsonData, true);
        $data = $this->setWechat($arrayData['ToUserName'],$arrayData['EventKey']);
        if($data['code'] == 0){//登录失败,请先绑定
            $resMessage = $data['message'];
        }elseif($data['code'] == 1){
            $resMessage = $data['message'];
        }elseif($data['code'] == 2){
            $resMessage = $data['message'];
        }else{
            $resMessage = $data['message'];
        }
        Cache::add($arrayData['Ticket'],$data,300);
        return "<xml>
                <ToUserName><![CDATA[$message->FromUserName]]></ToUserName>
                <FromUserName><![CDATA[$message->ToUserName]]></FromUserName>
                <CreateTime>".time()."</CreateTime>
                <MsgType><![CDATA[text]]></MsgType>
                <Content><![CDATA[$resMessage]]></Content>
            </xml>";
    }

    /**
     * @remark :登录成功响应
     * @name   :getWechatLoginInfo
     * @author :lyh
     * @method :post
     * @time   :2023/9/1 10:12
     */
    public function getWechatLoginInfo(){
        $this->request->validate([
            'ticket' => 'required',
        ],[
            'ticket.required' => 'ticket不能为空',
        ]);
        $info = Cache::get($this->param['ticket']);
        $this->response('success',Code::SUCCESS,$info);
    }

    /**
     * @remark :解token
     * @name   :globalSo_v6_login
     * @author :lyh
     * @method :post
     * @time   :2023/8/24 17:37
     */
    public function globalSo_v6_login(UserLoginLogic $logic){
        $common = new Common();
        $arr = $common->decrypt($this->param['token']);
        if(empty($arr)){
            $this->response('登录失败',Code::USER_ERROR);
        }
        $userModel = new UserModel();
        $info = $userModel->read(['mobile'=>$arr['phone']]);
        if($info === false){
            $this->response('当前用户不存在请联系管理员',Code::USER_ERROR);
        }
        $data = [
            'user_id'=>$info['id'],
            'manager_id'=>0,
        ];
        $info = $logic->autologin($data);
        $this->response('success',Code::SUCCESS,['info'=>$info]);
    }

    /**
     * @remark :微信登录处理数据
     * @name   :wechatLogin
     * @author :lyh
     * @method :post
     * @time   :2023/8/31 9:13
     */
    public function setWechat($wechat,$eventKey){
        $userLoginLogic = new UserLoginLogic();
        $key = explode("_",$eventKey);
        if($key[1] == 'login'){
            $data = $userLoginLogic->wechatLogin($wechat);
        }elseif($key[1] == 'bind'){
            $data = $userLoginLogic->wechatBind($wechat,$key[2]);
        }else{
            $data = [
                'code'=>0,
                'message'=>'关注成功,请登录后绑定账号后扫码',
            ];
        }
        return $data;
    }

    public function ceshi(){
        $templateModel = new TemplateModule();
        $list = $templateModel->list();
        foreach ($list as $k => $v){
            $html = $this->updateHtml();
            $templateModel->edit(['html'=>$html],['id'=>$v['id']]);
        }
        return 1;
    }

    public function re(&$html,$srcValue,$path){
        $html = str_replace(
            $srcValue,
            $path,
            $html
        );
        return $html;
    }

    public function updateHtml(){
        $html = $this->re($v['html'],'admin.item.globalso.site','ecdn6.globalso.com/');
//        $html = $this->re($v['html'],'https://develop.globalso.com/b/image/','https://ecdn6.globalso.com/public/template/');
    }

    public function updateCe(){
        $templateModel = new TemplateModule();
        $list = [];
        foreach ($list as $k => $v){
            preg_match_all('/\"https:\/\/develop.globalso.com\/a\/image\/(.*?)\"/', $v['html'], $matches);
            if (!empty($matches[1])) {
                $srcValues = $matches[1];
                $imageModel = new Image();
                $html = $v['html'];
                foreach ($srcValues as $srcValue) {
                    $image_info = $imageModel->read(['hash' => $srcValue]);
                    if ($image_info !== false) {
                        $path = basename($image_info['path']);
                        $html = $this->re($html, $srcValue, $path);
                    }
                }
            }
            $templateModel->edit(['html'=>$html],['id'=>$v['id']]);
        }
    }

}