|
|
|
@ -21,8 +21,8 @@ namespace OpenAuth.WebApi.Model.mqtt
|
|
|
|
|
|
|
|
|
|
public Task HandleAsync(string topic, string payload)
|
|
|
|
|
{
|
|
|
|
|
_logger.LogError($"[Service] Topic={topic}, Payload={payload}");
|
|
|
|
|
Console.WriteLine($"[Service] Topic={topic}, Payload={payload}");
|
|
|
|
|
//_logger.LogError($"[Service] Topic={topic}, Payload={payload}");
|
|
|
|
|
//Console.WriteLine($"[Service] Topic={topic}, Payload={payload}");
|
|
|
|
|
if (payload.Contains("live_start_push"))//直播
|
|
|
|
|
{
|
|
|
|
|
var root = JsonNode.Parse(payload)?.AsObject();
|
|
|
|
|