using DataLinkMesWork; using Global; using System; using System.Collections.Generic; using System.Data; using static DtWebApiDT.DataAccess; //using static SqlManage.ExecSql; /// /// /// namespace DTTest { /// /// 对于数据库的操作 /// public partial class SqlOperation { /// /// 设备信号仿真 /// public class SqlDeviceSignalSim { /// /// 更新 设备信号仿真任务 开始时间 /// 2021.3.5 /// 2021.6.23 /// /// /// 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); } /// /// 删除 设备信号仿真任务 /// 2021.3.5 /// /// /// /// /// /// 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); } /// /// 查找信号仿真名称的数据 /// 2021.3.5 /// /// /// 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]; } /// /// 按照项目查询设备信号仿真,所有 /// 2021.3.4 /// 2021.6.23 /// llx /// /// 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; } /// /// 添加设备信号仿真 /// 2021.3.5 /// 2021.6.23 /// /// /// //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); } /// /// 删除设备信号仿真 及 设备信号仿真所有 /// 2021.3.5 /// /// /// 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); } /// /// 修改设备信号仿真树名称 /// 2021.3.5 /// /// /// 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); } } } }