You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
160 lines
6.2 KiB
160 lines
6.2 KiB
using Aborlen.Model;
|
|
using Aborlen.Opc.PlcBase;
|
|
using FrameWork.Log;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Reflection;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace Aborlen.PlcCommunicationInit
|
|
{
|
|
public partial class WorkStation: StationBase
|
|
{
|
|
|
|
|
|
|
|
private void OpcTag_EventTagChanged(string tagId, int tagMarkCode, object tagValue, DateTime timeTrigger)
|
|
{
|
|
try
|
|
{
|
|
if (!Convert.ToBoolean(tagValue))
|
|
{
|
|
return;
|
|
}
|
|
|
|
|
|
//判断数据库采集功能配置表（DataCollectConfig） 是否包含当前信号
|
|
List<DataCollectConfig> configList = CollectsConfig.Where(p => p.TagMarkCode == tagMarkCode && p.TagConfigCode == ThisStationInfo.TagConfigCode).ToList();
|
|
long InsertIndex = 0;
|
|
foreach (var configItem in configList)
|
|
{
|
|
|
|
//保存质量数据
|
|
//判断是否保存索引
|
|
if (configItem.CollectIndexMarkCode > 0)
|
|
{
|
|
//存在索引 这里统计索引信息
|
|
string indexTableName = configItem.CollectIndexTableName;
|
|
|
|
//索引标志TagMarkId
|
|
int indexTagMarkCode = configItem.CollectIndexMarkCode;
|
|
|
|
//获取索引需要保存的字段
|
|
|
|
List<DataCollectConfigDetail> stationConfigDetails = StationConfigDetails.Where(p => p.TagConfigCode == configItem.TagConfigCode).ToList();
|
|
|
|
//通过反射创建表实例 Aborlen.Model.QualityDataInfoIndex
|
|
Assembly assembly = Assembly.Load("Aborlen.Model");
|
|
Type type = assembly.GetType("Aborlen.Model." + indexTableName);
|
|
|
|
var instace = Activator.CreateInstance(type);
|
|
|
|
foreach (var detailItem in stationConfigDetails)
|
|
{
|
|
//读取对应点数据
|
|
|
|
if (type.GetProperty(detailItem.TargetColName).PropertyType == typeof(string))
|
|
{
|
|
type.GetProperty(detailItem.TargetColName).SetValue(instace, Read(detailItem.CollectIndexMarkCode).ToString());
|
|
}
|
|
else
|
|
{
|
|
type.GetProperty(detailItem.TargetColName).SetValue(instace, Convert.ToInt32(Read(detailItem.CollectIndexMarkCode)));
|
|
}
|
|
}
|
|
type.GetProperty("StationId").SetValue(instace, ThisStationInfo.StationId);
|
|
|
|
type.GetProperty("StationCode").SetValue(instace, ThisStationInfo.StationCode);
|
|
|
|
type.GetProperty("StationName").SetValue(instace, ThisStationInfo.StationName);
|
|
|
|
InsertIndex = EntityFrameWork.DbHelperMapping[indexTableName + "_Insert"].Invoke(instace);
|
|
|
|
}
|
|
|
|
//保存明细数据
|
|
|
|
//获取表名称
|
|
|
|
string DetailTableName = configItem.CollectTableName;
|
|
|
|
|
|
|
|
//遍历当前工位所有质量数据信号点
|
|
foreach (var qualityTagDetails in StationQualityTagDetails.GroupBy(p => p.GroupSerialNumber))
|
|
{
|
|
foreach (var qualityTagItem in qualityTagDetails)
|
|
{
|
|
|
|
int itemQualityMark = 0;
|
|
if (qualityTagItem.SerialType == 1 && qualityTagItem.IsValidate == 0)
|
|
{
|
|
|
|
itemQualityMark = Convert.ToInt32(Read(qualityTagItem.TagId, timeTrigger));
|
|
}
|
|
else
|
|
{
|
|
QualityDataInfo qualityDataInfo = new QualityDataInfo();
|
|
qualityDataInfo.TagId = qualityTagItem.TagId;
|
|
qualityDataInfo.ParentId = InsertIndex;
|
|
|
|
qualityDataInfo.MeasurePosition = qualityTagItem.MeasurePosition;
|
|
qualityDataInfo.MeasureItem = qualityTagItem.MeasureItem;
|
|
qualityDataInfo.TagValue = Read(qualityTagItem.TagId, timeTrigger).ToString();
|
|
|
|
qualityDataInfo.MeasureUnit = qualityTagItem.MeasureUnit;
|
|
|
|
if (qualityTagItem.IsValidate == 1)
|
|
{
|
|
qualityDataInfo.UpperLimit = qualityTagItem.UpperLimit;
|
|
qualityDataInfo.LowerLimit = qualityTagItem.LowerLimit;
|
|
if (Convert.ToDouble(qualityDataInfo.TagValue) > Convert.ToDouble(qualityTagItem.LowerLimit) && Convert.ToDouble(qualityDataInfo.TagValue) < Convert.ToDouble(qualityTagItem.UpperLimit))
|
|
{
|
|
qualityDataInfo.QualifiedMark = 1;
|
|
}
|
|
else
|
|
{
|
|
qualityDataInfo.QualifiedMark = 2;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
qualityDataInfo.QualifiedMark = itemQualityMark;
|
|
}
|
|
|
|
qualityDataInfo.ItemSerialNumber = qualityTagItem.ItemSerialNumber;
|
|
qualityDataInfo.GroupSerialNumber = qualityTagItem.GroupSerialNumber;
|
|
qualityDataInfo.CreateTime = DateTime.Now;
|
|
|
|
QualityDataInfo.Insert(qualityDataInfo);
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
}
|
|
catch(Exception ex)
|
|
{
|
|
LogHelper.WriteLog(LogHelper.GetMethodInfo(), ex);
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
}
|