collector_producer/app/JsonRpc/FormService.php

<?php
namespace App\JsonRpc;


use Hyperf\RpcServer\Annotation\RpcService;
use App\Tools\Result;
use App\Model\GlobalTable;
use Hyperf\DbConnection\Db;
use App\Model\GlobalTableField;
use App\Model\GlobalTableFieldType;

#[RpcService(name: "FormService", protocol: "jsonrpc-http", server: "jsonrpc-http")]
class FormService implements FormServiceInterface
{

    /**
     * 添加全局表单
     * @param array $data
     * @return array|mixed
     */
    public function addGlobalTable(array $data): array
    {
        // 过滤掉空值
        $data = array_filter($data, function($value) {
            return !empty($value);
        });
        // 检查是否已存在相同名称的记录
        $globalTable = GlobalTable::on('global')->where(['table'=> $data['table'],'website_id'=>$data['website_id']])->first();
        if (empty($globalTable)) {
            $id = GlobalTable::on('global')->insertGetId($data);
            //给global库创建表 表名为$data['table'] 的值，并初始化一个字段id，类型为int，自增，主键，再初始化一个字段title,类型为varchar，长度为255
            Db::connection('global')->statement("CREATE TABLE IF NOT EXISTS `{$data['table']}` (
                `id` int(11) NOT NULL AUTO_INCREMENT,
                `title` varchar(255) DEFAULT NULL,
                PRIMARY KEY (`id`)
            )");
            //给GlobalTableField表初始化一条数据，表table_id为$id，field_name为title字符串，title为标题，field_type为varchar，length为255，is_required为1，is_unique为0，is_primary为0，is_index为0，is_foreign为0，is_auto_increment为1，is_default为0，default_value为'',description为'',website_id为$data['website_id']
            GlobalTableField::on('global')->insert([
                    'table_id' => $id,
                    'field_name' => 'title',
                    'title' => '标题',
                    'field_type' => '1',
                    'length' => 255,
                    'sort' => 0,
                    'is_check' => 1,
                    'admin_display' => 1,
                    'home_display' => 1,
                    'disable_del' => 1,
                ]);
 
            return Result::success('添加成功');
        }
        return Result::error('表单已存在');
    }
    /**
     * 获取全局表单列表
     * @param array $data
     * @return array
     */
    public function getGlobalTableList(array $data): array
    {
        try {
            // 构建查询
            $query = GlobalTable::query()
                ->when(!empty($data['website_id']), function($q) use ($data) {
                    return $q->where('website_id', $data['website_id']);
                })
                ->when(!empty($data['name']), function($q) use ($data) {
                    return $q->where('name', 'like', '%' . $data['name'] . '%');
                });
            
            // 分页参数
            $page = (int)($data['page'] ?? 1);
            $pageSize = (int)($data['pageSize'] ?? 10);
            
            // 先获取总数
            $total = $query->count();
            
            // 获取数据
            $list = $query->orderBy('updated_at', 'desc')
                         ->offset(($page - 1) * $pageSize)
                         ->limit($pageSize)
                         ->get();
            
            // 如果没有数据，直接返回空结果
            if ($list->isEmpty()) {
                return Result::success([
                    'list' => [],
                    'total' => $total,
                    'page' => $page,
                    'pageSize' => $pageSize
                ]);
            }
            
            // 获取并合并 website 数据
            $websites = Db::connection('secondary')
                ->table('website')
                ->whereIn('id', $list->pluck('website_id'))
                ->pluck('website_name', 'id');
            
            // 合并数据并返回
            return Result::success([
                'list' => $list->map(function($item) use ($websites) {
                    $item->website_name = $websites[$item->website_id] ?? '';
                    return $item;
                }),
                'total' => $total,
                'page' => $page,
                'pageSize' => $pageSize
            ]);
            
        } catch (\Throwable $e) {
            return Result::error('查询失败：' . $e->getMessage());
        }
    }
    /**
     * 获取全局表单
     * @param array $data
     * @return array
     */
    public function getGlobalTable(array $data): array
    {
        $globalTable = GlobalTable::where('id',$data['id'])->first();
        return Result::success($globalTable);
    }
    /**
     * 修改全局表单
     * @param array $data
     * @return array
     */
    public function upGlobalTable(array $data): array   
    {
        $globalTable = GlobalTable::where('id',$data['id'])->first();
        if(empty($globalTable)){
            return Result::error('表单不存在');
        }   
        $data = array_filter($data,function($value){
            return !empty($value);
        });
        GlobalTable::where(['id'=>$data['id']])->update($data);
        return Result::success('修改成功');
    }   
    /**
     * 删除全局表单
     * @param array $data
     * @return array
     */
    public function delGlobalTable(array $data): array          
    {
        $globalTable = GlobalTable::where('id', $data['id'])->first();
        if(empty($globalTable)){
            return Result::error('表单不存在');
        }
        //删除global库的表
        Db::connection('global')->statement("DROP TABLE IF EXISTS `{$globalTable->table}`");
        //删除GlobalTableField表中table_id为$data['id']的数据
        GlobalTableField::where('table_id', $data['id'])->delete();
        GlobalTable::where('id', $data['id'])->delete();
        return Result::success('删除成功');
    }
    /**
     * 获取表单字段列表
     * @param array $data
     * @return array
     */
    public function getGlobalTableFieldList(array $data): array
    {
        $globalTableField = GlobalTableField::where('table_id',$data['id'])->orderBy("sort","asc")->get();
        return Result::success($globalTableField);
    }
    /**
     * 获取表单字段
     * @param array $data
     * @return array    
     */
    public function getGlobalTableField(array $data): array
    {
        $globalTableField = GlobalTableField::where('id',$data['id'])->first();
        return Result::success($globalTableField);
    }
    /**
     * 添加表单字段
     * @param array $data
     * @return array
     * @throws \Throwable
     */
    public function addGlobalTableField(array $data): array
    {
        $globalTable = GlobalTable::where('id',$data['table_id'])->first(); 
        if(empty($globalTable)){
            return Result::error('表单不存在');     
        }
        //检查是否已存在相同名称的记录
        $globalTableField = GlobalTableField::where(['table_id'=>$data['table_id'],'field_name'=>$data['field_name']])->first();    
        if(!empty($globalTableField)){
            return Result::error('字段已存在');
        }

        // 检查表中是否已存在该列
        try {
            $columns = Db::connection('global')->select("SHOW COLUMNS FROM `{$globalTable->table}`");
            $columnNames = array_column($columns, 'Field');
            if (in_array($data['field_name'], $columnNames)) {
                return Result::error('字段名已存在于数据表中');
            }
        } catch (\Throwable $e) {
            return Result::error('检查字段是否存在时出错：' . $e->getMessage());
        }

        $globalTableFieldTypeInfo = GlobalTableFieldType::where('id',$data['field_type'])->first();
        //给global库的表添加字段
        Db::connection('global')->statement("ALTER TABLE `{$globalTable->table}` ADD COLUMN `{$data['field_name']}` {$globalTableFieldTypeInfo['field_type']}({$data['length']}) COMMENT '{$data['title']}'"); 
        //给GlobalTableField表添加数据
        GlobalTableField::create($data);
        return Result::success('添加成功');
    }
    /**
     * 修改表单字段
     * @param array $data
     * @return array
     * @throws \Throwable
     */
    public function upGlobalTableField(array $data): array
    {
        $globalTable = GlobalTable::where('id',$data['table_id'])->first(); 
        if(empty($globalTable)){
            return Result::error('表单不存在');
        }
        //检查是否已存在相同名称的记录
        $globalTableField = GlobalTableField::where(['table_id'=>$data['table_id'],'field_name'=>$data['field_name']])->first();
        if(!empty($globalTableField) && $globalTableField->id != $data['id']){
            return Result::error('字段已存在');
        }
        $globalTableFieldTypeInfo = GlobalTableFieldType::where('id',$data['field_type'])->first();
        //给global库的表修改字段
        Db::connection('global')->statement("ALTER TABLE `{$globalTable->table}` CHANGE COLUMN `{$data['field_name']}` `{$data['field_name']}` {$globalTableFieldTypeInfo['field_type']}({$data['length']}) COMMENT '{$data['title']}'"); 
        //给GlobalTableField表修改数据
        GlobalTableField::where('id',$data['id'])->update($data);
        return Result::success('修改成功');
    }
    /**
     * 删除表单字段
     * @param array $data
     * @return array
     * @throws \Throwable
     */
    public function delGlobalTableField(array $data): array
    {
        $tableFieldInfo = GlobalTableField::where('id',$data['id'])->first(); 
        if(empty($tableFieldInfo)){
            return Result::error('字段不存在');
        }
        $globalTable = GlobalTable::where('id',$tableFieldInfo['table_id'])->first(); 
        if(empty($globalTable)){
            return Result::error('表单不存在');
        }
        //给global库的表删除字段
        Db::connection('global')->statement("ALTER TABLE `{$globalTable->table}` DROP COLUMN `{$tableFieldInfo['field_name']}`"); 
        //给GlobalTableField表删除数据
        GlobalTableField::where('id',$data['id'])->delete();
        return Result::success('删除成功');
    }
    /**
     * 获取自定义生成表里面的数据
     */
    public function getCustomTableData(array $data): array
    {
        $globalTable = GlobalTable::where('id',$data['table_id'])->first();
        if(empty($globalTable)){
            return Result::error('表单不存在');
        }
        //根据返回的table名称，查询这个表的数据
        $data = Db::connection('global')->table($globalTable->table)->get();
        return Result::success($data);
    }
}