using System; using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Mvc; using Microsoft.Extensions.Caching.Memory; using Newtonsoft.Json.Linq; using ResfullApi.Models; using System.Data; using System.Net; using System.Net.Http; using ApiProcess.Models.bet; using Newtonsoft.Json; using System.Collections; using System.Web; using System.Text; using System.Security.Cryptography; using ResfullApi.Models.bet; using CommonObj.common; namespace ApiProcess.Controllers { [ApiController] [Route("api/[controller]/[action]/data")] public class luckyGameCms : ControllerBase { static readonly log4net.ILog logger = log4net.LogManager.GetLogger(typeof(luckyGame)); private IMemoryCache memoryCache; public luckyGameCms(IMemoryCache memoryCache) { this.memoryCache = memoryCache; } // Lay ve danh sach cac term cua game_id //chu y voi status nhu sau: //--1: dang cho phep mua ticket,2: khoa va ko cho phep mua ticket doi nhap ket qua,3: da nhap ket qua roi,4=tu choi,5=duyet //Voi game LKPW muon lay danh sach term de nhap ket qua thi phai du status=2,4 [HttpPost] public IActionResult getTermList([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } betGetTermList response = new betGetTermList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string usersName = Convert.ToString(obj["usersName"]); string gameId = Convert.ToString(obj["gameId"]); string id = Convert.ToString(obj["id"]); string serviceId = Convert.ToString(obj["serviceId"]); string channel = Convert.ToString(obj["channel"]); string language = Convert.ToString(obj["language"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string status = Convert.ToString(obj["status"]); string rowsOnPage = Convert.ToString(obj["rowsOnPage"]); string seqPage = Convert.ToString(obj["seqPage"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(usersName)) usersName = "-1"; if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(serviceId)) serviceId = "-1"; if (string.IsNullOrEmpty(channel)) channel = "APP"; if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(status)) status = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; if (string.IsNullOrEmpty(id)) id = "-1"; if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; if (string.IsNullOrEmpty(status)) status = "-1"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); //string channel = Convert.ToString(userObj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, language, urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, channel); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.getListTerm(usersName, gameId, serviceId, channel, language, fromDate, toDate, status, rowsOnPage, seqPage,id); logger.Info("Call database getTermList success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; response.rowsOnPage = ds_regist.Tables[0].Rows[0]["ROW_ON_PAGE"].ToString(); response.seqPage = ds_regist.Tables[0].Rows[0]["SEQ_PAGE"].ToString(); response.gameId = gameId; response.totalPage = ds_regist.Tables[0].Rows[0]["TOTAL_PAGE"].ToString(); response.listTerm = new betGetTerm[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { betGetTerm _obj = new betGetTerm(); _obj.seq = ds_regist.Tables[0].Rows[j]["seq"].ToString(); _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString(); _obj.date_start = ds_regist.Tables[0].Rows[j]["DATE_START"].ToString(); _obj.date_end = ds_regist.Tables[0].Rows[j]["DATE_END"].ToString(); _obj.date_random = ds_regist.Tables[0].Rows[j]["DATE_RANDOM"].ToString(); _obj.status = ds_regist.Tables[0].Rows[j]["status"].ToString(); _obj.gameId = ds_regist.Tables[0].Rows[j]["gameID"].ToString(); _obj.result = ds_regist.Tables[0].Rows[j]["STR"].ToString(); _obj.split = ds_regist.Tables[0].Rows[j]["SPLT"].ToString(); _obj.countDownSeconds = ds_regist.Tables[0].Rows[j]["countDown"].ToString(); response.listTerm[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, language, urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, channel); } return Ok(response); } //Ham nay ho tro nhan vien nhap du lieu giai thuong vao he thong //status: --0=nhap lieu,1=tu choi,2=accept [HttpPost] public IActionResult lkpwResultUpdate([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } ResCommnon response = new ResCommnon(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string usersName = Convert.ToString(obj["usersName"]); string randomId = Convert.ToString(obj["randomId"]); string result = Convert.ToString(obj["result"]); string status = Convert.ToString(obj["action"]); //0=nhap lieu;1=tu choi;2=chap nhan string note = Convert.ToString(obj["note"]); string key = Convert.ToString(obj["key"]); string channel = Convert.ToString(obj["channel"]); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(usersName)) usersName = "-1"; if (string.IsNullOrEmpty(randomId)) randomId = "-1"; if (string.IsNullOrEmpty(result)) result = "-1"; if (string.IsNullOrEmpty(status)) status = "-1"; if (string.IsNullOrEmpty(note)) note = ""; if (string.IsNullOrEmpty(key)) key = "-1"; if (string.IsNullOrEmpty(channel)) channel = "APP"; if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); //string channel = Convert.ToString(userObj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, language, urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, channel); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.lkpw_result_update(randomId, usersName, result, status, note); logger.Info("Call database lkpwResultUpdate 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]["msg"].ToString(); } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, language, urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, channel); } return Ok(response); } //Ham nay lay ve lich su cua mot ket qua nhap lieu [HttpPost] public IActionResult lkpwResultGetHis([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } lkpwResultHisList response = new lkpwResultHisList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string usersName = Convert.ToString(obj["usersName"]); string randomId = Convert.ToString(obj["randomId"]); string channel = Convert.ToString(obj["channel"]); string language = Convert.ToString(obj["language"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(randomId)) randomId = "-1"; if (string.IsNullOrEmpty(usersName)) usersName = "-1"; if (string.IsNullOrEmpty(channel)) channel = "APP"; if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(key)) key = "-1"; try { //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, language, urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, channel); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.lkpw_result_get_his(randomId,usersName); logger.Info("Call database lkpwResultGetHis success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; response.listHis = new lkpwResultHis[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { lkpwResultHis _obj = new lkpwResultHis(); _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString(); _obj.randomId = ds_regist.Tables[0].Rows[j]["RANDOM_ID"].ToString(); _obj.date = ds_regist.Tables[0].Rows[j]["VSYSDATE"].ToString(); _obj.result = ds_regist.Tables[0].Rows[j]["STR"].ToString(); _obj.usersName = ds_regist.Tables[0].Rows[j]["USERS"].ToString(); _obj.status = ds_regist.Tables[0].Rows[j]["STATUS"].ToString(); _obj.action = ds_regist.Tables[0].Rows[j]["ACTION"].ToString(); _obj.note = ds_regist.Tables[0].Rows[j]["NOTE"].ToString(); response.listHis[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, language, urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, channel); } return Ok(response); } //Them mot export du lieu [HttpPost] public IActionResult exportCreated([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } ResCommnon response = new ResCommnon(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI export_created: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string usersName = Convert.ToString(obj["usersName"]); string gameId = Convert.ToString(obj["gameId"]); string name = Convert.ToString(obj["name"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string key = Convert.ToString(obj["key"]); //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(usersName)) usersName = "-1"; if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(name)) name = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = ""; if (string.IsNullOrEmpty(key)) key = "-1"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.export_created(usersName, gameId, name, fromDate, toDate); logger.Info("Call database export_created 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]["msg"].ToString(); } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } //Chuyen doi trang thai cua mot export //--;0=delete data ,1=start upload data,2=finish upload data xong, doi duyet,3=reject,4= duyet;5=delete export [HttpPost] public IActionResult exportAction([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } ResCommnon response = new ResCommnon(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI export_created: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string usersName = Convert.ToString(obj["usersName"]); string exportId = Convert.ToString(obj["exportId"]); string type = Convert.ToString(obj["type"]); string note = Convert.ToString(obj["note"]); string key = Convert.ToString(obj["key"]); //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(usersName)) usersName = "-1"; if (string.IsNullOrEmpty(exportId)) exportId = "-1"; if (string.IsNullOrEmpty(type)) type = "-1"; if (string.IsNullOrEmpty(note)) note = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.export_action(usersName, exportId, type, note); logger.Info("Call database export_created 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]["msg"].ToString(); } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } //Cho phep lay danh sach nguoi trung thuong tu he thong ve //du vao gameId, tu ngay, den ngayf [HttpPost] public IActionResult exportWinnerGetData([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } lotoExportDataList response = new lotoExportDataList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string usersName = Convert.ToString(obj["usersName"]); string gameId = Convert.ToString(obj["gameId"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string isPayOnline = Convert.ToString(obj["isPayOnline"]); string rowsOnPage = Convert.ToString(obj["rowsOnPage"]); string seqPage = Convert.ToString(obj["seqPage"]); string isPayType = Convert.ToString(obj["isPayType"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(usersName)) usersName = "-1"; if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(isPayOnline)) isPayOnline = "-1"; if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "10000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; if (string.IsNullOrEmpty(isPayType)) isPayType = "-1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(key)) key = "-1"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.export_winner_get_data(usersName, gameId, fromDate, toDate, isPayOnline, rowsOnPage, seqPage, isPayType); logger.Info("Call database export_winner_get_data success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; 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.listLotoExportData = new lotoExportData[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { lotoExportData _obj = new lotoExportData(); _obj.seq = ds_regist.Tables[0].Rows[j]["seq"].ToString(); _obj.winnerId = ds_regist.Tables[0].Rows[j]["WINNER_ID"].ToString(); _obj.msisdn = ds_regist.Tables[0].Rows[j]["MSISDN"].ToString(); _obj.date = ds_regist.Tables[0].Rows[j]["VSYSDATE"].ToString(); _obj.gameId = ds_regist.Tables[0].Rows[j]["GAME_ID"].ToString(); _obj.randomId = ds_regist.Tables[0].Rows[j]["RANDOM_ID"].ToString(); _obj.betId = ds_regist.Tables[0].Rows[j]["BET_ID"].ToString(); _obj.isPayOnline = ds_regist.Tables[0].Rows[j]["IS_PAY_ONLINE"].ToString(); _obj.isPay = ds_regist.Tables[0].Rows[j]["IS_PAY"].ToString(); _obj.winnerCode = ds_regist.Tables[0].Rows[j]["WINNER_CODE"].ToString(); _obj.winnerName = ds_regist.Tables[0].Rows[j]["WINNER_NAME"].ToString(); _obj.money = ds_regist.Tables[0].Rows[j]["MONEY"].ToString(); response.listLotoExportData[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } //Cho phep lay danh sach nguoi trung thuong tu he thong ve //du vao gameId, tu ngay, den ngayf [HttpPost] public IActionResult exportWinnerGetDataById([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } lotoExportDataList response = new lotoExportDataList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string usersName = Convert.ToString(obj["usersName"]); string exportId = Convert.ToString(obj["exportId"]); string type = Convert.ToString(obj["type"]); string rowsOnPage = Convert.ToString(obj["rowsOnPage"]); string seqPage = Convert.ToString(obj["seqPage"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(usersName)) usersName = "-1"; if (string.IsNullOrEmpty(exportId)) exportId = "-1"; if (string.IsNullOrEmpty(type)) type = "-1"; if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "100000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(key)) key = "-1"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.export_winner_get_data_byId(usersName, exportId, type, rowsOnPage, seqPage); logger.Info("Call database export_winner_get_data_byId success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; 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.listLotoExportData = new lotoExportData[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { lotoExportData _obj = new lotoExportData(); _obj.seq = ds_regist.Tables[0].Rows[j]["seq"].ToString(); _obj.winnerId = ds_regist.Tables[0].Rows[j]["WINNER_ID"].ToString(); _obj.msisdn = ds_regist.Tables[0].Rows[j]["MSISDN"].ToString(); _obj.date = ds_regist.Tables[0].Rows[j]["VSYSDATE"].ToString(); _obj.gameId = ds_regist.Tables[0].Rows[j]["GAME_ID"].ToString(); _obj.randomId = ds_regist.Tables[0].Rows[j]["RANDOM_ID"].ToString(); _obj.betId = ds_regist.Tables[0].Rows[j]["BET_ID"].ToString(); _obj.isPayOnline = ds_regist.Tables[0].Rows[j]["IS_PAY_ONLINE"].ToString(); _obj.isPay = ds_regist.Tables[0].Rows[j]["IS_PAY"].ToString(); _obj.winnerCode = ds_regist.Tables[0].Rows[j]["WINNER_CODE"].ToString(); _obj.winnerName = ds_regist.Tables[0].Rows[j]["WINNER_NAME"].ToString(); _obj.money = ds_regist.Tables[0].Rows[j]["MONEY"].ToString(); response.listLotoExportData[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } //Ham nay lay ve lich su cua mot export [HttpPost] public IActionResult exportGetHis([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } lotoExportHisList response = new lotoExportHisList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string usersName = Convert.ToString(obj["usersName"]); string exportId = Convert.ToString(obj["exportId"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(exportId)) exportId = "-1"; if (string.IsNullOrEmpty(usersName)) usersName = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.export_get_his(exportId, usersName); logger.Info("Call database export_get_his success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; response.listLotoExportHis = new lotoExportHis[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { lotoExportHis _obj = new lotoExportHis(); _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString(); _obj.users = ds_regist.Tables[0].Rows[j]["USERS"].ToString(); _obj.date = ds_regist.Tables[0].Rows[j]["VSYSDATE"].ToString(); _obj.note = ds_regist.Tables[0].Rows[j]["NOTE"].ToString(); _obj.status = ds_regist.Tables[0].Rows[j]["STATUS"].ToString(); _obj.exportId = ds_regist.Tables[0].Rows[j]["EXPORT_ID"].ToString(); _obj.action = ds_regist.Tables[0].Rows[j]["ACTION"].ToString(); response.listLotoExportHis[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } //Ham nay lay ve danh sach export [HttpPost] public IActionResult exportGetList([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } lotoExportGetList response = new lotoExportGetList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string usersName = Convert.ToString(obj["usersName"]); string exportId = Convert.ToString(obj["exportId"]); string gameId = Convert.ToString(obj["gameId"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string rowsOnPage = Convert.ToString(obj["rowsOnPage"]); string seqPage = Convert.ToString(obj["seqPage"]); string status = Convert.ToString(obj["status"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(usersName)) usersName = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; if (string.IsNullOrEmpty(status)) status = "-1"; if (string.IsNullOrEmpty(exportId)) exportId = "-1"; if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.export_get_list( usersName, gameId, fromDate, toDate,rowsOnPage,seqPage, status,exportId); logger.Info("Call database export_get_list success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; 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.listLotoExportGet = new lotoExportGet[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { lotoExportGet _obj = new lotoExportGet(); _obj.seq = ds_regist.Tables[0].Rows[j]["seq"].ToString(); _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString(); _obj.code = ds_regist.Tables[0].Rows[j]["CODE"].ToString(); _obj.name = ds_regist.Tables[0].Rows[j]["NAME"].ToString(); _obj.gameId = ds_regist.Tables[0].Rows[j]["GAME_ID"].ToString(); _obj.fromDate = ds_regist.Tables[0].Rows[j]["FROM_DATE"].ToString(); _obj.toDate = ds_regist.Tables[0].Rows[j]["TO_DATE"].ToString(); _obj.status = ds_regist.Tables[0].Rows[j]["STATUS"].ToString(); _obj.createUsers = ds_regist.Tables[0].Rows[j]["CREATED_USERS"].ToString(); _obj.createDate = ds_regist.Tables[0].Rows[j]["CREATED_DATE"].ToString(); _obj.acceptUsers = ds_regist.Tables[0].Rows[j]["ACCEPT_USERS"].ToString(); _obj.acceptDate = ds_regist.Tables[0].Rows[j]["ACCEPT_DATE"].ToString(); _obj.moneySystem = ds_regist.Tables[0].Rows[j]["MONEY_SYSTEM"].ToString(); _obj.moneyImport = ds_regist.Tables[0].Rows[j]["MONEY_IMPORT"].ToString(); _obj.moneyNotImport = ds_regist.Tables[0].Rows[j]["MONEY_NOT_IN_IMPORT"].ToString(); _obj.moneyNotSys = ds_regist.Tables[0].Rows[j]["MONEY_NOT_IN_SYS"].ToString(); response.listLotoExportGet[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } //Import data vao Export //--; [HttpPost] public IActionResult exportInsertData([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } ResCommnon response = new ResCommnon(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI export_created: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); lotoImportDataList _data = JsonConvert.DeserializeObject(sendData.ToString()); string key = Convert.ToString(obj["key"]); //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(key)) key = "-1"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } string export_id = _data.exportId; List> DataColumms = new List>(); var LIST_EXPORT_ID = new List(); var LIST_WINNER_ID = new List(); var LIST_MSISDN = new List(); var LIST_MONEY = new List(); var LIST_RANDOM_ID = new List(); var LIST_BET_ID = new List(); var LIST_WINNER_CODE = new List(); foreach (lotoImportData eachData in _data.data) { LIST_EXPORT_ID.Add(export_id); LIST_WINNER_ID.Add(eachData.winnerId); LIST_MSISDN.Add(eachData.msisdn); LIST_MONEY.Add(eachData.money); LIST_RANDOM_ID.Add(eachData.randomId); LIST_BET_ID.Add(eachData.betId); LIST_WINNER_CODE.Add(eachData.winnerCode); } DataColumms.Add(LIST_EXPORT_ID); DataColumms.Add(LIST_WINNER_ID); DataColumms.Add(LIST_MSISDN); DataColumms.Add(LIST_MONEY); DataColumms.Add(LIST_RANDOM_ID); DataColumms.Add(LIST_BET_ID); DataColumms.Add(LIST_WINNER_CODE); balanceDataAccess.InsertBulkExport("LOTO_CMS_PKG.export_insert_data", DataColumms); logger.Info("Call database export_created success:"); response.responseCode = "0"; response.responseMessage = "Success"; } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } //Import blacklist // //format: msisdn,isLock (1=lock,0=ko lock) [HttpPost] public IActionResult blackInsertData([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } ResCommnon response = new ResCommnon(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI export_created: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); lotoBlackInsertList _data = JsonConvert.DeserializeObject(sendData.ToString()); string key = Convert.ToString(obj["key"]); //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(key)) key = "-1"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } string users = _data.users; List> DataColumms = new List>(); var LIST_USERS = new List(); var LIST_MSISDN = new List(); var LIST_ISLOCK = new List(); var LIST_NOTE = new List(); foreach (lotoBlackInsert eachData in _data.data) { LIST_USERS.Add(users); LIST_MSISDN.Add(eachData.msisdn); LIST_ISLOCK.Add(eachData.isLock); LIST_NOTE.Add(eachData.note); } DataColumms.Add(LIST_USERS); DataColumms.Add(LIST_MSISDN); DataColumms.Add(LIST_ISLOCK); DataColumms.Add(LIST_NOTE); balanceDataAccess.InsertBulkBlack("LOTO_CMS_PKG.blacklist_insert_data", DataColumms); logger.Info("Call database export_created success:"); response.responseCode = "0"; response.responseMessage = "Success"; } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } //Ham nay lay ve lich su cua mot export [HttpPost] public IActionResult backListGetList([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } lotoBlackGetList response = new lotoBlackGetList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string usersName = Convert.ToString(obj["usersName"]); string msisdn = Convert.ToString(obj["msisdn"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string rowsOnPage = Convert.ToString(obj["rowsOnPage"]); string seqPage = Convert.ToString(obj["seqPage"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(usersName)) usersName = "-1"; if (string.IsNullOrEmpty(msisdn)) msisdn = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(key)) key = "-1"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.blackList_get_list(usersName, msisdn, fromDate, toDate, rowsOnPage, seqPage); logger.Info("Call database blackList_get_list success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; 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.listLotoBlackList = new lotoBlackGet[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { lotoBlackGet _obj = new lotoBlackGet(); _obj.seq = ds_regist.Tables[0].Rows[j]["seq"].ToString(); _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString(); _obj.msisdn = ds_regist.Tables[0].Rows[j]["MSISDN"].ToString(); _obj.date = ds_regist.Tables[0].Rows[j]["VSYSDATE"].ToString(); _obj.users = ds_regist.Tables[0].Rows[j]["USERS"].ToString(); _obj.isLock= ds_regist.Tables[0].Rows[j]["ISLOCK"].ToString(); _obj.note = ds_regist.Tables[0].Rows[j]["NOTE"].ToString(); response.listLotoBlackList[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } //Ham nay lay ve lich su cua mot ket qua nhap lieu [HttpPost] public IActionResult cmsGetTraficByDay([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } cmsRevenueList response = new cmsRevenueList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string gameId = Convert.ToString(obj["gameId"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string rowsOnPage = Convert.ToString(obj["rowsOnPage"]); string seqPage = Convert.ToString(obj["seqPage"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.report_get_total_trafic(gameId, fromDate,toDate, rowsOnPage, seqPage); logger.Info("Call database report_get_total_trafic success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; 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.listRevenue = new cmsRevenue[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { cmsRevenue _obj = new cmsRevenue(); _obj.date = ds_regist.Tables[0].Rows[j]["ngay"].ToString(); _obj.gameId = ds_regist.Tables[0].Rows[j]["gameId"].ToString(); _obj.totalUser = ds_regist.Tables[0].Rows[j]["unique_users"].ToString(); _obj.totalTicket = ds_regist.Tables[0].Rows[j]["ticket"].ToString(); _obj.totalMoney = ds_regist.Tables[0].Rows[j]["money_buy"].ToString(); _obj.totalTicketWin = ds_regist.Tables[0].Rows[j]["ticket_win"].ToString(); _obj.totalMoneyWin = ds_regist.Tables[0].Rows[j]["money_win"].ToString(); _obj.rate = ds_regist.Tables[0].Rows[j]["tyle"].ToString(); response.listRevenue[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } //Ham nay lay ve lich su cua mot ket qua nhap lieu [HttpPost] public IActionResult cmsSearMsisdn([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } cmsSearchMsisdnList response = new cmsSearchMsisdnList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string subId = Convert.ToString(obj["subId"]); string msisdn = Convert.ToString(obj["msisdn"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(subId)) subId = "-1"; if (string.IsNullOrEmpty(msisdn)) msisdn = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.cmsSearMsisdn(subId, msisdn); logger.Info("Call database cmsSearMsisdn success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; response.listSeachMsisdn = new cmsSearchMsisdn[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { cmsSearchMsisdn _obj = new cmsSearchMsisdn(); _obj.subId = ds_regist.Tables[0].Rows[j]["sub_id"].ToString(); _obj.msg = ds_regist.Tables[0].Rows[j]["msg"].ToString(); _obj.msisdn = ds_regist.Tables[0].Rows[j]["msisdn"].ToString(); _obj.lastLogin = ds_regist.Tables[0].Rows[j]["lastLogin"].ToString(); _obj.createDate = ds_regist.Tables[0].Rows[j]["createDate"].ToString(); _obj.note = ds_regist.Tables[0].Rows[j]["note"].ToString(); _obj.status= ds_regist.Tables[0].Rows[j]["status"].ToString(); _obj.lockDate = ds_regist.Tables[0].Rows[j]["lockDate"].ToString(); response.listSeachMsisdn[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } [HttpPost] public IActionResult cmsLockByMsisdn([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } ResCommnon response = new ResCommnon(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string subId = Convert.ToString(obj["subId"]); string msisdn = Convert.ToString(obj["msisdn"]); string users = Convert.ToString(obj["users"]); string isLock = Convert.ToString(obj["isLock"]); string note = Convert.ToString(obj["note"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(subId)) subId = "-1"; if (string.IsNullOrEmpty(msisdn)) msisdn = "-1"; if (string.IsNullOrEmpty(users)) users = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.cmsLockByMsisdn(subId, msisdn, users,isLock,note); logger.Info("Call database cmsSearMsisdn success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; } else { response.responseCode = "-1"; response.responseMessage = "Err"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } [HttpPost] public IActionResult cmsGetInfoTicket([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } cmsTicketInfoList response = new cmsTicketInfoList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string gameId = Convert.ToString(obj["gameId"]); string msisdn = Convert.ToString(obj["msisdn"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string rowsOnPage = Convert.ToString(obj["rowsOnPage"]); string seqPage = Convert.ToString(obj["seqPage"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(msisdn)) msisdn = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.cmsGetInfoTicket(gameId,msisdn, fromDate, toDate, rowsOnPage, seqPage); logger.Info("Call database cmsGetInfoTicket success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; 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.listTicketInfo = new cmsTicketInfo[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { cmsTicketInfo _obj = new cmsTicketInfo(); _obj.seq = ds_regist.Tables[0].Rows[j]["SEQ"].ToString(); _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString(); _obj.billCode = ds_regist.Tables[0].Rows[j]["BILL_CODE"].ToString(); _obj.subId = ds_regist.Tables[0].Rows[j]["SUBID"].ToString(); _obj.users = ds_regist.Tables[0].Rows[j]["USERS"].ToString(); _obj.date = ds_regist.Tables[0].Rows[j]["VSYSDATE"].ToString(); _obj.money = ds_regist.Tables[0].Rows[j]["MONEY"].ToString(); _obj.gameId = ds_regist.Tables[0].Rows[j]["gameId"].ToString(); _obj.ticket = ds_regist.Tables[0].Rows[j]["STR"].ToString(); _obj.note = ds_regist.Tables[0].Rows[j]["NOTE"].ToString(); _obj.randomId = ds_regist.Tables[0].Rows[j]["RANDOM_ID"].ToString(); response.listTicketInfo[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } [HttpPost] public IActionResult cmsGetTicketWin([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } cmsTicketWinList response = new cmsTicketWinList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string gameId = Convert.ToString(obj["gameId"]); string msisdn = Convert.ToString(obj["msisdn"]); string subId = Convert.ToString(obj["subId"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string rowsOnPage = Convert.ToString(obj["rowsOnPage"]); string seqPage = Convert.ToString(obj["seqPage"]); //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(msisdn)) msisdn = "-1"; if (string.IsNullOrEmpty(subId)) subId = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.cmsGetTicketWin(gameId,msisdn,subId, fromDate, toDate, rowsOnPage, seqPage); logger.Info("Call database cmsGetTicketWin success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; 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.listTicketWin = new cmsTicketWin[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { cmsTicketWin _obj = new cmsTicketWin(); _obj.seq = ds_regist.Tables[0].Rows[j]["SEQ"].ToString(); _obj.id = ds_regist.Tables[0].Rows[j]["WINNER_ID"].ToString(); _obj.date = ds_regist.Tables[0].Rows[j]["VSYSDATE"].ToString(); _obj.msisdn = ds_regist.Tables[0].Rows[j]["MSISDN"].ToString(); _obj.gameId = ds_regist.Tables[0].Rows[j]["GAME_ID"].ToString(); _obj.randomId = ds_regist.Tables[0].Rows[j]["RANDOM_ID"].ToString(); _obj.betId = ds_regist.Tables[0].Rows[j]["BET_ID"].ToString(); _obj.isPayOnline = ds_regist.Tables[0].Rows[j]["IS_PAY_ONLINE"].ToString(); _obj.isPay = ds_regist.Tables[0].Rows[j]["IS_PAY"].ToString(); _obj.winnerCode = ds_regist.Tables[0].Rows[j]["WINNER_CODE"].ToString(); _obj.winnerName = ds_regist.Tables[0].Rows[j]["WINNER_NAME"].ToString(); response.listTicketWin[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } [HttpPost] public IActionResult cmsGetTraficTotal([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } lotoTraficTotal response = new lotoTraficTotal(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string gameId = Convert.ToString(obj["gameId"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.cmsGetTraficTotal(gameId, fromDate, toDate); logger.Info("Call database cmsGetTraficTotal success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; response.uniqueUsers = ds_regist.Tables[0].Rows[0]["unique_users"].ToString(); response.totalTicket = ds_regist.Tables[0].Rows[0]["ticket"].ToString(); response.totalMoney = ds_regist.Tables[0].Rows[0]["money_buy"].ToString(); response.totalTicketWin = ds_regist.Tables[0].Rows[0]["ticket_win"].ToString(); response.totalMoneyWin = ds_regist.Tables[0].Rows[0]["money_win"].ToString(); } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } [HttpPost] public IActionResult cmsGetTop([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } lotoTopCusList response = new lotoTopCusList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI getTotalWinnerByBet: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string gameId = Convert.ToString(obj["gameId"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string type = Convert.ToString(obj["type"]); string totalRow = Convert.ToString(obj["totalRow"]); string rowsOnPage = Convert.ToString(obj["rowsOnPage"]); string seqPage = Convert.ToString(obj["seqPage"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(type)) type = "1"; if (string.IsNullOrEmpty(totalRow)) totalRow = "1000"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.cmsGetTop(gameId, fromDate, toDate, type, totalRow, rowsOnPage, seqPage); logger.Info("Call database cmsGetTop success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; 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.listLotoCusTop = new lotoTopCus[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { lotoTopCus _obj = new lotoTopCus(); _obj.seq = ds_regist.Tables[0].Rows[j]["SEQ"].ToString(); _obj.money = ds_regist.Tables[0].Rows[j]["MONEY"].ToString(); _obj.cusId = ds_regist.Tables[0].Rows[j]["ID"].ToString(); _obj.actStatus= ds_regist.Tables[0].Rows[j]["ACTSTATUS"].ToString(); _obj.address = ds_regist.Tables[0].Rows[j]["ADDRESS"].ToString(); _obj.birthday = ds_regist.Tables[0].Rows[j]["BIRTHDATE"].ToString(); _obj.district = ds_regist.Tables[0].Rows[j]["DISTRICT"].ToString(); _obj.gentder = ds_regist.Tables[0].Rows[j]["GENDER"].ToString(); _obj.idno=ds_regist.Tables[0].Rows[j]["IDNO"].ToString(); _obj.idtype = ds_regist.Tables[0].Rows[j]["IDTYPE"].ToString(); _obj.imageName1 = ds_regist.Tables[0].Rows[j]["IMAGENAME1"].ToString(); _obj.imageName2 = ds_regist.Tables[0].Rows[j]["IMAGENAME2"].ToString(); _obj.imageName3 = ds_regist.Tables[0].Rows[j]["IMAGENAME3"].ToString(); _obj.imagePath = ds_regist.Tables[0].Rows[j]["IMAGEPATH"].ToString(); _obj.isdn = ds_regist.Tables[0].Rows[j]["users"].ToString(); _obj.language = ds_regist.Tables[0].Rows[j]["LANGUAGE"].ToString(); _obj.precinct = ds_regist.Tables[0].Rows[j]["PRECINCT"].ToString(); _obj.province = ds_regist.Tables[0].Rows[j]["PROVINCE"].ToString(); _obj.subId = ds_regist.Tables[0].Rows[j]["SUBID"].ToString(); _obj.subName = ds_regist.Tables[0].Rows[j]["SUBNAME"].ToString(); _obj.isConfirm = ds_regist.Tables[0].Rows[j]["IS_CONFIRM"].ToString(); _obj.date = ds_regist.Tables[0].Rows[j]["VSYSDATE"].ToString(); _obj.lastUpdate = ds_regist.Tables[0].Rows[j]["LAST_UPDATE"].ToString(); response.listLotoCusTop[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } [HttpPost] public IActionResult cmsGetParamList([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } cmsParamList response = new cmsParamList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI cmsGetParamList: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string channel = Convert.ToString(obj["channel"]); string codeGroup = Convert.ToString(obj["codeGroup"]); string code = Convert.ToString(obj["code"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(channel)) channel = "-1"; if (string.IsNullOrEmpty(codeGroup)) codeGroup = "-1"; if (string.IsNullOrEmpty(code)) code = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); //string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.param_get_list(channel, codeGroup, code); logger.Info("Call database param_get_list success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; response.listParam = new cmsParam [ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { cmsParam _obj = new cmsParam(); _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.listParam[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } [HttpPost] public IActionResult cmsParamUpdate([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } ResCommnon response = new ResCommnon(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI cmsParamUpdate: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string id = Convert.ToString(obj["id"]); string values = Convert.ToString(obj["values"]); string note = Convert.ToString(obj["note"]); string display0 = Convert.ToString(obj["display0"]); string display1 = Convert.ToString(obj["display1"]); string display2 = Convert.ToString(obj["display2"]); string display3 = Convert.ToString(obj["display3"]); string display4 = Convert.ToString(obj["display4"]); string display5 = Convert.ToString(obj["display5"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(id)) id = "-1"; if (string.IsNullOrEmpty(values)) values = "-1"; if (string.IsNullOrEmpty(note)) note = "-1"; if (string.IsNullOrEmpty(display0)) display0 = "-1"; if (string.IsNullOrEmpty(display1)) display1 = "-1"; if (string.IsNullOrEmpty(display2)) display2 = "-1"; if (string.IsNullOrEmpty(display3)) display3 = "-1"; if (string.IsNullOrEmpty(display4)) display4 = "-1"; if (string.IsNullOrEmpty(display5)) display5 = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } if (id=="-1" || values=="-1" || note == "-1" || display0 == "-1" || display1 == "-1" || display2 == "-1" || display3 == "-1" || display4 == "-1" || display5 == "-1") { response.responseCode = "4"; //sai tham so //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "4", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.param_update(id, values, note, display0, display1, display2, display3, display4, display5); logger.Info("Call database param_get_list success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } [HttpPost] public IActionResult cmsRevenueTotal([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } cmsTraficTotalList response = new cmsTraficTotalList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI cmsGetParamList: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string channel = Convert.ToString(obj["channel"]); string serviceId = Convert.ToString(obj["serviceId"]); string gameId = Convert.ToString(obj["gameId"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(channel)) channel = "-1"; if (string.IsNullOrEmpty(serviceId)) serviceId = "-1"; if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); //string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.cmsDoanhThuTongHop(channel,serviceId, gameId, fromDate,toDate); logger.Info("Call database param_get_list success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; response.list = new cmsTraficTotal[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { cmsTraficTotal _obj = new cmsTraficTotal(); _obj.seq = ds_regist.Tables[0].Rows[j]["seq"].ToString(); _obj.gameName = ds_regist.Tables[0].Rows[j]["tenGiai"].ToString(); _obj.total = ds_regist.Tables[0].Rows[j]["tongBet"].ToString(); _obj.moneyAfterTax = ds_regist.Tables[0].Rows[j]["tienSauThue"].ToString(); _obj.moneyBeforeTax = ds_regist.Tables[0].Rows[j]["tienTruocThue"].ToString(); _obj.tax = ds_regist.Tables[0].Rows[j]["thue"].ToString(); _obj.moneyTax = ds_regist.Tables[0].Rows[j]["tienThue"].ToString(); response.list[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } [HttpPost] public IActionResult cmsPaymentTotal([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } cmsTraficTotalList response = new cmsTraficTotalList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI cmsGetParamList: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string channel = Convert.ToString(obj["channel"]); string serviceId = Convert.ToString(obj["serviceId"]); string gameId = Convert.ToString(obj["gameId"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(channel)) channel = "-1"; if (string.IsNullOrEmpty(serviceId)) serviceId = "-1"; if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); //string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.cmsTraThuongTongHop(channel, serviceId, gameId, fromDate, toDate); logger.Info("Call database param_get_list success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; response.list = new cmsTraficTotal[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { cmsTraficTotal _obj = new cmsTraficTotal(); _obj.seq = ds_regist.Tables[0].Rows[j]["seq"].ToString(); _obj.gameName = ds_regist.Tables[0].Rows[j]["tenGiai"].ToString(); _obj.total = ds_regist.Tables[0].Rows[j]["tongBet"].ToString(); _obj.moneyAfterTax = ds_regist.Tables[0].Rows[j]["tienSauThue"].ToString(); _obj.moneyBeforeTax = ds_regist.Tables[0].Rows[j]["tienTruocThue"].ToString(); _obj.tax = ds_regist.Tables[0].Rows[j]["thue"].ToString(); _obj.moneyTax = ds_regist.Tables[0].Rows[j]["tienThue"].ToString(); response.list[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } [HttpPost] public IActionResult cmsRevenueDetail([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } cmsTraficDetailList response = new cmsTraficDetailList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI cmsGetParamList: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string channel = Convert.ToString(obj["channel"]); string serviceId = Convert.ToString(obj["serviceId"]); string gameId = Convert.ToString(obj["gameId"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(channel)) channel = "-1"; if (string.IsNullOrEmpty(serviceId)) serviceId = "-1"; if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); //string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.cmsDoanhThuChiTiet(channel, serviceId, gameId, fromDate, toDate); logger.Info("Call database param_get_list success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; response.list = new cmsTraficDetail[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { cmsTraficDetail _obj = new cmsTraficDetail(); _obj.seq = ds_regist.Tables[0].Rows[j]["seq"].ToString(); _obj.gameName = ds_regist.Tables[0].Rows[j]["tenGiai"].ToString(); _obj.billCode = ds_regist.Tables[0].Rows[j]["BILL_CODE"].ToString(); _obj.tranCode = ds_regist.Tables[0].Rows[j]["ID"].ToString(); _obj.date = ds_regist.Tables[0].Rows[j]["VSYSDATE"].ToString(); _obj.cusName = ds_regist.Tables[0].Rows[j]["NAME"].ToString(); _obj.msisdn = ds_regist.Tables[0].Rows[j]["USERS"].ToString(); _obj.quantity = ds_regist.Tables[0].Rows[j]["SOLUONG"].ToString(); _obj.price = ds_regist.Tables[0].Rows[j]["DONGIA"].ToString(); _obj.moneyAfterTax = ds_regist.Tables[0].Rows[j]["TIEN_SAU_THUE"].ToString(); _obj.moneyBeforeTax = ds_regist.Tables[0].Rows[j]["TIEN_TRUOC_THUE"].ToString(); _obj.tax = ds_regist.Tables[0].Rows[j]["THUE"].ToString(); _obj.moneyTax = ds_regist.Tables[0].Rows[j]["TIEN_THUE"].ToString(); response.list[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } [HttpPost] public IActionResult cmsPaymentDetail([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } cmsTraficDetailList response = new cmsTraficDetailList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI cmsGetParamList: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string channel = Convert.ToString(obj["channel"]); string serviceId = Convert.ToString(obj["serviceId"]); string gameId = Convert.ToString(obj["gameId"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(channel)) channel = "-1"; if (string.IsNullOrEmpty(serviceId)) serviceId = "-1"; if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); //string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.cmsTraThuongChiTiet(channel, serviceId, gameId, fromDate, toDate); logger.Info("Call database param_get_list success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; response.list = new cmsTraficDetail[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { cmsTraficDetail _obj = new cmsTraficDetail(); _obj.seq = ds_regist.Tables[0].Rows[j]["seq"].ToString(); _obj.gameName = ds_regist.Tables[0].Rows[j]["tenGiai"].ToString(); _obj.billCode = ds_regist.Tables[0].Rows[j]["BILL_CODE"].ToString(); _obj.tranCode = ds_regist.Tables[0].Rows[j]["ID"].ToString(); _obj.date = ds_regist.Tables[0].Rows[j]["VSYSDATE"].ToString(); _obj.cusName = ds_regist.Tables[0].Rows[j]["NAME"].ToString(); _obj.msisdn = ds_regist.Tables[0].Rows[j]["USERS"].ToString(); _obj.quantity = ds_regist.Tables[0].Rows[j]["SOLUONG"].ToString(); _obj.price = ds_regist.Tables[0].Rows[j]["DONGIA"].ToString(); _obj.moneyAfterTax = ds_regist.Tables[0].Rows[j]["TIEN_SAU_THUE"].ToString(); _obj.moneyBeforeTax = ds_regist.Tables[0].Rows[j]["TIEN_TRUOC_THUE"].ToString(); _obj.tax = ds_regist.Tables[0].Rows[j]["THUE"].ToString(); _obj.moneyTax = ds_regist.Tables[0].Rows[j]["TIEN_THUE"].ToString(); response.list[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } [HttpPost] public IActionResult cmsTotalByTern([FromBody] dynamic sendData) { //Lay ve url va key voi muc dich post vao lay Message cua Errcode string urlPostGetErrCodeMessage = string.Empty, keyPostGetErrCodeMessage = string.Empty, _keyConfig = string.Empty; memoryCache.TryGetValue("urlPostGetErrCodeMessage", out urlPostGetErrCodeMessage); if (string.IsNullOrEmpty(urlPostGetErrCodeMessage)) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; urlPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "urlPostGetErrCodeMessage"); memoryCache.Set("urlPostGetErrCodeMessage", urlPostGetErrCodeMessage, cacheExpiryOptions); } memoryCache.TryGetValue("keyPostGetErrCodeMessage", out keyPostGetErrCodeMessage); if (string.IsNullOrEmpty(keyPostGetErrCodeMessage)) { var cacheExpiryOptions1 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; keyPostGetErrCodeMessage = Common.GetValuesAppSetting("webConfig", "keyPostGetErrCodeMessage"); memoryCache.Set("keyPostGetErrCodeMessage", keyPostGetErrCodeMessage, cacheExpiryOptions1); } memoryCache.TryGetValue("_keyConfig", out _keyConfig); if (string.IsNullOrEmpty(_keyConfig)) { var cacheExpiryOptions2 = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMinutes(5), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); memoryCache.Set("_keyConfig", _keyConfig, cacheExpiryOptions2); } cmsTotalByTermList response = new cmsTotalByTermList(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI cmsTotalByTern: " + sendData.ToString()); var obj = JObject.Parse(sendData.ToString()); string channel = Convert.ToString(obj["channel"]); string serviceId = Convert.ToString(obj["serviceId"]); string gameId = Convert.ToString(obj["gameId"]); string fromDate = Convert.ToString(obj["fromDate"]); string toDate = Convert.ToString(obj["toDate"]); string key = Convert.ToString(obj["key"]); if (string.IsNullOrEmpty(channel)) channel = "-1"; if (string.IsNullOrEmpty(serviceId)) serviceId = "-1"; if (string.IsNullOrEmpty(gameId)) gameId = "-1"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if (string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(key)) key = "-1"; //var obj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(obj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(obj["token"]); //string channel = Convert.ToString(obj["channel"]); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); redisConnection _redis = new redisConnection(RedisIp, RedisPort, RedisPass); if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = "Check Authen false"; return Ok(response); } //Ket thuc check token //Check key for authencation string _keyDecrypt =ResfullApi.Models.CustomEncryption.Decrypt(key); if (_keyDecrypt != _keyConfig) { response.responseCode = "-3"; //response.responseMessage = "Authentication is false"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); logger.Info("Responase to web: " + response.ToString()); return Ok(response); } DataSet ds_regist = balanceDataAccess.cmsTongHopTheoKyQuay(channel, serviceId, gameId, fromDate, toDate); logger.Info("Call database param_get_list success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.responseCode = "0"; response.responseMessage = "Success"; response.list = new cmsTotalByTerm[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { cmsTotalByTerm _obj = new cmsTotalByTerm(); _obj.randomId = ds_regist.Tables[0].Rows[j]["ID"].ToString(); _obj.startDate = ds_regist.Tables[0].Rows[j]["DATE_START"].ToString(); _obj.endDate = ds_regist.Tables[0].Rows[j]["DATE_END"].ToString(); _obj.result = ds_regist.Tables[0].Rows[j]["RESULT"].ToString(); _obj.status = ds_regist.Tables[0].Rows[j]["STATUS"].ToString(); _obj.money = ds_regist.Tables[0].Rows[j]["money"].ToString(); _obj.moneyWin = ds_regist.Tables[0].Rows[j]["money_win"].ToString(); _obj.rate = ds_regist.Tables[0].Rows[j]["rate"].ToString(); response.list[j] = _obj; } } else { response.responseCode = "1"; response.responseMessage = "Nodata"; } } catch (Exception ex) { logger.Info("getResultOfTerm exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; response.responseMessage = Common.GetErrMessageFromErrCode(response.responseCode, "0", urlPostGetErrCodeMessage, keyPostGetErrCodeMessage, "APP"); } return Ok(response); } } }