| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326 | using System;using System.Collections.Generic;using System.Text;using FirebirdSql.Data.FirebirdClient;using System.Data;using System.Collections;using System.IO;using System.Data.Common;using System.Diagnostics;namespace IControls_FireManager{    /*******************************************************************************************     * TB_RECEIVER(수신기) 설정 관련 Dac     *******************************************************************************************/  public class DacReceiverConfig: DacBase    {        public DacReceiverConfig()        {          //try {          //  base.Connect();          //}          //catch (Exception ex) {          //  Util.UErrorMessage(ex, 0, 0);          //}        }                ~DacReceiverConfig()        {          //try {          //  base.DisConnect();          //}          //catch (Exception ex) {          //  Util.UErrorMessage(ex, 0, 0);          //}        }        public DataTable Receiver_Select(int RECEIVER_ID)        {            DataTable dt = null;            try            {                String SQL = "";                SQL += "SELECT RECEIVER_ID,RECEIVER_NAME,IP_ADDRESS,EVENT_PORT_NO,COMMAND_PORT_NO";                SQL += ",REDUNDANT_FLAG FROM TB_RECEIVER  ";                SQL += " WHERE USE_FLAG = 'Y' AND RECEIVER_ID = {0}";                SQL = String.Format(SQL, RECEIVER_ID);                DataSet dao = Select(SQL);                dt = dao.Tables[0];            }            catch (Exception ex)            {                Util.UErrorMessage(ex, 0, 0);                throw ex;            }            return dt;        }        public DataTable Receiver_Select(String RECEIVER_ID)        {            DataTable dt = null;            try            {                String SQL = "";                if (RECEIVER_ID == null)                {                    SQL += "SELECT RECEIVER_ID,RECEIVER_NAME,IP_ADDRESS,EVENT_PORT_NO,COMMAND_PORT_NO";                    SQL += ",REDUNDANT_FLAG FROM TB_RECEIVER ";                    SQL += " WHERE USE_FLAG = 'Y'";                    SQL += " ORDER BY RECEIVER_ID";                }                else                {                    SQL += "SELECT RECEIVER_ID,RECEIVER_NAME,IP_ADDRESS,EVENT_PORT_NO,COMMAND_PORT_NO";                    SQL += ",REDUNDANT_FLAG FROM TB_RECEIVER  ";                    SQL += " WHERE USE_FLAG = 'Y' AND RECEIVER_ID = '{0}'";                    SQL = String.Format(SQL, RECEIVER_ID);                }                DataSet dao = Select(SQL);                dt = dao.Tables[0];            }            catch (Exception ex)            {              Util.UErrorMessage(ex,0,0);                throw ex;            }            return dt;        }        public int ReceiverID_Max()        {            int ReceiverId = 0;            try            {                DataSet dao = Select("SELECT MAX(RECEIVER_ID) FROM TB_RECEIVER");                DataTable dt = dao.Tables[0];                if (dt.Rows.Count > 0)                {                    foreach (DataRow dr in dt.Rows)                    {                        if (!dr[0].ToString().Equals(""))                            ReceiverId = int.Parse(dr[0].ToString());                    }                }            }            catch (Exception ex)            {              Util.UErrorMessage(ex,0,0);                throw ex;            }            return ReceiverId;        }      public void Receiver_Clear() {        try {          String SQL = "DELETE FROM TB_RECEIVER ";          ExecuteNonQuery(SQL);        }        catch (Exception ex) {          Util.UErrorMessage(ex, 0, 0);          throw ex;        }      }        public void Receiver_Update(QUERYMode cmd, String RECEIVER_ID, String RECEIVER_NAME, String IP_ADDRESS, String EVENT_PORT_NO, String COMMAND_PORT_NO, String REDUNDANT_FLAG, String USE_FLAG)        {            try            {                DataTable dt = Receiver_Select(RECEIVER_ID);                if (cmd == QUERYMode.insert)                {                    if (dt.Rows.Count > 0)                    {                        throw new Exception("이미 해당 자료가 존재합니다. 수정모드로 작업하여 주십시요.");                    }                    String SQL = "INSERT INTO TB_RECEIVER (RECEIVER_ID,RECEIVER_NAME,IP_ADDRESS,EVENT_PORT_NO,COMMAND_PORT_NO,REDUNDANT_FLAG,USE_FLAG,UPDATE_USER_ID,UPDATE_TIME)";                    SQL += " VALUES ({0},'{1}','{2}',{3},{4},'{5}','{6}','FPER',current_timestamp)";                    SQL = String.Format(SQL, RECEIVER_ID, RECEIVER_NAME, IP_ADDRESS, EVENT_PORT_NO, COMMAND_PORT_NO, REDUNDANT_FLAG, USE_FLAG);                    ExecuteNonQuery(SQL);                    //통신보드 백루프 사용여부를 수정해 준다..                    DacCommConfig dacCommConfig = new DacCommConfig();                    dacCommConfig.Comm_FlagUpdate(QUERYMode.InsertAndUpdate, int.Parse(RECEIVER_ID), COMMLOOP.BackLoop, REDUNDANT_FLAG);                }                else if (cmd == QUERYMode.update)                {                    if (dt.Rows.Count < 1)                    {                        throw new Exception("해당 자료를 찾을수 없습니다.");                    }                    String SQL = "UPDATE TB_RECEIVER SET  RECEIVER_NAME = '{0}'";                    SQL += ", IP_ADDRESS = '{1}', EVENT_PORT_NO = '{2}'";                    SQL += ", COMMAND_PORT_NO = '{3}', REDUNDANT_FLAG = '{4}', USE_FLAG = '{5}'";                    SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";                    SQL += " WHERE RECEIVER_ID = {6}";                    SQL = String.Format(SQL, RECEIVER_NAME, IP_ADDRESS, EVENT_PORT_NO, COMMAND_PORT_NO, REDUNDANT_FLAG, USE_FLAG, RECEIVER_ID);                    ExecuteNonQuery(SQL);                    //통신보드 백루프 사용여부를 수정해 준다..                    DacCommConfig dacCommConfig = new DacCommConfig();                    dacCommConfig.Comm_FlagUpdate(QUERYMode.InsertAndUpdate, int.Parse(RECEIVER_ID), COMMLOOP.BackLoop, REDUNDANT_FLAG);                }                else if (cmd == QUERYMode.delete)                {                    if (dt.Rows.Count < 1)                    {                        throw new Exception("해당 자료를 찾을수 없습니다.");                    }                    String SQL = "UPDATE  TB_RECEIVER SET USE_FLAG = 'N' ";                    SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";                    SQL += " WHERE RECEIVER_ID = {0}";                    //String SQL = "DELETE FROM TB_RECEIVER WHERE RECEIVER_ID = {0}";                    SQL = String.Format(SQL, RECEIVER_ID);                    ExecuteNonQuery(SQL);                }            }            catch (Exception ex)            {              Util.UErrorMessage(ex,0,0);                throw ex;            }        }        //환경설정정보 읽어옴        public DataTable Config_Select(int RECEIVER_ID)        {            DataTable dt = null;            try            {                String SQL = "";                SQL += "SELECT FIRE_ACCUMULATION_MODE,FIRE_ACCUMULATION_TIME,FIRE_PROCESS_MODE,SOUND_PROCESS_MODE";                SQL += ",MASTER_USER_ID,MASTER_PASSWORD,BUILDING_NAME,JUMP_FIELD FROM TB_CONFIG ";                SQL += " WHERE  RECEIVER_ID = '{0}'";                SQL = String.Format(SQL, RECEIVER_ID);                DataSet dao = Select(SQL);                dt = dao.Tables[0];            }            catch (Exception ex)            {                Debug.WriteLine(" Config Select Exception.. ");              // Util.UErrorMessage(ex,0,0);                throw ex;            }            return dt;        }        //환경정보 저장        public void Config_Update(QUERYMode cmd, int RECEIVER_ID, String FIRE_ACCUMULATION_MODE, int FIRE_ACCUMULATION_TIME            , String FIRE_PROCESS_MODE, String SOUND_PROCESS_MODE, String MASTER_USER_ID, String MASTER_PASSWORD            , String BUILDING_NAME, string BACKGROUND_IMAGE)        {            try            {                DataTable dt = Config_Select(RECEIVER_ID);                if (dt.Rows.Count == 0)                {                    String SQL = "INSERT INTO TB_CONFIG (RECEIVER_ID,FIRE_ACCUMULATION_MODE,FIRE_ACCUMULATION_TIME";                    SQL += ",FIRE_PROCESS_MODE,SOUND_PROCESS_MODE,MASTER_USER_ID,MASTER_PASSWORD";                    SQL += ",BUILDING_NAME,BACKGROUND_IMAGE,UPDATE_USER_ID,UPDATE_TIME)";                    SQL += " VALUES ({0},'{1}',{2},'{3}','{4}','{5}','{6}','{7}','{8}','FPER',current_timestamp)";                    SQL = String.Format(SQL, RECEIVER_ID, FIRE_ACCUMULATION_MODE, FIRE_ACCUMULATION_TIME                        , FIRE_PROCESS_MODE, SOUND_PROCESS_MODE, MASTER_USER_ID, MASTER_PASSWORD, BUILDING_NAME, BACKGROUND_IMAGE);                    ExecuteNonQuery(SQL);                    //ExecuteNonQueryParam(SQL, BACKGROUND_IMAGE);                }                else                {                    String SQL = "UPDATE  TB_CONFIG SET FIRE_ACCUMULATION_MODE = '{0}',FIRE_ACCUMULATION_TIME={1},FIRE_PROCESS_MODE='{2}' ";                    SQL += ", SOUND_PROCESS_MODE = '{3}', MASTER_USER_ID = '{4}',MASTER_PASSWORD = '{5}'";                    SQL += ", BUILDING_NAME = '{6}', BACKGROUND_IMAGE = '{7}'";                    SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";                    SQL += " WHERE RECEIVER_ID = {8}";                    SQL = String.Format(SQL, FIRE_ACCUMULATION_MODE, FIRE_ACCUMULATION_TIME, FIRE_PROCESS_MODE                        , SOUND_PROCESS_MODE, MASTER_USER_ID, MASTER_PASSWORD, BUILDING_NAME,BACKGROUND_IMAGE, RECEIVER_ID);                    ExecuteNonQuery(SQL);                   // ExecuteNonQueryParam(SQL, BACKGROUND_IMAGE);                }            }            catch (Exception ex)            {              Util.UErrorMessage(ex,0,0);                throw ex;            }        }    }    /*******************************************************************************************/}
 |