QQ 聊天记录解密类 DELPHI版

以前写的一个QQ聊天记录解密时写的，加密解密就是麻烦

如需要QQTEA单元，参见上一篇文章

{
/----------------------------------------------|
 |               QQ消息解密类                  |
 |             Writeted By RYYD                |
 |             Mail:ryyd@163.com               |
 ----------------------------------------------/
}

unit QQMSG;

interface

uses ActiveX,Classes,Sysutils,QQTEA,Windows,StdCtrls,comobj,Axctrls,MD5,Dialogs;

type
  IntType=array of Integer;
  PerMSG=record
    Content:string;
    Time:TDateTime;
    Name:string;
    Group:string;
  end;
  MSGType=(C2CMsg,SysMsg,DiscMsg,GroupMsg,TempSessionMsg,MobileMsg);
  TQQMSG=class
    private
      QQ:string;//用来存储QQ号
      FileName:string;//用来存储消息文件名
      RootStorage:IStorage; //用来储存结构化文件的根文件
      Key:ByteType;//全局解密KEY
      QQHash:ByteType; //存储QQ号的Hash Byte数组
      MatrixData:ByteType;//存储Matrix.db的内容
      C2CMsgList:TStrings;//好友列表
      SysMsgList:TStrings;//系统信息列表
      DiscMsgList:TStrings;//组列表
      GroupMsgList:TStrings;//群列表
      TempSessionMsgList:TStrings;//临时消息列表
      MobileMsgList:TStrings;//移动消息列表


      procedure GetMatrixData;//得到MatrixData数据
      function GetRealByte(Des:ByteType):ByteType; //得到一个Byte数组去除了0后的真实数组
      procedure GetKey;//得到全局解密KEY
      procedure GetQQHash;//得到QQ号的Hash Byte数组;
      function GetByteString(InByte:ByteType):string;overload;//得到二进制BYTE数组的字符串形式
      function GetByteString(InByte:ByteType;InBegin:Integer;InLen:Integer):string;overload;//得到二进制BYTE数组的字符串形式
      procedure GetRootStorage;//得到根文件
      procedure GetList;//得到所有的列表
      function GetBS(InByte:ByteType):string;
      function GetIntegerFromFourByte(a1:Byte;a2:Byte;a3:Byte;a4:Byte):Integer;
      function GetRealMessage(InByte:ByteType;InMSGType:MSGType):PerMSG;//从解密后的某条Byte里获取完整的消息
    public
      function GetMSG(InMSGType:MSGtype;Number:string):string;//得到全部的消息;
      procedure Print;
      constructor Create(InFileName:string;InQQ:string); //构造函数,传入参数为结构化文件的文件名以及QQ号码
  end;
implementation

uses MainUnit;

function TQQMSG.GetRealMessage(InByte: ByteType;InMSGType: MSGType):PerMSG;
var
  DateTime:TDateTime;
  Position:Integer;
  NameLength:Integer;
  Name:string;
  MSGLength:Integer;
  MSG:string;
  GroupLength:Integer;
  Group:string;
  TempByteData:ByteType;
begin
  Position:=4;
  DateTime:=EncodeDate(1970,1,1)+EncodeTime(0,0,0,0);
  DateTime:=DateTime+GetIntegerFromFourByte(InByte[0],InByte[1],InByte[2],InByte[3])/24/3600;
  case InMSGType of
    C2CMsg:Position:=Position+1;
    SysMsg:Position:=Position+4;
    DiscMsg:Position:=Position+1;
    GroupMsg:Position:=Position+8;
    TempSessionMsg:Position:=Position+9;
    MobileMsg:Position:=Position+1;
  end;
  if InMSGType=TempSessionMsg then
  begin
    GroupLength:=GetIntegerFromFourByte(InByte[Position],InByte[Position+1],InByte[Position+2],InByte[Position+3]);
    Position:=Position+4;
    //Group:=GetByteString(InByte,Position,GroupLength);
    SetLength(TempByteData,GroupLength);
    CopyMemory(@TempByteData[0],@InByte[Position],GroupLength);
    Group:=GetBS(TempByteData);
    Position:=Position+GroupLength;  
  end;
  NameLength:=GetIntegerFromFourByte(InByte[Position],InByte[Position+1],InByte[Position+2],InByte[Position+3]);
  Position:=Position+4;
  //Name:=GetByteString(InByte,Position,NameLength);
  SetLength(TempByteData,NameLength);
  CopyMemory(@TempByteData[0],@InByte[Position],NameLength);
  Name:=GetBS(TempByteData);
  Position:=Position+NameLength;
  MSGLength:=GetIntegerFromFourByte(InByte[Position],InByte[Position+1],InByte[Position+2],InByte[Position+3]);
  Position:=Position+4;
  //MSG:=GetByteString(InByte,Position,MSGLength);
  SetLength(TempByteData,MSGLength);
  CopyMemory(@TempByteData[0],@InByte[Position],MSGLength);
  MSG:=GetBS(TempByteData);
  Result.Content:=MSG;
  Result.Time:=DateTime;
  Result.Name:=Name;
  Result.Group:=Group;
end;

function TQQMSG.GetIntegerFromFourByte(a1: Byte; a2: Byte; a3: Byte; a4: Byte):Integer;
var
  TempByte:array[1..4] of Byte;
begin
  TempByte[1]:=a1;
  TempByte[2]:=a2;
  TempByte[3]:=a3;
  TempByte[4]:=a4;
  CopyMemory(@Result,@TempByte[1],4);
end;

function TQQMSG.GetBS(InByte: ByteType):string;
var
  i: Integer;
begin
  for i := 0 to Length(InByte) - 1 do Result:=Result+' '+IntToStr(InByte[i]);
end;

function TQQMSG.GetMSG(InMSGType: MSGType; Number: string):string;
var
  OpenString:string;
  TempStorage:IStorage;
  MSGStorage:IStorage;
  TempStream:IStream;
  TempOutOleStream:TOlestream;
  TempOutStream:TMemoryStream;
  Index,Data:ByteType;
  FileLen,Num:Integer;
  Pos,Len:array of Integer;
  i,t:Integer;
  TempOutString:string;
  TempData,TempMSG:ByteType;
  TempDecrypter:TQQTEA;
  Position,EndPosition:Integer;
  j: Integer;
  TempDateTime:TDateTime;
  PerM:PerMSG;
  TempStringList:TStrings;
  TempString:string;
begin
  TempOutString:='';
  TempDecrypter:=TQQTEA.Create;
  case InMSGType of
    C2CMsg:OpenString:='C2CMsg';
    SysMsg:OpenString:='SysMsg';
    DiscMsg:OpenString:='DiscMsg';
    GroupMsg:OpenString:='GroupMsg';
    TempSessionMsg:OpenString:='TempSessionMsg';
    MobileMsg:OpenString:='MobileMsg';
  end;
  
  OleCheck(RootStorage.OpenStorage(StringToOleStr(OpenString),nil,STGM_READWRITE or STGM_SHARE_EXCLUSIVE,nil,0,TempStorage));
  OleCheck(TempStorage.OpenStorage(StringToOleStr(Number),nil,STGM_READWRITE or STGM_SHARE_EXCLUSIVE,nil,0,MSGStorage));
  OleCheck(MSGStorage.OpenStream(StringToOleStr('Index.msj'),nil,STGM_READWRITE or STGM_SHARE_EXCLUSIVE,0,TempStream));
  TempOutOleStream:=TOleStream.Create(TempStream);
  TempOutStream:=TMemoryStream.Create;
  TempOutStream.Size:=0;
  TempOutStream.CopyFrom(TempOutOleStream,TempOutOleStream.Size);
  TempOutOleStream.Free;
  TempOutStream.Position:=0;
  SetLength(Index,TempOutStream.Size);
  for i:=0 to length(Index)-1 do Index[i]:=0;
  TempOutStream.ReadBuffer(Index[0],TempOutStream.size);
  TempOutStream.Free;
  
  OleCheck(MSGStorage.OpenStream(StringToOleStr('Data.msj'),nil,STGM_READWRITE or STGM_SHARE_EXCLUSIVE,0,TempStream));
  TempOutOleStream:=TOleStream.Create(TempStream);
  TempOutStream:=TMemoryStream.Create;
  TempOutStream.Size:=0;
  TempOutStream.CopyFrom(TempOutOleStream,TempOutOleStream.Size);
  TempOutOleStream.Free;
  TempOutStream.Position:=0;
  SetLength(Data,TempOutStream.Size);
  for i:=0 to length(Data)-1 do Data[i]:=0;
  TempOutStream.ReadBuffer(Data[0],TempOutStream.size);
  TempOutStream.Free;

  FileLen:=Length(Index);
  Num:=Trunc(FileLen/4);
  SetLength(Pos,Num+1);
  t:=0;i:=0;
  while i<Length(Index) do
  begin
    CopyMemory(@pos[t],@Index[i],4);
    i:=i+4;
    t:=t+1;
  end;
  FileLen:=Length(Data);
  SetLength(Len,Num);
  pos[Num]:=fileLen;
  for i:=0 to Num-1 do
  begin
    len[i]:= pos[i+1]-pos[i];
  end;

  TempStringList:=TStringList.Create;
  for i :=0 to Num - 1 do
  begin
    TempString:='';
    Position:=Pos[i];
    SetLength(TempData,Len[i]);
    CopyMemory(@TempData[0],@Data[Position],Len[i]);
    TempMSG:=TempDecrypter.DeCrypt(TempData,Key);
    PerM:=GetRealMessage(TempMSG,InMSGType);
    TempString:=TempString+DateTimeToStr(PerM.Time);
    TempString:=TempString+#13+#10;
    TempString:=TempString+PerM.Name+': '+PerM.Content;
    TempStringList.Add(TempString);
    TempStringList.Add('');
  end;
  Result:=TempStringList.Text;
  TempDecrypter.Destroy;
end;

procedure TQQMSG.GetList;
var
  EnumStatStg:IEnumStatStg;
  StatStg:TStatStg;
  TempStorage:IStorage;
begin
  OleCheck(RootStorage.OpenStorage(StringToOleStr('C2CMsg'),nil,STGM_READWRITE or STGM_SHARE_EXCLUSIVE,nil,0,TempStorage));
  OleCheck(TempStorage.EnumElements(0,nil,0,EnumStatStg));
  while EnumStatStg.Next(1,StatStg,nil)=S_Ok do
  begin
    C2CMsgList.Add(StatStg.pwcsName);
  end;

  OleCheck(RootStorage.OpenStorage(StringToOleStr('SysMsg'),nil,STGM_READWRITE or STGM_SHARE_EXCLUSIVE,nil,0,TempStorage));
  OleCheck(TempStorage.EnumElements(0,nil,0,EnumStatStg));
  while EnumStatStg.Next(1,StatStg,nil)=S_Ok do
  begin
    SysMsgList.Add(StatStg.pwcsName);
  end;

  {OleCheck(RootStorage.OpenStorage(StringToOleStr('DiscMsg'),nil,STGM_READWRITE or STGM_SHARE_EXCLUSIVE,nil,0,TempStorage));
  OleCheck(TempStorage.EnumElements(0,nil,0,EnumStatStg));
  while EnumStatStg.Next(1,StatStg,nil)=S_Ok do
  begin
    DiscMsgList.Add(StatStg.pwcsName);
  end;           }

  OleCheck(RootStorage.OpenStorage(StringToOleStr('GroupMsg'),nil,STGM_READWRITE or STGM_SHARE_EXCLUSIVE,nil,0,TempStorage));
  OleCheck(TempStorage.EnumElements(0,nil,0,EnumStatStg));
  while EnumStatStg.Next(1,StatStg,nil)=S_Ok do
  begin
    GroupMsgList.Add(StatStg.pwcsName);
  end;

  OleCheck(RootStorage.OpenStorage(StringToOleStr('TempSessionMsg'),nil,STGM_READWRITE or STGM_SHARE_EXCLUSIVE,nil,0,TempStorage));
  OleCheck(TempStorage.EnumElements(0,nil,0,EnumStatStg));
  while EnumStatStg.Next(1,StatStg,nil)=S_Ok do
  begin
    TempSessionMsgList.Add(StatStg.pwcsName);
  end;   
end;

procedure TQQMSG.GetRootStorage;
begin
  if FileExists(FileName) then
  begin
    OleCheck(StgOpenStorage(StringToOleStr(FileName),nil,STGM_READWRITE or STGM_SHARE_EXCLUSIVE,nil,0,RootStorage));
  end;
end;

function TQQMSG.GetByteString(InByte: ByteType):string;
var
  TempStringStream:TStringStream;
begin
  TempStringStream:=TStringStream.Create('');
  TempStringStream.WriteBuffer(InByte[0],Length(InByte));
  Result:=TempStringStream.DataString;
  TempStringStream.Free;
end;

function TQQMSG.GetByteString(InByte: ByteType; InBegin: Integer; InLen: Integer):string;
var
  TempStringStream:TStringStream;
begin
  TempStringStream:=TStringStream.Create('');
  TempStringStream.WriteBuffer(InByte[InBegin],InLen);
  Result:=TempStringStream.DataString;
  TempStringStream.Free;
end;

procedure TQQMSG.Print;
var
  i:Integer;
  TempString:string;
begin
  for i := 0 to Length(Key) - 1 do
  begin
    TempString:=TempString+inttostr(Key[i])+' ';
  end;
  MainUnit.MainForm.Caption:=TempString;
end;

constructor TQQMSG.Create(InFileName: string; InQQ: string);
begin
  C2CMsgList:=TStringList.Create;
  SysMsgList:=TStringList.Create;
  DiscMsgList:=TStringList.Create;
  GroupMsgList:=TStringList.Create;
  TempSessionMsgList:=TStringList.Create;
  MobileMsgList:=TStringList.Create;
  QQ:=InQQ;
  FileName:=InFileName;
  GetRootStorage;
  GetList;
  GetKey;
end;

function TQQMSG.GetRealByte(Des:ByteType):ByteType;
var
  l:Integer;
begin
  for l := 0 to Length(Des) - 1 do
  begin
    if Des[l]=0 then Break;
  end;
  SetLength(Des,l);
  SetLength(Result,length(Des));
  CopyMemory(@Result[0],@Des[0],Length(Des));
end;

procedure TQQMSG.GetQQHash;
var
  TempMD5:MD5Digest;
begin
  TempMD5:=MD5String(QQ);
  SetLength(QQHash,Length(TempMD5));
  CopyMemory(@QQHash[0],@TempMD5[0],Length(TempMD5));  
end;

procedure TQQMSG.GetKey;
var
  Len,Len1,Len2:Integer;
  bl:Boolean;
  i,j:Integer;
  typeB,xor1,xor2:Byte;
  dataT,TempByte:ByteType;
  TempDecrypter:TQQTEA;
begin
  GetQQHash;
  GetMatrixData;
  TempDecrypter:=TQQTEA.Create;
  Len:=Length(MatrixData);
  if ((Len<6) or (MatrixData[0] <> $51) or (MatrixData[1] <> $44)) then
  begin
    Key:=nil;
    Exit;
  end;
  if Len >= 32768 then
  begin
    Key:=nil;
    Exit;
  end;
  bl:=false;
  i:=6;
  while i<Len do
  begin
    bl:=False;
    typeb:=MatrixData[i];
    i:=i+1;
    if (i + 2) > len then Break;
    Len1:=MatrixData[i]+MatrixData[i+1]*256;
    xor1:=Byte(MatrixData[i] xor MatrixData[i+1]);
    i:=i+2;
    if (i+len1)>Len then Break;
    for j := 0 to Len1-1do
    begin
      MatrixData[i+j]:=Byte(not(MatrixData[i+j] xor xor1));
    end;
    if (Len1=3) and (MatrixData[i]=$43) and (MatrixData[i+1]=$52) and (MatrixData[i+2]=$4B) then
    begin
      bl:=true;
    end;
    i:=i+len1;
    if typeB > 7 then break;
    if (i + 4)> len then break;
    len2:= MatrixData[i] + MatrixData[i + 1] * 256 + MatrixData[i + 2] * 256 * 256 + MatrixData[i + 3] * 256 * 256 * 256;
    xor2:=byte(MatrixData[i] xor MatrixData[i + 1]);
    i:=i+4;
    if (i + len2) > len then break;
    if ((typeB=6) or (typeB=7)) then
    begin
      for j := 0 to len2-1 do
      begin
        MatrixData[i+j]:=Byte(not(MatrixData[i+j] xor xor2));
      end;
    end;
    if (bl and (len2=$20)) then
    begin
      SetLength(dataT,len2);
      for j := 0 to Len2-1 do dataT[j]:=MatrixData[i+j];
      TempByte:=TempDecrypter.Decrypt(dataT,QQHash);
      SetLength(Key,Length(TempByte));
      CopyMemory(@Key[0],@TempByte[0],Length(TempByte));
      Exit; 
    end;
    i:=i+len2;
  end;
  if (i<>len) then
  begin
    Key:=nil;
    exit;
  end;
end;

procedure TQQMSG.GetMatrixData;
var
  i:Integer;
  MatrixStroage:IStorage;
  MatrixDBFileStream:IStream;
  TempOutOleStream:TOlestream;
  TempOutStream:TMemoryStream;
begin
  OleCheck(RootStorage.OpenStorage(StringToOleStr('Matrix'),nil,STGM_READWRITE or STGM_SHARE_EXCLUSIVE,nil,0,MatrixStroage));
  OleCheck(MatrixStroage.OpenStream(StringToOleStr('Matrix.db'),nil,STGM_READWRITE or STGM_SHARE_EXCLUSIVE,0,MatrixDBFileStream));
  TempOutOleStream:=TOleStream.Create(MatrixDBFileStream);
  TempOutStream:=TMemoryStream.Create;
  TempOutStream.Size:=0;
  TempOutStream.CopyFrom(TempOutOleStream,TempOutOleStream.Size);
  TempOutOleStream.Free;
  TempOutStream.Position:=0;
  SetLength(MatrixData,TempOutStream.Size);
  for i:=0 to length(MatrixData)-1 do MatrixData[i]:=0;
  TempOutStream.ReadBuffer(MatrixData[0],TempOutStream.size);
  TempOutStream.Free;
end;

end.