frnengn.pas

乐都SQL版传奇全套代码,绝对可编译

unit FrnEngn;

interface

uses
  Windows, Classes, SysUtils, Grobal2, ObjBase,mylist;

type
  TSaveRcd = record
    sAccount: string[15];
    sChrName: string[15];
    nSessionID: Integer;
    nReTryCount: Integer;
    PlayObject: TPlayObject;
    HumanRcd: THumDataInfo;
  end;
  pTSaveRcd = ^TSaveRcd;
  TFrontEngine = class(TThread)
    m_UserCriticalSection: TRTLCriticalSection;
    m_LoadRcdList: TMyList;                                   //0x30
    m_SaveRcdList: TMyList;                                   //0x34
    m_ChangeGoldList: TMyList;                                //0x38
  private
    m_LoadRcdTempList: TMyList;
    m_SaveRcdTempList: TMyList;
    procedure GetGameTime();
    procedure ProcessGameDate();
    function LoadHumFromDB(LoadUser: pTLoadDBInfo; var boReTry: Boolean):
      Boolean;
    function ChangeUserGoldInDB(GoldChangeInfo: pTGoldChangeInfo): Boolean;
    procedure Run();
    { Private declarations }
  protected
    procedure Execute; override;
  public
    constructor Create(CreateSuspended: Boolean);
    destructor Destroy; override;
    function SaveListCount(): Integer;
    function IsIdle(): Boolean;
    function IsFull(): Boolean;
    procedure DeleteHuman(nGateIndex, nSocket: Integer);
    function InSaveRcdList(sChrName: string): Boolean;
    procedure AddChangeGoldList(sGameMasterName, sGetGoldUserName: string;
      nGold: Integer);
    procedure AddToLoadRcdList(sAccount, sChrName, sIPaddr: string; boFlag:
      Boolean; nSessionID: Integer; nPayMent, nPayMode, nSoftVersionDate,
      nSocket,
      nGSocketIdx, nGateIdx: Integer);
    procedure AddToSaveRcdList(SaveRcd: pTSaveRcd);
  end;

implementation
uses
  M2Share, RunDB;
{ TFrontEngine }

constructor TFrontEngine.Create(CreateSuspended: Boolean);
begin
  inherited;
  InitializeCriticalSection(m_UserCriticalSection);
  m_LoadRcdList := TMyList.create;
  m_SaveRcdList := TMyList.create;
  m_ChangeGoldList := TMyList.create;
  m_LoadRcdTempList := TMyList.create;
  m_SaveRcdTempList := TMyList.create;
  //  FreeOnTerminate:=True;
 // AddToProcTable(@TFrontEngine.ProcessGameDate,
 //   'TFrontEngine.ProcessGameDatea');

end;

destructor TFrontEngine.Destroy;
begin
  m_LoadRcdList.Free;
  m_SaveRcdList.Free;
  m_ChangeGoldList.Free;
  m_LoadRcdTempList.Free;
  m_SaveRcdTempList.Free;
  DeleteCriticalSection(m_UserCriticalSection);
  inherited;
end;
//004B5148

procedure TFrontEngine.Execute;
resourcestring
  sExceptionMsg                         = '[Exception] TFrontEngine::Execute';
begin
  while not Terminated do
  begin
    try
      Run();
    except
      MainOutMessage(sExceptionMsg);
    end;
    Sleep(1);
  end;
end;

procedure TFrontEngine.GetGameTime;                         //004B50AC
var
  Hour, Min, Sec, MSec                  : Word;
begin
 try
  DecodeTime(Time, Hour, Min, Sec, MSec);
  case Hour of
    5, 6, 7, 8, 9, 10, 16, 17, 18, 19, 20, 21, 22: g_nGameTime := 1;
    11, 23: g_nGameTime := 2;
    4, 15: g_nGameTime := 0;
    0, 1, 2, 3, 12, 13, 14: g_nGameTime := 3;
  end;
 finally
 End;
end;

function TFrontEngine.IsIdle: Boolean;
begin
  Result := False;
  EnterCriticalSection(m_UserCriticalSection);
  try
    if m_SaveRcdList.Count = 0 then
      Result := True;
  finally
    LeaveCriticalSection(m_UserCriticalSection);
  end;

end;

function TFrontEngine.SaveListCount: Integer;
begin
  Result := 0;
  EnterCriticalSection(m_UserCriticalSection);
  try
    Result := m_SaveRcdList.Count;
  finally
    LeaveCriticalSection(m_UserCriticalSection);
  end;
end;

procedure TFrontEngine.ProcessGameDate;
var
  i                                     : Integer;
  ii                                    : Integer;
  TempList                              : TMyList;
  ChangeGoldList                        : TMyList;
  LoadDBInfo                            : pTLoadDBInfo;
  SaveRcd                               : pTSaveRcd;
  GoldChangeInfo                        : pTGoldChangeInfo;
  boReTryLoadDB                         : Boolean;
   hid:string;
begin
{$IF SoftVersion <> VERFREE}
     {$I License.inc}
 
     {$I License.inc}
       if NotRegenMonsters then exit;
     {$I License.inc}
     {$IFEND}
  ChangeGoldList := nil;
  EnterCriticalSection(m_UserCriticalSection);
  try
    for i := 0 to m_SaveRcdList.Count - 1 do
    begin
      m_SaveRcdTempList.Add(m_SaveRcdList.Items[i]);
    end;

    TempList := m_LoadRcdTempList;
    m_LoadRcdTempList := m_LoadRcdList;
    m_LoadRcdList := TempList;

    if m_ChangeGoldList.Count > 0 then
    begin
      ChangeGoldList := TMyList.create;
      for i := 0 to m_ChangeGoldList.Count - 1 do
      begin
        ChangeGoldList.Add(m_ChangeGoldList.Items[i]);
      end;
    end;
    m_ChangeGoldList.Clear;
  finally
    LeaveCriticalSection(m_UserCriticalSection);
  end;
  for i := 0 to m_SaveRcdTempList.Count - 1 do
  begin
    SaveRcd := m_SaveRcdTempList.Items[i];
    if SaveHumRcdToDB(SaveRcd.sAccount, SaveRcd.sChrName, SaveRcd.nSessionID,
      SaveRcd.HumanRcd) or (SaveRcd.nReTryCount > -1) then
    begin
      if SaveRcd.PlayObject <> nil then
      begin
        TPlayObject(SaveRcd.PlayObject).m_boRcdSaved := True;
      end;
      EnterCriticalSection(m_UserCriticalSection);
      try
        for ii := 0 to m_SaveRcdList.Count - 1 do
        begin
          if m_SaveRcdList.Items[ii] = SaveRcd then
          begin
            m_SaveRcdList.Delete(ii);
            DisPose(SaveRcd);
            break;
          end;
        end;
      finally
        LeaveCriticalSection(m_UserCriticalSection);
      end;
    end
    else
    begin
      Inc(SaveRcd.nReTryCount);
    end;
  end;                                                      //004B4FDA
  m_SaveRcdTempList.Clear;

  for i := 0 to m_LoadRcdTempList.Count - 1 do
  begin
    LoadDBInfo := m_LoadRcdTempList.Items[i];
    if not LoadHumFromDB(LoadDBInfo, boReTryLoadDB) then
    begin
      RunSocket.CloseUser(LoadDBInfo.nGateIdx, LoadDBInfo.nSocket);
      //  MainOutMessage('读取错误2');
    end;
    if not boReTryLoadDB then
    begin
      DisPose(LoadDBInfo);
    end
    else
    begin //如果读取人物数据失败(数据还没有保存),则重新加入队列
      EnterCriticalSection(m_UserCriticalSection);
      try
        m_LoadRcdList.Add(LoadDBInfo);
      finally
        LeaveCriticalSection(m_UserCriticalSection);
      end;
    end;
  end;                                                      //004B504D
  m_LoadRcdTempList.Clear;

  if ChangeGoldList <> nil then
  begin
    for i := 0 to ChangeGoldList.Count - 1 do
    begin
      GoldChangeInfo := ChangeGoldList.Items[i];
      ChangeUserGoldInDB(GoldChangeInfo);
      DisPose(GoldChangeInfo);
    end;                                                    //004B509F
    ChangeGoldList.Free;
  end;                                                      //004B50A7
end;

function TFrontEngine.IsFull: Boolean;                      //004B4988
begin
  Result := False;
  EnterCriticalSection(m_UserCriticalSection);
  try
    if m_SaveRcdList.Count >= 1000 then
    begin
      Result := True;
    end;
  finally
    LeaveCriticalSection(m_UserCriticalSection);
  end;
end;

procedure TFrontEngine.AddToLoadRcdList(sAccount, sChrName, sIPaddr: string;
  boFlag: Boolean; nSessionID, nPayMent, nPayMode, nSoftVersionDate, nSocket,
  nGSocketIdx, nGateIdx: Integer);
//004B46A0
var
  LoadRcdInfo                           : pTLoadDBInfo;
begin
  New(LoadRcdInfo);
  if LoadRcdInfo=nil then Exit;
  LoadRcdInfo.sAccount := sAccount;
  LoadRcdInfo.sCharName := sChrName;
  LoadRcdInfo.sIPaddr := sIPaddr;
  //LoadRcdInfo.boClinetFlag     := boFlag;
  LoadRcdInfo.nSessionID := nSessionID;
  LoadRcdInfo.nSoftVersionDate := nSoftVersionDate;
  LoadRcdInfo.nPayMent := nPayMent;
  LoadRcdInfo.DBindex := nPayMode;
  LoadRcdInfo.nSocket := nSocket;
  LoadRcdInfo.nGSocketIdx := nGSocketIdx;
  LoadRcdInfo.nGateIdx := nGateIdx;
  LoadRcdInfo.dwNewUserTick := GetTickCount();
  LoadRcdInfo.PlayObject := nil;
  LoadRcdInfo.nReLoadCount := 0;

  EnterCriticalSection(m_UserCriticalSection);
  try
    m_LoadRcdList.Add(LoadRcdInfo);
  finally
    LeaveCriticalSection(m_UserCriticalSection);
  end;
end;

function TFrontEngine.LoadHumFromDB(LoadUser: pTLoadDBInfo; var boReTry:
  Boolean): Boolean;                                        //004B4B10
var
  HumanRcd                              : THumDataInfo;
  UserOpenInfo                          : pTUserOpenInfo;
resourcestring
  sReLoginFailMsg                         =
    '[非法登录] 全局会话验证失败(%s/%s/%s/%d)';
begin
  Result := False;
  boReTry := False;
  if InSaveRcdList(LoadUser.sCharName) then
  begin
    // MainOutMessage('读取错误3333');
    boReTry := True; //反回TRUE,则重新加入队列
    exit;
  end;

  if (UserEngine.GetPlayObjectEx(LoadUser.sCharName,LoadUser.DBindex) <> nil) then
  begin
    UserEngine.KickPlayObjectEx(LoadUser.sCharName);
    // MainOutMessage('已经在线');
    boReTry := True; //反回TRUE,则重新加入队列
    exit;
  end;
  if not LoadHumRcdFromDB(LoadUser.sAccount, LoadUser.sCharName,
    LoadUser.sIPaddr, HumanRcd, LoadUser.nSessionID) then
  begin
    RunSocket.SendOutConnectMsg(LoadUser.nGateIdx, LoadUser.nSocket,
      LoadUser.nGSocketIdx);
   //    MainOutMessage('读取错误1');
  end
  else
  begin
    New(UserOpenInfo);
    if UserOpenInfo=nil then exit;
    UserOpenInfo.sChrName := LoadUser.sCharName;
    UserOpenInfo.LoadUser := LoadUser^;
    UserOpenInfo.HumanRcd := HumanRcd;

    UserEngine.AddUserOpenInfo(UserOpenInfo);
    Result := True;
  end;
end;

function TFrontEngine.InSaveRcdList(sChrName: string): Boolean; //004B4A48
var
  i                                     : Integer;
begin
  Result := False;
  //2005-09-18
 // Exit;
  EnterCriticalSection(m_UserCriticalSection);
  try
    for i := 0 to m_SaveRcdList.Count - 1 do
    begin
       
      if pTSaveRcd(m_SaveRcdList.Items[i]).sChrName = sChrName then
      begin
        Result := True;
        break;
      end;
    end;
  finally
    LeaveCriticalSection(m_UserCriticalSection);
  end;
end;

procedure TFrontEngine.AddChangeGoldList(sGameMasterName, sGetGoldUserName:
  string;
  nGold: Integer);                                          //004B4828
var
  GoldInfo                              : pTGoldChangeInfo;
begin
  New(GoldInfo);
  if GoldInfo=nil then exit;
  GoldInfo.sGameMasterName := sGameMasterName;
  GoldInfo.sGetGoldUser := sGetGoldUserName;
  GoldInfo.nGold := nGold;
  m_ChangeGoldList.Add(GoldInfo);
end;

procedure TFrontEngine.AddToSaveRcdList(SaveRcd: pTSaveRcd); //004B49EC
begin
  EnterCriticalSection(m_UserCriticalSection);
  try
    m_SaveRcdList.Add(SaveRcd);
  finally
    LeaveCriticalSection(m_UserCriticalSection);
  end;
end;

procedure TFrontEngine.DeleteHuman(nGateIndex, nSocket: Integer); //004B45EC
var
  i                                     : Integer;
  LoadRcdInfo                           : pTLoadDBInfo;
begin
  EnterCriticalSection(m_UserCriticalSection);
  try
    for i := 0 to m_LoadRcdList.Count - 1 do
    begin
      LoadRcdInfo := m_LoadRcdList.Items[i];
      if (LoadRcdInfo.nGateIdx = nGateIndex) and (LoadRcdInfo.nSocket = nSocket)
        then
      begin
        DisPose(LoadRcdInfo);
        m_LoadRcdList.Delete(i);
        break;
      end;
    end;
  finally
    LeaveCriticalSection(m_UserCriticalSection);
  end;
end;

function TFrontEngine.ChangeUserGoldInDB(GoldChangeInfo: pTGoldChangeInfo):
  Boolean;
var
  HumanRcd                              : THumDataInfo;
begin
  Result := False;
  if LoadHumRcdFromDB('1', GoldChangeInfo.sGetGoldUser, '1', HumanRcd, 1) then
  begin
    if ((HumanRcd.Data.nGold + GoldChangeInfo.nGold) > 0) and
      ((HumanRcd.Data.nGold + GoldChangeInfo.nGold) < 2000000000) then
    begin
      Inc(HumanRcd.Data.nGold, GoldChangeInfo.nGold);
      if SaveHumRcdToDB('1', GoldChangeInfo.sGetGoldUser, 1, HumanRcd) then
      begin
        UserEngine.sub_4AE514(GoldChangeInfo);
        Result := True;
      end;
    end;
  end;
end;

procedure TFrontEngine.Run;
begin
  ProcessGameDate();
  GetGameTime();
end;
end.