AiDOPWarehouse/scripts/s8/r3-out-of-range-regression.sh

#!/usr/bin/env bash
# R3-OUT_OF_RANGE regression script — S8-REGRESSION-FIXTURE-1 重构版（dev/test only, aidopdev）。
#
# 演变史：
#   - 旧版基于 G01_TEST_WATCH 旧 fixture（id=34）+ 强依赖 baseline=13 + id=34 backfill 断言。
#   - 重构后：默认复用 demo rule 11 DEMO_ORDER_DIMENSION_OOR（CTO 拍板二.B），
#     若 demo rule 缺失则 record_skip。rule 12 (DEMO_ORDER_YIELD_OOR) 保留为演示备份不动。
#
# 验证项（demo rule 11 模式）：
#   1. 双 run-once HTTP 200；
#   2. OUT_OF_RANGE 主链已建单；活动 exception 数与 dedup_key 1:1；
#   3. last_detected_at 在两次运行之间推进；
#   4. source_payload 含 measured_value/upper_bound/deviation/direction + __ 元数据；
#   5. demo rule 11 守恒。

set -uo pipefail

SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
# shellcheck source=./s8-regression-common.sh
source "${SCRIPT_DIR}/s8-regression-common.sh"

auth_load

RULE_CODE="${RULE_CODE:-DEMO_ORDER_DIMENSION_OOR}"

baseline_before=$(read_baseline)
echo "==== r3-out-of-range-regression  RULE_CODE=${RULE_CODE} baseline_before=${baseline_before} ===="

if ! require_demo_rule "${RULE_CODE}"; then
  record_skip "OUT_OF_RANGE fixture '${RULE_CODE}' not present or disabled — historic G01_TEST_WATCH removed from dev"
  print_summary
  exit 0
fi
record_pass "${RULE_CODE} enabled"

RULE_ID=$(get_rule_id_by_code "${RULE_CODE}")
snap_enabled=$(get_rule_field "${RULE_ID}" enabled)
snap_paused=$(get_rule_field "${RULE_ID}" paused_until)
snap_trigger=$(get_rule_field "${RULE_ID}" trigger_count_required)
snap_recover=$(get_rule_field "${RULE_ID}" recover_count_required)
snap_rtype=$(get_rule_field "${RULE_ID}" rule_type)
snap_expr=$(get_rule_field "${RULE_ID}" expression)
snap_params=$(get_rule_field "${RULE_ID}" params_json)

resp1=$(run_once_endpoint)
count1=$(printf '%s' "${resp1}" | python3 -c "import json,sys;print(json.load(sys.stdin).get('count',0))")
[[ "${count1}" -ge 1 ]] && record_pass "first run-once HTTP 200, count=${count1}" || record_fail "first run-once empty (${count1})"

failed1=$(printf '%s' "${resp1}" | python3 -c "
import json,sys
d=json.load(sys.stdin)
print(sum(1 for r in d.get('results',[]) if r.get('errorMessage') or r.get('reason')=='create_failed'))
")
[[ "${failed1}" == "0" ]] && record_pass "first run-once failed=0" || record_fail "first run-once failed=${failed1}"

before_ts=$(mysql_run "SELECT IFNULL(MAX(last_detected_at), '1970-01-01') FROM ado_s8_exception WHERE source_rule_code='${RULE_CODE}' AND status<>'CLOSED' AND is_deleted=0;")
echo "pre-second-run last_detected_at=${before_ts}"

sleep 1
resp2=$(run_once_endpoint)
count2=$(printf '%s' "${resp2}" | python3 -c "import json,sys;print(json.load(sys.stdin).get('count',0))")
[[ "${count2}" -ge 1 ]] && record_pass "second run-once HTTP 200, count=${count2}" || record_fail "second run-once empty (${count2})"

# 活动 exception 数 = 数据源 dedup_key 行数（dimension_oor 命中 OOR-DEMO-001/002 两条）
oor_active=$(mysql_run "SELECT COUNT(*) FROM ado_s8_exception WHERE source_rule_code='${RULE_CODE}' AND status<>'CLOSED' AND is_deleted=0;")
[[ "${oor_active}" -ge 1 ]] && record_pass "active OUT_OF_RANGE exception count=${oor_active} (>=1)" || record_fail "expected at least 1 active OOR exception, got ${oor_active}"

after_ts=$(mysql_run "SELECT MAX(last_detected_at) FROM ado_s8_exception WHERE source_rule_code='${RULE_CODE}' AND status<>'CLOSED' AND is_deleted=0;")
[[ "${after_ts}" > "${before_ts}" ]] && record_pass "last_detected_at refreshed: ${before_ts} -> ${after_ts}" || record_fail "last_detected_at did not refresh (before=${before_ts}, after=${after_ts})"

payload=$(mysql_run "SELECT source_payload FROM ado_s8_exception WHERE source_rule_code='${RULE_CODE}' AND status<>'CLOSED' AND is_deleted=0 ORDER BY id DESC LIMIT 1;")
metadata_ok=1
for field in measured_value upper_bound deviation direction __ruleType __sourceObjectType __sourceObjectId; do
  echo "${payload}" | grep -q "${field}" || { record_fail "source_payload missing ${field}"; metadata_ok=0; }
done
(( metadata_ok == 1 )) && record_pass "source_payload contains measured/upper/deviation/direction + 3 metadata fields"

final_enabled=$(get_rule_field "${RULE_ID}" enabled)
final_paused=$(get_rule_field "${RULE_ID}" paused_until)
final_trigger=$(get_rule_field "${RULE_ID}" trigger_count_required)
final_recover=$(get_rule_field "${RULE_ID}" recover_count_required)
final_rtype=$(get_rule_field "${RULE_ID}" rule_type)
final_expr=$(get_rule_field "${RULE_ID}" expression)
final_params=$(get_rule_field "${RULE_ID}" params_json)
[[ "${final_enabled}" == "${snap_enabled}" && "${final_paused}" == "${snap_paused}" \
   && "${final_trigger}" == "${snap_trigger}" && "${final_recover}" == "${snap_recover}" \
   && "${final_rtype}" == "${snap_rtype}" && "${final_expr}" == "${snap_expr}" \
   && "${final_params}" == "${snap_params}" ]] \
  && record_pass "${RULE_CODE} 守恒: enabled/paused/trigger/recover/rule_type/expression/params_json 全部不变" \
  || record_fail "${RULE_CODE} 守恒失败: 配置字段被污染"

# rule 12 (YIELD_OOR) 备份不动断言
r12_state=$(mysql_run "SELECT CONCAT_WS(':', enabled, IFNULL(paused_until,'NULL'), trigger_count_required, recover_count_required) FROM ado_s8_watch_rule WHERE id=12;")
[[ "${r12_state}" == "1:NULL:1:1" ]] && record_pass "demo rule 12 (YIELD_OOR) untouched: ${r12_state}" || record_fail "demo rule 12 drift: ${r12_state}"

assert_baseline_unchanged "${baseline_before}"

print_summary
exit_by_summary