MorderAppService.cs 27 KB

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