|
|
@@ -282,8 +282,8 @@ 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();
|
|
|
+ //go(function () use ($data, $redisconfig) {
|
|
|
+ $redis = new \Redis();
|
|
|
$ret = $redis->connect($redisconfig['host'], $redisconfig['port']);
|
|
|
if (!$ret) {
|
|
|
throw new \Exception('redis 连接失败');
|
|
|
@@ -298,7 +298,7 @@ class HttpServerSettelement
|
|
|
|
|
|
$redis->lpush(self::TASKQNUM, $data);
|
|
|
return;
|
|
|
- });
|
|
|
+ // });
|
|
|
unset($data);
|
|
|
$i++;
|
|
|
}
|