162 lines
3.9 KiB
PHP
162 lines
3.9 KiB
PHP
<?php
|
|
|
|
namespace App\Models;
|
|
|
|
use GeneaLabs\LaravelModelCaching\Traits\Cachable;
|
|
use GuzzleHttp\Exception\ConnectException;
|
|
use Illuminate\Foundation\Auth\User as Authenticatable;
|
|
use Illuminate\Http\Client\PendingRequest;
|
|
use Illuminate\Http\Client\Response;
|
|
use Illuminate\Support\Facades\Cache;
|
|
use Illuminate\Support\Facades\Http;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Illuminate\Support\Str;
|
|
use JetBrains\PhpStorm\ArrayShape;
|
|
|
|
class Module extends Authenticatable
|
|
{
|
|
use Cachable;
|
|
|
|
public $incrementing = false;
|
|
|
|
// primary key
|
|
public $timestamps = false;
|
|
protected $table = 'modules';
|
|
protected $keyType = 'string';
|
|
protected $fillable = [
|
|
'id',
|
|
'name',
|
|
'api_token'
|
|
];
|
|
|
|
protected $hidden = [
|
|
'api_token',
|
|
'url',
|
|
'wecom_key'
|
|
];
|
|
|
|
protected static function boot()
|
|
{
|
|
parent::boot();
|
|
static::creating(function ($model) {
|
|
// if local
|
|
if (!app()->environment('local')) {
|
|
$model->api_token = Str::random(60);
|
|
}
|
|
});
|
|
}
|
|
|
|
// public function moduleHostFunctions($host_id, $func, $requests): array
|
|
// {
|
|
// $http = Http::module($this->api_token, $this->url);
|
|
// $response = $http->post("hosts/{$host_id}/functions/" . $func, $requests);
|
|
//
|
|
// return $this->getResponse($response);
|
|
// }
|
|
|
|
|
|
// post, get, patch, delete 等请求
|
|
public function remote($func, $requests): array
|
|
{
|
|
$response = $this->http()->post('functions/' . $func, $requests);
|
|
|
|
return $this->getResponse($response);
|
|
}
|
|
|
|
public function http(): PendingRequest
|
|
{
|
|
return Http::module($this->api_token, $this->url)->acceptJson()->timeout(5);
|
|
}
|
|
|
|
private function getResponse(Response $response): array
|
|
{
|
|
$json = $response->json();
|
|
$status = $response->status();
|
|
|
|
$success = true;
|
|
|
|
// if status code is not 20x
|
|
if ($status < 200 || $status >= 300) {
|
|
$success = false;
|
|
}
|
|
|
|
return [
|
|
'body' => $response->body(),
|
|
'json' => $json,
|
|
'status' => $status,
|
|
'success' => $success,
|
|
];
|
|
}
|
|
|
|
public function request($method, $path, $requests): array
|
|
{
|
|
return $this->baseRequest($method, "functions/$path", $requests);
|
|
}
|
|
|
|
public function baseRequest($method, $path, $requests): array
|
|
{
|
|
$user = auth('sanctum')->user();
|
|
|
|
if ($user) {
|
|
$this->http()->withHeaders([
|
|
'X-User-id' => $user->id,
|
|
]);
|
|
$requests['user_id'] = $user->id;
|
|
if ($method == 'post') {
|
|
// add user to requests
|
|
$requests['user'] = $user;
|
|
}
|
|
}
|
|
|
|
$response = $this->http()->{$method}($path, $requests);
|
|
|
|
return $this->getResponse($response);
|
|
}
|
|
|
|
public function moduleRequest($method, $path, $requests): array
|
|
{
|
|
$module_id = auth('module')->id();
|
|
|
|
$http = $this->http()->withHeaders([
|
|
'X-Module' => $module_id
|
|
]);
|
|
|
|
$requests['module_id'] = $module_id;
|
|
|
|
$response = $http->{$method}("exports/$path", $requests);
|
|
|
|
return $this->getResponse($response);
|
|
}
|
|
|
|
public function check(): bool
|
|
{
|
|
// $module_id = null
|
|
// if ($module_id) {
|
|
// $module = Module::find($module_id);
|
|
// } else {
|
|
// $module = $this;
|
|
// }
|
|
|
|
$success = 0;
|
|
|
|
try {
|
|
$response = $this->http()->get('remote');
|
|
|
|
if ($response->status() == 200) {
|
|
$success = 1;
|
|
}
|
|
} catch (ConnectException $e) {
|
|
Log::error($e->getMessage());
|
|
}
|
|
|
|
return $success;
|
|
}
|
|
|
|
#[ArrayShape(['transactions' => "array"])]
|
|
public function calculate(): array
|
|
{
|
|
$cache_key = 'module_earning_' . $this->id;
|
|
return Cache::get($cache_key, []);
|
|
}
|
|
}
|