分支自 SuZhouGuanHong/TaiYuanTaiZhong

huanghongfeng
2024-07-19 bb929bd0809eefc1108dd779846ff07d997f7ef0
´úÂë¹ÜÀí/PCS/WCS_Server/WIDESEA_WCS/WCSClient/DBExtension.cs
@@ -1,6 +1,8 @@
using System;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.CompilerServices;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Entity.DomainModels;
@@ -18,43 +20,98 @@
        /// <exception cref="Exception"></exception>
        public static object Read(dt_plcinfodetail detail, PLCClient client)
        {
                if (detail.plcdetail_valtype == typeof(int).Name.ToLower())//4字节,有符号类型
            if (detail.plcdetail_valtype == typeof(int).Name.ToLower())//4字节,有符号类型
            {
                return (client.Read<int>(detail.plcdetail_db + "." + detail.plcdetail_value));
            }
            else if (detail.plcdetail_valtype == typeof(uint).Name.ToLower())//4字节,无符号类型
            {
                return (client.Read<uint>(detail.plcdetail_db + "." + detail.plcdetail_value));
            }
            else if (detail.plcdetail_valtype == typeof(short).Name.ToLower())//2字节,有符号类型,最常用
            {
                return (client.Read<short>(detail.plcdetail_db + "." + detail.plcdetail_value));
            }
            else if (detail.plcdetail_valtype == typeof(ushort).Name.ToLower())//2字节,无符号类型
            {
                return (client.Read<ushort>(detail.plcdetail_db + "." + detail.plcdetail_value));
            }
            else if (detail.plcdetail_valtype == typeof(float).Name.ToLower())//浮点型
            {
                return (client.Read<float>(detail.plcdetail_db + "." + detail.plcdetail_value));
            }
            else if (detail.plcdetail_valtype == typeof(bool).Name.ToLower())
            {
                return (client.Read<bool>(detail.plcdetail_db + "." + detail.plcdetail_value));
            }
            else if (detail.plcdetail_valtype == typeof(byte).Name.ToLower())//字节
            {
                return (client.Read<byte>(detail.plcdetail_db + "." + detail.plcdetail_value));
            }
            else if (detail.plcdetail_valtype == typeof(string).Name.ToLower())//字符串
            {
                return (client.Read<string>(detail.plcdetail_db + "." + detail.plcdetail_value, detail.plcdetail_len.GetValueOrDefault()));
            }
            else
            {
                throw new Exception($"【{detail.plcdetail_remark}】,DB地址{detail.plcdetail_db + "." + detail.plcdetail_value},未定义数据类型{detail.plcdetail_valtype}");
            }
        }
        /// <summary>
        ///
        /// </summary>
        /// <param name="detail"></param>
        /// <param name="client"></param>
        /// <param name="value"></param>
        /// <returns></returns>
        public static object Read(DBItemGroup itemGroup, PLCClient client)
        {
            //PLCClient client = PLCClient.Clients.Where(x => x.PLCName == itemGroup.name).FirstOrDefault();
            if (client == null)
            {
                throw new Exception($"未找到{itemGroup.name}连接对象");
            }
            else
            {
                if (itemGroup.dataType == typeof(int).Name.ToLower())//4字节,有符号类型
                {
                    return (client.Read<int>(detail.plcdetail_db+"."+detail.plcdetail_value));
                    return (client.Read<int>(itemGroup.dbAddress));
                }
                else if (detail.plcdetail_valtype == typeof(uint).Name.ToLower())//4字节,无符号类型
                else if (itemGroup.dataType == typeof(uint).Name.ToLower())//4字节,无符号类型
                {
                    return (client.Read<uint>(detail.plcdetail_db + "." + detail.plcdetail_value));
                    return (client.Read<uint>(itemGroup.dbAddress));
                }
                else if (detail.plcdetail_valtype == typeof(short).Name.ToLower())//2字节,有符号类型,最常用
                else if (itemGroup.dataType == typeof(short).Name.ToLower())//2字节,有符号类型,最常用
                {
                    return (client.Read<short>(detail.plcdetail_db + "." + detail.plcdetail_value));
                    return (client.Read<short>(itemGroup.dbAddress));
                }
                else if (detail.plcdetail_valtype == typeof(ushort).Name.ToLower())//2字节,无符号类型
                else if (itemGroup.dataType == typeof(ushort).Name.ToLower())//2字节,无符号类型
                {
                    return (client.Read<ushort>(detail.plcdetail_db + "." + detail.plcdetail_value));
                    return (client.Read<ushort>(itemGroup.dbAddress));
                }
                else if (detail.plcdetail_valtype == typeof(float).Name.ToLower())//浮点型
                else if (itemGroup.dataType == typeof(float).Name.ToLower())//浮点型
                {
                    return (client.Read<float>(detail.plcdetail_db + "." + detail.plcdetail_value));
                    return (client.Read<float>(itemGroup.dbAddress));
                }
                else if (detail.plcdetail_valtype == typeof(bool).Name.ToLower())
                else if (itemGroup.dataType == typeof(bool).Name.ToLower())
                {
                    return (client.Read<bool>(detail.plcdetail_db + "." + detail.plcdetail_value));
                    return (client.Read<bool>(itemGroup.dbAddress));
                }
                else if (detail.plcdetail_valtype == typeof(byte).Name.ToLower())//字节
                else if (itemGroup.dataType == typeof(byte).Name.ToLower())//字节
                {
                    return (client.Read<byte>(detail.plcdetail_db + "." + detail.plcdetail_value));
                    return (client.Read<byte>(itemGroup.dbAddress));
                }
                else if (detail.plcdetail_valtype == typeof(string).Name.ToLower())//字符串
                else if (itemGroup.dataType == typeof(string).Name.ToLower())//字符串
                {
                    return (client.Read<string>(detail.plcdetail_db + "." + detail.plcdetail_value, detail.plcdetail_len.GetValueOrDefault()));
                    return (client.Read<string>(itemGroup.dbAddress, itemGroup.dataLen.GetValueOrDefault()));
                }
                else
                {
                    throw new Exception($"【{detail.plcdetail_remark}】,DB地址{detail.plcdetail_db + "." + detail.plcdetail_value},未定义数据类型{detail.plcdetail_valtype}");
                    throw new Exception($"【{itemGroup.name}】,DB地址{itemGroup.dbAddress},未定义数据类型{itemGroup.dataType}");
                }
            }
        }
    }
}