YAO/YAO-portal
1
0
Fork 0
mirror of https://github.com/newnius/YAO-portal.git synced 2025-12-13 09:06:43 +00:00
Code Issues Releases Wiki Activity

update, add virtual cluster management

Browse Source
This commit is contained in:
Newnius
2019-07-30 15:49:09 +08:00
parent b7a13462fd
commit 3d7f919942
4 changed files with 177 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

118
cluster.logic.php Normal file
View File

@@ -0,0 +1,118 @@
<?php
require_once('predis/autoload.php');
require_once('util4p/util.php');
require_once('util4p/CRObject.class.php');
require_once('util4p/AccessController.class.php');
require_once('util4p/CRLogger.class.php');
require_once('Code.class.php');
require_once('config.inc.php');
require_once('init.inc.php');
function cluster_add(CRObject $cluster)
{
if (!AccessController::hasAccess(Session::get('role', 'visitor'), 'cluster.add')) {
$res['errno'] = Code::NO_PRIVILEGE;
return $res;
}
$spider = new Spider();
$data['group'] = json_encode($cluster);
$spider->doPost(YAO_SCHEDULER_ADDR . '?action=group_add', $data);
$msg = json_decode($spider->getBody(), true);
$res['errno'] = Code::SUCCESS;
if ($msg['code'] !== 0) {
$res['errno'] = Code::FAIL;
$res['msg'] = $msg['error'];
}
$log = new CRObject();
$log->set('scope', Session::get('uid'));
$log->set('tag', 'cluster.add');
$content = array('cluster' => $cluster, 'response' => $res['errno']);
$log->set('content', json_encode($content));
CRLogger::log($log);
return $res;
}
function cluster_remove(CRObject $cluster)
{
if (!AccessController::hasAccess(Session::get('role', 'visitor'), 'cluster.remove')) {
$res['errno'] = Code::NO_PRIVILEGE;
return $res;
}
// TODO: check owner
$spider = new Spider();
$data['group'] = json_encode($cluster);
$spider->doPost(YAO_SCHEDULER_ADDR . '?action=group_remove', $data);
$msg = json_decode($spider->getBody(), true);
$res['errno'] = Code::SUCCESS;
if ($msg['code'] !== 0) {
$res['errno'] = Code::FAIL;
$res['msg'] = $msg['error'];
}
$log = new CRObject();
$log->set('scope', Session::get('uid'));
$log->set('tag', 'cluster.remove');
$content = array('cluster' => $cluster, 'response' => $res['errno']);
$log->set('content', json_encode($content));
CRLogger::log($log);
return $res;
}
function cluster_update(CRObject $cluster)
{
if (!AccessController::hasAccess(Session::get('role', 'visitor'), 'cluster.update')) {
$res['errno'] = Code::NO_PRIVILEGE;
return $res;
}
//TODO: check owner
$spider = new Spider();
$data['group'] = json_encode($cluster);
$spider->doPost(YAO_SCHEDULER_ADDR . '?action=group_update', $data);
$msg = json_decode($spider->getBody(), true);
$res['errno'] = Code::SUCCESS;
if ($msg['code'] !== 0) {
$res['errno'] = Code::FAIL;
$res['msg'] = $msg['error'];
}
$log = new CRObject();
$log->set('scope', Session::get('uid'));
$log->set('tag', 'cluster.update');
$content = array('cluster' => $cluster, 'response' => $res['errno']);
$log->set('content', json_encode($content));
CRLogger::log($log);
return $res;
}
function cluster_list(CRObject $rule)
{
if (!AccessController::hasAccess(Session::get('role', 'visitor'), 'cluster.list')) {
$res['errno'] = Code::NO_PRIVILEGE;
return $res;
}
$spider = new Spider();
$spider->doGet(YAO_SCHEDULER_ADDR . '?action=group_list');
$msg = json_decode($spider->getBody(), true);
if ($msg['code'] !== 0) {
$res['errno'] = $msg['code'] !== null ? $msg['code'] : Code::UNKNOWN_ERROR;
$res['msg'] = $msg['error'];
return $res;
}
$res['clusters'] = $msg['groups'];
$res['errno'] = Code::SUCCESS;
return $res;
}