package com.am;
import java.text.*;
import java.util.*;
import java.lang.*;
import java.io.*;
import java.sql.*;
import com.am.*;
public class alarm {
  public String createDatetime;
  public String station;
  public String equipment;
  public String signal;
  public String alarmInfo;
  public int tag;
 public  DataBase db = new DataBase();
 public static DealString ds = new DealString();
 private SimpleDateFormat dateFormatter;
   private String strSql;
   private Connection dbConn;

   public void setConnection(Connection dbConn) {
           this.dbConn = dbConn;
    }

    public alarm() {
     dateFormatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
     station="";
     equipment="";
     signal="";
     alarmInfo="";

     createDatetime=dateFormatter.format(new java.util.Date());
              tag=0;
              strSql="";
      dbConn=null;
 }
  public void add(){
      String tmpcreateDatetime;
      createDatetime=dateFormatter.format(new java.util.Date());
       strSql="insert into alarm ";
        strSql=strSql + "(";
        strSql=strSql + "stime,";
        strSql=strSql+"station,";
        strSql=strSql+"equipment,";
        strSql=strSql+"signal,";
        strSql=strSql+"alarmInfo,";
        strSql=strSql+"tag";
         strSql=strSql + ") ";
          strSql=strSql + "values(";
           strSql=strSql + "'" + createDatetime + "',";
           strSql=strSql + "'" + station + "',";
           strSql=strSql + "'" + equipment + "',";
           strSql=strSql + "'" + signal + "',";
           strSql=strSql + "'" + alarmInfo + "',";
          strSql=strSql + "'" + tag + "',";
          strSql=strSql + ")";
                exeSql(strSql);
  }


  public void delete(String no)
    {
         strSql="delete from `alarm` where no='";
         strSql=strSql + no + "'";
         exeSql(strSql);

    }

 public void enable(String st){
       strSql="update alarm set tag=0 where stime='";
        strSql=strSql  + this.createDatetime + "'";
        exeSql(strSql);

   }

   public void  disable()
      {
           strSql="update alarm set tag=-1 where stime='";
           strSql=strSql + this.createDatetime + "'";
           exeSql(strSql);

   }

   public boolean  init()
 {
      strSql="select * from alarm where stime=";
      strSql=strSql +"'"+ this.createDatetime + "'";
      Statement stmt=null;
      ResultSet rs=null;
    try{
          stmt=dbConn.createStatement();
          rs =stmt.executeQuery(strSql);
          if (rs.next())
          {

              createDatetime=rs.getString("stime");
              station=rs.getString("station");
              equipment=rs.getString("equipment");
              signal=rs.getString("signal");
              alarmInfo=rs.getString("alarmInfo");
              tag=rs.getInt("tag");
              return true;
          }
          else
           {return false;}

           }
              catch(Exception ex){ }
      finally
      {
          stmt=null;
          rs=null;
      return false;}
 }



   private void exeSql(String strSql)
     {
                  try
                  {
                          Statement stmt=dbConn.createStatement();
                          stmt.executeUpdate(strSql);

                  }
                  catch(Exception ex)
                  {


                  }
     }





     public ResultSet selectRecord(String sql)
             {
                     return db.QuerySQL(sql);
	}






    public Vector getAllData(){
        Vector vect = new Vector();

                strSql =" select * From alarm where tag=0 "
			+ " order by no ";

                ResultSet rs = db.QuerySQL(strSql);
		Statement stmt = null;
                try{
                        //取得列數和列名
                        ResultSetMetaData rsmd = rs.getMetaData();
                        int cols = rsmd.getColumnCount();
                        while (rs.next()) {
                                Hashtable hash = new Hashtable();
                                for (int i = 1; i <= cols; i++) {
                                        String field = ds.toString(rsmd.getColumnName(i));
                                        String value = ds.toString(rs.getString(i));
                                        if (value == null)
                                                        value = "";
                                                hash.put(field, value);
                                        }
                                        vect.add(hash);
                                }
                        }catch(Exception e){System.out.println("運行時出錯："+e);}
                        finally{
                                if(rs!=null)try{ stmt = rs.getStatement(); rs.close();}catch(Exception e){System.out.println("關閉記錄集rs時出錯"+e);}
                                if(stmt!=null) try{stmt.close();}catch(Exception e){System.out.println("關閉聲明時statement出錯"+e);}
                        }
                        return vect;
                }


public Vector getData(boolean isfather,String pxzd,boolean isdesc,String srchzd,String srchzdval,boolean isexact)
 { //isfather是否看總公司所有紀錄；pxzd按哪個字段排序；isdesc是否降序排列；srchzd按哪個字段搜索；isexact是否精確查詢
     Vector vect = new Vector();
     OpenDB ob=new OpenDB();
     dbConn=ob.getConnection();
     strSql = "";
  String zdnames="stime,station,equipment,signal,alarmInfo";
   if(isexact)
     strSql= "select "+zdnames+" from alarm where tag=0 and "+srchzd+"='"+srchzdval+"'";
   else  if(!isexact)
   strSql = "select "+zdnames+" from alarm where tag=0 and "+srchzd+" like %'"+srchzdval+"'%";
    strSql = strSql+" order by no";




    if(isdesc)
    {
    strSql = strSql+" DESC";
     }
     Hashtable ht = new Hashtable();
       ht.put("sql",strSql);
                vect.add(ht);
                    Statement stmt = null;
                   ResultSet rs=null ;



    try{          stmt = dbConn.createStatement();
                   rs = stmt.executeQuery(strSql);

                int rowno=0;

                //取得列數和列名
                ResultSetMetaData rsmd = rs.getMetaData();
                int cols = rsmd.getColumnCount();

                while(rs.next())
                {
                        rowno++;
                       // Hashtable hash = new Hashtable();
                     //   for(int i=1;i<=cols;i++)
                     //   {
                       //         String field = ds.toString(rsmd.getColumnName(i));
                       //         String value = ds.toString(rs.getString(i));
                         //       if(value==null)value="";
                       //         hash.put(field,value);
                     //   }
                   //     vect.add(hash);
               }

               vect.add(new Integer(rowno));
                }catch(Exception e){System.out.println("運行時出錯："+e);}
                finally{
                        if(rs!=null)try{ stmt = rs.getStatement(); rs.close();}catch(Exception e){System.out.println("關閉記錄集rs時出錯"+e);}
                        if(stmt!=null) try{stmt.close();}catch(Exception e){System.out.println("關閉聲明時statement出錯"+e);}
                }
                return vect;
	}

        //分頁時取得一頁的數據量
        public Vector getOnePage(String sql,int page,int records)
              {
                      return db.getOnePage(sql,page,records);
              }

         public void closeconn()
        {db.releaseConn();}

  }