using DotNetty.Transport.Channels; using HybirdFrameworkCore.Autofac.Attribute; using log4net; using Service.Charger.Client; using Service.Charger.Common; using Service.Charger.Msg.Charger.Req; using Service.Charger.Msg.Charger.Resp; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using Aliyun.OSS.Util; using Common.Util; using Service.Init; namespace Service.Charger.Handler { /// /// 电池包实时遥信上报(站内充电模式有电池包时周期性上传) /// [Order(8)] [Scope("InstancePerDependency")] public class RemoteSignalingHandler : SimpleChannelInboundHandler, IBaseHandler { private static readonly ILog Log = LogManager.GetLogger(typeof(RemoteSignalingHandler)); protected override void ChannelRead0(IChannelHandlerContext ctx, RemoteSignaling msg) { if (ClientMgr.TryGetClient(ctx.Channel, out string sn, out var client)) { Log.Info($"receive {msg} from {sn}"); client.RemoteSignaling = msg; if (StaticStationInfo.AutoFireRelocation == 1) { if (msg.MaximumAlarmLevel == 3) { Log.Info($"receive msg.MaximumAlarmLevel = {msg.MaximumAlarmLevel} 触发自动消防移仓"); HttpUtil.SendPostRequest(client.BinNo,HttpUtil.MAIN_UER+"api/SwapMonitor/FireProtectionRelocation/"); } } } } } }