TradeFluxRecordController.cs 14 KB

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