get(); $bar = $this->output->createProgressBar(count($oldData)); $bar->start(); $data = []; $newData = []; foreach ($oldData as $key => $value){ // 查询店铺是否存在balance $exist = DB::table($newTableName) ->where('source_id',$value->user_id) ->where('user_type',5) ->first(); if(empty($exist)){ $newData[] = [ 'source_id' => $value->user_id, 'user_type' => 5, 'balance' => 0, 'created_at' => time(), 'updated_at' => time() ]; }else{ $data[] = [ 'store_id' => $value->id, 'user_id' => $value->user_id, 'balance_id' => $exist->id ]; } $bar->advance(); } // 添加到新表 $res = DB::table($newTableName)->insert($newData); $bar->finish(); var_dump('new_total: '.count($newData)); var_dump('exist: '.count($data)); var_dump($data); var_dump('res: '.$res); return 0; } }