tt

datainf/logic/HttpServerSettelement.php

@@ -89,7 +89,7 @@ class HttpServerSettelement
         $paras = array_merge(['request_time' => date("H:i:s")], !empty($request->get) ? $request->get : [], !empty($request->post) ? $request->post : []);
 
         $request_uri = substr($request->server['request_uri'], 1);
-        $urls = ['WinFail', 'Settelement', 'DoWinFailOneOrder'];
+        $urls = ['WinFail', 'Settelement','DoWinFailOneOrder'];
 
         $this->httpserver->account->add();
 
@@ -282,24 +282,23 @@ class HttpServerSettelement
             foreach ($PageOrder_ids_1 as $p_order_ids) {
                 $nowchange_status = ($i == 1) ? $change_status : 0;
                 $data = json_encode(['ids' => $p_order_ids, 'bettype' => $bettype, 'settype' => $settype, 'game_code' => $game_code, 'match_id' => $match_id, 'change_status' => $nowchange_status], 256);
-                //go(function () use ($data, $redisconfig) {
-                //$redis = new Swoole\Coroutine\Redis();
-                $redis = new \Redis();
-                $ret = $redis->connect($redisconfig['host'], $redisconfig['port']);
-                if (!$ret) {
-                    throw  new \Exception('redis 连接失败');
-                }
-                if (!empty($redisconfig['passwd'])) {
-                    $ret = $redis->auth($redisconfig['passwd']);
+                go(function () use ($data, $redisconfig) {
+                    $redis = new Swoole\Coroutine\Redis();
+                    $ret = $redis->connect($redisconfig['host'], $redisconfig['port']);
                     if (!$ret) {
-                        throw  new \Exception('redis auth 失败');
+                        throw  new \Exception('redis 连接失败');
                     }
-                }
-                $redis->select($redisconfig['db']);
+                    if (!empty($redisconfig['passwd'])) {
+                        $ret = $redis->auth($redisconfig['passwd']);
+                        if (!$ret) {
+                            throw  new \Exception('redis auth 失败');
+                        }
+                    }
+                    $redis->select($redisconfig['db']);
 
-                $redis->lpush(self::TASKQNUM, $data);
-                return;
-                //  });
+                    $redis->lpush(self::TASKQNUM, $data);
+                    return;
+                });
                 unset($data);
                 $i++;
             }