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
|
#!/usr/bin/python
# -*- encoding: utf-8 -*-
###########################################################################
# Module Writen to OpenERP, Open Source Management Solution
# Copyright (C) OpenERP Venezuela (<http://openerp.com.ve>).
# All Rights Reserved
# Credits######################################################
# Coded by: javier@vauxoo.com
# Planified by: Nhomar Hernandez
# Audited by: Vauxoo C.A.
#############################################################################
# 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
from openerp.osv import osv, fields
import decimal_precision as dp
from operator import itemgetter
class account_invoice_line(osv.Model):
_inherit = 'account.invoice.line'
def _compute_lines(self, cr, uid, ids, name, args, context=None):
'''
Returns the account cost of a product.
'''
result = {}
for il in self.browse(cr, uid, ids, context):
am_lines = self.move_line_id_cost_get(cr, uid, [il.id])
total = 0.0
for m in self.pool.get('account.move.line').browse(cr, uid,
am_lines,
context):
total += (m.quantity and (m.debit/m.quantity) or 0.0) - (
m.quantity and (m.credit/m.quantity) or 0.0)
result[il.id] = total
return result
def _get_iline_from_amline(self, cr, uid, ids, context={}):
'''
Returns the invoice line associated with an account move line.
'''
move = {}
inv_line_ids = []
for line in self.pool.get('account.move.line').browse(cr, uid, ids):
move[line.move_id.id] = True
invoice_ids = []
if move:
invoice_ids = self.pool.get('account.invoice').search(
cr, uid, [('move_id', 'in', move.keys())], context=context)
inv_line_ids = self.pool.get('account.invoice.line').search(
cr, uid, [('invoice_id', 'in', invoice_ids)], context=context)
return inv_line_ids
def _get_iline_from_invoice(self, cr, uid, ids, context={}):
'''
Returns the invoice line of invoice.
'''
move = {}
inv_line_ids = []
for invoice in self.pool.get('account.invoice').browse(cr, uid, ids):
if invoice.state == 'open':
for line in invoice.invoice_line:
inv_line_ids.append(line.id)
return inv_line_ids
_description = "Last Invoice Price"
_columns = {
'last_price': fields.float('Last Price',
digits_compute=dp.get_precision('Account')),
'acc_cost': fields.function(_compute_lines, method=True,
string='Costo', type="float",
digits_compute=dp.get_precision('Account'),
store={
'account.invoice':
(_get_iline_from_invoice,
['state',
'invoice_line'], 50),
'account.move.line':
(_get_iline_from_amline,
['debit', 'credit',
'quantity'], 50),
}, help="""The account moves cost
of the invoice line"""),
}
def move_line_id_cost_get(self, cr, uid, ids, *args):
'''
Returns the expense account move line of invoice.
'''
res = []
for l in self.browse(cr, uid, ids):
if l.invoice_id.type in ('out_invoice', 'out_refund'):
src_account_id = l.product_id.property_account_expense and\
l.product_id.property_account_expense.id or\
False
if not src_account_id:
# raise osv.except_osv('Accion Invalida !', "Producto sin cuenta de costo
# o inventario asignada!: '%s'" % (l.product_id.name,))
continue
# FIXME - que pasa si la factura no tiene movimiento(draft) o
# esta cancelada
if l.invoice_id.move_id:
for aml in l.invoice_id.move_id.line_id:
if aml.account_id.id == src_account_id and\
aml.product_id.id == l.product_id.id and\
aml.quantity == l.quantity:
res.append(aml.id)
return res
def move_line_id_inv_get(self, cr, uid, ids, *args):
'''
Returns the inventory account move line of invoice.
'''
res = []
aml_obj = self.pool.get('account.move.line')
aml_ids = []
for l in self.browse(cr, uid, ids):
if l.invoice_id.type in ('out_invoice', 'out_refund'):
src_account_id = l.product_id.property_stock_account_output \
and \
l.product_id.property_stock_account_output.id\
or False
else:
src_account_id = l.product_id.property_stock_account_input and\
l.product_id.property_stock_account_input.id or\
False
if not src_account_id:
# raise osv.except_osv('Accion Invalida !', "Producto sin cuenta de costo
# o inventario asignada!: '%s'" % (l.product_id.name,))
continue
if l.invoice_id.move_id:
aml_ids = aml_obj.find(cr, uid, mov_id=l.invoice_id.move_id.id,
acc_id=src_account_id,
prd_id=l.product_id.id,
qty=l.quantity)
if aml_ids:
res.append(aml_ids[0])
return res
def _update_last_cost(self, cr, uid, ids=False, context=None):
"""
Function called by the scheduler to update the
last purchase cost of invoice line
@param self: The object pointer
@param cr: the current row, from the database cursor,
@param uid: the current user’s ID for security checks,
@param context: A standard dictionary for contextual values
"""
prod_obj = self.pool.get('product.product')
line_inv_obj = self.pool.get('account.invoice.line')
if not ids:
cr.execute("SELECT l.id FROM account_invoice_line l "
"INNER JOIN account_invoice i ON (i.id=l.invoice_id) "
"WHERE i.state IN ('open', 'paid') ")
ids = map(itemgetter(0), cr.fetchall())
sql = """
SELECT id FROM report_profit"""
cr.execute(sql)
res = cr.fetchall()
for line in line_inv_obj.browse(cr, uid, map(lambda x: x[0], res)):
if line.invoice_id.state in ('open', 'paid'):
inv_id = line.invoice_id.parent_id and\
line.invoice_id.parent_id.id or line.invoice_id.id
prod_price = prod_obj._product_get_price(cr, uid, [
line.product_id.id],
inv_id, False,
line.invoice_id.
date_invoice,
context,
('open', 'paid'),
'in_invoice')
if (not prod_price[line.product_id.id]) and\
line.product_id.seller_ids:
supinfo_ids = []
for sup in line.product_id.seller_ids:
supinfo_ids.append(sup.id)
cr.execute('''select max(price) from pricelist_partnerinfo
where suppinfo_id in %s''', (
tuple(ids),))
record = cr.fetchone()
prod_price[
line.product_id.id] = record and record[0] or 0.0
line_inv_obj.write(cr, uid, line.id, {'last_price': prod_price[
line.product_id.id]}, context=context)
return True
class account_invoice(osv.Model):
_inherit = 'account.invoice'
def button_reset_cost(self, cr, uid, ids, context=None):
if not context:
context = {}
# Update the stored value (fields.function), so we write to trigger
# recompute
self.pool.get('account.invoice').write(cr, uid, ids,
{'invoice_line': []},
context=context)
return True
# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:
|