📄 idsoccli.pas

📁 乐都SQL版传奇全套代码,绝对可编译
💻 PAS
字号:
//DB 都没搞懂 我要了也没用  王清 QQ286251099 2008.3.23 
unit IDSocCli;

interface

uses
  Windows, Messages, SysUtils, Classes, Graphics, mylist,
  Controls, Forms, Dialogs, StdCtrls, ExtCtrls, Grobal2, DBShare, IniFiles,
  D7ScktComp;
type
  TFrmIDSoc = class(TForm)
    IDSocket: TClientSocket;
    Timer1: TTimer;
    KeepAliveTimer: TTimer;
    procedure FormCreate(Sender: TObject);
    procedure FormDestroy(Sender: TObject);
    procedure Timer1Timer(Sender: TObject);
    procedure IDSocketError(Sender: TObject; Socket: TCustomWinSocket;
      ErrorEvent: TErrorEvent; var ErrorCode: Integer);
    procedure IDSocketRead(Sender: TObject; Socket: TCustomWinSocket);
    procedure KeepAliveTimerTimer(Sender: TObject);
  private
    GlobaSessionList: TMyList;                                //0x2D8
    m_sSockMsg: string;                                     //0x2E4
    sIDAddr: string;
    nIDPort: Integer;
    procedure ProcessSocketMsg;
    procedure ProcessAddSession(sData: string);
    procedure ProcessDelSession(sData: string);
    procedure ProcessGetOnlineCount(sData: string);

    procedure SendKeepAlivePacket();
    { Private declarations }
  public
    procedure SendSocketMsg(wIdent: Word; sMsg: string);
    function CheckSession(sAccount, sIPaddr: string;
      nSessionID: Integer  ): Boolean;
    function CheckSessionLoadRcd(sAccount, sIPaddr: string; nSessionID: Integer;
      var boFoundSession: Boolean ): Boolean;
    function SetSessionSaveRcd(sAccount: string): Boolean;
    procedure SetGlobaSessionNoPlay(nSessionID: Integer);
    procedure SetGlobaSessionPlay(nSessionID: Integer);
    function GetGlobaSessionStatus(nSessionID: Integer): Boolean;
    procedure CloseSession(sAccount: string; nSessionID: Integer); //关闭全局会话
    procedure OpenConnect();
    procedure CloseConnect();
    function GetSession(sAccount, sIPaddr: string): Boolean;


    { Public declarations }
  end;

var
  FrmIDSoc                              : TFrmIDSoc;

implementation

uses HUtil32, UsrSoc;



{$R *.DFM}

procedure TFrmIDSoc.FormCreate(Sender: TObject);
//0x004A128C
var
  Conf                                  : TIniFile;
begin
  Conf := TIniFile.Create(sConfFileName);
  if Conf <> nil then
  begin
    sIDAddr := Conf.ReadString('Server', 'IDSAddr', sIDServerAddr);
    nIDPort := Conf.ReadInteger('Server', 'IDSPort', nIDServerPort);
    Conf.Free;
  end;
  GlobaSessionList := TMyList.Create;
  m_sSockMsg := '';
end;

procedure TFrmIDSoc.FormDestroy(Sender: TObject);
//0x004A13C8
var
  i                                     : Integer;
  GlobaSessionInfo                      : pTGlobaSessionInfo;
begin
  for i := 0 to GlobaSessionList.Count - 1 do
  begin
    GlobaSessionInfo := GlobaSessionList.Items[i];

    Dispose(GlobaSessionInfo);
  end;
  GlobaSessionList.Free;
end;

procedure TFrmIDSoc.Timer1Timer(Sender: TObject);           //0x004A18C8
begin
  if (IDSocket.Address <> '') and not (IDSocket.Active) then
    IDSocket.Active := True;
end;

procedure TFrmIDSoc.IDSocketRead(Sender: TObject;
  Socket: TCustomWinSocket);                                //004A183C
begin
  m_sSockMsg := m_sSockMsg + Socket.ReceiveText;
  if Pos(')', m_sSockMsg) > 0 then
  begin
    ProcessSocketMsg();
  end;
end;
//004A1958

procedure TFrmIDSoc.ProcessSocketMsg();
var
  sScoketText                           : string;
  sData                                 : string;
  sCode                                 : string;
  sBody                                 : string;
  nIdent                                : Integer;
begin
  sScoketText := m_sSockMsg;
  while (Pos(')', sScoketText) > 0) do
  begin
    sScoketText := ArrestStringEx(sScoketText, '(', ')', sData);
    if sData = '' then
      break;
    sBody := GetValidStr3(sData, sCode, ['/']);
    nIdent := Str_ToInt(sCode, 0);
    case nIdent of
      SS_OPENSESSION {100}: ProcessAddSession(sBody);
      SS_CLOSESESSION {101}: ProcessDelSession(sBody);
      SS_KEEPALIVE {104}: ProcessGetOnlineCount(sBody);
    end;
  end;
  m_sSockMsg := sScoketText;
end;

procedure TFrmIDSoc.SendSocketMsg(wIdent: Word; sMsg: string);
//004A1C1C
var
  sSendText                             : string;
resourcestring
  sFormatMsg                            = '(%d/%s)';
begin
  sSendText := format(sFormatMsg, [wIdent, sMsg]);
  if IDSocket.Active then
    IDSocket.Socket.SendText(sSendText);
end;
//004A1718

function TFrmIDSoc.CheckSession(sAccount, sIPaddr: string;
  nSessionID: Integer  ): Boolean;
var
  i                                     : Integer;
  GlobaSessionInfo                      : pTGlobaSessionInfo;
begin
  g_CheckCode.dwThread0 := 1001800;
  Result := False;
  try
    for i := 0 to GlobaSessionList.Count - 1 do
    begin
      GlobaSessionInfo := GlobaSessionList.Items[i];
      if GlobaSessionInfo <> nil then
      begin
        //if (GlobaSessionInfo.sAccount = sAccount) and (GlobaSessionInfo.sIPaddr = sIPaddr) then begin
        if (GlobaSessionInfo.sAccount = sAccount) and (GlobaSessionInfo.nSessionID= nSessionID) then
        begin
          Result := True;
          break;
        end;
      end;
    end;
  except
  End;
  g_CheckCode.dwThread0 := 1001801;
end;

function TFrmIDSoc.CheckSessionLoadRcd(sAccount, sIPaddr: string; nSessionID:
  Integer; var boFoundSession: Boolean): Boolean;
var
  i                                     : Integer;
  GlobaSessionInfo                      : pTGlobaSessionInfo;
begin
  g_CheckCode.dwThread0 := 1001900;
  Result := False;
  boFoundSession := False;
  for i := 0 to GlobaSessionList.Count - 1 do
  begin
    GlobaSessionInfo := GlobaSessionList.Items[i];
    if GlobaSessionInfo <> nil then
    begin
      if (GlobaSessionInfo.sAccount = sAccount) and (GlobaSessionInfo.nSessionID= nSessionID) then
      begin
        boFoundSession := True;
        if not GlobaSessionInfo.boLoadRcd then
        begin
          GlobaSessionInfo.boLoadRcd := True;
          Result := True;
        end;
        break;
      end;
    end;
  end;
  g_CheckCode.dwThread0 := 1001901;
end;

function TFrmIDSoc.SetSessionSaveRcd(sAccount: string): Boolean;
var
  i                                     : Integer;
  GlobaSessionInfo                      : pTGlobaSessionInfo;
begin
  g_CheckCode.dwThread0 := 1002500;
  Result := False;
  for i := 0 to GlobaSessionList.Count - 1 do
  begin
    GlobaSessionInfo := GlobaSessionList.Items[i];
    if GlobaSessionInfo <> nil then
    begin
      if (GlobaSessionInfo.sAccount = sAccount) then
      begin
        GlobaSessionInfo.boLoadRcd := False;
        Result := True;
      end;
    end;
  end;
  g_CheckCode.dwThread0 := 1002501;
end;

//004A15E0

procedure TFrmIDSoc.SetGlobaSessionNoPlay(nSessionID: Integer);
var
  i                                     : Integer;
  GlobaSessionInfo                      : pTGlobaSessionInfo;
begin
  g_CheckCode.dwThread0 := 1002300;
  for i := 0 to GlobaSessionList.Count - 1 do
  begin
    GlobaSessionInfo := GlobaSessionList.Items[i];
    if GlobaSessionInfo <> nil then
    begin
      if (GlobaSessionInfo.nSessionID = nSessionID) then
      begin
        GlobaSessionInfo.boStartPlay := False;
        break;
      end;
    end;
  end;
  g_CheckCode.dwThread0 := 1002301;
end;

//004A1644

procedure TFrmIDSoc.SetGlobaSessionPlay(nSessionID: Integer);
var
  i                                     : Integer;
  GlobaSessionInfo                      : pTGlobaSessionInfo;
begin
  g_CheckCode.dwThread0 := 1002400;
  for i := 0 to GlobaSessionList.Count - 1 do
  begin
    GlobaSessionInfo := GlobaSessionList.Items[i];
    if GlobaSessionInfo <> nil then
    begin
      if (GlobaSessionInfo.nSessionID = nSessionID) then
      begin
        GlobaSessionInfo.boStartPlay := True;
        break;
      end;
    end;
  end;
  g_CheckCode.dwThread0 := 1002401;
end;

function TFrmIDSoc.GetGlobaSessionStatus(nSessionID: Integer): Boolean;
//004A16A8
var
  i                                     : Integer;
  GlobaSessionInfo                      : pTGlobaSessionInfo;
begin
  Result := False;
  for i := 0 to GlobaSessionList.Count - 1 do
  begin
    GlobaSessionInfo := GlobaSessionList.Items[i];
    if GlobaSessionInfo <> nil then
    begin
      if (GlobaSessionInfo.nSessionID = nSessionID) then
      begin
        Result := GlobaSessionInfo.boStartPlay;
        break;
      end;
    end;
  end;
end;

procedure TFrmIDSoc.CloseSession(sAccount: string; nSessionID: Integer);
//0x4A1500
var
  i                                     : Integer;
  GlobaSessionInfo                      : pTGlobaSessionInfo;
begin
  for i := 0 to GlobaSessionList.Count - 1 do
  begin
    GlobaSessionInfo := GlobaSessionList.Items[i];
    if GlobaSessionInfo <> nil then
    begin
      if (GlobaSessionInfo.nSessionID = nSessionID) then
      begin
        if GlobaSessionInfo.sAccount = sAccount then
        begin
          Dispose(GlobaSessionInfo);
          GlobaSessionList.Delete(i);
          break;
        end;
      end;
    end;
  end;
end;

procedure TFrmIDSoc.IDSocketError(Sender: TObject;
  Socket: TCustomWinSocket; ErrorEvent: TErrorEvent;
  var ErrorCode: Integer);
begin
  ErrorCode := 0;
  Socket.Close;
end;



procedure TFrmIDSoc.ProcessAddSession(sData: string);
//004A1A80
var
  sAccount, s10, s14, s18, sIPaddr,sGateIP      : string;
  GlobaSessionInfo                    : pTGlobaSessionInfo;

begin
  g_CheckCode.dwThread0 := 1001600;
  //OutMainMessage('Add: ' + sData);
  sData := GetValidStr3(sData, sAccount, ['/']);
  sData := GetValidStr3(sData, s10, ['/']); //sessionid
  sData := GetValidStr3(sData, s14, ['/']); //paycost
  sData := GetValidStr3(sData, s18, ['/']); //dbindex
  sData := GetValidStr3(sData, sIPaddr, ['/']);
  sData := GetValidStr3(sData, sGateIP, ['/']);  //网关ip
  New(GlobaSessionInfo);
 // GlobaSessionInfo.Dbindex:=str_Toint(s18,0);
  GlobaSessionInfo.sAccount := sAccount;
  GlobaSessionInfo.sGateIp:=sGateIP;
  GlobaSessionInfo.sIPaddr := sIPaddr;
  GlobaSessionInfo.nSessionID := Str_ToInt(s10, 0);
  GlobaSessionInfo.n24 := Str_ToInt(s14, 0);
  GlobaSessionInfo.boStartPlay := False;
  GlobaSessionInfo.boLoadRcd := False;
  GlobaSessionInfo.dwAddTick := GetTickCount();
  GlobaSessionInfo.dAddDate := Now();
  GlobaSessionList.Add(GlobaSessionInfo);
  g_CheckCode.dwThread0 := 1001601;
end;

procedure TFrmIDSoc.ProcessDelSession(sData: string);       //004A1B84
var
  sAccount                              : string;
  i, nSessionID                         : Integer;
  GlobaSessionInfo                      : pTGlobaSessionInfo;
begin
  g_CheckCode.dwThread0 := 1001700;
  //OutMainMessage('Del: ' + sData);
  sData := GetValidStr3(sData, sAccount, ['/']);
  nSessionID := Str_ToInt(sData, 0);
  for i := 0 to GlobaSessionList.Count - 1 do
  begin
    GlobaSessionInfo := GlobaSessionList.Items[i];
    if GlobaSessionInfo <> nil then
    begin
      if (GlobaSessionInfo.nSessionID = nSessionID) and
        (GlobaSessionInfo.sAccount = sAccount) then
      begin
        Dispose(GlobaSessionInfo);
        GlobaSessionList.Delete(i);
        break;
      end;
    end;
  end;
  g_CheckCode.dwThread0 := 1001701;
end;

procedure TFrmIDSoc.SendKeepAlivePacket;
begin
  if IDSocket.Socket.Connected then
  begin
    IDSocket.Socket.SendText('(' + IntToStr(SS_SERVERINFO) + '/' + sServerName +
      '/' + '99' + '/' + IntToStr(FrmUserSoc.GetUserCount) + ')');
  end;

end;

procedure TFrmIDSoc.CloseConnect;
begin
  KeepAliveTimer.Enabled := False;
  IDSocket.Active := False;
end;

function TFrmIDSoc.GetSession(sAccount, sIPaddr: string): Boolean;
var
  i                                     : Integer;
  GlobaSessionInfo                      : pTGlobaSessionInfo;
begin
  g_CheckCode.dwThread0 := 1002200;
  Result := False;
  for i := 0 to GlobaSessionList.Count - 1 do
  begin
    GlobaSessionInfo := GlobaSessionList.Items[i];
    if GlobaSessionInfo <> nil then
    begin
      if (GlobaSessionInfo.sAccount = sAccount) and (GlobaSessionInfo.sIPaddr =
        sIPaddr) then
      begin
        Result := True;
        break;
      end;
    end;
  end;
  g_CheckCode.dwThread0 := 1002201;
end;

procedure TFrmIDSoc.OpenConnect;
begin
  KeepAliveTimer.Enabled := True;
  IDSocket.Active := False;
  IDSocket.Address := sIDServerAddr;
  IDSocket.Port := nIDServerPort;
  IDSocket.Active := True;
end;

procedure TFrmIDSoc.KeepAliveTimerTimer(Sender: TObject);
begin
  SendKeepAlivePacket();
end;

procedure TFrmIDSoc.ProcessGetOnlineCount(sData: string);
begin

end;
{
function TFrmIDSoc.GetDbindex(nsessionid: Integer): Integer;
var
  i                                     : Integer;
  GlobaSessionInfo                      : pTGlobaSessionInfo;
begin
  g_CheckCode.dwThread0 := 1002300;
  Result:=0;
  for i := 0 to GlobaSessionList.Count - 1 do
  begin
    GlobaSessionInfo := GlobaSessionList.Items[i];
    if GlobaSessionInfo <> nil then
    begin
      if (GlobaSessionInfo.nSessionID = nSessionID) then
      begin
        Result:=GlobaSessionInfo.Dbindex;
        break;
      end;
    end;
  end;
  g_CheckCode.dwThread0 := 1002301;
end;
}
end.
⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -