DacKeypadConfig.cs 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284
  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. namespace FPER
  8. {
  9. /*******************************************************************************************
  10. * TB_BOARD(키패드) 설정 관련 Dac
  11. *******************************************************************************************/
  12. public class DacKeypadConfig : DacBase
  13. {
  14. public DacKeypadConfig(int ID)
  15. : base(ID)// cyim 2015.7.30 데이타베이스 접속 루틴 변경
  16. {
  17. //try {
  18. // base.Connect();
  19. //}
  20. //catch (Exception ex) {
  21. // Util.UErrorMessage(ex, 0, 0);
  22. //}
  23. }
  24. ~DacKeypadConfig()
  25. {
  26. //try {
  27. // base.DisConnect();
  28. //}
  29. //catch (Exception ex) {
  30. // Util.UErrorMessage(ex, 0, 0);
  31. //}
  32. }
  33. public DataTable Keypad_Select(int RECEIVER_ID, String UseFlag)
  34. {
  35. DataTable dt = null;
  36. try
  37. {
  38. String SQL = "";
  39. SQL += "SELECT BOARD_ID,BOARD_NAME,LOOP0_USE_FLAG,LOOP1_USE_FLAG,USE_FLAG";
  40. SQL += " ,MAIN_VERSION,SUB_VERSION,BAUD_RATE,LOOP0_BAUD_RATE,LOOP1_BAUD_RATE";
  41. SQL += " ,LOOP0_CUT_FLAG,LOOP1_CUT_FLAG,LOOP0_USE_FLAG,LOOP1_USE_FLAG ";
  42. SQL += " FROM TB_BOARD WHERE RECEIVER_ID = {0} AND COMM_ID = 4 AND BOARD_ID = 1 ";
  43. if (UseFlag != null) SQL += " AND USE_FLAG = '" + UseFlag + "'";
  44. SQL += " ORDER BY BOARD_ID";
  45. SQL = String.Format(SQL, RECEIVER_ID);
  46. DataSet dao = Select(SQL);
  47. dt = dao.Tables[0];
  48. }
  49. catch (Exception ex)
  50. {
  51. Util.UErrorMessage(ex, 0, 0);
  52. throw ex;
  53. }
  54. return dt;
  55. }
  56. public void Keypad_Update(QUERYMode cmd, int RECEIVER_ID, String BOARD_NAME, String USE_FLAG
  57. , int BAUD_RATE, int MAIN_VERSION, int SUB_VERSION)
  58. {
  59. try
  60. {
  61. DataTable dt = Keypad_Select(RECEIVER_ID, null);
  62. if (cmd == QUERYMode.insert || cmd == QUERYMode.update || cmd == QUERYMode.InsertAndUpdate)
  63. {
  64. String SQL = "";
  65. if (dt.Rows.Count > 0)
  66. {
  67. SQL = "UPDATE TB_BOARD SET BOARD_NAME = '{0}'";
  68. SQL += ", USE_FLAG = '{1}'";
  69. SQL += ", LOOP0_USE_FLAG = 'Y', LOOP1_USE_FLAG = 'N'";
  70. SQL += ", BAUD_RATE = {2}, LOOP0_BAUD_RATE = 0";
  71. SQL += ", LOOP1_BAUD_RATE = 0";
  72. SQL += ", MAIN_VERSION = {3}, SUB_VERSION = {4}";
  73. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  74. SQL += " WHERE RECEIVER_ID = {5} AND COMM_ID = 4 AND BOARD_ID = 1";
  75. SQL = String.Format(SQL, BOARD_NAME, USE_FLAG, BAUD_RATE, MAIN_VERSION, SUB_VERSION, RECEIVER_ID);
  76. }
  77. else
  78. {
  79. SQL = "INSERT INTO TB_BOARD ( ";
  80. SQL += " RECEIVER_ID,COMM_ID,BOARD_ID,BOARD_NAME,LOOP0_USE_FLAG,LOOP1_USE_FLAG";
  81. SQL += ",BAUD_RATE,LOOP0_BAUD_RATE,LOOP1_BAUD_RATE,MAIN_VERSION,SUB_VERSION";
  82. SQL += ",USE_FLAG,UPDATE_USER_ID,UPDATE_TIME";
  83. SQL += ") VALUES ({0},4,1,'{1}','Y','N',{2},0,0,{3},{4},'{5}','FPER',current_timestamp)";
  84. SQL = String.Format(SQL, RECEIVER_ID, BOARD_NAME, BAUD_RATE, MAIN_VERSION, SUB_VERSION, USE_FLAG);
  85. }
  86. ExecuteNonQuery(SQL);
  87. }
  88. else if (cmd == QUERYMode.delete)
  89. {
  90. if (dt.Rows.Count < 1)
  91. {
  92. throw new Exception("해당 자료를 찾을수 없습니다.");
  93. }
  94. String SQL = "UPDATE TB_BOARD SET USE_FLAG = 'N' ";
  95. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  96. SQL += " WHERE RECEIVER_ID = {0} AND COMM_ID = 4 AND BOARD_ID = 1";
  97. SQL = String.Format(SQL, RECEIVER_ID);
  98. ExecuteNonQuery(SQL);
  99. }
  100. }
  101. catch (Exception ex)
  102. {
  103. Util.UErrorMessage(ex, 0, 0);
  104. throw ex;
  105. }
  106. }
  107. //회로조회
  108. public DataTable Device_Select(int RECEIVER_ID, int BOARD_ID, int DEVICE_ID, String INOUT_TYPE)
  109. {
  110. DataTable dt = null;
  111. try
  112. {
  113. String SQL = "";
  114. //CREATE TABLE TB_DEVICE (
  115. // RECEIVER_ID INTEGER NOT NULL, /* RECEIVER ID (1 - 32) */
  116. // COMM_ID INTEGER NOT NULL, /* COMM ID (1 - 4) */
  117. // BOARD_ID INTEGER NOT NULL, /* BOARD ID (1 - 16) */
  118. // LOOP_NO INTEGER NOT NULL, /* LOOP NO. (0 - 1) */
  119. // REPEATER_ID INTEGER NOT NULL, /* REPEATER ID (1 - 126) */
  120. // DEVICE_ID INTEGER NOT NULL, /* DEVICE ID (1 - 16) */
  121. // DEVICE_NAME VARCHAR(40), /* DEVICE NAME */
  122. // DEVICE_TYPE VARCHAR(2), /* DEVICE TYPE */
  123. // UPDATE_USER_ID VARCHAR(10), /* UPDATE USER ID */
  124. // UPDATE_TIME TIMESTAMP, /* UPDATE TIME */
  125. // CONSTRAINT PK_TB_DEVICE PRIMARY KEY (RECEIVER_ID,COMM_ID,BOARD_ID,LOOP_NO,REPEATER_ID,DEVICE_ID)
  126. //);
  127. if (DEVICE_ID == 0)
  128. {
  129. SQL += "SELECT a.DEVICE_ID,a.DEVICE_NAME,a.DEVICE_TYPE,a.INOUT_TYPE,a.CUT_FLAG";
  130. SQL += " ,b.DEVICE_TYPE_NAME,a.BOARD_ID,a.POSITION_CODE,c.POSITION_NAME";
  131. SQL += " FROM TB_DEVICE a";
  132. SQL += " LEFT OUTER JOIN TB_DEVICE_TYPE b ON a.DEVICE_TYPE = b.DEVICE_TYPE";
  133. SQL += " LEFT OUTER JOIN TB_POSITION_CODE c ON a.POSITION_CODE = c.POSITION_CODE";
  134. SQL += " WHERE a.RECEIVER_ID = {0} AND a.COMM_ID = 4 AND a.BOARD_ID = {1} AND a.LOOP_NO = 0 AND a.REPEATER_ID = 0";
  135. SQL += " ORDER BY a.DEVICE_ID";
  136. SQL = String.Format(SQL, RECEIVER_ID, BOARD_ID);
  137. }
  138. else
  139. {
  140. SQL += "SELECT a.DEVICE_ID,a.DEVICE_NAME,a.DEVICE_TYPE,a.INOUT_TYPE,a.CUT_FLAG";
  141. SQL += " ,b.DEVICE_TYPE_NAME,a.BOARD_ID,a.POSITION_CODE,c.POSITION_NAME";
  142. SQL += " FROM TB_DEVICE a";
  143. SQL += " LEFT OUTER JOIN TB_DEVICE_TYPE b ON a.DEVICE_TYPE = b.DEVICE_TYPE";
  144. SQL += " LEFT OUTER JOIN TB_POSITION_CODE c ON a.POSITION_CODE = c.POSITION_CODE";
  145. SQL += " WHERE a.RECEIVER_ID = {0} AND a.COMM_ID = 4 AND a.BOARD_ID = {1} AND a.LOOP_NO = 0 AND a.REPEATER_ID = 0";
  146. SQL += " AND a.DEVICE_ID = {2} AND a.INOUT_TYPE = '{3}'";
  147. SQL = String.Format(SQL, RECEIVER_ID, BOARD_ID, DEVICE_ID, INOUT_TYPE);
  148. }
  149. DataSet dao = Select(SQL);
  150. dt = dao.Tables[0];
  151. }
  152. catch (Exception ex)
  153. {
  154. Util.UErrorMessage(ex, 0, 0);
  155. throw ex;
  156. }
  157. return dt;
  158. }
  159. //회로설정값 저장
  160. public void Device_Update(QUERYMode cmd, int RECEIVER_ID, int BOARD_ID, int DEVICE_ID, String INOUT_TYPE
  161. , String DEVICE_NAME, String DEVICE_TYPE, String POSITION_CODE)
  162. {
  163. try
  164. {
  165. if (cmd == QUERYMode.insert || cmd == QUERYMode.update || cmd == QUERYMode.InsertAndUpdate)
  166. {
  167. if (DEVICE_ID < 1) return;
  168. String SQL = "";
  169. DataTable dt = Device_Select(RECEIVER_ID, BOARD_ID, DEVICE_ID, INOUT_TYPE);
  170. if (dt.Rows.Count > 0)
  171. {
  172. SQL = "UPDATE TB_DEVICE SET DEVICE_NAME = '{0}'";
  173. SQL += ", DEVICE_TYPE = '{1}', POSITION_CODE = '{2}' ";
  174. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  175. SQL += " WHERE RECEIVER_ID = {3} AND COMM_ID = 4 AND BOARD_ID = {4} ";
  176. SQL += " AND DEVICE_ID = {5} AND INOUT_TYPE = '{6}'";
  177. SQL = String.Format(SQL, DEVICE_NAME, DEVICE_TYPE, POSITION_CODE, RECEIVER_ID, BOARD_ID, DEVICE_ID, INOUT_TYPE);
  178. }
  179. else
  180. {
  181. SQL = "INSERT INTO TB_DEVICE ( ";
  182. SQL += " RECEIVER_ID,COMM_ID,BOARD_ID,LOOP_NO,REPEATER_ID,DEVICE_ID,INOUT_TYPE,DEVICE_NAME";
  183. SQL += ",DEVICE_TYPE,POSITION_CODE,UPDATE_USER_ID,UPDATE_TIME";
  184. SQL += ") VALUES ({0},4,{1},0,0,{2},'{3}','{4}','{5}','{6}','FPER',current_timestamp)";
  185. SQL = String.Format(SQL, RECEIVER_ID, BOARD_ID, DEVICE_ID, INOUT_TYPE, DEVICE_NAME, DEVICE_TYPE, POSITION_CODE);
  186. }
  187. ExecuteNonQuery(SQL);
  188. }
  189. else if (cmd == QUERYMode.delete)
  190. {
  191. String SQL = "";
  192. if (DEVICE_ID < 1)
  193. {
  194. SQL = "DELETE FROM TB_DEVICE WHERE RECEIVER_ID = {0} AND COMM_ID = 4 AND BOARD_ID = {1} AND LOOP_NO = 0 AND REPEATER_ID = 0";
  195. SQL = String.Format(SQL, RECEIVER_ID, BOARD_ID);
  196. }
  197. else
  198. {
  199. SQL = "DELETE FROM TB_DEVICE WHERE RECEIVER_ID = {0} AND COMM_ID = 4 AND BOARD_ID = {1} AND LOOP_NO = 0 AND REPEATER_ID = 0";
  200. SQL += " AND DEVICE_ID = {2} AND INOUT_TYPE = '{3}'";
  201. SQL = String.Format(SQL, RECEIVER_ID, BOARD_ID, DEVICE_ID, INOUT_TYPE);
  202. }
  203. ExecuteNonQuery(SQL);
  204. }
  205. }
  206. catch (Exception ex)
  207. {
  208. Util.UErrorMessage(ex, 0, 0);
  209. throw ex;
  210. }
  211. }
  212. }
  213. }