develop#项目文件

chenchangqin · chenchangqin · commit 682d38d33450 · 2020-07-16T18:17:31.000+08:00
diff --git a/.idea/php-docker-settings.xml b/.idea/php-docker-settings.xml
diff --git a/.idea/php.xml b/.idea/php.xml
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -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
diff --git a/hyperf/.env.example b/hyperf/.env.example
@@ -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=
diff --git a/hyperf/app/Controller/HouseController.php b/hyperf/app/Controller/HouseController.php
@@ -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!');
+    }
+}
diff --git a/hyperf/app/Controller/UserController.php b/hyperf/app/Controller/UserController.php
@@ -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
+        ];
+    }
+
 }
diff --git a/hyperf/app/Middleware/CorsMiddleware.php b/hyperf/app/Middleware/CorsMiddleware.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);
+    }
+}
diff --git a/hyperf/app/Model/User.php b/hyperf/app/Model/User.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'];
+}
diff --git a/hyperf/app/Service/SystemService.php b/hyperf/app/Service/SystemService.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;
+    }
+}
diff --git a/hyperf/app/Service/UserService.php b/hyperf/app/Service/UserService.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(),
+        ];
+    }
+}
diff --git a/hyperf/config/autoload/databases.php b/hyperf/config/autoload/databases.php
@@ -12,11 +12,11 @@
 return [
     'default' => [
         'driver' => env('DB_DRIVER', 'mysql'),
-        'host' => env('DB_HOST', 'localhost'),
+        'host' => env('DB_HOST', 'mysql'),
         'port' => env('DB_PORT', 3306),
         'database' => env('DB_DATABASE', 'hyperf'),
         'username' => env('DB_USERNAME', 'root'),
-        'password' => env('DB_PASSWORD', ''),
+        'password' => env('DB_PASSWORD', 'hSMZYpAGbNwVmERI'),
         'charset' => env('DB_CHARSET', 'utf8'),
         'collation' => env('DB_COLLATION', 'utf8_unicode_ci'),
         'prefix' => env('DB_PREFIX', ''),
