From b363957b52d25b20213c2c3474b0b8d540c84a92 Mon Sep 17 00:00:00 2001 From: zhaoxiang <756958008@qq.com> Date: Tue, 13 Oct 2020 00:10:56 +0800 Subject: [PATCH] =?UTF-8?q?modified=20=E5=AE=8C=E6=88=90=E5=AD=97=E6=AE=B5?= =?UTF-8?q?=E5=8A=9F=E8=83=BD=E7=A7=BB=E6=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/controller/admin/Fields.php | 284 ++++++++++++++++++++++++++++++++ 1 file changed, 284 insertions(+) create mode 100644 app/controller/admin/Fields.php diff --git a/app/controller/admin/Fields.php b/app/controller/admin/Fields.php new file mode 100644 index 0000000..78f8117 --- /dev/null +++ b/app/controller/admin/Fields.php @@ -0,0 +1,284 @@ + + */ + +namespace app\controller\admin; + +use app\model\AdminFields; +use app\model\AdminList; +use app\util\DataType; +use app\util\ReturnCode; +use app\util\Tools; +use think\Response; + +class Fields extends Base { + + private $dataType = [ + DataType::TYPE_INTEGER => 'Integer', + DataType::TYPE_STRING => 'String', + DataType::TYPE_BOOLEAN => 'Boolean', + DataType::TYPE_ENUM => 'Enum', + DataType::TYPE_FLOAT => 'Float', + DataType::TYPE_FILE => 'File', + DataType::TYPE_MOBILE => 'Mobile', + DataType::TYPE_OBJECT => 'Object', + DataType::TYPE_ARRAY => 'Array' + ]; + + /** + * @return Response + * @author zhaoxiang + */ + public function index(): Response { + return $this->buildSuccess($this->dataType); + } + + /** + * 获取请求参数 + * @return Response + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + * @author zhaoxiang + */ + public function request(): Response { + $limit = $this->request->get('size', config('apiadmin.ADMIN_LIST_DEFAULT')); + $start = $this->request->get('page', 1); + $hash = $this->request->get('hash', ''); + + if (empty($hash)) { + return $this->buildFailed(ReturnCode::EMPTY_PARAMS, '缺少必要参数'); + } + $listObj = (new AdminFields())->where('hash', $hash)->where('type', 0) + ->paginate(['page' => $start, 'list_rows' => $limit])->toArray(); + + $apiInfo = (new AdminList())->where('hash', $hash)->find(); + + return $this->buildSuccess([ + 'list' => $listObj['data'], + 'count' => $listObj['total'], + 'dataType' => $this->dataType, + 'apiInfo' => $apiInfo + ]); + } + + /** + * 获取返回参数 + * @return Response + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + * @author zhaoxiang + */ + public function response(): Response { + $limit = $this->request->get('size', config('apiadmin.ADMIN_LIST_DEFAULT')); + $start = $this->request->get('page', 1); + $hash = $this->request->get('hash', ''); + + if (empty($hash)) { + return $this->buildFailed(ReturnCode::EMPTY_PARAMS, '缺少必要参数'); + } + $listObj = (new AdminFields())->where('hash', $hash)->where('type', 1) + ->paginate(['page' => $start, 'list_rows' => $limit])->toArray(); + + $apiInfo = (new AdminList())->where('hash', $hash)->find(); + + return $this->buildSuccess([ + 'list' => $listObj['data'], + 'count' => $listObj['total'], + 'dataType' => $this->dataType, + 'apiInfo' => $apiInfo + ]); + } + + /** + * 新增字段 + * @return Response + * @author zhaoxiang + */ + public function add(): Response { + $postData = $this->request->post(); + $postData['show_name'] = $postData['field_name']; + $postData['default'] = $postData['defaults']; + unset($postData['defaults']); + $res = AdminFields::create($postData); + + cache('RequestFields:NewRule:' . $postData['hash'], null); + cache('RequestFields:Rule:' . $postData['hash'], null); + cache('ResponseFieldsRule:' . $postData['hash'], null); + + if ($res === false) { + return $this->buildFailed(ReturnCode::DB_SAVE_ERROR); + } + + return $this->buildSuccess(); + } + + /** + * 字段编辑 + * @return Response + * @author zhaoxiang + */ + public function edit(): Response { + $postData = $this->request->post(); + $postData['show_name'] = $postData['field_name']; + $postData['default'] = $postData['defaults']; + unset($postData['defaults']); + $res = AdminFields::update($postData); + + cache('RequestFields:NewRule:' . $postData['hash'], null); + cache('RequestFields:Rule:' . $postData['hash'], null); + cache('ResponseFieldsRule:' . $postData['hash'], null); + + if ($res === false) { + return $this->buildFailed(ReturnCode::DB_SAVE_ERROR); + } + + return $this->buildSuccess(); + } + + /** + * 字段删除 + * @return Response + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + * @author zhaoxiang + */ + public function del(): Response { + $id = $this->request->get('id'); + if (!$id) { + return $this->buildFailed(ReturnCode::EMPTY_PARAMS, '缺少必要参数'); + } + + $fieldsInfo = (new AdminFields())->where('id', $id)->find(); + cache('RequestFields:NewRule:' . $fieldsInfo->hash, null); + cache('RequestFields:Rule:' . $fieldsInfo->hash, null); + cache('ResponseFieldsRule:' . $fieldsInfo->hash, null); + + AdminFields::destroy($id); + + return $this->buildSuccess(); + } + + /** + * 批量上传返回字段 + * @return Response + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + * @author zhaoxiang + */ + public function upload(): Response { + $hash = $this->request->post('hash'); + $type = $this->request->post('type'); + $jsonStr = $this->request->post('jsonStr'); + $jsonStr = html_entity_decode($jsonStr); + $data = json_decode($jsonStr, true); + if ($data === null) { + return $this->buildFailed(ReturnCode::EXCEPTION, 'JSON数据格式有误'); + } + AdminList::update(['return_str' => json_encode($data)], ['hash' => $hash]); + $this->handle($data['data'], $dataArr); + $old = (new AdminFields())->where('hash', $hash)->where('type', $type)->select(); + $old = Tools::buildArrFromObj($old); + $oldArr = array_column($old, 'show_name'); + $newArr = array_column($dataArr, 'show_name'); + $addArr = array_diff($newArr, $oldArr); + $delArr = array_diff($oldArr, $newArr); + if ($delArr) { + AdminFields::destroy(['show_name' => ['in', $delArr]]); + } + if ($addArr) { + $addData = []; + foreach ($dataArr as $item) { + if (in_array($item['show_name'], $addArr)) { + $addData[] = $item; + } + } + (new AdminFields())->insertAll($addData); + } + + cache('RequestFields:NewRule:' . $hash, null); + cache('RequestFields:Rule:' . $hash, null); + cache('ResponseFieldsRule:' . $hash, null); + + return $this->buildSuccess(); + } + + /** + * @param $data + * @param $dataArr + * @param string $prefix + * @param string $index + * @author zhaoxiang + */ + private function handle(array $data, &$dataArr, string $prefix = 'data', string $index = 'data'): void { + if (!$this->isAssoc($data)) { + $addArr = [ + 'field_name' => $index, + 'show_name' => $prefix, + 'hash' => $this->request->post('hash'), + 'is_must' => 1, + 'data_type' => DataType::TYPE_ARRAY, + 'type' => $this->request->post('type') + ]; + $dataArr[] = $addArr; + $prefix .= '[]'; + if (isset($data[0]) && is_array($data[0])) { + $this->handle($data[0], $dataArr, $prefix); + } + } else { + $addArr = [ + 'field_name' => $index, + 'show_name' => $prefix, + 'hash' => $this->request->post('hash'), + 'is_must' => 1, + 'data_type' => DataType::TYPE_OBJECT, + 'type' => $this->request->post('type') + ]; + $dataArr[] = $addArr; + $prefix .= '{}'; + foreach ($data as $index => $datum) { + $myPre = $prefix . $index; + $addArr = array( + 'field_name' => $index, + 'show_name' => $myPre, + 'hash' => $this->request->post('hash'), + 'is_must' => 1, + 'data_type' => DataType::TYPE_STRING, + 'type' => $this->request->post('type') + ); + if (is_numeric($datum)) { + if (preg_match('/^\d*$/', $datum)) { + $addArr['data_type'] = DataType::TYPE_INTEGER; + } else { + $addArr['data_type'] = DataType::TYPE_FLOAT; + } + $dataArr[] = $addArr; + } elseif (is_array($datum)) { + $this->handle($datum, $dataArr, $myPre, $index); + } else { + $addArr['data_type'] = DataType::TYPE_STRING; + $dataArr[] = $addArr; + } + } + } + } + + /** + * 判断是否是关联数组（true表示是关联数组） + * @param array $arr + * @return bool + * @author zhaoxiang + */ + private function isAssoc(array $arr): bool { + if (array() === $arr) return false; + + return array_keys($arr) !== range(0, count($arr) - 1); + } +}