291 lines
9.7 KiB
PHP
291 lines
9.7 KiB
PHP
<?php
|
|
|
|
namespace App\Commands;
|
|
|
|
use Carbon\Carbon;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Support\Facades\Http;
|
|
use Illuminate\Http\Client;
|
|
|
|
class EcowittExportCommand extends Command
|
|
{
|
|
/** @var Carbon */
|
|
protected $startDate;
|
|
|
|
/** @var Carbon */
|
|
protected $endDate;
|
|
|
|
protected $ecowitt_account;
|
|
|
|
protected $ecowitt_passphrase;
|
|
|
|
/**
|
|
* The name and signature of the console command.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $signature = 'export {--debug} {--user=} {--pass=} {startDate} {endDate}';
|
|
|
|
/**
|
|
* The console command description.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $description = 'fetch all data from ecowitt';
|
|
|
|
protected $times = [];
|
|
|
|
/**
|
|
* Create a new command instance.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
}
|
|
|
|
/**
|
|
* Execute the console command.
|
|
*
|
|
* @return int
|
|
*/
|
|
public function handle()
|
|
{
|
|
$this->ecowitt_account = $this->option('user');
|
|
$this->ecowitt_passphrase = $this->option('pass');
|
|
|
|
if (empty($this->ecowitt_account) || empty($this->ecowitt_passphrase)) {
|
|
$this->error('Ecowitt Username or passphrase required!');
|
|
|
|
return 1;
|
|
}
|
|
|
|
$session_id = $this->getSessionId();
|
|
$device_ids = $this->getDeviceIds($session_id);
|
|
|
|
$this->startDate = Carbon::parse($this->argument('startDate'))->startOfDay();
|
|
|
|
$this->endDate = Carbon::parse($this->argument('endDate'))->endOfDay();
|
|
|
|
$device_ids->each(function ($deviceId) use ($session_id) {
|
|
$startDate = $this->startDate->clone();
|
|
$endDate = $this->endDate->clone();
|
|
// declare output variable
|
|
$outputData = [];
|
|
|
|
do {
|
|
$response = Http::withCookies(
|
|
[
|
|
'ousaite_session' => $session_id,
|
|
], 'www.ecowitt.net')
|
|
->asForm()
|
|
->post('https://webapi.www.ecowitt.net/index/get_data', [
|
|
'device_id' => $deviceId,
|
|
'is_list' => 0,
|
|
'mode' => 0,
|
|
'sdate' => $startDate->clone()->startOfDay()->format('Y-m-d H:i'),
|
|
'edate' => $startDate->clone()->endOfDay()->format('Y-m-d H:i'),
|
|
'page' => 1,
|
|
]);
|
|
|
|
$this->comment("fetching range: {$startDate->clone()->startOfDay()} - {$startDate->clone()->endOfDay()}");
|
|
|
|
$ecowitt = $response->json();
|
|
|
|
$this->times = data_get($ecowitt, 'times', []);
|
|
|
|
|
|
// Temperature in C
|
|
$this->debug('fetch outTemp');
|
|
$outdoorTemp = $this->getData($ecowitt, 'list.tempf.list.tempf');
|
|
|
|
// Feels Like in C
|
|
$this->debug('fetch outTempApp');
|
|
$outdoorTempApp = $this->getData($ecowitt, 'list.tempf.list.apparent_temp');
|
|
|
|
// Dew Point in C
|
|
$this->debug('fetch dewpoint');
|
|
$outdoorTempDew = $this->getData($ecowitt, 'list.tempf.list.drew_temp'); // yes ecowitt calls it drew_temp :)
|
|
|
|
// humidity in %
|
|
$this->debug('fetch outHumidity %');
|
|
$outdoorHumidity = $this->getData($ecowitt, 'list.humidity.list.humidity');
|
|
|
|
// temp indoor in C
|
|
$this->debug('fetch inTemp');
|
|
$indoorTemp = $this->getData($ecowitt, 'list.tempinf.list.tempinf');
|
|
|
|
// humidityin in %
|
|
$this->debug('fetch inHumidityin %');
|
|
$indoorHumidity = $this->getData($ecowitt, 'list.humidityin.list.humidityin');
|
|
|
|
// solar in lx -- Solar and UVI
|
|
$this->debug('fetch solar radiation');
|
|
$solarRadiation = $this->getData($ecowitt, 'list.so_uv.list.solarradiation');
|
|
|
|
// uv
|
|
$this->debug('fetch uv index');
|
|
$uvi = $this->getData($ecowitt, 'list.so_uv.list.uv');
|
|
|
|
//replace empty values with 0
|
|
foreach ($uvi as $key => $value) {
|
|
if (empty($value)) {
|
|
$uvi[$key] = '0';
|
|
}
|
|
}
|
|
|
|
// rainrate in mm/hr b
|
|
$this->debug('fetch rainratein');
|
|
$rainRateIn = $this->getData($ecowitt, 'list.rain.list.rainratein');
|
|
|
|
// daily rainrate total mm/hr
|
|
$this->debug('fetch dailyrainin');
|
|
$dailyRainIn = $this->getData($ecowitt, 'list.rain.list.dailyrainin');
|
|
|
|
// wind_speed in m/s
|
|
$this->debug('fetch windspeedmph (kmh)');
|
|
$windSpeed = $this->getData($ecowitt, 'list.wind.list.windspeedmph'); // this key is called mph but units in data struct is kmh :/
|
|
|
|
// windGust
|
|
$this->debug('fetch windgustmph (kmh)');
|
|
$windGust = $this->getData($ecowitt, 'list.wind.list.windgustmph'); // wind gust key called mph but units in data struct is kmh
|
|
|
|
// winddir in degree
|
|
$this->debug('fetch winddir');
|
|
$windDir = $this->getData($ecowitt, 'list.wind.list.winddir');
|
|
|
|
// pressure relative in hPa
|
|
$this->debug('fetch baromrelin');
|
|
$pressureRel = $this->getData($ecowitt, 'list.pressure.list.baromrelin');
|
|
|
|
// pressure absolute in hPa
|
|
$this->debug('fetch baromabsin');
|
|
$pressureAbs = $this->getData($ecowitt, 'list.pressure.list.baromabsin');
|
|
|
|
foreach ($outdoorTemp as $date => $temp) {
|
|
if (!$temp) {
|
|
$this->debug('Skipping a bogus index');
|
|
continue;
|
|
}
|
|
$this->debug('unpacking $temp: ' . $temp);
|
|
$tmp = [
|
|
'time' => $date, // %Y-%m-%d %H:%M:%S
|
|
|
|
'outTemp' => $temp, // degree
|
|
'outTempApp' => data_get($outdoorTempApp, $date), // degree
|
|
'dewpoint' => data_get($outdoorTempDew, $date), // degree
|
|
'outHumidity' => data_get($outdoorHumidity, $date), // percent
|
|
|
|
'inTemp' => data_get($indoorTemp, $date), // degree
|
|
'inHumidity' => data_get($indoorHumidity, $date), // percent
|
|
|
|
'radiation' => data_get($solarRadiation, $date), // lx
|
|
'uv' => data_get($uvi, $date),
|
|
|
|
'rain_rate' => data_get($rainRateIn, // mm
|
|
$date
|
|
),
|
|
'rain_daily' => data_get($dailyRainIn, $date), // mm
|
|
|
|
'wind_speed' => data_get($windSpeed, // m_per_second
|
|
$date
|
|
),
|
|
'windGust' => data_get($windGust, $date), // m_per_second
|
|
'windDir' => data_get($windDir, $date), // degree_compass
|
|
|
|
'pressure_abs' => data_get($pressureAbs, $date), // hPa
|
|
'pressure_rel' => data_get($pressureRel, $date),
|
|
];
|
|
$outputData[] = $tmp;
|
|
}
|
|
$startDate = $startDate->addDay()->startOfDay();
|
|
} while ($startDate->lte($endDate));
|
|
|
|
$outFile = getcwd()."/export_ecowitt_{$deviceId}.csv";
|
|
$this->export($outFile, $outputData);
|
|
$this->debug('exported to output file: ' . $outFile);
|
|
});
|
|
}
|
|
|
|
protected function getData($stack, $key)
|
|
{
|
|
return collect(data_get($stack, $key))
|
|
->mapWithKeys(function ($value, $idx) {
|
|
$dateTime = data_get($this->times, $idx);
|
|
|
|
return [$dateTime => $value ?: null];
|
|
});
|
|
}
|
|
|
|
/**
|
|
* simulate login to ecowitt.net and store session_id from cookie
|
|
*
|
|
* @return mixed
|
|
*/
|
|
protected function getSessionId()
|
|
{
|
|
$response = Http::asForm()->post('https://webapi.www.ecowitt.net/user/site/login', [
|
|
'account' => $this->ecowitt_account,
|
|
'password' => $this->ecowitt_passphrase,
|
|
'authorize' => '',
|
|
]);
|
|
|
|
$loginData = $response->json();
|
|
|
|
$cookies = $response->cookies();
|
|
|
|
return $cookies->getCookieByName('ousaite_session')->getValue();
|
|
}
|
|
|
|
/**
|
|
* fetch all available device IDs
|
|
*/
|
|
protected function getDeviceIds($session_id): \Illuminate\Support\Collection
|
|
{
|
|
$deviceResponse = Http::withCookies(
|
|
[
|
|
'ousaite_session' => $session_id,
|
|
], 'www.ecowitt.net')
|
|
->asForm()
|
|
->post('https://webapi.www.ecowitt.net/index/get_devices', [
|
|
'uid' => '',
|
|
'type' => 1,
|
|
]);
|
|
|
|
$devices = collect(data_get($deviceResponse->json(), 'device_list'));
|
|
|
|
return $devices->map(function ($device) {
|
|
return data_get($device, 'id');
|
|
});
|
|
}
|
|
|
|
/**
|
|
* Takes in a filename and an array associative data array and outputs a csv file
|
|
*/
|
|
protected function export(string $fileName, array $data)
|
|
{
|
|
if (isset($data['0'])) {
|
|
$fp = fopen($fileName, 'w+');
|
|
fwrite($fp, implode(',', array_keys($data['0']))."\n");
|
|
foreach ($data as $values) {
|
|
fwrite($fp, implode(',', $values)."\n");
|
|
}
|
|
fclose($fp);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @param mixed ...$args
|
|
*/
|
|
protected function debug(string $msg, ...$args)
|
|
{
|
|
if ($this->option('debug')) {
|
|
$this->info($msg);
|
|
if (! empty($args)) {
|
|
dump($args);
|
|
}
|
|
}
|
|
}
|
|
}
|