UsersController.cs 144 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005
  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 (SelfId == 0 && ParentId == 0)
  64. {
  65. if (ShowFlag == 0)
  66. {
  67. Dictionary<string, object> objs = new Dictionary<string, object>();
  68. return Json(objs);
  69. }
  70. }
  71. string condition = " and Status>-1";
  72. string sort = "Id desc";
  73. //直属创客编号
  74. if (!string.IsNullOrEmpty(ParentMakerCode))
  75. {
  76. condition += " and ParentUserId in (select UserId from UserForMakerCode where MakerCode='" + ParentMakerCode + "')";
  77. }
  78. //直属创客名称
  79. if (!string.IsNullOrEmpty(ParentRealName))
  80. {
  81. condition += " and ParentUserId in (select UserId from UserForRealName where RealName='" + ParentRealName + "')";
  82. }
  83. //实名状态
  84. if (!string.IsNullOrEmpty(AuthFlagSelect))
  85. {
  86. condition += " and AuthFlag=" + AuthFlagSelect;
  87. }
  88. //顶级创客
  89. if (TopUserId > 0)
  90. {
  91. condition += " and ParentNav like '," + TopUserId + ",%'";
  92. }
  93. //风控标识
  94. if (!string.IsNullOrEmpty(RiskFlagSelect))
  95. {
  96. condition += " and RiskFlag=" + RiskFlagSelect;
  97. }
  98. //商户创客类型
  99. if (!string.IsNullOrEmpty(MerchantTypeSelect))
  100. {
  101. condition += " and MerchantType=" + MerchantTypeSelect;
  102. }
  103. if (sSettleAmount != null)
  104. {
  105. condition += " and SettleAmount>=" + sSettleAmount.Value;
  106. }
  107. if (eSettleAmount != null)
  108. {
  109. condition += " and SettleAmount<=" + eSettleAmount.Value;
  110. }
  111. if (sCashFreezeAmt != null)
  112. {
  113. condition += " and CashFreezeAmt>=" + sCashFreezeAmt.Value;
  114. }
  115. if (eCashFreezeAmt != null)
  116. {
  117. condition += " and CashFreezeAmt<=" + eCashFreezeAmt.Value;
  118. }
  119. if (SelfId > 0)
  120. {
  121. Users self = db.Users.FirstOrDefault(m => m.Id == SelfId);
  122. if (self != null)
  123. {
  124. string ParentNav = function.CheckNull(self.ParentNav);
  125. condition += " and Id in (" + ParentNav.Trim(',').Replace(",,", ",") + ")";
  126. sort = "ParentNav asc";
  127. }
  128. }
  129. if (ParentId > 0)
  130. {
  131. condition += " and ParentUserId=" + ParentId;
  132. }
  133. if (UserId > 0)
  134. {
  135. condition += " and Id=" + UserId;
  136. }
  137. if (!string.IsNullOrEmpty(CreateDateData))
  138. {
  139. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  140. string start = datelist[0];
  141. string end = datelist[1];
  142. condition += " and CreateDate>='" + start + " 00:00:00' and CreateDate<='" + end + " 23:59:59'";
  143. }
  144. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, sort, "True", page, limit, condition);
  145. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  146. foreach (Dictionary<string, object> dic in diclist)
  147. {
  148. dic["AuthFlagName"] = dic["AuthFlag"].ToString() == "1" ? "已实名" : "未实名";
  149. dic["RiskFlagName"] = dic["RiskFlag"].ToString() == "1" ? "已风控" : "未风控";
  150. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  151. dic["MerchantType"] = RelationClassForConst.GetMerchantTypeInfo(int.Parse(dic["MerchantType"].ToString()));
  152. int ParentUserId = int.Parse(dic["ParentUserId"].ToString());
  153. Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
  154. dic["ParentMakerCode"] = puser.MakerCode;
  155. dic["ParentRealName"] = puser.RealName;
  156. string ParentNav = dic["ParentNav"].ToString();
  157. if (!string.IsNullOrEmpty(ParentNav))
  158. {
  159. string[] list = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  160. var topUserInfo = new Users();
  161. if (list.Length > 1)
  162. {
  163. topUserInfo = db.Users.FirstOrDefault(m => m.Id == int.Parse(list[1])) ?? new Users();
  164. }
  165. else
  166. {
  167. topUserInfo = db.Users.FirstOrDefault(m => m.Id == int.Parse(list[0])) ?? new Users();
  168. }
  169. dic["TopMakerCode"] = topUserInfo.MakerCode;
  170. dic["TopRealName"] = topUserInfo.RealName;
  171. }
  172. }
  173. return Json(obj);
  174. }
  175. #endregion
  176. #region 创客列表
  177. /// <summary>
  178. /// 根据条件查询创客列表
  179. /// </summary>
  180. /// <returns></returns>
  181. public IActionResult CancleUsers(Users data, string right, int SelfId = 0, int ParentId = 0, string MakerCode = "")
  182. {
  183. ViewBag.RightInfo = RightInfo;
  184. ViewBag.right = right;
  185. ViewBag.SelfId = SelfId.ToString();
  186. ViewBag.ParentId = ParentId.ToString();
  187. ViewBag.MakerCode = MakerCode;
  188. List<Users> TopUsers = db.Users.Where(m => m.ParentUserId == 0).ToList();
  189. ViewBag.TopUsers = TopUsers;
  190. List<UserLevelSet> Levels = db.UserLevelSet.OrderBy(m => m.Id).ToList();
  191. ViewBag.Levels = Levels;
  192. return View();
  193. }
  194. #endregion
  195. #region 根据条件查询创客列表
  196. /// <summary>
  197. /// 创客列表
  198. /// </summary>
  199. /// <returns></returns>
  200. public JsonResult CancleUsersData(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)
  201. {
  202. Dictionary<string, string> Fields = new Dictionary<string, string>();
  203. Fields.Add("MakerCode", "1"); //创客编号
  204. Fields.Add("RealName", "1"); //创客名称
  205. Fields.Add("Mobile", "1"); //手机号
  206. Fields.Add("CertId", "1"); //身份证号码
  207. Fields.Add("SettleAmount", "3"); //结算金额
  208. Fields.Add("CashFreezeAmt", "3"); //冻结金额
  209. Fields.Add("UserLevel", "0"); //创客等级
  210. string condition = " and Status=-1";
  211. string sort = "Id desc";
  212. //直属创客编号
  213. if (!string.IsNullOrEmpty(ParentMakerCode))
  214. {
  215. condition += " and ParentUserId in (select UserId from UserForMakerCode where MakerCode='" + ParentMakerCode + "')";
  216. }
  217. //直属创客名称
  218. if (!string.IsNullOrEmpty(ParentRealName))
  219. {
  220. condition += " and ParentUserId in (select UserId from UserForRealName where RealName='" + ParentRealName + "')";
  221. }
  222. //实名状态
  223. if (!string.IsNullOrEmpty(AuthFlagSelect))
  224. {
  225. condition += " and AuthFlag=" + AuthFlagSelect;
  226. }
  227. //顶级创客
  228. if (TopUserId > 0)
  229. {
  230. condition += " and ParentNav like '," + TopUserId + ",%'";
  231. }
  232. //风控标识
  233. if (!string.IsNullOrEmpty(RiskFlagSelect))
  234. {
  235. condition += " and RiskFlag=" + RiskFlagSelect;
  236. }
  237. //商户创客类型
  238. if (!string.IsNullOrEmpty(MerchantTypeSelect))
  239. {
  240. condition += " and MerchantType=" + MerchantTypeSelect;
  241. }
  242. if (sSettleAmount != null)
  243. {
  244. condition += " and SettleAmount>=" + sSettleAmount.Value;
  245. }
  246. if (eSettleAmount != null)
  247. {
  248. condition += " and SettleAmount<=" + eSettleAmount.Value;
  249. }
  250. if (sCashFreezeAmt != null)
  251. {
  252. condition += " and CashFreezeAmt>=" + sCashFreezeAmt.Value;
  253. }
  254. if (eCashFreezeAmt != null)
  255. {
  256. condition += " and CashFreezeAmt<=" + eCashFreezeAmt.Value;
  257. }
  258. if (SelfId > 0)
  259. {
  260. Users self = db.Users.FirstOrDefault(m => m.Id == SelfId);
  261. if (self != null)
  262. {
  263. string ParentNav = function.CheckNull(self.ParentNav);
  264. condition += " and Id in (" + ParentNav.Trim(',').Replace(",,", ",") + ")";
  265. sort = "ParentNav asc";
  266. }
  267. }
  268. if (ParentId > 0)
  269. {
  270. condition += " and ParentUserId=" + ParentId;
  271. }
  272. if (UserId > 0)
  273. {
  274. condition += " and Id=" + UserId;
  275. }
  276. if (!string.IsNullOrEmpty(CreateDateData))
  277. {
  278. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  279. string start = datelist[0];
  280. string end = datelist[1];
  281. condition += " and CreateDate>='" + start + " 00:00:00' and CreateDate<='" + end + " 23:59:59'";
  282. }
  283. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, sort, "True", page, limit, condition);
  284. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  285. foreach (Dictionary<string, object> dic in diclist)
  286. {
  287. dic["AuthFlagName"] = dic["AuthFlag"].ToString() == "1" ? "已实名" : "未实名";
  288. dic["RiskFlagName"] = dic["RiskFlag"].ToString() == "1" ? "已风控" : "未风控";
  289. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  290. dic["MerchantType"] = RelationClassForConst.GetMerchantTypeInfo(int.Parse(dic["MerchantType"].ToString()));
  291. int ParentUserId = int.Parse(dic["ParentUserId"].ToString());
  292. Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
  293. dic["ParentMakerCode"] = puser.MakerCode;
  294. dic["ParentRealName"] = puser.RealName;
  295. string ParentNav = dic["ParentNav"].ToString();
  296. if (!string.IsNullOrEmpty(ParentNav))
  297. {
  298. string[] list = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  299. if (list.Length > 1)
  300. {
  301. int TopId = int.Parse(function.CheckInt(list[1]));
  302. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopId) ?? new Users();
  303. dic["TopMakerCode"] = tuser.MakerCode;
  304. dic["TopRealName"] = tuser.RealName;
  305. }
  306. }
  307. }
  308. return Json(obj);
  309. }
  310. #endregion
  311. #region 增加创客
  312. /// <summary>
  313. /// 增加或修改创客信息
  314. /// </summary>
  315. /// <returns></returns>
  316. public IActionResult Add(string right)
  317. {
  318. ViewBag.RightInfo = RightInfo;
  319. ViewBag.right = right;
  320. return View();
  321. }
  322. #endregion
  323. #region 增加创客
  324. /// <summary>
  325. /// 增加或修改创客信息
  326. /// </summary>
  327. /// <returns></returns>
  328. [HttpPost]
  329. public string Add(Users data, string ParentMakerCode)
  330. {
  331. bool check = db.UserForMobile.Any(m => m.Mobile == data.Mobile);
  332. if (check)
  333. {
  334. return "手机号已存在,请重新输入";
  335. }
  336. check = db.UserForRealName.Any(m => m.RealName == data.RealName);
  337. if (check)
  338. {
  339. return "姓名已存在,请重新输入";
  340. }
  341. if (!string.IsNullOrEmpty(data.MakerCode))
  342. {
  343. check = db.UserForMakerCode.Any(m => m.MakerCode == data.MakerCode);
  344. if (check)
  345. {
  346. return "创客编码已存在,请重新输入";
  347. }
  348. }
  349. Dictionary<string, object> Fields = new Dictionary<string, object>();
  350. Fields.Add("RealName", data.RealName); //真实姓名
  351. Fields.Add("CertId", data.CertId); //身份证号
  352. Fields.Add("Mobile", data.Mobile); //手机号
  353. Fields.Add("LoginPwd", function.MD532(data.LoginPwd)); //登录密码
  354. Fields.Add("SettleBankCardNo", data.SettleBankCardNo); //结算银行卡号
  355. if (!string.IsNullOrEmpty(ParentMakerCode))
  356. {
  357. UserForMakerCode userFor = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == ParentMakerCode) ?? new UserForMakerCode();
  358. Users puser = db.Users.FirstOrDefault(m => m.Id == userFor.UserId) ?? new Users();
  359. Fields.Add("ParentUserId", userFor.UserId);
  360. Fields.Add("ParentNav", puser.ParentNav + "," + userFor.UserId + ",");
  361. }
  362. int Id = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Add("Users", Fields, 0);
  363. if (string.IsNullOrEmpty(ParentMakerCode))
  364. {
  365. string MakerCode = Id.ToString();
  366. for (int i = 0; i < 7 - Id.ToString().Length; i++)
  367. {
  368. MakerCode = "0" + MakerCode;
  369. }
  370. MakerCode = "K" + MakerCode;
  371. Fields = new Dictionary<string, object>();
  372. Fields.Add("MakerCode", MakerCode); //编号
  373. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, Id);
  374. }
  375. db.UserDetail.Add(new UserDetail() { Id = Id });
  376. db.UserData.Add(new UserData() { UserId = Id });
  377. AddSysLog(data.Id.ToString(), "Users", "add");
  378. db.SaveChanges();
  379. return "success";
  380. }
  381. #endregion
  382. #region 修改创客
  383. /// <summary>
  384. /// 增加或修改创客信息
  385. /// </summary>
  386. /// <returns></returns>
  387. public IActionResult Edit(string right, int Id = 0)
  388. {
  389. ViewBag.RightInfo = RightInfo;
  390. ViewBag.right = right;
  391. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  392. ViewBag.data = editData;
  393. return View();
  394. }
  395. #endregion
  396. #region 修改创客
  397. /// <summary>
  398. /// 增加或修改创客信息
  399. /// </summary>
  400. /// <returns></returns>
  401. [HttpPost]
  402. public string Edit(Users data, UserDetail userdetail, UserData userdata)
  403. {
  404. Dictionary<string, object> Fields = new Dictionary<string, object>();
  405. Fields.Add("RealName", data.RealName); //真实姓名
  406. Fields.Add("CertId", data.CertId); //身份证号
  407. Fields.Add("Mobile", data.Mobile); //手机号
  408. Fields.Add("SettleBankName", data.SettleBankName); //结算银行名称
  409. Fields.Add("SettleBankCardNo", data.SettleBankCardNo); //结算银行卡号
  410. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, data.Id);
  411. AddSysLog(data.Id.ToString(), "Users", "update");
  412. db.SaveChanges();
  413. return "success";
  414. }
  415. #endregion
  416. #region 重置小分仓机具数
  417. public string ResetSmallPosCount(string Id)
  418. {
  419. DataTable dt = OtherMySqlConn.dtable("update SmallStoreHouse s set TotalNum=(select count(Id) from PreSendStockDetail where ToUserId=s.UserId and ApplyFlag=0 and Status>-1 and Status<2),LaveNum=10-(select count(Id) from PreSendStockDetail where ToUserId=s.UserId and ApplyFlag=0 and Status>-1 and Status<2) where UserId=" + Id);
  420. string text = string.Format("重置小分仓机具数,UserId: '" + Id + "',操作人: '" + SysUserName + "_" + SysRealName + "',Time'" + DateTime.Now + "'");
  421. function.WriteLog(text, "重置小分仓机具数");
  422. AddSysLog("0", "Users", "ResetSmallPosCount");
  423. return "success";
  424. }
  425. #endregion
  426. #region 清除登陆TOKEN
  427. public string ClearToken(string Id)
  428. {
  429. var UserId = int.Parse(Id);
  430. var utoken = RedisDbconn.Instance.GetKeys("utoken:*" + UserId);
  431. var apptoken = RedisDbconn.Instance.GetKeys("apptoken:*" + UserId);
  432. RedisDbconn.Instance.Clear("utoken:*" + UserId);
  433. RedisDbconn.Instance.Clear("apptoken:*" + UserId);
  434. AddSysLog(Id, "Users", "ClearToken");
  435. return "success";
  436. }
  437. #endregion
  438. #region 修改结算金额
  439. public IActionResult EditSettleAmount(string right, int Id = 0)
  440. {
  441. ViewBag.RightInfo = RightInfo;
  442. ViewBag.right = right;
  443. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  444. ViewBag.data = editData;
  445. return View();
  446. }
  447. #endregion
  448. #region 修改结算金额
  449. [HttpPost]
  450. public string EditSettleAmount(Users data)
  451. {
  452. Dictionary<string, object> Fields = new Dictionary<string, object>();
  453. Fields.Add("SettleAmount", data.SettleAmount);
  454. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, data.Id);
  455. AddSysLog(data.Id.ToString(), "Users", "EditSettleAmount");
  456. db.SaveChanges();
  457. return "success";
  458. }
  459. #endregion
  460. #region 修改账户金额
  461. public IActionResult EditCashFreezeAmt(string right, int Id = 0)
  462. {
  463. ViewBag.RightInfo = RightInfo;
  464. ViewBag.right = right;
  465. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  466. ViewBag.data = editData;
  467. return View();
  468. }
  469. #endregion
  470. #region 修改账户金额
  471. [HttpPost]
  472. public string EditCashFreezeAmt(Users data, string Note, int Kind)
  473. {
  474. int UserId = data.Id;
  475. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  476. if (account == null)
  477. {
  478. account = db.UserAccount.Add(new UserAccount()
  479. {
  480. Id = UserId,
  481. UserId = UserId,
  482. }).Entity;
  483. db.SaveChanges();
  484. }
  485. if ((Kind == 1 || Kind == 3) && data.CashFreezeAmt > account.BalanceAmount)
  486. {
  487. return "账号余额不足";
  488. }
  489. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  490. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  491. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  492. int ChangeType = 0;
  493. if (Kind == 1 && data.CashFreezeAmt <= account.BalanceAmount)
  494. {
  495. account.BalanceAmount -= data.CashFreezeAmt;
  496. account.FreezeAmount += data.CashFreezeAmt;
  497. ChangeType = 61;
  498. }
  499. else if (Kind == 1 && data.CashFreezeAmt > account.BalanceAmount)
  500. {
  501. return "冻结金额大于余额";
  502. }
  503. else if (Kind == 2 && data.CashFreezeAmt <= account.FreezeAmount)
  504. {
  505. account.BalanceAmount += data.CashFreezeAmt;
  506. account.FreezeAmount -= data.CashFreezeAmt;
  507. ChangeType = 62;
  508. }
  509. else if (Kind == 2 && data.CashFreezeAmt > account.FreezeAmount)
  510. {
  511. return "解冻金额大于冻结金额";
  512. }
  513. else if (Kind == 3 && data.CashFreezeAmt <= account.BalanceAmount)
  514. {
  515. account.TotalAmount -= data.CashFreezeAmt;
  516. account.BalanceAmount -= data.CashFreezeAmt;
  517. ChangeType = 63;
  518. }
  519. else if (Kind == 3 && data.CashFreezeAmt > account.BalanceAmount)
  520. {
  521. return "扣减金额大于余额";
  522. }
  523. else if (Kind == 4)
  524. {
  525. account.TotalAmount += data.CashFreezeAmt;
  526. account.BalanceAmount += data.CashFreezeAmt;
  527. ChangeType = 64;
  528. }
  529. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  530. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  531. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  532. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  533. {
  534. CreateDate = DateTime.Now,
  535. UpdateDate = DateTime.Now,
  536. UserId = UserId, //创客
  537. ChangeType = ChangeType, //变动类型
  538. ChangeAmount = data.CashFreezeAmt, //变更金额
  539. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  540. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  541. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  542. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  543. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  544. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  545. Remark = Note,
  546. }).Entity;
  547. db.SaveChanges();
  548. RedisDbconn.Instance.Set("UserAccount:" + UserId, account);
  549. AddSysLog(data.Id.ToString(), "Users", "EditCashFreezeAmt");
  550. db.SaveChanges();
  551. return "success";
  552. }
  553. #endregion
  554. #region 账户操作
  555. public IActionResult EditBalance(string right, int Id = 0)
  556. {
  557. ViewBag.RightInfo = RightInfo;
  558. ViewBag.right = right;
  559. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  560. ViewBag.data = editData;
  561. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == Id) ?? new UserAccount();
  562. ViewBag.account = account;
  563. return View();
  564. }
  565. #endregion
  566. #region 账户操作
  567. [HttpPost]
  568. public string EditBalance(UserAccount data)
  569. {
  570. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == data.Id);
  571. if (account != null)
  572. {
  573. decimal amount = data.BalanceAmount - account.BalanceAmount;
  574. if (amount != 0)
  575. {
  576. account.BalanceAmount += amount;
  577. account.TotalAmount += amount;
  578. AddSysLog(data.Id.ToString(), "UserAccount", "EditBalance");
  579. db.SaveChanges();
  580. }
  581. }
  582. return "success";
  583. }
  584. #endregion
  585. #region 详情
  586. public IActionResult Detail(string right, int Id = 0)
  587. {
  588. ViewBag.RightInfo = RightInfo;
  589. ViewBag.right = right;
  590. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  591. ViewBag.AuthDate = editData.AuthDate == null ? "" : editData.AuthDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
  592. string Age = "";
  593. if (!string.IsNullOrEmpty(editData.CertId))
  594. {
  595. int year = DateTime.Now.Year - int.Parse(editData.CertId.Substring(6, 4));
  596. Age = year.ToString();
  597. }
  598. ViewBag.Age = Age;
  599. ViewBag.QrCode = string.IsNullOrEmpty(editData.ReferenceQrCode) ? defaultImage : SourceHost + editData.ReferenceQrCode;
  600. return View();
  601. }
  602. #endregion
  603. #region 三/四要素验证
  604. public IActionResult ThreeElement(string right)
  605. {
  606. ViewBag.RightInfo = RightInfo;
  607. ViewBag.right = right;
  608. return View();
  609. }
  610. #endregion
  611. #region 三/四要素验证
  612. [HttpPost]
  613. public string ThreeElement(string Name, string CertId, string CardNo, string Mobile)
  614. {
  615. return "success";
  616. }
  617. #endregion
  618. #region 删除创客信息
  619. /// <summary>
  620. /// 删除创客信息
  621. /// </summary>
  622. /// <returns></returns>
  623. public string Delete(string Id)
  624. {
  625. string[] idlist = Id.Split(new char[] { ',' });
  626. AddSysLog(Id, "Users", "del");
  627. foreach (string subid in idlist)
  628. {
  629. int id = int.Parse(subid);
  630. Dictionary<string, object> Fields = new Dictionary<string, object>();
  631. Fields.Add("Status", -1);
  632. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  633. }
  634. db.SaveChanges();
  635. return "success";
  636. }
  637. #endregion
  638. #region 注销
  639. // 1.创客名下无未绑定机具且没有申请中的机具循环及兑换订单
  640. // 2.创客名下无预发机
  641. // 3.创客名下无分仓及运营中心
  642. // 满足以上全部条件的用户可申请注销,申请后用户二次填写确认填写信息(姓名、手机号、身份证号)即可完成注销
  643. public string Cancel(string UserId)
  644. {
  645. AddSysLog("0", "Users", "Cancel");
  646. Users user = db.Users.FirstOrDefault(m => m.Id == Convert.ToInt32(UserId));
  647. if (user != null)
  648. {
  649. if (user.AuthFlag == 1)
  650. {
  651. // bool check = db.PosMachinesTwo.Any(m => m.BuyUserId == user.Id && m.BindingState == 1);
  652. // if (check)
  653. // {
  654. // return "注销失败,未满足条件:已实名创客,无开通商户。如有疑问,请联系客服";
  655. // }
  656. // DateTime checkDate = DateTime.Now.AddDays(-7);
  657. // check = db.Orders.Any(m => m.CreateDate >= checkDate && m.Status > 0 && m.UserId == user.Id);
  658. // if (check)
  659. // {
  660. // return "注销失败,未满足条件:近7天未在商城下单过商品。如有疑问,请联系客服";
  661. // }
  662. // check = db.PosMachinesTwo.Any(m => m.BuyUserId == user.Id && m.IsPurchase == 0);
  663. // if (check)
  664. // {
  665. // return "注销失败,未满足条件:名下无未绑定机具、机具券,无未申请的循环机。如有疑问,请联系客服";
  666. // }
  667. // check = db.PosCoupons.Any(m => m.UserId == user.Id && m.IsUse == 0);
  668. // if (check)
  669. // {
  670. // return "注销失败,未满足条件:名下无未绑定机具、机具券,无未申请的循环机。如有疑问,请联系客服";
  671. // }
  672. bool check = db.PosMachinesTwo.Any(m => m.BuyUserId == user.Id && m.BindingState == 0);
  673. if (check)
  674. {
  675. return "注销失败,未满足条件:名下存在未绑定机具。如有疑问,请联系客服";
  676. }
  677. check = db.MachineApply.Any(m => m.Status == 0 && m.UserId == user.Id);
  678. if (check)
  679. {
  680. return "注销失败,未满足条件:名下存在未完成的机具循环兑换订单。如有疑问,请联系客服";
  681. }
  682. check = db.PreSendStockDetail.Any(m => m.Status == 1 && m.AuthFlag == 0 && m.ToUserId == user.Id);
  683. if (check)
  684. {
  685. return "注销失败,未满足条件:名下存在预发机。如有疑问,请联系客服";
  686. }
  687. if (user.UserType == 1)
  688. {
  689. return "注销失败,未满足条件:名下存在运营中心。如有疑问,请联系客服";
  690. }
  691. check = db.StoreHouse.Any(m => m.Status == 1 && m.UserId == user.Id);
  692. if (check)
  693. {
  694. return "注销失败,未满足条件:名下存在分仓。如有疑问,请联系客服";
  695. }
  696. UserForMobile forMobile = db.UserForMobile.FirstOrDefault(m => m.Mobile == user.Mobile);
  697. if (forMobile != null)
  698. {
  699. db.Remove(forMobile);
  700. }
  701. UserForMakerCode forCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == user.MakerCode);
  702. if (forCode != null)
  703. {
  704. db.UserForMakerCode.Remove(forCode);
  705. }
  706. user.Status = -1;
  707. user.Mobile += "d";
  708. user.CertId += "d";
  709. user.LogOutDate = DateTime.Now;
  710. }
  711. else
  712. {
  713. UserForMobile forMobile = db.UserForMobile.FirstOrDefault(m => m.Mobile == user.Mobile);
  714. if (forMobile != null)
  715. {
  716. db.UserForMobile.Remove(forMobile);
  717. }
  718. UserForMakerCode forCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == user.MakerCode);
  719. if (forCode != null)
  720. {
  721. db.UserForMakerCode.Remove(forCode);
  722. }
  723. user.Status = -1;
  724. user.Mobile += "d";
  725. user.CertId += "d";
  726. user.LogOutDate = DateTime.Now;
  727. }
  728. function.WriteLog(user.Id + "于" + DateTime.Now.ToString() + "注销账号", "创客注销日志");
  729. // TODO: 每月扫描一次注销的创客,把注销创客伞下创客全部挂到注销创客的上级
  730. // TODO: 清除token,token登录返回
  731. db.SaveChanges();
  732. }
  733. return "success";
  734. }
  735. #endregion
  736. #region 开启
  737. /// <summary>
  738. /// 开启
  739. /// </summary>
  740. /// <returns></returns>
  741. public string Open(string Id)
  742. {
  743. string[] idlist = Id.Split(new char[] { ',' });
  744. AddSysLog(Id, "Users", "open");
  745. foreach (string subid in idlist)
  746. {
  747. int id = int.Parse(subid);
  748. Dictionary<string, object> Fields = new Dictionary<string, object>();
  749. Fields.Add("Status", 1);
  750. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  751. }
  752. db.SaveChanges();
  753. return "success";
  754. }
  755. #endregion
  756. #region 关闭
  757. /// <summary>
  758. /// 关闭
  759. /// </summary>
  760. /// <returns></returns>
  761. public string Close(string Id)
  762. {
  763. string[] idlist = Id.Split(new char[] { ',' });
  764. AddSysLog(Id, "Users", "close");
  765. foreach (string subid in idlist)
  766. {
  767. int id = int.Parse(subid);
  768. Dictionary<string, object> Fields = new Dictionary<string, object>();
  769. Fields.Add("Status", 0);
  770. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  771. }
  772. db.SaveChanges();
  773. return "success";
  774. }
  775. #endregion
  776. #region 一键企业创客
  777. /// <summary>
  778. /// 一键企业创客
  779. /// </summary>
  780. /// <returns></returns>
  781. public string OpenEnterpriseMaker(string Id)
  782. {
  783. string[] idlist = Id.Split(new char[] { ',' });
  784. AddSysLog(Id, "Users", "OpenEnterpriseMaker");
  785. foreach (string subid in idlist)
  786. {
  787. int id = int.Parse(subid);
  788. Dictionary<string, object> Fields = new Dictionary<string, object>();
  789. Fields.Add("BusinessFlag", 1);
  790. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  791. }
  792. db.SaveChanges();
  793. return "success";
  794. }
  795. #endregion
  796. #region 关闭企业创客
  797. /// <summary>
  798. /// 关闭企业创客
  799. /// </summary>
  800. /// <returns></returns>
  801. public string CloseEnterpriseMaker(string Id)
  802. {
  803. string[] idlist = Id.Split(new char[] { ',' });
  804. AddSysLog(Id, "Users", "CloseEnterpriseMaker");
  805. foreach (string subid in idlist)
  806. {
  807. int id = int.Parse(subid);
  808. Dictionary<string, object> Fields = new Dictionary<string, object>();
  809. Fields.Add("BusinessFlag", 0);
  810. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  811. }
  812. db.SaveChanges();
  813. return "success";
  814. }
  815. #endregion
  816. #region 一键大盟主
  817. /// <summary>
  818. /// 一键大盟主
  819. /// </summary>
  820. /// <returns></returns>
  821. public string SetBigLeader(string Id)
  822. {
  823. string[] idlist = Id.Split(new char[] { ',' });
  824. AddSysLog(Id, "Users", "SetBigLeader");
  825. foreach (string subid in idlist)
  826. {
  827. int id = int.Parse(subid);
  828. Dictionary<string, object> Fields = new Dictionary<string, object>();
  829. Fields.Add("LeaderLevel", 2);
  830. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  831. }
  832. db.SaveChanges();
  833. return "success";
  834. }
  835. #endregion
  836. #region 一键小盟主
  837. /// <summary>
  838. /// 一键小盟主
  839. /// </summary>
  840. /// <returns></returns>
  841. public string SetSmallLeader(string Id)
  842. {
  843. string[] idlist = Id.Split(new char[] { ',' });
  844. AddSysLog(Id, "Users", "SetSmallLeader");
  845. foreach (string subid in idlist)
  846. {
  847. int id = int.Parse(subid);
  848. Dictionary<string, object> Fields = new Dictionary<string, object>();
  849. Fields.Add("LeaderLevel", 1);
  850. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  851. }
  852. db.SaveChanges();
  853. return "success";
  854. }
  855. #endregion
  856. #region 风控
  857. public IActionResult Risk(string right, int Id = 0)
  858. {
  859. ViewBag.RightInfo = RightInfo;
  860. ViewBag.right = right;
  861. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  862. ViewBag.data = editData;
  863. return View();
  864. }
  865. #endregion
  866. #region 风控
  867. [HttpPost]
  868. public string Risk(Users data)
  869. {
  870. Users user = db.Users.FirstOrDefault(m => m.Id == data.Id);
  871. if (user != null)
  872. {
  873. user.RiskFlag = data.RiskFlag;
  874. user.RiskRemark = data.RiskRemark;
  875. db.SaveChanges();
  876. }
  877. AddSysLog("0", "Users", "Risk");
  878. return "success";
  879. }
  880. #endregion
  881. #region 解除风控
  882. public string UnRisk(string Id)
  883. {
  884. string[] idlist = Id.Split(new char[] { ',' });
  885. AddSysLog(Id, "Users", "UnRisk");
  886. foreach (string subid in idlist)
  887. {
  888. int id = int.Parse(subid);
  889. Dictionary<string, object> Fields = new Dictionary<string, object>();
  890. Fields.Add("RiskFlag", 0);
  891. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  892. }
  893. db.SaveChanges();
  894. return "success";
  895. }
  896. #endregion
  897. #region 重置密码
  898. public string ResetPwd(int Id)
  899. {
  900. string NewPwd = function.get_Random(6);
  901. Dictionary<string, object> Fields = new Dictionary<string, object>();
  902. Fields.Add("LoginPwd", function.MD532(NewPwd));
  903. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, Id);
  904. //通用添加创客迁移数据
  905. AddUserMoveInfo(Id, null, NewPwd);
  906. AddSysLog(Id, "Users", "ResetPwd");
  907. return "success|" + NewPwd;
  908. }
  909. #endregion
  910. #region 排序
  911. /// <summary>
  912. /// 排序
  913. /// </summary>
  914. /// <param name="Id"></param>
  915. public string Sort(int Id, int Sort)
  916. {
  917. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Sort("Users", Sort, Id);
  918. AddSysLog(Id.ToString(), "Users", "sort");
  919. return "success";
  920. }
  921. #endregion
  922. #region 导入数据
  923. /// <summary>
  924. /// 导入数据
  925. /// </summary>
  926. /// <param name="ExcelData"></param>
  927. public string Import(string ExcelData, int Kind = 0)
  928. {
  929. ExcelData = HttpUtility.UrlDecode(ExcelData);
  930. JsonData list = JsonMapper.ToObject(ExcelData);
  931. if (Kind == 1)
  932. {
  933. for (int i = 1; i < list.Count; i++)
  934. {
  935. JsonData dr = list[i];
  936. string MakerCode = dr[0].ToString();
  937. string SettleAmount = dr[2].ToString();
  938. UserForMakerCode UserCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  939. if (UserCode != null)
  940. {
  941. Users User = db.Users.FirstOrDefault(m => m.Id == UserCode.UserId);
  942. if (User != null)
  943. {
  944. User.SettleAmount = decimal.Parse(function.CheckInt(SettleAmount));
  945. }
  946. }
  947. }
  948. db.SaveChanges();
  949. }
  950. else if (Kind == 2)
  951. {
  952. for (int i = 1; i < list.Count; i++)
  953. {
  954. JsonData dr = list[i];
  955. string MakerCode = dr[0].ToString();
  956. string CashFreezeAmt = dr[2].ToString();
  957. UserForMakerCode UserCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  958. if (UserCode != null)
  959. {
  960. Users User = db.Users.FirstOrDefault(m => m.Id == UserCode.UserId);
  961. if (User != null)
  962. {
  963. User.CashFreezeAmt = decimal.Parse(function.CheckInt(CashFreezeAmt));
  964. }
  965. }
  966. }
  967. db.SaveChanges();
  968. }
  969. else if (Kind == 3)
  970. {
  971. for (int i = 1; i < list.Count; i++)
  972. {
  973. JsonData dr = list[i];
  974. string MakerCode = dr[0].ToString();
  975. string RiskFlag = dr[2].ToString();
  976. string RiskNote = dr[3].ToString();
  977. UserForMakerCode UserCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  978. if (UserCode != null)
  979. {
  980. Users User = db.Users.FirstOrDefault(m => m.Id == UserCode.UserId);
  981. if (User != null)
  982. {
  983. User.RiskFlag = ulong.Parse(function.CheckInt(RiskFlag));
  984. User.RiskRemark = RiskNote;
  985. }
  986. }
  987. }
  988. db.SaveChanges();
  989. }
  990. else if (Kind == 4)
  991. {
  992. string error = "";
  993. for (int i = 1; i < list.Count; i++)
  994. {
  995. JsonData dr = list[i];
  996. string MakerCode = dr[0].ToString();
  997. string OperationAmt = dr[2].ToString();//操作金额
  998. string OperationType = dr[3].ToString();//操作类型
  999. UserForMakerCode UserCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  1000. if (UserCode != null)
  1001. {
  1002. Users User = db.Users.FirstOrDefault(m => m.Id == UserCode.UserId);
  1003. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == User.Id);
  1004. if (account == null)
  1005. {
  1006. account = db.UserAccount.Add(new UserAccount()
  1007. {
  1008. Id = User.Id,
  1009. UserId = User.Id,
  1010. }).Entity;
  1011. db.SaveChanges();
  1012. }
  1013. if (User != null)
  1014. {
  1015. decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
  1016. decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
  1017. decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
  1018. int ChangeType = 0;
  1019. if (OperationType == "1" && Convert.ToDecimal(OperationAmt) <= account.BalanceAmount)
  1020. {
  1021. account.BalanceAmount -= Convert.ToDecimal(OperationAmt);
  1022. account.FreezeAmount += Convert.ToDecimal(OperationAmt);
  1023. ChangeType = 61;
  1024. }
  1025. else if (OperationType == "1" && Convert.ToDecimal(OperationAmt) > account.BalanceAmount)
  1026. {
  1027. error += "以下操作失败" + User.MakerCode + ',' + User.RealName + "冻结金额大于余额" + '|' + '\n';
  1028. }
  1029. else if (OperationType == "2" && Convert.ToDecimal(OperationAmt) <= account.FreezeAmount)
  1030. {
  1031. account.BalanceAmount += Convert.ToDecimal(OperationAmt);
  1032. account.FreezeAmount -= Convert.ToDecimal(OperationAmt);
  1033. ChangeType = 62;
  1034. }
  1035. else if (OperationType == "2" && Convert.ToDecimal(OperationAmt) > account.FreezeAmount)
  1036. {
  1037. error += "以下操作失败" + User.MakerCode + ',' + User.RealName + "解冻金额大于冻结金额" + '|' + '\n';
  1038. }
  1039. else if (OperationType == "3" && Convert.ToDecimal(OperationAmt) <= account.BalanceAmount)
  1040. {
  1041. account.TotalAmount -= Convert.ToDecimal(OperationAmt);
  1042. account.BalanceAmount -= Convert.ToDecimal(OperationAmt);
  1043. ChangeType = 63;
  1044. }
  1045. else if (OperationType == "3" && Convert.ToDecimal(OperationAmt) > account.BalanceAmount)
  1046. {
  1047. error += "以下操作失败" + User.MakerCode + ',' + User.RealName + "扣减金额大于余额" + '|' + '\n';
  1048. }
  1049. else if (OperationType == "4")
  1050. {
  1051. account.TotalAmount += Convert.ToDecimal(OperationAmt);
  1052. account.BalanceAmount += Convert.ToDecimal(OperationAmt);
  1053. ChangeType = 64;
  1054. }
  1055. decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
  1056. decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
  1057. decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
  1058. UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
  1059. {
  1060. CreateDate = DateTime.Now,
  1061. UpdateDate = DateTime.Now,
  1062. UserId = User.Id, //创客
  1063. ChangeType = ChangeType, //变动类型
  1064. ChangeAmount = Convert.ToDecimal(OperationAmt), //变更金额
  1065. BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
  1066. AfterTotalAmount = AfterTotalAmount, //变更后总金额
  1067. BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
  1068. AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
  1069. BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
  1070. AfterBalanceAmount = AfterBalanceAmount, //变更后余额
  1071. Remark = dr[4].ToString(),
  1072. }).Entity;
  1073. db.SaveChanges();
  1074. AddSysLog(User.Id.ToString(), "Users", "ChangeCashFreezeAmts");
  1075. db.SaveChanges();
  1076. }
  1077. }
  1078. }
  1079. db.SaveChanges();
  1080. return "warning" + error;
  1081. }
  1082. AddSysLog("0", "Users", "Import");
  1083. return "success";
  1084. }
  1085. #endregion
  1086. #region 通过队列导入数据
  1087. public IActionResult ImportByQueue(string right, string ExcelKind)
  1088. {
  1089. ViewBag.RightInfo = RightInfo;
  1090. ViewBag.right = right;
  1091. ViewBag.ExcelKind = ExcelKind;
  1092. return View();
  1093. }
  1094. /// <summary>
  1095. /// 通过队列导入数据
  1096. /// </summary>
  1097. /// <param name="ExcelPath"></param>
  1098. [HttpPost]
  1099. public string ImportByQueuePost(string ExcelPath, int Kind = 0)
  1100. {
  1101. string key = function.MD5_16(Guid.NewGuid().ToString());
  1102. RedisDbconn.Instance.AddList("BatchEditUserAmountQueue", ExcelPath + "#cut#" + Kind + "#cut#" + key + "#cut#" + SysUserName);
  1103. return "success|" + key;
  1104. }
  1105. public string CheckImport(string key)
  1106. {
  1107. string result = RedisDbconn.Instance.Get<string>("BatchEditUserAmountCheckImport:" + key);
  1108. if (!string.IsNullOrEmpty(result))
  1109. {
  1110. string[] datalist = result.Split('|');
  1111. if (datalist[0] == "success")
  1112. {
  1113. return result;
  1114. }
  1115. return datalist[0];
  1116. }
  1117. return "0";
  1118. }
  1119. public Dictionary<string, object> CheckImportV2(string key)
  1120. {
  1121. Dictionary<string, object> Obj = new Dictionary<string, object>();
  1122. string result = RedisDbconn.Instance.Get<string>("BatchEditUserAmountCheckImport:" + key);
  1123. if (!string.IsNullOrEmpty(result))
  1124. {
  1125. string[] datalist = result.Split('|');
  1126. if (datalist[0] == "success")
  1127. {
  1128. List<string> errList = RedisDbconn.Instance.GetList<string>("ErrList" + key);
  1129. if (errList.Count > 0)
  1130. {
  1131. Obj.Add("status", 2);
  1132. Obj.Add("errList", errList);
  1133. }
  1134. else
  1135. {
  1136. Obj.Add("status", 1);
  1137. Obj.Add("data", result);
  1138. }
  1139. return Obj;
  1140. }
  1141. Obj.Add("status", 0);
  1142. Obj.Add("data", datalist[0]);
  1143. return Obj;
  1144. }
  1145. Obj.Add("status", -1);
  1146. Obj.Add("data", "执行中...");
  1147. return Obj;
  1148. }
  1149. #endregion
  1150. #region 导出Excel
  1151. /// <summary>
  1152. /// 导出Excel
  1153. /// </summary>
  1154. /// <returns></returns>
  1155. 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)
  1156. {
  1157. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1158. Fields.Add("MakerCode", "1"); //创客编号
  1159. Fields.Add("RealName", "1"); //创客名称
  1160. Fields.Add("Mobile", "1"); //手机号
  1161. Fields.Add("CertId", "1"); //身份证号码
  1162. Fields.Add("CreateDate", "3"); //注册时间
  1163. Fields.Add("SettleAmount", "3"); //结算金额
  1164. Fields.Add("CashFreezeAmt", "3"); //冻结金额
  1165. Fields.Add("UserLevel", "0"); //创客等级
  1166. string condition = " and Status>-1";
  1167. //直属创客编号
  1168. if (!string.IsNullOrEmpty(ParentMakerCode))
  1169. {
  1170. condition += " and Id in (select UserId from UserForMakerCode where MakerCode='" + ParentMakerCode + "')";
  1171. }
  1172. //直属创客名称
  1173. if (!string.IsNullOrEmpty(ParentRealName))
  1174. {
  1175. condition += " and Id in (select UserId from UserForRealName where RealName='" + ParentRealName + "')";
  1176. }
  1177. //实名状态
  1178. if (!string.IsNullOrEmpty(AuthFlagSelect))
  1179. {
  1180. condition += " and AuthFlag=" + AuthFlagSelect;
  1181. }
  1182. //顶级创客
  1183. if (TopUserId > 0)
  1184. {
  1185. condition += " and ParentNav like '," + TopUserId + ",%'";
  1186. }
  1187. //风控标识
  1188. if (!string.IsNullOrEmpty(RiskFlagSelect))
  1189. {
  1190. condition += " and RiskFlag=" + RiskFlagSelect;
  1191. }
  1192. //商户创客类型
  1193. if (!string.IsNullOrEmpty(MerchantTypeSelect))
  1194. {
  1195. condition += " and MerchantType=" + MerchantTypeSelect;
  1196. }
  1197. if (SelfId > 0)
  1198. {
  1199. Users self = db.Users.FirstOrDefault(m => m.Id == SelfId);
  1200. if (self != null)
  1201. {
  1202. string ParentNav = function.CheckNull(self.ParentNav);
  1203. condition += " and Id in (" + ParentNav.Trim(',').Replace(",,", ",") + ")";
  1204. }
  1205. }
  1206. if (ParentId > 0)
  1207. {
  1208. condition += " and ParentUserId=" + ParentId;
  1209. }
  1210. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, "Id desc", "True", 1, 20000, condition, "MakerCode,RealName,ParentUserId,ParentNav,UserLevel,SettleAmount,CashFreezeAmt,CertId,Mobile,MerchantType,MerchantDate,AuthFlag,RiskFlag,CreateDate", false);
  1211. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1212. foreach (Dictionary<string, object> dic in diclist)
  1213. {
  1214. dic["AuthFlag"] = dic["AuthFlag"].ToString() == "1" ? "已实名" : "未实名";
  1215. dic["RiskFlag"] = dic["RiskFlag"].ToString() == "1" ? "已风控" : "未风控";
  1216. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  1217. dic["MerchantType"] = RelationClassForConst.GetMerchantTypeInfo(int.Parse(dic["MerchantType"].ToString()));
  1218. int ParentUserId = int.Parse(dic["ParentUserId"].ToString());
  1219. Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
  1220. dic["ParentMakerCode"] = puser.MakerCode;
  1221. dic["ParentRealName"] = puser.RealName;
  1222. string ParentNav = dic["ParentNav"].ToString();
  1223. if (!string.IsNullOrEmpty(ParentNav))
  1224. {
  1225. string[] list = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  1226. if (list.Length > 1)
  1227. {
  1228. int TopId = int.Parse(function.CheckInt(list[1]));
  1229. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopId) ?? new Users();
  1230. dic["TopMakerCode"] = tuser.MakerCode;
  1231. dic["TopRealName"] = tuser.RealName;
  1232. }
  1233. }
  1234. dic.Remove("ParentUserId");
  1235. dic.Remove("ParentNav");
  1236. }
  1237. Dictionary<string, object> result = new Dictionary<string, object>();
  1238. result.Add("Status", "1");
  1239. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1240. result.Add("Obj", diclist);
  1241. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  1242. ReturnFields.Add("MakerCode", "创客编号");
  1243. ReturnFields.Add("RealName", "创客姓名");
  1244. ReturnFields.Add("UserLevel", "创客等级");
  1245. ReturnFields.Add("SettleAmount", "提现金额(元)");
  1246. ReturnFields.Add("CashFreezeAmt", "冻结金额(元)");
  1247. ReturnFields.Add("CertId", "身份证号");
  1248. ReturnFields.Add("Mobile", "联系手机");
  1249. ReturnFields.Add("MerchantType", "商户创客类型");
  1250. ReturnFields.Add("MerchantDate", "成为商户创客时间");
  1251. ReturnFields.Add("ParentMakerCode", "直属创客编号");
  1252. ReturnFields.Add("ParentRealName", "直属创客名称");
  1253. ReturnFields.Add("TopMakerCode", "顶级创客编号");
  1254. ReturnFields.Add("TopRealName", "顶级创客名称");
  1255. ReturnFields.Add("AuthFlag", "实名状态");
  1256. ReturnFields.Add("RiskFlag", "风控状态");
  1257. ReturnFields.Add("CreateDate", "注册时间");
  1258. result.Add("Fields", ReturnFields);
  1259. AddSysLog("0", "Users", "ExportExcel");
  1260. return Json(result);
  1261. }
  1262. #endregion
  1263. #region 直属创客导出Excel
  1264. /// <summary>
  1265. /// 直属创客导出Excel
  1266. /// </summary>
  1267. /// <returns></returns>
  1268. public JsonResult ExportZSExcel(Users data, string MakerCode, string ParentMakerCode)
  1269. {
  1270. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1271. string condition = " and Status>-1";
  1272. //创客编号
  1273. if (!string.IsNullOrEmpty(MakerCode))
  1274. {
  1275. condition += " and ParentUserId in (select UserId from UserForMakerCode where MakerCode='" + MakerCode + "')";
  1276. }
  1277. //直属创客编号
  1278. if (!string.IsNullOrEmpty(ParentMakerCode))
  1279. {
  1280. condition += " and ParentUserId in (select UserId from UserForMakerCode where MakerCode='" + ParentMakerCode + "')";
  1281. }
  1282. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, "Id desc", "True", 1, 20000, condition, "Id,MakerCode,RealName,UserLevel", false);
  1283. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1284. foreach (Dictionary<string, object> dic in diclist)
  1285. {
  1286. int Id = int.Parse(dic["Id"].ToString());
  1287. Users userZS = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  1288. dic["MakerCode"] = userZS.MakerCode;
  1289. dic["RealName"] = userZS.RealName;
  1290. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  1291. }
  1292. Dictionary<string, object> result = new Dictionary<string, object>();
  1293. result.Add("Status", "1");
  1294. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1295. result.Add("Obj", diclist);
  1296. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  1297. ReturnFields.Add("Id", "Id");
  1298. ReturnFields.Add("MakerCode", "创客编号");
  1299. ReturnFields.Add("RealName", "创客姓名");
  1300. ReturnFields.Add("UserLevel", "创客等级");
  1301. result.Add("Fields", ReturnFields);
  1302. AddSysLog("0", "Users", "ExportZSExcel");
  1303. return Json(result);
  1304. }
  1305. #endregion
  1306. #region 上级创客导出Excel
  1307. /// <summary>
  1308. /// 上级创客导出Excel
  1309. /// </summary>
  1310. /// <returns></returns>
  1311. public JsonResult ExportSJExcel(Users data, string MakerCode, string ParentMakerCode)
  1312. {
  1313. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1314. string condition = " and Status>-1";
  1315. //创客编号
  1316. if (!string.IsNullOrEmpty(MakerCode))
  1317. {
  1318. var query = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  1319. Users self = db.Users.FirstOrDefault(m => m.Id == query.UserId);
  1320. if (self != null)
  1321. {
  1322. string ParentNav = function.CheckNull(self.ParentNav);
  1323. condition += " and Id in (" + ParentNav.Trim(',').Replace(",,", ",") + ")";
  1324. }
  1325. }
  1326. //直属创客编号
  1327. if (!string.IsNullOrEmpty(ParentMakerCode))
  1328. {
  1329. var query = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == ParentMakerCode);
  1330. Users self = db.Users.FirstOrDefault(m => m.Id == query.UserId);
  1331. if (self != null)
  1332. {
  1333. string ParentNav = function.CheckNull(self.ParentNav);
  1334. condition += " and Id in (" + ParentNav.Trim(',').Replace(",,", ",") + ")";
  1335. }
  1336. }
  1337. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, "Id desc", "True", 1, 20000, condition, "Id,MakerCode,RealName,UserLevel", false);
  1338. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1339. foreach (Dictionary<string, object> dic in diclist)
  1340. {
  1341. int Id = int.Parse(dic["Id"].ToString());
  1342. Users userSJ = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  1343. dic["MakerCode"] = userSJ.MakerCode;
  1344. dic["RealName"] = userSJ.RealName;
  1345. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  1346. }
  1347. Dictionary<string, object> result = new Dictionary<string, object>();
  1348. result.Add("Status", "1");
  1349. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1350. result.Add("Obj", diclist);
  1351. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  1352. ReturnFields.Add("Id", "Id");
  1353. ReturnFields.Add("MakerCode", "创客编号");
  1354. ReturnFields.Add("RealName", "创客姓名");
  1355. ReturnFields.Add("UserLevel", "创客等级");
  1356. result.Add("Fields", ReturnFields);
  1357. AddSysLog("0", "Users", "ExportSJExcel");
  1358. return Json(result);
  1359. }
  1360. #endregion
  1361. #region 同步数据
  1362. /// <summary>
  1363. /// 同步数据
  1364. /// </summary>
  1365. /// <returns></returns>
  1366. public string SycnData(int Id = 0)
  1367. {
  1368. var Brands = db.KqProducts.Where(m => m.Status == 1).ToList();
  1369. foreach (var Brand in Brands)
  1370. {
  1371. PublicFunction.SycnMachineCount(Id, Brand.Id);
  1372. }
  1373. AddSysLog(Id, "Users", "SycnData");
  1374. db.SaveChanges();
  1375. return "success";
  1376. }
  1377. #endregion
  1378. #region 同步交易额
  1379. public IActionResult SycnTradeAmount(string right, int Id = 0)
  1380. {
  1381. ViewBag.RightInfo = RightInfo;
  1382. ViewBag.right = right;
  1383. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  1384. ViewBag.data = editData;
  1385. return View();
  1386. }
  1387. #endregion
  1388. #region 同步交易额
  1389. [HttpPost]
  1390. public string SycnTradeAmountDo(DateTime sdate, DateTime edate, int UserId, int BrandId)
  1391. {
  1392. if (sdate.AddMonths(1) < edate)
  1393. {
  1394. return "时间间隔不能超过1个月";
  1395. }
  1396. if (edate >= DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00"))
  1397. {
  1398. return "结束时间只能是今天之前";
  1399. }
  1400. string check = RedisDbconn.Instance.Get<string>("ResetUserTradeQueue:" + UserId + ":" + BrandId);
  1401. if (!string.IsNullOrEmpty(check))
  1402. {
  1403. return "请稍后再试";
  1404. }
  1405. try
  1406. {
  1407. 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);
  1408. RedisDbconn.Instance.Set("ResetUserTradeQueue:" + UserId + ":" + BrandId, "wait");
  1409. RedisDbconn.Instance.SetExpire("ResetUserTradeQueue:" + UserId + ":" + BrandId, 3600);
  1410. }
  1411. catch (Exception ex)
  1412. {
  1413. function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计创客的交易额异常");
  1414. return "同步异常";
  1415. }
  1416. AddSysLog("0", "Users", "SycnTradeAmountDo");
  1417. return "success";
  1418. }
  1419. #endregion
  1420. #region 创客展业城市
  1421. public IActionResult City(Users data, string right)
  1422. {
  1423. ViewBag.RightInfo = RightInfo;
  1424. ViewBag.right = right;
  1425. List<Users> TopUsers = db.Users.Where(m => m.ParentUserId == 0).ToList();
  1426. ViewBag.TopUsers = TopUsers;
  1427. return View();
  1428. }
  1429. #endregion
  1430. #region 根据条件查询创客展业城市
  1431. public JsonResult CityData(Users data, string ParentMakerCode, string ParentRealName, int TopUserId, string Areas, int page = 1, int limit = 30)
  1432. {
  1433. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1434. Fields.Add("MakerCode", "1"); //创客编号
  1435. Fields.Add("RealName", "1"); //创客名称
  1436. Fields.Add("CitySetDate", "3"); //创建时间
  1437. Fields.Add("Areas", "2"); //省市
  1438. string condition = " and Status>-1";
  1439. //直属创客编号
  1440. if (!string.IsNullOrEmpty(ParentMakerCode))
  1441. {
  1442. condition += " and Id in (select UserId from UserForMakerCode where MakerCode='" + ParentMakerCode + "')";
  1443. }
  1444. //直属创客名称
  1445. if (!string.IsNullOrEmpty(ParentRealName))
  1446. {
  1447. condition += " and Id in (select UserId from UserForRealName where RealName='" + ParentRealName + "')";
  1448. }
  1449. //顶级创客
  1450. if (TopUserId > 0)
  1451. {
  1452. condition += " and ParentNav like '," + TopUserId + ",%'";
  1453. }
  1454. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, "Id desc", "True", page, limit, condition);
  1455. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1456. foreach (Dictionary<string, object> dic in diclist)
  1457. {
  1458. int ParentUserId = int.Parse(dic["ParentUserId"].ToString());
  1459. Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
  1460. dic["ParentMakerCode"] = puser.MakerCode;
  1461. dic["ParentRealName"] = puser.RealName;
  1462. string ParentNav = dic["ParentNav"].ToString();
  1463. if (!string.IsNullOrEmpty(ParentNav))
  1464. {
  1465. int TopId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  1466. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopId) ?? new Users();
  1467. dic["TopMakerCode"] = tuser.MakerCode;
  1468. dic["TopRealName"] = tuser.RealName;
  1469. }
  1470. }
  1471. return Json(obj);
  1472. }
  1473. #endregion
  1474. #region 导出展业城市
  1475. public JsonResult ExportCity(Users data, string CreateDate, string ParentMakerCode, string ParentRealName, string AuthFlagSelect, int TopUserId, string RiskFlagSelect, string MerchantTypeSelect)
  1476. {
  1477. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1478. Fields.Add("MakerCode", "1"); //创客编号
  1479. Fields.Add("RealName", "1"); //创客名称
  1480. Fields.Add("Mobile", "1"); //手机号
  1481. Fields.Add("CertId", "1"); //身份证号码
  1482. Fields.Add("CreateDate", "3"); //注册时间
  1483. Fields.Add("SettleAmount", "3"); //结算金额
  1484. Fields.Add("CashFreezeAmt", "3"); //冻结金额
  1485. Fields.Add("UserLevel", "0"); //创客等级
  1486. string condition = " and Status>-1";
  1487. //直属创客编号
  1488. if (!string.IsNullOrEmpty(ParentMakerCode))
  1489. {
  1490. condition += " and Id in (select UserId from UserForMakerCode where MakerCode='" + ParentMakerCode + "')";
  1491. }
  1492. //直属创客名称
  1493. if (!string.IsNullOrEmpty(ParentRealName))
  1494. {
  1495. condition += " and Id in (select UserId from UserForRealName where RealName='" + ParentRealName + "')";
  1496. }
  1497. //实名状态
  1498. if (!string.IsNullOrEmpty(AuthFlagSelect))
  1499. {
  1500. condition += " and AuthFlag=" + AuthFlagSelect;
  1501. }
  1502. //顶级创客
  1503. if (TopUserId > 0)
  1504. {
  1505. condition += " and ParentNav like '," + TopUserId + ",%'";
  1506. }
  1507. //风控标识
  1508. if (!string.IsNullOrEmpty(RiskFlagSelect))
  1509. {
  1510. condition += " and RiskFlag=" + RiskFlagSelect;
  1511. }
  1512. //商户创客类型
  1513. if (!string.IsNullOrEmpty(MerchantTypeSelect))
  1514. {
  1515. condition += " and MerchantType=" + MerchantTypeSelect;
  1516. }
  1517. 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);
  1518. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1519. foreach (Dictionary<string, object> dic in diclist)
  1520. {
  1521. dic["AuthFlag"] = dic["AuthFlag"].ToString() == "1" ? "已实名" : "未实名";
  1522. dic["RiskFlag"] = dic["RiskFlag"].ToString() == "1" ? "已风控" : "未风控";
  1523. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  1524. dic["MerchantType"] = RelationClassForConst.GetMerchantTypeInfo(int.Parse(dic["MerchantType"].ToString()));
  1525. int ParentUserId = int.Parse(dic["ParentUserId"].ToString());
  1526. Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
  1527. dic["ParentMakerCode"] = puser.MakerCode;
  1528. dic["ParentRealName"] = puser.RealName;
  1529. string ParentNav = dic["ParentNav"].ToString();
  1530. if (!string.IsNullOrEmpty(ParentNav))
  1531. {
  1532. int TopId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
  1533. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopId) ?? new Users();
  1534. dic["TopMakerCode"] = tuser.MakerCode;
  1535. dic["TopRealName"] = tuser.RealName;
  1536. }
  1537. dic.Remove("ParentUserId");
  1538. dic.Remove("ParentNav");
  1539. }
  1540. Dictionary<string, object> result = new Dictionary<string, object>();
  1541. result.Add("Status", "1");
  1542. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1543. result.Add("Obj", diclist);
  1544. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  1545. ReturnFields.Add("MakerCode", "创客编号");
  1546. ReturnFields.Add("RealName", "创客姓名");
  1547. ReturnFields.Add("UserLevel", "创客等级");
  1548. ReturnFields.Add("SettleAmount", "提现金额(元)");
  1549. ReturnFields.Add("CashFreezeAmt", "冻结金额(元)");
  1550. ReturnFields.Add("CertId", "身份证号");
  1551. ReturnFields.Add("Mobile", "联系手机");
  1552. ReturnFields.Add("MerchantType", "商户创客类型");
  1553. ReturnFields.Add("MerchantDate", "成为商户创客时间");
  1554. ReturnFields.Add("ParentMakerCode", "直属创客编号");
  1555. ReturnFields.Add("ParentRealName", "直属创客名称");
  1556. ReturnFields.Add("TopMakerCode", "顶级创客编号");
  1557. ReturnFields.Add("TopRealName", "顶级创客名称");
  1558. ReturnFields.Add("AuthFlag", "实名状态");
  1559. ReturnFields.Add("RiskFlag", "风控状态");
  1560. ReturnFields.Add("CreateDate", "注册时间");
  1561. result.Add("Fields", ReturnFields);
  1562. AddSysLog("0", "Users", "ExportExcel");
  1563. return Json(result);
  1564. }
  1565. #endregion
  1566. #region 根据条件查询直属创客交易额列表
  1567. /// <summary>
  1568. /// 直属创客交易额列表
  1569. /// </summary>
  1570. /// <returns></returns>
  1571. public IActionResult Children(Users data, string right, int ParentId = 0, string MakerCode = "")
  1572. {
  1573. ViewBag.RightInfo = RightInfo;
  1574. ViewBag.right = right;
  1575. ViewBag.ParentId = ParentId.ToString();
  1576. ViewBag.MakerCode = MakerCode;
  1577. List<Users> TopUsers = db.Users.Where(m => m.ParentUserId == 0).ToList();
  1578. ViewBag.TopUsers = TopUsers;
  1579. List<UserLevelSet> Levels = db.UserLevelSet.OrderBy(m => m.Id).ToList();
  1580. ViewBag.Levels = Levels;
  1581. List<KqProducts> Brands = db.KqProducts.OrderBy(m => m.Id).ToList();
  1582. ViewBag.Brands = Brands;
  1583. return View();
  1584. }
  1585. #endregion
  1586. #region 根据条件查询直属创客交易额列表
  1587. /// <summary>
  1588. /// 直属创客交易额列表
  1589. /// </summary>
  1590. /// <returns></returns>
  1591. public JsonResult ChildrenData(Users data, int BrandSelect, string MakerCode, string CreateDateData, int ParentId = 0, int page = 1, int limit = 30)
  1592. {
  1593. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1594. WebCMSEntities db = new WebCMSEntities();
  1595. Fields.Add("MakerCode", "1"); //创客编号
  1596. int BrandId = BrandSelect;
  1597. string start = "";
  1598. string end = "";
  1599. string condition = " and Status>-1 and AuthFlag >0";
  1600. string con = " and Status>-1";
  1601. string cons = " and Status>=-1";
  1602. string sort = "Id desc";
  1603. //创客编号
  1604. if (!string.IsNullOrEmpty(MakerCode))
  1605. {
  1606. condition += " and Id in (select UserId from UserForMakerCode where MakerCode='" + MakerCode + "')";
  1607. }
  1608. if (ParentId > 0)
  1609. {
  1610. condition += " and ParentUserId=" + ParentId + " or Id=" + ParentId;
  1611. }
  1612. //时间不为空
  1613. if (!string.IsNullOrEmpty(CreateDateData))
  1614. {
  1615. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  1616. start = datelist[0].Replace("-", "");
  1617. end = datelist[1].Replace("-", "");
  1618. con += " and TradeDate>='" + start + "' and TradeDate<='" + end + "'";
  1619. cons += " and SeoKeyword >=" + start + " and SeoKeyword <=" + end;
  1620. }
  1621. //时间为空
  1622. else
  1623. {
  1624. start = DateTime.Now.ToString("yyyyMM") + "01";
  1625. end = DateTime.Now.AddMonths(1).ToString("yyyyMM") + "01";
  1626. con += " and TradeDate>='" + start + "' and TradeDate<'" + end + "'";
  1627. cons += " and SeoKeyword >=" + start + " and SeoKeyword <" + end;
  1628. }
  1629. if (!string.IsNullOrEmpty(BrandSelect.ToString()) && BrandId > 0)
  1630. {
  1631. con += " and BrandId='" + BrandId + "'";
  1632. cons += " and BrandId='" + BrandId + "'";
  1633. }
  1634. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, sort, "True", page, limit, condition);
  1635. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1636. foreach (Dictionary<string, object> dic in diclist)
  1637. {
  1638. int UId = int.Parse(dic["Id"].ToString());
  1639. var Info = GetMonthTradeForBrand(UId, start, end, BrandId);
  1640. dic["TotalAmtfc"] = Convert.ToDecimal(Info["TotalAmtfc"].ToString()) + Convert.ToDecimal(Info["YAmtfc"].ToString());
  1641. dic["DAmtfc"] = Convert.ToDecimal(Info["DAmtfc"].ToString());
  1642. dic["JAmtfc"] = Convert.ToDecimal(Info["JAmtfc"].ToString());
  1643. dic["JfAmtfc"] = Convert.ToDecimal(Info["JfAmtfc"].ToString());
  1644. dic["JCountfc"] = Convert.ToInt32(Info["JCountfc"].ToString());
  1645. dic["YAmtfc"] = Convert.ToDecimal(Info["YAmtfc"].ToString());
  1646. dic["TotalAmtwd"] = Convert.ToDecimal(Info["TotalAmtwd"].ToString()) + Convert.ToDecimal(Info["YAmtwd"].ToString());
  1647. dic["DAmtwd"] = Convert.ToDecimal(Info["DAmtwd"].ToString());
  1648. dic["JAmtwd"] = Convert.ToDecimal(Info["JAmtwd"].ToString());
  1649. dic["JfAmtwd"] = Convert.ToDecimal(Info["JfAmtwd"].ToString());
  1650. dic["JCountwd"] = Convert.ToInt32(Info["JCountwd"].ToString());
  1651. dic["YAmtwd"] = Convert.ToDecimal(Info["YAmtwd"].ToString());
  1652. dic["TotalAmtyl"] = Convert.ToDecimal(Info["TotalAmtyl"].ToString()) + Convert.ToDecimal(Info["YAmtyl"].ToString());
  1653. dic["DAmtyl"] = Convert.ToDecimal(Info["DAmtyl"].ToString());
  1654. dic["JAmtyl"] = Convert.ToDecimal(Info["JAmtyl"].ToString());
  1655. dic["JfAmtyl"] = Convert.ToDecimal(Info["JfAmtyl"].ToString());
  1656. dic["JCountyl"] = Convert.ToInt32(Info["JCountyl"].ToString());
  1657. dic["YAmtyl"] = Convert.ToDecimal(Info["YAmtyl"].ToString());
  1658. dic["TotalAmtyl2"] = Convert.ToDecimal(Info["TotalAmtyl2"].ToString());
  1659. dic["DAmtyl2"] = Convert.ToDecimal(Info["DAmtyl2"].ToString());
  1660. dic["JAmtyl2"] = Convert.ToDecimal(Info["JAmtyl2"].ToString());
  1661. dic["JfAmtyl2"] = Convert.ToDecimal(Info["JfAmtyl2"].ToString());
  1662. dic["JCountyl2"] = Convert.ToInt32(Info["JCountyl2"].ToString());
  1663. dic["YAmtyl2"] = Convert.ToDecimal(Info["YAmtyl2"].ToString());
  1664. dic["TotalPosAmount"] = Convert.ToDecimal(dic["TotalAmtfc"].ToString()) + Convert.ToDecimal(dic["TotalAmtwd"].ToString()) + Convert.ToDecimal(dic["TotalAmtyl"].ToString()) + Convert.ToDecimal(dic["TotalAmtyl2"].ToString());
  1665. dic["TBCount"] = Info["TBCount"].ToString();
  1666. dic["TACount"] = Info["TACount"].ToString();
  1667. }
  1668. //个人
  1669. //扶持期
  1670. decimal TotalAmtfc = 0;
  1671. decimal DAmtfc = 0;
  1672. decimal JAmtfc = 0;
  1673. decimal JfAmtfc = 0;
  1674. int JCountfc = 0;
  1675. decimal YAmtfc = 0;
  1676. //稳定期
  1677. decimal TotalAmtwd = 0;
  1678. decimal DAmtwd = 0;
  1679. decimal JAmtwd = 0;
  1680. decimal JfAmtwd = 0;
  1681. int JCountwd = 0;
  1682. decimal YAmtwd = 0;
  1683. //盈利期(稳定期A)
  1684. decimal TotalAmtyl = 0;
  1685. decimal DAmtyl = 0;
  1686. decimal JAmtyl = 0;
  1687. decimal JfAmtyl = 0;
  1688. int JCountyl = 0;
  1689. decimal YAmtyl = 0;
  1690. //盈利期(稳定期B)
  1691. decimal TotalAmtyls = 0;
  1692. decimal DAmtyls = 0;
  1693. decimal JAmtyls = 0;
  1694. decimal JfAmtyls = 0;
  1695. int JCountyls = 0;
  1696. decimal YAmtyls = 0;
  1697. decimal TotalPosAmount = 0;
  1698. //团队
  1699. //扶持期
  1700. decimal TotalAmtfc1 = 0;
  1701. decimal DAmtfc1 = 0;
  1702. decimal JAmtfc1 = 0;
  1703. decimal JfAmtfc1 = 0;
  1704. int JCountfc1 = 0;
  1705. decimal YAmtfc1 = 0;
  1706. //稳定期
  1707. decimal TotalAmtwd1 = 0;
  1708. decimal DAmtwd1 = 0;
  1709. decimal JAmtwd1 = 0;
  1710. decimal JfAmtwd1 = 0;
  1711. int JCountwd1 = 0;
  1712. decimal YAmtwd1 = 0;
  1713. //盈利期(稳定期A)
  1714. decimal TotalAmtyl1 = 0;
  1715. decimal DAmtyl1 = 0;
  1716. decimal JAmtyl1 = 0;
  1717. decimal JfAmtyl1 = 0;
  1718. int JCountyl1 = 0;
  1719. decimal YAmtyl1 = 0;
  1720. //盈利期(稳定期B)
  1721. decimal TotalAmtyl1s = 0;
  1722. decimal DAmtyl1s = 0;
  1723. decimal JAmtyl1s = 0;
  1724. decimal JfAmtyl1s = 0;
  1725. int JCountyl1s = 0;
  1726. decimal YAmtyl1s = 0;
  1727. decimal TotalPosAmount1 = 0;
  1728. int PBCount = 0;
  1729. int PACount = 0;
  1730. int TBCount = 0;
  1731. int TACount = 0;
  1732. Dictionary<string, object> other = new Dictionary<string, object>();
  1733. DataTable dt = CustomerSqlConn.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)),Sum(ProfitDirectTradeAmt + ProfitDirectDebitTradeAmt),Sum(if (QueryCount = 0,ProfitDirectTradeAmt,0)),Sum(if (QueryCount = 0,ProfitDirectDebitTradeAmt - ProfitDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,ProfitDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,ProfitDirectDebitCapNum,0)),Sum(if (QueryCount = 1,ProfitDirectTradeAmt,0))from TradeDaySummary where SeoTitle = 'self' and UserId =" + ParentId + "" + con, MysqlConn.ReadSqlConnStr);
  1734. if (dt.Rows.Count > 0)
  1735. {
  1736. TotalAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][0].ToString()));
  1737. DAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][1].ToString()));
  1738. JAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][2].ToString()));
  1739. JfAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][3].ToString()));
  1740. JCountfc = Convert.ToInt32(function.CheckInt(dt.Rows[0][4].ToString()));
  1741. YAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][5].ToString()));
  1742. TotalAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][6].ToString()));
  1743. DAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][7].ToString()));
  1744. JAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][8].ToString()));
  1745. JfAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][9].ToString()));
  1746. JCountwd = Convert.ToInt32(function.CheckInt(dt.Rows[0][10].ToString()));
  1747. YAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][11].ToString()));
  1748. TotalAmtyl = Convert.ToDecimal(function.CheckNum(dt.Rows[0][12].ToString()));
  1749. DAmtyl = Convert.ToDecimal(function.CheckNum(dt.Rows[0][13].ToString()));
  1750. JAmtyl = Convert.ToDecimal(function.CheckNum(dt.Rows[0][14].ToString()));
  1751. JfAmtyl = Convert.ToDecimal(function.CheckNum(dt.Rows[0][15].ToString()));
  1752. JCountyl = Convert.ToInt32(function.CheckInt(dt.Rows[0][16].ToString()));
  1753. YAmtyl = Convert.ToDecimal(function.CheckNum(dt.Rows[0][17].ToString()));
  1754. }
  1755. dt = CustomerSqlConn.dtable("SELECT Sum(ProfitTradeAmt + ProfitDebitTradeAmt),Sum(if (QueryCount = 0,ProfitTradeAmt,0)),Sum(if (QueryCount = 0,ProfitDebitTradeAmt - ProfitDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,ProfitDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,ProfitDebitCapNum,0)),Sum(if (QueryCount = 1,ProfitTradeAmt,0)) from TradeDaySummary2 where SeoTitle = 'self' and UserId =" + ParentId + "" + con, MysqlConn.ReadSqlConnStr);
  1756. if (dt.Rows.Count > 0)
  1757. {
  1758. TotalAmtyls = Convert.ToDecimal(function.CheckNum(dt.Rows[0][0].ToString()));
  1759. DAmtyls = Convert.ToDecimal(function.CheckNum(dt.Rows[0][1].ToString()));
  1760. JAmtyls = Convert.ToDecimal(function.CheckNum(dt.Rows[0][2].ToString()));
  1761. JfAmtyls = Convert.ToDecimal(function.CheckNum(dt.Rows[0][3].ToString()));
  1762. JCountyls = Convert.ToInt32(function.CheckInt(dt.Rows[0][4].ToString()));
  1763. YAmtyls = Convert.ToDecimal(function.CheckNum(dt.Rows[0][5].ToString()));
  1764. }
  1765. TotalPosAmount = TotalAmtfc + TotalAmtwd + TotalAmtyl + TotalAmtyls;
  1766. //统计激活数(个人、团队)
  1767. dt = CustomerSqlConn.dtable("SELECT SUM(if(SeoTitle='self',ActiveBuddyMerStatus,0)),SUM(if(SeoTitle='team',ActiveBuddyMerStatus,0)) FROM UserTradeMonthSummary WHERE UserId= " + ParentId + "" + cons, MysqlConn.ReadSqlConnStr);
  1768. if (dt.Rows.Count > 0)
  1769. {
  1770. PACount = Convert.ToInt32(function.CheckNum(dt.Rows[0][0].ToString()));
  1771. TACount = Convert.ToInt32(function.CheckNum(dt.Rows[0][1].ToString()));
  1772. }
  1773. DataTable dts = CustomerSqlConn.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)),Sum(ProfitNonDirectTradeAmt + ProfitNonDirectDebitTradeAmt),Sum(if (QueryCount = 0,ProfitNonDirectTradeAmt,0)),Sum(if (QueryCount = 0,ProfitNonDirectDebitTradeAmt - ProfitNonDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,ProfitNonDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,ProfitNonDirectDebitCapNum,0)),Sum(if (QueryCount = 1,ProfitNonDirectTradeAmt,0))from TradeDaySummary where SeoTitle = 'team' and UserId =" + ParentId + "" + con, MysqlConn.ReadSqlConnStr);
  1774. if (dts.Rows.Count > 0)
  1775. {
  1776. TotalAmtfc1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][0].ToString()));
  1777. DAmtfc1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][1].ToString()));
  1778. JAmtfc1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][2].ToString()));
  1779. JfAmtfc1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][3].ToString()));
  1780. JCountfc1 = Convert.ToInt32(function.CheckInt(dts.Rows[0][4].ToString()));
  1781. YAmtfc1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][5].ToString()));
  1782. TotalAmtwd1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][6].ToString()));
  1783. DAmtwd1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][7].ToString()));
  1784. JAmtwd1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][8].ToString()));
  1785. JfAmtwd1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][9].ToString()));
  1786. JCountwd1 = Convert.ToInt32(function.CheckInt(dts.Rows[0][10].ToString()));
  1787. YAmtwd1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][11].ToString()));
  1788. TotalAmtyl1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][12].ToString()));
  1789. DAmtyl1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][13].ToString()));
  1790. JAmtyl1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][14].ToString()));
  1791. JfAmtyl1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][15].ToString()));
  1792. JCountyl1 = Convert.ToInt32(function.CheckInt(dts.Rows[0][16].ToString()));
  1793. YAmtyl1 = Convert.ToDecimal(function.CheckNum(dts.Rows[0][17].ToString()));
  1794. }
  1795. dt = CustomerSqlConn.dtable("SELECT Sum(ProfitTradeAmt + ProfitDebitTradeAmt),Sum(if (QueryCount = 0,ProfitTradeAmt,0)),Sum(if (QueryCount = 0,ProfitDebitTradeAmt - ProfitDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,ProfitDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,ProfitDebitCapNum,0)),Sum(if (QueryCount = 1,ProfitTradeAmt,0)) from TradeDaySummary2 where SeoTitle = 'team' and UserId =" + ParentId + "" + con, MysqlConn.ReadSqlConnStr);
  1796. if (dt.Rows.Count > 0)
  1797. {
  1798. TotalAmtyl1s = Convert.ToDecimal(function.CheckNum(dt.Rows[0][0].ToString()));
  1799. DAmtyl1s = Convert.ToDecimal(function.CheckNum(dt.Rows[0][1].ToString()));
  1800. JAmtyl1s = Convert.ToDecimal(function.CheckNum(dt.Rows[0][2].ToString()));
  1801. JfAmtyl1s = Convert.ToDecimal(function.CheckNum(dt.Rows[0][3].ToString()));
  1802. JCountyl1s = Convert.ToInt32(function.CheckInt(dt.Rows[0][4].ToString()));
  1803. YAmtyl1s = Convert.ToDecimal(function.CheckNum(dt.Rows[0][5].ToString()));
  1804. }
  1805. TotalPosAmount1 = TotalAmtfc1 + TotalAmtwd1 + TotalAmtyl1 + TotalAmtyl1s;
  1806. other.Add("TotalAmtfc", TotalAmtfc);
  1807. other.Add("DAmtfc", DAmtfc);
  1808. other.Add("JAmtfc", JAmtfc);
  1809. other.Add("JfAmtfc", JfAmtfc);
  1810. other.Add("JCountfc", JCountfc);
  1811. other.Add("YAmtfc", YAmtfc);
  1812. other.Add("TotalAmtwd", TotalAmtwd);
  1813. other.Add("DAmtwd", DAmtwd);
  1814. other.Add("JAmtwd", JAmtwd);
  1815. other.Add("JfAmtwd", JfAmtwd);
  1816. other.Add("JCountwd", JCountwd);
  1817. other.Add("YAmtwd", YAmtwd);
  1818. other.Add("TotalAmtyl", TotalAmtyl);
  1819. other.Add("DAmtyl", DAmtyl);
  1820. other.Add("JAmtyl", JAmtyl);
  1821. other.Add("JfAmtyl", JfAmtyl);
  1822. other.Add("JCountyl", JCountyl);
  1823. other.Add("YAmtyl", YAmtyl);
  1824. other.Add("TotalAmtyls", TotalAmtyls);
  1825. other.Add("DAmtyls", DAmtyls);
  1826. other.Add("JAmtyls", JAmtyls);
  1827. other.Add("JfAmtyls", JfAmtyls);
  1828. other.Add("JCountyls", JCountyls);
  1829. other.Add("YAmtyls", YAmtyls);
  1830. other.Add("TotalAmtfc1", TotalAmtfc1);
  1831. other.Add("DAmtfc1", DAmtfc1);
  1832. other.Add("JAmtfc1", JAmtfc1);
  1833. other.Add("JfAmtfc1", JfAmtfc1);
  1834. other.Add("JCountfc1", JCountfc1);
  1835. other.Add("YAmtfc1", YAmtfc1);
  1836. other.Add("TotalAmtwd1", TotalAmtwd1);
  1837. other.Add("DAmtwd1", DAmtwd1);
  1838. other.Add("JAmtwd1", JAmtwd1);
  1839. other.Add("JfAmtwd1", JfAmtwd1);
  1840. other.Add("JCountwd1", JCountwd1);
  1841. other.Add("YAmtwd1", YAmtwd1);
  1842. other.Add("TotalAmtyl1", TotalAmtyl1);
  1843. other.Add("DAmtyl1", DAmtyl1);
  1844. other.Add("JAmtyl1", JAmtyl1);
  1845. other.Add("JfAmtyl1", JfAmtyl1);
  1846. other.Add("JCountyl1", JCountyl1);
  1847. other.Add("YAmtyl1", YAmtyl1);
  1848. other.Add("TotalAmtyl1s", TotalAmtyl1s);
  1849. other.Add("DAmtyl1s", DAmtyl1s);
  1850. other.Add("JAmtyl1s", JAmtyl1s);
  1851. other.Add("JfAmtyl1s", JfAmtyl1s);
  1852. other.Add("JCountyl1s", JCountyl1s);
  1853. other.Add("YAmtyl1s", YAmtyl1s);
  1854. other.Add("TotalPosAmount", TotalPosAmount);
  1855. other.Add("TotalPosAmount1", TotalPosAmount1);
  1856. other.Add("PBCount", PBCount);
  1857. other.Add("PACount", PACount);
  1858. other.Add("TBCount", TBCount);
  1859. other.Add("TACount", TACount);
  1860. db.Dispose();
  1861. obj.Add("other", other);
  1862. return Json(obj);
  1863. }
  1864. public Dictionary<string, object> GetMonthTradeForBrand(int UserId, string sTradeDate, string eTradeDate, int BrandId)
  1865. {
  1866. WebCMSEntities db = new WebCMSEntities();
  1867. string condition = " and Status>-1";
  1868. string cons = " and Status>=-1";
  1869. //产品类型
  1870. if (!string.IsNullOrEmpty(BrandId.ToString()) && BrandId > 0)
  1871. {
  1872. condition += " and BrandId =" + BrandId;
  1873. cons += " and BrandId =" + BrandId;
  1874. }
  1875. //创客Id
  1876. if (!string.IsNullOrEmpty(UserId.ToString()))
  1877. {
  1878. condition += " and UserId =" + UserId;
  1879. }
  1880. //开始时间
  1881. if (!string.IsNullOrEmpty(sTradeDate) && !string.IsNullOrEmpty(eTradeDate))
  1882. {
  1883. condition += " and TradeDate >=" + Convert.ToInt32(sTradeDate) + " and TradeDate <=" + Convert.ToInt32(eTradeDate);
  1884. cons += " and SeoKeyword >=" + Convert.ToInt32(sTradeDate) + " and SeoKeyword <=" + Convert.ToInt32(eTradeDate);
  1885. }
  1886. //结束时间
  1887. else
  1888. {
  1889. var start = DateTime.Now.ToString("yyyyMM") + "01";
  1890. condition += " and TradeDate >=" + Convert.ToInt32(start) + " and TradeDate <=" + Convert.ToInt32(eTradeDate);
  1891. cons += " and SeoKeyword >=" + Convert.ToInt32(start) + " and SeoKeyword <=" + Convert.ToInt32(eTradeDate);
  1892. }
  1893. //扶持期
  1894. decimal TotalAmtfc = 0;
  1895. decimal DAmtfc = 0;
  1896. decimal JAmtfc = 0;
  1897. decimal JfAmtfc = 0;
  1898. int JCountfc = 0;
  1899. decimal YAmtfc = 0;
  1900. //稳定期
  1901. decimal TotalAmtwd = 0;
  1902. decimal DAmtwd = 0;
  1903. decimal JAmtwd = 0;
  1904. decimal JfAmtwd = 0;
  1905. int JCountwd = 0;
  1906. decimal YAmtwd = 0;
  1907. //盈利期(稳定期A)
  1908. decimal TotalAmtyl = 0;
  1909. decimal DAmtyl = 0;
  1910. decimal JAmtyl = 0;
  1911. decimal JfAmtyl = 0;
  1912. int JCountyl = 0;
  1913. decimal YAmtyl = 0;
  1914. //盈利期(稳定期B)
  1915. decimal TotalAmtyl2 = 0;
  1916. decimal DAmtyl2 = 0;
  1917. decimal JAmtyl2 = 0;
  1918. decimal JfAmtyl2 = 0;
  1919. int JCountyl2 = 0;
  1920. decimal YAmtyl2 = 0;
  1921. decimal TotalPosAmount = 0;
  1922. int BCount = 0;
  1923. int ACount = 0;
  1924. int PBCount = 0;
  1925. int PACount = 0;
  1926. int TBCount = 0;
  1927. int TACount = 0;
  1928. Dictionary<string, object> obj = new Dictionary<string, object>();
  1929. DataTable dt = CustomerSqlConn.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)),Sum(ProfitNonDirectTradeAmt + ProfitNonDirectDebitTradeAmt),Sum(if (QueryCount = 0,ProfitNonDirectTradeAmt,0)),Sum(if (QueryCount = 0,ProfitNonDirectDebitTradeAmt - ProfitNonDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,ProfitNonDirectDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,ProfitNonDirectDebitCapNum,0)),Sum(if (QueryCount = 1,ProfitNonDirectTradeAmt,0))from TradeDaySummary where SeoTitle = 'team'" + condition, MysqlConn.ReadSqlConnStr);
  1930. if (dt.Rows.Count > 0)
  1931. {
  1932. TotalAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][0].ToString()));
  1933. DAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][1].ToString()));
  1934. JAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][2].ToString()));
  1935. JfAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][3].ToString()));
  1936. JCountfc = Convert.ToInt32(function.CheckInt(dt.Rows[0][4].ToString()));
  1937. YAmtfc = Convert.ToDecimal(function.CheckNum(dt.Rows[0][5].ToString()));
  1938. TotalAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][6].ToString()));
  1939. DAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][7].ToString()));
  1940. JAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][8].ToString()));
  1941. JfAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][9].ToString()));
  1942. JCountwd = Convert.ToInt32(function.CheckInt(dt.Rows[0][10].ToString()));
  1943. YAmtwd = Convert.ToDecimal(function.CheckNum(dt.Rows[0][11].ToString()));
  1944. TotalAmtyl = Convert.ToDecimal(function.CheckNum(dt.Rows[0][12].ToString()));
  1945. DAmtyl = Convert.ToDecimal(function.CheckNum(dt.Rows[0][13].ToString()));
  1946. JAmtyl = Convert.ToDecimal(function.CheckNum(dt.Rows[0][14].ToString()));
  1947. JfAmtyl = Convert.ToDecimal(function.CheckNum(dt.Rows[0][15].ToString()));
  1948. JCountyl = Convert.ToInt32(function.CheckInt(dt.Rows[0][16].ToString()));
  1949. YAmtyl = Convert.ToDecimal(function.CheckNum(dt.Rows[0][17].ToString()));
  1950. }
  1951. dt = CustomerSqlConn.dtable("SELECT Sum(ProfitTradeAmt + ProfitDebitTradeAmt),Sum(if (QueryCount = 0,ProfitTradeAmt,0)),Sum(if (QueryCount = 0,ProfitDebitTradeAmt - ProfitDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,ProfitDebitCapTradeAmt,0)),Sum(if (QueryCount = 0,ProfitDebitCapNum,0)),Sum(if (QueryCount = 1,ProfitTradeAmt,0)) from TradeDaySummary2 where SeoTitle = 'team'" + condition, MysqlConn.ReadSqlConnStr);
  1952. if (dt.Rows.Count > 0)
  1953. {
  1954. TotalAmtyl2 = Convert.ToDecimal(function.CheckNum(dt.Rows[0][0].ToString()));
  1955. DAmtyl2 = Convert.ToDecimal(function.CheckNum(dt.Rows[0][1].ToString()));
  1956. JAmtyl2 = Convert.ToDecimal(function.CheckNum(dt.Rows[0][2].ToString()));
  1957. JfAmtyl2 = Convert.ToDecimal(function.CheckNum(dt.Rows[0][3].ToString()));
  1958. JCountyl2 = Convert.ToInt32(function.CheckInt(dt.Rows[0][4].ToString()));
  1959. YAmtyl2 = Convert.ToDecimal(function.CheckNum(dt.Rows[0][5].ToString()));
  1960. }
  1961. TotalPosAmount = TotalAmtfc + TotalAmtwd + TotalAmtyl + TotalAmtyl2;
  1962. //统计激活数(个人、团队)
  1963. dt = CustomerSqlConn.dtable("SELECT SUM(if(SeoTitle='team',ActiveBuddyMerStatus,0)) FROM UserTradeMonthSummary WHERE UserId= " + UserId + "" + cons, MysqlConn.ReadSqlConnStr);
  1964. if (dt.Rows.Count > 0)
  1965. {
  1966. TACount = Convert.ToInt32(function.CheckNum(dt.Rows[0][0].ToString()));
  1967. }
  1968. obj.Add("TotalAmtfc", TotalAmtfc);
  1969. obj.Add("DAmtfc", DAmtfc);
  1970. obj.Add("JAmtfc", JAmtfc);
  1971. obj.Add("JfAmtfc", JfAmtfc);
  1972. obj.Add("JCountfc", JCountfc);
  1973. obj.Add("YAmtfc", YAmtfc);
  1974. obj.Add("TotalAmtwd", TotalAmtwd);
  1975. obj.Add("DAmtwd", DAmtwd);
  1976. obj.Add("JAmtwd", JAmtwd);
  1977. obj.Add("JfAmtwd", JfAmtwd);
  1978. obj.Add("JCountwd", JCountwd);
  1979. obj.Add("YAmtwd", YAmtwd);
  1980. obj.Add("TotalAmtyl", TotalAmtyl);
  1981. obj.Add("DAmtyl", DAmtyl);
  1982. obj.Add("JAmtyl", JAmtyl);
  1983. obj.Add("JfAmtyl", JfAmtyl);
  1984. obj.Add("JCountyl", JCountyl);
  1985. obj.Add("YAmtyl", YAmtyl);
  1986. obj.Add("TotalAmtyl2", TotalAmtyl2);
  1987. obj.Add("DAmtyl2", DAmtyl2);
  1988. obj.Add("JAmtyl2", JAmtyl2);
  1989. obj.Add("JfAmtyl2", JfAmtyl2);
  1990. obj.Add("JCountyl2", JCountyl2);
  1991. obj.Add("YAmtyl2", YAmtyl2);
  1992. obj.Add("TotalPosAmount", TotalPosAmount);
  1993. obj.Add("BCount", BCount);
  1994. obj.Add("ACount", ACount);
  1995. obj.Add("PBCount", PBCount);
  1996. obj.Add("PACount", PACount);
  1997. obj.Add("TBCount", TBCount);
  1998. obj.Add("TACount", TACount);
  1999. db.Dispose();
  2000. return obj;
  2001. }
  2002. #endregion
  2003. #region 未实名创客列表
  2004. /// <summary>
  2005. /// 根据条件查询未实名创客列表
  2006. /// </summary>
  2007. /// <returns></returns>
  2008. public IActionResult AuthIndex(Users data, string right)
  2009. {
  2010. ViewBag.RightInfo = RightInfo;
  2011. ViewBag.right = right;
  2012. return View();
  2013. }
  2014. #endregion
  2015. #region 根据条件查询未实名创客列表
  2016. /// <summary>
  2017. /// 未实名创客列表
  2018. /// </summary>
  2019. /// <returns></returns>
  2020. public JsonResult AuthIndexData(Users data, int page = 1, int limit = 30)
  2021. {
  2022. Dictionary<string, string> Fields = new Dictionary<string, string>();
  2023. Fields.Add("MakerCode", "1"); //创客编号
  2024. string condition = " and Status>-1 and AuthFlag=0 and RealName is not null and CertId is not null and SettleBankCardNo is not null and SettleBankName is not null";
  2025. string sort = "Id desc";
  2026. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, sort, "True", page, limit, condition);
  2027. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  2028. foreach (Dictionary<string, object> dic in diclist)
  2029. {
  2030. dic["AuthFlagName"] = dic["AuthFlag"].ToString() == "1" ? "已实名" : "未实名";
  2031. dic["RiskFlagName"] = dic["RiskFlag"].ToString() == "1" ? "已风控" : "未风控";
  2032. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  2033. dic["MerchantType"] = RelationClassForConst.GetMerchantTypeInfo(int.Parse(dic["MerchantType"].ToString()));
  2034. int ParentUserId = int.Parse(dic["ParentUserId"].ToString());
  2035. Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
  2036. dic["ParentMakerCode"] = puser.MakerCode;
  2037. dic["ParentRealName"] = puser.RealName;
  2038. string ParentNav = dic["ParentNav"].ToString();
  2039. if (!string.IsNullOrEmpty(ParentNav))
  2040. {
  2041. string[] list = ParentNav.Trim(',').Replace(",,", ",").Split(',');
  2042. if (list.Length > 1)
  2043. {
  2044. int TopId = int.Parse(function.CheckInt(list[1]));
  2045. Users tuser = db.Users.FirstOrDefault(m => m.Id == TopId) ?? new Users();
  2046. dic["TopMakerCode"] = tuser.MakerCode;
  2047. dic["TopRealName"] = tuser.RealName;
  2048. }
  2049. }
  2050. }
  2051. return Json(obj);
  2052. }
  2053. #endregion
  2054. #region 认证
  2055. /// <summary>
  2056. /// 认证
  2057. /// </summary>
  2058. /// <returns></returns>
  2059. public string Auth(string Id)
  2060. {
  2061. string[] idlist = Id.Split(new char[] { ',' });
  2062. AddSysLog(Id, "Users", "Auth");
  2063. foreach (string subid in idlist)
  2064. {
  2065. int id = int.Parse(subid);
  2066. Dictionary<string, object> Fields = new Dictionary<string, object>();
  2067. Fields.Add("AuthFlag", 1);
  2068. Fields.Add("AuthDate", DateTime.Now);
  2069. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, id);
  2070. }
  2071. db.SaveChanges();
  2072. return "success";
  2073. }
  2074. #endregion
  2075. #region 修改盟主金额
  2076. public IActionResult ChangeLeaderAmount(string right, int Id = 0)
  2077. {
  2078. ViewBag.RightInfo = RightInfo;
  2079. ViewBag.right = right;
  2080. Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
  2081. ViewBag.data = editData;
  2082. return View();
  2083. }
  2084. #endregion
  2085. #region 修改盟主金额
  2086. [HttpPost]
  2087. public string ChangeLeaderAmount(Users data, string ChangeAmount, int AmountType, string Note, int Kind)
  2088. {
  2089. int UserId = data.Id;
  2090. var Amount = Convert.ToDecimal(ChangeAmount);
  2091. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
  2092. if (account == null)
  2093. {
  2094. account = db.UserAccount.Add(new UserAccount()
  2095. {
  2096. Id = UserId,
  2097. UserId = UserId,
  2098. }).Entity;
  2099. db.SaveChanges();
  2100. }
  2101. //盟主储蓄金
  2102. if (AmountType == 1)
  2103. {
  2104. if ((Kind == 1 || Kind == 3) && Amount > account.LeaderReserve)
  2105. {
  2106. return "盟主储蓄金不足";
  2107. }
  2108. decimal BeforeLeaderReserve = account.LeaderReserve; //变更前盟主储蓄金
  2109. decimal BeforeLeaderBalanceAmount = account.LeaderBalanceAmount; //变更前盟主可提现余额
  2110. int ChangeType = 0;
  2111. if (Kind == 1 && Amount <= account.LeaderReserve)
  2112. {
  2113. account.LeaderReserve -= Amount;
  2114. account.TotalProfit += Amount;
  2115. string text = string.Format("修改盟主金额,操作人: '" + SysUserName + "_" + SysRealName + "',操作类型: '系统冻结(盟主储蓄金)',Time'" + DateTime.Now + "'");
  2116. function.WriteLog(text, "ChangeLeaderAmount");//修改盟主金额
  2117. }
  2118. else if (Kind == 1 && Amount > account.LeaderReserve)
  2119. {
  2120. return "冻结金额大于盟主储蓄金";
  2121. }
  2122. else if (Kind == 2 && Amount <= account.TotalProfit)
  2123. {
  2124. account.LeaderReserve += Amount;
  2125. account.TotalProfit -= Amount;
  2126. string text = string.Format("修改盟主金额,操作人: '" + SysUserName + "_" + SysRealName + "',操作类型: '系统解冻(盟主储蓄金)',Time'" + DateTime.Now + "'");
  2127. function.WriteLog(text, "ChangeLeaderAmount");//修改盟主金额
  2128. }
  2129. else if (Kind == 2 && Amount > account.TotalProfit)
  2130. {
  2131. return "解冻金额大于冻结金额";
  2132. }
  2133. else if (Kind == 3 && Amount <= account.LeaderReserve)
  2134. {
  2135. account.LeaderReserve -= Amount;
  2136. ChangeType = 4;
  2137. decimal AfterLeaderReserve = account.LeaderReserve; //变更后盟主储蓄金
  2138. decimal AfterLeaderBalanceAmount = account.LeaderBalanceAmount; //变更后盟主可提现余额
  2139. var query = db.LeaderReserveRecord.Add(new LeaderReserveRecord()
  2140. {
  2141. CreateDate = DateTime.Now, //创建时间
  2142. UserId = UserId, //创客
  2143. Remark = "系统扣减(盟主储蓄金)",
  2144. ChangeType = ChangeType,
  2145. BeforeAmt = BeforeLeaderReserve,
  2146. AfterAmt = AfterLeaderReserve,
  2147. ChangeAmt = Amount,
  2148. TradeDate = DateTime.Now.ToString("yyyyMMdd"),
  2149. TradeMonth = DateTime.Now.ToString("yyyyMM"),
  2150. }).Entity;
  2151. db.SaveChanges();
  2152. string text = string.Format("修改盟主金额,操作人: '" + SysUserName + "_" + SysRealName + "',操作类型: '系统扣减(盟主储蓄金)',Time'" + DateTime.Now + "'");
  2153. function.WriteLog(text, "ChangeLeaderAmount");//修改盟主金额
  2154. }
  2155. else if (Kind == 3 && Amount > account.LeaderReserve)
  2156. {
  2157. return "扣减金额大于盟主储蓄金";
  2158. }
  2159. else if (Kind == 4)
  2160. {
  2161. account.LeaderReserve += Amount;
  2162. ChangeType = 1;
  2163. decimal AfterLeaderReserve = account.LeaderReserve; //变更后总金额
  2164. decimal AfterLeaderBalanceAmount = account.LeaderBalanceAmount; //变更后冻结金额
  2165. var query = db.LeaderReserveRecord.Add(new LeaderReserveRecord()
  2166. {
  2167. CreateDate = DateTime.Now, //创建时间
  2168. UserId = UserId, //创客
  2169. Remark = "系统增加(盟主储蓄金)",
  2170. ChangeType = ChangeType,
  2171. BeforeAmt = BeforeLeaderReserve,
  2172. AfterAmt = AfterLeaderReserve,
  2173. ChangeAmt = Amount,
  2174. TradeDate = DateTime.Now.ToString("yyyyMMdd"),
  2175. TradeMonth = DateTime.Now.ToString("yyyyMM"),
  2176. }).Entity;
  2177. db.SaveChanges();
  2178. string text = string.Format("修改盟主金额,操作人: '" + SysUserName + "_" + SysRealName + "',操作类型: '系统增加(盟主储蓄金)',Time'" + DateTime.Now + "'");
  2179. function.WriteLog(text, "ChangeLeaderAmount");//修改盟主金额
  2180. }
  2181. AddSysLog(data.Id.ToString(), "Users", "ChangeLeaderAmount");
  2182. db.SaveChanges();
  2183. }
  2184. //盟主可提现余额
  2185. if (AmountType == 2)
  2186. {
  2187. if ((Kind == 1 || Kind == 3) && Amount > account.LeaderBalanceAmount)
  2188. {
  2189. return "盟主可提现余额不足";
  2190. }
  2191. decimal BeforeLeaderReserve = account.LeaderReserve; //变更前盟主储蓄金
  2192. decimal BeforeLeaderBalanceAmount = account.LeaderBalanceAmount; //变更前盟主可提现余额
  2193. int ChangeType = 0;
  2194. if (Kind == 1 && Amount <= account.LeaderReserve)
  2195. {
  2196. account.LeaderBalanceAmount -= Amount;
  2197. account.TotalServiceProfit += Amount;
  2198. string text = string.Format("修改盟主金额,操作人: '" + SysUserName + "_" + SysRealName + "',操作类型: '系统冻结(盟主可提现余额)',Time'" + DateTime.Now + "'");
  2199. function.WriteLog(text, "ChangeLeaderAmount");//修改盟主金额
  2200. }
  2201. else if (Kind == 1 && Amount > account.LeaderBalanceAmount)
  2202. {
  2203. return "冻结金额大于盟主可提现余额";
  2204. }
  2205. else if (Kind == 2 && Amount <= account.TotalServiceProfit)
  2206. {
  2207. account.LeaderBalanceAmount += Amount;
  2208. account.TotalServiceProfit -= Amount;
  2209. string text = string.Format("修改盟主金额,操作人: '" + SysUserName + "_" + SysRealName + "',操作类型: '系统解冻(盟主可提现余额)',Time'" + DateTime.Now + "'");
  2210. function.WriteLog(text, "ChangeLeaderAmount");//修改盟主金额
  2211. }
  2212. else if (Kind == 2 && Amount > account.TotalServiceProfit)
  2213. {
  2214. return "解冻金额大于冻结金额";
  2215. }
  2216. else if (Kind == 3 && Amount <= account.LeaderBalanceAmount)
  2217. {
  2218. account.LeaderBalanceAmount -= Amount;
  2219. ChangeType = 6;
  2220. decimal AfterLeaderReserve = account.LeaderReserve; //变更后总金额
  2221. decimal AfterLeaderBalanceAmount = account.LeaderBalanceAmount; //变更后冻结金额
  2222. var query = db.LeaderReserveRecord.Add(new LeaderReserveRecord()
  2223. {
  2224. CreateDate = DateTime.Now, //创建时间
  2225. UserId = UserId, //创客
  2226. Remark = "系统扣减(盟主可提现余额)",
  2227. ChangeType = ChangeType,
  2228. BeforeAmt = BeforeLeaderBalanceAmount,
  2229. AfterAmt = AfterLeaderBalanceAmount,
  2230. ChangeAmt = Amount,
  2231. TradeDate = DateTime.Now.ToString("yyyyMMdd"),
  2232. TradeMonth = DateTime.Now.ToString("yyyyMM"),
  2233. }).Entity;
  2234. db.SaveChanges();
  2235. string text = string.Format("修改盟主金额,操作人: '" + SysUserName + "_" + SysRealName + "',操作类型: '系统扣减(盟主可提现余额)',Time'" + DateTime.Now + "'");
  2236. function.WriteLog(text, "ChangeLeaderAmount");//修改盟主金额
  2237. }
  2238. else if (Kind == 3 && Amount > account.LeaderBalanceAmount)
  2239. {
  2240. return "扣减金额大于盟主可提现余额";
  2241. }
  2242. else if (Kind == 4)
  2243. {
  2244. account.LeaderBalanceAmount += Amount;
  2245. ChangeType = 5;
  2246. decimal AfterLeaderReserve = account.LeaderReserve; //变更后总金额
  2247. decimal AfterLeaderBalanceAmount = account.LeaderBalanceAmount; //变更后冻结金额
  2248. var query = db.LeaderReserveRecord.Add(new LeaderReserveRecord()
  2249. {
  2250. CreateDate = DateTime.Now, //创建时间
  2251. UserId = UserId, //创客
  2252. Remark = "系统增加(盟主可提现余额)",
  2253. ChangeType = ChangeType,
  2254. BeforeAmt = BeforeLeaderBalanceAmount,
  2255. AfterAmt = AfterLeaderBalanceAmount,
  2256. ChangeAmt = Amount,
  2257. TradeDate = DateTime.Now.ToString("yyyyMMdd"),
  2258. TradeMonth = DateTime.Now.ToString("yyyyMM"),
  2259. }).Entity;
  2260. db.SaveChanges();
  2261. string text = string.Format("修改盟主金额,操作人: '" + SysUserName + "_" + SysRealName + "',操作类型: '系统增加(盟主可提现余额)',Time'" + DateTime.Now + "'");
  2262. function.WriteLog(text, "ChangeLeaderAmount");//修改盟主金额
  2263. }
  2264. AddSysLog(data.Id.ToString(), "Users", "ChangeLeaderAmount");
  2265. db.SaveChanges();
  2266. }
  2267. return "success";
  2268. }
  2269. #endregion
  2270. #region 伞下创客列表
  2271. /// <summary>
  2272. /// 根据条件查询伞下创客列表
  2273. /// </summary>
  2274. /// <returns></returns>
  2275. public IActionResult SanIndex(Users data, string right)
  2276. {
  2277. ViewBag.RightInfo = RightInfo;
  2278. ViewBag.right = right;
  2279. List<Users> TopUsers = db.Users.Where(m => m.ParentUserId == 0).ToList();
  2280. ViewBag.TopUsers = TopUsers;
  2281. List<UserLevelSet> Levels = db.UserLevelSet.OrderBy(m => m.Id).ToList();
  2282. ViewBag.Levels = Levels;
  2283. return View();
  2284. }
  2285. #endregion
  2286. #region 根据条件查询伞下创客列表
  2287. /// <summary>
  2288. /// 伞下创客列表
  2289. /// </summary>
  2290. /// <returns></returns>
  2291. public JsonResult SanIndexData(Users data, string MakerCode, string IsLeader, string IsOp, string CreateDateData, string UserYsLevel, string UserLevel, int ShowFlag = 0, int page = 1, int limit = 30)
  2292. {
  2293. Dictionary<string, string> Fields = new Dictionary<string, string>();
  2294. if (ShowFlag == 0)
  2295. {
  2296. Dictionary<string, object> objs = new Dictionary<string, object>();
  2297. return Json(objs);
  2298. }
  2299. string condition = " and Status>-1";
  2300. //创客编号
  2301. if (!string.IsNullOrEmpty(MakerCode))
  2302. {
  2303. var userForMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode) ?? new UserForMakerCode();
  2304. if (userForMakerCode.UserId == 0)
  2305. {
  2306. return Json(new AppResultJson() { Status = "-1", Info = "未找到创客" + MakerCode + "关联数据", Data = "" });
  2307. }
  2308. var user = db.Users.FirstOrDefault(m => m.Id == userForMakerCode.UserId) ?? new Users();
  2309. if (user.Id == 0)
  2310. {
  2311. return Json(new AppResultJson() { Status = "-1", Info = "创客" + MakerCode + "不存在", Data = "" });
  2312. }
  2313. condition += " and ParentNav like '%," + user.Id + ",%'";
  2314. }
  2315. if (!string.IsNullOrEmpty(IsLeader))
  2316. {
  2317. condition += " and LeaderLevel=" + IsLeader;
  2318. }
  2319. if (!string.IsNullOrEmpty(UserYsLevel))
  2320. {
  2321. var UserIds = "";
  2322. var Rank = int.Parse(UserYsLevel);
  2323. var list = db.UserRankWhite.Where(m => m.Status > -1 && m.Rank == Rank).ToList();
  2324. foreach (var item in list)
  2325. {
  2326. UserIds += item.UserId + ",";
  2327. }
  2328. UserIds = UserIds.TrimEnd(',');
  2329. condition += " and Id IN(" + UserIds + ")";
  2330. }
  2331. if (!string.IsNullOrEmpty(UserLevel))
  2332. {
  2333. condition += " and UserLevel=" + UserLevel;
  2334. }
  2335. if (!string.IsNullOrEmpty(IsOp))
  2336. {
  2337. var UserIds = "";
  2338. DataTable dt = CustomerSqlConn.dtable("SELECT UserId FROM SysAdmin WHERE Status>-1 and Sort>0 and QueryCount>0 and AdminName!='admin'", OpConn);
  2339. foreach (DataRow item in dt.Rows)
  2340. {
  2341. UserIds += item["UserId"].ToString() + ",";
  2342. }
  2343. UserIds = UserIds.TrimEnd(',');
  2344. if (IsOp == "1")
  2345. {
  2346. condition += " and Id IN(" + UserIds + ")";
  2347. }
  2348. if (IsOp == "2")
  2349. {
  2350. condition += " and Id NOT IN(" + UserIds + ")";
  2351. }
  2352. }
  2353. if (!string.IsNullOrEmpty(CreateDateData))
  2354. {
  2355. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  2356. string start = datelist[0];
  2357. string end = datelist[1];
  2358. condition += " and CreateDate>='" + start + " 00:00:00' and CreateDate<='" + end + " 23:59:59'";
  2359. }
  2360. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("Users", Fields, "Id desc", "True", page, limit, condition);
  2361. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  2362. foreach (Dictionary<string, object> dic in diclist)
  2363. {
  2364. dic["AuthFlagName"] = dic["AuthFlag"].ToString() == "1" ? "已实名" : "未实名";
  2365. dic["RiskFlagName"] = dic["RiskFlag"].ToString() == "1" ? "已风控" : "未风控";
  2366. dic["UserLevel"] = RelationClass.GetUserLevelSetInfo(int.Parse(dic["UserLevel"].ToString()));
  2367. int UserId = int.Parse(dic["Id"].ToString());
  2368. int ParentUserId = int.Parse(dic["ParentUserId"].ToString());
  2369. Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
  2370. dic["ParentMakerCode"] = puser.MakerCode;
  2371. dic["ParentRealName"] = puser.RealName;
  2372. var userRankWhite = db.UserRankWhite.FirstOrDefault(m => m.UserId == UserId) ?? new UserRankWhite();
  2373. dic["UserYsLevel"] = RelationClass.GetUserLevelSetInfo(userRankWhite.Rank);
  2374. int LeaderLevel = int.Parse(dic["LeaderLevel"].ToString());
  2375. if (LeaderLevel == 1)
  2376. {
  2377. dic["IsLeader"] = "小盟主";
  2378. }
  2379. else if (LeaderLevel == 2)
  2380. {
  2381. dic["IsLeader"] = "大盟主";
  2382. }
  2383. else
  2384. {
  2385. dic["IsLeader"] = "";
  2386. }
  2387. var sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.Status > -1 && m.Sort > 0 && m.QueryCount > 0 && m.AdminName != "admin" && m.UserId == UserId) ?? new OpModels.SysAdmin();
  2388. if (sysAdmin.Id > 0)
  2389. {
  2390. dic["IsOp"] = sysAdmin.OpCode;
  2391. }
  2392. else
  2393. {
  2394. dic["IsOp"] = "";
  2395. }
  2396. dic["MerchantType"] = RelationClassForConst.GetMerchantTypeInfo(int.Parse(dic["MerchantType"].ToString()));
  2397. }
  2398. return Json(obj);
  2399. }
  2400. #endregion
  2401. #region 重置小分仓额度
  2402. /// <summary>
  2403. /// 重置小分仓额度
  2404. /// </summary>
  2405. /// <returns></returns>
  2406. public string SycnAmountData(int Id = 0)
  2407. {
  2408. if (Id > 0)
  2409. {
  2410. var userAccount = db.UserAccount.FirstOrDefault(m => m.Id == Id) ?? new UserAccount();
  2411. RedisDbconn.Instance.AddList("ResetSmallStoreByUserIdQueue", userAccount.Id);
  2412. }
  2413. AddSysLog(Id, "UserAccount", "SycnAmountData");
  2414. db.SaveChanges();
  2415. return "success";
  2416. }
  2417. #endregion
  2418. #region 批量查询创客信息
  2419. public IActionResult BatchSeeUserInfo(string right)
  2420. {
  2421. ViewBag.RightInfo = RightInfo;
  2422. ViewBag.right = right;
  2423. return View();
  2424. }
  2425. #endregion
  2426. #region 批量查询创客信息
  2427. public JsonResult BatchSeeUserInfoDo(string PosSns, string MerNos, int page = 1, int limit = 30)
  2428. {
  2429. var error = "";
  2430. //实际押金
  2431. Dictionary<string, object> errorInfo = new Dictionary<string, object>();
  2432. List<Dictionary<string, object>> dataList = new List<Dictionary<string, object>>();
  2433. if (string.IsNullOrEmpty(PosSns) && string.IsNullOrEmpty(MerNos))
  2434. {
  2435. Dictionary<string, object> objs = new Dictionary<string, object>();
  2436. return Json(objs);
  2437. }
  2438. else if (!string.IsNullOrEmpty(PosSns) && !string.IsNullOrEmpty(MerNos))
  2439. {
  2440. Dictionary<string, object> objs = new Dictionary<string, object>();
  2441. return Json(objs);
  2442. }
  2443. else
  2444. {
  2445. if (!string.IsNullOrEmpty(PosSns))
  2446. {
  2447. string[] PosSnsList = PosSns.Replace("\r", "").Replace("\n", ",").Replace(" ", ",").Split(',');
  2448. foreach (string PosSn in PosSnsList)
  2449. {
  2450. string SeoKeyword = "0";
  2451. Dictionary<string, object> data = new Dictionary<string, object>();
  2452. var pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == PosSn) ?? new PosMachinesTwo();
  2453. if (pos.Id > 0)
  2454. {
  2455. // error += "机具" + PosSn + "不存在" + '\n';
  2456. // }
  2457. // else
  2458. // {
  2459. var TopMakerCode = ""; //顶级创客编号
  2460. var TopRealName = ""; //顶级创客名称
  2461. var SecondMakerCode = ""; //次顶级创客编号
  2462. var SecondRealName = ""; //次顶级创客姓名
  2463. var ThirdMakerCode = ""; //次次顶级创客编号
  2464. var ThirdRealName = ""; //次次顶级创客姓名
  2465. var mer = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId) ?? new PosMerchantInfo();
  2466. var brand = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId) ?? new KqProducts();
  2467. // if (brand.Id > 0 && brand.SingleDepositApi == 0 && !string.IsNullOrEmpty(SeoKeyword))
  2468. if (brand.Id > 0 && brand.NoticeMoneyUnit == 2 && !string.IsNullOrEmpty(pos.SeoKeyword))
  2469. {
  2470. SeoKeyword = (decimal.Parse(pos.SeoKeyword) / 100).ToString();
  2471. }
  2472. else
  2473. {
  2474. SeoKeyword = pos.SeoKeyword;
  2475. }
  2476. var user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  2477. var userAccount = db.UserAccount.FirstOrDefault(m => m.Id == user.Id) ?? new UserAccount();
  2478. if (!string.IsNullOrEmpty(user.ParentNav))
  2479. {
  2480. string[] ParentNavList = user.ParentNav.Trim(',').Replace(",,", ",").Split(',');
  2481. var topUserInfo = new Users();
  2482. var secondUserInfo = new Users();
  2483. var thirdUserInfo = new Users();
  2484. if (ParentNavList.Length > 1)
  2485. {
  2486. topUserInfo = db.Users.FirstOrDefault(m => m.Id == (int.Parse(ParentNavList[1]))) ?? new Users();
  2487. if (ParentNavList.Length > 2)
  2488. {
  2489. secondUserInfo = db.Users.FirstOrDefault(m => m.Id == (int.Parse(ParentNavList[2]))) ?? new Users();
  2490. if (ParentNavList.Length > 3)
  2491. {
  2492. thirdUserInfo = db.Users.FirstOrDefault(m => m.Id == (int.Parse(ParentNavList[3]))) ?? new Users();
  2493. }
  2494. }
  2495. }
  2496. else
  2497. {
  2498. topUserInfo = db.Users.FirstOrDefault(m => m.Id == (int.Parse(ParentNavList[0]))) ?? new Users();
  2499. }
  2500. TopMakerCode = topUserInfo.MakerCode; //顶级创客编号
  2501. TopRealName = topUserInfo.RealName; //顶级创客名称
  2502. SecondMakerCode = secondUserInfo.MakerCode; //次顶级创客编号
  2503. SecondRealName = secondUserInfo.RealName; //次顶级创客姓名
  2504. ThirdMakerCode = thirdUserInfo.MakerCode; //次次顶级创客编号
  2505. ThirdRealName = thirdUserInfo.RealName; //次次顶级创客姓名
  2506. }
  2507. data["BrandName"] = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId).Name; //机具类型
  2508. data["BindingTime"] = pos.BindingTime == null ? "" : pos.BindingTime.Value.ToString("yyyy-MM-dd HH:mm:ss"); //绑定时间
  2509. data["ActivationTime"] = pos.ActivationTime == null ? "" : pos.ActivationTime.Value.ToString("yyyy-MM-dd HH:mm:ss"); //激活时间
  2510. data["MerchantName"] = mer.MerchantName; //商户姓名
  2511. // data["MerchantName"] = mer.MerchantName + " " + mer.MerRealName; //商户姓名/真实姓名
  2512. data["PosSn"] = pos.PosSn; //机具Sn
  2513. data["MerNo"] = mer.KqMerNo; //商户编号
  2514. data["PosFee"] = SeoKeyword; //服务费
  2515. data["userInfo"] = user.Id > 0 ? user.MakerCode + "_" + user.RealName : ""; //创客信息
  2516. // data["MakerCode"] = user.MakerCode; //创客编号
  2517. // data["RealName"] = user.RealName; //创客姓名
  2518. data["Mobile"] = user.Mobile; //创客手机号
  2519. data["Balance"] = userAccount.BalanceAmount; //创客账户余额
  2520. data["TopMakerCode"] = TopMakerCode; //顶级创客编号
  2521. data["TopRealName"] = TopRealName; //顶级创客名称
  2522. data["SecondMakerCode"] = SecondMakerCode; //次顶级创客编号
  2523. data["SecondRealName"] = SecondRealName; //次顶级创客姓名
  2524. data["ThirdMakerCode"] = ThirdMakerCode; //次次顶级创客编号
  2525. data["ThirdRealName"] = ThirdRealName; //次次顶级创客姓名
  2526. dataList.Add(data);
  2527. }
  2528. }
  2529. }
  2530. if (!string.IsNullOrEmpty(MerNos))
  2531. {
  2532. string[] MerNosList = MerNos.Replace("\r", "").Replace("\n", ",").Replace(" ", ",").Split(',');
  2533. foreach (string MerNo in MerNosList)
  2534. {
  2535. string SeoKeyword = "0";
  2536. Dictionary<string, object> data = new Dictionary<string, object>();
  2537. var mer = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == MerNo) ?? new PosMerchantInfo();
  2538. if (mer.Id > 0)
  2539. {
  2540. // error += "商户" + MerNo + "不存在" + '\n';
  2541. // }
  2542. // else
  2543. // {
  2544. var TopMakerCode = ""; //顶级创客编号
  2545. var TopRealName = ""; //顶级创客名称
  2546. var SecondMakerCode = ""; //次顶级创客编号
  2547. var SecondRealName = ""; //次顶级创客姓名
  2548. var ThirdMakerCode = ""; //次次顶级创客编号
  2549. var ThirdRealName = ""; //次次顶级创客姓名
  2550. var pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == mer.KqSnNo) ?? new PosMachinesTwo();
  2551. var brand = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId) ?? new KqProducts();
  2552. // if (brand.Id > 0 && brand.SingleDepositApi == 0 && !string.IsNullOrEmpty(SeoKeyword))
  2553. if (brand.Id > 0 && brand.NoticeMoneyUnit == 2 && !string.IsNullOrEmpty(pos.SeoKeyword))
  2554. {
  2555. SeoKeyword = (decimal.Parse(pos.SeoKeyword) / 100).ToString();
  2556. }
  2557. else
  2558. {
  2559. SeoKeyword = pos.SeoKeyword;
  2560. }
  2561. var user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
  2562. var userAccount = db.UserAccount.FirstOrDefault(m => m.Id == user.Id) ?? new UserAccount();
  2563. if (!string.IsNullOrEmpty(user.ParentNav))
  2564. {
  2565. string[] ParentNavList = user.ParentNav.Trim(',').Replace(",,", ",").Split(',');
  2566. var topUserInfo = new Users();
  2567. var secondUserInfo = new Users();
  2568. var thirdUserInfo = new Users();
  2569. if (ParentNavList.Length > 1)
  2570. {
  2571. topUserInfo = db.Users.FirstOrDefault(m => m.Id == (int.Parse(ParentNavList[1]))) ?? new Users();
  2572. if (ParentNavList.Length > 2)
  2573. {
  2574. secondUserInfo = db.Users.FirstOrDefault(m => m.Id == (int.Parse(ParentNavList[2]))) ?? new Users();
  2575. if (ParentNavList.Length > 3)
  2576. {
  2577. thirdUserInfo = db.Users.FirstOrDefault(m => m.Id == (int.Parse(ParentNavList[3]))) ?? new Users();
  2578. }
  2579. }
  2580. }
  2581. else
  2582. {
  2583. topUserInfo = db.Users.FirstOrDefault(m => m.Id == (int.Parse(ParentNavList[0]))) ?? new Users();
  2584. }
  2585. TopMakerCode = topUserInfo.MakerCode; //顶级创客编号
  2586. TopRealName = topUserInfo.RealName; //顶级创客名称
  2587. SecondMakerCode = secondUserInfo.MakerCode; //次顶级创客编号
  2588. SecondRealName = secondUserInfo.RealName; //次顶级创客姓名
  2589. ThirdMakerCode = thirdUserInfo.MakerCode; //次次顶级创客编号
  2590. ThirdRealName = thirdUserInfo.RealName; //次次顶级创客姓名
  2591. }
  2592. data["BrandName"] = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId).Name; //机具类型
  2593. data["BindingTime"] = pos.BindingTime == null ? "" : pos.BindingTime.Value.ToString("yyyy-MM-dd HH:mm:ss"); //绑定时间
  2594. data["ActivationTime"] = pos.ActivationTime == null ? "" : pos.ActivationTime.Value.ToString("yyyy-MM-dd HH:mm:ss"); //激活时间
  2595. data["MerchantName"] = mer.MerchantName; //商户姓名
  2596. // data["MerchantName"] = mer.MerchantName + " " + mer.MerRealName; //商户姓名/真实姓名
  2597. data["PosSn"] = pos.PosSn; //机具Sn
  2598. data["MerNo"] = mer.KqMerNo; //商户编号
  2599. data["PosFee"] = SeoKeyword; //服务费
  2600. data["userInfo"] = user.Id > 0 ? user.MakerCode + "_" + user.RealName : ""; //创客信息
  2601. // data["MakerCode"] = user.MakerCode; //创客编号
  2602. // data["RealName"] = user.RealName; //创客姓名
  2603. data["Mobile"] = user.Mobile; //创客手机号
  2604. data["Balance"] = userAccount.BalanceAmount; //创客账户余额
  2605. data["TopMakerCode"] = TopMakerCode; //顶级创客编号
  2606. data["TopRealName"] = TopRealName; //顶级创客名称
  2607. data["SecondMakerCode"] = SecondMakerCode; //次顶级创客编号
  2608. data["SecondRealName"] = SecondRealName; //次顶级创客姓名
  2609. data["ThirdMakerCode"] = ThirdMakerCode; //次次顶级创客编号
  2610. data["ThirdRealName"] = ThirdRealName; //次次顶级创客姓名
  2611. dataList.Add(data);
  2612. }
  2613. }
  2614. }
  2615. }
  2616. Dictionary<string, object> obj = new Dictionary<string, object>();
  2617. obj.Add("code", 0);
  2618. obj.Add("msg", "");
  2619. obj.Add("count", dataList.Count);
  2620. obj.Add("data", dataList);
  2621. return Json(obj);
  2622. }
  2623. #endregion
  2624. #region 批量查询创客信息快捷导出Excel
  2625. public IActionResult ExportBatchSeeUserInfoExcel(string right)
  2626. {
  2627. ViewBag.RightInfo = RightInfo;
  2628. ViewBag.right = right;
  2629. return View();
  2630. }
  2631. [HttpPost]
  2632. public string ExportBatchSeeUserInfoExcelDo(string PosSns, string MerNos)
  2633. {
  2634. var sql = "";
  2635. if (string.IsNullOrEmpty(PosSns) && string.IsNullOrEmpty(MerNos))
  2636. {
  2637. return "请输入查询内容";
  2638. }
  2639. else if (!string.IsNullOrEmpty(PosSns) && !string.IsNullOrEmpty(MerNos))
  2640. {
  2641. return "不能同时输入机具Sn和商户编号";
  2642. }
  2643. else
  2644. {
  2645. if (!string.IsNullOrEmpty(PosSns))
  2646. {
  2647. var posIds = "";
  2648. string[] PosSnsList = PosSns.Replace("\r", "").Replace("\n", ",").Replace(" ", ",").Split(',');
  2649. foreach (string PosSn in PosSnsList)
  2650. {
  2651. var pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == PosSn) ?? new PosMachinesTwo();
  2652. posIds += pos.Id + ",";
  2653. }
  2654. posIds = posIds.TrimEnd(',');
  2655. sql = "SELECT i.BrandName '机具类型',i.PosSn '机具SN',j.KqMerNo '商编',j.MerchantName '商户名称',(CASE WHEN i.posfee IS NULL THEN 0 ELSE i.posfee END) '服务费',DATE_FORMAT(i.BindingTime,'%Y-%m-%d %H:%i:%s') '绑定时间',DATE_FORMAT(i.ActivationTime,'%Y-%m-%d %H:%i:%s') '激活时间',i.userInfo '创客信息',i.Mobile '创客手机号',i.BalanceAmount '创客账户余额',i.topMakerCode '顶级创客编号',i.topRealname '顶级姓名',i.secondMakerCode '次顶级创客编号',i.secondRealname '次顶级姓名',i.thirdMakerCode '次次顶级创客编号',i.thirdRealname '次次顶级姓名' FROM(SELECT g.*,h.MakerCode thirdMakerCode,h.Realname thirdRealname FROM (SELECT e.*,f.MakerCode secondMakerCode,f.Realname secondRealname FROM(SELECT c.*,d.MakerCode topMakerCode,d.Realname topRealname FROM(SELECT a.*,c1.NAME BrandName,(CASE WHEN a.BrandId not in(2,7,10,11) THEN ROUND(CAST(a.SeoKeyword AS DECIMAL)/100, 2) ELSE a.SeoKeyword end) posfee,b.Id useId,CONCAT(b.MakerCode,'_',b.RealName) userInfo,b.Mobile,c2.BalanceAmount,b.RealName uRealName, SUBSTRING_INDEX(SUBSTRING_INDEX(b.ParentNav,',',4),',',-1) topId,SUBSTRING_INDEX(SUBSTRING_INDEX(b.ParentNav,',',6),',',-1) secondId,SUBSTRING_INDEX(SUBSTRING_INDEX(b.ParentNav,',',8),',',-1) thirdId FROM PosMachinesTwo a LEFT JOIN Users b ON a.BuyUserId=b.Id LEFT JOIN UserAccount c2 ON a.BuyUserId=c2.Id LEFT JOIN KqProducts c1 ON a.BrandId=c1.Id WHERE a.Id in(" + posIds + "))c LEFT JOIN Users d ON c.topId=d.Id) e LEFT JOIN Users f ON e.secondId=f.Id) g LEFT JOIN Users h ON g.thirdId=h.Id) i LEFT JOIN PosMerchantInfo j ON i.BindMerchantId=j.Id";
  2656. }
  2657. if (!string.IsNullOrEmpty(MerNos))
  2658. {
  2659. var merIds = "";
  2660. string[] MerNosList = MerNos.Replace("\r", "").Replace("\n", ",").Replace(" ", ",").Split(',');
  2661. foreach (string MerNo in MerNosList)
  2662. {
  2663. var mer = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == MerNo) ?? new PosMerchantInfo();
  2664. merIds += mer.Id + ",";
  2665. }
  2666. merIds = merIds.TrimEnd(',');
  2667. sql = "SELECT i.BrandName '机具类型',i.KqSnNo '机具SN',i.KqMerNo '商编',i.MerchantName '商户名称',(CASE WHEN i.SeoKeyword IS NULL THEN 0 ELSE i.SeoKeyword END) '服务费',DATE_FORMAT(i.BindingTime,'%Y-%m-%d %H:%i:%s') '绑定时间',DATE_FORMAT(i.ActivationTime,'%Y-%m-%d %H:%i:%s') '激活时间',i.userInfo '创客信息',i.Mobile '创客手机号',i.BalanceAmount '创客账户余额',i.topMakerCode '顶级创客编号',i.topRealname '顶级姓名',i.secondMakerCode '次顶级创客编号',i.secondRealname '次顶级姓名',j.MakerCode '次次顶级创客编号',j.Realname '次次顶级姓名' FROM(SELECT g.*,h.MakerCode secondMakerCode,h.Realname secondRealname FROM(SELECT e.*,f.MakerCode topMakerCode,f.RealName topRealName FROM(SELECT c.*,CONCAT(d.MakerCode,'_',d.RealName) userInfo,d.Mobile,SUBSTRING_INDEX(SUBSTRING_INDEX(d.ParentNav,',',4),',',-1) topId,SUBSTRING_INDEX(SUBSTRING_INDEX(d.ParentNav,',',6),',',-1) secondId,SUBSTRING_INDEX(SUBSTRING_INDEX(d.ParentNav,',',8),',',-1) thirdId FROM(SELECT a.KqMerNo,a.KqSnNo,a.MerchantName,(CASE WHEN b.BrandId not in(2,7,10,11) THEN ROUND(CAST(b.SeoKeyword AS DECIMAL)/100, 2) ELSE b.SeoKeyword end) SeoKeyword,b.BindingTime,b.ActivationTime,b.BuyUserId,c1.Name BrandName,c2.BalanceAmount FROM PosMerchantInfo a LEFT JOIN PosMachinesTwo b ON a.KqSnNo=b.PosSn LEFT JOIN UserAccount c2 ON b.BuyUserId=c2.Id LEFT JOIN KqProducts c1 ON b.BrandId=c1.Id WHERE a.Id in(" + merIds + "))c LEFT JOIN Users d ON c.BuyUserId=d.Id) e LEFT JOIN Users f ON e.topId=f.Id) g LEFT JOIN Users h ON g.secondId=h.Id) i LEFT JOIN Users j ON i.thirdId=j.Id";
  2668. }
  2669. }
  2670. var sysAdmin = bsdb.SysAdmin.FirstOrDefault(m => m.AdminName == SysUserName && m.Status > -1);
  2671. var FileName = "批量查询创客信息" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  2672. string SendData = "{\"Operater\":\"" + sysAdmin.Id + "\",\"SqlString\":\"" + sql + "\",\"FileName\":\"" + FileName + "\",\"MaxCount\":\"0\"}";
  2673. RedisDbconn.Instance.AddList("ExportQueue", SendData);
  2674. AddSysLog("0", "Users", "ExportBatchSeeUserInfoExcelDo");
  2675. return "success";
  2676. }
  2677. #endregion
  2678. #region 注销时间提前
  2679. public string SetLogoutDate(int Id)
  2680. {
  2681. Dictionary<string, object> Fields = new Dictionary<string, object>();
  2682. Fields.Add("LogOutDate", DateTime.Now.AddDays(-31));
  2683. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("Users", Fields, Id);
  2684. AddSysLog(Id, "Users", "SetLogoutDate");
  2685. return "success";
  2686. }
  2687. #endregion
  2688. }
  2689. }