using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using Newtonsoft.Json;
using Newtonsoft.Json.Converters;
using NLog;
namespace MatplotlibCS
{
///
/// Обёртка над питоновским скриптом построения графиков
///
// ReSharper disable once InconsistentNaming
public class MatplotlibCS
{
#region Fields
private ILogger _log;
///
/// Пусть к интерпрететору питона
///
private string _pythonExePath;
///
/// Путь к скрипту dasPlot.py
///
private string _dasPlotPyPath;
///
/// Путь директории, в которой хранятся временные json-файлы, через которые передаются параметры задачи
///
private string _jsonTempPath;
///
/// Python web service URL
///
private string _serviceUrlCheckAliveMethod = "http://127.0.0.1:57123/";
///
/// Python web service URL
///
private string _serviceUrlPlotMethod = "http://127.0.0.1:57123/plot";
///
/// Kill web service url
///
private string _serviceUrlKillMethod = "http://127.0.0.1:57123/kill";
#endregion
#region .ctor
///
/// Обёртка над python скриптом, строящим matplotlib графики
///
/// Путь python.exe
/// Путь dasPlot.py
/// Опциональный путь директории, в которой хранятся временные json файлы, через которые передаются данные
public MatplotlibCS(string pythonExePath, string dasPlotPyPath, string jsonTempPath = "c:\\MatplotlibCS")
{
_pythonExePath = pythonExePath;
_dasPlotPyPath = dasPlotPyPath;
_jsonTempPath = jsonTempPath;
_log = LogManager.GetLogger(typeof(MatplotlibCS).Name);
if (!Directory.Exists(_jsonTempPath))
Directory.CreateDirectory(_jsonTempPath);
}
#endregion
#region Public methods
///
/// Выполняет задачу построения графиков
///
/// Описание задачи
public async Task BuildFigure(Figure task)
{
task.HealthCheck();
try
{
LaunchPythonWebService();
if (!Path.IsPathRooted(task.FileName))
task.FileName = Path.Combine(_jsonTempPath, task.FileName);
JsonConvert.DefaultSettings = (() =>
{
var settings = new JsonSerializerSettings();
settings.Converters.Add(new StringEnumConverter { CamelCaseText = true });
return settings;
});
var serializer = new JsonSerializer() { StringEscapeHandling = StringEscapeHandling.EscapeHtml };
var sb = new StringBuilder();
using (var writer = new StringWriter(sb))
{
serializer.Serialize(writer, task);
}
var json = sb.ToString();
using (var client = new HttpClient())
{
var content = new StringContent(JsonConvert.SerializeObject(json), Encoding.UTF8, "application/json");
var response = await client.PostAsync(_serviceUrlPlotMethod, content);
var responseString = await response.Content.ReadAsStringAsync();
}
}
catch (Exception ex)
{
_log.Fatal($"Error while building figure: {ex.Message}\n{ex.StackTrace}");
}
}
#endregion
#region Private methods
///
/// Check if python web service is alive and if no, launches it
///
private void LaunchPythonWebService()
{
if (!CheckIfWebServiceIsUpAndRunning())
{
var psi = new ProcessStartInfo(_pythonExePath, _dasPlotPyPath)
{
RedirectStandardOutput = true,
RedirectStandardError = true,
RedirectStandardInput = true,
UseShellExecute = false,
CreateNoWindow = true,
WindowStyle = ProcessWindowStyle.Hidden
};
_log.Info($"Starting python process {_pythonExePath}, {_dasPlotPyPath}");
Process.Start(psi);
// when starting python process, it's better to wait for some time to ensure, that
// web service started
Thread.Sleep(2000);
}
}
///
/// Check if python web service is alive
///
/// true if service is up and running
private bool CheckIfWebServiceIsUpAndRunning()
{
try
{
_log.Info("Check if python web-service is already running");
//Creating the HttpWebRequest
var request = WebRequest.Create(_serviceUrlCheckAliveMethod) as HttpWebRequest;
//Setting the Request method HEAD, you can also use GET too.
request.Method = "GET";
//Getting the Web Response.
var response = request.GetResponse() as HttpWebResponse;
//Returns TRUE if the Status code == 200
response.Close();
_log.Info($"Service response status is {response.StatusCode}");
return (response.StatusCode == HttpStatusCode.OK);
}
catch (Exception ex)
{
_log.Info("Python web-service wasn't found");
//Any exception will returns false.
return false;
}
}
///
/// Возвращает новый путь, по которому можно сохранить json задачи
///
///
private string GetNewJsonPath()
{
if (!Directory.Exists(_jsonTempPath))
{
Directory.CreateDirectory(_jsonTempPath);
}
return Path.Combine(_jsonTempPath, $"task-{DateTime.Now:HHmmssfff}.json");
}
#endregion
}
}