forked from FarmMaps/FarmMapsApiClient
Added BlightApiClient
This commit is contained in:
67
FarmMapsBlight/BlightService.cs
Normal file
67
FarmMapsBlight/BlightService.cs
Normal file
@@ -0,0 +1,67 @@
|
||||
using FarmmapsApi.Models;
|
||||
using FarmmapsApi.Services;
|
||||
using Microsoft.Extensions.Logging;
|
||||
using System;
|
||||
using System.Threading.Tasks;
|
||||
using static FarmmapsApi.Extensions;
|
||||
using static FarmmapsApiSamples.Constants;
|
||||
|
||||
namespace FarmMapsBlight
|
||||
{
|
||||
public class BlightService
|
||||
{
|
||||
private readonly ILogger<BlightService> _logger;
|
||||
private readonly FarmmapsApiService _farmmapsApiService;
|
||||
private readonly GeneralService _generalService;
|
||||
|
||||
public BlightService(ILogger<BlightService> logger, FarmmapsApiService farmmapsApiService,
|
||||
GeneralService generalService)
|
||||
{
|
||||
_logger = logger;
|
||||
_farmmapsApiService = farmmapsApiService;
|
||||
_generalService = generalService;
|
||||
}
|
||||
|
||||
public async Task<Item> CreateAdvice(Item cropfieldItem, DateTime plantingDate, DateTime emergeDate)
|
||||
{
|
||||
var taskRequest = new TaskRequest()
|
||||
{
|
||||
TaskType = "vnd.farmmaps.task.blight"
|
||||
};
|
||||
|
||||
taskRequest.attributes["plantingDate"] = plantingDate.ToUniversalTime().ToString("o");
|
||||
taskRequest.attributes["emergeDate"] = emergeDate.ToUniversalTime().ToString("o");
|
||||
|
||||
var taskCode = await _farmmapsApiService.QueueTaskAsync(cropfieldItem.Code, taskRequest);
|
||||
await PollTask(TimeSpan.FromSeconds(3), async (tokenSource) =>
|
||||
{
|
||||
_logger.LogInformation("Checking blight task status");
|
||||
var itemTaskStatus = await _farmmapsApiService.GetTaskStatusAsync(cropfieldItem.Code, taskCode);
|
||||
if (itemTaskStatus.IsFinished)
|
||||
tokenSource.Cancel();
|
||||
});
|
||||
|
||||
var itemTask = await _farmmapsApiService.GetTaskStatusAsync(cropfieldItem.Code, taskCode);
|
||||
if (itemTask.State == ItemTaskState.Error)
|
||||
{
|
||||
_logger.LogError($"Something went wrong with task execution: {itemTask.Message}");
|
||||
return null;
|
||||
}
|
||||
|
||||
var itemName = $"Blight";
|
||||
var blightAdviceItem = await _generalService.FindChildItemAsync(cropfieldItem.Code,
|
||||
BLIGHT_ITEMTYPE, itemName);
|
||||
|
||||
// incorrect filter task is finished after updating
|
||||
|
||||
// i => i.Updated >= itemTask.Finished && i.Name.ToLower().Contains(itemName.ToLower())
|
||||
if (blightAdviceItem == null)
|
||||
{
|
||||
_logger.LogError("Could not find the blight item under cropfield");
|
||||
return null;
|
||||
}
|
||||
|
||||
return blightAdviceItem;
|
||||
}
|
||||
}
|
||||
}
|
Reference in New Issue
Block a user