Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
35 changes: 22 additions & 13 deletions cities_light/management/commands/cities_light.py
Original file line number Diff line number Diff line change
Expand Up @@ -313,9 +313,10 @@ def region_import(self, items):
except InvalidItems:
return

force_insert = False
force_update = False

try:
force_insert = False
force_update = False
region = Region.objects.get(geoname_id=items[IRegion.geonameid])
force_update = True
except Region.DoesNotExist:
Expand Down Expand Up @@ -370,17 +371,6 @@ def city_import(self, items):
except InvalidItems:
return

try:
force_insert = False
force_update = False
city = City.objects.get(geoname_id=items[ICity.geonameid])
force_update = True
except City.DoesNotExist:
if self.noinsert:
return
city = City(geoname_id=items[ICity.geonameid])
force_insert = True

try:
country_id = self._get_country_id(items[ICity.countryCode])
except Country.DoesNotExist:
Expand All @@ -397,6 +387,25 @@ def city_import(self, items):
except Region.DoesNotExist:
region_id = None

force_insert = False
force_update = False

try:
city = City.objects.get(geoname_id=items[ICity.geonameid])
force_update = True
except City.DoesNotExist:
try:
# check on duplicate by unique key
city = City.objects.get(name=items[ICity.name],
region_id=region_id)
if city:
return
except City.DoesNotExist:
if self.noinsert:
return
city = City(geoname_id=items[ICity.geonameid])
force_insert = True

save = False
if city.country_id != country_id:
city.country_id = country_id
Expand Down