qlhb/Ropin.Environmentally.WebScada/FlexBox.cs

using System;
using System.Collections.Generic;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;
using FBoxClientDriver;
using FBoxClientDriver.Contract;
using FBoxClientDriver.Impl;
using NLog;

namespace Ropin.Environmentally.WebScada
{
    public class FlexBox
    {
    }
    public class FBoxClientParameters
    {

        //Fbox线上地址，私有云的改成私有地址即可。
        public static string IdServer { get; set; } = "https://account.flexem.com/core";
        public static string MainServer { get; set; } = "http://fbox360.com";
        public static string HdataServer { get; set; } = "http://fbhs1.fbox360.com";



        //填写平台创建的开发者账号
        public static string ClientId { get; set; } = "b19d14eeacb74522bd29627b79c18ab8"; //"a1d6d4291a0e4caf8d1b486cdb12ba0f"
        public static string ClientSecret { get; set; } = "7b89e021586c43d3b79440ba6eea0b67"; //"412e1a83cd1e4e64a98ef9eb83f9aaf9"


    }




    public class demo : IDisposable //实现接口
    {
        public static Logger logger = LogManager.GetLogger("SimpleDemo"); //打印日志在文件夹中，文件夹命名SimpleDemo

        public readonly IFBoxClientManager _fbox;


        private readonly string guid = Guid.NewGuid().ToString("N");

        public demo()
        {
            HttpClient httpClient = new HttpClient();

            var provider = new DefaultCredentialProvider(FBoxClientParameters.ClientId, FBoxClientParameters.ClientSecret);


            _fbox = new FBoxClientManager(FBoxClientParameters.IdServer, FBoxClientParameters.MainServer,
            FBoxClientParameters.HdataServer, provider, guid, null, httpClient);



            //侦听盒子状态变更事件     (订阅事件是，只能订阅一次)
            _fbox.BoxConnectStateChanged += _fbox_BoxConnectStateChanged;

            // 侦听实时数据变更事件 ,和盒子状态变更事件同时用
            //_fbox.DataMonitorValueChanged += _fbox_DataMonitorValueChanged;

            //侦听报警触发推送，和盒子状态变更事件同时用
            // _fbox.AlarmTriggered += _fbox_AlarmTriggered;

            //监听时报警还原推送
            //_fbox.AlarmRecoverd += _fbox_AlarmRecoverd;

            Console.WriteLine(guid);
            Console.WriteLine();

        }


        public void Dispose()
        {
            _fbox?.Dispose();
        }

        //时实数据推送方法，处理有时间限制，尽量控制在100秒左右
        private void _fbox_DataMonitorValueChanged(object sender, IList<DataMonitorValueChangedArgs> e)
        {
            foreach (var dmon in e)
            {
                Console.WriteLine(
                    $"dmv:{dmon.Uid},Value:{dmon.Value},Status:{dmon.Status},BoxNo:{dmon.BoxNo},Name:{dmon.Name},BoxId:{dmon.BoxId},GroupName:{dmon.GroupName},Timestamp:{dmon.Timestamp}");
                //logger.Error($"uid:{dmon.Uid},value:{dmon.Value},Status:{dmon.Status},BoxNo:{dmon.BoxNo},BoxId:{dmon.BoxId},GroupName:{dmon.GroupName},Timestamp:{dmon.Timestamp}，Name:{dmon.Name}");
                System.DateTime currentTime = new System.DateTime();
                currentTime = System.DateTime.Now;
                Console.WriteLine(currentTime);
                logger.Info("时间" + currentTime + "Uid" + dmon.Uid + "名称:" + dmon.Name + "值:" + dmon.Value + "状态:" + dmon.Status + "盒子号:" + dmon.BoxNo + "分组名称:" + dmon.GroupName + "时间" + dmon.Timestamp);


            }

            //接收数据，先存数据，再把数据显示到页面上
        }

        /// <summary>
        /// 盒子状态变更函数监听一次事件也叫(订阅事件)
        /// 第一个连接上或者是重连signalr，推送的盒子的状态只会推送盒子的在线状态
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        ///
        ///

        private void _fbox_BoxConnectStateChanged(object sender, IList<BoxConnectionStateItem> e) //处理有时间限制，尽量控制在100秒左右
        {
            foreach (var stateItem in e)
            {
                //  每一个盒子断线之后再上线，需要重新调用这个方法判断盒子的一个状态  ,这个方法是不包含在这个监听事件里面的，只是写在这个地方了，如果客户自己写的话，需要客户调用这个方法。
                if (stateItem.NewState == BoxConnectionState.Connected ||
                    stateItem.NewState == BoxConnectionState.TimedOut) //判断这个盒子的在线的一个状态
                {
                    //监控所有的监控点,(这个方法里面会有报错误500，需要在task里面捕获异常，需要添加重试机制)
                    _fbox.StartAllDataMonitorPointsOnBox(new BoxArgs(stateItem.BoxNo)).Wait();

                }

                Console.WriteLine($"{stateItem.BoxNo},{stateItem.NewState},{stateItem.NetworkType}");

                logger.Error($"{stateItem.BoxNo},{stateItem.NewState}"); //打印日志在文件夹中
                logger.Info("盒子号:" + stateItem.BoxNo + "状态:" + stateItem.NewState);
                logger.Info("信号:" + stateItem.Rssi);
            }
        }

        private int guard;


        //  报警触发推送
        private void _fbox_AlarmTriggered(object sender, IList<AlarmTriggerDefinitionArgs> e)
        {
            foreach (var triggered in e)
            {
                Console.WriteLine(
                    $"dmv:{triggered.BoxNo},{triggered.BoxId}{triggered.Uid},{triggered.Value},{triggered.Name}{triggered.Message}");
            }

            System.DateTime currentTime = new System.DateTime();
            currentTime = System.DateTime.Now;
            Console.WriteLine(currentTime);
        }


        //报警还原推送

        private void _fbox_AlarmRecoverd(object sender, IList<AlarmRecoverDefinitonArgs> e)
        {
            foreach (var recover in e)
            {
                Console.WriteLine($"dmv:{recover.Uid},{recover.Value},{recover.Name},{recover.Message}");
            }
        }



        //<summary>
        //启用
        //</summary>
        public async Task Start()
        {
            try
            {
                //通过参数登录服务器，连接signalr

                await _fbox.Restart();
                //只会重启一次，是单例，盒子和服务器只能建立一条通道传输数据

            }

            catch (Exception e)
            {
                Console.WriteLine(e); //控制台输出
                throw e; //抛异常

            }

        }


        // <summary>
        //监控点写值
        //  </summary>
        // public void WriteValue()
        // {
        //
        //     try
        //     {
        //         _fbox.WriteValue(new DataMonitorWriteValueArgsV2()
        //         {
        //             BoxNo = boxNo,
        //             // DataMonitorUid = 177968673027267519,
        //             DataMonitorGroupName= "test",
        //             DataMonitorName= "ceshi1",
        //             Value = 1,
        //             Type = 0
        //         }).Wait();
        //        
        //     }
        //     catch (Exception e)
        //     {
        //         Console.WriteLine(e);
        //         throw;
        //     }
        //
        // }



        //<summary>
        //获取历史记录条目 (历史记录接口)
        //</summary>
        // public void GetHdataItems()
        // {
        //     var itemsss = _fbox.GetHdataItems(new BoxArgs()
        //     {
        //         BoxNo = boxNo
        //     }).Result;
        //     foreach (var items in itemsss)
        //     {
        //         Console.WriteLine(items.BoxId);
        //         foreach (var channels in items.Channels)
        //         {
        //             Console.WriteLine(channels.Uid);                //通道Id
        //             Console.WriteLine(channels.HasSubAddress);      //寄存器是否有子地址
        //             Console.WriteLine(channels.HasSubIndex);        //寄存器是否有DB块地址
        //             Console.WriteLine(channels.DataType);           //数据类型，详情见接口文档中附录二
        //             Console.WriteLine(channels.MainAddress);        //主地址
        //             Console.WriteLine(channels.RegName);            //寄存器名称
        //             Console.WriteLine(channels.RegId);              //寄存器Id
        //             Console.WriteLine(channels.IoWidth);            //寄存器位宽
        //             Console.WriteLine(channels.StationNo);          //站号
        //             Console.WriteLine(channels.SubAddress);         //子地址
        //             Console.WriteLine(channels.DevAlias);           //PLC别名
        //             Console.WriteLine(channels.SubIndex);           //DB块地址
        //         }
        //         Console.WriteLine(items.Name);                      //名称
        //         Console.WriteLine(items.RecordingPeriod);           //采集周期
        //         Console.WriteLine(items.Uid);                       //主键
        //         Console.WriteLine(items.IsControl);                 //是否使用使能
        //     }
        // }


        //获取历史记录数据
        //获取历史的数据的sdk里方法的时间是正确时间，如果是调用接口的话需要加上8小时。
        // public IList<ByRowHistoryDataRow> GetByRowHistoryData()
        // {
        //     try
        //     {
        //         var hdata = _fbox.GetByRowHistoryData(new GetHistoryDataArgs()
        //         {
        //             BoxNo = boxNo,                                //盒子号
        //             StartTime = DateTime.Parse("2020-12-10 05:00:00"),  //new DateTime(2020, 8, 11, 6, 0, 0)     //起始时间
        //             EndTime = DateTime.Parse("2020-12-11 06:00:00"),        //结束时间
        //             Limit = 500,                                 //最大获取数据条数
        //             TimeRange = TimeRangeTypes.BeginOpenEndOpen, //区间类型,BeginCloseEndClose:全毕区间,BeginCloseEndOpen:左闭右开，BeginOpenEndClose:左开右闭，BeginOpenEndOpen:全开区间
        //             HdataItemName = "test2",                        //历史数据条目名称
        //             HdataChannelNames = new List<string>() { "test2","test3" }//通道名称
        //         }).Result;
        //
        //         foreach (var d in hdata.Rows)
        //         {
        //             Console.WriteLine(d.Time); // 历史数据条目的采集时间
        //             Console.WriteLine(d.Values[0]); // 对应通道名称集合中的第一个元素
        //             Console.WriteLine(d.Values[1]); // 对应通道名称集合中的第二个元素
        //         }
        //         return hdata.Rows;
        //         //Console.WriteLine(itemssData.Rows.Count);    //不是数组集合，不用循环
        //         //return itemssData.Rows;
        //     }
        //     catch (Exception e)
        //     {
        //         Console.WriteLine(e);
        //         throw e;
        //     }
        // }




    }
}