MorderAppService.cs 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558
  1. using Business.Core.Enum;
  2. using Business.Core.Utilities;
  3. using Business.Domain;
  4. using Business.EntityFrameworkCore.SqlRepositories;
  5. using Business.ResourceExamineManagement.Dto;
  6. using Newtonsoft.Json.Linq;
  7. using System;
  8. using System.Collections.Generic;
  9. using System.Linq;
  10. using Volo.Abp.Application.Services;
  11. namespace Business.ResourceExamineManagement
  12. {
  13. public class MorderAppService : ApplicationService
  14. {
  15. #region 服务
  16. ///// <summary>
  17. ///// 生产工单主表
  18. ///// </summary>
  19. //private readonly IMongoDB<mo_mes_morder> _mo_mes_morder;
  20. ///// <summary>
  21. ///// 生产工单子表
  22. ///// </summary>
  23. //private readonly IMongoDB<mo_mes_moentry> _mo_mes_moentry;
  24. ///// <summary>
  25. ///// 在制工单占用记录表
  26. ///// </summary>
  27. //private readonly IMongoDB<mo_mes_mooccupy> _mo_mes_mooccupy;
  28. ///// <summary>
  29. ///// 销售订单
  30. ///// </summary>
  31. //private readonly IRepository<crm_seorder, long> _mysql_crm_seorder;
  32. ///// <summary>
  33. ///// 销售订单明细
  34. ///// </summary>
  35. //private readonly IRepository<crm_seorderentry, long> _mysql_crm_seorderentry;
  36. /// <summary>
  37. /// 资源检查入参
  38. /// </summary>
  39. public SeorderentryDto param = new SeorderentryDto();
  40. /// <summary>
  41. /// 产能检查
  42. /// </summary>
  43. private readonly ProductExamineAppService _productExamineAppService;
  44. /// <summary>
  45. /// 雪花算法
  46. /// </summary>
  47. SnowFlake snowFlake = new SnowFlake();
  48. /// <summary>
  49. /// 生产线明细表
  50. /// </summary>
  51. public List<ProdLineDetail> prodLines = new List<ProdLineDetail>();
  52. /// <summary>
  53. /// 标准工艺路径表
  54. /// </summary>
  55. public List<RoutingOpDetail> routingOps = new List<RoutingOpDetail>();
  56. /// <summary>
  57. /// 排产记录表
  58. /// </summary>
  59. public List<PeriodSequenceDet> periodSequences = new List<PeriodSequenceDet>();
  60. /// <summary>
  61. /// 工作日历
  62. /// </summary>
  63. public List<ShopCalendarWorkCtr> calendarWorks = new List<ShopCalendarWorkCtr>();
  64. /// <summary>
  65. /// 休息时间段
  66. /// </summary>
  67. public List<QualityLineWorkDetail> qualityLineWorks = new List<QualityLineWorkDetail>();
  68. /// <summary>
  69. /// 节假日
  70. /// </summary>
  71. public List<HolidayMaster> holidays = new List<HolidayMaster>();
  72. /// <summary>
  73. /// 工单
  74. /// </summary>
  75. public List<mo_mes_morder> mo_Mes_Morders = new List<mo_mes_morder>();
  76. /// <summary>
  77. /// 工单子表
  78. /// </summary>
  79. public List<mo_mes_moentry> mo_Mes_Moentry = new List<mo_mes_moentry>();
  80. /// <summary>
  81. /// 工单占用
  82. /// </summary>
  83. public List<mo_mes_mooccupy> mo_Mes_Mooccupies = new List<mo_mes_mooccupy>();
  84. private readonly ISqlRepository<rf_serialnumber> _rf_serialnumber;
  85. #endregion
  86. #region 构造函数
  87. /// <summary>
  88. /// 构造函数
  89. /// </summary>
  90. /// <param name="icitem"></param>
  91. /// <param name="icbom"></param>
  92. public MorderAppService(
  93. //IMongoDB<mo_mes_morder> mo_mes_morder,
  94. //IMongoDB<mo_mes_moentry> mo_mes_moentry,
  95. //IMongoDB<mo_mes_mooccupy> mo_mes_mooccupy,
  96. //IRepository<crm_seorder, long> mysql_crm_seorder,
  97. //IRepository<crm_seorderentry, long> mysql_crm_seorderentry,
  98. ProductExamineAppService productExamineAppService,
  99. ISqlRepository<rf_serialnumber> rf_serialnumber
  100. )
  101. {
  102. //_mo_mes_morder = mo_mes_morder;
  103. //_mo_mes_moentry = mo_mes_moentry;
  104. //_mo_mes_mooccupy = mo_mes_mooccupy;
  105. //_mysql_crm_seorder = mysql_crm_seorder;
  106. //_mysql_crm_seorderentry = mysql_crm_seorderentry;
  107. _productExamineAppService = productExamineAppService;
  108. _rf_serialnumber = rf_serialnumber;
  109. }
  110. #endregion
  111. /// <summary>
  112. /// 生成工单
  113. /// </summary>
  114. /// <param name="seorderentry">销售订单子表</param>
  115. /// <param name="BomNumber">Bom编号</param>
  116. /// <param name="version">Bom版本</param>
  117. /// <param name="number">物料编码</param>
  118. /// <param name="Quantity"></param>
  119. /// <param name="ParentId"></param>
  120. public Mes_MorderDto GenerateMorder(GenerateMorderDto generateMorderDto, int urgent)
  121. {
  122. //1.库存、在制工单检查完成后 当前BOM需要自制时 产生工单。
  123. //2.每一个销售订单行对应一个工单。
  124. //TODO:考虑性能问题 循环调用,后期改造传递数组,批量处理数据后,批量保存。
  125. mo_mes_morder mes_Morder = new mo_mes_morder();
  126. mes_Morder.GenerateNewId(snowFlake.NextId());
  127. mes_Morder.mysql_id = snowFlake.NextId();
  128. mes_Morder.bang_id = generateMorderDto.bang_id;
  129. mes_Morder.morder_type = generateMorderDto.morder_type;
  130. mes_Morder.parent_id = generateMorderDto.ParentId;
  131. //mes_Morder.morder_icitem_type
  132. mes_Morder.work_order_type = generateMorderDto.work_order_type;
  133. mes_Morder.morder_state = generateMorderDto.morder_state;
  134. mes_Morder.morder_no = GetMaxSerialNumber(418022612537413);//WWPO
  135. mes_Morder.fms_number = generateMorderDto.ic_Item.fms_number;
  136. mes_Morder.bom_number = generateMorderDto.BomNumber;
  137. mes_Morder.fmodel = generateMorderDto.ic_Item.model;
  138. mes_Morder.urgent = urgent;
  139. if (generateMorderDto.ParentId != null && generateMorderDto.moentry_sys_stime != null)
  140. {
  141. //最早的开工时间3天后、 最晚时间为订单承诺时间 - 采购提前期 - 质检提前期 - 入库提前期 - 发料提前期 = 最晚开工时间 最早或最晚为系统建议开工日期
  142. //var StartDate = DateTime.Now.Date.AddDays(3);
  143. mes_Morder.moentry_sys_stime = generateMorderDto.moentry_sys_stime;
  144. if (!string.IsNullOrEmpty(generateMorderDto.BomNumber))
  145. {
  146. ProdExamineParamDto prodExamine = new ProdExamineParamDto()
  147. {
  148. ItemNum = generateMorderDto.BomNumber,
  149. PlanStart = generateMorderDto.moentry_sys_stime.Value,
  150. QtyOrd = (int)generateMorderDto.Quantity.GetValueOrDefault()
  151. };
  152. _productExamineAppService.prodLines = prodLines;
  153. _productExamineAppService.routingOps = routingOps;
  154. _productExamineAppService.periodSequences = periodSequences;
  155. _productExamineAppService.calendarWorks = calendarWorks;
  156. _productExamineAppService.qualityLineWorks = qualityLineWorks;
  157. _productExamineAppService.holidays = holidays;
  158. var ProductiveDate = _productExamineAppService.ProductiveExamine(prodExamine);
  159. //系统建议完工日期为 开工日期+产能检查时间=完工日期
  160. //var Day = ProductiveDate / (60 * 10); //返回的分钟除以十个小时得出工作天数;
  161. mes_Morder.moentry_sys_etime = ProductiveDate;
  162. TimeSpan span = ProductiveDate - generateMorderDto.moentry_sys_stime.Value;
  163. mes_Morder.morder_need_time = (decimal)span.TotalMinutes;
  164. }
  165. }
  166. mes_Morder.moentry_startup_status = 0;
  167. mes_Morder.tenant_id = param.company_id.GetValueOrDefault();
  168. mes_Morder.factory_id = param.factoryId;
  169. mes_Morder.company_id = param.company_id;
  170. mes_Morder.org_id = param.org_id;
  171. mes_Morder.product_code = generateMorderDto.number;
  172. mes_Morder.product_name = generateMorderDto.ic_Item.name;
  173. if (generateMorderDto.seorder != null)
  174. {
  175. mes_Morder.project_name = generateMorderDto.seorder.project_name;
  176. }
  177. mes_Morder.morder_date = DateTime.Now.Date.AddDays(1);
  178. //mes_Morder.morder_fstate = "计划";
  179. //TODO:目前没有取值位置
  180. mes_Morder.moentry_prd = null;
  181. mes_Morder.moentry_prdname = null;
  182. mes_Morder.moentry_wrkc = null;
  183. mes_Morder.moentry_wrkcname = null;
  184. mes_Morder.picking_qty = 0;
  185. //TODO:可删除主表字段
  186. mes_Morder.unit = generateMorderDto.ic_Item.unit;
  187. mes_Morder.morder_production_number = generateMorderDto.Quantity;
  188. mes_Morder.need_number = generateMorderDto.Quantity;
  189. mes_Morder.remaining_number = 0;
  190. mes_Morder.create_time = DateTime.Now;
  191. //生成工单子表数据
  192. mo_mes_moentry mes_Moentry = new mo_mes_moentry();
  193. mes_Moentry.GenerateNewId(snowFlake.NextId());
  194. mes_Moentry.mysql_id = snowFlake.NextId();
  195. mes_Moentry.bang_id = generateMorderDto.bang_id;
  196. mes_Moentry.moentry_moid = mes_Morder.mysql_id;
  197. mes_Moentry.moentry_mono = mes_Morder.morder_no;
  198. mes_Moentry.unit = generateMorderDto.ic_Item.unit;
  199. mes_Moentry.morder_production_number = generateMorderDto.Quantity;
  200. mes_Moentry.need_number = generateMorderDto.Quantity;
  201. mes_Moentry.remaining_number = 0;
  202. mes_Moentry.tenant_id = param.company_id.GetValueOrDefault();
  203. mes_Moentry.factory_id = param.factoryId;
  204. mes_Moentry.company_id = param.company_id;
  205. mes_Moentry.org_id = param.org_id;
  206. mes_Moentry.create_time = DateTime.Now;
  207. Mes_MorderDto mes_MorderDto = new Mes_MorderDto();
  208. mes_MorderDto.mes_Morders = new List<mo_mes_morder>();
  209. mes_MorderDto.mes_Moentries = new List<mo_mes_moentry>();
  210. mes_MorderDto.mes_Morders.Add(mes_Morder);
  211. mes_MorderDto.mes_Moentries.Add(mes_Moentry);
  212. if (generateMorderDto.seorderentry != null)
  213. {
  214. mes_Morder.planner_num = generateMorderDto.seorderentry.planner_no;
  215. mes_Morder.planner_name = generateMorderDto.seorderentry.planner_name;
  216. mes_Moentry.soentry_id = generateMorderDto.seorderentry.Id;
  217. mes_Moentry.fbill_no = generateMorderDto.seorderentry.bill_no;
  218. mes_Moentry.fentry_id = generateMorderDto.seorderentry.entry_seq.Value;
  219. }
  220. return mes_MorderDto;
  221. //using (TransactionScope scope = new TransactionScope())
  222. // {
  223. //_mes_morder.InsertOne(mes_Morder);
  224. //_mes_moentry.InsertOne(mes_Moentry);
  225. //scope.Complete();
  226. //}
  227. }
  228. /// <summary>
  229. /// 检查在制工单
  230. /// </summary>
  231. /// <param name="bomNumber">Bom编码</param>
  232. /// <param name="Quantity">需要数量</param>
  233. /// <param name="DeliverDate">交付日期</param>
  234. /// <param name="seorderentry_id">销售订单子表ID</param>
  235. /// <returns></returns>
  236. public virtual List<mo_mes_mooccupy> CheckMorder(string bomNumber, decimal Quantity, DateTime DeliverDate, crm_seorderentry seorderentry, mo_ic_item ic_Item, long bang_id)
  237. {
  238. if (string.IsNullOrEmpty(bomNumber))
  239. {
  240. //TODO:入参异常;
  241. return null;
  242. }
  243. //获取销售订单信息
  244. //var seorder = await _crm_seorder.FindAsync(x => x.Id == OrderId);
  245. //var seorderentry = await _mysql_crm_seorderentry.FindAsync(x => x.Id == seorderentry_id);
  246. //根据Bom编码查询出对应工单并且状态不为完成、关闭,非委外工单。
  247. //TODO:工单类型;
  248. //var morderList = await _mo_mes_morder.GetManyByCondition(x => x.bom_number == bomNumber && (x.morder_state != MorderEnum.Accomplish_state || x.morder_state != MorderEnum.Close_state
  249. //&& x.morder_icitem_type != MorderEnum.XgwyMorder) && !x.IsDeleted && x.tenant_id == seorderentry.tenant_id && x.bang_id == bang_id);
  250. //var morderList = mo_Mes_Morders.Where(x => x.bom_number == bomNumber).ToList();
  251. //获取物料详情
  252. //var ic_item = _ic_item.GetManyByCondition(x => x.number == seorderentry.item_number && x.tenant_id == seorderentry.tenant_id).Result.FirstOrDefault();
  253. //工单已被占用后要与占用表关联查询...减去占用量后 剩下生产数量可供下个销售工单使用。
  254. //var mes_mooccupyList = await _mo_mes_mooccupy.GetManyByCondition(x => x.moo_state == 1 && !x.IsDeleted && x.tenant_id == seorderentry.tenant_id
  255. //&& x.fitem_number == ic_Item.number && x.bang_id == bang_id);
  256. var mes_mooccupyList = mo_Mes_Mooccupies.Where(x => x.fitem_number == ic_Item.number);
  257. //首先满足需求数量工单其次判断是否满足交付日期、当数量不满足时继续查找最早交付日期订单 工单数量累加。
  258. //当前工单计划日期-1天 小于交付日期 && 计算生产数量-入库数据并且大于需求产品数量。
  259. var moentrys = mo_Mes_Moentry.Where(s => s.soentry_id == seorderentry.Id);
  260. //找到当前订单行生成的主工单
  261. var toMid = moentrys.Select(s => s.moentry_moid).ToList();
  262. var morderDataList = mo_Mes_Morders.Where(x => x.bom_number == bomNumber && x.morder_type == MorderEnum.JhMorder && x.moentry_sys_etime.GetValueOrDefault().AddDays(-1) < DeliverDate &&
  263. (x.morder_production_number - x.inventory_number - mes_mooccupyList.Where(p => p.moo_moid.GetValueOrDefault() == x.mysql_id)?.Sum(m => m.moo_qty)) > Quantity)
  264. .OrderByDescending(x => x.planner_end_date).ToList();
  265. List<mo_mes_mooccupy> mes_Mooccupies = new List<mo_mes_mooccupy>();
  266. //当数量或日期不满足的时候,寻找最早日期的工单
  267. if (morderDataList.Count == 0)
  268. {
  269. morderDataList = mo_Mes_Morders.Where(x => x.bom_number == bomNumber && (x.morder_type == MorderEnum.JhMorder || toMid.Contains(x.mysql_id)) && x.moentry_sys_etime.GetValueOrDefault().AddDays(-1) < DeliverDate).OrderByDescending(x => x.planner_end_date).ToList();
  270. }
  271. var QuantityNumber = 0.00m;
  272. //存在此数据满足当前BOM交付找到最早日期工单,则返回无需后续继续检查。
  273. foreach (var item in morderDataList)
  274. {
  275. //查询当前工单是否存在占用情况
  276. var mooccupies = mes_mooccupyList.Where(x => x.moo_moid.GetValueOrDefault() == item.mysql_id).ToList();
  277. //已占用数据
  278. var Sumqty = mooccupies.Count > 0 ? mooccupies.Sum(x => x.moo_qty) : 0.00m;
  279. //获取此工单剩余可占用数量
  280. var Sum = item.morder_production_number.GetValueOrDefault() - item.inventory_number.GetValueOrDefault() - Sumqty.GetValueOrDefault();
  281. if (Sum > 0)
  282. {
  283. #region 注释
  284. //if (Sumqty > 0 || item.inventory_number > 0)
  285. //{
  286. // ProdExamineParamDto prodExamine = new ProdExamineParamDto()
  287. // {
  288. // bom_number = item.bom_number,
  289. // version = version,
  290. // packages = (int)(item.inventory_number + Sumqty).GetValueOrDefault(),
  291. // tenantId = item.tenant_id,
  292. // factoryId = item.factory_id.GetValueOrDefault()
  293. // };
  294. // //获取入库和已占用的数据的生产时长
  295. // var ProductiveDate = _productExamineAppService.ProductiveExamine(prodExamine);
  296. // var Day = ProductiveDate.Result / (60 * 10);
  297. // //工单被完全占用结束日期为工单结束时间
  298. // if (Quantity - (item.morder_production_number - item.inventory_number - Sumqty) == 0)
  299. // {
  300. // var date = item.moentry_sys_stime.GetValueOrDefault().AddDays((double)Day);
  301. // var endDate = item.moentry_sys_etime;
  302. // }
  303. // //工单未被完成占用计算结束日期
  304. // else if (item.morder_production_number - item.inventory_number - Sumqty - Quantity > 0)
  305. // {
  306. // var date = item.moentry_sys_stime.GetValueOrDefault().AddDays((double)Day);
  307. // ProdExamineParamDto EndprodExamine = new ProdExamineParamDto()
  308. // {
  309. // bom_number = item.bom_number,
  310. // version = version,
  311. // packages = (int)Quantity,
  312. // tenantId = item.tenant_id,
  313. // factoryId = item.factory_id.GetValueOrDefault()
  314. // };
  315. // var EndProductiveDate = _productExamineAppService.ProductiveExamine(EndprodExamine);
  316. // var EndDay = ProductiveDate.Result / (60 * 10);
  317. // var endDate = date.AddDays((double)EndDay);
  318. // }
  319. //}
  320. #endregion
  321. //工单可占用数量-需求数量小于0时 占用工单全部可占用数量
  322. if (Sum - Quantity <= 0)
  323. {
  324. QuantityNumber = Sum;
  325. }
  326. else
  327. {
  328. //工单可占用数量满足 需求数量时直接占用需求数量
  329. QuantityNumber = Quantity;
  330. }
  331. var mes_Mooccupy = GetMooccupies(seorderentry, ic_Item, item, QuantityNumber, bang_id);
  332. mes_Mooccupies.Add(mes_Mooccupy);
  333. //当剩余需要数量大于0则继续寻找可占用工单,已满足需要数量停止循环查找
  334. if (Quantity - Sum <= 0)
  335. {
  336. break;
  337. }
  338. Quantity = Quantity - Sum;
  339. }
  340. }
  341. #region 注释
  342. // if (morderDataList.Count > 0)
  343. // {
  344. // //存在此数据满足当前BOM交付找到最早日期工单,则返回无需后续继续检查。
  345. // var morder = morderDataList.OrderByDescending(x => x.planner_end_date);
  346. // foreach (var item in morder)
  347. // {
  348. // var mooccupies = mes_mooccupyList.Where(x => x.moo_moid == item.Id).ToList();
  349. // if (mooccupies.Count > 0)
  350. // {
  351. // var Sumqty = mooccupies.Sum(x => x.moo_qty);
  352. // //判断此工单剩下数量是否还有
  353. // if (item.morder_production_number - item.inventory_number - Sumqty > 0)
  354. // {
  355. // var Sum = item.morder_production_number - item.inventory_number - Sumqty;
  356. // //需要数量-(计划数量-入库数量-已占用量)
  357. // Quantity = Quantity - (item.morder_production_number - item.inventory_number - Sumqty);
  358. // if (Quantity > 0)
  359. // {
  360. // var mes_Mooccupy = GetMooccupies(seorderentry, ic_Item, item, Sum);
  361. // mes_Mooccupies.Add(mes_Mooccupy);
  362. // }
  363. // else
  364. // {
  365. // break;
  366. // }
  367. // }
  368. // }
  369. // }
  370. // await _mes_mooccupy.InsertMany(mes_Mooccupies);
  371. // Number = 1;
  372. // }
  373. // else
  374. // {
  375. // // 寻找最早日期工单 && 计算生产数量-入库数据并且大于需求产品数量后累加直到满足需求产品数量
  376. // var morderListData = morderList.Where(x => x.planner_end_date.Value.AddDays(-1) < DeliverDate).OrderByDescending(x => x.planner_end_date).ToList();
  377. // decimal? number = Quantity;
  378. // foreach (var item in morderListData)
  379. // {
  380. // //查询出工单已占用总数量
  381. // var mooccupies = mes_mooccupyList.Where(x => x.moo_moid == item.Id).ToList();
  382. // var Sumqty = mooccupies.Count > 0 ? mooccupies.Sum(x => x.moo_qty) : 0.00m;
  383. // //判断此工单剩下数量是否还有
  384. // if (item.morder_production_number - item.inventory_number - Sumqty > 0)
  385. // {
  386. // var Sum = item.morder_production_number - item.inventory_number - Sumqty;
  387. // //需要数量-(计划数量-入库数量-已占用量)
  388. // Quantity = Quantity - (item.morder_production_number - item.inventory_number - Sumqty);
  389. // if (Quantity > 0)
  390. // {
  391. // var mes_Mooccupy = GetMooccupies(seorderentry, ic_Item, item, Sum);
  392. // mes_Mooccupies.Add(mes_Mooccupy);
  393. // }
  394. // else
  395. // {
  396. // break;
  397. // }
  398. // }
  399. // //var mes_Mooccupy = GetMooccupies(seorderentry, ic_Item, item, mooccupies);
  400. // //mes_Mooccupies.Add(mes_Mooccupy);
  401. // //需求数量-占用量后小于或等于0 停止循环占用工单
  402. // //if (number - mes_Mooccupy.moo_qty <= 0)
  403. // //{
  404. // // break;
  405. // //}
  406. // }
  407. // var morderDatas = morderList.Where(x => x.planner_end_date.Value.AddDays(-1) > DeliverDate &&
  408. //(x.morder_production_number - x.inventory_number) > Quantity).ToList();
  409. // if (number > 0)
  410. // {
  411. // Number = 3;
  412. // }
  413. // if (morderDatas.Count > 0)
  414. // {
  415. // Number = 2;
  416. // }
  417. // else
  418. // {
  419. // Number = 1;
  420. // }
  421. // }
  422. #endregion
  423. //TODO:返回占用数据,外层每个BOM根据占用工单数据判断是否满足。
  424. return mes_Mooccupies.OrderByDescending(s => s.moo_etime).ToList();
  425. }
  426. /// <summary>
  427. /// 拼接工单占用表
  428. /// </summary>
  429. /// <param name="seorderentry">销售订单子表</param>
  430. /// <param name="mysql_ic_item">物料详情表</param>
  431. /// <param name="item">工单表</param>
  432. /// <param name="mes_mooccupy">占用工单表</param>
  433. /// <returns></returns>
  434. public mo_mes_mooccupy GetMooccupies(crm_seorderentry seorderentry, mo_ic_item ic_item, mo_mes_morder item, decimal? number, long bang_id)
  435. {
  436. //生成mes_mooccupy工单占用表数据,代表多个工单被某个销售订单已占用。
  437. mo_mes_mooccupy mes_Mooccupy = new mo_mes_mooccupy();
  438. mes_Mooccupy.GenerateNewId(snowFlake.NextId());
  439. mes_Mooccupy.mysql_id = snowFlake.NextId();
  440. mes_Mooccupy.bang_id = bang_id;
  441. mes_Mooccupy.moo_id_type = MorderEnum.Zyjc_Type;
  442. if (seorderentry != null)
  443. {
  444. mes_Mooccupy.moo_id_billid = seorderentry.Id;//销售子表ID
  445. mes_Mooccupy.fbill_no = seorderentry.bill_no;//销售订单号
  446. mes_Mooccupy.fentry_id = seorderentry.entry_seq.Value;//销售订单行
  447. mes_Mooccupy.org_id = seorderentry.org_id;
  448. }
  449. mes_Mooccupy.fitem_name = ic_item.name;//物料名称
  450. mes_Mooccupy.fitem_number = ic_item.number;
  451. mes_Mooccupy.fmodel = ic_item.model;//规格型号
  452. mes_Mooccupy.moo_moid = item.mysql_id;
  453. mes_Mooccupy.moo_mo = item.morder_no;
  454. //占用量=生产计划数量-入库数量-已被占用数量
  455. mes_Mooccupy.moo_qty = number;
  456. mes_Mooccupy.moo_stime = item.moentry_sys_stime;
  457. mes_Mooccupy.moo_etime = item.moentry_sys_etime;
  458. mes_Mooccupy.moo_state = 1;
  459. //mes_Mooccupy.moo_cbr = string.Empty;
  460. //mes_Mooccupy.moo_ctime = ;
  461. //mes_Mooccupy.moo_creason = string.Empty;
  462. mes_Mooccupy.company_id = param.company_id;//取销售子表企业ID
  463. mes_Mooccupy.factory_id = param.factoryId;
  464. mes_Mooccupy.org_id = param.org_id;
  465. return mes_Mooccupy;
  466. }
  467. /// <summary>
  468. /// 得到一个流水号的最大流水号
  469. /// </summary>
  470. /// <param name="id">流水号id</param>
  471. /// <param name="formData">json数据,可以用json中的某个字段值作为通配符字替换流水号格式。</param>
  472. /// <returns></returns>
  473. public string GetMaxSerialNumber(long id, JObject? formData = null)
  474. {
  475. var modelList = _rf_serialnumber.Select(s => s.Id == id);
  476. if (modelList == null || modelList.Count < 1)
  477. {
  478. return string.Empty;
  479. }
  480. var model = modelList[0];
  481. int max = model.CurrentNumber + 1;
  482. var date = DateTime.Now;
  483. var lastDate = model.LastTime;
  484. switch (model.NumberType)
  485. {
  486. case 1: //年流水
  487. if (date.Year > lastDate.Year)
  488. {
  489. max = 1;
  490. }
  491. break;
  492. case 2: //月流水
  493. if (date.Year > lastDate.Year || date.Month > lastDate.Month)
  494. {
  495. max = 1;
  496. }
  497. break;
  498. case 3: //日流水
  499. if (date.Year > lastDate.Year || date.Month > lastDate.Month || date.Day > lastDate.Day)
  500. {
  501. max = 1;
  502. }
  503. break;
  504. }
  505. string number = max.ToString().PadLeft(model.NumberSize, '0');
  506. string serialNumber = string.IsNullOrWhiteSpace(model.Format) ? number
  507. : model.Format.ContainsIgnoreCase("{number}")
  508. ? model.Format.ReplaceIgnoreCase("{number}", number)
  509. : model.Format + number;
  510. //更新当前编号和最后时间
  511. model.LastTime = date;
  512. model.CurrentNumber = max;
  513. _rf_serialnumber.Update(model);
  514. return Wildcard.Replace(serialNumber, formData);
  515. }
  516. }
  517. }