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
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
|
#!/usr/bin/env python
# -*- encoding: utf-8 -*-
##############################################################################
#
# OpenERP, Open Source Management Solution
# Copyright (C) 2011 TeMPO Consulting, MSF
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as
# published by the Free Software Foundation, either version 3 of the
# License, or (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Affero General Public License for more details.
#
# You should have received a copy of the GNU Affero General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
#
##############################################################################
import time
import netsvc
from osv import osv
from osv import fields
from tools.translate import _
class procurement_list(osv.osv):
_name = 'procurement.list'
_description = 'Procurement list'
_columns = {
'name': fields.char(size=64, string='Ref.', required=True, readonly=True,
states={'draft': [('readonly', False)]}),
'requestor': fields.char(size=20, string='Requestor',),
'order_date': fields.date(string='Order date', required=True),
'warehouse_id': fields.many2one('stock.warehouse', string='Warehouse'),
'origin': fields.char(size=64, string='Origin'),
'state': fields.selection([('draft', 'Draft'),('done', 'Done'), ('cancel', 'Cancel')],
string='State', readonly=True),
'line_ids': fields.one2many('procurement.list.line', 'list_id', string='Lines', readonly=True,
states={'draft': [('readonly', False)]}),
'notes': fields.text(string='Notes'),
'order_ids': fields.many2many('purchase.order', 'procurement_list_order_rel',
'list_id', 'order_id', string='Orders', readonly=True),
}
_defaults = {
'name': lambda obj, cr, uid, context: obj.pool.get('ir.sequence').get(cr, uid, 'procurement.list'),
'state': lambda *a: 'draft',
'order_date': lambda *a: time.strftime('%Y-%m-%d'),
}
def copy(self, cr, uid, ids, default={}, context={}):
'''
Increments the sequence for the new list
'''
default['name'] = self.pool.get('ir.sequence').get(cr, uid, 'procurement.list')
default['order_ids'] = []
res = super(procurement_list, self).copy(cr, uid, ids, default, context=context)
return res
def cancel(self, cr, uid, ids, context={}):
'''
Sets the procurement list to the 'Cancel' state
'''
self.write(cr, uid, ids, {'state': 'cancel'})
return True
def create_po(self, cr, uid, ids, context={}):
'''
Creates all purchase orders according to choices on lines
'''
if ids and isinstance(ids, (int, long)):
ids = [ids]
order_obj = self.pool.get('purchase.order')
order_line_obj = self.pool.get('purchase.order.line')
proc_obj = self.pool.get('procurement.list')
line_obj = self.pool.get('procurement.list.line')
prod_sup_obj = self.pool.get('product.supplierinfo')
# We search if at least one line hasn't defined supplier
for list in self.browse(cr, uid, ids):
for line in list.line_ids:
if not line.supplier_id:
raise osv.except_osv(_('Error'), _('You cannot create purchase orders while all lines haven\'t a defined supplier'))
# We search lines group by supplier_id
po_exists = {}
po_id = False
po_ids = []
line_ids = line_obj.search(cr, uid, [('list_id', 'in', ids)], order='supplier_id')
for l in line_obj.browse(cr, uid, line_ids):
# Search if a PO already exists in the system
if not po_exists.get(l.supplier_id.id, False):
# If no PO in local memory, search in DB
po_exist = order_obj.search(cr, uid, [('origin', '=', l.list_id.name), ('partner_id', '=', l.supplier_id.id)])
if po_exist:
# A PO exists in DB, set the id in local memory
po_exists[l.supplier_id.id] = po_exist[0]
else:
# try to create a new PO, and set its id in local memory
address = l.supplier_id.address_get().get('default')
# Returns an error when the supplier has not defined address
if not address:
raise osv.except_osv(_('Error'), _('The supplier %s has no address defined on its form' %l.supplier_id.name))
# When starting or when the supplier changed, we create a Purchase Order
po_id = order_obj.create(cr, uid, {'partner_id': l.supplier_id.id,
'partner_address_id': address,
'pricelist_id': l.supplier_id.property_product_pricelist.id,
'origin': l.list_id.name,
'location_id': proc_obj._get_location(cr, uid, l.list_id.warehouse_id)})
po_exists[l.supplier_id.id] = po_id
# Get the PO id in local memory
po_id = po_exists.get(l.supplier_id.id)
# We create all lines for this supplier
price_unit = prod_sup_obj.price_get(cr, uid, [l.supplier_id.id], l.product_id.id, l.product_qty)
order_line_obj.create(cr, uid, {'product_uom': l.product_uom_id.id,
'product_id': l.product_id.id,
'order_id': po_id,
'price_unit': price_unit[l.supplier_id.id],
'date_planned': l.list_id.order_date,
'product_qty': l.product_qty,
'name': l.product_id.name,})
for supplier in po_exists:
po_ids.append(po_exists.get(supplier))
# We confirm all created orders
wf_service = netsvc.LocalService("workflow")
for po in po_ids:
wf_service.trg_validate(uid, 'purchase.order', po, 'purchase_confirm', cr)
proc_obj.write(cr, uid, ids[0], {'state': 'done', 'order_ids': [(6, 0, po_ids)]})
return {'type': 'ir.actions.act_window',
'res_model': 'purchase.order',
'view_type': 'form',
'view_mode': 'tree,form',
'domain': [('id', 'in', po_ids)],
}
def create_rfq(self, cr, uid, ids, context={}):
'''
Create a RfQ per supplier with all products
'''
purchase_obj = self.pool.get('purchase.order')
line_obj = self.pool.get('purchase.order.line')
order_ids = []
for list in self.browse(cr, uid, ids, context=context):
# Returns an error message if no products defined
if not list.line_ids or len(list.line_ids) == 0:
raise osv.except_osv(_('Error'), _('No line defined for this list !'))
location_id = self._get_location(cr, uid, list.warehouse_id)
context['active_ids'] = ids
context['active_id'] = ids[0]
return {'type': 'ir.actions.act_window',
'res_model': 'procurement.choose.supplier.rfq',
'target': 'new',
'view_type': 'form',
'view_mode': 'form',
'context': context}
def reset(self, cr, uid, ids, context={}):
'''
Sets the procurement list to the 'Draft' state
'''
self.write(cr, uid, ids, {'state': 'draft'})
return True
def _get_location(self, cr, uid, warehouse=None):
'''
Returns the default input location for product
'''
if warehouse:
return warehouse.lot_input_id.id
warehouse_obj = self.pool.get('stock.warehouse')
warehouse_id = warehouse_obj.search(cr, uid, [])[0]
return warehouse_obj.browse(cr, uid, warehouse_id).lot_input_id.id
procurement_list()
class procurement_list_line(osv.osv):
_name = 'procurement.list.line'
_description = 'Procurement line'
_rec_name = 'product_id'
_columns = {
'product_id': fields.many2one('product.product', string='Product', required=True),
'product_uom_id': fields.many2one('product.uom', string='UoM', required=True),
'product_qty': fields.float(digits=(16,4), string='Quantity', required=True),
'comment': fields.char(size=128, string='Comment'),
'from_stock': fields.boolean(string='From stock ?'),
'latest': fields.char(size=64, string='Latest document', readonly=True),
'list_id': fields.many2one('procurement.list', string='List', required=True, ondelete='cascade'),
'supplier_id': fields.many2one('res.partner', string='Supplier'),
}
_defaults = {
'latest': lambda *a: '',
}
def copy_data(self, cr, uid, id, default={}, context={}):
'''
Initializes the 'latest' fields to an empty field
'''
default['latest'] = ''
res = super(procurement_list_line, self).copy_data(cr, uid, id, default, context=context)
return res
def product_id_change(self, cr, uid, ids, product_id, context={}):
'''
Fills automatically the product_uom_id field on the line when the
product was changed.
'''
product_obj = self.pool.get('product.product')
v = {}
if not product_id:
v.update({'product_uom_id': False, 'supplier_id': False})
else:
product = product_obj.browse(cr, uid, product_id, context=context)
v.update({'product_uom_id': product.uom_id.id, 'supplier_id': product.seller_id.id})
return {'value': v}
def split_line(self, cr, uid, ids, context={}):
'''
Split a line into two lines
'''
if ids and isinstance(ids, (int, long)):
ids = [ids]
for line in self.browse(cr, uid, ids):
state = line.list_id.state
context.update({'line_id': ids[0], 'state': state})
return {'type': 'ir.actions.act_window',
'res_model': 'procurement.list.line.split',
'target': 'new',
'view_type': 'form',
'view_mode': 'form',
'context': context,
}
def merge_line(self, cr, uid, ids, context={}):
'''
Merges two lines
'''
if ids and isinstance(ids, (int, long)):
ids = [ids]
for line in self.browse(cr, uid, ids):
state = line.list_id.state
context.update({'line_id': ids[0], 'state': state})
return {'type': 'ir.actions.act_window',
'res_model': 'procurement.list.line.merge',
'target': 'new',
'view_type': 'form',
'view_mode': 'form',
'context': context,
}
procurement_list_line()
class purchase_order_line(osv.osv):
_name = 'purchase.order.line'
_inherit = 'purchase.order.line'
_columns = {
'procurement_line_id': fields.many2one('procurement.list.line', string='Procurement Line', readonly=True, ondelete='set null'),
}
def action_confirm(self, cr, uid, ids, context={}):
'''
Changes the status of the procurement line
'''
proc_line_obj = self.pool.get('procurement.list.line')
for line in self.browse(cr, uid, ids):
if line.procurement_line_id and line.procurement_line_id.id:
proc_line_obj.write(cr, uid, [line.procurement_line_id.id], {'latest': line.order_id.name})
return super(purchase_order_line, self).action_confirm(cr, uid, ids, context=context)
purchase_order_line()
# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:
|