mirror of
https://github.com/nikdoof/test-auth.git
synced 2025-12-13 22:32:15 +00:00
88 lines
3.0 KiB
Python
88 lines
3.0 KiB
Python
import logging
|
|
import datetime
|
|
|
|
from eve_api.models.api_player import EVEAccount, EVEPlayerCorporation, EVEPlayerCharacter
|
|
import eve_api.api_puller.accounts
|
|
from eve_api.api_puller.alliances import __start_full_import as alliance_import
|
|
from eve_api.api_puller.corp_management import pull_corp_members
|
|
from eve_api.api_exceptions import APIAuthException, APINoUserIDException
|
|
|
|
class UpdateAPIs():
|
|
"""
|
|
Updates all Eve API elements in the database
|
|
"""
|
|
|
|
settings = { 'update_corp': False }
|
|
|
|
last_update_delay = 86400
|
|
batches = 50
|
|
|
|
@property
|
|
def _logger(self):
|
|
if not hasattr(self, '__logger'):
|
|
self.__logger = logging.getLogger(__name__)
|
|
return self.__logger
|
|
|
|
def job(self):
|
|
# Update all the eve accounts and related corps
|
|
|
|
delta = datetime.timedelta(seconds=self.last_update_delay)
|
|
self._logger.debug("Updating APIs older than %s" % (datetime.datetime.now() - delta))
|
|
|
|
accounts = EVEAccount.objects.filter(api_last_updated__lt=(datetime.datetime.now() - delta)).order_by('api_last_updated').order_by('api_last_updated')[:self.batches]
|
|
self._logger.debug("%s account(s) to update" % len(accounts))
|
|
for acc in accounts:
|
|
self._logger.info("Updating UserID %s" % acc.api_user_id)
|
|
if not acc.user:
|
|
acc.delete()
|
|
continue
|
|
eve_api.api_puller.accounts.import_eve_account(acc.api_key, acc.api_user_id)
|
|
|
|
if self.settings['update_corp']:
|
|
for corp in EVEPlayerCorporation.objects.all():
|
|
try:
|
|
corp.query_and_update_corp()
|
|
except:
|
|
self._logger.error('Error updating %s' % corp)
|
|
continue
|
|
|
|
class CorpManagementUpdate():
|
|
"""
|
|
Pulls character information from corp directors marked in the DB
|
|
"""
|
|
|
|
settings = { 'update_corp': False }
|
|
|
|
last_update_delay = 86400
|
|
batches = 50
|
|
|
|
@property
|
|
def _logger(self):
|
|
if not hasattr(self, '__logger'):
|
|
self.__logger = logging.getLogger(__name__)
|
|
return self.__logger
|
|
|
|
def job(self):
|
|
directors = EVEPlayerCharacter.objects.filter(director_update=True)
|
|
|
|
for director in directors:
|
|
self._logger.info("Updating: %s / %s" % (director, director.corporation))
|
|
#api = director.eveaccount
|
|
api = EVEAccount.objects.get(characters__in=[director])
|
|
pull_corp_members(api.api_key, api.api_user_id, director.id)
|
|
|
|
class AllianceUpdate():
|
|
"""
|
|
Pulls the AllianceList.xml.aspx and updates the alliance objects
|
|
"""
|
|
|
|
@property
|
|
def _logger(self):
|
|
if not hasattr(self, '__logger'):
|
|
self.__logger = logging.getLogger(__name__)
|
|
return self.__logger
|
|
|
|
def job(self):
|
|
alliance_import()
|
|
|