IOManager.cs 5.5 KB
using OnlineStore.Common;
using OnlineStore.LoadCSVLibrary;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace OnlineStore.DeviceLibrary
{
    public abstract class IOManager
    {
        public static IOManager instance = null;

        public abstract void ConnectionIOList(List<string> dIODeviceNameList);


        #region KNDIO
        public static void IOMove(string ioType, IO_VALUE ioValue, int subType)
        {
            ConfigIO configIo = GetDO(ioType, subType);
            if (configIo != null)
            {
                instance.WriteSingleDO(configIo.IO_IP, 0, configIo.GetIOAddr(), ioValue);
                Thread.Sleep(1);
            }
            else
            {
                LogUtil.error("未找到DO,[" + ioType + "][" + subType + "]");
            }
        }

        public static IO_VALUE IOValue(string ioType, int subType)
        {
            IO_VALUE ioValue = IO_VALUE.LOW;
            ConfigIO configIo = GetDI(ioType, subType);
            if (configIo == null)
            {
                configIo = GetDO(ioType, subType);
            }

            if (configIo != null)
            {
                if (configIo.ProType.Equals(ConfigItemType.DI))
                {

                    ioValue = instance.GetDIValue(configIo.IO_IP, 0, configIo.GetIOAddr());
                }
                else
                {
                    ioValue = instance.GetDOValue(configIo.IO_IP, 0, configIo.GetIOAddr());
                }
            }
            else
            {
                LogUtil.error("未找到IO[" + ioType + "][" + subType + "]");
            }
            return ioValue;
        }
        public static IO_VALUE DOValue(string ioType, int subType = 0)
        {
            IO_VALUE ioValue = IO_VALUE.LOW;
            ConfigIO configIo = GetDO(ioType, subType);

            if (configIo != null)
            {
                ioValue = instance.GetDOValue(configIo.IO_IP, 0, configIo.GetIOAddr());
            }
            else
            {
                LogUtil.error("没有DO=" + ioType);
            }
            return ioValue;
        }
        private static ConfigIO GetDI(string ioType, int subType)
        {
            ConfigIO configIo = null;
            if (subType <= 0)
            {
                if (StoreManager.Config.DIList.ContainsKey(ioType))
                {
                    return StoreManager.Config.DIList[ioType];
                }
            }
            else
            {
                if (StoreManager.AllConfigMap.ContainsKey(subType))
                {
                    string newType = ioType.Replace("SW1_", "SW_").Replace("SW2_", "SW_").Replace("SW3_", "SW_").Replace("SW4_", "SW_");
                    if (StoreManager.AllConfigMap[subType].DIList.ContainsKey(newType))
                    {
                        return StoreManager.AllConfigMap[subType].DIList[newType];
                    }
                }

            }
            return configIo;
        }
        private static ConfigIO GetDO(string ioType, int subType)
        {
            ConfigIO configIo = null;
            if (subType <= 0)
            {
                if (StoreManager.Config.DOList.ContainsKey(ioType))
                {
                    return StoreManager.Config.DOList[ioType];
                }
            }
            else
            {
                if (StoreManager.AllConfigMap.ContainsKey(subType))
                {
                    string newType = ioType.Replace("SW1_", "SW_").Replace("SW2_", "SW_").Replace("SW3_", "SW_").Replace("SW4_", "SW_");
                    if (StoreManager.AllConfigMap[subType].DOList.ContainsKey(newType))
                    {
                        return StoreManager.AllConfigMap[subType].DOList[newType];
                    }
                }

            }
            return configIo;
        }
        public static void CloseDeviceDO(List<ConfigIO> DoList)
        {
            foreach (ConfigIO io in DoList)
            {
                instance.WriteSingleDO(io.IO_IP, 0, io.GetIOAddr(), IO_VALUE.LOW);
                Thread.Sleep(60);
            }
        }
        public static void CloseDeviceDO(int subType)
        {
            List<ConfigIO> DoList = new List<ConfigIO>();
            if (subType <= 0)
            {
                DoList = new List<ConfigIO>(StoreManager.Config.DOList.Values);
            }
            else
            {
                if (StoreManager.AllConfigMap.ContainsKey(subType))
                {
                    DoList = new List<ConfigIO>(StoreManager.AllConfigMap[subType].DOList.Values);
                }
            }
            CloseDeviceDO(DoList);
        }
        #endregion
        public static void Init()
        {
            instance = new AIOBOXManager();
        }
        public abstract void ReadAllDI(string deviceName, byte slaveId);

        public abstract void ReadAllDO(string deviceName, byte slaveId);

        public abstract void WriteSingleDO(string deviceName, byte slaveId, ushort index, IO_VALUE value, int time);

        public abstract void WriteSingleDO(string deviceName, byte slaveId, ushort index, IO_VALUE value);


        public abstract IO_VALUE GetDIValue(string deviceName, byte slaveID, ushort v);


        public abstract IO_VALUE GetDOValue(string deviceName, byte slaveID, ushort v);


        public abstract IO_VALUE GetIOValue(ConfigIO configIO);

        public abstract void CloseAllDO();


        public abstract void CloseAllConnection();

    }
}