WebSVN – heizung – Diff – /trunk/heizung.c

 /*
- * (C) Copyright 2010 by Andreas Theofilu <andreas@theosys.at>
+ * (C) Copyright 2010, 2011 by Andreas Theofilu <andreas@theosys.at>
  * All rights reserved!
  */
 #include <stdio.h>
 #include <string.h>
 #include <netinet/in.h>
 #include <sys/param.h>
 #include <sys/ioctl.h>
 #include <pwd.h>
 #include <grp.h>
-typedef struct
+#include "sensor.h"
-{
-      char User[32];
+#include "usb_comm.h"
-      char Grp[32];
-      char HeizPath[256];
+#include "heizung.h"
-      int port;
-}CONFIGURE;
 typedef struct
+{
       int wday;
       ulong start;
 CONFIGURE configs;
 HEIZINDEX *HeizFirst;
 float ActTemperature;
 float ActPressure;
-static pthread_t pthr_pars;
+static pthread_t pthr_pars, pthr_temp_pars;
 // Prototypes
 void daemon_start(int ignsigcld);
+void *pthr_temperature(void *pV_data);
 void *pthr_parser(void *pV_data);
 void sig_child(void);
 int parseCommand(int s1, char *cmd);
 void changeToUser(char *, char *);
 char *readLine(int fd, char *buf, int bufLen);
 char *trim(char *str);
 char *remove_string(char *str, char *search, char *ret);
 static pthread_mutex_t fastmutex = PTHREAD_MUTEX_INITIALIZER;
+static pthread_mutex_t fastmutex_ser = PTHREAD_MUTEX_INITIALIZER;
 /*
  * The main program, initializing everything and start the daemon.
  */
 int main(int argc, char *argv[])
+{
 int fd, index;
 	HeizFirst = NULL;
 	readConf();
+	// Initialize USB
+	serialDev.fd = -1;
+	serialDev.switch_fd = -1;
+	serialDev.handle = NULL;
 	// Now daemonize this application
 	daemon_start(0);
 	changeToUser(&configs.User[0], &configs.Grp[0]);
 	// Now start our Thread
 	if (pthread_create(&pthr_pars, NULL, pthr_parser, (void *)0) != 0)
+	{
 	   syslog (LOG_DAEMON,"Create of thread \"pthr_parser\" failed!");
 	   return 1;
+	}
+	// Here we start another thread to read the temperature
+	if (pthread_create(&pthr_temp_pars, NULL, pthr_temperature, (void *)0) != 0)
+	{
+	   syslog(LOG_DAEMON,"Create of thread \"pthr_temperature\" failed!");
+	   pthread_cancel(pthr_pars);
+	   return 1;
+	}
 	while (1)
 	   sleep(3600);
+	pthread_exit(NULL);
 	return 0;
+}
 /*
  * Detach application from console and make it a daemon.
 	   if(userpwd->pw_dir)
 	      setenv("HOME", userpwd->pw_dir, 1);
+        }
+}
+void *pthr_temperature(void *pV_data)
+{
+time_t t, tstart;
+struct tm *zeit, sz;
+int sleep_sec;
+	// Initialize the serial port.
+	serial_set_method((strlen(configs.Device)) ? 1 : 0, configs.VID, configs.PID);
+	if (strlen(configs.Device))
+	   serial_set_device(configs.Device);
+	if (!serial_open())
+	   return NULL;
+	if (serialDev.switch_fd == -1)
+	{
+	   if (!serial_open())
+	      return NULL;
+	}
+	pthread_mutex_lock (&fastmutex_ser);
+	while(1)
+	{
+	   HEIZINDEX *act;
+	   ActTemperature = GetTemp();
+	   sleep_sec = 300;
+	   // Compare the actual temperature with the one that should be
+	   // and switch heating on or off
+	   if (HeizFirst)
+	   {
+	      int wday;
+	      unsigned long loctm;
+	      t = time (NULL);
+	      sleep_sec = 300 - (int)((t + 300L) % 300L);
+	      sleep_sec++;
+	      zeit = localtime (&t);
+	      wday = (zeit->tm_wday == 0) ? 7 : zeit->tm_wday;
+	      memset (&sz, 0, sizeof (struct tm));
+	      sz.tm_min = 0;
+	      sz.tm_hour = 0;
+	      sz.tm_mon = zeit->tm_mon;
+	      sz.tm_mday = zeit->tm_mday;
+	      sz.tm_year = zeit->tm_year;
+	      sz.tm_isdst = zeit->tm_isdst;
+	      tstart = mktime(&sz);
+	      loctm = t - tstart;	// Seconds since midnight
+	      act = HeizFirst;
+syslog(LOG_INFO,"wday: %d, loctm: %lu", wday, loctm);
+	      while(act)
+	      {
+		 if (act->heizung->wday == wday && loctm >= act->heizung->start && loctm <= act->heizung->end)
+		 {
+syslog(LOG_INFO,"wday: %d, loctm: %lu, endt: %lu, solltemp: %.1f", wday, loctm, act->heizung->start, act->heizung->temp);
+		    if (ActTemperature == 9999.0)
+		       SwitchOff();		// No temperature, no heating
+		    else if (ActTemperature < 5.0)
+		       SwitchOn();		// Make sure it will not freeze
+		    else if (ActTemperature > 30.0)
+		       SwitchOff();		// Don't over heat
+		    else if (ActTemperature <= (act->heizung->temp - 0.5))
+		       SwitchOn();
+		    else if (ActTemperature > act->heizung->temp)
+		       SwitchOff();
+		 }
+		 act = act->next;
+	      }
+	   }
+	   else
+	      syslog(LOG_INFO,"Structure not initialized!");
+	   sleep(sleep_sec);		// Wait 5 Minutes
+	}
+	pthread_mutex_unlock(&fastmutex_ser);
+}
 void *pthr_parser( void *pV_data )
+{
 int i;
 char ch, buf[128];
 // socket structure
+	      }
 	      i++;
+	   }
-	   pthread_mutex_unlock(&fastmutex);
 	   close (s1);
+	   pthread_mutex_unlock(&fastmutex);
+	}
+	serial_close();
 	return NULL;
+}
 int parseCommand(int s1, char *cmd)
+{
 	   strncpy(bef,cmd,p - cmd);
 	   strncpy(par,p+1,strlen(p+1));
+	}
 	else
 	   strncpy(bef,cmd,strlen(cmd)-1);
-sprintf(&hv0[0], "%s --> %s\n", bef, par);
-write(s1, hv0, strlen(hv0));
 	if (!strcasecmp(bef, "LIST"))		// Write out current list
+	{
-	   act = HeizFirst;
-	   i = 1;
+	   int wday = 1;
+	   i = 1;	// The line counter
+	   // We will write out the week days in the correct order.
+	   // So we need 2 loops. The first one is runnung for every week day
+	   // and the 2nd one will find every entry for the actual week day.
-	   while (act)
+	   while (wday <= 7)
+	   {
+	      act = HeizFirst;
+	      while (act)
+	      {
+		 if (act->heizung->wday == wday)
+		 {
-	      sprintf(&hv0[0], "LINE:%d:%d:%lu:%lu:%f;", i, act->heizung->wday,
+		    sprintf(&hv0[0], "LINE:%d:%d:%lu:%lu:%.1f;", i, act->heizung->wday,
-		      act->heizung->start, act->heizung->end, act->heizung->temp);
+			act->heizung->start, act->heizung->end, act->heizung->temp);
-	      write(s1, &hv0[0], strlen(hv0));
+		    write(s1, &hv0[0], strlen(hv0));
-	      i++;
+		    i++;
+		 }
-	      act = act->next;
+		 act = act->next;
+	      }
+	      wday++;
+	   }
+	}
 	if (!strcasecmp(bef, "GET WDAY"))		// Write out a particular week day
+	{
 	   i = 1;
 	   while (act && act->heizung->wday == wday)
+	   {
-	      sprintf(&hv0[0], "LINE:%d:%d:%lu:%lu:%f;", i, act->heizung->wday,
+	      sprintf(&hv0[0], "LINE:%d:%d:%lu:%lu:%.1f;", i, act->heizung->wday,
 		      act->heizung->start, act->heizung->end, act->heizung->temp);
 	      write(s1, &hv0[0], strlen(hv0));
 	      i++;
 	      act = act->next;
+	   }
+	}
 	if (!strcasecmp(bef, "GET TEMP"))	// Return actual temperature
+	{
-	   sprintf(&hv0[0], "TEMP:%f;", ActTemperature);
+	   sprintf(&hv0[0], "TEMP:%.1f;", ActTemperature);
 	   write(s1, &hv0[0], strlen(hv0));
+	}
 	if (!strcasecmp(bef, "GET PRESSURE"))	// Return the actual air pressure
+	{
-	   sprintf(&hv0[0], "PRESSURE:%f;", ActPressure);
+	   sprintf(&hv0[0], "PRESSURE:%.3f;", ActPressure);
 	   write(s1, &hv0[0], strlen(hv0));
+	}
 	// SET DAY:<count>:<day>:<end1>:<temp>[:<end2>:<temp>[:...]];
 	// <count>   number of entries following
 		 act->heizung->wday = wday;
 		 act->heizung->end = endt;
 		 act->heizung->temp = temp;
 		 if (last)
-		    act->heizung->start = act->heizung->end;
+		    act->heizung->start = last->heizung->end;
 		 else
 		    act->heizung->start = 0L;
 		 last = act;
+	      }
+	      writeHeizPlan();
+	   }
+	}
 	// SET TEMP:<wday>:<end>:<temp>;
-	if (!strcasecmp(bef, "SET TEMP:"))	// Set the temperature for a particular day and line
+	if (!strcasecmp(bef, "SET TEMP"))	// Set the temperature for a particular day and line
+	{
 	int wday;
 	unsigned long endt;
 	float tmp;
 	   remove_string(par, ":", &hv0[0]);
 	   endt = atol(par);
 	   remove_string(par, ":", &hv0[0]);
 	   tmp = atof(par);
 	   insertMember(wday, endt, tmp);
+	   writeHeizPlan();
+	}
 	return 1;
+}
 	   next = act->next;
 	   free(act);
 	   act = next;
+	}
+	HeizFirst = NULL;
+}
 /*
  * Free only one entry in the chain
  */
+	   }
+	}
 	else
 	   confFile[0] = 0;
-        memset(&configs, 0, sizeof(configs));
+	memset(&configs, 0, sizeof(configs));
-        strcpy(configs.User,"nobody");
+	strcpy(configs.User,"nobody");
-        strcpy(configs.Grp,"nobody");
+	strcpy(configs.Grp,"nobody");
-        strcpy(configs.HeizPath, "/var/www/.HeizPlan.conf");
+	strcpy(configs.HeizPath, "/var/www/.HeizPlan.conf");
+	strcpy(configs.Werte, "/var/log/werte.dat");
+	strcpy(configs.Device, "/dev/ttyS1");
-        configs.port = 11001;
+	configs.port = 11001;
 	if (!confFile[0] || (fd = open(confFile,O_RDONLY)) == -1)
+	{
 	   if (confFile[0])
 	      syslog(LOG_WARNING,"Error opening the config file %s! Using built in defaults. (%s)", confFile, strerror(errno));
 	   if (!strcasecmp(hv0, "heizpath"))
+	   {
 	      syslog(LOG_INFO,"Found \"heizpath\": %s", hv1);
 	      strncpy (configs.HeizPath, hv1, sizeof(configs.HeizPath));
+	   }
+	   if (!strcasecmp(hv0, "Werte"))
+	   {
+	      syslog(LOG_INFO,"Found \"Werte\": %s", hv1);
+	      strncpy (configs.Werte, hv1, sizeof(configs.Werte));
+	   }
+	   if (!strcasecmp(hv0, "Device"))
+	   {
+	      syslog(LOG_INFO,"Found \"Device\": %s", hv1);
+	      strncpy (configs.Device, hv1, sizeof(configs.Device));
+	   }
+	   if (!strcasecmp(hv0, "VID"))
+	   {
+	      syslog(LOG_INFO,"Found VendorID: %04x", atoi(hv1));
+	      configs.VID = atoi(hv1);
+	   }
+	   if (!strcasecmp(hv0, "PID"))
+	   {
+	      syslog(LOG_INFO,"Found ProductID: %04x", atoi(hv1));
+	      configs.PID = atoi(hv1);
+	   }
+	}
 	close (fd);
+}
+	{
 	   int len;
 	   trim (&line[0]);
-	   if (line[0] == '#')
+	   if (line[0] == '#' || !strlen(line) || strchr(line, ',') == NULL)
 	      continue;
 	   // We need a place to store the information
 	   prev = act;
 		       hour = atoi(p);
 		       min = atoi(xp+1);
 		       if (hour >= 0 && hour <= 23 && min >= 0 && min <= 59)
+		       {
-			  act->heizung->end = hour * 3600 + (min + 1) * 60;
+			  act->heizung->end = hour * 3600 + min * 60 + 59;
 			  if (prev && prev->heizung->wday == act->heizung->wday)
 			     act->heizung->start = prev->heizung->end;
+		       }
+		    }
 char hv0[512];
 HEIZINDEX *act;
 	fd = -1;
-	if (!access(configs.HeizPath, R_OK))
+	if (access(configs.HeizPath, R_OK))
 	   return 0;
 	if ((fd = open(configs.HeizPath, O_RDWR | O_TRUNC)) == -1)
 	   return 0;
 	act = HeizFirst;
 	while(act)
+	{
+	   if (act->heizung->wday)
+	   {
+	      int hour, min;
+	      hour = act->heizung->end / 3600;
+	      min = (act->heizung->end - (hour * 3600)) / 60;
+	      if (hour > 23)
+	      {
+		 hour = 23;
+		 min = 59;
+	      }
-	   sprintf(&hv0[0], "%d,%lu,%f\n",
+	      sprintf(&hv0[0], "%d,%02d:%02d,%.1f\n",
-		   act->heizung->wday, act->heizung->end,
+		   act->heizung->wday, hour, min,
 		   act->heizung->temp);
-	   write(fd, &hv0[0], strlen(hv0));
+	      write(fd, &hv0[0], strlen(hv0));
+	   }
 	   act = act->next;
+	}
 	close(fd);
 	return 1;
 	if ((p = strstr(str, search)) != NULL)
+	{
 	int len = strlen(search);
 	   strncpy(ret, str, p - str + len);
+	   ret[p - str + len] = 0;
-	   memmove(str, p + len + 1, strlen(p+len));
+	   memmove(str, p + len, strlen(p+len));
+	   str[strlen(p+len)] = 0;
 	   return ret;
+	}
 	return NULL;
+}

Subversion Repositories heizung

(root)/trunk/heizung.c – Rev 4 → 5