From b9638e2f067b2168c32faece13b2f1d7b6aa172d Mon Sep 17 00:00:00 2001
From: xjl <2595686544@qq.com>
Date: Mon, 24 Jun 2024 14:57:40 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E4=B8=8B=E5=8F=91=E5=B0=96?=
 =?UTF-8?q?=E5=B3=B0=E5=B9=B3=E8=B0=B7=E7=9A=84=E6=97=A5=E5=BF=97=E5=92=8C?=
 =?UTF-8?q?=E6=8E=A5=E6=94=B6=E5=B0=96=E5=B3=B0=E5=B9=B3=E8=B0=B7=E7=9A=84?=
 =?UTF-8?q?handler?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Service/Charger/Client/ChargerClient.cs       |  4 +++
 .../Charger/Handler/ResponseSettingHandler.cs | 34 +++++++++++++++++++
 2 files changed, 38 insertions(+)
 create mode 100644 Service/Charger/Handler/ResponseSettingHandler.cs

diff --git a/Service/Charger/Client/ChargerClient.cs b/Service/Charger/Client/ChargerClient.cs
index e8c9f43..14ef6e4 100644
--- a/Service/Charger/Client/ChargerClient.cs
+++ b/Service/Charger/Client/ChargerClient.cs
@@ -455,9 +455,13 @@ public class ChargerClient : TcpClient<IBaseHandler, Decoder, Encoder>
             return Result<bool>.Fail($"charger-{BinNo} disconnect");
         }
 
+
         CurrentCmd = JsonConvert.SerializeObject(setPeakValleyTime, Formatting.Indented) + "\r\n" +
                      BitUtls.BytesToHexStr(setPeakValleyTime.ToBytes());
         this.Channel.WriteAndFlushAsync(setPeakValleyTime);
+
+       Log().Info($"SendSetPeakValleyTime{CurrentCmd} to chargeOrderNo={BinNo}");
+
         return Result<bool>.Success();
     }
 
diff --git a/Service/Charger/Handler/ResponseSettingHandler.cs b/Service/Charger/Handler/ResponseSettingHandler.cs
new file mode 100644
index 0000000..a21abde
--- /dev/null
+++ b/Service/Charger/Handler/ResponseSettingHandler.cs
@@ -0,0 +1,34 @@
+using System.Text;
+using DotNetty.Transport.Channels;
+using HybirdFrameworkCore.Autofac.Attribute;
+using log4net;
+using Service.Charger.Client;
+using Service.Charger.Handler;
+using Service.Charger.Msg.Charger.Req;
+using Service.Charger.Msg.Charger.Resp;
+using Service.Charger.Msg.Host.Resp;
+
+namespace HybirdFrameworkServices.Charger.Handler
+{
+    /// <summary>
+    /// 3.4.10 监控网关响应尖峰平谷设置
+    /// <code>
+    /// 1，保存日志到log
+    /// </code>
+    /// </summary>
+    [Order(8)]
+    [Scope("InstancePerDependency")]
+    public class ResponseSettingHandler : SimpleChannelInboundHandler<ResponseSetting>, IBaseHandler
+    {
+        private static readonly ILog Log = LogManager.GetLogger(typeof(ResponseSettingHandler));
+        protected override void ChannelRead0(IChannelHandlerContext ctx, ResponseSetting msg)
+        {
+            if (ClientMgr.TryGetClient(ctx.Channel, out var sn, out var client))
+            {
+                Log.Info($"receive {msg} from {sn}");
+
+            }
+            
+        }
+    }
+}