UserSwapSummaryController.cs 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402
  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.Models;
  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 UserSwapSummaryController : BaseController
  23. {
  24. public UserSwapSummaryController(IHttpContextAccessor accessor, ILogger<BaseController> logger, IOptions<Setting> setting) : base(accessor, logger, setting)
  25. {
  26. OtherMySqlConn.connstr = ConfigurationManager.AppSettings["SqlConnStr"].ToString();
  27. }
  28. #region 创客循环返风控月汇总列表
  29. /// <summary>
  30. /// 根据条件查询创客循环返风控月汇总列表
  31. /// </summary>
  32. /// <returns></returns>
  33. public IActionResult Index(UserSwapSummary 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(UserSwapSummary data, string MakerCode, string RealName, string TopMakerCode, string TopRealName, string RiskStatusSelect, string TradeMonthSelect, int page = 1, int limit = 30)
  46. {
  47. Dictionary<string, string> Fields = new Dictionary<string, string>();
  48. Fields.Add("UpdateDate", "3"); //时间
  49. Fields.Add("BrandId", "0"); //品牌
  50. string condition = " and Status>-1";
  51. //创客编号
  52. if (!string.IsNullOrEmpty(MakerCode))
  53. {
  54. condition += " and UserId in (select UserId from UserForMakerCode where MakerCode='" + MakerCode + "')";
  55. }
  56. //创客名称
  57. if (!string.IsNullOrEmpty(RealName))
  58. {
  59. condition += " and UserId in (select UserId from UserForRealName where RealName='" + RealName + "')";
  60. }
  61. //顶级创客编号
  62. if (!string.IsNullOrEmpty(TopMakerCode))
  63. {
  64. condition += " and TopUserId in (select UserId from UserForMakerCode where MakerCode='" + TopMakerCode + "')";
  65. }
  66. //顶级创客名称
  67. if (!string.IsNullOrEmpty(TopRealName))
  68. {
  69. condition += " and TopUserId in (select UserId from UserForRealName where RealName='" + TopRealName + "')";
  70. }
  71. //循环风控降档状态
  72. if(!string.IsNullOrEmpty(RiskStatusSelect))
  73. {
  74. condition += " and RiskStatus=" + RiskStatusSelect;
  75. }
  76. //交易月份
  77. if(!string.IsNullOrEmpty(TradeMonthSelect))
  78. {
  79. condition += " and TradeMonth=" + TradeMonthSelect.Replace("-", "");
  80. }
  81. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("UserSwapSummary", Fields, "Id desc", "0", page, limit, condition);
  82. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  83. foreach (Dictionary<string, object> dic in diclist)
  84. {
  85. dic["BrandName"] = RelationClass.GetKqProductBrandInfo(int.Parse(dic["BrandId"].ToString()));
  86. dic["SwapExtProductTypes"] = RelationClass.GetKqProductBrandList(dic["SwapExtProductTypes"].ToString());
  87. int UserId = int.Parse(dic["UserId"].ToString());
  88. Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  89. dic["MakerCode"] = user.MakerCode;
  90. dic["RealName"] = user.RealName;
  91. int TopUserId = int.Parse(dic["TopUserId"].ToString());
  92. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopUserId) ?? new Users();
  93. dic["TopMakerCode"] = tuser.MakerCode;
  94. dic["TopRealName"] = tuser.RealName;
  95. int RiskStatus = int.Parse(dic["RiskStatus"].ToString());
  96. if(RiskStatus == 0) dic["RiskStatus"] = "降档";
  97. if(RiskStatus == 1) dic["RiskStatus"] = "不降档";
  98. }
  99. Dictionary<string, object> other = new Dictionary<string, object>();
  100. other.Add("DirectActMerCount", 0);
  101. other.Add("RiskCount", 0);
  102. obj.Add("other", other);
  103. return Json(obj);
  104. }
  105. #endregion
  106. #region 增加创客循环返风控月汇总
  107. /// <summary>
  108. /// 增加或修改创客循环返风控月汇总信息
  109. /// </summary>
  110. /// <returns></returns>
  111. public IActionResult Add(string right)
  112. {
  113. ViewBag.RightInfo = RightInfo;
  114. ViewBag.right = right;
  115. return View();
  116. }
  117. #endregion
  118. #region 增加创客循环返风控月汇总
  119. /// <summary>
  120. /// 增加或修改创客循环返风控月汇总信息
  121. /// </summary>
  122. /// <returns></returns>
  123. [HttpPost]
  124. public string Add(UserSwapSummary data)
  125. {
  126. Dictionary<string, object> Fields = new Dictionary<string, object>();
  127. Fields.Add("SeoTitle", data.SeoTitle);
  128. Fields.Add("SeoKeyword", data.SeoKeyword);
  129. Fields.Add("SeoDescription", data.SeoDescription);
  130. int Id = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Add("UserSwapSummary", Fields, 0);
  131. AddSysLog(data.Id.ToString(), "UserSwapSummary", "add");
  132. db.SaveChanges();
  133. return "success";
  134. }
  135. #endregion
  136. #region 修改创客循环返风控月汇总
  137. /// <summary>
  138. /// 增加或修改创客循环返风控月汇总信息
  139. /// </summary>
  140. /// <returns></returns>
  141. public IActionResult Edit(string right, int Id = 0)
  142. {
  143. ViewBag.RightInfo = RightInfo;
  144. ViewBag.right = right;
  145. UserSwapSummary editData = db.UserSwapSummary.FirstOrDefault(m => m.Id == Id) ?? new UserSwapSummary();
  146. ViewBag.data = editData;
  147. return View();
  148. }
  149. #endregion
  150. #region 修改创客循环返风控月汇总
  151. /// <summary>
  152. /// 增加或修改创客循环返风控月汇总信息
  153. /// </summary>
  154. /// <returns></returns>
  155. [HttpPost]
  156. public string Edit(UserSwapSummary data)
  157. {
  158. Dictionary<string, object> Fields = new Dictionary<string, object>();
  159. Fields.Add("SeoTitle", data.SeoTitle);
  160. Fields.Add("SeoKeyword", data.SeoKeyword);
  161. Fields.Add("SeoDescription", data.SeoDescription);
  162. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("UserSwapSummary", Fields, data.Id);
  163. AddSysLog(data.Id.ToString(), "UserSwapSummary", "update");
  164. db.SaveChanges();
  165. return "success";
  166. }
  167. #endregion
  168. #region 删除创客循环返风控月汇总信息
  169. /// <summary>
  170. /// 删除创客循环返风控月汇总信息
  171. /// </summary>
  172. /// <returns></returns>
  173. public string Delete(string Id)
  174. {
  175. string[] idlist = Id.Split(new char[] { ',' });
  176. AddSysLog(Id, "UserSwapSummary", "del");
  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.MainTables).Edit("UserSwapSummary", Fields, id);
  183. }
  184. db.SaveChanges();
  185. return "success";
  186. }
  187. #endregion
  188. #region 开启
  189. /// <summary>
  190. /// 开启
  191. /// </summary>
  192. /// <returns></returns>
  193. public string Open(string Id)
  194. {
  195. string[] idlist = Id.Split(new char[] { ',' });
  196. AddSysLog(Id, "UserSwapSummary", "open");
  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", 1);
  202. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("UserSwapSummary", Fields, id);
  203. }
  204. db.SaveChanges();
  205. return "success";
  206. }
  207. #endregion
  208. #region 关闭
  209. /// <summary>
  210. /// 关闭
  211. /// </summary>
  212. /// <returns></returns>
  213. public string Close(string Id)
  214. {
  215. string[] idlist = Id.Split(new char[] { ',' });
  216. AddSysLog(Id, "UserSwapSummary", "close");
  217. foreach (string subid in idlist)
  218. {
  219. int id = int.Parse(subid);
  220. Dictionary<string, object> Fields = new Dictionary<string, object>();
  221. Fields.Add("Status", 0);
  222. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("UserSwapSummary", Fields, id);
  223. }
  224. db.SaveChanges();
  225. return "success";
  226. }
  227. #endregion
  228. #region 排序
  229. /// <summary>
  230. /// 排序
  231. /// </summary>
  232. /// <param name="Id"></param>
  233. public string Sort(int Id, int Sort)
  234. {
  235. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Sort("UserSwapSummary", Sort, Id);
  236. AddSysLog(Id.ToString(), "UserSwapSummary", "sort");
  237. return "success";
  238. }
  239. #endregion
  240. #region 导入数据
  241. /// <summary>
  242. /// 导入数据
  243. /// </summary>
  244. /// <param name="ExcelData"></param>
  245. public string Import(string ExcelData)
  246. {
  247. ExcelData = HttpUtility.UrlDecode(ExcelData);
  248. JsonData list = JsonMapper.ToObject(ExcelData);
  249. for (int i = 1; i < list.Count; i++)
  250. {
  251. JsonData dr = list[i];
  252. db.UserSwapSummary.Add(new UserSwapSummary()
  253. {
  254. CreateDate = DateTime.Now,
  255. UpdateDate = DateTime.Now,
  256. });
  257. db.SaveChanges();
  258. }
  259. AddSysLog("0", "UserSwapSummary", "Import");
  260. return "success";
  261. }
  262. #endregion
  263. #region 导出Excel
  264. /// <summary>
  265. /// 导出Excel
  266. /// </summary>
  267. /// <returns></returns>
  268. public JsonResult ExportExcel(UserSwapSummary data, string MakerCode, string RealName, string TopMakerCode, string TopRealName, string RiskStatusSelect, string TradeMonthSelect)
  269. {
  270. Dictionary<string, string> Fields = new Dictionary<string, string>();
  271. Fields.Add("UpdateDate", "3"); //时间
  272. Fields.Add("BrandId", "0"); //品牌
  273. string condition = " and Status>-1";
  274. //创客编号
  275. if (!string.IsNullOrEmpty(MakerCode))
  276. {
  277. condition += " and UserId in (select UserId from UserForMakerCode where MakerCode='" + MakerCode + "')";
  278. }
  279. //创客名称
  280. if (!string.IsNullOrEmpty(RealName))
  281. {
  282. condition += " and UserId in (select UserId from UserForRealName where RealName='" + RealName + "')";
  283. }
  284. //顶级创客编号
  285. if (!string.IsNullOrEmpty(TopMakerCode))
  286. {
  287. condition += " and TopUserId in (select UserId from UserForMakerCode where MakerCode='" + TopMakerCode + "')";
  288. }
  289. //顶级创客名称
  290. if (!string.IsNullOrEmpty(TopRealName))
  291. {
  292. condition += " and TopUserId in (select UserId from UserForRealName where RealName='" + TopRealName + "')";
  293. }
  294. //循环风控降档状态
  295. if(!string.IsNullOrEmpty(RiskStatusSelect))
  296. {
  297. condition += " and RiskStatus=" + RiskStatusSelect;
  298. }
  299. //交易月份
  300. if(!string.IsNullOrEmpty(TradeMonthSelect))
  301. {
  302. condition += " and TradeMonth=" + TradeMonthSelect.Replace("-", "");
  303. }
  304. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("UserSwapSummary", Fields, "Id desc", "0", 1, 20000, condition, "UserId,TopUserId,TradeMonth,BrandId,DirectActMerCount,DirAvgTradeAmt,RiskStatus,SwapExtProductTypes", false);
  305. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  306. foreach (Dictionary<string, object> dic in diclist)
  307. {
  308. dic["BrandId"] = RelationClass.GetKqProductBrandInfo(int.Parse(dic["BrandId"].ToString()));
  309. dic["SwapExtProductTypes"] = RelationClass.GetKqProductBrandList(dic["SwapExtProductTypes"].ToString());
  310. int UserId = int.Parse(dic["UserId"].ToString());
  311. Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  312. dic["MakerCode"] = user.MakerCode;
  313. dic["RealName"] = user.RealName;
  314. int TopUserId = int.Parse(dic["TopUserId"].ToString());
  315. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopUserId) ?? new Users();
  316. dic["TopMakerCode"] = tuser.MakerCode;
  317. dic["TopRealName"] = tuser.RealName;
  318. int RiskStatus = int.Parse(dic["RiskStatus"].ToString());
  319. if(RiskStatus == 0) dic["RiskStatus"] = "降档";
  320. if(RiskStatus == 1) dic["RiskStatus"] = "不降档";
  321. dic.Remove("UserId");
  322. dic.Remove("TopUserId");
  323. }
  324. Dictionary<string, object> result = new Dictionary<string, object>();
  325. result.Add("Status", "1");
  326. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  327. result.Add("Obj", diclist);
  328. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  329. ReturnFields.Add("TradeMonth", "交易月份");
  330. ReturnFields.Add("MakerCode", "创客编号");
  331. ReturnFields.Add("RealName", "创客姓名");
  332. ReturnFields.Add("TopMakerCode", "顶级创客编号");
  333. ReturnFields.Add("TopRealName", "顶级创客名称");
  334. ReturnFields.Add("BrandId", "产品名称");
  335. ReturnFields.Add("DirectActMerCount", "上月新增数");
  336. ReturnFields.Add("DirAvgTradeAmt", "户均(元)");
  337. ReturnFields.Add("RiskStatus", "是否风控降档");
  338. ReturnFields.Add("SwapExtProductTypes", "可申请循环产品");
  339. result.Add("Fields", ReturnFields);
  340. AddSysLog("0", "UserSwapSummary", "ExportExcel");
  341. return Json(result);
  342. }
  343. #endregion
  344. }
  345. }