| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090 |
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Threading.Tasks;
- using CommonObj.common;
- using CommonObj.lotoModel;
- using CommonObj.model;
- using Microsoft.AspNetCore.Http;
- using Microsoft.AspNetCore.Mvc;
- using Microsoft.Extensions.Caching.Memory;
- using Newtonsoft.Json;
- using Newtonsoft.Json.Linq;
- using ResfullApi.Models;
- using System.Data;
- using ResfullApi.Models.bet;
- namespace ApiProcessToken.Controllers
- {
- [ApiController]
- [Route("api/[controller]/[action]/data")]
- public class loto : ControllerBase
- {
- static readonly log4net.ILog logger = log4net.LogManager.GetLogger(typeof(loto));
- private IMemoryCache memoryCache;
- public loto(IMemoryCache memoryCache)
- {
- this.memoryCache = memoryCache;
- }
- [HttpPost]
- public IActionResult buyTicket([FromBody] dynamic sendData)
- {
- buyTicketResponse response = new buyTicketResponse();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- buyTicketObj data = JsonConvert.DeserializeObject<buyTicketObj>(sendData.ToString());
- if (data.language != "0" || data.language != "1") data.language = "0";
- logger.Info("New request income bet :" + data.ToString());
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, data.token, data.channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, data.channel, response.responseCode, data.language);
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- //Chu y:
- // Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- if (_tokenObj != null)
- {
- if (_tokenObj.msisdn != data.msisdn)
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, data.channel, response.responseCode, data.language);
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- }
- //Ket thuc check token
- //Kiem tra xem co blaclist hay ko? Tham thoi dung voi muc dich whiteList
- blacklistObj _blackObj = CommonFunction.getBlackListFromRedis(_redis, "2", "-1", data.msisdn);
- if(_blackObj!=null)
- {
- logger.Info("Blacklist roi"+ data.msisdn);
- response.responseCode = "26";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, data.channel, response.responseCode, data.language);
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- logger.Info("So nay ko blacklist" + data.msisdn);
- if (data.channel != "WALLET")
- {
- logger.Info("Channel !=WALLET tuc la mua ve qua tai khoan goc cua thue bao: " + data.msisdn);
- string _pakage = CommonFunction.chargeGWGetPackage(_redis, CommonFunction.getGuiId(), data.msisdn, logger);
- if(_pakage=="unknow")
- {
- logger.Info("View :" + data.msisdn +" loi nen exit with update system");
- response.responseCode = "-2";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, data.channel, response.responseCode, data.language);
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- string _listThueBaoTraSau = CommonFunction.getParamObjFromRedis(_redis, "THUEBAO_TRASAU", "THUEBAO_TRASAU", "SYSTEM").values;
- if(_listThueBaoTraSau.IndexOf(","+_pakage+",")>0)
- {
- logger.Info("Thue bao :" + data.msisdn + " la tra sau--> not play on ussd or web channel. Tra ma loi 23");
- response.responseCode = "23";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, data.channel, response.responseCode, data.language);
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- }
- int is_promotion = 0, status_prompotion = 0;
- long totalMoney = 0, totalPromotionMoney = 0, id_promotion = -1, totalPaymentMoney = 0;
- //1. DUA VAO GAMEID DE KIEM TRA KY QUAY ID VA THOI GIAN QUAY THUONG
- termObj _termObj = CommonFunction.getTermObjObjFromRedis(_redis, data.gameId);
- //Kiem tra thoi gian hien tai > thoi gian dong cong + 10 phut thi exit
- DateTime _endDate = new DateTime();
- try { _endDate = DateTime.ParseExact(_termObj.endDate, "dd/MM/yyyy HH:mm:ss", null); }
- catch { }
- logger.Info("_endDate chua add 10 phut: "+ _endDate.ToString());
- TimeSpan _addMore = new TimeSpan(0, 10, 0);
- _endDate = _endDate + _addMore;
- logger.Info("_endDate da add 10 phut: " + _endDate.ToString());
- DateTime dNow = DateTime.Now;
- logger.Info("dNow : " + dNow.ToString());
- if (dNow > _endDate)
- {
- logger.Info("He thong bi loi, het thoi gian choi cua ky nay roi nhe");
- response.responseCode = "-2";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, data.channel, response.responseCode, data.language);
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- logger.Info("Check thoi gian da OK, xin moi tiep tuc");
- //2. KIEM TRA TICKET NAY CO HOP LE VE TIEN HAY KO?
- //Tinh tong tien cua ve
- if (!CommonFunction.checkTicket(data, out totalMoney))
- {
- //Ticke sai formart
- logger.Info("Check ticket false");
- response.responseCode = "3";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, data.channel, response.responseCode, data.language);
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- if (!string.IsNullOrEmpty(data.promotionCode))
- {
- DataSet _ds = lotoDataAccess.getPromotionByCode(data.promotionCode, data.msisdn);
- if (_ds != null && _ds.Tables[0].Rows.Count > 0)
- {
- id_promotion = Convert.ToUInt32(_ds.Tables[0].Rows[0]["ID"].ToString());
- totalPromotionMoney = Convert.ToUInt32(_ds.Tables[0].Rows[0]["MONEY"].ToString());
- status_prompotion = Convert.ToUInt16(_ds.Tables[0].Rows[0]["STATUS"].ToString());
- if (status_prompotion == 2)
- {
- //Ma code khuyen mai da su dung roi
- logger.Info("Promotion code have use");
- response.responseCode = "38";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, data.channel, response.responseCode, data.language);
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- else if (status_prompotion == 0)
- {
- //Ma code khuyen mai chua send
- logger.Info("Promotion is not active");
- response.responseCode = "40";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, data.channel, response.responseCode, data.language);
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- else if (status_prompotion == 1)
- {
- logger.Info("Promotion code OK");
- is_promotion = 1;
- }
- }
- else
- {
- //Promotion code ko hop le
- logger.Info("Promotion code invalid");
- response.responseCode = "39";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, data.channel, response.responseCode, data.language);
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- }
- if (totalPromotionMoney >= totalMoney)
- totalPaymentMoney = 0;
- else
- totalPaymentMoney = totalMoney - totalPromotionMoney;
- response.responseCode = "0";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, data.channel, response.responseCode, data.language);
- response.termObj = _termObj;
- response.requestId = data.requestId;
- response.transId = CommonFunction.getGuiId();
- response.isPromotion = is_promotion.ToString();
- response.totalMoney = totalMoney.ToString();
- response.totalMoneyPromotion = totalPromotionMoney.ToString();
- response.totalMoneyPayment = totalPaymentMoney.ToString();
- response.promotionId = id_promotion.ToString();
- data.buyTicketResponse = response;
- //Ghi request nay vao select 2 cua DB
- //ghi lai token vao DB(1)
- int _token_timeout = Convert.ToInt16(((paramObj)CommonFunction.getParamObjFromRedis(_redis, "TICKET_CONFIRM_TIMEOUT", "TICKET_CONFIRM_TIMEOUT", "SYSTEM")).values);
- TimeSpan _timeSpam = new TimeSpan(0, 0, _token_timeout);
- _redis.setByKey(_redis.DB_INDEX_DATA_USER, response.transId, data.ToString(), _timeSpam);
- }
- catch (Exception ex)
- {
- logger.Info("getCurentTerm exception: " + ex.ToString());
- }
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult confirmTicket([FromBody] dynamic sendData)
- {
- confirmTiketResponse response = new confirmTiketResponse();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- response.transId = CommonFunction.getGuiId();
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- string paymentTransCode = "";
- string requestId = string.Empty, language = string.Empty, transIdByTicket = string.Empty, paymentCode = string.Empty, token = string.Empty, channel = string.Empty;
- try
- {
- var obj = JObject.Parse(sendData.ToString());
- requestId = Convert.ToString(obj["requestId"]);
- transIdByTicket = Convert.ToString(obj["transIdByTicket"]);
- paymentCode = Convert.ToString(obj["paymentCode"]);
- token = Convert.ToString(obj["token"]);
- channel = Convert.ToString(obj["channel"]);
- paymentTransCode = paymentCode;
- response.requestId = requestId;
- /*
- if (string.IsNullOrEmpty(requestId)) requestId = "";
- if (string.IsNullOrEmpty(transIdByTicket)) transIdByTicket = "";
- if (string.IsNullOrEmpty(paymentCode)) paymentCode = "";
- if (string.IsNullOrEmpty(token)) token = "";
- */
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- //Ket thuc check token
- //Lay thong tin cua requetByTicket ve
- if (!_redis.existsByKey(Convert.ToInt16(_redis.DB_INDEX_DATA_USER), transIdByTicket))
- {
- logger.Info("Request buy ticket not exits");
- response.responseCode = "41";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- buyTicketObj data = JsonConvert.DeserializeObject<buyTicketObj>(_redis.getByKey(_redis.DB_INDEX_DATA_USER, transIdByTicket));
- _redis.delByKey(_redis.DB_INDEX_DATA_USER, transIdByTicket);
- string _resultCharge = "-2";
- if (channel != "WALLET")
- {
- //Tien hanh charge tien, gui ve ma loi va ma giao dich
- _resultCharge = CommonFunction.chargeGW(_redis,response.transId, data.msisdn, data.buyTicketResponse.totalMoneyPayment, logger);
- paymentTransCode = response.transId;
- if (_resultCharge != "0")
- {
- logger.Info("Charge false so exit");
- response.responseCode = _resultCharge;
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- }
- //truong hop con lai thi da tru tien thanh cong va insert ve nay vao DB
- bool _resultInsert = false;
- try
- {
- //tao chuoi ticket co format: termId1#money#ticket1*termId2#money#tiket2*.......
- string _tiketformat = "";
- for (int i = 0; i < data.ticket.Length; i++)
- {
- if (i == 0)
- _tiketformat = data.buyTicketResponse.termObj.id + "#" + data.ticket[i].money + "#" + data.ticket[i].code;
- else
- _tiketformat = _tiketformat + "*" + data.buyTicketResponse.termObj.id + "#" + data.ticket[i].money + "#" + data.ticket[i].code;
- }
- DataSet _ds = lotoDataAccess.lotoInsertBet(data.msisdn, data.buyTicketResponse.promotionId, _tiketformat,
- data.buyTicketResponse.totalMoneyPayment, data.requestId, data.buyTicketResponse.transId,
- response.requestId, response.transId, paymentTransCode, "Success", DateTime.Now.ToString("dd/MM/yyyy HH:mm:ss")
- , DateTime.Now.ToString("dd/MM/yyyy HH:mm:ss"), "0", data.gameId, data.channel, data.language);
- if (_ds != null && _ds.Tables[0].Rows.Count > 0)
- {
- //lay ve ma don hang, list betId
- response.orderId = _ds.Tables[0].Rows[0]["bill_code"].ToString();
- response.listTiketId = _ds.Tables[0].Rows[0]["tran_code"].ToString();
- response.responseCode = "0";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- }
- }
- catch (Exception ex)
- {
- logger.Info("Insert bet into Database errr " + ex.Message, ex);
- _resultInsert = false;
- }
- if (!_resultInsert)
- {
- //Ghi lai log cua giao dich con hoan lai tien
- logger.Info("Insert bet into Database err so write log for revert");
- //Ghi log
- response.responseCode = "-2";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- }
- }
- catch (Exception ex)
- {
- logger.Info("getCurentTerm exception: " + ex.ToString());
- }
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult sendOtp([FromBody] dynamic sendData)
- {
- Response response = new Response();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- string msisdn = string.Empty, language = string.Empty, transIdByTicket = string.Empty, paymentCode = string.Empty, token = string.Empty, channel = string.Empty;
- try
- {
- var obj = JObject.Parse(sendData.ToString());
- msisdn = Convert.ToString(obj["msisdn"]);
- token = Convert.ToString(obj["token"]);
- channel = Convert.ToString(obj["channel"]);
- language = Convert.ToString(obj["language"]);
- if (string.IsNullOrEmpty(language)) language = "-1";
- /*
- if (string.IsNullOrEmpty(requestId)) requestId = "";
- if (string.IsNullOrEmpty(transIdByTicket)) transIdByTicket = "";
- if (string.IsNullOrEmpty(paymentCode)) paymentCode = "";
- if (string.IsNullOrEmpty(token)) token = "";
- */
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- //Chu y:
- // Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- if (_tokenObj != null)
- {
- if (_tokenObj.msisdn != msisdn && _tokenObj.role == "USER")
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- }
- //Ket thuc check token
- DataSet ds = lotoDataAccess.otpSend(msisdn, "1", channel, language);
- if (ds != null && ds.Tables[0].Rows.Count > 0)
- {
- logger.Info("Send OTP success");
- response.responseCode = "0";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- logger.Info("Send OTP not sucess");
- response.responseCode = "-2";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult confirmOtp([FromBody] dynamic sendData)
- {
- Response response = new Response();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- string msisdn = string.Empty, language = string.Empty, otp = string.Empty, token = string.Empty, channel = string.Empty;
- try
- {
- var obj = JObject.Parse(sendData.ToString());
- msisdn = Convert.ToString(obj["msisdn"]);
- token = Convert.ToString(obj["token"]);
- channel = Convert.ToString(obj["channel"]);
- otp = Convert.ToString(obj["otp"]);
- language = Convert.ToString(obj["language"]);
- if (string.IsNullOrEmpty(language)) language = "-1";
- /*
- if (string.IsNullOrEmpty(requestId)) requestId = "";
- if (string.IsNullOrEmpty(transIdByTicket)) transIdByTicket = "";
- if (string.IsNullOrEmpty(paymentCode)) paymentCode = "";
- if (string.IsNullOrEmpty(token)) token = "";
- */
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- //Chu y:
- // Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- if (_tokenObj != null && _tokenObj.role == "USER")
- {
- if (_tokenObj.msisdn != msisdn)
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("buyTicket response : " + response.ToString());
- return Ok(response);
- }
- }
- //Ket thuc check token
- DataSet ds = lotoDataAccess.otpConfirm(msisdn, "1", channel, otp, language);
- if (ds != null && ds.Tables[0].Rows.Count > 0)
- {
- string status = ds.Tables[0].Rows[0]["status"].ToString();
- string msg = ds.Tables[0].Rows[0]["mesage"].ToString();
- logger.Info("Send OTP success");
- response.responseCode = status;
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- logger.Info("Send OTP not sucess");
- response.responseCode = "-2";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
-
- [HttpPost]
- public IActionResult convertMoneyByUser([FromBody] dynamic sendData)
- {
- convertMoneyResponseObj response = new convertMoneyResponseObj();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- string msisdn = string.Empty, msisdnReceive = string.Empty, money = string.Empty, language = string.Empty,
- channelPayment = string.Empty, token = string.Empty, channel = string.Empty, serviceId = string.Empty, otp = string.Empty;
- try
- {
- var obj = JObject.Parse(sendData.ToString());
- serviceId = Convert.ToString(obj["serviceId"]);
- msisdn = Convert.ToString(obj["msisdn"]);
- msisdnReceive = Convert.ToString(obj["msisdnReceive"]);
- token = Convert.ToString(obj["token"]);
- channel = Convert.ToString(obj["channel"]);
- channelPayment = Convert.ToString(obj["channelPayment"]);
- money = Convert.ToString(obj["money"]);
- language = Convert.ToString(obj["language"]);
- otp = Convert.ToString(obj["otp"]);
- if (string.IsNullOrEmpty(language)) language = "1";
- if (string.IsNullOrEmpty(money)) money = "0";
- if (string.IsNullOrEmpty(channelPayment)) channelPayment = "-1";
- if (string.IsNullOrEmpty(channelPayment)) serviceId = "1";
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- //Chu y:
- // Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- if (_tokenObj != null && _tokenObj.role == "USER")
- {
- if (_tokenObj.msisdn != msisdn)
- {
- logger.Info("_tokenObj.msisdn != msisdn Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- return Ok(response);
- }
- }
- //Ket thuc check token
- if (!(channelPayment == "1" || channelPayment == "2"))
- {
- //He thong nang cap
- logger.Info("Tham so sai");
- response.responseCode = "4";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- return Ok(response);
- }
- if (channelPayment=="2")
- {
- //Kiem tra su ton tai cua vi
- string _reqeustCheckWallet = CommonFunction.getGuiId();
- //-1: He thong nang cap,1= Vi ton tai va active,2=Khong ton tai vi,3= Vi khong active
- string _isexitsWallet = CommonFunction.checkExistsWallet(_redis, _reqeustCheckWallet, msisdnReceive, logger);
- if (_isexitsWallet == "-1")
- {
- //He thong nang cap
- logger.Info("Khong check vi duoc");
- response.responseCode = "-2";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- return Ok(response);
- }
- if (_isexitsWallet == "2")
- {
- //Vi khong ton tai
- logger.Info("Vi khong ton tai");
- response.responseCode = "20";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- return Ok(response);
- }
- if (_isexitsWallet == "3")
- {
- //Vi khong active
- logger.Info("Vi khong active");
- response.responseCode = "21";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- return Ok(response);
- }
- }
-
- /*
- //Kiem tra them OTP neu ko phai kenh ussd
- if (channel != "USSD")
- {
- DataSet ds_otp = lotoDataAccess.otpConfirm(msisdn, "1", channel, otp, language);
- if (ds_otp != null && ds_otp.Tables[0].Rows.Count > 0)
- {
- string status = ds_otp.Tables[0].Rows[0]["status"].ToString();
- string msg = ds_otp.Tables[0].Rows[0]["mesage"].ToString();
- if (status != "0")
- {
- logger.Info("Confirm OTP not sucess");
- response.responseCode = status;
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- }
- else
- {
- logger.Info("Confirm OTP not sucess");
- response.responseCode = "-2";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- }
- */
- //Kiem tra them vai dieu kien
- if (string.IsNullOrEmpty(msisdnReceive))
- {
- logger.Info("msisdnReceive is null");
- response.responseCode = "4";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- return Ok(response);
- }
- int _money = 0;
- if (int.TryParse(money, out _money))
- {
- if (_money <= 0)
- {
- logger.Info("msisdnReceive is null");
- response.responseCode = "4";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- return Ok(response);
- }
- }
- else
- {
- logger.Info("msisdnReceive is null");
- response.responseCode = "4";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- return Ok(response);
- }
- DataSet ds = lotoDataAccess.convertMoney(msisdn, msisdnReceive, channel, channelPayment, money, language, serviceId);
- if (ds != null && ds.Tables[0].Rows.Count > 0)
- {
- logger.Info("Chuyen tien thanh cong");
- response.responseCode = ds.Tables[0].Rows[0]["status"].ToString();
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- response.paymentCode = ds.Tables[0].Rows[0]["paymentCode"].ToString();
- return Ok(response);
- }
- else
- {
- logger.Info("Send convert coins to money not sucess");
- response.responseCode = "-2";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult getListConvertByUser([FromBody] dynamic sendData)
- {
- convertMoneyListObj response = new convertMoneyListObj();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- try
- {
- var obj = JObject.Parse(sendData.ToString());
- string serviceId = Convert.ToString(obj["serviceId"]);
- string msisdn = Convert.ToString(obj["msisdn"]);
- string id = Convert.ToString(obj["id"]);
- string type = Convert.ToString(obj["type"]); // --0=dang thuc hien,1=thuc hien thanh cong,2=pending,3=revert
- string order = Convert.ToString(obj["order"]); // ASC= tang dan theo ID ticket,DESC= giam dan theo Id ticket
- string rowsOnPage = Convert.ToString(obj["rowsOnPage"]);
- string seqPage = Convert.ToString(obj["seqPage"]);
- string channel = Convert.ToString(obj["channel"]);
- string fromDate = Convert.ToString(obj["fromDate"]);
- string toDate = Convert.ToString(obj["toDate"]);
- string channelPayment = Convert.ToString(obj["channelPayment"]);
- string token = Convert.ToString(obj["token"]);
- string language = Convert.ToString(obj["language"]);
- if (string.IsNullOrEmpty(language)) language = "1";
- if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000";
- if (string.IsNullOrEmpty(seqPage)) seqPage = "1";
- if (string.IsNullOrEmpty(id)) id = "-1";
- if (string.IsNullOrEmpty(type)) type = "-1";
- if (string.IsNullOrEmpty(order)) order = "ASC";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(channel)) channel = "-1";
- if (string.IsNullOrEmpty(channelPayment)) channelPayment = "-1";
-
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- //Chu y:
- // Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- if (_tokenObj != null && _tokenObj.role == "USER")
- {
- if (_tokenObj.msisdn != msisdn)
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- return Ok(response);
- }
- }
- DataSet ds_regist = lotoDataAccess.getListConvertByUser(serviceId, msisdn, type, order, rowsOnPage, seqPage, id, language, fromDate, toDate, channelPayment);
- response.responseCode = "0";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.rowsOnPage = ds_regist.Tables[0].Rows[0]["ROW_ON_PAGE"].ToString();
- response.seqPage = ds_regist.Tables[0].Rows[0]["SEQ_PAGE"].ToString();
- response.totalPage = ds_regist.Tables[0].Rows[0]["TOTAL_PAGE"].ToString();
- response.totalRow = ds_regist.Tables[0].Rows[0]["TOTAL_ROW"].ToString();
- response.list = new convertMoneyObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- convertMoneyObj _obj = new convertMoneyObj();
- _obj.seq = ds_regist.Tables[0].Rows[j]["SEQ"].ToString();
- _obj.id = ds_regist.Tables[0].Rows[j]["id"].ToString();
- _obj.acountSend = ds_regist.Tables[0].Rows[j]["ACOUNT_SEND"].ToString();
- _obj.acountRecieve = ds_regist.Tables[0].Rows[j]["ACOUNT_RECEIVE"].ToString();
- _obj.timeRequest = ds_regist.Tables[0].Rows[j]["TIMEREQUEST"].ToString();
- _obj.timeTopup = ds_regist.Tables[0].Rows[j]["TIMETOPUP"].ToString();
- _obj.status = ds_regist.Tables[0].Rows[j]["STATUS"].ToString();
- _obj.money = ds_regist.Tables[0].Rows[j]["MONEY"].ToString();
- _obj.channelRequest = ds_regist.Tables[0].Rows[j]["CHANNEL_REQUEST"].ToString();
- _obj.channelPayment = ds_regist.Tables[0].Rows[j]["CHANNEL_PAYMENT"].ToString();
- _obj.reqeustId = ds_regist.Tables[0].Rows[j]["REQEUST_ID"].ToString();
- _obj.responseId = ds_regist.Tables[0].Rows[j]["RESPONSE_ID"].ToString();
- _obj.errCode = ds_regist.Tables[0].Rows[j]["ERR_CODE"].ToString();
- _obj.errMsg = ds_regist.Tables[0].Rows[j]["ERR_MSG"].ToString();
- _obj.serviceId = ds_regist.Tables[0].Rows[j]["SERVICE_ID"].ToString();
- response.list[j] = _obj;
- }
- return Ok(response);
- }
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
- //{"id":"1","users":"quangbh","key":"jqB3Vi1fIlu+9a2ODQs65w=="}
- [HttpPost]
- public IActionResult paramGetList([FromBody] dynamic sendData)
- {
- logger.Info("New request income balanceGetList :" + sendData.ToString());
- paramObjList response = new paramObjList();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string users = Convert.ToString(userObj["users"]);
- string id = Convert.ToString(userObj["id"]);
- string token = Convert.ToString(userObj["token"]);
- string channel = Convert.ToString(userObj["channel"]);
- string language = Convert.ToString(userObj["language"]);
- if (string.IsNullOrEmpty(language)) language = "1";
- if (string.IsNullOrEmpty(users)) users = "-1";
- if (string.IsNullOrEmpty(id)) id = "-1";
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- DataSet ds_regist = lotoDataAccess.paramGetList(id, users);
- logger.Info("Call database balGetList success:");
- response.responseCode = "0";
- response.responseMessage = "Success";
- if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0)
- {
- response.list = new paramObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- paramObj _obj = new paramObj();
- _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString();
- _obj.code = ds_regist.Tables[0].Rows[j]["CODE"].ToString();
- _obj.values = ds_regist.Tables[0].Rows[j]["SVALUES"].ToString();
- _obj.note = ds_regist.Tables[0].Rows[j]["NOTE"].ToString();
- _obj.status = ds_regist.Tables[0].Rows[j]["STATUS"].ToString();
- _obj.codeGroup = ds_regist.Tables[0].Rows[j]["CODE_GROUP"].ToString();
- _obj.display0 = ds_regist.Tables[0].Rows[j]["DISPLAY0"].ToString();
- _obj.display1 = ds_regist.Tables[0].Rows[j]["DISPLAY1"].ToString();
- _obj.display2 = ds_regist.Tables[0].Rows[j]["DISPLAY2"].ToString();
- _obj.display3 = ds_regist.Tables[0].Rows[j]["DISPLAY3"].ToString();
- _obj.display4 = ds_regist.Tables[0].Rows[j]["DISPLAY4"].ToString();
- _obj.display5 = ds_regist.Tables[0].Rows[j]["DISPLAY5"].ToString();
- _obj.gameId = ds_regist.Tables[0].Rows[j]["GAME_ID"].ToString();
- _obj.channel = ds_regist.Tables[0].Rows[j]["CHANNEL"].ToString();
- response.list[j] = _obj;
- }
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Responase to web: " + response.ToString());
- return Ok(response);
- }
- /*
- {"code":"124","values":"Cty Viettech 1","note":"0","status":"1","codeGroup":"quangbh","display0":"display0","display1":"display1","display2":"display2","display3":"display3","display4":"display4","display5":"display5","gameId":"1","channel":"channel","users":"haha","key":"jqB3Vi1fIlu+9a2ODQs65w=="}
- */
- public IActionResult paramInsert([FromBody] dynamic sendData)
- {
- logger.Info("New request income balanceInsert :" + sendData.ToString());
- Response response = new Response();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string code = Convert.ToString(userObj["code"]);
- string values = Convert.ToString(userObj["values"]);
- string note = Convert.ToString(userObj["note"]);
- string status = Convert.ToString(userObj["status"]);
- string codeGroup = Convert.ToString(userObj["codeGroup"]);
- string display0 = Convert.ToString(userObj["display0"]);
- string display1 = Convert.ToString(userObj["display1"]);
- string display2 = Convert.ToString(userObj["display2"]);
- string display3 = Convert.ToString(userObj["display3"]);
- string display4 = Convert.ToString(userObj["display4"]);
- string display5 = Convert.ToString(userObj["display5"]);
- string gameId = Convert.ToString(userObj["gameId"]);
- string channel = Convert.ToString(userObj["channel"]);
- string token = Convert.ToString(userObj["token"]);
- string users = Convert.ToString(userObj["users"]);
- string key = Convert.ToString(userObj["key"]);
- string language = Convert.ToString(userObj["language"]);
-
- if (string.IsNullOrEmpty(code)) code = "-1";
- if (string.IsNullOrEmpty(codeGroup)) codeGroup = "-1";
- if (string.IsNullOrEmpty(language)) language = "1";
- if (string.IsNullOrEmpty(users)) users = "-1";
- if (string.IsNullOrEmpty(key)) key = "-1";
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- DataSet ds_regist = lotoDataAccess.paramInsert(code, values, note, status, codeGroup, display0, display1,
- display2, display3, display4, display5, gameId, channel, users);
- logger.Info("Call database balInsert success:");
- response.responseCode = "0";
- response.responseMessage = "Success";
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Responase to web: " + response.ToString());
- return Ok(response);
- }
- /*
- {"id":"1","code":"124","values":"Cty Viettech 1","note":"0","status":"1","codeGroup":"quangbh","display0":"display0","display1":"display1","display2":"displayso 3","display3":"display3","display4":"display4","display5":"display5","gameId":"1","channel":"channel","type":"0","users":"quangbh","key":"jqB3Vi1fIlu+9a2ODQs65w=="}
- */
- public IActionResult paramUpdate([FromBody] dynamic sendData)
- {
- logger.Info("New request income companyGetList :" + sendData.ToString());
- Response response = new Response();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string id = Convert.ToString(userObj["id"]);
- string code = Convert.ToString(userObj["code"]);
- string values = Convert.ToString(userObj["values"]);
- string note = Convert.ToString(userObj["note"]);
- string status = Convert.ToString(userObj["status"]);
- string codeGroup = Convert.ToString(userObj["codeGroup"]);
- string display0 = Convert.ToString(userObj["display0"]);
- string display1 = Convert.ToString(userObj["display1"]);
- string display2 = Convert.ToString(userObj["display2"]);
- string display3 = Convert.ToString(userObj["display3"]);
- string display4 = Convert.ToString(userObj["display4"]);
- string display5 = Convert.ToString(userObj["display5"]);
- string gameId = Convert.ToString(userObj["gameId"]);
- string channel = Convert.ToString(userObj["channel"]);
- string type = Convert.ToString(userObj["type"]);
- string users = Convert.ToString(userObj["users"]);
- string token = Convert.ToString(userObj["token"]);
- string language = Convert.ToString(userObj["language"]);
- if (string.IsNullOrEmpty(id)) id = "-1";
- if (string.IsNullOrEmpty(type)) type = "0";
- if (string.IsNullOrEmpty(language)) language = "1";
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- DataSet ds_regist = lotoDataAccess.paramUpdate(id, code, values, note, status, codeGroup, display0, display1,
- display2, display3, display4, display5, gameId, channel, users, type);
- logger.Info("Call database comInsert success:");
- response.responseCode = "0";
- response.responseMessage = "Success";
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Responase to web: " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult rpTotalByDay([FromBody] dynamic sendData)
- {
- rpTotalByDayListObj response = new rpTotalByDayListObj();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- try
- {
- var obj = JObject.Parse(sendData.ToString());
-
- string msisdn = Convert.ToString(obj["msisdn"]);
- string gameId = Convert.ToString(obj["gameId"]);
- string gameType = Convert.ToString(obj["gameType"]); // --1=Newyork,2=Florida
- string isEvening = Convert.ToString(obj["isEvening"]); // --1=evening,0= not evening
-
- string channel = Convert.ToString(obj["channel"]);
- string fromDate = Convert.ToString(obj["fromDate"]);
- string toDate = Convert.ToString(obj["toDate"]);
-
- string token = Convert.ToString(obj["token"]);
- string language = Convert.ToString(obj["language"]);
- if (string.IsNullOrEmpty(language)) language = "1";
-
- if (string.IsNullOrEmpty(msisdn)) msisdn = "-1";
- if (string.IsNullOrEmpty(gameId)) gameId = "-1";
- if (string.IsNullOrEmpty(gameType)) gameType = "-1";
- if (string.IsNullOrEmpty(isEvening)) isEvening = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(channel)) channel = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- string channelPayment = Convert.ToString(obj["channelPayment"]);
- if (string.IsNullOrEmpty(channelPayment)) channelPayment = "-1";
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- //Chu y:
- // Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- //if (_tokenObj != null && _tokenObj.role == "USER")
- //{
- // if (_tokenObj.msisdn != msisdn)
- // {
- // logger.Info("Authen token false");
- // response.responseCode = "35";
- // response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- // return Ok(response);
- // }
- //}
- DataSet ds_regist = lotoDataAccess.reTotalByDay(msisdn, fromDate, toDate, gameId, gameType, isEvening, channelPayment);
- response.responseCode = "0";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
-
- response.list = new rpTotalByDayObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- rpTotalByDayObj _obj = new rpTotalByDayObj();
- _obj.date = ds_regist.Tables[0].Rows[j]["ngay"].ToString();
- _obj.player = ds_regist.Tables[0].Rows[j]["player"].ToString();
- _obj.ticket = ds_regist.Tables[0].Rows[j]["ticket"].ToString();
- _obj.money = ds_regist.Tables[0].Rows[j]["money"].ToString();
- _obj.palyerWin = ds_regist.Tables[0].Rows[j]["player_win"].ToString();
- _obj.ticketWin = ds_regist.Tables[0].Rows[j]["ticket_win"].ToString();
- _obj.moneyWin = ds_regist.Tables[0].Rows[j]["money_win"].ToString();
- _obj.benefit = ds_regist.Tables[0].Rows[j]["benefit"].ToString();
- _obj.sharing = ds_regist.Tables[0].Rows[j]["sharing"].ToString();
- response.list[j] = _obj;
- }
- return Ok(response);
- }
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
-
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult rpTotalByDayLkps([FromBody] dynamic sendData)
- {
- rpTotalByDayListObj response = new rpTotalByDayListObj();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- try
- {
- var obj = JObject.Parse(sendData.ToString());
- string msisdn = Convert.ToString(obj["msisdn"]);
- string channel = Convert.ToString(obj["channel"]);
- string fromDate = Convert.ToString(obj["fromDate"]);
- string toDate = Convert.ToString(obj["toDate"]);
- string token = Convert.ToString(obj["token"]);
- string language = Convert.ToString(obj["language"]);
- if (string.IsNullOrEmpty(language)) language = "1";
- if (string.IsNullOrEmpty(msisdn)) msisdn = "-1";
-
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(channel)) channel = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- string channelPayment = Convert.ToString(obj["channelPayment"]);
- if (string.IsNullOrEmpty(channelPayment)) channelPayment = "-1";
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- //Chu y:
- // Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- //if (_tokenObj != null && _tokenObj.role == "USER")
- //{
- // if (_tokenObj.msisdn != msisdn)
- // {
- // logger.Info("Authen token false");
- // response.responseCode = "35";
- // response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- // return Ok(response);
- // }
- //}
- DataSet ds_regist = lotoDataAccess.reTotalByDayLkps(msisdn, fromDate, toDate, channelPayment);
- response.responseCode = "0";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.list = new rpTotalByDayObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- rpTotalByDayObj _obj = new rpTotalByDayObj();
- _obj.date = ds_regist.Tables[0].Rows[j]["ngay"].ToString();
- _obj.player = ds_regist.Tables[0].Rows[j]["player"].ToString();
- _obj.ticket = ds_regist.Tables[0].Rows[j]["ticket"].ToString();
- _obj.money = ds_regist.Tables[0].Rows[j]["money"].ToString();
- _obj.palyerWin = ds_regist.Tables[0].Rows[j]["player_win"].ToString();
- _obj.ticketWin = ds_regist.Tables[0].Rows[j]["ticket_win"].ToString();
- _obj.moneyWin = ds_regist.Tables[0].Rows[j]["money_win"].ToString();
- _obj.benefit = ds_regist.Tables[0].Rows[j]["benefit"].ToString();
- _obj.sharing = ds_regist.Tables[0].Rows[j]["sharing"].ToString();
- response.list[j] = _obj;
- }
- return Ok(response);
- }
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult rpTotalByDayConvertMoney([FromBody] dynamic sendData)
- {
- rpTotalByDayConvetMoneyListObj response = new rpTotalByDayConvetMoneyListObj();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- try
- {
- var obj = JObject.Parse(sendData.ToString());
-
- string channel = Convert.ToString(obj["channel"]);
-
- string fromDate = Convert.ToString(obj["fromDate"]);
- string toDate = Convert.ToString(obj["toDate"]);
- string token = Convert.ToString(obj["token"]);
- string language = Convert.ToString(obj["language"]);
- if (string.IsNullOrEmpty(language)) language = "1";
-
-
-
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(channel)) channel = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- string channelPayment = Convert.ToString(obj["channelPayment"]);
- if (string.IsNullOrEmpty(channelPayment)) channelPayment = "-1";
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- //Chu y:
- // Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- //if (_tokenObj != null && _tokenObj.role == "USER")
- //{
- // if (_tokenObj.msisdn != msisdn)
- // {
- // logger.Info("Authen token false");
- // response.responseCode = "35";
- // response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- // return Ok(response);
- // }
- //}
- DataSet ds_regist = lotoDataAccess.reTotalByDayConvertMoney(fromDate, toDate, channelPayment);
- response.responseCode = "0";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.list = new rpTotalByDayConvetMoneyObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- rpTotalByDayConvetMoneyObj _obj = new rpTotalByDayConvetMoneyObj();
- _obj.date = ds_regist.Tables[0].Rows[j]["ngay"].ToString();
- _obj.total = ds_regist.Tables[0].Rows[j]["total"].ToString();
- _obj.money = ds_regist.Tables[0].Rows[j]["money"].ToString();
- _obj.totalSuccess = ds_regist.Tables[0].Rows[j]["totalSucces"].ToString();
- _obj.moneySuccess = ds_regist.Tables[0].Rows[j]["moneySuccess"].ToString();
- _obj.totalRevert = ds_regist.Tables[0].Rows[j]["totalRevert"].ToString();
- _obj.moneyRevert = ds_regist.Tables[0].Rows[j]["moneyRevert"].ToString();
- _obj.totalPending = ds_regist.Tables[0].Rows[j]["totalPending"].ToString();
- _obj.moneyPending = ds_regist.Tables[0].Rows[j]["moneyPending"].ToString();
- response.list[j] = _obj;
- }
- return Ok(response);
- }
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult rpTotalByPrizeBolet([FromBody] dynamic sendData)
- {
- rpTotalByDayPrizwBoletListObj response = new rpTotalByDayPrizwBoletListObj();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- try
- {
- var obj = JObject.Parse(sendData.ToString());
- string msisdn = Convert.ToString(obj["msisdn"]);
-
- string gameType = Convert.ToString(obj["gameType"]); // --1=Newyork,2=Florida
- string isEvening = Convert.ToString(obj["isEvening"]); // --1=evening,0= not evening
- string channel = Convert.ToString(obj["channel"]);
- string fromDate = Convert.ToString(obj["fromDate"]);
- string toDate = Convert.ToString(obj["toDate"]);
- string token = Convert.ToString(obj["token"]);
- string language = Convert.ToString(obj["language"]);
- if (string.IsNullOrEmpty(language)) language = "1";
- if (string.IsNullOrEmpty(msisdn)) msisdn = "-1";
-
- if (string.IsNullOrEmpty(gameType)) gameType = "-1";
- if (string.IsNullOrEmpty(isEvening)) isEvening = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(channel)) channel = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- string channelPayment = Convert.ToString(obj["channelPayment"]);
- if (string.IsNullOrEmpty(channelPayment)) channelPayment = "-1";
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- //Chu y:
- // Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- //if (_tokenObj != null && _tokenObj.role == "USER")
- //{
- // if (_tokenObj.msisdn != msisdn)
- // {
- // logger.Info("Authen token false");
- // response.responseCode = "35";
- // response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- // return Ok(response);
- // }
- //}
- DataSet ds_regist = lotoDataAccess.reTotalByDayPrizeBolet(msisdn, fromDate, toDate, gameType, isEvening, channelPayment);
- response.responseCode = "0";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.list = new rpTotalByDayPrizeBoletObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- rpTotalByDayPrizeBoletObj _obj = new rpTotalByDayPrizeBoletObj();
- _obj.date = ds_regist.Tables[0].Rows[j]["ngay"].ToString();
- _obj.player = ds_regist.Tables[0].Rows[j]["player"].ToString();
- _obj.ticket = ds_regist.Tables[0].Rows[j]["ticket"].ToString();
- _obj.money = ds_regist.Tables[0].Rows[j]["money"].ToString();
- _obj.palyerWin = ds_regist.Tables[0].Rows[j]["player_win"].ToString();
- _obj.ticketWin = ds_regist.Tables[0].Rows[j]["ticket_win"].ToString();
- _obj.moneyWin = ds_regist.Tables[0].Rows[j]["money_win"].ToString();
- _obj.ticketWinLot1 = ds_regist.Tables[0].Rows[j]["ticket_win_lot1"].ToString();
- _obj.moneyWinLot1 = ds_regist.Tables[0].Rows[j]["money_win_lot1"].ToString();
- _obj.ticketWinLot2 = ds_regist.Tables[0].Rows[j]["ticket_win_lot2"].ToString();
- _obj.moneyWinLot2 = ds_regist.Tables[0].Rows[j]["money_win_lot2"].ToString();
- _obj.ticketWinLot3 = ds_regist.Tables[0].Rows[j]["ticket_win_lot3"].ToString();
- _obj.moneyWinLot3 = ds_regist.Tables[0].Rows[j]["money_win_lot3"].ToString();
- response.list[j] = _obj;
- }
- return Ok(response);
- }
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult rpSearchDetailTicket([FromBody] dynamic sendData)
- {
- reSearchDetailBetListObj response = new reSearchDetailBetListObj();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- try
- {
- var obj = JObject.Parse(sendData.ToString());
- string msisdn = Convert.ToString(obj["msisdn"]);
- string gameId = Convert.ToString(obj["gameId"]);
- string gameType = Convert.ToString(obj["gameType"]); // --1=Newyork,2=Florida
- string isEvening = Convert.ToString(obj["isEvening"]); // --1=evening,0= not evening
- string channel = Convert.ToString(obj["channel"]);
- string fromDate = Convert.ToString(obj["fromDate"]);
- string toDate = Convert.ToString(obj["toDate"]);
- string isWin = Convert.ToString(obj["isWin"]);
- string token = Convert.ToString(obj["token"]);
- string language = Convert.ToString(obj["language"]);
- if (string.IsNullOrEmpty(language)) language = "1";
- if (string.IsNullOrEmpty(msisdn)) msisdn = "-1";
- if (string.IsNullOrEmpty(gameId)) gameId = "-1";
- if (string.IsNullOrEmpty(gameType)) gameType = "-1";
- if (string.IsNullOrEmpty(isEvening)) isEvening = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(channel)) channel = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(isWin)) isWin = "-1";
- string channelPayment = Convert.ToString(obj["channelPayment"]);
- if (string.IsNullOrEmpty(channelPayment)) channelPayment = "-1";
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- ////Chu y:
- //// Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- //if (_tokenObj != null && _tokenObj.role == "USER")
- //{
- // if (_tokenObj.msisdn != msisdn)
- // {
- // logger.Info("Authen token false");
- // response.responseCode = "35";
- // response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- // return Ok(response);
- // }
- //}
- DataSet ds_regist = lotoDataAccess.reSearDeatailBet(msisdn, fromDate, toDate, gameId, gameType, isEvening, channelPayment, isWin);
- response.responseCode = "0";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.list = new reSearchDetailBetObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- reSearchDetailBetObj _obj = new reSearchDetailBetObj();
- _obj.msisdn = ds_regist.Tables[0].Rows[j]["USERS"].ToString();
- _obj.lottery = ds_regist.Tables[0].Rows[j]["LOTTERY"].ToString();
- _obj.game = ds_regist.Tables[0].Rows[j]["GAME"].ToString();
- _obj.channel = ds_regist.Tables[0].Rows[j]["CHANNEL"].ToString();
- _obj.ticketId = ds_regist.Tables[0].Rows[j]["ticketID"].ToString();
- _obj.ticketCode = ds_regist.Tables[0].Rows[j]["ticketCode"].ToString();
- _obj.buyTime = ds_regist.Tables[0].Rows[j]["vsysdate"].ToString();
- _obj.isEvening = ds_regist.Tables[0].Rows[j]["IS_EVENING"].ToString();
- _obj.drawTime = ds_regist.Tables[0].Rows[j]["DATE_RANDOM"].ToString();
- _obj.money = ds_regist.Tables[0].Rows[j]["MONEY"].ToString();
- _obj.moneyWin = ds_regist.Tables[0].Rows[j]["MONEY_WIN"].ToString();
- _obj.result = ds_regist.Tables[0].Rows[j]["str"].ToString();
- response.list[j] = _obj;
- }
- return Ok(response);
- }
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult rpSearchDetailTicketLkps([FromBody] dynamic sendData)
- {
- reSearchDetailBetListObj response = new reSearchDetailBetListObj();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- try
- {
- var obj = JObject.Parse(sendData.ToString());
- string msisdn = Convert.ToString(obj["msisdn"]);
-
- string channel = Convert.ToString(obj["channel"]);
- string fromDate = Convert.ToString(obj["fromDate"]);
- string toDate = Convert.ToString(obj["toDate"]);
- string isWin = Convert.ToString(obj["isWin"]);
- string token = Convert.ToString(obj["token"]);
- string language = Convert.ToString(obj["language"]);
- if (string.IsNullOrEmpty(language)) language = "1";
- if (string.IsNullOrEmpty(msisdn)) msisdn = "-1";
-
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(channel)) channel = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(isWin)) isWin = "-1";
- string channelPayment = Convert.ToString(obj["channelPayment"]);
- if (string.IsNullOrEmpty(channelPayment)) channelPayment = "-1";
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- ////Chu y:
- //// Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- //if (_tokenObj != null && _tokenObj.role == "USER")
- //{
- // if (_tokenObj.msisdn != msisdn)
- // {
- // logger.Info("Authen token false");
- // response.responseCode = "35";
- // response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- // return Ok(response);
- // }
- //}
- DataSet ds_regist = lotoDataAccess.reSearDeatailBetLkps(msisdn, fromDate, toDate, channelPayment, isWin);
- response.responseCode = "0";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.list = new reSearchDetailBetObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- reSearchDetailBetObj _obj = new reSearchDetailBetObj();
- _obj.msisdn = ds_regist.Tables[0].Rows[j]["USERS"].ToString();
-
-
- _obj.channel = ds_regist.Tables[0].Rows[j]["CHANNEL"].ToString();
- _obj.ticketId = ds_regist.Tables[0].Rows[j]["ticketID"].ToString();
- _obj.ticketCode = ds_regist.Tables[0].Rows[j]["ticketCode"].ToString();
- _obj.buyTime = ds_regist.Tables[0].Rows[j]["vsysdate"].ToString();
-
- _obj.drawTime = ds_regist.Tables[0].Rows[j]["DATE_RANDOM"].ToString();
- _obj.money = ds_regist.Tables[0].Rows[j]["MONEY"].ToString();
- _obj.moneyWin = ds_regist.Tables[0].Rows[j]["MONEY_WIN"].ToString();
- _obj.result = ds_regist.Tables[0].Rows[j]["str"].ToString();
- response.list[j] = _obj;
- }
- return Ok(response);
- }
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult rpSearchDetailTicketUniqueMsisdn([FromBody] dynamic sendData)
- {
- reSearchDetailBetListObj response = new reSearchDetailBetListObj();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- try
- {
- var obj = JObject.Parse(sendData.ToString());
- string msisdn = Convert.ToString(obj["msisdn"]);
- string gameId = Convert.ToString(obj["gameId"]);
- string gameType = Convert.ToString(obj["gameType"]); // --1=Newyork,2=Florida
- string isEvening = Convert.ToString(obj["isEvening"]); // --1=evening,0= not evening
- string channel = Convert.ToString(obj["channel"]);
- string fromDate = Convert.ToString(obj["fromDate"]);
- string toDate = Convert.ToString(obj["toDate"]);
- string isWin = Convert.ToString(obj["isWin"]);
- string token = Convert.ToString(obj["token"]);
- string language = Convert.ToString(obj["language"]);
- if (string.IsNullOrEmpty(language)) language = "1";
- if (string.IsNullOrEmpty(msisdn)) msisdn = "-1";
- if (string.IsNullOrEmpty(gameId)) gameId = "-1";
- if (string.IsNullOrEmpty(gameType)) gameType = "-1";
- if (string.IsNullOrEmpty(isEvening)) isEvening = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(channel)) channel = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(isWin)) isWin = "-1";
- string channelPayment = Convert.ToString(obj["channelPayment"]);
- if (string.IsNullOrEmpty(channelPayment)) channelPayment = "-1";
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- ////Chu y:
- //// Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- //if (_tokenObj != null && _tokenObj.role == "USER")
- //{
- // if (_tokenObj.msisdn != msisdn)
- // {
- // logger.Info("Authen token false");
- // response.responseCode = "35";
- // response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- // return Ok(response);
- // }
- //}
- DataSet ds_regist = lotoDataAccess.reSearDeatailBetUniqueMsisdn(msisdn, fromDate, toDate, gameId, gameType, isEvening, channelPayment, isWin);
- response.responseCode = "0";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.list = new reSearchDetailBetObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- reSearchDetailBetObj _obj = new reSearchDetailBetObj();
- _obj.msisdn = ds_regist.Tables[0].Rows[j]["USERS"].ToString();
- _obj.lottery = ds_regist.Tables[0].Rows[j]["LOTTERY"].ToString();
- _obj.game = ds_regist.Tables[0].Rows[j]["GAME"].ToString();
- _obj.channel = ds_regist.Tables[0].Rows[j]["CHANNEL"].ToString();
- _obj.ticketId = ds_regist.Tables[0].Rows[j]["ticketID"].ToString();
- _obj.ticketCode = ds_regist.Tables[0].Rows[j]["ticketCode"].ToString();
- _obj.buyTime = ds_regist.Tables[0].Rows[j]["vsysdate"].ToString();
- _obj.isEvening = ds_regist.Tables[0].Rows[j]["IS_EVENING"].ToString();
- _obj.drawTime = ds_regist.Tables[0].Rows[j]["DATE_RANDOM"].ToString();
- _obj.money = ds_regist.Tables[0].Rows[j]["MONEY"].ToString();
- _obj.moneyWin = ds_regist.Tables[0].Rows[j]["MONEY_WIN"].ToString();
- _obj.result = ds_regist.Tables[0].Rows[j]["str"].ToString();
- response.list[j] = _obj;
- }
- return Ok(response);
- }
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult updateResultManua([FromBody] dynamic sendData)
- {
- Response response = new Response();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- try
- {
- var obj = JObject.Parse(sendData.ToString());
- string termId = Convert.ToString(obj["termId"]);
- string result = Convert.ToString(obj["result"]);
- string users = Convert.ToString(obj["users"]);
-
- string channel = Convert.ToString(obj["channel"]);
-
- string token = Convert.ToString(obj["token"]);
- string language = Convert.ToString(obj["language"]);
- if (string.IsNullOrEmpty(language)) language = "1";
- if (string.IsNullOrEmpty(termId)) termId = "-1";
- if (string.IsNullOrEmpty(result)) result = "-1";
- if (string.IsNullOrEmpty(users)) users = "-1";
- if (string.IsNullOrEmpty(channel)) channel = "-1";
-
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- DataSet ds_regist = lotoDataAccess.resultUpdateManual(termId,result,users);
- logger.Info("Call database resultUpdateManual success:");
- if(ds_regist!=null && ds_regist.Tables[0].Rows.Count>0)
- {
- response.responseCode = ds_regist.Tables[0].Rows[0]["status"].ToString();
- response.responseMessage = ds_regist.Tables[0].Rows[0]["message"].ToString();
- }
- else
- {
- response.responseCode = "0";
- response.responseMessage = "nodata";
- }
-
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult rpSearchDetailMtBuyMsisdn([FromBody] dynamic sendData)
- {
- mtList response = new mtList();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- logger.Info("Request from UI getCurentTerm: " + sendData.ToString());
- try
- {
- var obj = JObject.Parse(sendData.ToString());
- string msisdn = Convert.ToString(obj["msisdn"]);
-
- string channel = Convert.ToString(obj["channel"]);
- string fromDate = Convert.ToString(obj["fromDate"]);
- string toDate = Convert.ToString(obj["toDate"]);
-
- string token = Convert.ToString(obj["token"]);
- string language = Convert.ToString(obj["language"]);
- if (string.IsNullOrEmpty(language)) language = "1";
- if (string.IsNullOrEmpty(msisdn)) msisdn = "-1";
-
-
- if (string.IsNullOrEmpty(channel)) channel = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
-
- string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
- string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
- string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
- var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
- //---------------------Lay ra va luu mot redis tu cache-----------------------------
- redisConnection _redis;
- memoryCache.TryGetValue("redis", out _redis);
- if (_redis == null)
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
- _redis.connet();
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- if (!_redis.isConnet())
- {
- if (!_redis.connet())
- {
- logger.Info("Connect to redis false");
- response.responseCode = "-2";
- response.responseMessage = "System Update";
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- else
- {
- var cacheExpiryOptions = new MemoryCacheEntryOptions
- {
- AbsoluteExpiration = DateTime.Now.AddMonths(12),
- Priority = CacheItemPriority.High,
- SlidingExpiration = TimeSpan.FromMinutes(2),
- Size = 1024,
- };
- memoryCache.Set("redis", _redis, cacheExpiryOptions);
- }
- }
- //----------------------Ket thuc lay redis tu cache -------------------------------------
- tokenObj _tokenObj = null;
- if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
- {
- logger.Info("Authen token false");
- response.responseCode = "35";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- logger.Info("confirmTicket response : " + response.ToString());
- return Ok(response);
- }
- ////Chu y:
- //// Voi nhung ham quan trong thi neu out _tokenObj !=null thi ta len kiem tra msisdn trong body voi msisdn trong token
- //if (_tokenObj != null && _tokenObj.role == "USER")
- //{
- // if (_tokenObj.msisdn != msisdn)
- // {
- // logger.Info("Authen token false");
- // response.responseCode = "35";
- // response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- // return Ok(response);
- // }
- //}
- DataSet ds_regist = lotoDataAccess.reSearDeatailMt(msisdn, fromDate, toDate);
- response.responseCode = "0";
- response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.list = new mtObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- mtObj _obj = new mtObj();
- _obj.id = ds_regist.Tables[0].Rows[j]["MT_HIS_ID"].ToString();
- _obj.msisdn = ds_regist.Tables[0].Rows[j]["MSISDN"].ToString();
- _obj.message = ds_regist.Tables[0].Rows[j]["MESSAGE"].ToString();
- _obj.sendTime = ds_regist.Tables[0].Rows[j]["SENT_TIME"].ToString();
- _obj.receiveTime = ds_regist.Tables[0].Rows[j]["RECEIVE_TIME"].ToString();
- _obj.status = ds_regist.Tables[0].Rows[j]["STATUS"].ToString();
- _obj.channel = ds_regist.Tables[0].Rows[j]["CHANNEL"].ToString();
-
- response.list[j] = _obj;
- }
- return Ok(response);
- }
- }
- catch (Exception ex)
- {
- logger.Info("sendOtp exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("sendOtp response : " + response.ToString());
- return Ok(response);
- }
- }
- }
|