package com.hxzkoa.udp;

import java.math.BigInteger;

import com.hxzkoa.json.tb_achor;
import com.hxzkoa.json.tb_person;
import com.hxzkoa.json.tb_system;
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 DellMessage {
	static int start = 0;
	static String baoxu = "00";
	static String receive_tagid0;
	static String anchormode = "image/anchor/基站在线.png";
	static boolean baoxuyiyang = false;
	static int anchornum;// 和某一个标签测距的基站的数量
	static int sleeptime = 0;
	// static int kuadu = Integer.parseInt(Systems.sys().getRssid());// 跨度
	static int i = 0;
	static String postUrl = Config.getPostUrl();
	static String url_tag_bw = postUrl + "labelManagement_search.do";
	static String url_warning_bw = postUrl + "warningSummary_search.do";
	static String url_realTimeWarning_bw = postUrl + "realTimeWarning_search.do";
	static String url_person_bw = postUrl + "personManagement_search.do";
	static String url_realAttendance_bw = postUrl + "realAttendance_search";
	static String url_sysSetting_bw = postUrl + "sysSetting_bw.do";
	static String url_label_bw_power = postUrl + "label_bw_power.do";
	static String url_fenceList_bw = postUrl + "fenceList_bw.do";
	static String url_xunjiansetList_bw = postUrl + "xunjiansetList_bw.do";
	static String url_warning_bw_add = postUrl + "warning_bw_add.do";
	static String url_realinwarning_bw_add = postUrl + "realinwarning_bw_add.do";
	static String url_realinwarning_bw_remove = postUrl + "realinwarning_bw_remove.do";
	static String url_track_bw_add = postUrl + "track_bw_add.do";
	static String url_realAttendance_bw_add = postUrl + "realAttendance_bw_add.do";
	static String url_xunjianset_bw_add = postUrl + "xunjianset_bw_add.do";
	static String url_person_bw_power = postUrl + "person_bw_power.do";
	static String url_person_bw_SOS = postUrl + "person_bw_power.do";
	static String url_person_bw_kaoqin = postUrl + "person_bw_kaoqin.do";
	static String url_person_bw_warning = postUrl + "person_bw_warning.do";
	static String url_map_bw_floor = postUrl + "map_bw_floor.do";
	static String url_anchor_bw_status = postUrl + "anchor_bw_status.do";
	static String url_setting_bw = postUrl + "getSysSetting.do";
	static String url_anchor_bw = postUrl + "anchorManagement_search.do";
	private static String hexStr = "0123456789ABCDEF";
	private static String[] binaryArray = { "0000", "0001", "0010", "0011", "0100", "0101", "0110", "0111", "1000",
			"1001", "1010", "1011", "1100", "1101", "1110", "1111" };

	@SuppressWarnings("unused")
	/** 处理原始测距信息 */
	public static void dell_info(String ip, String infom, String addtime, int timestamp) {

		if (infom.startsWith("55AA01")) {

			// 原始数据
			String[] hex = StringToHex.hex(infom);

			// 指令类型
			StringBuffer zhilingtype = new StringBuffer(hex[2]);

			// 数据长度
			StringBuffer lenth = new StringBuffer(String.valueOf(decodeHEX(hex[3])));

			// 包序
			StringBuffer receive_baoxu = new StringBuffer(String.valueOf(decodeHEX(hex[4])));

			// 模块ID receive_tagid
			StringBuffer receive_tagid = new StringBuffer(hex[6] + hex[5]);

			// 模块ID receive_anchorid
			StringBuffer receive_anchorid = new StringBuffer(hex[8] + hex[7]);

			// 距离
			int receive_distance = decodeHEX(hex[12] + hex[11] + hex[10] + hex[9]);

			// 电量
			StringBuffer battery = new StringBuffer(String.valueOf(decodeHEX(hex[13])));

			int batteryint = decodeHEX(hex[13]);

			// 按键
			StringBuffer button = new StringBuffer(bytes2BinaryStr(HexStringToBinary(hex[14])).substring(7, 8));

			// 标签静止
			StringBuffer jingzhi = new StringBuffer(
					bytes2BinaryStr(HexStringToBinary(infom.substring(28, 30))).substring(6, 7));

			// 标签休眠
			StringBuffer xiumian = new StringBuffer(
					bytes2BinaryStr(HexStringToBinary(infom.substring(28, 30))).substring(5, 6));

			// 信号强度1
			StringBuffer Strong1 = new StringBuffer("-" + decodeHEX(hex[15]));

			// 信号强度差
			StringBuffer Strong2 = new StringBuffer("-" + decodeHEX(hex[16]));

			// 标签频率
			StringBuffer taghz = new StringBuffer(String.valueOf(decodeHEX(hex[17])));

			int int_taghz = decodeHEX(hex[17]);

			// 标签时间片
			StringBuffer time_pian = new StringBuffer(String.valueOf(decodeHEX(hex[18])));

			StringBuffer data = new StringBuffer(addtime + "  收  ip:" + ip + "  包序:" + receive_baoxu + "  标签:"
					+ receive_tagid + "  基站:" + receive_anchorid + "  距离:" + receive_distance + "  电量:" + battery + "%"
					+ "  按键:" + button + "  静止:" + jingzhi + "  休眠:" + xiumian + "  power:" + Strong1 + "  power_diff:"
					+ Strong2 + "  taghz:" + taghz + "  timepian:" + time_pian);

			 StringBuffer huceju=new StringBuffer(GetNowTime.now2()+" 基站:"+receive_tagid+" 基站:"+receive_anchorid+" 距离:"+receive_distance+" cm");

			// 低电量告警
			 if(batteryint<5) {
			 Warnig.lowpower(batteryint, receive_tagid.toString());
			 }

			/** SOS告警 **/
			 Warnig.sos(button, jingzhi, xiumian, receive_tagid, addtime,
			 receive_baoxu);

			
			// 互测距显示测距信息
			 String AnchorPath = Config.getAnchorConfig();
			 String beice_anchor = ModifyConfig.readData(AnchorPath, "beice_anchor");
			 if(beice_anchor!="") {
				 if(beice_anchor.equals(receive_tagid.toString())) {
					 ModifyConfig.writeData(AnchorPath, "huceju", huceju.toString());
				 }				 
			 }
			 //报文显示
//			 String postUrl = Config.getPostUrl();
//			 String yuanshiMessage=postUrl+"yuanshiMessage.do";
			 String messageJson =  GetNowTime.timestamp2()+ " 收：" +data.toString() ;
//			 JSONObject json = JSONObject.fromObject(messageJson);
//			 HttpUtil.doPost(yuanshiMessage, json, "UTF-8");
			 String BaowenPath = Config.getBaowenConfig();
				String baowenContent = ModifyConfig.readData(BaowenPath, "yuanshiMessage");
				String baowenStatus = ModifyConfig.readData(BaowenPath, "baowenSwitch");
				if (baowenStatus.equals("1")){
					/* Udp_Receive.yuanshiMessage.add(messageJson); */
				}

//			// 更新基站状态为在线
//			// Anchor_Dell.set_anchor_mode(receive_anchorid.toString(), "1",
//			// ip.toString());
//			tb_achor anchor = new tb_achor();
//			anchor.setAnchorid(receive_anchorid.toString());
//			anchor.setAnchormode("1");
//			anchor.setAnchorip(battery.toString());
//			JSONObject anchorobject = JSONObject.fromObject(anchor);
//			HttpUtil.doPost(url_anchor_bw_status, anchorobject.toString(), Config.getCharset());
//
//			// 更改标签的状态和电量信息
//			tb_tag tag = new tb_tag();
//			tag.setTag_id(receive_tagid.toString());
//			tag.setPower(battery.toString());
//			JSONObject tagobject = JSONObject.fromObject(tag);
//			HttpUtil.doPost(url_label_bw_power, tagobject.toString(), Config.getCharset());
//
//			// 修改标签的人员的SOS状态
//			// person_Dell.alert_sos(receive_tagid.toString(),
//			// button.toString());
//			tb_person person = new tb_person();
//			person.setP_tagid(receive_tagid.toString());
//			person.setP_power(battery.toString());
//			person.setP_sos(button.toString());
//			JSONObject personObject = JSONObject.fromObject(person);
//			HttpUtil.doPost(url_person_bw_SOS, personObject.toString(), Config.getCharset());
//
//			// 修改人员的电量信息,
//			// person_Dell.alert_person_power(receive_tagid.toString(),
//			// battery.toString());
//			
//			HttpUtil.doPost(url_person_bw_power, personObject.toString(), Config.getCharset());
//			
//			//setting
//			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);
//			
//			//get anchor
//			JSONObject re_tb_anchor = HttpUtil.doPost(url_anchor_bw, anchorobject.toString(), Config.getCharset());
//			tb_achor re_anchor = (tb_achor) JSONObject.toBean(JSONObject.fromObject(re_tb_anchor.get("result").toString()),
//					tb_system.class);
//
//			/** 铁科院定制算法已知标签所在的组和需要用来计算的基站 */
//			 if(re_setting.getKnow_tag_zu().equals("1") &&
//			 Dell_usetaganchor.get_UseTagAndAnchor(receive_tagid.toString())
//			 !=null) {
//			
//			 UseTagAndAnchor
//			 usta=Dell_usetaganchor.get_UseTagAndAnchor(receive_tagid.toString());
			 
		}
	}

	/**
	 * 数据给到JNA处理
	 * 
	 * @param receive_baoxu接收到的包序
	 * @param receive_tagid接收到的标签id
	 * @param receive_anchorid接收到的基站id集合
	 * @param receive_distance接收到的距离集合
	 * @param stationary_flag
	 *            静止状态
	 * @param signal_power信号强度
	 * @param timestamp时间戳
	 * @param int_taghz标签的频率
	 */
	public static void dellforJNA(String ip, String receive_baoxu, String receive_tagid, String receive_anchorid,
			String receive_distance, String stationary_flag, String signal_power, int timestamp, String sos,
			String battery, String layer, String power, String power_diff, int int_taghz) {

		Ceju cej = new Ceju();
		cej.setCe_baoxu(receive_baoxu);
		cej.setCe_ip(ip);
		cej.setCe_tagid(receive_tagid);
		cej.setCe_timestamp(timestamp);
		cej.setCe_anchorid(receive_anchorid);
		cej.setCe_distance(receive_distance);
		cej.setCe_battery(battery);// 电量
		cej.setCe_power(power);
		cej.setCe_power_diff(power_diff);
		cej.setCe_taghz(int_taghz);
		cej.setCe_jingzhi(stationary_flag);

//		 Dell_Ceju.dell_ceju(ip,receive_tagid,cej,Integer.parseInt(receive_baoxu),receive_anchorid);

	}

	/** 16进制转为10进制 */
	public static int decodeHEX(String hexs) {
		BigInteger bigint = new BigInteger(hexs, 16);
		int numb = bigint.intValue();
		return numb;

	}

	/** 32进制转为10进制 */
	public static String change32To10(String num) {
		int f = 32;
		int t = 10;
		return new java.math.BigInteger(num, f).toString(t);
	}

	/**
	 * 将byte[]转为各种进制的字符串
	 * 
	 * @param bytes
	 *            byte[]
	 * @param radix
	 *            基数可以转换进制的范围，从Character.MIN_RADIX到Character.MAX_RADIX，超出范围后变为10进制
	 * @return 转换后的字符串
	 */
	public static String binary(byte[] bytes, int radix) {
		return new BigInteger(1, bytes).toString(radix);// 这里的1代表正数
	}

	private static final char[] HEXES = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e',
			'f' };

	/**
	 * byte数组 转换成 16进制小写字符串
	 */
	public static String bytes2Hex(byte[] bytes) {
		if (bytes == null || bytes.length == 0) {
			return null;
		}

		StringBuilder hex = new StringBuilder();

		for (byte b : bytes) {
			hex.append(HEXES[(b >> 4) & 0x0F]);
			hex.append(HEXES[b & 0x0F]);
		}

		return hex.toString();
	}

	/**
	 * 截取指定长度的BYTE数组
	 * 
	 * @param src原字节数组
	 * @param 开始位置
	 * @param 截取长度
	 */
	public static byte[] subBytes(byte[] src, int begin, int count) {
		byte[] bs = new byte[count];
		System.arraycopy(src, begin, bs, 0, count);
		return bs;
	}

	/**
	 * 
	 * @param hexString
	 * @return 将十六进制转换为字节数组
	 */
	public static byte[] HexStringToBinary(String hexString) {
		// hexString的长度对2取整，作为bytes的长度
		int len = hexString.length() / 2;
		byte[] bytes = new byte[len];
		byte high = 0;// 字节高四位
		byte low = 0;// 字节低四位

		for (int i = 0; i < len; i++) {
			// 右移四位得到高位
			high = (byte) ((hexStr.indexOf(hexString.charAt(2 * i))) << 4);
			low = (byte) hexStr.indexOf(hexString.charAt(2 * i + 1));
			bytes[i] = (byte) (high | low);// 高地位做或运算
		}
		return bytes;
	}

	/**
	 * 
	 * @param str
	 * @return 转换为二进制字符串
	 */
	public static String bytes2BinaryStr(byte[] bArray) {

		String outStr = "";
		int pos = 0;
		for (byte b : bArray) {
			// 高四位
			pos = (b & 0xF0) >> 4;
			outStr += binaryArray[pos];
			// 低四位
			pos = b & 0x0F;
			outStr += binaryArray[pos];
		}
		return outStr;

	}

}