using iWare_SCADA_BusinessLogical.BLL;
|
using iWare_SCADA_BusinessLogical.Utils;
|
using iWare_SCADA_Model;
|
using iWare_SCADA_Model.MiddleModel;
|
using log4net;
|
using System;
|
using System.Collections.Generic;
|
using System.Data.Entity.Core.Common.CommandTrees;
|
using System.Data.Entity.Validation;
|
using System.Data.SqlTypes;
|
using System.Diagnostics;
|
using System.IO;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using System.Web.UI.WebControls;
|
using System.Windows.Forms;
|
|
namespace iWare_SCADA_BusinessLogical
|
{
|
/// <summary>
|
/// OP80质量数据采集
|
/// </summary>
|
public class OP80QualityDataHandler : DataCaptureHandler
|
{
|
public static readonly OP80QualityDataHandler Instance = new OP80QualityDataHandler();
|
public static readonly string path = ConfigHelper.GetConfigString("OP80QualityData");//OP80的地址
|
public static readonly string query_WorkingProcedureCurrent = "OP80";
|
public static readonly string _DataCapturePointCode = "OP8002";
|
public static readonly LogType logType = LogType.PLCOP80_QC;
|
|
public OP80QualityDataHandler()
|
{
|
}
|
|
public override string WorkingProcedure
|
{
|
get { return _dataCaptureConfig.WorkingProcedure; }
|
}
|
|
public override string DataCapturePointCode
|
{
|
get { return _dataCaptureConfig.DataCapturePointCode; }
|
}
|
public override string DataCapturePointCname
|
{
|
get { return _dataCaptureConfig.DataCapturePointCname; }
|
}
|
|
|
public override void RefreshDataList(List<DataCaptureConfig> dataCaptureConfig)
|
{
|
}
|
|
public override void DataCaptureStart()
|
{
|
while (true)
|
{
|
try
|
{
|
Do();
|
|
Thread.Sleep(1000 * 10);
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(logType, $"OP80质量数据采集异常：", ex);
|
}
|
finally
|
{
|
}
|
}
|
}
|
|
private void Do()
|
{
|
using (DbModel db = new DbModel())
|
{
|
try
|
{
|
ThreadStatusMonitorMiddle threadStatusMonitor = new ThreadStatusMonitorMiddle();
|
threadStatusMonitor.ErrorMsg = "";
|
threadStatusMonitor.Threadcode = logType.ToString();
|
threadStatusMonitor.Threadcname = "OP80质量数据采集";
|
threadStatusMonitor.Threadendtime = DateTime.Now;
|
threadStatusMonitor.Threadstatue = 0;
|
threadStatusMonitor.ThreadId = Thread.CurrentThread.ManagedThreadId.ToString();
|
threadStatusMonitor.Threadlastmodifytime = DateTime.Now;
|
|
var processList = db.WorkPieceProcess.Where(o => o.WorkingProcedureCurrent == query_WorkingProcedureCurrent && o.GetQcDataFlag == 0
|
).OrderBy(x => x.CreatedTime).ToList();
|
foreach (var item in processList)
|
{
|
var qualityData = db.QualityDataInfo.Where(o => o.WorkPieceID == item.WorkPieceID).FirstOrDefault();
|
if (qualityData == null)
|
{
|
Log4NetHelper.WriteErrorLog(logType, $"OP80质量数据采集异常,根据工件号{item.WorkPieceID}没有找到质量数据");
|
continue;
|
}
|
WorkPieceInfo info = db.WorkPieceInfo.Where(o => o.WorkPieceID == item.WorkPieceID).FirstOrDefault();
|
if (info == null)
|
{
|
Log4NetHelper.WriteErrorLog(logType, $"OP80质量数据采集异常,根据工件号{item.WorkPieceID}没有找到工件数据");
|
continue;
|
}
|
|
Do_One(db, info, item, qualityData, WorkingProcedure);
|
|
Thread.Sleep(1000);
|
}
|
|
WorkPieceInfoManager.ThreadMonitor(threadStatusMonitor);
|
}
|
catch (Exception e)
|
{
|
Log4NetHelper.WriteErrorLog(logType, $" OP80质量数据采集异常：{e.Message} {e.StackTrace}");
|
}
|
}
|
}
|
|
private void Do_One(DbModel db, WorkPieceInfo info, WorkPieceProcess pieceProcess, QualityDataInfo qualityData, string WorkingProcedure)
|
{
|
try
|
{
|
if (WorkingProcedure.Equals("OP80"))
|
{
|
var time = DateTimeHelper.GetDateTime();
|
|
//OP80 需要扫描文件读取质量信息
|
//扫描修改时间在上次扫描时间之前30秒到当前时间的之间的文件
|
List<FileInfo> files = new List<FileInfo>();
|
var newFiles = FileHelper.DetectNewFilesCSV(path, 300, time.AddDays(-7), time.AddDays(1));
|
foreach (var file in newFiles)
|
{
|
files.Add((FileInfo)file);
|
}
|
//files = files.OrderByDescending(o => o.LastWriteTime).ToList();
|
files = files.OrderBy(o => o.LastWriteTime).ToList();//时间升序
|
Log4NetHelper.WriteErrorLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"OP80下线完成读取到文件{files.Count()}个工件{pieceProcess.WorkPieceID} ");
|
|
bool isGetQcSuccess = false;
|
|
foreach (var file in files)
|
{//取倒序匹配的文件名为工件号的文件
|
if (file.Name.Contains(pieceProcess.WorkPieceID))
|
{
|
Log4NetHelper.WriteErrorLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"OP80下线完成读取到文件{file.Name}，是指定的工件{pieceProcess.WorkPieceID}");
|
|
WorkPieceLogMiddle wplog = new WorkPieceLogMiddle();
|
wplog.WorkPieceID = pieceProcess.WorkPieceID;
|
wplog.WorkingProcedure = _DataCapturePointCode;
|
wplog.Id = Yitter.IdGenerator.YitIdHelper.NextId();
|
wplog.EquipmentID = _dataCaptureConfig.EquipmentID; ;
|
wplog.Remarks = wplog.WorkingProcedure;
|
wplog.MonitoringPoint = _DataCapturePointCode;
|
wplog.CreatedTime = DateTimeHelper.GetDateTime();
|
wplog.CreatedUserName = _DataCapturePointCode;
|
wplog.UpdatedTime = DateTimeHelper.GetDateTime();
|
wplog.UpdatedUserName = Environment.MachineName + "自动" + Thread.CurrentThread.ManagedThreadId.ToString();
|
wplog.IsDeleted = false;
|
|
WorkPieceLog loginfo2 = new WorkPieceLog();
|
loginfo2 = EntityPropHelper.Mapper<WorkPieceLog, WorkPieceLogMiddle>(wplog);
|
|
var datatable = CSVHelper.ReadCSVList(file.FullName);
|
List<string> rowFirst = new List<string>();
|
List<string> rowSecond = new List<string>();
|
if (datatable.Count == 2)
|
{
|
rowFirst = datatable[0].Split(',').ToList();
|
rowSecond = datatable[1].Split(',').ToList();
|
if (rowSecond.Count < 11)
|
{
|
continue;
|
}
|
//日期和时间 批号/标识号 嵌套号/主轴号 操作符 文本 测量机 过程参数 测量系统 过程参数值 序列号 零件识别号 1
|
OP80Info oP80Info = new OP80Info();
|
oP80Info.日期和时间 = rowSecond[0];
|
oP80Info.批号 = rowSecond[1];
|
oP80Info.嵌套号 = rowSecond[2];
|
oP80Info.操作符 = rowSecond[3];
|
oP80Info.文本 = rowSecond[4];
|
oP80Info.测量机 = rowSecond[5];
|
oP80Info.过程参数 = rowSecond[6];
|
oP80Info.测量系统 = rowSecond[7];
|
oP80Info.过程参数值 = rowSecond[8];
|
oP80Info.序列号 = rowSecond[9];
|
oP80Info.零件识别号 = rowSecond[10];
|
for (int i = 1; i <= (rowSecond.Count - 11) / 10; i++)
|
{
|
if (rowSecond.Count < (11 + i * 10))
|
{
|
break;
|
}
|
//名称 相对值 相对值单位 绝对值 绝对值单位 名义值 上限 下限 状态/等级 分隔符
|
OP80ItemInfo item = new OP80ItemInfo();
|
item.分隔符 = rowSecond[1 + i * 10];//例如：* 表头：状态
|
item.名称 = rowSecond[2 + i * 10];//例如：Weight Big End 表头：*
|
item.相对值 = rowSecond[3 + i * 10];//例如：-2.8 表头：简述
|
item.相对值单位 = rowSecond[4 + i * 10];//例如：gr 表头：Weight Big End
|
item.绝对值 = rowSecond[5 + i * 10];//例如：371.66 表头：测量单位
|
item.绝对值单位 = rowSecond[6 + i * 10];//例如：gr 表头：绝对值
|
item.名义值 = rowSecond[7 + i * 10];//例如：374.5 表头：绝对值测量单位（UoM）
|
item.上限 = rowSecond[8 + i * 10];//例如：10.5 表头：名义值
|
item.下限 = rowSecond[9 + i * 10];//例如：-10.5 表头：USL值
|
item.状态 = rowSecond[10 + i * 10];//例如：3 表头：LSL值
|
oP80Info.OP80ItemInfolist.Add(item);
|
if (item.名称.Equals("Weight Class") || item.名称.Equals("Weight Small End")
|
|| item.名称.Equals("Weight Big End") || item.名称.Equals("Dime Small_End Class")
|
|| item.名称.Equals("Dime Big_End Class"))
|
{
|
}
|
else
|
{
|
if (!string.IsNullOrEmpty(item.状态))
|
{
|
oP80Info.OP80ItemStatusInfolist.Add(item);
|
}
|
}
|
}
|
if (oP80Info.OP80ItemStatusInfolist.Count > 0)
|
{
|
if (oP80Info.OP80ItemStatusInfolist.Any(o => !o.状态.Equals("OK")))
|
{
|
wplog.QualityStateStr = "NG";
|
}
|
else
|
{
|
wplog.QualityStateStr = "OK";
|
}
|
}
|
else
|
{
|
wplog.QualityStateStr = "OK";
|
}
|
|
|
wplog.OP80QualityFilePath = file.FullName;
|
wplog.OP80NewCode = oP80Info.批号?.Replace("#", "");
|
//大头重量
|
wplog.QualityOP80To1 = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Weight Big End")).FirstOrDefault()?.绝对值;
|
//小头重量
|
wplog.QualityOP80To2 = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Weight Small End")).FirstOrDefault()?.绝对值;
|
//总重
|
wplog.QualityOP80To3 = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Total Weight")).FirstOrDefault()?.绝对值;
|
//弯曲
|
wplog.QualityOP80To4 = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Bend to A")).FirstOrDefault()?.绝对值;
|
//扭度
|
wplog.QualityOP80To5 = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Twist to A")).FirstOrDefault()?.绝对值;
|
//大头垂直度
|
wplog.QualityOP80To6 = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Big_End_C_Squareness")).FirstOrDefault()?.绝对值;
|
//小头垂直度
|
wplog.QualityOP80To10 = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Sma_End_C_Squareness")).FirstOrDefault()?.绝对值;
|
//大头孔分组级别
|
wplog.QualityOP80To7 = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Dime Big_End Class")).FirstOrDefault()?.状态;
|
//小头孔分组级别
|
wplog.QualityOP80To8 = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Dime Small_End Class")).FirstOrDefault()?.状态;
|
//重量组别
|
wplog.QualityOP80To9 = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Weight Class")).FirstOrDefault()?.状态;
|
//wplog.Remarks = (wplog.Remarks ?? "") + $"OP80下线完成读取文件{file.FullName},数据【{wplog.OP80NewCode??"空"}】【{wplog.QualityOP80To1 ?? "空"}】【{wplog.QualityOP80To2 ?? "空"}】【{wplog.QualityOP80To3 ?? "空"}】【{wplog.QualityOP80To4 ?? "空"}】【{wplog.QualityOP80To5 ?? "空"}】";
|
|
//新增OP80的一些质量数据 【Editby shaocx,2024-06-13】
|
wplog.QualityOP80_Houdu = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Big_End_Thickness")).FirstOrDefault()?.绝对值;
|
wplog.QualityOP80_ZXJ = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Distance of Two Head")).FirstOrDefault()?.绝对值;
|
wplog.QualityOP80_DTKYZD = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Big_End_Cylindricity")).FirstOrDefault()?.绝对值;
|
wplog.QualityOP80_XTSMYD = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Small_End_Top_Roundn")).FirstOrDefault()?.绝对值;
|
wplog.QualityOP80_XTXMYD = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Small_End_Bot_Roundn")).FirstOrDefault()?.绝对值;
|
|
|
wplog.QualityOP80_D_S_X = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Big_End_Top_X_Dia.")).FirstOrDefault()?.绝对值;
|
wplog.QualityOP80_D_S_Y = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Big_End_Top_Y_Dia.")).FirstOrDefault()?.绝对值;
|
wplog.QualityOP80_D_X_X = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Big_End_Bot_X_Dia.")).FirstOrDefault()?.绝对值;
|
wplog.QualityOP80_D_X_Y = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Big_End_Bot_Y_Dia.")).FirstOrDefault()?.绝对值;
|
//计算大头孔直径,大头孔直径=（大头上面X方向直径+大头上面Y方向直径+大头下面X方向直径+大头下面Y方向直径）/4
|
List<decimal> valueList = new List<decimal>() {
|
SystemHelper.GetDecimal(wplog.QualityOP80_D_S_X),
|
SystemHelper.GetDecimal(wplog.QualityOP80_D_S_Y),
|
SystemHelper.GetDecimal(wplog.QualityOP80_D_X_X),
|
SystemHelper.GetDecimal(wplog.QualityOP80_D_X_Y),
|
};
|
wplog.QualityOP80_D_TKZJ = SystemHelper.CalcDecimalAvg(valueList, 3);
|
|
|
wplog.QualityOP80_X_S_X = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Small_End_Top_X_Dia.")).FirstOrDefault()?.绝对值;
|
wplog.QualityOP80_X_S_Y = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Small_End_Top_Y_Dia.")).FirstOrDefault()?.绝对值;
|
wplog.QualityOP80_X_X_X = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Small_End_Bot_X_Dia.")).FirstOrDefault()?.绝对值;
|
wplog.QualityOP80_X_X_Y = oP80Info.OP80ItemInfolist.Where(o => o.名称.Equals("Small_End_Bot_Y_Dia.")).FirstOrDefault()?.绝对值;
|
//计算小头孔直径,小头孔直径=（小头上面X方向直径+小头上面Y方向直径+小头下面X方向直径+小头下面Y方向直径）/4
|
valueList = new List<decimal>();
|
valueList = new List<decimal>() {
|
SystemHelper.GetDecimal(wplog.QualityOP80_X_S_X),
|
SystemHelper.GetDecimal(wplog.QualityOP80_X_S_Y),
|
SystemHelper.GetDecimal(wplog.QualityOP80_X_X_X),
|
SystemHelper.GetDecimal(wplog.QualityOP80_X_X_Y),
|
};
|
wplog.QualityOP80_X_TKZJ = SystemHelper.CalcDecimalAvg(valueList, 3);
|
|
}
|
else
|
{
|
wplog.Remarks = (wplog.Remarks ?? "") + $"OP80下线完成读取文件{file.FullName}异常，行数不是2行";
|
}
|
|
|
//更新WorkPieceInfo表以及插入WorkPieceLog表和WorkPieceInfoLog表
|
info.OP80NewCode = wplog.OP80NewCode;//更新成品吗
|
|
info.QualityState = (int)((wplog.QualityStateStr.Equals("OK") || wplog.QualityStateStr.Equals("0K")) ? QualityState.OK : QualityState.NG);
|
wplog.QualityState = info.QualityState;
|
info.QualityStateUpdateUser = wplog.UpdatedUserName;
|
info.QualityStateUpdateTime = wplog.UpdatedTime.Value.LocalDateTime;
|
info.QualityStateUpdateMode = QualityStateUpdateMode.Auto.ToString();
|
|
//var qualityData = db.QualityDataInfo.Where(o => o.WorkPieceID == wplog.WorkPieceID).FirstOrDefault();
|
//if (qualityData == null || qualityData.WorkPieceID.Length < 1 || qualityData.WorkingProcedure.Length < 1)
|
//{//插入QualityDataInfo表
|
// qualityData = EntityPropHelper.Mapper<QualityDataInfo, WorkPieceLog>(wplog);
|
// db.QualityDataInfo.Add(GetAddQualityDataInfo(qualityData));
|
//}
|
//修改QualityDataInfo表 //重复收到质量信息，会覆盖之前的
|
EntityPropHelper<WorkPieceLogMiddle, QualityDataInfo>.CopyProp(wplog, qualityData, WorkPieceInfoManager.GetQualityDataInfoUpdate(wplog.WorkingProcedure, wplog.MonitoringPoint));//指定修改字段
|
|
qualityData.QualityStateUpdateUser = info.UpdatedUserName;
|
qualityData.QualityReceiveTime = info.UpdatedTime.Value.LocalDateTime;
|
qualityData.QualityStateUpdateMode = info.QualityStateUpdateMode;
|
qualityData.OP80QualityState = wplog.QualityState.HasValue ? wplog.QualityState.Value.ToString() : "3";
|
qualityData.OP80QualityReceiveTime = DateTimeHelper.GetDateTime();
|
qualityData.OP80QualityFilePath = wplog.OP80QualityFilePath;
|
long op80id = qualityData.Id;
|
if (op80id > 0)
|
{
|
pieceProcess.QualityDataInfoID = op80id;
|
}
|
loginfo2.Remarks = (loginfo2.Remarks ?? "") + $"质量：{wplog.QualityStateStr ?? "空"}";
|
if (!info.QualityState.Equals(((int)QualityState.OK).ToString()))
|
{
|
info.QualityErrorInfo = $"{wplog.WorkingProcedure}工序质量采集数据不合格";
|
}
|
else
|
{
|
info.QualityErrorInfo = "";
|
}
|
|
pieceProcess.GetQcDataCount = (pieceProcess.GetQcDataCount ?? 0) + 1;
|
pieceProcess.GetQcDataFlag_Remark = "找到文件";
|
pieceProcess.GetQcDataFlag = 1;
|
|
db.WorkPieceLog.Add(WorkPieceInfoManager.GetAddWorkPieceLog(loginfo2));//插入工件采集日志表
|
|
db.QualityDataInfoLog.Add(WorkPieceInfoManager.GetAddQualityDataInfoLog(qualityData));//插入质量日志
|
|
//转移文件
|
var toPath = file.FullName.Replace("CA4GC20TD", "CA4GC20TD_COPY");
|
File.Move(file.FullName, toPath);//移动
|
|
db.SaveChanges();
|
|
isGetQcSuccess = true;
|
|
break;
|
}
|
else
|
{
|
|
}
|
}
|
if (isGetQcSuccess == false)
|
{
|
pieceProcess.GetQcDataCount = (pieceProcess.GetQcDataCount ?? 0) + 1;
|
pieceProcess.GetQcDataFlag_Remark = "没有找到文件";
|
if (pieceProcess.GetQcDataCount >= 10)
|
{
|
pieceProcess.GetQcDataFlag = 2;
|
}
|
|
db.SaveChanges();
|
|
Log4NetHelper.WriteErrorLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"OP80下线完成读取文件没有找到指定工件{info.WorkPieceID}的文件");
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"指定工件{info.WorkPieceID},OP80下线完成读取文件数据时异常,避免工序完成异常：", ex);
|
}
|
}
|
|
}
|
}
|
