Changeset 24 for trunk/Modules/ChiyuAccessControlers/UTerminalBF630.pas

Timestamp:

Nov 19, 2012, 12:31:19 PM (12 years ago)

Author:

chronos

Message:

• Opraveno: Ladění komunikačního protokolu s terminálem BF-630.

File:

• trunk/Modules/ChiyuAccessControlers/UTerminalBF630.pas (modified) (21 diffs)

trunk/Modules/ChiyuAccessControlers/UTerminalBF630.pas

@@ -6 +6 @@
 
 uses
-  Classes, SysUtils, UBinarySerializer, UCommTCPServer, UCommPin, SyncObjs, DateUtils,
-  SpecializedList, SpecializedStream, Forms, UCommTCPClient, Dialogs;
+  Classes, SysUtils, UBinarySerializer, UCommTCPServer, UCommPin, SyncObjs,
+  SpecializedList, SpecializedStream, Forms, UCommTCPClient, Dialogs, DateUtils,
+  UAccessControler, UAttendance;
 
 const
@@ -45 +46 @@
     toAntiDuressGet = $97, toSrcurityBypassGetStatus = $98,
     toTimeSet = $a6, toTimeZoneAdd = $a7, toGroupAdd = $a8,
-    toDoorSettingSet = $a9, toHolidayAdd = $aa, toDesignationAdd = $ac,
+    toDoorSettingSet = $a9, toHolidayAdd = $aa,
+    toUserAdd = $ab, toDesignationAdd = $ac, toDepartmentAdd = $ad,
     toTimeDel = $b6, toTimeZoneDel = $b7,  toGroupDel = $b8,
     toSecurityBypass = $b9, toHolidayDel = $ba,
-    toDesignationDel = $bc, toDepartmentAdd = $bd,
+    toDesignationDel = $bc, toDepartmentDel = $bd,
     toTimeDelAll = $c6, toZimeZoneDelAll = $c7, toGroupDelAll = $c8,
     toHolidayDelAll = $ca, toDesignationDelAll = $cc, toDepartmentDelAll = $cd,
@@ -59 +61 @@
   { TTerminalBF630 }
 
-  TTerminalBF630 = class
+  TTerminalBF630 = class(TAccessControler)
   private
-    FActive: Boolean;
     ReceiveData: TListByte;
     ReceiveDataThread: TListByte;
@@ -67 +68 @@
     SendTime: TDateTime;
     procedure ReceiveDataHandler(Sender: TCommPin; AList: TListByte);
-    procedure SetActive(AValue: Boolean);
     procedure WaitForBytes(Count: Integer);
+  protected
+    procedure SetActive(AValue: Boolean); override;
   public
-    Id: Integer;
     CommSocket: TCommTCPClient;
-    Pin: TCommPin;
     AccessKey: array[0..5] of Byte;
     UseAccessKey: Boolean;
@@ -80 +80 @@
     function SendPacket(Command: TTerminalOperation; Request: TListByte = nil; Response: TListByte = nil): Byte;
     function ReadDateTime: TDateTime;
-    function GetUserCount: Integer;
-    property Active: Boolean read FActive write SetActive;
-    constructor Create;
+    function GetUserCount: Integer; override;
+    function GetUser(Id: Integer; User: TUser): Boolean; override;
+    constructor Create; override;
     destructor Destroy; override;
   end;
@@ -102 +102 @@
   TVirtualTerminalBF630User = class
     Id: Integer;
-    Name: string;
+    FirstName: string;
+    SecondName: string;
   end;
 
@@ -139 +140 @@
 resourcestring
   SCommunicatiomTimeout = 'Communication timeout';
+  SWrongId = 'Wrong id';
 
 { TVirtualTerminalBF630Session }
@@ -155 +157 @@
   Command: Byte;
   ResultCode: Byte;
-  OldPos: Integer;
 begin
   with Parent do
@@ -182 +183 @@
         Dec(DataLength, 6);
       end;
-      Request.Count := 0;
-      Request.AddListPart(List, RecDataSerializer.Position, DataLength - 10);
-      OldPos := Position;
+      if (DataLength - 10) > 0 then begin
+        Request.Count := 0;
+        ReadList(Request, 0, DataLength - 10);
+      end;
       ExpectedCheckSum := 0;
-      for I := 0 to OldPos - 1 do
+      for I := 0 to Position - 1 do
         ExpectedCheckSum := (ExpectedCheckSum + List[I]) and $ff;
-      Position := OldPos;
       CheckSum := ReadByte; // byte sum from ACK to DATA
       if CheckSum <> ExpectedCheckSum then Exit;
@@ -282 +283 @@
 var
   UserId: Integer;
-  RequestStream: TMemoryStreamByte;
-  ResponseStream: TMemoryStreamByte;
-  S: TStream;
-begin
-  try
-    RequestStream := TMemoryStreamByte.Create(Request);
-    ResponseStream := TMemoryStreamByte.Create(Response);
-    //UserId := RequestStream.ReadInteger;
-    //ResponseStream.WriteInteger(UserId);
-  finally
-    RequestStream.Free;
-    ResponseStream.Free;
+  RequestSerializer: TBinarySerializer;
+  ResponseSerializer: TBinarySerializer;
+  I: Integer;
+begin
+  try
+    RequestSerializer := TBinarySerializer.Create;
+    RequestSerializer.List := Request;
+    UserId := RequestSerializer.ReadInteger;
+
+    ResponseSerializer := TBinarySerializer.Create;
+    ResponseSerializer.List := Response;
+    with ResponseSerializer do begin
+      WriteInteger(UserId);
+      WriteByte(0);
+      WriteByte(0);
+      for I := 0 to 7 do WriteByte(0);
+      with TVirtualTerminalBF630User(Users[UserId]) do
+      for I := 1 to 15 do
+        if I < Length(FirstName) then WriteByte(Ord(FirstName[I]))
+         else WriteByte(0);
+      with TVirtualTerminalBF630User(Users[UserId]) do
+      for I := 1 to 15 do
+        if I < Length(SecondName) then WriteByte(Ord(SecondName[I]))
+          else WriteByte(0);
+    end;
+  finally
+    RequestSerializer.Free;
+    ResponseSerializer.Free;
   end;
 end;
@@ -300 +317 @@
 begin
   if FActive = AValue then Exit;
-  FActive := AValue;
+  inherited;
   CommSocket.Active := AValue;
 end;
@@ -331 +348 @@
   with TVirtualTerminalBF630User(Users.AddNew(TVirtualTerminalBF630User.Create)) do begin
     Id := Users.Count;
-    Name := 'User ' + IntToStr(Id);
+    FirstName := 'User ' + IntToStr(Id);
+    SecondName := 'Second ' + IntToStr(Id);
   end;
   with TVirtualTerminalBF630User(Users.AddNew(TVirtualTerminalBF630User.Create)) do begin
     Id := Users.Count;
-    Name := 'User ' + IntToStr(Id);
+    FirstName := 'User ' + IntToStr(Id);
+    SecondName := 'Second ' + IntToStr(Id);
   end;
 end;
@@ -352 +371 @@
 destructor TVirtualTerminalBF630.Destroy;
 begin
-  CommSocket.Free;
-  Users.Free;
-  Sessions.Free;
+  Active := False;
+  FreeAndNil(CommSocket);
+  FreeAndNil(Users);
+  FreeAndNil(Sessions);
   inherited Destroy;
 end;
@@ -372 +392 @@
 procedure TTerminalBF630.SetActive(AValue: Boolean);
 begin
-  if FActive = AValue then Exit;
+  if Active = AValue then Exit;
+  inherited;
   CommSocket.Address := Address;
   CommSocket.Port := Port;
   CommSocket.Active := AValue;
-  FActive := AValue;
 end;
 
@@ -410 +430 @@
   SendDataSerializer: TBinarySerializer;
   SendDataStream: TMemoryStream;
-  ResponseData: TListByte;
+//  ResponseData: TListByte;
   ResponseSerializer: TBinarySerializer;
   CheckSum: Byte;
@@ -417 +437 @@
   DataLength: Cardinal;
   DataByte: Byte;
-  OldPos: Integer;
 begin
   try
@@ -424 +443 @@
     SendDataSerializer.List := SendData;
     SendDataStream := TMemoryStream.Create;
-    ResponseData := TListByte.Create;
+    //ResponseData := TListByte.Create;
     ResponseSerializer := TBinarySerializer.Create;
-    ResponseSerializer.List := ResponseData;
+    ResponseSerializer.List := ReceiveData;
 
     // Clear buffer
@@ -448 +467 @@
       WriteByte(Id); // TID
       WriteByte(Byte(Command));
-      if Assigned(Request) then
+      if Assigned(Request) then begin
         SendDataSerializer.WriteList(Request, 0, Request.Count);
+      end;
       if UseAccessKey then begin
         WriteByte(AccessKey[0]);
@@ -471 +491 @@
       with ReceiveData, ResponseSerializer do begin
         Endianness := enBig;
+        ExpectedCheckSum := 0;
         WaitForBytes(8);
         DataByte := ReadByte;
@@ -478 +499 @@
         if ReadByte <> Id then raise Exception.Create('Wrong Id'); // STX
         Result := ReadByte;
-        OldPos := Position;
         if Assigned(Response) then begin
+          WaitForBytes(DataLength - 10);
           Response.Count := 0;
-          WaitForBytes(DataLength - 10);
-
-          Response.AddListPart(ReceiveData, 0, DataLength - 10);
+          Response.AddListPart(ReceiveData, Position, DataLength - 10);
+          Position := Position + (DataLength - 10);
         end;
-        OldPos := Position;
-        ExpectedCheckSum := 0;
-        for I := 0 to OldPos - 1 do
+        WaitForBytes(2);
+        for I := 0 to Position - 1 do
           ExpectedCheckSum := (ExpectedCheckSum + ReceiveData[I]) and $ff;
-        Position := OldPos;
-        WaitForBytes(2);
         CheckSum := ReadByte; // byte sum from BS to DATA
-        if CheckSum <> ExpectedCheckSum then raise Exception.Create('Bad receive checksum');
-        if ReadByte <> CodeETX then raise Exception.Create('Expected ETX'); // ETX
+        if CheckSum <> ExpectedCheckSum then
+          raise Exception.Create('Bad receive checksum');
+        if ReadByte <> CodeETX then
+          raise Exception.Create('Expected ETX'); // ETX
       end;
     end;
   finally
     ResponseSerializer.Free;
-    ResponseData.Free;
+    //ResponseData.Free;
     SendDataStream.Free;
     SendDataSerializer.Free;
@@ -531 +550 @@
 end;
 
+function TTerminalBF630.GetUser(Id: Integer; User: TUser): Boolean;
+var
+  Request: TListByte;
+  RequestSerializer: TBinarySerializer;
+  Response: TListByte;
+  I: Integer;
+  Title: Integer;
+  Department: Integer;
+begin
+  try
+    Response := TListByte.Create;
+    Request := TListByte.Create;
+    RequestSerializer := TBinarySerializer.Create;
+    RequestSerializer.List := Request;
+    RequestSerializer.WriteInteger(Id);
+    SendPacket(toUserDataGet, Request, Response);
+    if Response[0] <> Id then raise Exception.Create(SWrongId);
+    Title := Response[4];
+    Department := Response[5];
+    User.FirstName := '';
+    for I := 0 to 14 do begin
+      if Response[14 + I] < 32 then Break;
+      User.FirstName := User.FirstName + Chr(Response[14 + I]);
+    end;
+    User.SecondName := '';
+    for I := 0 to 14 do begin
+      if Response[29 + I] < 32 then Break;
+      User.SecondName := User.SecondName + Chr(Response[29 + I]);
+    end;
+
+  finally
+    Request.Free;
+    RequestSerializer.Free;
+    Response.Free;
+  end;
+end;
+
 constructor TTerminalBF630.Create;
 begin
+  inherited;
   ReceiveData := TListByte.Create;
   ReceiveDataThread := TListByte.Create;
   ReceiveDataLock := TCriticalSection.Create;
   CommSocket := TCommTCPClient.Create(nil);
-  Pin := TCommPin.Create;
   Pin.Connect(CommSocket.Pin);
   Pin.OnReceive := ReceiveDataHandler;
   Timeout := 3 * OneSecond;
-  Id := 1;
+  Address := 'localhost';
+  Port := 2000;
 end;
 
 destructor TTerminalBF630.Destroy;
 begin
-  Pin.Free;
-  CommSocket.Free;
-  ReceiveDataLock.Free;
-  ReceiveDataThread.Free;
-  ReceiveData.Free;
+  Active := False;
+  FreeAndNil(CommSocket);
+  FreeAndNil(ReceiveDataLock);
+  FreeAndNil(ReceiveDataThread);
+  FreeAndNil(ReceiveData);
   inherited Destroy;
 end;