[PYTHON] ~fix update_membership_state function
[burette/remembership.git] / remembership.py
1 # -*- coding: utf-8 -*-
2 ##############################################################################
3 #
4 # Remembership module for OpenERP, Membership module enhancement and bug fixes
5 # Copyright (C) 2012-2018 L'Heureux Cyclage (<http://www.heureux-cyclage.org>)
6 #
7 # This file is a part of Remembership
8 #
9 # Remembership is free software: you can redistribute it and/or modify
10 # it under the terms of the GNU General Public License as published by
11 # the Free Software Foundation, either version 3 of the License, or
12 # (at your option) any later version.
13 #
14 # Remembership is distributed in the hope that it will be useful,
15 # but WITHOUT ANY WARRANTY; without even the implied warranty of
16 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 # GNU General Public License for more details.
18 #
19 # You should have received a copy of the GNU General Public License
20 # along with this program. If not, see <http://www.gnu.org/licenses/>.
21 #
22 ##############################################################################
23
24 from openerp.osv import osv
25 from openerp.osv import fields
26 import time
27 from datetime import datetime, date
28 from dateutil.relativedelta import relativedelta
29 from openerp.tools.translate import _
30
31 class Partner(osv.osv):
32 _inherit = 'res.partner'
33
34 # XXX: copied from openerp/addons/membership/membership.py
35 def _membership_date(self, cr, uid, ids, name, args, context=None):
36 """Return date of membership"""
37 name = name[0]
38 res = {}
39 member_line_obj = self.pool.get('membership.membership_line')
40 print ("DEV: [remembership] [_membership_date]")
41 for partner in self.browse(cr, uid, ids, context=context):
42 # XXX: commented part from openerp/addons/membership/membership.py
43 #if partner.associate_member:
44 # partner_id = partner.associate_member.id
45 #else:
46 # NOTE: hmm, ça devrait être toujours partner.id
47 partner_id = partner.id
48 res[partner.id] = {
49 'membership_start': False,
50 'membership_stop': False,
51 'membership_cancel': False
52 }
53 if name == 'membership_start':
54 line_id = member_line_obj.search(cr, uid, [('partner', '=', partner_id),('state','!=','canceled')],
55 limit=1, order='date_from', context=context)
56 if line_id:
57 res[partner.id]['membership_start'] = member_line_obj.read(cr, uid, line_id[0],
58 ['date_from'], context=context)['date_from']
59 if partner.associate_member:
60 print ("DEV: [_membership_date] [associate] date_from: %s" % str(res[partner.id]['membership_start']))
61 else:
62 print ("DEV: [_membership_date] date_from: %s" % str(res[partner.id]['membership_start']))
63
64 if name == 'membership_stop':
65 line_id1 = member_line_obj.search(cr, uid, [('partner', '=', partner_id),('state','!=','canceled')],
66 limit=1, order='date_to desc', context=context)
67 if line_id1:
68 res[partner.id]['membership_stop'] = member_line_obj.read(cr, uid, line_id1[0],
69 ['date_to'], context=context)['date_to']
70 if partner.associate_member:
71 print ("DEV: [_membership_date] [associate] date_to: %s" % str(res[partner.id]['membership_stop']))
72 else:
73 print ("DEV: [_membership_date] date_to: %s" % str(res[partner.id]['membership_stop']))
74
75 if name == 'membership_cancel':
76 if partner.membership_state == 'canceled':
77 line_id2 = member_line_obj.search(cr, uid, [('partner', '=', partner.id)], limit=1, order='date_cancel', context=context)
78 if line_id2:
79 res[partner.id]['membership_cancel'] = member_line_obj.read(cr, uid, line_id2[0], ['date_cancel'], context=context)['date_cancel']
80 return res
81 # XXX: copied from openerp/addons/membership/membership.py
82 def _get_partner_id(self, cr, uid, ids, context=None):
83 member_line_obj = self.pool.get('membership.membership_line')
84 res_obj = self.pool.get('res.partner')
85 data_inv = member_line_obj.browse(cr, uid, ids, context=context)
86 list_partner = []
87 for data in data_inv:
88 list_partner.append(data.partner.id)
89 ids2 = list_partner
90 while ids2:
91 ids2 = res_obj.search(cr, uid, [('associate_member', 'in', ids2)], context=context)
92 list_partner += ids2
93 return list_partner
94 # XXX: copied from openerp/addons/membership/membership.py
95 def _get_invoice_partner(self, cr, uid, ids, context=None):
96 inv_obj = self.pool.get('account.invoice')
97 res_obj = self.pool.get('res.partner')
98 data_inv = inv_obj.browse(cr, uid, ids, context=context)
99 list_partner = []
100 for data in data_inv:
101 list_partner.append(data.partner_id.id)
102 ids2 = list_partner
103 while ids2:
104 ids2 = res_obj.search(cr, uid, [('associate_member', 'in', ids2)], context=context)
105 list_partner += ids2
106 return list_partner
107
108 _columns = {
109 'member_ident': fields.char('Member identifier', size=64),
110 'associate_members': fields.one2many('res.partner', 'associate_member', 'Associate members', help='Members who are associated to this partner.'),
111 # XXX: copied from openerp/addons/membership/membership.py
112 'membership_start': fields.function(
113 _membership_date, multi = 'membership_start',
114 string = 'Membership Start Date', type = 'date',
115 store = {
116 'account.invoice': (_get_invoice_partner, ['state'], 10),
117 'membership.membership_line': (_get_partner_id, ['state'], 10, ),
118 'res.partner': (lambda self, cr, uid, ids, c={}: ids, ['free_member'], 10)
119 }, help="Date from which membership becomes active."),
120 # XXX: copied from openerp/addons/membership/membership.py
121 'membership_stop': fields.function(
122 _membership_date,
123 string = 'Membership End Date', type='date', multi='membership_stop',
124 store = {
125 'account.invoice': (_get_invoice_partner, ['state'], 10),
126 'membership.membership_line': (_get_partner_id, ['state'], 10),
127 'res.partner': (lambda self, cr, uid, ids, c={}: ids, ['free_member'], 10)
128 }, help="Date until which membership remains active."),
129 # XXX: copied from openerp/addons/membership/membership.py
130 'membership_cancel': fields.function(
131 _membership_date,
132 string = 'Cancel Membership Date', type='date', multi='membership_cancel',
133 store = {
134 'account.invoice': (_get_invoice_partner, ['state'], 11),
135 'membership.membership_line': (_get_partner_id, ['state'], 10),
136 'res.partner': (lambda self, cr, uid, ids, c={}: ids, ['free_member'], 10)
137 }, help="Date on which membership has been cancelled"),
138 }
139
140 _sql_constraints = [
141 ('member_ident_uniq', 'unique(member_ident, company_id)', 'The member identifier must be unique !'),
142 ]
143
144 def create_membership_invoice(self, cr, uid, ids, product_id=None, datas=None, context=None):
145 # NOTE: use context to supply date_from to account_invoice_line.create
146 context = context and context.copy() or {}
147 context.update({'date_from': datas.get('date_from', None)});
148 # XXX: copied from openerp/addons/membership/membership.py to fix account_invoice_line creation
149 print ("DEV: [remembership] [partner] [create_membership_invoice] ids=%s" % str(ids))
150 invoice_obj = self.pool.get('account.invoice')
151 invoice_line_obj = self.pool.get('account.invoice.line')
152 invoice_tax_obj = self.pool.get('account.invoice.tax')
153 product_id = product_id or datas.get('membership_product_id', False)
154 amount = datas.get('amount', 0.0)
155 invoice_list = []
156 if type(ids) in (int, long,):
157 ids = [ids]
158 for partner in self.browse(cr, uid, ids, context=context):
159 print ("DEV: [remembership] [partner] [create_membership_invoice] ids=%s partner=%s" % (str(ids),str(partner.id)))
160 account_id = partner.property_account_receivable and partner.property_account_receivable.id or False
161 fpos_id = partner.property_account_position and partner.property_account_position.id or False
162 addr = self.address_get(cr, uid, [partner.id], ['invoice'])
163 if partner.free_member:
164 raise osv.except_osv(_('Error!'),
165 _("Partner is a free Member."))
166 if not addr.get('invoice', False):
167 raise osv.except_osv(_('Error!'),
168 _("Partner doesn't have an address to make the invoice."))
169 quantity = 1
170 line_value = {
171 'product_id': product_id,
172 }
173
174 print ("DEV: [remembership] [partner] [create_membership_invoice] ids=%s partner=%s [invoice_line_obj] [product_id_change]" % (str(ids),str(partner.id)))
175 line_dict = invoice_line_obj.product_id_change(cr, uid, {},
176 product_id, False, quantity, '', 'out_invoice', partner.id, fpos_id, price_unit=amount, context=context)
177 line_value.update(line_dict['value'])
178 line_value['price_unit'] = amount
179 if line_value.get('invoice_line_tax_id', False):
180 tax_tab = [(6, 0, line_value['invoice_line_tax_id'])]
181 line_value['invoice_line_tax_id'] = tax_tab
182
183 print ("DEV: [remembership] [partner] [create_membership_invoice] ids=%s partner=%s [invoice_obj] [create] account=%s" % (str(ids),str(partner.id),str(account_id)))
184 # NOTE: let account_invoice_obj.create() call account_invoice_line.create()
185 # to have a correct membership_state: becauce now fields.function 'store' watchdogs
186 # are triggered after account_invoice_line.create().
187 invoice_id = invoice_obj.create(cr, uid, {
188 'partner_id': partner.id,
189 'account_id': account_id,
190 'fiscal_position': fpos_id or False,
191 'invoice_line':[(0, 0, line_value)]
192 }, context=context)
193 #line_value['invoice_id'] = invoice_id
194 #print ("DEV: [remembership] [partner] [create_membership_invoice] ids=%s partner=%s [invoice_line_obj] [create]" % (str(ids),str(partner.id)))
195 #invoice_line_id = invoice_line_obj.create(cr, uid, line_value, context=context)
196 #invoice_obj.write(cr, uid, invoice_id, {'invoice_line': line_value}, context=context)
197 print ("DEV: [remembership] [partner] [create_membership_invoice] : invoice_list.append(invoice_id) : pre")
198 invoice_list.append(invoice_id)
199 print ("DEV: [remembership] [partner] [create_membership_invoice] : invoice_list.append(invoice_id) : post")
200 if line_value['invoice_line_tax_id']:
201 tax_value = invoice_tax_obj.compute(cr, uid, invoice_id).values()
202 for tax in tax_value:
203 invoice_tax_obj.create(cr, uid, tax, context=context)
204 # NOTE: this wasn't working, and is not needed now.
205 #recompute the membership_state of those partners
206 #print ("DEV: [remembership] [partner] [create_membership_invoice] ids=%s [recompute states]" % str(ids))
207 #self.pool.get('res.partner').write(cr, uid, ids, {}, context=context)
208 print ("DEV: [remembership] [partner] [create_membership_invoice] return=%s" % str(invoice_list))
209 return invoice_list
210
211 def update_membership_status(self, cr, uid):
212 """Action for updating old members status with scheduled cron job"""
213 partner_obj = self.pool.get('res.partner')
214 today = date.today()
215 ids = partner_obj.search(cr, uid, [('membership_state', '=', 'paid'), ('membership_stop', '<', today)], context=None)
216 for id in ids:
217 self.write(cr, uid, id, {'membership_state': 'old'}, context=None)
218
219 def copy(self, cr, uid, id, default=None, context=None):
220 if default is None:
221 default = {}
222 default['member_ident'] = None
223 return super(Partner, self).copy(cr, uid, id, default, context)
224
225
226 Partner()
227
228
229 class Product(osv.osv):
230 _inherit = 'product.product'
231
232 _columns = {
233 'membership_grouped': fields.boolean('Grouped membership product', help='Check if it\'s a grouped membership product.'),
234 'membership_date2date': fields.boolean('Date to date membership product', required=False, help='Check if it\'s a date to date membership product.'),
235 }
236
237 Product()
238
239
240 class account_invoice_line(osv.osv):
241 _inherit = 'account.invoice.line'
242
243 def write(self, cr, uid, ids, vals, context=None):
244 member_line_obj = self.pool.get('membership.membership_line')
245 res = super(account_invoice_line, self).write(cr, uid, ids, vals, context=context)
246 for line in self.browse(cr, uid, ids, context=context):
247 if line.invoice_id.type == 'out_invoice':
248 ml_ids = member_line_obj.search(cr, uid, [('account_invoice_line', '=', line.id)], context=context)
249 if line.product_id and line.product_id.membership:
250 member_line_id = member_line_obj.search(cr, uid
251 , [('partner' , '=', line.invoice_id.partner_id.id)
252 ,('account_invoice_line', '=', line.id)]
253 , limit=1
254 , context=context)
255 for member_line in member_line_obj.browse(cr, uid, member_line_id, context=context):
256 # NOTE: get member_line created in membership.account_invoice_line.create
257 date_from = member_line.date_from
258 date_to = member_line.date_to
259 if line.product_id.membership_date2date:
260 date_from = ('date_from' in context
261 and context.get('date_from')
262 and datetime.strptime(context('date_from'), "%Y-%m-%d")
263 or date.today())
264 date_to = date_from + relativedelta(months=+12, days=-1) # TODO: parameterize this delta?
265 date_from = date_from.strftime("%Y-%m-%d")
266 date_to = date_to .strftime("%Y-%m-%d")
267 print ("DEV: [remembership] [account_invoice_line] [write] date_from: %s" % str(date_from))
268 print ("DEV: [remembership] [account_invoice_line] [write] date_to : %s" % str(date_to))
269 member_line_obj.write(cr, uid, member_line.id
270 , {'date_from': date_from
271 ,'date_to' : date_to
272 }
273 , context=context)
274 if line.product_id.membership_grouped:
275 if line.invoice_id.partner_id.associate_members:
276 associate_member_line_ids = member_line_obj.search(cr, uid
277 , [ ('account_invoice_line', '=', line.id)
278 , ('partner', '!=', line.invoice_id.partner_id.id)
279 ]
280 , context=context)
281 for associate_member_line in member_line_obj.browse(cr, uid, associate_member_line_ids, context=context):
282 print ("DEV: [remembership] [account_invoice_line] [write] [associate] date_from: %s" % str(date_from))
283 print ("DEV: [remembership] [account_invoice_line] [write] [associate] date_to : %s" % str(date_to))
284 member_line_obj.write(cr, uid, associate_member_line.id
285 , {'date_from': date_from
286 ,'date_to' : date_to
287 }
288 , context=context)
289 else:
290 print("DEV: mettre une contrainte pour l'objet\
291 membership.membership_line interdisant les\
292 adhésions groupées reliées à des partenaires\
293 sans membres associés")
294 else:
295 associate_member_line_ids = member_line_obj.search(cr, uid
296 , [ ('account_invoice_line', '=', line.id)
297 , ('partner', '!=', line.invoice_id.partner_id.id)
298 ]
299 , context=context)
300 member_line_obj.unlink(cr, uid, associate_member_line_ids, context=context)
301 #Define member ident if it's necessary
302 partners = [line.invoice_id.partner_id]
303 if line.invoice_id.partner_id.associate_members:
304 partners.extend(line.invoice_id.partner_id.associate_members)
305 for i in partners:
306 if not i.member_ident:
307 mbr_id = self.pool.get('ir.sequence').get(cr, uid, 'member_ident')
308 self.pool.get('res.partner').write(cr, uid, i.id, {'member_ident': mbr_id})
309 if line.product_id and not line.product_id.membership and ml_ids:
310 # Product line has changed to a non membership product
311 member_line_obj.unlink(cr, uid, ml_ids, context=context)
312 print ("DEV: [remembership] [account_invoice_line] [write] : return=%s" % str(res))
313 return res
314
315 def create(self, cr, uid, vals, context=None):
316 member_line_obj = self.pool.get('membership.membership_line')
317 res = super(account_invoice_line, self).create(cr, uid, vals, context=context)
318 print ("DEV: [remembership] [account_invoice_line] [create] : begin res=%s" % str(res))
319 line = self.browse(cr, uid, res, context=context)
320
321 if line.invoice_id.type == 'out_invoice' and line.product_id and line.product_id.membership:
322 member_line_id = member_line_obj.search(cr, uid
323 , [('partner' , '=', line.invoice_id.partner_id.id)
324 ,('account_invoice_line', '=', line.id)]
325 , limit=1
326 , context=context)
327 for member_line in member_line_obj.browse(cr, uid, member_line_id, context=context):
328 # NOTE: get member_line created in membership.account_invoice_line.create
329 date_from = member_line.date_from
330 date_to = member_line.date_to
331 if line.product_id.membership_date2date:
332 date_from = ('date_from' in context
333 and context.get('date_from')
334 and datetime.strptime(context.get('date_from'), "%Y-%m-%d")
335 or date.today())
336 print("#DEBUG: Date de début - %s" % str(date_from))
337 date_to = date_from + relativedelta(months=+12, days=-1) # TODO: parameterize this delta?
338 date_from = date_from.strftime("%Y-%m-%d")
339 date_to = date_to .strftime("%Y-%m-%d")
340 print ("DEV: [remembership] [account_invoice_line] [create] date_from: %s" % str(date_from))
341 print ("DEV: [remembership] [account_invoice_line] [create] date_to : %s" % str(date_to))
342 member_line_obj.write(cr, uid, member_line.id
343 , {'date_from': date_from
344 ,'date_to' : date_to
345 }
346 , context=context)
347 partners = [line.invoice_id.partner_id]
348 if line.product_id.membership_grouped and line.invoice_id.partner_id.associate_members:
349 partners.extend(line.invoice_id.partner_id.associate_members)
350 #Adding membership lines just for associate partners
351 for associate_member in line.invoice_id.partner_id.associate_members:
352 print ("DEV: [remembership] [account_invoice_line] [create] [associate] date_from: %s" % str(date_from))
353 print ("DEV: [remembership] [account_invoice_line] [create] [associate] date_to : %s" % str(date_to))
354 member_line_obj.create(cr, uid, {
355 'partner': associate_member.id,
356 'membership_id': line.product_id.id,
357 'member_price': line.price_unit,
358 'date': time.strftime('%Y-%m-%d'),
359 'date_from': date_from,
360 'date_to': date_to,
361 'account_invoice_line': line.id,
362 }, context=context)
363 elif line.product_id.membership_grouped and not line.invoice_id.partner_id.associate_members:
364 raise osv.except_osv(_('Error!!!'), _('You try to invoice grouped membership product to a partner who hasn\'t associated partners.'))
365 #Define member ident if it's necessary
366 for i in partners:
367 if not i.member_ident:
368 mbr_id = self.pool.get('ir.sequence').get(cr, uid, 'member_ident')
369 self.pool.get('res.partner').write(cr, uid, i.id, {'member_ident': mbr_id})
370 print ("DEV: [remembership] [account_invoice_line] [create] : return=%s" % str(res))
371 return res
372
373 account_invoice_line()
374 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: