App_V2.3/SourceCode/WeApp.Web/Controllers/MsgMonitorController.cs

using System;
using System.Web.Mvc;
using System.Web.WebPages;

using Abp.Auditing;
using Abp.Web.Mvc.Authorization;

using IwbZero.ToolCommon;
using IwbZero.ToolCommon.StringModel;

using WeApp.CommonManager.MqttClient;
using WeApp.Configuration;

namespace WeApp.Controllers
{
    [AbpMvcAuthorize, DisableAuditing]
    public class MsgMonitorController : IwbControllerBase
    {
        public MsgMonitorController(WeAppMsgClientManager msgClient)
        {
            MsgClient = msgClient;
        }

        private string EngineUrl => IwbSettingNames.GetWeEngineIp(SettingManager).Ew("/");

        private WeAppMsgClientManager 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 = string.IsNullOrEmpty(id) ? 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 = string.IsNullOrEmpty(id) ? new Random().Next(1000, 9999) + "" : id;
            $"{EngineUrl}Home/Send?topic={IwbConsts.ClientName}&id={msg}".RequestPost("");
            return Content("OK");
        }
    }
}