package PbuliClass; import java.util.Iterator; import java.util.List; import java.util.Vector; import DataBase.DatabaseManagement; import Method.GetNowTime; import tbDataModel.TbGas; /**»ñÈ¡ËùÓеĴ«¸ÐÆ÷¶ÔÏó*/ @SuppressWarnings("rawtypes") public class Get_Tb_Gass { static Vector TbGass=new Vector<>();//ËùÓеIJɼ¯ÒǶÔÏó //³õʼ»¯ static { Iterator iterator = DatabaseManagement.get_alldate_indatabase("tb_gas").iterator(); while (iterator.hasNext()) {//µü´úÆ÷´æÔÚÔªËØ List info = (List) iterator.next();//½«µü´úÆ÷ÀïÃæµÄÔªËØ¸øµ½info¼¯ºÏ TbGas gas=new TbGas(); gas.setId(Integer.parseInt((String)info.get(0))); gas.setWei_zhi((String)info.get(1));//²É¼¯ÒǵݲװλÖà gas.setGas_type((String)info.get(2));//´«¸ÐÆ÷µÄÖÖÀà gas.setNong_du((String)info.get(3));//Ũ¶ÈÖµ gas.setStatus((String)info.get(4));//¸æ¾¯(״̬) gas.setCollect_ip((String)info.get(5));//´«¸ÐÆ÷ËùÔڵIJɼ¯ÒǵÄÖ÷»úID gas.setTong_dao((String)info.get(6));//´«¸ÐÆ÷ËùÔڵIJɼ¯ÒÇͨµÀ gas.setWaring_zhi((String)info.get(7));//´«¸ÐÆ÷µÄ±¨¾¯Öµ gas.setIp((String)info.get(8));//´«¸ÐÆ÷ËùÔÚÖ÷»úµÄ´®¿ÚµÄIP gas.setX((String)info.get(9));//´«¸ÐÆ÷°²×°µÄX×ø±ê gas.setY((String)info.get(10));//´«¸ÐÆ÷°²×°µÄY×ø±ê gas.setAddtime((String)info.get(11));//Êý¾Ý¸üеÄʱ¼ä TbGass.add(gas); } } /**»ñÈ¡ËùÓÐµÄÆøÌå´«¸ÐÆ÷¶ÔÏó*/ public static Vector get_gass(){ return TbGass; } /**ͨ¹ýIDÕÒµ½Ä³¸öÆøÌå´«¸ÐÆ÷¶ÔÏó*/ public static TbGas get_gas(String id) { TbGas gas=null; if(TbGass.size() !=0) { Iterator it=TbGass.iterator(); while (it.hasNext()) {//µü´úÆ÷´æÔÚÔªËØ TbGas gas1 = it.next();//½«µü´úÆ÷ÀïÃæµÄÔªËØ¸øµ½info¼¯ºÏ String id1=String.valueOf(gas1.getId()); if(id1.equals(id)) { gas=gas1; break; } } } return gas; } /**»ñȡij¸ö°²×°Î»ÖõÄËùÓд«¸ÐÆ÷¶ÔÏó*/ public static Vector get_mou_weizhi_tbgas(String name) { Vector mou_tbgas=new Vector<>(); if(TbGass.size() !=0) { Iterator it=TbGass.iterator(); while (it.hasNext()) {//µü´úÆ÷´æÔÚÔªËØ TbGas gas = it.next();//½«µü´úÆ÷ÀïÃæµÄÔªËØ¸øµ½info¼¯ºÏ String weizhi=gas.getWei_zhi(); if(weizhi.equals(name)) { mou_tbgas.add(gas); } } } return mou_tbgas; } /**ͨ¹ý´«¸ÐÆ÷µÄ²É¼¯ÒÇipºÍËùÔÚͨµÀ»ñÈ¡´«¸ÐÆ÷¶ÔÏó*/ public static TbGas get_gas(String tongdao,String collect_ip) { TbGas gas=null; if(TbGass.size() !=0) { Iterator it=TbGass.iterator(); while (it.hasNext()) {//µü´úÆ÷´æÔÚÔªËØ TbGas gas1 = it.next();//½«µü´úÆ÷ÀïÃæµÄÔªËØ¸øµ½info¼¯ºÏ String tongdao2=gas1.getTong_dao(); String collect_ip1=gas1.getIp(); if(tongdao2.equals(tongdao)&& collect_ip1.equals(collect_ip)) { gas=gas1; break; } } } return gas; } /**»ñȡij¸ö²É¼¯ÒÇËùÕ¼ÓõÄͨµÀÊýÒâ˼¾ÍÊǰ²×°Á˼¸¸öÆøÌå´«¸ÐÆ÷*/ public static int get_gasnum(int id) { int gasnum=0; if(TbGass.size() !=0) { Iterator it=TbGass.iterator(); while (it.hasNext()) {//µü´úÆ÷´æÔÚÔªËØ TbGas gas1 = it.next();//½«µü´úÆ÷ÀïÃæµÄÔªËØ¸øµ½info¼¯ºÏ int ip=Integer.parseInt(gas1.getCollect_ip()); if(ip==id) { gasnum++; } } } return gasnum; } /**ɾ³ýijһ¸öÆøÌå´«¸ÐÆ÷¶ÔÏó*/ public static void delete_gas(String tongdao,String collect_ip) { if( !TbGass.isEmpty()) { TbGass.remove(get_gas(tongdao,collect_ip)); } } /**ͨ¹ýIDɾ³ýijһ¸öÆøÌå´«¸ÐÆ÷¶ÔÏó*/ public static void delete_gas(String id) { if( !TbGass.isEmpty()) { TbGass.remove(get_gas(id)); } } /**ɾ³ýËùÓеĴ«¸ÐÆ÷¶ÔÏó*/ public static void deleteall_gas() { if( !TbGass.isEmpty()) { TbGass.removeAll(TbGass); } } /**ÐÂÔö´«¸ÐÆ÷¶ÔÏó*/ public static void add_gas(String id,String tongdao,String collect_ip,String gas_type,String ip,String x,String y,String warning_zhi) { TbGas newgas=new TbGas(); newgas.setId(Integer.parseInt(id)); newgas.setTong_dao(tongdao);//´«¸ÐÆ÷ËùÔڵIJɼ¯ÒÇͨµÀ newgas.setCollect_ip(collect_ip);//´«¸ÐÆ÷ËùÔڵIJɼ¯ÒǵÄÖ÷»úID newgas.setGas_type(gas_type);//´«¸ÐÆ÷µÄÖÖÀà newgas.setIp(ip);//´«¸ÐÆ÷ËùÔÚÖ÷»úµÄ´®¿ÚµÄIP newgas.setX(x);//´«¸ÐÆ÷°²×°µÄX×ø±ê newgas.setY(y);//´«¸ÐÆ÷°²×°µÄY×ø±ê newgas.setWaring_zhi(warning_zhi);//´«¸ÐÆ÷µÄ±¨¾¯Öµ TbGass.add(newgas); } /**Ð޸Ĵ«¸ÐÆ÷¶ÔÏó*/ public static void alert_gas(String tongdao,String collect_ip,String gas_type,String ip,String x,String y,String warning_zhi) { if(get_gas(tongdao,collect_ip) !=null) { get_gas(tongdao,collect_ip).setTong_dao(tongdao);//´«¸ÐÆ÷ËùÔڵIJɼ¯ÒÇͨµÀ get_gas(tongdao,collect_ip).setCollect_ip(collect_ip);//´«¸ÐÆ÷ËùÔڵIJɼ¯ÒǵÄÖ÷»úID get_gas(tongdao,collect_ip).setGas_type(gas_type);//´«¸ÐÆ÷µÄÖÖÀà get_gas(tongdao,collect_ip).setIp(ip);//´«¸ÐÆ÷ËùÔÚÖ÷»úµÄ´®¿ÚµÄIP get_gas(tongdao,collect_ip).setX(x);//´«¸ÐÆ÷°²×°µÄX×ø±ê get_gas(tongdao,collect_ip).setY(y);//´«¸ÐÆ÷°²×°µÄY×ø±ê get_gas(tongdao,collect_ip).setWaring_zhi(warning_zhi);//´«¸ÐÆ÷µÄ±¨¾¯Öµ } } /**Ð޸Ĵ«¸ÐÆ÷µÄ״̬*/ public static void alert_gas_status(String id,String status) { if(get_gas(id)!=null) { get_gas(id).setStatus(status); get_gas(id).setAddtime(GetNowTime.gethm()); } } /**Ð޸Ĵ«¸ÐÆ÷¶ÔÏóºÍÊý¾Ý¿â*/ public static boolean alert_gasc(String id,String tong_dao,String collect_ip,String gas_type,String x,String y,String warning_zhi) { boolean alert=false; if(get_gas(id) !=null) { get_gas(id).setTong_dao(tong_dao);//´«¸ÐÆ÷ËùÔڵIJɼ¯ÒÇͨµÀ get_gas(id).setCollect_ip(collect_ip);//´«¸ÐÆ÷ËùÔڵIJɼ¯ÒǵÄÖ÷»úID get_gas(id).setGas_type(gas_type);//´«¸ÐÆ÷µÄÖÖÀà get_gas(id).setX(x);//´«¸ÐÆ÷°²×°µÄX×ø±ê get_gas(id).setY(y);//´«¸ÐÆ÷°²×°µÄY×ø±ê get_gas(id).setWaring_zhi(warning_zhi);//´«¸ÐÆ÷µÄ±¨¾¯Öµ StringBuilder updateSQL=new StringBuilder("UPDATE tb_gas SET tong_dao='" +tong_dao+"' , collect_ip='"+collect_ip+"' , gas_type='"+gas_type+"' , x='" +x+"' , y='"+y+"' , waring_zhi='"+warning_zhi+"' where id='"+id+"'"); if(DatabaseManagement.update(updateSQL.toString())==1) { alert=true; }; } return alert; } /**ÐÞ¸ÄÄ³ÆøÌå´«¸ÐÆ÷µÄŨ¶ÈÖµ*/ public static void alert_gas_nongdu(String id,String nong_du,String status) { if(get_gas(id) !=null) { get_gas(id).setNong_du(nong_du); get_gas(id).setStatus(status); get_gas(id).setAddtime(GetNowTime.HH_MM_SS()); } } /**ͨ¹ý´«¸ÐÆ÷µÄIDÕÒµ½Ä³¸ö´«¸ÐÆ÷*/ public static TbGas get_tbGas(String id) { TbGas gas=null; if(TbGass.size() !=0) { Iterator it=TbGass.iterator(); while (it.hasNext()) {//µü´úÆ÷´æÔÚÔªËØ TbGas gas1 = it.next();//½«µü´úÆ÷ÀïÃæµÄÔªËØ¸øµ½info¼¯ºÏ String id1=String.valueOf(gas1.getId()); if(id1.equals(id)) { gas=gas1; break; } } } return gas; } /**Ð޸Ĵ«¸ÐÆ÷IPµØÖ·*/ public static void alert_ip(String ip,String caijiyi_ip,String wei_zhi) { if(TbGass.size() !=0) { Iterator it=TbGass.iterator(); while (it.hasNext()) {//µü´úÆ÷´æÔÚÔªËØ TbGas tbgas=it.next(); if(tbgas.getCollect_ip().equals(caijiyi_ip)) { tbgas.setIp(ip);//Ð޸ļ¯ºÏÖвɼ¯ÒÇIPÏàͬµÄÆøÌå´«¸ÐÆ÷IPµØÖ· StringBuilder updateSQL=new StringBuilder("UPDATE tb_gas SET ip='" +ip+"',wei_zhi='"+wei_zhi+"' where collect_ip='"+caijiyi_ip+"'"); DatabaseManagement.update(updateSQL.toString()); } } } } }