DacCommConfig.cs 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295
  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_COMM(통신) 설정 관련 Dac
  11. *******************************************************************************************/
  12. public class DacCommConfig : DacBase
  13. {
  14. public DacCommConfig(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. ~DacCommConfig()
  25. {
  26. //try {
  27. // base.DisConnect();
  28. //}
  29. //catch (Exception ex) {
  30. // Util.UErrorMessage(ex, 0, 0);
  31. //}
  32. }
  33. public DataTable Comm_Select(int RECEIVER_ID, int COMM_ID, String UseFlag)
  34. {
  35. DataTable dt = null;
  36. try
  37. {
  38. String SQL = "";
  39. if (COMM_ID < 1)
  40. {
  41. SQL += "SELECT COMM_ID,COMM_NAME,COMM_LOOP,COMM_TYPE";
  42. SQL += ",COMM_PORT,BAUD_RATE,PARITY,DATA_BITS,STOP_BITS";
  43. SQL += ",IP_ADDRESS,PORT_NO,COMM_TIMEOUT,COMM_DELAY";
  44. SQL += ",LOG_FLAG,USE_FLAG FROM TB_COMM ";
  45. if (UseFlag != null)
  46. {
  47. SQL += " WHERE USE_FLAG = '" + UseFlag + "'";
  48. SQL += " AND RECEIVER_ID = '{0}'";
  49. }
  50. else
  51. {
  52. SQL += " WHERE RECEIVER_ID = '{0}'";
  53. }
  54. SQL += " ORDER BY COMM_ID";
  55. SQL = String.Format(SQL, RECEIVER_ID);
  56. }
  57. else
  58. {
  59. SQL += "SELECT COMM_ID,COMM_NAME,COMM_LOOP,COMM_TYPE";
  60. SQL += ",COMM_PORT,BAUD_RATE,PARITY,DATA_BITS,STOP_BITS";
  61. SQL += ",IP_ADDRESS,PORT_NO,COMM_TIMEOUT,COMM_DELAY";
  62. SQL += ",LOG_FLAG,USE_FLAG FROM TB_COMM ";
  63. if (UseFlag != null)
  64. {
  65. SQL += " WHERE USE_FLAG = '" + UseFlag + "'";
  66. SQL += " AND RECEIVER_ID = {0} AND COMM_ID = {1}";
  67. }
  68. else
  69. {
  70. SQL += " WHERE RECEIVER_ID = {0} AND COMM_ID = {1}";
  71. }
  72. SQL = String.Format(SQL, RECEIVER_ID, COMM_ID);
  73. }
  74. DataSet dao = Select(SQL);
  75. dt = dao.Tables[0];
  76. }
  77. catch (Exception ex)
  78. {
  79. Util.UErrorMessage(ex, 0, 0);
  80. throw ex;
  81. }
  82. return dt;
  83. }
  84. public void Comm_FlagUpdate(QUERYMode cmd, int RECEIVER_ID, Enum COMM_ID, String USE_FLAG)
  85. {
  86. try
  87. {
  88. int commId = (int)Enum.Parse(typeof(COMMLOOP), COMM_ID.ToString());
  89. DataTable dt = Comm_Select(RECEIVER_ID, commId, null);
  90. if (cmd == QUERYMode.insert || cmd == QUERYMode.update || cmd == QUERYMode.InsertAndUpdate)
  91. {
  92. String SQL = "";
  93. if (dt.Rows.Count > 0)
  94. {
  95. SQL = "UPDATE TB_COMM SET USE_FLAG = '{0}'";
  96. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  97. SQL += " WHERE RECEIVER_ID = {1} AND COMM_ID = {2}";
  98. SQL = String.Format(SQL, USE_FLAG, RECEIVER_ID, commId);
  99. ExecuteNonQuery(SQL);
  100. }
  101. }
  102. }
  103. catch (Exception ex)
  104. {
  105. Util.UErrorMessage(ex, 0, 0);
  106. throw ex;
  107. }
  108. }
  109. public void Comm_FlagUpdate(QUERYMode cmd, int RECEIVER_ID, Enum COMM_ID, String USE_FLAG, String LOG_FLAG)
  110. {
  111. try
  112. {
  113. int commId = (int)Enum.Parse(typeof(COMMLOOP), COMM_ID.ToString());
  114. DataTable dt = Comm_Select(RECEIVER_ID, commId, null);
  115. if (cmd == QUERYMode.insert || cmd == QUERYMode.update || cmd == QUERYMode.InsertAndUpdate)
  116. {
  117. String SQL = "";
  118. if (dt.Rows.Count > 0)
  119. {
  120. SQL = "UPDATE TB_COMM SET LOG_FLAG = '{0}',USE_FLAG = '{1}'";
  121. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  122. SQL += " WHERE RECEIVER_ID = {2} AND COMM_ID = {3}";
  123. SQL = String.Format(SQL, LOG_FLAG, USE_FLAG, RECEIVER_ID, commId);
  124. ExecuteNonQuery(SQL);
  125. }
  126. }
  127. }
  128. catch (Exception ex)
  129. {
  130. Util.UErrorMessage(ex, 0, 0);
  131. throw ex;
  132. }
  133. }
  134. public void Comm_Clear()
  135. {
  136. try
  137. {
  138. String SQL = "DELETE FROM TB_COMM ";
  139. ExecuteNonQuery(SQL);
  140. }
  141. catch (Exception ex)
  142. {
  143. Util.UErrorMessage(ex, 0, 0);
  144. throw ex;
  145. }
  146. }
  147. public void Comm_Update(QUERYMode cmd, int RECEIVER_ID, Enum COMM_ID, String COMM_NAME, Enum COMM_LOOP
  148. , String COMM_TYPE, String COMM_PORT, int BAUD_RATE, String PARITY, String DATA_BITS, String STOP_BITS
  149. , String IP_ADDRESS, int PORT_NO, int COMM_TIMEOUT, int COMM_DELAY, /*String RUN_TYPE,*/ String LOG_FLAG, String USE_FLAG)
  150. {
  151. try
  152. {
  153. int commId = (int)Enum.Parse(typeof(COMMLOOP), COMM_ID.ToString());
  154. int commLoop = (int)Enum.Parse(typeof(COMMLOOP), COMM_LOOP.ToString());
  155. DataTable dt = Comm_Select(RECEIVER_ID, commId, null);
  156. if (cmd == QUERYMode.insert || cmd == QUERYMode.update || cmd == QUERYMode.InsertAndUpdate)
  157. {
  158. String SQL = "";
  159. if (dt.Rows.Count > 0)
  160. {
  161. //RS232
  162. if (COMM_TYPE.Equals("C") || COMM_TYPE.Equals("R"))
  163. {
  164. SQL = "UPDATE TB_COMM SET COMM_NAME = '{0}'";
  165. SQL += ", COMM_LOOP = {1}, COMM_TYPE = '{2}'";
  166. SQL += ", COMM_PORT = '{3}', BAUD_RATE = {4}";
  167. SQL += ", PARITY = '{5}', DATA_BITS = '{6}'";
  168. SQL += ", STOP_BITS = '{7}'";
  169. SQL += ", COMM_TIMEOUT = {8}, COMM_DELAY = {9}";
  170. SQL += ", USE_FLAG = '{10}'";
  171. SQL += ", LOG_FLAG = '{11}'";
  172. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  173. SQL += " WHERE RECEIVER_ID = {12} AND COMM_ID = {13}";
  174. SQL = String.Format(SQL, COMM_NAME, commLoop, COMM_TYPE, COMM_PORT, BAUD_RATE
  175. , PARITY, DATA_BITS, STOP_BITS, COMM_TIMEOUT, COMM_DELAY, USE_FLAG, LOG_FLAG, RECEIVER_ID, commId);
  176. }
  177. //LEN
  178. else
  179. {
  180. SQL = "UPDATE TB_COMM SET COMM_NAME = '{0}'";
  181. SQL += ", COMM_LOOP = {1}, COMM_TYPE = '{2}'";
  182. SQL += ", IP_ADDRESS = '{3}', PORT_NO = {4}";
  183. SQL += ", COMM_TIMEOUT = {5}, COMM_DELAY = {6}";
  184. SQL += ", USE_FLAG = '{7}'";
  185. SQL += ", LOG_FLAG = '{8}'";
  186. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  187. SQL += " WHERE RECEIVER_ID = {9} AND COMM_ID = {10}";
  188. SQL = String.Format(SQL, COMM_NAME, commLoop, COMM_TYPE, IP_ADDRESS, PORT_NO
  189. , COMM_TIMEOUT, COMM_DELAY, USE_FLAG, LOG_FLAG, RECEIVER_ID, commId);
  190. }
  191. }
  192. else
  193. {
  194. if (COMM_TYPE.Equals("C") || COMM_TYPE.Equals("R"))
  195. {
  196. SQL = "INSERT INTO TB_COMM ( ";
  197. SQL += " RECEIVER_ID,COMM_ID,COMM_NAME,COMM_LOOP,COMM_TYPE,COMM_PORT";
  198. SQL += ",BAUD_RATE,PARITY,DATA_BITS,STOP_BITS";
  199. SQL += ",COMM_TIMEOUT,COMM_DELAY,USE_FLAG,LOG_FLAG,UPDATE_USER_ID,UPDATE_TIME";
  200. SQL += ") VALUES ({0},{1},'{2}',{3},'{4}','{5}',{6},'{7}','{8}','{9}',{10},{11},'{12}','{13}','FPER',current_timestamp)";
  201. SQL = String.Format(SQL, RECEIVER_ID, commId, COMM_NAME, commLoop, COMM_TYPE, COMM_PORT
  202. , BAUD_RATE, PARITY, DATA_BITS, STOP_BITS
  203. , COMM_TIMEOUT, COMM_DELAY, USE_FLAG, LOG_FLAG);
  204. }
  205. else
  206. {
  207. SQL = "INSERT INTO TB_COMM ( ";
  208. SQL += " RECEIVER_ID,COMM_ID,COMM_NAME,COMM_LOOP,COMM_TYPE";
  209. SQL += ",IP_ADDRESS,PORT_NO";
  210. SQL += ",COMM_TIMEOUT,COMM_DELAY,USE_FLAG,LOG_FLAG,UPDATE_USER_ID,UPDATE_TIME";
  211. SQL += ") VALUES ({0},'{1}','{2}',{3},{4},'{5}','{6}','FPER',current_timestamp)";
  212. SQL = String.Format(SQL, RECEIVER_ID, commId, COMM_NAME, commLoop, COMM_TYPE
  213. , IP_ADDRESS, PORT_NO
  214. , COMM_TIMEOUT, COMM_DELAY, USE_FLAG, LOG_FLAG, USE_FLAG);
  215. }
  216. }
  217. ExecuteNonQuery(SQL);
  218. }
  219. else if (cmd == QUERYMode.delete)
  220. {
  221. if (dt.Rows.Count < 1)
  222. {
  223. throw new Exception("해당 자료를 찾을수 없습니다.");
  224. }
  225. String SQL = "UPDATE TB_COMM SET USE_FLAG = 'N' ";
  226. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  227. SQL += " WHERE RECEIVER_ID = {0} AND COMM_ID = {1}";
  228. //String SQL = "DELETE FROM TB_COMM WHERE RECEIVER_ID = {0} AND COMM_ID = {1}";
  229. SQL = String.Format(SQL, RECEIVER_ID, commId);
  230. ExecuteNonQuery(SQL);
  231. }
  232. }
  233. catch (Exception ex)
  234. {
  235. Util.UErrorMessage(ex, 0, 0);
  236. throw ex;
  237. }
  238. }
  239. }
  240. /*******************************************************************************************/
  241. }