SysAdminOperateController.cs 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864
  1. using System.ComponentModel;
  2. using System.Runtime.CompilerServices;
  3. /*
  4. * 运营中心
  5. */
  6. using System;
  7. using System.Web;
  8. using System.Collections.Generic;
  9. using System.Diagnostics;
  10. using System.Linq;
  11. using System.Threading.Tasks;
  12. using Microsoft.AspNetCore.Mvc;
  13. using Microsoft.AspNetCore.Http;
  14. using Microsoft.Extensions.Logging;
  15. using Microsoft.Extensions.Options;
  16. using MySystem.OpModels;
  17. using Library;
  18. using LitJson;
  19. using MySystemLib;
  20. namespace MySystem.Areas.Admin.Controllers
  21. {
  22. [Area("Admin")]
  23. [Route("Admin/[controller]/[action]")]
  24. public class SysAdminOperateController : BaseController
  25. {
  26. public SysAdminOperateController(IHttpContextAccessor accessor, ILogger<BaseController> logger, IOptions<Setting> setting) : base(accessor, logger, setting)
  27. {
  28. }
  29. #region 运营中心列表
  30. /// <summary>
  31. /// 根据条件查询运营中心列表
  32. /// </summary>
  33. /// <returns></returns>
  34. public IActionResult Index(SysAdmin data, string right)
  35. {
  36. ViewBag.RightInfo = RightInfo;
  37. ViewBag.right = right;
  38. string Condition = "";
  39. Condition += "AdminName:\"" + data.AdminName + "\",";
  40. Condition += "RealName:\"" + data.RealName + "\",";
  41. Condition += "Role:\"" + data.Role + "\",";
  42. if (!string.IsNullOrEmpty(Condition))
  43. {
  44. Condition = Condition.TrimEnd(',');
  45. Condition = ", where: {" + Condition + "}";
  46. }
  47. ViewBag.Condition = Condition;
  48. return View();
  49. }
  50. #endregion
  51. #region 根据条件查询运营中心列表
  52. /// <summary>
  53. /// 运营中心列表
  54. /// </summary>
  55. /// <returns></returns>
  56. public JsonResult IndexData(SysAdmin data, string OpCode, string MakerCode, string MakerName, string UserType, string ExpiredStatus, string CreateDateData, string ExpiredDateData, int page = 1, int limit = 30)
  57. {
  58. Dictionary<string, string> Fields = new Dictionary<string, string>();
  59. Fields.Add("RealName", "1"); //名称
  60. string condition = " and Status>-1 and Sort>0 and QueryCount>0 and AdminName!='admin'";
  61. //运营中心编号
  62. if (!string.IsNullOrEmpty(OpCode))
  63. {
  64. condition += " and Id in (select OpId from OperateForCode where OpCode='" + OpCode + "')";
  65. }
  66. //创客编号
  67. if (!string.IsNullOrEmpty(MakerCode))
  68. {
  69. var user = db.Users.FirstOrDefault(m => m.MakerCode == MakerCode) ?? new Models.Users();
  70. condition += " and UserId=" + user.Id;
  71. }
  72. //创客姓名
  73. if (!string.IsNullOrEmpty(MakerName))
  74. {
  75. var user = db.Users.Where(m => m.RealName == MakerName).ToList();
  76. var userIds = "";
  77. foreach (var item in user)
  78. {
  79. userIds += item.Id + ",";
  80. };
  81. userIds = userIds.TrimEnd(',');
  82. condition += " and UserId in (" + userIds + ")";
  83. }
  84. //合伙人类型
  85. if (!string.IsNullOrEmpty(UserType))
  86. {
  87. var type = int.Parse(UserType);
  88. var user = db.Users.Where(m => m.UserType == type).ToList();
  89. var userIds = "";
  90. foreach (var item in user)
  91. {
  92. userIds += item.Id + ",";
  93. };
  94. userIds = userIds.TrimEnd(',');
  95. condition += " and UserId in (" + userIds + ")";
  96. }
  97. //创建时间
  98. if (!string.IsNullOrEmpty(CreateDateData))
  99. {
  100. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  101. string start = datelist[0];
  102. string end = datelist[1];
  103. condition += " and CreateDate>='" + start + " 00:00:00' and CreateDate<='" + end + " 23:59:59'";
  104. }
  105. //是否过期
  106. if (!string.IsNullOrEmpty(ExpiredStatus))
  107. {
  108. var status = int.Parse(ExpiredStatus);
  109. var time = DateTime.Now.ToString("yyyy-MM-dd Hh:mm:ss");
  110. if (status == 0) condition += " and ExpiredDate>'" + time + "'";
  111. if (status == 1) condition += " and ExpiredDate<='" + time + "'";
  112. }
  113. //过期时间
  114. if (!string.IsNullOrEmpty(ExpiredDateData))
  115. {
  116. string[] datelist = ExpiredDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  117. string start = datelist[0];
  118. string end = datelist[1];
  119. condition += " and ExpiredDate>='" + start + " 00:00:00' and ExpiredDate<='" + end + " 23:59:59'";
  120. }
  121. Dictionary<string, object> obj = new AdminContentByConn(_accessor.HttpContext, PublicFunction.OpTables, OpConn).IndexData("SysAdmin", Fields, "Id desc", "0", page, limit, condition);
  122. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  123. foreach (Dictionary<string, object> dic in diclist)
  124. {
  125. //所属人信息
  126. int Id = int.Parse(dic["Id"].ToString());
  127. SysAdmin sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.Id == Id) ?? new SysAdmin();
  128. dic["ExpiredStatus"] = "未过期"; // 是否过期(0 未过期 1 已过期)
  129. if (sysAdmin.ExpireDate < DateTime.Now)
  130. {
  131. dic["ExpiredStatus"] = "已过期";
  132. }
  133. var userInfo = db.Users.FirstOrDefault(m => m.Id == sysAdmin.UserId) ?? new Models.Users();
  134. if (userInfo.UserType == 0) dic["Kind"] = "";
  135. if (userInfo.UserType == 1) dic["Kind"] = "运营中心";
  136. if (userInfo.UserType == 2) dic["Kind"] = "黄金合伙人";
  137. if (userInfo.UserType == 3) dic["Kind"] = "钻石合伙人";
  138. if (userInfo.UserType == 4) dic["Kind"] = "战略合伙人";
  139. dic["MakerForCode"] = userInfo.MakerCode;
  140. dic["MakerForName"] = userInfo.RealName;
  141. //登陆地址
  142. dic["LoginUrl"] = OpHost + "Admin/" + dbconn.Encrypt3DES(sysAdmin.Sort.ToString(), "kxs12345").Replace("/", "%2F") + "/Login";
  143. //未使用用额度
  144. UserAccount userAccount = opdb.UserAccount.FirstOrDefault(m => m.Sort == Id) ?? new UserAccount();
  145. dic["TotalAmt"] = userAccount.TotalAmt;
  146. //可提现额度
  147. dic["ValidForGetAmount"] = userAccount.ValidForGetAmount;
  148. //关联分仓额度
  149. dic["ValidAmount"] = userAccount.ValidAmount;
  150. //已提现金额
  151. dic["WithdrawAmount"] = userAccount.WithdrawAmount;
  152. //提现中金额
  153. dic["WithdrawingAmount"] = userAccount.WithdrawingAmount;
  154. //对公标记
  155. dic["BusinessFlag"] = dic["BusinessFlag"].ToString() == "1" ? "是" : "否";
  156. }
  157. return Json(obj);
  158. }
  159. #endregion
  160. #region 增加运营中心
  161. /// <summary>
  162. /// 增加或修改运营中心信息
  163. /// </summary>
  164. /// <returns></returns>
  165. public IActionResult Add(string right)
  166. {
  167. ViewBag.RightInfo = RightInfo;
  168. ViewBag.right = right;
  169. return View();
  170. }
  171. #endregion
  172. #region 增加运营中心
  173. /// <summary>
  174. /// 增加或修改运营中心信息
  175. /// </summary>
  176. /// <returns></returns>
  177. [HttpPost]
  178. public string Add(SysAdmin data, UserAccount userAccount, string Areas, string Address, string Kind)
  179. {
  180. Dictionary<string, object> Fields = new Dictionary<string, object>();
  181. Dictionary<string, object> Field = new Dictionary<string, object>();
  182. var userForMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == data.MakerCode) ?? new Models.UserForMakerCode();
  183. if (userForMakerCode.UserId > 0)
  184. {
  185. var userInfo = db.Users.FirstOrDefault(m => m.Id == userForMakerCode.UserId && m.Mobile == data.MakerMobile) ?? new Models.Users();
  186. if (userInfo.Id > 0)
  187. {
  188. var check = opdb.SysAdmin.Any(m => m.AdminName == data.AdminName);
  189. var checks = opdb.SysAdmin.Any(m => m.UserId == userInfo.Id);
  190. if (check)
  191. {
  192. return "该用户名已存在,请重新输入";
  193. }
  194. if (checks)
  195. {
  196. return "该用户已存在运营中心,请重新输入";
  197. }
  198. Fields.Add("CreateMan", SysUserName + "_" + SysRealName); //创建人
  199. Fields.Add("RealName", data.RealName); //运营中心名称
  200. Fields.Add("MakerCode", data.MakerCode); //创客编号
  201. Fields.Add("MakerMobile", data.MakerMobile); //手机号
  202. Fields.Add("UserId", userInfo.Id); //创客Id
  203. Fields.Add("MakerName", userInfo.RealName); //创客真实姓名
  204. Fields.Add("AdminName", data.AdminName); //用户名
  205. Fields.Add("Password", function.MD5_32(data.Password)); //密码
  206. Fields.Add("FilePath", data.FilePath); //附件
  207. Fields.Add("ReturnFlag", data.ReturnFlag); //返还标记
  208. Fields.Add("ReturnAmount", data.ReturnAmount); //返还金额
  209. Fields.Add("QueryCount", 1); //是否为主账号(1是,0否)
  210. Fields.Add("ExpireDate", DateTime.Now.AddMonths(12)); //过期时间
  211. Fields.Add("BusinessFlag", data.BusinessFlag);
  212. int Id = new AdminContentByConn(_accessor.HttpContext, PublicFunction.OpTables, OpConn).Add("SysAdmin", Fields, 0);
  213. SysAdmin edit = opdb.SysAdmin.FirstOrDefault(m => m.Id == Id);
  214. if (edit != null)
  215. {
  216. string No = Id.ToString();
  217. for (int i = 0; i < 7 - Id.ToString().Length; i++)
  218. {
  219. No = "0" + No;
  220. }
  221. No = "YZ" + No;
  222. edit.OpCode = No;
  223. edit.Sort = Id;
  224. AddSysLog(data.Id.ToString(), "SysAdmin", "add");
  225. var query = opdb.OperateForCode.Add(new OperateForCode()
  226. {
  227. OpCode = No,
  228. OpId = Id,
  229. }).Entity;
  230. opdb.SaveChanges();
  231. }
  232. var info = opdb.SysAdmin.FirstOrDefault(m => m.Id == Id);
  233. if (info != null)
  234. {
  235. Field.Add("TotalAmt", userAccount.TotalAmt); //初始额度
  236. Field.Add("Sort", Id); //运营中心Id
  237. Field.Add("Id", edit.UserId); //创客Id
  238. Field.Add("UserId", edit.UserId); //创客Id
  239. int Ids = new AdminContentByConn(_accessor.HttpContext, PublicFunction.OpTables, OpConn).Add("UserAccount", Field, 0);
  240. AddSysLog(userAccount.Id.ToString(), "UserAccount", "add");
  241. var query = opdb.SysAdminRole.Add(new SysAdminRole()
  242. {
  243. CreateDate = DateTime.Now, //创建时间
  244. Sort = edit.Id,//所属运营中心
  245. CreateMan = SysUserName + "_" + SysRealName,
  246. Details = "运营中心管理员,可以操作运营中心所有权限",
  247. RightInfo = ",1_1,1_1_1,1_1_1_edit,1_2,1_2_1,1_2_1_export,1_2_2,1_3,1_3_1,1_3_1_import,1_4,1_4_1,1_4_1_add,1_4_2,1_4_2_add,1_4_3,1_4_3_edit,1_4_3_base,1_4_3_audit,1_6,1_6_1,1_6_1_add,1_6_1_delete,1_6_1_edit,1_6_2,1_6_2_add,1_6_2_delete,1_6_2_edit,",
  248. Name = "运营中心管理员",
  249. }).Entity;
  250. opdb.SaveChanges();
  251. var role = opdb.SysAdminRole.FirstOrDefault(m => m.Sort == edit.Id);
  252. if (role != null)
  253. {
  254. edit.Role = role.Id.ToString();
  255. opdb.SaveChanges();
  256. }
  257. }
  258. userInfo.UserType = int.Parse(Kind);//设置创客为运营中心
  259. //添加合伙人预设职级记录
  260. var operatorRankWhite = db.OperatorRankWhite.FirstOrDefault(m => m.Id == userInfo.Id) ?? new Models.OperatorRankWhite();
  261. if (operatorRankWhite.Id == 0)
  262. {
  263. operatorRankWhite = db.OperatorRankWhite.Add(new Models.OperatorRankWhite()
  264. {
  265. Id = userInfo.Id,
  266. CreateDate = DateTime.Now,
  267. UpdateDate = DateTime.Now.AddMonths(12),
  268. Rank = 9,
  269. UserId = userInfo.Id,
  270. }).Entity;
  271. }
  272. db.SaveChanges();
  273. var kqProduct = db.KqProducts.ToList();
  274. foreach (var item in kqProduct)
  275. {
  276. string Nos = "YC000" + item.Id + info.Id;
  277. var query = db.StoreHouse.Add(new Models.StoreHouse()
  278. {
  279. CreateDate = DateTime.Now, //创建时间
  280. CreateMan = SysUserName + "_" + SysRealName,
  281. ManageMobile = data.MakerMobile, //手机号
  282. UserId = info.UserId, //运营中心创客Id
  283. OpId = info.UserId, //运营中心创客Id
  284. Address = Address,//仓库地址
  285. Areas = Areas,//所属地区
  286. ManageUserId = info.UserId,//仓库管理员
  287. StoreName = item.Name + "运营分仓", //仓库名称
  288. StoreNo = Nos, //仓库编号
  289. Sort = info.Id,//运营中心Id
  290. Status = 1,
  291. BrandId = item.Id.ToString(),
  292. StoreKind = 2,//运营仓
  293. }).Entity;
  294. db.SaveChanges();
  295. var querys = opdb.StoreForOperate.Add(new OpModels.StoreForOperate()
  296. {
  297. CreateDate = DateTime.Now, //创建时间
  298. CreateMan = SysUserName + "_" + SysRealName,
  299. Sort = info.UserId,
  300. OpId = info.UserId,
  301. StoreId = query.Id,
  302. SeoKeyword = query.StoreNo,
  303. SeoDescription = query.StoreName,
  304. }).Entity;
  305. opdb.SaveChanges();
  306. }
  307. var sys = opdb.SysAdmin.Select(m => new { m.UserId, m.CreateDate }).Where(m => m.CreateDate < DateTime.Now).ToList();
  308. foreach (var item in sys)
  309. {
  310. AddOpStoreHouseByUserId(item.UserId.ToString());
  311. }
  312. if (data.ReturnFlag == 1)
  313. {
  314. RedisDbconn.Instance.AddList("OperateAddServiceQueue", Id.ToString());
  315. }
  316. }
  317. else
  318. {
  319. return "创客编号和手机号不匹配";
  320. }
  321. }
  322. else
  323. {
  324. return data.MakerCode + "关联信息缺失";
  325. }
  326. return "success";
  327. }
  328. #endregion
  329. #region 修改运营中心
  330. /// <summary>
  331. /// 增加或修改运营中心信息
  332. /// </summary>
  333. /// <returns></returns>
  334. public IActionResult Edit(string right, int Id = 0)
  335. {
  336. ViewBag.RightInfo = RightInfo;
  337. ViewBag.right = right;
  338. SysAdmin editData = opdb.SysAdmin.FirstOrDefault(m => m.Id == Id) ?? new SysAdmin();
  339. UserAccount editDatas = opdb.UserAccount.FirstOrDefault(m => m.Sort == Id) ?? new UserAccount();
  340. ViewBag.data = editData;
  341. ViewBag.datas = editDatas;
  342. var userInfo = db.Users.FirstOrDefault(m => m.Id == editData.UserId) ?? new Models.Users();
  343. ViewBag.Kind = userInfo.UserType;
  344. return View();
  345. }
  346. #endregion
  347. #region 修改运营中心
  348. /// <summary>
  349. /// 增加或修改运营中心信息
  350. /// </summary>
  351. /// <returns></returns>
  352. [HttpPost]
  353. public string Edit(SysAdmin data, UserAccount userAccount, string Areas, string Address, string Kind)
  354. {
  355. Dictionary<string, object> Fields = new Dictionary<string, object>();
  356. Fields.Add("UpdateMan", SysUserName + "_" + SysRealName); //修改人
  357. Fields.Add("RealName", data.RealName); //运营中心名称
  358. Fields.Add("FilePath", data.FilePath); //附件
  359. Fields.Add("AdminName", data.AdminName); //用户名
  360. Fields.Add("BusinessFlag", data.BusinessFlag);
  361. if (!string.IsNullOrEmpty(data.Password)) //密码不为空就修改密码,否则不操作
  362. {
  363. var sys = opdb.SysAdmin.FirstOrDefault(m => m.Id == data.Id);
  364. if (data.Password != sys.Password)
  365. {
  366. Fields.Add("Password", function.MD5_32(data.Password)); //密码
  367. }
  368. }
  369. new AdminContentByConn(_accessor.HttpContext, PublicFunction.OpTables, OpConn).Edit("SysAdmin", Fields, data.Id);
  370. SysAdmin edit = opdb.SysAdmin.FirstOrDefault(m => m.Id == data.Id);
  371. edit.CreateDate = edit.CreateDate;
  372. var userInfo = db.Users.FirstOrDefault(m => m.Id == edit.UserId) ?? new Models.Users();
  373. userInfo.UserType = int.Parse(Kind);//设置创客为运营中心
  374. userInfo.UpdateDate = DateTime.Now;
  375. AddSysLog(data.Id.ToString(), "SysAdmin", "update");
  376. db.SaveChanges();
  377. return "success";
  378. }
  379. #endregion
  380. #region 删除运营中心信息
  381. /// <summary>
  382. /// 删除运营中心信息
  383. /// </summary>
  384. /// <returns></returns>
  385. public string Delete(string Id)
  386. {
  387. string[] idlist = Id.Split(new char[] { ',' });
  388. AddSysLog(Id, "SysAdmin", "del");
  389. foreach (string subid in idlist)
  390. {
  391. int id = int.Parse(subid);
  392. var sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.Id == id) ?? new OpModels.SysAdmin();
  393. if (sysAdmin.Id > 0)
  394. {
  395. var userAccount = opdb.UserAccount.FirstOrDefault(m => m.Status > -1 && m.Sort == id && m.UserId == sysAdmin.UserId) ?? new OpModels.UserAccount();
  396. if (userAccount.Id > 0)
  397. {
  398. userAccount.Status = -1;
  399. }
  400. var operateForCode = opdb.OperateForCode.FirstOrDefault(m => m.OpId == id) ?? new OpModels.OperateForCode();
  401. if (operateForCode.OpId > 0)
  402. {
  403. new AdminContentByConn(_accessor.HttpContext, PublicFunction.OpTables, OpConn).Delete("UserAccount", operateForCode.OpId);
  404. }
  405. //修改运营中心仓
  406. var storeHouse = db.StoreHouse.Where(m => m.Sort == id && m.Status == 1 && m.UserId == sysAdmin.UserId && m.OpId == sysAdmin.UserId).ToList();
  407. foreach (var item in storeHouse)
  408. {
  409. var list = storeHouse.FirstOrDefault(m => m.Id == item.Id) ?? new Models.StoreHouse();
  410. if (list.Id > 0)
  411. {
  412. list.Status = -1;
  413. list.UpdateDate = DateTime.Now;
  414. list.UpdateMan = SysUserName + "-" + SysRealName;
  415. db.SaveChanges();
  416. }
  417. }
  418. //修改运营中心关联分仓
  419. var storeHouses = db.StoreHouse.Where(m => m.Sort == id && m.Status == 1).ToList();
  420. foreach (var item in storeHouses)
  421. {
  422. var list = storeHouses.FirstOrDefault(m => m.Id == item.Id) ?? new Models.StoreHouse();
  423. if (list.Id > 0)
  424. {
  425. list.Sort = 0;
  426. list.OpId = 0;
  427. list.UpdateDate = DateTime.Now;
  428. list.UpdateMan = SysUserName + "-" + SysRealName;
  429. db.SaveChanges();
  430. }
  431. }
  432. //修改关联运营中心仓
  433. var storeForOperate = opdb.StoreForOperate.Where(m => m.Status == 0 && m.OpId == sysAdmin.UserId && m.Sort == sysAdmin.UserId && m.QueryCount == 0).ToList();
  434. foreach (var items in storeForOperate)
  435. {
  436. var lists = storeForOperate.FirstOrDefault(m => m.Id == items.Id) ?? new OpModels.StoreForOperate();
  437. if (lists.Id > 0)
  438. {
  439. lists.Status = -1;
  440. lists.UpdateDate = DateTime.Now;
  441. lists.UpdateMan = SysUserName + "-" + SysRealName;
  442. opdb.SaveChanges();
  443. }
  444. }
  445. //修改运营中心关联分仓
  446. var storeForOperates = opdb.StoreForOperate.Where(m => m.Status == 0 && m.OpId == sysAdmin.UserId && m.Sort == 0 && m.QueryCount == sysAdmin.UserId).ToList();
  447. foreach (var items in storeForOperates)
  448. {
  449. var lists = storeForOperates.FirstOrDefault(m => m.Id == items.Id) ?? new OpModels.StoreForOperate();
  450. if (lists.Id > 0)
  451. {
  452. lists.Status = -1;
  453. lists.UpdateDate = DateTime.Now;
  454. lists.UpdateMan = SysUserName + "-" + SysRealName;
  455. opdb.SaveChanges();
  456. }
  457. }
  458. opdb.SaveChanges();
  459. }
  460. Dictionary<string, object> Fields = new Dictionary<string, object>();
  461. Fields.Add("Status", -1);
  462. new AdminContentByConn(_accessor.HttpContext, PublicFunction.OpTables, OpConn).Edit("SysAdmin", Fields, id);
  463. }
  464. opdb.SaveChanges();
  465. return "success";
  466. }
  467. #endregion
  468. #region 开启
  469. /// <summary>
  470. /// 开启
  471. /// </summary>
  472. /// <returns></returns>
  473. public string Open(string Id)
  474. {
  475. string[] idlist = Id.Split(new char[] { ',' });
  476. AddSysLog(Id, "SysAdmin", "open");
  477. foreach (string subid in idlist)
  478. {
  479. int id = int.Parse(subid);
  480. Dictionary<string, object> Fields = new Dictionary<string, object>();
  481. Fields.Add("Status", 1);
  482. new AdminContentByConn(_accessor.HttpContext, PublicFunction.OpTables, OpConn).Edit("SysAdmin", Fields, id);
  483. }
  484. opdb.SaveChanges();
  485. return "success";
  486. }
  487. #endregion
  488. #region 关闭
  489. /// <summary>
  490. /// 关闭
  491. /// </summary>
  492. /// <returns></returns>
  493. public string Close(string Id)
  494. {
  495. string[] idlist = Id.Split(new char[] { ',' });
  496. AddSysLog(Id, "SysAdmin", "close");
  497. foreach (string subid in idlist)
  498. {
  499. int id = int.Parse(subid);
  500. Dictionary<string, object> Fields = new Dictionary<string, object>();
  501. Fields.Add("Status", 0);
  502. new AdminContentByConn(_accessor.HttpContext, PublicFunction.OpTables, OpConn).Edit("SysAdmin", Fields, id);
  503. }
  504. opdb.SaveChanges();
  505. return "success";
  506. }
  507. #endregion
  508. #region 排序
  509. /// <summary>
  510. /// 排序
  511. /// </summary>
  512. /// <param name="Id"></param>
  513. public string Sort(int Id, int Sort)
  514. {
  515. new AdminContentByConn(_accessor.HttpContext, PublicFunction.OpTables, OpConn).Sort("SysAdmin", Sort, Id);
  516. AddSysLog(Id.ToString(), "SysAdmin", "sort");
  517. return "success";
  518. }
  519. #endregion
  520. #region 导入数据
  521. /// <summary>
  522. /// 导入数据
  523. /// </summary>
  524. /// <param name="ExcelData"></param>
  525. public string Import(string ExcelData)
  526. {
  527. ExcelData = HttpUtility.UrlDecode(ExcelData);
  528. JsonData list = JsonMapper.ToObject(ExcelData);
  529. for (int i = 1; i < list.Count; i++)
  530. {
  531. JsonData dr = list[i];
  532. opdb.SysAdmin.Add(new SysAdmin()
  533. {
  534. CreateDate = DateTime.Now,
  535. UpdateDate = DateTime.Now,
  536. });
  537. opdb.SaveChanges();
  538. }
  539. AddSysLog("0", "SysAdmin", "Import");
  540. return "success";
  541. }
  542. #endregion
  543. #region 导出Excel
  544. /// <summary>
  545. /// 导出Excel
  546. /// </summary>
  547. /// <returns></returns>
  548. public JsonResult ExportExcel(SysAdmin data)
  549. {
  550. Dictionary<string, string> Fields = new Dictionary<string, string>();
  551. Fields.Add("AdminName", "2"); //用户名
  552. Fields.Add("RealName", "2"); //名称
  553. Fields.Add("Role", "1"); //角色
  554. Fields.Add("LastLoginDate", "3"); //最后登录时间
  555. Dictionary<string, object> obj = new AdminContentByConn(_accessor.HttpContext, PublicFunction.OpTables, OpConn).IndexData("SysAdmin", Fields, "Id desc", "0", 1, 20000, "", "", false);
  556. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  557. foreach (Dictionary<string, object> dic in diclist)
  558. {
  559. }
  560. Dictionary<string, object> result = new Dictionary<string, object>();
  561. result.Add("Status", "1");
  562. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  563. result.Add("Obj", diclist);
  564. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  565. result.Add("Fields", ReturnFields);
  566. AddSysLog("0", "SysAdmin", "ExportExcel");
  567. return Json(result);
  568. }
  569. #endregion
  570. #region 修改运营中心未使用额度
  571. public IActionResult EditAmt(string right, int Id = 0)
  572. {
  573. ViewBag.RightInfo = RightInfo;
  574. ViewBag.right = right;
  575. SysAdmin editData = opdb.SysAdmin.FirstOrDefault(m => m.Id == Id) ?? new SysAdmin();
  576. ViewBag.data = editData;
  577. return View();
  578. }
  579. #endregion
  580. #region 修改运营中心未使用额度
  581. [HttpPost]
  582. public string EditAmt(SysAdmin data, string OperationAmount, string Note, int Kind, int ReturnFlag)
  583. {
  584. var sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.Id == data.Id);
  585. var account = opdb.UserAccount.FirstOrDefault(m => m.UserId == sysAdmin.UserId);
  586. decimal BeforeAmount = account.TotalAmt + account.ValidAmount + account.ValidForGetAmount; //变更前总金额
  587. int OperateType = 0;
  588. int ChangeType = 0;
  589. var bAmount = account.ValidForGetAmount;
  590. var description = "";
  591. if (Kind == 1)
  592. {
  593. account.TotalAmt -= decimal.Parse(OperationAmount);
  594. OperateType = 2;//系统扣减
  595. description = "系统扣减未使用额度" + "-" + Note;
  596. ChangeType = 13;
  597. }
  598. //增加
  599. else if (Kind == 2)
  600. {
  601. // sysAdmin.ReturnAmount = decimal.Parse(OperationAmount);
  602. account.TotalAmt += decimal.Parse(OperationAmount);
  603. OperateType = 1;//系统增加
  604. description = "系统增加未使用额度" + "-" + Note;
  605. ChangeType = 12;
  606. }
  607. decimal AfterAmount = account.TotalAmt + account.ValidAmount + account.ValidForGetAmount; //变更后总金额
  608. AddSysLog(data.Id.ToString(), "SysAdmin", "EditAmt");
  609. opdb.SaveChanges();
  610. if (OperateType > 0 && decimal.Parse(OperationAmount) > 0)
  611. {
  612. OpAmountItem opAmountItem = new OpAmountItem
  613. {
  614. UserId = sysAdmin.UserId,//创客Id
  615. OperateType = OperateType,//操作类型(0 总和 1 增加 2 减少)
  616. ChangeType = ChangeType,//类别
  617. Remark = description,//备注
  618. UseAmount = decimal.Parse(OperationAmount),//变更总额度
  619. UseValidForGetAmount = 0,//变更可提现额度
  620. UseTotalAmt = decimal.Parse(OperationAmount),//变更未使用额度
  621. UseValidAmount = 0,//变更关联分仓额度
  622. DataType = 0,//来源类型,区分表(1订单,2机具,3申请记录,4购买运营中心,5预扣款 6兑换大盟主 7仓库)
  623. DataId = 0,//来源Id,表的主键Id
  624. NoAccount = 1//是否入账(0 是 1 否)
  625. };
  626. RedisDbconn.Instance.AddList("OperateAmountRecordServiceQueue", opAmountItem);
  627. AddSysLog(data.Id.ToString(), "SysAdmin", "EditAmt");
  628. opdb.SaveChanges();
  629. if (Kind == 2 && ReturnFlag == 1)
  630. {
  631. RedisDbconn.Instance.AddList("OperateAddServiceQueue", sysAdmin.Id.ToString());
  632. }
  633. }
  634. return "success";
  635. }
  636. #endregion
  637. #region 修改运营中心可提现额度
  638. public IActionResult EditBalance(string right, int Id = 0)
  639. {
  640. ViewBag.RightInfo = RightInfo;
  641. ViewBag.right = right;
  642. SysAdmin editData = opdb.SysAdmin.FirstOrDefault(m => m.Id == Id) ?? new SysAdmin();
  643. ViewBag.data = editData;
  644. return View();
  645. }
  646. #endregion
  647. #region 修改运营中心可提现额度
  648. [HttpPost]
  649. public string EditBalance(SysAdmin data, string OperationAmount, string Note, int Kind)
  650. {
  651. var sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.Id == data.Id);
  652. var account = opdb.UserAccount.FirstOrDefault(m => m.UserId == sysAdmin.UserId);
  653. if ((Kind == 1) && decimal.Parse(OperationAmount) > account.ValidForGetAmount)
  654. {
  655. return "账号余额不足";
  656. }
  657. decimal BeforeAmount = account.TotalAmt + account.ValidAmount + account.ValidForGetAmount; //变更前总金额
  658. int OperateType = 0;
  659. int ChangeType = 0;
  660. var bAmount = account.ValidForGetAmount;
  661. var description = "";
  662. if (Kind == 1 && decimal.Parse(OperationAmount) <= account.ValidForGetAmount)
  663. {
  664. account.ValidForGetAmount -= decimal.Parse(OperationAmount);
  665. OperateType = 2;
  666. description = "系统扣减可提现额度" + "-" + Note;
  667. ChangeType = 13;
  668. }
  669. else if (Kind == 1 && decimal.Parse(OperationAmount) > account.ValidForGetAmount)
  670. {
  671. return "扣减金额大于可提现额度" + "-" + Note;
  672. }
  673. else if (Kind == 2)
  674. {
  675. account.ValidForGetAmount += decimal.Parse(OperationAmount);
  676. OperateType = 1;
  677. description = "系统增加可提现额度" + "-" + Note;
  678. ChangeType = 12;
  679. }
  680. decimal AfterAmount = account.TotalAmt + account.ValidAmount + account.ValidForGetAmount; //变更后总金额
  681. if (OperateType > 0 && decimal.Parse(OperationAmount) > 0)
  682. {
  683. OpAmountItem opAmountItem = new OpAmountItem
  684. {
  685. UserId = sysAdmin.UserId,//创客Id
  686. OperateType = OperateType,//操作类型(0 总和 1 增加 2 减少)
  687. ChangeType = ChangeType,//类别
  688. Remark = description,//备注
  689. UseAmount = decimal.Parse(OperationAmount),//变更总额度
  690. UseValidForGetAmount = decimal.Parse(OperationAmount),//变更可提现额度
  691. UseTotalAmt = 0,//变更未使用额度
  692. UseValidAmount = 0,//变更关联分仓额度
  693. DataType = 0,//来源类型,区分表(1订单,2机具,3申请记录,4购买运营中心,5预扣款 6兑换大盟主 7仓库)
  694. DataId = 0,//来源Id,表的主键Id
  695. NoAccount = 1//是否入账(0 是 1 否)
  696. };
  697. RedisDbconn.Instance.AddList("OperateAmountRecordServiceQueue", opAmountItem);
  698. AddSysLog(data.Id.ToString(), "SysAdmin", "EditBalance");
  699. opdb.SaveChanges();
  700. }
  701. return "success";
  702. }
  703. #endregion
  704. #region 新建运营中心添加历史运营中心缺少分仓
  705. /// <summary>
  706. /// 新建运营中心添加历史运营中心缺少分仓
  707. /// </summary>
  708. /// <returns></returns>
  709. public string AddOpStoreHouseByUserId(string UserIds)
  710. {
  711. string[] UserIdList = UserIds.Split(new char[] { ',' });
  712. AddSysLog(UserIds, "SysAdmin", "新建运营中心添加历史运营中心缺少分仓");
  713. var kqProduct = db.KqProducts.ToList();
  714. foreach (string subid in UserIdList)
  715. {
  716. int UserId = int.Parse(subid);
  717. SysAdmin sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.UserId == UserId) ?? new SysAdmin();
  718. var store = db.StoreHouse.FirstOrDefault(m => m.Sort == sysAdmin.Id && m.UserId == sysAdmin.UserId) ?? new Models.StoreHouse();
  719. foreach (var item in kqProduct)
  720. {
  721. var BrandId = item.Id.ToString();
  722. var check = db.StoreHouse.Any(m => m.Sort == sysAdmin.Id && m.UserId == sysAdmin.UserId && m.BrandId == BrandId);
  723. if (!check)
  724. {
  725. string Nos = "YC000" + item.Id + sysAdmin.Id;
  726. var query = db.StoreHouse.Add(new Models.StoreHouse()
  727. {
  728. CreateDate = DateTime.Now, //创建时间
  729. CreateMan = SysUserName + "_" + SysRealName,
  730. ManageMobile = sysAdmin.MakerMobile, //手机号
  731. UserId = UserId, //运营中心创客Id
  732. OpId = UserId, //运营中心创客Id
  733. Address = store.Address,//仓库地址
  734. Areas = store.Areas,//所属地区
  735. ManageUserId = UserId,//仓库管理员
  736. StoreName = item.Name + "运营分仓", //仓库名称
  737. StoreNo = Nos, //仓库编号
  738. Sort = sysAdmin.Id,//运营中心Id
  739. Status = 1,
  740. BrandId = item.Id.ToString(),
  741. StoreKind = 2,//运营仓
  742. }).Entity;
  743. db.SaveChanges();
  744. var querys = opdb.StoreForOperate.Add(new OpModels.StoreForOperate()
  745. {
  746. CreateDate = DateTime.Now, //创建时间
  747. CreateMan = SysUserName + "_" + SysRealName,
  748. Sort = sysAdmin.UserId,
  749. OpId = sysAdmin.UserId,
  750. StoreId = query.Id,
  751. SeoKeyword = query.StoreNo,
  752. SeoDescription = query.StoreName,
  753. }).Entity;
  754. opdb.SaveChanges();
  755. }
  756. }
  757. }
  758. db.SaveChanges();
  759. return "success";
  760. }
  761. #endregion
  762. }
  763. }