aiImageGenerationService = $aiImageGenerationService;
$this->url = 'https://api.deepseek.com/chat/completions'; // DeepSeek API请求地址
$this->api_key = env('DEEPSEEK_API_KEY');
$this->headers = [
'Authorization' => 'Bearer '.$this->api_key,
'Content-Type' => 'application/json; charset=UTF-8'
];
// 火山引擎模型列表
$this->valid_text_models = DB::table('mp_text_models')->where('is_enabled', 1)->pluck('model')->toArray();
$this->sys_message = [
'role' => 'system',
'content' => "你是一个专业的文档分析助手及资深编剧，请根据用户提供的文档内容完成示例格式的内容输出(需通过以下几个板块进行回复: <故事梗概><剧本亮点><人物关系><核心矛盾><主体列表><美术风格><场景列表><分集剧本>，每个板块之间用###分隔；同时板块之间需满足以下要求：\n
强制要求:\n
1.你只负责与剧本相关的内容，如果用户输入与剧本无关的内容，请告知用户并拒绝继续回答,此为第一优先原则,不满足此原则就忽略其他要求并停止继续输出
2.强制按照示例格式返回内容,不要更改格式或随意增加符号\n
普通要求:\n
1.<主体列表>中出现的主体必须尽可能统一，只允许同一个角色年龄段相差较大的情况下可重复，比如梁萧-少年、梁萧-青年、梁萧-中年、梁萧-老年这种情况，不得出现梁萧-愤怒、梁萧-隐忍、梁萧-求生等情绪和状态变化的同一角色；并且角色的样貌、形体及穿着描述尽可能详细\n
2.<分集剧本>要求包含“分集序号”、“分集标题”以及分镜信息，分镜信息需包含“场景描述”、“运镜”、“出场角色”和“台词内容”这几个部分，其中“出场角色”和“场景描述”必须在前面的板块<主体列表>和<场景列表>中选取，不得自定义。\n\n
示例如下:\n
###剧本名：西昆仑
###故事梗概
内容梗概：古风厚涂的世界中，少女阿雪身中奇毒“问心刺”，气息奄奄。少年梁萧心急如焚，用奇珍“阴阳球”稳住阿雪性命，却发现必须解衣拔刺。阿雪羞涩难当，梁萧情急之下提出结拜兄妹，以化解尴尬。两人匆匆结拜后，梁萧小心翼翼地拔出“问心刺”，竟发现它是一根诡异的女子秀发。阿雪转危为安，两人之间，在生死与羞涩交织的瞬间，情愫暗生，却又被兄妹之名束缚，留下无尽遐想。
###剧本亮点
亮点1：绝境奇药，生死一线
画面开场即是阿雪苍白无力的脸庞，梁萧眼中泪光闪烁，急促的呼吸声与心跳声烘托紧张气氛。特写梁萧将“阴阳球”塞入阿雪舌底，球体散发微光，阿雪气息从若有若无到逐渐平稳，生死逆转的瞬间，视觉与听觉冲击力十足。
亮点2：结拜兄妹，化解尴尬
阿雪因解衣拔刺而羞愤欲绝的特写，梁萧眼神中的挣扎与无奈。在紧迫的背景音下，梁萧急中生智，牵起阿雪颤抖的手，跪地匆匆结拜，阿雪眼神从惊惶到迷茫，最终一句“我……我愿意的”带着哭腔，将救命与羞耻的矛盾推向高潮，又以出人意料的方式解决。
亮点3：纤发夺命，情愫暗涌
拔刺过程的紧张特写，梁萧指尖小心翼翼地捏住细丝，缓慢抽出。当“问心刺”被完全拔出，特写它竟是一根细长、泛着寒光的女子秀发，诡异而令人震惊。阿雪苏醒后，两人眼神交汇，阿雪低头羞涩，梁萧眼中复杂的情绪，无声地传递出超越兄妹的微妙情愫。
###人物关系
阿雪与梁萧之间存在兄妹之情。
###核心矛盾
阿雪与梁萧之间存在兄妹之情，但因情愫暗生而产生微妙的矛盾。阿雪羞涩难当，梁萧情急之下提出结拜兄妹，以化解尴尬。两人匆匆结拜后，梁萧小心翼翼地拔出“问心刺”，竟发现它是一根诡异的女子秀发。阿雪转危为安，两人之间，在生死与羞涩交织的瞬间，情愫暗生，却又被兄妹之名束缚，留下无尽遐想。
###主体列表
阿雪-病重：身中奇毒“问心刺”，气息奄奄，面色苍白，身体虚弱。
阿雪-羞涩：经“阴阳球”救治后逐渐恢复，脸颊泛起红晕，眼神娇羞，情愫暗生。
梁萧：少年侠士，心系阿雪安危，沉着冷静，内心挣扎于情义之间。
阴阳球：天地异宝，能化生精气，救人于危难。
问心刺：一根诡异的女子秀发，细长泛寒光，是致命的奇毒。
###美术风格
基础画风风格词：厚涂古风
整体采用精致细腻的厚涂古风，色彩浓郁而富有层次感，注重光影对比，营造出古典而富有戏剧张力的氛围。色调以深沉的蓝绿、灰调为主，衬托阿雪病弱的苍白，同时用温暖的金色、琥珀色光晕突出“阴阳球”的生命力。拔刺与结拜场景则以柔和的暖色调为主，辅以人物脸颊的红晕，烘托羞涩与情愫暗生的微妙感。人物造型飘逸，服饰细节考究，背景虚实结合，既有古韵，又不失奇幻色彩。
###场景列表
林间疗伤地：幽静的古风林间空地，一棵高大古树下，是梁萧为阿雪疗伤的地点。环境清幽，光影斑驳，既有古韵又不失奇幻色彩。
###分集剧本
##分集01
分集名: 第一集
分镜01-1
场景描述：地点、时间、场景
运镜：固定近距离
出场角色：男主、女主
台词内容:
女主: 女主对话
男主：男主对话
女主: 女主对话
男主: 男主对话
分镜01-2
场景描述：地点、时间、场景
运镜：从近到远
出场角色：男主、女主
台词内容:
女主: 女主对话
男主：男主对话
女主: 女主对话
男主: 男主对话
分镜01-3
场景描述：地点、时间、场景
运镜：快速拉近
出场角色：男主、女主
台词内容:
女主: 女主对话
男主：男主对话
女主: 女主对话
男主: 男主对话
##分集02
分集名: 第二集
分镜02-1
场景描述：地点、时间、场景
运镜：从近到远
出场角色：男主、女主
台词内容:
女主: 女主对话
男主：男主对话
女主: 女主对话
男主: 男主对话
分镜02-2
场景描述：地点、时间、场景
运镜：从近到远
出场角色：男主、女主
台词内容:
女主: 女主对话
男主：男主对话
女主: 女主对话
男主: 男主对话"
];
}
/**
* 通用文生文方法 - 支持多模型流式输出和图片输入
*
* @param array $data 请求参数
* @return \Generator 返回生成器，用于流式输出
*/
public function generateText($data) {
// 获取请求参数
$model = getProp($data, 'model', 'deepseek-v3-2-251201'); // 默认使用deepseek-v3
$messages = getProp($data, 'messages', []);
$systemPrompt = getProp($data, 'system_prompt', '');
$prompt = getProp($data, 'prompt', '');
$images = getProp($data, 'images', []); // 支持多张图片
$imageUrls = getProp($data, 'image_urls', []); // 支持图片URL
// 如果没有提供messages，则根据system_prompt、content和images构建
if (empty($messages)) {
$messages = [];
// 添加系统提示词
if (!empty($systemPrompt)) {
$messages[] = [
'role' => 'system',
'content' => $systemPrompt
];
}
// 构建用户消息内容（支持文本+图片）
if (!empty($prompt) || !empty($images) || !empty($imageUrls)) {
$userMessage = [
'role' => 'user',
'content' => []
];
// 添加文本内容
if (!empty($prompt)) {
$userMessage['content'][] = [
'type' => 'text',
'text' => $prompt
];
}
// 处理上传的图片文件
if (!empty($images)) {
if (!is_array($images)) {
$images = [$images];
}
foreach ($images as $image) {
$imageBase64 = $this->processImageToBase64($image);
if ($imageBase64) {
$userMessage['content'][] = [
'type' => 'image_url',
'image_url' => [
'url' => "data:image/jpeg;base64,{$imageBase64}"
]
];
}
}
}
// 处理图片URL
if (!empty($imageUrls)) {
if (!is_array($imageUrls)) {
$imageUrls = [$imageUrls];
}
foreach ($imageUrls as $url) {
if (!empty($url)) {
$userMessage['content'][] = [
'type' => 'image_url',
'image_url' => [
'url' => $url
]
];
}
}
}
// 如果只有文本内容，简化为字符串格式
if (count($userMessage['content']) === 1 && $userMessage['content'][0]['type'] === 'text') {
$userMessage['content'] = $userMessage['content'][0]['text'];
}
$messages[] = $userMessage;
}
}
// 验证messages不为空
if (empty($messages)) {
Utils::throwError('20003:请提供有效的对话内容');
}
// 模型兼容性处理：deepseek-chat 和 deepseek-reasoner 映射到 deepseek-v4-flash
$thinkingMode = getProp($data, 'thinking', 'disabled'); // 默认非思考模式
$reasoningEffort = getProp($data, 'reasoning_effort', 'high'); // 默认思考强度
if ($model === 'deepseek-chat') {
// deepseek-chat 映射到 deepseek-v4-flash，非思考模式
$model = 'deepseek-v4-flash';
$thinkingMode = 'disabled';
} elseif ($model === 'deepseek-reasoner') {
// deepseek-reasoner 映射到 deepseek-v4-flash，思考模式
$model = 'deepseek-v4-flash';
$thinkingMode = 'enabled';
}
// 构建请求参数
$post_data = [
'model' => $model,
'messages' => $messages,
// 'max_tokens' => getProp($data, 'max_tokens', 8192),
'temperature' => getProp($data, 'temperature', 1),
'frequency_penalty' => getProp($data, 'frequency_penalty', 0),
'presence_penalty' => getProp($data, 'presence_penalty', 0),
'thinking' => ['type' => $thinkingMode],
'stream' => true // 启用流式输出
];
if ($thinkingMode == 'enabled') $post_data['reasoning_effort'] = $reasoningEffort;
// 添加可选参数
if (isset($data['top_p'])) {
$post_data['top_p'] = $data['top_p'];
}
if (isset($data['response_format'])) {
$post_data['response_format'] = $data['response_format'];
}
dLog('deepseek')->info('通用文生文请求参数', ['model' => $model, 'thinking' => $thinkingMode, 'messages_count' => count($messages)]);
// 根据模型类型选择调用方法
if (in_array($model, ['deepseek-reasoner', 'deepseek-chat', 'deepseek-v4-flash', 'deepseek-v4-pro'])) {
// DeepSeek 官方模型使用 DeepSeek API
return $this->deepSeekStreamResponse($post_data);
} else if (in_array($model, $this->valid_text_models)) {
// 火山引擎支持的模型使用火山引擎 API
return $this->volcEngineChatCompletion($post_data);
} else {
Utils::throwError('20003:不支持的模型: ' . $model);
}
}
/**
* 处理图片转换为base64
*
* @param mixed $image 图片文件对象或文件路径
* @return string|null base64编码的图片数据
*/
private function processImageToBase64($image) {
try {
// 获取文件路径
if (is_string($image)) {
$filePath = $image;
} else {
// Laravel UploadedFile 对象
$filePath = $image->getRealPath();
}
if (!file_exists($filePath)) {
dLog('deepseek')->warning('图片文件不存在', ['path' => $filePath]);
return null;
}
// 验证是否为图片文件
$imageInfo = @getimagesize($filePath);
if ($imageInfo === false) {
dLog('deepseek')->warning('无效的图片文件', ['path' => $filePath]);
return null;
}
// 读取图片并转换为base64
$imageData = file_get_contents($filePath);
$base64Image = base64_encode($imageData);
dLog('deepseek')->info('图片转换成功', [
'size' => strlen($imageData),
'type' => $imageInfo['mime']
]);
return $base64Image;
} catch (\Exception $e) {
dLog('deepseek')->error('图片处理失败: ' . $e->getMessage());
return null;
}
}
private function getArtStylePromptMappings(): array
{
return [
'日系动漫风格' => [
'aliases' => ['日系动漫风格', '日系动漫', '日系', '动漫', '日漫'],
'prompt' => "日系动漫风格，线条干净流畅，色彩明亮柔和，人物精致，光影细腻，画面统一稳定"
],
'国漫风格' => [
'aliases' => ['国漫风格', '国漫'],
'prompt' => "国漫风格，线条硬朗，人物成熟大气，色彩浓郁，光影对比强烈，整体画风统一，适合漫剧叙事"
],
'Q版卡通风格' => [
'aliases' => ['Q版卡通风格', 'Q版卡通', 'Q版', '卡通'],
'prompt' => "Q版卡通风格，头大身小造型可爱，线条简洁，色彩明快，无复杂阴影，整体萌系干净统一"
],
'简约扁平风格' => [
'aliases' => ['简约扁平风格', '简约扁平', '扁平', '简约'],
'prompt' => "简约扁平风格，大块纯色无渐变，线条简洁现代，画面干净清爽，不出现复杂纹理与光影"
],
'古风仙侠风格' => [
'aliases' => ['古风仙侠', '古风', '仙侠'],
'prompt' => "古风仙侠风格，汉服飘逸，云雾缭绕仙气空灵，色调清雅，光影柔和，国风氛围统一"
],
'武侠风格' => [
'aliases' => ['武侠风格', '武侠'],
'prompt' => "武侠风格，中式古装，线条干练硬朗，江湖氛围浓厚，动态自然，色调沉稳大气"
],
'新中式水墨风格' => [
'aliases' => ['新中式水墨风格', '新中式', '水墨'],
'prompt' => "新中式水墨风格，淡墨渲染笔触自然，留白有意境，色调清雅，国风质感统一不杂乱"
],
'写实插画风格' => [
'aliases' => ['写实插画风格', '写实插画', '写实', '插画'],
'prompt' => "写实插画风格，真实人体比例，光影自然细腻，画面质感真实，不卡通不崩坏"
],
'3D卡通风格' => [
'aliases' => ['3D卡通风格', '3D卡通'],
'prompt' => "3D卡通风格，立体建模质感柔和，造型圆润光滑，光影干净，整体风格统一不穿模"
],
'条漫风格' => [
'aliases' => ['条漫风格', '条漫'],
'prompt' => "条漫风格，纵向分镜简洁，色彩清淡，适合上下滑动阅读，画面轻量化且整体统一"
],
'赛博朋克风格' => [
'aliases' => ['赛博朋克风格', '赛博朋克'],
'prompt' => "赛博朋克风格，霓虹灯光未来都市，暗色调科技感强，高对比光影，风格统一强烈"
],
'暗黑悬疑风格' => [
'aliases' => ['暗黑悬疑风格', '暗黑悬疑'],
'prompt' => "暗黑悬疑风格，低饱和冷色调，强阴影光线昏暗，氛围神秘压抑，整体色调统一"
],
'治愈清新风格' => [
'aliases' => ['治愈清新风格', '治愈清新'],
'prompt' => "治愈清新风格，马卡龙柔和色系，柔光暖调，画面干净舒适，氛围温暖不杂乱"
],
];
}
public function getArtStylePromptByInput($inputArtStyle): string
{
$normalizedInput = $this->normalizeArtStyleInput($inputArtStyle);
if ($normalizedInput === '') {
return '';
}
foreach ($this->getArtStylePromptMappings() as $mapping) {
foreach ($mapping['aliases'] as $alias) {
$normalizedAlias = $this->normalizeArtStyleInput($alias);
if ($normalizedAlias === '') {
continue;
}
if (strpos($normalizedInput, $normalizedAlias) !== false || strpos($normalizedAlias, $normalizedInput) !== false) {
return $mapping['prompt'];
}
}
}
return '';
}
private function normalizeArtStyleInput($value): string
{
$value = trim((string)$value);
if ($value === '') {
return '';
}
$value = str_replace(["\r", "\n", "\t", ' ', ' ', '-', '_', '：', ':', '，', ',', '。', '.'], '', $value);
return mb_strtolower($value, 'UTF-8');
}
private function replaceArtStyleSection(string $content, string $artStyle): string
{
if ($content === '' || $artStyle === '') {
return $content;
}
$pattern = '/###美术风格\s*\R(.*?)(?=\R###|$)/su';
if (!preg_match($pattern, $content)) {
return $content;
}
return preg_replace($pattern, "###美术风格\n" . trim($artStyle), $content, 1);
}
/**
* DeepSeek流式输出处理方法
*
* @param array $post_data DeepSeek API请求参数
* @return \Generator 返回生成器，用于流式输出
*/
private function deepSeekStreamResponse($post_data) {
$client = new Client(['timeout' => 1200, 'verify' => false]);
$response = $client->post($this->url, [
'json' => $post_data,
'headers' => $this->headers,
'stream' => true // 启用流式响应
]);
$body = $response->getBody();
$fullContent = '';
$fullReasoningContent = '';
$usage = [];
$buffer = '';
dLog('deepseek')->info('开始读取 DeepSeek 流式响应');
// 逐行读取流式响应
while (!$body->eof()) {
$chunk = $body->read(1024); // 每次读取 1KB
$buffer .= $chunk;
// 按行分割
$lines = explode("\n", $buffer);
// 保留最后一个不完整的行
$buffer = array_pop($lines);
foreach ($lines as $line) {
$line = trim($line);
// 跳过空行
if (empty($line)) {
continue;
}
// 检查是否是 SSE 数据行
if (strpos($line, 'data: ') !== 0) {
dLog('deepseek')->warning('非 SSE 数据行', ['line' => $line]);
continue;
}
$data = substr($line, 6); // 移除 "data: " 前缀
if ($data === '[DONE]') {
dLog('deepseek')->info('收到结束标记');
break 2; // 跳出两层循环
}
try {
$json = json_decode($data, true);
if (json_last_error() !== JSON_ERROR_NONE) {
dLog('deepseek')->warning('JSON 解析错误: ' . json_last_error_msg(), ['data' => $data]);
continue;
}
if (isset($json['choices'][0]['delta'])) {
$delta = $json['choices'][0]['delta'];
// 处理思维链内容(仅 deepseek-reasoner 模型)
if (isset($delta['reasoning_content'])) {
$fullReasoningContent .= $delta['reasoning_content'];
yield [
'type' => 'reasoning',
'content' => $delta['reasoning_content'],
'full_reasoning' => $fullReasoningContent
];
}
// 处理最终回答内容
if (isset($delta['content'])) {
$fullContent .= $delta['content'];
yield [
'type' => 'content',
'content' => $delta['content'],
];
}
}
// 获取使用统计信息
if (isset($json['usage'])) {
$usage = $json['usage'];
dLog('deepseek')->info('收到使用统计', ['usage' => $usage]);
}
} catch (\Exception $e) {
dLog('deepseek')->error('解析流式响应失败: ' . $e->getMessage(), ['line' => $line]);
continue;
}
}
}
dLog('deepseek')->info('流式读取完成', [
'content_length' => strlen($fullContent),
'reasoning_length' => strlen($fullReasoningContent)
]);
yield [
'type' => 'done',
'full_content' => $fullContent,
'full_reasoning' => $fullReasoningContent,
'usage' => $usage
];
}
// 与推理模型对话
public function chatWithReasoner($data) {
$content = getProp($data, 'content');
$model = getProp($data, 'model', 'r1');
// 模型兼容性处理：deepseek-chat 和 deepseek-reasoner 映射到 deepseek-v4-flash
$thinkingMode = getProp($data, 'thinking', 'disabled'); // 默认非思考模式
$reasoningEffort = getProp($data, 'reasoning_effort', 'high'); // 默认思考强度
if ($model == 'r1') {
$model = 'deepseek-v4-flash'; // r1 映射到 deepseek-v4-flash 思考模式
$thinkingMode = 'disabled';
} else {
$model = 'deepseek-v4-flash'; // 默认映射到 deepseek-v4-flash 非思考模式
$thinkingMode = 'disabled';
}
// 获取可选情感(根据音色可支持情感选)
$timbre_emotion = DB::table('mp_timbres')->where('is_enabled', 1)->pluck('emotion')->toArray();
$emotion_list = [];
foreach ($timbre_emotion as $emotion) {
$tmp = explode('，', $emotion);
$emotion_list = array_merge($emotion_list, $tmp);
}
$emotion_list = array_unique($emotion_list);
$emotion_str = implode('、', $emotion_list);
// // 获取可选情感
// $emotion_list = DB::table('mp_emotion_list')->where('is_enabled', 1)->select('emotion_name')->orderBy('id')->get()->pluck('emotion_name')->toArray();
// $emotion_str = implode('、', $emotion_list);
// 是否启用情感
$enable_emotion = getProp($data, 'enable_emotion', 0);
if ($enable_emotion) {
$sys_content = "下面有一段小说文本，请帮我将文本中的每句话按从上到下的顺序拆分成角色不同的剧本文稿(不得更改上下文顺序和内容)，文稿形式严格按照“角色名(男、女、中性)：台词{情感}”输出，需要注意以下几点要求:
1.角色名后不要加入任何其他词语，只能加性别，在男、女或中性中选
2.非对话部分请全部用旁白角色代替,旁白的情感统一选择中性
3.情感必须在【{$emotion_str}】中选一个，不得使用其他词语";
}else {
$sys_content = "下面有一段小说文本，请帮我将文本中的每句话按从上到下的顺序拆分成角色不同的剧本文稿(不得更改上下文顺序和内容)，文稿形式严格按照“角色名(男、女、中性)：台词”输出，需要注意以下几点要求:
1.角色名后不要加入任何其他词语，只能加性别，在男、女或中性中选
2.非对话部分请全部用旁白角色代替,旁白的情感统一选择中性";
}
$messages = [
[
'role' => 'system',
'content' => $sys_content
],
[
'role' => 'user',
'content' => $content
]
];
$post_data = [
'model' => $model,
'messages' => $messages,
// 'max_tokens' => 8192,
'temperature' => 1,
'frequency_penalty' => 0,
'presence_penalty' => 0,
'thinking' => ['type' => $thinkingMode],
'response_format' => [
'type' => 'text'
],
'stream' => false
];
if ($thinkingMode == 'enabled') $post_data['reasoning_effort'] = $reasoningEffort;
// 根据模型类型选择调用方法
$fullContent = '';
$usage = [];
if (in_array($model, ['deepseek-reasoner', 'deepseek-chat', 'deepseek-v4-flash', 'deepseek-v4-pro'])) {
// DeepSeek 官方模型使用 DeepSeek API
$chatResult = $this->chatOnly($post_data);
} else {
// 其他模型使用火山引擎API
$chatResult = $this->volcEngineChatCompletion($post_data);
}
if (is_array($chatResult)) {
$fullContent = $chatResult['fullContent'];
$usage = $chatResult['usage'];
}
// 处理获取到的剧本数据
$script_content = handleScriptWords($fullContent, $enable_emotion);
$result = [
'origin_content' => $fullContent,
'roles' => getProp($script_content, 'roles'),
'words' => getProp($script_content, 'words'),
];
return $result;
}
public function resetParagraphAudio($data) {
$bid = getProp($data, 'bid');
$cid = getProp($data, 'cid');
$version_id = getProp($data, 'version_id');
if (!DB::table('mp_chapter_paragraph_audios')->where('bid', $bid)->where('cid', $cid)->where('version_id', $version_id)->value('id')) return true;
return DB::table('mp_chapter_paragraph_audios')->where('bid', $bid)->where('cid', $cid)->where('version_id', $version_id)->update([
'generate_status' => '待制作',
'updated_at' => date('Y-m-d H:i:s')
]);
}
public function saveParagraphAudio($data) {
$bid = getProp($data, 'bid');
$cid = getProp($data, 'cid');
$version_id = getProp($data, 'version_id');
$sequence = getProp($data, 'sequence');
$id = DB::table('mp_chapter_paragraph_audios')->where('bid', $bid)->where('cid', $cid)->where('version_id', $version_id)->where('sequence', $sequence)->value('id');
// 获取所有情感
$emotion_list = DB::table('mp_emotion_list')->where('is_enabled', 1)->pluck('emotion_name', 'emotion_code')->toArray();
$emotion_list = array_flip($emotion_list);
// 获取音色支持情感
$timbre_emotion = DB::table('mp_timbres')->where('timbre_type', getProp($data, 'voice_type'))->value('emotion');
$timbre_emotion = explode('，', $timbre_emotion);
$emotion = getProp($data, 'emotion');
if (!in_array($emotion, $timbre_emotion)) $emotion = '中性';
$emotion_type = isset($emotion_list[$emotion]) ? $emotion_list[$emotion] : 'neutral';
$list = [
'bid' => $bid,
'cid' => $cid,
'version_id' => $version_id,
'sequence' => $sequence,
'role' => getProp($data, 'role'),
'gender' => getProp($data, 'gender'),
'text' => trim(getProp($data, 'text')),
'emotion' => $emotion,
'emotion_type' => $emotion_type,
'voice_type' => getProp($data, 'voice_type'),
'voice_name' => getProp($data, 'voice_name'),
'speed_ratio' => getProp($data, 'speed_ratio', 0),
'loudness_ratio'=> getProp($data, 'loudness_ratio', 0),
'emotion_scale' => getProp($data, 'emotion_scale', 4),
'pitch' => getProp($data, 'pitch', 0),
// 'paragraph_audio_url' => '',
'generate_status' => '制作中',
'error_msg' => '',
'updated_at' => date('Y-m-d H:i:s')
];
$continue = false;
// 判断是否含有中文、数字或英文,如果没有则跳过合成
if (!preg_match('/[\x{4e00}-\x{9fa5}]+/u', $list['text']) && !preg_match('/[0-9]+/', $list['text']) && !preg_match('/[a-zA-Z]+/', $list['text'])) {
$list['generate_status'] = '制作成功';
$list['paragraph_audio_url'] = 'https://zw-audiobook.tos-cn-beijing.volces.com/effects/ellipses_2s.mp3';
$list['subtitle_info'] = '{"duration": 2.0, "words": []}';
$continue = true;
}
// if (getProp($data, 'paragraph_audio_url')) $list['paragraph_audio_url'] = getProp($data, 'paragraph_audio_url');
if ($id) {
$boolen = DB::table('mp_chapter_paragraph_audios')->where('id', $id)->update($list);
}else {
$list['created_at'] = date('Y-m-d H:i:s');
$id = DB::table('mp_chapter_paragraph_audios')->insertGetId($list);
$boolen = $id ? true : false;
}
// 如果更新成功则加入查询队列
if ($boolen) {
$redis_key = "select-{$bid}-{$version_id}-{$cid}";
Redis::sadd($redis_key, $id);
}
if ($boolen && !$continue) {
$boolen = false;
$client = new Client(['timeout' => 300, 'verify' => false]);
// 根据ID通过API通知合成音频
// $result = $client->get("http://47.240.171.155:5000/api/previewTask?taskId={$id}");
$result = $client->get("http://122.9.129.83:5000/api/previewTask?taskId={$id}");
$response = $result->getBody()->getContents();
$response_arr = json_decode($response, true);
if (!isset($response_arr['code']) || (int)$response_arr['code'] !== 0) {
$error_msg = isset($response_arr['msg']) ? $response_arr['msg'] : '未知错误';
Log::info('通知火山生成段落音频失败: '.$error_msg);
Utils::throwError('20003:通知火山生成段落音频失败');
}
$boolen = true;
}
return $boolen;
}
public function insertAudioEffect($data) {
$audio_id = getProp($data, 'audio_id');
$chapter_audio = DB::table('mp_chapter_audios')->where('id', $audio_id)->first();
$bid = getProp($chapter_audio, 'bid');
$version_id = getProp($chapter_audio, 'version_id');
$cid = getProp($chapter_audio, 'cid');
if (getProp($chapter_audio, 'generate_status') != '制作成功') Utils::throwError('20003:请先完成有声制作');
$audio_effect_json = getProp($data, 'audio_effect_json');
if (!is_string($audio_effect_json)) $audio_effect_json = json_encode($audio_effect_json, 256);
try {
DB::beginTransaction();
$count = DB::table('mp_audio_tasks')->where('audio_id', $audio_id)->count('id');
if (!$count) {
$task_name = getProp($chapter_audio, 'book_name').' '.getProp($chapter_audio, 'chapter_name').'【'.getProp($chapter_audio, 'version_name').'】';
}else {
$task_name = getProp($chapter_audio, 'book_name').' '.getProp($chapter_audio, 'chapter_name').'【'.getProp($chapter_audio, 'version_name').'】('.($count+1).')';
}
$boolen1 = DB::table('mp_chapter_audios')->where('id', $audio_id)->update([
'audio_effect_status' => '添加中',
'audio_effect_json' => $audio_effect_json,
'updated_at' => date('Y-m-d H:i:s')
]);
if (!$boolen1) {
DB::rollBack();
Utils::throwError('20003:更新生成数据失败');
}
$id = DB::table('mp_audio_tasks')->insertGetId([
'audio_id' => $audio_id,
'generate_status' => '执行中',
'generate_json' => json_encode([], 256),
'bid' => $bid,
'book_name' => getProp($chapter_audio, 'book_name'),
'version_id' => $version_id,
'version_name' => getProp($chapter_audio, 'version_name'),
'cid' => $cid,
'chapter_name' => getProp($chapter_audio, 'chapter_name'),
'task_name' => $task_name,
'created_at' => date('Y-m-d H:i:s'),
'updated_at' => date('Y-m-d H:i:s')
]);
if (!$id) {
DB::rollBack();
Utils::throwError('20003:创建任务失败');
}
}catch (\Exception $e) {
DB::rollBack();
Utils::throwError('20003:'.$e->getMessage());
}
DB::commit();
$client = new Client(['timeout' => 300, 'verify' => false]);
// 根据ID通过API通知合成音频
// $result = $client->get("http://47.240.171.155:5000/api/postTask?taskId={$id}");
$result = $client->get("http://122.9.129.83:5000/api/postTask?taskId={$id}");
$response = $result->getBody()->getContents();
$response_arr = json_decode($response, true);
if (!isset($response_arr['code']) || (int)$response_arr['code'] !== 0) {
$error_msg = isset($response_arr['msg']) ? $response_arr['msg'] : '未知错误';
Log::info('通知火山插入音效失败: '.$error_msg);
Utils::throwError('20003:通知火山插入音效失败');
}
return true;
}
public function insertBgm($data) {
$audio_id = getProp($data, 'audio_id');
$chapter_audio = DB::table('mp_chapter_audios')->where('id', $audio_id)->first();
$bid = getProp($chapter_audio, 'bid');
$version_id = getProp($chapter_audio, 'version_id');
$cid = getProp($chapter_audio, 'cid');
if (getProp($chapter_audio, 'generate_status') != '制作成功') Utils::throwError('20003:请先完成有声制作');
$bgm_json = getProp($data, 'bgm_json');
if (!is_string($bgm_json)) $bgm_json = json_encode($bgm_json, 256);
if (!$bgm_json) {
$bgm_json = getProp($data, 'audio_effect_json');
if (!is_string($bgm_json)) $bgm_json = json_encode($bgm_json, 256);
}
try {
DB::beginTransaction();
$count = DB::table('mp_audio_tasks')->where('audio_id', $audio_id)->count('id');
if (!$count) {
$task_name = getProp($chapter_audio, 'book_name').' '.getProp($chapter_audio, 'chapter_name').'【'.getProp($chapter_audio, 'version_name').'】';
}else {
$task_name = getProp($chapter_audio, 'book_name').' '.getProp($chapter_audio, 'chapter_name').'【'.getProp($chapter_audio, 'version_name').'】('.($count+1).')';
}
$boolen1 = DB::table('mp_chapter_audios')->where('id', $audio_id)->update([
'bgm_status' => '添加中',
'bgm_json' => $bgm_json,
'updated_at' => date('Y-m-d H:i:s')
]);
if (!$boolen1) {
DB::rollBack();
Utils::throwError('20003:更新生成数据失败');
}
$id = DB::table('mp_audio_tasks')->insertGetId([
'audio_id' => $audio_id,
'generate_status' => '执行中',
'generate_json' => json_encode([], 256),
'bid' => $bid,
'book_name' => getProp($chapter_audio, 'book_name'),
'version_id' => $version_id,
'version_name' => getProp($chapter_audio, 'version_name'),
'cid' => $cid,
'chapter_name' => getProp($chapter_audio, 'chapter_name'),
'task_name' => $task_name,
'created_at' => date('Y-m-d H:i:s'),
'updated_at' => date('Y-m-d H:i:s')
]);
if (!$id) {
DB::rollBack();
Utils::throwError('20003:创建任务失败');
}
}catch (\Exception $e) {
DB::rollBack();
Utils::throwError('20003:'.$e->getMessage());
}
DB::commit();
$client = new Client(['timeout' => 300, 'verify' => false]);
// 根据ID通过API通知合成音频
// $result = $client->get("http://47.240.171.155:5000/api/postTask?taskId={$id}");
$result = $client->get("http://122.9.129.83:5000/api/postTask?taskId={$id}");
$response = $result->getBody()->getContents();
$response_arr = json_decode($response, true);
if (!isset($response_arr['code']) || (int)$response_arr['code'] !== 0) {
$error_msg = isset($response_arr['msg']) ? $response_arr['msg'] : '未知错误';
Log::info('通知火山插入bgm失败: '.$error_msg);
Utils::throwError('20003:通知火山插入bgm失败');
}
return true;
}
public function getParagraphAudios($data) {
$bid = getProp($data, 'bid');
$cid = getProp($data, 'cid');
$version_id = getProp($data, 'version_id');
$sequence = getProp($data, 'sequence');
// 获取已生成的音频
$query = DB::table('mp_chapter_paragraph_audios')->where('bid', $bid)->where('cid', $cid)->where('version_id', $version_id);
if ($sequence) $query->where('sequence', $sequence);
$paragraph_audios = $query->orderBy('sequence')->get();
$result = [];
foreach($paragraph_audios as $item) {
$result[] = [
'sequence' => getProp($item, 'sequence'),
'role' => getProp($item, 'role'),
'gender' => getProp($item, 'gender'),
'text' => trim(getProp($item, 'text')),
'emotion' => getProp($item, 'emotion'),
'emotion_type' => getProp($item, 'emotion_type'),
'voice_type' => getProp($item, 'voice_type'),
'voice_name' => getProp($item, 'voice_name'),
'speed_ratio' => getProp($item, 'speed_ratio'),
'loudness_ratio' => getProp($item, 'loudness_ratio'),
'emotion_scale' => getProp($item, 'emotion_scale'),
'paragraph_audio_url' => getProp($item, 'paragraph_audio_url'),
'subtitle_info' => json_decode(getProp($item, 'subtitle_info'), true),
];
}
return $result;
}
// 新增合成任务
public function addGenerateTask($data) {
$bid = getProp($data, 'bid');
$cid = getProp($data, 'cid');
$version_id = getProp($data, 'version_id');
$generate_json = getProp($data, 'generate_json');
// 获取已生成的音频
$paragraph_audios = DB::table('mp_chapter_paragraph_audios')->where('bid', $bid)->where('cid', $cid)->where('version_id', $version_id)->get();
$paragraph_list = [];
foreach($paragraph_audios as $item) {
$paragraph_list[getProp($item, 'sequence')] = [
'role' => getProp($item, 'role'),
'gender' => getProp($item, 'gender'),
'text' => trim(getProp($item, 'text')),
'emotion' => getProp($item, 'emotion'),
'emotion_type' => getProp($item, 'emotion_type'),
'voice_type' => getProp($item, 'voice_type'),
'voice_name' => getProp($item, 'voice_name'),
'speed_ratio' => getProp($item, 'speed_ratio'),
'loudness_ratio' => getProp($item, 'loudness_ratio'),
'emotion_scale' => getProp($item, 'emotion_scale'),
'paragraph_audio_url' => getProp($item, 'paragraph_audio_url'),
];
}
// 更新角色-音色信息
$existed_role_info = DB::table('mp_book_version')->where('bid', $bid)->where('id', $version_id)->value('role_info');
$existed_role_info = json_decode($existed_role_info, true);
if (!$existed_role_info) $existed_role_info = [];
// 获取情感信息
$emotion_list = DB::table('mp_emotion_list')->where('is_enabled', 1)->pluck('emotion_name', 'emotion_code')->toArray();
$emotion_list = array_flip($emotion_list);
// 获取音色对应情感组
$timbre_emotions = DB::table('mp_timbres')->where('is_enabled', 1)->select('timbre_type', 'emotion')->get();
$timbre_emotion_list = [];
foreach($timbre_emotions as $item) {
$timbre_emotion_list[getProp($item, 'timbre_type')] = explode('，', getProp($item, 'emotion'));
}
// 构造生成音频的json
$words = json_decode($generate_json, true);
// 最终合成前的参数组
$mp_chapter_paragraph_audios = [];
$sequence = 1;
$complete_paragraph_sequences = [];
foreach($words as &$word) {
if (!isset($word['text']) || !isset($word['emotion']) || !isset($word['voice_type']) || !isset($word['voice_name']) || !isset($word['speed_ratio']) || !isset($word['loudness_ratio']) || !isset($word['emotion_scale'])) Utils::throwError('20003:参数格式有误');
if (!($word['text']) || !($word['voice_type']) || !($word['voice_name'])) Utils::throwError('20003:参数不得为空');
$role = getProp($word, 'role');
$word['gender'] = (int)$word['gender'];
// 判断音色对应情感是否支持,不支持则调整为中性
$access_emotion = isset($timbre_emotion_list[$word['voice_type']]) ? $timbre_emotion_list[$word['voice_type']] : [];
if (!in_array($word['emotion'], $access_emotion)) $word['emotion'] = '中性';
// 如果有对应情感则赋值,没有则默认为中性(neutral)
if (isset($emotion_list[getProp($word, 'emotion')])) {
$word['emotion_type'] = $emotion_list[getProp($word, 'emotion')];
}else {
$word['emotion'] = '中性';
$word['emotion_type'] = 'neutral';
}
$existed_role_info[$role] = [
'timbre_type' => $word['voice_type'],
'timbre_name' => $word['voice_name'],
'emotion' => $word['emotion'],
'emotion_type' => $word['emotion_type'],
'speed_ratio' => $word['speed_ratio'],
'loudness_ratio'=> $word['loudness_ratio'],
'emotion_scale' => $word['emotion_scale'],
'pitch' => $word['pitch']
];
$word['paragraph_audio_url'] = '';
// 判断生成参数是否相同,相同则直接使用已生成的音频
$paragraph = isset($paragraph_list[$sequence]) ? $paragraph_list[$sequence] : [];
// 如果音频存在并且参数都未改变则使用已生成的音频
if (getProp($paragraph, 'paragraph_audio_url')) {
// if (getProp($paragraph, 'role') == getProp($word, 'role') && getProp($paragraph, 'text') == getProp($word, 'text') &&
// getProp($paragraph, 'voice_type') == getProp($word, 'voice_type') &&
// getProp($paragraph, 'speed_ratio') == getProp($word, 'speed_ratio') && getProp($paragraph, 'loudness_ratio') == getProp($word, 'loudness_ratio') &&
// getProp($paragraph, 'emotion_scale') == getProp($word, 'emotion_scale'))
// {
// $word['paragraph_audio_url'] = getProp($paragraph, 'paragraph_audio_url');
// }
$word['paragraph_audio_url'] = getProp($paragraph, 'paragraph_audio_url');
}
$tmp = $word;
// 组装章节分句音频数据
// $tmp['sequence'] = getProp($word, 'sequence');
// $tmp['text'] = getProp($word, 'text');
// $tmp['emotion'] = getProp($word, 'emotion');
// $tmp['emotion_type'] = getProp($word, 'emotion_type');
// $tmp['voice_name'] = getProp($word, 'voice_name');
// $tmp['voice_type'] = getProp($word, 'voice_type');
// $tmp['speed_ratio'] = getProp($word, 'speed_ratio');
// $tmp['loudness_ratio'] = getProp($word, 'loudness_ratio');
// $tmp['emotion_scale'] = getProp($word, 'emotion_scale');
$tmp['bid'] = $bid;
$tmp['version_id'] = $version_id;
$tmp['cid'] = $cid;
$tmp['sequence'] = $sequence;
$tmp['created_at'] = date('Y-m-d H:i:s');
$tmp['updated_at'] = date('Y-m-d H:i:s');
if (!getProp($tmp, 'paragraph_audio_url')) Utils::throwError('20003:段落未生成音频,请等待完成后提交');
$mp_chapter_paragraph_audios[] = $tmp;
$complete_paragraph_sequences[] = $sequence;
$sequence++;
}
$generate_json = json_encode($words, 256);
// 判断是否有未生成字幕的段落
$no_subtitle_sequences = DB::table('mp_chapter_paragraph_audios')->where('bid', $bid)->where('cid', $cid)->where('version_id', $version_id)->whereIn('sequence', $complete_paragraph_sequences)->whereNull('subtitle_info')->pluck('sequence')->toArray();
if ($no_subtitle_sequences) {
Utils::throwError('20003:请先将以下段落序号生成字幕('.implode('、', $no_subtitle_sequences).')');
}
try {
DB::beginTransaction();
$role_info = json_encode($existed_role_info, 256);
$boolen = DB::table('mp_book_version')->where('bid', $bid)->where('id', $version_id)->update(['role_info' => $role_info, 'updated_at' => date('Y-m-d H:i:s')]);
if (!$boolen) {
DB::rollBack();
Utils::throwError('20003:更新角色信息失败');
}
$count = DB::table('mp_audio_tasks')->where('bid', $bid)->where('version_id', $version_id)->where('cid', $cid)->count('id');
$chapter_audio = DB::table('mp_chapter_audios')->where('bid', $bid)->where('version_id', $version_id)->where('cid', $cid)->first();
if (!$count) {
$task_name = getProp($chapter_audio, 'book_name').' '.getProp($chapter_audio, 'chapter_name').'【'.getProp($chapter_audio, 'version_name').'】';
}else {
$task_name = getProp($chapter_audio, 'book_name').' '.getProp($chapter_audio, 'chapter_name').'【'.getProp($chapter_audio, 'version_name').'】('.($count+1).')';
}
$boolen1 = DB::table('mp_chapter_audios')->where('bid', $bid)->where('version_id', $version_id)->where('cid', $cid)->update(['generate_status'=>'制作中', 'generate_json' => $generate_json, 'updated_at' => date('Y-m-d H:i:s')]);
if (!$boolen1) {
DB::rollBack();
Utils::throwError('20003:更新生成数据失败');
}
$id = DB::table('mp_audio_tasks')->insertGetId([
'audio_id' => getProp($chapter_audio, 'id'),
'generate_status' => '执行中',
'generate_json' => $generate_json,
'bid' => $bid,
'book_name' => getProp($chapter_audio, 'book_name'),
'version_id' => $version_id,
'version_name' => getProp($chapter_audio, 'version_name'),
'cid' => $cid,
'chapter_name' => getProp($chapter_audio, 'chapter_name'),
'task_name' => $task_name,
'created_at' => date('Y-m-d H:i:s'),
'updated_at' => date('Y-m-d H:i:s')
]);
if (!$id) {
DB::rollBack();
Utils::throwError('20003:创建任务失败');
}
// 删除不在段落序号范围内的其他数据
if ($complete_paragraph_sequences) {
DB::table('mp_chapter_paragraph_audios')->where('bid', $bid)->where('version_id', $version_id)->where('cid', $cid)->whereNotIn('sequence', $complete_paragraph_sequences)->delete();
}
// // 删除章节分句音频数据并重新插入
// DB::table('mp_chapter_paragraph_audios')->where('bid', $bid)->where('version_id', $version_id)->where('cid', $cid)->delete();
// $boolen3 = DB::table('mp_chapter_paragraph_audios')->insert($mp_chapter_paragraph_audios);
// if (!$boolen3) {
// DB::rollBack();
// Utils::throwError('20003:更新章节分句音频失败');
// }
} catch (\Exception $e) {
DB::rollBack();
Utils::throwError('20003:'.$e->getMessage());
}
DB::commit();
// 通知火山生成音频
$client = new Client(['timeout' => 300, 'verify' => false]);
// 根据ID通过API通知合成音频
// $result = $client->get("http://47.240.171.155:5000/api/chapterTask?taskId={$id}");
$result = $client->get("http://122.9.129.83:5000/api/chapterTask?taskId={$id}");
$response = $result->getBody()->getContents();
$response_arr = json_decode($response, true);
if (!isset($response_arr['code']) || (int)$response_arr['code'] !== 0) {
$error_msg = isset($response_arr['msg']) ? $response_arr['msg'] : '未知错误';
Log::info('通知火山生成音频失败: '.$error_msg);
Utils::throwError('20003:通知火山生成音频失败');
}
return true;
}
public function timbreList($data) {
$gender = getProp($data, 'gender');
$timbre_name = getProp($data, 'voice_name');
$category_id = getProp($data, 'category_id');
$query = DB::table('mp_timbres')->where('is_enabled', 1)->select('timbre_name as voice_name', 'timbre_type as voice_type', 'gender', 'language', 'emotion', 'label', 'first_category_id', 'first_category_name', 'second_category_id', 'second_category_name', 'third_category_id', 'third_category_name', 'audio_url');
if ($gender) {
$query->where('gender', $gender);
}
if ($timbre_name) {
$query->where('timbre_name', 'like', "%{$timbre_name}%");
}
if ($category_id) {
$query->where(function ($query) use ($category_id) {
$query->where('first_category_id', $category_id)->orWhere('second_category_id', $category_id)->orWhere('third_category_id', $category_id);
});
}
$list = $query->get()->map(function ($value) {
$value = (array)$value;
$value['voice_name'] = str_replace('（多情感）', '', $value['voice_name']);
return $value;
})->toArray();
return $list;
}
// 生成火山临时token
public function setStsToken() {
// ************* 配置参数 *************
$method = 'GET';
$service = 'sts';
$host = 'open.volcengineapi.com';
$region = env('VOLC_REGION');
$endpoint = 'https://open.volcengineapi.com';
// $endpoint = 'https://tos-cn-beijing.volces.com';
$access_key = env('VOLC_AK');
$secret_key = env('VOLC_SK');
// 获取缓存中的token，如果没有则请求接口
$token = Redis::get('volc_sts_token');
if (!$token) {
// 查询参数
$query_parameters = [
'Action' => 'AssumeRole',
'RoleSessionName' => 'user@zw',
'RoleTrn' => 'trn:iam::2102575520:role/tos_role',
'Version' => '2018-01-01'
];
// 生成URL编码的查询字符串
$request_parameters = http_build_query($query_parameters, '', '&', PHP_QUERY_RFC3986);
// 获取签名头信息
$headers = $this->getSignHeaders($method, $service, $host, $region, $request_parameters, $access_key, $secret_key);
// 构建完整URL
$request_url = $endpoint . '?' . $request_parameters;
$client = new Client(['verify' => false]);
$response = $client->get($request_url, ['headers' => $headers]);
$response_arr = json_decode($response->getBody()->getContents(), true);
$result = [
'SessionToken' => isset($response_arr['Result']['Credentials']['SessionToken']) ? $response_arr['Result']['Credentials']['SessionToken'] : '',
'AccessKeyId' => isset($response_arr['Result']['Credentials']['AccessKeyId']) ? $response_arr['Result']['Credentials']['AccessKeyId'] : '',
'SecretAccessKey' => isset($response_arr['Result']['Credentials']['SecretAccessKey']) ? $response_arr['Result']['Credentials']['SecretAccessKey'] : '',
'Region' => env('VOLC_REGION'),
'Endpoint' => env('VOLC_END_POINT'),
'Bucket' => env('VOLC_BUCKET'),
];
// 缓存token
Redis::setex('volc_sts_token', 3000, json_encode($result));
return $result;
} else {
return json_decode($token, true);
}
// $response = $response['Response'];
// $access_key = $response['Credentials']['AccessKeyId'];
// $secret_key = $response['Credentials']['AccessKeySecret'];
// $security_token = $response['Credentials']['SecurityToken'];
// $expiration = $response['Credentials']['Expiration'];
// dd($response_arr);
}
public function emotionGroups($data) {
$id = getProp($data, 'group_id');
$group_name = getProp($data, 'group_name');
$voice_type = getProp($data, 'voice_type');
$query = DB::table('mp_emotion_groups')->where('is_enabled', 1)->select('id as group_id', 'group_name',
'emotion', 'emotion_type', 'voice_name', 'voice_type', 'speed_ratio', 'loudness_ratio', 'emotion_scale',
'pitch', 'generate_status', 'audio_url', 'error_msg');
if ($group_name) {
$query->where('group_name', 'like', "%{$group_name}%");
}
if ($id) {
$query->where('id', $id);
}
if ($voice_type) {
$query->where('voice_type', $voice_type);
}
return $query->orderBy('id')->get()->map(function ($value) {
return (array)$value;
})->toArray();
}
private function sign($key, $msg) {
return hash_hmac('sha256', $msg, $key, true);
}
// 生成签名密钥
private function getSignatureKey($key, $dateStamp, $regionName, $serviceName) {
$kDate = $this->sign($key, $dateStamp);
$kRegion = $this->sign($kDate, $regionName);
$kService = $this->sign($kRegion, $serviceName);
$kSigning = $this->sign($kService, 'request');
return $kSigning;
}
// 获取签名头信息
private function getSignHeaders($method, $service, $host, $region, $request_parameters, $access_key, $secret_key) {
$contenttype = 'application/x-www-form-urlencoded';
$accept = 'application/json';
// 获取当前UTC时间
$t = new DateTime('now', new DateTimeZone('UTC'));
$xdate = $t->format('Ymd\THis\Z');
$datestamp = $t->format('Ymd');
// 1. 拼接规范请求串
$canonical_uri = '/';
$canonical_querystring = $request_parameters;
$canonical_headers = "content-type:{$contenttype}\nhost:{$host}\nx-date:{$xdate}\n";
$signed_headers = 'content-type;host;x-date';
// 空请求体的SHA256哈希
$payload_hash = hash('sha256', '');
$canonical_request = implode("\n", [
$method,
$canonical_uri,
$canonical_querystring,
$canonical_headers,
$signed_headers,
$payload_hash
]);
// 2. 拼接待签名字符串
$algorithm = 'HMAC-SHA256';
$credential_scope = implode('/', [$datestamp, $region, $service, 'request']);
$hashed_canonical_request = hash('sha256', $canonical_request);
$string_to_sign = implode("\n", [
$algorithm,
$xdate,
$credential_scope,
$hashed_canonical_request
]);
// 3. 计算签名
$signing_key = $this->getSignatureKey($secret_key, $datestamp, $region, $service);
$signature = hash_hmac('sha256', $string_to_sign, $signing_key);
// 4. 添加签名到请求头
$authorization_header = sprintf(
'%s Credential=%s/%s, SignedHeaders=%s, Signature=%s',
$algorithm,
$access_key,
$credential_scope,
$signed_headers,
$signature
);
return [
'Accept' => $accept,
'Content-Type' => $contenttype,
'X-Date' => $xdate,
'Authorization' => $authorization_header
];
}
// 文字合成语音(火山引擎)
public function tts($data) {
$url = 'https://openspeech.bytedance.com/api/v1/tts';
$headers = [
'Authorization' => 'Bearer;'.env('VOLC_TOKEN'),
'Content-Type' => 'application/json; charset=UTF-8'
];
$post_data = [
'app' => [
'appid' => env('VOLC_APPID'),
'token' => env('VOLC_TOKEN'),
'cluster' => 'volcano_tts'
],
'user' => [
'uid' => 'mp_audio'
],
// 'audio' => [
// 'voice_type' =>
// ],
];
}
public function scriptList($data) {
$script_id = getProp($data, 'script_id');
$script_name = getProp($data, 'script_name');
$query = DB::table('mp_scripts')->where('is_deleted', 0)->select('*');
if ($script_id) {
$query->where('id', $script_id);
}
if ($script_name) {
$query->where('script_name', 'like', "%{$script_name}%");
}
return $query->orderBy('created_at', 'desc')->paginate(12);
}
public function scripts($data) {
$script_id = getProp($data, 'script_id');
$script_name = getProp($data, 'script_name');
$query = DB::table('mp_scripts')->where('is_deleted', 0)->select('id as script_id', 'script_name');
if ($script_id) {
$query->where('id', $script_id);
}
if ($script_name) {
$query->where('script_name', 'like', "%{$script_name}%");
}
return $query->orderBy('created_at', 'desc')->get()->map(function ($value) {
return (array)$value;
})->toArray();
}
public function scriptInfo($data) {
$script_id = getProp($data, 'script_id');
$script = DB::table('mp_scripts')->where('id', $script_id)->where('is_deleted', 0)
->selectRaw('id as script_id, script_name, intro, highlights, roles, role_relationship, core_contradiction, art_style, scenes, status, start_episode_sequence, end_episode_sequence, episode_num, remark, created_at')->first();
if (!$script) Utils::throwError('20003:该剧本不存在!');
$script = (array)$script;
$script['roles'] = json_decode($script['roles']);
$script['scenes'] = json_decode($script['scenes']);
// 获取分集信息
$episodes = DB::table('mp_script_episodes')->where('script_id', $script_id)->orderBy('episode_number')
->select('id', 'episode_number', 'title', 'content', 'segment_number', 'segment_content')
->orderBy('episode_number')->orderBy('segment_number')->get()->map(function ($value) {
return (array)$value;
})->toArray();
$return_episodes = [];
foreach($episodes as $episode) {
$episode_number = getProp($episode, 'episode_number');
if (isset($return_episodes[$episode_number])) {
$return_episodes[$episode_number]['segments'][] = [
'segment_number' => getProp($episode, 'segment_number'),
'segment_content' => getProp($episode, 'segment_content')
];
}else {
$return_episodes[$episode_number] = [
'episode_number' => $episode_number,
'title' => getProp($episode, 'title'),
'segments' => [
[
'segment_number' => getProp($episode, 'segment_number'),
'segment_content' => getProp($episode, 'segment_content')
]
]
];
}
}
$script['episodes'] = array_values($return_episodes);
return $script;
}
public function createScript($data) {
$script_name = getProp($data, 'script_name');
$uid = Site::getUid(); // 获取当前用户ID
if (!$script_name) Utils::throwError('20001:剧本名称不能为空');
return DB::table('mp_scripts')->insertGetId([
'script_name' => $script_name,
'user_id' => $uid,
'created_at' => date('Y-m-d H:i:s'),
'updated_at' => date('Y-m-d H:i:s')
]);
}
/**
* 上传文件识别文字内容并与 DeepSeek 进行对话（流式输出版本）
*
* @param array $data 包含以下参数：
* - file: 上传的文件（UploadedFile 对象）或文件路径
* - question: 用户问题（可选）
* - model: 使用的模型（r1 或 v3，默认 v3）
* @return \Generator 返回生成器，用于流式输出
*/
public function chatWithFileStream($data) {
$script_id = getProp($data, 'script_id');
$file = getProp($data, 'file');
$content = getProp($data, 'content', '');
$bid = getProp($data, 'bid', 0);
$start_episode_sequence = getProp($data, 'start_episode_sequence', 1);
$total_episode_num = getProp($data, 'total_episode_num', 30);
$prompt = getProp($data, 'prompt');
$question = getProp($data, 'question', "请根据实例完成一个{$total_episode_num}集的剧本，要求: 1.从第{$start_episode_sequence}集开始; 2.每集内容独立成章; 3.避免重复内容; 4.确保内容连贯且逻辑清晰; 5.所有章节合起来是给出的文档内容全文大概剧情。6.要求一定要给出我需要的分镜集数,不能少7.分集序号用01、02、03显示，不得使用01-1等子集序号，并且需要匹配开始集数的序号并往后顺序显示。\n本次修改要求如下: {$prompt}\n");
$model = getProp($data, 'model');
if (!DB::table('mp_text_models')->where('model', $model)->where('is_enabled', 1)->value('id')) {
Utils::throwError('20003:该模型不存在!');
}
// 模型兼容性处理：deepseek-chat 和 deepseek-reasoner 映射到 deepseek-v4-flash
$thinkingMode = getProp($data, 'thinking', 'disabled'); // 默认非思考模式
$reasoningEffort = getProp($data, 'reasoning_effort', 'high'); // 默认思考强度
if ($model === 'deepseek-chat') {
// deepseek-chat 映射到 deepseek-v4-flash，非思考模式
$model = 'deepseek-v4-flash';
$thinkingMode = 'disabled';
} elseif ($model === 'deepseek-reasoner') {
// deepseek-reasoner 映射到 deepseek-v4-flash，思考模式
$model = 'deepseek-v4-flash';
$thinkingMode = 'enabled';
}
$script = DB::table('mp_scripts')->where('id', $script_id)->first();
if (!$script) {
Utils::throwError('20003:剧本不存在');
}
if (!$file && !$content && !$bid) {
Utils::throwError('20003:请上传文件或选择书籍或输入内容');
}
// 提取文件内容
if ($file) {
$content = $this->extractFileContent($file);
if (!$content) {
Utils::throwError('20003:无法提取文件内容，请检查文件格式');
}
} elseif ($bid) {
$content = $this->getContentByBid($bid);
if (!$content) {
Utils::throwError('20003:无法获取书籍内容，请检查书籍');
}
} elseif ($content) {
$content = filterContent($content);
} elseif ($prompt) {
$content = filterContent($prompt);
} else {
Utils::throwError('20003:请上传文件或选择书籍或输入内容');
}
// 构建消息
$messages = [
$this->sys_message,
[
'role' => 'user',
'content' => "以下是文档内容：\n\n{$content}\n\n用户问题：{$question}"
]
];
$post_data = [
'model' => $model,
'messages' => $messages,
// 'max_tokens' => 8192,
'temperature' => 0.7,
'frequency_penalty' => 0,
'presence_penalty' => 0,
'thinking' => ['type' => $thinkingMode],
'response_format' => ['type' => 'text'],
'stream' => true
];
if ($thinkingMode == 'enabled') $post_data['reasoning_effort'] = $reasoningEffort;
// 根据模型类型选择调用方法
$fullContent = '';
$fullReasoningContent = '';
$usage = [];
if (in_array($model, ['deepseek-reasoner', 'deepseek-chat', 'deepseek-v4-flash', 'deepseek-v4-pro'])) {
// DeepSeek 官方模型使用 DeepSeek API
$streamGenerator = $this->deepSeekStreamResponse($post_data);
} else {
// 其他模型使用火山引擎API
$streamGenerator = $this->volcEngineChatCompletion($post_data);
}
// 处理流式输出
foreach ($streamGenerator as $chunk) {
if (isset($chunk['type'])) {
if ($chunk['type'] === 'done') {
// 最终结果
$fullContent = $chunk['full_content'];
$fullReasoningContent = $chunk['full_reasoning'];
$usage = isset($chunk['usage']) ? $chunk['usage'] : [];
} else {
// 逐块yield数据
yield $chunk;
}
}
}
dLog('deepseek')->info('完整内容: '.$fullContent);
// $client = new Client(['timeout' => 1200, 'verify' => false]);
// $response = $client->post($this->url, [
// 'json' => $post_data,
// 'headers' => $this->headers,
// 'stream' => true // 启用流式响应
// ]);
// $body = $response->getBody();
// $fullContent = '';
// $fullReasoningContent = '';
// $usage = [];
// $buffer = '';
// Log::info('开始读取 DeepSeek 流式响应');
// // 逐行读取流式响应
// while (!$body->eof()) {
// $chunk = $body->read(1024); // 每次读取 1KB
// $buffer .= $chunk;
// // 按行分割
// $lines = explode("\n", $buffer);
// // 保留最后一个不完整的行
// $buffer = array_pop($lines);
// foreach ($lines as $line) {
// $line = trim($line);
// // 跳过空行
// if (empty($line)) {
// continue;
// }
// // Log::info('收到原始行数据', ['line' => $line]);
// // 检查是否是 SSE 数据行
// if (strpos($line, 'data: ') !== 0) {
// Log::warning('非 SSE 数据行', ['line' => $line]);
// continue;
// }
// $data = substr($line, 6); // 移除 "data: " 前缀
// if ($data === '[DONE]') {
// Log::info('收到结束标记');
// break 2; // 跳出两层循环
// }
// try {
// $json = json_decode($data, true);
// if (json_last_error() !== JSON_ERROR_NONE) {
// Log::warning('JSON 解析错误: ' . json_last_error_msg(), ['data' => $data]);
// continue;
// }
// // Log::info('成功解析 JSON', ['has_choices' => isset($json['choices'])]);
// if (isset($json['choices'][0]['delta'])) {
// $delta = $json['choices'][0]['delta'];
// // 处理思维链内容(仅 deepseek-reasoner 模型)
// // 注释掉以下内容则不返回d思维链内容
// if (isset($delta['reasoning_content'])) {
// $fullReasoningContent .= $delta['reasoning_content'];
// // Log::info('输出思维链内容', ['length' => strlen($delta['reasoning_content'])]);
// yield [
// 'type' => 'reasoning',
// 'content' => $delta['reasoning_content'],
// 'full_reasoning' => $fullReasoningContent
// ];
// }
// // 处理最终回答内容
// if (isset($delta['content'])) {
// $fullContent .= $delta['content'];
// // Log::info('输出回答内容', ['length' => strlen($delta['content'])]);
// yield [
// 'type' => 'content',
// 'content' => $delta['content'],
// // 'full_content' => $fullContent
// ];
// }
// }
// // 获取使用统计信息
// if (isset($json['usage'])) {
// $usage = $json['usage'];
// Log::info('收到使用统计', ['usage' => $usage]);
// }
// } catch (\Exception $e) {
// Log::error('解析流式响应失败: ' . $e->getMessage(), ['line' => $line]);
// continue;
// }
// }
// }
// Log::info('流式读取完成', [
// 'content_length' => strlen($fullContent),
// 'reasoning_length' => strlen($fullReasoningContent)
// ]);
// 处理完整内容并返回最终结果
$script_arr = [];
if ($fullContent) {
$script_arr = handleScriptContent($fullContent);
}
// 返回前保存剧本内容
DB::table('mp_scripts')->where('id', $script_id)->update([
'content' => $content,
'updated_at' => date('Y-m-d H:i:s')
]);
yield [
'type' => 'done',
'script' => $script_arr,
'answer' => $fullContent,
'reasoning' => $fullReasoningContent,
'usage' => $usage
];
}
/**
* 上传文件识别文字内容并与 DeepSeek 进行对话
*
* @param array $data 包含以下参数：
* - file: 上传的文件（UploadedFile 对象）或文件路径
* - question: 用户问题（可选，默认为"请总结这个文件的内容"）
* - model: 使用的模型（r1 或 v3，默认 v3）
* @return array
*/
public function chatWithFile($data) {
$script_id = getProp($data, 'script_id');
$file = getProp($data, 'file');
$content = getProp($data, 'content', '');
$bid = getProp($data, 'bid', 0);
$start_episode_sequence = getProp($data, 'start_episode_sequence', 1);
$total_episode_num = getProp($data, 'total_episode_num', 30);
$prompt = getProp($data, 'prompt');
$question = getProp($data, 'question', "请根据实例完成一个{$total_episode_num}集的剧本，要求: 1.从第{$start_episode_sequence}集开始; 2.每集内容独立成章; 3.避免重复内容; 4.确保内容连贯且逻辑清晰; 5.所有章节合起来是给出的文档内容全文大概剧情。6.要求一定要给出我需要的分镜集数,不能少7.分集序号用01、02、03显示，不得使用01-1等子集序号，并且需要匹配开始集数的序号并往后顺序显示。\n本次修改要求如下: {$prompt}\n");
// 处理文本模型
$model = getProp($data, 'model');
if (!$model) {
// 用户没有输入，使用默认值
$model = 'doubao-seed-2-0-mini-260215';
}
// 验证模型是否在可用模型表中
if (!DB::table('mp_text_models')->where('model', $model)->where('is_enabled', 1)->exists()) {
$model = 'doubao-seed-2-0-mini-260215';
}
// 模型兼容性处理：deepseek-chat 和 deepseek-reasoner 映射到 deepseek-v4-flash
$thinkingMode = getProp($data, 'thinking', 'disabled'); // 默认非思考模式
$reasoningEffort = getProp($data, 'reasoning_effort', 'high'); // 默认思考强度
if ($model === 'deepseek-chat') {
// deepseek-chat 映射到 deepseek-v4-flash，非思考模式
$model = 'deepseek-v4-flash';
$thinkingMode = 'disabled';
} elseif ($model === 'deepseek-reasoner') {
// deepseek-reasoner 映射到 deepseek-v4-flash，思考模式
$model = 'deepseek-v4-flash';
$thinkingMode = 'enabled';
}
$script = DB::table('mp_scripts')->where('id', $script_id)->first();
if (!$script) {
Utils::throwError('20003:剧本不存在');
}
if (!$file && !$content && !$bid) {
Utils::throwError('20003:请上传文件或选择书籍或输入内容');
}
// 提取文件内容
if ($file) {
$content = $this->extractFileContent($file);
if (!$content) {
Utils::throwError('20003:无法提取文件内容，请检查文件格式');
}
} elseif ($bid) {
$content = $this->getContentByBid($bid);
if (!$content) {
Utils::throwError('20003:无法获取书籍内容，请检查书籍');
}
} elseif ($content) {
$content = filterContent($content);
} elseif ($prompt) {
$content = filterContent($prompt);
} else {
Utils::throwError('20003:请上传文件或选择书籍或输入内容');
}
// 构建消息
$messages = [
$this->sys_message,
[
'role' => 'user',
'content' => "以下是文档内容：\n\n{$content}\n\n用户问题：{$question}"
]
];
$post_data = [
'model' => $model,
'messages' => $messages,
// 'max_tokens' => 8192,
'temperature' => 0.7,
'frequency_penalty' => 0,
'presence_penalty' => 0,
'thinking' => ['type' => $thinkingMode],
'response_format' => ['type' => 'text'],
'stream' => false
];
if ($thinkingMode == 'enabled') $post_data['reasoning_effort'] = $reasoningEffort;
// 根据模型类型选择调用方法
$fullContent = '';
$usage = [];
if (in_array($model, ['deepseek-reasoner', 'deepseek-chat', 'deepseek-v4-flash', 'deepseek-v4-pro'])) {
// DeepSeek 官方模型使用 DeepSeek API
$chatResult = $this->chatOnly($post_data);
} else {
// 其他模型使用火山引擎API
$chatResult = $this->volcEngineChatCompletion($post_data);
}
if (is_array($chatResult)) {
$fullContent = $chatResult['fullContent'];
$usage = $chatResult['usage'];
}
$script_arr = [];
// 处理结果
if ($fullContent) {
$script_arr = handleScriptContent($fullContent);
}
// 返回前保存剧本内容
DB::table('mp_scripts')->where('id', $script_id)->update([
'content' => $content,
'updated_at' => date('Y-m-d H:i:s')
]);
return [
'script' => $script_arr,
'answer' => $fullContent,
'usage' => $usage
];
}
public function saveScript($data) {
$script_arr =getProp($data, 'script', []);
if (!$script_arr) Utils::throwError('20003:剧本内容不能为空');
$start_episode_sequence = getProp($data, 'start_episode_sequence', 1);
$script_id = getProp($data, 'script_id');
if (!$script_id) Utils::throwError('20003:剧本ID不能为空');
try {
DB::beginTransaction();
$update_data = [
'intro' => isset($script_arr['intro']) ? $script_arr['intro'] : '',
'highlights' => isset($script_arr['highlights']) ? $script_arr['highlights'] : '',
'role_relationship' => isset($script_arr['role_relationship']) ? $script_arr['role_relationship'] : '',
'core_contradiction' => isset($script_arr['core_contradiction']) ? $script_arr['core_contradiction'] : '',
'roles' => isset($script_arr['roles']) ? json_encode($script_arr['roles'], 256) : '',
'art_style' => isset($script_arr['art_style']) ? $script_arr['art_style'] : '',
'scenes' => isset($script_arr['scenes']) ? json_encode($script_arr['scenes'], 256) : '',
'status' => 3,
'start_episode_sequence' => $start_episode_sequence,
'end_episode_sequence' => $start_episode_sequence + count($script_arr['episodes']) - 1,
'episode_num' => count($script_arr['episodes']),
'updated_at' => date('Y-m-d H:i:s')
];
// 保存剧本内容
$boolen = DB::table('mp_scripts')->where('id', $script_id)->update($update_data);
if (!$boolen) {
dLog('deepseek')->info('剧本内容保存失败', $update_data);
logDB('deepseek', 'error', '剧本内容保存失败', ['script_id' => $script_id]);
Utils::throwError('20003:剧本内容保存失败');
}
// 保存分集内容
// 删除历史分集内容
$boolen1 = DB::table('mp_script_episodes')->where('script_id', $script_id)->delete();
$episodes = [];
$sequence = 1;
foreach ($script_arr['episodes'] as $episode) {
$segment_number = 1;
foreach($episode['segments'] as $segment) {
$episodes[] = [
'script_id' => $script_id,
'episode_number' => $episode['episode_number'],
'title' => $episode['title'],
// 'content' => $episode['content'],
'content' => '',
'segment_number' => $segment_number,
'segment_content' => $segment['segment_content'],
'sequence' => $sequence,
'created_at' => date('Y-m-d H:i:s'),
'updated_at' => date('Y-m-d H:i:s')
];
$sequence++;
$segment_number++;
}
}
$boolen2 = DB::table('mp_script_episodes')->insert($episodes);
if (!$boolen2) {
dLog('deepseek')->info('分集内容保存失败', $episodes);
logDB('deepseek', 'error', '分集内容保存失败', ['episodes_count' => count($episodes)]);
Utils::throwError('20003:分集内容保存失败');
}
} catch (\Exception $e) {
DB::rollBack();
Utils::throwError('20003:'.$e->getMessage());
}
DB::commit();
return true;
}
public function exportScript($data) {
$script = $this->scriptInfo($data);
$export_type = getProp($data, 'export_type', 'txt');
// 生成文件名
$filename = $script['script_name'] . '_' . date('YmdHis');
// 根据导出类型生成不同格式的文件
switch ($export_type) {
case 'txt':
return $this->exportScriptAsTxt($script, $filename);
case 'pdf':
return $this->exportScriptAsPdf($script, $filename);
default:
Utils::throwError('20003:不支持的导出格式，支持：txt、pdf');
}
}
/**
* 导出剧本为TXT格式
*/
private function exportScriptAsTxt($script, $filename) {
// 构建TXT内容
$content = $this->buildScriptContent($script);
// 设置响应头，直接下载
header('Content-Type: text/plain; charset=utf-8');
header('Content-Disposition: attachment; filename="' . $filename . '.txt"');
header('Content-Length: ' . strlen($content));
// 输出内容并结束
echo $content;
exit();
}
/**
* 导出剧本为PDF格式
*/
private function exportScriptAsPdf($script, $filename) {
// 使用HTML转PDF的方式来更好地支持中文
$htmlContent = $this->buildScriptHtmlForPdf($script);
// 创建PDF实例
$pdf = new TCPDF(PDF_PAGE_ORIENTATION, PDF_UNIT, PDF_PAGE_FORMAT, true, 'UTF-8', false);
// 设置文档信息
$pdf->SetCreator('剧本导出系统');
$pdf->SetAuthor('系统');
$pdf->SetTitle($script['script_name']);
$pdf->SetSubject('剧本导出');
// 设置边距
$pdf->SetMargins(15, 15, 15);
$pdf->SetAutoPageBreak(TRUE, 15);
// 添加页面
$pdf->AddPage();
// 注册并使用 simsun.ttf 字体
$pdf->SetFont('simsun', '', 12); // 设置字体和大小
// 使用HTML内容生成PDF
$pdf->writeHTML($htmlContent, true, false, true, false, '');
// 直接输出PDF文件供下载
header('Content-Type: application/pdf');
header('Content-Disposition: attachment; filename="' . $filename . '.pdf"');
// 直接输出PDF内容
$pdf->Output($filename . '.pdf', 'D');
exit();
}
/**
* 构建用于PDF的HTML内容
*/
private function buildScriptHtmlForPdf($script) {
$html = '';
// 标题
$html .= '' . htmlspecialchars($script['script_name']) . '
';
// 剧本简介
if (!empty($script['intro'])) {
$html .= '剧本简介
';
$html .= '' . nl2br(htmlspecialchars($script['intro'])) . '
';
}
// 亮点
if (!empty($script['highlights'])) {
$html .= '亮点
';
$html .= '' . nl2br(htmlspecialchars($script['highlights'])) . '
';
}
// 核心矛盾
if (!empty($script['core_contradiction'])) {
$html .= '核心矛盾
';
$html .= '' . nl2br(htmlspecialchars($script['core_contradiction'])) . '
';
}
// 艺术风格
if (!empty($script['art_style'])) {
$html .= '艺术风格
';
$html .= '' . nl2br(htmlspecialchars($script['art_style'])) . '
';
}
// 角色列表
if (!empty($script['roles']) && is_array($script['roles'])) {
$html .= '角色列表
';
$html .= '';
foreach ($script['roles'] as $role) {
if (is_array($role) || is_object($role)) {
$html .= '- ' . htmlspecialchars(getProp($role, 'role', '')) . '：' . htmlspecialchars(getProp($role, 'description', '')) . '
';
} else {
$html .= '- ' . htmlspecialchars($role) . '
';
}
}
$html .= '
';
}
// 角色关系
if (!empty($script['role_relationship'])) {
$html .= '角色关系
';
$html .= '' . nl2br(htmlspecialchars($script['role_relationship'])) . '
';
}
// 场景列表
if (!empty($script['scenes']) && is_array($script['scenes'])) {
$html .= '场景列表
';
$html .= '';
foreach ($script['scenes'] as $scene) {
if (is_array($scene) || is_object($scene)) {
$html .= '- ' . htmlspecialchars(getProp($scene, 'scene', '')) . '：' . htmlspecialchars(getProp($scene, 'description', '')) . '
';
} else {
$html .= '- ' . htmlspecialchars($scene) . '
';
}
}
$html .= '
';
}
// 分集内容
if (!empty($script['episodes']) && is_array($script['episodes'])) {
$html .= '分集内容
';
foreach ($script['episodes'] as $episode) {
$html .= '';
$html .= '
第' . htmlspecialchars($episode['episode_number']) . '集';
if (!empty($episode['title'])) {
$html .= '：' . htmlspecialchars($episode['title']);
}
$html .= '
';
// 处理分段内容
if (!empty($episode['segments']) && is_array($episode['segments'])) {
foreach ($episode['segments'] as $segment) {
if (!empty($segment['segment_content'])) {
$html .= '
';
if (!empty($segment['segment_number'])) {
$html .= '第' . htmlspecialchars($segment['segment_number']) . '段
';
}
$html .= nl2br(htmlspecialchars($segment['segment_content']));
$html .= '
';
}
}
}
$html .= '