WEP_V2.1.3/SourceCode/We.AppOnline/WeOnlineApp.Web/Controllers/MsgMonitorController.cs

using System;
using System.Web.Mvc;
using System.Web.WebPages;
using Abp.Auditing;
using Abp.Configuration;
using Abp.Web.Mvc.Authorization;
using IwbZero.ToolCommon;
using WeOnlineApp.Configuration;
using WeOnlineApp.MqttClient;

namespace WeOnlineApp.Controllers
{
    [AbpMvcAuthorize, DisableAuditing]
    public class MsgMonitorController : IwbControllerBase
    {
        public MsgMonitorController(WeOnlineAppMsgClientManager msgClient)
        {
            MsgClient = msgClient;
        }
        private string EngineUrl => SettingManager.GetSettingValue(IwbSettingNames.WeEngineIp);

        private WeOnlineAppMsgClientManager MsgClient { get; }
        public ActionResult Index()
        {
            return View();
        }
        public ActionResult Refresh(int id)
        {
            if (id == 1)
            {
                MsgClient.RefreshClient();
            }
            else
            {
                $"{EngineUrl}/Home/RefreshClient".RequestPost("");
            }
            return Content("OK");
        }

        public ActionResult Send(string id)
        {
            string msg = id.IsEmpty() ? new Random().Next(1000, 9999) + "" : id;
            //MsgClient.SendMessage("WeEngine", $"APP发送测试消息：{msg}");
            MsgClient.SendMessage(IwbConsts.ClientName, $"APP发送测试消息：{msg}");
            return Content("OK");
        }
        public ActionResult EngineSend(string id)
        {
            string msg = id.IsEmpty() ? new Random().Next(1000, 9999) + "" : id;
            $"{EngineUrl}/Home/Send?topic={IwbConsts.ClientName}&id={msg}".RequestPost("");
            return Content("OK");
        }
    }
}