Upload 4 files

state_manager.py

@@ -18,6 +18,7 @@ from __future__ import annotations
 
 import copy
 import logging
+import re
 from typing import Any, Optional
 from pydantic import BaseModel, Field
 
@@ -491,10 +492,78 @@ class GameState:
                 rest_available=True,
                 ambient_description="溪水潺潺流淌，偶有鸟鸣声在林间回荡，这里是森林中的一片安宁绿洲。",
             ),
+            # -------- 扩展地点 --------
+            "河边渡口": LocationInfo(
+                name="河边渡口",
+                location_type="wilderness",
+                description="一座破旧的木制渡口，宽阔的河流在此缓缓流淌。一艘半沉的渡船拴在码头桩上。",
+                connected_to=["村口小路", "废弃矿洞入口", "山麓盗贼营"],
+                npcs_present=["渡口老渔夫"],
+                danger_level=3,
+                is_discovered=False,
+                ambient_description="河水拍打着朽烂的木桩，远处有鹰在盘旋，对岸隐约可见矿洞的轮廓。",
+            ),
+            "废弃矿洞入口": LocationInfo(
+                name="废弃矿洞入口",
+                location_type="dungeon",
+                description="荒废多年的铁矿洞，入口被蛛网和碎石半堵。矿道里传来金属碰撞的回声。",
+                connected_to=["河边渡口", "矿洞深层"],
+                enemies=["骷髅兵", "矿洞蝙蝠群", "锈铁傀儡"],
+                danger_level=5,
+                is_discovered=False,
+                ambient_description="腐朽的矿车轨道延伸向黑暗深处，空气里弥漫着铁锈和硫磺的气味。",
+            ),
+            "矿洞深层": LocationInfo(
+                name="矿洞深层",
+                location_type="dungeon",
+                description="矿洞最深处，一个巨大的地下空间。墙壁上嵌着发光的矿石，中央有一座被遗忘的祭坛。",
+                connected_to=["废弃矿洞入口"],
+                enemies=["亡灵矿工", "岩石巨像"],
+                danger_level=8,
+                is_discovered=False,
+                is_accessible=False,
+                required_item="矿工旧钥匙",
+                ambient_description="发光矿石将洞穴映成幽蓝色，祭坛上刻着无人能读的文字，隐约有低沉的嗡鸣。",
+            ),
+            "山麓盗贼营": LocationInfo(
+                name="山麓盗贼营",
+                location_type="wilderness",
+                description="藏在山脚灌木丛后的盗贼据点，几顶破帐篷围着一堆余烬。看起来已被匆忙弃置。",
+                connected_to=["河边渡口", "精灵遗迹"],
+                enemies=["盗贼斥候", "盗贼头目"],
+                danger_level=5,
+                is_discovered=False,
+                ambient_description="地上散落着翻倒的酒桶和吃了一半的干粮，有人走得很匆忙。",
+            ),
+            "精灵遗迹": LocationInfo(
+                name="精灵遗迹",
+                location_type="special",
+                description="一片被藤蔓覆盖的古老石柱林，精灵文字在月光下隐约发光。空气中有淡淡的魔力涌动。",
+                connected_to=["山麓盗贼营"],
+                npcs_present=["遗迹守护者"],
+                danger_level=4,
+                is_discovered=False,
+                ambient_description="石柱上的符文随风明灭，仿佛在回应某种古老的感召。脚下的青苔异常柔软。",
+            ),
+            "古塔废墟": LocationInfo(
+                name="古塔废墟",
+                location_type="dungeon",
+                description="一座半坍塌的石塔，据说曾是某位法师的研究所。顶层似乎还有东西在闪烁。",
+                connected_to=["村口小路"],
+                enemies=["石像鬼", "游荡幽灵"],
+                danger_level=6,
+                is_discovered=False,
+                ambient_description="风从塔身的裂缝中呼啸而过，残破的阶梯上覆满了青苔和鸟粪。",
+            ),
         }
 
         self.world.discovered_locations = ["村庄广场", "村庄铁匠铺", "村庄旅店", "村庄杂货铺", "村口小路"]
 
+        # 扩展村口小路的连接 —— 链接到新区域
+        self.world.locations["村口小路"].connected_to = [
+            "村庄广场", "黑暗森林入口", "河边渡口", "古塔废墟",
+        ]
+
         # --- 初始 NPC ---
         self.world.npcs = {
             "村长老伯": NPCState(
@@ -569,6 +638,37 @@ class GameState:
                 schedule={"清晨": "村庄旅店", "夜晚": "村口小路"},
                 backstory="似乎在寻找什么。偶尔从斗篷下露出的手指上有奇异的魔法纹路。",
             ),
+            # -------- 扩展 NPC --------
+            "渡口老渔夫": NPCState(
+                name="渡口老渔���",
+                npc_type="quest_giver",
+                location="河边渡口",
+                attitude="friendly",
+                description="一个皮肤黝黑、满脸皱纹的老人，正坐在码头上修补渔网。",
+                race="人类",
+                occupation="渔夫",
+                relationship_level=5,
+                can_give_quest=True,
+                available_quests=["side_quest_02"],
+                memory=[],
+                schedule={"清晨": "河边渡口", "正午": "河边渡口", "夜晚": "村庄旅店"},
+                backstory="在这条河边住了四十年，对河流两岸的地形了如指掌。最近总念叨对岸矿洞里的怪响。",
+            ),
+            "遗迹守护者": NPCState(
+                name="遗迹守护者",
+                npc_type="quest_giver",
+                location="精灵遗迹",
+                attitude="cautious",
+                description="一个身形消瘦的半精灵，穿着褪色的绿袍，眼神中有深深的疲惫。",
+                race="半精灵",
+                occupation="守护者",
+                relationship_level=-5,
+                can_give_quest=True,
+                available_quests=["side_quest_03"],
+                memory=[],
+                schedule={"清晨": "精灵遗迹", "正午": "精灵遗迹", "夜晚": "精灵遗迹"},
+                backstory="最后一位遗迹守护者，独自守护这片先祖的圣地已有三十年。对外来者充满警惕，但内心渴望帮助。",
+            ),
         }
 
         # --- 初始任务 ---
@@ -612,6 +712,46 @@ class GameState:
                 ),
                 prerequisites=[],
             ),
+            # -------- 扩展任务 --------
+            "side_quest_02": QuestState(
+                quest_id="side_quest_02",
+                title="河底的秘密",
+                description="渡口老渔夫说他最近总在河里捞到奇怪的骨头，而且对岸矿洞方向夜里总是有光。他请你去查明真相。",
+                quest_type="side",
+                status="active",
+                giver_npc="渡口老渔夫",
+                objectives={
+                    "与渡口老渔夫交谈": False,
+                    "前往废弃矿洞调查": False,
+                    "找到矿洞异常的原因": False,
+                },
+                rewards=QuestRewards(
+                    gold=60,
+                    experience=40,
+                    items=["矿工旧钥匙"],
+                    reputation_changes={"村庄": 10},
+                ),
+                prerequisites=[],
+            ),
+            "side_quest_03": QuestState(
+                quest_id="side_quest_03",
+                title="守护者的试炼",
+                description="精灵遗迹的守护者提出一个交换条件：通过她设下的试炼，就能获得古老的精灵祝福。",
+                quest_type="side",
+                status="active",
+                giver_npc="遗迹守护者",
+                objectives={
+                    "与遗迹守护者交谈": False,
+                    "通过守护者的试炼": False,
+                },
+                rewards=QuestRewards(
+                    experience=50,
+                    unlock_skill="精灵祝福",
+                    karma_change=10,
+                    title="遗迹认可者",
+                ),
+                prerequisites=[],
+            ),
         }
 
         # --- 初始物品注册表 ---
@@ -630,6 +770,14 @@ class GameState:
             "地图碎片": ItemInfo(name="地图碎片", item_type="quest_item", description="一片残破的地图，标记着森林深处的某个位置。", quest_related=True, value=0, lore_text="这张地图似乎非常古老，纸张已经泛黄，但上面的墨迹依然清晰。"),
             "森林之钥": ItemInfo(name="森林之钥", item_type="key", description="一把散发着微弱绿光的古老钥匙，似乎能打开森林深处的某个入口。", rarity="rare", quest_related=True, value=0, lore_text="钥匙上刻着精灵文字，翻译过来是：'唯有勇者可通行'。"),
             "神秘卷轴": ItemInfo(name="神秘卷轴", item_type="quest_item", description="记载着古老知识的卷轴，散发着微弱的魔力波动。", rarity="rare", quest_related=True, value=0),
+            # -------- 扩展物品 --------
+            "矿工旧钥匙": ItemInfo(name="矿工旧钥匙", item_type="key", description="一把生锈的铜钥匙，上面刻着一个矿镐图案。", rarity="uncommon", quest_related=True, value=0, lore_text="钥匙柄上隐约可见'B-7采掘区'的刻字。"),
+            "骷髅碎骨": ItemInfo(name="骷髅碎骨", item_type="material", description="从骷髅兵身上掉落的骨头碎片，泛着不自然的寒光。", rarity="common", value=5),
+            "盗贼日志": ItemInfo(name="盗贼日志", item_type="quest_item", description="一本沾满泥渍的笔记本，记录着盗贼团伙近期的行动计划。", rarity="uncommon", quest_related=True, value=0),
+            "精灵护符": ItemInfo(name="精灵护符", item_type="accessory", description="由精灵遗迹守护者亲手制作的小型护符，散发着柔和的绿色微光。", rarity="rare", stat_bonus={"perception": 3, "sanity": 5}, value=50, lore_text="佩戴者能感受到来自远古精灵的庇佑。"),
+            "锈蚀铁锤": ItemInfo(name="锈蚀铁锤", item_type="weapon", description="矿洞里发现的旧铁锤，虽然锈迹斑斑但依然沉重有力。", rarity="common", stat_bonus={"attack": 4}, value=15),
+            "荧光苔藓": ItemInfo(name="荧光苔藓", item_type="consumable", description="矿洞深处生长的发光苔藓，据说有微弱的疗伤效果。", usable=True, use_effect="恢复 15 HP，恢复 5 理智", rarity="uncommon", value=12),
+            "古塔法师笔记": ItemInfo(name="古塔法师笔记", item_type="quest_item", description="在古塔废墟中找到的残破笔记，记载着某种仪式的片段。", rarity="rare", quest_related=True, value=0, lore_text="字迹已经模糊，但仍能辨认出几个关键的魔法符号。"),
         }
 
         # --- 初始传闻 ---
@@ -637,8 +785,25 @@ class GameState:
             "最近森林里的哥布林越来越嚣张了，好几个猎人都不敢进去了。",
             "听说铁匠格林以前在王都待过，不知道为什么来了这个小村子。",
             "旅店里来了个奇怪的旅人，整天把自己裹得严严实实的。",
+            "河对岸的旧矿洞晚上闹鬼，渡口的老渔夫说他亲眼看见过蓝色的火光。",
+            "山脚下好像有一伙盗贼扎了营，最近有商队被劫的消息。",
+            "村子东边的古塔里据说住过一个法师，后来不知为何法师消失了，塔也荒废了。",
+            "有人在精灵遗迹附近见到过一个穿绿袍的身影，不知是人是鬼。",
         ]
 
+        # --- 随机事件候选池 ---
+        self.random_event_pool: list[str] = [
+            "一个受伤的旅行商人跌跌撞撞地出现在你面前，他的货物散落一地。",
+            "天空忽然暗了下来，远处传来隐约的雷声，一场暴雨似乎即将来临。",
+            "你注意到路边有一个被藤蔓遮住的旧箱子，看起来已经放了很久。",
+            "一只受伤的猎鹰坠落在你脚边，它的腿上绑着一小卷羊皮纸。",
+            "远处传来激烈的打斗声，似乎有人遭到了伏击。",
+            "一个衣衫褴褛的流浪汉向你走来，自称知道附近藏宝的秘密。",
+            "你经过的路上发现了一串新鲜的、不属于任何已知生物的巨大脚印。",
+            "一阵古怪的风带来了焦糊的味道，顺着风向看去，远处有一缕黑烟升起。",
+        ]
+        self.pending_random_event: str | None = None  # 本回合触发的随机事件
+
         # --- 玩家初始装备 ---
         self.player.inventory = ["面包", "面包", "小型治疗药水"]
 
@@ -1111,7 +1276,18 @@ class GameState:
         if self.world.rumors:
             rumors_desc = "\n【流传的传闻】\n" + "\n".join(f"  - {r}" for r in self.world.rumors[-3:])
 
-        # 8. 一致性约束指令
+        # 8. 随机事件
+        random_event_desc = ""
+        if getattr(self, 'pending_random_event', None):
+            random_event_desc = (
+                f"\n【本回合随机事件 —— 必须融入本次叙事】\n"
+                f"{self.pending_random_event}\n"
+                f"请将此事件自然地融入剧情描写中，作为额外的意外插曲。"
+                f"玩家可以选择回应或忽视此事件。至少一个选项应与此事件相关。"
+            )
+            self.pending_random_event = None  # 用后清除
+
+        # 9. 一致性约束指令
         consistency_rules = (
             "\n【一致性约束 —— 你必须严格遵守】\n"
             "1. 已死亡的NPC不可再出现或对话（除非有特殊复活剧情）。\n"
@@ -1145,6 +1321,7 @@ class GameState:
             move_desc,
             event_desc,
             rumors_desc,
+            random_event_desc,
             consistency_rules,
         ])
 
@@ -1248,6 +1425,103 @@ class GameState:
 
         return contradictions
 
+    def pre_validate_action(self, intent: dict) -> tuple[bool, str]:
+        """
+        预校验玩家意图的合法性（在 LLM 调用前立即拦截非法操作）。
+
+        设计思路：
+        - 在任何 API 调用之前就检测明显违反一致性的操作
+        - 不合法时立即驳回，避免浪费 API 调用和回合
+        - 检测维度：物品是否在背包/装备中、技能是否已习得、
+          raw_input 中是否提及使用不存在的物品
+
+        Returns:
+            (is_valid, rejection_reason): 合法返回 (True, ""), 否则返回 (False, "拒绝原因")
+        """
+        action = intent.get("intent", "")
+        target = intent.get("target", "") or ""
+        details = intent.get("details", "") or ""
+        raw_input = intent.get("raw_input", "") or ""
+
+        inventory = list(self.player.inventory)
+        equipped_items = [v for v in self.player.equipment.values() if v]
+        all_owned = set(inventory) | set(equipped_items)
+
+        # --- 检测 1: USE_ITEM / EQUIP: target 必须在背包或装备中 ---
+        if action in ("USE_ITEM", "EQUIP") and target:
+            if target not in all_owned:
+                return False, f"你的背包中没有「{target}」，无法使用或装备。"
+            if action == "EQUIP" and target not in inventory:
+                if target in equipped_items:
+                    return False, f"「{target}」已经装备在身上了。"
+                return False, f"你的背包中没有「{target}」，无法装备。"
+
+        # --- 检测 2: SKILL: 必须已习得 ---
+        if action == "SKILL" and target:
+            if target not in self.player.skills:
+                return False, f"你尚未习得技能「{target}」。"
+
+        # --- 检测 3: 扫描 raw_input 中是否在使用上下文中引用了未拥有的已知物品 ---
+        known_items: set[str] = set(self.world.item_registry.keys())
+        for event in self.event_log:
+            sc = event.state_changes
+            if isinstance(sc, dict):
+                for item in sc.get("items_gained", []):
+                    known_items.add(str(item))
+                for item in sc.get("items_lost", []):
+                    known_items.add(str(item))
+
+        unavailable_known = {
+            item for item in known_items
+            if item not in all_owned and len(item) >= 2
+        }
+
+        use_verbs = [
+            "使用", "用", "吃", "喝", "装备", "穿上", "戴上",
+            "拿出", "掏出", "挥舞", "举起", "服用", "食用", "拔出", "拿起",
+        ]
+
+        for item_name in unavailable_known:
+            if item_name not in raw_input:
+                continue
+            for verb in use_verbs:
+                if verb + item_name in raw_input:
+                    return False, f"你的背包中没有「{item_name}」，无法{verb}。"
+
+        # --- 检测 4: 检查 raw_input 中是否提及使用完全未知的物品 ---
+        # 匹配常见的"使用物品"语句模式，提取物品名称并校验
+        extraction_patterns = [
+            (r'(?:掏出|拿出|拔出|举起)(.{2,8}?)(?:$|[，。！？,\s来])', "使用"),
+            (r'吃(?:一个|一块|一份|了个|了一个)?(.{2,8}?)(?:$|[，。！？,\s来])', "吃"),
+            (r'喝(?:一瓶|一杯|一口|了一瓶|了)?(.{2,8}?)(?:$|[，。！？,\s来])', "喝"),
+            (r'用(.{2,6}?)(?:打|攻击|砍|刺|射|劈|挡|切|割)', "使用"),
+        ]
+
+        non_item_words = {
+            "拳头", "双手", "手", "脚", "头", "身体",
+            "魔法", "技能", "力量", "勇气", "智慧",
+            "办法", "方法", "速度", "周围", "四周",
+        }
+
+        full_text = raw_input + " " + details
+
+        for pattern, verb_desc in extraction_patterns:
+            match = re.search(pattern, full_text)
+            if match:
+                mentioned = match.group(1).strip()
+                if not mentioned or mentioned in non_item_words:
+                    continue
+                if mentioned not in all_owned:
+                    # 模糊匹配："剑" 可能是 "铁剑" 的简称
+                    fuzzy_match = any(
+                        mentioned in owned or owned in mentioned
+                        for owned in all_owned
+                    )
+                    if not fuzzy_match:
+                        return False, f"你并没有「{mentioned}」，请检查你的背包。"
+
+        return True, ""
+
     def is_game_over(self) -> bool:
         """
         判断游戏是否结束。
@@ -1319,6 +1593,9 @@ class GameState:
         # 更新 NPC 位置（根据时间表）
         self._update_npc_schedules()
 
+        # 随机事件（约 25% 概率触发）
+        self._roll_random_event()
+
         return tick_log
 
     def _apply_status_effects(self) -> list[str]:
@@ -1385,6 +1662,15 @@ class GameState:
 
         return effect_log
 
+    def _roll_random_event(self):
+        """以一定概率从事件池中抽取一个随机事件，注入到下一次 Prompt 中"""
+        import random
+        self.pending_random_event = None
+        if self.random_event_pool and random.random() < 0.25:
+            event = random.choice(self.random_event_pool)
+            self.pending_random_event = event
+            logger.info(f"随机事件触发: {event}")
+
     def _check_quest_deadlines(self):
         """检查限时任务是否过期"""
         for quest in self.world.quests.values():

story_engine.py

@@ -367,6 +367,13 @@ MERGED_SYSTEM_PROMPT_TEMPLATE = """【最高优先级指令 ── 输出格式
 - 战斗场景要紧张刺激
 - 货币统一称"金币"
 
+【剧情多样性规则 ── 极其重要】
+- 禁止连续两个回合出现相同类型的敌人（如上回合打了哥布林，本回合不能再打哥布林）
+- 连续战斗不得超过 2 个回合，之后必须穿插非战斗事件（对话/探索/发现/交易）
+- 鼓励引入新NPC、新线索、支线事件，让世界有"活"的感觉
+- 如果世界状态中标注了【本回合随机事件】，必须将其融入叙事
+- 尽量引导玩家前往不同的区域探索，而非反复停留在同一地点
+
 【选项规则】
 - 恰好 3 个选项，覆盖不同策略方向（激进/谨慎/探索/社交等）
 - 选项中的人物/物品/地点必须已在当前或之前剧情中出现过
@@ -532,6 +539,10 @@ class StoryEngine:
             # 再次检查
             consistency_issues = self.game_state.check_consistency(state_changes)
 
+        # 移除与非法物品相关的状态变更（安全网）
+        if consistency_issues:
+            state_changes = self._strip_invalid_item_effects(state_changes)
+
         # ============================================
         # 清理状态变更：阻止非消耗品被错误移除
         # ============================================
@@ -1007,6 +1018,51 @@ class StoryEngine:
 
         return changes, warnings
 
+    def _strip_invalid_item_effects(self, state_changes: dict) -> dict:
+        """
+        当 LLM 生成了涉及不存在物品的状态变更时，移除相关效果（安全网）。
+
+        例如：LLM 生成了"吃了包子" → hunger_change: +10, items_lost: ["包子"]，
+        但包子不在背包中。此方法移除 items_lost 和相关的属性效果。
+        """
+        changes = dict(state_changes)
+
+        if "items_lost" not in changes:
+            return changes
+
+        items_gained = {str(i) for i in changes.get("items_gained", [])}
+        invalid_count = 0
+        valid_items_lost = []
+
+        for item in changes["items_lost"]:
+            item_str = str(item)
+            # 同回合获得的物品可以立即消耗（如拾取后使用）
+            if item_str in items_gained:
+                valid_items_lost.append(item)
+                continue
+            if item_str in self.game_state.player.inventory:
+                valid_items_lost.append(item)
+            else:
+                invalid_count += 1
+                logger.warning(f"[安全网] 阻止消耗不存在的物品「{item_str}」")
+
+        if invalid_count > 0:
+            if valid_items_lost:
+                changes["items_lost"] = valid_items_lost
+            else:
+                changes.pop("items_lost", None)
+                # 所有 items_lost 都无效 → 属性变更可能全部源于非法物品使用
+                for key in ["hunger_change", "hp_change", "mp_change",
+                            "morale_change", "sanity_change"]:
+                    if key in changes:
+                        logger.warning(f"[安全网] 因物品不合法，阻止 {key}: {changes[key]}")
+                        changes.pop(key)
+                if "status_effects_added" in changes:
+                    logger.warning("[安全网] 因物品不合法，阻止状态效果添加")
+                    changes.pop("status_effects_added")
+
+        return changes
+
     def _validate_options(self, options: list[dict]) -> list[dict]:
         """
         验证生成的选项：移除引用了玩家不拥有的物品的选项。
@@ -1315,6 +1371,8 @@ class StoryEngine:
 
         if consistency_issues:
             logger.warning(f"发现一致性问题: {consistency_issues}")
+            # 移除与非法物品相关的状态变更（安全网）
+            state_changes = self._strip_invalid_item_effects(state_changes)
 
         # 清理状态变更
         event_type = outline.get("event_type", "")