CalcBomViewAppService.cs 57 KB

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