-
Notifications
You must be signed in to change notification settings - Fork 1
Expand file tree
/
Copy pathProgram.cs
More file actions
119 lines (100 loc) · 3.75 KB
/
Copy pathProgram.cs
File metadata and controls
119 lines (100 loc) · 3.75 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
using System;
using System.Collections.Generic;
using System.Net;
using System.Text;
using System.Threading;
using Newtonsoft.Json;
using System.IO;
namespace HomeMonitorConsole
{
class Program
{
const string API_URL = "http://localhost:58448/api/monitor";
static void Main(string[] args)
{
var rnd = new Random();
do
{
var tempList = new List<Measurement>
{
GetMeasurement(rnd, "1", "Teploměr vnitřní"),
GetMeasurement(rnd, "2", "Teploměr venkovní"),
GetMeasurement(rnd, "3", "Teploměr na chodbě")
};
var batch = new MeasurementBatch
{
BatchDate = DateTime.Now,
DeviceId = "1",
DeviceName = "Tonda's raspberry",
MeasurementType = 1,
Measurements = tempList
};
DoPost(batch);
for (int i = 7; i > 0; i--)
{
Console.Write("..." + i.ToString() + "...");
Thread.Sleep(10000);
}
} while (true);
/*
do
{
var temp1 = GetMeasurement(rnd, "1", "Teploměr vnitřní");
DoPost(temp1);
var temp2 = GetMeasurement(rnd, "2", "Teploměr venkovní");
DoPost(temp2);
var temp3 = GetMeasurement(rnd, "3", "Teploměr na chodbě");
DoPost(temp3);
//Console.ReadLine();
Thread.Sleep(60000);
} while (true); //(Console.ReadKey(true).Key != ConsoleKey.X);
*/
}
private static void DoPost(MeasurementBatch batch)
{
var measurementJson = JsonConvert.SerializeObject(batch);
var myReq = (HttpWebRequest)WebRequest.Create(API_URL);
myReq.Method = "POST";
myReq.ContentType = "application/json";
byte[] byteArray = Encoding.UTF8.GetBytes(measurementJson);
myReq.ContentLength = byteArray.Length;
Stream dataStream = myReq.GetRequestStream();
dataStream.Write(byteArray, 0, byteArray.Length);
dataStream.Close();
var response = (HttpWebResponse)myReq.GetResponse();
Console.WriteLine("Odeslána teplota: {0}", measurementJson);
Console.WriteLine("============================");
}
private static Measurement GetMeasurement(Random rnd, string sensorId, string sensorName)
{
return new Measurement
{
MeasurementDate = DateTime.Now,
SensorId = sensorId,
SensorName = sensorName,
Unit = "Celsius",
Value = ((float)rnd.Next(180, 260)/10).ToString("N1")
};
}
}
public class MeasurementBatch
{
public int BatchId { get; set; }
public int MeasurementType { get; set; }
public string DeviceId { get; set; }
public string DeviceName { get; set; }
public DateTime BatchDate { get; set; }
public List<Measurement> Measurements { get; set; }
}
public class Measurement
{
public int MeasurementId { get; set; }
public int BatchId { get; set; }
public string SensorId { get; set; }
public string SensorName { get; set; }
public DateTime MeasurementDate { get; set; }
public string Value { get; set; }
public string Unit { get; set; }
public DateTime InsertDate { get; set; }
}
}