SpTradeRecordController.cs 14 KB

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