// コンストラクタ
	public BlueTooth(string portName, int bauRate, string p, Delegate function) {
	    serialPort = new SerialPort(portName, bauRate, parity, 8, StopBits.One);
	    serialPort.WriteBufferSize = 32 * 1024; // 送信データサイズ（32KB）
	    serialPort.ReadBufferSize = 32 * 1024; // 受信データサイズ（32KB）
	    callback = function;
	    serialPort.DataReceived += new SerialDataReceivedEventHandler(ReceiveMsg);
	}

	// シリアルポートオープン
        public bool PortOpen() {
            bool isOpen = false;
            // ポートが開放されていない場合は開放する
            if (!serialPort.IsOpen) {
                serialPort.Open();
            }
            if (serialPort.IsOpen) {
		receiveDataLengthBuffer = new StringBuilder();
		receiveDataBuffer = new StringBuilder();
		receiveFlg = false;
                isOpen = true;
            }
            return isOpen;
        }

	// シリアルポートクローズ
        public void PortClose() {
            // ポートオープン前はオブジェクトが無い為何もしない
            if (serialPort.IsOpen) {
                serialPort.Close();
            }
        }

        // 電文送信
        public int SendMsg(string msg) {
            // シリアルポートがオープンされていれば電文を送信する。
            if (serialPort.IsOpen) {
                if (!string.IsNullOrEmpty(msg)) {
                    // 引数がnullもしくは""でなければ送信
                    // Base64エンコード
                    msg = Utility.EncodeBase64(msg);
                    // JIS-8単位符号化
                    byte[] msgArray = Utility.EncodeJis8(msg);
                    // TLV形式に変換
                    string tlvString = Utility.CreateMassageTLV(msgArray);
                    // 32KBで分割して送信
                    int stringSize = 2 * 32 * 1024; // 最大送信データサイズ：1バイト当り2文字×32KB
                    int subStringIndex = 0;
                    while (subStringIndex < tlvString.Length) {
                        // 未送信の電文が残っている場合
                        string tempStr;
                        if (tlvString.Substring(subStringIndex).Length > stringSize) {
                            // 残りの電文内容の文字数が最大送信データサイズより大きい場合
                            // 残りの文字列から最大送信データサイズ分だけ取り出す
                            tempStr = tlvString.Substring(subStringIndex, stringSize);
                        } else {
                            // 残りの電文内容の文字数が最大送信データサイズに収まる場合
                            // 残りの文字列を取り出す
                            tempStr = tlvString.Substring(subStringIndex);
                        }
                        // 電文送信
                        byte[] sendDataByte = Utility.HexToByte(tempStr);
                        SendData(sendDataByte, 0, sendDataByte.Length);
                        // 未送信の電文の開始位置の更新
                        subStringIndex += tempStr.Length;
                    }
                    return 0;
                } else {
                    // 引数がnullもしくは""であれば1(エラー)を返却
                    return 1;
                }
            } else {
                // ポートが開いてなければ1(エラー)を返却
                return 1;
            }
        }

	// シリアル送信
        void SendData(byte[] data, int i, int length) {
            serialPort.Write(data, i, length);
        }

        // 電文受信
        void ReceiveMsg(object sender, SerialDataReceivedEventArgs e) {
            string outmsg = "";
            // 受信データを読み込む
            int rbyte = serialPort.BytesToRead;
            byte[] buffer = new byte[rbyte];
            int read = 0;
            while (read < rbyte) {
                int length = serialPort.Read(buffer, read, rbyte - read);
                read += length;
            }
            string readDataStr = Utility.ToHexString(buffer, buffer.Length);
            // 受信データの識別子をチェックする
            if (readDataStr.Substring(0, 2) == "ff") {
                receiveDataLengthBuffer.Clear();
                receiveDataBuffer.Clear();
                readDataStr = readDataStr.Substring(2);
                receiveFlg = true;
            }
            // 受信データのデータ部レングスをチェックする
            if (receiveFlg) {
                for (int i = 0; i < readDataStr.Length; i++) {
                    if (receiveDataLengthBuffer.Length < 8) {
                        // 受信データのデータ部レングスが8バイトになるまで、データ部レングスバッファに1バイトずつ積込む
                        receiveDataLengthBuffer.Append(readDataStr[i]);
                    } else {
                        // データ部レングスが8バイトに満たした場合、残りのデータをデータ部バッファに積込む
                        receiveDataBuffer.Append(readDataStr[i]);
                    }
                }
            }
            // 受信データのデータ部をチェックする
            if (receiveDataBuffer.Length == int.Parse(receiveDataLengthBuffer.ToString())) {
                receiveFlg = false;
                byte[] msgArray = Utility.HexToByte(receiveDataBuffer.ToString());
                // JIS-8単位符号復号化
                string msg = Utility.DecodeJis8(msgArray);
                // Base64デコード
                outmsg = Utility.DecodeBase64(msg);
                // 電文を返却
                callback(outmsg);
            }
        }
    }
}

namespace Util {
    public static class Utility {
        // Base64エンコード
        public static string EncodeBase64(string msg) {
            return Convert.ToBase64String(Encoding.UTF8.GetBytes(msg), Base64FormattingOptions.InsertLineBreaks);
        }

        // Base64デコード
        public static string DecodeBase64(string msg) {
            return Encoding.UTF8.GetString(Convert.FromBase64String(msg));
        }

        // JIS8単位符号化
        public static byte[] EncodeJis8(string msg) {
            return Encoding.UTF8.GetBytes(msg);
        }

        // JIS8単位符号復号化
        public static string DecodeJis8(byte[] msgArray) {
            return Encoding.UTF8.GetString(msgArray);
        }

        //16進数復元処理
        public static byte[] HexToByte(string hexStr) {
            int strLength = hexStr.Length / 2;
            byte[] bytes = new byte[strLength];
            int j = 0;
            for (int i = 0; i < strLength; i++) {
                bytes[i] = Convert.ToByte(hexStr.Substring(j, 2), 16);
                j += 2;
            }
            return bytes;
        }

        //16進文字列変換処理
        public static string ToHexString(byte[] bytes, int size) {
            StringBuilder sb = new StringBuilder(size * 2);
            for (int i = 0; i < size; i++) {
              if (bytes[i] < 16) {
                sb.Append('0');
              }
              sb.Append(Convert.ToString(bytes[i], 16));
            }
            return sb.ToString();
        }

        //TLV形式変換
        public static string CreateMassageTLV(byte[] msgArray) {
            StringBuilder sendDataSb = new StringBuilder();
            string hexStr = BitConverter.ToString(msgArray);
            hexStr = hexStr.Replace("-", "");
            sendDataSb.Append("ff");
            sendDataSb.Append(string.Format("{0:00000000}", hexStr.Length));
            sendDataSb.Append(hexStr);
            return sendDataSb.ToString();
        }
    }
}