AddFile: Activate scenarios.

scenarios
Pierre-Antoine Rouby 2024-08-26 14:59:47 +02:00
parent 8b9bb68ac5
commit 1cfc7e6638
4 changed files with 67 additions and 20 deletions

View File

@ -30,10 +30,11 @@ class AddFile(SQLSubModel):
def __init__(self, id: int = -1, enabled=True, def __init__(self, id: int = -1, enabled=True,
name="", path="", text="", name="", path="", text="",
status=None): status=None, owner_scenario=-1):
super(AddFile, self).__init__(id) super(AddFile, self).__init__(
id=id, status=status,
self._status = status owner_scenario=owner_scenario
)
self._enabled = enabled self._enabled = enabled
self._name = f"File #{self._pamhyr_id}" if name == "" else name self._name = f"File #{self._pamhyr_id}" if name == "" else name
@ -64,7 +65,7 @@ class AddFile(SQLSubModel):
elif key == "text": elif key == "text":
self._text = value self._text = value
self._status.modified() self.modified()
@property @property
def enabled(self): def enabled(self):
@ -73,7 +74,7 @@ class AddFile(SQLSubModel):
@enabled.setter @enabled.setter
def enabled(self, enabled): def enabled(self, enabled):
self._enabled = enabled self._enabled = enabled
self._status.modified() self.modified()
def is_enabled(self): def is_enabled(self):
return self._enabled return self._enabled
@ -85,7 +86,7 @@ class AddFile(SQLSubModel):
@name.setter @name.setter
def name(self, name): def name(self, name):
self._name = name self._name = name
self._status.modified() self.modified()
@property @property
def path(self): def path(self):
@ -94,7 +95,7 @@ class AddFile(SQLSubModel):
@path.setter @path.setter
def path(self, path): def path(self, path):
self._path = path self._path = path
self._status.modified() self.modified()
@property @property
def text(self): def text(self):
@ -103,7 +104,7 @@ class AddFile(SQLSubModel):
@text.setter @text.setter
def text(self, text): def text(self, text):
self._text = text self._text = text
self._status.modified() self.modified()
@classmethod @classmethod
def _db_create(cls, execute, ext=""): def _db_create(cls, execute, ext=""):
@ -158,10 +159,17 @@ class AddFile(SQLSubModel):
@classmethod @classmethod
def _db_load(cls, execute, data=None): def _db_load(cls, execute, data=None):
new = [] new = []
scenario = data["scenario"]
loaded = data['loaded_pid']
if scenario is None:
return new
table = execute( table = execute(
"SELECT pamhyr_id, enabled, name, path, text " + "SELECT pamhyr_id, enabled, name, path, text, scenario " +
"FROM additional_files" "FROM additional_files " +
f"WHERE scenario = {scenario.id} " +
f"AND pamhyr_id NOT IN ({', '.join(map(str, loaded))})"
) )
for row in table: for row in table:
@ -172,25 +180,36 @@ class AddFile(SQLSubModel):
name = next(it) name = next(it)
path = next(it) path = next(it)
text = next(it) text = next(it)
owner_scenario = next(it)
f = cls( f = cls(
id=id, enabled=enabled, name=name, path=path, text=text, id=id, enabled=enabled, name=name, path=path, text=text,
status=data['status'] status=data['status'], owner_scenario=owner_scenario
) )
loaded.add(id)
new.append(f) new.append(f)
data["scenario"] = scenario.parent
new += cls._db_load(execute, data)
data["scenario"] = scenario
return new return new
def _db_save(self, execute, data=None): def _db_save(self, execute, data=None):
if not self.must_be_saved():
return True
sql = ( sql = (
"INSERT INTO " + "INSERT INTO " +
"additional_files(pamhyr_id, enabled, name, path, text) " + "additional_files(pamhyr_id, enabled, " +
"name, path, text, scenario) " +
"VALUES (" + "VALUES (" +
f"{self._pamhyr_id}, {self._enabled}, " + f"{self._pamhyr_id}, {self._enabled}, " +
f"'{self._db_format(self._name)}', " + f"'{self._db_format(self._name)}', " +
f"'{self._db_format(self._path)}', " + f"'{self._db_format(self._path)}', " +
f"'{self._db_format(self._text)}'" + f"'{self._db_format(self._text)}', " +
f"{self._status.scenario_id}"
")" ")"
) )
execute(sql) execute(sql)

View File

@ -38,7 +38,10 @@ class AddFileList(PamhyrModelList):
ok = True ok = True
# Delete previous data # Delete previous data
execute("DELETE FROM additional_files") execute(
"DELETE FROM additional_files " +
f"WHERE scenario = {self._status.scenario_id}"
)
for af in self._lst: for af in self._lst:
ok &= af._db_save(execute, data) ok &= af._db_save(execute, data)

View File

@ -122,7 +122,6 @@ class Study(SQLModel):
logger.debug(f"Backup previous version copy: {filename}") logger.debug(f"Backup previous version copy: {filename}")
shutil.copy(self.filename, filename) shutil.copy(self.filename, filename)
self._old_save_id += 1 self._old_save_id += 1
is_new = True
if ".backup" in self.filename: if ".backup" in self.filename:
is_new = True is_new = True
@ -308,7 +307,6 @@ class Study(SQLModel):
@classmethod @classmethod
def _load(cls, filename): def _load(cls, filename):
new = cls(init_new=False, filename=filename) new = cls(init_new=False, filename=filename)
data = {"status": new.status}
def sql_exec(sql): def sql_exec(sql):
return new.execute( return new.execute(
@ -340,6 +338,8 @@ class Study(SQLModel):
) )
) )
data = {"status": new.status}
# Scenarios # Scenarios
new.scenarios = Scenarios._db_load( new.scenarios = Scenarios._db_load(
sql_exec, sql_exec,
@ -354,6 +354,9 @@ class Study(SQLModel):
scenario = new.scenarios[int(scenario_id[0])] scenario = new.scenarios[int(scenario_id[0])]
new.status.scenario = scenario new.status.scenario = scenario
data["scenario"] = scenario
data["loaded_pid"] = set()
# Load river data # Load river data
new._river = River._db_load( new._river = River._db_load(
sql_exec, sql_exec,
@ -444,14 +447,17 @@ class Study(SQLModel):
return new return new
def reload_from_scenario(self, scenario): def reload_from_scenario(self, scenario):
data = {"status": new.status}
def sql_exec(sql): def sql_exec(sql):
return new.execute( return self.execute(
sql, fetch_one=False, commit=True sql, fetch_one=False, commit=True
) )
self.status.scenario = scenario self.status.scenario = scenario
data = {
"status": self.status,
"loaded_pid": set(),
"scenario": scenario
}
# Reload river data # Reload river data
self._river = River._db_load( self._river = River._db_load(

View File

@ -157,6 +157,25 @@ class SQLModel(SQL):
class SQLSubModel(PamhyrID): class SQLSubModel(PamhyrID):
_sub_classes = [] _sub_classes = []
def __init__(self, id: int = -1, status=None,
owner_scenario=-1):
super(SQLSubModel, self).__init__(id)
self._status = status
self._owner_scenario = 0
if owner_scenario == -1:
if status is not None:
self._owner_scenario = self._status.scenario_id
else:
self._owner_scenario = owner_scenario
def must_be_saved(self):
return self._owner_scenario == self._status.scenario_id
def modified(self):
self._owner_scenario = self._status.scenario_id
self._status.modified()
def _db_format(self, value): def _db_format(self, value):
# Replace ''' by ''' to preserve SQL injection # Replace ''' by ''' to preserve SQL injection
if type(value) is str: if type(value) is str: