CZ_Power/TcpGroup.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System.Collections.Generic;
using System.Data;
using System.Threading;
using ComLibiary;
using System;

namespace CZ_Power
{
    /// <summary>
    /// 以太网初始化类
    /// </summary>
    public class TcpGroup
    {
        #region 字段
        private static List<ClassGroup> listClassGroup = new List<ClassGroup>();
        #endregion

        #region 属性
        /// <summary>
        /// 以太网A类设备集合
        /// </summary>
        internal static List<ClassGroup> ListClassGroup
        {
            get { return TcpGroup.listClassGroup; }
            set { TcpGroup.listClassGroup = value; }
        }
        #endregion

        #region 方法
        /// <summary>
        /// 初始化以太网
        /// </summary>
        public static void InitialTcp(DatabaseType type, string workname)
        {
            switch (type)
            {
                case DatabaseType.SQLServer:
                    #region 数据库初始化
                    //读取以太网设备列表
                    DataTable dtTcpGroup = DataBaseManage.ReadDataDeCom(type);//SELECT [ID],[IP],[GpName],[Decount],[DePars],[Codes] FROM [CZPower].[dbo].[PowerUnit]
                    int comcount = dtTcpGroup.Rows.Count;//以太网设备个数
                    for (int i = 0; i < comcount; i++)
                    {
                        string DeId =dtTcpGroup.Rows[i][0].ToString();//ID
                        string TcpIp = (string)dtTcpGroup.Rows[i][1];//IP
                        string TcpPort = workname == "主机" ? "950" : "951";
                        string TcpGpName = (string)dtTcpGroup.Rows[i][2];//GpName
                        int TcpDeCount = (int)dtTcpGroup.Rows[i][3];//Decount
                        string TcpDeNames = (string)dtTcpGroup.Rows[i][4];//DePars
                        string TcpCodes = (string)dtTcpGroup.Rows[i][5];//Codes
                        ClassData.MsgAdd("正在初始化 " + TcpIp);
                        ClassGroup dea = new ClassGroup(TcpIp, TcpPort, DeId, TcpGpName, TcpDeCount, TcpDeNames, TcpCodes);
                        dea.IsActiveTcp = true;
                        listClassGroup.Add(dea);
                    }
                    StartTcp();
                    #endregion
                    break;
                case DatabaseType.XML:
                    break;