lotoCmsDataAccess.cs 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916
  1. using Oracle.ManagedDataAccess.Client;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Data;
  5. using System.Linq;
  6. using System.Web;
  7. namespace ResfullApi.Models.bet
  8. {
  9. public class balanceDataAccess
  10. {
  11. public balanceDataAccess()
  12. {
  13. }
  14. public static DataSet getListTerm(string v_users, string v_gameId, string v_serviceId, string v_channel, string v_language
  15. , string v_fromDate, string v_toDate, string v_status, string v_rowsOnPage,string v_seqPage,string v_id)
  16. {
  17. string str;
  18. str = "";
  19. str = "LOTO_CMS_PKG.get_list_term";
  20. OracleParameter[] parms;
  21. parms = new OracleParameter[]
  22. {
  23. new OracleParameter("v_users", OracleDbType.NVarchar2),
  24. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  25. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  26. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  27. new OracleParameter("v_language", OracleDbType.NVarchar2),
  28. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  29. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  30. new OracleParameter("v_status", OracleDbType.NVarchar2),
  31. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  32. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  33. new OracleParameter("v_id", OracleDbType.NVarchar2),
  34. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  35. };
  36. parms[0].Value = v_users;
  37. parms[1].Value = v_gameId;
  38. parms[2].Value = v_serviceId;
  39. parms[3].Value = v_channel;
  40. parms[4].Value = v_language;
  41. parms[5].Value = v_fromDate;
  42. parms[6].Value = v_toDate;
  43. parms[7].Value = v_status;
  44. parms[8].Value = v_rowsOnPage;
  45. parms[9].Value = v_seqPage;
  46. parms[10].Value = v_id;
  47. return DataAccess.getDataFromProcedure(str, "", parms);
  48. }
  49. public static DataSet lkpw_result_update(string v_randomId, string v_users, string v_result, string v_status, string v_note)
  50. {
  51. string str;
  52. str = "";
  53. str = "LOTO_CMS_PKG.lkpw_result_update";
  54. OracleParameter[] parms;
  55. parms = new OracleParameter[]
  56. {
  57. new OracleParameter("v_randomId", OracleDbType.NVarchar2),
  58. new OracleParameter("v_users", OracleDbType.NVarchar2),
  59. new OracleParameter("v_result", OracleDbType.NVarchar2),
  60. new OracleParameter("v_status", OracleDbType.NVarchar2),
  61. new OracleParameter("v_note", OracleDbType.NVarchar2),
  62. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  63. };
  64. parms[0].Value = v_randomId;
  65. parms[1].Value = v_users;
  66. parms[2].Value = v_result;
  67. parms[3].Value = v_status;
  68. parms[4].Value = v_note;
  69. return DataAccess.getDataFromProcedure(str, "", parms);
  70. }
  71. public static DataSet lkpw_result_get_his(string v_randomId, string v_users)
  72. {
  73. string str;
  74. str = "";
  75. str = "LOTO_CMS_PKG.lkpw_result_get_his";
  76. OracleParameter[] parms;
  77. parms = new OracleParameter[]
  78. {
  79. new OracleParameter("v_randomId", OracleDbType.NVarchar2),
  80. new OracleParameter("v_users", OracleDbType.NVarchar2),
  81. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  82. };
  83. parms[0].Value = v_randomId;
  84. parms[1].Value = v_users;
  85. return DataAccess.getDataFromProcedure(str, "", parms);
  86. }
  87. public static DataSet report_get_total_trafic(string v_gameId, string v_fromDate,string v_toDate,string totalRow,string seqRow)
  88. {
  89. string str;
  90. str = "";
  91. str = "LOTO_CMS_PKG.report_get_total_by_day";
  92. OracleParameter[] parms;
  93. parms = new OracleParameter[]
  94. {
  95. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  96. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  97. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  98. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  99. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  100. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  101. };
  102. parms[0].Value = v_gameId;
  103. parms[1].Value = v_fromDate;
  104. parms[2].Value = v_toDate;
  105. parms[3].Value = totalRow;
  106. parms[4].Value = seqRow;
  107. return DataAccess.getDataFromProcedure(str, "", parms);
  108. }
  109. public static DataSet cmsSearMsisdn(string v_subId, string v_msisdn)
  110. {
  111. string str;
  112. str = "";
  113. str = "LOTO_CMS_PKG.report_lock_stats_get";
  114. OracleParameter[] parms;
  115. parms = new OracleParameter[]
  116. {
  117. new OracleParameter("v_subId", OracleDbType.NVarchar2),
  118. new OracleParameter("v_msisdn", OracleDbType.NVarchar2),
  119. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  120. };
  121. parms[0].Value = v_subId;
  122. parms[1].Value = v_msisdn;
  123. return DataAccess.getDataFromProcedure(str, "", parms);
  124. }
  125. public static DataSet cmsLockByMsisdn(string v_subId, string v_msisdn,string users,string isLock,string note)
  126. {
  127. string str;
  128. str = "";
  129. str = "LOTO_CMS_PKG.report_lock_by_msisdn";
  130. OracleParameter[] parms;
  131. parms = new OracleParameter[]
  132. {
  133. new OracleParameter("v_subId", OracleDbType.NVarchar2),
  134. new OracleParameter("v_msisdn", OracleDbType.NVarchar2),
  135. new OracleParameter("v_users", OracleDbType.NVarchar2),
  136. new OracleParameter("v_isLock", OracleDbType.NVarchar2),
  137. new OracleParameter("v_note", OracleDbType.NVarchar2),
  138. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  139. };
  140. parms[0].Value = v_subId;
  141. parms[1].Value = v_msisdn;
  142. parms[2].Value = users;
  143. parms[3].Value = isLock;
  144. parms[4].Value = note;
  145. return DataAccess.getDataFromProcedure(str, "", parms);
  146. }
  147. public static DataSet cmsGetInfoTicket(string gameId, string msisdn, string tungay,string denngay,string v_rowsOnPage,string v_seqPage)
  148. {
  149. string str;
  150. str = "";
  151. str = "LOTO_CMS_PKG.report_ticket_get_info";
  152. OracleParameter[] parms;
  153. parms = new OracleParameter[]
  154. {
  155. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  156. new OracleParameter("v_msisdn", OracleDbType.NVarchar2),
  157. new OracleParameter("v_tungay", OracleDbType.NVarchar2),
  158. new OracleParameter("v_denngay", OracleDbType.NVarchar2),
  159. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  160. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  161. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  162. };
  163. parms[0].Value = gameId;
  164. parms[1].Value = msisdn;
  165. parms[2].Value = tungay;
  166. parms[3].Value = denngay;
  167. parms[4].Value = v_rowsOnPage;
  168. parms[5].Value = v_seqPage;
  169. return DataAccess.getDataFromProcedure(str, "", parms);
  170. }
  171. public static DataSet cmsGetTicketWin(string gameId, string msisdn,string subId, string tungay, string denngay, string v_rowsOnPage, string v_seqPage)
  172. {
  173. string str;
  174. str = "";
  175. str = "LOTO_CMS_PKG.report_ticket_get_win";
  176. OracleParameter[] parms;
  177. parms = new OracleParameter[]
  178. {
  179. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  180. new OracleParameter("v_msisdn", OracleDbType.NVarchar2),
  181. new OracleParameter("v_subId", OracleDbType.NVarchar2),
  182. new OracleParameter("v_tungay", OracleDbType.NVarchar2),
  183. new OracleParameter("v_denngay", OracleDbType.NVarchar2),
  184. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  185. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  186. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  187. };
  188. parms[0].Value = gameId;
  189. parms[1].Value = msisdn;
  190. parms[2].Value = subId;
  191. parms[3].Value = tungay;
  192. parms[4].Value = denngay;
  193. parms[5].Value = v_rowsOnPage;
  194. parms[6].Value = v_seqPage;
  195. return DataAccess.getDataFromProcedure(str, "", parms);
  196. }
  197. public static DataSet cmsGetTraficTotal(string gameId, string tungay, string denngay)
  198. {
  199. string str;
  200. str = "";
  201. str = "LOTO_CMS_PKG.report_get_trafic_total";
  202. OracleParameter[] parms;
  203. parms = new OracleParameter[]
  204. {
  205. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  206. new OracleParameter("v_tungay", OracleDbType.NVarchar2),
  207. new OracleParameter("v_denngay", OracleDbType.NVarchar2),
  208. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  209. };
  210. parms[0].Value = gameId;
  211. parms[1].Value = tungay;
  212. parms[2].Value = denngay;
  213. return DataAccess.getDataFromProcedure(str, "", parms);
  214. }
  215. public static DataSet cmsGetTop(string gameId, string tungay, string denngay,string type, string row, string v_rowsOnPage, string v_seqPage)
  216. {
  217. string str;
  218. str = "";
  219. str = "LOTO_CMS_PKG.report_get_top";
  220. OracleParameter[] parms;
  221. parms = new OracleParameter[]
  222. {
  223. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  224. new OracleParameter("v_tungay", OracleDbType.NVarchar2),
  225. new OracleParameter("v_denngay", OracleDbType.NVarchar2),
  226. new OracleParameter("v_type", OracleDbType.NVarchar2),
  227. new OracleParameter("v_total_row", OracleDbType.NVarchar2),
  228. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  229. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  230. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  231. };
  232. parms[0].Value = gameId;
  233. parms[1].Value = tungay;
  234. parms[2].Value = denngay;
  235. parms[3].Value = type;
  236. parms[4].Value = row;
  237. parms[5].Value = v_rowsOnPage;
  238. parms[6].Value = v_seqPage;
  239. return DataAccess.getDataFromProcedure(str, "", parms);
  240. }
  241. public static DataSet export_created(string v_users, string v_gameId, string v_name, string v_fromDate, string v_toDate)
  242. {
  243. string str;
  244. str = "";
  245. str = "LOTO_CMS_PKG.export_created";
  246. OracleParameter[] parms;
  247. parms = new OracleParameter[]
  248. {
  249. new OracleParameter("v_users", OracleDbType.NVarchar2),
  250. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  251. new OracleParameter("v_name", OracleDbType.NVarchar2),
  252. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  253. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  254. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  255. };
  256. parms[0].Value = v_users;
  257. parms[1].Value = v_gameId;
  258. parms[2].Value = v_name;
  259. parms[3].Value = v_fromDate;
  260. parms[4].Value = v_toDate;
  261. return DataAccess.getDataFromProcedure(str, "", parms);
  262. }
  263. public static DataSet export_action(string v_users, string v_export_id, string v_type, string v_note)
  264. {
  265. string str;
  266. str = "";
  267. str = "LOTO_CMS_PKG.export_action";
  268. OracleParameter[] parms;
  269. parms = new OracleParameter[]
  270. {
  271. new OracleParameter("v_users", OracleDbType.NVarchar2),
  272. new OracleParameter("v_export_id", OracleDbType.NVarchar2),
  273. new OracleParameter("v_type", OracleDbType.NVarchar2),
  274. new OracleParameter("v_note", OracleDbType.NVarchar2),
  275. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  276. };
  277. parms[0].Value = v_users;
  278. parms[1].Value = v_export_id;
  279. parms[2].Value = v_type;
  280. parms[3].Value = v_note;
  281. return DataAccess.getDataFromProcedure(str, "", parms);
  282. }
  283. public static DataSet export_winner_get_data(string v_users, string v_gameId, string v_fromDate, string v_toDate, string v_payOnline
  284. , string v_rowsOnPage, string v_seqPage,string isPayType)
  285. {
  286. string str;
  287. str = "";
  288. str = "LOTO_CMS_PKG.export_winner_get_data";
  289. OracleParameter[] parms;
  290. parms = new OracleParameter[]
  291. {
  292. new OracleParameter("v_users", OracleDbType.NVarchar2),
  293. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  294. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  295. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  296. new OracleParameter("v_payOnline", OracleDbType.NVarchar2),
  297. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  298. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  299. new OracleParameter("v_payType", OracleDbType.NVarchar2),
  300. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  301. };
  302. parms[0].Value = v_users;
  303. parms[1].Value = v_gameId;
  304. parms[2].Value = v_fromDate;
  305. parms[3].Value = v_toDate;
  306. parms[4].Value = v_payOnline;
  307. parms[5].Value = v_rowsOnPage;
  308. parms[6].Value = v_seqPage;
  309. parms[7].Value = isPayType;
  310. return DataAccess.getDataFromProcedure(str, "", parms);
  311. }
  312. public static DataSet export_winner_get_data_byId(string v_users, string v_export_id, string v_type
  313. , string v_rowsOnPage, string v_seqPage)
  314. {
  315. string str;
  316. str = "";
  317. str = "LOTO_CMS_PKG.export_winner_get_data_byId";
  318. OracleParameter[] parms;
  319. parms = new OracleParameter[]
  320. {
  321. new OracleParameter("v_users", OracleDbType.NVarchar2),
  322. new OracleParameter("v_export_id", OracleDbType.NVarchar2),
  323. new OracleParameter("v_type", OracleDbType.NVarchar2),
  324. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  325. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  326. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  327. };
  328. parms[0].Value = v_users;
  329. parms[1].Value = v_export_id;
  330. parms[2].Value = v_type;
  331. parms[3].Value = v_rowsOnPage;
  332. parms[4].Value = v_seqPage;
  333. return DataAccess.getDataFromProcedure(str, "", parms);
  334. }
  335. public static DataSet export_get_his(string v_export_id, string v_users)
  336. {
  337. string str;
  338. str = "";
  339. str = "LOTO_CMS_PKG.export_get_his";
  340. OracleParameter[] parms;
  341. parms = new OracleParameter[]
  342. {
  343. new OracleParameter("v_export_id", OracleDbType.NVarchar2),
  344. new OracleParameter("v_users", OracleDbType.NVarchar2),
  345. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  346. };
  347. parms[0].Value = v_export_id;
  348. parms[1].Value = v_users;
  349. return DataAccess.getDataFromProcedure(str, "", parms);
  350. }
  351. public static DataSet export_get_list( string v_users, string v_gameId,string v_fromDate,string v_toDate, string v_rowsOnPage, string v_seqPage,string v_status,string exportId)
  352. {
  353. string str;
  354. str = "";
  355. str = "LOTO_CMS_PKG.export_get_list";
  356. OracleParameter[] parms;
  357. parms = new OracleParameter[]
  358. {
  359. new OracleParameter("v_users", OracleDbType.NVarchar2),
  360. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  361. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  362. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  363. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  364. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  365. new OracleParameter("v_status", OracleDbType.NVarchar2),
  366. new OracleParameter("v_exportId", OracleDbType.NVarchar2),
  367. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  368. };
  369. parms[0].Value = v_users;
  370. parms[1].Value = v_gameId;
  371. parms[2].Value = v_fromDate;
  372. parms[3].Value = v_toDate;
  373. parms[4].Value = v_rowsOnPage;
  374. parms[5].Value = v_seqPage;
  375. parms[6].Value = v_status;
  376. parms[7].Value = exportId;
  377. return DataAccess.getDataFromProcedure(str, "", parms);
  378. }
  379. public static DataSet blackList_get_list(string v_users,string v_msisdn, string v_fromDate,string v_toDate,string v_rowsOnPage,string v_seqPage)
  380. {
  381. string str;
  382. str = "";
  383. str = "LOTO_CMS_PKG.blacklist_get_data";
  384. OracleParameter[] parms;
  385. parms = new OracleParameter[]
  386. {
  387. new OracleParameter("v_users", OracleDbType.NVarchar2),
  388. new OracleParameter("v_msisdn", OracleDbType.NVarchar2),
  389. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  390. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  391. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  392. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  393. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  394. };
  395. parms[0].Value = v_users;
  396. parms[1].Value = v_msisdn;
  397. parms[2].Value = v_fromDate;
  398. parms[3].Value = v_toDate;
  399. parms[4].Value = v_rowsOnPage;
  400. parms[5].Value = v_seqPage;
  401. return DataAccess.getDataFromProcedure(str, "", parms);
  402. }
  403. public static DataSet param_get_list(string channel, string codeGroup, string code)
  404. {
  405. string str;
  406. str = "";
  407. str = "LOTO_CMS_PKG.param_get_list";
  408. OracleParameter[] parms;
  409. parms = new OracleParameter[]
  410. {
  411. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  412. new OracleParameter("v_pram_group_code", OracleDbType.NVarchar2),
  413. new OracleParameter("v_pram_code", OracleDbType.NVarchar2),
  414. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  415. };
  416. parms[0].Value = channel;
  417. parms[1].Value = codeGroup;
  418. parms[2].Value = code;
  419. return DataAccess.getDataFromProcedure(str, "", parms);
  420. }
  421. public static DataSet param_update(string id, string values, string note,string ds0, string ds1, string ds2, string ds3, string ds4, string ds5)
  422. {
  423. string str;
  424. str = "";
  425. str = "LOTO_CMS_PKG.param_update";
  426. OracleParameter[] parms;
  427. parms = new OracleParameter[]
  428. {
  429. new OracleParameter("v_id", OracleDbType.NVarchar2),
  430. new OracleParameter("v_values", OracleDbType.NVarchar2),
  431. new OracleParameter("v_note", OracleDbType.NVarchar2),
  432. new OracleParameter("v_ds0", OracleDbType.NVarchar2),
  433. new OracleParameter("v_ds1", OracleDbType.NVarchar2),
  434. new OracleParameter("v_ds2", OracleDbType.NVarchar2),
  435. new OracleParameter("v_ds3", OracleDbType.NVarchar2),
  436. new OracleParameter("v_ds4", OracleDbType.NVarchar2),
  437. new OracleParameter("v_ds5", OracleDbType.NVarchar2),
  438. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  439. };
  440. parms[0].Value = id;
  441. parms[1].Value = values;
  442. parms[2].Value = note;
  443. parms[3].Value = ds0;
  444. parms[4].Value = ds1;
  445. parms[5].Value = ds2;
  446. parms[6].Value = ds3;
  447. parms[7].Value = ds4;
  448. parms[8].Value = ds5;
  449. return DataAccess.getDataFromProcedure(str, "", parms);
  450. }
  451. public static DataSet cmsDoanhThuTongHop (string channel, string serviceId, string gameId, string gamefromDate, string toDate)
  452. {
  453. string str;
  454. str = "";
  455. str = "LOTO_CMS_PKG.baocao_doanhthu_tonghop";
  456. OracleParameter[] parms;
  457. parms = new OracleParameter[]
  458. {
  459. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  460. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  461. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  462. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  463. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  464. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  465. };
  466. parms[0].Value = channel;
  467. parms[1].Value = serviceId;
  468. parms[2].Value = gameId;
  469. parms[3].Value = gamefromDate;
  470. parms[4].Value = toDate;
  471. return DataAccess.getDataFromProcedure(str, "", parms);
  472. }
  473. public static DataSet cmsDoanhThuChiTiet(string channel, string serviceId, string gameId, string gamefromDate, string toDate)
  474. {
  475. string str;
  476. str = "";
  477. str = "LOTO_CMS_PKG.baocao_doanhthu_chitiet";
  478. OracleParameter[] parms;
  479. parms = new OracleParameter[]
  480. {
  481. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  482. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  483. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  484. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  485. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  486. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  487. };
  488. parms[0].Value = channel;
  489. parms[1].Value = serviceId;
  490. parms[2].Value = gameId;
  491. parms[3].Value = gamefromDate;
  492. parms[4].Value = toDate;
  493. return DataAccess.getDataFromProcedure(str, "", parms);
  494. }
  495. public static DataSet cmsTraThuongTongHop(string channel, string serviceId, string gameId, string gamefromDate, string toDate)
  496. {
  497. string str;
  498. str = "";
  499. str = "LOTO_CMS_PKG.baocao_trathuong_tonghop";
  500. OracleParameter[] parms;
  501. parms = new OracleParameter[]
  502. {
  503. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  504. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  505. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  506. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  507. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  508. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  509. };
  510. parms[0].Value = channel;
  511. parms[1].Value = serviceId;
  512. parms[2].Value = gameId;
  513. parms[3].Value = gamefromDate;
  514. parms[4].Value = toDate;
  515. return DataAccess.getDataFromProcedure(str, "", parms);
  516. }
  517. public static DataSet cmsTraThuongChiTiet(string channel, string serviceId, string gameId, string gamefromDate, string toDate)
  518. {
  519. string str;
  520. str = "";
  521. str = "LOTO_CMS_PKG.baocao_trathuong_chitiet";
  522. OracleParameter[] parms;
  523. parms = new OracleParameter[]
  524. {
  525. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  526. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  527. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  528. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  529. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  530. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  531. };
  532. parms[0].Value = channel;
  533. parms[1].Value = serviceId;
  534. parms[2].Value = gameId;
  535. parms[3].Value = gamefromDate;
  536. parms[4].Value = toDate;
  537. return DataAccess.getDataFromProcedure(str, "", parms);
  538. }
  539. public static DataSet cmsTongHopTheoKyQuay(string channel, string serviceId, string gameId, string gamefromDate, string toDate)
  540. {
  541. string str;
  542. str = "";
  543. str = "LOTO_CMS_PKG.baocao_tonghop_kyquay";
  544. OracleParameter[] parms;
  545. parms = new OracleParameter[]
  546. {
  547. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  548. new OracleParameter("v_serviceId", OracleDbType.NVarchar2),
  549. new OracleParameter("v_gameId", OracleDbType.NVarchar2),
  550. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  551. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  552. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  553. };
  554. parms[0].Value = channel;
  555. parms[1].Value = serviceId;
  556. parms[2].Value = gameId;
  557. parms[3].Value = gamefromDate;
  558. parms[4].Value = toDate;
  559. return DataAccess.getDataFromProcedure(str, "", parms);
  560. }
  561. public static void InsertBulkExport(string sSQL, List<List<string>> dataColumn)
  562. {
  563. OracleConnection connection = null;
  564. try
  565. {
  566. connection =DataAccess.getPoolingConnection();
  567. connection.Open();
  568. OracleTransaction transaction;
  569. // Start a local transaction
  570. transaction = connection.BeginTransaction(IsolationLevel.ReadCommitted);
  571. using (var command = connection.CreateCommand())
  572. {
  573. command.CommandText = sSQL;
  574. command.CommandType = CommandType.StoredProcedure;
  575. command.ArrayBindCount = dataColumn[0].Count;
  576. command.Transaction = transaction;
  577. var v_export_id = dataColumn[0].ToArray();
  578. OracleParameter param0 = new OracleParameter("v_export_id", OracleDbType.NVarchar2, ParameterDirection.Input);
  579. param0.Value = v_export_id;
  580. param0.Size = v_export_id.Length;
  581. command.Parameters.Add(param0);
  582. var v_winner_id = dataColumn[1].ToArray();
  583. OracleParameter param1 = new OracleParameter("v_winner_id", OracleDbType.NVarchar2, ParameterDirection.Input);
  584. param1.Value = v_winner_id;
  585. param1.Size = v_winner_id.Length;
  586. command.Parameters.Add(param1);
  587. var v_msisdn = dataColumn[2].ToArray();
  588. OracleParameter param2 = new OracleParameter("v_msisdn", OracleDbType.NVarchar2, ParameterDirection.Input);
  589. param2.Value = v_msisdn;
  590. param2.Size = v_msisdn.Length;
  591. command.Parameters.Add(param2);
  592. var v_money = dataColumn[3].ToArray();
  593. OracleParameter param3 = new OracleParameter("v_money", OracleDbType.NVarchar2, ParameterDirection.Input);
  594. param3.Value = v_money;
  595. param3.Size = v_money.Length;
  596. command.Parameters.Add(param3);
  597. var v_random_id = dataColumn[4].ToArray();
  598. OracleParameter param4 = new OracleParameter("v_random_id", OracleDbType.NVarchar2, ParameterDirection.Input);
  599. param4.Value = v_random_id;
  600. param4.Size = v_random_id.Length;
  601. command.Parameters.Add(param4);
  602. var v_bet_id = dataColumn[5].ToArray();
  603. OracleParameter param5 = new OracleParameter("v_bet_id", OracleDbType.NVarchar2, ParameterDirection.Input);
  604. param5.Value = v_bet_id;
  605. param5.Size = v_bet_id.Length;
  606. command.Parameters.Add(param5);
  607. var v_winner_code = dataColumn[6].ToArray();
  608. OracleParameter param6 = new OracleParameter("v_winner_code", OracleDbType.NVarchar2, ParameterDirection.Input);
  609. param6.Value = v_winner_code;
  610. param6.Size = v_winner_code.Length;
  611. command.Parameters.Add(param6);
  612. command.ExecuteNonQuery();
  613. transaction.Commit();
  614. }
  615. }
  616. catch (OracleException ex)
  617. {
  618. Console.WriteLine(ex.ToString());
  619. throw;
  620. }
  621. finally
  622. {
  623. connection.Close();
  624. }
  625. }
  626. public static void InsertBulkBlack(string sSQL, List<List<string>> dataColumn)
  627. {
  628. OracleConnection connection = null;
  629. try
  630. {
  631. connection = DataAccess.getPoolingConnection();
  632. connection.Open();
  633. OracleTransaction transaction;
  634. // Start a local transaction
  635. transaction = connection.BeginTransaction(IsolationLevel.ReadCommitted);
  636. using (var command = connection.CreateCommand())
  637. {
  638. command.CommandText = sSQL;
  639. command.CommandType = CommandType.StoredProcedure;
  640. command.ArrayBindCount = dataColumn[0].Count;
  641. command.Transaction = transaction;
  642. var v_users = dataColumn[0].ToArray();
  643. OracleParameter param0 = new OracleParameter("v_users", OracleDbType.NVarchar2, ParameterDirection.Input);
  644. param0.Value = v_users;
  645. param0.Size = v_users.Length;
  646. command.Parameters.Add(param0);
  647. var v_msisdn = dataColumn[1].ToArray();
  648. OracleParameter param1 = new OracleParameter("v_msisdn", OracleDbType.NVarchar2, ParameterDirection.Input);
  649. param1.Value = v_msisdn;
  650. param1.Size = v_msisdn.Length;
  651. command.Parameters.Add(param1);
  652. var v_isLock = dataColumn[2].ToArray();
  653. OracleParameter param2 = new OracleParameter("v_isLock", OracleDbType.NVarchar2, ParameterDirection.Input);
  654. param2.Value = v_isLock;
  655. param2.Size = v_isLock.Length;
  656. command.Parameters.Add(param2);
  657. var v_note = dataColumn[3].ToArray();
  658. OracleParameter param3 = new OracleParameter("v_note", OracleDbType.NVarchar2, ParameterDirection.Input);
  659. param3.Value = v_note;
  660. param3.Size = v_note.Length;
  661. command.Parameters.Add(param3);
  662. command.ExecuteNonQuery();
  663. transaction.Commit();
  664. }
  665. }
  666. catch (OracleException ex)
  667. {
  668. Console.WriteLine(ex.ToString());
  669. throw;
  670. }
  671. finally
  672. {
  673. connection.Close();
  674. }
  675. }
  676. }
  677. }