logic update

extend/queue.logic.php

@@ -32,9 +32,19 @@ class queue_logic
         $postData['delay_time']         = 0;
 
         $token = $this->login($params['req_url'],$params['key']);
+        if(empty($token)) {
+            $ret = ['code'=> 1,'msg' => '柜体服务器错误'];
+            $this->sync_return($params['ret_queue'],$params['method'],$ret);
+            return $ret;
+        }
         $resp = $this->reqest($params['req_url'] ,'/open_box', $postData,$token);
-
-        $this->sync_return($params['ret_queue'],$params['method'],$resp);
+        if(empty($resp)) {
+            $ret = ['state'=> 1,'msg' => 'openbox fail.'];
+            $this->sync_return($params['ret_queue'],$params['method'],$ret);
+            return $ret;
+        }
+        $resp = $this->sync_return($params['ret_queue'],$params['method'],$resp);
+        return $resp;
     }
 
     public function LockCabinet($params) {
@@ -53,9 +63,13 @@ class queue_logic
 
     private function sync_return($queue_name,$key,$params){
         global $config;
-        $host = ['net_queue']['host'];
+        $host = $config['net_queue']['host'];
         $port = $config['net_queue']['port'];
-
-        QueueClient::push($queue_name,$host ,$port ,$key,$params);
+        try {
+            QueueClient::push($queue_name,$host ,$port ,$key,$params);
+            return ['code'=>0 , 'msg' => 'ok'];
+        } catch (Exception $ex) {
+            return ['code'=>1 , 'msg' => 'cabinet redis connect error'];
+        }
     }
 }

queue/queuehandler.php

@@ -41,8 +41,8 @@ class queuehandler
                     Log::record("method={$method} args={$argstr}",Log::DEBUG);
 
                     $result = $logic_queue->$method($arg);
-                    if (!$result['state']) {
-                        Log::record("{$method} run error: {$result['msg']}",Log::DEBUG);
+                    if ($result['code'] != 0) {
+                        Log::record("{$method} run error: {$result['msg']}",Log::ERR);
                     }
                 }
             }