96 lines
3.0 KiB
PHP
96 lines
3.0 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs\VirtualMachine\Sync;
|
|
|
|
use App\Http\Services\vCenter as ServiceVCenter;
|
|
use App\Models\ModuleDatacenter;
|
|
use App\Models\ModuleFolder;
|
|
use App\Models\vCenter;
|
|
use Illuminate\Bus\Queueable;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
|
use Illuminate\Queue\InteractsWithQueue;
|
|
use Illuminate\Queue\SerializesModels;
|
|
|
|
class SyncFolder implements ShouldQueue
|
|
{
|
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
|
|
|
protected $vCenter = null;
|
|
protected $data = null;
|
|
|
|
/**
|
|
* Create a new job instance.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function __construct()
|
|
{
|
|
$this->data = vCenter::select('id', 'host', 'user', 'password', 'token')->get();
|
|
$this->vCenter = new ServiceVCenter;
|
|
}
|
|
|
|
/**
|
|
* Execute the job.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function handle()
|
|
{
|
|
foreach ($this->data as $item) {
|
|
$this->vCenter->apiUri = $item->host;
|
|
|
|
if (!$item->token) {
|
|
$token = $this->vCenter->loginServer($item);
|
|
if ($token) {
|
|
vCenter::where('id', $item->id)->update(['token' => $token]);
|
|
$this->vCenter->token = $token;
|
|
}
|
|
}
|
|
$this->vCenter->token = $item->token;
|
|
|
|
if (!$this->vCenter->token) {
|
|
continue;
|
|
}
|
|
|
|
$dataCenter = ModuleDatacenter::where('vcenter_id', $item->id)->select('id', 'datacenter_id')->get();
|
|
foreach ($dataCenter as $_item) {
|
|
$folder = $this->vCenter->getAllFolder($_item['datacenter_id']);
|
|
|
|
if ($folder === "Login_Again") {
|
|
$token = $this->vCenter->loginServer($item);
|
|
if ($token) {
|
|
vCenter::where('id', $item->id)->update(['token' => $token]);
|
|
$this->vCenter->token = $token;
|
|
}
|
|
$folder = $this->vCenter->getAllFolder($_item['datacenter_id']);
|
|
}
|
|
|
|
if (!is_array($folder)) {
|
|
continue;
|
|
}
|
|
|
|
$syncedFolderIds = [];
|
|
foreach ($folder as $_subItem) {
|
|
$record = ModuleFolder::updateOrCreate(
|
|
['folder' => $_subItem['folder'], 'module_datacenter_id' => $_item['id']],
|
|
['name' => $_subItem['name'], 'type' => $_subItem['type']]
|
|
);
|
|
$syncedFolderIds[] = $record->id;
|
|
}
|
|
|
|
// Remove stale folders no longer in vCenter
|
|
ModuleFolder::where('module_datacenter_id', $_item['id'])
|
|
->whereNotIn('id', $syncedFolderIds)
|
|
->delete();
|
|
}
|
|
|
|
}
|
|
// Notify success via Telegram
|
|
(new \App\Http\Services\Telegram())->SendJobRunInfo('SyncFolder', 'Success', [
|
|
'message' => 'Sync folder completed successfully',
|
|
'synced_vcenters' => $this->data->count(),
|
|
]);
|
|
}
|
|
}
|