package com.hxzkoa.udp;
import java.util.List;
import java.util.Vector;
import javax.persistence.Query;
import org.springframework.beans.factory.annotation.Autowired;
import com.hxzkoa.json.Baowen;
import com.hxzkoa.json.tb_system;
import com.hxzkoa.json.tb_tag;
import com.hxzkoa.json.tb_warning;
import com.hxzkoa.services.SysSettingService;
import com.hxzkoa.util.Config;
import com.hxzkoa.util.HttpUtil;

import net.sf.json.JSONObject;


public class Yuanshibaowen implements Runnable {
	int sleeptime=0;
	static Vector<Baowen> baowenvec=new Vector<Baowen>();
	
	
	public static void intsert(String ip,String hex) {
		Baowen baowen=new Baowen();
		baowen.setHex(hex);
		baowen.setIp(ip);
		baowen.setAddtime(GetNowTime.timestamp2());
		baowen.setTimestamp(GetNowTime.timestamp());	
		baowenvec.add(baowen);
	}
	
	public void dellhex() {
		int size=baowenvec.size();
		if(size !=0) {
			sleeptime=0;
			Baowen baowen=baowenvec.get(0);
			String ip=baowen.getIp();
			String hex=baowen.getHex();
			String time=baowen.getAddtime();
			int timestamp=baowen.getTimestamp();
			int lenth=hex.length();
			//存、转发
//			Have_Yuanshi_Do.Dell_yuanshi(ip, hex,time);
			
			//测距数据
			if(hex.startsWith("55AA01") && lenth==42) {
				Have_55AA01_do.dell_55AA01(ip, hex, time, timestamp);
			
			//基站心跳包
			}else if(hex.startsWith("55AA02") && lenth==32){
//				Have_55AA02_do.dellrgs(hex);	
						
			//注册报文
			}else if(hex.startsWith("55AA0A") && lenth==48) {
//				Dell_tag_reg_ms.dellrgs(hex,ip);	
				
			//基站信息返回
			}else if(hex.startsWith("55AA03") && lenth==202) {
				ReadPeizhiMessage.get_readpeizhi(ip, hex);
//				ReadPeizhiMessage.get_readpeizhi(ip,hex);
//				if(AnchorSet.isReadpeizhi()) {
//				ShowMessage.zidingyi(ip+" ��ȡ���óɹ���");
//				AnchorSet.jt_area.append("\n"+GetNowTime.timestamp2()+"\n"+ip+" ��ȡ���óɹ���");
//				}		
			//气体报文
			}else if(hex.startsWith("0103")|| hex.startsWith("0203")|| hex.startsWith("0303") ) {
				dell_gas(hex,ip);
			}

			baowenvec.removeElement(baowenvec.get(0));
			baowen=null;
			ip=null;
			hex=null;
			time=null;
			
		}else {
			sleeptime=100;
		}
	}
	
	/**处理气体数据*/
	public void dell_gas(String infom,String ip) {
			//如果开启气体监听
		String gasOpen = "0";
		String postUrl = Config.getPostUrl();
		String url_setting_bw = postUrl + "getSysSetting.do";
		JSONObject re_tb_setting = HttpUtil.doPost(url_setting_bw, "", Config.getCharset());
		tb_system re_setting = (tb_system) JSONObject.toBean(JSONObject.fromObject(re_tb_setting.get("result").toString()),
				tb_system.class);
		gasOpen = re_setting.getGas_open();
		if(gasOpen.equals("1") && infom.length()>140) {	
			ReadGas.dell_gas_data(ip,infom);
		}
	}
	
	

	
	public void startThread() {
		Thread t=new Thread(this);
		t.start();
	}

	public void run() {
		while(true) {
			try { 
				dellhex();
				
				Thread.sleep(sleeptime);
			} catch (InterruptedException e) {
				e.printStackTrace(); 
			}
		}
	}


}