slash_api/app/appapi/controller/v1/User.php

<?php

namespace app\appapi\controller\v1;

use app\appapi\ApiController;
use think\facade\Db;

use GuzzleHttp\Client;

use app\common\lib\Aes;
use app\common\lib\Sign;

use app\service\Sso;

class User extends ApiController
{
    /*
    * 取得用戶資料
    */
    public function getUserInfo()
    {
        //檢查是否有serail_no
        $slashToken = urldecode(input('slashToken'));

        $precardData = '';

        if (!empty($slashToken)) {

            $rtn = \app\common\Activation::checkSlashtoken($slashToken);

            if ($rtn['code'] > 0) {
                return $this->error($rtn['msg'], $rtn['code']);
            }
            $precardData = $rtn['data'];
        }

        $user = Db::name('user')
            // ->field('id,user_id,address,avatar,phone,email,url,facebook,ig,youtube,mark,uniqid,overdue_time,level,nc_func,agent_id,real_name,nfc_addon,company')
            ->where('user_id', $this->uid)
            ->find();

        //使用者不存在,至SSO Server取得,並加入會員資料表
        if (!$user) {
            $user_data = [
                'user_id' => $this->uid
            ];

            $sso = Sso::getUserInfo($user_data);
            if (!$sso['code'] == 200) {
                return $this->error('get sso user info error!!!');
            }

            $sso_data = $sso['data'];

            try {
                $sso_data['level'] = 2;
                $sso_data['status'] = 1;
                $sso_data['overdue_time'] = strtotime(date('Y-m-d', time() + (60 * 60 * 24 * 7)));
                $sso_data['cus_card'] = '';
                $sso_data['create_time'] = date('Y-m-d H:i:s');
                unset($sso_data['user_app']);
                Db::name('user')
                    ->insert($sso_data);


                unset($sso_data);
            } catch (\Exception $e) {
                return $this->error($e->getMessage());
            }
        }

        //更新預開卡狀態
        if ($precardData) {
            //更新卡號,會員編號連結
            Db::name('user_sno')
                ->insert([
                    'user_id' => $this->uid,
                    'serial_no' => $precardData['serial_no'],
                ]);

            //更新用戶資料
            if ($precardData['days'] > 0) {
                Db::name('user')
                    ->where('user_id', $this->uid)
                    ->update(
                        [
                            'level' => 1,
                            'overdue_time' => Db::raw('overdue_time + ' . (60 * 60 * 24 * $precardData['days']))
                        ]
                    );
            }

            //更新預開卡狀態
            Db::name('precard')
                ->where('serial_no', $precardData['serial_no'])
                ->update([
                    'status' => 2,
                    'user_id' => $this->uid
                ]);

            //更新sso user_app資料
            //新增User至Oss Server
            $ua_data['appid'] = 'sc';
            $ua_data['app'] = "card";
            $ua_data['user_id'] = $this->uid;
            $ua_data['status'] = 1;
            $ua_data['timestamp'] = time();
            $sign = Sign::genSign($ua_data);
            $ua_data['sign'] = $sign;

            $client = new Client([
                'base_uri' => env('utel.sso_base_url') . '/api/v1/'
            ]);

            $response = $client->post('user/updateUserApp', [
                'form_params' => $ua_data
            ]);

            if ($response->getStatusCode() != 200) {
                return $this->error('更新UserApp失敗');
            }

            $rtn = json_decode($response->getBody()->getContents(), true);
            if($rtn['code']!=200){
                return $this->error($rtn['data']);
            }            
        }

        $user = Db::name('user')
            ->where('user_id', $this->uid)
            ->find();

        $aes = new Aes([]);
        if (strlen(trim($user['uniqid'])) > 0) {
            $params = urlencode($aes->encrypt('verify_code=' . $user['uniqid']));
        } else {
            $params = urlencode($aes->encrypt('user_id=' . $user['user_id']));
        }

        $user['nfcurl'] = getUrl() . '/card/?params=' . $params;

        // $user['level_name'] = Db::name('user_level')->where('agent_id',$user['agent_id'])->where('level_id',$user['level'])->value('name');

        // $user['overdue_time'] = date('Y-m-d H:i:s',$user['overdue_time']);
        if (time() > $user['overdue_time']) {
            //更新用戶level
            Db::name('user')->where('user_id', $this->uid)->update(['level' => 0]);
            $user['level'] = 0;
        }

        switch ($user['level']) {
            case 0:
                $user['level_name'] = '未付費用戶';
                break;
            case 1:
                $user['level_name'] = '付費用戶';
                break;
            case 2:
                $user['level_name'] = '試用用戶';
                break;
            default:
                break;
        }

        $user['nc_func'] = explode(',', $user['nc_func']);

        $user['agent_prefix'] = Db::name('agent')->where('id', $user['agent_id'])->value('prefix');

        return $this->Success($user);
    }

    public function getUserCompany()
    {
        if (!$this->uid) {
            $this->error('用戶ID錯誤');
        }

        $result = Db::name('user_company')
            ->where('user_id', $this->uid)
            ->select();

        return $this->success($result);
    }

    public function addUserCompany()
    {
        if (!$this->uid) {
            $this->error('用戶ID錯誤');
        }

        $ucData = input('post.');
        $ucData['user_id'] = $this->uid;
        unset($ucData['uid']);
        unset($ucData['action']);

        try {
            if (isset($ucData['is_default']) && $ucData['is_default']) {

                Db::name('user_company')
                    ->where('user_id', $this->uid)
                    ->update(['is_default' => 0]);

                Db::name('user')
                    ->where('user_id', $this->uid)
                    ->update([
                        'company' => isset($ucData['uc_name']) ? $ucData['uc_name'] : '',
                        'title' => isset($ucData['uc_title']) ? $ucData['uc_title'] : '',
                        'tel' => isset($ucData['uc_tel']) ? $ucData['uc_tel'] : '',
                        'address' => isset($ucData['uc_address']) ? $ucData['uc_address'] : '',
                        'url' => isset($ucData['uc_url']) ? $ucData['uc_url'] : '',
                    ]);
            }
            Db::name('user_company')
                ->insert($ucData);

            $result = Db::name('user_company')
                ->where('user_id', $this->uid)
                ->select();

            return $this->success($result);
        } catch (\Exception $e) {
            print_r($e);
            return $this->error('操作錯誤');
        }
    }

    public function setUCDefault()
    {
        if (!$this->uid) {
            $this->error('用戶ID錯誤');
        }

        try {
            Db::name('user_company')
                ->where('user_id', $this->uid)
                ->update(['is_default' => 0]);

            Db::name('user_company')
                ->where('id', input('id'))
                ->update(['is_default' => 1]);

            $res = Db::name('user_company')
                ->where('id', input('id'))
                ->find();

            Db::name('user')
                ->where('user_id', $this->uid)
                ->update([
                    'company' => $res['uc_name'],
                    'title' => $res['uc_title'],
                    'tel' => $res['uc_tel'],
                    'address' => $res['uc_address'],
                    'url' => $res['uc_url'],
                ]);

            //更新用戶資料
            $result = Db::name('user_company')
                ->where('user_id', $this->uid)
                ->select();

            return $this->success($result);
        } catch (\Exception $e) {
            print_r($e);
            return $this->error('操作錯誤');
        }
    }

    public function updateUserCompany()
    {
        if (!$this->uid) {
            $this->error('用戶ID錯誤');
        }
        $ucData = input('post.');
        unset($ucData['action']);
        unset($ucData['uid']);
        unset($ucData['id']);
        try {

            if (isset($ucData['is_default']) && $ucData['is_default']) {
                Db::name('user_company')
                    ->where('user_id', $this->uid)
                    ->update(['is_default' => 0]);

                Db::name('user')
                    ->where('user_id', $this->uid)
                    ->update([
                        'company' => $ucData['uc_name'],
                        'title' => $ucData['uc_title'],
                        'tel' => $ucData['uc_tel'],
                        'address' => $ucData['uc_address'],
                        'url' => $ucData['uc_url'],
                    ]);
            }

            Db::name('user_company')
                ->where('id', input('id'))
                ->update($ucData);

            // $res = Db::name('user_company')
            // ->where('id',input('id'))
            // ->find();

            //更新用戶資料
            $result = Db::name('user_company')
                ->where('user_id', $this->uid)
                ->select();

            return $this->success($result);
        } catch (\Exception $e) {
            print_r($e);
            return $this->error('操作錯誤');
        }
    }

    public function deleteUserCompany()
    {
        if (!$this->uid) {
            $this->error('用戶ID錯誤');
        }

        try {
            Db::name('user_company')
                ->where('id', input('id'))
                ->delete();

            //更新用戶資料
            $result = Db::name('user_company')
                ->where('user_id', $this->uid)
                ->select();

            if (count($result) == 0) {
                Db::name('user')
                    ->where('user_id', $this->uid)
                    ->update([
                        'company' => '',
                        'title' => '',
                        'tel' => '',
                        'address' => '',
                        'url' => '',
                    ]);
            }
            return $this->success($result);
        } catch (\Exception $e) {
            return $this->error('操作錯誤');
        }
    }

    public function setUserLevel()
    {
        $result = Db::name('user')
            ->where('user_id', $this->uid)
            ->update(['level' => input('level')]);


        return $this->Success($result);
    }

    public function setUserTpl()
    {
        try {
            $result = Db::name('user')
                ->where('user_id', $this->uid)
                ->update(['nc_template' => input('tpl')]);
        } catch (\Excenption $e) {
            return $this->Error('更新失敗');
        }

        return $this->Success($result);
    }

    public function uploadAvatar()
    {

        $files = request()->file('file');
        $savename =  \think\facade\Filesystem::disk('public')->putFile(input('user_id'), $files);

        $avatar = getUrl() . '/storage/' . $savename;


        // Db::name('user')
        // ->where('user_id',input('user_id'))
        // ->update(['avatar'=>$avatar]);

        return $this->Success($avatar);
    }

    public function updateSendCount()
    {
        $user_id = input('userid');

        Db::name('user')
            ->where('user_id', input('userid'))
            ->exp('send_count', 'send_count+1')
            ->update();
        // ->inc('send_count',1);

        return $this->Success('更新成功');
    }

    public function addFavorite()
    {
        try {
            $is_exist = Db::name('user_favorite')
                ->where('user_id', $this->uid)
                ->where('uf_user_id', input('userid'))
                ->count();

            if (!$is_exist) {
                Db::name('user_favorite')
                    ->insert(['user_id' => $this->uid, 'uf_user_id' => input('userid')]);
            }
            return $this->success('操作成功');
        } catch (\Exception $e) {
            return $this->error('操作失敗');
        }
    }

    public function delFavorite()
    {
        try {
            Db::name('user_favorite')
                ->where('id', input('id'))
                ->delete();

            return $this->success('操作成功');
        } catch (\Exception $e) {
            return $this->error('操作失敗');
        }
    }

    public function uploadConnections()
    {
        try {
            Db::name('user')
                ->where('user_id', $this->uid)
                ->update(['connections' => input('uc')]);

            return $this->success('操作成功');
        } catch (\Exception $e) {
            print_r($e);
            return $this->error('操作失敗');
        }
    }

    public function getFavorite()
    {
        try {
            $uf = Db::name('user_favorite')
                ->alias('uf')
                ->leftjoin('user u', 'uf.uf_user_id = u.user_id')
                ->field('uf.id as ufid,u.*')
                ->where('uf.user_id', $this->uid)
                ->select()
                ->toArray();

            $aes = new Aes([]);

            foreach ($uf as $key => $val) {

                if (strlen($val['uniqid']) > 0) {
                    $params = urlencode($aes->encrypt('verify_code=' . $val['uniqid']));
                } else {
                    $params = urlencode($aes->encrypt('user_id=' . $val['user_id']));
                }

                $uf[$key]['nfcurl'] = getUrl() . '/card/?params=' . $params;
            }

            return $this->success($uf);
        } catch (\Exception $e) {
            return $this->error('操作失敗');
        }
    }

    public function getConnections()
    {
        try {
            $result = Db::name('user')
                ->where('user_id', $this->uid)
                ->value('connections');

            return $this->success($result);
        } catch (\Exception $e) {
            return $this->error('操作失敗');
        }
    }
}