package http;
import java.net.InetAddress;
import java.util.LinkedHashMap;
import java.util.Vector;

import Method.BaoWenShow;
import PbuliClass.ShowMessage;
import VectroData.ForwardDatas;
import cn.hutool.http.Header;
import cn.hutool.http.HttpRequest;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import tbDataModel.Tb_forward_data;
public class HTTP_Post implements Runnable{	
	static Vector<LinkedHashMap<String, Object>> displayvc=new Vector<LinkedHashMap<String,Object>>();
	static int sleeptime=1;
	static Object lock=new Object();
	/**Æô¶¯Ï̵߳ķ½·¨*/
	public void startThread() {		
		Thread t=new Thread(this);
		t.start();
	}


	public void run() {
		while(true) {			
			try {
				synchronized (lock) {
					lock.wait(sleeptime);
					zhuanfa_display();
				}
			} catch (InterruptedException e) {
				e.printStackTrace(); 
			}		
			
		}
	}
	
	/**ת·¢Î»ÖÃÊý¾Ý*/
	public static void zhuanfa_display() {		
		if(displayvc.size()>10000) {
			displayvc.removeAllElements();
		}else {
			if(displayvc.size()==0) {
				sleeptime=100;
			}else {
				sleeptime=1;
				LinkedHashMap<String, Object> displayh= displayvc.get(0);
				HTTP_Post.display("", "", displayh);
				displayvc.removeElement(displayh);
			}
		}	
		
	}
	
	/**µÇ¼ҳÃæ*/
	public static String login(String url,String admin,String password) {

		String paramJson = "{\r\n" + 
				"\"password\": \""+password+"\",\r\n" + 
				"\"account\": \""+admin+"\"\r\n" + 
				"}";

		//µ÷ÓõǼ»ñÈ¡µÄtoken
		String token ="";
		//ÇëÇó½Ó¿Ú»ñÈ¡½á¹û
		String result = HttpRequest.post(url)
				.header("token",token)
				.body(paramJson)
				.execute().body();

		JSONObject jo = JSONUtil.parseObj(result);
		JSONObject jo1 = JSONUtil.parseObj(jo.get("data"));
		String tokens=(String) jo1.get("token");
		return tokens;

	}


	/**
	 * ´«ÈëÐèÒªÁ¬½ÓµÄIP£¬·µ»ØÊÇ·ñÁ¬½Ó³É¹¦
	 * @param remoteInetAddr
	 * @return
	 */
	public static boolean isReachable(String remoteInetAddr) {
		boolean reachable = false;
		try {
			InetAddress address = InetAddress.getByName(remoteInetAddr);
			reachable = address.isReachable(5000);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return reachable;
	}


	/**HTTPת·¢Î»ÖÃÊý¾Ý
	 * /**ת·¢ÊµÊ±Î»ÖÃÊý¾Ý
	 * { 
	 * {"type": "display", "tagid": "8252", "x":"200", "y": "585", "z": "150", "floor": "0" ,"biaozhi": "23", "timestamp": "2021-05-31 23:14:14.063"},	 
	 * {"type": "display", "tagid": "8354", "x":"175", "y": "369", "z": "175", "floor": "1", "biaozhi": "23", "timestamp": "2021-05-31 23:14:14.063"},  
	 * {"type": "display", "tagid": "8680", "x":"857", "y": "814", "z": "163", "floor": "0", "biaozhi": "23", "timestamp": "2021-05-31 23:14:14.063"}
	 * }**/
	public static void display(
			String admin,
			String password,
			LinkedHashMap<String, Object> display) {
		int size=ForwardDatas.get_mou_tb_forword("HTTP-Client", "λÖÃÊý¾Ý").size();
		for(int i=0;i<size;i++) {
			String url=ForwardDatas.get_mou_tb_forword("HTTP-Client", "λÖÃÊý¾Ý").get(i).getIp();
			JSONObject json = new JSONObject(display);
			try {
				String data=json.toString();
				HttpRequest.post(url).timeout(1000).header(Header.CONTENT_TYPE,"application/json").body(data).execute().body();
				BaoWenShow.show2(data, "HTTPת·¢",url,1000);
			} catch (Exception e) {
				displayvc.removeAllElements();
				sleeptime=1000;
				ShowMessage.zidingyi("HTTPת·¢Òì³£"+url);				
			}		
		}
	}



	/**²î·Ö¶¨Î»Êý¾Ý
	 * ¸ñʽÈçÏÂ
	 * {¡°positionmsg¡±:¡±$GNGGA,043310.44,3951.73773,N,11615.40420,E,4,12,0.71,53.0,M,-8.9,M,1.4,1935*41,1234,2d¡±}
	 * Êý¾Ý¶¨Òå²Î¿¼£º¡¶±êǩʵʱλÖÃ$GNGGA¡·*/
	public static void gngga(
			String admin,
			String password,
			LinkedHashMap<String, Object> display) {
		int size=ForwardDatas.get_mou_tb_forword("HTTP-Client", "λÖÃÊý¾Ý").size();
		for(int i=0;i<size;i++) {
			//String url = "http://123.60.216.101:8081/stage-api/api/chinasoft/upload/uploadPositionForBeidou";
			String url=ForwardDatas.get_mou_tb_forword("HTTP-Client", "λÖÃÊý¾Ý").get(i).getIp();
			JSONObject json = new JSONObject(display);
			try {
				String data=json.toString();
				HttpRequest.post(url).header(Header.CONTENT_TYPE,"application/json").body(data).execute().body();
				BaoWenShow.show2(data, "HTTPת·¢",url,1000);
			} catch (Exception e) {
				ShowMessage.zidingyi("HTTPת·¢Òì³£"+url);
			}		
		}
	}


	/**HTTPת·¢¸æ¾¯Êý¾Ý*/
	public static void warnig(String admin,String password,LinkedHashMap<String, Object> message) {
		Vector<Tb_forward_data> vc=ForwardDatas.get_mou_tb_forword("HTTP-Client", "¸æ¾¯Êý¾Ý");
		int size=vc.size();
		for(int i=0;i<size;i++) {
			String url=vc.get(i).getIp();
			JSONObject json = new JSONObject(message);
			try {
				String data=json.toString();
				HttpRequest.post(url).header(Header.CONTENT_TYPE,"application/json").body(data).execute().body();
				BaoWenShow.show2(data, "HTTPת·¢",url,1000);
			} catch (Exception e) {
				ShowMessage.zidingyi("HTTPת·¢Òì³£"+url);
			}
		}
	}


	public static Vector<LinkedHashMap<String, Object>> getDisplayvc() {
		return displayvc;
	}


	public static void setDisplayvc(Vector<LinkedHashMap<String, Object>> display) {
		HTTP_Post.displayvc = display;
	}


}