CalcBomViewAppService.cs 67 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348
  1. using Business.Core.Enum;
  2. using Business.Core.Utilities;
  3. using Business.Model.Production;
  4. using Business.Model.Sale;
  5. using Business.Model.SRM;
  6. using Business.MongoModel.MES.IC;
  7. using Business.MongoModel.Production;
  8. using Business.MongoModel.SRM;
  9. using Business.MongoModel.Tech;
  10. using Business.ResourceExamineManagement.Dto;
  11. using MongoDB.Driver.Linq;
  12. using System;
  13. using System.Collections;
  14. using System.Collections.Generic;
  15. using System.Globalization;
  16. using System.Linq;
  17. using Volo.Abp.Application.Services;
  18. using static Spire.Pdf.General.Render.Decode.Jpeg2000.j2k.codestream.HeaderInfo;
  19. namespace Business.ResourceExamineManagement
  20. {
  21. public class CalcBomViewAppService : ApplicationService
  22. {
  23. /// <summary>
  24. /// 资源检查入参
  25. /// </summary>
  26. public SeorderentryDto param = new SeorderentryDto();
  27. public List<mo_ic_plan> planList { get; set; }
  28. public List<ICItemLeadTimeDto> leadTimeList = new List<ICItemLeadTimeDto>();
  29. public List<mo_srm_purchase> supplierList = new List<mo_srm_purchase>();
  30. public List<SRMPRDto> SRMPRDtoList = new List<SRMPRDto>();
  31. public List<mo_mes_oorder> orderList = new List<mo_mes_oorder>();
  32. public List<mo_mes_morder> mordersList = new List<mo_mes_morder>();
  33. public List<mo_mes_morder> mordersInsertList = new List<mo_mes_morder>();
  34. public List<mo_mes_moentry> moentriesList = new List<mo_mes_moentry>();
  35. public List<mo_mes_moentry> moentriesInsertList = new List<mo_mes_moentry>();
  36. public List<mo_mes_mooccupy> mooccupyAllList = new List<mo_mes_mooccupy>();
  37. public List<mo_mes_mooccupy> mooccupyAllInsertList = new List<mo_mes_mooccupy>();
  38. public List<mo_srm_po_list> srm_Po_Lists = new List<mo_srm_po_list>();
  39. public List<mo_srm_po_occupy> srm_Po_Occupies = new List<mo_srm_po_occupy>();
  40. public List<mo_srm_po_occupy> srm_Po_OccupiesInsert = new List<mo_srm_po_occupy>();
  41. public crm_seorder seorder = new crm_seorder();
  42. SnowFlake help = new SnowFlake();
  43. /// <summary>
  44. /// 生产线明细表
  45. /// </summary>
  46. public List<ProdLineDetail> prodLines = new List<ProdLineDetail>();
  47. /// <summary>
  48. /// 标准工艺路径表
  49. /// </summary>
  50. public List<RoutingOpDetail> routingOps = new List<RoutingOpDetail>();
  51. /// <summary>
  52. /// 排产记录表
  53. /// </summary>
  54. public List<PeriodSequenceDet> periodSequences = new List<PeriodSequenceDet>();
  55. /// <summary>
  56. /// 工作日历
  57. /// </summary>
  58. public List<ShopCalendarWorkCtr> calendarWorks = new List<ShopCalendarWorkCtr>();
  59. /// <summary>
  60. /// 休息时间段
  61. /// </summary>
  62. public List<QualityLineWorkDetail> qualityLineWorks = new List<QualityLineWorkDetail>();
  63. /// <summary>
  64. /// 节假日
  65. /// </summary>
  66. public List<HolidayMaster> holidays = new List<HolidayMaster>();
  67. /// <summary>
  68. /// 工单App
  69. /// </summary>
  70. private readonly MorderAppService _morderAppService;
  71. /// <summary>
  72. /// 产能检查
  73. /// </summary>
  74. private readonly ProductExamineAppService _productExamineAppService;
  75. /// <summary>
  76. /// 在途检查
  77. /// </summary>
  78. private readonly PurchaseOrderAppService _purchaseOrderAppService;
  79. Random rnd = new Random();
  80. public decimal ProductionTimeDay;
  81. /// <summary>
  82. /// 构造函数
  83. /// </summary>
  84. /// <param name="morderAppService"></param>
  85. public CalcBomViewAppService(MorderAppService morderAppService,
  86. ProductExamineAppService productExamineAppService,
  87. PurchaseOrderAppService purchaseOrderAppService)
  88. {
  89. _morderAppService = morderAppService;
  90. _productExamineAppService = productExamineAppService;
  91. _purchaseOrderAppService = purchaseOrderAppService;
  92. }
  93. /// <summary>
  94. /// 计算物料库存量
  95. /// </summary>
  96. /// <param name="returnlist"></param>
  97. public void BomStock(List<BomChildExamineDto> returnlist, List<mo_ic_item_stock> _ic_item_stock, long bangid)
  98. {
  99. returnlist = returnlist.OrderBy(s => s.num_order).ToList();
  100. //获取当前工厂下物料库存数据
  101. List<long> icitemIds = returnlist.Select(c => c.item_id).ToList();
  102. var stocklist = _ic_item_stock.Where(p => p.factory_id == param.factoryId && p.bang_id == bangid && icitemIds.Contains(p.icitem_id)).ToList();
  103. //计算剩余库存
  104. foreach (var item in returnlist)
  105. {
  106. if (item.erp_cls == 4)//虚拟件不计算
  107. {
  108. continue;
  109. }
  110. //非虚拟件
  111. //当前物料的库存数量
  112. decimal stockQty = stocklist.Where(s => s.icitem_id == item.item_id).Sum(p => p.sqty.GetValueOrDefault());
  113. item.sqty = stockQty;
  114. }
  115. }
  116. /// <summary>
  117. /// Bom平铺物料情况计算
  118. /// </summary>
  119. /// <param name="returnlist"></param>
  120. /// <param name="bangid"></param>
  121. /// <param name="count"></param>
  122. /// <param name="plan_date"></param>
  123. /// <param name="checkflag">是否生成工单、委外、采购</param>
  124. public void CalcView(List<BomChildExamineDto> returnlist, long bangid, decimal count, DateTime
  125. ? plan_date, List<mo_ic_item_stockoccupy> sklist, crm_seorderentry sentrys,int urgent, List<mo_ic_item> icitemlist)
  126. {
  127. ProductionTimeDay = 0;
  128. //第一级
  129. returnlist = returnlist.OrderBy(s => s.num_order).ToList();
  130. var level1Dto = returnlist[0];
  131. //第二级
  132. var childList = returnlist.Where(s => s.parent_id == level1Dto.fid && s.type == 0).OrderBy(s => s.num_order).ToList();
  133. //1.如果主料够的时候,不需要显示替代料的平铺视图,如果主料不够,显示替代料的平铺视图。
  134. //2.替代策略和替代方式,影响到的是甲乙组概念,替代按主料有限,取代按组的优先级。A与B的替代,则A和B各自会存在一个组。
  135. List<long> calcIds = new List<long>();
  136. //先处理下最顶级的产品需要数量
  137. level1Dto.needCount = level1Dto.qty * count;
  138. //直接占用库存,缺料就生成采购
  139. mo_ic_item_stockoccupy itemStockoccupyDto = new mo_ic_item_stockoccupy();
  140. itemStockoccupyDto.bang_id = bangid;
  141. itemStockoccupyDto.icitem_id = level1Dto.item_id;
  142. itemStockoccupyDto.item_no = level1Dto.num;
  143. if (sentrys != null)
  144. {
  145. itemStockoccupyDto.orderentry_id = sentrys.Id;
  146. }
  147. if (param.checkflag)
  148. {
  149. //找到当前物料的占用记录
  150. var itemSockoccupy = sklist.Where(s => s.icitem_id == level1Dto.item_id && s.bang_id == bangid).ToList();
  151. //计算库存减去占用
  152. level1Dto.sqty -= itemSockoccupy.Sum(s => s.quantity);
  153. level1Dto.sqty = level1Dto.sqty < 0 ? 0 : level1Dto.sqty;
  154. level1Dto.lack_qty = level1Dto.needCount - level1Dto.sqty;
  155. level1Dto.lack_qty = level1Dto.lack_qty < 0 ? 0 : level1Dto.lack_qty;
  156. if (level1Dto.sqty != 0)
  157. {
  158. if (level1Dto.lack_qty > 0)
  159. {
  160. level1Dto.use_qty = level1Dto.sqty;
  161. }
  162. else {
  163. level1Dto.use_qty = level1Dto.needCount;
  164. }
  165. itemStockoccupyDto.quantity = level1Dto.sqty;
  166. sklist.Add(itemStockoccupyDto);
  167. }
  168. }
  169. else {
  170. level1Dto.lack_qty = level1Dto.needCount;
  171. level1Dto.sqty = 0;
  172. }
  173. level1Dto.self_lack_qty = level1Dto.lack_qty;
  174. //平铺需要数量
  175. CaclMaterialShortage(returnlist);
  176. level1Dto.is_use = true;
  177. if (level1Dto.lack_qty > 0)
  178. {
  179. //获取物料详情
  180. var ic_item = icitemlist.Find(s => s.mysql_id == level1Dto.item_id);
  181. _morderAppService.mo_Mes_Morders = mordersList;//工单
  182. _morderAppService.mo_Mes_Moentry = moentriesList;//工单子表
  183. _morderAppService.mo_Mes_Mooccupies = mooccupyAllList;//工单占用
  184. List<mo_mes_mooccupy> mooccupylist = new List<mo_mes_mooccupy>();
  185. if (param.checkflag)
  186. {
  187. //工单检查无需检查在制
  188. mooccupylist = _morderAppService.CheckMorder(level1Dto.bom_number, level1Dto.lack_qty, plan_date.GetValueOrDefault(), sentrys, ic_item, bangid);
  189. }
  190. if (mooccupylist.Any())
  191. {
  192. mooccupyAllList.AddRange(mooccupylist);
  193. mooccupyAllInsertList.AddRange(mooccupylist);
  194. //在制占用明细
  195. level1Dto.mo_occupy_list = new List<mo_occupy>();
  196. mooccupylist.ForEach(s =>
  197. {
  198. mo_occupy mooc = new mo_occupy();
  199. mooc.id = s.id;
  200. mooc.moo_mo = s.moo_mo;
  201. mooc.moo_stime = s.moo_ctime;
  202. mooc.moo_etime = s.moo_etime;
  203. mooc.moo_qty = s.moo_qty;
  204. level1Dto.mo_occupy_list.Add(mooc);
  205. });
  206. }
  207. decimal moo_qty = mooccupylist.Sum(s => s.moo_qty.GetValueOrDefault());
  208. level1Dto.mo_qty = moo_qty;
  209. if (moo_qty == level1Dto.lack_qty)
  210. {
  211. //在制完全足够
  212. level1Dto.lack_qty = 0;
  213. level1Dto.satisfy_time = mooccupylist[0].moo_etime;
  214. level1Dto.kitting_time = level1Dto.satisfy_time;
  215. level1Dto.stock_state = 1;
  216. return;
  217. }
  218. else
  219. {
  220. //占用不够,占用后减少缺料数量
  221. level1Dto.lack_qty -= moo_qty;
  222. //先设定在制的齐套时间
  223. //level1Dto.satisfy_time = mooccupylist[0]?.moo_etime;
  224. level1Dto.stock_state = 0;
  225. if (param.checkflag)
  226. {
  227. //根据成品属性来判断是自制还是委外还是外购,需要考虑这种场景
  228. if (level1Dto.erp_cls == 1)
  229. {
  230. level1Dto.make_qty = level1Dto.lack_qty;
  231. //生成主工单
  232. GenerateMorderDto generateMorderDto = new GenerateMorderDto()
  233. {
  234. seorderentry = sentrys,
  235. seorder = seorder,
  236. ic_Item = ic_item,
  237. BomNumber = level1Dto.bom_number,
  238. version = level1Dto.version,
  239. number = level1Dto.item_number,
  240. Quantity = level1Dto.lack_qty,
  241. morder_type = MorderEnum.XsMorder,
  242. work_order_type = MorderEnum.CgMorder,
  243. morder_state = MorderEnum.Initial_state,
  244. bang_id = bangid
  245. };
  246. CreateMainOrder(generateMorderDto, level1Dto, childList, returnlist, bangid, plan_date, sklist, sentrys, urgent, icitemlist);
  247. }
  248. else if (level1Dto.erp_cls == 3)
  249. {
  250. //先找在途
  251. CalcInTransit(sentrys, level1Dto, bangid, plan_date.GetValueOrDefault());
  252. if (level1Dto.lack_qty > 0)
  253. {
  254. //采购申请
  255. PackageSRMPR(level1Dto, bangid, plan_date, sentrys);
  256. }
  257. }
  258. else if (level1Dto.erp_cls == 2)
  259. {
  260. //先找在途
  261. CalcInTransit(sentrys, level1Dto, bangid, plan_date.GetValueOrDefault());
  262. if (level1Dto.lack_qty > 0)
  263. {
  264. //先计算末级数据的齐套时间。
  265. if (childList.Count() > 0)
  266. {
  267. MatterTileDevelop(level1Dto, childList, returnlist, sklist, bangid, plan_date, sentrys, icitemlist);
  268. level1Dto.kitting_time = childList.Max(s => s.kitting_time);
  269. }
  270. //1.先生成委外工单。
  271. var mesorder = CreateMesOOder(level1Dto, param.tenantId, param.factoryId, bangid, leadTimeList, supplierList, plan_date.Value);
  272. level1Dto.subcontracting_qty = level1Dto.lack_qty;
  273. level1Dto.subcontracting_list = new List<ooder>();
  274. ooder oo = new ooder();
  275. oo.Id = mesorder.id;
  276. oo.morder_production_number = mesorder.morder_production_number;
  277. oo.production_unit = mesorder.production_unit;
  278. oo.production_unit_code = mesorder.production_unit_code;
  279. oo.ooentry_prdname = mesorder.ooentry_prdname;
  280. oo.ooentry_stime = mesorder.ooentry_stime;
  281. oo.ooentry_etime = mesorder.ooentry_etime;
  282. oo.oorder_date = mesorder.oorder_date;
  283. oo.oorder_no = mesorder.oorder_no;
  284. level1Dto.subcontracting_list.Add(oo);
  285. level1Dto.kitting_time = mesorder.ooentry_etime;
  286. orderList.Add(mesorder);
  287. //2.生成采购申请
  288. //采购申请
  289. PackageSRMPR(level1Dto, bangid, plan_date, sentrys);
  290. }
  291. }
  292. }
  293. else {
  294. MatterTileDevelop(level1Dto, childList, returnlist, sklist, bangid, plan_date, sentrys, icitemlist);
  295. }
  296. }
  297. }
  298. else
  299. {
  300. level1Dto.is_use= true;
  301. level1Dto.kitting_time = DateTime.Now;
  302. level1Dto.lack_qty = 0;
  303. level1Dto.satisfy_time = DateTime.Now;
  304. level1Dto.stock_state = 1;
  305. return;
  306. }
  307. }
  308. /// <summary>
  309. /// 生成主工单
  310. /// </summary>
  311. public void CreateMainOrder(GenerateMorderDto generateMorderDto, BomChildExamineDto level1Dto, List<BomChildExamineDto> childList, List<BomChildExamineDto> returnlist, long bangid, DateTime
  312. ? plan_date, List<mo_ic_item_stockoccupy> sklist, crm_seorderentry sentrys,int urgent, List<mo_ic_item> icitemlist)
  313. {
  314. //生成主工单
  315. _morderAppService.prodLines = prodLines;
  316. _morderAppService.routingOps = routingOps;
  317. _morderAppService.periodSequences = periodSequences;
  318. _morderAppService.calendarWorks = calendarWorks;
  319. _morderAppService.qualityLineWorks = qualityLineWorks;
  320. _morderAppService.holidays = holidays;
  321. Mes_MorderDto mes_MorderDto = _morderAppService.GenerateMorder(generateMorderDto, urgent);
  322. MatterTileDevelop(level1Dto, childList, returnlist, sklist, bangid, plan_date, sentrys, icitemlist);
  323. //这里更新产品得满足时间。
  324. if (mes_MorderDto != null)
  325. {
  326. //主工单最后计算满足日期
  327. var mes_Morders = mes_MorderDto.mes_Morders.Where(x => x.parent_id == null).FirstOrDefault();
  328. if (mes_Morders != null)
  329. {
  330. if (!string.IsNullOrEmpty(mes_Morders.bom_number))
  331. {
  332. mes_Morders.moentry_sys_stime = childList.Max(s => s.kitting_time.GetValueOrDefault()).AddDays(1).Date;//数据齐套完成后隔天开始生产;
  333. //var ProductiveDate = ProductiveExamine(mes_Morders.bom_number, level1Dto.version, (int)mes_Morders.morder_production_number.Value);
  334. ProdExamineParamDto prodExamine = new ProdExamineParamDto()
  335. {
  336. ItemNum = mes_Morders.bom_number,
  337. PlanStart = mes_Morders.moentry_sys_stime.Value,
  338. QtyOrd = (int)mes_Morders.morder_production_number.Value
  339. };
  340. _productExamineAppService.prodLines = prodLines;
  341. _productExamineAppService.routingOps = routingOps;
  342. _productExamineAppService.periodSequences = periodSequences;
  343. _productExamineAppService.calendarWorks = calendarWorks;
  344. _productExamineAppService.qualityLineWorks = qualityLineWorks;
  345. _productExamineAppService.holidays = holidays;
  346. var plan = planList.Find(x => x.icitem_id == level1Dto.item_id);
  347. var ProductiveDate = _productExamineAppService.ProductiveExamine(prodExamine);
  348. //var Day = ProductiveDate / (60 * 10); //返回的分钟除以十个小时得出工作天数;
  349. //结束日期=开始时间+生产时长+自检提前期+入库提前期+发运提前期;
  350. DateTime LeadTime;
  351. if (plan != null)
  352. {
  353. var TQdate = plan.self_inspection_date.GetValueOrDefault() + plan.Warehousing_date.GetValueOrDefault();
  354. LeadTime = ProductiveDate.AddDays((double)TQdate);
  355. }
  356. else
  357. {
  358. LeadTime = ProductiveDate;
  359. }
  360. //ProductionTimeDay = LeadTime;
  361. mes_Morders.moentry_sys_etime = LeadTime;
  362. mes_Morders.morder_need_time = Convert.ToInt32(DateTime.ParseExact(ProductiveDate.ToString("yyyyMMddHHmmss"), "yyyyMMddHHmmss", CultureInfo.CurrentCulture) -
  363. DateTime.ParseExact(mes_Morders.moentry_sys_stime.Value.ToString("yyyyMMddHHmmss"), "yyyyMMddHHmmss", CultureInfo.CurrentCulture));
  364. //满足资源检查的时间需加上提前期
  365. level1Dto.satisfy_time = LeadTime;
  366. if (sentrys != null)
  367. {
  368. sentrys.sys_capacity_date = level1Dto.satisfy_time;
  369. }
  370. }
  371. level1Dto.make_list = new List<moorder>();
  372. mes_MorderDto.mes_Morders.ForEach(me =>
  373. {
  374. moorder mo = new moorder();
  375. mo.Id = me.id;
  376. mo.moentry_stime = me.moentry_stime;
  377. mo.moentry_etime = me.moentry_etime;
  378. mo.moentry_wrkcname = me.moentry_wrkcname;
  379. mo.moentry_sys_stime = me.moentry_sys_stime;
  380. mo.moentry_sys_etime = me.moentry_sys_etime;
  381. mo.moentry_prdname = me.moentry_prdname;
  382. mo.morder_need_time = me.morder_need_time;
  383. mo.morder_no = me.morder_no;
  384. mo.morder_production_number = me.morder_production_number;
  385. mo.need_number = me.need_number;
  386. mo.reality_end_time = me.reality_end_time;
  387. mo.reality_start_time = me.reality_start_time;
  388. level1Dto.make_list.Add(mo);
  389. });
  390. //批量保存 后期考虑子工单
  391. mordersList.AddRange(mes_MorderDto.mes_Morders);
  392. mordersInsertList.AddRange(mes_MorderDto.mes_Morders);
  393. moentriesList.AddRange(mes_MorderDto.mes_Moentries);
  394. moentriesInsertList.AddRange(mes_MorderDto.mes_Moentries);
  395. }
  396. }
  397. }
  398. /// <summary>
  399. /// 物料计算
  400. /// </summary>
  401. /// <param name="level1Dto"></param>
  402. /// <param name="childList"></param>
  403. /// <param name="returnlist"></param>
  404. /// <param name="sklist"></param>
  405. /// <param name="bangid"></param>
  406. /// <param name="plan_date"></param>
  407. /// <param name="sentrys"></param>
  408. /// <param name="icitemlist"></param>
  409. public void MatterTileDevelop(BomChildExamineDto level1Dto,List<BomChildExamineDto> childList, List<BomChildExamineDto> returnlist, List<mo_ic_item_stockoccupy> sklist,long bangid,DateTime
  410. ? plan_date, crm_seorderentry sentrys, List<mo_ic_item> icitemlist)
  411. {
  412. //这是从上往下展开计算缺料和可制
  413. CaleLackItem(level1Dto, childList, returnlist, sklist, bangid);
  414. //level1Dto.kz = childList.Min(s => s.kz);//得到最小可制数量。
  415. //再加个循环,来根据替代关系里的检查结果,根据规则明确使用和生成占用关系。
  416. List<long> childidList = new List<long>();
  417. CalcIcitem(childList, returnlist, bangid, sklist, plan_date, icitemlist, sentrys, childidList);
  418. level1Dto.kitting_time = childList.Max(x => x.kitting_time.GetValueOrDefault());
  419. }
  420. /// <summary>
  421. /// 平铺计算物料情况
  422. /// </summary>
  423. /// <param name="returnlist"></param>
  424. /// <param name="item"></param>
  425. /// <param name="count"></param>
  426. public void CaclMaterialShortage(List<BomChildExamineDto> returnlist)
  427. {
  428. foreach (var item in returnlist)
  429. {
  430. if (item.level == 1)
  431. {
  432. continue;
  433. }
  434. //循环平铺整个资源检查的物料库存情况、缺料情况,子集缺料需要用父级缺料*子集使用数量-
  435. var parent = returnlist.Find(s => s.fid == item.parent_id);
  436. //当前物料总共需要数量
  437. item.needCount = parent.needCount * item.qty;
  438. }
  439. }
  440. /// <summary>
  441. /// 计算物料是否缺料
  442. /// </summary>
  443. /// <param name="parent"></param>
  444. /// <param name="bzlist"></param>
  445. /// <param name="returnlist"></param>
  446. /// <param name="sockoccupyList"></param>
  447. public void CaleLackItem(BomChildExamineDto parent, List<BomChildExamineDto> bzlist, List<BomChildExamineDto> returnlist, List<mo_ic_item_stockoccupy> sockoccupyList, long bangid)
  448. {
  449. //从第二级开始循环
  450. foreach (var item in bzlist)
  451. {
  452. var childList = returnlist.Where(s => s.parent_id == item.fid && s.type == 0).ToList();
  453. //根据占用情况计算库存
  454. Calczykc(item, parent, sockoccupyList, bangid);
  455. //如果有子集,则丢入循环,判断下库存可制等信息。
  456. CaleLackItem(item, childList, returnlist, sockoccupyList, bangid);
  457. }
  458. }
  459. /// <summary>
  460. /// 根据每个物料来实时计算占用情况
  461. /// </summary>
  462. /// <param name="item"></param>
  463. /// <param name="sockoccupyList"></param>
  464. public void Calczykc(BomChildExamineDto item, BomChildExamineDto parent, List<mo_ic_item_stockoccupy> sockoccupyList, long bangid)
  465. {
  466. //找到当前物料的占用记录
  467. var itemSockoccupy = sockoccupyList.Where(s => s.icitem_id == item.item_id && s.bang_id == bangid).ToList();
  468. //计算库存减去占用
  469. item.sqty -= itemSockoccupy.Sum(s => s.quantity);
  470. //如果库存
  471. item.sqty = item.sqty < 0 ? 0 : item.sqty;
  472. if (parent.stock_state == 1 || parent.stock_state == -1)
  473. {
  474. item.stock_state = parent.stock_state;
  475. item.lack_qty = 0;
  476. item.self_lack_qty = 0;
  477. }
  478. else
  479. {
  480. //判断缺料数量
  481. item.self_lack_qty = parent.lack_qty * item.qty;
  482. item.lack_qty = item.self_lack_qty - item.sqty;
  483. item.lack_qty = item.lack_qty < 0 ? 0 : item.lack_qty;
  484. //判断状态
  485. item.stock_state = item.lack_qty > 0 ? 0 : 1;
  486. }
  487. }
  488. /// <summary>
  489. /// 循环计算物料情况
  490. /// </summary>
  491. /// <param name="childList"></param>
  492. /// <param name="returnlist"></param>
  493. /// <param name="bangid"></param>
  494. /// <param name="orderid"></param>
  495. /// <param name="input"></param>
  496. /// <param name="sklist"></param>
  497. /// <param name="plan_date"></param>
  498. public void CalcIcitem(List<BomChildExamineDto> childList, List<BomChildExamineDto> returnlist, long bangid, List<mo_ic_item_stockoccupy> sklist, DateTime
  499. ? plan_date, List<mo_ic_item> icitemlist, crm_seorderentry sentrys, List<long> childidList)
  500. {
  501. foreach (var item in childList)
  502. {
  503. var parent = returnlist.Find(s => s.fid == item.parent_id);
  504. if (parent.stock_state == 0)
  505. {
  506. if (childidList.Contains(item.bom_child_id.GetValueOrDefault()))
  507. {
  508. continue;
  509. }
  510. if (item.haveicsubs == 1)
  511. {
  512. //如果有替代关系,根据群组来明确使用哪个群组的替代料。按整批和混用逻辑来算
  513. //如果有群组替代,就移除掉被检查过的记录 item.icitem_ids
  514. //通过替代群组代码,将替代群组物料进行绑定。
  515. childidList.AddRange(returnlist.Where(s => s.substitute_code == item.substitute_code).Select(d => d.bom_child_id.GetValueOrDefault()));
  516. CalcStrategy(item, returnlist, bangid, sklist, plan_date, icitemlist, sentrys, childidList);
  517. }
  518. else
  519. {
  520. Calczykc(item, parent, sklist, bangid);
  521. //直接占用库存,缺料就生成采购
  522. mo_ic_item_stockoccupy itemStockoccupyDto = new mo_ic_item_stockoccupy();
  523. itemStockoccupyDto.bang_id = bangid;
  524. itemStockoccupyDto.icitem_id = item.item_id;
  525. itemStockoccupyDto.item_no = item.num;
  526. item.kitting_time = DateTime.Now;
  527. item.is_use = true;
  528. StartProcessing(item, icitemlist, returnlist, plan_date, sentrys, sklist, itemStockoccupyDto, bangid, childidList);
  529. }
  530. }
  531. }
  532. }
  533. /// <summary>
  534. /// 针对缺料开始进行处理
  535. /// </summary>
  536. /// <param name="item"></param>
  537. /// <param name="icitemlist"></param>
  538. /// <param name="returnlist"></param>
  539. /// <param name="plan_date"></param>
  540. /// <param name="sentrys"></param>
  541. /// <param name="sklist"></param>
  542. /// <param name="itemStockoccupyDto"></param>
  543. /// <param name="bangid"></param>
  544. /// <param name="input"></param>
  545. public void StartProcessing(BomChildExamineDto item, List<mo_ic_item> icitemlist, List<BomChildExamineDto> returnlist, DateTime
  546. ? plan_date, crm_seorderentry sentrys, List<mo_ic_item_stockoccupy> sklist, mo_ic_item_stockoccupy itemStockoccupyDto, long bangid, List<long> childidList)
  547. {
  548. var parent = returnlist.Find(s => s.fid == item.parent_id);
  549. if (item.lack_qty > 0)
  550. {
  551. var cilList = returnlist.Where(s => s.parent_id == item.fid && s.type == item.type).OrderBy(k => k.num_order).ToList();
  552. //如果缺料,占用库存,然后走采购或自制
  553. if (item.sqty > 0)
  554. {
  555. itemStockoccupyDto.quantity = item.sqty;
  556. sklist.Add(itemStockoccupyDto);
  557. }
  558. item.use_qty = item.sqty;
  559. if (item.erp_cls == 1)
  560. {
  561. /*var ic_item = icitemlist.Find(s => s.Id == item.item_id);
  562. var mooccupylist = _morderAppService.CheckMorder(item.bom_number, item.lack_qty, plan_date.GetValueOrDefault(), sentrys, ic_item).Result;
  563. decimal moo_qty = mooccupylist.Sum(s => s.moo_qty.GetValueOrDefault());
  564. item.mo_qty = moo_qty;
  565. item.mo_occupy_list = new List<mo_occupy>();
  566. mooccupylist.ForEach(s =>
  567. {
  568. mo_occupy mooc = new mo_occupy();
  569. mooc.moo_mo = s.moo_mo;
  570. mooc.moo_stime = s.moo_ctime;
  571. mooc.moo_etime = s.moo_etime;
  572. mooc.moo_qty = s.moo_qty;
  573. item.mo_occupy_list.Add(mooc);
  574. });*/
  575. decimal moo_qty = 0;
  576. if (moo_qty == returnlist[0].lack_qty)
  577. {
  578. //在制完全足够
  579. item.lack_qty = 0;
  580. //item.kitting_time = mooccupylist[0].moo_etime;
  581. item.kitting_time = DateTime.Now;
  582. item.stock_state = 1;
  583. }
  584. else
  585. {
  586. item.lack_qty -= moo_qty;
  587. item.kitting_time = DateTime.Now;
  588. //先计算末级数据的齐套时间。
  589. if (cilList.Count() > 0)
  590. {
  591. CalcIcitem(cilList, returnlist, bangid, sklist, plan_date, icitemlist, sentrys, childidList);
  592. item.kitting_time = cilList.Max(s => s.kitting_time);
  593. }
  594. item.make_qty = item.lack_qty;
  595. /*//走自制
  596. ProdExamineParamDto prodExamine = new ProdExamineParamDto()
  597. {
  598. bom_number = item.bom_number,
  599. version = item.version,
  600. packages = (int)item.lack_qty
  601. };
  602. _productExamineAppService.process = process;
  603. _productExamineAppService.techs = techs;
  604. _productExamineAppService.tech_Processes = tech_Processes;
  605. _productExamineAppService.tech_Proc_Workshops = tech_Proc_Workshops;
  606. *//*if (param.checkflag)
  607. {
  608. //todo:增加生成子工单后,这里需要加上生成的子工单的明细。
  609. }*//*
  610. item.make_list = new List<moorder>();
  611. var minute = _productExamineAppService.ProductiveExamine(prodExamine);
  612. //系统建议完工日期为 开工日期+产能检查时间=完工日期
  613. var Day = minute / (60 * 10); //返回的分钟除以十个小时得出工作天数;
  614. var ktime = item.kitting_time.Value.AddDays((double)Day);
  615. //item.kitting_time = ktime > mooccupylist[0].moo_etime ? ktime : mooccupylist[0].moo_etime;
  616. item.kitting_time = ktime;*/
  617. }
  618. }
  619. else if (item.erp_cls == 3)
  620. {
  621. //先找在途
  622. CalcInTransit(sentrys, item, bangid, plan_date.GetValueOrDefault());
  623. if (item.lack_qty > 0)
  624. {
  625. //采购申请
  626. PackageSRMPR(item, bangid, plan_date, sentrys);
  627. }
  628. }
  629. else if (item.erp_cls == 2)
  630. {
  631. //先找在途
  632. CalcInTransit(sentrys, item, bangid, plan_date.GetValueOrDefault());
  633. if (item.lack_qty > 0)
  634. {
  635. //先计算末级数据的齐套时间。
  636. if (cilList.Count() > 0)
  637. {
  638. CalcIcitem(cilList, returnlist, bangid, sklist, plan_date, icitemlist, sentrys, childidList);
  639. item.kitting_time = cilList.Max(s => s.kitting_time);
  640. }
  641. //1.先生成委外工单。
  642. var mesorder = CreateMesOOder(item, param.tenantId, param.factoryId, bangid, leadTimeList, supplierList, plan_date.Value);
  643. item.subcontracting_qty = item.lack_qty;
  644. item.subcontracting_list = new List<ooder>();
  645. ooder oo = new ooder();
  646. oo.Id = mesorder.id;
  647. oo.morder_production_number = mesorder.morder_production_number;
  648. oo.production_unit = mesorder.production_unit;
  649. oo.production_unit_code = mesorder.production_unit_code;
  650. oo.ooentry_prdname = mesorder.ooentry_prdname;
  651. oo.ooentry_stime = mesorder.ooentry_stime;
  652. oo.ooentry_etime = mesorder.ooentry_etime;
  653. oo.oorder_date = mesorder.oorder_date;
  654. oo.oorder_no = mesorder.oorder_no;
  655. item.subcontracting_list.Add(oo);
  656. item.kitting_time = mesorder.ooentry_etime;
  657. orderList.Add(mesorder);
  658. //2.生成采购申请
  659. //采购申请
  660. PackageSRMPR(item, bangid, plan_date, sentrys);
  661. }
  662. }
  663. else
  664. {
  665. item.kitting_time = DateTime.Now;
  666. //先计算末级数据的齐套时间。
  667. if (cilList.Count() > 0)
  668. {
  669. CalcIcitem(cilList, returnlist, bangid, sklist, plan_date, icitemlist, sentrys, childidList);
  670. item.kitting_time = cilList.Max(s => s.kitting_time);
  671. }
  672. }
  673. }
  674. else
  675. {
  676. //如果父级缺料,则本级等于父级缺料*本级使用数量
  677. if (parent != null)
  678. {
  679. item.use_qty = parent.lack_qty * item.qty;
  680. item.kitting_time = DateTime.Now;
  681. itemStockoccupyDto.quantity = item.use_qty;
  682. }
  683. sklist.Add(itemStockoccupyDto);
  684. }
  685. }
  686. /// <summary>
  687. /// 根据替代策略计算
  688. /// </summary>
  689. /// <param name="item"></param>
  690. /// <param name="returnlist"></param>
  691. /// <param name="bangid"></param>
  692. /// <param name="sklist"></param>
  693. /// <param name="input"></param>
  694. /// <param name="plan_date"></param>
  695. public void CalcStrategy(BomChildExamineDto item, List<BomChildExamineDto> returnlist, long bangid, List<mo_ic_item_stockoccupy> sklist, DateTime
  696. ? plan_date, List<mo_ic_item> icitemlist, crm_seorderentry sentrys, List<long> childidList)
  697. {
  698. //提取群组关系
  699. var sublist = returnlist.Where(s => s.parent_id == item.parent_id && s.num == item.num && s.level == item.level).OrderBy(c => c.substitute_all_num).ToList();
  700. List<BomChildExamineDto> select = new List<BomChildExamineDto>();
  701. var parent = returnlist.Find(s => s.fid == item.parent_id);
  702. switch (item.substitute_strategy)
  703. {
  704. case 0://整批
  705. WholeBatchCheck(sublist, returnlist, sklist, select, bangid);
  706. //如果都需要采购的情况下,则默认使用优先级最高的
  707. WholeBatch(item, sublist, returnlist, sklist, select, bangid, parent, plan_date, icitemlist, sentrys, childidList);
  708. break;
  709. case 1://混用
  710. MixedUse(item, sublist, returnlist, sklist, bangid, parent, plan_date, icitemlist, sentrys, childidList);
  711. break;
  712. case 2://整批加混用
  713. WholeBatchCheck(sublist, returnlist, sklist, select, bangid);
  714. if (select.Count() == 0)
  715. {
  716. //走混用
  717. MixedUse(item, sublist, returnlist, sklist, bangid, parent, plan_date, icitemlist, sentrys, childidList);
  718. }
  719. else
  720. {
  721. //走整批
  722. WholeBatch(item, sublist, returnlist, sklist, select, bangid, parent, plan_date, icitemlist, sentrys, childidList);
  723. }
  724. break;
  725. }
  726. }
  727. /// <summary>
  728. /// 整批计算
  729. /// </summary>
  730. /// <param name="sublist"></param>
  731. /// <param name="returnlist"></param>
  732. /// <param name="sklist"></param>
  733. /// <param name="select"></param>
  734. public void WholeBatchCheck(List<BomChildExamineDto> sublist, List<BomChildExamineDto> returnlist, List<mo_ic_item_stockoccupy> sklist, List<BomChildExamineDto> select, long bangid)
  735. {
  736. for (int idx = 0; idx < 99; idx++)
  737. {
  738. var list = sublist.Where(s => s.substitute_all_num == idx).ToList();
  739. if (list.Any())
  740. {
  741. foreach (var s in list)
  742. {
  743. RecalculationStock(s, returnlist, sklist, bangid);
  744. }
  745. //可制计算:需要对list进行可制计算,按主料来算辅料
  746. if (list.Where(s => s.stock_state != 1).Count() == 0)
  747. {
  748. //只满足充足或可制
  749. //无缺料情况
  750. select = list;
  751. select.ForEach(s => { s.is_use = true; });
  752. break;
  753. }
  754. idx++;
  755. }
  756. else
  757. {
  758. idx = 99;
  759. }
  760. }
  761. }
  762. /// <summary>
  763. /// 整批占用
  764. /// </summary>
  765. /// <param name="item"></param>
  766. /// <param name="sublist"></param>
  767. /// <param name="returnlist"></param>
  768. /// <param name="sklist"></param>
  769. /// <param name="select"></param>
  770. /// <param name="bangid"></param>
  771. /// <param name="parent"></param>
  772. /// <param name="plan_date"></param>
  773. public void WholeBatch(BomChildExamineDto item, List<BomChildExamineDto> sublist, List<BomChildExamineDto> returnlist, List<mo_ic_item_stockoccupy> sklist, List<BomChildExamineDto> select, long bangid, BomChildExamineDto parent, DateTime
  774. ? plan_date, List<mo_ic_item> icitemlist, crm_seorderentry sentrys, List<long> childidList)
  775. {
  776. if (select.Count() == 0)
  777. {
  778. //如果为空,则默认使用优先级为0的集合作为替代关系
  779. if (item.substitute_mode == 0)
  780. {
  781. //替代
  782. select = sublist.Where(s => s.type == 0).ToList();
  783. }
  784. else
  785. {
  786. //取代
  787. select = sublist.Where(s => s.substitute_all_num == 0).ToList();
  788. }
  789. select.ForEach(s => { s.is_use = true; });
  790. }
  791. //占用库存
  792. foreach (var slt in select)
  793. {
  794. slt.self_lack_qty = parent.lack_qty * slt.qty;
  795. mo_ic_item_stockoccupy itemStockoccupyDto = new mo_ic_item_stockoccupy();
  796. itemStockoccupyDto.bang_id = bangid;
  797. itemStockoccupyDto.icitem_id = slt.item_id;
  798. itemStockoccupyDto.item_no = slt.num;
  799. slt.is_use = true;
  800. StartProcessing(slt, icitemlist, returnlist, plan_date, sentrys, sklist, itemStockoccupyDto, bangid, childidList);
  801. }
  802. }
  803. /// <summary>
  804. /// 混用占用
  805. /// </summary>
  806. /// <param name="item"></param>
  807. /// <param name="sublist"></param>
  808. /// <param name="returnlist"></param>
  809. /// <param name="sklist"></param>
  810. /// <param name="bangid"></param>
  811. /// <param name="parent"></param>
  812. /// <param name="plan_date"></param>
  813. public void MixedUse(BomChildExamineDto item, List<BomChildExamineDto> sublist, List<BomChildExamineDto> returnlist, List<mo_ic_item_stockoccupy> sklist, long bangid, BomChildExamineDto parent, DateTime
  814. ? plan_date, List<mo_ic_item> icitemlist, crm_seorderentry sentrys, List<long> childidList)
  815. {
  816. decimal parent_lack = 0;
  817. if (parent != null)
  818. {
  819. parent_lack = parent.lack_qty;
  820. }
  821. for (int idx = 0; idx < 99; idx++)
  822. {
  823. if (parent_lack <= 0)
  824. {
  825. break;
  826. }
  827. var list = sublist.Where(s => s.substitute_all_num == idx).ToList();
  828. if (list.Any())
  829. {
  830. foreach (var s in list)
  831. {
  832. RecalculationStock(s, returnlist, sklist, bangid);
  833. }
  834. decimal minMake = 99999999;
  835. foreach (var hy in list)
  836. {
  837. //混用先使用掉当前要用的数量
  838. //得到库存最小数量,去占用,然后剩余的丢第二个循环里去占用。
  839. //获取物料详情
  840. /*var ic_item = icitemlist.Find(s => s.Id == hy.item_id);
  841. var mooccupylist = _morderAppService.CheckMorder(hy.bom_number, hy.lack_qty, plan_date.GetValueOrDefault(), sentrys, ic_item, false).Result;
  842. decimal moo_qty = mooccupylist.Sum(s => s.moo_qty.GetValueOrDefault());
  843. decimal make = (hy.sqty + moo_qty) / hy.qty;
  844. if (Math.Floor(hy.qty) == hy.qty)
  845. {
  846. //如果物料的使用数量是小数,则按小数计算。
  847. make = Math.Floor(make);
  848. }
  849. if (minMake > make)
  850. {
  851. minMake = make;
  852. }*/
  853. //先去掉上面的在制
  854. decimal make = hy.sqty / hy.qty;
  855. if (Math.Floor(hy.qty) == hy.qty)
  856. {
  857. //如果物料的使用数量是小数,则按小数计算。
  858. make = Math.Floor(make);
  859. }
  860. if (minMake > make)
  861. {
  862. minMake = make;
  863. }
  864. }
  865. decimal use_p_num = 0;
  866. if (parent_lack > minMake) //20>10
  867. {
  868. use_p_num = minMake;
  869. parent_lack -= use_p_num;
  870. }
  871. else
  872. {
  873. use_p_num = parent_lack;
  874. parent_lack = 0;
  875. }
  876. //根据混用逻辑,去占用物料
  877. foreach (var zy in list)
  878. {
  879. zy.is_use = true;
  880. zy.kitting_time = DateTime.Now;
  881. if (parent_lack <= 0)
  882. {
  883. zy.stock_state = 1;
  884. }
  885. mo_ic_item_stockoccupy itemStockoccupyDto = new mo_ic_item_stockoccupy();
  886. if (sentrys != null)
  887. {
  888. itemStockoccupyDto.orderentry_id = sentrys.Id;
  889. }
  890. itemStockoccupyDto.bang_id = bangid;
  891. itemStockoccupyDto.icitem_id = zy.item_id;
  892. /*decimal moo_qty = use_p_num * zy.qty - zy.sqty;
  893. if (moo_qty > 0)
  894. {
  895. var ic_item = icitemlist.Find(s => s.Id == zy.item_id);
  896. var mooccupylist = _morderAppService.CheckMorder(zy.bom_number, moo_qty, plan_date.GetValueOrDefault(), sentrys, ic_item).Result;
  897. itemStockoccupyDto.quantity = zy.sqty;
  898. zy.use_qty = zy.sqty;
  899. zy.mo_qty = moo_qty;
  900. zy.mo_occupy_list = new List<mo_occupy>();
  901. mooccupylist.ForEach(s =>
  902. {
  903. mo_occupy mooc = new mo_occupy();
  904. mooc.moo_mo = s.moo_mo;
  905. mooc.moo_stime = s.moo_ctime;
  906. mooc.moo_etime = s.moo_etime;
  907. mooc.moo_qty = s.moo_qty;
  908. zy.mo_occupy_list.Add(mooc);
  909. });
  910. }
  911. else
  912. {
  913. zy.use_qty = use_p_num * zy.qty;
  914. itemStockoccupyDto.quantity = zy.use_qty;
  915. }*/
  916. //先去掉上面的在制逻辑
  917. zy.use_qty = use_p_num * zy.qty;
  918. itemStockoccupyDto.quantity = zy.use_qty;
  919. itemStockoccupyDto.item_no = zy.num;
  920. sklist.Add(itemStockoccupyDto);
  921. }
  922. idx++;
  923. }
  924. }
  925. if (parent_lack > 0)
  926. {
  927. var select = new List<BomChildExamineDto>();
  928. if (item.substitute_mode == 0)
  929. {
  930. //替代
  931. select = sublist.Where(s => s.type == 0).ToList();
  932. }
  933. else
  934. {
  935. //取代
  936. select = sublist.Where(s => s.substitute_all_num == 0).ToList();
  937. }
  938. //对select执行补充(根据属性采购、外购、自制等)
  939. foreach (var sct in select)
  940. {
  941. decimal sqty = sct.sqty - sct.use_qty;//这里得出前面混用使用后的库存。
  942. decimal lack_Count = parent_lack * sct.qty;//混用后还缺的部分。
  943. mo_ic_item_stockoccupy itemStockoccupyDto = new mo_ic_item_stockoccupy();
  944. if (sentrys != null)
  945. {
  946. itemStockoccupyDto.orderentry_id = sentrys.Id;
  947. }
  948. itemStockoccupyDto.bang_id = bangid;
  949. itemStockoccupyDto.icitem_id = sct.item_id;
  950. itemStockoccupyDto.item_no = sct.num;
  951. decimal lack_num = sqty - lack_Count;//库存还够缺的部分
  952. if (lack_num >= 0)
  953. {
  954. //剩余得库存还够还缺的部分
  955. itemStockoccupyDto.quantity = lack_Count;
  956. sct.use_qty += lack_Count;
  957. sklist.Add(itemStockoccupyDto);
  958. }
  959. else
  960. {
  961. var cilList = returnlist.Where(s => s.parent_id == sct.fid && s.type == sct.type).OrderBy(k => k.num_order).ToList();
  962. itemStockoccupyDto.quantity = sqty;
  963. sklist.Add(itemStockoccupyDto);
  964. sct.lack_qty = lack_num * -1;
  965. sct.kitting_time = DateTime.Now;
  966. sct.use_qty += sqty;
  967. if (sct.erp_cls == 1)
  968. {
  969. //先计算末级数据的齐套时间。
  970. if (cilList.Count() > 0)
  971. {
  972. CalcIcitem(cilList, returnlist, bangid, sklist, plan_date, icitemlist, sentrys, childidList);
  973. sct.kitting_time = cilList.Max(s => s.kitting_time);
  974. }
  975. sct.make_qty = sct.lack_qty;
  976. /*//走自制
  977. ProdExamineParamDto prodExamine = new ProdExamineParamDto()
  978. {
  979. bom_number = sct.bom_number,
  980. version = sct.version,
  981. packages = (int)sct.lack_qty
  982. };
  983. _productExamineAppService.process = process;
  984. _productExamineAppService.techs = techs;
  985. _productExamineAppService.tech_Processes = tech_Processes;
  986. _productExamineAppService.tech_Proc_Workshops = tech_Proc_Workshops;
  987. var minute = _productExamineAppService.ProductiveExamine(prodExamine);
  988. //系统建议完工日期为 开工日期+产能检查时间=完工日期
  989. var Day = minute / (60 * 10); //返回的分钟除以十个小时得出工作天数;
  990. sct.kitting_time = sct.kitting_time.Value.AddDays((double)Day);
  991. sct.make_qty = sct.lack_qty;*/
  992. //todo:
  993. sct.make_list = new List<moorder>();
  994. }
  995. else if (sct.erp_cls == 3)
  996. {
  997. //先找在途
  998. CalcInTransit(sentrys, sct, bangid, plan_date.GetValueOrDefault());
  999. if (sct.lack_qty > 0)
  1000. {
  1001. //采购申请
  1002. PackageSRMPR(sct, bangid, plan_date, sentrys);
  1003. }
  1004. }
  1005. else if (sct.erp_cls == 2)
  1006. {
  1007. //先找在途
  1008. CalcInTransit(sentrys, sct, bangid, plan_date.GetValueOrDefault());
  1009. if (sct.lack_qty > 0)
  1010. {
  1011. //先计算末级数据的齐套时间。
  1012. if (cilList.Count() > 0)
  1013. {
  1014. CalcIcitem(cilList, returnlist, bangid, sklist, plan_date, icitemlist, sentrys, childidList);
  1015. sct.kitting_time = cilList.Max(s => s.kitting_time);
  1016. }
  1017. //1.先生成委外工单。
  1018. var mesorder = CreateMesOOder(sct, param.tenantId, param.factoryId, bangid, leadTimeList, supplierList, plan_date.Value);
  1019. sct.subcontracting_qty = sct.lack_qty;
  1020. sct.subcontracting_list = new List<ooder>();
  1021. ooder oo = new ooder();
  1022. oo.Id = mesorder.id;
  1023. oo.morder_production_number = mesorder.morder_production_number;
  1024. oo.production_unit = mesorder.production_unit;
  1025. oo.production_unit_code = mesorder.production_unit_code;
  1026. oo.ooentry_prdname = mesorder.ooentry_prdname;
  1027. oo.ooentry_stime = mesorder.ooentry_stime;
  1028. oo.ooentry_etime = mesorder.ooentry_etime;
  1029. oo.oorder_date = mesorder.oorder_date;
  1030. oo.oorder_no = mesorder.oorder_no;
  1031. item.subcontracting_list.Add(oo);
  1032. sct.kitting_time = mesorder.ooentry_etime;
  1033. orderList.Add(mesorder);
  1034. //采购申请
  1035. PackageSRMPR(sct, bangid, plan_date, sentrys);
  1036. }
  1037. }
  1038. else
  1039. {
  1040. if (cilList.Count() > 0)
  1041. {
  1042. CalcIcitem(cilList, returnlist, bangid, sklist, plan_date, icitemlist, sentrys, childidList);
  1043. sct.kitting_time = cilList.Max(s => s.kitting_time);
  1044. }
  1045. }
  1046. }
  1047. }
  1048. }
  1049. }
  1050. /// <summary>
  1051. /// 根据占用情况重新计算占用
  1052. /// </summary>
  1053. /// <param name="item"></param>
  1054. /// <param name="returnlist"></param>
  1055. /// <param name="sklist"></param>
  1056. public void RecalculationStock(BomChildExamineDto item, List<BomChildExamineDto> returnlist, List<mo_ic_item_stockoccupy> sklist, long bangid)
  1057. {
  1058. //再计算一边占用情况,这里根据父级产品额缺料量*当前子料的使用数量-子料库存量。得出当前子物料的缺料数量
  1059. var parent = returnlist.Find(s => s.fid == item.parent_id);
  1060. decimal stockQty = sklist.Where(s => s.icitem_id == item.item_id && s.bang_id == bangid).Sum(p => p.quantity);
  1061. item.sqty = item.sqty - stockQty;
  1062. item.lack_qty = parent.lack_qty * item.qty - item.sqty;
  1063. item.lack_qty = item.lack_qty > 0 ? item.lack_qty : 0;
  1064. item.self_lack_qty = item.lack_qty;
  1065. item.stock_state = item.lack_qty > 0 ? 0 : 1;
  1066. }
  1067. /// <summary>
  1068. /// 生成采购申请单,颗粒度是一个物料一个单,没必要弄列表
  1069. /// </summary>
  1070. /// <param name="returnlist"></param>
  1071. /// <param name="factoryid"></param>
  1072. /// <param name="orderType">2委外采购申请单,3采购申请单</param>
  1073. private SRMPRDto CreateSRMPR(BomChildExamineDto returnlist, long tenantId, long factoryid, long bangId, int orderType, List<ICItemLeadTimeDto> iCItemLeadTimes, List<mo_srm_purchase> supplierList, List<mo_ic_plan> planList, DateTime deliveryDate, crm_seorderentry sentrys)
  1074. {
  1075. SRMPRDto sRMPR = new SRMPRDto();
  1076. var leadTime = iCItemLeadTimes.Find(x => x.item_id == returnlist.item_id);
  1077. var supplier = supplierList.Where(x => x.icitem_id == returnlist.item_id).ToList();//默认取第一个供应商
  1078. var plan = planList.Find(x => x.icitem_id == returnlist.item_id);
  1079. sRMPR.srm_Pr_Main = new List<mo_srm_pr_main>();
  1080. if (leadTime == null || !supplier.Any() || plan == null)
  1081. {
  1082. sRMPR.lastStartTmie = DateTime.Now.AddDays(7);//减去提前期
  1083. return sRMPR;
  1084. //throw new NotImplementedException("未找到物料ic_factory_details或ic_item_pur或ic_plan信息!");
  1085. }
  1086. supplier.ForEach(x =>
  1087. {
  1088. //提前期随机数,金额随机数
  1089. leadTime.order_leadtime = rnd.Next(1, 5);
  1090. leadTime.transportation_leadtime = rnd.Next(1, 5);
  1091. leadTime.stock_leadtime = rnd.Next(1, 5);
  1092. leadTime.production_leadtime = rnd.Next(1, 5);
  1093. x.netpurchase_price = rnd.Next(1, 100);
  1094. x.taxrate = 0.13m;//固定13%增值税
  1095. mo_srm_pr_main srm_Pr = new mo_srm_pr_main();
  1096. srm_Pr.id = help.NextId();
  1097. srm_Pr.mysql_id = help.NextId();
  1098. srm_Pr.pr_billno = returnlist.erp_cls == 2 ? getOrderNum("WWPR") : getOrderNum("PR");//pr单号
  1099. srm_Pr.pr_mono = "";//关联工单号
  1100. srm_Pr.entity_id = 1;//工单行号
  1101. srm_Pr.pr_purchaseid = x.supplier_id;//供应商id
  1102. srm_Pr.pr_purchasenumber = x.supplier_number;//供应商编码
  1103. srm_Pr.pr_purchasename = x.supplier_name;//供应商名称
  1104. srm_Pr.pr_purchaser = x.purcher;//采购员
  1105. srm_Pr.pr_purchaser_num = "";//采购员工号(采购信息表)
  1106. srm_Pr.pr_rqty = returnlist.lack_qty;//需求数量
  1107. srm_Pr.pr_aqty = returnlist.lack_qty;//申请数量
  1108. srm_Pr.pr_sqty = returnlist.lack_qty;//建议数量
  1109. srm_Pr.icitem_id = returnlist.item_id;//物料id
  1110. srm_Pr.icitem_name = returnlist.item_name;//物料名称
  1111. srm_Pr.pr_order_type = 1;//单据类型
  1112. srm_Pr.pr_ssend_date = DateTime.Now;//系统建议下单日期
  1113. srm_Pr.pr_sarrive_date = DateTime.Now.AddDays((double)leadTime.order_leadtime).AddDays((double)leadTime.transportation_leadtime);//系统建议到达日期(建议到货日期)
  1114. srm_Pr.pr_psend_date = DateTime.Now;//计划下单日期
  1115. srm_Pr.pr_parrive_date = DateTime.Now.AddDays((double)leadTime.order_leadtime).AddDays((double)leadTime.transportation_leadtime);//计划到达日期
  1116. srm_Pr.pr_rarrive_date = DateTime.Now.AddDays((double)leadTime.order_leadtime).AddDays((double)leadTime.transportation_leadtime);//需求到货日期
  1117. srm_Pr.pr_sysprice = returnlist.lack_qty * x.netpurchase_price * (1 + x.taxrate);//系统价格(含税)
  1118. srm_Pr.pr_orderprice = returnlist.lack_qty * x.netpurchase_price * (1 + x.taxrate);//订单价格(含税)
  1119. srm_Pr.pr_rarrive_date = DateTime.Now.AddDays((double)leadTime.order_leadtime);
  1120. srm_Pr.pr_price = x.netpurchase_price;//采购净价(不含税)
  1121. srm_Pr.pr_rate = x.taxrate;//税率
  1122. srm_Pr.pr_unit = returnlist.unit;//单位
  1123. srm_Pr.state = 1;//状态
  1124. srm_Pr.old_apply_aqty = 0;//已申请数量
  1125. srm_Pr.pr_type = orderType;//申请类型
  1126. srm_Pr.currencytype = x.currency_type;//币种
  1127. srm_Pr.secInv_ratio = plan.secinv_ratio;//安全库存触发采购比例
  1128. srm_Pr.tenant_id = tenantId;
  1129. srm_Pr.factory_id = factoryid;
  1130. srm_Pr.bang_id = bangId;
  1131. if (sentrys != null)
  1132. {
  1133. srm_Pr.sentry_id = sentrys.Id;
  1134. }
  1135. //_srm_pr_main.InsertOne(srm_Pr);
  1136. decimal? totalLeadTime = leadTime.transportation_leadtime + leadTime.stock_leadtime + leadTime.production_leadtime + leadTime.order_leadtime;
  1137. srm_Pr.totalLeadTime= totalLeadTime;
  1138. srm_Pr.create_time = DateTime.Now;
  1139. sRMPR.srm_Pr_Main.Add(srm_Pr);
  1140. });
  1141. if (sRMPR.srm_Pr_Main.Any())
  1142. {
  1143. sRMPR.srm_Pr_Main.OrderBy(x => x.totalLeadTime.GetValueOrDefault()).ThenBy(x => x.pr_orderprice.GetValueOrDefault()).First().isbestoptions = true;
  1144. }
  1145. sRMPR.item_no = returnlist.num;
  1146. sRMPR.orderentry_id = returnlist.sentry_id;
  1147. sRMPR.lastStartTmie = DateTime.Now.AddDays((double)sRMPR.srm_Pr_Main.MinBy(x=>x.totalLeadTime).totalLeadTime);//减去提前期
  1148. return sRMPR;
  1149. }
  1150. // 生成订单编号 字母+年月日+8位随机数+时间戳
  1151. private string getOrderNum(string preCode)
  1152. {
  1153. string Dates = DateTime.Now.ToString("yyyyMMdd");//获取当前时间
  1154. Random Rdm = new Random(Guid.NewGuid().GetHashCode());//随机数
  1155. TimeSpan ts = DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, 0);//时间戳
  1156. string newts = Convert.ToInt64(ts.TotalMilliseconds).ToString();//时间戳
  1157. string new_orderNum = preCode + Dates + Rdm.Next(0, 100000000) + newts;
  1158. return new_orderNum;
  1159. }
  1160. /// <summary>
  1161. /// 生成委外工单
  1162. /// </summary>
  1163. /// <param name="returnlist"></param>
  1164. /// <param name="factoryid"></param>
  1165. private mo_mes_oorder CreateMesOOder(BomChildExamineDto returnlist, long tenantId, long factoryid, long bangId, List<ICItemLeadTimeDto> iCItemLeadTimes, List<mo_srm_purchase> supplierList, DateTime deliveryDate)
  1166. {
  1167. mo_mes_oorder oOrder = new mo_mes_oorder();
  1168. oOrder.id = help.NextId();
  1169. oOrder.GenerateNewId();
  1170. oOrder.oorder_no = getOrderNum("WW");//生产工单编号
  1171. oOrder.oorder_type = "委外工单";//生产工单类型
  1172. oOrder.oorder_date = DateTime.Now;//委外订单日期
  1173. oOrder.oorder_state = "已提交";//订单状态
  1174. oOrder.ooentry_prd = 10000;//生产组织
  1175. oOrder.ooentry_prdname = "1000";//生产组织名称
  1176. oOrder.ooentry_wrkc = 10000;//工作中心id
  1177. oOrder.ooentry_wrkcname = "10001";//工作中心名称
  1178. oOrder.planner_num = "wwww";//计划员工号
  1179. oOrder.planner_name = "qqq";//计划员名称
  1180. oOrder.ooentry_stime = returnlist.kitting_time == null ? DateTime.Now.AddDays(1) : returnlist.kitting_time.GetValueOrDefault().AddDays(1);//计划开工日期
  1181. oOrder.ooentry_etime = oOrder.ooentry_stime.GetValueOrDefault().AddDays(7);//计划完工日期
  1182. oOrder.product_code = "产品代码";//产品代码
  1183. oOrder.ffms_number = "1000";//fms旧料号
  1184. oOrder.product_name = "test";//产品名称
  1185. oOrder.specification_model = returnlist.model;//规格型号
  1186. oOrder.bom_number = returnlist.bom_number;//bom编码
  1187. oOrder.unit = returnlist.unit;//单位
  1188. oOrder.morder_progress = "";//工单进度
  1189. oOrder.morder_production_number = returnlist.lack_qty;//工单生产数量(计划数量)
  1190. oOrder.need_number = returnlist.lack_qty;//需求数量
  1191. oOrder.remaining_number = returnlist.lack_qty;//剩余可用数量
  1192. oOrder.work_number = 0;//报工数量
  1193. oOrder.inspection_number = 0;//报检数量
  1194. oOrder.qualified_number = 0;//合格数量
  1195. oOrder.inventory_number = 0;//入库数量
  1196. oOrder.notice_qty = 0;//已开通知单数量
  1197. oOrder.moentry_on = 1;//启动状态
  1198. //oOrder.start_time = DateTime.Now;//开始时间
  1199. //oOrder.pause_time = DateTime.Now;//最近暂停时间
  1200. //oOrder.restart_time = DateTime.Now;//最近重启时间
  1201. oOrder.project_name = returnlist.item_name;//项目名称
  1202. oOrder.sent_status = 1;//发料状态 1-待发料 2-已发料
  1203. oOrder.production_unit = returnlist.unit;//加工单位
  1204. oOrder.production_unit_code = "";//加工单位编码
  1205. oOrder.need_icitem_status = 1;//所需物料是否充足 1-充足 0-缺料
  1206. oOrder.tenant_id = tenantId;
  1207. oOrder.factory_id = factoryid;
  1208. oOrder.bang_id = bangId;
  1209. oOrder.sentry_id = returnlist.sentry_id;
  1210. return oOrder;
  1211. //_mes_oorder.InsertOne(oOrder);
  1212. }
  1213. /// <summary>
  1214. /// 计算在途
  1215. /// </summary>
  1216. public void CalcInTransit(crm_seorderentry sentrys, BomChildExamineDto item, long bangid, DateTime plan_date)
  1217. {
  1218. var occupylist = _purchaseOrderAppService.CheckPurchaseOrder(sentrys, item.item_id, item.lack_qty, plan_date, planList, bangid);
  1219. if (occupylist.Any())
  1220. {
  1221. decimal occqty = occupylist.Sum(s => s.qty.GetValueOrDefault());
  1222. item.purchase_occupy_qty = occqty;
  1223. item.lack_qty -= occqty;
  1224. item.purchase_occupy_list = new List<purchase_occupy>();
  1225. item.kitting_time = occupylist[0].etime;
  1226. occupylist.ForEach(s => {
  1227. purchase_occupy ocp = new purchase_occupy();
  1228. ocp.id = s.id;
  1229. ocp.stime = s.stime;
  1230. ocp.etime = s.etime;
  1231. ocp.qty = s.qty;
  1232. ocp.type = s.type;
  1233. var polist = srm_Po_Lists.Find(f => f.id == s.polist_id);
  1234. if (polist != null)
  1235. {
  1236. ocp.po_billno = polist.po_billno;
  1237. }
  1238. item.purchase_occupy_list.Add(ocp);
  1239. });
  1240. srm_Po_Occupies.AddRange(occupylist);
  1241. srm_Po_OccupiesInsert.AddRange(occupylist);
  1242. }
  1243. }
  1244. public void PackageSRMPR(BomChildExamineDto item,long bangid,DateTime? plan_date, crm_seorderentry sentrys)
  1245. {
  1246. //采购申请
  1247. var SRMPRDto = CreateSRMPR(item, param.tenantId, param.factoryId, bangid, item.erp_cls, leadTimeList, supplierList, planList, plan_date.Value, sentrys);
  1248. item.purchase_list = new List<purchase>();
  1249. if (SRMPRDto.srm_Pr_Main != null)
  1250. {
  1251. for(int i=0;i< SRMPRDto.srm_Pr_Main.Count;i++)
  1252. {
  1253. purchase pur = new purchase();
  1254. pur.Id = SRMPRDto.srm_Pr_Main[i].id;
  1255. pur.pr_billno = SRMPRDto.srm_Pr_Main[i].pr_billno;
  1256. pur.pr_purchasenumber = SRMPRDto.srm_Pr_Main[i].pr_purchasenumber;
  1257. pur.pr_purchasename = SRMPRDto.srm_Pr_Main[i].pr_purchasename;
  1258. pur.pr_rqty = SRMPRDto.srm_Pr_Main[i].pr_rqty;
  1259. pur.pr_aqty = SRMPRDto.srm_Pr_Main[i].pr_aqty;
  1260. pur.pr_sqty = SRMPRDto.srm_Pr_Main[i].pr_sqty;
  1261. pur.pr_parrive_date = SRMPRDto.srm_Pr_Main[i].pr_parrive_date;
  1262. pur.pr_rarrive_date = SRMPRDto.srm_Pr_Main[i].pr_rarrive_date;
  1263. pur.pr_pur_affirm_date = SRMPRDto.srm_Pr_Main[i].pr_pur_affirm_date;
  1264. pur.pr_sysprice = SRMPRDto.srm_Pr_Main[i].pr_sysprice;
  1265. pur.pr_orderprice = SRMPRDto.srm_Pr_Main[i].pr_orderprice;
  1266. pur.pr_price = SRMPRDto.srm_Pr_Main[i].pr_price;
  1267. pur.pr_rate = SRMPRDto.srm_Pr_Main[i].pr_rate;
  1268. pur.isbestoptions = SRMPRDto.srm_Pr_Main[i].isbestoptions;
  1269. item.purchase_list.Add(pur);
  1270. }
  1271. }
  1272. if (item.erp_cls == 3)
  1273. {
  1274. item.purchase_qty = item.lack_qty;
  1275. item.purchase_list = new List<purchase>();
  1276. item.kitting_time = SRMPRDto.lastStartTmie;
  1277. }
  1278. SRMPRDtoList.Add(SRMPRDto);
  1279. }
  1280. }
  1281. }