From b1fe1a1efb2902cfca0eb8680ef4f446598fd313 Mon Sep 17 00:00:00 2001 From: Mark van der Wal Date: Mon, 6 Apr 2020 22:43:39 +0200 Subject: [PATCH] Added first herbicide flow with one input. --- FarmmapsApi/Extensions.cs | 2 +- FarmmapsApiSamples/Application.cs | 4 +- FarmmapsApiSamples/HerbicideService.cs | 157 +++++++++++++++++++++++-- FarmmapsApiSamples/NitrogenService.cs | 8 +- 4 files changed, 153 insertions(+), 18 deletions(-) diff --git a/FarmmapsApi/Extensions.cs b/FarmmapsApi/Extensions.cs index 2ef39ea..7f0737f 100644 --- a/FarmmapsApi/Extensions.cs +++ b/FarmmapsApi/Extensions.cs @@ -45,7 +45,7 @@ namespace FarmmapsApi } catch { - // ignored + tokenSource.Cancel(); } } while (!token.IsCancellationRequested); } diff --git a/FarmmapsApiSamples/Application.cs b/FarmmapsApiSamples/Application.cs index 318764e..ef1ee4a 100644 --- a/FarmmapsApiSamples/Application.cs +++ b/FarmmapsApiSamples/Application.cs @@ -40,8 +40,8 @@ namespace FarmmapsApiSamples await _farmmapsApiService.GetCurrentUserCodeAsync(); var roots = await _farmmapsApiService.GetCurrentUserRootsAsync(); - await _nitrogenService.TestFlow(roots); -// await _herbicideService.TestFlow(roots); +// await _nitrogenService.TestFlow(roots); + await _herbicideService.TestFlow(roots); } catch (Exception ex) { diff --git a/FarmmapsApiSamples/HerbicideService.cs b/FarmmapsApiSamples/HerbicideService.cs index 36c342c..46a7a9f 100644 --- a/FarmmapsApiSamples/HerbicideService.cs +++ b/FarmmapsApiSamples/HerbicideService.cs @@ -1,11 +1,16 @@ using System; using System.Collections.Generic; +using System.IO; using System.Linq; using System.Threading.Tasks; using FarmmapsApi.Models; using FarmmapsApi.Services; +using FarmmapsApiSamples.Models; +using Google.Apis.Upload; using Microsoft.Extensions.Logging; +using Newtonsoft.Json; using Newtonsoft.Json.Linq; +using static FarmmapsApi.Extensions; using static FarmmapsApiSamples.Constants; namespace FarmmapsApiSamples @@ -15,32 +20,76 @@ namespace FarmmapsApiSamples private readonly ILogger _logger; private readonly FarmmapsApiService _farmmapsApiService; + private HerbicideAgent liberatorTarweAgent; + public HerbicideService(ILogger logger, FarmmapsApiService farmmapsApiService) { _logger = logger; _farmmapsApiService = farmmapsApiService; + + liberatorTarweAgent = new HerbicideAgent() + { + Middel = "Liberator", + Grondsoort = "Klei", + ExtraProductType = "OS", + ActieveStofGehalte = "diflu100+flufenacet400", + MinDosis = 0.33f, + MaxDosis = 0.6f, + A = 0.007f, + B = 0.25f, + C = 1.05f, + D = 97f, + E = 3f, + P = 1f, + Gewas = "Tarwe", + Opmerking = "Org. stof arme grond", + TankMix = string.Empty + }; } public async Task TestFlow(List roots) { + var downloadFolder = "Downloads"; + if (!Directory.Exists(downloadFolder)) + Directory.CreateDirectory(downloadFolder); + var myDrive = roots.SingleOrDefault(r => r.Name == "My drive"); if (myDrive == null) { _logger.LogError("Could not find a needed root item"); return; } - var cropfieldItem = await GetOrCreateCropfieldItemAsync(myDrive.Code); + + var uploadedRoot = roots.SingleOrDefault(r => r.Name == "Uploaded"); + if (uploadedRoot == null) + { + _logger.LogError("Could not find a needed root item"); + return; + } - // find or create relevant data as geotiff format + _logger.LogInformation("Creating cropfield"); + var cropfieldItem = await CreateCropfieldItemAsync(myDrive.Code); + + _logger.LogInformation("Uploading data"); + var dataItem = await UploadData(uploadedRoot, GEOTIFF_PROCESSED_ITEMTYPE, Path.Combine("Data", "Lutum.tiff")); + if(dataItem == null) + { + _logger.LogError($"Failed to upload data"); + return; + } - // create or get herbicide agent - - // call herbicide task - - // download appliance map + _logger.LogInformation("Calculating appliance map"); + var applianceMapItem = await CalculateApplianceMap(cropfieldItem, dataItem, liberatorTarweAgent); + if (applianceMapItem == null) + { + return; + } + + _logger.LogInformation("Downloading appliance map"); + await _farmmapsApiService.DownloadItemAsync(applianceMapItem.Code, Path.Combine(downloadFolder, $"{applianceMapItem.Name}.zip")); } - - private async Task GetOrCreateCropfieldItemAsync(string parentItemCode) + + private async Task CreateCropfieldItemAsync(string parentItemCode) { var currentYear = new DateTime(DateTime.UtcNow.Year, 1, 1); var cropfieldItemRequest = new ItemRequest() @@ -50,13 +99,99 @@ namespace FarmmapsApiSamples Name = "Cropfield VRA Herbicide LUTUM", DataDate = currentYear, DataEndDate = currentYear.AddMonths(3), - Data = JObject.FromObject(new - {startDate = currentYear, endDate = currentYear.AddMonths(3)}), + Data = JObject.Parse("{}"), Geometry = JObject.Parse( @"{""type"":""Polygon"",""coordinates"":[[[4.617786844284247,52.22533706956424],[4.618642601314543,52.225938364585989],[4.6192153806397,52.22563988897754],[4.619192414656403,52.2256242822442],[4.620306732153958,52.225031745661528],[4.620542019225217,52.22519855319158],[4.621157509147853,52.22487436515405],[4.623387917230182,52.22367660757213],[4.624563444939009,52.22304740241544],[4.624562779355982,52.223046635247019],[4.624534908813479,52.22302596787506],[4.627873021330343,52.221240670658399],[4.627504935938338,52.220104419135129],[4.627324878706837,52.22020569669098],[4.627320696113512,52.22020660117888],[4.626707169518044,52.22053923770041],[4.624700376420229,52.221619047547488],[4.623471571183885,52.22227447969577],[4.623471511010673,52.22227500174403],[4.623468838689317,52.22228052566992],[4.617786844284247,52.22533706956424]]]}") }; return await _farmmapsApiService.CreateItemAsync(cropfieldItemRequest); } + + private async Task UploadData(UserRoot root, string itemType, string filePath) + { + var startUpload = DateTime.UtcNow; + var result = await _farmmapsApiService.UploadFile(filePath, root.Code, + progress => _logger.LogInformation($"Status: {progress.Status} - BytesSent: {progress.BytesSent}")); + + if (result.Progress.Status == UploadStatus.Failed) + return null; + + var fileName = Path.GetFileNameWithoutExtension(filePath); + return await FindItem(root.Code, itemType, fileName, + i => i.Created >= startUpload && + i.Name.ToLower().Contains(fileName.ToLower())); + } + + private async Task CalculateApplianceMap(Item cropfieldItem, Item inputItem, HerbicideAgent agent) + { + var taskRequest = new TaskRequest() + { + TaskType = "vnd.farmmaps.task.vraherbicide" + }; + taskRequest.attributes["inputCode"] = inputItem.Code; + taskRequest.attributes["agent"] = JsonConvert.SerializeObject(agent); + + var taskCode = await _farmmapsApiService.QueueTaskAsync(cropfieldItem.Code, taskRequest); + await PollTask(TimeSpan.FromSeconds(3), async (tokenSource) => + { + _logger.LogInformation("Checking vraherbicide task status"); + var itemTaskStatus = await _farmmapsApiService.GetTaskStatusAsync(cropfieldItem.Code, taskCode); + if (itemTaskStatus.State == ItemTaskState.Error || itemTaskStatus.State == ItemTaskState.Ok) + 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 = $"VRAHerbicide {agent.Middel}"; + var applianceMapItem = await FindItem(cropfieldItem.Code, + GEOTIFF_PROCESSED_ITEMTYPE, itemName, + i => i.Updated >= itemTask.Finished.GetValueOrDefault(DateTime.UtcNow) && + i.Name.ToLower().Contains(itemName.ToLower())); + + if (applianceMapItem == null) + { + _logger.LogError("Could not find the VRAHerbicide geotiff child item under cropfield"); + return null; + } + + return applianceMapItem; + } + + private async Task FindItem(string parentCode, string itemType, string containsName, + Func filter = null, int maxTries = 10) + { + Item dataItem = null; + int tries = 0; + await PollTask(TimeSpan.FromSeconds(3), async source => + { + _logger.LogInformation($"Trying to get {containsName} data"); + var uploadedFilesChildren = await _farmmapsApiService.GetItemChildrenAsync(parentCode, itemType); + if (uploadedFilesChildren.Count > 0) + { + Func func = filter ?? (i => i.Name.ToLower().Contains(containsName.ToLower())); + dataItem = uploadedFilesChildren.FirstOrDefault(func); + source.Cancel(); + } else if (tries == maxTries) + { + source.Cancel(); + } + + tries++; + }); + + if (dataItem == null) + { + _logger.LogError("dataItem not found"); + return null; + } + + _logger.LogInformation($"Found {containsName} item"); + return dataItem; + } } } \ No newline at end of file diff --git a/FarmmapsApiSamples/NitrogenService.cs b/FarmmapsApiSamples/NitrogenService.cs index 9570bae..2599e8a 100644 --- a/FarmmapsApiSamples/NitrogenService.cs +++ b/FarmmapsApiSamples/NitrogenService.cs @@ -150,7 +150,7 @@ namespace FarmmapsApiSamples { _logger.LogInformation("Checking shapetogeotiff task status"); var itemTaskStatus = await _farmmapsApiService.GetTaskStatusAsync(isariaShapeItem.Code, taskCode); - if (itemTaskStatus.State != ItemTaskState.Processing && itemTaskStatus.State != ItemTaskState.Scheduled) + if (itemTaskStatus.State == ItemTaskState.Error || itemTaskStatus.State == ItemTaskState.Ok) tokenSource.Cancel(); }); @@ -201,7 +201,7 @@ namespace FarmmapsApiSamples await PollTask(TimeSpan.FromSeconds(3), async (tokenSource) => { var itemTaskStatus = await _farmmapsApiService.GetTaskStatusAsync(cropfieldItem.Code, itemTaskCode); - if (itemTaskStatus.State != ItemTaskState.Processing && itemTaskStatus.State != ItemTaskState.Scheduled) + if (itemTaskStatus.State == ItemTaskState.Error || itemTaskStatus.State == ItemTaskState.Ok) tokenSource.Cancel(); }); @@ -242,7 +242,7 @@ namespace FarmmapsApiSamples await PollTask(TimeSpan.FromSeconds(5), async (tokenSource) => { var itemTaskStatus = await _farmmapsApiService.GetTaskStatusAsync(cropfieldItem.Code, itemTaskCode); - if (itemTaskStatus.State != ItemTaskState.Processing && itemTaskStatus.State != ItemTaskState.Scheduled) + if (itemTaskStatus.State == ItemTaskState.Error || itemTaskStatus.State == ItemTaskState.Ok) tokenSource.Cancel(); }); @@ -296,7 +296,7 @@ namespace FarmmapsApiSamples await PollTask(TimeSpan.FromSeconds(5), async (tokenSource) => { var itemTaskStatus = await _farmmapsApiService.GetTaskStatusAsync(cropfieldItem.Code, itemTaskCode); - if (itemTaskStatus.State != ItemTaskState.Processing && itemTaskStatus.State != ItemTaskState.Scheduled) + if (itemTaskStatus.State == ItemTaskState.Error || itemTaskStatus.State == ItemTaskState.Ok) tokenSource.Cancel(); });