|
|
|
using log4net;
|
|
|
|
using Newtonsoft.Json;
|
|
|
|
using Service.Execute.Model;
|
|
|
|
|
|
|
|
namespace Service.Execute.Api;
|
|
|
|
|
|
|
|
public class RfidApi
|
|
|
|
{
|
|
|
|
private static readonly ILog Log = LogManager.GetLogger(typeof(RfidApi));
|
|
|
|
|
|
|
|
//TODO::Rfid 服务地址
|
|
|
|
private static readonly string BASE_URL = "http://localhost:5037";
|
|
|
|
|
|
|
|
private static readonly HttpClient _httpClient = new HttpClient()
|
|
|
|
{
|
|
|
|
Timeout = TimeSpan.FromSeconds(60)
|
|
|
|
};
|
|
|
|
|
|
|
|
public static async Task<bool> BeginRead()
|
|
|
|
{
|
|
|
|
var disConnect =await DisConnect();
|
|
|
|
//断连
|
|
|
|
var connect = await Connect();
|
|
|
|
if (!connect)
|
|
|
|
{
|
|
|
|
Log.Info("Rfid connect fail");
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
Log.Info("BeginRead");
|
|
|
|
string url = BASE_URL + "/Api/BeginRead";
|
|
|
|
try
|
|
|
|
{
|
|
|
|
string s = await _httpClient.GetStringAsync(url);
|
|
|
|
Log.Info($"BeginRead resp = {s}");
|
|
|
|
return bool.Parse(s);
|
|
|
|
}
|
|
|
|
catch (Exception e)
|
|
|
|
{
|
|
|
|
Log.Error($"RfidApi BeginRead err e={e}");
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public static async Task<bool> StopRead()
|
|
|
|
{
|
|
|
|
Log.Info("StopRead");
|
|
|
|
string url = BASE_URL + "/Api/StopRead";
|
|
|
|
try
|
|
|
|
{
|
|
|
|
string s = await _httpClient.GetStringAsync(url);
|
|
|
|
Log.Info($"StopRead resp = {s}");
|
|
|
|
return bool.Parse(s);
|
|
|
|
}
|
|
|
|
catch (Exception e)
|
|
|
|
{
|
|
|
|
Log.Error($"RfidApi StopRead err e={e}");
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
public static async Task<bool> DisConnect()
|
|
|
|
{
|
|
|
|
Log.Info("DisConnect");
|
|
|
|
string url = BASE_URL + "/Api/Close";
|
|
|
|
try
|
|
|
|
{
|
|
|
|
string s = await _httpClient.GetStringAsync(url);
|
|
|
|
Log.Info($"DisConnect resp={s}");
|
|
|
|
return bool.Parse(s);
|
|
|
|
}
|
|
|
|
catch (Exception e)
|
|
|
|
{
|
|
|
|
Log.Error($"RfidApi DisConnect err e={e}");
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public static async Task<bool> Connect()
|
|
|
|
{
|
|
|
|
var disConnect = await DisConnect();
|
|
|
|
|
|
|
|
Log.Info("Connect");
|
|
|
|
string url = BASE_URL + "/Api/Open";
|
|
|
|
try
|
|
|
|
{
|
|
|
|
string s = await _httpClient.GetStringAsync(url);
|
|
|
|
Log.Info($"Connect resp={s}");
|
|
|
|
return bool.Parse(s);
|
|
|
|
}
|
|
|
|
catch (Exception e)
|
|
|
|
{
|
|
|
|
Log.Error($"RfidApi Connect err e={e}");
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public static async Task<RfidReadModel?> ReadRifd()
|
|
|
|
{
|
|
|
|
|
|
|
|
|
|
|
|
Log.Info("ReadRifd");
|
|
|
|
string readUrl = BASE_URL + "/Api/BeginRead";
|
|
|
|
string url = BASE_URL + "/Api/ReadRfidData";
|
|
|
|
try
|
|
|
|
{
|
|
|
|
var vBeginRead = await _httpClient.GetStringAsync(readUrl);
|
|
|
|
string s = await _httpClient.GetStringAsync(url);
|
|
|
|
Log.Info($"ReadRifd resp={s}");
|
|
|
|
if (s != String.Empty)
|
|
|
|
{
|
|
|
|
RfidReadModel? model = JsonConvert.DeserializeObject<RfidReadModel>(s);
|
|
|
|
if (model != null)
|
|
|
|
{
|
|
|
|
return model;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (Exception e)
|
|
|
|
{
|
|
|
|
Log.Error($"RfidApi ReadRifd err e={e}");
|
|
|
|
return null;
|
|
|
|
}
|
|
|
|
|
|
|
|
return null;
|
|
|
|
}
|
|
|
|
}
|