Changes for page 2 Script

Summary

• Page properties (2 modified, 0 added, 0 removed)
• Attachments (0 modified, 2 added, 0 removed)
  • InputHTTPparameter.png
  • image-20220709173500-1.png

Details

Page properties

Author

...	...	@@ -1,1 +1,1 @@
1		-XWiki.admin
	1	+XWiki.Hunter

Content

...	...	@@ -13,7 +13,7 @@
13	13	for example. addr_setshort(addr,num) Function: Write 16-bit signed decimal address
14	14	addr_getshort(addr) Function:Read 16-bit signed decimal address
15	15	addr_getword(string addr)Function: Read 16-bit unsigned decimal address
16		-More script function are in the second section of [[“V-BOX Script Interface Manual”>>doc:V-BOX.V-Net.1\.User Manual.04 Lua Script.01 Lua Functions.WebHome]]
	16	+More script function are in the second section of [[“V-BOX Script Interface Manual”>>doc:V-BOX.V-Net.Manual.04 Lua Script.01 Lua Functions.WebHome]]
17	17
18	18	== **1.2 Arithmetic** ==
19	19
...	...	@@ -27,16 +27,11 @@
27	27
28	28	== **1.4 Short message** ==
29	29
30		-When the alarm condition is reached: temp1 > 5 & temp2 >10 & temp3 < 20(lasts more than 5 seconds) , then send an "alarm trigger" sms.
	30	+The following demo shows that when the alarm condition is reached: temp1 > 5 & temp2 >10 & temp3 < 20(lasts more than 5 seconds) , then send an "alarm trigger" sms.
31	31
32		-When the alarm condition is released，then send an "alarm release" sms.
	32	+When the alarm condition is released，then send an  "alarm release" sms. Script is as below:
33	33
34		-(% style="text-align:center" %)
35		-[[image:1645535936750-316.png||height="385" width="400" class="img-thumbnail"]]
36		-
37		-Script is as below:
38		-
39		-{{code language="Lua"}}
	34	+{{code language="lua"}}
40	40	function sms.main()
41	41	------send condition------
42	42	local temp1 = addr_getword("@Temperature1")
...	...	@@ -46,18 +46,18 @@
46	46	local tag = addr_getbit("@Tag")
47	47	------lasting time------
48	48	if temp1 > 5 and temp2 > 10 and temp3 < 20 then
49		- timer = timer + 1
50		- addr_setword("@Timer",timer)
	44	+ timer = timer + 1
	45	+ addr_setword("@Timer",timer)
51	51	else
52		- timer = 0
53		- addr_setword("@Timer",timer)
	47	+ timer = 0
	48	+ addr_setword("@Timer",timer)
54	54	end
55	55	------send sms & output Y0------
56	56	if timer > 5 then
57		- if tag == 0 then
58		- send_sms_ira("19859254700","alarm trigger")
59		- addr_setbit("@Tag",1)
60		- end
	52	+ if tag == 0 then
	53	+ send_sms_ira("19859254700","alarm trigger")
	54	+ addr_setbit("@Tag",1)
	55	+ end
61	61	elseif tag == 1 then
62	62	send_sms_ira("19859254700","alarm release")
63	63	addr_setbit("@Tag",0)
...	...	@@ -69,6 +69,12 @@
69	69
70	70	This example shows how to use the Bot API to send message into Telegram group or channel. When monitoring bit "@HDX" changes, it will trigger and send the message. Please replace with your own Token and chat id.
71	71
	67	+As for How to get the botToken and chatID, please check the followig videos:
	68	+
	69	+[[https:~~/~~/www.youtube.com/watch?v=zh6yYlnjX7k>>https://www.youtube.com/watch?v=zh6yYlnjX7k]]
	70	+
	71	+[[https:~~/~~/www.youtube.com/watch?v=Pj8mwuMZZvg>>https://www.youtube.com/watch?v=Pj8mwuMZZvg]]
	72	+
72	72	{{code language="Lua"}}
73	73	local tempBit = 0
74	74	local tempWord = 0
...	...	@@ -134,7 +134,343 @@
134	134	end
135	135	{{/code}}
136	136
	138	+== **1.6 LINE Notify** ==
137	137
	140	+This example shows how to use the LINE Notify to send message into LINE group. When monitoring bit "@test" changes, it will trigger and send the message. Please replace with your own Token.
	141	+
	142	+{{code language="lua"}}
	143	+local tempBit = 0
	144	+local tempWord = 0
	145	+
	146	+local LineToken = "08XCpubkOdwGdGgRTXF0x8umiyrALtoM0v6lBFUV6PC"
	147	+
	148	+local https = require("https")
	149	+local json = require("json")
	150	+local ltn12 = require("ltn12")
	151	+
	152	+-- Send http.get request and return response result
	153	+function getHttpsUrl(url,header,reqbody)
	154	+ local body = {}
	155	+ local bodyJson = json.encode(body)
	156	+ local result_table, code, headers, status = https.request{
	157	+ method = "POST",
	158	+ url = url,
	159	+ source = ltn12.source.string(reqbody),
	160	+ headers = header,
	161	+ sink = ltn12.sink.table(body)
	162	+ }
	163	+ print("code:"..code)
	164	+ if code~= 200 then
	165	+ return
	166	+ else
	167	+ return body
	168	+ end
	169	+end
	170	+
	171	+function getMessageUrl(lineMessage)
	172	+ local url = "https://notify-api.line.me/api/notify"
	173	+ local reqMess = "message="..lineMessage
	174	+ local headers =
	175	+ {
	176	+ ["Authorization"] = "Bearer "..LineToken,
	177	+ ["Content-Type"] = "application/x-www-form-urlencoded",
	178	+ ["Content-Length"] = #reqMess
	179	+ }
	180	+
	181	+ print("Get the link:"..url)
	182	+ getHttpsUrl(url, headers, reqMess)
	183	+end
	184	+
	185	+
	186	+function linenotify.main()
	187	+ local bitValue = addr_getbit("@test");
	188	+ local message = ''
	189	+ print("b=="..bitValue)
	190	+ if bitValue == 1 and bitValue ~= tempBit then
	191	+ message = 'Alarm V-Box triggered, the output is '.. bitValue
	192	+ getMessageUrl(message)
	193	+ print("Notification pushed of triggering alarm,"..bitValue)
	194	+ elseif bitValue == 0 and bitValue ~= tempBit then
	195	+ message = 'Alarm V-Box dismissed, the output is '.. bitValue
	196	+ getMessageUrl(message)
	197	+ print("Notification pushed of dismissing alarm,"..bitValue)
	198	+ end
	199	+ tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform
	200	+
	201	+ local wordValue = addr_getword("@t2")
	202	+ print("w=="..wordValue)
	203	+ --dosomething
	204	+ if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then
	205	+ message = 'Alarm V-Box triggered, the temperature is '.. wordValue
	206	+ getMessageUrl(message)
	207	+ print("Notification pushed of triggering alarm,"..wordValue)
	208	+ elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then
	209	+ message = 'Alarm V-Box dismissed, the temperature is '.. wordValue
	210	+ getMessageUrl(message)
	211	+ print("Notification pushed of dismissing alarm,"..wordValue)
	212	+ end
	213	+ tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform
	214	+end
	215	+{{/code}}
	216	+
	217	+== **1.7 Twilio WhatsApp Messaging** ==
	218	+
	219	+This example shows how to use the Twilio API to send WhatsApp message to private number. When monitoring bit "@testBit" changes, it will trigger and send the message. Please replace with your own SID, Token, twilioPhoneNumber and receiverPhoneNumber.
	220	+
	221	+About how to register the Twilio API, please check the following video:
	222	+
	223	+[[https:~~/~~/www.youtube.com/watch?v=Id4lKichauU>>https://www.youtube.com/watch?v=Id4lKichauU]]
	224	+
	225	+{{code language="Lua"}}
	226	+local tempBit = 0
	227	+local tempWord = 0
	228	+
	229	+local https = require("https")
	230	+local json = require("json")
	231	+local ltn12 = require("ltn12")
	232	+
	233	+local SID = 'AC1703bd710ffa98006d2bcc0b********'
	234	+local Token = 'd3c11897623c39e538b20263ec19****'
	235	+
	236	+local twilioPhoneNumber = '+14155238886'
	237	+local receiverPhoneNumber = '+8615880018277'
	238	+
	239	+local b='ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/'
	240	+function encodingBase64(data)
	241	+ return ((data:gsub('.', function(x)
	242	+ local r,b='',x:byte()
	243	+ for i=8,1,-1 do r=r..(b%2^i-b%2^(i-1)>0 and '1' or '0') end
	244	+ return r;
	245	+ end)..'0000'):gsub('%d%d%d?%d?%d?%d?', function(x)
	246	+ if (#x < 6) then return '' end
	247	+ local c=0
	248	+ for i=1,6 do c=c+(x:sub(i,i)=='1' and 2^(6-i) or 0) end
	249	+ return b:sub(c+1,c+1)
	250	+ end)..({ '', '==', '=' })[#data%3+1])
	251	+end
	252	+
	253	+function encodeUrl(str)
	254	+ str = string.gsub(str, "([^%w%.%- ])", function(c)
	255	+ return string.format("%%%02X", string.byte(c)) end)
	256	+ return string.gsub(str, " ", "+")
	257	+end
	258	+
	259	+
	260	+
	261	+
	262	+function requestBodySplice(message, sender, receiver)
	263	+ local reqBody = ''
	264	+ local encodeMess = encodeUrl(message)
	265	+ local encodeSend = encodeUrl(sender)
	266	+ local encodeRece = encodeUrl(receiver)
	267	+ --reqBody = "Body=Hello%20Wecon2&From=whatsapp%3A%2B14155238886&To=whatsapp%3A%2B8615880018277"
	268	+ reqBody = string.format("Body=%s&From=whatsapp:%s&To=whatsapp:%s", encodeMess, encodeSend, encodeRece)
	269	+ print(reqBody)
	270	+ return reqBody
	271	+end
	272	+
	273	+
	274	+-- Send http.get request and return response result
	275	+function getHttpsUrl(url,header,reqbody)
	276	+ local body = {}
	277	+ local bodyJson = json.encode(body)
	278	+ local result_table, code, headers, status = https.request{
	279	+ method = "POST",
	280	+ url = url,
	281	+ source = ltn12.source.string(reqbody),
	282	+ headers = header,
	283	+ sink = ltn12.sink.table(body)
	284	+ }
	285	+ print("code:"..code)
	286	+ if code~= 200 then
	287	+ return
	288	+ else
	289	+ return body
	290	+ end
	291	+end
	292	+
	293	+function getMessageUrl(whatsAppMessage)
	294	+ local auth = SID..':'..Token
	295	+ local url = "https://api.twilio.com/2010-04-01/Accounts/"..SID.."/Messages"
	296	+ --local reqMess = "message="..twilioMessage
	297	+ local reqMess = requestBodySplice(whatsAppMessage, twilioPhoneNumber, receiverPhoneNumber)
	298	+ local headers =
	299	+ {
	300	+ ["Authorization"] = "Basic "..encodingBase64(auth),
	301	+ ["Content-Type"] = "application/x-www-form-urlencoded",
	302	+ ["Content-Length"] = #reqMess
	303	+ }
	304	+
	305	+ print("Get the link:"..url)
	306	+ getHttpsUrl(url, headers, reqMess)
	307	+end
	308	+
	309	+
	310	+
	311	+function Twilio.main()
	312	+ --dosomething
	313	+ --local auth = SID..':'..Token
	314	+ --print(requestBodySplice("HelloWorld", twilioPhoneNumber, receiverPhoneNumber))
	315	+ --print(encodingBase64(auth))
	316	+ local bitValue = addr_getbit("@testBit");
	317	+ local message = ''
	318	+ print("b=="..bitValue)
	319	+ if bitValue == 1 and bitValue ~= tempBit then
	320	+ message = 'Alarm V-Box triggered, the output is '.. bitValue
	321	+ getMessageUrl(message)
	322	+ print("Notification pushed of triggering alarm,"..bitValue)
	323	+ elseif bitValue == 0 and bitValue ~= tempBit then
	324	+ message = 'Alarm V-Box dismissed, the output is '.. bitValue
	325	+ getMessageUrl(message)
	326	+ print("Notification pushed of dismissing alarm,"..bitValue)
	327	+ end
	328	+ tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform
	329	+
	330	+ local wordValue = addr_getword("@testWord")
	331	+ print("w=="..wordValue)
	332	+ --dosomething
	333	+ if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then
	334	+ message = 'Alarm V-Box triggered, the temperature is '.. wordValue
	335	+ getMessageUrl(message)
	336	+ print("Notification pushed of triggering alarm,"..wordValue)
	337	+ elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then
	338	+ message = 'Alarm V-Box dismissed, the temperature is '.. wordValue
	339	+ getMessageUrl(message)
	340	+ print("Notification pushed of dismissing alarm,"..wordValue)
	341	+ end
	342	+ tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform
	343	+end
	344	+{{/code}}
	345	+
	346	+== **1.8 How to parse value from HTTP response body** ==
	347	+
	348	+This example use [[https:~~/~~/www.weatherapi.com/>>https://www.weatherapi.com/]] as example, to show how to parse value from HTTP response body. When we input the city name into address "@HDW5050":
	349	+
	350	+(% style="text-align:center" %)
	351	+[[image:InputHTTPparameter.png]]
	352	+
	353	+Then the response body would be like as following:
	354	+
	355	+{{code language="json"}}
	356	+{
	357	+ "location": {
	358	+ "name": "Madrid",
	359	+ "region": "Madrid",
	360	+ "country": "Spain",
	361	+ "lat": 40.4,
	362	+ "lon": -3.68,
	363	+ "tz_id": "Europe/Madrid",
	364	+ "localtime_epoch": 1669022636,
	365	+ "localtime": "2022-11-21 10:23"
	366	+ },
	367	+ "current": {
	368	+ "last_updated_epoch": 1669022100,
	369	+ "last_updated": "2022-11-21 10:15",
	370	+ "temp_c": 13.0,
	371	+ "temp_f": 55.4,
	372	+ "is_day": 1,
	373	+ "condition": {
	374	+ "text": "Partly cloudy",
	375	+ "icon": "//cdn.weatherapi.com/weather/64x64/day/116.png",
	376	+ "code": 1003
	377	+ },
	378	+ "wind_mph": 11.9,
	379	+ "wind_kph": 19.1,
	380	+ "wind_degree": 210,
	381	+ "wind_dir": "SSW",
	382	+ "pressure_mb": 1015.0,
	383	+ "pressure_in": 29.97,
	384	+ "precip_mm": 0.0,
	385	+ "precip_in": 0.0,
	386	+ "humidity": 88,
	387	+ "cloud": 75,
	388	+ "feelslike_c": 10.8,
	389	+ "feelslike_f": 51.4,
	390	+ "vis_km": 10.0,
	391	+ "vis_miles": 6.0,
	392	+ "uv": 3.0,
	393	+ "gust_mph": 22.1,
	394	+ "gust_kph": 35.6
	395	+ }
	396	+}
	397	+{{/code}}
	398	+
	399	+(% class="wikigeneratedid" %)
	400	+So we decode json into lua object to assign the value into addresses HDW6060(temperature), HDW7070(humidity), the code example like follows:
	401	+
	402	+{{code language="lua"}}
	403	+local APIkey = '70faaecf926b4341b1974006221711'
	404	+
	405	+
	406	+local http = require("socket.http")
	407	+local json = require("json")
	408	+
	409	+-- Send http.get request and return response result
	410	+function getHttpsUrl(url)
	411	+ local result_table, code, headers, status = http.request(url)
	412	+ print("code:"..code)
	413	+ if code~= 200 then
	414	+ return
	415	+ else
	416	+ return result_table
	417	+ end
	418	+end
	419	+
	420	+function sendAPI(key, city)
	421	+ local url = "http://api.weatherapi.com/v1/current.json?key="..key.."&q="..city.."&aqi=no"
	422	+ --local url = 'http://v-box.net'
	423	+ --local url = 'https://www.google.com/'
	424	+ --http://api.weatherapi.com/v1/current.json?key=70faaecf926b4341b1974006221711&q=Barcelona&aqi=no
	425	+ print("Get the link:"..url)
	426	+ local body = getHttpsUrl(url)
	427	+ --print(body)
	428	+ local jsonBody = json.decode(body)
	429	+ --print(jsonBody["current"]["temp_c"])
	430	+ --print(type(jsonBody["current"]["temp_c"]))
	431	+ --print(type(jsonBody["current"]["humidity"]))
	432	+ addr_setfloat("@HDW6060", jsonBody["current"]["temp_c"])
	433	+ addr_setword("@HDW7070", jsonBody["current"]["humidity"])
	434	+end
	435	+
	436	+
	437	+function Weather.main()
	438	+ local cityName = addr_getstring("@HDW5050",6)
	439	+ print("cityName: "..cityName)
	440	+ sendAPI(APIkey, cityName)
	441	+end
	442	+{{/code}}
	443	+
	444	+== **1.9 High-Low Byte Switch** ==
	445	+
	446	+The following example is converting the floating number from order 1234 to order 3412, and formating output the number with 2 decimal point. About which high-low word order corresponding to which value, please refer to the [[Address Operation Table>>doc:V-BOX.V-Net.Manual.04 Lua Script.01 Lua Functions.WebHome||anchor="H2Addressoperation"]].
	447	+
	448	+{{code language="lua"}}
	449	+function highLowByteSwitch(floatNumber)
	450	+ addr_setfloat("@W_0#HDW23036",floatNumber,0,2)
	451	+ local newFloat = addr_getfloat("@W_0#HDW23036")
	452	+ local formattedFloat = string.format("%.2f",newFloat)
	453	+ print("The formatted float value is the : "..formattedFloat)
	454	+ return formattedFloat
	455	+end
	456	+{{/code}}
	457	+
	458	+== **1.10 Read 64bits Unsigned Value** ==
	459	+
	460	+In our built-in function library doesn't have the function for reading 64-bit unsigned format value, so the following function is for solve this. But if the number is greater 2^53, the precision will be lost. So the final result will be a little bit different from the original value.
	461	+
	462	+{{code language="lua"}}
	463	+function addr_getquatra(address)
	464	+ local highAddress = addr_newnoaddr(address,2)
	465	+ local low32 = addr_getdword(address)
	466	+ local high32 = addr_getdword(highAddress)
	467	+ --print("the low number is "..low32)
	468	+ --print("the high number is "..high32)
	469	+ local formatVal = string.format("%64.0f",2^32*high32+low32)
	470	+ print("the format value is ".. formatVal)
	471	+ return formatVal
	472	+end
	473	+{{/code}}
	474	+
138	138	= **2 V-Box connect with third part server** =
139	139
140	140	V-Box have two mode.One is for V-Net,User need to use WECON server to store data.We call this V-NET platform.
...	...	@@ -153,157 +153,304 @@
153	153
154	154	(% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate
155	155
156		-== **2.1 V-Box connect with customer server:grouprobotinfo.com** ==
	493	+{{info}}
	494	+**✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool.
	495	+{{/info}}
157	157
158		-This demo does not use SSL certification. Script is as below
	497	+(% class="wikigeneratedid" %)
	498	+Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]**
159	159
160		-Demo1:
	500	+== **2.1 V-Box connect with test server(General Example)** ==
161	161
162		-{{code language="Lua"}}
163		--- Meta class
164		---main
165		-function mq.main()
166		- if not mq.m then
167		-  local err = ""
	502	+The following example is trying to publish to the topic "testtopic/test/no1/7890", and subscribe the topic "testtopic/test/no1/123456".
168	168
169		-  mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID")  -- create connection
170		-  if mq.m then
171		-   mq.config = {
172		-    username = "",-- ID
173		-    password = "",-- password
174		-    netway = 1, -- Ethernet connection, WIFI=1
175		-    -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds.
176		-    -- cleansession = 0, -- Optional, keep session
177		-   }
178		-   mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks
179		-    local str = string.format("%s:%s", topic, msg)
180		-    -- print("mqtt msg:", str) -- Print out the received topics and content
181		-   end
182		-   )
183		-   mq.m:on("offline", function (cause) -- Register for lost connection callbacks
184		-    -- addr_setstring("@xxx", "cause"..(cause or " got nil"))
185		-   end)
186		-   mq.m:on("arrived", function() -- Registration for sending messages to callbacks
187		-    print("msg arrived")
188		-   end)
189		-  else
190		-   print("mqtt create failed:", err) -- Create object failed
191		-  end
192		- else
193		-  if mq.m:isconnected() then -- If online, post a message
194		-     local phaseStatus ="unknow"
195		-     if addr_getbit("@Standby")== 1 then
196		-         phaseStatus = "Standby"
197		-     elseif addr_getbit("@Pre-Freeze")==1 then
198		-         phaseStatus= "Pre-Freeze"
199		-     elseif addr_getbit("@Prepare")==1 then
200		-         phaseStatus ="Prepare"
201		-     elseif addr_getbit("@Primary Dry")==1 then
202		-         phaseStatus = "Primary dry"
203		-     elseif addr_getbit("@Secondary Dry")==1 then
204		-         phaseStatus = "Secondary Dry"
205		-     end
206		---   print(addr_getbit("@Primary Dry"))
207		--------------------------------------------------------------------------------------------------------------------------
208		-     local activating ="unknow"
209		-     if addr_getbit("@Compressor")==1 then
210		-         activating = ",".."Compressor"
211		-     end
212		-     if addr_getbit("@Silicone Pump")==1 then
213		-         activating = activating..",".."Silicone Pump"
214		-     end
215		-     if addr_getbit("@Vacuum Pump")==1 then
216		-         activating = activating..",".."Vacuum Pump"
217		-     end
218		-     if addr_getbit("@Root Pump")==1 then
219		-         activating = activating..",".."Root Pump"
220		-     end
221		-     if addr_getbit("@Heater")==1 then
222		-         activating = activating..",".."Heater"
223		-     end
224		-     if addr_getbit("@Valve Silicone")==1 then
225		-         activating = activating..",".."Valve Silicone"
226		-     end
227		-     if addr_getbit("@Valve Ice Condenser")==1 then
228		-         activating = activating..",".."Valve Ice Condenser"
229		-     end
230		-     if addr_getbit("@Valve Vacuum Pump")==1 then
231		-         activating = activating..",".."Valve Vacuum Pump"
232		-     end
233		-     local pr_activating =string.sub(activating,2)
234		-    --  print(pr_activating)
	504	+And the JSON message is like follows:
235	235
	506	+{{code language="JSON"}}
	507	+{
	508	+ "timestamp": 1631152760,
	509	+ "messageId": 1,
	510	+ "event": "test_data",
	511	+ "mfrs": "HMI/box",
	512	+ "data":
	513	+ {
	514	+ "id" : 1436217747670454274,
	515	+ "waterlevel" : 48,
	516	+ "temperture" : 23
	517	+ }
	518	+}
	519	+{{/code}}
236	236
	521	+{{code language="lua"}}
	522	+--MQTT configuration table
	523	+local MQTT_CFG={}
	524	+MQTT_CFG.username = "weconsupport"
	525	+MQTT_CFG.password = "123456"
	526	+MQTT_CFG.netway = 0
	527	+MQTT_CFG.keepalive = 60
	528	+MQTT_CFG.cleansession = 1
	529	+--TCP URL
	530	+MQTT_URL = "tcp://mq.tongxinmao.com:1883"
	531	+--Client ID
	532	+MQTT_CLIENT_ID = "V-BOXH-AG"
237	237
238		-     local status_text ="unknow"
239		-     if addr_getbit("@Status Run")==1 then
240		-         status_text = "RUNNING"
241		-     else
242		-         status_text = "STOP"
243		-     end
244		--------------------------------------------------------------------------------------------------------------------------
	534	+--Generate UUID
	535	+function uuid()
	536	+ local seed = {'e','1','2','3','4','5','6','7','8','9','a','b','c','d','e','f'}
	537	+ local tb = {}
	538	+ for i=1, 32 do
	539	+ table.insert(tb, seed[math.random(1,16)])
	540	+ end
	541	+ local sid=table.concat(tb)
	542	+ return string.format('%s',
	543	+ string.sub(sid,1,32)
	544	+ )
	545	+end
245	245
246		-     local js =  {type="status",
247		-                  mc_name ="FD300",
248		-                  status=status_text,
249		-                  elapsed_time={
250		-                                hour=addr_getword("@Elapsed Time (Hour)"),
251		-                                min=addr_getword("@Elapsed Time (Minute)"),
252		-                                sec=addr_getword("@Elapsed Time (Second)")
253		-                                },
254		-                   phase = phaseStatus,
255		-                   step = addr_getword("@Step"),
256		-                   activating_output = pr_activating,
257		-                   sv=addr_getshort("@SV Silicone")/10,
258		-                   pv=addr_getshort("@PV Silicone")/10,
259		-                   product1=addr_getshort("@Product 1")/10,
260	260
261		-                   product2=addr_getshort("@Product 2")/10,
262		-                   product3=addr_getshort("@Product 3")/10,
263		-                   product4=addr_getshort("@Product 4")/10,
264		-                   ice1=addr_getshort("@Ice condenser 1")/10,
265		-                   ice2=addr_getshort("@Ice condenser 2")/10,
266		-                   vacuum=addr_getfloat("@Vacuum")
	548	+--Topic name to subscribed
	549	+local SUBSCRIBE_TOPIC = 'testtopic/test/no1/123456'
267	267
268		-                }
269		-     local jsAlarm = {  HPC = addr_getbit("@B_25395#W0.00"),
270		-                        ODPC = addr_getbit("@B_25395#W0.01"),
271		-                        MTPC=addr_getbit("@B_25395#W0.02"),
272		-                        HTT = addr_getbit("@B_25395#W1.03"),
273		-                        CPC = addr_getbit("@B_25395#W0.08"),
274		-                        CPSP =addr_getbit("@B_25395#W1.00"),
275		-                        CPVP =addr_getbit("@B_25395#W0.10"),
276		-                        CPRP =addr_getbit("@B_25395#W0.11"),
277		-                        HP =addr_getbit("@B_25395#W1.01"),
278		-                        PP= addr_getbit("@B_25395#W1.02"),
279		-                        PO=addr_getbit("@B_25395#W0.07"),
280		-                        FSE=addr_getbit("@B_25395#W2.04"),
281		-                        AVVSVV=addr_getbit("@B_25395#W1.12"),
282		-                        ICHT=addr_getbit("@B_25395#W3.06")
283		-
284		-                }
	551	+--Topic name to be published
	552	+local PUBLISH_TOPIC = 'testtopic/test/no1/7890'
285	285
286		-    -- ("@B_25395#CIO1.02")
287		-     mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0)
288		-     mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0)
289		-  else
290		-   local stat, err = mq.m:connect(mq.config) -- connection
291		-   if stat == nil then --Determine whether to connect
292		-    print("mqtt connect failed:", err)
293		-    return -- Connection failed, return directly
294		-   end
295		-   mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics
296	296
297		-  end
298		-  -- mq.m:unsubscribe("stc/test")
299		-  -- mq.m:disconnect() -- close matt
300		-  -- mq.m:close() -- close clase
301		- end
	555	+--real time
	556	+local LAST_TIME = 0
	557	+
	558	+
	559	+--initialize mqtt
	560	+function mqtt_init()
	561	+ print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID))
	562	+ if g_mq then
	563	+ mqtt.close() --Close mqtt object
	564	+ end
	565	+ g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
	566	+ if g_mq then
	567	+ g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages
	568	+ g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline
	569	+ print("mqtt init success")
	570	+ else
	571	+ print("mqtt init failed:", err)
	572	+ end
302	302	end
	574	+
	575	+-- connect to mqtt
	576	+function mqtt_connect()
	577	+ print("mqtt connecting...")
	578	+ local stat, err = g_mq:connect(MQTT_CFG)
	579	+ if stat == nil then
	580	+ print("mqtt connect failed:", err)
	581	+ return
	582	+ else
	583	+ print("mqtt connected")
	584	+ end
	585	+ g_mq:subscribe(SUBSCRIBE_TOPIC, 0)
	586	+end
	587	+
	588	+--Offline callback function
	589	+function mqtt_msg_offline(cause)
	590	+ print("mqtt offline, cause:", cause)
	591	+end
	592	+
	593	+-- Received message callback function
	594	+function mqtt_msg_callback(topic, msg)
	595	+ print("topic:", topic)
	596	+ print("msg:", msg)
	597	+ local objMsg = json.decode(msg)
	598	+ local water = objMsg.data.waterlevel
	599	+ local temp = objMsg.data.temperature
	600	+ addr_setword("@HDW20",water)
	601	+ addr_setword("@HDW10",temp)
	602	+end
	603	+
	604	+--Send data (data upload to platform and encapsulate it with custom functions)
	605	+function send_data()
	606	+ local pub_data = {
	607	+ timestamp = os.time(),
	608	+ messageId = 1,
	609	+ event = 'test_data',
	610	+ mfrs = 'V-Box',
	611	+ data = {
	612	+ id = uuid(),
	613	+ waterlevel = addr_getword("@HDW10"),
	614	+ temperature = addr_getword("@HDW20")
	615	+ }
	616	+ }
	617	+ return g_mq:publish(PUBLISH_TOPIC, json.encode(pub_data), 0, 0)
	618	+end
	619	+
	620	+
	621	+--main function fixed timed execution
	622	+function MQTT.main()
	623	+ --dosomething
	624	+ print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main start")
	625	+ --determine the mqtt object whether exist
	626	+ if g_mq then
	627	+ --determine the mqtt object whether has been connected or not
	628	+ if g_mq:isconnected() then
	629	+ send_data()
	630	+ else
	631	+ --if exceed 5 sec not connect, reconnect once
	632	+ if os.time() - LAST_TIME > 5 then
	633	+ LAST_TIME = os.time()
	634	+ --reinitial the mqtt object
	635	+ mqtt_init()
	636	+ --connect to mqtt or reconnect
	637	+ mqtt_connect()
	638	+ end
	639	+ end
	640	+ else
	641	+ --mqtt object does not exist so create new one
	642	+ mqtt_init()
	643	+ end
	644	+ print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main end")
	645	+end
303	303	{{/code}}
304	304
305		-== **2.2 V-Box connect with Azure platform** ==
	648	+== **2.2 V-Box connect with customer server:grouprobotinfo.com** ==
306	306
	650	+This demo does not use SSL certification. Script is as below
	651	+
	652	+Demo1:
	653	+
	654	+{{code language="lua"}}
	655	+-- Meta class
	656	+--main
	657	+function mq.main()
	658	+ if not mq.m then
	659	+ local err = ""
	660	+
	661	+ mq.m, err = mqtt.create("tcp://grouprobotinfo.com:1883", "ClienID") -- create connection
	662	+ if mq.m then
	663	+ mq.config = {
	664	+ username = "",-- ID
	665	+ password = "",-- password
	666	+ netway = 1, -- Ethernet connection, WIFI=1
	667	+ -- keepalive = 100, -- Optional, set the connection heartbeat interval for 100 seconds.
	668	+ -- cleansession = 0, -- Optional, keep session
	669	+ }
	670	+ mq.m:on("message", function(topic, msg) -- Register for receiving message callbacks
	671	+ local str = string.format("%s:%s", topic, msg)
	672	+ -- print("mqtt msg:", str) -- Print out the received topics and content
	673	+ end)
	674	+ mq.m:on("offline", function (cause) -- Register for lost connection callbacks
	675	+ -- addr_setstring("@xxx", "cause"..(cause or " got nil"))
	676	+ end)
	677	+ mq.m:on("arrived", function() -- Registration for sending messages to callbacks
	678	+ print("msg arrived")
	679	+ end)
	680	+ else
	681	+ print("mqtt create failed:", err) -- Create object failed
	682	+ end
	683	+ else
	684	+ if mq.m:isconnected() then -- If online, post a message
	685	+ local phaseStatus ="unknow"
	686	+ if addr_getbit("@Standby")== 1 then
	687	+ phaseStatus = "Standby"
	688	+ elseif addr_getbit("@Pre-Freeze")==1 then
	689	+ phaseStatus= "Pre-Freeze"
	690	+ elseif addr_getbit("@Prepare")==1 then
	691	+ phaseStatus ="Prepare"
	692	+ elseif addr_getbit("@Primary Dry")==1 then
	693	+ phaseStatus = "Primary dry"
	694	+ elseif addr_getbit("@Secondary Dry")==1 then
	695	+ phaseStatus = "Secondary Dry"
	696	+ end
	697	+ --print(addr_getbit("@Primary Dry"))
	698	+-------------------------------------------------------------------------------------------------------------------------
	699	+ local activating ="unknow"
	700	+ if addr_getbit("@Compressor")==1 then
	701	+ activating = ",".."Compressor"
	702	+ end
	703	+ if addr_getbit("@Silicone Pump")==1 then
	704	+ activating = activating..",".."Silicone Pump"
	705	+ end
	706	+ if addr_getbit("@Vacuum Pump")==1 then
	707	+ activating = activating..",".."Vacuum Pump"
	708	+ end
	709	+ if addr_getbit("@Root Pump")==1 then
	710	+ activating = activating..",".."Root Pump"
	711	+ end
	712	+ if addr_getbit("@Heater")==1 then
	713	+ activating = activating..",".."Heater"
	714	+ end
	715	+ if addr_getbit("@Valve Silicone")==1 then
	716	+ activating = activating..",".."Valve Silicone"
	717	+ end
	718	+ if addr_getbit("@Valve Ice Condenser")==1 then
	719	+ activating = activating..",".."Valve Ice Condenser"
	720	+ end
	721	+ if addr_getbit("@Valve Vacuum Pump")==1 then
	722	+ activating = activating..",".."Valve Vacuum Pump"
	723	+ end
	724	+ local pr_activating =string.sub(activating,2)
	725	+ -- print(pr_activating)
	726	+ local status_text ="unknow"
	727	+ if addr_getbit("@Status Run")==1 then
	728	+ status_text = "RUNNING"
	729	+ else
	730	+ status_text = "STOP"
	731	+ end
	732	+-------------------------------------------------------------------------------------------------------------------------
	733	+ local js = {type="status",
	734	+ mc_name ="FD300",
	735	+ status=status_text,
	736	+ elapsed_time={
	737	+ hour=addr_getword("@Elapsed Time (Hour)"),
	738	+ min=addr_getword("@Elapsed Time (Minute)"),
	739	+ sec=addr_getword("@Elapsed Time (Second)")
	740	+ },
	741	+ phase = phaseStatus,
	742	+ step = addr_getword("@Step"),
	743	+ activating_output = pr_activating,
	744	+ sv=addr_getshort("@SV Silicone")/10,
	745	+ pv=addr_getshort("@PV Silicone")/10,
	746	+ product1=addr_getshort("@Product 1")/10,
	747	+
	748	+ product2=addr_getshort("@Product 2")/10,
	749	+ product3=addr_getshort("@Product 3")/10,
	750	+ product4=addr_getshort("@Product 4")/10,
	751	+ ice1=addr_getshort("@Ice condenser 1")/10,
	752	+ ice2=addr_getshort("@Ice condenser 2")/10,
	753	+ vacuum=addr_getfloat("@Vacuum")
	754	+ }
	755	+ local jsAlarm = { HPC = addr_getbit("@B_25395#W0.00"),
	756	+ ODPC = addr_getbit("@B_25395#W0.01"),
	757	+ MTPC=addr_getbit("@B_25395#W0.02"),
	758	+ HTT = addr_getbit("@B_25395#W1.03"),
	759	+ CPC = addr_getbit("@B_25395#W0.08"),
	760	+ CPSP =addr_getbit("@B_25395#W1.00"),
	761	+ CPVP =addr_getbit("@B_25395#W0.10"),
	762	+ CPRP =addr_getbit("@B_25395#W0.11"),
	763	+ HP =addr_getbit("@B_25395#W1.01"),
	764	+ PP= addr_getbit("@B_25395#W1.02"),
	765	+ PO=addr_getbit("@B_25395#W0.07"),
	766	+ FSE=addr_getbit("@B_25395#W2.04"),
	767	+ AVVSVV=addr_getbit("@B_25395#W1.12"),
	768	+ ICHT=addr_getbit("@B_25395#W3.06")
	769	+ }
	770	+ -- ("@B_25395#CIO1.02")
	771	+ mq.m:publish("mqtt-v-box-epsilon-fd300", json.encode(js) , 0, 0)
	772	+ mq.m:publish("mqtt-v-box-epsilon-alarm-fd300", json.encode(jsAlarm) , 0, 0)
	773	+ else
	774	+ local stat, err = mq.m:connect(mq.config) -- connection
	775	+ if stat == nil then --Determine whether to connect
	776	+ print("mqtt connect failed:", err)
	777	+ return -- Connection failed, return directly
	778	+ end
	779	+ mq.m:subscribe("mqtt-v-box-epsilon", 0)-- Subscribe to topics
	780	+
	781	+ end
	782	+ -- mq.m:unsubscribe("stc/test")
	783	+ -- mq.m:disconnect() -- close matt
	784	+ -- mq.m:close() -- close clase
	785	+ end
	786	+end
	787	+{{/code}}
	788	+
	789	+== **2.3 V-Box connect with Azure platform** ==
	790	+
307	307	In this demo,V-Box connects with Azure by SSL certification.
308	308
309	309	Video link: [[https:~~/~~/youtu.be/cdI6rIQcpMY?list=PL_Bpnb2RgaksCic9HCcVAZhU9sYwCRKzW>>https://youtu.be/cdI6rIQcpMY?list=PL_Bpnb2RgaksCic9HCcVAZhU9sYwCRKzW]]
...	...	@@ -312,131 +312,128 @@
312	312
313	313	Script is as below
314	314
315		-{{code language="Lua"}}
316		---https://support.huaweicloud.com/qs-IoT/iot_05_0005.html  mqtt.fx monitor to connect azure iot
	799	+(% class="box infomessage" %)
	800	+(((
	801	+~-~-https:~/~/support.huaweicloud.com/qs-IoT/iot_05_0005.html mqtt.fx monitor to connect azure iot
317	317	sprint = print
318	318
319		---Get custom configuration parameters (vbox custom information)
320		---local CUSTOM = bns_get_config("bind")
321		---local DS_ID = CUSTOM.DSID or "60a71ccbbbe12002c08f3a1a_WECON"
	804	+~-~-Get custom configuration parameters (vbox custom information)
	805	+~-~-local CUSTOM = bns_get_config("bind")
	806	+~-~-local DS_ID = CUSTOM.DSID or "60a71ccbbbe12002c08f3a1a_WECON"
322	322
323	323
324		-
325		---Cloud mode interface to obtain the MQTT information configured by the cloud platform: (5 returns, namely the server address, client ID, connection table, last word table, certificate table)
	809	+~-~-Cloud mode interface to obtain the MQTT information configured by the cloud platform: (5 returns, namely the server address, client ID, connection table, last word table, certificate table)
326	326	local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
327	327
328		---MQTT_CFG.username = '60a71ccbbbe12002c08f3a1a_WECON'
329		---MQTT_CFG.password='wecon123'
330		---MQTT_CLIENTID = '60a71ccbbbe12002c08f3a1a_WECON_0_0_2021052110usernxame:60a71ccbbbe12002c08f3a1a_WECONpassword:a0a951581855aa8e0262129da6cf1b43f2c0ecfac4fa56117fc5a20c90be169a'
	812	+~-~-MQTT_CFG.username = '60a71ccbbbe12002c08f3a1a_WECON'
	813	+~-~-MQTT_CFG.password='wecon123'
	814	+~-~-MQTT_CLIENTID = '60a71ccbbbe12002c08f3a1a_WECON_0_0_2021052110usernxame:60a71ccbbbe12002c08f3a1a_WECONpassword:a0a951581855aa8e0262129da6cf1b43f2c0ecfac4fa56117fc5a20c90be169a'
331	331
332		---publish to topics
	816	+~-~-publish to topics
333	333	local pub_RE_TOPIC = string.format('devices/wecon_02/messages/events/')
334		---Subscribe topics
	818	+~-~-Subscribe topics
335	335	local Subscribe_RE_TOPIC1 = string.format('devices/wecon_02/messages/devicebound/#')
336	336
337		---variable
	821	+~-~-variable
338	338	local last_time = 0
339	339
340	340
341		-
342		---Timing main function
	825	+~-~-Timing main function
343	343	function Azure.main()
344	344
345		-   sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main start")
346		-   if g_mq then
347		-        if g_mq:isconnected() then
348		-            send_Data()
349		-        else
350		-            if os.time() - last_time > 20 then
351		-                last_time = os.time()
352		-                mymqtt_connect()
353		-            end
354		-        end
355		-    else
356		-        mymqtt_init()
357		-    end
358		-    sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main end")
	828	+ sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main start")
	829	+ if g_mq then
	830	+ if g_mq:isconnected() then
	831	+ send_Data()
	832	+ else
	833	+ if os.time() - last_time > 20 then
	834	+ last_time = os.time()
	835	+ mymqtt_connect()
	836	+ end
	837	+ end
	838	+ else
	839	+ mymqtt_init()
	840	+ end
	841	+ sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main end")
359	359	end
360	360
361		--- Initialize MQTT
	844	+~-~- Initialize MQTT
362	362	function mymqtt_init()
363		-    sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
364		-    g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) -- Create the object and declare it as a global variable
365		-    if g_mq then
366		-        g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
367		-        sprint("mqtt init success")
368		-    else
369		-        sprint("mqtt init failed:", err)
370		-    end
	846	+ sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
	847	+ g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
	848	+ if g_mq then
	849	+ g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
	850	+ sprint("mqtt init success")
	851	+ else
	852	+ sprint("mqtt init failed:", err)
	853	+ end
371	371	end
372	372
373		--- Connect to MQTT server
	856	+~-~- Connect to MQTT server
374	374	function mymqtt_connect()
375		-    sprint("mqtt connecting...")
376		-    local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
377		-    if stat == nil then
378		-        sprint("mqtt connect failed:", err)
379		-        return
380		-    else
381		-        sprint("mqtt connected")
382		-    end
383		-    g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
	858	+ sprint("mqtt connecting...")
	859	+ local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
	860	+ if stat == nil then
	861	+ sprint("mqtt connect failed:", err)
	862	+ return
	863	+ else
	864	+ sprint("mqtt connected")
	865	+ end
	866	+ g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
384	384	end
385	385
386		--- Receive MQTT message callback function
	869	+~-~- Receive MQTT message callback function
387	387	function mymqtt_msg_callback(topic, msg)
388		-    print("topic:",topic)
389		-    print("revdata:",msg)
390		-   -- local revData = json.decode(msg)
391		- --  if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
392		--- if string.match(topic,Subscribe_RE_TOPIC1) then
393		-     --   print("topi11:",topic)
394		-       setValue(revData)
395		-   -- end
	871	+ print("topic:",topic)
	872	+ print("revdata:",msg)
	873	+ ~-~- local revData = json.decode(msg)
	874	+ ~-~- if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
	875	+~-~- if string.match(topic,Subscribe_RE_TOPIC1) then
	876	+ ~-~- print("topi11:",topic)
	877	+ setValue(revData)
	878	+ ~-~- end
396	396	end
397	397
398		---Process the received data
399		---function setValue(revData)
400		-   -- if revData ~=nil then
401		- --       for i,v in pairs(revData) do
402		-  --          print("Data received：",i,v)
403		-  --      end
404		-   -- end
405		---end
	881	+~-~-Process the received data
	882	+~-~-function setValue(revData)
	883	+ ~-~- if revData ~~=nil then
	884	+ ~-~- for i,v in pairs(revData) do
	885	+ ~-~- print("Data received：",i,v)
	886	+ ~-~- end
	887	+ ~-~- end
	888	+~-~-end
406	406
407		---Get real-time data
	890	+~-~-Get real-time data
408	408	function getData()
409		-    local jdata = {}
410		-    local addr = bns_get_alldata()
411		-    print(json.encode(addr))
412		-    for i,v in pairs(addr) do
413		-        if v[2] == 1 then
414		-           jdata[v[3]] = v[4]
415		-        end
416		-    end
417		-    return jdata
418		-end
	892	+ local jdata = {}
	893	+ local addr = bns_get_alldata()
	894	+ print(json.encode(addr))
	895	+ for i,v in pairs(addr) do
	896	+ if v[2] == 1 then
	897	+ jdata[v[3]] = v[4]
	898	+ end
	899	+ end
	900	+ return jdata
	901	+end
419	419
420	420
421		-
422		---send data
	904	+~-~-send data
423	423	function send_Data()
424		-    local pub_data = {100
425		-     --   services={{
426		-
427		-            --serviceId ='Temperature',
428		-           -- properties={
429		-               -- value = 55
430		-           -- },
431		-       -- }}
	906	+ local pub_data = {100
	907	+ ~-~- services=~{~{
	908	+\\ ~-~-serviceId ='Temperature',
	909	+ ~-~- properties={
	910	+ ~-~- value = 55
	911	+ ~-~- },
	912	+ ~-~- }}
432	432	}
433	433	sprint(json.encode(pub_data))
434	434	print("..........",pub_RE_TOPIC)
435		-    return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
	916	+ return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
436	436	end
437		-{{/code}}
	918	+)))
438	438
439		-== **2.3 How to configure the Huawei platform?（✎Note: Huawei IOT DA function is only in China area.If you want this function,you need to use chinese mobile to register）** ==
	920	+== **2.4 How to configure the Huawei platform?（✎Note: Huawei IOT DA function is only in China area.If you want this function,you need to use chinese mobile to register）** ==
440	440
441	441	1.Register a account: [[https:~~/~~/www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ>>https://www.huaweicloud.com/intl/en-us/s/JUlPVERNJQ]]
442	442
...	...	@@ -585,7 +585,7 @@
585	585	(% style="text-align:center" %)
586	586	[[image:1624441186851-536.png||height="434" width="700" class="img-thumbnail"]]
587	587
588		-== **2.4 V-Box connect with Huawei platform** ==
	1069	+== **2.5 V-Box connect with Huawei platform** ==
589	589
590	590	In this demo,V-Box connects with Huawei by SSL certification.
591	591
...	...	@@ -706,7 +706,7 @@
706	706	(% style="text-align:center" %)
707	707	[[image:1624506666650-161.png||height="547" width="1000" class="img-thumbnail"]]
708	708
709		-== **2.5 V-Box connect with AWS platform** ==
	1190	+== **2.6 V-Box connect with AWS platform** ==
710	710
711	711	=== **Log in AWS** ===
712	712
...	...	@@ -731,318 +731,269 @@
731	731
732	732	{{code language="java"}}
733	733	{
734		-
735	735	"Version": "2012-10-17",
736		-
737	737	"Statement": [
738		-
739	739	{
740		-
741	741	"Effect": "Allow",
742		-
743	743	"Action": [
744		-
745	745	"iot:Connect",
746		-
747	747	"iot:Publish",
748		-
749	749	"iot:Subscribe",
750		-
751	751	"iot:Receive",
752		-
753	753	"greengrass:Discover"
754		-
755	755	],
756		-
757	757	"Resource": "*"
758		-
759	759	}
760		-
761	761	]
762		-
763	763	}
764	764	{{/code}}
765	765
766		-1. **Create things**
	1232	+=== **Create things** ===
767	767
768	768	Click “Manage”~-~-->“Things”~-~-->“Create things”~-~-->“Create single thing”
769	769
	1236	+[[image:image-20220709165402-6.png]]
770	770
771		-|
772		-| |[[image:image-20220709165402-6.png]]
	1238	+[[image:image-20220709165402-7.png]]
773	773
774		-|
775		-| |[[image:image-20220709165402-7.png]]
776		-
777		-|
778		-| |[[image:image-20220709165402-8.png]]
779		-
780	780	Name the thing~-~-->Click “Next”
781	781
	1242	+[[image:image-20220709165402-8.png]]
782	782
783	783	Select the way to create certificate
784	784
	1246	+[[image:image-20220709165402-9.png]]
785	785
786		-|
787		-| |[[image:image-20220709165402-9.png]]
788		-
789	789	Select policy
790	790
	1250	+[[image:image-20220709165402-10.png]]
791	791
792		-|
793		-| |[[image:image-20220709165402-10.png]]
	1252	+[[image:image-20220709165402-11.png]]
794	794
795	795
	1255	+=== **Test with MQTT.fx tool** ===
796	796
797		-
798		-
799		-
800		-|
801		-| |[[image:image-20220709165402-11.png]]
802		-
803		-
804		-
805		-1. **Test with MQTT.fx tool**
806		-
807	807	Click “View Setting” to get the “Broker Adress”
808	808
	1259	+[[image:image-20220709165402-13.png]]
809	809
810		-|
811		-| |[[image:image-20220709165402-12.png]]
	1261	+[[image:image-20220709165402-12.png]]
812	812
813		-|
814		-| |[[image:image-20220709165402-13.png]]
815		-
816		-
817		-
818		-
819		-
820		-|
821		-| |[[image:image-20220709165402-14.png]]
822		-
823	823	Create one connection in MQTT.fx tool, set broker port as 8883.
824	824
	1265	+[[image:image-20220709165402-14.png]]
	1266	+
825	825	Upload the CA File, Client Certificate File, Client Key File
826	826
	1269	+[[image:image-20220709165402-15.png]]
827	827
828		-|
829		-| |[[image:image-20220709165402-15.png]]
830		-
831	831	Publish message to topic “TEST”
832	832
	1273	+[[image:image-20220709165402-17.png]]
833	833
834		-|
835		-| |[[image:image-20220709165402-16.png]]
836		-
837		-|
838		-| |[[image:image-20220709165402-17.png]]
839		-
840	840	Click”Test”~-~-->”MQTT test client”~-~-->”Subscrible to a topic”, to get message publish from MQTT.fx tool.
841	841
	1277	+[[image:image-20220709173500-1.png]]
	1278	+
842	842	And we can also send message form AWS platform to MQTT.fx tool.
843	843
	1281	+[[image:image-20220709165402-18.png]]
844	844
845		-|
846		-| |[[image:image-20220709165402-18.png]]
	1283	+=== **Configurate in CloudTool** ===
847	847
848		-1. **Configurate in CloudTool**
849		-
850	850	Copy the same setting in MQTT.fx to MQTT configuration
851	851
	1287	+[[image:image-20220709165402-19.png]]
852	852
853		-|
854		-| |[[image:image-20220709165402-19.png]]
855		-
856	856	Add a lua script and copy the lua demo into it.
857	857
	1291	+[[image:image-20220709165402-20.png]]
858	858
859		-|
860		-| |[[image:image-20220709165402-20.png]]
	1293	+{{info}}
	1294	+**✎Note:** Before using the following demo script, please make sure the V-Box firmware is newer than 22110701
	1295	+{{/info}}
861	861
	1297	+{{code language="lua"}}
862	862	sprint = print
863	863
864		-~-~-Cloud mode interface to obtain the MQTT information configured by the cloud platform: (5 returns, namely the server address, client ID, connection table, last word table, certificate table)
	1300	+--Cloud mode interface to obtain the MQTT information configured by the cloud platform: (5 returns, namely the server address, client ID, connection table, last word table, certificate table)
865	865
866	866	local MQTT_URL, MQTT_CLIENTID, MQTT_CFG, MQTT_LWT, MQTT_CART = mqtt.setup_cfg()
867	867
868		-~-~-publish to topics
	1304	+--publish to topics
869	869
870	870	local pub_RE_TOPIC = string.format('TEST')
871	871
872		-~-~-Subscribe topics
	1308	+--Subscribe topics
873	873
874	874	local Subscribe_RE_TOPIC1 = string.format('TEST')
875	875
876		-~-~-variable
	1312	+--variable
877	877
878	878	local last_time = 0
879	879
880		-~-~-Timing main function
	1316	+--Timing main function
881	881
882	882	function aws.main()
883	883
884		- sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
	1320	+ sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main start")
885	885
886		- if g_mq then
	1322	+ if g_mq then
887	887
888		- if g_mq:isconnected() then
	1324	+ if g_mq:isconnected() then
889	889
890		- send_Data()
	1326	+ send_Data()
891	891
892		- else
	1328	+ else
893	893
894		- if os.time() - last_time > 5 then
	1330	+ if os.time() - last_time > 5 then
895	895
896		- last_time = os.time()
	1332	+ last_time = os.time()
897	897
898		- mymqtt_connect()
	1334	+ mymqtt_connect()
899	899
	1336	+ end
	1337	+
900	900	end
901	901
902		- end
	1340	+ else
903	903
904		- else
	1342	+ mymqtt_init()
905	905
906		- mymqtt_init()
	1344	+ end
907	907
908		- end
	1346	+ sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
909	909
910		- sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " aws.main end")
911		-
912	912	end
913	913
914	914
915		-~-~- Initialize MQTT
916	916
	1352	+-- Initialize MQTT
	1353	+
917	917	function mymqtt_init()
918	918
919		- sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
	1356	+ sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
920	920
921		- g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
	1358	+ g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID, 1) -- Create the object and declare it as a global variable, 1 means using the domain to connect
922	922
923		- if g_mq then
	1360	+ if g_mq then
924	924
925		- g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
	1362	+ g_mq:on("message", mymqtt_msg_callback) -- Register to receive message callbacks
926	926
927		- sprint("mqtt init success")
	1364	+ sprint("mqtt init success")
928	928
929		- else
	1366	+ else
930	930
931		- sprint("mqtt init failed:", err)
	1368	+ sprint("mqtt init failed:", err)
932	932
933		- end
	1370	+ end
934	934
935	935	end
936	936
937		-~-~- Connect to MQTT server
	1374	+-- Connect to MQTT server
938	938
939	939	function mymqtt_connect()
940	940
941		- sprint("mqtt connecting...")
	1378	+ sprint("mqtt connecting...")
942	942
943		- local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
	1380	+ local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
944	944
945		- if stat == nil then
	1382	+ if stat == nil then
946	946
947		- sprint("mqtt connect failed:", err)
	1384	+ sprint("mqtt connect failed:", err)
948	948
949		- return
	1386	+ return
950	950
951		- else
	1388	+ else
952	952
953		- sprint("mqtt connected")
	1390	+ sprint("mqtt connected")
954	954
955		- end
	1392	+ end
956	956
957		- g_mq:subscribe(TEST, 0)
	1394	+ g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
958	958
959	959	end
960	960
961		-~-~- Receive MQTT message callback function
	1398	+-- Receive MQTT message callback function
962	962
963	963	function mymqtt_msg_callback(topic, msg)
964	964
965		- print("topic:",topic)
	1402	+ print("topic:",topic)
966	966
967		- print("revdata:",msg)
	1404	+ print("revdata:",msg)
968	968
969		- local revData = json.decode(msg)
	1406	+ local revData = json.decode(msg)
970	970
971		- print (revData)
	1408	+ print (revData)
972	972
973		- if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
	1410	+ if topic == Subscribe_RE_TOPIC1 then --Process topic information subscribed from the cloud
974	974
975		-if string.match(topic,Subscribe_RE_TOPIC1) then
	1412	+ if string.match(topic,Subscribe_RE_TOPIC1) then
976	976
977		- ~-~-if revData ~~= nil then
	1414	+ --if revData ~= nil then
978	978
979		- for k,v in pairs (revData) do
	1416	+ for k,v in pairs (revData) do
980	980
981		- print("printing revdata after kv here")
	1418	+ print("printing revdata after kv here")
982	982
983		- print (k,v)
	1420	+ print (k,v)
984	984
985		- end
	1422	+ end
986	986
987		- print ("current state is",fanstate)
	1424	+ print ("current state is",fanstate)
988	988
989		- ~-~-end
	1426	+ --end
990	990
991		-end
	1428	+ end
992	992
993		-end
	1430	+ end
994	994
995	995	end
996	996
997	997
998		-~-~-Get real-time data
999	999
	1436	+--Get real-time data
	1437	+
1000	1000	function getData()
1001	1001
1002		- local jdata = {}
	1440	+ local jdata = {}
1003	1003
1004		- local addr = bns_get_alldata()
	1442	+ local addr = bns_get_alldata()
1005	1005
1006		- print(json.encode(addr))
	1444	+ print(json.encode(addr))
1007	1007
1008		- for i,v in pairs(addr) do
	1446	+ for i,v in pairs(addr) do
1009	1009
1010		- if v[2] == 1 then
	1448	+ if v[2] == 1 then
1011	1011
1012		- jdata[v[3]] = v[4]
	1450	+ jdata[v[3]] = v[4]
1013	1013
1014		- end
	1452	+ end
1015	1015
1016		- end
	1454	+ end
1017	1017
1018		- return jdata
	1456	+ return jdata
1019	1019
1020	1020	end
1021	1021
1022		-~-~-send data
	1460	+--send data
1023	1023
1024	1024	function send_Data()
1025	1025
1026		- local pub_data =
	1464	+ local pub_data =
	1465	+ {
	1466	+ 123
	1467	+ }
1027	1027
1028		- {
1029		-
1030		-123
1031		-
1032		-}
1033		-
1034	1034	sprint(json.encode(pub_data))
1035	1035
1036	1036	print("..........",pub_RE_TOPIC)
1037	1037
1038		- return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
	1473	+ return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
1039	1039
1040	1040	end
	1476	+{{/code}}
1041	1041
1042		-
1043		-
1044	1044	Get message in AWS
1045	1045
1046		-
1047		-|
1048		-| |[[image:image-20220709165402-21.png]]
	1480	+[[image:image-20220709165402-21.png]]

InputHTTPparameter.png

Author

...	...	@@ -1,0 +1,1 @@
	1	+XWiki.Hunter

Size

...	...	@@ -1,0 +1,1 @@
	1	+17.9 KB

Content

image-20220709173500-1.png

Author

...	...	@@ -1,0 +1,1 @@
	1	+XWiki.Jim

Size

...	...	@@ -1,0 +1,1 @@
	1	+1.5 MB

Content