Rumah Pintar Rumah

Kode

• MediaTekRx
• nodejs - server lokal
• ThermoStatController.cs
• PIRController.cs
• MoistureController.cs
• LivingRoomController.cs
• LightController.cs
• GPSController.cs
• GasController.cs
• DistanceController.cs
• BedRoomController.cs

MediaTekRxC/C++

/* Klien web Sketsa ini terhubung ke situs web menggunakan fungsionalitas Wi-Fi pada platform MediaTek LinkIt. Ubah makro WIFI_AP, WIFI_PASSWORD, WIFI_AUTH, dan SITE_URL. dibuat 13 Juli 2010 oleh dlf (Metodo2 srl) dimodifikasi 31 Mei 2012 oleh Tom Igoe dimodifikasi 20 Agustus 2014 oleh MediaTek Inc. */#include #include #include #include #menentukan WIFI_AP "ap Anda"#menentukan WIFI_PASSWORD "kata sandi Anda"#menentukan WIFI_AUTH LWIFI_WPA // memilih dari LWIFI_OPEN, LWIFI_WPA, atau LWIFI_WEP.#menentukan SITE_URL "ip Anda" //alamat nodejs atau ip biru Anda nama domainLWiFiClient c;pengaturan batal(){ LWiFi.begin(); Serial.begin(115200); // terus coba lagi sampai terhubung ke AP Serial.println("Connecting to AP"); while (0 ==LWiFi.connect(WIFI_AP, LWiFiLoginInfo(WIFI_AUTH, WIFI_PASSWORD))) { delay(1000); } // terus coba lagi sampai terhubung ke website Serial.println("Connecting to WebSite"); while (0 ==c.connect(SITE_URL, 3000)) { Serial.println("Menghubungkan Kembali ke Situs Web"); penundaan (1000); }}boolean disconnectedMsg =false;void loop(){ // Pastikan kita terhubung, dan buang konten respon ke Serial while (!c) { Serial.println(" Server disconnected.."); // terus coba lagi sampai terhubung ke website Serial.println("Connecting to WebSite"); while (0 ==c.connect(SITE_URL, 3000)) { Serial.println("Menghubungkan Kembali ke Situs Web"); penundaan (1000); } } Serial.println("Membaca suhu.."); updateSuhu(); penundaan(3000); Serial.println("Mendeteksi suara.."); updateSuara(); penundaan(3000); Serial.println("Mendeteksi pergerakan orang.."); perbaruiPIR(); penundaan(3000); Serial.println("Mendeteksi halangan.."); perbarui jarak(); penundaan(3000); Serial.println("Memperbarui lokasi perangkat.."); perbaruiGPSTracker(); penundaan(3000); Serial.println("Menghitung kelembapan tanah.."); updateMoisture(); penundaan(3000); Serial.println("Mendeteksi kebocoran gas.."); updateGasLeak(); penundaan(3000); Serial.println("Merekam intensitas cahaya.."); updateLightIntensity(); penundaan(3000); updateLivingroomAttributes(); penundaan(3000); updateBedroomAttributes(); delay(3000);}void writeToConsole(){ // Pastikan kita terhubung, dan buang konten respons ke Serial while (c) { int v =c.read(); if (v !=-1) { Serial.print((char)v); } } Serial.println(); Serial.println("Server terputus.."); // terus coba lagi sampai terhubung ke website Serial.println("Connecting to WebSite"); while (0 ==c.connect(SITE_URL, 3000)) { Serial.println("Menghubungkan Kembali ke Situs Web"); penundaan (1000); } }void updatePIR(){ long unsigned int s; DynamicJsonBuffer jsonBuffer; JsonObject&root =jsonBuffer.createObject(); JsonObject&diinginkan =root.createNestedObject("diinginkan"); root["deviceid"] ="/iot/myhome/ruang tamu/pir"; //anggap unit default ms yang diinginkan["motionstart"] =String(random(0,1000)); diinginkan["motionend"]=String(random(1000,10000)); String len =String(root.measureLength()); c.println("POST /iot/myhome/ruang tamu/pir HTTP/1.1"); c.println("Host:" SITE_URL); c.println("Tipe-Konten:aplikasi/json"); c.println("Kontrol Cache:tanpa cache"); c.print("Panjang Konten:"); c.println(len); c.println("Koneksi:tutup"); c.println(); root.printTo(c); root.printTo(Serial); //logika untuk mendeteksi respons server yang lambat dan memposting permintaan lagi tanpa menunggu respons mati s =milis(); // menunggu respons server Serial.println("menunggu respons HTTP:"); while (!c.available()) { delay(100); if((milis() - s> 3000)) { Serial.println(); Serial.println("Server tidak merespons.."); merusak; } } Serial.println("Memanggil tulis ke konsol.."); writeToConsole(); }void updateDistance(){ long unsigned int s; DynamicJsonBuffer jsonBuffer; JsonObject&root =jsonBuffer.createObject(); JsonObject&diinginkan =root.createNestedObject("diinginkan"); root["deviceid"] ="/iot/myhome/ruang tamu/sensor jarak"; //asumsikan satuan default cm yang diinginkan["hambatan"]=String(random(50.450)); String len =String(root.measureLength()); c.println("POST /iot/myhome/ruang tamu/jarak HTTP/1.1"); c.println("Host:" SITE_URL); c.println("Tipe-Konten:aplikasi/json"); c.println("Kontrol Cache:tanpa cache"); c.print("Panjang Konten:"); c.println(len); c.println("Koneksi:tutup"); c.println(); root.printTo(c); root.printTo(Serial); s =mili(); // menunggu respons server Serial.println("menunggu respons HTTP:"); while (!c.available()) { delay(100); if((milis() - s> 3000)) { Serial.println(); Serial.println("Server tidak merespons.."); merusak; } } Serial.println("Memanggil tulis ke konsol.."); writeToConsole(); }void updateGPSTracker(){ long unsigned int s; DynamicJsonBuffer jsonBuffer; JsonObject&root =jsonBuffer.createObject(); JsonObject&diinginkan =root.createNestedObject("diinginkan"); root["deviceid"] ="/iot/mydevice"; diinginkan["lat"] =String(acak(20,25)); diinginkan["panjang"]=String(acak(22,27)); String len =String(root.measureLength()); c.println("POST /iot/mydevice/lokasi HTTP/1.1"); c.println("Host:" SITE_URL); c.println("Tipe-Konten:aplikasi/json"); c.println("Kontrol Cache:tanpa cache"); c.print("Panjang Konten:"); c.println(len); c.println("Koneksi:tutup"); c.println(); root.printTo(c); root.printTo(Serial); s =mili(); // menunggu respons server Serial.println("menunggu respons HTTP:"); while (!c.available()) { delay(100); if((milis() - s> 3000)) { Serial.println(); Serial.println("Server tidak merespons.."); merusak; } } Serial.println("Memanggil tulis ke konsol.."); writeToConsole();}void updateMoisture(){ long unsigned int s; DynamicJsonBuffer jsonBuffer; JsonObject&root =jsonBuffer.createObject(); JsonObject&diinginkan =root.createNestedObject("diinginkan"); root["deviceid"] ="/iot/rumahku/taman/kelembaban"; //asumsikan unit default yang diinginkan["kelembaban"] =String(random(40,60)); String len =String(root.measureLength()); c.println("POST /iot/myhome/garden/moisture HTTP/1.1"); c.println("Host:" SITE_URL); c.println("Tipe-Konten:aplikasi/json"); c.println("Kontrol Cache:tanpa cache"); c.print("Panjang Konten:"); c.println(len); c.println("Koneksi:tutup"); c.println(); root.printTo(c); root.printTo(Serial); s =mili(); // menunggu respons server Serial.println("menunggu respons HTTP:"); while (!c.available()) { delay(100); if((milis() - s> 3000)) { Serial.println(); Serial.println("Server tidak merespons.."); merusak; } } Serial.println("Memanggil tulis ke konsol.."); writeToConsole(); }void updateGasLeak(){ DynamicJsonBuffer jsonBuffer; JsonObject&root =jsonBuffer.createObject(); JsonObject&diinginkan =root.createNestedObject("diinginkan"); diinginkan["kebocoran"] ="tidak"; root["deviceid"] ="/iot/rumahku/dapur/gas"; int s panjang yang tidak ditandatangani; String len =String(root.measureLength()); c.println("POST /iot/myhome/dapur/gas HTTP/1.1"); c.println("Host:" SITE_URL); c.println("Tipe-Konten:aplikasi/json"); c.println("Kontrol Cache:tanpa cache"); c.print("Panjang Konten:"); c.println(len); c.println("Koneksi:tutup"); c.println(); root.printTo(c); root.printTo(Serial); s =mili(); // menunggu respons server Serial.println("menunggu respons HTTP:"); while (!c.available()) { delay(100); if((milis() - s> 3000)) { Serial.println(); Serial.println("Server tidak merespons.."); merusak; } } Serial.println("Memanggil tulis ke konsol.."); writeToConsole(); }void updateLightIntensity(){ DynamicJsonBuffer jsonBuffer; JsonObject&root =jsonBuffer.createObject(); JsonObject&diinginkan =root.createNestedObject("diinginkan"); diinginkan["intensitas"] ="80"; root["deviceid"] ="/iot/myhome/livingroom/light"; int s panjang yang tidak ditandatangani; String len =String(root.measureLength()); c.println("POST /iot/myhome/livingroom/light HTTP/1.1"); c.println("Host:" SITE_URL); c.println("Tipe-Konten:aplikasi/json"); c.println("Kontrol Cache:tanpa cache"); c.print("Panjang Konten:"); c.println(len); c.println("Koneksi:tutup"); c.println(); root.printTo(c); root.printTo(Serial); s =mili(); // menunggu respons server Serial.println("menunggu respons HTTP:"); while (!c.available()) { delay(100); if((milis() - s> 3000)) { Serial.println(); Serial.println("Server tidak merespons.."); merusak; } } Serial.println("Memanggil tulis ke konsol.."); writeToConsole(); }void updateLivingroomAttributes(){ DynamicJsonBuffer jsonBuffer; JsonObject&root =jsonBuffer.createObject(); root["deviceid"] ="/iot/rumahku/ruang tamu"; JsonObject&diinginkan =root.createNestedObject("diinginkan"); //Api alternatif untuk loggin atribut ruang tamu sekaligus yang diinginkan["window"] ="open"; diinginkan["pintu"] ="tertutup"; diinginkan["ac"] ="mati"; diinginkan["suhu"] =String(acak(24,28)); diinginkan["kelembaban"] =String(random(60,65)); int s panjang yang tidak ditandatangani; String len =String(root.measureLength()); c.println("POST /iot/myhome/ruang tamu HTTP/1.1"); c.println("Host:" SITE_URL); c.println("Tipe-Konten:aplikasi/json"); c.println("Kontrol Cache:tanpa cache"); c.print("Panjang Konten:"); c.println(len); c.println("Koneksi:tutup"); c.println(); root.printTo(c); root.printTo(Serial); s =mili(); // menunggu respons server Serial.println("menunggu respons HTTP:"); while (!c.available()) { delay(100); if((milis() - s> 3000)) { Serial.println(); Serial.println("Server tidak merespons.."); merusak; } } Serial.println("Memanggil tulis ke konsol.."); writeToConsole(); } batal updateBedroomAttributes(){ DynamicJsonBuffer jsonBuffer; JsonObject&root =jsonBuffer.createObject(); root["deviceid"] ="/iot/rumahku/kamar tidur"; JsonObject&diinginkan =root.createNestedObject("diinginkan"); //Api alternatif untuk loggin atribut ruang tamu sekaligus yang diinginkan["window"] ="open"; diinginkan["pintu"] ="tertutup"; diinginkan["ac"] ="mati"; diinginkan["suhu"] =String(acak(22,23)); diinginkan["kelembaban"] =String(acak(75,80)); int s panjang yang tidak ditandatangani; String len =String(root.measureLength()); c.println("POST /iot/myhome/bedroom HTTP/1.1"); c.println("Host:" SITE_URL); c.println("Tipe-Konten:aplikasi/json"); c.println("Kontrol Cache:tanpa cache"); c.print("Panjang Konten:"); c.println(len); c.println("Koneksi:tutup"); c.println(); root.printTo(c); root.printTo(Serial); s =mili(); // menunggu respons server Serial.println("menunggu respons HTTP:"); while (!c.available()) { delay(100); if((milis() - s> 3000)) { Serial.println(); Serial.println("Server tidak merespons.."); merusak; } } Serial.println("Memanggil tulis ke konsol.."); writeToConsole(); } void updateSound(){ long unsigned int s; panjang unsigned int e; DynamicJsonBuffer jsonBuffer; JsonObject&root =jsonBuffer.createObject(); JsonObject&diinginkan =root.createNestedObject("diinginkan"); diinginkan["intensitas"] =String(acak(40,80)); root["deviceid"] ="/iot/myhome/ruang tamu/mikrofon"; root["waktu"] =""; root["ditandatangani"]=""; String len =String(root.measureLength()); c.println("POST /iot/myhome/ruang tamu/mic HTTP/1.1"); c.println("Host:" SITE_URL); c.println("Tipe-Konten:aplikasi/json"); c.println("Kontrol Cache:tanpa cache"); c.print("Panjang Konten:"); c.println(len); c.println("Koneksi:tutup"); c.println(); root.printTo(c); root.printTo(Serial); s =mili(); // menunggu respons server Serial.println("menunggu respons HTTP:"); while (!c.available()) { delay(100); if((milis() - s> 3000)) { Serial.println(); Serial.println("Server tidak merespons.."); merusak; } } Serial.println("Memanggil tulis ke konsol.."); writeToConsole();}void updateTemperature(){ long unsigned int s; panjang unsigned int e; DynamicJsonBuffer jsonBuffer; JsonObject&root =jsonBuffer.createObject(); JsonObject&diinginkan =root.createNestedObject("diinginkan"); diinginkan["suhu"] =String(acak(20,40)); diinginkan["kelembaban"]=String(random(60,80)); root["deviceid"] ="/iot/myhome/ruang tamu/termostat"; root["waktu"] =""; root["ditandatangani"]=""; String len =String(root.measureLength()); c.println("POST /iot/myhome/ruang tamu/termostat HTTP/1.1"); c.println("Host:" SITE_URL); c.println("Tipe-Konten:aplikasi/json"); c.println("Kontrol Cache:tanpa cache"); c.print("Panjang Konten:"); c.println(len); c.println("Koneksi:tutup"); c.println(); root.printTo(c); root.printTo(Serial); s =mili(); // menunggu respons server Serial.println("menunggu respons HTTP:"); while (!c.available()) { delay(100); if((milis() - s> 3000)) { Serial.println(); Serial.println("Server tidak merespons.."); merusak; } } Serial.println("Memanggil tulis ke konsol.."); writeToConsole(); }

nodejs - server lokalJavaScript

var express =require('express');var router =express.Router();var buf =require('buffer');var request =memerlukan("permintaan");//ganti nama-ip-atau-domain-Anda dengan alamat ip atau nama domain Anda yang sebenarnya//contoh iot.azurewebsites.com//contoh namadomainanda.com//contoh 47.12.67.16// terima POST permintaan di homepagerouter.post('/iot/myhome/livingroom/thermostat', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ metode:'POST', url:'http://your-ip-or-domain-name/api/iot/myhome/livingroom/thermostat', header:{ 'cache -control':'no-cache', 'content-type':'application/json' }, body:state, json:true }; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Suhu ruang tamu direkam');});// terima permintaan POST microuter.post('/iot/myhome/livingroom/mic' , seru ction (req, res) { var state =req.body; state.timeutc =Tanggal baru(); state.signedby ="orangepi"; console.log(negara); var options ={ metode:'POST', url:'http://your-ip-or-domain-name/api/iot/myhome/livingroom/microphone', headers:{ 'cache-control':'no- cache', 'content-type':'application/json' }, body:state, json:true }; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Intensitas suara ruang tamu direkam');});// terima permintaan POST pirrouter.post('/iot/myhome/livingroom/pir', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ metode:'POST', url:'http://your-ip-or-domain-name /api/iot/myhome/livingroom/pir', headers:{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true }; request (options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Gerakan pir ruang tamu direkam');});/ / terima permintaan POST distancerouter.post('/iot/myhome/livingroom/distance', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ metode:'POST', url:'http://your-ip-or-domain-name/api/iot/myhome/livingroom/distance', headers:{ 'cache -control':'no-cache', 'content-type':'application/json' }, body:state, js pada:benar }; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Ruang tamu terekam');});// terima permintaan POST gpsrouter.post('/iot/mydevice/location', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ method:'POST', url:'http://your-ip-or-domain-name/api/ iot/mydevice/location/gps', headers:{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true }; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('device location recorded');});// accept POST request moisturerouter .post('/iot/myhome/garden/moisture', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state ); var options ={ method:'POST', url:'http://your-ip-or-domain-name/api/iot/myhome/garden/moisture', headers:{ 'cache-control':' no-cache', 'content-type':'application/json' }, body:state, json:true }; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Garden moisture level recorded');});// accept POST request gasrouter.post('/iot/myhome/kitchen/gas', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ method:'POST', url:'http://your-ip-or-domain-name/api/iot/myhome/kitchen/gas', headers:{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true }; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Gas leak information recorded');});// accept POST request lightrouter.post('/iot/myhome/livingroom/light', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ method:'POST', url:'http://your-ip-or-domain-name/api/iot/myhome/livingroom/light', headers:{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true }; request(optio ns, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Light intensity recorded');});// accept POST request livingroomrouter.post('/iot/myhome/livingroom', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ method:'POST', url:'http://your-ip-or-domain-name/api/iot/myhome/room/livingroom', headers:{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true }; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Livingroom attributes recorded');});// accept POST request bedroomrouter.post('/iot/myhome/bedroom', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ method:'POST', url:'http://your-ip-or-domain-name/api/iot/myhome/room/bedroom', headers:{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true }; request(options, fu nction (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Bedroom attributes recorded');});// accept PUT request at /userrouter.put('/user', function (req, res) { res.send('Got a PUT request at /user');});// accept DELETE request at /user//router.delete('/user', function (req, res) {// res.send('Got a DELETE request at /user');//});/* GET home page. */router.get('/', function(req, res, next) { res.render('index', { title:'Express' });});module.exports =router;

ThermoStatController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Newtonsoft.Json;using Microsoft.WindowsAzure.Storage;using Microsoft.WindowsAzure.Storage.Auth;using Microsoft.WindowsAzure.Storage.Table;// For more information on enabling MVC for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/livingroom/[Controller]")] public class ThermoStatController :IoTController { // GET:// public IActionResult Index() { return View(); } [HttpPost] public IActionResult Post([FromBody]IotTemperature iotTemperature) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotTemperature.PartitionKey ="thermostat"; iotTemperature.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotTemperature); // Execute the insert operation. table.Execute(insertOperation); return Ok("Temperature data logged to azure cloud.."); } } public class IotTemperature :TableEntity { public string deviceid { get; mengatur; } public string timeutc { get; mengatur; } public string signedby { get; mengatur; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; mengatur; } public class Desired { public string temperature { get; mengatur; } public string humidity { get; mengatur; } } }}

PIRController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/livingroom/[Controller]")] public class PIRController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotPIR iotPIR) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotPIR.PartitionKey ="pir"; iotPIR.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotPIR); // Execute the insert operation. table.Execute(insertOperation); return Ok("PIR data logged to azure cloud.."); } } public class IotPIR :TableEntity { public string deviceid { get; mengatur; } public string timeutc { get; mengatur; } public string signedby { get; mengatur; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; mengatur; } public class Desired { public string motionstart { get; mengatur; } public string motionend { get; mengatur; } } }}

MoistureController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/garden/[Controller]")] public class MoistureController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotMoisture iotMoisture) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotMoisture.PartitionKey ="moisture"; iotMoisture.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotMoisture); // Execute the insert operation. table.Execute(insertOperation); return Ok("Moisture data logged to azure cloud.."); } } public class IotMoisture :TableEntity { public string deviceid { get; mengatur; } public string timeutc { get; mengatur; } public string signedby { get; mengatur; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; mengatur; } public class Desired { public string moisture { get; mengatur; } } }}

LivingRoomController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/room/[controller]")] public class LivingRoomController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotLivingRoom iotLivingRoom) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotLivingRoom.PartitionKey ="livingroom"; iotLivingRoom.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotLivingRoom); // Execute the insert operation. table.Execute(insertOperation); return Ok("Living room attributes logged to azure cloud.."); } } public class IotLivingRoom :TableEntity { public string deviceid { get; mengatur; } public string timeutc { get; mengatur; } public string signedby { get; mengatur; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; mengatur; } public class Desired { public string window { get; mengatur; } public string door { get; mengatur; } public string ac { get; mengatur; } public string temperature { get; mengatur; } public string humidity { get; mengatur; } } }}

LightController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/livingroom/[Controller]")] public class LightController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotLight iotLight) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotLight.PartitionKey ="light"; iotLight.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotLight); // Execute the insert operation. table.Execute(insertOperation); return Ok("Light intensity logged to azure cloud.."); } } public class IotLight :TableEntity { public string deviceid { get; mengatur; } public string timeutc { get; mengatur; } public string signedby { get; mengatur; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; mengatur; } public class Desired { public string intensity { get; mengatur; } } }}

GPSController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/mydevice/location/[Controller]")] public class GPSController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotGPS iotGPS) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotGPS.PartitionKey ="gps"; iotGPS.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotGPS); // Execute the insert operation. table.Execute(insertOperation); return Ok("GPS data logged to azure cloud.."); } } public class IotGPS :TableEntity { public string deviceid { get; mengatur; } public string timeutc { get; mengatur; } public string signedby { get; mengatur; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; mengatur; } public class Desired { public string lat { get; mengatur; } [JsonProperty("long")] public string longitude { get; mengatur; } } }}

GasController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/kitchen/[Controller]")] public class GasController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotGas iotGas) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotGas.PartitionKey ="gas"; iotGas.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotGas); // Execute the insert operation. table.Execute(insertOperation); return Ok("Gas leak information logged to azure cloud.."); } } public class IotGas :TableEntity { public string deviceid { get; mengatur; } public string timeutc { get; mengatur; } public string signedby { get; mengatur; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; mengatur; } public class Desired { public string leak { get; mengatur; } } }}

DistanceController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/livingroom/[Controller]")] public class DistanceController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotDistance iotDistance) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotDistance.PartitionKey ="distance"; iotDistance.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotDistance); // Execute the insert operation. table.Execute(insertOperation); return Ok("Obstacle data logged to azure cloud.."); } } public class IotDistance :TableEntity { public string deviceid { get; mengatur; } public string timeutc { get; mengatur; } public string signedby { get; mengatur; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; mengatur; } public class Desired { public string obstacle { get; mengatur; } } }}

BedRoomController.csC#

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNet.Mvc;using Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// For more information on enabling Web API for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860namespace iotwebapp.Controllers{ [Route("api/iot/myhome/room/[controller]")] public class BedRoomController :IoTController { [HttpPost] public IActionResult Post([FromBody]IotBedRoom iotBedRoom) { // Create the table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Create the CloudTable object that represents the "people" table. CloudTable table =tableClient.GetTableReference("iot"); iotBedRoom.PartitionKey ="bedroom"; iotBedRoom.RowKey =Guid.NewGuid().ToString(); // Create the TableOperation object that inserts the customer entity. TableOperation insertOperation =TableOperation.Insert(iotBedRoom); // Execute the insert operation. table.Execute(insertOperation); return Ok("Bed room attributes logged to azure cloud.."); } } public class IotBedRoom :TableEntity { public string deviceid { get; mengatur; } public string timeutc { get; mengatur; } public string signedby { get; mengatur; } public string state { get { return JsonConvert.SerializeObject(this.desired); } set {; } } public Desired desired { get; mengatur; } public class Desired { public string window { get; mengatur; } public string door { get; mengatur; } public string ac { get; mengatur; } public string temperature { get; mengatur; } public string humidity { get; mengatur; } } }}

Media Tek Smart home - Source code for data logging

Skema