更新星火认知模型分析信息

app/job/AiAianalyse.php

@@ -0,0 +1,91 @@
+<?php
+
+namespace app\job;
+
+use app\common\model\informationg\UserInformationg;
+use think\facade\Db;
+use think\queue\Job;
+use WebSocket\Client;
+use GuzzleHttp\Client as GzClient;
+use GuzzleHttp\Psr7\Request;
+use GuzzleHttp\Exception\GuzzleException;
+use Guzzle\Http\Exception\RequestException;
+
+
+/**
+ * 任务执行AI分析
+ */
+class AiAianalyse
+{
+    private $app_id='2eda6c2e';
+    private $api_key='12ec1f9d113932575fc4b114a2f60ffd';
+    private $api_secret='MDEyMzE5YTc5YmQ5NjMwOTU1MWY4N2Y2';
+
+    public function fire(Job $job, $data)
+    {
+        if ($job->attempts() > 3) {
+            //通过这个方法可以检查这个任务已经重试了几次了
+        }
+        $type_name = Db::name('category_business')->where('id', $data['category_child'])->value('name');
+        $data_field = json_decode($data['data_field'], true);
+        $demand = '';
+        foreach($data_field as $k=>$v) {
+            $demand .= $k . '：' . $v . '；';
+        }
+        $question = "分析以下{$type_name}信息【{$demand}】请问有那些商机？";
+        try {
+            $chat=new ChatClient($this->app_id,$this->api_key,$this->api_secret);
+            $client = new Client($chat->assembleAuthUrl('wss://spark-api.xf-yun.com/v2.1/chat'));
+            // 连接到 WebSocket 服务器
+            if ($client) {
+                $header = [
+                    "app_id" => $this->app_id,
+                    "uid"    => "1"
+                ];
+                $parameter = [
+                    "chat" => [
+                        "domain"        => "generalv2",
+                        "temperature"   => 0.5,
+                        "max_tokens"    => 1024
+                    ]
+                ];
+                $payload = [
+                    "message"  => [
+                        "text" => [
+                            ["role" => "user", "content" => $question]
+                        ]
+                    ]
+                ];
+                $data = json_encode([
+                    "header"    => $header,
+                    "parameter" => $parameter,
+                    "payload"   => $payload
+                ]);
+
+                $client->send($data);
+                $answer = '';
+                while(true){
+                    $response = $client->receive();
+                    $resp = json_decode($response, true);
+                    $code = $resp["header"]["code"] ?? 0;
+                    if($code == 0){
+                        $status  = $resp["header"]["status"];
+                        $content = $resp['payload']['choices']['text'][0]['content'] ?? '';
+                        $answer .= $content;
+                        if($status == 2){
+                            break;
+                        }
+                    }else{
+                        break;
+                    }
+                }
+                $update_data = [
+                    'ai_aianalyse' => $answer,
+                    'update_time' => time(),
+                ];
+                Db::name('user_informationg_demand')->where($data)->update($update_data);
+            }
+        } catch (\Exception $e) {}
+        $job->delete();
+    }
+}