error("数据库管理插件只允许在开发环境下使用"); } if (!$this->auth->isSuperAdmin()) { $this->error(__('Access is allowed only to the super management group')); } $this->dbName = Config::get("database.database"); $this->view->assign("suffixList", $this->getSuffixList()); } /** * 字段首页 */ public function fields() { $name = $this->request->get('name'); $is_admin = (int) $this->request->get('is_admin'); $offset = $this->request->get("offset"); $limit = $this->request->get("limit"); if ($name == NULL) { $this->error(__('Parameter %s can not be empty', 'name')); } $ints = ["int", "tinyint", "smallint", "mediumint", "bigint", "float", "double", "decimal"]; if ($this->request->isAjax()) { $tableFields = Db::table("information_schema.COLUMNS")->field("*")->where(['TABLE_SCHEMA' => $this->dbName, 'TABLE_NAME' => $name])->select(); $list = []; foreach ($tableFields as $key => $tableField) { $list[$key]['id'] = $tableField['ORDINAL_POSITION']; $list[$key]['name'] = $tableField['COLUMN_NAME']; $list[$key]['type'] = $tableField['DATA_TYPE']; $list[$key]['length'] = $tableField['COLUMN_TYPE']; $list[$key]['default'] = $tableField['COLUMN_DEFAULT']; $list[$key]['primary_key'] = $tableField['COLUMN_KEY'] == 'PRI' ? 1 : 0; $list[$key]['index'] = $tableField['COLUMN_KEY'] == 'MUL' ? 1 : 0; $list[$key]['is_null'] = $tableField['IS_NULLABLE'] == 'YES' ? '否' : '是'; $list[$key]['unsigned'] = strpos($tableField['COLUMN_TYPE'], 'unsigned') !== false ? '是' : (in_array($tableField['DATA_TYPE'], $ints) ? '否' : '-'); $list[$key]['auto_increment'] = strpos($tableField['EXTRA'], 'auto_increment') !== false ? 1 : 0; $list[$key]['comment'] = $tableField['COLUMN_COMMENT']; $list[$key]['is_admin'] = $is_admin; } $result = array("total" => count($list), "rows" => array_slice($list, $offset, $limit)); return json($result); } $this->view->assign("name", $name); $this->view->assign("is_admin", $is_admin); return $this->view->fetch(); } /** * 快速建表 */ public function create() { $name = $this->request->get('name'); $is_admin = (int) $this->request->get('is_admin'); if ($name == NULL) { $this->error(__('Parameter %s can not be empty', 'name')); } if ($this->request->isPost()) { $params = $this->request->post("row/a"); if ($params) { $result = false; $sql = "ALTER TABLE `{$name}`"; $column_name = explode(',', $params['column_name']); foreach ($column_name as $column) { $sql .= $this->getCommonFields($column); } $sql = rtrim($sql, ','); Db::startTrans(); try { $result = Db::execute($sql); Db::commit(); } catch (\think\exception\PDOException $e) { Db::rollback(); $this->error($e->getMessage()); } catch (\think\Exception $e) { Db::rollback(); $this->error($e->getMessage()); } if ($result !== false) { $this->success(); } else { $this->error(__('No rows were inserted')); } } $this->error(__('Parameter %s can not be empty', '')); } $this->view->assign("name", $name); $this->view->assign("is_admin", $is_admin); return $this->view->fetch(); } /** * 添加字段 */ public function field_add() { if ($this->request->isPost()) { $name = $this->request->param('name'); $params = $this->request->post("row/a"); $column_name = $params['suffix'] == '无' ? $params['name'] : $params['name'] . $params['suffix']; if ($params) { $result = false; $sql = "ALTER TABLE `{$name}` ADD COLUMN `{$column_name}` "; Db::startTrans(); try { if (in_array($params['type'], ['enum', 'set'])) { $length_arr = json_decode($params['length'], true); $default_arr = []; foreach ($length_arr as $value) { $default_arr[] = $value['vo']; } $params['length'] = $default_arr; } $sql .= $this->getFieldSql($column_name, $params); $result = Db::execute($sql); Db::commit(); } catch (\think\exception\PDOException $e) { Db::rollback(); $this->error($e->getMessage()); } catch (\think\Exception $e) { Db::rollback(); $this->error($e->getMessage()); } if ($result !== false) { $this->success(); } else { $this->error(__('No rows were updated')); } } } return $this->view->fetch(); } /** * 修改字段 */ public function field_edit() { $table = $this->request->param("table"); if ($table == NULL) { $this->error(__('Parameter %s can not be empty', 'table')); } $field = $this->request->param("field"); if ($field == NULL) { $this->error(__('Parameter %s can not be empty', 'field')); } $properties = Db::query("SHOW FULL COLUMNS FROM `{$table}` WHERE Field = '{$field}'"); $type_arr = explode(" ", $properties[0]["Type"]); $type = strstr($type_arr[0], "(", true) !== false ? strstr($type_arr[0], "(", true) : $type_arr[0]; $length = preg_match('/\((.*?)\)/', $type_arr[0], $matches) ? $matches[1] : 0; $row['name'] = $properties[0]["Field"]; $row['type'] = $type; $row['collate'] = $properties[0]["Collation"]; if (in_array($type, ["enum", "set"])) { $length_arr = explode(",", $length); $length_res = []; foreach ($length_arr as $key => $value) { preg_match("/\'(.*?)\'/", $value, $matches); $length_res[$key]['vo'] = $matches[1]; } $length = json_encode($length_res); } $row['length'] = $length; $row['default'] = $properties[0]["Default"]; $row['is_null'] = $properties[0]["Null"]; $row['unsigned'] = in_array("unsigned", $type_arr) ? 1 : 0; $row['zerofill'] = in_array("zerofill", $type_arr) ? 1 : 0; $row['comment'] = $properties[0]["Comment"]; if ($this->request->isPost()) { $params = $this->request->post("row/a"); if ($params) { $result = false; $sql = "ALTER TABLE `{$table}` MODIFY COLUMN `{$field}` "; Db::startTrans(); try { if ($params['name'] !== $row['name']) { $sql = "ALTER TABLE `{$table}` CHANGE `{$row['name']}` `{$params['name']}`"; } if (in_array($params['type'], ['enum', 'set'])) { $length_arr = json_decode($params['length'], true); $default_arr = []; foreach ($length_arr as $value) { $default_arr[] = $value['vo']; } $params['length'] = $default_arr; } $sql .= $this->getFieldSql($params['name'], $params); // halt($sql); $result = Db::execute($sql); Db::commit(); } catch (\think\exception\PDOException $e) { Db::rollback(); $this->error($e->getMessage()); } catch (\think\Exception $e) { Db::rollback(); $this->error($e->getMessage()); } if ($result !== false) { $this->success(); } else { $this->error(__('No rows were updated')); } } $this->error(__('Parameter %s can not be empty', '')); } $ints = ["int", "tinyint", "smallint", "mediumint", "bigint", "float", "double", "decimal"]; $no_length = ['date', 'datetime', 'time', 'year', "mediumtext", "longtext", "text"]; $this->view->assign("row", $row); $this->view->assign("is_int", in_array($row['type'], $ints)); $this->view->assign("is_enum", in_array($row['type'], ['enum', 'set'])); $this->view->assign("is_length", in_array($row['type'], $no_length)); return $this->view->fetch(); } /** * 删除 */ public function field_del() { $table = $this->request->param("table"); if ($table == NULL) { $this->error(__('Parameter %s can not be empty', 'table')); } $field = $this->request->param("field"); if ($field == NULL) { $this->error(__('Parameter %s can not be empty', 'field')); } $result = false; Db::startTrans(); try { $sql = "ALTER TABLE `{$table}` DROP COLUMN `{$field}`;"; $result = Db::execute($sql); Db::commit(); } catch (\think\exception\PDOException $e) { Db::rollback(); $this->error($e->getMessage()); } catch (\think\Exception $e) { Db::rollback(); $this->error($e->getMessage()); } if ($result !== false) { $this->success(); } else { $this->error(__('No rows were deleted')); } } /** * 字段排序 */ public function field_drag() { $name = $this->request->get('name'); if ($name == NULL) { $this->error(__('Parameter %s can not be empty', 'name')); } $fields = Db::getTableFields($name); //排序的数组 $ids = $this->request->post("ids"); //拖动的记录ID $changeid = (int) $this->request->post("changeid"); $ids = explode(',', $ids); $position = array_search($changeid, $ids); switch ($position) { case 0: if ($ids[array_search($changeid, $ids) + 1] > 1) { $changeField = $fields[$changeid - 1]; $afterField = $fields[$ids[1] - 2]; $properties = $this->getProperties($name, $changeField); $sql = "ALTER TABLE `{$name}` MODIFY COLUMN `{$changeField}` {$properties} AFTER `{$afterField}`"; } else { $afterField = $fields[$changeid - 1]; $properties = $this->getProperties($name, $afterField); $sql = "ALTER TABLE `{$name}` MODIFY COLUMN `{$afterField}` {$properties} FIRST"; } break; default: $changeField = $fields[$changeid - 1]; $afterField = $fields[($ids[array_search($changeid, $ids) - 1] - 1)]; $properties = $this->getProperties($name, $changeField); $sql = "ALTER TABLE `{$name}` MODIFY COLUMN `{$changeField}` {$properties} AFTER `{$afterField}`"; } $result = false; Db::startTrans(); try { $result = Db::execute($sql); Db::commit(); } catch (\think\exception\PDOException $e) { Db::rollback(); $this->error($e->getMessage()); } catch (\think\Exception $e) { Db::rollback(); $this->error($e->getMessage()); } if ($result !== false) { $this->success(); } else { $this->error(__('No rows were updated')); } } /** * 查看 * @internal */ public function index() { $this->error('禁止访问'); } /** * 添加 * @internal */ public function add() { $this->error('禁止访问'); } /** * 编辑 * @param string $ids * @internal */ public function edit($ids = null) { $this->error('禁止访问'); } /** * 删除 * @param string $ids * @internal */ public function del($ids = null) { $this->error('禁止访问'); } /** * 批量更新 * @internal * @param string $ids * @return void */ public function multi($ids = null) { $this->error('禁止访问'); } /** * 字段选择 * @internal */ public function selectfields() { //当前页 $page = $this->request->request("pageNumber"); //分页大小 $pagesize = $this->request->request("pageSize"); $q_word = (array) $this->request->request("q_word/a"); $word = $q_word[0]; $custom = (array) $this->request->request("custom/a"); if ($custom && is_array($custom)) { $table = $custom['table']; } $fields = $this->getFields($table, ['id']); $commonFields = $this->getCommonFields(); $fieldLists = []; foreach ($commonFields as $commonField) { if (!in_array($commonField['column_name'], $fields)) { $fieldLists[] = $commonField; } } if (!empty($word)) { $res_arr = []; foreach ($fieldLists as $fieldList) { $res_arr[] = $fieldList['column_name'] . '-' . $fieldList['comment']; } $res_arr = array_filter($res_arr, function ($v) use ($word) { return stripos($v, $word) !== false; }); $res_arrs = array_values($res_arr); $fieldLists_arr = []; foreach ($res_arrs as $res) { $fieldLists_arr[] = [ 'column_name' => explode('-', $res)[0], 'comment' => explode('-', $res)[1] ]; } $fieldLists = $fieldLists_arr; } $result = array("total" => count($fieldLists), "list" => array_slice($fieldLists, ($page - 1) * $pagesize, $pagesize)); return json($result); } /** * 字段类型 * @internal */ public function getType() { //当前页 $page = $this->request->request("pageNumber"); //分页大小 $pagesize = $this->request->request("pageSize"); $q_word = (array) $this->request->request("q_word/a"); $word = $q_word ? $q_word[0] : ''; $custom = (array) $this->request->request("custom/a"); $keyValue = $this->request->request('keyValue'); if (!$keyValue) { $suffix = []; $type = []; if ($custom && is_array($custom)) { $suffix = $custom['suffix']; $suffixList = $this->getSuffixList($suffix); $type = !is_array($suffixList['type']) ? [$suffixList['type']] : $suffixList['type']; } $typeList = $this->getTypeList($type); $lists = []; foreach ($typeList as $v) { $lists[] = ['type' => $v]; } if (!empty($word)) { $res_arr = []; foreach ($lists as $list) { $res_arr[] = $list['type']; } $res_arr = array_filter($res_arr, function ($v) use ($word) { return stripos($v, $word) !== false; }); $res_arrs = array_values($res_arr); $lists_arr = []; foreach ($res_arrs as $res) { $lists_arr[] = [ 'type' => $res, ]; } $lists = $lists_arr; } } else { $lists[] = ['type' => $keyValue]; } $result = array("total" => count($lists), "rows" => array_slice($lists, ($page - 1) * $pagesize, $pagesize)); return json($result); } /** * 字段后缀 * @internal */ public function getSuffix() { $name = $this->request->request("name"); $suffix = $this->getSuffixList($name); return json($suffix); } /** * 读取后缀规则 * @return array */ protected function getSuffixList($suffix = '') { $suffixList = []; $suffixList['time'] = ["type" => ["bigint", "datetime"], "length" => 16, "default" => NULL, "comment" => '时间', "remark" => '识别为日期时间型数据,自动创建选择时间的组件']; $suffixList['image'] = ["type" => ["varchar"], "length" => 255, "default" => '', "comment" => '缩略图', "remark" => '识别为图片文件,自动生成可上传图片的组件,单图']; $suffixList['images'] = ["type" => ["varchar"], "length" => 1500, "default" => '', "comment" => '组图', "remark" => '识别为图片文件,自动生成可上传图片的组件,多图']; $suffixList['file'] = ["type" => ["varchar"], "length" => 100, "default" => '', "is_null" => 1, "comment" => '附件', "remark" => '识别为普通文件,自动生成可上传文件的组件,单文件']; $suffixList['files'] = ["type" => ["varchar"], "length" => 1000, "default" => '', "is_null" => 1, "comment" => '附件', "remark" => '识别为普通文件,自动生成可上传文件的组件,多文件']; $suffixList['avatar'] = ["type" => ["varchar"], "length" => 255, "default" => '', "is_null" => 1, "comment" => '头像', "remark" => '识别为头像,自动生成可上传图片的组件,单图']; $suffixList['avatars'] = ["type" => ["varchar"], "length" => 1500, "default" => '', "is_null" => 1, "comment" => '头像', "remark" => '识别为头像,自动生成可上传图片的组件,多图']; $suffixList['seconds'] = ["type" => ["int"], "length" => 10, "default" => NULL, "is_null" => 1, "comment" => '时长/分钟']; $suffixList['price'] = ["type" => ["decimal"], "length" => '10,2', "default" => '0.00', "is_null" => 1, 'unsigned' => 1, "comment" => '价格']; $suffixList['content'] = ["type" => ["text", "mediumtext", "longtext"], "is_null" => 1, "comment" => '内容', "remark" => '识别为内容,自动生成富文本编辑器(需安装富文本插件)']; $suffixList['_id'] = ["type" => ["int"], "length" => 10, "default" => 0, "is_null" => 1, "unsigned" => 1, "zerofill" => 0, "comment" => 'ID', "remark" => '识别为关联字段,自动生成可自动完成的文本框,单选']; $suffixList['_ids'] = ["type" => ["varchar"], "length" => 100, "default" => '', "comment" => 'ID集合', "remark" => '识别为关联字段,自动生成可自动完成的文本框,多选']; $suffixList['list'] = ["type" => ["enum", "set"], "is_null" => 1, "remark" => ['识别为列表字段,自动生成单选下拉列表', '识别为列表字段,自动生成多选下拉列表']]; $suffixList['data'] = ["type" => ["enum", "set"], "is_null" => 1, "remark" => ['识别为选项字段,自动生成单选框', '识别为选项字段,自动生成复选框']]; if (version_compare(config('fastadmin.version'), '1.3.0', '<')) { $suffixList['json'] = ["type" => ["varchar"], "length" => 255, "default" => '', "is_null" => 1, "comment" => '管理员ID', "remark" => '识别为键值组件,自动生成键值录入组件,仅支持1.2.0+']; $suffixList['switch'] = ["type" => ["tinyint"], "length" => 1, "default" => 0, "is_null" => 1, "comment" => '开关', "remark" => '识别为开关字段,自动生成开关组件,默认值1为开,0为关,仅支持FastAdmin 1.2.0+']; } else { $suffixList['range'] = ["type" => ["varchar"], "length" => 100, "default" => '', "is_null" => 1, "comment" => '区间', "remark" => '识别为时间区间组件,自动生成时间区间组件,仅支持FastAdmin 1.3.0+']; $suffixList['tag'] = ["type" => ["varchar"], "length" => 255, "default" => '', "is_null" => 1, "comment" => '标签', "remark" => '识别为Tagsinput,自动生成标签输入组件,仅支持FastAdmin 1.3.0+']; $suffixList['tags'] = ["type" => ["varchar"], "length" => 255, "default" => '', "is_null" => 1, "comment" => '标签组', "remark" => '识别为Tagsinput,自动生成标签输入组件,仅支持FastAdmin 1.3.0+']; } return empty($suffix) ? array_keys($suffixList) : $suffixList[$suffix]; } /** * 读取类型规则 * @return array */ protected function getTypeList($types = []) { $typeList = []; $sql = "SELECT DISTINCT DATA_TYPE FROM information_schema.COLUMNS"; $result = Db::query($sql); foreach ($result as $key => $value) { $typeList[$value['DATA_TYPE']] = $value['DATA_TYPE']; if (!empty($types) && !in_array($value['DATA_TYPE'], $types)) { unset($typeList[$value['DATA_TYPE']]); } } return $typeList; } public function getCommonFields($fields = '') { $fieldList = include ADDON_PATH . 'famysql' . DS . 'data' . DS . 'fields.php'; $fields = $fields == '' ? [] : explode(',', $fields); if (!empty($fields)) { $sql = ""; foreach ($fieldList as $field => $fieldInfo) { if (in_array($field, $fields)) { $sql .= " ADD COLUMN `{$field}`" . $this->getFieldSql($field, $fieldInfo); $sql .= ","; } } return $sql; } else { $fields = array_keys($fieldList); $result = []; foreach ($fields as $key => $field) { $result[$key] = [ "column_name" => $field, "comment" => isset($fieldList[$field]['comment']) ? $fieldList[$field]['comment'] : ucwords($field) ]; } return $result; } } /** * 获取表字段属性 */ protected function getProperties($table, $field) { $all = Db::query("SHOW FULL COLUMNS FROM `{$table}` WHERE Field = '{$field}'"); $str = ''; $str .= "{$all[0]['Type']}"; if ($all[0]['Collation'] != NULL) { $charset = substr($all[0]['Collation'], 0, strpos($all[0]['Collation'], '_')); $str .= " CHARACTER SET {$charset} COLLATE {$all[0]['Collation']}"; } if ($all[0]['Null'] == 'NO') $str .= ' NOT NULL'; if ($all[0]['Default'] === '') $str .= " DEFAULT ''"; if ($all[0]['Default'] != NULL && $all[0]['Default'] != '') $str .= " DEFAULT '{$all[0]['Default']}'"; if ($all[0]['Extra'] == 'auto_increment') $str .= ' AUTO_INCREMENT'; $str .= " Comment '{$all[0]['Comment']}'"; return $str; } protected function getFieldSql($field, $fieldInfo) { $sql = ""; if (isset($fieldInfo['type'])) { $sql .= " {$fieldInfo['type']}"; } if (!in_array($fieldInfo['type'], ["enum", "set"]) && isset($fieldInfo['length'])) { $sql .= "(" . $fieldInfo['length'] . ")"; } elseif (in_array($fieldInfo['type'], ["enum", "set"])) { $length = ""; foreach ($fieldInfo['length'] as $value) { $length .= "'{$value}',"; } $length = rtrim($length, ","); $sql .= "(" . $length . ")"; } if (isset($fieldInfo['unsigned']) && $fieldInfo['unsigned'] == 1) { $sql .= " UNSIGNED"; } if (isset($fieldInfo['zerofill']) && $fieldInfo['zerofill'] == 1) { $sql .= " ZEROFILL"; } if (isset($fieldInfo['is_null']) && $fieldInfo['is_null'] == 0) { $sql .= " NOT NULL"; } if (isset($fieldInfo['default'])) { if (in_array($fieldInfo['type'], ["int", "tinyint", "smallint", "mediumint", "bigint"])) { if ($fieldInfo['default'] == "") { $sql .= ""; } elseif ($fieldInfo['default'] == 0) { $sql .= " DEFAULT 0"; } else { $sql .= empty($fieldInfo['default']) ? "" : " DEFAULT {$fieldInfo['default']}"; } } elseif (in_array($fieldInfo['type'], ["float", "double", "decimal"])) { if ($fieldInfo['default'] == "") { $sql .= ""; } elseif ($fieldInfo['default'] == 0) { $sql .= " DEFAULT '0.00'"; } else { $sql .= empty($fieldInfo['default']) ? "" : " DEFAULT '{$fieldInfo['default']}'"; } } elseif (in_array($fieldInfo['type'], ["text", "longtext", "mediumtext"])) { $sql .= empty($fieldInfo['default']) ? "" : " DEFAULT '{$fieldInfo['default']}'"; } elseif (in_array($fieldInfo['type'], ["enum", "set"])) { $sql .= (empty($fieldInfo['default']) && $fieldInfo['default'] !== '0') ? "" : " DEFAULT '{$fieldInfo['default']}'"; } else { if ($fieldInfo['default'] === '0') { $sql .= " DEFAULT '0'"; } elseif (empty($fieldInfo['default'])) { } else { $sql .= " DEFAULT '{$fieldInfo['default']}'"; } } } $comment = isset($fieldInfo['comment']) ? $fieldInfo['comment'] : ucwords($field); $sql .= " COMMENT '{$comment}'"; return $sql; } protected function getFields($table, $excludeFields = []) { $fields = Db::getFields($table); $result = []; foreach ($fields as $field => $fieldInfo) { if (!in_array($field, $excludeFields)) { $result[] = $field; } } return $result; } }