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

using System;
using System.Web.Mvc;
using System.Web.WebPages;
using Abp.Auditing;
using Abp.Authorization;
using Abp.Configuration;
using Abp.Web.Mvc.Authorization;
using IwbZero.ToolCommon;
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 => SettingManager.GetSettingValue(IwbSettingNames.WeEngineIp);

        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 = 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");
        }
    }

    
}