This repository has been archived by the owner on Dec 6, 2019. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 1
/
manager.py
72 lines (62 loc) · 1.85 KB
/
manager.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
# -*- coding: utf-8 -*-
"""
"""
# @Time: 2017/6/23 10:02
# @Author:still_night@163.com
# @File: manager.py
import const
import Queue
from time import sleep
from random import random
import process_order,recv_message
from log import logging
def loop_process_order(q):
while True:
logging.debug("q.get start")
info=q.get()
logging.debug("q.get end %s"%info['student_id'])
logging.info(u"开始处理订单:获取到 " + str(info[u'student_id']))
process_order.process_order(info)
sleep(15*random())
def manage():
logging.info("****start manager *********")
logging.debug(const.sys.path)
# m=Manager()
# q=m.Queue()
# p=Process(target=recv_message.recv_to_queue,args=(q,))
# p.start()
# num=3
# pool=Pool(num)
q=Queue.Queue()
m=recv_message.Mailbox(queue=q)
while True:
m.recv_to_queue(q)
while not q.empty():
info = q.get()
logging.debug("q.get end %s" % info['student_id'])
logging.info(u"开始处理订单:获取到 " + str(info[u'student_id']))
process_order.process_order(info)
sleep(10 )
sleep(60)
# loop_process_order(q)
# pool.map(loop_process_order,[q for i in range(num)])
if __name__ == '__main__':
t=0
while True:
try:
manage()
except Exception ,e:
logging.error(e)
finally:
t += 1
if t%5==0:
import send_mail
try:
f=open(const.INFOLOGFILE)
except:
pass
s=f.read()
try:
send_mail.send("ruizhiqing@foxmail.com","[yjpj]infolog",s)
except:
pass