2023-03-22 13:48:13 +00:00
using System ;
using System.Collections.Generic ;
2023-11-01 12:02:54 +00:00
using System.Diagnostics ;
2023-03-22 13:48:13 +00:00
using System.IO ;
using System.IO.Compression ;
using System.Linq ;
2024-05-28 08:06:48 +00:00
using System.Net.NetworkInformation ;
2023-03-22 13:48:13 +00:00
using System.Threading.Tasks ;
2024-05-15 13:45:53 +00:00
using System.Transactions ;
2023-03-22 13:48:13 +00:00
using FarmmapsApi ;
using FarmmapsApi.Models ;
using FarmmapsApi.Services ;
using FarmmapsKPI.Models ;
using Microsoft.Extensions.Logging ;
using Newtonsoft.Json ;
using Newtonsoft.Json.Linq ;
using static FarmmapsApiSamples . Constants ;
namespace FarmmapsKPI
{
public class KPIApplication : IApplication
{
//private const string DownloadFolder = "Downloads";
private const string SettingsFile = "settings.json" ;
private readonly ILogger < KPIApplication > _logger ;
private readonly FarmmapsApiService _farmmapsApiService ;
2023-10-04 15:21:05 +00:00
private readonly KPIService _kpiService ;
2023-03-22 13:48:13 +00:00
private readonly GeneralService _generalService ;
private Settings _settings ;
public KPIApplication ( ILogger < KPIApplication > logger , FarmmapsApiService farmmapsApiService ,
2023-10-04 15:21:05 +00:00
GeneralService generalService , KPIService kpiService )
2023-03-22 13:48:13 +00:00
{
_logger = logger ;
_farmmapsApiService = farmmapsApiService ;
_generalService = generalService ;
2023-10-04 15:21:05 +00:00
_kpiService = kpiService ;
2023-03-22 13:48:13 +00:00
}
public async Task RunAsync ( )
{
2023-11-01 12:02:54 +00:00
KPIInput input ;
2023-10-24 11:06:36 +00:00
string fnKPIinput ;
2023-11-28 14:16:44 +00:00
//Console.WriteLine("Type name of input json file. Example: KPIinput.json (in same directory as FarmmapsKPI.exe) or for example like this: C:/temp/KPIinputChemieTmp.json");
//fnKPIinput = Console.ReadLine();
//if (string.IsNullOrEmpty(fnKPIinput))
//{
2024-07-04 11:35:33 +00:00
//fnKPIinput = "KPIinput.json";
fnKPIinput = "C:\\git\\FarmMapsApiClient_KB34_MAST\\FarmmapsKPI\\KPIinput.json" ;
2023-11-28 14:16:44 +00:00
//}
2023-10-24 11:06:36 +00:00
var fieldsInputJson = File . ReadAllText ( fnKPIinput ) ;
2023-03-22 13:48:13 +00:00
List < KPIInput > fieldsInputs = JsonConvert . DeserializeObject < List < KPIInput > > ( fieldsInputJson ) ;
// !! this call is needed the first time an api is called with a fresh clientid and secret !!
await _farmmapsApiService . GetCurrentUserCodeAsync ( ) ;
var roots = await _farmmapsApiService . GetCurrentUserRootsAsync ( ) ;
2023-10-13 14:37:50 +00:00
//Where to write the output
string downloadFolder = fieldsInputs [ 0 ] . DownloadFolder ;
if ( string . IsNullOrEmpty ( downloadFolder ) )
{
downloadFolder = "Downloads" ;
}
if ( ! Directory . Exists ( downloadFolder ) )
Directory . CreateDirectory ( downloadFolder ) ;
2023-10-24 11:06:36 +00:00
2023-10-13 14:37:50 +00:00
//Write the same info to a single csv file. Note this means existing file will be overwritten!
2023-10-24 11:06:36 +00:00
StreamWriter sw ;
string KPIItemCsv = Path . GetFileNameWithoutExtension ( fnKPIinput ) + "_Items.csv" ;
string KPIItemPathCsv = Path . Combine ( downloadFolder , KPIItemCsv ) ;
2024-05-15 13:45:53 +00:00
List < string > headerList = new List < string > { "run" , "parentName" , "cropfieldcode" , "area_ha" , "cropTypeCode" , "cropTypeName" , "KPIid" , "KPIvariable" , "KPIvalue" , "KPIunit" , "KPItargetvalue" , "KPIthresholdValue" ,
2023-11-22 15:16:59 +00:00
"mbp_productCode" , "mbp_productName" , "mbp_quantity" , "mbp_unitCode" , "mbp_date" , "mbp_KPIvariable" , "mbp_KPIvalue" } ;
2023-10-13 14:37:50 +00:00
//Create a new csv file. Means if existing then overwritten !!!
sw = new StreamWriter ( KPIItemPathCsv ) ;
2023-11-28 14:16:44 +00:00
Configuration cf = await _farmmapsApiService . GetConfiguration ( ) ;
string endPoint = cf . Endpoint ;
sw . WriteLine ( $"Using FarmmapsKPI application in FarmmapsApSamples.sln. Input file: '{fnKPIinput}'. Download DateTime: '{DateTime.Now}'. Calculations on: '{endPoint}'" ) ;
2023-11-01 12:02:54 +00:00
sw . WriteLine ( ) ;
2023-10-13 14:37:50 +00:00
sw . WriteLine ( string . Join ( "," , headerList ) ) ;
2023-11-01 12:02:54 +00:00
// For each input download all KPI's. Keep track to time, important when doing bulk calculations
var watch = System . Diagnostics . Stopwatch . StartNew ( ) ;
TimeSpan tsSofar = new TimeSpan ( ) ;
TimeSpan tsRemaining ;
TimeSpan tsTotalEstimated ;
2024-05-15 13:45:53 +00:00
//Per default just 1 run per field. For debugging check if when we run multiple times do we get (should be) always the same output?
2024-05-27 11:52:15 +00:00
int nrun = 1 ;
2024-05-15 13:45:53 +00:00
for ( int run = 1 ; run < = nrun ; run + + ) {
2024-05-15 14:06:19 +00:00
for ( int i = 0 ; i < fieldsInputs . Count ; i + + )
2024-08-26 08:35:58 +00:00
//for (int i = 3; i < 4; i++) // for testing
2023-03-22 13:48:13 +00:00
{
2024-05-15 13:45:53 +00:00
watch . Restart ( ) ;
input = fieldsInputs [ i ] ;
_logger . LogInformation ( string . Format ( $"// FarmmapsKPI: Run {run}: Downloading KPI's for field {i + 1} out of {fieldsInputs.Count} to single csv file {KPIItemPathCsv}" ) ) ;
try
{
await Process ( roots , input , sw , run ) ;
}
catch ( Exception ex )
{
_logger . LogError ( ex . Message ) ;
}
watch . Stop ( ) ;
tsSofar = tsSofar + watch . Elapsed ;
tsTotalEstimated = tsSofar / ( i + 1 ) * fieldsInputs . Count ;
tsRemaining = tsTotalEstimated - tsSofar ;
_logger . LogInformation ( string . Format ( $"// Time (hh:mm:ss): this field: {strTime(watch.Elapsed)}. Sofar: {strTime(tsSofar)}. Estimated total: {strTime(tsTotalEstimated)}. Remaining: {strTime(tsRemaining)}" ) ) ;
}
2023-03-22 13:48:13 +00:00
}
2023-10-13 14:37:50 +00:00
//Close the csv file, write message to screen
sw . Close ( ) ;
2023-11-01 12:02:54 +00:00
_logger . LogInformation ( string . Format ( $"// FarmmapsKPI:" ) ) ;
_logger . LogInformation ( $"Done! Written all KPI for all fields in '{fnKPIinput}' to output file '{KPIItemPathCsv}'" ) ;
2023-03-22 13:48:13 +00:00
}
2024-05-15 13:45:53 +00:00
private async Task Process ( List < UserRoot > roots , KPIInput input , StreamWriter sw , int run )
2023-03-22 13:48:13 +00:00
{
2023-11-21 13:03:14 +00:00
List < Item > cropfieldChildren ;
List < Item > crprecChildren ;
2023-10-13 14:37:50 +00:00
KPIOutput kpio ;
2023-10-16 11:55:12 +00:00
KPIOutput kpioPrevious = new KPIOutput ( ) ; //creates a new empty
2023-11-22 15:16:59 +00:00
//If KPI E1 is calculated, write these sub kpi's to output
string [ ] mbp_KPIvariables = new string [ ] { "aquaticLife" , "groundWater" , "soilLife" } ;
string mbp_KPIvalue ;
2023-11-28 14:16:44 +00:00
int targetKPIitemsCount ; //if we know we should be getting 8 KPI items (A1,B1,B2,C1,D1,E1,F1,F2)
int maxtries = 5 ; // but don't keep on trying forever; there is a maximum number of tries
int trycnt ;
2024-05-27 13:35:25 +00:00
//double totalNferiliserInput = 0;
//double totalNferiliserCropfield = 0;
2023-10-13 14:37:50 +00:00
2023-03-22 13:48:13 +00:00
string downloadFolder = input . DownloadFolder ;
if ( string . IsNullOrEmpty ( downloadFolder ) ) {
downloadFolder = "Downloads" ;
}
if ( ! Directory . Exists ( downloadFolder ) )
Directory . CreateDirectory ( downloadFolder ) ;
// !!specify if you are using an already created cropfield:
2023-10-13 14:37:50 +00:00
bool useExistingCropfieldWithChildren = input . UseExistingCropfieldWithChildren ;
int cropYear = input . CropYear ;
string fieldName = input . fieldName ;
string fieldGeom = input . GeometryJson . ToString ( Formatting . None ) ;
2023-03-22 13:48:13 +00:00
2023-10-13 14:37:50 +00:00
//Settings
2023-03-22 13:48:13 +00:00
string settingsfile = $"Settings_{fieldName}.json" ;
LoadSettings ( settingsfile ) ;
var uploadedRoot = roots . SingleOrDefault ( r = > r . Name = = "USER_IN" ) ;
if ( uploadedRoot = = null )
{
_logger . LogError ( "Could not find a needed root item" ) ;
return ;
}
var myDriveRoot = roots . SingleOrDefault ( r = > r . Name = = "USER_FILES" ) ;
if ( myDriveRoot = = null )
{
_logger . LogError ( "Could not find a needed root item" ) ;
return ;
}
2023-04-25 14:14:43 +00:00
// Use already created cropfield or create new one, added a Data input, with field specific data for the KPI calculation
2023-03-22 13:48:13 +00:00
Item cropfieldItem ;
2023-10-13 14:37:50 +00:00
//1 useExistingCropfieldWithChildren = false -> create new
//2 useExistingCropfieldWithChildren = true && input.CropfieldItemCode = "" or absent -> read from settings json
//3 useExistingCropfieldWithChildren = true && input.CropfieldItemCode like "deb48a74c5b54299bb852f17288010e9" in KPIinput -> use this one
if ( useExistingCropfieldWithChildren = = false )
2023-03-22 13:48:13 +00:00
{
2023-11-01 12:02:54 +00:00
_logger . LogInformation ( $"Creating cropfield with name '{fieldName}'" ) ;
2023-03-22 13:48:13 +00:00
cropfieldItem = await _generalService . CreateCropfieldItemAsync ( myDriveRoot . Code ,
2023-11-08 12:50:37 +00:00
$"{fieldName}" , cropYear , input . GeometryJson . ToString ( Formatting . None ) , input . DataCropfield . ToString ( Formatting . None ) , input . StartDate , input . EndDate ) ;
2023-03-22 13:48:13 +00:00
_settings . CropfieldItemCode = cropfieldItem . Code ;
SaveSettings ( settingsfile ) ;
}
2023-06-27 12:08:27 +00:00
else if ( string . IsNullOrEmpty ( input . CropfieldItemCode ) )
2023-03-22 13:48:13 +00:00
{
2023-10-04 15:21:05 +00:00
_logger . LogInformation ( "reading CropfieldItemCode from settings file" ) ;
2023-03-22 13:48:13 +00:00
cropfieldItem = await _farmmapsApiService . GetItemAsync ( _settings . CropfieldItemCode ) ;
}
2023-06-27 12:08:27 +00:00
else
{
2023-11-01 12:02:54 +00:00
_logger . LogInformation ( "reading CropfieldItemCode from KPIinput json" ) ;
2023-06-27 12:08:27 +00:00
cropfieldItem = await _farmmapsApiService . GetItemAsync ( input . CropfieldItemCode ) ;
2023-10-13 14:37:50 +00:00
SaveSettings ( settingsfile ) ;
2023-06-27 12:08:27 +00:00
}
2023-03-22 13:48:13 +00:00
2024-02-27 14:44:07 +00:00
// The cropfieldCharacteristicItem is used to enter crop yields and/or straw yields
2023-11-01 12:02:54 +00:00
Item cropfieldCharacteristicItem ;
2024-02-27 14:44:07 +00:00
string dataCropfieldCharacteristic ;
2023-11-01 12:02:54 +00:00
//1 useExistingCropfieldWithChildren = false -> create new
//2 useExistingCropfieldWithChildren = true && input.CropfieldCharacteristicItemCode = "" or absent -> read from settings json
//3 useExistingCropfieldWithChildren = true && input.CropfieldCharacteristicItemCode like "deb48a74c5b54299bb852f17288010e9" in KPIinput -> use this one
if ( useExistingCropfieldWithChildren = = false )
{
2024-02-27 14:44:07 +00:00
for ( int i = 0 ; i < input . DataCropfieldCharacteristics . Length ; i + + )
{
dataCropfieldCharacteristic = input . DataCropfieldCharacteristics [ i ] . ToString ( Formatting . None ) ;
dynamic data = JObject . Parse ( dataCropfieldCharacteristic ) ;
_logger . LogInformation ( $"CreateCropfieldCharacteristicItemAsync ... for cropfieldCharacteristic {i}: '{data.label}', value '{data.value}'" ) ;
cropfieldCharacteristicItem = await _generalService . CreateCropfieldCharacteristicItemAsync ( cropfieldItem . Code , cropYear , fieldGeom , dataCropfieldCharacteristic ) ;
_settings . CropfieldCharacteristicItemCode = cropfieldCharacteristicItem . Code ;
SaveSettings ( settingsfile ) ;
}
2023-11-01 12:02:54 +00:00
}
else if ( string . IsNullOrEmpty ( input . CropfieldItemCode ) )
{
2024-02-27 14:44:07 +00:00
_logger . LogInformation ( "reading CropfieldCharacteristicItemCode from settings file" ) ;
2023-11-01 12:02:54 +00:00
cropfieldCharacteristicItem = await _farmmapsApiService . GetItemAsync ( _settings . CropfieldCharacteristicItemCode ) ;
}
else
{
_logger . LogInformation ( "reading CropfieldCharacteristicItemCode from KPIinput json" ) ;
cropfieldCharacteristicItem = await _farmmapsApiService . GetItemAsync ( input . CropfieldCharacteristicItemCode ) ;
SaveSettings ( settingsfile ) ;
}
2023-10-04 15:21:05 +00:00
2023-11-01 12:02:54 +00:00
// Now we can do a first KPI calculation and get the polygon area from the KPI output (where it is based on geometry)
// We need that because for operations, you need to provide the area on which the operation was applied
// And if we put that to the crop area, then we neatly get everything on a per ha basis
_logger . LogInformation ( $"Getting polygon area (ha))" ) ;
2024-05-27 11:52:15 +00:00
List < Item > KPIItemsArea = await _generalService . GetKpiItemsForCropField ( cropfieldItem , 3 ) ;
2023-11-28 14:16:44 +00:00
trycnt = 1 ;
2024-05-27 11:52:15 +00:00
targetKPIitemsCount = 3 ; // here for the area we need at least 3, but not more than that
while ( KPIItemsArea . Count < targetKPIitemsCount & trycnt < maxtries )
2023-11-28 14:16:44 +00:00
{
2024-05-27 11:52:15 +00:00
KPIItemsArea = await _generalService . GetKpiItemsForCropField ( cropfieldItem , 3 ) ;
_logger . LogInformation ( $"Found {KPIItemsArea.Count} KPI items" ) ;
2023-11-28 14:16:44 +00:00
trycnt + + ;
}
2024-05-27 11:52:15 +00:00
kpio = JsonConvert . DeserializeObject < KPIOutput > ( KPIItemsArea [ 0 ] . Data . ToString ( ) ) ;
2023-11-01 12:02:54 +00:00
string area_ha = kpio . data . area ;
// turn the area into a JObject for later merging with operation data;
string strJarea = JsonConvert . SerializeObject ( new { area = area_ha } ) ;
JObject Jarea = JObject . Parse ( strJarea ) ;
2023-11-22 15:16:59 +00:00
if ( useExistingCropfieldWithChildren = = false )
2023-11-21 13:03:14 +00:00
{
2023-11-22 15:16:59 +00:00
//Retreiving BOFEK. A cropfield has 1 soil
//Have a look at the cropfieldChildren before and after running this task, see one child (i.e. soil) has been added)
//cropfieldChildren = await _farmmapsApiService.GetItemChildrenAsync(cropfieldItem.Code);
_logger . LogInformation ( "Get BOFEK for field" ) ;
Item bofekItem = await _generalService . RunBofekTask ( cropfieldItem ) ;
if ( bofekItem = = null )
{
_logger . LogError ( "Something went wrong while obtaining the BOFEK data" ) ;
return ;
}
//cropfieldChildren = await _farmmapsApiService.GetItemChildrenAsync(cropfieldItem.Code);
}
else
{
_logger . LogInformation ( "For existing cropfield we assume it already has BOFEK soil data" ) ;
2023-11-21 13:03:14 +00:00
}
2023-11-01 12:02:54 +00:00
// A cropfield has 1 crop recording and the crop recording has 0:many operations
//So first at the crop recording
2023-10-04 15:21:05 +00:00
Item crprecItem ;
2023-10-13 14:37:50 +00:00
//1 useExistingCropfieldWithChildren = false -> create new
//2 useExistingCropfieldWithChildren = true && input.CropRecordingItemCode = "" or absent -> read from settings json
//3 useExistingCropfieldWithChildren = true && input.CropRecordingItemCode like "deb48a74c5b54299bb852f17288010e9" in KPIinput -> use this one
if ( useExistingCropfieldWithChildren = = false )
2023-10-04 15:21:05 +00:00
{
_logger . LogInformation ( "RunCropRecordingTask ..." ) ;
crprecItem = await _generalService . RunCropRecordingTask ( cropfieldItem ) ;
_settings . CropRecordingItemCode = crprecItem . Code ;
SaveSettings ( settingsfile ) ;
}
else if ( string . IsNullOrEmpty ( input . CropfieldItemCode ) )
{
_logger . LogInformation ( "reading CropRecordingItemCode from settings file" ) ;
crprecItem = await _farmmapsApiService . GetItemAsync ( _settings . CropRecordingItemCode ) ;
}
else
2023-03-22 13:48:13 +00:00
{
2023-11-01 12:02:54 +00:00
_logger . LogInformation ( "reading CropRecordingItemCode from KPIinput json" ) ;
2023-10-04 15:21:05 +00:00
crprecItem = await _farmmapsApiService . GetItemAsync ( input . CropRecordingItemCode ) ;
2023-10-13 14:37:50 +00:00
SaveSettings ( settingsfile ) ;
2023-10-04 15:21:05 +00:00
}
2023-03-22 13:48:13 +00:00
2023-11-01 12:02:54 +00:00
// Now add the operations
2023-10-13 14:37:50 +00:00
List < Item > crpOperationItems = new List < Item > { } ;
List < string > crpOperationItemCodes = new List < string > { } ;
2023-10-04 15:21:05 +00:00
Item crpOperationItem ;
2023-10-13 14:37:50 +00:00
string dataOperation ;
string codeOperation ;
//1 useExistingCropfieldWithChildren = false -> create new
//2 useExistingCropfieldWithChildren = true && input.OperationItemCode = "" or absent -> read from settings json
//3 useExistingCropfieldWithChildren = true && input.OperationItemCode like "deb48a74c5b54299bb852f17288010e9" in KPIinput -> use this one
if ( useExistingCropfieldWithChildren = = false )
2023-10-04 15:21:05 +00:00
{
2023-10-13 14:37:50 +00:00
for ( int i = 0 ; i < input . DataOperations . Length ; i + + )
{
dataOperation = input . DataOperations [ i ] . ToString ( Formatting . None ) ;
dynamic data = JObject . Parse ( dataOperation ) ;
2023-11-01 12:02:54 +00:00
_logger . LogInformation ( $"CreateOperationItemAsync ... for operation {i}: '{data.name}', on date '{data.from}'" ) ;
// Now check if the operation has a field called area
string? opArea = data [ "area" ] ;
if ( string . IsNullOrEmpty ( opArea ) )
{
// if not having field area: add it to dataOperation ...
input . DataOperations [ i ] . Merge ( Jarea ) ;
// ... and update the string
dataOperation = input . DataOperations [ i ] . ToString ( Formatting . None ) ;
}
else
{
// if yes having field area: compare with polygon area. If not the same, throw warning
if ( data . area ! = area_ha )
{
double differencePercent = 100.0 * ( Convert . ToDouble ( area_ha ) / Convert . ToDouble ( data . area ) - 1.0 ) ;
2023-11-15 15:49:46 +00:00
_logger . LogWarning ( $"cropfield has area {area_ha}, but in your KPIinput.json or file like that, you have an operation with area {data.area}" +
2023-11-01 12:02:54 +00:00
$" Difference is {area_ha} / {data.area} - 100% = {differencePercent}%." +
$" Is that correct? Example if operation was applied in part of field, e.g. in case of variable rate (VRA) application." +
$" Or did you accidentally fill in area in the KPIinput json? To use cropfield area, omit field 'area' from json" +
$" then the KPI applicataion will fill in area calculated from geometry" ) ;
}
}
//Now after optionally adding the area, add the Operation to the crop recording
2023-10-13 14:37:50 +00:00
crpOperationItem = await _generalService . CreateOperationItemAsync ( crprecItem . Code , cropYear , fieldGeom , dataOperation ) ;
crpOperationItems . Add ( crpOperationItem ) ;
crpOperationItemCodes . Add ( crpOperationItem . Code ) ;
2024-05-15 13:45:53 +00:00
//Keep track of totalNferiliserInput
2024-05-27 13:35:25 +00:00
//totalNferiliserInput = totalNferiliserInput + (double)data.n; / this causes a problem if N content of the fertilizer is missing. As this check is no longer needed I just commented it out
2023-10-13 14:37:50 +00:00
}
_settings . OperationItemCodes = crpOperationItemCodes . ToArray ( ) ;
2023-10-04 15:21:05 +00:00
SaveSettings ( settingsfile ) ;
}
else if ( string . IsNullOrEmpty ( input . CropfieldItemCode ) )
{
_logger . LogInformation ( "reading OperationItemCode from settings file" ) ;
2023-10-13 14:37:50 +00:00
for ( int i = 0 ; i < _settings . OperationItemCodes . Length ; i + + )
{
codeOperation = _settings . OperationItemCodes [ i ] ;
crpOperationItem = await _farmmapsApiService . GetItemAsync ( codeOperation ) ;
crpOperationItems . Add ( crpOperationItem ) ;
crpOperationItemCodes . Add ( crpOperationItem . Code ) ;
}
2023-10-04 15:21:05 +00:00
}
else
{
2023-11-01 12:02:54 +00:00
_logger . LogInformation ( "reading OperationItemCodes from KPIinput json" ) ;
2023-10-13 14:37:50 +00:00
for ( int i = 0 ; i < input . OperationItemCodes . Length ; i + + )
{
codeOperation = input . OperationItemCodes [ i ] ;
crpOperationItem = await _farmmapsApiService . GetItemAsync ( codeOperation ) ;
crpOperationItems . Add ( crpOperationItem ) ;
crpOperationItemCodes . Add ( crpOperationItem . Code ) ;
}
_settings . OperationItemCodes = crpOperationItemCodes . ToArray ( ) ;
SaveSettings ( settingsfile ) ;
2023-10-04 15:21:05 +00:00
}
2023-03-22 13:48:13 +00:00
2023-10-13 14:37:50 +00:00
// Inspect the children and grandchildren. If all is well, cropfield will have:
2023-11-01 12:02:54 +00:00
// one crprec, with 0-many operations as children. And the Data of an operation will have specification of how much fertilizer / cropprotection agent was applied
2023-10-13 14:37:50 +00:00
// one edicrop.characteristic (with yield in the data)
2023-11-21 13:03:14 +00:00
cropfieldChildren = await _farmmapsApiService . GetItemChildrenAsync ( cropfieldItem . Code ) ;
crprecChildren = await _farmmapsApiService . GetItemChildrenAsync ( crprecItem . Code ) ;
2023-10-04 15:21:05 +00:00
2024-05-15 13:45:53 +00:00
//Check total operations
int nOperationsInput = input . DataOperations . Length ;
int nOperationsCropfield = crprecChildren . Count ;
if ( nOperationsInput ! = nOperationsCropfield )
2024-05-16 08:04:48 +00:00
{
_logger . LogWarning ( String . Format ( $"1. run {run}: nOperationsInput != nOperationsCropfield?!" ) ) ;
//throw new Exception(String.Format($"run {run}: nOperationsInput != nOperationsCropfield?!"));
}
2024-05-15 13:45:53 +00:00
2024-05-27 13:35:25 +00:00
//Check totalNfertiliser input and Cropfield,
//for (int o = 0; o < crprecChildren.Count; o++)
//{
// dynamic data = JObject.Parse(crprecChildren[o].Data.ToString());
// totalNferiliserCropfield = totalNferiliserCropfield + (double)data.n;
//}
//if (totalNferiliserInput != totalNferiliserCropfield)
//{
// _logger.LogWarning(String.Format($"2. run {run}: totalNferiliserInput != totalNferiliserCropfield?!"));
// //throw new Exception(String.Format($"run {run}: totalNferiliserInput != totalNferiliserCropfield?!"));
//}
2024-05-15 13:45:53 +00:00
2023-10-04 15:21:05 +00:00
//Now get the KPIs for this cropfield, mounted with operations & cropyield
2024-05-27 11:52:15 +00:00
List < Item > KPIItems = await _generalService . GetKpiItemsForCropField ( cropfieldItem , 3 ) ;
2023-10-11 15:00:25 +00:00
_logger . LogInformation ( $"GetKpiItemsForCropField('{cropfieldItem.Code}')" ) ;
2023-11-21 13:03:14 +00:00
//Pesticide KPI's D1 and E1 are retreived from API's of CTBG and CLM and may take a bit longer to retrieve
2023-11-28 14:16:44 +00:00
targetKPIitemsCount = 8 ; //if we know we should be getting 8 KPI items (A1,B1,B2,C1,D1,E1,F1,F2)
trycnt = 0 ;
bool boolAquaticLife = false ;
_logger . LogInformation ( $"Firing calls GetKpiItemsForCropField() until we have {targetKPIitemsCount} KPIitems, but don't keep firing forever, stop after {maxtries} calls" ) ;
_logger . LogInformation ( $"Before we start:" ) ;
2024-05-27 11:52:15 +00:00
//_logger.LogInformation($"* KPIItems.Count = {KPIItems.Count}");
2023-11-28 14:16:44 +00:00
_logger . LogInformation ( $"* trycnt = {trycnt}" ) ;
_logger . LogInformation ( $"* boolAquaticLife = {boolAquaticLife}" ) ;
//additional criterion for while loop: check if it really contains the E1 mbp elements.
//while (trycnt == 0 || ((KPIItems.Count < targetKPIitemsCount || boolAquaticLife == false) & trycnt < maxtries))
2024-02-27 14:44:07 +00:00
targetKPIitemsCount = 8 ; //if we know we should be getting 8 KPI items (A1,B1,B2,C1,D1,E1,F1,F2)
2023-11-28 14:16:44 +00:00
while ( trycnt = = 0 | | ( KPIItems . Count < targetKPIitemsCount & trycnt < maxtries ) )
{
_logger . LogInformation ( $"Call nr {trycnt + 1}" ) ;
2024-05-27 11:52:15 +00:00
KPIItems = await _generalService . GetKpiItemsForCropField ( cropfieldItem , 30 ) ; //number after comma is how many seconds per try, should be between 30 seconds and 5 minutes
2023-11-21 13:03:14 +00:00
_logger . LogInformation ( $"Found {KPIItems.Count} KPI items" ) ;
2023-11-28 14:16:44 +00:00
//boolAquaticLife = GetBoolAquaticLife(KPIItems);
2023-11-21 13:03:14 +00:00
trycnt + + ;
}
if ( KPIItems . Count < targetKPIitemsCount ) {
_logger . LogWarning ( $"Found {KPIItems.Count} KPIItems while you were aiming for {targetKPIitemsCount} KPIItems" ) ;
}
2023-04-25 10:00:08 +00:00
2023-10-04 15:21:05 +00:00
//Download KPI's into a json output file for this specific cropfield (with unique cropfieldItem.Code)
2023-10-13 14:37:50 +00:00
string KPIItemPathJson = Path . Combine ( downloadFolder , $"KPIItems_{cropfieldItem.Code}.json" ) ;
2023-04-25 10:00:08 +00:00
var count = 0 ;
2023-10-13 14:37:50 +00:00
foreach ( Item item in KPIItems )
2023-03-22 13:48:13 +00:00
{
2023-10-13 14:37:50 +00:00
//Console.WriteLine($"KPI item #{count}: {item.Name}");
File . AppendAllText ( KPIItemPathJson , item . Data + Environment . NewLine ) ;
2023-04-25 10:00:08 +00:00
count + + ;
2023-03-22 13:48:13 +00:00
}
2023-10-13 14:37:50 +00:00
_logger . LogInformation ( $"Downloaded file {KPIItemPathJson}" ) ;
2023-11-28 14:16:44 +00:00
_logger . LogInformation ( $"" ) ;
2023-04-25 10:00:08 +00:00
2024-05-27 11:52:15 +00:00
//Remove duplicate KPI items
List < Item > KPIItemsClean = new List < Item > ( ) ;
Item itemi ;
2024-05-28 08:06:48 +00:00
string id , idNext ;
double value , valueNext ;
int DuplicateCounter ;
2024-05-27 11:52:15 +00:00
value = 0 ;
id = "" ;
2024-07-04 11:35:33 +00:00
DuplicateCounter = 1 ;
2024-05-27 11:52:15 +00:00
for ( int i = 0 ; i < KPIItems . Count ; i + + )
{
itemi = KPIItems [ i ] ;
idNext = JsonConvert . DeserializeObject < KPIOutput > ( itemi . Data . ToString ( ) ) . id ;
2024-05-28 08:06:48 +00:00
valueNext = Convert . ToDouble ( JsonConvert . DeserializeObject < KPIOutput > ( itemi . Data . ToString ( ) ) . value ) ;
2024-05-27 11:52:15 +00:00
if ( idNext ! = null )
{
if ( id ! = idNext )
{
KPIItemsClean . Add ( itemi ) ;
}
else
{
if ( valueNext > = value )
{
//Remove the previous element from this list with same id but wrong value (valueNext > value) or duplicate value (valueNext == value). Presumes list is always sorted by kpiid, e.g. we may havce "
2024-05-28 08:06:48 +00:00
KPIItemsClean . RemoveAt ( i - DuplicateCounter ) ; //added a duplicate counter to deal with calculations where there is more 1 duplicate.
2024-05-27 11:52:15 +00:00
KPIItemsClean . Add ( itemi ) ;
2024-05-28 08:06:48 +00:00
DuplicateCounter = DuplicateCounter + 1 ;
2024-05-27 11:52:15 +00:00
}
else
{
//Previous element was correct and already added so do nothing here
}
}
id = idNext ;
value = valueNext ;
}
}
////Order again from A zo Z.
//List<Item> KPIItemsCleanSorted = new List<Item>();
//for (int i = KPIItemsClean.Count - 1; i >= 0; i--)
//{
// KPIItemsCleanSorted.Add(KPIItemsClean[i]);
//}
2023-10-13 14:37:50 +00:00
//Write to the csv file that collects all KPI's for all the crop fields
List < string > dataList ;
2024-05-27 11:52:15 +00:00
foreach ( Item item in KPIItemsClean )
{
2023-10-13 14:37:50 +00:00
kpio = JsonConvert . DeserializeObject < KPIOutput > ( item . Data . ToString ( ) ) ;
2023-10-24 11:06:36 +00:00
if ( kpio . id ! = null )
2023-10-13 14:37:50 +00:00
{
2024-05-27 11:52:15 +00:00
KPIelementsOfBalance kPIelementsOfBalance = kpio . data . values ;
if ( kpio . id = = "A1" ) //TtD
{
//Make a new dataList = new line to be written
//Fill the datalist with this kpi
dataList = new List < string >
2024-03-11 13:35:03 +00:00
{
2024-05-27 11:52:15 +00:00
run . ToString ( ) ,
2024-03-11 13:35:03 +00:00
kpio . parentName ,
cropfieldItem . Code ,
kpio . data . area ,
kpio . data . cropTypeCode ,
kpio . data . cropTypeName ,
kpio . id ,
kpio . quantity , // in KPI output quantity is what we call KPIvariable in headerlist of csv file
kpio . value ,
kpio . unit ,
kpio . targetValue ,
kpio . thresholdValue
} ;
2024-05-27 11:52:15 +00:00
//Write the datalist to a line to the streamwrieter sw for the output csv file
sw . WriteLine ( string . Join ( "," , dataList ) ) ;
foreach ( string elementName in kpio . A1elements )
{
// get A1element from the element called values
// TtD 20240311: note elements of A1 are in the data structure elements of kpio.data and not as below for B1, B2, etc as kpio.data.values
string elementValue = ( string ) kpio . data . GetType ( ) . GetProperty ( elementName ) . GetValue ( kpio . data , null ) ;
dataList = new List < string >
2024-03-11 13:35:03 +00:00
{
2024-05-15 13:45:53 +00:00
run . ToString ( ) ,
2024-03-11 13:35:03 +00:00
kpio . parentName ,
cropfieldItem . Code ,
kpio . data . area ,
kpio . data . cropTypeCode ,
kpio . data . cropTypeName ,
kpio . id ,
elementName , // specific output variable name for A1 element
elementValue , // specific output value name for A1 element
kpio . unit ,
"" ,
""
} ;
2024-05-27 11:52:15 +00:00
//Write the datalist to a line to the streamwrieter sw for the output csv file
sw . WriteLine ( string . Join ( "," , dataList ) ) ;
2024-03-11 13:35:03 +00:00
}
2024-05-27 11:52:15 +00:00
}
else if ( kpio . id = = "B1" )
{
//Make a new dataList = new line to be written
//Fill the datalist with this kpi
dataList = new List < string >
2024-02-16 13:52:48 +00:00
{
2024-05-15 13:45:53 +00:00
run . ToString ( ) ,
2024-02-16 13:52:48 +00:00
kpio . parentName ,
cropfieldItem . Code ,
kpio . data . area ,
kpio . data . cropTypeCode ,
kpio . data . cropTypeName ,
kpio . id ,
kpio . quantity , // in KPI output quantity is what we call KPIvariable in headerlist of csv file
kpio . value ,
kpio . unit ,
kpio . targetValue ,
kpio . thresholdValue
2024-05-27 11:52:15 +00:00
} ;
//Write the datalist to a line to the streamwrieter sw for the output csv file
sw . WriteLine ( string . Join ( "," , dataList ) ) ;
2024-02-12 14:43:00 +00:00
2024-05-27 11:52:15 +00:00
foreach ( string elementName in kpio . B1elements )
{
// get B1element from the element called values
string elementValue = ( string ) kPIelementsOfBalance . GetType ( ) . GetProperty ( elementName ) . GetValue ( kPIelementsOfBalance , null ) ;
dataList = new List < string >
2024-02-16 13:52:48 +00:00
{
2024-05-15 13:45:53 +00:00
run . ToString ( ) ,
2024-02-16 13:52:48 +00:00
kpio . parentName ,
cropfieldItem . Code ,
kpio . data . area ,
kpio . data . cropTypeCode ,
kpio . data . cropTypeName ,
kpio . id ,
elementName , // specific output variable name for B1 element
elementValue , // specific output value name for B1 element
kpio . unit ,
"" ,
""
} ;
2024-05-27 11:52:15 +00:00
//Write the datalist to a line to the streamwrieter sw for the output csv file
sw . WriteLine ( string . Join ( "," , dataList ) ) ;
2024-05-15 13:45:53 +00:00
2024-05-27 11:52:15 +00:00
//Check if totalNferiliserInput is equal to what comes out of the KPI calculation
2024-05-27 13:35:25 +00:00
//if (elementName == "nFertilizerNKgHa")
//{
// if (totalNferiliserInput != Convert.ToDouble(elementValue))
// {
// _logger.LogWarning(String.Format($"3. run {run}: totalNferiliserInput != nFertilizerNKgHa"));
// //throw new Exception(String.Format($"run {run}: totalNferiliserInput != nFertilizerNKgHa"));
// }
//}
2023-11-22 15:16:59 +00:00
}
2024-05-27 11:52:15 +00:00
}
else if ( kpio . id = = "B2" )
{
//Make a new dataList = new line to be written
dataList = new List < string >
2024-02-16 13:52:48 +00:00
{
//Fill the datalist with this kpi
2024-05-15 13:45:53 +00:00
run . ToString ( ) ,
2024-02-16 13:52:48 +00:00
kpio . parentName ,
cropfieldItem . Code ,
kpio . data . area ,
kpio . data . cropTypeCode ,
kpio . data . cropTypeName ,
kpio . id ,
kpio . quantity , // in KPI output quantity is what we call KPIvariable in headerlist of csv file
kpio . value ,
kpio . unit ,
kpio . targetValue ,
kpio . thresholdValue
} ;
2024-05-27 11:52:15 +00:00
//Write the datalist to a line to the streamwrieter sw for the output csv file
sw . WriteLine ( string . Join ( "," , dataList ) ) ;
2024-02-12 14:43:00 +00:00
2024-05-27 11:52:15 +00:00
foreach ( string elementName in kpio . B2elements )
{
// get B1element from the element called values
string elementValue = ( string ) kPIelementsOfBalance . GetType ( ) . GetProperty ( elementName ) . GetValue ( kPIelementsOfBalance , null ) ;
dataList = new List < string >
2024-02-16 13:52:48 +00:00
{
2024-05-15 13:45:53 +00:00
run . ToString ( ) ,
2024-02-16 13:52:48 +00:00
kpio . parentName ,
cropfieldItem . Code ,
kpio . data . area ,
kpio . data . cropTypeCode ,
kpio . data . cropTypeName ,
kpio . id ,
elementName , // specific output variable name for B2 element
elementValue , // specific output value name for B2 element
kpio . unit ,
"" ,
""
} ;
2024-05-27 11:52:15 +00:00
//Write the datalist to a line to the streamwrieter sw for the output csv file
sw . WriteLine ( string . Join ( "," , dataList ) ) ;
2024-02-12 14:43:00 +00:00
}
2024-05-27 11:52:15 +00:00
}
2024-02-16 11:58:00 +00:00
2024-05-27 11:52:15 +00:00
else if ( kpio . id = = "C1" ) //TtD
{
//Make a new dataList = new line to be written
dataList = new List < string >
2024-02-16 13:52:48 +00:00
{
2024-05-15 13:45:53 +00:00
run . ToString ( ) ,
2024-02-16 13:52:48 +00:00
kpio . parentName ,
cropfieldItem . Code ,
kpio . data . area ,
kpio . data . cropTypeCode ,
kpio . data . cropTypeName ,
kpio . id ,
kpio . quantity , // in KPI output quantity is what we call KPIvariable in headerlist of csv file
kpio . value ,
kpio . unit ,
kpio . targetValue ,
kpio . thresholdValue
} ;
2024-05-27 11:52:15 +00:00
//Write the datalist to a line to the streamwrieter sw for the output csv file
sw . WriteLine ( string . Join ( "," , dataList ) ) ;
2024-02-16 11:58:00 +00:00
2024-05-27 11:52:15 +00:00
foreach ( string elementName in kpio . C1elements )
{
// get C1element from the element called values
string elementValue = ( string ) kPIelementsOfBalance . GetType ( ) . GetProperty ( elementName ) . GetValue ( kPIelementsOfBalance , null ) ;
dataList = new List < string >
2024-02-16 13:52:48 +00:00
{
2024-05-15 13:45:53 +00:00
run . ToString ( ) ,
2024-02-16 13:52:48 +00:00
kpio . parentName ,
cropfieldItem . Code ,
kpio . data . area ,
kpio . data . cropTypeCode ,
kpio . data . cropTypeName ,
kpio . id ,
elementName , // specific output variable name for C1 element
elementValue , // specific output value name for C1 element
kpio . unit ,
"" ,
""
} ;
2024-05-27 11:52:15 +00:00
//Write the datalist to a line to the streamwrieter sw for the output csv file
sw . WriteLine ( string . Join ( "," , dataList ) ) ;
2024-02-16 11:58:00 +00:00
}
2024-05-27 11:52:15 +00:00
}
else if ( kpio . id = = "E1" )
{
//for E1, environmentMeasureData is an array of elements with 1 per pesticide. Inside each element there are multiple mbp_KPIvariables to be written
foreach ( KPIenvironmentMeasureData e in kpio . data . environmentMeasureData )
2023-11-22 15:16:59 +00:00
{
2024-05-27 11:52:15 +00:00
foreach ( string mbp_KPIvariable in mbp_KPIvariables )
2023-11-22 15:16:59 +00:00
{
2024-05-27 11:52:15 +00:00
if ( mbp_KPIvariable = = "aquaticLife" ) { mbp_KPIvalue = e . aquaticLife ; } else if ( mbp_KPIvariable = = "groundWater" ) { mbp_KPIvalue = e . groundWater ; } else if ( mbp_KPIvariable = = "soilLife" ) { mbp_KPIvalue = e . soilLife ; } else { mbp_KPIvalue = "" ; }
//Make a new dataList = new line to be written
dataList = new List < string >
2024-02-16 13:52:48 +00:00
{
2024-05-15 13:45:53 +00:00
run . ToString ( ) ,
2024-02-16 13:52:48 +00:00
kpio . parentName ,
cropfieldItem . Code ,
kpio . data . area ,
kpio . data . cropTypeCode ,
kpio . data . cropTypeName ,
kpio . id , //"E1"
kpio . quantity , // "mbp"
"" , // not here the value
"" , // not here KPIunit for this indicator
"" , // not here KPItargetvalue for this indicator
"" , // not here KPIthresholdValue for this indicator
e . productCode ,
e . productName ,
e . quantity ,
e . unitCode ,
e . date ,
mbp_KPIvariable ,
mbp_KPIvalue
} ;
2024-05-27 11:52:15 +00:00
//Write the datalist to a line to the streamwrieter sw for the output csv file
sw . WriteLine ( string . Join ( "," , dataList ) ) ;
2023-11-22 15:16:59 +00:00
}
}
2024-05-27 11:52:15 +00:00
}
2024-07-04 11:35:33 +00:00
else if ( kpio . id = = "G1" ) //TtD
{
//Make a new dataList = new line to be written
dataList = new List < string >
{
run . ToString ( ) ,
kpio . parentName ,
cropfieldItem . Code ,
kpio . data . area ,
kpio . data . cropTypeCode ,
kpio . data . cropTypeName ,
kpio . id ,
kpio . quantity , // in KPI output quantity is what we call KPIvariable in headerlist of csv file
kpio . value ,
kpio . unit ,
kpio . targetValue ,
kpio . thresholdValue
} ;
//Write the datalist to a line to the streamwrieter sw for the output csv file
sw . WriteLine ( string . Join ( "," , dataList ) ) ;
foreach ( string elementName in kpio . G1elements )
{
// get G1element from the element called values
string elementValue = ( string ) kPIelementsOfBalance . GetType ( ) . GetProperty ( elementName ) . GetValue ( kPIelementsOfBalance , null ) ;
dataList = new List < string >
{
run . ToString ( ) ,
kpio . parentName ,
cropfieldItem . Code ,
kpio . data . area ,
kpio . data . cropTypeCode ,
kpio . data . cropTypeName ,
kpio . id ,
elementName , // specific output variable name for G1 element
elementValue , // specific output value name for G1 element
kpio . unit ,
"" ,
""
} ;
//Write the datalist to a line to the streamwrieter sw for the output csv file
sw . WriteLine ( string . Join ( "," , dataList ) ) ;
}
}
2024-05-27 11:52:15 +00:00
else
{
2024-07-04 11:35:33 +00:00
//Any other KPI, (D1, F1, and F2), with just 1 record to write
2024-05-27 11:52:15 +00:00
dataList = new List < string >
2024-02-16 13:52:48 +00:00
{
2024-05-15 13:45:53 +00:00
run . ToString ( ) ,
2024-02-16 13:52:48 +00:00
kpio . parentName ,
cropfieldItem . Code ,
kpio . data . area ,
kpio . data . cropTypeCode ,
kpio . data . cropTypeName ,
kpio . id ,
kpio . quantity ,
kpio . value ,
kpio . unit ,
kpio . targetValue ,
kpio . thresholdValue
} ;
2024-05-27 11:52:15 +00:00
//Write the datalist to a line to the streamwrieter sw for the output csv file
sw . WriteLine ( string . Join ( "," , dataList ) ) ;
2023-10-24 11:06:36 +00:00
}
2023-10-13 14:37:50 +00:00
}
}
2024-02-12 14:43:00 +00:00
////Total N applied from input
//double totalNapplied = 0.0;
//double operationNapplied;
//for (int i = 0; i < crpOperationItemCodes.Count; i++)
//{
// codeOperation = crpOperationItemCodes[i];
// crpOperationItem = await _farmmapsApiService.GetItemAsync(codeOperation);
// dynamic data = JObject.Parse(crpOperationItem.Data.ToString(Formatting.None));
// if (data.n != null)
// {
// operationNapplied = crpOperationItem.Data.GetValue("n").ToObject<double>();
// totalNapplied = totalNapplied + operationNapplied;
// }
//}
////Also add totalNapplied to the csv
//dataList = new List<string> { };
//dataList.Add(kpioPrevious.parentName);
//dataList.Add(cropfieldItem.Code);
//try { dataList.Add(kpioPrevious.data.area); } catch { dataList.Add(""); };
//try { dataList.Add(kpioPrevious.data.cropTypeCode); } catch { dataList.Add(""); };
//try { dataList.Add(kpioPrevious.data.cropTypeName); } catch { dataList.Add(""); };
//dataList.Add("");
//dataList.Add("totalNapplied");
//dataList.Add(totalNapplied.ToString());
//dataList.Add("kg/ha");
//dataList.Add("");
//dataList.Add("");
//sw.WriteLine(string.Join(",", dataList));
2023-10-16 13:34:07 +00:00
2023-10-13 14:37:50 +00:00
//Clean up. Only newly created fields
//Look up instruction in Swagger / api / v1 / items /{ code}
if ( useExistingCropfieldWithChildren = = false & & input . DeleteNewlyCreatedAfterCalc = = true )
{
// Tested and found that if I delete the parent (cropfieldItem) then
// automatically deletes children (crprecItem, cropfieldCharacteristicItem, KPIcontainer)
// and automatically deletes grand children (crprecItem: operations, KPIcontainer: KPI items)
await _farmmapsApiService . DeleteItemAsync ( cropfieldItem . Code ) ;
//Do we need to wait here for the task to be completed? Or does it continue in the background?
//await Task.Delay(60000); // wait 60 secs for task to be completed
//Before the GetItem you will see cropfieldItem, crprecItem etc exist (with data).
//After the GetItem these cropfieldItem, crprecItem etc are null which means they have been succesfully deleted.
//// Check if below works, i.e. is item really deleted?
//cropfieldItem = await _farmmapsApiService.GetItemAsync(cropfieldItem.Code);
//// Check if croprecording has also been deleted. If not also delete it
//crprecItem = await _farmmapsApiService.GetItemAsync(crprecItem.Code);
//// Check if 1 operation has also been deleted. If not also delete it
//crpOperationItem = await _farmmapsApiService.GetItemAsync(crpOperationItemCodes[0]);
//// Check if 1 cropfieldCharacteristicItem has also been deleted. If not also delete it
//cropfieldCharacteristicItem = await _farmmapsApiService.GetItemAsync(cropfieldCharacteristicItem.Code);
}
2023-03-22 13:48:13 +00:00
}
// Functions to save previously created cropfields
private void LoadSettings ( string file )
{
if ( File . Exists ( file ) )
{
var jsonText = File . ReadAllText ( file ) ;
_settings = JsonConvert . DeserializeObject < Settings > ( jsonText ) ;
}
else
{
_settings = new Settings ( ) ;
}
}
private void SaveSettings ( string file )
{
if ( _settings = = null )
return ;
var json = JsonConvert . SerializeObject ( _settings ) ;
File . WriteAllText ( file , json ) ;
}
private void SaveInfo ( string file )
{
if ( _settings = = null )
return ;
var json = JsonConvert . SerializeObject ( _settings ) ;
File . WriteAllText ( file , json ) ;
}
2023-11-01 12:02:54 +00:00
private string strTime ( TimeSpan ts )
{
return String . Format ( "{0:00}:{1:00}:{2:00}" , ts . Hours , ts . Minutes , ts . Seconds ) ;
}
2023-11-28 14:16:44 +00:00
private bool GetBoolAquaticLife ( List < Item > KPIItems )
{
bool found = false ;
foreach ( Item item in KPIItems )
{
KPIOutput kpio = JsonConvert . DeserializeObject < KPIOutput > ( item . Data . ToString ( ) ) ;
if ( kpio . id = = "E1" )
{
try
{
foreach ( KPIenvironmentMeasureData e in kpio . data . environmentMeasureData )
{
if ( e . aquaticLife ! = null )
{
found = true ;
_logger . LogInformation ( $"Found e.aquaticLife = {e.aquaticLife}" ) ;
_logger . LogInformation ( "" ) ;
}
}
}
catch ( Exception ex )
{
_logger . LogWarning ( $"NOT Found e.aquaticLife" ) ;
_logger . LogError ( ex . Message ) ;
}
}
}
return found ;
}
2023-03-22 13:48:13 +00:00
}
}