package com.product.device.data.gather.service;
 
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.nio.charset.Charset;

import com.product.core.dao.BaseDao;
import com.product.core.spring.context.SpringMVCContextHolder;

import org.mozilla.universalchardet.UniversalDetector;


public class DeviceDataProcessThread extends Thread {
	Charset utf8Charset = Charset.forName("UTF-8");
    Charset gbkCharset = Charset.forName("GBK");
    Charset gbCharset = Charset.forName("GB2312");
    Charset ISOCharset = Charset.forName("ISO-8859-1");
    Charset US = Charset.forName("US-ASCII");
    
    public BaseDao baseDao;
    
	Socket socket = null;
	//每启动一个线程，连接对应的Socket
 
	public DeviceDataProcessThread(Socket socket,BaseDao dao) {
		this.socket = socket;
		this.baseDao=dao;
	}
	
	//启动线程，即响应客户请求
	public void run() { 
        BufferedReader reader=null;
        
        BufferedWriter writer=null; 
		try {
			reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));//读取客户端消息  
            writer=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));//向客户端写消息
            String line="";
            while((line=reader.readLine()) !=null ){
//            	SpringMVCContextHolder.getSystemLogger().info("=============="+encode(line));
            	SpringMVCContextHolder.getSystemLogger().info("=====字符编码："+getEncoding(line));
            	SpringMVCContextHolder.getSystemLogger().info("=====收到来自客户端发送的消息是：" + line);
//            	SpringMVCContextHolder.getSystemLogger().info("=====收到来自客户端的发送的消息是1111：" + new String(line.getBytes(utf8Charset)));
//            	SpringMVCContextHolder.getSystemLogger().info("=====收到来自客户端的发送的消息是1：" + new String(line.getBytes(US),gbkCharset));
//            	SpringMVCContextHolder.getSystemLogger().info("=====收到来自客户端的发送的消息是12：" + new String(line.getBytes(US),utf8Charset));
//            	String lineGBK = new String(line.getBytes(ISOCharset), gbkCharset); 
//            	SpringMVCContextHolder.getSystemLogger().info("=====收到来自客户端的发送的消息是2：" + lineGBK);
//            	String lineUTF8 = new String(line.getBytes(ISOCharset), utf8Charset); 
//            	SpringMVCContextHolder.getSystemLogger().info("=====收到来自客户端的发送的消息是3：" + lineUTF8);
//            	String lineiso = new String(line.getBytes(utf8Charset), ISOCharset); 
//            	SpringMVCContextHolder.getSystemLogger().info("=====收到来自客户端的发送的消息是4：" + lineiso);
//            	String lineug = new String(line.getBytes(utf8Charset), gbkCharset); 
//            	SpringMVCContextHolder.getSystemLogger().info("=====收到来自客户端的发送的消息是5：" + lineug);
//            	
//            	String linegi = new String(line.getBytes(gbkCharset), ISOCharset); 
//            	SpringMVCContextHolder.getSystemLogger().info("=====收到来自客户端的发送的消息是6：" + linegi);
//            	String linegu = new String(line.getBytes(gbkCharset), utf8Charset); 
//            	SpringMVCContextHolder.getSystemLogger().info("=====收到来自客户端的发送的消息是7：" + linegu);
            } 
            
          writer.write("服务器已收到:"+line+"\n");  
          writer.flush(); 
		} catch (IOException e) {
			e.printStackTrace();
		} finally{
			try {
				if(reader!=null) {
					reader.close();
				}
				if(writer!=null) {
					writer.close();
				}
//				if(socket!=null) {
//					socket.close();
//				}
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	
	}
	
	public static  String encode(String str) {
//        String testString = "这是一个测试字符串";
        byte[] testData = str.getBytes();
 
        // 初始化 CharsetDetector
        UniversalDetector detector = new UniversalDetector(null);
 
        // 将数据填充到 CharsetDetector
        detector.handleData(testData, 0, testData.length);
 
        // 完成数据填充
        detector.dataEnd();
 
        // 获取检测出来的字符集
        String encoding = detector.getDetectedCharset();
 
        if (encoding != null) {
            System.out.println("编码格式为：" + encoding);
        } else {
            System.out.println("未能检测出编码格式。");
        }
 
        // 释放资源
        detector.reset();
        return encoding;
    }
	
	
	public static String getEncoding(String str) {
        String encode = "GB2312";
        try {
            if (isEncoding(str, encode)) { // 判断是不是GB2312
                return encode;
            }
        } catch (Exception exception) {
        	
        }
        encode = "ISO-8859-1";
        try {
            if (isEncoding(str, encode)) { // 判断是不是ISO-8859-1
                return encode;
            }
        } catch (Exception exception1) {
        }
        encode = "UTF-8";
        try {
            if (isEncoding(str, encode)) { // 判断是不是UTF-8
                return encode;
            }
        } catch (Exception exception2) {
        }
        encode = "GBK";
        try {
            if (isEncoding(str, encode)) { // 判断是不是GBK
                return encode;
            }
        } catch (Exception exception3) {
        }
        return "如果都不是，说明输入的内容不属于常见的编码格式"; // 如果都不是，说明输入的内容不属于常见的编码格式。
    }

	public static boolean isEncoding(String str, String encode) {
        try {
            if (str.equals(new String(str.getBytes(), encode))) {
                return true;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false;
    }

}