Smart/smartEnergyView-backend
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Correction of the implementation of the methods referring to telemetry.

Browse Source
This commit is contained in:
Djonathan 2022-07-19 20:47:20 -03:00
parent 9494c1af3c
commit 4e1eda8e91
6 changed files with 137 additions and 107 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
app/Http/Controllers/TelemetryController.php
View File

@ -31,35 +31,10 @@ class TelemetryController extends Controller
}
}
public function powerFactor(Request $request)
{
try {
$response = $this->med5minContract->getPowerFactor($request->all());
return (new TelemetryResource($response))
->response()
->setStatusCode(Response::HTTP_OK);
} catch (\Exception $ex) {
return $this->errorResponse(false, $ex->getMessage(), Response::HTTP_INTERNAL_SERVER_ERROR);
}
}
public function demand(Request $request)
{
try {
$response = $this->med5minContract->getDemand($request->all());
return (new TelemetryResource($response))
->response()
->setStatusCode(Response::HTTP_OK);
} catch (\Exception $ex) {
return $this->errorResponse(false, $ex->getMessage(), Response::HTTP_INTERNAL_SERVER_ERROR);
}
}
public function discretization(Request $request)
{
try {
$response = $this->med5minContract->getDiscretization($request->all());
$response = $this->med5minContract->getDiscretization($request->all(), $request->getPathInfo());
return (new TelemetryResource($response))
->response()
->setStatusCode(Response::HTTP_OK);

13
app/Models/Med5min.php
View File

@ -8,6 +8,7 @@ use DateTimeInterface;
use Illuminate\Database\Eloquent\Factories\HasFactory;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Database\Eloquent\SoftDeletes;
use Illuminate\Database\Eloquent\Builder;
use OwenIt\Auditing\Contracts\Auditable as Auditing;
use OwenIt\Auditing\Auditable;
@ -43,4 +44,16 @@ class Med5min extends Model implements Auditing
{
return $date->format('d/m/Y H:i:s');
}
protected static function booted()
{
static::addGlobalScope('dados_cadastrais', function (Builder $builder){
$builder->join(
"dados_cadastrais",
"dados_cadastrais.codigo_scde",
"=",
"med_5min.ponto"
);
});
}
}

4
app/Models/Scopes/UserScope.php
View File

@ -13,8 +13,8 @@ class UserScope implements Scope
/**
* Apply the scope to a given Eloquent query builder.
*
* @param \Illuminate\Database\Eloquent\Builder $builder
* @param \Illuminate\Database\Eloquent\Model $model
* @param Builder $builder
* @param Model $model
* @return void
*/
public function apply(Builder $builder, Model $model)

14
app/Repositories/Med5min/Med5minContractInterface.php
View File

@ -8,13 +8,11 @@ use App\Repositories\ContractInterface;
interface Med5minContractInterface extends ContractInterface
{
public function getDiscretized5min($params);
public function getDiscretized15min($params);
public function getDiscretizedOneHour($params);
public function getDiscretizedOneDay($params);
public function getDiscretizedOneMonth($params);
public function getPowerFactor($params);
public function getDemand($params);
public function getDiscretization($params);
public function getDiscretized5min($params, bool $typeField);
public function getDiscretized15min($params, bool $typeField);
public function getDiscretizedOneHour($params, bool $typeField);
public function getDiscretizedOneDay($params, bool $typeField);
public function getDiscretizedOneMonth($params, bool $typeField);
public function getDiscretization($params, $path);
}

182
app/Repositories/Med5min/Med5minRepository.php
View File

@ -10,6 +10,7 @@ use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\Collection;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Str;
class Med5minRepository extends AbstractRepository implements Med5minContractInterface
@ -31,77 +32,33 @@ class Med5minRepository extends AbstractRepository implements Med5minContractInt
return $query;
}
public function getPowerFactor($params): Collection|array
{
$fields =
[
"med_5min.ponto",
"med_5min.dia_num",
DB::raw("SUM(med_5min.ativa_consumo) AS consumo"),
DB::raw("SUM(med_5min.reativa_consumo+med_5min.reativa_geracao) AS reativa"),
DB::raw("(SUM(med_5min.ativa_consumo)/(SUM(med_5min.ativa_consumo)^2 +SUM(med_5min.reativa_consumo+med_5min.reativa_geracao)^2))*1000 as FP"),
DB::raw("0.92 as F_ref")
];
$params = static::filterRow($params);
return $this->execute($fields, $params)
->groupBy(["med_5min.dia_num", "med_5min.ponto"])
->orderBy(DB::raw("med_5min.dia_num, med_5min.ponto"))
->distinct()
->get();
}
public function getDemand($params): Collection|array
{
$fields =
[
"med_5min.ponto",
"med_5min.dia_num",
DB::raw("TO_CHAR((date('1899-12-31') + interval '1' day * med_5min.dia_num), 'DD/MM/YYYY') as day_formatted"),
DB::raw("(med_5min.minuto/60) AS hora"),
DB::raw("SUM(med_5min.ativa_consumo) AS dem_reg"),
DB::raw("(CASE WHEN ((med_5min.minuto/60) >= 18 AND (med_5min.minuto/60) <= 21) THEN dados_cadastrais.demanda_p ELSE dados_cadastrais.demanda_fp END) as dem_cont")
];
$params = static::filterRow($params);
return $this->execute($fields, $params)
->join(
"dados_cadastrais",
"dados_cadastrais.codigo_scde",
"=",
"med_5min.ponto"
)
->groupBy(["med_5min.ponto", "med_5min.dia_num", "day_formatted", 'hora', 'dem_cont'])
->distinct()
->get();
}
public function getDiscretization($params)
public function getDiscretization($params, $path): Collection|array
{
if (empty($params['type'])) {
return abort(404, 'Error! The type field needs to be filled in.');
}
$typeField = collect($path)->map(function($item){
$value = Str::of($item)->explode('/')->offsetGet(3);
return $value === "powerFactor" ? true : ($value === "demand"? false : null);
})->first();
$type = $params['type'];
$params = static::filterRow($params);
return match ($type) {
'5_min' => $this->getDiscretized5min($params),
'15_min' => $this->getDiscretized15min($params),
'1_hora' => $this->getDiscretizedOneHour($params),
'1_dia' => $this->getDiscretizedOneDay($params),
'1_mes' => $this->getDiscretizedOneMonth($params)
'5_min' => $this->getDiscretized5min($params, $typeField),
'15_min' => $this->getDiscretized15min($params, $typeField),
'1_hora' => $this->getDiscretizedOneHour($params, $typeField),
'1_dia' => $this->getDiscretizedOneDay($params, $typeField),
'1_mes' => $this->getDiscretizedOneMonth($params, $typeField)
};
}
public function getDiscretized5min($params)
public function getDiscretized5min($params, bool $typeField = null): Collection|array
{
$fields =
[
'med_5min.ponto',
@ -113,14 +70,21 @@ class Med5minRepository extends AbstractRepository implements Med5minContractInt
DB::raw("SUM(med_5min.reativa_consumo+med_5min.reativa_geracao) AS reativa")
];
if (!is_null($typeField))
{
$fields = $this->typeField($fields, $typeField);
}
$groupBy = $this->groupField($typeField);
return $this->execute($fields, $params)
->groupBy(["med_5min.ponto", "med_5min.dia_num", "day_formatted", 'hora', 'minut'])
->groupBy($groupBy)
->distinct()
->get();
}
public function getDiscretized15min($params)
public function getDiscretized15min($params, $typeField = null)
{
$fields =
[
@ -133,13 +97,20 @@ class Med5minRepository extends AbstractRepository implements Med5minContractInt
DB::raw("SUM(med_5min.reativa_consumo+med_5min.reativa_geracao) AS reativa")
];
if (!is_null($typeField))
{
$fields = $this->typeField($fields, $typeField);
}
$groupBy = $this->groupField($typeField);
return $this->execute($fields, $params)
->groupBy(["med_5min.ponto", "med_5min.dia_num", "day_formatted", 'hora', 'minut'])
->groupBy($groupBy)
->distinct()
->get();
}
public function getDiscretizedOneHour($params)
public function getDiscretizedOneHour($params, $typeField = null, string $type = '1_hora'): Collection|array
{
$fields =
[
@ -149,15 +120,22 @@ class Med5minRepository extends AbstractRepository implements Med5minContractInt
DB::raw("(med_5min.minuto/60) AS hora"),
DB::raw("SUM(med_5min.ativa_consumo) AS consumo"),
DB::raw("SUM(med_5min.reativa_consumo+med_5min.reativa_geracao) AS reativa")
];;
];
if (!is_null($typeField))
{
$fields = $this->typeField($fields, $typeField);
}
$groupBy = $this->groupField($typeField, $type);
return $this->execute($fields, $params)
->groupBy(["med_5min.ponto", "med_5min.dia_num", "day_formatted", 'hora'])
->groupBy($groupBy)
->distinct()
->get();
}
public function getDiscretizedOneDay($params)
public function getDiscretizedOneDay($params, $typeField = null, string $type = '1_dia'): Collection|array
{
$fields =
[
@ -168,17 +146,25 @@ class Med5minRepository extends AbstractRepository implements Med5minContractInt
DB::raw("SUM(med_5min.reativa_consumo+med_5min.reativa_geracao) AS reativa")
];
if (!is_null($typeField))
{
$fields = $this->typeField($fields, $typeField);
}
$groupBy = $this->groupField($typeField, $type);
return $this->execute($fields, $params)
->groupBy(["med_5min.ponto", "med_5min.dia_num", "day_formatted"])
->groupBy($groupBy)
->distinct()
->get();
}
public function getDiscretizedOneMonth($params): Collection|array
public function getDiscretizedOneMonth($params, $typeField = null, string $type = '1_mes'): Collection|array
{
$fields =
[
'med_5min.ponto',
'med_5min.dia_num',
DB::raw("(
med_5min.dia_num::INTEGER - extract(day from (
(date('1899-12-30') + interval '1' day * med_5min.dia_num)
@ -193,14 +179,20 @@ class Med5minRepository extends AbstractRepository implements Med5minContractInt
)
))
) as dia_data"),
DB::raw("1 as hora"),
DB::raw("1 as minuto"),
DB::raw("TO_CHAR((date('1899-12-31') + interval '1' day * med_5min.dia_num), 'DD/MM/YYYY') as day_formatted"),
DB::raw("SUM(med_5min.ativa_consumo) As consumo"),
DB::raw("SUM(med_5min.reativa_consumo+med_5min.reativa_geracao) As reativa")
];
if (!is_null($typeField))
{
$fields = $this->typeField($fields, $typeField);
}
$groupBy = $this->groupField($typeField, $type);
return $this->execute($fields, $params)
->groupBy(["med_5min.dia_num", "med_5min.ponto"])
->groupBy($groupBy)
->orderBy(DB::raw("med_5min.dia_num, med_5min.ponto"))
->get();
@ -219,4 +211,56 @@ class Med5minRepository extends AbstractRepository implements Med5minContractInt
return $arr;
}
private function typeField(array $fields, bool $typeField): array
{
return collect($fields)->when($typeField, function ($collection, $value){
$field =
[
DB::raw("(SUM(med_5min.ativa_consumo)/(SUM(med_5min.ativa_consumo)^2 +SUM(med_5min.reativa_consumo+med_5min.reativa_geracao)^2))*1000 as FP"),
DB::raw("0.92 as F_ref")
];
return $collection->merge($field);
}, function ($collection, $value){
$field =
[
DB::raw("SUM(med_5min.ativa_consumo) AS dem_reg"),
DB::raw("(CASE WHEN ((med_5min.minuto/60) >= 18 AND (med_5min.minuto/60) <= 21) THEN dados_cadastrais.demanda_p ELSE dados_cadastrais.demanda_fp END) as dem_cont")
];
return $collection->merge($field);
})->all();
}
public function groupField($typeField, $type = null): array
{
$fields = ["med_5min.ponto", "med_5min.dia_num", "day_formatted", 'hora', 'minut'];
if ($type === '1_hora')
{
array_splice($fields, 4);
}
if ($type === '1_dia' || $type === '1_mes')
{
array_splice($fields, 3);
}
if ($typeField === false)
{
$item = ['dem_cont'];
return collect($fields)->merge($item)->all();
}
return $fields;
}
}

4
routes/api.php
View File

@ -67,8 +67,8 @@ Route::middleware(['auth:sanctum', 'ability:Client'])->group(function () {
Route::post('economy/estimates', [\App\Http\Controllers\EconomyController::class, 'captiveMonthlyEconomy']);
Route::post('economy/MWh', [\App\Http\Controllers\EconomyController::class, 'costMWhEconomy']);
Route::post('telemetry/powerFactor', [\App\Http\Controllers\TelemetryController::class, 'powerFactor']);
Route::post('telemetry/demand', [\App\Http\Controllers\TelemetryController::class, 'demand']);
Route::post('telemetry/powerFactor', [\App\Http\Controllers\TelemetryController::class, 'discretization']);
Route::post('telemetry/demand', [\App\Http\Controllers\TelemetryController::class, 'discretization']);
Route::post('telemetry/discretization', [\App\Http\Controllers\TelemetryController::class, 'discretization']);
Route::post('operation/summary', [\App\Http\Controllers\OperationSummaryController::class, 'operationSummary']); // Resumo Operações