diff --git a/JiShe.CollectBus.sln b/JiShe.CollectBus.sln
index c3ad8a0..ef80d8c 100644
--- a/JiShe.CollectBus.sln
+++ b/JiShe.CollectBus.sln
@@ -47,8 +47,6 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "JiShe.CollectBus.Kafka.Test
 EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "6", "6", "{02EA681E-C7D8-13C7-8484-4AC65E1B71E8}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "JiShe.CollectBus.PluginFileWatcher", "external\JiShe.CollectBus.PluginFileWatcher\JiShe.CollectBus.PluginFileWatcher.csproj", "{F767D1C3-6807-4AE3-996A-3A28FE8124C2}"
-EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "JiShe.CollectBus.Protocol.T1882018", "protocols\JiShe.CollectBus.Protocol.T1882018\JiShe.CollectBus.Protocol.T1882018.csproj", "{430D298B-377E-49B8-83AA-ADC7C0EBDB0F}"
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "JiShe.CollectBus.Protocol.T37612012", "protocols\JiShe.CollectBus.Protocol.T37612012\JiShe.CollectBus.Protocol.T37612012.csproj", "{8A61DF78-069B-40B5-8811-614E2960443E}"
@@ -127,10 +125,6 @@ Global
 		{6D6A2A58-7406-9C8C-7B23-3E442CCE3E6B}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{6D6A2A58-7406-9C8C-7B23-3E442CCE3E6B}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{6D6A2A58-7406-9C8C-7B23-3E442CCE3E6B}.Release|Any CPU.Build.0 = Release|Any CPU
-		{F767D1C3-6807-4AE3-996A-3A28FE8124C2}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{F767D1C3-6807-4AE3-996A-3A28FE8124C2}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{F767D1C3-6807-4AE3-996A-3A28FE8124C2}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{F767D1C3-6807-4AE3-996A-3A28FE8124C2}.Release|Any CPU.Build.0 = Release|Any CPU
 		{430D298B-377E-49B8-83AA-ADC7C0EBDB0F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{430D298B-377E-49B8-83AA-ADC7C0EBDB0F}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{430D298B-377E-49B8-83AA-ADC7C0EBDB0F}.Release|Any CPU.ActiveCfg = Release|Any CPU
@@ -168,7 +162,6 @@ Global
 		{A377955E-7EA1-6F29-8CF7-774569E93925} = {3C3F9DB2-EC97-4464-B49F-BF1A0C2B46DC}
 		{443B4549-0AC0-4493-8F3E-49C83225DD76} = {2E0FE301-34C3-4561-9CAE-C7A9E65AEE59}
 		{6D6A2A58-7406-9C8C-7B23-3E442CCE3E6B} = {2E0FE301-34C3-4561-9CAE-C7A9E65AEE59}
-		{F767D1C3-6807-4AE3-996A-3A28FE8124C2} = {02EA681E-C7D8-13C7-8484-4AC65E1B71E8}
 		{430D298B-377E-49B8-83AA-ADC7C0EBDB0F} = {3C3F9DB2-EC97-4464-B49F-BF1A0C2B46DC}
 		{8A61DF78-069B-40B5-8811-614E2960443E} = {3C3F9DB2-EC97-4464-B49F-BF1A0C2B46DC}
 		{E27377CC-E2D3-4237-060F-96EA214D3129} = {3C3F9DB2-EC97-4464-B49F-BF1A0C2B46DC}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/CollectBusProtocolT37612012Module.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/CollectBusProtocolT37612012Module.cs
index d3005df..ec4a12f 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/CollectBusProtocolT37612012Module.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/CollectBusProtocolT37612012Module.cs
@@ -1,7 +1,4 @@
-using JiShe.CollectBus.FreeRedis.Options;
-using Microsoft.Extensions.Configuration;
-using Microsoft.Extensions.DependencyInjection;
-using Volo.Abp.Modularity;
+using Volo.Abp.Modularity;
 
 namespace JiShe.CollectBus.Protocol.Contracts
 {
diff --git a/protocols/JiShe.CollectBus.Protocol/Abstracts/ProtocolPlugin.cs b/protocols/JiShe.CollectBus.Protocol/Abstracts/ProtocolPlugin.cs
index c398896..56320a1 100644
--- a/protocols/JiShe.CollectBus.Protocol/Abstracts/ProtocolPlugin.cs
+++ b/protocols/JiShe.CollectBus.Protocol/Abstracts/ProtocolPlugin.cs
@@ -1,15 +1,9 @@
-using JiShe.CollectBus.Common.BuildSendDatas;
-using JiShe.CollectBus.Common.Enums;
-using System;
-using System.Reflection;
-using JiShe.CollectBus.Common.Consts;
+using JiShe.CollectBus.Common.Consts;
 using JiShe.CollectBus.Common.Extensions;
-using JiShe.CollectBus.Common.Models;
 using JiShe.CollectBus.FreeRedis;
 using JiShe.CollectBus.IotSystems.Protocols;
-using JiShe.CollectBus.Protocol.Contracts.Interfaces;
-using JiShe.CollectBus.Protocol.Contracts.Models;
 using JiShe.CollectBus.Protocol.Contracts.SendData;
+using JiShe.CollectBus.Protocol.Interfaces;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 using TouchSocket.Sockets;
diff --git a/protocols/JiShe.CollectBus.Protocol/Interfaces/IAnalysisStrategy.cs b/protocols/JiShe.CollectBus.Protocol/Interfaces/IAnalysisStrategy.cs
index dcd12fb..0066c19 100644
--- a/protocols/JiShe.CollectBus.Protocol/Interfaces/IAnalysisStrategy.cs
+++ b/protocols/JiShe.CollectBus.Protocol/Interfaces/IAnalysisStrategy.cs
@@ -1,12 +1,4 @@
-using JiShe.CollectBus.Protocol.Contracts.Models;
-using JiShe.CollectBus.Protocol.Dto;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace JiShe.CollectBus.Protocol.Contracts.Interfaces
+namespace JiShe.CollectBus.Protocol.Interfaces
 {
     public interface IAnalysisStrategy<TInput, TResult>
     {
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/Interfaces/IProtocolPlugin.cs b/protocols/JiShe.CollectBus.Protocol/Interfaces/IProtocolPlugin.cs
similarity index 95%
rename from protocols/JiShe.CollectBus.Protocol.T37612012/Interfaces/IProtocolPlugin.cs
rename to protocols/JiShe.CollectBus.Protocol/Interfaces/IProtocolPlugin.cs
index 9f6ee76..0153e69 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/Interfaces/IProtocolPlugin.cs
+++ b/protocols/JiShe.CollectBus.Protocol/Interfaces/IProtocolPlugin.cs
@@ -7,7 +7,7 @@ using JiShe.CollectBus.Protocol.Contracts.Models;
 using JiShe.CollectBus.Protocol.Contracts.SendData;
 using TouchSocket.Sockets;
 
-namespace JiShe.CollectBus.Protocol.Contracts.Interfaces
+namespace JiShe.CollectBus.Protocol.Interfaces
 {
     public interface IProtocolPlugin
     {
diff --git a/protocols/JiShe.CollectBus.Protocol/Interfaces/IProtocolService.cs b/protocols/JiShe.CollectBus.Protocol/Interfaces/IProtocolService.cs
index 757457a..fd42f76 100644
--- a/protocols/JiShe.CollectBus.Protocol/Interfaces/IProtocolService.cs
+++ b/protocols/JiShe.CollectBus.Protocol/Interfaces/IProtocolService.cs
@@ -6,7 +6,7 @@ using System.Text;
 using System.Threading.Tasks;
 using Volo.Abp;
 
-namespace JiShe.CollectBus.Protocol.Contracts.Interfaces
+namespace JiShe.CollectBus.Protocol.Interfaces
 {
     public interface IProtocolService
     {
diff --git a/services/JiShe.CollectBus.Application/JiShe.CollectBus.Application.csproj b/services/JiShe.CollectBus.Application/JiShe.CollectBus.Application.csproj
index 6f71f34..3ab9831 100644
--- a/services/JiShe.CollectBus.Application/JiShe.CollectBus.Application.csproj
+++ b/services/JiShe.CollectBus.Application/JiShe.CollectBus.Application.csproj
@@ -22,6 +22,7 @@
 		<PackageReference Include="TouchSocket" Version="3.0.19" />
     <PackageReference Include="TouchSocket.Hosting" Version="3.0.19" />
     <PackageReference Include="Volo.Abp.EventBus.Kafka" Version="8.3.3" />
+    <ProjectReference Include="..\..\protocols\JiShe.CollectBus.Protocol\JiShe.CollectBus.Protocol.csproj" />
 
 		<ProjectReference Include="..\JiShe.CollectBus.Application.Contracts\JiShe.CollectBus.Application.Contracts.csproj" />
 
diff --git a/services/JiShe.CollectBus.Application/Samples/TestAppService.cs b/services/JiShe.CollectBus.Application/Samples/TestAppService.cs
index f5f2e6b..1975d5a 100644
--- a/services/JiShe.CollectBus.Application/Samples/TestAppService.cs
+++ b/services/JiShe.CollectBus.Application/Samples/TestAppService.cs
@@ -1,35 +1,20 @@
-using System;
-using System.Collections.Generic;
-using System.Threading.Tasks;
-using Apache.IoTDB.DataStructure;
-using Apache.IoTDB;
-using Confluent.Kafka;
-using JiShe.CollectBus.Ammeters;
-using JiShe.CollectBus.FreeSql;
-using JiShe.CollectBus.IotSystems.PrepayModel;
-using Microsoft.AspNetCore.Authorization;
-using Microsoft.AspNetCore.Mvc;
-using Microsoft.Extensions.Options;
-using Microsoft.Extensions.Logging;
-using JiShe.CollectBus.Common.Helpers; 
-using JiShe.CollectBus.Protocol.Contracts.Interfaces;
-using Microsoft.Extensions.DependencyInjection;
+using Cassandra;
 using JiShe.CollectBus.Cassandra;
 using JiShe.CollectBus.Common.Enums;
-using JiShe.CollectBus.Common.Extensions;
+using JiShe.CollectBus.DynamicModule;
+using JiShe.CollectBus.Interceptors;
 using JiShe.CollectBus.IotSystems.MessageIssueds;
-using Volo.Abp.Application.Services;
-using JiShe.CollectBus.IotSystems.MessageReceiveds;
-using Volo.Abp.Domain.Repositories;
+using JiShe.CollectBus.IotSystems.Protocols;
+using JiShe.CollectBus.Protocol.Interfaces;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Generic;
 using System.Diagnostics;
 using System.Linq;
 using System.Reflection;
-using Cassandra;
-using JiShe.CollectBus.Interceptors;
-using JiShe.CollectBus.IotSystems.Protocols;
-using TouchSocket.Core;
+using System.Threading.Tasks;
 using Volo.Abp.Modularity;
-using JiShe.CollectBus.DynamicModule;
 
 namespace JiShe.CollectBus.Samples;
 
diff --git a/services/JiShe.CollectBus.Application/Subscribers/SubscriberAppService.cs b/services/JiShe.CollectBus.Application/Subscribers/SubscriberAppService.cs
index f8a880c..d6a7e75 100644
--- a/services/JiShe.CollectBus.Application/Subscribers/SubscriberAppService.cs
+++ b/services/JiShe.CollectBus.Application/Subscribers/SubscriberAppService.cs
@@ -2,30 +2,21 @@
 using JiShe.CollectBus.Common.Enums;
 using JiShe.CollectBus.Common.Helpers;
 using JiShe.CollectBus.Common.Models;
-using JiShe.CollectBus.IotSystems.Devices;
+using JiShe.CollectBus.Interceptors;
+using JiShe.CollectBus.IoTDB.Interface;
 using JiShe.CollectBus.IotSystems.MessageReceiveds;
 using JiShe.CollectBus.IotSystems.MeterReadingRecords;
 using JiShe.CollectBus.Kafka.Attributes;
-using JiShe.CollectBus.Protocol.Contracts;
+using JiShe.CollectBus.Kafka.Internal;
 using JiShe.CollectBus.Protocol.Contracts.Interfaces;
-using JiShe.CollectBus.Protocol.Contracts.Models;
 using JiShe.CollectBus.Repository.MeterReadingRecord;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 using System;
-using System.Linq;
+using System.Collections.Generic;
 using System.Threading.Tasks;
-using JiShe.CollectBus.IoTDB.Interface;
 using TouchSocket.Sockets;
 using Volo.Abp.Domain.Repositories;
-using System.Collections.Generic;
-using JiShe.CollectBus.Interceptors;
-using JiShe.CollectBus.Kafka.Internal;
-using JiShe.CollectBus.IoTDB.Provider;
-using JiShe.CollectBus.Protocol.Dto;
-using System.Collections;
-using JiShe.CollectBus.Interfaces;
-using System.CodeDom.Compiler;
 
 namespace JiShe.CollectBus.Subscribers
 {
diff --git a/web/JiShe.CollectBus.Host/Extensions/CustomApplicationBuilderExtensions.cs b/web/JiShe.CollectBus.Host/Extensions/CustomApplicationBuilderExtensions.cs
index 6019cd2..f933497 100644
--- a/web/JiShe.CollectBus.Host/Extensions/CustomApplicationBuilderExtensions.cs
+++ b/web/JiShe.CollectBus.Host/Extensions/CustomApplicationBuilderExtensions.cs
@@ -1,7 +1,4 @@
-using JiShe.CollectBus.Protocol.Contracts.Interfaces;
-using Volo.Abp.Caching;
-
-namespace JiShe.CollectBus.Host.Extensions
+namespace JiShe.CollectBus.Host.Extensions
 {
     public static class CustomApplicationBuilderExtensions
     {