usrengn.pas

传世源码可编译的,功能齐全.是学习的好模版,会DELPHI的朋友们也可以自己修改,弄个自己的引擎.

      PlayObject.m_nSessionID:=UserOpenInfo.LoadUser.nSessionID;
      PlayObject.m_nPayMent:=UserOpenInfo.LoadUser.nPayMent;
      PlayObject.m_nPayMode:=UserOpenInfo.LoadUser.nPayMode;
      PlayObject.m_dwLoadTick:=UserOpenInfo.LoadUser.dwNewUserTick;
      PlayObject.m_nSoftVersionDateEx:=GetExVersionNO(UserOpenInfo.LoadUser.nSoftVersionDate,PlayObject.m_nSoftVersionDate);
      Result:=PlayObject;
    except
      MainOutMessage(sExceptionMsg);
    end;
  end;

var
  dwUsrRotTime     :LongWord;
  dwCheckTime      :LongWord;  //0x10
  dwCurTick        :LongWord;
  nCheck30         :Integer; //0x30
  boCheckTimeLimit :Boolean; //0x31
  nIdx             :Integer;
  PlayObject,hum       :TPlayObject;
  I                :Integer;
  UserOpenInfo     :pTUserOpenInfo;
  GoldChangeInfo   :pTGoldChangeInfo;
  LineNoticeMsg    :String;

ResourceString
  sExceptionMsg1 = '[Exception] TUserEngine::ProcessHumans -> Ready, Save, Load... Code:=%d';
  sExceptionMsg2 = '[Exception] TUserEngine::ProcessHumans ClosePlayer.Delete - Free';
  sExceptionMsg3 = '[Exception] TUserEngine::ProcessHumans ClosePlayer.Delete';
  sExceptionMsg4 = '[Exception] TUserEngine::ProcessHumans RunNotice';
  sExceptionMsg5 = '[Exception] TUserEngine::ProcessHumans Human.Operate Code: %d';
  sExceptionMsg6 = '[Exception] TUserEngine::ProcessHumans Human.Finalize Code: %d';
  sExceptionMsg7 = '[Exception] TUserEngine::ProcessHumans RunSocket.CloseUser Code: %d';
  sExceptionMsg8 = '[Exception] TUserEngine::ProcessHumans  Code: %d';
begin
  nCheck30:=0;
  dwCheckTime:=GetTickCount();
////////////////////////////////////////////////////////////////////////////
//  if RUNID1<>1 then exit;
////////////////////////////////////////////////////////////////////////////
  if (GetTickCount - m_dwProcessLoadPlayTick) > 200 then begin
    m_dwProcessLoadPlayTick:=GetTickCount();
    try
      EnterCriticalSection(m_LoadPlaySection);
      try

        for i:=0 to m_LoadPlayList.Count -1 do begin
          if not FrontEngine.IsFull and not IsLogined(m_LoadPlayList.Strings[i]) then begin
            UserOpenInfo:=pTUserOpenInfo(m_LoadPlayList.Objects[i]);

            PlayObject:=MakeNewHuman(UserOpenInfo);

            if PlayObject <> nil then begin
              m_PlayObjectList.AddObject(m_LoadPlayList.Strings[i],PlayObject);
              SendServerGroupMsg(SS_201,nServerIndex,PlayObject.m_sCharName);
              m_NewHumanList.Add(PlayObject);
            end;

          end else begin
            KickOnlineUser(m_LoadPlayList.Strings[i]);
            UserOpenInfo:=pTUserOpenInfo(m_LoadPlayList.Objects[i]);
            m_ListOfGateIdx.Add(Pointer(UserOpenInfo.LoadUser.nGateIdx));
            m_ListOfSocket.Add(Pointer(UserOpenInfo.LoadUser.nSocket));
          end;
          Dispose(pTUserOpenInfo(m_LoadPlayList.Objects[I]));
        end;
        m_LoadPlayList.Clear;
        for I:=0 to m_ChangeHumanDBGoldList.Count -1 do begin
          GoldChangeInfo:=m_ChangeHumanDBGoldList.Items[I];
          PlayObject:=GeTPlayObject(GoldChangeInfo.sGameMasterName);
          if PlayObject <> nil then begin
            PlayObject.GoldChange(GoldChangeInfo.sGetGoldUser,GoldChangeInfo.nGold);
          end;
          Dispose(GoldChangeInfo);
        end;
        m_ChangeHumanDBGoldList.Clear;
      finally
        LeaveCriticalSection(m_LoadPlaySection);
      end;

      for I:=0 to m_NewHumanList.Count -1 do begin
         PlayObject:=TPlayObject(m_NewHumanList.Items[I]);
         RunSocket.SetGateUserList(PlayObject.m_nGateIdx,PlayObject.m_nSocket,PlayObject);
      end;
      m_NewHumanList.Clear;

      for i:=0 to m_ListOfGateIdx.Count -1 do begin
        RunSocket.CloseUser(Integer(m_ListOfGateIdx.Items[i]),Integer(m_ListOfSocket.Items[i]));//GateIdx,nSocket
      end;
      m_ListOfGateIdx.Clear;
      m_ListOfSocket.Clear;
    except
      on e: Exception do begin
        MainOutMessage(format(sExceptionMsg1,[0]));
        MainOutMessage(E.Message); raise;
      end;
      
    end;
  end;

  try
    for I := 0 to m_PlayObjectFreeList.Count - 1 do begin
      PlayObject:=TPlayObject(m_PlayObjectFreeList.Items[i]);
      if (GetTickCount - PlayObject.m_dwGhostTick) > g_Config.dwHumanFreeDelayTime {5 * 60 * 1000} then begin
        try
          TPlayObject(m_PlayObjectFreeList.Items[i]).Free;
        except
          MainOutMessage(sExceptionMsg2);
        end;

        m_PlayObjectFreeList.Delete(i);
        break;
      end else begin
        if PlayObject.m_boSwitchData and (PlayObject.m_boRcdSaved) then begin
          if SendSwitchData(PlayObject,PlayObject.m_nServerIndex) or (PlayObject.m_nWriteChgDataErrCount > 20) then begin
            PlayObject.m_boSwitchData:=False;
            PlayObject.m_boSwitchDataSended:=True;
            PlayObject.m_dwChgDataWritedTick:=GetTickCount();
          end else Inc(PlayObject.m_nWriteChgDataErrCount);
        end;
        if PlayObject.m_boSwitchDataSended and ((GetTickCount - PlayObject.m_dwChgDataWritedTick) > 100) then begin
          PlayObject.m_boSwitchDataSended:=False;
          SendChangeServer(PlayObject,PlayObject.m_nServerIndex);
        end;
      end;
    end;
  except
    MainOutMessage(sExceptionMsg3);
  end;

  boCheckTimeLimit:=False;
  try
    dwCurTick:=GetTickCount();
    nIdx:=m_nProcHumIDx;
     while True do begin
       if m_PlayObjectList.Count <= nIdx then break;
    
       PlayObject:=TPlayObject(m_PlayObjectList.Objects[nIdx]);
       if Integer(dwCurTick - PlayObject.m_dwRunTick) > PlayObject.m_nRunTime then begin
         PlayObject.m_dwRunTick:=dwCurTick;

         if (PlayObject.m_boDeath) or (PlayObject.m_boGhost) then begin
           if not PlayObject.m_boDeathRcdSaved then begin
           SaveHumanRcd(PlayObject);
           PlayObject.m_boDeathRcdSaved:=true;
           end;
         end;

         if not PlayObject.m_boGhost then begin
           if not PlayObject.m_boLoginNoticeOK then begin
{$IF CATEXCEPTION = TRYEXCEPTION}
             try
               PlayObject.RunNotice();
             except
               MainOutMessage(sExceptionMsg4);
             end;
{$IFEND}
           end else begin
             try
               if not PlayObject.m_boReadyRun then begin
                 PlayObject.m_boReadyRun:=True;//004B1075
                 if  PlayObject.sYsnameMaster<>'' then begin  //说明是元神
                   hum:=nil;
                   hum:=PlayObject.ysmasterplayer;
                 if hum<>nil then begin
                  PlayObject.SendDefMessage(1809,0,0,0,0,'');
                  PlayObject.SendDefMessage(38292,integer(PlayObject),0,40,0,''); //背包的大小


                  PlayObject.SendDefMessage(38294,0,0,0,0,'');   //任务列表
                  PlayObject.SendDefMessage(21292,
                             Integer(PlayObject),
                             8,
                             PlayObject.GetYSfenghao(PlayObject.M_YSfenghao), // 0 1 2 3 4
                             0,
                             '');

                    PlayObject.nyuanqi:=0;
                    PlayObject.SendDefMessage(38417,0,0,100,0,'');
                    PlayObject.m_boStartshow :=true;
                   inc(hum.m_nYsCallcount);

                 end;
                end;
                 PlayObject.UserLogon;
               end else begin
                 if (GetTickCount() - PlayObject.m_dwSearchTick) > PlayObject.m_dwSearchTime then begin
                   PlayObject.m_dwSearchTick:=GetTickCount();
                   PlayObject.SearchViewRange;
                   PlayObject.GameTimeChanged;
                 end;
                 /////////////   广告
                if PlayObject.sYsnameMaster='' then  begin
                 if (GetTickCount-  PlayObject.m_dwShowBannerNoticeTime  >  g_Config.HideBannerNoticeTime) and (not PlayObject.m_boshowBanner)  then begin
                    PlayObject.m_dwShowBannerNoticeTime:= GetTickCount();
                    if BannerNotice.Count > PlayObject.m_nShowBannerNoticeIdx then begin
                     LineNoticeMsg:=g_ManageNPC.GetLineVariableText(PlayObject,BannerNotice.Strings[PlayObject.m_nShowBannerNoticeIdx]);

                     PlayObject.SendDefMessage(100,0,38656,10,768,LineNoticeMsg); //广告  显示
                     PlayObject.m_boshowBanner:=true;
                    end;
                   Inc(PlayObject.m_nShowBannerNoticeIdx);
                   if (BannerNotice.Count <= PlayObject.m_nShowBannerNoticeIdx) then
                    PlayObject.m_nShowBannerNoticeIdx:=0;

                 end;

                 if (GetTickCount-  PlayObject.m_dwShowBannerNoticeTime  >  g_Config.ShowBannerNoticeTime) and (PlayObject.m_boshowBanner) then begin
                    PlayObject.m_dwShowBannerNoticeTime:= GetTickCount();
                   PlayObject.SendDefMessage(100,0,38656,10,768,''); //广告 隐藏
                   PlayObject.m_boshowBanner:=false;
                 end;
                end;

                 if (GetTickCount() - PlayObject.m_dwShowLineNoticeTick) > g_Config.dwShowLineNoticeTime then begin
                   PlayObject.m_dwShowLineNoticeTick:=GetTickCount();
                   if LineNoticeList.Count > PlayObject.m_nShowLineNoticeIdx then begin

                     LineNoticeMsg:=g_ManageNPC.GetLineVariableText(PlayObject,LineNoticeList.Strings[PlayObject.m_nShowLineNoticeIdx]);

                     case LineNoticeMsg[1] of
                       'R': PlayObject.SysMsg(Copy(LineNoticeMsg,2,length(LineNoticeMsg) - 1),c_Red,t_Notice);
                       'G': PlayObject.SysMsg(Copy(LineNoticeMsg,2,length(LineNoticeMsg) - 1),c_Green,t_Notice);
                       'B': PlayObject.SysMsg(Copy(LineNoticeMsg,2,length(LineNoticeMsg) - 1),c_Blue,t_Notice);
                       else begin
                         PlayObject.SysMsg(LineNoticeMsg,TMsgColor(g_Config.nLineNoticeColor){c_Blue},t_Notice);
                       end;
                     end;
                   end;
                   Inc(PlayObject.m_nShowLineNoticeIdx);
                   if (LineNoticeList.Count <= PlayObject.m_nShowLineNoticeIdx) then
                     PlayObject.m_nShowLineNoticeIdx:=0;
                 end;

                 PlayObject.Run();

                 if not FrontEngine.IsFull and((GetTickCount() - PlayObject.m_dwSaveRcdTick) > g_Config.dwSaveHumanRcdTime) then begin
                   PlayObject.m_dwSaveRcdTick:=GetTickCount();
                   PlayObject.DealCancelA();
                   SaveHumanRcd(PlayObject);
                 end;
               end;
             except
               on e: Exception do begin
                 MainOutMessage(format(sExceptionMsg5,[0]));
                 MainOutMessage(E.Message);raise;
               end;
               
             end;
           end;
         end else begin
           try
             m_PlayObjectList.Delete(nIdx);
             nCheck30:=2;
             PlayObject.Disappear();
              nCheck30:=3;
           except
             on e: Exception do begin
               MainOutMessage(format(sExceptionMsg6,[nCheck30]));
               MainOutMessage(E.Message);   raise;
             end;
             
           end;
           try
             //如果人物死亡
            AddToHumanFreeList(PlayObject);
             nCheck30:=4;
             PlayObject.DealCancelA();

             RunSocket.CloseUser(PlayObject.m_nGateIdx,PlayObject.m_nSocket);   //        解决1.9 版本复活功能
           except
             MainOutMessage(format(sExceptionMsg7,[nCheck30]));
           end;
           SendServerGroupMsg(SS_202,nServerIndex,PlayObject.m_sCharName);
           Continue;
         end;
       end;
       Inc(nIdx);
       if (GetTickCount - dwCheckTime) > g_dwHumLimit then begin
         boCheckTimeLimit:=True;
         m_nProcHumIDx:=nIdx;
         break;
       end;
     end;
     if not boCheckTimeLimit then m_nProcHumIDx:=0;
  except
       on e: Exception do begin
        MainOutMessage(format(sExceptionMsg8,[nCheck30]));
        MainOutMessage(E.Message);    raise;
       end;
  end;
  Inc(nProcessHumanLoopTime);
  g_nProcessHumanLoopTime:=nProcessHumanLoopTime;
  if m_nProcHumIDx = 0 then
  begin
    nProcessHumanLoopTime:=0;
    g_nProcessHumanLoopTime:=nProcessHumanLoopTime;
    dwUsrRotTime:=GetTickCount - g_dwUsrRotCountTick;
    dwUsrRotCountMin:=dwUsrRotTime;
    g_dwUsrRotCountTick:=GetTickCount();
    if dwUsrRotCountMax < dwUsrRotTime then dwUsrRotCountMax:=dwUsrRotTime;
  end;
  g_nHumCountMin:=GetTickCount - dwCheckTime;
  if g_nHumCountMax < g_nHumCountMin then g_nHumCountMax:=g_nHumCountMin;
end;

procedure TUserEngine.ProcessMerchants;
var
  dwRunTick,dwCurrTick:LongWord;
  i:integer;
  MerchantNPC:TMerchant;
  boProcessLimit:Boolean;
ResourceString
  sExceptionMsg = '[Exception] TUserEngine::ProcessMerchants';
begin
  dwRunTick:=GetTickCount();
  boProcessLimit:=False;
  try
    dwCurrTick:=GetTickCount();
    m_MerchantList.Lock;
    try
      for i:=nMerchantPosition to m_MerchantList.Count -1 do begin
        MerchantNPC:=m_MerchantList.Items[i];
        if not MerchantNPC.m_boGhost then begin
          if Integer(dwCurrTick - MerchantNPC.m_dwRunTick) > MerchantNPC.m_nRunTime then begin
            if (GetTickCount - MerchantNPC.m_dwSearchTick) > MerchantNPC.m_dwSearchTime then begin
              MerchantNPC.m_dwSearchTick:=GetTickCount();
              MerchantNPC.SearchViewRange();
            end;
            if Integer(dwCurrTick - MerchantNPC.m_dwRunTick) > MerchantNPC.m_nRunTime then begin
              MerchantNPC.m_dwRunTick:=dwCurrTick;
              MerchantNPC.Run;
            end;
          end;
        end else begin
          if (GetTickCount - MerchantNPC.m_dwGhostTick) > 60 * 1000 then begin
            MerchantNPC.Free;
            m_MerchantList.Delete(i);
            break;
          end;
        end;
        if (GetTickCount - dwRunTick) > g_dwNpcLimit then begin
          nMerchantPosition:=i;
          boProcessLimit:=True;
          Break;
        end;
      end;
    finally
      m_MerchantList.UnLock;
    end;