package android.serialport.api.sample;

import java.io.InputStream;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.List;

import android.os.Message;

public class KNX_ReceiveAndSend {

	public static List<byte[]> SendDatasList = new ArrayList<byte[]>();
	private static KNX_Serialport mKNX_SerialPort;
	private static OutputStream mOutputStream;
	private static InputStream mInputStream;

	public static void Start(KNX_Serialport _KNX_SerialPort, OutputStream _OutputStream, InputStream _InputStream) {

		mInputStream = _InputStream;
		mKNX_SerialPort = _KNX_SerialPort;
		mOutputStream = _OutputStream;

		// 发送数据线程
		// new SendThread().start();

		new ReceiveThread().start();
	}

	private static class SendThread extends Thread {

		@Override
		public void run() {
			super.run();

			while (true) {

				try {

					Thread.sleep(100);

					for (int i = 0; i < SendDatasList.size(); i++) {

						try {
							Thread.sleep(100);
						} catch (Exception e) {

						}
						try {
							byte[] sendBytes = SendDatasList.get(i);
							try {

								mOutputStream.flush();
								mOutputStream.write(sendBytes);

							} catch (Exception e) {
								e.printStackTrace();
							}
							SendDatasList.remove(i);
							i--;
						} catch (Exception ex) {
							ex.getMessage();
						}
					}
				} catch (Exception e) {
					e.getMessage();
				}
			}
		}
	}

	private static class ReceiveThread extends Thread {

		@Override
		public void run() {
			super.run();

			while (!isInterrupted()) {

				int size = 0;

				try {

					byte[] buffer = new byte[64];

					if (mInputStream == null) {
						return;
					}

					size = mInputStream.read(buffer);

					for (int i = 0; i < size - 1; i++) {

						if ((buffer[i] & 0xFF) == 0xAA) {

							byte bytes[] = new byte[(int) buffer[i + 1]];

							System.arraycopy(buffer, i, bytes, 0, bytes.length);

							// String str = "";
							// for (int j = 0; j < bytes.length; j++) {
							// str += Integer.toHexString(bytes[j] & 0xFF)+".";
							// }

							if (KNX.UART_Receive(bytes)) {

								// 物理地址不处理
								// int individual_addr =
								// KNX.get_Individual_addr();
								Message msg = new Message();
								msg.arg1 = KNX.get_Group_addr();
								msg.arg2 = KNX.get_State();

								Fragment_KNX.mHandler.sendMessage(msg);
							}
						}
					}

				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}
	}
}