package android.serialport.api.sample;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import android.annotation.SuppressLint;
import android.app.Activity;
import android.app.AlertDialog;
import android.content.ContentUris;
import android.content.Context;
import android.content.DialogInterface;
import android.content.Intent;
import android.database.Cursor;
import android.net.Uri;
import android.os.Build;
import android.os.Bundle;
import android.os.Environment;
import android.os.Handler;
import android.os.Message;
import android.provider.DocumentsContract;
import android.provider.MediaStore;
import android.support.v4.app.Fragment;
import android.util.DisplayMetrics;
import android.util.Log;
import android.view.LayoutInflater;
import android.view.View;
import android.view.View.OnClickListener;
import android.view.ViewGroup;
import android.view.WindowManager;
import android.widget.Button;
import android.widget.EditText;
import android.widget.ProgressBar;
import android.widget.TextView;
import android.widget.Toast;
import sendData.Commands;
import sendData.SendDatas;

public class Fragment_Update extends Fragment implements OnClickListener {

	public static Fragment_Update mFragment_Update;
	private byte[] mBuffer;
	private UpgradeThread mThread;
	private static boolean mFlag = false;

	private View mView;
	private Button Btn_Path;
	private Button Btn_Upgrade;
	private EditText EditText_Path;

	private AlertDialog ProDialog;
	private ProgressBar Pro;

	@Override
	public void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
	}

	@Override
	public View onCreateView(LayoutInflater inflater, ViewGroup container, Bundle savedInstanceState) {

		mView = inflater.inflate(R.layout.fragment_upgrade, container, false);

		iniView();

		iniData();

		return mView;
	}

	@Override
	public void onActivityResult(int requestCode, int resultCode, Intent data) {

		String mPath = "";

		if (resultCode == Activity.RESULT_OK) {

			Uri uri = data.getData();

			if (Build.VERSION.SDK_INT > Build.VERSION_CODES.KITKAT) {
				// 大于 android 4.4
				mPath = getPath(getActivity(), uri);
			} else {
				// 小于 android 4.4
				mPath = getRealPathFromURI(uri);
			}
		}

		EditText_Path.setText(mPath + "");
	}

	private String getRealPathFromURI(Uri contentUri) {

		String res = null;
		String[] proj = { MediaStore.Images.Media.DATA };
		Cursor cursor = getActivity().getContentResolver().query(contentUri, proj, null, null, null);
		if (null != cursor && cursor.moveToFirst()) {
			;
			int column_index = cursor.getColumnIndexOrThrow(MediaStore.Images.Media.DATA);
			res = cursor.getString(column_index);
			cursor.close();
		}
		return res;
	}

	/**
	 * 专为Android4.4设计的从Uri获取文件绝对路径，以前的方法已不好使
	 */
	@SuppressLint("NewApi")
	private String getPath(final Context context, final Uri uri) {

		final boolean isKitKat = Build.VERSION.SDK_INT >= Build.VERSION_CODES.KITKAT;

		// DocumentProvider
		if (isKitKat && DocumentsContract.isDocumentUri(context, uri)) {
			// ExternalStorageProvider
			if (isExternalStorageDocument(uri)) {
				final String docId = DocumentsContract.getDocumentId(uri);
				final String[] split = docId.split(":");
				final String type = split[0];

				if ("primary".equalsIgnoreCase(type)) {
					return Environment.getExternalStorageDirectory() + "/" + split[1];
				}
			}
			// DownloadsProvider
			else if (isDownloadsDocument(uri)) {

				final String id = DocumentsContract.getDocumentId(uri);
				final Uri contentUri = ContentUris.withAppendedId(Uri.parse("content://downloads/public_downloads"),
						Long.valueOf(id));

				return getDataColumn(context, contentUri, null, null);
			}
			// MediaProvider
			else if (isMediaDocument(uri)) {
				final String docId = DocumentsContract.getDocumentId(uri);
				final String[] split = docId.split(":");
				final String type = split[0];

				Uri contentUri = null;
				if ("image".equals(type)) {
					contentUri = MediaStore.Images.Media.EXTERNAL_CONTENT_URI;
				} else if ("video".equals(type)) {
					contentUri = MediaStore.Video.Media.EXTERNAL_CONTENT_URI;
				} else if ("audio".equals(type)) {
					contentUri = MediaStore.Audio.Media.EXTERNAL_CONTENT_URI;
				}

				final String selection = "_id=?";
				final String[] selectionArgs = new String[] { split[1] };

				return getDataColumn(context, contentUri, selection, selectionArgs);
			}
		}
		// MediaStore (and general)
		else if ("content".equalsIgnoreCase(uri.getScheme())) {
			return getDataColumn(context, uri, null, null);
		}
		// File
		else if ("file".equalsIgnoreCase(uri.getScheme())) {
			return uri.getPath();
		}
		return null;
	}

	/**
	 * Get the value of the data column for this Uri. This is useful for
	 * MediaStore Uris, and other file-based ContentProviders.
	 * 
	 * @param context
	 *            The context.
	 * @param uri
	 *            The Uri to query.
	 * @param selection
	 *            (Optional) Filter used in the query.
	 * @param selectionArgs
	 *            (Optional) Selection arguments used in the query.
	 * @return The value of the _data column, which is typically a file path.
	 */
	private String getDataColumn(Context context, Uri uri, String selection, String[] selectionArgs) {

		Cursor cursor = null;
		final String column = "_data";
		final String[] projection = { column };

		try {
			cursor = context.getContentResolver().query(uri, projection, selection, selectionArgs, null);
			if (cursor != null && cursor.moveToFirst()) {
				final int column_index = cursor.getColumnIndexOrThrow(column);
				return cursor.getString(column_index);
			}
		} finally {
			if (cursor != null)
				cursor.close();
		}
		return null;
	}

	/**
	 * @param uri
	 *            The Uri to check.
	 * @return Whether the Uri authority is ExternalStorageProvider.
	 */
	private boolean isExternalStorageDocument(Uri uri) {
		return "com.android.externalstorage.documents".equals(uri.getAuthority());
	}

	/**
	 * @param uri
	 *            The Uri to check.
	 * @return Whether the Uri authority is DownloadsProvider.
	 */
	private boolean isDownloadsDocument(Uri uri) {
		return "com.android.providers.downloads.documents".equals(uri.getAuthority());
	}

	/**
	 * @param uri
	 *            The Uri to check.
	 * @return Whether the Uri authority is MediaProvider.
	 */
	private boolean isMediaDocument(Uri uri) {
		return "com.android.providers.media.documents".equals(uri.getAuthority());
	}

	private void iniView() {
		//
		Btn_Path = (Button) mView.findViewById(R.id.Btn_path);
		Btn_Path.setOnClickListener(this);
		Btn_Upgrade = (Button) mView.findViewById(R.id.Btn_Upgrade);
		Btn_Upgrade.setOnClickListener(this);
		EditText_Path = (EditText) mView.findViewById(R.id.EditText_Path);

		ProDialog = new AlertDialog.Builder(getActivity(), R.style.Theme_Transparent).create();

		LayoutInflater inflater = LayoutInflater.from(getActivity());
		final View tmpickerview = inflater.inflate(R.layout.dialog_pro, null);
		ProDialog.setView(tmpickerview);
		Pro = (ProgressBar) tmpickerview.findViewById(R.id.pro);
	}

	private void iniData() {
		mFlag = false;
		mFragment_Update = this;
	}

	private void showPro() {

		Pro.setProgress(0);
		ProDialog.show();
		ProDialog.setTitle("upgrading, please do not operate it.");
		WindowManager.LayoutParams lp = ProDialog.getWindow().getAttributes();
		lp.width = 700;
		lp.height = 80;
		ProDialog.getWindow().setAttributes(lp);
	}

	private void hidePro() {
		ProDialog.dismiss();
	}

	private void NoticeDialog(String str) {
		//
		new AlertDialog.Builder(getActivity(), R.style.Theme_Transparent_NoTitle).setMessage(str)
				.setPositiveButton("OK", new DialogInterface.OnClickListener() {

					@Override
					public void onClick(DialogInterface dialog, int which) {
						dialog.dismiss();
					}
				}).create().show();
	}

	private byte[] getBytes(int index) {

		// try {

		int count = mBuffer.length / 64;
		int b = mBuffer.length % 64;
		if (b != 0) {
			count = count + 1;
		}

		//
		// int count = (mBuffer.length / 64) + (mBuffer.length % 64 == 0 ? 0
		// : 1);

		byte[] _bytes;

		if (index > count) {
			// 当index大于count的时候，代表升级成功
			mFragment_Update.mUpdataHandler.sendEmptyMessage(2);
			return null;
		}

		if (index == count) {
			// 最后一条
			_bytes = new byte[(mBuffer.length - (index - 1) * 64) + 2];

		} else {

			_bytes = new byte[64 + 2];
		}

		_bytes[0] = (byte) (index / 256);
		_bytes[1] = (byte) (index % 256);

		System.arraycopy(mBuffer, (index - 1) * 64, _bytes, 2, _bytes.length - 2);

		Message msg = new Message();
		msg.arg1 = (index * 100) / count;
		msg.what = 0;
		mFragment_Update.mUpdataHandler.sendMessage(msg);

		return _bytes;

		// } catch (Exception e) {
		// mFragment_Update.mUpdataHandler.sendEmptyMessage(1);
		// Log.e("asdf", e.getMessage().toString());
		// return null;
		// }
	}

	private void SendUpgradeData(final int index) {

		new Thread(new Runnable() {

			@Override
			public void run() {

				try {

					byte[] _bytes = getBytes(index);

					if (_bytes == null) {
						//
						return;
					}

					byte[] sendBytes = SendDatas.AddSendData(Commands.DataRequest_ACK.getCommand(), Global.SubNet_Id,
							Global.Device_Id, _bytes);

					ReceiveAndSend.SendDatasList.add(sendBytes);

					Log.i("asd", "发送第" + index + "条数据包" + _bytes.length);

				} catch (Exception e) {
					mFragment_Update.mUpdataHandler.sendEmptyMessage(1);
					e.getMessage();
				}
			}
		}).start();
	}

	private void SendUpgradeDataLength() {

		try {

			int count = (mBuffer.length / 64) + (mBuffer.length % 64 == 0 ? 0 : 1);

			byte[] _byte = new byte[4];
			_byte[0] = 0;
			_byte[1] = 0;
			_byte[2] = (byte) (count / 256);
			_byte[3] = (byte) (count % 256);

			byte[] sendBytes = SendDatas.AddSendData(Commands.DataRequest_ACK.getCommand(), Global.SubNet_Id,
					Global.Device_Id, _byte);
			Global.mOutputStream.flush();
			Global.mOutputStream.write(sendBytes);

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

	@Override
	public void onClick(View v) {

		if (v.equals(Btn_Path)) {
			// 查找文件路径
			Intent intent = new Intent(Intent.ACTION_GET_CONTENT);
			intent.setType("*/*");
			intent.addCategory(Intent.CATEGORY_OPENABLE);
			startActivityForResult(intent, 1);

		} else if (v.equals(Btn_Upgrade)) {
			// 升级
			if (EditText_Path.getText().toString().equals("")) {
				NoticeDialog("The path cannot be empty.");
				return;
			}
			File file = new File(EditText_Path.getText().toString());
			String name = file.getName();
			String prefix = name.substring(name.lastIndexOf(".") + 1).toUpperCase();

			if (!prefix.equals("BIN")) {
				new AlertDialog.Builder(getActivity()).setMessage("File type error !").create().show();
				return;
			}

			// 读取文件
			try {

				FileInputStream fis = new FileInputStream(file);
				int length = fis.available();
				mBuffer = new byte[length];
				fis.read(mBuffer);

				if (mBuffer.length > 256 * 1024) {
					new AlertDialog.Builder(getActivity()).setMessage("File Error !").create().show();
					return;
				}

				mFlag = true;
				mThread = new UpgradeThread();
				mThread.start();

				showPro();

			} catch (IOException e) {
				mFlag = false;
				e.printStackTrace();
			}
		}
	}

	public Handler mHandler = new Handler() {

		@Override
		public void handleMessage(Message msg) {

			if (mBuffer == null)
				return;

			if (msg.what == 0) {
				// 接收到的是备注，回复数据包长度
				Log.i("asd", "接收到的是备注，回复数据包长度");
				SendUpgradeDataLength();
			} else {
				// 发送对应的数据
				Log.i("asd", "发送对应的数据");
				SendUpgradeData(msg.what);
			}
		}
	};

	private Handler mUpdataHandler = new Handler() {

		@Override
		public void handleMessage(Message msg) {

			switch (msg.what) {
			case 0:
				Pro.setProgress(msg.arg1);
				break;
			case 1:
				hidePro();
				NoticeDialog("Upgrade Failed !");
				break;
			case 2:
				hidePro();
				NoticeDialog("Upgrade Succeed !");
				break;
			default:
				break;
			}
		}

	};

	@Override
	public void onStart() {
		super.onStart();
	}

	@Override
	public void onStop() {
		super.onStop();
	}

	@Override
	public void onDestroy() {
		super.onDestroy();
	}

	private class UpgradeThread extends Thread {

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

			int i = 0;

			while (mFlag) {

				try {
					if (i > 20) {
						// 发送20次没有成功就直接退出了
						mFlag = false;
						Log.i("asdf", "发送wan了读取备注命令");
						return;
					}

					i++;
					byte[] sendBytes = SendDatas.AddSendData(Commands.readRemark.getCommand(), Global.SubNet_Id,
							Global.Device_Id, new byte[] {});
					Global.mOutputStream.flush();
					Global.mOutputStream.write(sendBytes);

					Log.i("asdf", "发送了读取备注命令");
					sleep(30);

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