mirror of
https://github.com/ThearchyHelios/AgentLab.git
synced 2026-11-15 04:31:58 +00:00
ThearchyHelios
941723b17c
- 身份与工具：登录页建第一个管理员（认人接口的 401 说明能不能建）；搭建者有只读的人和组名录，选人给候选并核对名字；授权三行带标题；端点请求头名校验（空名、非法名存不进、发不出时说清原因）；写入能力在工具页试运行一律演练、不发送，HTTP 状态照实说成败；写记忆不算只读、查询能力只能选同一端点上的只读能力；审批与遮罩的说法和实际规则一致；开登录时不要署名、导入和发布记登录的人；使用者不显示推演等只给搭建者的操作，403 按是否开登录说话；登录页只认一次人 - 流程与实例：图里用到的岗位（派给谁、超时升级给谁、发送确认派给谁）全部派生、没绑人的发布时报错；写外部系统的参数按能力声明的类型收拢后再算哈希和发送，收不成就不发；发起人的实例页只看这一步的状态，处理人才给待办卡；会签进度带登录核实和时间，升级后照实写规则；实例状态写流程的结论（已退回、未确认、等待核实写入结果），核实生效后不再挂失败原因；流程应用首页不派生最近封存运行的结果块，看板没数据时是安静的空态；样例⑩的金额带类型和下限、待办标题带金额，表单上下限前后端一起生效 - 看板与证据：定时任务模板加 ISO 周、上一 ISO 周、本月、上月；出处链穿过原样解析查询结果的整形节点，追不到原始数据的照实说停在哪里，样例⑨改用 cell()；应用首页和版本历史都能做成应用；指标块单位不重复；版本列表带退役说明；定时任务页头跟着刷新；删视图要确认、新视图能起名；编辑器属性用中文名、术语带解释 - 指标出具（用户 2026-10-15 拍板）：契约只写「指标来自」、上游没有报告撰写节点、成果里没有模型写的话时按指标出具——必需指标齐、指标输入追到原始数据、成果字段里的数回指得上才完整出具；受管级要求每个指标静态地追到原始数据（governed.metric_untraced）；出具横幅和应用印章写明按指标 - 受管工作流降为已发布只给管理员（Q8 顺延，服务端同样拦）；工作流接口带当前发布版的级别，画布上改过之后也认得出受管工作流
246 lines
13 KiB
Python
246 lines
13 KiB
Python
"""定时任务的输入模板（app/scheduler/service.py）：日期变量按触发时间在任务时区算，模板写错就说出来。
|
||
|
||
- 变量都按 fire_at（计划触发时间）在任务时区算，不按「现在」：补跑晚了一小时，昨天还是计划那天的昨天
|
||
- 跨月、跨年、跨时区（同一时刻在上海已经是周一，在纽约还是周日）；周从周一算起
|
||
- ISO 周（2026-W42）的年份跟着周走：2026-12-31、2027-01-01 都是 2026-W53，2025-12-29 是 2026-W01；月份写 YYYY-MM
|
||
- schedule.last_fire_time 是上一次计划触发的时间（按 cron 往前找），和本次一样写成带偏移的 ISO 时间
|
||
- 模板写错（未知变量、未知过滤器、{{ }} 不成对、空的 {{ }}、值不是文本）抛 TemplateError，中文说明哪个输入
|
||
- 声明了入口字段的工作流：模板里多出来的字段名、缺的必填输入（没有默认值）都拦下
|
||
|
||
夹具的工作流、字段名都是虚构的。
|
||
"""
|
||
from __future__ import annotations
|
||
|
||
from datetime import datetime, timezone
|
||
|
||
import pytest
|
||
|
||
from app.scheduler import service
|
||
from app.scheduler.service import TemplateError
|
||
|
||
UTC = timezone.utc
|
||
|
||
|
||
def values(fire_at: datetime, tz: str = "Asia/Shanghai", cron: str = "0 9 * * 1") -> dict[str, str]:
|
||
return service.template_values(fire_at, tz, cron)
|
||
|
||
|
||
# --------------------------------------------------------------------------
|
||
# 变量按 fire_at 在任务时区算
|
||
# --------------------------------------------------------------------------
|
||
|
||
|
||
def test_monday_morning_in_shanghai():
|
||
v = values(datetime(2026, 10, 5, 1, 0, tzinfo=UTC)) # 上海 2026-10-05（周一）09:00
|
||
assert v == {
|
||
"today": "2026-10-05",
|
||
"yesterday": "2026-10-04",
|
||
"this_week": "2026-W41",
|
||
"last_week": "2026-W40",
|
||
"week_before_last": "2026-W39",
|
||
"this_week_start": "2026-10-05",
|
||
"last_week_start": "2026-09-28",
|
||
"last_week_end": "2026-10-04",
|
||
"this_month": "2026-10",
|
||
"last_month": "2026-09",
|
||
"month_before_last": "2026-08",
|
||
"this_month_start": "2026-10-01",
|
||
"last_month_start": "2026-09-01",
|
||
"last_month_end": "2026-09-30",
|
||
"fire_time": "2026-10-05T09:00:00+08:00",
|
||
"last_fire_time": "2026-09-28T09:00:00+08:00",
|
||
}
|
||
|
||
|
||
def test_across_a_month_boundary():
|
||
# 上海 2026-03-01（周日）00:30，UTC 还是 2 月 28 日
|
||
v = values(datetime(2026, 2, 28, 16, 30, tzinfo=UTC), cron="30 0 * * *")
|
||
assert (v["today"], v["yesterday"]) == ("2026-03-01", "2026-02-28")
|
||
assert (v["this_week_start"], v["last_week_start"], v["last_week_end"]) == ("2026-02-23", "2026-02-16", "2026-02-22")
|
||
assert (v["this_month_start"], v["last_month_start"], v["last_month_end"]) == ("2026-03-01", "2026-02-01", "2026-02-28")
|
||
assert v["last_fire_time"] == "2026-02-28T00:30:00+08:00"
|
||
|
||
|
||
def test_across_a_year_boundary():
|
||
v = values(datetime(2027, 1, 1, 0, 0, tzinfo=UTC), cron="0 8 1 * *") # 上海 2027-01-01（周五）08:00
|
||
assert (v["today"], v["yesterday"]) == ("2027-01-01", "2026-12-31")
|
||
assert (v["this_week_start"], v["last_week_start"], v["last_week_end"]) == ("2026-12-28", "2026-12-21", "2026-12-27")
|
||
assert (v["this_month_start"], v["last_month_start"], v["last_month_end"]) == ("2027-01-01", "2026-12-01", "2026-12-31")
|
||
assert v["last_fire_time"] == "2026-12-01T08:00:00+08:00"
|
||
|
||
|
||
@pytest.mark.parametrize("day, this_week, last_week, before_last", [
|
||
# 2026 年 1 月 1 日是周四，这一年有 53 周：年底那几天、2027 年开头的周五到周日都还在 2026-W53
|
||
((2026, 12, 31), "2026-W53", "2026-W52", "2026-W51"),
|
||
((2027, 1, 1), "2026-W53", "2026-W52", "2026-W51"),
|
||
((2027, 1, 3), "2026-W53", "2026-W52", "2026-W51"),
|
||
# 周一换周：上周是上一年的最后一周
|
||
((2027, 1, 4), "2027-W01", "2026-W53", "2026-W52"),
|
||
# 反过来，2025 年最后几天已经算 2026 年的第 1 周
|
||
((2025, 12, 29), "2026-W01", "2025-W52", "2025-W51"),
|
||
((2026, 1, 5), "2026-W02", "2026-W01", "2025-W52"),
|
||
])
|
||
def test_iso_weeks_across_the_year(day, this_week, last_week, before_last):
|
||
"""ISO 周的年份是周所在的年，不是日历年；周号补足两位"""
|
||
y, m, d = day
|
||
v = values(datetime(y, m, d, 1, 0, tzinfo=UTC)) # 上海当天 09:00
|
||
assert (v["this_week"], v["last_week"], v["week_before_last"]) == (this_week, last_week, before_last)
|
||
|
||
|
||
def test_iso_week_and_month_follow_the_schedule_timezone():
|
||
"""UTC 2026-12-31 16:30：上海已经是 2027-01-01 00:30（周五，仍在 2026-W53），伦敦还是 2026-12-31"""
|
||
moment = datetime(2026, 12, 31, 16, 30, tzinfo=UTC)
|
||
shanghai = values(moment, "Asia/Shanghai", "30 0 * * *")
|
||
london = values(moment, "Europe/London", "30 16 * * *")
|
||
assert (shanghai["this_week"], shanghai["this_month"], shanghai["last_month"], shanghai["month_before_last"]) == (
|
||
"2026-W53", "2027-01", "2026-12", "2026-11")
|
||
assert (london["this_week"], london["this_month"], london["last_month"]) == ("2026-W53", "2026-12", "2026-11")
|
||
# 跨到周一那一刻：上海已经是 2027-W01，纽约还在 2026-W53
|
||
monday = datetime(2027, 1, 3, 20, 0, tzinfo=UTC)
|
||
assert values(monday, "Asia/Shanghai", "0 4 * * *")["this_week"] == "2027-W01"
|
||
assert values(monday, "America/New_York", "0 15 * * *")["this_week"] == "2026-W53"
|
||
|
||
|
||
def test_months_across_a_year_boundary():
|
||
v = values(datetime(2027, 2, 1, 1, 0, tzinfo=UTC), cron="0 9 1 * *")
|
||
assert (v["this_month"], v["last_month"], v["month_before_last"]) == ("2027-02", "2027-01", "2026-12")
|
||
v = values(datetime(2027, 1, 1, 1, 0, tzinfo=UTC), cron="0 9 1 * *")
|
||
assert (v["this_month"], v["last_month"], v["month_before_last"]) == ("2027-01", "2026-12", "2026-11")
|
||
|
||
|
||
def test_leap_february_ends_on_the_29th():
|
||
v = values(datetime(2028, 3, 1, 1, 0, tzinfo=UTC), cron="0 9 1 * *")
|
||
assert (v["last_month_start"], v["last_month_end"]) == ("2028-02-01", "2028-02-29")
|
||
|
||
|
||
def test_same_moment_in_two_timezones():
|
||
"""UTC 2026-10-04 20:00：上海已经是周一 04:00，纽约还是周日 16:00"""
|
||
moment = datetime(2026, 10, 4, 20, 0, tzinfo=UTC)
|
||
shanghai = values(moment, "Asia/Shanghai", "0 4 * * *")
|
||
new_york = values(moment, "America/New_York", "0 16 * * *")
|
||
assert (shanghai["today"], shanghai["this_week_start"]) == ("2026-10-05", "2026-10-05")
|
||
assert (new_york["today"], new_york["this_week_start"]) == ("2026-10-04", "2026-09-28")
|
||
assert shanghai["fire_time"] == "2026-10-05T04:00:00+08:00"
|
||
assert new_york["fire_time"] == "2026-10-04T16:00:00-04:00"
|
||
|
||
|
||
def test_fire_time_drops_sub_seconds():
|
||
"""立即运行的触发时间是点下去的那一刻，写进输入时只到秒"""
|
||
v = values(datetime(2026, 10, 5, 3, 4, 5, 678901, tzinfo=UTC))
|
||
assert v["fire_time"] == "2026-10-05T11:04:05+08:00"
|
||
|
||
|
||
# --------------------------------------------------------------------------
|
||
# 渲染与校验
|
||
# --------------------------------------------------------------------------
|
||
|
||
|
||
def test_render_inputs():
|
||
v = values(datetime(2026, 10, 5, 1, 0, tzinfo=UTC))
|
||
out = service.render_inputs({
|
||
"stat_date": "{{ schedule.yesterday }}",
|
||
"week": "{{schedule.last_week_start}}~{{ schedule.last_week_end }}",
|
||
"region": "华东",
|
||
"tag": "{{ schedule.today | upper }}",
|
||
}, v)
|
||
assert out == {"stat_date": "2026-10-04", "week": "2026-09-28~2026-10-04", "region": "华东", "tag": "2026-10-05"}
|
||
# 按周统计的周报：周一早上出上周的报告，和上上周比
|
||
weekly = service.render_inputs({"week": "{{ schedule.last_week }}", "prev_week": "{{ schedule.week_before_last }}",
|
||
"month": "{{ schedule.last_month }}"}, v)
|
||
assert weekly == {"week": "2026-W40", "prev_week": "2026-W39", "month": "2026-09"}
|
||
assert service.check_template({"week": "{{ schedule.this_week }}", "month": "{{ schedule.this_month }}"})
|
||
|
||
|
||
def test_valid_templates_pass():
|
||
assert service.check_template({"a": "{{ schedule.today }}", "b": "固定值", "c": "{{ schedule.fire_time | trim }}"}) == {
|
||
"a": "{{ schedule.today }}", "b": "固定值", "c": "{{ schedule.fire_time | trim }}"}
|
||
assert service.check_template(None) == {}
|
||
|
||
|
||
@pytest.mark.parametrize("template, fragments", [
|
||
({"stat_date": "{{ schedule.yesterdy }}"}, ["stat_date", "schedule.yesterdy", "schedule.yesterday"]),
|
||
({"stat_date": "{{ input.day }}"}, ["stat_date", "input.day"]),
|
||
({"stat_date": "{{ schedule.today"}, ["stat_date", "成对"]),
|
||
({"stat_date": "schedule.today }}"}, ["stat_date", "成对"]),
|
||
({"stat_date": "{{ }}"}, ["stat_date", "空的"]),
|
||
({"stat_date": "{{ schedule.today | shout }}"}, ["stat_date", "shout", "过滤器"]),
|
||
({"stat_date": 20261005}, ["stat_date", "文本"]),
|
||
({"": "{{ schedule.today }}"}, ["字段名"]),
|
||
(["{{ schedule.today }}"], ["输入模板"]),
|
||
])
|
||
def test_bad_templates_explain_in_chinese(template, fragments):
|
||
with pytest.raises(TemplateError) as caught:
|
||
service.check_template(template)
|
||
for fragment in fragments:
|
||
assert fragment in str(caught.value), str(caught.value)
|
||
|
||
|
||
def test_field_names_are_trimmed_and_unique():
|
||
assert service.check_template({" stat_date ": "{{ schedule.yesterday }}"}) == {"stat_date": "{{ schedule.yesterday }}"}
|
||
with pytest.raises(TemplateError) as caught:
|
||
service.check_template({"stat_date": "a", "stat_date ": "b"})
|
||
assert "stat_date" in str(caught.value) and "两次" in str(caught.value)
|
||
|
||
|
||
def test_variable_catalog():
|
||
items = service.variables(datetime(2026, 10, 5, 1, 0, tzinfo=UTC), "Asia/Shanghai")
|
||
names = [i["name"] for i in items]
|
||
assert names == [f"schedule.{key}" for key in (
|
||
"today", "yesterday", "this_week", "last_week", "week_before_last", "this_week_start", "last_week_start",
|
||
"last_week_end", "this_month", "last_month", "month_before_last", "this_month_start", "last_month_start",
|
||
"last_month_end", "fire_time", "last_fire_time")]
|
||
by_name = {i["name"]: i for i in items}
|
||
assert by_name["schedule.yesterday"] == {"name": "schedule.yesterday", "label": "昨天（YYYY-MM-DD）",
|
||
"example": "2026-10-04", "note": ""}
|
||
assert by_name["schedule.last_week"]["example"] == "2026-W40" and "2026-W53" in by_name["schedule.last_week"]["note"]
|
||
assert by_name["schedule.this_month"]["example"] == "2026-10"
|
||
assert all(i["label"] and i["example"] for i in items)
|
||
# 补充说明只写在 ISO 周上
|
||
assert [i["name"] for i in items if i["note"]] == ["schedule.this_week", "schedule.last_week", "schedule.week_before_last"]
|
||
|
||
|
||
# --------------------------------------------------------------------------
|
||
# 和工作流入口字段对照
|
||
# --------------------------------------------------------------------------
|
||
|
||
|
||
def graph(*fields: dict) -> dict:
|
||
return {
|
||
"nodes": [
|
||
{"id": "start", "type": "input", "position": {"x": 0, "y": 0},
|
||
"data": {"label": "输入", "config": {"fields": list(fields)}}},
|
||
{"id": "out", "type": "output", "position": {"x": 300, "y": 0},
|
||
"data": {"label": "成果", "config": {"fields": [{"name": "r", "value": "完成"}]}}},
|
||
],
|
||
"edges": [{"source": "start", "target": "out"}],
|
||
}
|
||
|
||
|
||
def test_fields_of_a_graph():
|
||
g = graph({"name": "stat_date", "required": True}, {"name": "region", "default": "华东"})
|
||
assert [f["name"] for f in service.input_fields(g)] == ["stat_date", "region"]
|
||
assert service.input_fields({"nodes": "坏掉的图"}) == []
|
||
|
||
|
||
def test_unknown_field_names_are_refused():
|
||
fields = service.input_fields(graph({"name": "stat_date"}, {"name": "region"}))
|
||
with pytest.raises(TemplateError) as caught:
|
||
service.check_fields({"stat_dat": "{{ schedule.yesterday }}"}, fields, "门店周报")
|
||
assert "stat_dat" in str(caught.value) and "门店周报" in str(caught.value) and "stat_date" in str(caught.value)
|
||
|
||
|
||
def test_missing_required_inputs_are_refused_only_when_asked():
|
||
fields = service.input_fields(graph({"name": "stat_date", "required": True},
|
||
{"name": "region", "required": True, "default": "华东"}))
|
||
with pytest.raises(TemplateError) as caught:
|
||
service.check_fields({}, fields, "门店周报")
|
||
assert "stat_date" in str(caught.value) and "必填" in str(caught.value)
|
||
# 预览时还在填，不查缺的；有默认值的必填项不算缺
|
||
service.check_fields({}, fields, "门店周报", require=False)
|
||
service.check_fields({"stat_date": "{{ schedule.yesterday }}"}, fields, "门店周报")
|
||
|
||
|
||
def test_graph_without_declared_fields_accepts_any_name():
|
||
"""入口没声明字段时输入是开放的：运行时传什么键都收"""
|
||
service.check_fields({"anything": "x"}, service.input_fields(graph()), "门店周报")
|