V0.9.1

GWSocketClient/Form1.cs

@@ -37,8 +37,8 @@ namespace GWSocketClient
 
         private void Form1_Load(object sender, EventArgs e)
         {
-            XmlLoader xmlLoader = new XmlLoader();
-            vcarecityProtocolBean = xmlLoader.loadXml();
+//            XmlLoader xmlLoader = new XmlLoader();
+//            vcarecityProtocolBean = xmlLoader.loadXml();
             if (vcarecityProtocolBean != null)
             {
                 this.Text = vcarecityProtocolBean.ProtocolName + " - " + vcarecityProtocolBean.ProtocolNo + " - " +
@@ -114,22 +114,23 @@ namespace GWSocketClient
         //处理回复信息
         private void handleResponse(SocketHelper.Sockets sks, string reqData)
         {
-            string resp = tfTmpResponse.Text.Trim();
+            //取出原数据功能码
+            string functionWord = reqData.Substring(18, 2);
+            int funcode = Utils.hexToTen(functionWord);
 
-            if (resp.Equals(""))
+            if (!(funcode == 16 || funcode == 32))
             {
-                resp = "00";
+                Console.WriteLine(funcode + " 这个功能码不用回复!");
+                return;
             }
 
-            string functionWord = reqData.Substring(18, 2);
-            int funcode = Utils.hexToTen(functionWord);
 
             //16 表示要读数据,返回数据库中的数据
             //32 表示返回结果 成功:00 失败:01 
 
-
             //数据长度
-            int dataLen = Utils.hexToTen(reqData.Substring(20, 4));
+            int dataLen = Utils.hexToTen(reqData.Substring(20, 4)) * 2;
+
             string readlData = "";
             try
             {
@@ -138,48 +139,72 @@ namespace GWSocketClient
             catch (Exception e)
             {
                 Console.WriteLine(e.Message);
-                addToListboxItem("数据长度与帧长度对不上!!");
+                addToListboxItem("数据长度与帧长度对不上!! 帧数据长度=" + (dataLen / 2) + " ,Error=" + e.Message);
                 return;
             }
 
+            //消息流水&测量点
+            string flowPoint = readlData.Substring(0, 6);
+            //ID
             string myId = readlData.Substring(6, 4);
+            //对应信息
             string idInfo = readlData.Substring(10);
 
+            //回复功能码
+            int responceFunCode = funcode + 128;
+
+            string cmd = reqData.Substring(0, 18); //前面的
+
+            cmd += Utils.stringWith0(Utils.tenToHex(responceFunCode), 2); //回复功能码
+            string body = flowPoint + myId;
+
             if (funcode == 32)
             {
                 //设置数据
                 int res = AccsessDbLoader.getInstance().setReceiveData(myId, idInfo);
+                //成功回复00 失败回复01
                 if (res > 0)
                 {
-                    //00
+                    body += "00";
+                    AccsessDbLoader.getInstance().reloadAccessDb();
                 }
                 else
                 {
-                    //01
+                    body += "01";
                 }
             }
-            else if (funcode == 16)
+            else
             {
-                //返回数据库的数据
-            }
-
+                //返回数据库的数据 OR 临时数据,如果临时数据有数据的话
+                try
+                {
+                    string responce = AccsessDbLoader.getInstance().getUserIdInfo()[myId];
 
-            if (funcode == 16 || funcode == 32)
-            {
-                funcode = funcode + 128;
-                functionWord = Utils.stringWith0(Utils.tenToHex(funcode), 2);
-                string cmd = reqData.Substring(0, 18) + functionWord;
-                string data = reqData.Substring(24, 10) + resp;
-                cmd = cmd + Utils.stringWith0(Utils.tenToHex(data.Length / 2), 4) + data;
-                cmd = Utils.calcCrcCode(cmd);
+                    if (!tfTmpResponse.Text.Trim().Equals(""))
+                    {
+                        string inputRespocse = tfTmpResponse.Text.Trim();
+                        responce = Utils.stringWith0(inputRespocse, responce.Length);
+                    }
+                    body += responce;
+                }
+                catch (Exception e)
+                {
+                    Console.WriteLine(e);
+                    addToListboxItem("异常,没有这个ID=(" + myId + "),ERROR=" + e.Message);
+                    return;
+                }
+            }
+            cmd += Utils.stringWith0(Utils.tenToHex(body.Length / 2), 4); //长度
+            cmd += body; //消息体 
+            cmd = Utils.calcCrcCode(cmd); //计算检验码
 
-                addToListboxItem(string.Format("回复服务端{0}回应消息：[{1}]", sks.Ip, cmd));
+            addToListboxItem(string.Format("回复服务端{0}回应消息：[{1}]", sks.Ip, cmd));
 
-                byte[] ts = HexUtil.hexToBytes(cmd);
-                sockeTcpClients.SendData(ts);
-            }
+            byte[] ts = HexUtil.hexToBytes(cmd);
+            sockeTcpClients.SendData(ts);
         }
 
+
         private void tbEquipmentAddress_TextChanged(object sender, EventArgs e)
         {
             string equipmentAddress = tbEquipmentAddress.Text.Trim();
@@ -191,8 +216,8 @@ namespace GWSocketClient
         {
             try
             {
-                if (!showTopForNoLoadXML())
-                    return;
+                /*if (!showTopForNoLoadXML())
+                    return;*/
 
                 ip = tbIpaddress.Text.Trim();
                 port = tbPort.Text.Trim();
@@ -414,7 +439,14 @@ namespace GWSocketClient
 
         private void btnTextCmd_Click(object sender, EventArgs e)
         {
-            try
+            string code = Utils.calcCrcCode("7e7e7e123456789abc20000701010107030001");
+//            code = Utils.calcCrcCode("7e7e7e123456789abc10000501010107023f");
+            Console.WriteLine(code);
+
+            handleResponse(null, code);
+
+
+            /*try
             {
                 Dictionary<string, string> abc = AccsessDbLoader.getInstance().getUserIdInfo();
                 MessageBox.Show(abc.Count + "");
@@ -424,7 +456,7 @@ namespace GWSocketClient
             catch (Exception exception)
             {
                 Console.WriteLine(exception);
-            }
+            }*/
         }
     }
 }