BPASmartClient/BPASmartClient.MorkMV1/DataServer.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using BPA.Message;
using BPASmartClient.Model;
using BPA.Communication;
using BPA.Communication.Interfaces;


namespace BPASmartClient.MorkMV1
{
    public class DataServer
    {

        private volatile static DataServer _Instance;
        public static DataServer GetInstance => _Instance ?? (_Instance = new DataServer());
        private DataServer() { }

        public ScreenModelMorkS morkS { get; set; } = new ScreenModelMorkS();

        //MqttHelper mQTTProxy = new MqttHelper();
        ICommMqtt mQTTProxy = CommHelper.MQTT;
        public void Init()
        {
            //mQTTProxy.Connected = new Action(() =>
            //{
            //    mQTTProxy.Subscrib(ScreenTOPIC.GetInstance.GetTopic(ScreenDeviceType.煮面机));
            //    TaskManage.GetInstance.StartLong(new Action(() =>
            //    {
            //        morkS.MorkS_OrderCount = Json<OrderStatistics>.Data.Count;
            //        SendScreenDataModel sendScreenDataModel = new SendScreenDataModel();
            //        sendScreenDataModel.Name = ScreenDeviceType.煮面机;
            //        sendScreenDataModel.Value = morkS.ToJSON();
            //        mQTTProxy.Publish(ScreenTOPIC.GetInstance.GetTopic(ScreenDeviceType.煮面机), sendScreenDataModel.ToJSON());
            //        Thread.Sleep(100);
            //    }), "海科食堂大屏监听");
            //});
            ////mQTTProxy.Connect("UserName", "Password", "Host", 1883, $"MORKS 设备监听数据{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
            //mQTTProxy.Connect(new BPA.Communication.Base.ConfigurationOptions()
            //{
            //    UserName = "UserName",
            //    Password = "Password",
            //    IpAddress = "Host",
            //    Port = 1883,
            //    ClientId = $"MORKS 设备监听数据{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"
            //});

            CommHelper.CreateMqtt("Host", "UserName", "Password", $"MORKS 设备监听数据{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}").OnSuccess(s =>
            {
                mQTTProxy = s.Content;
                mQTTProxy.Subscrib(ScreenTOPIC.GetInstance.GetTopic(ScreenDeviceType.煮面机));
                TaskManage.GetInstance.StartLong(new Action(() =>
                {
                    morkS.MorkS_OrderCount = Json<OrderStatistics>.Data.Count;
                    SendScreenDataModel sendScreenDataModel = new SendScreenDataModel();
                    sendScreenDataModel.Name = ScreenDeviceType.煮面机;
                    sendScreenDataModel.Value = morkS.ToJSON();
                    mQTTProxy.Publish(ScreenTOPIC.GetInstance.GetTopic(ScreenDeviceType.煮面机), sendScreenDataModel.ToJSON());
                    Thread.Sleep(100);
                }), "海科食堂大屏监听");
            });

        }

        //订单信息（正在制作，等待制作，制作完成）
        //煮面炉上下状态（6个煮面炉上或下）
        //温度状态（煮面炉温度是否到达）
        //料仓位置（当前料仓在几号位置）
        //料仓上下物料检测
        //落碗机构缺碗检测
        //机器人状态
        //当日订单总量
        //报警信息
    }
}