package com.glodon.com.test;

import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.SimpleDateFormat;
import java.util.LinkedList;
import java.util.zip.GZIPOutputStream;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

public class Manager {
	//缓存消息队列
	private static LinkedList<String> list = new LinkedList<String>();
	
	/*
	 * 发送方法
	 * 返回true:成功发送	  
	 * 返回false：网络问题发送失败会有断网续传机制将数据先写到缓存
	 * 抛出异常：发送的json格式不对或字段没有符合埋点规范
	 */
	public static boolean sendToServer(String jsonString) throws Exception{
		/*//先看本地文件是否存在，存在先发
		File directory = new File("");
		String path = directory.getAbsolutePath();
		System.out.println(path);
		File file = new File(path + "\\data.txt");
		if(file.exists() && file.length() > 0){
			readFromFileToList(file);//本地文件内容读到list中
			//解密
			for(int i = 0; i < list.size(); i ++) list.set(i,new String(decode(list.get(i))));
		}
		if(!list.isEmpty()){
			JSONArray arr = JSONArray.fromObject(list);
			//添加用于标记存盘后发送的tag
			String tag = "{'pcode':'-101000','fncode':'111','trigertime':'1970/01/01 00:00:00 000','tag':''}";
			JSONObject jo = JSONObject.fromObject(tag);
			arr.add(jo);
			//发送服务器地址
			String url = "http://tj.glodon.com/applog2/LogAccept";
	        boolean flag = true;
	        try{
	        	sendPost(url, compress(arr.toString()));
	        }catch(Exception e){
	        	flag = false;
	        	System.out.println("批量发送失败");
	        }
	        if(flag) list.clear();
		}*/
		
		return sendJsonObject(jsonString);
	}
	
	private static boolean sendJsonObject(String jsonString) throws Exception{
		
		//先对json串进行简单校验
		JSONObject jo = JSONObject.fromObject(jsonString);  
	//	format(jo);
        
        //将单个jsonString封装成JSONArray并进行gzip压缩
        byte[] arr = compress("[" + jo.toString() + "]");
        
        //发送数据
//        String url = "http://tj.glodon.com/applog2";
//        String url = "http://localhost:8088/LogAccept";
        String url = "http://io.glodon.com/test_logs/LogAccept";
//        String url = "http://tj.glodon.com/applog2/LogAccept";
//        String url = "http://10.127.49.98:8088/web_log";
        boolean res = true;
        try{
        	sendPost(url, arr);
//        	sendGet(url, arr);
        }catch(Exception e){
        	//在此扩展断网续传机制
        	System.out.println(e);
    		if(list.size() > 1000){
    			list.removeFirst();
    			list.add(jo.toString());
    		}else{
    			list.add(jo.toString());
    		}
        	res = false;
        }
        
		return res;
	}
	
	//程序退出时将list数据写入本地
	private static void writeToFile(File file){
		if (!file.exists()) {
			try {
				file.createNewFile();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		//加密
		for(int i = 0; i < list.size(); i ++) list.set(i, encode(list.get(i).getBytes()));
		
		FileOutputStream fos = null;
		ObjectOutputStream oos = null;
		try {
			fos = new FileOutputStream(file);
			oos = new ObjectOutputStream(fos);
			oos.writeObject(list);
			list.clear();
		} catch (FileNotFoundException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
		
	}
	
	private static void readFromFileToList(File file) {
		// 将文件数据读入缓存list
		if (!file.exists() || file.length() == 0) {
			return;
		}
		System.out.println("读文件");
		FileInputStream freader = null;
		ObjectInputStream objectInputStream = null;
		try {
			freader = new FileInputStream(file);
			objectInputStream = new ObjectInputStream(freader);
			LinkedList<String> list2 = (LinkedList<String>) objectInputStream.readObject();
			list.addAll(list2);
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (FileNotFoundException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}finally{
			if(objectInputStream != null){
				try {
					objectInputStream.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
			if(freader != null){
				try {
					freader.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
		System.gc();    //加上确保文件能删除，不然可能删不掉  
		System.out.println("删除文件" + file.delete());
	}
	
	//简单校验
	private static void format(JSONObject jo) throws Exception{
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss SSS");
		if(!jo.containsKey("pcode") ||!(jo.getString("pcode").equals("-103000") || jo.getString("pcode").equals("-103001"))
				|| !jo.containsKey("fncode")|| !jo.containsKey("trigertime")){
			throw new Exception("the necessary key is not contain");
		}
		if(!jo.containsKey("sys") & !jo.getString("pcode").equals("-103000")){
			throw new Exception("json key is not standard");
		}
		if(jo.containsKey("sys") && ("1".equals(jo.getString("sys")) || "2".equals(jo.getString("sys")))){
			if(!jo.getString("pcode").equals("-103001")) {
				throw new Exception("json key is not standard");
			}
		}
		sdf.parse(jo.getString("trigertime"));
	}

	
	/** 
     * 字符串压缩为GZIP字节数组 
     *  
     * @param str 
     * @return
     */  
    public static byte[] compress(String str) {  
        if (str == null || str.length() == 0) {  
            return null;  
        }  
        ByteArrayOutputStream out = new ByteArrayOutputStream();  
        GZIPOutputStream gzip = null;  
        byte[] compressed;
        try {  
            gzip = new GZIPOutputStream(out);  
            gzip.write(str.getBytes());  //"utf-8"
            gzip.close();  
            compressed = out.toByteArray();
        } catch (IOException e) {  
        	compressed = null;
        }finally{
        	if(gzip != null){
        		try {
					gzip.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
        	}
        	if (out != null) {
				try {
					out.close();
				} catch (IOException e) {
				}
			}
        }
        return compressed;  
    }  
	

	/**
     * 向指定 URL 发送POST方法的请求
     * 
     * @param url
     *            发送请求的 URL
     * @return 所代表远程资源的响应结果
	 * @throws Exception 
     */
    private static String sendPost(String url, byte[] arr) throws Exception {
    	OutputStream out = null;
        BufferedReader in = null;
        ByteArrayOutputStream bos = null;
        String result = "";
        try {
            URL realUrl = new URL(url);
            // 打开和URL之间的连接
            HttpURLConnection conn = (HttpURLConnection) realUrl.openConnection();
            // 发送POST请求必须设置如下两行
            conn.setDoOutput(true);
            conn.setDoInput(true);
            // 获取URLConnection对象对应的输出流
            out = conn.getOutputStream();
            // 发送请求参数
            out.write(arr);
            // flush输出流的缓冲
            out.flush(); 
            
            //接收返回值
            InputStream is = null;
            if(conn.getResponseCode() == HttpURLConnection.HTTP_OK || conn.getResponseCode() == HttpURLConnection.HTTP_CREATED
            		|| conn.getResponseCode() == HttpURLConnection.HTTP_ACCEPTED)
            	is = conn.getInputStream();
            else{
            	is = conn.getErrorStream();
            	throw new Exception("request is not deal correct!");
            }
          byte[] buf = new byte[1024];
          bos = new ByteArrayOutputStream();
          int offset = -1;
          while((offset = is.read(buf)) != -1){
        	  bos.write(buf, 0, offset);
          }
          System.out.println(bos.toString());
        } catch (Exception e) {
            System.out.println("发送 POST 请求出现异常！"+e);
            throw e;
        }
        //使用finally块来关闭输出流、输入流
        finally{
            try{
                if(out!=null){
                    out.close();
                }
                if(in!=null){
                    in.close();
                }
                if(bos != null){
                	bos.close();
                }
            }
            catch(IOException ex){
                ex.printStackTrace();
            }
        }
        return result;
    }



	/**
	 * 向指定 URL 发送GET方法的请求
	 *
	 * @param url
	 *            发送请求的 URL
	 * @return 所代表远程资源的响应结果
	 * @throws Exception
	 */
	private static String sendGet(String url, byte[] arr) throws Exception {
		OutputStream out = null;
		BufferedReader in = null;
		ByteArrayOutputStream bos = null;
		String result = "";
		try {
			URL realUrl = new URL(url);
			// 打开和URL之间的连接
			HttpURLConnection conn = (HttpURLConnection) realUrl.openConnection();
			// 获取URLConnection对象对应的输出流
			out = conn.getOutputStream();
			// 发送请求参数
			out.write(arr);
			// flush输出流的缓冲
			out.flush();

			//接收返回值
			InputStream is = null;
			if(conn.getResponseCode() == HttpURLConnection.HTTP_OK || conn.getResponseCode() == HttpURLConnection.HTTP_CREATED
					|| conn.getResponseCode() == HttpURLConnection.HTTP_ACCEPTED)
				is = conn.getInputStream();
			else{
				is = conn.getErrorStream();
				throw new Exception("request is not deal correct!");
			}
			byte[] buf = new byte[1024];
			bos = new ByteArrayOutputStream();
			int offset = -1;
			while((offset = is.read(buf)) != -1){
				bos.write(buf, 0, offset);
			}
			System.out.println(bos.toString());
		} catch (Exception e) {
			System.out.println("发送 POST 请求出现异常！"+e);
			throw e;
		}
		//使用finally块来关闭输出流、输入流
		finally{
			try{
				if(out!=null){
					out.close();
				}
				if(in!=null){
					in.close();
				}
				if(bos != null){
					bos.close();
				}
			}
			catch(IOException ex){
				ex.printStackTrace();
			}
		}
		return result;
	}





	//加密
	   private static String encode(byte[] bstr){    
	   return new sun.misc.BASE64Encoder().encode(bstr);    
	   }    
	   
	   //解密
	   private static byte[] decode(String str){    
	   byte[] bt = null;    
	   try {    
	       sun.misc.BASE64Decoder decoder = new sun.misc.BASE64Decoder();    
	       bt = decoder.decodeBuffer( str );    
	   } catch (IOException e) {    
	       e.printStackTrace();    
	   }    
	       return bt;    
	   }    
	
	public static void main(String[] args){
		//String jsonString = "[{\"id\":\"1\",\"name\":\"zhangsan\",\"query\":\"{\'a\':\'b\'}\"},{\"id\":\"2\",\"name\":\"lisi\",\"age\":14,\"mm\":\"nn\"}]";
		for(int i = 0; i < 2; i ++){
			String jsonString = "{\"ak\":\"ak\",\"vername\":\"bim web云测试\",\"mac\":\"C3BBAD16-B47F-4DBB-944F-13500C604648\",\"prjname\":\"大小写测试.GBQ5\",\"fncode\":1021,\"query\":{\"inforegion\":\"北京\"},\"fnname\":\"点击造价\",\"hardwareid\":\"C3BBAD16-B47F-4DBB-944F-13500C604648\",\"trigertime\":\"2017/04/12 16:40:11 594\",\"sys\":2,\"ver\":\"1.1.1\",\"projectid\":\"ff8080815b5b68f8015b6023d29e08a6\",\"sysver\":\"10.3\",\"pcode\":\"-103000\",\"utype\":\"2\",\"fngroup\":\"造价页签\",\"gid\":\"6127630218902238065\",\"receivetime\":\"2017/04/12 16:40:07 858\",\"ip\":\"223.104.3.238\"}";
//			String jsonString = "http://10.127.49.96:8088/web_event/web.gif?method=web_event_srv.upload&event={\"ut\": \"2018-10-24 15:43:27\",\"tz\": 28800000,\"debug\": 0,\"ak\": \"fe7d85c77a704c53ad0e88dd08444cbe\",\"usr\": {\"did\": \"16699fce3892d-01f75659aebb9d-5c1b3517-1fa400-16699fce38a156\"},\"data\": [\n" +
//					"{\"dt\": \"evt\",\"pr\": {\"$ct\": 1540367007080,\"$tz\": 28800000,\"$sid\": 1540365706836,\"$url\": \"http://10.127.49.96:8088/zhuge/zhugeanalyticstest.html\",\"$ref\": \"\",\"$referrer_domain\": \"\",\"$eid\": \"fncode\",\"_pcode\": 1,\"_sessionid\": 1540365706836,\"_fncode\": \"fncode\",\"_fnname\": \"fnname\",\"_fngroup\": \"fngroup\",\"_trigertime\": \"\",\"_device_id\": \"16699fce3892d-01f75659aebb9d-5c1b3517-1fa400-16699fce38a156\",\"_query\": {\"a\": 1,\"b\": \"sadf\",\"v\": {\"a\": 12}},\"_appname\": \"whqtest\"}}\n" +
//					"]}&_=1540367007081";
			try {
				System.out.println(Manager.sendToServer(jsonString));
			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
//		for(int i = 0; i < 1; i ++){
//			String jsonString = "{\"vername\":\"云计价助手\",\"mac\":\"C3BBAD16-B47F-4DBB-944F-13500C604648\",\"prjname\":\"大小写测试.GBQ5\",\"fncode\":1021,\"query\":{\"inforegion\":\"北京\"},\"fnname\":\"点击造价\",\"hardwareid\":\"C3BBAD16-B47F-4DBB-944F-13500C604648\",\"trigertime\":\"2017/04/12 16:40:11 594\",\"sys\":2,\"ver\":\"1.1.1\",\"projectid\":\"ff8080815b5b68f8015b6023d29e08a6\",\"sysver\":\"10.3\",\"pcode\":\"-101002\",\"utype\":\"2\",\"fngroup\":\"造价页签\",\"gid\":\"6127630218902238065\",\"receivetime\":\"2017/04/12 16:40:07 858\",\"ip\":\"223.104.3.238\"}";
//			try {
//			} catch (Exception e) {
//				e.printStackTrace();
//			}
//			System.out.println("--------------");
//		}
//		
//		System.out.println("****************万恶的分割线******************");
//		try {
//			Thread.sleep(10 * 1000);
//		} catch (InterruptedException e1) {
//			e1.printStackTrace();
//		}
		
//		for(int i = 0; i < 1; i ++){
//			String jsonString = "{\"pcode\":\"-101002\",\"fncode\":111000,\"trigertime\":\"2016/11/30 15:20:45 52\",\"mac\":\"122\",\"sys\":2,\"sysver\":\"mm\",\"query\":\"{\'ppp\':\'qqq\',\'哈哈\':\'呵呵\'}\"}";
//			try {
//				System.out.println(Manager.sendToServer(jsonString));
//			} catch (Exception e) {
//				e.printStackTrace();
//			}
//			System.out.println("--------------");
//		}
		
		File directory = new File("");
		String path = directory.getAbsolutePath();
		System.out.println(path);
		File file = new File(path + "\\data.txt");
		writeToFile(file);
	}
	
}