TradeFluxRecordController.cs 15 KB

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