修改

81041

2019-06-24 a7cdf717e2ad9f3c7a8dcff5ecfa499e2fd372e8

 sensor/src/com/fgkj/dao/impl/Sensor_infImpl.java

@@ -32,7 +32,17 @@
      boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{sinf.getSensor_dev_id(),sinf.getProvince(),sinf.getCity(),sinf.getCounty(),sinf.getDevice_name()});

      return bl;

   }

    //删除信息

   
   //修改告警值

   public boolean replaceAlarm(Object obj){

      Sensor_inf sinf=(Sensor_inf) obj;

      String sql=" repalce into db_sensor.tb_sensor_inf(sensor_dev_id,airtmp_alarm,airhum_alarm,smoke_alarm)"

            + "  values(?,?,?,?)";

      boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{sinf.getSensor_dev_id(),

         sinf.getAirtmp_alarm(),sinf.getAirhum_alarm(),sinf.getSmoke_alarm()});

      return bl;

   }

   //删除信息

   @Override

   public boolean del(Object obj) {

      Sensor_inf sinf=(Sensor_inf) obj;

@@ -50,7 +60,7 @@
   @Override

   public List serchByCondition(Object obj) {

      Sensor_inf sinf=(Sensor_inf) obj;

      String sql=" select distinct sensor_dev_id,num,province,city,county,device_name "

      String sql=" select distinct sensor_dev_id,num,province,city,county,airtmp_alarm,airhum_alarm,smoke_alarm,device_name "

            + "  from db_sensor.tb_sensor_inf  "

            + "  where sensor_dev_id=? ";

      List  list=(List) DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{sinf.getSensor_dev_id()}, new CallBack() {

@@ -66,6 +76,9 @@
                  s.setProvince(rs.getString("province"));

                  s.setCity(rs.getString("city"));

                  s.setCounty(rs.getString("county"));

                  s.setAirtmp_alarm(rs.getFloat("airtmp_alarm"));

                  s.setAirhum_alarm(rs.getFloat("airhum_alarm"));

                  s.setSmoke_alarm(rs.getInt("smoke_alarm"));

                  s.setDevice_name(rs.getString("device_name"));

                  list.add(s);

               }

@@ -126,7 +139,7 @@
   //查询所有的城市（三级）

   public List serchCounty(Object obj){

      Sensor_inf sinf=(Sensor_inf) obj;

      String sql=" select distinct county,sensor_dev_id,province,device_name from db_sensor.tb_sensor_inf where province like ? and city like ? order by province asc";

      String sql=" select distinct county from db_sensor.tb_sensor_inf where province like ? and city like ? order by province asc";

      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+sinf.getProvince()+"%","%"+sinf.getCity()+"%"}, new CallBack() {

         

         @Override

@@ -134,12 +147,40 @@
            List list=new ArrayList();

            try {

               while(rs.next()){

                  String county=rs.getString("county");

                  list.add(county);

               }

            } catch (SQLException e) {

               // TODO Auto-generated catch block

               e.printStackTrace();

            }

            return list;

         }

      });

      return list;

   }

   //查询所有的设备（四级）

   public List serchDevice(Object obj){

      Sensor_inf sinf=(Sensor_inf) obj;

      String sql=" select distinct sensor_dev_id,num,province,city,county,airtmp_alarm,airhum_alarm,smoke_alarm,device_name from db_sensor.tb_sensor_inf where province like ? and city like ? and county like ? order by province asc";

      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+sinf.getProvince()+"%","%"+sinf.getCity()+"%","%"+sinf.getCounty()+"%"}, new CallBack() {

			
         @Override

         public List getResults(ResultSet rs) {

            List list=new ArrayList();

            try {

               while(rs.next()){

                  Sensor_inf s=new Sensor_inf();

                  s.setNum(rs.getInt("num"));

                  s.setSensor_dev_id(rs.getInt("sensor_dev_id"));

                  s.setProvince(rs.getString("province"));

                  s.setCity(rs.getString("city"));

                  s.setCounty(rs.getString("county"));

                  s.setAirtmp_alarm(rs.getFloat("airtmp_alarm"));

                  s.setAirhum_alarm(rs.getFloat("airhum_alarm"));

                  s.setSmoke_alarm(rs.getInt("smoke_alarm"));

                  s.setDevice_name(rs.getString("device_name"));

                  list.add(s);

               }

            } catch (SQLException e) {

               // TODO Auto-generated catch block

@@ -165,7 +206,13 @@
   

   public static void main(String[] args) {

      Sensor_infImpl simpl=new Sensor_infImpl();

      List list=simpl.serchProvice();

      //List list=simpl.serchProvice();

      Sensor_inf sinf=new Sensor_inf();

      sinf.setSensor_dev_id(291200001);

      List<Sensor_inf> list=simpl.serchByCondition(sinf);

      for (Sensor_inf s : list) {

         System.out.println(s);

      }

      System.out.println(list.size());

   }