updates an asset nach online-aktion
This commit is contained in:
parent
fcabafa080
commit
ac0bced963
1 changed files with 12 additions and 1 deletions
13
asset.py
13
asset.py
|
@ -827,6 +827,12 @@ class Asset(SymbolMixin, ModelSQL, ModelView):
|
||||||
('product.identifiers.code',) + tuple(clause[1:]),
|
('product.identifiers.code',) + tuple(clause[1:]),
|
||||||
]
|
]
|
||||||
|
|
||||||
|
@classmethod
|
||||||
|
def after_update_actions(cls, assets):
|
||||||
|
""" run activities after rate-update
|
||||||
|
"""
|
||||||
|
pass
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def cron_update(cls):
|
def cron_update(cls):
|
||||||
""" update asset-rates
|
""" update asset-rates
|
||||||
|
@ -837,10 +843,15 @@ class Asset(SymbolMixin, ModelSQL, ModelView):
|
||||||
context = Transaction().context
|
context = Transaction().context
|
||||||
|
|
||||||
query_time = context.get('qdatetime', CurrentTimestamp())
|
query_time = context.get('qdatetime', CurrentTimestamp())
|
||||||
|
to_run_activities = []
|
||||||
for asset in Asset2.search([
|
for asset in Asset2.search([
|
||||||
('nextupdate', '<=', query_time),
|
('nextupdate', '<=', query_time),
|
||||||
]):
|
]):
|
||||||
OnlineSource.update_rate(asset)
|
if OnlineSource.update_rate(asset):
|
||||||
|
to_run_activities.append(asset)
|
||||||
|
|
||||||
|
if len(to_run_activities) > 0:
|
||||||
|
cls.after_update_actions(to_run_activities)
|
||||||
|
|
||||||
# end Asset
|
# end Asset
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue