248 lines
10 KiB
C#
248 lines
10 KiB
C#
using DataLinkMesWork1;
|
|
using MesServerFunctions;
|
|
using MesServerWork;
|
|
using MisDataFunDll;
|
|
using Newtonsoft.Json;
|
|
using System;
|
|
using System.Collections;
|
|
using System.Collections.Concurrent;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Data.SqlClient;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using System.Xml.Linq;
|
|
|
|
namespace MisDataSaveDate
|
|
{
|
|
public partial class FuntionMesRead
|
|
{
|
|
|
|
#region 2023.05.14,新增报警
|
|
|
|
public static Hashtable Base_TagIdList = new Hashtable();
|
|
public static Hashtable Base_ObjList = new Hashtable();
|
|
|
|
|
|
public static void GetAlarmInit()
|
|
{
|
|
Base_TagIdList.Clear();
|
|
GetTagIdList("", out DataTable dt);
|
|
|
|
for (int i = 0; i < dt.Rows.Count; i++)
|
|
{
|
|
string tagid = dt.Rows[i]["TagID"].ToString();
|
|
|
|
if (tagid[0].ToString() == "9")
|
|
{
|
|
var opName = dt.Rows[i]["工位号"].ToString();
|
|
var ItemName = dt.Rows[i]["测量项目"].ToString(); // 报警内容
|
|
var ShaftID = dt.Rows[i]["测量位置"].ToString(); // 报警类型
|
|
|
|
string SendMessage = "MES|PlcAlarm|" + opName + "|" + tagid + "&@TagValue&" + ItemName + "&" + ShaftID;
|
|
Base_TagIdList.Add(tagid, SendMessage);
|
|
|
|
//在存一份报警对象到键值对中
|
|
Base_ObjList.Add(tagid, dt.Rows[i]);
|
|
}
|
|
}
|
|
}
|
|
|
|
//public static void Send_AlarmMsg(string tagid, string tagVvalue)
|
|
//{
|
|
// var val = Base_TagIdList[tagid];
|
|
// if (val != null)
|
|
// {
|
|
// //var msg = Base_TagIdList[tagid].ToString();
|
|
// //var sendmsg = msg.Replace("@TagValue", tagVvalue);
|
|
// //SendMessageFun.AsyncSendMessage(sendmsg);
|
|
// string alarmTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
|
// var msg = Base_TagIdList[tagid].ToString();
|
|
// var sendmsg = msg.Replace("@TagValue", tagVvalue) + "&" + alarmTime;
|
|
// SendMessageFun.AsyncSendMessage(sendmsg);
|
|
// // 去存一份记录到数据库
|
|
// DataRow errObj = (DataRow)Base_ObjList[tagid];
|
|
// MisDataFun.Alarm_Insert2(Convert.ToInt32(errObj["TagID"]), errObj["工位号"].ToString(), errObj["测量项目"].ToString(), Convert.ToInt32(tagVvalue), errObj["测量位置"].ToString());
|
|
// }
|
|
//}
|
|
public static DataRow Send_AlarmMsg(string tagid, string tagVvalue)
|
|
{
|
|
var val = Base_TagIdList[tagid];
|
|
DataRow errObj = null;
|
|
if (val != null)
|
|
{
|
|
//var msg = Base_TagIdList[tagid].ToString();
|
|
//var sendmsg = msg.Replace("@TagValue", tagVvalue);
|
|
//SendMessageFun.AsyncSendMessage(sendmsg);
|
|
|
|
var msg = Base_TagIdList[tagid].ToString();
|
|
var sendmsg = msg.Replace("@TagValue", tagVvalue);
|
|
SendMessageFun.AsyncSendMessage(sendmsg);
|
|
// 去存一份记录到数据库
|
|
errObj = (DataRow)Base_ObjList[tagid];
|
|
|
|
MisDataFun.Alarm_Insert2(Convert.ToInt32(errObj["TagID"]), errObj["工位号"].ToString(), errObj["测量项目"].ToString(), Convert.ToInt32(tagVvalue), errObj["测量位置"].ToString());
|
|
}
|
|
return errObj;
|
|
}
|
|
|
|
|
|
|
|
static public void GetTagIdList(string opName, out DataTable dt)
|
|
{
|
|
string procedureName;
|
|
procedureName = "MES_基本变量_原始数据_根据工位号查询";
|
|
SqlParameter[] thisParms = new SqlParameter[1];
|
|
thisParms[0] = new System.Data.SqlClient.SqlParameter("@工位号", opName);
|
|
DataAccess.ExecuteStoredProcedure(procedureName, ref thisParms, out dt);
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
#endregion
|
|
|
|
public static void Alarm_Insert_Init(string Opname)
|
|
{
|
|
DataTable dt;
|
|
MisDataFun.Alarm_Moby_Search(out dt);
|
|
if (dt == null) return;
|
|
for (int i = 0; i < dt.Rows.Count; i++)
|
|
{
|
|
string TagId = dt.Rows[i]["TagId"].ToString();
|
|
object tagValueStr = "";
|
|
string tagValue = "0";
|
|
MIS_BASE.Read_TagValueByTagID(TagId, out tagValueStr);
|
|
if (tagValueStr != null)
|
|
{
|
|
switch (tagValueStr.ToString().ToLower())
|
|
{
|
|
case "1":
|
|
case "true":
|
|
tagValue = "1";
|
|
break;
|
|
default:
|
|
tagValue = "0";
|
|
break;
|
|
}
|
|
Send_AlarmMsg(TagId, tagValue);
|
|
}
|
|
}
|
|
}
|
|
|
|
public static void Alarm_InitAlarm_Send(string opName, out Hashtable ht)
|
|
{
|
|
var tagValues = MIS_BASE.ReadPLC_OpName(opName);
|
|
//过滤出来质量数据 //获得带合格标志的质量数据
|
|
var keyValues = tagValues.OrderBy(x => x.Key).ToDictionary(k => k.Key, v => v.Value);
|
|
ht = new Hashtable();
|
|
|
|
foreach (KeyValuePair<string, DeviceDriver_BasicData.CustomeEvetnArgs> _cd in keyValues)
|
|
{
|
|
var tf = _cd.Value;
|
|
string TagID = tf.TagID.ToString();
|
|
if (TagID[0].ToString() == "9")
|
|
{
|
|
string tagValue = tf.TagValue.ToString();
|
|
if (tf.TagValue == null) return;
|
|
switch (tagValue.ToLower())
|
|
{
|
|
case "1":
|
|
case "true":
|
|
tagValue = "1";
|
|
break;
|
|
default:
|
|
tagValue = "0";
|
|
break;
|
|
}
|
|
if (tagValue == "1")
|
|
{
|
|
ht.Add(tf.TagID, tagValue);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
public static bool Alarm_Insert(string TagID, string tagTypeID, string opName, int TagValue,
|
|
DateTime alarmStartTime, DateTime alarmEndTime, int TimeDiff,
|
|
string Text1, string Text2, string TagOrderBy)
|
|
{
|
|
|
|
|
|
string produceName = "测量数据工位报警全部_增加数据";
|
|
SqlParameter[] thisParms = new SqlParameter[10];
|
|
thisParms[0] = new System.Data.SqlClient.SqlParameter("@TagID", TagID);
|
|
thisParms[1] = new System.Data.SqlClient.SqlParameter("@TagTypeID", tagTypeID);
|
|
thisParms[2] = new System.Data.SqlClient.SqlParameter("@opName", opName);
|
|
thisParms[3] = new System.Data.SqlClient.SqlParameter("@TagValue", TagValue);
|
|
thisParms[4] = new System.Data.SqlClient.SqlParameter("@alarmStartTime", alarmStartTime);
|
|
thisParms[5] = new System.Data.SqlClient.SqlParameter("@alarmEndTime", alarmEndTime);
|
|
thisParms[6] = new System.Data.SqlClient.SqlParameter("@TimeDiff", TimeDiff);
|
|
thisParms[7] = new System.Data.SqlClient.SqlParameter("@Text1", Text1);
|
|
thisParms[8] = new System.Data.SqlClient.SqlParameter("@Text2", Text2);
|
|
thisParms[9] = new System.Data.SqlClient.SqlParameter("@TagOrderBy", TagOrderBy);
|
|
if (DataAccess.ExecuteStoredProcedure(produceName, ref thisParms))
|
|
{
|
|
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 报错详细工件记录日志 （有可能报错 所以封装）
|
|
/// </summary>
|
|
/// <param name="errorStep">1.申请上线 2.传递机型 3.允许保存 4.扫码</param>
|
|
/// <param name="e"></param>
|
|
public static void Alarm_SaveFileLog4Error(string errorStep, object e, string FunName, Exception err)
|
|
{
|
|
try
|
|
{
|
|
MyLog4Net.MyLogHelper.Error($"{FunName}异常：", $"Message:{err.Message} InnerException: {err.InnerException}");
|
|
string leftErrorStep;
|
|
if (errorStep == "PartLoad")
|
|
{
|
|
leftErrorStep = "申请上线";
|
|
}
|
|
else if (errorStep == "EngineGetOver")
|
|
{
|
|
leftErrorStep = "传递机型";
|
|
}
|
|
else if (errorStep == "MesRead")
|
|
{
|
|
leftErrorStep = "允许保存";
|
|
}
|
|
else if (errorStep == "Barcode")
|
|
{
|
|
leftErrorStep = "扫码";
|
|
}
|
|
else
|
|
{
|
|
leftErrorStep = $"未知类型{errorStep}";
|
|
}
|
|
|
|
DeviceDriver_BasicData.CustomeEvetnArgs msgEvent = (DeviceDriver_BasicData.CustomeEvetnArgs)e;
|
|
string OpName = Convert.ToString(msgEvent.OpName);
|
|
MIS_BASE.GetEngineTypeFromPLC(OpName, out int EngineTypeID, out string EngineType, out string EngineID, out int PartPallet_Code, out string OrderForm);
|
|
MyLog4Net.MyLogHelper.Error($"{FunName}{leftErrorStep}操作异常：", $"工位号：{OpName}、总成号：{EngineID}、机型：{EngineType}、机型代码：{EngineTypeID}、订单号：{OrderForm}、托盘号：{PartPallet_Code}");
|
|
|
|
string saveString = $"{FunName}{leftErrorStep}操作异常 Message:{err.Message} InnerException: {err.InnerException}：工位号：{OpName}、总成号：{EngineID}、机型：{EngineType}、机型代码：{EngineTypeID}、订单号：{OrderForm}、托盘号：{PartPallet_Code}";
|
|
var sql =
|
|
$"INSERT INTO 合力_系统日志 ([工位号],[日志类型],[日志文本])"+
|
|
$" VALUES('{OpName}', 'system', '{saveString}')";
|
|
DataAccess.ExecuteDataTable(sql, out DataTable dt);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
MyLog4Net.MyLogHelper.Error($"{FunName}保存错误日志失败：", $"Message:{ex}");
|
|
}
|
|
}
|
|
|
|
public static void Alarm_SystemError(string FunName, Exception err)
|
|
{
|
|
MyLog4Net.MyLogHelper.Error($"系统{FunName}方法异常：", $"Message:{err.Message} InnerException:{err.InnerException}");
|
|
}
|
|
}
|
|
}
|