/**

 * limit 分页优化

 * @author ercom

 */
$startTime = time();

$condition = [

    ['status',   '=', 1],

    ['platform', '=', 1],

];

$count = Member::query()

    ->where($condition)

    ->count('id');

$pageSize = 20;

$pageNum = ceil($count / $pageSize);

$startMemberId = 1;

for ($i = 1; $i <= $pageNum; $i++) {

    $condition = [

        ['id',       '>=', $startMemberId],

        ['status',   '=', 1],

        ['platform', '=', 1],

    ];

    $results = Member::query()

        ->where($condition)

        ->orderBy('id', 'asc')

        ->limit($pageSize)

        ->get();

    if ($results->isNotEmpty()) {

        $memberArr = $results->toArray();

        dispatch(new TransferMemberJob($memberArr));

        $startMemberId = max(array_column($memberArr, 'id')) + $pageSize;

    } else {

        $startMemberId = $startMemberId + $pageSize;

    }

    $this->info(sprintf('page=%s, startMemberId=%s', $i, $startMemberId));

}

$endTime = time();

$seconds = $endTime - $startTime;
  $hours = sprintf('%.2f', $seconds/3600);
  $rps = sprintf('%.2f', $count/$seconds);
  $qps = sprintf('%.2f', $pageNum/$seconds);

$this->info(sprintf('All finished, %s / %s, total %s rows, cost %s hours, %s rows/s, %s query/s', date('Y-m-d H:i:s', $startTime), date('Y-m-d H:i:s', $endTime), $count, $hours, $rps, $qps));