|
|
|
<?php
|
|
|
|
|
|
|
|
namespace App\Http\Logic\Aside\Devops;
|
|
|
|
|
|
|
|
|
|
|
|
use App\Enums\Common\Code;
|
|
|
|
use App\Exceptions\AsideGlobalException;
|
|
|
|
use App\Exceptions\BsideGlobalException;
|
|
|
|
use App\Http\Logic\Aside\BaseLogic;
|
|
|
|
use App\Models\Devops\ServerInformation;
|
|
|
|
use App\Models\Devops\ServerInformationLog;
|
|
|
|
use Illuminate\Database\Eloquent\Builder;
|
|
|
|
use Illuminate\Database\Eloquent\Collection;
|
|
|
|
use Illuminate\Database\Eloquent\Model;
|
|
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
|
|
|
|
class ServerInformationLogic extends BaseLogic
|
|
|
|
{
|
|
|
|
/**
|
|
|
|
* @var array
|
|
|
|
*/
|
|
|
|
private $param;
|
|
|
|
|
|
|
|
public function __construct()
|
|
|
|
{
|
|
|
|
parent::__construct();
|
|
|
|
|
|
|
|
$this->param = $this->requestAll;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 添加数据
|
|
|
|
* @return array
|
|
|
|
* @throws AsideGlobalException
|
|
|
|
* @throws BsideGlobalException
|
|
|
|
*/
|
|
|
|
public function create()
|
|
|
|
{
|
|
|
|
$request = $this->param ?? [];
|
|
|
|
$service = new ServerInformation();
|
|
|
|
$this->extracted($request, $service, $service->FieldsArray());
|
|
|
|
if ($this->checkIp($request['ip'])) {
|
|
|
|
return $this->fail('服务器信息添加失败,ip已存在');
|
|
|
|
}
|
|
|
|
DB::beginTransaction();
|
|
|
|
if ($service->save()) {
|
|
|
|
$original = $service->getOriginal();
|
|
|
|
$original['type'] = $request['type'];
|
|
|
|
$original['belong_to'] = $request['belong_to'];
|
|
|
|
// 添加日志
|
|
|
|
$this->server_action_log(ServerInformationLog::ACTION_ADD, $original, $original, '添加服务器信息成功 - ID : ' . $service->id);
|
|
|
|
DB::commit();
|
|
|
|
return $this->success();
|
|
|
|
}
|
|
|
|
DB::rollBack();
|
|
|
|
return $this->fail('服务器信息添加失败');
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 修改数据
|
|
|
|
* @return array
|
|
|
|
* @throws AsideGlobalException
|
|
|
|
* @throws BsideGlobalException
|
|
|
|
*/
|
|
|
|
public function update()
|
|
|
|
{
|
|
|
|
$service = $this->getService();
|
|
|
|
$fields_array = $service->FieldsArray();
|
|
|
|
$request = $this->param ?? [];
|
|
|
|
$original = $service->getOriginal();
|
|
|
|
$original['type'] = $service->ServiceStr($original['type']);
|
|
|
|
$original['belong_to'] = $service->BelongToStr($original['belong_to']);
|
|
|
|
$this->extracted($request, $service, $original);
|
|
|
|
// 检查ip是否存在
|
|
|
|
if ($service->ip != $request['ip']) {
|
|
|
|
if ($this->checkIp($request['ip'])) {
|
|
|
|
$this->fail('服务器信息修改失败,ip已存在', Code::USER_ERROR);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
DB::beginTransaction();
|
|
|
|
if ($service->save()) {
|
|
|
|
$revised = $service->getAttributes();
|
|
|
|
$diff = array_diff_assoc($original, $revised);
|
|
|
|
unset($diff['created_at']);
|
|
|
|
unset($diff['updated_at']);
|
|
|
|
unset($diff['deleted']);
|
|
|
|
$remarks = '';
|
|
|
|
if ($diff) {
|
|
|
|
$remarks .= '修改ID为 ' . $service->id . ' 的服务器信息,修改内容为:';
|
|
|
|
foreach ($diff as $key => $value) {
|
|
|
|
$remarks .= $fields_array[$key] . ' 由 ' . $value . ' 修改为 ' . $revised[$key] . '; ';
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
$remarks .= '修改ID为 ' . $service->id . ' 的服务器信息,无修改';
|
|
|
|
}
|
|
|
|
// 添加日志
|
|
|
|
$this->server_action_log(ServerInformationLog::ACTION_UPDATE, $original, $revised, $remarks);
|
|
|
|
DB::commit();
|
|
|
|
return $this->success();
|
|
|
|
}
|
|
|
|
DB::rollBack();
|
|
|
|
return $this->fail('服务器信息修改失败');
|
|
|
|
}
|
|
|
|
|
|
|
|
public function getService(int $deleted = ServerInformation::DELETED_NORMAL)
|
|
|
|
{
|
|
|
|
$id = $this->param['id'] ?? 0;
|
|
|
|
if (!$id) {
|
|
|
|
return $this->fail('ID不能为空');
|
|
|
|
}
|
|
|
|
$data = ServerInformation::query()->where('deleted', $deleted)->find($id);
|
|
|
|
if (!$data) {
|
|
|
|
return $this->fail('数据不存在！');
|
|
|
|
}
|
|
|
|
return $data;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 检查ip是否存在
|
|
|
|
* @param $ip
|
|
|
|
* @return bool
|
|
|
|
*/
|
|
|
|
public function checkIp($ip)
|
|
|
|
{
|
|
|
|
$usIp = ServerInformation::query()->where('ip', $ip)->first();
|
|
|
|
if ($usIp) {
|
|
|
|
return true;
|
|
|
|
} else {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 详情
|
|
|
|
* @param int $deleted
|
|
|
|
* @return array|Builder|Collection|Model
|
|
|
|
* @throws AsideGlobalException
|
|
|
|
* @throws BsideGlobalException
|
|
|
|
*/
|
|
|
|
public function serverInfo(int $deleted = ServerInformation::DELETED_NORMAL)
|
|
|
|
{
|
|
|
|
$id = $this->param['id'] ?? 0;
|
|
|
|
if (!$id) {
|
|
|
|
return $this->fail('ID不能为空');
|
|
|
|
}
|
|
|
|
$data = ServerInformation::query()->where('deleted', $deleted)->find($id, ['type', 'ip', 'title', 'belong_to', 'ports', 'created_at', 'updated_at']);
|
|
|
|
if (!$data) {
|
|
|
|
return $this->fail('数据不存在！');
|
|
|
|
}
|
|
|
|
return $data;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 服务器操作日志
|
|
|
|
* @param int $action 1:添加 2:修改 3:删除 4:搜索 5:详情 6:列表
|
|
|
|
* @param array $original 原始数据
|
|
|
|
* @param array $revised 修改后数据
|
|
|
|
*/
|
|
|
|
public function server_action_log(int $action = ServerInformationLog::ACTION_ADD, array $original = [], array $revised = [], $remarks = '')
|
|
|
|
{
|
|
|
|
$log = new ServerInformationLog();
|
|
|
|
$this->log($log, $action, $original, $revised, $remarks);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 提取数据
|
|
|
|
* @param array $request
|
|
|
|
* @param $service
|
|
|
|
* @param array $original
|
|
|
|
* @return void
|
|
|
|
*/
|
|
|
|
public function extracted(array $request, $service, array $original)
|
|
|
|
{
|
|
|
|
$request = array_intersect_key($request, $original);
|
|
|
|
foreach ($request as $key => $value) {
|
|
|
|
$service->$key = trim($value) ?? $original[$key];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 批量获取数据删除
|
|
|
|
* @return array
|
|
|
|
* @throws AsideGlobalException
|
|
|
|
* @throws BsideGlobalException
|
|
|
|
*/
|
|
|
|
public function get_batch_update($action = ServerInformationLog::ACTION_DELETE, $deleted = ServerInformation::DELETED_NORMAL)
|
|
|
|
{
|
|
|
|
$ids = $this->getIds();
|
|
|
|
$data = ServerInformation::query()->whereIn('id', $ids)->where('deleted', $deleted)->get();
|
|
|
|
$restore_ids = $data->pluck('id')->toArray();
|
|
|
|
$actionArr = ServerInformationLog::actionArr();
|
|
|
|
$actionStr = $actionArr[$action];
|
|
|
|
if (empty($restore_ids)) {
|
|
|
|
$this->fail($actionStr . '服务器信息不存在！', Code::USER_ERROR);
|
|
|
|
}
|
|
|
|
$original = $data->toArray();
|
|
|
|
DB::beginTransaction();
|
|
|
|
try {
|
|
|
|
$update = $deleted == ServerInformation::DELETED_NORMAL ? ServerInformation::DELETED_DELETE : ServerInformation::DELETED_NORMAL;
|
|
|
|
ServerInformation::query()->whereIn('id', $restore_ids)->update(['deleted' => $update]);
|
|
|
|
$this->server_action_log($action, $original, $original, $actionStr . '服务器信息 - ID : ' . implode(', ', $restore_ids));
|
|
|
|
DB::commit();
|
|
|
|
return $this->success();
|
|
|
|
} catch (\Exception $e) {
|
|
|
|
DB::rollBack();
|
|
|
|
return $this->fail('服务器信息' . $actionStr . '失败', Code::USER_ERROR);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 批量获取数据恢复
|
|
|
|
* @return array
|
|
|
|
* @throws AsideGlobalException
|
|
|
|
* @throws BsideGlobalException
|
|
|
|
*/
|
|
|
|
public function getIds()
|
|
|
|
{
|
|
|
|
$id = $this->param['id'] ?? 0;
|
|
|
|
if (!$id) {
|
|
|
|
return $this->fail('参数错误');
|
|
|
|
}
|
|
|
|
$ids = [];
|
|
|
|
if (!is_array($id)) {
|
|
|
|
$ids = explode(',', $id);
|
|
|
|
}
|
|
|
|
$ids = array_filter($ids, 'intval');
|
|
|
|
if (empty($ids)) {
|
|
|
|
return $this->fail('参数错误');
|
|
|
|
}
|
|
|
|
return $ids;
|
|
|
|
}
|
|
|
|
} |
