mkm/xunfei-wss
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新

Browse Source
This commit is contained in:
mkm 2023-10-11 13:46:20 +08:00
parent fbea31ba7c
commit 3350338e07
37 changed files with 266 additions and 77 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

152
app/Pusher copy.php Normal file
View File

@ -0,0 +1,152 @@
<?php
namespace app;
use Workerman\Connection\TcpConnection;
use IFlytek\Xfyun\Speech\ChatClient;
use WebSocket\Client;
use Workerman\Connection\AsyncTcpConnection;
use support\Request;
class Pusher
{
private $app_id = '2eda6c2e';
private $api_key = '12ec1f9d113932575fc4b114a2f60ffd';
private $api_secret = 'MDEyMzE5YTc5YmQ5NjMwOTU1MWY4N2Y2';
private $chatClient;
public function onConnect(TcpConnection $connection)
{
echo "onConnect\n";
}
public function onWebSocketConnect(TcpConnection $connection, $http_buffer)
{
echo "onWebSocketConnect\n";
}
public function onMessage(TcpConnection $connection, $data)
{
$data=json_decode($data,true);
if(isset($data[0])&&$data[0]['content']==''){
return $connection->send(['header'=>['code'=>10003,'message'=>'消息不能为空']]);
}
if ($data != '') {
$client = new Client($this->assembleAuthUrl('wss://spark-api.xf-yun.com/v2.1/chat'));
// 连接到 WebSocket 服务器
if ($client) {
$this->chatClient=$client;
// 发送数据到 WebSocket 服务器
$data = $this->getBody($this->app_id, $data);
$client->send($data);
// 从 WebSocket 服务器接收数据
while (true) {
$response = $client->receive();
$resp = json_decode($response, true);
$code = $resp["header"]["code"];
// echo "从服务器接收到的数据： " . $response;
if(0 == $code){
$status = $resp["header"]["status"];
if($status != 2){
// $content = $resp['payload']['choices']['text'][0]['content'];
$connection->send($response);
}else{
// $content = $resp['payload']['choices']['text'][0]['content'];
$connection->send($response);
// $total_tokens = $resp['payload']['usage']['text']['total_tokens'];
print("\n本次消耗token用量：\n");
$client->close();
break;
}
}
if($code==10004){
return $connection->send(['header'=>['code'=>10004,'message'=>'上下文超出限制，请清空后重试']]);
}
}
}
}
}
public function onClose(TcpConnection $connection)
{
if($this->chatClient){
$this->chatClient->close();
}
echo "onClose\n";
}
function getBody($appid, $question)
{
$header = array(
"app_id" => $appid,
"uid" => "1"
);
$parameter = array(
"chat" => array(
"domain" => "generalv2",
"temperature" => 0.5,
"max_tokens" => 8192
)
);
$payload = array(
"message" => array(
"text" => $question
)
);
$json_string = json_encode(array(
"header" => $header,
"parameter" => $parameter,
"payload" => $payload
));
return $json_string;
}
function assembleAuthUrl($addr, $method = 'GET')
{
$apiKey = $this->api_key;
$apiSecret = $this->api_secret;
if ($apiKey == "" && $apiSecret == "") { // 不鉴权
return $addr;
}
$ul = parse_url($addr); // 解析地址
if ($ul === false) { // 地址不对，也不鉴权
return $addr;
}
// // $date = date(DATE_RFC1123); // 获取当前时间并格式化为RFC1123格式的字符串
$timestamp = time();
$rfc1123_format = gmdate("D, d M Y H:i:s \G\M\T", $timestamp);
// $rfc1123_format = "Mon, 31 Jul 2023 08:24:03 GMT";
// 参与签名的字段 host, date, request-line
$signString = array("host: " . $ul["host"], "date: " . $rfc1123_format, $method . " " . $ul["path"] . " HTTP/1.1");
// 对签名字符串进行排序，确保顺序一致
// ksort($signString);
// 将签名字符串拼接成一个字符串
$sgin = implode("\n", $signString);
// 对签名字符串进行HMAC-SHA256加密，得到签名结果
$sha = hash_hmac('sha256', $sgin, $apiSecret, true);
$signature_sha_base64 = base64_encode($sha);
// 将API密钥、算法、头部信息和签名结果拼接成一个授权URL
$authUrl = "api_key=\"$apiKey\",algorithm=\"hmac-sha256\",headers=\"host date request-line\",signature=\"$signature_sha_base64\"";
// 对授权URL进行Base64编码，并添加到原始地址后面作为查询参数
$authAddr = $addr . '?' . http_build_query(array(
'host' => $ul['host'],
'date' => $rfc1123_format,
'authorization' => base64_encode($authUrl),
));
return $authAddr;
}
}

41
app/Pusher.php
View File

@ -7,6 +7,9 @@ use IFlytek\Xfyun\Speech\ChatClient;
use WebSocket\Client;
use Workerman\Connection\AsyncTcpConnection;
use support\Request;
use Webman\Container;
use function DI\env;
class Pusher
{
@ -18,6 +21,12 @@ class Pusher
private $chatClient;
private $ttsConfig =[
'aue'=>'lame',
'sfl'=>1,
'vcn'=>'xiaoyan'
];
public function onConnect(TcpConnection $connection)
{
echo "onConnect\n";
@ -31,6 +40,14 @@ class Pusher
public function onMessage(TcpConnection $connection, $data)
{
$data=json_decode($data,true);
$tts_type=0;
if(isset($data['tts'])){
$tts_type = $data['tts'];
}
if(isset($data['data'])){
$data = $data['data'];
}
if(isset($data[0])&&$data[0]['content']==''){
return $connection->send(['header'=>['code'=>10003,'message'=>'消息不能为空']]);
}
@ -52,10 +69,22 @@ class Pusher
if(0 == $code){
$status = $resp["header"]["status"];
if($status != 2){
// $content = $resp['payload']['choices']['text'][0]['content'];
if($tts_type==1){
$url=$this->tts($resp['payload']['choices']['text'][0]['content']);
$resp['payload']['choices']['mp3']=$url;
$response=json_encode($resp,true);
}
$connection->send($response);
}else{
// $content = $resp['payload']['choices']['text'][0]['content'];
if($tts_type==1){
$url=$this->tts($resp['payload']['choices']['text'][0]['content']);
$resp['payload']['choices']['mp3']=$url;
$response=json_encode($resp,true);
}
$this->tts($resp['payload']['choices']['text'][0]['content']);
$connection->send($response);
// $total_tokens = $resp['payload']['usage']['text']['total_tokens'];
@ -149,4 +178,12 @@ class Pusher
));
return $authAddr;
}
function tts($text){
$name=time().'.mp3';
$tts=new extend\IFlytek\Xfyun\Speech\TtsClient($this->app_id,$this->api_key,$this->api_secret,$this->ttsConfig);
file_put_contents(public_path('tts').'/'.$name,$tts->request($text)->getBody()->getContents());
return 'https://chat.lihaink.cn/tts/'.$name;
}
}

6
app/controller/IndexController.php
View File

@ -3,6 +3,7 @@
namespace app\controller;
use app\extend\ChatGLM\Core;
use app\extend\IFlytek\Xfyun\Speech\TtsClient;
use support\App;
use support\Request;
use Webman\Container;
@ -12,9 +13,8 @@ class IndexController
{
public function index(Request $request)
{
// $chat=(new Container())->get(Core::class);
(new Core())->getUrl();
$chat=(new Container())->get(Core::class);
// (new Core())->getUrl();
static $readme;
if (!$readme) {
$readme = file_get_contents(base_path('README.md'));

2
app/extend/IFlytek/Xfyun/Core/Config/ConfigInterface.php
View File

@ -16,7 +16,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Core\Config;
namespace app\extend\IFlytek\Xfyun\Core\Config;
/**
* 配置类接口

2
app/extend/IFlytek/Xfyun/Core/Handler/Guzzle7HttpHandler.php
View File

@ -16,7 +16,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Core\Handler;
namespace app\extend\IFlytek\Xfyun\Core\Handler;
use GuzzleHttp\ClientInterface;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

2
app/extend/IFlytek/Xfyun/Core/Handler/HttpHandlerFactory.php
View File

@ -16,7 +16,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Core\Handler;
namespace app\extend\IFlytek\Xfyun\Core\Handler;
use GuzzleHttp\Client;
use GuzzleHttp\ClientInterface;

16
app/extend/IFlytek/Xfyun/Core/Handler/WsHandler.php
View File

@ -16,20 +16,20 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Core\Handler;
namespace app\extend\IFlytek\Xfyun\Core\Handler;
use IFlytek\Xfyun\Core\Traits\JsonTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\JsonTrait;
use WebSocket\Client;
use WebSocket\Exception;
use GuzzleHttp\Psr7\Response;
use Psr\Log\{LoggerAwareInterface, LoggerInterface, NullLogger};
use Psr\Log\{LoggerInterface, NullLogger};
/**
* WebSocket处理类
*
* @author guizheng@iflytek.com
*/
class WsHandler implements LoggerAwareInterface
class WsHandler
{
use JsonTrait;
@ -118,9 +118,9 @@ class WsHandler implements LoggerAwareInterface
}
}
public function setLogger(LoggerInterface $logger = null)
{
$this->logger = $logger ?: new NullLogger();
}
// public function setLogger(LoggerInterface $logger = null)
// {
// $this->logger = $logger ?: new NullLogger();
// }
}

10
app/extend/IFlytek/Xfyun/Core/HttpClient.php
View File

@ -16,7 +16,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Core;
namespace app\extend\IFlytek\Xfyun\Core;
/**
* Http客户端
@ -26,10 +26,10 @@ namespace IFlytek\Xfyun\Core;
use Exception;
use GuzzleHttp\Psr7\Response;
use IFlytek\Xfyun\Core\Handler\Guzzle7HttpHandler;
use IFlytek\Xfyun\Core\Traits\SignTrait;
use IFlytek\Xfyun\Core\Traits\DecideRetryTrait;
use IFlytek\Xfyun\Core\Handler\HttpHandlerFactory;
use app\extend\IFlytek\Xfyun\Core\Handler\Guzzle7HttpHandler;
use app\extend\IFlytek\Xfyun\Core\Traits\SignTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\DecideRetryTrait;
use app\extend\IFlytek\Xfyun\Core\Handler\HttpHandlerFactory;
use Psr\Http\Message\RequestInterface;
use GuzzleHttp\Psr7\Utils;

2
app/extend/IFlytek/Xfyun/Core/Traits/ArrayTrait.php
View File

@ -16,7 +16,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Core\Traits;
namespace app\extend\IFlytek\Xfyun\Core\Traits;
/**
* 数组处理

2
app/extend/IFlytek/Xfyun/Core/Traits/DecideRetryTrait.php
View File

@ -16,7 +16,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Core\Traits;
namespace app\extend\IFlytek\Xfyun\Core\Traits;
use GuzzleHttp\Exception\RequestException;

2
app/extend/IFlytek/Xfyun/Core/Traits/JsonTrait.php
View File

@ -16,7 +16,7 @@
* limitations under the License.
*/
namespace Iflytek\Xfyun\Core\Traits;
namespace app\extend\Iflytek\Xfyun\Core\Traits;
/**
* 提供对原生json_encode和json_decode的封装，以便在发生错误时抛出一个异常

2
app/extend/IFlytek/Xfyun/Core/Traits/SignTrait.php
View File

@ -16,7 +16,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Core\Traits;
namespace app\extend\IFlytek\Xfyun\Core\Traits;
/**
* 提供平台的签名方法

2
app/extend/IFlytek/Xfyun/Core/WsClient.php
View File

@ -16,7 +16,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Core;
namespace app\extend\IFlytek\Xfyun\Core;
/**
* WebSocket客户端

8
app/extend/IFlytek/Xfyun/Speech/Config/IgrConfig.php
View File

@ -16,11 +16,11 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Config;
namespace app\extend\IFlytek\Xfyun\Speech\Config;
use IFlytek\Xfyun\Core\Traits\ArrayTrait;
use IFlytek\Xfyun\Core\Traits\JsonTrait;
use IFlytek\Xfyun\Core\Config\ConfigInterface;
use app\extend\IFlytek\Xfyun\Core\Traits\ArrayTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\JsonTrait;
use app\extend\IFlytek\Xfyun\Core\Config\ConfigInterface;
/**
* 性别年龄识别配置参数类

8
app/extend/IFlytek/Xfyun/Speech/Config/IseConfig.php
View File

@ -16,11 +16,11 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Config;
namespace app\extend\IFlytek\Xfyun\Speech\Config;
use IFlytek\Xfyun\Core\Traits\ArrayTrait;
use IFlytek\Xfyun\Core\Traits\JsonTrait;
use IFlytek\Xfyun\Core\Config\ConfigInterface;
use app\extend\IFlytek\Xfyun\Core\Traits\ArrayTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\JsonTrait;
use app\extend\IFlytek\Xfyun\Core\Config\ConfigInterface;
/**
* 语音评测配置参数类

8
app/extend/IFlytek/Xfyun/Speech/Config/LfasrConfig.php
View File

@ -16,11 +16,11 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Config;
namespace app\extend\IFlytek\Xfyun\Speech\Config;
use IFlytek\Xfyun\Core\Traits\ArrayTrait;
use IFlytek\Xfyun\Core\Traits\JsonTrait;
use IFlytek\Xfyun\Core\Config\ConfigInterface;
use app\extend\IFlytek\Xfyun\Core\Traits\ArrayTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\JsonTrait;
use app\extend\IFlytek\Xfyun\Core\Config\ConfigInterface;
/**
* 语音转写配置参数类

6
app/extend/IFlytek/Xfyun/Speech/Config/TcConfig.php
View File

@ -16,10 +16,10 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Config;
namespace app\extend\IFlytek\Xfyun\Speech\Config;
use IFlytek\Xfyun\Core\Traits\ArrayTrait;
use IFlytek\Xfyun\Core\Config\ConfigInterface;
use app\extend\IFlytek\Xfyun\Core\Traits\ArrayTrait;
use app\extend\IFlytek\Xfyun\Core\Config\ConfigInterface;
/**
* 文本纠错配置参数类

8
app/extend/IFlytek/Xfyun/Speech/Config/TtsConfig.php
View File

@ -16,11 +16,11 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Config;
namespace app\extend\IFlytek\Xfyun\Speech\Config;
use IFlytek\Xfyun\Core\Traits\ArrayTrait;
use IFlytek\Xfyun\Core\Traits\JsonTrait;
use IFlytek\Xfyun\Core\Config\ConfigInterface;
use app\extend\IFlytek\Xfyun\Core\Traits\ArrayTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\JsonTrait;
use app\extend\IFlytek\Xfyun\Core\Config\ConfigInterface;
/**
* 语音合成配置参数类

2
app/extend/IFlytek/Xfyun/Speech/Constants/ChatConstants.php
View File

@ -15,7 +15,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Constants;
namespace app\extend\IFlytek\Xfyun\Speech\Constants;
/**
* 星火

2
app/extend/IFlytek/Xfyun/Speech/Constants/IgrConstants.php
View File

@ -15,7 +15,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Constants;
namespace app\extend\IFlytek\Xfyun\Speech\Constants;
/**
* 性别年龄识别常量

2
app/extend/IFlytek/Xfyun/Speech/Constants/IseConstants.php
View File

@ -15,7 +15,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Constants;
namespace app\extend\IFlytek\Xfyun\Speech\Constants;
/**
* 语音评测常量

2
app/extend/IFlytek/Xfyun/Speech/Constants/LfasrConstants.php
View File

@ -15,7 +15,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Constants;
namespace app\extend\IFlytek\Xfyun\Speech\Constants;
/**
* 语音转写常量

2
app/extend/IFlytek/Xfyun/Speech/Constants/TcConstants.php
View File

@ -15,7 +15,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Constants;
namespace app\extend\IFlytek\Xfyun\Speech\Constants;
/**
* 文本纠错常量

2
app/extend/IFlytek/Xfyun/Speech/Constants/TtsConstants.php
View File

@ -15,7 +15,7 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Constants;
namespace app\extend\IFlytek\Xfyun\Speech\Constants;
/**
* 语音合成常量

4
app/extend/IFlytek/Xfyun/Speech/Helper/SliceIdGenerator.php
View File

@ -15,9 +15,9 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Helper;
namespace app\extend\IFlytek\Xfyun\Speech\Helper;
use IFlytek\Xfyun\Speech\Constants\LfasrConstants;
use app\extend\IFlytek\Xfyun\Speech\Constants\LfasrConstants;
/**
* 转写切片ID生成类

6
app/extend/IFlytek/Xfyun/Speech/Traits/IgrTrait.php
View File

@ -15,10 +15,10 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Traits;
namespace app\extend\IFlytek\Xfyun\Speech\Traits;
use IFlytek\Xfyun\Core\Traits\ArrayTrait;
use IFlytek\Xfyun\Core\Traits\JsonTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\ArrayTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\JsonTrait;
/**
* 性别年龄识别方法

6
app/extend/IFlytek/Xfyun/Speech/Traits/IseTrait.php
View File

@ -15,10 +15,10 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Traits;
namespace app\extend\IFlytek\Xfyun\Speech\Traits;
use IFlytek\Xfyun\Core\Traits\ArrayTrait;
use IFlytek\Xfyun\Core\Traits\JsonTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\ArrayTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\JsonTrait;
/**
* 语音评测方法

4
app/extend/IFlytek/Xfyun/Speech/Traits/LfasrTrait.php
View File

@ -15,9 +15,9 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Traits;
namespace app\extend\IFlytek\Xfyun\Speech\Traits;
use IFlytek\Xfyun\Speech\Constants\LfasrConstants;
use app\extend\IFlytek\Xfyun\Speech\Constants\LfasrConstants;
/**
* 转写方法

6
app/extend/IFlytek/Xfyun/Speech/Traits/TcTrait.php
View File

@ -15,10 +15,10 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Traits;
namespace app\extend\IFlytek\Xfyun\Speech\Traits;
use IFlytek\Xfyun\Core\Traits\ArrayTrait;
use IFlytek\Xfyun\Core\Traits\JsonTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\ArrayTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\JsonTrait;
/**
* 文本纠错方法

6
app/extend/IFlytek/Xfyun/Speech/Traits/TtsTrait.php
View File

@ -15,10 +15,10 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech\Traits;
namespace app\extend\IFlytek\Xfyun\Speech\Traits;
use IFlytek\Xfyun\Core\Traits\ArrayTrait;
use IFlytek\Xfyun\Core\Traits\JsonTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\ArrayTrait;
use app\extend\IFlytek\Xfyun\Core\Traits\JsonTrait;
/**
* 语音合成方法

20
app/extend/IFlytek/Xfyun/Speech/TtsClient.php
View File

@ -15,15 +15,15 @@
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech;
namespace app\extend\IFlytek\Xfyun\Speech;
use Exception;
use IFlytek\Xfyun\Speech\Config\TtsConfig;
use IFlytek\Xfyun\Speech\Constants\TtsConstants;
use IFlytek\Xfyun\Speech\Traits\TtsTrait;
use IFlytek\Xfyun\Core\Handler\WsHandler;
use IFlytek\Xfyun\Core\WsClient;
use IFlytek\Xfyun\Core\Traits\SignTrait;
use app\extend\IFlytek\Xfyun\Speech\Config\TtsConfig;
use app\extend\IFlytek\Xfyun\Speech\Constants\TtsConstants;
use app\extend\IFlytek\Xfyun\Speech\Traits\TtsTrait;
use app\extend\IFlytek\Xfyun\Core\Handler\WsHandler;
use app\extend\IFlytek\Xfyun\Core\WsClient;
use app\extend\IFlytek\Xfyun\Core\Traits\SignTrait;
use Psr\Log\LoggerInterface;
/**
@ -89,9 +89,9 @@ class TtsClient
]),
$this->generateInput($text, $this->appId, $this->requestConfig->toArray())
);
if ($this->logger) {
$ttsHandler->setLogger($this->logger);
}
// if ($this->logger) {
// $ttsHandler->setLogger($this->logger);
// }
$client = new WsClient([
'handler' => $ttsHandler
]);

BIN
public/tts/001.wav Normal file
View File

Binary file not shown.

BIN
public/tts/1697002464.mp3 Normal file
View File

Binary file not shown.

BIN
public/tts/1697002684.mp3 Normal file
View File

Binary file not shown.

BIN
public/tts/1697003116.mp3 Normal file
View File

Binary file not shown.

BIN
public/tts/1697003117.mp3 Normal file
View File

Binary file not shown.

BIN
public/tts/1697003118.mp3 Normal file
View File

Binary file not shown.