package monitorGas;
import java.util.Iterator;
import java.util.List;
import java.util.Vector;
import DataBase.DatabaseManagement;
import Method.GetNowTime;
import Method.InsertData;
import PbuliClass.ShowMessage;
import engbs.engine_do;
import home.Open_soft_dialog;
import jiekou.Warnig;
import person.Person;
import person.person_Dell;
import tbDataModel_Dell.Tb_Warnig_Dell;
import urt.Control_urt;

@SuppressWarnings("rawtypes")
public class Dell_co {
	static Vector<tb_co> co_vector=new Vector<>();//¼¯ºÏ
	static {
		Open_soft_dialog.addara("¼ÓÔØtb_cojilu");
		Iterator iterator = DatabaseManagement.table_AandD("tb_cojilu","DESC").iterator();		
		while (iterator.hasNext()) {//µü´úÆ÷´æÔÚÔªËØ
			List info = (List) iterator.next();//½«µü´úÆ÷ÀïÃæµÄÔªËظøµ½info¼¯ºÏ
			//String id=(String) info.get(0);  
			String tagid=(String) info.get(1);    
			String name=(String) info.get(2);     
			String nongdu=(String) info.get(3);   
			String oknongdu=(String) info.get(4);   
			String state=(String) info.get(5);  
			String xypos=(String) info.get(6);    
			String time=(String) info.get(7);  
			tb_co c0=new tb_co();
			c0.setTagid(tagid);
			c0.setName(name);
			c0.setNongdu(nongdu);
			c0.setOknongdu(oknongdu);
			c0.setState(state);
			c0.setXypos(xypos);
			c0.setTime(time);
			co_vector.add(c0); 
		}
	}

	public static tb_co get_tb_co(String tagid) {
		tb_co co=null;
		int size=co_vector.size();
		if(size !=0) {
			for(int i=0;i<size;i++) {
				tb_co co0=co_vector.get(i);
				String tagid1=co0.getTagid();
				if(tagid.equals(tagid1)) {
					co=co0;
					break;
				}
			}
		}
		return co;

	}

	public static Vector<tb_co> getCo_vector() {
		return co_vector;
	}

	public static void setCo_vector(Vector<tb_co> co_vector) {
		Dell_co.co_vector = co_vector;
	}

	/**10ÃëÖÓ¸üÐÂtb_coµÄÊý¾Ý*/
	public static void alert_tb_cojilu() {
		int size=co_vector.size();
		if(size==0) {
			return;
		}
		StringBuffer sql=new StringBuffer("UPDATE tb_cojilu SET ");
		Vector<String> vtagid=new Vector<String>();
		Vector<String> vnongdu=new Vector<String>();
		Vector<String> vstate=new Vector<String>();
		Vector<String> vxypos=new Vector<String>();
		Vector<String> vtime=new Vector<String>();
		Vector<String> vonlie=new Vector<String>();
		for(int i=0;i<size;i++) {
			tb_co cO=co_vector.get(i);
			String tagid=cO.getTagid();
			Person per=person_Dell.get_Person(tagid);
			if(per==null) {
				continue;
			}
			String onlie=per.getP_online();			
			if(onlie==null || onlie.equals("0")) {				
				continue;
			}
			vonlie.add(onlie);
			String nongdu=cO.getNongdu();
			String state=cO.getState();
			String xypos=cO.getXypos();
			String time=cO.getTime();
			vtagid.add(tagid);
			vnongdu.add(nongdu);
			vstate.add(state);
			vxypos.add(xypos);
			vtime.add(time);

		}

		if(vonlie.size() !=0) {
			sql.append(engine_do.getinfo(vnongdu,"nongdu",vtagid,"tagid")+" , ");
			sql.append(engine_do.getinfo(vstate,"state",vtagid,"tagid")+" , ");
			sql.append(engine_do.getinfo(vxypos,"xypos",vtagid,"tagid")+" , ");
			sql.append(engine_do.getinfo(vtime,"time",vtagid,"tagid")+" ");	
			sql.append(engine_do.getlast(vtagid,"tagid"));
			//¸üÐÂÊý¾Ý¿â
			DatabaseManagement.update(sql.toString());
			sql.setLength(0);
		}

	}

	/**¸üÐÂCOŨ¶ÈÊý¾Ý*/
	public static void alertco(String type,String nongdu,String tagid,Person person) {
		if(type.equals("URT+CO")) {
			tb_co co=get_tb_co(tagid);
			String time=GetNowTime.now();
			String name=person.getP_name();
			String state="Õý³£";
			double nd=Double.parseDouble(nongdu)*10;
			if(nd>10) {
				state="Òì³£";
				ShowMessage.zidingyi(tagid+"COŨ¶ÈÒì³£Çë×¢Òâ");				
			}
			if(co==null) {				
				String[] ziduan= {"tagid","name","nongdu","oknongdu","state","time"};
				String[] zhi= {tagid,name,nongdu,"0",state,time};
				DatabaseManagement.insertfast("tb_cojilu", ziduan, zhi);
				tb_co c0=new tb_co();
				c0.setTagid(tagid);
				c0.setName(name);
				c0.setNongdu(nongdu);
				c0.setState(state);
				c0.setTime(time);
				co_vector.add(c0);
			}else {
				String x=person.getP_x()+"";
				String y=person.getP_y()+"";
				String floor=person.getP_floor();
				String xypos=x+";"+y+";"+floor;
				if(nd>1) {//Èç¹ûŨ¶ÈÒì³£
					String[] ziduan= {"tagid","name","nongdu","oknongdu","xypos","state","time"};
					String[] zhi= {tagid,name,nongdu,"0",xypos,state,time};
					DatabaseManagement.fast_alert_dbase("tb_cojilu", ziduan, zhi);
					String state1=co.getState();
					int ndz=(int)nd;
					Warnig.co_warning(nongdu,"10", tagid, x, y, floor);
					Control_urt.say_voice(tagid,"Ò»Ñõ»¯Ì¼Å¨¶ÈÒì³£Çë×¢Òâ",0,10);
					if(state1.equals("Õý³£") && nd>10) {
						String beizhu=ndz+",×ø±ê£º"+xypos;
						InsertData.sosInsertTbWarning(tagid,"COŨ¶ÈÒì³£", "δ´¦Àí",beizhu);//½«¸æ¾¯¼Ç¼³öÈëµ½Êý¾Ý¿â
						Tb_Warnig_Dell.add_tb_warning("COŨ¶ÈÒì³£", tagid, "δ´¦Àí",beizhu);
					}
					co.setState("Òì³£");

				}else {
					co.setState("Õý³£");
				}
				co.setName(name);
				co.setNongdu(nongdu);
				co.setXypos(xypos);
				co.setTime(time);
			}
		}		
	}

}