File content as of revision 4:c16866ed9508:
/*
Copyright (c) 2010 Wimpie
Based on the VBus� Protocol Specification see http://goo.gl/HP6ZY
and http://hobbyelektronik.org/w/index.php/VBus-Decoder
VBus� en Resol� are registrated trademarks see http://www.resol.de
Debugtrace.h -> http://mbed.org/users/snatch59/programs/DebugTrace/gpdz54
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included in
all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
THE SOFTWARE.
*/
#include "VBus.h"
#define DEBUG 0
#if DEBUG
#include "DebugTrace.h"
DebugTrace pc_VBus(ON, TO_SERIAL);
#endif
static uint8_t CalcCrc(const unsigned char *Buffer, int Offset, int Length);
float CalcTemp(char Byte1, char Byte2);
VBus::VBus(PinName tx, PinName rx)
: _Serial(tx, rx) {
_sdcard=false;
_all=false;
ClearMax();
Init(0);
}
void VBus::Init(int addr=0) {
_Serial.baud(9600);
_Serial.format(8,Serial::None,1);
m_timeout=2;
if (addr!=0)
networkaddress=addr;
else
networkaddress=ResolAddress;
}
void VBus::SDcardAvailable(bool status) {
_sdcard=status;
}
void VBus::InjectSeptet(unsigned char *Buffer, int Offset, int Length) {
for (unsigned int i = 0; i < Length; i++) {
if (Septet & (1 << i)) {
Buffer [Offset + i] |= 0x80;
}
}
}
bool VBus::Read() {
int F;
char c;
bool start,stop,quit;
start = true;
stop = false;
quit = false;
Bufferlength=0;
m_timer.reset();
m_timer.start();
while ((!stop) and (!quit)) {
if (_Serial.readable()) {
c=_Serial.getc();
if (c == Sync) {
if (start) {
start=false;
Bufferlength=0;
//#if DEBUG
// pc_VBus.traceOut("\r\n");
//#endif
} else {
if (Bufferlength<20) {
m_timer.stop();
m_timer.reset();
m_timer.start();
Bufferlength=0;
} else
stop=true;
}
}
//#if DEBUG
// pc_VBus.traceOut("%X ",c);
//#endif
if ((!start) and (!stop)) {
Buffer[Bufferlength]=c;
Bufferlength++;
}
}
if ((m_timeout > 0) && (m_timer.read() > m_timeout )) {
quit=true;
//#if DEBUG
// pc_VBus.traceOut("Timeout %i",m_timer.read());
//#endif
}
}
m_timer.stop();
#if DEBUG
pc_VBus.traceOut("\r\nBuffer %i \r\n",Bufferlength);
for (int i=0; i<Bufferlength;i++) {
pc_VBus.traceOut("%X ",Buffer[i]);
}
pc_VBus.traceOut("\r\n");
#endif
if (!quit) {
Destination_address = Buffer[2] << 8;
Destination_address |= Buffer[1];
Source_address = Buffer[4] << 8;
Source_address |= Buffer[3];
ProtocolVersion = (Buffer[5]>>4) + (Buffer[5] &(1<<15));
Command = Buffer[7] << 8;
Command |= Buffer[6];
Framecnt = Buffer[8];
Checksum = Buffer[9]; //TODO check if Checksum is OK
#if DEBUG
pc_VBus.traceOut("\r\nDestination %X",Destination_address);
pc_VBus.traceOut("\r\nSource %X",Source_address);
pc_VBus.traceOut("\r\nProtocol version %X",ProtocolVersion);
pc_VBus.traceOut("\r\nCommand %X",Command);
pc_VBus.traceOut("\r\nFramecnt %X", Framecnt);
pc_VBus.traceOut("\r\nChecksum %X\r\n", Checksum);
#endif
// only analyse Commands 0x100 = Packet Contains data for slave
// with correct length = 10 bytes for HEADER and 6 Bytes for each frame
if ((Command==0x0100) and (Bufferlength==10+Framecnt*6)) {
// Frame info for the Resol ConergyDT5
// check VBusprotocol specification for other products
// This library is made for the ConergyDT5 (0x3271)
//Offset Size Mask Name Factor Unit
//0 2 Temperature sensor 1 0.1 �C
//2 2 Temperature sensor 2 0.1 �C
//4 2 Temperature sensor 3 0.1 �C
//6 2 Temperature sensor 4 0.1 �C
//8 1 Pump speed pump 1 1
//9 1 Pump speed pump 2 1
//10 1 Relay mask 1
//11 1 Error mask 1
//12 2 System time 1
//14 1 Scheme 1
//15 1 1 Option PostPulse 1
//15 1 2 Option thermostat 1
//15 1 4 Option HQM 1
//16 2 Operating hours relay 1 1
//18 2 Operating hours relay 2 1
//20 2 Heat quantity 1 Wh
//22 2 Heat quantity 1000 Wh
//24 2 Heat quantity 1000000 Wh
//26 2 Version 0.01
//
// Each frame has 6 bytes
// byte 1 to 4 are data bytes -> MSB of each bytes
// byte 5 is a septet and contains MSB of bytes 1 to 4
// byte 6 is a checksum
//
//******************* Frame 1 *******************
F=FOffset;
Septet=Buffer[F+FSeptet];
InjectSeptet(Buffer,F,4);
// 'collector1' Temperatur Sensor 1, 15 bits, factor 0.1 in C
Sensor1_temp =CalcTemp(Buffer[F+1], Buffer[F]);
// 'store1' Temperature sensor 2, 15 bits, factor 0.1 in C
Sensor2_temp =CalcTemp(Buffer[F+3], Buffer[F+2]);
//******************* Frame 2 *******************
F=FOffset+FLength;
Septet=Buffer[F+FSeptet];
InjectSeptet(Buffer,F,4);
Sensor3_temp =CalcTemp(Buffer[F+1], Buffer[F]);
Sensor4_temp =CalcTemp(Buffer[F+3], Buffer[F+2]);
//******************* Frame 3 *******************
F=FOffset+FLength*2;
Septet=Buffer[F+FSeptet];
InjectSeptet(Buffer,F,4);
PumpSpeed1 = (Buffer[F] & 0X7F);
PumpSpeed2 = (Buffer[F+1] & 0X7F);
RelaisMask = Buffer[F+2];
ErrorMask = Buffer[F+3];
//******************* Frame 4 *******************
F=FOffset+FLength*3;
Septet=Buffer[F+FSeptet];
InjectSeptet(Buffer,F,4);
#if DEBUG
pc_VBus.traceOut("\r\nFrame 4 %i %i %i %i ",Buffer[F],Buffer[F+1],Buffer[F+2],Buffer[F+3]);
#endif
SystemTime = Buffer[F+1] << 8 | Buffer[F];
Scheme = Buffer[F+2];
OptionPostPulse = (Buffer[F+3] & 0x01);
OptionThermostat = ((Buffer[F+3] & 0x02) >> 1);
OptionHQM = ((Buffer[F+3] & 0x04) >> 2);
//******************* Frame 5 *******************
F=FOffset+FLength*4;
Septet=Buffer[F+FSeptet];
InjectSeptet(Buffer,F,4);
#if DEBUG
pc_VBus.traceOut("\r\nFrame 5 %i %i %i %i ",Buffer[F],Buffer[F+1],Buffer[F+2],Buffer[F+3]);
#endif
OperatingHoursRelais1=Buffer[F+1] << 8 | Buffer[F];
OperatingHoursRelais2=Buffer[F+3] << 8| Buffer[F+2];
//******************* Frame 6 *******************
F=FOffset+FLength*5;
Septet=Buffer[F+FSeptet];
InjectSeptet(Buffer,F,4);
#if DEBUG
pc_VBus.traceOut("\r\nFrame 6 %i %i %i %i ",Buffer[F],Buffer[F+1],Buffer[F+2],Buffer[F+3]);
#endif
HeatQuantity=(Buffer[F+1] << 8 | Buffer[F])+(Buffer[F+3] << 8| Buffer[F+2])*1000;
//******************* Frame 7 *******************
F=FOffset+FLength*6;
Septet=Buffer[F+FSeptet];
InjectSeptet(Buffer,F,4);
#if DEBUG
pc_VBus.traceOut("\r\nFrame 7 %i %i %i %i ",Buffer[F],Buffer[F+1],Buffer[F+2],Buffer[F+3]);
#endif
HeatQuantity=HeatQuantity+(Buffer[F+1] << 8 | Buffer[F])*1000000;
Version=Buffer[F+3] << 8| Buffer[F+2];
///******************* End of frames ****************
if (Sensor1_temp>Sensor1_temp_max)
Sensor1_temp_max=Sensor1_temp;
if (Sensor2_temp>Sensor2_temp_max)
Sensor2_temp_max=Sensor2_temp;
if (Sensor3_temp>Sensor3_temp_max)
Sensor3_temp_max=Sensor3_temp;
if (Sensor4_temp>Sensor4_temp_max)
Sensor4_temp_max=Sensor4_temp;
#if DEBUG
/* pc_VBus.traceOut("\r\nSensor 1 %f", Sensor1_temp);
pc_VBus.traceOut("\r\nSensor 2 %f", Sensor2_temp);
pc_VBus.traceOut("\r\nSensor 3 %f", Sensor3_temp);
pc_VBus.traceOut("\r\nSensor 4 %f", Sensor4_temp);
pc_VBus.traceOut("\r\nPumpSpeed1 %i", PumpSpeed1);
pc_VBus.traceOut("\r\nPumpSpeed2 %i", PumpSpeed2);
pc_VBus.traceOut("\r\nRelaismask %i", RelaisMask);
pc_VBus.traceOut("\r\nErrorMask %i", ErrorMask);
pc_VBus.traceOut("\r\nSystemTime %i", SystemTime);
pc_VBus.traceOut("\r\nSystem %i", Scheme);
pc_VBus.traceOut("\r\nOptionPostPulse %i", OptionPostPulse);
pc_VBus.traceOut("\r\nOptionThermostat %i", OptionThermostat);
pc_VBus.traceOut("\r\nOptionHQM %i", OptionHQM);
pc_VBus.traceOut("\r\nOperatingHoursRelais1 %i", OperatingHoursRelais1);
pc_VBus.traceOut("\r\nOperatingHoursRelais2 %i", OperatingHoursRelais2);*/
pc_VBus.traceOut("\r\nHeatQuantity %i", HeatQuantity);
#endif
}
}
return !quit;
}
void VBus::SaveToSDcard(char* datetime, char* date,char* dayfn) {
char fn[17];
strcpy(fn,"/sd/vb");
strcat(fn,dayfn);
strcat(fn,".csv");
//****************
// filename vbyymmdd.csv
//
// detailed dayinfo, each 5 minutes
//
// dd.mm.yy hh:mm:ss;v1;v2;v3;v4;v5;v6;v7;...
//
//****************
#if DEBUG
pc_VBus.traceOut("%s;%4.1f;%4.1f;%4.1f;%4.1f;%i;%i;%i;%i;%i;%i;%i;%i;%i;%i;%i%;%i;%i\r\n",datetime,
Sensor1_temp, Sensor2_temp,Sensor3_temp, Sensor4_temp,
PumpSpeed1,PumpSpeed2,
RelaisMask,ErrorMask,SystemTime,Scheme,OptionPostPulse,
OptionThermostat, OptionHQM, OperatingHoursRelais1,OperatingHoursRelais2,HeatQuantity,Version
);
#endif
if (_sdcard) {
FILE *fp = fopen(fn, "a");
if (fp) {
fprintf(fp,"%s;%4.1f;%4.1f;%4.1f;%4.1f;%i;%i;%i;%i;%i;%i;%i;%i;%i;%i;%i%;%i;%i\r\n",datetime,
Sensor1_temp, Sensor2_temp,Sensor3_temp, Sensor4_temp,
PumpSpeed1,PumpSpeed2,
RelaisMask,ErrorMask,SystemTime,Scheme,OptionPostPulse,
OptionThermostat, OptionHQM, OperatingHoursRelais1,OperatingHoursRelais2,HeatQuantity,Version
);
fclose(fp);
}
}
}
void VBus::ClearMax() {
Sensor1_temp_max=0.0;
Sensor2_temp_max=0.0;
Sensor3_temp_max=0.0;
Sensor4_temp_max=0.0;
}
void VBus::make_Header (unsigned int DAdr,unsigned int SAdr,unsigned char Ver,unsigned int Cmd,unsigned char AFrames) {
unsigned char Buffer[10]={Sync,(uint8_t)DAdr,DAdr>>8,(uint8_t)SAdr,SAdr>>8,Ver,(uint8_t)Cmd,Cmd>>8,AFrames};
Buffer[9]=CalcCrc(Buffer,1,8);
for (unsigned bo=0;bo<=9;bo++) {
_Serial.putc(Buffer[bo]);
}
}
static uint8_t CalcCrc(const unsigned char *Buffer, int Offset, int Length) {
static uint8_t Crc= 0x7F;
for (unsigned int i = 0; i < Length; i++) {
Crc = (Crc - Buffer [Offset + i]) & 0x7F;
}
return Crc;
}
float CalcTemp(char Byte1, char Byte2) {
int v;
v = Byte1 << 8 | Byte2;
if (Byte1 == 0xFF)
v = v - 0x10000;
if (v==SENSORNOTCONNECTED)
v=0;
return (float)((float) v * 0.1);
}
Wim De Roeve