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