周海龙 / globalso · 提交

转到一个项目

作者 lyh
提交 7e99282724f90b0ac5bdb41be94580b664b525f1 1 个父辈 8e0b6bc2

GXgeo设置

内嵌 并排对比
正在显示 1 个修改的文件 包含 3 行增加 和 135 行删除
... ... @@ -41,8 +41,7 @@ class GeoQuestionRes extends Command
public function handle()
{
while (true) {
// $task_id = $this->getTaskId();
$task_id = 5;
$task_id = $this->getTaskId();
if (empty($task_id)) {
sleep(300);
continue;
... ... @@ -51,27 +50,23 @@ class GeoQuestionRes extends Command
if (empty($task)) {
continue;
}
$project = Project::select(['geo_status', 'geo_frequency'])->where(['id' => $task->project_id])->first();
if (empty($project->get_status)) {
$task->status = GeoQuestion::STATUS_CLOSE;
$task->save();
continue;
}
if ((empty($task->question) || FALSE == is_array($task->question)) || (empty($task->keywords) && empty($task->url))) {
$this->output('task id: ' . $task_id . ', error: 任务数据缺失, continue!');
$task->status = GeoQuestion::STATUS_CLOSE;
$task->save();
continue;
}
$platforms = GeoPlatform::where(['status' => GeoPlatform::STATUS_ON])->get();
if ($platforms->isEmpty) {
$this->output('未设置AI模型！');
continue;
}
$geo_service = new GeoService();
$geoResultModel = new GeoQuestionResult();
$geoLogModel = new GeoQuestionLog();
... ... @@ -89,8 +84,9 @@ class GeoQuestionRes extends Command
} else {
$result = $geo_service->getAiPlatformResult($question, $platform->en_name);
}
if (empty($result['text']))
if (empty($result['text'])){
goto GET_RESULT;
}
} catch (\Exception $e) {
$this->output('task id：' . $task_id . ', question: ' . $question . ', platform: ' . $question . ', error: ' . $e->getMessage());
if ($error_num < 5) {
... ... @@ -98,7 +94,6 @@ class GeoQuestionRes extends Command
}
continue;
}
// 命中文案
$hit_data[] = $result['text'];
if(FALSE == empty($result['annotations'])){
... ... @@ -107,7 +102,6 @@ class GeoQuestionRes extends Command
$hit_data = array_merge($url, $title, $hit_data);
}
$hit_string = implode(',', $hit_data);
// 命中关键词和路由
$hit_keyword = $hit_url = [];
$hit = 0;
... ... @@ -125,7 +119,6 @@ class GeoQuestionRes extends Command
$hit++;
}
}
// 保存数据结果
$geo_result = GeoQuestionResult::where(['project_id' => $task['project_id'], 'question_id' => $task['id'], 'platform' => $platform, 'question' => $question])->first();
$save_data = [
... ... @@ -167,7 +160,6 @@ class GeoQuestionRes extends Command
'model' => 'Google AI Overview',
'text' => '',
];
if (FALSE == empty($data['ai_overview']['texts']) && is_array($data['ai_overview']['texts'])) {
$texts = [];
foreach ($data['ai_overview']['texts'] as $item) {
... ... @@ -185,7 +177,6 @@ class GeoQuestionRes extends Command
}
}
}
// 第一层就有内容
if (FALSE == empty($item['snippet'])) {
// title 放到数组最前面
... ... @@ -194,7 +185,6 @@ class GeoQuestionRes extends Command
else
array_push($texts, $item['snippet']);
}
// list类型
if (FALSE == empty($item['type']) && $item['type'] == 'list' && FALSE == empty($item['list']) && is_array($item['list'])) {
foreach ($item['list'] as $list) {
... ... @@ -209,128 +199,6 @@ class GeoQuestionRes extends Command
return $result;
}
public function handle1(){
while (true){
$task_id = $this->getTaskId();
if(empty($task_id)){
sleep(30);
continue;
}
echo date('Y-m-d H:i:s').'->task_id:'.$task_id.PHP_EOL;
$questionModel = new GeoQuestion();//问题
$info = $questionModel->read(['id'=>$task_id]);
//获取当前项目的执行频率
$projectModel = new Project();
$projectInfo = $projectModel->read(['id'=>$info['project_id']],['geo_status','geo_frequency']);
if($projectInfo['geo_status'] == 0){
$questionModel->edit(['status'=>0],['id'=>$task_id]);
continue;
}
$questionArr = $info['question'];
if(empty($questionArr)){
echo date('Y-m-d H:i:s').'当前任务不存在问题。'.PHP_EOL;
$questionModel->edit(['status'=>0],['id'=>$task_id]);
}
//获取平台信息
$platformModel = new GeoPlatform();//平台
$platformArr = $platformModel->selectField(['status'=>$platformModel::STATUS_ON],'en_name');
if(empty($platformArr)){
echo date('Y-m-d H:i:s').'请求平台为空。'.PHP_EOL;
continue;
}
$geoService = new GeoService();
$keywordArr = $info['keywords'] ?? [];
$urlArr = $info['url'] ?? [];
$geoResultModel = new GeoQuestionResult();
foreach ($questionArr as $q_item){
foreach ($platformArr as $p_item){
$keywords = [];//命中的关键词
$urls = [];//命中的网址
try {
$result_data = $geoService->setWebSearchChatAction($q_item,$p_item);
echo 'success:'.$result_data['code'].PHP_EOL;
if(isset($result_data) && $result_data['code'] == 200){
$result_data_annotations[] = $result_data['text'];
if(!empty($result_data['annotations'])){
$url = array_column(array_column($result_data['annotations'], 'url_citation'), 'url');
$title = array_column(array_column($result_data['annotations'], 'url_citation'), 'title');;
$result_data_annotations = array_merge($url,$title,$result_data_annotations);
}
$keywords = $this->getKeywords($keywordArr,$result_data_annotations ?? []);
$urls = $this->getUrl($urlArr,$result_data_annotations ?? []);
}
}catch (\Exception $e){
echo $e->getMessage().PHP_EOL;
continue;
}
//查询当前是否已有执行保存记录
$resultInfo = $geoResultModel->read(['project_id'=>$info['project_id'],'question_id'=>$info['id'],'platform'=>$p_item,'question'=>$q_item],['id']);
//保存一条结果记录
$data = [
'project_id'=>$info['project_id'],
'question_id'=>$info['id'],
'platform'=>$p_item,
'question'=>$q_item,
'keywords'=>json_encode($keywords ?? [],true),//命中的关键词
'text'=>json_encode($result_data ?? [],true),
'url'=>json_encode($urls ?? [],true),//命中的网址
'type'=>$info['type'] ?? GeoQuestion::TYPE_BRAND
];
if($resultInfo === false){
$geoResultModel->addReturnId($data);
}else{
$geoResultModel->edit($data,['id'=>$resultInfo['id']]);
}
//日志记录
$geoLogModel = new GeoQuestionLog();
$geoLogModel->addReturnId($data);
}
}
//更新下次执行时间
$questionModel->edit(['current_time'=>date('Y-m-d'),'next_time'=>date('Y-m-d', strtotime(date('Y-m-d') . ' +'.(int)$projectInfo['geo_frequency'].' days'))],['id'=>$info['id']]);
}
}
/**
* @remark :获取命中的url
* @name :getUrl
* @author :lyh
* @method :post
* @time :2025/7/3 16:38
*/
public function getUrl($urlArr = [],$result_annotations = []){
$url = [];
if(!empty($urlArr)){
$str = implode(',',$result_annotations);
foreach ($urlArr as $u_item){
if (str_contains($str, $u_item)) {
$url[] = $u_item;
}
}
}
return array_values(array_unique($url));
}
/**
* @remark :获取命中的关键词
* @name :getKeywords
* @author :lyh
* @method :post
* @time :2025/7/3 16:26
*/
public function getKeywords($keywordArr = [],$result_text = []){
$keywords = [];
if(!empty($keywordArr) && !empty($result_text)){
$str = implode(',',$result_text);
foreach ($keywordArr as $k_item){
if (str_contains($str, $k_item)) {
$keywords[] = $k_item;
}
}
}
return $keywords;
}
/**
* 获取待执行任务ID
* @return mixed
... ...