using Business.Core.Enum;
using Business.Core.Utilities;
using Business.Domain;
using Business.EntityFrameworkCore.SqlRepositories;
using Business.ResourceExamineManagement.Dto;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Linq;
using Volo.Abp.Application.Services;
namespace Business.ResourceExamineManagement
{
public class MorderAppService : ApplicationService
{
#region 服务
/////
///// 生产工单主表
/////
//private readonly IMongoDB _mo_mes_morder;
/////
///// 生产工单子表
/////
//private readonly IMongoDB _mo_mes_moentry;
/////
///// 在制工单占用记录表
/////
//private readonly IMongoDB _mo_mes_mooccupy;
/////
///// 销售订单
/////
//private readonly IRepository _mysql_crm_seorder;
/////
///// 销售订单明细
/////
//private readonly IRepository _mysql_crm_seorderentry;
///
/// 资源检查入参
///
public SeorderentryDto param = new SeorderentryDto();
///
/// 产能检查
///
private readonly ProductExamineAppService _productExamineAppService;
///
/// 雪花算法
///
SnowFlake snowFlake = new SnowFlake();
///
/// 生产线明细表
///
public List prodLines = new List();
///
/// 标准工艺路径表
///
public List routingOps = new List();
///
/// 排产记录表
///
public List periodSequences = new List();
///
/// 工作日历
///
public List calendarWorks = new List();
///
/// 休息时间段
///
public List qualityLineWorks = new List();
///
/// 节假日
///
public List holidays = new List();
///
/// 工单
///
public List mo_Mes_Morders = new List();
///
/// 工单子表
///
public List mo_Mes_Moentry = new List();
///
/// 工单占用
///
public List mo_Mes_Mooccupies = new List();
private readonly ISqlRepository _rf_serialnumber;
#endregion
#region 构造函数
///
/// 构造函数
///
///
///
public MorderAppService(
//IMongoDB mo_mes_morder,
//IMongoDB mo_mes_moentry,
//IMongoDB mo_mes_mooccupy,
//IRepository mysql_crm_seorder,
//IRepository mysql_crm_seorderentry,
ProductExamineAppService productExamineAppService,
ISqlRepository rf_serialnumber
)
{
//_mo_mes_morder = mo_mes_morder;
//_mo_mes_moentry = mo_mes_moentry;
//_mo_mes_mooccupy = mo_mes_mooccupy;
//_mysql_crm_seorder = mysql_crm_seorder;
//_mysql_crm_seorderentry = mysql_crm_seorderentry;
_productExamineAppService = productExamineAppService;
_rf_serialnumber = rf_serialnumber;
}
#endregion
///
/// 生成工单
///
/// 销售订单子表
/// Bom编号
/// Bom版本
/// 物料编码
///
///
public Mes_MorderDto GenerateMorder(GenerateMorderDto generateMorderDto, int urgent)
{
//1.库存、在制工单检查完成后 当前BOM需要自制时 产生工单。
//2.每一个销售订单行对应一个工单。
//TODO:考虑性能问题 循环调用,后期改造传递数组,批量处理数据后,批量保存。
mo_mes_morder mes_Morder = new mo_mes_morder();
mes_Morder.GenerateNewId(snowFlake.NextId());
mes_Morder.mysql_id = snowFlake.NextId();
mes_Morder.bang_id = generateMorderDto.bang_id;
mes_Morder.morder_type = generateMorderDto.morder_type;
mes_Morder.parent_id = generateMorderDto.ParentId;
//mes_Morder.morder_icitem_type
mes_Morder.work_order_type = generateMorderDto.work_order_type;
mes_Morder.morder_state = generateMorderDto.morder_state;
mes_Morder.morder_no = GetMaxSerialNumber(418022612537413);//WWPO
mes_Morder.fms_number = generateMorderDto.ic_Item.fms_number;
mes_Morder.bom_number = generateMorderDto.BomNumber;
mes_Morder.fmodel = generateMorderDto.ic_Item.model;
mes_Morder.urgent = urgent;
if (generateMorderDto.ParentId != null && generateMorderDto.moentry_sys_stime != null)
{
//最早的开工时间3天后、 最晚时间为订单承诺时间 - 采购提前期 - 质检提前期 - 入库提前期 - 发料提前期 = 最晚开工时间 最早或最晚为系统建议开工日期
//var StartDate = DateTime.Now.Date.AddDays(3);
mes_Morder.moentry_sys_stime = generateMorderDto.moentry_sys_stime;
if (!string.IsNullOrEmpty(generateMorderDto.BomNumber))
{
ProdExamineParamDto prodExamine = new ProdExamineParamDto()
{
ItemNum = generateMorderDto.BomNumber,
PlanStart = generateMorderDto.moentry_sys_stime.Value,
QtyOrd = (int)generateMorderDto.Quantity.GetValueOrDefault()
};
_productExamineAppService.prodLines = prodLines;
_productExamineAppService.routingOps = routingOps;
_productExamineAppService.periodSequences = periodSequences;
_productExamineAppService.calendarWorks = calendarWorks;
_productExamineAppService.qualityLineWorks = qualityLineWorks;
_productExamineAppService.holidays = holidays;
var ProductiveDate = _productExamineAppService.ProductiveExamine(prodExamine);
//系统建议完工日期为 开工日期+产能检查时间=完工日期
//var Day = ProductiveDate / (60 * 10); //返回的分钟除以十个小时得出工作天数;
mes_Morder.moentry_sys_etime = ProductiveDate;
TimeSpan span = ProductiveDate - generateMorderDto.moentry_sys_stime.Value;
mes_Morder.morder_need_time = (decimal)span.TotalMinutes;
}
}
mes_Morder.moentry_startup_status = 0;
mes_Morder.tenant_id = param.company_id.GetValueOrDefault();
mes_Morder.factory_id = param.factoryId;
mes_Morder.company_id = param.company_id;
mes_Morder.org_id = param.org_id;
mes_Morder.product_code = generateMorderDto.number;
mes_Morder.product_name = generateMorderDto.ic_Item.name;
if (generateMorderDto.seorder != null)
{
mes_Morder.project_name = generateMorderDto.seorder.project_name;
}
mes_Morder.morder_date = DateTime.Now.Date.AddDays(1);
//mes_Morder.morder_fstate = "计划";
//TODO:目前没有取值位置
mes_Morder.moentry_prd = null;
mes_Morder.moentry_prdname = null;
mes_Morder.moentry_wrkc = null;
mes_Morder.moentry_wrkcname = null;
mes_Morder.picking_qty = 0;
//TODO:可删除主表字段
mes_Morder.unit = generateMorderDto.ic_Item.unit;
mes_Morder.morder_production_number = generateMorderDto.Quantity;
mes_Morder.need_number = generateMorderDto.Quantity;
mes_Morder.remaining_number = 0;
mes_Morder.create_time = DateTime.Now;
//生成工单子表数据
mo_mes_moentry mes_Moentry = new mo_mes_moentry();
mes_Moentry.GenerateNewId(snowFlake.NextId());
mes_Moentry.mysql_id = snowFlake.NextId();
mes_Moentry.bang_id = generateMorderDto.bang_id;
mes_Moentry.moentry_moid = mes_Morder.mysql_id;
mes_Moentry.moentry_mono = mes_Morder.morder_no;
mes_Moentry.unit = generateMorderDto.ic_Item.unit;
mes_Moentry.morder_production_number = generateMorderDto.Quantity;
mes_Moentry.need_number = generateMorderDto.Quantity;
mes_Moentry.remaining_number = 0;
mes_Moentry.tenant_id = param.company_id.GetValueOrDefault();
mes_Moentry.factory_id = param.factoryId;
mes_Moentry.company_id = param.company_id;
mes_Moentry.org_id = param.org_id;
mes_Moentry.create_time = DateTime.Now;
Mes_MorderDto mes_MorderDto = new Mes_MorderDto();
mes_MorderDto.mes_Morders = new List();
mes_MorderDto.mes_Moentries = new List();
mes_MorderDto.mes_Morders.Add(mes_Morder);
mes_MorderDto.mes_Moentries.Add(mes_Moentry);
if (generateMorderDto.seorderentry != null)
{
mes_Morder.planner_num = generateMorderDto.seorderentry.planner_no;
mes_Morder.planner_name = generateMorderDto.seorderentry.planner_name;
mes_Moentry.soentry_id = generateMorderDto.seorderentry.Id;
mes_Moentry.fbill_no = generateMorderDto.seorderentry.bill_no;
mes_Moentry.fentry_id = generateMorderDto.seorderentry.entry_seq.Value;
}
return mes_MorderDto;
//using (TransactionScope scope = new TransactionScope())
// {
//_mes_morder.InsertOne(mes_Morder);
//_mes_moentry.InsertOne(mes_Moentry);
//scope.Complete();
//}
}
///
/// 检查在制工单
///
/// Bom编码
/// 需要数量
/// 交付日期
/// 销售订单子表ID
///
public virtual List CheckMorder(string bomNumber, decimal Quantity, DateTime DeliverDate, crm_seorderentry seorderentry, mo_ic_item ic_Item, long bang_id)
{
if (string.IsNullOrEmpty(bomNumber))
{
//TODO:入参异常;
return null;
}
//获取销售订单信息
//var seorder = await _crm_seorder.FindAsync(x => x.Id == OrderId);
//var seorderentry = await _mysql_crm_seorderentry.FindAsync(x => x.Id == seorderentry_id);
//根据Bom编码查询出对应工单并且状态不为完成、关闭,非委外工单。
//TODO:工单类型;
//var morderList = await _mo_mes_morder.GetManyByCondition(x => x.bom_number == bomNumber && (x.morder_state != MorderEnum.Accomplish_state || x.morder_state != MorderEnum.Close_state
//&& x.morder_icitem_type != MorderEnum.XgwyMorder) && !x.IsDeleted && x.tenant_id == seorderentry.tenant_id && x.bang_id == bang_id);
//var morderList = mo_Mes_Morders.Where(x => x.bom_number == bomNumber).ToList();
//获取物料详情
//var ic_item = _ic_item.GetManyByCondition(x => x.number == seorderentry.item_number && x.tenant_id == seorderentry.tenant_id).Result.FirstOrDefault();
//工单已被占用后要与占用表关联查询...减去占用量后 剩下生产数量可供下个销售工单使用。
//var mes_mooccupyList = await _mo_mes_mooccupy.GetManyByCondition(x => x.moo_state == 1 && !x.IsDeleted && x.tenant_id == seorderentry.tenant_id
//&& x.fitem_number == ic_Item.number && x.bang_id == bang_id);
var mes_mooccupyList = mo_Mes_Mooccupies.Where(x => x.fitem_number == ic_Item.number);
//首先满足需求数量工单其次判断是否满足交付日期、当数量不满足时继续查找最早交付日期订单 工单数量累加。
//当前工单计划日期-1天 小于交付日期 && 计算生产数量-入库数据并且大于需求产品数量。
var moentrys = mo_Mes_Moentry.Where(s => s.soentry_id == seorderentry.Id);
//找到当前订单行生成的主工单
var toMid = moentrys.Select(s => s.moentry_moid).ToList();
var morderDataList = mo_Mes_Morders.Where(x => x.bom_number == bomNumber && x.morder_type == MorderEnum.JhMorder && x.moentry_sys_etime.GetValueOrDefault().AddDays(-1) < DeliverDate &&
(x.morder_production_number - x.inventory_number - mes_mooccupyList.Where(p => p.moo_moid.GetValueOrDefault() == x.mysql_id)?.Sum(m => m.moo_qty)) > Quantity)
.OrderByDescending(x => x.planner_end_date).ToList();
List mes_Mooccupies = new List();
//当数量或日期不满足的时候,寻找最早日期的工单
if (morderDataList.Count == 0)
{
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();
}
var QuantityNumber = 0.00m;
//存在此数据满足当前BOM交付找到最早日期工单,则返回无需后续继续检查。
foreach (var item in morderDataList)
{
//查询当前工单是否存在占用情况
var mooccupies = mes_mooccupyList.Where(x => x.moo_moid.GetValueOrDefault() == item.mysql_id).ToList();
//已占用数据
var Sumqty = mooccupies.Count > 0 ? mooccupies.Sum(x => x.moo_qty) : 0.00m;
//获取此工单剩余可占用数量
var Sum = item.morder_production_number.GetValueOrDefault() - item.inventory_number.GetValueOrDefault() - Sumqty.GetValueOrDefault();
if (Sum > 0)
{
#region 注释
//if (Sumqty > 0 || item.inventory_number > 0)
//{
// ProdExamineParamDto prodExamine = new ProdExamineParamDto()
// {
// bom_number = item.bom_number,
// version = version,
// packages = (int)(item.inventory_number + Sumqty).GetValueOrDefault(),
// tenantId = item.tenant_id,
// factoryId = item.factory_id.GetValueOrDefault()
// };
// //获取入库和已占用的数据的生产时长
// var ProductiveDate = _productExamineAppService.ProductiveExamine(prodExamine);
// var Day = ProductiveDate.Result / (60 * 10);
// //工单被完全占用结束日期为工单结束时间
// if (Quantity - (item.morder_production_number - item.inventory_number - Sumqty) == 0)
// {
// var date = item.moentry_sys_stime.GetValueOrDefault().AddDays((double)Day);
// var endDate = item.moentry_sys_etime;
// }
// //工单未被完成占用计算结束日期
// else if (item.morder_production_number - item.inventory_number - Sumqty - Quantity > 0)
// {
// var date = item.moentry_sys_stime.GetValueOrDefault().AddDays((double)Day);
// ProdExamineParamDto EndprodExamine = new ProdExamineParamDto()
// {
// bom_number = item.bom_number,
// version = version,
// packages = (int)Quantity,
// tenantId = item.tenant_id,
// factoryId = item.factory_id.GetValueOrDefault()
// };
// var EndProductiveDate = _productExamineAppService.ProductiveExamine(EndprodExamine);
// var EndDay = ProductiveDate.Result / (60 * 10);
// var endDate = date.AddDays((double)EndDay);
// }
//}
#endregion
//工单可占用数量-需求数量小于0时 占用工单全部可占用数量
if (Sum - Quantity <= 0)
{
QuantityNumber = Sum;
}
else
{
//工单可占用数量满足 需求数量时直接占用需求数量
QuantityNumber = Quantity;
}
var mes_Mooccupy = GetMooccupies(seorderentry, ic_Item, item, QuantityNumber, bang_id);
mes_Mooccupies.Add(mes_Mooccupy);
//当剩余需要数量大于0则继续寻找可占用工单,已满足需要数量停止循环查找
if (Quantity - Sum <= 0)
{
break;
}
Quantity = Quantity - Sum;
}
}
#region 注释
// if (morderDataList.Count > 0)
// {
// //存在此数据满足当前BOM交付找到最早日期工单,则返回无需后续继续检查。
// var morder = morderDataList.OrderByDescending(x => x.planner_end_date);
// foreach (var item in morder)
// {
// var mooccupies = mes_mooccupyList.Where(x => x.moo_moid == item.Id).ToList();
// if (mooccupies.Count > 0)
// {
// var Sumqty = mooccupies.Sum(x => x.moo_qty);
// //判断此工单剩下数量是否还有
// if (item.morder_production_number - item.inventory_number - Sumqty > 0)
// {
// var Sum = item.morder_production_number - item.inventory_number - Sumqty;
// //需要数量-(计划数量-入库数量-已占用量)
// Quantity = Quantity - (item.morder_production_number - item.inventory_number - Sumqty);
// if (Quantity > 0)
// {
// var mes_Mooccupy = GetMooccupies(seorderentry, ic_Item, item, Sum);
// mes_Mooccupies.Add(mes_Mooccupy);
// }
// else
// {
// break;
// }
// }
// }
// }
// await _mes_mooccupy.InsertMany(mes_Mooccupies);
// Number = 1;
// }
// else
// {
// // 寻找最早日期工单 && 计算生产数量-入库数据并且大于需求产品数量后累加直到满足需求产品数量
// var morderListData = morderList.Where(x => x.planner_end_date.Value.AddDays(-1) < DeliverDate).OrderByDescending(x => x.planner_end_date).ToList();
// decimal? number = Quantity;
// foreach (var item in morderListData)
// {
// //查询出工单已占用总数量
// var mooccupies = mes_mooccupyList.Where(x => x.moo_moid == item.Id).ToList();
// var Sumqty = mooccupies.Count > 0 ? mooccupies.Sum(x => x.moo_qty) : 0.00m;
// //判断此工单剩下数量是否还有
// if (item.morder_production_number - item.inventory_number - Sumqty > 0)
// {
// var Sum = item.morder_production_number - item.inventory_number - Sumqty;
// //需要数量-(计划数量-入库数量-已占用量)
// Quantity = Quantity - (item.morder_production_number - item.inventory_number - Sumqty);
// if (Quantity > 0)
// {
// var mes_Mooccupy = GetMooccupies(seorderentry, ic_Item, item, Sum);
// mes_Mooccupies.Add(mes_Mooccupy);
// }
// else
// {
// break;
// }
// }
// //var mes_Mooccupy = GetMooccupies(seorderentry, ic_Item, item, mooccupies);
// //mes_Mooccupies.Add(mes_Mooccupy);
// //需求数量-占用量后小于或等于0 停止循环占用工单
// //if (number - mes_Mooccupy.moo_qty <= 0)
// //{
// // break;
// //}
// }
// var morderDatas = morderList.Where(x => x.planner_end_date.Value.AddDays(-1) > DeliverDate &&
//(x.morder_production_number - x.inventory_number) > Quantity).ToList();
// if (number > 0)
// {
// Number = 3;
// }
// if (morderDatas.Count > 0)
// {
// Number = 2;
// }
// else
// {
// Number = 1;
// }
// }
#endregion
//TODO:返回占用数据,外层每个BOM根据占用工单数据判断是否满足。
return mes_Mooccupies.OrderByDescending(s => s.moo_etime).ToList();
}
///
/// 拼接工单占用表
///
/// 销售订单子表
/// 物料详情表
/// 工单表
/// 占用工单表
///
public mo_mes_mooccupy GetMooccupies(crm_seorderentry seorderentry, mo_ic_item ic_item, mo_mes_morder item, decimal? number, long bang_id)
{
//生成mes_mooccupy工单占用表数据,代表多个工单被某个销售订单已占用。
mo_mes_mooccupy mes_Mooccupy = new mo_mes_mooccupy();
mes_Mooccupy.GenerateNewId(snowFlake.NextId());
mes_Mooccupy.mysql_id = snowFlake.NextId();
mes_Mooccupy.bang_id = bang_id;
mes_Mooccupy.moo_id_type = MorderEnum.Zyjc_Type;
if (seorderentry != null)
{
mes_Mooccupy.moo_id_billid = seorderentry.Id;//销售子表ID
mes_Mooccupy.fbill_no = seorderentry.bill_no;//销售订单号
mes_Mooccupy.fentry_id = seorderentry.entry_seq.Value;//销售订单行
mes_Mooccupy.org_id = seorderentry.org_id;
}
mes_Mooccupy.fitem_name = ic_item.name;//物料名称
mes_Mooccupy.fitem_number = ic_item.number;
mes_Mooccupy.fmodel = ic_item.model;//规格型号
mes_Mooccupy.moo_moid = item.mysql_id;
mes_Mooccupy.moo_mo = item.morder_no;
//占用量=生产计划数量-入库数量-已被占用数量
mes_Mooccupy.moo_qty = number;
mes_Mooccupy.moo_stime = item.moentry_sys_stime;
mes_Mooccupy.moo_etime = item.moentry_sys_etime;
mes_Mooccupy.moo_state = 1;
//mes_Mooccupy.moo_cbr = string.Empty;
//mes_Mooccupy.moo_ctime = ;
//mes_Mooccupy.moo_creason = string.Empty;
mes_Mooccupy.company_id = param.company_id;//取销售子表企业ID
mes_Mooccupy.factory_id = param.factoryId;
mes_Mooccupy.org_id = param.org_id;
return mes_Mooccupy;
}
///
/// 得到一个流水号的最大流水号
///
/// 流水号id
/// json数据,可以用json中的某个字段值作为通配符字替换流水号格式。
///
public string GetMaxSerialNumber(long id, JObject? formData = null)
{
var modelList = _rf_serialnumber.Select(s => s.Id == id);
if (modelList == null || modelList.Count < 1)
{
return string.Empty;
}
var model = modelList[0];
int max = model.CurrentNumber + 1;
var date = DateTime.Now;
var lastDate = model.LastTime;
switch (model.NumberType)
{
case 1: //年流水
if (date.Year > lastDate.Year)
{
max = 1;
}
break;
case 2: //月流水
if (date.Year > lastDate.Year || date.Month > lastDate.Month)
{
max = 1;
}
break;
case 3: //日流水
if (date.Year > lastDate.Year || date.Month > lastDate.Month || date.Day > lastDate.Day)
{
max = 1;
}
break;
}
string number = max.ToString().PadLeft(model.NumberSize, '0');
string serialNumber = string.IsNullOrWhiteSpace(model.Format) ? number
: model.Format.ContainsIgnoreCase("{number}")
? model.Format.ReplaceIgnoreCase("{number}", number)
: model.Format + number;
//更新当前编号和最后时间
model.LastTime = date;
model.CurrentNumber = max;
_rf_serialnumber.Update(model);
return Wildcard.Replace(serialNumber, formData);
}
}
}