'========================================================= '
'                                                          '
'  .NET Visual Bacis 言語サンプルコード                    '
'  このコードだけでは、動作しません。                      '
'                                                          '
'========================================================= '

Imports System.Collections.Generic
Imports System.Linq
Imports System.Text
Imports System.IO.Ports
Imports System.ComponentModel
Imports System.Data
Imports System.Diagnostics
Imports System.Threading
Imports System.Management
Imports USBXpressNET

Namespace BDG_VCS
    Module mainModule
        Sub Main()

            Dim myDevice As New Serial()

            ' デバイスと接続して、命令を送信、受信データを待ちます '
            myDevice.start_serial()
            myDevice.make_command()
            myDevice.send()
            myDevice.ReceivedAction()

        End Sub
    End Module
    
    Class Serial

        Public PACKET_HEAD As Byte = &H55
        Public DEVICE_ID As Byte = &H30
        Public crc As Crc

        Private Const BUFFER_SIZE As Integer = 128
        Private Const WAITTIME As Integer = 5000
        Public writeBuffer As Byte() = New Byte(BUFFER_SIZE - 1) {}
        Public readBuffer As Byte() = New Byte(BUFFER_SIZE - 1) {}
        Public Handle As UInteger
        Public count As Integer

        Public MainEncording As Encoding = Encoding.ASCII

        Public Sub start_serial()

            crc = New Crc()

            Dim devices As Integer = 0
            Dim x As Integer = 0
            Dim productstrings As String = ""

            ' デバイス情報を取得します '
            Dim retVal As ReturnValue = API.GetNumDevices(devices)
            Dim retVal2 As ReturnValue = API.GetProductString(x, productstrings, DirectCast(0, GetProductOptions))
            Debug.WriteLine("SI_RETURN_SERIAL_NUMBER : " & productstrings)
            Dim retVal3 As ReturnValue = API.GetProductString(x, productstrings, DirectCast(1, GetProductOptions))
            Debug.WriteLine("SI_RETURN_DESCRIPTION : " & productstrings)
            Dim retVal4 As ReturnValue = API.GetProductString(x, productstrings, DirectCast(2, GetProductOptions))
            Debug.WriteLine("SI_RETURN_LINK_NAME : " & productstrings)
            Dim retVal5 As ReturnValue = API.GetProductString(x, productstrings, DirectCast(3, GetProductOptions))
            Debug.WriteLine("SI_RETURN_VID : " & productstrings)
            Dim retVal6 As ReturnValue = API.GetProductString(x, productstrings, DirectCast(4, GetProductOptions))
            Debug.WriteLine("SI_RETURN_PID : " & productstrings)

            If devices > 0 Then

                Debug.WriteLine("{0} 個のデバイスが見つかりました !", devices)

                retVal = API.Open(0, Handle)
                If retVal = ReturnValue.SI_SUCCESS Then

                    ' 無限に待つ場合 Dim inifity As Integer = 0xFFFF; '
                    Dim notinfinity As Integer = 5000
                    '最初、送受信バッファーを空にします '
                    API.FlushBuffers(Handle, True, True)
                    ' 送受信の待ち時間を設定 '
                    API.SetTimeouts(notinfinity, notinfinity)
                    ' ボードレートの設定 '
                    API.SetBaudRate(Handle, 115200)

                Else
                    Debug.WriteLine("デバイスが見つかりません")
                    Environment.[Exit](0)
                End If
            End If
        End Sub
        Public Sub make_command()

		' 送信コマンドの作成 '
		writeBuffer(0) = 0x01; // 測定器の Modbus アドレス
		writeBuffer(1) = COMMAND; // 命令コマンド
		writeBuffer(2) = DATA_1; // パラメータ
		writeBuffer(3) = DATA_2; // パラメータ 
		writeBuffer(4) = DATA_3; // パラメータ
		writeBuffer(5) = DATA_4; // パラメータ
		writeBuffer(6) = CRC1; // Modbus CRC符号
		writeBuffer(7) = CRC2; // Modbus CRC符号
		write_command(writeBuffer)

        End Sub
        Public Sub send()
            Debug.WriteLine("Write: " & Convert.ToString(writeBuffer))
            write_command(writeBuffer)
        End Sub
        Public Sub ReceivedAction()
            ' 受信データの処理 '
            Debug.WriteLine("Read: start index count = " & count)
            Dim ret As ReturnValue = API.Read(Handle, readBuffer, count)
            If ret <> ReturnValue.SI_SUCCESS Then
                Debug.WriteLine("Read is not success !!! {0}", ret)
            Else
                If crc.checkcrc(readBuffer) Then
                    '正しく受信できているので、'
                    Debug.WriteLine("Read:" & BitConverter.ToString(readBuffer, 0, readBuffer.Length))
                    Dim data_printer As New BDG2_data()
                    ' 誤り訂正符号のチェック '
                    If readBuffer(2) = COMMAND_X Then
                        data_printer.command_R(readBuffer)
                    End If
                End If
            End If
            '待ち時間'
            Thread.Sleep(WAITTIME)
        End Sub
        Public Sub write_command(ByVal buffer As Byte())
            'デバイスへの書き込み'
            Debug.WriteLine("Write in byte : " & BitConverter.ToString(buffer, 0, buffer.Length))
            Dim ret As ReturnValue = API.Write(Handle, buffer, count)
            If ret <> ReturnValue.SI_SUCCESS Then
                Debug.WriteLine("Write not success !!! {0}", ret)
            End If
            '待ち時間'
            Thread.Sleep(WAITTIME)
        End Sub
        Public Sub close_serial()
            API.Close(Handle)
        End Sub
    End Class
    
    Class BDG2_data

        Public Sub command_R(ByVal buffer As Byte())
            ' 受信データを出力ロジックをここに書きます '
            ' ..... '
            ' ..... '
            ' ..... '
            ' ..... '
        End Sub
    End Class
        
End Namespace

/***************************************************************
 * .NET C# 言語サンプルコード
 *  --- このコードだけでは、動作しません。---
 *  --- 秘密保持契約後に、サンプルコードを提供可能です ---
 ***************************************************************/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO.Ports;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Threading;
using System.Management;
using USBXpressNET;   // USBXpressNET ライブラリが使えるようになります。

namespace BDG_VCS
{
    class Program
    {
        static void Main(string[] args)
        {
			// デバイスと接続して、命令を送信、データを受信します。
            Serial myDevice = new Serial();
            myDevice.start_serial();
            myDevice.make_command();
            myDevice.send();
            myDevice.ReceivedAction();
        }
    }
    class Serial
    {
        public byte PACKET_HEAD = 0x55;
        public byte DEVICE_ID = 0x30;
        public Crc crc;

        private const int BUFFER_SIZE = 128;
        private const int WAITTIME = 5000;
        public byte[] writeBuffer = new byte[BUFFER_SIZE];
        public byte[] readBuffer = new byte[BUFFER_SIZE];
        public uint Handle;
        public int count;

        public Encoding MainEncording = Encoding.ASCII;

        public void start_serial()
        {
            crc = new Crc();

            int devices = 0;
            int x = 0;
            string productstrings = "";

			// デバイス情報の取得
            ReturnValue retVal = API.GetNumDevices(out devices);
            ReturnValue retVal2 = API.GetProductString(x, out productstrings, (GetProductOptions)0);
            Debug.WriteLine("SI_RETURN_SERIAL_NUMBER : " + productstrings);
            ReturnValue retVal3 = API.GetProductString(x, out productstrings, (GetProductOptions)1);
            Debug.WriteLine("SI_RETURN_DESCRIPTION : " + productstrings);
            ReturnValue retVal4 = API.GetProductString(x, out productstrings, (GetProductOptions)2);
            Debug.WriteLine("SI_RETURN_LINK_NAME : " + productstrings);
            ReturnValue retVal5 = API.GetProductString(x, out productstrings, (GetProductOptions)3);
            Debug.WriteLine("SI_RETURN_VID : " + productstrings);
            ReturnValue retVal6 = API.GetProductString(x, out productstrings, (GetProductOptions)4);
            Debug.WriteLine("SI_RETURN_PID : " + productstrings);

            if (devices > 0)
            {
                Debug.WriteLine("{0} 個のデバイスが見つかりました !", devices);
                retVal = API.Open(0, out Handle);
                if (retVal == ReturnValue.SI_SUCCESS)
                {
                    int notinfinity = 5000;　//int inifity = 0xFFFF;
                    API.FlushBuffers(Handle, true, true); // 送受信バッファーを空にする。
                    API.SetTimeouts(notinfinity, notinfinity); // 送受信の待ち時間の設定
                    API.SetBaudRate(Handle, 115200); // ボードレートの設定
                }
                else
                {
                	// デバイスが見つからない場合
                    Debug.WriteLine("No devices found");
                    Environment.Exit(0);
                }
            }
        }
        public void make_command()
        {
		// 送信コマンドを作成
		writeBuffer[0] = 0x01; // 測定器の Modbus アドレス
		writeBuffer[1] = COMMAND; // 命令コマンド
		writeBuffer[2] = DATA_1; // パラメータ
		writeBuffer[3] = DATA_2; // パラメータ 
		writeBuffer[4] = DATA_3; // パラメータ
		writeBuffer[5] = DATA_4; // パラメータ
		writeBuffer[6] = CRC1; // Modbus CRC符号
		writeBuffer[7] = CRC2; // Modbus CRC符号
		write_command(writeBuffer);
        }
        public void send()
        {
            Debug.WriteLine("Write: " + writeBuffer);
            write_command(writeBuffer);
        }
        public void ReceivedAction()
        {
			// データを受信した場合
            Debug.WriteLine("Read: start index count = " + count);
            ReturnValue ret = API.Read(Handle, ref readBuffer, out count);
            if (ret != ReturnValue.SI_SUCCESS)
            {
            	// 受信失敗の場合
                Debug.WriteLine("Read is not success !!! {0}", ret);
            }
            else
            {
                if ( crc.checkcrc(readBuffer) ) // 誤り訂正符号のチェック
                {
                    Debug.WriteLine("Read:" + BitConverter.ToString(readBuffer, 0, readBuffer.Length));
                    BDG2_data data_printer = new BDG2_data();

                    if (readBuffer[2] == COMMAND_X)
                    {
                        data_printer.command_R(readBuffer);
                    }
                }
            }
            Thread.Sleep(WAITTIME); //待ち時間
        }
        public void write_command(byte[] buffer)
        {
            Debug.WriteLine("Write in byte : " + BitConverter.ToString(buffer, 0, buffer.Length));
            ReturnValue ret = API.Write(Handle, ref buffer, out count);

            if (ret != ReturnValue.SI_SUCCESS)
            {
                Debug.WriteLine("Write not success !!! {0}", ret);
            }
            Thread.Sleep(WAITTIME);//待ち時間

        }
        public void close_serial()
        {
            API.Close(Handle);
        }
    }

    class BDG2_data
    {
        public void command_R(byte[] buffer)
        {
            //  ここに受信データの解析や、出力を記載します。
        }
    }    
}

/***************************************************************
 * Java - Raspberry Pi 言語サンプルコード
 *  --- このコードだけでは、動作しません。---
 *  --- 秘密保持契約後に、サンプルコードを提供可能です ---
 ***************************************************************/

/*

(1) Change Device PID to 0xEA60. This is enable to work as Serial Device.
Use CP210xSetIDs.exe from silabs.com


(2) Check your Raspberry Pi Kernel has Cp210x driver.
dmesg | grep 210x
lsmod | grep 210x
otherwise, You have to do compile kernel with 
in Kernel configuration, You can find the device at :
Device Drivers -> USB support -> USB Serial Converter support ->
  USB CP2101 UART Bridge Controller

(3) Install library.
sudo apt-get install librxtx-java

(4)
in .bashrc, Add this.
export CLASSPATH=$CLASSPATH:/usr/share/java/RXTXcomm.jar
LD_LIBRARY_PATH=/usr/lib/jni/

(5) compile
javac bdg3.java

(6) execute
java -Djava.library.path=/usr/lib/jni/  jp.taroumaru.bdg3.bdg3

*/



package jp.taroumaru.bdg3;

import gnu.io.*; // こちらは、apt-get で install できる。
//import javax.comm.*; // Sun の Serial ライブラリだが、raspberry では使えない。

import java.io.*;
import java.util.*;


class bdg3 implements SerialPortEventListener {


    private SerialPort port;
    private InputStream inputStream;
    static OutputStream outputStream;
    private static BufferedReader reader;
    private static bdg3 obj;
    private byte[] cmd = new byte[5];
    
    bdg3() {
        try {
            
        	// シリアルポートの初期化
        	Enumeration portList = CommPortIdentifier.getPortIdentifiers();

            while (portList.hasMoreElements()) {
            	CommPortIdentifier portId = (CommPortIdentifier) portList.nextElement();
                if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {
                
                     // シリアルデバイス Raspberry Pi で割り当てられたデバイスを探す
                     // dmesg | grep 210x で探せます。
                     if (portId.getName().equals("/dev/ttyUSB0")) {
                        try {
                        	
                            // デバイスオープン
                            port = (SerialPort)
                            portId.open("serial", 2000);
                        } catch (PortInUseException e) {}
                        try {
                        
                            // 入出力の設定
                            outputStream = port.getOutputStream();
                            inputStream = port.getInputStream();
                            reader = new BufferedReader(new InputStreamReader(inputStream));
                        } catch (IOException e) {}
                        try {
                        
                        　　// ポートの設定
                        	port.setSerialPortParams(115200,
                                SerialPort.DATABITS_8,
                                SerialPort.STOPBITS_1,
                                SerialPort.PARITY_NONE);
                            port.setFlowControlMode(SerialPort.FLOWCONTROL_NONE);
                        } catch (UnsupportedCommOperationException e) {}
                        try {
                        
                        　　// データ（測定値）を受信した時のイベント
                            port.addEventListener(this);
                            port.notifyOnDataAvailable(true);
                        } catch (TooManyListenersException e) {
                            System.out.println("Error: " + e);
                        }
                    }
                }
            }
            


        } catch (Exception e) {
            System.out.println("Error: " + e);
            System.exit(1);
        }
    }
    public static String buffer2str(byte[] buffer) {

		  // Hex の値を画面に表示する
          
		  String bufferstr = "";
		  
	        for (int i = 0;i < buffer.length; i++){
	            bufferstr += String.format("%02x ", buffer[i]);
	        }

	        return bufferstr;
	}
    public void run() {
        try {
            
            // 測定器に、測定値を返信するようにする命令				 
        	// 送信コマンドを作成
        	cmd[0] = 0x01; // 測定器の Modbus アドレス
        	cmd[1] = COMMAND; // 命令コマンド
        	cmd[2] = DATA_1; // パラメータ
        	cmd[3] = DATA_2; // パラメータ 
        	cmd[4] = DATA_3; // パラメータ
        	cmd[5] = DATA_4; // パラメータ
        	cmd[6] = CRC1; // Modbus CRC符号
        	cmd[7] = CRC2; // Modbus CRC符号

            OutputStream out = port.getOutputStream();
            out.write(cmd);
            System.out.println("Write: "+buffer2str(cmd));
            Thread.sleep(3000); 
        	port.close();

        } catch (Exception e) {
            System.out.println("Error: " + e);
        }
    }

    public void serialEvent(SerialPortEvent event) {
    
    　　// データ（測定値）を受け取ったときのイベント
    
        if (event.getEventType() == SerialPortEvent.DATA_AVAILABLE) {
        	byte[] readBuffer = new byte[30];
            try {
               // read data
               while (inputStream.available() > 0) {
                  int numBytes = inputStream.read(readBuffer);
               } 
               System.out.println("Read: "+buffer2str(readBuffer));
            } catch (IOException e) {}
        }
    }

    public static void main(String arg[]) {
       
        // 実行します。
    	obj = new bdg3();
    	obj.run();
    }
}

/***************************************************************
 * Android サンプルコード
 *  --- このコードだけでは、動作しません。---
 *  --- 秘密保持契約後に、サンプルコードを提供可能です ---
 ***************************************************************/

package com.example.bdg_for_android;

public class MainActivity extends Activity {

    private final String TAG = MainActivity.class.getSimpleName();
    private TextView tvMsg;

    private static UsbSerialPort sPort = null;
    private SerialInputOutputManager mSerialIoManager;
    private PendingIntent mPermissionIntent = null;

    private final SerialInputOutputManager.Listener mListener =
            new SerialInputOutputManager.Listener() {

                public void onNewData(final byte[] data) {
                    runOnUiThread(new Runnable() {
                        @Override
                        public void run() {

			    //データを受信後、誤り訂正符号のチェック
                            if (crc.checkcrc(data)){
                                updateReceivedData(data);
                            }
                        }
                    });
                }
            };

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        tvMsg = (TextView)findViewById(R.id.tvMsg);


	//デバイスと接続
        if( connectUSB() ) {

	    //命令を送信
            send();
            
        }
    }


    private boolean connectUSB(){

        // デバイス情報の取得
        UsbManager manager = (UsbManager) getSystemService(Context.USB_SERVICE);

        UsbSerialProber prober = new UsbSerialProber(customTable);
        List availableDrivers = prober.findAllDrivers(manager);

        if (availableDrivers.isEmpty()) {
            tvMsg.setText("No available drivers.");
            return false;
        }

        UsbSerialDriver driver = availableDrivers.get(0);

        // 接続の許可
        if (mPermissionIntent == null) {
            mPermissionIntent = PendingIntent.getBroadcast(this, 0, new Intent("USB_PERMISSION"), 0);
        }
        manager.requestPermission(driver.getDevice(), mPermissionIntent);
        if (!manager.hasPermission(driver.getDevice())) {
            tvMsg.setText("The driver does not have permission.");
            return false;
        }

        UsbDeviceConnection connection = manager.openDevice(driver.getDevice());
        if (connection == null) {
             tvMsg.setText("Can not open a connection to the driver.");
            return false;
        }

        // Open port
        List myPortList = driver.getPorts();
        sPort = myPortList.get(0);
        try {
            sPort.open(connection);
            sPort.setParameters(115200, 8, UsbSerialPort.STOPBITS_1, UsbSerialPort.PARITY_NONE);
        } catch (IOException e) {
            tvMsg.setText("Error opening device: " + e.getMessage());
            try {
                sPort.close();
            } catch (IOException e2) {
                // Ignore.ｗ
            }
            sPort = null;
            return false;
        }

        onDeviceStateChange();
        return true;

    }

    private void send() {

        	// 送信コマンドを作成
        	writeBuffer[0] = 0x01; // 測定器の Modbus アドレス
        	writeBuffer[1] = COMMAND; // 命令コマンド
        	writeBuffer[2] = DATA_1; // パラメータ
        	writeBuffer[3] = DATA_2; // パラメータ 
        	writeBuffer[4] = DATA_3; // パラメータ
        	writeBuffer[5] = DATA_4; // パラメータ
        	writeBuffer[6] = CRC1; // Modbus CRC符号
        	writeBuffer[7] = CRC2; // Modbus CRC符号

        try {
            sPort.write(writeBuffer, writeBuffer.length);
        } catch(IOException e){
            Log.e(TAG,e.getMessage());
        }

    }

    private void updateReceivedData(byte[] buffer) {

	// データを受信した場合
        ByteBuffer buffer_wrap = ByteBuffer.wrap(buffer).order(ByteOrder.LITTLE_ENDIAN);

        final String message;
        message = "Statistics : " + der_statistics + "\n"
                + "Dose rate  : " + (String.format("%.2f μSv/h", der)) + "\n"
                + "Dose       : " + (String.format("%.3f mSv", de)) + "\n"
                + "Dose       : " + (String.format("%.3f μSv", de_uSv)) + "\n"
                + "Dose time  : " + (String.format("%d second", de_second)) + "\n";

        tvMsg.setText(message);

    }

}

/***************************************************************
 * Arduino UNO 用のサンプルコード
 *  --- このコードだけでは、動作しません。---
 *  --- 秘密保持契約後に、サンプルコードを提供可能です ---
 *
 *
 *  Arduino UNO は、ハードウェアシリアルポートが一つだけなので、
 *  ハードウェアシリアルポート(ボーレート 115,200) を測定器に利用、
 *  Windows のCOMポートに割り当てられたシリアルモニターが使えなくなるため、
 *  結果の表示に、SoftwareSerial mySerial(11, 12); // RX, TX　を利用しました。
 *
 *  [ Arduino UNO ] --- [UART-RS485変換チップ] ----RS485ケーブル--- [ 測定器 ]
 *      |
 *      |
 *      +------[Serial USB変換器]-----[Windows PC]
 *
 ***************************************************************/


// for Arduino UNO

#include <SoftwareSerial.h>

#define PIN_RTS 3
#define BUFFER 30
int del=100;

SoftwareSerial mySerial(11, 12); // RX, TX

void setup() {
  
// 測定器は、115200 のボーレートが必要なため、Serial を利用。
  Serial.begin(115200);

// 動作結果の表示は、ソフトウェアシリアルを利用する。
// パソコン等につないで、teraTerm で結果を表示する。
  mySerial.begin(9600);

// RS485の送信・通信の制御ピン
  pinMode(PIN_RTS, OUTPUT);
}
void printbyte( byte *cmd, int length ){

// Byte の配列を hex の形で表示する
  int i;
  
  for(i=0;i<length;i++){
    if( ( cmd[i] >> 4 ) == 0 ){
      mySerial.print("0");
    }
    mySerial.print(cmd[i],HEX);
    if( i<length-1 ){
      mySerial.print(",");
    }
  }
  mySerial.print("\r\n");
  
}
void print_der(byte *buf){

  float der;
  int stat;

  union u_tag {
     byte b[4];
     float fval;
  } u;

  stat = buf[4+21];
  u.b[0] = buf[4+14];
  u.b[1] = buf[4+15];
  u.b[2] = buf[4+16];
  u.b[3] = buf[4+17];

  der = u.fval;

  mySerial.print(der,3);
  mySerial.println( " uSv/h");
  
  mySerial.print(stat,DEC);
  mySerial.println( " %");
   
}
void loop() {

  byte cmd[5] = { /* 通信仕様のコマンド */ 0x01, COMMAND, DATA_1, DATA_2, DATA_3, DATA_4, CRC1, CRC2 };
  byte txbuf[BUFFER];
  int i;

// データの書き込み
    mySerial.println("Writing..");
    printbyte(cmd,5);
    
    digitalWrite(PIN_RTS, HIGH);
    
    // RTS(送受信制御)を切り替えた後、少し時間を置いた方がよい
    delayMicroseconds(120); 
    
    for(i=0;i<5;i++){
      Serial.write(cmd[i]);
    }
    // 送信後に、少し時間を置いた方がよい
    delayMicroseconds(400);
    digitalWrite(PIN_RTS, LOW);
    
    // RTS(送受信制御)を切り替えた後、少し時間を置いた方がよい
    delay(15);

// データの受信
    i=0;
    for(i=0;i<BUFFER;i++){
      txbuf[i]=Serial.read() ;
    }
    printbyte(txbuf,BUFFER);
    print_der(txbuf);
  
    delay(1000);

}