diff options
| author | Azka Nathan <darizkyfaz@gmail.com> | 2026-01-01 06:13:19 +0700 |
|---|---|---|
| committer | Azka Nathan <darizkyfaz@gmail.com> | 2026-01-01 06:13:19 +0700 |
| commit | 956be5a7ac4cd008dad9c854f1ba2e5b1346cc01 (patch) | |
| tree | 58de506497a0562748487ada2d9c9906906836a7 /fixco_custom/models/webhook_ginee.py | |
| parent | 1f3660c422500d06676547e10292536b7a6a5f8b (diff) | |
| parent | 4f29a01888d72ffe07ebffa4e9e0637efb2495d2 (diff) | |
Merge branch 'main' of bitbucket.org:altafixco/fixco-addons
# Conflicts:
# fixco_custom/models/webhook_ginee.py
Diffstat (limited to 'fixco_custom/models/webhook_ginee.py')
| -rwxr-xr-x | fixco_custom/models/webhook_ginee.py | 25 |
1 files changed, 13 insertions, 12 deletions
diff --git a/fixco_custom/models/webhook_ginee.py b/fixco_custom/models/webhook_ginee.py index 606bd21..444306b 100755 --- a/fixco_custom/models/webhook_ginee.py +++ b/fixco_custom/models/webhook_ginee.py @@ -19,23 +19,24 @@ class WebhookGinee(models.Model): ('not_found', 'Record not found') ], 'Execute Status') - # def process_queue_item(self, limit=100, max_exec_time=30): - # domain = [('execute_status', '=', False)] - # records = self.search(domain, order='create_date asc', limit=limit) - # start_time = time.time() - # for rec in records: - # end_time = time.time() - # elapsed_time = end_time - start_time - # if elapsed_time > max_exec_time: - # break - # rec.execute_queue() - - def process_queue_item(self, limit=100): + def process_queue_item(self, limit=100, max_exec_time=30): domain = [('execute_status', '=', False)] records = self.search(domain, order='create_date asc', limit=limit) + start_time = time.time() for rec in records: + end_time = time.time() + elapsed_time = end_time - start_time + if elapsed_time > max_exec_time: + break rec.execute_queue() + # def process_queue_item(self, limit=100): + # domain = [('create_date', '>', '2025-12-31 23:59:59')] + # records = self.search(domain, order='create_date asc', limit=limit) + # for rec in records: + # rec.execute_queue() + + def execute_queue(self): detail_order = self.env['detail.order'].create({ 'json_ginee': self.json_ginee, |
