package com.hxzkoa.udp;

import java.util.List;

import com.hxzkoa.json.Tag_regist_msg;
import com.hxzkoa.json.tb_achor;
import com.hxzkoa.json.tb_tag;
import com.hxzkoa.util.Config;
import com.hxzkoa.util.HttpUtil;
import com.hxzkoa.util.ModifyConfig;

import net.sf.json.JSONObject;

/** 处理标签的注册信息集合 */
public class Dell_tag_reg_ms implements Runnable {
	Thread t = new Thread(this);
	/** 启动线程的方法 */
	public void startThread() {
		t.start();
	}
	

	public void stopThread() {
		try {
            Thread.sleep(2000);
            t.interrupt();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
	}

	public void run() {
		while (true) {
			// get_ok_regs(GetNowTime.timestamp());
			try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				// TODO 自动生成的 catch 块
				e.printStackTrace();
				Thread.interrupted();
			} // 休眠时间
		}
	}

	/** 寻找有效的注册信息给到JNA处理 */
	public void get_ok_regs(int nowtimestamp, List<Tag_regist_msg> t_r_mList, tb_achor anchor, String Zhuceanchor,
			String udp_out, String wifi_model) {
		if (t_r_mList.size() != 0) {
			// 取system
			// String url_sysSetting_bw = Config.getPostUrl() +
			// "sysSetting_bw.do";
			// JSONObject re_sysSetting_bw = HttpUtil.doPost(url_sysSetting_bw,
			// "", Config.getCharset());
			// tb_system system = (tb_system) JSONObject
			// .toBean(JSONObject.fromObject(re_sysSetting_bw.get("result").toString()),
			// tb_system.class);

			for (int i = 0; i < t_r_mList.size(); i++) {
				int timestamp = t_r_mList.get(i).getTimestamp();

				// 如果现在的时间戳减去第一条注册信息的时间戳大于200ms
				if (nowtimestamp - timestamp >= 200) {
					String anchorid = t_r_mList.get(i).getAnchorid();
					String tagid = t_r_mList.get(i).getTagid();
					int tag_freq = t_r_mList.get(i).getTaghz();

					int tagidint = 0;
					// 如果标签ID存在字母
					if (JugeHaveZimu.haszimu(tagid)) {
						tagidint = ReadPeizhiMessage.decodeHEX(tagid);
					} else {
						tagidint = Integer.parseInt(tagid);
					}

					// 将数据给到动态库
					int shijianpian = DellJAN.get_slotted_aloha(timestamp, tagidint, tag_freq);

					// BaoWenShow.show(" 收："+GetNowTime.timestamp2()+";
					// ToJNA:"+timestamp+"; tagid:"+tagidint+";
					// tag_freq:"+tag_freq+"; pian:"+shijianpian, "注册报文");

					// 计算出时间片后将数据给到基站
					byte[] byt = Read_Write_Anchor_Message.write_timestamp(tagid, tag_freq, shijianpian);

					// 显示注册报文信息
					if (anchor != null) {
						String ip = anchor.getAnchorip();

						// 如果指定了给某个基站下发注册信息
						if (Zhuceanchor.length() > 3) {
							anchorid = Zhuceanchor;
							ip = anchor.getAnchorip();
							Udp_Out.out(byt, byt.length, ip, udp_out, wifi_model);

						} else if (Dell_Ip.get_ipanchor(ip) != null) {
							Udp_Out.out(byt, byt.length, ip, udp_out, wifi_model);
						}

						// BaoWenShow.show(ip+"基站："+anchorid+";"+BytesToHex.bytesToHex(byt),
						// "注册报文");
					}
					// 删除掉该数据
					t_r_mList.remove(t_r_mList.get(i));
				}
			}
		}

	}

	/** 处理注册信息 */
	public static void dellrgs(String infom, String ip) {

		String[] hex = StringToHex.hex(infom);
		String url_tag_bw = Config.getPostUrl() + "labelManagement_search.do";

		String anchorid = hex[5] + hex[4];
		String tagid = hex[7] + hex[6];
		String tagstate = DellMessage.bytes2BinaryStr(DellMessage.HexStringToBinary(hex[8]));

		// 开启振动01
		String move_open = tagstate.substring(7, 8);

		// 开启休眠01
		String sleep_open = tagstate.substring(6, 7);

		// 按键状态01表示按下
		String button = tagstate.substring(5, 6);

		// 标签版本号
		String version = "V" + Integer.parseInt(hex[10], 16) + "." + Integer.parseInt(hex[9], 16);

		// 标签的频率
		int hz = Integer.parseInt(hex[11], 16);

		// 标签的功率
		int gonglv = Integer.parseInt(hex[12], 16);

		// 标签的加速计阈值
		int speed = Integer.parseInt((hex[14] + hex[13]), 16);

		// 标签静止休眠时间
		int sleep_time = Integer.parseInt((hex[16] + hex[15]), 16);

		// 标签信号强度
		int power = Integer.parseInt((hex[17]), 16);

		// 修改基站的在线状态及IP
		tb_achor anchor = new tb_achor();
		anchor.setAnchorid(anchorid);
		anchor.setAnchormode("1");
		anchor.setAnchorip(ip);
		// Anchor_Dell.set_anchor_mode(anchorid, "1", ip);

		// 显示标签注册信息
		// if(TcpIpManage.getStar()&&
		// TcpIpManage.getDatatypeis().equals("注册报文")) {
		String message = GetNowTime.timestamp2() + "收：" + "基站:" + anchorid + ", 标签:" + tagid + ", 标签状态:" + tagstate
				+ ", 振动:" + move_open + ", 休眠:" + sleep_open + ", 版本:" + version + ", 频率:" + hz + ", 功率:" + gonglv
				+ ", 加速计:" + speed + ", 休眠时间:" + sleep_time + ", 信号强度：" + power;
		// TcpIpManage.get_text_area().setCaretPosition(TcpIpManage.get_text_area().getText().length());
		// }

		// 如果标签在列表中存在
		// if(Tag_Dell.get_tag(tagid) !=null && !ToolBarModel.isAddtagzidong())
		// {
		// 报文显示
		// 原始报文
//		String postUrl = Config.getPostUrl();
//		String yuanshiMessage = postUrl + "yuanshiMessage.do";
		String messageJson =   message;
//		JSONObject json = JSONObject.fromObject(messageJson);
//		HttpUtil.doPost(yuanshiMessage, json, "UTF-8");
		String BaowenPath = Config.getBaowenConfig();
		String baowenStatus = ModifyConfig.readData(BaowenPath, "baowenSwitch");
		if (baowenStatus.equals("1")){
			/* Udp_Receive.yuanshiMessage.add(messageJson); */
		}
		// 注册报文
//		String zhuceMessage = postUrl + "zhuceMessage.do";
//		JSONObject zhucejson = JSONObject.fromObject(messageJson);
//		HttpUtil.doPost(zhuceMessage, zhucejson, "UTF-8");
		baowenStatus = ModifyConfig.readData(BaowenPath, "baowenSwitch");
		if (baowenStatus.equals("1")){
			/* Udp_Receive.zhuceMessage.add(messageJson); */
		}
		//
		tb_tag tag = new tb_tag();
		tag.setTag_id(tagid);
		tag.setPower(power + "");
		// 更改标签的状态和电量信息
		// Tag_Dell.set_tagpower(tagid, "100");
		JSONObject jsonObject = JSONObject.fromObject(tag);
		JSONObject re_tag_bw = HttpUtil.doPost(url_tag_bw, jsonObject.toString(), Config.getCharset());
		tb_tag re_tag = (tb_tag) JSONObject.toBean(JSONObject.fromObject(re_tag_bw.get("result").toString()),
				tb_tag.class);
		if (re_tag != null) {
			// 更新注册信息
			// Tag_Dell.alert_tag(tagid, version, hz, move_open, sleep_open,
			// button, gonglv, speed, sleep_time, power);
		} else {
			// 插入一条注册信息
			Tag_regist_msg trgmes = new Tag_regist_msg();
			trgmes.setTaghz(hz);
			trgmes.setTagid(tagid);
			trgmes.setPower(power);
			trgmes.setAnchorid(anchorid);
			trgmes.setTimestamp(GetNowTime.timestamp());
			// 如果标签注册信息集合中信息不为空
			// if (get_tagrgm(tagid) != null) {
			// //如果新上来的注册信息的信号强度大于已经存在的标签信号强度
			// int oldpower=get_tagrgm(tagid).getPower();
			//
			// if(power-oldpower<0) {
			// trgmes.setAnchorid(anchorid);
			// trgmes.setPower(power);
			// }
			// } else {
			// insert_tagrgm(tagid, trgmes);
			// }
		}
	}
}