StoreHouseController.cs 101 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042
  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. PublicFunction.ClearPosHistory(db, posInfo.PosSn); //清除机具历史记录
  940. db.SaveChanges();
  941. }
  942. else
  943. {
  944. var changeNo = "JJBH" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
  945. StoreStockChange stockchange = db.StoreStockChange.Add(new StoreStockChange()
  946. {
  947. CreateDate = DateTime.Now,
  948. StoreId = fromStore.Id, //出货仓库
  949. ToStoreId = toStore.Id, //发货仓库
  950. BrandId = Convert.ToInt32(BrandId), //产品类型
  951. ProductName = RelationClass.GetKqProductBrandInfo(Convert.ToInt32(BrandId)), //产品名称
  952. ChangeNo = changeNo, //变更记录单号
  953. BizBatchNo = No, //业务批次号
  954. TransType = 4, //交易类型
  955. SnNo = PosSn, //SN编号
  956. StockOpDirect = 1, //库存操作方向
  957. SnStatus = 1, //SN状态
  958. DeviceVendor = posInfo.DeviceName, //设备厂商
  959. DeviceModel = posInfo.DeviceKind, //设备型号
  960. DeviceType = posInfo.DeviceType, //设备类型
  961. SourceStoreId = posInfo.SourceStoreId, //源仓库编号
  962. BrandType = posInfo.DeviceType, //品牌类型
  963. }).Entity;
  964. db.SaveChanges();
  965. db.StoreChangeHistory.Add(new StoreChangeHistory()
  966. {
  967. CreateDate = DateTime.Now,
  968. CreateMan = SysUserName,
  969. UserId = user.Id, //创客
  970. FromUserId = user.Id,//来源创客
  971. ToUserId = toStore.UserId,//接收创客
  972. StoreId = fromStore.Id, //出货仓库
  973. ToStoreId = toStore.Id, //发货仓库
  974. BrandId = Convert.ToInt32(BrandId), //产品类型
  975. ChangeRecordNo = changeNo, //变更记录单号
  976. SeoTitle = "机具驳回仓库",
  977. BizBatchNo = No, //业务批次号
  978. SnNo = PosSn, //SN编号
  979. TransType = 4,//驳回
  980. });
  981. db.SaveChanges();
  982. StoreBalance balance = db.StoreBalance.Add(new StoreBalance()
  983. {
  984. CreateDate = DateTime.Now,
  985. StoreId = fromStore.Id, //仓库
  986. BrandId = Convert.ToInt32(BrandId), //产品类型
  987. OpStoreNum = 1, //操作库存数
  988. OpSymbol = "-", //操作符
  989. BeforeTotalNum = fromStore.TotalNum, //操作前总库存数
  990. AfterTotalNum = fromStore.TotalNum - 1, //操作后总库存数
  991. BeforeLaveNum = fromStore.LaveNum, //操作前剩余库存数
  992. AfterLaveNum = fromStore.LaveNum - 1, //操作后剩余库存数
  993. BeforeOutNum = fromStore.OutNum, //操作前出库数
  994. AfterOutNum = fromStore.OutNum - 1, //操作后出库数
  995. }).Entity;
  996. db.SaveChanges();
  997. posInfo.StoreId = toStore.Id;
  998. posInfo.BuyUserId = 0;
  999. posInfo.UserId = 0;
  1000. posInfo.RecycEndDate = null;
  1001. posInfo.PosSnType = 0;
  1002. posInfo.BindMerchantId = 0;
  1003. posInfo.ActivityList = null;
  1004. posInfo.ScanQrTrade = 0;
  1005. posInfo.DebitCardTrade = 0;
  1006. posInfo.PrizeParams = null;
  1007. posInfo.IsVip = 0;
  1008. posInfo.CreditTrade = 0;
  1009. posInfo.UserNav = null;
  1010. posInfo.TransferTime = null;
  1011. posInfo.IsPurchase = 0;
  1012. posInfo.BindingTime = null;
  1013. posInfo.BindingState = 0;
  1014. posInfo.ActivationTime = null;
  1015. posInfo.ActivationState = 0;
  1016. posInfo.LeaderUserId = 0;
  1017. posInfo.PreUserId = 0;
  1018. posInfo.IsFirst = 0;
  1019. fuserMachineData.TotalMachineCount -= 1;
  1020. fuserMachineData.UnBindCount -= 1;
  1021. toStore.LaveNum += 1;
  1022. toStore.TotalNum += 1;
  1023. PublicFunction.ClearPosHistory(db, posInfo.PosSn); //清除机具历史记录
  1024. db.SaveChanges();
  1025. }
  1026. db.SaveChanges();
  1027. }
  1028. }
  1029. }
  1030. if (!string.IsNullOrEmpty(error))
  1031. {
  1032. return "Warning|" + error;
  1033. }
  1034. }
  1035. AddSysLog("0", "MachinesRejectStore", "Import");
  1036. return "success";
  1037. }
  1038. #endregion
  1039. #region 导出Excel
  1040. /// <summary>
  1041. /// 导出Excel
  1042. /// </summary>
  1043. /// <returns></returns>
  1044. public JsonResult ExportExcel(StoreHouse data, string UserIdMakerCode, string UserIdRealName, string ManageUserIdRealName, string ManageUserIdMobile, string ManageUserIdMakerCode, string StoreStatusSelect)
  1045. {
  1046. Dictionary<string, string> Fields = new Dictionary<string, string>();
  1047. Fields.Add("StoreNo", "1"); //仓库编号
  1048. Fields.Add("CreateDate", "3"); //时间
  1049. Fields.Add("StoreName", "1"); //仓库名称
  1050. Fields.Add("ManagerEmail", "1"); //管理者邮箱
  1051. string condition = " and Status>-1";
  1052. //仓库归属人创客编号
  1053. if (!string.IsNullOrEmpty(UserIdMakerCode))
  1054. {
  1055. condition += " and UserId in (select UserId from UserForMakerCode where MakerCode='" + UserIdMakerCode + "')";
  1056. }
  1057. //仓库归属人真实姓名
  1058. if (!string.IsNullOrEmpty(UserIdRealName))
  1059. {
  1060. condition += " and UserId in (select UserId from UserForRealName where RealName='" + UserIdRealName + "')";
  1061. }
  1062. //仓库管理员真实姓名
  1063. if (!string.IsNullOrEmpty(ManageUserIdRealName))
  1064. {
  1065. condition += " and ManageUserId in (select ManageUserId from UserForRealName where RealName='" + ManageUserIdRealName + "')";
  1066. }
  1067. //仓库管理员手机号
  1068. if (!string.IsNullOrEmpty(ManageUserIdMobile))
  1069. {
  1070. condition += " and ManageUserId in (select ManageUserId from UserForMobile where Mobile='" + ManageUserIdMobile + "')";
  1071. }
  1072. //仓库管理员创客编号
  1073. if (!string.IsNullOrEmpty(ManageUserIdMakerCode))
  1074. {
  1075. condition += " and ManageUserId in (select ManageUserId from UserForMakerCode where MakerCode='" + ManageUserIdMakerCode + "')";
  1076. }
  1077. //仓库状态
  1078. if (!string.IsNullOrEmpty(StoreStatusSelect))
  1079. {
  1080. condition += " and StoreStatus=" + StoreStatusSelect;
  1081. }
  1082. 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);
  1083. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  1084. foreach (Dictionary<string, object> dic in diclist)
  1085. {
  1086. //仓库归属人
  1087. int UserId = int.Parse(function.CheckInt(dic["UserId"].ToString()));
  1088. Users userid_Users = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  1089. dic["UserIdMakerCode"] = userid_Users.MakerCode;
  1090. dic["UserIdRealName"] = userid_Users.RealName;
  1091. //产品类型
  1092. dic["BrandId"] = RelationClass.GetKqProductBrandList(dic["BrandId"].ToString());
  1093. //仓库管理员
  1094. int ManageUserId = int.Parse(function.CheckInt(dic["ManageUserId"].ToString()));
  1095. Users manageuserid_Users = db.Users.FirstOrDefault(m => m.Id == ManageUserId) ?? new Users();
  1096. dic["ManageUserIdRealName"] = manageuserid_Users.RealName;
  1097. dic["ManageUserIdMobile"] = manageuserid_Users.Mobile;
  1098. dic["ManageUserIdMakerCode"] = manageuserid_Users.MakerCode;
  1099. //仓库类型
  1100. int StoreType = int.Parse(dic["StoreType"].ToString());
  1101. if (StoreType == 0) dic["StoreType"] = "实体仓";
  1102. if (StoreType == 1) dic["StoreType"] = "虚拟仓";
  1103. //仓库状态
  1104. int StoreStatus = int.Parse(dic["StoreStatus"].ToString());
  1105. if (StoreStatus == 1) dic["StoreStatus"] = "启用";
  1106. if (StoreStatus == 0) dic["StoreStatus"] = "禁用";
  1107. //仓库归属类型
  1108. int StoreKind = int.Parse(dic["StoreKind"].ToString());
  1109. if (StoreKind == 0) dic["StoreKind"] = "分仓";
  1110. if (StoreKind == 1) dic["StoreKind"] = "总仓";
  1111. }
  1112. Dictionary<string, object> result = new Dictionary<string, object>();
  1113. result.Add("Status", "1");
  1114. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1115. result.Add("Obj", diclist);
  1116. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  1117. ReturnFields.Add("StoreNo", "仓库编号");
  1118. ReturnFields.Add("StoreName", "仓库名称");
  1119. ReturnFields.Add("UserIdMakerCode", "仓库归属人创客编号");
  1120. ReturnFields.Add("UserIdRealName", "仓库归属人真实姓名");
  1121. ReturnFields.Add("BrandId", "产品类型");
  1122. ReturnFields.Add("Address", "仓库地址");
  1123. ReturnFields.Add("ManageUserIdRealName", "仓库管理员真实姓名");
  1124. ReturnFields.Add("ManageUserIdMobile", "仓库管理员手机号");
  1125. ReturnFields.Add("ManageUserIdMakerCode", "仓库管理员创客编号");
  1126. ReturnFields.Add("ManagerEmail", "管理者邮箱");
  1127. ReturnFields.Add("StoreType", "仓库类型");
  1128. ReturnFields.Add("TotalNum", "总库存数");
  1129. ReturnFields.Add("LaveNum", "剩余库存数");
  1130. ReturnFields.Add("OutNum", "出库数");
  1131. ReturnFields.Add("LimitTopUserId", "限制创客特殊仓库");
  1132. ReturnFields.Add("StoreStatus", "仓库状态");
  1133. ReturnFields.Add("StoreKind", "仓库归属类型");
  1134. result.Add("Fields", ReturnFields);
  1135. AddSysLog("0", "StoreHouse", "ExportExcel");
  1136. return Json(result);
  1137. }
  1138. #endregion
  1139. #region 仓库列表
  1140. /// <summary>
  1141. /// 根据条件查询仓库列表
  1142. /// </summary>
  1143. /// <returns></returns>
  1144. public IActionResult Stat(StoreHouse data, string right)
  1145. {
  1146. ViewBag.RightInfo = RightInfo;
  1147. ViewBag.right = right;
  1148. return View();
  1149. }
  1150. #endregion
  1151. #region 根据条件查询仓库列表
  1152. /// <summary>
  1153. /// 仓库列表
  1154. /// </summary>
  1155. /// <returns></returns>
  1156. public JsonResult StatDo(string CreateDateData, int page = 1, int limit = 30)
  1157. {
  1158. OtherMySqlConn.connstr = ConfigurationManager.AppSettings["StatSqlConnStr"].ToString();
  1159. string sCreateDate = DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00";
  1160. string eCreateDate = DateTime.Now.ToString("yyyy-MM-dd") + " 23:59:59";
  1161. if (!string.IsNullOrEmpty(CreateDateData))
  1162. {
  1163. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  1164. sCreateDate = datelist[0] + " 00:00:00";
  1165. eCreateDate = datelist[1] + " 23:59:59";
  1166. }
  1167. else
  1168. {
  1169. Dictionary<string, object> nodata = new Dictionary<string, object>();
  1170. nodata.Add("code", 0);
  1171. nodata.Add("msg", "");
  1172. nodata.Add("count", 0);
  1173. nodata.Add("data", new List<Dictionary<string, object>>());
  1174. return Json(nodata);
  1175. }
  1176. string minId = "0";
  1177. string maxId = "0";
  1178. string minPosId = "0";
  1179. string maxPosId = "0";
  1180. DataTable startDt = OtherMySqlConn.dtable("select min(Id) from StoreStockChange where CreateDate>='" + sCreateDate + "'");
  1181. if (startDt.Rows.Count > 0)
  1182. {
  1183. minId = function.CheckInt(startDt.Rows[0][0].ToString());
  1184. if (minId == "0")
  1185. {
  1186. startDt = OtherMySqlConn.dtable("select max(Id) from StoreStockChange");
  1187. if (startDt.Rows.Count > 0)
  1188. {
  1189. minId = function.CheckInt(startDt.Rows[0][0].ToString());
  1190. }
  1191. }
  1192. }
  1193. DataTable endDt = OtherMySqlConn.dtable("select max(Id) from StoreStockChange where CreateDate>='" + sCreateDate + "'");
  1194. if (endDt.Rows.Count > 0)
  1195. {
  1196. maxId = function.CheckInt(endDt.Rows[0][0].ToString());
  1197. if (minId == "0")
  1198. {
  1199. endDt = OtherMySqlConn.dtable("select max(Id) from StoreStockChange");
  1200. if (endDt.Rows.Count > 0)
  1201. {
  1202. maxId = function.CheckInt(endDt.Rows[0][0].ToString());
  1203. }
  1204. }
  1205. }
  1206. DataTable startPosDt = OtherMySqlConn.dtable("select min(Id) from PosMachinesTwo where ActivationTime>='" + sCreateDate + "'");
  1207. if (startPosDt.Rows.Count > 0)
  1208. {
  1209. minPosId = function.CheckInt(startPosDt.Rows[0][0].ToString());
  1210. if (minPosId == "0")
  1211. {
  1212. startPosDt = OtherMySqlConn.dtable("select max(Id) from PosMachinesTwo");
  1213. if (startPosDt.Rows.Count > 0)
  1214. {
  1215. minPosId = function.CheckInt(startPosDt.Rows[0][0].ToString());
  1216. }
  1217. }
  1218. }
  1219. DataTable endPosDt = OtherMySqlConn.dtable("select max(Id) from PosMachinesTwo where ActivationTime>='" + sCreateDate + "'");
  1220. if (endPosDt.Rows.Count > 0)
  1221. {
  1222. maxPosId = function.CheckInt(endPosDt.Rows[0][0].ToString());
  1223. if (maxPosId == "0")
  1224. {
  1225. endPosDt = OtherMySqlConn.dtable("select max(Id) from PosMachinesTwo");
  1226. if (endPosDt.Rows.Count > 0)
  1227. {
  1228. maxPosId = function.CheckInt(endPosDt.Rows[0][0].ToString());
  1229. }
  1230. }
  1231. }
  1232. 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");
  1233. int recordcount = list.Rows.Count;
  1234. List<Dictionary<string, object>> diclist = new List<Dictionary<string, object>>();
  1235. foreach (DataRow sub in list.Rows)
  1236. {
  1237. Dictionary<string, object> row = new Dictionary<string, object>();
  1238. row.Add("StoreName", sub["StoreName"].ToString());
  1239. row.Add("StoreNo", sub["StoreNo"].ToString());
  1240. row.Add("Mobile", sub["Mobile"].ToString());
  1241. row.Add("RealName", sub["RealName"].ToString());
  1242. row.Add("Name", sub["Name"].ToString());
  1243. row.Add("LaveNum", sub["LaveNum"].ToString());
  1244. row.Add("c1", sub["c1"].ToString());
  1245. row.Add("c2", sub["c2"].ToString());
  1246. row.Add("c3", sub["c3"].ToString());
  1247. diclist.Add(row);
  1248. }
  1249. Dictionary<string, object> obj = new Dictionary<string, object>();
  1250. obj.Add("code", 0);
  1251. obj.Add("msg", "");
  1252. obj.Add("count", recordcount);
  1253. obj.Add("data", diclist);
  1254. return Json(obj);
  1255. }
  1256. #endregion
  1257. #region 导出Excel
  1258. /// <summary>
  1259. /// 导出Excel
  1260. /// </summary>
  1261. /// <returns></returns>
  1262. public JsonResult StatExportExcel(string CreateDateData)
  1263. {
  1264. OtherMySqlConn.connstr = ConfigurationManager.AppSettings["StatSqlConnStr"].ToString();
  1265. string sCreateDate = DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00";
  1266. string eCreateDate = DateTime.Now.ToString("yyyy-MM-dd") + " 23:59:59";
  1267. if (!string.IsNullOrEmpty(CreateDateData))
  1268. {
  1269. string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  1270. sCreateDate = datelist[0] + " 00:00:00";
  1271. eCreateDate = datelist[1] + " 23:59:59";
  1272. }
  1273. else
  1274. {
  1275. Dictionary<string, object> nodata = new Dictionary<string, object>();
  1276. nodata.Add("Status", "1");
  1277. nodata.Add("Info", "分仓统计数据报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1278. nodata.Add("Obj", new List<Dictionary<string, object>>());
  1279. Dictionary<string, object> NoDataReturnFields = new Dictionary<string, object>();
  1280. NoDataReturnFields.Add("StoreName", "仓库名称");
  1281. NoDataReturnFields.Add("StoreNo", "仓库编号");
  1282. NoDataReturnFields.Add("Mobile", "仓库所属人手机号");
  1283. NoDataReturnFields.Add("RealName", "仓库所属人名称");
  1284. NoDataReturnFields.Add("MakerCode", "仓库所属人编码");
  1285. NoDataReturnFields.Add("ManageMakerCode", "仓库管理员编码");
  1286. NoDataReturnFields.Add("Name", "品牌");
  1287. NoDataReturnFields.Add("LaveNum", "当前库存");
  1288. NoDataReturnFields.Add("c1", "出库(调拨)量");
  1289. NoDataReturnFields.Add("c2", "出货(发货到创客)量");
  1290. NoDataReturnFields.Add("c3", "激活量");
  1291. nodata.Add("Fields", NoDataReturnFields);
  1292. return Json(nodata);
  1293. }
  1294. string minId = "0";
  1295. string maxId = "0";
  1296. string minPosId = "0";
  1297. string maxPosId = "0";
  1298. DataTable startDt = OtherMySqlConn.dtable("select min(Id) from StoreStockChange where CreateDate>='" + sCreateDate + "'");
  1299. if (startDt.Rows.Count > 0)
  1300. {
  1301. minId = function.CheckInt(startDt.Rows[0][0].ToString());
  1302. if (minId == "0")
  1303. {
  1304. startDt = OtherMySqlConn.dtable("select max(Id) from StoreStockChange");
  1305. if (startDt.Rows.Count > 0)
  1306. {
  1307. minId = function.CheckInt(startDt.Rows[0][0].ToString());
  1308. }
  1309. }
  1310. }
  1311. DataTable endDt = OtherMySqlConn.dtable("select max(Id) from StoreStockChange where CreateDate>='" + sCreateDate + "'");
  1312. if (endDt.Rows.Count > 0)
  1313. {
  1314. maxId = function.CheckInt(endDt.Rows[0][0].ToString());
  1315. if (minId == "0")
  1316. {
  1317. endDt = OtherMySqlConn.dtable("select max(Id) from StoreStockChange");
  1318. if (endDt.Rows.Count > 0)
  1319. {
  1320. maxId = function.CheckInt(endDt.Rows[0][0].ToString());
  1321. }
  1322. }
  1323. }
  1324. DataTable startPosDt = OtherMySqlConn.dtable("select min(Id) from PosMachinesTwo where ActivationTime>='" + sCreateDate + "'");
  1325. if (startPosDt.Rows.Count > 0)
  1326. {
  1327. minPosId = function.CheckInt(startPosDt.Rows[0][0].ToString());
  1328. if (minPosId == "0")
  1329. {
  1330. startPosDt = OtherMySqlConn.dtable("select max(Id) from PosMachinesTwo");
  1331. if (startPosDt.Rows.Count > 0)
  1332. {
  1333. minPosId = function.CheckInt(startPosDt.Rows[0][0].ToString());
  1334. }
  1335. }
  1336. }
  1337. DataTable endPosDt = OtherMySqlConn.dtable("select max(Id) from PosMachinesTwo where ActivationTime>='" + sCreateDate + "'");
  1338. if (endPosDt.Rows.Count > 0)
  1339. {
  1340. maxPosId = function.CheckInt(endPosDt.Rows[0][0].ToString());
  1341. if (maxPosId == "0")
  1342. {
  1343. endPosDt = OtherMySqlConn.dtable("select max(Id) from PosMachinesTwo");
  1344. if (endPosDt.Rows.Count > 0)
  1345. {
  1346. maxPosId = function.CheckInt(endPosDt.Rows[0][0].ToString());
  1347. }
  1348. }
  1349. }
  1350. 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");
  1351. int recordcount = list.Rows.Count;
  1352. List<Dictionary<string, object>> diclist = new List<Dictionary<string, object>>();
  1353. foreach (DataRow sub in list.Rows)
  1354. {
  1355. Dictionary<string, object> row = new Dictionary<string, object>();
  1356. row.Add("StoreName", sub["StoreName"].ToString());
  1357. row.Add("StoreNo", sub["StoreNo"].ToString());
  1358. row.Add("Mobile", sub["Mobile"].ToString());
  1359. row.Add("RealName", sub["RealName"].ToString());
  1360. row.Add("MakerCode", sub["MakerCode"].ToString());
  1361. row.Add("ManageMakerCode", sub["ManageMakerCode"].ToString());
  1362. row.Add("Name", sub["Name"].ToString());
  1363. row.Add("LaveNum", sub["LaveNum"].ToString());
  1364. row.Add("c1", sub["c1"].ToString());
  1365. row.Add("c2", sub["c2"].ToString());
  1366. row.Add("c3", sub["c3"].ToString());
  1367. diclist.Add(row);
  1368. }
  1369. Dictionary<string, object> result = new Dictionary<string, object>();
  1370. result.Add("Status", "1");
  1371. result.Add("Info", "分仓统计数据报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  1372. result.Add("Obj", diclist);
  1373. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  1374. ReturnFields.Add("StoreName", "仓库名称");
  1375. ReturnFields.Add("StoreNo", "仓库编号");
  1376. ReturnFields.Add("Mobile", "仓库所属人手机号");
  1377. ReturnFields.Add("RealName", "仓库所属人名称");
  1378. ReturnFields.Add("MakerCode", "仓库所属人编码");
  1379. ReturnFields.Add("ManageMakerCode", "仓库管理员编码");
  1380. ReturnFields.Add("Name", "品牌");
  1381. ReturnFields.Add("LaveNum", "当前库存");
  1382. ReturnFields.Add("c1", "出库(调拨)量");
  1383. ReturnFields.Add("c2", "出货(发货到创客)量");
  1384. ReturnFields.Add("c3", "激活量");
  1385. result.Add("Fields", ReturnFields);
  1386. AddSysLog("0", "StoreHouse", "StatExportExcel");
  1387. return Json(result);
  1388. }
  1389. #endregion
  1390. #region 同步数据
  1391. /// <summary>
  1392. /// 同步数据
  1393. /// </summary>
  1394. /// <returns></returns>
  1395. public string SycnData(int Id = 0)
  1396. {
  1397. if (Id > 0)
  1398. {
  1399. 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);
  1400. if (dt.Rows.Count > 0)
  1401. {
  1402. int CurLaveNum = int.Parse(function.CheckInt(dt.Rows[0]["CurLaveNum"].ToString()));
  1403. StoreHouse store = db.StoreHouse.FirstOrDefault(m => m.Id == Id);
  1404. if (store != null)
  1405. {
  1406. store.LaveNum = CurLaveNum;
  1407. db.SaveChanges();
  1408. }
  1409. }
  1410. }
  1411. else
  1412. {
  1413. 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)");
  1414. foreach (DataRow dr in dt.Rows)
  1415. {
  1416. int StoreId = int.Parse(function.CheckInt(dr["Id"].ToString()));
  1417. int CurLaveNum = int.Parse(function.CheckInt(dr["CurLaveNum"].ToString()));
  1418. StoreHouse store = db.StoreHouse.FirstOrDefault(m => m.Id == StoreId);
  1419. if (store != null)
  1420. {
  1421. store.LaveNum = CurLaveNum;
  1422. db.SaveChanges();
  1423. }
  1424. }
  1425. }
  1426. AddSysLog(Id, "StoreHouse", "SycnData");
  1427. db.SaveChanges();
  1428. return "success";
  1429. }
  1430. #endregion
  1431. #region 设置缓存
  1432. private void SetRedis(int Id, int UserId)
  1433. {
  1434. if (UserId > 0)
  1435. {
  1436. }
  1437. }
  1438. #endregion
  1439. #region 关联分仓
  1440. /// <summary>
  1441. /// 关联分仓
  1442. /// </summary>
  1443. /// <returns></returns>
  1444. public IActionResult BatchSetting(string right, string StoreIds)
  1445. {
  1446. string[] idlist = StoreIds.Split(new char[] { ',' });
  1447. decimal totalAmount = 0;
  1448. decimal deposit = 0;
  1449. var userIds = "";
  1450. foreach (var item in idlist)
  1451. {
  1452. int StoreId = int.Parse(item);
  1453. var amount = 0;
  1454. var tamount = 0;
  1455. var storeInfo = db.StoreHouse.FirstOrDefault(m => m.Id == StoreId);
  1456. var posCount = db.PosMachinesTwo.Count(m => m.StoreId == StoreId && m.UserId == 0 && m.BuyUserId == 0 && m.OpId == 0);
  1457. var BrandId = int.Parse(storeInfo.BrandId);
  1458. var brandInfo = db.KqProducts.FirstOrDefault(m => m.Id == BrandId);
  1459. if (brandInfo.Name.Contains("电签"))
  1460. {
  1461. amount = 100;
  1462. }
  1463. if (brandInfo.Name.Contains("大POS"))
  1464. {
  1465. amount = 150;
  1466. }
  1467. if (!userIds.Contains(storeInfo.UserId + ","))
  1468. {
  1469. userIds += storeInfo.UserId + ",";
  1470. deposit += storeInfo.Deposit;
  1471. }
  1472. tamount = amount * posCount;//扣减运营中心该品牌机具额度
  1473. totalAmount += tamount;//关联分仓打标记运营中心所需额度
  1474. }
  1475. ViewBag.RightInfo = RightInfo;
  1476. ViewBag.right = right;
  1477. // ViewBag.totalAmount = "关联分仓机具需要额度:" + totalAmount + "\n" + "关联分仓获得押金:" + deposit;
  1478. ViewBag.totalAmount = "关联分仓机具需要额度:" + totalAmount;
  1479. ViewBag.deposit = "关联分仓获得押金:" + deposit;
  1480. return View();
  1481. }
  1482. #endregion
  1483. #region 关联分仓
  1484. /// <summary>
  1485. /// 关联分仓
  1486. /// </summary>
  1487. /// <returns></returns>
  1488. [HttpPost]
  1489. public string BatchSetting(string Id, string MakerCode, string IsOk = "1")
  1490. {
  1491. string[] idlist = Id.Split(new char[] { ',' });
  1492. Dictionary<string, object> Fields = new Dictionary<string, object>();
  1493. AddSysLog(Id, "StoreHouse", "StoreHouseBatchSetting");
  1494. var userForMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode) ?? new UserForMakerCode();
  1495. if (userForMakerCode.UserId > 0)
  1496. {
  1497. var sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.UserId == userForMakerCode.UserId) ?? new OpModels.SysAdmin();
  1498. Fields.Add("OpId", sysAdmin.UserId);
  1499. if (sysAdmin.Id > 0)
  1500. {
  1501. var amount = 0;
  1502. var tamount = 0;
  1503. decimal deposit = 0;
  1504. var pCount = 0;
  1505. var userIds = "";
  1506. string error = "";
  1507. List<int> StoreIds = new List<int>();
  1508. foreach (var items in idlist)
  1509. {
  1510. StoreIds.Add(int.Parse(items));
  1511. }
  1512. List<StoreHouse> StoreHouses = db.StoreHouse.Where(m => StoreIds.Contains(m.Id)).ToList();
  1513. List<PosMachinesTwo> PosList = db.PosMachinesTwo.Where(m => StoreIds.Contains(m.StoreId) && m.UserId == 0 && m.BuyUserId == 0).ToList();
  1514. List<KqProducts> ProductList = db.KqProducts.ToList();
  1515. foreach (var items in idlist)
  1516. {
  1517. int StoreId = int.Parse(items);
  1518. var storeInfo = StoreHouses.FirstOrDefault(m => m.Id == StoreId && m.StoreKind != 2);
  1519. if (storeInfo.OpId > 0)
  1520. {
  1521. error += "以下操作失败" + storeInfo.StoreNo + ',' + "请先解除该分仓的关联" + '\n';
  1522. }
  1523. else
  1524. {
  1525. var pos = PosList.Where(m => m.StoreId == StoreId && m.UserId == 0 && m.BuyUserId == 0).ToList();
  1526. var posCount = pos.Count();
  1527. var brandInfo = ProductList.FirstOrDefault(m => m.Id == int.Parse(storeInfo.BrandId));
  1528. if (brandInfo.Name.Contains("电签"))
  1529. {
  1530. amount = 100;
  1531. }
  1532. if (brandInfo.Name.Contains("大POS"))
  1533. {
  1534. amount = 150;
  1535. }
  1536. if (!userIds.Contains(storeInfo.UserId + ","))
  1537. {
  1538. userIds += storeInfo.UserId + ",";
  1539. deposit += storeInfo.Deposit;//增加分仓押金
  1540. }
  1541. tamount += amount * posCount;//扣减运营中心该品牌机具额度
  1542. pCount += posCount;//添加总机具数
  1543. }
  1544. }
  1545. if (!string.IsNullOrEmpty(error))
  1546. {
  1547. return "Warning|" + error;
  1548. }
  1549. var userAmount = opdb.UserAccount.FirstOrDefault(m => m.Sort == sysAdmin.Id) ?? new OpModels.UserAccount();
  1550. decimal TotalAmount = userAmount.ValidAmount + userAmount.TotalAmt + userAmount.ValidForGetAmount;//旧的总金额
  1551. userAmount.ValidAmount += deposit;
  1552. opdb.SaveChanges();
  1553. decimal toAmount = userAmount.ValidAmount + userAmount.TotalAmt + userAmount.ValidForGetAmount;//新的总金额
  1554. if (toAmount >= tamount)
  1555. {
  1556. foreach (var item in idlist)
  1557. {
  1558. int StoreId = int.Parse(item);
  1559. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("StoreHouse", Fields, StoreId);
  1560. var storeInfo = StoreHouses.FirstOrDefault(m => m.Id == StoreId && m.StoreKind != 2);
  1561. if (storeInfo.OpId == 0)
  1562. {
  1563. var pos = PosList.Where(m => m.StoreId == StoreId && m.UserId == 0 && m.BuyUserId == 0).ToList();
  1564. var posCount = pos.Count();
  1565. var BrandId = int.Parse(storeInfo.BrandId);
  1566. var brandInfo = ProductList.FirstOrDefault(m => m.Id == BrandId);
  1567. if (brandInfo.Name.Contains("电签"))
  1568. {
  1569. amount = 100;
  1570. }
  1571. if (brandInfo.Name.Contains("大POS"))
  1572. {
  1573. amount = 150;
  1574. }
  1575. if (IsOk == "1")
  1576. {
  1577. foreach (var items in pos)
  1578. {
  1579. var posInfo = pos.FirstOrDefault(m => m.Id == items.Id) ?? new PosMachinesTwo();
  1580. posInfo.OpId = sysAdmin.UserId;
  1581. if (userAmount.ValidAmount - amount >= 0)
  1582. {
  1583. userAmount.ValidAmount -= amount;
  1584. posInfo.OpReserve3 += amount; //关联分仓额度
  1585. posInfo.OpReserve1 = 0; //未使用额度
  1586. posInfo.OpReserve2 = 0; //可提现额度
  1587. opdb.SaveChanges();
  1588. }
  1589. else
  1590. {
  1591. if (userAmount.TotalAmt - amount >= 0)
  1592. {
  1593. userAmount.TotalAmt -= amount - userAmount.ValidAmount;
  1594. posInfo.OpReserve3 = userAmount.ValidAmount;
  1595. posInfo.OpReserve1 = amount - userAmount.ValidAmount;
  1596. posInfo.OpReserve2 = 0;
  1597. opdb.SaveChanges();
  1598. }
  1599. else
  1600. {
  1601. if (userAmount.ValidForGetAmount - amount >= 0)
  1602. {
  1603. userAmount.ValidForGetAmount -= amount - userAmount.TotalAmt;
  1604. posInfo.OpReserve3 = 0;
  1605. posInfo.OpReserve1 = userAmount.TotalAmt;
  1606. posInfo.OpReserve2 = amount - userAmount.TotalAmt;
  1607. opdb.SaveChanges();
  1608. }
  1609. }
  1610. }
  1611. db.SaveChanges();
  1612. }
  1613. sysAdmin.TotalMachineCount += posCount;//添加总机具数
  1614. opdb.SaveChanges();
  1615. }
  1616. storeInfo.OpId = sysAdmin.UserId;
  1617. db.SaveChanges();
  1618. var query = opdb.StoreForOperate.FirstOrDefault(m => m.OpId == sysAdmin.UserId && m.StoreId == StoreId && m.Sort == 0 && m.QueryCount == storeInfo.UserId && m.Status == 0);
  1619. if (query == null)
  1620. {
  1621. var user = db.Users.FirstOrDefault(m => m.Id == storeInfo.UserId) ?? new Users();
  1622. query = opdb.StoreForOperate.Add(new OpModels.StoreForOperate()
  1623. {
  1624. CreateDate = DateTime.Now, //创建时间
  1625. CreateMan = SysUserName + "_" + SysRealName,
  1626. QueryCount = storeInfo.UserId,//分仓所属人Id
  1627. SeoTitle = user.MakerCode,
  1628. SeoKeyword = storeInfo.StoreNo,
  1629. SeoDescription = storeInfo.StoreName,
  1630. OpId = sysAdmin.UserId,
  1631. StoreId = StoreId,
  1632. }).Entity;
  1633. opdb.SaveChanges();
  1634. }
  1635. //添加分仓创建时间
  1636. var users = db.Users.FirstOrDefault(m => m.Id == storeInfo.UserId) ?? new Users();
  1637. if (users.Id > 0)
  1638. {
  1639. DataTable dt = OtherMySqlConn.dtable("SELECT CreateDate FROM StoreHouse WHERE UserId=" + users.Id + " AND `Status`>0 ORDER BY CreateDate LIMIT 1");
  1640. if (dt.Rows.Count > 0)
  1641. {
  1642. users.CreateStoreDate = DateTime.Parse(dt.Rows[0][0].ToString());
  1643. db.SaveChanges();
  1644. }
  1645. }
  1646. }
  1647. }
  1648. if (IsOk == "1")
  1649. {
  1650. if (deposit > tamount)
  1651. {
  1652. var amoutRecord = opdb.AmountRecord.Add(new OpModels.AmountRecord
  1653. {
  1654. CreateDate = DateTime.Now,
  1655. UserId = sysAdmin.UserId,
  1656. SeoDescription = "关联分仓",
  1657. OperateType = 1,
  1658. UseAmount = deposit - tamount,
  1659. BeforeAmount = TotalAmount,
  1660. AfterAmount = TotalAmount + deposit - tamount,
  1661. }).Entity;
  1662. }
  1663. if (deposit < tamount)
  1664. {
  1665. var amoutRecord = opdb.AmountRecord.Add(new OpModels.AmountRecord
  1666. {
  1667. CreateDate = DateTime.Now,
  1668. UserId = sysAdmin.UserId,
  1669. SeoDescription = "关联分仓",
  1670. OperateType = 2,
  1671. UseAmount = tamount - deposit,
  1672. BeforeAmount = TotalAmount,
  1673. AfterAmount = TotalAmount + deposit - tamount,
  1674. }).Entity;
  1675. }
  1676. opdb.SaveChanges();
  1677. }
  1678. sysAdmin.StoreCount += idlist.Count();//添加关联分仓数
  1679. opdb.SaveChanges();
  1680. }
  1681. else
  1682. {
  1683. userAmount.ValidAmount -= deposit;
  1684. opdb.SaveChanges();
  1685. return "运营中心额度不足";
  1686. }
  1687. }
  1688. else
  1689. {
  1690. return "该创客未创建运营中心";
  1691. }
  1692. }
  1693. return "success";
  1694. }
  1695. //获取运营中心额度
  1696. public string GetReserve(string MakerCode)
  1697. {
  1698. UserForMakerCode userFor = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode) ?? new UserForMakerCode();
  1699. OpModels.UserAccount account = opdb.UserAccount.FirstOrDefault(m => m.Id == userFor.UserId) ?? new OpModels.UserAccount();
  1700. decimal TotalAmount = account.ValidAmount + account.TotalAmt + account.ValidForGetAmount;
  1701. return TotalAmount.ToString("f2");
  1702. }
  1703. #endregion
  1704. #region 取消关联
  1705. /// <summary>
  1706. /// 取消关联
  1707. /// </summary>
  1708. /// <returns></returns>
  1709. public IActionResult BatchCancle(string right, string StoreIds)
  1710. {
  1711. string[] idlist = StoreIds.Split(new char[] { ',' });
  1712. decimal totalAmount = 0;
  1713. decimal deposit = 0;
  1714. var userIds = "";
  1715. foreach (var item in idlist)
  1716. {
  1717. int StoreId = int.Parse(item);
  1718. var amount = 0;
  1719. var tamount = 0;
  1720. var storeInfo = db.StoreHouse.FirstOrDefault(m => m.Id == StoreId);
  1721. var posCount = db.PosMachinesTwo.Count(m => m.StoreId == StoreId && m.UserId == 0 && m.BuyUserId == 0 && m.OpId == storeInfo.OpId);
  1722. var BrandId = int.Parse(storeInfo.BrandId);
  1723. var brandInfo = db.KqProducts.FirstOrDefault(m => m.Id == BrandId);
  1724. if (brandInfo.Name.Contains("电签"))
  1725. {
  1726. amount = 100;
  1727. }
  1728. if (brandInfo.Name.Contains("大POS"))
  1729. {
  1730. amount = 150;
  1731. }
  1732. if (!userIds.Contains(storeInfo.UserId + ","))
  1733. {
  1734. userIds += storeInfo.UserId + ",";
  1735. deposit += storeInfo.Deposit;
  1736. }
  1737. tamount = amount * posCount;//增加运营中心该品牌机具额度
  1738. totalAmount += tamount;//取消关联分仓打标记运营中心所需额度
  1739. }
  1740. ViewBag.RightInfo = RightInfo;
  1741. ViewBag.right = right;
  1742. ViewBag.totalAmount = "取消关联机具获得额度:" + totalAmount;
  1743. ViewBag.deposit = "取消关联分仓扣除押金:" + deposit;
  1744. return View();
  1745. }
  1746. #endregion
  1747. #region 取消关联
  1748. /// <summary>
  1749. /// 取消关联
  1750. /// </summary>
  1751. /// <returns></returns>
  1752. [HttpPost]
  1753. public string BatchCancle(string Id, string MakerCode, string IsOk = "1")
  1754. {
  1755. string[] idlist = Id.Split(new char[] { ',' });
  1756. Dictionary<string, object> Fields = new Dictionary<string, object>();
  1757. AddSysLog(Id, "StoreHouse", "StoreHouseBatchCancle");
  1758. var userForMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode) ?? new UserForMakerCode();
  1759. if (userForMakerCode.UserId > 0)
  1760. {
  1761. var sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.UserId == userForMakerCode.UserId);
  1762. var userAmount = opdb.UserAccount.FirstOrDefault(m => m.Sort == sysAdmin.Id) ?? new OpModels.UserAccount();
  1763. decimal TotalAmount = userAmount.ValidAmount + userAmount.TotalAmt + userAmount.ValidForGetAmount;//旧的总金额
  1764. Fields.Add("OpId", 0);
  1765. if (sysAdmin.Id > 0)
  1766. {
  1767. var amount = 0;
  1768. var tamount = 0;
  1769. decimal deposit = 0;
  1770. decimal ValidAmount = 0;
  1771. decimal TotalAmt = 0;
  1772. decimal ValidForGetAmount = 0;
  1773. var pCount = 0;
  1774. var userIds = "";
  1775. string error = "";
  1776. List<int> StoreIds = new List<int>();
  1777. foreach (var items in idlist)
  1778. {
  1779. StoreIds.Add(int.Parse(items));
  1780. }
  1781. List<StoreHouse> StoreHouses = db.StoreHouse.Where(m => StoreIds.Contains(m.Id)).ToList();
  1782. List<PosMachinesTwo> PosList = db.PosMachinesTwo.Where(m => StoreIds.Contains(m.StoreId) && m.UserId == 0 && m.BuyUserId == 0 && m.OpId > 0).ToList();
  1783. List<KqProducts> ProductList = db.KqProducts.ToList();
  1784. foreach (var item in idlist)
  1785. {
  1786. int StoreId = int.Parse(item);
  1787. var store = StoreHouses.FirstOrDefault(m => m.Id == StoreId && m.StoreKind != 2 && m.OpId == sysAdmin.UserId);
  1788. if (store == null)
  1789. {
  1790. error += "分仓" + store.StoreNo + "未在创客" + MakerCode + "的关联分仓中";
  1791. }
  1792. else
  1793. {
  1794. var pos = PosList.Where(m => m.StoreId == StoreId && m.UserId == 0 && m.BuyUserId == 0 && m.OpId == sysAdmin.UserId).ToList();
  1795. var posCount = pos.Count();
  1796. var BrandId = int.Parse(store.BrandId);
  1797. var brandInfo = ProductList.FirstOrDefault(m => m.Id == BrandId);
  1798. if (brandInfo.Name.Contains("电签"))
  1799. {
  1800. amount = 100;
  1801. }
  1802. if (brandInfo.Name.Contains("大POS"))
  1803. {
  1804. amount = 150;
  1805. }
  1806. if (!userIds.Contains(store.UserId + ","))
  1807. {
  1808. userIds += store.UserId + ",";
  1809. deposit += store.Deposit;//增加分仓押金
  1810. }
  1811. foreach (var items in pos)
  1812. {
  1813. var posInfo = pos.FirstOrDefault(m => m.Id == items.Id) ?? new PosMachinesTwo();
  1814. ValidAmount += posInfo.OpReserve3;
  1815. TotalAmt += posInfo.OpReserve1;
  1816. ValidForGetAmount += posInfo.OpReserve2;
  1817. }
  1818. tamount += amount * posCount;//扣减运营中心该品牌机具额度
  1819. pCount += posCount;//添加总机具数
  1820. }
  1821. }
  1822. if (!string.IsNullOrEmpty(error))
  1823. {
  1824. return "Warning|" + error;
  1825. }
  1826. decimal toAmount = userAmount.ValidAmount + userAmount.TotalAmt + userAmount.ValidForGetAmount + ValidAmount + TotalAmt + ValidForGetAmount;//新的总金额
  1827. if (toAmount >= deposit)
  1828. {
  1829. foreach (var item in idlist)
  1830. {
  1831. int StoreId = int.Parse(item);
  1832. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("StoreHouse", Fields, StoreId);
  1833. db.SaveChanges();
  1834. var store = StoreHouses.FirstOrDefault(m => m.Id == StoreId && m.StoreKind != 2);
  1835. var pos = PosList.Where(m => m.StoreId == StoreId && m.UserId == 0 && m.BuyUserId == 0 && m.OpId == sysAdmin.UserId).ToList();
  1836. foreach (var items in pos)
  1837. {
  1838. var posInfo = pos.FirstOrDefault(m => m.Id == items.Id) ?? new PosMachinesTwo();
  1839. posInfo.OpReserve3 = 0;
  1840. posInfo.OpReserve1 = 0;
  1841. posInfo.OpReserve2 = 0;
  1842. posInfo.OpId = 0;
  1843. db.SaveChanges();
  1844. }
  1845. var query = opdb.StoreForOperate.FirstOrDefault(m => m.Status == 0 && m.OpId == sysAdmin.UserId && m.StoreId == StoreId && m.Sort == 0 && m.QueryCount == store.UserId);
  1846. if (query != null)
  1847. {
  1848. query.UpdateDate = DateTime.Now;
  1849. query.UpdateMan = SysUserName + "_" + SysRealName;
  1850. query.Status = -1;
  1851. opdb.SaveChanges();
  1852. }
  1853. }
  1854. userAmount.ValidAmount -= deposit;//扣减关联分仓押金
  1855. userAmount.ValidAmount += ValidAmount;
  1856. userAmount.TotalAmt += TotalAmt;
  1857. userAmount.ValidForGetAmount += ValidForGetAmount;
  1858. sysAdmin.StoreCount -= idlist.Count();//减少关联分仓数
  1859. sysAdmin.TotalMachineCount -= pCount;//减少关联分仓机具数
  1860. if (deposit > tamount)
  1861. {
  1862. var amoutRecord = opdb.AmountRecord.Add(new OpModels.AmountRecord
  1863. {
  1864. CreateDate = DateTime.Now,
  1865. UserId = sysAdmin.UserId,
  1866. SeoDescription = "取消关联分仓",
  1867. OperateType = 2,
  1868. UseAmount = deposit - tamount,
  1869. BeforeAmount = TotalAmount,
  1870. AfterAmount = TotalAmount - deposit + tamount,
  1871. }).Entity;
  1872. }
  1873. if (deposit < tamount)
  1874. {
  1875. var amoutRecord = opdb.AmountRecord.Add(new OpModels.AmountRecord
  1876. {
  1877. CreateDate = DateTime.Now,
  1878. UserId = sysAdmin.UserId,
  1879. SeoDescription = "取消关联分仓",
  1880. OperateType = 1,
  1881. UseAmount = tamount - deposit,
  1882. BeforeAmount = TotalAmount,
  1883. AfterAmount = TotalAmount - deposit + tamount,
  1884. }).Entity;
  1885. }
  1886. opdb.SaveChanges();
  1887. }
  1888. else
  1889. {
  1890. return "运营中心额度不足";
  1891. }
  1892. }
  1893. }
  1894. else
  1895. {
  1896. return "该创客未创建运营中心";
  1897. }
  1898. return "success";
  1899. }
  1900. #endregion
  1901. }
  1902. }