diff --git a/MasstransferCommon.Tests/MasstransferCommon.Tests.csproj b/MasstransferCommon.Tests/MasstransferCommon.Tests.csproj
new file mode 100644
index 0000000..4925776
--- /dev/null
+++ b/MasstransferCommon.Tests/MasstransferCommon.Tests.csproj
@@ -0,0 +1,21 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFrameworks>net7.0</TargetFrameworks>
+    
+    <IsPackable>false</IsPackable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="JetBrains.Annotations" Version="2024.2.0" />
+    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.11.1" />
+    <PackageReference Include="MSTest.TestAdapter" Version="3.5.2" />
+    <PackageReference Include="MSTest.TestFramework" Version="3.5.2" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\MasstransferCommon\MasstransferCommon.csproj" />
+    <ProjectReference Include="..\MasstransferExporter\MasstransferExporter.csproj" />
+  </ItemGroup>
+  
+</Project>
\ No newline at end of file
diff --git a/MasstransferCommon.Tests/Utils/JsonUtilTest.cs b/MasstransferCommon.Tests/Utils/JsonUtilTest.cs
new file mode 100644
index 0000000..871ba5e
--- /dev/null
+++ b/MasstransferCommon.Tests/Utils/JsonUtilTest.cs
@@ -0,0 +1,21 @@
+using System.IO;
+using JetBrains.Annotations;
+using MasstransferCommon.Utils;
+using MasstransferExporter.DataExporter.Model;
+using Microsoft.VisualStudio.TestTools.UnitTesting;
+
+namespace MasstransferCommon.Tests.Utils;
+
+[TestClass]
+[TestSubject(typeof(JsonUtil))]
+public class JsonUtilTest
+{
+    [TestMethod]
+    public void Test()
+    {
+        var json = File.ReadAllText("C:\\Users\\huangxianguo\\Desktop\\formula.json");
+
+        var dto = JsonUtil.FromJson<FormulaDTO>(json);
+        Assert.IsNotNull(dto);
+    }
+}
\ No newline at end of file
diff --git a/MasstransferCommon/Utils/JsonUtil.cs b/MasstransferCommon/Utils/JsonUtil.cs
index 1c9da47..1db00a9 100644
--- a/MasstransferCommon/Utils/JsonUtil.cs
+++ b/MasstransferCommon/Utils/JsonUtil.cs
@@ -49,6 +49,7 @@ public class JsonUtil
         }
         catch (Exception e)
         {
+            Console.WriteLine(e);
             throw new ArgumentException($" 无效的json 字符串 {json} ");
         }
     }
diff --git a/MasstransferExporter.sln b/MasstransferExporter.sln
index bfee5fe..9309002 100644
--- a/MasstransferExporter.sln
+++ b/MasstransferExporter.sln
@@ -6,7 +6,7 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MasstransferInfrastructure"
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MasstransferCommon", "MasstransferCommon\MasstransferCommon.csproj", "{66C6D73C-BADB-4E28-9C83-E701B019626D}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "TestProject1", "TestProject1\TestProject1.csproj", "{D26C3A44-62AF-4ACC-B454-51E1098C2C86}"
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MasstransferCommon.Tests", "MasstransferCommon.Tests\MasstransferCommon.Tests.csproj", "{DBEDC6E1-AEE6-47FA-A17A-2B412CE99C7C}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -26,9 +26,9 @@ Global
 		{66C6D73C-BADB-4E28-9C83-E701B019626D}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{66C6D73C-BADB-4E28-9C83-E701B019626D}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{66C6D73C-BADB-4E28-9C83-E701B019626D}.Release|Any CPU.Build.0 = Release|Any CPU
-		{D26C3A44-62AF-4ACC-B454-51E1098C2C86}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{D26C3A44-62AF-4ACC-B454-51E1098C2C86}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{D26C3A44-62AF-4ACC-B454-51E1098C2C86}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{D26C3A44-62AF-4ACC-B454-51E1098C2C86}.Release|Any CPU.Build.0 = Release|Any CPU
+		{DBEDC6E1-AEE6-47FA-A17A-2B412CE99C7C}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{DBEDC6E1-AEE6-47FA-A17A-2B412CE99C7C}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{DBEDC6E1-AEE6-47FA-A17A-2B412CE99C7C}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{DBEDC6E1-AEE6-47FA-A17A-2B412CE99C7C}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 EndGlobal
diff --git a/MasstransferExporter.sln.DotSettings.user b/MasstransferExporter.sln.DotSettings.user
index e69de29..e3bc613 100644
--- a/MasstransferExporter.sln.DotSettings.user
+++ b/MasstransferExporter.sln.DotSettings.user
@@ -0,0 +1,8 @@
+<wpf:ResourceDictionary xml:space="preserve" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:s="clr-namespace:System;assembly=mscorlib" xmlns:ss="urn:shemas-jetbrains-com:settings-storage-xaml" xmlns:wpf="http://schemas.microsoft.com/winfx/2006/xaml/presentation">
+	<s:String x:Key="/Default/Environment/UnitTesting/CreateUnitTestDialog/TestProjectMapping/=66C6D73C_002DBADB_002D4E28_002D9C83_002DE701B019626D/@EntryIndexedValue">MasstransferCommon.Tests</s:String>
+	<s:String x:Key="/Default/Environment/UnitTesting/CreateUnitTestDialog/TestTemplateMapping/=MSTest/@EntryIndexedValue">d6790ab7-33c2-4425-b2c9-51480cd1a852</s:String>
+	<s:String x:Key="/Default/Environment/UnitTesting/UnitTestSessionStore/Sessions/=df21ed25_002D5064_002D4b51_002D96dd_002D1d6a1eb4ab6c/@EntryIndexedValue">&lt;SessionState ContinuousTestingMode="0" IsActive="True" Name="Test" xmlns="urn:schemas-jetbrains-com:jetbrains-ut-session"&gt;&#xD;
+  &lt;TestAncestor&gt;&#xD;
+    &lt;TestId&gt;MSTest::DBEDC6E1-AEE6-47FA-A17A-2B412CE99C7C::net7.0::MasstransferCommon.Tests.Utils.JsonUtilTest.Test&lt;/TestId&gt;&#xD;
+  &lt;/TestAncestor&gt;&#xD;
+&lt;/SessionState&gt;</s:String></wpf:ResourceDictionary>
\ No newline at end of file
diff --git a/MasstransferExporter/DataExporter/ConfigService.cs b/MasstransferExporter/DataExporter/ConfigService.cs
index 37745d5..92b0438 100644
--- a/MasstransferExporter/DataExporter/ConfigService.cs
+++ b/MasstransferExporter/DataExporter/ConfigService.cs
@@ -1,6 +1,8 @@
 using MasstransferCommon.Atrributes;
 using MasstransferCommon.Events;
+using MasstransferCommon.Model.Constant;
 using MasstransferCommon.Utils;
+using MasstransferCommunicate.Mqtt.Client;
 using MasstransferExporter.DataExporter.Model;
 using Masuit.Tools;
 
@@ -16,7 +18,7 @@ public class ConfigService : Instant
     /// </summary>
     private static async Task ListenConfigIssuedEvent(EventType type, bool start)
     {
-        // await MessageQueueHelper.Subscribe(Topics.DownloadConfigData, HandleConfigIssuedEvent);
+        await MessageQueueHelper.Subscribe(Topics.DownloadConfigData, HandleConfigIssuedEvent);
     }
 
 
@@ -25,7 +27,7 @@ public class ConfigService : Instant
     /// </summary>
     /// <param name="topic"></param>
     /// <param name="data"></param>
-    private static void HandleConfigIssuedEvent(string topic, ConfigData data)
+    private static void HandleConfigIssuedEvent(string topic, ConfigData<object> data)
     {
         if (data.IsNullOrEmpty()) return;
 
@@ -38,7 +40,12 @@ public class ConfigService : Instant
             case "FORMULA":
             {
                 var param = data.Param;
-                var formulaDto = JsonUtil.FromJson<FormulaDTO>(JsonUtil.ToJson(param));
+                var formulaDto = JsonUtil.FromJson<FormulaDTO>(param.ToString());
+                if (formulaDto != null)
+                {
+                    formulaDto.Name = data.Name;
+                }
+
                 FormulaService.HandleFormulaIssuedEvent(formulaDto);
                 break;
             }
diff --git a/MasstransferExporter/DataExporter/FormulaService.cs b/MasstransferExporter/DataExporter/FormulaService.cs
index 1c8e58f..2c3bff6 100644
--- a/MasstransferExporter/DataExporter/FormulaService.cs
+++ b/MasstransferExporter/DataExporter/FormulaService.cs
@@ -263,7 +263,7 @@ public class FormulaService
             {
                 var formulaDto = GetFormulaById(formula.Id);
                 if (formulaDto == null) continue;
-                var data = new ConfigData()
+                var data = new ConfigData<FormulaDTO>()
                 {
                     Name = formulaDto.Name,
                     Param = formulaDto,
diff --git a/MasstransferExporter/DataExporter/Model/ConfigData.cs b/MasstransferExporter/DataExporter/Model/ConfigData.cs
index e18adb1..2bb1a28 100644
--- a/MasstransferExporter/DataExporter/Model/ConfigData.cs
+++ b/MasstransferExporter/DataExporter/Model/ConfigData.cs
@@ -5,11 +5,11 @@ namespace MasstransferExporter.DataExporter.Model;
 /// <summary>
 /// 配置数据
 /// </summary>
-public class ConfigData
+public class ConfigData<T>
 {
     [JsonProperty("name")] public string Name { get; set; }
 
     [JsonProperty("type")] public string Type { get; set; }
 
-    [JsonProperty("param")] public object Param { get; set; }
+    [JsonProperty("param")] public T? Param { get; set; }
 }
\ No newline at end of file
diff --git a/MasstransferExporter/DataExporter/SystemParamsService.cs b/MasstransferExporter/DataExporter/SystemParamsService.cs
index 5459833..7bdff9e 100644
--- a/MasstransferExporter/DataExporter/SystemParamsService.cs
+++ b/MasstransferExporter/DataExporter/SystemParamsService.cs
@@ -19,12 +19,12 @@ public class SystemParamsService
     /// 处理下发的系统配置参数
     /// </summary>
     /// <param name="data"></param>
-    public static void HandleSystemParamsIssuedEvent(ConfigData data)
+    public static void HandleSystemParamsIssuedEvent(ConfigData<object> data)
     {
         if (data.IsNullOrEmpty()) return;
 
         var name = data.Name;
-        var param = JsonUtil.ToJson(data.Param);
+        var param = data?.Param?.ToString();
         switch (name)
         {
             case "相机配置":
@@ -125,55 +125,55 @@ public class SystemParamsService
     {
         try
         {
-            var cameraParams = new ConfigData()
+            var cameraParams = new ConfigData<CameraParams>()
             {
                 Name = "相机配置",
                 Param = GetCameraParams(),
                 Type = "SYSTEM"
             };
 
-            var substrateCameraInternalParams = new ConfigData()
+            var substrateCameraInternalParams = new ConfigData<CameraInternalParams>()
             {
                 Name = "基板拍照相机内参",
                 Param = GetSubstrateParams(),
                 Type = "SYSTEM"
             };
 
-            var waferCameraInternalParams = new ConfigData()
+            var waferCameraInternalParams = new ConfigData<CameraInternalParams>()
             {
                 Name = "芯片拍照相机内参",
                 Param = GetWaferParams(),
                 Type = "SYSTEM"
             };
-            var logParams = new ConfigData()
+            var logParams = new ConfigData<LogParams>()
             {
                 Name = "日志配置",
                 Param = GetLogParams(),
                 Type = "SYSTEM"
             };
 
-            var systemParams = new ConfigData()
+            var systemParams = new ConfigData<SystemParams>()
             {
                 Name = "系统配置",
                 Param = GetSystemParams(),
                 Type = "SYSTEM"
             };
 
-            var scannerParams = new ConfigData()
+            var scannerParams = new ConfigData<ScannerParams>()
             {
                 Name = "扫描器配置",
                 Param = GetScannerParams(),
                 Type = "SYSTEM"
             };
 
-            var minioParams = new ConfigData()
+            var minioParams = new ConfigData<MinioParams>()
             {
                 Name = "MinIO配置",
                 Param = GetMinioParams(),
                 Type = "SYSTEM"
             };
 
-            var mqttParams = new ConfigData()
+            var mqttParams = new ConfigData<MqttParams>()
             {
                 Name = "MQTT配置",
                 Param = GetMqttConnectParams(),