SpTradeRecordController.cs 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385
  1. /*
  2. * 交易记录
  3. */
  4. using System;
  5. using System.Web;
  6. using System.Collections.Generic;
  7. using System.Diagnostics;
  8. using System.Linq;
  9. using System.Threading.Tasks;
  10. using Microsoft.AspNetCore.Mvc;
  11. using Microsoft.AspNetCore.Http;
  12. using Microsoft.Extensions.Logging;
  13. using Microsoft.Extensions.Options;
  14. using MySystem.SpModels;
  15. using Library;
  16. using LitJson;
  17. using MySystemLib;
  18. namespace MySystem.Areas.Admin.Controllers
  19. {
  20. [Area("Admin")]
  21. [Route("Admin/[controller]/[action]")]
  22. public class SpTradeRecordController : BaseController
  23. {
  24. public SpTradeRecordController(IHttpContextAccessor accessor, ILogger<BaseController> logger, IOptions<Setting> setting) : base(accessor, logger, setting)
  25. {
  26. OtherMySqlConn.connstr = ConfigurationManager.AppSettings["SpSqlConnStr"].ToString();
  27. }
  28. #region 交易记录列表
  29. /// <summary>
  30. /// 根据条件查询交易记录列表
  31. /// </summary>
  32. /// <returns></returns>
  33. public IActionResult Index(TradeRecord data, string right)
  34. {
  35. ViewBag.RightInfo = RightInfo;
  36. ViewBag.right = right;
  37. return View();
  38. }
  39. #endregion
  40. #region 根据条件查询交易记录列表
  41. /// <summary>
  42. /// 交易记录列表
  43. /// </summary>
  44. /// <returns></returns>
  45. public JsonResult IndexData(TradeRecord data, string TradeStatusSelect, string ProductTypeSelect, string CreateDateData, int page = 1, int limit = 30)
  46. {
  47. Dictionary<string, string> Fields = new Dictionary<string, string>();
  48. Fields.Add("MerNo", "1"); //商户编号
  49. Fields.Add("MerSnNo", "1"); //机具号
  50. Fields.Add("ChannelSerial", "1"); //渠道流水号
  51. string condition = " and Status>-1";
  52. //交易状态
  53. if (!string.IsNullOrEmpty(TradeStatusSelect))
  54. {
  55. condition += " and TradeStatus=" + TradeStatusSelect;
  56. }
  57. //产品类型
  58. if (!string.IsNullOrEmpty(ProductTypeSelect))
  59. {
  60. condition += " and ProductType=" + ProductTypeSelect;
  61. }
  62. //创建时间
  63. if (!string.IsNullOrEmpty(CreateDateData))
  64. {
  65. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  66. string start = datelist[0];
  67. string end = datelist[1];
  68. condition += " and CreateDate>='" + start + " 00:00:00' and CreateDate<='" + end + " 23:59:59'";
  69. }
  70. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.SpTables).IndexData("TradeRecord", Fields, "Id desc", "0", page, limit, condition);
  71. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  72. foreach (Dictionary<string, object> dic in diclist)
  73. {
  74. //状态
  75. string Status = dic["Status"].ToString();
  76. if (Status == "1") dic["Status"] = "待同步";
  77. if (Status == "2") dic["Status"] = "已同步";
  78. if (Status == "") dic["Status"] = "";
  79. //交易状态
  80. string TradeStatus = dic["TradeStatus"].ToString();
  81. if (TradeStatus == "1") dic["TradeStatus"] = "成功";
  82. if (TradeStatus == "2") dic["TradeStatus"] = "失败";
  83. if (TradeStatus == "") dic["TradeStatus"] = "";
  84. //银行卡类型
  85. string BankCardType = dic["BankCardType"].ToString();
  86. if (BankCardType == "0001") dic["BankCardType"] = "贷记卡";
  87. if (BankCardType == "0002") dic["BankCardType"] = "借记卡";
  88. if (BankCardType == "") dic["BankCardType"] = "";
  89. //产品类型
  90. dic["ProductType"] = RelationClass.GetKqProductBrandList(dic["ProductType"].ToString());
  91. }
  92. return Json(obj);
  93. }
  94. #endregion
  95. #region 增加交易记录
  96. /// <summary>
  97. /// 增加或修改交易记录信息
  98. /// </summary>
  99. /// <returns></returns>
  100. public IActionResult Add(string right)
  101. {
  102. ViewBag.RightInfo = RightInfo;
  103. ViewBag.right = right;
  104. return View();
  105. }
  106. #endregion
  107. #region 增加交易记录
  108. /// <summary>
  109. /// 增加或修改交易记录信息
  110. /// </summary>
  111. /// <returns></returns>
  112. [HttpPost]
  113. public string Add(TradeRecord data)
  114. {
  115. Dictionary<string, object> Fields = new Dictionary<string, object>();
  116. Fields.Add("SeoTitle", data.SeoTitle);
  117. Fields.Add("SeoKeyword", data.SeoKeyword);
  118. Fields.Add("SeoDescription", data.SeoDescription);
  119. int Id = new AdminContentOther(_accessor.HttpContext, PublicFunction.SpTables).Add("TradeRecord", Fields, 0);
  120. AddSysLog(data.Id.ToString(), "TradeRecord", "add");
  121. spdb.SaveChanges();
  122. return "success";
  123. }
  124. #endregion
  125. #region 修改交易记录
  126. /// <summary>
  127. /// 增加或修改交易记录信息
  128. /// </summary>
  129. /// <returns></returns>
  130. public IActionResult Edit(string right, int Id = 0)
  131. {
  132. ViewBag.RightInfo = RightInfo;
  133. ViewBag.right = right;
  134. TradeRecord editData = spdb.TradeRecord.FirstOrDefault(m => m.Id == Id) ?? new TradeRecord();
  135. ViewBag.data = editData;
  136. return View();
  137. }
  138. #endregion
  139. #region 修改交易记录
  140. /// <summary>
  141. /// 增加或修改交易记录信息
  142. /// </summary>
  143. /// <returns></returns>
  144. [HttpPost]
  145. public string Edit(TradeRecord data)
  146. {
  147. Dictionary<string, object> Fields = new Dictionary<string, object>();
  148. Fields.Add("SeoTitle", data.SeoTitle);
  149. Fields.Add("SeoKeyword", data.SeoKeyword);
  150. Fields.Add("SeoDescription", data.SeoDescription);
  151. new AdminContentOther(_accessor.HttpContext, PublicFunction.SpTables).Edit("TradeRecord", Fields, data.Id);
  152. AddSysLog(data.Id.ToString(), "TradeRecord", "update");
  153. spdb.SaveChanges();
  154. return "success";
  155. }
  156. #endregion
  157. #region 删除交易记录信息
  158. /// <summary>
  159. /// 删除交易记录信息
  160. /// </summary>
  161. /// <returns></returns>
  162. public string Delete(string Id)
  163. {
  164. string[] idlist = Id.Split(new char[] { ',' });
  165. AddSysLog(Id, "TradeRecord", "del");
  166. foreach (string subid in idlist)
  167. {
  168. int id = int.Parse(subid);
  169. Dictionary<string, object> Fields = new Dictionary<string, object>();
  170. Fields.Add("Status", -1);
  171. new AdminContentOther(_accessor.HttpContext, PublicFunction.SpTables).Edit("TradeRecord", Fields, id);
  172. }
  173. spdb.SaveChanges();
  174. return "success";
  175. }
  176. #endregion
  177. #region 开启
  178. /// <summary>
  179. /// 开启
  180. /// </summary>
  181. /// <returns></returns>
  182. public string Open(string Id)
  183. {
  184. string[] idlist = Id.Split(new char[] { ',' });
  185. AddSysLog(Id, "TradeRecord", "open");
  186. foreach (string subid in idlist)
  187. {
  188. int id = int.Parse(subid);
  189. Dictionary<string, object> Fields = new Dictionary<string, object>();
  190. Fields.Add("Status", 1);
  191. new AdminContentOther(_accessor.HttpContext, PublicFunction.SpTables).Edit("TradeRecord", Fields, id);
  192. }
  193. spdb.SaveChanges();
  194. return "success";
  195. }
  196. #endregion
  197. #region 关闭
  198. /// <summary>
  199. /// 关闭
  200. /// </summary>
  201. /// <returns></returns>
  202. public string Close(string Id)
  203. {
  204. string[] idlist = Id.Split(new char[] { ',' });
  205. AddSysLog(Id, "TradeRecord", "close");
  206. foreach (string subid in idlist)
  207. {
  208. int id = int.Parse(subid);
  209. Dictionary<string, object> Fields = new Dictionary<string, object>();
  210. Fields.Add("Status", 0);
  211. new AdminContentOther(_accessor.HttpContext, PublicFunction.SpTables).Edit("TradeRecord", Fields, id);
  212. }
  213. spdb.SaveChanges();
  214. return "success";
  215. }
  216. #endregion
  217. #region 排序
  218. /// <summary>
  219. /// 排序
  220. /// </summary>
  221. /// <param name="Id"></param>
  222. public string Sort(int Id, int Sort)
  223. {
  224. new AdminContentOther(_accessor.HttpContext, PublicFunction.SpTables).Sort("TradeRecord", Sort, Id);
  225. AddSysLog(Id.ToString(), "TradeRecord", "sort");
  226. return "success";
  227. }
  228. #endregion
  229. #region 导入数据
  230. /// <summary>
  231. /// 导入数据
  232. /// </summary>
  233. /// <param name="ExcelData"></param>
  234. public string Import(string ExcelData)
  235. {
  236. ExcelData = HttpUtility.UrlDecode(ExcelData);
  237. JsonData list = JsonMapper.ToObject(ExcelData);
  238. for (int i = 1; i < list.Count; i++)
  239. {
  240. JsonData dr = list[i];
  241. spdb.TradeRecord.Add(new TradeRecord()
  242. {
  243. CreateDate = DateTime.Now,
  244. UpdateDate = DateTime.Now,
  245. });
  246. spdb.SaveChanges();
  247. }
  248. AddSysLog("0", "TradeRecord", "Import");
  249. return "success";
  250. }
  251. #endregion
  252. #region 导出Excel
  253. /// <summary>
  254. /// 导出Excel
  255. /// </summary>
  256. /// <returns></returns>
  257. public JsonResult ExportExcel(TradeRecord data, string TradeStatusSelect, string ProductTypeSelect)
  258. {
  259. Dictionary<string, string> Fields = new Dictionary<string, string>();
  260. Fields.Add("MerNo", "1"); //商户编号
  261. Fields.Add("ChannelSerial", "1"); //渠道流水号
  262. string condition = " and Status>-1";
  263. //交易状态
  264. if (!string.IsNullOrEmpty(TradeStatusSelect))
  265. {
  266. condition += " and TradeStatus=" + TradeStatusSelect;
  267. }
  268. //产品类型
  269. if (!string.IsNullOrEmpty(ProductTypeSelect))
  270. {
  271. condition += " and ProductType=" + ProductTypeSelect;
  272. }
  273. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.SpTables).IndexData("TradeRecord", Fields, "Id desc", "0", 1, 20000, condition, "TradeSerialNo,MerNo,TradeAmount,TradeStatus,TradeDate,TradeTime,BankCardType,BankCardNo,SettleFee,Remark,ProductType,AgentNo,ChannelSerial", false);
  274. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  275. foreach (Dictionary<string, object> dic in diclist)
  276. {
  277. //交易状态
  278. string TradeStatus = dic["TradeStatus"].ToString();
  279. if (TradeStatus == "1") dic["TradeStatus"] = "成功";
  280. if (TradeStatus == "2") dic["TradeStatus"] = "失败";
  281. if (TradeStatus == "") dic["TradeStatus"] = "";
  282. //银行卡类型
  283. string BankCardType = dic["BankCardType"].ToString();
  284. if (BankCardType == "0001") dic["BankCardType"] = "贷记卡";
  285. if (BankCardType == "0002") dic["BankCardType"] = "借记卡";
  286. if (BankCardType == "") dic["BankCardType"] = "";
  287. //产品类型
  288. string ProductType = dic["ProductType"].ToString();
  289. if (ProductType == "KYSPOS") dic["ProductType"] = "快益刷";
  290. if (ProductType == "KPOS") dic["ProductType"] = "快联盟大POS";
  291. if (ProductType == "SIGNPOS") dic["ProductType"] = "快联盟电签POS";
  292. if (ProductType == "SUPPOS") dic["ProductType"] = "超级Mpos";
  293. if (ProductType == "") dic["ProductType"] = "";
  294. }
  295. Dictionary<string, object> result = new Dictionary<string, object>();
  296. result.Add("Status", "1");
  297. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  298. result.Add("Obj", diclist);
  299. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  300. ReturnFields.Add("TradeSerialNo", "交易单号");
  301. ReturnFields.Add("MerNo", "商户编号");
  302. ReturnFields.Add("TradeAmount", "交易金额");
  303. ReturnFields.Add("TradeStatus", "交易状态");
  304. ReturnFields.Add("TradeDate", "交易日期");
  305. ReturnFields.Add("TradeTime", "交易时间");
  306. ReturnFields.Add("BankCardType", "银行卡类型");
  307. ReturnFields.Add("BankCardNo", "交易卡号");
  308. ReturnFields.Add("SettleFee", "出款手续费");
  309. ReturnFields.Add("Remark", "备注");
  310. ReturnFields.Add("ProductType", "产品类型");
  311. ReturnFields.Add("AgentNo", "代理商编号");
  312. ReturnFields.Add("ChannelSerial", "渠道流水号");
  313. result.Add("Fields", ReturnFields);
  314. AddSysLog("0", "TradeRecord", "ExportExcel");
  315. return Json(result);
  316. }
  317. #endregion
  318. }
  319. }