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; } } } /*******************************************************************************************/ }