UsersController.cs 79 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793
  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 UsersController : BaseController
  24. {
  25. public UsersController(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(Users data, string right, int SelfId = 0, int ParentId = 0, string MakerCode = "")
  35. {
  36. ViewBag.RightInfo = RightInfo;
  37. ViewBag.right = right;
  38. ViewBag.SelfId = SelfId.ToString();
  39. ViewBag.ParentId = ParentId.ToString();
  40. ViewBag.MakerCode = MakerCode;
  41. List<Users> TopUsers = db.Users.Where(m => m.ParentUserId == 0).ToList();
  42. ViewBag.TopUsers = TopUsers;
  43. List<UserLevelSet> Levels = db.UserLevelSet.OrderBy(m => m.Id).ToList();
  44. ViewBag.Levels = Levels;
  45. return View();
  46. }
  47. #endregion
  48. #region 根据条件查询创客列表
  49. /// <summary>
  50. /// 创客列表
  51. /// </summary>
  52. /// <returns></returns>
  53. public JsonResult IndexData(Users data, string ParentMakerCode, string ParentRealName, string AuthFlagSelect, string CreateDateData, int TopUserId, string RiskFlagSelect, string MerchantTypeSelect, int? sSettleAmount, int? eSettleAmount, int? sCashFreezeAmt, int? eCashFreezeAmt, int UserId, int SelfId = 0, int ParentId = 0, int ShowFlag = 0, int page = 1, int limit = 30)
  54. {
  55. Dictionary<string, string> Fields = new Dictionary<string, string>();
  56. Fields.Add("MakerCode", "1"); //创客编号
  57. Fields.Add("RealName", "1"); //创客名称
  58. Fields.Add("Mobile", "1"); //手机号
  59. Fields.Add("CertId", "1"); //身份证号码
  60. Fields.Add("SettleAmount", "3"); //结算金额
  61. Fields.Add("CashFreezeAmt", "3"); //冻结金额
  62. Fields.Add("UserLevel", "0"); //创客等级
  63. if (ShowFlag == 0)
  64. {
  65. Dictionary<string, object> objs = new Dictionary<string, object>();
  66. return Json(objs);
  67. }
  68. string condition = " and Status>-1";
  69. string sort = "Id desc";
  70. //直属创客编号
  71. if (!string.IsNullOrEmpty(ParentMakerCode))
  72. {
  73. condition += " and ParentUserId in (select UserId from UserForMakerCode where MakerCode='" + ParentMakerCode + "')";
  74. }
  75. //直属创客名称
  76. if (!string.IsNullOrEmpty(ParentRealName))
  77. {
  78. condition += " and ParentUserId in (select UserId from UserForRealName where RealName='" + ParentRealName + "')";
  79. }
  80. //实名状态
  81. if (!string.IsNullOrEmpty(AuthFlagSelect))
  82. {
  83. condition += " and AuthFlag=" + AuthFlagSelect;
  84. }
  85. //顶级创客
  86. if (TopUserId > 0)
  87. {
  88. condition += " and ParentNav like '," + TopUserId + ",%'";
  89. }
  90. //风控标识
  91. if (!string.IsNullOrEmpty(RiskFlagSelect))
  92. {
  93. condition += " and RiskFlag=" + RiskFlagSelect;
  94. }
  95. //商户创客类型
  96. if (!string.IsNullOrEmpty(MerchantTypeSelect))
  97. {
  98. condition += " and MerchantType=" + MerchantTypeSelect;
  99. }
  100. if (sSettleAmount != null)
  101. {
  102. condition += " and SettleAmount>=" + sSettleAmount.Value;
  103. }
  104. if (eSettleAmount != null)
  105. {
  106. condition += " and SettleAmount<=" + eSettleAmount.Value;
  107. }
  108. if (sCashFreezeAmt != null)
  109. {
  110. condition += " and CashFreezeAmt>=" + sCashFreezeAmt.Value;
  111. }
  112. if (eCashFreezeAmt != null)
  113. {
  114. condition += " and CashFreezeAmt<=" + eCashFreezeAmt.Value;
  115. }
  116. if (SelfId > 0)
  117. {
  118. Users self = db.Users.FirstOrDefault(m => m.Id == SelfId);
  119. if (self != null)
  120. {
  121. string ParentNav = function.CheckNull(self.ParentNav);
  122. condition += " and Id in (" + ParentNav.Trim(',').Replace(",,", ",") + ")";
  123. sort = "ParentNav asc";
  124. }
  125. }
  126. if (ParentId > 0)
  127. {
  128. condition += " and ParentUserId=" + ParentId;
  129. }
  130. if (UserId > 0)
  131. {
  132. condition += " and Id=" + UserId;
  133. }
  134. if (!string.IsNullOrEmpty(CreateDateData))
  135. {
  136. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  137. string start = datelist[0];
  138. string end = datelist[1];
  139. condition += " and CreateDate>='" + start + " 00:00:00' and CreateDate<='" + end + " 23:59:59'";
  140. }
  141. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, sort, "True", page, limit, condition);
  142. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  143. foreach (Dictionary<string, object> dic in diclist)
  144. {
  145. dic["AuthFlagName"] = dic["AuthFlag"].ToString() == "1" ? "已实名" : "未实名";
  146. dic["RiskFlagName"] = dic["RiskFlag"].ToString() == "1" ? "已风控" : "未风控";
  147. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  148. dic["MerchantType"] = RelationClassForConst.GetMerchantTypeInfo(int.Parse(dic["MerchantType"].ToString()));
  149. int ParentUserId = int.Parse(dic["ParentUserId"].ToString());
  150. Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
  151. dic["ParentMakerCode"] = puser.MakerCode;
  152. dic["ParentRealName"] = puser.RealName;
  153. string ParentNav = dic["ParentNav"].ToString();
  154. if (!string.IsNullOrEmpty(ParentNav))
  155. {
  156. string[] list = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  157. if (list.Length > 1)
  158. {
  159. int TopId = int.Parse(function.CheckInt(list[1]));
  160. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopId) ?? new Users();
  161. dic["TopMakerCode"] = tuser.MakerCode;
  162. dic["TopRealName"] = tuser.RealName;
  163. }
  164. }
  165. }
  166. return Json(obj);
  167. }
  168. #endregion
  169. #region 增加创客
  170. /// <summary>
  171. /// 增加或修改创客信息
  172. /// </summary>
  173. /// <returns></returns>
  174. public IActionResult Add(string right)
  175. {
  176. ViewBag.RightInfo = RightInfo;
  177. ViewBag.right = right;
  178. return View();
  179. }
  180. #endregion
  181. #region 增加创客
  182. /// <summary>
  183. /// 增加或修改创客信息
  184. /// </summary>
  185. /// <returns></returns>
  186. [HttpPost]
  187. public string Add(Users data, string ParentMakerCode)
  188. {
  189. bool check = db.UserForMobile.Any(m => m.Mobile == data.Mobile);
  190. if (check)
  191. {
  192. return "手机号已存在,请重新输入";
  193. }
  194. check = db.UserForRealName.Any(m => m.RealName == data.RealName);
  195. if (check)
  196. {
  197. return "姓名已存在,请重新输入";
  198. }
  199. if (!string.IsNullOrEmpty(data.MakerCode))
  200. {
  201. check = db.UserForMakerCode.Any(m => m.MakerCode == data.MakerCode);
  202. if (check)
  203. {
  204. return "创客编码已存在,请重新输入";
  205. }
  206. }
  207. Dictionary<string, object> Fields = new Dictionary<string, object>();
  208. Fields.Add("RealName", data.RealName); //真实姓名
  209. Fields.Add("CertId", data.CertId); //身份证号
  210. Fields.Add("Mobile", data.Mobile); //手机号
  211. Fields.Add("LoginPwd", function.MD532(data.LoginPwd)); //登录密码
  212. Fields.Add("SettleBankCardNo", data.SettleBankCardNo); //结算银行卡号
  213. if (!string.IsNullOrEmpty(ParentMakerCode))
  214. {
  215. UserForMakerCode userFor = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == ParentMakerCode) ?? new UserForMakerCode();
  216. Users puser = db.Users.FirstOrDefault(m => m.Id == userFor.UserId) ?? new Users();
  217. Fields.Add("ParentUserId", userFor.UserId);
  218. Fields.Add("ParentNav", puser.ParentNav + "," + userFor.UserId + ",");
  219. }
  220. int Id = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Add("Users", Fields, 0);
  221. if (string.IsNullOrEmpty(ParentMakerCode))
  222. {
  223. string MakerCode = Id.ToString();
  224. for (int i = 0; i < 7 - Id.ToString().Length; i++)
  225. {
  226. MakerCode = "0" + MakerCode;
  227. }
  228. MakerCode = "K" + MakerCode;
  229. Fields = new Dictionary<string, object>();
  230. Fields.Add("MakerCode", MakerCode); //编号
  231. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, Id);
  232. }
  233. db.UserDetail.Add(new UserDetail() { Id = Id });
  234. db.UserData.Add(new UserData() { UserId = Id });
  235. AddSysLog(data.Id.ToString(), "Users", "add");
  236. db.SaveChanges();
  237. return "success";
  238. }
  239. #endregion
  240. #region 修改创客
  241. /// <summary>
  242. /// 增加或修改创客信息
  243. /// </summary>
  244. /// <returns></returns>
  245. public IActionResult Edit(string right, int Id = 0)
  246. {
  247. ViewBag.RightInfo = RightInfo;
  248. ViewBag.right = right;
  249. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  250. ViewBag.data = editData;
  251. return View();
  252. }
  253. #endregion
  254. #region 修改创客
  255. /// <summary>
  256. /// 增加或修改创客信息
  257. /// </summary>
  258. /// <returns></returns>
  259. [HttpPost]
  260. public string Edit(Users data, UserDetail userdetail, UserData userdata)
  261. {
  262. Dictionary<string, object> Fields = new Dictionary<string, object>();
  263. Fields.Add("RealName", data.RealName); //真实姓名
  264. Fields.Add("CertId", data.CertId); //身份证号
  265. Fields.Add("Mobile", data.Mobile); //手机号
  266. Fields.Add("SettleBankName", data.SettleBankName); //结算银行名称
  267. Fields.Add("SettleBankCardNo", data.SettleBankCardNo); //结算银行卡号
  268. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, data.Id);
  269. AddSysLog(data.Id.ToString(), "Users", "update");
  270. db.SaveChanges();
  271. return "success";
  272. }
  273. #endregion
  274. #region 修改结算金额
  275. public IActionResult EditSettleAmount(string right, int Id = 0)
  276. {
  277. ViewBag.RightInfo = RightInfo;
  278. ViewBag.right = right;
  279. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  280. ViewBag.data = editData;
  281. return View();
  282. }
  283. #endregion
  284. #region 修改结算金额
  285. [HttpPost]
  286. public string EditSettleAmount(Users data)
  287. {
  288. Dictionary<string, object> Fields = new Dictionary<string, object>();
  289. Fields.Add("SettleAmount", data.SettleAmount);
  290. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, data.Id);
  291. AddSysLog(data.Id.ToString(), "Users", "EditSettleAmount");
  292. db.SaveChanges();
  293. return "success";
  294. }
  295. #endregion
  296. #region 修改账户金额
  297. public IActionResult EditCashFreezeAmt(string right, int Id = 0)
  298. {
  299. ViewBag.RightInfo = RightInfo;
  300. ViewBag.right = right;
  301. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  302. ViewBag.data = editData;
  303. return View();
  304. }
  305. #endregion
  306. #region 修改账户金额
  307. [HttpPost]
  308. public string EditCashFreezeAmt(Users data, string Note, int Kind)
  309. {
  310. int UserId = data.Id;
  311. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  312. if (account == null)
  313. {
  314. account = db.UserAccount.Add(new UserAccount()
  315. {
  316. Id = UserId,
  317. UserId = UserId,
  318. }).Entity;
  319. db.SaveChanges();
  320. }
  321. if ((Kind == 1 || Kind == 3) && data.CashFreezeAmt > account.BalanceAmount)
  322. {
  323. return "账号余额不足";
  324. }
  325. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  326. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  327. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  328. int ChangeType = 0;
  329. if (Kind == 1 && data.CashFreezeAmt <= account.BalanceAmount)
  330. {
  331. account.BalanceAmount -= data.CashFreezeAmt;
  332. account.FreezeAmount += data.CashFreezeAmt;
  333. ChangeType = 61;
  334. }
  335. else if (Kind == 1 && data.CashFreezeAmt > account.BalanceAmount)
  336. {
  337. return "冻结金额大于余额";
  338. }
  339. else if (Kind == 2 && data.CashFreezeAmt <= account.FreezeAmount)
  340. {
  341. account.BalanceAmount += data.CashFreezeAmt;
  342. account.FreezeAmount -= data.CashFreezeAmt;
  343. ChangeType = 62;
  344. }
  345. else if (Kind == 2 && data.CashFreezeAmt > account.FreezeAmount)
  346. {
  347. return "解冻金额大于冻结金额";
  348. }
  349. else if (Kind == 3 && data.CashFreezeAmt <= account.BalanceAmount)
  350. {
  351. account.TotalAmount -= data.CashFreezeAmt;
  352. account.BalanceAmount -= data.CashFreezeAmt;
  353. ChangeType = 63;
  354. }
  355. else if (Kind == 3 && data.CashFreezeAmt > account.BalanceAmount)
  356. {
  357. return "扣减金额大于余额";
  358. }
  359. else if (Kind == 4)
  360. {
  361. account.TotalAmount += data.CashFreezeAmt;
  362. account.BalanceAmount += data.CashFreezeAmt;
  363. ChangeType = 64;
  364. }
  365. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  366. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  367. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  368. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  369. {
  370. CreateDate = DateTime.Now,
  371. UpdateDate = DateTime.Now,
  372. UserId = UserId, //创客
  373. ChangeType = ChangeType, //变动类型
  374. ChangeAmount = data.CashFreezeAmt, //变更金额
  375. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  376. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  377. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  378. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  379. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  380. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  381. Remark = Note,
  382. }).Entity;
  383. db.SaveChanges();
  384. RedisDbconn.Instance.Set("UserAccount:" + UserId, account);
  385. AddSysLog(data.Id.ToString(), "Users", "EditCashFreezeAmt");
  386. db.SaveChanges();
  387. return "success";
  388. }
  389. #endregion
  390. #region 账户操作
  391. public IActionResult EditBalance(string right, int Id = 0)
  392. {
  393. ViewBag.RightInfo = RightInfo;
  394. ViewBag.right = right;
  395. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  396. ViewBag.data = editData;
  397. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == Id) ?? new UserAccount();
  398. ViewBag.account = account;
  399. return View();
  400. }
  401. #endregion
  402. #region 账户操作
  403. [HttpPost]
  404. public string EditBalance(UserAccount data)
  405. {
  406. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == data.Id);
  407. if (account != null)
  408. {
  409. decimal amount = data.BalanceAmount - account.BalanceAmount;
  410. if (amount != 0)
  411. {
  412. account.BalanceAmount += amount;
  413. account.TotalAmount += amount;
  414. AddSysLog(data.Id.ToString(), "UserAccount", "EditBalance");
  415. db.SaveChanges();
  416. }
  417. }
  418. return "success";
  419. }
  420. #endregion
  421. #region 详情
  422. public IActionResult Detail(string right, int Id = 0)
  423. {
  424. ViewBag.RightInfo = RightInfo;
  425. ViewBag.right = right;
  426. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  427. ViewBag.AuthDate = editData.AuthDate == null ? "" : editData.AuthDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
  428. string Age = "";
  429. if (!string.IsNullOrEmpty(editData.CertId))
  430. {
  431. int year = DateTime.Now.Year - int.Parse(editData.CertId.Substring(6, 4));
  432. Age = year.ToString();
  433. }
  434. ViewBag.Age = Age;
  435. ViewBag.QrCode = string.IsNullOrEmpty(editData.ReferenceQrCode) ? defaultImage : SourceHost + editData.ReferenceQrCode;
  436. return View();
  437. }
  438. #endregion
  439. #region 三/四要素验证
  440. public IActionResult ThreeElement(string right)
  441. {
  442. ViewBag.RightInfo = RightInfo;
  443. ViewBag.right = right;
  444. return View();
  445. }
  446. #endregion
  447. #region 三/四要素验证
  448. [HttpPost]
  449. public string ThreeElement(string Name, string CertId, string CardNo, string Mobile)
  450. {
  451. return "success";
  452. }
  453. #endregion
  454. #region 删除创客信息
  455. /// <summary>
  456. /// 删除创客信息
  457. /// </summary>
  458. /// <returns></returns>
  459. public string Delete(string Id)
  460. {
  461. string[] idlist = Id.Split(new char[] { ',' });
  462. AddSysLog(Id, "Users", "del");
  463. foreach (string subid in idlist)
  464. {
  465. int id = int.Parse(subid);
  466. Dictionary<string, object> Fields = new Dictionary<string, object>();
  467. Fields.Add("Status", -1);
  468. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  469. }
  470. db.SaveChanges();
  471. return "success";
  472. }
  473. #endregion
  474. #region 注销
  475. // 1、未实名创客;
  476. // 2、已实名创客,无开通商户;
  477. // 3、近7天未在商城下单过商品;
  478. // 4、名下无未绑定机具、机具券,无未申请的循环机;
  479. public string Cancel(string UserId)
  480. {
  481. Users user = db.Users.FirstOrDefault(m => m.Id == Convert.ToInt32(UserId));
  482. if (user != null)
  483. {
  484. if (user.AuthFlag == 1)
  485. {
  486. bool check = db.PosMachinesTwo.Any(m => m.BuyUserId == user.Id && m.BindingState == 1);
  487. if (check)
  488. {
  489. // return Json(new AppResultJson() { Status = "-1", Info = "注销失败,未满足条件:已实名创客,无开通商户。如有疑问,请联系客服" });
  490. return "注销失败,未满足条件:已实名创客,无开通商户。如有疑问,请联系客服";
  491. }
  492. DateTime checkDate = DateTime.Now.AddDays(-7);
  493. check = db.Orders.Any(m => m.CreateDate >= checkDate && m.Status > 0 && m.UserId == user.Id);
  494. if (check)
  495. {
  496. // return Json(new AppResultJson() { Status = "-1", Info = "注销失败,未满足条件:近7天未在商城下单过商品。如有疑问,请联系客服" });
  497. return "注销失败,未满足条件:近7天未在商城下单过商品。如有疑问,请联系客服";
  498. }
  499. check = db.PosMachinesTwo.Any(m => m.BuyUserId == user.Id && m.IsPurchase == 0);
  500. if (check)
  501. {
  502. // return Json(new AppResultJson() { Status = "-1", Info = "注销失败,未满足条件:名下无未绑定机具、机具券,无未申请的循环机。如有疑问,请联系客服" });
  503. return "注销失败,未满足条件:名下无未绑定机具、机具券,无未申请的循环机。如有疑问,请联系客服";
  504. }
  505. check = db.PosCoupons.Any(m => m.UserId == user.Id && m.IsUse == 0);
  506. if (check)
  507. {
  508. // return Json(new AppResultJson() { Status = "-1", Info = "注销失败,未满足条件:名下无未绑定机具、机具券,无未申请的循环机。如有疑问,请联系客服" });
  509. return "注销失败,未满足条件:名下无未绑定机具、机具券,无未申请的循环机。如有疑问,请联系客服";
  510. }
  511. }
  512. UserForMobile forMobile = db.UserForMobile.FirstOrDefault(m => m.Mobile == user.Mobile);
  513. if (forMobile != null)
  514. {
  515. db.UserForMobile.Remove(forMobile);
  516. }
  517. UserForMakerCode forCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == user.MakerCode);
  518. if (forCode != null)
  519. {
  520. db.UserForMakerCode.Remove(forCode);
  521. }
  522. user.Status = -1;
  523. user.Mobile += "d";
  524. user.CertId += "d";
  525. function.WriteLog(user.Id + "于" + DateTime.Now.ToString() + "注销账号", "创客注销日志");
  526. // TODO: 每月扫描一次注销的创客,把注销创客伞下创客全部挂到注销创客的上级
  527. // TODO: 清除token,token登录返回
  528. db.SaveChanges();
  529. }
  530. return "success";
  531. }
  532. #endregion
  533. #region 开启
  534. /// <summary>
  535. /// 开启
  536. /// </summary>
  537. /// <returns></returns>
  538. public string Open(string Id)
  539. {
  540. string[] idlist = Id.Split(new char[] { ',' });
  541. AddSysLog(Id, "Users", "open");
  542. foreach (string subid in idlist)
  543. {
  544. int id = int.Parse(subid);
  545. Dictionary<string, object> Fields = new Dictionary<string, object>();
  546. Fields.Add("Status", 1);
  547. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  548. }
  549. db.SaveChanges();
  550. return "success";
  551. }
  552. #endregion
  553. #region 关闭
  554. /// <summary>
  555. /// 关闭
  556. /// </summary>
  557. /// <returns></returns>
  558. public string Close(string Id)
  559. {
  560. string[] idlist = Id.Split(new char[] { ',' });
  561. AddSysLog(Id, "Users", "close");
  562. foreach (string subid in idlist)
  563. {
  564. int id = int.Parse(subid);
  565. Dictionary<string, object> Fields = new Dictionary<string, object>();
  566. Fields.Add("Status", 0);
  567. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  568. }
  569. db.SaveChanges();
  570. return "success";
  571. }
  572. #endregion
  573. #region 一键企业创客
  574. /// <summary>
  575. /// 一键企业创客
  576. /// </summary>
  577. /// <returns></returns>
  578. public string OpenEnterpriseMaker(string Id)
  579. {
  580. string[] idlist = Id.Split(new char[] { ',' });
  581. AddSysLog(Id, "Users", "OpenEnterpriseMaker");
  582. foreach (string subid in idlist)
  583. {
  584. int id = int.Parse(subid);
  585. Dictionary<string, object> Fields = new Dictionary<string, object>();
  586. Fields.Add("BusinessFlag", 1);
  587. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  588. }
  589. db.SaveChanges();
  590. return "success";
  591. }
  592. #endregion
  593. #region 关闭企业创客
  594. /// <summary>
  595. /// 关闭企业创客
  596. /// </summary>
  597. /// <returns></returns>
  598. public string CloseEnterpriseMaker(string Id)
  599. {
  600. string[] idlist = Id.Split(new char[] { ',' });
  601. AddSysLog(Id, "Users", "CloseEnterpriseMaker");
  602. foreach (string subid in idlist)
  603. {
  604. int id = int.Parse(subid);
  605. Dictionary<string, object> Fields = new Dictionary<string, object>();
  606. Fields.Add("BusinessFlag", 0);
  607. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  608. }
  609. db.SaveChanges();
  610. return "success";
  611. }
  612. #endregion
  613. #region 一键大盟主
  614. /// <summary>
  615. /// 一键大盟主
  616. /// </summary>
  617. /// <returns></returns>
  618. public string SetBigLeader(string Id)
  619. {
  620. string[] idlist = Id.Split(new char[] { ',' });
  621. AddSysLog(Id, "Users", "SetBigLeader");
  622. foreach (string subid in idlist)
  623. {
  624. int id = int.Parse(subid);
  625. Dictionary<string, object> Fields = new Dictionary<string, object>();
  626. Fields.Add("LeaderLevel", 2);
  627. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  628. }
  629. db.SaveChanges();
  630. return "success";
  631. }
  632. #endregion
  633. #region 一键小盟主
  634. /// <summary>
  635. /// 一键小盟主
  636. /// </summary>
  637. /// <returns></returns>
  638. public string SetSmallLeader(string Id)
  639. {
  640. string[] idlist = Id.Split(new char[] { ',' });
  641. AddSysLog(Id, "Users", "SetSmallLeader");
  642. foreach (string subid in idlist)
  643. {
  644. int id = int.Parse(subid);
  645. Dictionary<string, object> Fields = new Dictionary<string, object>();
  646. Fields.Add("LeaderLevel", 1);
  647. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  648. }
  649. db.SaveChanges();
  650. return "success";
  651. }
  652. #endregion
  653. #region 风控
  654. public IActionResult Risk(string right, int Id = 0)
  655. {
  656. ViewBag.RightInfo = RightInfo;
  657. ViewBag.right = right;
  658. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  659. ViewBag.data = editData;
  660. return View();
  661. }
  662. #endregion
  663. #region 风控
  664. [HttpPost]
  665. public string Risk(Users data)
  666. {
  667. Users user = db.Users.FirstOrDefault(m => m.Id == data.Id);
  668. if (user != null)
  669. {
  670. user.RiskFlag = data.RiskFlag;
  671. user.RiskRemark = data.RiskRemark;
  672. db.SaveChanges();
  673. }
  674. return "success";
  675. }
  676. #endregion
  677. #region 解除风控
  678. public string UnRisk(string Id)
  679. {
  680. string[] idlist = Id.Split(new char[] { ',' });
  681. AddSysLog(Id, "Users", "UnRisk");
  682. foreach (string subid in idlist)
  683. {
  684. int id = int.Parse(subid);
  685. Dictionary<string, object> Fields = new Dictionary<string, object>();
  686. Fields.Add("RiskFlag", 0);
  687. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  688. }
  689. db.SaveChanges();
  690. return "success";
  691. }
  692. #endregion
  693. #region 重置密码
  694. public string ResetPwd(int Id)
  695. {
  696. string NewPwd = function.get_Random(6);
  697. Dictionary<string, object> Fields = new Dictionary<string, object>();
  698. Fields.Add("LoginPwd", function.MD532(NewPwd));
  699. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, Id);
  700. AddSysLog(Id, "Users", "ResetPwd");
  701. return "success|" + NewPwd;
  702. }
  703. #endregion
  704. #region 排序
  705. /// <summary>
  706. /// 排序
  707. /// </summary>
  708. /// <param name="Id"></param>
  709. public string Sort(int Id, int Sort)
  710. {
  711. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Sort("Users", Sort, Id);
  712. AddSysLog(Id.ToString(), "Users", "sort");
  713. return "success";
  714. }
  715. #endregion
  716. #region 导入数据
  717. /// <summary>
  718. /// 导入数据
  719. /// </summary>
  720. /// <param name="ExcelData"></param>
  721. public string Import(string ExcelData, int Kind = 0)
  722. {
  723. ExcelData = HttpUtility.UrlDecode(ExcelData);
  724. JsonData list = JsonMapper.ToObject(ExcelData);
  725. if (Kind == 1)
  726. {
  727. for (int i = 1; i < list.Count; i++)
  728. {
  729. JsonData dr = list[i];
  730. string MakerCode = dr[0].ToString();
  731. string SettleAmount = dr[2].ToString();
  732. UserForMakerCode UserCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  733. if (UserCode != null)
  734. {
  735. Users User = db.Users.FirstOrDefault(m => m.Id == UserCode.UserId);
  736. if (User != null)
  737. {
  738. User.SettleAmount = decimal.Parse(function.CheckInt(SettleAmount));
  739. }
  740. }
  741. }
  742. db.SaveChanges();
  743. }
  744. else if (Kind == 2)
  745. {
  746. for (int i = 1; i < list.Count; i++)
  747. {
  748. JsonData dr = list[i];
  749. string MakerCode = dr[0].ToString();
  750. string CashFreezeAmt = dr[2].ToString();
  751. UserForMakerCode UserCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  752. if (UserCode != null)
  753. {
  754. Users User = db.Users.FirstOrDefault(m => m.Id == UserCode.UserId);
  755. if (User != null)
  756. {
  757. User.CashFreezeAmt = decimal.Parse(function.CheckInt(CashFreezeAmt));
  758. }
  759. }
  760. }
  761. db.SaveChanges();
  762. }
  763. else if (Kind == 3)
  764. {
  765. for (int i = 1; i < list.Count; i++)
  766. {
  767. JsonData dr = list[i];
  768. string MakerCode = dr[0].ToString();
  769. string RiskFlag = dr[2].ToString();
  770. string RiskNote = dr[3].ToString();
  771. UserForMakerCode UserCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  772. if (UserCode != null)
  773. {
  774. Users User = db.Users.FirstOrDefault(m => m.Id == UserCode.UserId);
  775. if (User != null)
  776. {
  777. User.RiskFlag = ulong.Parse(function.CheckInt(RiskFlag));
  778. User.RiskRemark = RiskNote;
  779. }
  780. }
  781. }
  782. db.SaveChanges();
  783. }
  784. else if (Kind == 4)
  785. {
  786. string error = "";
  787. for (int i = 1; i < list.Count; i++)
  788. {
  789. JsonData dr = list[i];
  790. string MakerCode = dr[0].ToString();
  791. string OperationAmt = dr[2].ToString();//操作金额
  792. string OperationType = dr[3].ToString();//操作类型
  793. UserForMakerCode UserCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  794. if (UserCode != null)
  795. {
  796. Users User = db.Users.FirstOrDefault(m => m.Id == UserCode.UserId);
  797. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == User.Id);
  798. if (account == null)
  799. {
  800. account = db.UserAccount.Add(new UserAccount()
  801. {
  802. Id = User.Id,
  803. UserId = User.Id,
  804. }).Entity;
  805. db.SaveChanges();
  806. }
  807. if (User != null)
  808. {
  809. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  810. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  811. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  812. int ChangeType = 0;
  813. if (OperationType == "1" && Convert.ToDecimal(OperationAmt) <= account.BalanceAmount)
  814. {
  815. account.BalanceAmount -= Convert.ToDecimal(OperationAmt);
  816. account.FreezeAmount += Convert.ToDecimal(OperationAmt);
  817. ChangeType = 61;
  818. }
  819. else if (OperationType == "1" && Convert.ToDecimal(OperationAmt) > account.BalanceAmount)
  820. {
  821. error += "以下操作失败" + User.MakerCode + ',' + User.RealName + "冻结金额大于余额" + '|' + '\n';
  822. }
  823. else if (OperationType == "2" && Convert.ToDecimal(OperationAmt) <= account.FreezeAmount)
  824. {
  825. account.BalanceAmount += Convert.ToDecimal(OperationAmt);
  826. account.FreezeAmount -= Convert.ToDecimal(OperationAmt);
  827. ChangeType = 62;
  828. }
  829. else if (OperationType == "2" && Convert.ToDecimal(OperationAmt) > account.FreezeAmount)
  830. {
  831. error += "以下操作失败" + User.MakerCode + ',' + User.RealName + "解冻金额大于冻结金额" + '|' + '\n';
  832. }
  833. else if (OperationType == "3" && Convert.ToDecimal(OperationAmt) <= account.BalanceAmount)
  834. {
  835. account.TotalAmount -= Convert.ToDecimal(OperationAmt);
  836. account.BalanceAmount -= Convert.ToDecimal(OperationAmt);
  837. ChangeType = 63;
  838. }
  839. else if (OperationType == "3" && Convert.ToDecimal(OperationAmt) > account.BalanceAmount)
  840. {
  841. error += "以下操作失败" + User.MakerCode + ',' + User.RealName + "扣减金额大于余额" + '|' + '\n';
  842. }
  843. else if (OperationType == "4")
  844. {
  845. account.TotalAmount += Convert.ToDecimal(OperationAmt);
  846. account.BalanceAmount += Convert.ToDecimal(OperationAmt);
  847. ChangeType = 64;
  848. }
  849. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  850. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  851. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  852. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  853. {
  854. CreateDate = DateTime.Now,
  855. UpdateDate = DateTime.Now,
  856. UserId = User.Id, //创客
  857. ChangeType = ChangeType, //变动类型
  858. ChangeAmount = Convert.ToDecimal(OperationAmt), //变更金额
  859. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  860. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  861. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  862. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  863. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  864. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  865. Remark = dr[4].ToString(),
  866. }).Entity;
  867. db.SaveChanges();
  868. AddSysLog(User.Id.ToString(), "Users", "ChangeCashFreezeAmts");
  869. db.SaveChanges();
  870. }
  871. }
  872. }
  873. db.SaveChanges();
  874. return "warning" + error;
  875. }
  876. AddSysLog("0", "Users", "Import");
  877. return "success";
  878. }
  879. #endregion
  880. #region 导出Excel
  881. /// <summary>
  882. /// 导出Excel
  883. /// </summary>
  884. /// <returns></returns>
  885. public JsonResult ExportExcel(Users data, string CreateDate, string ParentMakerCode, string ParentRealName, string AuthFlagSelect, int TopUserId, string RiskFlagSelect, string MerchantTypeSelect, int SelfId = 0, int ParentId = 0)
  886. {
  887. Dictionary<string, string> Fields = new Dictionary<string, string>();
  888. Fields.Add("MakerCode", "1"); //创客编号
  889. Fields.Add("RealName", "1"); //创客名称
  890. Fields.Add("Mobile", "1"); //手机号
  891. Fields.Add("CertId", "1"); //身份证号码
  892. Fields.Add("CreateDate", "3"); //注册时间
  893. Fields.Add("SettleAmount", "3"); //结算金额
  894. Fields.Add("CashFreezeAmt", "3"); //冻结金额
  895. Fields.Add("UserLevel", "0"); //创客等级
  896. string condition = " and Status>-1";
  897. //直属创客编号
  898. if (!string.IsNullOrEmpty(ParentMakerCode))
  899. {
  900. condition += " and Id in (select UserId from UserForMakerCode where MakerCode='" + ParentMakerCode + "')";
  901. }
  902. //直属创客名称
  903. if (!string.IsNullOrEmpty(ParentRealName))
  904. {
  905. condition += " and Id in (select UserId from UserForRealName where RealName='" + ParentRealName + "')";
  906. }
  907. //实名状态
  908. if (!string.IsNullOrEmpty(AuthFlagSelect))
  909. {
  910. condition += " and AuthFlag=" + AuthFlagSelect;
  911. }
  912. //顶级创客
  913. if (TopUserId > 0)
  914. {
  915. condition += " and ParentNav like '," + TopUserId + ",%'";
  916. }
  917. //风控标识
  918. if (!string.IsNullOrEmpty(RiskFlagSelect))
  919. {
  920. condition += " and RiskFlag=" + RiskFlagSelect;
  921. }
  922. //商户创客类型
  923. if (!string.IsNullOrEmpty(MerchantTypeSelect))
  924. {
  925. condition += " and MerchantType=" + MerchantTypeSelect;
  926. }
  927. if (SelfId > 0)
  928. {
  929. Users self = db.Users.FirstOrDefault(m => m.Id == SelfId);
  930. if (self != null)
  931. {
  932. string ParentNav = function.CheckNull(self.ParentNav);
  933. condition += " and Id in (" + ParentNav.Trim(',').Replace(",,", ",") + ")";
  934. }
  935. }
  936. if (ParentId > 0)
  937. {
  938. condition += " and ParentUserId=" + ParentId;
  939. }
  940. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, "Id desc", "True", 1, 20000, condition, "ParentUserId,ParentNav,UserLevel,SettleAmount,CashFreezeAmt,CertId,Mobile,MerchantType,MerchantDate,AuthFlag,RiskFlag,CreateDate", false);
  941. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  942. foreach (Dictionary<string, object> dic in diclist)
  943. {
  944. dic["AuthFlag"] = dic["AuthFlag"].ToString() == "1" ? "已实名" : "未实名";
  945. dic["RiskFlag"] = dic["RiskFlag"].ToString() == "1" ? "已风控" : "未风控";
  946. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  947. dic["MerchantType"] = RelationClassForConst.GetMerchantTypeInfo(int.Parse(dic["MerchantType"].ToString()));
  948. int ParentUserId = int.Parse(dic["ParentUserId"].ToString());
  949. Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
  950. dic["ParentMakerCode"] = puser.MakerCode;
  951. dic["ParentRealName"] = puser.RealName;
  952. string ParentNav = dic["ParentNav"].ToString();
  953. if (!string.IsNullOrEmpty(ParentNav))
  954. {
  955. string[] list = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  956. if (list.Length > 1)
  957. {
  958. int TopId = int.Parse(function.CheckInt(list[1]));
  959. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopId) ?? new Users();
  960. dic["TopMakerCode"] = tuser.MakerCode;
  961. dic["TopRealName"] = tuser.RealName;
  962. }
  963. }
  964. dic.Remove("ParentUserId");
  965. dic.Remove("ParentNav");
  966. }
  967. Dictionary<string, object> result = new Dictionary<string, object>();
  968. result.Add("Status", "1");
  969. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  970. result.Add("Obj", diclist);
  971. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  972. ReturnFields.Add("MakerCode", "创客编号");
  973. ReturnFields.Add("RealName", "创客姓名");
  974. ReturnFields.Add("UserLevel", "创客等级");
  975. ReturnFields.Add("SettleAmount", "提现金额(元)");
  976. ReturnFields.Add("CashFreezeAmt", "冻结金额(元)");
  977. ReturnFields.Add("CertId", "身份证号");
  978. ReturnFields.Add("Mobile", "联系手机");
  979. ReturnFields.Add("MerchantType", "商户创客类型");
  980. ReturnFields.Add("MerchantDate", "成为商户创客时间");
  981. ReturnFields.Add("ParentMakerCode", "直属创客编号");
  982. ReturnFields.Add("ParentRealName", "直属创客名称");
  983. ReturnFields.Add("TopMakerCode", "顶级创客编号");
  984. ReturnFields.Add("TopRealName", "顶级创客名称");
  985. ReturnFields.Add("AuthFlag", "实名状态");
  986. ReturnFields.Add("RiskFlag", "风控状态");
  987. ReturnFields.Add("CreateDate", "注册时间");
  988. result.Add("Fields", ReturnFields);
  989. AddSysLog("0", "Users", "ExportExcel");
  990. return Json(result);
  991. }
  992. #endregion
  993. #region 直属创客导出Excel
  994. /// <summary>
  995. /// 直属创客导出Excel
  996. /// </summary>
  997. /// <returns></returns>
  998. public JsonResult ExportZSExcel(Users data, string MakerCode, string ParentMakerCode)
  999. {
  1000. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1001. string condition = " and Status>-1";
  1002. //创客编号
  1003. if (!string.IsNullOrEmpty(MakerCode))
  1004. {
  1005. condition += " and ParentUserId in (select UserId from UserForMakerCode where MakerCode='" + MakerCode + "')";
  1006. }
  1007. //直属创客编号
  1008. if (!string.IsNullOrEmpty(ParentMakerCode))
  1009. {
  1010. condition += " and ParentUserId in (select UserId from UserForMakerCode where MakerCode='" + ParentMakerCode + "')";
  1011. }
  1012. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, "Id desc", "True", 1, 20000, condition, "Id,MakerCode,RealName,UserLevel", false);
  1013. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1014. foreach (Dictionary<string, object> dic in diclist)
  1015. {
  1016. int Id = int.Parse(dic["Id"].ToString());
  1017. Users userZS = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  1018. dic["MakerCode"] = userZS.MakerCode;
  1019. dic["RealName"] = userZS.RealName;
  1020. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  1021. }
  1022. Dictionary<string, object> result = new Dictionary<string, object>();
  1023. result.Add("Status", "1");
  1024. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1025. result.Add("Obj", diclist);
  1026. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  1027. ReturnFields.Add("Id", "Id");
  1028. ReturnFields.Add("MakerCode", "创客编号");
  1029. ReturnFields.Add("RealName", "创客姓名");
  1030. ReturnFields.Add("UserLevel", "创客等级");
  1031. result.Add("Fields", ReturnFields);
  1032. AddSysLog("0", "Users", "ExportZSExcel");
  1033. return Json(result);
  1034. }
  1035. #endregion
  1036. #region 上级创客导出Excel
  1037. /// <summary>
  1038. /// 上级创客导出Excel
  1039. /// </summary>
  1040. /// <returns></returns>
  1041. public JsonResult ExportSJExcel(Users data, string MakerCode, string ParentMakerCode)
  1042. {
  1043. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1044. string condition = " and Status>-1";
  1045. //创客编号
  1046. if (!string.IsNullOrEmpty(MakerCode))
  1047. {
  1048. var query = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  1049. Users self = db.Users.FirstOrDefault(m => m.Id == query.UserId);
  1050. if (self != null)
  1051. {
  1052. string ParentNav = function.CheckNull(self.ParentNav);
  1053. condition += " and Id in (" + ParentNav.Trim(',').Replace(",,", ",") + ")";
  1054. }
  1055. }
  1056. //直属创客编号
  1057. if (!string.IsNullOrEmpty(ParentMakerCode))
  1058. {
  1059. var query = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == ParentMakerCode);
  1060. Users self = db.Users.FirstOrDefault(m => m.Id == query.UserId);
  1061. if (self != null)
  1062. {
  1063. string ParentNav = function.CheckNull(self.ParentNav);
  1064. condition += " and Id in (" + ParentNav.Trim(',').Replace(",,", ",") + ")";
  1065. }
  1066. }
  1067. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, "Id desc", "True", 1, 20000, condition, "Id,MakerCode,RealName,UserLevel", false);
  1068. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1069. foreach (Dictionary<string, object> dic in diclist)
  1070. {
  1071. int Id = int.Parse(dic["Id"].ToString());
  1072. Users userSJ = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  1073. dic["MakerCode"] = userSJ.MakerCode;
  1074. dic["RealName"] = userSJ.RealName;
  1075. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  1076. }
  1077. Dictionary<string, object> result = new Dictionary<string, object>();
  1078. result.Add("Status", "1");
  1079. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1080. result.Add("Obj", diclist);
  1081. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  1082. ReturnFields.Add("Id", "Id");
  1083. ReturnFields.Add("MakerCode", "创客编号");
  1084. ReturnFields.Add("RealName", "创客姓名");
  1085. ReturnFields.Add("UserLevel", "创客等级");
  1086. result.Add("Fields", ReturnFields);
  1087. AddSysLog("0", "Users", "ExportExcel");
  1088. return Json(result);
  1089. }
  1090. #endregion
  1091. #region 同步数据
  1092. /// <summary>
  1093. /// 同步数据
  1094. /// </summary>
  1095. /// <returns></returns>
  1096. public string SycnData(int Id = 0)
  1097. {
  1098. var Brands = db.KqProducts.Where(m => m.Status == 1).ToList();
  1099. foreach (var Brand in Brands)
  1100. {
  1101. PublicFunction.SycnMachineCount(Id, Brand.Id);
  1102. }
  1103. AddSysLog(Id, "Users", "SycnData");
  1104. db.SaveChanges();
  1105. return "success";
  1106. }
  1107. #endregion
  1108. #region 同步交易额
  1109. public IActionResult SycnTradeAmount(string right, int Id = 0)
  1110. {
  1111. ViewBag.RightInfo = RightInfo;
  1112. ViewBag.right = right;
  1113. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  1114. ViewBag.data = editData;
  1115. return View();
  1116. }
  1117. #endregion
  1118. #region 同步交易额
  1119. [HttpPost]
  1120. public string SycnTradeAmountDo(DateTime sdate, DateTime edate, int UserId, int BrandId)
  1121. {
  1122. if (sdate.AddMonths(1) < edate)
  1123. {
  1124. return "时间间隔不能超过1个月";
  1125. }
  1126. if (edate >= DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00"))
  1127. {
  1128. return "结束时间只能是今天之前";
  1129. }
  1130. string check = RedisDbconn.Instance.Get<string>("ResetUserTradeQueue:" + UserId + ":" + BrandId);
  1131. if (!string.IsNullOrEmpty(check))
  1132. {
  1133. return "请稍后再试";
  1134. }
  1135. try
  1136. {
  1137. RedisDbconn.Instance.AddList("ResetUserTradeQueue", UserId + "#cut#" + sdate.ToString("yyyy-MM-dd HH:mm:ss") + "#cut#" + edate.ToString("yyyy-MM-dd HH:mm:ss") + "#cut#" + BrandId);
  1138. RedisDbconn.Instance.Set("ResetUserTradeQueue:" + UserId + ":" + BrandId, "wait");
  1139. RedisDbconn.Instance.SetExpire("ResetUserTradeQueue:" + UserId + ":" + BrandId, 3600);
  1140. }
  1141. catch (Exception ex)
  1142. {
  1143. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计创客的交易额异常");
  1144. return "同步异常";
  1145. }
  1146. return "success";
  1147. }
  1148. #endregion
  1149. #region 创客展业城市
  1150. public IActionResult City(Users data, string right)
  1151. {
  1152. ViewBag.RightInfo = RightInfo;
  1153. ViewBag.right = right;
  1154. List<Users> TopUsers = db.Users.Where(m => m.ParentUserId == 0).ToList();
  1155. ViewBag.TopUsers = TopUsers;
  1156. return View();
  1157. }
  1158. #endregion
  1159. #region 根据条件查询创客展业城市
  1160. public JsonResult CityData(Users data, string ParentMakerCode, string ParentRealName, int TopUserId, string Areas, int page = 1, int limit = 30)
  1161. {
  1162. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1163. Fields.Add("MakerCode", "1"); //创客编号
  1164. Fields.Add("RealName", "1"); //创客名称
  1165. Fields.Add("CitySetDate", "3"); //创建时间
  1166. Fields.Add("Areas", "2"); //省市
  1167. string condition = " and Status>-1";
  1168. //直属创客编号
  1169. if (!string.IsNullOrEmpty(ParentMakerCode))
  1170. {
  1171. condition += " and Id in (select UserId from UserForMakerCode where MakerCode='" + ParentMakerCode + "')";
  1172. }
  1173. //直属创客名称
  1174. if (!string.IsNullOrEmpty(ParentRealName))
  1175. {
  1176. condition += " and Id in (select UserId from UserForRealName where RealName='" + ParentRealName + "')";
  1177. }
  1178. //顶级创客
  1179. if (TopUserId > 0)
  1180. {
  1181. condition += " and ParentNav like '," + TopUserId + ",%'";
  1182. }
  1183. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, "Id desc", "True", page, limit, condition);
  1184. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1185. foreach (Dictionary<string, object> dic in diclist)
  1186. {
  1187. int ParentUserId = int.Parse(dic["ParentUserId"].ToString());
  1188. Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
  1189. dic["ParentMakerCode"] = puser.MakerCode;
  1190. dic["ParentRealName"] = puser.RealName;
  1191. string ParentNav = dic["ParentNav"].ToString();
  1192. if (!string.IsNullOrEmpty(ParentNav))
  1193. {
  1194. int TopId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  1195. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopId) ?? new Users();
  1196. dic["TopMakerCode"] = tuser.MakerCode;
  1197. dic["TopRealName"] = tuser.RealName;
  1198. }
  1199. }
  1200. return Json(obj);
  1201. }
  1202. #endregion
  1203. #region 导出展业城市
  1204. public JsonResult ExportCity(Users data, string CreateDate, string ParentMakerCode, string ParentRealName, string AuthFlagSelect, int TopUserId, string RiskFlagSelect, string MerchantTypeSelect)
  1205. {
  1206. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1207. Fields.Add("MakerCode", "1"); //创客编号
  1208. Fields.Add("RealName", "1"); //创客名称
  1209. Fields.Add("Mobile", "1"); //手机号
  1210. Fields.Add("CertId", "1"); //身份证号码
  1211. Fields.Add("CreateDate", "3"); //注册时间
  1212. Fields.Add("SettleAmount", "3"); //结算金额
  1213. Fields.Add("CashFreezeAmt", "3"); //冻结金额
  1214. Fields.Add("UserLevel", "0"); //创客等级
  1215. string condition = " and Status>-1";
  1216. //直属创客编号
  1217. if (!string.IsNullOrEmpty(ParentMakerCode))
  1218. {
  1219. condition += " and Id in (select UserId from UserForMakerCode where MakerCode='" + ParentMakerCode + "')";
  1220. }
  1221. //直属创客名称
  1222. if (!string.IsNullOrEmpty(ParentRealName))
  1223. {
  1224. condition += " and Id in (select UserId from UserForRealName where RealName='" + ParentRealName + "')";
  1225. }
  1226. //实名状态
  1227. if (!string.IsNullOrEmpty(AuthFlagSelect))
  1228. {
  1229. condition += " and AuthFlag=" + AuthFlagSelect;
  1230. }
  1231. //顶级创客
  1232. if (TopUserId > 0)
  1233. {
  1234. condition += " and ParentNav like '," + TopUserId + ",%'";
  1235. }
  1236. //风控标识
  1237. if (!string.IsNullOrEmpty(RiskFlagSelect))
  1238. {
  1239. condition += " and RiskFlag=" + RiskFlagSelect;
  1240. }
  1241. //商户创客类型
  1242. if (!string.IsNullOrEmpty(MerchantTypeSelect))
  1243. {
  1244. condition += " and MerchantType=" + MerchantTypeSelect;
  1245. }
  1246. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, "Id desc", "True", 1, 20000, condition, "ParentUserId,ParentNav,UserLevel,SettleAmount,CashFreezeAmt,CertId,Mobile,MerchantType,MerchantDate,AuthFlag,RiskFlag,CreateDate", false);
  1247. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1248. foreach (Dictionary<string, object> dic in diclist)
  1249. {
  1250. dic["AuthFlag"] = dic["AuthFlag"].ToString() == "1" ? "已实名" : "未实名";
  1251. dic["RiskFlag"] = dic["RiskFlag"].ToString() == "1" ? "已风控" : "未风控";
  1252. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  1253. dic["MerchantType"] = RelationClassForConst.GetMerchantTypeInfo(int.Parse(dic["MerchantType"].ToString()));
  1254. int ParentUserId = int.Parse(dic["ParentUserId"].ToString());
  1255. Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
  1256. dic["ParentMakerCode"] = puser.MakerCode;
  1257. dic["ParentRealName"] = puser.RealName;
  1258. string ParentNav = dic["ParentNav"].ToString();
  1259. if (!string.IsNullOrEmpty(ParentNav))
  1260. {
  1261. int TopId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  1262. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopId) ?? new Users();
  1263. dic["TopMakerCode"] = tuser.MakerCode;
  1264. dic["TopRealName"] = tuser.RealName;
  1265. }
  1266. dic.Remove("ParentUserId");
  1267. dic.Remove("ParentNav");
  1268. }
  1269. Dictionary<string, object> result = new Dictionary<string, object>();
  1270. result.Add("Status", "1");
  1271. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1272. result.Add("Obj", diclist);
  1273. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  1274. ReturnFields.Add("MakerCode", "创客编号");
  1275. ReturnFields.Add("RealName", "创客姓名");
  1276. ReturnFields.Add("UserLevel", "创客等级");
  1277. ReturnFields.Add("SettleAmount", "提现金额(元)");
  1278. ReturnFields.Add("CashFreezeAmt", "冻结金额(元)");
  1279. ReturnFields.Add("CertId", "身份证号");
  1280. ReturnFields.Add("Mobile", "联系手机");
  1281. ReturnFields.Add("MerchantType", "商户创客类型");
  1282. ReturnFields.Add("MerchantDate", "成为商户创客时间");
  1283. ReturnFields.Add("ParentMakerCode", "直属创客编号");
  1284. ReturnFields.Add("ParentRealName", "直属创客名称");
  1285. ReturnFields.Add("TopMakerCode", "顶级创客编号");
  1286. ReturnFields.Add("TopRealName", "顶级创客名称");
  1287. ReturnFields.Add("AuthFlag", "实名状态");
  1288. ReturnFields.Add("RiskFlag", "风控状态");
  1289. ReturnFields.Add("CreateDate", "注册时间");
  1290. result.Add("Fields", ReturnFields);
  1291. AddSysLog("0", "Users", "ExportExcel");
  1292. return Json(result);
  1293. }
  1294. #endregion
  1295. #region 根据条件查询直属创客交易额列表
  1296. /// <summary>
  1297. /// 直属创客交易额列表
  1298. /// </summary>
  1299. /// <returns></returns>
  1300. public IActionResult Children(Users data, string right, int ParentId = 0, string MakerCode = "")
  1301. {
  1302. ViewBag.RightInfo = RightInfo;
  1303. ViewBag.right = right;
  1304. ViewBag.ParentId = ParentId.ToString();
  1305. ViewBag.MakerCode = MakerCode;
  1306. List<Users> TopUsers = db.Users.Where(m => m.ParentUserId == 0).ToList();
  1307. ViewBag.TopUsers = TopUsers;
  1308. List<UserLevelSet> Levels = db.UserLevelSet.OrderBy(m => m.Id).ToList();
  1309. ViewBag.Levels = Levels;
  1310. List<KqProducts> Brands = db.KqProducts.OrderBy(m => m.Id).ToList();
  1311. ViewBag.Brands = Brands;
  1312. return View();
  1313. }
  1314. #endregion
  1315. #region 根据条件查询直属创客交易额列表
  1316. /// <summary>
  1317. /// 直属创客交易额列表
  1318. /// </summary>
  1319. /// <returns></returns>
  1320. public JsonResult ChildrenData(Users data, int BrandSelect, string MakerCode, string CreateDateData, int ParentId = 0, int page = 1, int limit = 30)
  1321. {
  1322. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1323. WebCMSEntities db = new WebCMSEntities();
  1324. Fields.Add("MakerCode", "1"); //创客编号
  1325. int BrandId = BrandSelect;
  1326. string start = "";
  1327. string end = "";
  1328. string condition = " and Status>-1 and AuthFlag >0";
  1329. string con = " and Status>-1";
  1330. string cons = " and Status>=-1";
  1331. string sort = "Id desc";
  1332. //创客编号
  1333. if (!string.IsNullOrEmpty(MakerCode))
  1334. {
  1335. condition += " and Id in (select UserId from UserForMakerCode where MakerCode='" + MakerCode + "')";
  1336. }
  1337. if (ParentId > 0)
  1338. {
  1339. condition += " and ParentUserId=" + ParentId + " or Id=" + ParentId;
  1340. }
  1341. //时间不为空
  1342. if (!string.IsNullOrEmpty(CreateDateData))
  1343. {
  1344. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  1345. start = datelist[0].Replace("-", "");
  1346. end = datelist[1].Replace("-", "");
  1347. con += " and TradeDate>='" + start + "' and TradeDate<='" + end + "'";
  1348. cons += " and SeoKeyword >=" + start + " and SeoKeyword <=" + end;
  1349. }
  1350. //时间为空
  1351. else
  1352. {
  1353. start = DateTime.Now.ToString("yyyyMM") + "01";
  1354. end = DateTime.Now.AddMonths(1).ToString("yyyyMM") + "01";
  1355. con += " and TradeDate>='" + start + "' and TradeDate<'" + end + "'";
  1356. cons += " and SeoKeyword >=" + start + " and SeoKeyword <" + end;
  1357. }
  1358. if (!string.IsNullOrEmpty(BrandSelect.ToString()) && BrandId > 0)
  1359. {
  1360. con += " and BrandId='" + BrandId + "'";
  1361. cons += " and BrandId='" + BrandId + "'";
  1362. }
  1363. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, sort, "True", page, limit, condition);
  1364. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1365. foreach (Dictionary<string, object> dic in diclist)
  1366. {
  1367. int UId = int.Parse(dic["Id"].ToString());
  1368. var Info = GetMonthTradeForBrand(UId, start, end, BrandId);
  1369. dic["TotalAmtfc"] = Convert.ToDecimal(Info["TotalAmtfc"].ToString()) + Convert.ToDecimal(Info["YAmtfc"].ToString());
  1370. dic["DAmtfc"] = Convert.ToDecimal(Info["DAmtfc"].ToString());
  1371. dic["JAmtfc"] = Convert.ToDecimal(Info["JAmtfc"].ToString());
  1372. dic["JfAmtfc"] = Convert.ToDecimal(Info["JfAmtfc"].ToString());
  1373. dic["JCountfc"] = Convert.ToInt32(Info["JCountfc"].ToString());
  1374. dic["YAmtfc"] = Convert.ToDecimal(Info["YAmtfc"].ToString());
  1375. dic["TotalAmtwd"] = Convert.ToDecimal(Info["TotalAmtwd"].ToString()) + Convert.ToDecimal(Info["YAmtwd"].ToString());
  1376. dic["DAmtwd"] = Convert.ToDecimal(Info["DAmtwd"].ToString());
  1377. dic["JAmtwd"] = Convert.ToDecimal(Info["JAmtwd"].ToString());
  1378. dic["JfAmtwd"] = Convert.ToDecimal(Info["JfAmtwd"].ToString());
  1379. dic["JCountwd"] = Convert.ToInt32(Info["JCountwd"].ToString());
  1380. dic["YAmtwd"] = Convert.ToDecimal(Info["YAmtwd"].ToString());
  1381. dic["TBCount"] = Info["TBCount"].ToString();
  1382. dic["TACount"] = Info["TACount"].ToString();
  1383. // dic["BCount"] = Info["BCount"].ToString();
  1384. // dic["ACount"] = Info["ACount"].ToString();
  1385. }
  1386. //个人
  1387. //扶持期
  1388. decimal TotalAmtfc = 0;
  1389. decimal DAmtfc = 0;
  1390. decimal JAmtfc = 0;
  1391. decimal JfAmtfc = 0;
  1392. int JCountfc = 0;
  1393. decimal YAmtfc = 0;
  1394. //稳定期
  1395. decimal TotalAmtwd = 0;
  1396. decimal DAmtwd = 0;
  1397. decimal JAmtwd = 0;
  1398. decimal JfAmtwd = 0;
  1399. int JCountwd = 0;
  1400. decimal YAmtwd = 0;
  1401. //团队
  1402. //扶持期
  1403. decimal TotalAmtfc1 = 0;
  1404. decimal DAmtfc1 = 0;
  1405. decimal JAmtfc1 = 0;
  1406. decimal JfAmtfc1 = 0;
  1407. int JCountfc1 = 0;
  1408. decimal YAmtfc1 = 0;
  1409. //稳定期
  1410. decimal TotalAmtwd1 = 0;
  1411. decimal DAmtwd1 = 0;
  1412. decimal JAmtwd1 = 0;
  1413. decimal JfAmtwd1 = 0;
  1414. int JCountwd1 = 0;
  1415. decimal YAmtwd1 = 0;
  1416. int PBCount = 0;
  1417. int PACount = 0;
  1418. int TBCount = 0;
  1419. int TACount = 0;
  1420. Dictionary<string, object> other = new Dictionary<string, object>();
  1421. DataTable dt = OtherMySqlConn.dtable("SELECT Sum(HelpDirectTradeAmt + HelpDirectDebitTradeAmt),Sum(if (QueryCount = 0,HelpDirectTradeAmt,0)),Sum(if (QueryCount = 0,HelpDirectDebitTradeAmt - HelpDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,HelpDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,HelpDirectDebitCapNum,0)),Sum(if (QueryCount = 1,HelpDirectTradeAmt,0)),Sum(NotHelpDirectTradeAmt + NotHelpDirectDebitTradeAmt),Sum(if (QueryCount = 0,NotHelpDirectTradeAmt,0)),Sum(if (QueryCount = 0,NotHelpDirectDebitTradeAmt - NotHelpDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,NotHelpDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,NotHelpDirectDebitCapNum,0)),Sum(if (QueryCount = 1,NotHelpDirectTradeAmt,0))from TradeDaySummary where SeoTitle = 'self' and UserId =" + ParentId + "" + con);
  1422. if (dt.Rows.Count > 0)
  1423. {
  1424. TotalAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][0].ToString()));
  1425. DAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][1].ToString()));
  1426. JAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][2].ToString()));
  1427. JfAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][3].ToString()));
  1428. JCountfc = Convert.ToInt32(function.CheckInt(dt.Rows[0][4].ToString()));
  1429. YAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][5].ToString()));
  1430. TotalAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][6].ToString()));
  1431. DAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][7].ToString()));
  1432. JAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][8].ToString()));
  1433. JfAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][9].ToString()));
  1434. JCountwd = Convert.ToInt32(function.CheckInt(dt.Rows[0][10].ToString()));
  1435. YAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][11].ToString()));
  1436. }
  1437. //统计激活数(个人、团队)
  1438. dt = OtherMySqlConn.dtable("SELECT SUM(if(SeoTitle='self',ActiveBuddyMerStatus,0)),SUM(if(SeoTitle='team',ActiveBuddyMerStatus,0)) FROM UserTradeMonthSummary WHERE UserId= " + ParentId + "" + cons);
  1439. if (dt.Rows.Count > 0)
  1440. {
  1441. PACount = Convert.ToInt32(function.CheckNum(dt.Rows[0][0].ToString()));
  1442. TACount = Convert.ToInt32(function.CheckNum(dt.Rows[0][1].ToString()));
  1443. }
  1444. DataTable dts = OtherMySqlConn.dtable("SELECT Sum(HelpNonDirectTradeAmt + HelpNonDirectDebitTradeAmt),Sum(if (QueryCount = 0,HelpNonDirectTradeAmt,0)),Sum(if (QueryCount = 0,HelpNonDirectDebitTradeAmt - HelpNonDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,HelpNonDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,HelpNonDirectDebitCapNum,0)),Sum(if (QueryCount = 1,HelpNonDirectTradeAmt,0)),Sum(NotHelpNonDirectTradeAmt + NotHelpNonDirectDebitTradeAmt),Sum(if (QueryCount = 0,NotHelpNonDirectTradeAmt,0)),Sum(if (QueryCount = 0,NotHelpNonDirectDebitTradeAmt - NotHelpNonDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,NotHelpNonDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,NotHelpNonDirectDebitCapNum,0)),Sum(if (QueryCount = 1,NotHelpNonDirectTradeAmt,0))from TradeDaySummary where SeoTitle = 'team' and UserId =" + ParentId + "" + con);
  1445. if (dts.Rows.Count > 0)
  1446. {
  1447. TotalAmtfc1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][0].ToString()));
  1448. DAmtfc1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][1].ToString()));
  1449. JAmtfc1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][2].ToString()));
  1450. JfAmtfc1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][3].ToString()));
  1451. JCountfc1 = Convert.ToInt32(function.CheckInt(dts.Rows[0][4].ToString()));
  1452. YAmtfc1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][5].ToString()));
  1453. TotalAmtwd1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][6].ToString()));
  1454. DAmtwd1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][7].ToString()));
  1455. JAmtwd1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][8].ToString()));
  1456. JfAmtwd1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][9].ToString()));
  1457. JCountwd1 = Convert.ToInt32(function.CheckInt(dts.Rows[0][10].ToString()));
  1458. YAmtwd1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][11].ToString()));
  1459. }
  1460. other.Add("TotalAmtfc", TotalAmtfc);
  1461. other.Add("DAmtfc", DAmtfc);
  1462. other.Add("JAmtfc", JAmtfc);
  1463. other.Add("JfAmtfc", JfAmtfc);
  1464. other.Add("JCountfc", JCountfc);
  1465. other.Add("YAmtfc", YAmtfc);
  1466. other.Add("TotalAmtwd", TotalAmtwd);
  1467. other.Add("DAmtwd", DAmtwd);
  1468. other.Add("JAmtwd", JAmtwd);
  1469. other.Add("JfAmtwd", JfAmtwd);
  1470. other.Add("JCountwd", JCountwd);
  1471. other.Add("YAmtwd", YAmtwd);
  1472. other.Add("TotalAmtfc1", TotalAmtfc1);
  1473. other.Add("DAmtfc1", DAmtfc1);
  1474. other.Add("JAmtfc1", JAmtfc1);
  1475. other.Add("JfAmtfc1", JfAmtfc1);
  1476. other.Add("JCountfc1", JCountfc1);
  1477. other.Add("YAmtfc1", YAmtfc1);
  1478. other.Add("TotalAmtwd1", TotalAmtwd1);
  1479. other.Add("DAmtwd1", DAmtwd1);
  1480. other.Add("JAmtwd1", JAmtwd1);
  1481. other.Add("JfAmtwd1", JfAmtwd1);
  1482. other.Add("JCountwd1", JCountwd1);
  1483. other.Add("YAmtwd1", YAmtwd1);
  1484. other.Add("PBCount", PBCount);
  1485. other.Add("PACount", PACount);
  1486. other.Add("TBCount", TBCount);
  1487. other.Add("TACount", TACount);
  1488. db.Dispose();
  1489. obj.Add("other", other);
  1490. return Json(obj);
  1491. }
  1492. public Dictionary<string, object> GetMonthTradeForBrand(int UserId, string sTradeDate, string eTradeDate, int BrandId)
  1493. {
  1494. WebCMSEntities db = new WebCMSEntities();
  1495. string condition = " and Status>-1";
  1496. string cons = " and Status>=-1";
  1497. //产品类型
  1498. if (!string.IsNullOrEmpty(BrandId.ToString()) && BrandId > 0)
  1499. {
  1500. condition += " and BrandId =" + BrandId;
  1501. cons += " and BrandId =" + BrandId;
  1502. }
  1503. //创客Id
  1504. if (!string.IsNullOrEmpty(UserId.ToString()))
  1505. {
  1506. condition += " and UserId =" + UserId;
  1507. }
  1508. //开始时间
  1509. if (!string.IsNullOrEmpty(sTradeDate) && !string.IsNullOrEmpty(eTradeDate))
  1510. {
  1511. condition += " and TradeDate >=" + Convert.ToInt32(sTradeDate) + " and TradeDate <=" + Convert.ToInt32(eTradeDate);
  1512. cons += " and SeoKeyword >=" + Convert.ToInt32(sTradeDate) + " and SeoKeyword <=" + Convert.ToInt32(eTradeDate);
  1513. }
  1514. //结束时间
  1515. else
  1516. {
  1517. var start = DateTime.Now.ToString("yyyyMM") + "01";
  1518. condition += " and TradeDate >=" + Convert.ToInt32(start) + " and TradeDate <=" + Convert.ToInt32(eTradeDate);
  1519. cons += " and SeoKeyword >=" + Convert.ToInt32(start) + " and SeoKeyword <=" + Convert.ToInt32(eTradeDate);
  1520. }
  1521. //扶持期
  1522. decimal TotalAmtfc = 0;
  1523. decimal DAmtfc = 0;
  1524. decimal JAmtfc = 0;
  1525. decimal JfAmtfc = 0;
  1526. int JCountfc = 0;
  1527. decimal YAmtfc = 0;
  1528. //稳定期
  1529. decimal TotalAmtwd = 0;
  1530. decimal DAmtwd = 0;
  1531. decimal JAmtwd = 0;
  1532. decimal JfAmtwd = 0;
  1533. int JCountwd = 0;
  1534. decimal YAmtwd = 0;
  1535. int BCount = 0;
  1536. int ACount = 0;
  1537. int PBCount = 0;
  1538. int PACount = 0;
  1539. int TBCount = 0;
  1540. int TACount = 0;
  1541. Dictionary<string, object> obj = new Dictionary<string, object>();
  1542. DataTable dt = OtherMySqlConn.dtable("SELECT Sum(HelpDirectTradeAmt + HelpDirectDebitTradeAmt),Sum(if (QueryCount = 0,HelpDirectTradeAmt,0)),Sum(if (QueryCount = 0,HelpDirectDebitTradeAmt - HelpDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,HelpDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,HelpDirectDebitCapNum,0)),Sum(if (QueryCount = 1,HelpDirectTradeAmt,0)),Sum(NotHelpDirectTradeAmt + NotHelpDirectDebitTradeAmt),Sum(if (QueryCount = 0,NotHelpDirectTradeAmt,0)),Sum(if (QueryCount = 0,NotHelpDirectDebitTradeAmt - NotHelpDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,NotHelpDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,NotHelpDirectDebitCapNum,0)),Sum(if (QueryCount = 1,NotHelpDirectTradeAmt,0))from TradeDaySummary where SeoTitle = 'team'" + condition);
  1543. if (dt.Rows.Count > 0)
  1544. {
  1545. TotalAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][0].ToString()));
  1546. DAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][1].ToString()));
  1547. JAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][2].ToString()));
  1548. JfAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][3].ToString()));
  1549. JCountfc = Convert.ToInt32(function.CheckInt(dt.Rows[0][4].ToString()));
  1550. YAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][5].ToString()));
  1551. TotalAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][6].ToString()));
  1552. DAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][7].ToString()));
  1553. JAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][8].ToString()));
  1554. JfAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][9].ToString()));
  1555. JCountwd = Convert.ToInt32(function.CheckInt(dt.Rows[0][10].ToString()));
  1556. YAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][11].ToString()));
  1557. }
  1558. //统计激活数(个人、团队)
  1559. dt = OtherMySqlConn.dtable("SELECT SUM(if(SeoTitle='team',ActiveBuddyMerStatus,0)) FROM UserTradeMonthSummary WHERE UserId= " + UserId + "" + cons);
  1560. if (dt.Rows.Count > 0)
  1561. {
  1562. TACount = Convert.ToInt32(function.CheckNum(dt.Rows[0][0].ToString()));
  1563. }
  1564. obj.Add("TotalAmtfc", TotalAmtfc);
  1565. obj.Add("DAmtfc", DAmtfc);
  1566. obj.Add("JAmtfc", JAmtfc);
  1567. obj.Add("JfAmtfc", JfAmtfc);
  1568. obj.Add("JCountfc", JCountfc);
  1569. obj.Add("YAmtfc", YAmtfc);
  1570. obj.Add("TotalAmtwd", TotalAmtwd);
  1571. obj.Add("DAmtwd", DAmtwd);
  1572. obj.Add("JAmtwd", JAmtwd);
  1573. obj.Add("JfAmtwd", JfAmtwd);
  1574. obj.Add("JCountwd", JCountwd);
  1575. obj.Add("YAmtwd", YAmtwd);
  1576. obj.Add("BCount", BCount);
  1577. obj.Add("ACount", ACount);
  1578. obj.Add("PBCount", PBCount);
  1579. obj.Add("PACount", PACount);
  1580. obj.Add("TBCount", TBCount);
  1581. obj.Add("TACount", TACount);
  1582. db.Dispose();
  1583. return obj;
  1584. }
  1585. #endregion
  1586. }
  1587. }