DepositController.cs 3.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using Microsoft.AspNetCore.Mvc;
  5. using Microsoft.AspNetCore.Http;
  6. using Microsoft.Extensions.Logging;
  7. using Microsoft.Extensions.Options;
  8. using Microsoft.AspNetCore.Authorization;
  9. using System.Web;
  10. using MySystem.MainModels;
  11. using LitJson;
  12. using Library;
  13. using System.IO;
  14. using System.Text;
  15. namespace MySystem.Areas.Api.Controllers.v1
  16. {
  17. [Area("Api")]
  18. [Route("Api/[controller]/[action]")]
  19. public class DepositController : BaseController
  20. {
  21. public DepositController(IHttpContextAccessor accessor, ILogger<BaseController> logger, IOptions<Setting> setting) : base(accessor, logger, setting)
  22. {
  23. }
  24. #region 设置押金
  25. public Dictionary<string, object> Set()
  26. {
  27. Dictionary<string, object> result = new Dictionary<string, object>();
  28. try
  29. {
  30. StreamReader sr = new StreamReader(Request.Body);
  31. string requestMes = sr.ReadToEnd();
  32. JsonData json = JsonMapper.ToObject(requestMes);
  33. string value = AesDecrypt(json["content"].ToString(), "kvS4TIRh7Yulg4nr");
  34. JsonData data = JsonMapper.ToObject(value);
  35. string sn = data["sn"].ToString();
  36. string serviceFee = data["serviceFee"].ToString();
  37. WebCMSEntities db = new WebCMSEntities();
  38. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == sn);
  39. if(pos != null)
  40. {
  41. Dictionary<string, object> req = new Dictionary<string, object>();
  42. req.Add("PosSnId", pos.Id);
  43. req.Add("BrandId", 12);
  44. req.Add("Deposit", serviceFee);
  45. RedisDbconn.Instance.AddList("ChangePosFeeQueue", Newtonsoft.Json.JsonConvert.SerializeObject(req));
  46. result.Add("code", 0);
  47. result.Add("status", "success");
  48. result.Add("msg", "成功");
  49. }
  50. else
  51. {
  52. result.Add("code", 1);
  53. result.Add("status", "fail");
  54. result.Add("msg", "机具号不存在");
  55. }
  56. }
  57. catch(Exception ex)
  58. {
  59. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "设置押金异常");
  60. result.Add("code", 1);
  61. result.Add("status", "fail");
  62. result.Add("msg", "异常");
  63. }
  64. return result;
  65. }
  66. public string AesDecrypt(string str, string key)
  67. {
  68. if (string.IsNullOrEmpty(str)) return null;
  69. byte[] toEncryptArray = Convert.FromBase64String(str);
  70. System.Security.Cryptography.RijndaelManaged rm = new System.Security.Cryptography.RijndaelManaged
  71. {
  72. Key = Encoding.UTF8.GetBytes(key),
  73. Mode = System.Security.Cryptography.CipherMode.ECB,
  74. Padding = System.Security.Cryptography.PaddingMode.PKCS7,
  75. };
  76. System.Security.Cryptography.ICryptoTransform cTransform = rm.CreateDecryptor();
  77. byte[] resultArray = cTransform.TransformFinalBlock(toEncryptArray, 0, toEncryptArray.Length);
  78. return Encoding.UTF8.GetString(resultArray);
  79. }
  80. #endregion
  81. }
  82. }