develop#项目文件

Author: chenchangqin

.idea/php-docker-settings.xml

@@ -56,5 +56,5 @@ services:
       - "9200:9200"
     networks:
       - hyperf
-    command: /bin/bash -c "rm -rf /opt/www/hyperf/runtime/container && php /opt/www/hyperf/bin/hyperf.php start"
+#    command: /bin/bash -c "rm -rf /opt/www/hyperf/runtime/container && php /opt/www/hyperf/bin/hyperf.php start"
     tty: true

.idea/php.xml

@@ -2,11 +2,11 @@ APP_NAME=skeleton
 APP_ENV=dev
 
 DB_DRIVER=mysql
-DB_HOST=localhost
+DB_HOST=mysql
 DB_PORT=3306
 DB_DATABASE=hyperf
 DB_USERNAME=root
-DB_PASSWORD=
+DB_PASSWORD=hSMZYpAGbNwVmERI
 DB_CHARSET=utf8mb4
 DB_COLLATION=utf8mb4_unicode_ci
 DB_PREFIX=

docker-compose.yml

@@ -0,0 +1,16 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Controller;
+
+use Hyperf\HttpServer\Contract\RequestInterface;
+use Hyperf\HttpServer\Contract\ResponseInterface;
+
+class HouseController extends AbstractController
+{
+    public function index(RequestInterface $request, ResponseInterface $response)
+    {
+        return $response->raw('Hello Hyperf!');
+    }
+}

hyperf/.env.example

@@ -1,4 +1,5 @@
 <?php
+declare(strict_types=1);
 /**
  * Created by PhpStorm.
  * User: chenchangqin
@@ -8,23 +9,68 @@
 
 namespace App\Controller;
 
-use Hyperf\HttpServer\Annotation\AutoController;
+use App\Service\UserService;
+use Hyperf\Di\Annotation\Inject;
+use Hyperf\HttpServer\Annotation\Controller;
+use Hyperf\HttpServer\Annotation\RequestMapping;
 use Hyperf\HttpServer\Contract\RequestInterface;
 
 /**
- * @AutoController()
+ * @Controller()
  */
 class UserController extends AbstractController
 {
+
+    /**
+     * @Inject
+     * @var UserService
+     */
+    private $userService;
+
+    /**
+     * @param RequestInterface $request
+     * @return string
+     * @RequestMapping(path="index",methods={"get"})
+     */
     public function index(RequestInterface $request)
     {
         $id = $request->getMethod();
         return $id;
     }
 
-    public function info(RequestInterface $request)
+    /**
+     * @param RequestInterface $request
+     * @param int              $id
+     * @return array
+     * @RequestMapping(path="/user/{id:\d+}",methods={"get"})
+     */
+    public function info(RequestInterface $request,int $id)
     {
-        $id = $request->getMethod();
-        return $id;
+        $result = $this->userService->user($id);
+
+        $method = $request->getMethod();
+        return [
+            'method' => $method,
+            'result' => $result
+        ];
     }
+
+    /**
+     * @param RequestInterface $request
+     * @param int              $id
+     * @return array
+     * @RequestMapping(path="update/[{id:\d+}]",methods={"put"})
+     */
+    public function update(RequestInterface $request,int $id)
+    {
+        $data = $request->post();
+        $result = $this->userService->updateUser($id,$data);
+
+        $method = $request->getMethod();
+        return [
+            'method' => $method,
+            'result' => $result
+        ];
+    }
+
 }

hyperf/app/Controller/HouseController.php

@@ -0,0 +1,42 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Middleware;
+
+use Hyperf\Utils\Context;
+use Psr\Container\ContainerInterface;
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Server\MiddlewareInterface;
+use Psr\Http\Message\ServerRequestInterface;
+use Psr\Http\Server\RequestHandlerInterface;
+
+class CorsMiddleware implements MiddlewareInterface
+{
+    /**
+     * @var ContainerInterface
+     */
+    protected $container;
+
+    public function __construct(ContainerInterface $container)
+    {
+        $this->container = $container;
+    }
+
+    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
+    {
+        $response = Context::get(ResponseInterface::class);
+        $response = $response->withHeader('Access-Control-Allow-Origin', '*')
+            ->withHeader('Access-Control-Allow-Credentials', 'true')
+            // Headers 可以根据实际情况进行改写。
+            ->withHeader('Access-Control-Allow-Headers', 'DNT,Keep-Alive,User-Agent,Cache-Control,Content-Type,Authorization');
+
+        Context::set(ResponseInterface::class, $response);
+
+        if ($request->getMethod() == 'OPTIONS') {
+            return $response;
+        }
+
+        return $handler->handle($request);
+    }
+}

hyperf/app/Controller/UserController.php

@@ -0,0 +1,35 @@
+<?php
+
+declare (strict_types=1);
+namespace App\Model;
+
+use Hyperf\DbConnection\Model\Model;
+/**
+ * @property int $id 
+ * @property string $username 
+ * @property int $status 
+ * @property int $admin 
+ * @property \Carbon\Carbon $created_at 
+ * @property \Carbon\Carbon $updated_at 
+ */
+class User extends Model
+{
+    /**
+     * The table associated with the model.
+     *
+     * @var string
+     */
+    protected $table = 'user';
+    /**
+     * The attributes that are mass assignable.
+     *
+     * @var array
+     */
+    protected $fillable = [];
+    /**
+     * The attributes that should be cast to native types.
+     *
+     * @var array
+     */
+    protected $casts = ['id' => 'integer', 'status' => 'integer', 'admin' => 'integer', 'created_at' => 'datetime', 'updated_at' => 'datetime'];
+}

hyperf/app/Middleware/CorsMiddleware.php

@@ -0,0 +1,25 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Service;
+
+use Hyperf\Di\Annotation\Inject;
+use Hyperf\Cache\Listener\DeleteListenerEvent;
+use Psr\EventDispatcher\EventDispatcherInterface;
+
+class SystemService
+{
+    /**
+     * @Inject
+     * @var EventDispatcherInterface
+     */
+    protected $dispatcher;
+
+    public function flushCache($userId)
+    {
+        $this->dispatcher->dispatch(new DeleteListenerEvent('user-update', [$userId]));
+
+        return true;
+    }
+}

hyperf/app/Model/User.php

@@ -0,0 +1,48 @@
+<?php
+declare(strict_types=1);
+/**
+ * Created by PhpStorm.
+ * User: chenchangqin
+ * Date: 2020-07-16
+ * Time: 14:51
+ */
+
+namespace App\Service;
+
+use App\Model\User;
+use Hyperf\Cache\Annotation\Cacheable;
+use Hyperf\Cache\Annotation\CachePut;
+
+class UserService
+{
+    /**
+     * @Cacheable(prefix="user", ttl=9000, listener="user-update")
+     */
+    public function user(int $id)
+    {
+        $user = User::query()->where('id',$id)->first();
+
+        if($user){
+            return $user->toArray();
+        }
+
+        return null;
+    }
+
+    /**
+     * @CachePut(prefix="user", ttl=3601)
+     */
+    public function updateUser(int $id,array $data)
+    {
+
+        $user = User::query()->find($id);
+        foreach ($data as $key => $value) {
+            $user->{$key} = $value;
+        }
+        $user->save();
+
+        return [
+            'user' => $user->toArray(),
+        ];
+    }
+}