493 lines
19 KiB
C#
493 lines
19 KiB
C#
using DC_A95.MES_A95;
|
||
using NPOI.OpenXmlFormats.Dml;
|
||
using NPOI.SS.Formula.Eval;
|
||
using NPOI.SS.Formula.Functions;
|
||
using NPOI.Util;
|
||
using Opc.Ua;
|
||
using OpcBasic;
|
||
using Rhino.DocObjects;
|
||
using Rhino.Geometry;
|
||
using SlMesDbIterface;
|
||
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.Reflection.Emit;
|
||
using System.Text;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
using System.Windows.Forms;
|
||
using SystemFramework;
|
||
|
||
/// <summary>
|
||
///
|
||
/// </summary>
|
||
namespace MesWork
|
||
{
|
||
/// <summary>
|
||
/// 操作数据库
|
||
/// </summary>
|
||
public class ExecuteDB
|
||
{
|
||
/// <summary>
|
||
/// 报警开始
|
||
/// </summary>
|
||
/// <param name="opName"></param>
|
||
/// <param name="alarming"></param>
|
||
public static void Alarm_Start(string opName,int[] alarming)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var name = "Event_Alarm_Start";
|
||
|
||
for (int i = 0; i < alarming.Length ; i++)
|
||
{
|
||
var alarmCode = alarming[i];
|
||
var sqlParameters = new SqlParameter[] {
|
||
new SqlParameter("@StationName", opName),
|
||
new SqlParameter("@AlarmCode", alarmCode),
|
||
new SqlParameter("@ChangeTime", ChangeTime)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(name, sqlParameters, out DataSet ds, out string error);
|
||
}
|
||
|
||
}
|
||
/// <summary>
|
||
/// 报警结束
|
||
/// </summary>
|
||
/// <param name="opName"></param>
|
||
public static void Alarm_End(string opName)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var name = "Event_Alarm_End";
|
||
|
||
var sqlParameters = new SqlParameter[] {
|
||
new SqlParameter("@StationName", opName),
|
||
new SqlParameter("@ChangeTime", ChangeTime)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(name, sqlParameters, out DataSet ds, out string error);
|
||
|
||
}
|
||
/// <summary>
|
||
/// 安东开始
|
||
/// </summary>
|
||
/// <param name="opCode"></param>
|
||
/// <param name="alarmCode">变量类型代码</param>
|
||
public static void Alarm_Andon_Start(string opCode, int alarmCode)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var name = "Event_Alarm_Andon_Start";
|
||
|
||
var sqlParameters = new SqlParameter[] {
|
||
new SqlParameter("@StationName", opCode),
|
||
new SqlParameter("@AlarmCode", alarmCode),
|
||
new SqlParameter("@ChangeTime", ChangeTime)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(name, sqlParameters, out DataSet ds, out string error);
|
||
|
||
}
|
||
/// <summary>
|
||
/// 安东结束
|
||
/// </summary>
|
||
/// <param name="opCode"></param>
|
||
/// <param name="alarmCode"></param>
|
||
public static void Alarm_Andon_End(string opCode, int alarmCode)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var name = "Event_Alarm_Andon_End";
|
||
|
||
var sqlParameters = new SqlParameter[] {
|
||
new SqlParameter("@StationName", opCode),
|
||
new SqlParameter("@AlarmCode", alarmCode),
|
||
new SqlParameter("@ChangeTime", ChangeTime)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(name, sqlParameters, out DataSet ds, out string error);
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 安东确认
|
||
/// </summary>
|
||
/// <param name="opName"></param>
|
||
/// <param name="alarmCode"></param>
|
||
public static void Alarm_Andon_Sure(string opName, int alarmCode)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var name = "Event_Alarm_Andon_Sure";
|
||
|
||
var sqlParameters = new SqlParameter[] {
|
||
new SqlParameter("@StationName", opName),
|
||
new SqlParameter("@AlarmCode", alarmCode),
|
||
new SqlParameter("@ChangeTime", ChangeTime)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(name, sqlParameters, out DataSet ds, out string error);
|
||
|
||
}
|
||
public static DataTable Get_TaskTypeInfo()
|
||
{
|
||
var sql = $" SELECT [任务类型],[任务类型名称],[质量数据数量]" +
|
||
$" ,[数据名称1],[数据单位1],[数据名称2],[数据单位2],[数据名称3],[数据单位3],[数据名称4],[数据单位4]" +
|
||
$" FROM [配方_大柴_任务类型]";
|
||
SqlOperation.ExecuteSql(sql, out DataTable dt, out string err);
|
||
return dt;
|
||
}
|
||
|
||
public static void Save_StationPass_Info(string engineNo, string engineTypeNo, int palletNo, string orderNum, int orderNo,int orderSum,string processCode, string processName,
|
||
string opCode, string opName, int passAttr, string opter, int QualityOk,int PassStatus, int upOrDown, int optFlag,string sortNo_PLC)
|
||
{
|
||
var weight = -1;
|
||
|
||
var P_name = "Event_MOM_过点数据";
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
|
||
SqlParameter[] Parameters ={
|
||
new SqlParameter("@发动机流水号",engineNo),
|
||
new SqlParameter("@机型号",engineTypeNo),
|
||
new SqlParameter("@托盘号",palletNo),
|
||
new SqlParameter("@订单号",orderNum),
|
||
new SqlParameter("@订单序号",orderNo),
|
||
new SqlParameter("@订单数量",orderSum),
|
||
new SqlParameter("@工序编码",processCode),
|
||
new SqlParameter("@工序名称", processName),
|
||
new SqlParameter("@工位编码",opCode),
|
||
new SqlParameter("@工位名称",opName),
|
||
new SqlParameter("@过点属性",passAttr),
|
||
new SqlParameter("@采集时间",ChangeTime),
|
||
new SqlParameter("@操作者",opter),
|
||
new SqlParameter("@合格标志",QualityOk),
|
||
new SqlParameter("@过站状态",PassStatus),
|
||
new SqlParameter("@岔道上下件",upOrDown),
|
||
new SqlParameter("@重量",weight),
|
||
new SqlParameter("@操作标记",optFlag),
|
||
new SqlParameter("@机型标志",sortNo_PLC)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(P_name, Parameters, out string err);
|
||
if (err.Length > 0)
|
||
{
|
||
LogRecord.LogRecord.Insert_Log(Type_Log.Alarm, "", $"Save_StationPass_Info 报错！，，{err}");
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 增加：测量数据索引
|
||
/// </summary>
|
||
/// <param name="tagTypeCodeID"></param>
|
||
/// <param name="engineTypeNo"></param>
|
||
/// <param name="engineNo"></param>
|
||
/// <param name="opCode"></param>
|
||
/// <param name="orderNum"></param>
|
||
/// <param name="palletNo"></param>
|
||
/// <param name="QCDataCount"></param>
|
||
/// <param name="Operator"></param>
|
||
/// <param name="QuaulityFlag"></param>
|
||
/// <param name="Id_tagCF"></param>
|
||
public static void Save_MeasureData_Index(int tagTypeCodeID, string engineTypeNo, string engineNo,string opCode,string orderNum, int palletNo,int QCDataCount, string Operator, int QuaulityFlag, out int Id_tagCF)
|
||
{
|
||
var P_name = "测量数据合格索引_增加";
|
||
Id_tagCF = 0;
|
||
SqlParameter[] thisParms = new SqlParameter[10];
|
||
thisParms[0] = new SqlParameter("@TagID_CF", tagTypeCodeID);
|
||
thisParms[1] = new SqlParameter("@EngineType", engineTypeNo);
|
||
thisParms[2] = new SqlParameter("@EngineID", engineNo);
|
||
thisParms[3] = new SqlParameter("@工位号", opCode);
|
||
thisParms[4] = new SqlParameter("@订单号", orderNum);
|
||
thisParms[5] = new SqlParameter("@托盘编号", palletNo);
|
||
thisParms[6] = new SqlParameter("@质量数据数量", QCDataCount);
|
||
thisParms[7] = new SqlParameter("@操作者工号", Operator);
|
||
thisParms[8] = new SqlParameter("@合格标志", QuaulityFlag);
|
||
thisParms[9] = new SqlParameter("@Id_tagCF", Id_tagCF);
|
||
thisParms[9].Direction = ParameterDirection.Output;
|
||
|
||
if(SqlOperation.ExecuteStoredProcedure(P_name, thisParms, out string err))
|
||
{
|
||
Id_tagCF=Convert.ToInt32(thisParms[9].Value.ToString());
|
||
}
|
||
else
|
||
{
|
||
Id_tagCF = -1;
|
||
}
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 即时参数存储
|
||
/// </summary>
|
||
/// <param name="opName"></param>
|
||
/// <param name="tagTypeCodeID"></param>
|
||
/// <param name="value"></param>
|
||
/// <param name="tagID"></param>
|
||
public static void Update_ImmediateParam(string opName, int tagTypeCodeID, string value, string tagID)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var name = "Event_MES_工位_即时参数_变化";
|
||
|
||
var sqlParameters = new SqlParameter[] {
|
||
new SqlParameter("@工位号", opName),
|
||
new SqlParameter("@变量类型代码",tagTypeCodeID ),
|
||
new SqlParameter("@值",value),
|
||
new SqlParameter("@更新时间", ChangeTime),
|
||
new SqlParameter("@TagID", tagID),
|
||
new SqlParameter("@开始时间", ChangeTime),
|
||
new SqlParameter("@结束时间", ChangeTime),
|
||
new SqlParameter("@持续时间", 0)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(name, sqlParameters, out DataSet ds, out string error);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设备状态变化
|
||
/// </summary>
|
||
/// <param name="opName"></param>
|
||
/// <param name="tagTypeCodeID"></param>
|
||
/// <param name="value"></param>
|
||
/// <param name="tagID"></param>
|
||
/// <param name="deviceMode"></param>
|
||
public static void Event_StationStatus_Changed(string opName, string manual, string running, string alarm, string onLine = "1")
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var name = "Event_StationStatus_Changed";
|
||
|
||
var sqlParameters = new SqlParameter[] {
|
||
new SqlParameter("@工位号", opName),
|
||
new SqlParameter("@手动模式", manual),
|
||
new SqlParameter("@运行中",running ),
|
||
new SqlParameter("@报警",alarm),
|
||
new SqlParameter("@在线",onLine),
|
||
new SqlParameter("@更新时间", ChangeTime)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(name, sqlParameters, out DataSet ds, out string error);
|
||
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 保存布局
|
||
/// </summary>
|
||
/// <param name="stationName"></param>
|
||
/// <param name="px"></param>
|
||
/// <param name="py"></param>
|
||
public static void SaveLyout_P(string stationName, int px, int py)
|
||
{
|
||
var sql =
|
||
$" UPDATE [MES_计划BOM_工位与名称] SET [PX] = {px},[PY] = {py}" +
|
||
$" WHERE [工位号] = '{stationName}'";
|
||
SqlOperation.ExecuteSql(sql, out string error);
|
||
}
|
||
/// <summary>
|
||
/// 保存布局
|
||
/// </summary>
|
||
/// <param name="stationName"></param>
|
||
/// <param name="pxt"></param>
|
||
/// <param name="pyt"></param>
|
||
public static void SaveLyout_PT(string stationName, int pxt, int pyt)
|
||
{
|
||
var sql =
|
||
$" UPDATE [MES_计划BOM_工位与名称] SET [PX_T] = {pxt},[PY_T] = {pyt}" +
|
||
$" WHERE [工位号] = '{stationName}'";
|
||
SqlOperation.ExecuteSql(sql, out string error);
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 查询工位信息
|
||
/// </summary>
|
||
/// <param name="dt"></param>
|
||
public static void Select_Station(out DataTable dt)
|
||
{
|
||
var sql =
|
||
$" SELECT [工位号],[工位名称],[PLC],[PLC代码]," +
|
||
$"ISNULL([PX],0) AS PX,ISNULL([PY],0) AS PY,ISNULL([PX_T],0) AS PX_T,ISNULL([PY_T],0) AS PY_T,[控件启用]" +
|
||
$" ,[区域代码]" +
|
||
$" FROM [MES_计划BOM_工位与名称] WHERE [是否启用MES] = 1" + // AND [ProgramPartial] = {MesWorkForm.ProgramPartial}
|
||
$" ORDER BY [工位号]";
|
||
SqlOperation.ExecuteSql(sql, out dt, out string error);
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 检查上线的发动机流水号是否重复
|
||
/// </summary>
|
||
/// <param name="dt"></param>
|
||
public static void Check_Repeat_LineSet(string opcode, string engineNo, out bool ifrepeat)
|
||
{
|
||
ifrepeat = false;
|
||
var sql = $" SELECT count(AID) FROM [大柴_过点信息] where 工位编码='{opcode}' and 发动机流水号='{engineNo}'";
|
||
SqlOperation.ExecuteSql(sql, out DataTable dt, out string error);
|
||
if (int.Parse(dt.Rows[0][0].ToString()) > 0) ifrepeat = true;
|
||
}
|
||
public static void Save_ScanRecord_outLineSet(string opCode, string engineNo, string ActualNumber,string Decode_Result)
|
||
{
|
||
//保存扫码记录
|
||
string sql = $@"INSERT INTO[MES_装配数据_零部件扫码记录]([工位号],[发动机流水号],[ActualNumber],[Decode_Result],[MaterialCode], Scanner_No,[操作时间])
|
||
VALUES('{opCode}', {engineNo}, '{ActualNumber}', '{Decode_Result}', '{engineNo}', 1, getdate())";
|
||
SqlOperation.ExecuteSql(sql,out string error);
|
||
}
|
||
public static void Get_EngineInfo_OutSide(int AGVCode,out string EngineNo,out int EngineTypeID,out string EngineType,out string OrderNum)
|
||
{
|
||
//根据agvcode获取发动机信息
|
||
string sql = $@"SELECT TOP (1)[发动机流水号],[大机型ID],[机型号],[工单号] FROM [大柴_上线记录_外装线]
|
||
where AGV号={AGVCode} and 外装线绑定状态=1 and [发动机流水号]<>'' order by 操作时间 desc";
|
||
SqlOperation.ExecuteSql(sql,out DataTable dt,out string error);
|
||
if(dt.Rows.Count==1)
|
||
{
|
||
EngineNo = dt.Rows[0]["发动机流水号"].ToString();
|
||
EngineTypeID = int.Parse(dt.Rows[0]["大机型ID"].ToString());
|
||
EngineType = dt.Rows[0]["机型号"].ToString();
|
||
OrderNum = dt.Rows[0]["工单号"].ToString();
|
||
|
||
}
|
||
else
|
||
{
|
||
EngineNo = "";
|
||
EngineTypeID = 0;
|
||
EngineType = "";
|
||
OrderNum = "";
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 内装线上线工位：请求下载
|
||
/// </summary>
|
||
/// <param name="opCode"></param>
|
||
/// <param name="partCode"></param>
|
||
/// <param name="palletNo"></param>
|
||
/// <param name="engineNo"></param>
|
||
/// <param name="sortNo"></param>
|
||
/// <param name="sortName"></param>
|
||
/// <param name="printCode"></param>
|
||
/// <param name="orderNo"></param>
|
||
public static void Select_OnLine_Plan_Engine(string opCode,string partCode, int palletNo
|
||
, out string engineNo
|
||
, out int sortNo
|
||
, out string sortName
|
||
, out string printCode
|
||
, out string orderNo
|
||
, out int errCode
|
||
, out string errMessage
|
||
, out int printPosition
|
||
|
||
)
|
||
{
|
||
engineNo = "";
|
||
sortNo = 0;
|
||
sortName = "";
|
||
printCode = "";
|
||
orderNo = "";
|
||
errCode = 0;
|
||
errMessage = "";
|
||
printPosition = 0;
|
||
|
||
var name = "Event_Query_上线发动机数据";
|
||
var sqlParameters = new SqlParameter[] {
|
||
new SqlParameter("@StationName", opCode),
|
||
new SqlParameter("@PartCode",partCode ),
|
||
new SqlParameter("@PalletNo",palletNo )
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(name, sqlParameters, out DataTable dt, out string error);
|
||
if (dt.Rows.Count > 0)
|
||
{
|
||
engineNo = dt.Rows[0]["发动机编号"].ToString();
|
||
sortNo = int.Parse(dt.Rows[0]["机型ID"].ToString());
|
||
sortName = dt.Rows[0]["机型号"].ToString();
|
||
printCode = dt.Rows[0]["缸体打印码"].ToString();
|
||
orderNo = dt.Rows[0]["工单号"].ToString();
|
||
|
||
errCode = Convert.ToInt32(dt.Rows[0]["Code"]);
|
||
errMessage = dt.Rows[0]["Message"].ToString();
|
||
printPosition = Convert.ToInt32(dt.Rows[0]["PrintPosition"]);
|
||
}
|
||
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 执行计划：成功上线的发动机，更新执行计划为2
|
||
/// </summary>
|
||
/// <param name="opCode"></param>
|
||
/// <param name="engineNo"></param>
|
||
public static void Update_ExcutePlan_LineSetOK(string opCode,string engineNo)
|
||
{
|
||
var name = "Event_执行计划_验证完成";
|
||
var sqlParameters = new SqlParameter[] {
|
||
new SqlParameter("@StationName", opCode),
|
||
new SqlParameter("@EngineNo", engineNo)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(name, sqlParameters,out DataTable dt,out string err);
|
||
if (err.Length > 0)
|
||
{
|
||
LogRecord.LogRecord.Insert_Log(Type_Log.Alarm, "", $"Update_ExcutePlan_LineSetOK 报错！，，{err}");
|
||
}
|
||
|
||
}
|
||
|
||
|
||
public static void Event_OutSide_OnLine(string opCode, string engineNo, int engineTypeID, int orderNo, string engineTypeCode, int agvCode)
|
||
{
|
||
var name = "Event_OutSide_OnLine";
|
||
var sqlParameters = new SqlParameter[] {
|
||
new SqlParameter("@StationName", opCode),
|
||
new SqlParameter("@EngineNo", engineNo),
|
||
new SqlParameter("@EngineTypeNo",engineTypeID),
|
||
new SqlParameter("@OrderNo",orderNo ),
|
||
new SqlParameter("@EngineTypeCode",engineTypeCode),
|
||
new SqlParameter("@AgvCode",agvCode),
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(name, sqlParameters, out string error);
|
||
}
|
||
|
||
|
||
public static bool Event_QueryRecipes_ColdTest(string opCode, string sortNo, out DataTable dt)
|
||
{
|
||
var name = "Event_QueryRecipes_ColdTest";
|
||
var sqlParameters = new SqlParameter[] {
|
||
new SqlParameter("@StationName", opCode),
|
||
new SqlParameter("@SortNo",sortNo),
|
||
};
|
||
return SqlOperation.ExecuteStoredProcedure(name, sqlParameters, out dt, out string error);
|
||
}
|
||
|
||
}
|
||
}
|