合并分支 'akun' 到 'master'

Akun



查看合并请求 !3209

@@ -63,7 +63,7 @@ class KeywordPageAiContent extends Command
         while (true) {
         while (true) {
             $task = ProjectKeywordAiTask::getPendingTask();
             $task = ProjectKeywordAiTask::getPendingTask();
             if (!$task) {
             if (!$task) {
-                sleep(10);
+                sleep(60);
                 continue;
                 continue;
             }
             }
             $project_id = $task->project_id;
             $project_id = $task->project_id;
@@ -78,7 +78,17 @@ class KeywordPageAiContent extends Command
 
 
                 ProjectKeywordAiTask::finish($task->id, $update_rows);
                 ProjectKeywordAiTask::finish($task->id, $update_rows);
 
 
-                $update_rows && $this->sendNotify($project_id);
+//                $update_rows && $this->sendNotify($project_id);
+
+                if($update_rows){
+                    //缓存 在发送页面更新的项目数据 id
+                    $notify_cache_key = "keyword_page_ai_content_notify_{$project_id}";
+                    if(Redis::setnx($notify_cache_key, 1)){
+                        Redis::expire($notify_cache_key, 120);
+
+                        $this->sendNotify($project_id); //通知主站按需更新
+                    }
+                }
 
 
             } catch (ValidateException $e) {
             } catch (ValidateException $e) {
                 echo getmypid() . ' ' . date('Y-m-d H:i:s') . 'line: ' . $e->getLine() . ' error: ' . $project_id . '->' . $e->getMessage() . PHP_EOL;
                 echo getmypid() . ' ' . date('Y-m-d H:i:s') . 'line: ' . $e->getLine() . ' error: ' . $project_id . '->' . $e->getMessage() . PHP_EOL;

@@ -52,6 +52,11 @@ class Temp extends Command
 
 
     }
     }
 
 
+    public function geoProjectMatchOptimist()
+    {
+
+    }
+
     /**
     /**
      * 4301项目特殊产品数据导入
      * 4301项目特殊产品数据导入
      * @return bool
      * @return bool