package com.sound.chat;

import java.io.File;
import java.io.IOException;
import java.util.Calendar;
import java.lang.Math;
import java.util.Locale;
import org.json.JSONException;
import org.json.JSONObject;
import android.content.Context;
import android.media.MediaPlayer;
import android.media.MediaPlayer.OnCompletionListener;
import android.os.AsyncTask;
import android.os.Environment;
import android.text.format.DateFormat;
import android.util.Log;
import android.widget.AutoCompleteTextView.Validator;
import android.os.Handler;
import com.facebook.react.modules.core.DeviceEventManagerModule;
import com.facebook.react.bridge.ReactApplicationContext;
import com.facebook.react.bridge.ReadableArray;
import com.facebook.react.bridge.ReadableMap;
//获取系统属性
import java.lang.reflect.Field;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import android.app.AppOpsManager;
import android.content.pm.ApplicationInfo;
import java.util.concurrent.Executors;
/**
* 统一接口
**/
public class VoiceChatApi implements IVoiceAPI{
	/** 录音管理类 */
	private RecordManger recordManger;
	/** 上传文件服务器地址 */
	private String uploadFileServerUrl;
	private OnStateListener uploadFileStateListener;
	private OnStateListener downloadFileFileStateListener;
	private Context _context;
	public static final String TAG = "VoiceChatApi";
	private ReactApplicationContext _reactContext;
	private MediaPlayer mediaPlayer;
	private String _imgType;
	//通知栏状态参数
	private static final String CHECK_OP_NO_THROW = "checkOpNoThrow";
    private static final String OP_POST_NOTIFICATION = "OP_POST_NOTIFICATION";
    private static DownloadTaskManagerThread downloadTaskManagerThread;

	public VoiceChatApi(ReactApplicationContext reactContext){
		_reactContext=reactContext;
		Handler handler = new Handler(reactContext.getMainLooper());
		recordManger = new RecordManger(handler);
	}

	public void initApi(Context content,String serverUrl) {
		_context=content;
		uploadFileServerUrl=serverUrl;      
	}
	
	/** 启动录音不进行网络上传 */
	public void recordStart() {
		try {
			recordManger.startRecordCreateFile(_context);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	/** 停止录音 */
	public String recordStop() {
		return recordManger.stopRecord();// 停止录音
	}

	//播放录音
	public void recordPlay(String filePath){
		if(mediaPlayer!=null){
			mediaPlayer.release();
			mediaPlayer=null;
		}
		mediaPlayer = new MediaPlayer();
		try{
			File f = new File(filePath);
			mediaPlayer.setDataSource(f.getAbsolutePath());
			mediaPlayer.prepare();
			mediaPlayer.start();
			Log.d(TAG,"play");
			//设置播放完成的监听
			mediaPlayer.setOnCompletionListener(new OnCompletionListener() {
				@Override
				public void onCompletion(MediaPlayer mediaPlayer) {
					sendEvent("playSoundFinish","播放完成");
					mediaPlayer.release();
					mediaPlayer=null;
				}
			});
			if (downloadFileFileStateListener != null) {
				downloadFileFileStateListener.onState(0, "成功");
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public void stopPlay(){
		if(mediaPlayer!=null){
			mediaPlayer.stop();
		}
	}

	/** 停止录音后上传 */
	public void recordUpload() {
		File file = recordManger.getFile();
		if (file == null || !file.exists() || file.length() == 0) {
			if (uploadFileStateListener != null)
				uploadFileStateListener.onState(-1, "文件不存在或已经损坏");
			return;
		}
		Log.d(TAG,file.getAbsolutePath());
		new UpLoadecordFile().executeOnExecutor(Executors.newCachedThreadPool());// 调用异步任务
	}



	/** 异步任务-录音上传 */
	public class UpLoadecordFile extends AsyncTask<String, Integer, String> {

		@Override
		protected String doInBackground(String... parameters) {
			Log.d(TAG,"startUploadAmr");
			return UploadUtil.uploadFile(recordManger.getFile(),uploadFileServerUrl);
		}

		@Override
		protected void onPostExecute(String result) {
			if (result == null) {
				Log.d(TAG,"FAIL");
				sendEvent("uploadFail","上传失败");
				if (uploadFileStateListener != null)
					uploadFileStateListener.onState(-2, "上传文件失败");
			}else{
				Log.d(TAG,"SUCCESS");
				sendEvent("uploadSuccess",result);
				//保存配置信息
				saveConfig(result,recordManger.getFile().getAbsolutePath());
				if (uploadFileStateListener != null)
					uploadFileStateListener.onState(0, "上传文件成功");
			}
		}
	}

	public void uploadImgs(ReadableArray filePaths,String imgType){
		_imgType = imgType;
		Log.d(TAG,"startUploadImgs");
		for (int i = 0; i < filePaths.size(); i++) {
            ReadableMap file = filePaths.getMap(i);
            String imgServer= file.getString("imgServer");
            String filePath = file.getString("filePath");
            filePath = filePath.replace("file://", "");
			new UploadImageTask().executeOnExecutor(Executors.newCachedThreadPool(),filePath,imgServer);
		}
	}

	/** 下载*/
	public void recordDownload(String uploadFilename) {
		//new DownloadRecordFile().execute(uploadFilename,"record");
	}

	public void imageDownload(Context context, String uploadFilename){
		_context = context;
		//new DownloadRecordFile().execute(uploadFilename,"image");

	 	//如果轮训结束了,重新生成调度
	 	if(downloadTaskManagerThread==null||downloadTaskManagerThread.getStop()){
			initThreadExec();
	 	}
	 	DownloadTaskManager downloadTaskMananger = DownloadTaskManager.getInstance();  
		downloadTaskMananger.addDownloadTask(new DownloadTask(uploadFilename,"image",_context,_reactContext));
	}

	private static void initThreadExec() {
		downloadTaskManagerThread = new DownloadTaskManagerThread();  
	    new Thread(downloadTaskManagerThread).start();  
	}

	/** 异步任务-下载后播放
	public class DownloadRecordFile extends AsyncTask<String, Integer, File> {
		String httpurl="";
		@Override
		protected File doInBackground(String... parameters) {
			try {
				String filename = parameters[0];
				httpurl = parameters[0];
				int index=filename.lastIndexOf("/");
				filename = System.currentTimeMillis() + (int)(Math.random()*100) + filename.substring(index+1);
				Log.i("filename", filename);
				return FileHelper.DownloadFromUrlToData(parameters[0],filename,parameters[1],_context);
			} catch (Exception e) {
				e.printStackTrace();
			}
			return null;
		}

		@Override
		protected void onPostExecute(File result) {
			if (result == null || !result.exists() || result.length() == 0) {
				if (downloadFileFileStateListener != null) {
					downloadFileFileStateListener.onState(-1, "下载文件失败");
					return;
				}
			}
			try {
				sendEvent("downloadSuccess",result.getAbsolutePath());
				//保存数据到配置文件
				saveConfig(httpurl,result.getAbsolutePath());
				if (downloadFileFileStateListener != null) {
					downloadFileFileStateListener.onState(0, "成功");
					return;
				}
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}
	*/

	/** 异步任务-上传图片 */
	public class UploadImageTask extends AsyncTask<String, Integer, String> {
		@Override
		protected String doInBackground(String... parameters) {
			Log.d(TAG,"startUploadImg");
			try {
				File f= new File(parameters[0]);
				return UploadUtil.uploadFile(f,parameters[1]);
			} catch (Exception e) {
				e.printStackTrace();
			}
			return null;
		}

		@Override
		protected void onPostExecute(String result) {
			if (result == null) {
				Log.d(TAG,"FAIL");
				sendEvent("uploadImgFail","上传失败");
				if (uploadFileStateListener != null)
					uploadFileStateListener.onState(-2, "上传文件失败");
			}else{
				Log.d(TAG,"SUCCESS");
				sendEvent("uploadImgSuccess",result+","+_imgType);
				if (uploadFileStateListener != null)
					uploadFileStateListener.onState(0, "上传文件成功");
			}
		}
	}


	public boolean fileIsExits(String path){
		File f= new File(path);
		if(f.exists()){
			return true;
		}
		return false;
	}

	public void fileDelete(String path){
		File f = new File(path);
		if (f.isFile() && f.exists()) {  
	        f.delete();  
	    }   
	}

	public boolean isNotificationEnabled(Context context) {
        AppOpsManager mAppOps = (AppOpsManager)context.getSystemService(Context.APP_OPS_SERVICE);
        ApplicationInfo appInfo = context.getApplicationInfo();
        String pkg = context.getApplicationContext().getPackageName();
        int uid = appInfo.uid;
        Class appOpsClass = null; /* Context.APP_OPS_MANAGER */
        try {
            appOpsClass = Class.forName(AppOpsManager.class.getName());
            Method checkOpNoThrowMethod = appOpsClass.getMethod(CHECK_OP_NO_THROW, Integer.TYPE, Integer.TYPE, String.class);
            Field opPostNotificationValue = appOpsClass.getDeclaredField(OP_POST_NOTIFICATION);
            int value = (int)opPostNotificationValue.get(Integer.class);
            return ((int)checkOpNoThrowMethod.invoke(mAppOps,value, uid, pkg) == AppOpsManager.MODE_ALLOWED);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (NoSuchMethodException e) {
            e.printStackTrace();
        } catch (NoSuchFieldException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        }
        return false;
    } 

    public String getConfig(Context context,String url){
    	_context = context;
    	return FileHelper.getConfig(_context,url);
    }

    public void saveConfig(String url,String nativePath){
    	FileHelper.saveConfig(_context,url,nativePath);
    }

    public String getAllConfig(Context context){
    	_context = context;
    	return FileHelper.getAllConfig(_context);
    }

	private void sendEvent(String eventName,String returnMsg){
        _reactContext.getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter.class)
        .emit(eventName, returnMsg);
    }

	public RecordManger getRecordManger() {
		return recordManger;
	}

	public void setRecordManger(RecordManger recordManger) {
		this.recordManger = recordManger;
	}

	public Context getContext() {
		return _context;
	}

	public void setContext(Context context) {
		this._context = context;
	}


	public String getUploadFileServerUrl() {
		return uploadFileServerUrl;
	}

	public void setUploadFileServerUrl(String uploadFileServerUrl) {
		this.uploadFileServerUrl = uploadFileServerUrl;
	}

	public OnStateListener getUploadFileStateListener() {
		return uploadFileStateListener;
	}

	public void setUploadFileStateListener(
			OnStateListener uploadFileStateListener) {
		this.uploadFileStateListener = uploadFileStateListener;
	}

	public OnStateListener getDownloadFileFileStateListener() {
		return downloadFileFileStateListener;
	}

	public void setDownloadFileFileStateListener(
			OnStateListener downloadFileFileStateListener) {
		this.downloadFileFileStateListener = downloadFileFileStateListener;
	}

}