From 0e3687e697e3a3fa75091534286f0f47b6688121 Mon Sep 17 00:00:00 2001
From: liangyuyan <1103300295@qq.com>
Date: Fri, 14 Aug 2020 17:48:55 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E7=94=A8=E6=88=B7unionid?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .gitignore                           |  1 +
 app/Controller/UserController.php    | 31 ++++++++++++++
 app/Request/UserUnionidRequest.php   | 45 ++++++++++++++++++++
 app/Service/UserService.php          | 63 ++++++++++++++++++++++++++++
 app/Service/UserServiceInterface.php | 18 ++++++++
 config/routes.php                    | 23 ++++++++++
 6 files changed, 181 insertions(+)
 create mode 100644 app/Controller/UserController.php
 create mode 100644 app/Request/UserUnionidRequest.php
 create mode 100644 app/Service/UserService.php
 create mode 100644 app/Service/UserServiceInterface.php

diff --git a/.gitignore b/.gitignore
index 9091e68..8088c1b 100644
--- a/.gitignore
+++ b/.gitignore
@@ -12,3 +12,4 @@ vendor/
 *.lock
 .phpunit*
 /watch
+.vscode/settings.json
diff --git a/app/Controller/UserController.php b/app/Controller/UserController.php
new file mode 100644
index 0000000..d494d83
--- /dev/null
+++ b/app/Controller/UserController.php
@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Controller;
+
+use Hyperf\Di\Annotation\Inject;
+use App\Service\UserServiceInterface;
+use App\Request\UserUnionidRequest;
+
+class UserController extends BaseController
+{
+
+    /**
+     * @Inject
+     * @var UserServiceInterface
+     */
+    protected $userService;
+
+    /**
+     * 根据用户的openid更新unionid信息
+     */
+    public function saveUserUnionid(UserUnionidRequest $request)
+    {
+        $openid  = $this->request->input('openid','');
+        $unionid = $this->request->input('unionid','');
+
+        return $this->success($this->userService->saveUserUnionid($openid,$unionid));
+    }
+
+}
diff --git a/app/Request/UserUnionidRequest.php b/app/Request/UserUnionidRequest.php
new file mode 100644
index 0000000..939940f
--- /dev/null
+++ b/app/Request/UserUnionidRequest.php
@@ -0,0 +1,45 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Request;
+
+use Hyperf\Validation\Request\FormRequest;
+
+class UserUnionidRequest extends FormRequest
+{
+    /**
+     * Determine if the user is authorized to make this request.
+     */
+    public function authorize(): bool
+    {
+        return true;
+    }
+
+    /**
+     * Get the validation rules that apply to the request.
+     */
+    public function rules(): array
+    {
+        return [
+            'openid' => 'required|nonempty',
+            'unionid' => 'required|nonempty',
+        ];
+    }
+
+    public function messages(): array
+    {
+        return [
+            'openid.*' => ':attribute必须',
+            'unionid.*' => ':attribute必须',
+        ];
+    }
+
+    public function attributes(): array
+    {
+        return [
+            'openid' => '用户openid',
+            'unionid' => '用户unionid',
+        ];
+    }
+}
diff --git a/app/Service/UserService.php b/app/Service/UserService.php
new file mode 100644
index 0000000..87606c1
--- /dev/null
+++ b/app/Service/UserService.php
@@ -0,0 +1,63 @@
+<?php
+
+namespace App\Service;
+
+use App\Model\OrderMain;
+use App\Model\Users;
+
+class UserService implements UserServiceInterface
+{
+
+    /**
+     * 是否平台新用户
+     * 在很多奖励的地方会需要用到这个查询
+     * 判定条件：
+     * 没有在平台下过单（包括线上和线下）
+     * @param $user_id
+     * @return mixed|void
+     */
+    public function isStageNewUser($user_id): bool
+    {
+        $exist = OrderMain::query()
+            ->where(['user_id' => $user_id])
+            ->where(function ($query){
+                $query->where('state', 'in', [4,5,10])
+                        ->orWhere('dm_state', 'in', [2,3]);
+            })
+            ->exists();
+
+        return !$exist;
+    }
+    
+    /**
+     * 根据用户的openid更新unionid信息
+     * 如果没有找到用户，则不做任何处理
+     * @param $openid
+     * @param $unionid
+     * @return array
+     */
+    public function saveUserUnionid($openid,$unionid)
+    {
+        $result = [
+            'status' => false,
+            'msg'    => '用户不存在或者已存在相同unionid'
+        ];
+
+        // 查询用户是否存在
+        $userinfo = Users::select('id','unionid')->where('openid',$openid)->first();
+        if($userinfo && $userinfo->unionid != $unionid){
+            $userinfo->unionid = $unionid;
+            if($res = $userinfo->save()){
+                $result['status'] = true;
+                $result['msg'] = '更改用户unionid信息成功';
+                $result['res'] = $res;
+            }else{
+                $result['msg'] = '更改用户unionid信息失败';
+            }
+        }
+
+        return $result;
+    }
+
+
+}
\ No newline at end of file
diff --git a/app/Service/UserServiceInterface.php b/app/Service/UserServiceInterface.php
new file mode 100644
index 0000000..06c1ea0
--- /dev/null
+++ b/app/Service/UserServiceInterface.php
@@ -0,0 +1,18 @@
+<?php
+
+
+namespace App\Service;
+
+
+interface UserServiceInterface
+{
+    /**
+     * 是否平台新用户
+     * @param $user_id
+     * @return mixed
+     */
+    public function isStageNewUser($user_id): bool;
+
+    public function saveUserUnionid($openid,$unionid);
+
+}
\ No newline at end of file
diff --git a/config/routes.php b/config/routes.php
index 706a9ab..e75b7ce 100644
--- a/config/routes.php
+++ b/config/routes.php
@@ -23,4 +23,27 @@ Router::addGroup('/v1/',function (){
     Router::post('ServiceEvaluate/isPersonnel', 'App\Controller\ServiceEvaluateController@isPersonnel');
     Router::post('ServiceEvaluate/getPersonnelInfo', 'App\Controller\ServiceEvaluateController@getPersonnelInfo');
     Router::post('ServiceEvaluate/getEvaluateList', 'App\Controller\ServiceEvaluateController@getEvaluateList');
+    Router::post('Attachment/uploadImage', 'App\Controller\AttachmentController@uploadImage');
+    Router::post('Attachment/uploadImageByBase64', 'App\Controller\AttachmentController@uploadImageByBase64');
+    Router::post('Attachment/upload', 'App\Controller\AttachmentController@upload');
+    Router::post('ParamsToken/generate', 'App\Controller\ParamsTokenController@generate');
+    Router::post('ParamsToken/analyze', 'App\Controller\ParamsTokenController@analyze');
+    Router::post('Ad/banners', 'App\Controller\AdController@banners');
+    Router::post('CouponRebate/isCouponRebate', 'App\Controller\CouponRebateController@isCouponRebate');
+    Router::post('CouponRebate/userReceiveCoupon', 'App\Controller\CouponRebateController@userReceiveCoupon');
+    Router::post('CouponRebate/getActiveInfo', 'App\Controller\CouponRebateController@getActiveInfo');
+	Router::post('CouponRebate/tieCouponActive', 'App\Controller\CouponRebateController@tieCouponActive');
+    Router::post('CouponRebate/couponRebate', 'App\Controller\CouponRebateController@couponRebate');
+    Router::post('CouponRebate/clearSsdbReceive', 'App\Controller\CouponRebateController@clearSsdbCouponReceiveByName');
+    //播报器相关
+    Router::post('Device/bind', 'App\Controller\DeviceController@bind');
+    Router::post('Device/list', 'App\Controller\DeviceController@list');
+    Router::post('Device/unbind', 'App\Controller\DeviceController@unbind');
+
+    //测试路由
+    Router::get('test/index1', 'App\Controller\TestController@index1');
+
+    Router::post('Store/applyEntry', 'App\Controller\StoreController@applyEntry');
+    Router::post('Community/bind', 'App\Controller\CommunityController@bind');
+    Router::post('user/saveUserUnionid', 'App\Controller\UserController@saveUserUnionid');
 });
\ No newline at end of file