/*
 * Copyright © 2012-2013 LiuZhongnan. All rights reserved.
 * 
 * Email:qq81595157@126.com
 * 
 * PROPRIETARY/CONFIDENTIAL.
 */

package com.youku.service.download;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Map.Entry;

import android.content.Intent;
import android.os.Handler;
import android.os.HandlerThread;
import android.os.Message;
import android.widget.Toast;

import com.baseproject.utils.Logger;
import com.youku.player.YoukuPlayerConfiguration;
import com.youku.player.ui.R;
import com.youku.player.util.PlayerUtil;
import com.youku.service.download.SDCardManager.SDCardInfo;

/**
 * FileCreateThread.创建下载视频文件
 * 
 * @author 刘仲男 qq81595157@126.com
 * @version v3.5
 * @created time 2012-10-15 下午4:03:24
 */
public class FileCreateThread extends Thread {

	private static final String TAG = "Download_CreateRunnable";
	private static final String pageName = "缓存模块";
	private DownloadServiceManager download;
	// private Activity activity;
	/** 添加等待队列，防止重复添加 */
	private ArrayList<DownloadInfo> download_temp_infos;
	public static Map<String, String> tempCreateData;
	private int successCount = 0;
	private int failCount = 0;
	private boolean hasMaryPaths = false;
	private static boolean isRunning = false;

	public static boolean isRunning() {
		return isRunning;
	}

	public FileCreateThread(String videoId, String videoName) {
		download = DownloadServiceManager.getInstance();
		isRunning = true;
		if (download_temp_infos == null)
			download_temp_infos = new ArrayList<DownloadInfo>();
		if (tempCreateData == null)
			tempCreateData = new HashMap<String, String>();
		if (tempCreateData.containsKey(videoId)) {
			return;
		}
		DownloadInfo info;
		Logger.d(TAG, "title:" + videoName + "/vid:" + videoId);
		info = new DownloadInfo();
		info.videoid = videoId;
		info.title = videoName;
		info.format = DownloadUtils.getDownloadFormat();
		info.language = DownloadUtils.getDownloadLanguageName();
		info.savePath = download.getCurrentDownloadSDCardPath()
				+ YoukuPlayerConfiguration.getDownloadPath() + info.videoid + "/";
		download_temp_infos.add(info);
		tempCreateData.put(info.videoid, "");
	}

	public FileCreateThread(String[] vids, String[] titles) {
		download = DownloadServiceManager.getInstance();
		isRunning = true;
		if (download_temp_infos == null)
			download_temp_infos = new ArrayList<DownloadInfo>();
		if (tempCreateData == null)
			tempCreateData = new HashMap<String, String>();
		int format = DownloadUtils.getDownloadFormat();
		String language = DownloadUtils.getDownloadLanguageName();
		String path = download.getCurrentDownloadSDCardPath();
		DownloadInfo info;
		for (int i = 0, n = vids.length; i < n; i++) {
			Logger.d(TAG, "titles:" + titles[i] + "/vids:" + vids[i]);
			if (tempCreateData.containsKey(vids[i])) {
				continue;
			}
			info = new DownloadInfo();
			info.title = titles[i];
			info.videoid = vids[i];
			info.format = format;
			info.language = language;
			info.savePath = path + YoukuPlayerConfiguration.getDownloadPath() + info.videoid + "/";
			download_temp_infos.add(info);
			tempCreateData.put(info.videoid, "");
		}
	}

	private void over() {
		YoukuPlayerConfiguration.context.sendBroadcast(new Intent(
				IDownload.ACTION_CREATE_DOWNLOAD_ALL_READY));
		download_temp_infos.clear();
		isRunning = false;
	}

	@Override
	public void run() {
		for (DownloadInfo info : download_temp_infos) {
			if (download.existsDownloadInfo(info.videoid)) {
				if (download.isDownloadFinished(info.videoid)) {// 已下载完成
					PlayerUtil.showTips(R.string.download_exist_finished);
				} else {
					PlayerUtil.showTips(R.string.download_exist_not_finished);
				}
				continue;
			}
			long time = System.currentTimeMillis();
			info.createTime = time;
			info.taskId = String.valueOf(time).substring(5);// 用时间戳做ID
			if (init(info)) {
				Logger.d("DownloadFlow","init() success");
				download.addDownloadingInfo(info);
				switch (info.format) {
				case DownloadInfo.FORMAT_HD2:
					break;
				case DownloadInfo.FORMAT_MP4:
					break;
				default:
					break;
				}
				successCount++;
				YoukuPlayerConfiguration.context.sendBroadcast(new Intent(
						IDownload.ACTION_CREATE_DOWNLOAD_ONE_READY));
			} else {
				Logger.d("DownloadFlow","init() fail");
				failCount++;
				YoukuPlayerConfiguration.context.sendBroadcast(new Intent(
						IDownload.ACTION_CREATE_DOWNLOAD_ONE_FAILED));
				if (info.getExceptionId() == DownloadInfo.EXCEPTION_NO_SPACE) {// 没有空间，提示切换空间
					failCount = download_temp_infos.size() - successCount;
					ArrayList<SDCardInfo> card = SDCardManager
							.getExternalStorageDirectory();
					if (card != null && card.size() > 1) {
						hasMaryPaths = true;
						HandlerThread ht = new HandlerThread("handler_thread1");
						ht.start();
						new Handler(ht.getLooper()) {
							public void handleMessage(Message msg) {
/*								YoukuPlayerConfiguration.context
										.startActivity(new Intent(
												YoukuPlayerConfiguration.context,
												EmptyActivity.class)
												.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK));*/
								Toast.makeText(YoukuPlayerConfiguration.context, "存储空间不足", Toast.LENGTH_SHORT).show();
							};

						}.sendEmptyMessageDelayed(0, 500L);

					}
					break;
				}
				continue;
			}
		}
		for (DownloadInfo info : download_temp_infos) {
			tempCreateData.remove(info.videoid);
		}
		showTips();
		over();
		HandlerThread ht = new HandlerThread("handler_thread2");
		ht.start();
		new Handler(ht.getLooper()) {
			public void handleMessage(Message msg) {
				Logger.d("DownloadFlow","FileCreateThread: create task to download");
				download.startNewTask();
			};

		}.sendEmptyMessageDelayed(0, 1000L);
		super.run();
	}

	private void showTips() {
		if (download_temp_infos.size() == successCount) {// 全部成功
			PlayerUtil.showTips(R.string.download_add_success);
			return;
		} else if (download_temp_infos.size() == 1) {// 单个添加失败
			if (hasMaryPaths == false) {
				String e = download_temp_infos.get(0).getExceptionInfo();
				if (e != null && e.length() != 0){
					PlayerUtil.showTips(e);
					Logger.e("DownloadFlow",e);
				}

					
			}
			return;
		}
		// 多个添加失败
		int differenceFailCount = 0;// 不同错误的数量
		int exceptionId = -1;
		for (DownloadInfo info : download_temp_infos) {
			if (info.getExceptionId() != 0) {
				if (info.getExceptionId() != exceptionId) {
					exceptionId = info.getExceptionId();
					differenceFailCount++;
				}
			}
		}

		if (differenceFailCount == 1) {// 只有一种错误原因的
			switch (exceptionId) {
			case DownloadInfo.EXCEPTION_NO_SDCARD:
			case DownloadInfo.EXCEPTION_NO_NETWORK:
				break;
			case DownloadInfo.EXCEPTION_NO_SPACE:
				if (hasMaryPaths == false) {
					String e = YoukuPlayerConfiguration.context.getResources().getString(
							R.string.download_many_fail_no_space);
					e = e.replace("S", String.valueOf(successCount));
					e = e.replace("F", String.valueOf(failCount));
					PlayerUtil.showTips(e);
				}
				break;
			case DownloadInfo.EXCEPTION_NO_COPYRIGHT:
			case DownloadInfo.EXCEPTION_NO_RESOURCES:
			case DownloadInfo.EXCEPTION_HTTP_NOT_FOUND:
				String e = YoukuPlayerConfiguration.context.getResources().getString(
						R.string.download_many_fail);
				e = e.replace("S", String.valueOf(successCount));
				e = e.replace("F", String.valueOf(failCount));
				PlayerUtil.showTips(e);
				break;
			case DownloadInfo.EXCEPTION_TIMEOUT:
				e = YoukuPlayerConfiguration.context.getResources().getString(
						R.string.download_many_fail_timeout);
				e = e.replace("S", String.valueOf(successCount));
				e = e.replace("F", String.valueOf(failCount));
				PlayerUtil.showTips(e);
				break;
			case DownloadInfo.EXCEPTION_WRITE_ERROR:
			case DownloadInfo.EXCEPTION_UNKNOWN_ERROR:
				e = YoukuPlayerConfiguration.context.getResources().getString(
						R.string.download_many_fail_unknown_error);
				e = e.replace("S", String.valueOf(successCount));
				e = e.replace("F", String.valueOf(failCount));
				PlayerUtil.showTips(e);
				break;
			default:
				break;
			}
		} else if (differenceFailCount > 1) {// 有两种不同错误以上
			String s = YoukuPlayerConfiguration.context.getResources().getString(
					R.string.download_many_fail_unknown_error);
			s = s.replace("S", String.valueOf(successCount));
			s = s.replace("F", String.valueOf(failCount));
			PlayerUtil.showTips(s);
		}
	}

	private boolean init(final DownloadInfo info) {
		info.setState(DownloadInfo.STATE_INIT);
		if (!DownloadUtils.getDownloadData(info)) {
			return false;
		}
		if (!DownloadUtils.getVideoInfo(info)) {
			return false;
		}
		if (hasEnoughSpace(info.size)) {
			new Thread() {
				public void run() {
					DownloadUtils.createVideoThumbnail(info.imgUrl,
							info.savePath);
				};
			}.start();
			DownloadUtils.makeM3U8File(info);
		} else {
			info.setExceptionId(DownloadInfo.EXCEPTION_NO_SPACE);
			return false;
		}
		if (!DownloadUtils.makeDownloadInfoFile(info)) {
			return false;
		}
		Logger.d("DownloadFlow","FileCreateThread: init() end: return true");
		info.downloadListener = new DownloadListenerImpl(YoukuPlayerConfiguration.context, info);
		return true;
	}

	/***
	 * 是否有足够的空间
	 * 
	 * @param needSpace
	 * @return
	 */
	@SuppressWarnings("rawtypes")
	private boolean hasEnoughSpace(long needSpace) {
		String savePath = download.getCurrentDownloadSDCardPath();
		SDCardManager m = new SDCardManager(savePath);
		if (!m.exist())
			return false;
		// 下载中的视频还需要的空间
		long needsize = 0L;
		Map<String, DownloadInfo> data = download.getDownloadingData();
		Iterator<?> iter = data.entrySet().iterator(); // 获得map的Iterator
		while (iter.hasNext()) {
			Entry entry = (Entry) iter.next();
			DownloadInfo info = (DownloadInfo) entry.getValue();
			if (info.savePath.contains(savePath)) {
				needsize += (info.size - info.downloadedSize);
			}
		}
		// 未使用的剩余空间-未完成的视频所需空间-新视频所需空间
		if (savePath.equals(SDCardManager.getDefauleSDCardPath())) {
			
				if ((m.getFreeSize() - needsize - needSpace) < 100 * 1024 * 1024) {
					return false;// SD卡空间不足
				}
		} else {
			if ((m.getFreeSize() - needsize - needSpace) < 100 * 1024 * 1024) {
				return false;// SD卡空间不足
			}
		}
		return true;
	}

}