package android.serialport.api.sample;

import java.util.List;
import java.io.IOException;
import java.util.ArrayList;
import android.os.Message;
import android.widget.Toast;
import sendData.Commands;
import sendData.SendDatas;

import java.security.InvalidParameterException;

public class ReceiveAndSend {

	public static List<byte[]> SendDatasList = new ArrayList<byte[]>();

	public static void Start() {

		getSerialPort();

		new SendThread().start();

		new SendDatasThread().start();

		new ReadThread().start();
	}

	/**
	 * Open the serial port, input and output streams
	 */
	public static void getSerialPort() {

		Global.mApplication = new Application();

		try {

			Global.mSerialPort = Global.mApplication.getSerialPort();
			Global.mOutputStream = Global.mSerialPort.getOutputStream();
			Global.mInputStream = Global.mSerialPort.getInputStream();
			if (MainActivity.CuttentActivity.mFragment_BUS != null) {
				Global.BUS bus = new Global.BUS();
				Message msg = new Message();
				msg.obj = bus;

				bus.index = 11;
				bus.value = 1;
				bus.value2 = 1;

				MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);
			}
		} catch (SecurityException e) {
			if (MainActivity.CuttentActivity.mFragment_BUS != null) {
				Global.BUS bus = new Global.BUS();
				Message msg = new Message();
				msg.obj = bus;

				bus.index = 11;
				bus.value = 0;
				bus.value2 = 0;

				MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);

				msg = new Message();
				bus.index = -1;
				bus.str = "You do not have read/write permission to the serial port.";
				MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);
			}
		} catch (IOException e) {

			if (MainActivity.CuttentActivity.mFragment_BUS != null) {
				Global.BUS bus = new Global.BUS();
				Message msg = new Message();
				msg.obj = bus;

				bus.index = 11;
				bus.value = 0;
				bus.value2 = 0;

				MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);

				msg = new Message();
				bus.index = -1;
				bus.str = "The serial port can not be opened for an unknown reason.";

				MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);
			}
		} catch (InvalidParameterException e) {

			if (MainActivity.CuttentActivity.mFragment_BUS != null) {
				Global.BUS bus = new Global.BUS();
				Message msg = new Message();
				msg.obj = bus;

				bus.index = 11;
				bus.value = 0;
				bus.value2 = 0;

				MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);

				msg = new Message();
				bus.index = -1;
				bus.str = "error_configuration";

				MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);
			}
		}
	}

	/**
	 * Read data thread
	 * 
	 * @author 2017年12月19日
	 */
	private static class ReadThread extends Thread {

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

			while (!isInterrupted()) {
				int size = 0;

				try {
					byte[] buffer = new byte[64];
					if (Global.mInputStream == null) {
						return;
					}
					size = Global.mInputStream.read(buffer);

					// Log.i("asdfg", Integer.toHexString(((buffer[7] & 0xFF) *
					// 256) + (buffer[8] & 0xFF)) + "");

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

						if (i != 0) {
							if ((buffer[i] & 0xFF) == 0xAA && (buffer[i + 1] & 0xFF) == 0xAA) {
								//
								byte[] _bf = new byte[i];
								System.arraycopy(buffer, 0, _bf, 0, i);

								if (_bf.length >= 13) {
									int command = (buffer[7] & 0xFF) * 256 + (buffer[8] & 0xFF);
									if (command == Commands.ReadTimeFeedback.getCommand()
											|| command == Commands.DryContactInitiativeToSend.getCommand()
											|| command == Commands.READ_TEMP_WITH_DRY1_ACK.getCommand()
											|| command == Commands.InductorState.getCommand()
											|| command == Commands.SensorBack.getCommand()
											|| command == Commands.ClickState.getCommand()
											|| command == Commands.ReadID_ACK.getCommand()
											|| command == Commands.WriteID_ACK.getCommand()
											|| command == Commands.DataRequest.getCommand()
											|| command == Commands.readRemark_ACK.getCommand()) {
										onDataReceived(buffer, size);
									}
								}

								byte[] _bf2 = new byte[size - i];
								System.arraycopy(buffer, i, _bf2, 0, size - i);
								if (_bf2.length >= 13) {
									int command = (buffer[7] & 0xFF) * 256 + (buffer[8] & 0xFF);
									if (command == Commands.ReadTimeFeedback.getCommand()
											|| command == Commands.DryContactInitiativeToSend.getCommand()
											|| command == Commands.READ_TEMP_WITH_DRY1_ACK.getCommand()
											|| command == Commands.InductorState.getCommand()
											|| command == Commands.SensorBack.getCommand()
											|| command == Commands.ClickState.getCommand()
											|| command == Commands.ReadID_ACK.getCommand()
											|| command == Commands.WriteID_ACK.getCommand()
											|| command == Commands.DataRequest.getCommand()
											|| command == Commands.readRemark_ACK.getCommand()) {
										onDataReceived(buffer, size);
									}
								}
							}
						} else {
							if (size >= 13) {
								int command = (buffer[7] & 0xFF) * 256 + (buffer[8] & 0xFF);
								if (command == Commands.ReadTimeFeedback.getCommand()
										|| command == Commands.DryContactInitiativeToSend.getCommand()
										|| command == Commands.READ_TEMP_WITH_DRY1_ACK.getCommand()
										|| command == Commands.InductorState.getCommand()
										|| command == Commands.SensorBack.getCommand()
										|| command == Commands.ClickState.getCommand()
										|| command == Commands.ReadID_ACK.getCommand()
										|| command == Commands.WriteID_ACK.getCommand()
										|| command == Commands.DataRequest.getCommand()
										|| command == Commands.readRemark_ACK.getCommand()) {
									onDataReceived(buffer, size);
								}
							}
						}
					}
				} catch (Exception e) {
					e.printStackTrace();
					return;
				}
			}
		}
	}

	private static void onDataReceived(final byte[] buffer, final int size) {

		if (MainActivity.CuttentActivity.mFragment_BUS == null)
			return;

		Global.BUS bus = new Global.BUS();
		Message msg = new Message();
		try {

			int command = (buffer[7] & 0xFF) * 256 + (buffer[8] & 0xFF);

			if (command == Commands.ReadTimeFeedback.getCommand()) {
				//
			} else if (command == Commands.DryContactInitiativeToSend.getCommand()) {

				try {
					Global.mOutputStream
							.write(SendDatas.AddSendData(Commands.DryContactInitiativeToSendFeedback.getCommand(),
									Global.SubNet_Id, Global.Device_Id, new byte[] { (byte) 0xf8 }));
				} catch (Exception e) {
					e.printStackTrace();
				}

				bus.index = 1;
				bus.contact1 = buffer[11] & 0xFF;
				bus.contact2 = buffer[12] & 0xFF;
				bus.contact3 = buffer[13] & 0xFF;
				bus.contact4 = buffer[14] & 0xFF;
				bus.contact5 = buffer[15] & 0xFF;
				bus.contact6 = buffer[16] & 0xFF;

				msg.obj = bus;
				MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);

			} else if (command == Commands.READ_TEMP_WITH_DRY1_ACK.getCommand()) {// 读取温度

				int value = (int) (buffer[11] & 0xFF);

				if ((buffer[13] & 0xFF) == 0) {
					// 单位摄氏度
					bus.index = 7;
					bus.value = 0;
					bus.value2 = value;

					msg.obj = bus;
					MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);

				} else {
					// 华氏度
					bus.index = 7;
					bus.value = 1;
					bus.value2 = value;

					msg.obj = bus;
					MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);

				}

			} else if (command == Commands.SensorBack.getCommand()) {
				// 传感器灵敏度
				bus.index = 8;
				bus.value = (int) (buffer[12] & 0xFF);
				bus.value2 = (int) (buffer[12] & 0xFF);

				msg.obj = bus;
				MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);

			} else if (command == Commands.InductorState.getCommand()) {

				bus.index = 9;
				bus.value = 0;
				bus.value2 = 0;

				msg.obj = bus;
				MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);

			} else if (command == Commands.ClickState.getCommand()) {
				int key = buffer[12] & 0xFF;
				switch (key) {
				case 0:// 弹起
					bus.index = 109;
					bus.value = 0;
					bus.value2 = 0;

					msg.obj = bus;
					MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);
					break;
				case 1:// 按下
					bus.index = 10;
					bus.value = 1;
					bus.value2 = 0;

					msg.obj = bus;
					MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);
					break;
				case 2:// 长按
					bus.index = 10;
					bus.value = 2;
					bus.value2 = 0;

					msg.obj = bus;
					MainActivity.CuttentActivity.mFragment_BUS.mHandler.sendMessage(msg);
					break;
				}
			} else if (command == Commands.SET_TEMP_COMPENSATE_VALUE_ACK.getCommand()) {
				if ((buffer[11] & 0xFF) == 0xF5) {
					Toast.makeText(MainActivity.CuttentActivity, "set compensate value failed", Toast.LENGTH_SHORT)
							.show();
				}
			} else if (command == Commands.WriteID_ACK.getCommand()) {
				// 写入ID返回
				if ((buffer[11] & 0xFF) == 0xF5) {
					NavigationDrawerFragment.mNavigationDrawerFragment.mHandler.sendEmptyMessage(0);
				} else if ((buffer[11] & 0xFF) == 0xF8) {
					NavigationDrawerFragment.mNavigationDrawerFragment.mHandler.sendEmptyMessage(1);
				}

			} else if (command == Commands.ReadID_ACK.getCommand()) {
				// 读取返回
				bus.value = buffer[11] & 0xFF;
				bus.value2 = buffer[12] & 0xFF;

				msg.obj = bus;
				NavigationDrawerFragment.mNavigationDrawerFragment.mHandler_Data.sendMessage(msg);
			} else if (command == Commands.DataRequest.getCommand()) {
				// 读取备注返回 / 设备升级 0x15FE buffer[11] buffer[12] 都为0的话，就是备注
				// Log.i("asdfg", "设备升级 0x15FE");
				int index = (buffer[11] & 0xFF) * 256 + (buffer[12] & 0xFF);// 请求的是第几条包
				Fragment_Update.mFragment_Update.mHandler.sendEmptyMessage(index);
			}

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

	/**
	 * 2015.12.10 读取温度
	 */
	private static class SendThread extends Thread {

		@Override
		public void run() {
			super.run();
			while (true) {
				try {
					byte[] sendBytes = SendDatas.AddSendData(Commands.READ_TEMP_WITH_DRY1.getCommand(),
							Global.SubNet_Id, Global.Device_Id, new byte[] {});
					Global.mOutputStream.flush();
					Global.mOutputStream.write(sendBytes);
					sleep(1000);
				} catch (Exception e) {
					//
					continue;
				}
			}
		}
	}

	private static class SendDatasThread extends Thread {

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

			while (true) {

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

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

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

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

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

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