__main__.py 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. """Main app"""
  2. import time
  3. from app import scheduler, session
  4. from app.api import get_citizens, get_residents
  5. from app.database import get_state_regions # , save_citizens, save_residents
  6. def print_players(players):
  7. """Print professors"""
  8. for player in players:
  9. print('{:20} {:30}'.format(
  10. player['id'],
  11. player['name'],
  12. ))
  13. def job_update_citizens(state_id):
  14. """Update citizens"""
  15. regions = get_state_regions(state_id)
  16. for region in regions:
  17. citizens = get_citizens(region.id)
  18. print_players(citizens)
  19. # save_citizens(citizens)
  20. def job_update_residents(state_id):
  21. """Update residents"""
  22. regions = get_state_regions(state_id)
  23. for region in regions:
  24. residents = get_residents(region.id)
  25. print_players(residents)
  26. # save_citizens(citizens)
  27. def add_update_department(state_id):
  28. """Add jobs"""
  29. scheduler.add_job(
  30. job_update_citizens,
  31. 'cron',
  32. args=[state_id],
  33. id='citizens_{}'.format(state_id),
  34. replace_existing=True,
  35. minute='0'
  36. )
  37. if __name__ == '__main__':
  38. # jobs
  39. # job_update_citizens(2788)
  40. job_update_residents(2788)
  41. # Verenigde Nederlanden
  42. add_update_department(2788)
  43. # Belgium
  44. add_update_department(2604)
  45. # De Provincien
  46. add_update_department(2620)
  47. try:
  48. while True:
  49. time.sleep(100)
  50. except KeyboardInterrupt:
  51. print('Exiting application')
  52. session.close()
  53. exit()