ó
|
õ®[c @ s¡ d d l Z d d l m Z d d l Z d d l Z d d l m Z d d l Z d d l Z d e f d YZ
|
d d
|
d YZ d a d Z d Z d S( iÿÿÿÿN( t ProjectRobot( t Threadt AIThreadc B s# e Z d Z d Z d Z RS( c C sr t j | d d d | | | _ g | _ t j j } | j | _ d | _
|
d | _ d | _ d | _ d S( Ns AIThreadPy_%si i ( R t __init__t Nonet robotMgrt AIListt ConfigurationReadert ConfigIniReadert GetConfigt GetTJGLimitCntt tjgLimitCntt lastTimet badRobotCntt ProcessFindTJGTimet lastLoginTime( t selfR t indext config( ( s .\\Tool\Robot\Robot\RobotMgr.pyR s c
|
C st t j d | j xVt royt j } | j rq| | j | j k rqt j d | j | j j
|
| j k r | j j j n | | _ | j j } | j j j } g } xx t t | D]d } | j } | d | k rd G| d GHqÐ n | j j | } | j | | d k rÐ PqÐ qÐ Wx6 | D]+ } | sQq?n | j s?| j q?q?Wn xs t | j j
|
D]\ } | | j j
|
k r¦Pn y | j j | } Wn Pn X| sÓqn | j j qW| j sü| | _ n t j d x· t | j j
|
D] } y | j j | } Wn Pn X| std GH| j j | | j d 7_ Pn | j r d GHt j d | j | j j | | j d 7_ Pq q Wt j } | | j d
|
k r'd | j j
|
| j j f GH| | _ | j r'd | j GHq'n Wq t k
|
rk} t j! d t" | t j! d t# j$ q Xq Wd S( Ns thread %s starts self.tjgLimitCnt %s i s ÕýÔڵǼÖÐ------i
|
g{®Gáz?s ====ûÓлúÆ÷ÈËs ++++++±»´Ý»Ùs GetNeedDestroy __peer:0x%08X i s ÍÑ»ú¹ÒÍæ¼ÒÊýÁ¿: %s - %ss ²Î¿¼-ÀúÊ·Òì³£ÍÑ»ú¹Ò´ÎÊý£º%ss AIThread: %s(% t loggingt infot getNamet Truet timeR R t debugR R t GetRobotCountt dbRobott
|
ClearTokent GetRobotAccIDListt GetTokenListt xranget lent popt AddRobott appendt IsConnectedt ReCreateRobott GetRobott GetAIMgrt ProcessAIt sleept RemoveR t GetNeedDestroyt GetPeerValueR t GetLoginOKRobotCountt Exceptiont errort strt tracebackt print_exc(
|
R t nowTimet logoningListt tokenListt robotListt it tokenInfot robotR t e( ( s .\\Tool\Robot\Robot\RobotMgr.pyt runThread s ! c C s | j } | d S( N( R: ( R t runM( ( s .\\Tool\Robot\Robot\RobotMgr.pyt runy s ( t __name__t
|
__module__R R: R< ( ( ( s .\\Tool\Robot\Robot\RobotMgr.pyR s \t RobotMgrc B sk e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
d Z d
|
Z RS( c C sS | | _ d | _ g | _ g | _ | | _ i | _ t | d } | j d S( Ni ( t _RobotMgr__asioMgrt _RobotMgr__robotNumt _RobotMgr__robotst _RobotMgr__robotAccIDsR t TeamMgrR t start( R t asioMgrR t th( ( s .\\Tool\Robot\Robot\RobotMgr.pyR s c C s> g | _ x+ | j D] } | j j | j d q W| j S( Ni ( RC RB R" t GetRobotConfig( R R8 ( ( s .\\Tool\Robot\Robot\RobotMgr.pyR s c C s: t j d | f t | j | } | j j | | S( Ns Create Robot index:%s.....( R R R R@ RB R" ( R R7 R8 ( ( s .\\Tool\Robot\Robot\RobotMgr.pyR! s c C s t | j S( N( R RB ( R ( ( s .\\Tool\Robot\Robot\RobotMgr.pyR ¡ s c C s7 d } x* | j D] } | j r | d 7} q q W| S( Ni i ( RB R# ( R t nR8 ( ( s .\\Tool\Robot\Robot\RobotMgr.pyt GetConnectedRobotCount¥ s
|
c C sM d } x@ | j D]5 } | j r/ | d 7} q t j d | j q W| S( Ni i s !!!not login :0x%08X( RB t GetIsLoginOKR R R+ ( R RI R8 ( ( s .\\Tool\Robot\Robot\RobotMgr.pyR, s c C s | j | S( N( RB ( R R ( ( s .\\Tool\Robot\Robot\RobotMgr.pyR% Ä s c C s | j j | d S( N( RB t remove( R R8 ( ( s .\\Tool\Robot\Robot\RobotMgr.pyR) É s c C sP | j j } t j d | | j | | j k rL | j | n d S( Ns DisconnectServer for %s( t GetPlayerInfot GetAccIDR R t DestroyRobotRB R) ( R R8 t accID( ( s .\\Tool\Robot\Robot\RobotMgr.pyt DisconnectServerÍ s
|
|
c C s. t j d | | j | } | s* t Sd S( Ns StartAI for %d( R R R% t False( R R R8 ( ( s .\\Tool\Robot\Robot\RobotMgr.pyt StartAI× s c C s. t j d | | j | } | s* t Sd S( Ns StopAI for %d( R R R% RR ( R R R8 ( ( s .\\Tool\Robot\Robot\RobotMgr.pyt StopAIã s ( R= R> R R R! R RJ R, R% R) RQ RS RT ( ( ( s .\\Tool\Robot\Robot\RobotMgr.pyR? s
|
|
c C s t s t | | a n d S( N( t __gRobotMgrR? ( RF R ( ( s .\\Tool\Robot\Robot\RobotMgr.pyt CreateRobotMgr s c C s t S( N( RU ( ( ( s .\\Tool\Robot\Robot\RobotMgr.pyt GetRobotMgr s ( ( R t ProjectBinding.ProjectRobotR t& ConfigurationReader.RobotsConfigReaderR t# ConfigurationReader.ConfigIniReadert threadingR R0 R R R? R RU RV RW ( ( ( s .\\Tool\Robot\Robot\RobotMgr.pyt <module> s p
|
