52 lines
1.2 KiB
Python
52 lines
1.2 KiB
Python
|
# -*- coding: utf-8 -*-
|
||
|
|
"""
|
||
|
|
@author: eigencomm cfang
|
||
|
|
|
||
|
|
"""
|
||
|
|
|
||
|
|
#!/usr/bin/env python
|
||
|
|
|
||
|
|
#-*- coding:utf-8 -*-
|
||
|
|
import socket
|
||
|
|
import sys
|
||
|
|
import json
|
||
|
|
import time
|
||
|
|
|
||
|
|
LIB_VERSION = "PyEpatlib 0.1"
|
||
|
|
|
||
|
|
class EpatController:
|
||
|
|
_START_CMD =b'{"settings":[{"action":"start","option":""}]}'
|
||
|
|
_STOP_CMD=b'{"settings": [{"action": "stop","option": ""}]}'
|
||
|
|
_SAVE_CMD_PRE='{"settings": [{"action":"save","option":"'
|
||
|
|
_SAVE_CMD_AFTER='"}]}'
|
||
|
|
_UPDATE_DB_CMD_PRE='{"settings": [{"action": "updatedb","option": "'
|
||
|
|
_UPDATE_DB_CMD_AFTER='"}]}'
|
||
|
|
|
||
|
|
def __init__(self,HOST='127.0.0.1',PORT=10565):
|
||
|
|
ADDR = (HOST,PORT)
|
||
|
|
self.tcpCliSock = socket.socket()
|
||
|
|
self.tcpCliSock.connect(ADDR)
|
||
|
|
print('connect host success')
|
||
|
|
|
||
|
|
def EPAT_DB_Setting(self,dbfilepath):
|
||
|
|
send_str=str.encode(self._UPDATE_DB_CMD_PRE+dbfilepath+self._UPDATE_DB_CMD_AFTER)
|
||
|
|
print(send_str)
|
||
|
|
self.tcpCliSock.send(send_str)
|
||
|
|
|
||
|
|
def EPAT_Start(self):
|
||
|
|
print('connect host success')
|
||
|
|
self.tcpCliSock.send(self._START_CMD)
|
||
|
|
|
||
|
|
def EPAT_Stop(self):
|
||
|
|
self.tcpCliSock.send(self._STOP_CMD)
|
||
|
|
|
||
|
|
def EPAT_Save(self,filepath):
|
||
|
|
send_str=str.encode(self._SAVE_CMD_PRE+filepath+self._SAVE_CMD_AFTER)
|
||
|
|
print(send_str)
|
||
|
|
self.tcpCliSock.send(send_str)
|
||
|
|
|
||
|
|
def EPAT_Version(self):
|
||
|
|
print(str(LIB_VERSION))
|
||
|
|
|
||
|
|
if __name__ == '__main__':
|
||
|
|
run()
|