using System; using System.Collections.Generic; using System.Text; using System.Data; using System.Collections; using System.Diagnostics; namespace FPER { //±×·ìŸÀÔÁ¤ÀÇ public struct code_GroupIO { public const String Input = "I"; public const String Output = "O"; public const String Unknown = ""; } class DacMap : DacBase { public DacMap(int ID) : base(ID)// cyim 2015.7.30 µ¥ÀÌŸº£À̽º Á¢¼Ó ·çƾ º¯°æ { //try { // Connect(); //} //catch (Exception ex) { // Util.UErrorMessage(ex, 0, 0); //} } ~DacMap() { //try { // DisConnect(); //} //catch (Exception ex) { // Util.UErrorMessage(ex, 0, 0); //} } //±×·ìÁ¶È¸ public DataTable Group_Select(String GROUP_ID, String GROUP_TYPE) { DataTable dt = null; try { String SQL = "SELECT * FROM TB_GROUP "; /* if (GROUP_ID != null || GROUP_TYPE != code_GroupIO.Unknown) { SQL += " WHERE "; if (GROUP_ID != null) { SQL += String.Format(" GROUP_ID = '{0}'", GROUP_ID); if (GROUP_TYPE != code_GroupIO.Unknown) SQL += String.Format(" AND GROUP_TYPE = '{0}'", GROUP_TYPE); } else { if (GROUP_TYPE != code_GroupIO.Unknown) SQL += String.Format(" GROUP_TYPE = '{0}'", GROUP_TYPE); } } */ SQL += " ORDER BY GROUP_ID"; DataSet dao = Select(SQL); dt = dao.Tables[0]; } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return dt; } // cyim 2014.8.14 ±×·ìÁ¤º¸´Â ¼ö½Å±â¾ÆÀ̵𿡠µû¶ó Ãâ·ÂµÊ public DataTable Group_Select(String GROUP_ID, String GROUP_TYPE, string Receiver_ID) { DataTable dt = null; try { String SQL = "SELECT * FROM TB_GROUP "; /* if (GROUP_ID != null || GROUP_TYPE != code_GroupIO.Unknown) { SQL += " WHERE "; if (GROUP_ID != null) { SQL += String.Format(" GROUP_ID = '{0}'", GROUP_ID); if (GROUP_TYPE != code_GroupIO.Unknown) SQL += String.Format(" AND GROUP_TYPE = '{0}'", GROUP_TYPE); } else { if (GROUP_TYPE != code_GroupIO.Unknown) SQL += String.Format(" GROUP_TYPE = '{0}'", GROUP_TYPE); } } */ SQL += " WHERE RECEIVER_ID = '" + Receiver_ID + "'"; SQL += " ORDER BY GROUP_ID"; DataSet dao = Select(SQL); dt = dao.Tables[0]; } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return dt; } public void Group_Update(QUERYMode cmd, String GROUP_ID, String GROUP_TYPE, String GROUP_NAME) { try { DataTable dt = Group_Select(GROUP_ID, code_GroupIO.Unknown); if (cmd == QUERYMode.insert) { if (dt.Rows.Count > 0) { throw new Exception("ÀÌ¹Ì ÇØ´ç ÀÚ·á°¡ Á¸ÀçÇÕ´Ï´Ù. ¼öÁ¤¸ðµå·Î ÀÛ¾÷ÇÏ¿© Áֽʽÿä."); } String SQL = "INSERT INTO TB_GROUP (GROUP_ID,GROUP_NAME,GROUP_TYPE,UPDATE_USER_ID,UPDATE_TIME)"; SQL += " VALUES ('{0}','{1}','{2}','FPER',current_timestamp)"; SQL = String.Format(SQL, GROUP_ID, GROUP_NAME, GROUP_TYPE); ExecuteNonQuery(SQL); } else if (cmd == QUERYMode.update) { if (dt.Rows.Count < 1) { throw new Exception("ÇØ´ç ÀڷḦ ãÀ»¼ö ¾ø½À´Ï´Ù."); } String SQL = "UPDATE TB_GROUP SET GROUP_NAME = '{0}'"; SQL += ", GROUP_TYPE = '{1}'"; SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp"; SQL += " WHERE GROUP_ID = '{2}'"; SQL = String.Format(SQL, GROUP_NAME, GROUP_TYPE, GROUP_ID); ExecuteNonQuery(SQL); } else if (cmd == QUERYMode.delete) { if (dt.Rows.Count < 1) { throw new Exception("ÇØ´ç ÀڷḦ ãÀ»¼ö ¾ø½À´Ï´Ù."); } String SQL = "DELETE FROM TB_GROUP WHERE GROUP_ID = '{0}'"; SQL = String.Format(SQL, GROUP_ID); ExecuteNonQuery(SQL); SQL = "DELETE FROM TB_GROUP_DEVICE WHERE GROUP_ID = '{0}'"; SQL = String.Format(SQL, GROUP_ID); ExecuteNonQuery(SQL); SQL = "DELETE FROM TB_MAP_PROCESS WHERE GROUP_ID = '{0}'"; SQL = String.Format(SQL, GROUP_ID); ExecuteNonQuery(SQL); } } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } } //±×·ìÁ¶È¸ public DataTable Group_Modal_Select(String GROUP_TYPE, String SEARCH_KEY) { DataTable dt = null; try { String SQL = "SELECT * FROM TB_GROUP "; //if (GROUP_TYPE != code_GroupIO.Unknown) //{ // SQL += String.Format(" WHERE GROUP_TYPE = '{0}'", GROUP_TYPE); // if (SEARCH_KEY != null) // { // SQL += String.Format(" AND GROUP_NAME LIKE '%{0}%' ", SEARCH_KEY); // } //} //else if (SEARCH_KEY != null) { SQL += String.Format(" WHERE GROUP_NAME LIKE '%{0}%' ", SEARCH_KEY); } SQL += " ORDER BY GROUP_ID"; DataSet dao = Select(SQL); dt = dao.Tables[0]; } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return dt; } //±×·ìȸ·Î ¸®½ºÆ®Á¶È¸ public DataTable Group_Device_Select(String GROUP_ID, int RECEIVER_ID) { DataTable dt = null; try { String SQL = "SELECT A.*,B.DEVICE_NAME,B.DEVICE_TYPE,C.DEVICE_TYPE_NAME,B.POSITION_CODE,D.POSITION_NAME "; SQL += " FROM TB_GROUP_DEVICE A"; SQL += " LEFT OUTER JOIN TB_DEVICE B ON A.RECEIVER_ID = B.RECEIVER_ID AND A.COMM_ID = B.COMM_ID "; SQL += " AND A.BOARD_ID = B.BOARD_ID AND A.LOOP_NO = B.LOOP_NO AND A.REPEATER_ID = B.REPEATER_ID "; SQL += " AND A.DEVICE_ID = B.DEVICE_ID AND A.INOUT_TYPE = B.INOUT_TYPE"; SQL += " LEFT OUTER JOIN TB_DEVICE_TYPE C ON B.DEVICE_TYPE = C.DEVICE_TYPE"; SQL += " LEFT OUTER JOIN TB_POSITION_CODE D ON B.POSITION_CODE = D.POSITION_CODE"; SQL += String.Format(" WHERE A.GROUP_ID = '{0}' AND A.RECEIVER_ID = {1} ", GROUP_ID, RECEIVER_ID); SQL += " ORDER BY A.COMM_ID,A.BOARD_ID,A.LOOP_NO,A.REPEATER_ID,A.DEVICE_ID"; DataSet dao = Select(SQL); dt = dao.Tables[0]; } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return dt; } //±×·ìȸ·Î ¸®½ºÆ®Á¶È¸ public DataTable Group_Device_Select(String GROUP_ID, int RECEIVER_ID, int COMM_ID, int BOARD_ID, int LOOP_NO, int REPEATER_ID, int DEVICE_ID, String INOUT_TYPE) { DataTable dt = null; try { String SQL = "SELECT A.*,B.DEVICE_NAME,B.DEVICE_TYPE,C.DEVICE_TYPE_NAME FROM TB_GROUP_DEVICE A"; SQL += " LEFT OUTER JOIN TB_DEVICE B ON A.RECEIVER_ID = B.RECEIVER_ID AND A.COMM_ID = B.COMM_ID "; SQL += " AND A.BOARD_ID = B.BOARD_ID AND A.LOOP_NO = B.LOOP_NO AND A.REPEATER_ID = B.REPEATER_ID "; SQL += " AND A.DEVICE_ID = B.DEVICE_ID AND A.INOUT_TYPE = B.INOUT_TYPE"; SQL += " LEFT OUTER JOIN TB_DEVICE_TYPE C ON B.DEVICE_TYPE = C.DEVICE_TYPE"; SQL += String.Format(" WHERE A.GROUP_ID = '{0}' AND A.RECEIVER_ID = {1} AND A.COMM_ID = {2} ", GROUP_ID, RECEIVER_ID, COMM_ID); SQL += String.Format(" AND A.BOARD_ID = {0} AND A.LOOP_NO = {1}", BOARD_ID, LOOP_NO); SQL += String.Format(" AND A.REPEATER_ID = {0} AND A.DEVICE_ID = {1} AND A.INOUT_TYPE = '{2}'", REPEATER_ID, DEVICE_ID, INOUT_TYPE); DataSet dao = Select(SQL); dt = dao.Tables[0]; } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return dt; } //¸ÊÁ¶È¸ public DataTable Map_Select(int MAP_NO) { DataTable dt = null; try { String SQL = "SELECT * FROM TB_MAP "; if (MAP_NO > 0) SQL += String.Format(" WHERE MAP_NO = {0} ", MAP_NO); SQL += " ORDER BY MAP_NO"; DataSet dao = Select(SQL); dt = dao.Tables[0]; } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return dt; } //¸ÊÁ¶È¸ public DataTable Map_Select(String MAP_ID) { DataTable dt = null; try { String SQL = "SELECT * FROM TB_MAP "; if (MAP_ID != null) SQL += String.Format(" WHERE MAP_ID = '{0}' ", MAP_ID); SQL += " ORDER BY MAP_NO"; DataSet dao = Select(SQL); dt = dao.Tables[0]; } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return dt; } //¸ÊÁ¶È¸ public int Map_Max_Select() { int MAP_NO = 0; try { String SQL = "SELECT MAX(MAP_NO) FROM TB_MAP "; DataSet dao = Select(SQL); DataTable dt = dao.Tables[0]; if (dt.Rows.Count > 0) { foreach (DataRow dr in dt.Rows) { MAP_NO = Util.StrToInt(dr[0], 0); } } } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return ++MAP_NO; } //¸ÊÁ¶È¸ public int Map_Process_Seq_Max_Select(int MAP_NO, String MAP_TYPE) { int SEQ_NO = 0; try { String SQL = "SELECT MAX(SEQ_NO) FROM TB_MAP_PROCESS "; SQL += String.Format(" WHERE MAP_NO = {0} AND MAP_TYPE = '{1}'", MAP_NO, MAP_TYPE); DataSet dao = Select(SQL); DataTable dt = dao.Tables[0]; if (dt.Rows.Count > 0) { foreach (DataRow dr in dt.Rows) { SEQ_NO = Util.StrToInt(dr[0], 0); } } } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return ++SEQ_NO; } //¸Ê SEQUENCE Á¶È¸ public DataTable Map_Process_Select(int MAP_NO, String MAP_TYPE, int SEQ_NO) { DataTable dt = null; try { String SQL = "SELECT a.*"; SQL += " ,CASE a.PROCESS_TYPE WHEN 'D' THEN b.DEVICE_NAME ELSE c.GROUP_NAME END AS PROCESS_NAME"; SQL += " FROM TB_MAP_PROCESS a"; SQL += " LEFT OUTER JOIN TB_DEVICE b ON a.RECEIVER_ID = b.RECEIVER_ID AND a.COMM_ID = b.COMM_ID "; SQL += " AND a.BOARD_ID = b.BOARD_ID AND a.LOOP_NO = b.LOOP_NO"; SQL += " AND a.REPEATER_ID = b.REPEATER_ID AND a.DEVICE_ID = b.DEVICE_ID"; SQL += " AND a.INOUT_TYPE = b.INOUT_TYPE "; SQL += " LEFT OUTER JOIN TB_GROUP c ON a.GROUP_ID = c.GROUP_ID"; SQL += String.Format(" WHERE a.MAP_NO = {0} AND a.MAP_TYPE = '{1}'", MAP_NO, MAP_TYPE); if (SEQ_NO > 0) SQL += String.Format(" AND a.SEQ_NO = {0} ", SEQ_NO); SQL += " ORDER BY a.SEQ_NO"; DataSet dao = Select(SQL); dt = dao.Tables[0]; } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return dt; } //¸Ê ȸ·Î Á¶È¸ public DataTable Map_Process_Select(int MAP_NO, String MAP_TYPE, int RECEIVER_ID, int COMM_ID, int BOARD_ID, int LOOP_NO , int REPEATER_ID, int DEVICE_ID, string INOUT_TYPE) { DataTable dt = null; try { String SQL = "SELECT a.*"; SQL += " ,CASE a.PROCESS_TYPE WHEN 'D' THEN b.DEVICE_NAME ELSE c.GROUP_NAME END AS PROCESS_NAME"; SQL += " FROM TB_MAP_PROCESS a"; SQL += " LEFT OUTER JOIN TB_DEVICE b ON a.RECEIVER_ID = b.RECEIVER_ID AND a.COMM_ID = b.COMM_ID "; SQL += " AND a.BOARD_ID = b.BOARD_ID AND a.LOOP_NO = b.LOOP_NO"; SQL += " AND a.REPEATER_ID = b.REPEATER_ID AND a.DEVICE_ID = b.DEVICE_ID"; SQL += " AND a.INOUT_TYPE = b.INOUT_TYPE "; SQL += " LEFT OUTER JOIN TB_GROUP c ON a.GROUP_ID = c.GROUP_ID"; SQL += String.Format(" WHERE a.MAP_NO = {0} AND a.MAP_TYPE = '{1}'", MAP_NO, MAP_TYPE); SQL += String.Format(" AND a.PROCESS_TYPE = 'D' AND a.RECEIVER_ID = {0}", RECEIVER_ID); SQL += String.Format(" AND a.COMM_ID = {0} AND a.RECEIVER_ID = {1}", COMM_ID, BOARD_ID); SQL += String.Format(" AND a.LOOP_NO = {0} AND a.REPEATER_ID = {1}", LOOP_NO, REPEATER_ID); SQL += String.Format(" AND a.DEVICE_ID = {0} AND a.INOUT_TYPE = '{1}'", DEVICE_ID, INOUT_TYPE); SQL += " ORDER BY a.SEQ_NO"; DataSet dao = Select(SQL); dt = dao.Tables[0]; } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return dt; } //¸Ê ±×·ì Á¶È¸ public DataTable Map_Process_Select(int MAP_NO, String MAP_TYPE, string GROUP_ID) { DataTable dt = null; try { String SQL = "SELECT a.*"; SQL += " ,CASE a.PROCESS_TYPE WHEN 'D' THEN b.DEVICE_NAME ELSE c.GROUP_NAME END AS PROCESS_NAME"; SQL += " FROM TB_MAP_PROCESS a"; SQL += " LEFT OUTER JOIN TB_DEVICE b ON a.RECEIVER_ID = b.RECEIVER_ID AND a.COMM_ID = b.COMM_ID "; SQL += " AND a.BOARD_ID = b.BOARD_ID AND a.LOOP_NO = b.LOOP_NO"; SQL += " AND a.REPEATER_ID = b.REPEATER_ID AND a.DEVICE_ID = b.DEVICE_ID"; SQL += " AND a.INOUT_TYPE = b.INOUT_TYPE "; SQL += " LEFT OUTER JOIN TB_GROUP c ON a.GROUP_ID = c.GROUP_ID"; SQL += String.Format(" WHERE a.MAP_NO = {0} AND a.MAP_TYPE = '{1}'", MAP_NO, MAP_TYPE); SQL += String.Format(" AND a.PROCESS_TYPE = 'G' AND a.GROUP_ID = '{0}'", GROUP_ID); SQL += " ORDER BY a.SEQ_NO"; DataSet dao = Select(SQL); dt = dao.Tables[0]; } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return dt; } //¸ÅÇÎ ¸Ê °¡Á®¿À±â public DataTable Mapping_Map_Select(String MAP_TYPE, int RECEIVER_ID, String MAP_ID) { DataTable dt = null; try { String SQL = "SELECT a.MAP_NO,a.MAP_ID,a.MAP_NAME"; SQL += " ,b.MAP_TYPE,b.SEQ_NO,b.PROCESS_TYPE,b.GROUP_ID"; SQL += " ,CASE b.PROCESS_TYPE WHEN 'D' THEN b.COMM_ID ELSE d.COMM_ID END AS COMM_ID"; SQL += " ,CASE b.PROCESS_TYPE WHEN 'D' THEN b.BOARD_ID ELSE d.BOARD_ID END AS BOARD_ID"; SQL += " ,CASE b.PROCESS_TYPE WHEN 'D' THEN b.LOOP_NO ELSE d.LOOP_NO END AS LOOP_NO"; SQL += " ,CASE b.PROCESS_TYPE WHEN 'D' THEN b.REPEATER_ID ELSE d.REPEATER_ID END AS REPEATER_ID"; SQL += " ,CASE b.PROCESS_TYPE WHEN 'D' THEN b.DEVICE_ID ELSE d.DEVICE_ID END AS DEVICE_ID"; SQL += " ,c.GROUP_NAME,c.GROUP_TYPE"; SQL += " FROM TB_MAP a"; SQL += " JOIN TB_MAP_PROCESS b ON a.MAP_NO = b.MAP_NO"; SQL += " LEFT OUTER JOIN TB_GROUP c ON b.GROUP_ID = c.GROUP_ID"; SQL += " LEFT OUTER JOIN TB_GROUP_DEVICE d ON c.GROUP_ID = d.GROUP_ID"; SQL += String.Format(" WHERE b.MAP_TYPE = '{0}' AND b.RECEIVER_ID = {1}", MAP_TYPE, RECEIVER_ID); if (MAP_ID != null) SQL += String.Format(" AND a.MAP_ID = '{0}'", MAP_ID); SQL += " ORDER BY a.MAP_ID,b.MAP_TYPE"; SQL += " ,CASE b.PROCESS_TYPE WHEN 'D' THEN b.COMM_ID ELSE d.COMM_ID END"; SQL += " ,CASE b.PROCESS_TYPE WHEN 'D' THEN b.BOARD_ID ELSE d.BOARD_ID END "; SQL += " ,CASE b.PROCESS_TYPE WHEN 'D' THEN b.LOOP_NO ELSE d.LOOP_NO END "; SQL += " ,CASE b.PROCESS_TYPE WHEN 'D' THEN b.REPEATER_ID ELSE d.REPEATER_ID END "; SQL += " ,CASE b.PROCESS_TYPE WHEN 'D' THEN b.DEVICE_ID ELSE d.DEVICE_ID END "; DataSet dao = Select(SQL); dt = dao.Tables[0]; } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } return dt; } //±×·ì ȸ·Î¼³Á¤°ª ÀúÀå public void Group_Device_Update(QUERYMode cmd, String GROUP_ID, int RECEIVER_ID, int COMM_ID, int BOARD_ID , int LOOP_NO, int REPEATER_ID, int DEVICE_ID, String INOUT_TYPE) { try { if (cmd == QUERYMode.insert || cmd == QUERYMode.update || cmd == QUERYMode.InsertAndUpdate) { if (DEVICE_ID < 1) return; String SQL = ""; DataTable dt = Group_Device_Select(GROUP_ID, RECEIVER_ID, COMM_ID, BOARD_ID, LOOP_NO, REPEATER_ID, DEVICE_ID, INOUT_TYPE); if (dt.Rows.Count < 1) { SQL = "INSERT INTO TB_GROUP_DEVICE ( "; SQL += " GROUP_ID,RECEIVER_ID,COMM_ID,BOARD_ID,LOOP_NO,REPEATER_ID,DEVICE_ID,INOUT_TYPE,UPDATE_USER_ID,UPDATE_TIME,GROUP_RECEIVER_ID,USE_FLAG";// ksd, 2012.02.21, db table change update SQL += ") VALUES ('{0}',{1},{2},{3},{4},{5},{6},'{7}','FPER',current_timestamp,{8},'Y')";// ksd, 2012.02.21, db table change update SQL = String.Format(SQL, GROUP_ID, RECEIVER_ID, COMM_ID, BOARD_ID, LOOP_NO, REPEATER_ID, DEVICE_ID, INOUT_TYPE, RECEIVER_ID); ExecuteNonQuery(SQL); } } else if (cmd == QUERYMode.delete) { String SQL = ""; if (DEVICE_ID < 1) { SQL = "DELETE FROM TB_GROUP_DEVICE WHERE RECEIVER_ID = {0} AND GROUP_ID = '{1}' "; SQL = String.Format(SQL, RECEIVER_ID, GROUP_ID); } else { SQL = "DELETE FROM TB_GROUP_DEVICE WHERE RECEIVER_ID = {0} AND GROUP_ID = '{1}' AND COMM_ID = {2} "; SQL += " AND BOARD_ID = {3} AND LOOP_NO = {4} AND REPEATER_ID = {5} AND DEVICE_ID = {6} AND INOUT_TYPE = '{7}'"; SQL = String.Format(SQL, RECEIVER_ID, GROUP_ID, COMM_ID, BOARD_ID, LOOP_NO, REPEATER_ID, DEVICE_ID, INOUT_TYPE); } ExecuteNonQuery(SQL); } } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } } public void Map_Update(QUERYMode cmd, int MAP_NO, String MAP_ID, String MAP_NAME) { try { DataTable dt = Map_Select(MAP_NO); if (cmd == QUERYMode.insert) { if (dt.Rows.Count > 0) { throw new Exception("ÀÌ¹Ì ÇØ´ç ÀÚ·á°¡ Á¸ÀçÇÕ´Ï´Ù. ¼öÁ¤¸ðµå·Î ÀÛ¾÷ÇÏ¿© Áֽʽÿä."); } String SQL = "INSERT INTO TB_MAP (MAP_NO,MAP_ID,MAP_NAME,UPDATE_USER_ID,UPDATE_TIME)"; SQL += " VALUES ({0},'{1}','{2}','FPER',current_timestamp)"; SQL = String.Format(SQL, MAP_NO, MAP_ID, MAP_NAME); ExecuteNonQuery(SQL); } else if (cmd == QUERYMode.update) { if (dt.Rows.Count < 1) { throw new Exception("ÇØ´ç ÀڷḦ ãÀ»¼ö ¾ø½À´Ï´Ù."); } String SQL = "UPDATE TB_MAP SET MAP_NAME = '{0}'"; SQL += ", MAP_ID = '{1}'"; SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp"; SQL += " WHERE MAP_NO = '{2}'"; SQL = String.Format(SQL, MAP_NAME, MAP_ID, MAP_NO); ExecuteNonQuery(SQL); } else if (cmd == QUERYMode.delete) { if (dt.Rows.Count < 1) { throw new Exception("ÇØ´ç ÀڷḦ ãÀ»¼ö ¾ø½À´Ï´Ù."); } String SQL = "DELETE FROM TB_MAP WHERE MAP_NO = {0}"; SQL = String.Format(SQL, MAP_NO); ExecuteNonQuery(SQL); SQL = "DELETE FROM TB_MAP_PROCESS WHERE MAP_NO = '{0}'"; SQL = String.Format(SQL, MAP_NO); ExecuteNonQuery(SQL); } } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } } public void Map_Process_Update(QUERYMode cmd, int MAP_NO, String MAP_TYPE, int SEQ_NO, String PROCESS_TYPE, String GROUP_ID , int RECEIVER_ID, int COMM_ID, int BOARD_ID, int LOOP_NO, int REPEATER_ID, int DEVICE_ID, string INOUT_TYPE) { try { DataTable dt = null; if (PROCESS_TYPE.Equals("D")) dt = Map_Process_Select(MAP_NO, MAP_TYPE, RECEIVER_ID, COMM_ID, BOARD_ID, LOOP_NO, REPEATER_ID, DEVICE_ID, INOUT_TYPE); else if (PROCESS_TYPE.Equals("G")) dt = Map_Process_Select(MAP_NO, MAP_TYPE, GROUP_ID); else dt = Map_Process_Select(MAP_NO, MAP_TYPE, SEQ_NO); if (cmd == QUERYMode.InsertAndUpdate || cmd == QUERYMode.insert || cmd == QUERYMode.update) { if (dt.Rows.Count > 0) { throw new Exception("ÀÌ¹Ì µî·ÏµÈ ÀÚ·áÀÔ´Ï´Ù.."); //String SQL = "UPDATE TB_MAP_PROCESS SET PROCESS_TYPE = '{0}'"; //SQL += ", GROUP_ID = '{1}', RECEIVER_ID = '{1}', COMM_ID = '{2}'"; //SQL += ", BOARD_ID = '{3}', LOOP_NO = '{4}', REPEATER_ID = '{5}'"; //SQL += ", DEVICE_ID = '{6}', INOUT_TYPE = '{7}'"; //SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp"; //SQL += " WHERE MAP_NO = '{8}' AND MAP_TYPE = '{9}' AND SEQ_NO = {10}"; //SQL = String.Format(SQL, PROCESS_TYPE, GROUP_ID, RECEIVER_ID, COMM_ID, BOARD_ID, LOOP_NO, REPEATER_ID, DEVICE_ID, INOUT_TYPE // , MAP_NO, MAP_TYPE, SEQ_NO); //ExecuteNonQuery(SQL); } else { String SQL = "INSERT INTO TB_MAP_PROCESS (MAP_NO,MAP_TYPE,SEQ_NO,PROCESS_TYPE,GROUP_ID"; SQL += ",RECEIVER_ID,COMM_ID,BOARD_ID,LOOP_NO,REPEATER_ID,DEVICE_ID,INOUT_TYPE,UPDATE_USER_ID,UPDATE_TIME, MAP_RECEIVER_ID,USE_FLAG)";// ksd, 2012.02.21, db table change update SQL += " VALUES ({0},'{1}',{2},'{3}','{4}'"; SQL += ",{5},{6},{7},{8},{9},{10},'{11}','FPER',current_timestamp,{5},'Y')";// ksd, 2012.02.21, db table change update SQL = String.Format(SQL, MAP_NO, MAP_TYPE, SEQ_NO, PROCESS_TYPE, GROUP_ID , RECEIVER_ID, COMM_ID, BOARD_ID, LOOP_NO, REPEATER_ID, DEVICE_ID, INOUT_TYPE); ExecuteNonQuery(SQL); } } else if (cmd == QUERYMode.delete) { if (dt.Rows.Count < 1) { throw new Exception("ÇØ´ç ÀڷḦ ãÀ»¼ö ¾ø½À´Ï´Ù."); } String SQL = "DELETE FROM TB_MAP_PROCESS "; SQL += " WHERE MAP_NO = {0} AND MAP_TYPE = '{1}' AND SEQ_NO = {2}"; SQL = String.Format(SQL, MAP_NO, MAP_TYPE, SEQ_NO); ExecuteNonQuery(SQL); } } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } } public void Map_Clear() { try { String SQL = "DELETE FROM TB_GROUP_DEVICE "; ExecuteNonQuery(SQL); SQL = "DELETE FROM TB_GROUP "; ExecuteNonQuery(SQL); SQL = "DELETE FROM TB_MAP "; ExecuteNonQuery(SQL); SQL = "DELETE FROM TB_MAP_PROCESS "; ExecuteNonQuery(SQL); } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); throw ex; } } public void Group_Update(QUERYMode cmd, String s_GROUP_ID, String s_GROUP_NAME, String s_GROUP_TYPE, String GROUP_ID, String GROUP_NAME, String GROUP_TYPE) { try { DataTable dt = Group_Select(GROUP_ID, code_GroupIO.Unknown); if (cmd == QUERYMode.insert) { if (dt.Rows.Count > 0) { throw new Exception("ÀÌ¹Ì ÇØ´ç ÀÚ·á°¡ Á¸ÀçÇÕ´Ï´Ù. ¼öÁ¤¸ðµå·Î ÀÛ¾÷ÇÏ¿© Áֽʽÿä."); } String SQL = "INSERT INTO TB_GROUP (" + s_GROUP_ID + "," + s_GROUP_NAME + "," + s_GROUP_TYPE + ",UPDATE_USER_ID,UPDATE_TIME)"; SQL += " VALUES ('{0}','{1}','{2}','FPER',current_timestamp)"; SQL = String.Format(SQL, GROUP_ID, GROUP_NAME, GROUP_TYPE); ExecuteNonQuery(SQL); } } catch (Exception ex) { Util.UErrorMessage(ex, 0, 0); //throw ex; } } } }