5a8471b2ea799c0c53424d9d0de9b9d7dc1da040.svn-base 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Text;
  4. using FirebirdSql.Data.FirebirdClient;
  5. using System.Data;
  6. using System.Collections;
  7. using System.IO;
  8. using System.Data.Common;
  9. using System.Diagnostics;
  10. namespace IControls_FireManager
  11. {
  12. /*******************************************************************************************
  13. * TB_RECEIVER(수신기) 설정 관련 Dac
  14. *******************************************************************************************/
  15. public class DacReceiverConfig: DacBase
  16. {
  17. public DacReceiverConfig()
  18. {
  19. //try {
  20. // base.Connect();
  21. //}
  22. //catch (Exception ex) {
  23. // Util.UErrorMessage(ex, 0, 0);
  24. //}
  25. }
  26. ~DacReceiverConfig()
  27. {
  28. //try {
  29. // base.DisConnect();
  30. //}
  31. //catch (Exception ex) {
  32. // Util.UErrorMessage(ex, 0, 0);
  33. //}
  34. }
  35. public DataTable Receiver_Select(int RECEIVER_ID)
  36. {
  37. DataTable dt = null;
  38. try
  39. {
  40. String SQL = "";
  41. SQL += "SELECT RECEIVER_ID,RECEIVER_NAME,IP_ADDRESS,EVENT_PORT_NO,COMMAND_PORT_NO";
  42. SQL += ",REDUNDANT_FLAG FROM TB_RECEIVER ";
  43. SQL += " WHERE USE_FLAG = 'Y' AND RECEIVER_ID = {0}";
  44. SQL = String.Format(SQL, RECEIVER_ID);
  45. DataSet dao = Select(SQL);
  46. dt = dao.Tables[0];
  47. }
  48. catch (Exception ex)
  49. {
  50. Util.UErrorMessage(ex, 0, 0);
  51. throw ex;
  52. }
  53. return dt;
  54. }
  55. public DataTable Receiver_Select(String RECEIVER_ID)
  56. {
  57. DataTable dt = null;
  58. try
  59. {
  60. String SQL = "";
  61. if (RECEIVER_ID == null)
  62. {
  63. SQL += "SELECT RECEIVER_ID,RECEIVER_NAME,IP_ADDRESS,EVENT_PORT_NO,COMMAND_PORT_NO";
  64. SQL += ",REDUNDANT_FLAG FROM TB_RECEIVER ";
  65. SQL += " WHERE USE_FLAG = 'Y'";
  66. SQL += " ORDER BY RECEIVER_ID";
  67. }
  68. else
  69. {
  70. SQL += "SELECT RECEIVER_ID,RECEIVER_NAME,IP_ADDRESS,EVENT_PORT_NO,COMMAND_PORT_NO";
  71. SQL += ",REDUNDANT_FLAG FROM TB_RECEIVER ";
  72. SQL += " WHERE USE_FLAG = 'Y' AND RECEIVER_ID = '{0}'";
  73. SQL = String.Format(SQL, RECEIVER_ID);
  74. }
  75. DataSet dao = Select(SQL);
  76. dt = dao.Tables[0];
  77. }
  78. catch (Exception ex)
  79. {
  80. Util.UErrorMessage(ex,0,0);
  81. throw ex;
  82. }
  83. return dt;
  84. }
  85. public int ReceiverID_Max()
  86. {
  87. int ReceiverId = 0;
  88. try
  89. {
  90. DataSet dao = Select("SELECT MAX(RECEIVER_ID) FROM TB_RECEIVER");
  91. DataTable dt = dao.Tables[0];
  92. if (dt.Rows.Count > 0)
  93. {
  94. foreach (DataRow dr in dt.Rows)
  95. {
  96. if (!dr[0].ToString().Equals(""))
  97. ReceiverId = int.Parse(dr[0].ToString());
  98. }
  99. }
  100. }
  101. catch (Exception ex)
  102. {
  103. Util.UErrorMessage(ex,0,0);
  104. throw ex;
  105. }
  106. return ReceiverId;
  107. }
  108. public void Receiver_Clear() {
  109. try {
  110. String SQL = "DELETE FROM TB_RECEIVER ";
  111. ExecuteNonQuery(SQL);
  112. }
  113. catch (Exception ex) {
  114. Util.UErrorMessage(ex, 0, 0);
  115. throw ex;
  116. }
  117. }
  118. 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)
  119. {
  120. try
  121. {
  122. DataTable dt = Receiver_Select(RECEIVER_ID);
  123. if (cmd == QUERYMode.insert)
  124. {
  125. if (dt.Rows.Count > 0)
  126. {
  127. throw new Exception("이미 해당 자료가 존재합니다. 수정모드로 작업하여 주십시요.");
  128. }
  129. 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)";
  130. SQL += " VALUES ({0},'{1}','{2}',{3},{4},'{5}','{6}','FPER',current_timestamp)";
  131. SQL = String.Format(SQL, RECEIVER_ID, RECEIVER_NAME, IP_ADDRESS, EVENT_PORT_NO, COMMAND_PORT_NO, REDUNDANT_FLAG, USE_FLAG);
  132. ExecuteNonQuery(SQL);
  133. //통신보드 백루프 사용여부를 수정해 준다..
  134. DacCommConfig dacCommConfig = new DacCommConfig();
  135. dacCommConfig.Comm_FlagUpdate(QUERYMode.InsertAndUpdate, int.Parse(RECEIVER_ID), COMMLOOP.BackLoop, REDUNDANT_FLAG);
  136. }
  137. else if (cmd == QUERYMode.update)
  138. {
  139. if (dt.Rows.Count < 1)
  140. {
  141. throw new Exception("해당 자료를 찾을수 없습니다.");
  142. }
  143. String SQL = "UPDATE TB_RECEIVER SET RECEIVER_NAME = '{0}'";
  144. SQL += ", IP_ADDRESS = '{1}', EVENT_PORT_NO = '{2}'";
  145. SQL += ", COMMAND_PORT_NO = '{3}', REDUNDANT_FLAG = '{4}', USE_FLAG = '{5}'";
  146. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  147. SQL += " WHERE RECEIVER_ID = {6}";
  148. SQL = String.Format(SQL, RECEIVER_NAME, IP_ADDRESS, EVENT_PORT_NO, COMMAND_PORT_NO, REDUNDANT_FLAG, USE_FLAG, RECEIVER_ID);
  149. ExecuteNonQuery(SQL);
  150. //통신보드 백루프 사용여부를 수정해 준다..
  151. DacCommConfig dacCommConfig = new DacCommConfig();
  152. dacCommConfig.Comm_FlagUpdate(QUERYMode.InsertAndUpdate, int.Parse(RECEIVER_ID), COMMLOOP.BackLoop, REDUNDANT_FLAG);
  153. }
  154. else if (cmd == QUERYMode.delete)
  155. {
  156. if (dt.Rows.Count < 1)
  157. {
  158. throw new Exception("해당 자료를 찾을수 없습니다.");
  159. }
  160. String SQL = "UPDATE TB_RECEIVER SET USE_FLAG = 'N' ";
  161. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  162. SQL += " WHERE RECEIVER_ID = {0}";
  163. //String SQL = "DELETE FROM TB_RECEIVER WHERE RECEIVER_ID = {0}";
  164. SQL = String.Format(SQL, RECEIVER_ID);
  165. ExecuteNonQuery(SQL);
  166. }
  167. }
  168. catch (Exception ex)
  169. {
  170. Util.UErrorMessage(ex,0,0);
  171. throw ex;
  172. }
  173. }
  174. //환경설정정보 읽어옴
  175. public DataTable Config_Select(int RECEIVER_ID)
  176. {
  177. DataTable dt = null;
  178. try
  179. {
  180. String SQL = "";
  181. SQL += "SELECT FIRE_ACCUMULATION_MODE,FIRE_ACCUMULATION_TIME,FIRE_PROCESS_MODE,SOUND_PROCESS_MODE";
  182. SQL += ",MASTER_USER_ID,MASTER_PASSWORD,BUILDING_NAME,JUMP_FIELD FROM TB_CONFIG ";
  183. SQL += " WHERE RECEIVER_ID = '{0}'";
  184. SQL = String.Format(SQL, RECEIVER_ID);
  185. DataSet dao = Select(SQL);
  186. dt = dao.Tables[0];
  187. }
  188. catch (Exception ex)
  189. {
  190. Debug.WriteLine(" Config Select Exception.. ");
  191. // Util.UErrorMessage(ex,0,0);
  192. throw ex;
  193. }
  194. return dt;
  195. }
  196. //환경정보 저장
  197. public void Config_Update(QUERYMode cmd, int RECEIVER_ID, String FIRE_ACCUMULATION_MODE, int FIRE_ACCUMULATION_TIME
  198. , String FIRE_PROCESS_MODE, String SOUND_PROCESS_MODE, String MASTER_USER_ID, String MASTER_PASSWORD
  199. , String BUILDING_NAME, string BACKGROUND_IMAGE)
  200. {
  201. try
  202. {
  203. DataTable dt = Config_Select(RECEIVER_ID);
  204. if (dt.Rows.Count == 0)
  205. {
  206. String SQL = "INSERT INTO TB_CONFIG (RECEIVER_ID,FIRE_ACCUMULATION_MODE,FIRE_ACCUMULATION_TIME";
  207. SQL += ",FIRE_PROCESS_MODE,SOUND_PROCESS_MODE,MASTER_USER_ID,MASTER_PASSWORD";
  208. SQL += ",BUILDING_NAME,BACKGROUND_IMAGE,UPDATE_USER_ID,UPDATE_TIME)";
  209. SQL += " VALUES ({0},'{1}',{2},'{3}','{4}','{5}','{6}','{7}','{8}','FPER',current_timestamp)";
  210. SQL = String.Format(SQL, RECEIVER_ID, FIRE_ACCUMULATION_MODE, FIRE_ACCUMULATION_TIME
  211. , FIRE_PROCESS_MODE, SOUND_PROCESS_MODE, MASTER_USER_ID, MASTER_PASSWORD, BUILDING_NAME, BACKGROUND_IMAGE);
  212. ExecuteNonQuery(SQL);
  213. //ExecuteNonQueryParam(SQL, BACKGROUND_IMAGE);
  214. }
  215. else
  216. {
  217. String SQL = "UPDATE TB_CONFIG SET FIRE_ACCUMULATION_MODE = '{0}',FIRE_ACCUMULATION_TIME={1},FIRE_PROCESS_MODE='{2}' ";
  218. SQL += ", SOUND_PROCESS_MODE = '{3}', MASTER_USER_ID = '{4}',MASTER_PASSWORD = '{5}'";
  219. SQL += ", BUILDING_NAME = '{6}', BACKGROUND_IMAGE = '{7}'";
  220. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  221. SQL += " WHERE RECEIVER_ID = {8}";
  222. SQL = String.Format(SQL, FIRE_ACCUMULATION_MODE, FIRE_ACCUMULATION_TIME, FIRE_PROCESS_MODE
  223. , SOUND_PROCESS_MODE, MASTER_USER_ID, MASTER_PASSWORD, BUILDING_NAME,BACKGROUND_IMAGE, RECEIVER_ID);
  224. ExecuteNonQuery(SQL);
  225. // ExecuteNonQueryParam(SQL, BACKGROUND_IMAGE);
  226. }
  227. }
  228. catch (Exception ex)
  229. {
  230. Util.UErrorMessage(ex,0,0);
  231. throw ex;
  232. }
  233. }
  234. }
  235. /*******************************************************************************************/
  236. }