-
Notifications
You must be signed in to change notification settings - Fork 68
/
Copy pathqueue_requeue_job.go
119 lines (103 loc) · 4.09 KB
/
queue_requeue_job.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
package odoo
import (
"fmt"
)
// QueueRequeueJob represents queue.requeue.job model.
type QueueRequeueJob struct {
LastUpdate *Time `xmlrpc:"__last_update,omptempty"`
CreateDate *Time `xmlrpc:"create_date,omptempty"`
CreateUid *Many2One `xmlrpc:"create_uid,omptempty"`
DisplayName *String `xmlrpc:"display_name,omptempty"`
Id *Int `xmlrpc:"id,omptempty"`
JobIds *Relation `xmlrpc:"job_ids,omptempty"`
WriteDate *Time `xmlrpc:"write_date,omptempty"`
WriteUid *Many2One `xmlrpc:"write_uid,omptempty"`
}
// QueueRequeueJobs represents array of queue.requeue.job model.
type QueueRequeueJobs []QueueRequeueJob
// QueueRequeueJobModel is the odoo model name.
const QueueRequeueJobModel = "queue.requeue.job"
// Many2One convert QueueRequeueJob to *Many2One.
func (qrj *QueueRequeueJob) Many2One() *Many2One {
return NewMany2One(qrj.Id.Get(), "")
}
// CreateQueueRequeueJob creates a new queue.requeue.job model and returns its id.
func (c *Client) CreateQueueRequeueJob(qrj *QueueRequeueJob) (int64, error) {
return c.Create(QueueRequeueJobModel, qrj)
}
// UpdateQueueRequeueJob updates an existing queue.requeue.job record.
func (c *Client) UpdateQueueRequeueJob(qrj *QueueRequeueJob) error {
return c.UpdateQueueRequeueJobs([]int64{qrj.Id.Get()}, qrj)
}
// UpdateQueueRequeueJobs updates existing queue.requeue.job records.
// All records (represented by ids) will be updated by qrj values.
func (c *Client) UpdateQueueRequeueJobs(ids []int64, qrj *QueueRequeueJob) error {
return c.Update(QueueRequeueJobModel, ids, qrj)
}
// DeleteQueueRequeueJob deletes an existing queue.requeue.job record.
func (c *Client) DeleteQueueRequeueJob(id int64) error {
return c.DeleteQueueRequeueJobs([]int64{id})
}
// DeleteQueueRequeueJobs deletes existing queue.requeue.job records.
func (c *Client) DeleteQueueRequeueJobs(ids []int64) error {
return c.Delete(QueueRequeueJobModel, ids)
}
// GetQueueRequeueJob gets queue.requeue.job existing record.
func (c *Client) GetQueueRequeueJob(id int64) (*QueueRequeueJob, error) {
qrjs, err := c.GetQueueRequeueJobs([]int64{id})
if err != nil {
return nil, err
}
if qrjs != nil && len(*qrjs) > 0 {
return &((*qrjs)[0]), nil
}
return nil, fmt.Errorf("id %v of queue.requeue.job not found", id)
}
// GetQueueRequeueJobs gets queue.requeue.job existing records.
func (c *Client) GetQueueRequeueJobs(ids []int64) (*QueueRequeueJobs, error) {
qrjs := &QueueRequeueJobs{}
if err := c.Read(QueueRequeueJobModel, ids, nil, qrjs); err != nil {
return nil, err
}
return qrjs, nil
}
// FindQueueRequeueJob finds queue.requeue.job record by querying it with criteria.
func (c *Client) FindQueueRequeueJob(criteria *Criteria) (*QueueRequeueJob, error) {
qrjs := &QueueRequeueJobs{}
if err := c.SearchRead(QueueRequeueJobModel, criteria, NewOptions().Limit(1), qrjs); err != nil {
return nil, err
}
if qrjs != nil && len(*qrjs) > 0 {
return &((*qrjs)[0]), nil
}
return nil, fmt.Errorf("no queue.requeue.job was found with criteria %v", criteria)
}
// FindQueueRequeueJobs finds queue.requeue.job records by querying it
// and filtering it with criteria and options.
func (c *Client) FindQueueRequeueJobs(criteria *Criteria, options *Options) (*QueueRequeueJobs, error) {
qrjs := &QueueRequeueJobs{}
if err := c.SearchRead(QueueRequeueJobModel, criteria, options, qrjs); err != nil {
return nil, err
}
return qrjs, nil
}
// FindQueueRequeueJobIds finds records ids by querying it
// and filtering it with criteria and options.
func (c *Client) FindQueueRequeueJobIds(criteria *Criteria, options *Options) ([]int64, error) {
ids, err := c.Search(QueueRequeueJobModel, criteria, options)
if err != nil {
return []int64{}, err
}
return ids, nil
}
// FindQueueRequeueJobId finds record id by querying it with criteria.
func (c *Client) FindQueueRequeueJobId(criteria *Criteria, options *Options) (int64, error) {
ids, err := c.Search(QueueRequeueJobModel, criteria, options)
if err != nil {
return -1, err
}
if len(ids) > 0 {
return ids[0], nil
}
return -1, fmt.Errorf("no queue.requeue.job was found with criteria %v and options %v", criteria, options)
}