10263 【英文】【越南】【BT】【砍树】后端支持NPC仿真实玩家战斗和快速战斗（防范剩余血量计算报错；）

hxp

2025-06-09 ce13cefb478f3181792d4e290c4d47f2e55f8774

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
ó 
cc@s 
dd
lm
Z

ddlZddlmZ
ddlZddlmZ
ddlmZ
ddl    m
Z
mZmZm Z mZmZmZ
ddlmZ
ddlmZmZ
ddlZed    ƒ
ZddlZyddlZWnek
r



ddlZn
Xd
e
f
d„ƒYZdS(iÿÿÿÿ(
tThreadN(
tsleep(
tmylog(
tCommFunc(tSingletonObjecttCommonDefinet    FuncGradetGlobalFunctionsterrort
SpeedGradetStat(
t MongoDBServer(tSendPackProtocolt
MMORPGPacksConfig.DBConfigtCtrlDBc
BséeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Z    d„Z
d    „Zd
„Zd„Z d„Zd „Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„ZRS(cCs

tj
|d
|
ƒ


g|_x9td|ƒD](}d}|jj|tjƒgƒ

q,W||_d|_d|_    d|_
d|_t|_ tj|
ƒ
|_tj|
ƒ
|_ddg|_tjƒ|_t|_d|_t|_d|_d|_dS(Ntnameit((Rt__init__tpriorityQueueListtxrangetappendtQueuet ctrlDBManagertNonet _CtrlDB__hostt _CtrlDB__portt_CtrlDB__dbNamet_CtrlDB__reconnectCnttFalset_CtrlDB__elegantExitRtFuncGradeManagertfuncGradeManagerR    t SpeedGradeMgrtspeedGradeManagertStatet    threadingtLockt
StateMutextQueueSizeExceedThresholdtBlockCntt    Connectedt
connectiontdb(tselft
threadNametpriorityQueueSizeRt
itqueueProcessRequestType((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyRs*
    


 
    
    
    
    
    
    



    
        
    
cCsHtj
r5|jjƒ
d
d
g|_|jjƒ
nd
d
g|_dS(Ni(tDBConfigtMultiThreadingR%tacquireR"trelease(R+tRequest((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyt
clearState6s
    
 

cCsTtj
r;|jjƒ
|
tjƒg|_|jjƒ
n|
tjƒg|_dS(
N(R0R1R%R2ttimeitt default_timerR"R3(R+tcurrentProcessingRequest((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pytupdateState?s

    
 

c
Csˆtj
r@|jjƒ
|jd
}
|jd}|jjƒ
n|jd
}
|jd}|
sddStjƒ}d|
||||fS(Nii
s
-s)Type = %s, process time = %s secs, %s, %s(R0R1R%R2R"R3R6R7(R+tstatetstartProcessTicktcurrentTime((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pytgetStateGs
    
 
 
 
 
 


c


Cs|jS(
N(
R(
R+((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pytGetFuncGradeManagerVs
c


Cs|jS(
N(
R!(
R+((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pytGetSpeedGradeMgrYs
cCs|jj
|
ƒ
S(
N(RtGetFuncGrade(R+tfuncName((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyR@\s
cCs|jj
|
ƒ
S(
N(R!t GetSpeedGrade(R+R((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyRB_s
c

Cs t|j
ƒ
S(
N(tlenR(
R+((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pytgetPrioorityQueueCntbs
cCs|j|
d
j
ƒS(Ni
(Rtqsize(R+tindex((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pytgetPriorityQueueSizees
cCsEtj
ƒjƒ}tj|jƒ_|j|
ƒ

|jj    |ƒ

dS(
N(
RtgetPackPooltallocRtatInnertgetPackHeadttypet    setBufferRt dbRequestPush(R+tbuftsendPack((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyt sendDBRequesths


 
c    Cs®tj
d
|
|||||fƒ

tjƒjƒ}|j|
ƒ

||jƒ_||jƒ_||jƒ_    ||jƒ_
||jƒ_|j|ƒ

|j j|ƒ

dS(NsksendViaSessiondID = %s, sessionID = %s, poolIndex = %s, type = %s, dstSvrType = %s,         srcSvrType = %s(RtdebugRRHRItsetSessionIDRKt    sessionIDt    poolIndexRLt
dstSvrTypet
srcSvrTypeRMRtdbAnswerPush(    R+tsendViaSessiondIDRTRURLRVRWRORP((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pytpackSendns


 





 
cCs5tj
ƒj|
jƒƒ
}|r1|j|
ƒ

ndS(
N(RtgetServerMgrtFindServerByClientSessionIDtgetSessionIDtpushSend(R+tpacktoServer((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyR^|s

cCsHxAtd
t
|jƒ
ƒD]'}|j|d
}|
|krtSqWtS(Ni(RRCRtTrueR(R+trequestTypeR.trequestTypeList((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyt
canProcess‚s




cCs|
|_||_
dS(
N(RR(R+thosttport((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyt    setServerŠs
    
cCs|
|_||_
||_dS(
N(Rt_CtrlDB__dbUsert_CtrlDB__dbPwd(R+tdbNametusertpwd((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pytsetDataBaseŽs
    
    
cCs
d
}tj
|
jƒ|ƒ\}}d}xGtd
t|jƒ
ƒD]-}|j|d
}||krC|}PqCqCW|d
ks•|t|jƒ
krÂtjdtjd|ƒ}t    j|ƒ

t
St    jd||fƒ

|jd|ƒ
j ƒ
|j|dj|
ƒ

tS(NiiÿÿÿÿRspriorityLV = %s not found!spack type = %s add to queue %ssrequestPush_%si
(RtReadBYTEt    getBufferRRCRRt    formatMsgtERROR_NO_42RRRRRBtRefreshtputRa(R+R_tposRbt
priorityLVR.Rctmsg((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pytrequestPushs 








!

 




c
Cstj
r
d
}
xÅtd
t|jƒ
ƒD]«}|j|djƒtjkr¦|jsÓ|jd7_t    |_t
jd|jƒ||j|djƒfƒ

qÓq(|j|djƒtj kr(|
d7}
q(q(W|jr
|
t|jƒ
kr
t|_t
jd|jƒƒ

q
nxãtd
t|jƒ
ƒD]É}y|j|djƒ}Wntjk
rn



q4
n
X|r4
d
}tj|jƒ|ƒ\}}|jd|ƒ
jƒ
tjƒ}|j|ƒ

t
jd||jƒfƒ

tjƒj|ƒ

|Sq4
WdS(Nii
s!!!*** %s queue %s size = %ss$!!!*** %s queue resume low balanced!s requestPop_%ss)pop pack from queue(priorityLV = %s) = %s( R0tStartProfileRRCRREtProfileQueueThresholdMaxR&R'RaRtwarningtgetNametProfileQueueThresholdMinRt
get_nowaitRtEmptyRRnRoRBRrR tMMORPGPacket_StacktassignRRtoutputStringRRHtfreeR(R+tlowBalanceQueueCntR.R_RtRbtret((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyt__requestPop¯s8    


 
    

    
7
 


    









 


c
    CsEx>tr@yb|j
sÄtjd
|j|jfƒ

tj|j|jdtƒ
|_    |j    |j
|_t|_
tjd|j|jfƒ

tj |j|jd|j    ƒ
s±dS|j|jƒ

n|jƒ}
tjr
|
dkr*
|jròPntdƒ

wq*
n%|
dkr
Pntjƒjd7_d}d}|
jƒdkr”
d}tj|
jƒ|ƒ\}}|j|ƒ

tjr”
t j!ƒ}q”
n|j"|j|
ƒ}|rtjrþ
|rþ
t j!ƒ|}|tj#dkrþ
tj$d    ||fƒ

qþ
n|j%|ƒ

ntj&d
t'|
jƒdƒ
ƒ

|r;wnt(j)dt(j*d|
j+ƒƒ}tj(|ƒ

Wqtj,j-k
r


|j.d7_.tjd |j|j|j.fƒ

|j.tj/krþt(j)dt(j0d|j|jfƒ}tj1|ƒ

dSt}q


t(j)dt(j2dt3j4ƒƒ}tj(|ƒ

qXqWdS(Ns!!!!!!!!!!!connect %s:%stauto_start_requests!!!!!!!!!!!connect %s:%s ok!R)gš™™™™™¹?i
ig@@s.!!!---request type = %s process time = %s secssend process request type = %dRsfailed to process pack = %ss"try reconnecting %s:%s cnt = %s...tfatalsreconnect %s:%s failed!s%s(5RaR(RtinfoRRtpymongot
ConnectionRR)RR*RtLoginMongoDBRhRit onConnectedOKt_CtrlDB__requestPopR0R1RRR
R
tGetStattDBProcessCountt    getLengthRRnRoR9RxR6R7trequestLogicProcesstProfileThresholdRzR5RRtordRRptERROR_NO_43Rterrorst AutoReconnectRtmaxReconnectCnttERROR_NO_44R‡tERROR_NO_45t    tracebackt
format_exc(    R+R_RbtprocessStartTickRttresulttprocessTimeRvt
bConnected((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyt__requestProcessÑsh    

    

!

    
!

    

    



    






     




!

"


#

(
 

    
"
c

Cs1|jƒ
t
jr-tjd
|jƒƒ

ndS(NsThread %s exit!(t_CtrlDB__requestProcessR0R1RRˆR{(
R+((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pytrun
s

    
cCstj
d
ƒ

dS(s×ÓÀàʵÏÖs
unhandled!N(RRz(R+R*R_((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyR‘
sc
Csd
S(s×ÓÀàʵÏÖN((R+R*((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyRŒ
sc

Cs:t|_
tj|ƒ

tjd
|jƒ|jfƒ

dS(NsThread %s(%s) start!(RRRtstartRRˆR{tident(
R+((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyR£#
s
    
 
c

CsXtj
d
|jƒƒ

t|_x|jƒr<tdƒ

q#Wtj
d|jƒƒ

dS(NsStoping thread %s...gš™™™™™¹?sThread %s stop OK!(RRˆR{RaRtisAliveR
(
R+((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pytstop(
s


    

cCs„tj
ƒ}||_d
|_|jƒ|}|j|
jƒ|
jƒj|
jƒj    |
jƒj
|
jƒj|
jƒj|ƒ
dS(Ni
( RttagDBToGameServerHeadtTypetSuccesst    GetBufferRZR]RKRTRURLRWRV(R+trecvPackRLtdataRPtsendBuf((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pytsendGameServerString0
s

    
    




(t__name__t
__module__RR5R9R=R>R?R@RBRDRGRQRZR^RdRgRmRwRR¡R¢R‘RŒR£R¦R®(((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyRs2
                                                                            "    D                    (R#RRttimeR
R‰tCommonRRtDBCommonRRRRRR    R
tNetRtProtocolRR Ršt
__import__R0R6tImportErrortdummy_threadingR(((sO.\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\LogicProcess\CtrlDB.pyt<module>s 





4