order

app/Controller/LoginController.php

@@ -1,16 +1,17 @@
 <?php
-declare(strict_types=1);
+declare (strict_types = 1);
 namespace App\Controller;
-use \Phper666\JWTAuth\JWT;
-use Hyperf\Di\Annotation\Inject;
-use Hyperf\HttpServer\Annotation\AutoController;
-use Hyperf\Validation\Contract\ValidatorFactoryInterface;
-use App\Tools\Result;
+
 use App\JsonRpc\UserServiceInterface;
 use App\Tools\CommonService;
-use function Hyperf\Support\env;
 use App\Tools\PublicData;
-use Hyperf\Context\Context;
+use App\Tools\Result;
+use function Hyperf\Support\env;
+use Hyperf\Di\Annotation\Inject;
+use Hyperf\HttpServer\Annotation\AutoController;
+use Hyperf\Validation\Contract\ValidatorFactoryInterface;
+use \Phper666\JWTAuth\JWT;
+
 /**
  * @AutoController()
  */
@@ -29,50 +30,50 @@ class LoginController extends AbstractController
     {
 //        $this->logger->info("验证之前");
 
-        $reqData =  $this->request->all();
+        $reqData = $this->request->all();
         $validator = $this->validationFactory->make(
             $reqData,
             [
                 'username' => 'required',
                 'password' => 'required',
-                'type'     =>'required'
+                'type' => 'required',
             ],
             [
                 'username.required' => '用户名不能为空',
                 'password.required' => '密码不能为空',
-                'type.required'     => '登录方式必填'
+                'type.required' => '登录方式必填',
             ]
         );
 
-        if ($validator->fails()){
+        if ($validator->fails()) {
             $errorMessage = $validator->errors()->first();
             return Result::error($errorMessage);
         }
         $comm = new CommonService();
         $ip = $comm->userIp();
         $redis = $this->container->get(\Hyperf\Redis\Redis::class);
-        $code = $redis->get('code'.$ip);
-        if(empty($code)){
+        $code = $redis->get('code' . $ip);
+        if (empty($code)) {
             return Result::error("验证码已过期");
         }
-        var_dump("验证码：",$code);
-        if(strtolower($code)!=$reqData['captcha']){
+        var_dump("验证码：", $code);
+        if (strtolower($code) != $reqData['captcha']) {
             return Result::error("验证码错误");
         }
-            //$reqData
+        //$reqData
         $where = [];
-        if($reqData['type'] ==1){//密码登录
+        if ($reqData['type'] == 1) { //密码登录
             $where = [
-                'user_name'=>$reqData['username'],
+                'user_name' => $reqData['username'],
             ];
         }
 //        $this->logger->info("验证之前");
         $userInfos = $this->userServiceClient->verifyUserInfo($where);
-        if($userInfos['code']==0){
+        if ($userInfos['code'] == 0) {
             return Result::error("用户名或密码错误");
         }
 //        $this->logger->info("验证用户返回值：", $userInfos);
-        if(md5(md5($reqData['password']).$userInfos['data']['salt']) != $userInfos['data']['password']){
+        if (md5(md5($reqData['password']) . $userInfos['data']['salt']) != $userInfos['data']['password']) {
             return Result::error("用户名或密码错误");
         }
         $userData = [
@@ -82,7 +83,7 @@ class LoginController extends AbstractController
             'mobile' => $userInfos['data']['mobile'],
             'email' => $userInfos['data']['email'],
             'rong_token' => $userInfos['data']['rong_token'],
-            'level_id' => $userInfos['data']['level_id']
+            'level_id' => $userInfos['data']['level_id'],
         ];
         var_dump($userData);
         // 使用默认场景登录
@@ -100,24 +101,24 @@ class LoginController extends AbstractController
     public function checkVerifyCode(Jwt $jwt)
     {
         //其它信息暂时不管 先以openid
-        $reqData =  $this->request->all();
+        $reqData = $this->request->all();
         $validator = $this->validationFactory->make(
             $reqData,
             [
-                'token' => 'required'
+                'token' => 'required',
             ],
             [
-                'token.required' => 'token不能为空'
+                'token.required' => 'token不能为空',
             ]
         );
-        if ($validator->fails()){
+        if ($validator->fails()) {
             $errorMessage = $validator->errors()->first();
             return Result::error($errorMessage);
         }
         $userInfo = $jwt->getClaimsByToken($reqData['token']);
-        if($userInfo){
-            return Result::success(['token'=>$reqData['token']]);
-        }else{
+        if ($userInfo) {
+            return Result::success(['token' => $reqData['token']]);
+        } else {
             return Result::error("token无效");
         }
     }
@@ -128,40 +129,40 @@ class LoginController extends AbstractController
     public function registerOrLogin(Jwt $jwt)
     {
         //获取access_token
-        $reqData =  $this->request->all();
+        $reqData = $this->request->all();
         $validator = $this->validationFactory->make(
             $reqData,
             [
-                'code' => 'required'
+                'code' => 'required',
             ],
             [
-                'code.required' => 'code不能为空'
+                'code.required' => 'code不能为空',
             ]
         );
 
-        if ($validator->fails()){
+        if ($validator->fails()) {
             $errorMessage = $validator->errors()->first();
             return Result::error($errorMessage);
         }
 
-        $url = env("WECHAT")."cgi-bin/token?appid=".env("APPID")."&secret=".env("APP_SECRET")."&grant_type=client_credential";
-        $result =  PublicData::http_get($url);
-        $accessTokenData = json_decode($result,true);
+        $url = env("WECHAT") . "cgi-bin/token?appid=" . env("APPID") . "&secret=" . env("APP_SECRET") . "&grant_type=client_credential";
+        $result = PublicData::http_get($url);
+        $accessTokenData = json_decode($result, true);
         //获取openid
-        $url = env("WECHAT")."sns/jscode2session?appid=".env("APPID")."&secret=".env("APP_SECRET")."&js_code=".$reqData['loginCode']."&grant_type=authorization_code";
-        $result =  PublicData::http_get($url);
-        $openInfoData = json_decode($result,true);
-        if(isset($openInfoData['errcode']) && in_array($openInfoData['errcode'],[40163,40029])){
-            return  Result::error($openInfoData['errmsg']);
+        $url = env("WECHAT") . "sns/jscode2session?appid=" . env("APPID") . "&secret=" . env("APP_SECRET") . "&js_code=" . $reqData['loginCode'] . "&grant_type=authorization_code";
+        $result = PublicData::http_get($url);
+        $openInfoData = json_decode($result, true);
+        if (isset($openInfoData['errcode']) && in_array($openInfoData['errcode'], [40163, 40029])) {
+            return Result::error($openInfoData['errmsg']);
         }
         $data = [
             'code' => $reqData['code'],
-            'openid'=>$openInfoData['openid']
+            'openid' => $openInfoData['openid'],
         ];
         // 将数组转换为JSON字符串
         $jsonData = json_encode($data);
         // 初始化cURL会话
-        $ch = curl_init(env("WECHAT")."wxa/business/getuserphonenumber?access_token=".$accessTokenData['access_token']);
+        $ch = curl_init(env("WECHAT") . "wxa/business/getuserphonenumber?access_token=" . $accessTokenData['access_token']);
 
         // 设置cURL选项 Todo 这里有一万个wc 封装成post方法就报错，后期再研究
         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
@@ -169,50 +170,50 @@ class LoginController extends AbstractController
         curl_setopt($ch, CURLOPT_POSTFIELDS, $jsonData);
         curl_setopt($ch, CURLOPT_HTTPHEADER, [
             'Content-Type: application/json',
-            'Content-Length: ' . strlen($jsonData)
+            'Content-Length: ' . strlen($jsonData),
         ]);
         // 执行cURL会话
         $response = curl_exec($ch);
         // 检查是否有错误发生
-        if(curl_errno($ch)){
-            return  Result::error("获取手机号失败");
+        if (curl_errno($ch)) {
+            return Result::error("获取手机号失败");
         }
         // 关闭cURL会话
         curl_close($ch);
-        $response = json_decode($response,true);
-        if($response['errcode']=='40029'){
-            return  Result::error($openInfoData['errmsg']);
+        $response = json_decode($response, true);
+        if ($response['errcode'] == '40029') {
+            return Result::error($openInfoData['errmsg']);
         }
-       // 打印响应内容
-        var_dump($openInfoData,$response);
+        // 打印响应内容
+        var_dump($openInfoData, $response);
         //根据openid 获取token
 
         $checkUserInfo = $this->userServiceClient->verifyUserInfo([
-            'user_name'=>$response['phone_info']['purePhoneNumber']
+            'user_name' => $response['phone_info']['purePhoneNumber'],
         ]);
-        if($checkUserInfo['code']==0){
+        if ($checkUserInfo['code'] == 0) {
             $salt = rand(1, 999999);
             $createUserData = [
-                'user_name'=>$response['phone_info']['purePhoneNumber'],
+                'user_name' => $response['phone_info']['purePhoneNumber'],
                 'salt' => $salt,
-                'password'=>$openInfoData['openid']
+                'password' => $openInfoData['openid'],
             ];
-            $checkUserInfo =  $this->userServiceClient->createUser($createUserData);
+            $checkUserInfo = $this->userServiceClient->createUser($createUserData);
         }
         //根据openid和手机号判断是否注册，未注册直接注册
         $wechatReqData = [
-            'openid'=>$openInfoData['openid'],
-            'purePhoneNumber'=>$response['phone_info']['purePhoneNumber']
+            'openid' => $openInfoData['openid'],
+            'purePhoneNumber' => $response['phone_info']['purePhoneNumber'],
         ];
         $wechatInfo = $this->userServiceClient->getWechatInfo($wechatReqData);
-        if($wechatInfo['code']==0){
+        if ($wechatInfo['code'] == 0) {
             $wechatData = [
-                'openid'=>$openInfoData['openid'],
-                'phoneNumber'=>$response['phone_info']['phoneNumber'],
-                'purePhoneNumber'=>$response['phone_info']['purePhoneNumber'],
-                'countryCode'=>$response['phone_info']['countryCode'],
-                'watermark'=>json_encode($response['phone_info']['watermark']),
-                'user_id'=>$checkUserInfo['data']['id']
+                'openid' => $openInfoData['openid'],
+                'phoneNumber' => $response['phone_info']['phoneNumber'],
+                'purePhoneNumber' => $response['phone_info']['purePhoneNumber'],
+                'countryCode' => $response['phone_info']['countryCode'],
+                'watermark' => json_encode($response['phone_info']['watermark']),
+                'user_id' => $checkUserInfo['data']['id'],
             ];
             $this->userServiceClient->addWechatInfo($wechatData);
         }
@@ -242,8 +243,8 @@ class LoginController extends AbstractController
         $h = $this->request->getHeaders();
 //        var_dump($this->request->getHeaders());
 //        $a= 'eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJwaHBlcjY2Ni9qd3QiLCJ1aWQiOjMyLCJ1c2VyX25hbWUiOiIxIiwicm9sZV9pZCI6MSwibW9iaWxlIjoiMTU4MDEyNDU3NTUiLCJlbWFpbCI6IjVAcXEuY29tIiwicm9uZ190b2tlbiI6IiIsImxldmVsX2lkIjo4LCJqd3Rfc2NlbmUiOiJkZWZhdWx0IiwianRpIjoiZGVmYXVsdF82Njc1MjJkZDQ3YWYxMi41MTE5MjI5MiIsImlhdCI6MTcxODk1MjY2OSwibmJmIjoxNzE4OTUyNjY5LCJleHAiOjE3MjE1NDQ2Njl9.e0JW8fgNrwBdFgmQ8GNtES2ME1SbcbIih5MsQWzT6sk';
-        $arr =  $jwt->getClaimsByToken($h['token'][0]);
-        var_dump($h['token'][0],"+++++++++++",$arr,"===####");
+        $arr = $jwt->getClaimsByToken($h['token'][0]);
+        var_dump($h['token'][0], "+++++++++++", $arr, "===####");
         return $this->response->json(['code' => 0, 'msg' => 'success', 'data' => ['a' => 1]]);
     }
-}
+}

app/Controller/OrderController.php

@@ -31,8 +31,9 @@ class OrderController extends AbstractController
     {
         return $response->raw('Hello Hyperf!');
     }
-    public function getStauts(){
-      
+    public function getStauts()
+    {
+
     }
 
     /**
@@ -59,4 +60,160 @@ class OrderController extends AbstractController
         $result = $this->orderServiceClient->getAD($requireData);
         return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
     }
+    public function getOrderListAdmin()
+    {
+        $requireData = $this->request->all();
+        $validator = $this->validationFactory->make(
+            $requireData,
+            [
+                'page' => 'required',
+                'pagesize' => 'required',
+
+            ],
+            [
+                'page.required' => 'page不能为空',
+                'pagesize.required' => 'pagesize不能为空',
+
+            ]
+        );
+        if ($validator->fails()) {
+            $errorMessage = $validator->errors()->first();
+            return Result::error($errorMessage);
+        }
+        $result = $this->orderServiceClient->getOrderListAdmin($requireData);
+        return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
+
+    }
+    public function getOrderDetailAdmin()
+    {
+        $requireData = $this->request->all();
+        $validator = $this->validationFactory->make(
+            $requireData,
+            [
+                'id' => 'required',
+
+            ],
+            [
+                'id.required' => 'id不能为空',
+
+            ]
+        );
+        if ($validator->fails()) {
+            $errorMessage = $validator->errors()->first();
+            return Result::error($errorMessage);
+        }
+        $result = $this->orderServiceClient->getOrderDetailAdmin($requireData);
+        return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
+    }
+    public function applyOrderStatusAdmin()
+    {
+        $requireData = $this->request->all();
+        $validator = $this->validationFactory->make(
+            $requireData,
+            [
+                'id' => 'required',
+
+            ],
+            [
+                'id.required' => 'id不能为空',
+
+            ]
+        );
+        if ($validator->fails()) {
+            $errorMessage = $validator->errors()->first();
+            return Result::error($errorMessage);
+        }
+        $result = $this->orderServiceClient->getOrderDetailAdmin($requireData);
+        return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
+    }
+    //修改订单价格
+    public function editPriceOrderAdmin()
+    {
+        $requireData = $this->request->all();
+        $validator = $this->validationFactory->make(
+            $requireData,
+            [
+                'id' => 'required',
+                'price' => 'required|decimal:2',
+
+            ],
+            [
+                'id.required' => 'id不能为空',
+                'price.required' => '价格不能为空',
+                'price.decimal' => '价格格式不正确',
+
+            ]
+        );
+        if ($validator->fails()) {
+            $errorMessage = $validator->errors()->first();
+            return Result::error($errorMessage);
+        }
+        $result = $this->orderServiceClient->editOrderAdmin($requireData);
+        return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
+    }
+    public function rejectOrderAdmin()
+    {
+        $requireData = $this->request->all();
+        $validator = $this->validationFactory->make(
+            $requireData,
+            [
+                'id' => 'required',
+                'reason' => 'required',
+            ],
+            [
+                'id.required' => 'id不能为空',
+                'reason.required' => '原因不能为空',
+
+            ]
+        );
+        if ($validator->fails()) {
+            $errorMessage = $validator->errors()->first();
+            return Result::error($errorMessage);
+        }
+        $result = $this->orderServiceClient->rejectOrderAdmin($requireData);
+        return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
+
+    }
+    public function endOrderAdmin()
+    {
+        $requireData = $this->request->all();
+        $validator = $this->validationFactory->make(
+            $requireData,
+            [
+                'id' => 'required',
+
+            ],
+            [
+                'id.required' => 'id不能为空',
+
+            ]
+        );
+        if ($validator->fails()) {
+            $errorMessage = $validator->errors()->first();
+            return Result::error($errorMessage);
+        }
+        $result = $this->orderServiceClient->endOrderAdmin($requireData);
+        return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
+    }
+    public function delOrderAdmin()
+    {
+        $requireData = $this->request->all();
+        $validator = $this->validationFactory->make(
+            $requireData,
+            [
+                'id' => 'required',
+
+            ],
+            [
+                'id.required' => 'id不能为空',
+
+            ]
+        );
+        if ($validator->fails()) {
+            $errorMessage = $validator->errors()->first();
+            return Result::error($errorMessage);
+        }
+        $result = $this->orderServiceClient->delOrderAdmin($requireData);
+        return $result['code'] == 200 ? Result::success($result['data']) : Result::error($result['message']);
+    }
 }

app/JsonRpc/OrderService.php

@@ -26,4 +26,37 @@ class OrderService extends AbstractServiceClient implements OrderServiceInterfac
         return $this->__request(__FUNCTION__, $data);
     }
 
+    /**
+     * @param array $data
+     * @return mixed
+     */
+    public function getOrderListAdmin(array $data)
+    {
+        return $this->__request(__FUNCTION__, $data);
+    }
+    public function getOrderDetailAdmin(array $data)
+    {
+        return $this->__request(__FUNCTION__, $data);
+    }
+    public function editOrderStatusAdmin(array $data)
+    {
+        return $this->__request(__FUNCTION__, $data);
+    }
+    public function editOrderAdmin(array $data)
+    {
+        return $this->__request(__FUNCTION__, $data);
+    }
+    public function rejectOrderAdmin(array $data)
+    {
+        return $this->__request(__FUNCTION__, $data);
+    }
+    public function endOrderAdmin(array $data)
+    {
+        return $this->__request(__FUNCTION__, $data);
+    }
+    public function delOrderAdmin(array $data)
+    {
+        return $this->__request(__FUNCTION__, $data);
+    }
+
 }

app/JsonRpc/OrderServiceInterface.php

@@ -9,4 +9,33 @@ interface OrderServiceInterface
      */
     public function getAD(array $data);
 
+    /**
+     * @param array $data
+     */
+    public function getOrderListAdmin(array $data);
+    /**
+     * @param array $data
+     */
+    public function getOrderDetailAdmin(array $data);
+    /**
+     * @param array $data
+     */
+    public function editOrderStatusAdmin(array $data);
+    /**
+     * @param array $data
+     */
+    public function editOrderAdmin(array $data);
+    /**
+     * @param array $data
+     */
+    public function rejectOrderAdmin(array $data);
+    /**
+     * @param array $data
+     */
+    public function endOrderAdmin(array $data);
+    /**
+     * @param array $data
+     */
+    public function delOrderAdmin(array $data);
+
 }

config/api/order.php

@@ -1,6 +1,6 @@
 <?php
 
-declare (strict_types = 1);
+declare (strict_types = );
 use App\Controller\OrderController;
 use App\Middleware\Auth\FooMiddleware;
 use Hyperf\HttpServer\Router\Router;
@@ -12,28 +12,38 @@ Router::addGroup(
 
         //订单状态对应
         Router::post('/getStauts', [OrderController::class, 'getStauts']);
-        //查询广告  1
+        //查询广告  
         Router::post('/getAD', [OrderController::class, 'getAD']);
-        //添加订单 1
+        //添加订单 
         Router::post('/addAD', [OrderController::class, 'addAD']);
-        //获取订单列表 1
+        //获取订单列表 
         Router::post('/getOrderList', [OrderController::class, 'getOrderList']);
-        //获取订单详情  1
+        //获取订单详情  
         Router::post('/getOrderDetail', [OrderController::class, 'getOrderDetail']);
-        //撤回订单 1
+        //撤回订单 
         Router::post('/cancelOrder', [OrderController::class, 'cancelOrder']);
         //删除广告
         Router::post('/delOrderAD', [OrderController::class, 'delOrderAD']);
 
         //后台管理
-        //获取订单列表 1
+        //获取订单列表  
         Router::post('/getOrderListAdmin', [OrderController::class, 'getOrderListAdmin']);
-        //获取订单详情 1
+        //获取订单详情 
         Router::post('/getOrderDetailAdmin', [OrderController::class, 'getOrderDetailAdmin']);
+        //审核订单
+        Router::post('/applyOrderStatusAdmin', [OrderController::class, 'applyOrderStatusAdmin']);
+        //修改订单价格
+        Router::post('/editPriceOrderAdmin', [OrderController::class, 'editPriceOrderAdmin']);
+        //驳回订单
+        Router::post('/rejectOrderAdmin', [OrderController::class, 'rejectOrderAdmin']);
+        //结束订单
+        Router::post('/endOrderAdmin', [OrderController::class, 'endOrderAdmin']);
+        //删除订单
+        Router::post('/delOrderAdmin', [OrderController::class, 'delOrderAdmin']);
 
-        //获取广告列表 1
+        //获取广告列表
         Router::post('/getADList', [OrderController::class, 'getADList']);
-        //获取广告详情 2
+        //获取广告详情
         Router::post('/getADDetail', [OrderController::class, 'getADDetail']);
         //添加广告
         Router::post('/addADAdmin', [OrderController::class, 'addAD']);
@@ -41,8 +51,6 @@ Router::addGroup(
         Router::post('/editAD', [OrderController::class, 'editAD']);
         //删除广告
         Router::post('/delAD', [OrderController::class, 'delAD']);
-        //驳回  结束   修改价格
-        Router::post('/editOrderStatus', [OrderController::class, 'editOrderStatus']);
 
     },
     ['middleware' => [FooMiddleware::class]]