指令化登录,心跳

DotNettyFrom/DotNettyFrom.csproj

     <Compile Include="form\ItemManagerForm.Designer.cs">
       <DependentUpon>ItemManagerForm.cs</DependentUpon>
     </Compile>
+    <Compile Include="generatecmd\CmdGenetor.cs" />
     <Compile Include="MainForm.cs">
       <SubType>Form</SubType>
     </Compile>
   <ItemGroup>
     <None Include="App.config" />
   </ItemGroup>
-  <ItemGroup />
+  <ItemGroup>
+    <Folder Include="cmdparser\" />
+  </ItemGroup>
   <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
 </Project>

DotNettyFrom/MainForm.cs

 using DotNettyFrom.db;
 using DotNettyFrom.dialog;
 using DotNettyFrom.form;
+using DotNettyFrom.generatecmd;
 using DotNettyFrom.netty;
 using DotNettyFrom.util;
 
             Task startNew = Task.Factory.StartNew(() =>
             {
                 _nettyClient = new NettyClient();
-                _nettyClient.StartNetty(host, port);
+                _nettyClient.StartNetty(host, port, null);
             });
         }
 
 
             Task startNew = Task.Factory.StartNew(() =>
             {
+                string loginCmd = CmdGenetor.GetInstance().SetDeviceId(TbDeviceId.Text.Trim())
+                    .GetLoginCmd(TbCCID.Text.Trim());
                 _nettyClient = new NettyClient();
-                _nettyClient.StartNetty(host, port);
+                _nettyClient.StartNetty(host, port, loginCmd);
             });
         }
 
             int index = LBLogShow.SelectedIndex;
             if (index >= 0 && index < LBLogShow.Items.Count)
             {
+                UIInfoModel uiInfoModel = LBLogShow.SelectedItem as UIInfoModel;
             }
         }
 

DotNettyFrom/config/SystemConfig.cs

         public static int FunctionCodeStartPos = 18;
         public static int FunctionCodeLength = 2;
 
-        public static int ReaderIdleTimeSeconds = 30;
-        public static int WriterIdleTimeSeconds = 35;
+        public static int ReaderIdleTimeSeconds = 5;
+        public static int WriterIdleTimeSeconds = 5;
         public static int AllIdleTimeSeconds = 25;
 
 

DotNettyFrom/generatecmd/CmdGenetor.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using DotNetty.Handlers.Timeout;
+using DotNettyFrom.util;
+
+namespace DotNettyFrom.generatecmd
+{
+    public class CmdGenetor
+    {
+        public static CmdGenetor Instance = new CmdGenetor();
+        public string DeviceId { get; set; }
+
+
+        public static CmdGenetor GetInstance()
+        {
+            return Instance;
+        }
+
+        public CmdGenetor SetDeviceId(string deviceId)
+        {
+            this.DeviceId = deviceId;
+            return this;
+        }
+
+        private CmdGenetor()
+        {
+        }
+
+
+        public string GetLoginCmd(string ccid)
+        {
+            string cmd = DeviceId + "820014" + ccid;
+            cmd = "7e7e7e" + CmdUtil.CalcCrcCode(cmd);
+            return cmd;
+        }
+
+        public string GetHeartbeat()
+        {
+            //7e7e7e00000000000184000085
+            string cmd = DeviceId + "840000";
+            cmd = "7e7e7e" + CmdUtil.CalcCrcCode(cmd);
+            return cmd;
+        }
+    }
+}

DotNettyFrom/netty/NettyClient.cs

 using DotNetty.Transport.Channels.Sockets;
 using DotNettyFrom.common;
 using DotNettyFrom.config;
+using DotNettyFrom.generatecmd;
 using DotNettyFrom.util;
 
 namespace DotNettyFrom.netty
     {
         private MultithreadEventLoopGroup _group;
         private NettyClientHandler _clientHandler;
-        private static bool _isSendLoginCmd = true;
+        private static string LoginCmd = null;
 
-        public void StartNetty(string host, int port, bool isSendLoginCmd = true)
+        public void StartNetty(string host, int port, string loginCmd)
         {
-            _isSendLoginCmd = isSendLoginCmd;
+            LoginCmd = loginCmd;
             IPAddress hostIp = IPAddress.Parse(host);
             RunClientAsync(hostIp, port);
             DataModel.ReceCollection.Add(new UIInfoModel("StartNetty:开始尝试连接").setSendType(SystemConfig.DebugType));
                 DataModel.ReceCollection.Add(new UIInfoModel("ChannelActive:连接成功").setAction(1)
                     .setSendType(SystemConfig.DebugType));
 
-                if (_isSendLoginCmd)
+                if (LoginCmd != null)
                 {
                     //发送登录指令
-                    IByteBuffer cmd =
-                        AryUtil.Hex2IByteBuffer("7e7e7e0000000000018200143839383630324731313931353530333339393137e3");
+                    IByteBuffer cmd = AryUtil.Hex2IByteBuffer(LoginCmd);
                     context.WriteAndFlushAsync(cmd);
-                    DataModel.ReceCollection.Add(
-                        new UIInfoModel("发送登录", "7e7e7e0000000000018200143839383630324731313931353530333339393137e3")
-                            .setAction(1).setSendType(SystemConfig.SendType));
+                    DataModel.ReceCollection.Add(new UIInfoModel("发送登录", LoginCmd)
+                        .setAction(1).setSendType(SystemConfig.SendType));
                 }
             }
 
                     string recCmd = AryUtil.ByteBuffer2Hex(buffer);
                     DataModel.ReceCollection.Add(new UIInfoModel("收到", recCmd));
                 }
+                else
+                {
+                    Console.WriteLine("Other ChannelRead");
+                }
             }
 
-            public override void ChannelReadComplete(IChannelHandlerContext context)
-            {
-                base.ChannelReadComplete(context);
-            }
 
             public override void UserEventTriggered(IChannelHandlerContext context, object evt)
             {
-                base.UserEventTriggered(context, evt);
+                IdleStateEvent state = (IdleStateEvent) evt;
+
+
+                if (state == IdleStateEvent.ReaderIdleStateEvent)
+                {
+                }
+                else if (state == IdleStateEvent.WriterIdleStateEvent)
+                {
+                    string hb = CmdGenetor.GetInstance().GetHeartbeat();
+                    context.Channel.WriteAndFlushAsync(AryUtil.Hex2IByteBuffer(hb));
+                    DataModel.ReceCollection.Add(new UIInfoModel("发送", hb).setSendType(SystemConfig.SendType));
+                }
+                else
+                {
+                }
             }
 
             public override void ExceptionCaught(IChannelHandlerContext context, Exception exception)

DotNettyFrom/util/CmdUtil.cs

             int res = Hex2Dec(hex);
             return FrontWithZero(Convert.ToString(res, 2), 8);
         }
+
+        public static string CalcCrcCode2(string str)
+        {
+            List<string> list = new List<string>();
+            for (int i = 0; i < str.Length; i += 2)
+            {
+                list.Add(str.Substring(i, 2));
+            }
+
+            int result = 0;
+            for (int i = 0; i < list.Count(); i++)
+            {
+                result ^= Hex2Dec(list[i]);
+            }
+            return FrontWithZero(Dec2Hex(result), 2);
+        }
+
+
+        public static string CalcCrcCode(string str)
+        {
+            List<string> list = new List<string>();
+            for (int i = 0; i < str.Length; i += 2)
+            {
+                list.Add(str.Substring(i, 2));
+            }
+
+            int result = 0;
+            for (int i = 0; i < list.Count(); i++)
+            {
+                result ^= Hex2Dec(list[i]);
+            }
+            return str + FrontWithZero(Dec2Hex(result), 2);
+        }
+
     }
 }

DotNettyFromTests/DotNettyFromTests.csproj

   </Choose>
   <ItemGroup>
     <Compile Include="common\UIInfoModelTests.cs" />
+    <Compile Include="generatecmd\CmdGenetorTests.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
     <Compile Include="util\CmdUtilTests.cs" />
   </ItemGroup>

DotNettyFromTests/generatecmd/CmdGenetorTests.cs

+using Microsoft.VisualStudio.TestTools.UnitTesting;
+using DotNettyFrom.generatecmd;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace DotNettyFrom.generatecmd.Tests
+{
+    [TestClass()]
+    public class CmdGenetorTests
+    {
+        [TestMethod()]
+        public void GetLoginCmdTest()
+        {
+            
+
+        }
+
+        [TestMethod()]
+        public void GetHeartbeatTest()
+        {
+            CmdGenetor c = CmdGenetor.GetInstance().SetDeviceId("000000000002");
+            string cmd = c.GetLoginCmd("3839383630324731313931353530333339393137");
+            Console.WriteLine(cmd);
+        }
+    }
+}