buy/cron.py

# -*- coding: utf-8 -*-
"""
    demeter web
    name:cron.py
    author:rabin
"""
import time
from demeter.core import *
from gevent import monkey; monkey.patch_socket()
import gevent
timeSleep = 10

def run(site, product):
	site['product'] = product
	service = Demeter.service(site['name'])
	service.init(site)
	service.start()
	gevent.sleep(timeSleep)

def handle():
	while 1:
		task = []
		product = Demeter.service('product')
		data = product.get()
		if data:
			for v in data:
				product.status(v['id'], 2)
				site = product.getSite(v['site_id'])
				task.append(gevent.spawn(run, site, [v]))
			gevent.joinall(task)
		gevent.sleep(timeSleep)
		

handle()