summaryrefslogtreecommitdiff
path: root/fixco_custom/models/webhook_ginee.py
diff options
context:
space:
mode:
authorAzka Nathan <darizkyfaz@gmail.com>2026-01-01 06:13:19 +0700
committerAzka Nathan <darizkyfaz@gmail.com>2026-01-01 06:13:19 +0700
commit956be5a7ac4cd008dad9c854f1ba2e5b1346cc01 (patch)
tree58de506497a0562748487ada2d9c9906906836a7 /fixco_custom/models/webhook_ginee.py
parent1f3660c422500d06676547e10292536b7a6a5f8b (diff)
parent4f29a01888d72ffe07ebffa4e9e0637efb2495d2 (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-xfixco_custom/models/webhook_ginee.py25
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,