reset_flow表

application/admin/model/ResetFlow.php

@@ -0,0 +1,70 @@
+<?php
+namespace app\admin\model;
+
+use think\Model;
+use think\Log;
+use \think\Session;
+
+use traits\model\SoftDelete;
+class ResetFlow 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.'_'."reset_flow",
+            '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.'_'."reset_flow");
+        });
+
+        //获取公司编码
+        $userInfo = Session::get('admin');
+        $company_id = (int)$userInfo['company'];
+
+        //把当前表加入到监听队列
+        Redis_sAdd('watch_tables', $company_id.'_'."reset_flow");
+        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;
+
+
+    }
+
+}