pull/46/head
shaun feakes 2018-01-12 13:18:58 -06:00
parent 3a827c39be
commit ecb50af6b6
3 changed files with 10 additions and 10 deletions

View File

@ -100,10 +100,10 @@ bool checkAqualinkTime()
time_difference = (int)difftime(now, last_checked);
if (time_difference < TIME_CHECK_INTERVAL) {
logMessage(LOG_DEBUG, "time not checked, will check in %d seconds", TIME_CHECK_INTERVAL - time_difference);
return TRUE;
return true;
} else {
last_checked = now;
//return FALSE;
//return false;
}
char datestr[DATE_STRING_LEN];
@ -114,7 +114,7 @@ bool checkAqualinkTime()
if (strptime(datestr, "%m/%d/%y %a %I:%M %p", &aq_tm) == NULL) {
logMessage(LOG_ERR, "Could not convert RS time string '%s'", datestr);
last_checked = (time_t)NULL;
return TRUE;
return true;
}
aq_tm.tm_isdst = -1; // Force mktime to use local timezone
@ -125,8 +125,8 @@ bool checkAqualinkTime()
if(abs(time_difference) <= ACCEPTABLE_TIME_DIFF) {
// Time difference is less than or equal to 90 seconds (1 1/2 minutes).
// Set the return value to TRUE.
return TRUE;
// Set the return value to true.
return true;
}
/*
@ -139,7 +139,7 @@ bool checkAqualinkTime()
printf("Aqualink '%s'\n",datestring);
printf("test '%s'\n",datestring);
*/
return FALSE;
return false;
}
/*
@ -219,7 +219,7 @@ void processMessage(char *message)
else if( (msg[1] == ':' || msg[2] == ':') && msg[strlen(msg)-1] == 'M') { // time in format '9:45 AM'
strcpy(_aqualink_data.time, msg);
// Setting time takes a long time, so don't try until we have all other programmed data.
if ( (_initWithRS == true) && strlen(_aqualink_data.date) > 1 && checkAqualinkTime() != TRUE ) {
if ( (_initWithRS == true) && strlen(_aqualink_data.date) > 1 && checkAqualinkTime() != true ) {
logMessage(LOG_NOTICE, "RS time is NOT accurate '%s %s', re-setting on controller!\n", _aqualink_data.time, _aqualink_data.date);
aq_programmer(AQ_SET_TIME, NULL, &_aqualink_data);
} else {
@ -255,7 +255,7 @@ void processMessage(char *message)
bool process_packet(unsigned char* packet, int length)
{
bool rtn = FALSE;
bool rtn = false;
static unsigned char last_packet[AQ_MAXPKTLEN];
static char message[AQ_MSGLONGLEN+1];
static int processing_long_msg = 0;

View File

@ -207,7 +207,7 @@ void mqtt_broadcast_aqualinkstate(struct mg_connection *nc)
if (_aqualink_data->spa_temp != TEMP_UNKNOWN && _aqualink_data->spa_temp != _last_mqtt_aqualinkdata.spa_temp) {
_last_mqtt_aqualinkdata.spa_temp = _aqualink_data->spa_temp;
send_mqtt_temp_msg(nc, SPA_TEMP_TOPIC, _aqualink_data->spa_temp);
send_domoticz_mqtt_temp_msg(nc, _aqualink_config->dzidx_spa_water_temp, _aqualink_data->pool_temp);
send_domoticz_mqtt_temp_msg(nc, _aqualink_config->dzidx_spa_water_temp, _aqualink_data->spa_temp);
}
if (_aqualink_data->pool_htr_set_point != TEMP_UNKNOWN && _aqualink_data->pool_htr_set_point != _last_mqtt_aqualinkdata.pool_htr_set_point) {
_last_mqtt_aqualinkdata.pool_htr_set_point = _aqualink_data->pool_htr_set_point;
@ -640,7 +640,7 @@ static void ev_handler(struct mg_connection *nc, int ev, void *ev_data) {
mg_mqtt_subscribe(nc, topics, 1, 42);
logMessage(LOG_INFO, "MQTT: Subscribing to '%s'\n", aq_topic);
}
else if (_aqualink_config->mqtt_aq_topic != NULL) {
else if (_aqualink_config->mqtt_dz_sub_topic != NULL) {
topics[0].topic = _aqualink_config->mqtt_dz_sub_topic;;
topics[0].qos = qos;
mg_mqtt_subscribe(nc, topics, 1, 42);

Binary file not shown.