nikdoof/test-auth
1
0
Fork 0
mirror of https://github.com/nikdoof/test-auth.git synced 2025-12-17 11:49:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added some error tracking to the Alliance details import task

Browse Source
This commit is contained in:
Andrew Williams
2011-06-21 12:42:18 +01:00
parent 935aa0f4aa
commit 36f6d3a35c
1 changed files with 30 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
app/eve_api/tasks/alliance.py
View File

@@ -4,6 +4,7 @@ from xml.dom import minidom
from celery.decorators import task from celery.decorators import task
from eve_proxy.models import CachedDocument from eve_proxy.models import CachedDocument
from eve_proxy.exceptions import DocumentRetrievalError
from eve_api.models import EVEAccount, EVEPlayerCorporation, EVEPlayerAlliance from eve_api.models import EVEAccount, EVEPlayerCorporation, EVEPlayerAlliance
from eve_api.utils import basic_xml_parse_doc from eve_api.utils import basic_xml_parse_doc
@@ -11,32 +12,42 @@ from eve_api.tasks.corporation import import_corp_details, import_corp_details_r
from django.core.exceptions import ValidationError from django.core.exceptions import ValidationError
@task(ignore_result=True) @task(ignore_result=True, default_retry_delay=10 * 60)
def import_alliance_details(): def import_alliance_details():
""" """
Imports all in-game alliances and links their related corporations Imports all in-game alliances and links their related corporations
""" """
doc = CachedDocument.objects.api_query('/eve/AllianceList.xml.aspx') try:
doc = CachedDocument.objects.api_query('/eve/AllianceList.xml.aspx')
except DocumentRetrievalError, exc:
import_alliance_details.retry(exc=exc)
return
for alliance in basic_xml_parse_doc(doc)['eveapi']['result']['alliances']: parsedoc = basic_xml_parse_doc(doc)
allobj, created = EVEPlayerAlliance.objects.get_or_create(pk=alliance['allianceID'])
allobj.name = alliance['name']
allobj.ticker = alliance['shortName']
allobj.date_founded = datetime.strptime(alliance['startDate'],"%Y-%m-%d %H:%M:%S")
allobj.executor, created = EVEPlayerCorporation.objects.get_or_create(id=alliance['executorCorpID'])
allobj.member_count = alliance['memberCount']
allobj.api_last_updated = datetime.utcnow()
allobj.save()
corplist = allobj.eveplayercorporation_set.all().values_list('id', flat=True) if 'eveapi' in parsedoc and not 'error' in parsedoc['eveapi']:
for alliance in parsedoc['eveapi']['result']['alliances']:
allobj, created = EVEPlayerAlliance.objects.get_or_create(pk=alliance['allianceID'])
allobj.name = alliance['name']
allobj.ticker = alliance['shortName']
allobj.date_founded = datetime.strptime(alliance['startDate'],"%Y-%m-%d %H:%M:%S")
allobj.executor, created = EVEPlayerCorporation.objects.get_or_create(id=alliance['executorCorpID'])
allobj.member_count = alliance['memberCount']
allobj.api_last_updated = datetime.utcnow()
allobj.save()
validcorps = [] corplist = allobj.eveplayercorporation_set.all().values_list('id', flat=True)
for corp in alliance['memberCorporations']:
if int(corp['corporationID']) not in corplist:
import_corp_details.delay(corp['corporationID'])
validcorps.append(int(corp['corporationID']))
delcorps = set(corplist) - set(validcorps) validcorps = []
EVEPlayerCorporation.objects.filter(id__in=delcorps).update(alliance=None) for corp in alliance['memberCorporations']:
if int(corp['corporationID']) not in corplist:
import_corp_details.delay(corp['corporationID'])
validcorps.append(int(corp['corporationID']))
delcorps = set(corplist) - set(validcorps)
EVEPlayerCorporation.objects.filter(id__in=delcorps).update(alliance=None)
else:
# We got a error, retry
import_alliance_details.retry()