0312 新卡牌服务器

hch

2025-05-16 5f8f590c4b577b1a81bbfff7aa69b8b01e7ff804

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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
#!/usr/bin/python 
# -*- coding: GBK -*- 
#------------------------------------------------------------------------------- 
# 
#------------------------------------------------------------------------------- 
# 
from Protocol import (MMORPGPack,RecvPackProtocol, SendPackProtocol) 
from Common import (CommFunc, mylog) 
 
# from DBCommon import (CommonDefine,SingletonObject) 
# import GMToolCommandMgr 
# g_GMCMDMgr = GMToolCommandMgr.GetGMOrderMgr() 
 
##################################################################  
                ####### ÌṩµÄ½Ó¿Ú ###### 
#ת·¢GM¹¤¾ßÃüÁî°üµ½GameServer   
def SendGMToolCommandToGameServer(pack): 
    # global g_GMCMDMgr 
      
    # recvPack = RecvPackProtocol.tagGMCommand() 
    # recvPack.ReadData(pack.getBuffer()) 
    # recvPack.Type = CommonDefine.bgDBGMCommand 
     
    # mylog.info('ProjSpecialProcess SendGMToolCommandToGameServer OrderId = %s'%recvPack.OrderId) 
     
    # ServerMgr = MongoDBServer.getServerMgr() 
    # sendViaSessionID = ServerMgr.getClientSessionIDByName("CenterGate",0) 
     
    # SessionID = 0 
    # PoolIndex = -1 
    # mylog.info('ProjSpecialProcess SendGMToolCommandToGameServer sendViaSessionID = %s,SessionID = %d,PoolIndex = %d'%( 
    #                                                                                                            sendViaSessionID, 
    #                                                                                                            SessionID, 
    #                                                                                                            PoolIndex)) 
    # ServerMgr.packSendBySessionID(sendViaSessionID, SessionID, PoolIndex, 
    #               CommonDefine.atInner, 
    #               MMORPGPack.stGame, MMORPGPack.stData,  
    #               recvPack.GetBuffer()) 
    mylog.info('ProjSpecialProcess SendGMToolCommandToGameServer Done')  
     
#»Ø¸´GM¹¤¾ßÃüÁîÖ´Ðнá¹û°ü 
def SendToGMToolCommandResult(OrderLen,OrderId,ResultLen,Result,UserDataLen,UserData): 
    # global g_GMCMDMgr 
    # if isinstance(Result, unicode): 
    #     #Ö±½Ó´ÓÊý¾Ý¿âδ½øÐÐת»¯µÄ»°ÊÇunicode 
    #     Result = Result.encode('gbk') 
         
    # mylog.info('ProjSpecialProcess SendToGMToolCommandResult OrderId = %s'%OrderId)  
    # recvPack = SendPackProtocol.tagGMCommandResult() 
    # recvPack.Type = CommonDefine.gstGMToolCommandResult  
    # recvPack.OrderLen = OrderLen 
    # recvPack.OrderId = OrderId 
    # recvPack.ResultLen     = ResultLen 
    # recvPack.Result        = Result 
    # recvPack.UserDataLen   = UserDataLen 
    # recvPack.UserData      = UserData 
     
     
    # sendViaSessionID =  g_GMCMDMgr.PopPair(recvPack.OrderId) 
    # ServerMgr = MongoDBServer.getServerMgr()              
     
    # SessionID = 0 
    # PoolIndex = -1 
    # mylog.info('ProjSpecialProcess SendToGMToolCommandResult sendViaSessionID = %s,SessionID = %d,PoolIndex = %d'%(sendViaSessionID, SessionID,PoolIndex)) 
    # if sendViaSessionID == '': 
    #     mylog.warning('ProjSpecialProcess SendToGMToolCommandResult Fail, No Client in GMToolPort') 
    #     return 
     
    # ServerMgr.packSendBySessionID(sendViaSessionID, SessionID, PoolIndex, 
    #               CommonDefine.atInner, 
    #               MMORPGPack.stGMTool, MMORPGPack.stData,  
    #               recvPack.GetBuffer()) 
    mylog.info('ProjSpecialProcess SendToGMToolCommandResult Done')   
  
#·¢ËÍÊý¾Ý¿âÇëÇó 
def SendDBRequest(Type,OrderLen,OrderId,DataLen,Data): 
    #Type˵Ã÷ 
    #CommonDefine.gstGMToolCmdSysDBRequest         #GM¹¤¾ßSysCtrlDBÇëÇóÀàÐÍ   
    #CommonDefine.gstGMToolCmdLogDBRequest         #GM¹¤¾ßLogCtrlDBÇëÇóÀàÐÍ   
    #CommonDefine.gstGMToolCmdUserDBRequest        #GM¹¤¾ßUserCtrlDBÇëÇóÀàÐÍ 
     
 
    # #¹¹½¨ÇëÇó°ü 
    # pack = RecvPackProtocol.tagGMCommandDBRequest() 
    # pack.Type = Type 
    # pack.OrderLen = OrderLen 
    # pack.OrderId = OrderId 
    # pack.DataLen = DataLen 
    # pack.Data = Data 
    # #·¢ÇëÇó°ü 
    # sendPack = SingletonObject.getPackPool().alloc() 
    # sendPack.setSendViaSocketID(-1) 
    # sendPack.getPackHead().sessionID = 0 
    # sendPack.getPackHead().poolIndex = -1 
    # sendPack.getPackHead().type = CommonDefine.atInner 
    # sendPack.setBuffer(pack.GetBuffer()) 
    # ctrlDBMgr = CtrlDBManager.getCtrlMgr() 
    # ctrlDBMgr.dbRequestPush(sendPack) 
    # mylog.info('ProjSpecialProcess SendDBRequest Done ,Type = %s, OrderId = %s'%(Type,OrderId))  
    return True 
 
#·¢ËÍÂß¼­´¦ÀíÇëÇó 
def SendLogicProcessRequest(Type,OrderLen,OrderId,DataLen,Data): 
    #Type˵Ã÷ 
    #CommonDefine.gstGMToolCmdLogicProcessRequest  #GM¹¤¾ßLogicÇëÇóÀàÐÍ 
    #¹¹½¨ÇëÇó°ü 
    # pack = RecvPackProtocol.tagGMCommandDBRequest() 
    # pack.Type = Type 
    # pack.OrderLen = OrderLen 
    # pack.OrderId = OrderId 
    # pack.DataLen = DataLen 
    # pack.Data = Data 
    # #·¢ÇëÇó°ü 
    # sendPack = SingletonObject.getPackPool().alloc() 
    # sendPack.setSendViaSocketID(-1) 
    # sendPack.getPackHead().sessionID = 0 
    # sendPack.getPackHead().poolIndex = -1 
    # sendPack.getPackHead().type = CommonDefine.atInner 
    # sendPack.setBuffer(pack.GetBuffer()) 
     
    # logicProcess = GlobalVarDefine.g_logicProcessThread 
    # if logicProcess == None: 
    #     mylog.warning('ProjSpecialProcess SendLogicProcessRequest Fail!!! logicProcessThread == None??') 
    #     return False 
    # logicProcess.requestPush(sendPack) 
    # mylog.info('ProjSpecialProcess SendLogicProcessRequest Done ,Type = %s, OrderId = %s'%(Type,OrderId))  
    return True 
     
       
##################################################################