mirror of https://gitlab.com/pamhyr/pamhyr2
Adists: Scenario: Some minor fix.
parent
4ac86b9acb
commit
d7fcf62e12
|
|
@ -95,7 +95,7 @@ class BoundaryConditionAdisTS(SQLSubModel):
|
|||
if int(release) < 7:
|
||||
cls._db_create(execute)
|
||||
|
||||
if major == "0" and int(minor) < 2:
|
||||
elif major == "0" and int(minor) < 2:
|
||||
cls._db_update_to_0_2_0(execute, data)
|
||||
|
||||
return True
|
||||
|
|
@ -149,7 +149,7 @@ class BoundaryConditionAdisTS(SQLSubModel):
|
|||
new = []
|
||||
|
||||
table = execute(
|
||||
"SELECT id, pollutant, type, node " +
|
||||
"SELECT pamhyr_id, pollutant, type, node " +
|
||||
"FROM boundary_condition_adists"
|
||||
)
|
||||
|
||||
|
|
|
|||
|
|
@ -72,7 +72,7 @@ class D90AdisTS(SQLSubModel):
|
|||
if int(release) < 6:
|
||||
cls._db_create(execute)
|
||||
|
||||
if major == "0" and int(minor) < 2:
|
||||
elif major == "0" and int(minor) < 2:
|
||||
cls._db_update_to_0_2_0(execute, data)
|
||||
|
||||
return True
|
||||
|
|
|
|||
|
|
@ -78,7 +78,7 @@ class DIFAdisTS(SQLSubModel):
|
|||
if int(release) < 6:
|
||||
cls._db_create(execute)
|
||||
|
||||
if major == "0" and int(minor) < 2:
|
||||
elif major == "0" and int(minor) < 2:
|
||||
cls._db_update_to_0_2_0(execute, data)
|
||||
|
||||
return True
|
||||
|
|
|
|||
|
|
@ -82,7 +82,7 @@ class InitialConditionsAdisTS(SQLSubModel):
|
|||
if int(release) < 6:
|
||||
cls._db_create(execute)
|
||||
|
||||
if major == "0" and int(minor) < 2:
|
||||
elif major == "0" and int(minor) < 2:
|
||||
cls._db_update_to_0_2_0(execute, data)
|
||||
|
||||
return True
|
||||
|
|
@ -99,8 +99,8 @@ class InitialConditionsAdisTS(SQLSubModel):
|
|||
|
||||
execute(
|
||||
f"INSERT INTO {table}_tmp " +
|
||||
"(pamhyr_id, pollutant, reach, begin_rk, end_rk, scenario) " +
|
||||
"SELECT pamhyr_id, pollutant, edge, begin_rk, end_rk, scenario) " +
|
||||
"(pamhyr_id, pollutant, name, concentration, eg, em, ed, scenario) " +
|
||||
"SELECT pamhyr_id, pollutant, name, concentration, eg, em, ed, scenario) " +
|
||||
f"FROM {table}"
|
||||
)
|
||||
|
||||
|
|
@ -114,8 +114,8 @@ class InitialConditionsAdisTS(SQLSubModel):
|
|||
new = []
|
||||
|
||||
table = execute(
|
||||
"SELECT id, pollutant, name, concentration, eg, em, ed, " +
|
||||
"enabled " +
|
||||
"SELECT pamhyr_id, pollutant, name, concentration, eg, em, ed, " +
|
||||
"enabled, scenario " +
|
||||
"FROM initial_conditions_adists"
|
||||
)
|
||||
|
||||
|
|
@ -176,7 +176,7 @@ class InitialConditionsAdisTS(SQLSubModel):
|
|||
sql = (
|
||||
"INSERT INTO " +
|
||||
"initial_conditions_adists(" +
|
||||
"id, pollutant, name, concentration, " +
|
||||
"pamhyr_id, pollutant, name, concentration, " +
|
||||
"eg, em, ed, enabled" +
|
||||
") " +
|
||||
"VALUES (" +
|
||||
|
|
|
|||
|
|
@ -97,7 +97,7 @@ class LateralContributionAdisTS(SQLSubModel):
|
|||
if int(release) < 7:
|
||||
cls._db_create(execute)
|
||||
|
||||
if major == "0" and int(minor) < 2:
|
||||
elif major == "0" and int(minor) < 2:
|
||||
cls._db_update_to_0_2_0(execute, data)
|
||||
|
||||
return True
|
||||
|
|
@ -154,7 +154,7 @@ class LateralContributionAdisTS(SQLSubModel):
|
|||
loaded = data['loaded_pid']
|
||||
|
||||
table = execute(
|
||||
"SELECT id, pollutant, edge, begin_rk, end_rk " +
|
||||
"SELECT pamhyr_id, pollutant, reach, begin_rk, end_rk " +
|
||||
"FROM lateral_contribution_adists " +
|
||||
f"WHERE scenario = {scenario.id} " +
|
||||
f"AND pamhyr_id NOT IN ({', '.join(map(str, loaded))}) "
|
||||
|
|
@ -173,8 +173,8 @@ class LateralContributionAdisTS(SQLSubModel):
|
|||
lca.end_rk = row[4]
|
||||
|
||||
values = execute(
|
||||
"SELECT data0," +
|
||||
" data1 FROM lateral_contribution_data_adists " +
|
||||
"SELECT data0, data1 " +
|
||||
"FROM lateral_contribution_data_adists " +
|
||||
f"WHERE scenario = {scenario.id} " +
|
||||
f"AND pamhyr_id NOT IN ({', '.join(map(str, loaded))}) "
|
||||
f"AND lca = '{lca.id}'"
|
||||
|
|
@ -201,12 +201,12 @@ class LateralContributionAdisTS(SQLSubModel):
|
|||
|
||||
execute(
|
||||
f"DELETE FROM lateral_contribution_adists " +
|
||||
f" WHERE id = {self.id} " +
|
||||
f"WHERE pamhyr_id = {self.id} " +
|
||||
f"AND scenario = {self._status.scenario_id}"
|
||||
)
|
||||
execute(
|
||||
f"DELETE FROM lateral_contribution_data_adists " +
|
||||
f" WHERE lc = {self.id} " +
|
||||
f"WHERE lca = {self.id} " +
|
||||
f"AND scenario = {self._status.scenario_id}"
|
||||
)
|
||||
|
||||
|
|
@ -228,7 +228,7 @@ class LateralContributionAdisTS(SQLSubModel):
|
|||
|
||||
sql = (
|
||||
"INSERT INTO " +
|
||||
"lateral_contribution_data_adists(data0, data1, lc) " +
|
||||
"lateral_contribution_data_adists(data0, data1, lca) " +
|
||||
f"VALUES ('{data0}', {data1}, {self.id})"
|
||||
)
|
||||
execute(sql)
|
||||
|
|
|
|||
|
|
@ -100,7 +100,7 @@ class OutputRKAdists(SQLSubModel):
|
|||
if int(release) < 7:
|
||||
cls._db_create(execute)
|
||||
|
||||
if major == "0" and int(minor) <= 2:
|
||||
elif major == "0" and int(minor) <= 2:
|
||||
if int(release) <= 0:
|
||||
cls._db_update_to_0_2_0(execute, data)
|
||||
|
||||
|
|
@ -137,7 +137,7 @@ class OutputRKAdists(SQLSubModel):
|
|||
status = data["status"]
|
||||
|
||||
table = execute(
|
||||
"SELECT id, reach, rk, title " +
|
||||
"SELECT pamhyr_id, reach, rk, title " +
|
||||
f"FROM OutputRKAdists"
|
||||
)
|
||||
|
||||
|
|
@ -164,7 +164,7 @@ class OutputRKAdists(SQLSubModel):
|
|||
|
||||
sql = (
|
||||
"INSERT INTO " +
|
||||
"OutputRKAdists(id, reach, rk, title) " +
|
||||
"OutputRKAdists(pamhyr_id, reach, rk, title) " +
|
||||
"VALUES (" +
|
||||
f"{self.id}, {self._reach}, {self._rk}, " +
|
||||
f"'{self._db_format(self._title)}'" +
|
||||
|
|
|
|||
|
|
@ -40,7 +40,7 @@ class OutputRKAdistsList(PamhyrModelList):
|
|||
# Delete previous data
|
||||
execute(
|
||||
"DELETE FROM OutputRKAdists " +
|
||||
f"AND scenario = {self._status.scenario_id}"
|
||||
f"WHERE scenario = {self._status.scenario_id}"
|
||||
)
|
||||
|
||||
for sl in self._lst:
|
||||
|
|
|
|||
Loading…
Reference in New Issue