Changes for page 2 Script

Summary

• Page properties (2 modified, 0 added, 0 removed)
• Attachments (0 modified, 1 added, 0 removed)
  • 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
...	...	@@ -36,39 +36,46 @@
36	36
37	37	Script is as below:
38	38
39		-{{code language="Lua"}}
	39	+(% class="box infomessage" %)
	40	+(((
40	40	function sms.main()
41		-------send condition------
	42	+~-~-~-~-~-~-send condition~-~-~-~-~-~-
42	42	local temp1 = addr_getword("@Temperature1")
43	43	local temp2 = addr_getword("@Temperature2")
44	44	local temp3 = addr_getword("@Temperature3")
45	45	local timer = addr_getword("@Timer")
46	46	local tag = addr_getbit("@Tag")
47		-------lasting time------
	48	+~-~-~-~-~-~-lasting time~-~-~-~-~-~-
48	48	if temp1 > 5 and temp2 > 10 and temp3 < 20 then
49		- timer = timer + 1
50		- addr_setword("@Timer",timer)
	50	+ timer = timer + 1
	51	+ addr_setword("@Timer",timer)
51	51	else
52		- timer = 0
53		- addr_setword("@Timer",timer)
	53	+ timer = 0
	54	+ addr_setword("@Timer",timer)
54	54	end
55		-------send sms & output Y0------
	56	+~-~-~-~-~-~-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
	58	+ if tag == 0 then
	59	+ send_sms_ira("19859254700","alarm trigger")
	60	+ addr_setbit("@Tag",1)
	61	+ end
61	61	elseif tag == 1 then
62	62	send_sms_ira("19859254700","alarm release")
63	63	addr_setbit("@Tag",0)
64	64	end
65	65	end
66		-{{/code}}
	67	+)))
67	67
68	68	== **1.5 Telegram notification** ==
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
	73	+As for How to get the botToken and chatID, please check the followig videos:
	74	+
	75	+[[https:~~/~~/www.youtube.com/watch?v=zh6yYlnjX7k>>https://www.youtube.com/watch?v=zh6yYlnjX7k]]
	76	+
	77	+[[https:~~/~~/www.youtube.com/watch?v=Pj8mwuMZZvg>>https://www.youtube.com/watch?v=Pj8mwuMZZvg]]
	78	+
72	72	{{code language="Lua"}}
73	73	local tempBit = 0
74	74	local tempWord = 0
...	...	@@ -134,7 +134,214 @@
134	134	end
135	135	{{/code}}
136	136
	144	+== **1.6 LINE Notify** ==
137	137
	146	+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.
	147	+
	148	+{{code}}
	149	+local tempBit = 0
	150	+local tempWord = 0
	151	+
	152	+local LineToken = "08XCpubkOdwGdGgRTXF0x8umiyrALtoM0v6lBFUV6PC"
	153	+
	154	+local https = require("https")
	155	+local json = require("json")
	156	+local ltn12 = require("ltn12")
	157	+
	158	+-- Send http.get request and return response result
	159	+function getHttpsUrl(url,header,reqbody)
	160	+ local body = {}
	161	+ local bodyJson = json.encode(body)
	162	+ local result_table, code, headers, status = https.request{
	163	+ method = "POST",
	164	+ url = url,
	165	+ source = ltn12.source.string(reqbody),
	166	+ headers = header,
	167	+ sink = ltn12.sink.table(body)
	168	+ }
	169	+ print("code:"..code)
	170	+ if code~= 200 then
	171	+ return
	172	+ else
	173	+ return body
	174	+ end
	175	+end
	176	+
	177	+function getMessageUrl(lineMessage)
	178	+ local url = "https://notify-api.line.me/api/notify"
	179	+ local reqMess = "message="..lineMessage
	180	+ local headers =
	181	+ {
	182	+ ["Authorization"] = "Bearer "..LineToken,
	183	+ ["Content-Type"] = "application/x-www-form-urlencoded",
	184	+ ["Content-Length"] = #reqMess
	185	+ }
	186	+
	187	+ print("Get the link:"..url)
	188	+ getHttpsUrl(url, headers, reqMess)
	189	+end
	190	+
	191	+
	192	+function linenotify.main()
	193	+ local bitValue = addr_getbit("@test");
	194	+ local message = ''
	195	+ print("b=="..bitValue)
	196	+ if bitValue == 1 and bitValue ~= tempBit then
	197	+ message = 'Alarm V-Box triggered, the output is '.. bitValue
	198	+ getMessageUrl(message)
	199	+ print("Notification pushed of triggering alarm,"..bitValue)
	200	+ elseif bitValue == 0 and bitValue ~= tempBit then
	201	+ message = 'Alarm V-Box dismissed, the output is '.. bitValue
	202	+ getMessageUrl(message)
	203	+ print("Notification pushed of dismissing alarm,"..bitValue)
	204	+ end
	205	+ tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform
	206	+
	207	+ local wordValue = addr_getword("@t2")
	208	+ print("w=="..wordValue)
	209	+ --dosomething
	210	+ if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then
	211	+ message = 'Alarm V-Box triggered, the temperature is '.. wordValue
	212	+ getMessageUrl(message)
	213	+ print("Notification pushed of triggering alarm,"..wordValue)
	214	+ elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then
	215	+ message = 'Alarm V-Box dismissed, the temperature is '.. wordValue
	216	+ getMessageUrl(message)
	217	+ print("Notification pushed of dismissing alarm,"..wordValue)
	218	+ end
	219	+ tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform
	220	+end
	221	+{{/code}}
	222	+
	223	+== **1.7 Twilio WhatsApp Messaging** ==
	224	+
	225	+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.
	226	+
	227	+About how to register the Twilio API, please check the following video:
	228	+
	229	+[[https:~~/~~/www.youtube.com/watch?v=Id4lKichauU>>https://www.youtube.com/watch?v=Id4lKichauU]]
	230	+
	231	+{{code language="Lua"}}
	232	+local tempBit = 0
	233	+local tempWord = 0
	234	+
	235	+local https = require("https")
	236	+local json = require("json")
	237	+local ltn12 = require("ltn12")
	238	+
	239	+local SID = 'AC1703bd710ffa98006d2bcc0b********'
	240	+local Token = 'd3c11897623c39e538b20263ec19****'
	241	+
	242	+local twilioPhoneNumber = '+14155238886'
	243	+local receiverPhoneNumber = '+8615880018277'
	244	+
	245	+local b='ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/'
	246	+function encodingBase64(data)
	247	+ return ((data:gsub('.', function(x)
	248	+ local r,b='',x:byte()
	249	+ for i=8,1,-1 do r=r..(b%2^i-b%2^(i-1)>0 and '1' or '0') end
	250	+ return r;
	251	+ end)..'0000'):gsub('%d%d%d?%d?%d?%d?', function(x)
	252	+ if (#x < 6) then return '' end
	253	+ local c=0
	254	+ for i=1,6 do c=c+(x:sub(i,i)=='1' and 2^(6-i) or 0) end
	255	+ return b:sub(c+1,c+1)
	256	+ end)..({ '', '==', '=' })[#data%3+1])
	257	+end
	258	+
	259	+function encodeUrl(str)
	260	+ str = string.gsub(str, "([^%w%.%- ])", function(c)
	261	+ return string.format("%%%02X", string.byte(c)) end)
	262	+ return string.gsub(str, " ", "+")
	263	+end
	264	+
	265	+
	266	+
	267	+
	268	+function requestBodySplice(message, sender, receiver)
	269	+ local reqBody = ''
	270	+ local encodeMess = encodeUrl(message)
	271	+ local encodeSend = encodeUrl(sender)
	272	+ local encodeRece = encodeUrl(receiver)
	273	+ --reqBody = "Body=Hello%20Wecon2&From=whatsapp%3A%2B14155238886&To=whatsapp%3A%2B8615880018277"
	274	+ reqBody = string.format("Body=%s&From=whatsapp:%s&To=whatsapp:%s", encodeMess, encodeSend, encodeRece)
	275	+ print(reqBody)
	276	+ return reqBody
	277	+end
	278	+
	279	+
	280	+-- Send http.get request and return response result
	281	+function getHttpsUrl(url,header,reqbody)
	282	+ local body = {}
	283	+ local bodyJson = json.encode(body)
	284	+ local result_table, code, headers, status = https.request{
	285	+ method = "POST",
	286	+ url = url,
	287	+ source = ltn12.source.string(reqbody),
	288	+ headers = header,
	289	+ sink = ltn12.sink.table(body)
	290	+ }
	291	+ print("code:"..code)
	292	+ if code~= 200 then
	293	+ return
	294	+ else
	295	+ return body
	296	+ end
	297	+end
	298	+
	299	+function getMessageUrl(whatsAppMessage)
	300	+ local auth = SID..':'..Token
	301	+ local url = "https://api.twilio.com/2010-04-01/Accounts/"..SID.."/Messages"
	302	+ --local reqMess = "message="..twilioMessage
	303	+ local reqMess = requestBodySplice(whatsAppMessage, twilioPhoneNumber, receiverPhoneNumber)
	304	+ local headers =
	305	+ {
	306	+ ["Authorization"] = "Basic "..encodingBase64(auth),
	307	+ ["Content-Type"] = "application/x-www-form-urlencoded",
	308	+ ["Content-Length"] = #reqMess
	309	+ }
	310	+
	311	+ print("Get the link:"..url)
	312	+ getHttpsUrl(url, headers, reqMess)
	313	+end
	314	+
	315	+
	316	+
	317	+function Twilio.main()
	318	+ --dosomething
	319	+ --local auth = SID..':'..Token
	320	+ --print(requestBodySplice("HelloWorld", twilioPhoneNumber, receiverPhoneNumber))
	321	+ --print(encodingBase64(auth))
	322	+ local bitValue = addr_getbit("@testBit");
	323	+ local message = ''
	324	+ print("b=="..bitValue)
	325	+ if bitValue == 1 and bitValue ~= tempBit then
	326	+ message = 'Alarm V-Box triggered, the output is '.. bitValue
	327	+ getMessageUrl(message)
	328	+ print("Notification pushed of triggering alarm,"..bitValue)
	329	+ elseif bitValue == 0 and bitValue ~= tempBit then
	330	+ message = 'Alarm V-Box dismissed, the output is '.. bitValue
	331	+ getMessageUrl(message)
	332	+ print("Notification pushed of dismissing alarm,"..bitValue)
	333	+ end
	334	+ tempBit = bitValue----Prevent monitoring values from continuous being sent to the platform
	335	+
	336	+ local wordValue = addr_getword("@testWord")
	337	+ print("w=="..wordValue)
	338	+ --dosomething
	339	+ if wordValue >= 100 and wordValue ~= tempWord and tempWord <= 100 then
	340	+ message = 'Alarm V-Box triggered, the temperature is '.. wordValue
	341	+ getMessageUrl(message)
	342	+ print("Notification pushed of triggering alarm,"..wordValue)
	343	+ elseif wordValue < 100 and wordValue ~= tempWord and tempWord >= 100 then
	344	+ message = 'Alarm V-Box dismissed, the temperature is '.. wordValue
	345	+ getMessageUrl(message)
	346	+ print("Notification pushed of dismissing alarm,"..wordValue)
	347	+ end
	348	+ tempWord = wordValue----Prevent monitoring values from continuous being sent to the platform
	349	+end
	350	+{{/code}}
	351	+
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,13 +153,137 @@
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** ==
	370	+(% class="wikigeneratedid" %)
	371	+**✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool.
157	157
	373	+(% class="wikigeneratedid" %)
	374	+Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]**
	375	+
	376	+== **2.1 V-Box connect with test server(General Example)** ==
	377	+
	378	+{{code language="lua"}}
	379	+--MQTT configuration table
	380	+local MQTT_CFG={}
	381	+MQTT_CFG.username = "weconsupport"
	382	+MQTT_CFG.password = "123456"
	383	+MQTT_CFG.netway = 0
	384	+MQTT_CFG.keepalive = 60
	385	+MQTT_CFG.cleansession = 1
	386	+--TCP URL
	387	+MQTT_URL = "tcp://mq.tongxinmao.com:1883"
	388	+--Client ID
	389	+MQTT_CLIENT_ID = "V-BOXH-AG"
	390	+
	391	+--Generate UUID
	392	+function uuid()
	393	+ local seed = {'e','1','2','3','4','5','6','7','8','9','a','b','c','d','e','f'}
	394	+ local tb = {}
	395	+ for i=1, 32 do
	396	+ table.insert(tb, seed[math.random(1,16)])
	397	+ end
	398	+ local sid=table.concat(tb)
	399	+ return string.format('%s',
	400	+ string.sub(sid,1,32)
	401	+ )
	402	+end
	403	+
	404	+
	405	+--Topic name to subscribed
	406	+local SUBSCRIBE_TOPIC = 'testtopic/test/no1/123456'
	407	+
	408	+--Topic name to be published
	409	+local PUBLISH_TOPIC = 'testtopic/test/no1/7890'
	410	+
	411	+
	412	+--real time
	413	+local LAST_TIME = 0
	414	+
	415	+
	416	+--initialize mqtt
	417	+function mqtt_init()
	418	+ print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID))
	419	+ g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable
	420	+ if g_mq then
	421	+ g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages
	422	+ print("mqtt init success")
	423	+ else
	424	+ print("mqtt init failed:", err)
	425	+ end
	426	+end
	427	+
	428	+-- connect to mqtt
	429	+function mqtt_connect()
	430	+ print("mqtt connecting...")
	431	+ local stat, err = g_mq:connect(MQTT_CFG)
	432	+ if stat == nil then
	433	+ print("mqtt connect failed:", err)
	434	+ return
	435	+ else
	436	+ print("mqtt connected")
	437	+ end
	438	+ g_mq:subscribe(SUBSCRIBE_TOPIC, 0)
	439	+end
	440	+
	441	+-- Received message callback function
	442	+function mqtt_msg_callback(topic, msg)
	443	+ print("topic:", topic)
	444	+ print("msg:", msg)
	445	+ local objMsg = json.decode(msg)
	446	+ local water = objMsg.data.waterlevel
	447	+ local temp = objMsg.data.temperature
	448	+ addr_setword("@HDW20",water)
	449	+ addr_setword("@HDW10",temp)
	450	+end
	451	+
	452	+--Send data (data upload to platform and encapsulate it with custom functions)
	453	+function send_data()
	454	+ local pub_data = {
	455	+ timestamp = os.time(),
	456	+ messageId = 1,
	457	+ event = 'test_data',
	458	+ mfrs = 'V-Box',
	459	+ data = {
	460	+ id = uuid(),
	461	+ waterlevel = addr_getword("@HDW10"),
	462	+ temperature = addr_getword("@HDW20")
	463	+ }
	464	+ }
	465	+ return g_mq:publish(PUBLISH_TOPIC, json.encode(pub_data), 0, 0)
	466	+end
	467	+
	468	+
	469	+--main function fixed timed execution
	470	+function MQTT.main()
	471	+ --dosomething
	472	+ print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main start")
	473	+ --determine the mqtt object whether exist
	474	+ if g_mq then
	475	+ --determine the mqtt object whether has been connected or not
	476	+ if g_mq:isconnected() then
	477	+ send_data()
	478	+ else
	479	+ --if exceed 20 sec not connect, reconnect once
	480	+ if os.time() - LAST_TIME > 20 then
	481	+ LAST_TIME = os.time()
	482	+ --connect to mqtt or reconnect
	483	+ mqtt_connect()
	484	+ end
	485	+ end
	486	+ else
	487	+ --mqtt object does not exist so create new one
	488	+ mqtt_init()
	489	+ end
	490	+ print(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " main end")
	491	+end
	492	+{{/code}}
	493	+
	494	+== **2.2 V-Box connect with customer server:grouprobotinfo.com** ==
	495	+
158	158	This demo does not use SSL certification. Script is as below
159	159
160	160	Demo1:
161	161
162		-{{code language="Lua"}}
	500	+{{code language="lua"}}
163	163	-- Meta class
164	164	--main
165	165	function mq.main()
...	...	@@ -280,7 +280,7 @@
280	280	FSE=addr_getbit("@B_25395#W2.04"),
281	281	AVVSVV=addr_getbit("@B_25395#W1.12"),
282	282	ICHT=addr_getbit("@B_25395#W3.06")
283		-
	621	+
284	284	}
285	285
286	286	-- ("@B_25395#CIO1.02")
...	...	@@ -302,7 +302,7 @@
302	302	end
303	303	{{/code}}
304	304
305		-== **2.2 V-Box connect with Azure platform** ==
	643	+== **2.3 V-Box connect with Azure platform** ==
306	306
307	307	In this demo,V-Box connects with Azure by SSL certification.
308	308
...	...	@@ -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
	653	+(% class="box infomessage" %)
	654	+(((
	655	+~-~-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"
	658	+~-~-Get custom configuration parameters (vbox custom information)
	659	+~-~-local CUSTOM = bns_get_config("bind")
	660	+~-~-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)
	663	+~-~-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'
	666	+~-~-MQTT_CFG.username = '60a71ccbbbe12002c08f3a1a_WECON'
	667	+~-~-MQTT_CFG.password='wecon123'
	668	+~-~-MQTT_CLIENTID = '60a71ccbbbe12002c08f3a1a_WECON_0_0_2021052110usernxame:60a71ccbbbe12002c08f3a1a_WECONpassword:a0a951581855aa8e0262129da6cf1b43f2c0ecfac4fa56117fc5a20c90be169a'
331	331
332		---publish to topics
	670	+~-~-publish to topics
333	333	local pub_RE_TOPIC = string.format('devices/wecon_02/messages/events/')
334		---Subscribe topics
	672	+~-~-Subscribe topics
335	335	local Subscribe_RE_TOPIC1 = string.format('devices/wecon_02/messages/devicebound/#')
336	336
337		---variable
	675	+~-~-variable
338	338	local last_time = 0
339	339
340	340
341		-
342		---Timing main function
	679	+~-~-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")
	682	+ sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main start")
	683	+ if g_mq then
	684	+ if g_mq:isconnected() then
	685	+ send_Data()
	686	+ else
	687	+ if os.time() - last_time > 20 then
	688	+ last_time = os.time()
	689	+ mymqtt_connect()
	690	+ end
	691	+ end
	692	+ else
	693	+ mymqtt_init()
	694	+ end
	695	+ sprint(os.date("%Y-%m-%d %H:%M %S", os.time()) .. " Azureiot.main end")
359	359	end
360	360
361		--- Initialize MQTT
	698	+~-~- 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
	700	+ sprint(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENTID))
	701	+ g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENTID) ~-~- Create the object and declare it as a global variable
	702	+ if g_mq then
	703	+ g_mq:on("message", mymqtt_msg_callback) ~-~- Register to receive message callbacks
	704	+ sprint("mqtt init success")
	705	+ else
	706	+ sprint("mqtt init failed:", err)
	707	+ end
371	371	end
372	372
373		--- Connect to MQTT server
	710	+~-~- 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)
	712	+ sprint("mqtt connecting...")
	713	+ local stat, err = g_mq:connect(MQTT_CFG,MQTT_LWT, MQTT_CART)
	714	+ if stat == nil then
	715	+ sprint("mqtt connect failed:", err)
	716	+ return
	717	+ else
	718	+ sprint("mqtt connected")
	719	+ end
	720	+ g_mq:subscribe(Subscribe_RE_TOPIC1, 0)
384	384	end
385	385
386		--- Receive MQTT message callback function
	723	+~-~- 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
	725	+ print("topic:",topic)
	726	+ print("revdata:",msg)
	727	+ ~-~- local revData = json.decode(msg)
	728	+ ~-~- if topic == Subscribe_RE_TOPIC1 then ~-~-Process topic information subscribed from the cloud
	729	+~-~- if string.match(topic,Subscribe_RE_TOPIC1) then
	730	+ ~-~- print("topi11:",topic)
	731	+ setValue(revData)
	732	+ ~-~- 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
	735	+~-~-Process the received data
	736	+~-~-function setValue(revData)
	737	+ ~-~- if revData ~~=nil then
	738	+ ~-~- for i,v in pairs(revData) do
	739	+ ~-~- print("Data received：",i,v)
	740	+ ~-~- end
	741	+ ~-~- end
	742	+~-~-end
406	406
407		---Get real-time data
	744	+~-~-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
	746	+ local jdata = {}
	747	+ local addr = bns_get_alldata()
	748	+ print(json.encode(addr))
	749	+ for i,v in pairs(addr) do
	750	+ if v[2] == 1 then
	751	+ jdata[v[3]] = v[4]
	752	+ end
	753	+ end
	754	+ return jdata
	755	+end
419	419
420	420
421		-
422		---send data
	758	+~-~-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		-       -- }}
	760	+ local pub_data = {100
	761	+ ~-~- services=~{~{
	762	+\\ ~-~-serviceId ='Temperature',
	763	+ ~-~- properties={
	764	+ ~-~- value = 55
	765	+ ~-~- },
	766	+ ~-~- }}
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)
	770	+ return g_mq:publish(pub_RE_TOPIC, json.encode(pub_data), 0, 0)
436	436	end
437		-{{/code}}
	772	+)))
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）** ==
	774	+== **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** ==
	923	+== **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** ==
	1044	+== **2.6 V-Box connect with AWS platform** ==
710	710
711	711	=== **Log in AWS** ===
712	712
...	...	@@ -763,102 +763,67 @@
763	763	}
764	764	{{/code}}
765	765
766		-1. **Create things**
	1101	+=== **Create things** ===
767	767
768	768	Click “Manage”~-~-->“Things”~-~-->“Create things”~-~-->“Create single thing”
769	769
	1105	+[[image:image-20220709165402-6.png]]
770	770
771		-|
772		-| |[[image:image-20220709165402-6.png]]
	1107	+[[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
	1111	+[[image:image-20220709165402-8.png]]
782	782
783	783	Select the way to create certificate
784	784
	1115	+[[image:image-20220709165402-9.png]]
785	785
786		-|
787		-| |[[image:image-20220709165402-9.png]]
788		-
789	789	Select policy
790	790
	1119	+[[image:image-20220709165402-10.png]]
791	791
792		-|
793		-| |[[image:image-20220709165402-10.png]]
	1121	+[[image:image-20220709165402-11.png]]
794	794
795	795
	1124	+=== **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
	1128	+[[image:image-20220709165402-13.png]]
809	809
810		-|
811		-| |[[image:image-20220709165402-12.png]]
	1130	+[[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
	1134	+[[image:image-20220709165402-14.png]]
	1135	+
825	825	Upload the CA File, Client Certificate File, Client Key File
826	826
	1138	+[[image:image-20220709165402-15.png]]
827	827
828		-|
829		-| |[[image:image-20220709165402-15.png]]
830		-
831	831	Publish message to topic “TEST”
832	832
	1142	+[[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
	1146	+[[image:image-20220709173500-1.png]]
	1147	+
842	842	And we can also send message form AWS platform to MQTT.fx tool.
843	843
	1150	+[[image:image-20220709165402-18.png]]
844	844
845		-|
846		-| |[[image:image-20220709165402-18.png]]
	1152	+=== **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
	1156	+[[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
	1160	+[[image:image-20220709165402-20.png]]
858	858
859		-|
860		-| |[[image:image-20220709165402-20.png]]
861		-
862	862	sprint = print
863	863
864	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)
...	...	@@ -1039,10 +1039,6 @@
1039	1039
1040	1040	end
1041	1041
1042		-
1043		-
1044	1044	Get message in AWS
1045	1045
1046		-
1047		-|
1048		-| |[[image:image-20220709165402-21.png]]
	1344	+[[image:image-20220709165402-21.png]]

image-20220709173500-1.png

Author

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

Size

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

Content