ym.7in6.com/application/admin/model/QcodeProduct.php

<?php
namespace app\admin\model;

use think\Model;
use think\Log;
use traits\model\SoftDelete;
class QcodeProduct extends Model
{
    protected $connection = 'mongodb';
    protected $table = 'qcode_product';
    protected $deleteTime = 'delete_time';

    use SoftDelete;

    // 获取DB3连接的方法
    public static function db3()
    {
        return \think\Db::connect(config('database.db3'));
    }

    public function createIndex()
    {
        $this->connection->command([
            'createIndexes' => $this->table,
            'indexes' => [
                [
                    'key' => ['pid' => 1],
                    'name' => 'pid_index'
                ]
            ]
        ]);
    }
    protected static function init()
    {

        //把当前表加入到监听队列
        Redis_sAdd('watch_tables', "qcode_product");
        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;


    }

}