ProductionScheduleAppService.cs 162 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770
  1. using Business.Business.Dto;
  2. using Business.Core.Utilities;
  3. using Business.Domain;
  4. using Business.Dto;
  5. using Business.EntityFrameworkCore.SqlRepositories;
  6. using Business.ResourceExamineManagement.Dto;
  7. using Business.StructuredDB.Production;
  8. using System;
  9. using System.Collections.Generic;
  10. using System.Collections.Immutable;
  11. using System.Configuration;
  12. using System.Linq;
  13. using System.Threading.Tasks;
  14. using System.Transactions;
  15. using Volo.Abp.Application.Services;
  16. using Volo.Abp.MultiTenancy;
  17. using Microsoft.Extensions.Configuration;
  18. using MongoDB.Driver.Linq;
  19. using Amazon.Runtime.Internal.Util;
  20. using IdentityModel.Client;
  21. namespace Business.ResourceExamineManagement
  22. {
  23. /// <summary>
  24. /// 生产排产服务
  25. /// </summary>
  26. public class ProductionScheduleAppService : ApplicationService
  27. {
  28. #region 服务
  29. /// <summary>
  30. /// 物料
  31. /// </summary>
  32. private ISqlRepository<ItemMaster> _itemMaster;
  33. /// <summary>
  34. /// 工单
  35. /// </summary>
  36. private ISqlRepository<WorkOrdMaster> _workOrdMaster;
  37. /// <summary>
  38. /// 工单物料明细
  39. /// </summary>
  40. private ISqlRepository<WorkOrdDetail> _workOrdDetail;
  41. /// <summary>
  42. /// 工单工艺路线明细
  43. /// </summary>
  44. private ISqlRepository<WorkOrdRouting> _workOrdRouting;
  45. /// <summary>
  46. /// 库存主数据
  47. /// </summary>
  48. private ISqlRepository<InvMaster> _invMaster;
  49. /// <summary>
  50. /// 生产线明细
  51. /// </summary>
  52. private ISqlRepository<ProdLineDetail> _prodLineDetail;
  53. /// <summary>
  54. /// 生产周期明细
  55. /// </summary>
  56. private ISqlRepository<PeriodSequenceDet> _periodSequenceDet;
  57. /// <summary>
  58. /// 排产结果明细
  59. /// </summary>
  60. private ISqlRepository<ScheduleResultOpMaster> _scheduleResultOpMaster;
  61. /// <summary>
  62. /// 工作日历数据
  63. /// </summary>
  64. private ISqlRepository<ShopCalendarWorkCtr> _shopCalendarWorkCtr;
  65. /// <summary>
  66. /// 产线休息时间记录表
  67. /// </summary>
  68. private ISqlRepository<QualityLineWorkDetail> _qualityLineWorkDetail;
  69. /// <summary>
  70. /// 产线人员配置表
  71. /// </summary>
  72. private ISqlRepository<ProdLineDetailRunCrew> _prodLineDetailRunCrew;
  73. /// <summary>
  74. /// 加班设置表
  75. /// </summary>
  76. private ISqlRepository<ResourceOccupancyTime> _resourceOccupancyTime;
  77. /// <summary>
  78. /// 加班设置表
  79. /// </summary>
  80. private ISqlRepository<GeneralizedCodeMaster> _generalizedCodeMaster;
  81. /// <summary>
  82. /// 节假日记录表
  83. /// </summary>
  84. private ISqlRepository<HolidayMaster> _holidayMaster;
  85. /// <summary>
  86. /// 排产异常记录
  87. /// </summary>
  88. private ISqlRepository<ScheduleExceptionMaster> _scheduleExceptionMaster;
  89. /// <summary>
  90. /// 雪花算法
  91. /// </summary>
  92. SnowFlake help = new SnowFlake();
  93. private readonly ICurrentTenant _currentTenant;
  94. /// <summary>
  95. /// 工作日历数据
  96. /// </summary>
  97. private List<ShopCalendarWorkCtr> calendars;
  98. /// <summary>
  99. /// 产线休息记录数据
  100. /// </summary>
  101. private List<QualityLineWorkDetail> qualityLines;
  102. /// <summary>
  103. /// 节假日记录数据
  104. /// </summary>
  105. private List<HolidayMaster> holidays;
  106. /// <summary>
  107. /// 生产线UPH设置
  108. /// </summary>
  109. private List<ProdLineDetailRunCrew> prodLineDetailRunCrews;
  110. /// <summary>
  111. /// 加班设置
  112. /// </summary>
  113. private List<ResourceOccupancyTime> resourceOccupancyTimes;
  114. /// <summary>
  115. /// 工厂id
  116. /// </summary>
  117. private string domain = "";
  118. #endregion
  119. #region 构造函数
  120. /// <summary>
  121. /// 构造函数
  122. /// </summary>
  123. public ProductionScheduleAppService(
  124. ISqlRepository<ItemMaster> itemMaster,
  125. ISqlRepository<WorkOrdMaster> workOrdMaster,
  126. ISqlRepository<WorkOrdDetail> workOrdDetail,
  127. ISqlRepository<WorkOrdRouting> workOrdRouting,
  128. ISqlRepository<ProdLineDetail> prodLineDetail,
  129. ISqlRepository<ProdLineDetailRunCrew> prodLineDetailRunCrew,
  130. ISqlRepository<ResourceOccupancyTime> resourceOccupancyTime,
  131. ISqlRepository<PeriodSequenceDet> periodSequenceDet,
  132. ISqlRepository<ScheduleResultOpMaster> scheduleResultOpMaster,
  133. ISqlRepository<InvMaster> invMaster,
  134. ISqlRepository<ShopCalendarWorkCtr> shopCalendarWorkCtr,
  135. ISqlRepository<QualityLineWorkDetail> qualityLineWorkDetail,
  136. ISqlRepository<HolidayMaster> holidayMaster,
  137. ISqlRepository<GeneralizedCodeMaster> generalizedCodeMaster,
  138. ICurrentTenant currentTenant,
  139. ISqlRepository<ScheduleExceptionMaster> scheduleExceptionMaster
  140. )
  141. {
  142. _itemMaster = itemMaster;
  143. _workOrdMaster = workOrdMaster;
  144. _workOrdDetail = workOrdDetail;
  145. _workOrdRouting = workOrdRouting;
  146. _prodLineDetail = prodLineDetail;
  147. _prodLineDetailRunCrew = prodLineDetailRunCrew;
  148. _resourceOccupancyTime = resourceOccupancyTime;
  149. _periodSequenceDet = periodSequenceDet;
  150. _scheduleResultOpMaster = scheduleResultOpMaster;
  151. _invMaster = invMaster;
  152. _shopCalendarWorkCtr = shopCalendarWorkCtr;
  153. _qualityLineWorkDetail = qualityLineWorkDetail;
  154. _holidayMaster = holidayMaster;
  155. _generalizedCodeMaster = generalizedCodeMaster;
  156. _currentTenant = currentTenant;
  157. _scheduleExceptionMaster = scheduleExceptionMaster;
  158. }
  159. #endregion
  160. /// <summary>
  161. /// 生产排产-定时任务
  162. /// </summary>
  163. public async void DoExt()
  164. {
  165. //定时任务排产:获取工厂id
  166. IConfiguration configuration = new ConfigurationBuilder().AddJsonFile("appsettings.json", optional: true, reloadOnChange: true).Build();
  167. domain = configuration.GetConnectionString("Factory_id");
  168. //获取排产锁定期
  169. var generalizedCodeMaster = _generalizedCodeMaster.Select(p => p.FldName == "SystemConfig" && p.Val == "WorkOrderLockPeriod" && p.Domain == domain && p.IsActive).FirstOrDefault();
  170. decimal lockDays = generalizedCodeMaster != null ? generalizedCodeMaster.UDeci1 : 0;
  171. //获取需要排产的工单(获取四周的工单:正常工单+已审批通过的特殊工单)
  172. DateTime endDate = DateTime.Now.Date.AddWeeks(4).AddDays(1);
  173. DateTime startDate = DateTime.Now.Date;
  174. var workOrds = _workOrdMaster.Select(p => p.IsActive && p.Domain == domain && p.OrdDate < endDate && p.OrdDate >= startDate && string.IsNullOrEmpty(p.Status) && (string.IsNullOrEmpty(p.Typed) || (!string.IsNullOrEmpty(p.Typed) && p.BusinessID >0 ))).ToList();
  175. await DoProductSchedule(workOrds, domain, 1);
  176. }
  177. /// <summary>
  178. /// 生产排产
  179. /// </summary>
  180. /// <param name="workOrds">工单</param>
  181. /// <param name="factoryid">工单的工厂id</param>
  182. /// <param name="type">排产类型:1-自动排产;2-手动排产</param>
  183. /// <returns></returns>
  184. public async Task DoProductSchedule(List<WorkOrdMaster> workOrds, string factoryid,int type)
  185. {
  186. //记录工厂id
  187. domain = factoryid;
  188. if (workOrds.Count == 0)//没有工单需要排产
  189. {
  190. return;
  191. }
  192. //工单排产的最早日期
  193. DateTime earlist = DateTime.Now.Date.AddDays(1);
  194. //特殊工单指定时间开工,不需要计算产能,只需要计算时长即可
  195. var tsWorkOrds = workOrds.Where(p => !string.IsNullOrEmpty(p.Typed)).ToList();
  196. //正常工单
  197. var zcWorkOrds = workOrds.Where(p => string.IsNullOrEmpty(p.Typed)).ToList();
  198. //2、获取数据
  199. //获取工单工艺路径数据
  200. List<WorkOrdRouting> workOrdRoutings = _workOrdRouting.Select(p => workOrds.Select(m => m.WorkOrd).Contains(p.WorkOrd) && p.ParentOp == 0 && p.Domain == domain && p.Status != "C" && p.IsActive);
  201. //特殊工单的工艺路线
  202. List<WorkOrdRouting> tsWoRoutings = workOrdRoutings.Where(p => tsWorkOrds.Select(m => m.WorkOrd).Contains(p.WorkOrd)).ToList();
  203. //获取物料对应的生产线信息:物料、工序对应的生产线
  204. List<ProdLineDetail> prodLines = _prodLineDetail.Select(p => workOrds.Select(m => m.ItemNum).Contains(p.Part) && p.Domain == domain && p.IsActive);
  205. List<string> lines = prodLines.Select(p => p.Line).ToList();
  206. //获取非标准产线人员配置
  207. prodLineDetailRunCrews = _prodLineDetailRunCrew.Select(x => prodLines.Select(p => p.RecID).Contains(x.ProdLineDetailRecID) && x.IsActive && x.Domain == domain).ToList();
  208. //获取加班设置
  209. resourceOccupancyTimes = _resourceOccupancyTime.Select(x => prodLines.Select(p => p.Line).Contains(x.Resource) && x.IsActive && x.Domain == domain && x.StartTime.Value > DateTime.Now).ToList();
  210. //获取生产周期数据,TODO:需要过滤锁定期之外的工单
  211. List<PeriodSequenceDet> dbPeriodSequences = _periodSequenceDet.Select(p => lines.Contains(p.Line) && p.PlanDate >= earlist && p.Domain == domain && p.IsActive);
  212. //获取当前日期往后的排产记录数据,TODO:需要过滤锁定期之外的工单
  213. List<ScheduleResultOpMaster> dbSchedules = _scheduleResultOpMaster.Select(p => lines.Contains(p.Line) && p.WorkDate >= earlist && p.Domain == domain);
  214. //获取工作日历数据:产线的工作日历+默认的工作日历
  215. calendars = _shopCalendarWorkCtr.Select(p => (lines.Contains(p.ProdLine) || string.IsNullOrEmpty(p.ProdLine)) && p.Domain == domain && p.IsActive);
  216. //获取产线休息记录数据
  217. qualityLines = _qualityLineWorkDetail.Select(p => lines.Contains(p.ProdLine) && p.Domain == domain && p.IsActive);
  218. //获取节假日记录数据
  219. holidays = _holidayMaster.Select(p => p.Domain == domain && p.IsActive && p.Dated >= earlist);
  220. //排产前校验
  221. List<ScheduleExceptionMaster> exceptions = BeforeScheduleCheck(workOrds, workOrdRoutings, prodLines,type);
  222. if (exceptions.Any())
  223. {
  224. using (TransactionScope scope = new TransactionScope())
  225. {
  226. try
  227. {
  228. //记录排产异常数据
  229. _scheduleExceptionMaster.Insert(exceptions);
  230. scope.Complete();
  231. }
  232. catch (Exception ex)
  233. {
  234. new NLogHelper("ProductionScheduleAppService").WriteLog("DoProductSchedule", "保存排产异常数据失败:" + ex.Message, _currentTenant.Id.ToString());
  235. scope.Dispose();
  236. }
  237. }
  238. return;
  239. }
  240. //3、排产
  241. //生产周期
  242. List<PeriodSequenceDet> periodSequenceDtls = new List<PeriodSequenceDet>();
  243. //排产记录表
  244. List<ScheduleResultOpMaster> scheduleMasters = new List<ScheduleResultOpMaster>();
  245. //排产结果
  246. List<ScheduleResultOpMaster> allResults = new List<ScheduleResultOpMaster>();
  247. allResults.AddRange(dbSchedules);
  248. //记录特殊工单排产结果
  249. List<string> ypcWorkOrds = new List<string>();
  250. foreach (var item in zcWorkOrds)
  251. {
  252. //记录产线占用情况
  253. allResults.AddRange(scheduleMasters);
  254. //当前工单工艺路线主产线的关键工序
  255. var curRoutings = workOrdRoutings.Where(p => p.ItemNum == item.ItemNum && p.ParentOp == 0 && p.MilestoneOp).OrderBy(p=>p.OP).ToList();
  256. //当前工单的产线明细
  257. var curProdLines = prodLines.Where(p => p.Part == item.ItemNum).ToList();
  258. //产线排产
  259. LineSchedule(item, curRoutings, curProdLines, periodSequenceDtls, scheduleMasters, allResults, tsWorkOrds, ypcWorkOrds, tsWoRoutings);
  260. List<ScheduleResultOpMaster> scheduleList = scheduleMasters.Where(s => s.WorkOrd == item.WorkOrd).ToList();
  261. if (scheduleList.Any())
  262. {
  263. item.OrdDate = scheduleList.Min(s => s.WorkStartTime);
  264. item.DueDate = scheduleList.Max(s => s.WorkEndTime);
  265. }
  266. }
  267. //判断是否有特殊工单没有排产,如果有,则对剩余特殊工单排产
  268. var notSchedules = tsWorkOrds.Where(p => !ypcWorkOrds.Contains(p.WorkOrd)).ToList();
  269. List<WorkOrdMstDto> workDtos = new List<WorkOrdMstDto>();
  270. foreach (var item in notSchedules)
  271. {
  272. int op = tsWoRoutings.Where(p => p.WorkOrd == item.WorkOrd).OrderByDescending(p => p.OP).First().OP;
  273. workDtos.Add(new WorkOrdMstDto
  274. {
  275. WorkOrd = item.WorkOrd,
  276. ItemNum = item.ItemNum,
  277. QtyOrded = item.QtyOrded,
  278. OrdDate = item.OrdDate.GetValueOrDefault(),
  279. ProdLine = item.ProdLine,
  280. LbrVar = item.LbrVar * 60,
  281. Worked = 0,
  282. QtyWorked = 0,
  283. Op = op
  284. });
  285. }
  286. TsLineSchedule(workDtos, periodSequenceDtls, scheduleMasters);
  287. //处理特殊工单计划开始日期、计划结束日期
  288. foreach (var item in tsWorkOrds)
  289. {
  290. List<ScheduleResultOpMaster> scheduleList = scheduleMasters.Where(s => s.WorkOrd == item.WorkOrd).ToList();
  291. if (scheduleList.Any())
  292. {
  293. item.OrdDate = scheduleList.Min(s => s.WorkStartTime);
  294. item.DueDate = scheduleList.Max(s => s.WorkEndTime);
  295. }
  296. }
  297. using (TransactionScope scope = new TransactionScope())
  298. {
  299. try
  300. {
  301. //记录排产数据
  302. _workOrdMaster.Update(workOrds);
  303. _periodSequenceDet.Insert(periodSequenceDtls);
  304. _scheduleResultOpMaster.Insert(scheduleMasters);
  305. scope.Complete();
  306. }
  307. catch (Exception ex)
  308. {
  309. new NLogHelper("ProductionScheduleAppService").WriteLog("DoProductSchedule", "保存排产数据失败:" + ex.Message, _currentTenant.Id.ToString());
  310. scope.Dispose();
  311. }
  312. }
  313. }
  314. /// <summary>
  315. /// 排产前校验
  316. /// </summary>
  317. /// <param name="workOrds">待排产工单</param>
  318. /// <param name="workOrdRoutings">工单工艺路线</param>
  319. /// <param name="prodLines">产线明细</param>
  320. /// <param name="type">排产类型:1-自动排产,2-手动排产</param>
  321. /// <returns></returns>
  322. public List<ScheduleExceptionMaster> BeforeScheduleCheck(List<WorkOrdMaster> workOrds,List<WorkOrdRouting> workOrdRoutings, List<ProdLineDetail> prodLines,int type)
  323. {
  324. List<ScheduleExceptionMaster> exceptions = new List<ScheduleExceptionMaster>();
  325. ScheduleExceptionMaster entity;
  326. foreach (var item in workOrds)
  327. {
  328. if (!string.IsNullOrEmpty(item.Typed))//特殊工单
  329. {
  330. //只需要校验有没有维护工艺路线即可
  331. var routings = workOrdRoutings.Where(p=>p.ItemNum == item.ItemNum).ToList();
  332. if (!routings.Any())
  333. {
  334. entity = new ScheduleExceptionMaster();
  335. entity.Domain = item.Domain;
  336. entity.WorkOrd = item.WorkOrd;
  337. entity.ItemNum = item.ItemNum;
  338. entity.CreateTime = DateTime.Now;
  339. entity.Remark = "排产异常:工单没有维护工艺路线,请维护后再操作!";
  340. entity.Type = type == 1 ? "自动排产" : "手动排产";
  341. exceptions.Add(entity);
  342. }
  343. continue;
  344. }
  345. var curRoutings = workOrdRoutings.Where(p => p.ItemNum == item.ItemNum && p.MilestoneOp).OrderBy(p=>p.OP).Select(p=>p.OP).ToList();
  346. //判断当前工单主产线是否设置了关键工序
  347. if (!curRoutings.Any())//当前工单没有维护关键工序
  348. {
  349. entity = new ScheduleExceptionMaster();
  350. entity.Domain = item.Domain;
  351. entity.WorkOrd = item.WorkOrd;
  352. entity.ItemNum = item.ItemNum;
  353. entity.CreateTime = DateTime.Now;
  354. entity.Remark = "排产异常:工单的工艺路径没有维护关键工序,请维护后再操作!";
  355. entity.Type = type == 1 ? "自动排产" : "手动排产";
  356. exceptions.Add(entity);
  357. continue;
  358. }
  359. //获取当前工单物料对应的产线信息
  360. var lineDetails = prodLines.Where(x => x.Part == item.ItemNum && curRoutings.Contains(x.Op)).ToList();
  361. if (!lineDetails.Any())
  362. {
  363. entity = new ScheduleExceptionMaster();
  364. entity.Domain = item.Domain;
  365. entity.WorkOrd = item.WorkOrd;
  366. entity.ItemNum = item.ItemNum;
  367. entity.CreateTime = DateTime.Now;
  368. entity.Remark = "排产异常:工单的关键工序没有维护产线数据,请维护后再操作!";
  369. entity.Type = type == 1 ? "自动排产" : "手动排产";
  370. exceptions.Add(entity);
  371. continue;
  372. }
  373. //校验关键工序是否维护了产线
  374. List<LineStartDto> lines = new List<LineStartDto>();
  375. foreach (var op in curRoutings)
  376. {
  377. var curLines = lineDetails.Where(p => p.Op == op).ToList();
  378. if (!curLines.Any())//当前Op没有维护产线
  379. {
  380. entity = new ScheduleExceptionMaster();
  381. entity.Domain = item.Domain;
  382. entity.WorkOrd = item.WorkOrd;
  383. entity.ItemNum = item.ItemNum;
  384. entity.CreateTime = DateTime.Now;
  385. entity.Remark = "排产异常:工单的关键工序["+ op + "]没有维护产线数据,请维护后再操作!";
  386. entity.Type = type == 1 ? "自动排产" : "手动排产";
  387. exceptions.Add(entity);
  388. }
  389. foreach (var line in curLines)
  390. {
  391. lines.Add(new LineStartDto {
  392. Line = line.Line,
  393. Op = op
  394. });
  395. }
  396. }
  397. //校验一条产线是否维护了多个关键工序
  398. List<string> pdLines = lines.Select(p => p.Line).Distinct().ToList();
  399. foreach (var line in pdLines)
  400. {
  401. var curLines = lines.Where(p => p.Line == line).ToList();
  402. if (curLines.Count() > 1)//当前物料的多个关键工序对应一条产线
  403. {
  404. entity = new ScheduleExceptionMaster();
  405. entity.Domain = item.Domain;
  406. entity.WorkOrd = item.WorkOrd;
  407. entity.ItemNum = item.ItemNum;
  408. entity.CreateTime = DateTime.Now;
  409. entity.Remark = "排产异常:工单的多个关键工序[" + string.Join("、",curLines.Select(p=>p.Op).ToList()) + "]对应同一条产线,请调整后再操作!";
  410. entity.Type = type == 1 ? "自动排产" : "手动排产";
  411. exceptions.Add(entity);
  412. }
  413. }
  414. //校验主产线关键工序对应的产线是否维护了工作日历
  415. var curCalendars = calendars.Where(x => lineDetails.Select(p => p.Line).Contains(x.ProdLine) || string.IsNullOrEmpty(x.ProdLine)).ToList();
  416. foreach (var rut in lineDetails)
  417. {
  418. //获取当前产线维护的工作日历
  419. var lineCals = curCalendars.Where(p => p.ProdLine == rut.Line).ToList();
  420. if (!lineCals.Any())//当前产线未维护工作日历
  421. {
  422. lineCals = calendars.Where(p => string.IsNullOrEmpty(p.ProdLine)).ToList();
  423. if (!lineCals.Any() || lineCals.Select(p => p.WeekDay).Distinct().Count() != 7)
  424. {
  425. entity = new ScheduleExceptionMaster();
  426. entity.Domain = item.Domain;
  427. entity.WorkOrd = item.WorkOrd;
  428. entity.ItemNum = item.ItemNum;
  429. entity.CreateTime = DateTime.Now;
  430. entity.Remark = "排产异常:产线["+rut.Line+ "]没有维护工作日历且标准工作日历未维护完全,请维护后再操作!";
  431. entity.Type = type == 1 ? "自动排产" : "手动排产";
  432. exceptions.Add(entity);
  433. }
  434. }
  435. else if (lineCals.Select(p => p.WeekDay).Distinct().Count() != 7)//当前产线维护了工作日历,但是没有维护完全
  436. {
  437. entity = new ScheduleExceptionMaster();
  438. entity.Domain = item.Domain;
  439. entity.WorkOrd = item.WorkOrd;
  440. entity.ItemNum = item.ItemNum;
  441. entity.CreateTime = DateTime.Now;
  442. entity.Remark = "排产异常:产线[" + rut.Line + "]工作日历没有维护完整,请维护后再操作!";
  443. entity.Type = type == 1 ? "自动排产" : "手动排产";
  444. exceptions.Add(entity);
  445. }
  446. }
  447. }
  448. return exceptions;
  449. }
  450. /// <summary>
  451. /// 排产
  452. /// </summary>
  453. /// <param name="workOrd">工单</param>
  454. /// <param name="workOrdRoutings">当前工单的工艺路线的关键工序(有几个关键工序就有几条产线)</param>
  455. /// <param name="prodLines">当前工单的产线明细</param>
  456. /// <param name="periodsDet">生产周期</param>
  457. /// <param name="scheduleResults">排产结果</param>
  458. /// <param name="allResults">产线占用记录</param>
  459. /// <param name="tsWorkOrds">特殊工单</param>
  460. /// <param name="ypcWorkOrds">已排产特殊工单的工单编号</param>
  461. /// <param name="tsWoRoutings">特殊工单的工艺路线</param>
  462. public void LineSchedule(WorkOrdMaster workOrd, List<WorkOrdRouting> workOrdRoutings, List<ProdLineDetail> prodLines,List<PeriodSequenceDet> periodsDet, List<ScheduleResultOpMaster> scheduleResults, List<ScheduleResultOpMaster> allResults,List<WorkOrdMaster> tsWorkOrds,List<string> ypcWorkOrds, List<WorkOrdRouting> tsWoRoutings)
  463. {
  464. //生产周期
  465. List<PeriodSequenceDet> curSequences = new List<PeriodSequenceDet>();
  466. //排产明细
  467. List<ScheduleResultOpMaster> curScheduleRsts = new List<ScheduleResultOpMaster>();
  468. //记录上一产线排产开始时间
  469. LineStartDto lineStart = new LineStartDto();
  470. TimeSpan span = TimeSpan.Zero;
  471. //第一层级工序有几个关键工序,就有几条产线
  472. for (int i = 0; i < workOrdRoutings.Count; i++)
  473. {
  474. //产线实际排产开始时间
  475. if (i == 0)//第一条产线
  476. {
  477. lineStart = DealStartTime(workOrd, workOrdRoutings[i].OP, prodLines, allResults);
  478. }
  479. else
  480. {
  481. //获取前一产线排产开始时间,通过提前期计算当前产线排产开始时间
  482. lineStart = DealNextStartTime(workOrd, lineStart, workOrdRoutings[i].OP, prodLines, allResults);
  483. }
  484. //当前产线的工作日历
  485. var mLCalendars = calendars.Where(p => p.ProdLine == lineStart.Line || string.IsNullOrEmpty(p.ProdLine)).ToList();
  486. //当前产线的休息时间设置
  487. var mlqtyWorkDtls = qualityLines.Where(p => p.ProdLine == lineStart.Line).ToList();
  488. //产线排产开始时间
  489. DateTime workStartTime = lineStart.StartTime;
  490. //记录特殊工单:获取第一天是否有特殊工单
  491. List<WorkOrdMaster> fstWOMasters = tsWorkOrds.Where(p => p.ProdLine == lineStart.Line && p.OrdDate.Value.Date == workStartTime.Date).OrderBy(p => p.OrdDate).ToList();
  492. List<WorkOrdMstDto> workDtos = new List<WorkOrdMstDto>();
  493. foreach (var item in fstWOMasters)
  494. {
  495. int op = tsWoRoutings.Where(p => p.WorkOrd == item.WorkOrd).OrderByDescending(p => p.OP).First().OP;
  496. workDtos.Add(new WorkOrdMstDto{
  497. WorkOrd = item.WorkOrd,
  498. ItemNum = item.ItemNum,
  499. QtyOrded = item.QtyOrded,
  500. LbrVar = item.LbrVar * 60,
  501. Worked = 0,
  502. QtyWorked = 0,
  503. Op = op
  504. });
  505. }
  506. //记录排产开始第二天及以后安排的特殊工单
  507. var secWOMasters = new List<WorkOrdMaster>();
  508. //特殊工单工作时长(分钟)
  509. decimal sumTsTimes = fstWOMasters.Sum(p => p.LbrVar) * 60;
  510. while (sumTsTimes > 0) //产线排产开始当天安排了特殊工单,则先安排特殊工单
  511. {
  512. secWOMasters.Clear();
  513. //获取当天的产能
  514. LineScheduledDto dto = GetScheduledPoint(lineStart, workStartTime, mLCalendars, mlqtyWorkDtls);
  515. //获取当天的工作时间段
  516. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  517. if (curCalendar == null)
  518. {
  519. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  520. }
  521. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, workStartTime, curCalendar, mlqtyWorkDtls);
  522. //如果当天的可用产能大于特殊工单生产时长,此时需要考虑当天是否安排了其他的特殊工单
  523. if (dto.EffTime > sumTsTimes)
  524. {
  525. //获取特殊工单
  526. secWOMasters = tsWorkOrds.Where(p => p.ProdLine == lineStart.Line && p.OrdDate.Value.Date == workStartTime.Date).OrderBy(p => p.OrdDate).ToList();
  527. //此时需要过滤掉第一天的工单
  528. secWOMasters = secWOMasters.Where(p=> !workDtos.Select(m=>m.WorkOrd).Contains(p.WorkOrd)).ToList();
  529. //记录新增待排产特殊工单
  530. foreach (var item in secWOMasters)
  531. {
  532. int op = tsWoRoutings.Where(p => p.WorkOrd == item.WorkOrd).OrderByDescending(p => p.OP).First().OP;
  533. workDtos.Add(new WorkOrdMstDto
  534. {
  535. WorkOrd = item.WorkOrd,
  536. ItemNum = item.ItemNum,
  537. QtyOrded = item.QtyOrded,
  538. LbrVar = item.LbrVar * 60,
  539. Worked = 0,
  540. QtyWorked = 0,
  541. Op = op
  542. });
  543. }
  544. //特殊工单待排产时长增加新增的特殊工单生产时长
  545. sumTsTimes += secWOMasters.Sum(p => p.LbrVar) * 60;
  546. }
  547. if (dto.EffTime >= sumTsTimes)//当天的可用生产时长满足特殊工单生产时长
  548. {
  549. DateTime beginTime = workStartTime;
  550. DateTime endTime = dto.EndTime;
  551. foreach (var item in workDtos)
  552. {
  553. if (item.LbrVar == item.Worked)//当前工单已排产,跳过
  554. {
  555. continue;
  556. }
  557. //当前工单还需工作时长
  558. decimal needTime = item.LbrVar - item.Worked;
  559. //计算工单排产结束时间
  560. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  561. span = curPoint.EndPoint - beginTime;
  562. //当天工作时间段的有效生产时间(分钟)
  563. decimal effMins = (decimal)span.TotalMinutes;
  564. if (effMins >= needTime)//当前工作时间段即可满足产能
  565. {
  566. endTime = beginTime.AddMinutes((double)needTime);
  567. }
  568. else
  569. {
  570. //获取后续生产时间段
  571. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  572. //剩余需要工作时长
  573. decimal nextMins = needTime - effMins;
  574. foreach (var p in nextPoints)
  575. {
  576. if (p.WorkMinutes >= nextMins)
  577. {
  578. endTime = p.StartPoint.AddMinutes((double)nextMins);
  579. break;
  580. }
  581. nextMins -= p.WorkMinutes;
  582. }
  583. }
  584. //记录生产周期
  585. curSequences.Add(new PeriodSequenceDet
  586. {
  587. Domain = domain,
  588. Line = lineStart.Line,
  589. ItemNum = item.ItemNum,
  590. PlanDate = beginTime.Date,
  591. Period = dto.Period,
  592. OrdQty = item.QtyOrded - item.QtyWorked,
  593. WorkOrds = item.WorkOrd,
  594. Op = item.Op,
  595. IsActive = true,
  596. Status = "",
  597. CreateTime = DateTime.Now
  598. });
  599. //记录排产记录
  600. curScheduleRsts.Add(new ScheduleResultOpMaster
  601. {
  602. Domain = domain,
  603. WorkOrd = item.WorkOrd,
  604. Line = lineStart.Line,
  605. ItemNum = item.ItemNum,
  606. Op = item.Op,
  607. WorkDate = beginTime.Date,
  608. WorkQty = item.QtyOrded - item.QtyWorked,
  609. WorkStartTime = beginTime,
  610. WorkEndTime = endTime,
  611. CreateTime = DateTime.Now
  612. });
  613. //下一工单开始时间=当前工单结束时间,如果位于工作区间结尾,则为下一工作区间开始时间
  614. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  615. if (endTime == curPoint.EndPoint)//结束时间位于工作区间结尾
  616. {
  617. //获取后续生产时间段
  618. var nextPoint = workPoints.Where(p => p.Level == curPoint.Level + 1).FirstOrDefault();
  619. if (nextPoint != null)//存在后续工作区间
  620. {
  621. endTime = nextPoint.StartPoint;
  622. }
  623. }
  624. beginTime = endTime;
  625. //工单排产完成,排产时长=工单工作时长
  626. item.Worked = item.LbrVar;
  627. item.QtyWorked = item.QtyOrded;
  628. sumTsTimes -= needTime;
  629. }
  630. if (dto.EffTime == sumTsTimes)//当天产能完全占用
  631. {
  632. sumTsTimes = 0;//排产完毕,特殊工单时长置0
  633. //获取下一个工作日
  634. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  635. //特殊工单排产完成,占用了当天的全部产能,则需要判断下一个工作日是否存在特殊工单,如果存在,则需要继续排特殊工单
  636. secWOMasters = tsWorkOrds.Where(p => p.ProdLine == lineStart.Line && p.OrdDate.Value.Date == workStartTime.Date).OrderBy(p => p.OrdDate).ToList();
  637. //此时需要过滤掉已排产的工单
  638. secWOMasters = secWOMasters.Where(p => !workDtos.Select(m => m.WorkOrd).Contains(p.WorkOrd)).ToList();
  639. //记录新增待排产特殊工单
  640. foreach (var item in secWOMasters)
  641. {
  642. int op = tsWoRoutings.Where(p => p.WorkOrd == item.WorkOrd).OrderByDescending(p => p.OP).First().OP;
  643. workDtos.Add(new WorkOrdMstDto
  644. {
  645. WorkOrd = item.WorkOrd,
  646. ItemNum = item.ItemNum,
  647. QtyOrded = item.QtyOrded,
  648. LbrVar = item.LbrVar * 60,
  649. Worked = 0,
  650. QtyWorked = 0,
  651. Op = op
  652. });
  653. }
  654. //特殊工单待排产时长增加新增带排产特殊工单生产时长
  655. sumTsTimes += secWOMasters.Sum(p => p.LbrVar) * 60;
  656. }
  657. else {//当天可用生产时长大于特殊工单生产时长
  658. sumTsTimes = 0;//排产完毕,特殊工单时长置0
  659. //处理workStartTime
  660. workStartTime = endTime;
  661. var curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  662. if (endTime == curPoint.EndPoint)
  663. {
  664. var nextPoint = workPoints.Find(p => p.Level == curPoint.Level + 1);
  665. if (nextPoint != null)
  666. {
  667. workStartTime = nextPoint.StartPoint;
  668. }
  669. }
  670. }
  671. }
  672. else//当天的可用产能不满足特殊工单生产时长,则当天产能全部排特殊工单
  673. {
  674. decimal residueTime = dto.EffTime;//当天产能剩余产能(分钟)
  675. DateTime beginTime = workStartTime;//排产开始时间
  676. DateTime endTime = dto.EndTime;//排产结束时间
  677. foreach (var item in workDtos)
  678. {
  679. if (item.LbrVar == item.Worked)//当前工单已排产
  680. {
  681. continue;
  682. }
  683. //当前工单剩余待排产时长(分钟)
  684. decimal needTime = item.LbrVar - item.Worked;
  685. if (residueTime >= needTime)//当天剩余产能满足当前工单的剩余待排产时长
  686. {
  687. //计算工单排产结束时间
  688. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  689. span = curPoint.EndPoint - beginTime;
  690. //当前工作时间段的有效生产时间(分钟)
  691. decimal effMins = (decimal)span.TotalMinutes;
  692. if (effMins >= needTime)//当前工作时间段即可满足产能
  693. {
  694. endTime = beginTime.AddMinutes((double)needTime);
  695. }
  696. else
  697. {
  698. //获取后续生产时间段
  699. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  700. //剩余需要工作时长
  701. decimal nextMins = needTime - effMins;
  702. foreach (var p in nextPoints)
  703. {
  704. if (p.WorkMinutes >= nextMins)
  705. {
  706. endTime = p.StartPoint.AddMinutes((double)nextMins);
  707. break;
  708. }
  709. nextMins -= p.WorkMinutes;
  710. }
  711. }
  712. //记录生产周期
  713. curSequences.Add(new PeriodSequenceDet
  714. {
  715. Domain = domain,
  716. Line = lineStart.Line,
  717. ItemNum = item.ItemNum,
  718. PlanDate = beginTime.Date,
  719. Period = dto.Period,
  720. OrdQty = item.QtyOrded - item.QtyWorked,
  721. WorkOrds = item.WorkOrd,
  722. Op = item.Op,
  723. IsActive = true,
  724. Status = "",
  725. CreateTime = DateTime.Now
  726. });
  727. //记录排产记录
  728. curScheduleRsts.Add(new ScheduleResultOpMaster
  729. {
  730. Domain = domain,
  731. WorkOrd = item.WorkOrd,
  732. Line = lineStart.Line,
  733. ItemNum = item.ItemNum,
  734. Op = item.Op,
  735. WorkDate = beginTime.Date,
  736. WorkQty = item.QtyOrded - item.QtyWorked,
  737. WorkStartTime = beginTime,
  738. WorkEndTime = endTime,
  739. CreateTime = DateTime.Now
  740. });
  741. beginTime = endTime;
  742. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  743. if (endTime == curPoint.EndPoint)
  744. {
  745. var nextPoint = workPoints.Find(p => p.Level == curPoint.Level + 1);
  746. if (nextPoint != null)
  747. {
  748. beginTime = nextPoint.StartPoint;
  749. }
  750. }
  751. //当前工单已排产完成,已排产时间=工单生产时长,已排产数量=工单数量
  752. item.Worked = item.LbrVar;
  753. item.QtyWorked = item.QtyWorked;
  754. //当天剩余产能
  755. residueTime -= needTime;
  756. if (residueTime == 0)
  757. {
  758. break;
  759. }
  760. }
  761. else//当天剩余产能不满足当前工单的剩余待排产时长
  762. {
  763. //计算生产数量
  764. decimal qty = Math.Ceiling(residueTime / item.LbrVar * item.QtyOrded);
  765. //记录生产周期
  766. curSequences.Add(new PeriodSequenceDet
  767. {
  768. Domain = domain,
  769. Line = lineStart.Line,
  770. ItemNum = item.ItemNum,
  771. PlanDate = beginTime.Date,
  772. Period = dto.Period,
  773. OrdQty = qty,
  774. WorkOrds = item.WorkOrd,
  775. Op = item.Op,
  776. IsActive = true,
  777. Status = "",
  778. CreateTime = DateTime.Now
  779. });
  780. //记录排产记录
  781. curScheduleRsts.Add(new ScheduleResultOpMaster
  782. {
  783. Domain = domain,
  784. WorkOrd = item.WorkOrd,
  785. Line = lineStart.Line,
  786. ItemNum = item.ItemNum,
  787. Op = item.Op,
  788. WorkDate = beginTime.Date,
  789. WorkQty = qty,
  790. WorkStartTime = beginTime,
  791. WorkEndTime = endTime,
  792. CreateTime = DateTime.Now
  793. });
  794. item.Worked += residueTime;
  795. item.QtyWorked += qty;
  796. residueTime = 0;
  797. break;
  798. }
  799. }
  800. //特殊工单剩余待排产时长(分钟)
  801. sumTsTimes -= dto.EffTime;
  802. //获取下一个工作日
  803. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  804. }
  805. }
  806. //记录已排产特殊工单
  807. ypcWorkOrds.AddRange(workDtos.Select(p => p.WorkOrd).ToList());
  808. //正常工单排产
  809. //正常工单产线已排产数量
  810. decimal sumQty = 0m;
  811. //产线准备时间(分钟)
  812. decimal sumTimes = 0m;
  813. fstWOMasters.Clear();
  814. workDtos.Clear();
  815. sumTsTimes = 0m;
  816. //正常工单排产第一天标识
  817. bool isFstDay = true;
  818. while (sumQty < workOrd.QtyOrded || sumTsTimes > 0)
  819. {
  820. secWOMasters.Clear();
  821. //获取当天的产能
  822. LineScheduledDto dto = GetScheduledPoint(lineStart, workStartTime, mLCalendars, mlqtyWorkDtls);
  823. //正常工单排产第一天没有特殊工单,第一天之后才需要考虑是否有特殊工单
  824. if (!isFstDay)
  825. {
  826. //获取特殊工单
  827. secWOMasters = tsWorkOrds.Where(p => p.ProdLine == lineStart.Line && p.OrdDate.Value.Date == workStartTime.Date).OrderBy(p => p.OrdDate).ToList();
  828. foreach (var item in secWOMasters)
  829. {
  830. int op = tsWoRoutings.Where(p => p.WorkOrd == item.WorkOrd).OrderByDescending(p => p.OP).First().OP;
  831. workDtos.Add(new WorkOrdMstDto
  832. {
  833. WorkOrd = item.WorkOrd,
  834. ItemNum = item.ItemNum,
  835. QtyOrded = item.QtyOrded,
  836. LbrVar = item.LbrVar * 60,
  837. Worked = 0,
  838. QtyWorked = 0,
  839. Op = op
  840. });
  841. }
  842. //记录特殊工单剩余生产时长
  843. sumTsTimes += secWOMasters.Sum(p => p.LbrVar) * 60;
  844. }
  845. //排产开始时,需要先减去产线准备时间
  846. if (sumTimes < lineStart.setupTime * 60)
  847. {
  848. //当天的可用生产时长能满足提前期
  849. if (dto.EffTime > lineStart.setupTime * 60 - sumTimes)
  850. {
  851. //当天剩余时长(分钟)
  852. decimal residueTime = dto.EffTime - lineStart.setupTime * 60 - sumTimes;
  853. //产线提前期安排完之后,需要考虑当前是否存在特殊工单:
  854. //1、如果当天是排产的最后一天,则先排完正常工单,再安排特殊工单;
  855. //2、如果是排产中间日期,则先安排特殊工单排产
  856. //当天剩余产能
  857. decimal sumAmount = dto.ProductQty - Math.Floor(dto.Rate * (lineStart.setupTime - sumTimes / 60));
  858. //判断已排产数量+当天的产能是否超过工单数量
  859. if (sumQty + sumAmount <= workOrd.QtyOrded)//当天的产能需要全部排产
  860. {
  861. if (sumTsTimes > 0)//当天有特殊工单,先排特殊工单
  862. {
  863. DateTime beginTime = workStartTime;//排产开始时间
  864. DateTime endTime = dto.EndTime;//排产结束时间
  865. //获取当天的工作时间段
  866. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  867. if (curCalendar == null)
  868. {
  869. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  870. }
  871. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, workStartTime, curCalendar, mlqtyWorkDtls);
  872. if (residueTime > sumTsTimes)//当天的可用产能满足特殊工单生产时长
  873. {
  874. //特殊工单排产
  875. foreach (var item in workDtos)
  876. {
  877. if (item.LbrVar == item.Worked)//当前工单已排产,跳过
  878. {
  879. continue;
  880. }
  881. //当前工单还需工作时长
  882. decimal needTime = item.LbrVar - item.Worked;
  883. //计算工单排产结束时间
  884. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  885. span = curPoint.EndPoint - beginTime;
  886. //当天工作时间段的有效生产时间(分钟)
  887. decimal effMins = (decimal)span.TotalMinutes;
  888. if (effMins >= needTime)//当前工作时间段即可满足产能
  889. {
  890. endTime = beginTime.AddMinutes((double)needTime);
  891. }
  892. else
  893. {
  894. //获取后续生产时间段
  895. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  896. //剩余需要工作时长
  897. decimal nextMins = needTime - effMins;
  898. foreach (var p in nextPoints)
  899. {
  900. if (p.WorkMinutes >= nextMins)
  901. {
  902. endTime = p.StartPoint.AddMinutes((double)nextMins);
  903. break;
  904. }
  905. nextMins -= p.WorkMinutes;
  906. }
  907. }
  908. //记录生产周期
  909. curSequences.Add(new PeriodSequenceDet
  910. {
  911. Domain = domain,
  912. Line = lineStart.Line,
  913. ItemNum = item.ItemNum,
  914. PlanDate = beginTime.Date,
  915. Period = dto.Period,
  916. OrdQty = item.QtyOrded - item.QtyWorked,
  917. WorkOrds = item.WorkOrd,
  918. Op = item.Op,
  919. IsActive = true,
  920. Status = "",
  921. CreateTime = DateTime.Now
  922. });
  923. //记录排产记录
  924. curScheduleRsts.Add(new ScheduleResultOpMaster
  925. {
  926. Domain = domain,
  927. WorkOrd = item.WorkOrd,
  928. Line = lineStart.Line,
  929. ItemNum = item.ItemNum,
  930. Op = item.Op,
  931. WorkDate = beginTime.Date,
  932. WorkQty = item.QtyOrded - item.QtyWorked,
  933. WorkStartTime = beginTime,
  934. WorkEndTime = endTime,
  935. CreateTime = DateTime.Now
  936. });
  937. //下一工单开始时间=当前工单结束时间,如果位于工作区间结尾,则为下一工作区间开始时间
  938. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  939. if (endTime == curPoint.EndPoint)//结束时间位于工作区间结尾
  940. {
  941. //获取后续生产时间段
  942. var nextPoint = workPoints.Where(p => p.Level == curPoint.Level + 1).FirstOrDefault();
  943. if (nextPoint != null)//存在后续工作区间
  944. {
  945. endTime = nextPoint.StartPoint;
  946. }
  947. }
  948. beginTime = endTime;
  949. //工单排产完成,排产时长=工单工作时长
  950. item.Worked = item.LbrVar;
  951. item.QtyWorked = item.QtyOrded;
  952. sumTsTimes -= needTime;
  953. }
  954. //处理正常工单开工时间
  955. workStartTime = endTime;
  956. var point = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  957. if (endTime == point.EndPoint)
  958. {
  959. var nextPoint = workPoints.FirstOrDefault(p => p.Level == point.Level + 1);
  960. if (nextPoint != null)
  961. {
  962. workStartTime = nextPoint.StartPoint;
  963. }
  964. }
  965. //剩余产能继续排正常工单
  966. sumAmount = dto.ProductQty - Math.Floor(dto.Rate * (lineStart.setupTime - (sumTimes + sumTsTimes) / 60));
  967. //记录生产周期
  968. curSequences.Add(new PeriodSequenceDet
  969. {
  970. Domain = domain,
  971. Line = lineStart.Line,
  972. ItemNum = workOrd.ItemNum,
  973. PlanDate = workStartTime.Date,
  974. Period = dto.Period,
  975. OrdQty = sumAmount,
  976. WorkOrds = workOrd.WorkOrd,
  977. Op = lineStart.Op,
  978. IsActive = true,
  979. Status = "",
  980. CreateTime = DateTime.Now
  981. });
  982. //记录排产记录
  983. curScheduleRsts.Add(new ScheduleResultOpMaster
  984. {
  985. Domain = domain,
  986. WorkOrd = workOrd.WorkOrd,
  987. Line = lineStart.Line,
  988. ItemNum = workOrd.ItemNum,
  989. Op = lineStart.Op,
  990. WorkDate = workStartTime.Date,
  991. WorkQty = sumAmount,
  992. WorkStartTime = workStartTime,
  993. WorkEndTime = dto.EndTime,
  994. CreateTime = DateTime.Now
  995. });
  996. //累计已排产数量
  997. sumQty += sumAmount;
  998. //继续排下一个工作日
  999. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1000. isFstDay = false;
  1001. //排产完毕,特殊工单时长置0
  1002. sumTsTimes = 0;
  1003. }
  1004. else//当天的可用产能不满足或者刚好满足特殊工单生产时长
  1005. {
  1006. foreach (var item in workDtos)
  1007. {
  1008. if (item.LbrVar == item.Worked)//当前工单已排产
  1009. {
  1010. continue;
  1011. }
  1012. //当前工单剩余待排产时长(分钟)
  1013. decimal needTime = item.LbrVar - item.Worked;
  1014. if (residueTime >= needTime)//当天剩余产能满足当前工单的剩余待排产时长
  1015. {
  1016. //计算工单排产结束时间
  1017. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1018. span = curPoint.EndPoint - beginTime;
  1019. //当前工作时间段的有效生产时间(分钟)
  1020. decimal effMins = (decimal)span.TotalMinutes;
  1021. if (effMins >= needTime)//当前工作时间段即可满足产能
  1022. {
  1023. endTime = beginTime.AddMinutes((double)needTime);
  1024. }
  1025. else
  1026. {
  1027. //获取后续生产时间段
  1028. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  1029. //剩余需要工作时长
  1030. decimal nextMins = needTime - effMins;
  1031. foreach (var p in nextPoints)
  1032. {
  1033. if (p.WorkMinutes >= nextMins)
  1034. {
  1035. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1036. break;
  1037. }
  1038. nextMins -= p.WorkMinutes;
  1039. }
  1040. }
  1041. //记录生产周期
  1042. curSequences.Add(new PeriodSequenceDet
  1043. {
  1044. Domain = domain,
  1045. Line = lineStart.Line,
  1046. ItemNum = item.ItemNum,
  1047. PlanDate = beginTime.Date,
  1048. Period = dto.Period,
  1049. OrdQty = item.QtyOrded - item.QtyWorked,
  1050. WorkOrds = item.WorkOrd,
  1051. Op = item.Op,
  1052. IsActive = true,
  1053. Status = "",
  1054. CreateTime = DateTime.Now
  1055. });
  1056. //记录排产记录
  1057. curScheduleRsts.Add(new ScheduleResultOpMaster
  1058. {
  1059. Domain = domain,
  1060. WorkOrd = item.WorkOrd,
  1061. Line = lineStart.Line,
  1062. ItemNum = item.ItemNum,
  1063. Op = item.Op,
  1064. WorkDate = beginTime.Date,
  1065. WorkQty = item.QtyOrded - item.QtyWorked,
  1066. WorkStartTime = beginTime,
  1067. WorkEndTime = endTime,
  1068. CreateTime = DateTime.Now
  1069. });
  1070. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  1071. if (endTime == curPoint.EndPoint)
  1072. {
  1073. var nextPoint = workPoints.FirstOrDefault(p => p.Level == curPoint.Level + 1);
  1074. if (nextPoint != null)
  1075. {
  1076. endTime = nextPoint.StartPoint;
  1077. }
  1078. }
  1079. beginTime = endTime;
  1080. //当前工单已排产完成,已排产时间=工单生产时长,已排产数量=工单数量
  1081. item.Worked = item.LbrVar;
  1082. item.QtyWorked = item.QtyWorked;
  1083. //当天剩余产能
  1084. residueTime -= needTime;
  1085. if (residueTime == 0)
  1086. {
  1087. break;
  1088. }
  1089. }
  1090. else//当天剩余产能不满足当前工单的剩余待排产时长
  1091. {
  1092. //计算生产数量
  1093. decimal qty = Math.Ceiling(residueTime / item.LbrVar * item.QtyOrded);
  1094. //记录生产周期
  1095. curSequences.Add(new PeriodSequenceDet
  1096. {
  1097. Domain = domain,
  1098. Line = lineStart.Line,
  1099. ItemNum = item.ItemNum,
  1100. PlanDate = beginTime.Date,
  1101. Period = dto.Period,
  1102. OrdQty = qty,
  1103. WorkOrds = item.WorkOrd,
  1104. Op = item.Op,
  1105. IsActive = true,
  1106. Status = "",
  1107. CreateTime = DateTime.Now
  1108. });
  1109. //记录排产记录
  1110. curScheduleRsts.Add(new ScheduleResultOpMaster
  1111. {
  1112. Domain = domain,
  1113. WorkOrd = item.WorkOrd,
  1114. Line = lineStart.Line,
  1115. ItemNum = item.ItemNum,
  1116. Op = item.Op,
  1117. WorkDate = beginTime.Date,
  1118. WorkQty = qty,
  1119. WorkStartTime = beginTime,
  1120. WorkEndTime = endTime,
  1121. CreateTime = DateTime.Now
  1122. });
  1123. item.Worked += residueTime;
  1124. item.QtyWorked += qty;
  1125. break;
  1126. }
  1127. }
  1128. //特殊工单剩余待排产时长(分钟)
  1129. sumTsTimes -= residueTime;
  1130. //获取下一个工作日
  1131. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1132. isFstDay = false;
  1133. }
  1134. }
  1135. else { //当天没有特殊工单
  1136. #region 正常工单排产-开始
  1137. //记录生产周期
  1138. curSequences.Add(new PeriodSequenceDet
  1139. {
  1140. Domain = domain,
  1141. Line = lineStart.Line,
  1142. ItemNum = workOrd.ItemNum,
  1143. PlanDate = workStartTime.Date,
  1144. Period = dto.Period,
  1145. OrdQty = sumAmount,
  1146. WorkOrds = workOrd.WorkOrd,
  1147. Op = lineStart.Op,
  1148. IsActive = true,
  1149. Status = "",
  1150. CreateTime = DateTime.Now
  1151. });
  1152. //记录排产记录
  1153. curScheduleRsts.Add(new ScheduleResultOpMaster
  1154. {
  1155. Domain = domain,
  1156. WorkOrd = workOrd.WorkOrd,
  1157. Line = lineStart.Line,
  1158. ItemNum = workOrd.ItemNum,
  1159. Op = lineStart.Op,
  1160. WorkDate = workStartTime.Date,
  1161. WorkQty = sumAmount,
  1162. WorkStartTime = dto.StartTime,
  1163. WorkEndTime = dto.EndTime,
  1164. CreateTime = DateTime.Now
  1165. });
  1166. //累计已排产数量
  1167. sumQty += sumAmount;
  1168. //继续排下一个工作日
  1169. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1170. isFstDay = false;
  1171. #endregion 正常工单排产-结束
  1172. }
  1173. }
  1174. else// 当天的产能正常工单只能占用一部分
  1175. {
  1176. #region 正常工单排产-开始
  1177. //剩余需要排产的数量
  1178. decimal residueQty = workOrd.QtyOrded - sumQty;
  1179. //剩余数量生产需要时长(分钟)
  1180. decimal workTime = Math.Ceiling(residueQty / dto.Rate * 60);
  1181. //获取当天的工作时间段
  1182. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  1183. if (curCalendar == null)
  1184. {
  1185. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  1186. }
  1187. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, workStartTime, curCalendar, mlqtyWorkDtls);
  1188. var curPoint = workPoints.Find(p => p.StartPoint <= workStartTime && workStartTime <= p.EndPoint);
  1189. span = curPoint.EndPoint - workStartTime;
  1190. //当天工作时间段的有效生产时间
  1191. decimal effMins = (decimal)span.TotalMinutes;
  1192. DateTime workEndTime = workStartTime;
  1193. if (effMins >= workTime)//当前工作时间段即可满足产能
  1194. {
  1195. workEndTime = workStartTime.AddMinutes((double)workTime);
  1196. }
  1197. else
  1198. {
  1199. //获取后续生产时间段
  1200. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  1201. //剩余需要工作时长
  1202. decimal nextMins = workTime - effMins;
  1203. foreach (var p in nextPoints)
  1204. {
  1205. if (p.WorkMinutes >= nextMins)
  1206. {
  1207. workEndTime = p.StartPoint.AddMinutes((double)nextMins);
  1208. break;
  1209. }
  1210. nextMins -= p.WorkMinutes;
  1211. }
  1212. }
  1213. sumQty = workOrd.QtyOrded;
  1214. //记录生产周期
  1215. curSequences.Add(new PeriodSequenceDet
  1216. {
  1217. Domain = domain,
  1218. Line = lineStart.Line,
  1219. ItemNum = workOrd.ItemNum,
  1220. PlanDate = workStartTime.Date,
  1221. Period = dto.Period,
  1222. OrdQty = residueQty,
  1223. WorkOrds = workOrd.WorkOrd,
  1224. Op = lineStart.Op,
  1225. IsActive = true,
  1226. Status = "",
  1227. CreateTime = DateTime.Now
  1228. });
  1229. //记录排产记录
  1230. curScheduleRsts.Add(new ScheduleResultOpMaster
  1231. {
  1232. Domain = domain,
  1233. WorkOrd = workOrd.WorkOrd,
  1234. Line = lineStart.Line,
  1235. ItemNum = workOrd.ItemNum,
  1236. Op = lineStart.Op,
  1237. WorkDate = workStartTime.Date,
  1238. WorkQty = residueQty,
  1239. WorkStartTime = workStartTime,
  1240. WorkEndTime = workEndTime,
  1241. CreateTime = DateTime.Now
  1242. });
  1243. #endregion 正常工单排产-结束
  1244. #region 特殊工单排产-开始
  1245. //当天剩余产能
  1246. decimal restTime = residueTime - workTime;
  1247. if (sumTsTimes > 0)
  1248. {
  1249. DateTime beginTime = workEndTime;//排产开始时间
  1250. DateTime endTime = dto.EndTime;//排产结束时间
  1251. if (restTime >= sumTsTimes)//当天的可用产能满足特殊工单生产时长
  1252. {
  1253. foreach (var item in workDtos)
  1254. {
  1255. if (item.LbrVar == item.Worked)//当前工单已排产,跳过
  1256. {
  1257. continue;
  1258. }
  1259. //当前工单还需工作时长
  1260. decimal needTime = item.LbrVar - item.Worked;
  1261. //计算工单排产结束时间
  1262. curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1263. span = curPoint.EndPoint - beginTime;
  1264. //当天工作时间段的有效生产时间(分钟)
  1265. effMins = (decimal)span.TotalMinutes;
  1266. if (effMins >= needTime)//当前工作时间段即可满足产能
  1267. {
  1268. endTime = beginTime.AddMinutes((double)needTime);
  1269. }
  1270. else
  1271. {
  1272. //获取后续生产时间段
  1273. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  1274. //剩余需要工作时长
  1275. decimal nextMins = needTime - effMins;
  1276. foreach (var p in nextPoints)
  1277. {
  1278. if (p.WorkMinutes >= nextMins)
  1279. {
  1280. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1281. break;
  1282. }
  1283. nextMins -= p.WorkMinutes;
  1284. }
  1285. }
  1286. //记录生产周期
  1287. curSequences.Add(new PeriodSequenceDet
  1288. {
  1289. Domain = domain,
  1290. Line = lineStart.Line,
  1291. ItemNum = item.ItemNum,
  1292. PlanDate = beginTime.Date,
  1293. Period = dto.Period,
  1294. OrdQty = item.QtyOrded - item.QtyWorked,
  1295. WorkOrds = item.WorkOrd,
  1296. Op = item.Op,
  1297. IsActive = true,
  1298. Status = "",
  1299. CreateTime = DateTime.Now
  1300. });
  1301. //记录排产记录
  1302. curScheduleRsts.Add(new ScheduleResultOpMaster
  1303. {
  1304. Domain = domain,
  1305. WorkOrd = item.WorkOrd,
  1306. Line = lineStart.Line,
  1307. ItemNum = item.ItemNum,
  1308. Op = item.Op,
  1309. WorkDate = beginTime.Date,
  1310. WorkQty = item.QtyOrded - item.QtyWorked,
  1311. WorkStartTime = beginTime,
  1312. WorkEndTime = endTime,
  1313. CreateTime = DateTime.Now
  1314. });
  1315. //下一工单开始时间=当前工单结束时间,如果位于工作区间结尾,则为下一工作区间开始时间
  1316. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  1317. if (endTime == curPoint.EndPoint)//结束时间位于工作区间结尾
  1318. {
  1319. //获取后续生产时间段
  1320. var nextPoint = workPoints.Where(p => p.Level == curPoint.Level + 1).FirstOrDefault();
  1321. if (nextPoint != null)//存在后续工作区间
  1322. {
  1323. endTime = nextPoint.StartPoint;
  1324. }
  1325. }
  1326. beginTime = endTime;
  1327. //工单排产完成,排产时长=工单工作时长
  1328. item.Worked = item.LbrVar;
  1329. item.QtyWorked = item.QtyOrded;
  1330. sumTsTimes -= needTime;
  1331. }
  1332. sumTsTimes = 0;//排产完毕,特殊工单时长置0
  1333. }
  1334. else//当天的可用产能不满足特殊工单生产时长
  1335. {
  1336. foreach (var item in workDtos)
  1337. {
  1338. if (item.LbrVar == item.Worked)//当前工单已排产
  1339. {
  1340. continue;
  1341. }
  1342. //当前工单剩余待排产时长(分钟)
  1343. decimal needTime = item.LbrVar - item.Worked;
  1344. if (restTime >= needTime)//当天剩余产能满足当前工单的剩余待排产时长
  1345. {
  1346. //计算工单排产结束时间
  1347. curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1348. span = curPoint.EndPoint - beginTime;
  1349. //当前工作时间段的有效生产时间(分钟)
  1350. effMins = (decimal)span.TotalMinutes;
  1351. if (effMins >= needTime)//当前工作时间段即可满足产能
  1352. {
  1353. endTime = beginTime.AddMinutes((double)needTime);
  1354. }
  1355. else
  1356. {
  1357. //获取后续生产时间段
  1358. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  1359. //剩余需要工作时长
  1360. decimal nextMins = needTime - effMins;
  1361. foreach (var p in nextPoints)
  1362. {
  1363. if (p.WorkMinutes >= nextMins)
  1364. {
  1365. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1366. break;
  1367. }
  1368. nextMins -= p.WorkMinutes;
  1369. }
  1370. }
  1371. //记录生产周期
  1372. curSequences.Add(new PeriodSequenceDet
  1373. {
  1374. Domain = domain,
  1375. Line = lineStart.Line,
  1376. ItemNum = item.ItemNum,
  1377. PlanDate = beginTime.Date,
  1378. Period = dto.Period,
  1379. OrdQty = item.QtyOrded - item.QtyWorked,
  1380. WorkOrds = item.WorkOrd,
  1381. Op = item.Op,
  1382. IsActive = true,
  1383. Status = "",
  1384. CreateTime = DateTime.Now
  1385. });
  1386. //记录排产记录
  1387. curScheduleRsts.Add(new ScheduleResultOpMaster
  1388. {
  1389. Domain = domain,
  1390. WorkOrd = item.WorkOrd,
  1391. Line = lineStart.Line,
  1392. ItemNum = item.ItemNum,
  1393. Op = item.Op,
  1394. WorkDate = beginTime.Date,
  1395. WorkQty = item.QtyOrded - item.QtyWorked,
  1396. WorkStartTime = beginTime,
  1397. WorkEndTime = endTime,
  1398. CreateTime = DateTime.Now
  1399. });
  1400. beginTime = endTime;
  1401. //当前工单已排产完成,已排产时间=工单生产时长,已排产数量=工单数量
  1402. item.Worked = item.LbrVar;
  1403. item.QtyWorked = item.QtyWorked;
  1404. //当天剩余产能
  1405. restTime -= needTime;
  1406. if (restTime == 0)
  1407. {
  1408. break;
  1409. }
  1410. }
  1411. else//当天剩余产能不满足当前工单的剩余待排产时长
  1412. {
  1413. //计算生产数量
  1414. decimal qty = Math.Ceiling(restTime / item.LbrVar * item.QtyOrded);
  1415. //记录生产周期
  1416. curSequences.Add(new PeriodSequenceDet
  1417. {
  1418. Domain = domain,
  1419. Line = lineStart.Line,
  1420. ItemNum = item.ItemNum,
  1421. PlanDate = beginTime.Date,
  1422. Period = dto.Period,
  1423. OrdQty = qty,
  1424. WorkOrds = item.WorkOrd,
  1425. Op = item.Op,
  1426. IsActive = true,
  1427. Status = "",
  1428. CreateTime = DateTime.Now
  1429. });
  1430. //记录排产记录
  1431. curScheduleRsts.Add(new ScheduleResultOpMaster
  1432. {
  1433. Domain = domain,
  1434. WorkOrd = item.WorkOrd,
  1435. Line = lineStart.Line,
  1436. ItemNum = item.ItemNum,
  1437. Op = item.Op,
  1438. WorkDate = beginTime.Date,
  1439. WorkQty = qty,
  1440. WorkStartTime = beginTime,
  1441. WorkEndTime = endTime,
  1442. CreateTime = DateTime.Now
  1443. });
  1444. item.Worked += restTime;
  1445. item.QtyWorked += qty;
  1446. break;
  1447. }
  1448. }
  1449. //特殊工单剩余待排产时长(分钟)
  1450. sumTsTimes -= restTime;
  1451. //获取下一个工作日
  1452. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1453. isFstDay = false;
  1454. }
  1455. }
  1456. #endregion 特殊工单排产-结束
  1457. }
  1458. //记录提前期
  1459. sumTimes = lineStart.setupTime * 60;
  1460. }
  1461. else//当天可用生产时长不能满足或者刚好满足提前期
  1462. {
  1463. //当天的可用生产时长不能满足提前期
  1464. sumTimes += dto.EffTime;
  1465. //获取下一个工作日
  1466. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1467. isFstDay = false;
  1468. }
  1469. }
  1470. else
  1471. {
  1472. //判断已排产数量+当天的产能是否超过工单数量
  1473. if (sumQty + dto.ProductQty <= workOrd.QtyOrded)//当天的产能需要全部排产
  1474. {
  1475. if (sumTsTimes > 0)//当天有特殊工单,先排特殊工单
  1476. {
  1477. //当天剩余产能(分钟)
  1478. decimal residueTime = dto.EffTime;
  1479. DateTime beginTime = workStartTime;//排产开始时间
  1480. DateTime endTime = dto.EndTime;//排产结束时间
  1481. //获取当天的工作时间段
  1482. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  1483. if (curCalendar == null)
  1484. {
  1485. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  1486. }
  1487. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, workStartTime, curCalendar, mlqtyWorkDtls);
  1488. if (residueTime > sumTsTimes)//当天的可用产能满足特殊工单生产时长
  1489. {
  1490. //特殊工单排产
  1491. foreach (var item in workDtos)
  1492. {
  1493. if (item.LbrVar == item.Worked)//当前工单已排产,跳过
  1494. {
  1495. continue;
  1496. }
  1497. //当前工单还需工作时长
  1498. decimal needTime = item.LbrVar - item.Worked;
  1499. //计算工单排产结束时间
  1500. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1501. span = curPoint.EndPoint - beginTime;
  1502. //当天工作时间段的有效生产时间(分钟)
  1503. decimal effMins = (decimal)span.TotalMinutes;
  1504. if (effMins >= needTime)//当前工作时间段即可满足产能
  1505. {
  1506. endTime = beginTime.AddMinutes((double)needTime);
  1507. }
  1508. else
  1509. {
  1510. //获取后续生产时间段
  1511. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  1512. //剩余需要工作时长
  1513. decimal nextMins = needTime - effMins;
  1514. foreach (var p in nextPoints)
  1515. {
  1516. if (p.WorkMinutes >= nextMins)
  1517. {
  1518. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1519. break;
  1520. }
  1521. nextMins -= p.WorkMinutes;
  1522. }
  1523. }
  1524. //记录生产周期
  1525. curSequences.Add(new PeriodSequenceDet
  1526. {
  1527. Domain = domain,
  1528. Line = lineStart.Line,
  1529. ItemNum = item.ItemNum,
  1530. PlanDate = beginTime.Date,
  1531. Period = dto.Period,
  1532. OrdQty = item.QtyOrded - item.QtyWorked,
  1533. WorkOrds = item.WorkOrd,
  1534. Op = item.Op,
  1535. IsActive = true,
  1536. Status = "",
  1537. CreateTime = DateTime.Now
  1538. });
  1539. //记录排产记录
  1540. curScheduleRsts.Add(new ScheduleResultOpMaster
  1541. {
  1542. Domain = domain,
  1543. WorkOrd = item.WorkOrd,
  1544. Line = lineStart.Line,
  1545. ItemNum = item.ItemNum,
  1546. Op = item.Op,
  1547. WorkDate = beginTime.Date,
  1548. WorkQty = item.QtyOrded - item.QtyWorked,
  1549. WorkStartTime = beginTime,
  1550. WorkEndTime = endTime,
  1551. CreateTime = DateTime.Now
  1552. });
  1553. //下一工单开始时间=当前工单结束时间,如果位于工作区间结尾,则为下一工作区间开始时间
  1554. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  1555. if (endTime == curPoint.EndPoint)//结束时间位于工作区间结尾
  1556. {
  1557. //获取后续生产时间段
  1558. var nextPoint = workPoints.Where(p => p.Level == curPoint.Level + 1).FirstOrDefault();
  1559. if (nextPoint != null)//存在后续工作区间
  1560. {
  1561. endTime = nextPoint.StartPoint;
  1562. }
  1563. }
  1564. beginTime = endTime;
  1565. //工单排产完成,排产时长=工单工作时长
  1566. item.Worked = item.LbrVar;
  1567. item.QtyWorked = item.QtyOrded;
  1568. sumTsTimes -= needTime;
  1569. }
  1570. //处理正常工单开工时间
  1571. workStartTime = endTime;
  1572. var point = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  1573. if (endTime == point.EndPoint)
  1574. {
  1575. var nextPoint = workPoints.FirstOrDefault(p => p.Level == point.Level + 1);
  1576. if (nextPoint != null)
  1577. {
  1578. workStartTime = nextPoint.StartPoint;
  1579. }
  1580. }
  1581. //剩余产能继续排正常工单
  1582. decimal sumAmount = dto.ProductQty - Math.Floor(dto.Rate * (dto.EffTime - sumTsTimes) / 60);
  1583. //记录生产周期
  1584. curSequences.Add(new PeriodSequenceDet
  1585. {
  1586. Domain = domain,
  1587. Line = lineStart.Line,
  1588. ItemNum = workOrd.ItemNum,
  1589. PlanDate = workStartTime.Date,
  1590. Period = dto.Period,
  1591. OrdQty = sumAmount,
  1592. WorkOrds = workOrd.WorkOrd,
  1593. Op = lineStart.Op,
  1594. IsActive = true,
  1595. Status = "",
  1596. CreateTime = DateTime.Now
  1597. });
  1598. //记录排产记录
  1599. curScheduleRsts.Add(new ScheduleResultOpMaster
  1600. {
  1601. Domain = domain,
  1602. WorkOrd = workOrd.WorkOrd,
  1603. Line = lineStart.Line,
  1604. ItemNum = workOrd.ItemNum,
  1605. Op = lineStart.Op,
  1606. WorkDate = workStartTime.Date,
  1607. WorkQty = sumAmount,
  1608. WorkStartTime = workStartTime,
  1609. WorkEndTime = dto.EndTime,
  1610. CreateTime = DateTime.Now
  1611. });
  1612. //累计已排产数量
  1613. sumQty += sumAmount;
  1614. //继续排下一个工作日
  1615. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1616. isFstDay = false;
  1617. //排产完毕,特殊工单时长置0
  1618. sumTsTimes = 0;
  1619. }
  1620. else//当天的可用产能不满足或者刚好满足特殊工单生产时长
  1621. {
  1622. foreach (var item in workDtos)
  1623. {
  1624. if (item.LbrVar == item.Worked)//当前工单已排产
  1625. {
  1626. continue;
  1627. }
  1628. //当前工单剩余待排产时长(分钟)
  1629. decimal needTime = item.LbrVar - item.Worked;
  1630. if (residueTime >= needTime)//当天剩余产能满足当前工单的剩余待排产时长
  1631. {
  1632. //计算工单排产结束时间
  1633. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1634. span = curPoint.EndPoint - beginTime;
  1635. //当前工作时间段的有效生产时间(分钟)
  1636. decimal effMins = (decimal)span.TotalMinutes;
  1637. if (effMins >= needTime)//当前工作时间段即可满足产能
  1638. {
  1639. endTime = beginTime.AddMinutes((double)needTime);
  1640. }
  1641. else
  1642. {
  1643. //获取后续生产时间段
  1644. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  1645. //剩余需要工作时长
  1646. decimal nextMins = needTime - effMins;
  1647. foreach (var p in nextPoints)
  1648. {
  1649. if (p.WorkMinutes >= nextMins)
  1650. {
  1651. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1652. break;
  1653. }
  1654. nextMins -= p.WorkMinutes;
  1655. }
  1656. }
  1657. //记录生产周期
  1658. curSequences.Add(new PeriodSequenceDet
  1659. {
  1660. Domain = domain,
  1661. Line = lineStart.Line,
  1662. ItemNum = item.ItemNum,
  1663. PlanDate = beginTime.Date,
  1664. Period = dto.Period,
  1665. OrdQty = item.QtyOrded - item.QtyWorked,
  1666. WorkOrds = item.WorkOrd,
  1667. Op = item.Op,
  1668. IsActive = true,
  1669. Status = "",
  1670. CreateTime = DateTime.Now
  1671. });
  1672. //记录排产记录
  1673. curScheduleRsts.Add(new ScheduleResultOpMaster
  1674. {
  1675. Domain = domain,
  1676. WorkOrd = item.WorkOrd,
  1677. Line = lineStart.Line,
  1678. ItemNum = item.ItemNum,
  1679. Op = item.Op,
  1680. WorkDate = beginTime.Date,
  1681. WorkQty = item.QtyOrded - item.QtyWorked,
  1682. WorkStartTime = beginTime,
  1683. WorkEndTime = endTime,
  1684. CreateTime = DateTime.Now
  1685. });
  1686. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  1687. if (endTime == curPoint.EndPoint)
  1688. {
  1689. var nextPoint = workPoints.FirstOrDefault(p => p.Level == curPoint.Level + 1);
  1690. if (nextPoint != null)
  1691. {
  1692. endTime = nextPoint.StartPoint;
  1693. }
  1694. }
  1695. beginTime = endTime;
  1696. //当前工单已排产完成,已排产时间=工单生产时长,已排产数量=工单数量
  1697. item.Worked = item.LbrVar;
  1698. item.QtyWorked = item.QtyWorked;
  1699. //当天剩余产能
  1700. residueTime -= needTime;
  1701. if (residueTime == 0)
  1702. {
  1703. break;
  1704. }
  1705. }
  1706. else//当天剩余产能不满足当前工单的剩余待排产时长
  1707. {
  1708. //计算生产数量
  1709. decimal qty = Math.Ceiling(residueTime / item.LbrVar * item.QtyOrded);
  1710. //记录生产周期
  1711. curSequences.Add(new PeriodSequenceDet
  1712. {
  1713. Domain = domain,
  1714. Line = lineStart.Line,
  1715. ItemNum = item.ItemNum,
  1716. PlanDate = beginTime.Date,
  1717. Period = dto.Period,
  1718. OrdQty = qty,
  1719. WorkOrds = item.WorkOrd,
  1720. Op = item.Op,
  1721. IsActive = true,
  1722. Status = "",
  1723. CreateTime = DateTime.Now
  1724. });
  1725. //记录排产记录
  1726. curScheduleRsts.Add(new ScheduleResultOpMaster
  1727. {
  1728. Domain = domain,
  1729. WorkOrd = item.WorkOrd,
  1730. Line = lineStart.Line,
  1731. ItemNum = item.ItemNum,
  1732. Op = item.Op,
  1733. WorkDate = beginTime.Date,
  1734. WorkQty = qty,
  1735. WorkStartTime = beginTime,
  1736. WorkEndTime = endTime,
  1737. CreateTime = DateTime.Now
  1738. });
  1739. item.Worked += residueTime;
  1740. item.QtyWorked += qty;
  1741. break;
  1742. }
  1743. }
  1744. //特殊工单剩余待排产时长(分钟)
  1745. sumTsTimes -= residueTime;
  1746. //获取下一个工作日
  1747. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1748. isFstDay = false;
  1749. }
  1750. }
  1751. else {//不存在特殊工单
  1752. //记录生产周期
  1753. curSequences.Add(new PeriodSequenceDet
  1754. {
  1755. Domain = domain,
  1756. Line = lineStart.Line,
  1757. ItemNum = workOrd.ItemNum,
  1758. PlanDate = workStartTime.Date,
  1759. Period = dto.Period,
  1760. OrdQty = dto.ProductQty,
  1761. WorkOrds = workOrd.WorkOrd,
  1762. Op = lineStart.Op,
  1763. IsActive = true,
  1764. Status = "",
  1765. CreateTime = DateTime.Now
  1766. });
  1767. //记录排产记录
  1768. curScheduleRsts.Add(new ScheduleResultOpMaster
  1769. {
  1770. Domain = domain,
  1771. WorkOrd = workOrd.WorkOrd,
  1772. Line = lineStart.Line,
  1773. ItemNum = workOrd.ItemNum,
  1774. Op = lineStart.Op,
  1775. WorkDate = workStartTime.Date,
  1776. WorkQty = dto.ProductQty,
  1777. WorkStartTime = dto.StartTime,
  1778. WorkEndTime = dto.EndTime,
  1779. CreateTime = DateTime.Now
  1780. });
  1781. //累计已排产数量
  1782. sumQty += dto.ProductQty;
  1783. //继续排下一个工作日
  1784. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1785. isFstDay = false;
  1786. }
  1787. }
  1788. else// 当天的产能正常工单只能占用一部分
  1789. {
  1790. decimal workTime = 0m;
  1791. DateTime workEndTime = workStartTime;
  1792. //获取当天的工作时间段
  1793. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  1794. if (curCalendar == null)
  1795. {
  1796. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  1797. }
  1798. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, workStartTime, curCalendar, mlqtyWorkDtls);
  1799. if (sumQty < workOrd.QtyOrded)
  1800. {
  1801. #region 正常工单排产-开始
  1802. //剩余需要排产的数量
  1803. decimal residueQty = workOrd.QtyOrded - sumQty;
  1804. //剩余数量生产需要时长(分钟)
  1805. workTime = Math.Ceiling(residueQty / dto.Rate * 60);
  1806. var curPoint = workPoints.Find(p => p.StartPoint <= workStartTime && workStartTime <= p.EndPoint);
  1807. span = curPoint.EndPoint - workStartTime;
  1808. //当天工作时间段的有效生产时间
  1809. decimal effMins = (decimal)span.TotalMinutes;
  1810. if (effMins >= workTime)//当前工作时间段即可满足产能
  1811. {
  1812. workEndTime = workStartTime.AddMinutes((double)workTime);
  1813. }
  1814. else
  1815. {
  1816. //获取后续生产时间段
  1817. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  1818. //剩余需要工作时长
  1819. decimal nextMins = workTime - effMins;
  1820. foreach (var p in nextPoints)
  1821. {
  1822. if (p.WorkMinutes >= nextMins)
  1823. {
  1824. workEndTime = p.StartPoint.AddMinutes((double)nextMins);
  1825. break;
  1826. }
  1827. nextMins -= p.WorkMinutes;
  1828. }
  1829. }
  1830. sumQty = workOrd.QtyOrded;
  1831. //记录生产周期
  1832. curSequences.Add(new PeriodSequenceDet
  1833. {
  1834. Domain = domain,
  1835. Line = lineStart.Line,
  1836. ItemNum = workOrd.ItemNum,
  1837. PlanDate = workStartTime.Date,
  1838. Period = dto.Period,
  1839. OrdQty = residueQty,
  1840. WorkOrds = workOrd.WorkOrd,
  1841. Op = lineStart.Op,
  1842. IsActive = true,
  1843. Status = "",
  1844. CreateTime = DateTime.Now
  1845. });
  1846. //记录排产记录
  1847. curScheduleRsts.Add(new ScheduleResultOpMaster
  1848. {
  1849. Domain = domain,
  1850. WorkOrd = workOrd.WorkOrd,
  1851. Line = lineStart.Line,
  1852. ItemNum = workOrd.ItemNum,
  1853. Op = lineStart.Op,
  1854. WorkDate = workStartTime.Date,
  1855. WorkQty = residueQty,
  1856. WorkStartTime = workStartTime,
  1857. WorkEndTime = workEndTime,
  1858. CreateTime = DateTime.Now
  1859. });
  1860. #endregion 正常工单排产-结束
  1861. }
  1862. #region 特殊工单排产-开始
  1863. //当天剩余产能(分钟)
  1864. decimal restTime = dto.EffTime - workTime;
  1865. if (sumTsTimes > 0)//存在特殊工单
  1866. {
  1867. DateTime beginTime = workEndTime;//排产开始时间
  1868. DateTime endTime = dto.EndTime;//排产结束时间
  1869. if (restTime >= sumTsTimes)//当天的可用产能满足特殊工单生产时长
  1870. {
  1871. foreach (var item in workDtos)
  1872. {
  1873. if (item.LbrVar == item.Worked)//当前工单已排产,跳过
  1874. {
  1875. continue;
  1876. }
  1877. //当前工单还需工作时长
  1878. decimal needTime = item.LbrVar - item.Worked;
  1879. //计算工单排产结束时间
  1880. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1881. span = curPoint.EndPoint - beginTime;
  1882. //当天工作时间段的有效生产时间(分钟)
  1883. decimal effMins = (decimal)span.TotalMinutes;
  1884. if (effMins >= needTime)//当前工作时间段即可满足产能
  1885. {
  1886. endTime = beginTime.AddMinutes((double)needTime);
  1887. }
  1888. else
  1889. {
  1890. //获取后续生产时间段
  1891. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  1892. //剩余需要工作时长
  1893. decimal nextMins = needTime - effMins;
  1894. foreach (var p in nextPoints)
  1895. {
  1896. if (p.WorkMinutes >= nextMins)
  1897. {
  1898. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1899. break;
  1900. }
  1901. nextMins -= p.WorkMinutes;
  1902. }
  1903. }
  1904. //记录生产周期
  1905. curSequences.Add(new PeriodSequenceDet
  1906. {
  1907. Domain = domain,
  1908. Line = lineStart.Line,
  1909. ItemNum = item.ItemNum,
  1910. PlanDate = beginTime.Date,
  1911. Period = dto.Period,
  1912. OrdQty = item.QtyOrded - item.QtyWorked,
  1913. WorkOrds = item.WorkOrd,
  1914. Op = item.Op,
  1915. IsActive = true,
  1916. Status = "",
  1917. CreateTime = DateTime.Now
  1918. });
  1919. //记录排产记录
  1920. curScheduleRsts.Add(new ScheduleResultOpMaster
  1921. {
  1922. Domain = domain,
  1923. WorkOrd = item.WorkOrd,
  1924. Line = lineStart.Line,
  1925. ItemNum = item.ItemNum,
  1926. Op = item.Op,
  1927. WorkDate = beginTime.Date,
  1928. WorkQty = item.QtyOrded - item.QtyWorked,
  1929. WorkStartTime = beginTime,
  1930. WorkEndTime = endTime,
  1931. CreateTime = DateTime.Now
  1932. });
  1933. //下一工单开始时间=当前工单结束时间,如果位于工作区间结尾,则为下一工作区间开始时间
  1934. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  1935. if (endTime == curPoint.EndPoint)//结束时间位于工作区间结尾
  1936. {
  1937. //获取后续生产时间段
  1938. var nextPoint = workPoints.Where(p => p.Level == curPoint.Level + 1).FirstOrDefault();
  1939. if (nextPoint != null)//存在后续工作区间
  1940. {
  1941. endTime = nextPoint.StartPoint;
  1942. }
  1943. }
  1944. beginTime = endTime;
  1945. //工单排产完成,排产时长=工单工作时长
  1946. item.Worked = item.LbrVar;
  1947. item.QtyWorked = item.QtyOrded;
  1948. sumTsTimes -= needTime;
  1949. }
  1950. sumTsTimes = 0;//排产完毕,特殊工单时长置0
  1951. }
  1952. else//当天的可用产能不满足特殊工单生产时长
  1953. {
  1954. foreach (var item in workDtos)
  1955. {
  1956. if (item.LbrVar == item.Worked)//当前工单已排产
  1957. {
  1958. continue;
  1959. }
  1960. //当前工单剩余待排产时长(分钟)
  1961. decimal needTime = item.LbrVar - item.Worked;
  1962. if (restTime >= needTime)//当天剩余产能满足当前工单的剩余待排产时长
  1963. {
  1964. //计算工单排产结束时间
  1965. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1966. span = curPoint.EndPoint - beginTime;
  1967. //当前工作时间段的有效生产时间(分钟)
  1968. decimal effMins = (decimal)span.TotalMinutes;
  1969. if (effMins >= needTime)//当前工作时间段即可满足产能
  1970. {
  1971. endTime = beginTime.AddMinutes((double)needTime);
  1972. }
  1973. else
  1974. {
  1975. //获取后续生产时间段
  1976. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  1977. //剩余需要工作时长
  1978. decimal nextMins = needTime - effMins;
  1979. foreach (var p in nextPoints)
  1980. {
  1981. if (p.WorkMinutes >= nextMins)
  1982. {
  1983. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1984. break;
  1985. }
  1986. nextMins -= p.WorkMinutes;
  1987. }
  1988. }
  1989. //记录生产周期
  1990. curSequences.Add(new PeriodSequenceDet
  1991. {
  1992. Domain = domain,
  1993. Line = lineStart.Line,
  1994. ItemNum = item.ItemNum,
  1995. PlanDate = beginTime.Date,
  1996. Period = dto.Period,
  1997. OrdQty = item.QtyOrded - item.QtyWorked,
  1998. WorkOrds = item.WorkOrd,
  1999. Op = item.Op,
  2000. IsActive = true,
  2001. Status = "",
  2002. CreateTime = DateTime.Now
  2003. });
  2004. //记录排产记录
  2005. curScheduleRsts.Add(new ScheduleResultOpMaster
  2006. {
  2007. Domain = domain,
  2008. WorkOrd = item.WorkOrd,
  2009. Line = lineStart.Line,
  2010. ItemNum = item.ItemNum,
  2011. Op = item.Op,
  2012. WorkDate = beginTime.Date,
  2013. WorkQty = item.QtyOrded - item.QtyWorked,
  2014. WorkStartTime = beginTime,
  2015. WorkEndTime = endTime,
  2016. CreateTime = DateTime.Now
  2017. });
  2018. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  2019. if (endTime == curPoint.EndPoint)
  2020. {
  2021. var nextPoint = workPoints.FirstOrDefault(p=>p.Level == curPoint.Level +1);
  2022. if (nextPoint != null)
  2023. {
  2024. endTime = nextPoint.StartPoint;
  2025. }
  2026. }
  2027. beginTime = endTime;
  2028. //当前工单已排产完成,已排产时间=工单生产时长,已排产数量=工单数量
  2029. item.Worked = item.LbrVar;
  2030. item.QtyWorked = item.QtyWorked;
  2031. //当天剩余产能
  2032. restTime -= needTime;
  2033. if (restTime == 0)
  2034. {
  2035. break;
  2036. }
  2037. }
  2038. else//当天剩余产能不满足当前工单的剩余待排产时长
  2039. {
  2040. //计算生产数量
  2041. decimal qty = Math.Ceiling(restTime / item.LbrVar * item.QtyOrded);
  2042. //记录生产周期
  2043. curSequences.Add(new PeriodSequenceDet
  2044. {
  2045. Domain = domain,
  2046. Line = lineStart.Line,
  2047. ItemNum = item.ItemNum,
  2048. PlanDate = beginTime.Date,
  2049. Period = dto.Period,
  2050. OrdQty = qty,
  2051. WorkOrds = item.WorkOrd,
  2052. Op = item.Op,
  2053. IsActive = true,
  2054. Status = "",
  2055. CreateTime = DateTime.Now
  2056. });
  2057. //记录排产记录
  2058. curScheduleRsts.Add(new ScheduleResultOpMaster
  2059. {
  2060. Domain = domain,
  2061. WorkOrd = item.WorkOrd,
  2062. Line = lineStart.Line,
  2063. ItemNum = item.ItemNum,
  2064. Op = item.Op,
  2065. WorkDate = beginTime.Date,
  2066. WorkQty = qty,
  2067. WorkStartTime = beginTime,
  2068. WorkEndTime = endTime,
  2069. CreateTime = DateTime.Now
  2070. });
  2071. item.Worked += restTime;
  2072. item.QtyWorked += qty;
  2073. break;
  2074. }
  2075. }
  2076. //特殊工单剩余待排产时长(分钟)
  2077. sumTsTimes -= restTime;
  2078. //获取下一个工作日
  2079. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  2080. isFstDay = false;
  2081. }
  2082. }
  2083. #endregion 特殊工单排产-结束
  2084. }
  2085. }
  2086. }
  2087. //记录已排产特殊工单
  2088. ypcWorkOrds.AddRange(workDtos.Select(p=>p.WorkOrd).ToList());
  2089. }
  2090. //记录排产结果
  2091. periodsDet.AddRange(curSequences);
  2092. scheduleResults.AddRange(curScheduleRsts);
  2093. }
  2094. /// <summary>
  2095. /// 特殊工单排产:和正常工单不共用产线的特殊工单
  2096. /// </summary>
  2097. /// <param name="workOrds">特殊工单</param>
  2098. /// <param name="periodsDet">生产周期</param>
  2099. /// <param name="scheduleResults">排产结果</param>
  2100. public void TsLineSchedule(List<WorkOrdMstDto> workOrds, List<PeriodSequenceDet> periodsDet, List<ScheduleResultOpMaster> scheduleResults)
  2101. {
  2102. foreach (var item in workOrds)
  2103. {
  2104. //工单的生产时长(分钟)
  2105. decimal sumTimes = item.LbrVar;
  2106. //工单的排产开始时间
  2107. DateTime workStartTime = item.OrdDate;
  2108. //当前产线的工作日历
  2109. var mLCalendars = calendars.Where(p => p.ProdLine == item.ProdLine || string.IsNullOrEmpty(p.ProdLine)).ToList();
  2110. //当前产线的休息时间设置
  2111. var mlqtyWorkDtls = qualityLines.Where(p => p.ProdLine == item.ProdLine).ToList();
  2112. LineStartDto lineStart = new LineStartDto();
  2113. lineStart.RecID = 0;
  2114. lineStart.Line = item.ProdLine;
  2115. lineStart.Op = item.Op;
  2116. lineStart.StartTime = workStartTime;
  2117. lineStart.Rate = 0;
  2118. while (sumTimes > 0)
  2119. {
  2120. //获取当天的工作时间段
  2121. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  2122. if (curCalendar == null)
  2123. {
  2124. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  2125. }
  2126. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, workStartTime, curCalendar, mlqtyWorkDtls);
  2127. //获取当天的产能
  2128. LineScheduledDto dto = GetScheduledPoint(lineStart, workStartTime, mLCalendars, mlqtyWorkDtls);
  2129. //当天的可用生产时长不能满足特殊工单生产时长
  2130. if (dto.EffTime <= sumTimes)
  2131. {
  2132. decimal qty = Math.Ceiling(dto.EffTime / item.LbrVar * item.QtyOrded);
  2133. //记录生产周期
  2134. periodsDet.Add(new PeriodSequenceDet
  2135. {
  2136. Domain = domain,
  2137. Line = item.ProdLine,
  2138. ItemNum = item.ItemNum,
  2139. PlanDate = workStartTime.Date,
  2140. Period = dto.Period,
  2141. OrdQty = qty,
  2142. WorkOrds = item.WorkOrd,
  2143. Op = item.Op,
  2144. IsActive = true,
  2145. Status = "",
  2146. CreateTime = DateTime.Now
  2147. });
  2148. //记录排产记录
  2149. scheduleResults.Add(new ScheduleResultOpMaster
  2150. {
  2151. Domain = domain,
  2152. WorkOrd = item.WorkOrd,
  2153. Line = item.ProdLine,
  2154. ItemNum = item.ItemNum,
  2155. Op = item.Op,
  2156. WorkDate = workStartTime.Date,
  2157. WorkQty = qty,
  2158. WorkStartTime = dto.StartTime,
  2159. WorkEndTime = dto.EndTime,
  2160. CreateTime = DateTime.Now
  2161. });
  2162. //剩余待排产时长
  2163. sumTimes -= dto.EffTime;
  2164. //已排产数量
  2165. item.QtyWorked += qty;
  2166. //继续排下一个工作日
  2167. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  2168. }
  2169. else// 最后一天的产能只能占用一部分
  2170. {
  2171. //剩余生产时长(分钟)
  2172. decimal workTime = sumTimes;
  2173. var curPoint = workPoints.Find(p => p.StartPoint <= workStartTime && workStartTime <= p.EndPoint);
  2174. TimeSpan span = curPoint.EndPoint - workStartTime;
  2175. //当前工作时间段的有效生产时间
  2176. decimal effMins = (decimal)span.TotalMinutes;
  2177. DateTime workEndTime = workStartTime;
  2178. if (effMins >= workTime)//当前工作时间段即可满足产能
  2179. {
  2180. workEndTime = workStartTime.AddMinutes((double)workTime);
  2181. }
  2182. else
  2183. {
  2184. //获取后续生产时间段
  2185. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  2186. //剩余需要工作时长
  2187. decimal nextMins = workTime - effMins;
  2188. foreach (var p in nextPoints)
  2189. {
  2190. if (p.WorkMinutes >= nextMins)
  2191. {
  2192. workEndTime = p.StartPoint.AddMinutes((double)nextMins);
  2193. break;
  2194. }
  2195. nextMins -= p.WorkMinutes;
  2196. }
  2197. }
  2198. //记录生产周期
  2199. periodsDet.Add(new PeriodSequenceDet
  2200. {
  2201. Domain = domain,
  2202. Line = item.ProdLine,
  2203. ItemNum = item.ItemNum,
  2204. PlanDate = workStartTime.Date,
  2205. Period = dto.Period,
  2206. OrdQty = item.QtyOrded - item.QtyWorked,
  2207. WorkOrds = item.WorkOrd,
  2208. Op = item.Op,
  2209. IsActive = true,
  2210. Status = "",
  2211. CreateTime = DateTime.Now
  2212. });
  2213. //记录排产记录
  2214. scheduleResults.Add(new ScheduleResultOpMaster
  2215. {
  2216. Domain = domain,
  2217. WorkOrd = item.WorkOrd,
  2218. Line = item.ProdLine,
  2219. ItemNum = item.ItemNum,
  2220. Op = item.Op,
  2221. WorkDate = workStartTime.Date,
  2222. WorkQty = item.QtyOrded - item.QtyWorked,
  2223. WorkStartTime = workStartTime,
  2224. WorkEndTime = workEndTime,
  2225. CreateTime = DateTime.Now
  2226. });
  2227. sumTimes = 0;
  2228. item.QtyWorked = item.QtyOrded;
  2229. }
  2230. }
  2231. }
  2232. }
  2233. /// <summary>
  2234. /// 获取产线当天的开工时间,结束时间,有效工作时长,生产数量
  2235. /// </summary>
  2236. /// <param name="lineStart">排产产线</param>
  2237. /// <param name="startTime">产线排产开始时间</param>
  2238. /// <param name="curCalendars"></param>
  2239. /// <param name="curQtyDtls"></param>
  2240. /// <returns></returns>
  2241. public LineScheduledDto GetScheduledPoint(LineStartDto lineStart, DateTime startTime, List<ShopCalendarWorkCtr> curCalendars, List<QualityLineWorkDetail> curQtyDtls)
  2242. {
  2243. LineScheduledDto scheduledDto = new LineScheduledDto();
  2244. //当天排产开始时间
  2245. scheduledDto.StartTime = startTime;
  2246. //开始时间是周几
  2247. int weekDay = (int)startTime.DayOfWeek;
  2248. //当天的工作日历
  2249. var shopCal = curCalendars.Where(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  2250. if (shopCal == null)//当前产线当天没有设置工作日历
  2251. {
  2252. //取默认工作日历
  2253. shopCal = curCalendars.Where(p =>string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  2254. }
  2255. //当前日期的工作时间段
  2256. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, startTime, shopCal, curQtyDtls);
  2257. //当天排产结束时间
  2258. scheduledDto.EndTime = workPoints.Last().EndPoint;
  2259. //计算starttime处于那个工作时间段
  2260. var curPoint = workPoints.Where(p => startTime >= p.StartPoint && startTime <= p.EndPoint).First();
  2261. TimeSpan span = curPoint.EndPoint - startTime;
  2262. scheduledDto.EffTime = (decimal)span.TotalMinutes;
  2263. //获取后续工作时间段的有效工作时间
  2264. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  2265. foreach (var item in nextPoints)
  2266. {
  2267. span = item.EndPoint - item.StartPoint;
  2268. scheduledDto.EffTime += (decimal)span.TotalMinutes;
  2269. }
  2270. //判断当前产线的UPH
  2271. var curRunCrews = prodLineDetailRunCrews.Where(p=>p.ProdLineDetailRecID == lineStart.RecID).ToList();
  2272. //判断当前日期是否配置了UPH
  2273. var curLevel = curRunCrews.FirstOrDefault(p => p.StartDate.GetValueOrDefault().Date <= startTime.Date && p.EndDate.GetValueOrDefault().Date >= startTime.Date);
  2274. decimal rate = curLevel == null ? lineStart.Rate : curLevel.Rate;
  2275. scheduledDto.Rate = rate;
  2276. //计算当天的产能(向下取整)
  2277. scheduledDto.ProductQty = Math.Floor(scheduledDto.EffTime / 60 * rate);
  2278. //计算班次
  2279. scheduledDto.Period = 1;//默认一班制
  2280. if (shopCal.ShiftsStart2 != 0 && shopCal.ShiftsHours2 != 0)
  2281. {
  2282. scheduledDto.Period = 2;
  2283. }
  2284. return scheduledDto;
  2285. }
  2286. /// <summary>
  2287. /// 计算主产线实际排产开始时间
  2288. /// </summary>
  2289. /// <param name="workOrd">工单</param>
  2290. /// <param name="op">工序</param>
  2291. /// <param name="prodLines">生产线明细</param>
  2292. /// <param name="allResults">产线占用记录</param>
  2293. /// <returns></returns>
  2294. public LineStartDto DealStartTime(WorkOrdMaster workOrd,int op,List<ProdLineDetail> prodLines, List<ScheduleResultOpMaster> allResults)
  2295. {
  2296. DateTime actStart = DateTime.Now.Date.AddDays(1);
  2297. LineStartDto lineStart = new LineStartDto();
  2298. //获取工序对应的产线,根据优先级排序
  2299. var lines = prodLines.Where(p => p.Part == workOrd.ItemNum && p.Op == op).OrderBy(p => p.Sequence).ToList();
  2300. //获取第一条产线排产结束时间
  2301. var schedule = allResults.Where(p => p.Line == lines[0].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  2302. actStart = schedule == null ? actStart : (schedule.WorkEndTime >= actStart ? schedule.WorkEndTime : actStart);
  2303. //计算实际开工时间
  2304. //产线工作日历:当前产线的工作日历+默认工作日历
  2305. var curCalendars = calendars.Where(p => p.ProdLine == lines[0].Line || string.IsNullOrEmpty(p.ProdLine)).ToList();
  2306. var curQtyDtls = qualityLines.Where(p=>p.ProdLine == lines[0].Line).ToList();
  2307. actStart = CalcActStartTime(lines[0].Line, actStart, curCalendars, curQtyDtls);
  2308. lineStart.RecID = lines[0].RecID;
  2309. lineStart.Line = lines[0].Line;
  2310. lineStart.StartTime = actStart;
  2311. lineStart.setupTime = lines[0].SetupTime;
  2312. lineStart.Rate = lines[0].Rate;
  2313. lineStart.Op = op;
  2314. //循环其他产线
  2315. for (int i = 1; i < lines.Count; i++)
  2316. {
  2317. schedule = allResults.Where(p => p.Line == lines[i].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  2318. DateTime StartTime = schedule == null ? actStart : (schedule.WorkEndTime >= actStart ? schedule.WorkEndTime : actStart);
  2319. //计算实际开工时间
  2320. //产线工作日历:当前产线的工作日历+默认工作日历
  2321. curCalendars = calendars.Where(p => p.ProdLine == lines[i].Line || string.IsNullOrEmpty(p.ProdLine)).ToList();
  2322. curQtyDtls = qualityLines.Where(p => p.ProdLine == lines[i].Line).ToList();
  2323. StartTime = CalcActStartTime(lines[0].Line, StartTime, curCalendars, curQtyDtls);
  2324. if (StartTime < lineStart.StartTime)
  2325. {
  2326. lineStart.RecID = lines[i].RecID;
  2327. lineStart.Line = lines[i].Line;
  2328. lineStart.StartTime = StartTime;
  2329. lineStart.setupTime = lines[i].SetupTime;
  2330. lineStart.Rate = lines[i].Rate;
  2331. lineStart.Op = op;
  2332. }
  2333. }
  2334. return lineStart;
  2335. }
  2336. /// <summary>
  2337. /// 计算主产线实际排产开始时间
  2338. /// </summary>
  2339. /// <param name="prodLine">生产线</param>
  2340. /// <param name="startTime">开始时间</param>
  2341. /// <param name="curCalendars">当前产线工作日历+默认工作日历</param>
  2342. /// <param name="curQtyDtls">当前产线休息记录</param>
  2343. /// <returns></returns>
  2344. public DateTime CalcActStartTime(string prodLine,DateTime startTime, List<ShopCalendarWorkCtr> curCalendars, List<QualityLineWorkDetail> curQtyDtls)
  2345. {
  2346. //实际排产开始时间
  2347. DateTime actStart = startTime;
  2348. //开始时间是周几
  2349. int weekDay = (int)startTime.DayOfWeek;
  2350. //判断当天是否是工作日
  2351. bool isWorkDay = CheckIsWorkDay(startTime);
  2352. if (!isWorkDay)//不是工作日
  2353. {
  2354. //获取下一个工作日开始时间
  2355. actStart = GetNextWorkDay(weekDay, startTime, curCalendars);
  2356. return actStart;
  2357. }
  2358. //当天的工作日历
  2359. var shopCal = curCalendars.Where(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  2360. if (shopCal == null)
  2361. {
  2362. //产线没有维护当天的工作日历,则取默认工作日历
  2363. shopCal = curCalendars.Where(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  2364. }
  2365. //当前日期的工作时间段
  2366. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(prodLine, startTime, shopCal, curQtyDtls);
  2367. //计算starttime处于那个工作时间段
  2368. var curPoint = workPoints.Where(p => startTime >= p.StartPoint && startTime <= p.EndPoint).FirstOrDefault();
  2369. if (curPoint == null)//不处于工作时间段
  2370. {
  2371. //开始时间小于当天工作开始时间
  2372. if (startTime < workPoints.First().StartPoint)
  2373. {
  2374. actStart = workPoints.First().StartPoint;
  2375. }
  2376. //开始时间大于当前工作结束时间
  2377. else if (startTime > workPoints.Last().EndPoint)
  2378. {
  2379. //获取下一个工作日开始时间
  2380. actStart = GetNextWorkDay(weekDay, startTime, curCalendars);
  2381. }
  2382. else
  2383. {//开始时间位于当天的休息时间段
  2384. foreach (var item in workPoints)
  2385. {
  2386. //获取下一个时间段
  2387. var next = workPoints.First(p => p.Level == item.Level + 1);
  2388. if (item.EndPoint < startTime && startTime < next.StartPoint)
  2389. {
  2390. actStart = next.StartPoint;
  2391. break;
  2392. }
  2393. }
  2394. }
  2395. return actStart;
  2396. }
  2397. if (startTime != curPoint.EndPoint)
  2398. {
  2399. return actStart;
  2400. }
  2401. //查询下一时间段的开始时间点
  2402. var nextPoint = workPoints.Where(p => p.Level == curPoint.Level + 1).FirstOrDefault();
  2403. if (nextPoint != null)
  2404. {
  2405. return nextPoint.StartPoint;
  2406. }
  2407. //开始时间为今天下班时间,实际排产开始时间为下一个工作日的开始时间
  2408. actStart = GetNextWorkDay(weekDay, startTime, curCalendars);
  2409. return actStart;
  2410. }
  2411. /// <summary>
  2412. /// 排产开始时间处理为半小时/整点开始--向后取整
  2413. /// </summary>
  2414. /// <param name="startTime"></param>
  2415. /// <returns></returns>
  2416. public DateTime CalcStartTimeAfter(DateTime startTime)
  2417. {
  2418. DateTime rtnTime = startTime;
  2419. DateTime curDate = startTime.Date;
  2420. //时间转换为分钟
  2421. TimeSpan span = rtnTime - curDate;
  2422. decimal sumMinutes = (decimal)span.TotalMinutes;
  2423. int times = (int)Math.Ceiling(sumMinutes / 30);
  2424. rtnTime = curDate.AddMinutes(times * 30);
  2425. return rtnTime;
  2426. }
  2427. /// <summary>
  2428. /// 排产开始时间处理为半小时/整点开始--向前取整
  2429. /// </summary>
  2430. /// <param name="startTime"></param>
  2431. /// <returns></returns>
  2432. public DateTime CalcStartTimeBefore(DateTime startTime)
  2433. {
  2434. DateTime rtnTime = startTime;
  2435. DateTime curDate = startTime.Date;
  2436. //时间转换为分钟
  2437. TimeSpan span = rtnTime - curDate;
  2438. decimal sumMinutes = (decimal)span.TotalMinutes;
  2439. int times = (int)Math.Floor(sumMinutes / 30);
  2440. rtnTime = curDate.AddMinutes(times * 30);
  2441. return rtnTime;
  2442. }
  2443. /// <summary>
  2444. /// 判断当天是否是工作日
  2445. /// </summary>
  2446. /// <param name="dateTime"></param>
  2447. /// <returns></returns>
  2448. public bool CheckIsWorkDay(DateTime dateTime)
  2449. {
  2450. bool isWorkDay = true;
  2451. //周几
  2452. int weekDay = (int)dateTime.DayOfWeek;
  2453. //判断当天是否是工作日
  2454. if (weekDay == 0 || weekDay == 6)//周六或者周日,需要判断是否调班,需要加班
  2455. {
  2456. if (!holidays.Exists(p => p.Dated.GetValueOrDefault().Date == dateTime.Date && p.Ufld1 == "调班"))//不是调班
  2457. {
  2458. isWorkDay = false;
  2459. }
  2460. return isWorkDay;
  2461. }
  2462. //不是周六周日,需要判断是不是节假日
  2463. if (holidays.Exists(p => p.Dated.GetValueOrDefault().Date == dateTime.Date && p.Ufld1 == "休假"))//是节假日
  2464. {
  2465. isWorkDay = false;
  2466. }
  2467. return isWorkDay;
  2468. }
  2469. /// <summary>
  2470. /// 计算下一产线实际排产开始时间
  2471. /// </summary>
  2472. /// <param name="workOrd">工单</param>
  2473. /// <param name="lineStart">上一产线开始时间</param>
  2474. /// <param name="op">工序</param>
  2475. /// <param name="prodLines">产线明细</param>
  2476. /// <param name="allResults">产线占用记录</param>
  2477. /// <returns></returns>
  2478. public LineStartDto DealNextStartTime(WorkOrdMaster workOrd,LineStartDto lineStart,int op, List<ProdLineDetail> prodLines, List<ScheduleResultOpMaster> allResults)
  2479. {
  2480. LineStartDto startDto = new LineStartDto();
  2481. //获取产线
  2482. var lines = prodLines.Where(p => p.Part == workOrd.ItemNum && p.Op == op).OrderBy(p=>p.Sequence).ToList();
  2483. //获取第一条产线排产结束时间
  2484. var schedule = allResults.Where(p => p.Line == lines[0].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  2485. DateTime startTime = CalcStartTimeWithSetUpTime(lines[0], lineStart.StartTime, lineStart.setupTime + lines[0].OverlapTime);
  2486. startDto.RecID = lines[0].RecID;
  2487. startDto.Line = lines[0].Line;
  2488. startDto.setupTime = lines[0].SetupTime;
  2489. startDto.StartTime = schedule == null ? startTime : (startTime < schedule.WorkEndTime ? schedule.WorkEndTime : startTime);
  2490. startDto.Rate = lines[0].Rate;
  2491. startDto.Op = op;
  2492. //循环剩余产线,找到最早可开工产线
  2493. for (int i = 1; i < lines.Count(); i++)
  2494. {
  2495. schedule = allResults.Where(p => p.Line == lines[i].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  2496. startTime = CalcStartTimeWithSetUpTime(lines[i], lineStart.StartTime, lineStart.setupTime + lines[i].OverlapTime);
  2497. startTime = schedule == null ? startTime : (startTime < schedule.WorkEndTime ? schedule.WorkEndTime : startTime);
  2498. if (startTime < startDto.StartTime)
  2499. {
  2500. startDto.RecID = lines[i].RecID;
  2501. startDto.Line = lines[i].Line;
  2502. startDto.setupTime = lines[i].SetupTime;
  2503. startDto.StartTime = startTime;
  2504. startDto.Rate = lines[i].Rate;
  2505. startDto.Op = op;
  2506. }
  2507. }
  2508. return startDto;
  2509. }
  2510. /// <summary>
  2511. /// 通过提前期计算产线排产开始时间
  2512. /// </summary>
  2513. /// <param name="line">产线</param>
  2514. /// <param name="startTime">上一产线开始时间</param>
  2515. /// <param name="setupTime">上一产线准备时间+当前产线提前期</param>
  2516. /// <returns></returns>
  2517. public DateTime CalcStartTimeWithSetUpTime(ProdLineDetail line, DateTime startTime, decimal setupTime)
  2518. {
  2519. //提前期转换成分钟
  2520. decimal needMinute = setupTime * 60;
  2521. //实际排产开始时间
  2522. DateTime actStart = startTime;
  2523. //开始时间是周几
  2524. int weekDay = (int)startTime.DayOfWeek;
  2525. //当天的工作日历
  2526. var shopCal = calendars.Where(p => p.ProdLine == line.Line && p.WeekDay == weekDay).FirstOrDefault();
  2527. if (shopCal == null)
  2528. {
  2529. //产线没有维护当天的工作日历,则取默认工作日历
  2530. shopCal = calendars.Where(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  2531. }
  2532. //当前产线的休息时间设置
  2533. var curQtyDtls = qualityLines.Where(p => p.ProdLine == line.Line).ToList();
  2534. //当前日期的工作时间段
  2535. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(line.Line, startTime, shopCal, curQtyDtls);
  2536. //计算starttime处于那个工作时间段
  2537. var curPoint = workPoints.Where(p => startTime >= p.StartPoint && startTime <= p.EndPoint).FirstOrDefault();
  2538. //当前时间段可用时长
  2539. TimeSpan span = curPoint.EndPoint - startTime;
  2540. decimal curMins = (decimal)span.TotalMinutes;
  2541. if (curMins >= needMinute)//当前时间段的可用时长满足提前期
  2542. {
  2543. actStart = startTime.AddMinutes((double)needMinute);
  2544. return actStart;
  2545. }
  2546. //当前时间段的可用时长不满足
  2547. //剩余提前期
  2548. needMinute -= curMins;
  2549. //获取后层级时间段
  2550. var prePoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  2551. bool flag = true;//标志位
  2552. foreach (var item in prePoints)
  2553. {
  2554. if (item.WorkMinutes >= needMinute)//当前时间段的可用时长满足
  2555. {
  2556. actStart = item.StartPoint.AddMinutes((double)needMinute);
  2557. flag = false;
  2558. break;
  2559. }
  2560. needMinute -= item.WorkMinutes;
  2561. }
  2562. if (!flag)
  2563. {
  2564. return actStart;
  2565. }
  2566. //今天可用时长不够,往后工作日找
  2567. DateTime nextStartTime = startTime;
  2568. while (flag)
  2569. {
  2570. //获取下一个工作日
  2571. nextStartTime = GetNextWorkDay(weekDay, startTime, calendars.Where(p => p.ProdLine == line.Line || string.IsNullOrEmpty(p.ProdLine)).ToList());
  2572. weekDay = (int)nextStartTime.DayOfWeek;
  2573. //获取前一个工作日的工作时间段数据,level顺排
  2574. var curCalendar = calendars.Where(p => p.ProdLine == line.Line && p.WeekDay == weekDay).FirstOrDefault();
  2575. if (curCalendar == null )
  2576. {
  2577. curCalendar = calendars.Where(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  2578. }
  2579. workPoints = DealWorkDayToLevels(line.Line, nextStartTime, curCalendar, curQtyDtls).OrderBy(p => p.Level).ToList();
  2580. //当天的工作时长(分钟)
  2581. decimal sumWorkMins = workPoints.Sum(p => p.WorkMinutes);
  2582. if (sumWorkMins >= needMinute)//当天可用提前期满足
  2583. {
  2584. //获取开始时间
  2585. foreach (var item in workPoints)
  2586. {
  2587. if (item.WorkMinutes >= needMinute)//当前时间段满足
  2588. {
  2589. actStart = item.StartPoint.AddMinutes((double)needMinute);
  2590. break;
  2591. }
  2592. needMinute -= item.WorkMinutes;
  2593. }
  2594. flag = false;
  2595. }
  2596. else
  2597. {
  2598. //当天可用提前期不满足
  2599. needMinute -= sumWorkMins;
  2600. }
  2601. }
  2602. return actStart;
  2603. }
  2604. /// <summary>
  2605. /// 获取下一个工作日开始时间
  2606. /// </summary>
  2607. /// <param name="weekDay">当前周几</param>
  2608. /// <param name="startTime">开始时间</param>
  2609. /// <param name="curCalendars">当前产线的工作日历+默认工作日历</param>
  2610. /// <returns></returns>
  2611. public DateTime GetNextWorkDay(int weekDay, DateTime startTime, List<ShopCalendarWorkCtr> curCalendars)
  2612. {
  2613. DateTime rtnData = startTime;
  2614. //下一天
  2615. DateTime nextDate = startTime.Date.AddDays(1);
  2616. //下一天是周几
  2617. int nextWeekDay = (weekDay + 1) % 7;
  2618. //获取工作日历:先获取当前产线的工作日历,若没有维护,则获取默认工作日历
  2619. var calendar = curCalendars.FirstOrDefault(p =>!string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == nextWeekDay);
  2620. if (calendar == null)
  2621. {
  2622. calendar = curCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == nextWeekDay);
  2623. }
  2624. string strStart = calendar.ShiftsStart1.ToString("0.00").Replace(".", ":");
  2625. //判断下一天是否是工作日
  2626. if (nextWeekDay == 0 || nextWeekDay == 6)//下一天是周六或者周日,需要判断是否调班,需要加班
  2627. {
  2628. if (!holidays.Exists(p => p.Dated.GetValueOrDefault().Date == nextDate && p.Ufld1 == "调班"))//下一天是周末
  2629. {
  2630. //递归继续找下一个工作日
  2631. rtnData = GetNextWorkDay(nextWeekDay, nextDate, curCalendars);
  2632. return rtnData;
  2633. }
  2634. rtnData = Convert.ToDateTime(nextDate.ToString("yyyy-MM-dd") + " " + strStart);
  2635. return rtnData;
  2636. }
  2637. //下一天不是周六周日,需要判断是不是节假日
  2638. if (holidays.Exists(p => p.Dated.GetValueOrDefault().Date == nextDate && p.Ufld1 == "休假"))//是节假日
  2639. {
  2640. //递归继续找下一个工作日
  2641. rtnData = GetNextWorkDay(nextWeekDay, nextDate, curCalendars);
  2642. return rtnData;
  2643. }
  2644. rtnData = Convert.ToDateTime(nextDate.ToString("yyyy-MM-dd") + " " + strStart);
  2645. return rtnData;
  2646. }
  2647. /// <summary>
  2648. /// 处理当前日期的工作时间段
  2649. /// </summary>
  2650. /// <param name="prodLine"></param>
  2651. /// <param name="startTime"></param>
  2652. /// <param name="shopCal">当前产线的工作日历-周几</param>
  2653. /// <param name="curQtyDtls">每天休息记录</param>
  2654. /// <returns></returns>
  2655. public List<LineWorkPointDto> DealWorkDayToLevels(string prodLine, DateTime startTime, ShopCalendarWorkCtr shopCal, List<QualityLineWorkDetail> curQtyDtls)
  2656. {
  2657. //年-月-日
  2658. string date = startTime.Date.ToString("yyyy-MM-dd");
  2659. //排产记录结束日期是周几
  2660. int weekDay = (int)startTime.DayOfWeek;
  2661. //工作时间段
  2662. List<LineWorkPointDto> workPoints = new List<LineWorkPointDto>();
  2663. LineWorkPointDto dto = new LineWorkPointDto();
  2664. int level = 1;
  2665. TimeSpan span = TimeSpan.Zero;
  2666. //开始时间
  2667. string strStart = shopCal.ShiftsStart1.ToString("0.00").Replace(".", ":");
  2668. DateTime dayStartPoint = Convert.ToDateTime(date + " " + strStart);
  2669. //结束时间
  2670. DateTime dayEndPoint = dayStartPoint.AddHours((double)(shopCal.ShiftsHours1 + shopCal.ShiftsHours2));
  2671. dto.Level = level;
  2672. dto.Line = prodLine;
  2673. dto.WeekDay = weekDay;
  2674. dto.StartPoint = dayStartPoint;
  2675. //按照产线休息时间切分时间段
  2676. curQtyDtls = curQtyDtls.OrderBy(p => p.RestTimePoint).ToList();
  2677. foreach (var item in curQtyDtls)
  2678. {
  2679. DateTime endPoint = Convert.ToDateTime(date + " " + item.RestTimePoint);
  2680. dto.EndPoint = endPoint;
  2681. span = dto.EndPoint - dto.StartPoint;
  2682. dto.WorkMinutes = (decimal)span.TotalMinutes;
  2683. workPoints.Add(dto);
  2684. level++;
  2685. dto = new LineWorkPointDto();
  2686. dto.Level = level;
  2687. dto.Line = prodLine;
  2688. dto.WeekDay = weekDay;
  2689. dto.StartPoint = endPoint.AddMinutes(item.RestTime);
  2690. }
  2691. dto.EndPoint = dayEndPoint;
  2692. span = dto.EndPoint - dto.StartPoint;
  2693. dto.WorkMinutes = (decimal)span.TotalMinutes;
  2694. workPoints.Add(dto);
  2695. //产线当天加班设置
  2696. var curOccupyTimes = resourceOccupancyTimes.Where(p => p.Resource == prodLine && p.StartTime.GetValueOrDefault().Date == startTime.Date).OrderBy(p=>p.StartTime).ToList();
  2697. foreach (var item in curOccupyTimes)
  2698. {
  2699. level++;
  2700. dto = new LineWorkPointDto();
  2701. dto.Level = level;
  2702. dto.Line = prodLine;
  2703. dto.WeekDay = weekDay;
  2704. dto.StartPoint = item.StartTime.GetValueOrDefault();
  2705. dto.EndPoint = dto.StartPoint.AddHours(Convert.ToDouble(item.Ufld1));
  2706. dto.WorkMinutes = Convert.ToDecimal(item.Ufld1) * 60;
  2707. workPoints.Add(dto);
  2708. }
  2709. return workPoints.OrderBy(p => p.Level).ToList();
  2710. }
  2711. }
  2712. }