using Amazon.Auth.AccessControlPolicy;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Util;
using Business.Core.Enum;
using Business.Core.Utilities;
using Business.Domain;
using Business.DOP;
using Business.Dto;
using Business.EntityFrameworkCore;
using Business.EntityFrameworkCore.SqlRepositories;
using Business.PriorityManagement;
using Business.Replenishment;
using Business.ResourceExamineManagement.Dto;
using Business.StructuredDB.MES;
using Business.StructuredDB.MES.IC;
using Business.StructuredDB.Replenishment;
using Business.StructuredDB.SaleFcst;
using Business.StructuredDB.WMS;
using Business.SystemJobManagement;
using EFCore.BulkExtensions;
using Microsoft.EntityFrameworkCore;
using MongoDB.Driver;
using MongoDB.Driver.Linq;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using NPOI.SS.Formula.Functions;
using NPOI.XWPF.UserModel;
using NUglify.JavaScript.Syntax;
using Org.BouncyCastle.Asn1.X500;
using Org.BouncyCastle.Asn1.X509;
using Org.BouncyCastle.Crypto;
using SixLabors.ImageSharp;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Drawing;
using System.Linq;
using System.Linq.Dynamic.Core;
using System.Threading.Tasks;
using Volo.Abp;
using Volo.Abp.Application.Services;
using Volo.Abp.Data;
using Volo.Abp.DependencyInjection;
using Volo.Abp.Domain.Repositories;
using Volo.Abp.MultiTenancy;
using Volo.Abp.Uow;
namespace Business.ResourceExamineManagement
{
///
/// 资源检查
///
//[Authorize(BusinessPermissions.ResourceExamine.Default)]
public class ResourceExamineAppService : ApplicationService, IResourceExamineAppService, ITransientDependency
{
#region 服务
SnowFlake help = new SnowFlake();
private readonly ICurrentTenant _currentTenant;
///
/// 工艺路径
///
private readonly IRepository _mes_technique;
///
/// 工序
///
private readonly IRepository _mes_process;
///
/// 工艺关联工序
///
private readonly IRepository _mes_tech_process;
///
/// 工艺工序关联工位
///
private readonly IRepository _mes_tech_proc_workshop;
///
/// 物料占用记录
///
private readonly IRepository _ic_item_stockoccupy;
private IRepository _mysql_ic_item_stockoccupy;
///
/// 物料详情
///
private readonly IRepository _ic_item;
private IRepository _mysql_ic_item;
private IRepository _mysql_ic_demandschedule;
///
/// 物料BOM
///
private readonly IRepository _ic_bom;
private IRepository _mysql_ic_bom;
///
/// 物料BOM明细
///
private readonly IRepository _ic_bom_child;
private IRepository _mysql_ic_bom_child;
///
/// 物料库存表
///
private readonly IRepository _ic_item_stock;
private IRepository _mysql_ic_item_stock;
///
/// 物料采购报价单
///
private readonly IRepository _srm_purchase;
private IRepository _mysql_srm_purchase;
///
/// 交期回复
///
private readonly ISqlRepository _scm_jhjh_jq;
///
/// 采购申请单
///
private readonly IRepository _srm_pr_main;
private IRepository _mysql_srm_pr_main;
///
/// 采购订单表
///
private readonly IRepository _srm_po_main;
private IRepository _mysql_srm_po_main;
///
/// 采购订单明细表
///
private readonly IRepository _srm_po_list;
private IRepository _mysql_srm_po_list;
private readonly IRepository _replenishmentWeekPlan;
///
/// 采购订单占用详情
///
private readonly IRepository _srm_po_occupy;
private IRepository _mysql_srm_po_occupy;
///
/// 供应商
///
private readonly IRepository _srm_supplier;
private IRepository _mysql_srm_supplier;
///
/// 委外工单
///
private readonly IRepository _mes_oorder;
private IRepository _mysql_mes_oorder;
private IRepository _mysql_b_bom_pretreatment;
private IRepository _mysql_examine_result;
private IRepository _mysql_bom_child_examine;
private IRepository _mysql_mo_occupy;
private IRepository _mysql_mo_order;
private IRepository _mysql_ooder;
private IRepository _mysql_purchase;
private IRepository _mysql_purchase_occupy;
///
/// 库存主数据
///
private ISqlRepository _invMaster;
///
/// 客户主数据
///
private readonly ISqlRepository _custMaster;
///
/// 替代方案
///
private readonly IRepository _ic_substitute;
///
/// 替代方案群组
///
private readonly IRepository _ic_substitute_group;
///
/// 替代明细
///
private readonly IRepository _ic_substitute_group_detail;
///
/// 替代方案
///
private readonly IRepository _mysql_ic_substitute;
///
/// 替代方案群组
///
private readonly IRepository _mysql_ic_substitute_group;
///
/// 替代明细
///
private readonly IRepository _mysql_ic_substitute_group_detail;
///
/// 生产工单主表
///
private readonly IRepository _mes_morder;
///
/// 生产工单子表
///
private readonly IRepository _mes_moentry;
///
/// 在制工单占用记录表
///
private readonly IRepository _mes_mooccupy;
///
/// mysql在制工单占用表
///
private readonly IRepository _mysql_mes_mooccupy;
///
/// 销售订单
///
private readonly IRepository _mysql_crm_seorder;
///
/// 销售订单明细
///
private readonly IRepository _mysql_crm_seorderentry;
///
/// 生产工单主表
///
private readonly IRepository _mysql_mes_morder;
///
/// 生产工单子表
///
private readonly IRepository _mysql_mes_moentry;
///
/// 工艺路线表
///
private readonly ISqlRepository _routingOpDetail;
///
/// 生产线明细
///
private readonly ISqlRepository _prodLineDetail;
///
/// 排产记录表
///
private readonly ISqlRepository _periodSequenceDet;
///
/// 物料职责表
///
private readonly ISqlRepository _empWorkDutyMaster;
///
/// 雇员信息表
///
private readonly ISqlRepository _employeeMaster;
///
/// 排产结果明细
///
private ISqlRepository _scheduleResultOpMaster;
///
/// 工作日历
///
private readonly ISqlRepository _shopCalendarWorkCtr;
///
/// 休息时间段
///
private readonly ISqlRepository _qualityLineWorkDetail;
///
/// 节假日
///
private readonly ISqlRepository _holidayMaster;
///
/// 标准BOM表
///
private readonly ISqlRepository _productStructureMaster;
///
/// 工单工序表
///
private ISqlRepository _workOrdRouting;
///
/// 工单主表
///
private ISqlRepository _workOrdMaster;
///
/// 成品虚拟件工序关系表
///
private readonly ISqlRepository _productStructureOp;
///
/// 工单物料明细
///
private ISqlRepository _workOrdDetail;
private readonly ISqlRepository _rf_serialnumber;
private readonly ISqlRepository _locationDetail;
private readonly ISqlRepository _configurationItem;
///
/// 资源检查入参
///
private readonly SeorderentryDto param = new SeorderentryDto();
///
/// 预处理
///
private readonly PretreatmentAppService _pretreatmentAppService;
///
/// 在途检查
///
private readonly PurchaseOrderAppService _purchaseOrderAppService;
///
/// 工单App
///
private readonly MorderAppService _morderAppService;
private readonly SerialNumberAppService _serialNumberAppService;
private readonly HolidayHelper _holidayHelper;
///
/// 优先级
///
private readonly ReplenishmentAppService _replenishmentAppService;
///
/// 计算BOM平铺物料情况
///
private readonly CalcBomViewAppService _CalcBomViewAppService;
///
/// 账号时效性验证
///
private readonly AccountValidityAppService _AccountValidityAppService;
private List leadTimeList;
private List supplierList;
private readonly BusinessBangDbContext _businessBangDbContext;
private readonly BusinessDbContext _businessDbContext;
private readonly ISqlRepository _tagMasterRepository;
///
/// 生产线维护表
///
private ISqlRepository _lineMaster;
private ISqlRepository _itemMaster;
private ISqlRepository _nbrMaster;
private ISqlRepository _nbrDetail;
private ISqlRepository _srm_polist_ds;
private ISqlRepository _purOrdMaster;
private ISqlRepository _purOrdDetail;
private ISqlRepository _purOrdDetailBatch;
private ISqlRepository _itemPackMaster;
private ISqlRepository _generalizedCodeMaster;
private readonly ISqlRepository _SAPInv;
///
/// 生产排产
///
private readonly ProductionScheduleAppService _productionScheduleAppService;
///
/// 优先级
///
private readonly PriorityAppService _priorityAppService;
///
/// 产能检查
///
private readonly ProductExamineAppService _productExamineAppService;
///
/// 生产线明细表
///
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 IDataFilter dataFilter { get; set; }
private readonly IUnitOfWorkManager _unitOfWorkManager;
private readonly SystemJobAppService _systemJobAppService;
#endregion
#region 构造函数
///
/// 构造函数
///
///
///
public ResourceExamineAppService(
IRepository mes_technique,
IRepository mes_process,
IRepository mes_tech_process,
IRepository mes_tech_proc_workshop,
IRepository ic_item,
IRepository ic_bom,
IRepository ic_bom_child,
IRepository ic_item_stock,
IRepository mes_oorder,
IRepository srm_pr_main,
IRepository srm_po_main,
IRepository srm_po_list,
IRepository srm_po_occupy,
IRepository srm_purchase,
IRepository ic_substitute,
IRepository ic_substitute_group,
IRepository ic_substitute_group_detail,
IRepository mes_morder,
IRepository mes_moentry,
IRepository mes_mooccupy,
IRepository ic_item_stockoccupy,
IRepository srm_supplier,
IRepository mysql_ic_item,
IRepository mysql_ic_demandschedule,
IRepository mysql_ic_bom,
IRepository mysql_ic_bom_child,
IRepository mysql_mes_technique,
IRepository mysql_crm_seorder,
IRepository mysql_crm_seorderentry,
IRepository mysql_ic_item_stock,
IRepository mysql_ic_item_stockoccupy,
IRepository mysql_mes_oorder,
IRepository mysql_srm_pr_main,
IRepository mysql_mes_mooccupy,
IRepository mysql_mes_morder,
IRepository mysql_mes_moentry,
IRepository mysql_mes_process,
IRepository mysql_mes_tech_process,
IRepository mysql_srm_po_main,
IRepository mysql_srm_po_list,
IRepository mysql_srm_po_occupy,
IRepository mysql_srm_purchase,
IRepository mysql_examine_result,
IRepository mysql_bom_child_examine,
IRepository mysql_mo_occupy,
IRepository mysql_mo_order,
IRepository mysql_ooder,
IRepository mysql_purchase,
IRepository mysql_purchase_occupy,
IRepository mysql_b_bom_pretreatment,
IRepository mysql_srm_supplier,
ISqlRepository tagMasterRepository,
ISqlRepository periodSequenceDet,
ISqlRepository employeeMaster,
ISqlRepository empWorkDutyMaster,
ISqlRepository lineMaster,
ISqlRepository itemMaster,
ISqlRepository custMaster,
PretreatmentAppService pretreatmentAppService,
CalcBomViewAppService calcbomviewAppService,
AccountValidityAppService accountValidityAppService,
PurchaseOrderAppService purchaseOrderAppService,
ICurrentTenant currentTenant,
MorderAppService morderAppService,
BusinessBangDbContext businessBangDbContext,
BusinessDbContext businessDbContext,
ProductionScheduleAppService productionScheduleAppService,
ISqlRepository routingOpDetail,
ISqlRepository productStructureMaster,
ISqlRepository workOrdRouting,
ISqlRepository workOrdMaster,
ISqlRepository productStructureOp,
ISqlRepository workOrdDetail,
ISqlRepository nbrMaster,
ISqlRepository nbrDetail,
ISqlRepository srmpolistds,
ISqlRepository purOrdMaster,
ISqlRepository purOrdDetail,
ISqlRepository purOrdDetailBatch,
PriorityAppService priorityAppService,
ISqlRepository prodLineDetail,
ISqlRepository shopCalendarWorkCtr,
ISqlRepository qualityLineWorkDetail,
ISqlRepository holidayMaster,
ProductExamineAppService productExamineAppService,
ISqlRepository rf_serialnumber,
ISqlRepository locationDetail,
ISqlRepository configurationItem,
ISqlRepository itemPackMaster,
ISqlRepository generalizedCodeMaster,
ISqlRepository scheduleResultOpMaster,
IRepository mysql_ic_substitute,
IRepository mysql_ic_substitute_group,
IRepository mysql_ic_substitute_group_detail,
IRepository domesticTerminalFcst,
ISqlRepository ASNBOLShipperDetail,
IRepository standardItemModelSet,
ISqlRepository invTransHist,
ISqlRepository SAPInv,
ISqlRepository monthlyShipmentPlan,
IRepository srmPurchase,
IUnitOfWorkManager unitOfWorkManager,
SerialNumberAppService serialNumberAppService,
HolidayHelper holidayHelper,
ReplenishmentAppService replenishmentAppService,
IRepository replenishmentWeekPlan,
ISqlRepository invMaster,
ISqlRepository scm_jhjh_jq,
SystemJobAppService systemJobAppService
)
{
_mes_technique = mes_technique;
_mes_process = mes_process;
_mes_tech_process = mes_tech_process;
_mes_tech_proc_workshop = mes_tech_proc_workshop;
_ic_item = ic_item;
_ic_bom = ic_bom;
_ic_bom_child = ic_bom_child;
_ic_item_stock = ic_item_stock;
_SAPInv = SAPInv;
_mes_oorder = mes_oorder;
_srm_pr_main = srm_pr_main;
_srm_po_main = srm_po_main;
_srm_po_list = srm_po_list;
_srm_po_occupy = srm_po_occupy;
_srm_purchase = srm_purchase;
_ic_substitute = ic_substitute;
_ic_substitute_group = ic_substitute_group;
_ic_substitute_group_detail = ic_substitute_group_detail;
_mysql_ic_substitute = mysql_ic_substitute;
_mysql_ic_substitute_group = mysql_ic_substitute_group;
_mysql_ic_substitute_group_detail = mysql_ic_substitute_group_detail;
_mes_morder = mes_morder;
_mes_moentry = mes_moentry;
_mes_mooccupy = mes_mooccupy;
_ic_item_stockoccupy = ic_item_stockoccupy;
_srm_supplier = srm_supplier;
_mysql_ic_item = mysql_ic_item;
_mysql_ic_demandschedule = mysql_ic_demandschedule;
_mysql_ic_bom = mysql_ic_bom;
_mysql_ic_bom_child = mysql_ic_bom_child;
_mysql_crm_seorder = mysql_crm_seorder;
_mysql_crm_seorderentry = mysql_crm_seorderentry;
_mysql_ic_item_stock = mysql_ic_item_stock;
_mysql_ic_item_stockoccupy = mysql_ic_item_stockoccupy;
_mysql_mes_oorder = mysql_mes_oorder;
_mysql_srm_pr_main = mysql_srm_pr_main;
_mysql_mes_mooccupy = mysql_mes_mooccupy;
_mysql_mes_morder = mysql_mes_morder;
_mysql_mes_moentry = mysql_mes_moentry;
_mysql_srm_po_main = mysql_srm_po_main;
_mysql_srm_po_list = mysql_srm_po_list;
_mysql_srm_po_occupy = mysql_srm_po_occupy;
_mysql_srm_purchase = mysql_srm_purchase;
_mysql_examine_result = mysql_examine_result;
_mysql_bom_child_examine = mysql_bom_child_examine;
_mysql_mo_occupy = mysql_mo_occupy;
_mysql_mo_order = mysql_mo_order;
_mysql_ooder = mysql_ooder;
_mysql_purchase = mysql_purchase;
_mysql_purchase_occupy = mysql_purchase_occupy;
_mysql_b_bom_pretreatment = mysql_b_bom_pretreatment;
_mysql_srm_supplier = mysql_srm_supplier;
_tagMasterRepository = tagMasterRepository;
_periodSequenceDet = periodSequenceDet;
_employeeMaster = employeeMaster;
_empWorkDutyMaster = empWorkDutyMaster;
_pretreatmentAppService = pretreatmentAppService;
_CalcBomViewAppService = calcbomviewAppService;
_AccountValidityAppService = accountValidityAppService;
_purchaseOrderAppService = purchaseOrderAppService;
_currentTenant = currentTenant;
_morderAppService = morderAppService;
_businessBangDbContext = businessBangDbContext;
_businessDbContext = businessDbContext;
_productionScheduleAppService = productionScheduleAppService;
_routingOpDetail = routingOpDetail;
_productStructureMaster = productStructureMaster;
_workOrdRouting = workOrdRouting;
_workOrdMaster = workOrdMaster;
_productStructureOp = productStructureOp;
_workOrdDetail = workOrdDetail;
_lineMaster = lineMaster;
_itemMaster = itemMaster;
_custMaster = custMaster;
_nbrMaster = nbrMaster;
_nbrDetail = nbrDetail;
_srm_polist_ds = srmpolistds;
_purOrdMaster = purOrdMaster;
_purOrdDetail = purOrdDetail;
_purOrdDetailBatch = purOrdDetailBatch;
_priorityAppService = priorityAppService;
_rf_serialnumber = rf_serialnumber;
_prodLineDetail = prodLineDetail;
_shopCalendarWorkCtr = shopCalendarWorkCtr;
_qualityLineWorkDetail = qualityLineWorkDetail;
_holidayMaster = holidayMaster;
_productExamineAppService = productExamineAppService;
_locationDetail = locationDetail;
_configurationItem = configurationItem;
_itemPackMaster = itemPackMaster;
_generalizedCodeMaster = generalizedCodeMaster;
_unitOfWorkManager = unitOfWorkManager;
_scheduleResultOpMaster = scheduleResultOpMaster;
_serialNumberAppService = serialNumberAppService;
_holidayHelper = holidayHelper;
_replenishmentAppService = replenishmentAppService;
_replenishmentWeekPlan = replenishmentWeekPlan;
_invMaster = invMaster;
_scm_jhjh_jq = scm_jhjh_jq;
_systemJobAppService = systemJobAppService;
}
#endregion
///
/// 自动任务执行资源检查
///
///
///
public async Task receiveresultControllerApi(string companyid)
{
//var IsActived = _AccountValidityAppService.IsActived();
//if (!IsActived)
//{
// return "此账号已限制访问";
//}
////获取订单行数据
var sentrys = await _mysql_crm_seorderentry.GetListAsync(p => (p.progress == "1" || p.progress == "2") && p.company_id.ToString() == companyid && !p.IsDeleted);
var seorders = _mysql_crm_seorder.GetListAsync(s => sentrys.Select(x => x.seorder_id.GetValueOrDefault()).Contains(s.Id) && s.company_id.ToString() == companyid).Result;
string ids = string.Join(',', seorders.Select(x => x.Id));
var rtn = await ReceiveResult(ids, 0, companyid);
if (rtn == "ok")
{
rtn = await ReviewExamineResult(ids, 0);
}
return rtn;
}
///
/// 资源检查 -- TODO:根据客户的不同标准交货期(假如客户设定10天),如果检查交期小于标准交货期(10天),则默认把建议交期调整为10天。
///
///
/// 类型(0,销售订单 1,全域订单)
///
///
public async Task ReceiveResult(string ids, int type, string companyid)
{
//var IsActived = _AccountValidityAppService.IsActived();
//if (!IsActived)
//{
// return "此账号已限制访问";
//}
if (string.IsNullOrEmpty(ids))
{
throw new NotImplementedException("请输入正确的订单号!");
}
ResourceCheckInputDto input = new ResourceCheckInputDto();
input.sorderId = AnalysisIdList(ids);
//资源检查结果
PschedDto rtn = new PschedDto();
List sorders = new List();
List sentrys = new List();
//生成当前计算bangid
long bangid = help.NextId();
if (type == 0)
{
//获取订单数据
sorders = _mysql_crm_seorder.GetListAsync(p => input.sorderId.Contains(p.Id) && !p.IsDeleted).Result;
if (!sorders.Any())
{
new NLogHelper("ResourceExamineAppService").WriteLog("ReceiveResult", "订单数据不存在", _currentTenant.Id.ToString());
return "订单数据不存在";
}
//获取订单行数据
sentrys = await _mysql_crm_seorderentry.GetListAsync(p => input.sorderId.Contains(p.seorder_id.GetValueOrDefault()) && (p.progress == "1" || p.progress == "2" || p.progress == "0") && !p.IsDeleted);
if (!sentrys.Any())
{
new NLogHelper("ResourceExamineAppService").WriteLog("ReceiveResult", "订单行数据不存在", _currentTenant.Id.ToString());
return "订单行数据不存在";
}
}
else {
//获取订单行数据
sentrys = await _mysql_crm_seorderentry.GetListAsync(p => (p.progress == "1" || p.progress == "2" || p.progress == "0") && p.company_id.ToString() == companyid && !p.IsDeleted);
if (!sentrys.Any())
{
new NLogHelper("ResourceExamineAppService").WriteLog("ReceiveResult", "订单行数据不存在", _currentTenant.Id.ToString());
return "没有需要检查的订单行。";
}
sorders = _mysql_crm_seorder.GetListAsync(p => sentrys.Select(s => s.seorder_id).Contains(p.Id) && !p.IsDeleted).Result;
if (!sorders.Any())
{
new NLogHelper("ResourceExamineAppService").WriteLog("ReceiveResult", "订单数据不存在", _currentTenant.Id.ToString());
return "没有需要检查的订单。";
}
}
input.company_id = sorders[0].company_id;
input.factoryId = sorders[0].factory_id.GetValueOrDefault();
//资源检查入参全局变量赋值
param.company_id = input.company_id;
param.factoryId = input.factoryId;
param.checkflag = true;
rtn.sorderid = input.sorderId;
//资源检查明细list
List examines = new List();
ExamineResult dtl;
//处理销售订单优先级
sorders = _priorityAppService.CalcOrderPriority(sorders, sentrys);
//处理订单行优先级
sentrys = _priorityAppService.CalcOrderEntryPriority(sorders, sentrys);
//删除同步Mysql后旧数据
await DeleteMySqlOldData(sentrys);
//通过订单行的产品代码获取物料BOM数据
List boms = _ic_bom.GetListAsync(p => sentrys.Select(m => m.item_number).Contains(p.item_number) && p.factory_id == input.factoryId && p.company_id == input.company_id && !p.IsDeleted).Result.ToList();
//物料信息
List icitemlist = _ic_item.GetListAsync(p => sentrys.Select(m => m.item_number).Contains(p.number) && !p.IsDeleted).Result;
//物料信息
//List icitemlist = new List();
//物料库存表
List stocklist = new List();
//物料占用记录
List sklist = new List();
var pretreatments = _mysql_b_bom_pretreatment.GetListAsync(s => boms.Select(c => c.mysql_id).ToList().Contains(s.sourceid)).Result;
List autoCreates = new List();
boms.ForEach(p =>
{
if (!pretreatments.Where(s => s.sourceid == p.mysql_id).Any())
{
autoCreates.Add(p);
}
});
if (autoCreates.Any() || !boms.Any() || icitemlist.Count!= boms.Count)
{
AutoCreateBomBill(param.company_id.ToString(), autoCreates);
pretreatments = _mysql_b_bom_pretreatment.GetListAsync(s => boms.Select(c => c.mysql_id).ToList().Contains(s.sourceid)).Result;
sentrys.ForEach(s => {
if (!pretreatments.Where(p => p.bom_number == s.item_number).Any())
{
var curicitem = icitemlist.Find(c => c.number == s.item_number);
//bom未生成
var fid = help.NextId();
b_bom_pretreatment bomChildExamineDto = new b_bom_pretreatment();
bomChildExamineDto.fid = fid;
bomChildExamineDto.bom_child_id = null;
bomChildExamineDto.bom_id = null;
bomChildExamineDto.bom_number = s.item_number;
bomChildExamineDto.qty = 1;
bomChildExamineDto.erp_cls = curicitem == null ? 1 : curicitem.erp_cls.GetValueOrDefault();
bomChildExamineDto.item_id = curicitem == null ? 0 : curicitem.mysql_id;
bomChildExamineDto.item_name = curicitem == null ? "" : curicitem.name;
bomChildExamineDto.item_number = s.item_number;
bomChildExamineDto.level = 1;
bomChildExamineDto.model = curicitem == null ? "" : curicitem.model;
bomChildExamineDto.unit = curicitem == null ? "" : curicitem.unit;
bomChildExamineDto.num = "1";
bomChildExamineDto.parent_id = 0;
bomChildExamineDto.type = 0;
bomChildExamineDto.PurLT = curicitem == null ? 0 : curicitem.PurLT;
bomChildExamineDto.clean_leadtime = curicitem == null ? 0 : curicitem.clean_leadtime;
bomChildExamineDto.BOMDesignTime = curicitem == null ? 0 : curicitem.BOMDesignTime;
bomChildExamineDto.RoutingDesignTime = curicitem == null ? 0 : curicitem.RoutingDesignTime;
pretreatments.Add(bomChildExamineDto);
}
});
}
await AsyncItemStockFromWMS(pretreatments);
//数据库快照-同步mysql库数据到mongoDB中
await DbSnapShot(input.company_id, input.factoryId, bangid, pretreatments);
//记录订单行的物料齐套时间
List kittingTimes = new List();
DataInitialization(boms, bangid, icitemlist, stocklist, pretreatments, sklist);
List GenerateMoList = new List();
var moNbrlistDto = _serialNumberAppService.GetBillNo(input.factoryId.ToString(), "M5", sentrys.Count, "", 1);
if (moNbrlistDto.Any())
{
foreach (var nbr in moNbrlistDto)
{
GenerateMoList.Add(nbr.NbrResult);
}
}
_CalcBomViewAppService.GenerateMoList = GenerateMoList;
foreach (var sorder in sorders)
{
param.sorderId = sorder.Id;
param.company_id = input.company_id;
param.factoryId = input.factoryId;
//param.checkflag = true;
_morderAppService.param = param;
_purchaseOrderAppService.param = param;
if (sorder.order_type.GetValueOrDefault() == 1)
{
_CalcBomViewAppService.morder_type = MorderEnum.XsMorder;
}
else {
_CalcBomViewAppService.morder_type = MorderEnum.JhMorder;
}
_CalcBomViewAppService.param = param;
//_CalcBomViewAppService.IsStraight = true;
_CalcBomViewAppService.seorder = sorder;//销售订单
var orderSentrys = sentrys.Where(s => s.seorder_id == sorder.Id).ToList();
foreach (var item in orderSentrys)
{
//工单资源检查信息
dtl = new ExamineResult();
dtl.sorderid = sorder.Id;
dtl.bill_no = sorder.bill_no;
dtl.sentry_id = item.Id;
dtl.entry_seq = item.entry_seq;
dtl.need_qty = item.qty.GetValueOrDefault();
dtl.need_time = item.plan_date;
dtl.bangid = bangid;
dtl.prd_code = item.item_number;
var bomlist = boms.Where(p => p.item_number == item.item_number).ToList();
List getBomList = new List();
if (bomlist.Count == 1)
{
//获取当前物料bom数据
var childBom = boms.Where(p => p.item_number == item.item_number).FirstOrDefault();
dtl.bom_number = childBom.bom_number;
var itemPrelist = pretreatments.Where(s => s.sourceid == childBom.mysql_id).ToList();
if (!itemPrelist.Any())
{
continue;
}
getBomList = ObjectMapper.Map, List>(itemPrelist);
getBomList.ForEach(s => s.sentry_id = item.Id);
//库存初始化
_CalcBomViewAppService.BomStock(getBomList, stocklist, bangid);
_CalcBomViewAppService.newStockOccList = new List();
//计算
_CalcBomViewAppService.CalcView(getBomList, bangid, item.qty.GetValueOrDefault(), item.plan_date, sklist, item, icitemlist);
//TODO:最晚开始时间
var curFacDtl = leadTimeList.FirstOrDefault(p => p.item_id == childBom.icitem_id);
//最晚开工时间=订单行客户要求交期-运输提前期-库存提前期-生产提前期-下单提前期-生产时间
dtl.latest_times = item.plan_date.GetValueOrDefault().AddDays(-Convert.ToDouble(curFacDtl?.transportation_leadtime.GetValueOrDefault() + curFacDtl?.stock_leadtime.GetValueOrDefault() + curFacDtl?.production_leadtime.GetValueOrDefault() + curFacDtl?.order_leadtime.GetValueOrDefault() + _CalcBomViewAppService.ProductionTimeDay));
//物料齐套时间
dtl.kitting_times = getBomList.Where(p => p.is_use).OrderByDescending(m => m.kitting_time).First().kitting_time.GetValueOrDefault();
//TODO:最早开始时间默认3天后(后期调整,因为要计算排产,计算产能这一类,才能得到开工时间)
dtl.earliest_times = dtl.kitting_times.AddDays(1);
}
else
{
dtl.bom_number = item.item_number;
var curicitem = icitemlist.Find(c => c.number == item.item_number);
// TODO:最晚开始时间
var curFacDtl = leadTimeList.FirstOrDefault(p => p.item_id == curicitem.mysql_id);
var itemPrelist = pretreatments.Where(s => s.bom_number == item.item_number).ToList();
getBomList = ObjectMapper.Map, List>(itemPrelist);
//库存初始化
_CalcBomViewAppService.BomStock(getBomList, stocklist, bangid);
//生成主工单
GenerateMorderDto generateMorderDto = new GenerateMorderDto()
{
seorderentry = item,
seorder = sorder,
ic_Item = curicitem,
BomNumber = item.item_number,
version = getBomList[0].version,
number = item.item_number,
Quantity = item.qty.GetValueOrDefault(),
morder_type = _CalcBomViewAppService.morder_type,
work_order_type = MorderEnum.CgMorder,
morder_state = MorderEnum.Initial_state,//MorderEnum.Initial_state,按要求,变成未发布工单,在周计划发布那里发布工单
bang_id = bangid,
morder_no = GenerateMoList[0]
};
_CalcBomViewAppService.CreateMainOrder(generateMorderDto, getBomList[0], new List(), new List(), bangid, item.plan_date.GetValueOrDefault(), sklist, item, icitemlist, Convert.ToInt32(getBomList[0].RoutingDesignTime.GetValueOrDefault() == 0 ? 1 : getBomList[0].RoutingDesignTime.GetValueOrDefault()));
//最晚开工时间=订单行客户要求交期-运输提前期-库存提前期-生产提前期-下单提前期-生产时间
dtl.latest_times = item.plan_date.GetValueOrDefault().AddDays(-Convert.ToDouble(curFacDtl?.transportation_leadtime.GetValueOrDefault() + curFacDtl?.stock_leadtime.GetValueOrDefault() + curFacDtl?.production_leadtime.GetValueOrDefault() + curFacDtl?.order_leadtime.GetValueOrDefault() + _CalcBomViewAppService.ProductionTimeDay));
//物料齐套时间
dtl.kitting_times = dtl.latest_times.AddDays(Convert.ToDouble(getBomList[0].BOMDesignTime.GetValueOrDefault() + getBomList[0].PurLT));
//TODO:最早开始时间默认3天后(后期调整,因为要计算排产,计算产能这一类,才能得到开工时间)
dtl.earliest_times = dtl.kitting_times.AddDays(1);
}
//再评审状态改为确认
item.progress = item.progress == "0" ? "3" : "2";
//替代关系展开list
dtl.BomChildExamineList = getBomList;
//添加订单行开工信息
examines.Add(dtl);
//记录订单行的建议交期
KittingTimeDto dto = new KittingTimeDto();
dto.sentry_id = item.Id;
dto.ItemNum = item.item_number;
dto.LackQty = getBomList.First(p => p.level == 1).lack_qty;
dto.kitting_time = dtl.kitting_times;
kittingTimes.Add(dto);
}
}
//计算订单行的建议交期(产能/物料)
CalcSuggestDate(sentrys, kittingTimes, icitemlist);
examines.ForEach(p => {
var sent = sentrys.Find(s => s.Id == p.sentry_id);
if (sent != null)
{
p.sys_material_date = sent.sys_material_date;
p.sys_capacity_date = sent.sys_capacity_date;
}
});
rtn.mordersList = _CalcBomViewAppService.mordersInsertList;
List prmainlist = new List();
if (_CalcBomViewAppService.SRMPRDtoList.Any())
{
List> prlist = _CalcBomViewAppService.SRMPRDtoList.Where(f => f.srm_Pr_Main != null).Select(s => s.srm_Pr_Main).ToList();
foreach (var pr in prlist)
{
foreach (var item in pr)
{
prmainlist.Add(item);
}
}
rtn.srm_pr_list = _CalcBomViewAppService.SRMPRDtoList;
}
using (var unitOfWork = _unitOfWorkManager.Begin(false, true))
{
try
{
await _businessDbContext.BulkUpdateAsync(sentrys);
/*//批量保存 后期考虑子工单
if (moderlist.Any())
{
await _mes_morder.InsertMany(_CalcBomViewAppService.mordersInsertList);
_businessDbContext.BulkInsert(moderlist);
if (workOrds.Any())
{
_workOrdMaster.Insert(workOrds);
}
if (workOrdRoutings.Any())
{
_workOrdRouting.Insert(workOrdRoutings);
}
if (workOrdDetails.Any())
{
_workOrdDetail.Insert(workOrdDetails);
}
}*/
if (_CalcBomViewAppService.mordersInsertList.Any())
{
await MongoHelper.InsertManyAsync(_CalcBomViewAppService.mordersInsertList);
}
if (prmainlist.Any())
{
await MongoHelper.InsertManyAsync(prmainlist);
}
if (_CalcBomViewAppService.mooccupyAllInsertList.Any())
{
_CalcBomViewAppService.mooccupyAllInsertList.ForEach(s => { s.tenant_id = param.company_id.GetValueOrDefault(); s.company_id = param.company_id; s.factory_id = param.factoryId; });
await MongoHelper.InsertManyAsync(_CalcBomViewAppService.mooccupyAllInsertList);
/*var moOccupy = ObjectMapper.Map, List>(_CalcBomViewAppService.mooccupyAllInsertList);
_businessDbContext.BulkInsert(moOccupy);*/
rtn.mooccupyAllList = _CalcBomViewAppService.mooccupyAllInsertList;
}
if (_CalcBomViewAppService.moentriesInsertList.Any())
{
_CalcBomViewAppService.moentriesInsertList.ForEach(s => { s.tenant_id = param.company_id.GetValueOrDefault(); s.company_id = param.company_id; s.factory_id = param.factoryId; });
await MongoHelper.InsertManyAsync(_CalcBomViewAppService.moentriesInsertList);
/*var mesmoentrys = ObjectMapper.Map, List>(_CalcBomViewAppService.moentriesInsertList);
_businessDbContext.BulkInsert(mesmoentrys);*/
}
if (_CalcBomViewAppService.orderList.Any())
{
_CalcBomViewAppService.orderList.ForEach(s => { s.tenant_id = param.company_id.GetValueOrDefault(); s.company_id = param.company_id; s.factory_id = param.factoryId; });
await MongoHelper.InsertManyAsync(_CalcBomViewAppService.orderList);
/*var ooders = ObjectMapper.Map, List>(_CalcBomViewAppService.orderList);
_businessDbContext.BulkInsert(ooders);*/
rtn.order_list = _CalcBomViewAppService.orderList;
}
if (_CalcBomViewAppService.newStockOccList.Any())
{
_CalcBomViewAppService.newStockOccList.ForEach(s => { s.GenerateNewId(help.NextId()); s.tenant_id = param.company_id.GetValueOrDefault(); s.company_id = param.company_id; s.factory_id = param.factoryId; });
await MongoHelper.InsertManyAsync(_CalcBomViewAppService.newStockOccList);
}
if (_CalcBomViewAppService.srm_Po_OccupiesInsert.Any())
{
_CalcBomViewAppService.srm_Po_OccupiesInsert.ForEach(s => { s.GenerateNewId(help.NextId()); s.tenant_id = param.company_id.GetValueOrDefault(); s.company_id = param.company_id; s.factory_id = param.factoryId; });
await MongoHelper.InsertManyAsync(_CalcBomViewAppService.srm_Po_OccupiesInsert);
/*var poOccupies = ObjectMapper.Map, List>(_CalcBomViewAppService.srm_Po_OccupiesInsert);
_businessDbContext.BulkInsert(poOccupies);*/
}
await unitOfWork.CompleteAsync();
}
catch (Exception e)
{
unitOfWork.Dispose();
new NLogHelper("ResourceExamineAppService").WriteLog("ReceiveResult", "资源检查工单相关数据更新失败:" + e.Message, _currentTenant.Id.ToString());
return e.Message;
};
}
rtn.examines = examines;
rtn.item_stockoccupy_list = sklist;
//检查结果写入数据库
await ExamineResultInsertDBAsync(rtn.examines);
//清空快照数据
await ClearSnapShot(bangid);
return JsonConvert.SerializeObject("ok");
}
public async Task ExamineResultInsertDBAsync(List examines)
{
//检查结果写入数据库
List examineList = new List();
List bomExamineList = new List();
List mooccupyList = new List();
List moorderList = new List();
List ooderList = new List();
List purchaseList = new List();
List purchaseoccupyList = new List