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
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
|
// Copyright 2011 Juri Glass, Mathias Runge, Nadim El Sayed
// DAI-Labor, TU-Berlin
//
// This file is part of libSML.
// Thanks to Thomas Binder and Axel (tuxedo) for providing code how to
// print OBIS data (see transport_receiver()).
// https://community.openhab.org/t/using-a-power-meter-sml-with-openhab/21923
//
// libSML is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// libSML is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with libSML. If not, see <http://www.gnu.org/licenses/>.
#include <stdio.h>
#include <fcntl.h>
#include <unistd.h>
#include <errno.h>
#include <termios.h>
#include <stdlib.h>
#include <stdbool.h>
#include <string.h>
#include <math.h>
#include <sys/ioctl.h>
#include <sml/sml_file.h>
#include <sml/sml_transport.h>
#include <sml/sml_value.h>
#include "unit.h"
int serial_port_open(const char* device) {
int bits;
struct termios config;
memset(&config, 0, sizeof(config));
if (!strcmp(device, "-"))
return 0; // read stdin when "-" is given for the device
#ifdef O_NONBLOCK
int fd = open(device, O_RDWR | O_NOCTTY | O_NONBLOCK);
#else
int fd = open(device, O_RDWR | O_NOCTTY | O_NDELAY);
#endif
if (fd < 0) {
fprintf(stderr, "error: open(%s): %s\n", device, strerror(errno));
return -1;
}
// set RTS
ioctl(fd, TIOCMGET, &bits);
bits |= TIOCM_RTS;
ioctl(fd, TIOCMSET, &bits);
tcgetattr(fd, &config);
// set 8-N-1
config.c_iflag &= ~(IGNBRK | BRKINT | PARMRK | ISTRIP | INLCR | IGNCR
| ICRNL | IXON);
config.c_oflag &= ~OPOST;
config.c_lflag &= ~(ECHO | ECHONL | ICANON | ISIG | IEXTEN);
config.c_cflag &= ~(CSIZE | PARENB | PARODD | CSTOPB);
config.c_cflag |= CS8;
// set speed to 9600 baud
cfsetispeed(&config, B9600);
cfsetospeed(&config, B9600);
tcsetattr(fd, TCSANOW, &config);
return fd;
}
void transport_receiver(unsigned char *buffer, size_t buffer_len) {
int i;
// the buffer contains the whole message, with transport escape sequences.
// these escape sequences are stripped here.
sml_file *file = sml_file_parse(buffer + 8, buffer_len - 16);
// the sml file is parsed now
// this prints some information about the file
sml_file_print(file);
// read here some values ...
printf("OBIS data\n");
for (i = 0; i < file->messages_len; i++) {
sml_message *message = file->messages[i];
if (*message->message_body->tag == SML_MESSAGE_GET_LIST_RESPONSE) {
sml_list *entry;
sml_get_list_response *body;
body = (sml_get_list_response *) message->message_body->data;
for (entry = body->val_list; entry != NULL; entry = entry->next) {
if (!entry->value) { // do not crash on null value
fprintf(stderr, "Error in data stream. entry->value should not be NULL. Skipping this.\n");
continue;
}
if (entry->value->type == SML_TYPE_OCTET_STRING) {
char *str;
printf("%d-%d:%d.%d.%d*%d#%s#\n",
entry->obj_name->str[0], entry->obj_name->str[1],
entry->obj_name->str[2], entry->obj_name->str[3],
entry->obj_name->str[4], entry->obj_name->str[5],
sml_value_to_strhex(entry->value, &str, true));
free(str);
} else if (entry->value->type == SML_TYPE_BOOLEAN) {
printf("%d-%d:%d.%d.%d*%d#%s#\n",
entry->obj_name->str[0], entry->obj_name->str[1],
entry->obj_name->str[2], entry->obj_name->str[3],
entry->obj_name->str[4], entry->obj_name->str[5],
entry->value->data.boolean ? "true" : "false");
} else if (((entry->value->type & SML_TYPE_FIELD) == SML_TYPE_INTEGER) ||
((entry->value->type & SML_TYPE_FIELD) == SML_TYPE_UNSIGNED)) {
double value = sml_value_to_double(entry->value);
int scaler = (entry->scaler) ? *entry->scaler : 0;
value = value * pow(10, scaler);
printf("%d-%d:%d.%d.%d*%d#%.1f#",
entry->obj_name->str[0], entry->obj_name->str[1],
entry->obj_name->str[2], entry->obj_name->str[3],
entry->obj_name->str[4], entry->obj_name->str[5], value);
char *unit = NULL;
if (entry->unit && // do not crash on null (unit is optional)
(unit = dlms_get_unit((unsigned char) *entry->unit)) != NULL)
printf("%s", unit);
printf("\n");
// flush the stdout puffer, that pipes work without waiting
fflush(stdout);
}
}
}
}
// free the malloc'd memory
sml_file_free(file);
}
int main(int argc, char *argv[]) {
// this example assumes that a EDL21 meter sending SML messages via a
// serial device. Adjust as needed.
if (argc != 2) {
printf("Usage: %s <device>\n", argv[0]);
printf("device - serial device of connected power meter e.g. /dev/cu.usbserial, or - for stdin\n");
exit(1); // exit here
}
// open serial port
int fd = serial_port_open(argv[1]);
if (fd < 0) {
printf("Error: failed to open device (%s)\n", argv[1]);
exit(3);
}
// listen on the serial device, this call is blocking.
sml_transport_listen(fd, &transport_receiver);
close(fd);
return 0;
}
|
