root/Jyotisha
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

feat: sync guarded rectification gates

Browse Source
This commit is contained in:
732642856
2026-07-19 16:09:24 +08:00
parent 0bb7dbfe42
commit 352809fa82
9 changed files with 761 additions and 230 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/active_rectification_questions.py
+218 -13
View File
@@ -8,7 +8,23 @@ import json
from datetime import datetime, timedelta
from typing import Any
from scripts.active_rectification_scoring import build_questions, score_answers
OPTIONS = [
{"key": "A", "label": "明确有，且时间大致吻合", "score": 2},
{"key": "B", "label": "有类似，但时间略偏或不够重大", "score": 1},
{"key": "C", "label": "没有明显发生", "score": -2},
{"key": "D", "label": "不确定 / 不记得", "score": 0},
]
QUESTION_TEMPLATES = [
("education_environment_shift", 1, "education", ["D24", "D4", "Dasha"], "age_16_to_18", "16-18岁附近，是否有明显学业、学校、专业方向或学习环境变化？", "middle_candidate_cluster", "against_D24_sensitive_cluster"),
("residence_relocation_shift", 1, "residence", ["D4", "12H", "Rahu/Ketu", "Transit"], "age_20_to_24", "20-24岁附近，是否有搬家、离乡、长期异地、住宿或居住结构变化？", "D4_relocation_cluster", "against_D4_relocation_cluster"),
("relationship_or_partner_entry", 1, "relationship", ["D9", "UL", "A7", "7H"], "age_21_to_26", "21-26岁附近，是否有关系对象进入、关系断裂、暧昧升级或关系观明显转变？", "D9_UL_A7_cluster", "against_relationship_cluster"),
("career_responsibility_pressure", 1, "career", ["D10", "A10", "Saturn", "10H"], "age_26_to_30", "26-30岁附近，是否有责任增加、合作压力、工作结构变化或长期压力阶段？", "D10_A10_saturn_cluster", "against_career_pressure_cluster"),
("research_tool_expression_shift", 1, "career_learning", ["D10", "D24", "Mercury", "A10"], "recent_three_years", "近三年是否明显进入写作、技术、系统化学习、工具搭建、内容表达、AI/研究类方向？", "Mercury_D24_A10_cluster", "against_learning_expression_cluster"),
("health_crisis_or_low_period", 2, "health_pressure", ["D30", "6H", "8H", "Saturn/Mars"], "largest_pressure_window", "某个压力窗口附近，是否有健康、事故、低谷、睡眠/精神压力或身体负担明显阶段？", "D30_crisis_cluster", "against_D30_crisis_cluster"),
("public_role_or_project_visibility", 2, "public_work", ["A10", "D10", "AmK", "Karakamsha"], "career_visibility_window", "某个事业窗口附近，是否有项目公开、作品产出、职位/身份变化或被他人看见的机会？", "A10_public_visibility_cluster", "against_A10_cluster"),
("sequence_inner_vs_outer", 3, "fine_timing", ["KP_cusp", "Pratyantar", "Dasha_boundary"], "top_candidate_window", "关键变化更像先有内在转向、后有外部结果，还是几乎同时发生？", "fine_boundary_cluster", "neutral"),
]
def _parse_time(value: str) -> datetime:
@@ -97,6 +113,7 @@ def _candidate_recast(
return None
import domain_calculation_service
import jaimini
import kp_system
import varga
chart = domain_calculation_service.compute_chart({
@@ -117,7 +134,7 @@ def _candidate_recast(
if name in {"Sun", "Moon", "Mars", "Mercury", "Jupiter", "Venus", "Saturn", "Rahu", "Ketu"}
}
asc_lon = chart["ascendant"]["lon"]
vargas = varga.calc_all_vargas(planet_lons, asc_lon, divisions=[4, 9, 10, 24, 30, 60])
vargas = varga.calc_all_vargas(planet_lons, asc_lon, divisions=[9, 10, 24, 30, 60])
arudha = jaimini.calc_arudha_padas(int(asc_lon // 30), planet_lons)
padas = arudha.get("padas", {})
upapada = arudha.get("upapada", {})
@@ -128,16 +145,8 @@ def _candidate_recast(
"degree_in_sign": chart["ascendant"].get("degree_in_sign"),
},
"varga_lagna": {
**{
key: value.get("Ascendant", {})
for key, value in vargas.items()
},
**{
f"D{division}": value.get("Ascendant", {})
for division in (4, 9, 10, 24, 30)
for key, value in vargas.items()
if key.startswith(f"D{division}_")
},
key: value.get("Ascendant", {})
for key, value in vargas.items()
},
"arudha": {
"A7": padas.get("A7", {}),
@@ -180,7 +189,23 @@ def build_questionnaire(
tz: float | None = None,
ayanamsa: str = "lahiri",
) -> dict[str, Any]:
questions = build_questions()
questions = []
for qid, round_id, domain, sensitivity, window, prompt, yes_bias, no_bias in QUESTION_TEMPLATES:
questions.append({
"id": qid,
"round": round_id,
"domain": domain,
"sensitivity": sensitivity,
"window": window,
"prompt": prompt,
"options": OPTIONS,
"scoring_map": {
"A": {"effect": "support", "cluster": yes_bias, "points": 2},
"B": {"effect": "weak_support", "cluster": yes_bias, "points": 1},
"C": {"effect": "exclude_or_penalize", "cluster": no_bias, "points": -2},
"D": {"effect": "neutral", "cluster": "neutral", "points": 0},
},
})
return {
"scope": "active_birth_time_rectification_questionnaire",
"schema_version": 1,
@@ -212,6 +237,186 @@ def build_questionnaire(
}
def score_answers(
questionnaire: dict[str, Any],
answers: dict[str, str],
narayana_cross_scores: dict[str, int | float] | None = None,
jaimini_karaka_cross_scores: dict[str, int | float] | None = None,
vimsopaka_avastha_cross_scores: dict[str, int | float] | None = None,
shadbala_av_observation_scores: dict[str, int | float] | None = None,
gochara_transit_observation_scores: dict[str, int | float] | None = None,
) -> dict[str, Any]:
questions = questionnaire.get("questions") if isinstance(questionnaire.get("questions"), list) else []
by_id = {question["id"]: question for question in questions if isinstance(question, dict) and question.get("id")}
cluster_scores: dict[str, int] = {}
applied = []
unknown_ids = []
invalid_answers = []
for question_id, raw_choice in (answers or {}).items():
question = by_id.get(question_id)
if not question:
unknown_ids.append(question_id)
continue
choice = str(raw_choice or "").strip().upper()
scoring = (question.get("scoring_map") or {}).get(choice)
if not isinstance(scoring, dict):
invalid_answers.append({"id": question_id, "answer": raw_choice})
continue
cluster = str(scoring.get("cluster") or "neutral")
points = int(scoring.get("points") or 0)
if cluster != "neutral":
cluster_scores[cluster] = cluster_scores.get(cluster, 0) + points
applied.append({"id": question_id, "answer": choice, "cluster": cluster, "points": points})
answered_ids = {item["id"] for item in applied}
unanswered = [question for question in questions if question.get("id") not in answered_ids]
next_round = min((int(question.get("round") or 0) for question in unanswered), default=None)
rankings = []
for cluster, score in sorted(cluster_scores.items(), key=lambda item: (-item[1], item[0])):
narayana_score = 0
if isinstance(narayana_cross_scores, dict):
raw_narayana_score = narayana_cross_scores.get(cluster, 0)
if isinstance(raw_narayana_score, (int, float)):
narayana_score = raw_narayana_score
jaimini_score = 0
if isinstance(jaimini_karaka_cross_scores, dict):
raw_jaimini_score = jaimini_karaka_cross_scores.get(cluster, 0)
if isinstance(raw_jaimini_score, (int, float)):
jaimini_score = raw_jaimini_score
vimsopaka_score = 0
if isinstance(vimsopaka_avastha_cross_scores, dict):
raw_vimsopaka_score = vimsopaka_avastha_cross_scores.get(cluster, 0)
if isinstance(raw_vimsopaka_score, (int, float)):
vimsopaka_score = raw_vimsopaka_score
shadbala_av_score = 0
if isinstance(shadbala_av_observation_scores, dict):
raw_shadbala_av_score = shadbala_av_observation_scores.get(cluster, 0)
if isinstance(raw_shadbala_av_score, (int, float)):
shadbala_av_score = raw_shadbala_av_score
gochara_score = 0
if isinstance(gochara_transit_observation_scores, dict):
raw_gochara_score = gochara_transit_observation_scores.get(cluster, 0)
if isinstance(raw_gochara_score, (int, float)):
gochara_score = raw_gochara_score
downgrade_reasons = []
if score > 0 and narayana_score < 0:
downgrade_reasons.append("narayana")
if score > 0 and jaimini_score < 0:
downgrade_reasons.append("jaimini_karaka")
if score > 0 and vimsopaka_score < 0:
downgrade_reasons.append("vimsopaka_avastha")
if score > 0 and shadbala_av_score < 0:
downgrade_reasons.append("shadbala_av")
if score > 0 and gochara_score < 0:
downgrade_reasons.append("gochara_transit")
rankings.append(
{
"cluster": cluster,
"score": score,
"narayana_cross_score": narayana_score,
"narayana_cross_score_source": (
"provided_cross_score"
if isinstance(narayana_cross_scores, dict)
else "not_computed_yet"
),
"jaimini_karaka_cross_score": jaimini_score,
"jaimini_karaka_cross_score_source": (
"provided_cross_score"
if isinstance(jaimini_karaka_cross_scores, dict)
else "not_computed_yet"
),
"vimsopaka_avastha_cross_score": vimsopaka_score,
"vimsopaka_avastha_cross_score_source": (
"provided_cross_score"
if isinstance(vimsopaka_avastha_cross_scores, dict)
else "not_computed_yet"
),
"shadbala_av_observation_score": shadbala_av_score,
"shadbala_av_observation_score_source": (
"provided_observation_score"
if isinstance(shadbala_av_observation_scores, dict)
else "not_computed_yet"
),
"gochara_transit_observation_score": gochara_score,
"gochara_transit_observation_score_source": (
"provided_observation_score"
if isinstance(gochara_transit_observation_scores, dict)
else "not_computed_yet"
),
"claim_status": "candidate",
"truth_status": "not_birth_time_truth",
"confidence_cap": "low" if downgrade_reasons else "medium",
"conflict_policy": (
"downgrade_without_replacement"
if downgrade_reasons
else "cross_check_only_no_replacement"
),
"downgrade_reasons": downgrade_reasons,
}
)
return {
"scope": "active_birth_time_rectification_scoring",
"schema_version": 1,
"claim_status": "candidate",
"truth_status": "not_birth_time_truth",
"formula_unit_parity_status": "partial",
"timing_claim_status": "exploratory_unvalidated",
"answered_count": len(applied),
"candidate_cluster_rankings": rankings,
"technique_audit_table": [
{
"technique": "Vimshottari Rectification",
"status": "used",
"role": "primary_candidate_cluster_scoring",
},
{
"technique": "Narayana Dasha Rectification",
"status": "partial",
"role": "cross_check_downgrade_only",
"conflict_policy": "downgrade_without_replacement",
"boundary": "Narayana cross score may be supplied by a separate calculator; absent values default to neutral and never upgrade birth-time truth.",
},
{
"technique": "Jaimini Karaka Rectification",
"status": "partial",
"role": "cross_check_downgrade_only",
"conflict_policy": "downgrade_without_replacement",
"boundary": "Jaimini Karaka cross score may be supplied by a separate calculator; absent values default to neutral and never upgrade birth-time truth.",
},
{
"technique": "Vimsopaka Avastha Rectification",
"status": "partial",
"role": "cross_check_downgrade_only",
"conflict_policy": "downgrade_without_replacement",
"boundary": "Vimsopaka/Avastha cross score may be supplied by a separate calculator; absent values default to neutral and never upgrade birth-time truth.",
},
{
"technique": "Shadbala Ashtakavarga Rectification",
"status": "partial_observation",
"role": "observation_downgrade_only",
"weight_policy": "low_weight_only",
"conflict_policy": "downgrade_without_replacement",
"boundary": "Shadbala/Ashtakavarga formula and unit parity remain partial; observations cannot drive final rectification or truth claims.",
},
{
"technique": "Gochara Transit Rectification",
"status": "blocked_from_verified_timing",
"role": "observation_downgrade_only",
"holdout_gate": "negative_holdout_required",
"conflict_policy": "downgrade_without_replacement",
"boundary": "Gochara timing lacks independent negative-holdout validation; it can list exploratory triggers but cannot verify date/month timing claims.",
},
],
"next_round": next_round,
"next_round_questions": [question for question in unanswered if question.get("round") == next_round],
"applied_scoring": applied,
"unknown_question_ids": unknown_ids,
"invalid_answers": invalid_answers,
"boundary": "This narrows candidate clusters only; Narayana is a downgrade-only cross-check and does not convert candidates into birth-time truth.",
}
def main() -> int:
parser = argparse.ArgumentParser(description=__doc__)
parser.add_argument("--birth-time", required=True, help="Approximate local birth time, YYYY-MM-DD HH:MM")
scripts/jyotish_api_server.py
+9 -1
View File
@@ -6824,7 +6824,15 @@ class JyotishAPIHandler(BaseHTTPRequestHandler):
if not isinstance(answers, dict):
raise BadRequest('answers must be an object')
module = _load_local_module('active_rectification_questions')
result = module.score_answers(questionnaire, answers)
result = module.score_answers(
questionnaire,
answers,
narayana_cross_scores=body.get('narayana_cross_scores'),
jaimini_karaka_cross_scores=body.get('jaimini_karaka_cross_scores'),
vimsopaka_avastha_cross_scores=body.get('vimsopaka_avastha_cross_scores'),
shadbala_av_observation_scores=body.get('shadbala_av_observation_scores'),
gochara_transit_observation_scores=body.get('gochara_transit_observation_scores'),
)
return {
'success': True,
'endpoint': 'active_rectification_score',