using iWare_SCADA_BusinessLogical.BLL;
using iWare_SCADA_BusinessLogical.Utils;
using iWare_SCADA_Model;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
namespace iWare_SCADA_BusinessLogical
{
///
/// 下料标记,确认工件OP05工序已完成
///
public class DataCaptureHandler_OP0504 : DataCaptureHandler
{
public static readonly DataCaptureHandler_OP0504 Instance = new DataCaptureHandler_OP0504();
public DataCaptureHandler_OP0504()
{
}
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)
{
}
public override void DataCaptureStart()
{
if (IsCaptureflag)
{
var plcService = PLCManger.GetSinglePLCService(_dataCaptureConfig);
if (plcService == null)
{
SystemValue.lbl_Alert_OP0504 = $"{RandomHelper.GenerateRandomCode(4)} 没有找到{_dataCaptureConfig.WorkingProcedure}的PLC设备";
return;
}
if (plcService != null && !plcService.IsConnected)
{
plcService.Close();
plcService.OpenService();
}
while (true)
{
try
{
if (plcService == null || !plcService.IsConnected)
{
SystemValue.lbl_Alert_OP0504 = $" {RandomHelper.GenerateRandomCode(4)} {_dataCaptureConfig.WorkingProcedure} PLC连接已断开,正在尝试打开!";
plcService.Close();
plcService.OpenService();
Thread.Sleep(100);
continue;
}
else
{
object value = plcService.ReadValuePoint(_dataCaptureConfig.DbNumber, _dataCaptureConfig.Offset, PLCManger.GetTypeForString(_dataCaptureConfig.DataCaptureColumnType));
if (SystemValue.value_OP0504.Equals("0") && value.ToString().Equals("1"))
{
string WorkPieceID = "";
foreach (var col in colConfig.Where(o => o.DataCapturePointCode == DataCapturePointCode))
{
switch (col.DataCaptureColumnTabelName)
{
case "WorkPieceID":
WorkPieceID = plcService.ReadValuePoint(col.DbNumber, col.Offset, PLCManger.GetTypeForString(col.DataCaptureColumnType)).ToString();
break;
default:
break;
}
}
if (WorkPieceID.Length != 22)
{
SystemValue.lbl_Alert_OP0504 = $"工件推出标记,确认工件号:【" + WorkPieceID + "】长度异常,长度不等于22位";
Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"工件推出标记,确认工件号:【" + WorkPieceID + "】长度异常,长度不等于22位");
}
else
{
// OP05工序完成
WorkPieceLog wplog = new WorkPieceLog();
wplog.Id = Yitter.IdGenerator.YitIdHelper.NextId();
wplog.WorkPieceID = WorkPieceID;
wplog.WorkingProcedure = WorkingProcedure;
wplog.EquipmentID = WorkingProcedure;
wplog.Remarks = WorkingProcedure;
wplog.MonitoringPoint = DataCapturePointCode;
wplog.CreatedTime = DateTimeHelper.GetDateTime();
wplog.CreatedUserName = DataCapturePointCode;
wplog.IsDeleted = false;
//更新WorkPieceInfo表以及插入WorkPieceLog表和WorkPieceInfoLog表
WorkPieceInfoManager.WorkingProcedureComplete(wplog, PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure));
}
}
SystemValue.value_OP0503 = value.ToString();
}
}
catch (Exception ex)
{
SystemValue.lbl_Alert_OP0504 = $"读取{WorkingProcedure}工序下料标记确认工件工序已完成监控,出现异常,请查看日志!";
Log4NetHelper.WriteErrorLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"读取{WorkingProcedure}工序下料标记确认工件工序已完成监控,数据时异常:", ex);
}
if (!_dataCaptureConfig.DataCaptureFrequency.HasValue || _dataCaptureConfig.DataCaptureFrequency < 10)
{
Thread.Sleep(5000);
}
else
{
Thread.Sleep(_dataCaptureConfig.DataCaptureFrequency.Value);
}
}
}
else
{
SystemValue.lbl_Alert_OP0504 = $"读取{WorkingProcedure}工序下料标记确认工件工序已完成监控,请确认配置信息!";
Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"读取{WorkingProcedure}工序下料标记确认工件工序已完成监控,请确认是否配置异常");
}
}
}
}