VSMAppService.cs 108 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297
  1. using Business.Core.Enum;
  2. using Business.Core.Utilities;
  3. using Business.Domain;
  4. using Business.Dto;
  5. using Business.EntityFrameworkCore;
  6. using Business.EntityFrameworkCore.SqlRepositories;
  7. using Business.ResourceExamineManagement;
  8. using Business.ResourceExamineManagement.Dto;
  9. using Business.StructuredDB.MES;
  10. using Business.StructuredDB.MES.IC;
  11. using Business.StructuredDB.SaleFcst;
  12. using Business.StructuredDB.WMS;
  13. using Business.VSM;
  14. using MathNet.Numerics.LinearAlgebra.Factorization;
  15. using Microsoft.EntityFrameworkCore;
  16. using Microsoft.EntityFrameworkCore.Metadata.Internal;
  17. using Microsoft.Extensions.Configuration;
  18. using MongoDB.Driver.Linq;
  19. using Newtonsoft.Json;
  20. using NLog;
  21. using System;
  22. using System.Collections;
  23. using System.Collections.Generic;
  24. using System.Data;
  25. using System.Diagnostics.Metrics;
  26. using System.Linq;
  27. using System.Text;
  28. using System.Threading;
  29. using System.Threading.Tasks;
  30. using System.Xml.Linq;
  31. using Volo.Abp.Application.Services;
  32. using Volo.Abp.Domain.Repositories;
  33. using Volo.Abp.MultiTenancy;
  34. using WkHtmlToPdfDotNet;
  35. using ZstdSharp.Unsafe;
  36. using static Microsoft.EntityFrameworkCore.DbLoggerCategory;
  37. namespace Business.VSMManagement
  38. {
  39. public class VSMAppService : ApplicationService,IVSMAppService
  40. {
  41. private readonly ISqlRepository<ItemMaster> _itemMaster;
  42. private readonly ISqlRepository<InvTransHist> _invTransHist;
  43. private readonly IRepository<srm_purchase> _srm_purchase;
  44. private readonly IRepository<ic_item> _ic_item;
  45. private readonly ISqlRepository<LocationDetail> _LocationDetail;
  46. private readonly ISqlRepository<InvTransHistDay> _InvTransHistDay;
  47. private readonly IExtRASqlRepository<DMS_IN_PODETAIL> _DMS_IN_PODETAIL;
  48. private readonly IExtRASqlRepository<DMS_IN_LOCDETAIL> _DMS_IN_LOCDETAIL;
  49. private readonly IExtRASqlRepository<DMS_IN_ITEMMAPPING> _DMS_IN_ITEMMAPPING;
  50. private readonly IExtRASqlRepository<DMS_IN_SHIPPINGDETAIL> _DMS_IN_SHIPPINGDETAIL;
  51. private readonly ISqlRepository<SAPInv> _SAPInv;
  52. private readonly IRepository<MonthlyShipmentPlan> _monthlyShipmentPlan;
  53. private readonly ISqlRepository<ASNBOLShipperDetail> _aSNBOLShipperDetail;
  54. private readonly BusinessDbContext _businessDbContext;
  55. private readonly BusinessExtRADbContext _businessExtRADbContext;
  56. public VSMAppService(
  57. ISqlRepository<ItemMaster> itemMaster,
  58. ISqlRepository<InvTransHist> invTransHist,
  59. IRepository<srm_purchase> srm_purchase,
  60. IRepository<ic_item> ic_item,
  61. ISqlRepository<LocationDetail> locationDetail,
  62. ISqlRepository<InvTransHistDay> invTransHistDay,
  63. IExtRASqlRepository<DMS_IN_PODETAIL> dms_IN_PODETAIL,
  64. IExtRASqlRepository<DMS_IN_LOCDETAIL> dms_IN_LOCDETAIL,
  65. IExtRASqlRepository<DMS_IN_ITEMMAPPING> dms_IN_ITEMMAPPING,
  66. IExtRASqlRepository<DMS_IN_SHIPPINGDETAIL> dms_IN_SHIPPINGDETAIL,
  67. ISqlRepository<SAPInv> SAPInv,
  68. IRepository<MonthlyShipmentPlan> monthlyShipmentPlan,
  69. ISqlRepository<ASNBOLShipperDetail> aSNBOLShipperDetail,
  70. BusinessDbContext businessDbContext,
  71. BusinessExtRADbContext businessExtRADbContext
  72. )
  73. {
  74. _itemMaster = itemMaster;
  75. _invTransHist = invTransHist;
  76. _srm_purchase = srm_purchase;
  77. _ic_item = ic_item;
  78. _LocationDetail=locationDetail;
  79. _InvTransHistDay = invTransHistDay;
  80. _DMS_IN_PODETAIL = dms_IN_PODETAIL;
  81. _DMS_IN_LOCDETAIL= dms_IN_LOCDETAIL;
  82. _DMS_IN_ITEMMAPPING= dms_IN_ITEMMAPPING;
  83. _DMS_IN_SHIPPINGDETAIL = dms_IN_SHIPPINGDETAIL;
  84. _SAPInv =SAPInv;
  85. _monthlyShipmentPlan=monthlyShipmentPlan;
  86. _aSNBOLShipperDetail = aSNBOLShipperDetail;
  87. _businessDbContext = businessDbContext;
  88. _businessExtRADbContext = businessExtRADbContext;
  89. }
  90. public string ValueFrequency(string Loc, string BeginDate, string EndDate, string KanBan, string Frequency)
  91. {
  92. try
  93. {
  94. DateTime beginDate = Convert.ToDateTime(BeginDate);
  95. DateTime endDate = Convert.ToDateTime(EndDate);
  96. string sql = $"select distinct ItemNum,Min(CreateTime) AS HistMinTime from InvTransHist where Domain='8010' and createTime>='{beginDate}' and createTime<='{endDate}' group by ItemNum";
  97. var InvTransHistDto = _businessDbContext.InvTransHistDayDto.FromSqlRaw(sql).ToList();
  98. var itemList = InvTransHistDto.Select(a => a.ItemNum).Distinct().ToList();
  99. ValueFrequencyDto dto = new ValueFrequencyDto();
  100. List<ValueFrequencyKanBanDto> kanBanDtos = new List<ValueFrequencyKanBanDto>();
  101. var icitems = _ic_item.GetListAsync(a => itemList.Contains(a.number)).Result;
  102. var srm_purchases = _srm_purchase.GetListAsync(a => icitems.Select(b=>b.Id).ToList().Contains(a.icitem_id)).Result;
  103. string sqldzd = @"select MATNR AS ItemNum,MAx(NETPR)*10 AS NETPR from SupplierStatement group by MATNR";
  104. var dzdList = _businessDbContext.SupplierStatementDto.FromSqlRaw(sqldzd).ToList();
  105. var InvTransHistDayDto = _InvTransHistDay.Select(a => a.HistDayTime >= beginDate.Date && a.HistDayTime <= endDate);
  106. itemList.ForEach(item =>
  107. {
  108. if(icitems.Any(a=>a.number==item))
  109. {
  110. ValueFrequencyKanBanDto itemKanBanDto = new ValueFrequencyKanBanDto();
  111. itemKanBanDto.ItemNumber = item;
  112. itemKanBanDto.ItemId = icitems.Find(a => a.number == item).Id;
  113. itemKanBanDto.Model = icitems.Find(a => a.number == item).model;
  114. itemKanBanDto.ItemName = icitems.Find(a => a.number == item).name;
  115. itemKanBanDto.PLT = 14;
  116. //供应提前期取货源清单最大值,没有默认14天
  117. if (srm_purchases.Any(a => a.icitem_id == itemKanBanDto.ItemId && a.quota_rate.GetValueOrDefault() > 0))
  118. {
  119. itemKanBanDto.PLT = srm_purchases.Where(a => a.number == item && a.quota_rate.GetValueOrDefault() > 0).Max(a => a.lead_time).Value;
  120. }
  121. var entry = dzdList.FirstOrDefault(p => p.ItemNum == item);
  122. if (entry != null)
  123. {
  124. itemKanBanDto.NETPR = entry.NETPR;
  125. }
  126. else
  127. {
  128. itemKanBanDto.NETPR = 1 * 10;
  129. }
  130. //出库总数
  131. itemKanBanDto.OutStockQty = InvTransHistDayDto.Where(a => a.ItemNum == item).Sum(b => b.QtyChangeOut);
  132. //库存数据取进出存期末数据
  133. itemKanBanDto.Amount = InvTransHistDayDto.Where(a => a.ItemNum == item).OrderByDescending(a => a.HistDayTime).First().BalanceNum * itemKanBanDto.NETPR;
  134. itemKanBanDto.MoveCount = InvTransHistDayDto.Where(a => a.ItemNum == item && a.QtyChangeOut > 0).Count();
  135. int days = endDate.Subtract(beginDate).Days;
  136. //同一天算1天
  137. if (days == 0)
  138. days = 1;
  139. itemKanBanDto.ADU = itemKanBanDto.OutStockQty / days;
  140. itemKanBanDto.Kanban = itemKanBanDto.ADU * itemKanBanDto.PLT;
  141. kanBanDtos.Add(itemKanBanDto);
  142. }
  143. });
  144. decimal totalmoveCount = kanBanDtos.Sum(a=>a.MoveCount);
  145. decimal totalAmount = kanBanDtos.Sum(a => a.Amount);
  146. decimal avgmoveCount = kanBanDtos.Average(a => a.MoveCount);
  147. kanBanDtos=kanBanDtos.OrderByDescending(a => a.Amount).ToList();
  148. for (int i=0;i< kanBanDtos.Count;i++)
  149. {
  150. if (kanBanDtos[i].MoveCount > avgmoveCount)
  151. {
  152. kanBanDtos[i].FMR = "F";
  153. }
  154. else if(kanBanDtos[i].MoveCount < avgmoveCount / 2)
  155. {
  156. kanBanDtos[i].FMR = "R";
  157. }else
  158. {
  159. kanBanDtos[i].FMR = "M";
  160. }
  161. if(i<=kanBanDtos.Count*0.7)
  162. {
  163. kanBanDtos[i].ABC = "A";
  164. }else if(i>=kanBanDtos.Count*0.9)
  165. {
  166. kanBanDtos[i].ABC = "C";
  167. }else
  168. {
  169. kanBanDtos[i].ABC = "B";
  170. }
  171. kanBanDtos[i].AmountTotal = totalAmount;
  172. kanBanDtos[i].MovePencent = totalmoveCount == 0 ? 0 : kanBanDtos[i].MoveCount * 100 / totalmoveCount;
  173. }
  174. int totalCount = kanBanDtos.Count();
  175. dto.jzpc1 = $"{kanBanDtos.Where(a => a.ABC == "A" && a.FMR == "R").Count()}/{kanBanDtos.Count}";
  176. dto.jzpc2 = $"{kanBanDtos.Where(a => a.ABC == "A" && a.FMR == "M").Count()}/{kanBanDtos.Count}";
  177. dto.jzpc3 = $"{kanBanDtos.Where(a => a.ABC == "A" && a.FMR == "F").Count()}/{kanBanDtos.Count}";
  178. dto.jzpc4 = $"{kanBanDtos.Where(a => a.ABC == "B" && a.FMR == "R").Count()}/{kanBanDtos.Count}";
  179. dto.jzpc5 = $"{kanBanDtos.Where(a => a.ABC == "B" && a.FMR == "M").Count()}/{kanBanDtos.Count}";
  180. dto.jzpc6 = $"{kanBanDtos.Where(a => a.ABC == "B" && a.FMR == "F").Count()}/{kanBanDtos.Count}";
  181. dto.jzpc7 = $"{kanBanDtos.Where(a => a.ABC == "C" && a.FMR == "R").Count()}/{kanBanDtos.Count}";
  182. dto.jzpc8 = $"{kanBanDtos.Where(a => a.ABC == "C" && a.FMR == "M").Count()}/{kanBanDtos.Count}";
  183. dto.jzpc9 = $"{kanBanDtos.Where(a => a.ABC == "C" && a.FMR == "F").Count()}/{kanBanDtos.Count}";
  184. return JsonConvert.SerializeObject(dto);
  185. }
  186. catch (Exception ex)
  187. {
  188. return ex.Message;
  189. }
  190. }
  191. public string ValueFrequencyDetail(string Loc, string BeginDate, string EndDate, string KanBan, string Frequency, string JZ, string PC)
  192. {
  193. try
  194. {
  195. List<ValueFrequencyDetailDto> dtos = new List<ValueFrequencyDetailDto>();
  196. try
  197. {
  198. DateTime beginDate = Convert.ToDateTime(BeginDate);
  199. DateTime endDate = Convert.ToDateTime(EndDate);
  200. string sql = $"select distinct ItemNum,Min(CreateTime) AS HistMinTime from InvTransHist where Domain='8010' and createTime>='{beginDate}' and createTime<='{endDate}' group by ItemNum";
  201. var InvTransHistDto = _businessDbContext.InvTransHistDayDto.FromSqlRaw(sql).ToList();
  202. var itemList = InvTransHistDto.Select(a => a.ItemNum).Distinct().ToList();
  203. ValueFrequencyDto dto = new ValueFrequencyDto();
  204. List<ValueFrequencyKanBanDto> kanBanDtos = new List<ValueFrequencyKanBanDto>();
  205. var icitems = _ic_item.GetListAsync(a => itemList.Contains(a.number)).Result;
  206. var srm_purchases = _srm_purchase.GetListAsync(a => icitems.Select(b => b.Id).ToList().Contains(a.icitem_id)).Result;
  207. string sqldzd = @"select MATNR AS ItemNum,Max(NETPR)*10 AS NETPR from SupplierStatement group by MATNR";
  208. var dzdList = _businessDbContext.SupplierStatementDto.FromSqlRaw(sqldzd).ToList();
  209. var InvTransHistDayDto = _InvTransHistDay.Select(a=>a.HistDayTime>= beginDate.Date && a.HistDayTime<= endDate);
  210. itemList.ForEach(item =>
  211. {
  212. if (icitems.Any(a => a.number == item))
  213. {
  214. ValueFrequencyKanBanDto itemKanBanDto = new ValueFrequencyKanBanDto();
  215. itemKanBanDto.ItemNumber = item;
  216. itemKanBanDto.ItemId = icitems.Find(a => a.number == item).Id;
  217. itemKanBanDto.Model = icitems.Find(a => a.number == item).model;
  218. itemKanBanDto.ItemName = icitems.Find(a => a.number == item).name;
  219. itemKanBanDto.PLT = 14;
  220. //供应提前期取货源清单最大值,没有默认14天
  221. if (srm_purchases.Any(a => a.icitem_id == itemKanBanDto.ItemId && a.quota_rate.GetValueOrDefault() > 0))
  222. {
  223. itemKanBanDto.PLT = srm_purchases.Where(a => a.number == item && a.quota_rate.GetValueOrDefault() > 0).Max(a => a.lead_time).Value;
  224. }
  225. var entry = dzdList.FirstOrDefault(p => p.ItemNum == item);
  226. if (entry != null)
  227. {
  228. itemKanBanDto.NETPR = entry.NETPR;
  229. }
  230. else
  231. {
  232. itemKanBanDto.NETPR = 1 * 10;
  233. }
  234. //出库总数
  235. itemKanBanDto.OutStockQty = InvTransHistDayDto.Where(a=>a.ItemNum==item).Sum(b=>b.QtyChangeOut);
  236. //库存数据取进出存期末数据
  237. itemKanBanDto.Amount = InvTransHistDayDto.Where(a => a.ItemNum == item).OrderByDescending(a=>a.HistDayTime).First().BalanceNum * itemKanBanDto.NETPR;
  238. itemKanBanDto.MoveCount = InvTransHistDayDto.Where(a => a.ItemNum == item && a.QtyChangeOut>0).Count();
  239. int days = endDate.Subtract(beginDate).Days;
  240. //同一天算1天
  241. if (days == 0)
  242. days = 1;
  243. itemKanBanDto.ADU = itemKanBanDto.OutStockQty / days;
  244. itemKanBanDto.Kanban = itemKanBanDto.ADU * itemKanBanDto.PLT;
  245. kanBanDtos.Add(itemKanBanDto);
  246. }
  247. });
  248. decimal totalmoveCount = kanBanDtos.Sum(a => a.MoveCount);
  249. decimal totalAmount = kanBanDtos.Sum(a => a.Amount);
  250. decimal avgmoveCount = kanBanDtos.Average(a => a.MoveCount);
  251. kanBanDtos = kanBanDtos.OrderByDescending(a => a.Amount).ToList();
  252. for (int i = 0; i < kanBanDtos.Count; i++)
  253. {
  254. if (kanBanDtos[i].MoveCount > avgmoveCount)
  255. {
  256. kanBanDtos[i].FMR = "F";
  257. }
  258. else if (kanBanDtos[i].MoveCount < avgmoveCount / 2)
  259. {
  260. kanBanDtos[i].FMR = "R";
  261. }
  262. else
  263. {
  264. kanBanDtos[i].FMR = "M";
  265. }
  266. if (i <= kanBanDtos.Count * 0.7)
  267. {
  268. kanBanDtos[i].ABC = "A";
  269. }
  270. else if (i >= kanBanDtos.Count * 0.9)
  271. {
  272. kanBanDtos[i].ABC = "C";
  273. }
  274. else
  275. {
  276. kanBanDtos[i].ABC = "B";
  277. }
  278. kanBanDtos[i].AmountTotal = totalAmount;
  279. kanBanDtos[i].MovePencent = totalmoveCount == 0 ? 0 : kanBanDtos[i].MoveCount * 100 / totalmoveCount;
  280. }
  281. kanBanDtos=kanBanDtos.Where(a=>a.ABC==JZ&&a.FMR==PC && a.Kanban > Convert.ToDecimal(KanBan) && a.MovePencent*100 > Convert.ToDecimal(Frequency)).OrderByDescending(a=>a.Amount).ToList();
  282. for (int i=0;i< kanBanDtos.Count(); i++)
  283. {
  284. ValueFrequencyDetailDto detailDto = new ValueFrequencyDetailDto();
  285. detailDto.RowSeq =i+1;
  286. detailDto.ItemNum = kanBanDtos[i].ItemNumber;
  287. detailDto.ItemName = kanBanDtos[i].ItemName;
  288. detailDto.Model = kanBanDtos[i].Model;
  289. detailDto.ItemABC = kanBanDtos[i].ABC;
  290. detailDto.ItemFMR = kanBanDtos[i].FMR;
  291. detailDto.Amount = kanBanDtos[i].Amount;
  292. detailDto.AmountFix = Convert.ToDecimal(KanBan) * kanBanDtos[i].NETPR;
  293. detailDto.AmountDiff = detailDto.Amount- detailDto.AmountFix;
  294. dtos.Add(detailDto);
  295. }
  296. return JsonConvert.SerializeObject(dtos);
  297. }
  298. catch (Exception ex)
  299. {
  300. return ex.Message;
  301. }
  302. }
  303. catch (Exception ex)
  304. {
  305. return ex.Message;
  306. }
  307. }
  308. public string ChartLineOption(string Loc, string BeginDate, string EndDate, string ItemNum,string TurnOver,string KanBan)
  309. {
  310. try
  311. {
  312. DateTime beginDate = Convert.ToDateTime(BeginDate);
  313. DateTime endDate = Convert.ToDateTime(EndDate);
  314. var srm_purchases = _srm_purchase.GetListAsync(a =>a.number==ItemNum).Result;
  315. decimal chartPLT = 14;
  316. decimal chartKanBan = Convert.ToDecimal(KanBan);
  317. //供应提前期取货源清单最大值,没有默认14天
  318. if (srm_purchases.Any(a => a.number == ItemNum && a.quota_rate.GetValueOrDefault() > 0))
  319. {
  320. chartPLT = srm_purchases.Where(a => a.number == ItemNum && a.quota_rate.GetValueOrDefault() > 0).Max(a => a.lead_time).Value;
  321. }
  322. var InvTransHistDayDto = _InvTransHistDay.Select(a => a.ItemNum== ItemNum && a.HistDayTime >= beginDate.Date && a.HistDayTime <= endDate);
  323. int tranDays = (endDate-beginDate).Days;
  324. List<ValueFrequencyChartDto> chartDtos = new List<ValueFrequencyChartDto>();
  325. for(int i = 0; i < tranDays; i++)
  326. {
  327. ValueFrequencyChartDto dtoChart = new ValueFrequencyChartDto();
  328. dtoChart.Date = beginDate.AddDays(i).ToString("yyyy-MM-dd");
  329. var itemDays = InvTransHistDayDto.Where(a => beginDate.AddDays(i).Date == a.HistDayTime.Date).ToList();
  330. if(itemDays.Count>0)
  331. {
  332. dtoChart.InStockQty = itemDays[0].QtyChangeAdvance;
  333. dtoChart.OutStockQty = itemDays[0].QtyChangeOut;
  334. dtoChart.StockQty = itemDays[0].BalanceNum;
  335. dtoChart.SuggestQty = chartKanBan * chartPLT;
  336. }else
  337. {
  338. dtoChart.InStockQty = 0;
  339. dtoChart.OutStockQty = 0;
  340. dtoChart.StockQty = 0;
  341. dtoChart.SuggestQty = 0;
  342. }
  343. chartDtos.Add(dtoChart);
  344. }
  345. chartDtos = chartDtos.Where(a => string.Compare(a.Date, BeginDate) >= 0 && string.Compare(a.Date, EndDate) <= 0).ToList();
  346. StringBuilder sb = new StringBuilder();
  347. StringBuilder sbDays = new StringBuilder();
  348. StringBuilder sbDaysStock = new StringBuilder();
  349. StringBuilder sbDaysInStock = new StringBuilder();
  350. StringBuilder sbDaysOutStock = new StringBuilder();
  351. StringBuilder sbDaysSuggest = new StringBuilder();
  352. sb.Append("{tooltip:{trigger:'axis'},legend:{data: ['日库存数量','日出库数量','日入库数量','推荐日库存数量']},grid:{left:'3%',right:'4%',bottom:'3%',containLabel:true},toolbox:{feature:{saveAsImage: {}}},xAxis: {type:'category',boundaryGap: false,data:[");
  353. chartDtos.ForEach(a =>
  354. {
  355. sbDays.Append(string.Format("'{0}',",a.Date));
  356. sbDaysStock.Append(string.Format("{0},", a.StockQty));
  357. sbDaysOutStock.Append(string.Format("{0},", a.OutStockQty));
  358. sbDaysInStock.Append(string.Format("{0},", a.InStockQty));
  359. sbDaysSuggest.Append(string.Format("{0},", a.SuggestQty));
  360. });
  361. sb.Append(sbDays.ToString().TrimEnd(',')).
  362. Append("]},yAxis:{type:'value',},series:[{name:'日库存数量',type:'line',stack: 'Total',data:[").
  363. Append(sbDaysStock.ToString().TrimEnd(',')).
  364. Append("]},{name:'日出库数量',type:'line',stack:'Total',data:[").
  365. Append(sbDaysOutStock.ToString().TrimEnd(',')).
  366. Append("]},{name:'日入库数量',type:'line',stack:'Total',data:[").
  367. Append(sbDaysInStock.ToString().TrimEnd(',')).
  368. Append("]},{name:'推荐日库存数量',type:'line',stack:'Total',data:[").
  369. Append(sbDaysSuggest.ToString().TrimEnd(',')).
  370. Append("]}]}");
  371. return sb.ToString();
  372. }
  373. catch (Exception ex)
  374. {
  375. return ex.Message;
  376. }
  377. }
  378. public string ChartLineSupplierPLTOption()
  379. {
  380. return "{title:{text: '供应商PLT占比(%)',left:'center',},tooltip:{trigger: 'axis'},toolbox: {show: true,feature:{saveAsImage: {}}},xAxis: {type: 'category',data: ['1', '2', '3', '4', '5', '6', '7']},yAxis: {type: 'value',axisLabel: {formatter: '{value} %'},axisPointer: {snap: true} },series: [{data: [2, 5, 18, 55, 12, 5, 3],type: 'line',smooth: true}]}";
  381. }
  382. public string ChartLinePLTOption(string PLT)
  383. {
  384. if(PLT=="25")
  385. {
  386. string sql = @"select t.[Date] AS [Date],t.DateStockQty AS StockQty,t.DateOutStockQty AS OutStockQty,t.DateInStockQty AS InStockQty,0.0 AS SuggestQty from [dbo].[25PLT] t";
  387. var chartDtosTest = _businessDbContext.ValueFrequencyChartDto.FromSqlRaw(sql).ToList();
  388. StringBuilder sb = new StringBuilder();
  389. StringBuilder sbDays = new StringBuilder();
  390. StringBuilder sbDaysStock = new StringBuilder();
  391. StringBuilder sbDaysInStock = new StringBuilder();
  392. StringBuilder sbDaysOutStock = new StringBuilder();
  393. sb.Append("{tooltip:{trigger:'axis'},legend:{data: ['日库存数量','日出库数量','日入库数量']},grid:{left:'3%',right:'4%',bottom:'3%',containLabel:true},toolbox:{feature:{saveAsImage: {}}},xAxis: {type:'category',boundaryGap: false,data:[");
  394. chartDtosTest.ForEach(a =>
  395. {
  396. sbDays.Append(string.Format("'{0}',", a.Date));
  397. sbDaysStock.Append(string.Format("{0},", a.StockQty));
  398. sbDaysOutStock.Append(string.Format("{0},", a.OutStockQty));
  399. sbDaysInStock.Append(string.Format("{0},", a.InStockQty));
  400. });
  401. sb.Append(sbDays.ToString().TrimEnd(',')).
  402. Append("]},yAxis:{type:'value',},series:[{name:'日库存数量',type:'line',data:[").
  403. Append(sbDaysStock.ToString().TrimEnd(',')).
  404. Append("]},{name:'日出库数量',type:'line',data:[").
  405. Append(sbDaysOutStock.ToString().TrimEnd(',')).
  406. Append("]},{name:'日入库数量',type:'line',data:[").
  407. Append(sbDaysInStock.ToString().TrimEnd(',')).
  408. Append("]}").Append("]}");
  409. return sb.ToString();
  410. }else
  411. {
  412. string sql = @"select t.[Date] AS [Date],t.DateStockQty AS StockQty,t.DateOutStockQty AS OutStockQty,t.DateInStockQty AS InStockQty,0.0 AS SuggestQty from [dbo].[15PLT] t";
  413. var chartDtosTest = _businessDbContext.ValueFrequencyChartDto.FromSqlRaw(sql).ToList();
  414. StringBuilder sb = new StringBuilder();
  415. StringBuilder sbDays = new StringBuilder();
  416. StringBuilder sbDaysStock = new StringBuilder();
  417. StringBuilder sbDaysInStock = new StringBuilder();
  418. StringBuilder sbDaysOutStock = new StringBuilder();
  419. sb.Append("{tooltip:{trigger:'axis'},legend:{data: ['日库存数量','日出库数量','日入库数量']},grid:{left:'3%',right:'4%',bottom:'3%',containLabel:true},toolbox:{feature:{saveAsImage: {}}},xAxis: {type:'category',boundaryGap: false,data:[");
  420. chartDtosTest.ForEach(a =>
  421. {
  422. sbDays.Append(string.Format("'{0}',", a.Date));
  423. sbDaysStock.Append(string.Format("{0},", a.StockQty));
  424. sbDaysOutStock.Append(string.Format("{0},", a.OutStockQty));
  425. sbDaysInStock.Append(string.Format("{0},", a.InStockQty));
  426. });
  427. sb.Append(sbDays.ToString().TrimEnd(',')).
  428. Append("]},yAxis:{type:'value',},series:[{name:'日库存数量',type:'line',data:[").
  429. Append(sbDaysStock.ToString().TrimEnd(',')).
  430. Append("]},{name:'日出库数量',type:'line',data:[").
  431. Append(sbDaysOutStock.ToString().TrimEnd(',')).
  432. Append("]},{name:'日入库数量',type:'line',data:[").
  433. Append(sbDaysInStock.ToString().TrimEnd(',')).
  434. Append("]}").Append("]}");
  435. return sb.ToString();
  436. }
  437. }
  438. public string ChartLineModelOption(string factory_id, string model,string avgHW, string avgGK, string avgT1, string avgTotal)
  439. {
  440. var loclist = _DMS_IN_LOCDETAIL.Select(a => a.UPN == model);
  441. var lotList=loclist.Select(a => a.LOT).Distinct().ToList();
  442. decimal? hw = 0;
  443. decimal? gk = 0;
  444. decimal? t1 = 0;
  445. decimal? total = 0;
  446. lotList.ForEach(a =>
  447. {
  448. var itemHW = loclist.Where(x => x.LOT == a && x.DealerLevel == "LP" && x.DealerCode == "RQ000002").ToList();
  449. if(itemHW.Count>0)
  450. {
  451. hw += itemHW.OrderByDescending(y => y.InventoryDate).First().Qty;
  452. }
  453. var itemGK = loclist.Where(x => x.LOT == a && x.DealerLevel == "LP" && x.DealerCode == "RQ000005").ToList();
  454. if (itemGK.Count > 0)
  455. {
  456. gk += itemGK.OrderByDescending(y => y.InventoryDate).First().Qty;
  457. }
  458. var itemT1 = loclist.Where(x => x.LOT == a && (x.DealerLevel == "T1" || x.DealerLevel == "LS")).ToList();
  459. if (itemT1.Count > 0)
  460. {
  461. t1 += itemT1.OrderByDescending(y => y.InventoryDate).First().Qty;
  462. }
  463. });
  464. total=hw+gk+t1;
  465. if(avgHW!="0")
  466. {
  467. string numDecimalStr = (hw.Value / decimal.Parse(avgHW)).ToString("#0.00");
  468. hw = decimal.Parse(numDecimalStr);
  469. }else
  470. {
  471. hw = 0;
  472. }
  473. if (avgGK != "0")
  474. {
  475. string numDecimalStr = (hw.Value / decimal.Parse(avgGK)).ToString("#0.00");
  476. gk = decimal.Parse(numDecimalStr);
  477. }
  478. else
  479. {
  480. gk = 0;
  481. }
  482. if (avgT1 != "0")
  483. {
  484. string numDecimalStr = (hw.Value / decimal.Parse(avgT1)).ToString("#0.00");
  485. t1 = decimal.Parse(numDecimalStr);
  486. }
  487. else
  488. {
  489. t1 = 0;
  490. }
  491. if (avgTotal != "0")
  492. {
  493. string numDecimalStr = (hw.Value / decimal.Parse(avgTotal)).ToString("#0.00");
  494. total = decimal.Parse(numDecimalStr);
  495. }
  496. else
  497. {
  498. total = 0;
  499. }
  500. StringBuilder sb = new StringBuilder();
  501. sb.Append("{title: {text:'库存可供应周期(月)',left: 'center'},xAxis:{type:'category',data:['海王库存','国科库存','T1','Total']},yAxis:{type:'value'},series:[{data:[" + hw+","+gk+","+t1+","+total+"],type:'bar',label:{show:true,position:'top'},itemStyle:{normal:{color:function(params){if(params.value<4){return 'red';}else{return '#5470c6';}}}}}]}");
  502. return sb.ToString();
  503. }
  504. public string ChartLineOutStockOption(string factory_id, string model)
  505. {
  506. DateOnly dateOnly = DateOnly.FromDateTime(DateTime.Now.AddMonths(-14));
  507. var polist=_DMS_IN_PODETAIL.Select(a => a.UPN == model && a.OrderStatus != "Revoked" && a.OrderStatus != "Rejected" && a.SubmitDate>=dateOnly);
  508. StringBuilder sbDate = new StringBuilder();
  509. StringBuilder sbHWOutStock = new StringBuilder();
  510. StringBuilder sbGKOutStock = new StringBuilder();
  511. StringBuilder sbT1OutStock = new StringBuilder();
  512. StringBuilder sbTotalOutStock = new StringBuilder();
  513. for (int i=-14;i<1;i++)
  514. {
  515. sbDate.Append(string.Format("'{0}',",DateTime.Now.AddMonths(i).Date.ToString("yyyy-MM-dd")));
  516. var hw = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(i)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(i + 1)) && a.DealerCode== "RQ000002" && a.DealerLevel=="LP").Sum(a => a.RequiredQty);
  517. var gk = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(i)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(i + 1)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty);
  518. var t1 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(i)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(i + 1)) &&(a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty);
  519. var total = hw + gk + t1;
  520. sbHWOutStock.Append(string.Format("{0},", hw));
  521. sbGKOutStock.Append(string.Format("{0},", gk));
  522. sbT1OutStock.Append(string.Format("{0},", t1));
  523. sbTotalOutStock.Append(string.Format("{0},", total));
  524. }
  525. StringBuilder sb = new StringBuilder();
  526. sb.Append("{title: {text:'");
  527. sb.Append(model+"出货趋势',");
  528. sb.Append("left: 'center',},tooltip: {trigger: 'axis'},legend: {data:['海王', '国科', 'T1','Total'],bottom:-5,orient: 'horizontal'},grid: {left: '3%',right: '4%',bottom: '3%',containLabel: true},toolbox: {feature: {saveAsImage: {}}},xAxis:{type: 'category',boundaryGap: false,data:[");
  529. sb.Append(sbDate.ToString().TrimEnd(',')).
  530. Append("]},yAxis:{type:'value',},series:[{name:'海王',type:'line',stack: 'Total',data:[").
  531. Append(sbHWOutStock.ToString().TrimEnd(',')).
  532. Append("]},{name:'国科',type:'line',stack:'Total',data:[").
  533. Append(sbGKOutStock.ToString().TrimEnd(',')).
  534. Append("]},{name:'T1',type:'line',stack:'Total',data:[").
  535. Append(sbT1OutStock.ToString().TrimEnd(',')).
  536. Append("]},{name:'Total',type:'line',stack:'Total',data:[").
  537. Append(sbTotalOutStock.ToString().TrimEnd(',')).
  538. Append("]}]}");
  539. return sb.ToString();
  540. }
  541. public string ChartLineOutStock(string factory_id, string model)
  542. {
  543. DateOnly dateOnly = DateOnly.FromDateTime(DateTime.Now.AddMonths(-14));
  544. var polist = _DMS_IN_PODETAIL.Select(a => a.UPN == model && a.OrderStatus != "Revoked" && a.OrderStatus != "Rejected" && a.SubmitDate >= dateOnly);
  545. List<ModelMonthOutkDto> modelMonthOuts=new List<ModelMonthOutkDto>();
  546. ModelMonthOutkDto stockDto1 = new ModelMonthOutkDto();
  547. stockDto1.Month0 = "海王";
  548. stockDto1.Month1 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-14)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-13)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  549. stockDto1.Month2 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-13)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-12)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  550. stockDto1.Month3 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-12)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-11)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  551. stockDto1.Month4 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-11)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-10)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  552. stockDto1.Month5 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-10)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-9)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  553. stockDto1.Month6 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-9)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-8)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  554. stockDto1.Month7 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-8)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-7)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  555. stockDto1.Month8 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-7)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-6)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  556. stockDto1.Month9 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-6)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-5)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  557. stockDto1.Month10 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-5)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-4)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  558. stockDto1.Month11 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-4)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-3)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  559. stockDto1.Month12 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-3)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-2)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  560. stockDto1.Month13 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-2)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-1)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  561. stockDto1.Month14 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-1)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(0)) && a.DealerCode == "RQ000002" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  562. modelMonthOuts.Add(stockDto1);
  563. ModelMonthOutkDto stockDto2 = new ModelMonthOutkDto();
  564. stockDto2.Month0 = "国科";
  565. stockDto2.Month1 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-14)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-13)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value);
  566. stockDto2.Month2 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-13)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-12)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  567. stockDto2.Month3 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-12)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-11)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  568. stockDto2.Month4 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-11)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-10)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  569. stockDto2.Month5 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-10)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-9)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  570. stockDto2.Month6 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-9)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-8)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  571. stockDto2.Month7 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-8)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-7)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  572. stockDto2.Month8 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-7)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-6)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  573. stockDto2.Month9 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-6)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-5)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  574. stockDto2.Month10 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-5)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-4)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  575. stockDto2.Month11 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-4)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-3)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  576. stockDto2.Month12 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-3)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-2)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  577. stockDto2.Month13 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-2)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-1)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  578. stockDto2.Month14 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-1)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(0)) && a.DealerCode == "RQ000005" && a.DealerLevel == "LP").Sum(a => a.RequiredQty.Value); ;
  579. modelMonthOuts.Add(stockDto2);
  580. ModelMonthOutkDto stockDto3 = new ModelMonthOutkDto();
  581. stockDto3.Month0 = "T1";
  582. stockDto3.Month1 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-14)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-13)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value);
  583. stockDto3.Month2 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-13)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-12)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  584. stockDto3.Month3 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-12)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-11)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  585. stockDto3.Month4 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-11)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-10)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  586. stockDto3.Month5 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-10)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-9)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  587. stockDto3.Month6 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-9)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-8)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  588. stockDto3.Month7 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-8)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-7)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  589. stockDto3.Month8 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-7)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-6)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  590. stockDto3.Month9 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-6)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-5)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  591. stockDto3.Month10 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-5)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-4)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  592. stockDto3.Month11 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-4)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-3)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  593. stockDto3.Month12 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-3)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-2)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  594. stockDto3.Month13 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-2)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(-1)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  595. stockDto3.Month14 = polist.Where(a => a.SubmitDate >= DateOnly.FromDateTime(DateTime.Now.AddMonths(-1)) && a.SubmitDate < DateOnly.FromDateTime(DateTime.Now.AddMonths(0)) && (a.DealerLevel == "LP" || a.DealerLevel == "LS")).Sum(a => a.RequiredQty.Value); ;
  596. modelMonthOuts.Add(stockDto3);
  597. ModelMonthOutkDto stockDto4 = new ModelMonthOutkDto();
  598. stockDto4.Month0 = "Total";
  599. stockDto4.Month1 =stockDto1.Month1+stockDto2.Month1+stockDto3.Month1;
  600. stockDto4.Month2 = stockDto1.Month2 + stockDto2.Month2 + stockDto3.Month2;
  601. stockDto4.Month3 = stockDto1.Month3 + stockDto2.Month3 + stockDto3.Month3;
  602. stockDto4.Month4 = stockDto1.Month4 + stockDto2.Month4 + stockDto3.Month4;
  603. stockDto4.Month5 = stockDto1.Month5 + stockDto2.Month5 + stockDto3.Month5;
  604. stockDto4.Month6 = stockDto1.Month6 + stockDto2.Month6 + stockDto3.Month6;
  605. stockDto4.Month7 = stockDto1.Month7 + stockDto2.Month7 + stockDto3.Month7;
  606. stockDto4.Month8 = stockDto1.Month8 + stockDto2.Month8 + stockDto3.Month8;
  607. stockDto4.Month9 = stockDto1.Month9 + stockDto2.Month9 + stockDto3.Month9;
  608. stockDto4.Month10 = stockDto1.Month10 + stockDto2.Month10 + stockDto3.Month10;
  609. stockDto4.Month11 = stockDto1.Month11 + stockDto2.Month11 + stockDto3.Month11;
  610. stockDto4.Month12 = stockDto1.Month12 + stockDto2.Month12 + stockDto3.Month12;
  611. stockDto4.Month13 = stockDto1.Month13 + stockDto2.Month13 + stockDto3.Month13;
  612. stockDto4.Month14 = stockDto1.Month14 + stockDto2.Month14 + stockDto3.Month14;
  613. modelMonthOuts.Add(stockDto4);
  614. ModelMonthOutkDto stockDto5 = new ModelMonthOutkDto();
  615. stockDto5.Month0 = "海王均值";
  616. stockDto5.Month1 = decimal.Ceiling((stockDto1.Month12+stockDto1.Month13+stockDto1.Month14)/3);
  617. stockDto5.Month2 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  618. stockDto5.Month3 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  619. stockDto5.Month4 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  620. stockDto5.Month5 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  621. stockDto5.Month6 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  622. stockDto5.Month7 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  623. stockDto5.Month8 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  624. stockDto5.Month9 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  625. stockDto5.Month10 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  626. stockDto5.Month11 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  627. stockDto5.Month12 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  628. stockDto5.Month13 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  629. stockDto5.Month14 = decimal.Ceiling((stockDto1.Month12 + stockDto1.Month13 + stockDto1.Month14) / 3);
  630. modelMonthOuts.Add(stockDto5);
  631. ModelMonthOutkDto stockDto6 = new ModelMonthOutkDto();
  632. stockDto6.Month0 = "国科均值";
  633. stockDto6.Month1 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  634. stockDto6.Month2 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  635. stockDto6.Month3 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  636. stockDto6.Month4 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  637. stockDto6.Month5 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  638. stockDto6.Month6 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  639. stockDto6.Month7 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  640. stockDto6.Month8 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  641. stockDto6.Month9 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  642. stockDto6.Month10 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  643. stockDto6.Month11 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  644. stockDto6.Month12 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  645. stockDto6.Month13 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  646. stockDto6.Month14 = decimal.Ceiling((stockDto2.Month12 + stockDto2.Month13 + stockDto2.Month14) / 3);
  647. modelMonthOuts.Add(stockDto6);
  648. ModelMonthOutkDto stockDto7 = new ModelMonthOutkDto();
  649. stockDto7.Month0 = "T1均值";
  650. stockDto7.Month1 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  651. stockDto7.Month2 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  652. stockDto7.Month3 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  653. stockDto7.Month4 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  654. stockDto7.Month5 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  655. stockDto7.Month6 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  656. stockDto7.Month7 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  657. stockDto7.Month8 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  658. stockDto7.Month9 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  659. stockDto7.Month10 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  660. stockDto7.Month11 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  661. stockDto7.Month12 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  662. stockDto7.Month13 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  663. stockDto7.Month14 = decimal.Ceiling((stockDto3.Month12 + stockDto3.Month13 + stockDto3.Month14) / 3);
  664. modelMonthOuts.Add(stockDto7);
  665. ModelMonthOutkDto stockDto8 = new ModelMonthOutkDto();
  666. stockDto8.Month0 = "Total均值";
  667. stockDto8.Month1 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  668. stockDto8.Month2 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  669. stockDto8.Month3 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  670. stockDto8.Month4 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  671. stockDto8.Month5 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  672. stockDto8.Month6 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  673. stockDto8.Month7 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  674. stockDto8.Month8 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  675. stockDto8.Month9 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  676. stockDto8.Month10 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  677. stockDto8.Month11 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  678. stockDto8.Month12 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  679. stockDto8.Month13 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  680. stockDto8.Month14 = decimal.Ceiling((stockDto4.Month12 + stockDto4.Month13 + stockDto4.Month14) / 3);
  681. modelMonthOuts.Add(stockDto8);
  682. return JsonConvert.SerializeObject(modelMonthOuts);
  683. }
  684. /// <summary>
  685. ///
  686. /// </summary>
  687. /// <param name="factory_id"></param>
  688. /// <param name="isItemNum">统计维度:M物料、S系列</param>
  689. /// <param name="itemNumRange">统计范围:F工厂、G国科、H海王、A工厂+平台</param>
  690. /// <param name="itemNum">物料编码</param>
  691. /// <param name="groupBy">系列</param>
  692. /// <returns></returns>
  693. public string ForecastActual(string factory_id, string isItemNum, string itemNumRange, string itemNum, string groupBy)
  694. {
  695. string sql = $"exec [dbo].[pr_DOP_InventoryMonitoring]";
  696. var InventoryDto = _businessDbContext.InventoryDto.FromSqlRaw(sql).ToList();
  697. DateOnly dateOnly = DateOnly.FromDateTime(DateTime.Now.AddMonths(-2));
  698. var polist = _DMS_IN_PODETAIL.Select(a =>a.SubmitDate >= dateOnly && a.OrderStatus != "Revoked" && a.OrderStatus != "Rejected");
  699. var rqShip = _aSNBOLShipperDetail.Select(a => a.CreateTime >= DateTime.Now.AddMonths(-2) && a.Domain == factory_id);
  700. List<ForecastActualDto> modelMonthOuts = new List<ForecastActualDto>();
  701. string strMonth1 = DateTime.Now.AddMonths(-1).ToString("yyyy-MM");
  702. string strMonth2 = DateTime.Now.ToString("yyyy-MM");
  703. //按照物料统计
  704. if (isItemNum == "M")
  705. {
  706. switch (itemNumRange)
  707. {
  708. case "F":
  709. if(!string.IsNullOrEmpty(itemNum))
  710. {
  711. var shipPlan=_monthlyShipmentPlan.GetListAsync(a => a.SAPItemNumber == itemNum && (a.PlanMonth== strMonth1 || a.PlanMonth == strMonth2)
  712. && a.DistributionChannel == "瑞奇").Result;
  713. var itemDto = InventoryDto.Find(a => a.ItemNumber == itemNum);
  714. if(itemDto!=null)
  715. {
  716. ForecastActualDto forecastActualDto = new ForecastActualDto();
  717. forecastActualDto.ItemNum = itemNum;
  718. forecastActualDto.GroupBy = itemDto.Series;
  719. forecastActualDto.StockTurnOver = itemDto.GKMonthlyDemand + itemDto.HWMonthlyDemand==0?0:decimal.Ceiling((itemDto.GKInv+ itemDto.HWInv)/(itemDto.GKMonthlyDemand+ itemDto.HWMonthlyDemand));
  720. //月度发货计划找不到可以去月度发货计划历史表按照版本号找,暂不处理
  721. forecastActualDto.M1Plan = 0;
  722. forecastActualDto.M2Plan = 0;
  723. if (shipPlan.Any(a=> a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")))
  724. {
  725. forecastActualDto.M1Plan = shipPlan.Find(a=>a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")).Qty;
  726. }
  727. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")))
  728. {
  729. forecastActualDto.M2Plan = shipPlan.Find(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")).Qty;
  730. }
  731. forecastActualDto.M1Real = rqShip.Where(a=>a.ContainerItem==itemNum && a.CreateTime>=DateTime.Now.AddMonths(-2) && a.CreateTime < DateTime.Now.AddMonths(-1)).Sum(b=>b.QtyToShip.Value);
  732. forecastActualDto.M2Real = rqShip.Where(a => a.ContainerItem == itemNum && a.CreateTime >= DateTime.Now.AddMonths(-1) && a.CreateTime < DateTime.Now).Sum(b => b.QtyToShip.Value);
  733. forecastActualDto.M1Diff = (forecastActualDto.M1Plan == 0 || forecastActualDto.M1Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M1Real / forecastActualDto.M1Plan)}%";
  734. forecastActualDto.M2Diff = (forecastActualDto.M2Plan == 0 || forecastActualDto.M2Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M2Real / forecastActualDto.M2Plan)}%";
  735. modelMonthOuts.Add(forecastActualDto);
  736. }
  737. }else
  738. {
  739. var shipPlan = _monthlyShipmentPlan.GetListAsync(a => (a.PlanMonth == strMonth1 || a.PlanMonth == strMonth2)
  740. && a.DistributionChannel == "瑞奇").Result;
  741. var itemList = _itemMaster.Select(a =>a.ItemType == "RS50" && a.Domain==factory_id).Select(a=>a.ItemNum).Distinct().ToList();
  742. var shipItemList = shipPlan.Select(a => a.SAPItemNumber).Distinct().ToList();
  743. var intersection = itemList.Intersect(shipItemList).ToList();
  744. intersection.ForEach(x=>
  745. {
  746. var itemDto = InventoryDto.Find(a => a.ItemNumber == x);
  747. if (itemDto != null)
  748. {
  749. ForecastActualDto forecastActualDto = new ForecastActualDto();
  750. forecastActualDto.ItemNum = x;
  751. forecastActualDto.GroupBy = itemDto.Series;
  752. forecastActualDto.StockTurnOver = itemDto.GKMonthlyDemand + itemDto.HWMonthlyDemand == 0 ? 0 : decimal.Ceiling((itemDto.GKInv + itemDto.HWInv) / (itemDto.GKMonthlyDemand + itemDto.HWMonthlyDemand));
  753. //月度发货计划找不到可以去月度发货计划历史表按照版本号找,暂不处理
  754. forecastActualDto.M1Plan = 0;
  755. forecastActualDto.M2Plan = 0;
  756. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")))
  757. {
  758. forecastActualDto.M1Plan = shipPlan.Find(a => a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")).Qty;
  759. }
  760. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")))
  761. {
  762. forecastActualDto.M2Plan = shipPlan.Find(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")).Qty;
  763. }
  764. forecastActualDto.M1Real = rqShip.Where(a => a.ContainerItem == itemNum && a.CreateTime >= DateTime.Now.AddMonths(-2) && a.CreateTime < DateTime.Now.AddMonths(-1)).Sum(b => b.QtyToShip.Value);
  765. forecastActualDto.M2Real = rqShip.Where(a => a.ContainerItem == itemNum && a.CreateTime >= DateTime.Now.AddMonths(-1) && a.CreateTime < DateTime.Now).Sum(b => b.QtyToShip.Value);
  766. forecastActualDto.M1Diff = (forecastActualDto.M1Plan == 0 || forecastActualDto.M1Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M1Real / forecastActualDto.M1Plan)}%";
  767. forecastActualDto.M2Diff = (forecastActualDto.M2Plan == 0 || forecastActualDto.M2Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M2Real / forecastActualDto.M2Plan)}%";
  768. modelMonthOuts.Add(forecastActualDto);
  769. }
  770. });
  771. }
  772. break;
  773. case "G":
  774. case "H":
  775. string gkhw = itemNumRange == "G" ? "国科" : "海王";
  776. string gkhwcode = itemNumRange == "G" ? "RQ000005" : "RQ000002";
  777. if (!string.IsNullOrEmpty(itemNum))
  778. {
  779. var shipPlan = _monthlyShipmentPlan.GetListAsync(a => a.SAPItemNumber == itemNum && (a.PlanMonth == strMonth1 || a.PlanMonth == strMonth2) && a.DistributionChannel == gkhw).Result;
  780. var item = _DMS_IN_ITEMMAPPING.Select(a => a.CfnERPCode == itemNum);
  781. if (item != null && item.Count>0)
  782. {
  783. var itemDto = InventoryDto.Find(a => a.ItemNumber == itemNum);
  784. if (itemDto != null)
  785. {
  786. //表没有主键索引,用仓储查询很慢,改用这种方式
  787. string month1 = $"select '{itemNum}' AS ItemNum,UPN,SUM(Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] where UPN='{item[0].CfnCode}' and DealerLevel='T2' and ParentDealerCode='{gkhwcode}' and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-2).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' group by UPN";
  788. var month1Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month1).ToList();
  789. string month2 = $"select '{itemNum}' AS ItemNum,UPN,SUM(Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] where UPN='{item[0].CfnCode}' and DealerLevel='T2' and ParentDealerCode='{gkhwcode}' and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.ToString("yyyy-MM-dd")}' group by UPN";
  790. var month2Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month2).ToList();
  791. ForecastActualDto forecastActualDto = new ForecastActualDto();
  792. forecastActualDto.ItemNum = itemNum;
  793. forecastActualDto.GroupBy = itemDto.Series;
  794. forecastActualDto.StockTurnOver = itemDto.GKMonthlyDemand + itemDto.HWMonthlyDemand == 0 ? 0 : decimal.Ceiling((itemDto.GKInv + itemDto.HWInv) / (itemDto.GKMonthlyDemand + itemDto.HWMonthlyDemand));
  795. //月度发货计划找不到可以去月度发货计划历史表按照版本号找,暂不处理
  796. forecastActualDto.M1Plan = 0;
  797. forecastActualDto.M2Plan = 0;
  798. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")))
  799. {
  800. forecastActualDto.M1Plan = shipPlan.Find(a => a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")).Qty;
  801. }
  802. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")))
  803. {
  804. forecastActualDto.M2Plan = shipPlan.Find(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")).Qty;
  805. }
  806. forecastActualDto.M1Real = month1Qty.Sum(a => a.Qty);
  807. forecastActualDto.M2Real = month2Qty.Sum(a => a.Qty);
  808. forecastActualDto.M1Diff = (forecastActualDto.M1Plan == 0 || forecastActualDto.M1Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M1Real / forecastActualDto.M1Plan)}%";
  809. forecastActualDto.M2Diff = (forecastActualDto.M2Plan == 0 || forecastActualDto.M2Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M2Real / forecastActualDto.M2Plan)}%";
  810. modelMonthOuts.Add(forecastActualDto);
  811. }
  812. }
  813. }
  814. else
  815. {
  816. var shipPlan = _monthlyShipmentPlan.GetListAsync(a => (a.PlanMonth == strMonth1 || a.PlanMonth == strMonth2) && a.DistributionChannel == gkhw).Result;
  817. var itemList = _itemMaster.Select(a => a.ItemType == "RS50" && a.Domain == factory_id).Select(a => a.ItemNum).Distinct().ToList();
  818. string month1 = $"Select B.CfnERPCode AS ItemNum,A.UPN,SUM(A.Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] A Inner join [dbo].[DMS_IN_ITEMMAPPING] B on A.UPN=B.CfnCode where DealerLevel='T2' and ParentDealerCode='{gkhwcode}' and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-2).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' group by B.CfnERPCode,UPN";
  819. var month1Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month1).ToList();
  820. string month2 = $"Select B.CfnERPCode AS ItemNum,A.UPN,SUM(A.Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] A Inner join [dbo].[DMS_IN_ITEMMAPPING] B on A.UPN=B.CfnCode where DealerLevel='T2' and ParentDealerCode='{gkhwcode}' and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.ToString("yyyy-MM-dd")}' group by B.CfnERPCode,UPN";
  821. var month2Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month2).ToList();
  822. var shipItemList = shipPlan.Select(a => a.SAPItemNumber).Distinct().ToList();
  823. var intersection = itemList.Intersect(shipItemList).ToList();
  824. intersection.ForEach(x =>
  825. {
  826. var itemDto = InventoryDto.Find(a => a.ItemNumber == x);
  827. if (itemDto != null)
  828. {
  829. ForecastActualDto forecastActualDto = new ForecastActualDto();
  830. forecastActualDto.ItemNum = x;
  831. forecastActualDto.GroupBy = itemDto.Series;
  832. forecastActualDto.StockTurnOver = itemDto.GKMonthlyDemand + itemDto.HWMonthlyDemand == 0 ? 0 : decimal.Ceiling((itemDto.GKInv + itemDto.HWInv) / (itemDto.GKMonthlyDemand + itemDto.HWMonthlyDemand));
  833. //月度发货计划找不到可以去月度发货计划历史表按照版本号找,暂不处理
  834. forecastActualDto.M1Plan = 0;
  835. forecastActualDto.M2Plan = 0;
  836. if (shipPlan.Any(a => a.SAPItemNumber==x && a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")))
  837. {
  838. forecastActualDto.M1Plan = shipPlan.Find(a => a.SAPItemNumber == x && a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")).Qty;
  839. }
  840. if (shipPlan.Any(a => a.SAPItemNumber == x && a.PlanMonth == DateTime.Now.ToString("yyyy-MM")))
  841. {
  842. forecastActualDto.M2Plan = shipPlan.Find(a => a.SAPItemNumber == x && a.PlanMonth == DateTime.Now.ToString("yyyy-MM")).Qty;
  843. }
  844. forecastActualDto.M1Real = month1Qty.Where(a => a.ItemNum == x).Sum(a => a.Qty);
  845. forecastActualDto.M2Real = month2Qty.Where(a => a.ItemNum == x).Sum(a => a.Qty);
  846. forecastActualDto.M1Diff = (forecastActualDto.M1Plan == 0 || forecastActualDto.M1Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M1Real / forecastActualDto.M1Plan)}%";
  847. forecastActualDto.M2Diff = (forecastActualDto.M2Plan == 0 || forecastActualDto.M2Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M2Real / forecastActualDto.M2Plan)}%";
  848. modelMonthOuts.Add(forecastActualDto);
  849. }
  850. });
  851. }
  852. break;
  853. case "A":
  854. if (!string.IsNullOrEmpty(itemNum))
  855. {
  856. var shipPlan = _monthlyShipmentPlan.GetListAsync(a => a.SAPItemNumber == itemNum && (a.PlanMonth == strMonth1 || a.PlanMonth == strMonth2)).Result;
  857. var item = _DMS_IN_ITEMMAPPING.Select(a => a.CfnERPCode == itemNum);
  858. if (item != null && item.Count>0)
  859. {
  860. var itemDto = InventoryDto.Find(a => a.ItemNumber == itemNum);
  861. if (itemDto != null)
  862. {
  863. //表没有主键索引,用仓储查询很慢,改用这种方式
  864. string month1 = $"select '{itemNum}' AS ItemNum,UPN,SUM(Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] where UPN='{item[0].CfnCode}' and ((DealerLevel='T2' and (ParentDealerCode='RQ000005' or ParentDealerCode='RQ000002')) or (DealerLevel='T1' or DealerLevel='LS')) and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-2).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' group by UPN";
  865. var month1Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month1).ToList();
  866. string month2 = $"select '{itemNum}' AS ItemNum,UPN,SUM(Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] where UPN='{item[0].CfnCode}' and ((DealerLevel='T2' and (ParentDealerCode='RQ000005' or ParentDealerCode='RQ000002')) or (DealerLevel='T1' or DealerLevel='LS')) and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.ToString("yyyy-MM-dd")}' group by UPN";
  867. var month2Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month2).ToList();
  868. ForecastActualDto forecastActualDto = new ForecastActualDto();
  869. forecastActualDto.ItemNum = itemNum;
  870. forecastActualDto.GroupBy = itemDto.Series;
  871. forecastActualDto.StockTurnOver = itemDto.GKMonthlyDemand + itemDto.HWMonthlyDemand == 0 ? 0 : decimal.Ceiling((itemDto.GKInv + itemDto.HWInv) / (itemDto.GKMonthlyDemand + itemDto.HWMonthlyDemand));
  872. //月度发货计划找不到可以去月度发货计划历史表按照版本号找,暂不处理
  873. forecastActualDto.M1Plan = 0;
  874. forecastActualDto.M2Plan = 0;
  875. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")))
  876. {
  877. forecastActualDto.M1Plan = shipPlan.Find(a => a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")).Qty;
  878. }
  879. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")))
  880. {
  881. forecastActualDto.M2Plan = shipPlan.Find(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")).Qty;
  882. }
  883. forecastActualDto.M1Real = month1Qty.Sum(a => a.Qty);
  884. forecastActualDto.M2Real = month2Qty.Sum(a => a.Qty);
  885. forecastActualDto.M1Diff = (forecastActualDto.M1Plan == 0 || forecastActualDto.M1Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M1Real / forecastActualDto.M1Plan)}%";
  886. forecastActualDto.M2Diff = (forecastActualDto.M2Plan == 0 || forecastActualDto.M2Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M2Real / forecastActualDto.M2Plan)}%";
  887. modelMonthOuts.Add(forecastActualDto);
  888. }
  889. }
  890. }
  891. else
  892. {
  893. var shipPlan = _monthlyShipmentPlan.GetListAsync(a => (a.PlanMonth == strMonth1 || a.PlanMonth == strMonth2)).Result;
  894. var itemList = _itemMaster.Select(a => a.ItemType == "RS50" && a.Domain == factory_id).Select(a => a.ItemNum).Distinct().ToList();
  895. string month1 = $"Select B.CfnERPCode AS ItemNum,A.UPN,SUM(A.Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] A Inner join [dbo].[DMS_IN_ITEMMAPPING] B on A.UPN=B.CfnCode where ((DealerLevel='T2' and (ParentDealerCode='RQ000005' or ParentDealerCode='RQ000002')) or (DealerLevel='T1' or DealerLevel='LS')) and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-2).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' group by B.CfnERPCode,UPN";
  896. var month1Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month1).ToList();
  897. string month2 = $"Select B.CfnERPCode AS ItemNum,A.UPN,SUM(A.Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] A Inner join [dbo].[DMS_IN_ITEMMAPPING] B on A.UPN=B.CfnCode where ((DealerLevel='T2' and (ParentDealerCode='RQ000005' or ParentDealerCode='RQ000002')) or (DealerLevel='T1' or DealerLevel='LS')) and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.ToString("yyyy-MM-dd")}' group by B.CfnERPCode,UPN";
  898. var month2Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month2).ToList();
  899. var shipItemList = shipPlan.Select(a => a.SAPItemNumber).Distinct().ToList();
  900. var intersection = itemList.Intersect(shipItemList).ToList();
  901. intersection.ForEach(x =>
  902. {
  903. var itemDto = InventoryDto.Find(a => a.ItemNumber == x);
  904. if (itemDto != null)
  905. {
  906. ForecastActualDto forecastActualDto = new ForecastActualDto();
  907. forecastActualDto.ItemNum = x;
  908. forecastActualDto.GroupBy = itemDto.Series;
  909. forecastActualDto.StockTurnOver = itemDto.GKMonthlyDemand + itemDto.HWMonthlyDemand == 0 ? 0 : decimal.Ceiling((itemDto.GKInv + itemDto.HWInv) / (itemDto.GKMonthlyDemand + itemDto.HWMonthlyDemand));
  910. //月度发货计划找不到可以去月度发货计划历史表按照版本号找,暂不处理
  911. forecastActualDto.M1Plan = 0;
  912. forecastActualDto.M2Plan = 0;
  913. if (shipPlan.Any(a => a.SAPItemNumber == x && a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")))
  914. {
  915. forecastActualDto.M1Plan = shipPlan.Find(a => a.SAPItemNumber == x && a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")).Qty;
  916. }
  917. if (shipPlan.Any(a => a.SAPItemNumber == x && a.PlanMonth == DateTime.Now.ToString("yyyy-MM")))
  918. {
  919. forecastActualDto.M2Plan = shipPlan.Find(a => a.SAPItemNumber == x && a.PlanMonth == DateTime.Now.ToString("yyyy-MM")).Qty;
  920. }
  921. forecastActualDto.M1Real = month1Qty.Where(a => a.ItemNum == x).Sum(a => a.Qty);
  922. forecastActualDto.M2Real = month2Qty.Where(a => a.ItemNum == x).Sum(a => a.Qty);
  923. forecastActualDto.M1Diff = (forecastActualDto.M1Plan == 0 || forecastActualDto.M1Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M1Real / forecastActualDto.M1Plan)}%";
  924. forecastActualDto.M2Diff = (forecastActualDto.M2Plan == 0 || forecastActualDto.M2Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M2Real / forecastActualDto.M2Plan)}%";
  925. modelMonthOuts.Add(forecastActualDto);
  926. }
  927. });
  928. }
  929. break;
  930. default:
  931. break;
  932. }
  933. }else
  934. {
  935. switch (itemNumRange)
  936. {
  937. case "F":
  938. if (!string.IsNullOrEmpty(groupBy))
  939. {
  940. var shipPlan = _monthlyShipmentPlan.GetListAsync(a => a.ProdRange == groupBy && (a.PlanMonth == strMonth1 || a.PlanMonth == strMonth2) && a.DistributionChannel == "瑞奇").Result;
  941. var itemList=_itemMaster.Select(a => a.Series == groupBy && a.ItemType == "RS50").Select(b => b.ItemNum).Distinct().ToList();
  942. var itemDto = InventoryDto.Where(a => a.Series == groupBy && itemList.Contains(a.ItemNumber)).ToList();
  943. if (itemDto != null && itemDto.Count>0)
  944. {
  945. ForecastActualDto forecastActualDto = new ForecastActualDto();
  946. forecastActualDto.GroupBy =groupBy;
  947. decimal sumDemand = itemDto.Sum(a => a.GKMonthlyDemand + a.HWMonthlyDemand);
  948. decimal sumInv = itemDto.Sum(a => a.GKInv + a.HWInv);
  949. forecastActualDto.StockTurnOver = sumDemand == 0 ? 0 : decimal.Ceiling(sumInv / sumDemand);
  950. //月度发货计划找不到可以去月度发货计划历史表按照版本号找,暂不处理
  951. forecastActualDto.M1Plan = 0;
  952. forecastActualDto.M2Plan = 0;
  953. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM") && itemList.Contains(a.SAPItemNumber)))
  954. {
  955. forecastActualDto.M1Plan = shipPlan.Where(a => a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM") && itemList.Contains(a.SAPItemNumber)).Sum(x=>x.Qty);
  956. }
  957. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")))
  958. {
  959. forecastActualDto.M2Plan = shipPlan.Where(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM") && itemList.Contains(a.SAPItemNumber)).Sum(x=>x.Qty);
  960. }
  961. forecastActualDto.M1Real = rqShip.Where(a => itemList.Contains(a.ContainerItem) && a.CreateTime >= DateTime.Now.AddMonths(-2) && a.CreateTime < DateTime.Now.AddMonths(-1)).Sum(b => b.QtyToShip.Value);
  962. forecastActualDto.M2Real = rqShip.Where(a => itemList.ToList().Contains(a.ContainerItem) && a.CreateTime >= DateTime.Now.AddMonths(-1) && a.CreateTime < DateTime.Now).Sum(b => b.QtyToShip.Value);
  963. forecastActualDto.M1Diff = (forecastActualDto.M1Plan == 0 || forecastActualDto.M1Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M1Real / forecastActualDto.M1Plan)}%";
  964. forecastActualDto.M2Diff = (forecastActualDto.M2Plan == 0 || forecastActualDto.M2Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M2Real / forecastActualDto.M2Plan)}%";
  965. modelMonthOuts.Add(forecastActualDto);
  966. }
  967. }
  968. else
  969. {
  970. var shipPlan = _monthlyShipmentPlan.GetListAsync(a => (a.PlanMonth == strMonth1 || a.PlanMonth == strMonth2)&& a.DistributionChannel == "瑞奇").Result;
  971. var itemSeriesList = _itemMaster.Select(a =>a.ItemType == "RS50");
  972. var shipSeriesList = shipPlan.Select(a => a.ProdRange).Distinct().ToList();
  973. var ItemSeriesList = itemSeriesList.Select(a => a.Series).Distinct().ToList();
  974. var intersection = ItemSeriesList.Intersect(shipSeriesList).ToList();
  975. intersection.ForEach(x =>
  976. {
  977. var itemDto = InventoryDto.Where(a => a.Series == x).ToList();
  978. var itemNumList= itemSeriesList.Where(a=>a.Series==x).Select(a=>a.ItemNum).Distinct().ToList();
  979. if (itemDto != null && itemDto.Count > 0)
  980. {
  981. ForecastActualDto forecastActualDto = new ForecastActualDto();
  982. forecastActualDto.GroupBy =x;
  983. decimal sumDemand = itemDto.Sum(a => a.GKMonthlyDemand + a.HWMonthlyDemand);
  984. decimal sumInv = itemDto.Sum(a => a.GKInv + a.HWInv);
  985. forecastActualDto.StockTurnOver = sumDemand == 0 ? 0 : decimal.Ceiling(sumInv / sumDemand);
  986. //月度发货计划找不到可以去月度发货计划历史表按照版本号找,暂不处理
  987. forecastActualDto.M1Plan = 0;
  988. forecastActualDto.M2Plan = 0;
  989. if (shipPlan.Any(a => itemNumList.Contains(a.SAPItemNumber) && a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")))
  990. {
  991. forecastActualDto.M1Plan = shipPlan.Find(a => itemNumList.Contains(a.SAPItemNumber) && a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")).Qty;
  992. }
  993. if (shipPlan.Any(a => itemNumList.Contains(a.SAPItemNumber) && a.PlanMonth == DateTime.Now.ToString("yyyy-MM")))
  994. {
  995. forecastActualDto.M2Plan = shipPlan.Find(a => itemNumList.Contains(a.SAPItemNumber) && a.PlanMonth == DateTime.Now.ToString("yyyy-MM")).Qty;
  996. }
  997. forecastActualDto.M1Real = rqShip.Where(a => itemNumList.Contains(a.ContainerItem) && a.CreateTime >= DateTime.Now.AddMonths(-2) && a.CreateTime < DateTime.Now.AddMonths(-1)).Sum(b => b.QtyToShip.Value);
  998. forecastActualDto.M2Real = rqShip.Where(a => itemNumList.Contains(a.ContainerItem) && a.CreateTime >= DateTime.Now.AddMonths(-1) && a.CreateTime < DateTime.Now).Sum(b => b.QtyToShip.Value);
  999. forecastActualDto.M1Diff = (forecastActualDto.M1Plan == 0 || forecastActualDto.M1Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M1Real / forecastActualDto.M1Plan)}%";
  1000. forecastActualDto.M2Diff = (forecastActualDto.M2Plan == 0 || forecastActualDto.M2Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M2Real / forecastActualDto.M2Plan)}%";
  1001. modelMonthOuts.Add(forecastActualDto);
  1002. }
  1003. });
  1004. }
  1005. break;
  1006. case "G":
  1007. case "H":
  1008. string gkhw = itemNumRange == "G" ? "国科" : "海王";
  1009. string gkhwcode = itemNumRange == "G" ? "RQ000005" : "RQ000002";
  1010. if (!string.IsNullOrEmpty(groupBy))
  1011. {
  1012. var shipPlan = _monthlyShipmentPlan.GetListAsync(a => a.ProdRange == groupBy && (a.PlanMonth == strMonth1 || a.PlanMonth == strMonth2) && a.DistributionChannel == gkhw).Result;
  1013. var itemList = _itemMaster.Select(a => a.Series == groupBy && a.ItemType == "RS50").Distinct().ToList();
  1014. var item = _DMS_IN_ITEMMAPPING.Select(a => itemList.Select(a => a.ItemNum).ToList().Contains(a.CfnERPCode));
  1015. string result = string.Join("','", item.Select(a=>a.CfnCode).Distinct().ToList());
  1016. if (item != null)
  1017. {
  1018. var itemDto = InventoryDto.Where(a =>a.Series==groupBy).ToList();
  1019. if (itemDto != null && itemDto.Count > 0)
  1020. {
  1021. //表没有主键索引,用仓储查询很慢,改用这种方式
  1022. string month1 = $"select B.CfnERPCode AS ItemNum,UPN,SUM(Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] A Inner join [dbo].[DMS_IN_ITEMMAPPING] B on A.UPN=B.CfnCode and UPN in('{result}') and DealerLevel='T2' and ParentDealerCode='{gkhwcode}' and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-2).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' group by B.CfnERPCode,UPN";
  1023. var month1Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month1).ToList();
  1024. string month2 = $"select B.CfnERPCode AS ItemNum,UPN,SUM(Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] A Inner join [dbo].[DMS_IN_ITEMMAPPING] B on A.UPN=B.CfnCode and UPN in('{result}') and DealerLevel='T2' and ParentDealerCode='{gkhwcode}' and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.ToString("yyyy-MM-dd")}' group by B.CfnERPCode,UPN";
  1025. var month2Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month2).ToList();
  1026. ForecastActualDto forecastActualDto = new ForecastActualDto();
  1027. forecastActualDto.GroupBy = groupBy;
  1028. decimal sumDemand = itemDto.Sum(a => a.GKMonthlyDemand + a.HWMonthlyDemand);
  1029. decimal sumInv = itemDto.Sum(a => a.GKInv + a.HWInv);
  1030. forecastActualDto.StockTurnOver = sumDemand == 0 ? 0 : decimal.Ceiling(sumInv / sumDemand);
  1031. //月度发货计划找不到可以去月度发货计划历史表按照版本号找,暂不处理
  1032. forecastActualDto.M1Plan = 0;
  1033. forecastActualDto.M2Plan = 0;
  1034. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")))
  1035. {
  1036. forecastActualDto.M1Plan = shipPlan.Find(a => a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")).Qty;
  1037. }
  1038. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")))
  1039. {
  1040. forecastActualDto.M2Plan = shipPlan.Find(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")).Qty;
  1041. }
  1042. forecastActualDto.M1Real = month1Qty.Sum(a => a.Qty);
  1043. forecastActualDto.M2Real = month2Qty.Sum(a => a.Qty);
  1044. forecastActualDto.M1Diff = (forecastActualDto.M1Plan == 0 || forecastActualDto.M1Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M1Real / forecastActualDto.M1Plan)}%";
  1045. forecastActualDto.M2Diff = (forecastActualDto.M2Plan == 0 || forecastActualDto.M2Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M2Real / forecastActualDto.M2Plan)}%";
  1046. modelMonthOuts.Add(forecastActualDto);
  1047. }
  1048. }
  1049. }
  1050. else
  1051. {
  1052. var shipPlan = _monthlyShipmentPlan.GetListAsync(a => (a.PlanMonth == strMonth1 || a.PlanMonth == strMonth2)&& a.DistributionChannel == gkhw).Result;
  1053. string month1 = $"select B.CfnERPCode AS ItemNum,A.UPN,SUM(A.Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] A Inner join [dbo].[DMS_IN_ITEMMAPPING] B on A.UPN=B.CfnCode where DealerLevel='T2' and ParentDealerCode='{gkhwcode}' and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-2).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' group by B.CfnERPCode,UPN";
  1054. var month1Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month1).ToList();
  1055. string month2 = $"select B.CfnERPCode AS ItemNum,A.UPN,SUM(A.Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] A Inner join [dbo].[DMS_IN_ITEMMAPPING] B on A.UPN=B.CfnCode where DealerLevel='T2' and ParentDealerCode='{gkhwcode}' and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.ToString("yyyy-MM-dd")}' group by B.CfnERPCode,UPN";
  1056. var month2Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month2).ToList();
  1057. var itemList = _itemMaster.Select(a =>a.ItemType == "RS50").Distinct().ToList();
  1058. var item = _DMS_IN_ITEMMAPPING.Select(a => itemList.Select(a => a.ItemNum).ToList().Contains(a.CfnERPCode));
  1059. string result = string.Join("','", item.Select(a => a.CfnCode).Distinct().ToList());
  1060. var seriesList=itemList.Select(a => a.Series).Distinct().ToList();
  1061. seriesList.ForEach(x =>
  1062. {
  1063. var itemDto = InventoryDto.Where(a => a.Series == x).ToList();
  1064. if (itemDto != null && itemDto.Count > 0)
  1065. {
  1066. ForecastActualDto forecastActualDto = new ForecastActualDto();
  1067. forecastActualDto.GroupBy = x;
  1068. decimal sumDemand = itemDto.Sum(a => a.GKMonthlyDemand + a.HWMonthlyDemand);
  1069. decimal sumInv = itemDto.Sum(a => a.GKInv + a.HWInv);
  1070. forecastActualDto.StockTurnOver = sumDemand == 0 ? 0 : decimal.Ceiling(sumInv / sumDemand);
  1071. //月度发货计划找不到可以去月度发货计划历史表按照版本号找,暂不处理
  1072. forecastActualDto.M1Plan = 0;
  1073. forecastActualDto.M2Plan = 0;
  1074. if (shipPlan.Any(a => a.ProdRange == x && a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")))
  1075. {
  1076. forecastActualDto.M1Plan = shipPlan.Where(a => a.ProdRange == x && a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")).Sum(q=>q.Qty);
  1077. }
  1078. if (shipPlan.Any(a => a.SAPItemNumber == x && a.PlanMonth == DateTime.Now.ToString("yyyy-MM")))
  1079. {
  1080. forecastActualDto.M2Plan = shipPlan.Where(a => a.ProdRange == x && a.PlanMonth == DateTime.Now.ToString("yyyy-MM")).Sum(q => q.Qty);
  1081. }
  1082. List<string> seriesItemnum = new List<string>();
  1083. seriesItemnum.AddRange(itemList.Where(a => a.Series == x).Select(a => a.ItemNum).Distinct());
  1084. forecastActualDto.M1Real = month1Qty.Where(a => seriesItemnum.Contains(a.ItemNum)).Sum(a => a.Qty);
  1085. forecastActualDto.M2Real = month2Qty.Where(a => seriesItemnum.Contains(a.ItemNum)).Sum(a => a.Qty);
  1086. forecastActualDto.M1Diff = (forecastActualDto.M1Plan == 0 || forecastActualDto.M1Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M1Real / forecastActualDto.M1Plan)}%";
  1087. forecastActualDto.M2Diff = (forecastActualDto.M2Plan == 0 || forecastActualDto.M2Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M2Real / forecastActualDto.M2Plan)}%";
  1088. modelMonthOuts.Add(forecastActualDto);
  1089. }
  1090. });
  1091. }
  1092. break;
  1093. case "A":
  1094. if (!string.IsNullOrEmpty(groupBy))
  1095. {
  1096. var shipPlan = _monthlyShipmentPlan.GetListAsync(a => a.ProdRange == groupBy && (a.PlanMonth == strMonth1 || a.PlanMonth == strMonth2)).Result;
  1097. var itemList = _itemMaster.Select(a => a.Series == groupBy && a.ItemType == "RS50").Distinct().ToList();
  1098. var item = _DMS_IN_ITEMMAPPING.Select(a => itemList.Select(a => a.ItemNum).ToList().Contains(a.CfnERPCode));
  1099. string result = string.Join("','", item.Select(a => a.CfnCode).Distinct().ToList());
  1100. if (item != null)
  1101. {
  1102. var itemDto = InventoryDto.Where(a => a.Series == groupBy).ToList();
  1103. if (itemDto != null && itemDto.Count > 0)
  1104. {
  1105. //表没有主键索引,用仓储查询很慢,改用这种方式
  1106. string month1 = $"select B.CfnERPCode AS ItemNum,UPN,SUM(Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] A Inner join [dbo].[DMS_IN_ITEMMAPPING] B on A.UPN=B.CfnCode and UPN='{item[0].CfnCode}' and ((DealerLevel='T2' and (ParentDealerCode='RQ000005' or ParentDealerCode='RQ000002')) or (DealerLevel='T1' or DealerLevel='LS')) and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-2).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' group by B.CfnERPCode,UPN";
  1107. var month1Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month1).ToList();
  1108. string month2 = $"select B.CfnERPCode AS ItemNum,UPN,SUM(Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] A Inner join [dbo].[DMS_IN_ITEMMAPPING] B on A.UPN=B.CfnCode and UPN='{item[0].CfnCode}' and ((DealerLevel='T2' and (ParentDealerCode='RQ000005' or ParentDealerCode='RQ000002')) or (DealerLevel='T1' or DealerLevel='LS')) and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.ToString("yyyy-MM-dd")}' group by B.CfnERPCode,UPN";
  1109. var month2Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month2).ToList();
  1110. ForecastActualDto forecastActualDto = new ForecastActualDto();
  1111. forecastActualDto.GroupBy = groupBy;
  1112. decimal sumDemand = itemDto.Sum(a => a.GKMonthlyDemand + a.HWMonthlyDemand);
  1113. decimal sumInv = itemDto.Sum(a => a.GKInv + a.HWInv);
  1114. forecastActualDto.StockTurnOver = sumDemand == 0 ? 0 : decimal.Ceiling(sumInv / sumDemand);
  1115. //月度发货计划找不到可以去月度发货计划历史表按照版本号找,暂不处理
  1116. forecastActualDto.M1Plan = 0;
  1117. forecastActualDto.M2Plan = 0;
  1118. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")))
  1119. {
  1120. forecastActualDto.M1Plan = shipPlan.Find(a => a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")).Qty;
  1121. }
  1122. if (shipPlan.Any(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")))
  1123. {
  1124. forecastActualDto.M2Plan = shipPlan.Find(a => a.PlanMonth == DateTime.Now.ToString("yyyy-MM")).Qty;
  1125. }
  1126. forecastActualDto.M1Real = month1Qty.Sum(a => a.Qty);
  1127. forecastActualDto.M2Real = month2Qty.Sum(a => a.Qty);
  1128. forecastActualDto.M1Diff = (forecastActualDto.M1Plan == 0 || forecastActualDto.M1Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M1Real / forecastActualDto.M1Plan)}%";
  1129. forecastActualDto.M2Diff = (forecastActualDto.M2Plan == 0 || forecastActualDto.M2Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M2Real / forecastActualDto.M2Plan)}%";
  1130. modelMonthOuts.Add(forecastActualDto);
  1131. }
  1132. }
  1133. }
  1134. else
  1135. {
  1136. var shipPlan = _monthlyShipmentPlan.GetListAsync(a => (a.PlanMonth == strMonth1 || a.PlanMonth == strMonth2)).Result;
  1137. string month1 = $"select B.CfnERPCode AS ItemNum,A.UPN,SUM(A.Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] A Inner join [dbo].[DMS_IN_ITEMMAPPING] B on A.UPN=B.CfnCode where ((DealerLevel='T2' and (ParentDealerCode='RQ000005' or ParentDealerCode='RQ000002')) or (DealerLevel='T1' or DealerLevel='LS')) and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-2).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' group by B.CfnERPCode,UPN";
  1138. var month1Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month1).ToList();
  1139. string month2 = $"select B.CfnERPCode AS ItemNum,A.UPN,SUM(A.Qty) AS Qty from [dbo].[DMS_IN_SHIPPINGDETAIL] A Inner join [dbo].[DMS_IN_ITEMMAPPING] B on A.UPN=B.CfnCode where ((DealerLevel='T2' and (ParentDealerCode='RQ000005' or ParentDealerCode='RQ000002')) or (DealerLevel='T1' or DealerLevel='LS')) and Status !='Revoked' and Status !='Rejected' and ShipmentDate>='{DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd")}' and ShipmentDate<'{DateTime.Now.ToString("yyyy-MM-dd")}' group by B.CfnERPCode,UPN";
  1140. var month2Qty = _businessExtRADbContext.DMSShippingDetailDto.FromSqlRaw(month2).ToList();
  1141. var itemList = _itemMaster.Select(a =>a.ItemType == "RS50").Distinct().ToList();
  1142. var item = _DMS_IN_ITEMMAPPING.Select(a => itemList.Select(a => a.ItemNum).ToList().Contains(a.CfnERPCode));
  1143. string result = string.Join("','", item.Select(a => a.CfnCode).Distinct().ToList());
  1144. var seriesList = itemList.Select(a => a.Series).Distinct().ToList();
  1145. seriesList.ForEach(x =>
  1146. {
  1147. var itemDto = InventoryDto.Where(a => a.Series == x).ToList();
  1148. if (itemDto != null && itemDto.Count > 0)
  1149. {
  1150. ForecastActualDto forecastActualDto = new ForecastActualDto();
  1151. forecastActualDto.GroupBy = x;
  1152. decimal sumDemand = itemDto.Sum(a => a.GKMonthlyDemand + a.HWMonthlyDemand);
  1153. decimal sumInv = itemDto.Sum(a => a.GKInv + a.HWInv);
  1154. forecastActualDto.StockTurnOver = sumDemand == 0 ? 0 : decimal.Ceiling(sumInv / sumDemand);
  1155. //月度发货计划找不到可以去月度发货计划历史表按照版本号找,暂不处理
  1156. forecastActualDto.M1Plan = 0;
  1157. forecastActualDto.M2Plan = 0;
  1158. if (shipPlan.Any(a => a.ProdRange == x && a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")))
  1159. {
  1160. forecastActualDto.M1Plan = shipPlan.Where(a => a.ProdRange == x && a.PlanMonth == DateTime.Now.AddMonths(-1).ToString("yyyy-MM")).Sum(q => q.Qty);
  1161. }
  1162. if (shipPlan.Any(a => a.SAPItemNumber == x && a.PlanMonth == DateTime.Now.ToString("yyyy-MM")))
  1163. {
  1164. forecastActualDto.M2Plan = shipPlan.Where(a => a.ProdRange == x && a.PlanMonth == DateTime.Now.ToString("yyyy-MM")).Sum(q => q.Qty);
  1165. }
  1166. List<string> seriesItemnum = new List<string>();
  1167. seriesItemnum.AddRange(itemList.Where(a => a.Series == x).Select(a => a.ItemNum).Distinct());
  1168. forecastActualDto.M1Real = month1Qty.Where(a => seriesItemnum.Contains(a.ItemNum)).Sum(a => a.Qty);
  1169. forecastActualDto.M2Real = month2Qty.Where(a => seriesItemnum.Contains(a.ItemNum)).Sum(a => a.Qty);
  1170. forecastActualDto.M1Diff = (forecastActualDto.M1Plan == 0 || forecastActualDto.M1Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M1Real / forecastActualDto.M1Plan)}%";
  1171. forecastActualDto.M2Diff = (forecastActualDto.M2Plan == 0 || forecastActualDto.M2Real == 0) ? "100%" : $"{decimal.Ceiling(forecastActualDto.M2Real / forecastActualDto.M2Plan)}%";
  1172. modelMonthOuts.Add(forecastActualDto);
  1173. }
  1174. });
  1175. }
  1176. break;
  1177. default:
  1178. break;
  1179. }
  1180. }
  1181. return JsonConvert.SerializeObject(modelMonthOuts);
  1182. }
  1183. /// <summary>
  1184. /// 从当前日期往前倒推进出存,最小默认取到2024-01-01,定时任务建议选择每天晚上9点-12点之间
  1185. /// </summary>
  1186. /// <param name="domain"></param>
  1187. /// <returns></returns>
  1188. public string CalcInvDayHist(string domain)
  1189. {
  1190. //取物料已计算进出存的最新日期
  1191. string sqlMaxHistDayTime = $"select t1.* from InvTransHistDay t1 inner join (SELECT max(HistDayTime) as HistDayTime, ItemNum FROM InvTransHistDay where Domain='{domain}' group by ItemNum) t2 on t1.HistDayTime=t2.HistDayTime and t1.ItemNum=t2.ItemNum and t1.Domain='{domain}'";
  1192. var HistMaxTimeDayDto = _businessDbContext.InvTransHistDay.FromSqlRaw(sqlMaxHistDayTime).ToList();
  1193. string sqlHistDetail = $"select A.ItemNum,Loc,LotSerial,BeginBalance,case when a.QtyChange>0 then a.QtyChange else 0 end as QtyChangeAdvance,case when a.QtyChange<0 then abs(a.QtyChange) else 0 end as QtyChangeOut,BeginBalance+QtyChange as BalanceNum,createTime from InvTransHist A where Domain='{domain}' and CreateTime>='2024-01-01'";
  1194. if (HistMaxTimeDayDto.Count>0)
  1195. {
  1196. sqlHistDetail = $"select A.ItemNum,Loc,LotSerial,BeginBalance,case when a.QtyChange>0 then a.QtyChange else 0 end as QtyChangeAdvance,case when a.QtyChange<0 then abs(a.QtyChange) else 0 end as QtyChangeOut,BeginBalance+QtyChange as BalanceNum,createTime from InvTransHist A where Domain='{domain}' and CreateTime>='{HistMaxTimeDayDto[0].HistDayTime}'";
  1197. }
  1198. //取物料进出存明细
  1199. var HistDetailDto = _businessDbContext.InvTransHistDetailDto.FromSqlRaw(sqlHistDetail).ToList();
  1200. //取物料实时库存
  1201. string sql = $"exec [dbo].[pr_WMS_GetMissedLocationQty]";
  1202. var LocationQtyDto = _businessDbContext.LocationQtyDto.FromSqlRaw(sql).ToList();
  1203. ////取出物料库位批次的最新一条记录用于计算期末库存(由于可能出现最大进出存时间一模一样的两笔业务,需要汇总)
  1204. //string lastDetail = $"select a.ItemNum,a.Loc,a.LotSerial,0.00000 AS BeginBalance,Sum(case when a.QtyChange>0 then a.QtyChange else 0 end) as QtyChangeAdvance,Sum(case when a.QtyChange<0 then abs(a.QtyChange) else 0 end) as QtyChangeOut,Sum(BeginBalance+QtyChange) as BalanceNum,GETDATE() AS CreateTime from InvTransHist a inner join(select ItemNum,Loc,LotSerial,MAX(CreateTime) AS CreateTime from InvTransHist group by ItemNum,Loc,LotSerial) b on a.ItemNum=b.ItemNum and a.Loc=b.Loc and a.LotSerial=b.LotSerial and a.CreateTime=b.CreateTime and a.Domain='{domain}' group by a.ItemNum,a.Loc,a.LotSerial order by a.ItemNum,a.Loc,a.LotSerial";
  1205. //var lastDetailDto = _businessDbContext.InvTransHistDetailDto.FromSqlRaw(lastDetail).ToList();
  1206. //取出所有有进出存记录的物料
  1207. string sqlItemList = $"select distinct ItemNum from InvTransHist where Domain='{domain}' and CreateTime>='2024-01-01' group by ItemNum";
  1208. var QtyChangeDto = _businessDbContext.QtyChangeDto.FromSqlRaw(sqlItemList).ToList();
  1209. List<InvTransHistDay> daysHist = new List<InvTransHistDay>();
  1210. QtyChangeDto?.ForEach(x =>
  1211. {
  1212. DateTime dtMin = new DateTime(2024, 1, 1);
  1213. if (HistMaxTimeDayDto.Any(a => a.ItemNum == x.ItemNum))
  1214. {
  1215. dtMin = HistMaxTimeDayDto.Find(a => a.ItemNum == x.ItemNum).HistDayTime;
  1216. }
  1217. //物料期末总库存
  1218. var xBalanceNum = LocationQtyDto.Where(a => a.ItemNum == x.ItemNum).Sum(a => a.AvailStatusQty);
  1219. var xMaxDay = DateTime.Now;
  1220. int day = 0;
  1221. while (true)
  1222. {
  1223. if (xMaxDay.AddDays(day).Date < dtMin)
  1224. break;
  1225. InvTransHistDay invTransHistDay = new InvTransHistDay();
  1226. invTransHistDay.Domain = domain;
  1227. invTransHistDay.ItemNum = x.ItemNum;
  1228. invTransHistDay.HistDayTime = xMaxDay.AddDays(day).Date;
  1229. var xQtyChangeAdvance = HistDetailDto.Where(a => a.ItemNum == x.ItemNum && a.CreateTime.Date == xMaxDay.AddDays(day).Date).Sum(a => a.QtyChangeAdvance);
  1230. var xQtyChangeOut = HistDetailDto.Where(a => a.ItemNum == x.ItemNum && a.CreateTime.Date == xMaxDay.AddDays(day).Date).Sum(a => a.QtyChangeOut);
  1231. invTransHistDay.QtyChangeAdvance = xQtyChangeAdvance;
  1232. invTransHistDay.QtyChangeOut = xQtyChangeOut;
  1233. if (day == 0)
  1234. {
  1235. invTransHistDay.BalanceNum = xBalanceNum;
  1236. invTransHistDay.BeginBalance = xBalanceNum + xQtyChangeOut - xQtyChangeAdvance;
  1237. }
  1238. else
  1239. {
  1240. var nextDayQty = daysHist.Find(a => a.HistDayTime == xMaxDay.AddDays(day + 1).Date && a.ItemNum == x.ItemNum);
  1241. //倒推期初数
  1242. invTransHistDay.BalanceNum = nextDayQty.BeginBalance;
  1243. invTransHistDay.BeginBalance = nextDayQty.BeginBalance + xQtyChangeOut - xQtyChangeAdvance;
  1244. }
  1245. daysHist.Add(invTransHistDay);
  1246. day--;
  1247. }
  1248. });
  1249. _businessDbContext.AddRange(daysHist); _businessDbContext.SaveChanges();
  1250. return "ok";
  1251. }
  1252. }
  1253. }