|
...
|
...
|
@@ -390,6 +390,7 @@ class RankDataLogic extends BaseLogic |
|
|
|
public function syncRankData($api_no, $site_res, $force=false){
|
|
|
|
$project_ids = DeployOptimize::where('api_no', $api_no)->pluck('project_id');
|
|
|
|
foreach ($project_ids as $project_id) {
|
|
|
|
Log::channel('rank_data')->info('开始查项目：' . $project_id);
|
|
|
|
$project = Project::find($project_id);
|
|
|
|
if (!$project) {
|
|
|
|
throw new \Exception($api_no . '关联的项目不存在');
|
|
...
|
...
|
@@ -397,12 +398,14 @@ class RankDataLogic extends BaseLogic |
|
|
|
$api = new QuanqiusouApi();
|
|
|
|
$model = RankData::where('project_id', $project_id)->where('lang', '')->first();
|
|
|
|
if (!$model || $model->updated_date != date('Y-m-d') || $force) {
|
|
|
|
Log::channel('rank_data')->info('开始接口数据：' . $project_id);
|
|
|
|
$res = $api->getGoogleRank($project_id, $api_no, '', 7, $force);
|
|
|
|
if (!$res) {
|
|
|
|
throw new \Exception("接口数据获取失败,api_no:{$api_no}");
|
|
|
|
}
|
|
|
|
//收录数
|
|
|
|
$indexed_pages_num = $site_res[$api_no] ?? 0;
|
|
|
|
Log::channel('rank_data')->info('开始保存：' . $project_id);
|
|
|
|
$this->save_rank($project_id, $res, $indexed_pages_num);
|
|
|
|
}
|
|
|
|
//有小语种的
|
...
|
...
|
|
