|
|
|
|
@ -126,15 +126,17 @@ def save_model_log(users, model_operation, model_name, model_id, store_id): |
|
|
|
|
|
|
|
|
|
with transaction.atomic(): |
|
|
|
|
for user in users: |
|
|
|
|
if user.should_synchronize: |
|
|
|
|
model_log = ModelLog() |
|
|
|
|
model_log.user = user |
|
|
|
|
model_log.operation = model_operation |
|
|
|
|
model_log.model_name = model_name |
|
|
|
|
model_log.model_id = model_id |
|
|
|
|
model_log.store_id = store_id |
|
|
|
|
model_log.device_id = device_id |
|
|
|
|
model_log.save() |
|
|
|
|
print(f'>>> create log for {user.username} : {model_operation} {model_name}') |
|
|
|
|
|
|
|
|
|
# if user.should_synchronize: |
|
|
|
|
model_log = ModelLog() |
|
|
|
|
model_log.user = user |
|
|
|
|
model_log.operation = model_operation |
|
|
|
|
model_log.model_name = model_name |
|
|
|
|
model_log.model_id = model_id |
|
|
|
|
model_log.store_id = store_id |
|
|
|
|
model_log.device_id = device_id |
|
|
|
|
model_log.save() |
|
|
|
|
|
|
|
|
|
# print(f'ML users = {len(users)}') |
|
|
|
|
# existing_log = ModelLog.objects.filter(users__in=users, model_id=model_id, operation=model_operation).first() |
|
|
|
|
@ -249,6 +251,7 @@ def related_users(instance): |
|
|
|
|
|
|
|
|
|
# look in hierarchy |
|
|
|
|
related_instances = instance.related_instances() |
|
|
|
|
print(f'related_instances = {related_instances}') |
|
|
|
|
related_users = [ri.related_user for ri in related_instances if isinstance(ri, BaseModel)] |
|
|
|
|
users.update(related_users) |
|
|
|
|
|
|
|
|
|
|