RFID更改为tcp模式。

source/Common/Setting_Init.cs

@@ -35,6 +35,6 @@ namespace OnlineStore.Common
         public static string AgvServerIp = "AgvServerIp";
         public static string AgvServerIp = "AgvServerIp";
 
 
         public static string Agv_Log_Open = "Agv_Log_Open";
         public static string Agv_Log_Open = "Agv_Log_Open";
-
+        public static string RfidServer_Port = "RfidServer_Port";
     }
     }
 }
 }

source/DeviceLibrary/DeviceLibrary.csproj

@@ -39,6 +39,9 @@
     <Reference Include="Asa.IOModule.AIOBOX">
     <Reference Include="Asa.IOModule.AIOBOX">
       <HintPath>..\..\dll\Asa.IOModule.AIOBOX.dll</HintPath>
       <HintPath>..\..\dll\Asa.IOModule.AIOBOX.dll</HintPath>
     </Reference>
     </Reference>
+    <Reference Include="Asa.RFID">
+      <HintPath>..\..\dll\Asa.RFID.dll</HintPath>
+    </Reference>
     <Reference Include="Client">
     <Reference Include="Client">
       <HintPath>..\..\dll\Client.dll</HintPath>
       <HintPath>..\..\dll\Client.dll</HintPath>
     </Reference>
     </Reference>
@@ -81,9 +84,7 @@
     <Compile Include="bean\StoreStep.cs">
     <Compile Include="bean\StoreStep.cs">
       <SubType>Code</SubType>
       <SubType>Code</SubType>
     </Compile>
     </Compile>
-    <Compile Include="RFID\RFIDAuto.cs" />
-    <Compile Include="RFID\RFIDAutoReader.cs" />
-    <Compile Include="RFID\RFIDManager.cs" />
+    <Compile Include="RFIDManager.cs" />
   </ItemGroup>
   </ItemGroup>
   <ItemGroup>
   <ItemGroup>
     <ProjectReference Include="..\Common\Common.csproj">
     <ProjectReference Include="..\Common\Common.csproj">

source/DeviceLibrary/RFIDManager.cs

+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 ();
+        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);
+            }
+            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;
+        }
+    }
+}