当前位置: 首页 > 资源下载  > 恒远工具

SDK_Demo(MBUS集中器版)

开发平台:VS2012及以上版本,.Net 4.0using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Windows.Forms;using System.Configuration;namespace Te…

开发平台:VS2012及以上版本,.Net 4.0

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Windows.Forms;

using System.Configuration;


namespace TestModel

{

    public partial class Form1 : Form

    {

        /// <summary>

        /// 服务

        /// </summary>

        AsySocket.Server sever = null;

        /// <summary>

        /// 服务端口

        /// </summary>

        int Port;

        /// <summary>

        /// 服务类型

        /// </summary>

        AsySocket.Service_Type severType;

        /// <summary>

        /// 消息缓存

        /// </summary>

        AsySocket.MemQueue<string> msgQueue = new AsySocket.MemQueue<string>();

     


        public Form1()

        {

            Control.CheckForIllegalCrossThreadCalls = false;

            InitializeComponent();

        }


        private void btn_StartSever_Click(object sender, EventArgs e)

        {

            if (!int.TryParse(tbox_SeverPort.Text.Trim(), out Port))

            {

                Port = 10001;

                tbox_SeverPort.Text = Port.ToString();                

            }

            if (rbtn_SeverType.Checked)

            {

                severType = AsySocket.Service_Type.TCP;

            }else{

                severType = AsySocket.Service_Type.UDP;

            }


            sever = new AsySocket.Server();

            sever.onClose += new AsySocket.onClose(sever_onClose);

            sever.OnRegist += new AsySocket.onRegist(sever_OnRegist);

            sever.onCmdRecv += new AsySocket.onCmdRecv(sever_onCmdRecv);

            sever.onError += new AsySocket.onError(sever_onError);

            sever.Start(severType, Port);


            btn_StartSever.Enabled = false;

            btn_StopSever.Enabled = true;

        }

        #region 事件处理

        private void sever_onClose(AsySocket.CmdTag cmd)

        {

           msgQueue.Add("设备" + cmd.DeviceID + "断开。");

           lbox_deviceList.Items.Remove(cmd.DeviceID.ToString());

        }


        private void sever_OnRegist(AsySocket.CmdTag cmd)

        {

            msgQueue.Add("收到设备" + cmd.DeviceID + "注册登录信息。");

          

            sever.SetOnLine(cmd.DeviceID, 1);  //响应设备注册;1允许,0不允许


            lbox_deviceList.Items.Add(cmd.DeviceID.ToString());

        }


        private void sever_onCmdRecv(AsySocket.CmdTag cmd)

        {

            Exectue(cmd);

        }


        private void sever_onError(string msg)

        {

            msgQueue.Add(msg);

        }


        #endregion

        private void btn_StopSever_Click(object sender, EventArgs e)

        {

            if (sever == null)

            {

                return;

            }

            try

            {

                sever.Stop();

                sever = null;

                btn_StartSever.Enabled = true;

                btn_StopSever.Enabled = false;

            }

            catch { }

        }


        /// <summary>

        /// 解析收到的数据

        /// </summary>

        /// <param name="cmd"></param>

        private void Exectue(AsySocket.CmdTag cmd)

        {

            try

            {

                switch (cmd.CmdType)

                {

                    case 0xE0:

                        {

                            Exectue_0xE0(cmd);

                            break;

                        }

                    case 0xF0:

                        {

                            Exectue_0xF0(cmd);

                            break;

                        }

                    default:

                        {

                            msgQueue.Add(string.Format("收到设备{0}数据——{1}。", cmd.DeviceID, AsySocket.FormatHelper.ByteArrayToHexString(cmd.Param)));

                           

                            break;

                        }

                }

            }

            catch (Exception ex){

                msgQueue.Add(string.Format("解析数据错误{0},{1}\r\n{2}", cmd.DeviceID, AsySocket.FormatHelper.ByteArrayToHexString(cmd.Param), ex.Message));

            }

        }


        private void Exectue_0xE0(AsySocket.CmdTag cmd)

        {

            switch (cmd.CmdCode)

            {

                case 0xD0: //设备回复抄表指令

                    {

                        if (cmd.CmdState != AsySocket.CommandState.CMD_STATE_OK)

                        {

                            msgQueue.Add(cmd.DeviceID + " 执行抄表指令失败");

                        }

                        msgQueue.Add(cmd.DeviceID + " 执行抄表指令成功");

                        break;

                    }

                case 0xB2: //设请求端口配置数据

                    {

                        if (cmd.Param.Length < 9) {

                            msgQueue.Add(string.Format("{0}请求端口配置数据错误——{1}。", cmd.DeviceID, AsySocket.FormatHelper.ByteArrayToHexString(cmd.Param)));

                            break;

                        }

                       // string edition;

                        byte port = cmd.Param[7];

                        byte index = cmd.Param[8];


                        cmd.CmdCode = 0xB1; //发送配置信息

                        int meterCount = 1; //表数量,此处举例只有一个表地址;根据实际表数量修改

                        cmd.Param = new byte[meterCount * 8];

                        long meterAddr = 0;

                        if (tbox_cmdParam.Text.Trim().Length == 0)

                        {

                            break;

                        }

                        long.TryParse(tbox_cmdParam.Text.Trim(), out meterAddr);

                      

                        Utils.UINT64ToByteArray_LitMode(cmd.Param, (ulong)Utils.ToBCD(meterAddr), 0);

                        sever.Send(cmd); //发送配置关系 响应设备请求。

                        break;

                    }

                case 0xB3:

                    {

                        msgQueue.Add(cmd.DeviceID + " 请求配置水表与端口关系完成");

                        break;

                    }

                case 0xD1:  //汇报水表读数

                    {

                        if (cmd.Param.Length < 13)

                        {

                            msgQueue.Add(string.Format("{0}汇报水表读数错误——{1}。", cmd.DeviceID, AsySocket.FormatHelper.ByteArrayToHexString(cmd.Param)));

                            break;

                        }

                        int i = 0;

                       

                        while (i < cmd.Param.Length)

                        {

                            try

                            {

                                ulong meterNo = Utils.FromBCD(Utils.ByteArrayToUINT64_LitMode(cmd.Param, i));

                                                               

                                if (meterNo == 0)

                                {

                                    i += 13;

                                    continue;

                                }

                                byte status = cmd.Param[i + 12];

                                if (status == 0xff)  //读表失败

                                {                                   

                                    i += 13;

                                    continue;

                                }

                                uint meterReadNum = Utils.ByteArrayToUINT32_LitMode(cmd.Param, i + 8) / 100;  //设备上传的是乘以了100后的数据,所以在此除以100

                                msgQueue.Add(string.Format("收到设备{0}读水表数——表地址{1},读数{2},状态{3}。", cmd.DeviceID, meterNo, meterReadNum, status));

                            }

                            catch { }

                            i += 13;

                        }

                        break;

                    }

                default:

                    {

                        msgQueue.Add(string.Format("收到设备{0}数据——{1}。", cmd.DeviceID, AsySocket.FormatHelper.ByteArrayToHexString(cmd.Param)));

                        break;

                    }

            } 

        }

        private void Exectue_0xF0(AsySocket.CmdTag cmd)

        {

            switch (cmd.CmdCode)

            {

                case 0xAA:

                    {

                        if (cmd.Param.Length < 2) break;

                        int code = cmd.Param[1];

                        code = (code << 8) | cmd.Param[0];


                        switch (code)

                        {

                            case 0x05:

                                {

                                    int index = cmd.Param[2];


                                    int port = cmd.Param[4];

                                    port = (port << 8) | cmd.Param[3];


                                    string type = "TCP";

                                    if (cmd.Param[5] == 0x01)

                                    {

                                        type = "UDP";

                                    }

                                    string stucte = "停用";

                                    if (cmd.Param[6] == 0x01)

                                    {

                                        stucte = "启用";

                                    }

                                    string IP = ASCIIEncoding.Default.GetString(cmd.Param, 7, cmd.Param.Length - 7);


                                    msgQueue.Add(string.Format("{0}设备服务器信息:序号:{1} IP:{2} 端口:{3}  类型:{4}  状态:{5}", cmd.DeviceID,

                                        index, IP, port, type, stucte));

                                    break;

                                }                           

                        }

                        break;

                    }

                default:

                    {

                        msgQueue.Add(string.Format("收到设备{0}数据——{1}。", cmd.DeviceID, AsySocket.FormatHelper.ByteArrayToHexString(cmd.Param)));

                        break;

                    }

            }

        }



        private void Form1_Load(object sender, EventArgs e)

        {

        }



        private void btn_SendCmd_Click(object sender, EventArgs e)

        {

            long deviceNo = getDeviceID();

            if (deviceNo == 0)

            {

                MessageBox.Show("请选择在线设备。");

                return;

            }

            string codestr = cbox_CmdCode.SelectedItem.ToString();

            if (string.IsNullOrEmpty(codestr))

            {

                MessageBox.Show("请选择指令类型。");

                return;

            }

            if (sever == null)

            {

                MessageBox.Show("请先启动服务。");

                return;

            }

            AsySocket.CmdTag cmd = new AsySocket.CmdTag();           

            cmd.DeviceID = deviceNo;

            cmd.CmdState = AsySocket.CommandState.CMD_STATE_SEND;


            if (!getCmdCode(codestr, ref cmd)) return;


            

            sever.Send(cmd);

        }


        private long getDeviceID()

        {

            long deviceNo = 0;

            if (lbox_deviceList.Items.Count == 0)

            {

                return deviceNo;

            }

            long.TryParse(lbox_deviceList.Text, out deviceNo);

            return deviceNo;

        }


       

        /// <summary>

        /// 组织命令

        /// </summary>

        /// <param name="type"></param>

        /// <param name="cmd"></param>

        /// <returns></returns>

        private bool getCmdCode(string type,ref  AsySocket.CmdTag cmd)

        {

            

            switch (type)

            {

                case "全部抄表":

                    {

                        cmd.CmdCode = 0xD0;

                        cmd.CmdType = 0xE0;

                        return true;                       

                    }               

                case "单表抄表":

                    {

                        cmd.CmdCode = 0xCF;

                        cmd.CmdType = 0xE0;

                        cmd.Param = new byte[8];

                        long meterAddr = 0;

                        if (tbox_cmdParam.Text.Trim().Length == 0) {

                            msgQueue.Add("请填写水表地址");

                            return false;

                        }

                        long.TryParse(tbox_cmdParam.Text.Trim(), out meterAddr);

                      

                        Utils.UINT64ToByteArray_LitMode(cmd.Param, (ulong)Utils.ToBCD(meterAddr), 0);

                        return true;

                       

                    }

                case "配置表地址":

                    {

                        cmd.CmdCode = 0xB0;

                        cmd.CmdType = 0xE0;


                        byte port = 0;

                        if (tbox_cmdParam.Text.Trim().Length == 0 || cbox_port.Text.Length==0)

                        {

                            msgQueue.Add("必须填写水表地址和选择端口。");

                            return false;

                        }

                        byte.TryParse(cbox_port.Text.Trim(), out port);

                        cmd.Param = new byte[9];

                        cmd.Param[0] = port;

                        cmd.Param[1] = 1; //表数量 根据实际接入数量赋值;


                        Utils.DateTimeToByteArray_LitMode(DateTime.Now, ref cmd.Param, 2); //赋值当前时间

                        return true;

                       

                    }

                case "查询服务器配置":

                    {

                        cmd.CmdCode = 0xAA;

                        cmd.CmdType = 0xF0;

                        cmd.Param = new byte[2];

                        cmd.Param[0] = 0x05;

                        cmd.Param[1] = 0x00;

                        return true;

                       

                    }              

                    

            }

            return false;

        }


        private void timer1_Tick(object sender, EventArgs e)

        {

            while (msgQueue.Count > 0)

            {

                if (tbox_Msg.TextLength > 32768)

                {

                    tbox_Msg.Clear();

                }

                tbox_Msg.AppendText(string.Format("{0}:{1}\r\n", DateTime.Now.ToLongTimeString(), msgQueue.Get()));

            }

            

        }


        private void Form1_Closing(object sender, FormClosingEventArgs e)

        {

            timer1.Enabled = false;

            try

            {

                sever.Stop();

            }

            catch { }

        }


        private void btn_ClearMsg_Click(object sender, EventArgs e)

        {

            tbox_Msg.Clear();

           

        }


       


       

    }

}


附件下载

  • 下载

    开发SDK_Demo(集中器版).rar

    文件类型:rar 大小: 104KB

相关资源

  • 恒远物联通用配置工具-V2019

    恒远物联通用配置工具,支持DTU/RTU/MBUS集中器等系列产品在使用过程中有何疑问,请随时与我们联系:028-87657875

  • SDK_Demo(DTU-RTU通用版)

    开发平台:VS2012及以上版本 .Net 4.0using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Windows.Forms;using System.Configuration;namespace Test…

  • 恒远协议开发SDK

    DLL通信库文件说明 C# DLL库使用说明 1、DLL库名 AsySocket2、服务类名Server使用定义AsySocket.Server sever = null; 3、指令状态CommandStateCMD_STATE_OK ——0CMD_STATE_FAIL ——1CMD_STATE_SEND ——2 4、基本命令结构类CmdTagCmdTag结构类是事件和发送数据最小…

DTU(11) RTU(11) 物联网(11) MBUS(10) HERY(6) 4G全网通(5) 智慧工地(3) PLC(2) RS485(2) RS232(1) DI(1) DO(1) AI(1) AO(1) 集中器(1) 采集器(1) 抄表(1) GPRS(1) GPRS2G(1) 智慧水务(1) 5G(1) MQTT(1) HTTP(1) IOT(1) SCADA(1) NBIOT(1) WiFi(0) BLE(0) PWM(0) 污水处理(0)
咨询反馈
扫码关注

恒远物联 微信公众号

返回顶部
网站客服