dataRequest与dataRequestWithHost 新增头字段参数

ipu-plugin-basic/src/main/java/com/ai/ipu/mobile/plugin/MobileNetWork.java

@@ -1,460 +1,506 @@
package com.ai.ipu.mobile.plugin;
import java.io.File;
import java.io.InputStream;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import org.json.JSONArray;
import android.bluetooth.BluetoothAdapter;
import android.content.Intent;
import android.net.Uri;
import android.os.AsyncTask;
import android.os.Build;
import android.widget.Toast;
import com.ai.ipu.basic.file.FileUtil;
import com.ai.ipu.basic.net.http.HttpTool;
import com.ai.ipu.basic.string.StringUtil;
import com.ai.ipu.basic.thread.IpuThread;
import com.ai.ipu.mobile.app.ApkUtil;
import com.ai.ipu.mobile.app.AppInfoUtil;
import com.ai.ipu.mobile.common.bluetooth.activity.ShareByBluetoothActivity;
import com.ai.ipu.mobile.common.bluetooth.listener.OnOpenBluetoothListener;
import com.ai.ipu.mobile.common.bluetooth.util.BluetoothTool;
import com.ai.ipu.mobile.common.sms.listener.OnSmsReceiveListener;
import com.ai.ipu.mobile.common.sms.util.SmsTool;
import com.ai.ipu.mobile.frame.IIpuMobile;
import com.ai.ipu.mobile.frame.config.MobileConfig;
import com.ai.ipu.mobile.frame.config.ServerDataConfig;
import com.ai.ipu.mobile.frame.plugin.Plugin;
import com.ai.ipu.mobile.safe.MobileSecurity;
import com.ai.ipu.mobile.util.BizManager;
import com.ai.ipu.mobile.util.BusinessCache;
import com.ai.ipu.mobile.util.Constant;
import com.ai.ipu.mobile.util.DirectionUtil;
import com.ai.ipu.mobile.util.FuncConstant;
import com.ai.ipu.mobile.util.IpuMobileUtility;
import com.ai.ipu.mobile.util.Messages;
import com.ai.ipu.mobile.util.http.UnirestUtil;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
import com.litesuits.http.LiteHttpClient;
import com.litesuits.http.request.Request;
import com.litesuits.http.response.Response;
public class MobileNetWork extends Plugin {
	private boolean hasSetSmsListener;
	private DirectionUtil directionUtil;
	public MobileNetWork(IIpuMobile ipumobile) {
		super(ipumobile);
		directionUtil = DirectionUtil.getInstance(context);
	}
	public void setSmsListener(JSONArray param) throws Exception {
		String telString = param.getString(0);
		setSmsListener(telString);
	}
	public void setSmsListener(String telString) throws Exception {
		HashSet<String> telSet = null;
		if(!isNull(telString)){
			telSet = new HashSet<String>();
			if(StringUtil.isJSONArray(telString)) {
				JSONArray teles = new JSONArray(telString);
				for(int i=0; i <teles.length() ; i++){
					telSet.add(teles.getString(i));
				}
			} else {
				telSet.add(telString);
			}
		}
		
		final HashSet<String> _telSet = telSet;
		if (!hasSetSmsListener) {
			SmsTool.setSmsListener(context, new OnSmsReceiveListener() {
				@Override
				public boolean onSmsReceive(String content, String sender, long time) {
					if (_telSet == null || _telSet.contains(sender)) {// 没有滤号码或者存在过滤号码均处理
						IData resultData = new DataMap();
						resultData.put(FuncConstant.CONTENT, content);
						resultData.put(FuncConstant.SENDER, sender);
						resultData.put(FuncConstant.TIME, time);
						String result = resultData.toString();
						callback(result, true);
						hasSetSmsListener = false;
						return true;
					} else {
						return false;
					}
				}
			});
			hasSetSmsListener = true;
		}
	}
	public void httpRequest(JSONArray param) throws Exception {
		String requestUrl = param.getString(0);
		String encode = param.getString(1);
		if (isNull(encode)) {
			encode = MobileConfig.getInstance().getEncode();
		}
		String result;
		try {
			result = httpRequest(requestUrl, encode);
		} catch (Exception e) {
			result = "{\"X_RESULTCODE\":\"-1\",\"X_RESULTINFO\":\"" + e.getMessage() + "\"}";
		}
		callback(result, true);
	}
	public String httpRequest(String requestUrl, String encode) throws Exception {
		// TODO Auto-generated method stub
		MobileConfig config = MobileConfig.getInstance();
		// 预处理
		if (!requestUrl.startsWith(Constant.HTTP)) {
			if (!requestUrl.startsWith("/"))
				requestUrl = "/" + requestUrl;
			requestUrl = config.getRequestHost() + requestUrl;
		}
		requestUrl = HttpTool.urlEncode(requestUrl, encode);
		return HttpTool.httpRequest(requestUrl, null, Constant.HTTP_POST, encode);
	}
	public void httpGet(JSONArray param) throws Exception {
		String requestUrl = param.getString(0);
		String encode = param.getString(1);
		if (isNull(encode)) {
			encode = MobileConfig.getInstance().getEncode();// UTF-8
		}
		String result;
		try {
			/* 方式1 */
			/*result = httpGet(requestUrl,encode);*/
			/* 方式2 */
			LiteHttpClient client = LiteHttpClient.getInstance(context);
			Response res = client.execute(new Request(requestUrl));
			result = res.getString();
		} catch (Exception e) {
			result = e.getMessage();
		}
		callback(result, true);
	}
	public String httpGet(String requestUrl, String encode) throws Exception {
		MobileConfig config = MobileConfig.getInstance();
		/* 预处理 */
		if (!requestUrl.startsWith(Constant.HTTP)) {
			if (!requestUrl.startsWith("/"))
				requestUrl = "/" + requestUrl;
			requestUrl = config.getRequestHost() + requestUrl;
		}
		requestUrl = HttpTool.urlEncode(requestUrl, encode);
		return HttpTool.httpRequest(requestUrl, null, Constant.HTTP_GET, encode);
	}
	public void dataRequest(JSONArray param) throws Exception {
		String dataAction = param.getString(0);
		String data = param.getString(1);
		String result = dataRequest(dataAction, isNull(data) ? null : new DataMap(data));
		callback(result, true);
	}
	
	public void dataRequestWithHost(JSONArray param) throws Exception {
	    String requestUrl = param.getString(0);// http://ip:port/servername/mobiledata
        String dataAction = param.getString(1);
        String data = param.getString(2);
        String result = dataRequestWithHost(requestUrl, dataAction, isNull(data) ? null : new DataMap(data));
        callback(result, true);
    }
	/**
	 * @param dataAction
	 * @param param
	 * @param isMustEncrypt
	 *            是否一定加密传输
	 * @return
	 * @throws Exception
	 */
	public String dataRequest(String dataAction, IData param) throws Exception ) {
		synchronized (dataAction) {
			String result = (String) BusinessCache.getInstance().get(dataAction);
			if (result != null) {
				BusinessCache.getInstance().remove(dataAction);
			} else {
				try {
				    result = requestBizData(dataAction, param);
				} catch (Exception e) {
				    DataMap data = new DataMap();
                    data.put("X_RESULTCODE", -1);
                    data.put("X_RESULTINFO", e.getMessage());
                    result = data.toString();
                }
			}
			return result;
		}
	}
	
	public String dataRequestWithHost(String requestUrl, String dataAction, IData param) throws Exception {
        synchronized (dataAction) {
            String result = (String) BusinessCache.getInstance().get(dataAction);
            if (result != null) {
                BusinessCache.getInstance().remove(dataAction);
            } else {
                try {
                    result = requestBizDataWithHost(requestUrl, dataAction, param);
                } catch (Exception e) {
                    DataMap data = new DataMap();
                    data.put("X_RESULTCODE", -1);
                    data.put("X_RESULTINFO", e.getMessage());
                    result = data.toString();
                }
            }
            return result;
        }
    }
	private String requestBizData(String dataAction, IData param) throws Exception {
		Map<String,String> postData = transPostData(dataAction, param);
		String dataUrl = HttpTool.toQueryStringWithEncode(postData);
		BizManager.recordReqUrl(MobileConfig.getInstance().getRequestUrl());
		String result = HttpTool.httpRequest(MobileConfig.getInstance().getRequestUrl(),
				dataUrl, Constant.HTTP_POST);
		if (ServerDataConfig.isEncrypt(dataAction)) {
			result = MobileSecurity.responseDecrypt(result);
		}
		return result;
	}
	
	private String requestBizDataWithHost(String requestUrl, String dataAction, IData param) throws Exception {
        Map<String,String> postData = transPostData(dataAction, param);
        String dataUrl = HttpTool.toQueryStringWithEncode(postData);
        String result = HttpTool.httpRequest(requestUrl, dataUrl, Constant.HTTP_POST);
        if (ServerDataConfig.isEncrypt(dataAction)) {
            result = MobileSecurity.responseDecrypt(result);
        }
        return result;
    }
	
	public Map<String, String> transPostData(String dataAction, IData dataParam) throws Exception ) {
		// TODO Auto-generated method stub
		Map<String, String> postData = new HashMap<String, String>();
		postData.put(Constant.Server.ACTION, dataAction);
		if (ServerDataConfig.isEncrypt(dataAction)) {
			MobileSecurity.init();
			/* 参数加密处理 */
			String key = MobileSecurity.getDesKey();
			postData.put(Constant.Server.KEY, key);
			
			if(dataParam!=null){
				String encryptData = MobileSecurity.requestEncrypt(dataParam.toString());
				postData.put(Constant.Server.DATA, encryptData);
			}
		} else {
			if (dataParam != null) {
				postData.put(Constant.Server.DATA, dataParam.toString());
			}
		}
		return postData;
	}
	public void storageDataByThread(JSONArray param) throws Exception {
		String dataAction = param.getString(0);
		String data = param.getString(1);
		boolean isEncrypt = false;
		if (param.length() > 2) {
			isEncrypt = "true".equals(param.getString(2)) ? true : false;
		}
		int waitoutTime = 5;
		if (param.length() > 3) {
			waitoutTime = param.getInt(3);
		}
		storageDataByThread(dataAction, isNull(data) ? null : new DataMap(data), isEncrypt, waitoutTime);
	}
	public void storageDataByThread(final String dataAction, final IData param,
			final boolean isEncrypt, long waitoutTime) throws Exception {
		waitoutTime = (waitoutTime < 3 || waitoutTime > 10) ? 5 : waitoutTime;// 修正waitoutTime,确保在一定范围
		new IpuThread(dataAction, waitoutTime) {
			@Override
			protected void execute() throws Exception {
				String result = requestBizData(dataAction, param);
				synchronized (dataAction) {
					BusinessCache.getInstance().put(dataAction, result);
				}
			}
		}.start();
	}
	public void shareByBluetooth(JSONArray param) throws Exception {
		try {
			BluetoothAdapter adapter = BluetoothAdapter.getDefaultAdapter();
			if (adapter == null) {
				Toast.makeText(context, "蓝牙初始化出错!", Toast.LENGTH_LONG);
				return;
			}
		} catch (Exception e) {
			Toast.makeText(context, "蓝牙初始化出错!", Toast.LENGTH_LONG);
			return;
		}
		if (Build.VERSION.SDK_INT < AppInfoUtil.Android_4_1_2) {
			try {
				Intent intent = new Intent(context, ShareByBluetoothActivity.class);
				context.startActivity(intent);
			} catch (Exception e) {
				e.printStackTrace();
				Toast.makeText(context, "蓝牙初始化出错!", Toast.LENGTH_LONG);
			}
		} else {
			final BluetoothTool bluetoothTools = new BluetoothTool(context);
			if (bluetoothTools.isEnabled()) {
				bluetoothTools.sendFile(ApkUtil.getCurrApk());
			} else {
				bluetoothTools.openBluetooth(new OnOpenBluetoothListener() {
					public void OnOpened(BluetoothAdapter adapter) {
						// 开始查找设备。
						try {
							bluetoothTools.sendFile(ApkUtil.getCurrApk());
						} catch (Exception e) {
							e.printStackTrace();
						}
					}
				});
			}
		}
	}
	/**
	 * 打开浏览器
	 */
	public void openBrowser(JSONArray param) throws Exception {
		String url = param.getString(0);
		openBrowser(url);
	}
	/**
	 * 打开浏览器
	 */
	public void openBrowser(String url) {
		Uri uri = Uri.parse(url);
		Intent intent = new Intent(Intent.ACTION_VIEW, uri);
		context.startActivity(intent);
	}
	
	public void uploadWithServlet(JSONArray param) throws Exception {
		JSONArray filePaths = param.getJSONArray(0);
		String dataAction = param.getString(1);
		IData dataParam = isNull(param.getString(2))?new DataMap():new DataMap(param.getString(2));
		uploadWithServlet(filePaths, dataAction, dataParam);
	}
	
	@SuppressWarnings("unchecked")
	public void uploadWithServlet(final JSONArray filePaths, final String dataAction, IData dataParam) throws Exception ) {
		// TODO Auto-generated method stub
		Map<String, String> postData = transPostData(dataAction, dataParam);
		new AsyncTask<Map<String, String>, Integer, String>() {
			@Override
			protected String doInBackground(Map<String, String>... args) {
				Map<String, String> postData = args[0];
				Map<String, Object> fileData = new HashMap<String, Object>();
				// TODO Auto-generated method stub
				String result = null;
				try{
					String filePath = null;
					File file;
					for(int i=0;i<filePaths.length();i++){
						filePath = filePaths.getString(i);
						file = new File(filePath);
						if(!file.exists()){
							IpuMobileUtility.error(Messages.FILE_NOT_EXIST+":"+filePath);
						}
						fileData.put("UPLOAD_FILE"+i, file);//装载文件
					}
					fileData.put("UPLOAD_FILE_COUNT", filePaths.length());//装载文件数量
					
					String encode = MobileConfig.getInstance().getEncode();
					String dataUrl = HttpTool.urlEncode(HttpTool.toQueryString(postData), encode);
					String url = MobileConfig.getInstance().getRequestUrl() + "?" + dataUrl;
					result = UnirestUtil.uploadByPost(HttpTool.urlEscape(url).toString(), fileData);
					if (ServerDataConfig.isEncrypt(dataAction)) {
						result = MobileSecurity.responseDecrypt(result);
					}
				}catch(Exception e){
					MobileNetWork.this.error(e.getMessage());// 报错回调
					IpuMobileUtility.error(e);
				}
				return result;
			}
			
			@Override
			protected void onPostExecute(String result) {
				// TODO Auto-generated method stub
				super.onPostExecute(result);
				if (result != null) {
					MobileNetWork.this.callback(result, true);// 正常回调
				}
			}
		}.execute(postData);
	}
	
	public void downloadWithServlet(JSONArray param) throws Exception {
		String savePath = param.getString(0);
		String dataAction = param.getString(1);
		IData dataParam = param.getString(2) == null ? new DataMap() : new DataMap(param.getString(2));
		downloadWithServlet(savePath, dataAction, dataParam);
	}
	
	public void downloadWithServlet(final String _savePath, String dataAction, IData dataParam) throws Exception {
		// TODO Auto-generated method stub
		Map<String, String> tempPostData = transPostData(dataAction, dataParam);
		final Map<String, Object> postData = new HashMap<String, Object>();
		postData.putAll(tempPostData);
		new AsyncTask<String, Integer, String>() {
			@Override
			protected String doInBackground(String... arg0) {
				// TODO Auto-generated method stub
				String savePath = _savePath;
				try {
					InputStream in = UnirestUtil.downloadByPost(MobileConfig.getInstance().getRequestUrl(), postData);
					if (!savePath.startsWith(File.separator)) {
						savePath = directionUtil.getDirection(savePath, true);
					}
					File file = new File(savePath).getParentFile();
					if (!file.exists() && !file.mkdirs()) {
						IpuMobileUtility.error("创建下载文件夹失败!");
					}
					FileUtil.writeFile(in, savePath);
				} catch (Exception e) {
					MobileNetWork.this.error("[" + savePath + "]异常:" + e.getMessage());// 报错回调
				}
				return savePath;
			}
			
			@Override
			protected void onPostExecute(String savePath) {
				// TODO Auto-generated method stub
				super.onPostExecute(savePath);
				if (savePath != null) {
					MobileNetWork.this.callback(savePath, true);// 正常回调
				}
			}
		}.execute();
	}
	public void uploadFile(JSONArray param) throws Exception {
		String path = param.getString(0);
		uploadFile(path);
	}
	public void uploadFile(String path) throws Exception {
		// TODO Auto-generated method stub
		
	}
}
package com.ai.ipu.mobile.plugin;
import java.io.File;
import java.io.InputStream;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import org.json.JSONArray;
import org.json.JSONException;
import android.bluetooth.BluetoothAdapter;
import android.content.Intent;
import android.net.Uri;
import android.os.AsyncTask;
import android.os.Build;
import android.widget.Toast;
import com.ai.ipu.basic.file.FileUtil;
import com.ai.ipu.basic.net.http.HttpTool;
import com.ai.ipu.basic.string.StringUtil;
import com.ai.ipu.basic.thread.IpuThread;
import com.ai.ipu.mobile.app.ApkUtil;
import com.ai.ipu.mobile.app.AppInfoUtil;
import com.ai.ipu.mobile.common.bluetooth.activity.ShareByBluetoothActivity;
import com.ai.ipu.mobile.common.bluetooth.listener.OnOpenBluetoothListener;
import com.ai.ipu.mobile.common.bluetooth.util.BluetoothTool;
import com.ai.ipu.mobile.common.sms.listener.OnSmsReceiveListener;
import com.ai.ipu.mobile.common.sms.util.SmsTool;
import com.ai.ipu.mobile.frame.IIpuMobile;
import com.ai.ipu.mobile.frame.config.MobileConfig;
import com.ai.ipu.mobile.frame.config.ServerDataConfig;
import com.ai.ipu.mobile.frame.plugin.Plugin;
import com.ai.ipu.mobile.safe.MobileSecurity;
import com.ai.ipu.mobile.util.BizManager;
import com.ai.ipu.mobile.util.BusinessCache;
import com.ai.ipu.mobile.util.Constant;
import com.ai.ipu.mobile.util.DirectionUtil;
import com.ai.ipu.mobile.util.FuncConstant;
import com.ai.ipu.mobile.util.IpuMobileLog;
import com.ai.ipu.mobile.util.IpuMobileUtility;
import com.ai.ipu.mobile.util.Messages;
import com.ai.ipu.mobile.util.http.UnirestUtil;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
import com.litesuits.http.LiteHttpClient;
import com.litesuits.http.request.Request;
import com.litesuits.http.response.Response;
public class MobileNetWork extends Plugin {
	private boolean hasSetSmsListener;
	private DirectionUtil directionUtil;
	public MobileNetWork(IIpuMobile ipumobile) {
		super(ipumobile);
		directionUtil = DirectionUtil.getInstance(context);
	}
	public void setSmsListener(JSONArray param) throws Exception {
		String telString = param.getString(0);
		setSmsListener(telString);
	}
	public void setSmsListener(String telString) throws Exception {
		HashSet<String> telSet = null;
		if(!isNull(telString)){
			telSet = new HashSet<String>();
			if(StringUtil.isJSONArray(telString)) {
				JSONArray teles = new JSONArray(telString);
				for(int i=0; i <teles.length() ; i++){
					telSet.add(teles.getString(i));
				}
			} else {
				telSet.add(telString);
			}
		}
		
		final HashSet<String> _telSet = telSet;
		if (!hasSetSmsListener) {
			SmsTool.setSmsListener(context, new OnSmsReceiveListener() {
				@Override
				public boolean onSmsReceive(String content, String sender, long time) {
					if (_telSet == null || _telSet.contains(sender)) {// 没有滤号码或者存在过滤号码均处理
						IData resultData = new DataMap();
						resultData.put(FuncConstant.CONTENT, content);
						resultData.put(FuncConstant.SENDER, sender);
						resultData.put(FuncConstant.TIME, time);
						String result = resultData.toString();
						callback(result, true);
						hasSetSmsListener = false;
						return true;
					} else {
						return false;
					}
				}
			});
			hasSetSmsListener = true;
		}
	}
	public void httpRequest(JSONArray param) throws Exception {
		String requestUrl = param.getString(0);
		String encode = param.getString(1);
		if (isNull(encode)) {
			encode = MobileConfig.getInstance().getEncode();
		}
		String result;
		try {
			result = httpRequest(requestUrl, encode);
		} catch (Exception e) {
			result = "{\"X_RESULTCODE\":\"-1\",\"X_RESULTINFO\":\"" + e.getMessage() + "\"}";
		}
		callback(result, true);
	}
	public String httpRequest(String requestUrl, String encode) throws Exception {
		// TODO Auto-generated method stub
		MobileConfig config = MobileConfig.getInstance();
		// 预处理
		if (!requestUrl.startsWith(Constant.HTTP)) {
			if (!requestUrl.startsWith("/"))
				requestUrl = "/" + requestUrl;
			requestUrl = config.getRequestHost() + requestUrl;
		}
		requestUrl = HttpTool.urlEncode(requestUrl, encode);
		return HttpTool.httpRequest(requestUrl, null, Constant.HTTP_POST, encode);
	}
	public void httpGet(JSONArray param) throws Exception {
		String requestUrl = param.getString(0);
		String encode = param.getString(1);
		if (isNull(encode)) {
			encode = MobileConfig.getInstance().getEncode();// UTF-8
		}
		String result;
		try {
			/* 方式1 */
			/*result = httpGet(requestUrl,encode);*/
			/* 方式2 */
			LiteHttpClient client = LiteHttpClient.getInstance(context);
			Response res = client.execute(new Request(requestUrl));
			result = res.getString();
		} catch (Exception e) {
			result = e.getMessage();
		}
		callback(result, true);
	}
	public String httpGet(String requestUrl, String encode) throws Exception {
		MobileConfig config = MobileConfig.getInstance();
		/* 预处理 */
		if (!requestUrl.startsWith(Constant.HTTP)) {
			if (!requestUrl.startsWith("/"))
				requestUrl = "/" + requestUrl;
			requestUrl = config.getRequestHost() + requestUrl;
		}
		requestUrl = HttpTool.urlEncode(requestUrl, encode);
		return HttpTool.httpRequest(requestUrl, null, Constant.HTTP_GET, encode);
	}
	public void dataRequest(JSONArray param) throws Exception {
		String dataAction = param.getString(0);
		String data = param.getString(1);
		String headers = null;
		try {
			headers = param.getString(5);//应用更新api后，前端未同步导致的数组越界异常
		} catch (JSONException e) {
			IpuMobileLog.e(TAG, e.getMessage());
		} 
		String result = isNull(headers) ? dataRequest(dataAction, isNull(data) ? null : new DataMap(data)) :
			 dataRequest(dataAction, isNull(data) ? null : new DataMap(data),new DataMap(headers));
		callback(result, true);
	}
	
	public void dataRequestWithHost(JSONArray param) throws Exception {
	    String requestUrl = param.getString(0);// http://ip:port/servername/mobiledata
        String dataAction = param.getString(1);
        String data = param.getString(2);
        String headers = null;
        try {
        	headers = param.getString(6);
		} catch (Exception e) ) {
			IpuMobileLog.d(TAG, e.getMessage());
		}
        String result = isNull(headers) ? dataRequestWithHost(requestUrl, dataAction, isNull(data) ? null : new DataMap(data)) :
        	dataRequestWithHost(requestUrl, dataAction, isNull(data) ? null : new DataMap(data), new DataMap(headers));
        callback(result, true);
    }
	
	/**
	 * @param dataAction
	 * @param param
	 * @param isMustEncrypt
	 *            是否一定加密传输
	 * @return
	 * @throws Exception
	 */
	public String dataRequest(String dataAction, IData param) throws Exception {
		return dataRequest(dataAction, param, null);
	}
	/**
	 * @param dataAction
	 * @param param
	 * @param isMustEncrypt
	 *            是否一定加密传输
	 * @return
	 * @throws Exception
	 */
	public String dataRequest(String dataAction, IData param,IData headers) throws Exception {
		synchronized (dataAction) {
			String result = (String) BusinessCache.getInstance().get(dataAction);
			if (result != null) {
				BusinessCache.getInstance().remove(dataAction);
			} else {
				try {
				    result = (null == headers) ? requestBizData(dataAction, param) : requestBizData(dataAction, param, headers);
				} catch (Exception e) {
				    DataMap data = new DataMap();
                    data.put("X_RESULTCODE", -1);
                    data.put("X_RESULTINFO", e.getMessage());
                    result = data.toString();
                }
			}
			return result;
		}
	}
	
	public String dataRequestWithHost(String requestUrl, String dataAction, IData param) throws Exception {
            return dataRequestWithHost(requestUrl, dataAction, param, null);
        }
	public String dataRequestWithHost(String requestUrl, String dataAction, IData param,IData headers) throws Exception {
        synchronized (dataAction) {
            String result = (String) BusinessCache.getInstance().get(dataAction);
            if (result != null) {
                BusinessCache.getInstance().remove(dataAction);
            } else {
                try {
                    result = (null == headers) ? requestBizDataWithHost(requestUrl, dataAction, param) :
                    	requestBizDataWithHost(requestUrl, dataAction, param, headers);
                } catch (Exception e) ) {
                    DataMap data = new DataMap();
                    data.put("X_RESULTCODE", -1);
                    data.put("X_RESULTINFO", e.getMessage());
                    result = data.toString();
                }
            }
            return result;
        }
    }
	
	/**
	 * 新增头字段参数
	 */
	private String requestBizData(String dataAction, IData param,IData headers) throws Exception {
		Map<String,String> postData = transPostData(dataAction, param);
		String dataUrl = HttpTool.toQueryStringWithEncode(postData);
		BizManager.recordReqUrl(MobileConfig.getInstance().getRequestUrl());
		String result = (null == headers) ? HttpTool.httpRequest(MobileConfig.getInstance().getRequestUrl(),
				dataUrl, Constant.HTTP_POST) : HttpTool.httpRequest(MobileConfig.getInstance().getRequestUrl(),
						dataUrl, Constant.HTTP_POST,headers);
		if (ServerDataConfig.isEncrypt(dataAction)) {
			result = MobileSecurity.responseDecrypt(result);
		}
		return result;
	}
	
	private String requestBizData(String dataAction, IData param) throws Exception {
		return requestBizData(dataAction, param, null);
	}
	
	private String requestBizDataWithHost(String requestUrl, String dataAction, IData param) throws Exception {
        return requestBizDataWithHost(requestUrl, dataAction, param, null);
    }
	
	private String requestBizDataWithHost(String requestUrl, String dataAction, IData param,IData headers) throws Exception{
        Map<String,String> postData = transPostData(dataAction, param);
        String dataUrl = HttpTool.toQueryStringWithEncode(postData);
        String result = (null == headers) ? HttpTool.httpRequest(requestUrl, dataUrl, Constant.HTTP_POST) : 
        	HttpTool.httpRequest(requestUrl, dataUrl, Constant.HTTP_POST, headers);
        if (ServerDataConfig.isEncrypt(dataAction)) {
            result = MobileSecurity.responseDecrypt(result);
        }
        return result;
	}
	
	public Map<String, String> transPostData(String dataAction, IData dataParam) throws Exception {
		// TODO Auto-generated method stub
		Map<String, String> postData = new HashMap<String, String>();
		postData.put(Constant.Server.ACTION, dataAction);
		if (ServerDataConfig.isEncrypt(dataAction)) {
			MobileSecurity.init();
			/* 参数加密处理 */
			String key = MobileSecurity.getDesKey();
			postData.put(Constant.Server.KEY, key);
			
			if(dataParam!=null){
				String encryptData = MobileSecurity.requestEncrypt(dataParam.toString());
				postData.put(Constant.Server.DATA, encryptData);
			}
		} else {
			if (dataParam != null) {
				postData.put(Constant.Server.DATA, dataParam.toString());
			}
		}
		return postData;
	}
	public void storageDataByThread(JSONArray param) throws Exception {
		String dataAction = param.getString(0);
		String data = param.getString(1);
		boolean isEncrypt = false;
		if (param.length() > 2) {
			isEncrypt = "true".equals(param.getString(2)) ? true : false;
		}
		int waitoutTime = 5;
		if (param.length() > 3) {
			waitoutTime = param.getInt(3);
		}
		storageDataByThread(dataAction, isNull(data) ? null : new DataMap(data), isEncrypt, waitoutTime);
	}
	public void storageDataByThread(final String dataAction, final IData param,
			final boolean isEncrypt, long waitoutTime) throws Exception {
		waitoutTime = (waitoutTime < 3 || waitoutTime > 10) ? 5 : waitoutTime;// 修正waitoutTime,确保在一定范围
		new IpuThread(dataAction, waitoutTime) {
			@Override
			protected void execute() throws Exception {
				String result = requestBizData(dataAction, param);
				synchronized (dataAction) {
					BusinessCache.getInstance().put(dataAction, result);
				}
			}
		}.start();
	}
	public void shareByBluetooth(JSONArray param) throws Exception {
		try {
			BluetoothAdapter adapter = BluetoothAdapter.getDefaultAdapter();
			if (adapter == null) {
				Toast.makeText(context, "蓝牙初始化出错!", Toast.LENGTH_LONG);
				return;
			}
		} catch (Exception e) {
			Toast.makeText(context, "蓝牙初始化出错!", Toast.LENGTH_LONG);
			return;
		}
		if (Build.VERSION.SDK_INT < AppInfoUtil.Android_4_1_2) {
			try {
				Intent intent = new Intent(context, ShareByBluetoothActivity.class);
				context.startActivity(intent);
			} catch (Exception e) ) {
				e.printStackTrace();
				Toast.makeText(context, "蓝牙初始化出错!", Toast.LENGTH_LONG);
			}
		} else {
			final BluetoothTool bluetoothTools = new BluetoothTool(context);
			if (bluetoothTools.isEnabled()) {
				bluetoothTools.sendFile(ApkUtil.getCurrApk());
			} else {
				bluetoothTools.openBluetooth(new OnOpenBluetoothListener() {
					public void OnOpened(BluetoothAdapter adapter) {
						// 开始查找设备。
						try {
							bluetoothTools.sendFile(ApkUtil.getCurrApk());
						} catch (Exception e) {
							e.printStackTrace();
						}
					}
				});
			}
		}
	}
	/**
	 * 打开浏览器
	 */
	public void openBrowser(JSONArray param) throws Exception {
		String url = param.getString(0);
		openBrowser(url);
	}
	/**
	 * 打开浏览器
	 */
	public void openBrowser(String url) {
		Uri uri = Uri.parse(url);
		Intent intent = new Intent(Intent.ACTION_VIEW, uri);
		context.startActivity(intent);
	}
	
	public void uploadWithServlet(JSONArray param) throws Exception {
		JSONArray filePaths = param.getJSONArray(0);
		String dataAction = param.getString(1);
		IData dataParam = isNull(param.getString(2))?new DataMap():new DataMap(param.getString(2));
		uploadWithServlet(filePaths, dataAction, dataParam);
	}
	
	@SuppressWarnings("unchecked")
	public void uploadWithServlet(final JSONArray filePaths, final String dataAction, IData dataParam) throws Exception {
		// TODO Auto-generated method stub
		Map<String, String> postData = transPostData(dataAction, dataParam);
		new AsyncTask<Map<String, String>, Integer, String>() {
			@Override
			protected String doInBackground(Map<String, String>... args) {
				Map<String, String> postData = args[0];
				Map<String, Object> fileData = new HashMap<String, Object>();
				// TODO Auto-generated method stub
				String result = null;
				try{
					String filePath = null;
					File file;
					for(int i=0;i<filePaths.length();i++){
						filePath = filePaths.getString(i);
						file = new File(filePath);
						if(!file.exists()){
							IpuMobileUtility.error(Messages.FILE_NOT_EXIST+":"+filePath);
						}
						fileData.put("UPLOAD_FILE"+i, file);//装载文件
					}
					fileData.put("UPLOAD_FILE_COUNT", filePaths.length());//装载文件数量
					
					String encode = MobileConfig.getInstance().getEncode();
					String dataUrl = HttpTool.urlEncode(HttpTool.toQueryString(postData), encode);
					String url = MobileConfig.getInstance().getRequestUrl() + "?" + dataUrl;
					result = UnirestUtil.uploadByPost(HttpTool.urlEscape(url).toString(), fileData);
					if (ServerDataConfig.isEncrypt(dataAction)) {
						result = MobileSecurity.responseDecrypt(result);
					}
				}catch(Exception e){
					MobileNetWork.this.error(e.getMessage());// 报错回调
					IpuMobileUtility.error(e);
				}
				return result;
			}
			
			@Override
			protected void onPostExecute(String result) {
				// TODO Auto-generated method stub
				super.onPostExecute(result);
				if (result != null) {
					MobileNetWork.this.callback(result, true);// 正常回调
				}
			}
		}.execute(postData);
	}
	
	public void downloadWithServlet(JSONArray param) throws Exception {
		String savePath = param.getString(0);
		String dataAction = param.getString(1);
		IData dataParam = param.getString(2) == null ? new DataMap() : new DataMap(param.getString(2));
		downloadWithServlet(savePath, dataAction, dataParam);
	}
	
	public void downloadWithServlet(final String _savePath, String dataAction, IData dataParam) throws Exception {
		// TODO Auto-generated method stub
		Map<String, String> tempPostData = transPostData(dataAction, dataParam);
		final Map<String, Object> postData = new HashMap<String, Object>();
		postData.putAll(tempPostData);
		new AsyncTask<String, Integer, String>() {
			@Override
			protected String doInBackground(String... arg0) {
				// TODO Auto-generated method stub
				String savePath = _savePath;
				try {
					InputStream in = UnirestUtil.downloadByPost(MobileConfig.getInstance().getRequestUrl(), postData);
					if (!savePath.startsWith(File.separator)) {
						savePath = directionUtil.getDirection(savePath, true);
					}
					File file = new File(savePath).getParentFile();
					if (!file.exists() && !file.mkdirs()) {
						IpuMobileUtility.error("创建下载文件夹失败!");
					}
					FileUtil.writeFile(in, savePath);
				} catch (Exception e) {
					MobileNetWork.this.error("[" + savePath + "]异常:" + e.getMessage());// 报错回调
				}
				return savePath;
			}
			
			@Override
			protected void onPostExecute(String savePath) {
				// TODO Auto-generated method stub
				super.onPostExecute(savePath);
				if (savePath != null) {
					MobileNetWork.this.callback(savePath, true);// 正常回调
				}
			}
		}.execute();
	}
	public void uploadFile(JSONArray param) throws Exception {
		String path = param.getString(0);
		uploadFile(path);
	}
	public void uploadFile(String path) throws Exception {
		// TODO Auto-generated method stub
		
	}
}