jiaoyukun/DiverseYouthNightSchool
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
DiverseYouthNightSchool/application/admin/controller/famysql/Field.php

710 lines
27 KiB
PHP
Raw Normal View History

提交项目基础代码
2024-11-04 10:49:10 +08:00
<?php
namespace app\admin\controller\famysql;
use app\common\controller\Backend;
use think\Db;
use think\Config;
/**
* 字段管理
*/
class Field extends Backend
{
protected $dbName = '';
protected $noNeedRight = ['selectfields', 'getType', 'getSuffix'];
public function _initialize()
{
parent::_initialize();
if (!config("app_debug")) {
$this->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;
}
1，课时管理（机构端和总后台端） 2，教师管理（机构端和总后台端） 3，课程生成虚拟参与者（机构端和总后台端） 4，课程扩展免费课程并实现机构端课程提交审核 5，设计授权机构用户逻辑表和站内信表
2024-11-14 18:40:04 +08:00
public function getCommonFields($fields = '')
提交项目基础代码
2024-11-04 10:49:10 +08:00
{
$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;
}
}
Reference in New Issue Copy Permalink