\n| ecm_adapter.py<\/td>\n | \u67e5\u8be2\u6587\u4ef6\u5143\u4fe1\u606f\u3001\u9884\u89c8\u6587\u672c\u5185\u5bb9<\/td>\n | \u901a\u8fc7 FileNet Content Engine \u6216 IBM CMIS API<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n2.MCP Server \u9879\u76ee\u7ed3\u6784\u66f4\u65b0<\/h4>\nmcp_server\/
\n\u251c\u2500\u2500 main.py
\n\u251c\u2500\u2500 config.py
\n\u251c\u2500\u2500 db_adapter.py
\n\u251c\u2500\u2500 file_adapter.py
\n\u251c\u2500\u2500 bpm_adapter.py \u2705 IBM BPM \u8bbf\u95ee\u6a21\u5757
\n\u251c\u2500\u2500 ecm_adapter.py \u2705 IBM ECM \u8bbf\u95ee\u6a21\u5757
\n\u251c\u2500\u2500 auth.py
\n\u251c\u2500\u2500 requirements.txt<\/p>\n 3.IBM BPM \u63a5\u5165\u6a21\u5757\u793a\u4f8b（bpm_adapter.py）<\/h4>\n\u5047\u8bbe BPM \u4f7f\u7528 Business Automation Workflow，\u652f\u6301 REST \u63a5\u53e3<\/p>\n # bpm_adapter.py
\nimport requests
\nfrom config import BPM_API_BASE, BPM_AUTH<\/p>\n def get_bpm_process_info(process_id: str):
\n try:
\n url = f"{BPM_API_BASE}\/rest\/bpm\/wle\/v1\/process\/{process_id}"
\n headers = {"Authorization": f"Basic {BPM_AUTH}"}
\n resp = requests.get(url, headers=headers, timeout=10)
\n data = resp.json()<\/p>\n if data.get("status") != "200":
\n return f"\u6d41\u7a0b\u67e5\u8be2\u5931\u8d25：{data.get('statusReason')}"<\/p>\n instance = data["data"]["processInstance"]
\n return {
\n "\u6d41\u7a0bID": instance["piid"],
\n "\u72b6\u6001": instance["executionState"],
\n "\u6d41\u7a0b\u56fe": instance["bpdName"],
\n "\u5f53\u524d\u73af\u8282": instance["activities"]
\n }<\/p>\n except Exception as e:
\n return f"\u8fde\u63a5 BPM \u5931\u8d25：{e}"<\/p>\n 4.IBM ECM \u63a5\u5165\u6a21\u5757\u793a\u4f8b（ecm_adapter.py）<\/h4>\n\u5047\u8bbe ECM \u4f7f\u7528 FileNet P8，\u652f\u6301 REST \u6216 CMIS \u63a5\u53e3<\/p>\n # ecm_adapter.py
\nimport requests
\nfrom config import ECM_API_BASE, ECM_AUTH<\/p>\n def get_document_metadata(doc_id: str):
\n try:
\n url = f"{ECM_API_BASE}\/wsi\/FNCEWS40MTOM\/"
\n headers = {
\n "Authorization": f"Basic {ECM_AUTH}",
\n "Content-Type": "application\/soap+xml"
\n }<\/p>\n # \u5b9e\u9645\u8c03\u7528\u4e2d\u8fd9\u91cc\u8981\u5199 SOAP \u8bf7\u6c42\u4f53\u6216 CMIS \u8bf7\u6c42\u4f53，\u8fd9\u91cc\u7b80\u5316：
\n # \u7528 CMIS \u7684\u8bdd\u53ef\u76f4\u63a5\u7528 atom\/xml \u8bfb\u53d6
\n # \u53ef\u66ff\u6362\u4e3a requests.get(…)<\/p>\n # \u793a\u4f8b\u7b80\u5316\u8fd4\u56de
\n return {
\n "\u6587\u6863ID": doc_id,
\n "\u6587\u4ef6\u540d": "\u9500\u552e\u5408\u540c.docx",
\n "\u521b\u5efa\u4eba": "\u5f20\u4e09",
\n "\u521b\u5efa\u65f6\u95f4": "2024-11-02",
\n "\u6807\u7b7e": ["\u5408\u540c", "\u5ba2\u6237A"]
\n }<\/p>\n except Exception as e:
\n return f"\u8fde\u63a5 ECM \u5931\u8d25：{e}"<\/p>\n 5. MCP Server \u6269\u5c55\u5de5\u5177\u63a5\u53e3（main.py）<\/h4>\nfrom bpm_adapter import get_bpm_process_info
\nfrom ecm_adapter import get_document_metadata<\/p>\n @app.post("\/context\/v1\/query")
\nasync def handle_query(
\n req: MCPRequest,
\n request: Request,
\n auth: None = Depends(verify_api_key)
\n):
\n tools = req.context.get("tools", [])
\n query = req.input.strip()<\/p>\n if "read_nfs_file" in tools:
\n return {"output": read_file_from_nfs(query)}<\/p>\n elif "query_bpm" in tools:
\n return {"output": get_bpm_process_info(query)}<\/p>\n elif "query_ecm" in tools:
\n return {"output": get_document_metadata(query)}<\/p>\n return {"output": "\u4e0d\u652f\u6301\u7684\u5de5\u5177\u8c03\u7528"}<\/p>\n \u00a06.\u793a\u4f8b\u8c03\u7528<\/h4>\n\u67e5\u8be2 BPM \u6d41\u7a0b\u72b6\u6001：<\/h5>\ncurl -X POST http:\/\/localhost:3333\/context\/v1\/query \\\\
\n -H "Content-Type: application\/json" \\\\
\n -H "x-api-key: abc123xyz" \\\\
\n -d '{
\n "input": "12345",
\n "context": {
\n "tools": ["query_bpm"]
\n }
\n }'<\/p>\n \u67e5\u8be2 ECM \u6587\u6863\u5143\u6570\u636e：<\/h5>\ncurl -X POST http:\/\/localhost:3333\/context\/v1\/query \\\\
\n -H "Content-Type: application\/json" \\\\
\n -H "x-api-key: abc123xyz" \\\\
\n -d '{
\n "input": "doc-20240101001",
\n "context": {
\n "tools": ["query_ecm"]
\n }
\n }'<\/p>\n 7\u3001IBM ECM \u4e2d\u6587\u5168\u6587\u63d0\u53d6\u6a21\u5757<\/h3>\n\u00a0\u5b9e\u73b0 IBM ECM \u4e2d\u6587\u5168\u6587\u63d0\u53d6\u6a21\u5757，\u652f\u6301\u5c06 ECM \u4e2d\u6587\u6587\u6863\u5185\u5bb9\u63d0\u53d6\u51fa\u6765\u4f9b AI \u5206\u6790，\u6bd4\u5982\u7528\u4e8e：<\/p>\n \n- \n
🤖 \u591a\u667a\u80fd\u4f53\u57fa\u4e8e\u6587\u6863\u751f\u6210\u62a5\u544a\/\u56de\u7b54\u95ee\u9898<\/p>\n<\/li>\n - \n
🔎 LangChain + Claude \u8fdb\u884c\u95ee\u7b54\u5206\u6790<\/p>\n<\/li>\n - \n
📄 \u5168\u6587\u7d22\u5f15\u7528\u4e8e\u77e5\u8bc6\u5e93\u6784\u5efa\u00a0<\/p>\n<\/li>\n<\/ul>\n 1.\u573a\u666f\u8bf4\u660e<\/h4>\n\u5047\u8bbe\u4f60\u4f7f\u7528\u7684\u662f IBM FileNet P8 \u6216\u517c\u5bb9 ECM \u7cfb\u7edf，\u63d0\u4f9b\u4e86\u5982\u4e0b\u65b9\u5f0f\u8bbf\u95ee\u6587\u4ef6：<\/p>\n - \n
\u2705 REST \u6216 CMIS \u63a5\u53e3\u53ef\u4e0b\u8f7d\u6587\u6863\u6587\u4ef6（PDF\u3001Word \u7b49）<\/p>\n<\/li>\n - \n
\u2705 \u6587\u6863\u4ee5\u6587\u4ef6\u6d41\u5f62\u5f0f\u8fd4\u56de，\u9700\u4fdd\u5b58\/\u89e3\u6790<\/p>\n<\/li>\n - \n
\u2705 \u4e2d\u6587\u5185\u5bb9\u63d0\u53d6\u9700\u8981：<\/p>\n \n- \n
PDF：\u7528 pdfplumber \/ PyMuPDF<\/p>\n<\/li>\n - \n
Word：\u7528 python-docx<\/p>\n<\/li>\n - \n
\u56fe\u7247\u6216\u626b\u63cf PDF：\u53ef\u9009 OCR：pytesseract \/ PaddleOCR\u00a0<\/p>\n<\/li>\n<\/ul>\n<\/li>\n 2.\u66f4\u65b0\u9879\u76ee\u7ed3\u6784（\u65b0\u589e\u6a21\u5757）<\/h4>\nmcp_server\/
\n\u251c\u2500\u2500 ecm_adapter.py \u2705 ECM \u4e2d\u6587\u63d0\u53d6\u903b\u8f91
\n\u251c\u2500\u2500 utils\/
\n\u2502 \u2514\u2500\u2500 extract_text.py \u2705 \u6587\u4ef6\u7c7b\u578b\u8bc6\u522b + \u4e2d\u6587\u63d0\u53d6\u5de5\u5177<\/p>\n 3.\u6587\u4ef6\u5185\u5bb9\u63d0\u53d6\u5de5\u5177（utils\/extract_text.py）<\/h4>\n# utils\/extract_text.py
\nimport os
\nimport pdfplumber
\nimport docx
\nfrom pathlib import Path<\/p>\n def extract_text_from_file(file_path: str) -> str:
\n suffix = Path(file_path).suffix.lower()<\/p>\n if suffix == ".pdf":
\n return extract_text_from_pdf(file_path)
\n elif suffix in [".doc", ".docx"]:
\n return extract_text_from_docx(file_path)
\n else:
\n return f"\u6682\u4e0d\u652f\u6301\u7684\u6587\u4ef6\u7c7b\u578b：{suffix}"<\/p>\n def extract_text_from_pdf(path):
\n try:
\n text = ""
\n with pdfplumber.open(path) as pdf:
\n for page in pdf.pages:
\n text += page.extract_text() + "\\\\n"
\n return text.strip() or "\u672a\u63d0\u53d6\u5230\u6587\u672c，\u53ef\u80fd\u662f\u626b\u63cf\u4ef6"
\n except Exception as e:
\n return f"PDF \u63d0\u53d6\u5931\u8d25: {e}"<\/p>\n def extract_text_from_docx(path):
\n try:
\n doc = docx.Document(path)
\n return "\\\\n".join([para.text for para in doc.paragraphs]).strip()
\n except Exception as e:
\n return f"Word \u63d0\u53d6\u5931\u8d25: {e}"<\/p>\n 4.\u66f4\u65b0 ECM \u63a5\u53e3（ecm_adapter.py）<\/h4>\n# ecm_adapter.py
\nimport requests
\nimport tempfile
\nfrom config import ECM_API_BASE, ECM_AUTH
\nfrom utils.extract_text import extract_text_from_file<\/p>\n def get_document_content(doc_id: str):
\n try:
\n # \u6a21\u62df\u4ece ECM \u4e0b\u8f7d\u6587\u4ef6
\n url = f"{ECM_API_BASE}\/download\/{doc_id}"
\n headers = {"Authorization": f"Basic {ECM_AUTH}"}
\n response = requests.get(url, headers=headers, timeout=10)<\/p>\n if response.status_code != 200:
\n return f"\u4e0b\u8f7d\u5931\u8d25：{response.status_code}"<\/p>\n # \u4e34\u65f6\u4fdd\u5b58\u6587\u4ef6
\n suffix = get_suffix_from_header(response)
\n with tempfile.NamedTemporaryFile(delete=False, suffix=suffix) as tmp:
\n tmp.write(response.content)
\n tmp_path = tmp.name<\/p>\n # \u63d0\u53d6\u5185\u5bb9
\n return extract_text_from_file(tmp_path)<\/p>\n except Exception as e:
\n return f"\u83b7\u53d6\u6587\u6863\u5931\u8d25：{e}"<\/p>\n def get_suffix_from_header(response):
\n ctype = response.headers.get("Content-Type", "")
\n if "pdf" in ctype:
\n return ".pdf"
\n elif "word" in ctype:
\n return ".docx"
\n else:
\n return ".bin"<\/p>\n 5. \u5728 main.py \u6ce8\u518c\u65b0\u5de5\u5177<\/h4>\nfrom ecm_adapter import get_document_metadata, get_document_content<\/p>\n # \u65b0\u5de5\u5177\u63a5\u5165
\nelif "read_ecm_content" in tools:
\n return {"output": get_document_content(query)}<\/p>\n 6. \u793a\u4f8b\u8c03\u7528：<\/h4>\ncurl http:\/\/localhost:3333\/context\/v1\/query \\\\
\n -H "Content-Type: application\/json" \\\\
\n -H "x-api-key: abc123xyz" \\\\
\n -d '{
\n "input": "doc-20240101-\u5408\u540cABC",
\n "context": {
\n "tools": ["read_ecm_content"]
\n }
\n }'<\/p>\n 8\u3001ECM + BPM \u8054\u52a8\u6a21\u5757\u6784\u5efa<\/h2>\nECM + BPM \u8054\u52a8\u6a21\u5757\u6784\u5efa，\u8fd9\u662f\u5b9e\u73b0\u667a\u80fd\u5316\u4e1a\u52a1\u6d41\u7a0b\u5206\u6790\u3001\u6587\u6863\u9a71\u52a8\u5ba1\u6279\u3001Agent \u81ea\u52a8\u8f85\u52a9\u51b3\u7b56\u7684\u6838\u5fc3\u80fd\u529b\u3002<\/p>\n 1.\u76ee\u6807\u8bf4\u660e：\u4ec0\u4e48\u662f ECM + BPM \u8054\u52a8？<\/h3>\n\u300c\u6d41\u7a0b + \u6587\u6863\u300d\u8054\u52a8 = \u7ed3\u5408\u6d41\u7a0b\u72b6\u6001\u548c\u7ed1\u5b9a\u6587\u6863，\u6784\u5efa\u5b8c\u6574\u4e1a\u52a1\u4e0a\u4e0b\u6587\u3002<\/p>\n 2.\u793a\u4f8b\u573a\u666f<\/h3>\n\n\u573a\u666fBPM \u63d0\u4f9bECM \u63d0\u4f9b\u8054\u52a8\u6548\u679c<\/tr>\n \n\n| \u5408\u540c\u5ba1\u6279<\/td>\n | \u5f53\u524d\u6d41\u7a0b\u72b6\u6001\u3001\u5904\u7406\u4eba\u3001\u8282\u70b9<\/td>\n | \u5408\u540c\u539f\u6587\u5185\u5bb9\u3001\u521b\u5efa\u4eba<\/td>\n | \u81ea\u52a8\u751f\u6210\u5ba1\u6279\u6458\u8981\u3001\u667a\u80fd\u8f85\u52a9\u51b3\u7b56<\/td>\n<\/tr>\n | \n| \u6863\u6848\u5f52\u6863<\/td>\n | \u6d41\u7a0b\u5386\u53f2\u3001\u64cd\u4f5c\u8bb0\u5f55<\/td>\n | \u5bf9\u5e94\u626b\u63cf\u4ef6<\/td>\n | \u6d41\u7a0b + \u6587\u4ef6\u8054\u5408\u751f\u6210\u5f52\u6863\u8bb0\u5f55<\/td>\n<\/tr>\n | \n| \u6295\u8bc9\u5904\u7406<\/td>\n | \u6295\u8bc9\u6d41\u7a0b\u8fdb\u5ea6<\/td>\n | \u6295\u8bc9\u6750\u6599\u3001\u804a\u5929\u8bb0\u5f55<\/td>\n | \u591a\u6a21\u6001\u4fe1\u606f\u805a\u5408\u3001AI \u62a5\u544a\u5206\u6790<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n3.\u7cfb\u7edf\u7ed3\u6784\u56fe<\/h3>\n Claude \/ LangChain Agent
\n \u2502
\n \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2534\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
\n \u2502 MCP Server \u2502
\n \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u252c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518
\n \u2502
\n \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u252c\u2500\u2534\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
\n \u2502 BPM\u6a21\u5757 \u2502 ECM\u6a21\u5757 \u2502
\n \u2502 get_bpm_process_info() \u2502
\n \u2502 + get_linked_documents() \u2502
\n \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u252c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u252c\u2500\u2500\u2500\u2500\u2518
\n \u2502 \u2502
\n \u83b7\u53d6\u6d41\u7a0b\u4fe1\u606f \u83b7\u53d6\u6d41\u7a0b\u7ed1\u5b9a\u6587\u6863 \u2192 \u63d0\u53d6\u5168\u6587<\/p>\n 4.BPM \u8fd4\u56de\u7ed1\u5b9a\u6587\u6863 ID<\/h3>\n\u5728 bpm_adapter.py \u4e2d\u6269\u5c55\u51fd\u6570，\u5047\u8bbe\u67d0\u4e9b\u8282\u70b9\u5e26\u6709\u7ed1\u5b9a\u6587\u6863：<\/p>\n def get_bpm_process_info(process_id: str):
\n …
\n instance = data["data"]["processInstance"]
\n linked_docs = []<\/p>\n for act in instance.get("activities", []):
\n # \u5047\u8bbe\u9644\u52a0\u5c5e\u6027\u4e2d\u5b58\u653e\u6587\u6863 ID
\n doc_id = act.get("attachedDocumentId")
\n if doc_id:
\n linked_docs.append(doc_id)<\/p>\n return {
\n "\u6d41\u7a0bID": instance["piid"],
\n "\u72b6\u6001": instance["executionState"],
\n "\u6d41\u7a0b\u56fe": instance["bpdName"],
\n "\u5f53\u524d\u73af\u8282": instance["activities"],
\n "\u6587\u6863\u5217\u8868": linked_docs
\n }<\/p>\n 5.ECM \u63d0\u4f9b\u5185\u5bb9\u63d0\u53d6<\/h3>\n\u4f7f\u7528\u524d\u9762\u5199\u597d\u7684 get_document_content(doc_id) \u65b9\u6cd5，\u4f9d\u6b21\u63d0\u53d6\u8fd9\u4e9b\u6587\u6863\u3002<\/p>\n 6.\u8054\u52a8\u51fd\u6570：get_bpm_with_documents(process_id)<\/h3>\n\u653e\u5728 mcp_server\/bpm_ecm_combined.py：<\/p>\n # bpm_ecm_combined.py
\nfrom bpm_adapter import get_bpm_process_info
\nfrom ecm_adapter import get_document_content<\/p>\n def get_bpm_with_documents(process_id: str):
\n bpm_info = get_bpm_process_info(process_id)<\/p>\n if isinstance(bpm_info, str):
\n return f"BPM\u67e5\u8be2\u5931\u8d25：{bpm_info}"<\/p>\n docs = bpm_info.get("\u6587\u6863\u5217\u8868", [])
\n doc_contents = []<\/p>\n for doc_id in docs:
\n content = get_document_content(doc_id)
\n doc_contents.append({
\n "\u6587\u6863ID": doc_id,
\n "\u5185\u5bb9": content[:1000] # \u9650\u5236\u5185\u5bb9\u957f\u5ea6
\n })<\/p>\n return {
\n "\u6d41\u7a0b\u4fe1\u606f": bpm_info,
\n "\u6587\u6863\u5185\u5bb9": doc_contents
\n }<\/p>\n 7.\u5728 main.py \u4e2d\u66b4\u9732\u5de5\u5177\u8c03\u7528\u63a5\u53e3<\/h3>\nfrom bpm_ecm_combined import get_bpm_with_documents<\/p>\n @app.post("\/context\/v1\/query")
\nasync def handle_query(…):
\n …<\/p>\n elif "bpm_with_doc" in tools:
\n return {"output": get_bpm_with_documents(query)}<\/p>\n 8.\u793a\u4f8b\u8c03\u7528\u65b9\u5f0f<\/h3>\ncurl -X POST http:\/\/localhost:3333\/context\/v1\/query \\\\
\n -H "Content-Type: application\/json" \\\\
\n -H "x-api-key: abc123xyz" \\\\
\n -d '{
\n "input": "\u6d41\u7a0bID: process-abc-001",
\n "context": {
\n "tools": ["bpm_with_doc"]
\n }
\n }'<\/p>\n 9\u3001\u81ea\u52a8\u751f\u6210\u3010\u6d41\u7a0b+\u6587\u6863\u3011\u6458\u8981\u5e76\u8fd4\u56de<\/h2>\n\u81ea\u52a8\u751f\u6210\u3010\u6d41\u7a0b + \u6587\u6863\u3011\u6458\u8981\u5e76\u8fd4\u56de\u529f\u80fd，\u8ba9 Claude \/ GPT \u7b49 AI Agent \u5728\u638c\u63e1\u6d41\u7a0b\u72b6\u6001\u548c\u7ed1\u5b9a\u6587\u6863\u5185\u5bb9\u540e，\u751f\u6210\u4e00\u6bb5\u6e05\u6670\u3001\u4e13\u4e1a\u7684\u4e2d\u6587\u6458\u8981\u3002\u8fd9\u662f\u591a\u667a\u80fd\u4f53\u5e94\u7528\u4e2d\u7684\u5173\u952e\u7b2c\u4e00\u6b65！🚀<\/p>\n 1.\u529f\u80fd\u76ee\u6807<\/h3>\n\u7ed9\u5b9a\u4e00\u4e2a\u6d41\u7a0b ID，\u7cfb\u7edf\u81ea\u52a8：<\/p>\n - \n
\u83b7\u53d6\u6d41\u7a0b\u4fe1\u606f（BPM）<\/p>\n<\/li>\n - \n
\u83b7\u53d6\u7ed1\u5b9a\u6587\u6863\u5185\u5bb9（ECM）<\/p>\n<\/li>\n - \n
\u62fc\u63a5\u4e0a\u4e0b\u6587，\u8c03\u7528 Claude \/ GPT \u63a5\u53e3\u751f\u6210\u6458\u8981 \u2705 \u6700\u7ec8\u8fd4\u56de\u7ed3\u6784\u5316\u7684\u6458\u8981\u6587\u672c（\u53ef\u7528\u4e8e\u5ba1\u6279\u3001\u5f52\u6863\u3001\u5c55\u793a\u7b49）<\/p>\n<\/li>\n 2. \u67b6\u6784\u66f4\u65b0（\u65b0\u589e AI \u6458\u8981\u6a21\u5757）<\/h3>\nmcp_server\/
\n\u251c\u2500\u2500 bpm_adapter.py
\n\u251c\u2500\u2500 ecm_adapter.py
\n\u251c\u2500\u2500 bpm_ecm_combined.py
\n\u251c\u2500\u2500 summarizer.py \u2705 \u65b0\u589e：\u81ea\u52a8\u6458\u8981\u6a21\u5757<\/p>\n 3. \u6784\u5efa\u6458\u8981\u751f\u6210\u6a21\u5757（summarizer.py）<\/h3>\n# summarizer.py
\nimport os
\nimport openai # \u4e5f\u53ef\u63a5 Claude API \u6216\u672c\u5730 LLM<\/p>\n openai.api_key = os.getenv("OPENAI_API_KEY")<\/p>\n def generate_summary(bpm_info: dict, doc_contents: list) -> str:
\n # \u62fc\u63a5\u4e0a\u4e0b\u6587\u5185\u5bb9
\n context_text = "\u3010\u6d41\u7a0b\u4fe1\u606f\u3011\\\\n"
\n context_text += f"\u6d41\u7a0b\u540d\u79f0：{bpm_info['\u6d41\u7a0b\u56fe']}\\\\n"
\n context_text += f"\u5f53\u524d\u72b6\u6001：{bpm_info['\u72b6\u6001']}\\\\n"
\n context_text += "\u6d41\u7a0b\u8282\u70b9：\\\\n"
\n for act in bpm_info["\u5f53\u524d\u73af\u8282"]:
\n context_text += f" – {act['name']}（\u72b6\u6001：{act['state']}）\\\\n"<\/p>\n context_text += "\\\\n\u3010\u6587\u6863\u6458\u8981\u3011\\\\n"
\n for doc in doc_contents:
\n context_text += f"\\\\n\u6587\u6863 ID：{doc['\u6587\u6863ID']}\\\\n"
\n context_text += doc["\u5185\u5bb9"][:1000] + "\\\\n" # \u63a7\u5236\u957f\u5ea6<\/p>\n # \u5b9a\u4e49 Prompt
\n prompt = f"""\u4f60\u662f\u4f01\u4e1a\u6d41\u7a0b\u6587\u6863\u4e13\u5bb6，\u8bf7\u9605\u8bfb\u4e0b\u5217\u4fe1\u606f，\u8f93\u51fa\u4e00\u6bb5\u4e2d\u6587\u6458\u8981，\u8981\u6c42\u91cd\u70b9\u6e05\u6670\u3001\u8868\u8fbe\u7b80\u7ec3：
\n{context_text}
\n==>
\n\u8bf7\u7528\u4e2d\u6587\u8f93\u51fa\u6458\u8981："""<\/p>\n # \u8c03\u7528 OpenAI API
\n try:
\n response = openai.ChatCompletion.create(
\n model="gpt-4", # \u53ef\u6539\u4e3a gpt-3.5 \/ Claude \/ \u672c\u5730 LLM
\n messages=[{"role": "user", "content": prompt}],
\n temperature=0.3,
\n max_tokens=512,
\n )
\n return response.choices[0].message.content.strip()
\n except Exception as e:
\n return f"AI \u751f\u6210\u6458\u8981\u5931\u8d25：{e}"<\/p>\n 4.\u8054\u52a8\u8c03\u7528（\u5728 bpm_ecm_combined.py \u4e2d\u5c01\u88c5）<\/h3>\n# bpm_ecm_combined.py
\nfrom summarizer import generate_summary<\/p>\n def get_bpm_with_summary(process_id: str):
\n bpm_info = get_bpm_process_info(process_id)
\n if isinstance(bpm_info, str):
\n return f"BPM\u67e5\u8be2\u5931\u8d25：{bpm_info}"<\/p>\n docs = bpm_info.get("\u6587\u6863\u5217\u8868", [])
\n doc_contents = []
\n for doc_id in docs:
\n content = get_document_content(doc_id)
\n doc_contents.append({"\u6587\u6863ID": doc_id, "\u5185\u5bb9": content})<\/p>\n summary = generate_summary(bpm_info, doc_contents)<\/p>\n return {
\n "\u6d41\u7a0bID": process_id,
\n "\u6458\u8981": summary,
\n "\u539f\u59cb\u6d41\u7a0b\u4fe1\u606f": bpm_info,
\n "\u6587\u6863\u5185\u5bb9\u9884\u89c8": [{ "\u6587\u6863ID": d["\u6587\u6863ID"], "\u524d\u51e0\u767e\u5b57": d["\u5185\u5bb9"][:300] } for d in doc_contents]
\n }<\/p>\n 5.API \u63a5\u5165 main.py<\/h3>\nfrom bpm_ecm_combined import get_bpm_with_summary<\/p>\n elif "bpm_doc_summary" in tools:
\n return {"output": get_bpm_with_summary(query)}<\/p>\n 6.\u6d4b\u8bd5\u8c03\u7528（API \u793a\u4f8b）<\/h3>\ncurl http:\/\/localhost:3333\/context\/v1\/query \\\\
\n -H "Content-Type: application\/json" \\\\
\n -H "x-api-key: abc123xyz" \\\\
\n -d '{
\n "input": "process-20240318-A\u5408\u540c\u5ba1\u6279",
\n "context": {
\n "tools": ["bpm_doc_summary"]
\n }
\n }'<\/p>\n 7.\u8fd4\u56de\u793a\u4f8b\u7ed3\u6784<\/h3>\n{
\n "\u6d41\u7a0bID": "process-20240318-A\u5408\u540c\u5ba1\u6279",
\n "\u6458\u8981": "\u672c\u6d41\u7a0b\u4e3aA\u516c\u53f8\u4e0eB\u516c\u53f8\u91c7\u8d2d\u5408\u540c\u5ba1\u6279\u6d41\u7a0b，\u5f53\u524d\u7531\u6cd5\u52a1\u90e8\u8fdb\u884c\u5ba1\u9605\u3002\u5408\u540c\u6587\u672c\u5df2\u7531\u9500\u552e\u90e8\u4e0a\u4f20，\u5185\u5bb9\u6d89\u53ca\u5e74\u6846\u534f\u8bae\u53ca\u4ed8\u6b3e\u6761\u6b3e\u3002\u9700\u91cd\u70b9\u5173\u6ce8\u4ed8\u6b3e\u5468\u671f\u4e0e\u8fdd\u7ea6\u8d23\u4efb\u3002",
\n "\u539f\u59cb\u6d41\u7a0b\u4fe1\u606f": {…},
\n "\u6587\u6863\u5185\u5bb9\u9884\u89c8": [
\n { "\u6587\u6863ID": "doc-abc", "\u524d\u51e0\u767e\u5b57": "\u5408\u540c\u7f16\u53f7：2024-A001…" }
\n ]
\n}<\/p>\n 10\u3001\u81ea\u52a8\u7ed9\u51fa\u5ba1\u6279\u5efa\u8bae<\/h2>\n\u8ba9 Claude \/ GPT \u57fa\u4e8e\u6d41\u7a0b\u548c\u6587\u6863\u5185\u5bb9，\u81ea\u52a8\u7ed9\u51fa\u5ba1\u6279\u5efa\u8bae，\u6bd4\u5982：<\/p>\n \u2705\u300c\u5efa\u8bae\u901a\u8fc7\u5ba1\u6279，\u7406\u7531\u662f\u2026\u2026\u300d \u274c\u300c\u5efa\u8bae\u9000\u56de，\u56e0\u6587\u6863\u7f3a\u5c11\u2026\u2026\u300d 🟡\u300c\u9700\u8865\u5145\u8bf4\u660e\u2026\u2026\u300d<\/p>\n \u8fd9\u5c31\u8ba9 AI \u771f\u6b63\u53c2\u4e0e\u5230\u4e1a\u52a1\u5224\u65ad\u4e2d，\u5e2e\u52a9\u7528\u6237\u52a0\u5feb\u6d41\u7a0b\u3001\u63d0\u5347\u51b3\u7b56\u8d28\u91cf\u3002\u4e0b\u9762\u662f\u5b9e\u73b0\u65b9\u5f0f👇<\/p>\n 1.\u76ee\u6807\u529f\u80fd：\u81ea\u52a8\u7ed9\u51fa\u5ba1\u6279\u5efa\u8bae<\/h3>\n\n- \n
\u8f93\u5165：\u6d41\u7a0b ID<\/p>\n<\/li>\n - \n
\u7cfb\u7edf\u81ea\u52a8\u83b7\u53d6\u6d41\u7a0b\u4fe1\u606f + \u6587\u6863\u5185\u5bb9<\/p>\n<\/li>\n - \n
AI \u8f93\u51fa：<\/p>\n - \n
\u662f\u5426\u5efa\u8bae\u901a\u8fc7（\u901a\u8fc7 \/ \u4e0d\u901a\u8fc7 \/ \u9700\u8865\u5145）<\/p>\n<\/li>\n - \n
\u5efa\u8bae\u7406\u7531（\u5f15\u7528\u6587\u6863\u3001\u6d41\u7a0b\u7b49）\u00a0<\/p>\n<\/li>\n<\/li>\n<\/ul>\n 2.\u6a21\u5757\u7ed3\u6784\u66f4\u65b0<\/h3>\nmcp_server\/
\n\u251c\u2500\u2500 bpm_adapter.py
\n\u251c\u2500\u2500 ecm_adapter.py
\n\u251c\u2500\u2500 summarizer.py
\n\u251c\u2500\u2500 approval_advisor.py \u2705 \u65b0\u589e：\u5ba1\u6279\u5efa\u8bae\u6a21\u5757
\n\u251c\u2500\u2500 bpm_ecm_combined.py<\/p>\n 3.\u6784\u5efa approval_advisor.py\u00a0<\/h3>\n# approval_advisor.py
\nimport os
\nimport openai<\/p>\n openai.api_key = os.getenv("OPENAI_API_KEY")<\/p>\n def generate_approval_advice(bpm_info: dict, doc_contents: list) -> str:
\n context = "\u3010\u6d41\u7a0b\u4fe1\u606f\u3011\\\\n"
\n context += f"\u6d41\u7a0b\u540d\u79f0：{bpm_info['\u6d41\u7a0b\u56fe']}\\\\n\u5f53\u524d\u72b6\u6001：{bpm_info['\u72b6\u6001']}\\\\n"
\n context += "\u6d41\u7a0b\u8282\u70b9：\\\\n"
\n for act in bpm_info["\u5f53\u524d\u73af\u8282"]:
\n context += f" – {act['name']}（\u72b6\u6001：{act['state']}）\\\\n"<\/p>\n context += "\\\\n\u3010\u6587\u6863\u5185\u5bb9\u63d0\u8981\u3011\\\\n"
\n for doc in doc_contents:
\n context += f"\\\\n\u6587\u6863ID：{doc['\u6587\u6863ID']}\\\\n"
\n context += doc["\u5185\u5bb9"][:1000] + "\\\\n"<\/p>\n prompt = f"""\u4f60\u662f\u4f01\u4e1a\u6d41\u7a0b\u5ba1\u6279\u4e13\u5bb6，\u8bf7\u6839\u636e\u4ee5\u4e0b\u4fe1\u606f，\u5224\u65ad\u8be5\u6d41\u7a0b\u662f\u5426\u53ef\u4ee5\u5ba1\u6279\u901a\u8fc7\u3002\u8bf7\u4e25\u683c\u8bc4\u4f30，\u5e76\u8f93\u51fa\u5982\u4e0b\u7ed3\u6784：<\/p>\n 1. \u662f\u5426\u5efa\u8bae\u901a\u8fc7\u5ba1\u6279（\u901a\u8fc7 \/ \u4e0d\u901a\u8fc7 \/ \u9700\u8865\u5145）
\n2. \u5efa\u8bae\u7406\u7531（\u7ed3\u5408\u6d41\u7a0b\u4fe1\u606f\u4e0e\u6587\u6863\u5185\u5bb9，\u7b80\u660e\u6e05\u6670） <\/p>\n \u4ee5\u4e0b\u662f\u4fe1\u606f\u5185\u5bb9：
\n{context}
\n==>
\n\u8bf7\u8f93\u51fa\u5ba1\u6279\u5efa\u8bae："""<\/p>\n try:
\n response = openai.ChatCompletion.create(
\n model="gpt-4",
\n messages=[{"role": "user", "content": prompt}],
\n temperature=0.3,
\n max_tokens=512,
\n )
\n return response.choices[0].message.content.strip()
\n except Exception as e:
\n return f"AI \u751f\u6210\u5ba1\u6279\u5efa\u8bae\u5931\u8d25：{e}"<\/p>\n 4.\u5c01\u88c5\u51fd\u6570 get_bpm_with_advice<\/h3>\n\u66f4\u65b0 bpm_ecm_combined.py：<\/p>\n from approval_advisor import generate_approval_advice<\/p>\n def get_bpm_with_advice(process_id: str):
\n bpm_info = get_bpm_process_info(process_id)
\n if isinstance(bpm_info, str):
\n return f"BPM\u67e5\u8be2\u5931\u8d25：{bpm_info}"<\/p>\n docs = bpm_info.get("\u6587\u6863\u5217\u8868", [])
\n doc_contents = []
\n for doc_id in docs:
\n content = get_document_content(doc_id)
\n doc_contents.append({"\u6587\u6863ID": doc_id, "\u5185\u5bb9": content})<\/p>\n advice = generate_approval_advice(bpm_info, doc_contents)<\/p>\n return {
\n "\u6d41\u7a0bID": process_id,
\n "AI\u5ba1\u6279\u5efa\u8bae": advice,
\n "\u539f\u59cb\u6d41\u7a0b\u4fe1\u606f": bpm_info,
\n "\u6587\u6863\u9884\u89c8": [{ "\u6587\u6863ID": d["\u6587\u6863ID"], "\u524d\u51e0\u767e\u5b57": d["\u5185\u5bb9"][:300] } for d in doc_contents]
\n }<\/p>\n 5.\u5728 main.py \u4e2d\u66b4\u9732 API<\/h3>\nfrom bpm_ecm_combined import get_bpm_with_advice<\/p>\n elif "bpm_doc_advice" in tools:
\n return {"output": get_bpm_with_advice(query)}<\/p>\n 6.\u6d4b\u8bd5\u8c03\u7528（API \u793a\u4f8b）<\/h3>\ncurl http:\/\/localhost:3333\/context\/v1\/query \\\\
\n -H "Content-Type: application\/json" \\\\
\n -H "x-api-key: abc123xyz" \\\\
\n -d '{
\n "input": "process-20240318-A\u5408\u540c\u5ba1\u6279",
\n "context": {
\n "tools": ["bpm_doc_advice"]
\n }
\n }'<\/p>\n 7.\u8fd4\u56de\u7ed3\u6784\u793a\u4f8b<\/h3>\n{
\n "\u6d41\u7a0bID": "process-20240318-A\u5408\u540c\u5ba1\u6279",
\n "AI\u5ba1\u6279\u5efa\u8bae": "1. \u5efa\u8bae\u901a\u8fc7\u5ba1\u6279\\\\n2. \u7406\u7531：\u6d41\u7a0b\u5df2\u5b8c\u6210\u5173\u952e\u8282\u70b9\u5ba1\u6838，\u4e14\u6587\u6863\u4e2d\u5df2\u660e\u786e\u4ed8\u6b3e\u6761\u6b3e\u3001\u8fdd\u7ea6\u8d23\u4efb，\u65e0\u660e\u663e\u9057\u6f0f\u3002",
\n "\u539f\u59cb\u6d41\u7a0b\u4fe1\u606f": { … },
\n "\u6587\u6863\u9884\u89c8": [
\n { "\u6587\u6863ID": "doc-abc", "\u524d\u51e0\u767e\u5b57": "\u5408\u540c\u7f16\u53f7：2024-A001…" }
\n ]
\n}<\/p>\n 11\u3001\u589e\u52a0\u6cd5\u52a1Agent，\u4e13\u95e8\u5206\u6790\u5408\u540c\u6761\u6b3e\u7684\u6cd5\u5f8b\u98ce\u9669\u00a0<\/h2>\n\u00a0\u6cd5\u52a1 Agent，\u8ba9\u5b83\u4e13\u6ce8\u5206\u6790\u5408\u540c\u6761\u6b3e\u7684\u6cd5\u5f8b\u98ce\u9669\u3001\u5408\u89c4\u6027\u95ee\u9898\u548c\u5173\u952e\u6ce8\u610f\u4e8b\u9879，\u4ee5 AI \u6cd5\u5f8b\u987e\u95ee\u7684\u8eab\u4efd\u63d0\u4f9b\u4e13\u4e1a\u5224\u65ad，\u8f85\u52a9\u4e1a\u52a1\u5ba1\u6279\u6d41\u7a0b\u3002<\/p>\n 1.\u6cd5\u52a1 Agent \u529f\u80fd\u5b9a\u4f4d<\/h3>\n\n\u529f\u80fd\u8bf4\u660e<\/tr>\n \n\n| 🎯 \u805a\u7126\u5206\u6790<\/td>\n | \u53ea\u5206\u6790\u5408\u540c\u4e2d\u7684\u6cd5\u5f8b\u6761\u6b3e\u5185\u5bb9<\/td>\n<\/tr>\n | \n| 🛡\ufe0f \u98ce\u9669\u8bc6\u522b<\/td>\n | \u8bc6\u522b\u5982\u8fdd\u7ea6\u8d23\u4efb\u6a21\u7cca\u3001\u4ed8\u6b3e\u65b9\u5f0f\u4e0d\u5408\u89c4\u3001\u7f3a\u5c11\u4e89\u8bae\u89e3\u51b3\u6761\u6b3e\u7b49\u95ee\u9898<\/td>\n<\/tr>\n | \n| \u2696\ufe0f \u5408\u89c4\u5efa\u8bae<\/td>\n | \u7ed9\u51fa\u4fee\u6b63\u5efa\u8bae\u6216\u6807\u6ce8\u7f3a\u5931\u9879<\/td>\n<\/tr>\n | \n| \u2705 \u8f93\u51fa\u683c\u5f0f<\/td>\n | \u98ce\u9669\u7b49\u7ea7（\u9ad8\/\u4e2d\/\u4f4e）+ \u95ee\u9898\u6458\u8981 + \u4fee\u6539\u5efa\u8bae<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n2.\u67b6\u6784\u66f4\u65b0<\/h3>\nmcp_server\/
\n\u251c\u2500\u2500 bpm_adapter.py
\n\u251c\u2500\u2500 ecm_adapter.py
\n\u251c\u2500\u2500 approval_advisor.py
\n\u251c\u2500\u2500 summarizer.py
\n\u251c\u2500\u2500 legal_advisor.py \u2705 \u65b0\u589e：\u6cd5\u52a1 Agent \u6a21\u5757
\n\u251c\u2500\u2500 bpm_ecm_combined.py<\/p>\n 3.\u65b0\u589e legal_advisor.py<\/h3>\n# legal_advisor.py
\nimport os
\nimport openai<\/p>\n openai.api_key = os.getenv("OPENAI_API_KEY")<\/p>\n def analyze_legal_risks(doc_text: str) -> str:
\n prompt = f"""
\n\u4f60\u662f\u4f01\u4e1a\u5408\u540c\u6cd5\u52a1\u4e13\u5bb6，\u8bf7\u4f60\u9605\u8bfb\u4ee5\u4e0b\u5408\u540c\u6761\u6b3e\u5185\u5bb9，\u4ece\u6cd5\u5f8b\u5408\u89c4\u89d2\u5ea6\u8fdb\u884c\u98ce\u9669\u5206\u6790\u3002\u8bf7\u8bc6\u522b\u4ee5\u4e0b\u95ee\u9898\u5e76\u7ed9\u51fa\u5efa\u8bae：
\n– \u662f\u5426\u7f3a\u5c11\u5173\u952e\u6cd5\u5f8b\u6761\u6b3e（\u5982\u8fdd\u7ea6\u8d23\u4efb\u3001\u4e89\u8bae\u89e3\u51b3\u3001\u9002\u7528\u6cd5\u5f8b）
\n– \u662f\u5426\u5b58\u5728\u6a21\u7cca\u3001\u98ce\u9669\u6027\u63cf\u8ff0
\n– \u662f\u5426\u6761\u6b3e\u4e4b\u95f4\u5b58\u5728\u51b2\u7a81\u6216\u9057\u6f0f<\/p>\n \u8bf7\u6309\u5982\u4e0b\u7ed3\u6784\u8f93\u51fa：
\n1. \u98ce\u9669\u7b49\u7ea7（\u9ad8 \/ \u4e2d \/ \u4f4e）
\n2. \u98ce\u9669\u8981\u70b9（\u5217\u4e3e\u5b58\u5728\u7684\u95ee\u9898）
\n3. \u4fee\u6539\u5efa\u8bae<\/p>\n \u5408\u540c\u5185\u5bb9\u5982\u4e0b：
\n{doc_text[:3000]} # \u63a7\u5236\u4e0a\u4e0b\u6587\u957f\u5ea6
\n"""<\/p>\n try:
\n response = openai.ChatCompletion.create(
\n model="gpt-4",
\n messages=[{"role": "user", "content": prompt}],
\n temperature=0.2,
\n max_tokens=512,
\n )
\n return response.choices[0].message.content.strip()
\n except Exception as e:
\n return f"\u6cd5\u52a1\u98ce\u9669\u5206\u6790\u5931\u8d25：{e}"<\/p>\n 4.\u7ec4\u5408\u8c03\u7528（\u66f4\u65b0 bpm_ecm_combined.py）<\/h3>\nfrom legal_advisor import analyze_legal_risks<\/p>\n def get_bpm_with_legal_advice(process_id: str):
\n bpm_info = get_bpm_process_info(process_id)
\n if isinstance(bpm_info, str):
\n return f"BPM\u67e5\u8be2\u5931\u8d25：{bpm_info}"<\/p>\n docs = bpm_info.get("\u6587\u6863\u5217\u8868", [])
\n doc_contents = []
\n for doc_id in docs:
\n content = get_document_content(doc_id)
\n doc_contents.append({"\u6587\u6863ID": doc_id, "\u5185\u5bb9": content})<\/p>\n legal_reports = []
\n for doc in doc_contents:
\n if "\u5408\u540c" in doc["\u6587\u6863ID"] or "agreement" in doc["\u6587\u6863ID"].lower(): # \u7b80\u5355\u5224\u65ad\u662f\u5426\u4e3a\u5408\u540c
\n report = analyze_legal_risks(doc["\u5185\u5bb9"])
\n legal_reports.append({
\n "\u6587\u6863ID": doc["\u6587\u6863ID"],
\n "\u6cd5\u5f8b\u98ce\u9669\u5206\u6790": report
\n })<\/p>\n return {
\n "\u6d41\u7a0bID": process_id,
\n "\u6cd5\u5f8b\u98ce\u9669\u62a5\u544a": legal_reports,
\n "\u6587\u6863\u9884\u89c8": [{ "\u6587\u6863ID": d["\u6587\u6863ID"], "\u524d\u51e0\u767e\u5b57": d["\u5185\u5bb9"][:300] } for d in doc_contents]
\n }<\/p>\n 5. API \u63a5\u5165（main.py）<\/h3>\nfrom bpm_ecm_combined import get_bpm_with_legal_advice<\/p>\n elif "legal_risk_analysis" in tools:
\n return {"output": get_bpm_with_legal_advice(query)}<\/p>\n 6.\u6d4b\u8bd5\u8c03\u7528\u793a\u4f8b<\/h3>\ncurl http:\/\/localhost:3333\/context\/v1\/query \\\\
\n -H "Content-Type: application\/json" \\\\
\n -H "x-api-key: abc123xyz" \\\\
\n -d '{
\n "input": "process-20240318-A\u5408\u540c\u5ba1\u6279",
\n "context": {
\n "tools": ["legal_risk_analysis"]
\n }
\n }'<\/p>\n 7.\u8fd4\u56de\u7ed3\u6784\u793a\u4f8b<\/h3>\n{
\n "\u6d41\u7a0bID": "process-20240318-A\u5408\u540c\u5ba1\u6279",
\n "\u6cd5\u5f8b\u98ce\u9669\u62a5\u544a": [
\n {
\n "\u6587\u6863ID": "A\u516c\u53f8\u4e0eB\u516c\u53f8\u91c7\u8d2d\u5408\u540c",
\n "\u6cd5\u5f8b\u98ce\u9669\u5206\u6790": "1. \u98ce\u9669\u7b49\u7ea7：\u4e2d\\\\n2. \u98ce\u9669\u8981\u70b9：\u672a\u5305\u542b\u4e89\u8bae\u89e3\u51b3\u6761\u6b3e，\u8fdd\u7ea6\u8d23\u4efb\u8868\u8ff0\u6a21\u7cca\u3002\\\\n3. \u5efa\u8bae：\u8865\u5145\u4e89\u8bae\u89e3\u51b3\u6761\u6b3e，\u660e\u786e\u8d54\u507f\u8303\u56f4\u3002"
\n }
\n ],
\n "\u6587\u6863\u9884\u89c8": [
\n { "\u6587\u6863ID": "A\u516c\u53f8\u4e0eB\u516c\u53f8\u91c7\u8d2d\u5408\u540c", "\u524d\u51e0\u767e\u5b57": "\u5408\u540c\u7f16\u53f7：2024-A001…" }
\n ]
\n}<\/p>\n 12\u3001\u6cd5\u52a1\u8f85\u52a9 + \u81ea\u52a8\u4fee\u8ba2 + BPM\u8054\u52a8<\/h2>\n\u63a5\u4e0b\u6765\u5b9e\u73b0\u4ee5\u4e0b\u4e24\u4e2a\u529f\u80fd，\u6253\u9020\u771f\u6b63\u5177\u5907\u201c\u6cd5\u52a1\u8f85\u52a9 + \u81ea\u52a8\u4fee\u8ba2 + BPM\u8054\u52a8\u201d\u7684\u667a\u80fd\u6d41\u7a0b\u7cfb\u7edf：<\/p>\n \u529f\u80fd\u4e00：\u5c06\u6cd5\u52a1\u5206\u6790\u7ed3\u679c\u5199\u5165 BPM \u6d41\u7a0b\u5907\u6ce8\u5b57\u6bb5<\/h3>\n1. \u5b9e\u73b0\u903b\u8f91<\/h4>\n- \n
\u5728 get_bpm_with_legal_advice \u51fd\u6570\u4e2d\u5206\u6790\u6cd5\u5f8b\u98ce\u9669<\/p>\n<\/li>\n - \n
\u5c06\u5206\u6790\u7ed3\u679c\u7528\u63a5\u53e3\u5199\u5165 BPM \u7cfb\u7edf\u4e2d\u5bf9\u5e94\u6d41\u7a0b\u7684\u5907\u6ce8\u5b57\u6bb5（\u6216\u8bc4\u8bba\u3001\u5ba1\u9605\u65e5\u5fd7）\u00a0<\/p>\n<\/li>\n 2.BPM Adapter \u589e\u52a0\u63a5\u53e3（\u5047\u8bbe BPM \u652f\u6301 REST）<\/h4>\n\u66f4\u65b0 bpm_adapter.py：<\/p>\n def write_bpm_comment(process_id: str, comment: str) -> bool:
\n try:
\n # \u793a\u4f8b：\u5047\u8bbe\u6211\u4eec\u8c03\u7528\u672c\u5730 BPM API
\n url = f"http:\/\/localhost:8080\/bpm\/api\/processes\/{process_id}\/comment"
\n response = requests.post(url, json={"comment": comment})
\n return response.status_code == 200
\n except Exception as e:
\n print(f"BPM\u5199\u5165\u5907\u6ce8\u5931\u8d25：{e}")
\n return False<\/p>\n 3.\u66f4\u65b0 get_bpm_with_legal_advice<\/h4>\ndef get_bpm_with_legal_advice(process_id: str):
\n bpm_info = get_bpm_process_info(process_id)
\n if isinstance(bpm_info, str):
\n return f"BPM\u67e5\u8be2\u5931\u8d25：{bpm_info}"<\/p>\n docs = bpm_info.get("\u6587\u6863\u5217\u8868", [])
\n doc_contents = []
\n legal_reports = []<\/p>\n for doc_id in docs:
\n content = get_document_content(doc_id)
\n doc_contents.append({"\u6587\u6863ID": doc_id, "\u5185\u5bb9": content})
\n if "\u5408\u540c" in doc_id or "agreement" in doc_id.lower():
\n report = analyze_legal_risks(content)
\n legal_reports.append({"\u6587\u6863ID": doc_id, "\u6cd5\u5f8b\u98ce\u9669\u5206\u6790": report})<\/p>\n # \u7ec4\u7ec7\u5199\u5165\u5185\u5bb9
\n summary = "\\\\n\\\\n".join(
\n f"📄\u3010{r['\u6587\u6863ID']}\u3011\\\\n{r['\u6cd5\u5f8b\u98ce\u9669\u5206\u6790']}" for r in legal_reports
\n )
\n comment = f"🛡\ufe0f \u6cd5\u52a1\u98ce\u9669\u5206\u6790\u5982\u4e0b：\\\\n{summary}"<\/p>\n write_bpm_comment(process_id, comment)<\/p>\n return {
\n "\u6d41\u7a0bID": process_id,
\n "\u6cd5\u5f8b\u98ce\u9669\u62a5\u544a": legal_reports,
\n "\u5907\u6ce8\u5df2\u5199\u5165BPM": True,
\n }<\/p>\n \u529f\u80fd\u4e8c：AI \u81ea\u52a8\u4fee\u8ba2\u5408\u540c\u8349\u7a3f<\/h3>\n\u6211\u4eec\u8ba9 Claude \u6216 GPT \u76f4\u63a5\u7ed9\u51fa\u4fee\u6539\u5efa\u8bae\u6216\u8fd4\u56de\u4f18\u5316\u540e\u7684\u5408\u540c\u8349\u7a3f\u6bb5\u843d\u3002<\/p>\n 1.\u6a21\u5757\u65b0\u589e：contract_editor.py<\/h4>\n# contract_editor.py
\nimport os
\nimport openai<\/p>\n openai.api_key = os.getenv("OPENAI_API_KEY")<\/p>\n def revise_contract(contract_text: str, legal_issues: str) -> str:
\n prompt = f"""
\n\u4f60\u662f\u6cd5\u5f8b\u8bed\u8a00\u7f16\u8f91\u4e13\u5bb6\u3002\u8bf7\u6839\u636e\u4ee5\u4e0b\u6cd5\u5f8b\u98ce\u9669\u70b9，\u4f18\u5316\u4fee\u8ba2\u8fd9\u4efd\u5408\u540c\u5185\u5bb9，\u4f7f\u5176\u66f4\u52a0\u5408\u89c4\u3001\u6e05\u6670\u3002\u4e0d\u8981\u8fc7\u5ea6\u6da6\u8272，\u53ea\u505a\u6cd5\u5f8b\u5fc5\u8981\u4fee\u6b63\u3002<\/p>\n \u3010\u6cd5\u5f8b\u95ee\u9898\u3011：
\n{legal_issues}<\/p>\n \u3010\u539f\u59cb\u5408\u540c\u7247\u6bb5\u3011：
\n{contract_text[:3000]}<\/p>\n \u8bf7\u8fd4\u56de\u4f18\u5316\u540e\u7684\u4fee\u8ba2\u7248\u5408\u540c\u6587\u672c：
\n"""<\/p>\n try:
\n response = openai.ChatCompletion.create(
\n model="gpt-4",
\n messages=[{"role": "user", "content": prompt}],
\n temperature=0.3,
\n max_tokens=800,
\n )
\n return response.choices[0].message.content.strip()
\n except Exception as e:
\n return f"\u5408\u540c\u4fee\u8ba2\u5931\u8d25：{e}"<\/p>\n 2.\u66f4\u65b0\u7ec4\u5408\u6a21\u5757（\u5982 bpm_ecm_combined.py）<\/h4>\n\u52a0\u5165\u4fee\u8ba2\u5efa\u8bae\u529f\u80fd：<\/p>\n from contract_editor import revise_contract<\/p>\n def get_legal_advice_with_rewrite(process_id: str):
\n bpm_info = get_bpm_process_info(process_id)
\n docs = bpm_info.get("\u6587\u6863\u5217\u8868", [])
\n legal_reports = []
\n revised_docs = []<\/p>\n for doc_id in docs:
\n content = get_document_content(doc_id)
\n if "\u5408\u540c" in doc_id or "agreement" in doc_id.lower():
\n legal_analysis = analyze_legal_risks(content)
\n legal_reports.append({
\n "\u6587\u6863ID": doc_id,
\n "\u6cd5\u5f8b\u98ce\u9669\u5206\u6790": legal_analysis
\n })
\n revised_text = revise_contract(content, legal_analysis)
\n revised_docs.append({
\n "\u6587\u6863ID": doc_id,
\n "\u4fee\u8ba2\u5efa\u8bae": revised_text
\n })<\/p>\n return {
\n "\u6d41\u7a0bID": process_id,
\n "\u6cd5\u5f8b\u98ce\u9669\u62a5\u544a": legal_reports,
\n "\u5408\u540c\u4fee\u8ba2\u5efa\u8bae": revised_docs
\n }<\/p>\n 3.API \u8c03\u7528\u65b9\u5f0f<\/h4>\nPOST \/query<\/h5>\n{
\n "input": "process-20240318-A\u5408\u540c\u5ba1\u6279",
\n "context": {
\n "tools": ["legal_risk_analysis", "rewrite_contract"]
\n }
\n}<\/p>\n 4.\u6700\u7ec8\u8fd4\u56de\u7ed3\u6784\u793a\u4f8b\u00a0<\/h4>\n{
\n "\u6d41\u7a0bID": "process-20240318-A\u5408\u540c\u5ba1\u6279",
\n "\u6cd5\u5f8b\u98ce\u9669\u62a5\u544a": [
\n {
\n "\u6587\u6863ID": "\u91c7\u8d2d\u5408\u540c-A001",
\n "\u6cd5\u5f8b\u98ce\u9669\u5206\u6790": "1. \u98ce\u9669\u7b49\u7ea7：\u4e2d\\\\n2. \u95ee\u9898：\u7f3a\u5c11\u8fdd\u7ea6\u8d54\u507f\u673a\u5236\\\\n3. \u5efa\u8bae：\u52a0\u5165\u8d54\u507f\u6761\u6b3e"
\n }
\n ],
\n "\u5408\u540c\u4fee\u8ba2\u5efa\u8bae": [
\n {
\n "\u6587\u6863ID": "\u91c7\u8d2d\u5408\u540c-A001",
\n "\u4fee\u8ba2\u5efa\u8bae": "\u2026\u672c\u534f\u8bae\u7b2c\u516d\u6761\u65b0\u589e\u5982\u4e0b\u5185\u5bb9：\u82e5\u4efb\u4f55\u4e00\u65b9\u8fdd\u7ea6，\u5e94\u8d54\u507f\u5bf9\u65b9\u56e0\u6b64\u9020\u6210\u7684\u5b9e\u9645\u7ecf\u6d4e\u635f\u5931\u2026"
\n }
\n ]
\n}<\/p>\n \u603b\u7ed3<\/h3>\n\n\u529f\u80fd\u72b6\u6001<\/tr>\n \n\n| \u2705 \u6cd5\u52a1\u98ce\u9669\u8bc6\u522b<\/td>\n | \u5b8c\u6210<\/td>\n<\/tr>\n | \n| \u2705 \u98ce\u9669\u5199\u5165 BPM \u6d41\u7a0b\u5907\u6ce8<\/td>\n | \u5b8c\u6210<\/td>\n<\/tr>\n | \n| \u2705 AI \u81ea\u52a8\u4fee\u8ba2\u5408\u540c\u8349\u7a3f<\/td>\n | \u5b8c\u6210<\/td>\n<\/tr>\n | \n| \u2705 \u8fd4\u56de\u7ed3\u6784\u5316\u98ce\u9669 + \u5efa\u8bae<\/td>\n | \u5df2\u5b8c\u6210<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n13\u3001\u591a Agent \u6295\u7968\u673a\u5236<\/h2>\n\u591a Agent \u6295\u7968\u673a\u5236，\u6a21\u62df\u591a\u4e2a\u6cd5\u5f8b\u4e13\u5bb6\u5bf9\u5408\u540c\u6761\u6b3e\u8fdb\u884c\u72ec\u7acb\u5224\u65ad + \u6295\u7968\u8868\u51b3，\u786e\u4fdd\u7ed3\u8bba\u66f4\u5177\u6743\u5a01\u6027\u548c\u7a33\u5065\u6027\u3002<\/p>\n 1.\u4ec0\u4e48\u662f\u591a Agent \u6295\u7968\u673a\u5236？<\/h3>\n\u591a\u4e2a\u5927\u6a21\u578b（Agent），\u72ec\u7acb\u5206\u6790\u5408\u540c\u98ce\u9669，\u7136\u540e：<\/p>\n - \n
\u5404\u81ea\u8f93\u51fa\u5224\u65ad（\u98ce\u9669\u7b49\u7ea7\u3001\u9ad8\u4eae\u95ee\u9898\u3001\u5efa\u8bae）<\/p>\n<\/li>\n - \n
\u7cfb\u7edf\u81ea\u52a8\u5bf9\u6bd4\u610f\u89c1，\u5f52\u7eb3\u5171\u8bc6<\/p>\n<\/li>\n - \n
\u82e5\u51b2\u7a81，\u5219\u8f93\u51fa\u201c\u26a0\ufe0f \u5b58\u5728\u5206\u6b67，\u8bf7\u4eba\u5de5\u786e\u8ba4\u201d\u00a0<\/p>\n<\/li>\n 2.\u6295\u7968\u67b6\u6784\u8bbe\u8ba1<\/h3>\n \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
\n \u2502 Contract \u2502
\n \u2502 Text \u2502
\n \u2514\u2500\u2500\u2500\u2500\u252c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518
\n \u2502
\n \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u253c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
\n \u25bc \u25bc \u25bc
\n Claude Agent GPT Agent Mistral Agent
\n (\u98ce\u9669\u5206\u6790A) (\u98ce\u9669\u5206\u6790B) (\u98ce\u9669\u5206\u6790C)
\n \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u253c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518
\n \u25bc
\n 🤖 \u5408\u5e76 & \u6295\u7968\u5224\u65ad\u6a21\u5757
\n \u25bc
\n 📝 \u6700\u7ec8\u98ce\u9669\u5171\u8bc6 + \u5206\u6b67\u6807\u8bb0<\/p>\n 3.\u6b65\u9aa4\u4e00：\u521b\u5efa\u591a\u6a21\u578b\u5206\u6790\u51fd\u6570<\/h3>\n\u6211\u4eec\u65b0\u589e multi_agent_legal.py \u6a21\u5757：<\/p>\n # multi_agent_legal.py
\nfrom legal_advisor import analyze_legal_risks_with_model<\/p>\n def multi_agent_vote(contract_text: str):
\n models = {
\n "claude": "claude-3-opus-20240229",
\n "gpt": "gpt-4",
\n "mistral": "mistral-7b-instruct"
\n }<\/p>\n results = {}
\n for name, model in models.items():
\n result = analyze_legal_risks_with_model(contract_text, model)
\n results[name] = result<\/p>\n # \u7b80\u5355\u6295\u7968\u903b\u8f91（\u53ef\u6269\u5c55\u4e3a NLP \u5171\u8bc6\u5224\u65ad）
\n risk_levels = {}
\n for name, text in results.items():
\n if "\u9ad8" in text:
\n risk_levels[name] = "\u9ad8"
\n elif "\u4e2d" in text:
\n risk_levels[name] = "\u4e2d"
\n else:
\n risk_levels[name] = "\u4f4e"<\/p>\n votes = list(risk_levels.values())
\n if votes.count("\u9ad8") >= 2:
\n final_level = "\u9ad8"
\n elif votes.count("\u4e2d") >= 2:
\n final_level = "\u4e2d"
\n else:
\n final_level = "\u4f4e"<\/p>\n consensus = {
\n "\u6700\u7ec8\u98ce\u9669\u7b49\u7ea7": final_level,
\n "\u5404Agent\u5224\u65ad": risk_levels,
\n "\u8be6\u7ec6\u62a5\u544a": results
\n }<\/p>\n return consensus<\/p>\n 4.\u6b65\u9aa4\u4e8c：\u652f\u6301\u4e0d\u540c\u6a21\u578b\u8c03\u7528（\u4fee\u6539 legal_advisor.py）\u00a0<\/h3>\ndef analyze_legal_risks_with_model(doc_text: str, model: str) -> str:
\n prompt = f"""
\n\u4f60\u662f\u5408\u540c\u6cd5\u5f8b\u5ba1\u67e5\u4e13\u5bb6，\u8bf7\u5206\u6790\u4ee5\u4e0b\u5408\u540c\u6bb5\u843d\u7684\u6cd5\u5f8b\u98ce\u9669\u3001\u7f3a\u9677，\u5e76\u63d0\u51fa\u4fee\u6539\u5efa\u8bae\u3002<\/p>\n \u3010\u5408\u540c\u5185\u5bb9\u3011：
\n{doc_text[:3000]}
\n"""<\/p>\n try:
\n response = openai.ChatCompletion.create(
\n model=model,
\n messages=[{"role": "user", "content": prompt}],
\n temperature=0.2,
\n max_tokens=512,
\n )
\n return response.choices[0].message.content.strip()
\n except Exception as e:
\n return f"[{model}] \u98ce\u9669\u5206\u6790\u5931\u8d25：{e}"<\/p>\n 5.\u6b65\u9aa4\u4e09：\u5728\u6d41\u7a0b\u4e2d\u5f15\u5165\u6295\u7968\u5206\u6790<\/h3>\n\u66f4\u65b0\u7ec4\u5408\u6a21\u5757，\u5982：<\/p>\n from multi_agent_legal import multi_agent_vote<\/p>\n def get_legal_vote_result(process_id: str):
\n bpm_info = get_bpm_process_info(process_id)
\n docs = bpm_info.get("\u6587\u6863\u5217\u8868", [])
\n vote_reports = []<\/p>\n for doc_id in docs:
\n content = get_document_content(doc_id)
\n if "\u5408\u540c" in doc_id or "agreement" in doc_id.lower():
\n vote_result = multi_agent_vote(content)
\n vote_reports.append({
\n "\u6587\u6863ID": doc_id,
\n "\u6700\u7ec8\u98ce\u9669\u7b49\u7ea7": vote_result["\u6700\u7ec8\u98ce\u9669\u7b49\u7ea7"],
\n "\u591aAgent\u5224\u65ad": vote_result["\u5404Agent\u5224\u65ad"],
\n "\u8be6\u7ec6\u62a5\u544a": vote_result["\u8be6\u7ec6\u62a5\u544a"]
\n })<\/p>\n return {
\n "\u6d41\u7a0bID": process_id,
\n "\u5408\u540c\u591aAgent\u98ce\u9669\u5171\u8bc6\u62a5\u544a": vote_reports
\n }<\/p>\n 6.\u793a\u4f8b\u8fd4\u56de\u7ed3\u6784<\/h3>\n{
\n "\u6d41\u7a0bID": "A\u5408\u540c\u5ba1\u6279",
\n "\u5408\u540c\u591aAgent\u98ce\u9669\u5171\u8bc6\u62a5\u544a": [
\n {
\n "\u6587\u6863ID": "\u91c7\u8d2d\u5408\u540c-A001",
\n "\u6700\u7ec8\u98ce\u9669\u7b49\u7ea7": "\u4e2d",
\n "\u591aAgent\u5224\u65ad": {
\n "claude": "\u4e2d",
\n "gpt": "\u4e2d",
\n "mistral": "\u4f4e"
\n },
\n "\u8be6\u7ec6\u62a5\u544a": {
\n "claude": "\u5b58\u5728\u4ed8\u6b3e\u6761\u6b3e\u6a21\u7cca\u7b49\u95ee\u9898",
\n "gpt": "\u672a\u6307\u660e\u4e89\u8bae\u89e3\u51b3\u65b9\u5f0f，\u5efa\u8bae\u8865\u5145",
\n "mistral": "\u6574\u4f53\u98ce\u9669\u8f83\u4f4e，\u4ec5\u5efa\u8bae\u6dfb\u52a0\u4ed8\u6b3e\u8282\u70b9"
\n }
\n }
\n ]
\n}<\/p>\n 14\u3001\u529f\u80fd\u589e\u5f3a<\/h2>\n\u529f\u80fd 1：\u5728 ECM \u4e2d\u521b\u5efa\u201c\u6cd5\u5f8b\u98ce\u9669\u5ba1\u67e5\u8bb0\u5f55\u201d\u6587\u6863<\/h3>\n\u6a21\u5757\u65b0\u589e：ecm_writer.py<\/h4>\n# ecm_writer.py
\nimport requests<\/p>\n def create_legal_review_doc(doc_id: str, vote_result: dict) -> bool:
\n payload = {
\n "title": f"\u6cd5\u5f8b\u98ce\u9669\u5206\u6790\u62a5\u544a – {doc_id}",
\n "metadata": {
\n "\u539f\u6587\u6863ID": doc_id,
\n "\u98ce\u9669\u7b49\u7ea7": vote_result["\u6700\u7ec8\u98ce\u9669\u7b49\u7ea7"],
\n "\u591aAgent\u5224\u65ad": str(vote_result["\u5404Agent\u5224\u65ad"])
\n },
\n "content": vote_result["\u8be6\u7ec6\u62a5\u544a"]
\n }<\/p>\n try:
\n res = requests.post("http:\/\/localhost:8080\/ecm\/api\/create_doc", json=payload)
\n return res.status_code == 200
\n except Exception as e:
\n print(f"ECM\u5199\u5165\u5931\u8d25：{e}")
\n return False<\/p>\n \u529f\u80fd 2：BPM \u6d41\u7a0b\u5907\u6ce8\u4e2d\u5199\u5165\u6295\u7968\u7ed3\u679c\u6458\u8981<\/h3>\n\u590d\u7528\u4e4b\u524d\u7684 write_bpm_comment：<\/p>\n def summarize_vote(vote_result: dict) -> str:
\n votes = vote_result["\u5404Agent\u5224\u65ad"]
\n return f"""🗳\ufe0f \u6cd5\u52a1Agent\u6295\u7968\u7ed3\u679c：
\nClaude：{votes.get('claude')}
\nGPT：{votes.get('gpt')}
\nMistral：{votes.get('mistral')}
\n\u6700\u7ec8\u98ce\u9669\u7b49\u7ea7：{vote_result['\u6700\u7ec8\u98ce\u9669\u7b49\u7ea7']}"""<\/p>\n \u5728\u6d41\u7a0b\u4e2d\u8fd9\u6837\u8c03\u7528：<\/p>\n comment = summarize_vote(vote_result)
\nwrite_bpm_comment(process_id, comment)<\/p>\n \u529f\u80fd 3：\u524d\u7aef\u4eea\u8868\u76d8\u663e\u793a\u6295\u7968 & \u5408\u540c\u98ce\u9669\u6570\u636e<\/h3>\n\u4f7f\u7528 React + Tailwind \u6784\u5efa\u4e00\u4e2a\u4eea\u8868\u76d8（\u5efa\u8bae\u7528 shadcn\/ui）<\/h4>\n\u6211\u4eec\u6765\u751f\u6210\u4e00\u4e2a\u53ef\u90e8\u7f72\u7684 React \u9875\u9762：<\/p>\n \/\/ components\/LegalDashboard.tsx
\nimport { Card, CardContent } from "@\/components\/ui\/card"
\nimport { BarChart2, ShieldAlert } from "lucide-react"<\/p>\n export default function LegalDashboard({ data }) {
\n return (
\n <div className="grid gap-4 p-6 grid-cols-1 md:grid-cols-2">
\n {data.map((item: any) => (
\n <Card key={item.\u6587\u6863ID} className="shadow-lg rounded-2xl">
\n <CardContent className="p-4 space-y-2">
\n <div className="flex justify-between items-center">
\n <h2 className="text-xl font-bold">{item.\u6587\u6863ID}<\/h2>
\n <span className={`text-sm px-2 py-1 rounded-xl ${item.\u6700\u7ec8\u98ce\u9669\u7b49\u7ea7 === "\u9ad8" ? "bg-red-100 text-red-700" : item.\u6700\u7ec8\u98ce\u9669\u7b49\u7ea7 === "\u4e2d" ? "bg-yellow-100 text-yellow-800" : "bg-green-100 text-green-700"}`}>
\n \u98ce\u9669：{item.\u6700\u7ec8\u98ce\u9669\u7b49\u7ea7}
\n <\/span>
\n <\/div>
\n <div className="text-sm">
\n <p><ShieldAlert className="inline mr-1" \/> Claude：{item.\u591aAgent\u5224\u65ad.claude}<\/p>
\n <p><ShieldAlert className="inline mr-1" \/> GPT：{item.\u591aAgent\u5224\u65ad.gpt}<\/p>
\n <p><ShieldAlert className="inline mr-1" \/> Mistral：{item.\u591aAgent\u5224\u65ad.mistral}<\/p>
\n <\/div>
\n <details className="text-xs mt-2">
\n <summary className="cursor-pointer">📝 \u67e5\u770b\u8be6\u7ec6\u62a5\u544a<\/summary>
\n <pre className="whitespace-pre-wrap mt-1">{JSON.stringify(item.\u8be6\u7ec6\u62a5\u544a, null, 2)}<\/pre>
\n <\/details>
\n <\/CardContent>
\n <\/Card>
\n ))}
\n <\/div>
\n )
\n}<\/p>\n \u00a0\u6570\u636e\u53ef\u901a\u8fc7 \/api\/legal_risks \u52a8\u6001\u83b7\u53d6\u3002<\/p>\n \u603b\u96c6\u6210\u51fd\u6570（\u4e3b\u903b\u8f91）<\/h3>\ndef analyze_contract_process(process_id: str):
\n bpm_info = get_bpm_process_info(process_id)
\n vote_reports = []<\/p>\n for doc_id in bpm_info.get("\u6587\u6863\u5217\u8868", []):
\n content = get_document_content(doc_id)
\n if "\u5408\u540c" in doc_id:
\n vote_result = multi_agent_vote(content)<\/p>\n # \u5199\u5165 BPM
\n comment = summarize_vote(vote_result)
\n write_bpm_comment(process_id, comment)<\/p>\n # \u5199\u5165 ECM
\n create_legal_review_doc(doc_id, vote_result)<\/p>\n vote_reports.append({
\n "\u6587\u6863ID": doc_id,
\n **vote_result
\n })<\/p>\n return vote_reports<\/p>\n \u6700\u7ec8\u7cfb\u7edf\u67b6\u6784\u4e00\u89c8<\/h3>\n📄 \u6587\u6863\u63d0\u53d6 \u2192 🧠 \u591aAgent\u5206\u6790 \u2192 🗳\ufe0f \u6295\u7968\u5f52\u7eb3
\n \u2502 \u2502 \u2502
\n \u25bc \u25bc \u25bc
\n📎 ECM\u6587\u6863 📝 BPM\u5907\u6ce8 📊 \u524d\u7aef\u4eea\u8868\u76d8<\/p>\n 15\u3001\u589e\u52a0\u524d\u7aef\u6570\u636e\u6e90\u3001\u90ae\u4ef6\u5408\u89c4\u901a\u77e5\u3001\u628aReact\u524d\u7aef\u90e8\u7f72\u5230Docker\u91cc<\/h2>\n\u6b65\u9aa4\u4e00：FastAPI \u63d0\u4f9b \/api\/legal_risks \u63a5\u53e3（\u524d\u7aef\u6570\u636e\u6e90）<\/h3>\n\u65b0\u5efa FastAPI \u8def\u7531 routes\/legal_api.py<\/h4>\n# routes\/legal_api.py
\nfrom fastapi import APIRouter
\nfrom fastapi.responses import JSONResponse
\nfrom backend.legal_workflow import analyze_contract_process<\/p>\n router = APIRouter()<\/p>\n @router.get("\/api\/legal_risks")
\ndef get_legal_risks(process_id: str):
\n try:
\n report = analyze_contract_process(process_id)
\n return JSONResponse(content=report)
\n except Exception as e:
\n return JSONResponse(status_code=500, content={"error": str(e)})<\/p>\n \u4e3b\u670d\u52a1\u5f15\u5165\u8def\u7531（main.py）<\/h4>\n# main.py
\nfrom fastapi import FastAPI
\nfrom routes import legal_api<\/p>\n app = FastAPI()
\napp.include_router(legal_api.router)<\/p>\n \u00a0\u73b0\u5728\u4f60\u53ea\u8981\u8bbf\u95ee：<\/p>\n http:\/\/localhost:8000\/api\/legal_risks?process_id=A\u5408\u540c\u5ba1\u6279<\/p>\n \u5373\u53ef\u8fd4\u56de JSON \u62a5\u544a\u7ed9\u524d\u7aef\u7528！<\/p>\n \u6b65\u9aa4\u4e8c：\u6dfb\u52a0\u90ae\u4ef6\u901a\u77e5\u5408\u89c4\u5458\u529f\u80fd<\/h3>\n\u6211\u4eec\u6dfb\u52a0\u4e00\u4e2a\u901a\u7528\u7684\u90ae\u4ef6\u6a21\u5757 utils\/email_notify.py：<\/p>\n # utils\/email_notify.py
\nimport smtplib
\nfrom email.mime.text import MIMEText<\/p>\n SMTP_SERVER = "smtp.example.com"
\nSMTP_PORT = 587
\nSMTP_USER = "your_user@example.com"
\nSMTP_PASS = "your_password"<\/p>\n def send_email(to: str, subject: str, body: str):
\n msg = MIMEText(body, "plain", "utf-8")
\n msg["Subject"] = subject
\n msg["From"] = SMTP_USER
\n msg["To"] = to<\/p>\n with smtplib.SMTP(SMTP_SERVER, SMTP_PORT) as server:
\n server.starttls()
\n server.login(SMTP_USER, SMTP_PASS)
\n server.sendmail(SMTP_USER, to, msg.as_string())<\/p>\n \u7136\u540e\u5728 analyze_contract_process() \u4e2d\u52a0\u5165\u901a\u77e5\u903b\u8f91：<\/p>\n from utils.email_notify import send_email<\/p>\n # \u5185\u90e8\u6d41\u7a0b\u4e2d
\nsend_email(
\n to="compliance@company.com",
\n subject=f"\u3010\u65b0\u5408\u540c\u98ce\u9669\u62a5\u544a\u3011{doc_id}",
\n body=f"\u98ce\u9669\u7b49\u7ea7：{vote_result['\u6700\u7ec8\u98ce\u9669\u7b49\u7ea7']}\\\\n\u8bf7\u767b\u5f55\u4eea\u8868\u76d8\u67e5\u770b\u8be6\u60c5\u3002"
\n)<\/p>\n \u6b65\u9aa4\u4e09：React \u4eea\u8868\u76d8\u90e8\u7f72\u6210 Docker \u955c\u50cf<\/h3>\n\u6587\u4ef6\u7ed3\u6784<\/h4>\nlegal-dashboard\/
\n\u251c\u2500\u2500 public\/
\n\u251c\u2500\u2500 src\/
\n\u2502 \u2514\u2500\u2500 components\/LegalDashboard.tsx
\n\u251c\u2500\u2500 .dockerignore
\n\u251c\u2500\u2500 Dockerfile
\n\u251c\u2500\u2500 package.json
\n\u2514\u2500\u2500 vite.config.ts<\/p>\n Dockerfile \u793a\u4f8b（Dockefile）<\/h4>\n# Step 1: Build
\nFROM node:20 AS builder
\nWORKDIR \/app
\nCOPY . .
\nRUN npm install && npm run build<\/p>\n # Step 2: Serve with nginx
\nFROM nginx:alpine
\nCOPY –from=builder \/app\/dist \/usr\/share\/nginx\/html
\nEXPOSE 80
\nCMD ["nginx", "-g", "daemon off;"]<\/p>\n .dockerignore（Nginx）<\/h4>\nnode_modules
\ndist<\/p>\n \u6784\u5efa\u4e0e\u8fd0\u884c<\/h4>\ndocker build -t legal-dashboard .
\ndocker run -d -p 3000:80 legal-dashboard<\/p>\n \u7136\u540e\u8bbf\u95ee：<\/p>\n http:\/\/localhost:3000<\/p>\n \u524d\u7aef\u5c06\u81ea\u52a8\u8bbf\u95ee：<\/p>\n http:\/\/localhost:8000\/api\/legal_risks?process_id=A\u5408\u540c\u5ba1\u6279<\/p>\n \u5e76\u5c55\u793a\u6700\u65b0\u7684\u6295\u7968\u7ed3\u679c\u3002<\/p>\n","protected":false},"excerpt":{"rendered":" \u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.3k\u6b21\uff0c\u70b9\u8d5e35\u6b21\uff0c\u6536\u85cf31\u6b21\u3002MCP Server \u5176\u5b9e\u5c31\u662f\u4e00\u4e2a\u7b26\u5408 MCP \u534f\u8bae\u89c4\u8303 \u7684 Web Server\uff0c\u672c\u8d28\u4e0a\u662f\u4e00\u4e2a\u80fd\u63a5\u6536 JSON \u8bf7\u6c42\u3001\u6309\u9700\u8bbf\u95ee\u672c\u5730\u8d44\u6e90\uff08\u6587\u4ef6\u3001\u6570\u636e\u5e93\u3001API \u7b49\uff09\u5e76\u8fd4\u56de\u7ed3\u679c\u7684 REST API \u670d\u52a1\u3002_mcp pdf\u63d0\u53d6<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[916,915,50],"topic":[],"class_list":["post-14520","post","type-post","status-publish","format-standard","hentry","category-server","tag-bpm","tag-ecm","tag-50"],"yoast_head":"\n \u90e8\u7f72MCP\u670d\u52a1\u5668\u793a\u4f8b\uff1aIBM BPM\/ECM\u589e\u52a0AI\u529f\u80fd - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/14520.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u90e8\u7f72MCP\u670d\u52a1\u5668\u793a\u4f8b\uff1aIBM BPM\/ECM\u589e\u52a0AI\u529f\u80fd - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.3k\u6b21\uff0c\u70b9\u8d5e35\u6b21\uff0c\u6536\u85cf31\u6b21\u3002MCP Server \u5176\u5b9e\u5c31\u662f\u4e00\u4e2a\u7b26\u5408 MCP \u534f\u8bae\u89c4\u8303 \u7684 Web Server\uff0c\u672c\u8d28\u4e0a\u662f\u4e00\u4e2a\u80fd\u63a5\u6536 JSON \u8bf7\u6c42\u3001\u6309\u9700\u8bbf\u95ee\u672c\u5730\u8d44\u6e90\uff08\u6587\u4ef6\u3001\u6570\u636e\u5e93\u3001API \u7b49\uff09\u5e76\u8fd4\u56de\u7ed3\u679c\u7684 REST API \u670d\u52a1\u3002_mcp pdf\u63d0\u53d6\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/14520.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2025-04-18T13:17:43+00:00\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"24 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/14520.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/14520.html\",\"name\":\"\u90e8\u7f72MCP\u670d\u52a1\u5668\u793a\u4f8b\uff1aIBM BPM\/ECM\u589e\u52a0AI\u529f\u80fd - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2025-04-18T13:17:43+00:00\",\"dateModified\":\"2025-04-18T13:17:43+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/14520.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/14520.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/14520.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u90e8\u7f72MCP\u670d\u52a1\u5668\u793a\u4f8b\uff1aIBM BPM\/ECM\u589e\u52a0AI\u529f\u80fd\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"\u90e8\u7f72MCP\u670d\u52a1\u5668\u793a\u4f8b\uff1aIBM BPM\/ECM\u589e\u52a0AI\u529f\u80fd - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/14520.html","og_locale":"zh_CN","og_type":"article","og_title":"\u90e8\u7f72MCP\u670d\u52a1\u5668\u793a\u4f8b\uff1aIBM BPM\/ECM\u589e\u52a0AI\u529f\u80fd - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.3k\u6b21\uff0c\u70b9\u8d5e35\u6b21\uff0c\u6536\u85cf31\u6b21\u3002MCP Server \u5176\u5b9e\u5c31\u662f\u4e00\u4e2a\u7b26\u5408 MCP \u534f\u8bae\u89c4\u8303 \u7684 Web Server\uff0c\u672c\u8d28\u4e0a\u662f\u4e00\u4e2a\u80fd\u63a5\u6536 JSON \u8bf7\u6c42\u3001\u6309\u9700\u8bbf\u95ee\u672c\u5730\u8d44\u6e90\uff08\u6587\u4ef6\u3001\u6570\u636e\u5e93\u3001API \u7b49\uff09\u5e76\u8fd4\u56de\u7ed3\u679c\u7684 REST API \u670d\u52a1\u3002_mcp pdf\u63d0\u53d6","og_url":"https:\/\/www.wsisp.com\/helps\/14520.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2025-04-18T13:17:43+00:00","author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"24 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/14520.html","url":"https:\/\/www.wsisp.com\/helps\/14520.html","name":"\u90e8\u7f72MCP\u670d\u52a1\u5668\u793a\u4f8b\uff1aIBM BPM\/ECM\u589e\u52a0AI\u529f\u80fd - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2025-04-18T13:17:43+00:00","dateModified":"2025-04-18T13:17:43+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/14520.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/14520.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/14520.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"\u90e8\u7f72MCP\u670d\u52a1\u5668\u793a\u4f8b\uff1aIBM BPM\/ECM\u589e\u52a0AI\u529f\u80fd"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/14520","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=14520"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/14520\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=14520"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=14520"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=14520"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=14520"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}} | | | |