usrsoc.pas

翎风世界..传奇服务端..DELPHI源代码 包括DBServer,LogDataServer,LoginGate,LoginSrv,M2Server等..内容齐全.

  sGateIPaddr:=GetValidStr3(sIP,sUserIPaddr,['/']);
  for I:=0 to GateInfo.UserList.Count -1 do begin
    UserInfo:=GateInfo.UserList.Items[I];
    if (UserInfo <> nil) and (UserInfo.sConnID = sID) then begin
      exit;
    end;
  end;
  New(UserInfo);
  UserInfo.sAccount      :='';
  UserInfo.sUserIPaddr   :=sUserIPaddr;
  UserInfo.sGateIPaddr   :=sGateIPaddr;
  UserInfo.sConnID       :=sID;
  UserInfo.nSessionID    :=0;
  UserInfo.Socket        :=GateInfo.Socket;
  UserInfo.s2C           :='';
  UserInfo.dwTick34      :=GetTickCount();
  UserInfo.dwChrTick     :=GetTickCount();
  UserInfo.boChrSelected :=False;
  UserInfo.boChrQueryed  :=False;
  UserInfo.nSelGateID    :=GateInfo.nGateID;
  GateInfo.UserList.Add(UserInfo);
end;
//004A30B8
procedure TFrmUserSoc.CloseUser(sID: String; var GateInfo: pTGateInfo);
var
  I        :Integer;
  UserInfo :pTUserInfo;
begin
  for I:=0 to GateInfo.UserList.Count -1 do begin
    UserInfo:=GateInfo.UserList.Items[I];
    if (UserInfo <> nil) and (UserInfo.sConnID = sID) then begin
      if not FrmIDSoc.GetGlobaSessionStatus(UserInfo.nSessionID) then begin
        FrmIDSoc.SendSocketMsg(SS_SOFTOUTSESSION,UserInfo.sAccount + '/' + IntToStr(UserInfo.nSessionID));
        FrmIDSoc.CloseSession(UserInfo.sAccount,UserInfo.nSessionID);
      end;
      Dispose(UserInfo);
      GateInfo.UserList.Delete(I);
      break;
    end;
  end;
end;
procedure TFrmUserSoc.DeCodeUserMsg(sData: String;
  var UserInfo: pTUserInfo);//004A48E0
var
  sDefMsg,s18:String;
  Msg:TDefaultMessage;
begin
  sDefMsg:=Copy(sData,1,DEFBLOCKSIZE);
  s18:=Copy(sData,DEFBLOCKSIZE + 1,Length(sData) - DEFBLOCKSIZE);
  Msg:=DecodeMessage(sDefMsg);
  case Msg.Ident of
    CM_QUERYCHR: begin
      if not UserInfo.boChrQueryed or ((GetTIckCount - UserInfo.dwChrTick) > 200) then begin
        UserInfo.dwChrTick:=GetTickCount();
        if QueryChr(s18,UserInfo) then begin
          UserInfo.boChrQueryed:=True;
        end;
      end else begin
        Inc(g_nQueryChrCount);
        OutMainMessage('[Hacker Attack] _QUERYCHR ' + UserInfo.sUserIPaddr);
      end;
    end;
    CM_NEWCHR: begin
      if (GetTickCount - UserInfo.dwChrTick) > 1000 then begin
        UserInfo.dwChrTick:=GetTickCount();
        if (UserInfo.sAccount <> '')
        and FrmIDSoc.CheckSession(UserInfo.sAccount,UserInfo.sUserIPaddr,UserInfo.nSessionID) then begin
          NewChr(s18,UserInfo);
          UserInfo.boChrQueryed:=False;
        end else begin
          OutOfConnect(UserInfo);
        end;
      end else begin
        Inc(nHackerNewChrCount);
        OutMainMessage('[Hacker Attack] _NEWCHR ' + UserInfo.sAccount + '/' + UserInfo.sUserIPaddr);
      end;
    end;
    CM_DELCHR: begin
      if (GetTickCount - UserInfo.dwChrTick) > 1000 then begin
        UserInfo.dwChrTick:=GetTickCount();
        if (UserInfo.sAccount <> '')
        and FrmIDSoc.CheckSession(UserInfo.sAccount,UserInfo.sUserIPaddr,UserInfo.nSessionID) then begin
          DelChr(s18,UserInfo);
          UserInfo.boChrQueryed:=False;
        end else begin
          OutOfConnect(UserInfo);
        end;
      end else begin
        Inc(nHackerDelChrCount);
        OutMainMessage('[Hacker Attack] _DELCHR ' + UserInfo.sAccount + '/' + UserInfo.sUserIPaddr);
      end;
    end;
    CM_SELCHR: begin
      if not UserInfo.boChrQueryed then begin
        if (UserInfo.sAccount <> '')
        and FrmIDSoc.CheckSession(UserInfo.sAccount,UserInfo.sUserIPaddr,UserInfo.nSessionID) then begin
          if SelectChr(s18,UserInfo) then begin
            UserInfo.boChrSelected:=True;
          end;
        end else begin  //004A4D69
          OutOfConnect(UserInfo);
        end;
      end else begin//004A4D79
        Inc(nHackerSelChrCount);
        OutMainMessage('Double send _SELCHR ' + UserInfo.sAccount + '/' + UserInfo.sUserIPaddr);
      end;
    end;
    else begin
      Inc(n4ADC24);
    end;
  end;
end;
//004A3620
function TFrmUserSoc.QueryChr(sData: String; var UserInfo: pTUserInfo):Boolean;
var
  sAccount   :String;
  sSessionID :String;
  nSessionID :Integer;
  nChrCount  :Integer;
  ChrList    :TStringList;
  I          :Integer;
  nIndex     :Integer;
  ChrRecord  :THumDataInfo;
  HumRecord  :THumInfo;
  QuickID    :pTQuickID;
  btSex      :Byte;
  sChrName   :String;
  sJob       :String;
  sHair      :String;
  sLevel     :String;
  s40        :String;
begin
  Result     := False;
  sSessionID := GetValidStr3(DecodeString(sData),sAccount,['/']);
  nSessionID := Str_ToInt(sSessionID,-2);
  UserInfo.nSessionID:=nSessionID;
  nChrCount:=0;

  if FrmIDSoc.CheckSession(sAccount,UserInfo.sUserIPaddr,nSessionID) then begin
    FrmIDSoc.SetGlobaSessionNoPlay(nSessionID);
    UserInfo.sAccount:=sAccount;
    ChrList:=TStringList.Create;
    try
      if HumChrDB.Open and (HumChrDB.FindByAccount(sAccount,ChrList) >= 0) then begin
        try
          if HumDataDB.OpenEx then begin
            for I:=0 to ChrList.Count -1 do begin
              QuickID:=pTQuickID(ChrList.Objects[I]);
              //如果选择ID不对,则跳过
              if QuickID.nSelectID <> UserInfo.nSelGateID then Continue;
                
              if HumChrDB.GetBy(QuickID.nIndex,HumRecord) and not HumRecord.boDeleted then begin
                sChrName:=QuickID.sChrName;
                nIndex:=HumDataDB.Index(sChrName);
                if (nIndex < 0) or (nChrCount >= 2) then Continue;
                if HumDataDB.Get(nIndex,ChrRecord) >= 0 then begin
                  btSex:=ChrRecord.Data.btSex;
                  sJob:=IntToStr(ChrRecord.Data.btJob);
                  sHair:=IntToStr(ChrRecord.Data.btHair);
                  sLevel:=IntToStr(ChrRecord.Data.Abil.Level);
                  if HumRecord.boSelected then s40:=s40 + '*';
                    s40:=s40 + sChrName + '/' + sJob + '/' + sHair + '/' + sLevel + '/' + IntToStr(btSex) + '/';
                  Inc(nChrCount);
                end;
              end;
            end;
          end;
        finally
          HumDataDB.Close;
        end;
      end;
    finally
      HumChrDB.Close;
    end;
    ChrList.Free;
    SendUserSocket(UserInfo.Socket,
                   UserInfo.sConnID,
                   EncodeMessage(MakeDefaultMsg(SM_QUERYCHR,nChrCount,0,1,0)) + EncodeString(s40));
  //*ChrName/sJob/sHair/sLevel/sSex/
  end else begin
    SendUserSocket(UserInfo.Socket,
                   UserInfo.sConnID,
                   EncodeMessage(MakeDefaultMsg(SM_QUERYCHR_FAIL,nChrCount,0,1,0)));
    CloseUser(UserInfo.sConnID,CurGate);
  end;
end;
procedure TFrmUserSoc.OutOfConnect(Const UserInfo: pTUserInfo);
//004A4844
var
  Msg:TDefaultMessage;
  sMsg:String;
begin
  Msg:=MakeDefaultMsg(SM_OUTOFCONNECTION,0,0,0,0);
  sMsg:=EncodeMessage(Msg);
  SendUserSocket(UserInfo.Socket,sMsg,UserInfo.sConnID);
end;

procedure TFrmUserSoc.DelChr(sData: String;
  var UserInfo: pTUserInfo);
//004A424C
var
  sChrName:String;
  boCheck:Boolean;
  Msg:TDefaultMessage;
  sMsg:String;
  n10:Integer;
  HumRecord:THumInfo;
begin
  g_CheckCode.dwThread0:=1000300;
  sChrName:=DecodeString(sData);
  boCheck:=False;
  g_CheckCode.dwThread0:=1000301;
  try
    if HumChrDB.Open then begin
      n10:=HumChrDB.Index(sChrName);
      if n10 >= 0 then begin
        HumChrDB.Get(n10,HumRecord);
        if HumRecord.sAccount = UserInfo.sAccount then begin
          HumRecord.boDeleted:=True;
          HumRecord.dModDate:=Now();
          HumChrDB.Update(n10,HumRecord);
          boCheck:=True;
        end;
      end;
    end;
  finally
    HumChrDB.Close;
  end;
  g_CheckCode.dwThread0:=1000302;
  if boCheck then
    Msg:=MakeDefaultMsg(SM_DELCHR_SUCCESS,0,0,0,0)
  else
    Msg:=MakeDefaultMsg(SM_DELCHR_FAIL,0,0,0,0);

  sMsg:=EncodeMessage(Msg);
  SendUserSocket(UserInfo.Socket,UserInfo.sConnID,sMsg);
  g_CheckCode.dwThread0:=1000303;
end;
procedure TFrmUserSoc.NewChr(sData: String;var UserInfo: pTUserInfo);//004A3C08
var
  Data,sAccount,sChrName,sHair,sJob,sSex:String;
  nCode:Integer;
  Msg:TDefaultMessage;
  sMsg:String;
  HumRecord:THumInfo;
  i:Integer;
begin
  nCode:= -1;
  Data:=DecodeString(sData);
  Data:=GetValidStr3(Data,sAccount,['/']);
  Data:=GetValidStr3(Data,sChrName,['/']);
  Data:=GetValidStr3(Data,sHair,['/']);
  Data:=GetValidStr3(Data,sJob,['/']);
  Data:=GetValidStr3(Data,sSex,['/']);
  if Trim(Data) <> '' then nCode:=0;
  sChrName:=Trim(sChrName);
  if length(sChrName) < 3 then nCode:=0;
  if g_boEnglishNames and not IsEnglishStr(sChrName) then nCode:=0;
  if not CheckDenyChrName(sChrName) then nCode:= 2;
  if not CheckChrName(sChrName) then nCode:=0;
  for I := 1 to length(sChrName) do begin
    if (sChrName[i] = #$A1) or
       (sChrName[i] = ' ') or
       (sChrName[i] = '/') or
       (sChrName[i] = '@') or
       (sChrName[i] = '?') or
       (sChrName[i] = '''') or
       (sChrName[i] = '"') or
       (sChrName[i] = '\') or
       (sChrName[i] = '.') or
       (sChrName[i] = ',') or
       (sChrName[i] = ':') or
       (sChrName[i] = ';') or
       (sChrName[i] = '`') or
       (sChrName[i] = '~') or
       (sChrName[i] = '!') or
       (sChrName[i] = '#') or
       (sChrName[i] = '$') or
       (sChrName[i] = '%') or
       (sChrName[i] = '^') or
       (sChrName[i] = '&') or
       (sChrName[i] = '*') or
       (sChrName[i] = '(') or
       (sChrName[i] = ')') or
       (sChrName[i] = '-') or
       (sChrName[i] = '_') or
       (sChrName[i] = '+') or
       (sChrName[i] = '=') or
       (sChrName[i] = '|') or
       (sChrName[i] = '[') or
       (sChrName[i] = '{') or
       (sChrName[i] = ']') or
       (sChrName[i] = '}') then nCode:=0;
  end;

  if nCode = -1 then begin
  try
    HumDataDB.Lock;
    if HumDataDB.Index(sChrName) >= 0 then nCode:=2;
  finally
    HumDataDB.UnLock;
  end;
  FillChar(HumRecord,SizeOf(THumInfo),#0);

    try
      if HumChrDB.Open then begin
        if HumChrDB.ChrCountOfAccount(sAccount) < 2 then begin
          HumRecord.sChrName         := sChrName;
          HumRecord.sAccount         := sAccount;
          HumRecord.boDeleted        := False;
          HumRecord.btCount          := 0;
          HumRecord.Header.sName     := sChrName;
          HumRecord.Header.nSelectID := UserInfo.nSelGateID;
          if HumRecord.Header.sName <> '' then
            if not HumChrDB.Add(HumRecord) then nCode:=2;
        end else nCode:= 3;
      end;
    finally
      HumChrDB.Close;
    end;

    if nCode = -1 then begin
      if NewChrData(sChrName,Str_ToInt(sSex,0),Str_ToInt(sJob,0),Str_ToInt(sHair,0)) then
        nCode:= 1;
    end else begin
      FrmDBSrv.DelHum(sChrName);
      nCode:=4;
    end;
  end;
  if nCode = 1 then begin
    Msg:=MakeDefaultMsg(SM_NEWCHR_SUCCESS,0,0,0,0);
  end else begin
    Msg:=MakeDefaultMsg(SM_NEWCHR_FAIL,nCode,0,0,0);
  end;
  sMsg:=EncodeMessage(Msg);
  SendUserSocket(UserInfo.Socket,UserInfo.sConnID,sMsg);
end;
//004A440C
function TFrmUserSoc.SelectChr(sData: String;
  var UserInfo: pTUserInfo): Boolean;
var
  sAccount  :String;
  sChrName  :String;
  ChrList   :TStringList;
  HumRecord :THumInfo;
  I         :Integer;
  nIndex    :Integer;
  nMapIndex :Integer;
  QuickID   :pTQuickID;
  ChrRecord :THumDataInfo;
  sCurMap   :String;
  boDataOK  :Boolean;
  sDefMsg   :String;
  sRouteMsg :String;
  sRouteIP  :String;
  nRoutePort:Integer;
begin
  Result:=False;
  sChrName:=GetValidStr3(DecodeString(sData),sAccount,['/']);
  boDataOK:=False;
  if UserInfo.sAccount = sAccount then begin
    try
      if HumChrDB.Open then begin
        ChrList:=TStringList.Create;
        if HumChrDB.FindByAccount(sAccount,ChrList) >= 0 then begin
          for I := 0 to ChrList.Count - 1 do begin
            QuickID:=pTQuickID(ChrList.Objects[i]);
            nIndex:=QuickID.nIndex;
            if HumChrDB.GetBy(nIndex,HumRecord) then begin
              if HumRecord.sChrName = sChrName then begin
                HumRecord.boSelected:=True;
                HumChrDB.UpdateBy(nIndex,HumRecord);
              end else begin
                if HumRecord.boSelected then begin
                  HumRecord.boSelected:=False;
                  HumChrDB.UpdateBy(nIndex,HumRecord);
                end;
              end;
            end;
          end;
        end;
        ChrList.Free;
      end;
    finally
      HumChrDB.Close;
    end;
    try
      if HumDataDB.OpenEx then begin
        nIndex:=HumDataDB.Index(sChrName);
        if nIndex>= 0 then begin
          HumDataDB.Get(nIndex,ChrRecord);
          sCurMap:=ChrRecord.Data.sCurMap;
          boDataOK:=True;
        end;
      end;
    finally
      HumDataDB.Close;
    end;
  end;
    if boDataOK then begin
      nMapIndex:=GetMapIndex(sCurMap);
      sDefMsg:=EncodeMessage(MakeDefaultMsg(SM_STARTPLAY,0,0,0,0));
      sRouteIP:=GateRouteIP(CurGate.sGateaddr,nRoutePort);
      if g_boDynamicIPMode then sRouteIP:=UserInfo.sGateIPaddr; //使用动态IP

      sRouteMsg:=EncodeString(sRouteIP + '/' + IntToStr(nRoutePort + nMapIndex));
      SendUserSocket(UserInfo.Socket,
                     UserInfo.sConnID,
                     sDefMsg + sRouteMsg);
      FrmIDSoc.SetGlobaSessionPlay(UserInfo.nSessionID);
      Result:=True;
    end else begin
      SendUserSocket(UserInfo.Socket,
                     UserInfo.sConnID,
                     EncodeMessage(MakeDefaultMsg(SM_STARTFAIL,0,0,0,0)));
   end;
end;
function TFrmUserSoc.GateRoutePort(sGateIP:String):Integer;//004A2724
begin
  Result:=7200;
end;
function TFrmUserSoc.GateRouteIP(sGateIP:String;var nPort:Integer):String;//0x004A258C
  function GetRoute(RouteInfo:pTRouteInfo;var nGatePort:Integer):String;
  var
    nGateIndex:Integer;
  begin
    nGateIndex :=Random(RouteInfo.nGateCount);
    Result     :=RouteInfo.sGameGateIP[nGateIndex];
    nGatePort  :=RouteInfo.nGameGatePort[nGateIndex];
  end;
var
  I: Integer;
  RouteInfo:pTRouteInfo;
begin
  nPort:=0;
  Result:='';
  for I := Low(g_RouteInfo) to High(g_RouteInfo) do begin
    RouteInfo:=@g_RouteInfo[I];
    if RouteInfo.sSelGateIP = sGateIP then begin
      Result:=GetRoute(RouteInfo,nPort);
      break;
    end;
  end;    
end;
function TFrmUserSoc.GetMapIndex(sMap:String):Integer;//0x004A24D4
var
  i:Integer;
begin
  Result:=0;
  for I := 0 to MapList.Count - 1 do begin
    if MapList.Strings[i] =  sMap then begin
      Result:=Integer(MapList.Objects[i]);
      break;
    end;      
  end;
end;
procedure TFrmUserSoc.SendUserSocket(Socket: TCustomWinSocket; sSessionID,
  sSendMsg: String);
//004A2E18
begin
  Socket.SendText('%' + sSessionID + '/#' + sSendMsg + '!$');
end;
//0045C2C0
function TFrmUserSoc.CheckDenyChrName(sChrName: String): Boolean;
var
  i:Integer;
begin
  Result:=True;
  g_CheckCode.dwThread0:=1000700;
  for I := 0 to DenyChrNameList.Count - 1 do begin
    g_CheckCode.dwThread0:=1000701;
    if CompareText(sChrName,DenyChrNameList.Strings[i]) = 0 then begin
      g_CheckCode.dwThread0:=1000702;
      Result:=False;
      break;
    end;
  end;
  g_CheckCode.dwThread0:=1000703;
end;

end.