dm.7in6.com/application/admin/model/QcodeLarge.php

<?php
namespace app\admin\model;

use think\Model;
use think\Log;
use \think\Session;

use traits\model\SoftDelete;
class QcodeLarge extends Model
{
    protected $connection = 'mongodb';
    protected $table = '';
    protected $deleteTime = 'delete_time';

    use SoftDelete;

    public function createIndex()
    {
        //获取公司编码
        $userInfo = Session::get('admin');
        $company_id = (int)$userInfo['company'];

        $this->connection->command([
            'createIndexes' => $company_id.'_'."qcode_large",
            'indexes' => [
                [
                    'key' => ['pid' => 1],
                    'name' => 'pid_index'
                ]
            ]
        ]);
    }

    protected static function init()
    {
        self::event('before_insert', function ($model) {
            //获取公司编码
            $userInfo = Session::get('admin');
            $company_id = (int)$userInfo['company'];

            // 设置表名
            $model->table($company_id.'_'."qcode_large");
        });

        //获取公司编码
        $userInfo = Session::get('admin');
        $company_id = (int)$userInfo['company'];

        //把当前表加入到监听队列
        Redis_sAdd('watch_tables', $company_id.'_'."qcode_large");
        self::beforeWrite(function ($model) {
            if (!isset($model->create_time)){
                $model->create_time="";
            }
            if (!isset($model->update_time)){
                $model->update_time="";
            }
            if (!isset($model->delete_time)){
                $model->delete_time="";
            }

            $model->sync_flag=0;
        });

//        $model->sync_flag=1;


    }

}