using Bro.Common.Helper;
|
using Bro.M135.Common;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace Bro.M141.Process
|
{
|
public partial class M141Process
|
{
|
List<DefectNGRecord> DefectNGRecordList = new List<DefectNGRecord>();
|
|
|
public void InitialContinuousNGAlarm()
|
{
|
DefectNGRecordList = M141Config.ContinuousNGAlarmColletion.Where(u => u.IsEnabled).Select(u =>
|
{
|
DefectNGRecord record = new DefectNGRecord();
|
record.DefectName = u.DefectType;
|
record.AlarmSetting = u;
|
return record;
|
}).ToList();
|
|
|
}
|
|
|
|
|
|
public async void CheckContinuousNGAlarmAsync(ProductModel product)
|
{
|
await Task.Run(() =>
|
{
|
if (!M141Config.IsEnableContinuousNGAlarm)
|
{
|
LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"连续NG报警总开关已关闭");
|
return;
|
}
|
|
if (DefectNGRecordList.Count == 0)
|
return;
|
|
//var allDefects = product.DETAILS.SelectMany(u => u.DetectResults).ToList().GetDefectDescList();
|
|
List<string> allDefects = new List<string>();
|
foreach (var v in product.Details)
|
{
|
allDefects.AddRange(v.ResultList.GetDefectDescList());
|
allDefects.AddRange(v.DefectList);
|
}
|
allDefects = allDefects.Distinct().ToList();
|
|
string allMsg = "";
|
bool isAlarmRaised = false;
|
int alarmType = 0;
|
string ngItem = "";
|
|
DefectNGRecordList.ForEach(d =>
|
{
|
string alarmMsg = "";
|
|
if (d.CheckIsAlarmRaised(!allDefects.Contains(d.DefectName), out alarmMsg, out int alarmTypeTemp))
|
{
|
allMsg += $"{alarmMsg}\r\n";
|
isAlarmRaised = true;
|
ngItem = d.DefectName;
|
alarmType = alarmTypeTemp;
|
}
|
|
});
|
|
if (isAlarmRaised)
|
{
|
var state = Plc1.Read(3027, 1, out _)[0];
|
if (state == 0)
|
{
|
LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"连续NG监控报警，{allMsg}");
|
if (!Plc1.WriteSingleAddress(3006, 1, out _))
|
{
|
LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"连续NG监控通知PLC报警失败");
|
}
|
else
|
{
|
DefectNGRecordList.ForEach(d =>
|
{
|
d.ResetAlarm();
|
});
|
}
|
}
|
else
|
{
|
|
DefectNGRecordList.ForEach(d =>
|
{
|
d.ResetAlarm();
|
});
|
|
}
|
|
|
}
|
});
|
}
|
}
|
|
public class DefectNGRecord
|
{
|
public string DefectName { get; set; }
|
public List<DateTime> NGRecords { get; set; } = new List<DateTime>();
|
public int ContinuousNGNum { get; set; } = 0;
|
|
public ContinuousNGAlarm AlarmSetting { get; set; }
|
|
private object _lockObj = new object();
|
|
public bool IsAlarmRaised = false;
|
|
bool _isContinuousAlarm = false;
|
bool _timeAlarm = false;
|
|
public bool CheckIsAlarmRaised(bool isOK, out string alarmMsg, out int alarmType)
|
{
|
alarmType = 0;
|
alarmMsg = "";
|
bool isAlarmRasied = false;
|
|
if (IsAlarmRaised)
|
return false;
|
|
lock (_lockObj)
|
{
|
if (IsAlarmRaised)
|
return false;
|
|
if (isOK)
|
{
|
ContinuousNGNum = 0;
|
}
|
else
|
{
|
if (AlarmSetting.ContinuousNumThreshold > 0)
|
{
|
ContinuousNGNum++;
|
}
|
|
if (AlarmSetting.TimePeriodNumThresold > 0)
|
{
|
NGRecords.Add(DateTime.Now);
|
}
|
}
|
|
if (NGRecords.Count >= AlarmSetting.TimePeriodNumThresold && NGRecords.Count > 0)
|
{
|
NGRecords = NGRecords.Skip(NGRecords.Count - AlarmSetting.TimePeriodNumThresold).OrderBy(u => u).ToList();
|
|
int timeInMinute = (int)Math.Ceiling((NGRecords[NGRecords.Count - 1] - NGRecords[0]).TotalMinutes);
|
if (timeInMinute <= AlarmSetting.TimePeriod)
|
{
|
isAlarmRasied = true;
|
alarmMsg += $"{DefectName}{timeInMinute}分钟内NG{NGRecords.Count}个 ";
|
alarmType = AlarmSetting.TimePeriodAlarmType;
|
|
_timeAlarm = true;
|
}
|
}
|
|
if (ContinuousNGNum >= AlarmSetting.ContinuousNumThreshold)
|
{
|
isAlarmRasied = true;
|
alarmMsg += $"{DefectName}连续NG{ContinuousNGNum}个 ";
|
alarmType = AlarmSetting.ContinuousAlarmType;
|
|
_isContinuousAlarm = true;
|
}
|
|
IsAlarmRaised = isAlarmRasied;
|
|
return isAlarmRasied;
|
}
|
}
|
|
public void ResetAlarm()
|
{
|
string msg = "";
|
lock (_lockObj)
|
{
|
IsAlarmRaised = false;
|
|
if (_isContinuousAlarm)
|
{
|
ContinuousNGNum = 0;
|
_isContinuousAlarm = false;
|
|
msg += "连续NG报警 ";
|
}
|
|
if (_timeAlarm)
|
{
|
NGRecords.Clear();
|
_timeAlarm = false;
|
|
msg += "时段内NG报警 ";
|
}
|
}
|
|
CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"{DefectName}{msg}已重置");
|
}
|
}
|
}
|
