11.12：添加信号量同步机制；完成网关节点对环境节点的执行器控制功能。

2025-11-12 02:22:38 +08:00
parent 998b8a45d0
commit bfc15aaa18
7 changed files with 310 additions and 236 deletions
--- a/STM32/Environment_Node/Drivers/LoRa.c
+++ b/STM32/Environment_Node/Drivers/LoRa.c
@@ -84,7 +84,112 @@ void vLoRaToGateExeIdPkt(uint8_t ucExeId)
    }
 }

-void vLoRaReceivedMesg(void)
+eLoRaMsgRecStatus xLoRaMessageReceived(uint8_t *pucData)
 {
+    switch (*pucData)
+    {
+        case 0xD1:
+        /* code */
+        return statusNode1;
    
+        case 0xD2:
+        return statusNode2;
+
+        case 0xFA:
+        return statusExeLed;
+
+        case 0xFB:
+        return statusExeFan;
+
+        case 0xFC:
+        return statusExeHumidifier;
+
+        case 0xFD:
+        return statusExeBuzzer;
+
+        case 0xFE:
+        return statusExeServo;
+
+        case 0x01:
+        return statusExeOn;
+
+        case 0x00:
+        return statusExeOff;
+
+        default:
+        return statusNode1;
+    }
+}
+
+eLoRaMsgRecStatus xLoRaMsgProcess(uint8_t ucDataRecNodeId, uint8_t ucDataRecExeId, uint8_t ucDataRecExeSta)
+{
+    switch (xLoRaMessageReceived(&ucDataRecNodeId))
+    {
+        case statusNode1:
+        /* code */
+        while (xLoRaMessageReceived(&ucDataRecExeSta) == statusExeOn)
+        {
+            /* code */
+            if (xLoRaMessageReceived(&ucDataRecExeId) == statusExeLed)
+            {
+                /* code */
+                return statusLedOn;
+            } else if (xLoRaMessageReceived(&ucDataRecExeId) == statusExeFan)
+            {
+                /* code */
+                return statusFanOn;
+            } else if (xLoRaMessageReceived(&ucDataRecExeId) == statusExeHumidifier)
+            {
+                /* code */
+                return statusHumidifierOn;
+            }
+        }
+        while (xLoRaMessageReceived(&ucDataRecExeSta) == statusExeOff)
+        {
+            /* code */
+            if (xLoRaMessageReceived(&ucDataRecExeId) == statusExeLed)
+            {
+                /* code */
+                return statusLedOff;
+            } else if (xLoRaMessageReceived(&ucDataRecExeId) == statusExeFan)
+            {
+                /* code */
+                return statusFanOff;
+            } else if (xLoRaMessageReceived(&ucDataRecExeId) == statusExeHumidifier)
+            {
+                /* code */
+                return statusHumidifierOff;
+            }
+        }
+        
+        case statusNode2:
+        while (xLoRaMessageReceived(&ucDataRecExeSta) == statusExeOn)
+        {
+            /* code */
+            if (xLoRaMessageReceived(&ucDataRecExeId) == statusExeBuzzer)
+            {
+                /* code */
+                return statusBuzzerOn;
+            } else if (xLoRaMessageReceived(&ucDataRecExeId) == statusExeServo)
+            {
+                /* code */
+                return statusServoOn;
+            }
+        }
+        while (xLoRaMessageReceived(&ucDataRecExeSta) == statusExeOff)
+        {
+            /* code */
+            if (xLoRaMessageReceived(&ucDataRecExeId) == statusExeBuzzer)
+            {
+                /* code */
+                return statusBuzzerOff;
+            } else if (xLoRaMessageReceived(&ucDataRecExeId) == statusExeServo)
+            {
+                /* code */
+                return statusServoOff;
+            }
+        }
+        default:
+        return statusNode1;
+    }
 }