Мониторинг радона с помощью RADEX MR107+

#define ZABBIXPORT 10051 // Zabbix erver Port
#define ZABBIXMAXLEN 128
#define ZABBIXAGHOST "Ed" // Zabbix item's host name
#define ZABBIXSENDPERIOD 300 // Period in secoonds
#define wdt_on true

#include <cdcacm.h>
#include <usbhub.h>
#include <Ethernet.h>
#include "pgmstrings.h"

// Satisfy the IDE, which needs to see the include statment in the ino too.
#ifdef dobogusinclude
#include <spi4teensy3.h>
#endif
#include <SPI.h>
//#define SERIAL_OUT
#if wdt_on
#include <avr/wdt.h>
#endif

// ID abba:a104
uint32_t data_tmp;
float data_tmp_f;
uint8_t rec_buffer[100];
uint16_t rcvd = 70;
String str;
unsigned long curTime = 0, tmpTime;

#if defined(WIZ550io_WITH_MACADDRESS) // Use assigned MAC address of WIZ550io
;
#else
byte mac[] = { 0x00, 0xAA, 0xBB, 0xCC, 0xDE, 0x30 };
#endif
int len;
uint8_t res[ZABBIXMAXLEN];
EthernetClient client;
IPAddress server(192, 168, 1, 6); // Zabbix server IP.

void sendToZabbix(String key, float val)
{
str = "";
str = str + "{\"request\":\"sender data\",\"data\":[{\"host\":\"";
str = str + ZABBIXAGHOST;
str = str + "\",\"key\":\"";
str = str + key;
str = str + "\",\"value\":\"";
str = str + val;
str = str + "\"}]}";
len = str.length();
res[0] = 'Z';
res[1] = 'B';
res[2] = 'X';
res[3] = 'D';
res[4] = 0x01;
res[5] = str.length();
res[6] = 0;
res[7] = 0;
res[8] = 0;
res[9] = 0;
res[10] = 0;
res[11] = 0;
res[12] = 0;
str.getBytes(&(res[13]), ZABBIXMAXLEN - 12);
len = len + 13;
#ifdef SERIAL_OUT
for( int i = 0; i < len + 13; i++) {
Serial.print((char)(res[i]));
}
Serial.println();
#endif
if (client.connect(server, ZABBIXPORT)) {
client.write(res, len);
client.stop();
} else {
#ifdef SERIAL_OUT
Serial.println("Not connect. Reset client.");
#endif
client.stop();
}
}

float ieee754tofloat(uint32_t intValue) {
uint32_t e, m;
e = intValue >> 23;
if ( e == 0)
{
m = ( intValue & 0x7FFFFF ) << 1;
} else {
m = ( intValue & 0x7fffff ) | 0x800000;
}
return (float) ( m * pow(2, -23)) * (pow( 2 , ( e - 127)));
}

class ACMAsyncOper : public CDCAsyncOper {
public:
uint8_t OnInit(ACM *pacm);
};

uint8_t ACMAsyncOper::OnInit(ACM *pacm) {
uint8_t rcode;
// Set DTR = 1 RTS=1
rcode = pacm->SetControlLineState(3);

if (rcode) {
ErrorMessage<uint8_t>(PSTR("SetControlLineState"), rcode);
return rcode;
}

LINE_CODING lc;
lc.dwDTERate = 115200;
lc.bCharFormat = 0;
lc.bParityType = 0;
lc.bDataBits = 8;
rcode = pacm->SetLineCoding(&lc);
if (rcode)
ErrorMessage<uint8_t>(PSTR("SetLineCoding"), rcode);
return rcode;
}

USB Usb;
ACMAsyncOper AsyncOper;
ACM Acm(&Usb, &AsyncOper);
uint8_t snd_buffer[] = {0x7b, 0xff, 0x20, 0x00, 0x06, 0x00, 0x83, 0x04, 0x00, 0x00, 0xda, 0xfb, 0x04, 0x08, 0x0c, 0x00, 0xef, 0xf7};

void setup() {
#if wdt_on
wdt_disable();
#endif
#ifdef SERIAL_OUT
Serial.begin( 9600 );
Serial.println("Start");
#endif
pinMode(7, OUTPUT);
digitalWrite(7, HIGH); // Disable SS fo USB host.
#if wdt_on
wdt_enable(WDTO_8S);
#endif
#if !defined(__MIPSEL__)
while (!Serial); // Wait for serial port to connect - used on Leonardo, Teensy and other boards with built-in USB CDC serial connection
#endif
#if defined(WIZ550io_WITH_MACADDRESS) // Use assigned MAC address of WIZ550io
if (Ethernet.begin() == 0) {
#else
if (Ethernet.begin(mac) == 0) {
#endif
#ifdef SERIAL_OUT
Serial.println("Ethernet error.");
#endif
for(;;);
}
#ifdef SERIAL_OUT
Serial.print("Local IP: ");
Serial.println(Ethernet.localIP());
Serial.print("Zabbix server: ");
Serial.println(server);
#endif

if (Usb.Init() == -1) {
#ifdef SERIAL_OUT
Serial.println("OSCOKIRQ failed to assert !");
#endif
while ( 1 );
}
delay( 200 );
}

void loop() {
uint8_t rcode;

Usb.Task();
#if wdt_on
wdt_reset();
#endif
if( Acm.isReady()) {
tmpTime = millis();
if (curTime == 0 || tmpTime - curTime > (unsigned long) ZABBIXSENDPERIOD * 1000 ) {
curTime = tmpTime;
rcode = Acm.SndData(sizeof(snd_buffer), snd_buffer);
if (rcode)
ErrorMessage<uint8_t>(PSTR("SndData"), rcode);
delay(50);
rcvd = 70;
for (int i = 0; i < 100; i++)
rec_buffer[i] = 0;
rcode = Acm.RcvData(&rcvd, rec_buffer);
if (rcode && rcode != hrNAK) {
ErrorMessage<uint8_t>(PSTR("Ret"), rcode);
} else {
if( rcvd == 70 ) {
data_tmp = (uint32_t) rec_buffer[31] << 24 | (uint32_t) rec_buffer[30] << 16 | (uint32_t) rec_buffer[29] << 8 | (uint32_t) rec_buffer[28];
data_tmp_f = ieee754tofloat(data_tmp);
#ifdef SERIAL_OUT
Serial.print("Cur_Rn: ");
Serial.println(data_tmp_f);
#endif
sendToZabbix("mr107_radon", data_tmp_f);
} else {
#ifdef SERIAL_OUT
str = "Failed: " + String(rcvd);
Serial.println(str);
#endif
delay(1000);
curTime = 0;
}
}
}
} else {
#ifdef SERIAL_OUT
Serial.println("ACM not ready.");
#endif
curTime = 0;
delay(1000);
}
}

-typedef MAX3421e<P10, P9> MAX3421E; // Official Arduinos (UNO, Duemilanove, Mega, 2560, Leonardo, Due etc.), Intel Edison, Intel Galileo 2 or Teensy 2.0 and 3.x
+typedef MAX3421e<P7, P9> MAX3421E; // Official Arduinos (UNO, Duemilanove, Mega, 2560, Leonardo, Due etc.), Intel Edison, Intel Galileo 2 or Teensy 2.0 and 3.x