WokerTask/extend/IFlytek/Xfyun/Speech/LfasrClient.php

232 lines
6.1 KiB
PHP
Raw Permalink Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

<?php
/**
* Copyright 1999-2021 iFLYTEK Corporation
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
namespace IFlytek\Xfyun\Speech;
use Exception;
use IFlytek\Xfyun\Speech\Config\LfasrConfig;
use IFlytek\Xfyun\Speech\Constants\LfasrConstants;
use IFlytek\Xfyun\Speech\Traits\LfasrTrait;
use IFlytek\Xfyun\Speech\Helper\SliceIdGenerator;
use IFlytek\Xfyun\Core\Traits\SignTrait;
use IFlytek\Xfyun\Core\Traits\JsonTrait;
use IFlytek\Xfyun\Core\HttpClient;
use GuzzleHttp\Psr7\Request;
use GuzzleHttp\Psr7\Response;
use GuzzleHttp\Psr7\Query;
use GuzzleHttp\Psr7\Stream;
use GuzzleHttp\Psr7\MultipartStream;
/**
* 语音转写客户端
*
* @author guizheng@iflytek.com
*/
class LfasrClient
{
use SignTrait;
use JsonTrait;
use LfasrTrait;
/**
* @var string app_id
*/
protected $appId;
/**
* @var string secret_key
*/
protected $secretKey;
/**
* @var array 转写参数配置
*/
protected $requestConfig;
/** @var HttpClient */
protected $client;
/** @var array 初始化请求体 */
protected $requestBody;
public function __construct($appId, $secretKey, $requestConfig = [])
{
$this->appId = $appId;
$this->secretKey = $secretKey;
$this->requestConfig = new LfasrConfig($requestConfig);
$this->client = new HttpClient([]);
$timestamp = time();
$this->requestBody = [
'app_id' => $this->appId,
'signa' => $this->signV1($this->appId, $this->secretKey, $timestamp),
'ts' => $timestamp,
];
}
/**
* 打包上传接口封装了准备、分片上传和合并三个接口并返回task_id
*
* @param string $filePath 文件路径
* @return string
* @throws Exception
*/
public function combineUpload($filePath)
{
$prepareResponse = $this->prepare($filePath);
$prepareContent = $this->jsonDecode($prepareResponse->getBody()->getContents(), true);
$taskId = $prepareContent['data'];
$this->upload($taskId, $filePath);
$this->merge($taskId);
return $taskId;
}
/**
* 准备接口
*
* @param $file_path
* @return Response
* @throws Exception
*/
public function prepare($file_path)
{
$this->requestBody += $this->fileInfo($file_path);
$this->requestBody += $this->sliceInfo($file_path);
$this->requestBody += $this->requestConfig->toArray();
return $this->client->sendAndReceive(
new Request(
'POST',
LfasrConstants::URI_PREPARE,
['Content-Type' => 'application/x-www-form-urlencoded;charset=UTF-8'],
Query::build($this->requestBody)
)
);
}
/**
* 分片上传接口
*
* @param string $taskId task_id
* @param string $filePath 文件路径
* @return Response
* @throws Exception
*/
public function upload($taskId, $filePath)
{
$sliceIdGenerator = new SliceIdGenerator();
$sliceInfo = $this->sliceInfo($filePath);
$fileStream = new Stream(fopen($filePath, 'r'));
$this->requestBody += [
'task_id' => $taskId
];
$request = new Request(
'POST',
LfasrConstants::URI_UPLOAD
);
for ($i = 0; $i < $sliceInfo['slice_num']; $i++) {
$multipartStream = new MultipartStream([
[
'name' => 'app_id',
'contents' => $this->requestBody['app_id']
],
[
'name' => 'signa',
'contents' => $this->requestBody['signa']
],
[
'name' => 'ts',
'contents' => $this->requestBody['ts']
],
[
'name' => 'task_id',
'contents' => $taskId,
],
[
'name' => 'slice_id',
'contents' => $sliceIdGenerator->getId()
],
[
'name' => 'content',
'contents' => $fileStream->read(LfasrConstants::SLICE_PIECE_SIZE),
'filename' => '1.pcm'
]
]);
$this->client->sendAndReceive(
$request->withBody($multipartStream)
);
}
return new Response(200);
}
/**
* 合并接口
*
* @param string $taskId task_id
* @return Response
*/
public function merge($taskId)
{
return $this->process(LfasrConstants::URI_MERGE, $taskId);
}
/**
* 查询进度接口
*
* @param string $taskId task_id
* @return Response
*/
public function getProgress($taskId)
{
return $this->process(LfasrConstants::URI_GET_PROGRESS, $taskId);
}
/**
* 获取结果接口
*
* @param string $taskId task_id
* @return Response
*/
public function getResult($taskId)
{
return $this->process(LfasrConstants::URI_GET_RESULT, $taskId);
}
/**
* 封装操作
*
* @param string $task 操作
* @param string $taskId task_id
* @return Response
*/
private function process($task, $taskId)
{
$this->requestBody += ['task_id' => $taskId];
return $this->client->sendAndReceive(
new Request(
'POST',
$task,
['Content-Type' => 'application/x-www-form-urlencoded;charset=UTF-8'],
Query::build($this->requestBody)
)
);
}
}