| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774 |
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Net;
- using System.Net.Http;
- using ResfullApi.Models;
- using ResfullApi.Models.balance;
- using Newtonsoft.Json;
- using System.Data;
- using System.IO;
- using System.Xml;
- using Microsoft.AspNetCore.Mvc;
- using Newtonsoft.Json.Linq;
- using Microsoft.Extensions.Caching.Memory;
- using CommonObj.common;
- using CommonObj.model;
- using StackExchange.Redis;
- namespace ApiProcess.Controllers
- {
- [ApiController]
- [Route("api/[controller]/[action]/data")]
- public class systemApi : ControllerBase
- {
- static readonly log4net.ILog logger = log4net.LogManager.GetLogger(typeof(systemApi));
- private IMemoryCache memoryCache;
- public systemApi(IMemoryCache memoryCache)
- {
- this.memoryCache = memoryCache;
- }
- // {"msisdn":"50940227941","serviceId":"23","money":"2000"}
- [HttpPost]
- public IActionResult systemCharge([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
- {
- systemObjChargeRequest data = JsonConvert.DeserializeObject<systemObjChargeRequest>(sendData.ToString());
- logger.Info("New request income systemCharge :" + data.ToString());
- //lay ve thong tin cua CGW ung voi service
- DataSet ds_sv = systemDataAccess.SYS_GET_SERVICE_BY_ID(data.serviceId);
- logger.Info("Call database SYS_GET_SERVICE_BY_ID success:");
- if (ds_sv != null & ds_sv.Tables[0].Rows.Count > 0)
- {
- DataRow dr = ds_sv.Tables[0].Rows[0];
- string SV_CODE = dr["sv_code"].ToString();
- string sv_charg_shortcode = dr["sv_charg_shortcode"].ToString();
- string sv_command = dr["sv_command"].ToString();
- string sv_charg_url = dr["sv_charg_url"].ToString();
- string sv_charg_user = dr["sv_charg_user"].ToString();
- string sv_charg_pass = dr["sv_charg_pass"].ToString();
- string sv_char_timeout = dr["sv_char_timeout"].ToString();
- string sv_char_wscode = dr["sv_char_wscode"].ToString();
- string sv_charg_rawdata = dr["sv_charg_rawdata"].ToString();
- string sv_charg_gworder = dr["sv_charg_gworder"].ToString();
- string msisdn_temp = data.msisdn;
- string money = data.money;
- string reqid = SV_CODE + "_" + msisdn_temp+"_" + System.DateTime.Now.ToString("ddMMyyyyHHmmsss");
- string request = createdRequest(reqid, msisdn_temp, money, sv_charg_shortcode, sv_command, sv_charg_user, sv_charg_pass,
- sv_char_wscode, sv_charg_rawdata, sv_charg_gworder);
- logger.Info("Request :" + request);
- string resultPost = getContent(sv_charg_url, sv_char_timeout, request);
- logger.Info("Response :" + resultPost);
- string err_code_cmd = "-2000";
- string err_msg_cmd = "cmd err unknow";
- string ketqua = "-1000|unknow";
- string err_code = "-1000";
- string err_msg = "unknow";
- if (!string.IsNullOrEmpty(resultPost))
- {
- XmlDocument xmlDoc = new XmlDocument();
- xmlDoc.LoadXml(resultPost);
- err_code_cmd = xmlDoc.GetElementsByTagName("error").Item(0).InnerText;
- err_msg_cmd = xmlDoc.GetElementsByTagName("description").Item(0).InnerText;
- if (err_code_cmd == "0")
- {
-
- ketqua = xmlDoc.GetElementsByTagName("return").Item(0).InnerText;
- err_code = ketqua.Split('|')[0];
- err_msg = ketqua.Split('|')[1];
- logger.Info("send request id :" + reqid + " err_code: " + err_code + " err_msg: " + err_msg);
-
- }
- //update log charge
- DataSet ds_updateLog = systemDataAccess.SYS_UPDATE_LOG_CHARGE(data.msisdn, data.serviceId, data.money, err_code_cmd, err_msg_cmd, err_code, err_msg, data.isRenew);
- if (ds_updateLog != null & ds_updateLog.Tables[0].Rows.Count > 0)
- {
- response.status = ds_updateLog.Tables[0].Rows[0]["status"].ToString();
- response.message = ds_updateLog.Tables[0].Rows[0]["message"].ToString();
- }
- }
- }
-
- }
- catch (Exception ex)
- {
- logger.Info("Err:" + ex.ToString());
- }
- logger.Info("Responase to web: " + response.ToString());
- return Ok(response);
- }
- private string createdRequest(string requestid, string msisdn, string money, string shortcode, string command,
- string user, string pass, string sv_char_wscode, string sv_charg_rawdata, string sv_charg_gworder)
- {
- //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
- //log4net.Config.XmlConfigurator.Configure();
- string request = "";
- try
- {
- string input = msisdn + "|" + shortcode + "|" + command + "|1|" + money + "|" + requestid;
- request = request + @"<soapenv:Envelope xmlns:soapenv=""http://schemas.xmlsoap.org/soap/envelope/"" xmlns:web=""http://webservice.bccsgw.viettel.com/"">";
- request = request + @"<soapenv:Header/>";
- request = request + @"<soapenv:Body>";
- request = request + @"<web:gwOperation>";
- request = request + @"<Input>";
- request = request + @"<username>" + user + @"</username>";
- request = request + @"<password>" + pass + @"</password>";
- request = request + @"<wscode>" + sv_char_wscode + @"</wscode>";
- request = request + @"<param name=""GWORDER"" value=""" + sv_charg_gworder + @"""/>";
- request = request + @"<param name=""input"" value=""" + input + @"""/>";
- request = request + @"<rawData></rawData>";
- request = request + @"</Input>";
- request = request + @"</web:gwOperation>";
- request = request + @"</soapenv:Body>";
- request = request + @"</soapenv:Envelope>";
- }
- catch (Exception ex)
- {
- logger.Info("Err when create request: " + ex.ToString());
- }
- return request;
- }
- private string getContent(string api_path, string timeout, string xml)
- {
- //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
- //log4net.Config.XmlConfigurator.Configure();
- string rp = "";
- try
- {
- HttpWebRequest request = (HttpWebRequest)WebRequest.Create(api_path);
- byte[] bytes;
- bytes = System.Text.Encoding.UTF8.GetBytes(xml);
- request.ContentType = "text/xml; encoding='utf-8'";
- request.ContentLength = bytes.Length;
- request.Method = "POST";
- request.Timeout = Convert.ToInt32(timeout);
- Stream requestStream = request.GetRequestStream();
- requestStream.Write(bytes, 0, bytes.Length);
- requestStream.Close();
- HttpWebResponse response;
- response = (HttpWebResponse)request.GetResponse();
- Stream responseStream = response.GetResponseStream();
- rp = new StreamReader(responseStream).ReadToEnd();
- }
- catch (Exception ex)
- {
- logger.Info("Err when post: " + ex.ToString());
- }
- return rp;
- }
- // USER WEB CMS MANAGEMENT APIs
- [HttpPost]
- public IActionResult sysUserWebCmsGetList([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysUserWebCmsGetList :" + sendData.ToString());
- userWebCmsObjList response = new userWebCmsObjList();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string users = Convert.ToString(userObj["users"]);
- string id = Convert.ToString(userObj["id"]);
- string username = Convert.ToString(userObj["username"]);
- string role = Convert.ToString(userObj["role"]);
- string isLock = Convert.ToString(userObj["isLock"]);
- string order = Convert.ToString(userObj["order"]);
- string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]);
- string seqPage = Convert.ToString(userObj["seqPage"]);
-
- if (string.IsNullOrEmpty(users)) users = "-1";
- if (string.IsNullOrEmpty(id)) id = "-1";
- if (string.IsNullOrEmpty(username)) username = "-1";
- if (string.IsNullOrEmpty(role)) role = "-1";
- if (string.IsNullOrEmpty(isLock)) isLock = "-1";
- if (string.IsNullOrEmpty(order)) order = "asc";
- if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000000";
- if (string.IsNullOrEmpty(seqPage)) seqPage = "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 = systemUserDataAccess.SYS_USER_WEB_CMS_GET_LIST(users, id, username, role, isLock, order, rowsOnPage, seqPage);
- logger.Info("Call database SYS_USER_WEB_CMS_GET_LIST success:");
-
- response.responseCode = "0";
- response.responseMessage = "Success";
-
- if (ds_regist != null && ds_regist.Tables.Count > 0 && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.rowsOnPage = ds_regist.Tables[0].Rows[0]["ROW_ON_PAGE"].ToString();
- response.seqPage = ds_regist.Tables[0].Rows[0]["SEQ_PAGE"].ToString();
- response.totalPage = ds_regist.Tables[0].Rows[0]["TOTAL_PAGE"].ToString();
- response.list = new userWebCmsObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- userWebCmsObj _obj = new userWebCmsObj();
- _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString();
- _obj.username = ds_regist.Tables[0].Rows[j]["USERNAME"].ToString();
- _obj.password = ds_regist.Tables[0].Rows[j]["PASSWORD"].ToString();
- _obj.role = ds_regist.Tables[0].Rows[j]["ROLE"].ToString();
- _obj.countryCode = ds_regist.Tables[0].Rows[j]["COUNTRY_CODE"].ToString();
- _obj.isLock = ds_regist.Tables[0].Rows[j]["IS_LOCK"].ToString();
- _obj.totalFalse = ds_regist.Tables[0].Rows[j]["TOTAL_FALSE"].ToString();
- _obj.timeLock = ds_regist.Tables[0].Rows[j]["TIME_LOCK"].ToString();
- _obj.note = ds_regist.Tables[0].Rows[j]["NOTE"].ToString();
- response.list[j] = _obj;
- }
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Response to web: " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult sysUserWebCmsInsert([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysUserWebCmsInsert :" + sendData.ToString());
- Response response = new Response();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string username = Convert.ToString(userObj["username"]);
- string password = Convert.ToString(userObj["password"]);
- string role = Convert.ToString(userObj["role"]);
- string countryCode = Convert.ToString(userObj["countryCode"]);
- string note = Convert.ToString(userObj["note"]);
- string users = Convert.ToString(userObj["users"]);
- if (string.IsNullOrEmpty(username)) username = "-1";
- if (string.IsNullOrEmpty(password)) password = "-1";
- if (string.IsNullOrEmpty(role)) role = "-1";
- if (string.IsNullOrEmpty(countryCode)) countryCode = "-1";
- if (string.IsNullOrEmpty(note)) note = "-1";
- if (string.IsNullOrEmpty(users)) users = "-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 = systemUserDataAccess.SYS_USER_WEB_CMS_INSERT(username, password, role, countryCode, note, users);
- logger.Info("Call database SYS_USER_WEB_CMS_INSERT success:");
-
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.responseCode = ds_regist.Tables[0].Rows[0]["status"].ToString();
- response.responseMessage = ds_regist.Tables[0].Rows[0]["msg"].ToString();
- }
- else
- {
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Response to web: " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult sysUserWebCmsUpdate([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysUserWebCmsUpdate :" + sendData.ToString());
- Response response = new Response();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string id = Convert.ToString(userObj["id"]);
- string username = Convert.ToString(userObj["username"]);
- string password = Convert.ToString(userObj["password"]);
- string role = Convert.ToString(userObj["role"]);
- string countryCode = Convert.ToString(userObj["countryCode"]);
- string isLock = Convert.ToString(userObj["isLock"]);
- string timeLock = Convert.ToString(userObj["timeLock"]);
- string totalFalse = Convert.ToString(userObj["totalFalse"]);
- string note = Convert.ToString(userObj["note"]);
- string users = Convert.ToString(userObj["users"]);
- if (string.IsNullOrEmpty(id)) id = "-1";
- if (string.IsNullOrEmpty(username)) username = "-1";
- if (string.IsNullOrEmpty(password)) password = "-1";
- if (string.IsNullOrEmpty(role)) role = "-1";
- if (string.IsNullOrEmpty(countryCode)) countryCode = "-1";
- if (string.IsNullOrEmpty(isLock)) isLock = "-1";
- if (string.IsNullOrEmpty(timeLock)) timeLock = "-1";
- if (string.IsNullOrEmpty(totalFalse)) totalFalse = "-1";
- if (string.IsNullOrEmpty(note)) note = "-1";
- if (string.IsNullOrEmpty(users)) users = "-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 = systemUserDataAccess.SYS_USER_WEB_CMS_UPDATE(id, username, password, role, countryCode, isLock, timeLock, totalFalse, note, users);
- logger.Info("Call database SYS_USER_WEB_CMS_UPDATE success:");
-
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.responseCode = ds_regist.Tables[0].Rows[0]["status"].ToString();
- response.responseMessage = ds_regist.Tables[0].Rows[0]["msg"].ToString();
- }
- else
- {
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Response to web: " + response.ToString());
- return Ok(response);
- }
- // FUNCTION WEB CMS MANAGEMENT APIs
- [HttpPost]
- public IActionResult sysFunctionWebCmsGetList([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysFunctionWebCmsGetList :" + sendData.ToString());
- functionWebCmsObjList response = new functionWebCmsObjList();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string users = Convert.ToString(userObj["users"]);
- string id = Convert.ToString(userObj["id"]);
- string role = Convert.ToString(userObj["role"]);
- string name = Convert.ToString(userObj["name"]);
- string link = Convert.ToString(userObj["link"]);
- string order = Convert.ToString(userObj["order"]);
- string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]);
- string seqPage = Convert.ToString(userObj["seqPage"]);
-
- if (string.IsNullOrEmpty(users)) users = "-1";
- if (string.IsNullOrEmpty(id)) id = "-1";
- if (string.IsNullOrEmpty(role)) role = "-1";
- if (string.IsNullOrEmpty(name)) name = "-1";
- if (string.IsNullOrEmpty(link)) link = "-1";
- if (string.IsNullOrEmpty(order)) order = "asc";
- if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000000";
- if (string.IsNullOrEmpty(seqPage)) seqPage = "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 = systemUserDataAccess.SYS_FUNCTION_WEB_CMS_GET_LIST(users, id, role, name, link, order, rowsOnPage, seqPage);
- logger.Info("Call database SYS_FUNCTION_WEB_CMS_GET_LIST success:");
-
- response.responseCode = "0";
- response.responseMessage = "Success";
-
- if (ds_regist != null && ds_regist.Tables.Count > 0 && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.rowsOnPage = ds_regist.Tables[0].Rows[0]["ROW_ON_PAGE"].ToString();
- response.seqPage = ds_regist.Tables[0].Rows[0]["SEQ_PAGE"].ToString();
- response.totalPage = ds_regist.Tables[0].Rows[0]["TOTAL_PAGE"].ToString();
- response.list = new functionWebCmsObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- functionWebCmsObj _obj = new functionWebCmsObj();
- _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString();
- _obj.role = ds_regist.Tables[0].Rows[j]["ROLE"].ToString();
- _obj.name = ds_regist.Tables[0].Rows[j]["NAME"].ToString();
- _obj.link = ds_regist.Tables[0].Rows[j]["LINK"].ToString();
- _obj.note = ds_regist.Tables[0].Rows[j]["NOTE"].ToString();
- response.list[j] = _obj;
- }
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Response to web: " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult sysFunctionWebCmsInsert([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysFunctionWebCmsInsert :" + sendData.ToString());
- Response response = new Response();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string role = Convert.ToString(userObj["role"]);
- string name = Convert.ToString(userObj["name"]);
- string link = Convert.ToString(userObj["link"]);
- string note = Convert.ToString(userObj["note"]);
- string users = Convert.ToString(userObj["users"]);
- if (string.IsNullOrEmpty(role)) role = "-1";
- if (string.IsNullOrEmpty(name)) name = "-1";
- if (string.IsNullOrEmpty(link)) link = "-1";
- if (string.IsNullOrEmpty(note)) note = "-1";
- if (string.IsNullOrEmpty(users)) users = "-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 = systemUserDataAccess.SYS_FUNCTION_WEB_CMS_INSERT(role, name, link, note, users);
- logger.Info("Call database SYS_FUNCTION_WEB_CMS_INSERT success:");
-
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.responseCode = ds_regist.Tables[0].Rows[0]["status"].ToString();
- response.responseMessage = ds_regist.Tables[0].Rows[0]["msg"].ToString();
- }
- else
- {
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Response to web: " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult sysFunctionWebCmsUpdate([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysFunctionWebCmsUpdate :" + sendData.ToString());
- Response response = new Response();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string id = Convert.ToString(userObj["id"]);
- string role = Convert.ToString(userObj["role"]);
- string name = Convert.ToString(userObj["name"]);
- string link = Convert.ToString(userObj["link"]);
- string note = Convert.ToString(userObj["note"]);
- string users = Convert.ToString(userObj["users"]);
- if (string.IsNullOrEmpty(id)) id = "-1";
- if (string.IsNullOrEmpty(role)) role = "-1";
- if (string.IsNullOrEmpty(name)) name = "-1";
- if (string.IsNullOrEmpty(link)) link = "-1";
- if (string.IsNullOrEmpty(note)) note = "-1";
- if (string.IsNullOrEmpty(users)) users = "-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 = systemUserDataAccess.SYS_FUNCTION_WEB_CMS_UPDATE(id, role, name, link, note, users);
- logger.Info("Call database SYS_FUNCTION_WEB_CMS_UPDATE success:");
-
- if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.responseCode = ds_regist.Tables[0].Rows[0]["status"].ToString();
- response.responseMessage = ds_regist.Tables[0].Rows[0]["msg"].ToString();
- }
- else
- {
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Response to web: " + response.ToString());
- return Ok(response);
- }
- // REPORT COUNT DAILY MANAGEMENT APIs
- [HttpPost]
- public IActionResult sysReportCountDailyGetList([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysReportCountDailyGetList :" + sendData.ToString());
- reportCountDailyObjList response = new reportCountDailyObjList();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string users = Convert.ToString(userObj["users"]);
- string id = Convert.ToString(userObj["id"]);
- string reportDate = Convert.ToString(userObj["reportDate"]);
- string campaignId = Convert.ToString(userObj["campaignId"]);
- string serviceId = Convert.ToString(userObj["serviceId"]);
- string fromDate = Convert.ToString(userObj["fromDate"]);
- string toDate = Convert.ToString(userObj["toDate"]);
- string order = Convert.ToString(userObj["order"]);
- string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]);
- string seqPage = Convert.ToString(userObj["seqPage"]);
-
- if (string.IsNullOrEmpty(users)) users = "-1";
- if (string.IsNullOrEmpty(id)) id = "-1";
- if (string.IsNullOrEmpty(reportDate)) reportDate = "-1";
- if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
- if (string.IsNullOrEmpty(serviceId)) serviceId = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(order)) order = "desc";
- if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000000";
- if (string.IsNullOrEmpty(seqPage)) seqPage = "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 = systemDataAccess.SYS_REPORT_COUNT_DAILY_GET_LIST(users, id, reportDate, campaignId, serviceId, fromDate, toDate, order, rowsOnPage, seqPage);
- logger.Info("Call database SYS_REPORT_COUNT_DAILY_GET_LIST success:");
-
- response.responseCode = "0";
- response.responseMessage = "Success";
-
- if (ds_regist != null && ds_regist.Tables.Count > 0 && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.rowsOnPage = ds_regist.Tables[0].Rows[0]["ROW_ON_PAGE"].ToString();
- response.seqPage = ds_regist.Tables[0].Rows[0]["SEQ_PAGE"].ToString();
- response.totalPage = ds_regist.Tables[0].Rows[0]["TOTAL_PAGE"].ToString();
- response.list = new reportCountDailyObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- reportCountDailyObj _obj = new reportCountDailyObj();
- _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString();
- _obj.reportDate = ds_regist.Tables[0].Rows[j]["REPORT_DATE"] != DBNull.Value ? Convert.ToDateTime(ds_regist.Tables[0].Rows[j]["REPORT_DATE"]).ToString("dd/MM/yyyy") : "";
- _obj.campaignId = ds_regist.Tables[0].Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["CAMPAIGN_ID"].ToString() : "";
- _obj.campaignName = ds_regist.Tables[0].Rows[j]["CAMPAIGN_NAME"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["CAMPAIGN_NAME"].ToString() : "";
- _obj.priority = ds_regist.Tables[0].Rows[j]["PRIORITY"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["PRIORITY"].ToString() : "";
- _obj.isDefault = ds_regist.Tables[0].Rows[j]["IS_DEFAULT"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["IS_DEFAULT"].ToString() : "";
- _obj.isMyService = ds_regist.Tables[0].Rows[j]["IS_MYSERVICE"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["IS_MYSERVICE"].ToString() : "";
- _obj.addType = ds_regist.Tables[0].Rows[j]["ADD_TYPE"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["ADD_TYPE"].ToString() : "";
- _obj.serviceId = ds_regist.Tables[0].Rows[j]["SERVICE_ID"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["SERVICE_ID"].ToString() : "";
- _obj.serviceName = ds_regist.Tables[0].Rows[j]["SERVICE_NAME"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["SERVICE_NAME"].ToString() : "";
- _obj.countSend1 = ds_regist.Tables[0].Rows[j]["COUNT_SEND_1"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_SEND_1"].ToString() : "0";
- _obj.countSuccess1 = ds_regist.Tables[0].Rows[j]["COUNT_SUCCESS_1"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_SUCCESS_1"].ToString() : "0";
- _obj.countFail1 = ds_regist.Tables[0].Rows[j]["COUNT_FAIL_1"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_FAIL_1"].ToString() : "0";
- _obj.countPress1 = ds_regist.Tables[0].Rows[j]["COUNT_PRESS_1"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_PRESS_1"].ToString() : "0";
- _obj.countSend2 = ds_regist.Tables[0].Rows[j]["COUNT_SEND_2"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_SEND_2"].ToString() : "0";
- _obj.countPress2 = ds_regist.Tables[0].Rows[j]["COUNT_PRESS_2"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_PRESS_2"].ToString() : "0";
- _obj.countRegSuccess = ds_regist.Tables[0].Rows[j]["COUNT_REG_SUCCESS"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_REG_SUCCESS"].ToString() : "0";
- _obj.countRegFail = ds_regist.Tables[0].Rows[j]["COUNT_REG_FAIL"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_REG_FAIL"].ToString() : "0";
- _obj.insertTime = ds_regist.Tables[0].Rows[j]["INSERT_TIME"] != DBNull.Value ? Convert.ToDateTime(ds_regist.Tables[0].Rows[j]["INSERT_TIME"]).ToString("dd/MM/yyyy HH:mm:ss") : "";
- response.list[j] = _obj;
- }
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Response to web: " + response.ToString());
- return Ok(response);
- }
- // REPORT ERROR DAILY MANAGEMENT APIs
- [HttpPost]
- public IActionResult sysReportErrorDailyGetList([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysReportErrorDailyGetList :" + sendData.ToString());
- reportErrorDailyObjList response = new reportErrorDailyObjList();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string users = Convert.ToString(userObj["users"]);
- string reportDate = Convert.ToString(userObj["reportDate"]);
- string campaignId = Convert.ToString(userObj["campaignId"]);
- string serviceId = Convert.ToString(userObj["serviceId"]);
-
- if (string.IsNullOrEmpty(users)) users = "-1";
- if (string.IsNullOrEmpty(reportDate)) reportDate = "-1";
- if (string.IsNullOrEmpty(campaignId)) campaignId = "-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 = systemDataAccess.SYS_REPORT_ERROR_DAILY_GET_LIST(users, reportDate, campaignId, serviceId);
- logger.Info("Call database SYS_REPORT_ERROR_DAILY_GET_LIST success:");
-
- response.responseCode = "0";
- response.responseMessage = "Success";
-
- if (ds_regist != null && ds_regist.Tables.Count > 0 && ds_regist.Tables[0].Rows.Count > 0)
- {
- response.list = new reportErrorDailyObj[ds_regist.Tables[0].Rows.Count];
- for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
- {
- reportErrorDailyObj _obj = new reportErrorDailyObj();
- _obj.id = ds_regist.Tables[0].Rows[j]["ID"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["ID"].ToString() : "";
- _obj.reportDate = ds_regist.Tables[0].Rows[j]["REPORT_DATE"] != DBNull.Value ? Convert.ToDateTime(ds_regist.Tables[0].Rows[j]["REPORT_DATE"]).ToString("dd/MM/yyyy") : "";
- _obj.campaignId = ds_regist.Tables[0].Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["CAMPAIGN_ID"].ToString() : "";
- _obj.serviceId = ds_regist.Tables[0].Rows[j]["SERVICE_ID"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["SERVICE_ID"].ToString() : "";
- _obj.errorCode = ds_regist.Tables[0].Rows[j]["ERROR_CODE"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["ERROR_CODE"].ToString() : "";
- _obj.countNum = ds_regist.Tables[0].Rows[j]["COUNT_NUM"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_NUM"].ToString() : "0";
- _obj.insertTime = ds_regist.Tables[0].Rows[j]["INSERT_TIME"] != DBNull.Value ? Convert.ToDateTime(ds_regist.Tables[0].Rows[j]["INSERT_TIME"]).ToString("dd/MM/yyyy HH:mm:ss") : "";
- response.list[j] = _obj;
- }
- }
- else
- {
- response.list = new reportErrorDailyObj[0];
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Response to web: " + response.ToString());
- return Ok(response);
- }
- // HOURLY IMPRESSIONS API
- [HttpPost]
- public IActionResult sysHourlyImpressionsGetList([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysHourlyImpressionsGetList :" + sendData.ToString());
- hourlyImpressionsObjList response = new hourlyImpressionsObjList();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string campaignId = Convert.ToString(userObj["campaignId"]);
- string serviceId = Convert.ToString(userObj["serviceId"]);
- string hours = Convert.ToString(userObj["hours"]);
- string quickJump = Convert.ToString(userObj["quickJump"]);
-
- if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
- if (string.IsNullOrEmpty(serviceId)) serviceId = "-1";
- if (string.IsNullOrEmpty(hours)) hours = "72h";
- if (string.IsNullOrEmpty(quickJump)) quickJump = "-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("sysHourlyImpressionsGetList 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("sysHourlyImpressionsGetList response : " + response.ToString());
- return Ok(response);
- }
- DataSet ds = balanceDataAccess.GET_HOURLY_IMPRESSIONS(campaignId, serviceId, hours, quickJump);
- logger.Info("Call database GET_HOURLY_IMPRESSIONS success:");
-
- response.responseCode = "0";
- response.responseMessage = "Success";
-
- if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
- {
- response.list = new hourlyImpressionsObj[ds.Tables[0].Rows.Count];
- for (int j = 0; j < ds.Tables[0].Rows.Count; j++)
- {
- hourlyImpressionsObj _obj = new hourlyImpressionsObj();
- _obj.hourLabel = ds.Tables[0].Rows[j]["HOUR_LABEL"] != DBNull.Value ? ds.Tables[0].Rows[j]["HOUR_LABEL"].ToString() : "";
- _obj.hourValue = ds.Tables[0].Rows[j]["HOUR_VALUE"] != DBNull.Value ? ds.Tables[0].Rows[j]["HOUR_VALUE"].ToString() : "";
- _obj.campaignId = ds.Tables[0].Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_ID"].ToString() : "";
- _obj.campaignName = ds.Tables[0].Rows[j]["CAMPAIGN_NAME"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_NAME"].ToString() : "";
- _obj.serviceId = ""; // No longer using service
- _obj.serviceName = ""; // No longer using service
- _obj.countImpressions = ds.Tables[0].Rows[j]["COUNT_IMPRESSED"] != DBNull.Value ? ds.Tables[0].Rows[j]["COUNT_IMPRESSED"].ToString() : "0";
- response.list[j] = _obj;
- }
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Response to web: " + response.ToString());
- return Ok(response);
- }
- // DAILY IMPRESSIONS API
- [HttpPost]
- public IActionResult sysDailyImpressionsGetList([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysDailyImpressionsGetList :" + sendData.ToString());
- hourlyImpressionsObjList response = new hourlyImpressionsObjList();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string campaignId = Convert.ToString(userObj["campaignId"]);
- string fromDate = Convert.ToString(userObj["fromDate"]);
- string toDate = Convert.ToString(userObj["toDate"]);
-
- if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-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("sysDailyImpressionsGetList 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("sysDailyImpressionsGetList response : " + response.ToString());
- return Ok(response);
- }
- DataSet ds = balanceDataAccess.GET_DAILY_IMPRESSIONS(campaignId, fromDate, toDate);
- logger.Info("Call database GET_DAILY_IMPRESSIONS success:");
-
- response.responseCode = "0";
- response.responseMessage = "Success";
-
- if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
- {
- response.list = new hourlyImpressionsObj[ds.Tables[0].Rows.Count];
- for (int j = 0; j < ds.Tables[0].Rows.Count; j++)
- {
- hourlyImpressionsObj _obj = new hourlyImpressionsObj();
- _obj.hourLabel = ds.Tables[0].Rows[j]["DAY_LABEL"] != DBNull.Value ? ds.Tables[0].Rows[j]["DAY_LABEL"].ToString() : "";
- _obj.hourValue = ds.Tables[0].Rows[j]["DAY_VALUE"] != DBNull.Value ? Convert.ToDateTime(ds.Tables[0].Rows[j]["DAY_VALUE"]).ToString("yyyy-MM-dd") : "";
- _obj.campaignId = ds.Tables[0].Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_ID"].ToString() : "";
- _obj.campaignName = ds.Tables[0].Rows[j]["CAMPAIGN_NAME"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_NAME"].ToString() : "";
- _obj.serviceId = ""; // No longer using service
- _obj.serviceName = ""; // No longer using service
- _obj.countImpressions = ds.Tables[0].Rows[j]["COUNT_IMPRESSED"] != DBNull.Value ? ds.Tables[0].Rows[j]["COUNT_IMPRESSED"].ToString() : "0";
- response.list[j] = _obj;
- }
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("Response to web: " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult sysDailyUniqueImpressionsGetList([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysDailyUniqueImpressionsGetList :" + sendData.ToString());
- hourlyImpressionsObjList response = new hourlyImpressionsObjList();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string campaignId = Convert.ToString(userObj["campaignId"]);
- string serviceId = Convert.ToString(userObj["serviceId"]);
- string fromDate = Convert.ToString(userObj["fromDate"]);
- string toDate = Convert.ToString(userObj["toDate"]);
- if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
- if (string.IsNullOrEmpty(serviceId)) serviceId = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-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();
- 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("sysDailyUniqueImpressionsGetList 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);
- }
- }
- 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("sysDailyUniqueImpressionsGetList response : " + response.ToString());
- return Ok(response);
- }
- DataSet ds = balanceDataAccess.GET_DAILY_UNIQUE_IMPRESSIONS(campaignId, serviceId, fromDate, toDate);
- logger.Info("Call database GET_DAILY_UNIQUE_IMPRESSIONS success:");
- response.responseCode = "0";
- response.responseMessage = "Success";
- if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
- {
- response.list = new hourlyImpressionsObj[ds.Tables[0].Rows.Count];
- for (int j = 0; j < ds.Tables[0].Rows.Count; j++)
- {
- hourlyImpressionsObj _obj = new hourlyImpressionsObj();
- _obj.hourLabel = ds.Tables[0].Rows[j]["DAY_LABEL"] != DBNull.Value ? ds.Tables[0].Rows[j]["DAY_LABEL"].ToString() : "";
- _obj.hourValue = ds.Tables[0].Rows[j]["DAY_VALUE"] != DBNull.Value ? Convert.ToDateTime(ds.Tables[0].Rows[j]["DAY_VALUE"]).ToString("yyyy-MM-dd") : "";
- _obj.campaignId = ds.Tables[0].Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_ID"].ToString() : "";
- _obj.campaignName = ds.Tables[0].Rows[j]["CAMPAIGN_NAME"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_NAME"].ToString() : "";
- _obj.serviceId = "";
- _obj.serviceName = "";
- _obj.countImpressions = ds.Tables[0].Rows[j]["COUNT_IMPRESSED"] != DBNull.Value ? ds.Tables[0].Rows[j]["COUNT_IMPRESSED"].ToString() : "0";
- response.list[j] = _obj;
- }
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("sysDailyUniqueImpressionsGetList response : " + response.ToString());
- return Ok(response);
- }
- [HttpPost]
- public IActionResult sysDailyEngagedGetList([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysDailyEngagedGetList :" + sendData.ToString());
- hourlyImpressionsObjList response = new hourlyImpressionsObjList();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string campaignId = Convert.ToString(userObj["campaignId"]);
- string serviceId = Convert.ToString(userObj["serviceId"]);
- string fromDate = Convert.ToString(userObj["fromDate"]);
- string toDate = Convert.ToString(userObj["toDate"]);
- if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
- if (string.IsNullOrEmpty(serviceId)) serviceId = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-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();
- 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("sysDailyEngagedGetList 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);
- }
- }
- 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("sysDailyEngagedGetList response : " + response.ToString());
- return Ok(response);
- }
- DataSet ds = balanceDataAccess.GET_DAILY_ENGAGED_USERS(campaignId, serviceId, fromDate, toDate);
- logger.Info("Call database GET_DAILY_ENGAGED_USERS success:");
- response.responseCode = "0";
- response.responseMessage = "Success";
- if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
- {
- response.list = new hourlyImpressionsObj[ds.Tables[0].Rows.Count];
- for (int j = 0; j < ds.Tables[0].Rows.Count; j++)
- {
- hourlyImpressionsObj _obj = new hourlyImpressionsObj();
- _obj.hourLabel = ds.Tables[0].Rows[j]["DAY_LABEL"] != DBNull.Value ? ds.Tables[0].Rows[j]["DAY_LABEL"].ToString() : "";
- _obj.hourValue = ds.Tables[0].Rows[j]["DAY_VALUE"] != DBNull.Value ? Convert.ToDateTime(ds.Tables[0].Rows[j]["DAY_VALUE"]).ToString("yyyy-MM-dd") : "";
- _obj.campaignId = ds.Tables[0].Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_ID"].ToString() : "";
- _obj.campaignName = ds.Tables[0].Rows[j]["CAMPAIGN_NAME"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_NAME"].ToString() : "";
- _obj.serviceId = "";
- _obj.serviceName = "";
- _obj.countImpressions = ds.Tables[0].Rows[j]["COUNT_ENGAGED"] != DBNull.Value ? ds.Tables[0].Rows[j]["COUNT_ENGAGED"].ToString() : "0";
- response.list[j] = _obj;
- }
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("sysDailyEngagedGetList response : " + response.ToString());
- return Ok(response);
- }
- // PUSH USSD DETAIL REPORT
- [HttpPost]
- public IActionResult sysPushUssdDetailGetList([FromBody] dynamic sendData)
- {
- logger.Info("New request income sysPushUssdDetailGetList :" + sendData.ToString());
- pushUssdDetailObjList response = new pushUssdDetailObjList();
- response.responseCode = "-1";
- response.responseMessage = "Err unknow";
- try
- {
- var userObj = JObject.Parse(sendData.ToString());
- string users = Convert.ToString(userObj["users"]);
- string campaignId = Convert.ToString(userObj["campaignId"]);
- string serviceId = Convert.ToString(userObj["serviceId"]);
- string msisdn = Convert.ToString(userObj["msisdn"]);
- string sendStatus = Convert.ToString(userObj["sendStatus"]);
- string isSuccess = Convert.ToString(userObj["isSuccess"]);
- string fromDate = Convert.ToString(userObj["fromDate"]);
- string toDate = Convert.ToString(userObj["toDate"]);
- string order = Convert.ToString(userObj["order"]);
- string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]);
- string seqPage = Convert.ToString(userObj["seqPage"]);
- if (string.IsNullOrEmpty(users)) users = "-1";
- if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
- if (string.IsNullOrEmpty(serviceId)) serviceId = "-1";
- if (string.IsNullOrEmpty(msisdn)) msisdn = "-1";
- if (string.IsNullOrEmpty(sendStatus)) sendStatus = "-1";
- if (string.IsNullOrEmpty(isSuccess)) isSuccess = "-1";
- if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
- if (string.IsNullOrEmpty(toDate)) toDate = "-1";
- if (string.IsNullOrEmpty(order)) order = "desc";
- if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "100";
- if (string.IsNullOrEmpty(seqPage)) seqPage = "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();
- 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("sysPushUssdDetailGetList 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);
- }
- }
- 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("sysPushUssdDetailGetList response : " + response.ToString());
- return Ok(response);
- }
- DataSet ds = systemDataAccess.SYS_PUSH_USSD_DETAIL_GET_LIST(users, campaignId, serviceId, msisdn, sendStatus, isSuccess, fromDate, toDate, order, rowsOnPage, seqPage);
- logger.Info("Call database SYS_PUSH_USSD_DETAIL_GET_LIST success:");
- response.responseCode = "0";
- response.responseMessage = "Success";
- if (ds != null && ds.Tables.Count > 0)
- {
- var dataTable = ds.Tables[0];
- response.list = new pushUssdDetailObj[dataTable.Rows.Count];
- for (int j = 0; j < dataTable.Rows.Count; j++)
- {
- var _obj = new pushUssdDetailObj();
- _obj.id = dataTable.Rows[j]["ID"].ToString();
- _obj.requestId = dataTable.Rows[j]["REQUEST_ID"].ToString();
- _obj.campaignId = dataTable.Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? dataTable.Rows[j]["CAMPAIGN_ID"].ToString() : "";
- _obj.campaignName = dataTable.Rows[j].Table.Columns.Contains("CAMPAIGN_NAME") && dataTable.Rows[j]["CAMPAIGN_NAME"] != DBNull.Value ? dataTable.Rows[j]["CAMPAIGN_NAME"].ToString() : "";
- _obj.serviceId = dataTable.Rows[j]["SERVICE_ID"] != DBNull.Value ? dataTable.Rows[j]["SERVICE_ID"].ToString() : "";
- _obj.msisdn = dataTable.Rows[j]["MSISDN"].ToString();
- _obj.sendTime = dataTable.Rows[j]["SEND_TIME"] != DBNull.Value ? Convert.ToDateTime(dataTable.Rows[j]["SEND_TIME"]).ToString("dd/MM/yyyy HH:mm:ss") : "";
- _obj.sendStatus = dataTable.Rows[j]["SEND_STATUS"] != DBNull.Value ? dataTable.Rows[j]["SEND_STATUS"].ToString() : "";
- _obj.totalStep = dataTable.Rows[j]["TOTAL_STEP"] != DBNull.Value ? dataTable.Rows[j]["TOTAL_STEP"].ToString() : "";
- _obj.isStep1 = dataTable.Rows[j]["IS_STEP_1"] != DBNull.Value ? dataTable.Rows[j]["IS_STEP_1"].ToString() : "";
- _obj.step1Time = dataTable.Rows[j]["STEP_1_TIME"] != DBNull.Value ? Convert.ToDateTime(dataTable.Rows[j]["STEP_1_TIME"]).ToString("dd/MM/yyyy HH:mm:ss") : "";
- _obj.isStep2 = dataTable.Rows[j]["IS_STEP_2"] != DBNull.Value ? dataTable.Rows[j]["IS_STEP_2"].ToString() : "";
- _obj.step2Time = dataTable.Rows[j]["STEP_2_TIME"] != DBNull.Value ? Convert.ToDateTime(dataTable.Rows[j]["STEP_2_TIME"]).ToString("dd/MM/yyyy HH:mm:ss") : "";
- _obj.errorCode = dataTable.Rows[j]["ERROR_CODE"] != DBNull.Value ? dataTable.Rows[j]["ERROR_CODE"].ToString() : "";
- _obj.isSuccess = dataTable.Rows[j]["IS_SUCCESS"] != DBNull.Value ? dataTable.Rows[j]["IS_SUCCESS"].ToString() : "";
- _obj.insertTime = dataTable.Rows[j]["INSERT_TIME"] != DBNull.Value ? Convert.ToDateTime(dataTable.Rows[j]["INSERT_TIME"]).ToString("dd/MM/yyyy HH:mm:ss") : "";
- _obj.lastUpdate = dataTable.Rows[j]["LAST_UPDATE"] != DBNull.Value ? Convert.ToDateTime(dataTable.Rows[j]["LAST_UPDATE"]).ToString("dd/MM/yyyy HH:mm:ss") : "";
- _obj.msgContent = dataTable.Rows[j].Table.Columns.Contains("MSG_CONTENT") && dataTable.Rows[j]["MSG_CONTENT"] != DBNull.Value ? dataTable.Rows[j]["MSG_CONTENT"].ToString() : "";
- response.list[j] = _obj;
- }
- }
- }
- catch (Exception ex)
- {
- logger.Info("exception: " + ex.ToString());
- response.responseCode = "-2";
- response.responseMessage = "System upgrade";
- }
- logger.Info("sysPushUssdDetailGetList response : " + response.ToString());
- return Ok(response);
- }
- }
- }
|