StoreHouseController.cs 100 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040
  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;
  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.Models;
  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 StoreHouseController : BaseController
  25. {
  26. public StoreHouseController(IHttpContextAccessor accessor, ILogger<BaseController> logger, IOptions<Setting> setting) : base(accessor, logger, setting)
  27. {
  28. OtherMySqlConn.connstr = ConfigurationManager.AppSettings["SqlConnStr"].ToString();
  29. }
  30. #region 仓库列表
  31. /// <summary>
  32. /// 根据条件查询仓库列表
  33. /// </summary>
  34. /// <returns></returns>
  35. public IActionResult Index(StoreHouse data, string right)
  36. {
  37. ViewBag.RightInfo = RightInfo;
  38. ViewBag.right = right;
  39. return View();
  40. }
  41. #endregion
  42. #region 根据条件查询仓库列表
  43. /// <summary>
  44. /// 仓库列表
  45. /// </summary>
  46. /// <returns></returns>
  47. public JsonResult IndexData(StoreHouse data, string UserIdMakerCode, string UserIdRealName, string ManageUserIdRealName, string ManageUserIdMobile, string ManageUserIdMakerCode, string StoreStatusSelect, string CreateDateData, string MakerCode, string YZOpCode, string OpStatusSelect, string StoreKindSelect, int ShowFlag = 0, int page = 1, int limit = 30)
  48. {
  49. Dictionary<string, string> Fields = new Dictionary<string, string>();
  50. Fields.Add("StoreNo", "1"); //仓库编号
  51. Fields.Add("StoreName", "1"); //仓库名称
  52. Fields.Add("ManagerEmail", "1"); //管理者邮箱
  53. if (ShowFlag == 0)
  54. {
  55. Dictionary<string, object> objs = new Dictionary<string, object>();
  56. return Json(objs);
  57. }
  58. string condition = " and Status>-1";
  59. //仓库归属人创客编号
  60. if (!string.IsNullOrEmpty(UserIdMakerCode))
  61. {
  62. condition += " and UserId in (select UserId from UserForMakerCode where MakerCode='" + UserIdMakerCode + "')";
  63. }
  64. //仓库归属人真实姓名
  65. if (!string.IsNullOrEmpty(UserIdRealName))
  66. {
  67. DataTable dt = OtherMySqlConn.dtable("SELECT Id FROM Users WHERE RealName like '%" + UserIdRealName + "%'");
  68. var Count = dt.Rows.Count;
  69. // int times = 0;
  70. string UserIds = "";
  71. foreach (DataRow item in dt.Rows)
  72. {
  73. // times++;
  74. // if (times == Count)
  75. // {
  76. // UserIds += item["Id"].ToString();
  77. // }
  78. // else
  79. // {
  80. // UserIds += item["Id"].ToString() + ",";
  81. // }
  82. UserIds += item["Id"].ToString() + ",";
  83. }
  84. // condition += " and UserId in (select UserId from UserForRealName where RealName='" + UserIdRealName + "')";
  85. condition += " and UserId in (" + UserIds.TrimEnd(',') + ")";
  86. }
  87. //仓库管理员真实姓名
  88. if (!string.IsNullOrEmpty(ManageUserIdRealName))
  89. {
  90. DataTable dts = OtherMySqlConn.dtable("SELECT Id FROM Users WHERE RealName like '%" + ManageUserIdRealName + "%'");
  91. var Counts = dts.Rows.Count;
  92. // int time = 1;
  93. string UserIdss = "";
  94. foreach (DataRow items in dts.Rows)
  95. {
  96. // time++;
  97. // if (time == Counts)
  98. // {
  99. // UserIdss += items["Id"].ToString();
  100. // }
  101. // else
  102. // {
  103. // UserIdss += items["Id"].ToString() + ",";
  104. // }
  105. UserIdss += items["Id"].ToString() + ",";
  106. }
  107. // condition += " and ManageUserId in (select ManageUserId from UserForRealName where RealName='" + ManageUserIdRealName + "')";
  108. condition += " and UserId in (" + UserIdss.TrimEnd(',') + ")";
  109. }
  110. //仓库管理员手机号
  111. if (!string.IsNullOrEmpty(ManageUserIdMobile))
  112. {
  113. condition += " and ManageUserId in (select ManageUserId from UserForMobile where Mobile='" + ManageUserIdMobile + "')";
  114. }
  115. //仓库管理员创客编号
  116. if (!string.IsNullOrEmpty(ManageUserIdMakerCode))
  117. {
  118. condition += " and ManageUserId in (select ManageUserId from UserForMakerCode where MakerCode='" + ManageUserIdMakerCode + "')";
  119. }
  120. //仓库状态
  121. if (!string.IsNullOrEmpty(StoreStatusSelect))
  122. {
  123. condition += " and Status=" + StoreStatusSelect;
  124. }
  125. if (!string.IsNullOrEmpty(CreateDateData))
  126. {
  127. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  128. string start = datelist[0];
  129. string end = datelist[1];
  130. condition += " and CreateDate>='" + start + " 00:00:00' and CreateDate<='" + end + " 23:59:59'";
  131. }
  132. //下线创客编号
  133. if (!string.IsNullOrEmpty(MakerCode))
  134. {
  135. var userForMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode) ?? new UserForMakerCode();
  136. if (userForMakerCode.UserId > 0)
  137. {
  138. var user = db.Users.FirstOrDefault(m => m.Id == userForMakerCode.UserId);
  139. var users = db.Users.Where(m => m.ParentNav.Contains("," + user.Id.ToString() + ",")).ToList();
  140. string userIds = "";
  141. foreach (var item in users)
  142. {
  143. userIds += item.Id + ",";
  144. }
  145. userIds += user.Id;//下线创客Id包含自己
  146. string Id = "";
  147. DataTable dt = OtherMySqlConn.dtable("SELECT Id FROM StoreHouse WHERE UserId IN(" + userIds.TrimEnd(',') + ") AND `Status`=1 AND Sort=0 AND UserId>1");
  148. foreach (DataRow item in dt.Rows)
  149. {
  150. Id += item["Id"].ToString() + ",";
  151. }
  152. condition += " and Id in (" + Id.TrimEnd(',') + ")";
  153. }
  154. }
  155. //运营中心编号
  156. if (!string.IsNullOrEmpty(YZOpCode))
  157. {
  158. var sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.OpCode == YZOpCode) ?? new OpModels.SysAdmin();
  159. if (sysAdmin.Id > 0)
  160. {
  161. condition += " and OpId=" + sysAdmin.UserId;
  162. }
  163. }
  164. //是否关联
  165. if (!string.IsNullOrEmpty(OpStatusSelect))
  166. {
  167. if (int.Parse(OpStatusSelect) > 0)
  168. {
  169. condition += " and OpId>0";
  170. }
  171. else
  172. {
  173. condition += " and OpId=0";
  174. }
  175. }
  176. //是否运营仓
  177. if (!string.IsNullOrEmpty(StoreKindSelect))
  178. {
  179. if (int.Parse(StoreKindSelect) > 0)
  180. {
  181. condition += " and Sort>0 and StoreKind=2";
  182. }
  183. else
  184. {
  185. condition += " and Sort=0 and StoreKind!=2";
  186. }
  187. }
  188. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("StoreHouse", Fields, "Id desc", "0", page, limit, condition);
  189. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  190. foreach (Dictionary<string, object> dic in diclist)
  191. {
  192. //仓库归属人
  193. int UserId = int.Parse(function.CheckInt(dic["UserId"].ToString()));
  194. Users userid_Users = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  195. dic["UserIdMakerCode"] = userid_Users.MakerCode;
  196. dic["UserIdRealName"] = userid_Users.RealName;
  197. //产品类型
  198. dic["BrandId"] = RelationClass.GetKqProductBrandList(dic["BrandId"].ToString());
  199. //仓库管理员
  200. int ManageUserId = int.Parse(function.CheckInt(dic["ManageUserId"].ToString()));
  201. Users manageuserid_Users = db.Users.FirstOrDefault(m => m.Id == ManageUserId) ?? new Users();
  202. dic["ManageUserIdRealName"] = manageuserid_Users.RealName;
  203. dic["ManageUserIdMobile"] = manageuserid_Users.Mobile;
  204. dic["ManageUserIdMakerCode"] = manageuserid_Users.MakerCode;
  205. //仓库类型
  206. int StoreType = int.Parse(dic["StoreType"].ToString());
  207. if (StoreType == 0) dic["StoreType"] = "实体仓";
  208. if (StoreType == 1) dic["StoreType"] = "虚拟仓";
  209. //仓库状态
  210. int Status = int.Parse(dic["Status"].ToString());
  211. if (Status == 1) dic["Status"] = "启用";
  212. if (Status == 0) dic["Status"] = "禁用";
  213. //仓库归属类型
  214. int StoreKind = int.Parse(dic["StoreKind"].ToString());
  215. if (StoreKind == 0) dic["StoreKind"] = "分仓";
  216. if (StoreKind == 1) dic["StoreKind"] = "总仓";
  217. if (StoreKind == 2) dic["StoreKind"] = "运营仓";
  218. //小分仓
  219. int Id = int.Parse(function.CheckInt(dic["Id"].ToString()));
  220. int PreCount = db.PreSendStockDetail.Count(m => m.FromStoreId == Id && m.ApplyFlag == 0 && m.Status >= 0 && m.Status <= 1);
  221. dic["PreNum"] = PreCount.ToString();
  222. //分仓额度
  223. var amount = db.UserAccount.FirstOrDefault(m => m.Id == UserId) ?? new UserAccount();
  224. var ValidAmount = amount.ValidAmount;
  225. var FixedAmount = amount.FixedAmount;
  226. var TempAmount = amount.TempAmount + amount.TempAmountForBalance;
  227. var check = db.StoreHouseAmountPromiss.Any(m => m.ToUserId == UserId);
  228. decimal PromissAmount = 0;
  229. var ThisMonthPreAmount = amount.ThisMonthPreAmount;
  230. var ValidPreAmount = amount.ValidPreAmount;
  231. if (check)
  232. {
  233. PromissAmount = db.StoreHouseAmountPromiss.Where(m => m.Status == 1 && m.ToUserId == UserId).Sum(m => m.PromissAmount);
  234. }
  235. dic["ValidAmount"] = ValidAmount.ToString();//可用额度
  236. dic["FixedAmount"] = FixedAmount.ToString();//固定额度
  237. dic["TempAmount"] = TempAmount.ToString();//临时额度
  238. dic["PromissAmount"] = PromissAmount.ToString();//担保金额
  239. dic["ThisMonthPreAmount"] = ThisMonthPreAmount.ToString();//本月小分仓额度
  240. dic["ValidPreAmount"] = ValidPreAmount.ToString();//可用小分仓额度
  241. //是否关联
  242. int OpId = int.Parse(dic["OpId"].ToString());
  243. var opInfo = opdb.SysAdmin.FirstOrDefault(m => m.QueryCount > 0 && m.UserId == OpId) ?? new OpModels.SysAdmin();
  244. if (OpId == 0) dic["OpIdStatus"] = "否";
  245. if (OpId > 0) dic["OpIdStatus"] = opInfo.OpCode;
  246. }
  247. return Json(obj);
  248. }
  249. #endregion
  250. #region 增加仓库
  251. /// <summary>
  252. /// 增加或修改仓库信息
  253. /// </summary>
  254. /// <returns></returns>
  255. public IActionResult Add(string right)
  256. {
  257. ViewBag.RightInfo = RightInfo;
  258. ViewBag.right = right;
  259. return View();
  260. }
  261. #endregion
  262. #region 增加仓库
  263. /// <summary>
  264. /// 增加或修改仓库信息
  265. /// </summary>
  266. /// <returns></returns>
  267. [HttpPost]
  268. public string Add(StoreHouse data, string ManageMakerCode, string MakerCode)
  269. {
  270. string BrandIdString = data.BrandId;
  271. if (!string.IsNullOrEmpty(BrandIdString))
  272. {
  273. string[] BrandIdList = BrandIdString.Split(',');
  274. foreach (string BrandId in BrandIdList)
  275. {
  276. Dictionary<string, object> Fields = new Dictionary<string, object>();
  277. Fields.Add("CreateMan", SysUserName); //创建人
  278. Fields.Add("StoreName", data.StoreName); //仓库名称
  279. Fields.Add("FilePath", data.FilePath); //附件
  280. Fields.Add("Deposit", data.Deposit); //押金
  281. UserForMakerCode user = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  282. if (user == null)
  283. {
  284. return "您输入的仓库归属创客编号不存在,请重新输入正确的仓库归属创客编号";
  285. }
  286. Fields.Add("UserId", user.UserId); //仓库归属人
  287. Fields.Add("Areas", data.Areas); //所属地区
  288. Fields.Add("Address", data.Address); //仓库地址
  289. UserForMakerCode manage = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == ManageMakerCode);
  290. if (manage == null)
  291. {
  292. return "您输入的仓库负责人编号不存在,请重新输入正确的仓库负责人编号";
  293. }
  294. Fields.Add("ManageUserId", manage.UserId); //仓库管理员
  295. Fields.Add("ManagerEmail", data.ManagerEmail); //管理者邮箱
  296. Fields.Add("ManageMobile", data.ManageMobile);
  297. Fields.Add("Remark", data.Remark); //备注
  298. Fields.Add("LimitTopUserId", data.LimitTopUserId); //限制创客特殊仓库
  299. Fields.Add("StoreKind", data.StoreKind); //仓库归属类型
  300. int bid = int.Parse(BrandId);
  301. KqProducts pro = db.KqProducts.FirstOrDefault(m => m.Id == bid) ?? new KqProducts();
  302. Fields.Add("BrandId", BrandId);
  303. Fields.Add("ProductName", pro.Name);
  304. Fields.Add("StoreStatus", 1);
  305. Fields.Add("Status", 1);
  306. var name = db.StoreHouse.FirstOrDefault(m => m.UserId == user.UserId && m.BrandId == BrandId && m.StoreName == data.StoreName && m.OpId == 0);
  307. if (name != null)
  308. {
  309. return "您的仓库名重复,请重新填写";
  310. }
  311. int Id = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Add("StoreHouse", Fields, 0);
  312. //添加分仓创建时间
  313. var users = db.Users.FirstOrDefault(m => m.Id == user.UserId) ?? new Users();
  314. if (users.Id > 0)
  315. {
  316. if (string.IsNullOrEmpty(users.CreateStoreDate.ToString()))
  317. {
  318. users.CreateStoreDate = DateTime.Now;
  319. db.SaveChanges();
  320. }
  321. }
  322. StoreHouse edit = db.StoreHouse.FirstOrDefault(m => m.Id == Id);
  323. if (edit != null)
  324. {
  325. string No = Id.ToString();
  326. for (int i = 0; i < 7 - Id.ToString().Length; i++)
  327. {
  328. No = "0" + No;
  329. }
  330. No = "S" + No;
  331. edit.StoreNo = No;
  332. db.StoreForCode.Add(new StoreForCode()
  333. {
  334. Code = No,
  335. StoreId = Id,
  336. });
  337. RedisDbconn.Instance.Set("StoreForCode:" + No, Id);
  338. }
  339. StoreForName storeForName = db.StoreForName.FirstOrDefault(m => m.Name == data.StoreName);
  340. if (storeForName == null)
  341. {
  342. db.StoreForName.Add(new StoreForName()
  343. {
  344. Name = data.StoreName,
  345. StoreId = Id,
  346. });
  347. }
  348. else
  349. {
  350. storeForName.StoreId = Id;
  351. }
  352. UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == user.UserId);
  353. if (account == null)
  354. {
  355. account = db.UserAccount.Add(new UserAccount()
  356. {
  357. Id = user.UserId,
  358. UserId = user.UserId,
  359. }).Entity;
  360. db.SaveChanges();
  361. }
  362. if (account.FixedAmount == 0 && account.ValidAmount == 0)
  363. {
  364. account.FixedAmount = 20000;
  365. account.ValidAmount = 20000;
  366. }
  367. RedisDbconn.Instance.Set("StoreForName:" + data.StoreName, Id);
  368. AddSysLog(data.Id.ToString(), "StoreHouse", "add");
  369. db.SaveChanges();
  370. SetRedis(Id, user.UserId);
  371. }
  372. }
  373. return "success";
  374. }
  375. #endregion
  376. #region 修改仓库
  377. /// <summary>
  378. /// 增加或修改仓库信息
  379. /// </summary>
  380. /// <returns></returns>
  381. public IActionResult Edit(string right, int Id = 0)
  382. {
  383. ViewBag.RightInfo = RightInfo;
  384. ViewBag.right = right;
  385. StoreHouse editData = db.StoreHouse.FirstOrDefault(m => m.Id == Id) ?? new StoreHouse();
  386. ViewBag.data = editData;
  387. Users manage = db.Users.FirstOrDefault(m => m.Id == editData.ManageUserId) ?? new Users();
  388. ViewBag.ManageMakerCode = manage.MakerCode;
  389. ViewBag.ManageRealName = manage.RealName;
  390. Users user = db.Users.FirstOrDefault(m => m.Id == editData.ManageUserId) ?? new Users();
  391. ViewBag.MakerCode = user.MakerCode;
  392. return View();
  393. }
  394. #endregion
  395. #region 修改仓库
  396. /// <summary>
  397. /// 增加或修改仓库信息
  398. /// </summary>
  399. /// <returns></returns>
  400. [HttpPost]
  401. public string Edit(StoreHouse data, string ManageMakerCode, string MakerCode)
  402. {
  403. Dictionary<string, object> Fields = new Dictionary<string, object>();
  404. Fields.Add("CreateMan", SysUserName); //创建人
  405. Fields.Add("StoreName", data.StoreName); //仓库名称
  406. Fields.Add("FilePath", data.FilePath); //附件
  407. Fields.Add("Deposit", data.Deposit); //押金
  408. UserForMakerCode user = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  409. if (user == null)
  410. {
  411. return "您输入的仓库归属创客编号不存在,请重新输入正确的仓库归属创客编号";
  412. }
  413. Fields.Add("UserId", user.UserId); //仓库归属人
  414. Fields.Add("Areas", data.Areas); //所属地区
  415. Fields.Add("Address", data.Address); //仓库地址
  416. UserForMakerCode manage = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == ManageMakerCode);
  417. if (manage == null)
  418. {
  419. return "您输入的仓库负责人编号不存在,请重新输入正确的仓库负责人编号";
  420. }
  421. var store = db.StoreHouse.Where(m => m.Sort == 0 && m.Status == 1 && m.UserId == user.UserId).ToList();
  422. UserAccount userAccount = db.UserAccount.FirstOrDefault(m => m.Id == user.UserId);
  423. if (userAccount == null)
  424. {
  425. userAccount = db.UserAccount.Add(new UserAccount()
  426. {
  427. Id = user.UserId,
  428. UserId = user.UserId,
  429. }).Entity;
  430. db.SaveChanges();
  431. }
  432. userAccount.StoreDeposit = data.Deposit;
  433. db.SaveChanges();
  434. RedisDbconn.Instance.AddList("ResetStoreReserveQueue", user.UserId.ToString());
  435. decimal olddeposit = 0;//旧押金
  436. decimal newdeposit = 0;//新押金
  437. var sto = db.StoreHouse.FirstOrDefault(m => m.Id == data.Id);
  438. newdeposit = data.Deposit;
  439. olddeposit = sto.Deposit;
  440. if (sto.OpId > 0)
  441. {
  442. var amount = opdb.UserAccount.FirstOrDefault(m => m.UserId == sto.OpId) ?? new OpModels.UserAccount();
  443. if (newdeposit > olddeposit)
  444. {
  445. var amoutRecord = opdb.AmountRecord.Add(new OpModels.AmountRecord
  446. {
  447. CreateDate = DateTime.Now,
  448. UserId = sto.OpId,
  449. SeoDescription = "分仓押金变更",
  450. OperateType = 1,
  451. UseAmount = newdeposit - olddeposit,
  452. BeforeAmount = amount.ValidAmount,
  453. AfterAmount = amount.ValidAmount + newdeposit - olddeposit,
  454. }).Entity;
  455. opdb.SaveChanges();
  456. }
  457. if (newdeposit < olddeposit)
  458. {
  459. var amoutRecord = opdb.AmountRecord.Add(new OpModels.AmountRecord
  460. {
  461. CreateDate = DateTime.Now,
  462. UserId = sto.OpId,
  463. SeoDescription = "分仓押金变更",
  464. OperateType = 2,
  465. UseAmount = olddeposit - newdeposit,
  466. BeforeAmount = amount.ValidAmount,
  467. AfterAmount = amount.ValidAmount + newdeposit - olddeposit,
  468. }).Entity;
  469. opdb.SaveChanges();
  470. }
  471. amount.ValidAmount -= sto.Deposit;
  472. amount.ValidAmount += data.Deposit;
  473. opdb.SaveChanges();
  474. }
  475. foreach (var item in store)
  476. {
  477. var storeInfo = store.FirstOrDefault(m => m.Id == item.Id);
  478. storeInfo.Deposit = data.Deposit;
  479. db.SaveChanges();
  480. }
  481. Fields.Add("ManageUserId", manage.UserId); //仓库管理员
  482. Fields.Add("ManagerEmail", data.ManagerEmail); //管理者邮箱
  483. Fields.Add("ManageMobile", data.ManageMobile);
  484. Fields.Add("Remark", data.Remark); //备注
  485. Fields.Add("LimitTopUserId", data.LimitTopUserId); //限制创客特殊仓库
  486. Fields.Add("StoreKind", data.StoreKind); //仓库归属类型
  487. Fields.Add("Status", data.Status);
  488. Fields.Add("StoreStatus", data.Status);
  489. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("StoreHouse", Fields, data.Id);
  490. AddSysLog(data.Id.ToString(), "StoreHouse", "update");
  491. db.SaveChanges();
  492. SetRedis(data.Id, user.UserId);
  493. return "success";
  494. }
  495. #endregion
  496. #region 一键添加仓库
  497. /// <summary>
  498. /// 一件添加仓库
  499. /// </summary>
  500. /// <returns></returns>
  501. public IActionResult Edits(string right, int Id = 0)
  502. {
  503. ViewBag.RightInfo = RightInfo;
  504. ViewBag.right = right;
  505. StoreHouse editData = db.StoreHouse.FirstOrDefault(m => m.Id == Id) ?? new StoreHouse();
  506. ViewBag.data = editData;
  507. Users manage = db.Users.FirstOrDefault(m => m.Id == editData.ManageUserId) ?? new Users();
  508. ViewBag.ManageMakerCode = manage.MakerCode;
  509. ViewBag.ManageRealName = manage.RealName;
  510. Users user = db.Users.FirstOrDefault(m => m.Id == editData.ManageUserId) ?? new Users();
  511. ViewBag.MakerCode = user.MakerCode;
  512. return View();
  513. }
  514. #endregion
  515. #region 一键添加仓库
  516. /// <summary>
  517. /// 一键添加仓库
  518. /// </summary>
  519. /// <returns></returns>
  520. [HttpPost]
  521. public string Edits(StoreHouse data, string ManageMakerCode, string MakerCode)
  522. {
  523. Dictionary<string, object> Fields = new Dictionary<string, object>();
  524. StoreHouse storeHouse = db.StoreHouse.FirstOrDefault(m => m.Id == data.Id);
  525. var brand = db.StoreHouse.FirstOrDefault(m => m.UserId == storeHouse.UserId && m.BrandId == data.BrandId && m.OpId == 0);
  526. if (brand != null)
  527. {
  528. return "您已有该品牌类型的仓库,请重新选择";
  529. }
  530. var name = db.StoreHouse.FirstOrDefault(m => m.UserId == storeHouse.UserId && m.StoreName == data.StoreName);
  531. if (name != null)
  532. {
  533. return "您的仓库名重复,请重新填写";
  534. }
  535. Fields.Add("StoreName", data.StoreName); //仓库名称
  536. UserForMakerCode user = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  537. if (user == null)
  538. {
  539. return "您输入的仓库归属创客编号不存在,请重新输入正确的仓库归属创客编号";
  540. }
  541. Fields.Add("UserId", user.UserId); //仓库归属人
  542. Fields.Add("Areas", data.Areas); //所属地区
  543. Fields.Add("Address", data.Address); //仓库地址
  544. UserForMakerCode manage = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == ManageMakerCode);
  545. if (manage == null)
  546. {
  547. return "您输入的仓库负责人编号不存在,请重新输入正确的仓库负责人编号";
  548. }
  549. Fields.Add("CreateMan", SysUserName); //创建人
  550. Fields.Add("ManageUserId", manage.UserId); //仓库管理员
  551. Fields.Add("ManagerEmail", data.ManagerEmail); //管理者邮箱
  552. Fields.Add("ManageMobile", data.ManageMobile);
  553. Fields.Add("Remark", data.Remark); //备注
  554. Fields.Add("FilePath", data.FilePath); //附件
  555. Fields.Add("Deposit", data.Deposit); //押金
  556. Fields.Add("LimitTopUserId", data.LimitTopUserId); //限制创客特殊仓库
  557. Fields.Add("StoreKind", data.StoreKind); //仓库归属类型
  558. int bid = Convert.ToInt32(data.BrandId);
  559. KqProducts pro = db.KqProducts.FirstOrDefault(m => m.Id == bid) ?? new KqProducts();
  560. Fields.Add("BrandId", data.BrandId);
  561. Fields.Add("ProductName", pro.Name);
  562. Fields.Add("StoreStatus", 1);
  563. Fields.Add("Status", 1);
  564. int Id = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Add("StoreHouse", Fields, 0);
  565. //添加分仓创建时间
  566. var users = db.Users.FirstOrDefault(m => m.Id == user.UserId) ?? new Users();
  567. if (users.Id > 0)
  568. {
  569. if (string.IsNullOrEmpty(users.CreateStoreDate.ToString()))
  570. {
  571. users.CreateStoreDate = DateTime.Now;
  572. db.SaveChanges();
  573. }
  574. }
  575. StoreHouse edit = db.StoreHouse.FirstOrDefault(m => m.Id == Id);
  576. if (edit != null)
  577. {
  578. string No = Id.ToString();
  579. for (int i = 0; i < 7 - Id.ToString().Length; i++)
  580. {
  581. No = "0" + No;
  582. }
  583. No = "S" + No;
  584. edit.StoreNo = No;
  585. db.StoreForCode.Add(new StoreForCode()
  586. {
  587. Code = No,
  588. StoreId = Id,
  589. });
  590. RedisDbconn.Instance.Set("StoreForCode:" + No, Id);
  591. }
  592. StoreForName storeForName = db.StoreForName.FirstOrDefault(m => m.Name == data.StoreName);
  593. if (storeForName == null)
  594. {
  595. db.StoreForName.Add(new StoreForName()
  596. {
  597. Name = data.StoreName,
  598. StoreId = Id,
  599. });
  600. }
  601. else
  602. {
  603. storeForName.StoreId = Id;
  604. }
  605. RedisDbconn.Instance.Set("StoreForName:" + data.StoreName, Id);
  606. AddSysLog(data.Id.ToString(), "StoreHouse", "add");
  607. db.SaveChanges();
  608. SetRedis(Id, user.UserId);
  609. return "success";
  610. }
  611. #endregion
  612. #region 删除仓库信息
  613. /// <summary>
  614. /// 删除仓库信息
  615. /// </summary>
  616. /// <returns></returns>
  617. public string Delete(string Id)
  618. {
  619. string[] idlist = Id.Split(new char[] { ',' });
  620. AddSysLog(Id, "StoreHouse", "del");
  621. foreach (string subid in idlist)
  622. {
  623. int id = int.Parse(subid);
  624. Dictionary<string, object> Fields = new Dictionary<string, object>();
  625. Fields.Add("Status", -1);
  626. StoreHouse edit = db.StoreHouse.FirstOrDefault(m => m.Id == id);
  627. if (edit != null)
  628. {
  629. StoreForCode code = db.StoreForCode.FirstOrDefault(m => m.Code == edit.StoreNo);
  630. if (code != null)
  631. {
  632. db.StoreForCode.Remove(code);
  633. }
  634. StoreForName name = db.StoreForName.FirstOrDefault(m => m.Name == edit.StoreName);
  635. if (name != null)
  636. {
  637. db.StoreForName.Remove(name);
  638. }
  639. }
  640. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("StoreHouse", Fields, id);
  641. }
  642. db.SaveChanges();
  643. return "success";
  644. }
  645. #endregion
  646. #region 开启
  647. /// <summary>
  648. /// 开启
  649. /// </summary>
  650. /// <returns></returns>
  651. public string Open(string Id)
  652. {
  653. string[] idlist = Id.Split(new char[] { ',' });
  654. AddSysLog(Id, "StoreHouse", "open");
  655. foreach (string subid in idlist)
  656. {
  657. int id = int.Parse(subid);
  658. Dictionary<string, object> Fields = new Dictionary<string, object>();
  659. Fields.Add("Status", 1);
  660. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("StoreHouse", Fields, id);
  661. }
  662. db.SaveChanges();
  663. return "success";
  664. }
  665. #endregion
  666. #region 关闭
  667. /// <summary>
  668. /// 关闭
  669. /// </summary>
  670. /// <returns></returns>
  671. public string Close(string Id)
  672. {
  673. string[] idlist = Id.Split(new char[] { ',' });
  674. AddSysLog(Id, "StoreHouse", "close");
  675. foreach (string subid in idlist)
  676. {
  677. int id = int.Parse(subid);
  678. Dictionary<string, object> Fields = new Dictionary<string, object>();
  679. Fields.Add("Status", 0);
  680. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("StoreHouse", Fields, id);
  681. }
  682. db.SaveChanges();
  683. return "success";
  684. }
  685. #endregion
  686. #region 排序
  687. /// <summary>
  688. /// 排序
  689. /// </summary>
  690. /// <param name="Id"></param>
  691. public string Sort(int Id, int Sort)
  692. {
  693. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Sort("StoreHouse", Sort, Id);
  694. AddSysLog(Id.ToString(), "StoreHouse", "sort");
  695. return "success";
  696. }
  697. #endregion
  698. #region 导入数据
  699. public IActionResult Import(string right, string ExcelKind)
  700. {
  701. ViewBag.RightInfo = RightInfo;
  702. ViewBag.right = right;
  703. ViewBag.ExcelKind = ExcelKind;
  704. return View();
  705. }
  706. /// <summary>
  707. /// 导入数据
  708. /// </summary>
  709. /// <param name="ExcelData"></param>
  710. [HttpPost]
  711. public string ImportPost(string ExcelPath, int Kind = 0)
  712. {
  713. // RedisDbconn.Instance.AddList("ExcelImport", ExcelPath + "#cut#" + Kind);
  714. string key = function.MD5_16(Guid.NewGuid().ToString());
  715. RedisDbconn.Instance.AddList("ExcelImportV2", ExcelPath + "#cut#" + Kind + "#cut#" + key + "#cut#" + SysUserName);
  716. return "success|" + key;
  717. }
  718. // [HttpPost]
  719. // public Dictionary<string, object> ImportPostV2(string ExcelPath, int Kind = 0)
  720. // {
  721. // Dictionary<string, object> Obj = new Dictionary<string, object>();
  722. // string key = function.MD5_16(Guid.NewGuid().ToString());
  723. // RedisDbconn.Instance.AddList("ExcelImportV2", ExcelPath + "#cut#" + Kind + "#cut#" + key);
  724. // Obj.Add("status", "success");
  725. // Obj.Add("key", key);
  726. // Obj.Add("errlist", RedisDbconn.Instance.GetList<string>("ErrList" + key));
  727. // return Obj;
  728. // }
  729. public string CheckImport(string key)
  730. {
  731. string result = RedisDbconn.Instance.Get<string>("CheckImport:" + key);
  732. if (!string.IsNullOrEmpty(result))
  733. {
  734. string[] datalist = result.Split('|');
  735. if (datalist[0] == "success")
  736. {
  737. return result;
  738. }
  739. return datalist[0];
  740. }
  741. return "0";
  742. }
  743. public Dictionary<string, object> CheckImportV2(string key)
  744. {
  745. Dictionary<string, object> Obj = new Dictionary<string, object>();
  746. string result = RedisDbconn.Instance.Get<string>("CheckImport:" + key);
  747. if (!string.IsNullOrEmpty(result))
  748. {
  749. string[] datalist = result.Split('|');
  750. if (datalist[0] == "success")
  751. {
  752. List<string> errList = RedisDbconn.Instance.GetList<string>("ErrList" + key);
  753. if (errList.Count > 0)
  754. {
  755. Obj.Add("status", 2);
  756. Obj.Add("errList", errList);
  757. }
  758. else
  759. {
  760. Obj.Add("status", 1);
  761. Obj.Add("data", result);
  762. }
  763. return Obj;
  764. }
  765. Obj.Add("status", 0);
  766. Obj.Add("data", datalist[0]);
  767. return Obj;
  768. }
  769. Obj.Add("status", -1);
  770. Obj.Add("data", "执行中...");
  771. return Obj;
  772. }
  773. #endregion
  774. #region 机具驳回仓库
  775. /// <summary>
  776. /// 机具驳回仓库
  777. /// </summary>
  778. /// <param name="ExcelData"></param>
  779. public string RejectStore(string ExcelData, int ExcelKind = 0)
  780. {
  781. ExcelData = HttpUtility.UrlDecode(ExcelData);
  782. JsonData list = JsonMapper.ToObject(ExcelData);
  783. if (ExcelKind == 1)
  784. {
  785. string error = "";
  786. decimal amount = 0;
  787. List<string> PosSnList = new List<string>();
  788. for (int i = 1; i < list.Count; i++)
  789. {
  790. JsonData dr = list[i];
  791. string itemJson = dr.ToJson();
  792. string PosSn = itemJson.Contains("\"A\"") ? dr["A"].ToString() : "";
  793. string BrandId = itemJson.Contains("\"B\"") ? dr["B"].ToString() : "";
  794. string MakerCode = itemJson.Contains("\"C\"") ? dr["C"].ToString() : "";
  795. string StoreNo = itemJson.Contains("\"D\"") ? dr["D"].ToString() : "";
  796. string No = itemJson.Contains("\"E\"") ? dr["E"].ToString() : "";
  797. string Remark = itemJson.Contains("\"F\"") ? dr["F"].ToString() : "";
  798. UserForMakerCode userForMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
  799. StoreForCode storeForCode = db.StoreForCode.FirstOrDefault(m => m.Code == StoreNo);
  800. var store = db.StoreHouse.FirstOrDefault(m => m.Id == storeForCode.StoreId && m.BrandId == BrandId) ?? new StoreHouse();
  801. MachineForSnNo machineForSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == PosSn) ?? new MachineForSnNo();
  802. var pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == machineForSnNo.SnId && m.BrandId == Convert.ToInt32(BrandId) && m.BindingState == 0 && m.BuyUserId == userForMakerCode.UserId) ?? new PosMachinesTwo();
  803. var posInfo = db.PosMachinesTwo.FirstOrDefault(m => m.Id == machineForSnNo.SnId && m.BrandId == Convert.ToInt32(BrandId) && m.BindingState == 0) ?? new PosMachinesTwo();
  804. if (pos.Id == 0)
  805. {
  806. error += "以下操作失败" + PosSn + ',' + "未找到创客" + MakerCode + "的该台机具" + '\n';
  807. }
  808. if (store.Id == 0)
  809. {
  810. error += "以下操作失败" + PosSn + ',' + StoreNo + ',' + "未找到该仓库" + '\n';
  811. }
  812. if (posInfo.Id == 0)
  813. {
  814. error += "以下操作失败" + PosSn + ',' + "未找到该品牌的未使用机具" + '\n';
  815. }
  816. if (PosSnList.Contains(PosSn))
  817. {
  818. error += "以下操作失败" + PosSn + ',' + "该机具号重复" + '\n';
  819. }
  820. else
  821. {
  822. PosSnList.Add(PosSn);
  823. var fromStore = db.StoreHouse.FirstOrDefault(m => m.Id == pos.StoreId && m.BrandId == BrandId) ?? new StoreHouse();
  824. var toStore = db.StoreHouse.FirstOrDefault(m => m.Id == storeForCode.StoreId && m.BrandId == BrandId) ?? new StoreHouse();
  825. var user = db.Users.FirstOrDefault(m => m.Id == toStore.UserId) ?? new Users();
  826. var userAccount = db.UserAccount.FirstOrDefault(m => m.Id == toStore.UserId) ?? new UserAccount();
  827. var brandInfo = db.KqProducts.FirstOrDefault(m => m.Id == Convert.ToInt32(BrandId)) ?? new KqProducts();
  828. var fuserMachineData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == userForMakerCode.UserId + "_" + brandInfo.Id);
  829. if (brandInfo.Name.Contains("电签"))
  830. {
  831. amount = 200;
  832. }
  833. if (brandInfo.Name.Contains("大POS"))
  834. {
  835. amount = 300;
  836. }
  837. userAccount.ValidAmount -= amount;
  838. db.SaveChanges();
  839. if (posInfo != null)
  840. {
  841. if (fromStore.Id != toStore.Id)
  842. {
  843. var changeNo = "JJBH" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
  844. StoreStockChange stockchange = db.StoreStockChange.Add(new StoreStockChange()
  845. {
  846. CreateDate = DateTime.Now,
  847. StoreId = fromStore.Id, //出货仓库
  848. ToStoreId = toStore.Id, //发货仓库
  849. BrandId = Convert.ToInt32(BrandId), //产品类型
  850. ProductName = RelationClass.GetKqProductBrandInfo(Convert.ToInt32(BrandId)), //产品名称
  851. ChangeNo = changeNo, //变更记录单号
  852. BizBatchNo = No, //业务批次号
  853. TransType = 4, //交易类型
  854. SnNo = PosSn, //SN编号
  855. StockOpDirect = 1, //库存操作方向
  856. SnStatus = 1, //SN状态
  857. DeviceVendor = posInfo.DeviceName, //设备厂商
  858. DeviceModel = posInfo.DeviceKind, //设备型号
  859. DeviceType = posInfo.DeviceType, //设备类型
  860. SourceStoreId = posInfo.SourceStoreId, //源仓库编号
  861. BrandType = posInfo.DeviceType, //品牌类型
  862. }).Entity;
  863. db.SaveChanges();
  864. db.StoreChangeHistory.Add(new StoreChangeHistory()
  865. {
  866. CreateDate = DateTime.Now,
  867. CreateMan = SysUserName,
  868. UserId = user.Id, //创客
  869. FromUserId = user.Id,//来源创客
  870. ToUserId = toStore.UserId,//接收创客
  871. StoreId = fromStore.Id, //出货仓库
  872. ToStoreId = toStore.Id, //发货仓库
  873. BrandId = Convert.ToInt32(BrandId), //产品类型
  874. ChangeRecordNo = changeNo, //变更记录单号
  875. SeoTitle = "机具驳回仓库",
  876. BizBatchNo = No, //业务批次号
  877. TransType = 4,//驳回
  878. SnNo = PosSn, //SN编号
  879. });
  880. db.SaveChanges();
  881. StoreBalance fbalance = db.StoreBalance.Add(new StoreBalance()
  882. {
  883. CreateDate = DateTime.Now,
  884. StoreId = fromStore.Id, //仓库
  885. BrandId = Convert.ToInt32(BrandId), //产品类型
  886. OpStoreNum = 1, //操作库存数
  887. OpSymbol = "-", //操作符
  888. BeforeTotalNum = fromStore.TotalNum, //操作前总库存数
  889. AfterTotalNum = fromStore.TotalNum - 1, //操作后总库存数
  890. BeforeLaveNum = fromStore.LaveNum, //操作前剩余库存数
  891. AfterLaveNum = fromStore.LaveNum - 1, //操作后剩余库存数
  892. BeforeOutNum = fromStore.OutNum, //操作前出库数
  893. AfterOutNum = fromStore.OutNum - 1, //操作后出库数
  894. }).Entity;
  895. db.SaveChanges();
  896. StoreBalance tbalance = db.StoreBalance.Add(new StoreBalance()
  897. {
  898. CreateDate = DateTime.Now,
  899. StoreId = toStore.Id, //仓库
  900. BrandId = Convert.ToInt32(BrandId), //产品类型
  901. OpStoreNum = 1, //操作库存数
  902. OpSymbol = "+", //操作符
  903. BeforeTotalNum = toStore.TotalNum, //操作前总库存数
  904. AfterTotalNum = toStore.TotalNum + 1, //操作后总库存数
  905. BeforeLaveNum = toStore.LaveNum, //操作前剩余库存数
  906. AfterLaveNum = toStore.LaveNum + 1, //操作后剩余库存数
  907. BeforeOutNum = toStore.OutNum, //操作前出库数
  908. AfterOutNum = toStore.OutNum, //操作后出库数
  909. }).Entity;
  910. db.SaveChanges();
  911. posInfo.StoreId = toStore.Id;
  912. posInfo.BuyUserId = 0;
  913. posInfo.UserId = 0;
  914. posInfo.RecycEndDate = null;
  915. posInfo.PosSnType = 0;
  916. posInfo.BindMerchantId = 0;
  917. posInfo.ActivityList = null;
  918. posInfo.ScanQrTrade = 0;
  919. posInfo.DebitCardTrade = 0;
  920. posInfo.PrizeParams = null;
  921. posInfo.IsVip = 0;
  922. posInfo.CreditTrade = 0;
  923. posInfo.UserNav = null;
  924. posInfo.TransferTime = null;
  925. posInfo.IsPurchase = 0;
  926. posInfo.BindingTime = null;
  927. posInfo.BindingState = 0;
  928. posInfo.ActivationTime = null;
  929. posInfo.ActivationState = 0;
  930. posInfo.LeaderUserId = 0;
  931. posInfo.PreUserId = 0;
  932. posInfo.IsFirst = 0;
  933. fuserMachineData.TotalMachineCount -= 1;
  934. fuserMachineData.UnBindCount -= 1;
  935. toStore.TotalNum += 1;
  936. toStore.LaveNum += 1;
  937. fromStore.TotalNum -= 1;
  938. fromStore.LaveNum -= 1;
  939. db.SaveChanges();
  940. }
  941. else
  942. {
  943. var changeNo = "JJBH" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
  944. StoreStockChange stockchange = db.StoreStockChange.Add(new StoreStockChange()
  945. {
  946. CreateDate = DateTime.Now,
  947. StoreId = fromStore.Id, //出货仓库
  948. ToStoreId = toStore.Id, //发货仓库
  949. BrandId = Convert.ToInt32(BrandId), //产品类型
  950. ProductName = RelationClass.GetKqProductBrandInfo(Convert.ToInt32(BrandId)), //产品名称
  951. ChangeNo = changeNo, //变更记录单号
  952. BizBatchNo = No, //业务批次号
  953. TransType = 4, //交易类型
  954. SnNo = PosSn, //SN编号
  955. StockOpDirect = 1, //库存操作方向
  956. SnStatus = 1, //SN状态
  957. DeviceVendor = posInfo.DeviceName, //设备厂商
  958. DeviceModel = posInfo.DeviceKind, //设备型号
  959. DeviceType = posInfo.DeviceType, //设备类型
  960. SourceStoreId = posInfo.SourceStoreId, //源仓库编号
  961. BrandType = posInfo.DeviceType, //品牌类型
  962. }).Entity;
  963. db.SaveChanges();
  964. db.StoreChangeHistory.Add(new StoreChangeHistory()
  965. {
  966. CreateDate = DateTime.Now,
  967. CreateMan = SysUserName,
  968. UserId = user.Id, //创客
  969. FromUserId = user.Id,//来源创客
  970. ToUserId = toStore.UserId,//接收创客
  971. StoreId = fromStore.Id, //出货仓库
  972. ToStoreId = toStore.Id, //发货仓库
  973. BrandId = Convert.ToInt32(BrandId), //产品类型
  974. ChangeRecordNo = changeNo, //变更记录单号
  975. SeoTitle = "机具驳回仓库",
  976. BizBatchNo = No, //业务批次号
  977. SnNo = PosSn, //SN编号
  978. TransType = 4,//驳回
  979. });
  980. db.SaveChanges();
  981. StoreBalance balance = db.StoreBalance.Add(new StoreBalance()
  982. {
  983. CreateDate = DateTime.Now,
  984. StoreId = fromStore.Id, //仓库
  985. BrandId = Convert.ToInt32(BrandId), //产品类型
  986. OpStoreNum = 1, //操作库存数
  987. OpSymbol = "-", //操作符
  988. BeforeTotalNum = fromStore.TotalNum, //操作前总库存数
  989. AfterTotalNum = fromStore.TotalNum - 1, //操作后总库存数
  990. BeforeLaveNum = fromStore.LaveNum, //操作前剩余库存数
  991. AfterLaveNum = fromStore.LaveNum - 1, //操作后剩余库存数
  992. BeforeOutNum = fromStore.OutNum, //操作前出库数
  993. AfterOutNum = fromStore.OutNum - 1, //操作后出库数
  994. }).Entity;
  995. db.SaveChanges();
  996. posInfo.StoreId = toStore.Id;
  997. posInfo.BuyUserId = 0;
  998. posInfo.UserId = 0;
  999. posInfo.RecycEndDate = null;
  1000. posInfo.PosSnType = 0;
  1001. posInfo.BindMerchantId = 0;
  1002. posInfo.ActivityList = null;
  1003. posInfo.ScanQrTrade = 0;
  1004. posInfo.DebitCardTrade = 0;
  1005. posInfo.PrizeParams = null;
  1006. posInfo.IsVip = 0;
  1007. posInfo.CreditTrade = 0;
  1008. posInfo.UserNav = null;
  1009. posInfo.TransferTime = null;
  1010. posInfo.IsPurchase = 0;
  1011. posInfo.BindingTime = null;
  1012. posInfo.BindingState = 0;
  1013. posInfo.ActivationTime = null;
  1014. posInfo.ActivationState = 0;
  1015. posInfo.LeaderUserId = 0;
  1016. posInfo.PreUserId = 0;
  1017. posInfo.IsFirst = 0;
  1018. fuserMachineData.TotalMachineCount -= 1;
  1019. fuserMachineData.UnBindCount -= 1;
  1020. toStore.LaveNum += 1;
  1021. toStore.TotalNum += 1;
  1022. db.SaveChanges();
  1023. }
  1024. db.SaveChanges();
  1025. }
  1026. }
  1027. }
  1028. if (!string.IsNullOrEmpty(error))
  1029. {
  1030. return "Warning|" + error;
  1031. }
  1032. }
  1033. AddSysLog("0", "MachinesRejectStore", "Import");
  1034. return "success";
  1035. }
  1036. #endregion
  1037. #region 导出Excel
  1038. /// <summary>
  1039. /// 导出Excel
  1040. /// </summary>
  1041. /// <returns></returns>
  1042. public JsonResult ExportExcel(StoreHouse data, string UserIdMakerCode, string UserIdRealName, string ManageUserIdRealName, string ManageUserIdMobile, string ManageUserIdMakerCode, string StoreStatusSelect)
  1043. {
  1044. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1045. Fields.Add("StoreNo", "1"); //仓库编号
  1046. Fields.Add("CreateDate", "3"); //时间
  1047. Fields.Add("StoreName", "1"); //仓库名称
  1048. Fields.Add("ManagerEmail", "1"); //管理者邮箱
  1049. string condition = " and Status>-1";
  1050. //仓库归属人创客编号
  1051. if (!string.IsNullOrEmpty(UserIdMakerCode))
  1052. {
  1053. condition += " and UserId in (select UserId from UserForMakerCode where MakerCode='" + UserIdMakerCode + "')";
  1054. }
  1055. //仓库归属人真实姓名
  1056. if (!string.IsNullOrEmpty(UserIdRealName))
  1057. {
  1058. condition += " and UserId in (select UserId from UserForRealName where RealName='" + UserIdRealName + "')";
  1059. }
  1060. //仓库管理员真实姓名
  1061. if (!string.IsNullOrEmpty(ManageUserIdRealName))
  1062. {
  1063. condition += " and ManageUserId in (select ManageUserId from UserForRealName where RealName='" + ManageUserIdRealName + "')";
  1064. }
  1065. //仓库管理员手机号
  1066. if (!string.IsNullOrEmpty(ManageUserIdMobile))
  1067. {
  1068. condition += " and ManageUserId in (select ManageUserId from UserForMobile where Mobile='" + ManageUserIdMobile + "')";
  1069. }
  1070. //仓库管理员创客编号
  1071. if (!string.IsNullOrEmpty(ManageUserIdMakerCode))
  1072. {
  1073. condition += " and ManageUserId in (select ManageUserId from UserForMakerCode where MakerCode='" + ManageUserIdMakerCode + "')";
  1074. }
  1075. //仓库状态
  1076. if (!string.IsNullOrEmpty(StoreStatusSelect))
  1077. {
  1078. condition += " and StoreStatus=" + StoreStatusSelect;
  1079. }
  1080. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("StoreHouse", Fields, "Id desc", "0", 1, 20000, condition, "StoreNo,StoreName,UserId,BrandId,Address,ManageUserId,ManagerEmail,StoreType,TotalNum,LaveNum,OutNum,LimitTopUserId,StoreStatus,StoreKind", false);
  1081. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1082. foreach (Dictionary<string, object> dic in diclist)
  1083. {
  1084. //仓库归属人
  1085. int UserId = int.Parse(function.CheckInt(dic["UserId"].ToString()));
  1086. Users userid_Users = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  1087. dic["UserIdMakerCode"] = userid_Users.MakerCode;
  1088. dic["UserIdRealName"] = userid_Users.RealName;
  1089. //产品类型
  1090. dic["BrandId"] = RelationClass.GetKqProductBrandList(dic["BrandId"].ToString());
  1091. //仓库管理员
  1092. int ManageUserId = int.Parse(function.CheckInt(dic["ManageUserId"].ToString()));
  1093. Users manageuserid_Users = db.Users.FirstOrDefault(m => m.Id == ManageUserId) ?? new Users();
  1094. dic["ManageUserIdRealName"] = manageuserid_Users.RealName;
  1095. dic["ManageUserIdMobile"] = manageuserid_Users.Mobile;
  1096. dic["ManageUserIdMakerCode"] = manageuserid_Users.MakerCode;
  1097. //仓库类型
  1098. int StoreType = int.Parse(dic["StoreType"].ToString());
  1099. if (StoreType == 0) dic["StoreType"] = "实体仓";
  1100. if (StoreType == 1) dic["StoreType"] = "虚拟仓";
  1101. //仓库状态
  1102. int StoreStatus = int.Parse(dic["StoreStatus"].ToString());
  1103. if (StoreStatus == 1) dic["StoreStatus"] = "启用";
  1104. if (StoreStatus == 0) dic["StoreStatus"] = "禁用";
  1105. //仓库归属类型
  1106. int StoreKind = int.Parse(dic["StoreKind"].ToString());
  1107. if (StoreKind == 0) dic["StoreKind"] = "分仓";
  1108. if (StoreKind == 1) dic["StoreKind"] = "总仓";
  1109. }
  1110. Dictionary<string, object> result = new Dictionary<string, object>();
  1111. result.Add("Status", "1");
  1112. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1113. result.Add("Obj", diclist);
  1114. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  1115. ReturnFields.Add("StoreNo", "仓库编号");
  1116. ReturnFields.Add("StoreName", "仓库名称");
  1117. ReturnFields.Add("UserIdMakerCode", "仓库归属人创客编号");
  1118. ReturnFields.Add("UserIdRealName", "仓库归属人真实姓名");
  1119. ReturnFields.Add("BrandId", "产品类型");
  1120. ReturnFields.Add("Address", "仓库地址");
  1121. ReturnFields.Add("ManageUserIdRealName", "仓库管理员真实姓名");
  1122. ReturnFields.Add("ManageUserIdMobile", "仓库管理员手机号");
  1123. ReturnFields.Add("ManageUserIdMakerCode", "仓库管理员创客编号");
  1124. ReturnFields.Add("ManagerEmail", "管理者邮箱");
  1125. ReturnFields.Add("StoreType", "仓库类型");
  1126. ReturnFields.Add("TotalNum", "总库存数");
  1127. ReturnFields.Add("LaveNum", "剩余库存数");
  1128. ReturnFields.Add("OutNum", "出库数");
  1129. ReturnFields.Add("LimitTopUserId", "限制创客特殊仓库");
  1130. ReturnFields.Add("StoreStatus", "仓库状态");
  1131. ReturnFields.Add("StoreKind", "仓库归属类型");
  1132. result.Add("Fields", ReturnFields);
  1133. AddSysLog("0", "StoreHouse", "ExportExcel");
  1134. return Json(result);
  1135. }
  1136. #endregion
  1137. #region 仓库列表
  1138. /// <summary>
  1139. /// 根据条件查询仓库列表
  1140. /// </summary>
  1141. /// <returns></returns>
  1142. public IActionResult Stat(StoreHouse data, string right)
  1143. {
  1144. ViewBag.RightInfo = RightInfo;
  1145. ViewBag.right = right;
  1146. return View();
  1147. }
  1148. #endregion
  1149. #region 根据条件查询仓库列表
  1150. /// <summary>
  1151. /// 仓库列表
  1152. /// </summary>
  1153. /// <returns></returns>
  1154. public JsonResult StatDo(string CreateDateData, int page = 1, int limit = 30)
  1155. {
  1156. OtherMySqlConn.connstr = ConfigurationManager.AppSettings["StatSqlConnStr"].ToString();
  1157. string sCreateDate = DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00";
  1158. string eCreateDate = DateTime.Now.ToString("yyyy-MM-dd") + " 23:59:59";
  1159. if (!string.IsNullOrEmpty(CreateDateData))
  1160. {
  1161. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  1162. sCreateDate = datelist[0] + " 00:00:00";
  1163. eCreateDate = datelist[1] + " 23:59:59";
  1164. }
  1165. else
  1166. {
  1167. Dictionary<string, object> nodata = new Dictionary<string, object>();
  1168. nodata.Add("code", 0);
  1169. nodata.Add("msg", "");
  1170. nodata.Add("count", 0);
  1171. nodata.Add("data", new List<Dictionary<string, object>>());
  1172. return Json(nodata);
  1173. }
  1174. string minId = "0";
  1175. string maxId = "0";
  1176. string minPosId = "0";
  1177. string maxPosId = "0";
  1178. DataTable startDt = OtherMySqlConn.dtable("select min(Id) from StoreStockChange where CreateDate>='" + sCreateDate + "'");
  1179. if (startDt.Rows.Count > 0)
  1180. {
  1181. minId = function.CheckInt(startDt.Rows[0][0].ToString());
  1182. if (minId == "0")
  1183. {
  1184. startDt = OtherMySqlConn.dtable("select max(Id) from StoreStockChange");
  1185. if (startDt.Rows.Count > 0)
  1186. {
  1187. minId = function.CheckInt(startDt.Rows[0][0].ToString());
  1188. }
  1189. }
  1190. }
  1191. DataTable endDt = OtherMySqlConn.dtable("select max(Id) from StoreStockChange where CreateDate>='" + sCreateDate + "'");
  1192. if (endDt.Rows.Count > 0)
  1193. {
  1194. maxId = function.CheckInt(endDt.Rows[0][0].ToString());
  1195. if (minId == "0")
  1196. {
  1197. endDt = OtherMySqlConn.dtable("select max(Id) from StoreStockChange");
  1198. if (endDt.Rows.Count > 0)
  1199. {
  1200. maxId = function.CheckInt(endDt.Rows[0][0].ToString());
  1201. }
  1202. }
  1203. }
  1204. DataTable startPosDt = OtherMySqlConn.dtable("select min(Id) from PosMachinesTwo where ActivationTime>='" + sCreateDate + "'");
  1205. if (startPosDt.Rows.Count > 0)
  1206. {
  1207. minPosId = function.CheckInt(startPosDt.Rows[0][0].ToString());
  1208. if (minPosId == "0")
  1209. {
  1210. startPosDt = OtherMySqlConn.dtable("select max(Id) from PosMachinesTwo");
  1211. if (startPosDt.Rows.Count > 0)
  1212. {
  1213. minPosId = function.CheckInt(startPosDt.Rows[0][0].ToString());
  1214. }
  1215. }
  1216. }
  1217. DataTable endPosDt = OtherMySqlConn.dtable("select max(Id) from PosMachinesTwo where ActivationTime>='" + sCreateDate + "'");
  1218. if (endPosDt.Rows.Count > 0)
  1219. {
  1220. maxPosId = function.CheckInt(endPosDt.Rows[0][0].ToString());
  1221. if (maxPosId == "0")
  1222. {
  1223. endPosDt = OtherMySqlConn.dtable("select max(Id) from PosMachinesTwo");
  1224. if (endPosDt.Rows.Count > 0)
  1225. {
  1226. maxPosId = function.CheckInt(endPosDt.Rows[0][0].ToString());
  1227. }
  1228. }
  1229. }
  1230. DataTable list = OtherMySqlConn.dtable("select * from (select s.StoreName,s.StoreNo,u.RealName,u.Mobile,k.Name,s.LaveNum,(select count(Id) from StoreStockChange where Id>=" + minId + " and Id<=" + maxId + " and CreateDate>='" + sCreateDate + "' and CreateDate<='" + eCreateDate + "' and StoreId=s.Id and TransType=1) as c1,(select count(Id) from StoreStockChange where Id>=" + minId + " and Id<=" + maxId + " and CreateDate>='" + sCreateDate + "' and CreateDate<='" + eCreateDate + "' and StoreId=s.Id and TransType in (10,11,2)) as c2,(select count(Id) from PosMachinesTwo where Id>=" + minPosId + " and Id<=" + maxPosId + " and ActivationState=1 and ActivationTime>='" + sCreateDate + "' and ActivationTime<='" + eCreateDate + "' and StoreId=s.Id) as c3 from StoreHouse s left join Users u on s.BrandId>0 and s.UserId=u.Id left join KqProducts k on s.BrandId=k.Id) tb where c1>0 or c2>0 or c3>0");
  1231. int recordcount = list.Rows.Count;
  1232. List<Dictionary<string, object>> diclist = new List<Dictionary<string, object>>();
  1233. foreach (DataRow sub in list.Rows)
  1234. {
  1235. Dictionary<string, object> row = new Dictionary<string, object>();
  1236. row.Add("StoreName", sub["StoreName"].ToString());
  1237. row.Add("StoreNo", sub["StoreNo"].ToString());
  1238. row.Add("Mobile", sub["Mobile"].ToString());
  1239. row.Add("RealName", sub["RealName"].ToString());
  1240. row.Add("Name", sub["Name"].ToString());
  1241. row.Add("LaveNum", sub["LaveNum"].ToString());
  1242. row.Add("c1", sub["c1"].ToString());
  1243. row.Add("c2", sub["c2"].ToString());
  1244. row.Add("c3", sub["c3"].ToString());
  1245. diclist.Add(row);
  1246. }
  1247. Dictionary<string, object> obj = new Dictionary<string, object>();
  1248. obj.Add("code", 0);
  1249. obj.Add("msg", "");
  1250. obj.Add("count", recordcount);
  1251. obj.Add("data", diclist);
  1252. return Json(obj);
  1253. }
  1254. #endregion
  1255. #region 导出Excel
  1256. /// <summary>
  1257. /// 导出Excel
  1258. /// </summary>
  1259. /// <returns></returns>
  1260. public JsonResult StatExportExcel(string CreateDateData)
  1261. {
  1262. OtherMySqlConn.connstr = ConfigurationManager.AppSettings["StatSqlConnStr"].ToString();
  1263. string sCreateDate = DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00";
  1264. string eCreateDate = DateTime.Now.ToString("yyyy-MM-dd") + " 23:59:59";
  1265. if (!string.IsNullOrEmpty(CreateDateData))
  1266. {
  1267. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  1268. sCreateDate = datelist[0] + " 00:00:00";
  1269. eCreateDate = datelist[1] + " 23:59:59";
  1270. }
  1271. else
  1272. {
  1273. Dictionary<string, object> nodata = new Dictionary<string, object>();
  1274. nodata.Add("Status", "1");
  1275. nodata.Add("Info", "分仓统计数据报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1276. nodata.Add("Obj", new List<Dictionary<string, object>>());
  1277. Dictionary<string, object> NoDataReturnFields = new Dictionary<string, object>();
  1278. NoDataReturnFields.Add("StoreName", "仓库名称");
  1279. NoDataReturnFields.Add("StoreNo", "仓库编号");
  1280. NoDataReturnFields.Add("Mobile", "仓库所属人手机号");
  1281. NoDataReturnFields.Add("RealName", "仓库所属人名称");
  1282. NoDataReturnFields.Add("MakerCode", "仓库所属人编码");
  1283. NoDataReturnFields.Add("ManageMakerCode", "仓库管理员编码");
  1284. NoDataReturnFields.Add("Name", "品牌");
  1285. NoDataReturnFields.Add("LaveNum", "当前库存");
  1286. NoDataReturnFields.Add("c1", "出库(调拨)量");
  1287. NoDataReturnFields.Add("c2", "出货(发货到创客)量");
  1288. NoDataReturnFields.Add("c3", "激活量");
  1289. nodata.Add("Fields", NoDataReturnFields);
  1290. return Json(nodata);
  1291. }
  1292. string minId = "0";
  1293. string maxId = "0";
  1294. string minPosId = "0";
  1295. string maxPosId = "0";
  1296. DataTable startDt = OtherMySqlConn.dtable("select min(Id) from StoreStockChange where CreateDate>='" + sCreateDate + "'");
  1297. if (startDt.Rows.Count > 0)
  1298. {
  1299. minId = function.CheckInt(startDt.Rows[0][0].ToString());
  1300. if (minId == "0")
  1301. {
  1302. startDt = OtherMySqlConn.dtable("select max(Id) from StoreStockChange");
  1303. if (startDt.Rows.Count > 0)
  1304. {
  1305. minId = function.CheckInt(startDt.Rows[0][0].ToString());
  1306. }
  1307. }
  1308. }
  1309. DataTable endDt = OtherMySqlConn.dtable("select max(Id) from StoreStockChange where CreateDate>='" + sCreateDate + "'");
  1310. if (endDt.Rows.Count > 0)
  1311. {
  1312. maxId = function.CheckInt(endDt.Rows[0][0].ToString());
  1313. if (minId == "0")
  1314. {
  1315. endDt = OtherMySqlConn.dtable("select max(Id) from StoreStockChange");
  1316. if (endDt.Rows.Count > 0)
  1317. {
  1318. maxId = function.CheckInt(endDt.Rows[0][0].ToString());
  1319. }
  1320. }
  1321. }
  1322. DataTable startPosDt = OtherMySqlConn.dtable("select min(Id) from PosMachinesTwo where ActivationTime>='" + sCreateDate + "'");
  1323. if (startPosDt.Rows.Count > 0)
  1324. {
  1325. minPosId = function.CheckInt(startPosDt.Rows[0][0].ToString());
  1326. if (minPosId == "0")
  1327. {
  1328. startPosDt = OtherMySqlConn.dtable("select max(Id) from PosMachinesTwo");
  1329. if (startPosDt.Rows.Count > 0)
  1330. {
  1331. minPosId = function.CheckInt(startPosDt.Rows[0][0].ToString());
  1332. }
  1333. }
  1334. }
  1335. DataTable endPosDt = OtherMySqlConn.dtable("select max(Id) from PosMachinesTwo where ActivationTime>='" + sCreateDate + "'");
  1336. if (endPosDt.Rows.Count > 0)
  1337. {
  1338. maxPosId = function.CheckInt(endPosDt.Rows[0][0].ToString());
  1339. if (maxPosId == "0")
  1340. {
  1341. endPosDt = OtherMySqlConn.dtable("select max(Id) from PosMachinesTwo");
  1342. if (endPosDt.Rows.Count > 0)
  1343. {
  1344. maxPosId = function.CheckInt(endPosDt.Rows[0][0].ToString());
  1345. }
  1346. }
  1347. }
  1348. DataTable list = OtherMySqlConn.dtable("select * from (select s.StoreName,s.StoreNo,u.RealName,u.Mobile,u.MakerCode,(select MakerCode from Users where Id=s.ManageUserId) as ManageMakerCode,k.Name,s.LaveNum,(select count(Id) from StoreStockChange where Id>=" + minId + " and Id<=" + maxId + " and CreateDate>='" + sCreateDate + "' and CreateDate<='" + eCreateDate + "' and StoreId=s.Id and TransType=1) as c1,(select count(Id) from StoreStockChange where Id>=" + minId + " and Id<=" + maxId + " and CreateDate>='" + sCreateDate + "' and CreateDate<='" + eCreateDate + "' and StoreId=s.Id and TransType in (10,11,2)) as c2,(select count(Id) from PosMachinesTwo where Id>=" + minPosId + " and Id<=" + maxPosId + " and ActivationState=1 and ActivationTime>='" + sCreateDate + "' and ActivationTime<='" + eCreateDate + "' and StoreId=s.Id) as c3 from StoreHouse s left join Users u on s.BrandId>0 and s.UserId=u.Id left join KqProducts k on s.BrandId=k.Id) tb where c1>0 or c2>0 or c3>0");
  1349. int recordcount = list.Rows.Count;
  1350. List<Dictionary<string, object>> diclist = new List<Dictionary<string, object>>();
  1351. foreach (DataRow sub in list.Rows)
  1352. {
  1353. Dictionary<string, object> row = new Dictionary<string, object>();
  1354. row.Add("StoreName", sub["StoreName"].ToString());
  1355. row.Add("StoreNo", sub["StoreNo"].ToString());
  1356. row.Add("Mobile", sub["Mobile"].ToString());
  1357. row.Add("RealName", sub["RealName"].ToString());
  1358. row.Add("MakerCode", sub["MakerCode"].ToString());
  1359. row.Add("ManageMakerCode", sub["ManageMakerCode"].ToString());
  1360. row.Add("Name", sub["Name"].ToString());
  1361. row.Add("LaveNum", sub["LaveNum"].ToString());
  1362. row.Add("c1", sub["c1"].ToString());
  1363. row.Add("c2", sub["c2"].ToString());
  1364. row.Add("c3", sub["c3"].ToString());
  1365. diclist.Add(row);
  1366. }
  1367. Dictionary<string, object> result = new Dictionary<string, object>();
  1368. result.Add("Status", "1");
  1369. result.Add("Info", "分仓统计数据报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1370. result.Add("Obj", diclist);
  1371. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  1372. ReturnFields.Add("StoreName", "仓库名称");
  1373. ReturnFields.Add("StoreNo", "仓库编号");
  1374. ReturnFields.Add("Mobile", "仓库所属人手机号");
  1375. ReturnFields.Add("RealName", "仓库所属人名称");
  1376. ReturnFields.Add("MakerCode", "仓库所属人编码");
  1377. ReturnFields.Add("ManageMakerCode", "仓库管理员编码");
  1378. ReturnFields.Add("Name", "品牌");
  1379. ReturnFields.Add("LaveNum", "当前库存");
  1380. ReturnFields.Add("c1", "出库(调拨)量");
  1381. ReturnFields.Add("c2", "出货(发货到创客)量");
  1382. ReturnFields.Add("c3", "激活量");
  1383. result.Add("Fields", ReturnFields);
  1384. AddSysLog("0", "StoreHouse", "StatExportExcel");
  1385. return Json(result);
  1386. }
  1387. #endregion
  1388. #region 同步数据
  1389. /// <summary>
  1390. /// 同步数据
  1391. /// </summary>
  1392. /// <returns></returns>
  1393. public string SycnData(int Id = 0)
  1394. {
  1395. if (Id > 0)
  1396. {
  1397. DataTable dt = OtherMySqlConn.dtable("select Id,(select count(Id) from PosMachinesTwo where StoreId=s.Id and BuyUserId=0 and PreUserId=0 and Status>-1) as CurLaveNum from StoreHouse s where Id=" + Id);
  1398. if (dt.Rows.Count > 0)
  1399. {
  1400. int CurLaveNum = int.Parse(function.CheckInt(dt.Rows[0]["CurLaveNum"].ToString()));
  1401. StoreHouse store = db.StoreHouse.FirstOrDefault(m => m.Id == Id);
  1402. if (store != null)
  1403. {
  1404. store.LaveNum = CurLaveNum;
  1405. db.SaveChanges();
  1406. }
  1407. }
  1408. }
  1409. else
  1410. {
  1411. DataTable dt = OtherMySqlConn.dtable("select s.Id,LaveNum,count(p.Id) as CurLaveNum from StoreHouse s left join PosMachinesTwo p on s.Id=p.StoreId and s.BrandId=p.BrandId and p.BuyUserId=0 and p.PreUserId=0 and p.Status>-1 group by s.Id HAVING LaveNum!=count(p.Id)");
  1412. foreach (DataRow dr in dt.Rows)
  1413. {
  1414. int StoreId = int.Parse(function.CheckInt(dr["Id"].ToString()));
  1415. int CurLaveNum = int.Parse(function.CheckInt(dr["CurLaveNum"].ToString()));
  1416. StoreHouse store = db.StoreHouse.FirstOrDefault(m => m.Id == StoreId);
  1417. if (store != null)
  1418. {
  1419. store.LaveNum = CurLaveNum;
  1420. db.SaveChanges();
  1421. }
  1422. }
  1423. }
  1424. AddSysLog(Id, "StoreHouse", "SycnData");
  1425. db.SaveChanges();
  1426. return "success";
  1427. }
  1428. #endregion
  1429. #region 设置缓存
  1430. private void SetRedis(int Id, int UserId)
  1431. {
  1432. if (UserId > 0)
  1433. {
  1434. }
  1435. }
  1436. #endregion
  1437. #region 关联分仓
  1438. /// <summary>
  1439. /// 关联分仓
  1440. /// </summary>
  1441. /// <returns></returns>
  1442. public IActionResult BatchSetting(string right, string StoreIds)
  1443. {
  1444. string[] idlist = StoreIds.Split(new char[] { ',' });
  1445. decimal totalAmount = 0;
  1446. decimal deposit = 0;
  1447. var userIds = "";
  1448. foreach (var item in idlist)
  1449. {
  1450. int StoreId = int.Parse(item);
  1451. var amount = 0;
  1452. var tamount = 0;
  1453. var storeInfo = db.StoreHouse.FirstOrDefault(m => m.Id == StoreId);
  1454. var posCount = db.PosMachinesTwo.Count(m => m.StoreId == StoreId && m.UserId == 0 && m.BuyUserId == 0 && m.OpId == 0);
  1455. var BrandId = int.Parse(storeInfo.BrandId);
  1456. var brandInfo = db.KqProducts.FirstOrDefault(m => m.Id == BrandId);
  1457. if (brandInfo.Name.Contains("电签"))
  1458. {
  1459. amount = 100;
  1460. }
  1461. if (brandInfo.Name.Contains("大POS"))
  1462. {
  1463. amount = 150;
  1464. }
  1465. if (!userIds.Contains(storeInfo.UserId + ","))
  1466. {
  1467. userIds += storeInfo.UserId + ",";
  1468. deposit += storeInfo.Deposit;
  1469. }
  1470. tamount = amount * posCount;//扣减运营中心该品牌机具额度
  1471. totalAmount += tamount;//关联分仓打标记运营中心所需额度
  1472. }
  1473. ViewBag.RightInfo = RightInfo;
  1474. ViewBag.right = right;
  1475. // ViewBag.totalAmount = "关联分仓机具需要额度:" + totalAmount + "\n" + "关联分仓获得押金:" + deposit;
  1476. ViewBag.totalAmount = "关联分仓机具需要额度:" + totalAmount;
  1477. ViewBag.deposit = "关联分仓获得押金:" + deposit;
  1478. return View();
  1479. }
  1480. #endregion
  1481. #region 关联分仓
  1482. /// <summary>
  1483. /// 关联分仓
  1484. /// </summary>
  1485. /// <returns></returns>
  1486. [HttpPost]
  1487. public string BatchSetting(string Id, string MakerCode, string IsOk = "1")
  1488. {
  1489. string[] idlist = Id.Split(new char[] { ',' });
  1490. Dictionary<string, object> Fields = new Dictionary<string, object>();
  1491. AddSysLog(Id, "StoreHouse", "StoreHouseBatchSetting");
  1492. var userForMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode) ?? new UserForMakerCode();
  1493. if (userForMakerCode.UserId > 0)
  1494. {
  1495. var sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.UserId == userForMakerCode.UserId) ?? new OpModels.SysAdmin();
  1496. Fields.Add("OpId", sysAdmin.UserId);
  1497. if (sysAdmin.Id > 0)
  1498. {
  1499. var amount = 0;
  1500. var tamount = 0;
  1501. decimal deposit = 0;
  1502. var pCount = 0;
  1503. var userIds = "";
  1504. string error = "";
  1505. List<int> StoreIds = new List<int>();
  1506. foreach (var items in idlist)
  1507. {
  1508. StoreIds.Add(int.Parse(items));
  1509. }
  1510. List<StoreHouse> StoreHouses = db.StoreHouse.Where(m => StoreIds.Contains(m.Id)).ToList();
  1511. List<PosMachinesTwo> PosList = db.PosMachinesTwo.Where(m => StoreIds.Contains(m.StoreId) && m.UserId == 0 && m.BuyUserId == 0).ToList();
  1512. List<KqProducts> ProductList = db.KqProducts.ToList();
  1513. foreach (var items in idlist)
  1514. {
  1515. int StoreId = int.Parse(items);
  1516. var storeInfo = StoreHouses.FirstOrDefault(m => m.Id == StoreId && m.StoreKind != 2);
  1517. if (storeInfo.OpId > 0)
  1518. {
  1519. error += "以下操作失败" + storeInfo.StoreNo + ',' + "请先解除该分仓的关联" + '\n';
  1520. }
  1521. else
  1522. {
  1523. var pos = PosList.Where(m => m.StoreId == StoreId && m.UserId == 0 && m.BuyUserId == 0).ToList();
  1524. var posCount = pos.Count();
  1525. var brandInfo = ProductList.FirstOrDefault(m => m.Id == int.Parse(storeInfo.BrandId));
  1526. if (brandInfo.Name.Contains("电签"))
  1527. {
  1528. amount = 100;
  1529. }
  1530. if (brandInfo.Name.Contains("大POS"))
  1531. {
  1532. amount = 150;
  1533. }
  1534. if (!userIds.Contains(storeInfo.UserId + ","))
  1535. {
  1536. userIds += storeInfo.UserId + ",";
  1537. deposit += storeInfo.Deposit;//增加分仓押金
  1538. }
  1539. tamount += amount * posCount;//扣减运营中心该品牌机具额度
  1540. pCount += posCount;//添加总机具数
  1541. }
  1542. }
  1543. if (!string.IsNullOrEmpty(error))
  1544. {
  1545. return "Warning|" + error;
  1546. }
  1547. var userAmount = opdb.UserAccount.FirstOrDefault(m => m.Sort == sysAdmin.Id) ?? new OpModels.UserAccount();
  1548. decimal TotalAmount = userAmount.ValidAmount + userAmount.TotalAmt + userAmount.ValidForGetAmount;//旧的总金额
  1549. userAmount.ValidAmount += deposit;
  1550. opdb.SaveChanges();
  1551. decimal toAmount = userAmount.ValidAmount + userAmount.TotalAmt + userAmount.ValidForGetAmount;//新的总金额
  1552. if (toAmount >= tamount)
  1553. {
  1554. foreach (var item in idlist)
  1555. {
  1556. int StoreId = int.Parse(item);
  1557. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("StoreHouse", Fields, StoreId);
  1558. var storeInfo = StoreHouses.FirstOrDefault(m => m.Id == StoreId && m.StoreKind != 2);
  1559. if (storeInfo.OpId == 0)
  1560. {
  1561. var pos = PosList.Where(m => m.StoreId == StoreId && m.UserId == 0 && m.BuyUserId == 0).ToList();
  1562. var posCount = pos.Count();
  1563. var BrandId = int.Parse(storeInfo.BrandId);
  1564. var brandInfo = ProductList.FirstOrDefault(m => m.Id == BrandId);
  1565. if (brandInfo.Name.Contains("电签"))
  1566. {
  1567. amount = 100;
  1568. }
  1569. if (brandInfo.Name.Contains("大POS"))
  1570. {
  1571. amount = 150;
  1572. }
  1573. if (IsOk == "1")
  1574. {
  1575. foreach (var items in pos)
  1576. {
  1577. var posInfo = pos.FirstOrDefault(m => m.Id == items.Id) ?? new PosMachinesTwo();
  1578. posInfo.OpId = sysAdmin.UserId;
  1579. if (userAmount.ValidAmount - amount >= 0)
  1580. {
  1581. userAmount.ValidAmount -= amount;
  1582. posInfo.OpReserve3 += amount; //关联分仓额度
  1583. posInfo.OpReserve1 = 0; //未使用额度
  1584. posInfo.OpReserve2 = 0; //可提现额度
  1585. opdb.SaveChanges();
  1586. }
  1587. else
  1588. {
  1589. if (userAmount.TotalAmt - amount >= 0)
  1590. {
  1591. userAmount.TotalAmt -= amount - userAmount.ValidAmount;
  1592. posInfo.OpReserve3 = userAmount.ValidAmount;
  1593. posInfo.OpReserve1 = amount - userAmount.ValidAmount;
  1594. posInfo.OpReserve2 = 0;
  1595. opdb.SaveChanges();
  1596. }
  1597. else
  1598. {
  1599. if (userAmount.ValidForGetAmount - amount >= 0)
  1600. {
  1601. userAmount.ValidForGetAmount -= amount - userAmount.TotalAmt;
  1602. posInfo.OpReserve3 = 0;
  1603. posInfo.OpReserve1 = userAmount.TotalAmt;
  1604. posInfo.OpReserve2 = amount - userAmount.TotalAmt;
  1605. opdb.SaveChanges();
  1606. }
  1607. }
  1608. }
  1609. db.SaveChanges();
  1610. }
  1611. sysAdmin.TotalMachineCount += posCount;//添加总机具数
  1612. opdb.SaveChanges();
  1613. }
  1614. storeInfo.OpId = sysAdmin.UserId;
  1615. db.SaveChanges();
  1616. var query = opdb.StoreForOperate.FirstOrDefault(m => m.OpId == sysAdmin.UserId && m.StoreId == StoreId && m.Sort == 0 && m.QueryCount == storeInfo.UserId && m.Status == 0);
  1617. if (query == null)
  1618. {
  1619. var user = db.Users.FirstOrDefault(m => m.Id == storeInfo.UserId) ?? new Users();
  1620. query = opdb.StoreForOperate.Add(new OpModels.StoreForOperate()
  1621. {
  1622. CreateDate = DateTime.Now, //创建时间
  1623. CreateMan = SysUserName + "_" + SysRealName,
  1624. QueryCount = storeInfo.UserId,//分仓所属人Id
  1625. SeoTitle = user.MakerCode,
  1626. SeoKeyword = storeInfo.StoreNo,
  1627. SeoDescription = storeInfo.StoreName,
  1628. OpId = sysAdmin.UserId,
  1629. StoreId = StoreId,
  1630. }).Entity;
  1631. opdb.SaveChanges();
  1632. }
  1633. //添加分仓创建时间
  1634. var users = db.Users.FirstOrDefault(m => m.Id == storeInfo.UserId) ?? new Users();
  1635. if (users.Id > 0)
  1636. {
  1637. DataTable dt = OtherMySqlConn.dtable("SELECT CreateDate FROM StoreHouse WHERE UserId=" + users.Id + " AND `Status`>0 ORDER BY CreateDate LIMIT 1");
  1638. if (dt.Rows.Count > 0)
  1639. {
  1640. users.CreateStoreDate = DateTime.Parse(dt.Rows[0][0].ToString());
  1641. db.SaveChanges();
  1642. }
  1643. }
  1644. }
  1645. }
  1646. if (IsOk == "1")
  1647. {
  1648. if (deposit > tamount)
  1649. {
  1650. var amoutRecord = opdb.AmountRecord.Add(new OpModels.AmountRecord
  1651. {
  1652. CreateDate = DateTime.Now,
  1653. UserId = sysAdmin.UserId,
  1654. SeoDescription = "关联分仓",
  1655. OperateType = 1,
  1656. UseAmount = deposit - tamount,
  1657. BeforeAmount = TotalAmount,
  1658. AfterAmount = TotalAmount + deposit - tamount,
  1659. }).Entity;
  1660. }
  1661. if (deposit < tamount)
  1662. {
  1663. var amoutRecord = opdb.AmountRecord.Add(new OpModels.AmountRecord
  1664. {
  1665. CreateDate = DateTime.Now,
  1666. UserId = sysAdmin.UserId,
  1667. SeoDescription = "关联分仓",
  1668. OperateType = 2,
  1669. UseAmount = tamount - deposit,
  1670. BeforeAmount = TotalAmount,
  1671. AfterAmount = TotalAmount + deposit - tamount,
  1672. }).Entity;
  1673. }
  1674. opdb.SaveChanges();
  1675. }
  1676. sysAdmin.StoreCount += idlist.Count();//添加关联分仓数
  1677. opdb.SaveChanges();
  1678. }
  1679. else
  1680. {
  1681. userAmount.ValidAmount -= deposit;
  1682. opdb.SaveChanges();
  1683. return "运营中心额度不足";
  1684. }
  1685. }
  1686. else
  1687. {
  1688. return "该创客未创建运营中心";
  1689. }
  1690. }
  1691. return "success";
  1692. }
  1693. //获取运营中心额度
  1694. public string GetReserve(string MakerCode)
  1695. {
  1696. UserForMakerCode userFor = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode) ?? new UserForMakerCode();
  1697. OpModels.UserAccount account = opdb.UserAccount.FirstOrDefault(m => m.Id == userFor.UserId) ?? new OpModels.UserAccount();
  1698. decimal TotalAmount = account.ValidAmount + account.TotalAmt + account.ValidForGetAmount;
  1699. return TotalAmount.ToString("f2");
  1700. }
  1701. #endregion
  1702. #region 取消关联
  1703. /// <summary>
  1704. /// 取消关联
  1705. /// </summary>
  1706. /// <returns></returns>
  1707. public IActionResult BatchCancle(string right, string StoreIds)
  1708. {
  1709. string[] idlist = StoreIds.Split(new char[] { ',' });
  1710. decimal totalAmount = 0;
  1711. decimal deposit = 0;
  1712. var userIds = "";
  1713. foreach (var item in idlist)
  1714. {
  1715. int StoreId = int.Parse(item);
  1716. var amount = 0;
  1717. var tamount = 0;
  1718. var storeInfo = db.StoreHouse.FirstOrDefault(m => m.Id == StoreId);
  1719. var posCount = db.PosMachinesTwo.Count(m => m.StoreId == StoreId && m.UserId == 0 && m.BuyUserId == 0 && m.OpId == storeInfo.OpId);
  1720. var BrandId = int.Parse(storeInfo.BrandId);
  1721. var brandInfo = db.KqProducts.FirstOrDefault(m => m.Id == BrandId);
  1722. if (brandInfo.Name.Contains("电签"))
  1723. {
  1724. amount = 100;
  1725. }
  1726. if (brandInfo.Name.Contains("大POS"))
  1727. {
  1728. amount = 150;
  1729. }
  1730. if (!userIds.Contains(storeInfo.UserId + ","))
  1731. {
  1732. userIds += storeInfo.UserId + ",";
  1733. deposit += storeInfo.Deposit;
  1734. }
  1735. tamount = amount * posCount;//增加运营中心该品牌机具额度
  1736. totalAmount += tamount;//取消关联分仓打标记运营中心所需额度
  1737. }
  1738. ViewBag.RightInfo = RightInfo;
  1739. ViewBag.right = right;
  1740. ViewBag.totalAmount = "取消关联机具获得额度:" + totalAmount;
  1741. ViewBag.deposit = "取消关联分仓扣除押金:" + deposit;
  1742. return View();
  1743. }
  1744. #endregion
  1745. #region 取消关联
  1746. /// <summary>
  1747. /// 取消关联
  1748. /// </summary>
  1749. /// <returns></returns>
  1750. [HttpPost]
  1751. public string BatchCancle(string Id, string MakerCode, string IsOk = "1")
  1752. {
  1753. string[] idlist = Id.Split(new char[] { ',' });
  1754. Dictionary<string, object> Fields = new Dictionary<string, object>();
  1755. AddSysLog(Id, "StoreHouse", "StoreHouseBatchCancle");
  1756. var userForMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode) ?? new UserForMakerCode();
  1757. if (userForMakerCode.UserId > 0)
  1758. {
  1759. var sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.UserId == userForMakerCode.UserId);
  1760. var userAmount = opdb.UserAccount.FirstOrDefault(m => m.Sort == sysAdmin.Id) ?? new OpModels.UserAccount();
  1761. decimal TotalAmount = userAmount.ValidAmount + userAmount.TotalAmt + userAmount.ValidForGetAmount;//旧的总金额
  1762. Fields.Add("OpId", 0);
  1763. if (sysAdmin.Id > 0)
  1764. {
  1765. var amount = 0;
  1766. var tamount = 0;
  1767. decimal deposit = 0;
  1768. decimal ValidAmount = 0;
  1769. decimal TotalAmt = 0;
  1770. decimal ValidForGetAmount = 0;
  1771. var pCount = 0;
  1772. var userIds = "";
  1773. string error = "";
  1774. List<int> StoreIds = new List<int>();
  1775. foreach (var items in idlist)
  1776. {
  1777. StoreIds.Add(int.Parse(items));
  1778. }
  1779. List<StoreHouse> StoreHouses = db.StoreHouse.Where(m => StoreIds.Contains(m.Id)).ToList();
  1780. List<PosMachinesTwo> PosList = db.PosMachinesTwo.Where(m => StoreIds.Contains(m.StoreId) && m.UserId == 0 && m.BuyUserId == 0 && m.OpId > 0).ToList();
  1781. List<KqProducts> ProductList = db.KqProducts.ToList();
  1782. foreach (var item in idlist)
  1783. {
  1784. int StoreId = int.Parse(item);
  1785. var store = StoreHouses.FirstOrDefault(m => m.Id == StoreId && m.StoreKind != 2 && m.OpId == sysAdmin.UserId);
  1786. if (store == null)
  1787. {
  1788. error += "分仓" + store.StoreNo + "未在创客" + MakerCode + "的关联分仓中";
  1789. }
  1790. else
  1791. {
  1792. var pos = PosList.Where(m => m.StoreId == StoreId && m.UserId == 0 && m.BuyUserId == 0 && m.OpId == sysAdmin.UserId).ToList();
  1793. var posCount = pos.Count();
  1794. var BrandId = int.Parse(store.BrandId);
  1795. var brandInfo = ProductList.FirstOrDefault(m => m.Id == BrandId);
  1796. if (brandInfo.Name.Contains("电签"))
  1797. {
  1798. amount = 100;
  1799. }
  1800. if (brandInfo.Name.Contains("大POS"))
  1801. {
  1802. amount = 150;
  1803. }
  1804. if (!userIds.Contains(store.UserId + ","))
  1805. {
  1806. userIds += store.UserId + ",";
  1807. deposit += store.Deposit;//增加分仓押金
  1808. }
  1809. foreach (var items in pos)
  1810. {
  1811. var posInfo = pos.FirstOrDefault(m => m.Id == items.Id) ?? new PosMachinesTwo();
  1812. ValidAmount += posInfo.OpReserve3;
  1813. TotalAmt += posInfo.OpReserve1;
  1814. ValidForGetAmount += posInfo.OpReserve2;
  1815. }
  1816. tamount += amount * posCount;//扣减运营中心该品牌机具额度
  1817. pCount += posCount;//添加总机具数
  1818. }
  1819. }
  1820. if (!string.IsNullOrEmpty(error))
  1821. {
  1822. return "Warning|" + error;
  1823. }
  1824. decimal toAmount = userAmount.ValidAmount + userAmount.TotalAmt + userAmount.ValidForGetAmount + ValidAmount + TotalAmt + ValidForGetAmount;//新的总金额
  1825. if (toAmount >= deposit)
  1826. {
  1827. foreach (var item in idlist)
  1828. {
  1829. int StoreId = int.Parse(item);
  1830. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("StoreHouse", Fields, StoreId);
  1831. db.SaveChanges();
  1832. var store = StoreHouses.FirstOrDefault(m => m.Id == StoreId && m.StoreKind != 2);
  1833. var pos = PosList.Where(m => m.StoreId == StoreId && m.UserId == 0 && m.BuyUserId == 0 && m.OpId == sysAdmin.UserId).ToList();
  1834. foreach (var items in pos)
  1835. {
  1836. var posInfo = pos.FirstOrDefault(m => m.Id == items.Id) ?? new PosMachinesTwo();
  1837. posInfo.OpReserve3 = 0;
  1838. posInfo.OpReserve1 = 0;
  1839. posInfo.OpReserve2 = 0;
  1840. posInfo.OpId = 0;
  1841. db.SaveChanges();
  1842. }
  1843. var query = opdb.StoreForOperate.FirstOrDefault(m => m.Status == 0 && m.OpId == sysAdmin.UserId && m.StoreId == StoreId && m.Sort == 0 && m.QueryCount == store.UserId);
  1844. if (query != null)
  1845. {
  1846. query.UpdateDate = DateTime.Now;
  1847. query.UpdateMan = SysUserName + "_" + SysRealName;
  1848. query.Status = -1;
  1849. opdb.SaveChanges();
  1850. }
  1851. }
  1852. userAmount.ValidAmount -= deposit;//扣减关联分仓押金
  1853. userAmount.ValidAmount += ValidAmount;
  1854. userAmount.TotalAmt += TotalAmt;
  1855. userAmount.ValidForGetAmount += ValidForGetAmount;
  1856. sysAdmin.StoreCount -= idlist.Count();//减少关联分仓数
  1857. sysAdmin.TotalMachineCount -= pCount;//减少关联分仓机具数
  1858. if (deposit > tamount)
  1859. {
  1860. var amoutRecord = opdb.AmountRecord.Add(new OpModels.AmountRecord
  1861. {
  1862. CreateDate = DateTime.Now,
  1863. UserId = sysAdmin.UserId,
  1864. SeoDescription = "取消关联分仓",
  1865. OperateType = 2,
  1866. UseAmount = deposit - tamount,
  1867. BeforeAmount = TotalAmount,
  1868. AfterAmount = TotalAmount - deposit + tamount,
  1869. }).Entity;
  1870. }
  1871. if (deposit < tamount)
  1872. {
  1873. var amoutRecord = opdb.AmountRecord.Add(new OpModels.AmountRecord
  1874. {
  1875. CreateDate = DateTime.Now,
  1876. UserId = sysAdmin.UserId,
  1877. SeoDescription = "取消关联分仓",
  1878. OperateType = 1,
  1879. UseAmount = tamount - deposit,
  1880. BeforeAmount = TotalAmount,
  1881. AfterAmount = TotalAmount - deposit + tamount,
  1882. }).Entity;
  1883. }
  1884. opdb.SaveChanges();
  1885. }
  1886. else
  1887. {
  1888. return "运营中心额度不足";
  1889. }
  1890. }
  1891. }
  1892. else
  1893. {
  1894. return "该创客未创建运营中心";
  1895. }
  1896. return "success";
  1897. }
  1898. #endregion
  1899. }
  1900. }