Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/Atom1.5/script/interface/sensor.js – Rev 2298 → 2300

Rev 2298 | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | SVN | RSS feed

         var OregonRainSuccess = "NoSensor";
         var OregonTempHumSuccess = "NoSensor";
         var OregonWindSuccess = "NoSensor";
         var VikingSuccess = "NoVikingSensor";
         var VikingSteakSuccess = "NoVikingSteakSensor";
+        var RubicsonStationSuccessPkt1 = "NoSensor";
-        //Log("found sensor: "+variables["Protocol"]);
+        var RubicsonStationSuccessPkt2 = "NoSensor";
         if (variables["Protocol"] == "OregonRain")
+        {
             /* ----------- Data order proto-data ------
             * cc bb bb bb aa aa
             * a   = Rain in 0.01 inches per hour
             var byte0 = rshift(data,32)&0xF;
             var byte1 = rshift(data,28)&0xF;
             var byte2 = rshift(data,24)&0xF;
             var temp = Math.round((((((byte1^byte2)<<8)+((byte0^byte1)<<4)+byte0^10)-122)*5)/9);
             VikingSteakSuccess = "VikingNotFound";
+        } else if (variables["Protocol"] == "RubicsonStn")
+        {
+            var data = variables["IRdata"];
+            var pkt = rshift(data,39)&0x1;
+            if (pkt == 0)  //This is the first part
+            {
+                /*
+                      aaaaaaaa 0dddsttt tttttttt hhhhhhhh wwwwwwww wwwwwwww
+b11111001 11111001 00001100 10110010 11100011 01101111
+                a = address = winddirection, s = sign, t = temperature, h = humidity, w = vindspeed
+                */
+                var windspeed_avg = (rshift(data,8) & 0xFF)*0.8;
+                var windspeed_max = (data & 0xFF)*0.8;
+                //var crc = data&0xFF;
+                var humidity = rshift(data,16)&0xFF;
+                var temp = rshift(data,24)&0xFFF;
+                var winddirection = (rshift(data,36)&0x7)*360/8;
+                var addr = rshift(data,40)&0xFF;
+                //var calccrc=crc8(rshift(data,8), 32);
+                var sign = (temp>>>11)&1;
+                if (sign > 0)
+                {
+                    temp = temp^0xFFF;
+                    temp += 1;
+                    temp = -temp;
+                }
+                temp = temp/10;
+                RubicsonStationSuccessPkt1 = "NotFound";
+            } else //This is the second part
+            {
+                /*
+                      aaaaaaaa 1------- -------b rrrrrrrr rrrrrrrr rrrrrrrr
+b11111001 11111001 00001100 10110010 11100011 01101111
+                a = address b = battery empty, r = rain
+                */
+                var battery = rshift(data,24) & 0x1;
+                //var crc = data&0xFF;
+                var rain = 0.4*(data&0xFFFFFF);
+                var addr = rshift(data,40)&0xFF;
+                RubicsonStationSuccessPkt2 = "NotFound";
+            }
+        }
         loopAliases:    /* Label to break nested */
         for (var alias_name in aliases_data)
+        {
             if (aliases_data[alias_name]["specific"]["Channel"] == variables["Channel"] &&
                 aliases_data[alias_name]["specific"]["Proto"] == variables["Protocol"])
+            {
                 switch (variables["Protocol"])
                 {
-                    case "Viking":
+                    case "RubicsonStn":
-                    {   /* Add alias with these specifics: Channel=0,Proto=Viking,Address=<address of sensor> */
+                    {   /* Add alias with these specifics: Channel=0,Proto=RubicsonStn,Address=<address of sensor> */
+                        /* if no Address is added to the alias, all RubicsonStn will match*/
+                        if (aliases_data[alias_name]["specific"]["Address"] == undefined)
+                        {
-                        if (type == 4)
+                            if (pkt == 0)
-                        {
+                            {
+                                var last_value = {};
+                                var last_value_string = Storage_GetParameter("LastValues", alias_name);
-                            if (crc != calccrc)
+                                if (last_value_string)
+                                {
+                                    last_value = eval("(" + last_value_string + ")");
+                                }
+                                var timestamp = get_time();
+                                last_value["Temperature_Celsius"] = { "value" : temp.toString(), "timestamp" : timestamp };
+                                last_value["Humidity_Percent"] = { "value" : humidity.toString(), "timestamp" : timestamp };
+                                last_value["Wind_Speed_Avg"] = { "value" : windspeed_avg.toString(), "timestamp" : timestamp };
+                                last_value["Wind_Speed_Max"] = { "value" : windspeed_max.toString(), "timestamp" : timestamp };
+                                last_value["Wind_Direction"] = { "value" : winddirection.toString(), "timestamp" : timestamp };
+                                last_value["Address"] = { "value" : addr, "timestamp" : timestamp };
+                                Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));
+                                RubicsonStationSuccessPkt1 = "RubicsonStnFound";
+                                break loopAliases;
+                            } else
                             {
+                              var last_value = {};
-                                Log("\033[31mError: VikingSensor, incorrect CRC, data="+data+", CRC="+crc+", calcCRC="+calccrc+"\033[0m");
+                                var last_value_string = Storage_GetParameter("LastValues", alias_name);
+                                if (last_value_string)
+                                {
+                                    last_value = eval("(" + last_value_string + ")");
+                                }
+                                var timestamp = get_time();
+                                last_value["WaterAbsolute_mm"] = { "value" : rain.toString(), "timestamp" : timestamp };
+                                last_value["Battery_Low"] = { "value" : battery.toString(), "timestamp" : timestamp };
+                                last_value["Address"] = { "value" : addr, "timestamp" : timestamp };
+                                Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));
+                                RubicsonStationSuccessPkt2 = "RubicsonStnFound";
                                 break loopAliases;
+                            }
+                        }
+                        else if (addr == aliases_data[alias_name]["specific"]["Address"])
+                        {
+                            if (pkt == 0)
+                            {
+                                var last_value = {};
+                                var last_value_string = Storage_GetParameter("LastValues", alias_name);
+                                if (last_value_string)
+                                {
+                                    last_value = eval("(" + last_value_string + ")");
+                                }
+                                var timestamp = get_time();
+                                last_value["Temperature_Celsius"] = { "value" : temp.toString(), "timestamp" : timestamp };
+                                last_value["Humidity_Percent"] = { "value" : humidity.toString(), "timestamp" : timestamp };
+                                last_value["Wind_Speed"] = { "value" : windspeed.toString(), "timestamp" : timestamp };
+                                last_value["Wind_Direction"] = { "value" : winddirection.toString(), "timestamp" : timestamp };
+                                last_value["Address"] = { "value" : addr, "timestamp" : timestamp };
-                            if (addr == aliases_data[alias_name]["specific"]["Address"])
+                                Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));
+                                RubicsonStationSuccessPkt1 = "RubicsonStnFound";
+                                break loopAliases;
+                            } else
+                            {
+                              var last_value = {};
+                                var last_value_string = Storage_GetParameter("LastValues", alias_name);
+                                if (last_value_string)
+                                {
+                                    last_value = eval("(" + last_value_string + ")");
+                                }
+                                var timestamp = get_time();
+                                last_value["WaterAbsolute_mm"] = { "value" : (rain*0.4).toString(), "timestamp" : timestamp };
+                                last_value["Battery_Low"] = { "value" : battery.toString(), "timestamp" : timestamp };
+                                last_value["Address"] = { "value" : addr, "timestamp" : timestamp };
+                                Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));
+                                RubicsonStationSuccessPkt2 = "RubicsonStnFound";
+                                break loopAliases;
+                            }
+                        }
+                        break;
+                    }
+                    case "Viking":
+                    {   /* Add alias with these specifics: Channel=0,Proto=Viking,Address=<address of sensor> */
+                        if (type == 4)
+                        {
+                            if (crc != calccrc)
+                            {
+                                Log("\033[31mError: VikingSensor, incorrect CRC, data="+data+", CRC="+crc+", calcCRC="+calccrc+"\033[0m");
+                                break loopAliases;
+                            }
+                            if (addr == aliases_data[alias_name]["specific"]["Address"])
+                            {
                                 VikingSuccess = "VikingFound";
                                 var last_value = {};
                                 var last_value_string = Storage_GetParameter("LastValues", alias_name);
                                 if (last_value_string)
+                                {
+                                }
                                 var timestamp = get_time();
                                 last_value["Temperature_Celsius"] = { "value" : temp.toString(), "timestamp" : timestamp };
                                 if (humidity<101)
                                 {
                                     last_value["Humidity_Percent"] = { "value" : humidity.toString(), "timestamp" : timestamp };
+                                }
                                 Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));
                                 break loopAliases;
+                            }
                         }
                         else if (type == 3)
+                        {
                             /* Don't check crc since all bits did not fit in CAN-frame */
                             if (addr == aliases_data[alias_name]["specific"]["Address"])
                             {
                                 VikingSuccess = "VikingFound";
                                 var last_value = {};
                                 var last_value_string = Storage_GetParameter("LastValues", alias_name);
                                 if (last_value_string)
                                 {
                                     last_value = eval("(" + last_value_string + ")");
+                                }
                                 var timestamp = get_time();
                                 temp = temp-40.0;
                             /*if (humidity<101)
+                            {
                                 last_value["Humidity_Percent"] = { "value" : humidity.toString(), "timestamp" : timestamp };
+                            }
                             */
                             Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));
                             break loopAliases;
                         }
                         break;
                     }
                     case "VikingSteak":
                     {   /* Add alias with these specifics: Channel=0,Proto=VikingSteak,Address=<address of sensor> */
                         /* if no Address is added to the alias, all vikingSteaksensors will match*/
                         if (aliases_data[alias_name]["specific"]["Address"] == undefined)
+                        {
                             VikingSteakSuccess = "VikingFound";
                             var last_value = {};
                             var last_value_string = Storage_GetParameter("LastValues", alias_name);
                             if (last_value_string)
                             {
                                 last_value = eval("(" + last_value_string + ")");
+                            }
                             var timestamp = get_time();
                             last_value["Temperature_Celsius"] = { "value" : temp.toString(), "timestamp" : timestamp };
                             break loopAliases;
+                        }
                         else if (addr == aliases_data[alias_name]["specific"]["Address"])
+                        {
                             VikingSteakSuccess = "VikingFound";
                             var last_value = {};
                             var last_value_string = Storage_GetParameter("LastValues", alias_name);
                             if (last_value_string)
                             {
                                 last_value = eval("(" + last_value_string + ")");
+                            }
                             var timestamp = get_time();
                             last_value["Temperature_Celsius"] = { "value" : temp.toString(), "timestamp" : timestamp };
+                    }
                     case "Nexa2":
                     {   /* Add alias with these specifics: Channel=0,Proto=Nexa2,OnData=<data for on>,OffData=<data for off> */
                         var deviceStateCommand = "";
                         if (variables["IRdata"] == aliases_data[alias_name]["specific"]["OnData"] && variables["Status"] == "Pressed")
                         {
                             deviceStateCommand = "On";
+                        }
                         else if (variables["IRdata"] == aliases_data[alias_name]["specific"]["OffData"] && variables["Status"] == "Pressed")
+                        {
                             deviceStateCommand = "Off";
+                        }
                         else
                         {
                             break;
                         }
                         var last_value = {};
                         var last_value_string = Storage_GetParameter("LastValues", alias_name);
                         if (last_value_string)
+                        {
                             last_value = eval("(" + last_value_string + ")");
                         }
                         if (( typeof(last_value["State"]) == "undefined" ) ||
                             ( deviceStateCommand == "Off" && last_value["State"]["value"] == "On" ) ||
                             ( deviceStateCommand == "On" && last_value["State"]["value"] == "Off" ))
+                        {
                                     /* Call callback with arguments alias, state */
                                     Sensor_OnDeviceStateChangeFunctions[alias_name][n](alias_name, deviceStateCommand);
+                                }
+                            }
+                        }
                         break;
                     }
                 }
             }
+        }
         if (VikingSuccess == "VikingNotFound")
         {
             Log("Found unknown vikingsensor address="+addr+" temperature="+temp+" humidity="+humidity+" protocol type="+type);
+        }
         if (VikingSteakSuccess == "VikingNotFound")
+        {
             Log("Found unknown vikingSteaksensor address="+addr+" temperature="+temp);
         }
         if (RubicsonSuccess == "RubicsonNotFound")
+        {
             Log("Found unknown Rubicson sensor address="+addr+" temperature="+temp);
+        }
         if (OregonTempHumSuccess == "NotFound")
         {
             Log("Found unknown oregon temp/humidity sensor address="+addr+" temperature="+temp +" humidity="+humidity+" unknown="+unknown + " bat="+bat);
+        }
         if (OregonRainSuccess == "NotFound")
+        {
             Log("Found unknown oregon rain sensor address="+addr+" tot inch="+totInch +" totMM="+totMM+" inch/h="+inchPerHour + " mm/h="+mmPerHour +" bat="+bat);
         }
         if (OregonWindSuccess == "NotFound")
         {
             Log("Found unknown oregon wind sensor address="+addr+" Average="+average +" current="+current+" direction="+direction +" bat="+bat);
+        }
+        if (RubicsonStationSuccessPkt1 == "NotFound")
+        {
+            Log("Found unknown rubicson weather station, Packet 1 address="+addr + " temperature="+temp + " humidity="+humidity+" WindSpeed="+windspeed + " WindDirection="+winddirection);
+        }
+        if (RubicsonStationSuccessPkt2 == "NotFound")
+        {
+            Log("Found unknown rubicson weather station, Packet 2 address="+addr + " Rain="+rain + "mm BatteryLow="+battery);
+        }
+    }
+}
 Module_RegisterToOnMessage("all", SensorRf_OnMessage);