--- /dev/null
+/* YourDuino.com Example Software Sketch
+ DHT11 Humidity and Temperature Sensor test
+ Credits: Rob Tillaart
+ http://arduino-direct.com/sunshop/index.php?l=product_detail&p=162
+ terry@yourduino.com */
+
+/*-----( Import needed libraries )-----*/
+#include <dht11.h>
+#include <Wire.h>
+#include <BMP085.h>
+#include <WeatherSensorWH2.h>
+
+/*-----( Declare objects )-----*/
+dht11 DHT11;
+BMP085 bmp;
+
+/*-----( Declare Constants, Pin Numbers )-----*/
+#define DHT11PIN 4
+
+#define RF_IN 3
+
+#define REDPIN 11
+#define GREENPIN 12
+
+volatile byte got_interval = 0;
+volatile byte interval = 0;
+
+volatile unsigned long old = 0, packet_count = 0;
+volatile unsigned long spacing, now, average_interval;
+
+WeatherSensorWH2 weather;
+
+ISR(TIMER1_COMPA_vect)
+{
+ static byte count = 0;
+ static byte was_hi = 0;
+
+ if (digitalRead(RF_IN) == HIGH) {
+ count++;
+ was_hi = 1;
+ } else {
+ if (was_hi) {
+ was_hi = 0;
+ interval = count;
+ got_interval = 1;
+ count = 0;
+ }
+ }
+}
+
+void setup() /*----( SETUP: RUNS ONCE )----*/
+{
+ Serial.begin(9600);
+ Serial.println("STATUS:START");
+
+ bmp.begin();
+
+ pinMode(REDPIN,OUTPUT);
+ pinMode(GREENPIN,OUTPUT);
+
+ pinMode(RF_IN, INPUT);
+ TCCR1A = 0x00;
+ TCCR1B = 0x09;
+ TCCR1C = 0x00;
+ OCR1A = 399;
+ TIMSK1 = 0x02;
+ sei();
+
+}/*--(end setup )---*/
+
+unsigned long previousMillis = 0;
+unsigned long indoor_interval = 60000;
+unsigned long outdoor_interval = 45000;
+unsigned long previousIndoor = 0;
+unsigned long previousOutdoor = 0;
+
+void loop() /*----( LOOP: RUNS CONSTANTLY )----*/
+{
+
+ byte i;
+ byte *packet;
+
+ if (got_interval) {
+ weather.accept(interval);
+ if (weather.acquired()) {
+ now = millis();
+ spacing = now - old;
+ old = now;
+ packet_count++;
+ average_interval = now / packet_count;
+ /*
+ Serial.print("Spacing: ");
+ Serial.println(spacing, DEC);
+ Serial.print("Packet count: ");
+ Serial.println(packet_count, DEC);
+
+ Serial.print("Average spacing: ");
+ Serial.println(average_interval, DEC);
+
+
+ packet = weather.get_packet();
+ for(i=0;i<5;i++) {
+ Serial.print("0x");
+ Serial.print(packet[i], HEX);
+ Serial.print("/");
+ Serial.print(packet[i], DEC);
+ Serial.print(" ");
+ }
+
+ Serial.print("crc: ");
+ Serial.print(weather.calculate_crc(), HEX);
+ Serial.println((weather.valid() ? " OK" : " BAD"));
+
+ */
+
+ if (weather.valid()) {
+
+ Serial.print("SENSOR:TYPE=OUTDOOR,");
+
+ Serial.print("ID=");
+ Serial.print(weather.get_sensor_id(), HEX);
+
+ Serial.print(",HUMIDITY=");
+ Serial.print(weather.get_humidity(), DEC);
+
+ Serial.print(",TEMPERATURE=");
+ Serial.println(weather.get_temperature_formatted());
+
+ previousOutdoor = millis();
+ digitalWrite(REDPIN,HIGH);
+
+ } else {
+
+ Serial.println("ERROR:OUTDOOR");
+ previousOutdoor = millis();
+ digitalWrite(REDPIN,LOW);
+
+ }
+
+ }
+
+ got_interval = 0;
+
+ }
+
+
+ if ((unsigned long)(millis() - previousMillis) >= indoor_interval) {
+
+ previousMillis = millis();
+
+ int chk = DHT11.read(DHT11PIN);
+
+ if (chk==0) {
+
+ Serial.print("SENSOR:TYPE=INDOOR,");
+ Serial.print("HUMIDITY=");
+ Serial.println((float)DHT11.humidity, 2);
+
+// Serial.print(",TEMPERATURE=");
+// Serial.println((float)DHT11.temperature, 2);
+
+ Serial.print("SENSOR:TYPE=BARO,");
+ Serial.print("PRESSURE=");
+ Serial.print(bmp.readPressure());
+ Serial.print(",TEMPERATURE=");
+ Serial.println(bmp.readTemperature());
+
+ previousIndoor = millis();
+ digitalWrite(GREENPIN,HIGH);
+
+
+ } else {
+
+ Serial.println("ERROR:INDOOR");
+ previousIndoor = millis();
+ digitalWrite(GREENPIN,LOW);
+
+ }
+
+ }
+
+ if ((unsigned long)(millis() - previousIndoor) >= indoor_interval*10) {
+
+ Serial.println("ERROR:INDOOR TIMEOUT");
+ previousIndoor = millis();
+ digitalWrite(GREENPIN,LOW);
+
+ }
+
+ if ((unsigned long)(millis() - previousOutdoor) >= outdoor_interval*10) {
+
+ Serial.println("ERROR:OUTDOOR TIMEOUT");
+ previousOutdoor = millis();
+ digitalWrite(REDPIN,LOW);
+
+ }
+
+
+}/* --(end main loop )-- */
+
+/* ( THE END ) */
--- /dev/null
+-- MySQL dump 10.13 Distrib 5.5.35, for debian-linux-gnu (i686)
+--
+-- Host: estia Database: meteo
+-- ------------------------------------------------------
+-- Server version 5.5.35-0ubuntu0.13.10.2
+
+/*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */;
+/*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */;
+/*!40101 SET @OLD_COLLATION_CONNECTION=@@COLLATION_CONNECTION */;
+/*!40101 SET NAMES utf8 */;
+/*!40103 SET @OLD_TIME_ZONE=@@TIME_ZONE */;
+/*!40103 SET TIME_ZONE='+00:00' */;
+/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;
+/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;
+/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='NO_AUTO_VALUE_ON_ZERO' */;
+/*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */;
+
+--
+-- Table structure for table `sensor_types`
+--
+
+DROP TABLE IF EXISTS `sensor_types`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `sensor_types` (
+ `id` int(11) NOT NULL AUTO_INCREMENT,
+ `st_name` varchar(32) CHARACTER SET utf8 NOT NULL,
+ `st_description` varchar(255) CHARACTER SET utf8 DEFAULT NULL,
+ PRIMARY KEY (`id`),
+ UNIQUE KEY `st_name` (`st_name`)
+) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `sensor_values`
+--
+
+DROP TABLE IF EXISTS `sensor_values`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `sensor_values` (
+ `id` int(11) NOT NULL AUTO_INCREMENT,
+ `sensor_id` int(11) NOT NULL,
+ `timestamp` datetime NOT NULL,
+ `value` float NOT NULL,
+ `parameter_id` int(11) NOT NULL,
+ PRIMARY KEY (`id`),
+ KEY `fk_sensor_values_sens_idx` (`sensor_id`),
+ KEY `sensor_values_idx` (`sensor_id`,`timestamp`),
+ KEY `fk_sensor_values_param_idx` (`parameter_id`),
+ CONSTRAINT `fk_sensor_values_param` FOREIGN KEY (`parameter_id`) REFERENCES `st_parameters` (`id`) ON DELETE NO ACTION ON UPDATE NO ACTION,
+ CONSTRAINT `fk_sensor_values_sens` FOREIGN KEY (`sensor_id`) REFERENCES `sensors` (`id`) ON DELETE NO ACTION ON UPDATE NO ACTION
+) ENGINE=InnoDB AUTO_INCREMENT=223855 DEFAULT CHARSET=utf8;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `sensors`
+--
+
+DROP TABLE IF EXISTS `sensors`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `sensors` (
+ `id` int(11) NOT NULL AUTO_INCREMENT,
+ `st_id` int(11) NOT NULL,
+ `s_id` varchar(32) CHARACTER SET utf8 NOT NULL,
+ `s_description` varchar(255) CHARACTER SET utf8 DEFAULT NULL,
+ PRIMARY KEY (`id`),
+ UNIQUE KEY `UNIQUE` (`st_id`,`s_id`),
+ KEY `fk_sensors_st_idx` (`st_id`),
+ CONSTRAINT `fk_sensors_st` FOREIGN KEY (`st_id`) REFERENCES `sensor_types` (`id`) ON DELETE NO ACTION ON UPDATE NO ACTION
+) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `st_parameters`
+--
+
+DROP TABLE IF EXISTS `st_parameters`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `st_parameters` (
+ `id` int(11) NOT NULL AUTO_INCREMENT,
+ `st_id` int(11) NOT NULL,
+ `st_name` varchar(32) CHARACTER SET utf8 NOT NULL,
+ `st_unit` int(11) NOT NULL,
+ `st_description` varchar(255) CHARACTER SET utf8 DEFAULT NULL,
+ `st_dot_color` varchar(45) DEFAULT 'red',
+ `st_fill_color_top` varchar(45) DEFAULT 'red',
+ `st_fill_color_bottom` varchar(45) DEFAULT 'blue',
+ `st_line_color` varchar(45) DEFAULT 'navy',
+ PRIMARY KEY (`id`),
+ UNIQUE KEY `unique` (`st_id`,`st_name`),
+ KEY `fk_st_parameters_st_idx` (`st_id`),
+ KEY `fk_st_parameters_units_idx` (`st_unit`),
+ CONSTRAINT `fk_st_parameters_st` FOREIGN KEY (`st_id`) REFERENCES `sensor_types` (`id`) ON DELETE NO ACTION ON UPDATE NO ACTION,
+ CONSTRAINT `fk_st_parameters_units` FOREIGN KEY (`st_unit`) REFERENCES `units` (`id`) ON DELETE NO ACTION ON UPDATE NO ACTION
+) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `unit_conv`
+--
+
+DROP TABLE IF EXISTS `unit_conv`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `unit_conv` (
+ `id` int(11) NOT NULL AUTO_INCREMENT,
+ `from_unit` int(11) NOT NULL,
+ `to_unit` int(11) NOT NULL,
+ `a` float NOT NULL,
+ `b` float NOT NULL,
+ `c` float NOT NULL,
+ PRIMARY KEY (`id`)
+) ENGINE=InnoDB AUTO_INCREMENT=15 DEFAULT CHARSET=utf8;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `unit_groups`
+--
+
+DROP TABLE IF EXISTS `unit_groups`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `unit_groups` (
+ `id` int(11) NOT NULL AUTO_INCREMENT,
+ `name` varchar(45) NOT NULL,
+ PRIMARY KEY (`id`)
+) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `units`
+--
+
+DROP TABLE IF EXISTS `units`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `units` (
+ `id` int(11) NOT NULL AUTO_INCREMENT,
+ `name` varchar(32) CHARACTER SET utf8 NOT NULL,
+ `name_short` varchar(8) CHARACTER SET utf8 NOT NULL,
+ `unit_group` int(11) NOT NULL,
+ PRIMARY KEY (`id`),
+ KEY `fk_units_group_idx` (`unit_group`),
+ CONSTRAINT `fk_units_group` FOREIGN KEY (`unit_group`) REFERENCES `unit_groups` (`id`) ON DELETE NO ACTION ON UPDATE NO ACTION
+) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+/*!40103 SET TIME_ZONE=@OLD_TIME_ZONE */;
+
+/*!40101 SET SQL_MODE=@OLD_SQL_MODE */;
+/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;
+/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;
+/*!40101 SET CHARACTER_SET_CLIENT=@OLD_CHARACTER_SET_CLIENT */;
+/*!40101 SET CHARACTER_SET_RESULTS=@OLD_CHARACTER_SET_RESULTS */;
+/*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */;
+/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;
+
+-- Dump completed on 2014-03-17 20:17:36
--- /dev/null
+#!/usr/bin/python
+
+import serial
+
+from os import listdir
+from os.path import isfile, join
+
+from termios import tcflush, TCIOFLUSH
+
+from time import sleep,time
+
+from uuid import getnode
+
+from hashlib import md5
+
+import socket
+
+import sys,traceback
+
+import pycurl
+from urllib import urlencode
+from StringIO import StringIO
+
+searchpath = '/dev/serial/by-id/'
+baud = 9600
+timeout = 5
+
+external_submit_interval = 320
+expire_interval = 1200
+submit_time = time()
+submit_queue = {}
+
+import MySQLdb
+import ConfigParser
+
+def find_port():
+
+ global serial_num
+
+ files = listdir(searchpath)
+ for f in files:
+ if serialnum in f:
+ return join(searchpath,f)
+ return None
+
+def open_port(path):
+
+ ser = serial.Serial(path,baud,timeout)
+ if ser.portstr:
+ tcflush(ser,TCIOFLUSH);
+ return ser
+
+def read_port(ser):
+
+ line = ser.readline()
+ return line.strip()
+
+def read_loop(ser,callback):
+
+ while True:
+
+ try:
+ line=read_port(ser)
+ if line:
+ callback(line)
+ except KeyboardInterrupt:
+ break
+ finally:
+ None
+
+def submit_narodmon(queue):
+
+ param = { 'ID':"{:X}".format(getnode())}
+
+ for sensor in queue:
+ value = submit_queue[sensor]['val']
+ timestamp = submit_queue[sensor]['timestamp']
+ digest = md5(sensor).hexdigest()[:18]
+ param[digest] = value;
+
+ print param
+
+ url = "http://narodmon.ru/post.php"
+
+ try:
+
+ response_buffer = StringIO()
+ curl = pycurl.Curl()
+
+ curl.setopt(curl.URL, url)
+ curl.setopt(curl.WRITEFUNCTION, response_buffer.write)
+ curl.setopt(curl.POST, 1)
+ curl.setopt(curl.POSTFIELDS, urlencode(param))
+
+ curl.perform()
+ curl.close()
+
+ response_value = response_buffer.getvalue()
+
+ print 'Content: ', response_value
+
+ return True
+
+ except:
+
+ exc_type, exc_value, exc_traceback = sys.exc_info()
+ traceback.print_tb(exc_traceback, limit=1, file=sys.stdout)
+ traceback.print_exception(exc_type, exc_value, exc_traceback,
+ limit=2, file=sys.stdout)
+ return False
+
+def submit_owm(queue):
+
+ url = "http://openweathermap.org/data/post"
+ params = {'name':owm_station, 'lat':owm_lat, 'long':owm_lon}
+
+ try:
+
+ try:
+ params['temp'] = queue[owm_temp]['val']
+ params['pressure'] = queue[owm_pres]['val']
+ params['humidity'] = queue[owm_humi]['val']
+ except:
+ return False
+
+ response_buffer = StringIO()
+ curl = pycurl.Curl()
+
+ curl.setopt(curl.URL, url)
+ curl.setopt(curl.USERPWD, '%s:%s' % (owmuser, owmpasswd))
+ curl.setopt(curl.WRITEFUNCTION, response_buffer.write)
+ curl.setopt(curl.POST, 1)
+ curl.setopt(curl.POSTFIELDS, urlencode(params))
+
+ curl.perform()
+ curl.close()
+
+ response_value = response_buffer.getvalue()
+
+ print 'Content: ', response_value
+
+ return True
+
+ except:
+
+ exc_type, exc_value, exc_traceback = sys.exc_info()
+ traceback.print_tb(exc_traceback, limit=1, file=sys.stdout)
+ traceback.print_exception(exc_type, exc_value, exc_traceback,
+ limit=2, file=sys.stdout)
+ return False
+
+def purge_queue():
+ global submit_queue
+ clean = []
+ for key in submit_queue:
+ if submit_queue[key]['timestamp'] < time()-expire_interval:
+ print "Expired value for "+key
+ clean.append(key)
+ for i in clean:
+ del submit_queue[i]
+
+def submit_data(sensor_type,sensor_id,sensor_param,param_value):
+ global submit_time
+ global submit_queue
+ c = database.cursor()
+ c.execute('CALL meteo.submit_value(%s,%s,%s,%s)', (sensor_type,sensor_id,sensor_param,param_value))
+ database.commit()
+ submit_queue[sensor_type+'.'+sensor_id+'.'+sensor_param]={'val':param_value,'timestamp':time()}
+ if time()>submit_time+external_submit_interval:
+ if submit_narodmon(submit_queue):
+ if owmuser:
+ submit_owm(submit_queue)
+ print 'Purging queue...'
+ submit_time=time()
+ purge_queue()
+
+
+def process_str(str):
+ try:
+ msg_type, msg_body = str.split(':')
+ if msg_type == 'STATUS':
+ print 'Status: ', msg_body
+ elif msg_type == 'ERROR':
+ print 'Error: ', msg_body
+ elif msg_type == 'SENSOR':
+ sens = msg_body.split(',')
+ sensor = {}
+ sensor_type = None
+ sensor_id = None
+ for rec in sens:
+ key,value = rec.split('=')
+ if key == 'TYPE':
+ sensor_type = value
+ elif key == 'ID':
+ sensor_id = value
+ else:
+ sensor[key] = value
+ if sensor_type:
+ if not sensor_id:
+ sensor_id='DEFAULT';
+ for key in sensor:
+ print 'Type = ', sensor_type, ', ID = ', sensor_id, ', Param = ', key, ', Value = ', sensor[key]
+ submit_data(sensor_type,sensor_id,key,sensor[key])
+ except:
+ print 'Exception processing...'
+ try:
+ database.close()
+ except:
+ None
+ reconnect()
+
+def print_str(str):
+ print str
+
+def weather_mon():
+
+ path = find_port()
+ ser = open_port(path)
+ read_loop(ser,process_str)
+
+def reconnect():
+
+ try:
+
+ global database
+ database = MySQLdb.connect(host=dbhost,user=dbuser,passwd=dbpasswd,use_unicode=True,connect_timeout=10)
+ database.set_character_set('utf8')
+ c = database.cursor()
+ c.execute('SET NAMES utf8;')
+ print "Database connected..."
+
+ except:
+
+ print "Error connecting database"
+ sleep(30)
+
+def main():
+ weather_mon()
+
+try:
+
+ cfg = ConfigParser.RawConfigParser(allow_no_value=True)
+ cfg.readfp(open('/etc/weathermon.conf'))
+ dbhost = cfg.get("mysql","host")
+ dbuser = cfg.get("mysql","user")
+ dbpasswd = cfg.get("mysql","passwd")
+ serialnum = cfg.get("serial","id")
+ owmuser = cfg.get("openweathermap","user")
+ owmpasswd = cfg.get("openweathermap",'passwd')
+ if owmuser:
+ owm_temp = cfg.get("openweathermap",'temp')
+ owm_pres = cfg.get("openweathermap",'pres')
+ owm_humi = cfg.get("openweathermap",'humi')
+ owm_lat = cfg.get("openweathermap",'lat')
+ owm_lon = cfg.get("openweathermap",'lon')
+ owm_station = cfg.get("openweathermap",'station')
+ reconnect()
+
+except:
+
+ print "Cannot intialize system"
+ exit()
+
+if __name__ == "__main__":
+ import sys
+ reload(sys)
+ sys.setdefaultencoding('utf-8')
+ main()
--- /dev/null
+<!doctype html public "-//w3c//dtd html 4.0 transitional//en">
+<html>
+<head>
+ <meta http-equiv="Content-Type" content="text/html; charset=utf-8">
+ <meta name="GENERATOR" content="Mozilla/4.72 [cp1251] (X11; U; Linux 2.2.12-20smp i686) [Netscape]">
+ <title>WeatherMon (архив)</title>
+ <link rel="icon" href="favicon.png" />
+</head>
+<body text="black" bgcolor="silver" link="blue" vlink="#000080" alink="#FF0000">
+<?php
+
+include('config_local.php');
+include('calendar.php');
+
+$year = $_REQUEST['year'];
+$month = $_REQUEST['month'];
+$day = $_REQUEST['day'];
+
+if (! ($db = new PDO("mysql:host=$mysql_host;port=$mysql_port;dbname=$mysql_schema",$mysql_user,$mysql_pwd,array( PDO::ATTR_PERSISTENT => false)))) {
+ die($err);
+ }
+
+$db -> exec('SET CHARACTER SET utf8');
+
+if (! $year) {
+
+ $q = $db -> prepare(
+ 'select
+ date_format(timestamp,\'%Y\') as year
+ from
+ sensor_values
+ group by year
+ order by year');
+ $q -> execute();
+?>
+<h1>Архив метеоданных</h1>
+<?php
+ while ($row = $q -> fetch(PDO::FETCH_ASSOC)) {
+?>
+ <a href="?year=<?php echo $row['year']; ?>">Данные за <?php echo $row['year']; ?> год</a><br>
+<?php
+ }
+
+} else {
+
+ if (! $month) {
+
+ $next_year = $year+1;
+ $year = sprintf('%04d',$year);
+ $next_year = sprintf('%04d',$next_year);
+ $q = $db -> prepare(
+ 'select
+ date_format(timestamp,\'%m\') as month,
+ date_format(timestamp,\'%d\') as day
+ from
+ sensor_values
+ where
+ timestamp>=str_to_date(\''.$year.'-01-01\',\'%Y-%m-%d\') and
+ timestamp<str_to_date(\''.$next_year.'-01-01\',\'%Y-%m-%d\')
+ group by month,day
+ order by month,day'
+ );
+ $q -> execute();
+?>
+<h1 align="center"><?php echo $year; ?> год</h1>
+<?php
+ $data = $q -> fetchAll(PDO::FETCH_ASSOC);
+ $months = [];
+ foreach ($data as $row) {
+ $days [$year.$row['month'].$row['day']] = '&month='.$row['month'].'&day='.$row['day'];
+ $months[$row['month']]=1;
+ }
+ $m = 1;
+ echo '<table align="center">';
+ for ($i=1; $i<=3; $i++) {
+ echo '<tr>';
+ for ($j=1; $j<=4; $j++) {
+ echo '<td valign="top">';
+ $month=sprintf('%02d',$m);
+ $month_name = strftime('%B',mktime(0,0,0,$month,1,$year));
+ if (!empty($months[$month])) {
+ echo '<h3 align="center"><a href="?year='.$year.'&month='.$month.'">'.$month_name.'</a></h3>';
+ } else {
+ echo '<h3 align="center">'.$month_name.'</h3>';
+ }
+ calendar($year,$month,$days,'?year='.$year.'%s',0);
+ echo '</td>';
+ $m++;
+ }
+ echo '</tr>';
+ }
+ echo '</table>';
+
+ $next_year = $year+1;
+
+ $q = $db -> prepare (
+ 'select
+ s.id sensor,p.id param,s.s_description sensor_name,p.st_description param_name,
+ count(distinct date_format(v.timestamp,\'%d\')) cnt,
+ round(min(v.value),1) min_value,
+ round(max(v.value),1) max_value,
+ u.name_short unit
+ from
+ sensor_values v,sensors s,st_parameters p,units u
+ where
+ v.sensor_id=s.id and
+ v.parameter_id=p.id and
+ p.st_unit=u.id and
+ v.timestamp>=str_to_date(\''.$year.'-01-01\',\'%Y-%m-%d\') and
+ v.timestamp<str_to_date(\''.$next_year.'-01-01\',\'%Y-%m-%d\')
+ group by s.id,p.id,s.s_description,p.st_description
+ order by s.id,p.id'
+ );
+
+ $q -> execute();
+ $sensors = $q -> fetchAll(PDO::FETCH_ASSOC);
+
+ foreach ($sensors as $sensor) {
+
+ echo '<h3 align="center">'.$sensor['param_name'].'('.$sensor['sensor_name'].')</h3>';
+ echo '<table align="center">';
+ echo '<tr><td>';
+ echo 'Минимальное значение за год <b>'.$sensor['min_value'].' '.$sensor['unit'].'</b><br>';
+ echo 'Максимальное значение за год <b>'.$sensor['max_value'].' '.$sensor['unit'].'</b><br>';
+ echo '</td></tr>';
+ echo '</table>';
+
+ if ($sensor['cnt']>1) {
+
+ echo '<center><img src="image_minmax.php?sensor='.$sensor['sensor'].'¶m='.$sensor['param'].
+ '&type=year&year='.$year.'"></center>';
+
+ }
+
+ }
+
+
+ } else {
+
+ if (!$day) {
+
+ $next_year = $year;
+ $next_month = $month+1;
+
+ if ($next_month == 13) {
+ $next_month = 1;
+ $next_year = $next_year+1;
+ }
+
+ $next_month = sprintf('%02d',$next_month);
+ $next_year = sprintf('%04d',$next_year);
+ $month = sprintf('%02d',$month);
+ $year = sprintf('%04d',$year);
+
+ $q = $db -> prepare(
+ 'select
+ date_format(timestamp,\'%d\') as day
+ from
+ sensor_values
+ where
+ timestamp>=str_to_date(\''.$year.'-'.$month.'-01\',\'%Y-%m-%d\') and
+ timestamp<str_to_date(\''.$next_year.'-'.$next_month.'-01\',\'%Y-%m-%d\')
+ group by day
+ order by day'
+ );
+ $q -> execute();
+
+ $data = $q -> fetchAll(PDO::FETCH_ASSOC);
+
+ $month_name = strftime('%B %Y',mktime(0,0,0,$month,1,$year));
+
+?>
+<h1 align="center"><?php echo 'Данные за '.$month_name; ?></h1>
+<?php
+ foreach ($data as $row) {
+ $days [$year.$month.$row['day']] = $row['day'];
+ }
+
+ calendar($year,$month,$days,'?year='.$year.'&month='.$month.'&day=%s',3);
+
+ $q = $db -> prepare (
+ 'select
+ s.id sensor,p.id param,s.s_description sensor_name,p.st_description param_name,
+ count(distinct date_format(v.timestamp,\'%d\')) cnt,
+ round(min(v.value),1) min_value,
+ round(max(v.value),1) max_value,
+ u.name_short unit
+ from
+ sensor_values v,sensors s,st_parameters p,units u
+ where
+ v.sensor_id=s.id and
+ v.parameter_id=p.id and
+ p.st_unit=u.id and
+ v.timestamp>=str_to_date(\''.$year.'-'.$month.'-01\',\'%Y-%m-%d\') and
+ v.timestamp<str_to_date(\''.$next_year.'-'.$next_month.'-01\',\'%Y-%m-%d\')
+ group by s.id,p.id,s.s_description,p.st_description
+ order by s.id,p.id'
+ );
+
+ $q -> execute();
+ $sensors = $q -> fetchAll(PDO::FETCH_ASSOC);
+
+ foreach ($sensors as $sensor) {
+
+ echo '<h3 align="center">'.$sensor['param_name'].'('.$sensor['sensor_name'].')</h3>';
+ echo '<table align="center">';
+ echo '<tr><td>';
+ echo 'Минимальное значение за месяц <b>'.$sensor['min_value'].' '.$sensor['unit'].'</b><br>';
+ echo 'Максимальное значение за месяц <b>'.$sensor['max_value'].' '.$sensor['unit'].'</b><br>';
+ echo '</td></tr>';
+ echo '</table>';
+
+ if ($sensor['cnt']>1) {
+
+ echo '<center><img src="image_minmax.php?sensor='.$sensor['sensor'].'¶m='.$sensor['param'].
+ '&type=month&year='.$year.'&month='.$month.'"></center>';
+
+ }
+
+ }
+
+ } else {
+
+ $month = sprintf('%02d',$month);
+ $year = sprintf('%04d',$year);
+ $day = sprintf('%02d',$day);
+
+ $q = $db -> prepare(
+ 'select
+ distinct v.sensor_id,s.s_description,p.id as param_id,p.st_description
+ from
+ sensor_values v,st_parameters p,sensors s
+ where
+ v.timestamp>=str_to_date(\''.$year.'-'.$month.'-'.$day.'\',\'%Y-%m-%d\') and
+ v.timestamp<date_add(str_to_date(\''.$year.'-'.$month.'-'.$day.'\',\'%Y-%m-%d\'),interval 1 day)
+ and v.sensor_id=s.id
+ and s.st_id=p.st_id'
+ );
+ $q -> execute();
+
+ while ($row = $q -> fetch(PDO::FETCH_ASSOC)) {
+
+ echo '<h3 align="center">'.$row['s_description'].'/'.$row['st_description'].'</h3>';
+?>
+<center><img src="image.php?sensor=<?php echo $row['sensor_id']; ?>¶m=<?php echo $row['param_id']?>&type=range&fromdate=<?php echo $year.$month.$day.'000000'; ?>&todate=<?php echo $year.$month.$day.'235959'?>"></center>
+<?php
+
+ }
+ }
+ }
+}
+?>
+</body>
+
\ No newline at end of file
--- /dev/null
+<?php
+
+function calendar($year,$month, $days, $ref_template, $font_size) {
+
+ $firstday = mktime(0,0,0,$month,1,$year);
+ $dayofmonth = date('t',$firstday);
+
+ $day_count = 1;
+
+ $num = 0;
+
+ for($i = 0; $i < 7; $i++) {
+
+ $dayofweek = date('w', mktime(0, 0, 0, $month, $day_count, $year));
+ $dayofweek = $dayofweek - 1;
+ if($dayofweek == -1) $dayofweek = 6;
+
+ if($dayofweek == $i) {
+
+ $week[$num][$i] = $day_count;
+ $day_count++;
+
+ } else {
+
+ $week[$num][$i] = "";
+
+ }
+ }
+
+
+ while(true) {
+
+ $num++;
+
+ for($i = 0; $i < 7; $i++) {
+
+ $week[$num][$i] = $day_count;
+ $day_count++;
+
+ if($day_count > $dayofmonth) break;
+
+ }
+
+ if($day_count > $dayofmonth) break;
+
+ }
+
+ echo '<table align="center" border=1>';
+
+ for($i = 0; $i < count($week); $i++) {
+
+ echo '<tr>';
+
+ for($j = 0; $j < 7; $j++) {
+
+ if(!empty($week[$i][$j])) {
+ $str = $week[$i][$j];
+ $fstr='<font size="+'.$font_size.'">'.$str.'</font>';
+ if (!empty($days[$year.$month.sprintf('%02d',$str)])) {
+ $href=sprintf($ref_template,$days[$year.$month.sprintf('%02d',$str)]);
+ if($j == 5 || $j == 6) {
+ echo '<td align="right" bgcolor="mediumaquamarine"><a href='.$href.'><font color=red>'.$fstr.'</font></a></td>';
+ } else {
+ echo '<td align="right" bgcolor="mediumaquamarine"><a href='.$href.'>'.$fstr.'</a></td>';
+ }
+ } else {
+ if($j == 5 || $j == 6) {
+ echo '<td align="right"><font color=red>'.$fstr.'</font></td>';
+ } else {
+ echo '<td align="right">'.$fstr.'</td>';
+ }
+ }
+ }
+
+ else echo '<td> </td>';
+
+ }
+
+ echo '</tr>';
+
+ }
+
+ echo '</table>';
+
+}
+
+?>
\ No newline at end of file
--- /dev/null
+<?php
+
+ $mysql_host = 'hostname';
+ $mysql_schema = 'meteo';
+ $mysql_user = 'meteo';
+ $mysql_pwd = '***';
+ $mysql_port = 3306;
+
+ setlocale(LC_ALL,'ru_RU.UTF8');
+
+?>
+
\ No newline at end of file
--- /dev/null
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<!-- Created with Inkscape (http://www.inkscape.org/) -->
+<svg id="svg3187" xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#" xmlns="http://www.w3.org/2000/svg" height="16" width="16" version="1.0" xmlns:cc="http://creativecommons.org/ns#" xmlns:dc="http://purl.org/dc/elements/1.1/">
+ <metadata id="metadata8">
+ <rdf:RDF>
+ <cc:Work rdf:about="">
+ <dc:format>image/svg+xml</dc:format>
+ <dc:type rdf:resource="http://purl.org/dc/dcmitype/StillImage"/>
+ <dc:title/>
+ </cc:Work>
+ </rdf:RDF>
+ </metadata>
+ <path id="path2397-5" style="opacity:.3;fill-rule:evenodd;fill:#fff" d="m9 2c-1.1263 0-2.0808 0.5938-2.5938 1.4688-0.2888-0.206-0.6576-0.3126-1.0624-0.3126-0.92-1e-7 -1.6875 0.61768-1.6875 1.4062 1e-7 0.1771 0.056173 0.34346 0.125 0.5-1.0464 0.4008-1.7813 1.326-1.7813 2.3751 0 1.1271 0.8584 2.0573 2.0312 2.4063-0.0158-0.1138-0.0312-0.2256-0.0312-0.3438 0-1.3807 1.1193-2.5 2.5-2.5s2.5 1.1193 2.5 2.5c0 0.1726-0.0292 0.3373-0.0625 0.5h2.0625c1.662 0 3-1.1379 3-2.5625 0-1.1284-0.856-2.0895-2.031-2.4375 0.002-0.0488 0.031-0.1068 0.031-0.1562 0-1.5772-1.344-2.8438-3-2.8438zm-1 10.5c0 0.82843 0.67157 1.5 1.5 1.5s1.5-0.67157 1.5-1.5-0.67157-1.5-1.5-1.5-1.5 0.67157-1.5 1.5zm-3-3c0 0.828 0.6716 1.5 1.5 1.5s1.5-0.672 1.5-1.5c0-0.8284-0.6716-1.5-1.5-1.5s-1.5 0.6716-1.5 1.5zm-1 5c0 0.828 0.6716 1.5 1.5 1.5s1.5-0.672 1.5-1.5-0.6716-1.5-1.5-1.5-1.5 0.672-1.5 1.5z"/>
+ <path id="path2397" style="fill-rule:evenodd;fill:#3c3c3c" d="m9 1c-1.1263 0-2.0808 0.59376-2.5938 1.4688-0.28885-0.20595-0.6577-0.3125-1.0625-0.3125-0.92-1e-7 -1.6875 0.61768-1.6875 1.4062 1e-7 0.1771 0.056173 0.34346 0.125 0.5-1.0463 0.4007-1.7812 1.3259-1.7812 2.375 0 1.1271 0.8584 2.0573 2.0312 2.4063-0.0158-0.1138-0.0312-0.2256-0.0312-0.3438 0-1.3807 1.1193-2.5 2.5-2.5s2.5 1.1193 2.5 2.5c0 0.1726-0.0292 0.3373-0.0625 0.5h2.0625c1.662 0 3-1.1379 3-2.5625 0-1.1284-0.856-2.0895-2.031-2.4375 0.002-0.0488 0.031-0.1068 0.031-0.1562 0-1.5772-1.344-2.8438-3-2.8438zm-1 10.5c0 0.82843 0.67157 1.5 1.5 1.5s1.5-0.67157 1.5-1.5-0.67157-1.5-1.5-1.5-1.5 0.67157-1.5 1.5zm-3-3c0 0.8284 0.6716 1.5 1.5 1.5s1.5-0.6716 1.5-1.5-0.6716-1.5-1.5-1.5-1.5 0.6716-1.5 1.5zm-1 5c0 0.828 0.6716 1.5 1.5 1.5s1.5-0.672 1.5-1.5-0.6716-1.5-1.5-1.5-1.5 0.672-1.5 1.5z"/>
+</svg>
--- /dev/null
+<?php // content="text/plain; charset=utf-8"
+
+error_reporting(E_ALL & ~E_STRICT & ~E_NOTICE);
+
+include ('config_local.php');
+
+require_once ('jpgraph/jpgraph.php');
+require_once ('jpgraph/jpgraph_line.php');
+require_once ('jpgraph/jpgraph_date.php');
+require_once ('jpgraph/jpgraph_scatter.php');
+require_once ('jpgraph/jpgraph_regstat.php');
+
+if (! ($db = new PDO("mysql:host=$mysql_host;port=$mysql_port;dbname=$mysql_schema",$mysql_user,$mysql_pwd,array( PDO::ATTR_PERSISTENT => false)))) {
+
+ die('Не могу подключиться к БД');
+
+}
+
+$db -> exec('SET CHARACTER SET utf8');
+
+$type = $_REQUEST['type'];
+$sensor=$_REQUEST['sensor'];
+$param=$_REQUEST['param'];
+
+if ($type and $param) {
+
+ $sensor = intval($sensor);
+ $param = intval($param);
+
+ $q = $db -> prepare(
+ 'select s_description from sensors where id='.$sensor
+ );
+ $q -> execute();
+
+ while ($row = $q -> fetch(PDO::FETCH_ASSOC)) {
+ $sensor_name = $row['s_description'];
+ }
+
+ $q = $db -> prepare(
+ 'select st.st_dot_color,st.st_line_color,st.st_description,u.id,u.unit_group from st_parameters st,units u where st.id='.$param.' and st.st_unit=u.id'
+ );
+ $q -> execute();
+
+ while ($row = $q -> fetch(PDO::FETCH_ASSOC)) {
+ $param_name = $row['st_description'];
+ $from_unit = $row['id'];
+ $unit_group = $row['unit_group'];
+ $dot_color = $row['st_dot_color'];
+ $line_color = $row['st_line_color'];
+ }
+
+ if (!empty($_COOKIE['unit_'.$unit_group])) {
+ $to_unit=intval($_COOKIE['unit_'.$unit_group]);
+ } else {
+ $to_unit=$from_unit;
+ }
+
+ $q = $db -> prepare(
+ 'select u.name_short from units u where u.id='.$to_unit
+ );
+ $q -> execute();
+
+ while ($row = $q -> fetch(PDO::FETCH_ASSOC)) {
+ $param_unit = $row['name_short'];
+ }
+
+ $xdata = array();
+ $ydata = array();
+
+ if ($type == 'last24') {
+
+ $q = $db -> prepare(
+ 'select unix_timestamp(timestamp) as x,unitconv(value,'.$from_unit.','.$to_unit.') as y from sensor_values where timestamp>adddate(now(), -1) and sensor_id='.$sensor.' and parameter_id='.$param.' order by timestamp'
+ );
+
+ $height = 130;
+
+ } elseif ($type == 'range') {
+
+ $from = intval($_REQUEST['fromdate']);
+ $to = intval($_REQUEST['todate']);
+
+ $q = $db -> prepare(
+ 'select unix_timestamp(timestamp) as x,unitconv(value,'.$from_unit.','.$to_unit.') as y from sensor_values where timestamp>=str_to_date("'.$from.'","%Y%m%d%H%i%s") and timestamp<=str_to_date("'.$to.'","%Y%m%d%H%i%s") and sensor_id='.$sensor.' and parameter_id='.$param.' order by timestamp'
+ );
+
+ $height = 60;
+
+ }
+
+ $q -> execute();
+
+ while ($row = $q -> fetch(PDO::FETCH_ASSOC)) {
+
+ $xdata[] = $row['x'];
+ $ydata[] = $row['y'];
+
+ }
+
+
+ for ($i = 0; $i < count($xdata); ++$i) {
+
+ $total_weight=0;
+ $sum=0;
+ $maxdelta = 900;
+
+ for ($j = $i; $j < count($xdata); ++$j) {
+
+ $delta = abs($xdata[$i]-$xdata[$j]);
+ if ($delta > $maxdelta) { break; }
+
+ $weight = 1-$delta/$maxdelta;
+ $total_weight += $weight;
+ $sum += $weight*$ydata[$j];
+
+ }
+
+ for ($j = $i-1; $j >=0 ; --$j) {
+
+ $delta = abs($xdata[$i]-$xdata[$j]);
+ if ($delta > $maxdelta) { break; }
+
+ $weight = 1-$delta/$maxdelta;
+ $total_weight += $weight;
+ $sum += $weight*$ydata[$j];
+
+ }
+
+ $new_val = $sum/$total_weight;
+ $f_ydata[$i] = $new_val;
+
+ }
+
+ // Create the graph
+ $g = new Graph(640,480);
+ $g->graph_theme = null;
+
+ //$g->img->SetAntiAliasing();
+
+ // We need a linlin scale since we provide both
+ // x and y coordinates for the data points.
+ $g->SetScale('datlin');
+ $g->xaxis->SetLabelAngle(90);
+ $g->xaxis->SetPos("min");
+
+ // We use a scatterplot to illustrate the original
+ // contro points.
+ $splot = new ScatterPlot($ydata,$xdata);
+ $g->Add($splot);
+
+ //
+ $splot->mark->SetFillColor($dot_color);
+ $splot->mark->SetColor($dot_color);
+ $splot->mark->SetType(MARK_FILLEDCIRCLE);
+ $splot->mark->SetSize(2);
+
+ $fplot = new LinePlot($f_ydata,$xdata);
+ $g->Add($fplot);
+ $fplot->SetColor($line_color);
+ $fplot->SetWeight(2);
+
+ $g->SetMargin(50,30,40,$height);
+ $g->title->Set($sensor_name.'/'.$param_name.', '.$param_unit);
+ $g->title->SetFont(FF_DV_SANSSERIF,FS_BOLD,12);
+ $g->SetMarginColor('silver');
+
+ // Add the plots to the graph and stroke
+ $g->Stroke();
+
+} else {
+
+ header("Content-Type: text/html; charset=UTF-8");
+ die('Сенсор не выбран!');
+
+}
+
+?>
\ No newline at end of file
--- /dev/null
+<?php // content="text/plain; charset=utf-8"
+
+error_reporting(E_ALL & ~E_STRICT & ~E_NOTICE);
+
+include ('config_local.php');
+
+require_once ('jpgraph/jpgraph.php');
+require_once ('jpgraph/jpgraph_line.php');
+require_once ('jpgraph/jpgraph_date.php');
+require_once ('jpgraph/jpgraph_scatter.php');
+require_once ('jpgraph/jpgraph_regstat.php');
+
+if (! ($db = new PDO("mysql:host=$mysql_host;port=$mysql_port;dbname=$mysql_schema",$mysql_user,$mysql_pwd,array( PDO::ATTR_PERSISTENT => false)))) {
+
+ die('Не могу подключиться к БД');
+
+}
+
+$db -> exec('SET CHARACTER SET utf8');
+
+$type = $_REQUEST['type'];
+$sensor=$_REQUEST['sensor'];
+$param=$_REQUEST['param'];
+$year=$_REQUEST['year'];
+$month=$_REQUEST['month'];
+
+if ($type and $param) {
+
+ $sensor = intval($sensor);
+ $param = intval($param);
+
+ $q = $db -> prepare(
+ 'select s_description from sensors where id='.$sensor
+ );
+ $q -> execute();
+
+ while ($row = $q -> fetch(PDO::FETCH_ASSOC)) {
+ $sensor_name = $row['s_description'];
+ }
+
+ $q = $db -> prepare(
+ 'select st.st_fill_color_top,st.st_fill_color_bottom,st.st_description,u.id,u.unit_group from st_parameters st,units u where st.id='.$param.' and st.st_unit=u.id
+'
+ );
+ $q -> execute();
+
+ while ($row = $q -> fetch(PDO::FETCH_ASSOC)) {
+ $param_name = $row['st_description'];
+ $from_unit = $row['id'];
+ $unit_group = $row['unit_group'];
+ $fill_color_top=$row['st_fill_color_top'];
+ $fill_color_bottom=$row['st_fill_color_bottom'];
+ }
+
+ if (!empty($_COOKIE['unit_'.$unit_group])) {
+ $to_unit=intval($_COOKIE['unit_'.$unit_group]);
+ } else {
+ $to_unit=$from_unit;
+ }
+
+ $q = $db -> prepare(
+ 'select u.name_short from units u where u.id='.$to_unit
+ );
+ $q -> execute();
+
+ while ($row = $q -> fetch(PDO::FETCH_ASSOC)) {
+ $param_unit = $row['name_short'];
+ }
+
+ $xdata = array();
+ $ydata = array();
+
+ if ($type == 'month') {
+
+ $next_year = $year;
+ $next_month = $month+1;
+
+ if ($month==13) {
+
+ $next_year++;
+ $month=1;
+
+ }
+
+ $q = $db -> prepare(
+ '
+ select
+ x,
+ unitconv(min(value),'.$from_unit.','.$to_unit.') min_value,
+ unitconv(max(value),'.$from_unit.','.$to_unit.') max_value
+ from (
+ select
+ unix_timestamp(cast(timestamp as date)) x,
+ value
+ from
+ sensor_values
+ where
+ timestamp>=str_to_date(\''.$year.$month.'\',\'%Y%m\')
+ and timestamp<str_to_date(\''.$next_year.$next_month.'\',\'%Y%m\')
+ and sensor_id='.$sensor.'
+ and parameter_id='.$param.'
+ ) t group by x
+ order by x'
+ );
+
+ } elseif ($type == "year") {
+
+ $next_year = $year+1;
+
+ $q = $db -> prepare(
+ '
+ select
+ x,
+ unitconv(min(value),'.$from_unit.','.$to_unit.') min_value,
+ unitconv(max(value),'.$from_unit.','.$to_unit.') max_value
+ from (
+ select
+ unix_timestamp(
+ DATE_SUB(cast(timestamp as date), INTERVAL DAYOFWEEK(cast(timestamp as date))-1 DAY)
+ ) x,
+ value
+ from
+ sensor_values
+ where
+ timestamp>=str_to_date(\''.$year.'\',\'%Y\')
+ and timestamp<str_to_date(\''.$next_year.'\',\'%Y\')
+ and sensor_id='.$sensor.'
+ and parameter_id='.$param.'
+ ) t group by x
+ order by x'
+ );
+
+ }
+
+ $q -> execute();
+
+ while ($row = $q -> fetch(PDO::FETCH_ASSOC)) {
+
+ $xdata[] = $row['x'];
+ $mindata[] = $row['min_value'];
+ $maxdata[] = $row['max_value'];
+
+ }
+
+
+ // Create the graph
+ $g = new Graph(640,480);
+ $g->graph_theme = null;
+
+ //$g->img->SetAntiAliasing();
+
+ // We need a linlin scale since we provide both
+ // x and y coordinates for the data points.
+ $g->SetScale('datlin');
+ $g->xaxis->SetLabelAngle(90);
+ $g->xaxis->SetPos("min");
+
+ // We use a scatterplot to illustrate the original
+ // contro points.
+
+ $bplot = new LinePlot($maxdata,$xdata);
+ $g->Add($bplot);
+ $bplot->SetColor($fill_color_top);
+ $bplot->SetFillGradient($fill_color_top,$fill_color_bottom,100,TRUE);
+ $bplot->SetFillFromYMin(TRUE);
+ $bplot->SetWeight(4);
+
+ $aplot = new LinePlot($mindata,$xdata);
+ $g->Add($aplot);
+ $aplot->SetColor($fill_color_bottom);
+ $aplot->SetFillGradient($fill_color_bottom,'white',100,TRUE);
+ $aplot->SetFillFromYMin(TRUE);
+ $aplot->SetWeight(4);
+
+ $g->SetMargin(60,60,60,130);
+ $g->title->Set($sensor_name.'/'.$param_name.', '.$param_unit);
+ $g->title->SetFont(FF_DV_SANSSERIF,FS_BOLD,12);
+ $g->subtitle->Set('(минимальные и максимальные значения за период)');
+ $g->subtitle->SetColor('darkred');
+ $g->SetMarginColor('silver');
+
+ // Add the plots to the graph and stroke
+ $g->Stroke();
+
+} else {
+
+ header("Content-Type: text/html; charset=UTF-8");
+ die('Сенсор не выбран!');
+
+}
+
+?>
\ No newline at end of file
--- /dev/null
+<!doctype html public "-//w3c//dtd html 4.0 transitional//en">
+<html>
+<head>
+ <meta http-equiv="Content-Type" content="text/html; charset=utf-8">
+ <meta name="GENERATOR" content="Mozilla/4.72 [cp1251] (X11; U; Linux 2.2.12-20smp i686) [Netscape]">
+ <title>WeatherMon (Последние 24 часа)</title>
+ <link rel="icon" href="favicon.png" />
+</head>
+<body text="black" bgcolor="silver" link="blue" vlink="#000080" alink="#FF0000">
+<?php
+
+include('config_local.php');
+
+if (! ($db = new PDO("mysql:host=$mysql_host;port=$mysql_port;dbname=$mysql_schema",$mysql_user,$mysql_pwd,array( PDO::ATTR_PERSISTENT => false)))) {
+ die($err);
+ }
+
+$db -> exec('SET CHARACTER SET utf8');
+
+$q = $db -> prepare(
+ 'select
+ distinct v.sensor_id,s.s_description,p.id as param_id,p.st_description
+ from
+ sensor_values v,st_parameters p,sensors s
+ where
+ v.timestamp>adddate(now(), -1)
+ and v.sensor_id=s.id
+ and s.st_id=p.st_id'
+ );
+$q -> execute();
+
+while ($row = $q -> fetch(PDO::FETCH_ASSOC)) {
+
+ echo '<h3 align="center">'.$row['s_description'].'/'.$row['st_description'].'</h3>';
+?>
+<center><img src="image.php?sensor=<?php echo $row['sensor_id']; ?>¶m=<?php echo $row['param_id']?>&type=last24"></center>
+<?php
+
+}
+
+?>
+<a href="archive.php">Архивные данные</a>
+<br>
+<a href="setup.php">Настройки</a>
+</body>
+
\ No newline at end of file
--- /dev/null
+<?php
+
+error_reporting(E_ALL & ~E_STRICT & ~E_NOTICE);
+
+include ('config_local.php');
+
+if (! ($db = new PDO("mysql:host=$mysql_host;port=$mysql_port;dbname=$mysql_schema",$mysql_user,$mysql_pwd,array( PDO::ATTR_PERSISTENT => false)))) {
+
+ die('Не могу подключиться к БД');
+
+}
+
+$db -> exec('SET CHARACTER SET utf8');
+
+$selected = [];
+
+if ($_REQUEST['action']=='submit') {
+
+ foreach($_REQUEST as $key=>$value) {
+
+ if (strpos($key,'unit_')===0) {
+
+ $group_id=intval(substr($key,5));
+ $unit_id=$value;
+ setcookie('unit_'.$group_id,$unit_id,time()+86400*365*10);
+ $selected[$group_id]=$unit_id;
+
+ }
+
+ }
+
+?>
+<html>
+<head>
+ <meta http-equiv="Content-Type" content="text/html; charset=utf-8">
+ <meta http-equiv="refresh" content="2; url=index.php">
+ <meta name="GENERATOR" content="Mozilla/4.72 [cp1251] (X11; U; Linux 2.2.12-20smp i686) [Netscape]">
+ <title>WeatherMon (Настройки)</title>
+ <link rel="icon" href="favicon.png" />
+</head>
+<body text="black" bgcolor="silver" link="blue" vlink="#000080" alink="#FF0000">
+<h1 align="center">Сохранено...</h1>
+</body>
+<?php
+
+} else {
+
+ foreach($_COOKIE as $key=>$value) {
+
+ if (strpos($key,'unit_')===0) {
+
+ $group_id=intval(substr($key,5));
+ $unit_id=$value;
+ setcookie('unit_'.$group_id,$unit_id);
+ $selected[$group_id]=$unit_id;
+
+ }
+
+ }
+
+?>
+<!doctype html public "-//w3c//dtd html 4.0 transitional//en">
+<html>
+<head>
+ <meta http-equiv="Content-Type" content="text/html; charset=utf-8">
+ <meta name="GENERATOR" content="Mozilla/4.72 [cp1251] (X11; U; Linux 2.2.12-20smp i686) [Netscape]">
+ <title>WeatherMon (Настройки)</title>
+ <link rel="icon" href="favicon.svg" />
+</head>
+<body text="black" bgcolor="silver" link="blue" vlink="#000080" alink="#FF0000">
+
+<?php
+
+
+$q = $db -> prepare(
+ 'select id,name,(select count(*) from units where unit_group=g.id) cnt from unit_groups g'
+);
+$q -> execute();
+
+echo '<form action="setup.php" method="get">';
+while ($row = $q -> fetch(PDO::FETCH_ASSOC)) {
+ $group_id = $row['id'];
+ $group_name = $row['name'];
+ $group_cnt = $row['cnt'];
+
+ echo '<h3 align="center">'.$group_name.'</h3>';
+
+ $q_p = $db -> prepare(
+ 'select id,name from units where unit_group='.$group_id
+ );
+
+ $q_p->execute();
+
+ echo '<center><select name="unit_'.$group_id.'" size='.$group_cnt.'>';
+ while ($row_p = $q_p -> fetch(PDO::FETCH_ASSOC)) {
+
+ if ($selected[$group_id]==$row_p['id']) {
+ echo '<option selected value="'.$row_p['id'].'">'.$row_p['name'].'</option>';
+ } else {
+ echo '<option value="'.$row_p['id'].'">'.$row_p['name'].'</option>';
+ }
+
+ }
+ echo '</select></center>';
+}
+echo '<input type="hidden" name="action" value="submit">';
+echo '<p><center><input type="submit" value="Сохранить настройки"></center>';
+echo '</form>';
+
+}
+
+?>
+</body>
+</html>
\ No newline at end of file
projects / weathermon.git / commitdiff
