Compare commits

..

No commits in common. "4dc4dfdda00e2beae3c6f01d420afca17d696fda" and "dbcdace3482bba09f7c366791492e5c2416c7a1d" have entirely different histories.

2 changed files with 10 additions and 45 deletions

View File

@ -18,7 +18,6 @@ import struct
import logging import logging
import itertools import itertools
from tools import flatten
from functools import reduce from functools import reduce
from datetime import datetime from datetime import datetime
@ -147,34 +146,8 @@ class Profile(SQLSubModel):
else: else:
new_data = new[profile] new_data = new[profile]
if key in ["Z", "Q", "V"]: sf = ">" + ''.join(itertools.repeat("f", len_data))
sf = ">" + ''.join(itertools.repeat("f", len_data)) values = struct.unpack(sf, data)
len_values = len(values)
values = struct.unpack(sf, data)
elif key in ["sl"]:
nb_layer = len_data / len(timestamps) / 3
sf = ">" + ''.join(itertools.repeat("f", len_data))
values = struct.unpack(sf, data)
tmp_values = [[]]
for value in values:
t = tmp_values[-1]
if len(t) < 3:
t.append(value)
else:
tmp_values.append([value])
tmp_values = list(map(tuple, tmp_values))
values = [[]]
for value in tmp_values:
t = values[-1]
if len(t) < nb_layer:
t.append(value)
else:
values.append([value])
values = list(map(lambda x: [x], values))
for timestamp, value in zip(timestamps, values): for timestamp, value in zip(timestamps, values):
new_data.set(timestamp, key, value) new_data.set(timestamp, key, value)
@ -196,6 +169,7 @@ class Profile(SQLSubModel):
) )
def _db_save(self, execute, data=None): def _db_save(self, execute, data=None):
logger.debug("Save profile...")
pid = self._pamhyr_id pid = self._pamhyr_id
result = data["result"] result = data["result"]
@ -203,23 +177,13 @@ class Profile(SQLSubModel):
logger.debug(f"{keys}...") logger.debug(f"{keys}...")
for key in keys: for key in keys:
values = self.get_key(key) values = self.get_key(key)
if any(filter(lambda x: type(x) in [tuple, list], values)):
if key in ["Z", "Q", "V"]: logger.debug(f"{key} : {len(values)} {values[0]}")
values = list(map(float, values))
sf = ">" + ''.join(itertools.repeat("f", len(values)))
len_values = len(values)
elif key is "sl":
values = flatten(
flatten(
map(lambda v: list(
map(lambda t: list(
map(float, t)), v[0])),
values)))
len_values = len(values)
sf = ">" + ''.join(itertools.repeat("f", len_values))
else:
continue continue
values = list(map(float, values))
sf = ">" + ''.join(itertools.repeat("f", len(values)))
data_bytes = struct.pack(sf, *values) data_bytes = struct.pack(sf, *values)
execute( execute(
@ -231,7 +195,7 @@ class Profile(SQLSubModel):
pid, result, pid, result,
data["reach"].pamhyr_id, data["reach"].pamhyr_id,
self._profile.pamhyr_id, self._profile.pamhyr_id,
key, len_values, data_bytes, key, len(values), data_bytes,
self._owner_scenario self._owner_scenario
) )

View File

@ -136,6 +136,7 @@ class PlotAC(PamhyrPlot):
) )
def draw_gl(self): def draw_gl(self):
results = self.results[self._current_res_id] results = self.results[self._current_res_id]
reach = results.river.reach(self._current_reach_id) reach = results.river.reach(self._current_reach_id)
profile = reach.profile(self._current_profile_id) profile = reach.profile(self._current_profile_id)