cmd_key support added

Author: anwarx4u

src/Libs/Services/Connect.php

@@ -42,24 +42,31 @@ public static function connect(ZKTeco $self)
 
             // If data is received, process it.
             if (strlen($self->_data_recv) > 0) {
-                // Unpack the received data to extract session ID.
                 $u = unpack('H2h1/H2h2/H2h3/H2h4/H2h5/H2h6', substr($self->_data_recv, 0, 8));
 
-                // Convert session ID from hex to decimal.
-                $session = hexdec($u['h6'].$u['h5']);
-
-                // If session ID is empty, return false.
+                $session = hexdec($u['h6'] . $u['h5']);
                 if (empty($session)) {
                     return false;
                 }
-
-                // Set the session ID in the ZKTecoPhp instance.
                 $self->_session_id = $session;
-
-                // Check if the received data is valid.
-                return Util::checkValid($self->_data_recv);
+                $result = Util::checkValid($self->_data_recv);
+                if ($result == Util::CMD_ACK_UNAUTH) {
+                    $command_string = Util::makeCommKey($self->_password, $self->_session_id);
+                    $buf = Util::createHeader(Util::CMD_ACK_AUTH, 0, $self->_session_id, $reply_id, $command_string);
+                    socket_sendto($self->_zkclient, $buf, strlen($buf), 0, $self->_ip, $self->_port);
+                    @socket_recvfrom($self->_zkclient, $self->_data_recv, 1024, 0, $self->_ip, $self->_port);
+                    if (strlen($self->_data_recv) > 0) {
+                        $u = unpack('H2h1/H2h2/H2h3/H2h4/H2h5/H2h6', substr($self->_data_recv, 0, 8));
+                        $session = hexdec($u['h6'].$u['h5']);
+                        if (empty($session)) {
+                            return false;
+                        }
+                        $self->_session_id = $session;
+                        return Util::checkValid($self->_data_recv);
+                    }
+                }
+                return $result;
             } else {
-                // If no data is received, return false.
                 return false;
             }
         } catch (ErrorException $e) {

src/Libs/Services/Util.php

@@ -28,6 +28,7 @@ class Util
     const CMD_ACK_ERROR = 2001; // Return value for order perform failed
     const CMD_ACK_DATA = 2002; // Return data
     const CMD_ACK_UNAUTH = 2005; // Connection unauthorized
+    const CMD_ACK_AUTH = 1102; // Connection authorized
 
     const CMD_PREPARE_DATA = 1500; // Prepares to transmit the data
     const CMD_DATA = 1501; // Transmit a data packet
@@ -260,6 +261,35 @@ public static function createHeader($command, $chksum, $session_id, $reply_id, $
         return $buf.$command_string;
     }
 
+    public static function makeCommKey(int $key, int $session_id, $ticks= 50) {
+
+        $k = 0;
+        for($i = 0; $i < 32; $i++) {
+            if ($key & (1 << $i) ) {
+                $k = ($k << 1 | 1 );
+            } else {
+                $k = $k << 1;
+            }
+        }
+        $k += $session_id;
+        $k = pack("I",$k);
+        $k = unpack("C4", $k);
+
+        $k = pack("C4",
+            $k[1] ^ ord('Z'),
+            $k[2] ^ ord('K'),
+            $k[3] ^ ord('S'),
+            $k[4] ^ ord('O')
+        );
+
+        $k = unpack('S2', $k); // S , n , v all in php for short int
+        $k = pack('S2', $k[2], $k[1]);
+        $B = 0xff & 50;
+        $k = unpack('C4', $k);
+        $k = pack('C4', $k[1] ^ $B, $k[2] ^ $B, $B, $k[4]^ $B);
+        return $k;
+    }
+
     /**
      * Checks a returned packet to see if it returned Util::CMD_ACK_OK,
      * indicating success.

src/Libs/ZKTeco.php

@@ -32,18 +32,20 @@ class ZKTeco
     public $_section = '';
     public $_requiredPing = false;
     public $_silentPing = false;
+    public $_password = false;
 
     /**
      * @param string $ip         Device IP address.
      * @param int    $port       Port number. Default: 4370.
      * @param bool   $shouldPing should ping before device connection
      * @param int    $timeout    timeout in sec
      */
-    public function __construct(string $ip, int $port = 4370, bool $shouldPing = false, int $timeout = 25)
+    public function __construct(string $ip, int $port = 4370, bool $shouldPing = false, int $timeout = 25, $password = 0)
     {
         $this->_ip = $ip;
         $this->_port = $port;
         $this->_requiredPing = (bool) $shouldPing;
+        $this->_password = $password;
 
         $this->_zkclient = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);