scbc_repos/ssat_sdk/service/service_config.py

# -*- coding:utf-8 -*-
import os, sys, time
import shutil

from ssat_sdk.utils import Environment
from ConfigParser import *
import thread

try:
    Python_Home = sys.prefix
    # Server_CFG_Path = Python_Home + Environment.SDK_Relative_Path + u"config/server.cfg"
    Server_CFG_Path = Python_Home + Environment.SDK_Relative_Path + u"config/server_run.cfg"
    Server_CFG_Local_Path = Python_Home + Environment.SDK_Relative_Path + u"config/server.cfg"
    # Server_CFG_Path = "../config/server.cfg"
    Home_Init = True
except KeyError, e:
    print "KeyError:", e.message

class ServiceConfig():
    ServiceModel = "service"
    CFGParser = ConfigParser()
    CFGParser.read(Server_CFG_Path)

    def __init__(self):
        if not os.path.exists(Server_CFG_Path):
            print 'server_run.cfg文件不存在，复制server.cfg文件'
            shutil.copy(Server_CFG_Local_Path, Server_CFG_Path)
        print u"Server配置文件：", Server_CFG_Path

    def writeCFG(self):
        self.CFGParser.write(open(Server_CFG_Path, "w"))

    def setCCardListenerPort(self, listener_port):
        self.CFGParser.set("service","ccard_port", listener_port)
        self.writeCFG()

    def getCCardListenerPort(self):
        value = self.CFGParser.getint("service", "ccard_port")
        return value

    def setC22293ListenerPort(self, listener_port):
        self.CFGParser.set("service","c22293_port", str(listener_port))
        self.writeCFG()

    def getC22293ListenerPort(self):
        value = self.CFGParser.get("service", "c22293_port")
        value_int = int(value)
        return value_int

    def setSDKServer(self, onOff):
        self.CFGParser.set("service","onOff", onOff)
        self.writeCFG()

    def getSDKServer(self):
        return self.CFGParser.get("service", "onOff")

    def setSDKListenerPort(self, listener_port):
        self.CFGParser.set("service", "sdk_port", listener_port)
        self.writeCFG()

    def getSDKListenerPort(self):
        value = self.CFGParser.getint("service", "sdk_port")
        return value

    def setTG39ListenerPort(self, listener_port):
        self.CFGParser.set("service", "tg39_port", str(listener_port))
        self.writeCFG()

    def getTG39ListenerPort(self):
        value = self.CFGParser.get("service", "tg39_port")
        value_int = int(value)
        return value_int

    def setUB530ListenerPort(self, listener_port):
        self.CFGParser.set("service", "ub530_port", str(listener_port))
        self.writeCFG()

    def getUB530ListenerPort(self):
        value = self.CFGParser.get("service", "ub530_port")
        value_int = int(value)
        return value_int

    def setRedRatHubPort(self, listener_port):
        self.CFGParser.set("service", "redrathub_port", listener_port)
        self.writeCFG()

    def getRedRatHubPort(self):
		try:
			return self.CFGParser.getint("service","redrathub_port")
		except:
			return 40000

    def getRedRatHubSignalXml(self):
        try:
            return self.CFGParser.get("service","redrathub_signal")
        except:
            return None
    
    def setRedRatHubSignalXml(self, signal_xml):
        self.CFGParser.set("service", "redrathub_signal", signal_xml)
        self.writeCFG()

def testCFG():
    print "testCFG:"
    serviceCFG = ServiceConfig()

if __name__ == "__main__":
    thread.start_new_thread(testCFG,())
    thread.start_new_thread(testCFG,())
    thread.start_new_thread(testCFG,())

    time.sleep(3)