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