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);
|
}
|
}
|
}
|
|
}
|
