# 安装Python 3.10+
conda create -n med-agent python=3.10
conda activate med-agent
# 安装核心依赖
pip install langgraph==0.1.0 transformers==4.40.0 torch==2.2.0 pysyft==0.8.0 fhir-parser==0.6.0
# 安装医疗知识库依赖
pip install pymilvus==2.3.0 sentence-transformers==2.2.2
# 安装合规审计依赖
pip install openelm-audit==0.3.0

# 启动FHIR标准数据库服务
docker run -d -p 8080:8080 hapiproject/hapi:latest
# 启动Milvus向量数据库（存储医学知识库）
docker run -d -p 19530:19530 milvusdb/milvus:v2.3.0
# 启动隐私计算节点
docker run -d -p 8081:8081 openmined/pysyft:latest

渲染错误: Mermaid 渲染失败: Parsing failed: Lexer error on line 2, column 11: unexpected character: ->应<- at offset: 28, skipped 3 characters. Lexer error on line 2, column 21: unexpected character: ->[<- at offset: 38, skipped 5 characters. Lexer error on line 3, column 17: unexpected character: ->患<- at offset: 60, skipped 5 characters. Lexer error on line 3, column 30: unexpected character: ->[<- at offset: 73, skipped 7 characters. Lexer error on line 3, column 41: unexpected character: ->应<- at offset: 84, skipped 3 characters. Lexer error on line 4, column 17: unexpected character: ->医<- at offset: 104, skipped 4 characters. Lexer error on line 4, column 29: unexpected character: ->[<- at offset: 116, skipped 6 characters. Lexer error on line 4, column 39: unexpected character: ->应<- at offset: 126, skipped 3 characters. Lexer error on line 5, column 17: unexpected character: ->监<- at offset: 146, skipped 4 characters. Lexer error on line 5, column 29: unexpected character: ->[<- at offset: 158, skipped 6 characters. Lexer error on line 5, column 39: unexpected character: ->应<- at offset: 168, skipped 3 characters. Lexer error on line 6, column 18: unexpected character: ->管<- at offset: 189, skipped 3 characters. Lexer error on line 6, column 28: unexpected character: ->[<- at offset: 199, skipped 1 characters. Lexer error on line 6, column 36: unexpected character: ->管<- at offset: 207, skipped 4 characters. Lexer error on line 7, column 22: unexpected character: ->注<- at offset: 233, skipped 4 characters. Lexer error on line 7, column 34: unexpected character: ->[<- at offset: 245, skipped 1 characters. Lexer error on line 7, column 40: unexpected character: ->注<- at offset: 251, skipped 5 characters. Lexer error on line 7, column 56: unexpected character: ->管<- at offset: 267, skipped 3 characters. Lexer error on line 8, column 17: unexpected character: ->合<- at offset: 287, skipped 6 characters. Lexer error on line 8, column 31: unexpected character: ->[<- at offset: 301, skipped 8 characters. Lexer error on line 8, column 50: unexpected character: ->管<- at offset: 320, skipped 3 characters. Lexer error on line 9, column 17: unexpected character: ->路<- at offset: 340, skipped 6 characters. Lexer error on line 9, column 31: unexpected character: ->[<- at offset: 354, skipped 8 characters. Lexer error on line 9, column 50: unexpected character: ->管<- at offset: 373, skipped 3 characters. Lexer error on line 10, column 17: unexpected character: ->上<- at offset: 393, skipped 7 characters. Lexer error on line 10, column 32: unexpected character: ->[<- at offset: 408, skipped 9 characters. Lexer error on line 10, column 52: unexpected character: ->管<- at offset: 428, skipped 3 characters. Lexer error on line 11, column 16: unexpected character: ->层<- at offset: 447, skipped 1 characters. Lexer error on line 11, column 24: unexpected character: ->[<- at offset: 455, skipped 1 characters. Lexer error on line 11, column 30: unexpected character: ->层<- at offset: 461, skipped 2 characters. Lexer error on line 12, column 17: unexpected character: ->交<- at offset: 480, skipped 2 characters. Lexer error on line 12, column 32: unexpected character: ->[<- at offset: 495, skipped 5 characters. Lexer error on line 12, column 42: unexpected character: ->]<- at offset: 505, skipped 1 characters. Lexer error on line 12, column 52: unexpected character: ->层<- at offset: 515, skipped 1 characters. Lexer error on line 13, column 17: unexpected character: ->诊<- at offset: 533, skipped 2 characters. Lexer error on line 13, column 32: unexpected character: ->[<- at offset: 548, skipped 3 characters. Lexer error on line 13, column 40: unexpected character: ->]<- at offset: 556, skipped 1 characters. Lexer error on line 13, column 50: unexpected character: ->层<- at offset: 566, skipped 1 characters. Lexer error on line 14, column 17: unexpected character: ->药<- at offset: 584, skipped 2 characters. Lexer error on line 14, column 32: unexpected character: ->[<- at offset: 599, skipped 3 characters. Lexer error on line 14, column 40: unexpected character: ->]<- at offset: 607, skipped 1 characters. Lexer error on line 14, column 50: unexpected character: ->层<- at offset: 617, skipped 1 characters. Lexer error on line 15, column 17: unexpected character: ->合<- at offset: 635, skipped 2 characters. Lexer error on line 15, column 32: unexpected character: ->[<- at offset: 650, skipped 3 characters. Lexer error on line 15, column 40: unexpected character: ->]<- at offset: 658, skipped 1 characters. Lexer error on line 15, column 50: unexpected character: ->层<- at offset: 668, skipped 1 characters. Lexer error on line 16, column 17: unexpected character: ->慢<- at offset: 686, skipped 4 characters. Lexer error on line 16, column 34: unexpected character: ->[<- at offset: 703, skipped 5 characters. Lexer error on line 16, column 44: unexpected character: ->]<- at offset: 713, skipped 1 characters. Lexer error on line 16, column 54: unexpected character: ->层<- at offset: 723, skipped 1 characters. Lexer error on line 17, column 11: unexpected character: ->数<- at offset: 735, skipped 3 characters. Lexer error on line 17, column 21: unexpected character: ->[<- at offset: 745, skipped 5 characters. Lexer error on line 18, column 21: unexpected character: ->数<- at offset: 771, skipped 3 characters. Lexer error on line 18, column 32: unexpected character: ->[<- at offset: 782, skipped 1 characters. Lexer error on line 18, column 37: unexpected character: ->标<- at offset: 787, skipped 6 characters. Lexer error on line 18, column 47: unexpected character: ->数<- at offset: 797, skipped 3 characters. Lexer error on line 19, column 17: unexpected character: ->医<- at offset: 817, skipped 5 characters. Lexer error on line 19, column 30: unexpected character: ->[<- at offset: 830, skipped 7 characters. Lexer error on line 19, column 41: unexpected character: ->数<- at offset: 841, skipped 3 characters. Lexer error on line 20, column 17: unexpected character: ->隐<- at offset: 861, skipped 6 characters. Lexer error on line 20, column 31: unexpected character: ->[<- at offset: 875, skipped 8 characters. Lexer error on line 20, column 43: unexpected character: ->数<- at offset: 887, skipped 3 characters. Lexer error on line 22, column 5: unexpected character: ->患<- at offset: 896, skipped 5 characters. Lexer error on line 22, column 15: unexpected character: ->路<- at offset: 906, skipped 6 characters. Lexer error on line 23, column 5: unexpected character: ->医<- at offset: 917, skipped 4 characters. Lexer error on line 23, column 14: unexpected character: ->路<- at offset: 926, skipped 6 characters. Lexer error on line 24, column 5: unexpected character: ->监<- at offset: 937, skipped 4 characters. Lexer error on line 24, column 14: unexpected character: ->合<- at offset: 946, skipped 6 characters. Lexer error on line 25, column 5: unexpected character: ->路<- at offset: 957, skipped 6 characters. Lexer error on line 25, column 21: unexpected character: ->注<- at offset: 973, skipped 4 characters. Lexer error on line 26, column 5: unexpected character: ->路<- at offset: 982, skipped 6 characters. Lexer error on line 26, column 16: unexpected character: ->上<- at offset: 993, skipped 7 characters. Lexer error on line 27, column 5: unexpected character: ->路<- at offset: 1005, skipped 6 characters. Lexer error on line 27, column 16: unexpected character: ->交<- at offset: 1016, skipped 2 characters. Lexer error on line 28, column 5: unexpected character: ->交<- at offset: 1028, skipped 2 characters. Lexer error on line 28, column 17: unexpected character: ->诊<- at offset: 1040, skipped 2 characters. Lexer error on line 29, column 5: unexpected character: ->诊<- at offset: 1052, skipped 2 characters. Lexer error on line 29, column 17: unexpected character: ->药<- at offset: 1064, skipped 2 characters. Lexer error on line 30, column 5: unexpected character: ->药<- at offset: 1076, skipped 2 characters. Lexer error on line 30, column 17: unexpected character: ->合<- at offset: 1088, skipped 2 characters. Lexer error on line 31, column 5: unexpected character: ->合<- at offset: 1100, skipped 2 characters. Lexer error on line 31, column 17: unexpected character: ->慢<- at offset: 1112, skipped 4 characters. Lexer error on line 32, column 5: unexpected character: ->慢<- at offset: 1126, skipped 4 characters. Lexer error on line 32, column 19: unexpected character: ->医<- at offset: 1140, skipped 4 characters. Lexer error on line 33, column 10: unexpected character: ->层<- at offset: 1154, skipped 1 characters. Lexer error on line 33, column 16: unexpected character: ->隐<- at offset: 1160, skipped 6 characters. Lexer error on line 34, column 5: unexpected character: ->隐<- at offset: 1171, skipped 6 characters. Lexer error on line 34, column 20: unexpected character: ->数<- at offset: 1186, skipped 3 characters. Lexer error on line 35, column 5: unexpected character: ->隐<- at offset: 1194, skipped 6 characters. Lexer error on line 35, column 16: unexpected character: ->医<- at offset: 1205, skipped 5 characters. Lexer error on line 36, column 5: unexpected character: ->合<- at offset: 1215, skipped 6 characters. Lexer error on line 36, column 21: unexpected character: ->层<- at offset: 1231, skipped 1 characters. Parse error on line 2, column 14: Expecting token of type 'ID' but found `(cloud)`. Parse error on line 3, column 22: Expecting token of type 'ID' but found `(server)`. Parse error on line 3, column 44: Expecting token of type 'ID' but found ` `. Parse error on line 4, column 21: Expecting token of type 'ID' but found `(server)`. Parse error on line 4, column 42: Expecting token of type 'ID' but found ` `. Parse error on line 5, column 21: Expecting token of type 'ID' but found `(server)`. Parse error on line 5, column 42: Expecting token of type 'ID' but found ` `. Parse error on line 6, column 29: Expecting: one of these possible Token sequences: 1. [NEWLINE] 2. [EOF] but found: 'Harness' Parse error on line 6, column 40: Expecting token of type ':' but found ` `. Parse error on line 7, column 35: Expecting: one of these possible Token sequences: 1. [NEWLINE] 2. [EOF] but found: 'Agent' Parse error on line 7, column 46: Expecting token of type ':' but found `in`. Parse error on line 8, column 23: Expecting token of type 'ID' but found `(server)`. Parse error on line 9, column 23: Expecting token of type 'ID' but found `(server)`. Parse error on line 10, column 24: Expecting token of type 'ID' but found `(server)`. Parse error on line 11, column 25: Expecting: one of these possible Token sequences: 1. [NEWLINE] 2. [EOF] but found: 'Agent' Parse error on line 11, column 32: Expecting token of type ':' but found ` `. Parse error on line 12, column 37: Expecting: one of these possible Token sequences: 1. [NEWLINE] 2. [EOF] but found: 'Agent' Parse error on line 12, column 44: Expecting token of type ':' but found `in`. Parse error on line 13, column 35: Expecting: one of these possible Token sequences: 1. [NEWLINE] 2. [EOF] but found: 'Agent' Parse error on line 13, column 42: Expecting token of type ':' but found `in`. Parse error on line 14, column 35: Expecting: one of these possible Token sequences: 1. [NEWLINE] 2. [EOF] but found: 'Agent' Parse error on line 14, column 42: Expecting token of type ':' but found `in`. Parse error on line 15, column 35: Expecting: one of these possible Token sequences: 1. [NEWLINE] 2. [EOF] but found: 'Agent' Parse error on line 15, column 42: Expecting token of type ':' but found `in`. Parse error on line 16, column 39: Expecting: one of these possible Token sequences: 1. [NEWLINE] 2. [EOF] but found: 'Agent' Parse error on line 16, column 46: Expecting token of type ':' but found `in`. Parse error on line 17, column 14: Expecting token of type 'ID' but found `(cloud)`. Parse error on line 18, column 33: Expecting: one of these possible Token sequences: 1. [NEWLINE] 2. [EOF] but found: 'FHIR' Parse error on line 18, column 44: Expecting token of type ':' but found `in`. Parse error on line 19, column 22: Expecting token of type 'ID' but found `(server)`. Parse error on line 19, column 44: Expecting token of type 'ID' but found ` `. Parse error on line 20, column 23: Expecting token of type 'ID' but found `(server)`. Parse error on line 20, column 46: Expecting token of type 'ID' but found ` `. Parse error on line 22, column 11: Expecting token of type 'EOF' but found `--`. Parse error on line 23, column 10: Expecting token of type 'EOF' but found `--`. Parse error on line 24, column 10: Expecting token of type 'EOF' but found `--`. Parse error on line 25, column 12: Expecting token of type 'EOF' but found `--`. Parse error on line 25, column 25: Expecting token of type ':' but found ` `. Parse error on line 26, column 12: Expecting token of type 'EOF' but found `--`. Parse error on line 27, column 12: Expecting token of type 'EOF' but found `--`. Parse error on line 27, column 23: Expecting token of type ':' but found ` `. Parse error on line 28, column 13: Expecting token of type ':' but found `--`. Parse error on line 28, column 19: Expecting token of type 'ARROW_DIRECTION' but found `Agent`. Parse error on line 29, column 13: Expecting token of type ':' but found `--`. Parse error on line 29, column 19: Expecting token of type 'ARROW_DIRECTION' but found `Agent`. Parse error on line 30, column 13: Expecting token of type ':' but found `--`. Parse error on line 30, column 19: Expecting token of type 'ARROW_DIRECTION' but found `Agent`. Parse error on line 31, column 13: Expecting token of type ':' but found `--`. Parse error on line 31, column 21: Expecting token of type 'ARROW_DIRECTION' but found `Agent`. Parse error on line 32, column 15: Expecting token of type ':' but found `--`. Parse error on line 32, column 23: Expecting token of type 'ARROW_DIRECTION' but found ` `. Parse error on line 33, column 12: Expecting token of type ':' but found `--`. Parse error on line 33, column 22: Expecting token of type 'ARROW_DIRECTION' but found ` `. Parse error on line 34, column 12: Expecting token of type 'EOF' but found `--`. Parse error on line 34, column 23: Expecting token of type ':' but found ` `. Parse error on line 35, column 12: Expecting token of type 'EOF' but found `--`. Parse error on line 36, column 12: Expecting token of type 'EOF' but found `--`. Parse error on line 36, column 22: Expecting token of type ':' but found ` `.

渲染错误: Mermaid 渲染失败: Parse error on line 7: ...--> F[计算多Agent投票置信度P(R)] F --> G{P(R -----------------------^ Expecting 'SQE', 'DOUBLECIRCLEEND', 'PE', '-)', 'STADIUMEND', 'SUBROUTINEEND', 'PIPE', 'CYLINDEREND', 'DIAMOND_STOP', 'TAGEND', 'TRAPEND', 'INVTRAPEND', 'UNICODE_TEXT', 'TEXT', 'TAGSTART', got 'PS'

from langgraph.graph import StateGraph, END
from typing import TypedDict, List, Optional
from agents import PatientInteractionAgent, DiagnosisAgent, PharmacyAgent, ComplianceAgent, ChronicDiseaseManagerAgent

# 定义诊疗流程状态
class DiagnosisState(TypedDict):
    patient_id: str
    symptoms: List[str]
    medical_history: Optional[dict]
    diagnosis_results: List[dict]
    confidence: float
    medication_suggestion: Optional[dict]
    compliance_score: float
    doctor_review: Optional[dict]
    follow_up_plan: Optional[dict]

# 初始化Harness调度器
class MedAgentHarness:
    def __init__(self):
        self.workflow = StateGraph(DiagnosisState)
        self._register_nodes()
        self._register_edges()
        self.app = self.workflow.compile()
    
    def _register_nodes(self):
        # 注册所有Agent节点
        self.workflow.add_node("interaction_agent", PatientInteractionAgent().run)
        self.workflow.add_node("diagnosis_agent_group", self._run_diagnosis_group)
        self.workflow.add_node("pharmacy_agent", PharmacyAgent().run)
        self.workflow.add_node("compliance_agent", ComplianceAgent().run)
        self.workflow.add_node("chronic_agent", ChronicDiseaseManagerAgent().run)
        self.workflow.add_node("doctor_review", self._wait_for_doctor_review)
    
    def _run_diagnosis_group(self, state: DiagnosisState) -> DiagnosisState:
        # 调用3个不同的诊断Agent生成结果
        agents = [DiagnosisAgent(version="v1"), DiagnosisAgent(version="v2"), DiagnosisAgent(version="ens")]
        results = [agent.run(state) for agent in agents]
        # 计算置信度
        total_weight = sum([res["weight"] for res in results])
        max_diagnosis = max(results, key=lambda x: x["score"] * x["weight"])
        confidence = (max_diagnosis["score"] * max_diagnosis["weight"]) / total_weight
        return {**state, "diagnosis_results": results, "confidence": confidence}
    
    def _register_edges(self):
        self.workflow.set_entry_point("interaction_agent")
        # 病史采集完成后进入诊断组
        self.workflow.add_edge("interaction_agent", "diagnosis_agent_group")
        # 置信度判断
        self.workflow.add_conditional_edges(
            "diagnosis_agent_group",
            lambda x: "diagnosis_agent_group" if x["confidence"] < 0.85 else "pharmacy_agent"
        )
        self.workflow.add_edge("pharmacy_agent", "compliance_agent")
        # 合规判断
        self.workflow.add_conditional_edges(
            "compliance_agent",
            lambda x: "diagnosis_agent_group" if x["compliance_score"] < 0.95 else "doctor_review"
        )
        # 医生复核后生成随访计划
        self.workflow.add_conditional_edges(
            "doctor_review",
            lambda x: END if x["doctor_review"]["approved"] else "diagnosis_agent_group"
        )
        self.workflow.add_edge("doctor_review", "chronic_agent")
        self.workflow.add_edge("chronic_agent", END)
    
    def run(self, patient_id: str, symptoms: List[str]) -> dict:
        initial_state = {"patient_id": patient_id, "symptoms": symptoms, "confidence": 0.0, "compliance_score": 0.0}
        result = self.app.invoke(initial_state)
        # 存储审计日志
        self._save_audit_log(result)
        return result

from openelm_audit import AuditClient
from knowledge_base import MedicalKnowledgeBase

class ComplianceAgent:
    def __init__(self):
        self.audit_client = AuditClient()
        self.kb = MedicalKnowledgeBase()
        # 加载诊疗指南规则
        self.rules = self.kb.load_clinical_guidelines(["hypertension", "diabetes", "copd"])
    
    def run(self, state: DiagnosisState) -> DiagnosisState:
        diagnosis = state["diagnosis_results"][0]
        medication = state["medication_suggestion"]
        # 1. 校验诊断是否符合诊疗指南
        guideline_match = self.audit_client.match_guideline(diagnosis, self.rules)
        # 2. 校验是否存在药物禁忌
        contraindication = self.audit_client.check_contraindication(medication, state["medical_history"])
        # 3. 校验诊断是否有可解释依据
        explainable = self.audit_client.check_explainability(diagnosis)
        # 计算合规得分
        compliance_score = 0.4 * guideline_match + 0.3 * (1 - contraindication) + 0.3 * explainable
        return {**state, "compliance_score": compliance_score}