UserAccountRecordController.cs 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723
  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.Data;
  10. using System.Threading.Tasks;
  11. using Microsoft.AspNetCore.Mvc;
  12. using Microsoft.AspNetCore.Http;
  13. using Microsoft.Extensions.Logging;
  14. using Microsoft.Extensions.Options;
  15. using MySystem.Models;
  16. using Library;
  17. using LitJson;
  18. using MySystemLib;
  19. namespace MySystem.Areas.Admin.Controllers
  20. {
  21. [Area("Admin")]
  22. [Route("Admin/[controller]/[action]")]
  23. public class UserAccountRecordController : BaseController
  24. {
  25. public UserAccountRecordController(IHttpContextAccessor accessor, ILogger<BaseController> logger, IOptions<Setting> setting) : base(accessor, logger, setting)
  26. {
  27. OtherMySqlConn.connstr = ConfigurationManager.AppSettings["SqlConnStr"].ToString();
  28. }
  29. #region 创客账户变动记录列表
  30. /// <summary>
  31. /// 根据条件查询创客账户变动记录列表
  32. /// </summary>
  33. /// <returns></returns>
  34. public IActionResult Index(UserAccountRecord data, string right, int UserId = 0)
  35. {
  36. ViewBag.RightInfo = RightInfo;
  37. ViewBag.right = right;
  38. ViewBag.UserId = UserId.ToString();
  39. List<Users> TopUsers = db.Users.Where(m => m.ParentUserId == 0).ToList();
  40. ViewBag.TopUsers = TopUsers;
  41. List<KqProducts> Brands = db.KqProducts.OrderBy(m => m.Id).ToList();
  42. ViewBag.Brands = Brands;
  43. return View();
  44. }
  45. #endregion
  46. #region 根据条件查询创客账户变动记录列表
  47. /// <summary>
  48. /// 创客账户变动记录列表
  49. /// </summary>
  50. /// <returns></returns>
  51. public JsonResult IndexData(UserAccountRecord data, string ChangeType, int ProductType, string TransRecordNo, string MakerCode, string RealName, int TopUserId, string CreateDateData, int UserId = 0, int page = 1, int limit = 30)
  52. {
  53. Dictionary<string, string> Fields = new Dictionary<string, string>();
  54. // Fields.Add("ChangeType", "1"); //交易类型
  55. // Fields.Add("ProductType", "1"); //产品类型
  56. // Fields.Add("TransRecordNo", "3"); //交易流水编号
  57. string condition = " and Status>-1";
  58. //创客编号
  59. if (!string.IsNullOrEmpty(MakerCode))
  60. {
  61. condition += " and UserId in (select UserId from UserForMakerCode where MakerCode='" + MakerCode + "')";
  62. }
  63. //创客名称
  64. if (!string.IsNullOrEmpty(RealName))
  65. {
  66. condition += " and UserId in (select UserId from UserForRealName where RealName='" + RealName + "')";
  67. }
  68. //顶级创客
  69. if (TopUserId > 0)
  70. {
  71. condition += " and UserId in (select Id from Users where ParentNav like '," + TopUserId + ",%')";
  72. }
  73. if (UserId > 0)
  74. {
  75. condition += " and UserId=" + UserId;
  76. }
  77. if (!string.IsNullOrEmpty(CreateDateData))
  78. {
  79. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  80. var start = Convert.ToDateTime(Convert.ToDateTime(datelist[0]).ToString("yyyy-MM-dd"));
  81. var end = Convert.ToDateTime(Convert.ToDateTime(datelist[1]).ToString("yyyy-MM-dd") + " 23:59:59");
  82. var check = db.UserAccountRecord.Any(m => m.CreateDate >= start);
  83. var checks = db.UserAccountRecord.Any(m => m.CreateDate <= end);
  84. if (check)
  85. {
  86. var sId = db.UserAccountRecord.Where(m => m.CreateDate >= start).Min(m => m.Id);
  87. condition += " and Id >=" + sId;
  88. }
  89. if (checks)
  90. {
  91. var eId = db.UserAccountRecord.Where(m => m.CreateDate <= end).Max(m => m.Id);
  92. condition += " and Id <=" + eId;
  93. }
  94. }
  95. else
  96. {
  97. var start = Convert.ToDateTime(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01");
  98. var check = db.UserAccountRecord.Any(m => m.CreateDate >= start);
  99. if (check)
  100. {
  101. var minId = db.UserAccountRecord.Where(m => m.CreateDate >= start).Min(m => m.Id);
  102. var Info = function.ReadInstance("/WritePage/UsersAccountRecord/UsersAccountRecord.txt");
  103. if (string.IsNullOrEmpty(Info.ToString()))
  104. {
  105. function.WritePage("/WritePage/UsersAccountRecord/", "UsersAccountRecord.txt", minId.ToString());
  106. condition += " and Id >=" + minId;
  107. }
  108. else
  109. {
  110. condition += " and Id >=" + Convert.ToInt32(Info);
  111. }
  112. }
  113. else
  114. {
  115. condition += " and Id =0";
  116. }
  117. }
  118. if (!string.IsNullOrEmpty(ChangeType))
  119. {
  120. if (int.Parse(ChangeType) > 0)
  121. {
  122. if (int.Parse(ChangeType) == 1)
  123. {
  124. condition += " and (ChangeType=" + int.Parse(ChangeType) + " or (ChangeType in(112,1) and ProductType=101))";
  125. }
  126. else if (int.Parse(ChangeType) == 112)
  127. {
  128. condition += " and ChangeType=112 and ProductType=0";
  129. }
  130. else
  131. {
  132. condition += " and ChangeType=" + int.Parse(ChangeType);
  133. }
  134. }
  135. if (int.Parse(ChangeType) == 0)
  136. {
  137. condition += " and ChangeType in(0,12)";
  138. }
  139. }
  140. if (ProductType > 0)
  141. {
  142. condition += " and ProductType=" + ProductType;
  143. }
  144. if (!string.IsNullOrEmpty(TransRecordNo))
  145. {
  146. condition += " and TransRecordNo='" + TransRecordNo + "'";
  147. }
  148. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("UserAccountRecord", Fields, "Id desc", "0", page, limit, condition);
  149. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  150. foreach (Dictionary<string, object> dic in diclist)
  151. {
  152. int UId = int.Parse(dic["UserId"].ToString());
  153. Users user = db.Users.FirstOrDefault(m => m.Id == UId) ?? new Users();
  154. dic["MakerCode"] = user.MakerCode;
  155. dic["RealName"] = user.RealName;
  156. if (!string.IsNullOrEmpty(user.ParentNav))
  157. {
  158. int TopId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  159. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopId) ?? new Users();
  160. dic["TopMakerCode"] = tuser.MakerCode;
  161. dic["TopRealName"] = tuser.RealName;
  162. }
  163. int ProductTypes = int.Parse(dic["ProductType"].ToString());
  164. dic["ProductTypeName"] = RelationClass.GetKqProductBrandInfo(ProductTypes);
  165. int ChangeTypes = int.Parse(dic["ChangeType"].ToString());
  166. dic["ChangeTypeName"] = RelationClassForConst.GetChangeTypeInfo(ChangeTypes);
  167. //获得盟主5元奖励的机具Sn
  168. int SnId = int.Parse(dic["QueryCount"].ToString());
  169. PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == SnId) ?? new PosMachinesTwo();
  170. dic["PosSn"] = pos.PosSn;
  171. }
  172. Dictionary<string, object> other = new Dictionary<string, object>();
  173. // string ChangeTypeAmount0 = "0.00", ChangeTypeAmount1 = "0.00", ChangeTypeAmount2 = "0.00", ChangeTypeAmount3 = "0.00", ChangeTypeAmount4 = "0.00", ChangeTypeAmount5 = "0.00", ChangeTypeAmount6 = "0.00", ChangeTypeAmount61 = "0.00", ChangeTypeAmount62 = "0.00", ChangeTypeAmount63 = "0.00", ChangeTypeAmount64 = "0.00", ChangeTypeAmount50 = "0.00", ChangeTypeAmount111 = "0.00", ChangeTypeAmount112 = "0.00", ChangeTypeAmount60 = "0.00", ChangeTypeAmount31 = "0.00", ChangeTypeAmount31s = "0.00", ChangeTypeAmount124 = "0.00", ChangeTypeAmount125 = "0.00";
  174. // DataTable dt = OtherMySqlConn.dtable("select sum(if(ChangeType=0, ChangeAmount, 0)),sum(if(ChangeType=1 and ProductType!=101, ChangeAmount, 0)) + sum(if(ChangeType in(112,1) and ProductType=101, ChangeAmount, 0)),sum(if(ChangeType=2, ChangeAmount, 0)),sum(if(ChangeType=6, ChangeAmount, 0)),sum(if(ChangeType=61, ChangeAmount, 0)),sum(if(ChangeType=62, ChangeAmount, 0)),sum(if(ChangeType=63, ChangeAmount, 0)),sum(if(ChangeType=64, ChangeAmount, 0)),sum(if(ChangeType=50, ChangeAmount, 0)),sum(if(ChangeType=111, ChangeAmount, 0)),sum(if(ChangeType=112 and ProductType!=101, ChangeAmount, 0)),sum(if(ChangeType=60, ChangeAmount, 0)),sum(if(ChangeType=31 and Remark='开机抢红包活动', ChangeAmount, 0)),sum(if(ChangeType=3, ChangeAmount, 0)),sum(if(ChangeType=4, ChangeAmount, 0)),sum(if(ChangeType=5, ChangeAmount, 0)),sum(if(ChangeType=124, ChangeAmount, 0)),sum(if(ChangeType=125, ChangeAmount, 0)),sum(if(ChangeType=31 and (Remark!='开机抢红包活动' or Remark IS NULL), ChangeAmount, 0)) from UserAccountRecord where 1=1" + condition);
  175. // if (dt.Rows.Count > 0)
  176. // {
  177. // ChangeTypeAmount0 = dt.Rows[0][0].ToString();
  178. // ChangeTypeAmount1 = dt.Rows[0][1].ToString();
  179. // ChangeTypeAmount2 = dt.Rows[0][2].ToString();
  180. // ChangeTypeAmount3 = dt.Rows[0][13].ToString();
  181. // ChangeTypeAmount4 = dt.Rows[0][14].ToString();
  182. // ChangeTypeAmount5 = dt.Rows[0][15].ToString();
  183. // ChangeTypeAmount6 = dt.Rows[0][3].ToString();
  184. // ChangeTypeAmount61 = dt.Rows[0][4].ToString();
  185. // ChangeTypeAmount62 = dt.Rows[0][5].ToString();
  186. // ChangeTypeAmount63 = dt.Rows[0][6].ToString();
  187. // ChangeTypeAmount64 = dt.Rows[0][7].ToString();
  188. // ChangeTypeAmount50 = dt.Rows[0][8].ToString();
  189. // ChangeTypeAmount111 = dt.Rows[0][9].ToString();
  190. // ChangeTypeAmount112 = dt.Rows[0][10].ToString();
  191. // ChangeTypeAmount60 = dt.Rows[0][11].ToString();
  192. // ChangeTypeAmount31 = dt.Rows[0][12].ToString();
  193. // ChangeTypeAmount124 = dt.Rows[0][16].ToString();
  194. // ChangeTypeAmount125 = dt.Rows[0][17].ToString();
  195. // ChangeTypeAmount31s = dt.Rows[0][18].ToString();
  196. // }
  197. // other.Add("ChangeTypeAmount0", ChangeTypeAmount0); //激活奖励
  198. // other.Add("ChangeTypeAmount1", ChangeTypeAmount1); //交易分润
  199. // other.Add("ChangeTypeAmount2", ChangeTypeAmount2); //提现申请
  200. // other.Add("ChangeTypeAmount3", ChangeTypeAmount3); //提现代付
  201. // other.Add("ChangeTypeAmount4", ChangeTypeAmount4); //提现手续费
  202. // other.Add("ChangeTypeAmount5", ChangeTypeAmount5); //提现税点扣除
  203. // other.Add("ChangeTypeAmount6", ChangeTypeAmount6); //提现失败,解冻
  204. // other.Add("ChangeTypeAmount61", ChangeTypeAmount61); //人工冻结
  205. // other.Add("ChangeTypeAmount62", ChangeTypeAmount62); //人工解冻
  206. // other.Add("ChangeTypeAmount63", ChangeTypeAmount63); //人工扣减
  207. // other.Add("ChangeTypeAmount64", ChangeTypeAmount64); //人工增加
  208. // other.Add("ChangeTypeAmount50", ChangeTypeAmount50); //开机奖励
  209. // other.Add("ChangeTypeAmount111", ChangeTypeAmount111); //分润补贴
  210. // other.Add("ChangeTypeAmount112", ChangeTypeAmount112); //推荐奖励
  211. // other.Add("ChangeTypeAmount60", ChangeTypeAmount60); //流量卡分佣
  212. // other.Add("ChangeTypeAmount31", ChangeTypeAmount31); //红包奖励
  213. // other.Add("ChangeTypeAmount31s", ChangeTypeAmount31s); //活动奖励
  214. // other.Add("ChangeTypeAmount124", ChangeTypeAmount124); //机具过期
  215. // other.Add("ChangeTypeAmount125", ChangeTypeAmount125); //软件服务费
  216. string ChangeTypeAmount0 = "0.00", ChangeTypeAmount1 = "0.00", ChangeTypeAmount2 = "0.00", ChangeTypeAmount3 = "0.00", ChangeTypeAmount4 = "0.00", ChangeTypeAmount5 = "0.00", ChangeTypeAmount6 = "0.00", ChangeTypeAmount12 = "0.00", ChangeTypeAmount20 = "0.00", ChangeTypeAmount31 = "0.00", ChangeTypeAmount50 = "0.00", ChangeTypeAmount60 = "0.00", ChangeTypeAmount61 = "0.00", ChangeTypeAmount62 = "0.00", ChangeTypeAmount63 = "0.00", ChangeTypeAmount64 = "0.00", ChangeTypeAmount111 = "0.00", ChangeTypeAmount112 = "0.00", ChangeTypeAmount114 = "0.00", ChangeTypeAmount115 = "0.00", ChangeTypeAmount116 = "0.00", ChangeTypeAmount119 = "0.00", ChangeTypeAmount121 = "0.00", ChangeTypeAmount122 = "0.00", ChangeTypeAmount123 = "0.00", ChangeTypeAmount118And120 = "0.00", ChangeTypeAmount124 = "0.00", ChangeTypeAmount125 = "0.00", ChangeTypeAmount126 = "0.00", ChangeTypeAmount127 = "0.00", ChangeTypeAmount202 = "0.00", ChangeTypeAmount30 = "0.00";
  217. DataTable dt = OtherMySqlConn.dtable("select sum(if(ChangeType=0, ChangeAmount, 0)) + sum(if(ChangeType=12, ChangeAmount, 0)),sum(if(ChangeType=1 and ProductType!=101, ChangeAmount, 0)) + sum(if(ChangeType in(112,1) and ProductType=101, ChangeAmount, 0)),sum(if(ChangeType=2, ChangeAmount, 0)),sum(if(ChangeType=3, ChangeAmount, 0)),sum(if(ChangeType=4, ChangeAmount, 0)),sum(if(ChangeType=5, ChangeAmount, 0)),sum(if(ChangeType=6, ChangeAmount, 0)),sum(if(ChangeType=12, ChangeAmount, 0)),sum(if(ChangeType=20, ChangeAmount, 0)),sum(if(ChangeType=31 and (Remark!='开机抢红包活动' or Remark IS NULL), ChangeAmount, 0)),sum(if(ChangeType=50, ChangeAmount, 0)),sum(if(ChangeType=60, ChangeAmount, 0)),sum(if(ChangeType=61, ChangeAmount, 0)),sum(if(ChangeType=62, ChangeAmount, 0)),sum(if(ChangeType=63, ChangeAmount, 0)),sum(if(ChangeType=64, ChangeAmount, 0)),sum(if(ChangeType=111, ChangeAmount, 0)),sum(if(ChangeType=112 and ProductType=0, ChangeAmount, 0)),sum(if(ChangeType=114, ChangeAmount, 0)),sum(if(ChangeType=115, ChangeAmount, 0)),sum(if(ChangeType=116, ChangeAmount, 0)),sum(if(ChangeType=119, ChangeAmount, 0)),sum(if(ChangeType=121, ChangeAmount, 0)),sum(if(ChangeType=122, ChangeAmount, 0)),sum(if(ChangeType=123, ChangeAmount, 0)),sum(if(ChangeType in(118,120), ChangeAmount, 0)),sum(if(ChangeType=124, ChangeAmount, 0)),sum(if(ChangeType=125, ChangeAmount, 0)),sum(if(ChangeType=126, ChangeAmount, 0)),sum(if(ChangeType=127, ChangeAmount, 0)),sum(if(ChangeType=202, ChangeAmount, 0)),sum(if(ChangeType=31 and Remark='开机抢红包活动', ChangeAmount, 0)) from UserAccountRecord where 1=1" + condition);
  218. if (dt.Rows.Count > 0)
  219. {
  220. ChangeTypeAmount0 = dt.Rows[0][0].ToString();
  221. ChangeTypeAmount1 = dt.Rows[0][1].ToString();
  222. ChangeTypeAmount2 = dt.Rows[0][2].ToString();
  223. ChangeTypeAmount3 = dt.Rows[0][3].ToString();
  224. ChangeTypeAmount4 = dt.Rows[0][4].ToString();
  225. ChangeTypeAmount5 = dt.Rows[0][5].ToString();
  226. ChangeTypeAmount6 = dt.Rows[0][6].ToString();
  227. ChangeTypeAmount12 = dt.Rows[0][7].ToString();
  228. ChangeTypeAmount20 = dt.Rows[0][8].ToString();
  229. ChangeTypeAmount31 = dt.Rows[0][9].ToString();
  230. ChangeTypeAmount50 = dt.Rows[0][10].ToString();
  231. ChangeTypeAmount60 = dt.Rows[0][11].ToString();
  232. ChangeTypeAmount61 = dt.Rows[0][12].ToString();
  233. ChangeTypeAmount62 = dt.Rows[0][13].ToString();
  234. ChangeTypeAmount63 = dt.Rows[0][14].ToString();
  235. ChangeTypeAmount64 = dt.Rows[0][15].ToString();
  236. ChangeTypeAmount111 = dt.Rows[0][16].ToString();
  237. ChangeTypeAmount112 = dt.Rows[0][17].ToString();
  238. ChangeTypeAmount114 = dt.Rows[0][18].ToString();
  239. ChangeTypeAmount115 = dt.Rows[0][19].ToString();
  240. ChangeTypeAmount116 = dt.Rows[0][20].ToString();
  241. ChangeTypeAmount119 = dt.Rows[0][21].ToString();
  242. ChangeTypeAmount121 = dt.Rows[0][22].ToString();
  243. ChangeTypeAmount122 = dt.Rows[0][23].ToString();
  244. ChangeTypeAmount123 = dt.Rows[0][24].ToString();
  245. ChangeTypeAmount118And120 = dt.Rows[0][25].ToString();
  246. ChangeTypeAmount124 = dt.Rows[0][26].ToString();
  247. ChangeTypeAmount125 = dt.Rows[0][27].ToString();
  248. ChangeTypeAmount126 = dt.Rows[0][28].ToString();
  249. ChangeTypeAmount127 = dt.Rows[0][29].ToString();
  250. ChangeTypeAmount202 = dt.Rows[0][30].ToString();
  251. ChangeTypeAmount30 = dt.Rows[0][31].ToString();
  252. }
  253. other.Add("ChangeTypeAmount0", ChangeTypeAmount0); //激活奖励
  254. other.Add("ChangeTypeAmount1", ChangeTypeAmount1); //交易分润
  255. other.Add("ChangeTypeAmount2", ChangeTypeAmount2); //提现申请
  256. other.Add("ChangeTypeAmount3", ChangeTypeAmount3); //提现代付
  257. other.Add("ChangeTypeAmount4", ChangeTypeAmount4); //提现手续费
  258. other.Add("ChangeTypeAmount5", ChangeTypeAmount5); //提现税点扣除
  259. other.Add("ChangeTypeAmount6", ChangeTypeAmount6); //提现失败,解冻
  260. other.Add("ChangeTypeAmount12", ChangeTypeAmount12); //交易奖励
  261. other.Add("ChangeTypeAmount20", ChangeTypeAmount20); //余额支付
  262. other.Add("ChangeTypeAmount31", ChangeTypeAmount31); //活动奖励
  263. other.Add("ChangeTypeAmount50", ChangeTypeAmount50); //开机奖励
  264. other.Add("ChangeTypeAmount60", ChangeTypeAmount60); //流量卡分佣
  265. other.Add("ChangeTypeAmount61", ChangeTypeAmount61); //人工冻结
  266. other.Add("ChangeTypeAmount62", ChangeTypeAmount62); //人工解冻
  267. other.Add("ChangeTypeAmount63", ChangeTypeAmount63); //系统扣减(人工扣减)
  268. other.Add("ChangeTypeAmount64", ChangeTypeAmount64); //系统奖励(人工增加)
  269. other.Add("ChangeTypeAmount111", ChangeTypeAmount111); //分润补贴
  270. other.Add("ChangeTypeAmount112", ChangeTypeAmount112); //推荐奖励
  271. other.Add("ChangeTypeAmount114", ChangeTypeAmount114); //私董会分红
  272. other.Add("ChangeTypeAmount115", ChangeTypeAmount115); //分仓奖励
  273. other.Add("ChangeTypeAmount116", ChangeTypeAmount116); //大盟主奖励
  274. other.Add("ChangeTypeAmount119", ChangeTypeAmount119); //分仓临时额度退还
  275. other.Add("ChangeTypeAmount121", ChangeTypeAmount121); //运营中心奖励
  276. other.Add("ChangeTypeAmount122", ChangeTypeAmount122); //推荐大盟主奖励
  277. other.Add("ChangeTypeAmount123", ChangeTypeAmount123); //推荐小盟主奖励
  278. other.Add("ChangeTypeAmount118And120", ChangeTypeAmount118And120); //购机奖励(118盟主奖励(购机奖励) 120运营中心(购机奖励))
  279. other.Add("ChangeTypeAmount124", ChangeTypeAmount124); //扣机具货款
  280. other.Add("ChangeTypeAmount125", ChangeTypeAmount125); //软件服务费
  281. other.Add("ChangeTypeAmount126", ChangeTypeAmount126); //机具货款退还
  282. other.Add("ChangeTypeAmount127", ChangeTypeAmount127); //运营中心分仓奖励
  283. other.Add("ChangeTypeAmount202", ChangeTypeAmount202); //创客预扣款
  284. other.Add("ChangeTypeAmount30", ChangeTypeAmount30); //红包奖励
  285. obj.Add("other", other);
  286. return Json(obj);
  287. }
  288. #endregion
  289. #region 增加创客账户变动记录
  290. /// <summary>
  291. /// 增加或修改创客账户变动记录信息
  292. /// </summary>
  293. /// <returns></returns>
  294. public IActionResult Add(string right)
  295. {
  296. ViewBag.RightInfo = RightInfo;
  297. ViewBag.right = right;
  298. return View();
  299. }
  300. #endregion
  301. #region 增加创客账户变动记录
  302. /// <summary>
  303. /// 增加或修改创客账户变动记录信息
  304. /// </summary>
  305. /// <returns></returns>
  306. [HttpPost]
  307. public string Add(UserAccountRecord data)
  308. {
  309. Dictionary<string, object> Fields = new Dictionary<string, object>();
  310. Fields.Add("SeoTitle", data.SeoTitle);
  311. Fields.Add("SeoKeyword", data.SeoKeyword);
  312. Fields.Add("SeoDescription", data.SeoDescription);
  313. int Id = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Add("UserAccountRecord", Fields, 0);
  314. AddSysLog(data.Id.ToString(), "UserAccountRecord", "add");
  315. db.SaveChanges();
  316. return "success";
  317. }
  318. #endregion
  319. #region 修改创客账户变动记录
  320. /// <summary>
  321. /// 增加或修改创客账户变动记录信息
  322. /// </summary>
  323. /// <returns></returns>
  324. public IActionResult Edit(string right, int Id = 0)
  325. {
  326. ViewBag.RightInfo = RightInfo;
  327. ViewBag.right = right;
  328. UserAccountRecord editData = db.UserAccountRecord.FirstOrDefault(m => m.Id == Id) ?? new UserAccountRecord();
  329. ViewBag.data = editData;
  330. return View();
  331. }
  332. #endregion
  333. #region 修改创客账户变动记录
  334. /// <summary>
  335. /// 增加或修改创客账户变动记录信息
  336. /// </summary>
  337. /// <returns></returns>
  338. [HttpPost]
  339. public string Edit(UserAccountRecord data)
  340. {
  341. Dictionary<string, object> Fields = new Dictionary<string, object>();
  342. Fields.Add("SeoTitle", data.SeoTitle);
  343. Fields.Add("SeoKeyword", data.SeoKeyword);
  344. Fields.Add("SeoDescription", data.SeoDescription);
  345. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("UserAccountRecord", Fields, data.Id);
  346. AddSysLog(data.Id.ToString(), "UserAccountRecord", "update");
  347. db.SaveChanges();
  348. return "success";
  349. }
  350. #endregion
  351. #region 删除创客账户变动记录信息
  352. /// <summary>
  353. /// 删除创客账户变动记录信息
  354. /// </summary>
  355. /// <returns></returns>
  356. public string Delete(string Id)
  357. {
  358. string[] idlist = Id.Split(new char[] { ',' });
  359. AddSysLog(Id, "UserAccountRecord", "del");
  360. foreach (string subid in idlist)
  361. {
  362. int id = int.Parse(subid);
  363. Dictionary<string, object> Fields = new Dictionary<string, object>();
  364. Fields.Add("Status", -1);
  365. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("UserAccountRecord", Fields, id);
  366. }
  367. db.SaveChanges();
  368. return "success";
  369. }
  370. #endregion
  371. #region 开启
  372. /// <summary>
  373. /// 开启
  374. /// </summary>
  375. /// <returns></returns>
  376. public string Open(string Id)
  377. {
  378. string[] idlist = Id.Split(new char[] { ',' });
  379. AddSysLog(Id, "UserAccountRecord", "open");
  380. foreach (string subid in idlist)
  381. {
  382. int id = int.Parse(subid);
  383. Dictionary<string, object> Fields = new Dictionary<string, object>();
  384. Fields.Add("Status", 1);
  385. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("UserAccountRecord", Fields, id);
  386. }
  387. db.SaveChanges();
  388. return "success";
  389. }
  390. #endregion
  391. #region 关闭
  392. /// <summary>
  393. /// 关闭
  394. /// </summary>
  395. /// <returns></returns>
  396. public string Close(string Id)
  397. {
  398. string[] idlist = Id.Split(new char[] { ',' });
  399. AddSysLog(Id, "UserAccountRecord", "close");
  400. foreach (string subid in idlist)
  401. {
  402. int id = int.Parse(subid);
  403. Dictionary<string, object> Fields = new Dictionary<string, object>();
  404. Fields.Add("Status", 0);
  405. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("UserAccountRecord", Fields, id);
  406. }
  407. db.SaveChanges();
  408. return "success";
  409. }
  410. #endregion
  411. #region 排序
  412. /// <summary>
  413. /// 排序
  414. /// </summary>
  415. /// <param name="Id"></param>
  416. public string Sort(int Id, int Sort)
  417. {
  418. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Sort("UserAccountRecord", Sort, Id);
  419. AddSysLog(Id.ToString(), "UserAccountRecord", "sort");
  420. return "success";
  421. }
  422. #endregion
  423. #region 导入数据
  424. /// <summary>
  425. /// 导入数据
  426. /// </summary>
  427. /// <param name="ExcelData"></param>
  428. public string Import(string ExcelData)
  429. {
  430. ExcelData = HttpUtility.UrlDecode(ExcelData);
  431. JsonData list = JsonMapper.ToObject(ExcelData);
  432. for (int i = 1; i < list.Count; i++)
  433. {
  434. JsonData dr = list[i];
  435. db.UserAccountRecord.Add(new UserAccountRecord()
  436. {
  437. CreateDate = DateTime.Now,
  438. UpdateDate = DateTime.Now,
  439. });
  440. db.SaveChanges();
  441. }
  442. AddSysLog("0", "UserAccountRecord", "Import");
  443. return "success";
  444. }
  445. #endregion
  446. #region 导出Excel
  447. /// <summary>
  448. /// 导出Excel
  449. /// </summary>
  450. /// <returns></returns>
  451. public JsonResult ExportExcel(UserAccountRecord data, string ChangeType, int ProductType, string TransRecordNo, string MakerCode, string RealName, string CreateDateData, int TopUserId, int UserId)
  452. {
  453. Dictionary<string, string> Fields = new Dictionary<string, string>();
  454. // Fields.Add("ChangeType", "1"); //交易类型
  455. // Fields.Add("ProductType", "1"); //产品类型
  456. // Fields.Add("TransRecordNo", "3"); //交易流水编号
  457. string condition = " and Status>-1";
  458. //创客编号
  459. if (!string.IsNullOrEmpty(MakerCode))
  460. {
  461. condition += " and UserId in (select UserId from UserForMakerCode where MakerCode='" + MakerCode + "')";
  462. }
  463. //创客名称
  464. if (!string.IsNullOrEmpty(RealName))
  465. {
  466. condition += " and UserId in (select UserId from UserForRealName where RealName='" + RealName + "')";
  467. }
  468. //顶级创客
  469. if (TopUserId > 0)
  470. {
  471. condition += " and UserId in (select Id from Users where ParentNav like '," + TopUserId + ",%')";
  472. }
  473. if (UserId > 0)
  474. {
  475. condition += " and UserId=" + UserId;
  476. }
  477. if (!string.IsNullOrEmpty(ChangeType))
  478. {
  479. if (int.Parse(ChangeType) > 0)
  480. {
  481. if (int.Parse(ChangeType) == 1)
  482. {
  483. condition += " and (ChangeType=" + int.Parse(ChangeType) + " or (ChangeType in(112,1) and ProductType=101))";
  484. }
  485. else if (int.Parse(ChangeType) == 112)
  486. {
  487. condition += " and ChangeType=112 and ProductType=0";
  488. }
  489. else
  490. {
  491. condition += " and ChangeType=" + int.Parse(ChangeType);
  492. }
  493. }
  494. if (int.Parse(ChangeType) == 0)
  495. {
  496. condition += " and ChangeType in(0,12)";
  497. }
  498. }
  499. if (ProductType > 0)
  500. {
  501. condition += " and ProductType=" + ProductType;
  502. }
  503. if (!string.IsNullOrEmpty(TransRecordNo))
  504. {
  505. condition += " and TransRecordNo='" + TransRecordNo + "'";
  506. }
  507. if (!string.IsNullOrEmpty(CreateDateData))
  508. {
  509. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  510. var start = Convert.ToDateTime(Convert.ToDateTime(datelist[0]).ToString("yyyy-MM-dd"));
  511. var end = Convert.ToDateTime(Convert.ToDateTime(datelist[1]).ToString("yyyy-MM-dd") + " 23:59:59");
  512. var check = db.UserAccountRecord.Any(m => m.CreateDate >= start);
  513. var checks = db.UserAccountRecord.Any(m => m.CreateDate <= end);
  514. if (check)
  515. {
  516. var sId = db.UserAccountRecord.Where(m => m.CreateDate >= start).Min(m => m.Id);
  517. condition += " and Id >=" + sId;
  518. }
  519. if (checks)
  520. {
  521. var eId = db.UserAccountRecord.Where(m => m.CreateDate <= end).Max(m => m.Id);
  522. condition += " and Id <=" + eId;
  523. }
  524. }
  525. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("UserAccountRecord", Fields, "Id desc", "0", 1, 20000, condition, "UserId,ProductType,TransRecordNo,ChangeType,ChangeAmount,Remark,BeforeTotalAmount,AfterTotalAmount,BeforeFreezeAmount,AfterFreezeAmount,BeforeBalanceAmount,AfterBalanceAmount,CreateDate", false);
  526. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  527. foreach (Dictionary<string, object> dic in diclist)
  528. {
  529. int UId = int.Parse(dic["UserId"].ToString());
  530. Users user = db.Users.FirstOrDefault(m => m.Id == UId) ?? new Users();
  531. dic["MakerCode"] = user.MakerCode;
  532. dic["RealName"] = user.RealName;
  533. if (!string.IsNullOrEmpty(user.ParentNav))
  534. {
  535. int TopId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  536. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopId) ?? new Users();
  537. dic["TopMakerCode"] = tuser.MakerCode;
  538. dic["TopRealName"] = tuser.RealName;
  539. }
  540. int ProductTypes = int.Parse(dic["ProductType"].ToString());
  541. dic["ProductTypeName"] = RelationClass.GetKqProductBrandInfo(ProductTypes);
  542. int ChangeTypes = int.Parse(dic["ChangeType"].ToString());
  543. string Remark = dic["Remark"].ToString();
  544. if (ChangeTypes == 31 && (Remark == "开机抢红包活动" || string.IsNullOrEmpty(Remark)))
  545. {
  546. dic["ChangeTypeName"] = "红包奖励";
  547. }
  548. else
  549. {
  550. dic["ChangeTypeName"] = RelationClassForConst.GetChangeTypeInfo(ChangeTypes);
  551. }
  552. dic.Remove("UserId");
  553. dic.Remove("ChangeType");
  554. dic.Remove("ProductType");
  555. }
  556. Dictionary<string, object> result = new Dictionary<string, object>();
  557. result.Add("Status", "1");
  558. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  559. result.Add("Obj", diclist);
  560. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  561. ReturnFields.Add("MakerCode", "创客编号");
  562. ReturnFields.Add("RealName", "创客姓名");
  563. ReturnFields.Add("TopMakerCode", "顶级创客编号");
  564. ReturnFields.Add("TopRealName", "顶级创客名称");
  565. ReturnFields.Add("ProductTypeName", "产品类型");
  566. ReturnFields.Add("TransRecordNo", "交易流水编号");
  567. ReturnFields.Add("ChangeTypeName", "交易类型");
  568. ReturnFields.Add("ChangeAmount", "交易金额");
  569. ReturnFields.Add("Remark", "备注");
  570. ReturnFields.Add("BeforeTotalAmount", "交易前总金额");
  571. ReturnFields.Add("AfterTotalAmount", "交易后总金额");
  572. ReturnFields.Add("BeforeFreezeAmount", "交易前冻结金额");
  573. ReturnFields.Add("AfterFreezeAmount", "交易后冻结金额");
  574. ReturnFields.Add("BeforeBalanceAmount", "交易前余额");
  575. ReturnFields.Add("AfterBalanceAmount", "交易后余额");
  576. ReturnFields.Add("CreateDate", "交易时间");
  577. result.Add("Fields", ReturnFields);
  578. AddSysLog("0", "UserAccountRecord", "ExportExcel");
  579. return Json(result);
  580. }
  581. #endregion
  582. #region 快捷导出Excel
  583. public IActionResult QuickExportExcel(string right)
  584. {
  585. ViewBag.RightInfo = RightInfo;
  586. ViewBag.right = right;
  587. return View();
  588. }
  589. [HttpPost]
  590. public string QuickExportExcelDo(int ChangeType, int ProductType, string TransRecordNo, string MakerCode, string RealName, string CreateDateData)
  591. {
  592. string SqlString = " and a.Status>-1";
  593. //创客编号
  594. if (!string.IsNullOrEmpty(MakerCode))
  595. {
  596. SqlString += " and a.UserId in (select UserId from UserForMakerCode where MakerCode='" + MakerCode + "')";
  597. }
  598. //创客名称
  599. if (!string.IsNullOrEmpty(RealName))
  600. {
  601. SqlString += " and a.UserId in (select UserId from UserForRealName where RealName='" + RealName + "')";
  602. }
  603. if (ChangeType > 0)
  604. {
  605. if (ChangeType == 1)
  606. {
  607. SqlString += " and (a.ChangeType=" + ChangeType + " or (a.ChangeType in(112,1) and a.ProductType=101))";
  608. }
  609. else if (ChangeType == 30)
  610. {
  611. SqlString += " and a.ChangeType=31 and a.Remark='开机抢红包活动'";
  612. }
  613. else if (ChangeType == 31)
  614. {
  615. SqlString += " and (a.ChangeType=" + ChangeType + " and (a.Remark!='开机抢红包活动' or a.Remark IS NULL))";
  616. }
  617. else
  618. {
  619. SqlString += " and a.ChangeType=" + ChangeType;
  620. }
  621. }
  622. if (ProductType > 0)
  623. {
  624. SqlString += " and a.ProductType=" + ProductType;
  625. }
  626. if (!string.IsNullOrEmpty(TransRecordNo))
  627. {
  628. SqlString += " and a.TransRecordNo='" + TransRecordNo + "'";
  629. }
  630. if (!string.IsNullOrEmpty(CreateDateData))
  631. {
  632. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  633. var start = Convert.ToDateTime(Convert.ToDateTime(datelist[0]).ToString("yyyy-MM-dd"));
  634. var end = Convert.ToDateTime(Convert.ToDateTime(datelist[1]).ToString("yyyy-MM-dd") + " 23:59:59");
  635. var check = db.UserAccountRecord.Any(m => m.CreateDate >= start);
  636. var checks = db.UserAccountRecord.Any(m => m.CreateDate <= end);
  637. if (check)
  638. {
  639. var sId = db.UserAccountRecord.Where(m => m.CreateDate >= start).Min(m => m.Id);
  640. SqlString += " and a.Id >=" + sId;
  641. }
  642. if (checks)
  643. {
  644. var eId = db.UserAccountRecord.Where(m => m.CreateDate <= end).Max(m => m.Id);
  645. SqlString += " and a.Id <=" + eId;
  646. }
  647. }
  648. var Sql = "SELECT e.MakerCode '创客编号',e.RealName '创客姓名',f.MakerCode '顶级创客编号',f.RealName '顶级创客名称',e.`Name` '产品类型',e.TransRecordNo '交易流水编号',e.ChangeTypeName '交易类型',e.ChangeAmount '交易金额',e.Remark '备注',e.BeforeTotalAmount '交易前总金额',e.AfterTotalAmount '交易后总金额',e.BeforeFreezeAmount '交易前冻结金额',e.AfterFreezeAmount '交易后冻结金额',e.BeforeBalanceAmount '交易前余额',e.AfterBalanceAmount '交易后余额',e.CreateDate '交易时间' FROM (SELECT b.MakerCode,b.RealName,SUBSTRING_INDEX(SUBSTRING_INDEX(b.ParentNav,',',4),',',-1) topId,c.`Name`,a.TransRecordNo,d.`Name` ChangeTypeName,a.ChangeAmount,a.Remark,a.BeforeTotalAmount,a.AfterTotalAmount,a.BeforeFreezeAmount,a.AfterFreezeAmount,a.BeforeBalanceAmount,a.AfterBalanceAmount,a.CreateDate FROM UserAccountRecord a LEFT JOIN Users b ON a.UserId=b.Id LEFT JOIN KqProducts c ON a.ProductType=c.Id LEFT JOIN ChangeTypes d ON a.ChangeType=d.Id WHERE 1=1 " + SqlString + ") e LEFT JOIN Users f ON e.topId=f.Id";
  649. var sysAdmin = bsdb.SysAdmin.FirstOrDefault(m => m.AdminName == SysUserName && m.Status > -1);
  650. var FileName = "创客账户变动记录" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  651. string SendData = "{\"Operater\":\"" + sysAdmin.Id + "\",\"SqlString\":\"" + Sql + "\",\"FileName\":\"" + FileName + "\",\"MaxCount\":\"0\"}";
  652. RedisDbconn.Instance.AddList("ExportQueue", SendData);
  653. return "success";
  654. }
  655. #endregion
  656. }
  657. }