AiDOPWarehouse/scripts/s8/r3-shortage-regression.sh

#!/usr/bin/env bash
# R3-SHORTAGE regression script — S8-REGRESSION-FIXTURE-1 重构版（dev/test only, aidopdev）。
#
# 演变史：
#   - 旧版基于 G01_TEST_SHORTAGE 旧 fixture（id=53）。当前 dev 已无 SHORTAGE demo 规则。
#   - 重构后：找不到 SHORTAGE demo fixture → record_skip + exit 0。
#   - 任务 CTO 约束 六.F：不得 FAIL；不得自动创建 SHORTAGE TEMP fixture（除非有稳定方案）。
#
# 为日后 SHORTAGE 演示规则上线时启用，环境变量 RULE_CODE 可指定其他 SHORTAGE rule_code。

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:-G01_TEST_SHORTAGE}"  # 旧 fixture，当前 dev 无；保留为默认以便 SKIP 信息明确

baseline_before=$(read_baseline)
echo "==== r3-shortage-regression  RULE_CODE=${RULE_CODE} baseline_before=${baseline_before} ===="

# 当前 dev 无 SHORTAGE demo 规则；不在本轮创建 TEMP SHORTAGE fixture。
shortage_count=$(mysql_run "SELECT COUNT(*) FROM ado_s8_watch_rule WHERE rule_type='SHORTAGE' AND enabled=1 AND tenant_id=${TENANT_ID} AND factory_id=${FACTORY_ID};")
if [[ "${shortage_count}" == "0" ]]; then
  record_skip "SHORTAGE demo fixture not present in dev (no enabled SHORTAGE rule under tenant=${TENANT_ID}/factory=${FACTORY_ID})"
  assert_baseline_unchanged "${baseline_before}"
  print_summary
  exit 0
fi

if ! require_demo_rule "${RULE_CODE}"; then
  record_skip "SHORTAGE rule '${RULE_CODE}' not enabled — set RULE_CODE env to active SHORTAGE rule_code to run"
  assert_baseline_unchanged "${baseline_before}"
  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)

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"

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;")

sleep 1
run_once_endpoint >/dev/null

active_count=$(mysql_run "SELECT COUNT(*) FROM ado_s8_exception WHERE source_rule_code='${RULE_CODE}' AND status<>'CLOSED' AND is_deleted=0;")
[[ "${active_count}" -ge 1 ]] && record_pass "active SHORTAGE exception count=${active_count}" || record_fail "expected at least 1 active SHORTAGE exception, got ${active_count}"

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"

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 __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 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_enabled}" == "${snap_enabled}" && "${final_paused}" == "${snap_paused}" \
   && "${final_trigger}" == "${snap_trigger}" && "${final_recover}" == "${snap_recover}" ]] \
  && record_pass "${RULE_CODE} 守恒" || record_fail "${RULE_CODE} 守恒失败"

assert_baseline_unchanged "${baseline_before}"

print_summary
exit_by_summary