ó
|
@2Ü[c @ s< d d l Z d d l Z d d l Z d d l Z d d l Td d l m Z d d l Z d d l m Z m
|
Z
|
d d l Z d d l Z d d l Td d l Z d d l Z d d l Z d d l Z d Z d Z e j Z d Z d Z d Z d
|
Z d Z e d Z d d d YZ d e f d YZ d Z d S( iÿÿÿÿN( t *( t Thread( t MapEventPointReadert ChinMapReaders \Config\config.inis \PyMongoDataServer.inii i c C sv d } y* x# t t D] } t j | } q WWn t | f SXx( | D] } | t t | t A 7} qH Wt | f S( Nt ( t ranget BASE64_ENCODE_CNTt base64t decodestringt Falset chrt ordt XOR_KEYt True( t pswt rett i( ( s .\\frame.pyt GetEncodePsw) s s %Y-%m-%d %H:%M:%Sc C sK | j j d d } y t j j | t SWn t k
|
rF } d SXd S( Ns .i ( t stript splitt datetimet strptimet TYPE_Time_Formatt BaseException( t timeStrt e( ( s .\\frame.pyt GetDateTimeByStr7 s c C s. t j j | | j } t t j | S( N( R R t timetuplet intt timet mktime( R t
|
timeFormat( ( s .\\frame.pyt ChangeTimeStrToNum@ s t MongoDBRobotc B s> e Z d Z d Z d Z d Z d Z d Z RS( c C s d | _ d | _ d | _ d | _ d | _ d | _ d | _ d | _ t j
|
j } | j | _ | j | _ | j g | _ d S( NR ( t usert pwdt dbIPt dbNamet Nonet logdbt interfaceDatadbt userdbt
|
connectiont ConfigurationReadert ConfigIniReadert GetConfigt GetPlayerOffTimet PlayerOffTimet GetServerDBConfigPatht ServerDBConfigPatht InitDBCont tokenList( t selft config( ( s .\\frame.pyt __init__G s
|
c C s" t j j | j t } | j d | j d | _ t | j d d | _ t j j | j t
|
} | j d | j d | _ t j | j d d t | _ | j j } | j | j | j sß t j d d S| j | j d
|
| _ | j | j d | _ t j d d S( Nt autht
|
logdb_usert logdb_pwdi t connectt LOG_DB_IPii t auto_start_requests !!!InitDBCon errort LOG_DB_NAMEt USER_DB_NAMEs conn ok-----------( R+ R, t AppConfigR1 t ServerDBConfigPath1t
|
SetSectiont GetValueR" R R# t ServerDBConfigPath2R$ t pymongot
|
ConnectionR R* t admint authenticatet loggingt errorR' R) t info( R4 t dbConfigt dbConfig2t db( ( s .\\frame.pyR2 [ s c C s¶ | j d } t j } | | j } | j i d d 6i | d 6d 6d d 6i d d 6d 6i d
|
d 6d 6 } | sw d Sg } x% | D] } | j t | d q W| j d } xà | D]» } | j i | d 6 } | sá q¹ n | d } | s÷ q¹ n t | }
|
| |
|
d k rq¹ n d } t | d | | t | d t | d f } | | j
|
k r¹ | j
|
j | q¹ q¹ W| j
|
r²t j d t | j
|
t j d | j
|
n d S( Nt tagDBPlayerInfoLogi t IsOnlines $ltt LastLogoffTimei t AccStates $gtt TJGTimei t TJGStatet AccIDt tagDSAccountt ACCIDt LastLoginTimei
|
t abct Pswt Adultt AppIDs ´ýµÇ¼µÄÍÑ»ú¹ÒÍæ¼Ò----:%ss" ´ýµÇ¼µÄÍÑ»ú¹ÒÍæ¼Ò----tokenList:%s( R' R R/ t findt appendt strR) t find_oneR R R3 RH RJ t lent debug( R4 t colt nowTimet offTimet resultSett accIDListt robott accIDt resultR t loginTimet clientMact account( ( s .\\frame.pyt GetTJGRobots s: %"
|
3 c C s | j S( N( R3 ( R4 ( ( s .\\frame.pyt GetTokenListº s c C s | j j | d S( N( R3 t remove( R4 t value( ( s .\\frame.pyt RemoveToken½ s c C s g | _ d S( N( R3 ( R4 ( ( s .\\frame.pyt
|
ClearTokenÀ s ( t __name__t
|
__module__R6 R2 Rm Rn Rq Rr ( ( ( s .\\frame.pyR! F s G t WorkerThreadc B s e Z d Z d Z RS( c C sk t j | d d d | | _ | | _ d | _ t j j } | j | _
|
| j | _ d | _ d S( Nt WorkerThreadPyi ( R R6 R& t mgrt dbRobott lastTimeR+ R, R- t GetProcessFindTJGTimet ProcessFindTJGTimet GetStartRunTimet StartRunTimet lastStartRunTime( R4 Rw Rx R5 ( ( s .\\frame.pyR6 Ä s c C s= t j d | j x y | j j t j d t j } | j d k r^ | | _ n | | j | j k rz w n | | j | j
|
k rÛ | t d k r° t j d n d Gt j j GH| j j | | _ n Wq t k
|
r5} t | GHt j GHt j d t | t j d t j q Xq d S( Ns thread %s startg{®Gáz?i i( t clss -----s WorkerThread: %s( RH Ra t getNameRw t ThreadRunR t sleepR~ R} Ry R{ t g_starttimet ost systemR t todayRx Rm t ExceptionR^ t tracebackt print_excRI ( R4 Rc R ( ( s .\\frame.pyt runÐ s* ( Rs Rt R6 R ( ( ( s .\\frame.pyRu à s c C s t j d | t j d t j j t j j | d t j j } t
|
} t j | t j | t } | j | j | j | j | | j } | sÅ t j d d St j d | j } t j d | t | | } | j t | | d S( Ns PyBaseRoot:%ss title Robot-%ss Configuration\Config.inis Init PyNetwork failed.s Init PyNetwork success.s Host has %d logic processor.( RH RJ R R
R R R+ R, t
|
ReadConfigR- R! R t ReadMapEventPointR t ReadChinMapDatat CAsioMgrt
|
InitModulet GetVersionNot GetPackStartCountt GetKeyStringt GetSendKeyDictFilePatht fatalRa t GetProcessorNumberRu t startt CreateRobotMgr( t
|
PyBaseRootR5 Rx t asioMgrR t nThreadst th( ( s .\\frame.pyt StartAppô s&
|
( ( R t sysR R t binary.PyNetworkt threadingR RH t
|
DataReaderR R t& ConfigurationReader.RobotsConfigReaderR+ t# ConfigurationReader.ConfigIniReadert Robot.RobotMgrR R RD R@ RC R R R R R R R R! Ru R ( ( ( s .\\frame.pyt <module> s4
|
|
}1
|
