From 4f1314cb69a47c22e52f1efdc4b4be6c1d55143d Mon Sep 17 00:00:00 2001
From: ningshuxia <ningshuxia0927@outlook.com>
Date: 星期一, 12 十二月 2022 15:26:16 +0800
Subject: [PATCH] 报表定时调用API服务
---
Server/IStation.DataDocking.Socket/Job/PackageHandleHelper.cs | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/Server/IStation.DataDocking.Socket/Job/PackageHandleHelper.cs b/Server/IStation.DataDocking.Socket/Job/PackageHandleHelper.cs
index 6ebdb6d..c90568a 100644
--- a/Server/IStation.DataDocking.Socket/Job/PackageHandleHelper.cs
+++ b/Server/IStation.DataDocking.Socket/Job/PackageHandleHelper.cs
@@ -45,7 +45,7 @@
}
if (configure == null)
{
- LogHelper.Info($"Socket鏁版嵁瀵规帴浠诲姟涓�,绔彛锛歿mySession.Server.Options.Listeners.First().Port},鏀跺埌涓�鏉℃棤娉曡瘑鍒殑娑堟伅锛歿message_str}");
+ LogHelper.Info($"Socket鏁版嵁瀵规帴浠诲姟涓鍙{mySession.Server.Options.Listeners.First().Port}]鏀跺埌涓�鏉℃棤娉曡瘑鍒殑娑堟伅锛歿message_str}");
return;
}
@@ -58,7 +58,7 @@
var dataDocking = DataDockingSocketFactory.CreateSocket<IDataDockingSocket.IHandleHelper>(configure.ConfigureParas.DependencyFile);
if (dataDocking == null)
{
- LogHelper.Info($"Socket鏁版嵁瀵规帴涓�,{configure.Name},鍒涘缓鏁版嵁瀵规帴瀵硅薄澶辫触锛�");
+ LogHelper.Info($"Socket鏁版嵁瀵规帴涓璠{configure.Name}]鍒涘缓鏁版嵁瀵规帴瀵硅薄澶辫触锛�");
return;
}
if (message_str == mySession.RegisterCode)
@@ -68,17 +68,17 @@
}
else if (message_str == mySession.Heartbeat)
{
- LogHelper.Info($"Socket鏁版嵁瀵规帴涓�,{configure.Name},鎺ユ敹鍒板績璺冲寘锛歿message_str}");
+ LogHelper.Info($"Socket鏁版嵁瀵规帴涓璠{configure.Name}]鎺ユ敹鍒板績璺冲寘锛歿message_str}");
dataDocking.HandleHeartbeat(mySession);
}
else
{
- LogHelper.Info($"Socket鏁版嵁瀵规帴涓�,{configure.Name}锛屾帴鏀跺埌鏁版嵁锛歿message_bts}");
+ LogHelper.Info($"Socket鏁版嵁瀵规帴涓璠{configure.Name}]鎺ユ敹鍒版暟鎹細{message_bts}");
dataDocking.HandleData(mySession, requestInfo.Body, configure.Mappers, (receive_list) =>
{
if (receive_list == null || receive_list.Count < 1)
{
- LogHelper.Info($"Socket鏁版嵁瀵规帴涓紝娉ㄥ唽鐮�:{configure.Name},鑾峰彇娴嬬偣璁板綍澶辫触锛�");
+ LogHelper.Info($"Socket鏁版嵁瀵规帴,娉ㄥ唽鐮乕{configure.Name}]鑾峰彇娴嬬偣璁板綍澶辫触锛�");
return;
}
var queue = new RabbitMqQueueHelper();
@@ -88,7 +88,7 @@
ConfigureID = configure.ID,
Records = receive_list
});
- LogHelper.Info($"Socket鏁版嵁瀵规帴涓�:{configure.Name}锛屾垚鍔熸帹鍏ラ�氶亾{receive_list.Count()}鏉℃暟鎹紒");
+ LogHelper.Info($"Socket鏁版嵁瀵规帴涓璠{configure.Name}]鎴愬姛鎺ㄥ叆閫氶亾{receive_list.Count()}鏉℃暟鎹紒");
});
}
});
--
Gitblit v1.9.3