Проверка контрольной сумму для MHZ-19.

[weathermon.git] / bin / weathermon-iio

diff --git a/bin/weathermon-iio b/bin/weathermon-iio
index 7fe5f68af08639a3340c5f348b177235324915d6..d288edf935d599d63f236ca97835c663c85313fb 100755 (executable)
--- a/bin/weathermon-iio
+++ b/bin/weathermon-iio
@@ -9,6 +9,21 @@ socket = require "socket"
 
 require "wm_util"
 
 
 require "wm_util"
 

+io.stdout:setvbuf('no')
+
+function dump(o)
+   if type(o) == 'table' then
+      local s = '{ '
+      for k,v in pairs(o) do
+         if type(k) ~= 'number' then k = '"'..k..'"' end
+         s = s .. '['..k..'] = ' .. dump(v) .. ','
+      end
+      return s .. '} '
+   else
+      return tostring(o)
+   end
+end
+

 function get_device_list(config_name)
 
   local devices
 function get_device_list(config_name)
 
   local devices


@@ -61,69 +76,151 @@ function find_device(name,subsystem)
 
 end
 
 
 end
 

-function init_device(device,parameters,i2c_bus)
+function get_parameter(record)
+  return tonumber(get_file_content(record["path"])) * record["scale"] + record["correction"]
+end
+
+function string.fromhex(str)
+  return (str:gsub('..', function (cc)
+    return string.char(tonumber(cc, 16))
+  end))
+end
+
+function string.tohex(str)
+  return (str:gsub('.', function (c)
+    return string.format('%02X', string.byte(c))
+  end))
+end
+
+function get_mhz(record)
+  local p = record["rs232"]  
+  p:read(9,100)
+  p:write(string.fromhex("ff0186000000000079"))
+  local e, s = p:read(9,1000)
+  if (e == 0) and (s:len() == 9) and (s:byte(1) == 255) then
+    local crc = 0
+    for i = 2, 8 do
+      crc = crc + s:byte(i)
+      if (crc>=256) then
+        crc = crc - 256
+      end  
+    end  
+    crc = 255 - crc
+    crc = crc + 1;
+    if crc == s:byte(9) then
+      return s:byte(3)*256+s:byte(4)
+    end  
+  end
+  
+  return nil
+   
+end
+
+function init_serial_device(device,subsystem,parameters)
+
+  rs232 = require("luars232")
+
+  pcall(function ()
+
+    local e, port = rs232.open(device["port"])
+  
+    if subsystem == "mhz" then
+    
+      assert(port:set_baud_rate(rs232.RS232_BAUD_9600) == rs232.RS232_ERR_NOERROR)
+      assert(port:set_data_bits(rs232.RS232_DATA_8) == rs232.RS232_ERR_NOERROR)
+      assert(port:set_parity(rs232.RS232_PARITY_NONE) == rs232.RS232_ERR_NOERROR)
+      assert(port:set_stop_bits(rs232.RS232_STOP_1) == rs232.RS232_ERR_NOERROR)
+      assert(port:set_flow_control(rs232.RS232_FLOW_OFF)  == rs232.RS232_ERR_NOERROR)
+    
+      getparameter = {}
+
+      getparameter["rs232"] = port
+      getparameter["function"] = get_mhz 
+      getparameter["name"] = "CO2_PPM"
+      getparameter["sensor"] = "MHZ19"
+      parameters[#parameters+1] = getparameter
+
+    end
+    
+  end)
+
+end
+
+function init_i2c_device(device,subsystem,parameters)

 
   if not i2c_bus then
     i2c_bus = 0
   end
 
 
   if not i2c_bus then
     i2c_bus = 0
   end
 

-  if device["module"] then
-    os.execute("modprobe "..device["module"])
-  end    
+  pcall(function ()
+    local f = io.open("/sys/class/i2c-dev/i2c-"..i2c_bus.."/device/new_device","w")
+    io.output(f)
+    io.write(device["name"].." "..device["address"])
+    io.close(f)
+  end)  

 
 

-  if device["type"] then
+  device_path=find_device(device["name"],subsystem)

 
 

-    devtype = split(device["type"],":")
-    bus = devtype[1]
-    subsystem = devtype[2]
-    
-    if (bus == "i2c") and device["address"] and device["name"] then
+  if device_path and device["set_param"] then
+    for key,record in pairs(device["set_param"]) do
+      setparam = split(record,":")
+      setpath = device_path.."/"..setparam[1]

       pcall(function ()
       pcall(function ()

-        local f = io.open("/sys/class/i2c-dev/i2c-"..i2c_bus.."/device/new_device","w")
+        local f = io.open(setpath,"w")

         io.output(f)
         io.output(f)

-        io.write(device["name"].." "..device["address"])
+        io.write(setparam[2])

         io.close(f)
       end)  
     end
         io.close(f)
       end)  
     end

+  end

 
 

-    device_path=find_device(device["name"],subsystem)
-
-    if device_path and device["set_param"] then
-      for key,record in pairs(device["set_param"]) do
-        setparam = split(record,":")
-        setpath = device_path.."/"..setparam[1]
-        pcall(function ()
-          local f = io.open(setpath,"w")
-          io.output(f)
-          io.write(setparam[2])
-          io.close(f)
-        end)  
+  if device_path and device["parameter"] then
+
+    for key,record in pairs(device["parameter"]) do
+
+      getparam = split(record,":")
+      getparameter = {}
+      getparameter["path"] = device_path.."/"..getparam[1]
+      getparameter["name"] = getparam[2]
+      getscale = getparam[3]
+      getcorrection = getparam[4]
+      if not getscale then
+        getscale = 1
+      end  
+      if not getcorrection then
+        getcorrection = 0

       end
       end

+      getparameter["scale"] = tonumber(getscale)
+      getparameter["sensor"] = device["name"]:upper()
+      getparameter["correction"] = tonumber(getcorrection)
+      getparameter["function"] = get_parameter
+      parameters[#parameters+1] = getparameter
+

     end
     end

+
+  end
+  
+end
+
+function init_device(device,parameters)
+
+  if device["module"] then
+    os.execute("modprobe "..device["module"])
+  end    
+
+  if device["type"] then
+
+    devtype = split(device["type"],":")
+    bus = devtype[1]
+    subsystem = devtype[2]

     
     

-    if device_path and device["parameter"] then
+    if (bus == "i2c") then
+
+      init_i2c_device(device,subsystem,parameters)

     
     

-      for key,record in pairs(device["parameter"]) do
-      
-        getparam = split(record,":")
-        getparameter = {}
-        getparameter["path"] = device_path.."/"..getparam[1]
-        getparameter["name"] = getparam[2]
-        getscale = getparam[3]
-        getcorrection = getparam[4]
-        if not getscale then
-          getscale = 1
-        end  
-        if not getcorrection then
-          getcorrection = 0
-        end
-        getparameter["scale"] = tonumber(getscale)
-        getparameter["sensor"] = device["name"]:upper()
-        getparameter["correction"] = tonumber(getcorrection)
+    elseif (bus == "serial") then

       
       

-        parameters[#parameters+1] = getparameter
-       
-      end
+      init_serial_device(device,subsystem,parameters) 

     
     end
     
     
     end
     


@@ -144,7 +241,7 @@ function init(config_name)
     device = get_device(config_name,devname)
     
     if device then
     device = get_device(config_name,devname)
     
     if device then

-      init_device(device,parameters,i2c_bus)
+      init_device(device,parameters)

     end  
   
   end
     end  
   
   end


@@ -153,18 +250,18 @@ function init(config_name)
 
 end
 
 
 end
 

-function get_parameter(parameter)
-  return tonumber(get_file_content(parameter["path"])) * parameter["scale"] + parameter["correction"]
-end
-

 function get_parameters(parameters)
   local results = {}
   for key,record in pairs(parameters) do
 function get_parameters(parameters)
   local results = {}
   for key,record in pairs(parameters) do

+

     if not results[record["sensor"]] then 
       results[record["sensor"]] = {}
     end
     if not results[record["sensor"]] then 
       results[record["sensor"]] = {}
     end

-    results[record["sensor"]][record["name"]] = get_parameter(record)
+    pcall(function ()
+        results[record["sensor"]][record["name"]] = record["function"](record)
+      end)

   end
   end

+  

   return results
 end
 
   return results
 end
 


@@ -173,7 +270,7 @@ if not config_name then
   config_name = "weathermon"
 end  
 
   config_name = "weathermon"
 end  
 

-web_id = uci.get(config_name,"web","devid")
+web_id = get_devid(config_name)

 
 parameters = init(config_name)
 
 
 parameters = init(config_name)
 


@@ -189,17 +286,16 @@ if not delay then
 end
 
 while true do
 end
 
 while true do

-  values = get_parameters(parameters)
-  records = {}
-  records[web_id] = {}
-  for key,record in pairs(values) do
-    records[web_id][key] = record
-    records[web_id]["timestamp"] = os.date("%Y-%m-%dT%H:%M:%S")
-  end
-  for key,value in pairs(values) do
-    value["device"] = key
-    print(json.encode(value))
-  end  
+    values = get_parameters(parameters)
+    records = {}
+    records[web_id] = {}
+    for key,record in pairs(values) do
+      records[web_id][key] = record
+      records[web_id]["timestamp"] = os.date("%Y-%m-%dT%H:%M:%S")
+    end
+    for key,value in pairs(values) do
+      value["device"] = key
+      print(json.encode(value))
+    end

   socket.sleep(delay)
 end
   socket.sleep(delay)
 end

-  
\ No newline at end of file