534 lines
24 KiB
C#
534 lines
24 KiB
C#
using DC_A95;
|
||
using ExternalDataSync;
|
||
using Newtonsoft.Json;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Data;
|
||
using System.Data.SqlClient;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace MesWork
|
||
{
|
||
/// <summary>
|
||
/// 数据库操作
|
||
/// </summary>
|
||
public class B_DB_Opera
|
||
{
|
||
|
||
public static void Event_WorkStart(string opName, int tagTypeCodeID, string partType, string tagID)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var procedureName = "Event_WorkStart";
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@OpName", opName),
|
||
new SqlParameter("@TagTypeCodeID", tagTypeCodeID),
|
||
new SqlParameter("@PartType", partType),
|
||
new SqlParameter("@ChangeTime",ChangeTime),
|
||
new SqlParameter("@TagID", tagID)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(procedureName, sqlParameter, out string errorMessage);
|
||
|
||
}
|
||
|
||
public static void Event_WorkEnd(string opName, int tagTypeCodeID, string partType
|
||
, string barCode, int qualityMask, int outCount, int duration
|
||
, string tagID)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var procedureName = "Event_WorkEnd";
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@OpName", opName),
|
||
new SqlParameter("@TagTypeCodeID", tagTypeCodeID),
|
||
new SqlParameter("@PartType", partType),
|
||
new SqlParameter("@BarCode", barCode),
|
||
new SqlParameter("@QualityMask", qualityMask),
|
||
new SqlParameter("@OutCount", outCount),
|
||
new SqlParameter("@Duration", duration),
|
||
new SqlParameter("@ChangeTime",ChangeTime),
|
||
new SqlParameter("@TagID", tagID)
|
||
};
|
||
|
||
SqlOperation.ExecuteStoredProcedure(procedureName, sqlParameter, out string errorMessage);
|
||
}
|
||
|
||
|
||
public static void Event_Signal_Log(string opName, int tagTypeCodeID, string signalName, string value)
|
||
{
|
||
var procedureName = "Event_Signal_Log";
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@OpName", opName),
|
||
new SqlParameter("@TagTypeCodeID", tagTypeCodeID),
|
||
new SqlParameter("@SignalName", signalName),
|
||
new SqlParameter("@TagValue", value)
|
||
};
|
||
|
||
SqlOperation.ExecuteStoredProcedure(procedureName, sqlParameter, out string errorMessage);
|
||
}
|
||
|
||
|
||
public static void Event_Alarm_Start(string opName, int tagTypeCodeID, string alarmText, string alarmLevel, string tagID)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var procedureName = "Event_Alarm_Start";
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@OpName", opName),
|
||
new SqlParameter("@TagTypeCodeID", tagTypeCodeID),
|
||
new SqlParameter("@AlarmText", alarmText),
|
||
new SqlParameter("@AlarmLevel", alarmLevel),
|
||
new SqlParameter("@ChangeTime",ChangeTime),
|
||
new SqlParameter("@TagID", tagID)
|
||
};
|
||
|
||
SqlOperation.ExecuteStoredProcedure(procedureName, sqlParameter, out string errorMessage);
|
||
|
||
}
|
||
|
||
|
||
public static void Event_Alarm_End(string opName, int tagTypeCodeID, string alarmText, string alarmLevel, string tagID)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var procedureName = "Event_Alarm_End";
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@OpName", opName),
|
||
new SqlParameter("@TagTypeCodeID", tagTypeCodeID),
|
||
new SqlParameter("@AlarmText", alarmText),
|
||
new SqlParameter("@AlarmLevel", alarmLevel),
|
||
new SqlParameter("@ChangeTime",ChangeTime),
|
||
new SqlParameter("@TagID", tagID)
|
||
};
|
||
|
||
SqlOperation.ExecuteStoredProcedure(procedureName, sqlParameter, out string errorMessage);
|
||
|
||
}
|
||
|
||
public static void Event_AlarmAndTip_Start(string opName, int tagTypeCodeID, string alarmText, string tagID, int Alarm1_Tip2)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var procedureName = "Event_AlarmAndTip_Start";
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@OpName", opName),
|
||
new SqlParameter("@TagTypeCodeID", tagTypeCodeID),
|
||
new SqlParameter("@AlarmText", alarmText),
|
||
new SqlParameter("@ChangeTime",ChangeTime),
|
||
new SqlParameter("@TagID", tagID),
|
||
new SqlParameter("@Alarm1_Tip2", Alarm1_Tip2),
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(procedureName, sqlParameter, out string errorMessage);
|
||
|
||
}
|
||
|
||
public static void MES_StatusChange(string opName, int StatusCode, string TriggerTime)
|
||
{
|
||
var procedureName = "设备管理_状态变化新增";
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@opName", opName),
|
||
new SqlParameter("@StatusCode", StatusCode),
|
||
new SqlParameter("@TriggerTime", TriggerTime),
|
||
};
|
||
|
||
SqlOperation.ExecuteStoredProcedure(procedureName, sqlParameter, out string errorMessage);
|
||
}
|
||
|
||
|
||
|
||
public static void Query_AlarmData(string opName, out int count, out string text)
|
||
{
|
||
count = 0;
|
||
text = "";
|
||
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var procedureName = "Query_AlarmData";
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@OpName", opName),
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure(procedureName, sqlParameter, out DataTable dt, out string errorMessage);
|
||
if (dt.Rows.Count > 0)
|
||
{
|
||
count = Convert.ToInt32(dt.Rows[0]["COUNT"].ToString());
|
||
text = dt.Rows[0]["TEXT"].ToString();
|
||
}
|
||
|
||
}
|
||
|
||
|
||
public static void Event_DeviceStatus_UseTime(string opName, string Onhours, string Workhours, string DeviceStatus)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var procedureName = "Event_DeviceStatus_UseTime";
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@OpName", opName),
|
||
new SqlParameter("@Onhours", Onhours),
|
||
new SqlParameter("@Workhours", Workhours),
|
||
new SqlParameter("@DeviceStatus", DeviceStatus),
|
||
new SqlParameter("@ChangeTime",ChangeTime),
|
||
};
|
||
|
||
SqlOperation.ExecuteStoredProcedure(procedureName, sqlParameter, out string errorMessage);
|
||
|
||
}
|
||
|
||
public static void Event_DeviceStatus_Change(string opName, string DeviceStatus)
|
||
{
|
||
var ChangeTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var procedureName = "Event_DeviceStatus_Change";
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@OpName", opName),
|
||
new SqlParameter("@DeviceStatus", DeviceStatus),
|
||
new SqlParameter("@ChangeTime",ChangeTime),
|
||
};
|
||
|
||
SqlOperation.ExecuteStoredProcedure(procedureName, sqlParameter, out string errorMessage);
|
||
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 请求日志记录
|
||
/// </summary>
|
||
public static void SaveLog_Request(string StationName, Log_Type LogType, string ReqCode, Log_FromAndTo ReqFrom, Log_FromAndTo ReqTo, string ReqStr, out long AID, string ReqStrSafe = "")
|
||
{
|
||
AID = -1;
|
||
var CreateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
ReqStr = PLC_R.GetString_CleanGarbled(ReqStr);
|
||
|
||
var param1 = new SqlParameter[] {
|
||
new SqlParameter("@工位号", StationName),
|
||
new SqlParameter("@日志类型", LogType.ToString()),
|
||
new SqlParameter("@TaskID", ReqCode),
|
||
new SqlParameter("@请求CMD",""),
|
||
new SqlParameter("@请求FROM",ReqFrom.ToString()),
|
||
new SqlParameter("@请求TO",ReqTo.ToString()),
|
||
new SqlParameter("@请求时间",CreateTime),
|
||
new SqlParameter("@请求内容",ReqStr),
|
||
new SqlParameter("@请求内容安全",ReqStrSafe)
|
||
};
|
||
DataLinkMesWork.SQLCommon.ExecuteStoredProcedure("Event_Log_Request", MesWorkForm.ConnectionString, ref param1, out DataTable dt, out string errorMessage);
|
||
if (dt.Rows.Count > 0)
|
||
{
|
||
AID = Convert.ToInt64(dt.Rows[0]["AID"]);
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 响应日志记录
|
||
/// </summary>
|
||
public static void SaveLog_Response(string result, long AID)
|
||
{
|
||
try
|
||
{
|
||
var CreateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var param4 = new SqlParameter[]
|
||
{
|
||
new SqlParameter("@AID",AID),
|
||
new SqlParameter("@响应时间",CreateTime),
|
||
new SqlParameter("@响应内容",JsonConvert.SerializeObject(result))
|
||
};
|
||
DataLinkMesWork.SQLCommon.ExecuteStoredProcedure("Event_Log_Respond", MesWorkForm.ConnectionString, ref param4, out string errorMessage);
|
||
}
|
||
catch (Exception err)
|
||
{
|
||
}
|
||
|
||
}
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 根据订货号匹配工件管理规则，查询机型参数（加油量/抽油量/密度/残油量上下限）
|
||
/// </summary>
|
||
public static bool QueryWorkpieceByOrderNo(string orderNo, out string modelNo, out decimal addOilQty, out decimal extractOilQty, out decimal density,
|
||
out decimal residualOilUpperLimit, out decimal residualOilLowerLimit)
|
||
{
|
||
modelNo = "";
|
||
addOilQty = 0; extractOilQty = 0; density = 0; residualOilUpperLimit = 0; residualOilLowerLimit = 0;
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@订货号", orderNo)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure("称重_查询工件参数", sqlParameter, out DataTable dt, out string err);
|
||
if (dt != null && dt.Rows.Count > 0 && dt.Rows[0]["result"].ToString() == "1")
|
||
{
|
||
var row = dt.Rows[0];
|
||
modelNo = row["机型号"]?.ToString() ?? "";
|
||
decimal.TryParse(row["加油量"]?.ToString(), out addOilQty);
|
||
decimal.TryParse(row["抽油量"]?.ToString(), out extractOilQty);
|
||
decimal.TryParse(row["密度"]?.ToString(), out density);
|
||
decimal.TryParse(row["残油量上限"]?.ToString(), out residualOilUpperLimit);
|
||
decimal.TryParse(row["残油量下限"]?.ToString(), out residualOilLowerLimit);
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询指定工位和原始重量匹配的工具标定配置。
|
||
/// </summary>
|
||
public static bool QueryToolCalibration(string opName, decimal rawWeight, out string toolName, out string formula, out string description, out string msg)
|
||
{
|
||
toolName = "";
|
||
formula = "";
|
||
description = "";
|
||
msg = "";
|
||
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@工位号", opName ?? ""),
|
||
new SqlParameter("@重量", rawWeight)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure("工具管理_查询匹配标定", sqlParameter, out DataTable dt, out string err);
|
||
if (dt == null)
|
||
{
|
||
msg = string.IsNullOrWhiteSpace(err) ? $"查询[{opName}]工具标定配置失败" : err;
|
||
return false;
|
||
}
|
||
|
||
if (dt.Rows.Count == 0)
|
||
{
|
||
msg = "";
|
||
return false;
|
||
}
|
||
|
||
var row = dt.Rows[0];
|
||
toolName = row["工具名称"]?.ToString() ?? "";
|
||
formula = row["计算公式"]?.ToString() ?? "";
|
||
description = row["说明"]?.ToString() ?? "";
|
||
return true;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 插入称重记录
|
||
/// </summary>
|
||
/// <returns>新记录ID，失败返回-1</returns>
|
||
public static long InsertWeighingRecord(
|
||
string stationNo, string weighType, string engineNo, string modelNo,
|
||
string orderNo, string palletNo,
|
||
decimal inWeight, decimal outWeight,
|
||
decimal addOilQty, decimal extractOilQty, decimal density,
|
||
decimal residualOilUpperLimit, decimal residualOilLowerLimit,
|
||
decimal oilRelease, decimal residualOil,
|
||
int qualityFlag, decimal waterContent,
|
||
string dataSource, string worker, int isComplete)
|
||
{
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@工位号", stationNo),
|
||
new SqlParameter("@称重类型", weighType),
|
||
new SqlParameter("@发动机号", engineNo),
|
||
new SqlParameter("@机型号", modelNo),
|
||
new SqlParameter("@工单号", orderNo),
|
||
new SqlParameter("@托盘号", palletNo),
|
||
new SqlParameter("@进站重量", inWeight),
|
||
new SqlParameter("@离站重量", outWeight),
|
||
new SqlParameter("@加油量", addOilQty),
|
||
new SqlParameter("@抽油量", extractOilQty),
|
||
new SqlParameter("@密度", density),
|
||
new SqlParameter("@残油量上限", residualOilUpperLimit),
|
||
new SqlParameter("@残油量下限", residualOilLowerLimit),
|
||
new SqlParameter("@放油量", oilRelease),
|
||
new SqlParameter("@残油量", residualOil),
|
||
new SqlParameter("@合格标志", qualityFlag),
|
||
new SqlParameter("@水含量", waterContent),
|
||
new SqlParameter("@数据来源", dataSource),
|
||
new SqlParameter("@操作者", worker),
|
||
new SqlParameter("@是否完成", isComplete)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure("称重记录_增加", sqlParameter, out DataTable dt, out string err);
|
||
if (dt != null && dt.Rows.Count > 0 && dt.Rows[0]["result"].ToString() == "1")
|
||
{
|
||
return Convert.ToInt64(dt.Rows[0]["ID"]);
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询放油前记录（按发动机号匹配，称重类型='空中'且未完成）
|
||
/// </summary>
|
||
public static bool QueryWeighingBeforeOil(string engineNo, out long recordId, out decimal preWeight, out decimal addOilQty, out decimal extractOilQty, out decimal density)
|
||
{
|
||
recordId = 0; preWeight = 0; addOilQty = 0; extractOilQty = 0; density = 0;
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@发动机号", engineNo)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure("称重记录_查询放油前", sqlParameter, out DataTable dt, out string err);
|
||
if (dt != null && dt.Rows.Count > 0 && dt.Rows[0]["result"].ToString() == "1")
|
||
{
|
||
var row = dt.Rows[0];
|
||
recordId = Convert.ToInt64(row["ID"]);
|
||
decimal.TryParse(row["进站重量"]?.ToString(), out preWeight);
|
||
decimal.TryParse(row["加油量"]?.ToString(), out addOilQty);
|
||
decimal.TryParse(row["抽油量"]?.ToString(), out extractOilQty);
|
||
decimal.TryParse(row["密度"]?.ToString(), out density);
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询指定工位最新的称重记录（不过滤完成状态）
|
||
/// </summary>
|
||
public static bool QueryLatestRecord(string stationNo, string engineNo,
|
||
out long recordId, out decimal preWeight,
|
||
out decimal addOilQty, out decimal extractOilQty, out decimal density)
|
||
{
|
||
recordId = 0; preWeight = 0; addOilQty = 0; extractOilQty = 0; density = 0;
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@工位号", stationNo),
|
||
new SqlParameter("@发动机号", engineNo)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure("称重记录_查询最新", sqlParameter, out DataTable dt, out string err);
|
||
if (dt != null && dt.Rows.Count > 0 && dt.Rows[0]["result"].ToString() == "1")
|
||
{
|
||
var row = dt.Rows[0];
|
||
recordId = Convert.ToInt64(row["ID"]);
|
||
decimal.TryParse(row["进站重量"]?.ToString(), out preWeight);
|
||
decimal.TryParse(row["加油量"]?.ToString(), out addOilQty);
|
||
decimal.TryParse(row["抽油量"]?.ToString(), out extractOilQty);
|
||
decimal.TryParse(row["密度"]?.ToString(), out density);
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 更新称重记录为完成状态（保存称重结果）
|
||
/// </summary>
|
||
public static bool UpdateWeighingComplete(long recordId, string weighType, string stationNo,
|
||
decimal weight, decimal oilRelease, decimal residualOil, decimal waterContent, out int qualityFlag, out string msg)
|
||
{
|
||
qualityFlag = 2;
|
||
msg = "";
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@ID", recordId),
|
||
new SqlParameter("@称重类型", weighType),
|
||
new SqlParameter("@工位号", stationNo),
|
||
new SqlParameter("@称重重量", weight),
|
||
new SqlParameter("@放油量", oilRelease),
|
||
new SqlParameter("@残油量", residualOil),
|
||
new SqlParameter("@水含量", waterContent)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure("称重记录_完成更新", sqlParameter, out DataTable dt, out string err);
|
||
if (dt == null || dt.Rows.Count == 0)
|
||
{
|
||
msg = string.IsNullOrEmpty(err) ? "称重记录完成更新未返回结果" : err;
|
||
return false;
|
||
}
|
||
|
||
qualityFlag = Convert.ToInt32(dt.Rows[0]["result"]);
|
||
msg = dt.Rows[0]["msg"].ToString();
|
||
return true;
|
||
}
|
||
|
||
// ====================================================================
|
||
// 过站记录操作方法
|
||
// ====================================================================
|
||
|
||
/// <summary>
|
||
/// 新增过站记录（case 44 请求工作时调用）
|
||
/// </summary>
|
||
public static long InsertStationRecord(string engineNo, string modelNo, string orderNo, string palletNo,
|
||
string stationNo, string stationName, decimal addOilQty, decimal extractOilQty, decimal density, string worker)
|
||
{
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@发动机号", engineNo),
|
||
new SqlParameter("@机型号", modelNo),
|
||
new SqlParameter("@工单号", orderNo),
|
||
new SqlParameter("@托盘号", palletNo),
|
||
new SqlParameter("@工位号", stationNo),
|
||
new SqlParameter("@工位名称", stationName),
|
||
new SqlParameter("@加油量", addOilQty),
|
||
new SqlParameter("@抽油量", extractOilQty),
|
||
new SqlParameter("@油密度", density),
|
||
new SqlParameter("@操作者", worker)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure("过站记录_新增", sqlParameter, out DataTable dt, out string err);
|
||
if (dt != null && dt.Rows.Count > 0 && dt.Rows[0]["result"].ToString() == "1")
|
||
return Convert.ToInt64(dt.Rows[0]["ID"]);
|
||
return -1;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 更新过站记录为完成（case 19 请求保存时调用）
|
||
/// </summary>
|
||
public static bool UpdateStationComplete(string engineNo, string stationNo, decimal weight)
|
||
{
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@发动机号", engineNo),
|
||
new SqlParameter("@工位号", stationNo),
|
||
new SqlParameter("@称重重量", weight)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure("过站记录_完成", sqlParameter, out DataTable dt, out string err);
|
||
return dt != null && dt.Rows.Count > 0 && dt.Rows[0]["result"].ToString() == "1";
|
||
}
|
||
|
||
// ====================================================================
|
||
// 称重曲线数据操作方法
|
||
// ====================================================================
|
||
|
||
/// <summary>
|
||
/// 创建紧凑曲线记录，点位值在保存时一次性写入。
|
||
/// </summary>
|
||
public static long CurveRecord_Start(string opName, string productNo, string modelNo, int sampleIntervalMs)
|
||
{
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@工位号", opName),
|
||
new SqlParameter("@产品编号", productNo),
|
||
new SqlParameter("@机型号", modelNo ?? (object)DBNull.Value),
|
||
new SqlParameter("@采样间隔ms", sampleIntervalMs)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure("称重曲线记录_开始", sqlParameter, out DataTable dt, out string err);
|
||
if (dt != null && dt.Rows.Count > 0 && dt.Rows[0]["result"].ToString() == "1")
|
||
{
|
||
return Convert.ToInt64(dt.Rows[0]["ID"]);
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 保存紧凑曲线点位字符串，并关联最终称重记录。
|
||
/// </summary>
|
||
public static bool CurveRecord_Save(long curveId, long weighingRecordId, int sampleCount, string pointValues,
|
||
decimal? finalWeight, int? finalStartSeq, int? finalEndSeq)
|
||
{
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@ID", curveId),
|
||
new SqlParameter("@称重记录ID", weighingRecordId > 0 ? (object)weighingRecordId : DBNull.Value),
|
||
new SqlParameter("@采样点数", sampleCount),
|
||
new SqlParameter("@点位值", string.IsNullOrEmpty(pointValues) ? (object)DBNull.Value : pointValues),
|
||
new SqlParameter("@最终重量", finalWeight.HasValue ? (object)finalWeight.Value : DBNull.Value),
|
||
new SqlParameter("@最终取点开始序号", finalStartSeq.HasValue ? (object)finalStartSeq.Value : DBNull.Value),
|
||
new SqlParameter("@最终取点结束序号", finalEndSeq.HasValue ? (object)finalEndSeq.Value : DBNull.Value)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure("称重曲线记录_保存", sqlParameter, out DataTable dt, out string err);
|
||
return dt != null && dt.Rows.Count > 0 && dt.Rows[0]["result"].ToString() == "1";
|
||
}
|
||
|
||
/// <summary>
|
||
/// 查询指定产品最新紧凑曲线记录。
|
||
/// </summary>
|
||
public static bool CurveRecord_QueryLatest(string opName, string productNo, out string pointValues, out decimal finalWeight)
|
||
{
|
||
pointValues = "";
|
||
finalWeight = 0;
|
||
var sqlParameter = new SqlParameter[] {
|
||
new SqlParameter("@工位号", opName),
|
||
new SqlParameter("@产品编号", productNo)
|
||
};
|
||
SqlOperation.ExecuteStoredProcedure("称重曲线记录_查询最新", sqlParameter, out DataTable dt, out string err);
|
||
if (dt != null && dt.Rows.Count > 0 && dt.Rows[0]["result"].ToString() == "1")
|
||
{
|
||
pointValues = dt.Rows[0]["点位值"]?.ToString() ?? "";
|
||
decimal.TryParse(dt.Rows[0]["最终重量"]?.ToString(), out finalWeight);
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 曲线采样点数据结构
|
||
/// </summary>
|
||
public class CurveSamplePoint
|
||
{
|
||
public int SeqNo;
|
||
public DateTime SampleTime;
|
||
public decimal Weight;
|
||
}
|
||
}
|