123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443 |
- <?php
- namespace app\admin\service\sys_manage;
- use app\common\Util;
- use app\model\SysField;
- use Illuminate\Database\Schema\Blueprint;
- use Illuminate\Support\Facades\Schema;
- use support\Db;
- use support\Request;
- class FieldService
- {
- /**
- * @Desc 字段列表
- * @Author Gorden
- * @Date 2024/2/22 14:49
- *
- * @param $page
- * @param $limit
- * @param $keywords
- * @return \support\Response
- */
- public static function fieldList(Request $request)
- {
- $page = $request->get('page', 1);
- $pageSize = $request->get('pageSize', 10);
- $fieldName = $request->get('field_name', '');
- $tableName = $request->get('table_name', '');
- $rows = SysField::select('*')
- ->when($fieldName != '', function ($query) use ($fieldName) {
- $query->where('field_name', 'like', '%' . $fieldName . '%');
- })
- ->when($tableName != '', function ($query) use ($tableName) {
- $query->where('field_table', 'like', '%' . $tableName . '%');
- })
- ->orderBy('field_addtimes', 'DESC')
- ->forPage($page, $pageSize)
- ->get()
- ->toArray();
- $total = SysField::when($fieldName != '', function ($query) use ($fieldName) {
- $query->where('field_name', 'like', '%' . $fieldName . '%');
- })->when($tableName != '', function ($query) use ($tableName) {
- $query->where('field_table', 'like', '%' . $tableName . '%');
- })->count();
- foreach ($rows as &$row){
- $row['field_refer_json'] = json_decode($row['field_refer_json']);
- }
- return json_success('', compact('rows', 'page', 'pageSize', 'total'));
- }
- /**
- * @Desc 字段详情
- * @Author Gorden
- * @Date 2024/2/22 14:55
- *
- * @param $id
- * @return \support\Response
- */
- public static function fieldInfo($id)
- {
- $field = SysField::where('field_id', $id)->first();
- if (!$field) {
- return json_fail('字段不存在');
- }
- return json_success('', $field->toArray());
- }
- /**
- * @Desc 新建字段
- * @Author Gorden
- * @Date 2024/2/22 14:31
- *
- * @param $params
- * @return \support\Response
- */
- public static function addField($params)
- {
- if (!empty($params['field_refer_json']['key'])){
- $params['field_refer_json']['val'] = $params['field_refer_json']['key'];
- }
- Db::beginTransaction();
- try {
- $data = [
- 'field_status' => $params['field_status'],
- 'field_category' => $params['field_category'],
- 'field_name' => $params['field_name'],
- 'field_table' => $params['field_table'],
- 'field_column_key' => $params['field_column_key'] ?? '',
- 'field_column_datatype' => $params['field_column_datatype'] ?? '',
- 'field_column_default' => $params['field_column_default'] ?? '',
- 'field_form_key' => $params['field_form_key'] ?? '',
- 'field_form_type' => $params['field_form_type'] ?? '',
- 'field_form_default' => $params['field_form_default'] ?? '',
- 'field_refer_json' => !empty($params['field_refer_json']) ? json_encode($params['field_refer_json']) : [],
- 'field_remark' => $params['field_remark'] ?? '',
- 'field_extend_json' => !empty($params['field_extend_json']) ? $params['field_extend_json'] : [],
- 'field_addtimes' => time()
- ];
- // 入库
- SysField::insert($data);
- // 字段设置
- $column = [
- 'type' => $params['field_column_datatype'],
- 'field' => $params['field_column_key'],
- 'primary_key' => false,
- 'nullable' => true,
- 'default' => $params['field_column_default'],
- 'auto_increment' => false,
- 'comment' => $params['field_name']
- ];
- $defaultLength = Util::fieldDefaultLength();
- if (isset($defaultLength[$column['type']])) {
- $column['length'] = $defaultLength[$column['type']];
- }
- // 写入字段
- Util::schema()->table($params['field_table'], function (Blueprint $table) use ($column) {
- self::createColumn($table, $column);
- });
- Db::commit();
- } catch (\Exception $e) {
- Db::rollBack();
- return json_fail('创建字段失败');
- }
- return json_success('创建字段成功');
- }
- /**
- * @Desc 修改字段
- * @Author Gorden
- * @Date 2024/2/22 14:40
- *
- * @param $id
- * @param $params
- * @return \support\Response
- */
- public static function updateField($id, $params)
- {
- Db::beginTransaction();
- try {
- $field = SysField::where('field_id', $id)->first();
- $data = [
- 'field_category' => $params['field_category'],
- 'field_name' => $params['field_name'],
- 'field_table' => $params['field_table'],
- 'field_column_key' => $params['field_column_key'],
- 'field_column_datatype' => $params['field_column_datatype'],
- 'field_column_default' => $params['field_column_default'],
- 'field_form_key' => $params['field_form_key'],
- 'field_form_type' => $params['field_form_type'],
- 'field_form_default' => $params['field_form_default'],
- 'field_refer_json' => !empty($params['field_refer_json']) ? $params['field_refer_json'] : [],
- 'field_remark' => $params['field_remark'],
- 'field_extend_json' => !empty($params['field_extend_json']) ? $params['field_extend_json'] : []
- ];
- // 更新
- SysField::where('field_id', $id)->update($data);
- // 字段设置
- $column = [
- 'type' => $params['field_column_datatype'],
- 'field' => $params['field_column_key'],
- 'old_field' => $field->field_column_key,
- 'primary_key' => false,
- 'nullable' => true,
- 'default' => $params['field_column_default'],
- 'auto_increment' => false,
- 'comment' => $params['field_name']
- ];
- // 设置字段长度
- $defaultLength = Util::fieldDefaultLength();
- if (isset($defaultLength[$column['type']])) {
- $column['length'] = $defaultLength[$column['type']];
- }
- // 表变动
- if ($field->field_table != $params['field_table']) {
- if (!empty($field->field_table)){
- // 删原表字段
- Util::db()->statement("ALTER TABLE " . getenv('DB_PREFIX') . $field->field_table . " DROP COLUMN `$field->field_column_key`");
- }
- // 在新表创建
- Util::schema()->table($params['field_table'], function (Blueprint $table) use ($column) {
- self::createColumn($table, $column);
- });
- } else {
- // 表没变,改就行
- self::modifyColumn(getenv('DB_PREFIX') . $params['field_table'], $column);
- }
- Db::commit();
- } catch (\Exception $e) {
- Db::rollBack();
- // dump($e->getTrace());
- return json_fail('修改字段失败');
- }
- return json_success('修改字段成功');
- }
- /**
- * @Desc 修改字段状态
- * @Author Gorden
- * @Date 2024/2/22 15:06
- *
- * @param $id
- * @param $params
- * @return \support\Response
- */
- public static function updateStatus($id, $params)
- {
- try {
- SysField::where('field_id', $id)->update(['field_status' => $params['field_status']]);
- } catch (\Exception $e) {
- return json_fail('字段状态修改失败');
- }
- return json_success('字段状态修改成功');
- }
- /**
- * @Desc 删除字段
- * @Author Gorden
- * @Date 2024/2/22 15:08
- *
- * @param $id
- * @return \support\Response
- */
- public static function delField($ids)
- {
- Db::beginTransaction();
- try {
- if (!is_array($ids)) {
- $ids = [$ids];
- }
- foreach ($ids as $id) {
- $field = SysField::where('field_id', $id)->first();
- // 删除表记录
- $field->delete();
- // 删除表字段
- Util::db()->statement("ALTER TABLE " . getenv('DB_PREFIX') . $field->field_table . " DROP COLUMN `$field->field_column_key`");
- }
- // 提交事务
- Db::commit();
- } catch (\Exception $e) {
- // 回滚
- Db::rollBack();
- return json_fail('字段删除失败');
- }
- return json_success('字段删除成功');
- }
- public static function checkTableExist($table)
- {
- try {
- $table = getenv('DB_PREFIX') . $table;
- $desc = (new SysField)->getConnection()->select("desc `$table`");
- if ($desc) {
- return true;
- }
- } catch (\Exception $e) {
- return false;
- }
- }
- /**
- * @Desc 验证表字段是否存在
- * @Author Gorden
- * @Date 2024/2/23 11:49
- *
- * @param $table
- * @param $field
- * @return bool
- */
- public static function checkFieldExist($table, $field)
- {
- return SysField::where('field_table', $table)
- ->where('field_column_key', $field)
- ->exists();
- }
- /**
- * 创建字段
- * @param $column
- * @param Blueprint $table
- * @return mixed
- * @throws \Exception
- */
- public static function createColumn(Blueprint $table, $column)
- {
- $method = $column['type'];
- $args = [$column['field']];
- $type_method_map = Util::methodControlMap();
- if (!isset($column['type'])) {
- throw new \Exception("请为{$column['field']}选择类型");
- }
- if (!isset($type_method_map[$column['type']])) {
- throw new \Exception("不支持的类型{$column['type']}");
- }
- if (stripos($method, 'int') !== false) {
- // auto_increment 会自动成为主键
- if ($column['auto_increment']) {
- $column['nullable'] = false;
- $column['default'] = null;
- $args[] = true;
- }
- } elseif (in_array($method, ['string', 'char']) || stripos($method, 'time') !== false) {
- if ($column['length']) {
- $args[] = $column['length'];
- }
- } elseif ($method === 'enum') {
- $args[] = array_map('trim', explode(',', $column['length']));
- } elseif (in_array($method, ['float', 'decimal', 'double'])) {
- if ($column['length']) {
- $args = array_merge($args, array_map('trim', explode(',', $column['length'])));
- }
- } else {
- $column['auto_increment'] = false;
- }
- $column_def = call_user_func_array([$table, $method], $args);
- if (!empty($column['comment'])) {
- $column_def = $column_def->comment($column['comment']);
- }
- if (!$column['auto_increment'] && $column['primary_key']) {
- $column_def = $column_def->primary(true);
- }
- if ($column['auto_increment'] && !$column['primary_key']) {
- $column_def = $column_def->primary(false);
- }
- $column_def = $column_def->nullable($column['nullable']);
- if ($column['primary_key']) {
- $column_def = $column_def->nullable(false);
- }
- if ($method != 'text' && $column['default'] !== null) {
- $column_def->default($column['default']);
- }
- return $column_def;
- }
- /**
- * 更改字段
- * @param $column
- * @param $table
- * @return mixed
- * @throws \Exception
- */
- protected static function modifyColumn($table, $column)
- {
- $method = $column['type'];
- $field = $column['field'];
- $old_field = $column['old_field'] ?? null;
- $nullable = $column['nullable'];
- $default = $column['default'] !== null ? Util::pdoQuote($column['default']) : null;
- $comment = Util::pdoQuote($column['comment']);
- $auto_increment = $column['auto_increment'];
- $length = (int)$column['length'];
- if ($column['primary_key']) {
- $default = null;
- }
- if ($old_field && $old_field !== $field) {
- $sql = "ALTER TABLE `$table` CHANGE COLUMN `$old_field` `$field` ";
- } else {
- $sql = "ALTER TABLE `$table` MODIFY `$field` ";
- }
- if (stripos($method, 'integer') !== false) {
- $type = str_ireplace('integer', 'int', $method);
- if (stripos($method, 'unsigned') !== false) {
- $type = str_ireplace('unsigned', '', $type);
- $sql .= "$type ";
- $sql .= 'unsigned ';
- } else {
- $sql .= "$type ";
- }
- if ($auto_increment) {
- $column['nullable'] = false;
- $column['default'] = null;
- $sql .= 'AUTO_INCREMENT ';
- }
- } else {
- switch ($method) {
- case 'string':
- $length = $length ?: 255;
- $sql .= "varchar($length) ";
- break;
- case 'char':
- case 'time':
- $sql .= $length ? "$method($length) " : "$method ";
- break;
- case 'enum':
- $args = array_map('trim', explode(',', (string)$column['length']));
- foreach ($args as $key => $value) {
- $args[$key] = Util::pdoQuote($value);
- }
- $sql .= 'enum(' . implode(',', $args) . ') ';
- break;
- case 'double':
- case 'float':
- case 'decimal':
- if (trim($column['length'])) {
- $args = array_map('intval', explode(',', $column['length']));
- $args[1] = $args[1] ?? $args[0];
- $sql .= "$method($args[0], $args[1]) ";
- break;
- }
- $sql .= "$method ";
- break;
- default :
- $sql .= "$method ";
- }
- }
- if (!$nullable) {
- $sql .= "NOT NULL ";
- }
- if ($method != 'text' && $default !== null) {
- $sql .= "DEFAULT $default ";
- }
- if ($comment !== null) {
- $sql .= "COMMENT $comment ";
- }
- echo "$sql\n";
- Util::db()->statement($sql);
- }
- }
|