import os
from configurations.constants import *
from services.job_service import *

from apscheduler.schedulers.background import BlockingScheduler

scheduler = BlockingScheduler()

@scheduler.scheduled_job('cron', day_of_week=os.environ.get('G_DAY'), hour=os.environ.get('G_HOUR'), minute=os.environ.get('G_MINUTE'), id='01', name=JOB['GENERATE']['SOCIAL_INTEREST_SIMILARITY'])
def social_interest_similarity_job_with_lcn():
	params = {
		'location': True,
		'chapter': True,
		'nationality': True
	}
	try:
		print "social_interest_similarity_job_with_lcn is running."
		g_social_interest_similarity_job(params)
	except:
		print "social_interest_similarity_job_with_lcn is failed!"


@scheduler.scheduled_job('cron', day_of_week=os.environ.get('G_DAY'), hour=os.environ.get('G_HOUR')+6, minute=os.environ.get('G_MINUTE'), id='02', name=JOB['GENERATE']['SOCIAL_INTEREST_SIMILARITY'])
def mutual_friend_job_with_lcn():
	params = {
		'location': True,
		'chapter': True,
		'nationality': True
	}
	try:
		print "mutual_friend_job_with_lcn is running."
		g_mutual_friends_job(params)
	except:
		print "mutual_friend_job_with_lcn is failed!"


@scheduler.scheduled_job('cron', day_of_week=os.environ.get('R_DAY'), hour=os.environ.get('R_HOUR'), minute=os.environ.get('R_MINUTE'), id='11', name=JOB['RETRIEVE']['SOCIAL_INTEREST_SIMILARITY'])
def interest_similarity_sqs_job():
	try:
		print "interest_similarity_sqs_job is running."
		r_interest_similarity_job()
	except:
		print "interest_similarity_sqs_job is failed!"

@scheduler.scheduled_job('cron', day_of_week=os.environ.get('R_DAY'), hour=os.environ.get('R_HOUR'), minute=os.environ.get('R_MINUTE'), id='12', name=JOB['RETRIEVE']['SOCIAL_INTEREST_SIMILARITY'])
def mutual_friend_sqs_job():
	try:
		print "mutual_friend_sqs_job is running."
		r_mutual_friend_job()
	except:
		print "mutual_friend_sqs_job is failed!"



scheduler.start()
import os
from configurations.constants import *
from services.job_service import *

from apscheduler.schedulers.background import BlockingScheduler

scheduler = BlockingScheduler()

@scheduler.scheduled_job('cron', day_of_week=os.environ.get('G_DAY'), hour=os.environ.get('G_HOUR'), minute=os.environ.get('G_MINUTE'), id='01', name=JOB['GENERATE']['SOCIAL_INTEREST_SIMILARITY'])
def social_interest_similarity_job_with_lcn():
	params = {
		'location': True,
		'chapter': True,
		'nationality': True
	}
	try:
		print "social_interest_similarity_job_with_lcn is running."
		g_social_interest_similarity_job(params)
	except:
		print "social_interest_similarity_job_with_lcn is failed!"


@scheduler.scheduled_job('cron', day_of_week=os.environ.get('G_DAY'), hour=int(os.environ.get('G_HOUR') + 6), minute=os.environ.get('G_MINUTE'), id='02', name=JOB['GENERATE']['SOCIAL_INTEREST_SIMILARITY'])
def mutual_friend_job_with_lcn():
	params = {
		'location': True,
		'chapter': True,
		'nationality': True
	}
	try:
		print "mutual_friend_job_with_lcn is running."
		g_mutual_friends_job(params)
	except:
		print "mutual_friend_job_with_lcn is failed!"


@scheduler.scheduled_job('cron', day_of_week=os.environ.get('R_DAY'), hour=os.environ.get('R_HOUR'), minute=os.environ.get('R_MINUTE'), id='11', name=JOB['RETRIEVE']['SOCIAL_INTEREST_SIMILARITY'])
def interest_similarity_sqs_job():
	try:
		print "interest_similarity_sqs_job is running."
		r_interest_similarity_job()
	except:
		print "interest_similarity_sqs_job is failed!"

@scheduler.scheduled_job('cron', day_of_week=os.environ.get('R_DAY'), hour=os.environ.get('R_HOUR'), minute=os.environ.get('R_MINUTE'), id='12', name=JOB['RETRIEVE']['SOCIAL_INTEREST_SIMILARITY'])
def mutual_friend_sqs_job():
	try:
		print "mutual_friend_sqs_job is running."
		r_mutual_friend_job()
	except:
		print "mutual_friend_sqs_job is failed!"



scheduler.start()
fix bug