水设备的登录和心跳功能

DotNettyFrom/DotNettyFrom.csproj

@@ -180,6 +180,8 @@
     <Compile Include="util\CheckUtil.cs" />
     <Compile Include="util\CmdUtil.cs" />
     <Compile Include="model\WvBean.cs" />
+    <Compile Include="util\HexUtil.cs" />
+    <Compile Include="util\Utils.cs" />
     <EmbeddedResource Include="dialog\HeartBeatTime.resx">
       <DependentUpon>HeartBeatTime.cs</DependentUpon>
     </EmbeddedResource>

DotNettyFrom/MainForm.Designer.cs

@@ -58,6 +58,8 @@
             this.RT_HI_CCID = new System.Windows.Forms.ToolStripMenuItem();
             this.toolStripSeparator2 = new System.Windows.Forms.ToolStripSeparator();
             this.RT_HI_SendData = new System.Windows.Forms.ToolStripMenuItem();
+            this.配置CToolStripMenuItem = new System.Windows.Forms.ToolStripMenuItem();
+            this.HalfPkgToolStripMenuItem = new System.Windows.Forms.ToolStripMenuItem();
             this.statusStrip1 = new System.Windows.Forms.StatusStrip();
             this.toolStripStatusLabel1 = new System.Windows.Forms.ToolStripStatusLabel();
             this.StatusItemHbTime = new System.Windows.Forms.ToolStripStatusLabel();
@@ -73,8 +75,6 @@
             this.TbDeviceId = new System.Windows.Forms.TextBox();
             this.label2 = new System.Windows.Forms.Label();
             this.label1 = new System.Windows.Forms.Label();
-            this.配置CToolStripMenuItem = new System.Windows.Forms.ToolStripMenuItem();
-            this.HalfPkgToolStripMenuItem = new System.Windows.Forms.ToolStripMenuItem();
             this.ListBoxLogContextMenu.SuspendLayout();
             this.menuStrip1.SuspendLayout();
             this.statusStrip1.SuspendLayout();
@@ -164,7 +164,7 @@
             this.TbHost.Name = "TbHost";
             this.TbHost.Size = new System.Drawing.Size(280, 22);
             this.TbHost.TabIndex = 1;
-            this.TbHost.Text = "127.0.0.1";
+            this.TbHost.Text = "i.device.yun.vcarefire.com";
             // 
             // TbPort
             // 
@@ -173,7 +173,7 @@
             this.TbPort.Name = "TbPort";
             this.TbPort.Size = new System.Drawing.Size(57, 22);
             this.TbPort.TabIndex = 1;
-            this.TbPort.Text = "15440";
+            this.TbPort.Text = "15443";
             this.TbPort.KeyPress += new System.Windows.Forms.KeyPressEventHandler(this.TbPort_KeyPress);
             // 
             // BtnConnection
@@ -247,15 +247,19 @@
             // 
             // dtuToolStripMenuItem
             // 
+            this.dtuToolStripMenuItem.Checked = true;
+            this.dtuToolStripMenuItem.CheckOnClick = true;
+            this.dtuToolStripMenuItem.CheckState = System.Windows.Forms.CheckState.Checked;
             this.dtuToolStripMenuItem.Name = "dtuToolStripMenuItem";
-            this.dtuToolStripMenuItem.Size = new System.Drawing.Size(115, 22);
+            this.dtuToolStripMenuItem.Size = new System.Drawing.Size(152, 22);
             this.dtuToolStripMenuItem.Text = "dtu";
             this.dtuToolStripMenuItem.Click += new System.EventHandler(this.dtuToolStripMenuItem_Click);
             // 
             // water2ToolStripMenuItem
             // 
+            this.water2ToolStripMenuItem.CheckOnClick = true;
             this.water2ToolStripMenuItem.Name = "water2ToolStripMenuItem";
-            this.water2ToolStripMenuItem.Size = new System.Drawing.Size(115, 22);
+            this.water2ToolStripMenuItem.Size = new System.Drawing.Size(152, 22);
             this.water2ToolStripMenuItem.Text = "water2";
             this.water2ToolStripMenuItem.Click += new System.EventHandler(this.water2ToolStripMenuItem_Click);
             // 
@@ -275,21 +279,21 @@
             this.RT_HB_Enable.CheckOnClick = true;
             this.RT_HB_Enable.CheckState = System.Windows.Forms.CheckState.Checked;
             this.RT_HB_Enable.Name = "RT_HB_Enable";
-            this.RT_HB_Enable.Size = new System.Drawing.Size(152, 22);
+            this.RT_HB_Enable.Size = new System.Drawing.Size(141, 22);
             this.RT_HB_Enable.Text = "启用心跳";
             this.RT_HB_Enable.Click += new System.EventHandler(this.RT_HB_Enable_Click);
             // 
             // RT_HB_Time
             // 
             this.RT_HB_Time.Name = "RT_HB_Time";
-            this.RT_HB_Time.Size = new System.Drawing.Size(152, 22);
+            this.RT_HB_Time.Size = new System.Drawing.Size(141, 22);
             this.RT_HB_Time.Text = "心跳超时(&H)";
             this.RT_HB_Time.Click += new System.EventHandler(this.RT_HB_Time_Click);
             // 
             // toolStripSeparator1
             // 
             this.toolStripSeparator1.Name = "toolStripSeparator1";
-            this.toolStripSeparator1.Size = new System.Drawing.Size(149, 6);
+            this.toolStripSeparator1.Size = new System.Drawing.Size(138, 6);
             // 
             // 历史HToolStripMenuItem
             // 
@@ -336,6 +340,21 @@
             this.RT_HI_SendData.Text = "发送数据";
             this.RT_HI_SendData.Click += new System.EventHandler(this.RT_HI_SendData_Click);
             // 
+            // 配置CToolStripMenuItem
+            // 
+            this.配置CToolStripMenuItem.DropDownItems.AddRange(new System.Windows.Forms.ToolStripItem[] {
+            this.HalfPkgToolStripMenuItem});
+            this.配置CToolStripMenuItem.Name = "配置CToolStripMenuItem";
+            this.配置CToolStripMenuItem.Size = new System.Drawing.Size(60, 21);
+            this.配置CToolStripMenuItem.Text = "配置(&C)";
+            // 
+            // HalfPkgToolStripMenuItem
+            // 
+            this.HalfPkgToolStripMenuItem.Name = "HalfPkgToolStripMenuItem";
+            this.HalfPkgToolStripMenuItem.Size = new System.Drawing.Size(129, 22);
+            this.HalfPkgToolStripMenuItem.Text = "半包-粘包";
+            this.HalfPkgToolStripMenuItem.Click += new System.EventHandler(this.HalfPkgToolStripMenuItem_Click);
+            // 
             // statusStrip1
             // 
             this.statusStrip1.Items.AddRange(new System.Windows.Forms.ToolStripItem[] {
@@ -458,7 +477,7 @@
             this.TbCCID.Name = "TbCCID";
             this.TbCCID.Size = new System.Drawing.Size(282, 22);
             this.TbCCID.TabIndex = 6;
-            this.TbCCID.Text = "3839383630324731313931353530333339393137";
+            this.TbCCID.Text = "3839383630324231313931353530343739313331";
             // 
             // label3
             // 
@@ -496,21 +515,6 @@
             this.label1.TabIndex = 2;
             this.label1.Text = "Host";
             // 
-            // 配置CToolStripMenuItem
-            // 
-            this.配置CToolStripMenuItem.DropDownItems.AddRange(new System.Windows.Forms.ToolStripItem[] {
-            this.HalfPkgToolStripMenuItem});
-            this.配置CToolStripMenuItem.Name = "配置CToolStripMenuItem";
-            this.配置CToolStripMenuItem.Size = new System.Drawing.Size(60, 21);
-            this.配置CToolStripMenuItem.Text = "配置(&C)";
-            // 
-            // HalfPkgToolStripMenuItem
-            // 
-            this.HalfPkgToolStripMenuItem.Name = "HalfPkgToolStripMenuItem";
-            this.HalfPkgToolStripMenuItem.Size = new System.Drawing.Size(152, 22);
-            this.HalfPkgToolStripMenuItem.Text = "半包-粘包";
-            this.HalfPkgToolStripMenuItem.Click += new System.EventHandler(this.HalfPkgToolStripMenuItem_Click);
-            // 
             // MainForm
             // 
             this.AutoScaleDimensions = new System.Drawing.SizeF(7F, 16F);

DotNettyFrom/MainForm.cs

@@ -4,6 +4,8 @@ using System.ComponentModel;
 using System.Data;
 using System.Drawing;
 using System.Linq;
+using System.Net;
+using System.Net.Sockets;
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
@@ -51,6 +53,18 @@ namespace DotNettyFrom
 
             UpdateUiComponent();
 
+            this.Text = "模拟器-DTU";
+            CmdGenetor.Genetor = new DtuCmdGenetor();
+
+            if ("".Equals(TbDeviceId.Text.Trim()))
+            {
+                CmdGenetor.Genetor.DeviceId = "000000000001";
+            }
+            else
+            {
+                CmdGenetor.Genetor.DeviceId = TbDeviceId.Text.Trim();
+            }
+
             var consumer = Task.Factory.StartNew(() =>
             {
                 foreach (UIInfoModel value in DataModel.ReceCollection.GetConsumingEnumerable())
@@ -120,9 +134,19 @@ namespace DotNettyFrom
 
         private void BeforeConnection()
         {
-            this.host = TbHost.Text.Trim();
-            this.port = int.Parse(TbPort.Text.Trim());
-            UpdateUiComponent();
+            try
+            {
+                IPAddress[] hostAddresses = Dns.GetHostAddresses(TbHost.Text.Trim());
+                IPAddress hostAddress = hostAddresses[0];
+                this.host = hostAddress.ToString();
+                this.port = int.Parse(TbPort.Text.Trim());
+
+                UpdateUiComponent();
+            }
+            catch (SocketException exception)
+            {
+                MessageBox.Show(exception.Message);
+            }
         }
 
         private void UpdateUiComponent()
@@ -130,15 +154,6 @@ namespace DotNettyFrom
             StatusItemHbTime.Text = "R:" + SystemConfig.ReaderIdleTimeSeconds + "/s,W:" +
                                     SystemConfig.WriterIdleTimeSeconds + "/s,A:" + SystemConfig.AllIdleTimeSeconds +
                                     "/s";
-            CmdGenetor.Genetor = new DtuCmdGenetor();
-            if ("".Equals(TbDeviceId.Text.Trim()))
-            {
-                CmdGenetor.Genetor.DeviceId = "000000000001";
-            }
-            else
-            {
-                CmdGenetor.Genetor.DeviceId = TbDeviceId.Text.Trim();
-            }
         }
 
         #region Component Event
@@ -215,11 +230,17 @@ namespace DotNettyFrom
 
         private void dtuToolStripMenuItem_Click(object sender, EventArgs e)
         {
+            this.Text = "模拟器-DTU";
+            water2ToolStripMenuItem.Checked = false;
+            CmdGenetor.Genetor = null;
             CmdGenetor.Genetor = new DtuCmdGenetor();
         }
 
         private void water2ToolStripMenuItem_Click(object sender, EventArgs e)
         {
+            this.Text = "模拟器-Water2";
+            dtuToolStripMenuItem.Checked = false;
+            CmdGenetor.Genetor = null;
             CmdGenetor.Genetor = new Water2CmdGenetor();
         }
 

DotNettyFrom/generatecmd/Water2CmdGenetor.cs

@@ -3,19 +3,22 @@ using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
+using DotNettyFrom.util;
 
 namespace DotNettyFrom.generatecmd
 {
     public class Water2CmdGenetor : CmdGenetor
     {
-        public override string GetLoginCmd( string ccid)
+        public override string GetLoginCmd(string ccid)
         {
-            throw new NotImplementedException();
+            string cmd = DeviceId + "0214" + ccid;
+            return "7e7e7e" + CmdUtil.CalcCrc16Code(cmd);
         }
 
         public override string GetHeartbeat()
         {
-            throw new NotImplementedException();
+            string cmd = DeviceId + "03020001";
+            return "7e7e7e" + CmdUtil.CalcCrc16Code(cmd);
         }
     }
 }

DotNettyFrom/util/CmdUtil.cs

@@ -96,5 +96,75 @@ namespace DotNettyFrom.util
             return str + FrontWithZero(Dec2Hex(result), 2);
         }
 
+
+        public static string CalcCrc16Code2(string str)
+        {
+            int value = crc16(HexUtil.hexToBytes(str));
+
+            return FrontWithZero(Utils.tenToHex(value), 4);
+        }
+
+
+        public static string CalcCrc16Code(string str)
+        {
+            int value = crc16(HexUtil.hexToBytes(str));
+
+            return str + FrontWithZero(Utils.tenToHex(value), 4);
+        }
+
+
+        private static int crc16(byte[] bs)
+        {
+            return crc16(bs, 0, bs.Length, 0xFFFF);
+        }
+
+        private static int crc16(byte[] bs, int offset, int len, int initCRC)
+        {
+            byte temp;
+            int index = offset;
+            while (len-- > 0)
+            {
+                temp = (byte) (initCRC & 0xFF);
+                initCRC = (initCRC >> 8) ^ crc_t_4[(temp ^ bs[index++]) & 0xFF];
+            }
+            return initCRC;
+        }
+
+
+        public static readonly int[] crc_t_4 = new int[]
+        {
+            0x0000, 0xC0C1, 0xC181, 0x0140, 0xC301, 0x03C0, 0x0280, 0xC241,
+            0xC601, 0x06C0, 0x0780, 0xC741, 0x0500, 0xC5C1, 0xC481, 0x0440,
+            0xCC01, 0x0CC0, 0x0D80, 0xCD41, 0x0F00, 0xCFC1, 0xCE81, 0x0E40,
+            0x0A00, 0xCAC1, 0xCB81, 0x0B40, 0xC901, 0x09C0, 0x0880, 0xC841,
+            0xD801, 0x18C0, 0x1980, 0xD941, 0x1B00, 0xDBC1, 0xDA81, 0x1A40,
+            0x1E00, 0xDEC1, 0xDF81, 0x1F40, 0xDD01, 0x1DC0, 0x1C80, 0xDC41,
+            0x1400, 0xD4C1, 0xD581, 0x1540, 0xD701, 0x17C0, 0x1680, 0xD641,
+            0xD201, 0x12C0, 0x1380, 0xD341, 0x1100, 0xD1C1, 0xD081, 0x1040,
+            0xF001, 0x30C0, 0x3180, 0xF141, 0x3300, 0xF3C1, 0xF281, 0x3240,
+            0x3600, 0xF6C1, 0xF781, 0x3740, 0xF501, 0x35C0, 0x3480, 0xF441,
+            0x3C00, 0xFCC1, 0xFD81, 0x3D40, 0xFF01, 0x3FC0, 0x3E80, 0xFE41,
+            0xFA01, 0x3AC0, 0x3B80, 0xFB41, 0x3900, 0xF9C1, 0xF881, 0x3840,
+            0x2800, 0xE8C1, 0xE981, 0x2940, 0xEB01, 0x2BC0, 0x2A80, 0xEA41,
+            0xEE01, 0x2EC0, 0x2F80, 0xEF41, 0x2D00, 0xEDC1, 0xEC81, 0x2C40,
+            0xE401, 0x24C0, 0x2580, 0xE541, 0x2700, 0xE7C1, 0xE681, 0x2640,
+            0x2200, 0xE2C1, 0xE381, 0x2340, 0xE101, 0x21C0, 0x2080, 0xE041,
+            0xA001, 0x60C0, 0x6180, 0xA141, 0x6300, 0xA3C1, 0xA281, 0x6240,
+            0x6600, 0xA6C1, 0xA781, 0x6740, 0xA501, 0x65C0, 0x6480, 0xA441,
+            0x6C00, 0xACC1, 0xAD81, 0x6D40, 0xAF01, 0x6FC0, 0x6E80, 0xAE41,
+            0xAA01, 0x6AC0, 0x6B80, 0xAB41, 0x6900, 0xA9C1, 0xA881, 0x6840,
+            0x7800, 0xB8C1, 0xB981, 0x7940, 0xBB01, 0x7BC0, 0x7A80, 0xBA41,
+            0xBE01, 0x7EC0, 0x7F80, 0xBF41, 0x7D00, 0xBDC1, 0xBC81, 0x7C40,
+            0xB401, 0x74C0, 0x7580, 0xB541, 0x7700, 0xB7C1, 0xB681, 0x7640,
+            0x7200, 0xB2C1, 0xB381, 0x7340, 0xB101, 0x71C0, 0x7080, 0xB041,
+            0x5000, 0x90C1, 0x9181, 0x5140, 0x9301, 0x53C0, 0x5280, 0x9241,
+            0x9601, 0x56C0, 0x5780, 0x9741, 0x5500, 0x95C1, 0x9481, 0x5440,
+            0x9C01, 0x5CC0, 0x5D80, 0x9D41, 0x5F00, 0x9FC1, 0x9E81, 0x5E40,
+            0x5A00, 0x9AC1, 0x9B81, 0x5B40, 0x9901, 0x59C0, 0x5880, 0x9841,
+            0x8801, 0x48C0, 0x4980, 0x8941, 0x4B00, 0x8BC1, 0x8A81, 0x4A40,
+            0x4E00, 0x8EC1, 0x8F81, 0x4F40, 0x8D01, 0x4DC0, 0x4C80, 0x8C41,
+            0x4400, 0x84C1, 0x8581, 0x4540, 0x8701, 0x47C0, 0x4680, 0x8641,
+            0x8201, 0x42C0, 0x4380, 0x8341, 0x4100, 0x81C1, 0x8081, 0x4040
+        };
     }
 }

DotNettyFrom/util/HexUtil.cs

@@ -0,0 +1,54 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace DotNettyFrom.util
+{
+    public class HexUtil
+    {
+        public static byte[] hexToBytes(string hex)
+        {
+            hex = hex.Replace(" ", "").Replace("\r", "").Replace("\t", "").Replace("\n", "");
+            int len = hex.Length / 2;
+            byte[] bs = new byte[len];
+            for (int i = 0; i < len; i++)
+            {
+                string sub = hex.Substring(2 * i, 2);
+                //                String sub = hex.substring(2 * i, 2 * i + 2);
+                int v = Utils.hexToTen(sub);
+                //                int v = Integer.valueOf(sub, 16);
+                bs[i] = (byte) v;
+            }
+
+            return bs;
+        }
+
+        public static String byteToHexStr(byte[] bs)
+        {
+            int len = bs.Length;
+            StringBuilder sb = new StringBuilder(len * 2);
+            for (int i = 0; i < len; i++)
+            {
+                byte b = bs[i];
+                string str = Convert.ToString(b, 16);
+                //                String str = Integer.toHexString(b);
+                if (str.Length == 1)
+                {
+                    sb.Append("0").Append(str);
+                }
+                else if (str.Length > 2)
+                {
+                    sb.Append(str.Substring(str.Length - 2));
+                }
+                else
+                {
+                    sb.Append(str);
+                }
+            }
+
+            return sb.ToString();
+        }
+    }
+}

DotNettyFrom/util/Utils.cs

@@ -0,0 +1,165 @@
+using System;
+using System.Collections.Generic;
+using System.Globalization;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace DotNettyFrom.util
+{
+    public class Utils
+    {
+        public static string Bytes2Hex(byte[] bs)
+        {
+            return BitConverter.ToString(bs, 0, bs.Length).Replace("-", "").ToUpper();
+        }
+
+
+        public static byte[] Hex2Bytes(string hex)
+        {
+            hex = hex.Replace(" ", "");
+            if (hex.Length % 2 != 0)
+                hex += " ";
+            byte[] returnBytes = new byte[hex.Length / 2];
+            for (int i = 0; i < returnBytes.Length; i++)
+                returnBytes[i] = Convert.ToByte(hex.Substring(i * 2, 2).Trim(), 16);
+            return returnBytes;
+        }
+
+        public static int hexToTen(string hex)
+        {
+            return int.Parse(hex, NumberStyles.HexNumber);
+        }
+
+
+        public static string hexToBin(string hex)
+        {
+            int res = hexToTen(hex);
+            return stringWith0(Convert.ToString(res, 2), 8);
+        }
+
+        public static string tenToHex(string ten)
+        {
+            return tenToHex(Convert.ToInt32(ten));
+        }
+
+
+        public static string tenToHex(int ten)
+        {
+            return Convert.ToString(ten, 16);
+        }
+
+
+        public static string tenToBin(string ten)
+        {
+            return tenToBin(Convert.ToInt32(ten));
+        }
+
+
+        public static string tenToBin(int ten)
+        {
+            return Convert.ToString(ten, 2);
+        }
+
+
+        public static string binToTen(string bin)
+        {
+            return binToTenInt(bin) + "";
+        }
+
+        public static int binToTenInt(string bin)
+        {
+            return Convert.ToInt32(bin, 2);
+        }
+
+
+        public static string binToHex(string bin)
+        {
+            int i = binToTenInt(bin);
+            return stringWith0(Convert.ToString(i, 16), 2);
+        }
+
+
+        public static string stringWith0(string str, int len)
+        {
+            int delta = len - str.Length;
+            string sb = "";
+            for (int i = 0; i < delta; i++)
+            {
+                sb += "0";
+            }
+            return sb + str;
+        }
+
+        public static string[] REG_STRING =
+        {
+            "0", "1", "2", "3", "4", "5", "6", "7", "8", "9", "A", "B", "C", "D", "E", "F", "a", "b", "c", "d", "e", "f"
+        };
+
+        public static string validInput(string reg)
+        {
+            string trim = reg.Trim();
+            if (trim.Length > 0)
+            {
+                string t = trim.Substring(trim.Length - 1, 1);
+                if (REG_STRING.Contains(t))
+                {
+                    return trim;
+                }
+                else
+                {
+                    return trim.Substring(0, trim.Length - 1);
+                }
+            }
+            return trim;
+        }
+
+        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 = 3; i < list.Count(); i++)
+            {
+                result ^= hexToTen(list[i]);
+            }
+            return str + stringWith0(tenToHex(result), 2);
+        }
+
+
+        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 = 3; i < list.Count(); i++)
+            {
+                result ^= hexToTen(list[i]);
+            }
+            return stringWith0(tenToHex(result), 2);
+        }
+
+        public static string transateCCID(string source)
+        {
+            string res = "";
+            for (int i = 0; i < source.Length; i++)
+            {
+                int hex = Int32.Parse(source[i].ToString(), NumberStyles.HexNumber);
+                int ten = hexToTen(hex + "") + 30;
+
+                res += ten + "";
+                // Console.WriteLine(ten);
+            }
+            return res;
+        }
+
+    }
+}