using OpcData;
using System;
using SystemFramework;
using System.Threading;
using System.Collections;
using System.Collections.Specialized;
using MisDataFunction;

namespace MisDataName
{
    //public partial class ___ { }
    public partial class MisData
    {
      
        private void MisData_SyncRawData()
        {

            /*
SELECT 
 [TagID]
,[TagName]
,[工位号]
,[数据来源]
,[IP]
,[TagTypeID]
,[TagLong]
,[DbName]
,[变量类型]
,[变量地址]
,[变量其它]
,[演示偏移]
,[列位置]
,[测量位置]
,[测量项目]
,[测量单位]
,[变量类型代码]
,[变量类型名称]
,[机体类型]
,[线体类型]
,[TagAdr]
,[TagAdrDemo]
,[是否启用]
,[连接名称]
,[OpcServer_MIS]
,[OpcServer_OPNAME]
,[变量特点]
,[是否监控]
,[变量排序]
,[工序能力]
,[监控属性代码]
,[测量位置短]
FROM [MES_基本变量_原始数据]


SELECT
 [数值代码]
,[TagID]
,[理论值]
,[值上限]
,[值下限]
,[发动机型号代码]
,[是否启用]
,[操作时间]
FROM [MES_基本数据_测量范围]




TagID
TagName
工位号
数据来源
IP
TagTypeID
TagLong
DbName
变量类型
变量地址

变量其它
演示偏移
列位置
测量位置
测量项目
测量单位
变量类型代码
变量类型名称
机体类型
线体类型

TagAdr
TagAdrDemo
是否启用
监控组
监控时间间隔
OpcServer_OPNAME
变量特点
是否监控
变量排序
工序能力

监控属性代码
测量位置短
上限值
下限值
理论值
IsGoodBad
IsSaveToSql
IsWebSocket

             */

            var sql_TRUNCATE = @"
TRUNCATE TABLE [MES_基本变量_原始数据]
TRUNCATE TABLE [MES_基本数据_测量范围]

";
            DataLinkMesWork.SQLCommon.ExecuteSql(sql_TRUNCATE, ConnectionString_MES, out string err_TRUNCATE);


            var dt = MesWork.PlcLinkForm.dt_BasicData.Copy();
            for (int i = 0; i < dt.Rows .Count ; i++)
            {
                var TagID = dt.Rows[i]["TagID"].ToString();
                var TagName = dt.Rows[i]["TagName"].ToString();
                var 工位号 = dt.Rows[i]["工位号"].ToString();
                var 数据来源 = dt.Rows[i]["数据来源"].ToString();
                var IP = dt.Rows[i]["IP"].ToString();
                var TagTypeID = dt.Rows[i]["TagTypeID"].ToString();
                var TagLong = dt.Rows[i]["TagLong"].ToString();
                var DbName = dt.Rows[i]["DbName"].ToString();
                var 变量类型 = dt.Rows[i]["变量类型"].ToString();
                var 变量地址 = dt.Rows[i]["变量地址"].ToString();

                var 变量其它 = dt.Rows[i]["变量其它"].ToString();
                var 演示偏移 = dt.Rows[i]["演示偏移"].ToString();
                var 列位置 = dt.Rows[i]["列位置"].ToString();
                var 测量位置 = dt.Rows[i]["测量位置"].ToString();
                var 测量项目 = dt.Rows[i]["测量项目"].ToString();
                var 测量单位 = dt.Rows[i]["测量单位"].ToString();
                var 变量类型代码 = dt.Rows[i]["变量类型代码"].ToString();
                var 变量类型名称 = dt.Rows[i]["变量类型名称"].ToString();
                var 机体类型 = dt.Rows[i]["机体类型"].ToString();
                var 线体类型 = dt.Rows[i]["线体类型"].ToString();

                var TagAdr = dt.Rows[i]["TagAdr"].ToString();
                var TagAdrDemo = dt.Rows[i]["TagAdrDemo"].ToString();
                var 是否启用 = dt.Rows[i]["是否启用"].ToString();
                var 监控组 = dt.Rows[i]["监控组"].ToString();
                var 监控时间间隔 = dt.Rows[i]["监控时间间隔"].ToString();
                var OpcServer_OPNAME = dt.Rows[i]["OpcServer_OPNAME"].ToString();
                var 变量特点 = dt.Rows[i]["变量特点"].ToString();
                var 是否监控 = dt.Rows[i]["是否监控"].ToString();
                var 变量排序 = dt.Rows[i]["变量排序"].ToString();
                var 工序能力 = dt.Rows[i]["工序能力"].ToString();

                var 监控属性代码 = dt.Rows[i]["监控属性代码"].ToString();
                var 测量位置短 = dt.Rows[i]["测量位置短"].ToString();
                var 上限值 = dt.Rows[i]["上限值"].ToString();
                var 下限值 = dt.Rows[i]["下限值"].ToString();
                var 理论值 = dt.Rows[i]["理论值"].ToString();
                var IsGoodBad = dt.Rows[i]["IsGoodBad"].ToString();
                var IsSaveToSql = dt.Rows[i]["IsSaveToSql"].ToString();
                var IsWebSocket = dt.Rows[i]["IsWebSocket"].ToString();

                var sql_1 = @"
INSERT into [MES_基本变量_原始数据](
[TagID]
,[TagName]
,[工位号]
,[数据来源]
,[IP]
,[TagTypeID]
,[TagLong]
,[DbName]
,[变量类型]
,[变量地址]
,[变量其它]
,[演示偏移]
,[列位置]
,[测量位置]
,[测量项目]
,[测量单位]
,[变量类型代码]
,[变量类型名称]
,[机体类型]
,[线体类型]
,[TagAdr]
,[TagAdrDemo]
,[是否启用]
,[连接名称]
,[OpcServer_MIS]
,[OpcServer_OPNAME]
,[变量特点]
,[是否监控]
,[变量排序]
,[工序能力]
,[监控属性代码]
,[测量位置短]

)VALUes("

+ "'" + TagID + "'" 
+",'"+TagName + "'" 
+",'"+工位号 + "'" 
+",'"+数据来源 + "'" 
+",'"+IP + "'" 
+","+TagTypeID
+","+TagLong
+",'"+DbName + "'" 
+",'"+ 变量类型 + "'"
+ ","+变量地址
+",'"+变量其它 + "'"
+ ","+演示偏移
+","+列位置
+",'"+测量位置 + "'" 
+",'"+测量项目 + "'" 
+",'"+测量单位 + "'" 
+","+变量类型代码
+",'"+变量类型名称 + "'" 
+","+机体类型
+",'"+线体类型 + "'"
+ ",'"+TagAdr + "'" 
+",'"+TagAdrDemo + "'" 
+","+是否启用
+",'"+IP + "'" 
+","+ OpcServer_OPNAME
+ ","+OpcServer_OPNAME
+","+变量特点
+","+是否监控
+","+变量排序
+","+工序能力
+","+监控属性代码
+",'"+测量位置短+"'"

+")" ;

                var sql_2 = @"
INSERT INTO [MES_基本数据_测量范围](
[TagID]
,[理论值]
,[值上限]
,[值下限]
,[发动机型号代码]
,[是否启用]
,[操作时间]

)VALUES("

+"'"+ TagID + "'"
+ ","+理论值
+","+ 上限值
+ ","+ 下限值
+ ","+ 监控属性代码
+ ","+是否启用
+","+"getdate()"

+")";

                var sql_INSERT = sql_1 + sql_2;
                DataLinkMesWork.SQLCommon.ExecuteSql(sql_INSERT, ConnectionString_MES, out string err_INSERT);

            }



        }








    }

}