ProductionScheduleAppService.cs 159 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722
  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).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. sumTsTimes -= needTime;
  628. }
  629. if (dto.EffTime == sumTsTimes)//当天产能完全占用
  630. {
  631. sumTsTimes = 0;//排产完毕,特殊工单时长置0
  632. //获取下一个工作日
  633. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  634. //特殊工单排产完成,占用了当天的全部产能,则需要判断下一个工作日是否存在特殊工单,如果存在,则需要继续排特殊工单
  635. secWOMasters = tsWorkOrds.Where(p => p.ProdLine == lineStart.Line && p.OrdDate.Value.Date == workStartTime.Date).OrderBy(p => p.OrdDate).ToList();
  636. //此时需要过滤掉已排产的工单
  637. secWOMasters = secWOMasters.Where(p => !workDtos.Select(m => m.WorkOrd).Contains(p.WorkOrd)).ToList();
  638. //记录新增待排产特殊工单
  639. foreach (var item in secWOMasters)
  640. {
  641. int op = tsWoRoutings.Where(p => p.WorkOrd == item.WorkOrd).OrderByDescending(p => p.OP).First().OP;
  642. workDtos.Add(new WorkOrdMstDto
  643. {
  644. WorkOrd = item.WorkOrd,
  645. ItemNum = item.ItemNum,
  646. QtyOrded = item.QtyOrded,
  647. LbrVar = item.LbrVar * 60,
  648. Worked = 0,
  649. QtyWorked = 0,
  650. Op = op
  651. });
  652. }
  653. //特殊工单待排产时长增加新增带排产特殊工单生产时长
  654. sumTsTimes += secWOMasters.Sum(p => p.LbrVar) * 60;
  655. }
  656. else {
  657. sumTsTimes = 0;//排产完毕,特殊工单时长置0
  658. //处理workStartTime
  659. workStartTime = endTime;
  660. var curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  661. if (endTime == curPoint.EndPoint)
  662. {
  663. var nextPoint = workPoints.Find(p => p.Level == curPoint.Level + 1);
  664. workStartTime = nextPoint.StartPoint;
  665. }
  666. }
  667. }
  668. else//当天的可用产能不满足特殊工单生产时长
  669. {
  670. decimal residueTime = dto.EffTime;//当天产能剩余产能(分钟)
  671. DateTime beginTime = workStartTime;//排产开始时间
  672. DateTime endTime = dto.EndTime;//排产结束时间
  673. foreach (var item in workDtos)
  674. {
  675. if (item.LbrVar == item.Worked)//当前工单已排产
  676. {
  677. continue;
  678. }
  679. //当前工单剩余待排产时长(分钟)
  680. decimal needTime = item.LbrVar - item.Worked;
  681. if (residueTime >= needTime)//当天剩余产能满足当前工单的剩余待排产时长
  682. {
  683. //计算工单排产结束时间
  684. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  685. span = curPoint.EndPoint - beginTime;
  686. //当前工作时间段的有效生产时间(分钟)
  687. decimal effMins = (decimal)span.TotalMinutes;
  688. if (effMins >= needTime)//当前工作时间段即可满足产能
  689. {
  690. endTime = beginTime.AddMinutes((double)needTime);
  691. }
  692. else
  693. {
  694. //获取后续生产时间段
  695. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  696. //剩余需要工作时长
  697. decimal nextMins = needTime - effMins;
  698. foreach (var p in nextPoints)
  699. {
  700. if (p.WorkMinutes >= nextMins)
  701. {
  702. endTime = p.StartPoint.AddMinutes((double)nextMins);
  703. break;
  704. }
  705. nextMins -= p.WorkMinutes;
  706. }
  707. }
  708. //记录生产周期
  709. curSequences.Add(new PeriodSequenceDet
  710. {
  711. Domain = domain,
  712. Line = lineStart.Line,
  713. ItemNum = item.ItemNum,
  714. PlanDate = beginTime.Date,
  715. Period = dto.Period,
  716. OrdQty = item.QtyOrded - item.QtyWorked,
  717. WorkOrds = item.WorkOrd,
  718. Op = item.Op,
  719. IsActive = true,
  720. Status = "",
  721. CreateTime = DateTime.Now
  722. });
  723. //记录排产记录
  724. curScheduleRsts.Add(new ScheduleResultOpMaster
  725. {
  726. Domain = domain,
  727. WorkOrd = item.WorkOrd,
  728. Line = lineStart.Line,
  729. ItemNum = item.ItemNum,
  730. Op = item.Op,
  731. WorkDate = beginTime.Date,
  732. WorkQty = item.QtyOrded - item.QtyWorked,
  733. WorkStartTime = beginTime,
  734. WorkEndTime = endTime,
  735. CreateTime = DateTime.Now
  736. });
  737. beginTime = endTime;
  738. //当前工单已排产完成,已排产时间=工单生产时长,已排产数量=工单数量
  739. item.Worked = item.LbrVar;
  740. item.QtyWorked = item.QtyWorked;
  741. //当天剩余产能
  742. residueTime -= needTime;
  743. if (residueTime == 0)
  744. {
  745. break;
  746. }
  747. }
  748. else//当天剩余产能不满足当前工单的剩余待排产时长
  749. {
  750. //计算生产数量
  751. decimal qty = Math.Ceiling(residueTime / item.LbrVar * item.QtyOrded);
  752. //记录生产周期
  753. curSequences.Add(new PeriodSequenceDet
  754. {
  755. Domain = domain,
  756. Line = lineStart.Line,
  757. ItemNum = item.ItemNum,
  758. PlanDate = beginTime.Date,
  759. Period = dto.Period,
  760. OrdQty = qty,
  761. WorkOrds = item.WorkOrd,
  762. Op = item.Op,
  763. IsActive = true,
  764. Status = "",
  765. CreateTime = DateTime.Now
  766. });
  767. //记录排产记录
  768. curScheduleRsts.Add(new ScheduleResultOpMaster
  769. {
  770. Domain = domain,
  771. WorkOrd = item.WorkOrd,
  772. Line = lineStart.Line,
  773. ItemNum = item.ItemNum,
  774. Op = item.Op,
  775. WorkDate = beginTime.Date,
  776. WorkQty = qty,
  777. WorkStartTime = beginTime,
  778. WorkEndTime = endTime,
  779. CreateTime = DateTime.Now
  780. });
  781. item.Worked += residueTime;
  782. item.QtyWorked += qty;
  783. residueTime = 0;
  784. break;
  785. }
  786. }
  787. //特殊工单剩余待排产时长(分钟)
  788. sumTsTimes -= dto.EffTime;
  789. //获取下一个工作日
  790. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  791. }
  792. }
  793. //记录已排产特殊工单
  794. ypcWorkOrds.AddRange(workDtos.Select(p => p.WorkOrd).ToList());
  795. //正常工单排产
  796. //正常工单产线已排产数量
  797. decimal sumQty = 0m;
  798. //产线准备时间(分钟)
  799. decimal sumTimes = 0m;
  800. fstWOMasters.Clear();
  801. workDtos.Clear();
  802. sumTsTimes = 0m;
  803. //正常工单排产第一天标识
  804. bool isFstDay = true;
  805. while (sumQty < workOrd.QtyOrded || sumTsTimes > 0)
  806. {
  807. secWOMasters.Clear();
  808. //获取当天的产能
  809. LineScheduledDto dto = GetScheduledPoint(lineStart, workStartTime, mLCalendars, mlqtyWorkDtls);
  810. //正常工单排产第一天没有特殊工单,第一天之后才需要考虑是否有特殊工单
  811. if (!isFstDay)
  812. {
  813. //获取特殊工单
  814. secWOMasters = tsWorkOrds.Where(p => p.ProdLine == lineStart.Line && p.OrdDate.Value.Date == workStartTime.Date).OrderBy(p => p.OrdDate).ToList();
  815. foreach (var item in secWOMasters)
  816. {
  817. int op = tsWoRoutings.Where(p => p.WorkOrd == item.WorkOrd).OrderByDescending(p => p.OP).First().OP;
  818. workDtos.Add(new WorkOrdMstDto
  819. {
  820. WorkOrd = item.WorkOrd,
  821. ItemNum = item.ItemNum,
  822. QtyOrded = item.QtyOrded,
  823. LbrVar = item.LbrVar * 60,
  824. Worked = 0,
  825. QtyWorked = 0,
  826. Op = op
  827. });
  828. }
  829. //记录特殊工单剩余生产时长
  830. sumTsTimes += secWOMasters.Sum(p => p.LbrVar) * 60;
  831. }
  832. //排产开始时,需要先减去产线准备时间
  833. if (sumTimes < lineStart.setupTime * 60)
  834. {
  835. //当天的可用生产时长能满足提前期
  836. if (dto.EffTime > lineStart.setupTime * 60 - sumTimes)
  837. {
  838. //当天剩余时长(分钟)
  839. decimal residueTime = dto.EffTime - lineStart.setupTime * 60 - sumTimes;
  840. //产线提前期安排完之后,需要考虑当前是否存在特殊工单:
  841. //1、如果当天是排产的最后一天,则先排完正常工单,再安排特殊工单;
  842. //2、如果是排产中间日期,则先安排特殊工单排产
  843. //当天剩余产能
  844. decimal sumAmount = dto.ProductQty - Math.Floor(dto.Rate * (lineStart.setupTime - sumTimes / 60));
  845. //判断已排产数量+当天的产能是否超过工单数量
  846. if (sumQty + sumAmount <= workOrd.QtyOrded)//当天的产能需要全部排产
  847. {
  848. if (sumTsTimes > 0)//当天有特殊工单,先排特殊工单
  849. {
  850. DateTime beginTime = workStartTime;//排产开始时间
  851. DateTime endTime = dto.EndTime;//排产结束时间
  852. //获取当天的工作时间段
  853. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  854. if (curCalendar == null)
  855. {
  856. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  857. }
  858. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, workStartTime, curCalendar, mlqtyWorkDtls);
  859. if (residueTime > sumTsTimes)//当天的可用产能满足特殊工单生产时长
  860. {
  861. //特殊工单排产
  862. foreach (var item in workDtos)
  863. {
  864. if (item.LbrVar == item.Worked)//当前工单已排产,跳过
  865. {
  866. continue;
  867. }
  868. //当前工单还需工作时长
  869. decimal needTime = item.LbrVar - item.Worked;
  870. //计算工单排产结束时间
  871. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  872. span = curPoint.EndPoint - beginTime;
  873. //当天工作时间段的有效生产时间(分钟)
  874. decimal effMins = (decimal)span.TotalMinutes;
  875. if (effMins >= needTime)//当前工作时间段即可满足产能
  876. {
  877. endTime = beginTime.AddMinutes((double)needTime);
  878. }
  879. else
  880. {
  881. //获取后续生产时间段
  882. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  883. //剩余需要工作时长
  884. decimal nextMins = needTime - effMins;
  885. foreach (var p in nextPoints)
  886. {
  887. if (p.WorkMinutes >= nextMins)
  888. {
  889. endTime = p.StartPoint.AddMinutes((double)nextMins);
  890. break;
  891. }
  892. nextMins -= p.WorkMinutes;
  893. }
  894. }
  895. //记录生产周期
  896. curSequences.Add(new PeriodSequenceDet
  897. {
  898. Domain = domain,
  899. Line = lineStart.Line,
  900. ItemNum = item.ItemNum,
  901. PlanDate = beginTime.Date,
  902. Period = dto.Period,
  903. OrdQty = item.QtyOrded - item.QtyWorked,
  904. WorkOrds = item.WorkOrd,
  905. Op = item.Op,
  906. IsActive = true,
  907. Status = "",
  908. CreateTime = DateTime.Now
  909. });
  910. //记录排产记录
  911. curScheduleRsts.Add(new ScheduleResultOpMaster
  912. {
  913. Domain = domain,
  914. WorkOrd = item.WorkOrd,
  915. Line = lineStart.Line,
  916. ItemNum = item.ItemNum,
  917. Op = item.Op,
  918. WorkDate = beginTime.Date,
  919. WorkQty = item.QtyOrded - item.QtyWorked,
  920. WorkStartTime = beginTime,
  921. WorkEndTime = endTime,
  922. CreateTime = DateTime.Now
  923. });
  924. //下一工单开始时间=当前工单结束时间,如果位于工作区间结尾,则为下一工作区间开始时间
  925. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  926. if (endTime == curPoint.EndPoint)//结束时间位于工作区间结尾
  927. {
  928. //获取后续生产时间段
  929. var nextPoint = workPoints.Where(p => p.Level == curPoint.Level + 1).FirstOrDefault();
  930. if (nextPoint != null)//存在后续工作区间
  931. {
  932. endTime = nextPoint.StartPoint;
  933. }
  934. }
  935. beginTime = endTime;
  936. //工单排产完成,排产时长=工单工作时长
  937. item.Worked = item.LbrVar;
  938. item.QtyWorked = item.QtyOrded;
  939. sumTsTimes -= needTime;
  940. }
  941. //处理正常工单开工时间
  942. workStartTime = endTime;
  943. var point = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  944. if (endTime == point.EndPoint)
  945. {
  946. var nextPoint = workPoints.Find(p => p.Level == point.Level + 1);
  947. workStartTime = nextPoint.StartPoint;
  948. }
  949. //剩余产能继续排正常工单
  950. sumAmount = dto.ProductQty - Math.Floor(dto.Rate * (lineStart.setupTime - sumTimes / 60 - sumTsTimes / 60));
  951. //记录生产周期
  952. curSequences.Add(new PeriodSequenceDet
  953. {
  954. Domain = domain,
  955. Line = lineStart.Line,
  956. ItemNum = workOrd.ItemNum,
  957. PlanDate = workStartTime.Date,
  958. Period = dto.Period,
  959. OrdQty = sumAmount,
  960. WorkOrds = workOrd.WorkOrd,
  961. Op = lineStart.Op,
  962. IsActive = true,
  963. Status = "",
  964. CreateTime = DateTime.Now
  965. });
  966. //记录排产记录
  967. curScheduleRsts.Add(new ScheduleResultOpMaster
  968. {
  969. Domain = domain,
  970. WorkOrd = workOrd.WorkOrd,
  971. Line = lineStart.Line,
  972. ItemNum = workOrd.ItemNum,
  973. Op = lineStart.Op,
  974. WorkDate = workStartTime.Date,
  975. WorkQty = sumAmount,
  976. WorkStartTime = workStartTime,
  977. WorkEndTime = dto.EndTime,
  978. CreateTime = DateTime.Now
  979. });
  980. //累计已排产数量
  981. sumQty += sumAmount;
  982. //继续排下一个工作日
  983. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  984. isFstDay = false;
  985. //排产完毕,特殊工单时长置0
  986. sumTsTimes = 0;
  987. }
  988. else//当天的可用产能不满足或者刚好满足特殊工单生产时长
  989. {
  990. foreach (var item in workDtos)
  991. {
  992. if (item.LbrVar == item.Worked)//当前工单已排产
  993. {
  994. continue;
  995. }
  996. //当前工单剩余待排产时长(分钟)
  997. decimal needTime = item.LbrVar - item.Worked;
  998. if (residueTime >= needTime)//当天剩余产能满足当前工单的剩余待排产时长
  999. {
  1000. //计算工单排产结束时间
  1001. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1002. span = curPoint.EndPoint - beginTime;
  1003. //当前工作时间段的有效生产时间(分钟)
  1004. decimal effMins = (decimal)span.TotalMinutes;
  1005. if (effMins >= needTime)//当前工作时间段即可满足产能
  1006. {
  1007. endTime = beginTime.AddMinutes((double)needTime);
  1008. }
  1009. else
  1010. {
  1011. //获取后续生产时间段
  1012. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  1013. //剩余需要工作时长
  1014. decimal nextMins = needTime - effMins;
  1015. foreach (var p in nextPoints)
  1016. {
  1017. if (p.WorkMinutes >= nextMins)
  1018. {
  1019. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1020. break;
  1021. }
  1022. nextMins -= p.WorkMinutes;
  1023. }
  1024. }
  1025. //记录生产周期
  1026. curSequences.Add(new PeriodSequenceDet
  1027. {
  1028. Domain = domain,
  1029. Line = lineStart.Line,
  1030. ItemNum = item.ItemNum,
  1031. PlanDate = beginTime.Date,
  1032. Period = dto.Period,
  1033. OrdQty = item.QtyOrded - item.QtyWorked,
  1034. WorkOrds = item.WorkOrd,
  1035. Op = item.Op,
  1036. IsActive = true,
  1037. Status = "",
  1038. CreateTime = DateTime.Now
  1039. });
  1040. //记录排产记录
  1041. curScheduleRsts.Add(new ScheduleResultOpMaster
  1042. {
  1043. Domain = domain,
  1044. WorkOrd = item.WorkOrd,
  1045. Line = lineStart.Line,
  1046. ItemNum = item.ItemNum,
  1047. Op = item.Op,
  1048. WorkDate = beginTime.Date,
  1049. WorkQty = item.QtyOrded - item.QtyWorked,
  1050. WorkStartTime = beginTime,
  1051. WorkEndTime = endTime,
  1052. CreateTime = DateTime.Now
  1053. });
  1054. beginTime = endTime;
  1055. //当前工单已排产完成,已排产时间=工单生产时长,已排产数量=工单数量
  1056. item.Worked = item.LbrVar;
  1057. item.QtyWorked = item.QtyWorked;
  1058. //当天剩余产能
  1059. residueTime -= needTime;
  1060. if (residueTime == 0)
  1061. {
  1062. break;
  1063. }
  1064. }
  1065. else//当天剩余产能不满足当前工单的剩余待排产时长
  1066. {
  1067. //计算生产数量
  1068. decimal qty = Math.Ceiling(residueTime / item.LbrVar * item.QtyOrded);
  1069. //记录生产周期
  1070. curSequences.Add(new PeriodSequenceDet
  1071. {
  1072. Domain = domain,
  1073. Line = lineStart.Line,
  1074. ItemNum = item.ItemNum,
  1075. PlanDate = beginTime.Date,
  1076. Period = dto.Period,
  1077. OrdQty = qty,
  1078. WorkOrds = item.WorkOrd,
  1079. Op = item.Op,
  1080. IsActive = true,
  1081. Status = "",
  1082. CreateTime = DateTime.Now
  1083. });
  1084. //记录排产记录
  1085. curScheduleRsts.Add(new ScheduleResultOpMaster
  1086. {
  1087. Domain = domain,
  1088. WorkOrd = item.WorkOrd,
  1089. Line = lineStart.Line,
  1090. ItemNum = item.ItemNum,
  1091. Op = item.Op,
  1092. WorkDate = beginTime.Date,
  1093. WorkQty = qty,
  1094. WorkStartTime = beginTime,
  1095. WorkEndTime = endTime,
  1096. CreateTime = DateTime.Now
  1097. });
  1098. item.Worked += residueTime;
  1099. item.QtyWorked += qty;
  1100. break;
  1101. }
  1102. }
  1103. //特殊工单剩余待排产时长(分钟)
  1104. sumTsTimes -= residueTime;
  1105. //获取下一个工作日
  1106. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1107. isFstDay = false;
  1108. }
  1109. }
  1110. else { //当天没有特殊工单
  1111. #region 正常工单排产-开始
  1112. //记录生产周期
  1113. curSequences.Add(new PeriodSequenceDet
  1114. {
  1115. Domain = domain,
  1116. Line = lineStart.Line,
  1117. ItemNum = workOrd.ItemNum,
  1118. PlanDate = workStartTime.Date,
  1119. Period = dto.Period,
  1120. OrdQty = sumAmount,
  1121. WorkOrds = workOrd.WorkOrd,
  1122. Op = lineStart.Op,
  1123. IsActive = true,
  1124. Status = "",
  1125. CreateTime = DateTime.Now
  1126. });
  1127. //记录排产记录
  1128. curScheduleRsts.Add(new ScheduleResultOpMaster
  1129. {
  1130. Domain = domain,
  1131. WorkOrd = workOrd.WorkOrd,
  1132. Line = lineStart.Line,
  1133. ItemNum = workOrd.ItemNum,
  1134. Op = lineStart.Op,
  1135. WorkDate = workStartTime.Date,
  1136. WorkQty = sumAmount,
  1137. WorkStartTime = dto.StartTime,
  1138. WorkEndTime = dto.EndTime,
  1139. CreateTime = DateTime.Now
  1140. });
  1141. //累计已排产数量
  1142. sumQty += sumAmount;
  1143. //继续排下一个工作日
  1144. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1145. isFstDay = false;
  1146. #endregion 正常工单排产-结束
  1147. }
  1148. }
  1149. else// 当天的产能正常工单只能占用一部分
  1150. {
  1151. #region 正常工单排产-开始
  1152. //剩余需要排产的数量
  1153. decimal residueQty = workOrd.QtyOrded - sumQty;
  1154. //剩余数量生产需要时长(分钟)
  1155. decimal workTime = Math.Ceiling(residueQty / dto.Rate * 60);
  1156. //获取当天的工作时间段
  1157. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  1158. if (curCalendar == null)
  1159. {
  1160. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  1161. }
  1162. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, workStartTime, curCalendar, mlqtyWorkDtls);
  1163. var curPoint = workPoints.Find(p => p.StartPoint <= workStartTime && workStartTime <= p.EndPoint);
  1164. span = curPoint.EndPoint - workStartTime;
  1165. //当天工作时间段的有效生产时间
  1166. decimal effMins = (decimal)span.TotalMinutes;
  1167. DateTime workEndTime = workStartTime;
  1168. if (effMins >= workTime)//当前工作时间段即可满足产能
  1169. {
  1170. workEndTime = workStartTime.AddMinutes((double)workTime);
  1171. }
  1172. else
  1173. {
  1174. //获取后续生产时间段
  1175. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  1176. //剩余需要工作时长
  1177. decimal nextMins = workTime - effMins;
  1178. foreach (var p in nextPoints)
  1179. {
  1180. if (p.WorkMinutes >= nextMins)
  1181. {
  1182. workEndTime = p.StartPoint.AddMinutes((double)nextMins);
  1183. break;
  1184. }
  1185. nextMins -= p.WorkMinutes;
  1186. }
  1187. }
  1188. sumQty = workOrd.QtyOrded;
  1189. //记录生产周期
  1190. curSequences.Add(new PeriodSequenceDet
  1191. {
  1192. Domain = domain,
  1193. Line = lineStart.Line,
  1194. ItemNum = workOrd.ItemNum,
  1195. PlanDate = workStartTime.Date,
  1196. Period = dto.Period,
  1197. OrdQty = residueQty,
  1198. WorkOrds = workOrd.WorkOrd,
  1199. Op = lineStart.Op,
  1200. IsActive = true,
  1201. Status = "",
  1202. CreateTime = DateTime.Now
  1203. });
  1204. //记录排产记录
  1205. curScheduleRsts.Add(new ScheduleResultOpMaster
  1206. {
  1207. Domain = domain,
  1208. WorkOrd = workOrd.WorkOrd,
  1209. Line = lineStart.Line,
  1210. ItemNum = workOrd.ItemNum,
  1211. Op = lineStart.Op,
  1212. WorkDate = workStartTime.Date,
  1213. WorkQty = residueQty,
  1214. WorkStartTime = workStartTime,
  1215. WorkEndTime = workEndTime,
  1216. CreateTime = DateTime.Now
  1217. });
  1218. #endregion 正常工单排产-结束
  1219. #region 特殊工单排产-开始
  1220. //当天剩余产能
  1221. decimal restTime = residueTime - workTime;
  1222. if (sumTsTimes > 0)
  1223. {
  1224. DateTime beginTime = workEndTime;//排产开始时间
  1225. DateTime endTime = dto.EndTime;//排产结束时间
  1226. if (restTime >= sumTsTimes)//当天的可用产能满足特殊工单生产时长
  1227. {
  1228. foreach (var item in workDtos)
  1229. {
  1230. if (item.LbrVar == item.Worked)//当前工单已排产,跳过
  1231. {
  1232. continue;
  1233. }
  1234. //当前工单还需工作时长
  1235. decimal needTime = item.LbrVar - item.Worked;
  1236. //计算工单排产结束时间
  1237. curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1238. span = curPoint.EndPoint - beginTime;
  1239. //当天工作时间段的有效生产时间(分钟)
  1240. effMins = (decimal)span.TotalMinutes;
  1241. if (effMins >= needTime)//当前工作时间段即可满足产能
  1242. {
  1243. endTime = beginTime.AddMinutes((double)needTime);
  1244. }
  1245. else
  1246. {
  1247. //获取后续生产时间段
  1248. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  1249. //剩余需要工作时长
  1250. decimal nextMins = needTime - effMins;
  1251. foreach (var p in nextPoints)
  1252. {
  1253. if (p.WorkMinutes >= nextMins)
  1254. {
  1255. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1256. break;
  1257. }
  1258. nextMins -= p.WorkMinutes;
  1259. }
  1260. }
  1261. //记录生产周期
  1262. curSequences.Add(new PeriodSequenceDet
  1263. {
  1264. Domain = domain,
  1265. Line = lineStart.Line,
  1266. ItemNum = item.ItemNum,
  1267. PlanDate = beginTime.Date,
  1268. Period = dto.Period,
  1269. OrdQty = item.QtyOrded - item.QtyWorked,
  1270. WorkOrds = item.WorkOrd,
  1271. Op = item.Op,
  1272. IsActive = true,
  1273. Status = "",
  1274. CreateTime = DateTime.Now
  1275. });
  1276. //记录排产记录
  1277. curScheduleRsts.Add(new ScheduleResultOpMaster
  1278. {
  1279. Domain = domain,
  1280. WorkOrd = item.WorkOrd,
  1281. Line = lineStart.Line,
  1282. ItemNum = item.ItemNum,
  1283. Op = item.Op,
  1284. WorkDate = beginTime.Date,
  1285. WorkQty = item.QtyOrded - item.QtyWorked,
  1286. WorkStartTime = beginTime,
  1287. WorkEndTime = endTime,
  1288. CreateTime = DateTime.Now
  1289. });
  1290. //下一工单开始时间=当前工单结束时间,如果位于工作区间结尾,则为下一工作区间开始时间
  1291. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  1292. if (endTime == curPoint.EndPoint)//结束时间位于工作区间结尾
  1293. {
  1294. //获取后续生产时间段
  1295. var nextPoint = workPoints.Where(p => p.Level == curPoint.Level + 1).FirstOrDefault();
  1296. if (nextPoint != null)//存在后续工作区间
  1297. {
  1298. endTime = nextPoint.StartPoint;
  1299. }
  1300. }
  1301. beginTime = endTime;
  1302. //工单排产完成,排产时长=工单工作时长
  1303. item.Worked = item.LbrVar;
  1304. item.QtyWorked = item.QtyOrded;
  1305. sumTsTimes -= needTime;
  1306. }
  1307. sumTsTimes = 0;//排产完毕,特殊工单时长置0
  1308. }
  1309. else//当天的可用产能不满足特殊工单生产时长
  1310. {
  1311. foreach (var item in workDtos)
  1312. {
  1313. if (item.LbrVar == item.Worked)//当前工单已排产
  1314. {
  1315. continue;
  1316. }
  1317. //当前工单剩余待排产时长(分钟)
  1318. decimal needTime = item.LbrVar - item.Worked;
  1319. if (restTime >= needTime)//当天剩余产能满足当前工单的剩余待排产时长
  1320. {
  1321. //计算工单排产结束时间
  1322. curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1323. span = curPoint.EndPoint - beginTime;
  1324. //当前工作时间段的有效生产时间(分钟)
  1325. effMins = (decimal)span.TotalMinutes;
  1326. if (effMins >= needTime)//当前工作时间段即可满足产能
  1327. {
  1328. endTime = beginTime.AddMinutes((double)needTime);
  1329. }
  1330. else
  1331. {
  1332. //获取后续生产时间段
  1333. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  1334. //剩余需要工作时长
  1335. decimal nextMins = needTime - effMins;
  1336. foreach (var p in nextPoints)
  1337. {
  1338. if (p.WorkMinutes >= nextMins)
  1339. {
  1340. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1341. break;
  1342. }
  1343. nextMins -= p.WorkMinutes;
  1344. }
  1345. }
  1346. //记录生产周期
  1347. curSequences.Add(new PeriodSequenceDet
  1348. {
  1349. Domain = domain,
  1350. Line = lineStart.Line,
  1351. ItemNum = item.ItemNum,
  1352. PlanDate = beginTime.Date,
  1353. Period = dto.Period,
  1354. OrdQty = item.QtyOrded - item.QtyWorked,
  1355. WorkOrds = item.WorkOrd,
  1356. Op = item.Op,
  1357. IsActive = true,
  1358. Status = "",
  1359. CreateTime = DateTime.Now
  1360. });
  1361. //记录排产记录
  1362. curScheduleRsts.Add(new ScheduleResultOpMaster
  1363. {
  1364. Domain = domain,
  1365. WorkOrd = item.WorkOrd,
  1366. Line = lineStart.Line,
  1367. ItemNum = item.ItemNum,
  1368. Op = item.Op,
  1369. WorkDate = beginTime.Date,
  1370. WorkQty = item.QtyOrded - item.QtyWorked,
  1371. WorkStartTime = beginTime,
  1372. WorkEndTime = endTime,
  1373. CreateTime = DateTime.Now
  1374. });
  1375. beginTime = endTime;
  1376. //当前工单已排产完成,已排产时间=工单生产时长,已排产数量=工单数量
  1377. item.Worked = item.LbrVar;
  1378. item.QtyWorked = item.QtyWorked;
  1379. //当天剩余产能
  1380. restTime -= needTime;
  1381. if (restTime == 0)
  1382. {
  1383. break;
  1384. }
  1385. }
  1386. else//当天剩余产能不满足当前工单的剩余待排产时长
  1387. {
  1388. //计算生产数量
  1389. decimal qty = Math.Ceiling(restTime / item.LbrVar * item.QtyOrded);
  1390. //记录生产周期
  1391. curSequences.Add(new PeriodSequenceDet
  1392. {
  1393. Domain = domain,
  1394. Line = lineStart.Line,
  1395. ItemNum = item.ItemNum,
  1396. PlanDate = beginTime.Date,
  1397. Period = dto.Period,
  1398. OrdQty = qty,
  1399. WorkOrds = item.WorkOrd,
  1400. Op = item.Op,
  1401. IsActive = true,
  1402. Status = "",
  1403. CreateTime = DateTime.Now
  1404. });
  1405. //记录排产记录
  1406. curScheduleRsts.Add(new ScheduleResultOpMaster
  1407. {
  1408. Domain = domain,
  1409. WorkOrd = item.WorkOrd,
  1410. Line = lineStart.Line,
  1411. ItemNum = item.ItemNum,
  1412. Op = item.Op,
  1413. WorkDate = beginTime.Date,
  1414. WorkQty = qty,
  1415. WorkStartTime = beginTime,
  1416. WorkEndTime = endTime,
  1417. CreateTime = DateTime.Now
  1418. });
  1419. item.Worked += restTime;
  1420. item.QtyWorked += qty;
  1421. break;
  1422. }
  1423. }
  1424. //特殊工单剩余待排产时长(分钟)
  1425. sumTsTimes -= restTime;
  1426. //获取下一个工作日
  1427. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1428. isFstDay = false;
  1429. }
  1430. }
  1431. #endregion 特殊工单排产-结束
  1432. }
  1433. //记录提前期
  1434. sumTimes = lineStart.setupTime * 60;
  1435. }
  1436. else//当天可用生产时长不能满足或者刚好满足提前期
  1437. {
  1438. //当天的可用生产时长不能满足提前期
  1439. sumTimes += dto.EffTime;
  1440. //获取下一个工作日
  1441. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1442. isFstDay = false;
  1443. }
  1444. }
  1445. else
  1446. {
  1447. //判断已排产数量+当天的产能是否超过工单数量
  1448. if (sumQty + dto.ProductQty <= workOrd.QtyOrded)//当天的产能需要全部排产
  1449. {
  1450. if (sumTsTimes > 0)//当天有特殊工单,先排特殊工单
  1451. {
  1452. //当天剩余产能(分钟)
  1453. decimal residueTime = dto.EffTime;
  1454. DateTime beginTime = workStartTime;//排产开始时间
  1455. DateTime endTime = dto.EndTime;//排产结束时间
  1456. //获取当天的工作时间段
  1457. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  1458. if (curCalendar == null)
  1459. {
  1460. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  1461. }
  1462. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, workStartTime, curCalendar, mlqtyWorkDtls);
  1463. if (residueTime > sumTsTimes)//当天的可用产能满足特殊工单生产时长
  1464. {
  1465. //特殊工单排产
  1466. foreach (var item in workDtos)
  1467. {
  1468. if (item.LbrVar == item.Worked)//当前工单已排产,跳过
  1469. {
  1470. continue;
  1471. }
  1472. //当前工单还需工作时长
  1473. decimal needTime = item.LbrVar - item.Worked;
  1474. //计算工单排产结束时间
  1475. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1476. span = curPoint.EndPoint - beginTime;
  1477. //当天工作时间段的有效生产时间(分钟)
  1478. decimal effMins = (decimal)span.TotalMinutes;
  1479. if (effMins >= needTime)//当前工作时间段即可满足产能
  1480. {
  1481. endTime = beginTime.AddMinutes((double)needTime);
  1482. }
  1483. else
  1484. {
  1485. //获取后续生产时间段
  1486. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  1487. //剩余需要工作时长
  1488. decimal nextMins = needTime - effMins;
  1489. foreach (var p in nextPoints)
  1490. {
  1491. if (p.WorkMinutes >= nextMins)
  1492. {
  1493. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1494. break;
  1495. }
  1496. nextMins -= p.WorkMinutes;
  1497. }
  1498. }
  1499. //记录生产周期
  1500. curSequences.Add(new PeriodSequenceDet
  1501. {
  1502. Domain = domain,
  1503. Line = lineStart.Line,
  1504. ItemNum = item.ItemNum,
  1505. PlanDate = beginTime.Date,
  1506. Period = dto.Period,
  1507. OrdQty = item.QtyOrded - item.QtyWorked,
  1508. WorkOrds = item.WorkOrd,
  1509. Op = item.Op,
  1510. IsActive = true,
  1511. Status = "",
  1512. CreateTime = DateTime.Now
  1513. });
  1514. //记录排产记录
  1515. curScheduleRsts.Add(new ScheduleResultOpMaster
  1516. {
  1517. Domain = domain,
  1518. WorkOrd = item.WorkOrd,
  1519. Line = lineStart.Line,
  1520. ItemNum = item.ItemNum,
  1521. Op = item.Op,
  1522. WorkDate = beginTime.Date,
  1523. WorkQty = item.QtyOrded - item.QtyWorked,
  1524. WorkStartTime = beginTime,
  1525. WorkEndTime = endTime,
  1526. CreateTime = DateTime.Now
  1527. });
  1528. //下一工单开始时间=当前工单结束时间,如果位于工作区间结尾,则为下一工作区间开始时间
  1529. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  1530. if (endTime == curPoint.EndPoint)//结束时间位于工作区间结尾
  1531. {
  1532. //获取后续生产时间段
  1533. var nextPoint = workPoints.Where(p => p.Level == curPoint.Level + 1).FirstOrDefault();
  1534. if (nextPoint != null)//存在后续工作区间
  1535. {
  1536. endTime = nextPoint.StartPoint;
  1537. }
  1538. }
  1539. beginTime = endTime;
  1540. //工单排产完成,排产时长=工单工作时长
  1541. item.Worked = item.LbrVar;
  1542. item.QtyWorked = item.QtyOrded;
  1543. sumTsTimes -= needTime;
  1544. }
  1545. //处理正常工单开工时间
  1546. workStartTime = endTime;
  1547. var point = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  1548. if (endTime == point.EndPoint)
  1549. {
  1550. var nextPoint = workPoints.Find(p => p.Level == point.Level + 1);
  1551. workStartTime = nextPoint.StartPoint;
  1552. }
  1553. //剩余产能继续排正常工单
  1554. decimal sumAmount = dto.ProductQty - Math.Floor(dto.Rate * (dto.EffTime - sumTsTimes) / 60);
  1555. //记录生产周期
  1556. curSequences.Add(new PeriodSequenceDet
  1557. {
  1558. Domain = domain,
  1559. Line = lineStart.Line,
  1560. ItemNum = workOrd.ItemNum,
  1561. PlanDate = workStartTime.Date,
  1562. Period = dto.Period,
  1563. OrdQty = sumAmount,
  1564. WorkOrds = workOrd.WorkOrd,
  1565. Op = lineStart.Op,
  1566. IsActive = true,
  1567. Status = "",
  1568. CreateTime = DateTime.Now
  1569. });
  1570. //记录排产记录
  1571. curScheduleRsts.Add(new ScheduleResultOpMaster
  1572. {
  1573. Domain = domain,
  1574. WorkOrd = workOrd.WorkOrd,
  1575. Line = lineStart.Line,
  1576. ItemNum = workOrd.ItemNum,
  1577. Op = lineStart.Op,
  1578. WorkDate = workStartTime.Date,
  1579. WorkQty = sumAmount,
  1580. WorkStartTime = workStartTime,
  1581. WorkEndTime = dto.EndTime,
  1582. CreateTime = DateTime.Now
  1583. });
  1584. //累计已排产数量
  1585. sumQty += sumAmount;
  1586. //继续排下一个工作日
  1587. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1588. isFstDay = false;
  1589. //排产完毕,特殊工单时长置0
  1590. sumTsTimes = 0;
  1591. }
  1592. else//当天的可用产能不满足或者刚好满足特殊工单生产时长
  1593. {
  1594. foreach (var item in workDtos)
  1595. {
  1596. if (item.LbrVar == item.Worked)//当前工单已排产
  1597. {
  1598. continue;
  1599. }
  1600. //当前工单剩余待排产时长(分钟)
  1601. decimal needTime = item.LbrVar - item.Worked;
  1602. if (residueTime >= needTime)//当天剩余产能满足当前工单的剩余待排产时长
  1603. {
  1604. //计算工单排产结束时间
  1605. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1606. span = curPoint.EndPoint - beginTime;
  1607. //当前工作时间段的有效生产时间(分钟)
  1608. decimal effMins = (decimal)span.TotalMinutes;
  1609. if (effMins >= needTime)//当前工作时间段即可满足产能
  1610. {
  1611. endTime = beginTime.AddMinutes((double)needTime);
  1612. }
  1613. else
  1614. {
  1615. //获取后续生产时间段
  1616. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  1617. //剩余需要工作时长
  1618. decimal nextMins = needTime - effMins;
  1619. foreach (var p in nextPoints)
  1620. {
  1621. if (p.WorkMinutes >= nextMins)
  1622. {
  1623. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1624. break;
  1625. }
  1626. nextMins -= p.WorkMinutes;
  1627. }
  1628. }
  1629. //记录生产周期
  1630. curSequences.Add(new PeriodSequenceDet
  1631. {
  1632. Domain = domain,
  1633. Line = lineStart.Line,
  1634. ItemNum = item.ItemNum,
  1635. PlanDate = beginTime.Date,
  1636. Period = dto.Period,
  1637. OrdQty = item.QtyOrded - item.QtyWorked,
  1638. WorkOrds = item.WorkOrd,
  1639. Op = item.Op,
  1640. IsActive = true,
  1641. Status = "",
  1642. CreateTime = DateTime.Now
  1643. });
  1644. //记录排产记录
  1645. curScheduleRsts.Add(new ScheduleResultOpMaster
  1646. {
  1647. Domain = domain,
  1648. WorkOrd = item.WorkOrd,
  1649. Line = lineStart.Line,
  1650. ItemNum = item.ItemNum,
  1651. Op = item.Op,
  1652. WorkDate = beginTime.Date,
  1653. WorkQty = item.QtyOrded - item.QtyWorked,
  1654. WorkStartTime = beginTime,
  1655. WorkEndTime = endTime,
  1656. CreateTime = DateTime.Now
  1657. });
  1658. beginTime = endTime;
  1659. //当前工单已排产完成,已排产时间=工单生产时长,已排产数量=工单数量
  1660. item.Worked = item.LbrVar;
  1661. item.QtyWorked = item.QtyWorked;
  1662. //当天剩余产能
  1663. residueTime -= needTime;
  1664. if (residueTime == 0)
  1665. {
  1666. break;
  1667. }
  1668. }
  1669. else//当天剩余产能不满足当前工单的剩余待排产时长
  1670. {
  1671. //计算生产数量
  1672. decimal qty = Math.Ceiling(residueTime / item.LbrVar * item.QtyOrded);
  1673. //记录生产周期
  1674. curSequences.Add(new PeriodSequenceDet
  1675. {
  1676. Domain = domain,
  1677. Line = lineStart.Line,
  1678. ItemNum = item.ItemNum,
  1679. PlanDate = beginTime.Date,
  1680. Period = dto.Period,
  1681. OrdQty = qty,
  1682. WorkOrds = item.WorkOrd,
  1683. Op = item.Op,
  1684. IsActive = true,
  1685. Status = "",
  1686. CreateTime = DateTime.Now
  1687. });
  1688. //记录排产记录
  1689. curScheduleRsts.Add(new ScheduleResultOpMaster
  1690. {
  1691. Domain = domain,
  1692. WorkOrd = item.WorkOrd,
  1693. Line = lineStart.Line,
  1694. ItemNum = item.ItemNum,
  1695. Op = item.Op,
  1696. WorkDate = beginTime.Date,
  1697. WorkQty = qty,
  1698. WorkStartTime = beginTime,
  1699. WorkEndTime = endTime,
  1700. CreateTime = DateTime.Now
  1701. });
  1702. item.Worked += residueTime;
  1703. item.QtyWorked += qty;
  1704. break;
  1705. }
  1706. }
  1707. //特殊工单剩余待排产时长(分钟)
  1708. sumTsTimes -= residueTime;
  1709. //获取下一个工作日
  1710. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1711. isFstDay = false;
  1712. }
  1713. }
  1714. else {//不存在特殊工单
  1715. //记录生产周期
  1716. curSequences.Add(new PeriodSequenceDet
  1717. {
  1718. Domain = domain,
  1719. Line = lineStart.Line,
  1720. ItemNum = workOrd.ItemNum,
  1721. PlanDate = workStartTime.Date,
  1722. Period = dto.Period,
  1723. OrdQty = dto.ProductQty,
  1724. WorkOrds = workOrd.WorkOrd,
  1725. Op = lineStart.Op,
  1726. IsActive = true,
  1727. Status = "",
  1728. CreateTime = DateTime.Now
  1729. });
  1730. //记录排产记录
  1731. curScheduleRsts.Add(new ScheduleResultOpMaster
  1732. {
  1733. Domain = domain,
  1734. WorkOrd = workOrd.WorkOrd,
  1735. Line = lineStart.Line,
  1736. ItemNum = workOrd.ItemNum,
  1737. Op = lineStart.Op,
  1738. WorkDate = workStartTime.Date,
  1739. WorkQty = dto.ProductQty,
  1740. WorkStartTime = dto.StartTime,
  1741. WorkEndTime = dto.EndTime,
  1742. CreateTime = DateTime.Now
  1743. });
  1744. //累计已排产数量
  1745. sumQty += dto.ProductQty;
  1746. //继续排下一个工作日
  1747. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  1748. isFstDay = false;
  1749. }
  1750. }
  1751. else// 当天的产能正常工单只能占用一部分
  1752. {
  1753. decimal workTime = 0m;
  1754. DateTime workEndTime = workStartTime;
  1755. //获取当天的工作时间段
  1756. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  1757. if (curCalendar == null)
  1758. {
  1759. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  1760. }
  1761. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, workStartTime, curCalendar, mlqtyWorkDtls);
  1762. if (sumQty < workOrd.QtyOrded)
  1763. {
  1764. #region 正常工单排产-开始
  1765. //剩余需要排产的数量
  1766. decimal residueQty = workOrd.QtyOrded - sumQty;
  1767. //剩余数量生产需要时长(分钟)
  1768. workTime = Math.Ceiling(residueQty / dto.Rate * 60);
  1769. var curPoint = workPoints.Find(p => p.StartPoint <= workStartTime && workStartTime <= p.EndPoint);
  1770. span = curPoint.EndPoint - workStartTime;
  1771. //当天工作时间段的有效生产时间
  1772. decimal effMins = (decimal)span.TotalMinutes;
  1773. if (effMins >= workTime)//当前工作时间段即可满足产能
  1774. {
  1775. workEndTime = workStartTime.AddMinutes((double)workTime);
  1776. }
  1777. else
  1778. {
  1779. //获取后续生产时间段
  1780. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  1781. //剩余需要工作时长
  1782. decimal nextMins = workTime - effMins;
  1783. foreach (var p in nextPoints)
  1784. {
  1785. if (p.WorkMinutes >= nextMins)
  1786. {
  1787. workEndTime = p.StartPoint.AddMinutes((double)nextMins);
  1788. break;
  1789. }
  1790. nextMins -= p.WorkMinutes;
  1791. }
  1792. }
  1793. sumQty = workOrd.QtyOrded;
  1794. //记录生产周期
  1795. curSequences.Add(new PeriodSequenceDet
  1796. {
  1797. Domain = domain,
  1798. Line = lineStart.Line,
  1799. ItemNum = workOrd.ItemNum,
  1800. PlanDate = workStartTime.Date,
  1801. Period = dto.Period,
  1802. OrdQty = residueQty,
  1803. WorkOrds = workOrd.WorkOrd,
  1804. Op = lineStart.Op,
  1805. IsActive = true,
  1806. Status = "",
  1807. CreateTime = DateTime.Now
  1808. });
  1809. //记录排产记录
  1810. curScheduleRsts.Add(new ScheduleResultOpMaster
  1811. {
  1812. Domain = domain,
  1813. WorkOrd = workOrd.WorkOrd,
  1814. Line = lineStart.Line,
  1815. ItemNum = workOrd.ItemNum,
  1816. Op = lineStart.Op,
  1817. WorkDate = workStartTime.Date,
  1818. WorkQty = residueQty,
  1819. WorkStartTime = workStartTime,
  1820. WorkEndTime = workEndTime,
  1821. CreateTime = DateTime.Now
  1822. });
  1823. #endregion 正常工单排产-结束
  1824. }
  1825. #region 特殊工单排产-开始
  1826. //当天剩余产能(分钟)
  1827. decimal restTime = dto.EffTime - workTime;
  1828. if (sumTsTimes > 0)//存在特殊工单
  1829. {
  1830. DateTime beginTime = workEndTime;//排产开始时间
  1831. DateTime endTime = dto.EndTime;//排产结束时间
  1832. if (restTime >= sumTsTimes)//当天的可用产能满足特殊工单生产时长
  1833. {
  1834. foreach (var item in workDtos)
  1835. {
  1836. if (item.LbrVar == item.Worked)//当前工单已排产,跳过
  1837. {
  1838. continue;
  1839. }
  1840. //当前工单还需工作时长
  1841. decimal needTime = item.LbrVar - item.Worked;
  1842. //计算工单排产结束时间
  1843. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1844. span = curPoint.EndPoint - beginTime;
  1845. //当天工作时间段的有效生产时间(分钟)
  1846. decimal effMins = (decimal)span.TotalMinutes;
  1847. if (effMins >= needTime)//当前工作时间段即可满足产能
  1848. {
  1849. endTime = beginTime.AddMinutes((double)needTime);
  1850. }
  1851. else
  1852. {
  1853. //获取后续生产时间段
  1854. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  1855. //剩余需要工作时长
  1856. decimal nextMins = needTime - effMins;
  1857. foreach (var p in nextPoints)
  1858. {
  1859. if (p.WorkMinutes >= nextMins)
  1860. {
  1861. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1862. break;
  1863. }
  1864. nextMins -= p.WorkMinutes;
  1865. }
  1866. }
  1867. //记录生产周期
  1868. curSequences.Add(new PeriodSequenceDet
  1869. {
  1870. Domain = domain,
  1871. Line = lineStart.Line,
  1872. ItemNum = item.ItemNum,
  1873. PlanDate = beginTime.Date,
  1874. Period = dto.Period,
  1875. OrdQty = item.QtyOrded - item.QtyWorked,
  1876. WorkOrds = item.WorkOrd,
  1877. Op = item.Op,
  1878. IsActive = true,
  1879. Status = "",
  1880. CreateTime = DateTime.Now
  1881. });
  1882. //记录排产记录
  1883. curScheduleRsts.Add(new ScheduleResultOpMaster
  1884. {
  1885. Domain = domain,
  1886. WorkOrd = item.WorkOrd,
  1887. Line = lineStart.Line,
  1888. ItemNum = item.ItemNum,
  1889. Op = item.Op,
  1890. WorkDate = beginTime.Date,
  1891. WorkQty = item.QtyOrded - item.QtyWorked,
  1892. WorkStartTime = beginTime,
  1893. WorkEndTime = endTime,
  1894. CreateTime = DateTime.Now
  1895. });
  1896. //下一工单开始时间=当前工单结束时间,如果位于工作区间结尾,则为下一工作区间开始时间
  1897. curPoint = workPoints.Find(p => p.StartPoint <= endTime && endTime <= p.EndPoint);
  1898. if (endTime == curPoint.EndPoint)//结束时间位于工作区间结尾
  1899. {
  1900. //获取后续生产时间段
  1901. var nextPoint = workPoints.Where(p => p.Level == curPoint.Level + 1).FirstOrDefault();
  1902. if (nextPoint != null)//存在后续工作区间
  1903. {
  1904. endTime = nextPoint.StartPoint;
  1905. }
  1906. }
  1907. beginTime = endTime;
  1908. //工单排产完成,排产时长=工单工作时长
  1909. item.Worked = item.LbrVar;
  1910. item.QtyWorked = item.QtyOrded;
  1911. sumTsTimes -= needTime;
  1912. }
  1913. sumTsTimes = 0;//排产完毕,特殊工单时长置0
  1914. }
  1915. else//当天的可用产能不满足特殊工单生产时长
  1916. {
  1917. foreach (var item in workDtos)
  1918. {
  1919. if (item.LbrVar == item.Worked)//当前工单已排产
  1920. {
  1921. continue;
  1922. }
  1923. //当前工单剩余待排产时长(分钟)
  1924. decimal needTime = item.LbrVar - item.Worked;
  1925. if (restTime >= needTime)//当天剩余产能满足当前工单的剩余待排产时长
  1926. {
  1927. //计算工单排产结束时间
  1928. var curPoint = workPoints.Find(p => p.StartPoint <= beginTime && beginTime <= p.EndPoint);
  1929. span = curPoint.EndPoint - beginTime;
  1930. //当前工作时间段的有效生产时间(分钟)
  1931. decimal effMins = (decimal)span.TotalMinutes;
  1932. if (effMins >= needTime)//当前工作时间段即可满足产能
  1933. {
  1934. endTime = beginTime.AddMinutes((double)needTime);
  1935. }
  1936. else
  1937. {
  1938. //获取后续生产时间段
  1939. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  1940. //剩余需要工作时长
  1941. decimal nextMins = needTime - effMins;
  1942. foreach (var p in nextPoints)
  1943. {
  1944. if (p.WorkMinutes >= nextMins)
  1945. {
  1946. endTime = p.StartPoint.AddMinutes((double)nextMins);
  1947. break;
  1948. }
  1949. nextMins -= p.WorkMinutes;
  1950. }
  1951. }
  1952. //记录生产周期
  1953. curSequences.Add(new PeriodSequenceDet
  1954. {
  1955. Domain = domain,
  1956. Line = lineStart.Line,
  1957. ItemNum = item.ItemNum,
  1958. PlanDate = beginTime.Date,
  1959. Period = dto.Period,
  1960. OrdQty = item.QtyOrded - item.QtyWorked,
  1961. WorkOrds = item.WorkOrd,
  1962. Op = item.Op,
  1963. IsActive = true,
  1964. Status = "",
  1965. CreateTime = DateTime.Now
  1966. });
  1967. //记录排产记录
  1968. curScheduleRsts.Add(new ScheduleResultOpMaster
  1969. {
  1970. Domain = domain,
  1971. WorkOrd = item.WorkOrd,
  1972. Line = lineStart.Line,
  1973. ItemNum = item.ItemNum,
  1974. Op = item.Op,
  1975. WorkDate = beginTime.Date,
  1976. WorkQty = item.QtyOrded - item.QtyWorked,
  1977. WorkStartTime = beginTime,
  1978. WorkEndTime = endTime,
  1979. CreateTime = DateTime.Now
  1980. });
  1981. beginTime = endTime;
  1982. //当前工单已排产完成,已排产时间=工单生产时长,已排产数量=工单数量
  1983. item.Worked = item.LbrVar;
  1984. item.QtyWorked = item.QtyWorked;
  1985. //当天剩余产能
  1986. restTime -= needTime;
  1987. if (restTime == 0)
  1988. {
  1989. break;
  1990. }
  1991. }
  1992. else//当天剩余产能不满足当前工单的剩余待排产时长
  1993. {
  1994. //计算生产数量
  1995. decimal qty = Math.Ceiling(restTime / item.LbrVar * item.QtyOrded);
  1996. //记录生产周期
  1997. curSequences.Add(new PeriodSequenceDet
  1998. {
  1999. Domain = domain,
  2000. Line = lineStart.Line,
  2001. ItemNum = item.ItemNum,
  2002. PlanDate = beginTime.Date,
  2003. Period = dto.Period,
  2004. OrdQty = qty,
  2005. WorkOrds = item.WorkOrd,
  2006. Op = item.Op,
  2007. IsActive = true,
  2008. Status = "",
  2009. CreateTime = DateTime.Now
  2010. });
  2011. //记录排产记录
  2012. curScheduleRsts.Add(new ScheduleResultOpMaster
  2013. {
  2014. Domain = domain,
  2015. WorkOrd = item.WorkOrd,
  2016. Line = lineStart.Line,
  2017. ItemNum = item.ItemNum,
  2018. Op = item.Op,
  2019. WorkDate = beginTime.Date,
  2020. WorkQty = qty,
  2021. WorkStartTime = beginTime,
  2022. WorkEndTime = endTime,
  2023. CreateTime = DateTime.Now
  2024. });
  2025. item.Worked += restTime;
  2026. item.QtyWorked += qty;
  2027. break;
  2028. }
  2029. }
  2030. //特殊工单剩余待排产时长(分钟)
  2031. sumTsTimes -= restTime;
  2032. //获取下一个工作日
  2033. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  2034. isFstDay = false;
  2035. }
  2036. }
  2037. #endregion 特殊工单排产-结束
  2038. }
  2039. }
  2040. }
  2041. //记录已排产特殊工单
  2042. ypcWorkOrds.AddRange(workDtos.Select(p=>p.WorkOrd).ToList());
  2043. }
  2044. //记录排产结果
  2045. periodsDet.AddRange(curSequences);
  2046. scheduleResults.AddRange(curScheduleRsts);
  2047. }
  2048. /// <summary>
  2049. /// 特殊工单排产:和正常工单不共用产线的特殊工单
  2050. /// </summary>
  2051. /// <param name="workOrds">特殊工单</param>
  2052. /// <param name="periodsDet">生产周期</param>
  2053. /// <param name="scheduleResults">排产结果</param>
  2054. public void TsLineSchedule(List<WorkOrdMstDto> workOrds, List<PeriodSequenceDet> periodsDet, List<ScheduleResultOpMaster> scheduleResults)
  2055. {
  2056. foreach (var item in workOrds)
  2057. {
  2058. //工单的生产时长(分钟)
  2059. decimal sumTimes = item.LbrVar;
  2060. //工单的排产开始时间
  2061. DateTime workStartTime = item.OrdDate;
  2062. //当前产线的工作日历
  2063. var mLCalendars = calendars.Where(p => p.ProdLine == item.ProdLine || string.IsNullOrEmpty(p.ProdLine)).ToList();
  2064. //当前产线的休息时间设置
  2065. var mlqtyWorkDtls = qualityLines.Where(p => p.ProdLine == item.ProdLine).ToList();
  2066. LineStartDto lineStart = new LineStartDto();
  2067. lineStart.Line = item.ProdLine;
  2068. lineStart.Op = item.Op;
  2069. lineStart.StartTime = workStartTime;
  2070. lineStart.Rate = 0;
  2071. while (sumTimes > 0)
  2072. {
  2073. //获取当天的工作时间段
  2074. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  2075. if (curCalendar == null)
  2076. {
  2077. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  2078. }
  2079. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, workStartTime, curCalendar, mlqtyWorkDtls);
  2080. //获取当天的产能
  2081. LineScheduledDto dto = GetScheduledPoint(lineStart, workStartTime, mLCalendars, mlqtyWorkDtls);
  2082. //当天的可用生产时长不能满足特殊工单生产时长
  2083. if (dto.EffTime <= sumTimes)
  2084. {
  2085. decimal qty = Math.Ceiling(dto.EffTime / item.LbrVar * item.QtyOrded);
  2086. //记录生产周期
  2087. periodsDet.Add(new PeriodSequenceDet
  2088. {
  2089. Domain = domain,
  2090. Line = item.ProdLine,
  2091. ItemNum = item.ItemNum,
  2092. PlanDate = workStartTime.Date,
  2093. Period = dto.Period,
  2094. OrdQty = qty,
  2095. WorkOrds = item.WorkOrd,
  2096. Op = item.Op,
  2097. IsActive = true,
  2098. Status = "",
  2099. CreateTime = DateTime.Now
  2100. });
  2101. //记录排产记录
  2102. scheduleResults.Add(new ScheduleResultOpMaster
  2103. {
  2104. Domain = domain,
  2105. WorkOrd = item.WorkOrd,
  2106. Line = item.ProdLine,
  2107. ItemNum = item.ItemNum,
  2108. Op = item.Op,
  2109. WorkDate = workStartTime.Date,
  2110. WorkQty = qty,
  2111. WorkStartTime = dto.StartTime,
  2112. WorkEndTime = dto.EndTime,
  2113. CreateTime = DateTime.Now
  2114. });
  2115. //剩余待排产时长
  2116. sumTimes -= dto.EffTime;
  2117. //已排产数量
  2118. item.QtyWorked += qty;
  2119. //继续排下一个工作日
  2120. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  2121. }
  2122. else// 最后一天的产能只能占用一部分
  2123. {
  2124. //剩余生产时长(分钟)
  2125. decimal workTime = sumTimes;
  2126. var curPoint = workPoints.Find(p => p.StartPoint <= workStartTime && workStartTime <= p.EndPoint);
  2127. TimeSpan span = curPoint.EndPoint - workStartTime;
  2128. //当前工作时间段的有效生产时间
  2129. decimal effMins = (decimal)span.TotalMinutes;
  2130. DateTime workEndTime = workStartTime;
  2131. if (effMins >= workTime)//当前工作时间段即可满足产能
  2132. {
  2133. workEndTime = workStartTime.AddMinutes((double)workTime);
  2134. }
  2135. else
  2136. {
  2137. //获取后续生产时间段
  2138. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  2139. //剩余需要工作时长
  2140. decimal nextMins = workTime - effMins;
  2141. foreach (var p in nextPoints)
  2142. {
  2143. if (p.WorkMinutes >= nextMins)
  2144. {
  2145. workEndTime = p.StartPoint.AddMinutes((double)nextMins);
  2146. break;
  2147. }
  2148. nextMins -= p.WorkMinutes;
  2149. }
  2150. }
  2151. //记录生产周期
  2152. periodsDet.Add(new PeriodSequenceDet
  2153. {
  2154. Domain = domain,
  2155. Line = item.ProdLine,
  2156. ItemNum = item.ItemNum,
  2157. PlanDate = workStartTime.Date,
  2158. Period = dto.Period,
  2159. OrdQty = item.QtyOrded - item.QtyWorked,
  2160. WorkOrds = item.WorkOrd,
  2161. Op = item.Op,
  2162. IsActive = true,
  2163. Status = "",
  2164. CreateTime = DateTime.Now
  2165. });
  2166. //记录排产记录
  2167. scheduleResults.Add(new ScheduleResultOpMaster
  2168. {
  2169. Domain = domain,
  2170. WorkOrd = item.WorkOrd,
  2171. Line = item.ProdLine,
  2172. ItemNum = item.ItemNum,
  2173. Op = item.Op,
  2174. WorkDate = workStartTime.Date,
  2175. WorkQty = item.QtyOrded - item.QtyWorked,
  2176. WorkStartTime = workStartTime,
  2177. WorkEndTime = workEndTime,
  2178. CreateTime = DateTime.Now
  2179. });
  2180. sumTimes = 0;
  2181. item.QtyWorked = item.QtyOrded;
  2182. }
  2183. }
  2184. }
  2185. }
  2186. /// <summary>
  2187. /// 获取产线当天的开工时间,结束时间,有效工作时长,生产数量
  2188. /// </summary>
  2189. /// <param name="lineStart">排产产线</param>
  2190. /// <param name="startTime">产线排产开始时间</param>
  2191. /// <param name="curCalendars"></param>
  2192. /// <param name="curQtyDtls"></param>
  2193. /// <returns></returns>
  2194. public LineScheduledDto GetScheduledPoint(LineStartDto lineStart, DateTime startTime, List<ShopCalendarWorkCtr> curCalendars, List<QualityLineWorkDetail> curQtyDtls)
  2195. {
  2196. LineScheduledDto scheduledDto = new LineScheduledDto();
  2197. //当天排产开始时间
  2198. scheduledDto.StartTime = startTime;
  2199. //开始时间是周几
  2200. int weekDay = (int)startTime.DayOfWeek;
  2201. //当天的工作日历
  2202. var shopCal = curCalendars.Where(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  2203. if (shopCal == null)//当前产线当天没有设置工作日历
  2204. {
  2205. //取默认工作日历
  2206. shopCal = curCalendars.Where(p =>string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  2207. }
  2208. //当前日期的工作时间段
  2209. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(lineStart.Line, startTime, shopCal, curQtyDtls);
  2210. //当天排产结束时间
  2211. scheduledDto.EndTime = workPoints.Last().EndPoint;
  2212. //计算starttime处于那个工作时间段
  2213. var curPoint = workPoints.Where(p => startTime >= p.StartPoint && startTime <= p.EndPoint).First();
  2214. TimeSpan span = curPoint.EndPoint - startTime;
  2215. scheduledDto.EffTime = (decimal)span.TotalMinutes;
  2216. //获取后续工作时间段的有效工作时间
  2217. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  2218. foreach (var item in nextPoints)
  2219. {
  2220. span = item.EndPoint - item.StartPoint;
  2221. scheduledDto.EffTime += (decimal)span.TotalMinutes;
  2222. }
  2223. //判断当前产线的UPH
  2224. var curRunCrews = prodLineDetailRunCrews.Where(p=>p.ProdLineDetailRecID == lineStart.RecID).ToList();
  2225. //判断当前日期是否配置了UPH
  2226. var curLevel = curRunCrews.FirstOrDefault(p => p.StartDate.GetValueOrDefault().Date <= startTime.Date && p.EndDate.GetValueOrDefault().Date >= startTime.Date);
  2227. decimal rate = curLevel == null ? lineStart.Rate : curLevel.Rate;
  2228. scheduledDto.Rate = rate;
  2229. //计算当天的产能(向下取整)
  2230. scheduledDto.ProductQty = Math.Floor(scheduledDto.EffTime / 60 * rate);
  2231. //计算班次
  2232. scheduledDto.Period = 1;//默认一班制
  2233. if (shopCal.ShiftsStart2 != 0 && shopCal.ShiftsHours2 != 0)
  2234. {
  2235. scheduledDto.Period = 2;
  2236. }
  2237. return scheduledDto;
  2238. }
  2239. /// <summary>
  2240. /// 计算主产线实际排产开始时间
  2241. /// </summary>
  2242. /// <param name="workOrd">工单</param>
  2243. /// <param name="op">工序</param>
  2244. /// <param name="prodLines">生产线明细</param>
  2245. /// <param name="allResults">产线占用记录</param>
  2246. /// <returns></returns>
  2247. public LineStartDto DealStartTime(WorkOrdMaster workOrd,int op,List<ProdLineDetail> prodLines, List<ScheduleResultOpMaster> allResults)
  2248. {
  2249. DateTime actStart = DateTime.Now.Date.AddDays(1);
  2250. LineStartDto lineStart = new LineStartDto();
  2251. //获取工序对应的产线,根据优先级排序
  2252. var lines = prodLines.Where(p => p.Part == workOrd.ItemNum && p.Op == op).OrderBy(p => p.Sequence).ToList();
  2253. //获取第一条产线排产结束时间
  2254. var schedule = allResults.Where(p => p.Line == lines[0].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  2255. actStart = schedule == null ? actStart : (schedule.WorkEndTime >= actStart ? schedule.WorkEndTime : actStart);
  2256. //计算实际开工时间
  2257. //产线工作日历:当前产线的工作日历+默认工作日历
  2258. var curCalendars = calendars.Where(p => p.ProdLine == lines[0].Line || string.IsNullOrEmpty(p.ProdLine)).ToList();
  2259. var curQtyDtls = qualityLines.Where(p=>p.ProdLine == lines[0].Line).ToList();
  2260. actStart = CalcActStartTime(lines[0].Line, actStart, curCalendars, curQtyDtls);
  2261. lineStart.RecID = lines[0].RecID;
  2262. lineStart.Line = lines[0].Line;
  2263. lineStart.StartTime = actStart;
  2264. lineStart.setupTime = lines[0].SetupTime;
  2265. lineStart.Rate = lines[0].Rate;
  2266. lineStart.Op = op;
  2267. //循环其他产线
  2268. for (int i = 1; i < lines.Count; i++)
  2269. {
  2270. schedule = allResults.Where(p => p.Line == lines[i].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  2271. DateTime StartTime = schedule == null ? actStart : (schedule.WorkEndTime >= actStart ? schedule.WorkEndTime : actStart);
  2272. //计算实际开工时间
  2273. //产线工作日历:当前产线的工作日历+默认工作日历
  2274. curCalendars = calendars.Where(p => p.ProdLine == lines[i].Line || string.IsNullOrEmpty(p.ProdLine)).ToList();
  2275. curQtyDtls = qualityLines.Where(p => p.ProdLine == lines[i].Line).ToList();
  2276. StartTime = CalcActStartTime(lines[0].Line, StartTime, curCalendars, curQtyDtls);
  2277. if (StartTime < lineStart.StartTime)
  2278. {
  2279. lineStart.RecID = lines[i].RecID;
  2280. lineStart.Line = lines[i].Line;
  2281. lineStart.StartTime = StartTime;
  2282. lineStart.setupTime = lines[i].SetupTime;
  2283. lineStart.Rate = lines[i].Rate;
  2284. lineStart.Op = op;
  2285. }
  2286. }
  2287. return lineStart;
  2288. }
  2289. /// <summary>
  2290. /// 计算主产线实际排产开始时间
  2291. /// </summary>
  2292. /// <param name="prodLine">生产线</param>
  2293. /// <param name="startTime">开始时间</param>
  2294. /// <param name="curCalendars">当前产线工作日历+默认工作日历</param>
  2295. /// <param name="curQtyDtls">当前产线休息记录</param>
  2296. /// <returns></returns>
  2297. public DateTime CalcActStartTime(string prodLine,DateTime startTime, List<ShopCalendarWorkCtr> curCalendars, List<QualityLineWorkDetail> curQtyDtls)
  2298. {
  2299. //实际排产开始时间
  2300. DateTime actStart = startTime;
  2301. //开始时间是周几
  2302. int weekDay = (int)startTime.DayOfWeek;
  2303. //判断当天是否是工作日
  2304. bool isWorkDay = CheckIsWorkDay(startTime);
  2305. if (!isWorkDay)//不是工作日
  2306. {
  2307. //获取下一个工作日开始时间
  2308. actStart = GetNextWorkDay(weekDay, startTime, curCalendars);
  2309. return actStart;
  2310. }
  2311. //当天的工作日历
  2312. var shopCal = curCalendars.Where(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  2313. if (shopCal == null)
  2314. {
  2315. //产线没有维护当天的工作日历,则取默认工作日历
  2316. shopCal = curCalendars.Where(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  2317. }
  2318. //当前日期的工作时间段
  2319. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(prodLine, startTime, shopCal, curQtyDtls);
  2320. //计算starttime处于那个工作时间段
  2321. var curPoint = workPoints.Where(p => startTime >= p.StartPoint && startTime <= p.EndPoint).FirstOrDefault();
  2322. if (curPoint == null)//不处于工作时间段
  2323. {
  2324. //开始时间小于当天工作开始时间
  2325. if (startTime < workPoints.First().StartPoint)
  2326. {
  2327. actStart = workPoints.First().StartPoint;
  2328. }
  2329. //开始时间大于当前工作结束时间
  2330. else if (startTime > workPoints.Last().EndPoint)
  2331. {
  2332. //获取下一个工作日开始时间
  2333. actStart = GetNextWorkDay(weekDay, startTime, curCalendars);
  2334. }
  2335. else
  2336. {//开始时间位于当天的休息时间段
  2337. foreach (var item in workPoints)
  2338. {
  2339. //获取下一个时间段
  2340. var next = workPoints.First(p => p.Level == item.Level + 1);
  2341. if (item.EndPoint < startTime && startTime < next.StartPoint)
  2342. {
  2343. actStart = next.StartPoint;
  2344. break;
  2345. }
  2346. }
  2347. }
  2348. return actStart;
  2349. }
  2350. if (startTime != curPoint.EndPoint)
  2351. {
  2352. return actStart;
  2353. }
  2354. //查询下一时间段的开始时间点
  2355. var nextPoint = workPoints.Where(p => p.Level == curPoint.Level + 1).FirstOrDefault();
  2356. if (nextPoint != null)
  2357. {
  2358. return nextPoint.StartPoint;
  2359. }
  2360. //开始时间为今天下班时间,实际排产开始时间为下一个工作日的开始时间
  2361. actStart = GetNextWorkDay(weekDay, startTime, curCalendars);
  2362. return actStart;
  2363. }
  2364. /// <summary>
  2365. /// 排产开始时间处理为半小时/整点开始--向后取整
  2366. /// </summary>
  2367. /// <param name="startTime"></param>
  2368. /// <returns></returns>
  2369. public DateTime CalcStartTimeAfter(DateTime startTime)
  2370. {
  2371. DateTime rtnTime = startTime;
  2372. DateTime curDate = startTime.Date;
  2373. //时间转换为分钟
  2374. TimeSpan span = rtnTime - curDate;
  2375. decimal sumMinutes = (decimal)span.TotalMinutes;
  2376. int times = (int)Math.Ceiling(sumMinutes / 30);
  2377. rtnTime = curDate.AddMinutes(times * 30);
  2378. return rtnTime;
  2379. }
  2380. /// <summary>
  2381. /// 排产开始时间处理为半小时/整点开始--向前取整
  2382. /// </summary>
  2383. /// <param name="startTime"></param>
  2384. /// <returns></returns>
  2385. public DateTime CalcStartTimeBefore(DateTime startTime)
  2386. {
  2387. DateTime rtnTime = startTime;
  2388. DateTime curDate = startTime.Date;
  2389. //时间转换为分钟
  2390. TimeSpan span = rtnTime - curDate;
  2391. decimal sumMinutes = (decimal)span.TotalMinutes;
  2392. int times = (int)Math.Floor(sumMinutes / 30);
  2393. rtnTime = curDate.AddMinutes(times * 30);
  2394. return rtnTime;
  2395. }
  2396. /// <summary>
  2397. /// 判断当天是否是工作日
  2398. /// </summary>
  2399. /// <param name="dateTime"></param>
  2400. /// <returns></returns>
  2401. public bool CheckIsWorkDay(DateTime dateTime)
  2402. {
  2403. bool isWorkDay = true;
  2404. //周几
  2405. int weekDay = (int)dateTime.DayOfWeek;
  2406. //判断当天是否是工作日
  2407. if (weekDay == 0 || weekDay == 6)//周六或者周日,需要判断是否调班,需要加班
  2408. {
  2409. if (!holidays.Exists(p => p.Dated.GetValueOrDefault().Date == dateTime.Date && p.Ufld1 == "调班"))//不是调班
  2410. {
  2411. isWorkDay = false;
  2412. }
  2413. return isWorkDay;
  2414. }
  2415. //不是周六周日,需要判断是不是节假日
  2416. if (holidays.Exists(p => p.Dated.GetValueOrDefault().Date == dateTime.Date && p.Ufld1 == "休假"))//是节假日
  2417. {
  2418. isWorkDay = false;
  2419. }
  2420. return isWorkDay;
  2421. }
  2422. /// <summary>
  2423. /// 计算下一产线实际排产开始时间
  2424. /// </summary>
  2425. /// <param name="workOrd">工单</param>
  2426. /// <param name="lineStart">上一产线开始时间</param>
  2427. /// <param name="op">工序</param>
  2428. /// <param name="prodLines">产线明细</param>
  2429. /// <param name="allResults">产线占用记录</param>
  2430. /// <returns></returns>
  2431. public LineStartDto DealNextStartTime(WorkOrdMaster workOrd,LineStartDto lineStart,int op, List<ProdLineDetail> prodLines, List<ScheduleResultOpMaster> allResults)
  2432. {
  2433. LineStartDto startDto = new LineStartDto();
  2434. //获取产线
  2435. var lines = prodLines.Where(p => p.Part == workOrd.ItemNum && p.Op == op).OrderBy(p=>p.Sequence).ToList();
  2436. //获取第一条产线排产结束时间
  2437. var schedule = allResults.Where(p => p.Line == lines[0].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  2438. DateTime startTime = CalcStartTimeWithSetUpTime(lines[0], lineStart.StartTime, lineStart.setupTime + lines[0].OverlapTime);
  2439. startDto.RecID = lines[0].RecID;
  2440. startDto.Line = lines[0].Line;
  2441. startDto.setupTime = lines[0].SetupTime;
  2442. startDto.StartTime = schedule == null ? startTime : (startTime < schedule.WorkEndTime ? schedule.WorkEndTime : startTime);
  2443. startDto.Rate = lines[0].Rate;
  2444. startDto.Op = op;
  2445. //循环剩余产线,找到最早可开工产线
  2446. for (int i = 1; i < lines.Count(); i++)
  2447. {
  2448. schedule = allResults.Where(p => p.Line == lines[i].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  2449. startTime = CalcStartTimeWithSetUpTime(lines[i], lineStart.StartTime, lineStart.setupTime + lines[i].OverlapTime);
  2450. startTime = schedule == null ? startTime : (startTime < schedule.WorkEndTime ? schedule.WorkEndTime : startTime);
  2451. if (startTime < startDto.StartTime)
  2452. {
  2453. startDto.RecID = lines[i].RecID;
  2454. startDto.Line = lines[i].Line;
  2455. startDto.setupTime = lines[i].SetupTime;
  2456. startDto.StartTime = startTime;
  2457. startDto.Rate = lines[0].Rate;
  2458. startDto.Op = op;
  2459. }
  2460. }
  2461. return startDto;
  2462. }
  2463. /// <summary>
  2464. /// 通过提前期计算产线排产开始时间
  2465. /// </summary>
  2466. /// <param name="line">产线</param>
  2467. /// <param name="startTime">上一产线开始时间</param>
  2468. /// <param name="setupTime">上一产线准备时间+当前产线提前期</param>
  2469. /// <returns></returns>
  2470. public DateTime CalcStartTimeWithSetUpTime(ProdLineDetail line, DateTime startTime, decimal setupTime)
  2471. {
  2472. //提前期转换成分钟
  2473. decimal needMinute = setupTime * 60;
  2474. //实际排产开始时间
  2475. DateTime actStart = startTime;
  2476. //开始时间是周几
  2477. int weekDay = (int)startTime.DayOfWeek;
  2478. //当天的工作日历
  2479. var shopCal = calendars.Where(p => p.ProdLine == line.Line && p.WeekDay == weekDay).FirstOrDefault();
  2480. if (shopCal == null)
  2481. {
  2482. //产线没有维护当天的工作日历,则取默认工作日历
  2483. shopCal = calendars.Where(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  2484. }
  2485. //当前产线的休息时间设置
  2486. var curQtyDtls = qualityLines.Where(p => p.ProdLine == line.Line).ToList();
  2487. //当前日期的工作时间段
  2488. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(line.Line, startTime, shopCal, curQtyDtls);
  2489. //计算starttime处于那个工作时间段
  2490. var curPoint = workPoints.Where(p => startTime >= p.StartPoint && startTime <= p.EndPoint).FirstOrDefault();
  2491. //当前时间段可用时长
  2492. TimeSpan span = curPoint.EndPoint - startTime;
  2493. decimal curMins = (decimal)span.TotalMinutes;
  2494. if (curMins >= needMinute)//当前时间段的可用时长满足提前期
  2495. {
  2496. actStart = startTime.AddMinutes((double)needMinute);
  2497. return actStart;
  2498. }
  2499. //当前时间段的可用时长不满足
  2500. //剩余提前期
  2501. needMinute -= curMins;
  2502. //获取后层级时间段
  2503. var prePoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  2504. bool flag = true;//标志位
  2505. foreach (var item in prePoints)
  2506. {
  2507. if (item.WorkMinutes >= needMinute)//当前时间段的可用时长满足
  2508. {
  2509. actStart = item.StartPoint.AddMinutes((double)needMinute);
  2510. flag = false;
  2511. break;
  2512. }
  2513. needMinute -= item.WorkMinutes;
  2514. }
  2515. if (!flag)
  2516. {
  2517. return actStart;
  2518. }
  2519. //今天可用时长不够,往后工作日找
  2520. DateTime nextStartTime = startTime;
  2521. while (flag)
  2522. {
  2523. //获取下一个工作日
  2524. nextStartTime = GetNextWorkDay(weekDay, startTime, calendars.Where(p => p.ProdLine == line.Line || string.IsNullOrEmpty(p.ProdLine)).ToList());
  2525. weekDay = (int)nextStartTime.DayOfWeek;
  2526. //获取前一个工作日的工作时间段数据,level顺排
  2527. var curCalendar = calendars.Where(p => p.ProdLine == line.Line && p.WeekDay == weekDay).FirstOrDefault();
  2528. if (curCalendar == null )
  2529. {
  2530. curCalendar = calendars.Where(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  2531. }
  2532. workPoints = DealWorkDayToLevels(line.Line, nextStartTime, curCalendar, curQtyDtls).OrderBy(p => p.Level).ToList();
  2533. //当天的工作时长(分钟)
  2534. decimal sumWorkMins = workPoints.Sum(p => p.WorkMinutes);
  2535. if (sumWorkMins >= needMinute)//当天可用提前期满足
  2536. {
  2537. //获取开始时间
  2538. foreach (var item in workPoints)
  2539. {
  2540. if (item.WorkMinutes >= needMinute)//当前时间段满足
  2541. {
  2542. actStart = item.StartPoint.AddMinutes((double)needMinute);
  2543. break;
  2544. }
  2545. needMinute -= item.WorkMinutes;
  2546. }
  2547. flag = false;
  2548. }
  2549. else
  2550. {
  2551. //当天可用提前期不满足
  2552. needMinute -= sumWorkMins;
  2553. }
  2554. }
  2555. return actStart;
  2556. }
  2557. /// <summary>
  2558. /// 获取下一个工作日开始时间
  2559. /// </summary>
  2560. /// <param name="weekDay">当前周几</param>
  2561. /// <param name="startTime">开始时间</param>
  2562. /// <param name="curCalendars">当前产线的工作日历+默认工作日历</param>
  2563. /// <returns></returns>
  2564. public DateTime GetNextWorkDay(int weekDay, DateTime startTime, List<ShopCalendarWorkCtr> curCalendars)
  2565. {
  2566. DateTime rtnData = startTime;
  2567. //下一天
  2568. DateTime nextDate = startTime.Date.AddDays(1);
  2569. //下一天是周几
  2570. int nextWeekDay = (weekDay + 1) % 7;
  2571. //获取工作日历:先获取当前产线的工作日历,若没有维护,则获取默认工作日历
  2572. var calendar = curCalendars.FirstOrDefault(p =>!string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == nextWeekDay);
  2573. if (calendar == null)
  2574. {
  2575. calendar = curCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == nextWeekDay);
  2576. }
  2577. string strStart = calendar.ShiftsStart1.ToString("0.00").Replace(".", ":");
  2578. //判断下一天是否是工作日
  2579. if (nextWeekDay == 0 || nextWeekDay == 6)//下一天是周六或者周日,需要判断是否调班,需要加班
  2580. {
  2581. if (!holidays.Exists(p => p.Dated.GetValueOrDefault().Date == nextDate && p.Ufld1 == "调班"))//下一天是周末
  2582. {
  2583. //递归继续找下一个工作日
  2584. rtnData = GetNextWorkDay(nextWeekDay, nextDate, curCalendars);
  2585. return rtnData;
  2586. }
  2587. rtnData = Convert.ToDateTime(nextDate.ToString("yyyy-MM-dd") + " " + strStart);
  2588. return rtnData;
  2589. }
  2590. //下一天不是周六周日,需要判断是不是节假日
  2591. if (holidays.Exists(p => p.Dated.GetValueOrDefault().Date == nextDate && p.Ufld1 == "休假"))//是节假日
  2592. {
  2593. //递归继续找下一个工作日
  2594. rtnData = GetNextWorkDay(nextWeekDay, nextDate, curCalendars);
  2595. return rtnData;
  2596. }
  2597. rtnData = Convert.ToDateTime(nextDate.ToString("yyyy-MM-dd") + " " + strStart);
  2598. return rtnData;
  2599. }
  2600. /// <summary>
  2601. /// 处理当前日期的工作时间段
  2602. /// </summary>
  2603. /// <param name="prodLine"></param>
  2604. /// <param name="startTime"></param>
  2605. /// <param name="shopCal">当前产线的工作日历-周几</param>
  2606. /// <param name="curQtyDtls">每天休息记录</param>
  2607. /// <returns></returns>
  2608. public List<LineWorkPointDto> DealWorkDayToLevels(string prodLine, DateTime startTime, ShopCalendarWorkCtr shopCal, List<QualityLineWorkDetail> curQtyDtls)
  2609. {
  2610. //年-月-日
  2611. string date = startTime.Date.ToString("yyyy-MM-dd");
  2612. //排产记录结束日期是周几
  2613. int weekDay = (int)startTime.DayOfWeek;
  2614. //工作时间段
  2615. List<LineWorkPointDto> workPoints = new List<LineWorkPointDto>();
  2616. LineWorkPointDto dto = new LineWorkPointDto();
  2617. int level = 1;
  2618. TimeSpan span = TimeSpan.Zero;
  2619. //开始时间
  2620. string strStart = shopCal.ShiftsStart1.ToString("0.00").Replace(".", ":");
  2621. DateTime dayStartPoint = Convert.ToDateTime(date + " " + strStart);
  2622. //结束时间
  2623. DateTime dayEndPoint = dayStartPoint.AddHours((double)(shopCal.ShiftsHours1 + shopCal.ShiftsHours2));
  2624. dto.Level = level;
  2625. dto.Line = prodLine;
  2626. dto.WeekDay = weekDay;
  2627. dto.StartPoint = dayStartPoint;
  2628. //按照产线休息时间切分时间段
  2629. curQtyDtls = curQtyDtls.OrderBy(p => p.RestTimePoint).ToList();
  2630. foreach (var item in curQtyDtls)
  2631. {
  2632. DateTime endPoint = Convert.ToDateTime(date + " " + item.RestTimePoint);
  2633. dto.EndPoint = endPoint;
  2634. span = dto.EndPoint - dto.StartPoint;
  2635. dto.WorkMinutes = (decimal)span.TotalMinutes;
  2636. workPoints.Add(dto);
  2637. level++;
  2638. dto = new LineWorkPointDto();
  2639. dto.Level = level;
  2640. dto.Line = prodLine;
  2641. dto.WeekDay = weekDay;
  2642. dto.StartPoint = endPoint.AddMinutes(item.RestTime);
  2643. }
  2644. dto.EndPoint = dayEndPoint;
  2645. span = dto.EndPoint - dto.StartPoint;
  2646. dto.WorkMinutes = (decimal)span.TotalMinutes;
  2647. workPoints.Add(dto);
  2648. //产线当天加班设置
  2649. var curOccupyTimes = resourceOccupancyTimes.Where(p => p.Resource == prodLine && p.StartTime.GetValueOrDefault().Date == startTime.Date).OrderBy(p=>p.StartTime).ToList();
  2650. foreach (var item in curOccupyTimes)
  2651. {
  2652. level++;
  2653. dto = new LineWorkPointDto();
  2654. dto.Level = level;
  2655. dto.Line = prodLine;
  2656. dto.WeekDay = weekDay;
  2657. dto.StartPoint = item.StartTime.GetValueOrDefault();
  2658. dto.EndPoint = dto.StartPoint.AddHours(Convert.ToDouble(item.Ufld1));
  2659. dto.WorkMinutes = Convert.ToDecimal(item.Ufld1) * 60;
  2660. workPoints.Add(dto);
  2661. }
  2662. return workPoints.OrderBy(p => p.Level).ToList();
  2663. }
  2664. }
  2665. }