balanceDataAccess.cs 129 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281328232833284328532863287328832893290329132923293329432953296329732983299330033013302330333043305330633073308330933103311331233133314331533163317331833193320
  1. using Oracle.ManagedDataAccess.Client;
  2. using StackExchange.Redis;
  3. using System;
  4. using System.Collections.Generic;
  5. using System.Data;
  6. using System.Linq;
  7. using System.Threading.Channels;
  8. using System.Web;
  9. namespace ResfullApi.Models.balance
  10. {
  11. public class balanceDataAccess
  12. {
  13. public balanceDataAccess()
  14. {
  15. }
  16. public static void InsertBulkBlackList(string sSQL, List<List<string>> dataColumn)
  17. {
  18. OracleConnection connection = null;
  19. try
  20. {
  21. connection = DataAccess.getPoolingConnection();
  22. connection.Open();
  23. OracleTransaction transaction;
  24. // Start a local transaction
  25. transaction = connection.BeginTransaction(IsolationLevel.ReadCommitted);
  26. using (var command = connection.CreateCommand())
  27. {
  28. command.CommandText = sSQL;
  29. command.CommandType = CommandType.StoredProcedure;
  30. command.ArrayBindCount = dataColumn[0].Count;
  31. command.Transaction = transaction;
  32. var v_msisdn = dataColumn[0].ToArray();
  33. OracleParameter param0 = new OracleParameter("v_msisdn", OracleDbType.NVarchar2, ParameterDirection.Input);
  34. param0.Value = v_msisdn;
  35. param0.Size = v_msisdn.Length;
  36. command.Parameters.Add(param0);
  37. var v_type = dataColumn[1].ToArray();
  38. OracleParameter param1 = new OracleParameter("v_type", OracleDbType.NVarchar2, ParameterDirection.Input);
  39. param1.Value = v_type;
  40. param1.Size = v_type.Length;
  41. command.Parameters.Add(param1);
  42. var v_sv_id = dataColumn[2].ToArray();
  43. OracleParameter param2 = new OracleParameter("v_sv_id", OracleDbType.NVarchar2, ParameterDirection.Input);
  44. param2.Value = v_sv_id;
  45. param2.Size = v_sv_id.Length;
  46. command.Parameters.Add(param2);
  47. var v_action = dataColumn[3].ToArray();
  48. OracleParameter param3 = new OracleParameter("v_action", OracleDbType.NVarchar2, ParameterDirection.Input);
  49. param3.Value = v_action;
  50. param3.Size = v_action.Length;
  51. command.Parameters.Add(param3);
  52. var v_users = dataColumn[4].ToArray();
  53. OracleParameter param4 = new OracleParameter("v_users", OracleDbType.NVarchar2, ParameterDirection.Input);
  54. param4.Value = v_users;
  55. param4.Size = v_users.Length;
  56. command.Parameters.Add(param4);
  57. command.ExecuteNonQuery();
  58. transaction.Commit();
  59. }
  60. }
  61. catch (OracleException ex)
  62. {
  63. Console.WriteLine(ex.ToString());
  64. throw;
  65. }
  66. finally
  67. {
  68. connection.Close();
  69. }
  70. }
  71. public static DataSet reportByCampaign(string v_users, string status,string v_fromDate, string v_toDate)
  72. {
  73. string str;
  74. str = "";
  75. str = "BALANCE_PKG.REPORT_BY_CAMPAIGN";
  76. OracleParameter[] parms;
  77. parms = new OracleParameter[]
  78. {
  79. new OracleParameter("v_users", OracleDbType.NVarchar2),
  80. new OracleParameter("v_status", OracleDbType.NVarchar2),
  81. new OracleParameter("v_FROMDATE", OracleDbType.NVarchar2),
  82. new OracleParameter("v_TODATE", OracleDbType.NVarchar2),
  83. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  84. };
  85. parms[0].Value = v_users;
  86. parms[1].Value = status;
  87. parms[2].Value = v_fromDate;
  88. parms[3].Value = v_toDate;
  89. return DataAccess.getDataFromProcedure(str, "", parms);
  90. }
  91. public static DataSet reportTotalByCampaign(string v_users, string v_fromDate, string v_toDate,string status,string isDefault)
  92. {
  93. string str;
  94. str = "";
  95. str = "BALANCE_PKG.CAM_GET_REPORT_TOTAL";
  96. OracleParameter[] parms;
  97. parms = new OracleParameter[]
  98. {
  99. new OracleParameter("v_users", OracleDbType.NVarchar2),
  100. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  101. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  102. new OracleParameter("v_status", OracleDbType.NVarchar2),
  103. new OracleParameter("v_isDefault", OracleDbType.NVarchar2),
  104. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  105. };
  106. parms[0].Value = v_users;
  107. parms[1].Value = v_fromDate;
  108. parms[2].Value = v_toDate;
  109. parms[3].Value = status;
  110. parms[4].Value = isDefault;
  111. return DataAccess.getDataFromProcedure(str, "", parms);
  112. }
  113. public static DataSet comGetList(string v_id,string v_users, string v_name, string v_code, string v_fromDate, string v_toDate
  114. , string v_order, string v_rowsOnPage, string v_seqPage)
  115. {
  116. string str;
  117. str = "";
  118. str = "BALANCE_PKG.COM_GET";
  119. OracleParameter[] parms;
  120. parms = new OracleParameter[]
  121. {
  122. new OracleParameter("v_id", OracleDbType.NVarchar2),
  123. new OracleParameter("v_users", OracleDbType.NVarchar2),
  124. new OracleParameter("v_name", OracleDbType.NVarchar2),
  125. new OracleParameter("v_code", OracleDbType.NVarchar2),
  126. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  127. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  128. new OracleParameter("v_order", OracleDbType.NVarchar2),
  129. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  130. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  131. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  132. };
  133. parms[0].Value = v_id;
  134. parms[1].Value = v_users;
  135. parms[2].Value = v_name;
  136. parms[3].Value = v_code;
  137. parms[4].Value = v_fromDate;
  138. parms[5].Value = v_toDate;
  139. parms[6].Value = v_order;
  140. parms[7].Value = v_rowsOnPage;
  141. parms[8].Value = v_seqPage;
  142. return DataAccess.getDataFromProcedure(str, "", parms);
  143. }
  144. public static DataSet comInsert(string V_CODE, string V_NAME,string V_PHONE,string V_EMAIL,string V_ADDRESS,string V_DESCRIPTION,
  145. string V_NOTE,string V_USERS)
  146. {
  147. string str;
  148. str = "";
  149. str = "BALANCE_PKG.COM_INSERT";
  150. OracleParameter[] parms;
  151. parms = new OracleParameter[]
  152. {
  153. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  154. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  155. new OracleParameter("V_PHONE", OracleDbType.NVarchar2),
  156. new OracleParameter("V_EMAIL", OracleDbType.NVarchar2),
  157. new OracleParameter("V_ADDRESS", OracleDbType.NVarchar2),
  158. new OracleParameter("V_DESCRIPTION", OracleDbType.NVarchar2),
  159. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  160. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  161. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  162. };
  163. parms[0].Value = V_CODE;
  164. parms[1].Value = V_NAME;
  165. parms[2].Value = V_PHONE;
  166. parms[3].Value = V_EMAIL;
  167. parms[4].Value = V_ADDRESS;
  168. parms[5].Value = V_DESCRIPTION;
  169. parms[6].Value = V_NOTE;
  170. parms[7].Value = V_USERS;
  171. return DataAccess.getDataFromProcedure(str, "", parms);
  172. }
  173. public static DataSet comUpdate(string V_ID,string V_CODE, string V_NAME, string V_PHONE, string V_EMAIL, string V_ADDRESS, string V_DESCRIPTION,
  174. string V_NOTE, string V_USERS,string V_TYPE)
  175. {
  176. string str;
  177. str = "";
  178. str = "BALANCE_PKG.COM_UPDATE";
  179. OracleParameter[] parms;
  180. parms = new OracleParameter[]
  181. {
  182. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  183. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  184. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  185. new OracleParameter("V_PHONE", OracleDbType.NVarchar2),
  186. new OracleParameter("V_EMAIL", OracleDbType.NVarchar2),
  187. new OracleParameter("V_ADDRESS", OracleDbType.NVarchar2),
  188. new OracleParameter("V_DESCRIPTION", OracleDbType.NVarchar2),
  189. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  190. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  191. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  192. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  193. };
  194. parms[0].Value = V_ID;
  195. parms[1].Value = V_CODE;
  196. parms[2].Value = V_NAME;
  197. parms[3].Value = V_PHONE;
  198. parms[4].Value = V_EMAIL;
  199. parms[5].Value = V_ADDRESS;
  200. parms[6].Value = V_DESCRIPTION;
  201. parms[7].Value = V_NOTE;
  202. parms[8].Value = V_USERS;
  203. parms[9].Value = V_TYPE;
  204. return DataAccess.getDataFromProcedure(str, "", parms);
  205. }
  206. public static DataSet listSubGetList(string v_id, string v_users,string V_sub_type, string v_name,string v_code,string v_fromDate,string v_toDate
  207. , string v_order,string v_rowsOnPage,string v_seqPage,string v_isActive)
  208. {
  209. string str;
  210. str = "";
  211. str = "BALANCE_PKG.LIST_SUB_GET";
  212. OracleParameter[] parms;
  213. parms = new OracleParameter[]
  214. {
  215. new OracleParameter("v_id", OracleDbType.NVarchar2),
  216. new OracleParameter("v_users", OracleDbType.NVarchar2),
  217. new OracleParameter("V_sub_type", OracleDbType.NVarchar2),
  218. new OracleParameter("v_name", OracleDbType.NVarchar2),
  219. new OracleParameter("v_code", OracleDbType.NVarchar2),
  220. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  221. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  222. new OracleParameter("v_order", OracleDbType.NVarchar2),
  223. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  224. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  225. new OracleParameter("v_isActive", OracleDbType.NVarchar2),
  226. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  227. };
  228. parms[0].Value = v_id;
  229. parms[1].Value = v_users;
  230. parms[2].Value = V_sub_type;
  231. parms[3].Value = v_name;
  232. parms[4].Value = v_code;
  233. parms[5].Value = v_fromDate;
  234. parms[6].Value = v_toDate;
  235. parms[7].Value = v_order;
  236. parms[8].Value = v_rowsOnPage;
  237. parms[9].Value = v_seqPage;
  238. parms[10].Value = v_isActive;
  239. return DataAccess.getDataFromProcedure(str, "", parms);
  240. }
  241. public static DataSet blistSubInsert(string V_CODE, string V_NAME,
  242. string V_NOTE, string V_USERS,string V_SUB_TYPE)
  243. {
  244. string str;
  245. str = "";
  246. str = "BALANCE_PKG.LIST_SUB_INSERT";
  247. OracleParameter[] parms;
  248. parms = new OracleParameter[]
  249. {
  250. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  251. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  252. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  253. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  254. new OracleParameter("V_SUB_TYPE", OracleDbType.NVarchar2),
  255. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  256. };
  257. parms[0].Value = V_CODE;
  258. parms[1].Value = V_NAME;
  259. parms[2].Value = V_NOTE;
  260. parms[3].Value = V_USERS;
  261. parms[4].Value = V_SUB_TYPE;
  262. return DataAccess.getDataFromProcedure(str, "", parms);
  263. }
  264. public static DataSet blistSubUpdate(string V_ID, string V_CODE, string V_NAME,string V_SUB_TYPE,
  265. string V_NOTE, string V_USERS, string V_TYPE,string status)
  266. {
  267. string str;
  268. str = "";
  269. str = "BALANCE_PKG.LIST_SUB_UPDATE";
  270. OracleParameter[] parms;
  271. parms = new OracleParameter[]
  272. {
  273. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  274. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  275. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  276. new OracleParameter("V_SUB_TYPE", OracleDbType.NVarchar2),
  277. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  278. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  279. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  280. new OracleParameter("V_STATUS", OracleDbType.NVarchar2),
  281. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  282. };
  283. parms[0].Value = V_ID;
  284. parms[1].Value = V_CODE;
  285. parms[2].Value = V_NAME;
  286. parms[3].Value = V_SUB_TYPE;
  287. parms[4].Value = V_NOTE;
  288. parms[5].Value = V_USERS;
  289. parms[6].Value = V_TYPE;
  290. parms[7].Value = status;
  291. return DataAccess.getDataFromProcedure(str, "", parms);
  292. }
  293. public static DataSet listSubFileGetList(string v_id, string v_users, string V_list_sub_id, string v_name, string v_code, string v_fromDate, string v_toDate
  294. , string v_order, string v_rowsOnPage, string v_seqPage)
  295. {
  296. string str;
  297. str = "";
  298. str = "BALANCE_PKG.LIST_SUB_FILE_GET";
  299. OracleParameter[] parms;
  300. parms = new OracleParameter[]
  301. {
  302. new OracleParameter("v_id", OracleDbType.NVarchar2),
  303. new OracleParameter("v_users", OracleDbType.NVarchar2),
  304. new OracleParameter("V_list_sub_id", OracleDbType.NVarchar2),
  305. new OracleParameter("v_name", OracleDbType.NVarchar2),
  306. new OracleParameter("v_code", OracleDbType.NVarchar2),
  307. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  308. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  309. new OracleParameter("v_order", OracleDbType.NVarchar2),
  310. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  311. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  312. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  313. };
  314. parms[0].Value = v_id;
  315. parms[1].Value = v_users;
  316. parms[2].Value = V_list_sub_id;
  317. parms[3].Value = v_name;
  318. parms[4].Value = v_code;
  319. parms[5].Value = v_fromDate;
  320. parms[6].Value = v_toDate;
  321. parms[7].Value = v_order;
  322. parms[8].Value = v_rowsOnPage;
  323. parms[9].Value = v_seqPage;
  324. return DataAccess.getDataFromProcedure(str, "", parms);
  325. }
  326. public static DataSet blistSubFileInsert(string V_CODE, string V_NAME,
  327. string V_NOTE, string V_USERS, string V_LIST_SUB_ID, string V_FILE_ID, string V_FILE_NAME)
  328. {
  329. string str;
  330. str = "";
  331. str = "BALANCE_PKG.LIST_SUB_FILE_INSERT";
  332. OracleParameter[] parms;
  333. parms = new OracleParameter[]
  334. {
  335. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  336. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  337. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  338. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  339. new OracleParameter("V_LIST_SUB_ID", OracleDbType.NVarchar2),
  340. new OracleParameter("V_FILE_ID", OracleDbType.NVarchar2),
  341. new OracleParameter("V_FILE_NAME", OracleDbType.NVarchar2),
  342. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  343. };
  344. parms[0].Value = V_CODE;
  345. parms[1].Value = V_NAME;
  346. parms[2].Value = V_NOTE;
  347. parms[3].Value = V_USERS;
  348. parms[4].Value = V_LIST_SUB_ID;
  349. parms[5].Value = V_FILE_ID;
  350. parms[6].Value = V_FILE_NAME;
  351. return DataAccess.getDataFromProcedure(str, "", parms);
  352. }
  353. public static DataSet blistSubFileUpdate(string V_ID, string V_CODE, string V_NAME, string V_LIST_SUB_ID,
  354. string V_NOTE, string V_USERS, string V_TYPE,string status)
  355. {
  356. string str;
  357. str = "";
  358. str = "BALANCE_PKG.LIST_SUB_FILE_UPDATE";
  359. OracleParameter[] parms;
  360. parms = new OracleParameter[]
  361. {
  362. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  363. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  364. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  365. new OracleParameter("V_LIST_SUB_ID", OracleDbType.NVarchar2),
  366. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  367. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  368. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  369. new OracleParameter("V_STATUS", OracleDbType.NVarchar2),
  370. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  371. };
  372. parms[0].Value = V_ID;
  373. parms[1].Value = V_CODE;
  374. parms[2].Value = V_NAME;
  375. parms[3].Value = V_LIST_SUB_ID;
  376. parms[4].Value = V_NOTE;
  377. parms[5].Value = V_USERS;
  378. parms[6].Value = V_TYPE;
  379. parms[7].Value = status;
  380. return DataAccess.getDataFromProcedure(str, "", parms);
  381. }
  382. public static DataSet sortCodeGetList( string v_type, string v_users)
  383. {
  384. string str;
  385. str = "";
  386. str = "BALANCE_PKG.SORT_CODE_GET_LIST";
  387. OracleParameter[] parms;
  388. parms = new OracleParameter[]
  389. {
  390. new OracleParameter("v_type", OracleDbType.NVarchar2),
  391. new OracleParameter("v_users", OracleDbType.NVarchar2),
  392. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  393. };
  394. parms[0].Value = v_type;
  395. parms[1].Value = v_users;
  396. return DataAccess.getDataFromProcedure(str, "", parms);
  397. }
  398. public static DataSet changeStatus(string v_type,string v_id, string v_status, string v_users)
  399. {
  400. string str;
  401. str = "";
  402. str = "BALANCE_PKG.CHANGE_STATUS";
  403. OracleParameter[] parms;
  404. parms = new OracleParameter[]
  405. {
  406. new OracleParameter("v_type", OracleDbType.NVarchar2),
  407. new OracleParameter("v_id", OracleDbType.NVarchar2),
  408. new OracleParameter("v_status", OracleDbType.NVarchar2),
  409. new OracleParameter("v_users", OracleDbType.NVarchar2),
  410. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  411. };
  412. parms[0].Value = v_type;
  413. parms[1].Value = v_id;
  414. parms[2].Value = v_status;
  415. parms[3].Value = v_users;
  416. return DataAccess.getDataFromProcedure(str, "", parms);
  417. }
  418. public static DataSet balGetList(string v_id, string v_users,string v_name,string v_code,string v_fromDate,string v_toDate
  419. , string v_order,string v_rowsOnPage,string v_seqPage,string isActive)
  420. {
  421. string str;
  422. str = "";
  423. str = "BALANCE_PKG.BL_GET";
  424. OracleParameter[] parms;
  425. parms = new OracleParameter[]
  426. {
  427. new OracleParameter("v_id", OracleDbType.NVarchar2),
  428. new OracleParameter("v_users", OracleDbType.NVarchar2),
  429. new OracleParameter("v_name", OracleDbType.NVarchar2),
  430. new OracleParameter("v_code", OracleDbType.NVarchar2),
  431. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  432. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  433. new OracleParameter("v_order", OracleDbType.NVarchar2),
  434. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  435. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  436. new OracleParameter("v_isActive", OracleDbType.NVarchar2),
  437. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  438. };
  439. parms[0].Value = v_id;
  440. parms[1].Value = v_users;
  441. parms[2].Value = v_name;
  442. parms[3].Value = v_code;
  443. parms[4].Value = v_fromDate;
  444. parms[5].Value = v_toDate;
  445. parms[6].Value = v_order;
  446. parms[7].Value = v_rowsOnPage;
  447. parms[8].Value = v_seqPage;
  448. parms[9].Value = isActive;
  449. return DataAccess.getDataFromProcedure(str, "", parms);
  450. }
  451. public static DataSet balInsert(string V_CODE, string V_NAME, string V_MIN, string V_MAX,
  452. string V_NOTE, string V_USERS)
  453. {
  454. string str;
  455. str = "";
  456. str = "BALANCE_PKG.BL_INSERT";
  457. OracleParameter[] parms;
  458. parms = new OracleParameter[]
  459. {
  460. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  461. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  462. new OracleParameter("V_MIN", OracleDbType.NVarchar2),
  463. new OracleParameter("V_MAX", OracleDbType.NVarchar2),
  464. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  465. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  466. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  467. };
  468. parms[0].Value = V_CODE;
  469. parms[1].Value = V_NAME;
  470. parms[2].Value = V_MIN;
  471. parms[3].Value = V_MAX;
  472. parms[4].Value = V_NOTE;
  473. parms[5].Value = V_USERS;
  474. return DataAccess.getDataFromProcedure(str, "", parms);
  475. }
  476. public static DataSet balUpdate(string V_ID,string V_CODE, string V_NAME, string V_MIN, string V_MAX,
  477. string V_NOTE, string V_USERS,string V_TYPE)
  478. {
  479. string str;
  480. str = "";
  481. str = "BALANCE_PKG.BL_UPDATE";
  482. OracleParameter[] parms;
  483. parms = new OracleParameter[]
  484. {
  485. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  486. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  487. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  488. new OracleParameter("V_MIN", OracleDbType.NVarchar2),
  489. new OracleParameter("V_MAX", OracleDbType.NVarchar2),
  490. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  491. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  492. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  493. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  494. };
  495. parms[0].Value = V_ID;
  496. parms[1].Value = V_CODE;
  497. parms[2].Value = V_NAME;
  498. parms[3].Value = V_MIN;
  499. parms[4].Value = V_MAX;
  500. parms[5].Value = V_NOTE;
  501. parms[6].Value = V_USERS;
  502. parms[7].Value = V_TYPE;
  503. return DataAccess.getDataFromProcedure(str, "", parms);
  504. }
  505. public static DataSet expGetList(string v_id, string v_users, string v_name, string v_code, string v_fromDate, string v_toDate
  506. , string v_order, string v_rowsOnPage, string v_seqPage,string v_isActive)
  507. {
  508. string str;
  509. str = "";
  510. str = "BALANCE_PKG.EP_GET";
  511. OracleParameter[] parms;
  512. parms = new OracleParameter[]
  513. {
  514. new OracleParameter("v_id", OracleDbType.NVarchar2),
  515. new OracleParameter("v_users", OracleDbType.NVarchar2),
  516. new OracleParameter("v_name", OracleDbType.NVarchar2),
  517. new OracleParameter("v_code", OracleDbType.NVarchar2),
  518. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  519. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  520. new OracleParameter("v_order", OracleDbType.NVarchar2),
  521. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  522. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  523. new OracleParameter("v_isActive", OracleDbType.NVarchar2),
  524. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  525. };
  526. parms[0].Value = v_id;
  527. parms[1].Value = v_users;
  528. parms[2].Value = v_name;
  529. parms[3].Value = v_code;
  530. parms[4].Value = v_fromDate;
  531. parms[5].Value = v_toDate;
  532. parms[6].Value = v_order;
  533. parms[7].Value = v_rowsOnPage;
  534. parms[8].Value = v_seqPage;
  535. parms[9].Value = v_isActive;
  536. return DataAccess.getDataFromProcedure(str, "", parms);
  537. }
  538. public static DataSet expInsert(string V_CODE, string V_NAME, string V_TOTAL_DAY_USE,
  539. string V_NOTE, string V_USERS,string min,string max)
  540. {
  541. string str;
  542. str = "";
  543. str = "BALANCE_PKG.EP_INSERT";
  544. OracleParameter[] parms;
  545. parms = new OracleParameter[]
  546. {
  547. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  548. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  549. new OracleParameter("V_TOTAL_DAY_USE", OracleDbType.NVarchar2),
  550. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  551. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  552. new OracleParameter("V_MIN", OracleDbType.NVarchar2),
  553. new OracleParameter("V_MAX", OracleDbType.NVarchar2),
  554. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  555. };
  556. parms[0].Value = V_CODE;
  557. parms[1].Value = V_NAME;
  558. parms[2].Value = V_TOTAL_DAY_USE;
  559. parms[3].Value = V_NOTE;
  560. parms[4].Value = V_USERS;
  561. parms[5].Value = min;
  562. parms[6].Value = max;
  563. return DataAccess.getDataFromProcedure(str, "", parms);
  564. }
  565. public static DataSet expUpdate(string V_ID, string V_CODE, string V_NAME, string V_TOTAL_DAY_USE,
  566. string V_NOTE, string V_USERS, string V_TYPE,string min,string max)
  567. {
  568. string str;
  569. str = "";
  570. str = "BALANCE_PKG.EP_UPDATE";
  571. OracleParameter[] parms;
  572. parms = new OracleParameter[]
  573. {
  574. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  575. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  576. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  577. new OracleParameter("V_TOTAL_DAY_USE", OracleDbType.NVarchar2),
  578. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  579. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  580. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  581. new OracleParameter("V_MIN", OracleDbType.NVarchar2),
  582. new OracleParameter("V_MAX", OracleDbType.NVarchar2),
  583. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  584. };
  585. parms[0].Value = V_ID;
  586. parms[1].Value = V_CODE;
  587. parms[2].Value = V_NAME;
  588. parms[3].Value = V_TOTAL_DAY_USE;
  589. parms[4].Value = V_NOTE;
  590. parms[5].Value = V_USERS;
  591. parms[6].Value = V_TYPE;
  592. parms[7].Value = min;
  593. parms[8].Value = max;
  594. return DataAccess.getDataFromProcedure(str, "", parms);
  595. }
  596. public static DataSet paramGetList(string v_id, string v_users)
  597. {
  598. string str;
  599. str = "";
  600. str = "BALANCE_PKG.PAM_GET";
  601. OracleParameter[] parms;
  602. parms = new OracleParameter[]
  603. {
  604. new OracleParameter("v_id", OracleDbType.NVarchar2),
  605. new OracleParameter("v_users", OracleDbType.NVarchar2),
  606. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  607. };
  608. parms[0].Value = v_id;
  609. parms[1].Value = v_users;
  610. return DataAccess.getDataFromProcedure(str, "", parms);
  611. }
  612. public static DataSet paramInsert(string V_CODE, string V_SVALUES, string V_NOTE,
  613. string V_STATUS, string V_CODE_GROUP, string V_DISPLAY0, string V_DISPLAY1, string V_DISPLAY2, string V_DISPLAY3,
  614. string V_DISPLAY4, string V_DISPLAY5, string V_GAME_ID, string V_CHANNEL, string V_USERS)
  615. {
  616. string str;
  617. str = "";
  618. str = "BALANCE_PKG.PAM_INSERT";
  619. OracleParameter[] parms;
  620. parms = new OracleParameter[]
  621. {
  622. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  623. new OracleParameter("V_SVALUES", OracleDbType.NVarchar2),
  624. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  625. new OracleParameter("V_STATUS", OracleDbType.NVarchar2),
  626. new OracleParameter("V_CODE_GROUP", OracleDbType.NVarchar2),
  627. new OracleParameter("V_DISPLAY0", OracleDbType.NVarchar2),
  628. new OracleParameter("V_DISPLAY1", OracleDbType.NVarchar2),
  629. new OracleParameter("V_DISPLAY2", OracleDbType.NVarchar2),
  630. new OracleParameter("V_DISPLAY3", OracleDbType.NVarchar2),
  631. new OracleParameter("V_DISPLAY4", OracleDbType.NVarchar2),
  632. new OracleParameter("V_DISPLAY5", OracleDbType.NVarchar2),
  633. new OracleParameter("V_GAME_ID", OracleDbType.NVarchar2),
  634. new OracleParameter("V_CHANNEL", OracleDbType.NVarchar2),
  635. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  636. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  637. };
  638. parms[0].Value = V_CODE;
  639. parms[1].Value = V_SVALUES;
  640. parms[2].Value = V_NOTE;
  641. parms[3].Value = V_STATUS;
  642. parms[4].Value = V_CODE_GROUP;
  643. parms[5].Value = V_DISPLAY0;
  644. parms[6].Value = V_DISPLAY1;
  645. parms[7].Value = V_DISPLAY2;
  646. parms[8].Value = V_DISPLAY3;
  647. parms[9].Value = V_DISPLAY4;
  648. parms[10].Value = V_DISPLAY5;
  649. parms[11].Value = V_GAME_ID;
  650. parms[12].Value = V_CHANNEL;
  651. parms[13].Value = V_USERS;
  652. return DataAccess.getDataFromProcedure(str, "", parms);
  653. }
  654. public static DataSet paramUpdate(string V_ID, string V_CODE, string V_SVALUES, string V_NOTE,
  655. string V_STATUS, string V_CODE_GROUP, string V_DISPLAY0, string V_DISPLAY1, string V_DISPLAY2, string V_DISPLAY3,
  656. string V_DISPLAY4, string V_DISPLAY5, string V_GAME_ID, string V_CHANNEL, string V_USERS, string V_TYPE)
  657. {
  658. string str;
  659. str = "";
  660. str = "BALANCE_PKG.PAM_UPDATE";
  661. OracleParameter[] parms;
  662. parms = new OracleParameter[]
  663. {
  664. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  665. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  666. new OracleParameter("V_SVALUES", OracleDbType.NVarchar2),
  667. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  668. new OracleParameter("V_STATUS", OracleDbType.NVarchar2),
  669. new OracleParameter("V_CODE_GROUP", OracleDbType.NVarchar2),
  670. new OracleParameter("V_DISPLAY0", OracleDbType.NVarchar2),
  671. new OracleParameter("V_DISPLAY1", OracleDbType.NVarchar2),
  672. new OracleParameter("V_DISPLAY2", OracleDbType.NVarchar2),
  673. new OracleParameter("V_DISPLAY3", OracleDbType.NVarchar2),
  674. new OracleParameter("V_DISPLAY4", OracleDbType.NVarchar2),
  675. new OracleParameter("V_DISPLAY5", OracleDbType.NVarchar2),
  676. new OracleParameter("V_GAME_ID", OracleDbType.NVarchar2),
  677. new OracleParameter("V_CHANNEL", OracleDbType.NVarchar2),
  678. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  679. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  680. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  681. };
  682. parms[0].Value = V_ID;
  683. parms[1].Value = V_CODE;
  684. parms[2].Value = V_SVALUES;
  685. parms[3].Value = V_NOTE;
  686. parms[4].Value = V_STATUS;
  687. parms[5].Value = V_CODE_GROUP;
  688. parms[6].Value = V_DISPLAY0;
  689. parms[7].Value = V_DISPLAY1;
  690. parms[8].Value = V_DISPLAY2;
  691. parms[9].Value = V_DISPLAY3;
  692. parms[10].Value = V_DISPLAY4;
  693. parms[11].Value = V_DISPLAY5;
  694. parms[12].Value = V_GAME_ID;
  695. parms[13].Value = V_CHANNEL;
  696. parms[14].Value = V_USERS;
  697. parms[15].Value = V_TYPE;
  698. return DataAccess.getDataFromProcedure(str, "", parms);
  699. }
  700. public static DataSet usersGetList(string v_id, string v_users)
  701. {
  702. string str;
  703. str = "";
  704. str = "BALANCE_PKG.USERS_GET";
  705. OracleParameter[] parms;
  706. parms = new OracleParameter[]
  707. {
  708. new OracleParameter("v_id", OracleDbType.NVarchar2),
  709. new OracleParameter("v_users", OracleDbType.NVarchar2),
  710. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  711. };
  712. parms[0].Value = v_id;
  713. parms[1].Value = v_users;
  714. return DataAccess.getDataFromProcedure(str, "", parms);
  715. }
  716. public static DataSet usersInsert(string V_USERNAME, string V_PASSWORD, string V_ROLE,
  717. string V_COUNTRY_CODE, string V_IS_LOCK, string V_TOTAL_FALSE, string V_TIME_LOCK, string V_NOTE, string V_USERS)
  718. {
  719. string str;
  720. str = "";
  721. str = "BALANCE_PKG.USERS_INSERT";
  722. OracleParameter[] parms;
  723. parms = new OracleParameter[]
  724. {
  725. new OracleParameter("V_USERNAME", OracleDbType.NVarchar2),
  726. new OracleParameter("V_PASSWORD", OracleDbType.NVarchar2),
  727. new OracleParameter("V_ROLE", OracleDbType.NVarchar2),
  728. new OracleParameter("V_COUNTRY_CODE", OracleDbType.NVarchar2),
  729. new OracleParameter("V_IS_LOCK", OracleDbType.NVarchar2),
  730. new OracleParameter("V_TOTAL_FALSE", OracleDbType.NVarchar2),
  731. new OracleParameter("V_TIME_LOCK", OracleDbType.NVarchar2),
  732. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  733. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  734. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  735. };
  736. parms[0].Value = V_USERNAME;
  737. parms[1].Value = V_PASSWORD;
  738. parms[2].Value = V_ROLE;
  739. parms[3].Value = V_COUNTRY_CODE;
  740. parms[4].Value = V_IS_LOCK;
  741. parms[5].Value = V_TOTAL_FALSE;
  742. parms[6].Value = V_TIME_LOCK;
  743. parms[7].Value = V_NOTE;
  744. parms[8].Value = V_USERS;
  745. return DataAccess.getDataFromProcedure(str, "", parms);
  746. }
  747. public static DataSet usersUpdate(string V_ID, string V_USERNAME, string V_PASSWORD, string V_ROLE,
  748. string V_COUNTRY_CODE, string V_IS_LOCK, string V_TOTAL_FALSE, string V_TIME_LOCK, string V_NOTE, string V_USERS, string V_TYPE)
  749. {
  750. string str;
  751. str = "";
  752. str = "BALANCE_PKG.USERS_UPDATE";
  753. OracleParameter[] parms;
  754. parms = new OracleParameter[]
  755. {
  756. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  757. new OracleParameter("V_USERNAME", OracleDbType.NVarchar2),
  758. new OracleParameter("V_PASSWORD", OracleDbType.NVarchar2),
  759. new OracleParameter("V_ROLE", OracleDbType.NVarchar2),
  760. new OracleParameter("V_COUNTRY_CODE", OracleDbType.NVarchar2),
  761. new OracleParameter("V_IS_LOCK", OracleDbType.NVarchar2),
  762. new OracleParameter("V_TOTAL_FALSE", OracleDbType.NVarchar2),
  763. new OracleParameter("V_TIME_LOCK", OracleDbType.NVarchar2),
  764. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  765. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  766. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  767. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  768. };
  769. parms[0].Value = V_ID;
  770. parms[1].Value = V_USERNAME;
  771. parms[2].Value = V_PASSWORD;
  772. parms[3].Value = V_ROLE;
  773. parms[4].Value = V_COUNTRY_CODE;
  774. parms[5].Value = V_IS_LOCK;
  775. parms[6].Value = V_TOTAL_FALSE;
  776. parms[7].Value = V_TIME_LOCK;
  777. parms[8].Value = V_NOTE;
  778. parms[9].Value = V_USERS;
  779. parms[10].Value = V_TYPE;
  780. return DataAccess.getDataFromProcedure(str, "", parms);
  781. }
  782. public static DataSet svGetList(string v_id, string v_users, string v_name, string v_code, string v_fromDate, string v_toDate
  783. , string v_order, string v_rowsOnPage, string v_seqPage,string isActive)
  784. {
  785. string str;
  786. str = "";
  787. str = "BALANCE_PKG.SV_GET";
  788. OracleParameter[] parms;
  789. parms = new OracleParameter[]
  790. {
  791. new OracleParameter("v_id", OracleDbType.NVarchar2),
  792. new OracleParameter("v_users", OracleDbType.NVarchar2),
  793. new OracleParameter("v_name", OracleDbType.NVarchar2),
  794. new OracleParameter("v_code", OracleDbType.NVarchar2),
  795. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  796. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  797. new OracleParameter("v_order", OracleDbType.NVarchar2),
  798. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  799. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  800. new OracleParameter("v_isActive", OracleDbType.NVarchar2),
  801. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  802. };
  803. parms[0].Value = v_id;
  804. parms[1].Value = v_users;
  805. parms[2].Value = v_name;
  806. parms[3].Value = v_code;
  807. parms[4].Value = v_fromDate;
  808. parms[5].Value = v_toDate;
  809. parms[6].Value = v_order;
  810. parms[7].Value = v_rowsOnPage;
  811. parms[8].Value = v_seqPage;
  812. parms[9].Value = isActive;
  813. return DataAccess.getDataFromProcedure(str, "", parms);
  814. }
  815. public static DataSet svGroupGetList(string v_id, string v_users)
  816. {
  817. string str;
  818. str = "";
  819. str = "BALANCE_PKG.SVGROUP_GET";
  820. OracleParameter[] parms;
  821. parms = new OracleParameter[]
  822. {
  823. new OracleParameter("v_id", OracleDbType.NVarchar2),
  824. new OracleParameter("v_users", OracleDbType.NVarchar2),
  825. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  826. };
  827. parms[0].Value = v_id;
  828. parms[1].Value = v_users;
  829. return DataAccess.getDataFromProcedure(str, "", parms);
  830. }
  831. public static DataSet svInsert(string V_CODE, string V_NAME, string V_DESCRIPTION,
  832. string V_SHORT_CODE, string V_COMMAND_REGISTER, string V_CONTENT_EN, string V_CONTENT_FR, string V_CONTENT_LC, string V_NOTE,
  833. string V_COMPANY_ID, string V_USERS, string msgRegisterSuccess, string msgRegisterFlase,string msgConfirm,string serviceGroupId,string apiServiceId, string isMyservice
  834. )
  835. {
  836. string str;
  837. str = "";
  838. str = "BALANCE_PKG.SV_INSERT";
  839. OracleParameter[] parms;
  840. parms = new OracleParameter[]
  841. {
  842. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  843. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  844. new OracleParameter("V_DESCRIPTION", OracleDbType.NVarchar2),
  845. new OracleParameter("V_SHORT_CODE", OracleDbType.NVarchar2),
  846. new OracleParameter("V_COMMAND_REGISTER", OracleDbType.NVarchar2),
  847. new OracleParameter("V_CONTENT_EN", OracleDbType.NVarchar2),
  848. new OracleParameter("V_CONTENT_FR", OracleDbType.NVarchar2),
  849. new OracleParameter("V_CONTENT_LC", OracleDbType.NVarchar2),
  850. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  851. new OracleParameter("V_COMPANY_ID", OracleDbType.NVarchar2),
  852. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  853. new OracleParameter("V_USSD_MSG_REGISTER_SUC", OracleDbType.NVarchar2),
  854. new OracleParameter("V_USSD_MSG_REGISTER_FAIL", OracleDbType.NVarchar2),
  855. new OracleParameter("V_USSD_CONFIRM", OracleDbType.NVarchar2),
  856. new OracleParameter("V_SERVICE_GROUP_ID", OracleDbType.NVarchar2),
  857. new OracleParameter("V_API_SERVICE_ID", OracleDbType.NVarchar2),
  858. new OracleParameter("v_isMyservice", OracleDbType.NVarchar2),
  859. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  860. };
  861. parms[0].Value = V_CODE;
  862. parms[1].Value = V_NAME;
  863. parms[2].Value = V_DESCRIPTION;
  864. parms[3].Value = V_SHORT_CODE;
  865. parms[4].Value = V_COMMAND_REGISTER;
  866. parms[5].Value = V_CONTENT_EN;
  867. parms[6].Value = V_CONTENT_FR;
  868. parms[7].Value = V_CONTENT_LC;
  869. parms[8].Value = V_NOTE;
  870. parms[9].Value = V_COMPANY_ID;
  871. parms[10].Value = V_USERS;
  872. parms[11].Value = msgRegisterSuccess;
  873. parms[12].Value = msgRegisterFlase;
  874. parms[13].Value = msgConfirm;
  875. parms[14].Value = serviceGroupId;
  876. parms[15].Value = apiServiceId;
  877. parms[16].Value = isMyservice;
  878. return DataAccess.getDataFromProcedure(str, "", parms);
  879. }
  880. public static DataSet svUpdate(string V_ID,string V_CODE, string V_NAME, string V_DESCRIPTION,
  881. string V_SHORT_CODE, string V_COMMAND_REGISTER, string V_CONTENT_EN, string V_CONTENT_FR, string V_CONTENT_LC, string V_NOTE,
  882. string V_COMPANY_ID, string V_USERS, string V_TYPE, string msgRegisterSuccess, string msgRegisterFlase,string msgConfirm, string serviceGroupId, string apiServiceId, string isMyservice)
  883. {
  884. string str;
  885. str = "";
  886. str = "BALANCE_PKG.SV_UPDATE";
  887. OracleParameter[] parms;
  888. parms = new OracleParameter[]
  889. {
  890. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  891. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  892. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  893. new OracleParameter("V_DESCRIPTION", OracleDbType.NVarchar2),
  894. new OracleParameter("V_SHORT_CODE", OracleDbType.NVarchar2),
  895. new OracleParameter("V_COMMAND_REGISTER", OracleDbType.NVarchar2),
  896. new OracleParameter("V_CONTENT_EN", OracleDbType.NVarchar2),
  897. new OracleParameter("V_CONTENT_FR", OracleDbType.NVarchar2),
  898. new OracleParameter("V_CONTENT_LC", OracleDbType.NVarchar2),
  899. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  900. new OracleParameter("V_COMPANY_ID", OracleDbType.NVarchar2),
  901. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  902. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  903. new OracleParameter("V_USSD_MSG_REGISTER_SUC", OracleDbType.NVarchar2),
  904. new OracleParameter("V_USSD_MSG_REGISTER_FAIL", OracleDbType.NVarchar2),
  905. new OracleParameter("V_USSD_CONFIRM", OracleDbType.NVarchar2),
  906. new OracleParameter("V_SERVICE_GROUP_ID", OracleDbType.NVarchar2),
  907. new OracleParameter("V_API_SERVICE_ID", OracleDbType.NVarchar2),
  908. new OracleParameter("v_isMyservice", OracleDbType.NVarchar2),
  909. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  910. };
  911. parms[0].Value = V_ID;
  912. parms[1].Value = V_CODE;
  913. parms[2].Value = V_NAME;
  914. parms[3].Value = V_DESCRIPTION;
  915. parms[4].Value = V_SHORT_CODE;
  916. parms[5].Value = V_COMMAND_REGISTER;
  917. parms[6].Value = V_CONTENT_EN;
  918. parms[7].Value = V_CONTENT_FR;
  919. parms[8].Value = V_CONTENT_LC;
  920. parms[9].Value = V_NOTE;
  921. parms[10].Value = V_COMPANY_ID;
  922. parms[11].Value = V_USERS;
  923. parms[12].Value = V_TYPE;
  924. parms[13].Value = msgRegisterSuccess;
  925. parms[14].Value = msgRegisterFlase;
  926. parms[15].Value = msgConfirm;
  927. parms[16].Value = serviceGroupId;
  928. parms[17].Value = apiServiceId;
  929. parms[18].Value = isMyservice;
  930. return DataAccess.getDataFromProcedure(str, "", parms);
  931. }
  932. public static void serviceUpdateGroupAndApiById(string id, string serviceGroupId, string apiServiceId)
  933. {
  934. if (string.IsNullOrEmpty(id)) return;
  935. if (string.IsNullOrEmpty(serviceGroupId) && string.IsNullOrEmpty(apiServiceId)) return;
  936. OracleConnection dbConnection = DataAccess.getPoolingConnection();
  937. try
  938. {
  939. dbConnection.Open();
  940. List<string> sets = new List<string>();
  941. if (!string.IsNullOrEmpty(serviceGroupId)) sets.Add("SERVICE_GROUP_ID = :groupId");
  942. if (!string.IsNullOrEmpty(apiServiceId)) sets.Add("API_SERVICE_ID = :apiId");
  943. if (sets.Count == 0) return;
  944. string sql = "UPDATE SERVICE SET " + string.Join(",", sets) + " WHERE ID = :id";
  945. using (OracleCommand cmd = new OracleCommand(sql, dbConnection))
  946. {
  947. if (!string.IsNullOrEmpty(serviceGroupId)) cmd.Parameters.Add(":groupId", OracleDbType.NVarchar2).Value = serviceGroupId;
  948. if (!string.IsNullOrEmpty(apiServiceId)) cmd.Parameters.Add(":apiId", OracleDbType.NVarchar2).Value = apiServiceId;
  949. cmd.Parameters.Add(":id", OracleDbType.NVarchar2).Value = id;
  950. cmd.ExecuteNonQuery();
  951. }
  952. }
  953. finally
  954. {
  955. dbConnection.Close();
  956. }
  957. }
  958. public static void serviceUpdateGroupAndApiByCode(string code, string serviceGroupId, string apiServiceId)
  959. {
  960. if (string.IsNullOrEmpty(code)) return;
  961. if (string.IsNullOrEmpty(serviceGroupId) && string.IsNullOrEmpty(apiServiceId)) return;
  962. OracleConnection dbConnection = DataAccess.getPoolingConnection();
  963. try
  964. {
  965. dbConnection.Open();
  966. List<string> sets = new List<string>();
  967. if (!string.IsNullOrEmpty(serviceGroupId)) sets.Add("SERVICE_GROUP_ID = :groupId");
  968. if (!string.IsNullOrEmpty(apiServiceId)) sets.Add("API_SERVICE_ID = :apiId");
  969. if (sets.Count == 0) return;
  970. string sql = "UPDATE SERVICE SET " + string.Join(",", sets) + " WHERE CODE = :code";
  971. using (OracleCommand cmd = new OracleCommand(sql, dbConnection))
  972. {
  973. if (!string.IsNullOrEmpty(serviceGroupId)) cmd.Parameters.Add(":groupId", OracleDbType.NVarchar2).Value = serviceGroupId;
  974. if (!string.IsNullOrEmpty(apiServiceId)) cmd.Parameters.Add(":apiId", OracleDbType.NVarchar2).Value = apiServiceId;
  975. cmd.Parameters.Add(":code", OracleDbType.NVarchar2).Value = code;
  976. cmd.ExecuteNonQuery();
  977. }
  978. }
  979. finally
  980. {
  981. dbConnection.Close();
  982. }
  983. }
  984. public static DataSet svAddGetList(string v_id, string v_users, string v_name, string v_code, string v_fromDate, string v_toDate
  985. , string v_order, string v_rowsOnPage, string v_seqPage)
  986. {
  987. string str;
  988. str = "";
  989. str = "BALANCE_PKG.SVADD_GET";
  990. OracleParameter[] parms;
  991. parms = new OracleParameter[]
  992. {
  993. new OracleParameter("v_id", OracleDbType.NVarchar2),
  994. new OracleParameter("v_users", OracleDbType.NVarchar2),
  995. new OracleParameter("v_name", OracleDbType.NVarchar2),
  996. new OracleParameter("v_code", OracleDbType.NVarchar2),
  997. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  998. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  999. new OracleParameter("v_order", OracleDbType.NVarchar2),
  1000. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  1001. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  1002. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1003. };
  1004. parms[0].Value = v_id;
  1005. parms[1].Value = v_users;
  1006. parms[2].Value = v_name;
  1007. parms[3].Value = v_code;
  1008. parms[4].Value = v_fromDate;
  1009. parms[5].Value = v_toDate;
  1010. parms[6].Value = v_order;
  1011. parms[7].Value = v_rowsOnPage;
  1012. parms[8].Value = v_seqPage;
  1013. return DataAccess.getDataFromProcedure(str, "", parms);
  1014. }
  1015. public static DataSet svAddInsert(string V_CODE, string V_NAME, string V_ADD_TYPE,
  1016. string V_NUMBER_DISPLAY, string V_PRIORITY, string V_SERVICE_ID, string V_NOTE,
  1017. string V_USERS)
  1018. {
  1019. string str;
  1020. str = "";
  1021. str = "BALANCE_PKG.SVADD_INSERT";
  1022. OracleParameter[] parms;
  1023. parms = new OracleParameter[]
  1024. {
  1025. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  1026. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  1027. new OracleParameter("V_ADD_TYPE", OracleDbType.NVarchar2),
  1028. new OracleParameter("V_NUMBER_DISPLAY", OracleDbType.NVarchar2),
  1029. new OracleParameter("V_PRIORITY", OracleDbType.NVarchar2),
  1030. new OracleParameter("V_SERVICE_ID", OracleDbType.NVarchar2),
  1031. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1032. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1033. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1034. };
  1035. parms[0].Value = V_CODE;
  1036. parms[1].Value = V_NAME;
  1037. parms[2].Value = V_ADD_TYPE;
  1038. parms[3].Value = V_NUMBER_DISPLAY;
  1039. parms[4].Value = V_PRIORITY;
  1040. parms[5].Value = V_SERVICE_ID;
  1041. parms[6].Value = V_NOTE;
  1042. parms[7].Value = V_USERS;
  1043. return DataAccess.getDataFromProcedure(str, "", parms);
  1044. }
  1045. public static DataSet svAddUpdate(string V_ID, string V_CODE, string V_NAME, string V_ADD_TYPE,
  1046. string V_NUMBER_DISPLAY, string V_PRIORITY, string V_SERVICE_ID, string V_NOTE, string V_USERS, string V_TYPE)
  1047. {
  1048. string str;
  1049. str = "";
  1050. str = "BALANCE_PKG.SVADD_UPDATE";
  1051. OracleParameter[] parms;
  1052. parms = new OracleParameter[]
  1053. {
  1054. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  1055. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  1056. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  1057. new OracleParameter("V_ADD_TYPE", OracleDbType.NVarchar2),
  1058. new OracleParameter("V_NUMBER_DISPLAY", OracleDbType.NVarchar2),
  1059. new OracleParameter("V_PRIORITY", OracleDbType.NVarchar2),
  1060. new OracleParameter("V_SERVICE_ID", OracleDbType.NVarchar2),
  1061. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1062. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1063. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  1064. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1065. };
  1066. parms[0].Value = V_ID;
  1067. parms[1].Value = V_CODE;
  1068. parms[2].Value = V_NAME;
  1069. parms[3].Value = V_ADD_TYPE;
  1070. parms[4].Value = V_NUMBER_DISPLAY;
  1071. parms[5].Value = V_PRIORITY;
  1072. parms[6].Value = V_SERVICE_ID;
  1073. parms[7].Value = V_NOTE;
  1074. parms[8].Value = V_USERS;
  1075. parms[9].Value = V_TYPE;
  1076. return DataAccess.getDataFromProcedure(str, "", parms);
  1077. }
  1078. public static DataSet camGetList(string v_id, string v_users, string v_name, string v_code, string v_fromDate, string v_toDate
  1079. , string v_order, string v_rowsOnPage, string v_seqPage,string v_status,string isDefault,string isMyservice)
  1080. {
  1081. string str;
  1082. str = "";
  1083. str = "BALANCE_PKG.CAM_GET";
  1084. OracleParameter[] parms;
  1085. parms = new OracleParameter[]
  1086. {
  1087. new OracleParameter("v_id", OracleDbType.NVarchar2),
  1088. new OracleParameter("v_users", OracleDbType.NVarchar2),
  1089. new OracleParameter("v_name", OracleDbType.NVarchar2),
  1090. new OracleParameter("v_code", OracleDbType.NVarchar2),
  1091. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  1092. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  1093. new OracleParameter("v_order", OracleDbType.NVarchar2),
  1094. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  1095. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  1096. new OracleParameter("v_status", OracleDbType.NVarchar2),
  1097. new OracleParameter("v_isDefault", OracleDbType.NVarchar2),
  1098. new OracleParameter("v_isMyservice", OracleDbType.NVarchar2),
  1099. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1100. };
  1101. parms[0].Value = v_id;
  1102. parms[1].Value = v_users;
  1103. parms[2].Value = v_name;
  1104. parms[3].Value = v_code;
  1105. parms[4].Value = v_fromDate;
  1106. parms[5].Value = v_toDate;
  1107. parms[6].Value = v_order;
  1108. parms[7].Value = v_rowsOnPage;
  1109. parms[8].Value = v_seqPage;
  1110. parms[9].Value = v_status;
  1111. parms[10].Value = isDefault;
  1112. parms[11].Value = isMyservice;
  1113. return DataAccess.getDataFromProcedure(str, "", parms);
  1114. }
  1115. public static DataSet camGetListCalendar( string v_users, string v_fromDate, string v_toDate,string status)
  1116. {
  1117. string str;
  1118. str = "";
  1119. str = "BALANCE_PKG.CAM_GET_CALENDAR";
  1120. OracleParameter[] parms;
  1121. parms = new OracleParameter[]
  1122. {
  1123. new OracleParameter("v_users", OracleDbType.NVarchar2),
  1124. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  1125. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  1126. new OracleParameter("v_status", OracleDbType.NVarchar2),
  1127. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1128. };
  1129. parms[0].Value = v_users;
  1130. parms[1].Value = v_fromDate;
  1131. parms[2].Value = v_toDate;
  1132. parms[3].Value = status;
  1133. return DataAccess.getDataFromProcedure(str, "", parms);
  1134. }
  1135. public static DataSet camInsert(string V_CODE, string V_NAME, string V_FROM_DATE,
  1136. string V_TO_DATE, string V_FROM_HOUR, string V_TO_HOUR, string V_RULE_ADD,
  1137. string V_PRIORITY, string V_BALANCE_ID, string V_EXPIRE_DATE_ID, string V_STATUS, string V_NOTE, string V_USERS,string V_NUMBERDIS,string addType,string title,string isDefault,string isMyservice)
  1138. {
  1139. string str;
  1140. str = "";
  1141. str = "BALANCE_PKG.CAM_INSERT";
  1142. OracleParameter[] parms;
  1143. parms = new OracleParameter[]
  1144. {
  1145. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  1146. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  1147. new OracleParameter("V_FROM_DATE", OracleDbType.NVarchar2),
  1148. new OracleParameter("V_TO_DATE", OracleDbType.NVarchar2),
  1149. new OracleParameter("V_FROM_HOUR", OracleDbType.NVarchar2),
  1150. new OracleParameter("V_TO_HOUR", OracleDbType.NVarchar2),
  1151. new OracleParameter("V_RULE_ADD", OracleDbType.NVarchar2),
  1152. new OracleParameter("V_PRIORITY", OracleDbType.NVarchar2),
  1153. new OracleParameter("V_BALANCE_ID", OracleDbType.NVarchar2),
  1154. new OracleParameter("V_EXPIRE_DATE_ID", OracleDbType.NVarchar2),
  1155. new OracleParameter("V_STATUS", OracleDbType.NVarchar2),
  1156. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1157. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1158. new OracleParameter("V_DISPLAY", OracleDbType.NVarchar2),
  1159. new OracleParameter("V_ADD_TYPE", OracleDbType.NVarchar2),
  1160. new OracleParameter("V_TITLE", OracleDbType.NVarchar2),
  1161. new OracleParameter("V_DEFAULT", OracleDbType.NVarchar2),
  1162. new OracleParameter("V_MYSERVICE", OracleDbType.NVarchar2),
  1163. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1164. };
  1165. parms[0].Value = V_CODE;
  1166. parms[1].Value = V_NAME;
  1167. parms[2].Value = V_FROM_DATE;
  1168. parms[3].Value = V_TO_DATE;
  1169. parms[4].Value = V_FROM_HOUR;
  1170. parms[5].Value = V_TO_HOUR;
  1171. parms[6].Value = V_RULE_ADD;
  1172. parms[7].Value = V_PRIORITY;
  1173. parms[8].Value = V_BALANCE_ID;
  1174. parms[9].Value = V_EXPIRE_DATE_ID;
  1175. parms[10].Value = V_STATUS;
  1176. parms[11].Value = V_NOTE;
  1177. parms[12].Value = V_USERS;
  1178. parms[13].Value = V_NUMBERDIS;
  1179. parms[14].Value = addType;
  1180. parms[15].Value = title;
  1181. parms[16].Value = isDefault;
  1182. parms[17].Value = isMyservice;
  1183. return DataAccess.getDataFromProcedure(str, "", parms);
  1184. }
  1185. public static DataSet camUpdate(string V_ID, string V_CODE, string V_NAME, string V_FROM_DATE,
  1186. string V_TO_DATE, string V_FROM_HOUR, string V_TO_HOUR, string V_RULE_ADD,
  1187. string V_PRIORITY, string V_BALANCE_ID, string V_EXPIRE_DATE_ID, string V_STATUS, string V_NOTE, string V_USERS, string V_TYPE,string DISPLAY,string addType,string title,string isDefault,string isMyService)
  1188. {
  1189. string str;
  1190. str = "";
  1191. str = "BALANCE_PKG.CAM_UPDATE";
  1192. OracleParameter[] parms;
  1193. parms = new OracleParameter[]
  1194. {
  1195. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  1196. new OracleParameter("V_CODE", OracleDbType.NVarchar2),
  1197. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  1198. new OracleParameter("V_FROM_DATE", OracleDbType.NVarchar2),
  1199. new OracleParameter("V_TO_DATE", OracleDbType.NVarchar2),
  1200. new OracleParameter("V_FROM_HOUR", OracleDbType.NVarchar2),
  1201. new OracleParameter("V_TO_HOUR", OracleDbType.NVarchar2),
  1202. new OracleParameter("V_RULE_ADD", OracleDbType.NVarchar2),
  1203. new OracleParameter("V_PRIORITY", OracleDbType.NVarchar2),
  1204. new OracleParameter("V_BALANCE_ID", OracleDbType.NVarchar2),
  1205. new OracleParameter("V_EXPIRE_DATE_ID", OracleDbType.NVarchar2),
  1206. new OracleParameter("V_STATUS", OracleDbType.NVarchar2),
  1207. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1208. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1209. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  1210. new OracleParameter("V_DISPLAY", OracleDbType.NVarchar2),
  1211. new OracleParameter("V_ADD_TYPE", OracleDbType.NVarchar2),
  1212. new OracleParameter("V_TITLE", OracleDbType.NVarchar2),
  1213. new OracleParameter("V_DEFAULT", OracleDbType.NVarchar2),
  1214. new OracleParameter("V_MYSERVICE", OracleDbType.NVarchar2),
  1215. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1216. };
  1217. parms[0].Value = V_ID;
  1218. parms[1].Value = V_CODE;
  1219. parms[2].Value = V_NAME;
  1220. parms[3].Value = V_FROM_DATE;
  1221. parms[4].Value = V_TO_DATE;
  1222. parms[5].Value = V_FROM_HOUR;
  1223. parms[6].Value = V_TO_HOUR;
  1224. parms[7].Value = V_RULE_ADD;
  1225. parms[8].Value = V_PRIORITY;
  1226. parms[9].Value = V_BALANCE_ID;
  1227. parms[10].Value = V_EXPIRE_DATE_ID;
  1228. parms[11].Value = V_STATUS;
  1229. parms[12].Value = V_NOTE;
  1230. parms[13].Value = V_USERS;
  1231. parms[14].Value = V_TYPE;
  1232. parms[15].Value = DISPLAY;
  1233. parms[16].Value = addType;
  1234. parms[17].Value = title;
  1235. parms[18].Value = isDefault;
  1236. parms[19].Value = isMyService;
  1237. return DataAccess.getDataFromProcedure(str, "", parms);
  1238. }
  1239. public static DataSet camCopy(string id)
  1240. {
  1241. string str;
  1242. str = "";
  1243. str = "BALANCE_PKG.CAM_COPPY";
  1244. OracleParameter[] parms;
  1245. parms = new OracleParameter[]
  1246. {
  1247. new OracleParameter("v_id", OracleDbType.NVarchar2),
  1248. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1249. };
  1250. parms[0].Value = id;
  1251. return DataAccess.getDataFromProcedure(str, "", parms);
  1252. }
  1253. public static DataSet camBalGetList(string v_id, string v_users, string v_campaignId, string v_fromDate, string v_toDate
  1254. , string v_order, string v_rowsOnPage, string v_seqPage,string channel,string language)
  1255. {
  1256. string str;
  1257. str = "";
  1258. str = "BALANCE_PKG.CAM_BAL_GET";
  1259. OracleParameter[] parms;
  1260. parms = new OracleParameter[]
  1261. {
  1262. new OracleParameter("v_id", OracleDbType.NVarchar2),
  1263. new OracleParameter("v_users", OracleDbType.NVarchar2),
  1264. new OracleParameter("v_campaignId", OracleDbType.NVarchar2),
  1265. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  1266. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  1267. new OracleParameter("v_order", OracleDbType.NVarchar2),
  1268. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  1269. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  1270. new OracleParameter("v_channel", OracleDbType.Varchar2),
  1271. new OracleParameter("v_language", OracleDbType.Varchar2),
  1272. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1273. };
  1274. parms[0].Value = v_id;
  1275. parms[1].Value = v_users;
  1276. parms[2].Value = v_campaignId;
  1277. parms[3].Value = v_fromDate;
  1278. parms[4].Value = v_toDate;
  1279. parms[5].Value = v_order;
  1280. parms[6].Value = v_rowsOnPage;
  1281. parms[7].Value = v_seqPage;
  1282. parms[8].Value = channel;
  1283. parms[9].Value = language;
  1284. return DataAccess.getDataFromProcedure(str, "", parms);
  1285. }
  1286. public static DataSet camBalInsert(string V_CAMPAING_ID, string V_REF_ID, string V_NOTE, string V_USERS, string v_channel
  1287. , string v_language)
  1288. {
  1289. string str;
  1290. str = "";
  1291. str = "BALANCE_PKG.CAM_BAL_INSERT";
  1292. OracleParameter[] parms;
  1293. parms = new OracleParameter[]
  1294. {
  1295. new OracleParameter("V_CAMPAING_ID", OracleDbType.NVarchar2),
  1296. new OracleParameter("V_REF_ID", OracleDbType.NVarchar2),
  1297. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1298. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1299. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  1300. new OracleParameter("v_language", OracleDbType.NVarchar2),
  1301. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1302. };
  1303. parms[0].Value = V_CAMPAING_ID;
  1304. parms[1].Value = V_REF_ID;
  1305. parms[2].Value = V_NOTE;
  1306. parms[3].Value = V_USERS;
  1307. parms[4].Value = v_channel;
  1308. parms[5].Value = v_language;
  1309. return DataAccess.getDataFromProcedure(str, "", parms);
  1310. }
  1311. public static DataSet camBalUpdate(string V_CAMPAING_ID, string V_REF_ID, string V_NOTE, string V_USERS, string v_channel
  1312. , string v_language,string id,string type)
  1313. {
  1314. string str;
  1315. str = "";
  1316. str = "BALANCE_PKG.CAM_BAL_UPDATE";
  1317. OracleParameter[] parms;
  1318. parms = new OracleParameter[]
  1319. {
  1320. new OracleParameter("V_CAMPAING_ID", OracleDbType.NVarchar2),
  1321. new OracleParameter("V_REF_ID", OracleDbType.NVarchar2),
  1322. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1323. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1324. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  1325. new OracleParameter("v_language", OracleDbType.NVarchar2),
  1326. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  1327. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  1328. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1329. };
  1330. parms[0].Value = V_CAMPAING_ID;
  1331. parms[1].Value = V_REF_ID;
  1332. parms[2].Value = V_NOTE;
  1333. parms[3].Value = V_USERS;
  1334. parms[4].Value = v_channel;
  1335. parms[5].Value = v_language;
  1336. parms[6].Value = id;
  1337. parms[7].Value = type;
  1338. return DataAccess.getDataFromProcedure(str, "", parms);
  1339. }
  1340. public static DataSet camSubGetList(string v_id, string v_users, string v_campaignId, string v_fromDate, string v_toDate
  1341. , string v_order, string v_rowsOnPage, string v_seqPage, string channel, string language)
  1342. {
  1343. string str;
  1344. str = "";
  1345. str = "BALANCE_PKG.CAM_SUB_GET";
  1346. OracleParameter[] parms;
  1347. parms = new OracleParameter[]
  1348. {
  1349. new OracleParameter("v_id", OracleDbType.NVarchar2),
  1350. new OracleParameter("v_users", OracleDbType.NVarchar2),
  1351. new OracleParameter("v_campaignId", OracleDbType.NVarchar2),
  1352. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  1353. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  1354. new OracleParameter("v_order", OracleDbType.NVarchar2),
  1355. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  1356. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  1357. new OracleParameter("v_channel", OracleDbType.Varchar2),
  1358. new OracleParameter("v_language", OracleDbType.Varchar2),
  1359. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1360. };
  1361. parms[0].Value = v_id;
  1362. parms[1].Value = v_users;
  1363. parms[2].Value = v_campaignId;
  1364. parms[3].Value = v_fromDate;
  1365. parms[4].Value = v_toDate;
  1366. parms[5].Value = v_order;
  1367. parms[6].Value = v_rowsOnPage;
  1368. parms[7].Value = v_seqPage;
  1369. parms[8].Value = channel;
  1370. parms[9].Value = language;
  1371. return DataAccess.getDataFromProcedure(str, "", parms);
  1372. }
  1373. public static DataSet camSubInsert(string V_CAMPAING_ID, string V_REF_ID, string V_NOTE, string V_USERS, string v_channel
  1374. , string v_language)
  1375. {
  1376. string str;
  1377. str = "";
  1378. str = "BALANCE_PKG.CAM_SUB_INSERT";
  1379. OracleParameter[] parms;
  1380. parms = new OracleParameter[]
  1381. {
  1382. new OracleParameter("V_CAMPAING_ID", OracleDbType.NVarchar2),
  1383. new OracleParameter("V_REF_ID", OracleDbType.NVarchar2),
  1384. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1385. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1386. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  1387. new OracleParameter("v_language", OracleDbType.NVarchar2),
  1388. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1389. };
  1390. parms[0].Value = V_CAMPAING_ID;
  1391. parms[1].Value = V_REF_ID;
  1392. parms[2].Value = V_NOTE;
  1393. parms[3].Value = V_USERS;
  1394. parms[4].Value = v_channel;
  1395. parms[5].Value = v_language;
  1396. return DataAccess.getDataFromProcedure(str, "", parms);
  1397. }
  1398. public static DataSet camSubUpdate(string V_CAMPAING_ID, string V_REF_ID, string V_NOTE, string V_USERS, string v_channel
  1399. , string v_language, string id, string type)
  1400. {
  1401. string str;
  1402. str = "";
  1403. str = "BALANCE_PKG.CAM_SUB_UPDATE";
  1404. OracleParameter[] parms;
  1405. parms = new OracleParameter[]
  1406. {
  1407. new OracleParameter("V_CAMPAING_ID", OracleDbType.NVarchar2),
  1408. new OracleParameter("V_REF_ID", OracleDbType.NVarchar2),
  1409. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1410. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1411. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  1412. new OracleParameter("v_language", OracleDbType.NVarchar2),
  1413. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  1414. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  1415. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1416. };
  1417. parms[0].Value = V_CAMPAING_ID;
  1418. parms[1].Value = V_REF_ID;
  1419. parms[2].Value = V_NOTE;
  1420. parms[3].Value = V_USERS;
  1421. parms[4].Value = v_channel;
  1422. parms[5].Value = v_language;
  1423. parms[6].Value = id;
  1424. parms[7].Value = type;
  1425. return DataAccess.getDataFromProcedure(str, "", parms);
  1426. }
  1427. public static DataSet camExpGetList(string v_id, string v_users, string v_campaignId, string v_fromDate, string v_toDate
  1428. , string v_order, string v_rowsOnPage, string v_seqPage, string channel, string language)
  1429. {
  1430. string str;
  1431. str = "";
  1432. str = "BALANCE_PKG.CAM_EXP_GET";
  1433. OracleParameter[] parms;
  1434. parms = new OracleParameter[]
  1435. {
  1436. new OracleParameter("v_id", OracleDbType.NVarchar2),
  1437. new OracleParameter("v_users", OracleDbType.NVarchar2),
  1438. new OracleParameter("v_campaignId", OracleDbType.NVarchar2),
  1439. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  1440. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  1441. new OracleParameter("v_order", OracleDbType.NVarchar2),
  1442. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  1443. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  1444. new OracleParameter("v_channel", OracleDbType.Varchar2),
  1445. new OracleParameter("v_language", OracleDbType.Varchar2),
  1446. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1447. };
  1448. parms[0].Value = v_id;
  1449. parms[1].Value = v_users;
  1450. parms[2].Value = v_campaignId;
  1451. parms[3].Value = v_fromDate;
  1452. parms[4].Value = v_toDate;
  1453. parms[5].Value = v_order;
  1454. parms[6].Value = v_rowsOnPage;
  1455. parms[7].Value = v_seqPage;
  1456. parms[8].Value = channel;
  1457. parms[9].Value = language;
  1458. return DataAccess.getDataFromProcedure(str, "", parms);
  1459. }
  1460. public static DataSet camExpInsert(string V_CAMPAING_ID, string V_REF_ID, string V_NOTE, string V_USERS, string v_channel
  1461. , string v_language)
  1462. {
  1463. string str;
  1464. str = "";
  1465. str = "BALANCE_PKG.CAM_EXP_INSERT";
  1466. OracleParameter[] parms;
  1467. parms = new OracleParameter[]
  1468. {
  1469. new OracleParameter("V_CAMPAING_ID", OracleDbType.NVarchar2),
  1470. new OracleParameter("V_REF_ID", OracleDbType.NVarchar2),
  1471. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1472. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1473. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  1474. new OracleParameter("v_language", OracleDbType.NVarchar2),
  1475. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1476. };
  1477. parms[0].Value = V_CAMPAING_ID;
  1478. parms[1].Value = V_REF_ID;
  1479. parms[2].Value = V_NOTE;
  1480. parms[3].Value = V_USERS;
  1481. parms[4].Value = v_channel;
  1482. parms[5].Value = v_language;
  1483. return DataAccess.getDataFromProcedure(str, "", parms);
  1484. }
  1485. public static DataSet camExpUpdate(string V_CAMPAING_ID, string V_REF_ID, string V_NOTE, string V_USERS, string v_channel
  1486. , string v_language, string id, string type)
  1487. {
  1488. string str;
  1489. str = "";
  1490. str = "BALANCE_PKG.CAM_EXP_UPDATE";
  1491. OracleParameter[] parms;
  1492. parms = new OracleParameter[]
  1493. {
  1494. new OracleParameter("V_CAMPAING_ID", OracleDbType.NVarchar2),
  1495. new OracleParameter("V_REF_ID", OracleDbType.NVarchar2),
  1496. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1497. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1498. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  1499. new OracleParameter("v_language", OracleDbType.NVarchar2),
  1500. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  1501. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  1502. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1503. };
  1504. parms[0].Value = V_CAMPAING_ID;
  1505. parms[1].Value = V_REF_ID;
  1506. parms[2].Value = V_NOTE;
  1507. parms[3].Value = V_USERS;
  1508. parms[4].Value = v_channel;
  1509. parms[5].Value = v_language;
  1510. parms[6].Value = id;
  1511. parms[7].Value = type;
  1512. return DataAccess.getDataFromProcedure(str, "", parms);
  1513. }
  1514. public static DataSet camScGetList(string v_id, string v_users, string v_campaignId, string v_fromDate, string v_toDate
  1515. , string v_order, string v_rowsOnPage, string v_seqPage, string channel, string language)
  1516. {
  1517. string str;
  1518. str = "";
  1519. str = "BALANCE_PKG.CAM_SC_GET";
  1520. OracleParameter[] parms;
  1521. parms = new OracleParameter[]
  1522. {
  1523. new OracleParameter("v_id", OracleDbType.NVarchar2),
  1524. new OracleParameter("v_users", OracleDbType.NVarchar2),
  1525. new OracleParameter("v_campaignId", OracleDbType.NVarchar2),
  1526. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  1527. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  1528. new OracleParameter("v_order", OracleDbType.NVarchar2),
  1529. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  1530. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  1531. new OracleParameter("v_channel", OracleDbType.Varchar2),
  1532. new OracleParameter("v_language", OracleDbType.Varchar2),
  1533. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1534. };
  1535. parms[0].Value = v_id;
  1536. parms[1].Value = v_users;
  1537. parms[2].Value = v_campaignId;
  1538. parms[3].Value = v_fromDate;
  1539. parms[4].Value = v_toDate;
  1540. parms[5].Value = v_order;
  1541. parms[6].Value = v_rowsOnPage;
  1542. parms[7].Value = v_seqPage;
  1543. parms[8].Value = channel;
  1544. parms[9].Value = language;
  1545. return DataAccess.getDataFromProcedure(str, "", parms);
  1546. }
  1547. public static DataSet camScInsert(string V_CAMPAING_ID, string V_REF_ID, string V_NOTE, string V_USERS, string v_channel
  1548. , string v_language)
  1549. {
  1550. string str;
  1551. str = "";
  1552. str = "BALANCE_PKG.CAM_SC_INSERT";
  1553. OracleParameter[] parms;
  1554. parms = new OracleParameter[]
  1555. {
  1556. new OracleParameter("V_CAMPAING_ID", OracleDbType.NVarchar2),
  1557. new OracleParameter("V_REF_ID", OracleDbType.NVarchar2),
  1558. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1559. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1560. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  1561. new OracleParameter("v_language", OracleDbType.NVarchar2),
  1562. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1563. };
  1564. parms[0].Value = V_CAMPAING_ID;
  1565. parms[1].Value = V_REF_ID;
  1566. parms[2].Value = V_NOTE;
  1567. parms[3].Value = V_USERS;
  1568. parms[4].Value = v_channel;
  1569. parms[5].Value = v_language;
  1570. return DataAccess.getDataFromProcedure(str, "", parms);
  1571. }
  1572. public static DataSet camScUpdate(string V_CAMPAING_ID, string V_REF_ID, string V_NOTE, string V_USERS, string v_channel
  1573. , string v_language, string id, string type)
  1574. {
  1575. string str;
  1576. str = "";
  1577. str = "BALANCE_PKG.CAM_SC_UPDATE";
  1578. OracleParameter[] parms;
  1579. parms = new OracleParameter[]
  1580. {
  1581. new OracleParameter("V_CAMPAING_ID", OracleDbType.NVarchar2),
  1582. new OracleParameter("V_REF_ID", OracleDbType.NVarchar2),
  1583. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1584. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1585. new OracleParameter("v_channel", OracleDbType.NVarchar2),
  1586. new OracleParameter("v_language", OracleDbType.NVarchar2),
  1587. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  1588. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  1589. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1590. };
  1591. parms[0].Value = V_CAMPAING_ID;
  1592. parms[1].Value = V_REF_ID;
  1593. parms[2].Value = V_NOTE;
  1594. parms[3].Value = V_USERS;
  1595. parms[4].Value = v_channel;
  1596. parms[5].Value = v_language;
  1597. parms[6].Value = id;
  1598. parms[7].Value = type;
  1599. return DataAccess.getDataFromProcedure(str, "", parms);
  1600. }
  1601. public static DataSet camAddGetList(string v_id, string v_users, string v_campaignId, string v_fromDate, string v_toDate
  1602. , string v_order, string v_rowsOnPage, string v_seqPage)
  1603. {
  1604. string str;
  1605. str = "";
  1606. str = "BALANCE_PKG.CAMADD_GET";
  1607. OracleParameter[] parms;
  1608. parms = new OracleParameter[]
  1609. {
  1610. new OracleParameter("v_id", OracleDbType.NVarchar2),
  1611. new OracleParameter("v_users", OracleDbType.NVarchar2),
  1612. new OracleParameter("v_campaignId", OracleDbType.NVarchar2),
  1613. new OracleParameter("v_fromDate", OracleDbType.NVarchar2),
  1614. new OracleParameter("v_toDate", OracleDbType.NVarchar2),
  1615. new OracleParameter("v_order", OracleDbType.NVarchar2),
  1616. new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2),
  1617. new OracleParameter("v_seqPage", OracleDbType.NVarchar2),
  1618. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1619. };
  1620. parms[0].Value = v_id;
  1621. parms[1].Value = v_users;
  1622. parms[2].Value = v_campaignId;
  1623. parms[3].Value = v_fromDate;
  1624. parms[4].Value = v_toDate;
  1625. parms[5].Value = v_order;
  1626. parms[6].Value = v_rowsOnPage;
  1627. parms[7].Value = v_seqPage;
  1628. return DataAccess.getDataFromProcedure(str, "", parms);
  1629. }
  1630. public static DataSet camAddInsert(string V_CAMPAING_ID, string V_SERVICE_ADD_ID, string V_NOTE, string V_USERS,
  1631. string ussdDisplay,string keyRegister,string msgConfirm)
  1632. {
  1633. string str;
  1634. str = "";
  1635. str = "BALANCE_PKG.CAMADD_INSERT";
  1636. OracleParameter[] parms;
  1637. parms = new OracleParameter[]
  1638. {
  1639. new OracleParameter("V_CAMPAING_ID", OracleDbType.NVarchar2),
  1640. new OracleParameter("V_SERVICE_ADD_ID", OracleDbType.NVarchar2),
  1641. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1642. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1643. new OracleParameter("V_USSD_DIS", OracleDbType.NVarchar2),
  1644. new OracleParameter("V_KEY_REGIS", OracleDbType.NVarchar2),
  1645. new OracleParameter("V_MSG_CONFIRM", OracleDbType.NVarchar2),
  1646. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1647. };
  1648. parms[0].Value = V_CAMPAING_ID;
  1649. parms[1].Value = V_SERVICE_ADD_ID;
  1650. parms[2].Value = V_NOTE;
  1651. parms[3].Value = V_USERS;
  1652. parms[4].Value = ussdDisplay;
  1653. parms[5].Value = keyRegister;
  1654. parms[6].Value = msgConfirm;
  1655. return DataAccess.getDataFromProcedure(str, "", parms);
  1656. }
  1657. public static DataSet camAddUpdate(string V_ID, string V_CAMPAING_ID, string V_SERVICE_ADD_ID, string V_NOTE,
  1658. string V_USERS, string V_TYPE,string ussdDisplay,string keyRegister, string msgConfirm)
  1659. {
  1660. string str;
  1661. str = "";
  1662. str = "BALANCE_PKG.CAMADD_UPDATE";
  1663. OracleParameter[] parms;
  1664. parms = new OracleParameter[]
  1665. {
  1666. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  1667. new OracleParameter("V_CAMPAING_ID", OracleDbType.NVarchar2),
  1668. new OracleParameter("V_SERVICE_ADD_ID", OracleDbType.NVarchar2),
  1669. new OracleParameter("V_NOTE", OracleDbType.NVarchar2),
  1670. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1671. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  1672. new OracleParameter("V_USSD_DIS", OracleDbType.NVarchar2),
  1673. new OracleParameter("V_KEY_REGIS", OracleDbType.NVarchar2),
  1674. new OracleParameter("V_MSG_CONFIRM", OracleDbType.NVarchar2),
  1675. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1676. };
  1677. parms[0].Value = V_ID;
  1678. parms[1].Value = V_CAMPAING_ID;
  1679. parms[2].Value = V_SERVICE_ADD_ID;
  1680. parms[3].Value = V_NOTE;
  1681. parms[4].Value = V_USERS;
  1682. parms[5].Value = V_TYPE;
  1683. parms[6].Value = ussdDisplay;
  1684. parms[7].Value = keyRegister;
  1685. parms[8].Value = msgConfirm;
  1686. return DataAccess.getDataFromProcedure(str, "", parms);
  1687. }
  1688. public static DataSet ADMIN_USERS_FUNCTION(string role)
  1689. {
  1690. // {"msisdn":"50940227941","users":"123","pass":"123","serviceId":"23","type":"DK","channel":"WEB"}
  1691. string str;
  1692. str = "";
  1693. str = "BALANCE_PKG.ADMIN_GET_ROLE";
  1694. OracleParameter[] parms;
  1695. parms = new OracleParameter[]
  1696. {
  1697. new OracleParameter("v_role", OracleDbType.NVarchar2),
  1698. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1699. };
  1700. parms[0].Value = role;
  1701. return DataAccess.getDataFromProcedure(str, "", parms);
  1702. }
  1703. public static DataSet ADMIN_USERS_INFO(string v_users, string v_pass)
  1704. {
  1705. // {"msisdn":"50940227941","users":"123","pass":"123","serviceId":"23","type":"DK","channel":"WEB"}
  1706. string str;
  1707. str = "";
  1708. str = "BALANCE_PKG.ADMIN_LOGIN";
  1709. OracleParameter[] parms;
  1710. parms = new OracleParameter[]
  1711. {
  1712. new OracleParameter("v_user", OracleDbType.NVarchar2),
  1713. new OracleParameter("v_pass", OracleDbType.NVarchar2),
  1714. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1715. };
  1716. parms[0].Value = v_users;
  1717. parms[1].Value = v_pass;
  1718. return DataAccess.getDataFromProcedure(str, "", parms);
  1719. }
  1720. public static DataSet callCheckDB()
  1721. {
  1722. string str;
  1723. str = "";
  1724. str = "BALANCE_PKG.ADMIN_CHECKDB";
  1725. OracleParameter[] parms;
  1726. parms = new OracleParameter[]
  1727. {
  1728. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1729. };
  1730. return DataAccess.getDataFromProcedure(str, "", parms);
  1731. }
  1732. public static DataSet ngamGetList(string v_id, string v_users)
  1733. {
  1734. string str;
  1735. str = "";
  1736. str = "BALANCE_PKG.TMP_GET";
  1737. OracleParameter[] parms;
  1738. parms = new OracleParameter[]
  1739. {
  1740. new OracleParameter("v_id", OracleDbType.NVarchar2),
  1741. new OracleParameter("v_users", OracleDbType.NVarchar2),
  1742. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1743. };
  1744. parms[0].Value = v_id;
  1745. parms[1].Value = v_users;
  1746. return DataAccess.getDataFromProcedure(str, "", parms);
  1747. }
  1748. public static DataSet ngamInsert(string V_NAME, string V_SV, string V_MSG,
  1749. string V_FD, string V_TD, string V_PC, string V_ADD_TYPE, string V_USERS)
  1750. {
  1751. string str;
  1752. str = "";
  1753. str = "BALANCE_PKG.TMP_INSERT";
  1754. OracleParameter[] parms;
  1755. parms = new OracleParameter[]
  1756. {
  1757. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  1758. new OracleParameter("V_SV", OracleDbType.NVarchar2),
  1759. new OracleParameter("V_MSG", OracleDbType.NVarchar2),
  1760. new OracleParameter("V_FD", OracleDbType.NVarchar2),
  1761. new OracleParameter("V_TD", OracleDbType.NVarchar2),
  1762. new OracleParameter("V_PC", OracleDbType.NVarchar2),
  1763. new OracleParameter("V_ADD_TYPE", OracleDbType.NVarchar2),
  1764. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1765. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1766. };
  1767. parms[0].Value = V_NAME;
  1768. parms[1].Value = V_SV;
  1769. parms[2].Value = V_MSG;
  1770. parms[3].Value = V_FD;
  1771. parms[4].Value = V_TD;
  1772. parms[5].Value = V_PC;
  1773. parms[6].Value = V_ADD_TYPE;
  1774. parms[7].Value = V_USERS;
  1775. return DataAccess.getDataFromProcedure(str, "", parms);
  1776. }
  1777. public static DataSet ngamUpdate(string V_ID, string V_NAME, string V_SV, string V_MSG,
  1778. string V_FD, string V_TD, string V_PC, string V_ADD_TYPE, string V_USERS, string V_TYPE)
  1779. {
  1780. string str;
  1781. str = "";
  1782. str = "BALANCE_PKG.TMP_UPDATE";
  1783. OracleParameter[] parms;
  1784. parms = new OracleParameter[]
  1785. {
  1786. new OracleParameter("V_ID", OracleDbType.NVarchar2),
  1787. new OracleParameter("V_NAME", OracleDbType.NVarchar2),
  1788. new OracleParameter("V_SV", OracleDbType.NVarchar2),
  1789. new OracleParameter("V_MSG", OracleDbType.NVarchar2),
  1790. new OracleParameter("V_FD", OracleDbType.NVarchar2),
  1791. new OracleParameter("V_TD", OracleDbType.NVarchar2),
  1792. new OracleParameter("V_PC", OracleDbType.NVarchar2),
  1793. new OracleParameter("V_ADD_TYPE", OracleDbType.NVarchar2),
  1794. new OracleParameter("V_USERS", OracleDbType.NVarchar2),
  1795. new OracleParameter("V_TYPE", OracleDbType.NVarchar2),
  1796. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1797. };
  1798. parms[0].Value = V_ID;
  1799. parms[1].Value = V_NAME;
  1800. parms[2].Value = V_SV;
  1801. parms[3].Value = V_MSG;
  1802. parms[4].Value = V_FD;
  1803. parms[5].Value = V_TD;
  1804. parms[6].Value = V_PC;
  1805. parms[7].Value = V_ADD_TYPE;
  1806. parms[8].Value = V_USERS;
  1807. parms[9].Value = V_TYPE;
  1808. return DataAccess.getDataFromProcedure(str, "", parms);
  1809. }
  1810. public static DataSet blackGettList(string msisdn,string type,string svid, string v_users)
  1811. {
  1812. string str;
  1813. str = "";
  1814. str = "BALANCE_PKG.BLACK_GET";
  1815. OracleParameter[] parms;
  1816. parms = new OracleParameter[]
  1817. {
  1818. new OracleParameter("v_msisdn", OracleDbType.NVarchar2),
  1819. new OracleParameter("v_type", OracleDbType.NVarchar2),
  1820. new OracleParameter("v_sv_id", OracleDbType.NVarchar2),
  1821. new OracleParameter("v_users", OracleDbType.NVarchar2),
  1822. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1823. };
  1824. parms[0].Value = msisdn;
  1825. parms[1].Value = type;
  1826. parms[2].Value = svid;
  1827. parms[3].Value = v_users;
  1828. return DataAccess.getDataFromProcedure(str, "", parms);
  1829. }
  1830. public static DataSet lkpw_result_update(string v_randomId, string v_users, string v_result, string v_status, string v_note)
  1831. {
  1832. string str;
  1833. str = "";
  1834. str = "LOTO_CMS_PKG.lkpw_result_update";
  1835. OracleParameter[] parms;
  1836. parms = new OracleParameter[]
  1837. {
  1838. new OracleParameter("v_randomId", OracleDbType.NVarchar2),
  1839. new OracleParameter("v_users", OracleDbType.NVarchar2),
  1840. new OracleParameter("v_result", OracleDbType.NVarchar2),
  1841. new OracleParameter("v_status", OracleDbType.NVarchar2),
  1842. new OracleParameter("v_note", OracleDbType.NVarchar2),
  1843. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1844. };
  1845. parms[0].Value = v_randomId;
  1846. parms[1].Value = v_users;
  1847. parms[2].Value = v_result;
  1848. parms[3].Value = v_status;
  1849. parms[4].Value = v_note;
  1850. return DataAccess.getDataFromProcedure(str, "", parms);
  1851. }
  1852. public static void InsertBulkExport(string sSQL, List<List<string>> dataColumn)
  1853. {
  1854. OracleConnection connection = null;
  1855. try
  1856. {
  1857. connection =DataAccess.getPoolingConnection();
  1858. connection.Open();
  1859. OracleTransaction transaction;
  1860. // Start a local transaction
  1861. transaction = connection.BeginTransaction(IsolationLevel.ReadCommitted);
  1862. using (var command = connection.CreateCommand())
  1863. {
  1864. command.CommandText = sSQL;
  1865. command.CommandType = CommandType.StoredProcedure;
  1866. command.ArrayBindCount = dataColumn[0].Count;
  1867. command.Transaction = transaction;
  1868. var v_export_id = dataColumn[0].ToArray();
  1869. OracleParameter param0 = new OracleParameter("v_export_id", OracleDbType.NVarchar2, ParameterDirection.Input);
  1870. param0.Value = v_export_id;
  1871. param0.Size = v_export_id.Length;
  1872. command.Parameters.Add(param0);
  1873. var v_winner_id = dataColumn[1].ToArray();
  1874. OracleParameter param1 = new OracleParameter("v_winner_id", OracleDbType.NVarchar2, ParameterDirection.Input);
  1875. param1.Value = v_winner_id;
  1876. param1.Size = v_winner_id.Length;
  1877. command.Parameters.Add(param1);
  1878. var v_msisdn = dataColumn[2].ToArray();
  1879. OracleParameter param2 = new OracleParameter("v_msisdn", OracleDbType.NVarchar2, ParameterDirection.Input);
  1880. param2.Value = v_msisdn;
  1881. param2.Size = v_msisdn.Length;
  1882. command.Parameters.Add(param2);
  1883. var v_money = dataColumn[3].ToArray();
  1884. OracleParameter param3 = new OracleParameter("v_money", OracleDbType.NVarchar2, ParameterDirection.Input);
  1885. param3.Value = v_money;
  1886. param3.Size = v_money.Length;
  1887. command.Parameters.Add(param3);
  1888. var v_random_id = dataColumn[4].ToArray();
  1889. OracleParameter param4 = new OracleParameter("v_random_id", OracleDbType.NVarchar2, ParameterDirection.Input);
  1890. param4.Value = v_random_id;
  1891. param4.Size = v_random_id.Length;
  1892. command.Parameters.Add(param4);
  1893. var v_bet_id = dataColumn[5].ToArray();
  1894. OracleParameter param5 = new OracleParameter("v_bet_id", OracleDbType.NVarchar2, ParameterDirection.Input);
  1895. param5.Value = v_bet_id;
  1896. param5.Size = v_bet_id.Length;
  1897. command.Parameters.Add(param5);
  1898. var v_winner_code = dataColumn[6].ToArray();
  1899. OracleParameter param6 = new OracleParameter("v_winner_code", OracleDbType.NVarchar2, ParameterDirection.Input);
  1900. param6.Value = v_winner_code;
  1901. param6.Size = v_winner_code.Length;
  1902. command.Parameters.Add(param6);
  1903. command.ExecuteNonQuery();
  1904. transaction.Commit();
  1905. }
  1906. }
  1907. catch (OracleException ex)
  1908. {
  1909. Console.WriteLine(ex.ToString());
  1910. throw;
  1911. }
  1912. finally
  1913. {
  1914. connection.Close();
  1915. }
  1916. }
  1917. public static void InsertBulkBlack(string sSQL, List<List<string>> dataColumn)
  1918. {
  1919. OracleConnection connection = null;
  1920. try
  1921. {
  1922. connection = DataAccess.getPoolingConnection();
  1923. connection.Open();
  1924. OracleTransaction transaction;
  1925. // Start a local transaction
  1926. transaction = connection.BeginTransaction(IsolationLevel.ReadCommitted);
  1927. using (var command = connection.CreateCommand())
  1928. {
  1929. command.CommandText = sSQL;
  1930. command.CommandType = CommandType.StoredProcedure;
  1931. command.ArrayBindCount = dataColumn[0].Count;
  1932. command.Transaction = transaction;
  1933. var v_users = dataColumn[0].ToArray();
  1934. OracleParameter param0 = new OracleParameter("v_users", OracleDbType.NVarchar2, ParameterDirection.Input);
  1935. param0.Value = v_users;
  1936. param0.Size = v_users.Length;
  1937. command.Parameters.Add(param0);
  1938. var v_msisdn = dataColumn[1].ToArray();
  1939. OracleParameter param1 = new OracleParameter("v_msisdn", OracleDbType.NVarchar2, ParameterDirection.Input);
  1940. param1.Value = v_msisdn;
  1941. param1.Size = v_msisdn.Length;
  1942. command.Parameters.Add(param1);
  1943. var v_isLock = dataColumn[2].ToArray();
  1944. OracleParameter param2 = new OracleParameter("v_isLock", OracleDbType.NVarchar2, ParameterDirection.Input);
  1945. param2.Value = v_isLock;
  1946. param2.Size = v_isLock.Length;
  1947. command.Parameters.Add(param2);
  1948. var v_note = dataColumn[3].ToArray();
  1949. OracleParameter param3 = new OracleParameter("v_note", OracleDbType.NVarchar2, ParameterDirection.Input);
  1950. param3.Value = v_note;
  1951. param3.Size = v_note.Length;
  1952. command.Parameters.Add(param3);
  1953. command.ExecuteNonQuery();
  1954. transaction.Commit();
  1955. }
  1956. }
  1957. catch (OracleException ex)
  1958. {
  1959. Console.WriteLine(ex.ToString());
  1960. throw;
  1961. }
  1962. finally
  1963. {
  1964. connection.Close();
  1965. }
  1966. }
  1967. public static DataSet reload( string V_TYPE, string V_USERS)
  1968. {
  1969. string str;
  1970. str = "";
  1971. str = "BALANCE_PKG.pro_get_update";
  1972. OracleParameter[] parms;
  1973. parms = new OracleParameter[]
  1974. {
  1975. new OracleParameter("v_prId", OracleDbType.NVarchar2),
  1976. new OracleParameter("v_user", OracleDbType.NVarchar2),
  1977. new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output),
  1978. };
  1979. parms[0].Value = V_TYPE;
  1980. parms[1].Value = V_USERS;
  1981. return DataAccess.getDataFromProcedure(str, "", parms);
  1982. }
  1983. public static DataSet apiServiceLoad(string v_id, string v_users,string v_order, string v_rowsOnPage, string v_seqPage,string v_isactive)
  1984. {
  1985. DataSet ds = new DataSet();
  1986. OracleConnection dbConnection = DataAccess.getPoolingConnection();
  1987. try
  1988. {
  1989. dbConnection.Open();
  1990. // Parse pagination parameters
  1991. int rowsOnPage = int.TryParse(v_rowsOnPage, out int r) ? r : 10;
  1992. int seqPage = int.TryParse(v_seqPage, out int s) ? s : 1;
  1993. // Build base query for counting total records
  1994. string countSql = "SELECT COUNT(*) FROM WEBSERVICE WHERE 1=1";
  1995. string dataSql = "SELECT WS_ID, WS_NAME, WS_CODE, WSDL, MSG_TEMPLATE, ERROR_TAG, SUCCESS_CODE, STATUS FROM WEBSERVICE WHERE 1=1";
  1996. // Add filters
  1997. if (v_id != null && v_id != "-1")
  1998. {
  1999. countSql += " AND WS_ID = :v_id";
  2000. dataSql += " AND WS_ID = :v_id";
  2001. }
  2002. if (v_isactive != null && v_isactive != "-1")
  2003. {
  2004. countSql += " AND STATUS = :v_isactive";
  2005. dataSql += " AND STATUS = :v_isactive";
  2006. }
  2007. // Add ordering
  2008. dataSql += " ORDER BY WS_ID " + (v_order == "desc" ? "DESC" : "ASC");
  2009. // Calculate pagination
  2010. OracleCommand countCmd = new OracleCommand(countSql, dbConnection);
  2011. countCmd.CommandType = CommandType.Text;
  2012. if (v_id != null && v_id != "-1")
  2013. {
  2014. countCmd.Parameters.Add(":v_id", OracleDbType.NVarchar2).Value = v_id;
  2015. }
  2016. if (v_isactive != null && v_isactive != "-1")
  2017. {
  2018. countCmd.Parameters.Add(":v_isactive", OracleDbType.NVarchar2).Value = v_isactive;
  2019. }
  2020. int totalRows = Convert.ToInt32(countCmd.ExecuteScalar());
  2021. int totalPage = (int)Math.Ceiling((double)totalRows / rowsOnPage);
  2022. // Get paginated data
  2023. int minRow = (seqPage - 1) * rowsOnPage;
  2024. dataSql = string.Format(@"SELECT * FROM (
  2025. SELECT A.*, ROWNUM rnum FROM ({0}) A WHERE ROWNUM <= {1}
  2026. ) WHERE rnum > {2}", dataSql, minRow + rowsOnPage, minRow);
  2027. OracleCommand dataCmd = new OracleCommand(dataSql, dbConnection);
  2028. dataCmd.CommandType = CommandType.Text;
  2029. if (v_id != null && v_id != "-1")
  2030. {
  2031. dataCmd.Parameters.Add(":v_id", OracleDbType.NVarchar2).Value = v_id;
  2032. }
  2033. if (v_isactive != null && v_isactive != "-1")
  2034. {
  2035. dataCmd.Parameters.Add(":v_isactive", OracleDbType.NVarchar2).Value = v_isactive;
  2036. }
  2037. OracleDataAdapter dataAdapter = new OracleDataAdapter(dataCmd);
  2038. dataAdapter.Fill(ds);
  2039. // Add pagination metadata to each row
  2040. if (ds.Tables[0].Columns.Contains("ROW_ON_PAGE"))
  2041. {
  2042. ds.Tables[0].Columns.Remove("ROW_ON_PAGE");
  2043. }
  2044. if (ds.Tables[0].Columns.Contains("SEQ_PAGE"))
  2045. {
  2046. ds.Tables[0].Columns.Remove("SEQ_PAGE");
  2047. }
  2048. if (ds.Tables[0].Columns.Contains("TOTAL_PAGE"))
  2049. {
  2050. ds.Tables[0].Columns.Remove("TOTAL_PAGE");
  2051. }
  2052. ds.Tables[0].Columns.Add("ROW_ON_PAGE", typeof(string));
  2053. ds.Tables[0].Columns.Add("SEQ_PAGE", typeof(string));
  2054. ds.Tables[0].Columns.Add("TOTAL_PAGE", typeof(string));
  2055. ds.Tables[0].Columns.Add("IS_ACTIVE", typeof(string));
  2056. foreach (DataRow row in ds.Tables[0].Rows)
  2057. {
  2058. row["ROW_ON_PAGE"] = rowsOnPage.ToString();
  2059. row["SEQ_PAGE"] = seqPage.ToString();
  2060. row["TOTAL_PAGE"] = totalPage.ToString();
  2061. row["IS_ACTIVE"] = row["STATUS"].ToString();
  2062. }
  2063. }
  2064. catch (OracleException ex)
  2065. {
  2066. throw ex;
  2067. }
  2068. catch (Exception ex)
  2069. {
  2070. throw ex;
  2071. }
  2072. finally
  2073. {
  2074. dbConnection.Close();
  2075. }
  2076. return ds;
  2077. }
  2078. public static DataSet apiServiceInsert(string ws_name, string ws_code, string wsdl, string msg_template, string error_tag, string success_code, string isActive, string users)
  2079. {
  2080. DataSet ds = new DataSet();
  2081. DataTable tb = new DataTable();
  2082. tb.Columns.Add("status", typeof(string));
  2083. tb.Columns.Add("msg", typeof(string));
  2084. OracleConnection dbConnection = DataAccess.getPoolingConnection();
  2085. try
  2086. {
  2087. dbConnection.Open();
  2088. string sql = @"INSERT INTO WEBSERVICE(WS_ID, WS_NAME, WS_CODE, WSDL, MSG_TEMPLATE, ERROR_TAG, SUCCESS_CODE, STATUS)
  2089. VALUES(WEBSERVICE_SEQ.NEXTVAL, :ws_name, :ws_code, :wsdl, :msg_template, :error_tag, :success_code, :status)";
  2090. using (OracleCommand cmd = new OracleCommand(sql, dbConnection))
  2091. {
  2092. cmd.CommandType = CommandType.Text;
  2093. cmd.Parameters.Add(":ws_name", OracleDbType.NVarchar2).Value = ws_name ?? "";
  2094. cmd.Parameters.Add(":ws_code", OracleDbType.NVarchar2).Value = ws_code ?? "";
  2095. cmd.Parameters.Add(":wsdl", OracleDbType.NVarchar2).Value = wsdl ?? "";
  2096. cmd.Parameters.Add(":msg_template", OracleDbType.NVarchar2).Value = msg_template ?? "";
  2097. cmd.Parameters.Add(":error_tag", OracleDbType.NVarchar2).Value = error_tag ?? "";
  2098. cmd.Parameters.Add(":success_code", OracleDbType.NVarchar2).Value = success_code ?? "";
  2099. cmd.Parameters.Add(":status", OracleDbType.Int32).Value = (isActive == "0" ? 0 : 1);
  2100. int affected = cmd.ExecuteNonQuery();
  2101. // get generated id in this session
  2102. string newId = "";
  2103. try
  2104. {
  2105. using (OracleCommand idCmd = new OracleCommand("SELECT WEBSERVICE_SEQ.CURRVAL FROM DUAL", dbConnection))
  2106. {
  2107. object val = idCmd.ExecuteScalar();
  2108. newId = val == null ? "" : Convert.ToString(val);
  2109. }
  2110. }
  2111. catch { }
  2112. var row = tb.NewRow();
  2113. row["status"] = affected > 0 ? "0" : "-1";
  2114. row["msg"] = affected > 0 ? ("Success" + (newId!=""? ("|"+newId):"")) : "Insert failed";
  2115. tb.Rows.Add(row);
  2116. }
  2117. }
  2118. catch (Exception ex)
  2119. {
  2120. var row = tb.NewRow();
  2121. row["status"] = "-1";
  2122. row["msg"] = ex.Message;
  2123. tb.Rows.Add(row);
  2124. }
  2125. finally
  2126. {
  2127. dbConnection.Close();
  2128. }
  2129. ds.Tables.Add(tb);
  2130. return ds;
  2131. }
  2132. public static DataSet apiServiceUpdate(string id, string ws_name, string ws_code, string wsdl, string msg_template, string error_tag, string success_code, string isActive, string users)
  2133. {
  2134. DataSet ds = new DataSet();
  2135. DataTable tb = new DataTable();
  2136. tb.Columns.Add("status", typeof(string));
  2137. tb.Columns.Add("msg", typeof(string));
  2138. OracleConnection dbConnection = DataAccess.getPoolingConnection();
  2139. try
  2140. {
  2141. dbConnection.Open();
  2142. string sql = @"UPDATE WEBSERVICE
  2143. SET WS_NAME = :ws_name,
  2144. WS_CODE = :ws_code,
  2145. WSDL = :wsdl,
  2146. MSG_TEMPLATE = :msg_template,
  2147. ERROR_TAG = :error_tag,
  2148. SUCCESS_CODE = :success_code,
  2149. STATUS = :status
  2150. WHERE WS_ID = :id";
  2151. using (OracleCommand cmd = new OracleCommand(sql, dbConnection))
  2152. {
  2153. cmd.CommandType = CommandType.Text;
  2154. cmd.Parameters.Add(":ws_name", OracleDbType.NVarchar2).Value = ws_name ?? "";
  2155. cmd.Parameters.Add(":ws_code", OracleDbType.NVarchar2).Value = ws_code ?? "";
  2156. cmd.Parameters.Add(":wsdl", OracleDbType.NVarchar2).Value = wsdl ?? "";
  2157. cmd.Parameters.Add(":msg_template", OracleDbType.NVarchar2).Value = msg_template ?? "";
  2158. cmd.Parameters.Add(":error_tag", OracleDbType.NVarchar2).Value = error_tag ?? "";
  2159. cmd.Parameters.Add(":success_code", OracleDbType.NVarchar2).Value = success_code ?? "";
  2160. cmd.Parameters.Add(":status", OracleDbType.Int32).Value = (isActive == "0" ? 0 : 1);
  2161. cmd.Parameters.Add(":id", OracleDbType.NVarchar2).Value = id ?? "";
  2162. int affected = cmd.ExecuteNonQuery();
  2163. var row = tb.NewRow();
  2164. row["status"] = affected > 0 ? "0" : "-1";
  2165. row["msg"] = affected > 0 ? "Success" : "Update failed";
  2166. tb.Rows.Add(row);
  2167. }
  2168. }
  2169. catch (Exception ex)
  2170. {
  2171. var row = tb.NewRow();
  2172. row["status"] = "-1";
  2173. row["msg"] = ex.Message;
  2174. tb.Rows.Add(row);
  2175. }
  2176. finally
  2177. {
  2178. dbConnection.Close();
  2179. }
  2180. ds.Tables.Add(tb);
  2181. return ds;
  2182. }
  2183. public static DataSet GET_HOURLY_IMPRESSIONS(string v_campaignId, string v_serviceId, string v_hours, string v_quickJump)
  2184. {
  2185. DataSet ds = new DataSet();
  2186. OracleConnection dbConnection = DataAccess.getPoolingConnection();
  2187. try
  2188. {
  2189. dbConnection.Open();
  2190. // Calculate date range based on hours parameter (default 72 hours)
  2191. int hours = 72;
  2192. if (!string.IsNullOrEmpty(v_hours) && v_hours != "-1" && v_hours != "All")
  2193. {
  2194. hours = int.TryParse(v_hours.Replace("h", ""), out int h) ? h : 72;
  2195. }
  2196. DateTime endDate = DateTime.Now;
  2197. DateTime startDate = endDate.AddHours(-hours);
  2198. // If quickJump is provided, use it as the center point
  2199. if (!string.IsNullOrEmpty(v_quickJump) && v_quickJump != "-1")
  2200. {
  2201. if (DateTime.TryParseExact(v_quickJump, "yyyy-MM-dd HH", null, System.Globalization.DateTimeStyles.None, out DateTime jumpDate))
  2202. {
  2203. startDate = jumpDate.AddHours(-hours / 2);
  2204. endDate = jumpDate.AddHours(hours / 2);
  2205. }
  2206. }
  2207. // Build WHERE clause
  2208. string whereClause = "WHERE TRUNC(REPORT_DATE, 'HH') >= TRUNC(:startDate, 'HH') AND TRUNC(REPORT_DATE, 'HH') <= TRUNC(:endDate, 'HH')";
  2209. if (!string.IsNullOrEmpty(v_campaignId) && v_campaignId != "-1" && v_campaignId != "All")
  2210. {
  2211. whereClause += " AND CAMPAIGN_ID = :campaignId";
  2212. }
  2213. if (!string.IsNullOrEmpty(v_serviceId) && v_serviceId != "-1" && v_serviceId != "All")
  2214. {
  2215. whereClause += " AND SERVICE_ID = :serviceId";
  2216. }
  2217. // Build SQL with subquery first, then LEFT JOIN
  2218. // Always group by CAMPAIGN_ID to show each campaign separately, even when "All" is selected
  2219. string sql = @"SELECT
  2220. base.HOUR_LABEL,
  2221. base.HOUR_VALUE,
  2222. base.CAMPAIGN_ID,
  2223. c.NAME AS CAMPAIGN_NAME,
  2224. base.COUNT_IMPRESSED
  2225. FROM (
  2226. SELECT
  2227. TO_CHAR(TRUNC(REPORT_DATE, 'HH'), 'YYYY-MM-DD HH24') AS HOUR_LABEL,
  2228. TO_CHAR(TRUNC(REPORT_DATE, 'HH'), 'YYYY-MM-DD HH24:MI:SS') AS HOUR_VALUE,
  2229. CAMPAIGN_ID,
  2230. SUM(NVL(COUNT_SEND_1, 0)) AS COUNT_IMPRESSED
  2231. FROM REPORT_COUNT_HOURLY
  2232. " + whereClause + @"
  2233. GROUP BY
  2234. TRUNC(REPORT_DATE, 'HH'),
  2235. CAMPAIGN_ID
  2236. ) base
  2237. LEFT JOIN B_CAMPAIGN c ON base.CAMPAIGN_ID = c.ID
  2238. ORDER BY base.HOUR_VALUE, base.CAMPAIGN_ID";
  2239. using (OracleCommand cmd = new OracleCommand(sql, dbConnection))
  2240. {
  2241. cmd.CommandType = CommandType.Text;
  2242. cmd.Parameters.Add(":startDate", OracleDbType.Date).Value = startDate;
  2243. cmd.Parameters.Add(":endDate", OracleDbType.Date).Value = endDate;
  2244. if (!string.IsNullOrEmpty(v_campaignId) && v_campaignId != "-1" && v_campaignId != "All")
  2245. {
  2246. cmd.Parameters.Add(":campaignId", OracleDbType.NVarchar2).Value = v_campaignId;
  2247. }
  2248. if (!string.IsNullOrEmpty(v_serviceId) && v_serviceId != "-1" && v_serviceId != "All")
  2249. {
  2250. cmd.Parameters.Add(":serviceId", OracleDbType.NVarchar2).Value = v_serviceId;
  2251. }
  2252. OracleDataAdapter adapter = new OracleDataAdapter(cmd);
  2253. adapter.Fill(ds);
  2254. }
  2255. }
  2256. catch (Exception ex)
  2257. {
  2258. throw ex;
  2259. }
  2260. finally
  2261. {
  2262. dbConnection.Close();
  2263. }
  2264. return ds;
  2265. }
  2266. public static DataSet GET_DAILY_IMPRESSIONS(string v_campaignId, string v_fromDate, string v_toDate)
  2267. {
  2268. DataSet ds = new DataSet();
  2269. OracleConnection dbConnection = DataAccess.getPoolingConnection();
  2270. try
  2271. {
  2272. dbConnection.Open();
  2273. // Build WHERE clause
  2274. string whereClause = "WHERE 1=1";
  2275. if (!string.IsNullOrEmpty(v_fromDate) && v_fromDate != "-1")
  2276. {
  2277. whereClause += " AND TRUNC(REPORT_DATE) >= TRUNC(TO_DATE(:fromDate, 'DD/MM/YYYY'))";
  2278. }
  2279. if (!string.IsNullOrEmpty(v_toDate) && v_toDate != "-1")
  2280. {
  2281. whereClause += " AND TRUNC(REPORT_DATE) <= TRUNC(TO_DATE(:toDate, 'DD/MM/YYYY'))";
  2282. }
  2283. if (!string.IsNullOrEmpty(v_campaignId) && v_campaignId != "-1" && v_campaignId != "All")
  2284. {
  2285. whereClause += " AND CAMPAIGN_ID = :campaignId";
  2286. }
  2287. // Build SQL with subquery first, then LEFT JOIN
  2288. // Group by date and campaign to show each campaign separately
  2289. // Using REPORT_COUNT_DAILY table with REPORT_DATE and COUNT_SEND_1
  2290. string sql = @"SELECT
  2291. base.DAY_LABEL,
  2292. base.DAY_VALUE,
  2293. base.CAMPAIGN_ID,
  2294. c.NAME AS CAMPAIGN_NAME,
  2295. base.COUNT_IMPRESSED
  2296. FROM (
  2297. SELECT
  2298. TO_CHAR(TRUNC(REPORT_DATE), 'YYYY-MM-DD') AS DAY_LABEL,
  2299. TRUNC(REPORT_DATE) AS DAY_VALUE,
  2300. CAMPAIGN_ID,
  2301. SUM(COUNT_SEND_1) AS COUNT_IMPRESSED
  2302. FROM REPORT_COUNT_DAILY
  2303. " + whereClause + @"
  2304. GROUP BY
  2305. TRUNC(REPORT_DATE),
  2306. CAMPAIGN_ID
  2307. ) base
  2308. LEFT JOIN B_CAMPAIGN c ON base.CAMPAIGN_ID = c.ID
  2309. ORDER BY base.DAY_VALUE, base.CAMPAIGN_ID";
  2310. using (OracleCommand cmd = new OracleCommand(sql, dbConnection))
  2311. {
  2312. cmd.CommandType = CommandType.Text;
  2313. if (!string.IsNullOrEmpty(v_fromDate) && v_fromDate != "-1")
  2314. {
  2315. cmd.Parameters.Add(":fromDate", OracleDbType.NVarchar2).Value = v_fromDate;
  2316. }
  2317. if (!string.IsNullOrEmpty(v_toDate) && v_toDate != "-1")
  2318. {
  2319. cmd.Parameters.Add(":toDate", OracleDbType.NVarchar2).Value = v_toDate;
  2320. }
  2321. if (!string.IsNullOrEmpty(v_campaignId) && v_campaignId != "-1" && v_campaignId != "All")
  2322. {
  2323. cmd.Parameters.Add(":campaignId", OracleDbType.NVarchar2).Value = v_campaignId;
  2324. }
  2325. OracleDataAdapter adapter = new OracleDataAdapter(cmd);
  2326. adapter.Fill(ds);
  2327. }
  2328. }
  2329. catch (Exception ex)
  2330. {
  2331. throw ex;
  2332. }
  2333. finally
  2334. {
  2335. dbConnection.Close();
  2336. }
  2337. return ds;
  2338. }
  2339. public static DataSet GET_DAILY_UNIQUE_IMPRESSIONS(string v_campaignId, string v_serviceId, string v_fromDate, string v_toDate)
  2340. {
  2341. DataSet ds = new DataSet();
  2342. OracleConnection dbConnection = DataAccess.getPoolingConnection();
  2343. try
  2344. {
  2345. dbConnection.Open();
  2346. string whereClause = "WHERE 1=1";
  2347. if (!string.IsNullOrEmpty(v_fromDate) && v_fromDate != "-1")
  2348. {
  2349. whereClause += " AND TRUNC(REPORT_DATE) >= TRUNC(TO_DATE(:fromDate, 'DD/MM/YYYY'))";
  2350. }
  2351. if (!string.IsNullOrEmpty(v_toDate) && v_toDate != "-1")
  2352. {
  2353. whereClause += " AND TRUNC(REPORT_DATE) <= TRUNC(TO_DATE(:toDate, 'DD/MM/YYYY'))";
  2354. }
  2355. if (!string.IsNullOrEmpty(v_campaignId) && v_campaignId != "-1" && v_campaignId != "All")
  2356. {
  2357. whereClause += " AND NVL(CAMPAIGN_ID, -1) = :campaignId";
  2358. }
  2359. if (!string.IsNullOrEmpty(v_serviceId) && v_serviceId != "-1" && v_serviceId != "All")
  2360. {
  2361. whereClause += " AND NVL(SERVICE_ID, -1) = :serviceId";
  2362. }
  2363. string sql = @"SELECT
  2364. base.DAY_LABEL,
  2365. base.DAY_VALUE,
  2366. base.CAMPAIGN_ID,
  2367. c.NAME AS CAMPAIGN_NAME,
  2368. base.COUNT_IMPRESSED
  2369. FROM (
  2370. SELECT
  2371. TO_CHAR(TRUNC(REPORT_DATE), 'YYYY-MM-DD') AS DAY_LABEL,
  2372. TRUNC(REPORT_DATE) AS DAY_VALUE,
  2373. NVL(CAMPAIGN_ID, -1) AS CAMPAIGN_ID,
  2374. SUM(NVL(COUNT_IMPRESSED, 0)) AS COUNT_IMPRESSED
  2375. FROM REPORT_USER_DAILY
  2376. " + whereClause + @"
  2377. GROUP BY
  2378. TRUNC(REPORT_DATE),
  2379. NVL(CAMPAIGN_ID, -1)
  2380. ) base
  2381. LEFT JOIN B_CAMPAIGN c ON base.CAMPAIGN_ID = c.ID
  2382. ORDER BY base.DAY_VALUE, base.CAMPAIGN_ID";
  2383. using (OracleCommand cmd = new OracleCommand(sql, dbConnection))
  2384. {
  2385. cmd.CommandType = CommandType.Text;
  2386. if (!string.IsNullOrEmpty(v_fromDate) && v_fromDate != "-1")
  2387. {
  2388. cmd.Parameters.Add(":fromDate", OracleDbType.NVarchar2).Value = v_fromDate;
  2389. }
  2390. if (!string.IsNullOrEmpty(v_toDate) && v_toDate != "-1")
  2391. {
  2392. cmd.Parameters.Add(":toDate", OracleDbType.NVarchar2).Value = v_toDate;
  2393. }
  2394. if (!string.IsNullOrEmpty(v_campaignId) && v_campaignId != "-1" && v_campaignId != "All")
  2395. {
  2396. cmd.Parameters.Add(":campaignId", OracleDbType.NVarchar2).Value = v_campaignId;
  2397. }
  2398. if (!string.IsNullOrEmpty(v_serviceId) && v_serviceId != "-1" && v_serviceId != "All")
  2399. {
  2400. cmd.Parameters.Add(":serviceId", OracleDbType.NVarchar2).Value = v_serviceId;
  2401. }
  2402. OracleDataAdapter adapter = new OracleDataAdapter(cmd);
  2403. adapter.Fill(ds);
  2404. }
  2405. }
  2406. catch (Exception ex)
  2407. {
  2408. throw ex;
  2409. }
  2410. finally
  2411. {
  2412. dbConnection.Close();
  2413. }
  2414. return ds;
  2415. }
  2416. public static DataSet GET_DAILY_ENGAGED_USERS(string v_campaignId, string v_serviceId, string v_fromDate, string v_toDate)
  2417. {
  2418. DataSet ds = new DataSet();
  2419. OracleConnection dbConnection = DataAccess.getPoolingConnection();
  2420. try
  2421. {
  2422. dbConnection.Open();
  2423. string whereClause = "WHERE 1=1";
  2424. if (!string.IsNullOrEmpty(v_fromDate) && v_fromDate != "-1")
  2425. {
  2426. whereClause += " AND TRUNC(REPORT_DATE) >= TRUNC(TO_DATE(:fromDate, 'DD/MM/YYYY'))";
  2427. }
  2428. if (!string.IsNullOrEmpty(v_toDate) && v_toDate != "-1")
  2429. {
  2430. whereClause += " AND TRUNC(REPORT_DATE) <= TRUNC(TO_DATE(:toDate, 'DD/MM/YYYY'))";
  2431. }
  2432. if (!string.IsNullOrEmpty(v_campaignId) && v_campaignId != "-1" && v_campaignId != "All")
  2433. {
  2434. whereClause += " AND NVL(CAMPAIGN_ID, -1) = :campaignId";
  2435. }
  2436. if (!string.IsNullOrEmpty(v_serviceId) && v_serviceId != "-1" && v_serviceId != "All")
  2437. {
  2438. whereClause += " AND NVL(SERVICE_ID, -1) = :serviceId";
  2439. }
  2440. string sql = @"SELECT
  2441. base.DAY_LABEL,
  2442. base.DAY_VALUE,
  2443. base.CAMPAIGN_ID,
  2444. c.NAME AS CAMPAIGN_NAME,
  2445. base.COUNT_ENGAGED
  2446. FROM (
  2447. SELECT
  2448. TO_CHAR(TRUNC(REPORT_DATE), 'YYYY-MM-DD') AS DAY_LABEL,
  2449. TRUNC(REPORT_DATE) AS DAY_VALUE,
  2450. NVL(CAMPAIGN_ID, -1) AS CAMPAIGN_ID,
  2451. SUM(NVL(COUNT_ENGAGED, 0)) AS COUNT_ENGAGED
  2452. FROM REPORT_USER_DAILY
  2453. " + whereClause + @"
  2454. GROUP BY
  2455. TRUNC(REPORT_DATE),
  2456. NVL(CAMPAIGN_ID, -1)
  2457. ) base
  2458. LEFT JOIN B_CAMPAIGN c ON base.CAMPAIGN_ID = c.ID
  2459. ORDER BY base.DAY_VALUE, base.CAMPAIGN_ID";
  2460. using (OracleCommand cmd = new OracleCommand(sql, dbConnection))
  2461. {
  2462. cmd.CommandType = CommandType.Text;
  2463. if (!string.IsNullOrEmpty(v_fromDate) && v_fromDate != "-1")
  2464. {
  2465. cmd.Parameters.Add(":fromDate", OracleDbType.NVarchar2).Value = v_fromDate;
  2466. }
  2467. if (!string.IsNullOrEmpty(v_toDate) && v_toDate != "-1")
  2468. {
  2469. cmd.Parameters.Add(":toDate", OracleDbType.NVarchar2).Value = v_toDate;
  2470. }
  2471. if (!string.IsNullOrEmpty(v_campaignId) && v_campaignId != "-1" && v_campaignId != "All")
  2472. {
  2473. cmd.Parameters.Add(":campaignId", OracleDbType.NVarchar2).Value = v_campaignId;
  2474. }
  2475. if (!string.IsNullOrEmpty(v_serviceId) && v_serviceId != "-1" && v_serviceId != "All")
  2476. {
  2477. cmd.Parameters.Add(":serviceId", OracleDbType.NVarchar2).Value = v_serviceId;
  2478. }
  2479. OracleDataAdapter adapter = new OracleDataAdapter(cmd);
  2480. adapter.Fill(ds);
  2481. }
  2482. }
  2483. catch (Exception ex)
  2484. {
  2485. throw ex;
  2486. }
  2487. finally
  2488. {
  2489. dbConnection.Close();
  2490. }
  2491. return ds;
  2492. }
  2493. }
  2494. }