From 3de5990573473ba6dad2b9f61b1d597740cd6ff2 Mon Sep 17 00:00:00 2001
From: TianMaiCheng <746290578@qq.com>
Date: Tue, 3 Feb 2026 08:54:16 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
BLWLogProduce/EnergyConsumption.cs | 70 +++-
.../Redis_to_Kafka_System_Documentation.md | 307 ++++++++++++++++++
BLWLogProduce/Services/KafkaProduce.cs | 55 +++-
BLWLogServer/Services/KafkaConsume.cs | 13 +-
CommonEntity/Iot.cs | 4 +
CommonEntity/TSLog.cs | 84 ++++-
CommonEntity/UDPPackage.cs | 19 +-
DAL/New_Models/FcsorderDatum.cs | 25 ++
DAL/New_Models/RicsContext.cs | 37 +++
DAL/New_Models/TbSysHotel.cs | 4 +
Redis定阅/bin/Debug/net8.0/CommonEntity.dll | Bin 93696 -> 99840 bytes
Redis定阅/bin/Debug/net8.0/CommonEntity.pdb | Bin 75676 -> 77932 bytes
Redis定阅/bin/Debug/net8.0/CommonTools.dll | Bin 22528 -> 22528 bytes
Redis定阅/bin/Debug/net8.0/CommonTools.pdb | Bin 23148 -> 23148 bytes
Redis定阅/bin/Debug/net8.0/Redis定阅.dll | Bin 7168 -> 7168 bytes
Redis定阅/bin/Debug/net8.0/Redis定阅.exe | Bin 151552 -> 151552 bytes
Redis定阅/bin/Debug/net8.0/Redis定阅.pdb | Bin 15448 -> 15448 bytes
.../obj/Debug/net8.0/Redis定阅.AssemblyInfo.cs | 2 +-
.../net8.0/Redis定阅.AssemblyInfoInputs.cache | 2 +-
...阅.GeneratedMSBuildEditorConfig.editorconfig | 2 +-
.../Redis定阅.csproj.AssemblyReference.cache | Bin 39889 -> 37284 bytes
Redis定阅/obj/Debug/net8.0/Redis定阅.dll | Bin 7168 -> 7168 bytes
Redis定阅/obj/Debug/net8.0/Redis定阅.pdb | Bin 15448 -> 15448 bytes
Redis定阅/obj/Debug/net8.0/apphost.exe | Bin 151552 -> 151552 bytes
Redis定阅/obj/Debug/net8.0/ref/Redis定阅.dll | Bin 6656 -> 6656 bytes
.../obj/Debug/net8.0/refint/Redis定阅.dll | Bin 6656 -> 6656 bytes
.../Release/net8.0/Redis定阅.AssemblyInfo.cs | 2 +-
.../net8.0/Redis定阅.AssemblyInfoInputs.cache | 2 +-
.../Redis定阅.csproj.AssemblyReference.cache | Bin 39897 -> 37292 bytes
.../Controllers/ValuesController.cs | 249 ++++++++++++++
.../PublishProfiles/FolderProfile1.pubxml | 20 ++
.../FolderProfile1.pubxml.user | 9 +
UseSQLQueryData/UseSQLQueryData.csproj.user | 2 +-
33 files changed, 865 insertions(+), 43 deletions(-)
create mode 100644 BLWLogProduce/Redis_to_Kafka_System_Documentation.md
create mode 100644 DAL/New_Models/FcsorderDatum.cs
create mode 100644 UseSQLQueryData/Properties/PublishProfiles/FolderProfile1.pubxml
create mode 100644 UseSQLQueryData/Properties/PublishProfiles/FolderProfile1.pubxml.user
diff --git a/BLWLogProduce/EnergyConsumption.cs b/BLWLogProduce/EnergyConsumption.cs
index d836069..3fb728a 100644
--- a/BLWLogProduce/EnergyConsumption.cs
+++ b/BLWLogProduce/EnergyConsumption.cs
@@ -32,21 +32,22 @@ namespace BLWData.Entity {
"bHZlGAogASgFIoABChZTaW5nbGVQb3dlckNoYW5uZWxEYXRhEg8KB2FkZHJl",
"c3MYASABKAkSDgoGZGlhbnlhGAIgASgBEg8KB2RpYW5saXUYAyABKAESDgoG",
"Z29uZ2x2GAQgASgBEg8KB25lbmdoYW8YBSABKAESEwoLem9uZ25lbmdoYW8Y",
- "BiABKAEihAMKEUVuZXJneUNvbnN1bXB0aW9uEhEKCUhvdGVsQ29kZRgBIAEo",
+ "BiABKAEilgMKEUVuZXJneUNvbnN1bXB0aW9uEhEKCUhvdGVsQ29kZRgBIAEo",
"AxISCgpIb3N0TnVtYmVyGAIgASgJEgsKA01hYxgDIAEoCRIQCghFbmRQb2lu",
- "dBgEIAEoCRIPCgdWZXJzaW9uGAUgASgJEhIKCklzVGFrZUNhcmQYBiABKAgS",
+ "dBgEIAEoCRIPCgdWZXJzaW9uGAUgASgJEhIKCklzVGFrZUNhcmQYBiABKAUS",
"QAoQUG93ZXJDaGFubmVsTGlzdBgHIAMoCzImLkJMV0RhdGEuRW50aXR5LlNp",
"bmdsZVBvd2VyQ2hhbm5lbERhdGESEgoKQ3JlYXRlVGltZRgIIAEoAxISCgpS",
"b29tTnVtYmVyGAkgASgJEhEKCUNhcmJvblZJUBgKIAEoBRIUCgxJZGVudGl0",
"eUluZm8YCyABKAUSNAoQRGV2aWNlU3RhdHVzTGlzdBgMIAMoCzIaLkJMV0Rh",
"dGEuRW50aXR5LkRldmljZURhdGESEQoJQ2FyZEV2ZW50GA0gASgFEhQKDElz",
- "SW5zZXJ0Q2FyZBgOIAEoBRISCgpQTVNfU3RhdHVzGA8gASgJYgZwcm90bzM="));
+ "SW5zZXJ0Q2FyZBgOIAEoBRISCgpQTVNfU3RhdHVzGA8gASgJEhAKCEJyaWdo",
+ "dF9HGBAgASgFYgZwcm90bzM="));
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
new pbr::FileDescriptor[] { },
new pbr::GeneratedClrTypeInfo(null, null, new pbr::GeneratedClrTypeInfo[] {
new pbr::GeneratedClrTypeInfo(typeof(global::BLWData.Entity.DeviceData), global::BLWData.Entity.DeviceData.Parser, new[]{ "HostID", "DeviceType", "Address", "Status", "Brightness", "CurrentTemp", "SettingTemp", "FanSpeed", "Mode", "Valve" }, null, null, null, null),
new pbr::GeneratedClrTypeInfo(typeof(global::BLWData.Entity.SinglePowerChannelData), global::BLWData.Entity.SinglePowerChannelData.Parser, new[]{ "Address", "Dianya", "Dianliu", "Gonglv", "Nenghao", "Zongnenghao" }, null, null, null, null),
- new pbr::GeneratedClrTypeInfo(typeof(global::BLWData.Entity.EnergyConsumption), global::BLWData.Entity.EnergyConsumption.Parser, new[]{ "HotelCode", "HostNumber", "Mac", "EndPoint", "Version", "IsTakeCard", "PowerChannelList", "CreateTime", "RoomNumber", "CarbonVIP", "IdentityInfo", "DeviceStatusList", "CardEvent", "IsInsertCard", "PMSStatus" }, null, null, null, null)
+ new pbr::GeneratedClrTypeInfo(typeof(global::BLWData.Entity.EnergyConsumption), global::BLWData.Entity.EnergyConsumption.Parser, new[]{ "HotelCode", "HostNumber", "Mac", "EndPoint", "Version", "IsTakeCard", "PowerChannelList", "CreateTime", "RoomNumber", "CarbonVIP", "IdentityInfo", "DeviceStatusList", "CardEvent", "IsInsertCard", "PMSStatus", "BrightG" }, null, null, null, null)
}));
}
#endregion
@@ -1023,6 +1024,7 @@ namespace BLWData.Entity {
cardEvent_ = other.cardEvent_;
isInsertCard_ = other.isInsertCard_;
pMSStatus_ = other.pMSStatus_;
+ brightG_ = other.brightG_;
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
}
@@ -1094,10 +1096,10 @@ namespace BLWData.Entity {
/// Field number for the "IsTakeCard" field.
public const int IsTakeCardFieldNumber = 6;
- private bool isTakeCard_;
+ private int isTakeCard_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
- public bool IsTakeCard {
+ public int IsTakeCard {
get { return isTakeCard_; }
set {
isTakeCard_ = value;
@@ -1210,6 +1212,18 @@ namespace BLWData.Entity {
}
}
+ /// Field number for the "Bright_G" field.
+ public const int BrightGFieldNumber = 16;
+ private int brightG_;
+ [global::System.Diagnostics.DebuggerNonUserCodeAttribute]
+ [global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
+ public int BrightG {
+ get { return brightG_; }
+ set {
+ brightG_ = value;
+ }
+ }
+
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
[global::System.CodeDom.Compiler.GeneratedCode("protoc", null)]
public override bool Equals(object other) {
@@ -1240,6 +1254,7 @@ namespace BLWData.Entity {
if (CardEvent != other.CardEvent) return false;
if (IsInsertCard != other.IsInsertCard) return false;
if (PMSStatus != other.PMSStatus) return false;
+ if (BrightG != other.BrightG) return false;
return Equals(_unknownFields, other._unknownFields);
}
@@ -1252,7 +1267,7 @@ namespace BLWData.Entity {
if (Mac.Length != 0) hash ^= Mac.GetHashCode();
if (EndPoint.Length != 0) hash ^= EndPoint.GetHashCode();
if (Version.Length != 0) hash ^= Version.GetHashCode();
- if (IsTakeCard != false) hash ^= IsTakeCard.GetHashCode();
+ if (IsTakeCard != 0) hash ^= IsTakeCard.GetHashCode();
hash ^= powerChannelList_.GetHashCode();
if (CreateTime != 0L) hash ^= CreateTime.GetHashCode();
if (RoomNumber.Length != 0) hash ^= RoomNumber.GetHashCode();
@@ -1262,6 +1277,7 @@ namespace BLWData.Entity {
if (CardEvent != 0) hash ^= CardEvent.GetHashCode();
if (IsInsertCard != 0) hash ^= IsInsertCard.GetHashCode();
if (PMSStatus.Length != 0) hash ^= PMSStatus.GetHashCode();
+ if (BrightG != 0) hash ^= BrightG.GetHashCode();
if (_unknownFields != null) {
hash ^= _unknownFields.GetHashCode();
}
@@ -1300,9 +1316,9 @@ namespace BLWData.Entity {
output.WriteRawTag(42);
output.WriteString(Version);
}
- if (IsTakeCard != false) {
+ if (IsTakeCard != 0) {
output.WriteRawTag(48);
- output.WriteBool(IsTakeCard);
+ output.WriteInt32(IsTakeCard);
}
powerChannelList_.WriteTo(output, _repeated_powerChannelList_codec);
if (CreateTime != 0L) {
@@ -1334,6 +1350,10 @@ namespace BLWData.Entity {
output.WriteRawTag(122);
output.WriteString(PMSStatus);
}
+ if (BrightG != 0) {
+ output.WriteRawTag(128, 1);
+ output.WriteInt32(BrightG);
+ }
if (_unknownFields != null) {
_unknownFields.WriteTo(output);
}
@@ -1364,9 +1384,9 @@ namespace BLWData.Entity {
output.WriteRawTag(42);
output.WriteString(Version);
}
- if (IsTakeCard != false) {
+ if (IsTakeCard != 0) {
output.WriteRawTag(48);
- output.WriteBool(IsTakeCard);
+ output.WriteInt32(IsTakeCard);
}
powerChannelList_.WriteTo(ref output, _repeated_powerChannelList_codec);
if (CreateTime != 0L) {
@@ -1398,6 +1418,10 @@ namespace BLWData.Entity {
output.WriteRawTag(122);
output.WriteString(PMSStatus);
}
+ if (BrightG != 0) {
+ output.WriteRawTag(128, 1);
+ output.WriteInt32(BrightG);
+ }
if (_unknownFields != null) {
_unknownFields.WriteTo(ref output);
}
@@ -1423,8 +1447,8 @@ namespace BLWData.Entity {
if (Version.Length != 0) {
size += 1 + pb::CodedOutputStream.ComputeStringSize(Version);
}
- if (IsTakeCard != false) {
- size += 1 + 1;
+ if (IsTakeCard != 0) {
+ size += 1 + pb::CodedOutputStream.ComputeInt32Size(IsTakeCard);
}
size += powerChannelList_.CalculateSize(_repeated_powerChannelList_codec);
if (CreateTime != 0L) {
@@ -1449,6 +1473,9 @@ namespace BLWData.Entity {
if (PMSStatus.Length != 0) {
size += 1 + pb::CodedOutputStream.ComputeStringSize(PMSStatus);
}
+ if (BrightG != 0) {
+ size += 2 + pb::CodedOutputStream.ComputeInt32Size(BrightG);
+ }
if (_unknownFields != null) {
size += _unknownFields.CalculateSize();
}
@@ -1476,7 +1503,7 @@ namespace BLWData.Entity {
if (other.Version.Length != 0) {
Version = other.Version;
}
- if (other.IsTakeCard != false) {
+ if (other.IsTakeCard != 0) {
IsTakeCard = other.IsTakeCard;
}
powerChannelList_.Add(other.powerChannelList_);
@@ -1502,6 +1529,9 @@ namespace BLWData.Entity {
if (other.PMSStatus.Length != 0) {
PMSStatus = other.PMSStatus;
}
+ if (other.BrightG != 0) {
+ BrightG = other.BrightG;
+ }
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
}
@@ -1542,7 +1572,7 @@ namespace BLWData.Entity {
break;
}
case 48: {
- IsTakeCard = input.ReadBool();
+ IsTakeCard = input.ReadInt32();
break;
}
case 58: {
@@ -1581,6 +1611,10 @@ namespace BLWData.Entity {
PMSStatus = input.ReadString();
break;
}
+ case 128: {
+ BrightG = input.ReadInt32();
+ break;
+ }
}
}
#endif
@@ -1621,7 +1655,7 @@ namespace BLWData.Entity {
break;
}
case 48: {
- IsTakeCard = input.ReadBool();
+ IsTakeCard = input.ReadInt32();
break;
}
case 58: {
@@ -1660,6 +1694,10 @@ namespace BLWData.Entity {
PMSStatus = input.ReadString();
break;
}
+ case 128: {
+ BrightG = input.ReadInt32();
+ break;
+ }
}
}
}
diff --git a/BLWLogProduce/Redis_to_Kafka_System_Documentation.md b/BLWLogProduce/Redis_to_Kafka_System_Documentation.md
new file mode 100644
index 0000000..e0be1a0
--- /dev/null
+++ b/BLWLogProduce/Redis_to_Kafka_System_Documentation.md
@@ -0,0 +1,307 @@
+# Redis消息转发到Kafka系统设计与实现
+
+## 1. 项目概述
+
+本项目是一个消息转发服务，主要功能是将从Redis订阅的各种消息，经过序列化处理后发送到Kafka队列。为了节省网络流量，系统根据不同消息类型采用了两种序列化方式：
+- 大部分消息使用MessagePack序列化
+- 特定消息使用Google Protocol Buffer序列化
+
+## 2. 系统架构
+
+### 2.1 核心组件
+
+| 组件 | 功能描述 | 实现文件 |
+|------|---------|---------|
+| KafkaProduce | 后台服务，负责Redis订阅和Kafka发送 | Services/KafkaProduce.cs |
+| MyPublishRedis | Redis发布订阅管理 | Models/MyPublishRedis.cs |
+| MessagePack序列化 | 轻量级序列化方案 | 通过MyMessagePacker实现 |
+| Protobuf序列化 | 高效二进制序列化方案 | EnergyConsumption.cs, NewActionChangeDataPush.cs |
+
+### 2.2 数据流图
+
+```mermaid
+flowchart TD
+ subgraph 数据来源
+ A[Redis消息发布者]
+ end
+
+ subgraph 消息处理层
+ B[Redis订阅] --> C[消息类型判断]
+ C --> D1[MessagePack序列化]
+ C --> D2[Protobuf序列化]
+ end
+
+ subgraph 消息发送层
+ D1 --> E[Kafka生产者]
+ D2 --> E
+ end
+
+ subgraph 数据去向
+ E --> F[Kafka队列]
+ end
+```
+
+## 3. 核心功能实现
+
+### 3.1 Redis订阅管理
+
+系统通过`CSRedisClient`订阅多个Redis通道，每个通道对应不同类型的消息：
+
+```csharp
+// 订阅UDP包数据
+var DingYue = ("redis-udppackage", new Action(async (args) =>
+{
+ try
+ {
+ string body = args.Body;
+ UDPPackage? usa = System.Text.Json.JsonSerializer.Deserialize(body);
+ // 处理数据...
+ byte[] bytes = MyMessagePacker.FastSerialize(usa);
+ // 发送到Kafka...
+ }
+ catch (Exception ex)
+ {
+ Console.WriteLine(ex.Message);
+ Console.WriteLine(ex.StackTrace);
+ }
+}));
+
+// 订阅其他通道...
+
+// 执行订阅
+CSRedisCacheHelper.redis3.Subscribe(DingYue);
+CSRedisCacheHelper.redis3.Subscribe(DingYue1);
+// 更多订阅...
+```
+
+
+### 3.2 序列化策略
+
+#### 3.2.1 MessagePack序列化
+
+大部分消息类型使用MessagePack进行序列化，通过`MyMessagePacker.FastSerialize`方法实现：
+
+```csharp
+// 序列化UDP包数据
+byte[] bytes = MyMessagePacker.FastSerialize(usa);
+var dr = await p.ProduceAsync(TopicKey, new Message { Key = DetailKey, Value = bytes });
+
+// 序列化房间状态数据
+StepInfo? usa = System.Text.Json.JsonSerializer.Deserialize(body);
+byte[] bytes = MyMessagePacker.FastSerialize(usa);
+await p.ProduceAsync(TopicKey, new Message { Key = DetailKey, Value = bytes });
+```
+
+
+#### 3.2.2 Protobuf序列化
+
+特定类型的消息（如能耗数据、设备动作数据）使用Protobuf进行序列化：
+
+```csharp
+// 能耗数据使用Protobuf序列化
+EnergyConsumption ese = new EnergyConsumption();
+ese.HotelCode = poo.HotelCode;
+ese.HostNumber = poo.HostNumber;
+// 设置其他字段...
+byte[] data = ese.ToByteArray();
+await p.ProduceAsync(TopicKey1, new Message { Key = DetailKey1, Value = data });
+
+// 设备动作数据使用Protobuf序列化
+NewActionChangeDataPush ese = new NewActionChangeDataPush();
+ese.Code = poo.code;
+ese.RoomNumber = poo.roomNumber;
+// 设置其他字段...
+byte[] data = ese.ToByteArray();
+await p.ProduceAsync(TopicKey1, new Message { Key = DetailKey1, Value = data });
+```
+
+
+### 3.3 Kafka发送实现
+
+系统使用Confluent.Kafka客户端库实现Kafka消息发送：
+
+```csharp
+// 初始化Kafka生产者
+string? ipport = Configuration["Kafka:EndPoint"];
+string? user = Configuration["Kafka:UserName"];
+string? pwd = Configuration["Kafka:PassWord"];
+var config = new ProducerConfig
+{
+ BootstrapServers = ipport,
+ SecurityProtocol = SecurityProtocol.SaslPlaintext,
+ SaslMechanism = SaslMechanism.Plain,
+ SaslUsername = user,
+ SaslPassword = pwd
+};
+var p = new ProducerBuilder(config).Build();
+
+// 发送消息
+var dr = await p.ProduceAsync(TopicKey, new Message { Key = DetailKey, Value = bytes });
+```
+
+
+## 4. 消息类型与处理
+
+### 4.1 主要消息类型
+
+| 消息类型 | Redis通道 | 序列化方式 | Kafka主题 | 用途 |
+|---------|----------|-----------|----------|------|
+| UDP包数据 | redis-udppackage | MessagePack | BLWLog_RCU_Topic | 设备通信数据 |
+| 房间状态监控 | redis-roomstatus-monitor | MessagePack | BLWLog_RCU_Topic | 房间状态变化 |
+| 旁路系统数据 | redis-forksystemdata | MessagePack | BLWLog_RCU_Topic | 旁路系统信息 |
+| 能耗数据 | redis-power | Protobuf | BLWLog4BaoJing_RCU_Topic | 能耗统计 |
+| 设备动作数据 | redis-action-data | Protobuf | BLWLog4BaoJing_RCU_Topic | 设备操作记录 |
+| 在线离线状态 | redis-on_off_line | Protobuf | BLWLog4BaoJing_RCU_Topic | 设备在线状态 |
+| 服务状态变化 | redis-serviceinfo_change | MessagePack | BLWLog_RCU_Topic | 服务状态监控 |
+| 第三方接口调用 | redis-invoke_httpinterface | MessagePack | BLWLog_RCU_Topic | 接口调用日志 |
+| 新版本协议数据 | redis-rcu-* | MessagePack | BLWLog_RCU_Topic | 新协议设备数据 |
+| 选住数据 | Redis-XuanZhuKafka | Protobuf | BLWLog4XuanZhu_RCU_Topic | 选住系统数据 |
+
+### 4.2 消息处理流程
+
+1. **消息接收**：通过Redis订阅接收消息
+2. **消息解析**：将JSON格式的消息解析为对应的数据模型
+3. **数据处理**：根据需要对数据进行转换和处理
+4. **序列化**：根据消息类型选择合适的序列化方式
+5. **发送到Kafka**：将序列化后的数据发送到对应的Kafka主题
+
+## 5. 序列化方案对比
+
+### 5.1 MessagePack vs Protocol Buffer
+
+| 特性 | MessagePack | Protocol Buffer |
+|------|-------------|-----------------|
+| 序列化速度 | 非常快 | 快 |
+| 序列化大小 | 小 | 非常小 |
+| 开发难度 | 低 | 中等（需要定义.proto文件） |
+| 类型安全 | 中等 | 高 |
+| 适用场景 | 一般消息 | 结构化数据、性能敏感场景 |
+
+### 5.2 选择策略
+
+系统根据以下原则选择序列化方案：
+- **MessagePack**：适用于大部分通用消息，开发简单，性能足够
+- **Protocol Buffer**：适用于结构化数据（如能耗数据、设备动作数据），以及对性能和数据大小要求较高的场景
+
+## 6. 代码优化建议
+
+### 6.1 异常处理优化
+
+当前代码中的异常处理较为简单，仅打印异常信息：
+
+```csharp
+try
+{
+ // 处理逻辑
+}
+catch (Exception ex)
+{
+ Console.WriteLine(ex.Message);
+ Console.WriteLine(ex.StackTrace);
+}
+```
+
+**优化建议**：
+- 使用NLog等日志框架记录详细异常信息
+- 实现重试机制，提高系统可靠性
+- 对不同类型的异常进行分类处理
+
+### 6.2 配置管理优化
+
+当前Kafka配置直接从Configuration读取：
+
+```csharp
+string? ipport = Configuration["Kafka:EndPoint"];
+string? user = Configuration["Kafka:UserName"];
+string? pwd = Configuration["Kafka:PassWord"];
+```
+
+**优化建议**：
+- 使用强类型配置类，提高代码可维护性
+- 实现配置热更新机制
+- 添加配置验证逻辑
+
+### 6.3 序列化工具封装
+
+当前序列化调用较为分散：
+
+```csharp
+// MessagePack序列化
+byte[] bytes = MyMessagePacker.FastSerialize(usa);
+
+// Protobuf序列化
+byte[] data = ese.ToByteArray();
+```
+
+**优化建议**：
+- 封装统一的序列化工具类，根据消息类型自动选择序列化方式
+- 提供序列化性能监控
+- 实现序列化缓存机制，提高重复消息的处理速度
+
+## 7. 性能与扩展性
+
+### 7.1 性能优化
+
+- **批量处理**：对相似消息进行批量处理，减少Kafka网络请求
+- **连接池**：使用Redis和Kafka连接池，减少连接建立开销
+- **异步处理**：充分利用异步编程模型，提高系统吞吐量
+- **内存管理**：优化内存使用，减少GC压力
+
+### 7.2 扩展性设计
+
+- **模块化**：消息处理逻辑模块化，便于添加新的消息类型
+- **插件架构**：支持通过插件方式扩展新的序列化方案
+- **多租户**：支持多租户配置，适应不同场景需求
+- **监控指标**：提供详细的系统运行指标，便于监控和调优
+
+## 8. 技术栈
+
+| 技术 | 版本/库 | 用途 |
+|------|---------|------|
+| .NET Core | 6.0+ | 运行环境 |
+| Redis | CSRedisClient | 消息订阅 |
+| Kafka | Confluent.Kafka | 消息发送 |
+| MessagePack | MyMessagePacker | 序列化 |
+| Protocol Buffer | Google.Protobuf | 序列化 |
+| NLog | NLog | 日志记录 |
+
+## 9. 部署与运维
+
+### 9.1 部署方式
+
+- **容器化**：使用Docker容器部署，便于横向扩展
+- **服务编排**：使用Kubernetes管理容器集群
+- **配置管理**：使用配置中心统一管理配置
+
+### 9.2 监控与告警
+
+- **健康检查**：实现服务健康检查接口
+- **指标监控**：收集Redis订阅、Kafka发送等关键指标
+- **告警机制**：对异常情况及时告警
+
+### 9.3 日志管理
+
+- **结构化日志**：使用结构化日志格式，便于分析
+- **日志聚合**：使用ELK等日志聚合系统
+- **日志轮转**：实现日志轮转，避免磁盘空间耗尽
+
+## 10. 总结
+
+本项目实现了一个高效的Redis消息转发到Kafka的系统，通过合理选择序列化方案，在保证性能的同时节省了网络流量。系统架构清晰，模块划分合理，具有良好的扩展性和可维护性。
+
+### 10.1 核心优势
+
+1. **序列化策略**：根据消息类型选择合适的序列化方案，平衡了性能和开发效率
+2. **异步处理**：充分利用异步编程模型，提高系统吞吐量
+3. **模块化设计**：消息处理逻辑模块化，便于扩展和维护
+4. **可靠性**：通过异常处理和日志记录，提高系统可靠性
+
+### 10.2 应用场景
+
+本系统适用于以下场景：
+- **物联网设备数据**：收集和转发物联网设备产生的大量数据
+- **监控系统**：实时监控和转发各种监控指标
+- **日志聚合**：集中收集和处理分布式系统的日志
+- **数据同步**：在不同系统间实现数据同步
+
+通过本系统的实现，不仅解决了Redis到Kafka的消息转发问题，也为类似场景的消息处理提供了参考方案。
\ No newline at end of file
diff --git a/BLWLogProduce/Services/KafkaProduce.cs b/BLWLogProduce/Services/KafkaProduce.cs
index fb14c96..5d0d5fe 100644
--- a/BLWLogProduce/Services/KafkaProduce.cs
+++ b/BLWLogProduce/Services/KafkaProduce.cs
@@ -9,6 +9,7 @@ using Google.Protobuf;
using MessagePack;
using Microsoft.CodeAnalysis.Host.Mef;
using Microsoft.Extensions.Caching.Memory;
+using Microsoft.Extensions.ObjectPool;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using NLog;
@@ -374,14 +375,14 @@ namespace BLWLogProduce.Services
{
return;
}
- logger.Error("能耗：" + body);
+ //logger.Error("能耗：" + body);
//string str= Newtonsoft.Json.JsonConvert.SerializeObject(poo);
//Console.WriteLine("收到了"+str);
- byte[] qf = MyMessagePacker.FastSerialize(poo);
+ //byte[] qf = MyMessagePacker.FastSerialize(poo);
- string TopicKey = KafkaKey.BLWLog_RCU_Topic;
- string DetailKey = KafkaKey.UDPPackagePowerMonitor;
- await p.ProduceAsync(TopicKey, new Message { Key = DetailKey, Value = qf });
+ //string TopicKey = KafkaKey.BLWLog_RCU_Topic;
+ //string DetailKey = KafkaKey.UDPPackagePowerMonitor;
+ //await p.ProduceAsync(TopicKey, new Message { Key = DetailKey, Value = qf });
#region 宝镜系统使用的能耗数据结构
@@ -440,6 +441,7 @@ namespace BLWLogProduce.Services
ese.IdentityInfo = poo.IdentityInfo;
ese.CardEvent = poo.CardEvent;
ese.PMSStatus = poo.PMS_Status;
+ ese.BrightG = poo.Bright_G;
byte[] data = ese.ToByteArray();
string TopicKey1 = KafkaKey.BLWLog4BaoJing_RCU_Topic;
@@ -514,6 +516,10 @@ namespace BLWLogProduce.Services
NewVersionLog? poo = System.Text.Json.JsonSerializer.Deserialize(body);
poo.ts_ms = Tools.GetUnixTime_MS();
+ if (string.IsNullOrEmpty(poo.hotel_id) || string.IsNullOrEmpty(poo.device_id))
+ {
+ return;
+ }
string TopicKey1 = KafkaKey.BLWLog4NodeJs_RCU_Topic;
string DetailKey1 = poo.comm_seq.ToString();
@@ -529,6 +535,35 @@ namespace BLWLogProduce.Services
}));
+ var TSLog_DingYue_0X36 = ("redis-0X36-0X0F", new Action(async (args) =>
+ {
+ string body = args.Body;
+
+ try
+ {
+ DeviceActionData? poo = System.Text.Json.JsonSerializer.Deserialize(body);
+ poo.ts_ms = Tools.GetUnixTime_MS();
+
+ if (string.IsNullOrEmpty(poo.hotel_id) || string.IsNullOrEmpty(poo.device_id))
+ {
+ return;
+ }
+ string TopicKey1 = KafkaKey.BLWLog4NodeJs_RCU_Action_Topic;
+ string DetailKey1 = poo.frame_id.ToString();
+
+ var jsonstr = JsonConvert.SerializeObject(poo);
+ await p.ProduceAsync(TopicKey1, new Message { Key = DetailKey1, Value = Encoding.UTF8.GetBytes(jsonstr) });
+
+ }
+ catch (Exception ex)
+ {
+ Console.WriteLine(ex.Message);
+ Console.WriteLine(ex.StackTrace);
+ }
+ }));
+
+
+
#region 碳达人
//var DingYue3_1 = ("redis-carbon_trigger", new Action(async (args) =>
//{
@@ -630,6 +665,8 @@ namespace BLWLogProduce.Services
string body = args.Body;
CommonEntity.OnOffLineData? usa = System.Text.Json.JsonSerializer.Deserialize(body);
+ //poo.ts_ms = Tools.GetUnixTime_MS();
+ usa.UnixTime = Tools.GetUnixTime_MS();
if (string.IsNullOrEmpty(usa.EndPoint))
{
logger.Error("RCUOnOffLine:" + body);
@@ -640,6 +677,12 @@ namespace BLWLogProduce.Services
logger.Error("RCUOnOffLine:" + body);
return;
}
+
+ string Key1 = KafkaKey.BLWLog4NodeJs_RCU_OnOffLine_Topic;
+ string Key2 = usa.HostNumber;
+ byte[] nnn = Encoding.UTF8.GetBytes(body);
+ var dr = await p.ProduceAsync(Key1, new Message { Key = Key2, Value = nnn });
+
BLWData.Entity.OnOffLineData ese = new BLWData.Entity.OnOffLineData();
ese.HotelCode = usa.HotelCode;
ese.HostNumber = usa.HostNumber;
@@ -649,7 +692,6 @@ namespace BLWLogProduce.Services
ese.Mac = usa.MAC ?? "";
ese.CurrentTime = usa.CurrentTime.ToString("yyyy-MM-dd HH:mm:ss.fff");
-
byte[] data = ese.ToByteArray();
string TopicKey1 = KafkaKey.BLWLog4BaoJing_RCU_Topic;
string DetailKey1 = KafkaKey.RCUOnLineStatus;
@@ -913,6 +955,7 @@ namespace BLWLogProduce.Services
//新版本日志
CSRedisCacheHelper.redis3.Subscribe(TSLog_DingYue);
+ CSRedisCacheHelper.redis3.Subscribe(TSLog_DingYue_0X36);
}
catch (Exception ex)
{
diff --git a/BLWLogServer/Services/KafkaConsume.cs b/BLWLogServer/Services/KafkaConsume.cs
index b017a77..ca60df7 100644
--- a/BLWLogServer/Services/KafkaConsume.cs
+++ b/BLWLogServer/Services/KafkaConsume.cs
@@ -200,12 +200,13 @@ namespace BLWLogServer.Services
us.HostNumber = UDPPPP.HostNumber;
us.Mac = UDPPPP.Mac;
us.EndPoint = UDPPPP.EndPoint;
- us.V = UDPPPP.V;
- us.A = UDPPPP.A;
- us.P = UDPPPP.P;
- us.Energy_Consumption = UDPPPP.Energy_Consumption;
- us.Sum_Energy_Consumption = UDPPPP.Sum_Energy_Consumption;
- us.IsTakeCard = UDPPPP.IsTakeCard;
+ //us.V = UDPPPP.V;
+ //us.A = UDPPPP.A;
+ //us.P = UDPPPP.P;
+ //us.Energy_Consumption = UDPPPP.Energy_Consumption;
+ //us.Sum_Energy_Consumption = UDPPPP.Sum_Energy_Consumption;
+ us.NengHaoList = UDPPPP.NengHaoList;
+ //us.IsTakeCard = UDPPPP.IsTakeCard;
us.CreateTime = UDPPPP.CreateTime;
us.ReportTime = DateTime.Parse(UDPPPP.ReportTime);
diff --git a/CommonEntity/Iot.cs b/CommonEntity/Iot.cs
index b86bfd0..a47e5a5 100644
--- a/CommonEntity/Iot.cs
+++ b/CommonEntity/Iot.cs
@@ -103,6 +103,10 @@ namespace CommonEntity
[Id(6)]
[Key(6)]
public string? RoomNumber { get; set; }
+
+ [Id(7)]
+ [Key(7)]
+ public long? UnixTime { get; set; }
}
diff --git a/CommonEntity/TSLog.cs b/CommonEntity/TSLog.cs
index 1156a06..62cbd4f 100644
--- a/CommonEntity/TSLog.cs
+++ b/CommonEntity/TSLog.cs
@@ -6,6 +6,58 @@ using System.Threading.Tasks;
namespace CommonEntity
{
+
+
+ public class ts_deviceitem
+ {
+ public short dev_type { get; set; }
+ public short dev_addr { get; set; }
+ public short dev_loop { get; set; }
+ public int dev_data { get; set; }
+ }
+ public class ts_faultitem
+ {
+ public short dev_type { get; set; }
+ public short dev_addr { get; set; }
+ public short dev_loop { get; set; }
+ public short error_type { get; set; }
+ public int error_data { get; set; }
+ }
+ public class ts_controlitem
+ {
+ public short dev_type { get; set; }
+ public short dev_addr { get; set; }
+ public short dev_loop { get; set; }
+ public short type_l { get; set; }
+ public int type_h { get; set; }
+ }
+ ///
+ /// 0x36
+ ///
+ public class DeviceActionData
+ {
+ public long ts_ms { get; set; }
+ public string hotel_id { get; set; }
+ public string room_id { get; set; }
+ public string device_id { get; set; }
+ ///
+ /// "上报" 或 "下发"
+ ///
+ public string direction { get; set; }
+
+ public string cmd_word { get; set; }
+ public int frame_id { get; set; }
+ public byte[] udp_raw { get; set; }
+ public int sys_lock_status { get; set; }
+
+ public int report_count { get; set; }
+ public int fault_count { get; set; }
+ public List device_list { get; set; }
+ public List fault_list { get; set; }
+ public List control_list { get; set; }
+
+ }
+
///
/// ts 日志
///
@@ -26,15 +78,41 @@ namespace CommonEntity
public int comm_seq { get; set; }
public long ts_ms { get; set; }
+ public List electricity { get; set; }
+ public List air_conditioner { get; set; }
public extra_data extra { get; set; }
+ public int insert_card { get; set; }
+ public int bright_g { get; set; }
+ public int version { get; set; }
+
+ }
+ public class NengHaolog
+ {
+ public string address { get; set; }
+ public double voltage { get; set; }
+ public double ampere { get; set; }
+ public double power { get; set; }
+ public double energy { get; set; }
+ public double sum_energy { get; set; }
+ public string phase { get; set; }
+ }
+ public class KongTiao
+ {
+ public string address { get; set; }
+ public int state { get; set; }
+ public int model { get; set; }
+ public int speed { get; set; }
+ public int set_temp { get; set; }
+ public int now_temp { get; set; }
+ public int solenoid_valve { get; set; }
}
public class extra_data
{
public byte[] original_byte { get; set; }
- public string source { get; set; }
+ //public string source { get; set; }
public string ver { get; set; }
- public object ac { get; set; }
- public object meter { get; set; }
+ //public object ac { get; set; }
+ //public object meter { get; set; }
}
}
diff --git a/CommonEntity/UDPPackage.cs b/CommonEntity/UDPPackage.cs
index fec19b3..fed1f47 100644
--- a/CommonEntity/UDPPackage.cs
+++ b/CommonEntity/UDPPackage.cs
@@ -35,6 +35,8 @@ namespace CommonEntity
/// 心跳包
///
public static string BLWLog4NodeJs_RCU_Topic = "blwlog4Nodejs-rcu-heartbeat-topic";
+ public static string BLWLog4NodeJs_RCU_OnOffLine_Topic = "blwlog4Nodejs-rcu-onoffline-topic";
+ public static string BLWLog4NodeJs_RCU_Action_Topic = "blwlog4Nodejs-rcu-action-topic";
#endregion
@@ -231,7 +233,7 @@ namespace CommonEntity
public string? Version { get; set; }
[Key(5)]
- public bool IsTakeCard { get; set; }
+ public int IsTakeCard { get; set; }
[Key(6)]
public List NengHaoList { get; set; }
@@ -294,6 +296,9 @@ namespace CommonEntity
[Key(15)]
public int IsInsertCard { get; set; }
+
+ [Key(16)]
+ public int Bright_G { get; set; }
}
[MessagePackObject()]
@@ -470,11 +475,13 @@ namespace CommonEntity
public string? EndPoint { get; set; }
public string? Version { get; set; }
public bool IsTakeCard { get; set; }
- public double V { get; set; }
- public double A { get; set; }
- public double P { get; set; }
- public double Energy_Consumption { get; set; }
- public double Sum_Energy_Consumption { get; set; }
+
+ public List NengHaoList { get; set; }
+ //public double V { get; set; }
+ //public double A { get; set; }
+ //public double P { get; set; }
+ //public double Energy_Consumption { get; set; }
+ //public double Sum_Energy_Consumption { get; set; }
public long CreateTime { get; set; }
public DateTime ReportTime { get; set; }
diff --git a/DAL/New_Models/FcsorderDatum.cs b/DAL/New_Models/FcsorderDatum.cs
new file mode 100644
index 0000000..5df8db0
--- /dev/null
+++ b/DAL/New_Models/FcsorderDatum.cs
@@ -0,0 +1,25 @@
+using System;
+using System.Collections.Generic;
+
+namespace DAL.New_Models;
+
+public partial class FcsorderDatum
+{
+ public int Id { get; set; }
+
+ public string? LocationUuid { get; set; }
+
+ public string? ItemUuid { get; set; }
+
+ public string? HotelCode { get; set; }
+
+ public string? HostNumber { get; set; }
+
+ public string? HostRoomnum { get; set; }
+
+ public string? ItemClass { get; set; }
+
+ public byte[]? UpdateTime { get; set; }
+
+ public string? FcsorderUuid { get; set; }
+}
diff --git a/DAL/New_Models/RicsContext.cs b/DAL/New_Models/RicsContext.cs
index fdf62d2..865c419 100644
--- a/DAL/New_Models/RicsContext.cs
+++ b/DAL/New_Models/RicsContext.cs
@@ -21,6 +21,8 @@ public partial class RicsContext : DbContext
public virtual DbSet EcoSettings { get; set; }
+ public virtual DbSet FcsorderData { get; set; }
+
public virtual DbSet KongTiaoTimers { get; set; }
public virtual DbSet LieEcos { get; set; }
@@ -167,6 +169,8 @@ public partial class RicsContext : DbContext
public virtual DbSet TftpSets { get; set; }
+ //protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ // => optionsBuilder.UseSqlServer("Data Source=DESKTOP-DUNS5K7;Initial Catalog=RICS;User ID=sa;Password=123456;Trust Server Certificate=True");
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
@@ -218,6 +222,33 @@ public partial class RicsContext : DbContext
entity.Property(e => e.StartTime).HasMaxLength(64);
});
+ modelBuilder.Entity(entity =>
+ {
+ entity.ToTable("FCSOrderData");
+
+ entity.Property(e => e.Id).HasColumnName("ID");
+ entity.Property(e => e.FcsorderUuid)
+ .HasMaxLength(64)
+ .HasColumnName("FCSOrderUUID");
+ entity.Property(e => e.HostNumber)
+ .HasMaxLength(64)
+ .HasColumnName("HostNUMBER");
+ entity.Property(e => e.HostRoomnum)
+ .HasMaxLength(64)
+ .HasColumnName("HostROOMNUM");
+ entity.Property(e => e.HotelCode).HasMaxLength(64);
+ entity.Property(e => e.ItemClass).HasMaxLength(64);
+ entity.Property(e => e.ItemUuid)
+ .HasMaxLength(64)
+ .HasColumnName("ItemUUID");
+ entity.Property(e => e.LocationUuid)
+ .HasMaxLength(64)
+ .HasColumnName("LocationUUID");
+ entity.Property(e => e.UpdateTime)
+ .IsRowVersion()
+ .IsConcurrencyToken();
+ });
+
modelBuilder.Entity(entity =>
{
entity.HasKey(e => e.Id).HasName("PK_KongTiaoTimer_1");
@@ -1972,6 +2003,9 @@ public partial class RicsContext : DbContext
.HasComment("英文名称")
.HasColumnName("EName");
entity.Property(e => e.EndDayTime).HasDefaultValue(18);
+ entity.Property(e => e.EtvHotelId)
+ .HasMaxLength(255)
+ .HasColumnName("ETV_HotelID");
entity.Property(e => e.FaultPushUrl)
.HasMaxLength(255)
.IsUnicode(false)
@@ -2076,6 +2110,9 @@ public partial class RicsContext : DbContext
.HasMaxLength(50)
.HasColumnName("TWName");
entity.Property(e => e.ValidateDate).HasColumnType("datetime");
+ entity.Property(e => e.WelcomeBgm)
+ .HasMaxLength(255)
+ .HasColumnName("WelcomeBGM");
entity.Property(e => e.WelcomeSpeech).HasMaxLength(100);
entity.Property(e => e.Wxvalidate)
.HasMaxLength(50)
diff --git a/DAL/New_Models/TbSysHotel.cs b/DAL/New_Models/TbSysHotel.cs
index 67adf48..6e0c200 100644
--- a/DAL/New_Models/TbSysHotel.cs
+++ b/DAL/New_Models/TbSysHotel.cs
@@ -180,6 +180,10 @@ public partial class TbSysHotel
public bool? IsNewVersionProtocol { get; set; }
+ public string? WelcomeBgm { get; set; }
+
+ public string? EtvHotelId { get; set; }
+
public virtual ICollection TbHosts { get; set; } = new List();
public virtual ICollection TbHotelSeasons { get; set; } = new List();
diff --git a/Redis定阅/bin/Debug/net8.0/CommonEntity.dll b/Redis定阅/bin/Debug/net8.0/CommonEntity.dll
index 7f9975510318834914a361c2cbbec1209e4d69af..f0ca105dd94b00c28cb9b73ae2a5d09101e00db9 100644
GIT binary patch
literal 99840
zcmeFad3aP+@;+XtyVFTJ3t3shl7s{ZbO<|yge4&%fC93~q9`DsfJz`y6cJ=s7B^5w
zHU$9@1y@iQMMV^Mgovo4jvy-HsDsOA6m{_TR^2+?olaz&=Qs1u_nAE0)Ahbp_iRw)8w2Jb}
zD#l%zF@D_CspVH?Trx4E;_9gxlc#2so;Nh(%JK;l^Wx%s*_!pB-bDS4n{If!@-pg&sWrxoPYoHsyc8PlZh3ZvpZ>
zj|Jp=H+Mw%-}8oI!QHmj(6Dgb*>DC?RERzbxNiu~yK3UKR{?)G8})@w+N$-oW}wIB
zRa91t2O)Js9i^dj@fq@01b5|COuV8ThFn)douv;J*0Adpa+-)walhh^>*k^ex@{?h
zBtzBDWQ#xcmsWu@r?pC}sONm3Z>P1&JD7^xb25p1tE1*yPVW+SdVQQ8
znHU**`jA>rk4og4|AZz5Yfjz`5n*v_8Z)X*z(XN>{j-5yeGGQyr;Ykym+vV9R)d<+F2$YGfeF|-r?7}nmsp;P@(@CaRL7Om30BC;hv5(d
zlUV<7kX`sxeCFd5#m0NJ46O-bs~J^Zi1sCW+&Nugl<3JR;B#DVNSIdql<0{?(a0lC
za;2zNm$-s$n$1;q<#gk7czk&XUc!umI(ghlR36VKMdfcC`0~m9uHw>SOD+{E|(w&-~n7NAq&9c
zw_E}cfQN6ngcAUdUMD^Pc<`2s!+HL3nw2JX3SzXhIoy)Kz2mgG7b=4=W51`IG3e+R
z_%|n!4g9(8oD#Gor<9u`UWUg)y`02m>Sgt7PvnOX3->FgHu$xL^{X?%Iev4pce%aX
zS$^`y`W;7M=5eOr*<7k^5zmtiY#DA;8G++TiS_%OES<9h?RR4BGuR_s6UklP8%;Tg
z{G6Q2%K)1zi&|G_`>-wIp%xaoRcCQI@*PA#RcHG#8@QC%(#~NPeO}%6T(A`jaP=wg
z56S1{^Nd`AI8HD=LNa0^HmYJ7tPcjdi6hC^oPCW@Vn=J25$1A37+8csnMiXGV?H1H
zxm8|eCVW2^EtCsd7JoK%xo3-jD_piEL;%su5-MnrLDSr7L;%sk5+Z=ev4jX9T3SK`
z5C|Zrd=WtSEg=GkTuX=mqO~PN0Fh@25kR!Dga{xoeK@6v0HU2GL;!(F%&`yw1STz0D)oT
z5F&uUaB>J0g8hJ@7C
zfWZ9k5F&uUTEQVy2az90mKcK5COzoONanso+U&8G2ap*fLLG&5kM@oga{xOSwaP^VPGu*lf~9Vg`8M}
z#S`BR-e@%!B7k_q
z5+ZR0x*;iPeYz)8m#}Om3(}V?bz$jmEM3IXS1iqB>1&qOu=EW}kFoT3mR@D)6ie^0^es#O
zWa&GWBHWO^XQ?4eKd@BD(*LnEj-`LFw2Y-6Sz5``Pb@vg5}M$t*vHb(EWODR+U%)#
zm!)4J@l^g#{^V&`1Q2H|Ap(fsEFl62?9Mu;hycP^LWQ7XTvj6jOx>0c0ffgAB7lgn
zga{zKmJk6%q$NZE5oHMxKtx+Y1Q0$;s1U4SjMaz$Q!Hkj)`(qRbL11kdebH6p;YuO&nP(a#bhfH=nzB7iv85+Z=;ZwV1V
z46uX>!SV-MjR-J3&k`bl7-R_%Kn%8o2q1=7LIe;)Eg=GkVU`d9#QByG0mN`ihyY@Q
zB}4!*(h@2J+c3&%M1bi9mJk8Ng_aNj#Ar*10OBG`hydbZONansj3rbEmOs{NM1biy
zONapC5=)2xV!S0p05QQ5B7m4^2@ybCY6%fQTxJOoKuofP2p}d~LIe;~EFl7j%Pk=S
zh$}210*EUup+d0PQ>{h>n3h{Y1Q63KAp(f$mJk6%g(XA)QE3Skg2i2BH6pYHd2u{N8RF+^iPYrgv3OY5tZv0I++f_-tX{>19{#Lf@s4~p
zs5mczaazTz^4YMW#LKu*#UA-=T+t;GIA<`P%;gN>$8+AgH}^%3DJk`CzC?09SZbda
z=5$8yr^nk8XY!dSae;i+uUI9Y4Jsay&$Nn{%MVqey;E>pY`$Y`Vb4_Opx5)%#Uf#dK6)_I6~f;v+%vv7q=w
zP}~_5pJLJRs=jZ7?H2iS<#gqU#+w7PIB%x__bkqQwv^zW#ktRxBHXh$``J>4dlu(E
zTMBW{;sRz%DehUjS>^pkY8q*6UYzY
zBWEPKZ#GMMl(d|Ap9c(`&P3
zKHQeOrZ!vV!)>|iYO`fN+?KnxHe2SyZMo}fvt>SDo8a^VyGCsB2A5kL71D=l!!8Tj
zFsf<8t_<2Rs%gV64%#rPX~V7$+AykV!yys0VN}zGLnUa#D8wewX*-8d(1wxNxF`v6
zf?#>I*z$w+9MN*>X!*@A);=TJ
z{-Wj7(em40ti4CH14YZJqvhAWSUXp=gG9@zqvf~1JauFI6J0q&M8&D2;&;ASb&e}%
zn5Z~)RQ%o-tJ=77hKq_*N0pG6AgUBR3V^S5?zj+Mao#L+e0v&Ql+3=Z=X1PQJ{lHv
z&$#h^4c@&Hhn8OiY8>?JJFAD^Sud2;v-hkXu4lbaR?q&kdT~En2x%?YhXD%?0k#m*
zTCg7j790j_A*8inU!no>CSVejjFY31qH-?QX0SWifZz3F1IE=1*rRN~-ev>F)eP9F
zY`_j@1IE=1*spBBK4$~Q)eP9XY`|`31IE=1*vD+Z&SwM0)eP9vb*I3BV}LD~NKQyf
z$Qk3bQ{0{cgT%zd+yuglbQ}ljOqeF&O}QjY0dfrv&i^@Mak|VCtuVmL#{ubebCioH
zMdk@7EHqN^@>qRxr~7iSWWoDlPR!(tXP~3r`U^3|mPr9inGCFDX!Ibu*fK3(DHDUW
z42>hi8Cy0DSjr?}Evv;7zjMmAtpc_(Wmwy4k;Spcw(SG9GJ#lI8)F=RY?dD|V@=Kk
zZM=;%o{-qAC}75#fSHXqo|)LJZ@`Q-0W%wQ9Jg#XC}75#fSHXwj$Sq!88Bl_z|2M<
z$1t0X4VbYeU}ocxBbm)61kVjvL`G_WxulbIMuYy=Gg(IK;$SV&Y%w(ShW
z1y5$dxoQgQeLSsUu1c`+@hPrZG7sr`#7p^yK{@M=khuo&rE8Jy2thUoyMT#-#7R#z
z2#XRikRT~mgBl?sCK4efYEmOU#6-fQx0=)l4l$9~=%Xf~ks(?MjDD&O4GYmqRGh2Y
z(3lXdgv0>Vh6aRaB_7UGZD=%zR)S%$YC}Uov=RwJRT~-yqLnZ>U$xbOK-3ZgBSh`0
zwo17ies}J01cG_=oMWv^8
zY7&+1D|`?aIJ{Y$o>cgRN@<0>dh^eYN^jLEB`UpX;q$6!Rfs3zpAozd#0Uu9~
zqe(H$H?%t?H^?qVy^7QFS-+w(ns+`LRD3O;X%(0GfX})IQwAU8WOAJ+qB@Oj#;f>5
zY{58NFZC<73vQrWGHDe%1vjjCSw0(89OutkcTuPfp^4QW^CKFWC1;a}~e
zTnZc8CocJZgLvB6M|lGo>pseXpm;DSRs}`OtJd~NP<)TYz?KT??IHxN{JC-_p=@-R
zdlr{7TMBc};(}&NY3^BE(rhWtJ&TK)E#p2eljmLlD=UW4rH
zf3T!|#%tI5+-I)J$+qEP`yX5l>5#Df59R}V1iDwk)vV2y`EXlqMs2pthud;9YqMoO
z+?KncHe2SyZMmCjvt>Tqmb
zb2-j*mvbuj-MSaRbFVAsO3`uZ+>`UtJb33^E?Q0FQ%A*1DOTamnWIdjE_mlG{e+868utU=H**_9)*XCD
zDwMq=<#t-V-Zu+n_1sdc*ZXFnte)Fy^@00lA*}^BIbdP$n}xI%-12~hy>AxMT5tyh
zEV$>m9YU&w^akHha^J}!jk_m!Lm7=ln)7|9(7ngszn|=nK5QuCwptI?xSx~|vUgsg
zeOcpvQUc0ahW2WW`$-8dYZ=9K-<;1AHh2rmT=GoZf`=_wjbnYRfM}v1Ep?!*;a%`k8gEpbP8MuFv
zUJTlV_G8HXlk{NFs#+fg@1Laaf>zafFL?hXy%w~p)^EX^DCw_&RiMYJ$L$nc(dFhM
z7`JY!YhyBaZ{Y>y%wu+RAns)SD&2Smh7B8pb)pzZA5K++upSfx>A-1fP^0_AM0&46
zO=|R=m`K-Mr6x5xPE4fVW~fPxUK11Pv}?r#tJ9E~Pgdh{y$xNB^Yy?@c$-hxL|D#=c|CT9#89(ilum7Z&`=u4djosyb=CPUV+DB1)g^yQ?2qQ_<`EzUCF2*Z-%Ur
zr5?^InMG%TDobSPcxQnsSo+ynpbD05brz_Cr4OA2s$l6be+Dl|1xxQZ3sk|<6}2o-
z>-{DR)DKacGv1rgUzJz!0`+QMpz@+kuA?o`_(nXp9c+zB&RIP!g00Vs2^8@YN8YRQ
zpqV=Zr|G>7ocnpm4gfH?BGST~!!~Ew#jFCmh8%2H+Tl
z1A8rmH8st~u>{ARICx8X3yw!|?8fl|j@NM<#_36--Pnb!f8*E{luEZ>F}u~uB?365hheV<_H&7?r?-5l}|ZBzsf&5LQ&-&
zN9a=dyd&gQ;?+^q*59mhzauoNeAN+>E8lPgUkdaQoZw5w@UxqKKvy(@JJQoC(cS$0
z&Cb@}b<5{~A@9L1mZ@i%e9P3gOjpY^uuOqv(kzq7D<>qrhL%Ce4%5goO)b;dGHor>
z#4=bfJ7=XwTMCs{%4aD&kyR?jQV2AqVl5RPpyDi*5uoBNl@OrnSgL)1O0ZPB0F`K|
z4go63QWybRiDXM*;jUDQr8)+vR7+(AsDNkM1gL;(Feo*zfN#L5e6}P>pL)3)e7|!>uLGorM{}6H&gf+PRHG?X-;a
zTDZ(0C-+|-D!~|l({WFbvj|yYbr4M$Bl)@DJ>`o*xyx_lvOL<991LV%Ol1~wimjU*
zkW$=|w1_<8
z;bn6{DlQ)GW;v**kDou)8@ygH2)Xz
zfJ=-M5AULRzZVazRAmS+hE+k=|_zm4a`3OFWa_8KR3YX)uhCsL`%+4+B
zxG*+CSdIkkj1`wxX<-vYHfj*=XSkpSmlMiq6Iuxu;?q+oAJ>)|WBh&aXB*>~100`Xd{y(Q2hfEB
z{Y#j0sT7BQWSAS8;cTigAX^9!Go(z{Aja
zJVr18KSKp_FkV9j;0aLSjyW0RaMIrbCjopN3jQ7nz6}N6hl2kL1wRIWGd?fEIK;)U
zhA+$h#rVX#0*)_#L{me@r;nSC1HnUBZcrJH^KneT!GSv;2ZkW6$C3Xa5)4U9wZ8Jt
zkt5}AU?wm<$!z|GD0saWrudQ-{tBDHR|3ad_>I6}7M>E=+rsYzcD4{pH)Peq!hZ;?
zZ{be@&k{JlV4wPr%;e7a9f_ud#!YbimfE0c5I%mZP2|miaxl+v9O)p<5d&wC^7Wz$
zWn|al*QddsZH%@;K71YaSA;s%jkD|kWvBW}!(7n}r;)!4I_yuVmb{yAH#-%#KH$R#
zB5qW`{!V}5O4xdV?MytV{N2l0;QEKYT75D{T1U;u2whrwg&TXuaHa;n`Le
zPCT~5SPzZI;F=TbrQkdkADG9mmI?1iT#9S-BUaQkxOTO0SlC-TIH?m**d*B{Xb_kh
zy4J!KhH^SEx(g=*BXDldP&-}T7T3aIZDA|s&B46}FSUCMw~7ZJ#)`zC!O*~vtPvlW
zpUxT|eUO!`dDp-&G(>PCRc#LK2Yd+*+*%Wsh;%=W=Wx7(<8L_lCLOl`)EY;A4v`&;C}O$$@to(e;P*JTl4%qXix3q>PBenRNp9Usvm@r9X=xssf8OB$~AO?bGUG8I5-16Hd46i1K@(-
zxd>vO0!Ha6hH+=fMP}sA0y4@dK3Uc3_i`IntIe0zq
zVx3$+%*lNbY2i*jC&)Q#Grqpyx?aO4@b6iD(jOVgb!SM3Lvnd%+gmTMzCRZ|q?4Y^
z1(;oG=^-=y3Zt0>k}->HBy3C(HIvy|DgC!HP@!$LWg|$fISozVPzCf`880
zf)g9~PDgYK?Fg5@Zdebb{)_cp>*xP)Td(-twvM!I4Zk-V9rSy^F&76pTyw?(<*chV
zs&P3$2g#_GHOfhpi=kX2R;s|Ct&1ig9~r+3U>MR%y*+@qt_AMNa2+N8;INLn2xr$^
z42}^t50?YXfWGo^0>jsUgCo$Hzj)s%bPNX9FuBm!u1`;N;tYKni5Vd0
zUZ+oWG(>|6ACxh*aB;P8b%Go+$6JemHB2LCYEBk|^;{qfQrVz->Ggs+1j3*}ki$t0
z`6Ru4Z0zLPSPV93uIT{-SZ6Z0uUZ4M#2TKKIy4KlZV>>^c=N;eSmxD;rxfsKi>H>z
zN8$b&TfN(Ji*!xMQ}1?!6f%gAs=nkeQvdB}}%BWC>5k%2mWGndsw*b8l)G6ePq#PZ5l
z-c(@sutKwi4cz567Z|w9#V-k;b;d7f{RdY+Jm+7F2852s;5BiA9gN`%pPz$sKEn4`
zAZN1@;7lmMv=r31LV+g$WKQH|F;>7eVwl70Y%%ObHWI^pp$(lAc}-*IL@bsF3thtf
zfc(g|KYWq$i(FKA|KWD_$Ug=0{)52Z1oHlaK-@y0@7Xf~-2&M&0`WU5XZOsAe`~J%
z3RMpEO>nN{8w%^5^tixW*$U-{%~rXf!sp7oS~$E$RKu=)kb`eK0y(o9K<7}99|{UW
zLAOxQBNP;cf?f<{mX&zG7yAhJsWsx^F7RiIhf-uC@z4i`q45yM-G!sJIc+I;9^Mb&
zcnZgU9NfL1;>iC737jia1ZG-H8lN#!eGY3aiZ^O1+KA$bnu>O!z^zPpRvkn!j}>~4
z)`^+m-Wh(s2QaXA)>U9&@2pT@VDGHEz`)*FPl171rC1=xt~9Si;90Ko5B1F;epu$79;`k1ic_t(dT4PWyi$dT_^V&UI=4#Jn!+GBwyZaa^KKPw%8N`$-ryjr-ywQxgg
z;m!}`)cqrb6ZZ$k^r)a67V3PBEJaLUkE}*a@HWob=A#Rdlf(ofwAPqt0vg*g@~m_$
zK4;)qjw62^lCW83ATp~pGzPJvMraHXHas+j2^$_7!-WmMAs;Dh_zn35!k#5GQvUEI
zPWpB(S{fP~!S%-#HZU4G*SCO!dSj*v4~#ywaQ%WDM*6uxcA2f-A0P(K;AcPcZW{L0
zYWSJ2!)NpJdB{in%x()E`#kRLIs}u7JTF6NlK-+W=awM{@?Q|f_7ygK3;!Hp`L0b?
zko^UQkKlpAp2bb)|3No#zwlO2?LPY5=a?88HGI^j77kn5K|6Iz2jN2I;9d1#AM3UCaFD~;I06**!U0|`w##+8sI(&a?XA0R}|
zizY8;$k)Kb2HM-ml=8R1B24j)C|0sUm-z1rGq0xU`>gO^4!b|0Yl2VK@PZNep>~<|
zk-$<5@zp43!^7#Au;EkhabbTaobdFh;OmeT+Swk+@tB^A7KFyqADDMvM)^ALA_`sw
zviBP3b6!lnE(TjTG6If&GkB6W2L-a-Tf!k`vFNh%ZiiZ8;a|{9j*Lea`P!3f))0DVSWddRflsh1SX=m?v@1z{|pX97|y1gALzC6yxCYV{oM5Kvf7GrT;%!
z9bB;Z&r8?0JW}YT;#Qmb8!{Y9oew6VD+BLbLe`_Dbo75gnXpz|;<)iYhsXcu3Y8U1wcjxq;&i&D@
z$LMfg8s5vkuRD6L&EdSJ^oF$er1ZlNEshj6r?oBF@^;8xdb;^$q~07(KWut9uQ@er
z)xUKU8i-QjsWo~go))!uty?P^5PeO%JepcK4?W{*wYe~lax*9S^Jp}fJnAI!=OxU%
zFX=*>1m8V_`sC4i$a(aQqz8+b-v=+}(YQS32O;&+pED1me=hFwLHD}!&tBZOkx|^M
z-$>ski~O<32ix4=rU~8$-5=$pt+|Kuy!3y)xRm_%T$3ldaGqDR;XDVxCXa@9XL+(=
z%MD2LXjNBcrl4-kp
zFDg5q-1rS7*4^h>R5lnWUeJ?*Jp8*S(7mpxuIOGfZ0W%x5I)Z!&%qeYjm2_9*`l)D
zK$u7IU-k8e=UJBtOQOfKA1phGagmMk6X;;xgE%is(e?;N&9S%6y5Sy19q~WeF?vT(
zXS}=5C|gi>8ZD@KBwH5aeSX&MC}uQ>77Fr+ZWvw-U|p)9QFJ$L0D8jzAZDAfc;BCO
zC!6tkW3eg4=*<#FmtlK~(TlwqO-3v*y4cI8g5DC;U(gJCPf)&;Fq=*Y`o_(ci|J=U
z1E9MW=odkI6aCFje&J7jt#vTsB}7GFl|PyP0|lx=+wn>MLlapoeLwpxKhk6LhhlXLC81y~ID?oIq~~I!yNo
zN|q8npvMGFlDd3?|Dcd9D@*yjPw6E=ZfV0m>19D9OENH5EQqY4^&#TNnK^vunS*A+R-d&-iYu9yCtZQc{)mFQV+
zeiXDFd6HReQgE}IKusjiwWfi49>&8v_8bbyD=Spj~SDtf1Rfw^vY=>RuFdN_8&_
z@~G}LcJQA_B6Z>>8_aBNVg`=Lt0dCG19nr=BrXUU7pD44{@A6
zS*H@|_5_wct{ufFiweQug@Q8my^$K?MZI?
zSJK0Sl34EDcq7sjY2z+wdvXHTXIIP?q(4a?{#DXGP1wG2i
z&vmDrKzc+*(5|IkSGSZZ9^8fz4G7QjuEx-jXhpoO`5j
zd+&s2>rzP+r`~p)wi0=mq>CioBIy;9_KRSfojp0dzLe8@Bt2Nb^5>Fnk@TOEz9E+P
zOZuUt+tS(c1<@{)5*rG0rHlDfT{vBbQg|G3+P)Eca71c0dS;r;ga=|;Lv}{7GdDVM
z{9_S*eoE3D>9<4Ti;JYkoW5Ni
z$Gv^A^!zoFzFn7@uOxl44wvYR>rFD2o!K=)>efthJJhH%>OU-zE%!@{oEcz{)a_(U
z5wy`#hx;0y1Nk?pXR(~yRBTR2DI;ZW;jwA`{z}N08YV4@7mpv7+JZvLPM=
z8;ySGA~Ca6t}-oThPg@RmiJ_49wpi-!fz3qXqnA6ikEZb%9SYdzxz7X$iInw
zg~*qPoG$V*kqborM&!#yenI4+?i10$nqL>F`3%vvl+r_MJ5=~I;X_-rMrv|U`1vC5
z7WpBuFN55He(So}-Hv|fu+Z0;_Ly5FUFjQ?fg2LM$Z;yO3g3|&q3DdDixo|5%DRb)
zZpkji-O+SKiRpKv*4HZfvS=O9Vns)bHsYPNTNL$ej@=u&ThNOX+hq%Mn*}Ydzq){R
z4-2}z{`!J#(7hheJ#Jj|o}go9f3Gb*5B7dd6=X_oomgS&ldGG-=oeoCHER~MOr|_RpPL=cy)ntushX|_
zBeR%>_+y|eRy5k57L!W-1$}Ow@wJSpM{5-=Z&eu6kWMhtx?umMIp@N4=^xXWnlVyc
zI<*z_BGvCQJSLqoTLg6()Jo7i>A?)@DCl$ZYuAfnGU!}EPJd?523>u?o
zVsQdx&?H6wa8HWKq-lzNa~GIQnyKirtSe)h(mX}iWK{w!b&!;vMJrXeru`Ie7OhdV
zseM17O^Sv`S9!8&o1zKP*b}0iiqhLud79B4MY(O@1=_EuPga$uIUP_mA}awM_O7B%
z$g>4~tf&}ywxBN*Ez6kb$)QtXv0xc{_Vp$aYS~Z(~7=9&GN~#
zbXrSA3E1iPDdLFiN=b@1BD+#UMeM%<%2LGsE1+BlNs9`plj=T1tqZBUqQ9Zmg;b`9
zTicBWD&p35qY;X3>p3#AJB?Aare{mjohB*ztm&08J!qPupPE(z&2*5I-jn95?#Jj`
zV|vn3MZZPg3A9oXkE0@5qlm{*5p7b$m>IEH*TVwkb;MHPJJeb|~tC^9Iu%MMXW=#tfmC6piY6f6P!i;2}Hj+bHd
zu_BI_Vf2L}j^y*{lp>Dg^XarAj^yEF@cKK?bsWjV2|tu4h$DFf;pegiaU_qRhKe|n
zM^cs|j^vS)>maGwDC(p-uGuK+u83r-H
zt#K@Q))-CG6!EMvnr15ES>qy_r-)~bi)g7Lo;5C}6^eM)xR}-`;#p%1ZB)dw#u(b>
zAZgK9E*gLPBfi91V=V1dOK#s-+M|fuH{7~gkhJeI>ZH1VxT`#uQFleZxfAf*q)gHG81Iv4prT(e-Y3xr2T3lI
zX{_r0;eIA&GEGwSn|nXdbVVC5;-=6{MUP^{O`-XUZiMb~TB_&{=q{&~iiY;C@?1e{
z6ix1(falGd6#1dMlC~-83Eh>nQ_&5*Q(aSOkD?X5^UPG*uc*F%B7QF9fTCvj;e>K}
zSJ8mdiJocnv7!s{65}-bLebRhLow6ol%hG=e*rq}AnAz;a>>)W#Zm0(3i2spPghW~
zqLzr{N@}R68zQ-qvK8?hc@^a<;yLmv>ZFKA$JNwb5s!|msmwuA`V2Zxb;GkqM$VuS
ziZ01+X=cz^MO?FMXp$nX*)@2^>_iriv1@6jA|7Mc(tJf+vzfG15!Y-ctyENj@pm1q
zQM3r-?>gF~sH3;aGmEw&x~252qNfpcOX+1ryz*E^Zz4^e5sc60@KK5q%R?!Mi
z3eeArxR-7rR~yGi+)KAmjDw^nZlx5}wTx&Odn+|k)HNa#sF|W9Z%*uO)LK!NHxH<@
zqW2;?#okUm6nz#^2-L?xQo;%vq`HWRD$fcUsie{i&b2q)LsH|fGo|PYTkhE_Vy{|g1^(s21h-4Y1Rn04b8aqfzUq{VV$EB~MJVjjkI_jc`
zOTUMDD&o@bp}vZ^^m}QLA};-28l`A7N?%Xo6ir6y>uHLEr1T9`sk%w6^UMaiUeTD=
zsjmBIp`!9kyhlMdD;l3!<=IGgD(YQiXd~UDsGw+~XA|A8sIYmj*iH0^qP*rCeVgei
z2TAFh>3P+SYSt%qGrgkd(q`uZ9a5Cuu}|#%^uD6pj^_e>qUbLj`owObFBP5Wa4yjI
ziZ*&DdLE!(6g}$29xr+D0x;$}DSa!&IVg%t-%6>9xb&^mL=l(%AT?LSr9Vh*6mjVf
zQ5QvA`a@Kts4?=~Mt$vh$a5PFR#b_aZKqL+=A&lY=@JJ?%^s%9RmU}Zm?{-<%^s%f
z6>-fTp@oXLW{=R#inwNv(w&O9W{=W6iq^I66Z;t5ujql+=K?*V=-u3jp2z7aMW5sv
z{6gLH4w9NZL9eRr$!H%U=o3YkV9#g={Y_ChbUW#LMYEvW
zNxv$JgzibgtvLHADiyjXDNfOsZL2&_QL3V!+9u#VmL`f;q*r-%QFBH2rYF!YYNM#o
zH_@}3x+v<4J-FReq^MKrq?kWbUq!{G1?JB*SWyxp`Dq%Zs5zqiX}UzwUASL)hNdXm
zg8P+cs8Z1k==RVoMT?=^LkkskDj5{}EG<{myW~QkI~841a#`$iw9cMaQUP?oqVr4U
z#6C|CE4s8~3D8px60hu~=dC4ra4)^0hH)
z`d-mf?W;U5(l3ghZI5?{2wNiJqv#eBJugwLq6YX`iI*rW%YWraVO>ao)?+MbWI*cgDU#Jryl)y$YzWqLw)CRT`wI3(k9$MkzYce4^(y8mH)|
z=6J?OQxpw@S6-(IMHAtb*J+lbh>jCIZ_oloNqF7<4O*^=rca&Z55m{JsV
z#D3OcYOH8h<`nNc)J)Nhnf-wB6usSSiuVY0R`l0q{eXHZT3j&2`!4lSbX!3`ph1dK
zdr$GcMl9s%c=?bvE4mu-@*zE}=tS#@o{#8BMc?APCLhsriXM!f==m$XtY``cBa^ttNVo(a(zBYGvpcxjO}Y
z^a;f}C~8uxNim;LilXaU6_`(`v7+dLD$j9hrYNx>fsRw2gQQas;bYIf5ig<_a
zOL|!mui5`bZzlC$C#CKWWQYS@xm-Q|6
zaFF!GchpC9=eZ_&zN7OLUEspo3N%vDz3|`nG*;2W@Za||SeUzW+T}6*#ALVB{s^|fXm0#!!MUP{w{6gP4
zNP6j4`dM{6`hO)C-gRRi@#z1RVibMjo#Oo`B`Z4Z?FZCIQ6%P`GnB0;xwIcpYenhM
z{YL!W9p~8!y5FdWq7T|l@scT1bfR59pz{=c51lb16uA+D#*B54)Y@ext8Q7w5s%AE
zSF|c)3D9+lI6~ZJz9Nngw^^oWUu2cXV^%79Ju-njX00OL^@}i@6!ETKgxRiW26ofD
zW~ZY0*iG}AXBD-_H7C;SS5%B^PNaEDQEG`hF3P;Cs98xo&{0J(Sw}q4<_kq>SxbPv
zRdgdps?VHObQead&$zle{mFX?F~+Be_Yz`EvZA{Y^RcF(qWcl^u_jwldrw+ioXJ&G
z>S-1iZ#pR&*M6d>j_Izb0$-%7W6BhDE51K6!3YDwEIOgk_1By82>zQ{IU5&lN`sQOrbFg<<-+ZBn
z@6H;SQ;PV`t${hM=m184nlS}VzkGzzpJsfD7Gs1rG)ao?!U%6@8Y=1rT_cmFs6TX#
zOs=BaF!~#tj*8Y{^fxx$6}^tp-^BD*bQq(*i5aNq6O8_JGhESE82#yHjG}#rx(suf
zqAEmPhMDFd>G@1EQ*}HGXPSA6coxnyOBL}LYid>~;xX3LtWm`CXO`Khi098NvrSQh
zg8L)0%??Gm1-Ah0QN+&!nwgjEdDvZUW)3(=YS!Gmt2(Y(bMvtxu32;Qg(9w53v)^l
z*Q|v(t%yfXjxqQa4#zH!oE+m*G$x{5TuYOrXlg_kpoWV2U=OL4$x<`|dq}NJuC>IK
z#BVw(;+25kba#-{I@gq`j<2w}W}qUz!seP0ioV0nP-`Uj6AjajOQcQxCXm5R8}+L|?rxX;>}O^UeB+L>*NxX;>|or<{6
z+M7L!xX;>~{ffBHI+z2BxX(J6cNKA;bu=F<;y&wWzOa_)vrgueBJQ(J=Cp&PMV*bS
zo8u#HQD@^*#4YMu&$=NqRH3?
z>uSmrv5yMOKt=4M0y9DpuYwBA7)87aDm0T6@hYgBnWl(WLEX$uMZ5~?ZssZCRZw@c
zR1vR&dYBc8coo#ctWm@s>uEMBVvqGS+Z3_Kip&m0?6D%V$3fDA#b&?ixCe{P0Y%({
z#pYc_yo&8*K32qj=w-f8#H-j6b4n4fVoS_vMZAhFHFzj30?jYjyBSAJb7$4|t`I>FywDQD0N0I&M*4Gf)w?sIM8Jh}Q-E
z%os(yF6d__DdIjm$4pbieRhtSsfgDF=bCwncwKO=S*nQF1^vwmMZ7NPZ`LT{b-@6$
zQ4y~T2AFM%+NY5^GDj5gx?qs`SkaB>
z!NKN)qPx(8gUu;LJW_|4pA_*(9b!xm$49&_7;2&w@w#BBNm9h?f?+025w8o*H(82!
zT`=7E74f=YxasI1@yZC(U3Ki05vI2y_R0t|P!UJ+NHbg!NAgHBMiF~ul(|e1du5cF
zriia37no}m@s;EPGfxp;NiH-?6!DehLbE~~x>TdU*A2-nqRJ7VV7HC9><)vn<>OMh~Uuq^P`VmonshO_mO*}Kb%*<5u
z5uTY|X67qefSs>NW~riEvGX;_tW;#MyEWOYQB()JTa(QuMf*$fY}ag4^mZwp?V6p6
zVzG~Tx!I$r0roL3H~SU6gz~O12NWGdc~_Ws6@AUmcFo6%{>jgF%@>Mp#O~cxb4t-&
z*u9%-PAkg7{wMzbgCfUAZLt4YZhVU3Gx2QKBq?f~iD$c}p`u67zUd}Q(O$G~y2(}a
zIqF$qIx6}e^{g=672S>5rqc9QbU$XBN;6Q=FGYBoYlbWGKzEfH;~)yyI#!QxUI>XP9}4cx61pELC)SGd#^TD-^A7hNrn^jUrw(Uu!lh;#KptW}6~j
zHP19V6!EHgrrD#2SIyU%mlW};`8snz(P!BcJ+sUaMc-!|e8cc#MbAV`^jvRFD0(fz
z;G1=)6!B_%w)sgBueN6!Q%v|<9L1~cIVM^WueRryBt^X1zQLp^;??#ICQA{ow&xnZ
zB3^CJH60c4YI~mPrifSD^Gt6=yxN{`1}Ngy_IxwkLE@DKW{m21j$B|aQ^a%R0y9k!
zbvWW#Xs%Th-(d;RJO@cGi_B8hv2Pcd6^humi_98D?Ayg=qayb0VzW&V`|n1xLlOJ$
zMzco|`|l?6k|OrsP3C|i_TLh7L=pRMiTPL&`){c^p@{vr)SObp{##~#QpEmSW=t=~
zN9@1lCR!2uZ@EcQ#QwY4q$y(m-E6WHvHxx{ensrRTTDkq?7v%0H%08fTTO38?7!R0
z07dM-+str9?7!R1#fsQ}x0}lxBt5^vOcQih)PTY(;#QcO1UWl`E6mywZqZ#)4|J)3
zZik`)g|mU)6Lc)PZDDV-!kiN1JUd%q`j$#hpo9gmtlyi_=lF8d(zunTt)RtG7sAsk
zO+}%uR~;%5|q%uZXW)cbXlFDlx+EGH)oFj}d;CIjV@S
zw|_D}DdOwxpG+*iIVyKccxrjK$yRhC6HkFnz9QZgTV)0*;$5*-X0#&S6WF9u4j
zc~|Tnlc0!q#qKpZig;J-Uei(0W~{o_oBoP+VAZwWj1;t=9_e;l+y-;4pwG=C-R_LL
z&kXCwCG4jgP~Ju}`dkNX!76s6xk}LI=Jj@K<2IVPf{vN>?anou%ohXL@^jN3SNqK-
zYLJ6c+boFNYW9G}ep=OKu`%p$s)IDHghcR*@@&S`A$m%{--2+`7
zjC;WR8nB!VlyN?v=S1WKCSQ;fkq?-)0kjjA^@p=1N8~ecTTNR*&U;8(O=83TkmJoq%|b!!%@^VxGs{PEo{l#k
zH`_)zh`sr^c~Ow#&Bx6_L5??{FgX{prQ^*VX2NI(rMB4_x5F&H$fAvLJIx(}9B)2p
zZo8Ouj>n!d+p3|Xf>zS6U0;oR%G@zFXt~SWaS0>GW4p{cK~65a%+_kU#|16G?f
z+hulFvwW$V2%zsy=D#=m5)ofNcu*(?;qmQCVcHhm{s%iQ?a%wto6
zmT#D61hHk;_%}?(<<_z+{w;Gxkkddv53t7jJyt+<;
zt7uWsGRf6n5L<4kljN$u*jnzalj^$l#-L?A*WH5H@`XC}T-i5S%Y${&TpgAKEgQMI
z31Z8S>NIjaplG!J%R1?-snI^VE-vJ1=qm(KE|&|2Byk9qO`
z=8`{~e|6}-RzaH|ny~x?-cNMVZ&+{OogJk3{u5HSGXJTZ@Aq^5PU-)xl>6zwU&?=~
z6=$#Q*|qk=J0(O3X5Uybgan=ZI1+#aZ2P{%%^`of&8K=*a)m{;xOw)3M>k
zf9T@IH|5;;g-$oVL*~Jrg9rb)w1@EDmg83zBM844N}F-i#jzdQH2jWg6C8^uikjls
z3`@NCj6712M=J6t#W%i6sii5UIryB9qn#5M}N8$4Vx){eHe2?@J9Eb3o(Mxe0!uLa`;5Y>BR2+x!
zlh+kE4$)Y`H|6jdO{)tGe%60n7mNje!R_Y2$4
zMB139YW9`rVF9da#i)!6ku($=oMuB(eY
zt_}1Ne(z%(6_)jLopf#X4R&RlokdfSURuQYd$TKXZeB(zv}e+9h5R9Y1FWmb$62}N
z#Ws(Cf1qe5a%+;k2f1;r#+lu{k0H-K$a5Ti@#61DH~0QgO8h76V>9C2*?R8FzDDku
zct+jB-O*G;4}$zw_Z~uwz`V^_rdZXt+pVI^lt;tyUeRxscjzfJmxAz4y#-r!gW2R@pXOM61jM}=7mi{f`L+pu=_ftuCn_uuvsmILuWo^9E-P_xD^6oaX
zJL8>m?9+6I4X3-!2kpJI+cZW0>^8Z0&wQ)7p+!IMSNL5N^4=loZu1DsPJe(i}R1G?zX=+Ln$Y?MR;?&8IJscB8)|EutTgmeOgYed!F+{^X91!kia{bQr}U
z9Z5+@M^indW2q6+36zO+5;aG91%4+zil$Lpr1)+y(rc*z>GjkT>0ByBx{&%Iy@>`Q
zebmeK+~pk#`FStb_7yMJ_Mn$*`<|C;d(_Ld{ld$&J>})v{^aG_QY6=wy+mPT@({UbTgVUe8Y=*Xi{E%43eds18C`*OSR(;WL~c}gCB
zg}Z%X9)6Fw5NSiY0BIJDN9v~yNITFINDJv%q$Tt^(sP9$D(Qvv8<_DTkEc#aEDw{k
z9O>mWFR29IE`Bnl1mC)?Lb{ATNa=@it5U`bKVJCBV78<#5N3feOQdcah1n>~Ryk{*
zF#CjgRn9tw?{ywZIxhTi;ZK6!jvx75NuMXV4VUgVTza(GM~|jvg8wNgOZY6|TY}%6
zS`6No+z;{#spBBmO`dEv(z8jE!MvV24@^$-0<#9p0`Ln`7np~TE)kn0uxX#T0X7|z
zH^OFD(nhh_C^lQ6J)F81+Op(*qTMIjeWHC8+K*C?L3?rXanT+Z?Q!!q;`zAPoP^Ci
zsm8UErX{;woWI+}b#S}54$-cC^m%F~wAUwRi8f2LEnTnEohdD${d;OLw6`bsgS