// 递归处理代理返点 function dailifandian($parentid, $fandian, $amount, $trano, $xiajiid, $xiajiuser, $xiajifandian, $i) { //查找上级的返点 $where['id'] = $parentid; $query = Test::getDb()->query("select id,par...

$worker = new Worker(); $worker->count = 100; $worker->onWorkerStart = function ($worker) { $client = Test::getServer(); // 订阅 $id = $worker->id; $client->subscribe("task-{$id}", function(...