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,23 +282,24 @@ 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();
-                    $ret = $redis->connect($redisconfig['host'], $redisconfig['port']);
+                //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']);
                     if (!$ret) {
-                        throw  new \Exception('redis 连接失败');
-                    }
-                    if (!empty($redisconfig['passwd'])) {
-                        $ret = $redis->auth($redisconfig['passwd']);
-                        if (!$ret) {
-                            throw  new \Exception('redis auth 失败');
-                        }
+                        throw  new \Exception('redis auth 失败');
                     }
-                    $redis->select($redisconfig['db']);
+                }
+                $redis->select($redisconfig['db']);
 
-                    $redis->lpush(self::TASKQNUM, $data);
-                    return;
-                });
+                $redis->lpush(self::TASKQNUM, $data);
+                return;
+                //  });
                 unset($data);
                 $i++;
             }