You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
436 lines
16 KiB
436 lines
16 KiB
<?php
|
|
|
|
namespace app\admin\controller;
|
|
|
|
use think\Db;
|
|
use think\Config;
|
|
use think\Request;
|
|
use app\common\controller\Backend;
|
|
use app\admin\library\buiapi\BuiApiFunc;
|
|
use app\admin\library\buiapi\BuiApiTemp;
|
|
use think\Exception;
|
|
use think\exception\PDOException;
|
|
use think\exception\ValidateException;
|
|
|
|
/**
|
|
* 模型管理管理
|
|
*/
|
|
class Buiapi extends Backend
|
|
{
|
|
|
|
/**
|
|
* ApiTable模型对象
|
|
*/
|
|
protected $model_table = null;
|
|
protected $model_field = null;
|
|
|
|
|
|
public function _initialize()
|
|
{
|
|
parent::_initialize();
|
|
$this->model_table = new \app\admin\model\BuiapiTable;
|
|
$this->model_field = new \app\admin\model\BuiapiField;
|
|
$actionname = strtolower($this->request->action());
|
|
if (in_array($actionname, ['execcommand']) && !config("app_debug")) {
|
|
$this->error("请先开启DEBUG调试模式");
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 01、数据库列表
|
|
*/
|
|
public function index()
|
|
{
|
|
$this->request->filter('trim,strip_tags,htmlspecialchars');
|
|
if ($this->request->isAjax()) {
|
|
if ($this->request->request('keyField')) {
|
|
return $this->selectpage();
|
|
}
|
|
list($where, $sort, $order, $offset, $limit) = $this->buildparams();
|
|
$total = $this->model_table->where($where)->order($sort, $order)->count();
|
|
$list = $this->model_table->where($where)->order($sort, $order)->limit($offset, $limit)->select();
|
|
$list = collection($list)->toArray();
|
|
$result = array("total" => $total, "rows" => $list);
|
|
return json($result);
|
|
}
|
|
return $this->view->fetch();
|
|
}
|
|
|
|
/**
|
|
* 02、同步数据库
|
|
*/
|
|
public function add()
|
|
{
|
|
if ($this->request->isPost()) {
|
|
$params = $this->request->post("row/a", [], 'trim');
|
|
if ($params) {
|
|
$params = $this->preExcludeFields($params);
|
|
|
|
//判断参数
|
|
if (empty($tables = $params['tables'])) {
|
|
$this->error("参数不能为空");
|
|
}
|
|
//处理数据
|
|
$params = BuiApiFunc::getTableFormatData($tables);
|
|
$fields = BuiApiFunc::getTableFieldFormatData($params);
|
|
$result = false;
|
|
Db::startTrans();
|
|
try {
|
|
$result = $this->model_table->insertAll($params);
|
|
$resultFields = $this->model_field->insertAll($fields);
|
|
Db::commit();
|
|
} catch (ValidateException $e) {
|
|
Db::rollback();
|
|
$this->error($e->getMessage());
|
|
} catch (PDOException $e) {
|
|
Db::rollback();
|
|
$this->error($e->getMessage());
|
|
} catch (Exception $e) {
|
|
Db::rollback();
|
|
$this->error($e->getMessage());
|
|
}
|
|
if ($result !== false && $resultFields !== false) {
|
|
$this->success();
|
|
} else {
|
|
$this->error(__('No rows were inserted'));
|
|
}
|
|
}
|
|
$this->error(__('Parameter %s can not be empty', ''));
|
|
}
|
|
$debar = [];
|
|
$field_list = collection($this->model_table->field(['table'])->select())->toArray();
|
|
if (!empty($field_list)) {
|
|
$debar = array_column($field_list, "table");
|
|
}
|
|
$this->view->assign('tableList', BuiApiFunc::getTableList($debar));
|
|
return $this->view->fetch();
|
|
}
|
|
|
|
/**
|
|
* 03、 删除数据库
|
|
*/
|
|
public function del($ids = "")
|
|
{
|
|
if ($ids) {
|
|
$pk = $this->model_table->getPk();
|
|
$adminIds = $this->getDataLimitAdminIds();
|
|
if (is_array($adminIds)) {
|
|
$this->model_table->where($this->dataLimitField, 'in', $adminIds);
|
|
}
|
|
$list = $this->model_table->where($pk, 'in', $ids)->select();
|
|
$count = 0;
|
|
Db::startTrans();
|
|
try {
|
|
foreach ($list as $k => $v) {
|
|
$this->model_field->where(['table' => trim($v['table'])])->delete();
|
|
$count += $v->delete();
|
|
}
|
|
Db::commit();
|
|
} catch (PDOException $e) {
|
|
Db::rollback();
|
|
$this->error($e->getMessage());
|
|
} catch (Exception $e) {
|
|
Db::rollback();
|
|
$this->error($e->getMessage());
|
|
}
|
|
if ($count) {
|
|
$this->success();
|
|
} else {
|
|
$this->error(__('No rows were deleted'));
|
|
}
|
|
}
|
|
$this->error(__('Parameter %s can not be empty', 'ids'));
|
|
}
|
|
|
|
/*
|
|
* 04、规则列表
|
|
*/
|
|
public function rulelist()
|
|
{
|
|
$table = trim($this->request->request('table'));
|
|
$list = $this->model_field->where("table", '=', $table)->where(['is_show' => 1])->order('id asc')->select();
|
|
if (!empty($list)) {
|
|
$list = collection($list)->toArray();
|
|
}
|
|
|
|
foreach ($list as $key => $data) {
|
|
list($list[$key]['tags'], $list[$key]['slist']) = [[], []];
|
|
$fieldType = (!empty($data['type'])) ? trim($data['type']) : 'none';
|
|
$fieldName = (!empty($data['field'])) ? trim($data['field']) : 'none';
|
|
$tableName = (isset($data['tables']['table']) && !empty($data['tables']['table'])) ? trim($data['tables']['table']) : 'none';
|
|
//处理 单选和多选
|
|
if (in_array($data['type'], ['enum', 'set'])) {
|
|
if (!empty($data['field_json'])) {
|
|
$list[$key]['slist'] = json_decode($data['field_json'], true);
|
|
}
|
|
}
|
|
//添加规则
|
|
if (!empty($data['rule_add'])) {
|
|
$rule_data = explode('|', $data['rule_add']);
|
|
foreach ($rule_data as $rk => $rv) {
|
|
$list[$key]["tags"][] = [
|
|
'tag' => sprintf("Add-%s", BuiApiFunc::$rules[$rv]),
|
|
'color' => 'bule',
|
|
'id' => $data['id'],
|
|
'type' => 'add',
|
|
'rule' => $rv
|
|
];
|
|
}
|
|
}
|
|
//添加规则
|
|
if (!empty($data['rule_edit'])) {
|
|
$rule_data = explode('|', $data['rule_edit']);
|
|
foreach ($rule_data as $rk => $rv) {
|
|
$list[$key]["tags"][] = [
|
|
'tag' => sprintf("Edit-%s", BuiApiFunc::$rules[$rv]),
|
|
'color' => 'red',
|
|
'id' => $data['id'],
|
|
'type' => 'edit',
|
|
'rule' => $rv
|
|
];
|
|
}
|
|
}
|
|
}
|
|
$this->view->assign("list", $list);
|
|
$this->view->assign("table", $table);
|
|
return $this->view->fetch();
|
|
}
|
|
|
|
/**
|
|
* 给表字段添加规则
|
|
*/
|
|
public function ruleadd($table = null)
|
|
{
|
|
if ($this->request->isPost()) {
|
|
$param = $this->request->request();
|
|
if (empty($param['rule_data'])) {
|
|
$this->error(__('规则数据不能为空'));
|
|
}
|
|
|
|
if (empty($param['field_id'])) {
|
|
$this->error(__('规则ID不能为空'));
|
|
}
|
|
if (empty($param['field_type'])) {
|
|
$this->error(__('规则类型不能为空'));
|
|
}
|
|
$fieldInfo = $this->model_field->get(['id' => intval($param['field_id'])]);
|
|
if (empty($fieldInfo)) {
|
|
$this->error(__('规则列表为空'));
|
|
}
|
|
if (!in_array($param['field_type'], ['add', 'edit'])) {
|
|
$this->error(__('规则类型错误'));
|
|
}
|
|
$field_key = sprintf("rule_%s", $param['field_type']);
|
|
$fieldResult = $fieldInfo->save(["{$field_key}" => implode('|', $param['rule_data'])]);
|
|
if (!empty($fieldResult)) {
|
|
$this->success(__('添加规则成功'));
|
|
}
|
|
$this->error(__('添加规则失败'));
|
|
}
|
|
if ($table == NULL) {
|
|
$table = trim($this->request->request('table'));
|
|
}
|
|
if (empty($table)) {
|
|
$this->error('参数不能为空');
|
|
}
|
|
$list = $this->model_field->where("table", '=', $table)->where(['is_show' => 1])->order('id asc')->select();
|
|
if (!empty($list)) {
|
|
$list = collection($list)->toArray();
|
|
}
|
|
if (empty($list)) {
|
|
$this->error('暂无字段列表，不能添加规则');
|
|
}
|
|
$this->view->assign("table_name", $table);
|
|
$this->view->assign("field_list", $list);
|
|
$this->view->assign("rule_list", BuiApiFunc::$rules);
|
|
return $this->view->fetch();
|
|
}
|
|
|
|
/**
|
|
* 规则删除
|
|
*/
|
|
public function rule_del(int $id = 0, $type = '', $rule = '')
|
|
{
|
|
list($rule_array, $update_value) = [[], ''];
|
|
$fieldInfo = $this->model_field->get(['id' => $id]);
|
|
if (empty($fieldInfo)) {
|
|
return json(['code' => 1, 'msg' => '规则列表为空']);
|
|
}
|
|
if ($type == 'add') {
|
|
$rule_data = explode('|', $fieldInfo['rule_add']);
|
|
}
|
|
|
|
if ($type == 'edit') {
|
|
$rule_data = explode('|', $fieldInfo['rule_edit']);
|
|
}
|
|
foreach ($rule_data as $rules) {
|
|
if ($rules == $rule) {
|
|
continue;
|
|
}
|
|
$rule_array[] = $rules;
|
|
}
|
|
if (!empty($rule_array)) {
|
|
$update_value = implode("|", $rule_array);
|
|
}
|
|
$field_key = sprintf("rule_%s", $type);
|
|
$fieldResult = $fieldInfo->save(["{$field_key}" => $update_value]);
|
|
if (!empty($fieldResult)) {
|
|
return json(['code' => 0, 'msg' => '删除规则成功']);
|
|
}
|
|
return json(['code' => 1, 'msg' => '删除规则失败']);
|
|
}
|
|
|
|
/**
|
|
* 隐藏字段
|
|
*/
|
|
public function field_hidden(int $id = 0)
|
|
{
|
|
$fieldModel = $this->model_field->get(['id' => intval($id)]);
|
|
if (empty($fieldModel)) {
|
|
return json(['code' => 1, 'msg' => '查询记录不存在']);
|
|
}
|
|
if (!empty($fieldModel->save(['is_show' => 0]))) {
|
|
return json(['code' => 0, 'msg' => '隐藏记录成功']);
|
|
}
|
|
return json(['code' => 1, 'msg' => '隐藏记录失败']);
|
|
}
|
|
|
|
/**
|
|
* 显示字段
|
|
*/
|
|
public function fieldview()
|
|
{
|
|
$type = $this->request->request('type', 'default');
|
|
if ($type == 'default') {
|
|
$table = trim($this->request->request('table'));
|
|
if (empty($table)) {
|
|
$this->error('参数不能为空');
|
|
}
|
|
$list = $this->model_field->field(['field', 'title', 'id'])->where("table", '=', $table)->where(['is_show' => 0])->order('id asc')->select();
|
|
$this->view->assign("table_name", $table);
|
|
$this->view->assign("field_list", $list);
|
|
return $this->view->fetch();
|
|
}
|
|
if ($type == 'save') {
|
|
$ids = $this->request->request('ids/a');
|
|
if (empty($ids)) {
|
|
$this->error('参数不能为空');
|
|
}
|
|
$list = $this->model_field->where('id', "in", $ids)->where(['is_show' => 0])->select();
|
|
$count = 0;
|
|
foreach ($list as $k => $v) {
|
|
$count += $v->isUpdate(true)->save(['is_show' => 1]);
|
|
}
|
|
if ($count) {
|
|
$this->success();
|
|
}
|
|
$this->error('显示记录失败');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 生成模版页面
|
|
*/
|
|
public function buildindex($table = null)
|
|
{
|
|
//$result = $this->model_table->get(['table'=>$table]);
|
|
//if(empty($result) || empty($result['name'])){
|
|
// $this->error('数据不存在');
|
|
//}
|
|
|
|
$loginList = ['vlogin' => '接口登录可访问', 'nlogin' => '无需登录可访问'];
|
|
$funList = ['index' => '列表(index)', 'add' => '创建(add)', 'edit' => '修改(edit)', 'view' => '详情(view)', 'del' => '删除(del)'];
|
|
|
|
$tableList = $this->model_table->field('table')->order('id asc')->select();
|
|
if (empty($tableList)) {
|
|
$this->error('数据不存在');
|
|
}
|
|
$tableList = collection($tableList)->toArray();
|
|
$tableList = array_column($tableList, 'table', 'table');
|
|
|
|
$this->view->assign("table", $table);
|
|
$this->view->assign("tableList", $tableList);
|
|
$this->view->assign("funList", $funList);
|
|
$this->view->assign("loginList", $loginList);
|
|
return $this->view->fetch();
|
|
}
|
|
|
|
/**
|
|
* 获取字段列表
|
|
*/
|
|
public function get_field_list()
|
|
{
|
|
$dbname = Config::get('database.database');
|
|
$prefix = Config::get('database.prefix');
|
|
$table = $this->request->request('table');
|
|
//从数据库中获取表字段信息
|
|
$sql = "SELECT * FROM `information_schema`.`columns` "
|
|
. "WHERE TABLE_SCHEMA = ? AND table_name = ? "
|
|
. "ORDER BY ORDINAL_POSITION";
|
|
//加载主表的列
|
|
$columnList = Db::query($sql, [$dbname, $prefix . $table]);
|
|
$fieldlist = [];
|
|
foreach ($columnList as $index => $item) {
|
|
$fieldlist[] = $item['COLUMN_NAME'];
|
|
}
|
|
$this->view->assign("table", $table);
|
|
$this->success("", null, ['fieldlist' => $fieldlist]);
|
|
}
|
|
|
|
/**
|
|
* 生成命令
|
|
*/
|
|
public function buildcommand()
|
|
{
|
|
$argv = [];
|
|
$params = $this->request->request('', '', 'trim,strip_tags');
|
|
if (empty($params['func'])) {
|
|
$this->error("生成的接口方法不能为空");
|
|
}
|
|
if (!in_array($params['login'], ['vlogin', 'nlogin'])) {
|
|
$this->error("验证登录接口方法不能为空");
|
|
}
|
|
$allowfields = ['table', 'controller', 'model', 'fields', 'force', 'local', 'delete', 'menu', 'searchfields'];
|
|
$allowfields = array_filter(array_intersect_key($params, array_flip($allowfields)));
|
|
if (isset($params['local']) && !$params['local']) {
|
|
$allowfields['local'] = $params['local'];
|
|
} else {
|
|
unset($allowfields['local']);
|
|
}
|
|
foreach ($allowfields as $key => $param) {
|
|
$argv[] = "--{$key}=" . (is_array($param) ? implode(',', $param) : $param);
|
|
}
|
|
$isrelation = (int)$this->request->request('isrelation');
|
|
if ($isrelation && isset($params['relation'])) {
|
|
foreach ($params['relation'] as $index => $relation) {
|
|
foreach ($relation as $key => $value) {
|
|
$argv[] = "--{$key}=" . (is_array($value) ? implode(',', $value) : $value);
|
|
}
|
|
}
|
|
}
|
|
$argv[] = sprintf("--func=%s", implode(",", $params['func']));
|
|
$vlogin = ($params['login'] == 'vlogin') ? 'yes' : 'not';
|
|
$argv[] = sprintf("--vlogin=%s", $vlogin);
|
|
$this->success("", null, ['command' => implode(' ', $argv)]);
|
|
}
|
|
|
|
/**
|
|
* 执行命令
|
|
*/
|
|
public function execcommand()
|
|
{
|
|
$commond_array = [];
|
|
$commond_string = $this->request->request('commond');
|
|
//判断字符串中是否有关联表
|
|
$commond_string = str_replace("--", "", $commond_string);
|
|
if (strpos($commond_string, 'relation=') !== false) {
|
|
$commond_string = str_replace("relation=", "^_^relation=", $commond_string);
|
|
$commond_array = explode("^_^", $commond_string);
|
|
} else {
|
|
$commond_array[0] = $commond_string;
|
|
}
|
|
$result = BuiApiTemp::handleTemplate($commond_array);
|
|
$this->success("", null, ['result' => $result['msg']]);
|
|
}
|
|
|
|
}
|
|
|