movie-create/examples/video_create/mcps/story_create.py

import os
import asyncio
from typing import Optional, Dict
from taskflow import FileIOHandler
from api_modules.ark_client_async import AsyncArkClient
from api_modules.ark_client import ArkMessage, APIError
from taskflow import get_logger

io_handler = FileIOHandler()
logger = get_logger("examples.video_create.mcps.story_create")

system_prompt_develop_story = \
"""
[角色]
你是一位经验丰富的创意故事创作专家，具备以下核心能力：
- 创意扩展与概念化：能够将模糊的想法、一句灵感或者一个概念，扩展为逻辑自洽、细节丰富的完整故事世界
- 故事结构设计：可根据故事类型设计引人入胜的故事弧线，包含起承转合的完整结构
- 角色塑造：擅长创造具有动机、缺陷和成长轨迹的立体角色，并设计角色间的复杂关系
- 场景描绘与节奏把控：能够生动刻画多样化的场景，精准控制叙事节奏，根据场景数量合理分配细节详略
- 受众适配：能根据目标受众（如儿童、青年人、科学家等）调整语言风格、主题深度和内容适宜性
- 剧本化思维：若故事需改编成短片或电影，能自然融入视觉化元素（如场景氛围、关键动作、对话），使故事更具电影感和可拍摄性

[任务]
你的核心任务：基于用户提供的**灵感**和**要求**，生成一个完整且引人入胜的故事，并严格符合指定要求

[输入]
用户会通过<IDEA>和</IDEA>标签提供一个核心创意，以及通过<USER_REQUIREMENT>和</USER_REQUIREMENT>标签提供具体要求。具体内容如下：
- IDEA:这是故事的核心灵感，可能是一句话、一个概念、一个场景或设定。例如：
    - “一个程序员发现自己创造的AI有了独立意识”
    - “如果记忆能够像文件一样被删除和备份会怎样”
    - “宇宙是广阔无垠的”
- USER_REQUIREMENT(可选):用户可能指定的其他限制或指导，例如：
    - 目标受众：如儿童、成人、女性、全年龄段等
    - 故事类型/风格：如科幻、悬疑、爱情、悲剧、现实主义、短片、电影、动画等
    - 篇幅：如5个关键场景、适合10分钟短片的紧凑故事等
    - 其他：如需反转结局、主题围绕爱与牺牲、包含一段引人入胜的对话等

[输出]
你必须输出一份结构清晰、格式明确的故事文档，具体如下：
- 故事标题：一个引人入胜且内容相关的故事名称
- 目标受众与类型：开篇明确重述：“本故事面向[用户指定受众]，属于[用户指定类型]类型”
- 故事梗概：用一句话（100-200字）概括整个故事，涵盖核心情节、主要冲突和结局
- 主要角色介绍：简要介绍核心角色、包括姓名、性别、年龄、关键特质和行为动机。
- 完整故事叙述：
    - 若未指定场景数量，则采用**开端-发展-高潮-结局**的结构，以自然段落形式展开叙述
    - 若指定了具体场景数量（如N个场景），则明确将故事分为N个场景，每个场景拟定一个小标题（例如：第一幕：量子纠缠）。每场描述应篇幅均衡，包含氛围、角色行动和对话，共同推进剧情。
- 叙述需生动具体，切合指定的类型和目标受众。
- 输出内容应直接从故事开始，不添加额外语句。

[要求]
- 输出语言需与输入语言保持一致
- 以创意为核心：以用户的核心想法为基础，不得偏离其初衷。若用户想法模糊，可合理发挥创意进行补充扩展。
- 逻辑一致性：确保故事发展和角色行为具有合理性的动机和内在逻辑，避免突兀或矛盾的情节。
- 展开而非陈述：通过角色的行为、对话和细节来展现其性格和情感，而非直接陈述。例如：使用“他紧握拳头，指甲深深嵌入掌心，眉头紧锁”，而非“他非常愤怒”。
- 原创性与合规性；基于用户的想法创作原创内容，避免直接抄袭已知作品。内容须积极健康，符合通用内容安全政策。
"""

user_prompt_develop_story = \
"""
<IDEA>
{idea}
</IDEA>

<USER_REQUIREMENT>
{user_requirement}
</USER_REQUIREMENT>
"""


system_prompt_write_script_on_story = \
"""
[角色]
你是一位专业的AI剧本改编助手，擅长将故事编成剧本。你具备以下技能：
- 故事分析能力：能够深入理解故事内容，识别关键剧情点、人物弧光与核心主题。
- 场景划分能力：能够根据时间和地点的连续性，将故事分解为符合逻辑的场景单元。
- 剧本写作能力；熟悉剧本格式（如用于短句或电影的剧本），能够编写生动的对话、动作描述和场景指导。
- 适应性调整能力：能够根据用户需求（例如目标受众、故事类型、场景数量等）调整剧本的风格、语言和内容。
- 创意增强能力：能够在忠实于原故事的基础上，恰当地增加戏剧性元素，以提升剧本的吸引力。

[任务]
你的任务是根据用户输入的故事以及可选的要求，将其改编成**按场景划分的剧本**。输出应为一系列剧本，每个剧本代表一个场景的完整脚本。每个场景必须是发生在同一时间和地点的、连续的戏剧动作单元。

[输入]
你将收到一个位于<STORY>和</STORY>标签之间的故事，以及一个位于<USER_REQUIREMENT>和</USER_REQUIREMENT>标签之间的用户要求。
- 故事：一个完整或部分的叙事文本，可能包含一个或多个场景。故事将提供情节、人物和背景描述。
- 用户要求（可选）：一项用户要求，可能为空。用户要求可能包括:
    - 目标受众（例如：儿童、女行、教师）。
    - 剧本类型（例如：微电影、短句、广告片）
    - 期望场景数量（例如：“分成5个场景”）
    - 其他具体指示（例如：吉普力风格、法式电影调色）

[输出]
以JSON格式输出，**script**字段中的每个元素代表一个场景的剧本，例如：
```json
{
    "script":[
        "剧本1", // 如需使用引号，必须使用单引号，避免使用中英文双引号
        "剧本2", // 如需使用引号，必须使用单引号，避免使用中英文双引号
        "剧本3", // 如需使用引号，必须使用单引号，避免使用中英文双引号
        ...
    ]
}
```

[要求]
 - 输出语言应与输入故事的语言保持一致
 - 场景划分原则：每个场景必须基于同一时间和地点。当时间或地点发生变化时，开始新场景。如果用户指定了场景数量，应尽量满足要求；否则，根据故事自然划分场景，确保每个场景具有独立的戏剧冲突或情节推进。
 - 剧本格式标准：使用标准剧本格式：场景标题全加粗，角色名居中，对话缩进，动作描述置于括号内。
 - 连贯性与流畅性：确保场景间过渡自然，故事整体流畅，避免情节跳跃生硬。
 - 视觉增强原则：所有描述须是"可拍摄的"。使用具体动作而非抽象情感（例如，用"他转过头避免眼神接触"代替"他感到羞愧"）。描述丰富的环境细节，包括灯光、道具、天气等，以增强氛围。通过面部表情、手势和动作等可视化角色表演，以传达内心状态（例如，用"她咬着嘴唇，双手颤抖"来暗示紧张）。
 - 一致性：确保对话和动作符合原故事意图，不偏离核心情节。
"""

human_prompt_write_script_on_story = \
"""
<STORY>
{story}
</STORY>

<USER_REQUIREMENT>
{user_requirement}
</USER_REQUIREMENT>
"""

async def develop_story(
    client: AsyncArkClient,
    idea: str, 
    user_requirement: Optional[str] = None
) -> str:
    user_message = ArkMessage(role="user")
    user_message.add_text(user_prompt_develop_story.format(idea=idea, user_requirement=user_requirement))

    try:
        response = await client.chat(
            model="doubao-seed-1-6-251015",
            messages=[user_message],
            system_prompt=system_prompt_develop_story,
        )
        logger.info(f"开发故事成功")
        return client.get_response_text(response)
    except APIError as e:
        logger.error(f"API错误: {e}")
        raise e


async def develop_story_base_on_story(
    client: AsyncArkClient,
    story: str, 
    user_requirement: Optional[str] = None
) -> Dict:
    user_message = ArkMessage(role="user")
    user_message.add_text(human_prompt_write_script_on_story.format(story=story, user_requirement=user_requirement))
    try:
        response = await client.chat(
            model="doubao-seed-1-6-251015",
            messages=[user_message],
            system_prompt=system_prompt_write_script_on_story,
        )
        logger.info(f"基于故事开发剧本成功")
        script = client.get_response_text(response)
        script = io_handler.string_to_json(script)
        return script
    except APIError as e:
        logger.error(f"API错误: {e}")
        raise e

if __name__ == "__main__":
    async def main():
        async with AsyncArkClient() as client:
            story = await develop_story(
                client=client,
                idea="一个程序员发现自己创造的AI有了独立意识", 
                user_requirement="科幻、短片、5个场景"
            )
            print(story)
            story_script = await develop_story_base_on_story(
                client=client,
                story=story, 
                user_requirement="科幻、短片、5个场景"
            )
            print(story_script)
            io_handler.write_json(story_script, "./output/story_script.json")
    
    asyncio.run(main())