def putSettingEvent(self, settingName, algoSetting):
     """发出算法配置更新事件"""
     algoSetting['settingName'] = settingName
     
     event = Event(EVENT_ALGO_SETTING)
     event.dict_['data'] = algoSetting
     self.eventEngine.put(event)

 def writeCtaLog(self, content):
     """快速发出CTA模块日志事件"""
     log = VtLogData()
     log.logContent = content
     event = Event(type_=EVENT_CTA_LOG)
     event.dict_['data'] = log
     self.eventEngine.put(event)   

 def writeDrLog(self, content):
     """快速发出日志事件"""
     log = VtLogData()
     log.logContent = content
     event = Event(type_=EVENT_DATARECORDER_LOG)
     event.dict_['data'] = log
     self.eventEngine.put(event)   

 def writeLog(self, content):
     """快速发出日志事件"""
     print "%s.%s.%s" % (__name__, self.__class__.__name__, get_current_function_name())
     log = VtLogData()
     log.logContent = content
     event = Event(type_=EVENT_LOG)
     event.dict_['data'] = log
     self.eventEngine.put(event)

 def writeLog(self, content):
     """快速发出日志事件"""
     log = VtLogData()
     log.logContent = content
     log.gatewayName = 'MAIN_ENGINE'
     event = Event(type_=EVENT_LOG)
     event.dict_['data'] = log
     self.eventEngine.put(event)        

 def writeLog(self, content):
     """发出日志事件"""
     log = VtLogData()
     log.logContent = content
     log.gatewayName = 'JAQS_SERVICE'
     event = Event(type_=EVENT_JS_LOG)
     event.dict_['data'] = log
     self.eventEngine.put(event)         

 def writeLog(self, msg):
     """"""
     log = VtLogData()
     log.logContent = msg
     
     event = Event(EVENT_TC_LOG)
     event.dict_['data'] = log
     self.eventEngine.put(event)

 def writeLog(self, content):
     """发出日志 """
     log = VtLogData()
     log.logContent = content
     
     event = Event(EVENT_OM_LOG)
     event.dict_['data'] = log
     self.eventEngine.put(event)         

 def writeLog(self, content):
     """输出日志"""
     log = VtLogData()
     log.logContent = content
     
     event = Event(EVENT_SPREADTRADING_ALGOLOG)
     event.dict_['data'] = log
     
     self.eventEngine.put(event)

 def putSpreadPosEvent(self, spread):
     """发出价差持仓事件"""
     event1 = Event(EVENT_SPREADTRADING_POS+spread.name)
     event1.dict_['data'] = spread
     self.eventEngine.put(event1)
 
     event2 = Event(EVENT_SPREADTRADING_POS)
     event2.dict_['data'] = spread
     self.eventEngine.put(event2)         

 def putSpreadTickEvent(self, spread):
     """发出价差行情更新事件"""
     event1 = Event(EVENT_SPREADTRADING_TICK+spread.name)
     event1.dict_['data'] = spread
     self.eventEngine.put(event1)
     
     event2 = Event(EVENT_SPREADTRADING_TICK)
     event2.dict_['data'] = spread
     self.eventEngine.put(event2)        

 def writeLog(self, content):
     """记录日志"""
     log = VtLogData()
     log.logContent = content
     log.gatewayName = self.ENGINE_NAME
     
     event = Event(EVENT_RTDSERVICE_LOG)
     event.dict_['data'] = log
     self.eventEngine.put(event)

    def cancelOrder(self, cancelOrderReq, gatewayName):
        """对特定接口撤单"""
        gateway = self.getGateway(gatewayName)

        event1 = Event(type_=EVENT_PRE_CANCEL_ORDER)
        event1.dict_['data'] = cancelOrderReq
        self.eventEngine.put(event1)
        
        if gateway:
            gateway.cancelOrder(cancelOrderReq)   

    def writeLog(self, content, algo=None):
        """输出日志"""
        log = VtLogData()
        log.logContent = content
        
        if algo:
            log.gatewayName = algo.algoName

        event = Event(EVENT_ALGO_LOG)
        event.dict_['data'] = log
        self.eventEngine.put(event)

 def putStrategyEvent(self, name):
     """触发策略状态变化事件（通常用于通知GUI更新）"""
     strategy = self.strategyDict[name]
     d = {k:strategy.__getattribute__(k) for k in strategy.varList}
     
     event = Event(EVENT_CTA_STRATEGY+name)
     event.dict_['data'] = d
     self.eventEngine.put(event)
     
     d2 = {k:str(v) for k,v in d.items()}
     d2['name'] = name
     event2 = Event(EVENT_CTA_STRATEGY)
     event2.dict_['data'] = d2
     self.eventEngine.put(event2)        

    def writeRiskLog(self, content):
        """快速发出日志事件"""
        # 发出报警提示音

        if platform.uname() == 'Windows':
            import winsound
            winsound.PlaySound("SystemHand", winsound.SND_ASYNC)

        # 发出日志事件
        log = VtLogData()
        log.logContent = content
        log.gatewayName = self.name
        event = Event(type_=EVENT_LOG)
        event.dict_['data'] = log
        self.eventEngine.put(event)

    def sendOrder(self, orderReq, gatewayName):
        """对特定接口发单"""
        # 如果创建了风控引擎，且风控检查失败则不发单
        if self.rmEngine and not self.rmEngine.checkRisk(orderReq, gatewayName):
            return ''

        gateway = self.getGateway(gatewayName)
        
        event1 = Event(type_=EVENT_PRE_ORDER)
        event1.dict_['data'] = orderReq
        self.eventEngine.put(event1)

        if gateway:
            vtOrderID = gateway.sendOrder(orderReq)
            self.dataEngine.updateOrderReq(orderReq, vtOrderID)     # 更新发出的委托请求到数据引擎中
            return vtOrderID
        else:
            return ''

 def putParamEvent(self, algo, d):
     """更新参数"""
     algoName = algo.algoName
     
     d['algoName'] = algoName
     event = Event(EVENT_ALGO_PARAM)
     event.dict_['data'] = d
     self.eventEngine.put(event)    
     
     # RPC推送
     if self.rpcServer:
         self.rpcServer.publish('AlgoTrading', event)        
     
     # 保存数据到数据库
     history = self.historyDict.setdefault(algoName, {})
     history['algoName'] = algoName
     history['param'] = d
     
     self.mainEngine.dbUpdate(ALGOTRADING_DB_NAME,
                              HISTORY_COLLECTION_NAME,
                              history,
                              {'algoName': algoName},
                              True)        

 def processTradeEvent(self, event):
     """处理成交推送"""
     # 检查成交是否需要处理
     trade = event.dict_['data']
     if trade.vtSymbol not in self.legDict:
         return
     
     # 更新腿持仓
     leg = self.legDict[trade.vtSymbol]
     direction = trade.direction
     offset = trade.offset
     
     if direction == DIRECTION_LONG:
         if offset == OFFSET_OPEN:
             leg.longPos += trade.volume
         else:
             leg.shortPos -= trade.volume
     else:
         if offset == OFFSET_OPEN:
             leg.shortPos += trade.volume
         else:
             leg.longPos -= trade.volume
     leg.netPos = leg.longPos - leg.shortPos
             
     # 更新价差持仓
     spread = self.vtSymbolSpreadDict[trade.vtSymbol]
     spread.calculatePos()
     
     # 推送价差持仓更新
     event1 = Event(EVENT_SPREADTRADING_POS+spread.name)
     event1.dict_['data'] = spread
     self.eventEngine.put(event1)
     
     event2 = Event(EVENT_SPREADTRADING_POS)
     event2.dict_['data'] = spread
     self.eventEngine.put(event2)