123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670 |
- 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 FPER
- {
-
- public class DacReceiverConfig : DacBase , IDisposable
- {
- public int ReceiverID = 0;
- public DacReceiverConfig(int ID)
- : base(ID)
- {
-
-
-
-
-
-
- ReceiverID = ID;
- }
- ~DacReceiverConfig()
- {
- try
- {
- base.DisConnect();
- }
- catch (Exception ex)
- {
- Util.UErrorMessage(ex, 0, 0);
- }
- }
-
- public void Dispose()
- {
- DisConnect();
- }
-
-
-
-
- public DataRowCollection TB_DAYTIME_Exist()
- {
- DataTable dt = null;
- try
- {
- String SQL = Table_Exist_SQL("TB_DAYTIME");
- DataSet dao = Select(SQL);
- dt = dao.Tables[0];
- return dt.Rows;
- }
- catch (Exception ex)
- {
- Util.UErrorMessage(ex, 0, 0);
- }
- return null;
- }
-
- public string Table_Exist_SQL(string TABLE_NAME)
- {
- string SQL = "select rdb$relation_name ";
- SQL = SQL + "from rdb$relations ";
- SQL = SQL + "where rdb$system_flag=0 ";
- SQL = SQL + "and rdb$relation_name = '" + TABLE_NAME + "'";
- return SQL;
- }
-
- public DataRowCollection TB_DAYTIME_Get()
- {
- DataTable dt = null;
- try
- {
- String SQL = "SELECT * FROM TB_DAYTIME";
- DataSet dao = Select(SQL);
- dt = dao.Tables[0];
- return dt.Rows;
- }
- catch (Exception ex)
- {
- Util.UErrorMessage(ex, 0, 0);
- }
- return null;
- }
-
- public void TB_DAYTIME_Set(string Start_Hour,string Start_Minute, string End_Hour, string End_Minute)
- {
- try
- {
- String SQL = "insert into TB_DAYTIME (START_HOUR,START_MIN,END_HOUR,END_MIN) values " + string.Format("({0},{1},{2},{3})", Start_Hour, Start_Minute, End_Hour, End_Minute);
- ExecuteNonQuery(SQL);
- }
- catch (Exception ex)
- {
- Util.UErrorMessage(ex, 0, 0);
- }
- }
-
- public void TB_DAYTIME_Init()
- {
- try
- {
- String SQL = "Delete from TB_DAYTIME";
- ExecuteNonQuery(SQL);
- }
- catch (Exception ex)
- {
- Util.UErrorMessage(ex, 0, 0);
- }
- }
-
-
- public DataTable Receiver_Select()
- {
- DataTable dt = null;
- try
- {
- String SQL = "";
- SQL += "SELECT RECEIVER_ID,RECEIVER_NAME,IP_ADDRESS FROM TB_RECEIVER ";
- DataSet dao = Select(SQL);
- dt = dao.Tables[0];
- }
- catch (Exception ex)
- {
- Util.UErrorMessage(ex, 0, 0);
- throw ex;
- }
- return dt;
- }
-
- public DataTable Pump_Select(int num)
- {
- DataTable dt = null;
- try
- {
- DataSet dao = Select(string.Format("select * from TB_DEVICE where COMM_ID ='3' and DEVICE_ID='{0}'", 8 + num));
- dt = dao.Tables[0];
- }
- catch
- {
- ;
- }
- return dt;
- }
- public DataTable Receiver_Select(String RECEIVER_ID, String UseFlag)
- {
- 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,USE_FLAG FROM TB_RECEIVER ";
- if (UseFlag != null) SQL += " WHERE USE_FLAG = '" + UseFlag + "'";
- SQL += " ORDER BY RECEIVER_ID";
- }
- else
- {
- SQL += "SELECT RECEIVER_ID,RECEIVER_NAME,IP_ADDRESS,EVENT_PORT_NO,COMMAND_PORT_NO";
- SQL += ",REDUNDANT_FLAG,USE_FLAG FROM TB_RECEIVER ";
- if (UseFlag != null)
- {
- SQL += " WHERE USE_FLAG = '" + UseFlag + "' AND RECEIVER_ID = '{0}'";
- }
- else
- {
- SQL += " WHERE 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, null);
- 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(ReceiverID);
- 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(ReceiverID);
- 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}";
-
- 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,BACKGROUND_IMAGE,TEST_RUN_FLAG,JUMP_FIELD,MASTER_FLAG ,RECEIVER_ID FROM TB_CONFIG ";
-
-
- if(RECEIVER_ID!=0)
- SQL += " WHERE RECEIVER_ID = '{0}'";
- SQL = String.Format(SQL, RECEIVER_ID);
- DataSet dao = Select(SQL);
- dt = dao.Tables[0];
- }
- catch (Exception ex)
- {
-
-
- 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, string TEST_RUN_FLAG, string JUMP_FIELD)
- {
- 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,TEST_RUN_FLAG,JUMP_FIELD UPDATE_TIME)";
- SQL += " VALUES ({0},'{1}',{2},'{3}','{4}','{5}','{6}','{7}','{8}','FPER','{9}',current_timestamp,'{10}')";
- 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, TEST_RUN_FLAG, JUMP_FIELD);
- ExecuteNonQuery(SQL);
-
- }
- 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}' , TEST_RUN_FLAG = '{9}' , JUMP_FIELD = '{10}'";
- 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, TEST_RUN_FLAG, JUMP_FIELD);
- ExecuteNonQuery(SQL);
-
- }
- }
- catch (Exception ex)
- {
- Util.UErrorMessage(ex, 0, 0);
- throw ex;
- }
- }
-
- public DataTable Device_Type_Select(String SYMBOL_TYPE, String DEVICE_TYPE)
- {
- DataTable dt = null;
- try
- {
- String SQL = "";
- SQL += "SELECT SYMBOL_TYPE,DEVICE_TYPE,DEVICE_TYPE_NAME,USE_FLAG ";
- SQL += " FROM TB_DEVICE_TYPE WHERE SYMBOL_TYPE = '{0}' AND DEVICE_TYPE = '{1}'";
- SQL += " ORDER BY DEVICE_TYPE";
- SQL = String.Format(SQL, SYMBOL_TYPE, DEVICE_TYPE);
- DataSet dao = Select(SQL);
- dt = dao.Tables[0];
- }
- catch (Exception ex)
- {
- Util.UErrorMessage(ex, 0, 0);
- throw ex;
- }
- return dt;
- }
-
- public void Device_Type_Clear(String SYMBOL_TYPE)
- {
- try
- {
- String SQL = "UPDATE TB_DEVICE_TYPE SET USE_FLAG = 'N' ";
- SQL += " ,UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
- SQL += " WHERE SYMBOL_TYPE = '{0}'";
- SQL = String.Format(SQL, SYMBOL_TYPE);
- ExecuteNonQuery(SQL);
- }
- catch (Exception ex)
- {
- Util.UErrorMessage(ex, 0, 0);
- throw ex;
- }
- }
-
- public void Device_Type_Update(QUERYMode cmd, String DEVICE_TYPE, String DEVICE_TYPE_NAME, String SYMBOL_TYPE
- , String USE_FLAG)
- {
- try
- {
- DataTable dt = Device_Type_Select(SYMBOL_TYPE, DEVICE_TYPE);
- if (dt.Rows.Count == 0)
- {
- String SQL = "INSERT INTO TB_DEVICE_TYPE (DEVICE_TYPE,DEVICE_TYPE_NAME";
- SQL += ",SYMBOL_TYPE,USE_FLAG,UPDATE_USER_ID,UPDATE_TIME)";
- SQL += " VALUES ('{0}','{1}','{2}','{3}','FPER',current_timestamp)";
- SQL = String.Format(SQL, DEVICE_TYPE, DEVICE_TYPE_NAME, SYMBOL_TYPE, USE_FLAG);
- ExecuteNonQuery(SQL);
- }
- else
- {
- String SQL = "UPDATE TB_DEVICE_TYPE SET DEVICE_TYPE_NAME = '{0}',SYMBOL_TYPE='{1}',USE_FLAG='{2}' ";
- SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
- SQL += " WHERE DEVICE_TYPE = '{3}'";
- SQL = String.Format(SQL, DEVICE_TYPE_NAME, SYMBOL_TYPE, USE_FLAG, DEVICE_TYPE);
- ExecuteNonQuery(SQL);
- }
- }
- catch (Exception ex)
- {
- Util.UErrorMessage(ex, 0, 0);
- throw ex;
- }
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- public void ExecuteSql(string SQL)
- {
- if (this.Connect())
- {
- FbTransaction transaction = connection.BeginTransaction();
- try
- {
-
- FbCommand command = new FbCommand(SQL, connection, transaction);
- command.CommandType = CommandType.Text;
- command.CommandTimeout = 5;
- command.ExecuteNonQuery();
- transaction.Commit();
- command.Dispose();
- }
- catch (Exception ex)
- {
-
- transaction.Rollback();
- throw ex;
- }
- finally
- {
- this.DisConnect();
- }
- }
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- }
-
- }
|