<?php
/**
 * +-----------------------------------------------------------------------------------------------------------------------
 * trait ：聊天 trait
 * +-----------------------------------------------------------------------------------------------------------------------
 *
 * PHP version 7
 *
 * @category  App\Models\Traits
 * @package   App\Models\Traits
 * @author    Richer <yangzi1028@163.com>
 * @date      2023年4月24日14:02:44
 * @copyright 2020-2021 Richer (http://www.Richer.com/)
 * @license   http://www.Richer.com/ License
 * @link      http://www.Richer.com/
 */
namespace App\Models\Traits;

use App\Factories\WechatFactory;
use App\Models\Category\CategoryLabelItemRemote;
use App\Models\Category\CategoryLabelRemote;
use App\Models\Category\CategoryRemote;
use App\Models\Chat\ChatRecordItemRemote;
use App\Models\Chat\ChatRecordRemote;
use App\Models\User\TimesRecordRemote;
use App\Models\User\UserRemote;
use Illuminate\Support\Facades\Storage;
use SimpleSoftwareIO\QrCode\Facades\QrCode;

/**
 * Trait SyncTrait
 * @package App\Models\Traits
 */
trait SyncTrait
{
    /**
     * 同步聊天记录到本地服务器
     * @param $model
     */
    public function syncRecord($model)
    {
        if(!ChatRecordRemote::find($model->id)) {
            ChatRecordRemote::create([
                'id' => $model->id,
                'user_id' => $model->user_id,
                'category_id' => $model->category_id,
                'label_id' => $model->label_id,
                'type' => $model->type,
                'consume_times' => $model->consume_times,
                'context' => $model->context,
                'labels' => my_json_encode($model->labels),
                'start_statement' => $model->start_statement,
                'question' => $model->question,
                'ai_model' => $model->ai_model,
                'status' => $model->status,
                'synchronized' => 1,
                'created_at' => $model->created_at,
                'updated_at' => $model->updated_at,
            ]);
            $model->synchronized = 1;
            $model->save();
        }
    }

    /**
     * 同步聊天记录到本地服务器
     * @param $model
     */
    public function syncRecordItem($model)
    {
        if(!ChatRecordItemRemote::find($model->id)) {
            ChatRecordItemRemote::create([
                'id' => $model->id,
                'user_id' => $model->user_id,
                'record_id' => $model->record_id,
                'category_id' => $model->category_id,
                'chat_type' => $model->chat_type,
                'user_type' => $model->user_type,
                'body_all' => $model->body_all,
                'body' => $model->body,
                'ai_model' => $model->ai_model,
                'synchronized' => 1,
                'status' => $model->status,
                'created_at' => $model->created_at,
                'updated_at' => $model->updated_at,
            ]);

            $model->synchronized = 1;
            $model->save();
        }
    }

    /**
     * 同步聊天记录到本地服务器
     * @param $model
     */
    public function syncUserTimesRecord($model)
    {
        if(!TimesRecordRemote::find($model->id)) {
            TimesRecordRemote::create([
//                'id' => $model->id,
                'user_id' => $model->user_id,
                'recordable_id' => $model->recordable_id,
                'recordable_type' => $model->recordable_type,
                'times' => $model->times,
                'type' => $model->type,
                'event' => $model->event,
                'synchronized' => 1,
                'created_at' => $model->created_at,
                'updated_at' => $model->updated_at,
            ]);

            $model->synchronized = 1;
            $model->save();
        }
    }

    /**
     * 同步用户到远程服务器
     * @param $model
     * @param string $operate
     * @param array $update
     */
    public function syncUser($model, $operate = 'store', $update = [])
    {
        switch ($operate) {
            case 'update':
                if (!UserRemote::find($model->id)) {
                    UserRemote::create([
                        'id' => $model->id,
                        'pid'      => $model->pid,
                        'gid'      => $model->gid,
                        'name'      => $model->name,
                        'password'  => $model->password,
                        'mobile'    => $model->mobile,
                        'times'     => $model->times,
                        'nickname'  => $model->nickname,
                        'avatar'    => $model->avatar,
                        'openid'    => $model->openid,
                        'status'    => $model->status,
                        'registered_at'     => $model->registered_at,
                        'registered_ip'     => $model->registered_ip,
                        'token'     => $model->token,
                        'login_times'     => $model->login_times,
                        'created_at'     => $model->created_at,
                    ]);
                } else {
                    UserRemote::where('id', $model->id)->update($update);
                }
                break;
            case 'delete':
                UserRemote::where('id', $model->id)->delete();
                break;
            default:
                if(!UserRemote::find($model->id)) {
                    UserRemote::create([
                        'id' => $model->id,
                        'pid'      => $model->pid,
                        'gid'      => $model->gid,
                        'name'      => $model->name,
                        'username'      => $model->username,
                        'password'  => $model->password,
                        'mobile'    => $model->mobile,
                        'times'     => 10,
                        'nickname'     => $model->nickname,
                        'avatar'     => $model->avatar,
                        'openid'     => $model->openid,
                        'status'     => $model->status,
                        'registered_at'     => $model->registered_at,
                        'registered_ip'     => $model->registered_ip,
                        'token'     => $model->token,
                        'login_times'     => $model->login_times,
                        'created_at'     => $model->created_at,
                    ]);
//                    $model->synchronized = 1;
//                    $model->save();
                }
                break;
        }
    }

    /**
     * 同步 分类到远程服务器
     *
     * @param $model
     * @param string $operate
     * @param array $update
     */
    public function syncCategory($model, $operate = 'store', $update = [])
    {
        switch ($operate) {
            case 'update':
                if(!CategoryRemote::find($model->id)) {
                    CategoryRemote::create([
                        'id' => $model->id,
                        'name' => $model->name,
                        'consume_times' => $model->consume_times,
                        'start_statement' => $model->start_statement,
                        'context' => $model->context,
                        'icon' => $model->icon,
                        'body' => $model->body,
                        'description' => $model->description,
                        'status' => $model->status,
                        'sort' => $model->sort,
                        'created_at' => $model->created_at,
                        'updated_at' => $model->updated_at,
                    ]);
                    $model->synchronized = 1;
                    $model->save();
                } else {
                    CategoryRemote::where('id', $model->id)->update($update);
                }
                break;
            case 'delete':
                CategoryRemote::where('id', $model->id)->delete();
                break;
            default:
                if(!CategoryRemote::find($model->id)) {
                    CategoryRemote::create([
                        'id' => $model->id,
                        'name' => $model->name,
                        'consume_times' => $model->consume_times,
                        'start_statement' => $model->start_statement,
                        'context' => $model->context,
                        'icon' => $model->icon,
                        'body' => $model->body,
                        'description' => $model->description,
                        'status' => $model->status,
                        'sort' => $model->sort,
                        'created_at' => $model->created_at,
                        'updated_at' => $model->updated_at,
                    ]);
                    $model->synchronized = 1;
                    $model->save();
                }
                break;
        }
    }

    /**
     * 同步 分类到远程服务器
     *
     * @param $model
     * @param string $operate
     * @param array $update
     */
    public function syncCategoryLabel($model, $operate = 'store', $update = [])
    {
        switch ($operate) {
            case 'update':
                if(!CategoryLabelRemote::find($model->id)) {
                    CategoryLabelRemote::create([
                        'id' => $model->id,
                        'category_id' => $model->category_id,
                        'icon' => $model->icon,
                        'name' => $model->name,
                        'semantics' => $model->semantics,
                        'body' => $model->body,
                        'description' => $model->description,
                        'can_multiple' => $model->can_multiple,
                        'status' => $model->status,
                        'sort' => $model->sort ?? 1,
                        'created_at' => $model->created_at,
                        'updated_at' => $model->updated_at,
                    ]);
                    $model->synchronized = 1;
                    $model->save();
                } else {
                    CategoryLabelRemote::where('id', $model->id)->update($update);
                }
                break;
            case 'delete':
                CategoryLabelRemote::where('id', $model->id)->delete();
                break;
            default:
                if(!CategoryLabelRemote::find($model->id)) {
                    CategoryLabelRemote::create([
                        'id' => $model->id,
                        'category_id' => $model->category_id,
                        'icon' => $model->icon,
                        'name' => $model->name,
                        'semantics' => $model->semantics,
                        'body' => $model->body,
                        'description' => $model->description,
                        'can_multiple' => $model->can_multiple,
                        'status' => $model->status,
                        'sort' => $model->sort ?? 1,
                        'created_at' => $model->created_at,
                        'updated_at' => $model->updated_at,
                    ]);
                    $model->synchronized = 1;
                    $model->save();
                }
                break;
        }
    }

    /**
     * 同步 分类到远程服务器
     *
     * @param $model
     * @param string $operate
     * @param array $update
     */
    public function syncCategoryLabelItem($model, $operate = 'store', $update = [])
    {
        switch ($operate) {
            case 'update':
                if(!CategoryLabelItemRemote::find($model->id)) {
                    CategoryLabelItemRemote::create([
                        'id' => $model->id,
                        'label_id' => $model->label_id,
                        'icon' => $model->icon,
                        'name' => $model->name,
                        'description' => $model->description,
                        'status' => $model->status,
                        'sort' => $model->sort ?? 1,
                        'created_at' => $model->created_at,
                        'updated_at' => $model->updated_at,
                    ]);
                    $model->synchronized = 1;
                    $model->save();
                } else {
                    CategoryLabelItemRemote::where('id', $model->id)->update($update);
                }
                break;
            case 'delete':
                CategoryLabelItemRemote::where('id', $model->id)->delete();
                break;
            default:
                if(!CategoryLabelItemRemote::find($model->id)) {
                    CategoryLabelItemRemote::create([
                        'id' => $model->id,
                        'label_id' => $model->label_id,
                        'icon' => $model->icon,
                        'name' => $model->name,
                        'description' => $model->description,
                        'status' => $model->status,
                        'sort' => $model->sort ?? 1,
                        'created_at' => $model->created_at,
                        'updated_at' => $model->updated_at,
                    ]);
                    $model->synchronized = 1;
                    $model->save();
                }
                break;
        }
    }

    /**
     * 本地生成文件
     *
     * @param $model
     * @return string
     */
    public function generateUserQrCode($user)
    {
        // 设置上传路径和文件名
        $dir = config('filesystems.disks.qr_code.root');
        $id = $user->id;
//            $logo = splice_file_path(optional($model->enterprise)->logo);
//            if (!$logo) {
//                $logo =   config('app.url') .'/assets/admin/img/logo.png';
//            }
        // add by Richer 于2022年6月10日14:02:26使用系统的logo
        dump($dir);
        // 生成二维码
        if (!is_dir($dir)) {
            mkdir(iconv("UTF-8", "GBK", $dir), 0777, true);
        }
        $filename = $id .'.png';
        $filepath   = $dir . '/' . $filename;

        dump($filepath);
        $url = config('app.url') .  '?inviter_id='.$user->id;

//            if (!file_exists($filepath)) {
        // 生成二维码
        QrCode::format('png')
            ->backgroundColor(255, 255, 255) // 设置背景色
            ->size(200) // 设置尺寸
            ->margin(1) // 边距设置
//                    ->eyeColor(0, 0, 0, 0, 255, 215, 0)
//                    ->eyeColor(1, 0, 0, 0, 255, 215, 0)
//                    ->eyeColor(2, 0, 0, 0, 255, 215, 0)
//                    ->eyeColor(1, 0, 0, 0, 205, 127, 50)
//                    ->eyeColor(1, 0, 0, 0, 166, 124, 64)
            ->errorCorrection('H') // 容错级别设置:
            ->generate($url, $filepath);
//            }
        // 返回二维码图片路径
        $img_src = config('filesystems.disks.qr_code.url') . '/'. $filename;
        dump($img_src);

        // 创建一张空的画布，像素3628x1757，背景白色
//            $img = Image::canvas(300, 300, '#fff');
//            // 获取本地图片，可以获取input上传文件
//            $leftImage = Image::make('https://www.baidu.com/img/flexible/logo/pc/result.png')->resize(30, 30);
//            $rightImage = Image::make($img_src)->resize(220, 220);
//            // 插入到画布，left-top是距离左侧和顶部，值对应的是后面 100 100 处
//            $img->insert($leftImage, 'left-top', 0, 0);
//            $img->insert($rightImage, 'center');
//            //可以直接返回图像，也可通过$img->save()进行保存图片
        $user->invite_qr_code = ltrim($img_src);
        $user->save();

        return $img_src;
    }

    /**
     * 创建用户的邀请二维码
     *
     * @param $user
     */
    public function generateUserQrCode1($user)
    {
        $url = config('app.url') .  '?inviter_id='.$user->id;

        QrCode::generate($url, '../public/q/qrcode.svg');

        $user_id = $user->id;



        $filename = $user_id . '.png'; // 文件名
        Storage::disk('qr_code')->put($filename, $url); // 存储到本地

        return  $url = Storage::disk('qr_code')->url($filename); // 获取 URL;
    }

    /**
     * 创建 用户的钱包
     *
     * @param $user
     */
    public function generateUserWallet($user)
    {
        $wallet = $user->wallet;
        if (!$wallet) {
            $user->wallet()->create([
//                'income' => 0,
//                'balance' => 0,
//                'withdrawn' => 0,
//                'frozen' => 0,
            ]);
        }
    }

    /**
     * 创建用户的邀请记录
     *
     * @param $user
     */
    public function recordInviteRecord($user)
    {
        if ($user->pid > 0) {
            $user->invitedRecords()->create([
                'user_id' => $user->pid
            ]);
        }
    }
}