358 lines
15 KiB
C#
358 lines
15 KiB
C#
|
|
using DOAN.Model.MES.recipe;
|
|
using DOAN.Model.MES.recipe.Dto;
|
|
using Infrastructure.Attribute;
|
|
using MDM.Attribute;
|
|
using MDM.Model.Material;
|
|
using MDM.Model.Process;
|
|
using MDM.Models.Flow;
|
|
using MDM.Models.Process;
|
|
using MDM.Models.Session;
|
|
using MDM.Service;
|
|
using NPOI.SS.Formula.Functions;
|
|
|
|
|
|
namespace MDM.Services.Flows
|
|
{
|
|
/// <summary>
|
|
/// 普通流程功能函数
|
|
/// </summary>
|
|
// [AppService(ServiceType = typeof(CommonFlowService), ServiceLifetime = LifeTime.Singleton)]
|
|
public class CommonFlowService : BaseService<Object>
|
|
{
|
|
|
|
/// <summary>
|
|
/// 普通入站流程
|
|
/// </summary>
|
|
/// <param name="operationCode">工序代码</param>
|
|
/// <param name="processCode">产品序列号</param>
|
|
/// <returns>入站结果</returns>
|
|
[RIZOFlow(FlowType = "common_inbound_flow")]
|
|
public InStationApplyResult CommonInboundStationFlow(string operationCode, string processCode)
|
|
{
|
|
// 参数验证
|
|
if (string.IsNullOrWhiteSpace(operationCode))
|
|
{
|
|
return InStationApplyResult.InvalidParameters;
|
|
}
|
|
|
|
if (string.IsNullOrWhiteSpace(processCode))
|
|
{
|
|
return InStationApplyResult.InvalidParameters;
|
|
}
|
|
|
|
//1.获取产品是正常件，完成件，返工件
|
|
ProductLifecycle productInfo = Context.Queryable<ProductLifecycle>()
|
|
.Where(p => p.ProductSN == processCode)
|
|
.First();
|
|
if (productInfo == null)
|
|
{
|
|
// 产品未开工，不得入站
|
|
RecordTrace(productInfo, operationCode, 0, ApplyStatusEnum.REJECTED, InStationApplyResult.ProductNotStartWork.ToString(), "产品未开工，不得入站");
|
|
return InStationApplyResult.ProductNotStartWork;
|
|
}
|
|
if (productInfo.ProductStatus == 2)
|
|
{
|
|
// 产品已经生产完成，不得入站
|
|
RecordTrace(productInfo, operationCode, 2, ApplyStatusEnum.REJECTED, InStationApplyResult.ProductCompleted.ToString(), "产品已经生产完成，不得入站");
|
|
return InStationApplyResult.ProductCompleted;
|
|
}
|
|
if (productInfo.ProductStatus == 3)
|
|
{
|
|
// 返工件允许入站
|
|
RecordTrace(productInfo, operationCode, 3, ApplyStatusEnum.SUCCESS, string.Empty, string.Empty);
|
|
return InStationApplyResult.Success;
|
|
}
|
|
if (productInfo.ProductStatus == 1)
|
|
{
|
|
//正常件处理
|
|
// 1.检查是否重复进站
|
|
bool IsRepeatInStation = Context.Queryable<ProductPassstationRecord>()
|
|
.Where(it => it.ProductSN == processCode && it.OperationCode == operationCode)
|
|
.Any();
|
|
if (IsRepeatInStation)
|
|
{
|
|
// 重复进站禁止入站
|
|
RecordTrace(productInfo, operationCode, 3, ApplyStatusEnum.REJECTED, InStationApplyResult.RepeatInStation.ToString(), "重复进站禁止入站");
|
|
return InStationApplyResult.RepeatInStation;
|
|
}
|
|
|
|
// 获取工序信息
|
|
ProcessOperation processOperation = Context.Queryable<ProcessOperation>()
|
|
.Where(it => it.FkRoutingCode == productInfo.RoutingCode && it.OperationCode == operationCode).First();
|
|
if (processOperation == null)
|
|
{
|
|
return InStationApplyResult.OperationNotFound;
|
|
}
|
|
|
|
// 可跳过的工序直接允许入站
|
|
if (processOperation.IsSkippable == 1)
|
|
{
|
|
RecordTrace(productInfo, operationCode, 1, ApplyStatusEnum.SUCCESS, null, null);
|
|
return InStationApplyResult.Success;
|
|
}
|
|
|
|
// 检查上一工序状态
|
|
if (processOperation.OperationSeq <= 10)
|
|
{
|
|
// 当前是第一个工序，无需检查上一工序
|
|
RecordTrace(productInfo, operationCode, 1, ApplyStatusEnum.SUCCESS, null, null);
|
|
return InStationApplyResult.Success;
|
|
}
|
|
|
|
// 获取上一个工序
|
|
var lastOperation = Context.Queryable<ProcessOperation>()
|
|
.Where(it => it.FkRoutingCode == productInfo.RoutingCode)
|
|
.Where(it => it.OperationSeq < processOperation.OperationSeq)
|
|
.OrderByDescending(it => it.OperationSeq)
|
|
.First();
|
|
|
|
if (lastOperation == null)
|
|
{
|
|
return InStationApplyResult.PreviousOperationNotFound;
|
|
}
|
|
|
|
// 获取上一工序的通过记录状态 判断上一站是否已经出站
|
|
bool lastOperationStatus = Context.Queryable<ProductPassstationRecord>()
|
|
.Where(it => it.ProductSN == processCode && it.OperationCode == lastOperation.OperationCode)
|
|
.Where(it => it.ApplyType == ApplyTypeEnum.OUT)
|
|
.Where(it => it.ApplyStatus == ApplyStatusEnum.SUCCESS)
|
|
.Any();
|
|
|
|
if (lastOperationStatus)
|
|
{
|
|
// 上一工序已完成，允许入站
|
|
RecordTrace(productInfo, operationCode, 1, ApplyStatusEnum.SUCCESS, InStationApplyResult.Success.ToString(), "上一工序已完成，允许入站");
|
|
return InStationApplyResult.Success;
|
|
}
|
|
else
|
|
{
|
|
// 上一工序未完成，禁止入站
|
|
RecordTrace(productInfo, operationCode, 1, ApplyStatusEnum.REJECTED, InStationApplyResult.PreviousOperationNotStarted.ToString(), "上一工序未完成，禁止入站");
|
|
return InStationApplyResult.PreviousOperationNotStarted;
|
|
}
|
|
}
|
|
|
|
return InStationApplyResult.UnknownStatus;
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
/// 记录入站操作轨迹
|
|
/// </summary>
|
|
/// <param name="product">产品信息</param>
|
|
/// <param name="operationCode">工序代码</param>
|
|
/// <param name="result">入站结果</param>
|
|
/// <param name="rejectReasonCode">拒绝原因代码</param>
|
|
/// <param name="rejectReasonDesc">拒绝原因描述</param>
|
|
private void RecordTrace(ProductLifecycle product, string operationCode, int ProductionLifeStage, ApplyStatusEnum isPass, string rejectReasonCode, string rejectReasonDesc)
|
|
{
|
|
// 更新产品状态
|
|
if (product != null)
|
|
{
|
|
Context.Updateable<ProductLifecycle>()
|
|
.SetColumns(it => new ProductLifecycle
|
|
{
|
|
ProductStatus = 1, // 设置为生产中状态
|
|
UpdatedTime = DateTime.Now
|
|
})
|
|
.Where(it => it.ProductSN == product.ProductSN)
|
|
.ExecuteCommand();
|
|
}
|
|
|
|
// 构建入站记录
|
|
var passstationRecord = new ProductPassstationRecord
|
|
{
|
|
Workorder = product?.Workorder,
|
|
Routingcode = product?.RoutingCode,
|
|
ProductSN = product?.ProductSN ?? string.Empty,
|
|
OperationCode = operationCode,
|
|
ProductionLifeStage = ProductionLifeStage, // 生产中
|
|
ApplyType = ApplyTypeEnum.IN,
|
|
ApplyStatus = isPass,
|
|
RejectReasonCode = rejectReasonCode,
|
|
RejectReasonDesc = rejectReasonDesc,
|
|
InStationTime = DateTime.Now,
|
|
CreatedTime = DateTime.Now
|
|
};
|
|
|
|
Context.Insertable(passstationRecord).ExecuteCommand();
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
//TODO: 下发中间操作流程规则
|
|
|
|
|
|
|
|
|
|
|
|
//TODO: 扫码流程 类型
|
|
[RIZOFlow(FlowType = "Scanningcode_flow")]
|
|
public List<ProcessOperationFlowMaterialParamter> ScanningcodeFlow(string RoutingCode, string operationCode, string FlowCode)
|
|
{
|
|
|
|
|
|
//获取这个工序d的扫码规则
|
|
List<ProcessOperationFlowMaterialParamter> ScanningFlowList = Context.Queryable<ProcessOperationFlow>().LeftJoin<ProcessOperationFlowMaterialParamter>((f, m) => f.FkRoutingCode == m.FkRoutingCode && f.FkOperationCode == m.FkOperationCode && f.FlowCode == m.FkFlowCode)
|
|
|
|
.Where((f, m) => f.FkRoutingCode == RoutingCode && f.FkOperationCode == operationCode && f.FlowTypeCode == "Scanningcode_flow"&&f.FlowCode== FlowCode)
|
|
.Select((f, m) => new ProcessOperationFlowMaterialParamter()
|
|
{
|
|
id = f.id,
|
|
FkRoutingCode = f.FkRoutingCode,
|
|
FkOperationCode = f.FkOperationCode,
|
|
FkFlowCode = m.FkFlowCode,
|
|
MaterialCode = m.MaterialCode,
|
|
MaterialName = m.MaterialName,
|
|
UseErrorProofRuleCode = m.UseErrorProofRuleCode,
|
|
|
|
})
|
|
.ToList();
|
|
return ScanningFlowList;
|
|
|
|
}
|
|
|
|
//TODO: 数采流程 类型 (工位流程)
|
|
[RIZOFlow(FlowType = "data_collect_flow")]
|
|
public List<ProcessOperationWorkstationFlowCollectParameter> DataCollectFlow( string RoutingCode, string operationCode, string FlowCode, string ProductlinebodyCode, string WorkstationCode)
|
|
{
|
|
//获取这个工序d的扫码规则
|
|
List<ProcessOperationWorkstationFlowCollectParameter> DataCollectFlowList = Context.Queryable<ProcessOperationFlow>().LeftJoin<ProcessOperationWorkstationFlowCollectParameter>
|
|
((f, m) => f.FkRoutingCode == m.FkRoutingCode && f.FkOperationCode == m.FkOperationCode && f.FlowCode == m.FkFlowCode)
|
|
.Where((f, m) => f.FkRoutingCode == RoutingCode && f.FkOperationCode == operationCode && f.FlowTypeCode == "Scanningcode_flow")
|
|
.Where((f,m)=>m.FkProductlinebodyCode== ProductlinebodyCode&&m.FkWorkstationCode== WorkstationCode&&m.FkFlowCode==FlowCode)
|
|
.Select((f, m) => new ProcessOperationWorkstationFlowCollectParameter()
|
|
{
|
|
FkRoutingCode = f.FkRoutingCode,
|
|
FkOperationCode = f.FkOperationCode,
|
|
FkProductlinebodyCode = m.FkProductlinebodyCode,
|
|
FkWorkstationCode = m.FkWorkstationCode,
|
|
FkFlowCode = m.FkFlowCode,
|
|
ParameterCode = m.ParameterCode,
|
|
PlcPoint = m.PlcPoint,
|
|
ParameterName = m.ParameterName,
|
|
Description = m.Description,
|
|
DataType = m.DataType,
|
|
Unit = m.Unit,
|
|
StandardValue = m.StandardValue,
|
|
MinValue = m.MinValue,
|
|
MaxValue = m.MaxValue,
|
|
IsControlled = m.IsControlled,
|
|
IsMonitored = m.IsMonitored,
|
|
ControlType = m.ControlType,
|
|
DefaultValue = m.DefaultValue,
|
|
IsRequired = m.IsRequired,
|
|
Sequence = m.Sequence,
|
|
|
|
|
|
|
|
})
|
|
.ToList();
|
|
return DataCollectFlowList;
|
|
|
|
}
|
|
|
|
//TODO: 配方流程 类型
|
|
[RIZOFlow(FlowType = "recipe_distribute_flow")]
|
|
public List<PfRecipeParametersDto> RecipeDistributeFlow(string RoutingCode, string operationCode, string FlowCode)
|
|
{
|
|
return Context.Queryable<PfRefProductRecipe>()
|
|
.LeftJoin<PfRecipeVersion>((refpr, ver) => refpr.RecipeCode == ver.RecipeCode)
|
|
.LeftJoin<PfRecipeParameters>((refpr, ver, param) => ver.RecipeCode == param.RecipeCode && ver.Version == param.Version)
|
|
.Where((refpr, ver, param) => refpr.FkFlowCode== FlowCode&&refpr.FkRoutingCode == RoutingCode && refpr.FkOperationCode == operationCode)
|
|
.Select((refpr, ver, param) => new PfRecipeParametersDto
|
|
{
|
|
Id = param.Id,
|
|
RecipeCode = param.RecipeCode,
|
|
Version = param.Version,
|
|
ParamName = param.ParamName,
|
|
Unit = param.Unit,
|
|
UpperLimit = param.UpperLimit,
|
|
LowerLimit = param.LowerLimit,
|
|
StandardValue = param.StandardValue,
|
|
Remark = param.Remark
|
|
}).ToList();
|
|
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// 普通出站流程
|
|
/// </summary>
|
|
/// <param name="operationCode"></param>
|
|
/// <param name="processCode"></param>
|
|
/// <returns></returns>
|
|
//[RIZOFlow(FlowType = "common_outbound_flow")]
|
|
//public OutStationApplyResult CommonOutboundStationFlow(string operationCode, string processCode)
|
|
//{
|
|
// // 参数验证
|
|
// if (string.IsNullOrWhiteSpace(operationCode) || string.IsNullOrWhiteSpace(processCode))
|
|
// {
|
|
// return OutStationApplyResult.InvalidParameters;
|
|
// }
|
|
// // 获取产品是正常件，完成件，返工件
|
|
// var product = GetProductBySn(processCode);
|
|
// if (product == null)
|
|
// {
|
|
// // 产品未开工，不得出站
|
|
// return OutStationApplyResult.ProductNotStartWork;
|
|
// }
|
|
// if (product.ProductStatus == 2)
|
|
// {
|
|
// // 产品已经生产完成，不得出站
|
|
// return OutStationApplyResult.ProductCompleted;
|
|
// }
|
|
// //如果正常件
|
|
// if (product.ProductStatus == 2)
|
|
// {
|
|
// // 此工序未入站，禁止出站
|
|
|
|
// // 此工序未完成中间流程，禁止出站
|
|
|
|
|
|
// //插入出站记录
|
|
// ProductPassstationRecord passstationRecord = new ProductPassstationRecord
|
|
// {
|
|
// Workorder = product.Workorder,
|
|
// Routingcode = product.RoutingCode,
|
|
// ProductSN = product.ProductSN,
|
|
// OperationCode = operationCode,
|
|
// ProuductStatus = 3, // 出站状态
|
|
// OutStationTime = DateTime.Now,
|
|
// CreatedTime = DateTime.Now
|
|
// };
|
|
// Context.Insertable(passstationRecord).ExecuteCommand();
|
|
// return OutStationApplyResult.Success;
|
|
// }
|
|
// //如果，返工件
|
|
// if (product.ProductStatus == 3)
|
|
// {
|
|
// //插入出站记录
|
|
// ProductPassstationRecord passstationRecord = new ProductPassstationRecord
|
|
// {
|
|
// Workorder = product.Workorder,
|
|
// Routingcode = product.RoutingCode,
|
|
// ProductSN = product.ProductSN,
|
|
// OperationCode = operationCode,
|
|
// ProuductStatus = 4, // 出站状态
|
|
// OutStationTime = DateTime.Now,
|
|
// CreatedTime = DateTime.Now
|
|
// };
|
|
// Context.Insertable(passstationRecord).ExecuteCommand();
|
|
// return OutStationApplyResult.Success;
|
|
// }
|
|
|
|
|
|
|
|
// return OutStationApplyResult.UnknownStatus;
|
|
//}
|
|
}
|
|
}
|