From bd88acc8f443ef41b80e72fb38e37ebff05663b6 Mon Sep 17 00:00:00 2001 From: denghy Date: Fri, 26 Apr 2019 02:53:35 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Virtual/Commands/Sync/FlowPoolMonthSync.php | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/app/Domains/Virtual/Commands/Sync/FlowPoolMonthSync.php b/app/Domains/Virtual/Commands/Sync/FlowPoolMonthSync.php index 8f714186..a19001b3 100644 --- a/app/Domains/Virtual/Commands/Sync/FlowPoolMonthSync.php +++ b/app/Domains/Virtual/Commands/Sync/FlowPoolMonthSync.php @@ -26,8 +26,14 @@ class FlowPoolMonthSync extends Command $array = []; - DB::connection('vd_old')->table('ckb_data_pool_statis_item')->select(['td_pool_sn', 'sim', 'vd_package_sn', 'flows_used'])->orderBy('dpci_id') - ->chunk(10000, function ($chunk) use (&$array, $flowPoolsKeyByName, $realFlowPools, $flowPools, $packages) { + $query = DB::connection('vd_old')->table('ckb_data_pool_statis_item')->select(['td_pool_sn', 'sim', 'vd_package_sn', 'flows_used'])->orderBy('dpci_id'); + + $total = $query->count(); + + $this->line('查询数据，条数 #:' . $total); + + $query->chunk(10000, function ($chunk) use (&$array, $flowPoolsKeyByName, $realFlowPools, $flowPools, $packages) { + echo '.'; foreach ($chunk as $value) { $value = (array)$value; $pool_id = 0;