BaoMa/app/Http/Controllers/Api/V1/CommonController.php

<?php
/**
 * Created by PhpStorm.
 * User: zilongs
 * Date: 20-9-23
 * Time: 上午11:26
 */

namespace App\Http\Controllers\Api\V1;

use App\Http\Controllers\Controller;
use App\Models\Area;
use App\Models\Banner;
use App\Models\HelpInfo;
use App\Models\Icons;
use App\Models\Order;
use App\Models\OrderPatient;
use App\Models\SystemConfig;
use App\Models\User;
use EasyWeChat\Factory;
use Cache;

class CommonController extends Controller
{
    public function wxLogin()
    {
        $req = request()->post();
        $this->validate(request(), [
            'wechat_code' => 'required',
            'phone|手机号' => 'max:20',
            'verify_code|验证码' => 'integer',
            'nickname|昵称' => 'max:50',
            'avatar|头像' => 'url',
            'latitude|纬度' => 'numeric',
            'longitude|纬度' => 'numeric',
        ]);

        if (!empty($req['phone'])) {
            if (empty($req['verify_code'])) {
                return out(null, 10003, '验证码不能为空');
            }
            $verify_code = Cache::get($req['phone'].'-1');
            if($verify_code != $req['verify_code']){
                if (env('APP_ENV') == 'online' || $req['verify_code'] != '111111') {
                    return out(null, 10004, '验证码错误');
                }
            }
            Cache::delete($req['phone'].'-1');
        }

        $app = Factory::miniProgram(config('config.wechat_small_program'));
        $data = $app->auth->session($req['wechat_code']);
        if (empty($data['openid'])){
            return out(null, 10001, '微信登录code错误');
        }

        $session_key = !empty($data['session_key']) ? $data['session_key'] : '';
        $user = User::select(['id', 'status', 'phone', 'nickname', 'avatar'])->where('openid', $data['openid'])->first();
        if(!empty($req['iv']) && !empty($req['encryptData'])) {
            $decryptedData = $app->encryptor->decryptData($session_key, $req['iv'], $req['encryptData']);
            \Log::info($decryptedData);
            if(isset($decryptedData['unionId']))$data['unionid'] = $decryptedData['unionId'];
        }
        if (empty($user)){
            if (!empty($req['phone']) && User::where('phone', $req['phone'])->exists()) {
                User::where('phone', $req['phone'])->update([
                    'openid' => $data['openid'],
                    'unionid' => $data['unionid'] ?? '',
                    'latitude' => $req['latitude'] ?? 0,
                    'longitude' => $req['longitude'] ?? 0,
                    'session_key' => $session_key,
                    'last_login_time' => time(),
                    'avatar' => request()->getScheme().'://'.request()->getHost().'/img/default-head.png',
                ]);
                $user = User::where('phone', $req['phone'])->first();
            }
            else {
                $add = [
                    'openid' => $data['openid'],
                    'unionid' => $data['unionid'] ?? '',
                    'latitude' => $req['latitude'] ?? 0,
                    'longitude' => $req['longitude'] ?? 0,
                    'phone' => $req['phone'] ?? '',
                    'session_key' => $session_key,
                    'last_login_time' => time(),
                ];

                $add['nickname'] = $req['nickname'] ?? '';
                $add['avatar'] = $req['avatar'] ?? request()->getScheme().'://'.request()->getHost().'/img/default-head.png';
                $user = User::create($add);
                if (empty($add['nickname'])) {
                    $nickname = '用户'.base_convert($user['id'], 10, 16);
                    User::where('id', $user['id'])->update(['nickname' => $nickname]);
                }
            }
        }
        else {
            if ($user['status'] == 0) {
                return out(null, 10002, '该账号已被冻结');
            }

            $update = [
                'nickname' => $req['nickname'] ?? '',
                'unionid' => $data['unionid'] ?? '',
                'avatar' => $req['avatar'] ?? '',
                'latitude' => $req['latitude'] ?? 0,
                'longitude' => $req['longitude'] ?? 0,
                'phone' => $req['phone'] ?? '',
                'session_key' => $session_key,
                'last_login_time' => time(),
            ];
            $update = array_filter($update);

            if (empty($req['nickname']) && empty($user['nickname'])) {
                $update['nickname'] = $req['nickname'] = '用户'.base_convert($user['id'], 10, 16);;
            }
            if (empty($req['avatar']) && empty($user['avatar'])) {
                $update['avatar'] = $req['avatar'] = request()->getScheme().'://'.request()->getHost().'/img/default-head.png';
            }

            User::where('id', $user['id'])->update($update);
        }

        $token = aes_encrypt(['id' => $user['id'], 'time' => time()]);

        $req['token'] = $token;
        $req['id'] = $user['id'];
        $req['flag'] = 'member_'.$user['id'];
        return out($req);
    }

    public function getPhoneNumber()
    {
        $req = request()->post();
        $this->validate(request(), [
            'wechat_code' => 'required',
            'iv' => 'required',
            'encryptData' => 'required',
        ]);

        try {
            $app = Factory::miniProgram(config('config.wechat_small_program'));
            $data = $app->auth->session($req['wechat_code']);
            if (empty($data['openid']) || empty($data['session_key'])){
                return out(null, 10001, '微信code错误');
            }

            $decryptedData = $app->encryptor->decryptData($data['session_key'], $req['iv'], $req['encryptData']);
            if (empty($decryptedData['phoneNumber'])) {
                return out(null, 10002, '授权手机号错误');
            }
            \Log::info($decryptedData);
            if(isset($decryptedData['unionId']))$data['unionid'] = $decryptedData['unionId'];
            if (!User::where('openid', $data['openid'])->exists()){
                if (User::where('phone', $decryptedData['phoneNumber'])->exists()) {
                    User::where('phone', $decryptedData['phoneNumber'])->update([
                        'openid' => $data['openid'],
                        'unionid' => $data['unionid'] ?? '',
                        'session_key' => $data['session_key'],
                        'avatar' => request()->getScheme().'://'.request()->getHost().'/img/default-head.png',
                        'last_login_time' => time(),
                    ]);
                }
                else {
                    $user = User::create([
                        'openid' => $data['openid'],
                        'unionid' => $data['unionid']?? '',
                        'phone' => $decryptedData['phoneNumber'],
                        'session_key' => $data['session_key'],
                        'avatar' => request()->getScheme().'://'.request()->getHost().'/img/default-head.png',
                        'last_login_time' => time(),
                    ]);
                    $nickname = '用户'.base_convert($user['id'], 10, 16);
                    User::where('id', $user['id'])->update(['nickname' => $nickname]);
                }
            }

        } catch (\Exception $e) {
            return out(null, 10003, '获取手机号失败', $e->getMessage());
        }

        return out($decryptedData);
    }

    public function getUserByCode()
    {
        $req = request()->post();
        $this->validate(request(), [
            'wechat_code' => 'required',
        ]);

        $app = Factory::miniProgram(config('config.wechat_small_program'));
        $data = $app->auth->session($req['wechat_code']);
        if (empty($data['openid'])){
            return out(null, 10001, '微信code错误');
        }

        $user = User::select(['id', 'status', 'phone', 'nickname', 'avatar'])->where('openid', $data['openid'])->first();
        if (!empty($user) && $user['status'] == 0) {
            return out(null, 10002, '该账号已被冻结');
        }

        return out($user);
    }

    public function uploadFile()
    {
        $file = request()->file('file');
        if (empty($file)) {
            return out(null, 10001, '文件不能为空');
        }

        $path = $file->store('uploads/'.date('Ymd'));
        $url = request()->getScheme().'://'.request()->getHost().'/'.$path;

        return out(['url' => $url]);
    }

    public function areaList()
    {
        $areas = Area::get();
        $data1 = $data2 = $data3 = [];
        foreach ($areas as $k => $v) {
            if ($v['level'] == 1) {
                $data1[$k]['id'] = $v['id'];
                $data1[$k]['name'] = $v['name'];
                $data1[$k]['sub'] = [];
            }
            if ($v['level'] == 2) {
                $arr = [];
                $arr['id'] = $v['id'];
                $arr['name'] = $v['name'];
                //$arr['sub'] = [];
                $data2[$v['parent_id']][] = $arr;
            }
            /*if ($v['level'] == 3) {
                $arr = [];
                $arr['id'] = $v['id'];
                $arr['name'] = $v['name'];
                $data3[$v['parent_id']][] = $arr;
            }*/
        }

        /*foreach ($data2 as $k => $v) {
            foreach ($v as $k1 => $v1) {
                $data2[$k][$k1]['sub'] = $data3[$v1['id']]??[];
            }
        }*/

        foreach ($data1 as $k => $v) {
            $data1[$k]['sub'] = $data2[$v['id']]??[];
        }

        return out($data1);
    }

    public function sendVerifyCode()
    {
        //防止恶意刷验证码接口，一分钟最多10次
        check_repeat_request(60, 10);
        $req = request()->post();
        $this->validate(request(), [
            'type' => 'required|integer',
            'phone|手机号' => 'required',
        ]);

        if($req['type'] == 3 || $req['type'] == 4){
            $user = User::getUserByToken();
            if ($user['phone'] != $req['phone']){
                return out(null, 30007, '该手机号不是注册时的手机号');
            }
        }
        if ($req['type'] == 5) {
            if (User::where('phone', $req['phone'])->exists()) {
                return out(null, 30008, '此手机号已经被占用');
            }
        }

        $verify_code = generate_code();
        $result = send_sms($req['phone'], 'verify_template_code', ['code' => $verify_code]);
        if (empty($result['Code']) || $result['Code'] != 'OK'){
            return out(null, 30010, '验证码发送失败，请稍后重试');
        }

        Cache::set($req['phone'].'-'.$req['type'], $verify_code, config('config.aly_sms.sms_verify_code_expire'));

        return out();
    }

    public function doc()
    {
        $database = env('DB_DATABASE');
        $prefix = env('DB_PREFIX');
        $exclude_tables = "'bm_password_resets','bm_admin_menu','bm_admin_users','bm_failed_jobs','bm_migrations'";

        $sql = "select TABLE_NAME name,TABLE_COMMENT comment from INFORMATION_SCHEMA.TABLES where TABLE_SCHEMA='".$database."' and TABLE_NAME not in (".$exclude_tables.")";
        $tables = \DB::select($sql);
        $map1 = $map2 = [];
        $i = round(count($tables)/2);
        foreach ($tables as $k => $v) {
            $name = str_replace($prefix, '', $v->name);
            if ($k >= $i) {
                $map1[$v->name] = $name.'('.$v->comment.')';
            }
            else {
                $map2[$v->name] = $name.'('.$v->comment.')';
            }
        }

        $data1 = [];
        foreach ($map1 as $k => $v){
            $sql = "select COLUMN_NAME name, DATA_TYPE type, COLUMN_COMMENT comment from INFORMATION_SCHEMA.COLUMNS where table_schema = '".$database."' AND table_name = '".$k."'";
            $comment = \DB::select($sql);
            $data1[$v] = $comment;
        }

        $data2 = [];
        foreach ($map2 as $k => $v){
            $sql = "select COLUMN_NAME name, DATA_TYPE type, COLUMN_COMMENT comment from INFORMATION_SCHEMA.COLUMNS where table_schema = '".$database."' AND table_name = '".$k."'";
            $comment = \DB::select($sql);
            $data2[$v] = $comment;
        }

        return view('doc', ['data1' => $data1, 'data2' => $data2]);
    }

    public function getHelpList()
    {
        $data = HelpInfo::where('status', 1)->orderBy('id', 'desc')->paginate();
        return out($data);
    }

    public function configList()
    {
        $systemConfig = SystemConfig::whereIn('key', ['phone_notice', 'chat_notice', 'clinic_notice', 'vaccine_notice', 'nurse_notice', 'poster', 'phone', 'protocol', 'recharge_notice', 'service_protocol', 'login_protocol', 'recharge_protocol'])->pluck('value', 'key')->toArray();
        $banners = Banner::where('status', 1)->get();
        $notices = SystemConfig::where('key','notices')->value('value');
        $notices_arr = explode('，',$notices);
        $data = [
            'banners' => $banners,
            'notices' => $notices_arr,
        ];

        $data = array_merge($data, $systemConfig);

        return out($data);
    }

    public function getCity()
    {
        $req = request()->post();
        $this->validate(request(), [
            'name' => 'required'
        ]);

        $area = Area::where('name', 'like', $req['name'].'%')->first();
        if (!empty($area) && $area['level'] == 3) {
            $area = Area::where('id', $area['parent_id'])->first();
        }

        return out($area);
    }

    public function buildToken()
    {
        $req = request()->post();
        $this->validate(request(), [
            'user_id' => 'integer',
            'docter_id' => 'integer',
        ]);

        $token = '';
        if (!empty($req['user_id'])) {
            $token = aes_encrypt(['id' => $req['user_id'], 'time' => time()]);
        }
        elseif (!empty($req['docter_id'])) {
            $token = aes_encrypt(['docter_id' => $req['docter_id'], 'time' => time()]);
        }

        return out(['token' => $token]);
    }

    public function delServerFile()
    {
        $req = request()->post();
        $this->validate(request(), [
            'url' => 'required|url'
        ]);

        $tem = parse_url($req['url']);
        $allPath = public_path().$tem['path'];
        unlink($allPath);

        return out();
    }

    //下单通知
    public function subscribe()
    {
        $msgType = request('type',3); //1公众号 2医生端小程序 3 用户端小程序
        $orderId = request('order_id'); //订单id
        if(empty($orderId)){
            return out('',601,'请输入参数');
        }
        $config = [
            1=>[
                'app_id' => env('OFFICE_APPID', 'wx92066f7587c34617'),
                'secret' => env('OFFICE_APPSECRET', 'bd7849c5259b79c41ec158173c5fb1d6'),
                'response_type' => 'array'
            ],
            2=>[
                'app_id' => env('DOCTRER_WECHAT_APPID', 'wx92066f7587c34617'),
                'secret' => env('DOCTRER_WECHAT_APPSECRET', 'bd7849c5259b79c41ec158173c5fb1d6'),
                'response_type' => 'array'
            ],
            3=>[
                'app_id' => env('WECHAT_APPID', 'wx6131f74e623bf6bf'),
                'secret' => env('WECHAT_APPSECRET', 'b703596ab6cbcad5b74eb51fec2aeb0b'),
                'response_type' => 'array'
            ],
        ] ;


        $order = Order::where(['id'=>$orderId])->first();
        if(empty($order)) return out('',602,'无效订单');
;
        if(empty($order->user_id)) return out('',602,'无效订单');
        $user = \App\User::where('id',$order->user_id)->first();
        //获取unionid
        $uid = $user->unionid;
        if(empty($user)) return apiReturn(602,'此订单用户不存在');

        $name = OrderPatient::where(['order_id'=>$orderId])->value('name');
        $type_arr = [1=>'电话咨询',2=>'图文咨询',3=>'门诊预约',4=>'疫苗',5=>'儿保',6=>'服务包',7=>'充值'];
        $order = Order::where(['id'=>$orderId])->first();
        $orderType = $type_arr[$order->product_type];

        //如果没有unionid 则用 openid
        if(empty($user->unionid)) $uid = $user->openid;

        if($msgType ==1){
            $app = Factory::officialAccount($config[$msgType]);
            $is_office = $app->user->get($uid);
            $data = [
                'touser' =>$uid,
                'template_id' => 'IABFkUm4hoY_J44a767nADSSsGnsexUS4L-lEWJx2AA',
//                'miniprogram' => [
//                    'appid' => env('WECHAT_APPID'),
//                    'pagepath' => '/pages/common_tools/my_consulting/consultingInfo?order_id='.$orderId,
//                ],
                'url'=>'https://wechat.fresherbaby.com/admin',
                'data' => [
                    'first' => '尊敬的客户，你有一笔'.$orderType.'订单已下单成功',
                    'keyword1' => $order->order_sn,
                    'keyword2' => ($order->total_amount/100).'元',
                    'keyword3' => '余额支付',
                    'remark' => '请耐心等待医生接单，如有疑问，请联系客服。',
                ]
            ];

            if($is_office){
                $app = Factory::officialAccount($config[3]);
                $data = [
                    'touser' =>'oYmUA5A1OIqtpA1XSrw35tbjtv1w',
                    'template_id' => 'M9b6PPKtD7PEqLsSnQ453iTIHtIZZpixOBjUjax8YXU',
                    'page' => '/pages/common_tools/my_consulting/consultingInfo?order_id='.$orderId,
                    'data' => [
                        'phrase1' => $orderType,
                        'name3' => $name,
                        'date4' => date('Y-m-d H:i:s'),
                        'thing8' => '你有一笔'.$orderType.'订单已成功下单请耐心等待',
                        'amount10' => ($order->total_amount/100).'元',
                    ]
                ];
            }

            $res = $app->template_message->send($data);
        } else {
            $app = Factory::miniProgram($config[$msgType]);

            $res = $app->subscribe_message->send([
                'touser' =>'oYmUA5A1OIqtpA1XSrw35tbjtv1w',
                'template_id' => 'M9b6PPKtD7PEqLsSnQ453iTIHtIZZpixOBjUjax8YXU',
                'page' => '/pages/common_tools/my_consulting/consultingInfo?order_id='.$orderId,
                'data' => [
                    'phrase1' => $orderType,
                    'name3' => $name,
                    'date4' => date('Y-m-d H:i:s'),
                    'thing8' => '你有一笔'.$orderType.'订单已成功下单,请耐心等待',
                    'amount10' => ($order->total_amount/100).'元',
                ]
            ]);
        }

        if($res['errcode'] == 0) return out('',200,'发送成功') ;
        return out('',$res['errcode'],$res['errmsg']);
    }

    public function icons()
    {

        $type = request('type',1); //位置  1.首页 2.文章中心 3.个人中心
        $pType = request('ptype',1);//平台类型 1.用户端 2.医生端
        $data = Icons::where(['type'=>$type,'status'=>1,'type_cl'=>$pType])->orderBy('laval','desc')
            ->get(['id','name','image','laval'])->toArray();
        foreach ($data as $key=>$icons){
            $data[$key]['image'] = env('APP_URL').'upload/'.$icons['image'];
        }
        return  out($data,200,'OK');

    }

}