泵類(lèi)型: 離心式冷卻液泵 (Centrifugal Coolant Pump)


泵型號(hào) : CoolFlow Pro 5000


設(shè)備 ID: PUMP-CNC-001


使用場(chǎng)景: 安裝在一臺(tái)中型 CNC 立式加工中心 (Machine ID: VMC-03) 上，用于循環(huán)供給水基切削液，冷卻刀具和工件。該機(jī)床主要加工鋼材和鋁合金零件，實(shí)行兩班倒工作制 (16小時(shí)/天)。泵已運(yùn)行約 18 個(gè)月。


關(guān)鍵監(jiān)測(cè)參數(shù): 振動(dòng) (mm/s RMS), 溫度 (°C), 出口壓力 (Bar), 流量 (L/min)。

1、IoT 數(shù)據(jù) (`IOT.json` & `/api/pump/status`):


    *   包含泵的實(shí)時(shí)傳感器讀數(shù)，如時(shí)間戳 (`timestamp`)、軸向/徑向振動(dòng) (`vibration_axial`/`radial`)、電機(jī)/軸承溫度 (`temperature_motor`/`bearing`)、出口壓力 (`pressure_outlet`)、流量 (`flow_rate`)。
    *   模擬了數(shù)據(jù)隨時(shí)間變化，包含正常和逐漸異常的狀態(tài)。


 2、MES 數(shù)據(jù) (`MES.json` & `/api/mes/pump/operation`):
    *   提供泵的運(yùn)行日志，關(guān)聯(lián)的設(shè)備 (`associated_machineId`)，運(yùn)行小時(shí)數(shù) (`operating_hours`)，處理的工單 (`jobs_processed`) 等。
    *   有助于了解泵的工作負(fù)載和上下文。


3、CMMS 數(shù)據(jù) (`CMMS.json` & `/api/cmms/pump/history`):
    *   包含歷史維護(hù)記錄 (`maintenance_records`)：工單號(hào)、日期、類(lèi)型、描述、更換部件、停機(jī)時(shí)間等。
    *   包含相關(guān)故障信息 (`related_failures_info`)：其他泵（或本機(jī)歷史）的故障案例，包括癥狀、故障模式、根本原因、糾正措施。這是重要的知識(shí)來(lái)源。


4、ERP 數(shù)據(jù) (`ERP.json` & `/api/erp/spare_parts`):
    *   提供備件信息：零件 ID (`partId`)、名稱(chēng) (`name`)、描述、適用泵型號(hào)、供應(yīng)商、庫(kù)存水平 (`stock_level`)、單價(jià) (`unit_price`)、采購(gòu)提前期 (`lead_time_days`)。
    *   用于生成維護(hù)建議時(shí)考慮備件可用性。


 模擬維護(hù)完成后，實(shí)際執(zhí)行情況的反饋數(shù)據(jù)，用于評(píng)估預(yù)測(cè)準(zhǔn)確性和閉環(huán)優(yōu)化。

ELSE (正常):  流向 ANSWER 節(jié)點(diǎn)，輸出簡(jiǎn)單的狀態(tài)正常信息。

IF (異常):  啟動(dòng)預(yù)測(cè)性維護(hù)流程。

調(diào)用 GET_CMMS_DATA 和 GET_MES_DATA 獲取歷史維護(hù)和運(yùn)行數(shù)據(jù)。

調(diào)用 KNOWLEDGE_RETRIEVAL 節(jié)點(diǎn)，結(jié)合當(dāng)前異常指標(biāo)查詢(xún)知識(shí)庫(kù) (離心泵設(shè)備手冊(cè) pdf、歷史維修案例 excel)。

**START:** 定義工作流入口參數(shù) (`pumpId`)。
  **GET\_... (HTTP Request):** 與模擬 API 交互，獲取各類(lèi)數(shù)據(jù)。
  **CODE (解析 IoT):** 解析 IoT JSON，提取關(guān)鍵指標(biāo)，**計(jì)算 `needs_maintenance` 標(biāo)志**。
  **IF/ELSE:** 根據(jù) `needs_maintenance` 標(biāo)志進(jìn)行流程分支。
  **KNOWLEDGE_RETRIEVAL:** (可選) 連接外部知識(shí)庫(kù)進(jìn)行 RAG 查詢(xún)。
  **FAULT_PREDICTION (LLM):** 基于多源信息進(jìn)行故障診斷與預(yù)測(cè)。
  **EXTRACT_PART_ID (CODE):** 從 LLM 輸出中解析結(jié)構(gòu)化信息 (Part ID)。
  **PARSE_ERP_DATA (CODE):** 解析 ERP 返回的 JSON 列表字符串。
  **SUGGESTIONS (LLM):** 結(jié)合故障預(yù)測(cè)和備件信息生成維護(hù)建議。
  **ANSWER / ANSWER 2:** 輸出最終結(jié)果。

1.  HTTP 請(qǐng)求：URL 與參數(shù)混淆
    *   **節(jié)點(diǎn):** `GET_IOT_DATA`
    *   **報(bào)錯(cuò):** `Invalid non-printable ASCII character...`
    *   **原因:** 同時(shí)在 URL 字段和 PARAMS 字段中定義了查詢(xún)參數(shù)。
    *   **解決:** URL 只寫(xiě)基礎(chǔ)路徑，參數(shù)在 PARAMS 中定義 (推薦: `{{start.pumpId}}`)。


2.  HTTP 請(qǐng)求：網(wǎng)絡(luò)訪問(wèn) & CORS 
    *   **節(jié)點(diǎn):** 所有 HTTP 請(qǐng)求節(jié)點(diǎn)
    *   **報(bào)錯(cuò):** Dify 404，但 API 日志顯示 200 OK。
    *   **原因:** API 服務(wù)監(jiān)聽(tīng)地址限制；缺少 CORS 配置。
    *   **解決:**
        *   API (`mock_api.py`): 啟動(dòng)時(shí) `host='0.0.0.0'`。
        *   API (`mock_api.py`): 安裝 `flask-cors` 并啟用 `CORS(app)`。


3.  數(shù)據(jù)處理：JSON 字符串解析 
    *   **節(jié)點(diǎn):** `CODE` (解析 IoT), `IF/ELSE`, `ANSWER`
    *   **報(bào)錯(cuò):** `IF/ELSE` 條件不生效；`ANSWER` 直接輸出占位符。
    *   **原因:** HTTP 節(jié)點(diǎn)返回的 `body` 是 JSON **字符串**，而非結(jié)構(gòu)化對(duì)象。
    *   **解決:** 在 HTTP 節(jié)點(diǎn)后加 `CODE` 節(jié)點(diǎn)，用 `json.loads()` 解析 `body` 字符串，輸出解析后的對(duì)象/列表供后續(xù)節(jié)點(diǎn)使用。


4.  IF/ELSE 節(jié)點(diǎn)：數(shù)值比較類(lèi)型問(wèn)題 
    *   **節(jié)點(diǎn):** `IF/ELSE`
    *   **報(bào)錯(cuò):** 數(shù)值比較條件 (`> 6.0`) 不生效。
    *   **原因:** `IF/ELSE` 可能將變量視為字符串進(jìn)行比較。
    *   **解決:** 將比較邏輯移入 `CODE` 節(jié)點(diǎn)，輸出簡(jiǎn)單標(biāo)志位 (如 `"1"`/`"0"` 字符串)，`IF/ELSE` 只判斷此標(biāo)志位。


5.  CODE 節(jié)點(diǎn)：Python 語(yǔ)法 & 類(lèi)型錯(cuò)誤 
    *   **節(jié)點(diǎn):** 所有 `CODE` 節(jié)點(diǎn)
    *   **報(bào)錯(cuò):** `IndentationError`, `NameError`, `Output variable 'xxx' must be a [Type]`。
    *   **原因:** 縮進(jìn)錯(cuò)誤；變量未定義；Dify 輸出類(lèi)型配置與代碼返回不符。
    *   **解決:** 嚴(yán)格檢查 Python 縮進(jìn)；確保 `return` 前所有變量已定義賦值；確保 Dify 中輸出變量的**名稱(chēng)和類(lèi)型**與代碼 `return` **完全匹配** (e.g., Part ID 是 String)。


6.  TEMPLATE 節(jié)點(diǎn)：Jinja2 語(yǔ)法 & 數(shù)據(jù)錯(cuò)誤 
    *   **節(jié)點(diǎn):** `TEMPLATE`
    *   **報(bào)錯(cuò):** `jinja2.exceptions.TemplateSyntaxError`。
    *   **原因:** 括號(hào)錯(cuò)誤 (`{{{` vs `{{`, `}} }`); 控制結(jié)構(gòu)括號(hào)錯(cuò)誤 (`{{%` vs `{%`); 變量名不匹配；在未解析數(shù)據(jù)上訪問(wèn)屬性。
    *   **解決:** 修正 Jinja2 語(yǔ)法；確保模板變量名與輸入變量名**完全一致**；對(duì)列表/字典數(shù)據(jù)，**先用 CODE 解析**再傳入模板，并使用 `{% for %}` 訪問(wèn)循環(huán)變量屬性 (`{{ part.name }}`)。

1.  獲取真實(shí) API 信息:** 獲取真實(shí)的 IoT、CMMS、MES、ERP 系統(tǒng)的 API 詳細(xì)信息：
    
    *   **URL 端點(diǎn) (Endpoint):** 每個(gè)系統(tǒng)提供數(shù)據(jù)的具體網(wǎng)址。
        
    *   **請(qǐng)求方法 (Method):** GET, POST, PUT, DELETE 等。
        
    *   **認(rèn)證方式 (Authentication):** 如何驗(yàn)證 Dify 的訪問(wèn)權(quán)限？可能是 API Key (放在 Header 或 Query Param)、OAuth 2.0 Token (放在 Header)、用戶(hù)名密碼等。
        
    *   **請(qǐng)求參數(shù)/體 (Parameters/Body):** 如何指定要查詢(xún)的設(shè)備 ID、時(shí)間范圍、零件 ID 等？是在 URL 參數(shù)中，還是在 POST 請(qǐng)求的 Body 中？Body 的格式是 JSON、XML 還是其他？
        
    *   **響應(yīng)格式 (Response Format):** 真實(shí)系統(tǒng)返回的數(shù)據(jù)結(jié)構(gòu)是怎樣的？與模擬的 JSON 結(jié)構(gòu)是否一致？
        
2.  修改 Dify HTTP Request 節(jié)點(diǎn):
    
    *   定位工作流中所有調(diào)用模擬 API 的 HTTP Request 節(jié)點(diǎn) (`GET_IOT_DATA`, `GET_CMMS_DATA`, `GET_MES_DATA`, `GET_ERP_DATA`)。
        
    *   **更新 URL:** 將節(jié)點(diǎn)的 URL 字段替換為真實(shí) API 的端點(diǎn)。
        
    *   **調(diào)整方法:** 根據(jù)真實(shí) API 要求修改請(qǐng)求方法 (GET/POST 等)。
        
    *   **配置認(rèn)證:** 在節(jié)點(diǎn)的 `Headers` 或 `Params` 部分添加必要的認(rèn)證信息 (如 `Authorization: Bearer <token>`, `X-API-Key: <key>`)。
        
    *   **適配參數(shù)/體:** 根據(jù)真實(shí) API 要求修改 `Params` 或 `Body` 的內(nèi)容和格式。
        
3.  適配數(shù)據(jù)解析 (關(guān)鍵步驟??):
    
    *   真實(shí) API 返回的數(shù)據(jù)結(jié)構(gòu)**極有可能**與模擬 JSON 不同。
        
    *   因此，所有緊跟在 HTTP Request 節(jié)點(diǎn)之后的 `CODE` 節(jié)點(diǎn)（如解析 IoT 的 `CODE` 節(jié)點(diǎn), `PARSE_ERP_DATA` 節(jié)點(diǎn)，以及可能需要為 CMMS/MES 新增的解析節(jié)點(diǎn)）**必須進(jìn)行修改**。
        
    *   需要根據(jù)真實(shí) API 返回的 JSON (或其他格式) 結(jié)構(gòu)，調(diào)整 Python 代碼中 `json.loads()` 之后訪問(wèn)數(shù)據(jù)的方式（字典鍵名、列表索引、嵌套結(jié)構(gòu)等），以確保存儲(chǔ)到 Dify 輸出變量中的是后續(xù)節(jié)點(diǎn)期望的數(shù)據(jù)。
        
    *   **這是最容易出錯(cuò)的環(huán)節(jié)，需要仔細(xì)比對(duì)真實(shí) API 的響應(yīng)并耐心調(diào)試** `CODE` **節(jié)點(diǎn)的 Python 代碼。
        
4.  端到端測(cè)試:** 修改完成后，使用真實(shí)的設(shè)備 ID 或測(cè)試 ID 進(jìn)行完整的端到端測(cè)試，驗(yàn)證：
    
    *   是否能成功從所有真實(shí)系統(tǒng)中獲取數(shù)據(jù)。
        
    *   數(shù)據(jù)解析是否正確。
        
    *   LLM 節(jié)點(diǎn)接收到的上下文是否符合預(yù)期。
        
    *   整個(gè)流程是否能按預(yù)期運(yùn)行。

告警通知: 在檢測(cè)到異常時(shí)，通過(guò) HTTP 請(qǐng)求節(jié)點(diǎn)調(diào)用企業(yè)微信、釘釘、郵件等的 API 發(fā)送告警通知。

工單系統(tǒng)集成: 將 `SUGGESTIONS` 生成的維護(hù)建議通過(guò) API 推送到 CMMS 系統(tǒng)，自動(dòng)創(chuàng)建維護(hù)工單。