新增营地插件, 可以售出战斗用品

.tasks/2025-11-10_1_backpack.md

@@ -20,7 +20,7 @@ PWF 插件框架下的 `WPSBackpackSystem` 负责物品注册、存取与跨插
 2. 调整战斗、菜园、炼金等插件的物品注册逻辑，补添加描述文本及系统售卖数据。  
 3. 实现 `WPSItemDescription` 插件，解析“查看”指令并输出物品基础信息、描述与系统售价。
 
-## 当前执行步骤:"4. 实现详情指令"
+## 当前执行步骤:"5. 实现营地售出"
 
 ## 任务进度
 2025-11-10_22:17:07
@@ -29,6 +29,12 @@ PWF 插件框架下的 `WPSBackpackSystem` 负责物品注册、存取与跨插
 - 原因: 支持物品详情查询并展示描述及出售信息
 - 阻碍因素: 无
 - 状态: 未确认
+2025-11-10_22:47:14
+- 已修改: Plugins/WPSCombatSystem/combat_plugin_camp.py Plugins/WPSCombatSystem/__init__.py
+- 更改: 新增营地售出插件，支持战斗纪念品系统回收指令
+- 原因: 提供“营地 售出”与菜园一致的出售体验
+- 阻碍因素: 无
+- 状态: 未确认
 
 ## 最终审查
 

Plugins/WPSCombatSystem/__init__.py

@@ -15,6 +15,7 @@ from .combat_plugin_equipment import WPSCombatEquipment
 from .combat_plugin_adventure import WPSCombatAdventure, WPSCombatAdventureAbort
 from .combat_plugin_battle import WPSCombatBattle
 from .combat_plugin_heal import WPSCombatHeal
+from .combat_plugin_camp import WPSCombatCamp
 
 __all__ = [
     "EquipmentDefinition",
@@ -31,5 +32,6 @@ __all__ = [
     "WPSCombatAdventureAbort",
     "WPSCombatBattle",
     "WPSCombatHeal",
+    "WPSCombatCamp",
 ]
 

Plugins/WPSCombatSystem/combat_plugin_camp.py

@@ -0,0 +1,149 @@
+"""营地售出插件 - 处理战斗纪念品回收"""
+
+from __future__ import annotations
+
+from typing import Optional
+
+from PWF.Convention.Runtime.Architecture import Architecture
+from PWF.Convention.Runtime.GlobalConfig import ConsoleFrontColor, ProjectConfig
+
+from Plugins.WPSBackpackSystem import WPSBackpackSystem
+from Plugins.WPSConfigSystem import WPSConfigAPI
+
+from .combat_models import ADVENTURE_SOUVENIRS
+from .combat_plugin_base import WPSCombatBase
+
+
+logger: ProjectConfig = ProjectConfig()
+
+
+class WPSCombatCamp(WPSCombatBase):
+    """营地售出指令插件"""
+
+    def __init__(self) -> None:
+        super().__init__()
+        self._souvenir_by_id = ADVENTURE_SOUVENIRS
+        self._souvenir_name_index = {
+            meta[0].lower(): item_id for item_id, meta in self._souvenir_by_id.items()
+        }
+
+    def is_enable_plugin(self) -> bool:
+        return True
+
+    def wake_up(self) -> None:
+        super().wake_up()
+        logger.Log(
+            "Info",
+            f"{ConsoleFrontColor.GREEN}WPSCombatCamp 插件已加载{ConsoleFrontColor.RESET}",
+        )
+        self.register_plugin("营地")
+        self.register_plugin("camp")
+
+    async def callback(self, message: str, chat_id: int, user_id: int) -> Optional[str]:
+        payload = self.parse_message_after_at(message).strip()
+        if not payload:
+            return await self.send_markdown_message(
+                self._help_message(), chat_id, user_id
+            )
+
+        tokens = [token.strip() for token in payload.split() if token.strip()]
+        if not tokens:
+            return await self.send_markdown_message(
+                self._help_message(), chat_id, user_id
+            )
+
+        command = tokens[0].lower()
+        if command in {"售出", "sell"}:
+            return await self._handle_sell(tokens[1:], chat_id, user_id)
+
+        return await self.send_markdown_message(
+            self._help_message(), chat_id, user_id
+        )
+
+    async def _handle_sell(
+        self, args: list[str], chat_id: int, user_id: int
+    ) -> Optional[str]:
+        if len(args) < 2:
+            return await self.send_markdown_message(
+                "❌ 指令格式：`营地 售出 <物品> <数量>`",
+                chat_id,
+                user_id,
+            )
+
+        identifier = args[0]
+        try:
+            quantity = int(args[1])
+        except ValueError:
+            return await self.send_markdown_message("❌ 数量必须是整数", chat_id, user_id)
+        if quantity <= 0:
+            return await self.send_markdown_message("❌ 数量必须大于0", chat_id, user_id)
+
+        resolved = self._resolve_souvenir(identifier)
+        if not resolved:
+            return await self.send_markdown_message(
+                "❌ 未找到对应纪念品", chat_id, user_id
+            )
+
+        item_id, name, price_per = resolved
+
+        backpack: WPSBackpackSystem = Architecture.Get(WPSBackpackSystem)
+        owned = 0
+        for item in backpack.get_user_items(user_id):
+            if item.item_id == item_id:
+                owned = item.quantity
+                break
+        if owned < quantity:
+            return await self.send_markdown_message(
+                "❌ 纪念品数量不足", chat_id, user_id
+            )
+
+        backpack.set_item_quantity(user_id, item_id, owned - quantity)
+        total_points = price_per * quantity
+
+        config_api: WPSConfigAPI = Architecture.Get(WPSConfigAPI)
+        new_points = await config_api.adjust_user_points(
+            chat_id,
+            user_id,
+            total_points,
+            reason=f"出售 {name}",
+        )
+
+        message = (
+            "# 🛒 售出成功\n"
+            f"- 纪念品：{name} × {quantity}\n"
+            f"- 单价：{price_per} 分\n"
+            f"- 总计：{total_points} 分\n"
+            f"- 当前积分：{new_points}"
+        )
+        return await self.send_markdown_message(message, chat_id, user_id)
+
+    def _resolve_souvenir(
+        self, identifier: str
+    ) -> Optional[tuple[str, str, int]]:
+        key = identifier.strip()
+        lowered = key.lower()
+        if key in self._souvenir_by_id:
+            item_id = key
+        elif lowered in self._souvenir_by_id:
+            item_id = lowered
+        elif lowered in self._souvenir_name_index:
+            item_id = self._souvenir_name_index[lowered]
+        else:
+            return None
+
+        name, _tier, price, _desc = self._souvenir_by_id[item_id]
+        return item_id, name, price
+
+    def _help_message(self) -> str:
+        return (
+            "# 🏕️ 营地指令\n"
+            "- `营地 售出 <纪念品> <数量>`：将战斗纪念品出售给系统换取积分\n"
+            "\n"
+            "**示例：**\n"
+            "- `营地 售出 战斗奖杯 1`\n"
+            "- `camp sell combat_souvenir_medal 3`\n"
+        )
+
+
+__all__ = ["WPSCombatCamp"]
+