for debug

application/common.php

@@ -45,11 +45,7 @@ function json_return($code,$data=[],$msg='')
 
 function json_success($data=[],$msg='ok')
 {
-    json_return(['code'=>0,'data'=>$data,'msg'=>$msg],JSON_UNESCAPED_UNICODE );
-}
-function json_error($code,$data=[],$msg='')
-{
-    json_return(['code'=>$code,'data'=>$data,'msg'=>$msg],JSON_UNESCAPED_UNICODE );
+    json_return(0, $data, $msg);
 }
 
 

application/index/controller/Cabinet.php

@@ -6,8 +6,10 @@ define('BASE_ROOT_PATH',str_replace('/application/index/controller','',dirname(_
 require_once(BASE_ROOT_PATH . '/extend/queue.php');
 require_once(BASE_ROOT_PATH . '/extend/queue.logic.php');
 
+use app\index\model\BoxActionModel;
 use app\index\model\CabinetModel;
 use app\index\model\BoxModel;
+use app\index\model\OrderModel;
 use think\Session;
 use QueueClient;
 use QueueServer;
@@ -20,6 +22,12 @@ class Cabinet extends Base
      */
     public function check_fcode(){
         $code = input('param.code');
+        $OrderModel = new OrderModel();
+        $result = $OrderModel->check_fcode($code);
+        if($result['code'] != 1){
+            return json(json_error_exception('1009'));
+        }
+        json_success($result['data']);
     }
     /**
      * 自提柜向服务器上报
@@ -37,6 +45,12 @@ class Cabinet extends Base
         $trunk      = input('param.trunk');
         $cabinet    = input('param.cabinet');
         $state      = input('param.state');
+
+        $result = $this->change_status($cabinet , $trunk , $state);
+        if($result['code'] != 1){
+            return json(json_error_exception('1006'));
+        }
+        json_success('');
     }
     /**
      * 自提柜批量生产
@@ -59,7 +73,10 @@ class Cabinet extends Base
         json_success([],'success');
     }
 
-    public function open_box()
+    /**
+     * 开启箱门
+    */
+    public function OpenBox()
     {
         session('start','1');
         $cabinet_number     = input('param.cabinet_number');
@@ -72,18 +89,53 @@ class Cabinet extends Base
             'ret_queue'  => $sid
         ];
 
-        $queue_name = 'access_wait_oper';
-        QueueClient::push($queue_name,'lredis',6379,'open_box',$params);
+        $queue_name = 'access_wait_open';
+        $this->push_queue('access_wait_open','OpenBox',$params);
+
+        $content = $this->wait_ret($sid,'lredis',6379);
+
+        if($content['value'] == 'ok'){
+            $this->box_action_record($cabinet_number , $box_number , 1);
+        }
+    }
+    /**
+     * 关闭箱门
+     */
+    public function LockBox()
+    {
+        session('start','1');
+        $cabinet_number     = input('param.cabinet_number');
+        $box_number         = input('param.box_number');
+        $sid = session_id();
+
+        $params = [
+            'cabinet_number' => $cabinet_number,
+            'box_number' => $box_number,
+            'ret_queue'  => $sid
+        ];
 
+        $this->push_queue('access_wait_close','close_box',$params);
         $content = $this->wait_ret($sid,'lredis',6379);
 
+        if($content['value'] == 'ok'){
+            $this->box_action_record($cabinet_number , $box_number , 2);
+        }
     }
 
     private function testSend($queue_name,$value) {
         QueueClient::push($queue_name,'lredis',6379,'open_box_return',['value' => 'ok']);
 
     }
+    /**
+     * queue推送
+    */
+    private function push_queue($queue_name,$key,$params){
+        QueueClient::push($queue_name,'lredis',6379,$key,$params);
+    }
 
+    /**
+     * queue监听队列等待
+    */
     private function wait_ret($queue_name,$host,$name)
     {
         $worker = new QueueServer($queue_name,$host,$name);
@@ -95,9 +147,8 @@ class Cabinet extends Base
             pcntl_signal_dispatch();
             try
             {
-                $content = $worker->pop($queues, 1);
+                $content = $worker->pop($queues, 0);
                 return $content;
-
             }
             catch (Exception $e)
             {
@@ -108,36 +159,55 @@ class Cabinet extends Base
         }
     }
     /**
+     * 更新箱子时间
+    */
+
+    /**
      * 自提柜箱子修改状态
      */
-    public function change_status(){
-        $cabinet_number     = input('param.cabinet_number');
-        $box_number         = input('param.box_number');
-        $status             = input('param.status');
+    private function change_status($cabinet_number , $box_number , $status){
         $BoxModel = new BoxModel();
         $box = $BoxModel->getOneCabinetBox($cabinet_number,$box_number);
         if(empty($cabinet)){
             return json(json_error_exception(1008));
         }
-        if($box['status'] == $status){
-            json_success('','success');
+        if($status == $cabinet['status']){
+            return msg(1, '', 'success');
         }
+        $where['cabinet_number']    = $cabinet_number;
+        $where['box_number']        = $box_number;
+        $update['box_status']       = $status;
+        return $BoxModel->editData($where,$update);
+    }
+    public function test(){
+        $cabinet_number     = input('param.cabinet_number');
+        $box_number         = input('param.box_number');
+        $order_sn           = input('param.order_sn');
+        $result = $this->box_bind_order($cabinet_number , $box_number , $order_sn);
     }
+
     /**
      * 自提柜箱子绑定订单号
      */
-    public function box_bind_order(){
-        $where['cabinet_number']    = input('param.cabinet_number');
-        $where['box_number']        = input('param.box_number');
-
-        $update['enter_time']       = date('Y-m-d H:i:s');
-        $update['order_sn']         = input('param.order_sn');
+    private function box_bind_order($cabinet_number , $box_number , $order_sn){
+        $where['cabinet_number']    = $cabinet_number;
+        $where['box_number']        = $box_number;
+        $update['order_sn']         = $order_sn;
+        $update['box_status']       = 2;
 
         $BoxModel = new BoxModel();
-        $result = $BoxModel->editData($where,$update);
-        if($result['code'] != 1){
-            return json(json_error_exception('1006',$result['msg']));
-        }
-        json_return(200,[],'success');
+        return  $BoxModel->editData($where,$update);
+    }
+
+    /**
+     * 记录箱子开启/关闭
+    */
+    private function box_action_record($cabinet_number , $box_number , $type){
+        $BoxActionModel = new BoxActionModel();
+        $params['cabinet_number']       = $cabinet_number;
+        $params['box_number']           = $box_number;
+        $params['type']                 = $type;
+        $params['datetime']             = date("Y-m-d H:i:s");
+        $BoxActionModel->save($params);
     }
 }

application/index/controller/Order.php

@@ -2,7 +2,6 @@
 
 namespace app\index\controller;
 
-use app\index\model\BoxModel;
 use app\index\model\OrderModel;
 use think\Controller;
 
@@ -10,7 +9,12 @@ class Order extends Controller
 {
     public function check_rcode(){
         $order_sn = input('param.order_sn');
-        $ret = ['check' => true,'order_sn' => $order_sn];
+        $OrderModel = new OrderModel();
+        $order = $OrderModel->getOne($order_sn);
+        if(empty($order)){
+            return json(json_error_exception(2001));
+        }
+        $ret = ['existed' => true,'order_sn' => $order_sn];
         json_success($ret);
     }
     /**
@@ -29,7 +33,7 @@ class Order extends Controller
         if($result['code'] != 1){
             return json(json_error_exception('1006',$result['msg']));
         }
-        json_return(200,[],'success');
+        json_success('');
     }
     /**
      * 生成校验码
@@ -44,4 +48,4 @@ class Order extends Controller
         return $code;
     }
 
-}
+}

application/index/model/BoxActionModel.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace app\index\model;
+
+use think\Model;
+
+class BoxActionModel extends Model {
+
+    // 确定链接表名
+    protected $name = 'box_action_record';
+
+}

application/index/model/OrderModel.php

@@ -3,6 +3,7 @@
 namespace app\index\model;
 
 use think\Model;
+use app\index\model\BoxModel;
 
 class OrderModel extends Model{
 
@@ -13,6 +14,11 @@ class OrderModel extends Model{
         return $this->where('order_sn' , $order_sn)->find();
     }
 
+    public function Box()
+    {
+        return $this->hasOne('BoxModel', 'order_sn', 'order_sn');
+    }
+
     /**
      * 根据既定条件修改信息
      * @where $param
@@ -33,4 +39,27 @@ class OrderModel extends Model{
             return msg(-2, '', $e->getMessage());
         }
     }
+    /**
+     * 检查取件码
+    */
+    public function check_fcode($code)
+    {
+        $where['sc_order.code'] = $code;
+        $where['BoxModel.box_status'] = 2;
+        try{
+            $order = $this->Box()->hasWhere($where)->find();
+            if(empty($order)){
+                // 验证失败 输出错误信息
+                return msg(-1, '', $this->getError());
+            }else{
+                $data['code'] = $code;
+                $data['existed'] = true;
+                $data['trunk'] = $order['box_number'];
+                $data['cabinet'] = $order['cabinet_number'];
+                return msg(1, $data, 'success');
+            }
+        }catch(\Exception $e){
+            return msg(-2, '', $e->getMessage());
+        }
+    }
 }

config/errorCode.php

@@ -14,4 +14,7 @@ return [
     '1006'  =>  '操作失败',
     '1007'  =>  '信息有误',
     '1008'  =>  '数据不存在',
+    '1009'  =>  'code不存在',
+
+    '2001'  =>  '订单不存在',
 ];

route/route.php

@@ -6,9 +6,13 @@
         'roleAdd'                   => 'index/user/roleAdd',
         'roleDel'                   => 'index/user/roleDel',
 
+        'test'                      => 'index/cabinet/test',
+
         'checkFcode'                => 'index/cabinet/check_fcode',
         'changeCabinetStatus'       => 'index/cabinet/change_cabinet_status',
         'AddCabinet'                => 'index/cabinet/add_cabinet',
-        'CloseBox'                     => 'index/cabinet/add_cabinet',
-        'OpenBox'                     => 'index/cabinet/open_box',
+        'CloseBox'                  => 'index/cabinet/add_cabinet',
+        'OpenBox'                   => 'index/cabinet/open_box',
+        'checkRcode'                => 'index/order/check_rcode',
+        'orderBindCode'             => 'index/order/order_bind_code',
     ));

tests/ExampleTest.php

@@ -12,7 +12,6 @@ namespace tests;
 
 class ExampleTest extends TestCase
 {
-
     public function testBasicExample()
     {
         $this->visit('/')->see('ThinkPHP');