using iWare_SCADA_BusinessLogical.Utils;
|
using iWare_SCADA_Model;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace iWare_SCADA_BusinessLogical.BLL.Important
|
{
|
public class WorkingProcedureCompleteManager
|
{
|
/// <summary>
|
/// 工序完成
|
/// </summary>
|
/// <param name="logMiddle"></param>
|
/// <param name="type"></param>
|
public static void WorkingProcedureComplete(WorkPieceLogMiddle logMiddle, LogType type)
|
{
|
|
using (DbModel db = new DbModel())
|
{
|
if (logMiddle.WorkingProcedure.Equals("OP70"))
|
{
|
logMiddle.QualityState = (int)QualityStateEnum.OK; //如果是OP70，则默认是合格 【Editby shaocx,2024-06-25】
|
}
|
|
WorkPieceLog loginfo2 = new WorkPieceLog();
|
loginfo2 = EntityPropHelper.Mapper<WorkPieceLog, WorkPieceLogMiddle>(logMiddle);
|
|
try
|
{
|
if (logMiddle.WorkPieceID != null && logMiddle.WorkPieceID.Trim('\0').Length == 22)
|
{
|
|
bool isAddWorkPieceInfo = false;
|
WorkPieceInfo db_info = new WorkPieceInfo();
|
db_info = db.WorkPieceInfo.Where(o => o.WorkPieceID == logMiddle.WorkPieceID).FirstOrDefault();
|
if (db_info == null || db_info.WorkPieceID.Length < 1)
|
{//没有工件信息，不做更新 （为了测试先先新增）
|
Log4NetHelper.WriteErrorLog(type, $"工件{logMiddle.WorkPieceID} 工件推出工序{logMiddle.WorkingProcedure} 没有获取到工件信息,此时需要新增数据");
|
//db.WorkPieceLog.Add(GetAddWorkPieceLog(loginfo));//插入工件采集日志表
|
//db.SaveChanges();
|
|
loginfo2 = CommonManager.Instance.GetWorkPieceID(logMiddle, type);
|
db_info = EntityPropHelper.Mapper<WorkPieceInfo, WorkPieceLog>(logMiddle);
|
//EntityPropHelper<WorkPieceLog, WorkPieceInfo>.CopyProp(loginfo, info, loginfo.GetWorkPieceInfoDict());
|
if (!logMiddle.WorkingProcedure.Equals("OP05"))
|
{//当工件二维码第一次出现的工序不是OP05，则设置为可疑状态
|
db_info.QualityState = (int)QualityStateEnum.Suspected;
|
db_info.QualityErrorInfo = $"工件二维码第一次出现的工序{logMiddle.MonitoringPoint}不是OP05,数据缺失,请确认情况并做相应处理！";
|
db_info.Remarks = $"工件二维码第一次出现的工序{logMiddle.MonitoringPoint}不是OP05,数据缺失,请确认情况并做相应处理！";
|
}
|
else
|
{
|
db_info.QualityState = (int)QualityStateEnum.OK;//此处需要注意，判断所有工序质量，然后再赋值 //默认合格，OP05默认是合格
|
db_info.Remarks = "OP05新增工件信息";
|
}
|
db_info.WorkPieceinitOnlineTime = DateTimeHelper.GetDateTime();//WorkPieceInitOnlineTime
|
db_info.WorkingProcedurePlan = ConfigHelper.GetConfigString("WorkingProcedureAllStr") ?? "OP05OP10OP20OP30OP35OP40OP50OP60OP70OP80";
|
db_info.CreatedUserName = logMiddle.MonitoringPoint;
|
SystemBussinessHelper.SetWorkPieceInfoMiddleForCreatedUserName(ref db_info, logMiddle.DataCapturePointCname);
|
db_info.CreatedTime = DateTime.SpecifyKind(DateTime.Now, DateTimeKind.Local);
|
db_info.WorkingProcedureCurrent = logMiddle.WorkingProcedure;
|
db_info.WorkingProcedureEndTime = null;
|
db_info = WorkPieceInfoManager.ParseQRCode(db_info);
|
isAddWorkPieceInfo = true;
|
}
|
if (logMiddle.WorkingProcedure.Equals("OP10"))
|
{
|
//var WorkingProcedure = (loginfo.MonitoringPoint.Equals("OP1002") ? "OP10" : "OP40");
|
loginfo2.WorkingProcedure = db_info.WorkingProcedureCurrent;//解决OP10，OP40同一个的问题
|
logMiddle.WorkingProcedure = db_info.WorkingProcedureCurrent; //解决OP10，OP40同一个的问题
|
}
|
|
db_info.WorkingProcedureCurrent = logMiddle.WorkingProcedure;//赋值最新工序 【Editby shaocx,2024-09-03】
|
db_info.UpdatedUserName = logMiddle.MonitoringPoint;
|
SystemBussinessHelper.SetWorkPieceInfoMiddleForUpdateDataCapturePointCname(ref db_info, logMiddle.DataCapturePointCname);
|
db_info.UpdatedTime = DateTimeHelper.GetDateTime();
|
db_info.WorkingProcedureCompleted = db_info.WorkingProcedureCompleted + logMiddle.WorkingProcedure;//已完成工序
|
if (!(db_info.WorkingProcedureStartTime.HasValue && db_info.WorkingProcedureStartTime > DateTime.Parse("1900/01/01")))
|
{//若一直没有工序开始时间，则赋值当前时间
|
db_info.WorkingProcedureStartTime = DateTimeHelper.GetDateTime();
|
}
|
db_info.WorkingProcedureEndTime = DateTimeHelper.GetDateTime();
|
db_info.WorkPieceCurrentPositionOrder = db_info.WorkingProcedurePlan.IndexOf(logMiddle.WorkingProcedure) / 2;
|
db_info.Remarks = $"{logMiddle.WorkingProcedure}工序完成";
|
long op80id = 0;
|
if (logMiddle.WorkingProcedure.Equals("OP80"))
|
{
|
db_info.WorkPieceState = (int)WorkPieceState.FinishedProducts;
|
db_info.WorkPieceLastOfflineTime = DateTimeHelper.GetDateTime();
|
db_info.WorkPieceCurrentPosition = "OP80";
|
db_info.CompleteTime = DateTimeHelper.GetDateTime();
|
db_info.OP80NewCode = logMiddle.OP80NewCode;
|
|
//质检数据改为 获取文件后修改 【Editby shaocx,2024-06-15】
|
/*
|
info.QualityState = (int)((loginfo.QualityStateStr.Equals("OK") || loginfo.QualityStateStr.Equals("0K")) ? QualityState.OK : QualityState.NG);
|
loginfo.QualityState = info.QualityState;
|
info.QualityStateUpdateUser = loginfo.UpdatedUserName;
|
info.QualityStateUpdateTime = loginfo.UpdatedTime.Value.LocalDateTime;
|
info.QualityStateUpdateMode = QualityStateUpdateMode.Auto.ToString();
|
//*/
|
|
|
var qualityData = db.QualityDataInfo.Where(o => o.WorkPieceID == logMiddle.WorkPieceID).FirstOrDefault();
|
if (qualityData == null || qualityData.WorkPieceID.Length < 1 || qualityData.WorkingProcedure.Length < 1)
|
{//插入QualityDataInfo表
|
qualityData = EntityPropHelper.Mapper<QualityDataInfo, WorkPieceLog>(logMiddle);
|
db.QualityDataInfo.Add(WorkPieceInfoManager.GetAddQualityDataInfo(qualityData));
|
}
|
//修改QualityDataInfo表 //重复收到质量信息，会覆盖之前的
|
EntityPropHelper<WorkPieceLogMiddle, QualityDataInfo>.CopyProp(logMiddle, qualityData, WorkPieceInfoManager.GetQualityDataInfoUpdate(logMiddle, logMiddle.WorkingProcedure, logMiddle.MonitoringPoint));//指定修改字段
|
|
//质检数据改为 获取文件后修改 【Editby shaocx,2024-06-15】
|
/*
|
qualityData.QualityStateUpdateUser = info.UpdatedUserName;
|
qualityData.QualityReceiveTime = info.UpdatedTime.Value.LocalDateTime;
|
qualityData.QualityStateUpdateMode = info.QualityStateUpdateMode;
|
qualityData.OP80QualityState = loginfo.QualityState.HasValue ? loginfo.QualityState.Value.ToString() : "3";
|
qualityData.OP80QualityReceiveTime = DateTimeHelper.GetDateTime();
|
qualityData.OP80QualityFilePath = loginfo.OP80QualityFilePath;
|
op80id = qualityData.Id;
|
loginfo2.Remarks = (loginfo2.Remarks ?? "") + $"质量：{loginfo.QualityStateStr ?? "空"}";
|
if (!info.QualityState.Equals(((int)QualityState.OK).ToString()))
|
{
|
info.QualityErrorInfo = $"{loginfo.WorkingProcedure}工序质量采集数据不合格";
|
}
|
else
|
{
|
info.QualityErrorInfo = "";
|
}
|
//*/
|
|
loginfo2.Remarks = $"测量合格状态:{logMiddle.St3_Means_OK},称重状态:{logMiddle.St4_Weight_OK}";
|
}
|
else if (logMiddle.WorkingProcedure.Equals("OP30"))
|
{
|
|
db_info.QualityState = (int)((logMiddle.QualityStateStr.Equals("OK") || logMiddle.QualityStateStr.Equals("0K")) ? QualityStateEnum.OK : QualityStateEnum.NG);
|
logMiddle.QualityState = db_info.QualityState;
|
db_info.QualityStateUpdateUser = logMiddle.UpdatedUserName;
|
db_info.QualityStateUpdateTime = logMiddle.UpdatedTime.Value.LocalDateTime;
|
db_info.QualityStateUpdateMode = QualityStateUpdateMode.Auto.ToString();
|
|
var qualityData = db.QualityDataInfo.Where(o => o.WorkPieceID == logMiddle.WorkPieceID).FirstOrDefault();
|
if (qualityData == null || qualityData.WorkPieceID.Length < 1 || qualityData.WorkingProcedure.Length < 1)
|
{//插入QualityDataInfo表
|
qualityData = EntityPropHelper.Mapper<QualityDataInfo, WorkPieceLog>(logMiddle);
|
db.QualityDataInfo.Add(WorkPieceInfoManager.GetAddQualityDataInfo(qualityData));
|
}
|
qualityData.QualityStateUpdateUser = db_info.UpdatedUserName;
|
qualityData.QualityReceiveTime = db_info.UpdatedTime.Value.LocalDateTime;
|
qualityData.QualityStateUpdateMode = db_info.QualityStateUpdateMode;
|
qualityData.OP30QualityState = logMiddle.QualityState.HasValue ? logMiddle.QualityState.Value.ToString() : "3";
|
qualityData.OP30QualityReceiveTime = DateTimeHelper.GetDateTime();
|
loginfo2.Remarks = (loginfo2.Remarks ?? "") + $"质量：{logMiddle.QualityStateStr ?? "空"}";
|
if (!db_info.QualityState.Equals(((int)QualityStateEnum.OK).ToString()))
|
{
|
db_info.QualityErrorInfo = $"{logMiddle.WorkingProcedure}工序质量采集数据不合格";
|
}
|
else
|
{
|
db_info.QualityErrorInfo = "";
|
}
|
}
|
else
|
{
|
//这里修复OP10、OP40 因为PLC先推 SPC推出、再推 产品下线问题，导致 产品下线更新数据时，把SPC数据覆盖的问题 【Editby shaocx,2024-08-27】
|
var isAlow = SystemBussinessHelper.IsAllowUpdateWorkPieceStateToWip(db_info, db, logMiddle);
|
if (isAlow)
|
{
|
db_info.WorkPieceState = (int)WorkPieceState.WIP;
|
}
|
|
|
if (db_info.WorkingProcedurePlan.IndexOf(logMiddle.WorkingProcedure) + 4 <= db_info.WorkingProcedurePlan.Length)
|
{
|
db_info.WorkPieceCurrentPosition = db_info.WorkingProcedurePlan.Substring(db_info.WorkingProcedurePlan.IndexOf(logMiddle.WorkingProcedure), 8);
|
}
|
}
|
|
var pro = db.WorkPieceProcess.Where(o => o.WorkPieceID == logMiddle.WorkPieceID
|
&& o.WorkingProcedureCurrent == db_info.WorkingProcedureCurrent
|
&& o.OperationType == OperationType.生产.ToString()).OrderByDescending(o => o.StartTime).FirstOrDefault();
|
if (pro == null || pro.WorkPieceID.Length < 1)
|
{
|
WorkPieceProcess add_process = new WorkPieceProcess();
|
add_process = EntityPropHelper.Mapper<WorkPieceProcess, WorkPieceInfo>(db_info);
|
QualityStateHelper.ResetQualityNoOkForNewProcess(ref add_process);
|
add_process.Id = Yitter.IdGenerator.YitIdHelper.NextId();
|
add_process.StartTime = DateTimeHelper.GetDateTime().AddSeconds(-SystemBussinessHelper.MoNiTimeForWorkingProcedure(logMiddle.WorkingProcedure));
|
add_process.EndTime = DateTimeHelper.GetDateTime();
|
if (logMiddle.WorkingProcedure.Equals("OP80"))
|
{//OP80的质量数据是后来获取文件搞的
|
//质检数据，再考虑 另外两种状态 【Editby shaocx,2024-08-27】
|
QualityStateHelper.SetQualityStateForOP80(logMiddle, ref db_info, ref add_process);
|
}
|
else
|
{
|
//不再默认赋值为合格 【Editby shaocx,2024-08-16】
|
//process.QualityState = logMiddle.QualityState.HasValue ? logMiddle.QualityState.Value : (int)QualityState.OK;//默认合格，已处理
|
add_process.QualityState = WorkPieceInfoManager.GetQualityStateValue(logMiddle.QualityState);
|
}
|
add_process.CreatedUserName = logMiddle.MonitoringPoint;
|
add_process.DataCapturePointCname = logMiddle.DataCapturePointCname;
|
add_process.CreatedTime = DateTime.SpecifyKind(DateTime.Now, DateTimeKind.Local);
|
add_process.UpdatedUserName = logMiddle.MonitoringPoint;
|
add_process.UpdateDataCapturePointCname = logMiddle.DataCapturePointCname;
|
add_process.UpdatedTime = DateTime.SpecifyKind(DateTime.Now, DateTimeKind.Local);
|
add_process.OperationType = OperationType.生产.ToString();
|
add_process.Remarks = "";
|
add_process.MyRemarks = "工序完成时，如果找不到就新建";
|
if (logMiddle.WorkingProcedure.Equals("OP80"))
|
{
|
add_process.GetQcDataFlag = logMiddle.GetQcDataFlag;//赋值标记 [Editby shaocx,2024-06-15]
|
}
|
if (op80id > 0)
|
{
|
add_process.QualityDataInfoID = op80id;
|
}
|
db.WorkPieceProcess.Add(add_process);
|
}
|
else
|
{
|
if (logMiddle.WorkingProcedure.Equals("OP80"))
|
{//OP80的质量数据是后来获取文件搞的
|
//质检数据，再考虑 另外两种状态 【Editby shaocx,2024-08-27】
|
QualityStateHelper.SetQualityStateForOP80(logMiddle, ref db_info, ref pro);
|
}
|
if (op80id > 0)
|
{
|
pro.QualityDataInfoID = op80id;
|
}
|
pro.EndTime = DateTimeHelper.GetDateTime();
|
pro.UpdatedUserName = logMiddle.MonitoringPoint;
|
pro.UpdateDataCapturePointCname = logMiddle.DataCapturePointCname;
|
pro.UpdatedTime = DateTimeHelper.GetDateTime();
|
if (logMiddle.WorkingProcedure.Equals("OP80"))
|
{
|
if (pro.GetQcDataFlag != 0)
|
{
|
pro.GetQcDataFlag = logMiddle.GetQcDataFlag;//赋值标记 [Editby shaocx,2024-06-15]
|
}
|
}
|
}
|
|
|
if (isAddWorkPieceInfo)
|
{
|
db.WorkPieceInfo.Add(db_info);
|
}
|
db.WorkPieceInfoLog.Add(WorkPieceInfoManager.GetAddWorkPieceInfoLog(db_info));
|
}
|
else
|
{
|
loginfo2.Remarks = $"下线完成读取二维码{logMiddle.WorkPieceID ?? "空"}异常";
|
Log4NetHelper.WriteErrorLog(type, $" {logMiddle.WorkingProcedure}工序下线 读取工件码数据[{logMiddle.WorkPieceID ?? "空"}]时异常：");
|
|
}
|
}
|
catch (Exception e)
|
{
|
loginfo2.Remarks = $"读取二维码{logMiddle.WorkPieceID ?? "空"}更新数据异常{e.Message}";
|
}
|
db.WorkPieceLog.Add(WorkPieceInfoManager.GetAddWorkPieceLog(loginfo2));//插入工件采集日志表
|
db.SaveChanges();
|
}
|
}
|
}
|
}
|
