info('清除企业统计数据表companyStatistics'); DB::table('company_statistics')->delete(); //转移company_statistics数据 $this->info("开始转移数据..."); $total = CompanyStatistics::get()->count(); $bar=$this->output->createProgressBar($total); CompanyStatistics::with('companyProfile')->orderBy('id', 'asc')->chunk(3000, function ($companyStatistics) use ($bar) { $statistics_arr = []; $this->handleStatistics($companyStatistics, $statistics_arr); if ($statistics_arr) { \App\Models\CompanyStatistics::insert($statistics_arr); } $bar->advance(3000); }); $bar->finish(); $this->line(" 完成!"); $this->info("转移company_statistics数据成功."); } public function handleStatistics($companyStatistics, &$statistics_arr) { $statisticsData = []; foreach ($companyStatistics as $key => $val) { if ($val->companyProfile) { $statisticsData['id'] = $val->id; if ($val->comid) { $statisticsData['company_id'] = $val->companyProfile->uid; } else { $statisticsData['company_id'] = $val->comid; }; $statisticsData['uid'] = $val->uid; if ($val->uid) { if ($val->companys) { $statisticsData['utype'] = 1; } else { $statisticsData['utype'] = 2; } } else { $statisticsData['utype'] = 0; } $statisticsData['job_id'] = $val->jobid; $statisticsData['source'] = $val->source; $statisticsData['apply'] = $val->apply; $statisticsData['created_at'] = date('Y-m-d H:i:s', $val->addtime); $statisticsData['updated_at'] = date('Y-m-d H:i:s', $val->addtime); $statistics_arr[] = $statisticsData; } } } }