- 下发ServerMsgNewWait4ApproveAfsOrder, ServerMsgKeyAfsOrderStatusChanged消息
This commit is contained in:
@@ -70,7 +70,7 @@ func routinueFunc() {
|
|||||||
registerMsg := msg.MsgData.(*MsgOp)
|
registerMsg := msg.MsgData.(*MsgOp)
|
||||||
delete(channelMap[registerMsg.StoreID], registerMsg.Chan2Listen)
|
delete(channelMap[registerMsg.StoreID], registerMsg.Chan2Listen)
|
||||||
close(registerMsg.Chan2Close)
|
close(registerMsg.Chan2Close)
|
||||||
case ServerMsgNewOrder, ServerMsgKeyOrderStatusChanged:
|
case ServerMsgNewOrder, ServerMsgKeyOrderStatusChanged, ServerMsgNewWait4ApproveAfsOrder, ServerMsgKeyAfsOrderStatusChanged:
|
||||||
globals.SugarLogger.Debugf("msghub routinueFunc, msg:%s", utils.Format4Output(msg, true))
|
globals.SugarLogger.Debugf("msghub routinueFunc, msg:%s", utils.Format4Output(msg, true))
|
||||||
utils.CallFuncAsync(func() {
|
utils.CallFuncAsync(func() {
|
||||||
for chan2Send := range channelMap[msg.StoreID] {
|
for chan2Send := range channelMap[msg.StoreID] {
|
||||||
|
|||||||
Reference in New Issue
Block a user