MorderAppService.cs 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557
  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.factory_id = param.factoryId;
  203. mes_Moentry.company_id = param.company_id;
  204. mes_Moentry.org_id = param.org_id;
  205. mes_Moentry.create_time = DateTime.Now;
  206. Mes_MorderDto mes_MorderDto = new Mes_MorderDto();
  207. mes_MorderDto.mes_Morders = new List<mo_mes_morder>();
  208. mes_MorderDto.mes_Moentries = new List<mo_mes_moentry>();
  209. mes_MorderDto.mes_Morders.Add(mes_Morder);
  210. mes_MorderDto.mes_Moentries.Add(mes_Moentry);
  211. if (generateMorderDto.seorderentry != null)
  212. {
  213. mes_Morder.planner_num = generateMorderDto.seorderentry.planner_no;
  214. mes_Morder.planner_name = generateMorderDto.seorderentry.planner_name;
  215. mes_Moentry.soentry_id = generateMorderDto.seorderentry.Id;
  216. mes_Moentry.fbill_no = generateMorderDto.seorderentry.bill_no;
  217. mes_Moentry.fentry_id = generateMorderDto.seorderentry.entry_seq.Value;
  218. }
  219. return mes_MorderDto;
  220. //using (TransactionScope scope = new TransactionScope())
  221. // {
  222. //_mes_morder.InsertOne(mes_Morder);
  223. //_mes_moentry.InsertOne(mes_Moentry);
  224. //scope.Complete();
  225. //}
  226. }
  227. /// <summary>
  228. /// 检查在制工单
  229. /// </summary>
  230. /// <param name="bomNumber">Bom编码</param>
  231. /// <param name="Quantity">需要数量</param>
  232. /// <param name="DeliverDate">交付日期</param>
  233. /// <param name="seorderentry_id">销售订单子表ID</param>
  234. /// <returns></returns>
  235. public virtual List<mo_mes_mooccupy> CheckMorder(string bomNumber, decimal Quantity, DateTime DeliverDate, crm_seorderentry seorderentry, mo_ic_item ic_Item, long bang_id)
  236. {
  237. if (string.IsNullOrEmpty(bomNumber))
  238. {
  239. //TODO:入参异常;
  240. return null;
  241. }
  242. //获取销售订单信息
  243. //var seorder = await _crm_seorder.FindAsync(x => x.Id == OrderId);
  244. //var seorderentry = await _mysql_crm_seorderentry.FindAsync(x => x.Id == seorderentry_id);
  245. //根据Bom编码查询出对应工单并且状态不为完成、关闭,非委外工单。
  246. //TODO:工单类型;
  247. //var morderList = await _mo_mes_morder.GetManyByCondition(x => x.bom_number == bomNumber && (x.morder_state != MorderEnum.Accomplish_state || x.morder_state != MorderEnum.Close_state
  248. //&& x.morder_icitem_type != MorderEnum.XgwyMorder) && !x.IsDeleted && x.tenant_id == seorderentry.tenant_id && x.bang_id == bang_id);
  249. //var morderList = mo_Mes_Morders.Where(x => x.bom_number == bomNumber).ToList();
  250. //获取物料详情
  251. //var ic_item = _ic_item.GetManyByCondition(x => x.number == seorderentry.item_number && x.tenant_id == seorderentry.tenant_id).Result.FirstOrDefault();
  252. //工单已被占用后要与占用表关联查询...减去占用量后 剩下生产数量可供下个销售工单使用。
  253. //var mes_mooccupyList = await _mo_mes_mooccupy.GetManyByCondition(x => x.moo_state == 1 && !x.IsDeleted && x.tenant_id == seorderentry.tenant_id
  254. //&& x.fitem_number == ic_Item.number && x.bang_id == bang_id);
  255. var mes_mooccupyList = mo_Mes_Mooccupies.Where(x => x.fitem_number == ic_Item.number);
  256. //首先满足需求数量工单其次判断是否满足交付日期、当数量不满足时继续查找最早交付日期订单 工单数量累加。
  257. //当前工单计划日期-1天 小于交付日期 && 计算生产数量-入库数据并且大于需求产品数量。
  258. var moentrys = mo_Mes_Moentry.Where(s => s.soentry_id == seorderentry.Id);
  259. //找到当前订单行生成的主工单
  260. var toMid = moentrys.Select(s => s.moentry_moid).ToList();
  261. var morderDataList = mo_Mes_Morders.Where(x => x.bom_number == bomNumber && x.morder_type == MorderEnum.JhMorder && x.moentry_sys_etime.GetValueOrDefault().AddDays(-1) < DeliverDate &&
  262. (x.morder_production_number - x.inventory_number - mes_mooccupyList.Where(p => p.moo_moid.GetValueOrDefault() == x.mysql_id)?.Sum(m => m.moo_qty)) > Quantity)
  263. .OrderByDescending(x => x.planner_end_date).ToList();
  264. List<mo_mes_mooccupy> mes_Mooccupies = new List<mo_mes_mooccupy>();
  265. //当数量或日期不满足的时候,寻找最早日期的工单
  266. if (morderDataList.Count == 0)
  267. {
  268. 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();
  269. }
  270. var QuantityNumber = 0.00m;
  271. //存在此数据满足当前BOM交付找到最早日期工单,则返回无需后续继续检查。
  272. foreach (var item in morderDataList)
  273. {
  274. //查询当前工单是否存在占用情况
  275. var mooccupies = mes_mooccupyList.Where(x => x.moo_moid.GetValueOrDefault() == item.mysql_id).ToList();
  276. //已占用数据
  277. var Sumqty = mooccupies.Count > 0 ? mooccupies.Sum(x => x.moo_qty) : 0.00m;
  278. //获取此工单剩余可占用数量
  279. var Sum = item.morder_production_number.GetValueOrDefault() - item.inventory_number.GetValueOrDefault() - Sumqty.GetValueOrDefault();
  280. if (Sum > 0)
  281. {
  282. #region 注释
  283. //if (Sumqty > 0 || item.inventory_number > 0)
  284. //{
  285. // ProdExamineParamDto prodExamine = new ProdExamineParamDto()
  286. // {
  287. // bom_number = item.bom_number,
  288. // version = version,
  289. // packages = (int)(item.inventory_number + Sumqty).GetValueOrDefault(),
  290. // tenantId = item.tenant_id,
  291. // factoryId = item.factory_id.GetValueOrDefault()
  292. // };
  293. // //获取入库和已占用的数据的生产时长
  294. // var ProductiveDate = _productExamineAppService.ProductiveExamine(prodExamine);
  295. // var Day = ProductiveDate.Result / (60 * 10);
  296. // //工单被完全占用结束日期为工单结束时间
  297. // if (Quantity - (item.morder_production_number - item.inventory_number - Sumqty) == 0)
  298. // {
  299. // var date = item.moentry_sys_stime.GetValueOrDefault().AddDays((double)Day);
  300. // var endDate = item.moentry_sys_etime;
  301. // }
  302. // //工单未被完成占用计算结束日期
  303. // else if (item.morder_production_number - item.inventory_number - Sumqty - Quantity > 0)
  304. // {
  305. // var date = item.moentry_sys_stime.GetValueOrDefault().AddDays((double)Day);
  306. // ProdExamineParamDto EndprodExamine = new ProdExamineParamDto()
  307. // {
  308. // bom_number = item.bom_number,
  309. // version = version,
  310. // packages = (int)Quantity,
  311. // tenantId = item.tenant_id,
  312. // factoryId = item.factory_id.GetValueOrDefault()
  313. // };
  314. // var EndProductiveDate = _productExamineAppService.ProductiveExamine(EndprodExamine);
  315. // var EndDay = ProductiveDate.Result / (60 * 10);
  316. // var endDate = date.AddDays((double)EndDay);
  317. // }
  318. //}
  319. #endregion
  320. //工单可占用数量-需求数量小于0时 占用工单全部可占用数量
  321. if (Sum - Quantity <= 0)
  322. {
  323. QuantityNumber = Sum;
  324. }
  325. else
  326. {
  327. //工单可占用数量满足 需求数量时直接占用需求数量
  328. QuantityNumber = Quantity;
  329. }
  330. var mes_Mooccupy = GetMooccupies(seorderentry, ic_Item, item, QuantityNumber, bang_id);
  331. mes_Mooccupies.Add(mes_Mooccupy);
  332. //当剩余需要数量大于0则继续寻找可占用工单,已满足需要数量停止循环查找
  333. if (Quantity - Sum <= 0)
  334. {
  335. break;
  336. }
  337. Quantity = Quantity - Sum;
  338. }
  339. }
  340. #region 注释
  341. // if (morderDataList.Count > 0)
  342. // {
  343. // //存在此数据满足当前BOM交付找到最早日期工单,则返回无需后续继续检查。
  344. // var morder = morderDataList.OrderByDescending(x => x.planner_end_date);
  345. // foreach (var item in morder)
  346. // {
  347. // var mooccupies = mes_mooccupyList.Where(x => x.moo_moid == item.Id).ToList();
  348. // if (mooccupies.Count > 0)
  349. // {
  350. // var Sumqty = mooccupies.Sum(x => x.moo_qty);
  351. // //判断此工单剩下数量是否还有
  352. // if (item.morder_production_number - item.inventory_number - Sumqty > 0)
  353. // {
  354. // var Sum = item.morder_production_number - item.inventory_number - Sumqty;
  355. // //需要数量-(计划数量-入库数量-已占用量)
  356. // Quantity = Quantity - (item.morder_production_number - item.inventory_number - Sumqty);
  357. // if (Quantity > 0)
  358. // {
  359. // var mes_Mooccupy = GetMooccupies(seorderentry, ic_Item, item, Sum);
  360. // mes_Mooccupies.Add(mes_Mooccupy);
  361. // }
  362. // else
  363. // {
  364. // break;
  365. // }
  366. // }
  367. // }
  368. // }
  369. // await _mes_mooccupy.InsertMany(mes_Mooccupies);
  370. // Number = 1;
  371. // }
  372. // else
  373. // {
  374. // // 寻找最早日期工单 && 计算生产数量-入库数据并且大于需求产品数量后累加直到满足需求产品数量
  375. // var morderListData = morderList.Where(x => x.planner_end_date.Value.AddDays(-1) < DeliverDate).OrderByDescending(x => x.planner_end_date).ToList();
  376. // decimal? number = Quantity;
  377. // foreach (var item in morderListData)
  378. // {
  379. // //查询出工单已占用总数量
  380. // var mooccupies = mes_mooccupyList.Where(x => x.moo_moid == item.Id).ToList();
  381. // var Sumqty = mooccupies.Count > 0 ? mooccupies.Sum(x => x.moo_qty) : 0.00m;
  382. // //判断此工单剩下数量是否还有
  383. // if (item.morder_production_number - item.inventory_number - Sumqty > 0)
  384. // {
  385. // var Sum = item.morder_production_number - item.inventory_number - Sumqty;
  386. // //需要数量-(计划数量-入库数量-已占用量)
  387. // Quantity = Quantity - (item.morder_production_number - item.inventory_number - Sumqty);
  388. // if (Quantity > 0)
  389. // {
  390. // var mes_Mooccupy = GetMooccupies(seorderentry, ic_Item, item, Sum);
  391. // mes_Mooccupies.Add(mes_Mooccupy);
  392. // }
  393. // else
  394. // {
  395. // break;
  396. // }
  397. // }
  398. // //var mes_Mooccupy = GetMooccupies(seorderentry, ic_Item, item, mooccupies);
  399. // //mes_Mooccupies.Add(mes_Mooccupy);
  400. // //需求数量-占用量后小于或等于0 停止循环占用工单
  401. // //if (number - mes_Mooccupy.moo_qty <= 0)
  402. // //{
  403. // // break;
  404. // //}
  405. // }
  406. // var morderDatas = morderList.Where(x => x.planner_end_date.Value.AddDays(-1) > DeliverDate &&
  407. //(x.morder_production_number - x.inventory_number) > Quantity).ToList();
  408. // if (number > 0)
  409. // {
  410. // Number = 3;
  411. // }
  412. // if (morderDatas.Count > 0)
  413. // {
  414. // Number = 2;
  415. // }
  416. // else
  417. // {
  418. // Number = 1;
  419. // }
  420. // }
  421. #endregion
  422. //TODO:返回占用数据,外层每个BOM根据占用工单数据判断是否满足。
  423. return mes_Mooccupies.OrderByDescending(s => s.moo_etime).ToList();
  424. }
  425. /// <summary>
  426. /// 拼接工单占用表
  427. /// </summary>
  428. /// <param name="seorderentry">销售订单子表</param>
  429. /// <param name="mysql_ic_item">物料详情表</param>
  430. /// <param name="item">工单表</param>
  431. /// <param name="mes_mooccupy">占用工单表</param>
  432. /// <returns></returns>
  433. public mo_mes_mooccupy GetMooccupies(crm_seorderentry seorderentry, mo_ic_item ic_item, mo_mes_morder item, decimal? number, long bang_id)
  434. {
  435. //生成mes_mooccupy工单占用表数据,代表多个工单被某个销售订单已占用。
  436. mo_mes_mooccupy mes_Mooccupy = new mo_mes_mooccupy();
  437. mes_Mooccupy.GenerateNewId(snowFlake.NextId());
  438. mes_Mooccupy.mysql_id = snowFlake.NextId();
  439. mes_Mooccupy.bang_id = bang_id;
  440. mes_Mooccupy.moo_id_type = MorderEnum.Zyjc_Type;
  441. if (seorderentry != null)
  442. {
  443. mes_Mooccupy.moo_id_billid = seorderentry.Id;//销售子表ID
  444. mes_Mooccupy.fbill_no = seorderentry.bill_no;//销售订单号
  445. mes_Mooccupy.fentry_id = seorderentry.entry_seq.Value;//销售订单行
  446. mes_Mooccupy.org_id = seorderentry.org_id;
  447. }
  448. mes_Mooccupy.fitem_name = ic_item.name;//物料名称
  449. mes_Mooccupy.fitem_number = ic_item.number;
  450. mes_Mooccupy.fmodel = ic_item.model;//规格型号
  451. mes_Mooccupy.moo_moid = item.mysql_id;
  452. mes_Mooccupy.moo_mo = item.morder_no;
  453. //占用量=生产计划数量-入库数量-已被占用数量
  454. mes_Mooccupy.moo_qty = number;
  455. mes_Mooccupy.moo_stime = item.moentry_sys_stime;
  456. mes_Mooccupy.moo_etime = item.moentry_sys_etime;
  457. mes_Mooccupy.moo_state = 1;
  458. //mes_Mooccupy.moo_cbr = string.Empty;
  459. //mes_Mooccupy.moo_ctime = ;
  460. //mes_Mooccupy.moo_creason = string.Empty;
  461. mes_Mooccupy.company_id = param.company_id;//取销售子表企业ID
  462. mes_Mooccupy.factory_id = param.factoryId;
  463. mes_Mooccupy.org_id = param.org_id;
  464. return mes_Mooccupy;
  465. }
  466. /// <summary>
  467. /// 得到一个流水号的最大流水号
  468. /// </summary>
  469. /// <param name="id">流水号id</param>
  470. /// <param name="formData">json数据,可以用json中的某个字段值作为通配符字替换流水号格式。</param>
  471. /// <returns></returns>
  472. public string GetMaxSerialNumber(long id, JObject? formData = null)
  473. {
  474. var modelList = _rf_serialnumber.Select(s => s.Id == id);
  475. if (modelList == null || modelList.Count < 1)
  476. {
  477. return string.Empty;
  478. }
  479. var model = modelList[0];
  480. int max = model.CurrentNumber + 1;
  481. var date = DateTime.Now;
  482. var lastDate = model.LastTime;
  483. switch (model.NumberType)
  484. {
  485. case 1: //年流水
  486. if (date.Year > lastDate.Year)
  487. {
  488. max = 1;
  489. }
  490. break;
  491. case 2: //月流水
  492. if (date.Year > lastDate.Year || date.Month > lastDate.Month)
  493. {
  494. max = 1;
  495. }
  496. break;
  497. case 3: //日流水
  498. if (date.Year > lastDate.Year || date.Month > lastDate.Month || date.Day > lastDate.Day)
  499. {
  500. max = 1;
  501. }
  502. break;
  503. }
  504. string number = max.ToString().PadLeft(model.NumberSize, '0');
  505. string serialNumber = string.IsNullOrWhiteSpace(model.Format) ? number
  506. : model.Format.ContainsIgnoreCase("{number}")
  507. ? model.Format.ReplaceIgnoreCase("{number}", number)
  508. : model.Format + number;
  509. //更新当前编号和最后时间
  510. model.LastTime = date;
  511. model.CurrentNumber = max;
  512. _rf_serialnumber.Update(model);
  513. return Wildcard.Replace(serialNumber, formData);
  514. }
  515. }
  516. }