using System; using System.Collections.Generic; using System.Linq; using System.Net; using System.Net.Http; using ResfullApi.Models; using Newtonsoft.Json; using Newtonsoft.Json.Linq; using System.Data; using System.Configuration; using Microsoft.AspNetCore.Mvc; using ApiProcess.Models; using CommonObj.model; using CommonObj.common; using Microsoft.Extensions.Caching.Memory; using ApiProcess.Models.balance; namespace ApiProcess.Controllers { [ApiController] [Route("api/[controller]/[action]/data")] public class userApi : ControllerBase { static readonly log4net.ILog logger = log4net.LogManager.GetLogger(typeof(userApi)); private IMemoryCache memoryCache; public userApi(IMemoryCache memoryCache) { this.memoryCache = memoryCache; } // {"users":"1234","pass":"123","partnerCode":"123","channel":"WEB"} /* [HttpPost] public IActionResult getToken([FromBody] dynamic sendData) { ////log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); ////log4net.Config.XmlConfigurator.Configure(); responseObjLogin response = new responseObjLogin(); response.status = "-1"; response.message = "Err unknow"; var ip = HttpContext.Connection.RemoteIpAddress.ToString(); try { var userObj = JObject.Parse(sendData.ToString()); string users = Convert.ToString(userObj["users"]); string pass = Convert.ToString(userObj["pass"]); string partnerCode = Convert.ToString(userObj["partnerCode"]); string channel = Convert.ToString(userObj["channel"]); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(users)) users = "1"; if (string.IsNullOrEmpty(pass)) pass = "-1"; if (string.IsNullOrEmpty(partnerCode)) partnerCode = "-1"; if (string.IsNullOrEmpty(channel)) channel = "-1"; if(users=="-1"|| pass == "-1" || partnerCode == "-1" || channel == "-1") { logger.Info("Authen false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } 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.status = "-2"; response.message = "System Update"; return Ok(response); } channelObj _channelObj =(channelObj) CommonFunction.getChannelObjFromRedis(_redis, channel); if (users != _channelObj.usersName || pass != _channelObj.password || partnerCode != _channelObj.partnerCode) { logger.Info("Authen false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //truong hop con lai la thanh cong. Tien hanh lay token tokenObj _token = CommonFunction.createToken(_redis,users,pass,channel); response.status = "0"; response.message = "Success"; response.role = ""; response.token = _token.token; return Ok(response); } catch (Exception ex) { logger.Info("Err:" + ex.ToString(),ex); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } */ // {"users":"123","pass":"123"} [HttpPost] public IActionResult usersAdminLogin([FromBody] dynamic sendData) { ////log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); ////log4net.Config.XmlConfigurator.Configure(); /// logger.Info("New request income admin Login :" + sendData.ToString()); responseObjLogin response = new responseObjLogin(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string users = Convert.ToString(userObj["users"]); string pass = Convert.ToString(userObj["pass"]); string channel = Convert.ToString(userObj["channel"]); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(users)) users = "1"; if (string.IsNullOrEmpty(pass)) pass = "-1"; if (string.IsNullOrEmpty(channel)) channel = "-1"; string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (users == "-1" || pass == "-1" || channel == "-1") { logger.Info("Authen false"); response.status = "35"; response.message = CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.status,"");// "Check Authen false"; return Ok(response); } DataSet ds_regist = usersDataAccess.ADMIN_USERS_INFO(users, ResfullApi.Models.CustomEncryption.Encrypt(pass)); logger.Info("Call database ADMIN_USERS_INFO success:"); if (ds_regist == null || ds_regist.Tables[0].Rows.Count == 0) { response.status = "1"; response.message = "Login false"; response.role = ""; response.token = ""; return Ok(response); } else { string status= ds_regist.Tables[0].Rows[0]["status"].ToString(); if(status=="0") { //Tiep tuc lay danh sach chu nang cua Role DataSet ds = usersDataAccess.ADMIN_USERS_FUNCTION(ds_regist.Tables[0].Rows[0]["role"].ToString()); if(ds == null || ds.Tables[0].Rows.Count > 0) { response.function = new adminFunctionObj[ds.Tables[0].Rows.Count]; for (int j = 0; j < ds.Tables[0].Rows.Count; j++) { adminFunctionObj _obj = new adminFunctionObj(); _obj.id = ds.Tables[0].Rows[j]["id"].ToString(); _obj.role = ds.Tables[0].Rows[j]["ROLE"].ToString(); _obj.name = ds.Tables[0].Rows[j]["NAME"].ToString(); _obj.link = ds.Tables[0].Rows[j]["LINK"].ToString(); _obj.note = ds.Tables[0].Rows[j]["NOTE"].ToString(); response.function[j] = _obj; } } tokenObj _token = CommonFunction.createToken(_redis, users, pass, channel,"LOGIN_ADMIN","", ds_regist.Tables[0].Rows[0]["role"].ToString()); response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); response.role = ds_regist.Tables[0].Rows[0]["role"].ToString(); response.token = _token.token; return Ok(response); } else { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); response.role = ds_regist.Tables[0].Rows[0]["role"].ToString(); response.token = ""; return Ok(response); } } } catch (Exception ex) { logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } // {"msisdn":"50940227941","users":"123","pass":"123","passnew":"123","serviceId":"23","channel":"WEB"} [HttpPost] public IActionResult usersRegister([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjLogin response = new responseObjLogin(); response.status = "-1"; response.message = "Err unknow"; var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; try { usersObjRegist data = JsonConvert.DeserializeObject(sendData.ToString()); logger.Info("New request income usersRegister :" + data.ToString()); string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- //Ngoai tru 2 lenh (data.command == "REGIST" || data.command=="LOGIN") thi cac lenh con lai deu phai check token if (!(data.command == "REGIST" || data.command == "LOGIN" || data.command == "RESETPASS")) { if (!CommonFunction.checkToken(clientIp,data.token, data.channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } } DataSet ds_regist = usersDataAccess.USERS_API_DK_HUY(data.msisdn, data.users, data.pass,data.passnew, data.serviceid,data.command, data.channel,data.role); logger.Info("Call database USERS_API_DK_HUY success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { string status = ds_regist.Tables[0].Rows[0]["status"].ToString(); if(status=="0" && (data.command == "REGIST" || data.command == "LOGIN")) { string _role = ds_regist.Tables[0].Rows[0]["role"].ToString(); //string _msisdn = ds_regist.Tables[0].Rows[0]["msisdn"].ToString(); string _msisdn = data.users; tokenObj _token = CommonFunction.createToken(_redis, data.users, data.pass, data.channel, "LOGIN_USER", _msisdn, _role); response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); response.role = ds_regist.Tables[0].Rows[0]["role"].ToString(); response.token = _token.token; logger.Info("Response :"+response.ToString()); return Ok(response); } else { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); response.role = ds_regist.Tables[0].Rows[0]["role"].ToString(); response.token = ""; logger.Info("Response :" + response.ToString()); return Ok(response); } } } catch (Exception ex) { logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //Input //{"users":"50912345","serviceId":"30"} //Output // {"status":"1","id":"23","msisdn":"5091234","users":"23","pass":"23","serviceId":"23","dateregist":"01/01/2019 00:00:00","isactive":"1","channel":"web","best_coin":"0","cast_coin":"0"} [HttpPost] public IActionResult usersCheckStatus([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersObjStatusResponse response = new usersObjStatusResponse(); try { usersObjStatusRequest data = JsonConvert.DeserializeObject(sendData.ToString()); logger.Info("New request income usersCheckStatus :" + data.ToString()); //Check token var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["token"]); string channel = Convert.ToString(userObj["channel"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_GET_STATUS(data.users, data.serviceid); logger.Info("Call database USERS_GET_STATUS success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.id = ds_regist.Tables[0].Rows[0]["id"].ToString(); response.msisdn = ds_regist.Tables[0].Rows[0]["msisdn"].ToString(); response.users = ds_regist.Tables[0].Rows[0]["users"].ToString(); response.pass = ds_regist.Tables[0].Rows[0]["pass"].ToString(); response.serviceid = ds_regist.Tables[0].Rows[0]["serviceid"].ToString(); response.dateregist = ds_regist.Tables[0].Rows[0]["dateregist"].ToString(); response.isactive = ds_regist.Tables[0].Rows[0]["isactive"].ToString(); response.channel = ds_regist.Tables[0].Rows[0]["channel"].ToString(); response.bet_coin = ds_regist.Tables[0].Rows[0]["bet_coin"].ToString(); response.cash_coin = ds_regist.Tables[0].Rows[0]["cash_coin"].ToString(); response.role = ds_regist.Tables[0].Rows[0]["role"].ToString(); response.ranking = ds_regist.Tables[0].Rows[0]["ranking"].ToString(); response.language = ds_regist.Tables[0].Rows[0]["LANGUAGE"].ToString(); //0=global,1=local } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"users":"50912345678","serviceId":"30","fullName":"Do thi Hong Hanh","sex":"Nam","address":"Yen nghia","provinceId":"2","cardNumber":"123","email":"quangbh@yahoo.com","company":"Viettech","description":"ha ha hehe","picture":"/data/quangbh.jpg","sexNeed":"Nu","birthday":"12/10/1980","height":"12","weight":"60","work":"Ke toan","lookingFor":"Ke toan truong"} [HttpPost] public IActionResult usersUpdateProfile([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { usersObjProfile data = JsonConvert.DeserializeObject(sendData.ToString()); logger.Info("New request income usersUpdateProfile :" + data.ToString()); //Check token var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["token"]); string channel = Convert.ToString(userObj["channel"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_UPDATE_PROFILE(data.users, data.fullName, data.sex, data.address, data.provinceId, data.cardNumber, data.email, data.company, data.description, data.picture,data.sexNeed,data.birthday,data.height,data.weight,data.work,data.serviceid,data.lookingFor); logger.Info("Call database USERS_UPDATE_PROFILE success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"users":"50912345678","serviceId":"30","language":"0"} [HttpPost] public IActionResult usersGetProfile([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersObjProfile response = new usersObjProfile(); try { var userObj = JObject.Parse(sendData.ToString()); string uid = Convert.ToString(userObj["users"]); string uidQuery = Convert.ToString(userObj["usersQuery"]); string sid = Convert.ToString(userObj["serviceId"]); string language = Convert.ToString(userObj["language"]); //var userObj = JObject.Parse(sendData.ToString()); //string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersGetProfile :" + sendData.ToString()); //Check token string token = Convert.ToString(userObj["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.status = "-2"; response.message = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_GET_PROFILE(uid,sid,uidQuery); logger.Info("Call database usersGetProfile success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.id = ds_regist.Tables[0].Rows[0]["id"].ToString(); response.usersId = ds_regist.Tables[0].Rows[0]["user_id"].ToString(); response.users = ds_regist.Tables[0].Rows[0]["users"].ToString(); response.serviceid = ds_regist.Tables[0].Rows[0]["serviceid"].ToString(); response.fullName = ds_regist.Tables[0].Rows[0]["fullName"].ToString(); response.sex = ds_regist.Tables[0].Rows[0]["sex"].ToString(); response.address = ds_regist.Tables[0].Rows[0]["address"].ToString(); response.provinceId = ds_regist.Tables[0].Rows[0]["provinceId"].ToString(); response.cardNumber = ds_regist.Tables[0].Rows[0]["cardNumber"].ToString(); response.email = ds_regist.Tables[0].Rows[0]["email"].ToString(); response.company = ds_regist.Tables[0].Rows[0]["company"].ToString(); response.description = ds_regist.Tables[0].Rows[0]["description"].ToString(); response.picture = ds_regist.Tables[0].Rows[0]["picture"].ToString(); response.sexNeed = ds_regist.Tables[0].Rows[0]["sexNeed"].ToString(); response.birthday = ds_regist.Tables[0].Rows[0]["birthday"].ToString(); response.height = ds_regist.Tables[0].Rows[0]["height"].ToString(); response.weight = ds_regist.Tables[0].Rows[0]["weight"].ToString(); response.work = ds_regist.Tables[0].Rows[0]["work"].ToString(); response.isLike = ds_regist.Tables[0].Rows[0]["isLike"].ToString(); response.totalLike = ds_regist.Tables[0].Rows[0]["totalLike"].ToString(); response.totalPic = ds_regist.Tables[0].Rows[0]["totalPicture"].ToString(); response.totalView = ds_regist.Tables[0].Rows[0]["TOTALVIEW"].ToString(); response.lookingFor = ds_regist.Tables[0].Rows[0]["LOOKING_FOR"].ToString(); DataSet dsInterests = new DataSet(); dsInterests = usersDataAccess.USERS_GET_INTERESTS_BY_USER(language, uid, sid); if (dsInterests != null & dsInterests.Tables[0].Rows.Count > 0) { response.listInterests = new usersInterests[dsInterests.Tables[0].Rows.Count]; for (int j = 0; j < dsInterests.Tables[0].Rows.Count; j++) { usersInterests obj = new usersInterests(); obj.id = dsInterests.Tables[0].Rows[j]["id"].ToString(); obj.code = dsInterests.Tables[0].Rows[j]["code"].ToString(); obj.name = dsInterests.Tables[0].Rows[j]["name"].ToString(); obj.picture = dsInterests.Tables[0].Rows[j]["PICTURE"].ToString(); response.listInterests[j] = obj; } } DataSet dsGift = new DataSet(); dsGift = usersDataAccess.USERS_GIFT_GET_BUY_TOTAL_USERS(uid, sid); if (dsGift != null & dsGift.Tables[0].Rows.Count > 0) { response.listGift = new usersGift[dsGift.Tables[0].Rows.Count]; for (int j = 0; j < dsGift.Tables[0].Rows.Count; j++) { usersGift obj = new usersGift(); obj.id = dsGift.Tables[0].Rows[j]["id"].ToString(); obj.code = dsGift.Tables[0].Rows[j]["code"].ToString(); obj.name = dsGift.Tables[0].Rows[j]["name"].ToString(); obj.chargMoney = dsGift.Tables[0].Rows[j]["CHARGE_MONEY"].ToString(); obj.chargeCode = dsGift.Tables[0].Rows[j]["CHARGE_CODE"].ToString(); obj.coin = dsGift.Tables[0].Rows[j]["COIN"].ToString(); obj.status = dsGift.Tables[0].Rows[j]["STATUS"].ToString(); response.listGift[j] = obj; } } } } catch (Exception ex) { } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"users":"50912345678","serviceId":"30","proviceId":"1","fromAge":"1","toAge":"50","rowsOnPage":"2","seqPage":"1","language":"0","isLike":"1","type":"0"} [HttpPost] public IActionResult usersSeachProfile([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersObjProfileList response = new usersObjProfileList(); try { var userObj = JObject.Parse(sendData.ToString()); string uid = Convert.ToString(userObj["users"]); string sid = Convert.ToString(userObj["serviceId"]); string prid = Convert.ToString(userObj["proviceId"]); string fromAge = Convert.ToString(userObj["fromAge"]); string toAge = Convert.ToString(userObj["toAge"]); string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]); string seqPage = Convert.ToString(userObj["seqPage"]); string language = Convert.ToString(userObj["language"]); string isLike = Convert.ToString(userObj["isLike"]); string type = Convert.ToString(userObj["type"]); string seek = Convert.ToString(userObj["seek"]); if (string.IsNullOrEmpty(isLike)) isLike = "-1"; if (string.IsNullOrEmpty(seek)) seek = "-1"; if (string.IsNullOrEmpty(prid)) prid = "-1"; if (string.IsNullOrEmpty(fromAge)) fromAge = "-1"; if (string.IsNullOrEmpty(toAge)) toAge = "-1"; if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "100000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; if (string.IsNullOrEmpty(type) || type=="-1") type = "0"; //var userObj = JObject.Parse(sendData.ToString()); //string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersSeachProfile :" + sendData.ToString()); //Check token string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_SEARCHE_PROFILE(uid, sid, prid, fromAge, toAge, rowsOnPage, seqPage, isLike, type, seek); logger.Info("Call database usersSeachProfile success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "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.listProfile = new usersObjProfile[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersObjProfile obj = new usersObjProfile(); obj.id = ds_regist.Tables[0].Rows[j]["id"].ToString(); obj.users = ds_regist.Tables[0].Rows[j]["users"].ToString(); obj.serviceid = ds_regist.Tables[0].Rows[j]["serviceid"].ToString(); obj.fullName = ds_regist.Tables[0].Rows[j]["fullName"].ToString(); obj.sex = ds_regist.Tables[0].Rows[j]["sex"].ToString(); obj.address = ds_regist.Tables[0].Rows[j]["address"].ToString(); obj.provinceId = ds_regist.Tables[0].Rows[j]["provinceId"].ToString(); obj.cardNumber = ds_regist.Tables[0].Rows[j]["cardNumber"].ToString(); obj.email = ds_regist.Tables[0].Rows[j]["email"].ToString(); obj.company = ds_regist.Tables[0].Rows[j]["company"].ToString(); obj.description = ds_regist.Tables[0].Rows[j]["description"].ToString(); obj.picture = ds_regist.Tables[0].Rows[j]["picture"].ToString(); obj.sexNeed = ds_regist.Tables[0].Rows[j]["sexNeed"].ToString(); obj.birthday = ds_regist.Tables[0].Rows[j]["birthday"].ToString(); obj.height = ds_regist.Tables[0].Rows[j]["height"].ToString(); obj.weight = ds_regist.Tables[0].Rows[j]["weight"].ToString(); obj.work = ds_regist.Tables[0].Rows[j]["work"].ToString(); obj.isLike = ds_regist.Tables[0].Rows[j]["isLike"].ToString(); obj.usersId = ds_regist.Tables[0].Rows[j]["USER_ID"].ToString(); obj.totalPic = ds_regist.Tables[0].Rows[j]["PIC_TOTAL"].ToString(); obj.totalLike = ds_regist.Tables[0].Rows[j]["TOTALLIKE"].ToString(); obj.totalView = ds_regist.Tables[0].Rows[j]["TOTALVIEW"].ToString(); obj.lookingFor = ds_regist.Tables[0].Rows[j]["LOOKING_FOR"].ToString(); DataSet dsInterests = new DataSet(); dsInterests = usersDataAccess.USERS_GET_INTERESTS_BY_USER(language, obj.users, obj.serviceid); if (dsInterests != null & dsInterests.Tables[0].Rows.Count > 0) { obj.listInterests = new usersInterests[dsInterests.Tables[0].Rows.Count]; for (int k = 0; k < dsInterests.Tables[0].Rows.Count; k++) { usersInterests obj1 = new usersInterests(); obj1.id = dsInterests.Tables[0].Rows[k]["id"].ToString(); obj1.code = dsInterests.Tables[0].Rows[k]["code"].ToString(); obj1.name = dsInterests.Tables[0].Rows[k]["name"].ToString(); obj1.picture = dsInterests.Tables[0].Rows[k]["PICTURE"].ToString(); obj.listInterests[k] = obj1; } } DataSet dsGift = new DataSet(); dsGift = usersDataAccess.USERS_GIFT_GET_BUY_TOTAL_USERS(uid, sid); if (dsGift != null & dsGift.Tables[0].Rows.Count > 0) { obj.listGift = new usersGift[dsGift.Tables[0].Rows.Count]; for (int n = 0; n < dsGift.Tables[0].Rows.Count; n++) { usersGift obj2 = new usersGift(); obj2.id = dsGift.Tables[0].Rows[n]["id"].ToString(); obj2.code = dsGift.Tables[0].Rows[n]["code"].ToString(); obj2.name = dsGift.Tables[0].Rows[n]["name"].ToString(); obj2.chargMoney = dsGift.Tables[0].Rows[n]["CHARGE_MONEY"].ToString(); obj2.chargeCode = dsGift.Tables[0].Rows[n]["CHARGE_CODE"].ToString(); obj2.coin = dsGift.Tables[0].Rows[n]["COIN"].ToString(); obj2.status = dsGift.Tables[0].Rows[n]["STATUS"].ToString(); obj.listGift[n] = obj2; } } response.listProfile[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } // {"users":"50912345678","serviceId":"30","users_receved":"50912345671123"} [HttpPost] public IActionResult usersViewUpdate([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string users = Convert.ToString(userObj["users"]); string serviceId = Convert.ToString(userObj["serviceId"]); string users_receved = Convert.ToString(userObj["users_receved"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersViewUpdate :" + sendData.ToString()); //Check token string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_VIEW_UPDATE(users, serviceId, users_receved); logger.Info("Call database USERS_VIEW_UPDATE success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"users":"50912345678","serviceId":"30","rowsOnPage":"2","seqPage":"1"} [HttpPost] public IActionResult usersChatGet_BK([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersChatList response = new usersChatList(); try { var userObj = JObject.Parse(sendData.ToString()); string uid = Convert.ToString(userObj["users"]); string sid = Convert.ToString(userObj["serviceId"]); string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]); string seqPage = Convert.ToString(userObj["seqPage"]); if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "100000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersChatGetList :" + sendData.ToString()); //Check token string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_CHAT_GET(uid, sid, rowsOnPage, seqPage); logger.Info("Call database USERS_CHAT_GET success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "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.listUsersChat = new usersChat[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersChat obj = new usersChat(); obj.seq = ds_regist.Tables[0].Rows[j]["SEQ"].ToString(); obj.id = ds_regist.Tables[0].Rows[j]["CHAT_ID"].ToString(); obj.title = ds_regist.Tables[0].Rows[j]["TITLE"].ToString(); obj.createdDate = ds_regist.Tables[0].Rows[j]["vsysdate"].ToString(); obj.lastUpdateDate = ds_regist.Tables[0].Rows[j]["LASTUPDATE"].ToString(); obj.youId = ds_regist.Tables[0].Rows[j]["YOU_ID"].ToString(); obj.youName = ds_regist.Tables[0].Rows[j]["YOU_NAME"].ToString(); obj.youUsers = ds_regist.Tables[0].Rows[j]["YOU_USER"].ToString(); obj.youPictrure = ds_regist.Tables[0].Rows[j]["YOU_PIC"].ToString(); obj.frendId = ds_regist.Tables[0].Rows[j]["FREND_ID"].ToString(); obj.frendName = ds_regist.Tables[0].Rows[j]["FREND_NAME"].ToString(); obj.frendUsers = ds_regist.Tables[0].Rows[j]["FREND_USER"].ToString(); obj.frendPicture = ds_regist.Tables[0].Rows[j]["FREND_PIC"].ToString(); obj.totalNotCheck = ds_regist.Tables[0].Rows[j]["TOTAL_NOT_CHECK"].ToString(); response.listUsersChat[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"users":"50912345678","serviceId":"30","rowsOnPage":"2","seqPage":"1","keyword":"1123"} [HttpPost] public IActionResult usersChatGet([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersChatList response = new usersChatList(); try { var userObj = JObject.Parse(sendData.ToString()); string uid = Convert.ToString(userObj["users"]); string sid = Convert.ToString(userObj["serviceId"]); string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]); string seqPage = Convert.ToString(userObj["seqPage"]); string keyword = Convert.ToString(userObj["keyword"]); if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "100000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; if (string.IsNullOrEmpty(keyword)) keyword = "-1"; //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersChatGetList :" + sendData.ToString()); //Check token string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_CHAT_GET(uid, sid, rowsOnPage, seqPage); logger.Info("Call database USERS_CHAT_GET success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "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.listUsersChat = new usersChat[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersChat obj = new usersChat(); obj.seq = ds_regist.Tables[0].Rows[j]["SEQ"].ToString(); obj.id = ds_regist.Tables[0].Rows[j]["CHAT_ID"].ToString(); obj.title = ds_regist.Tables[0].Rows[j]["TITLE"].ToString(); obj.createdDate = ds_regist.Tables[0].Rows[j]["vsysdate"].ToString(); obj.lastUpdateDate = ds_regist.Tables[0].Rows[j]["LASTUPDATE"].ToString(); obj.youId = ds_regist.Tables[0].Rows[j]["YOU_ID"].ToString(); obj.youName = ds_regist.Tables[0].Rows[j]["YOU_NAME"].ToString(); obj.youUsers = ds_regist.Tables[0].Rows[j]["YOU_USER"].ToString(); obj.youPictrure = ds_regist.Tables[0].Rows[j]["YOU_PIC"].ToString(); obj.frendId = ds_regist.Tables[0].Rows[j]["FREND_ID"].ToString(); obj.frendName = ds_regist.Tables[0].Rows[j]["FREND_NAME"].ToString(); obj.frendUsers = ds_regist.Tables[0].Rows[j]["FREND_USER"].ToString(); obj.frendPicture = ds_regist.Tables[0].Rows[j]["FREND_PIC"].ToString(); obj.totalNotCheck = ds_regist.Tables[0].Rows[j]["TOTAL_NOT_CHECK"].ToString(); response.listUsersChat[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"chatId":"1","rowsOnPage":"2","seqPage":"1"} [HttpPost] public IActionResult usersChatDetailGet([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersChatDetailList response = new usersChatDetailList(); try { var userObj = JObject.Parse(sendData.ToString()); string chatId = Convert.ToString(userObj["chatId"]); string uid = Convert.ToString(userObj["users"]); string sid = Convert.ToString(userObj["serviceId"]); string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]); string seqPage = Convert.ToString(userObj["seqPage"]); if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "100000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersChatDetailGet :" + sendData.ToString()); //Check token string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_CHAT_DETAIL_GET(chatId, rowsOnPage, seqPage, uid, sid); logger.Info("Call database USERS_CHAT_DETAIL_GET success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "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.listUsersChatDetail = new usersChatDetail[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersChatDetail obj = new usersChatDetail(); obj.seq = ds_regist.Tables[0].Rows[j]["SEQ"].ToString(); obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString(); obj.message = ds_regist.Tables[0].Rows[j]["MESSAGE"].ToString(); obj.chatId = ds_regist.Tables[0].Rows[j]["CHAT_ID"].ToString(); obj.isCheck = ds_regist.Tables[0].Rows[j]["IS_CHECK"].ToString(); obj.createdDate = ds_regist.Tables[0].Rows[j]["vsysdate"].ToString(); obj.userIdSend = ds_regist.Tables[0].Rows[j]["USER_ID_SEND"].ToString(); obj.fullNamSend = ds_regist.Tables[0].Rows[j]["USER_NAME_SEND"].ToString(); obj.userIdReceived = ds_regist.Tables[0].Rows[j]["USER_ID_RECEIVED"].ToString(); obj.fullNamReceived = ds_regist.Tables[0].Rows[j]["USER_NAME_RECEIVED"].ToString(); response.listUsersChatDetail[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"users":"50912345678","serviceId":"30","users_receved":"509123456789","message":"Nam","title":"than gui ban","chatId":"123"} [HttpPost] public IActionResult usersChatSend([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersChatSend response = new usersChatSend(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string users = Convert.ToString(userObj["users"]); string serviceid = Convert.ToString(userObj["serviceId"]); string users_receved = Convert.ToString(userObj["users_receved"]); string message = Convert.ToString(userObj["message"]); string title = Convert.ToString(userObj["title"]); string chatId = Convert.ToString(userObj["chatId"]); if (string.IsNullOrEmpty(chatId)) chatId = "-1"; //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersChatSend :" + sendData.ToString()); //Check token string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_CHAT_SEND_MSG(users, serviceid, users_receved, message, title,chatId); logger.Info("Call database USERS_CHAT_SEND_MSG success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); response.chatId = ds_regist.Tables[0].Rows[0]["CHAT_ID"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"chatDetailId":"2"} [HttpPost] public IActionResult usersChatDetailUpCheck([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string chatDetailId = Convert.ToString(userObj["chatDetailId"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersChatDetailUpCheck :" + sendData.ToString()); //Check token string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_CHAT_DETAIL_CHECK(chatDetailId); logger.Info("Call database USERS_CHAT_DETAIL_CHECK success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"chatId":"2"} [HttpPost] public IActionResult usersChatDelete([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string chatId = Convert.ToString(userObj["chatId"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersChatDelete :" + sendData.ToString()); //Check token string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_CHAT_DEL(chatId); logger.Info("Call database USERS_CHAT_DEL success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"chatDetailId":"2"} [HttpPost] public IActionResult usersChatDetailDelete([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string chatDetailId = Convert.ToString(userObj["chatDetailId"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersChatDetailDelete :" + sendData.ToString()); //Check token string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_CHAT_DETAIL_DEL(chatDetailId); logger.Info("Call database USERS_CHAT_DETAIL_DEL success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"users":"50912345678","serviceId":"30","users_receved":"509123456789","message":"Nam","title":"than gui ban"} [HttpPost] public IActionResult usersMesageSend([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string users = Convert.ToString(userObj["users"]); string serviceid = Convert.ToString(userObj["serviceId"]); string users_receved = Convert.ToString(userObj["users_receved"]); string messageLocal = Convert.ToString(userObj["messageLocal"]); string messageGlobal = Convert.ToString(userObj["messageGlobal"]); string titleLocal = Convert.ToString(userObj["titleLocal"]); string titleGlobal = Convert.ToString(userObj["titleGlobal"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersMesageSend :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_MSG_SEND(users, serviceid, users_receved, messageLocal, titleLocal, messageGlobal, titleGlobal); logger.Info("Call database USERS_MSG_SEND success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"messageId":"8"} [HttpPost] public IActionResult usersMesageCheck([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string messageId = Convert.ToString(userObj["messageId"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersMesageCheck :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_MSG_CHECK(messageId); logger.Info("Call database USERS_MSG_CHECK success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"messageId":"8","users":"50912345678","serviceId":"30","isSend":"1","top":"10"} [HttpPost] public IActionResult usersMesageGet([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersMsgList response = new usersMsgList(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string users = Convert.ToString(userObj["users"]); string serviceid = Convert.ToString(userObj["serviceId"]); string messageId = Convert.ToString(userObj["messageId"]); string isSend = Convert.ToString(userObj["isSend"]); string langegua = Convert.ToString(userObj["langegua"]); string fromDate = Convert.ToString(userObj["fromDate"]); string toDate = Convert.ToString(userObj["toDate"]); string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]); string seqPage = Convert.ToString(userObj["seqPage"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(users)) users = "-1"; if (string.IsNullOrEmpty(serviceid)) serviceid = "-1"; if (string.IsNullOrEmpty(messageId)) messageId = "-1"; if (string.IsNullOrEmpty(isSend)) isSend = "1"; if (string.IsNullOrEmpty(langegua)) langegua = "0"; if (string.IsNullOrEmpty(fromDate)) fromDate = "-1"; if(string.IsNullOrEmpty(toDate)) toDate = "-1"; if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; logger.Info("New request income usersMesageSend :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_MSG_GET(users, serviceid, isSend, messageId, language, fromDate, toDate, rowsOnPage, seqPage); logger.Info("Call database USERS_MSG_SEND success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "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.listMesage = new usersMsgObj[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersMsgObj obj = new usersMsgObj(); obj.id = ds_regist.Tables[0].Rows[j]["id"].ToString(); obj.usersFrom = ds_regist.Tables[0].Rows[j]["usersFrom"].ToString(); obj.userFromId = ds_regist.Tables[0].Rows[j]["userFromId"].ToString(); obj.usersFromName = ds_regist.Tables[0].Rows[j]["usersFromName"].ToString(); obj.usersTo = ds_regist.Tables[0].Rows[j]["usersTo"].ToString(); obj.usersToId = ds_regist.Tables[0].Rows[j]["usersToId"].ToString(); obj.usersToName = ds_regist.Tables[0].Rows[j]["usersToName"].ToString(); obj.serviceId = ds_regist.Tables[0].Rows[j]["serviceId"].ToString(); obj.message = ds_regist.Tables[0].Rows[j]["message"].ToString(); obj.dateSend = ds_regist.Tables[0].Rows[j]["dateSend"].ToString(); obj.isCheck = ds_regist.Tables[0].Rows[j]["isCheck"].ToString(); response.listMesage[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { response.status = "-1"; response.message = "Err unknow"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } // {"users":"50912345678","serviceId":"30","url":"quangbh/abc.jpg","note":"1"} [HttpPost] public IActionResult usersPicUpload([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string users = Convert.ToString(userObj["users"]); string serviceId = Convert.ToString(userObj["serviceId"]); string url = Convert.ToString(userObj["url"]); string note = Convert.ToString(userObj["note"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersPicUpload :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_PIC_ADD(users,serviceId, url, note); logger.Info("Call database USERS_PIC_ADD success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } // {"users":"50912345678","serviceId":"30","usersLike":"509123456789","isLike":"1"} [HttpPost] public IActionResult usersLikeUpdate([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string users = Convert.ToString(userObj["users"]); string serviceId = Convert.ToString(userObj["serviceId"]); string usersLike = Convert.ToString(userObj["usersLike"]); string isLike = Convert.ToString(userObj["isLike"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersLikeUpdate :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_LIKE_UPDATE(users, serviceId, usersLike, isLike); logger.Info("Call database USERS_LIKE_UPDATE success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"users":"50912345678","serviceId":"30","type":"1","rowsOnPage":"2","seqPage":"1","language":"0"} // "type":"0" : danh sach nguoi dung da like cho users và serviceId truyen vao // "type":"0" : danh sach nguoi dung ma users va serviceId truyen vao da like [HttpPost] public IActionResult usersGetListLike([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersObjProfileList response = new usersObjProfileList(); try { var userObj = JObject.Parse(sendData.ToString()); string uid = Convert.ToString(userObj["users"]); string sid = Convert.ToString(userObj["serviceId"]); string type = Convert.ToString(userObj["type"]); string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]); string seqPage = Convert.ToString(userObj["seqPage"]); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "100000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; if (string.IsNullOrEmpty(language)) language = "-1"; logger.Info("New request income usersGetListLike :" + sendData.ToString()); //Check token string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_GET_LIKE_PROFILE(uid, sid, type, rowsOnPage, seqPage); logger.Info("Call database usersSeachProfile success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "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.listProfile = new usersObjProfile[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersObjProfile obj = new usersObjProfile(); obj.id = ds_regist.Tables[0].Rows[j]["id"].ToString(); obj.users = ds_regist.Tables[0].Rows[j]["users"].ToString(); obj.serviceid = ds_regist.Tables[0].Rows[j]["serviceid"].ToString(); obj.fullName = ds_regist.Tables[0].Rows[j]["fullName"].ToString(); obj.sex = ds_regist.Tables[0].Rows[j]["sex"].ToString(); obj.address = ds_regist.Tables[0].Rows[j]["address"].ToString(); obj.provinceId = ds_regist.Tables[0].Rows[j]["provinceId"].ToString(); obj.cardNumber = ds_regist.Tables[0].Rows[j]["cardNumber"].ToString(); obj.email = ds_regist.Tables[0].Rows[j]["email"].ToString(); obj.company = ds_regist.Tables[0].Rows[j]["company"].ToString(); obj.description = ds_regist.Tables[0].Rows[j]["description"].ToString(); obj.picture = ds_regist.Tables[0].Rows[j]["picture"].ToString(); obj.sexNeed = ds_regist.Tables[0].Rows[j]["sexNeed"].ToString(); obj.birthday = ds_regist.Tables[0].Rows[j]["birthday"].ToString(); obj.height = ds_regist.Tables[0].Rows[j]["height"].ToString(); obj.weight = ds_regist.Tables[0].Rows[j]["weight"].ToString(); obj.work = ds_regist.Tables[0].Rows[j]["work"].ToString(); obj.isLike = ds_regist.Tables[0].Rows[j]["isLike"].ToString(); obj.usersId = ds_regist.Tables[0].Rows[j]["USER_ID"].ToString(); obj.totalPic = ds_regist.Tables[0].Rows[j]["PIC_TOTAL"].ToString(); obj.lookingFor = ds_regist.Tables[0].Rows[j]["LOOKING_FOR"].ToString(); DataSet dsInterests = new DataSet(); dsInterests = usersDataAccess.USERS_GET_INTERESTS_BY_USER(language, uid, sid); if (dsInterests != null & dsInterests.Tables[0].Rows.Count > 0) { obj.listInterests = new usersInterests[dsInterests.Tables[0].Rows.Count]; for (int k = 0; k < dsInterests.Tables[0].Rows.Count; k++) { usersInterests obj1 = new usersInterests(); obj1.id = dsInterests.Tables[0].Rows[k]["id"].ToString(); obj1.code = dsInterests.Tables[0].Rows[k]["code"].ToString(); obj1.name = dsInterests.Tables[0].Rows[k]["name"].ToString(); obj1.picture = dsInterests.Tables[0].Rows[k]["PICTURE"].ToString(); obj.listInterests[k] = obj1; } } response.listProfile[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } // {"picId":"123"} [HttpPost] public IActionResult usersPicDel([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string picId = Convert.ToString(userObj["picId"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersPicDel :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_PIC_DEL(picId); logger.Info("Call database USERS_LIKE_UPDATE success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"picId":"4","users":"50912345678","serviceId":"30","top":"10"} [HttpPost] public IActionResult usersPicGet([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersPicList response = new usersPicList(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string picId = Convert.ToString(userObj["picId"]); string users = Convert.ToString(userObj["users"]); string serviceId = Convert.ToString(userObj["serviceId"]); string top = Convert.ToString(userObj["top"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(picId)) picId = "-1"; logger.Info("New request income usersPicGet :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_PIC_GET(picId, users,serviceId, top); logger.Info("Call database USERS_PIC_GET success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "Success"; response.listPic = new usersPic[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersPic obj = new usersPic(); obj.id = ds_regist.Tables[0].Rows[j]["id"].ToString(); obj.usersId = ds_regist.Tables[0].Rows[j]["USER_ID"].ToString(); obj.url = ds_regist.Tables[0].Rows[j]["URL"].ToString(); obj.createdDate = ds_regist.Tables[0].Rows[j]["vsysdate"].ToString(); obj.note = ds_regist.Tables[0].Rows[j]["NOTE"].ToString(); response.listPic[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { response.status = "-1"; response.message = "Err unknow"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } // {"users":"50912345678","serviceId":"30","language":"1"} [HttpPost] public IActionResult usersSetLanguage([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string users = Convert.ToString(userObj["users"]); string serviceId = Convert.ToString(userObj["serviceId"]); string language = Convert.ToString(userObj["language"]); //var userObj = JObject.Parse(sendData.ToString()); //string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersSetLanguage :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_UPDATE_LANGUAGE(users, serviceId, language); logger.Info("Call database USERS_UPDATE_LANGUAGE success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"type":"1"} [HttpPost] public IActionResult usersGetListService([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); subServiceList response = new subServiceList(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string type = Convert.ToString(userObj["type"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income subGetListsubServiceCode :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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.status = "-2"; response.message = "System Update"; return Ok(response); } if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = subDataAccess.SUB_API_GET_SUBSEVICE(type); logger.Info("Call database SUB_API_GET_SUBSEVICE success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "Success"; response.listSubService = new subServiceObj[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { subServiceObj obj = new subServiceObj(); 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.country = ds_regist.Tables[0].Rows[j]["COUNTRY_CODE"].ToString(); obj.shortCode = ds_regist.Tables[0].Rows[j]["SHORT_CODE"].ToString(); response.listSubService[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"language":"0","serviceId":"1"} public IActionResult usersGetProvice([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersProviceList response = new usersProviceList(); try { var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); string serviceId = Convert.ToString(userObj["serviceId"]); //var userObj = JObject.Parse(sendData.ToString()); //string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersGetProvice :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_GET_PROVICE(language,serviceId); logger.Info("Call database usersGetProvice success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "Success"; response.listProvice = new usersProvice[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersProvice obj = new usersProvice(); 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(); response.listProvice[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"language":"0","serviceId":"1"} public IActionResult usersGetTopic([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersTopicList response = new usersTopicList(); try { var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); string serviceId = Convert.ToString(userObj["serviceId"]); //var userObj = JObject.Parse(sendData.ToString()); //string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersGetTopic :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_GET_TOPIC(language, serviceId); logger.Info("Call database usersGetProvice success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "Success"; response.listTopic = new usersTopic[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersTopic obj = new usersTopic(); 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(); response.listTopic[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"language":"0"} public IActionResult usersGiftGetList([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersGiftList response = new usersGiftList(); try { var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; string id = Convert.ToString(userObj["id"]); string serviceId = Convert.ToString(userObj["serviceId"]); if (string.IsNullOrEmpty(id)) id = "-1"; if (string.IsNullOrEmpty(serviceId)) serviceId = "-1"; //var userObj = JObject.Parse(sendData.ToString()); //string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersGetGift :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_GIFT_GET(language, id,serviceId); logger.Info("Call database USERS_GET_GIFT success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "Success"; response.listGift = new usersGift[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersGift obj = new usersGift(); 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.chargMoney = ds_regist.Tables[0].Rows[j]["CHARGE_MONEY"].ToString(); obj.chargeCode = ds_regist.Tables[0].Rows[j]["CHARGE_CODE"].ToString(); obj.coin = ds_regist.Tables[0].Rows[j]["COIN"].ToString(); obj.status = ds_regist.Tables[0].Rows[j]["STATUS"].ToString(); response.listGift[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } /* public IActionResult usersGiftSendNotOtp([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; logger.Info("New request income usersGiftSendNotOtp :" + sendData.ToString()); string mps_ip = ConfigurationSettings.AppSettings["MPS_IP"]; string mps_port = ConfigurationSettings.AppSettings["MPS_PORT"]; try { var userObj = JObject.Parse(sendData.ToString()); string users = Convert.ToString(userObj["users"]); string serviceid = Convert.ToString(userObj["serviceId"]); string users_receved = Convert.ToString(userObj["users_receved"]); string giftId = Convert.ToString(userObj["giftId"]); if (string.IsNullOrEmpty(giftId)) giftId = "-1"; DataSet ds_Gift = usersDataAccess.USERS_GIFT_GET("0", giftId); if (ds_Gift == null || ds_Gift.Tables[0].Rows.Count > 0) { response.status = "-10"; response.message = "Invalid Gift"; return Ok(response); } else { logger.Info("Start call charg money"); string subServiceCode = ds_Gift.Tables[0].Rows[0]["CHARGE_CODE"].ToString(); string data = "requestId=" + "&msisdn=" + users + "&otp=" + "&serviceid=" + serviceid + "&subServiceCode=" + subServiceCode; logger.Info("Request call charge: " + data); string response111 = Common.SocketUnSyn(data, mps_ip, Convert.ToInt32(mps_port), 12000); logger.Info("Result call charge: " + response111); mpsResponse resCallMps = JsonConvert.DeserializeObject(response111); if (resCallMps.responseCode=="0") { logger.Info("charge money success :" ); DataSet ds_regist = usersDataAccess.USERS_GIFT_SEND(users, serviceid, users_receved, giftId); logger.Info("Call database USERS_GIFT_SEND success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "Success"; return Ok(response); } } else if (resCallMps.responseCode == "401") { response.status = "-11"; response.message = "Not enough money "; return Ok(response); } else { response.status = "-12"; response.message = "System err"; return Ok(response); } } } catch (Exception ex) { logger.Info("Err:" + ex.ToString()); } return Ok(response); } public IActionResult usersGiftSendOtp([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); mpsResponseEx response = new mpsResponseEx(); response.status = "-1"; response.message = "Err unknow"; logger.Info("New request income usersGiftSendNotOtp :" + sendData.ToString()); string mps_ip = ConfigurationSettings.AppSettings["MPS_IP"]; string mps_port = ConfigurationSettings.AppSettings["MPS_PORT"]; try { var userObj = JObject.Parse(sendData.ToString()); string users = Convert.ToString(userObj["users"]); string serviceid = Convert.ToString(userObj["serviceId"]); string users_receved = Convert.ToString(userObj["users_receved"]); string giftId = Convert.ToString(userObj["giftId"]); if (string.IsNullOrEmpty(giftId)) giftId = "-1"; DataSet ds_Gift = usersDataAccess.USERS_GIFT_GET("0", giftId); if (ds_Gift == null || ds_Gift.Tables[0].Rows.Count > 0) { response.status = "-10"; response.message = "Invalid Gift"; return Ok(response); } else { logger.Info("Start call charg money"); string subServiceCode = ds_Gift.Tables[0].Rows[0]["CHARGE_CODE"].ToString(); string data = "requestId=" + "&msisdn=" + users + "&otp=" + "&serviceid=" + serviceid + "&subServiceCode=" + subServiceCode; logger.Info("Request call charge: " + data); string response111 = Common.SocketUnSyn(data, mps_ip, Convert.ToInt32(mps_port), 12000); logger.Info("Result call charge: " + response111); mpsResponse resCallMps = JsonConvert.DeserializeObject(response111); if (resCallMps.responseCode == "0") { logger.Info("charge money success :"); DataSet ds_regist = usersDataAccess.USERS_GIFT_SEND(users, serviceid, users_receved, giftId); logger.Info("Call database USERS_GIFT_SEND success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "Success"; response.message = resCallMps.requestID; return Ok(response); } } else if (resCallMps.responseCode == "401") { response.status = "-11"; response.message = "Not enough money "; return Ok(response); } else { response.status = "-12"; response.message = "System err"; return Ok(response); } } } catch (Exception ex) { logger.Info("Err:" + ex.ToString()); } return Ok(response); } */ //{"users":"50940240716","serviceId":"30","users_receved":"50912345678","giftId":"1","giftType":"1","requestId":"-1","otp":"-1"} //giftType=1 charge va tang qua, giftType=2 la move qua cua user login sang cho users_receved; public IActionResult usersGiftSend([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); mpsResponseEx response = new mpsResponseEx(); response.status = "-1"; response.message = "Err unknow"; logger.Info("New request income usersGiftSendNotOtp :" + sendData.ToString()); string mps_ip = "127.0.0.1"; string mps_port = "0000"; try { var userObj = JObject.Parse(sendData.ToString()); string users = Convert.ToString(userObj["users"]); string serviceid = Convert.ToString(userObj["serviceId"]); string users_receved = Convert.ToString(userObj["users_receved"]); string giftId = Convert.ToString(userObj["giftId"]); string giftType = Convert.ToString(userObj["giftType"]); string requestId = Convert.ToString(userObj["requestId"]); string otp = Convert.ToString(userObj["otp"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; if (string.IsNullOrEmpty(giftId)) giftId = "-1"; if (string.IsNullOrEmpty(giftType)) giftType = "-1"; if (string.IsNullOrEmpty(requestId)) requestId = "-1"; if (string.IsNullOrEmpty(otp)) otp = "-1"; //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token if (giftId=="-1" || giftType=="-1") { response.status = "-11"; response.message = "GiftID or giftType param invalid"; return Ok(response); } DataSet ds_mps_info = DataAccess.MPS_GET_BY_ID(serviceid); mps_ip = ds_mps_info.Tables[0].Rows[0]["MPS_IP"].ToString(); mps_port = ds_mps_info.Tables[0].Rows[0]["MPS_PORT"].ToString(); DataSet ds_subServiceCodeofGift = usersDataAccess.USERS_GIFT_GET_SUBSERVICECODE(users, serviceid, users_receved, giftId, giftType); if (ds_subServiceCodeofGift == null || ds_subServiceCodeofGift.Tables[0].Rows.Count == 0) { response.status = "-11"; response.message = "Invalid Gift(No gift found)"; return Ok(response); } else { string status = ds_subServiceCodeofGift.Tables[0].Rows[0]["STATUS"].ToString(); logger.Info("Status when find subsserviceCode is: status" + status); if(status=="0") { logger.Info("Send gift from acount coint success"); response.status = "0"; response.message = "Send gift from coin acount success"; return Ok(response); } else if(status=="1") { logger.Info("Khong ton tai gift trong acount cua coin"); response.status = "-11"; response.message = "Invalid Gift(No gift found in acount coin)"; return Ok(response); } else { logger.Info("Start call charg money"); string subServiceCode = ds_subServiceCodeofGift.Tables[0].Rows[0]["CHARGE_CODE"].ToString(); string data = "requestId=" + requestId + "&msisdn=" + users + "&otp=" + otp + "&serviceid=" + serviceid + "&subServiceCode=" + subServiceCode; logger.Info("Request call charge: " + data); string response111 = Common.SocketUnSyn(data, mps_ip, Convert.ToInt32(mps_port), 12000); logger.Info("Result call charge: " + response111); mpsResponse resCallMps = JsonConvert.DeserializeObject(response111); if (resCallMps.responseCode == "0") { logger.Info("charge money success :"); DataSet ds_regist = usersDataAccess.USERS_GIFT_SEND(users, serviceid, users_receved, giftId); logger.Info("Call database USERS_GIFT_SEND success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "Success"; response.requestId = resCallMps.requestID; return Ok(response); } } else if (resCallMps.responseCode == "100") { response.status = "100"; response.message = "Send OTP success to user, pls send this function with OTP & requestID agian for finsh"; response.requestId = resCallMps.requestID; return Ok(response); } else if (resCallMps.responseCode == "401") { response.status = "-12"; response.message = "Not enough money "; return Ok(response); } else if (resCallMps.responseCode == "415") { response.status = "-13"; response.message = "Invalid OTP code"; return Ok(response); } else if (resCallMps.responseCode == "416") { response.status = "-14"; response.message = "Incorrect OTP code/ OTP code expired"; return Ok(response); } else if (resCallMps.responseCode == "417") { response.status = "-15"; response.message = "Confirm OTP via USSD time out"; return Ok(response); } else { response.status = "-10"; response.message = "System err"; return Ok(response); } } } } catch (Exception ex) { logger.Info("Err:" + ex.ToString()); } return Ok(response); } //{"users":"50912345678","serviceId":"30","rowsOnPage":"2","seqPage":"1","type":"0"} //type: 0= user send,1= user receved (defualt) [HttpPost] public IActionResult usersGiftGetByUsers([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersGiftSendList response = new usersGiftSendList(); try { var userObj = JObject.Parse(sendData.ToString()); string uid = Convert.ToString(userObj["users"]); string sid = Convert.ToString(userObj["serviceId"]); string type = Convert.ToString(userObj["type"]); string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]); string seqPage = Convert.ToString(userObj["seqPage"]); if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "100000000"; if (string.IsNullOrEmpty(seqPage)) seqPage = "1"; if (string.IsNullOrEmpty(type)) type = "1"; //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersGiftGetByUsers :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_GIFT_GET_BUY_USERS( uid, sid, rowsOnPage, seqPage, type); logger.Info("Call database USERS_GIFT_GET_BUY_USERS success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "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.listGiftSend = new usersGiftSend[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersGiftSend obj = new usersGiftSend(); obj.seq = ds_regist.Tables[0].Rows[j]["SEQ"].ToString(); obj.giftSendId = ds_regist.Tables[0].Rows[j]["giftSendId"].ToString(); obj.usersSendId = ds_regist.Tables[0].Rows[j]["usersSendId"].ToString(); obj.usersSendName = ds_regist.Tables[0].Rows[j]["usersSendName"].ToString(); obj.usersRecevedId = ds_regist.Tables[0].Rows[j]["usersRecevedId"].ToString(); obj.usersRecevedName = ds_regist.Tables[0].Rows[j]["usersRecevedName"].ToString(); obj.dateSend = ds_regist.Tables[0].Rows[j]["dateSend"].ToString(); obj.giftId = ds_regist.Tables[0].Rows[j]["giftId"].ToString(); obj.code = ds_regist.Tables[0].Rows[j]["code"].ToString(); obj.name = ds_regist.Tables[0].Rows[j]["name"].ToString(); obj.chargMoney = ds_regist.Tables[0].Rows[j]["chargMoney"].ToString(); obj.chargeCode = ds_regist.Tables[0].Rows[j]["chargeCode"].ToString(); obj.coin = ds_regist.Tables[0].Rows[j]["coin"].ToString(); obj.status = ds_regist.Tables[0].Rows[j]["status"].ToString(); response.listGiftSend[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"language":"0"} public IActionResult usersGetInterests([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersInterestsList response = new usersInterestsList(); try { var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); //var userObj = JObject.Parse(sendData.ToString()); //string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersGetInterests :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_GET_INTERESTS(language); logger.Info("Call database USERS_GET_INTERESTS success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "Success"; response.listInterests = new usersInterests[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersInterests obj = new usersInterests(); 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.picture = ds_regist.Tables[0].Rows[j]["PICTURE"].ToString(); response.listInterests[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"users":"50912345678","serviceId":"30","language":"0"} public IActionResult usersGetInterestsByUser([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); usersInterestsList response = new usersInterestsList(); try { var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); string users = Convert.ToString(userObj["users"]); string serviceId = Convert.ToString(userObj["serviceId"]); //var userObj = JObject.Parse(sendData.ToString()); //string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersGetInterests :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_GET_INTERESTS_BY_USER(language, users,serviceId); logger.Info("Call database USERS_GET_INTERESTS success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = "0"; response.message = "Success"; response.listInterests = new usersInterests[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { usersInterests obj = new usersInterests(); 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.picture = ds_regist.Tables[0].Rows[j]["PICTURE"].ToString(); response.listInterests[j] = obj; } } else { response.status = "1"; response.message = "No data"; } } catch (Exception ex) { } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"users":"50912345678","serviceId":"30","listInterests":"1$2"} public IActionResult usersInterestsUpdate([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string listInterests = Convert.ToString(userObj["listInterests"]); string users = Convert.ToString(userObj["users"]); string serviceId = Convert.ToString(userObj["serviceId"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; logger.Info("New request income usersInterestsUpdate :" + sendData.ToString()); //Check token //var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["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(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_INTERESTS_UPDATE(users, serviceId, listInterests); logger.Info("Call database USERS_INTERESTS_UPDATE success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } // {"userId":"123","coin":"23","type":"1","tranCode":"ADD"} [HttpPost] public IActionResult usersUpdateCoin([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); response.status = "-1"; response.message = "Err unknow"; try { usersObjCoin data = JsonConvert.DeserializeObject(sendData.ToString()); logger.Info("New request income usersUpdateCoin :" + data.ToString()); //Check token var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["token"]); string channel = Convert.ToString(userObj["channel"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.USERS_UPDATE_COIN(data.userId, data.coin, data.type, data.tranCode); logger.Info("Call database USERS_UPDATE_COIN success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //{"users":"50940227941","serviceId":"30","money":"10"} [HttpPost] public IActionResult ChangeCoinToMoney([FromBody] dynamic sendData) { //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); //log4net.Config.XmlConfigurator.Configure(); responseObjUtil response = new responseObjUtil(); try { usersObjChangeCoinRequest data = JsonConvert.DeserializeObject(sendData.ToString()); logger.Info("New request income ChangeCoinToMoney :" + data.ToString()); //Check token var userObj = JObject.Parse(sendData.ToString()); string token = Convert.ToString(userObj["token"]); string channel = Convert.ToString(userObj["channel"]); //var userObj = JObject.Parse(sendData.ToString()); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "0"; string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.status = "-2"; response.message = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) { logger.Info("Authen token false"); response.status = "35"; response.message = "Check Authen false"; return Ok(response); } //Ket thuc check token DataSet ds_regist = usersDataAccess.ChangeCoinToMoney(data.userId, data.serviceid, data.money); logger.Info("Call database ChangeCoinToMoney success:"); if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.status = ds_regist.Tables[0].Rows[0]["status"].ToString(); response.message = ds_regist.Tables[0].Rows[0]["message"].ToString(); } } catch (Exception ex) { response.status = "-1"; response.message = "Unknow"; logger.Info("Err:" + ex.ToString()); } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //[HttpPost] //public IActionResult blacklistInsertData([FromBody] dynamic sendData) //{ // //Lay ve url va key voi muc dich post vao lay Message cua Errcode // string _keyConfig = string.Empty; // _keyConfig = Common.GetValuesAppSetting("webConfig", "key"); // responseObjUtil response = new responseObjUtil(); // response.status = "-1"; // response.message = "Err unknow"; // logger.Info("Request from UI : " + sendData.ToString()); // var obj = JObject.Parse(sendData.ToString()); // //Check token // var userObj = JObject.Parse(sendData.ToString()); // string token = Convert.ToString(userObj["token"]); // string channel = Convert.ToString(userObj["channel"]); // //var userObj = JObject.Parse(sendData.ToString()); // string language = Convert.ToString(userObj["language"]); // if (string.IsNullOrEmpty(language)) language = "0"; // string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); // string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); // string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); // //---------------------Lay ra va luu mot redis tu cache----------------------------- // redisConnection _redis; // memoryCache.TryGetValue("redis", out _redis); // if (_redis == null) // { // var cacheExpiryOptions = new MemoryCacheEntryOptions // { // AbsoluteExpiration = DateTime.Now.AddMonths(12), // Priority = CacheItemPriority.High, // SlidingExpiration = TimeSpan.FromMinutes(2), // Size = 1024, // }; // _redis = new redisConnection(RedisIp, RedisPort, RedisPass); // _redis.connet(); // memoryCache.Set("redis", _redis, cacheExpiryOptions); // } // if (!_redis.isConnet()) // { // if (!_redis.connet()) // { // logger.Info("Connect to redis false"); // response.status = "-2"; // response.message = "System Update"; // logger.Info("confirmTicket response : " + response.ToString()); // return Ok(response); // } // else // { // var cacheExpiryOptions = new MemoryCacheEntryOptions // { // AbsoluteExpiration = DateTime.Now.AddMonths(12), // Priority = CacheItemPriority.High, // SlidingExpiration = TimeSpan.FromMinutes(2), // Size = 1024, // }; // memoryCache.Set("redis", _redis, cacheExpiryOptions); // } // } // //----------------------Ket thuc lay redis tu cache ------------------------------------- // if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) // { // logger.Info("Authen token false"); // response.status = "35"; // response.message = "Check Authen false"; // return Ok(response); // } // //Ket thuc check token // blackObjList _data = JsonConvert.DeserializeObject(sendData.ToString()); // string user = Convert.ToString(obj["userName"]); // if (string.IsNullOrEmpty(user)) user = "-1"; // try // { // //Check key for authencation // /* // string _keyDecrypt = CustomEncryption.Decrypt(key); // if (_keyDecrypt != _keyConfig) // { // response.status = "-3"; // response.message = "Authentication is false"; // logger.Info("Responase to web: " + response.ToString()); // return Ok(response); // } // */ // List> DataColumms = new List>(); // var LIST_MSISDN = new List(); // var LIST_TYPE = new List(); // var USERS = new List(); // foreach (blackObj eachData in _data.data) // { // LIST_MSISDN.Add(eachData.msisdn); // LIST_TYPE.Add(eachData.isBlackList); // USERS.Add(user); // } // DataColumms.Add(LIST_MSISDN); // DataColumms.Add(LIST_TYPE); // DataColumms.Add(USERS); // usersDataAccess.InsertBulkBlackData("MPS_PKG.BLACKLIST_UPLOAD_DATA", DataColumms); // logger.Info("Call database export_created success:"); // response.status = "0"; // response.message = "Success"; // } // catch (Exception ex) // { // logger.Info("getResultOfTerm exception: " + ex.ToString()); // logger.Info("getParam exception: " + ex.ToString()); // response.status = "-2"; // response.message = "System upgrade"; // } // return Ok(response); //} //[HttpPost] //public IActionResult seachBlackList([FromBody] dynamic sendData) //{ // //Lay ve url va key voi muc dich post vao lay Message cua Errcode // //string _keyConfig = string.Empty; // //_keyConfig = Common.GetValuesAppSetting("webConfig", "key"); // rpBlackList response = new rpBlackList(); // response.status = "-1"; // response.message = "Err unknow"; // logger.Info("Request from UI : " + sendData.ToString()); // var obj = JObject.Parse(sendData.ToString()); // string msisdn = Convert.ToString(obj["msisdn"]); // //string key = Convert.ToString(obj["key"]); // if (string.IsNullOrEmpty(msisdn)) msisdn = "-1"; // try // { // //Check token // var userObj = JObject.Parse(sendData.ToString()); // string token = Convert.ToString(userObj["token"]); // string channel = Convert.ToString(userObj["channel"]); // //var userObj = JObject.Parse(sendData.ToString()); // string language = Convert.ToString(userObj["language"]); // if (string.IsNullOrEmpty(language)) language = "0"; // string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); // string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); // string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); // //---------------------Lay ra va luu mot redis tu cache----------------------------- // redisConnection _redis; // memoryCache.TryGetValue("redis", out _redis); // if (_redis == null) // { // var cacheExpiryOptions = new MemoryCacheEntryOptions // { // AbsoluteExpiration = DateTime.Now.AddMonths(12), // Priority = CacheItemPriority.High, // SlidingExpiration = TimeSpan.FromMinutes(2), // Size = 1024, // }; // _redis = new redisConnection(RedisIp, RedisPort, RedisPass); // _redis.connet(); // memoryCache.Set("redis", _redis, cacheExpiryOptions); // } // if (!_redis.isConnet()) // { // if (!_redis.connet()) // { // logger.Info("Connect to redis false"); // response.status = "-2"; // response.message = "System Update"; // logger.Info("confirmTicket response : " + response.ToString()); // return Ok(response); // } // else // { // var cacheExpiryOptions = new MemoryCacheEntryOptions // { // AbsoluteExpiration = DateTime.Now.AddMonths(12), // Priority = CacheItemPriority.High, // SlidingExpiration = TimeSpan.FromMinutes(2), // Size = 1024, // }; // memoryCache.Set("redis", _redis, cacheExpiryOptions); // } // } // //----------------------Ket thuc lay redis tu cache ------------------------------------- // if (!CommonFunction.checkToken(clientIp,token, channel, _redis, logger)) // { // logger.Info("Authen token false"); // response.status = "35"; // response.message = "Check Authen false"; // return Ok(response); // } // //Ket thuc check token // DataSet ds_regist = usersDataAccess.GET_BLACKLIST(msisdn); // logger.Info("Call database getMoney success:"); // if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) // { // response.status = "0"; // response.message = "Success"; // response.listData = new rpBlack[ds_regist.Tables[0].Rows.Count]; // for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) // { // rpBlack _obj = new rpBlack(); // _obj.msisdn = ds_regist.Tables[0].Rows[j]["MSISDN"].ToString(); // _obj.createDate = ds_regist.Tables[0].Rows[j]["createDate"].ToString(); // _obj.users = ds_regist.Tables[0].Rows[j]["USER_NAME"].ToString(); // _obj.type = ds_regist.Tables[0].Rows[j]["type"].ToString(); // response.listData[j] = _obj; // } // } // else // { // response.status = "1"; // response.message = "Nodata"; // } // } // catch (Exception ex) // { // logger.Info("getParam exception: " + ex.ToString()); // response.status = "-2"; // response.message = "System upgrade"; // } // return Ok(response); //} //{"id":"1","users":"quangbh","key":"jqB3Vi1fIlu+9a2ODQs65w=="} [HttpPost] public IActionResult blacklistGetList([FromBody] dynamic sendData) { logger.Info("New request income blacklistGetList :" + sendData.ToString()); blackListGetListArr response = new blackListGetListArr(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; try { var userObj = JObject.Parse(sendData.ToString()); string msisdn = Convert.ToString(userObj["msisdn"]); string type = Convert.ToString(userObj["type"]); string serviceId = Convert.ToString(userObj["serviceId"]); string users = Convert.ToString(userObj["users"]); if (string.IsNullOrEmpty(users)) users = "-1"; if (string.IsNullOrEmpty(msisdn)) msisdn = "-1"; if (string.IsNullOrEmpty(type)) type = "-1"; if (string.IsNullOrEmpty(serviceId)) serviceId = "-1"; string token = Convert.ToString(userObj["token"]); string channel = Convert.ToString(userObj["channel"]); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "-1"; string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass"); var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- tokenObj _tokenObj = null; if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language); logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } DataSet ds_regist = usersDataAccess.blackGettList(msisdn, type, serviceId, users); logger.Info("Call database blackGettList success:"); response.responseCode = "0"; response.responseMessage = "Success"; if (ds_regist != null & ds_regist.Tables[0].Rows.Count > 0) { response.list = new blackListGetList[ds_regist.Tables[0].Rows.Count]; for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++) { blackListGetList _obj = new blackListGetList(); _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString(); _obj.msisdn = ds_regist.Tables[0].Rows[j]["msisdn"].ToString(); _obj.type = ds_regist.Tables[0].Rows[j]["type"].ToString(); _obj.serviceId = ds_regist.Tables[0].Rows[j]["SV_ID"].ToString(); _obj.sysdate = ds_regist.Tables[0].Rows[j]["VSYSDATE"].ToString(); _obj.users = ds_regist.Tables[0].Rows[j]["USERS"].ToString(); response.list[j] = _obj; } } } catch (Exception ex) { logger.Info("exception: " + ex.ToString()); response.responseCode = "-2"; response.responseMessage = "System upgrade"; } logger.Info("Responase to web: " + response.ToString()); return Ok(response); } //Import data vao Export //--; [HttpPost] public IActionResult blacklistInsertData([FromBody] dynamic sendData) { Response response = new Response(); response.responseCode = "-1"; response.responseMessage = "Err unknow"; logger.Info("Request from UI blacklistInsertData: " + sendData.ToString()); var userObj = JObject.Parse(sendData.ToString()); blackImportDataList _data = JsonConvert.DeserializeObject(sendData.ToString()); if (string.IsNullOrEmpty(_data.type)) _data.type = "-1"; if (string.IsNullOrEmpty(_data.serviceId)) _data.serviceId = "-1"; if (string.IsNullOrEmpty(_data.users)) _data.users = "-1"; try { //Check key for authencation string token = Convert.ToString(userObj["token"]); string channel = Convert.ToString(userObj["channel"]); string language = Convert.ToString(userObj["language"]); if (string.IsNullOrEmpty(language)) language = "-1"; string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp"); string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort"); string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass"); var clientIp = HttpContext.Connection.RemoteIpAddress.ToString(); //---------------------Lay ra va luu mot redis tu cache----------------------------- redisConnection _redis; memoryCache.TryGetValue("redis", out _redis); if (_redis == null) { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; _redis = new redisConnection(RedisIp, RedisPort, RedisPass); _redis.connet(); memoryCache.Set("redis", _redis, cacheExpiryOptions); } if (!_redis.isConnet()) { if (!_redis.connet()) { logger.Info("Connect to redis false"); response.responseCode = "-2"; response.responseMessage = "System Update"; logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } else { var cacheExpiryOptions = new MemoryCacheEntryOptions { AbsoluteExpiration = DateTime.Now.AddMonths(12), Priority = CacheItemPriority.High, SlidingExpiration = TimeSpan.FromMinutes(2), Size = 1024, }; memoryCache.Set("redis", _redis, cacheExpiryOptions); } } //----------------------Ket thuc lay redis tu cache ------------------------------------- tokenObj _tokenObj = null; if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj)) { logger.Info("Authen token false"); response.responseCode = "35"; response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language); logger.Info("confirmTicket response : " + response.ToString()); return Ok(response); } List> DataColumms = new List>(); var LIST_MSISDN = new List(); var LIST_TYPE = new List(); var LIST_SVID = new List(); var LIST_ACTION = new List(); var LIST_USERS = new List(); foreach (blackListObj eachData in _data.data) { LIST_TYPE.Add(_data.type); LIST_SVID.Add(_data.serviceId); LIST_USERS.Add(_data.users); LIST_MSISDN.Add(eachData.msisdn); LIST_ACTION.Add(eachData.action); } DataColumms.Add(LIST_MSISDN); DataColumms.Add(LIST_TYPE); DataColumms.Add(LIST_SVID); DataColumms.Add(LIST_ACTION); DataColumms.Add(LIST_USERS); usersDataAccess.InsertBulkBlackList("BALANCE_PKG.BLACK_INSERT", 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"; } return Ok(response); } } }