]> dxcluster.org Git - dweather.git/blob - dirk-ae.pl
start a real(ish) dweather webapp
[dweather.git] / dirk-ae.pl
1 #!/usr/bin/perl
2
3 use DBI;
4 use strict;
5 use Device::SerialPort;
6 use Time::HiRes;
7 use AnyEvent;
8
9 my $devname = "/dev/davis";
10 my $dbsort = "SQLite";          
11 my $db="weather.db";
12 my $host="";
13 my $userid="";
14 my $passwd="";
15 my $connectionInfo="dbi:$dbsort:$db";
16 $connectionInfo .= ":$host" if $host;
17
18 # make connection to database
19 my %attr = ( PrintError => 0, RaiseError => 0 );
20 my $dbh = DBI->connect($connectionInfo,$userid,$passwd,\%attr) or die "Couldn't connect to database: " . DBI->errstr;
21
22
23 my ($count, $result);
24 my %hsh;
25 my @crc_table=();
26 my %bar_trend=();
27 load_crc_table();
28
29 my $ob = Device::SerialPort->new ($devname) || die;
30
31 $ob->user_msg(1);                               # misc. warnings
32 $ob->error_msg(1);                              # hardware and data errors
33
34 $ob->baudrate(19200);
35 $ob->parity("none");
36 #$ob->parity_enable(1);         # for any parity except "none"
37 $ob->databits(8);
38 $ob->stopbits(1);
39 $ob->handshake('none');
40 $ob->read_const_time(15000);    # ultimate timeout (15 seconds)
41 $ob->write_settings||die"setting failed";
42
43 my $cv = AE::cv;
44
45 my $hdl = new AnyEvent::Handle(
46                                                          fh => $ob->{HANDLE},
47                                                          on_error => sub {
48                                                                  my ($hdl, $fatal, $msg) = @_;
49                                                                  AE::log error => $msg;
50                                                                  $hdl->destroy;
51                                                                  $cv->send;
52                                                          },
53                                                         );
54
55 $hdl->push_write("\n");                 # kick the serial port
56 my $awake=0;
57 my $attempts=0;
58 #$ob->write("\n");                              # initial wake
59
60 while ($awake==0) {
61         
62         $hdl->push_write("\n");                 # wake for real
63         $hdl->push_read(regex => qr<\n\r>, timeout => sub )
64         $ob->read_interval(600);        # wait for a max of 600ms
65         ($count, $result) = $ob->read(10); # read up to 10 chars
66         if ($result eq "\n\r") {
67                 print "awoke on attempt $attempts :)\n"; 
68                 $awake=1;
69         }
70         else {
71                 print "wake error on attempt $attempts :(\n";
72         }
73         $attempts++;
74         dienice("failed to wake device - tried $attempts times") unless $attempts<6;
75 }
76
77 $ob->write("LAMPS 0\n");
78 $ob->read_interval(300);                # wait for a max of 300ms
79 ($count, $result) = $ob->read(8); # read up to 8 chars
80 $result=~s/(\r|\n)//g;
81 if ($result eq "OK") {
82         print "lamps on :)\n";
83 }
84 else {
85         dienice("lamp error '$result'");
86 }
87
88
89
90 my $ref=gettime();
91 $ref->[5]+=1900;
92 print "$ref->[2]:$ref->[1]:$ref->[0] $ref->[3]/$ref->[4]/$ref->[5]\n";
93
94 #settime();
95
96 #do_dmpaft();
97
98 while (1) {
99         get_loop();                                     # if you do anything after here - you need to wake up the device again
100         print "** do something else\n";
101         sleep 5;
102         $ob->write("\r");                       #  wake
103         $ob->read_interval(500);        # wait for a max of 300ms
104         my ($count, $result) = $ob->read(4096); # read any crap up to 4096 chars
105 }
106
107 #print "count=$count $result\n";
108 #for(my $i=0; $i<$count; $i++)
109 #{ printf("%02d ",ord(substr($result,$i,1))); }
110
111 #$ob->write("WRD\x12\x4d\n");
112
113 undef $ob; 
114 exit 0;
115
116 sub dienice
117 {
118         my $err=shift;
119         print "$err\n";
120         undef $ob;
121         exit 9;
122 }
123
124 sub parse_loop_blck 
125 {
126         my $blk = shift; 
127         my $loo =  substr $blk,0,3;  
128         unless ( $loo eq 'LOO') {
129                 warn("Block invalid loo -> $loo\n"); return "";
130         } 
131         my $t;
132     
133         #$hsh{'next_rec'}     = unpack("s", substr $blk,5,2);  
134   
135         $hsh{'Barometric_Trend'}    = unpack("C", substr $blk,3,1);
136         $hsh{'Barometric_Trend_txt'} = $bar_trend{$hsh{'Barometric_Trend'}};
137         $t = unpack("s", substr $blk,7,2) / 1000; 
138 #       $hsh{'Barometric_Press_hg'}          = $t;
139         $hsh{'Barometric_Press_mb'} = sprintf("%.2f",$t*33.8637526); 
140   
141
142         $t = unpack("s", substr $blk,9,2) / 10;
143 #       $hsh{'Air_Temp_Inside_f'}      = $t;
144         $hsh{'Air_Temp_Inside_c'} = sprintf("%.1f",($t - 32) * 5/9);
145         my $tf  = unpack("s", substr $blk,12,2) / 10; 
146 #       $hsh{'Air_Temp_Outside_f'}     = $tf;
147         $hsh{'Air_Temp_Outside_c'}  = sprintf("%.1f",($tf - 32) * 5/9);
148   
149         $hsh{'Wind_Speed_mph'}   = unpack("C", substr $blk,14,1); 
150 #       $hsh{'Wind_Speed_mps'} = sprintf("%.1f",$hsh{'Wind_Speed_mph'}*0.44704);
151         $hsh{'Wind_Speed_10min_Avg_mph'} = unpack("C", substr $blk,15,1);
152 #       $hsh{'Wind_Speed_10min_Avg_mps'} = sprintf("%.1f",$hsh{'Wind_Speed_10min_Avg_mph'}*0.44704);
153         $hsh{'Wind_Dir'}     = unpack("s", substr $blk,16,2);
154   
155   
156         $hsh{'Humidity_Outside'} = unpack("C", substr $blk,33,1);
157         $hsh{'Humidity_Inside'}  = unpack("C", substr $blk,11,1);
158         $hsh{'Dew_Point'}  = dew_point($tf, $hsh{'Humidity_Outside'});
159   
160 #       $hsh{'UV'}         = unpack("C", substr $blk,43,1);
161 #       $hsh{'Solar'}  = unpack("s", substr $blk,44,2); # watt/m**2
162   
163         $hsh{'Rain_Rate'}  = (unpack("s", substr $blk,41,2) / 100) * 25.4; # Inches per hr converted to mm
164         $hsh{'Rain_Storm'} = (unpack("s", substr $blk,46,2) / 100) * 25.4; # Inches per storm
165         #$hsh{'Storm_Date'} = unpack("s", substr $blk,48,2);  # Need to parse data (not sure what this is)
166         $hsh{'Rain_Day'}   = (unpack("s", substr $blk,50,2)/100) * 25.4;  
167         $hsh{'Rain_Month'}  = (unpack("s", substr $blk,52,2)/100) * 25.4;  
168         $hsh{'Rain_Year'}  = (unpack("s", substr $blk,54,2)/100) * 25.4; 
169   
170         $hsh{'ET_Day'}   = unpack("s", substr $blk,56,2)/1000;  
171         $hsh{'ET_Month'}  = unpack("s", substr $blk,58,2)/100;  
172         $hsh{'ET_Year'}  = unpack("s", substr $blk,60,2)/100;  
173   
174         #$hsh{'Alarms_Inside'}  = unpack("b8", substr $blk,70,1);  
175         #$hsh{'Alarms_Rain'}  = unpack("b8", substr $blk,70,1);  
176         #$hsh{'Alarms_Outside'}  = unpack("b8", substr $blk,70,1);  
177   
178         $hsh{'Batt_Transmitter'}  = unpack("C", substr $blk,86,1); #  * 0.005859375
179         $hsh{'Batt_Console'}  = unpack("s", substr $blk,87,2) * 0.005859375; 
180   
181         $hsh{'Forecast_Icon'}  = unpack("C", substr $blk,89,1);  
182         $hsh{'Forecast_Rule'}  = unpack("C", substr $blk,90,1); 
183   
184         $hsh{'Sunrise'}  = sprintf( "%04d", unpack("S", substr $blk,91,2) );  
185         $hsh{'Sunrise'}  =~ s/(\d{2})(\d{2})/$1:$2/; 
186         $hsh{'Sunset'}   = sprintf( "%04d", unpack("S", substr $blk,93,2) );  
187         $hsh{'Sunset'}  =~ s/(\d{2})(\d{2})/$1:$2/;
188   
189         #my $nl  =  ord substr $blk,95,1;  
190         #my $cr  =  ord substr $blk,96,1;   
191
192         my $crc = unpack "%n", substr($blk,97,2); 
193         my $crc_calc = CRC_CCITT($blk); 
194   
195         if ($crc_calc==0) {
196                 return 0;
197         }
198         else {
199                 print "CRC check failed for LOOP data!\n";
200                 return 1;
201         }
202         #delete @hsh{'crc', 'crc_calc', 'next_rec'};
203         #delete($hsh{crc})||die"cant delete crc";
204         #delete($hsh{crc_calc})||die"cant delete crc_calc";
205         #delete($hsh{next_rec})||die"cant delete next_rec";
206   
207 }
208
209 sub dew_point
210 {
211         my $temp = shift @_; 
212         my $rh   = shift @_; 
213   
214         #  Using the simplified approximation for dew point 
215         #  Accurate to 1 degree C for humidities > 50 %  
216         #  http://en.wikipedia.org/wiki/Dew_point
217
218         my $dew_point = $temp - ( (100 - $rh)/5 ); 
219     
220         return $dew_point; 
221 }
222
223 sub CRC_CCITT
224 {
225     # Expects packed data... 
226     my $data_str = shift @_;
227
228         my $crc = 0;
229         my @lst = split //, $data_str;
230         foreach my $data (@lst) {
231                 my $data = unpack("c",$data); 
232         
233                 my $crc_prev = $crc;
234                 my $index = $crc >> 8 ^ $data;
235                 my $lhs = $crc_table[$index];
236                 #print "lhs=$lhs, crc=$crc\n";
237                 my $rhs = ($crc << 8) & 0xFFFF;
238                 $crc = $lhs ^ $rhs;
239         
240            
241         }
242                 
243         return $crc;
244 }
245
246 sub load_crc_table
247 {
248
249         @crc_table = (
250                                   0x0, 0x1021, 0x2042, 0x3063, 0x4084, 0x50a5, 0x60c6, 0x70e7,
251                                   0x8108, 0x9129, 0xa14a, 0xb16b, 0xc18c, 0xd1ad, 0xe1ce, 0xf1ef,
252                                   0x1231, 0x210, 0x3273, 0x2252, 0x52b5, 0x4294, 0x72f7, 0x62d6,
253                                   0x9339, 0x8318, 0xb37b, 0xa35a, 0xd3bd, 0xc39c, 0xf3ff, 0xe3de,
254                                   0x2462, 0x3443, 0x420, 0x1401, 0x64e6, 0x74c7, 0x44a4, 0x5485,
255                                   0xa56a, 0xb54b, 0x8528, 0x9509, 0xe5ee, 0xf5cf, 0xc5ac, 0xd58d,
256                                   0x3653, 0x2672, 0x1611, 0x630, 0x76d7, 0x66f6, 0x5695, 0x46b4,
257                                   0xb75b, 0xa77a, 0x9719, 0x8738, 0xf7df, 0xe7fe, 0xd79d, 0xc7bc,
258                                   0x48c4, 0x58e5, 0x6886, 0x78a7, 0x840, 0x1861, 0x2802, 0x3823,
259                                   0xc9cc, 0xd9ed, 0xe98e, 0xf9af, 0x8948, 0x9969, 0xa90a, 0xb92b,
260                                   0x5af5, 0x4ad4, 0x7ab7, 0x6a96, 0x1a71, 0xa50, 0x3a33, 0x2a12,
261                                   0xdbfd, 0xcbdc, 0xfbbf, 0xeb9e, 0x9b79, 0x8b58, 0xbb3b, 0xab1a,
262                                   0x6ca6, 0x7c87, 0x4ce4, 0x5cc5, 0x2c22, 0x3c03, 0xc60, 0x1c41,
263                                   0xedae, 0xfd8f, 0xcdec, 0xddcd, 0xad2a, 0xbd0b, 0x8d68, 0x9d49,
264                                   0x7e97, 0x6eb6, 0x5ed5, 0x4ef4, 0x3e13, 0x2e32, 0x1e51, 0xe70,
265                                   0xff9f, 0xefbe, 0xdfdd, 0xcffc, 0xbf1b, 0xaf3a, 0x9f59, 0x8f78,
266                                   0x9188, 0x81a9, 0xb1ca, 0xa1eb, 0xd10c, 0xc12d, 0xf14e, 0xe16f,
267                                   0x1080, 0xa1, 0x30c2, 0x20e3, 0x5004, 0x4025, 0x7046, 0x6067,
268                                   0x83b9, 0x9398, 0xa3fb, 0xb3da, 0xc33d, 0xd31c, 0xe37f, 0xf35e,
269                                   0x2b1, 0x1290, 0x22f3, 0x32d2, 0x4235, 0x5214, 0x6277, 0x7256,
270                                   0xb5ea, 0xa5cb, 0x95a8, 0x8589, 0xf56e, 0xe54f, 0xd52c, 0xc50d,
271                                   0x34e2, 0x24c3, 0x14a0, 0x481, 0x7466, 0x6447, 0x5424, 0x4405,
272                                   0xa7db, 0xb7fa, 0x8799, 0x97b8, 0xe75f, 0xf77e, 0xc71d, 0xd73c,
273                                   0x26d3, 0x36f2, 0x691, 0x16b0, 0x6657, 0x7676, 0x4615, 0x5634,
274                                   0xd94c, 0xc96d, 0xf90e, 0xe92f, 0x99c8, 0x89e9, 0xb98a, 0xa9ab,
275                                   0x5844, 0x4865, 0x7806, 0x6827, 0x18c0, 0x8e1, 0x3882, 0x28a3,
276                                   0xcb7d, 0xdb5c, 0xeb3f, 0xfb1e, 0x8bf9, 0x9bd8, 0xabbb, 0xbb9a,
277                                   0x4a75, 0x5a54, 0x6a37, 0x7a16, 0xaf1, 0x1ad0, 0x2ab3, 0x3a92,
278                                   0xfd2e, 0xed0f, 0xdd6c, 0xcd4d, 0xbdaa, 0xad8b, 0x9de8, 0x8dc9,
279                                   0x7c26, 0x6c07, 0x5c64, 0x4c45, 0x3ca2, 0x2c83, 0x1ce0, 0xcc1,
280                                   0xef1f, 0xff3e, 0xcf5d, 0xdf7c, 0xaf9b, 0xbfba, 0x8fd9, 0x9ff8,
281                                   0x6e17, 0x7e36, 0x4e55, 0x5e74, 0x2e93, 0x3eb2, 0xed1, 0x1ef0
282                                  );
283
284         $bar_trend{-60} = "Falling Rapidly"; 
285         $bar_trend{196} = "Falling Rapidly";
286         $bar_trend{-20} = "Falling Slowly"; 
287         $bar_trend{236} = "Falling Slowly";
288         $bar_trend{0} = "Steady";
289         $bar_trend{20} = "Rising Slowly";
290         $bar_trend{60} = "Rising Rapidly";
291 }
292
293 sub gettime
294 {
295     $ob->write("GETTIME\n");
296         $ob->read_interval(200);
297         my($cnt_in, $str) = $ob->read(9);
298         if ($cnt_in==0) {
299                 dienice("read error cnt_in=$cnt_in, str='$str'");
300         }
301         
302         my $ck = CRC_CCITT(substr($str,1,9));
303         if ( $ck ) {
304                 warn "checksum error"; return 0;
305         }
306         my @rsp_lst =  split //, $str;
307         shift @rsp_lst; 
308         @rsp_lst = map ord, @rsp_lst; 
309     return \@rsp_lst; 
310 }
311
312 sub settime
313 {
314     my $s_time = [ localtime() ]; 
315     $s_time->[4] += 1; 
316     
317         $ob->write("SETTIME\n");
318         $ob->read_interval(300);
319         my ($cnt_in, $str) = $ob->read(1);
320         my $ack = ord $str; 
321         if ( $ack != 6 ) {
322                 warn "SETTIME not set ack $ack !"; return 0;
323         }
324         my ($sec, $min, $hour, $day, $mon, $yr) = @{$s_time};
325         $str = join "", map chr, ($sec, $min, $hour, $day, $mon, $yr);  
326         my $ck = CRC_CCITT($str);
327         $str = $str . pack("n",$ck); 
328         $ob->write($str);
329         ($cnt_in, $str) = $ob->read(1);
330         if ( ord($str) != 6 ) {
331                 warn "SETTIME not set!"; return 0;
332         }
333         sleep 3;                                        # The console seems to need to some time here... 
334 }
335
336 sub get_loop
337 {
338         print "** get loop at ", scalar localtime, "\n";
339         my $loops=1;
340         $ob->write("LOOP $loops\n");
341         $ob->read_interval(0);
342         ($count, $result) = $ob->read(1);
343         for (my $i=0; $i<$loops; $i+=1) {
344                 my $rc=loop_dump(); 
345                 if ($rc!=0) {
346                         last;
347                 }
348         }
349         return;
350
351 }
352
353 sub loop_dump
354 {
355         $ob->read_interval(0);
356         ($count, $result) = $ob->read(99);
357         if ($count != 99) {
358                 print "loop error - got $count bytes, expected 99\n";
359                 return 1;
360         }
361         print "LOOP data received\n";
362
363         if (ord(substr($result,0,1))==6) {
364                 $result=substr($result,1);
365         }
366
367         my $rc=parse_loop_blck($result);
368         if ($rc!=0) {
369                 return;
370         }                                                       # bad crc so goto next
371         foreach my $key (sort keys %hsh) {
372                 print "$key = $hsh{$key}\n";
373         }
374
375         my $stmt = 'INSERT INTO current (Date_Time,' . join(',', keys %hsh) . ') VALUES (NOW(),' . join(',', ('?') x keys %hsh) . ')';
376
377         $dbh->do( $stmt, undef, values %hsh);
378
379         %hsh=();
380         return 0;
381 }
382
383
384 sub do_dmpaft
385 {
386         #my $self = shift @_;
387         open(DMP,">dump.txt");
388         my $vDateStamp = shift @_;
389         my $vTimeStamp = shift @_; 
390
391         # If not date/time stamp then assume 0 which will down load the entire archive
392         unless ( $vDateStamp ) {
393                 $vDateStamp = 0;
394         } 
395         unless ( $vTimeStamp ) {
396                 $vTimeStamp = 0;
397         } 
398  
399         #my $port_obj = $self->{'port_obj'}; 
400   
401         my $datetime = pack("ss",$vDateStamp, $vTimeStamp); 
402  
403         my $crc = CRC_CCITT($datetime);
404         my $cmd = pack("ssn",$vDateStamp,$vTimeStamp,$crc); 
405
406         #-----------------------  
407         #my $str = unpack("H*", $cmd); 
408         #$str =~ s/(\w{2})/$1 /g; 
409         # Documentation is wrong! The example should be <0xC6><0x06><0xA2><0x03> in section X
410         #print "cmd : $str \n";exit; 
411         #-----------------------  
412
413         #sleep 2; # Needed after loop 
414         #$self->wake_up();  
415  
416         # Ok let's start the communication sequence.... 
417         my $cnt_out = $ob->write("DMPAFT\n");
418         unless ($cnt_out) {
419                 warn "write failed\n";
420         }
421         ;
422  
423         $ob->read_interval(300);
424         my ($cnt_in, $str) = $ob->read(1);
425   
426         my $ack = ord $str; 
427         unless ($ack == 6) {
428                 warn "Ack not received on DMPAFT command: $ack"; exit -1;
429         }
430  
431         $cnt_out = $ob->write($cmd);
432         unless ($cnt_out) {
433                 warn "write failed\n";
434         }
435         ;
436         ($cnt_in, $str) = $ob->read(7); 
437  
438         $ack = ord substr($str,0,1);    
439     
440         my $ls = unpack("H20",substr($str,1,4) ); 
441         $ls =~ s/(\w{2})/$1 /g; 
442  
443         my $pages = unpack("s",substr($str,1,2) ); 
444         my $rec_start = unpack("s",substr($str,3,2) ); 
445   
446         $crc = CRC_CCITT(substr($str,1,6) );
447
448         print "Pages = $pages : rec = $rec_start Datestamp $vDateStamp $crc\n"; 
449         
450         $cnt_out = $ob->write( pack("h", 0x06) );
451  
452         #if ($pages == 513 ) { return -1 }
453  
454         my @arc_rec_lst;          
455         foreach my $page (1..$pages) {
456                 my $page_sz = 267;      
457                 $ob->read_interval(0);
458                 my ($cnt_in, $str) = $ob->read($page_sz); #,3
459                 printf("len=%s\n",length($str));
460                 if ($cnt_in!=$page_sz) {
461                         dienice("hmm, dmpaft only got $cnt_in bytes. was expecting $page_sz");
462                 }
463                 print "Page $page\n"; 
464                 #print DMP $str,"\n";
465                 #print "ACK receipt of page $page\n";
466                 #$ob->write( pack("h", 0x06) );
467                 #next;
468                 my $calc_crc = CRC_CCITT($str);
469                 my $crc = unpack "%n", substr($str,265,2);
470                 print "page crc=$crc, calc_crc=$calc_crc\n";
471                 my $rec_sz = 52;
472                 my $date_prev = 0;      
473                 my %hsh;
474           
475                 foreach my $rec ( 0..4 ) {
476                         if ( ($page == 1) && ($rec < $rec_start ) ) {
477                                 next;
478                         }                                       # Find the right starting point... 
479
480                         my $start_ptr = 1 + ($rec * $rec_sz );    
481                         my $rec_str = substr($str, $start_ptr ,52);
482                   
483                         #print "$start_ptr \t > " . unpack( "h*", $rec_str) . "\n"; 
484                   
485                         my $date = substr($rec_str,0,2);  
486                         my $date_curr =  unpack "s", $date;
487                   
488                         # Check if we have wrapped... 
489                         if ( $date_curr < $date_prev ) {
490                                 last;
491                         }       
492                         $date_prev = $date_curr;       
493                   
494                         $hsh{'date_stamp'} =  $date_curr; 
495                         $hsh{'time_stamp'} =  unpack "s", substr($rec_str,2,2); 
496                    
497                         $hsh{'day'}    = unpack( "c", $date & pack("c",0x1F) ); 
498                         $hsh{'month'}  = ( $hsh{'date_stamp'} >> 5) & 0xF; 
499                         $hsh{'year'}  =  ( $hsh{'date_stamp'} >> 9) + 2000; 
500                 
501                         $hsh{'hour'}  = sprintf("%02d", int ( $hsh{'time_stamp'} / 100 )); 
502                   
503                         $hsh{'min'}  =  $hsh{'time_stamp'} - ($hsh{'hour'} * 100);  
504                         $hsh{'min'}  =  sprintf("%02d", $hsh{'min'}); 
505                 
506                         $hsh{'time_stamp_fmt'}  =  "$hsh{'hour'}:$hsh{'min'}:00"; 
507                         $hsh{'date_stamp_fmt'}  =  "$hsh{'year'}_$hsh{'month'}_$hsh{'day'}"; 
508
509                         #$hsh{'unixtime'} = timelocal(0,$hsh{min}, $hsh{hour}, $hsh{day}, $hsh{month}-1, $hsh{year}-1900);
510                                   
511                         $hsh{'Air_Temp'} = unpack("s", substr($rec_str,4,2)) / 10; 
512                         $hsh{'Air_Temp_Hi'} = unpack("s", substr($rec_str,6,2)) / 10; 
513                         $hsh{'Air_Temp_Lo'} = unpack("s", substr($rec_str,8,2)) / 10;
514                         $hsh{'Rain_Clicks'} = unpack("s", substr($rec_str,10,2));
515                         $hsh{'Rain_Rate'}   = unpack("s", substr($rec_str,12,2)) / 100; # Inches per hour
516                         $hsh{'Barometric_Press'}   = unpack("s", substr $rec_str,14,2) / 1000;  
517                         $hsh{'Solar'}   = unpack("s", substr $rec_str,16,2); # watt/m**2
518                         $hsh{'Wind_Samples'}  = unpack("s", substr $rec_str,18,2);   
519                         $hsh{'Air_Temp_Inside'}  = unpack("s", substr $rec_str,20,2) / 10;  
520
521                         $hsh{'Relative_Humidity_Inside'}  = unpack("C", substr $rec_str,22,1);
522                         $hsh{'Relative_Humidity'} = unpack("C", substr $rec_str,23,1);
523
524                         $hsh{'Wind_Speed'}    =  unpack("C", substr($rec_str,24,1)); 
525                         $hsh{'Wind_Gust_Max'} = unpack("C", substr($rec_str,25,1));
526                         $hsh{'Wind_Dir_Max'}  = unpack("C", substr($rec_str,26,1));
527                         $hsh{'Wind_Dir'}      = unpack("C", substr($rec_str,27,1));
528
529                         $hsh{'UV'} = unpack("C", substr($rec_str,28,1)) / 10;
530                         $hsh{'ET'} = unpack("C", substr($rec_str,29,1)) / 1000;
531
532                         $hsh{'Solar_Max'} = unpack("s", substr($rec_str,30,2)); 
533                         $hsh{'UV_Max'} = unpack("C", substr($rec_str,32,1));
534                   
535                         $hsh{'Forecast_Rule'} = unpack("C", substr($rec_str,33,1));
536                 
537 #                       $hsh{'Dew_Point'}  = _dew_point($hsh{'Air_Temp'},$hsh{'Relative_Humidity'}); 
538                                         
539                         # Miscellaneous others omitted for now
540                                         
541                         print "date> $hsh{'Air_Temp'} $hsh{'time_stamp'} $hsh{'time_stamp_fmt'}  $hsh{'date_stamp'} $hsh{'date_stamp_fmt'}\n";                  
542                         #print Dumper \%hsh; 
543                   
544                         push @arc_rec_lst, {%hsh}; 
545                 }       
546                   
547                 #$in = <STDIN>; # Testing step through facility
548                 #if ($in =~ /q/i ) {  $port_obj->write( pack("h", 0x1B) ); last; }
549                 #else              {  $port_obj->write( pack("h", 0x06) ); }
550                 print "ACK receipt of page\n";
551                 $ob->write( pack("h", 0x06) );
552           
553         }
554         close DMP;
555 }
556
557 package Device::SerialPort;
558
559 sub read_interval
560 {
561
562 }