Accueil Maison Intelligente

nodejs - serveur localJavaScript

var express =require('express');var router =express.Router();var buf =require('buffer');var request =require("request");//remplacez votre-ip-or-domain-name par votre adresse IP ou votre nom de domaine//exemple iot.azurewebsites.com//exemple votrenomdedomaine.com//exemple 47.12.67.16// accept Demande POST sur la page d'accueilrouter.post('/iot/myhome/livingroom/thermostat', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log (état); var options ={ méthode :'POST', url :'http://your-ip-or-domain-name/api/iot/myhome/livingroom/thermostat', en-têtes :{ '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('La température du salon enregistrée');}); // accepter la demande POST microu ter.post('/iot/myhome/livingroom/mic', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(état); var options ={ méthode :'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('Intensité sonore du salon enregistrée');});// accepter la requête 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 ={ method:'POST', url:'http://your-ip-or-domain-name /api/iot/myhome/livingroom/pir', en-têtes :{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true } ; request (options, fonction (erreur, réponse, corps) { si (erreur) lancer une nouvelle erreur (erreur); console.log(corps); }); res.send('Mouvement pir du salon enregistré');});/ / accepter la requête POST distancerouter.post('/iot/myhome/livingroom/distance', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log (état); var options ={ méthode :'POST', url :'http://your-ip-or-domain-name/api/iot/myhome/livingroom/distance', en-têtes :{ 'cache -contrôler':' 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('Obstacle du salon enregistré');});// accepte la requête 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', en-têtes :{ 'cache-control' :'no-cache', 'content-type' :'application/json' }, body:state, json :true } ; request(options, function (erreur, réponse, corps) { if (erreur) lancer une nouvelle erreur (erreur); console.log(corps); }); res.send('l'emplacement de l'appareil enregistré');});// accepter la requête POST 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-ty pe':'application/json' }, corps:état, json:true } ; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Niveau d'humidité du jardin enregistré');});// accepter la demande POST 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', en-têtes :{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true } ; request( options, fonction (erreur, réponse, corps) { si (erreur) lancer une nouvelle erreur (erreur); console.log(corps); }); res.send('Informations sur les fuites de gaz enregistrées');});// accepter POST request lightrouter.post('/iot/myhome/livingroom/light', function (req, res) { var state =req.body; state.timeutc =new Date (); state.signedby ="orangepi"; console. log (état); var options ={ méthode :'POST', url :'http://your-ip-or-domain-name/api/iot/myhome/livingroom/light', en-têtes :{ 'cache-control ':'pas de cache', 'contenu -type':'application/json' }, body:state, json:true } ; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Intensité lumineuse enregistrée');});// accepter la demande POST 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', en-têtes :{ 'cache-control':'no-cache', 'content-type':'application/json' }, body:state, json:true } ; request(options, function (erreur, réponse, corps) { si (erreur) lancer une nouvelle erreur (erreur); console.log(corps); }); res.send('Attributs du salon enregistrés');});// accepter la requête POST du routeur de chambre. post('/iot/myhome/ Bedroom', function (req, res) { var state =req.body; state.timeutc =new Date(); state.signedby ="orangepi"; console.log(state); var options ={ méthode :'POST', url :'http://your-ip-or-domain-name/api/iot/myhome/room/ Bedroom', headers :{ 'cache-control':'no-cache ', 'type de contenu' :'application/json' }, corps:état, json:true } ; request(options, function (error, response, body) { if (error) throw new Error(error); console.log(body); }); res.send('Attributs de chambre enregistrés');});// accepte la demande PUT à /userrouter.put('/user', fonction (req, res) { res.send('J'ai une demande PUT à /user' );});// accepter la demande DELETE sur /user//router.delete('/user', function (req, res) {// res.send('Got a DELETE request at /user');// });/* GET page d'accueil. */router.get('/', function(req, res, next) { res.render('index', { title:'Express' });});module.exports =router;

ThermoStatController.csC#

à l'aide de System;à l'aide de System.Collections.Generic;à l'aide de System.Linq;à l'aide de System.Threading.Tasks;à l'aide de Microsoft.AspNet.Mvc;à l'aide de Newtonsoft.Json;à l'aide de Microsoft.WindowsAzure. Stockage ; à l'aide de Microsoft.WindowsAzure.Storage.Auth ; à l'aide de Microsoft.WindowsAzure.Storage.Table ; // Pour plus d'informations sur l'activation de MVC pour les projets vides, visitez 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) { // Créez la table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Créez l'objet CloudTable qui représente la table "people". Table CloudTable =tableClient.GetTableReference("iot"); iotTemperature.PartitionKey ="thermostat"; iotTemperature.RowKey =Guid.NewGuid().ToString(); // Créez l'objet TableOperation qui insère l'entité client. TableOperation insertOperation =TableOperation.Insert(iotTemperature); // Exécute l'opération d'insertion. table.Execute(insertOperation); return Ok("Données de température enregistrées dans le nuage azur .."); } } classe publique IotTemperature :TableEntity { chaîne publique deviceid { get; ensemble; } chaîne publique timeutc { get; ensemble; } chaîne publique signée par { get; ensemble; } public string state { get { return JsonConvert.SerializeObject(this.desired); } ensemble {; } } public Désiré souhaité { get; ensemble; } public class Desired { public string temperature { get; ensemble; } chaîne publique humidité { get; ensemble; } } }}

PIRController.csC#

à l'aide de System;à l'aide de System.Collections.Generic;à l'aide de System.Linq;à l'aide de System.Threading.Tasks;à l'aide de Microsoft.AspNet.Mvc;à l'aide de Microsoft.WindowsAzure.Storage.Table;à l'aide de Microsoft.AspNet.Mvc;à l'aide de Microsoft.WindowsAzure.Storage.Table;à l'aide Newtonsoft.Json;// Pour plus d'informations sur l'activation de l'API Web pour les projets vides, visitez 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) { // Créez la table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Créez l'objet CloudTable qui représente la table "people". Table CloudTable =tableClient.GetTableReference("iot"); iotPIR.PartitionKey ="pir"; iotPIR.RowKey =Guid.NewGuid().ToString(); // Créez l'objet TableOperation qui insère l'entité client. TableOperation insertOperation =TableOperation.Insert(iotPIR); // Exécute l'opération d'insertion. table.Execute(insertOperation); return Ok("Données PIR enregistrées dans le cloud azur .."); } } classe publique IotPIR :TableEntity { chaîne publique deviceid { get; ensemble; } chaîne publique timeutc { get; ensemble; } chaîne publique signée par { get; ensemble; } public string state { get { return JsonConvert.SerializeObject(this.desired); } ensemble {; } } public Désiré souhaité { get; ensemble; } public class Desired { public string motionstart { get; ensemble; } chaîne publique motionend { get; ensemble; } } }}

MoistureController.csC#

à l'aide de System;à l'aide de System.Collections.Generic;à l'aide de System.Linq;à l'aide de System.Threading.Tasks;à l'aide de Microsoft.AspNet.Mvc;à l'aide de Microsoft.WindowsAzure.Storage.Table;à l'aide de Microsoft.AspNet.Mvc;à l'aide de Microsoft.WindowsAzure.Storage.Table;à l'aide Newtonsoft.Json;// Pour plus d'informations sur l'activation de l'API Web pour les projets vides, visitez 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) { // Créez la table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Créez l'objet CloudTable qui représente la table "people". Table CloudTable =tableClient.GetTableReference("iot"); iotMoisture.PartitionKey ="humidité"; iotMoisture.RowKey =Guid.NewGuid().ToString(); // Créez l'objet TableOperation qui insère l'entité client. TableOperation insertOperation =TableOperation.Insert(iotMoisture); // Exécute l'opération d'insertion. table.Execute(insertOperation); return Ok("Données d'humidité enregistrées dans le nuage azur .."); } } classe publique IotMoisture :TableEntity { chaîne publique deviceid { get; ensemble; } chaîne publique timeutc { get; ensemble; } chaîne publique signée par { get; ensemble; } public string state { get { return JsonConvert.SerializeObject(this.desired); } ensemble {; } } public Désiré souhaité { get; ensemble; } public class Desired { public string humidité { get; ensemble; } } }}

LivingRoomController.csC#

à l'aide de System;à l'aide de System.Collections.Generic;à l'aide de System.Linq;à l'aide de System.Threading.Tasks;à l'aide de Microsoft.AspNet.Mvc;à l'aide de Microsoft.WindowsAzure.Storage.Table;using Newtonsoft.Json;// Pour plus d'informations sur l'activation de l'API Web pour les projets vides, visitez 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) { // Créez la table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Créez l'objet CloudTable qui représente la table "people". Table CloudTable =tableClient.GetTableReference("iot"); iotLivingRoom.PartitionKey ="salon"; iotLivingRoom.RowKey =Guid.NewGuid().ToString(); // Créez l'objet TableOperation qui insère l'entité client. TableOperation insertOperation =TableOperation.Insert(iotLivingRoom); // Exécute l'opération d'insertion. table.Execute(insertOperation); return Ok("Attributs du salon enregistrés sur le nuage azur .."); } } classe publique IotLivingRoom :TableEntity { chaîne publique deviceid { get; ensemble; } chaîne publique timeutc { get; ensemble; } chaîne publique signée par { get; ensemble; } public string state { get { return JsonConvert.SerializeObject(this.desired); } ensemble {; } } public Désiré souhaité { get; ensemble; } public class Desired { public string window { get; ensemble; } chaîne publique porte { get; ensemble; } chaîne publique ac { obtenir; ensemble; } chaîne publique température { get; ensemble; } chaîne publique humidité { get; ensemble; } } }}

LightController.csC#

à l'aide de System;à l'aide de System.Collections.Generic;à l'aide de System.Linq;à l'aide de System.Threading.Tasks;à l'aide de Microsoft.AspNet.Mvc;à l'aide de Microsoft.WindowsAzure.Storage.Table;à l'aide de Newtonsoft.Json;// Pour plus d'informations sur l'activation de l'API Web pour les projets vides, visitez 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) { // Créez le client de la table. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Créez l'objet CloudTable qui représente la table "people". Table CloudTable =tableClient.GetTableReference("iot"); iotLight.PartitionKey ="lumière"; iotLight.RowKey =Guid.NewGuid().ToString(); // Créez l'objet TableOperation qui insère l'entité client. TableOperation insertOperation =TableOperation.Insert(iotLight); // Exécute l'opération d'insertion. table.Execute(insertOperation); return Ok("Intensité lumineuse enregistrée dans le nuage azur .."); } } classe publique IotLight :TableEntity { chaîne publique deviceid { get; ensemble; } chaîne publique timeutc { get; ensemble; } chaîne publique signée par { get; ensemble; } public string state { get { return JsonConvert.SerializeObject(this.desired); } ensemble {; } } public Désiré souhaité { get; ensemble; } public class Desired { public string intensité { get; ensemble; } } }}

GPSController.csC#

à l'aide de System;à l'aide de System.Collections.Generic;à l'aide de System.Linq;à l'aide de System.Threading.Tasks;à l'aide de Microsoft.AspNet.Mvc;à l'aide de Microsoft.WindowsAzure.Storage.Table;à l'aide de Newtonsoft .Json;// Pour plus d'informations sur l'activation de l'API Web pour les projets vides, visitez 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) { // Créez la table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Créez l'objet CloudTable qui représente la table "people". Table CloudTable =tableClient.GetTableReference("iot"); iotGPS.PartitionKey ="gps"; iotGPS.RowKey =Guid.NewGuid().ToString(); // Créez l'objet TableOperation qui insère l'entité client. TableOperation insertOperation =TableOperation.Insert(iotGPS); // Exécute l'opération d'insertion. table.Execute(insertOperation); return Ok("Données GPS enregistrées dans le cloud azur .."); } } classe publique IotGPS :TableEntity { chaîne publique deviceid { get; ensemble; } chaîne publique timeutc { get; ensemble; } chaîne publique signée par { get; ensemble; } public string state { get { return JsonConvert.SerializeObject(this.desired); } ensemble {; } } public Désiré souhaité { get; ensemble; } public class Desired { public string lat { get; ensemble; } [JsonProperty("long")] chaîne publique longitude { get; ensemble; } } }}

GasController.csC#

à l'aide de System;à l'aide de System.Collections.Generic;à l'aide de System.Linq;à l'aide de System.Threading.Tasks;à l'aide de Microsoft.AspNet.Mvc;à l'aide de Microsoft.WindowsAzure.Storage.Table;à l'aide de Newtonsoft.Json;// Pour plus d'informations sur l'activation de l'API Web pour les projets vides, visitez 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) { // Créez la table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Créez l'objet CloudTable qui représente la table "people". Table CloudTable =tableClient.GetTableReference("iot"); iotGas.PartitionKey ="gaz" ; iotGas.RowKey =Guid.NewGuid().ToString(); // Créez l'objet TableOperation qui insère l'entité client. TableOperation insertOperation =TableOperation.Insert(iotGas); // Exécute l'opération d'insertion. table.Execute(insertOperation); return Ok("Informations sur les fuites de gaz enregistrées dans le nuage azur .."); } } classe publique IotGas :TableEntity { chaîne publique deviceid { get; ensemble; } chaîne publique timeutc { get; ensemble; } chaîne publique signée par { get; ensemble; } public string state { get { return JsonConvert.SerializeObject(this.desired); } ensemble {; } } public Désiré souhaité { get; ensemble; } public class Desired { public string leak { get; ensemble; } } }}

DistanceController.csC#

à l'aide de System;à l'aide de System.Collections.Generic;à l'aide de System.Linq;à l'aide de System.Threading.Tasks;à l'aide de Microsoft.AspNet.Mvc;à l'aide de Microsoft.WindowsAzure.Storage.Table; using Newtonsoft.Json;// Pour plus d'informations sur l'activation de l'API Web pour les projets vides, visitez 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) { // Créez la table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Créez l'objet CloudTable qui représente la table "people". Table CloudTable =tableClient.GetTableReference("iot"); iotDistance.PartitionKey ="distance" ; iotDistance.RowKey =Guid.NewGuid().ToString(); // Créez l'objet TableOperation qui insère l'entité client. TableOperation insertOperation =TableOperation.Insert(iotDistance); // Exécute l'opération d'insertion. table.Execute(insertOperation); return Ok("Données d'obstacle enregistrées dans le nuage azur .."); } } classe publique IotDistance :TableEntity { chaîne publique deviceid { get; ensemble; } chaîne publique timeutc { get; ensemble; } chaîne publique signée par { get; ensemble; } public string state { get { return JsonConvert.SerializeObject(this.desired); } ensemble {; } } public Désiré souhaité { get; ensemble; } public class Desired { public string obstacle { get; ensemble; } } }}

BedRoomController.csC#

à l'aide de System;à l'aide de System.Collections.Generic;à l'aide de System.Linq;à l'aide de System.Threading.Tasks;à l'aide de Microsoft.AspNet.Mvc;à l'aide de Microsoft.WindowsAzure.Storage.Table; using Newtonsoft.Json;// Pour plus d'informations sur l'activation de l'API Web pour les projets vides, visitez 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) { // Créez la table client. CloudTableClient tableClient =storageAccount.CreateCloudTableClient(); // Créez l'objet CloudTable qui représente la table "people". Table CloudTable =tableClient.GetTableReference("iot"); iotBedRoom.PartitionKey ="chambre à coucher"; iotBedRoom.RowKey =Guid.NewGuid().ToString(); // Créez l'objet TableOperation qui insère l'entité client. TableOperation insertOperation =TableOperation.Insert(iotBedRoom); // Exécute l'opération d'insertion. table.Execute(insertOperation); return Ok("Attributs de chambre enregistrés sur le nuage azur .."); } } classe publique IotBedRoom :TableEntity { chaîne publique deviceid { get; ensemble; } chaîne publique timeutc { get; ensemble; } chaîne publique signée par { get; ensemble; } public string state { get { return JsonConvert.SerializeObject(this.desired); } ensemble {; } } public Désiré souhaité { get; ensemble; } public class Desired { public string window { get; ensemble; } chaîne publique porte { get; ensemble; } chaîne publique ac { obtenir; ensemble; } chaîne publique température { get; ensemble; } chaîne publique humidité { get; ensemble; } } }}

Maison intelligente Media Tek - Code source pour l'enregistrement des données