#!/usr/bin/python
# -*- coding: utf-8 -*-
import stomp  
import base64
import json
import psycopg2
import time, datetime
import sys
from twisted.web import server, resource
from twisted.internet import reactor
import logging
import os, sys, time
from twisted.internet.protocol import Protocol,Factory
from twisted.internet import reactor, defer, threads
from twisted.protocols.basic import LineReceiver
import sys;
from twisted.python import log ,logfile
'''from twisted.python.log import ILogObserver, FileLogObserver 
from twisted.python.logfile import DailyLogFile 
'''
from twisted.application.service import Application 

application = Application("myapp") 
'''
logFile = DailyLogFile("my.log", "/tmp") 

application.setComponent(ILogObserver, FileLogObserver(logFile).emit) 
log.startLogging(sys.stdout)
'''

#加载需要运行的文件
sys.path.append("twistota");
from  haierappup import Simplehaierapp ;
#from  haierDMUp import Simplehaierdm ;
sys.path.append("Analysis");
from  Analysishaierota import analysihaierota ;
#from  haierDMUp import Simplehaierdm ;
execfile('../../conf/main.py')


#后台启动网关
from twisted.application import internet, service
application = service.Application('echo')
echoService = internet.TCPServer(port_app, server.Site(Simplehaierapp()))
echoService.setServiceParent(application)
#echoServicedm = internet.TCPServer(port_dm, server.Site(Simplehaierdm()))
#echoServicedm.setServiceParent(application)

#后台启动循环脚本
reactor.callLater(1,analysihaierota)