Files
2026-05-29 10:07:05 +08:00

265 lines
12 KiB
C#

using DataLinkMesWork;
using Global;
using System;
using System.Collections.Generic;
using System.Data;
using static DtWebApiDT.DataAccess;
//using static SqlManage.ExecSql;
/// <summary>
///
/// </summary>
namespace DTTest
{
/// <summary>
/// 对于数据库的操作
/// </summary>
public partial class SqlOperation
{
/// <summary>
/// 设备信号仿真
/// </summary>
public class SqlDeviceSignalSim
{
/// <summary>
/// 更新 设备信号仿真任务 开始时间
/// 2021.3.5
/// 2021.6.23
/// </summary>
/// <param name="craftCode"></param>
/// <param name="startTime"></param>
public static void Update_DeviceSignalSimAlign(string id, int startTime, int keepTime, int sequenceNo,string tagValue)
{
// string sql =
//@" DECLARE @ID INT = " + id + "" +
//@" DECLARE @StartTime INT = " + startTime + "" +
//@" DECLARE @KeepTime INT = " + keepTime + "" +
//@" DECLARE @SequenceNo INT = " + sequenceNo + "" +
//@" DECLARE @TagValue NVARCHAR(50) = '" + tagValue + "'" +
//@" DECLARE @ProjectCode NVARCHAR(50) = '" + PP.ProjectCode + "'" +
//@" UPDATE [DeviceSignalSimTree] SET [StartTime] = @StartTime,[KeepTime] = @KeepTime,[SequenceNo] = @SequenceNo,[TagValue] = @TagValue" +
//@" WHERE [ProjectCode] = @ProjectCode AND [ID] = @ID";
string sql =
@" DECLARE @ID INT = " + id + "" +
@" DECLARE @StartTime INT = " + startTime + "" +
@" DECLARE @KeepTime INT = " + keepTime + "" +
@" DECLARE @SequenceNo INT = " + sequenceNo + "" +
@" DECLARE @TagValue NVARCHAR(50) = '" + tagValue + "'" +
@" DECLARE @ProjectCode NVARCHAR(50) = '" + PP.ProjectCode + "'" +
@" UPDATE [DeviceSignalSimTree] SET [StartTime] = @StartTime,[KeepTime] = @KeepTime,[SequenceNo] = @SequenceNo,[TagValue] = @TagValue" +
@" WHERE [ID] = @ID";
DataAccess.ExecuteDataset(sql, PP.ConnectionStr, out DataSet ds, out string errorMessage);
}
/// <summary>
/// 删除 设备信号仿真任务
/// 2021.3.5
/// </summary>
/// <param name="deviceSignalSimCode"></param>
/// <param name="tagID"></param>
/// <param name="tagValue"></param>
/// <param name="startTime"></param>
/// <param name="keepTime"></param>
public static void Delete_DeviceSignalSimAlign(string id)
{
string sql =
@" DECLARE @ID INT = " + id + "" +
@" DECLARE @ProjectCode NVARCHAR(50) = '" + PP.ProjectCode + "'" +
@" DELETE FROM [DeviceSignalSimTree] WHERE [ID] = @ID";
DataAccess.ExecuteDataset(sql, PP.ConnectionStr, out DataSet ds, out string errorMessage);
}
/// <summary>
/// 查找信号仿真名称的数据
/// 2021.3.5
/// </summary>
/// <param name="deviceSignalSimName"></param>
/// <returns></returns>
public static DataTable Select_DeviceSignalSim(string pid)
{
// string sql =
//@" DECLARE @Pid NVARCHAR(50) = '" + pid + "'" +
//@" DECLARE @Varieties NVARCHAR(50) = '" + Type_DeviceSignalSimTree.Signal + "'" +
//@" DECLARE @ProjectCode NVARCHAR(50) = '" + PP.ProjectCode + "'" +
//@" SELECT A.[ID],A.[Code],A.[TagID],A.[TagValue],A.[StartTime],A.[KeepTime],A.[OperationTime],A.[ProjectCode]," +
//@" A.[TagName] as Name,A.TagFrom " +
//@" FROM [DeviceSignalSimTree] A " +
//@" WHERE A.[ProjectCode] = @ProjectCode AND A.[Pid] = @Pid AND A.[Varieties] = @Varieties" +
//@" ORDER BY A.[SequenceNo]";
DataTable dt = new DataTable();
string sql =
@" DECLARE @Pid NVARCHAR(50) = '" + pid + "'" +
@" DECLARE @Varieties NVARCHAR(50) = '" + Type_DeviceSignalSimTree.Signal + "'" +
@" DECLARE @ProjectCode NVARCHAR(50) = '" + PP.ProjectCode + "'" +
@" SELECT A.[ID],A.[Code],A.[TagID],A.[TagValue],A.[StartTime],A.[KeepTime],A.[OperationTime],A.[ProjectCode]," +
@" A.[TagName] as Name,A.TagFrom,A.OpName,A.TagIDCopyFrom " +
@" FROM [DeviceSignalSimTree] A " +
@" WHERE A.[Pid] = @Pid AND A.[Varieties] = @Varieties" +
@" ORDER BY A.[SequenceNo]";
DataAccess.ExecuteDataset(sql, PP.ConnectionStr, out DataSet ds, out string errorMessage);
if (ds.Tables.Count < 1) return dt;
return ds.Tables[0];
}
/// <summary>
/// 按照项目查询设备信号仿真,所有
/// 2021.3.4
/// 2021.6.23
/// llx
/// </summary>
/// <returns></returns>
public static DataTable Select_DeviceSignalSimTree()
{
DataTable dt = new DataTable();
try
{
string sql =
@" DECLARE @ProjectCode NVARCHAR(50) = '" + PP.ProjectCode + "'" +
@" SELECT [ID],[Code],[Pid],[Varieties],[Name],[TagID],[TagValue],[StartTime],[KeepTime],[SequenceNo] FROM [DeviceSignalSimTree]" +
@" --WHERE [ProjectCode] = @ProjectCode ";
DataAccess.ExecuteDataset(sql, PP.ConnectionStr, out DataSet ds, out string errorMessage);
dt = ds.Tables[0];
}
catch
{
}
return dt;
}
/// <summary>
/// 添加设备信号仿真
/// 2021.3.5
/// 2021.6.23
/// </summary>
/// <param name="actName"></param>
/// <returns></returns>
//public static void Add_DeviceSignalSimTree(string pid ,string varieties, string name, string tagID, int keepTime)
//{
// var tagValue = "1";
// var startTime = 0;
// var sequenceNo = -1;
// string sql =
// @" DECLARE @AddCode NVARCHAR(50) = '" + OutGUID.Get_CS_GUID() + "'" +
// @" DECLARE @Pid NVARCHAR(50) = '" + pid + "'" +
// @" DECLARE @Varieties NVARCHAR(50) = '" + varieties + "'" +
// @" DECLARE @Name NVARCHAR(50) = '" + name + "'" +
// @" DECLARE @TagID NVARCHAR(50) = '" + tagID + "'" +
// @" DECLARE @TagValue NVARCHAR(50) = '" + tagValue + "'" +
// @" DECLARE @StartTime NVARCHAR(50) = '" + startTime + "'" +
// @" DECLARE @KeepTime NVARCHAR(50) = '" + keepTime + "'" +
// @" DECLARE @SequenceNo NVARCHAR(50) = '" + sequenceNo + "'" +
// @" DECLARE @OperationTime NVARCHAR(50) = '" + DateTime.Now.ToString ("yyyy-MM-dd hh:mm:ss.fff") + "'" +
// @" DECLARE @ProjectCode NVARCHAR(50) = '" + PP.ProjectCode + "'" +
// @" INSERT INTO [DeviceSignalSimTree]([Code],[Pid],[Varieties],[Name],[TagID],[TagValue],[StartTime],[KeepTime],[SequenceNo],[OperationTime],[ProjectCode])" +
// @" VALUES(@AddCode,@Pid,@Varieties,@Name,@TagID,@TagValue,@StartTime,@KeepTime,@SequenceNo,@OperationTime,@ProjectCode)";
// ExecuteDataset(sql, PP.ConnectionStr, out DataSet ds, out string errorMessage);
//}
public static void Add_DeviceSignalSimTree(string pid, string varieties, string name, string tagID, int keepTime, string tagName = "", int tagFrom = 0,string opName="", string TagIDCopyFrom="")
{
var tagValue = "1";
var startTime = 0;
var sequenceNo = -1;
string sql =
@" DECLARE @AddCode NVARCHAR(50) = '" + OutGUID.Get_CS_GUID() + "'" +
@" DECLARE @Pid NVARCHAR(50) = '" + pid + "'" +
@" DECLARE @Varieties NVARCHAR(50) = '" + varieties + "'" +
@" DECLARE @Name NVARCHAR(50) = '" + name + "'" +
@" DECLARE @TagID NVARCHAR(50) = '" + tagID + "'" +
@" DECLARE @TagValue NVARCHAR(50) = '" + tagValue + "'" +
@" DECLARE @StartTime NVARCHAR(50) = '" + startTime + "'" +
@" DECLARE @KeepTime NVARCHAR(50) = '" + keepTime + "'" +
@" DECLARE @SequenceNo NVARCHAR(50) = '" + sequenceNo + "'" +
@" DECLARE @OperationTime NVARCHAR(50) = '" + DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss.fff") + "'" +
@" DECLARE @ProjectCode NVARCHAR(50) = '" + PP.ProjectCode + "'" +
@" DECLARE @tagName NVARCHAR(50) = '" + tagName + "'" +
@" DECLARE @tagFrom INT = " + tagFrom +
@" DECLARE @OpName NVARCHAR(50) = '" + opName + "'" +
@" DECLARE @TagIDCopyFrom NVARCHAR(50) = '" + TagIDCopyFrom + "'" +
@" INSERT INTO [DeviceSignalSimTree]([Code],[Pid],[Varieties],[Name],[TagID],[TagValue],[StartTime],[KeepTime],[SequenceNo],[OperationTime],[ProjectCode],[TagName],[TagFrom],[OpName],[TagIDCopyFrom])" +
@" VALUES(@AddCode,@Pid,@Varieties,@Name,@TagID,@TagValue,@StartTime,@KeepTime,@SequenceNo,@OperationTime,@ProjectCode,@tagName,@tagFrom,@OpName,@TagIDCopyFrom)";
DataAccess.ExecuteDataset(sql, PP.ConnectionStr, out DataSet ds, out string errorMessage);
}
/// <summary>
/// 删除设备信号仿真 及 设备信号仿真所有
/// 2021.3.5
/// </summary>
/// <param name="actCode"></param>
/// <returns></returns>
public static void Delete_DeviceSignalSimTree(string code)
{
//string sql =
// @" DECLARE @Code NVARCHAR(50) = '" + code + "'" +
// @" DECLARE @ProjectCode NVARCHAR(50) = '" + PP.ProjectCode + "'" +
// @" DELETE FROM [DeviceSignalSimTree] WHERE [ProjectCode] = @ProjectCode AND [Code] = @Code";
string sql =
@" DECLARE @Code NVARCHAR(50) = '" + code + "'" +
@" DECLARE @ProjectCode NVARCHAR(50) = '" + PP.ProjectCode + "'" +
@" DELETE FROM [DeviceSignalSimTree] WHERE [Code] = @Code";
DataAccess.ExecuteDataset(sql, PP.ConnectionStr, out DataSet ds, out string errorMessage);
}
/// <summary>
/// 修改设备信号仿真树名称
/// 2021.3.5
/// </summary>
/// <param name="craftCode"></param>
/// <param name="craftName"></param>
public static void Update_DeviceSignalSimName(string code, string name)
{
//string sql =
// @" DECLARE @Code NVARCHAR(50) = '" + code + "'" +
// @" DECLARE @Name NVARCHAR(50) = '" + name + "'" +
// @" DECLARE @ProjectCode NVARCHAR(50) = '" + PP.ProjectCode + "'" +
// @" UPDATE [DeviceSignalSimTree] SET [Name] = @Name" +
// @" WHERE [ProjectCode] = @ProjectCode AND [Code] = @Code";
string sql =
@" DECLARE @Code NVARCHAR(50) = '" + code + "'" +
@" DECLARE @Name NVARCHAR(50) = '" + name + "'" +
@" DECLARE @ProjectCode NVARCHAR(50) = '" + PP.ProjectCode + "'" +
@" UPDATE [DeviceSignalSimTree] SET [Name] = @Name" +
@" WHERE [Code] = @Code";
DataAccess.ExecuteDataset(sql, PP.ConnectionStr, out DataSet ds, out string errorMessage);
}
}
}
}