RFIDManager.cs 3.5 KB
using Asa.RFID;
using OnlineStore.Common;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace OnlineStore.DeviceLibrary
{
    public class RFIDManager
    {
        private static ReadAll readAll =new ReadAll ("TheRFID");
        private static bool IsOpen = false;
       // private static ConcurrentDictionary<string, string> LastRfidMap = new ConcurrentDictionary<string, string>();
        public static void Open(string[] iparray)
        {
            if (IsOpen)
            {
                return;
            }
            try
            {
                int port = ConfigAppSettings.GetIntValue(Setting_Init.RfidServer_Port);
                if (port <= 0)
                {
                    port = 13001;
                }
                //   readAll.Received += ReadAll_Received;
             //   readAll.Log += ReadAll_Log;
                LogUtil.info("RFID Server Open,port=" + port);
                readAll.Start(port);
                IsOpen = true;
            }
            catch (Exception ex)
            {
                LogUtil.error("Open 出错:" + ex.ToString());
            }
        }
        private static string lastStr = "";
      
        private static void ReadAll_Log(string ip, string log)
        {
            string str = "RFID : [" + ip + "] " + log;
            if (lastStr.Equals(str))
            {
                return;
            }
            LogUtil.info(str);
            lastStr = str;
        }

        public static RFIDData ReadRFID(string ip, bool isClear = false)
        {
            try
            {
                if (String.IsNullOrEmpty(ip).Equals(false))
                {
                    string outValue = readAll.Read(ip);
                   
                    if (isClear)
                    {
                        readAll.Clear(ip); 
                    }

                    RFIDData data = new RFIDData(outValue);
                    return data;
                }
            }
            catch (Exception ex)
            {
                LogUtil.error("ReadRFID[" + ip + "] [" + isClear + "] 出错:" + ex.ToString());
            }
            return new RFIDData();
        }


        public static void Close()
        {
            try
            {
                readAll.Stop();
            }
            catch (Exception ex)
            {
                LogUtil.error("关闭RFID出错:" + ex.ToString());
            }
        }

    }
    public class RFIDData
    {
        public string StrData = "";
        public RFIDData(string data = "00")
        {
            if (String.IsNullOrEmpty(data))
            {
                data = "00";
            }
            this.StrData = data;
        }

        public string NumStr()
        {
            return StrData;
        }

        internal static bool IsRealRfid(string shelfRfid)
        {
            //判断料架号是否是真实的料架号
            if (shelfRfid.StartsWith("C") || shelfRfid.StartsWith("D"))
            {
                int num = -1;
                try
                {
                    num = Convert.ToInt32(shelfRfid.Substring(1, shelfRfid.Length - 1));
                }
                catch (Exception ex)
                {
                }
                if (num > 0)
                {
                    return true;
                }
            }
            return false;
        }
    }
}