停止机（Hard Stop）功能半实现，需前后端协同完善以支持船舱/战利品/目标船掉落即时停止

[syokounya]

Validations

• 我已经阅读了 用户文档 并尝试自己解决问题，同时在社群中进行了讨论
• 我无法找到任何 open issue 提出了相同的建议

问题描述

当前停止机（Hard Stop）功能处于半实现状态。前端已有 StopCondition 框架和日志解析触发的 taskStop() 调用，但后端的单轮战斗流程内部并没有被 stop 信号真正穿透，导致停止行为只能达到**「轮次级」（即等当前这一整轮 run_normal_fight(times=1) 跑完才能停下），而非「秒级」**（类似 Ctrl+C 在下一个安全检查点立即退出）。

具体表现：

• 当船舱接近 500、胖次接近 50，或已经捞到目标船时，如果当前轮次刚好进入 run_combat 状态机，即使点击停止或条件已触发，也必须等整场战斗（包括地图导航、出征准备、多节点战斗、结算动画）全部结束后才能停；
• 对于只想「捞到某艘船就停」的场景，目前 StopCondition 完全缺失 target_ship_dropped 字段，没有任何自动停止手段；
• 后端 DailyAutomationConfig 中存在 stop_max_ship / stop_max_loot 两个声明了但未被任何代码读取的死字段，属于未落地的配置残留。

另外，现有 taskStop() 的语义偏向「强制终止当前任务线程」，停止后任务虽然会标记为 STOPPED，但：

• 前端 stopRunning() 会把任务恢复为未执行状态并塞回队列；
• 后端 executor 只是在 for 循环开头检查 should_stop()，状态机内部（如长时间 OCR 等待、点击重试、地图导航）完全不检查 ctx.stop_event；
• 这种设计使得「立即停止」与「优雅恢复」之间存在张力：要么等很久才停，要么强行中断后前后端状态可能不一致。

解决方案

建议将停止机升级为前后端协同的安全检查点机制，核心目标：

1. 在战斗流程内部增加可安全退出的检查点（如出征准备页、战斗节点间、结算页），实现秒级响应；
2. 停止后不影响后端进程和后续任务队列，无需用户手动重启后端；
3. 补齐目标船掉落停止条件，并统一前后端配置入口。

1. 扩展 StopCondition 语义

在前后端统一的停止条件定义中增加：

• ship_count_ge: int — 舰船获取数达到即停；
• loot_count_ge: int — 战利品达到即停（已半实现，需后端兜底）；
• target_ship_dropped: list[str] — 掉落指定舰船即停（新增）；
• （可选）stop_after_map_count: int — 完成 N 张地图后停止。

2. 后端在战斗流程中嵌入安全检查点

NormalFightRunner（及 EventFightRunner 等）在以下节点主动检查停止条件：

• 出征前（_enter_fight 读取面板数量后）：若已触及上限，直接返回一个 STOP_CONDITION_MET 标志的 CombatResult，该轮不再进入战斗；
• 战斗节点间 / 结算后：若检测到目标船掉落或数量达标，立即标记本轮结果为停止条件触发；
• 状态机空闲期：在 combat.engine 的页面跳转、等待动画、OCR 轮询等非原子操作间隙，检查 ctx.stop_event.is_set()，安全退出当前轮次。

3. 统一停止后的行为语义

• 当停止条件触发或被用户手动停止时，当前任务应被标记为已完成但提前终止（stopped / condition_met），而不是失败；
• TaskScheduler / task.py 的各 executor 应识别该状态，不再重试、不再塞回队列，而是正常进入 handleTaskFinished 的后续流程；
• 后端进程保持存活，队列中其他任务（如远征、日常）仍可继续执行。

4. 清理并暴露配置入口

• 移除或激活 DailyAutomationConfig 中的 stop_max_ship / stop_max_loot 死字段（建议映射为全局默认 StopCondition，或直接删除避免误导）；
• 在前端 Plan / Preset 编辑器中增加「停止条件」配置项，将条件随 TaskRequest 下发到后端；
• 后端 CombatPlan.from_yaml() / from_dict() 支持读取 stop_condition 字段，runner 直接消费，不再完全依赖前端日志解析作为触发源。

通过以上改造，停止机可以从「轮次结束后才能停」升级为「在下一个安全检查点立刻停」，同时保证停止是可恢复、可继续的，不会导致后端进程异常或必须手动重启。

[github-actions]

Issue 概要

• issue：#431（停止机（Hard Stop）功能半实现，需前后端协同完善以支持船舱/战利品/目标船掉落即时停止 #431）
• 版本 / 分支 / 环境：issue 未提供具体版本与平台；代码对照基线为当前 main 的 2ee2aa0f14acffe0babf851bccf115a64a131eb4
• 任务 / 入口 / 相关设置：任务启动/停止走 /api/task/start、/api/task/stop；现有可观测计数是“今日舰船数/战利品数”
• 关键提示 / 报错文案：无明确报错，核心是“停止条件能力缺失 + 停止时机不够可控”
• 用户现象：希望支持“船/战利品达到阈值即停、目标舰船掉落即停、并尽量即时中断”

附件概览

• 实际可读文件：仅 issue 正文 + 1 条机器人评论（AI 分析任务启动通知）
• 缺失或未上传的证据：运行时日志、前端日志、配置导出、复现截图/录屏、崩溃转储

关键证据

点击此处展开

• issue 正文 / 评论：
  • 当前 issue 为功能诉求，未附复现日志；评论仅为 GitHub Action “正在分析”通知。
• 运行时日志：
  • 仓库内能确认出征面板会记录 "[UI] 战利品数量" / "[UI] 舰船数量" 日志：

    AutoWSGR/autowsgr/ui/map/panels/sortie.py

    Lines 115 to 142 in 2ee2aa0

    	_log.warning('[UI] 战利品数量 OCR 无结果')
    	return None
    	count = _parse_numerator(text, LOOT_MAX)
    	if count > 50 and str(count).endswith('1'):
    	count = int(str(count)[:-1]) # 可能 OCR 把 "/50" 识别成 "150"
    	if count is not None:
    	_log.info('[UI] 战利品数量: {}/{}', count, LOOT_MAX)
    	else:
    	_log.warning("[UI] 战利品数量 OCR 解析失败: '{}'", text)
    	return count
    	def recognize_ship_count(screen: np.ndarray, ocr: EasyOCREngine) -> int | None:
    	"""识别出征面板舰船已获取数量。
    	OCR ``X/500`` 区域并提取 ``/`` 前的数字, 上限固定为 500。
    	"""
    	img = PixelChecker.crop(screen, *SHIP_COUNT_CROP)
    	text = ocr.recognize_single(img, allowlist=_OCR_ALLOWLIST).text.strip()
    	if not text:
    	_log.warning('[UI] 舰船数量 OCR 无结果')
    	return None
    	count = _parse_numerator(text, SHIP_MAX)
    	if count is not None:
    	_log.info('[UI] 舰船数量: {}/{}', count, SHIP_MAX)
    	else:
    	_log.warning("[UI] 舰船数量 OCR 解析失败: '{}'", text)
    	return count

• UI / 服务日志：
  • task_stop 触发后，路由层确实设置了 ctx.stop_event，但轮次循环仍以 task_manager.should_stop() 为关口：

    AutoWSGR/autowsgr/server/routes/task.py

    Lines 47 to 48 in 2ee2aa0

    	ctx.stop_event = task_manager._stop_event

    、

    AutoWSGR/autowsgr/server/routes/task.py

    Lines 116 to 131 in 2ee2aa0

    	for i in range(request.times):
    	if task_manager.should_stop():
    	break
    	task_manager.update_progress(current_round=i + 1)
    	_log.info('[Task] 常规战第 {}/{} 轮', i + 1, request.times)
    	try:
    	result = run_normal_fight(
    	ctx,
    	plan,
    	times=1,
    	fleet_id=override_fleet_id,
    	fleet=override_fleet,
    	fleet_rules=override_fleet_rules,
    	)[0]

  • 战斗内并非“完全不检查停止信号”：识别循环里已有 stop_event.is_set()：

    AutoWSGR/autowsgr/combat/recognizer.py

    Lines 287 to 291 in 2ee2aa0

    	while time.time() < deadline:
    	# 检查停止信号
    	if self._ctx.stop_event.is_set():
    	raise CombatStopRequested('任务被用户停止')

  • 但该检查点目前仅出现在 CombatRecognizer.wait_for_phase，未覆盖所有长耗时步骤：

    AutoWSGR/autowsgr/combat/recognizer.py

    Lines 244 to 307 in 2ee2aa0

    	def wait_for_phase(
    	self,
    	candidates: list[CombatPhase],
    	*,
    	poll_action: Callable[[np.ndarray], None] | None = None,
    	) -> CombatPhase:
    	"""等待候选状态之一出现。
    	轮询截图并匹配，直到匹配到其中一个候选状态或超时。
    	Parameters
    	----------
    	candidates:
    	候选状态列表。
    	poll_action:
    	每轮匹配前执行的动作（如点击加速、节点追踪等）。
    	Returns
    	-------
    	CombatPhase
    	匹配到的状态。
    	Raises
    	------
    	CombatRecognitionTimeout
    	所有候选状态均未在超时内匹配到。
    	"""
    	# 构建签名列表并计算总超时
    	max_timeout = 0.0
    	phase_sigs: list[tuple[CombatPhase, PhaseSignature]] = []
    	for phase in candidates:
    	sig = self.get_signature(phase)
    	max_timeout = max(max_timeout, sig.default_timeout)
    	phase_sigs.append((phase, sig))
    	deadline = time.time() + max_timeout
    	_log.debug(
    	'[Combat] 等待状态: {} (超时 {:.1f}s)',
    	[p.name for p, _ in phase_sigs],
    	max_timeout,
    	)
    	while time.time() < deadline:
    	# 检查停止信号
    	if self._ctx.stop_event.is_set():
    	raise CombatStopRequested('任务被用户停止')
    	screen = self._device.screenshot()
    	if poll_action is not None:
    	poll_action(screen)
    	for phase, sig in phase_sigs:
    	if sig.template_key is None and sig.pixel_signature is None:
    	continue
    	if self._match_phase(screen, sig):
    	if sig.after_match_delay > 0:
    	time.sleep(sig.after_match_delay)
    	_log.debug('[Combat] 匹配到状态: {}', phase.name)
    	return phase
    	# 超时
    	phase_names = [p.name for p, _ in phase_sigs]
    	raise CombatRecognitionTimeout(f'等待状态超时 ({max_timeout:.1f}s): {phase_names}')

• 配置快照：
  • stop_max_ship / stop_max_loot 仅定义未被消费（代码搜索无读取点）：

    AutoWSGR/autowsgr/infra/config.py

    Lines 205 to 208 in 2ee2aa0

    	stop_max_ship: bool = False
    	"""获取当天上限 500 船后终止"""
    	stop_max_loot: bool = False
    	"""获取当天上限 50 胖次后终止"""

• 现场图 / 转储：
  • 无附件，无法建立“某次失败复现”的时序证据链。
• 代码依据：
  • 任务请求模型无 stop_condition / target_ship_dropped 等字段：

    AutoWSGR/autowsgr/server/schemas.py

    Lines 98 to 167 in 2ee2aa0

    	class CombatPlanRequest(BaseModel):
    	"""作战计划请求体。"""
    	name: str = Field(default='', description='计划名称')
    	mode: str = Field(default='normal', description='战斗模式')
    	chapter: int | str = Field(default=1, description='章节号')
    	map: int | str = Field(default=1, description='地图号')
    	fleet_id: int = Field(default=1, ge=1, le=6, description='舰队编号')
    	fleet: list[str] | None = Field(default=None, description='舰队成员')
    	fleet_rules: list[str | FleetRuleRequest] | None = Field(
    	default=None,
    	description='舰队槽位规则（字符串或候选规则）',
    	)
    	repair_mode: list[int] = Field(
    	default_factory=lambda: [2, 2, 2, 2, 2, 2],
    	description='修理策略 (6个位置)',
    	)
    	fight_condition: int = Field(default=4, ge=1, le=5, description='战况选择')
    	selected_nodes: list[str] = Field(
    	default_factory=list,
    	description='白名单节点',
    	)
    	node_defaults: NodeDecisionRequest = Field(
    	default_factory=NodeDecisionRequest,
    	description='默认节点决策',
    	)
    	node_args: dict[str, NodeDecisionRequest] = Field(
    	default_factory=dict,
    	description='各节点决策',
    	)
    	event_name: str | None = Field(default=None, description='活动名称')
    	model_config = {'extra': 'forbid'}
    	# ═══════════════════════════════════════════════════════════════════════════════
    	# 任务请求模型
    	# ═══════════════════════════════════════════════════════════════════════════════
    	class NormalFightRequest(BaseModel):
    	"""常规战请求。"""
    	type: Literal[TaskType.NORMAL_FIGHT] = TaskType.NORMAL_FIGHT
    	plan: CombatPlanRequest | None = Field(
    	default=None,
    	description='作战计划 (与 plan_id 二选一)',
    	)
    	plan_id: str | None = Field(
    	default=None,
    	description='计划名称或 YAML 文件路径',
    	)
    	times: int = Field(default=1, ge=1, description='执行次数')
    	gap: float = Field(default=0.0, ge=0, description='间隔时间(秒)')
    	model_config = {'extra': 'forbid'}
    	class EventFightRequest(BaseModel):
    	"""活动战请求。"""
    	type: Literal[TaskType.EVENT_FIGHT] = TaskType.EVENT_FIGHT
    	plan: CombatPlanRequest | None = Field(default=None)
    	plan_id: str | None = Field(default=None)
    	times: int = Field(default=1, ge=1)
    	gap: float = Field(default=0.0, ge=0)
    	fleet_id: int | None = Field(default=None, description='覆盖舰队')
    	model_config = {'extra': 'forbid'}

  • CombatPlan 无停止条件字段：

    AutoWSGR/autowsgr/combat/plan.py

    Lines 232 to 243 in 2ee2aa0

    	name: str = ''
    	mode: str = CombatMode.NORMAL
    	chapter: int | str = 1
    	map_id: int | str = 1
    	fleet_id: int = 1
    	fleet: list[str] | None = None
    	repair_mode: RepairMode | list[RepairMode] = RepairMode.severe_damage
    	fight_condition: FightCondition = FightCondition.aim
    	selected_nodes: list[str] = field(default_factory=list)
    	nodes: dict[str, NodeDecision] = field(default_factory=dict)
    	default_node: NodeDecision = field(default_factory=NodeDecision)
    	event_name: str | None = None

  • build_combat_plan 也未透传停止条件：

    AutoWSGR/autowsgr/server/serializers.py

    Lines 141 to 169 in 2ee2aa0

    	def build_combat_plan(request: Any) -> Any:
    	"""从请求构建 CombatPlan 对象。"""
    	from autowsgr.combat import CombatPlan, NodeDecision
    	from autowsgr.types import Formation, RepairMode
    	def _build_node_decision(node_req: Any) -> NodeDecision:
    	return NodeDecision(
    	formation=Formation(node_req.formation),
    	night=node_req.night,
    	proceed=node_req.proceed,
    	proceed_stop=[RepairMode(r) for r in node_req.proceed_stop],
    	detour=node_req.detour,
    	)
    	node_args = {k: _build_node_decision(v) for k, v in request.node_args.items()}
    	return CombatPlan(
    	name=request.name,
    	mode=request.mode,
    	chapter=request.chapter,
    	map_id=request.map,
    	fleet_id=request.fleet_id,
    	fleet=request.fleet,
    	repair_mode=[RepairMode(r) for r in request.repair_mode],
    	fight_condition=request.fight_condition,
    	selected_nodes=request.selected_nodes,
    	default_node=_build_node_decision(request.node_defaults),
    	nodes=node_args,
    	)

  • 掉落舰船信息在战斗历史里可提取（说明“掉落即停”有可复用数据源），但没有被 stop 策略消费：

    AutoWSGR/autowsgr/combat/history.py

    Lines 247 to 250 in 2ee2aa0

    	# 查找紧邻的 GET_SHIP 事件
    	if i + 1 < len(self.events) and self.events[i + 1].event_type == EventType.GET_SHIP:
    	fr.dropped_ship = self.events[i + 1].result
    	results.append(fr)

  • 上下文已有“今日掉落计数”累加能力，但无阈值停机决策层：

    AutoWSGR/autowsgr/context/game_context.py

    Lines 145 to 150 in 2ee2aa0

    	if loot_count is not None:
    	self.dropped_loot_count = loot_count
    	_log.debug('[Context] 今日战利品数: {}', loot_count)
    	if ship_acquired_count is not None:
    	self.dropped_ship_count = ship_acquired_count
    	_log.debug('[Context] 今日舰船数: {}', ship_acquired_count)

    、

    AutoWSGR/autowsgr/context/game_context.py

    Lines 201 to 205 in 2ee2aa0

    	fight_results = result.fight_results
    	new_drops = sum(1 for fr in fight_results if fr.dropped_ship)
    	if new_drops:
    	self.dropped_ship_count += new_drops
    	_log.info('[Context] 本次掉落 {} 艘, 今日累计 {}', new_drops, self.dropped_ship_count)

根因判断

• 直接结论：#431 的核心诉求成立，属于停止条件模型与执行链路缺失，不是单点 bug。当前后端已有计数与掉落识别能力，但没有统一的 stop condition 语义、请求透传、执行器判定与调度器响应闭环。
• 证据链：
  • “有数据源”已具备：出征面板 OCR、战斗掉落识别、上下文计数累加；
  • “有决策入口”缺失：请求模型/计划模型/runner/scheduler 都未承载 stop condition；
  • “死配置”存在：stop_max_ship / stop_max_loot 无消费。
• 当前主线是否可能已修复：部分已改善（战斗识别循环支持 stop_event），但“阈值停机 + 掉落即停 + 全链路一致性”仍未实现。

修复方案

1. 代码 / 配置 / 资源层修复
   在 schemas.CombatPlanRequest、CombatPlan、序列化构建链路新增统一 stop_condition（至少含 ship_count_ge、loot_count_ge、target_ship_dropped）；在 NormalFightRunner / EventFightRunner / TaskScheduler 引入统一 StopConditionEvaluator。
2. 需要补充的测试、日志或截图
   增加 API 模型校验测试、plan 构建透传测试、战斗后掉落命中即停测试、阈值边界测试（49→50、499→500）与 stop_event 响应延迟测试。
3. 如问题属于不支持场景，应如何限制入口或改进提示
   在 stop_condition 未配置或不受支持时，明确返回能力声明（API 字段校验错误/警告），避免“配置写了但实际无效”。

给用户的建议

• 用户现在可以直接尝试的动作：当前版本可继续使用“船坞满（DOCK_FULL）后停止”相关机制；若目标是“掉落某舰即停”，目前后端没有原生支持。
• 是否建议升级 / 重下完整包 / 重置配置 / 更换环境：该 issue 主要是能力缺口，不是安装损坏；优先等待功能落地版本。
• 是否有临时绕过方案：可将 times 设小并外层循环轮询 /api/game/context 的 dropped_ship_count / dropped_loot_count 做外部停机，但精度与实时性有限。

给修复 AI 的建议（可复制）

点击此处展开

现象：
用户希望任务在“舰船数/战利品数达到阈值”或“掉落目标舰船”时自动停止，但当前后端没有统一 stop_condition 执行链路。

关键证据：
1) 请求/计划模型无 stop_condition 字段（schemas.py / plan.py / serializers.py）
2) 掉落舰船信息已可在 CombatHistory 中提取（history.py）
3) stop_max_ship/stop_max_loot 为未消费死字段（config.py）
4) stop_event 仅在 CombatRecognizer.wait_for_phase 中检查（recognizer.py）

可能相关线索（待验证）：
可新增 StopCondition 数据结构 + StopConditionEvaluator，并在 _enter_fight（预检）和 sync_after_combat 后（后检）执行；命中后设置统一停止标志并让 TaskScheduler 按 DOCK_FULL 同级处理。

置信度

• 中高
• 还缺什么证据：缺少用户复现日志/截图，无法量化“即时停止延迟”在真实环境中的秒级表现。

---

点击此处展开分析过程

● skill(generic-issue-log-analysis)

● Get repo remote and HEAD info (shell)
  │ git --no-pager remote -v && git rev-parse HEAD && git branch --show-current
  └ 5 lines...

● Get issue details (MCP: github-mcp-server) · method: "get", owner: "OpenWSGR", repo: "AutoWSGR", …
  └ {"number":431,"title":"停止机（Hard
    Stop）功能半实现，需前后端协同完善以支持船舱/战利品/目标船掉落即时停止","body...

● Get issue details (MCP: github-mcp-server) · method: "get_comments", owner: "OpenWSGR", repo: "Au…
  └ [{"id":4238726753,"body":"🤖 **AI 正在分析该 Issue...**  \n\n感谢您的反馈！AI
    正在自动分析该问题，预...

● Get issue details (MCP: github-mcp-server) · method: "get_labels", owner: "OpenWSGR", repo: "Auto…
  └ {"labels":[],"totalCount":0}

● Search (grep)
  │ "StopCondition|stop_condition|loot_count_ge|ship_count_ge|target_ship_dropped|stop_max_ship|stop
  │ _max_loot|should_stop|stop_event|taskStop|DOCK_FULL"
  └ 62 lines found

● Search (glob)
  │ "**/*.{ts,tsx,js,vue,json,yaml,yml}"
  └ 314 files found

● Search (glob)
  │ "**/*.py"
  └ 224 files found

● Read task.py
  │ autowsgr/server/routes/task.py
  └ 335 lines read

● Read schemas.py
  │ autowsgr/server/schemas.py
  └ 296 lines read

● Read plan.py
  │ autowsgr/combat/plan.py
  └ 341 lines read

● Read config.py
  │ autowsgr/infra/config.py
  └ L170:250 (80 lines read)

● Read normal_fight.py
  │ autowsgr/ops/normal_fight.py
  └ 482 lines read

● Read recognizer.py
  │ autowsgr/combat/recognizer.py
  └ 341 lines read

● Read engine.py
  │ autowsgr/combat/engine.py
  └ 335 lines read

● Read scheduler.py
  │ autowsgr/scheduler/scheduler.py
  └ 300 lines read

● Read task_manager.py
  │ autowsgr/server/task_manager.py
  └ 270 lines read

● Read event_fight.py
  │ autowsgr/ops/event_fight.py
  └ 440 lines read

● Read serializers.py
  │ autowsgr/server/serializers.py
  └ 169 lines read

● Read history.py
  │ autowsgr/combat/history.py
  └ 301 lines read

● Read handlers.py
  │ autowsgr/combat/handlers.py
  └ 493 lines read

● Read sortie.py
  │ autowsgr/ui/map/panels/sortie.py
  └ 371 lines read

● Search (grep)
  │ "get_loot_and_ship_count|战利品数量|舰船数量|stop_condition|target_ship|dropped|drop|acquired|GE
  │ T_SHIP|stop_event" (autowsgr)
  └ 86 lines found

● Read game_context.py
  │ autowsgr/context/game_context.py
  └ 211 lines read

● Read game.py
  │ autowsgr/server/routes/game.py
  └ L1:170 (115 lines read)

● Search (grep)
  │ "def get_acquisition_counts|get_loot_and_ship_count" (autowsgr/ui/map)
  └ 2 lines found

● Read campaign.py
  │ autowsgr/ui/map/panels/campaign.py
  └ L120:230 (62 lines read)

● Search (grep)
  │ "stop_condition" (autowsgr/data)
  └ No matches found

● Search (grep)
  │ "target_ship_dropped|ship_count_ge|loot_count_ge|stop_after_map_count" (autowsgr)
  └ No matches found

● Search (grep)
  │ "stop_max_ship|stop_max_loot" (autowsgr)
  └ 2 lines found

● Search (grep)
  │ "stop_event\.is_set\(\)" (autowsgr)
  └ 1 line found

● No-op before writing report (shell)
  │ true
  └ 1 line...

● Edit
  └ Create copilot_answer.md

● Read copilot_answer.md
  └ 86 lines read

已完成。`copilot_answer.md` 已写入仓库根目录，包含对 **Issue #431** 的完整分析结论（概要、证据链、根因判断、修复方案、用户建议与置信度）。


Changes   +87 -0
Requests  1 Premium (3m 2s)
Tokens    ↑ 1.0m • ↓ 8.3k • 943.5k (cached) • 4.6k (reasoning)

🔗 GitHub Action 运行记录