lpf/SGGL_SHJ
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

云眸 日志

Browse Source
This commit is contained in:
李超
2025-12-24 15:35:40 +08:00
parent f2127a7500
commit 1af8e1126a
3 changed files with 30 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
SGGL/BLL/OpenService/YunMouService.cs
+9 -9
View File
@@ -80,11 +80,11 @@ namespace BLL
//token = YunMouHelper.getToken();
////创建消费者消费者如果5分钟未调用拉取消息接口将被删除。
//consumerId = YunMouHelper.addConsumer(token);
LogService.AddLog(token + ";" + consumerId, "调用消息队列参数");
ErrLogInfo.WriteLog(token + ";" + consumerId);
string content = YunMouHelper.consumerMessage(consumerId, token);
//调用消息队列第一次
LogService.AddLog(content, "调用消息队列1");
ErrLogInfo.WriteLog(content);
var j2 = JsonConvert.DeserializeObject<dynamic>(content);
//消费者首次拉取消息时需要与消息通道建立连接，此次调用实际拉到消息列表为空，
@@ -125,7 +125,7 @@ namespace BLL
//如果为空再调一次
content = YunMouHelper.consumerMessage(consumerId, token);
//调用消息队列第二次
LogService.AddLog(content, "调用消息队列" + (y + 2).ToString());
ErrLogInfo.WriteLog(content+"调用消息队列" + (y + 2).ToString());
j2 = JsonConvert.DeserializeObject<dynamic>(content);
if (j2.data.Count > 0)
{
@@ -170,7 +170,7 @@ namespace BLL
catch (Exception ex)
{
var erro = ex.Message;
LogService.AddLog(ex.Message, "调用消息队列");
ErrLogInfo.WriteLog(ex.Message);
}
}
@@ -183,10 +183,10 @@ namespace BLL
////创建消费者消费者如果5分钟未调用拉取消息接口将被删除。
//consumerId = YunMouHelper.addConsumer(token);
LogService.AddLog(token + ";" + consumerId, "调用消息队列参数");
ErrLogInfo.WriteLog(token + ";" + consumerId+ "调用消息队列参数");
string content = YunMouHelper.consumerMessage(consumerId, token);
//调用消息队列第一次
LogService.AddLog(content, "调用消息队列1");
ErrLogInfo.WriteLog(content );
var j2 = JsonConvert.DeserializeObject<dynamic>(content);
//消费者首次拉取消息时需要与消息通道建立连接，此次调用实际拉到消息列表为空，
@@ -227,7 +227,7 @@ namespace BLL
//如果为空再调一次
content = YunMouHelper.consumerMessage(consumerId, token);
//调用消息队列第二次
LogService.AddLog(content, "调用消息队列" + (y + 2).ToString());
ErrLogInfo.WriteLog(content+ "调用消息队列" + (y + 2).ToString());
j2 = JsonConvert.DeserializeObject<dynamic>(content);
if (j2.data.Count > 0)
{
@@ -272,7 +272,7 @@ namespace BLL
catch (Exception ex)
{
var erro = ex.Message;
LogService.AddLog(ex.Message, "调用消息队列");
ErrLogInfo.WriteLog(ex.Message );
}
}