Tout d'abord je dois dire ce que je fais avec ;-)
Mon but: avoir un composant wifi utilisable avec Jeedom pouvant piloter un relais, lire la température avec un ds18b20 (utilisant le protocol "one-wire"), lire le courant consommé (utilisant une petite pince ampèremétrique), vérifier la présence avec un capteur PIR (Passive Infrared Sensor) et lire une commande comme un interrupteur. Et pour finir, j'ai décider de faire un code commun pour la maintenance.
De plus, mon but est de pouvoir mettre cela dans une boite encastrable dans un mur pour par exemple être au dessus d'un bouton existant et ainsi le commander (avec retour d'état). Je metterais des photos plus tard ;-)
Donc dans le nodeMCU, j'ai organisé ainsi :
1) Avec le init.lua qui me sert juste à lancer la config du node, la config du wifi et du "main.lc" (version compilé du .lua pour gagner de la place) avec la possibilité de faire du telnet en option pour avoir un accès remote au code du nodemcu mais c'est encore de l'expérimentale ;-) :
-- init.lua -- -- Network Variables --list files in NODEMCU l = file.list(); for k,v in pairs(l) do --print("name:"..k..", size:"..v) --print(string.find(k, "_conf.lua", 1)) if((string.find(k, "_conf.lua", 1) ~= nil) and (string.find(k, "wifi_node", 1) ~= nil))then -- Load conf Jeedom --print("load file:"..string.sub(k, 1,string.find(k, ".lua", 1)-1)); require(string.sub(k, 1,string.find(k, ".lua", 1)-1)); end end -- Mode Variables ("telnet" or "web") require("mode_conf"); -- Configure Wireless Internet wifi.setmode(wifi.STATION); --print('set mode=STATION (mode='..wifi.getmode()..')\n') --print('MAC Address: ',wifi.sta.getmac()) --print('Chip ID: ',node.chipid()) --print('Heap Size: ',node.heap(),'\n') -- Configure WiFi wifi.sta.config(ssid,pass); tmr.alarm(0, 1000, 1, function() if wifi.sta.getip()==nil then print("Connect AP, Waiting...") else print("Wifi AP connected. IP:") print(wifi.sta.getip()) tmr.stop(0) if(telnet_server_mode == "true")then -- Load telnet server dofile("telnet.lc"); else -- Load main dofile("main.lc"); end end end)
2) avec le configuration wifi dans un fichier dédié pour gérer plusieurs nodes par la suite :
(moi je les mets en IP fixe à partir de ma freebox pour ne pas avoir de soucis et en fonction de leur adresse Mac) - wifi_nodeX_conf.lua (X étant le numéro de votre node sur le réseau, juste si vous voulez utiliser des points wifi différent ;-)
-- config wifi ssid = "votre ssid à mettre ici" pass = "et le password ici bien sur ;-)"
2 bis) avec le mode choisi (pour faire du telnet ou pas) - mode_conf.lua
telnet_server_mode = "false"; -- to activate "telnet" server when necessary (11/05/2015) because only one TCP server supported on NodeMCU firmware
3) et avant de parler du principal, voici aussi le code du telnet.lua à tester ;-) parce que encore expérimentale comme je l'ai déjà dis (qu'il faudra aussi compiler en .lc):
print("====a LUA console over wifi.==========") print("Telnet Server starting ......") sv=net.createServer(net.TCP, 180) sv:listen(8080, function(conn) print("Wifi console connected.") function s_output(str) if (conn~=nil) then conn:send(str) end end node.output(s_output,0) conn:on("receive", function(conn, pl) node.input(pl) if (conn==nil) then print("conn is nil.") end end) conn:on("disconnection",function(conn) node.output(nil) end) end) print("Telnet Server running at :8080") print("===Now,Using ESPlorer and input LUA.====")
4) et donc un main.lua (qu'il faudra compiler en .lc) où l'on retrouve le serveur web que je peux interroger en http mais aussi des commandes qui peuvent être envoyé vers jeedom :
version = "v0.0.8"; -- global variables SendingData = false; -- -- global functions function sendDataToVirtual (id,state) if SendingData then -- don't allow new sending data during process of sending data return else SendingData = true end --print("id: "..id); --print("state: "..state); -- A simple http client -> to send last/new state to jeedom if(httpreq == nil) then --print("initial create connection"); httpreq=net.createConnection(net.TCP, false); else --print("connect close"); httpreq:close(); collectgarbage(); --print("create connection"); httpreq=net.createConnection(net.TCP, false); end httpreq:on("receive", function(httpreq, pl) --print(pl) end) --print("connect connection"); httpreq:connect(80,jeedom_ip) httpreq:send("GET /jeedom/core/api/jeeApi.php?apikey="..api_key .."&type=virtual&id="..id .."&value="..state .." HTTP/1.1\r\nHost: "..jeedom_ip .."\r\n".."Connection: keep-alive\r\nAccept: */*\r\n\r\n") SendingData = false; end function Sleep(delay) local start= tmr.time(); while tmr.time() - start < delay do end end -- --list files in NODEMCU l = file.list(); for k,v in pairs(l) do --print("name:"..k..", size:"..v) --print(string.find(k, "_conf.lua", 1)) if((string.find(k, "_conf.lua", 1) ~= nil) and (string.find(k, "node", 1) ~= nil))then -- Load conf Jeedom --print("load file:"..string.sub(k, 1,string.find(k, ".lua", 1)-1)); require(string.sub(k, 1,string.find(k, ".lua", 1)-1)); end end -- for check of conf: --print("jeedom_ip:"..jeedom_ip) --print("api_key:"..api_key) --print("jeedom_virtual_relay_id:"..jeedom_virtual_relay_id) --print("jeedom_virtual_pir_id:"..jeedom_virtual_pir_id) -- led of Wemos D1 Mini on D4 (GPIO2) if(wemos_led ~= nil) then gpio.mode(wemos_led, gpio.OUTPUT); end -- -- relay command on D1 (GPIO5) if(relay1 ~= nil) then gpio.mode(relay1,gpio.OUTPUT); end -- -- switch if(switch1 ~= nil) then inInt = false; --Send initial state after reboot sendDataToVirtual (jeedom_virtual_relay_id, "0"); -- gpio.mode(switch1,gpio.INPUT,gpio.PULLUP); gpio.trig(switch1, "both", function(level) if inInt then -- don't allow interrupt in interrupt return else inInt = true end tmr.delay(100000) -- 100ms debounce if(gpio.read(relay1) == 0)then gpio.write(relay1, gpio.HIGH) localnewstate = 1 else gpio.write(relay1, gpio.LOW) localnewstate = 0 end sendDataToVirtual (jeedom_virtual_relay_id, localnewstate); inInt = false -- all done, allow interrupts again end) end -- -- pir if(pir1 ~= nil) then inIntMotion = false; gpio.mode(pir1,gpio.INT,gpio.FLOAT); gpio.trig(pir1, "both", function(level) if inIntMotion then -- don't allow interrupt in interrupt return else inIntMotion = true end PirNewstate = gpio.read(pir1); tmr.delay(100000) -- 100ms debounce sendDataToVirtual (jeedom_virtual_pir_id, PirNewstate); inIntMotion = false -- all done, allow interrupts again end) --print("pir state:"..gpio.read(pir1)); end -- -- DS18B20 reading on D4 (GPIO2) if(OneWirePin ~= nil) then -- setup to read temperature t = require("ds18b20") t.setup(OneWirePin) --addrs = t.addrs() --if (addrs ~= nil) then -- print("Total DS18B20 sensors: "..table.getn(addrs)) --end end -- -- MCP3008 library loading (D5 to D8 is allocated in all cases). if(MCP3008 ~= nil) then -- setup require("MCP3008") end -- -- CTSensor library loading if(CTSensor ~= nil) then -- setup require("CTSensor") end -- -- create web server srv=net.createServer(net.TCP) srv:listen(80,function(conn) conn:on("receive", function(client,request) local buf = ""; local _, _, method, path, vars = string.find(request, "([A-Z]+) (.+)?(.+) HTTP"); if(method == nil)then _, _, method, path = string.find(request, "([A-Z]+) (.+) HTTP"); end local _GET = {} if (vars ~= nil)then for k, v in string.gmatch(vars, "(%w+)=(%w+)&*") do _GET[k] = v end end --print(_GET.pin); --print(_GET.state); -- to read GPIO buf = "<!DOCTYPE HTML>\n"; buf = buf.."<html>\n"; if(_GET.state ~= nil)then if((_GET.state == "relay1") and (relay1 ~=nil))then buf = buf.."<div>"..gpio.read(relay1).."</div>".."\n"; elseif((_GET.state == "switch1") and (switch1 ~=nil))then buf = buf..gpio.read(switch1); elseif((_GET.state == "pir1") and (pir1 ~=nil))then buf = buf..gpio.read(pir1); elseif((_GET.state == "temp1") and (OneWirePin ~=nil))then if(t == nil) then -- setup to read temperature t = require("ds18b20") t.setup(OneWirePin) end temperature = t.read(); if(temperature ~=nil)then buf = buf.."<div>"..temperature.."</div>".."\n"; --buf = buf..temperature.."\n"; end elseif((string.find(_GET.state,"analog") ~= nil) and (MCP3008 ~=nil))then channel = tonumber(string.sub(_GET.state,7)); --print("Debug: Channel value found:"..tostring(channel)); analogvalue = readMCP3008(channel); if(analogvalue ~=nil)then buf = buf.."<div>"..analogvalue.."</div>".."\n"; end elseif((string.find(_GET.state,"power") ~= nil) and (MCP3008 ~=nil) and (CTSensor ~=nil))then channel = tonumber(string.sub(_GET.state,6)); --print("Debug: Channel value found:"..tostring(channel)); power = getPower(channel); if(power ~=nil)then buf = buf.."<div>"..power.."</div>".."\n"; end end end if(_GET.pin ~=nil)then -- else write GPIO if((_GET.pin == "wemosledon") and (wemos_led ~=nil))then gpio.write(wemos_led, gpio.HIGH); buf = buf.."1"; elseif((_GET.pin == "wemosledoff") and (wemos_led ~=nil))then gpio.write(wemos_led, gpio.LOW); buf = buf.."0"; elseif((_GET.pin == "relay1on") and (relay1 ~=nil))then gpio.write(relay1, gpio.HIGH); buf = buf.."1"; newstate=gpio.read(relay1); sendDataToVirtual (jeedom_virtual_relay_id, newstate); elseif((_GET.pin == "relay1off") and (relay1 ~=nil))then gpio.write(relay1, gpio.LOW); buf = buf.."0"; newstate=gpio.read(relay1); sendDataToVirtual (jeedom_virtual_relay_id, newstate); end end -- display web page or not if(web_server_ui == "true")then buf = buf.."<head><meta charset=\"UTF-8\"><title>My ESP8266 "..version.."</title></head>\n"; buf = buf.."<body>\n"; -- to display full web page buf = buf.."<h1> ESP8266 Web Server</h1>"; if(wemos_led ~= nil) then buf = buf.."<p>GPIO2 (D4) wemos led <a href=\"?pin=wemosledoff\"><button>ON</button></a> <a href=\"?pin=wemosledon\"><button>OFF</button></a>"; buf = buf.." status: "..gpio.read(wemos_led).."</p>\n"; end if(relay1 ~= nil) then buf = buf.."<p>GPIO5 (D1) relai <a href=\"?pin=relay1on\"><button>ON</button></a> <a href=\"?pin=relay1off\"><button>OFF</button></a>"; buf = buf.." status: "..gpio.read(relay1).."</p>\n"; end if(pir1 ~= nil) then buf = buf.."<p>GPIO4 (D2) pir"; buf = buf.." status: "..gpio.read(pir1).."</p>\n"; end if(switch1 ~= nil) then buf = buf.."<p>GPIO0 (D3) switch"; buf = buf.." status: "..gpio.read(switch1).."</p>\n"; end -- Just read temperature --print("Temperature: "..t.read().."'C") if(OneWirePin ~= nil) then buf = buf.."<p>GPIO2 (D4) OneWire"; buf = buf.." status: "..t.read().."°C</p>\n"; end if(MCP3008 ~= nil) then buf = buf.."<p>GPIO? (D6) MCP3008"; buf = buf.." status: "..readMCP3008(0).."</p>\n"; buf = buf.." status: "..readMCP3008(1).."</p>\n"; buf = buf.." status: "..readMCP3008(2).."</p>\n"; buf = buf.." status: "..readMCP3008(3).."</p>\n"; buf = buf.." status: "..readMCP3008(4).."</p>\n"; buf = buf.." status: "..readMCP3008(5).."</p>\n"; buf = buf.." status: "..readMCP3008(6).."</p>\n"; buf = buf.." status: "..readMCP3008(7).."</p>\n"; end -- Don't forget to release it after use --t = nil --ds18b20 = nil --package.loaded["ds18b20"]=nil buf = buf.."</body>\n"; end buf = buf.."</html>\n"; --local _on,_off = "","" client:send(buf); client:close(); collectgarbage(); -- reboot capacity ;-) if(_GET.reboot == "on")then node.restart(); end end) end)
5) Le main utilisant aussi une url avec l'IP et la clé api qui va bien mais qui est défini dans un "nodeX_conf.lua" (X étant le numéro de votre node sur le réseau, pour pouvoir utiliser des confs de nodes différents ;-). Dans ce fichier on peut aussi activer ou pas des fonctionnalités en fonction de la demande et jouer sur les numéros des entrées-sorties en affectant la valeur du pin ou par 'nil' si non activé :
-- jeedom api_key = "votre clé api jeedom à mettre ici"; jeedom_ip = "votre ip local de jeedom au format xxx.xxx.xxx.xxx, exemple: 192.168.0.100"; -- virtual jeedom device link to this node (please set to nil if not activated/used) jeedom_virtual_relay_id = 123; jeedom_virtual_pir_id = 234; -- gpio confs (please set to nil if not activated/used) -- led of Wemos D1 Mini on D4 (GPIO2) wemos_led = nil; -- relay command on D1 (GPIO5) relay1 = 1; -- switch reading on D3 (GPIO0) switch1 = 3; -- pir reading on D2 (GPIO4) pir1 = 2; -- DS18B20 reading on D4 (GPIO2) OneWirePin = 4; -- MCP3008 reading (D5 to D8 is allocated in all cases) MCP3008 = true; -- value nil or different of nil to activate the ressource loading. -- to access: http://192.168.0.XXX/?state=analogY where Y is the channel of MCP3008 CTSensor = true; -- value nil or different of nil to activate the ressource loading. -- to read CTSensor power: http://192.168.0.XXX/?state=powerY where Y is the channel of the CT Sensor. -- web server activation (to deactivate and to win memory) web_server_ui="false";
6) en option si la variable OneWirePin n'est pas à 'nil': le main utilise une libraire pour le ds18b20, ds18b20.lua (qu'il faudra aussi compiler en .lc)
-------------------------------------------------------------------------------- -- DS18B20 one wire module for NODEMCU -- NODEMCU TEAM -- LICENCE: http://opensource.org/licenses/MIT -- Vowstar <vowstar@nodemcu.com> -- 2015/02/14 sza2 <sza2trash@gmail.com> Fix for negative values -------------------------------------------------------------------------------- -- Set module name as parameter of require local modname = ... local M = {} _G[modname] = M -------------------------------------------------------------------------------- -- Local used variables -------------------------------------------------------------------------------- -- DS18B20 dq pin local pin = nil -- DS18B20 default pin local defaultPin = 9 -------------------------------------------------------------------------------- -- Local used modules -------------------------------------------------------------------------------- -- Table module local table = table -- String module local string = string -- One wire module local ow = ow -- Timer module local tmr = tmr -- Limited to local environment setfenv(1,M) -------------------------------------------------------------------------------- -- Implementation -------------------------------------------------------------------------------- C = 0 F = 1 K = 2 function setup(dq) pin = dq if(pin == nil) then pin = defaultPin end ow.setup(pin) end function addrs() setup(pin) tbl = {} ow.reset_search(pin) repeat addr = ow.search(pin) if(addr ~= nil) then table.insert(tbl, addr) end tmr.wdclr() until (addr == nil) ow.reset_search(pin) return tbl end function readNumber(addr, unit) result = nil setup(pin) flag = false if(addr == nil) then ow.reset_search(pin) count = 0 repeat count = count + 1 addr = ow.search(pin) tmr.wdclr() until((addr ~= nil) or (count > 100)) ow.reset_search(pin) end if(addr == nil) then return result end crc = ow.crc8(string.sub(addr,1,7)) if (crc == addr:byte(8)) then if ((addr:byte(1) == 0x10) or (addr:byte(1) == 0x28)) then -- print("Device is a DS18S20 family device.") ow.reset(pin) ow.select(pin, addr) ow.write(pin, 0x44, 1) -- tmr.delay(1000000) present = ow.reset(pin) ow.select(pin, addr) ow.write(pin,0xBE,1) -- print("P="..present) data = nil data = string.char(ow.read(pin)) for i = 1, 8 do data = data .. string.char(ow.read(pin)) end -- print(data:byte(1,9)) crc = ow.crc8(string.sub(data,1,8)) -- print("CRC="..crc) if (crc == data:byte(9)) then t = (data:byte(1) + data:byte(2) * 256) if (t > 32767) then t = t - 65536 end if (addr:byte(1) == 0x28) then t = t * 625 -- DS18B20, 4 fractional bits else t = t * 5000 -- DS18S20, 1 fractional bit end if(unit == nil or unit == 'C') then -- do nothing elseif(unit == 'F') then t = t * 1.8 + 320000 elseif(unit == 'K') then t = t + 2731500 else return nil end t = t / 10000 return t end tmr.wdclr() else -- print("Device family is not recognized.") end else -- print("CRC is not valid!") end return result end function read(addr, unit) t = readNumber(addr, unit) if (t == nil) then return nil else return t end end -- Return module table return M
7) en option si la variable MCP3008 est égale à 'true': le main utilise une libraire pour le MCP3008 (convertiseur analogique/numérique), MCP3008.lua (qu'il faudra aussi compiler en .lc)
MISO = 6 --> D6 MOSI = 7 --> D7 CLK = 5 --> D5 CS = 8 --> D8 -- Pin Initialization gpio.mode(CS, gpio.OUTPUT) gpio.mode(CLK, gpio.OUTPUT) gpio.mode(MOSI, gpio.OUTPUT) gpio.mode(MISO, gpio.INPUT) -- Function to read MCP3008 function readMCP3008(adc_ch) if (tonumber(adc_ch) >=0) and (tonumber(adc_ch) < 8) then -- MCP3008 has eight channels 0-8 gpio.write(CS,gpio.HIGH) tmr.delay(5) gpio.write(CLK, gpio.LOW) gpio.write(CS, gpio.LOW) -->Activate the chip tmr.delay(1) -->1us Delay commandout = adc_ch commandout=bit.bor(commandout, 0x18) commandout=bit.lshift(commandout, 3) for i=1,5 do if bit.band(commandout,0x80) >0 then gpio.write(MOSI, gpio.HIGH) else gpio.write(MOSI, gpio.LOW) end commandout=bit.lshift(commandout,1) gpio.write(CLK, gpio.HIGH) tmr.delay(1) gpio.write(CLK, gpio.LOW) tmr.delay(1) end adcout = 0 for i=1,12 do gpio.write(CLK, gpio.HIGH) tmr.delay(1) gpio.write(CLK, gpio.LOW) tmr.delay(1) adcout = bit.lshift(adcout,1); if gpio.read(MISO)>0 then adcout = bit.bor(adcout, 0x1) end end gpio.write(CS, gpio.HIGH) adcout = bit.rshift(adcout,1) return adcout else return -1 end end
8) en option si la variable CTSencor égale à 'true': le main utilise une libraire pour le capteur de courant (convertiseur analogique/numérique), CTSensor.lua (qu'il faudra aussi compiler en .lc)
BURDEN_R = 22.9 --> Resistance in Ohms of Burden Resistor CT_RATIO = 2000.0 --> Ratio of Primary:Secondary coils/current AC_VOLTAGE = 230.0 --> AC Supply Voltage NUM_SAMPLES = 100 --> Number of samples to take supplyVoltage = 3.30 --> Get current Vcc voltage (this is applied to AREF on the MCP3008) -- Calculate apparent power from current sensor function getPower(MCP3008_channel) -- Calculate the ratio of ADC step to measured current ratio = (CT_RATIO / BURDEN_R) * (supplyVoltage / 1024) Irms = 0 sample = 0 filtered = 0 squared = 0 sum = 0 -- For 10bit ADC offset = 512 (i.e. half of 1024) offset = 512 for i=1,NUM_SAMPLES do sample = readMCP3008(MCP3008_channel) -- Digital low pass filter extracts the 2.5 V or 1.65 V dc offset, -- then subtract this - signal is now centered on 0 counts. offset = (offset + (sample - offset) / 1024) filtered = sample - offset squared = filtered * filtered sum = sum + squared end -- Calculate average RMS current Irms = ratio * math.sqrt(sum / NUM_SAMPLES) -- Return output power in KWatts. return ((AC_VOLTAGE * Irms)/1000); end
Bon c'est tout, désolé, cela fait beaucoup pour une première fois mais j'ai préféré faire ainsi et tout vous mettre. A vous de prendre que ce qui est utile pour vous ;-)
Je vous parlerais de hard ;-) plus tard mais manque de temps cela sera pour une prochaine fois :-(
Je peux juste dire pour 'teaser' que j'en suis dans les 15 € pour mon "IoT" multi-capteurs !
Aucun commentaire :
Enregistrer un commentaire