115 lines
4.5 KiB
C#
115 lines
4.5 KiB
C#
using AgroBase.Models;
|
|
using AgroBase.Models.Operadores;
|
|
using Newtonsoft.Json;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
using static AgroBase.Models.Operadores.OperadoresModels;
|
|
|
|
namespace AgroBase.Services.Operadores
|
|
{
|
|
public class ManagerWorkerService : IWorkerModel
|
|
{
|
|
public ManagerWorkerModel DadosLeitura = new ManagerWorkerModel();
|
|
public SaudeWorkerModel Saude { get; set; } = new SaudeWorkerModel();
|
|
|
|
private bool DebugMode = true;
|
|
|
|
public void MostrarLog(string message, int limite = 500)
|
|
{
|
|
if (DebugMode)
|
|
{
|
|
Console.WriteLine($"[ManagerWorker] {message.Substring(0, Math.Min(limite, message.Length))}{(message.Length > limite ? "..." : "")}");
|
|
}
|
|
}
|
|
|
|
public async Task<bool> IniciarProcessamento()
|
|
{
|
|
RedisService.Subscribe(CmdKey.ManagerWorkerTx, RedisCallback);
|
|
|
|
DadosLeitura.IniciadoEm = DateTime.Now;
|
|
DadosLeitura.Iniciado = true;
|
|
|
|
bool pronto() => DadosLeitura.Pronto;
|
|
await FuncoesGlobais.AguardarCondicaoAsync(pronto, 5000);
|
|
if (pronto())
|
|
{
|
|
MostrarLog("Processamento iniciado com sucesso");
|
|
return true;
|
|
}
|
|
|
|
MostrarLog("Timeout ao iniciar script");
|
|
DadosLeitura.ReiniciarEstado();
|
|
return false;
|
|
}
|
|
|
|
public void RedisCallback(string mensagem)
|
|
{
|
|
try
|
|
{
|
|
var comando = JsonConvert.DeserializeObject<ComandoRedis>(mensagem);
|
|
|
|
var cmd = (ManagerWorkerCommandType)comando.cmd;
|
|
|
|
switch (cmd)
|
|
{
|
|
case ManagerWorkerCommandType.ScriptCarregado:
|
|
DadosLeitura.Pronto = true;
|
|
DadosLeitura.ProntoEm = DateTime.Now;
|
|
MostrarLog($"Comando recebido: cmd = {cmd.ToString()}");
|
|
break;
|
|
case ManagerWorkerCommandType.EnviarDadosControle:
|
|
if (Variaveis.OperacaoEmAndamento.Modo == Enums.ModoOperacao.MapaGPS)
|
|
{
|
|
if (comando.@params == null)
|
|
break;
|
|
|
|
var _Controle = Variaveis.OperacaoEmAndamento.Controle;
|
|
var novoComando = new ManagerWorkerMessageResponseComandoModel()
|
|
{
|
|
angulo = Convert.ToDouble(comando.@params["angulo"]),
|
|
percentual_velocidade = Convert.ToDouble(comando.@params["percentual_velocidade"]),
|
|
tipo_movimento = (Enums.TipoMovimentoDirecional)Convert.ToInt32(comando.@params["tipo_movimento"]),
|
|
simulacao = JsonConvert.DeserializeObject<List<double[]>>(comando.@params["simulacao"].ToString())
|
|
};
|
|
if (novoComando != null)
|
|
{
|
|
_Controle.Angulo = novoComando.angulo;
|
|
_Controle.TipoMovimento = novoComando.tipo_movimento;
|
|
_Controle.PercentualVelocidadeSP = novoComando.percentual_velocidade;
|
|
_Controle.SimulacaoMPC = novoComando.simulacao.Select(x => new MPCSimulacaoModel() { latitude = x[0], longitude = x[1], orientacao = x[2] }).ToList();
|
|
Variaveis.OperacaoEmAndamento.AtualizaInformacoesControleOperacao();
|
|
}
|
|
}
|
|
break;
|
|
case ManagerWorkerCommandType.FinalizarOperacao:
|
|
Task.Run(async () =>
|
|
{
|
|
await Variaveis.OperacaoEmAndamento.FinalizarOperacao();
|
|
});
|
|
break;
|
|
|
|
default:
|
|
MostrarLog($"Comando não reconhecido: {comando.cmd}");
|
|
break;
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
MostrarLog($"Erro ao deserializar resposta: {ex.Message}");
|
|
}
|
|
finally
|
|
{
|
|
DadosLeitura.UltimaMensagem = DateTime.Now;
|
|
}
|
|
}
|
|
|
|
public void AtualizarSaude()
|
|
{
|
|
Saude = OperadoresModels.AtualizarSaude(CtxKey.DadosManagerWorker);
|
|
}
|
|
|
|
}
|
|
}
|