添加of命令

application/controller/business/power/ShutdownController.php

@@ -10,13 +10,15 @@ namespace Application\controller\business\power;
 
 
 use Application\controller\Controller;
+use Lib\Gateway;
+use Lib\log\Log;
 
 class ShutdownController extends Controller
 {
 
     protected $parameterMap = [
 
-        '04' => []
+        '0F' => []
     ];
 
     public function __construct(string $clientId, string $message, string $command)
@@ -27,6 +29,13 @@ class ShutdownController extends Controller
 
     public function shutdown()
     {
+        if (isset($_SESSION['gateway_mac'])) {
+            try {
+                Gateway::closeCurrentClient();
+            } catch (\Exception $exception) {
+                Log::error($exception->getMessage());
+            }
+        }
 
     }
 

application/route/Api.php

@@ -33,7 +33,7 @@ class Api
         $this->add('08', 'business\port\OnlineController@online');
         $this->add('09', 'business\port\OfflineController@offline');
 
-//        $this->add('0F', 'business\power\ShutdownController@shutdown');
+        $this->add('0F', 'business\power\ShutdownController@shutdown');
         $this->add('0A', 'setting\SettingController@get');
 
         $this->add('31', 'card\PayRuleController@get');

lib/cdz/order/state/WaitingState.php

@@ -142,7 +142,7 @@ class WaitingState extends State
         ];
         //更新订单状态
         $startCapacity = $this->order->getStartCapacity();
-        if ($startCapacity !== -2 && $startCapacity > 0) {
+        if ($startCapacity !== -2 && $startCapacity >= 0) {
             $update['start_capacity'] = (int)$this->order->getStartCapacity();
         }
         $orderModel = new OrderModel();

src/BroadcastToAgent.php

@@ -10,6 +10,7 @@ namespace Src;
 
 
 use Lib\Gateway;
+use Lib\log\Log;
 
 class BroadcastToAgent
 {
@@ -26,11 +27,19 @@ class BroadcastToAgent
 
     public function broadcast(array $data)
     {
+        Log::debug('agent_id' . $this->agentId);
+        $redis = \Events::getRedis();
+        $superAgentIds = $redis->hGetAll('cdz:super_agent_id:hash');
+        foreach ($superAgentIds as $id => $value) {
+            Gateway::sendToUid($id, json_encode($data));
+        }
+
         if ($this->agentId !== '') {
             Gateway::sendToUid($this->agentId, json_encode($data));
             return true;
 
         } else {
+            Log::error('agent_id can not find');
             return false;
         }
     }