DacReceiverConfig.cs 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670
  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 FPER
  11. {
  12. /*******************************************************************************************
  13. * TB_RECEIVER(수신기) 설정 관련 Dac
  14. *******************************************************************************************/
  15. public class DacReceiverConfig : DacBase , IDisposable
  16. {
  17. public int ReceiverID = 0;
  18. public DacReceiverConfig(int ID)
  19. : base(ID)// cyim 2015.7.30 데이타베이스 접속 루틴 변경
  20. {
  21. //try {
  22. // base.Connect();
  23. //}
  24. //catch (Exception ex) {
  25. // Util.UErrorMessage(ex, 0, 0);
  26. //}
  27. ReceiverID = ID;
  28. }
  29. ~DacReceiverConfig()
  30. {
  31. try
  32. {
  33. base.DisConnect();
  34. }
  35. catch (Exception ex)
  36. {
  37. Util.UErrorMessage(ex, 0, 0);
  38. }
  39. }
  40. // cyim 2017.01.02 : Memory leak
  41. public void Dispose()
  42. {
  43. DisConnect();
  44. }
  45. //
  46. // cyim 2016.04.06 : 감지기의 낮시간대 설정
  47. //
  48. // 테이블 조회
  49. public DataRowCollection TB_DAYTIME_Exist()
  50. {
  51. DataTable dt = null;
  52. try
  53. {
  54. String SQL = Table_Exist_SQL("TB_DAYTIME");
  55. DataSet dao = Select(SQL);
  56. dt = dao.Tables[0];
  57. return dt.Rows;
  58. }
  59. catch (Exception ex)
  60. {
  61. Util.UErrorMessage(ex, 0, 0);
  62. }
  63. return null;
  64. }
  65. // 테이블 존재 여부
  66. public string Table_Exist_SQL(string TABLE_NAME)
  67. {
  68. string SQL = "select rdb$relation_name ";
  69. SQL = SQL + "from rdb$relations ";
  70. SQL = SQL + "where rdb$system_flag=0 ";
  71. SQL = SQL + "and rdb$relation_name = '" + TABLE_NAME + "'";
  72. return SQL;
  73. }
  74. // 테이블 읽기
  75. public DataRowCollection TB_DAYTIME_Get()
  76. {
  77. DataTable dt = null;
  78. try
  79. {
  80. String SQL = "SELECT * FROM TB_DAYTIME";
  81. DataSet dao = Select(SQL);
  82. dt = dao.Tables[0];
  83. return dt.Rows;
  84. }
  85. catch (Exception ex)
  86. {
  87. Util.UErrorMessage(ex, 0, 0);
  88. }
  89. return null;
  90. }
  91. // 테이블 쓰기
  92. public void TB_DAYTIME_Set(string Start_Hour,string Start_Minute, string End_Hour, string End_Minute)
  93. {
  94. try
  95. {
  96. String SQL = "insert into TB_DAYTIME (START_HOUR,START_MIN,END_HOUR,END_MIN) values " + string.Format("({0},{1},{2},{3})", Start_Hour, Start_Minute, End_Hour, End_Minute);
  97. ExecuteNonQuery(SQL);
  98. }
  99. catch (Exception ex)
  100. {
  101. Util.UErrorMessage(ex, 0, 0);
  102. }
  103. }
  104. // 테이블 삭제
  105. public void TB_DAYTIME_Init()
  106. {
  107. try
  108. {
  109. String SQL = "Delete from TB_DAYTIME";
  110. ExecuteNonQuery(SQL);
  111. }
  112. catch (Exception ex)
  113. {
  114. Util.UErrorMessage(ex, 0, 0);
  115. }
  116. }
  117. // cyim 2013.8.7 타수신기 화재 정보 팝업창 출력 (타수신기 정보를 모두 가져와야 된다)
  118. public DataTable Receiver_Select()
  119. {
  120. DataTable dt = null;
  121. try
  122. {
  123. String SQL = "";
  124. SQL += "SELECT RECEIVER_ID,RECEIVER_NAME,IP_ADDRESS FROM TB_RECEIVER ";
  125. DataSet dao = Select(SQL);
  126. dt = dao.Tables[0];
  127. }
  128. catch (Exception ex)
  129. {
  130. Util.UErrorMessage(ex, 0, 0);
  131. throw ex;
  132. }
  133. return dt;
  134. }
  135. // cyim 2017.01.24 : 사용중인 펌프만 표시하도록 한다
  136. public DataTable Pump_Select(int num) // num 1 -> 9, 8 -> 16
  137. {
  138. DataTable dt = null;
  139. try
  140. {
  141. DataSet dao = Select(string.Format("select * from TB_DEVICE where COMM_ID ='3' and DEVICE_ID='{0}'", 8 + num));
  142. dt = dao.Tables[0];
  143. }
  144. catch
  145. {
  146. ;
  147. }
  148. return dt;
  149. }
  150. public DataTable Receiver_Select(String RECEIVER_ID, String UseFlag)
  151. {
  152. DataTable dt = null;
  153. try
  154. {
  155. String SQL = "";
  156. if (RECEIVER_ID == null)
  157. {
  158. SQL += "SELECT RECEIVER_ID,RECEIVER_NAME,IP_ADDRESS,EVENT_PORT_NO,COMMAND_PORT_NO";
  159. SQL += ",REDUNDANT_FLAG,USE_FLAG FROM TB_RECEIVER ";
  160. if (UseFlag != null) SQL += " WHERE USE_FLAG = '" + UseFlag + "'";
  161. SQL += " ORDER BY RECEIVER_ID";
  162. }
  163. else
  164. {
  165. SQL += "SELECT RECEIVER_ID,RECEIVER_NAME,IP_ADDRESS,EVENT_PORT_NO,COMMAND_PORT_NO";
  166. SQL += ",REDUNDANT_FLAG,USE_FLAG FROM TB_RECEIVER ";
  167. if (UseFlag != null)
  168. {
  169. SQL += " WHERE USE_FLAG = '" + UseFlag + "' AND RECEIVER_ID = '{0}'";
  170. }
  171. else
  172. {
  173. SQL += " WHERE RECEIVER_ID = '{0}'";
  174. }
  175. SQL = String.Format(SQL, RECEIVER_ID);
  176. }
  177. DataSet dao = Select(SQL);
  178. dt = dao.Tables[0];
  179. }
  180. catch (Exception ex)
  181. {
  182. Util.UErrorMessage(ex, 0, 0);
  183. throw ex;
  184. }
  185. return dt;
  186. }
  187. public int ReceiverID_Max()
  188. {
  189. int ReceiverId = 0;
  190. try
  191. {
  192. DataSet dao = Select("SELECT MAX(RECEIVER_ID) FROM TB_RECEIVER");
  193. DataTable dt = dao.Tables[0];
  194. if (dt.Rows.Count > 0)
  195. {
  196. foreach (DataRow dr in dt.Rows)
  197. {
  198. if (!dr[0].ToString().Equals(""))
  199. ReceiverId = int.Parse(dr[0].ToString());
  200. }
  201. }
  202. }
  203. catch (Exception ex)
  204. {
  205. Util.UErrorMessage(ex, 0, 0);
  206. throw ex;
  207. }
  208. return ++ReceiverId;
  209. }
  210. //public DataTable ReceiverUse_List()
  211. //{
  212. // DataTable dt = null;
  213. // try
  214. // {
  215. // String SQL = "";
  216. // SQL += "SELECT RECEIVER_ID,RECEIVER_NAME FROM TB_RECEIVER WHERE USE_FLAG = 'Y' ORDER BY RECEIVER_ID";
  217. // DataSet dao = Select(SQL);
  218. // dt = dao.Tables[0];
  219. // }
  220. // catch (Exception ex)
  221. // {
  222. // throw ex;
  223. // }
  224. // return dt;
  225. //}
  226. public void Receiver_Clear()
  227. {
  228. try
  229. {
  230. String SQL = "DELETE FROM TB_RECEIVER ";
  231. ExecuteNonQuery(SQL);
  232. }
  233. catch (Exception ex)
  234. {
  235. Util.UErrorMessage(ex, 0, 0);
  236. throw ex;
  237. }
  238. }
  239. 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)
  240. {
  241. try
  242. {
  243. DataTable dt = Receiver_Select(RECEIVER_ID, null);
  244. if (cmd == QUERYMode.insert)
  245. {
  246. if (dt.Rows.Count > 0)
  247. {
  248. throw new Exception("이미 해당 자료가 존재합니다. 수정모드로 작업하여 주십시요.");
  249. }
  250. 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)";
  251. SQL += " VALUES ({0},'{1}','{2}',{3},{4},'{5}','{6}','FPER',current_timestamp)";
  252. SQL = String.Format(SQL, RECEIVER_ID, RECEIVER_NAME, IP_ADDRESS, EVENT_PORT_NO, COMMAND_PORT_NO, REDUNDANT_FLAG, USE_FLAG);
  253. ExecuteNonQuery(SQL);
  254. //통신보드 백루프 사용여부를 수정해 준다..
  255. DacCommConfig dacCommConfig = new DacCommConfig(ReceiverID);// cyim 2015.7.30 데이타베이스 접속 루틴 변경
  256. dacCommConfig.Comm_FlagUpdate(QUERYMode.InsertAndUpdate, int.Parse(RECEIVER_ID), COMMLOOP.BackLoop, REDUNDANT_FLAG);
  257. }
  258. else if (cmd == QUERYMode.update)
  259. {
  260. if (dt.Rows.Count < 1)
  261. {
  262. throw new Exception("해당 자료를 찾을수 없습니다.");
  263. }
  264. String SQL = "UPDATE TB_RECEIVER SET RECEIVER_NAME = '{0}'";
  265. SQL += ", IP_ADDRESS = '{1}', EVENT_PORT_NO = '{2}'";
  266. SQL += ", COMMAND_PORT_NO = '{3}', REDUNDANT_FLAG = '{4}', USE_FLAG = '{5}'";
  267. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  268. SQL += " WHERE RECEIVER_ID = {6}";
  269. SQL = String.Format(SQL, RECEIVER_NAME, IP_ADDRESS, EVENT_PORT_NO, COMMAND_PORT_NO, REDUNDANT_FLAG, USE_FLAG, RECEIVER_ID);
  270. ExecuteNonQuery(SQL);
  271. //통신보드 백루프 사용여부를 수정해 준다..
  272. DacCommConfig dacCommConfig = new DacCommConfig(ReceiverID);// cyim 2015.7.30 데이타베이스 접속 루틴 변경
  273. dacCommConfig.Comm_FlagUpdate(QUERYMode.InsertAndUpdate, int.Parse(RECEIVER_ID), COMMLOOP.BackLoop, REDUNDANT_FLAG);
  274. }
  275. else if (cmd == QUERYMode.delete)
  276. {
  277. if (dt.Rows.Count < 1)
  278. {
  279. throw new Exception("해당 자료를 찾을수 없습니다.");
  280. }
  281. //if (int.Parse(RECEIVER_ID) == myReceiverID)
  282. //{
  283. // throw new Exception("해당 수신기는 삭제할수 없습니다.");
  284. //}
  285. String SQL = "UPDATE TB_RECEIVER SET USE_FLAG = 'N' ";
  286. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  287. SQL += " WHERE RECEIVER_ID = {0}";
  288. //String SQL = "DELETE FROM TB_RECEIVER WHERE RECEIVER_ID = {0}";
  289. SQL = String.Format(SQL, RECEIVER_ID);
  290. ExecuteNonQuery(SQL);
  291. }
  292. }
  293. catch (Exception ex)
  294. {
  295. Util.UErrorMessage(ex, 0, 0);
  296. throw ex;
  297. }
  298. }
  299. //환경설정정보 읽어옴
  300. public DataTable Config_Select(int RECEIVER_ID)
  301. {
  302. DataTable dt = null;
  303. try
  304. {
  305. String SQL = "";
  306. // cyim 2013.6.27 운전설정시에 시운전 모드 체크박스 추가 및 메인 UI 표시 (TEST_RUN_FLAG 추가 및 기본값은 N)
  307. SQL += "SELECT FIRE_ACCUMULATION_MODE,FIRE_ACCUMULATION_TIME,FIRE_PROCESS_MODE,SOUND_PROCESS_MODE";
  308. // cyim 2013.6.27 운전설정시에 시운전 모드 체크박스 추가 및 메인 UI 표시
  309. // cyim 2013.7.29 화재시화면전환 정보 데이타베이스 저장 및 읽기
  310. // cyim 2014.8.11 화면에 마스터인지 슬레이브인지 표시
  311. SQL += ",MASTER_USER_ID,MASTER_PASSWORD,BUILDING_NAME,BACKGROUND_IMAGE,TEST_RUN_FLAG,JUMP_FIELD,MASTER_FLAG ,RECEIVER_ID FROM TB_CONFIG ";// cyim 2015.7.31 TB_CONFIG 테이블 정보를 읽을때 수신기 아이디도 같이 조회하게 한다
  312. // cyim 2015.7.31 수신반의 경우 TB_CONFIG 테이블을 읽을때만 수신기 아이디를 선택하지 않게 0으로 조회한다
  313. if(RECEIVER_ID!=0)
  314. SQL += " WHERE RECEIVER_ID = '{0}'";
  315. SQL = String.Format(SQL, RECEIVER_ID);
  316. DataSet dao = Select(SQL);
  317. dt = dao.Tables[0];
  318. }
  319. catch (Exception ex)
  320. {
  321. //Debug.WriteLine(" Config Select Exception.. ");
  322. // Util.UErrorMessage(ex,0,0);
  323. throw ex;
  324. }
  325. return dt;
  326. }
  327. //환경정보 저장
  328. public void Config_Update(QUERYMode cmd, int RECEIVER_ID, String FIRE_ACCUMULATION_MODE, int FIRE_ACCUMULATION_TIME
  329. , String FIRE_PROCESS_MODE, String SOUND_PROCESS_MODE, String MASTER_USER_ID, String MASTER_PASSWORD
  330. , String BUILDING_NAME, string BACKGROUND_IMAGE, string TEST_RUN_FLAG, string JUMP_FIELD)
  331. {
  332. try
  333. {
  334. DataTable dt = Config_Select(RECEIVER_ID);
  335. if (dt.Rows.Count == 0)
  336. {
  337. String SQL = "INSERT INTO TB_CONFIG (RECEIVER_ID,FIRE_ACCUMULATION_MODE,FIRE_ACCUMULATION_TIME";
  338. SQL += ",FIRE_PROCESS_MODE,SOUND_PROCESS_MODE,MASTER_USER_ID,MASTER_PASSWORD";
  339. // cyim 2013.6.27 운전설정시에 시운전 모드 체크박스 추가 및 메인 UI 표시 (TEST_RUN_FLAG 추가 및 기본값은 N)
  340. // cyim 2013.7.29 화재시화면전환 정보 데이타베이스 저장 및 읽기
  341. SQL += ",BUILDING_NAME,BACKGROUND_IMAGE,UPDATE_USER_ID,TEST_RUN_FLAG,JUMP_FIELD UPDATE_TIME)";
  342. SQL += " VALUES ({0},'{1}',{2},'{3}','{4}','{5}','{6}','{7}','{8}','FPER','{9}',current_timestamp,'{10}')";
  343. SQL = String.Format(SQL, RECEIVER_ID, FIRE_ACCUMULATION_MODE, FIRE_ACCUMULATION_TIME
  344. , FIRE_PROCESS_MODE, SOUND_PROCESS_MODE, MASTER_USER_ID, MASTER_PASSWORD, BUILDING_NAME, BACKGROUND_IMAGE, TEST_RUN_FLAG, JUMP_FIELD);
  345. ExecuteNonQuery(SQL);
  346. //ExecuteNonQueryParam(SQL, BACKGROUND_IMAGE);
  347. }
  348. else
  349. {
  350. String SQL = "UPDATE TB_CONFIG SET FIRE_ACCUMULATION_MODE = '{0}',FIRE_ACCUMULATION_TIME={1},FIRE_PROCESS_MODE='{2}' ";
  351. SQL += ", SOUND_PROCESS_MODE = '{3}', MASTER_USER_ID = '{4}',MASTER_PASSWORD = '{5}'";
  352. // cyim 2013.6.27 운전설정시에 시운전 모드 체크박스 추가 및 메인 UI 표시
  353. // cyim 2013.7.29 화재시화면전환 정보 데이타베이스 저장 및 읽기
  354. SQL += ", BUILDING_NAME = '{6}', BACKGROUND_IMAGE = '{7}' , TEST_RUN_FLAG = '{9}' , JUMP_FIELD = '{10}'";
  355. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  356. SQL += " WHERE RECEIVER_ID = {8}";
  357. SQL = String.Format(SQL, FIRE_ACCUMULATION_MODE, FIRE_ACCUMULATION_TIME, FIRE_PROCESS_MODE
  358. , SOUND_PROCESS_MODE, MASTER_USER_ID, MASTER_PASSWORD, BUILDING_NAME, BACKGROUND_IMAGE, RECEIVER_ID, TEST_RUN_FLAG, JUMP_FIELD);
  359. ExecuteNonQuery(SQL);
  360. // ExecuteNonQueryParam(SQL, BACKGROUND_IMAGE);
  361. }
  362. }
  363. catch (Exception ex)
  364. {
  365. Util.UErrorMessage(ex, 0, 0);
  366. throw ex;
  367. }
  368. }
  369. //입출력 회로 타입 조회
  370. public DataTable Device_Type_Select(String SYMBOL_TYPE, String DEVICE_TYPE)
  371. {
  372. DataTable dt = null;
  373. try
  374. {
  375. String SQL = "";
  376. SQL += "SELECT SYMBOL_TYPE,DEVICE_TYPE,DEVICE_TYPE_NAME,USE_FLAG ";
  377. SQL += " FROM TB_DEVICE_TYPE WHERE SYMBOL_TYPE = '{0}' AND DEVICE_TYPE = '{1}'";
  378. SQL += " ORDER BY DEVICE_TYPE";
  379. SQL = String.Format(SQL, SYMBOL_TYPE, DEVICE_TYPE);
  380. DataSet dao = Select(SQL);
  381. dt = dao.Tables[0];
  382. }
  383. catch (Exception ex)
  384. {
  385. Util.UErrorMessage(ex, 0, 0);
  386. throw ex;
  387. }
  388. return dt;
  389. }
  390. //입출력 회로 타입 Clear
  391. public void Device_Type_Clear(String SYMBOL_TYPE)
  392. {
  393. try
  394. {
  395. String SQL = "UPDATE TB_DEVICE_TYPE SET USE_FLAG = 'N' ";
  396. SQL += " ,UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  397. SQL += " WHERE SYMBOL_TYPE = '{0}'";
  398. SQL = String.Format(SQL, SYMBOL_TYPE);
  399. ExecuteNonQuery(SQL);
  400. }
  401. catch (Exception ex)
  402. {
  403. Util.UErrorMessage(ex, 0, 0);
  404. throw ex;
  405. }
  406. }
  407. //입출력 회로 타입 저장
  408. public void Device_Type_Update(QUERYMode cmd, String DEVICE_TYPE, String DEVICE_TYPE_NAME, String SYMBOL_TYPE
  409. , String USE_FLAG)
  410. {
  411. try
  412. {
  413. DataTable dt = Device_Type_Select(SYMBOL_TYPE, DEVICE_TYPE);
  414. if (dt.Rows.Count == 0)
  415. {
  416. String SQL = "INSERT INTO TB_DEVICE_TYPE (DEVICE_TYPE,DEVICE_TYPE_NAME";
  417. SQL += ",SYMBOL_TYPE,USE_FLAG,UPDATE_USER_ID,UPDATE_TIME)";
  418. SQL += " VALUES ('{0}','{1}','{2}','{3}','FPER',current_timestamp)";
  419. SQL = String.Format(SQL, DEVICE_TYPE, DEVICE_TYPE_NAME, SYMBOL_TYPE, USE_FLAG);
  420. ExecuteNonQuery(SQL);
  421. }
  422. else
  423. {
  424. String SQL = "UPDATE TB_DEVICE_TYPE SET DEVICE_TYPE_NAME = '{0}',SYMBOL_TYPE='{1}',USE_FLAG='{2}' ";
  425. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  426. SQL += " WHERE DEVICE_TYPE = '{3}'";
  427. SQL = String.Format(SQL, DEVICE_TYPE_NAME, SYMBOL_TYPE, USE_FLAG, DEVICE_TYPE);
  428. ExecuteNonQuery(SQL);
  429. }
  430. }
  431. catch (Exception ex)
  432. {
  433. Util.UErrorMessage(ex, 0, 0);
  434. throw ex;
  435. }
  436. }
  437. //// 읽기
  438. //public DataTable SelectSql(string SQL)
  439. //{
  440. // DataTable dt = null;
  441. // try
  442. // {
  443. // DataSet dao = Select(SQL);
  444. // dt = dao.Tables[0];
  445. // }
  446. // catch (Exception ex)
  447. // {
  448. // Util.UErrorMessage(ex, 0, 0);
  449. // }
  450. // return dt;
  451. //}
  452. // 쓰기
  453. public void ExecuteSql(string SQL)
  454. {
  455. if (this.Connect())
  456. {
  457. FbTransaction transaction = connection.BeginTransaction();
  458. try
  459. {
  460. FbCommand command = new FbCommand(SQL, connection, transaction);
  461. command.CommandType = CommandType.Text;
  462. command.CommandTimeout = 5;
  463. command.ExecuteNonQuery();
  464. transaction.Commit();
  465. command.Dispose();
  466. }
  467. catch (Exception ex)
  468. {
  469. //Util.UErrorMessage(ex, 0, 0);
  470. transaction.Rollback();
  471. throw ex;
  472. }
  473. finally
  474. {
  475. this.DisConnect();
  476. }
  477. }
  478. }
  479. // //환경테이블에 이미지 저장
  480. ////UPDATEBLOB table_name
  481. //// SET BLOB_필드 = :lb_data
  482. //// WHERE ID = :ls_code;
  483. ////--읽어오기--
  484. ////SELECTBLOB BLOB_필드
  485. //// INTO :lb_data
  486. //// FROM table_name
  487. //// WHERE ID = :ls_code;
  488. // public void ConfigImage_Update(QUERYMode cmd, int RECEIVER_ID, byte[] bytes)
  489. // {
  490. // FbTransaction transaction = connection.BeginTransaction();
  491. // try
  492. // {
  493. // String SQL = "UPDATE TB_CONFIG SET BACKGROUND_IMAGE = ?";
  494. // SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  495. // SQL += string.Format(" WHERE RECEIVER_ID = {0}", RECEIVER_ID);
  496. // FbCommand command = new FbCommand(SQL, connection, transaction);
  497. // FbParameter param = command.CreateParameter();
  498. // param.FbDbType = FbDbType.Binary;
  499. // param.SourceColumn = "BACKGROUND_IMAGE";
  500. // param.Value = bytes;
  501. // command.CommandType = CommandType.Text;
  502. // command.Parameters.Add(param);
  503. // command.ExecuteNonQuery();
  504. // transaction.Commit();
  505. // command.Dispose();
  506. // }
  507. // catch (Exception ex)
  508. // {
  509. // transaction.Rollback();
  510. // throw ex;
  511. // }
  512. // }
  513. }
  514. /*******************************************************************************************/
  515. }