usersDataAccess.cs 50 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Web;
  5. using Oracle.ManagedDataAccess.Client;
  6. using System.Data;
  7. namespace ResfullApi.Models
  8. {
  9. public class usersDataAccess
  10. {
  11. public usersDataAccess()
  12. {
  13. }
  14. public static DataSet USERS_API_DK_HUY(string v_msisdn, string v_users, string v_pass, string v_passnew, string n_serviceid, string v_command, string v_channel, string v_role)
  15. {
  16. // {"msisdn":"50940227941","users":"123","pass":"123","serviceId":"23","type":"DK","channel":"WEB"}
  17. string str;
  18. str = "";
  19. str = "api_pkg.USERS_API_DK_HUY";
  20. OracleParameter[] parms;
  21. parms = new OracleParameter[]
  22. {
  23. new OracleParameter("v_msisdn", OracleDbType.NVarchar2),
  24. new OracleParameter("v_users", OracleDbType.NVarchar2),
  25. new OracleParameter("v_pass", OracleDbType.NVarchar2),
  26. new OracleParameter("v_passnew", OracleDbType.NVarchar2),
  27. new OracleParameter("n_serviceid", OracleDbType.NVarchar2),
  28. new OracleParameter("v_command", OracleDbType.NVarchar2),
  29. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  30. new OracleParameter("v_role", OracleDbType.NVarchar2),
  31. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  32. };
  33. parms[0].Value = v_msisdn;
  34. parms[1].Value = v_users;
  35. parms[2].Value = v_pass;
  36. parms[3].Value = v_passnew;
  37. parms[4].Value = n_serviceid;
  38. parms[5].Value = v_command;
  39. parms[6].Value = v_channel;
  40. parms[7].Value = v_role;
  41. return DataAccess.getDataFromProcedure(str, "", parms);
  42. }
  43. public static DataSet USERS_GET_STATUS(string v_users, string n_serviceid)
  44. {
  45. // {"users":"123","serviceId":"23"}
  46. string str;
  47. str = "";
  48. str = "api_pkg.USERS_GET_STATUS";
  49. OracleParameter[] parms;
  50. parms = new OracleParameter[]
  51. {
  52. new OracleParameter("v_users", OracleDbType.NVarchar2),
  53. new OracleParameter("n_serviceid", OracleDbType.NVarchar2),
  54. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  55. };
  56. parms[0].Value = v_users;
  57. parms[1].Value = n_serviceid;
  58. return DataAccess.getDataFromProcedure(str, "", parms);
  59. }
  60. public static DataSet SERVICE_SEARCH_DETAIL(string serviceId, string msisdn, string role)
  61. {
  62. string sSQL = "MPS_PKG.SEARCH_SUB";
  63. OracleParameter[] cmdParms = new OracleParameter[]
  64. {
  65. new OracleParameter("vtype", OracleDbType.NVarchar2),
  66. new OracleParameter("vmsisdn", OracleDbType.NVarchar2),
  67. new OracleParameter("vrole", OracleDbType.NVarchar2),
  68. new OracleParameter("returnds", OracleDbType.RefCursor, ParameterDirection.Output)
  69. };
  70. cmdParms[0].Value = serviceId;
  71. cmdParms[1].Value = msisdn;
  72. cmdParms[2].Value = role;
  73. return DataAccess.getDataFromProcedure(sSQL, "HR_Content", cmdParms);
  74. }
  75. public static DataSet USERS_UPDATE_PROFILE(string users, string fullName, string sex, string address, string province, string cardNumber, string email, string company,
  76. string description, string picture,string sexNeed,string birthday,string height,string weight,string work,string serviceid,string lookingFor)
  77. {
  78. // {"users":"123","serviceId":"23"}
  79. string str;
  80. str = "";
  81. str = "api_pkg.USERS_UPDATE_PROFILE";
  82. OracleParameter[] parms;
  83. parms = new OracleParameter[]
  84. {
  85. new OracleParameter("v_users", OracleDbType.NVarchar2),
  86. new OracleParameter("v_fullName", OracleDbType.NVarchar2),
  87. new OracleParameter("v_sex", OracleDbType.NVarchar2),
  88. new OracleParameter("v_address", OracleDbType.NVarchar2),
  89. new OracleParameter("v_province", OracleDbType.NVarchar2),
  90. new OracleParameter("v_cardNumber", OracleDbType.NVarchar2),
  91. new OracleParameter("v_email", OracleDbType.NVarchar2),
  92. new OracleParameter("v_company", OracleDbType.NVarchar2),
  93. new OracleParameter("v_description", OracleDbType.NVarchar2),
  94. new OracleParameter("v_picture", OracleDbType.NVarchar2),
  95. new OracleParameter("v_sexNeed", OracleDbType.NVarchar2),
  96. new OracleParameter("v_birthday", OracleDbType.NVarchar2),
  97. new OracleParameter("v_height", OracleDbType.NVarchar2),
  98. new OracleParameter("v_weight", OracleDbType.NVarchar2),
  99. new OracleParameter("v_work", OracleDbType.NVarchar2),
  100. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  101. new OracleParameter("v_lookingFor", OracleDbType.NVarchar2),
  102. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  103. };
  104. parms[0].Value = users;
  105. parms[1].Value = fullName;
  106. parms[2].Value = sex;
  107. parms[3].Value = address;
  108. parms[4].Value = province;
  109. parms[5].Value = cardNumber;
  110. parms[6].Value = email;
  111. parms[7].Value = company;
  112. parms[8].Value = description;
  113. parms[9].Value = picture;
  114. parms[10].Value = sexNeed;
  115. parms[11].Value = birthday;
  116. parms[12].Value = height;
  117. parms[13].Value = weight;
  118. parms[14].Value = work;
  119. parms[15].Value = serviceid;
  120. parms[16].Value = lookingFor;
  121. return DataAccess.getDataFromProcedure(str, "", parms);
  122. }
  123. public static DataSet USERS_GET_PROFILE(string users, string serviceid, string uidQuery)
  124. {
  125. // {"users":"123","serviceId":"23"}
  126. string str;
  127. str = "";
  128. str = "api_pkg.USERS_GET_PROFILE";
  129. OracleParameter[] parms;
  130. parms = new OracleParameter[]
  131. {
  132. new OracleParameter("v_users", OracleDbType.NVarchar2),
  133. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  134. new OracleParameter("v_usersQuery", OracleDbType.NVarchar2),
  135. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  136. };
  137. parms[0].Value = users;
  138. parms[1].Value = serviceid;
  139. parms[2].Value = uidQuery;
  140. return DataAccess.getDataFromProcedure(str, "", parms);
  141. }
  142. public static DataSet USERS_SEARCHE_PROFILE(string users, string serviceid, string proviceId, string fromAge, string toAge, string rowsOnPage, string seqPage, string isLike, string type, string v_seek)
  143. {
  144. // {"users":"50912345678","serviceId":"30","proviceId":"1","fromAge":"1","toAge":"50","rowsOnPage":"2","seqPage":"1","isLike":"1"}
  145. string str;
  146. str = "";
  147. str = "api_pkg.USERS_SEARCHE_PROFILE";
  148. OracleParameter[] parms;
  149. parms = new OracleParameter[]
  150. {
  151. new OracleParameter("v_users", OracleDbType.NVarchar2),
  152. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  153. new OracleParameter("v_proviceId", OracleDbType.NVarchar2),
  154. new OracleParameter("v_fromAge", OracleDbType.NVarchar2),
  155. new OracleParameter("v_toAge", OracleDbType.NVarchar2),
  156. new OracleParameter("v_rowsOnPay", OracleDbType.NVarchar2),
  157. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  158. new OracleParameter("v_isLike", OracleDbType.NVarchar2),
  159. new OracleParameter("v_type", OracleDbType.NVarchar2),
  160. new OracleParameter("v_seek", OracleDbType.NVarchar2),
  161. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  162. };
  163. parms[0].Value = users;
  164. parms[1].Value = serviceid;
  165. parms[2].Value = proviceId;
  166. parms[3].Value = fromAge;
  167. parms[4].Value = toAge;
  168. parms[5].Value = rowsOnPage;
  169. parms[6].Value = seqPage;
  170. parms[7].Value = isLike;
  171. parms[8].Value = type;
  172. parms[9].Value = v_seek;
  173. return DataAccess.getDataFromProcedure(str, "", parms);
  174. }
  175. public static DataSet USERS_CHAT_GET(string users, string serviceid, string rowsOnPage, string seqPage)
  176. {
  177. string str;
  178. str = "";
  179. str = "api_pkg.USERS_CHAT_GET";
  180. OracleParameter[] parms;
  181. parms = new OracleParameter[]
  182. {
  183. new OracleParameter("v_users", OracleDbType.NVarchar2),
  184. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  185. new OracleParameter("v_rowsOnPay", OracleDbType.NVarchar2),
  186. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  187. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  188. };
  189. parms[0].Value = users;
  190. parms[1].Value = serviceid;
  191. parms[2].Value = rowsOnPage;
  192. parms[3].Value = seqPage;
  193. return DataAccess.getDataFromProcedure(str, "", parms);
  194. }
  195. public static DataSet USERS_CHAT_SEARCH(string users, string serviceid, string rowsOnPage, string seqPage,string keyword)
  196. {
  197. string str;
  198. str = "";
  199. str = "api_pkg.USERS_CHAT_SEARCH";
  200. OracleParameter[] parms;
  201. parms = new OracleParameter[]
  202. {
  203. new OracleParameter("v_users", OracleDbType.NVarchar2),
  204. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  205. new OracleParameter("v_rowsOnPay", OracleDbType.NVarchar2),
  206. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  207. new OracleParameter("v_keyword", OracleDbType.NVarchar2),
  208. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  209. };
  210. parms[0].Value = users;
  211. parms[1].Value = serviceid;
  212. parms[2].Value = rowsOnPage;
  213. parms[3].Value = seqPage;
  214. parms[4].Value = keyword;
  215. return DataAccess.getDataFromProcedure(str, "", parms);
  216. }
  217. public static DataSet USERS_CHAT_DETAIL_GET(string chatId, string rowsOnPage, string seqPage,string users,string serviceId)
  218. {
  219. string str;
  220. str = "";
  221. str = "api_pkg.USERS_CHAT_DETAIL_GET";
  222. OracleParameter[] parms;
  223. parms = new OracleParameter[]
  224. {
  225. new OracleParameter("v_chatId", OracleDbType.NVarchar2),
  226. new OracleParameter("v_rowsOnPay", OracleDbType.NVarchar2),
  227. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  228. new OracleParameter("v_users", OracleDbType.NVarchar2),
  229. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  230. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  231. };
  232. parms[0].Value = chatId;
  233. parms[1].Value = rowsOnPage;
  234. parms[2].Value = seqPage;
  235. parms[3].Value = users;
  236. parms[4].Value = serviceId;
  237. return DataAccess.getDataFromProcedure(str, "", parms);
  238. }
  239. public static DataSet USERS_CHAT_SEND_MSG(string users, string serviceid, string users_receved, string msg, string title,string chatId)
  240. {
  241. string str;
  242. str = "";
  243. str = "api_pkg.USERS_CHAT_SEND_MSG";
  244. OracleParameter[] parms;
  245. parms = new OracleParameter[]
  246. {
  247. new OracleParameter("v_users", OracleDbType.NVarchar2),
  248. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  249. new OracleParameter("v_users_receved", OracleDbType.NVarchar2),
  250. new OracleParameter("v_msg", OracleDbType.NVarchar2),
  251. new OracleParameter("v_title", OracleDbType.Clob),
  252. new OracleParameter("v_chatId", OracleDbType.NVarchar2),
  253. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  254. };
  255. parms[0].Value = users;
  256. parms[1].Value = serviceid;
  257. parms[2].Value = users_receved;
  258. parms[3].Value = msg;
  259. parms[4].Value = title;
  260. parms[5].Value = chatId;
  261. return DataAccess.getDataFromProcedure(str, "", parms);
  262. }
  263. public static DataSet USERS_CHAT_DETAIL_CHECK(string chatDetailId)
  264. {
  265. string str;
  266. str = "";
  267. str = "api_pkg.USERS_CHAT_DETAIL_CHECK";
  268. OracleParameter[] parms;
  269. parms = new OracleParameter[]
  270. {
  271. new OracleParameter("v_chatDetailId", OracleDbType.NVarchar2),
  272. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  273. };
  274. parms[0].Value = chatDetailId;
  275. return DataAccess.getDataFromProcedure(str, "", parms);
  276. }
  277. public static DataSet USERS_CHAT_DEL(string chatId)
  278. {
  279. string str;
  280. str = "";
  281. str = "api_pkg.USERS_CHAT_DEL";
  282. OracleParameter[] parms;
  283. parms = new OracleParameter[]
  284. {
  285. new OracleParameter("v_chatId", OracleDbType.NVarchar2),
  286. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  287. };
  288. parms[0].Value = chatId;
  289. return DataAccess.getDataFromProcedure(str, "", parms);
  290. }
  291. public static DataSet USERS_CHAT_DETAIL_DEL(string chatDetailId)
  292. {
  293. string str;
  294. str = "";
  295. str = "api_pkg.USERS_CHAT_DETAIL_DEL";
  296. OracleParameter[] parms;
  297. parms = new OracleParameter[]
  298. {
  299. new OracleParameter("v_chatDetailId", OracleDbType.NVarchar2),
  300. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  301. };
  302. parms[0].Value = chatDetailId;
  303. return DataAccess.getDataFromProcedure(str, "", parms);
  304. }
  305. public static DataSet USERS_MSG_SEND(string users, string serviceid, string users_receved, string msg_local, string title,string msg_global,string title_global)
  306. {
  307. string str;
  308. str = "";
  309. str = "api_pkg.USERS_MSG_SEND";
  310. OracleParameter[] parms;
  311. parms = new OracleParameter[]
  312. {
  313. new OracleParameter("v_users", OracleDbType.NVarchar2),
  314. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  315. new OracleParameter("v_users_receved", OracleDbType.NVarchar2),
  316. new OracleParameter("v_msg", OracleDbType.Clob),
  317. new OracleParameter("v_title", OracleDbType.NVarchar2),
  318. new OracleParameter("v_msg_global", OracleDbType.Clob),
  319. new OracleParameter("v_title_global", OracleDbType.NVarchar2),
  320. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  321. };
  322. parms[0].Value = users;
  323. parms[1].Value = serviceid;
  324. parms[2].Value = users_receved;
  325. parms[3].Value = msg_local;
  326. parms[4].Value = title;
  327. parms[5].Value = msg_global;
  328. parms[6].Value = title_global;
  329. return DataAccess.getDataFromProcedure(str, "", parms);
  330. }
  331. public static DataSet USERS_MSG_GET(string users, string serviceid, string isSend,string messageId
  332. , string language, string fromDate, string toDate, string rowsOnPage, string seqPage)
  333. {
  334. string str;
  335. str = "";
  336. str = "api_pkg.USERS_MSG_GET";
  337. OracleParameter[] parms;
  338. parms = new OracleParameter[]
  339. {
  340. new OracleParameter("v_users", OracleDbType.NVarchar2),
  341. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  342. new OracleParameter("v_isSend", OracleDbType.NVarchar2),
  343. new OracleParameter("v_top", OracleDbType.NVarchar2),
  344. new OracleParameter("v_msgId", OracleDbType.NVarchar2),
  345. new OracleParameter("v_language", OracleDbType.NVarchar2),
  346. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  347. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  348. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  349. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  350. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  351. };
  352. parms[0].Value = users;
  353. parms[1].Value = serviceid;
  354. parms[2].Value = isSend;
  355. parms[3].Value = messageId;
  356. parms[4].Value = language;
  357. parms[5].Value = fromDate;
  358. parms[6].Value = toDate;
  359. parms[7].Value = rowsOnPage;
  360. parms[8].Value = seqPage;
  361. return DataAccess.getDataFromProcedure(str, "", parms);
  362. }
  363. public static DataSet USERS_MSG_CHECK( string messageId)
  364. {
  365. string str;
  366. str = "";
  367. str = "api_pkg.USERS_MSG_CHECK";
  368. OracleParameter[] parms;
  369. parms = new OracleParameter[]
  370. {
  371. new OracleParameter("v_msgId", OracleDbType.NVarchar2),
  372. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  373. };
  374. parms[0].Value = messageId;
  375. return DataAccess.getDataFromProcedure(str, "", parms);
  376. }
  377. public static DataSet USERS_PIC_ADD(string v_users,string serviceId, string v_url, string v_note)
  378. {
  379. string str;
  380. str = "";
  381. str = "api_pkg.USERS_PIC_ADD";
  382. OracleParameter[] parms;
  383. parms = new OracleParameter[]
  384. {
  385. new OracleParameter("v_users", OracleDbType.NVarchar2),
  386. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  387. new OracleParameter("v_url", OracleDbType.NVarchar2),
  388. new OracleParameter("v_note", OracleDbType.NVarchar2),
  389. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  390. };
  391. parms[0].Value = v_users;
  392. parms[1].Value = serviceId;
  393. parms[2].Value = v_url;
  394. parms[3].Value = v_note;
  395. return DataAccess.getDataFromProcedure(str, "", parms);
  396. }
  397. public static DataSet USERS_PIC_GET(string v_picId, string v_users,string v_serviceId, string v_top)
  398. {
  399. string str;
  400. str = "";
  401. str = "api_pkg.USERS_PIC_GET";
  402. OracleParameter[] parms;
  403. parms = new OracleParameter[]
  404. {
  405. new OracleParameter("v_picId", OracleDbType.NVarchar2),
  406. new OracleParameter("v_users", OracleDbType.NVarchar2),
  407. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  408. new OracleParameter("v_top", OracleDbType.NVarchar2),
  409. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  410. };
  411. parms[0].Value = v_picId;
  412. parms[1].Value = v_users;
  413. parms[2].Value = v_serviceId;
  414. parms[3].Value = v_top;
  415. return DataAccess.getDataFromProcedure(str, "", parms);
  416. }
  417. public static DataSet USERS_PIC_DEL(string v_picId)
  418. {
  419. string str;
  420. str = "";
  421. str = "api_pkg.USERS_PIC_DEL";
  422. OracleParameter[] parms;
  423. parms = new OracleParameter[]
  424. {
  425. new OracleParameter("v_picId", OracleDbType.NVarchar2),
  426. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  427. };
  428. parms[0].Value = v_picId;
  429. return DataAccess.getDataFromProcedure(str, "", parms);
  430. }
  431. public static DataSet USERS_LIKE_UPDATE(string v_users, string serviceId, string v_usersLike, string v_isLike)
  432. {
  433. string str;
  434. str = "";
  435. str = "api_pkg.USERS_LIKE_UPDATE";
  436. OracleParameter[] parms;
  437. parms = new OracleParameter[]
  438. {
  439. new OracleParameter("v_users_send", OracleDbType.NVarchar2),
  440. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  441. new OracleParameter("v_users_receved", OracleDbType.NVarchar2),
  442. new OracleParameter("v_isLike", OracleDbType.NVarchar2),
  443. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  444. };
  445. parms[0].Value = v_users;
  446. parms[1].Value = serviceId;
  447. parms[2].Value = v_usersLike;
  448. parms[3].Value = v_isLike;
  449. return DataAccess.getDataFromProcedure(str, "", parms);
  450. }
  451. public static DataSet USERS_VIEW_UPDATE(string v_users, string serviceId, string users_receved)
  452. {
  453. string str;
  454. str = "";
  455. str = "api_pkg.USERS_VIEW_UPDATE";
  456. OracleParameter[] parms;
  457. parms = new OracleParameter[]
  458. {
  459. new OracleParameter("v_users", OracleDbType.NVarchar2),
  460. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  461. new OracleParameter("v_users_receved", OracleDbType.NVarchar2),
  462. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  463. };
  464. parms[0].Value = v_users;
  465. parms[1].Value = serviceId;
  466. parms[2].Value = users_receved;
  467. return DataAccess.getDataFromProcedure(str, "", parms);
  468. }
  469. public static DataSet USERS_GET_LIKE_PROFILE(string users, string serviceid, string type, string rowsOnPage, string seqPage)
  470. {
  471. // {"users":"50912345678","serviceId":"30","type":"0","rowsOnPage":"2","seqPage":"1"}
  472. string str;
  473. str = "";
  474. str = "api_pkg.USERS_GET_LIKE";
  475. OracleParameter[] parms;
  476. parms = new OracleParameter[]
  477. {
  478. new OracleParameter("v_users", OracleDbType.NVarchar2),
  479. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  480. new OracleParameter("v_type", OracleDbType.NVarchar2),
  481. new OracleParameter("v_rowsOnPay", OracleDbType.NVarchar2),
  482. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  483. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  484. };
  485. parms[0].Value = users;
  486. parms[1].Value = serviceid;
  487. parms[2].Value = type;
  488. parms[3].Value = rowsOnPage;
  489. parms[4].Value = seqPage;
  490. return DataAccess.getDataFromProcedure(str, "", parms);
  491. }
  492. public static DataSet USERS_UPDATE_LANGUAGE(string v_users, string serviceId, string v_language)
  493. {
  494. string str;
  495. str = "";
  496. str = "api_pkg.USERS_UPDATE_LANGUAGE";
  497. OracleParameter[] parms;
  498. parms = new OracleParameter[]
  499. {
  500. new OracleParameter("v_users", OracleDbType.NVarchar2),
  501. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  502. new OracleParameter("v_language", OracleDbType.NVarchar2),
  503. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  504. };
  505. parms[0].Value = v_users;
  506. parms[1].Value = serviceId;
  507. parms[2].Value = v_language;
  508. return DataAccess.getDataFromProcedure(str, "", parms);
  509. }
  510. public static DataSet USERS_GET_PROVICE(string language,string serviceId)
  511. {
  512. // {"language":"0"}
  513. string str;
  514. str = "";
  515. str = "api_pkg.USERS_GET_PROVICE";
  516. OracleParameter[] parms;
  517. parms = new OracleParameter[]
  518. {
  519. new OracleParameter("v_language", OracleDbType.NVarchar2),
  520. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  521. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  522. };
  523. parms[0].Value = language;
  524. parms[1].Value = serviceId;
  525. return DataAccess.getDataFromProcedure(str, "", parms);
  526. }
  527. public static DataSet USERS_GET_TOPIC(string language, string serviceId)
  528. {
  529. // {"language":"0"}
  530. string str;
  531. str = "";
  532. str = "api_pkg.USERS_GET_TOPIC";
  533. OracleParameter[] parms;
  534. parms = new OracleParameter[]
  535. {
  536. new OracleParameter("v_language", OracleDbType.NVarchar2),
  537. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  538. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  539. };
  540. parms[0].Value = language;
  541. parms[1].Value = serviceId;
  542. return DataAccess.getDataFromProcedure(str, "", parms);
  543. }
  544. public static DataSet ADMIN_USERS_INFO(string v_users, string v_pass)
  545. {
  546. // {"msisdn":"50940227941","users":"123","pass":"123","serviceId":"23","type":"DK","channel":"WEB"}
  547. string str;
  548. str = "";
  549. str = "api_pkg.ADMIN_LOGIN";
  550. OracleParameter[] parms;
  551. parms = new OracleParameter[]
  552. {
  553. new OracleParameter("v_user", OracleDbType.NVarchar2),
  554. new OracleParameter("v_pass", OracleDbType.NVarchar2),
  555. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  556. };
  557. parms[0].Value = v_users;
  558. parms[1].Value = v_pass;
  559. return DataAccess.getDataFromProcedure(str, "", parms);
  560. }
  561. public static DataSet ADMIN_USERS_FUNCTION(string role)
  562. {
  563. // {"msisdn":"50940227941","users":"123","pass":"123","serviceId":"23","type":"DK","channel":"WEB"}
  564. string str;
  565. str = "";
  566. str = "api_pkg.ADMIN_GET_ROLE";
  567. OracleParameter[] parms;
  568. parms = new OracleParameter[]
  569. {
  570. new OracleParameter("v_role", OracleDbType.NVarchar2),
  571. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  572. };
  573. parms[0].Value = role;
  574. return DataAccess.getDataFromProcedure(str, "", parms);
  575. }
  576. public static DataSet USERS_GIFT_GET_SUBSERVICECODE(string users, string serviceId, string users_receved, string giftId, string giftType)
  577. {
  578. // {"language":"0"}
  579. string str;
  580. str = "";
  581. str = "api_pkg.USERS_GIFT_GET_SUBSERVICECODE";
  582. OracleParameter[] parms;
  583. parms = new OracleParameter[]
  584. {
  585. new OracleParameter("v_users", OracleDbType.NVarchar2),
  586. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  587. new OracleParameter("v_users_receved", OracleDbType.NVarchar2),
  588. new OracleParameter("v_giftId", OracleDbType.NVarchar2),
  589. new OracleParameter("v_giftType", OracleDbType.NVarchar2),
  590. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  591. };
  592. parms[0].Value = users;
  593. parms[1].Value = serviceId;
  594. parms[2].Value = users_receved;
  595. parms[3].Value = giftId;
  596. parms[4].Value = giftType;
  597. return DataAccess.getDataFromProcedure(str, "", parms);
  598. }
  599. public static DataSet USERS_GIFT_GET(string language, string id, string serviceId)
  600. {
  601. // {"language":"0"}
  602. string str;
  603. str = "";
  604. str = "api_pkg.USERS_GIFT_GET";
  605. OracleParameter[] parms;
  606. parms = new OracleParameter[]
  607. {
  608. new OracleParameter("v_language", OracleDbType.NVarchar2),
  609. new OracleParameter("v_id", OracleDbType.NVarchar2),
  610. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  611. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  612. };
  613. parms[0].Value = language;
  614. parms[1].Value = id;
  615. parms[2].Value = serviceId;
  616. return DataAccess.getDataFromProcedure(str, "", parms);
  617. }
  618. public static DataSet USERS_GIFT_SEND(string users, string serviceid,string users_receved,string giftid)
  619. {
  620. // {"language":"0"}
  621. string str;
  622. str = "";
  623. str = "api_pkg.USERS_GIFT_SEND";
  624. OracleParameter[] parms;
  625. parms = new OracleParameter[]
  626. {
  627. new OracleParameter("v_users", OracleDbType.NVarchar2),
  628. new OracleParameter("v_serviceid", OracleDbType.NVarchar2),
  629. new OracleParameter("v_users_receved", OracleDbType.NVarchar2),
  630. new OracleParameter("v_giftId", OracleDbType.NVarchar2),
  631. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  632. };
  633. parms[0].Value = users;
  634. parms[1].Value = serviceid;
  635. parms[2].Value = users_receved;
  636. parms[3].Value = giftid;
  637. return DataAccess.getDataFromProcedure(str, "", parms);
  638. }
  639. //{"giftSendId":"1","users":"50912345678","serviceId":"30","rowsOnPage":"2","seqPage":"1","type":"0"}
  640. public static DataSet USERS_GIFT_GET_BUY_USERS( string users, string serviceid, string rowsOnPage, string seqPage, string type)
  641. {
  642. // {"language":"0"}
  643. string str;
  644. str = "";
  645. str = "api_pkg.USERS_GIFT_GET_BUY_USERS";
  646. OracleParameter[] parms;
  647. parms = new OracleParameter[]
  648. {
  649. new OracleParameter("v_users", OracleDbType.NVarchar2),
  650. new OracleParameter("v_serviceid", OracleDbType.NVarchar2),
  651. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  652. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  653. new OracleParameter("v_type", OracleDbType.NVarchar2),
  654. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  655. };
  656. parms[0].Value = users;
  657. parms[1].Value = serviceid;
  658. parms[2].Value = rowsOnPage;
  659. parms[3].Value = seqPage;
  660. parms[4].Value = type;
  661. return DataAccess.getDataFromProcedure(str, "", parms);
  662. }
  663. public static DataSet USERS_GIFT_GET_BUY_TOTAL_USERS(string users, string serviceid)
  664. {
  665. // {"language":"0"}
  666. string str;
  667. str = "";
  668. str = "api_pkg.USERS_GIFT_GET_BUY_TOTAL_USERS";
  669. OracleParameter[] parms;
  670. parms = new OracleParameter[]
  671. {
  672. new OracleParameter("v_users", OracleDbType.NVarchar2),
  673. new OracleParameter("v_serviceid", OracleDbType.NVarchar2),
  674. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  675. };
  676. parms[0].Value = users;
  677. parms[1].Value = serviceid;
  678. return DataAccess.getDataFromProcedure(str, "", parms);
  679. }
  680. public static DataSet USERS_GET_INTERESTS(string language)
  681. {
  682. // {"language":"0"}
  683. string str;
  684. str = "";
  685. str = "api_pkg.USERS_GET_INTERESTS";
  686. OracleParameter[] parms;
  687. parms = new OracleParameter[]
  688. {
  689. new OracleParameter("v_language", OracleDbType.NVarchar2),
  690. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  691. };
  692. parms[0].Value = language;
  693. return DataAccess.getDataFromProcedure(str, "", parms);
  694. }
  695. public static DataSet USERS_GET_INTERESTS_BY_USER(string language,string users,string serviceId)
  696. {
  697. // {"language":"0"}
  698. string str;
  699. str = "";
  700. str = "api_pkg.USERS_GET_INTERESTS_BY_USER";
  701. OracleParameter[] parms;
  702. parms = new OracleParameter[]
  703. {
  704. new OracleParameter("v_users", OracleDbType.NVarchar2),
  705. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  706. new OracleParameter("v_language", OracleDbType.NVarchar2),
  707. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  708. };
  709. parms[0].Value = users;
  710. parms[1].Value = serviceId;
  711. parms[2].Value = language;
  712. return DataAccess.getDataFromProcedure(str, "", parms);
  713. }
  714. public static DataSet USERS_INTERESTS_UPDATE( string users, string serviceId,string listInterests)
  715. {
  716. // {"language":"0"}
  717. string str;
  718. str = "";
  719. str = "api_pkg.USERS_INTERESTS_UPDATE";
  720. OracleParameter[] parms;
  721. parms = new OracleParameter[]
  722. {
  723. new OracleParameter("v_users", OracleDbType.NVarchar2),
  724. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  725. new OracleParameter("v_listInterests", OracleDbType.NVarchar2),
  726. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  727. };
  728. parms[0].Value = users;
  729. parms[1].Value = serviceId;
  730. parms[2].Value = listInterests;
  731. return DataAccess.getDataFromProcedure(str, "", parms);
  732. }
  733. public static DataSet USERS_UPDATE_COIN(string usersId, string coin, string type, string trandCode)
  734. {
  735. // {"users":"123","serviceId":"23"}
  736. string str;
  737. str = "";
  738. str = "api_pkg.USERS_UPDATE_COIN";
  739. OracleParameter[] parms;
  740. parms = new OracleParameter[]
  741. {
  742. new OracleParameter("v_usersId", OracleDbType.NVarchar2),
  743. new OracleParameter("v_coin", OracleDbType.NVarchar2),
  744. new OracleParameter("v_type", OracleDbType.NVarchar2),
  745. new OracleParameter("v_tranCode", OracleDbType.NVarchar2),
  746. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  747. };
  748. parms[0].Value = usersId;
  749. parms[1].Value = coin;
  750. parms[2].Value = type;
  751. parms[3].Value = trandCode;
  752. return DataAccess.getDataFromProcedure(str, "", parms);
  753. }
  754. public static DataSet ChangeCoinToMoney(string usersId, string serviceId, string money)
  755. {
  756. string str;
  757. str = "";
  758. str = "api_pkg.USERS_CHANGE_COIN_MONEY";
  759. OracleParameter[] parms;
  760. parms = new OracleParameter[]
  761. {
  762. new OracleParameter("v_users", OracleDbType.NVarchar2),
  763. new OracleParameter("v_serviceid", OracleDbType.NVarchar2),
  764. new OracleParameter("v_money", OracleDbType.NVarchar2),
  765. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  766. };
  767. parms[0].Value = usersId;
  768. parms[1].Value = serviceId;
  769. parms[2].Value = money;
  770. return DataAccess.getDataFromProcedure(str, "", parms);
  771. }
  772. public static void InsertBulkBlackData(string sSQL, List<List<string>> dataColumn)
  773. {
  774. OracleConnection connection = null;
  775. try
  776. {
  777. connection = DataAccess.getPoolingConnection();
  778. connection.Open();
  779. OracleTransaction transaction;
  780. // Start a local transaction
  781. transaction = connection.BeginTransaction(IsolationLevel.ReadCommitted);
  782. using (var command = connection.CreateCommand())
  783. {
  784. command.CommandText = sSQL;
  785. command.CommandType = CommandType.StoredProcedure;
  786. command.ArrayBindCount = dataColumn[0].Count;
  787. command.Transaction = transaction;
  788. var v_msisdn = dataColumn[0].ToArray();
  789. OracleParameter param0 = new OracleParameter("v_msisdn", OracleDbType.NVarchar2, ParameterDirection.Input);
  790. param0.Value = v_msisdn;
  791. param0.Size = v_msisdn.Length;
  792. command.Parameters.Add(param0);
  793. var v_type = dataColumn[1].ToArray();
  794. OracleParameter param1 = new OracleParameter("v_isBlaclist", OracleDbType.NVarchar2, ParameterDirection.Input);
  795. param1.Value = v_type;
  796. param1.Size = v_type.Length;
  797. command.Parameters.Add(param1);
  798. var v_user = dataColumn[2].ToArray();
  799. OracleParameter param2 = new OracleParameter("v_userName", OracleDbType.NVarchar2, ParameterDirection.Input);
  800. param2.Value = v_user;
  801. param2.Size = v_user.Length;
  802. command.Parameters.Add(param2);
  803. command.ExecuteNonQuery();
  804. transaction.Commit();
  805. }
  806. }
  807. catch (OracleException ex)
  808. {
  809. Console.WriteLine(ex.ToString());
  810. throw;
  811. }
  812. finally
  813. {
  814. connection.Close();
  815. }
  816. }
  817. public static DataSet GET_BLACKLIST(string msisdn)
  818. {
  819. string str;
  820. str = "";
  821. //str = "report_pkg.GET_USER_INFO";
  822. str = "MPS_PKG.BLACKLIST_GET";
  823. OracleParameter[] parms;
  824. parms = new OracleParameter[]
  825. {
  826. new OracleParameter("v_msisdn", OracleDbType.NVarchar2),
  827. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  828. };
  829. parms[0].Value = msisdn;
  830. return DataAccess.getDataFromProcedure(str, "", parms);
  831. }
  832. public static DataSet TKupdateCheckPin(string usersname, string ip, string errCode, string message, string channel,string type)
  833. {
  834. string str;
  835. str = "";
  836. str = "api_pkg.tokenUpdate";
  837. OracleParameter[] parms;
  838. parms = new OracleParameter[]
  839. {
  840. new OracleParameter("v_usersname", OracleDbType.NVarchar2),
  841. new OracleParameter("v_ip", OracleDbType.NVarchar2),
  842. new OracleParameter("v_errCode", OracleDbType.NVarchar2),
  843. new OracleParameter("v_message", OracleDbType.NVarchar2),
  844. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  845. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  846. };
  847. parms[0].Value = usersname;
  848. parms[1].Value = ip;
  849. parms[2].Value = errCode;
  850. parms[3].Value = message;
  851. parms[4].Value = channel;
  852. parms[5].Value = type;
  853. return DataAccess.getDataFromProcedure(str, "", parms);
  854. }
  855. public static DataSet TKcheckSpamCheckPin(string usersname, string ip, string channel,string type)
  856. {
  857. string str;
  858. str = "";
  859. str = "api_pkg.tokenCheckSpamCheckPin";
  860. OracleParameter[] parms;
  861. parms = new OracleParameter[]
  862. {
  863. new OracleParameter("v_usersname", OracleDbType.NVarchar2),
  864. new OracleParameter("v_ip", OracleDbType.NVarchar2),
  865. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  866. new OracleParameter("v_type", OracleDbType.NVarchar2),
  867. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  868. };
  869. parms[0].Value = usersname;
  870. parms[1].Value = ip;
  871. parms[2].Value = channel;
  872. parms[3].Value = type;
  873. return DataAccess.getDataFromProcedure(str, "", parms);
  874. }
  875. public static DataSet TKcheckToken(string ip, string channel, string token)
  876. {
  877. string str;
  878. str = "";
  879. str = "api_pkg.tokenCheck";
  880. OracleParameter[] parms;
  881. parms = new OracleParameter[]
  882. {
  883. new OracleParameter("v_ip", OracleDbType.NVarchar2),
  884. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  885. new OracleParameter("v_token", OracleDbType.NVarchar2),
  886. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  887. };
  888. parms[0].Value = ip;
  889. parms[1].Value = channel;
  890. parms[2].Value = token;
  891. return DataAccess.getDataFromProcedure(str, "", parms);
  892. }
  893. public static DataSet blackGettList(string msisdn, string type, string svid, string v_users)
  894. {
  895. string str;
  896. str = "";
  897. str = "BALANCE_PKG.BLACK_GET";
  898. OracleParameter[] parms;
  899. parms = new OracleParameter[]
  900. {
  901. new OracleParameter("v_msisdn", OracleDbType.NVarchar2),
  902. new OracleParameter("v_type", OracleDbType.NVarchar2),
  903. new OracleParameter("v_sv_id", OracleDbType.NVarchar2),
  904. new OracleParameter("v_users", OracleDbType.NVarchar2),
  905. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  906. };
  907. parms[0].Value = msisdn;
  908. parms[1].Value = type;
  909. parms[2].Value = svid;
  910. parms[3].Value = v_users;
  911. return DataAccess.getDataFromProcedure(str, "", parms);
  912. }
  913. public static void InsertBulkBlackList(string sSQL, List<List<string>> dataColumn)
  914. {
  915. OracleConnection connection = null;
  916. try
  917. {
  918. connection = DataAccess.getPoolingConnection();
  919. connection.Open();
  920. OracleTransaction transaction;
  921. // Start a local transaction
  922. transaction = connection.BeginTransaction(IsolationLevel.ReadCommitted);
  923. using (var command = connection.CreateCommand())
  924. {
  925. command.CommandText = sSQL;
  926. command.CommandType = CommandType.StoredProcedure;
  927. command.ArrayBindCount = dataColumn[0].Count;
  928. command.Transaction = transaction;
  929. var v_msisdn = dataColumn[0].ToArray();
  930. OracleParameter param0 = new OracleParameter("v_msisdn", OracleDbType.NVarchar2, ParameterDirection.Input);
  931. param0.Value = v_msisdn;
  932. param0.Size = v_msisdn.Length;
  933. command.Parameters.Add(param0);
  934. var v_type = dataColumn[1].ToArray();
  935. OracleParameter param1 = new OracleParameter("v_type", OracleDbType.NVarchar2, ParameterDirection.Input);
  936. param1.Value = v_type;
  937. param1.Size = v_type.Length;
  938. command.Parameters.Add(param1);
  939. var v_sv_id = dataColumn[2].ToArray();
  940. OracleParameter param2 = new OracleParameter("v_sv_id", OracleDbType.NVarchar2, ParameterDirection.Input);
  941. param2.Value = v_sv_id;
  942. param2.Size = v_sv_id.Length;
  943. command.Parameters.Add(param2);
  944. var v_action = dataColumn[3].ToArray();
  945. OracleParameter param3 = new OracleParameter("v_action", OracleDbType.NVarchar2, ParameterDirection.Input);
  946. param3.Value = v_action;
  947. param3.Size = v_action.Length;
  948. command.Parameters.Add(param3);
  949. var v_users = dataColumn[4].ToArray();
  950. OracleParameter param4 = new OracleParameter("v_users", OracleDbType.NVarchar2, ParameterDirection.Input);
  951. param4.Value = v_users;
  952. param4.Size = v_users.Length;
  953. command.Parameters.Add(param4);
  954. command.ExecuteNonQuery();
  955. transaction.Commit();
  956. }
  957. }
  958. catch (OracleException ex)
  959. {
  960. Console.WriteLine(ex.ToString());
  961. throw;
  962. }
  963. finally
  964. {
  965. connection.Close();
  966. }
  967. }
  968. }
  969. }