ProductionScheduleAppService.cs 57 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147
  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. namespace Business.ResourceExamineManagement
  20. {
  21. /// <summary>
  22. /// 生产排产服务
  23. /// </summary>
  24. public class ProductionScheduleAppService : ApplicationService
  25. {
  26. #region 服务
  27. /// <summary>
  28. /// 物料
  29. /// </summary>
  30. private ISqlRepository<ItemMaster> _itemMaster;
  31. /// <summary>
  32. /// 工单
  33. /// </summary>
  34. private ISqlRepository<WorkOrdMaster> _workOrdMaster;
  35. /// <summary>
  36. /// 工单物料明细
  37. /// </summary>
  38. private ISqlRepository<WorkOrdDetail> _workOrdDetail;
  39. /// <summary>
  40. /// 工单工艺路线明细
  41. /// </summary>
  42. private ISqlRepository<WorkOrdRouting> _workOrdRouting;
  43. /// <summary>
  44. /// 库存主数据
  45. /// </summary>
  46. private ISqlRepository<InvMaster> _invMaster;
  47. /// <summary>
  48. /// 生产线明细
  49. /// </summary>
  50. private ISqlRepository<ProdLineDetail> _prodLineDetail;
  51. /// <summary>
  52. /// 生产周期明细
  53. /// </summary>
  54. private ISqlRepository<PeriodSequenceDet> _periodSequenceDet;
  55. /// <summary>
  56. /// 排产结果明细
  57. /// </summary>
  58. private ISqlRepository<ScheduleResultOpMaster> _scheduleResultOpMaster;
  59. /// <summary>
  60. /// 工作日历数据
  61. /// </summary>
  62. private ISqlRepository<ShopCalendarWorkCtr> _shopCalendarWorkCtr;
  63. /// <summary>
  64. /// 产线休息时间记录表
  65. /// </summary>
  66. private ISqlRepository<QualityLineWorkDetail> _qualityLineWorkDetail;
  67. /// <summary>
  68. /// 产线人员配置表
  69. /// </summary>
  70. private ISqlRepository<ProdLineDetailRunCrew> _prodLineDetailRunCrew;
  71. /// <summary>
  72. /// 加班设置表
  73. /// </summary>
  74. private ISqlRepository<ResourceOccupancyTime> _resourceOccupancyTime;
  75. /// <summary>
  76. /// 加班设置表
  77. /// </summary>
  78. private ISqlRepository<GeneralizedCodeMaster> _generalizedCodeMaster;
  79. /// <summary>
  80. /// 节假日记录表
  81. /// </summary>
  82. private ISqlRepository<HolidayMaster> _holidayMaster;
  83. /// <summary>
  84. /// 雪花算法
  85. /// </summary>
  86. SnowFlake help = new SnowFlake();
  87. private readonly ICurrentTenant _currentTenant;
  88. /// <summary>
  89. /// 工作日历数据
  90. /// </summary>
  91. private List<ShopCalendarWorkCtr> calendars;
  92. /// <summary>
  93. /// 产线休息记录数据
  94. /// </summary>
  95. private List<QualityLineWorkDetail> qualityLines;
  96. /// <summary>
  97. /// 节假日记录数据
  98. /// </summary>
  99. private List<HolidayMaster> holidays;
  100. /// <summary>
  101. /// 工厂id
  102. /// </summary>
  103. private string domain = "";
  104. #endregion
  105. #region 构造函数
  106. /// <summary>
  107. /// 构造函数
  108. /// </summary>
  109. public ProductionScheduleAppService(
  110. ISqlRepository<ItemMaster> itemMaster,
  111. ISqlRepository<WorkOrdMaster> workOrdMaster,
  112. ISqlRepository<WorkOrdDetail> workOrdDetail,
  113. ISqlRepository<WorkOrdRouting> workOrdRouting,
  114. ISqlRepository<ProdLineDetail> prodLineDetail,
  115. ISqlRepository<ProdLineDetailRunCrew> prodLineDetailRunCrew,
  116. ISqlRepository<ResourceOccupancyTime> resourceOccupancyTime,
  117. ISqlRepository<PeriodSequenceDet> periodSequenceDet,
  118. ISqlRepository<ScheduleResultOpMaster> scheduleResultOpMaster,
  119. ISqlRepository<InvMaster> invMaster,
  120. ISqlRepository<ShopCalendarWorkCtr> shopCalendarWorkCtr,
  121. ISqlRepository<QualityLineWorkDetail> qualityLineWorkDetail,
  122. ISqlRepository<HolidayMaster> holidayMaster,
  123. ISqlRepository<GeneralizedCodeMaster> generalizedCodeMaster,
  124. ICurrentTenant currentTenant
  125. )
  126. {
  127. _itemMaster = itemMaster;
  128. _workOrdMaster = workOrdMaster;
  129. _workOrdDetail = workOrdDetail;
  130. _workOrdRouting = workOrdRouting;
  131. _prodLineDetail = prodLineDetail;
  132. _prodLineDetailRunCrew = prodLineDetailRunCrew;
  133. _resourceOccupancyTime = resourceOccupancyTime;
  134. _periodSequenceDet = periodSequenceDet;
  135. _scheduleResultOpMaster = scheduleResultOpMaster;
  136. _invMaster = invMaster;
  137. _shopCalendarWorkCtr = shopCalendarWorkCtr;
  138. _qualityLineWorkDetail = qualityLineWorkDetail;
  139. _holidayMaster = holidayMaster;
  140. _generalizedCodeMaster = generalizedCodeMaster;
  141. _currentTenant = currentTenant;
  142. }
  143. #endregion
  144. /// <summary>
  145. /// 执行生产排产
  146. /// </summary>
  147. public async void DoExt()
  148. {
  149. //定时任务排产:获取工厂id
  150. IConfiguration configuration = new ConfigurationBuilder().AddJsonFile("appsettings.json", optional: true, reloadOnChange: true).Build();
  151. domain = configuration.GetConnectionString("Factory_id");
  152. //获取提前期
  153. var generalizedCodeMaster = _generalizedCodeMaster.Select(x => x.FldName == "SystemConfig" && x.Val == "WorkOrderLockPeriod" && x.Domain == domain).FirstOrDefault();
  154. decimal Udecil = 0;
  155. if (generalizedCodeMaster != null)
  156. {
  157. Udecil = generalizedCodeMaster.UDeci1;
  158. }
  159. //排产取4周工单排产
  160. DateTime dateTime = DateTime.Now.AddDays(30);
  161. DateTime date = DateTime.Now.AddDays((double)Udecil);
  162. var workOrds = _workOrdMaster.Select(x => x.IsActive && x.Domain == domain && x.OrdDate < dateTime && x.OrdDate > date && x.Status == "初始").ToList();
  163. await DoProductShcedule(workOrds, domain);
  164. }
  165. /// <summary>
  166. /// 生产排产
  167. /// </summary>
  168. /// <param name="workOrds">工单:定时任务执行时count=0;资源检查调用count>0</param>
  169. /// <param name="factoryid">工单的工厂id</param>
  170. /// <returns></returns>
  171. public async Task DoProductShcedule(List<WorkOrdMaster> workOrds, string factoryid)
  172. {
  173. //记录工厂id
  174. domain = factoryid;
  175. if (workOrds.Count == 0)//没有工单需要排产
  176. {
  177. return;
  178. }
  179. //获取排产工单的最早计划开工日期
  180. DateTime earlist = DateTime.Now.Date.AddDays(1);
  181. //2、获取数据
  182. //获取工单工艺路径数据
  183. 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);
  184. //获取物料对应的生产线信息:物料、工序对应的生产线
  185. List<ProdLineDetail> prodLines = _prodLineDetail.Select(p => workOrds.Select(m => m.ItemNum).Contains(p.Part) && p.Domain == domain && p.IsActive);
  186. List<string> lines = prodLines.Select(p => p.Line).ToList();
  187. //获取非标准产线人员配置
  188. List<ProdLineDetailRunCrew> prodLineDetailRunCrews = _prodLineDetailRunCrew.Select(x => prodLines.Select(p => p.RecID).Contains(x.ProdLineDetailRecID) && x.IsActive && x.Domain == domain).ToList();
  189. //获取加班设置
  190. List<ResourceOccupancyTime> resourceOccupancyTimes = _resourceOccupancyTime.Select(x => prodLines.Select(p => p.Line).Contains(x.Resource) && x.IsActive && x.Domain == domain).ToList();
  191. //获取生产周期数据
  192. List<PeriodSequenceDet> dbPeriodSequences = _periodSequenceDet.Select(p => lines.Contains(p.Line) && p.PlanDate >= earlist && p.Domain == domain && p.IsActive);
  193. //获取当前日期往后的排产记录数据
  194. List<ScheduleResultOpMaster> dbSchedules = _scheduleResultOpMaster.Select(p => lines.Contains(p.Line) && p.WorkDate >= earlist && p.Domain == domain);
  195. //获取工作日历数据:产线的工作日历+默认的工作日历
  196. calendars = _shopCalendarWorkCtr.Select(p => (lines.Contains(p.ProdLine) || string.IsNullOrEmpty(p.ProdLine)) && p.Domain == domain && p.IsActive);
  197. //获取产线休息记录数据
  198. qualityLines = _qualityLineWorkDetail.Select(p => lines.Contains(p.ProdLine) && p.Domain == domain && p.IsActive);
  199. //获取节假日记录数据
  200. holidays = _holidayMaster.Select(p => p.Domain == domain && p.IsActive && p.Dated >= earlist);
  201. //3、排产
  202. //生产周期
  203. List<PeriodSequenceDet> periodSequenceDtls = new List<PeriodSequenceDet>();
  204. //排产记录表
  205. List<ScheduleResultOpMaster> scheduleMasters = new List<ScheduleResultOpMaster>();
  206. //排产结果
  207. List<ScheduleResultOpMaster> allResults = new List<ScheduleResultOpMaster>();
  208. allResults.AddRange(dbSchedules);
  209. foreach (var item in workOrds)
  210. {
  211. //记录产线占用情况
  212. allResults.AddRange(scheduleMasters);
  213. //当前工单工艺路线主产线的关键工序
  214. var curRoutings = workOrdRoutings.Where(p => p.ItemNum == item.ItemNum && p.ParentOp == 0 && p.MilestoneOp).OrderBy(p=>p.OP).ToList();
  215. //当前工单的产线明细
  216. var curProdLines = prodLines.Where(p => p.Part == item.ItemNum).ToList();
  217. #region 校验
  218. //工单工艺多产线关键工序、物料对应的生产线信息:物料,工序对应的生产线、工作日历数据
  219. var workOrdRouting = workOrdRoutings.Where(x => x.WorkOrd == item.WorkOrd && x.ParentOp == 0).ToList();
  220. if (workOrdRouting.Count == 0)
  221. {
  222. //记录排产异常原因
  223. new NLogHelper("ProductionScheduleAppService").WriteLog("DoProductShcedule", "工单<" + item.WorkOrd + ">的工单工艺流程数据维护为空", _currentTenant.Id.ToString());
  224. continue;
  225. }
  226. //TODO:多个关键工序校验
  227. //物料对应生产线校验
  228. var ProdLineDetails = prodLines.Where(x => x.Part == item.ItemNum).ToList();
  229. if (ProdLineDetails.Count == 0)
  230. {
  231. //记录排产异常原因
  232. new NLogHelper("ProductionScheduleAppService").WriteLog("DoProductShcedule", "工单<" + item.WorkOrd + ">的生产线物料数据维护为空", _currentTenant.Id.ToString());
  233. continue;
  234. }
  235. var calendarsList = calendars.Where(x => ProdLineDetails.Select(p => p.Line).Contains(x.ProdLine) || string.IsNullOrEmpty(x.ProdLine)).ToList();
  236. //校验每个层级是否维护了工作日历
  237. bool flag = false;
  238. foreach (var rut in ProdLineDetails)
  239. {
  240. var lineCals = calendarsList.Where(p => p.ProdLine == rut.Line).ToList();
  241. //当前产线未配置工作日历取标准无产线工作日历使用
  242. if (lineCals.Count == 0)
  243. {
  244. lineCals = calendars.Where(p => string.IsNullOrEmpty(p.ProdLine)).ToList();
  245. if (lineCals.Count == 0)
  246. {
  247. break;
  248. }
  249. }
  250. if (lineCals.Select(p => p.WeekDay).Distinct().Count() != 7)
  251. {
  252. flag = true;
  253. break;
  254. }
  255. }
  256. if (flag)
  257. {
  258. //记录排产异常原因
  259. new NLogHelper("ProductionScheduleAppService").WriteLog("DoProductShcedule", "工单<" + item.WorkOrd + ">的<" + item.ProdLine + ">工作日历数据维护错误", _currentTenant.Id.ToString());
  260. continue;
  261. }
  262. #endregion
  263. //产线排产
  264. LineSchedule(item, curRoutings, curProdLines, periodSequenceDtls, scheduleMasters,allResults);
  265. List<ScheduleResultOpMaster> scheduleList = scheduleMasters.Where(s => s.WorkOrd == item.WorkOrd).ToList();
  266. if (scheduleList.Any())
  267. {
  268. item.OrdDate = scheduleList.Min(s => s.WorkStartTime.Date);
  269. item.DueDate = scheduleList.Max(s => s.WorkEndTime.Date);
  270. }
  271. }
  272. using (TransactionScope scope = new TransactionScope())
  273. {
  274. try
  275. {
  276. //记录排产数据
  277. _workOrdMaster.Update(workOrds);
  278. _periodSequenceDet.Insert(periodSequenceDtls);
  279. _scheduleResultOpMaster.Insert(scheduleMasters);
  280. scope.Complete();
  281. }
  282. catch (Exception ex)
  283. {
  284. new NLogHelper("ProductionScheduleAppService").WriteLog("DoProductShcedule", "记录排产数据失败:" + ex.Message, _currentTenant.Id.ToString());
  285. scope.Dispose();
  286. }
  287. }
  288. }
  289. /// <summary>
  290. /// 排产
  291. /// </summary>
  292. /// <param name="workOrd">工单</param>
  293. /// <param name="workOrdRoutings">当前工单的工艺路线的关键工序(有几个关键工序就有几条产线)</param>
  294. /// <param name="prodLines">当前工单的产线明细</param>
  295. /// <param name="periodsDet">生产周期</param>
  296. /// <param name="scheduleResults">排产结果</param>
  297. /// <param name="allResults">产线占用记录</param>
  298. public void LineSchedule(WorkOrdMaster workOrd, List<WorkOrdRouting> workOrdRoutings, List<ProdLineDetail> prodLines,List<PeriodSequenceDet> periodsDet, List<ScheduleResultOpMaster> scheduleResults, List<ScheduleResultOpMaster> allResults)
  299. {
  300. //生产周期
  301. List<PeriodSequenceDet> curSequences = new List<PeriodSequenceDet>();
  302. //排产明细
  303. List<ScheduleResultOpMaster> curScheduleRsts = new List<ScheduleResultOpMaster>();
  304. //记录上一产线排产开始时间
  305. LineStartDto lineStart = new LineStartDto();
  306. //第一层级工序有几个关键工序,就有几条产线
  307. for (int i = 0; i < workOrdRoutings.Count; i++)
  308. {
  309. //产线实际排产开始时间
  310. if (i == 0)//第一条产线
  311. {
  312. lineStart = DealStartTime(workOrd, workOrdRoutings[i].OP, prodLines, allResults);
  313. }
  314. else
  315. {
  316. //获取前一产线排产开始时间,通过提前期计算当前产线排产开始时间
  317. lineStart = DealNextStartTime(workOrd,lineStart, workOrdRoutings[i].OP, prodLines, allResults);
  318. }
  319. //当前产线的工作日历
  320. var mLCalendars = calendars.Where(p => p.ProdLine == lineStart.Line || string.IsNullOrEmpty(p.ProdLine)).ToList();
  321. //当前产线的休息时间设置
  322. var mlqtyWorkDtls = qualityLines.Where(p => p.ProdLine == lineStart.Line).ToList();
  323. //产线已排产数量
  324. decimal sumQty = 0m;
  325. //产线准备时间
  326. decimal sumTimes = 0m;
  327. //产线排产开始时间
  328. DateTime workStartTime = lineStart.StartTime;
  329. //排产
  330. while (sumQty < workOrd.QtyOrded)
  331. {
  332. //获取当天的产能
  333. LineScheduledDto dto = GetScheduledPoint(lineStart.Rate, workStartTime, mLCalendars, mlqtyWorkDtls);
  334. //排产开始时,需要先减去产线准备时间
  335. if (sumTimes < lineStart.setupTime)
  336. {
  337. //判断当天的可用生产时长能满足提前期
  338. if (dto.EffTime >= lineStart.setupTime)
  339. {
  340. sumTimes = lineStart.setupTime;
  341. //当天剩余产能
  342. decimal sumAmount = dto.ProductQty - Math.Floor(lineStart.Rate * lineStart.setupTime);
  343. //判断已排产数量+当天的产能是否超过工单数量
  344. if (sumQty + sumAmount <= workOrd.QtyOrded)//当天的产能需要全部排产
  345. {
  346. //记录生产周期
  347. curSequences.Add(new PeriodSequenceDet
  348. {
  349. Domain = domain,
  350. Line = lineStart.Line,
  351. ItemNum = workOrd.ItemNum,
  352. PlanDate = workStartTime.Date,
  353. Period = dto.Period,
  354. OrdQty = sumAmount,
  355. WorkOrds = workOrd.WorkOrd,
  356. Op = lineStart.Op,
  357. IsActive = true,
  358. Status = "",
  359. CreateTime = DateTime.Now
  360. });
  361. //记录排产记录
  362. curScheduleRsts.Add(new ScheduleResultOpMaster
  363. {
  364. Domain = domain,
  365. WorkOrd = workOrd.WorkOrd,
  366. Line = lineStart.Line,
  367. ItemNum = workOrd.ItemNum,
  368. Op = lineStart.Op,
  369. WorkDate = workStartTime.Date,
  370. WorkQty = sumAmount,
  371. WorkStartTime = dto.StartTime,
  372. WorkEndTime = dto.EndTime,
  373. CreateTime = DateTime.Now
  374. });
  375. //累计已排产数量
  376. sumQty += sumAmount;
  377. //继续排下一个工作日
  378. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  379. }
  380. else// 最后一天的产能只能占用一部分
  381. {
  382. //剩余需要排产的数量
  383. decimal residueQty = workOrd.QtyOrded - sumQty;
  384. //剩余数量生产需要时长(分钟)
  385. decimal workTime = Math.Ceiling(residueQty / lineStart.Rate * 60);
  386. //获取当天的工作时间段
  387. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  388. if (curCalendar == null)
  389. {
  390. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  391. }
  392. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(workStartTime, curCalendar, mlqtyWorkDtls);
  393. var curPoint = workPoints.Find(p => p.StartPoint <= workStartTime && workStartTime <= p.EndPoint);
  394. if (curPoint != null)
  395. {
  396. TimeSpan span = curPoint.EndPoint - workStartTime;
  397. //当天工作时间段的有效生产时间
  398. decimal effMins = (decimal)span.TotalMinutes;
  399. DateTime workEndTime = workStartTime;
  400. if (effMins >= workTime)//当前工作时间段即可满足产能
  401. {
  402. workEndTime = workStartTime.AddMinutes((double)workTime);
  403. }
  404. else
  405. {
  406. //获取后续生产时间段
  407. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  408. //剩余需要工作时长
  409. decimal nextMins = workTime - effMins;
  410. foreach (var p in nextPoints)
  411. {
  412. if (p.WorkMinutes >= nextMins)
  413. {
  414. workEndTime = p.StartPoint.AddMinutes((double)nextMins);
  415. break;
  416. }
  417. nextMins -= p.WorkMinutes;
  418. }
  419. }
  420. sumQty = workOrd.QtyOrded;
  421. //记录生产周期
  422. curSequences.Add(new PeriodSequenceDet
  423. {
  424. Domain = domain,
  425. Line = lineStart.Line,
  426. ItemNum = workOrd.ItemNum,
  427. PlanDate = workStartTime.Date,
  428. Period = dto.Period,
  429. OrdQty = residueQty,
  430. WorkOrds = workOrd.WorkOrd,
  431. Op = lineStart.Op,
  432. IsActive = true,
  433. Status = "",
  434. CreateTime = DateTime.Now
  435. });
  436. //记录排产记录
  437. curScheduleRsts.Add(new ScheduleResultOpMaster
  438. {
  439. Domain = domain,
  440. WorkOrd = workOrd.WorkOrd,
  441. Line = lineStart.Line,
  442. ItemNum = workOrd.ItemNum,
  443. Op = lineStart.Op,
  444. WorkDate = workStartTime.Date,
  445. WorkQty = residueQty,
  446. WorkStartTime = workStartTime,
  447. WorkEndTime = workEndTime,
  448. CreateTime = DateTime.Now
  449. });
  450. }
  451. }
  452. }
  453. else {
  454. //当天的可用生产时长不能满足提前期
  455. sumTimes += dto.EffTime;
  456. //获取下一个工作日
  457. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  458. }
  459. }
  460. else {
  461. //判断已排产数量+当天的产能是否超过工单数量
  462. if (sumQty + dto.ProductQty <= workOrd.QtyOrded)//当天的产能需要全部排产
  463. {
  464. //记录生产周期
  465. curSequences.Add(new PeriodSequenceDet
  466. {
  467. Domain = domain,
  468. Line = lineStart.Line,
  469. ItemNum = workOrd.ItemNum,
  470. PlanDate = workStartTime.Date,
  471. Period = dto.Period,//目前只考虑一班制
  472. OrdQty = dto.ProductQty,
  473. WorkOrds = workOrd.WorkOrd,
  474. Op = lineStart.Op,
  475. IsActive = true,
  476. Status = "",
  477. CreateTime = DateTime.Now
  478. });
  479. //记录排产记录
  480. curScheduleRsts.Add(new ScheduleResultOpMaster
  481. {
  482. Domain = domain,
  483. WorkOrd = workOrd.WorkOrd,
  484. Line = lineStart.Line,
  485. ItemNum = workOrd.ItemNum,
  486. Op = lineStart.Op,
  487. WorkDate = workStartTime.Date,
  488. WorkQty = dto.ProductQty,
  489. WorkStartTime = dto.StartTime,
  490. WorkEndTime = dto.EndTime,
  491. CreateTime = DateTime.Now
  492. });
  493. //累计已排产数量
  494. sumQty += dto.ProductQty;
  495. //继续排下一个工作日
  496. workStartTime = GetNextWorkDay((int)workStartTime.DayOfWeek, workStartTime, mLCalendars);
  497. }
  498. else// 最后一天的产能只能占用一部分
  499. {
  500. //剩余需要排产的数量
  501. decimal residueQty = workOrd.QtyOrded - sumQty;
  502. //剩余数量生产需要时长(分钟)
  503. decimal workTime = Math.Ceiling(residueQty / lineStart.Rate * 60);
  504. //获取当天的工作时间段
  505. var curCalendar = mLCalendars.FirstOrDefault(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  506. if (curCalendar == null)
  507. {
  508. curCalendar = mLCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == (int)workStartTime.DayOfWeek);
  509. }
  510. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(workStartTime, curCalendar, mlqtyWorkDtls);
  511. var curPoint = workPoints.Find(p => p.StartPoint <= workStartTime && workStartTime <= p.EndPoint);
  512. if (curPoint == null)
  513. {
  514. continue;
  515. }
  516. TimeSpan span = curPoint.EndPoint - workStartTime;
  517. //当天工作时间段的有效生产时间
  518. decimal effMins = (decimal)span.TotalMinutes;
  519. DateTime workEndTime = workStartTime;
  520. if (effMins >= workTime)//当前工作时间段即可满足产能
  521. {
  522. workEndTime = workStartTime.AddMinutes((double)workTime);
  523. }
  524. else
  525. {
  526. //获取后续生产时间段
  527. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  528. //剩余需要工作时长
  529. decimal nextMins = workTime - effMins;
  530. foreach (var p in nextPoints)
  531. {
  532. if (p.WorkMinutes >= nextMins)
  533. {
  534. workEndTime = p.StartPoint.AddMinutes((double)nextMins);
  535. break;
  536. }
  537. nextMins -= p.WorkMinutes;
  538. }
  539. }
  540. sumQty = workOrd.QtyOrded;
  541. //记录生产周期
  542. curSequences.Add(new PeriodSequenceDet
  543. {
  544. Domain = domain,
  545. Line = lineStart.Line,
  546. ItemNum = workOrd.ItemNum,
  547. PlanDate = workStartTime.Date,
  548. Period = dto.Period,//目前只考虑一班制
  549. OrdQty = residueQty,
  550. WorkOrds = workOrd.WorkOrd,
  551. Op = lineStart.Op,
  552. IsActive = true,
  553. Status = "",
  554. CreateTime = DateTime.Now
  555. });
  556. //记录排产记录
  557. curScheduleRsts.Add(new ScheduleResultOpMaster
  558. {
  559. Domain = domain,
  560. WorkOrd = workOrd.WorkOrd,
  561. Line = lineStart.Line,
  562. ItemNum = workOrd.ItemNum,
  563. Op = lineStart.Op,
  564. WorkDate = workStartTime.Date,
  565. WorkQty = residueQty,
  566. WorkStartTime = workStartTime,
  567. WorkEndTime = workEndTime,
  568. CreateTime = DateTime.Now
  569. });
  570. }
  571. }
  572. }
  573. }
  574. //记录排产结果
  575. periodsDet.AddRange(curSequences);
  576. scheduleResults.AddRange(curScheduleRsts);
  577. }
  578. /// <summary>
  579. /// 获取产线当天的开工时间,结束时间,有效工作时长,生产数量
  580. /// </summary>
  581. /// <param name="rate">产线UPH</param>
  582. /// <param name="startTime">产线排产开始时间</param>
  583. /// <param name="curCalendars"></param>
  584. /// <param name="curQtyDtls"></param>
  585. /// <returns></returns>
  586. public LineScheduledDto GetScheduledPoint(decimal rate, DateTime startTime, List<ShopCalendarWorkCtr> curCalendars, List<QualityLineWorkDetail> curQtyDtls)
  587. {
  588. LineScheduledDto scheduledDto = new LineScheduledDto();
  589. //当天排产开始时间
  590. scheduledDto.StartTime = startTime;
  591. //开始时间是周几
  592. int weekDay = (int)startTime.DayOfWeek;
  593. //当天的工作日历
  594. var shopCal = curCalendars.Where(p => !string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  595. if (shopCal == null)//当前产线当天没有设置工作日历
  596. {
  597. //取默认工作日历
  598. shopCal = curCalendars.Where(p =>string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == weekDay).FirstOrDefault();
  599. }
  600. //当前日期的工作时间段
  601. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(startTime, shopCal, curQtyDtls);
  602. //当天排产结束时间
  603. scheduledDto.EndTime = workPoints.Last().EndPoint;
  604. //计算starttime处于那个工作时间段
  605. var curPoint = workPoints.Where(p => startTime >= p.StartPoint && startTime <= p.EndPoint).First();
  606. TimeSpan span = curPoint.EndPoint - startTime;
  607. scheduledDto.EffTime = (decimal)span.TotalHours;
  608. //获取后续工作时间段的有效工作时间
  609. var nextPoints = workPoints.Where(p => p.Level > curPoint.Level).ToList();
  610. foreach (var item in nextPoints)
  611. {
  612. span = item.EndPoint - item.StartPoint;
  613. scheduledDto.EffTime += (decimal)span.TotalHours;
  614. }
  615. //计算当天的产能
  616. scheduledDto.ProductQty = Math.Floor(scheduledDto.EffTime * rate);
  617. //计算班次
  618. scheduledDto.Period = 1;//默认一般制
  619. if (shopCal.ShiftsStart2 != 0 && shopCal.ShiftsHours2 != 0)
  620. {
  621. scheduledDto.Period = 2;
  622. }
  623. return scheduledDto;
  624. }
  625. /// <summary>
  626. /// 计算主产线实际排产开始时间
  627. /// </summary>
  628. /// <param name="workOrd">工单</param>
  629. /// <param name="op">工序</param>
  630. /// <param name="prodLines">生产线明细</param>
  631. /// <param name="allResults">产线占用记录</param>
  632. /// <returns></returns>
  633. public LineStartDto DealStartTime(WorkOrdMaster workOrd,int op,List<ProdLineDetail> prodLines, List<ScheduleResultOpMaster> allResults)
  634. {
  635. DateTime actStart = DateTime.Now.Date.AddDays(1);
  636. LineStartDto lineStart = new LineStartDto();
  637. //获取工序对应的产线,根据优先级排序
  638. var lines = prodLines.Where(p => p.Part == workOrd.ItemNum && p.Op == op).OrderBy(p => p.Sequence).ToList();
  639. //获取第一条产线排产结束时间
  640. var schedule = allResults.Where(p => p.Line == lines[0].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  641. actStart = schedule == null ? actStart : schedule.WorkEndTime;
  642. //计算实际开工时间
  643. var curCalendars = calendars.Where(p => p.ProdLine == lines[0].Line).ToList();
  644. var curQtyDtls = qualityLines.Where(p=>p.ProdLine == lines[0].Line).ToList();
  645. actStart = CalcActStartTime(actStart, curCalendars, curQtyDtls);
  646. lineStart.Line = lines[0].Line;
  647. lineStart.StartTime = actStart;
  648. lineStart.setupTime = lines[0].SetupTime;
  649. lineStart.Rate = lines[0].Rate;
  650. //循环其他产线
  651. for (int i = 1; i < lines.Count; i++)
  652. {
  653. schedule = allResults.Where(p => p.Line == lines[i].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  654. DateTime StartTime = schedule == null ? actStart : schedule.WorkEndTime;
  655. //计算实际开工时间
  656. curCalendars = calendars.Where(p => p.ProdLine == lines[i].Line).ToList();
  657. curQtyDtls = qualityLines.Where(p => p.ProdLine == lines[i].Line).ToList();
  658. StartTime = CalcActStartTime(StartTime, curCalendars, curQtyDtls);
  659. if (StartTime < lineStart.StartTime)
  660. {
  661. lineStart.Line = lines[i].Line;
  662. lineStart.StartTime = StartTime;
  663. lineStart.setupTime = lines[i].SetupTime;
  664. lineStart.Rate = lines[i].Rate;
  665. }
  666. }
  667. return lineStart;
  668. }
  669. /// <summary>
  670. /// 计算主产线实际排产开始时间
  671. /// </summary>
  672. /// <param name="startTime">开始时间</param>
  673. /// <param name="curCalendars">当前产线工作日历</param>
  674. /// <param name="curQtyDtls">当前产线休息记录</param>
  675. /// <returns></returns>
  676. public DateTime CalcActStartTime(DateTime startTime, List<ShopCalendarWorkCtr> curCalendars, List<QualityLineWorkDetail> curQtyDtls)
  677. {
  678. //实际排产开始时间
  679. DateTime actStart = startTime;
  680. //开始时间是周几
  681. int weekDay = (int)startTime.DayOfWeek;
  682. //判断当天是否是工作日
  683. bool isWorkDay = CheckIsWorkDay(startTime);
  684. if (!isWorkDay)//不是工作日
  685. {
  686. //获取下一个工作日开始时间
  687. actStart = GetNextWorkDay(weekDay, startTime, curCalendars);
  688. return actStart;
  689. }
  690. //当天的工作日历
  691. var shopCal = curCalendars.Where(p => p.WeekDay == weekDay).First();
  692. //当前日期的工作时间段
  693. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(startTime, shopCal, curQtyDtls);
  694. //计算starttime处于那个工作时间段
  695. var curPoint = workPoints.Where(p => startTime >= p.StartPoint && startTime <= p.EndPoint).FirstOrDefault();
  696. if (curPoint == null)//不处于工作时间段
  697. {
  698. //开始时间小于当天工作开始时间
  699. if (startTime < workPoints.First().StartPoint)
  700. {
  701. actStart = workPoints.First().StartPoint;
  702. }
  703. //开始时间大于当前工作结束时间
  704. else if (startTime > workPoints.Last().EndPoint)
  705. {
  706. //获取下一个工作日开始时间
  707. actStart = GetNextWorkDay(weekDay, startTime, curCalendars);
  708. }
  709. else
  710. {//开始时间位于当天的休息时间段
  711. foreach (var item in workPoints)
  712. {
  713. //获取下一个时间段
  714. var next = workPoints.First(p => p.Level == item.Level + 1);
  715. if (item.EndPoint < startTime && startTime < next.StartPoint)
  716. {
  717. actStart = next.StartPoint;
  718. break;
  719. }
  720. }
  721. }
  722. return actStart;
  723. }
  724. if (startTime != curPoint.EndPoint)
  725. {
  726. return actStart;
  727. }
  728. //查询下一时间段的开始时间点
  729. var nextPoint = workPoints.Where(p => p.Level == curPoint.Level + 1).FirstOrDefault();
  730. if (nextPoint != null)
  731. {
  732. return nextPoint.StartPoint;
  733. }
  734. //开始时间为今天下班时间,实际排产开始时间为下一个工作日的开始时间
  735. actStart = GetNextWorkDay(weekDay, startTime, curCalendars);
  736. return actStart;
  737. }
  738. /// <summary>
  739. /// 排产开始时间处理为半小时/整点开始--向后取整
  740. /// </summary>
  741. /// <param name="startTime"></param>
  742. /// <returns></returns>
  743. public DateTime CalcStartTimeAfter(DateTime startTime)
  744. {
  745. DateTime rtnTime = startTime;
  746. DateTime curDate = startTime.Date;
  747. //时间转换为分钟
  748. TimeSpan span = rtnTime - curDate;
  749. decimal sumMinutes = (decimal)span.TotalMinutes;
  750. int times = (int)Math.Ceiling(sumMinutes / 30);
  751. rtnTime = curDate.AddMinutes(times * 30);
  752. return rtnTime;
  753. }
  754. /// <summary>
  755. /// 排产开始时间处理为半小时/整点开始--向前取整
  756. /// </summary>
  757. /// <param name="startTime"></param>
  758. /// <returns></returns>
  759. public DateTime CalcStartTimeBefore(DateTime startTime)
  760. {
  761. DateTime rtnTime = startTime;
  762. DateTime curDate = startTime.Date;
  763. //时间转换为分钟
  764. TimeSpan span = rtnTime - curDate;
  765. decimal sumMinutes = (decimal)span.TotalMinutes;
  766. int times = (int)Math.Floor(sumMinutes / 30);
  767. rtnTime = curDate.AddMinutes(times * 30);
  768. return rtnTime;
  769. }
  770. /// <summary>
  771. /// 判断当天是否是工作日
  772. /// </summary>
  773. /// <param name="dateTime"></param>
  774. /// <returns></returns>
  775. public bool CheckIsWorkDay(DateTime dateTime)
  776. {
  777. bool isWorkDay = true;
  778. //周几
  779. int weekDay = (int)dateTime.DayOfWeek;
  780. //判断当天是否是工作日
  781. if (weekDay == 0 || weekDay == 6)//周六或者周日,需要判断是否调班,需要加班
  782. {
  783. if (!holidays.Exists(p => p.Dated.GetValueOrDefault().Date == dateTime.Date && p.Ufld1 == "调班"))//不是调班
  784. {
  785. isWorkDay = false;
  786. }
  787. return isWorkDay;
  788. }
  789. //不是周六周日,需要判断是不是节假日
  790. if (holidays.Exists(p => p.Dated.GetValueOrDefault().Date == dateTime.Date && p.Ufld1 == "休假"))//是节假日
  791. {
  792. isWorkDay = false;
  793. }
  794. return isWorkDay;
  795. }
  796. /// <summary>
  797. /// 计算下一产线实际排产开始时间
  798. /// </summary>
  799. /// <param name="workOrd">工单</param>
  800. /// <param name="lineStart">上一产线开始时间</param>
  801. /// <param name="op">工序</param>
  802. /// <param name="prodLines">产线明细</param>
  803. /// <param name="allResults">产线占用记录</param>
  804. /// <returns></returns>
  805. public LineStartDto DealNextStartTime(WorkOrdMaster workOrd,LineStartDto lineStart,int op, List<ProdLineDetail> prodLines, List<ScheduleResultOpMaster> allResults)
  806. {
  807. LineStartDto startDto = new LineStartDto();
  808. //获取产线
  809. var lines = prodLines.Where(p => p.Part == workOrd.ItemNum && p.Op == op).OrderBy(p=>p.Sequence).ToList();
  810. //获取第一条产线排产结束时间
  811. var schedule = allResults.Where(p => p.Line == lines[0].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  812. DateTime startTime = CalcStartTimeWithSetUpTime(lines[0], lineStart.StartTime, lineStart.setupTime + lines[0].OverlapTime);
  813. startDto.Line = lines[0].Line;
  814. startDto.setupTime = lines[0].SetupTime;
  815. startDto.StartTime = schedule == null ? startTime : (startTime < schedule.WorkEndTime ? schedule.WorkEndTime : startTime);
  816. startDto.Rate = lines[0].Rate;
  817. //循环剩余产线,找到最早可开工产线
  818. for (int i = 1; i < lines.Count(); i++)
  819. {
  820. schedule = allResults.Where(p => p.Line == lines[i].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  821. startTime = CalcStartTimeWithSetUpTime(lines[i], lineStart.StartTime, lineStart.setupTime + lines[i].OverlapTime);
  822. startTime = schedule == null ? startTime : (startTime < schedule.WorkEndTime ? schedule.WorkEndTime : startTime);
  823. if (startTime < startDto.StartTime)
  824. {
  825. startDto.Line = lines[i].Line;
  826. startDto.setupTime = lines[i].SetupTime;
  827. startDto.StartTime = startTime;
  828. startDto.Rate = lines[0].Rate;
  829. }
  830. }
  831. return startDto;
  832. }
  833. /// <summary>
  834. /// 通过提前期计算产线排产开始时间
  835. /// </summary>
  836. /// <param name="line">产线</param>
  837. /// <param name="startTime">上一产线开始时间</param>
  838. /// <param name="setupTime">上一产线准备时间+当前产线提前期</param>
  839. /// <returns></returns>
  840. public DateTime CalcStartTimeWithSetUpTime(ProdLineDetail line, DateTime startTime, decimal setupTime)
  841. {
  842. //提前期转换成分钟
  843. decimal needMinute = setupTime * 60;
  844. //实际排产开始时间
  845. DateTime actStart = startTime;
  846. //开始时间是周几
  847. int weekDay = (int)startTime.DayOfWeek;
  848. //当天的工作日历
  849. var shopCal = calendars.Where(p => p.ProdLine == line.Line && p.WeekDay == weekDay).First();
  850. //当前产线的休息时间设置
  851. var curQtyDtls = qualityLines.Where(p => p.ProdLine == line.Line).ToList();
  852. //当前日期的工作时间段
  853. List<LineWorkPointDto> workPoints = DealWorkDayToLevels(startTime, shopCal, curQtyDtls);
  854. //计算starttime处于那个工作时间段
  855. var curPoint = workPoints.Where(p => startTime >= p.StartPoint && startTime <= p.EndPoint).FirstOrDefault();
  856. //当前时间段可用时长
  857. TimeSpan span = curPoint.EndPoint - startTime;
  858. decimal curMins = (decimal)span.TotalMinutes;
  859. if (curMins >= needMinute)//当前时间段的可用时长满足提前期
  860. {
  861. actStart = startTime.AddMinutes((double)needMinute);
  862. return actStart;
  863. }
  864. //当前时间段的可用时长不满足
  865. //剩余提前期
  866. needMinute -= curMins;
  867. //获取后层级时间段
  868. var prePoints = workPoints.Where(p => p.Level > curPoint.Level).OrderBy(p => p.Level).ToList();
  869. bool flag = true;//标志位
  870. foreach (var item in prePoints)
  871. {
  872. if (item.WorkMinutes >= needMinute)//当前时间段的可用时长满足
  873. {
  874. actStart = item.StartPoint.AddMinutes((double)needMinute);
  875. flag = false;
  876. break;
  877. }
  878. needMinute -= item.WorkMinutes;
  879. }
  880. if (!flag)
  881. {
  882. return actStart;
  883. }
  884. //今天可用时长不够,往后工作日找
  885. DateTime nextStartTime = startTime;
  886. while (flag)
  887. {
  888. //获取下一个工作日
  889. nextStartTime = GetNextWorkDay(weekDay, startTime, calendars.Where(p => p.ProdLine == line.Line).ToList());
  890. weekDay = (int)nextStartTime.DayOfWeek;
  891. //获取前一个工作日的工作时间段数据,level顺排
  892. workPoints = DealWorkDayToLevels(nextStartTime, calendars.Where(p=>p.ProdLine == line.Line && p.WeekDay == weekDay).First(), curQtyDtls).OrderBy(p => p.Level).ToList();
  893. //当天的工作时长(分钟)
  894. decimal sumWorkMins = workPoints.Sum(p => p.WorkMinutes);
  895. if (sumWorkMins >= needMinute)//当天可用提前期满足
  896. {
  897. //获取开始时间
  898. foreach (var item in workPoints)
  899. {
  900. if (item.WorkMinutes >= needMinute)//当前时间段满足
  901. {
  902. actStart = item.StartPoint.AddMinutes((double)needMinute);
  903. break;
  904. }
  905. needMinute -= item.WorkMinutes;
  906. }
  907. flag = false;
  908. }
  909. else
  910. {
  911. //当天可用提前期不满足
  912. needMinute -= sumWorkMins;
  913. }
  914. }
  915. return actStart;
  916. }
  917. /// <summary>
  918. /// 获取下一个工作日开始时间
  919. /// </summary>
  920. /// <param name="weekDay">当前周几</param>
  921. /// <param name="startTime">开始时间</param>
  922. /// <param name="curCalendars">当前产线的工作日历</param>
  923. /// <returns></returns>
  924. public DateTime GetNextWorkDay(int weekDay, DateTime startTime, List<ShopCalendarWorkCtr> curCalendars)
  925. {
  926. DateTime rtnData = startTime;
  927. //下一天
  928. DateTime nextDate = startTime.Date.AddDays(1);
  929. //下一天是周几
  930. int nextWeekDay = (weekDay + 1) % 7;
  931. //获取工作日历:先获取当前产线的工作日历,若没有维护,则获取默认工作日历
  932. var calendar = curCalendars.FirstOrDefault(p =>!string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == nextWeekDay);
  933. if (calendar == null)
  934. {
  935. calendar = curCalendars.FirstOrDefault(p => string.IsNullOrEmpty(p.ProdLine) && p.WeekDay == nextWeekDay);
  936. }
  937. string strStart = calendar.ShiftsStart1.ToString("0.00").Replace(".", ":");
  938. //判断下一天是否是工作日
  939. if (nextWeekDay == 0 || nextWeekDay == 6)//下一天是周六或者周日,需要判断是否调班,需要加班
  940. {
  941. if (!holidays.Exists(p => p.Dated.GetValueOrDefault().Date == nextDate && p.Ufld1 == "调班"))//下一天是周末
  942. {
  943. //递归继续找下一个工作日
  944. rtnData = GetNextWorkDay(nextWeekDay, nextDate, curCalendars);
  945. return rtnData;
  946. }
  947. rtnData = Convert.ToDateTime(nextDate.ToString("yyyy-MM-dd") + " " + strStart);
  948. return rtnData;
  949. }
  950. //下一天不是周六周日,需要判断是不是节假日
  951. if (holidays.Exists(p => p.Dated.GetValueOrDefault().Date == nextDate && p.Ufld1 == "休假"))//是节假日
  952. {
  953. //递归继续找下一个工作日
  954. rtnData = GetNextWorkDay(nextWeekDay, nextDate, curCalendars);
  955. return rtnData;
  956. }
  957. rtnData = Convert.ToDateTime(nextDate.ToString("yyyy-MM-dd") + " " + strStart);
  958. return rtnData;
  959. }
  960. /// <summary>
  961. /// 获取上一个工作日开始时间
  962. /// </summary>
  963. /// <param name="startTime">开始时间</param>
  964. /// <param name="curCalendars">当前产线的工作日历</param>
  965. /// <returns></returns>
  966. public DateTime GetPreWorkDay(DateTime startTime, List<ShopCalendarWorkCtr> curCalendars)
  967. {
  968. DateTime rtnData = startTime;
  969. //前一天
  970. DateTime preDate = startTime.Date.AddDays(-1);
  971. //前一天是周几
  972. int preWeekDay = (int)preDate.DayOfWeek;
  973. var calendar = curCalendars.FirstOrDefault(p => p.WeekDay == preWeekDay);
  974. string strStart = calendar.ShiftsStart1.ToString("0.00").Replace(".", ":");
  975. //判断前一天是否是工作日
  976. if (preWeekDay == 0 || preWeekDay == 6)//前一天是周六或者周日,需要判断是否调班,需要加班
  977. {
  978. if (!holidays.Exists(p => p.Dated.GetValueOrDefault().Date == preDate && p.Ufld1 == "调班"))//前一天是非工作日
  979. {
  980. //递归继续找上一个工作日
  981. rtnData = GetPreWorkDay(preDate, curCalendars);
  982. return rtnData;
  983. }
  984. rtnData = Convert.ToDateTime(preDate.ToString("yyyy-MM-dd") + " " + strStart);
  985. return rtnData;
  986. }
  987. //前一天不是周六周日,需要判断是不是节假日
  988. if (holidays.Exists(p => p.Dated.GetValueOrDefault().Date == preDate && p.Ufld1 == "休假"))//是节假日
  989. {
  990. //递归继续找前一个工作日
  991. rtnData = GetPreWorkDay(preDate, curCalendars);
  992. return rtnData;
  993. }
  994. rtnData = Convert.ToDateTime(preDate.ToString("yyyy-MM-dd") + " " + strStart);
  995. return rtnData;
  996. }
  997. /// <summary>
  998. /// 处理当前日期的工作时间段
  999. /// </summary>
  1000. /// <param name="startTime"></param>
  1001. /// <param name="shopCal">当前产线的工作日历-周几</param>
  1002. /// <param name="curQtyDtls">每天休息记录</param>
  1003. /// <returns></returns>
  1004. public List<LineWorkPointDto> DealWorkDayToLevels(DateTime startTime, ShopCalendarWorkCtr shopCal, List<QualityLineWorkDetail> curQtyDtls)
  1005. {
  1006. //年-月-日
  1007. string date = startTime.Date.ToString("yyyy-MM-dd");
  1008. //排产记录结束日期是周几
  1009. int weekDay = (int)startTime.DayOfWeek;
  1010. //工作时间段
  1011. List<LineWorkPointDto> workPoints = new List<LineWorkPointDto>();
  1012. LineWorkPointDto dto = new LineWorkPointDto();
  1013. int level = 1;
  1014. TimeSpan span = TimeSpan.Zero;
  1015. //开始时间
  1016. string strStart = shopCal.ShiftsStart1.ToString("0.00").Replace(".", ":");
  1017. DateTime dayStartPoint = Convert.ToDateTime(date + " " + strStart);
  1018. //结束时间
  1019. DateTime dayEndPoint = CalcEndPoint(startTime, shopCal);
  1020. dto.Level = level;
  1021. dto.Line = shopCal.ProdLine;
  1022. dto.WeekDay = weekDay;
  1023. dto.StartPoint = dayStartPoint;
  1024. //按照产线休息时间切分时间段
  1025. curQtyDtls = curQtyDtls.OrderBy(p => p.RestTimePoint).ToList();
  1026. foreach (var item in curQtyDtls)
  1027. {
  1028. DateTime endPoint = Convert.ToDateTime(date + " " + item.RestTimePoint);
  1029. dto.EndPoint = endPoint;
  1030. span = dto.EndPoint - dto.StartPoint;
  1031. dto.WorkMinutes = (decimal)span.TotalMinutes;
  1032. workPoints.Add(dto);
  1033. level++;
  1034. dto = new LineWorkPointDto();
  1035. dto.Level = level;
  1036. dto.Line = shopCal.ProdLine;
  1037. dto.WeekDay = weekDay;
  1038. dto.StartPoint = endPoint.AddMinutes(item.RestTime);
  1039. }
  1040. dto.EndPoint = dayEndPoint;
  1041. span = dto.EndPoint - dto.StartPoint;
  1042. dto.WorkMinutes = (decimal)span.TotalMinutes;
  1043. workPoints.Add(dto);
  1044. return workPoints.OrderBy(p => p.Level).ToList();
  1045. }
  1046. /// <summary>
  1047. /// 计算当前班次结束时间
  1048. /// </summary>
  1049. /// <param name="startTime"></param>
  1050. /// <param name="shopCal"></param>
  1051. /// <returns></returns>
  1052. public DateTime CalcEndPoint(DateTime startTime, ShopCalendarWorkCtr shopCal)
  1053. {
  1054. //年-月-日
  1055. string date = startTime.Date.ToString("yyyy-MM-dd");
  1056. string strStart = "";
  1057. DateTime dayStartPoint = DateTime.Now;
  1058. DateTime dayEndPoint = DateTime.Now;
  1059. if (shopCal.ShiftsStart2 != 0 && shopCal.ShiftsHours2 != 0)//设置了第二班
  1060. {
  1061. strStart = shopCal.ShiftsStart2.ToString("0.00").Replace(".", ":");
  1062. dayStartPoint = Convert.ToDateTime(date + " " + strStart);
  1063. dayEndPoint = dayStartPoint.AddHours(Convert.ToDouble(shopCal.ShiftsHours2));
  1064. return dayEndPoint;
  1065. }
  1066. strStart = shopCal.ShiftsStart1.ToString("0.00").Replace(".", ":");
  1067. dayStartPoint = Convert.ToDateTime(date + " " + strStart);
  1068. dayEndPoint = dayStartPoint.AddHours(Convert.ToDouble(shopCal.ShiftsHours1));
  1069. return dayEndPoint;
  1070. }
  1071. /// <summary>
  1072. /// 计算第一条产线开始时间
  1073. /// </summary>
  1074. /// <param name="workOrd">工单</param>
  1075. /// <param name="op">关键工序</param>
  1076. /// <param name="prodLines">产线明细</param>
  1077. /// <param name="scheduleResults">排产结果</param>
  1078. /// <returns></returns>
  1079. public LineStartDto CalcLineStart(WorkOrdMaster workOrd, int op, List<ProdLineDetail> prodLines, List<ScheduleResultOpMaster> scheduleResults)
  1080. {
  1081. LineStartDto dto = new LineStartDto();
  1082. //获取工序对应的产线,根据优先级排序
  1083. var lines = prodLines.Where(p => p.Part == workOrd.ItemNum && p.Op == op).OrderBy(p=>p.Sequence).ToList();
  1084. //第一条产线:使用工单OrdDate计算开始排产时间,不需要考虑提前期
  1085. //获取当前产线排产结束时间
  1086. var schedule = scheduleResults.Where(p => p.Line == lines[0].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  1087. dto.Line = lines[0].Line;
  1088. dto.Op = op;
  1089. dto.StartTime = schedule == null ? workOrd.OrdDate.GetValueOrDefault() : (schedule.WorkEndTime <= workOrd.OrdDate ? workOrd.OrdDate.GetValueOrDefault() : schedule.WorkEndTime);
  1090. //循环其他产线
  1091. for (int i = 1; i < lines.Count; i++)
  1092. {
  1093. schedule = scheduleResults.Where(p => p.Line == lines[i].Line).OrderByDescending(p => p.WorkEndTime).FirstOrDefault();
  1094. DateTime StartTime = schedule == null ? workOrd.OrdDate.GetValueOrDefault() : (schedule.WorkEndTime <= workOrd.OrdDate ? workOrd.OrdDate.GetValueOrDefault() : schedule.WorkEndTime);
  1095. if (StartTime < dto.StartTime)
  1096. {
  1097. dto.Line = lines[i].Line;
  1098. dto.StartTime = StartTime;
  1099. }
  1100. }
  1101. return dto;
  1102. }
  1103. }
  1104. }