tt

composer.json

@@ -12,7 +12,6 @@
         "laravel/tinker": "~1.0",
         "mews/captcha": "^2.2",
         "orangehill/iseed": "^2.6",
-        "predis/predis": "^1.1",
         "simplesoftwareio/simple-qrcode": "^2.0",
         "spatie/laravel-permission": "^2.12",
         "stevenyangecho/laravel-u-editor": "^1.4",

websockServ/app/logic/CmdProxy.php

@@ -26,8 +26,10 @@ class CmdProxy
     public static function getInstance($cache = true)
     {
         if ($cache && self::$Instance) {
+            echo "直接返回 CmdProxy OBJ\n";
             return self::$Instance;
         }
+        echo "新建 CmdProxy OBJ\n";
         self::$Instance = new self();
         return self::$Instance;
     }

websockServ/app/logic/cmdpro/CmdTest.php

@@ -11,14 +11,16 @@ namespace app\logic\cmdpro;
 use app\lib\DataPack;
 use app\lib\GlobConfigs;
 use app\logic\cmdpro\CmdInf as CmdInf;
-
+use Illuminate\Database\Capsule\Manager as Capsule;
+use Illuminate\Database\Capsule\Manager as DB;
 
 use app\logic\MyPgsql as MyPgsql;
 
-use swoole ;
+use swoole;
 
 class CmdTest extends CmdInf
 {
+    static $pgsqlObj = '';
 
     //异步回调实现 mysql
     public function sqlold($serv, $task)
@@ -110,42 +112,46 @@ class CmdTest extends CmdInf
 
 
     //时间同步用
-    public function timeRsync($serv,$task){
-        $dataArr = json_decode($task->data->data,true);
-        $msg = DataPack::toJson(['mtype'=>'system_msg','stype'=>'TimeSync','data'=>$dataArr['data']]);
-        $this->onlineBroad($serv,$msg);
-        return ;
+    public function timeRsync($serv, $task)
+    {
+        $dataArr = json_decode($task->data->data, true);
+        $msg = DataPack::toJson(['mtype' => 'system_msg', 'stype' => 'TimeSync', 'data' => $dataArr['data']]);
+        $this->onlineBroad($serv, $msg);
+        return;
     }
 
 
-    public function pgsql($serv,$task){
-        $dataArr = json_decode($task->data->data,true);
+    public function pgsql($serv, $task)
+    {
+        $dataArr = json_decode($task->data->data, true);
         $config = GlobConfigs::getKey('pgsql');
-        go(function () use ($serv, $task, $config,$dataArr) {
-            $conf = $config ;
+        go(function () use ($serv, $task, $config, $dataArr) {
+            $conf = $config;
             $mysql = new Capsule();
             $mysql->addConnection($conf);
             $mysql->setAsGlobal();
             $mysql->bootEloquent();
 
-            $ret = DB::table('account')->where('id',83859)->first();
-            $this->sendTo($serv, $task->data->fd, DataPack::toJson(['mtype'=>'system','data'=>$ret]));
+            $ret = DB::table('account')->where('id', 83859)->first();
+            $this->sendTo($serv, $task->data->fd, DataPack::toJson(['mtype' => 'system', 'data' => $ret]));
 
         });
 
     }
 
 
-    public function pgsqlquery($serv,$task){
-        $dataArr = json_decode($task->data->data,true);
-        $ret = MyPgsql::getInstance()->getDb()->table('members')->where('id',intval($dataArr['data']))->first();
-        $this->sendTo($serv, $task->data->fd, DataPack::toJson(['mtype'=>'system','data'=>$ret]));
+    public function pgsqlquery($serv, $task)
+    {
+        $dataArr = json_decode($task->data->data, true);
+        $ret = MyPgsql::getInstance()->getDb()->table('members')->where('id', intval($dataArr['data']))->first();
+        $this->sendTo($serv, $task->data->fd, DataPack::toJson(['mtype' => 'system', 'data' => $ret]));
     }
 
-    public function pgsqlexec($serv,$task){
-        $dataArr = json_decode($task->data->data,true);
-        $ret = MyPgsql::getInstance()->getDb()->table('members')->where('id',57)->update(['name'=>'12-'.$dataArr['data']]);
-        $this->sendTo($serv, $task->data->fd, DataPack::toJson(['mtype'=>'system','data'=>$ret]));
+    public function pgsqlexec($serv, $task)
+    {
+        $dataArr = json_decode($task->data->data, true);
+        $ret = MyPgsql::getInstance()->getDb()->table('members')->where('id', 57)->update(['name' => '12-' . $dataArr['data']]);
+        $this->sendTo($serv, $task->data->fd, DataPack::toJson(['mtype' => 'system', 'data' => $ret]));
     }
 
 
@@ -155,7 +161,51 @@ class CmdTest extends CmdInf
     }
 
 
+    public function odds($serv, $task)
+    {
+
+        echo "进来了。。。。。。。。。。。。。。。。。。\n";
+
+        $now = microtime(true);
+        $datas = json_decode($task->data->data, true)['data'];
+        print_r($datas);
+        echo "Cost: " . (microtime(true) - $now) * 1000 . " 毫秒\r\n";
+        $pgsql = $this->getPgsqlObj();
+
+        $ret1 = DB::table("st_zq_local_league")->where(['others_lg_id'=>138112,'source'=>'hg0088'])->first();
+        $ret2 = DB::table("st_zq_local_match")->where(['others_match_id'=>3246051,'source'=>'hg3535'])->first();
+        if (!$ret1 || !$ret2){
+            echo "数据有错,返回..\n";
+            return ;
+        }
+        $ret3 = DB::table("st_zq_league")->where(['id'=>$ret1->lg_id])->first();
+        $ret4 = DB::table("st_zq_odds")->where(['odds_only'=>'41b995867e606e7bdea634d26d82a69b'])->first();
+        $ret5 = DB::table("st_zq_odds")->where(['odds_only'=>'41b995867e606e7bdea634d26d82a69b'])->update(['ctime'=>date("Y-m-d H:i:s")]);
+
+
+        print_r([$ret1,$ret2,$ret3,$ret4,$ret5]);
+
+
+        echo "Cost: " . (microtime(true) - $now) * 1000 . " 毫秒\r\n";
+
+
+    }
 
+    private function getPgsqlObj()
+    {
+        if (self::$pgsqlObj == '') {
+            echo '重建getPgsqlObj......'."\n";
+            $config = GlobConfigs::getKey('pgsql');
+            $mysql = new Capsule();
+            $mysql->addConnection($config);
+            $mysql->setAsGlobal();
+            $mysql->bootEloquent();
+            self::$pgsqlObj = $mysql;
+            return $mysql;
+        }
+        echo '直接返回 getPgsqlObj......'."\n";
+        return self::$pgsqlObj;
+    }
 
 
 }

websockServ/configs/configs.php

@@ -12,7 +12,7 @@ $tmp_config = [
             'driver' => 'pgsql',
             'host' => '192.168.2.200',
             'port' => 10432,
-            'database' => 'pai',
+            'database' => 'kaiyou',
             'username' => 'kaiyou',
             'password' => '123456',
             'charset' => 'utf8',
@@ -35,12 +35,12 @@ $tmp_config = [
             'maxUsers' => 50000,
             'sets' => [
                 'worker_num' => 2,
-                'daemonize' => true,
+                'daemonize' => false,
                 'max_request' => 50,
                 'task_enable_coroutine' => true,
                 'dispatch_mode' => 2,
                 'debug_mode' => 1,
-                'task_worker_num' => 5,
+                'task_worker_num' => 2,
                 'log_file' => '../logs/swoole_'.date("Ymd").'.log',
             ],
         ],