|
@@ -1,40 +1,15 @@
|
|
|
-#!/usr/bin/env python
|
|
|
# -*- coding: utf-8 -*-
|
|
|
-import time
|
|
|
from demeter.core import *
|
|
|
-from gevent import monkey; monkey.patch_socket()
|
|
|
-import gevent
|
|
|
-timeSleep = 15
|
|
|
|
|
|
-def command(file):
|
|
|
- return 'python '+File.path()+'convert.py -f ' + file
|
|
|
+print('''
|
|
|
+********************************************************
|
|
|
+* vecan-robot - 神算终端机器人 *
|
|
|
+* (c) 2019 rabin <rabin@dever.cc> *
|
|
|
+* https://github.com/shemic/vecan.git *
|
|
|
+********************************************************
|
|
|
+ 如需退出,可以按 Ctrl-4 组合键。
|
|
|
+''')
|
|
|
|
|
|
-# 文档转换
|
|
|
-def convert():
|
|
|
- r = Demeter.redis()
|
|
|
- c = Demeter.config['redis']
|
|
|
- i = 0
|
|
|
- while 1:
|
|
|
- file = r.lpop(c['name'])
|
|
|
- if file:
|
|
|
- g = command(file)
|
|
|
- Shell.popen(g, True, True)
|
|
|
- i = i+1
|
|
|
- if i >= 10:
|
|
|
- gevent.sleep(timeSleep)
|
|
|
- i = 0
|
|
|
|
|
|
-# 清理一天前的sign
|
|
|
-def signature():
|
|
|
- while 1:
|
|
|
- service = Demeter.service('convert')
|
|
|
- service.crearSignature()
|
|
|
- gevent.sleep(3600)
|
|
|
-
|
|
|
-def handle():
|
|
|
- gevent.joinall([
|
|
|
- gevent.spawn(convert),
|
|
|
- gevent.spawn(signature),
|
|
|
- ])
|
|
|
-
|
|
|
-handle()
|
|
|
+logger = Log.get(__name__)
|
|
|
+logger.info('测试测试')
|