systemApi.cs 97 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Net;
  5. using System.Net.Http;
  6. using ResfullApi.Models;
  7. using ResfullApi.Models.balance;
  8. using Newtonsoft.Json;
  9. using System.Data;
  10. using System.IO;
  11. using System.Xml;
  12. using Microsoft.AspNetCore.Mvc;
  13. using Newtonsoft.Json.Linq;
  14. using Microsoft.Extensions.Caching.Memory;
  15. using CommonObj.common;
  16. using CommonObj.model;
  17. using StackExchange.Redis;
  18. namespace ApiProcess.Controllers
  19. {
  20. [ApiController]
  21. [Route("api/[controller]/[action]/data")]
  22. public class systemApi : ControllerBase
  23. {
  24. static readonly log4net.ILog logger = log4net.LogManager.GetLogger(typeof(systemApi));
  25. private IMemoryCache memoryCache;
  26. public systemApi(IMemoryCache memoryCache)
  27. {
  28. this.memoryCache = memoryCache;
  29. }
  30. // {"msisdn":"50940227941","serviceId":"23","money":"2000"}
  31. [HttpPost]
  32. public IActionResult systemCharge([FromBody] dynamic sendData)
  33. {
  34. ////log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
  35. ////log4net.Config.XmlConfigurator.Configure();
  36. responseObjUtil response = new responseObjUtil();
  37. response.status = "-1";
  38. response.message = "Err unknow";
  39. try
  40. {
  41. systemObjChargeRequest data = JsonConvert.DeserializeObject<systemObjChargeRequest>(sendData.ToString());
  42. logger.Info("New request income systemCharge :" + data.ToString());
  43. //lay ve thong tin cua CGW ung voi service
  44. DataSet ds_sv = systemDataAccess.SYS_GET_SERVICE_BY_ID(data.serviceId);
  45. logger.Info("Call database SYS_GET_SERVICE_BY_ID success:");
  46. if (ds_sv != null & ds_sv.Tables[0].Rows.Count > 0)
  47. {
  48. DataRow dr = ds_sv.Tables[0].Rows[0];
  49. string SV_CODE = dr["sv_code"].ToString();
  50. string sv_charg_shortcode = dr["sv_charg_shortcode"].ToString();
  51. string sv_command = dr["sv_command"].ToString();
  52. string sv_charg_url = dr["sv_charg_url"].ToString();
  53. string sv_charg_user = dr["sv_charg_user"].ToString();
  54. string sv_charg_pass = dr["sv_charg_pass"].ToString();
  55. string sv_char_timeout = dr["sv_char_timeout"].ToString();
  56. string sv_char_wscode = dr["sv_char_wscode"].ToString();
  57. string sv_charg_rawdata = dr["sv_charg_rawdata"].ToString();
  58. string sv_charg_gworder = dr["sv_charg_gworder"].ToString();
  59. string msisdn_temp = data.msisdn;
  60. string money = data.money;
  61. string reqid = SV_CODE + "_" + msisdn_temp+"_" + System.DateTime.Now.ToString("ddMMyyyyHHmmsss");
  62. string request = createdRequest(reqid, msisdn_temp, money, sv_charg_shortcode, sv_command, sv_charg_user, sv_charg_pass,
  63. sv_char_wscode, sv_charg_rawdata, sv_charg_gworder);
  64. logger.Info("Request :" + request);
  65. string resultPost = getContent(sv_charg_url, sv_char_timeout, request);
  66. logger.Info("Response :" + resultPost);
  67. string err_code_cmd = "-2000";
  68. string err_msg_cmd = "cmd err unknow";
  69. string ketqua = "-1000|unknow";
  70. string err_code = "-1000";
  71. string err_msg = "unknow";
  72. if (!string.IsNullOrEmpty(resultPost))
  73. {
  74. XmlDocument xmlDoc = new XmlDocument();
  75. xmlDoc.LoadXml(resultPost);
  76. err_code_cmd = xmlDoc.GetElementsByTagName("error").Item(0).InnerText;
  77. err_msg_cmd = xmlDoc.GetElementsByTagName("description").Item(0).InnerText;
  78. if (err_code_cmd == "0")
  79. {
  80. ketqua = xmlDoc.GetElementsByTagName("return").Item(0).InnerText;
  81. err_code = ketqua.Split('|')[0];
  82. err_msg = ketqua.Split('|')[1];
  83. logger.Info("send request id :" + reqid + " err_code: " + err_code + " err_msg: " + err_msg);
  84. }
  85. //update log charge
  86. 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);
  87. if (ds_updateLog != null & ds_updateLog.Tables[0].Rows.Count > 0)
  88. {
  89. response.status = ds_updateLog.Tables[0].Rows[0]["status"].ToString();
  90. response.message = ds_updateLog.Tables[0].Rows[0]["message"].ToString();
  91. }
  92. }
  93. }
  94. }
  95. catch (Exception ex)
  96. {
  97. logger.Info("Err:" + ex.ToString());
  98. }
  99. logger.Info("Responase to web: " + response.ToString());
  100. return Ok(response);
  101. }
  102. private string createdRequest(string requestid, string msisdn, string money, string shortcode, string command,
  103. string user, string pass, string sv_char_wscode, string sv_charg_rawdata, string sv_charg_gworder)
  104. {
  105. //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
  106. //log4net.Config.XmlConfigurator.Configure();
  107. string request = "";
  108. try
  109. {
  110. string input = msisdn + "|" + shortcode + "|" + command + "|1|" + money + "|" + requestid;
  111. request = request + @"<soapenv:Envelope xmlns:soapenv=""http://schemas.xmlsoap.org/soap/envelope/"" xmlns:web=""http://webservice.bccsgw.viettel.com/"">";
  112. request = request + @"<soapenv:Header/>";
  113. request = request + @"<soapenv:Body>";
  114. request = request + @"<web:gwOperation>";
  115. request = request + @"<Input>";
  116. request = request + @"<username>" + user + @"</username>";
  117. request = request + @"<password>" + pass + @"</password>";
  118. request = request + @"<wscode>" + sv_char_wscode + @"</wscode>";
  119. request = request + @"<param name=""GWORDER"" value=""" + sv_charg_gworder + @"""/>";
  120. request = request + @"<param name=""input"" value=""" + input + @"""/>";
  121. request = request + @"<rawData></rawData>";
  122. request = request + @"</Input>";
  123. request = request + @"</web:gwOperation>";
  124. request = request + @"</soapenv:Body>";
  125. request = request + @"</soapenv:Envelope>";
  126. }
  127. catch (Exception ex)
  128. {
  129. logger.Info("Err when create request: " + ex.ToString());
  130. }
  131. return request;
  132. }
  133. private string getContent(string api_path, string timeout, string xml)
  134. {
  135. //log4net.ILog logger = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
  136. //log4net.Config.XmlConfigurator.Configure();
  137. string rp = "";
  138. try
  139. {
  140. HttpWebRequest request = (HttpWebRequest)WebRequest.Create(api_path);
  141. byte[] bytes;
  142. bytes = System.Text.Encoding.UTF8.GetBytes(xml);
  143. request.ContentType = "text/xml; encoding='utf-8'";
  144. request.ContentLength = bytes.Length;
  145. request.Method = "POST";
  146. request.Timeout = Convert.ToInt32(timeout);
  147. Stream requestStream = request.GetRequestStream();
  148. requestStream.Write(bytes, 0, bytes.Length);
  149. requestStream.Close();
  150. HttpWebResponse response;
  151. response = (HttpWebResponse)request.GetResponse();
  152. Stream responseStream = response.GetResponseStream();
  153. rp = new StreamReader(responseStream).ReadToEnd();
  154. }
  155. catch (Exception ex)
  156. {
  157. logger.Info("Err when post: " + ex.ToString());
  158. }
  159. return rp;
  160. }
  161. // USER WEB CMS MANAGEMENT APIs
  162. [HttpPost]
  163. public IActionResult sysUserWebCmsGetList([FromBody] dynamic sendData)
  164. {
  165. logger.Info("New request income sysUserWebCmsGetList :" + sendData.ToString());
  166. userWebCmsObjList response = new userWebCmsObjList();
  167. response.responseCode = "-1";
  168. response.responseMessage = "Err unknow";
  169. try
  170. {
  171. var userObj = JObject.Parse(sendData.ToString());
  172. string users = Convert.ToString(userObj["users"]);
  173. string id = Convert.ToString(userObj["id"]);
  174. string username = Convert.ToString(userObj["username"]);
  175. string role = Convert.ToString(userObj["role"]);
  176. string isLock = Convert.ToString(userObj["isLock"]);
  177. string order = Convert.ToString(userObj["order"]);
  178. string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]);
  179. string seqPage = Convert.ToString(userObj["seqPage"]);
  180. if (string.IsNullOrEmpty(users)) users = "-1";
  181. if (string.IsNullOrEmpty(id)) id = "-1";
  182. if (string.IsNullOrEmpty(username)) username = "-1";
  183. if (string.IsNullOrEmpty(role)) role = "-1";
  184. if (string.IsNullOrEmpty(isLock)) isLock = "-1";
  185. if (string.IsNullOrEmpty(order)) order = "asc";
  186. if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000000";
  187. if (string.IsNullOrEmpty(seqPage)) seqPage = "1";
  188. string token = Convert.ToString(userObj["token"]);
  189. string channel = Convert.ToString(userObj["channel"]);
  190. string language = Convert.ToString(userObj["language"]);
  191. if (string.IsNullOrEmpty(language)) language = "-1";
  192. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  193. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  194. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  195. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  196. //---------------------Lay ra va luu mot redis tu cache-----------------------------
  197. redisConnection _redis;
  198. memoryCache.TryGetValue("redis", out _redis);
  199. if (_redis == null)
  200. {
  201. var cacheExpiryOptions = new MemoryCacheEntryOptions
  202. {
  203. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  204. Priority = CacheItemPriority.High,
  205. SlidingExpiration = TimeSpan.FromMinutes(2),
  206. Size = 1024,
  207. };
  208. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  209. _redis.connet();
  210. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  211. }
  212. if (!_redis.isConnet())
  213. {
  214. if (!_redis.connet())
  215. {
  216. logger.Info("Connect to redis false");
  217. response.responseCode = "-2";
  218. response.responseMessage = "System Update";
  219. logger.Info("confirmTicket response : " + response.ToString());
  220. return Ok(response);
  221. }
  222. else
  223. {
  224. var cacheExpiryOptions = new MemoryCacheEntryOptions
  225. {
  226. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  227. Priority = CacheItemPriority.High,
  228. SlidingExpiration = TimeSpan.FromMinutes(2),
  229. Size = 1024,
  230. };
  231. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  232. }
  233. }
  234. //----------------------Ket thuc lay redis tu cache -------------------------------------
  235. tokenObj _tokenObj = null;
  236. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  237. {
  238. logger.Info("Authen token false");
  239. response.responseCode = "35";
  240. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  241. logger.Info("confirmTicket response : " + response.ToString());
  242. return Ok(response);
  243. }
  244. DataSet ds_regist = systemUserDataAccess.SYS_USER_WEB_CMS_GET_LIST(users, id, username, role, isLock, order, rowsOnPage, seqPage);
  245. logger.Info("Call database SYS_USER_WEB_CMS_GET_LIST success:");
  246. response.responseCode = "0";
  247. response.responseMessage = "Success";
  248. if (ds_regist != null && ds_regist.Tables.Count > 0 && ds_regist.Tables[0].Rows.Count > 0)
  249. {
  250. response.rowsOnPage = ds_regist.Tables[0].Rows[0]["ROW_ON_PAGE"].ToString();
  251. response.seqPage = ds_regist.Tables[0].Rows[0]["SEQ_PAGE"].ToString();
  252. response.totalPage = ds_regist.Tables[0].Rows[0]["TOTAL_PAGE"].ToString();
  253. response.list = new userWebCmsObj[ds_regist.Tables[0].Rows.Count];
  254. for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
  255. {
  256. userWebCmsObj _obj = new userWebCmsObj();
  257. _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString();
  258. _obj.username = ds_regist.Tables[0].Rows[j]["USERNAME"].ToString();
  259. _obj.password = ds_regist.Tables[0].Rows[j]["PASSWORD"].ToString();
  260. _obj.role = ds_regist.Tables[0].Rows[j]["ROLE"].ToString();
  261. _obj.countryCode = ds_regist.Tables[0].Rows[j]["COUNTRY_CODE"].ToString();
  262. _obj.isLock = ds_regist.Tables[0].Rows[j]["IS_LOCK"].ToString();
  263. _obj.totalFalse = ds_regist.Tables[0].Rows[j]["TOTAL_FALSE"].ToString();
  264. _obj.timeLock = ds_regist.Tables[0].Rows[j]["TIME_LOCK"].ToString();
  265. _obj.note = ds_regist.Tables[0].Rows[j]["NOTE"].ToString();
  266. response.list[j] = _obj;
  267. }
  268. }
  269. }
  270. catch (Exception ex)
  271. {
  272. logger.Info("exception: " + ex.ToString());
  273. response.responseCode = "-2";
  274. response.responseMessage = "System upgrade";
  275. }
  276. logger.Info("Response to web: " + response.ToString());
  277. return Ok(response);
  278. }
  279. [HttpPost]
  280. public IActionResult sysUserWebCmsInsert([FromBody] dynamic sendData)
  281. {
  282. logger.Info("New request income sysUserWebCmsInsert :" + sendData.ToString());
  283. Response response = new Response();
  284. response.responseCode = "-1";
  285. response.responseMessage = "Err unknow";
  286. try
  287. {
  288. var userObj = JObject.Parse(sendData.ToString());
  289. string username = Convert.ToString(userObj["username"]);
  290. string password = Convert.ToString(userObj["password"]);
  291. string role = Convert.ToString(userObj["role"]);
  292. string countryCode = Convert.ToString(userObj["countryCode"]);
  293. string note = Convert.ToString(userObj["note"]);
  294. string users = Convert.ToString(userObj["users"]);
  295. if (string.IsNullOrEmpty(username)) username = "-1";
  296. if (string.IsNullOrEmpty(password)) password = "-1";
  297. if (string.IsNullOrEmpty(role)) role = "-1";
  298. if (string.IsNullOrEmpty(countryCode)) countryCode = "-1";
  299. if (string.IsNullOrEmpty(note)) note = "-1";
  300. if (string.IsNullOrEmpty(users)) users = "-1";
  301. string token = Convert.ToString(userObj["token"]);
  302. string channel = Convert.ToString(userObj["channel"]);
  303. string language = Convert.ToString(userObj["language"]);
  304. if (string.IsNullOrEmpty(language)) language = "-1";
  305. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  306. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  307. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  308. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  309. //---------------------Lay ra va luu mot redis tu cache-----------------------------
  310. redisConnection _redis;
  311. memoryCache.TryGetValue("redis", out _redis);
  312. if (_redis == null)
  313. {
  314. var cacheExpiryOptions = new MemoryCacheEntryOptions
  315. {
  316. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  317. Priority = CacheItemPriority.High,
  318. SlidingExpiration = TimeSpan.FromMinutes(2),
  319. Size = 1024,
  320. };
  321. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  322. _redis.connet();
  323. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  324. }
  325. if (!_redis.isConnet())
  326. {
  327. if (!_redis.connet())
  328. {
  329. logger.Info("Connect to redis false");
  330. response.responseCode = "-2";
  331. response.responseMessage = "System Update";
  332. logger.Info("confirmTicket response : " + response.ToString());
  333. return Ok(response);
  334. }
  335. else
  336. {
  337. var cacheExpiryOptions = new MemoryCacheEntryOptions
  338. {
  339. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  340. Priority = CacheItemPriority.High,
  341. SlidingExpiration = TimeSpan.FromMinutes(2),
  342. Size = 1024,
  343. };
  344. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  345. }
  346. }
  347. //----------------------Ket thuc lay redis tu cache -------------------------------------
  348. tokenObj _tokenObj = null;
  349. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  350. {
  351. logger.Info("Authen token false");
  352. response.responseCode = "35";
  353. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  354. logger.Info("confirmTicket response : " + response.ToString());
  355. return Ok(response);
  356. }
  357. DataSet ds_regist = systemUserDataAccess.SYS_USER_WEB_CMS_INSERT(username, password, role, countryCode, note, users);
  358. logger.Info("Call database SYS_USER_WEB_CMS_INSERT success:");
  359. if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
  360. {
  361. response.responseCode = ds_regist.Tables[0].Rows[0]["status"].ToString();
  362. response.responseMessage = ds_regist.Tables[0].Rows[0]["msg"].ToString();
  363. }
  364. else
  365. {
  366. response.responseCode = "-1";
  367. response.responseMessage = "Err unknow";
  368. }
  369. }
  370. catch (Exception ex)
  371. {
  372. logger.Info("exception: " + ex.ToString());
  373. response.responseCode = "-2";
  374. response.responseMessage = "System upgrade";
  375. }
  376. logger.Info("Response to web: " + response.ToString());
  377. return Ok(response);
  378. }
  379. [HttpPost]
  380. public IActionResult sysUserWebCmsUpdate([FromBody] dynamic sendData)
  381. {
  382. logger.Info("New request income sysUserWebCmsUpdate :" + sendData.ToString());
  383. Response response = new Response();
  384. response.responseCode = "-1";
  385. response.responseMessage = "Err unknow";
  386. try
  387. {
  388. var userObj = JObject.Parse(sendData.ToString());
  389. string id = Convert.ToString(userObj["id"]);
  390. string username = Convert.ToString(userObj["username"]);
  391. string password = Convert.ToString(userObj["password"]);
  392. string role = Convert.ToString(userObj["role"]);
  393. string countryCode = Convert.ToString(userObj["countryCode"]);
  394. string isLock = Convert.ToString(userObj["isLock"]);
  395. string timeLock = Convert.ToString(userObj["timeLock"]);
  396. string totalFalse = Convert.ToString(userObj["totalFalse"]);
  397. string note = Convert.ToString(userObj["note"]);
  398. string users = Convert.ToString(userObj["users"]);
  399. if (string.IsNullOrEmpty(id)) id = "-1";
  400. if (string.IsNullOrEmpty(username)) username = "-1";
  401. if (string.IsNullOrEmpty(password)) password = "-1";
  402. if (string.IsNullOrEmpty(role)) role = "-1";
  403. if (string.IsNullOrEmpty(countryCode)) countryCode = "-1";
  404. if (string.IsNullOrEmpty(isLock)) isLock = "-1";
  405. if (string.IsNullOrEmpty(timeLock)) timeLock = "-1";
  406. if (string.IsNullOrEmpty(totalFalse)) totalFalse = "-1";
  407. if (string.IsNullOrEmpty(note)) note = "-1";
  408. if (string.IsNullOrEmpty(users)) users = "-1";
  409. string token = Convert.ToString(userObj["token"]);
  410. string channel = Convert.ToString(userObj["channel"]);
  411. string language = Convert.ToString(userObj["language"]);
  412. if (string.IsNullOrEmpty(language)) language = "-1";
  413. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  414. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  415. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  416. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  417. //---------------------Lay ra va luu mot redis tu cache-----------------------------
  418. redisConnection _redis;
  419. memoryCache.TryGetValue("redis", out _redis);
  420. if (_redis == null)
  421. {
  422. var cacheExpiryOptions = new MemoryCacheEntryOptions
  423. {
  424. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  425. Priority = CacheItemPriority.High,
  426. SlidingExpiration = TimeSpan.FromMinutes(2),
  427. Size = 1024,
  428. };
  429. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  430. _redis.connet();
  431. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  432. }
  433. if (!_redis.isConnet())
  434. {
  435. if (!_redis.connet())
  436. {
  437. logger.Info("Connect to redis false");
  438. response.responseCode = "-2";
  439. response.responseMessage = "System Update";
  440. logger.Info("confirmTicket response : " + response.ToString());
  441. return Ok(response);
  442. }
  443. else
  444. {
  445. var cacheExpiryOptions = new MemoryCacheEntryOptions
  446. {
  447. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  448. Priority = CacheItemPriority.High,
  449. SlidingExpiration = TimeSpan.FromMinutes(2),
  450. Size = 1024,
  451. };
  452. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  453. }
  454. }
  455. //----------------------Ket thuc lay redis tu cache -------------------------------------
  456. tokenObj _tokenObj = null;
  457. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  458. {
  459. logger.Info("Authen token false");
  460. response.responseCode = "35";
  461. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  462. logger.Info("confirmTicket response : " + response.ToString());
  463. return Ok(response);
  464. }
  465. DataSet ds_regist = systemUserDataAccess.SYS_USER_WEB_CMS_UPDATE(id, username, ResfullApi.Models.CustomEncryption.Encrypt(password), role, countryCode, isLock, timeLock, totalFalse, note, users);
  466. logger.Info("Call database SYS_USER_WEB_CMS_UPDATE success:");
  467. if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
  468. {
  469. response.responseCode = ds_regist.Tables[0].Rows[0]["status"].ToString();
  470. response.responseMessage = ds_regist.Tables[0].Rows[0]["msg"].ToString();
  471. }
  472. else
  473. {
  474. response.responseCode = "-1";
  475. response.responseMessage = "Err unknow";
  476. }
  477. }
  478. catch (Exception ex)
  479. {
  480. logger.Info("exception: " + ex.ToString());
  481. response.responseCode = "-2";
  482. response.responseMessage = "System upgrade";
  483. }
  484. logger.Info("Response to web: " + response.ToString());
  485. return Ok(response);
  486. }
  487. // FUNCTION WEB CMS MANAGEMENT APIs
  488. [HttpPost]
  489. public IActionResult sysFunctionWebCmsGetList([FromBody] dynamic sendData)
  490. {
  491. logger.Info("New request income sysFunctionWebCmsGetList :" + sendData.ToString());
  492. functionWebCmsObjList response = new functionWebCmsObjList();
  493. response.responseCode = "-1";
  494. response.responseMessage = "Err unknow";
  495. try
  496. {
  497. var userObj = JObject.Parse(sendData.ToString());
  498. string users = Convert.ToString(userObj["users"]);
  499. string id = Convert.ToString(userObj["id"]);
  500. string role = Convert.ToString(userObj["role"]);
  501. string name = Convert.ToString(userObj["name"]);
  502. string link = Convert.ToString(userObj["link"]);
  503. string order = Convert.ToString(userObj["order"]);
  504. string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]);
  505. string seqPage = Convert.ToString(userObj["seqPage"]);
  506. if (string.IsNullOrEmpty(users)) users = "-1";
  507. if (string.IsNullOrEmpty(id)) id = "-1";
  508. if (string.IsNullOrEmpty(role)) role = "-1";
  509. if (string.IsNullOrEmpty(name)) name = "-1";
  510. if (string.IsNullOrEmpty(link)) link = "-1";
  511. if (string.IsNullOrEmpty(order)) order = "asc";
  512. if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000000";
  513. if (string.IsNullOrEmpty(seqPage)) seqPage = "1";
  514. string token = Convert.ToString(userObj["token"]);
  515. string channel = Convert.ToString(userObj["channel"]);
  516. string language = Convert.ToString(userObj["language"]);
  517. if (string.IsNullOrEmpty(language)) language = "-1";
  518. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  519. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  520. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  521. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  522. //---------------------Lay ra va luu mot redis tu cache-----------------------------
  523. redisConnection _redis;
  524. memoryCache.TryGetValue("redis", out _redis);
  525. if (_redis == null)
  526. {
  527. var cacheExpiryOptions = new MemoryCacheEntryOptions
  528. {
  529. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  530. Priority = CacheItemPriority.High,
  531. SlidingExpiration = TimeSpan.FromMinutes(2),
  532. Size = 1024,
  533. };
  534. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  535. _redis.connet();
  536. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  537. }
  538. if (!_redis.isConnet())
  539. {
  540. if (!_redis.connet())
  541. {
  542. logger.Info("Connect to redis false");
  543. response.responseCode = "-2";
  544. response.responseMessage = "System Update";
  545. logger.Info("confirmTicket response : " + response.ToString());
  546. return Ok(response);
  547. }
  548. else
  549. {
  550. var cacheExpiryOptions = new MemoryCacheEntryOptions
  551. {
  552. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  553. Priority = CacheItemPriority.High,
  554. SlidingExpiration = TimeSpan.FromMinutes(2),
  555. Size = 1024,
  556. };
  557. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  558. }
  559. }
  560. //----------------------Ket thuc lay redis tu cache -------------------------------------
  561. tokenObj _tokenObj = null;
  562. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  563. {
  564. logger.Info("Authen token false");
  565. response.responseCode = "35";
  566. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  567. logger.Info("confirmTicket response : " + response.ToString());
  568. return Ok(response);
  569. }
  570. DataSet ds_regist = systemUserDataAccess.SYS_FUNCTION_WEB_CMS_GET_LIST(users, id, role, name, link, order, rowsOnPage, seqPage);
  571. logger.Info("Call database SYS_FUNCTION_WEB_CMS_GET_LIST success:");
  572. response.responseCode = "0";
  573. response.responseMessage = "Success";
  574. if (ds_regist != null && ds_regist.Tables.Count > 0 && ds_regist.Tables[0].Rows.Count > 0)
  575. {
  576. response.rowsOnPage = ds_regist.Tables[0].Rows[0]["ROW_ON_PAGE"].ToString();
  577. response.seqPage = ds_regist.Tables[0].Rows[0]["SEQ_PAGE"].ToString();
  578. response.totalPage = ds_regist.Tables[0].Rows[0]["TOTAL_PAGE"].ToString();
  579. response.list = new functionWebCmsObj[ds_regist.Tables[0].Rows.Count];
  580. for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
  581. {
  582. functionWebCmsObj _obj = new functionWebCmsObj();
  583. _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString();
  584. _obj.role = ds_regist.Tables[0].Rows[j]["ROLE"].ToString();
  585. _obj.name = ds_regist.Tables[0].Rows[j]["NAME"].ToString();
  586. _obj.link = ds_regist.Tables[0].Rows[j]["LINK"].ToString();
  587. _obj.note = ds_regist.Tables[0].Rows[j]["NOTE"].ToString();
  588. response.list[j] = _obj;
  589. }
  590. }
  591. }
  592. catch (Exception ex)
  593. {
  594. logger.Info("exception: " + ex.ToString());
  595. response.responseCode = "-2";
  596. response.responseMessage = "System upgrade";
  597. }
  598. logger.Info("Response to web: " + response.ToString());
  599. return Ok(response);
  600. }
  601. [HttpPost]
  602. public IActionResult sysFunctionWebCmsInsert([FromBody] dynamic sendData)
  603. {
  604. logger.Info("New request income sysFunctionWebCmsInsert :" + sendData.ToString());
  605. Response response = new Response();
  606. response.responseCode = "-1";
  607. response.responseMessage = "Err unknow";
  608. try
  609. {
  610. var userObj = JObject.Parse(sendData.ToString());
  611. string role = Convert.ToString(userObj["role"]);
  612. string name = Convert.ToString(userObj["name"]);
  613. string link = Convert.ToString(userObj["link"]);
  614. string note = Convert.ToString(userObj["note"]);
  615. string users = Convert.ToString(userObj["users"]);
  616. if (string.IsNullOrEmpty(role)) role = "-1";
  617. if (string.IsNullOrEmpty(name)) name = "-1";
  618. if (string.IsNullOrEmpty(link)) link = "-1";
  619. if (string.IsNullOrEmpty(note)) note = "-1";
  620. if (string.IsNullOrEmpty(users)) users = "-1";
  621. string token = Convert.ToString(userObj["token"]);
  622. string channel = Convert.ToString(userObj["channel"]);
  623. string language = Convert.ToString(userObj["language"]);
  624. if (string.IsNullOrEmpty(language)) language = "-1";
  625. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  626. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  627. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  628. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  629. //---------------------Lay ra va luu mot redis tu cache-----------------------------
  630. redisConnection _redis;
  631. memoryCache.TryGetValue("redis", out _redis);
  632. if (_redis == null)
  633. {
  634. var cacheExpiryOptions = new MemoryCacheEntryOptions
  635. {
  636. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  637. Priority = CacheItemPriority.High,
  638. SlidingExpiration = TimeSpan.FromMinutes(2),
  639. Size = 1024,
  640. };
  641. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  642. _redis.connet();
  643. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  644. }
  645. if (!_redis.isConnet())
  646. {
  647. if (!_redis.connet())
  648. {
  649. logger.Info("Connect to redis false");
  650. response.responseCode = "-2";
  651. response.responseMessage = "System Update";
  652. logger.Info("confirmTicket response : " + response.ToString());
  653. return Ok(response);
  654. }
  655. else
  656. {
  657. var cacheExpiryOptions = new MemoryCacheEntryOptions
  658. {
  659. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  660. Priority = CacheItemPriority.High,
  661. SlidingExpiration = TimeSpan.FromMinutes(2),
  662. Size = 1024,
  663. };
  664. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  665. }
  666. }
  667. //----------------------Ket thuc lay redis tu cache -------------------------------------
  668. tokenObj _tokenObj = null;
  669. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  670. {
  671. logger.Info("Authen token false");
  672. response.responseCode = "35";
  673. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  674. logger.Info("confirmTicket response : " + response.ToString());
  675. return Ok(response);
  676. }
  677. DataSet ds_regist = systemUserDataAccess.SYS_FUNCTION_WEB_CMS_INSERT(role, name, link, note, users);
  678. logger.Info("Call database SYS_FUNCTION_WEB_CMS_INSERT success:");
  679. if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
  680. {
  681. response.responseCode = ds_regist.Tables[0].Rows[0]["status"].ToString();
  682. response.responseMessage = ds_regist.Tables[0].Rows[0]["msg"].ToString();
  683. }
  684. else
  685. {
  686. response.responseCode = "-1";
  687. response.responseMessage = "Err unknow";
  688. }
  689. }
  690. catch (Exception ex)
  691. {
  692. logger.Info("exception: " + ex.ToString());
  693. response.responseCode = "-2";
  694. response.responseMessage = "System upgrade";
  695. }
  696. logger.Info("Response to web: " + response.ToString());
  697. return Ok(response);
  698. }
  699. [HttpPost]
  700. public IActionResult sysFunctionWebCmsUpdate([FromBody] dynamic sendData)
  701. {
  702. logger.Info("New request income sysFunctionWebCmsUpdate :" + sendData.ToString());
  703. Response response = new Response();
  704. response.responseCode = "-1";
  705. response.responseMessage = "Err unknow";
  706. try
  707. {
  708. var userObj = JObject.Parse(sendData.ToString());
  709. string id = Convert.ToString(userObj["id"]);
  710. string role = Convert.ToString(userObj["role"]);
  711. string name = Convert.ToString(userObj["name"]);
  712. string link = Convert.ToString(userObj["link"]);
  713. string note = Convert.ToString(userObj["note"]);
  714. string users = Convert.ToString(userObj["users"]);
  715. if (string.IsNullOrEmpty(id)) id = "-1";
  716. if (string.IsNullOrEmpty(role)) role = "-1";
  717. if (string.IsNullOrEmpty(name)) name = "-1";
  718. if (string.IsNullOrEmpty(link)) link = "-1";
  719. if (string.IsNullOrEmpty(note)) note = "-1";
  720. if (string.IsNullOrEmpty(users)) users = "-1";
  721. string token = Convert.ToString(userObj["token"]);
  722. string channel = Convert.ToString(userObj["channel"]);
  723. string language = Convert.ToString(userObj["language"]);
  724. if (string.IsNullOrEmpty(language)) language = "-1";
  725. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  726. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  727. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  728. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  729. //---------------------Lay ra va luu mot redis tu cache-----------------------------
  730. redisConnection _redis;
  731. memoryCache.TryGetValue("redis", out _redis);
  732. if (_redis == null)
  733. {
  734. var cacheExpiryOptions = new MemoryCacheEntryOptions
  735. {
  736. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  737. Priority = CacheItemPriority.High,
  738. SlidingExpiration = TimeSpan.FromMinutes(2),
  739. Size = 1024,
  740. };
  741. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  742. _redis.connet();
  743. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  744. }
  745. if (!_redis.isConnet())
  746. {
  747. if (!_redis.connet())
  748. {
  749. logger.Info("Connect to redis false");
  750. response.responseCode = "-2";
  751. response.responseMessage = "System Update";
  752. logger.Info("confirmTicket response : " + response.ToString());
  753. return Ok(response);
  754. }
  755. else
  756. {
  757. var cacheExpiryOptions = new MemoryCacheEntryOptions
  758. {
  759. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  760. Priority = CacheItemPriority.High,
  761. SlidingExpiration = TimeSpan.FromMinutes(2),
  762. Size = 1024,
  763. };
  764. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  765. }
  766. }
  767. //----------------------Ket thuc lay redis tu cache -------------------------------------
  768. tokenObj _tokenObj = null;
  769. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  770. {
  771. logger.Info("Authen token false");
  772. response.responseCode = "35";
  773. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  774. logger.Info("confirmTicket response : " + response.ToString());
  775. return Ok(response);
  776. }
  777. DataSet ds_regist = systemUserDataAccess.SYS_FUNCTION_WEB_CMS_UPDATE(id, role, name, link, note, users);
  778. logger.Info("Call database SYS_FUNCTION_WEB_CMS_UPDATE success:");
  779. if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
  780. {
  781. response.responseCode = ds_regist.Tables[0].Rows[0]["status"].ToString();
  782. response.responseMessage = ds_regist.Tables[0].Rows[0]["msg"].ToString();
  783. }
  784. else
  785. {
  786. response.responseCode = "-1";
  787. response.responseMessage = "Err unknow";
  788. }
  789. }
  790. catch (Exception ex)
  791. {
  792. logger.Info("exception: " + ex.ToString());
  793. response.responseCode = "-2";
  794. response.responseMessage = "System upgrade";
  795. }
  796. logger.Info("Response to web: " + response.ToString());
  797. return Ok(response);
  798. }
  799. [HttpPost]
  800. public IActionResult sysFunctionWebCmsDelete([FromBody] dynamic sendData)
  801. {
  802. logger.Info("New request income sysFunctionWebCmsDelete :" + sendData.ToString());
  803. Response response = new Response();
  804. response.responseCode = "-1";
  805. response.responseMessage = "Err unknow";
  806. try
  807. {
  808. var userObj = JObject.Parse(sendData.ToString());
  809. string id = Convert.ToString(userObj["id"]);
  810. string users = Convert.ToString(userObj["users"]);
  811. if (string.IsNullOrEmpty(id)) id = "-1";
  812. if (string.IsNullOrEmpty(users)) users = "-1";
  813. string token = Convert.ToString(userObj["token"]);
  814. string channel = Convert.ToString(userObj["channel"]);
  815. string language = Convert.ToString(userObj["language"]);
  816. if (string.IsNullOrEmpty(language)) language = "-1";
  817. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  818. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  819. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  820. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  821. //---------------------Lay ra va luu mot redis tu cache-----------------------------
  822. redisConnection _redis;
  823. memoryCache.TryGetValue("redis", out _redis);
  824. if (_redis == null)
  825. {
  826. var cacheExpiryOptions = new MemoryCacheEntryOptions
  827. {
  828. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  829. Priority = CacheItemPriority.High,
  830. SlidingExpiration = TimeSpan.FromMinutes(2),
  831. Size = 1024,
  832. };
  833. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  834. _redis.connet();
  835. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  836. }
  837. if (!_redis.isConnet())
  838. {
  839. if (!_redis.connet())
  840. {
  841. logger.Info("Connect to redis false");
  842. response.responseCode = "-2";
  843. response.responseMessage = "System Update";
  844. logger.Info("confirmTicket response : " + response.ToString());
  845. return Ok(response);
  846. }
  847. else
  848. {
  849. var cacheExpiryOptions = new MemoryCacheEntryOptions
  850. {
  851. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  852. Priority = CacheItemPriority.High,
  853. SlidingExpiration = TimeSpan.FromMinutes(2),
  854. Size = 1024,
  855. };
  856. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  857. }
  858. }
  859. //----------------------Ket thuc lay redis tu cache -------------------------------------
  860. tokenObj _tokenObj = null;
  861. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  862. {
  863. logger.Info("Authen token false");
  864. response.responseCode = "35";
  865. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  866. logger.Info("confirmTicket response : " + response.ToString());
  867. return Ok(response);
  868. }
  869. DataSet ds_regist = systemUserDataAccess.SYS_FUNCTION_WEB_CMS_DELETE(id, users);
  870. logger.Info("Call database SYS_FUNCTION_WEB_CMS_DELETE success:");
  871. if (ds_regist != null && ds_regist.Tables[0].Rows.Count > 0)
  872. {
  873. response.responseCode = ds_regist.Tables[0].Rows[0]["status"].ToString();
  874. response.responseMessage = ds_regist.Tables[0].Rows[0]["msg"].ToString();
  875. }
  876. else
  877. {
  878. response.responseCode = "-1";
  879. response.responseMessage = "Err unknow";
  880. }
  881. }
  882. catch (Exception ex)
  883. {
  884. logger.Info("exception: " + ex.ToString());
  885. response.responseCode = "-2";
  886. response.responseMessage = "System upgrade";
  887. }
  888. logger.Info("Response to web: " + response.ToString());
  889. return Ok(response);
  890. }
  891. // REPORT COUNT DAILY MANAGEMENT APIs
  892. [HttpPost]
  893. public IActionResult sysReportCountDailyGetList([FromBody] dynamic sendData)
  894. {
  895. logger.Info("New request income sysReportCountDailyGetList :" + sendData.ToString());
  896. reportCountDailyObjList response = new reportCountDailyObjList();
  897. response.responseCode = "-1";
  898. response.responseMessage = "Err unknow";
  899. try
  900. {
  901. var userObj = JObject.Parse(sendData.ToString());
  902. string users = Convert.ToString(userObj["users"]);
  903. string id = Convert.ToString(userObj["id"]);
  904. string reportDate = Convert.ToString(userObj["reportDate"]);
  905. string campaignId = Convert.ToString(userObj["campaignId"]);
  906. string serviceId = Convert.ToString(userObj["serviceId"]);
  907. string fromDate = Convert.ToString(userObj["fromDate"]);
  908. string toDate = Convert.ToString(userObj["toDate"]);
  909. string order = Convert.ToString(userObj["order"]);
  910. string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]);
  911. string seqPage = Convert.ToString(userObj["seqPage"]);
  912. if (string.IsNullOrEmpty(users)) users = "-1";
  913. if (string.IsNullOrEmpty(id)) id = "-1";
  914. if (string.IsNullOrEmpty(reportDate)) reportDate = "-1";
  915. if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
  916. if (string.IsNullOrEmpty(serviceId)) serviceId = "-1";
  917. if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
  918. if (string.IsNullOrEmpty(toDate)) toDate = "-1";
  919. if (string.IsNullOrEmpty(order)) order = "desc";
  920. if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "1000000000000";
  921. if (string.IsNullOrEmpty(seqPage)) seqPage = "1";
  922. string token = Convert.ToString(userObj["token"]);
  923. string channel = Convert.ToString(userObj["channel"]);
  924. string language = Convert.ToString(userObj["language"]);
  925. if (string.IsNullOrEmpty(language)) language = "-1";
  926. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  927. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  928. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  929. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  930. //---------------------Lay ra va luu mot redis tu cache-----------------------------
  931. redisConnection _redis;
  932. memoryCache.TryGetValue("redis", out _redis);
  933. if (_redis == null)
  934. {
  935. var cacheExpiryOptions = new MemoryCacheEntryOptions
  936. {
  937. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  938. Priority = CacheItemPriority.High,
  939. SlidingExpiration = TimeSpan.FromMinutes(2),
  940. Size = 1024,
  941. };
  942. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  943. _redis.connet();
  944. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  945. }
  946. if (!_redis.isConnet())
  947. {
  948. if (!_redis.connet())
  949. {
  950. logger.Info("Connect to redis false");
  951. response.responseCode = "-2";
  952. response.responseMessage = "System Update";
  953. logger.Info("confirmTicket response : " + response.ToString());
  954. return Ok(response);
  955. }
  956. else
  957. {
  958. var cacheExpiryOptions = new MemoryCacheEntryOptions
  959. {
  960. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  961. Priority = CacheItemPriority.High,
  962. SlidingExpiration = TimeSpan.FromMinutes(2),
  963. Size = 1024,
  964. };
  965. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  966. }
  967. }
  968. //----------------------Ket thuc lay redis tu cache -------------------------------------
  969. tokenObj _tokenObj = null;
  970. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  971. {
  972. logger.Info("Authen token false");
  973. response.responseCode = "35";
  974. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  975. logger.Info("confirmTicket response : " + response.ToString());
  976. return Ok(response);
  977. }
  978. DataSet ds_regist = systemDataAccess.SYS_REPORT_COUNT_DAILY_GET_LIST(users, id, reportDate, campaignId, serviceId, fromDate, toDate, order, rowsOnPage, seqPage);
  979. logger.Info("Call database SYS_REPORT_COUNT_DAILY_GET_LIST success:");
  980. response.responseCode = "0";
  981. response.responseMessage = "Success";
  982. if (ds_regist != null && ds_regist.Tables.Count > 0 && ds_regist.Tables[0].Rows.Count > 0)
  983. {
  984. response.rowsOnPage = ds_regist.Tables[0].Rows[0]["ROW_ON_PAGE"].ToString();
  985. response.seqPage = ds_regist.Tables[0].Rows[0]["SEQ_PAGE"].ToString();
  986. response.totalPage = ds_regist.Tables[0].Rows[0]["TOTAL_PAGE"].ToString();
  987. response.list = new reportCountDailyObj[ds_regist.Tables[0].Rows.Count];
  988. for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
  989. {
  990. reportCountDailyObj _obj = new reportCountDailyObj();
  991. _obj.id = ds_regist.Tables[0].Rows[j]["ID"].ToString();
  992. _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") : "";
  993. _obj.campaignId = ds_regist.Tables[0].Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["CAMPAIGN_ID"].ToString() : "";
  994. _obj.campaignName = ds_regist.Tables[0].Rows[j]["CAMPAIGN_NAME"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["CAMPAIGN_NAME"].ToString() : "";
  995. _obj.priority = ds_regist.Tables[0].Rows[j]["PRIORITY"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["PRIORITY"].ToString() : "";
  996. _obj.isDefault = ds_regist.Tables[0].Rows[j]["IS_DEFAULT"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["IS_DEFAULT"].ToString() : "";
  997. _obj.isMyService = ds_regist.Tables[0].Rows[j]["IS_MYSERVICE"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["IS_MYSERVICE"].ToString() : "";
  998. _obj.addType = ds_regist.Tables[0].Rows[j]["ADD_TYPE"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["ADD_TYPE"].ToString() : "";
  999. _obj.serviceId = ds_regist.Tables[0].Rows[j]["SERVICE_ID"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["SERVICE_ID"].ToString() : "";
  1000. _obj.serviceName = ds_regist.Tables[0].Rows[j]["SERVICE_NAME"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["SERVICE_NAME"].ToString() : "";
  1001. _obj.countSend1 = ds_regist.Tables[0].Rows[j]["COUNT_SEND_1"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_SEND_1"].ToString() : "0";
  1002. _obj.countSuccess1 = ds_regist.Tables[0].Rows[j]["COUNT_SUCCESS_1"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_SUCCESS_1"].ToString() : "0";
  1003. _obj.countFail1 = ds_regist.Tables[0].Rows[j]["COUNT_FAIL_1"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_FAIL_1"].ToString() : "0";
  1004. _obj.countPress1 = ds_regist.Tables[0].Rows[j]["COUNT_PRESS_1"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_PRESS_1"].ToString() : "0";
  1005. _obj.countSend2 = ds_regist.Tables[0].Rows[j]["COUNT_SEND_2"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_SEND_2"].ToString() : "0";
  1006. _obj.countPress2 = ds_regist.Tables[0].Rows[j]["COUNT_PRESS_2"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_PRESS_2"].ToString() : "0";
  1007. _obj.countRegSuccess = ds_regist.Tables[0].Rows[j]["COUNT_REG_SUCCESS"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_REG_SUCCESS"].ToString() : "0";
  1008. _obj.countRegFail = ds_regist.Tables[0].Rows[j]["COUNT_REG_FAIL"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_REG_FAIL"].ToString() : "0";
  1009. _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") : "";
  1010. response.list[j] = _obj;
  1011. }
  1012. }
  1013. }
  1014. catch (Exception ex)
  1015. {
  1016. logger.Info("exception: " + ex.ToString());
  1017. response.responseCode = "-2";
  1018. response.responseMessage = "System upgrade";
  1019. }
  1020. logger.Info("Response to web: " + response.ToString());
  1021. return Ok(response);
  1022. }
  1023. // REPORT ERROR DAILY MANAGEMENT APIs
  1024. [HttpPost]
  1025. public IActionResult sysReportErrorDailyGetList([FromBody] dynamic sendData)
  1026. {
  1027. logger.Info("New request income sysReportErrorDailyGetList :" + sendData.ToString());
  1028. reportErrorDailyObjList response = new reportErrorDailyObjList();
  1029. response.responseCode = "-1";
  1030. response.responseMessage = "Err unknow";
  1031. try
  1032. {
  1033. var userObj = JObject.Parse(sendData.ToString());
  1034. string users = Convert.ToString(userObj["users"]);
  1035. string reportDate = Convert.ToString(userObj["reportDate"]);
  1036. string campaignId = Convert.ToString(userObj["campaignId"]);
  1037. string serviceId = Convert.ToString(userObj["serviceId"]);
  1038. if (string.IsNullOrEmpty(users)) users = "-1";
  1039. if (string.IsNullOrEmpty(reportDate)) reportDate = "-1";
  1040. if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
  1041. if (string.IsNullOrEmpty(serviceId)) serviceId = "-1";
  1042. string token = Convert.ToString(userObj["token"]);
  1043. string channel = Convert.ToString(userObj["channel"]);
  1044. string language = Convert.ToString(userObj["language"]);
  1045. if (string.IsNullOrEmpty(language)) language = "-1";
  1046. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  1047. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  1048. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  1049. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  1050. //---------------------Lay ra va luu mot redis tu cache-----------------------------
  1051. redisConnection _redis;
  1052. memoryCache.TryGetValue("redis", out _redis);
  1053. if (_redis == null)
  1054. {
  1055. var cacheExpiryOptions = new MemoryCacheEntryOptions
  1056. {
  1057. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  1058. Priority = CacheItemPriority.High,
  1059. SlidingExpiration = TimeSpan.FromMinutes(2),
  1060. Size = 1024,
  1061. };
  1062. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  1063. _redis.connet();
  1064. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  1065. }
  1066. if (!_redis.isConnet())
  1067. {
  1068. if (!_redis.connet())
  1069. {
  1070. logger.Info("Connect to redis false");
  1071. response.responseCode = "-2";
  1072. response.responseMessage = "System Update";
  1073. logger.Info("confirmTicket response : " + response.ToString());
  1074. return Ok(response);
  1075. }
  1076. else
  1077. {
  1078. var cacheExpiryOptions = new MemoryCacheEntryOptions
  1079. {
  1080. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  1081. Priority = CacheItemPriority.High,
  1082. SlidingExpiration = TimeSpan.FromMinutes(2),
  1083. Size = 1024,
  1084. };
  1085. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  1086. }
  1087. }
  1088. //----------------------Ket thuc lay redis tu cache -------------------------------------
  1089. tokenObj _tokenObj = null;
  1090. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  1091. {
  1092. logger.Info("Authen token false");
  1093. response.responseCode = "35";
  1094. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  1095. logger.Info("confirmTicket response : " + response.ToString());
  1096. return Ok(response);
  1097. }
  1098. DataSet ds_regist = systemDataAccess.SYS_REPORT_ERROR_DAILY_GET_LIST(users, reportDate, campaignId, serviceId);
  1099. logger.Info("Call database SYS_REPORT_ERROR_DAILY_GET_LIST success:");
  1100. response.responseCode = "0";
  1101. response.responseMessage = "Success";
  1102. if (ds_regist != null && ds_regist.Tables.Count > 0 && ds_regist.Tables[0].Rows.Count > 0)
  1103. {
  1104. response.list = new reportErrorDailyObj[ds_regist.Tables[0].Rows.Count];
  1105. for (int j = 0; j < ds_regist.Tables[0].Rows.Count; j++)
  1106. {
  1107. reportErrorDailyObj _obj = new reportErrorDailyObj();
  1108. _obj.id = ds_regist.Tables[0].Rows[j]["ID"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["ID"].ToString() : "";
  1109. _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") : "";
  1110. _obj.campaignId = ds_regist.Tables[0].Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["CAMPAIGN_ID"].ToString() : "";
  1111. _obj.serviceId = ds_regist.Tables[0].Rows[j]["SERVICE_ID"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["SERVICE_ID"].ToString() : "";
  1112. _obj.errorCode = ds_regist.Tables[0].Rows[j]["ERROR_CODE"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["ERROR_CODE"].ToString() : "";
  1113. _obj.countNum = ds_regist.Tables[0].Rows[j]["COUNT_NUM"] != DBNull.Value ? ds_regist.Tables[0].Rows[j]["COUNT_NUM"].ToString() : "0";
  1114. _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") : "";
  1115. response.list[j] = _obj;
  1116. }
  1117. }
  1118. else
  1119. {
  1120. response.list = new reportErrorDailyObj[0];
  1121. }
  1122. }
  1123. catch (Exception ex)
  1124. {
  1125. logger.Info("exception: " + ex.ToString());
  1126. response.responseCode = "-2";
  1127. response.responseMessage = "System upgrade";
  1128. }
  1129. logger.Info("Response to web: " + response.ToString());
  1130. return Ok(response);
  1131. }
  1132. // HOURLY IMPRESSIONS API
  1133. [HttpPost]
  1134. public IActionResult sysHourlyImpressionsGetList([FromBody] dynamic sendData)
  1135. {
  1136. logger.Info("New request income sysHourlyImpressionsGetList :" + sendData.ToString());
  1137. hourlyImpressionsObjList response = new hourlyImpressionsObjList();
  1138. response.responseCode = "-1";
  1139. response.responseMessage = "Err unknow";
  1140. try
  1141. {
  1142. var userObj = JObject.Parse(sendData.ToString());
  1143. string campaignId = Convert.ToString(userObj["campaignId"]);
  1144. string serviceId = Convert.ToString(userObj["serviceId"]);
  1145. string hours = Convert.ToString(userObj["hours"]);
  1146. string quickJump = Convert.ToString(userObj["quickJump"]);
  1147. if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
  1148. if (string.IsNullOrEmpty(serviceId)) serviceId = "-1";
  1149. if (string.IsNullOrEmpty(hours)) hours = "72h";
  1150. if (string.IsNullOrEmpty(quickJump)) quickJump = "-1";
  1151. string token = Convert.ToString(userObj["token"]);
  1152. string channel = Convert.ToString(userObj["channel"]);
  1153. string language = Convert.ToString(userObj["language"]);
  1154. if (string.IsNullOrEmpty(language)) language = "-1";
  1155. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  1156. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  1157. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  1158. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  1159. //---------------------Lay ra va luu mot redis tu cache-----------------------------
  1160. redisConnection _redis;
  1161. memoryCache.TryGetValue("redis", out _redis);
  1162. if (_redis == null)
  1163. {
  1164. var cacheExpiryOptions = new MemoryCacheEntryOptions
  1165. {
  1166. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  1167. Priority = CacheItemPriority.High,
  1168. SlidingExpiration = TimeSpan.FromMinutes(2),
  1169. Size = 1024,
  1170. };
  1171. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  1172. _redis.connet();
  1173. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  1174. }
  1175. if (!_redis.isConnet())
  1176. {
  1177. if (!_redis.connet())
  1178. {
  1179. logger.Info("Connect to redis false");
  1180. response.responseCode = "-2";
  1181. response.responseMessage = "System Update";
  1182. logger.Info("sysHourlyImpressionsGetList response : " + response.ToString());
  1183. return Ok(response);
  1184. }
  1185. else
  1186. {
  1187. var cacheExpiryOptions = new MemoryCacheEntryOptions
  1188. {
  1189. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  1190. Priority = CacheItemPriority.High,
  1191. SlidingExpiration = TimeSpan.FromMinutes(2),
  1192. Size = 1024,
  1193. };
  1194. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  1195. }
  1196. }
  1197. //----------------------Ket thuc lay redis tu cache -------------------------------------
  1198. tokenObj _tokenObj = null;
  1199. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  1200. {
  1201. logger.Info("Authen token false");
  1202. response.responseCode = "35";
  1203. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  1204. logger.Info("sysHourlyImpressionsGetList response : " + response.ToString());
  1205. return Ok(response);
  1206. }
  1207. DataSet ds = balanceDataAccess.GET_HOURLY_IMPRESSIONS(campaignId, serviceId, hours, quickJump);
  1208. logger.Info("Call database GET_HOURLY_IMPRESSIONS success:");
  1209. response.responseCode = "0";
  1210. response.responseMessage = "Success";
  1211. if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
  1212. {
  1213. response.list = new hourlyImpressionsObj[ds.Tables[0].Rows.Count];
  1214. for (int j = 0; j < ds.Tables[0].Rows.Count; j++)
  1215. {
  1216. hourlyImpressionsObj _obj = new hourlyImpressionsObj();
  1217. _obj.hourLabel = ds.Tables[0].Rows[j]["HOUR_LABEL"] != DBNull.Value ? ds.Tables[0].Rows[j]["HOUR_LABEL"].ToString() : "";
  1218. _obj.hourValue = ds.Tables[0].Rows[j]["HOUR_VALUE"] != DBNull.Value ? ds.Tables[0].Rows[j]["HOUR_VALUE"].ToString() : "";
  1219. _obj.campaignId = ds.Tables[0].Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_ID"].ToString() : "";
  1220. _obj.campaignName = ds.Tables[0].Rows[j]["CAMPAIGN_NAME"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_NAME"].ToString() : "";
  1221. _obj.serviceId = ""; // No longer using service
  1222. _obj.serviceName = ""; // No longer using service
  1223. _obj.countImpressions = ds.Tables[0].Rows[j]["COUNT_IMPRESSED"] != DBNull.Value ? ds.Tables[0].Rows[j]["COUNT_IMPRESSED"].ToString() : "0";
  1224. response.list[j] = _obj;
  1225. }
  1226. }
  1227. }
  1228. catch (Exception ex)
  1229. {
  1230. logger.Info("exception: " + ex.ToString());
  1231. response.responseCode = "-2";
  1232. response.responseMessage = "System upgrade";
  1233. }
  1234. logger.Info("Response to web: " + response.ToString());
  1235. return Ok(response);
  1236. }
  1237. // DAILY IMPRESSIONS API
  1238. [HttpPost]
  1239. public IActionResult sysDailyImpressionsGetList([FromBody] dynamic sendData)
  1240. {
  1241. logger.Info("New request income sysDailyImpressionsGetList :" + sendData.ToString());
  1242. hourlyImpressionsObjList response = new hourlyImpressionsObjList();
  1243. response.responseCode = "-1";
  1244. response.responseMessage = "Err unknow";
  1245. try
  1246. {
  1247. var userObj = JObject.Parse(sendData.ToString());
  1248. string campaignId = Convert.ToString(userObj["campaignId"]);
  1249. string fromDate = Convert.ToString(userObj["fromDate"]);
  1250. string toDate = Convert.ToString(userObj["toDate"]);
  1251. if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
  1252. if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
  1253. if (string.IsNullOrEmpty(toDate)) toDate = "-1";
  1254. string token = Convert.ToString(userObj["token"]);
  1255. string channel = Convert.ToString(userObj["channel"]);
  1256. string language = Convert.ToString(userObj["language"]);
  1257. if (string.IsNullOrEmpty(language)) language = "-1";
  1258. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  1259. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  1260. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  1261. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  1262. //---------------------Lay ra va luu mot redis tu cache-----------------------------
  1263. redisConnection _redis;
  1264. memoryCache.TryGetValue("redis", out _redis);
  1265. if (_redis == null)
  1266. {
  1267. var cacheExpiryOptions = new MemoryCacheEntryOptions
  1268. {
  1269. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  1270. Priority = CacheItemPriority.High,
  1271. SlidingExpiration = TimeSpan.FromMinutes(2),
  1272. Size = 1024,
  1273. };
  1274. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  1275. _redis.connet();
  1276. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  1277. }
  1278. if (!_redis.isConnet())
  1279. {
  1280. if (!_redis.connet())
  1281. {
  1282. logger.Info("Connect to redis false");
  1283. response.responseCode = "-2";
  1284. response.responseMessage = "System Update";
  1285. logger.Info("sysDailyImpressionsGetList response : " + response.ToString());
  1286. return Ok(response);
  1287. }
  1288. else
  1289. {
  1290. var cacheExpiryOptions = new MemoryCacheEntryOptions
  1291. {
  1292. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  1293. Priority = CacheItemPriority.High,
  1294. SlidingExpiration = TimeSpan.FromMinutes(2),
  1295. Size = 1024,
  1296. };
  1297. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  1298. }
  1299. }
  1300. //----------------------Ket thuc lay redis tu cache -------------------------------------
  1301. tokenObj _tokenObj = null;
  1302. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  1303. {
  1304. logger.Info("Authen token false");
  1305. response.responseCode = "35";
  1306. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  1307. logger.Info("sysDailyImpressionsGetList response : " + response.ToString());
  1308. return Ok(response);
  1309. }
  1310. DataSet ds = balanceDataAccess.GET_DAILY_IMPRESSIONS(campaignId, fromDate, toDate);
  1311. logger.Info("Call database GET_DAILY_IMPRESSIONS success:");
  1312. response.responseCode = "0";
  1313. response.responseMessage = "Success";
  1314. if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
  1315. {
  1316. response.list = new hourlyImpressionsObj[ds.Tables[0].Rows.Count];
  1317. for (int j = 0; j < ds.Tables[0].Rows.Count; j++)
  1318. {
  1319. hourlyImpressionsObj _obj = new hourlyImpressionsObj();
  1320. _obj.hourLabel = ds.Tables[0].Rows[j]["DAY_LABEL"] != DBNull.Value ? ds.Tables[0].Rows[j]["DAY_LABEL"].ToString() : "";
  1321. _obj.hourValue = ds.Tables[0].Rows[j]["DAY_VALUE"] != DBNull.Value ? Convert.ToDateTime(ds.Tables[0].Rows[j]["DAY_VALUE"]).ToString("yyyy-MM-dd") : "";
  1322. _obj.campaignId = ds.Tables[0].Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_ID"].ToString() : "";
  1323. _obj.campaignName = ds.Tables[0].Rows[j]["CAMPAIGN_NAME"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_NAME"].ToString() : "";
  1324. _obj.serviceId = ""; // No longer using service
  1325. _obj.serviceName = ""; // No longer using service
  1326. _obj.countImpressions = ds.Tables[0].Rows[j]["COUNT_IMPRESSED"] != DBNull.Value ? ds.Tables[0].Rows[j]["COUNT_IMPRESSED"].ToString() : "0";
  1327. response.list[j] = _obj;
  1328. }
  1329. }
  1330. }
  1331. catch (Exception ex)
  1332. {
  1333. logger.Info("exception: " + ex.ToString());
  1334. response.responseCode = "-2";
  1335. response.responseMessage = "System upgrade";
  1336. }
  1337. logger.Info("Response to web: " + response.ToString());
  1338. return Ok(response);
  1339. }
  1340. [HttpPost]
  1341. public IActionResult sysDailyUniqueImpressionsGetList([FromBody] dynamic sendData)
  1342. {
  1343. logger.Info("New request income sysDailyUniqueImpressionsGetList :" + sendData.ToString());
  1344. hourlyImpressionsObjList response = new hourlyImpressionsObjList();
  1345. response.responseCode = "-1";
  1346. response.responseMessage = "Err unknow";
  1347. try
  1348. {
  1349. var userObj = JObject.Parse(sendData.ToString());
  1350. string campaignId = Convert.ToString(userObj["campaignId"]);
  1351. string serviceId = Convert.ToString(userObj["serviceId"]);
  1352. string fromDate = Convert.ToString(userObj["fromDate"]);
  1353. string toDate = Convert.ToString(userObj["toDate"]);
  1354. if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
  1355. if (string.IsNullOrEmpty(serviceId)) serviceId = "-1";
  1356. if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
  1357. if (string.IsNullOrEmpty(toDate)) toDate = "-1";
  1358. string token = Convert.ToString(userObj["token"]);
  1359. string channel = Convert.ToString(userObj["channel"]);
  1360. string language = Convert.ToString(userObj["language"]);
  1361. if (string.IsNullOrEmpty(language)) language = "-1";
  1362. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  1363. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  1364. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  1365. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  1366. redisConnection _redis;
  1367. memoryCache.TryGetValue("redis", out _redis);
  1368. if (_redis == null)
  1369. {
  1370. var cacheExpiryOptions = new MemoryCacheEntryOptions
  1371. {
  1372. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  1373. Priority = CacheItemPriority.High,
  1374. SlidingExpiration = TimeSpan.FromMinutes(2),
  1375. Size = 1024,
  1376. };
  1377. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  1378. _redis.connet();
  1379. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  1380. }
  1381. if (!_redis.isConnet())
  1382. {
  1383. if (!_redis.connet())
  1384. {
  1385. logger.Info("Connect to redis false");
  1386. response.responseCode = "-2";
  1387. response.responseMessage = "System Update";
  1388. logger.Info("sysDailyUniqueImpressionsGetList response : " + response.ToString());
  1389. return Ok(response);
  1390. }
  1391. else
  1392. {
  1393. var cacheExpiryOptions = new MemoryCacheEntryOptions
  1394. {
  1395. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  1396. Priority = CacheItemPriority.High,
  1397. SlidingExpiration = TimeSpan.FromMinutes(2),
  1398. Size = 1024,
  1399. };
  1400. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  1401. }
  1402. }
  1403. tokenObj _tokenObj = null;
  1404. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  1405. {
  1406. logger.Info("Authen token false");
  1407. response.responseCode = "35";
  1408. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  1409. logger.Info("sysDailyUniqueImpressionsGetList response : " + response.ToString());
  1410. return Ok(response);
  1411. }
  1412. DataSet ds = balanceDataAccess.GET_DAILY_UNIQUE_IMPRESSIONS(campaignId, serviceId, fromDate, toDate);
  1413. logger.Info("Call database GET_DAILY_UNIQUE_IMPRESSIONS success:");
  1414. response.responseCode = "0";
  1415. response.responseMessage = "Success";
  1416. if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
  1417. {
  1418. response.list = new hourlyImpressionsObj[ds.Tables[0].Rows.Count];
  1419. for (int j = 0; j < ds.Tables[0].Rows.Count; j++)
  1420. {
  1421. hourlyImpressionsObj _obj = new hourlyImpressionsObj();
  1422. _obj.hourLabel = ds.Tables[0].Rows[j]["DAY_LABEL"] != DBNull.Value ? ds.Tables[0].Rows[j]["DAY_LABEL"].ToString() : "";
  1423. _obj.hourValue = ds.Tables[0].Rows[j]["DAY_VALUE"] != DBNull.Value ? Convert.ToDateTime(ds.Tables[0].Rows[j]["DAY_VALUE"]).ToString("yyyy-MM-dd") : "";
  1424. _obj.campaignId = ds.Tables[0].Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_ID"].ToString() : "";
  1425. _obj.campaignName = ds.Tables[0].Rows[j]["CAMPAIGN_NAME"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_NAME"].ToString() : "";
  1426. _obj.serviceId = "";
  1427. _obj.serviceName = "";
  1428. _obj.countImpressions = ds.Tables[0].Rows[j]["COUNT_IMPRESSED"] != DBNull.Value ? ds.Tables[0].Rows[j]["COUNT_IMPRESSED"].ToString() : "0";
  1429. response.list[j] = _obj;
  1430. }
  1431. }
  1432. }
  1433. catch (Exception ex)
  1434. {
  1435. logger.Info("exception: " + ex.ToString());
  1436. response.responseCode = "-2";
  1437. response.responseMessage = "System upgrade";
  1438. }
  1439. logger.Info("sysDailyUniqueImpressionsGetList response : " + response.ToString());
  1440. return Ok(response);
  1441. }
  1442. [HttpPost]
  1443. public IActionResult sysDailyEngagedGetList([FromBody] dynamic sendData)
  1444. {
  1445. logger.Info("New request income sysDailyEngagedGetList :" + sendData.ToString());
  1446. hourlyImpressionsObjList response = new hourlyImpressionsObjList();
  1447. response.responseCode = "-1";
  1448. response.responseMessage = "Err unknow";
  1449. try
  1450. {
  1451. var userObj = JObject.Parse(sendData.ToString());
  1452. string campaignId = Convert.ToString(userObj["campaignId"]);
  1453. string serviceId = Convert.ToString(userObj["serviceId"]);
  1454. string fromDate = Convert.ToString(userObj["fromDate"]);
  1455. string toDate = Convert.ToString(userObj["toDate"]);
  1456. if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
  1457. if (string.IsNullOrEmpty(serviceId)) serviceId = "-1";
  1458. if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
  1459. if (string.IsNullOrEmpty(toDate)) toDate = "-1";
  1460. string token = Convert.ToString(userObj["token"]);
  1461. string channel = Convert.ToString(userObj["channel"]);
  1462. string language = Convert.ToString(userObj["language"]);
  1463. if (string.IsNullOrEmpty(language)) language = "-1";
  1464. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  1465. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  1466. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  1467. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  1468. redisConnection _redis;
  1469. memoryCache.TryGetValue("redis", out _redis);
  1470. if (_redis == null)
  1471. {
  1472. var cacheExpiryOptions = new MemoryCacheEntryOptions
  1473. {
  1474. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  1475. Priority = CacheItemPriority.High,
  1476. SlidingExpiration = TimeSpan.FromMinutes(2),
  1477. Size = 1024,
  1478. };
  1479. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  1480. _redis.connet();
  1481. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  1482. }
  1483. if (!_redis.isConnet())
  1484. {
  1485. if (!_redis.connet())
  1486. {
  1487. logger.Info("Connect to redis false");
  1488. response.responseCode = "-2";
  1489. response.responseMessage = "System Update";
  1490. logger.Info("sysDailyEngagedGetList response : " + response.ToString());
  1491. return Ok(response);
  1492. }
  1493. else
  1494. {
  1495. var cacheExpiryOptions = new MemoryCacheEntryOptions
  1496. {
  1497. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  1498. Priority = CacheItemPriority.High,
  1499. SlidingExpiration = TimeSpan.FromMinutes(2),
  1500. Size = 1024,
  1501. };
  1502. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  1503. }
  1504. }
  1505. tokenObj _tokenObj = null;
  1506. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  1507. {
  1508. logger.Info("Authen token false");
  1509. response.responseCode = "35";
  1510. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  1511. logger.Info("sysDailyEngagedGetList response : " + response.ToString());
  1512. return Ok(response);
  1513. }
  1514. DataSet ds = balanceDataAccess.GET_DAILY_ENGAGED_USERS(campaignId, serviceId, fromDate, toDate);
  1515. logger.Info("Call database GET_DAILY_ENGAGED_USERS success:");
  1516. response.responseCode = "0";
  1517. response.responseMessage = "Success";
  1518. if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
  1519. {
  1520. response.list = new hourlyImpressionsObj[ds.Tables[0].Rows.Count];
  1521. for (int j = 0; j < ds.Tables[0].Rows.Count; j++)
  1522. {
  1523. hourlyImpressionsObj _obj = new hourlyImpressionsObj();
  1524. _obj.hourLabel = ds.Tables[0].Rows[j]["DAY_LABEL"] != DBNull.Value ? ds.Tables[0].Rows[j]["DAY_LABEL"].ToString() : "";
  1525. _obj.hourValue = ds.Tables[0].Rows[j]["DAY_VALUE"] != DBNull.Value ? Convert.ToDateTime(ds.Tables[0].Rows[j]["DAY_VALUE"]).ToString("yyyy-MM-dd") : "";
  1526. _obj.campaignId = ds.Tables[0].Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_ID"].ToString() : "";
  1527. _obj.campaignName = ds.Tables[0].Rows[j]["CAMPAIGN_NAME"] != DBNull.Value ? ds.Tables[0].Rows[j]["CAMPAIGN_NAME"].ToString() : "";
  1528. _obj.serviceId = "";
  1529. _obj.serviceName = "";
  1530. _obj.countImpressions = ds.Tables[0].Rows[j]["COUNT_ENGAGED"] != DBNull.Value ? ds.Tables[0].Rows[j]["COUNT_ENGAGED"].ToString() : "0";
  1531. response.list[j] = _obj;
  1532. }
  1533. }
  1534. }
  1535. catch (Exception ex)
  1536. {
  1537. logger.Info("exception: " + ex.ToString());
  1538. response.responseCode = "-2";
  1539. response.responseMessage = "System upgrade";
  1540. }
  1541. logger.Info("sysDailyEngagedGetList response : " + response.ToString());
  1542. return Ok(response);
  1543. }
  1544. // PUSH USSD DETAIL REPORT
  1545. [HttpPost]
  1546. public IActionResult sysPushUssdDetailGetList([FromBody] dynamic sendData)
  1547. {
  1548. logger.Info("New request income sysPushUssdDetailGetList :" + sendData.ToString());
  1549. pushUssdDetailObjList response = new pushUssdDetailObjList();
  1550. response.responseCode = "-1";
  1551. response.responseMessage = "Err unknow";
  1552. try
  1553. {
  1554. var userObj = JObject.Parse(sendData.ToString());
  1555. string users = Convert.ToString(userObj["users"]);
  1556. string campaignId = Convert.ToString(userObj["campaignId"]);
  1557. string serviceId = Convert.ToString(userObj["serviceId"]);
  1558. string msisdn = Convert.ToString(userObj["msisdn"]);
  1559. string sendStatus = Convert.ToString(userObj["sendStatus"]);
  1560. string isSuccess = Convert.ToString(userObj["isSuccess"]);
  1561. string fromDate = Convert.ToString(userObj["fromDate"]);
  1562. string toDate = Convert.ToString(userObj["toDate"]);
  1563. string order = Convert.ToString(userObj["order"]);
  1564. string rowsOnPage = Convert.ToString(userObj["rowsOnPage"]);
  1565. string seqPage = Convert.ToString(userObj["seqPage"]);
  1566. if (string.IsNullOrEmpty(users)) users = "-1";
  1567. if (string.IsNullOrEmpty(campaignId)) campaignId = "-1";
  1568. if (string.IsNullOrEmpty(serviceId)) serviceId = "-1";
  1569. if (string.IsNullOrEmpty(msisdn)) msisdn = "-1";
  1570. if (string.IsNullOrEmpty(sendStatus)) sendStatus = "-1";
  1571. if (string.IsNullOrEmpty(isSuccess)) isSuccess = "-1";
  1572. if (string.IsNullOrEmpty(fromDate)) fromDate = "-1";
  1573. if (string.IsNullOrEmpty(toDate)) toDate = "-1";
  1574. if (string.IsNullOrEmpty(order)) order = "desc";
  1575. if (string.IsNullOrEmpty(rowsOnPage)) rowsOnPage = "100";
  1576. if (string.IsNullOrEmpty(seqPage)) seqPage = "1";
  1577. string token = Convert.ToString(userObj["token"]);
  1578. string channel = Convert.ToString(userObj["channel"]);
  1579. string language = Convert.ToString(userObj["language"]);
  1580. if (string.IsNullOrEmpty(language)) language = "-1";
  1581. string RedisIp = Common.GetValuesAppSetting("webConfig", "RedisIp");
  1582. string RedisPort = Common.GetValuesAppSetting("webConfig", "RedisPort");
  1583. string RedisPass = Common.GetValuesAppSetting("webConfig", "RedisPass");
  1584. var clientIp = HttpContext.Connection.RemoteIpAddress.ToString();
  1585. redisConnection _redis;
  1586. memoryCache.TryGetValue("redis", out _redis);
  1587. if (_redis == null)
  1588. {
  1589. var cacheExpiryOptions = new MemoryCacheEntryOptions
  1590. {
  1591. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  1592. Priority = CacheItemPriority.High,
  1593. SlidingExpiration = TimeSpan.FromMinutes(2),
  1594. Size = 1024,
  1595. };
  1596. _redis = new redisConnection(RedisIp, RedisPort, RedisPass);
  1597. _redis.connet();
  1598. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  1599. }
  1600. if (!_redis.isConnet())
  1601. {
  1602. if (!_redis.connet())
  1603. {
  1604. logger.Info("Connect to redis false");
  1605. response.responseCode = "-2";
  1606. response.responseMessage = "System Update";
  1607. logger.Info("sysPushUssdDetailGetList response : " + response.ToString());
  1608. return Ok(response);
  1609. }
  1610. else
  1611. {
  1612. var cacheExpiryOptions = new MemoryCacheEntryOptions
  1613. {
  1614. AbsoluteExpiration = DateTime.Now.AddMonths(12),
  1615. Priority = CacheItemPriority.High,
  1616. SlidingExpiration = TimeSpan.FromMinutes(2),
  1617. Size = 1024,
  1618. };
  1619. memoryCache.Set("redis", _redis, cacheExpiryOptions);
  1620. }
  1621. }
  1622. tokenObj _tokenObj = null;
  1623. if (!CommonFunction.checkToken(clientIp, token, channel, _redis, logger, out _tokenObj))
  1624. {
  1625. logger.Info("Authen token false");
  1626. response.responseCode = "35";
  1627. response.responseMessage = CommonObj.common.CommonFunction.getErrCodeObjFromRedis(_redis, channel, response.responseCode, language);
  1628. logger.Info("sysPushUssdDetailGetList response : " + response.ToString());
  1629. return Ok(response);
  1630. }
  1631. DataSet ds = systemDataAccess.SYS_PUSH_USSD_DETAIL_GET_LIST(users, campaignId, serviceId, msisdn, sendStatus, isSuccess, fromDate, toDate, order, rowsOnPage, seqPage);
  1632. logger.Info("Call database SYS_PUSH_USSD_DETAIL_GET_LIST success:");
  1633. response.responseCode = "0";
  1634. response.responseMessage = "Success";
  1635. if (ds != null && ds.Tables.Count > 0)
  1636. {
  1637. var dataTable = ds.Tables[0];
  1638. response.list = new pushUssdDetailObj[dataTable.Rows.Count];
  1639. for (int j = 0; j < dataTable.Rows.Count; j++)
  1640. {
  1641. var _obj = new pushUssdDetailObj();
  1642. _obj.id = dataTable.Rows[j]["ID"].ToString();
  1643. _obj.requestId = dataTable.Rows[j]["REQUEST_ID"].ToString();
  1644. _obj.campaignId = dataTable.Rows[j]["CAMPAIGN_ID"] != DBNull.Value ? dataTable.Rows[j]["CAMPAIGN_ID"].ToString() : "";
  1645. _obj.campaignName = dataTable.Rows[j].Table.Columns.Contains("CAMPAIGN_NAME") && dataTable.Rows[j]["CAMPAIGN_NAME"] != DBNull.Value ? dataTable.Rows[j]["CAMPAIGN_NAME"].ToString() : "";
  1646. _obj.serviceId = dataTable.Rows[j]["SERVICE_ID"] != DBNull.Value ? dataTable.Rows[j]["SERVICE_ID"].ToString() : "";
  1647. _obj.msisdn = dataTable.Rows[j]["MSISDN"].ToString();
  1648. _obj.sendTime = dataTable.Rows[j]["SEND_TIME"] != DBNull.Value ? Convert.ToDateTime(dataTable.Rows[j]["SEND_TIME"]).ToString("dd/MM/yyyy HH:mm:ss") : "";
  1649. _obj.sendStatus = dataTable.Rows[j]["SEND_STATUS"] != DBNull.Value ? dataTable.Rows[j]["SEND_STATUS"].ToString() : "";
  1650. _obj.totalStep = dataTable.Rows[j]["TOTAL_STEP"] != DBNull.Value ? dataTable.Rows[j]["TOTAL_STEP"].ToString() : "";
  1651. _obj.isStep1 = dataTable.Rows[j]["IS_STEP_1"] != DBNull.Value ? dataTable.Rows[j]["IS_STEP_1"].ToString() : "";
  1652. _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") : "";
  1653. _obj.isStep2 = dataTable.Rows[j]["IS_STEP_2"] != DBNull.Value ? dataTable.Rows[j]["IS_STEP_2"].ToString() : "";
  1654. _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") : "";
  1655. _obj.errorCode = dataTable.Rows[j]["ERROR_CODE"] != DBNull.Value ? dataTable.Rows[j]["ERROR_CODE"].ToString() : "";
  1656. _obj.isSuccess = dataTable.Rows[j]["IS_SUCCESS"] != DBNull.Value ? dataTable.Rows[j]["IS_SUCCESS"].ToString() : "";
  1657. _obj.insertTime = dataTable.Rows[j]["INSERT_TIME"] != DBNull.Value ? Convert.ToDateTime(dataTable.Rows[j]["INSERT_TIME"]).ToString("dd/MM/yyyy HH:mm:ss") : "";
  1658. _obj.lastUpdate = dataTable.Rows[j]["LAST_UPDATE"] != DBNull.Value ? Convert.ToDateTime(dataTable.Rows[j]["LAST_UPDATE"]).ToString("dd/MM/yyyy HH:mm:ss") : "";
  1659. _obj.msgContent = dataTable.Rows[j].Table.Columns.Contains("MSG_CONTENT") && dataTable.Rows[j]["MSG_CONTENT"] != DBNull.Value ? dataTable.Rows[j]["MSG_CONTENT"].ToString() : "";
  1660. response.list[j] = _obj;
  1661. }
  1662. }
  1663. }
  1664. catch (Exception ex)
  1665. {
  1666. logger.Info("exception: " + ex.ToString());
  1667. response.responseCode = "-2";
  1668. response.responseMessage = "System upgrade";
  1669. }
  1670. logger.Info("sysPushUssdDetailGetList response : " + response.ToString());
  1671. return Ok(response);
  1672. }
  1673. }
  1674. }