|
|
@ -221,34 +221,6 @@ def getPort(): |
|
|
|
return tmp.groups()[0] |
|
|
|
return tmp.groups()[0] |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def queryLog(): |
|
|
|
|
|
|
|
path = getConf() |
|
|
|
|
|
|
|
content = mw.readFile(path) |
|
|
|
|
|
|
|
rep = 'query_log\s*=\s*(.*)' |
|
|
|
|
|
|
|
tmp = re.search(rep, content) |
|
|
|
|
|
|
|
return tmp.groups()[0] |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def runStatus(): |
|
|
|
|
|
|
|
s = status() |
|
|
|
|
|
|
|
if s != 'start': |
|
|
|
|
|
|
|
return mw.returnJson(False, '没有启动程序') |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
sys.path.append(getPluginDir() + "/class") |
|
|
|
|
|
|
|
import sphinxapi |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
sh = sphinxapi.SphinxClient() |
|
|
|
|
|
|
|
port = getPort() |
|
|
|
|
|
|
|
sh.SetServer('127.0.0.1', port) |
|
|
|
|
|
|
|
info_status = sh.Status() |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
rData = {} |
|
|
|
|
|
|
|
for x in range(len(info_status)): |
|
|
|
|
|
|
|
rData[info_status[x][0]] = info_status[x][1] |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return mw.returnJson(True, 'ok', rData) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if __name__ == "__main__": |
|
|
|
if __name__ == "__main__": |
|
|
|
func = sys.argv[1] |
|
|
|
func = sys.argv[1] |
|
|
|
if func == 'status': |
|
|
|
if func == 'status': |
|
|
@ -277,7 +249,5 @@ if __name__ == "__main__": |
|
|
|
print(runLog()) |
|
|
|
print(runLog()) |
|
|
|
elif func == 'query_log': |
|
|
|
elif func == 'query_log': |
|
|
|
print(queryLog()) |
|
|
|
print(queryLog()) |
|
|
|
elif func == 'run_status': |
|
|
|
|
|
|
|
print(runStatus()) |
|
|
|
|
|
|
|
else: |
|
|
|
else: |
|
|
|
print('error') |
|
|
|
print('error') |
|
|
|