liutk
/
internet-everythings-agricultural
1
0
Fork 0
Code Releases Activity

Merge branch 'develop' of https://gitea.hmily.club/liutk/internet-everythings-agricultural into develop

develop
vine_liutk 2023-05-12 15:38:10 +08:00
parent cf8f326515 418e227866
commit 96bb016325
3 changed files with 294 additions and 295 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/Console/Commands/DeviceLogDailyReportCommand.php
View File

@ -76,7 +76,7 @@ class DeviceLogDailyReportCommand extends Command
protected function createReportToLinkosMeteorologicalDevice(Device $device): void
{
$lastReportedAt = MeteorologicalDailyReport::where('device_id', $device->id)->latest('reported_at')->value('reported_at')
?: MeteorologicalReport::where('device_id', $device->id)->latest('reported_at')->value('reported_at');
?: MeteorologicalReport::where('device_id', $device->id)->oldest('reported_at')->value('reported_at');
if ($lastReportedAt === null) {
return;
@ -104,7 +104,7 @@ class DeviceLogDailyReportCommand extends Command
protected function createReportToLinkosWaterQualityDevice(Device $device): void
{
$lastReportedAt = WaterQualityDailyReport::where('device_id', $device->id)->latest('reported_at')->value('reported_at')
?: WaterQualityReport::where('device_id', $device->id)->latest('reported_at')->value('reported_at');
?: WaterQualityReport::where('device_id', $device->id)->oldest('reported_at')->value('reported_at');
if ($lastReportedAt === null) {
return;

196
app/Console/Commands/DeviceLogReportCommand.php
View File

@ -6,6 +6,7 @@ use App\Models\Device;
use App\Models\MeteorologicalReport;
use App\Models\SoilReport;
use App\Models\WaterQualityReport;
use App\Services\DeviceLogService;
use Illuminate\Console\Command;
use Illuminate\Support\Arr;
@ -27,11 +28,18 @@ class DeviceLogReportCommand extends Command
*/
protected $description = '按设备厂商生成监控报告';
/**
* @var \App\Services\DeviceLogService
*/
protected $deviceLogService;
/**
* Execute the console command.
*/
public function handle()
public function handle(DeviceLogService $deviceLogService)
{
$this->deviceLogService = $deviceLogService;
$factory = $this->argument('factory');
$sleep = (int) value(fn ($sleep) => is_numeric($sleep) ? $sleep : 300, $this->option('sleep'));
@ -43,7 +51,15 @@ class DeviceLogReportCommand extends Command
foreach ($devices as $device) {
switch ($device->factory?->key) {
case 'link-os':
$this->createReportToLinkosDevice($device);
switch ($device->type) {
case Device::TYPE_METEOROLOGICAL:
$this->createReportToLinkosMeteorologicalDevice($device);
break;
case Device::TYPE_WATER_QUALITY:
$this->createReportToLinkosWaterQualityDevice($device);
break;
}
break;
}
}
@ -52,95 +68,9 @@ class DeviceLogReportCommand extends Command
};
}
protected function createReportToLinkosDevice(Device $device): void
{
switch ($device->type) {
case Device::TYPE_SOIL:
$this->createReportToLinkosSoilDevice($device);
break;
case Device::TYPE_METEOROLOGICAL:
$this->createReportToLinkosMeteorologicalDevice($device);
break;
case Device::TYPE_WATER_QUALITY:
$this->createReportToLinkosWaterQualityDevice($device);
break;
}
}
protected function createReportToLinkosSoilDevice(Device $device): void
{
$lastSoilReport = SoilReport::where('device_id', $device->id)
->latest('reported_at')
->first();
$lastReportedAt = $lastSoilReport?->reported_at
?: $device->logs()->oldest('reported_at')->value('reported_at');
if ($lastReportedAt === null) {
return;
}
$latestReportedAt = $device->logs()->latest('reported_at')->value('reported_at');
if ($latestReportedAt === null) {
return;
}
/** @var \Carbon\Carbon */
$startAt = $lastReportedAt->copy()->startOfHour();
/** @var \Carbon\Carbon */
$endAt = $latestReportedAt->copy()->startOfHour();
do {
/** @var \Illuminate\Database\Eloquent\Collection */
$logs = $device->logs()
->whereBetween('reported_at', [$startAt, $startAt->copy()->endOfHour()])
->oldest('reported_at')
->get();
if ($logs->isNotEmpty()) {
$soilReport = SoilReport::firstOrCreate(
[
'device_id' => $device->id,
'reported_at' => $startAt,
],
Arr::except($lastSoilReport?->setHidden([])?->attributesToArray() ?: [], ['reported_at'])
);
/** @var \App\Models\DeviceLog */
foreach ($logs as $log) {
foreach ([
'conductivity' => 'conductivity',
'soil_humidity' => 'humidity',
'soil_temperature' => 'temperature',
'nitrogen_content' => 'n',
'potassium_content' => 'k',
'phosphorus_content' => 'p',
] as $key => $attribute) {
if (! is_array($log->data) || ! array_key_exists($key, $log->data)) {
continue;
}
$soilReport->{$attribute} = $log->data[$key];
}
$lastSoilReport = tap($soilReport)->save();
}
}
$startAt->addHour();
} while ($endAt->gte($startAt));
}
protected function createReportToLinkosMeteorologicalDevice(Device $device): void
{
$lastMeteorologicalReport = MeteorologicalReport::where('device_id', $device->id)
->latest('reported_at')
->first();
$lastReportedAt = $lastMeteorologicalReport?->reported_at
$lastReportedAt = MeteorologicalReport::where('device_id', $device->id)->latest('reported_at')->value('reported_at')
?: $device->logs()->oldest('reported_at')->value('reported_at');
if ($lastReportedAt === null) {
@ -159,51 +89,7 @@ class DeviceLogReportCommand extends Command
$endAt = $latestReportedAt->copy()->startOfHour();
do {
/** @var \Illuminate\Database\Eloquent\Collection */
$logs = $device->logs()
->whereBetween('reported_at', [$startAt, $startAt->copy()->endOfHour()])
->oldest('reported_at')
->get();
if ($logs->isNotEmpty()) {
$meteorologicalReport = MeteorologicalReport::firstOrCreate(
[
'device_id' => $device->id,
'reported_at' => $startAt,
],
Arr::except($lastMeteorologicalReport?->setHidden([])?->attributesToArray() ?: [], ['reported_at'])
);
/** @var \App\Models\DeviceLog */
foreach ($logs as $log) {
foreach ([
'current_rainfall' => 'today_rainfall',
'day_rainfall' => 'yesterday_rainfall',
'accumulate_rainfall' => 'accumulate_rainfall',
'moment_rainfall' => 'moment_rainfall',
'pm10_concentration' => 'pm10',
'pm25_concentration' => 'pm25',
'box_illumination' => 'box_illumination',
'box_pressure' => 'box_pressure',
'box_carbon' => 'box_co2',
'box_temperature' => 'box_temperature',
'box_humidity' => 'box_humidity',
'box_noise' => 'box_noise',
'wind_degree' => 'wind_degree',
'wind_direction' => 'wind_direction',
'wind_power' => 'wind_power',
'wind_speed' => 'wind_speed',
] as $key => $attribute) {
if (! is_array($log->data) || ! array_key_exists($key, $log->data)) {
continue;
}
$meteorologicalReport->{$attribute} = $log->data[$key];
}
$lastMeteorologicalReport = tap($meteorologicalReport)->save();
}
}
$this->deviceLogService->createReportToLinkosMeteorologicalDevice($device, $startAt->copy());
$startAt->addHour();
} while ($endAt->gte($startAt));
@ -211,11 +97,7 @@ class DeviceLogReportCommand extends Command
protected function createReportToLinkosWaterQualityDevice(Device $device): void
{
$lastWaterQualityReport = WaterQualityReport::where('device_id', $device->id)
->latest('reported_at')
->first();
$lastReportedAt = $lastWaterQualityReport?->reported_at
$lastReportedAt = WaterQualityReport::where('device_id', $device->id)->latest('reported_at')->value('reported_at')
?: $device->logs()->oldest('reported_at')->value('reported_at');
if ($lastReportedAt === null) {
@ -234,41 +116,7 @@ class DeviceLogReportCommand extends Command
$endAt = $latestReportedAt->copy()->startOfHour();
do {
/** @var \Illuminate\Database\Eloquent\Collection */
$logs = $device->logs()
->whereBetween('reported_at', [$startAt, $startAt->copy()->endOfHour()])
->oldest('reported_at')
->get();
if ($logs->isNotEmpty()) {
$waterQualityReport = WaterQualityReport::firstOrCreate(
[
'device_id' => $device->id,
'reported_at' => $startAt,
],
Arr::except($lastWaterQualityReport?->setHidden([])?->attributesToArray() ?: [], ['reported_at'])
);
/** @var \App\Models\DeviceLog */
foreach ($logs as $log) {
foreach ([
'chlorine' => 'chlorine',
'conductivity' => 'conductivity',
'oxygen' => 'oxygen',
'ph' => 'ph',
'temp' => 'temperature',
'turbidity' => 'turbidity',
] as $key => $attribute) {
if (! is_array($log->data) || ! array_key_exists($key, $log->data)) {
continue;
}
$waterQualityReport->{$attribute} = $log->data[$key];
}
$lastWaterQualityReport = tap($waterQualityReport)->save();
}
}
$this->deviceLogService->createReportToLinkosWaterQualityDevice($device, $startAt->copy());
$startAt->addHour();
} while ($endAt->gte($startAt));

389
app/Services/DeviceLogService.php
View File

@ -78,6 +78,150 @@ class DeviceLogService
} while ($countResults === $perPage);
}
/**
* 创建 linkos 气象设备报告
*/
public function createReportToLinkosMeteorologicalDevice(Device $device, Carbon $time)
{
$start = $time->copy()->startOfHour();
/** @var \Illuminate\Database\Eloquent\Collection */
$logs = $device->logs()
->whereBetween('reported_at', [$start, $start->copy()->endOfHour()])
->oldest('reported_at')
->get();
if ($logs->isEmpty()) {
return;
}
$attributes = [];
/** @var \App\Models\DeviceLog */
foreach ($logs as $log) {
if (! is_array($data = $log->data)) {
continue;
}
foreach ([
'current_rainfall' => 'today_rainfall',
'day_rainfall' => 'yesterday_rainfall',
'accumulate_rainfall' => 'accumulate_rainfall',
'moment_rainfall' => 'moment_rainfall',
'pm10_concentration' => 'pm10',
'pm25_concentration' => 'pm25',
'box_illumination' => 'box_illumination',
'box_pressure' => 'box_pressure',
'box_carbon' => 'box_co2',
'box_temperature' => 'box_temperature',
'box_humidity' => 'box_humidity',
'box_noise' => 'box_noise',
'wind_degree' => 'wind_degree',
'wind_direction' => 'wind_direction',
'wind_power' => 'wind_power',
'wind_speed' => 'wind_speed',
] as $k => $v) {
if (! array_key_exists($k, $data)) {
continue;
}
$attributes[$v] = $data[$k];
}
}
if (
$meteorologicalReport = MeteorologicalReport::where('device_id', $device->id)
->where('reported_at', $start)
->first()
) {
$meteorologicalReport->update($attributes);
} else {
if (
$lastMeteorologicalReport = MeteorologicalReport::where('device_id', $device->id)
->where('reported_at', $start->copy()->subHour())
->first()
) {
foreach ($attributes as $k => $v) {
if ($v === null) {
$attributes[$k] = $lastMeteorologicalReport->{$k};
}
}
}
MeteorologicalReport::create(array_merge($attributes, [
'device_id' => $device->id,
'reported_at' => $start,
]));
}
}
/**
* 创建 linkos 水质设备报告
*/
public function createReportToLinkosWaterQualityDevice(Device $device, Carbon $time)
{
$start = $time->copy()->startOfHour();
/** @var \Illuminate\Database\Eloquent\Collection */
$logs = $device->logs()
->whereBetween('reported_at', [$start, $start->copy()->endOfHour()])
->oldest('reported_at')
->get();
if ($logs->isEmpty()) {
return;
}
$attributes = [];
/** @var \App\Models\DeviceLog */
foreach ($logs as $log) {
if (! is_array($data = $log->data)) {
continue;
}
foreach ([
'chlorine' => 'chlorine',
'conductivity' => 'conductivity',
'oxygen' => 'oxygen',
'ph' => 'ph',
'temp' => 'temperature',
'turbidity' => 'turbidity',
] as $k => $v) {
if (! array_key_exists($k, $data)) {
continue;
}
$attributes[$v] = $data[$k];
}
}
if (
$waterQualityReport = WaterQualityReport::where('device_id', $device->id)
->where('reported_at', $start)
->first()
) {
$waterQualityReport->update($attributes);
} else {
if (
$lastWaterQualityReport = WaterQualityReport::where('device_id', $device->id)
->where('reported_at', $start->copy()->subHour())
->first()
) {
foreach ($attributes as $k => $v) {
if ($v === null) {
$attributes[$k] = $lastWaterQualityReport->{$k};
}
}
}
WaterQualityReport::create(array_merge($attributes, [
'device_id' => $device->id,
'reported_at' => $start,
]));
}
}
/**
* 创建 linkos 气象设备每日报告
*/
@ -93,116 +237,116 @@ class DeviceLogService
return;
}
$result = $meteorologicalReports->reduce(function (array $carry, MeteorologicalReport $meteorologicalReport) {
foreach ($carry as $key => $item) {
if (is_null($v = $meteorologicalReport->{$key})) {
continue;
}
$attributes = value(function ($meteorologicalReports) {
$data = [
'today_rainfall' => ['sum' => 0, 'count' => 0],
'yesterday_rainfall' => ['sum' => 0, 'count' => 0],
'accumulate_rainfall' => ['sum' => 0, 'count' => 0],
'moment_rainfall' => ['sum' => 0, 'count' => 0],
'pm10' => ['sum' => 0, 'count' => 0],
'pm25' => ['sum' => 0, 'count' => 0],
'box_illumination' => ['sum' => 0, 'count' => 0],
'box_pressure' => ['sum' => 0, 'count' => 0],
'box_co2' => ['sum' => 0, 'count' => 0],
'box_temperature' => ['sum' => 0, 'count' => 0],
'box_humidity' => ['sum' => 0, 'count' => 0],
'box_noise' => ['sum' => 0, 'count' => 0],
'wind_samples' => [],
];
foreach ($meteorologicalReports as $meteorologicalReport) {
foreach ($data as $k => $item) {
if ($k === 'wind_samples') {
if (is_null($meteorologicalReport->wind_degree) || is_null($meteorologicalReport->wind_speed)) {
continue;
}
$item[] = [
'wind_degree' => $meteorologicalReport->wind_degree, // 风向度数
'wind_speed' => $meteorologicalReport->wind_speed, // 风速
];
} elseif (! is_null($v = $meteorologicalReport->{$k})) {
$item['sum'] = bcadd($item['sum'], $v, 2);
$item['count']++;
}
$data[$k] = $item;
}
}
$attributes = [];
foreach ($data as $key => $item) {
switch ($key) {
case 'wind_samples':
if (! is_null($meteorologicalReport->wind_degree) && ! is_null($meteorologicalReport->wind_speed)) {
$item['wind_samples'][] = [
'wind_degree' => $meteorologicalReport->wind_degree, // 风向度数
'wind_speed' => $meteorologicalReport->wind_speed, // 风速
];
}
$attributes['wind_degree'] = value(function (array $windSamples) {
$x = 0;
$y = 0;
foreach ($windSamples as $sample) {
if ($sample['wind_degree'] == 0 && $sample['wind_speed'] == 0) {
continue;
}
// 角度转弧度
$radian = deg2rad($sample['wind_degree']);
// $x += $sample['wind_speed'] * sin($radian);
// $y += $sample['wind_speed'] * cos($radian);
$x += sin($radian);
$y += cos($radian);
}
$degree = round(rad2deg(atan2($y, $x)));
if (($x > 0 || $x < 0) && $y < 0) {
$degree += 180;
} elseif ($x < 0 && $y > 0) {
$degree += 360;
}
return $degree;
}, $item);
$attributes['wind_direction'] = value(function ($windDegree) {
if ($windDegree >= 22.5 && $windDegree < 67.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_NORTHEAST;
} elseif ($windDegree >= 67.5 && $windDegree < 112.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_EAST;
} elseif ($windDegree >= 112.5 && $windDegree < 157.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_SOUTHEAST;
} elseif ($windDegree >= 157.5 && $windDegree < 202.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_SOUTH;
} elseif ($windDegree >= 202.5 && $windDegree < 247.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_SOUTHWEST;
} elseif ($windDegree >= 247.5 && $windDegree < 292.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_WEST;
} elseif ($windDegree >= 292.5 && $windDegree < 337.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_NORTHWEST;
}
return MeteorologicalDailyReport::WIND_DIRECTION_NORTH;
}, $attributes['wind_degree']);
break;
default:
$item['sum'] = bcadd($item['sum'], $v, 2);
$item['count']++;
$attributes[$key] = $item['count'] > 0 ? round(bcdiv($item['sum'], $item['count'], 2), 2) : null;
break;
}
$carry[$key] = $item;
}
return $carry;
}, [
'today_rainfall' => ['sum' => 0, 'count' => 0],
'yesterday_rainfall' => ['sum' => 0, 'count' => 0],
'accumulate_rainfall' => ['sum' => 0, 'count' => 0],
'moment_rainfall' => ['sum' => 0, 'count' => 0],
'pm10' => ['sum' => 0, 'count' => 0],
'pm25' => ['sum' => 0, 'count' => 0],
'box_illumination' => ['sum' => 0, 'count' => 0],
'box_pressure' => ['sum' => 0, 'count' => 0],
'box_co2' => ['sum' => 0, 'count' => 0],
'box_temperature' => ['sum' => 0, 'count' => 0],
'box_humidity' => ['sum' => 0, 'count' => 0],
'box_noise' => ['sum' => 0, 'count' => 0],
'wind_samples' => [],
]);
return $attributes;
}, $meteorologicalReports);
/** @var \App\Models\MeteorologicalDailyReport */
$meteorologicalDailyReport = MeteorologicalDailyReport::firstOrCreate([
'device_id' => $device->id,
'reported_at' => $date,
]);
], $attributes);
foreach ($result as $key => $item) {
switch ($key) {
case 'wind_samples':
$meteorologicalDailyReport->wind_degree = value(function (array $windSamples) {
$x = 0;
$y = 0;
foreach ($windSamples as $sample) {
if ($sample['wind_degree'] == 0 && $sample['wind_speed'] == 0) {
continue;
}
// 角度转弧度
$radian = deg2rad($sample['wind_degree']);
// $x += $sample['wind_speed'] * sin($radian);
// $y += $sample['wind_speed'] * cos($radian);
$x += sin($radian);
$y += cos($radian);
}
$degree = round(rad2deg(atan2($y, $x)));
if (($x > 0 || $x < 0) && $y < 0) {
$degree += 180;
} elseif ($x < 0 && $y > 0) {
$degree += 360;
}
return $degree;
}, $item);
$meteorologicalDailyReport->wind_direction = value(function ($windDegree) {
if ($windDegree >= 22.5 && $windDegree < 67.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_NORTHEAST;
} elseif ($windDegree >= 67.5 && $windDegree < 112.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_EAST;
} elseif ($windDegree >= 112.5 && $windDegree < 157.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_SOUTHEAST;
} elseif ($windDegree >= 157.5 && $windDegree < 202.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_SOUTH;
} elseif ($windDegree >= 202.5 && $windDegree < 247.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_SOUTHWEST;
} elseif ($windDegree >= 247.5 && $windDegree < 292.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_WEST;
} elseif ($windDegree >= 292.5 && $windDegree < 337.5) {
return MeteorologicalDailyReport::WIND_DIRECTION_NORTHWEST;
}
return MeteorologicalDailyReport::WIND_DIRECTION_NORTH;
}, $meteorologicalDailyReport->wind_degree);
break;
default:
if ($item['count'] > 0) {
$meteorologicalDailyReport->{$key} = round(bcdiv($item['sum'], $item['count'], 2), 2);
}
break;
}
if (! $meteorologicalDailyReport->wasRecentlyCreated) {
$meteorologicalDailyReport->update($attributes);
}
$meteorologicalDailyReport->save();
}
/**
@ -220,39 +364,46 @@ class DeviceLogService
return;
}
$result = $waterQualityReports->reduce(function (array $carry, WaterQualityReport $waterQualityReport) {
foreach ($carry as $key => $item) {
if (is_null($v = $waterQualityReport->{$key})) {
continue;
$attributes = value(function ($waterQualityReports) {
$data = [
'chlorine' => ['sum' => 0, 'count' => 0],
'conductivity' => ['sum' => 0, 'count' => 0],
'oxygen' => ['sum' => 0, 'count' => 0],
'ph' => ['sum' => 0, 'count' => 0],
'temperature' => ['sum' => 0, 'count' => 0],
'turbidity' => ['sum' => 0, 'count' => 0],
];
foreach ($waterQualityReports as $waterQualityReport) {
foreach ($data as $k => $item) {
if (is_null($v = $waterQualityReport->{$k})) {
continue;
}
$item['sum'] = bcadd($item['sum'], $v, 2);
$item['count']++;
$data[$k] = $item;
}
$item['sum'] = bcadd($item['sum'], $v, 2);
$item['count']++;
$carry[$key] = $item;
}
return $carry;
}, [
'chlorine' => ['sum' => 0, 'count' => 0],
'conductivity' => ['sum' => 0, 'count' => 0],
'oxygen' => ['sum' => 0, 'count' => 0],
'ph' => ['sum' => 0, 'count' => 0],
'temperature' => ['sum' => 0, 'count' => 0],
'turbidity' => ['sum' => 0, 'count' => 0],
]);
$attributes = [];
foreach ($data as $key => $item) {
$attributes[$key] = $item['count'] > 0 ? round(bcdiv($item['sum'], $item['count'], 2), 2) : null;
}
return $attributes;
}, $waterQualityReports);
/** @var \App\Models\WaterQualityDailyReport */
$waterQualityDailyReport = WaterQualityDailyReport::firstOrCreate([
'device_id' => $device->id,
'reported_at' => $date->format('Y-m-d'),
]);
], $attributes);
foreach ($result as $key => $item) {
if ($item['count'] > 0) {
$waterQualityDailyReport->{$key} = round(bcdiv($item['sum'], $item['count'], 2), 2);
}
if (! $waterQualityDailyReport->wasRecentlyCreated) {
$waterQualityDailyReport->update($attributes);
}
$waterQualityDailyReport->save();
}
}