望遠鏡ドットコム

#!/usr/bin/perl
 
use strict;
open(PORT,"/dev/ttyUSB0") || die "NG!";
 
my $times = time();
(my $sec,my $min,my $hour,my $mday,my $mon,my $year,my $wday,my $stime) = localtime($times);
$year = $year +1900;
$mon++;
my $datetime=sprintf("%04d-%02d-%02dT%02d:%02d:%02d+09:00", $year,$mon,$mday,$hour,$min,$sec);
 
my $serial = <PORT>;
chomp $serial;
my @val = split /,/,$serial;
 
if($val[1]<1){
    sleep(5);
    my $serial = <PORT>;
    chomp $serial;
    my @val = split /,/,$serial;
}
 
my $temp = $val[0];
my $press = $val[1];
chomp $temp;
chomp $press;
 
printf("%s,%0.2f,%2.2f\n", $datetime, $press, $temp);
 
close(PORT);

<?php
require_once('/PachubeAPI.php');
mb_internal_encoding("UTF-8");
 
$datafile = "/hoge/scp1000tmp.txt";
$t_file = file_get_contents($datafile);
 
//Pachube
$api_key = "your_api_key_here";
$feed = '5digit_feed_number';
 
//put all data into array
$rows = explode("\n", $t_file);
$cols = explode(",", $t_file);
$csv_arr = array_map("str_getcsv", $rows);
$row_c = count($csv_arr);
 
//read the last line
$last_1time = $csv_arr[$row_c-2][0];
$last_1pres = $csv_arr[$row_c-2][1];
$last_1temp = $csv_arr[$row_c-2][2];
 
$datetime = $last_1time;
$pressure = $last_1pres;
$temp = $last_1temp;
 
//print for cacti
printf("scppres:%0.2f scptemp:%2.2f", $pressure,$temp);
 
//max and min data for Pachube
$press_min = '800';
$press_max = '1050';
$temp_min = '-10';
$temp_max = '50';
 
//Pachube
//id1:Press id2:Temp
$json_arr = array(
                  'version' => '1.0.0',
                  'datastreams' => array(array('id' => '1', 'at' => $datetime, 'max_value' => $press_max, 'min_value' => $press_min, 'current_value' => $pressure),
                                         array('id' => '2', 'at' => $datetime, 'max_value' => $temp_max, 'min_value' => $temp_min, 'current_value' => $temp))
                  );
$update_data = json_encode($json_arr);
 
$obj = new PachubeAPI($api_key);
$obj->updateFeed('json', $feed, $update_data);
 
?>

 
//頭に追加
require_once('PachubeAPI.php');//上記本文参照
 
.....
 
//Pachube
$api_key = 'your_api_key_here';//APIキー
$feed = '5_digit_feed_number'; //作成したfeedのURLの末尾の数字
 
.....
 
//(略)前の記事参照のこと
 
.....
 
//最後に追加
 
//Pachube用データ作成と投稿
 
//先に取得済みのcpmとusvを四捨五入。
//JSON化するために数値->文字列に
$cpm_round = strval(round($cpm, 0));
$usv_round = strval(round($usv, 4));
 
//json_encode用に配列を作成。idとcurrent_valueを代入。
$json_arr = array(
                  'version' => '1.0.0',
                  'datastreams' => array(array('id' => '1', 'current_value' => $cpm_round),
                                         array('id' => '2', 'current_value' => $usv_round))
                  );
//JSON化
$update_data = json_encode($json_arr);
 
//データを投稿
$obj = new PachubeAPI($api_key);
$obj->updateFeed('json', $feed, $update_data);

int calccount(unsigned char *in, int length)
{
int i, d, s;
d = s = 0;
 
    for(i=length;i>0;i--){
      if(i<5){
        d = in[i-1] * pow(16,(i-1)*2);
        //printf("%02x %d\n", in[i-1], d);
        s = s + d;
        }
    }
    return s;
}
 
 
int calctimer(unsigned char *in, int length)
{
int i, d, s;
d = s = 0;
 
    for(i=length;i>0;i--){
      if(i>4){
        d = in[i-1] * pow(16,(i-5)*2);
        //printf("%02x %d\n", in[i-1], d);
        s = s + d;
        }
    }
    return s;
}

<?php
mb_internal_encoding("UTF-8");
 
//ログファイル指定
$datafile = "/var/www/html/hoge/counter.txt";
$t_file = file_get_contents($datafile);
 
//係数
$lnd712 = 120;
 
$rows = explode("\n", $t_file);
$cols = explode(",", $t_file);
$csv_arr = array_map("str_getcsv", $rows);
$row_c = count($csv_arr);
 
//最終行
$last_1c = $csv_arr[$row_c-2][0];
$last_1t = $csv_arr[$row_c-2][1];
 
//最終行の前の行
$last_2c = $csv_arr[$row_c-3][0];
$last_2t = $csv_arr[$row_c-3][1];
 
//最終行の前の前の行
$last_3c = $csv_arr[$row_c-4][0];
$last_3t = $csv_arr[$row_c-4][1];
 
//最終行の前の行と最終行との差
$count_1_2 = $last_1c - $last_2c;
$timer_1_2 = $last_1t - $last_2t;
 
//最終行は無視し、その一つ前の組み合わせ。
$count_2_3 = $last_2c - $last_3c;
$timer_2_3 = $last_2t - $last_3t;
 
//CPMとuSvを計算。
//最起動直後のデータは無視する
if ($count_1_2>0) {
  $counter = $last_1c;
  $timer = $last_1t;
  $cpm = $count_1_2 / $timer_1_2 * 60;
  $usv = $cpm / $lnd712;
 } else {
  $counter = $last_2c;
  $timer = $last_2t;
  $cpm = $count_2_3 / $timer_2_3 * 60;
  $usv = $cpm / $lnd712;
 }
 
printf("counter:%d timer:%d cpm:%d usv:%.3g", $counter, $timer, $cpm, $usv);
 
?>

@@ -24,45 +24,10 @@
 #include <usb.h>
 #include <unistd.h>
 #include <string.h>
+#include <math.h>
 
-#define USBRH_VENDOR  0x1774
-#define USBRH_PRODUCT 0x1001
-
-// parameter
-// http://www.sensirion.com/en/pdf/product_information/Data_Sheet_humidity_sensor_SHT1x_SHT7x_E.pdf
-// http://www.syscom-inc.co.jp/pdf/sht_datasheet_j.pdf
-#define d1 -40.00
-#define d2 0.01
-#define c1 -4
-#define c2 0.0405
-#define c3 -0.0000028
-#define t1 0.01
-#define t2 0.00008
-
-// Temperature = d1+d2*SOt
-// d1  -40.00
-// d2  0.04
-double convert_temp(int in)
-{
-double tmp;
-
-    tmp = 0;
-
-    tmp = d1+d2*in;
-
-    return(tmp);
-}
-
-double convert_humidity(int in)
-{
-double tmp;
-
-    tmp = 0;
-
-    tmp = c1+c2*in+c3*(in*in);
-
-    return((t1-25)*(t1+t2*in)+tmp);
-}
+#define USBGEIGER_VENDOR  0x1774
+#define USBGEIGER_PRODUCT 0x1002
 
 void dump(unsigned char *in, int length)
 {
@@ -82,6 +47,34 @@
 
 }
 
+int calccount(unsigned char *in, int length)
+{
+int i, d, s;
+d = s = 0;
+
+    for(i=length;i>0;i--){
+      if(i<5){
+       d = in[i-1] * pow(16,(i-1)*2);
+       s = s + d;
+        }
+    }
+    return s;
+}
+
+int calctimer(unsigned char *in, int length)
+{
+int i, d, s;
+d = s = 0;
+
+    for(i=length;i>0;i--){
+      if(i>4){
+       d = in[i-1] * pow(16,(i-5)*2);
+       s = s + d;
+        }
+    }
+    return s;
+}
+
 struct usb_device *searchdevice(unsigned int vendor, unsigned int product, int num)
 {
 struct usb_bus *bus;
@@ -113,7 +106,7 @@
 
     count=0;
 
-    puts("listing:USBRH");
+    puts("listing:USBGEIGER");
 
     for (bus = usb_get_busses(); bus; bus = bus->next){
         for (dev = bus->devices; dev; dev = dev->next){
@@ -132,14 +125,16 @@
 
 void usage()
 {
-    puts("USBRH on Linux 0.05 by Briareos\nusage: usbrh [-vthm1fl]\n"
+    puts("USBGEIGER on Linux 0.00 by Masaki Kamimura\n(originally published as USBRH on Linux by Mr. Briareos)\n\nusage: usbgeiger [-vthm1cfls]\n"
          "       -v : verbose\n"
-         "       -t : temperature (for MRTG2)\n"
-         "       -h : humidity (for MRTG2)\n"
-         "       -m : temperature/humidity output(for MRTG2)\n"
+         "       -t : counter (for MRTG2)\n"
+         "       -h : timer (for MRTG2)\n"
+         "       -m : counter/timer output(for MRTG2)\n"
          "       -1 : 1-line output\n"
+         "       -c : csv\n"
          "       -fn: set device number(n>0)\n"
-         "       -l : Device list\n" );
+         "       -l : Device list\n"
+         "       -sn: set sleep duration in n msec (default: 100ms)\n" );
 }
 
 int main(int argc, char *argv[])
@@ -148,24 +143,26 @@
 usb_dev_handle *dh;
 char buff[512];
 int rc;
-int iTemperature, iHumidity, opt;
-double temperature, humidity;
+int opt;
+int iCounter, iTimer;
 unsigned char data[8];
-char flag_v, flag_t, flag_h, flag_d, flag_f, flag_1line, flag_mrtg, flag_l;
+char flag_v, flag_t, flag_h, flag_d, flag_f, flag_1line, flag_mrtg, flag_l, flag_c;
 char tmpDevice[8];
 int  DeviceNum;
+unsigned long sleep_usec;
 
     dev = NULL;
     dh = NULL;
     rc = 0;
     DeviceNum = 1;
-    flag_f = flag_v = flag_t = flag_h = flag_d = flag_1line = flag_mrtg = flag_l = 0;
-    temperature = humidity = 0;
+    flag_f = flag_v = flag_t = flag_h = flag_d = flag_1line = flag_mrtg = flag_l = flag_c = 0;
+    counter = timer = 0;
+    sleep_usec = 1000 * 1000;
     memset(buff, 0, sizeof(buff));
     memset(data, 0, sizeof(data));
     memset(tmpDevice, 0, sizeof(tmpDevice));
 
-    while((opt = getopt(argc, argv,"lvth1dmf:?")) != -1){
+    while((opt = getopt(argc, argv,"lcvth1dmf:s:?")) != -1){
         switch(opt){
             case 'v':
                 flag_v = 1;
@@ -196,6 +193,12 @@
             case 'l':
                 flag_l = 1;
                 break;
+           case 's':
+               sleep_usec = atoi(optarg) * 1000;
+               break;
+           case 'c':
+               flag_c = 1;
+               break;
             default:
                 usage();
                 exit(0);
@@ -208,20 +211,20 @@
     usb_find_devices();
 
     if(flag_l){
-        listdevice(USBRH_VENDOR, USBRH_PRODUCT);
+        listdevice(USBGEIGER_VENDOR, USBGEIGER_PRODUCT);
         exit(0);
     }
 
     if(flag_d)
         usb_set_debug(5);
 
-    if((dev = searchdevice(USBRH_VENDOR, USBRH_PRODUCT, DeviceNum)) == (struct usb_device *)NULL){
-        puts("USBRH not found");
+    if((dev = searchdevice(USBGEIGER_VENDOR, USBGEIGER_PRODUCT, DeviceNum)) == (struct usb_device *)NULL){
+        puts("USBGEIGER not found");
         exit(1);
     }
 
     if(flag_d){
-        puts("USBRH is found");
+        puts("USBGEIGER is found");
     }
     dh = usb_open(dev);
     if(dh == NULL){
@@ -230,15 +233,21 @@
     }
 
     if((rc = usb_set_configuration(dh, dev->config->bConfigurationValue))<0){
-        puts("usb_set_configuration error");
-        usb_close(dh);
-        exit(3);
-    }
-
+      if((rc = usb_detach_kernel_driver_np(dh, dev->config->interface->altsetting->bInterfaceNumber))<0){
+       printf("usb_detach_kernel_driver_np error: %s\n", usb_strerror());
+       usb_close(dh);
+       exit(3);
+      }else{
+       if((rc =usb_set_configuration(dh, dev->config->bConfigurationValue))<0){
+         printf("usb_set_configuration error: %s\n", usb_strerror());
+         usb_close(dh);
+         exit(3);
+       }
+      }
+   }
     if((rc =usb_claim_interface(dh, dev->config->interface->altsetting->bInterfaceNumber))<0){
-        //puts("usb_claim_interface error");
         if((rc = usb_detach_kernel_driver_np(dh, dev->config->interface->altsetting->bInterfaceNumber))<0){
-            puts("usb_detach_kernel_driver_np error");
+           printf("usb_detach_kernel_driver_np error: %s\n", usb_strerror());
             usb_close(dh);
             exit(4);
         }else{
@@ -266,47 +275,50 @@
 
     // usb_control_msg() is successed
     if(rc>=0){
-        sleep(1);
+        usleep(sleep_usec);
 
         // Read data from device
-        rc = usb_bulk_read(dh, 1, buff, 7, 5000);
+       rc = usb_bulk_read(dh, 1, buff, 7, 5000);
         if(flag_d){
             if(rc<0){
                 puts("usb_bulk_read error");
             } else {
-                printf("usb_bulk_read:[%d] bytes readed.\n", rc);
+                printf("usb_bulk_read:[%d] bytes read.\n", rc);
                 dump(buff, rc);
             }
         }
+
+       iCounter = calccount(buff, rc);
+       iTimer = calctimer(buff,rc);
 
-        iTemperature = buff[2]<<8|(buff[3]&0xff);
-        iHumidity = buff[0]<<8|(buff[1]&0xff);
         if(flag_d){
-            printf("convert to integer(temperature):[%02x %02x] -> [%04x]\n", buff[2], buff[3], iTemperature);
-            printf("convert to integer(humidity):[%02x %02x] -> [%04x]\n", buff[0], buff[1], iHumidity);
+
+          printf("Counter: %d\n", iCounter);
+         printf("Timer: %d\n", iTimer);
         }
-        temperature = convert_temp(iTemperature);
-        humidity    = convert_humidity(iHumidity);
     }
 
     // Display Result
     if(flag_v){
-        printf("Temperature: %.2f C\n", temperature);
-        printf("Humidity: %.2f %\n", humidity);
+        printf("Counter: %d \n", iCounter);
+        printf("Timer: %d \n", iTimer);
     }else
     if(flag_t){
-        printf("%.2f\n%.2f\n\nTemperature\n", temperature, temperature);
+        printf("%d\n%d\n\nCounter\n", iCounter, iCounter);
     }else
     if(flag_h){
-        printf("%.2f\n%.2f\n\nHumidity\n", humidity, humidity);
+        printf("%d\n%d\n\nTimer\n", iTimer, iTimer);
     }else
     if(flag_mrtg){
-        printf("%.2f\n%.2f\n\nTemperature/Humidity\n", temperature, humidity);
+        printf("%d\n%d\n\nCounter/Timer\n", iCounter, iTimer);
+    }else
+    if(flag_c){
+        printf("%d,%d\n", iCounter, iTimer);
     }else
     if(flag_1line){
-        printf("Temperature: %.2f C Humidity: %.2f %%\n", temperature, humidity);
+        printf("Counter:%d Timer:%d \n", iCounter, iTimer);
     }else
-        printf("%.2f %.2f\n", temperature, humidity);
+        printf("%d %d\n", iCounter, iTimer);
 
     if((rc = usb_release_interface(dh, dev->config->interface->altsetting->bInterfaceNumber))<0){
         puts("usb_release_interface error");