388 lines
14 KiB
Python
388 lines
14 KiB
Python
|
# -*- coding: utf-8 -*-
|
||
|
|
# This file is part of lims_account_invoice module for Tryton.
|
||
|
|
# The COPYRIGHT file at the top level of this repository contains
|
||
|
|
# the full copyright notices and license terms.
|
||
|
|
|
||
|
|
from email.mime.base import MIMEBase
|
||
|
|
from email.mime.multipart import MIMEMultipart
|
||
|
|
from email.mime.application import MIMEApplication
|
||
|
|
from time import time
|
||
|
|
import logging
|
||
|
|
|
||
|
|
from trytond.model import Workflow, ModelView, ModelSQL, fields
|
||
|
|
from trytond.pool import Pool, PoolMeta
|
||
|
|
from trytond.pyson import Eval, Bool, Or
|
||
|
|
from trytond.transaction import Transaction
|
||
|
|
from trytond.tools import get_smtp_server
|
||
|
|
from trytond.config import config
|
||
|
|
|
||
|
|
__all__ = ['Invoice', 'InvoiceContact', 'InvoiceLine', 'CreditInvoice']
|
||
|
|
|
||
|
|
logger = logging.getLogger('lims_account_invoice')
|
||
|
|
|
||
|
|
|
||
|
|
class Invoice:
|
||
|
|
__name__ = 'account.invoice'
|
||
|
|
__metaclass__ = PoolMeta
|
||
|
|
|
||
|
|
lims_project = fields.Many2One('lims.project', 'TAS Project',
|
||
|
|
domain=[('type', '=', 'tas')],
|
||
|
|
states={
|
||
|
|
'readonly': Eval('state') != 'draft',
|
||
|
|
'invisible': Eval('type').in_(['in'])
|
||
|
|
})
|
||
|
|
no_send_invoice = fields.Boolean('No send invoice',
|
||
|
|
states={'invisible': Eval('type') == 'in'},
|
||
|
|
depends=['type'],
|
||
|
|
help='If checked, then the invoice will not be mailed to contacts.')
|
||
|
|
invoice_contacts = fields.One2Many('account.invoice.invoice_contacts',
|
||
|
|
'invoice', 'Invoice contacts',
|
||
|
|
states={'invisible': Eval('type') == 'in'},
|
||
|
|
depends=['type'],
|
||
|
|
)
|
||
|
|
sent = fields.Boolean('Sent', readonly=True,
|
||
|
|
help='If checked, then the invoice was mailed to contacts.')
|
||
|
|
sent_date = fields.DateTime('Sent date', readonly=True,
|
||
|
|
states={'invisible': Bool(Eval('no_send_invoice'))},
|
||
|
|
depends=['no_send_invoice'])
|
||
|
|
entries_comments = fields.Text('Entries comments',
|
||
|
|
states={'invisible': Eval('type') == 'in'},
|
||
|
|
depends=['type'], readonly=True)
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
def __setup__(cls):
|
||
|
|
super(Invoice, cls).__setup__()
|
||
|
|
cls._check_modify_exclude.extend(['sent', 'sent_date',
|
||
|
|
'invoice_contacts', 'no_send_invoice'])
|
||
|
|
cls._error_messages.update({
|
||
|
|
'not_invoice_contacts': 'Invoice Contacts field must have a value',
|
||
|
|
})
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
def view_attributes(cls):
|
||
|
|
return super(Invoice, cls).view_attributes() + [
|
||
|
|
('/form/notebook/page[@id="contacts"]', 'states', {
|
||
|
|
'invisible': Eval('type') == 'in',
|
||
|
|
}),
|
||
|
|
]
|
||
|
|
|
||
|
|
@fields.depends('party')
|
||
|
|
def on_change_party(self):
|
||
|
|
super(Invoice, self).on_change_party()
|
||
|
|
self.no_send_invoice = False
|
||
|
|
if self.party:
|
||
|
|
self.no_send_invoice = self.party.no_send_invoice
|
||
|
|
|
||
|
|
def _credit(self):
|
||
|
|
credit = super(Invoice, self)._credit()
|
||
|
|
if self.invoice_contacts:
|
||
|
|
credit.invoice_contacts = [contact._credit()
|
||
|
|
for contact in self.invoice_contacts]
|
||
|
|
credit.no_send_invoice = self.no_send_invoice
|
||
|
|
return credit
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
@ModelView.button
|
||
|
|
@Workflow.transition('posted')
|
||
|
|
def post(cls, invoices):
|
||
|
|
cls.check_invoice_contacts(invoices)
|
||
|
|
super(Invoice, cls).post(invoices)
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
def check_invoice_contacts(cls, invoices):
|
||
|
|
for invoice in invoices:
|
||
|
|
if invoice.type == 'out':
|
||
|
|
if (not invoice.no_send_invoice
|
||
|
|
and not invoice.invoice_contacts):
|
||
|
|
cls.raise_user_error('not_invoice_contacts')
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
def cron_send_invoice(cls):
|
||
|
|
'''
|
||
|
|
Cron - Send Of Invoice
|
||
|
|
'''
|
||
|
|
logger.info('Cron - Send Of Invoice:INIT')
|
||
|
|
t1 = time() # DEBUG
|
||
|
|
pool = Pool()
|
||
|
|
SendOfInvoice = pool.get('account.invoice.send_invoice', type='wizard')
|
||
|
|
Invoice = pool.get('account.invoice')
|
||
|
|
invoices = Invoice.search([
|
||
|
|
('type', '=', 'out'),
|
||
|
|
('sent', '=', False),
|
||
|
|
('no_send_invoice', '=', False),
|
||
|
|
('state', 'in', ['posted', 'paid']),
|
||
|
|
])
|
||
|
|
logger.info('Cron - Send Of Invoice:Se procesaran %s facturas...',
|
||
|
|
len(invoices))
|
||
|
|
if invoices:
|
||
|
|
session_id, _, _ = SendOfInvoice.create()
|
||
|
|
send_of_invoice = SendOfInvoice(session_id)
|
||
|
|
with Transaction().set_context(active_ids=[invoice.id for invoice
|
||
|
|
in invoices]):
|
||
|
|
send_of_invoice.transition_start()
|
||
|
|
tt = round(time() - t1, 2) # DEBUG
|
||
|
|
logger.info('Cron - Send Of Invoice:END:Finalizado en %s segundos.',
|
||
|
|
tt)
|
||
|
|
|
||
|
|
def mail_send_invoice(self):
|
||
|
|
if not self.invoice_report_cache:
|
||
|
|
return
|
||
|
|
|
||
|
|
from_addr = config.get('email', 'from')
|
||
|
|
to_addrs = [c.contact.email for c in self.invoice_contacts]
|
||
|
|
if not (from_addr and to_addrs):
|
||
|
|
logger.warn('mail_send_invoice():Factura %s:Envio omitido '
|
||
|
|
'por no contener contactos.', self.number) # DEBUG
|
||
|
|
return
|
||
|
|
logger.info('mail_send_invoice():INFO:Contactos de factura:'
|
||
|
|
'emails:(%s)', ','.join(to_addrs)) # DEBUG
|
||
|
|
|
||
|
|
subject, body = self.subject_body()
|
||
|
|
attachments_data = self.attachment()
|
||
|
|
msg = self.create_msg(from_addr, to_addrs, subject,
|
||
|
|
body, attachments_data)
|
||
|
|
return self.send_msg(from_addr, to_addrs, msg)
|
||
|
|
|
||
|
|
def subject_body(self):
|
||
|
|
pool = Pool()
|
||
|
|
Config = pool.get('lims.configuration')
|
||
|
|
User = pool.get('res.user')
|
||
|
|
Lang = pool.get('ir.lang')
|
||
|
|
|
||
|
|
config = Config(1)
|
||
|
|
|
||
|
|
lang = User(Transaction().user).language
|
||
|
|
if not lang:
|
||
|
|
lang, = Lang.search([
|
||
|
|
('code', '=', 'en'),
|
||
|
|
], limit=1)
|
||
|
|
|
||
|
|
with Transaction().set_context(language=lang.code):
|
||
|
|
subject = unicode('%s %s' % (config.mail_send_invoice_subject,
|
||
|
|
self.number)).strip()
|
||
|
|
body = unicode(config.mail_send_invoice_body)
|
||
|
|
|
||
|
|
return subject, body
|
||
|
|
|
||
|
|
def attachment(self):
|
||
|
|
data = []
|
||
|
|
data.append({
|
||
|
|
'content': self.invoice_report_cache,
|
||
|
|
'format': self.invoice_report_format,
|
||
|
|
'mimetype': self.invoice_report_format == 'pdf' and 'pdf'
|
||
|
|
or 'vnd.oasis.opendocument.text',
|
||
|
|
'filename': (unicode(self.number) + '.'
|
||
|
|
+ str(self.invoice_report_format)),
|
||
|
|
'name': unicode(self.number),
|
||
|
|
})
|
||
|
|
if self.invoice_service_report_cache:
|
||
|
|
data.append({
|
||
|
|
'content': self.invoice_service_report_cache,
|
||
|
|
'format': self.invoice_service_report_format,
|
||
|
|
'mimetype': self.invoice_service_report_format == 'pdf'
|
||
|
|
and 'pdf' or 'vnd.oasis.opendocument.text',
|
||
|
|
'filename': (unicode(self.number) + ' (II).'
|
||
|
|
+ str(self.invoice_report_format)),
|
||
|
|
'name': unicode(self.number) + ' (II)',
|
||
|
|
})
|
||
|
|
return data
|
||
|
|
|
||
|
|
def create_msg(self, from_addr, to_addrs, subject, body, attachments_data):
|
||
|
|
if not to_addrs:
|
||
|
|
return None
|
||
|
|
|
||
|
|
msg = MIMEMultipart()
|
||
|
|
msg['From'] = from_addr
|
||
|
|
hidden = True # TODO: HARDCODE!
|
||
|
|
if not hidden:
|
||
|
|
msg['To'] = ', '.join(to_addrs)
|
||
|
|
msg['Subject'] = subject
|
||
|
|
|
||
|
|
msg_body = MIMEBase('text', 'plain')
|
||
|
|
msg_body.set_payload(body.encode('UTF-8'), 'UTF-8')
|
||
|
|
msg.attach(msg_body)
|
||
|
|
|
||
|
|
for attachment_data in attachments_data:
|
||
|
|
attachment = MIMEApplication(
|
||
|
|
attachment_data['content'],
|
||
|
|
Name=attachment_data['filename'], _subtype="pdf")
|
||
|
|
attachment.add_header('content-disposition', 'attachment',
|
||
|
|
filename=('utf-8', '', attachment_data['filename']))
|
||
|
|
msg.attach(attachment)
|
||
|
|
|
||
|
|
return msg
|
||
|
|
|
||
|
|
def send_msg(self, from_addr, to_addrs, msg):
|
||
|
|
to_addrs = list(set(to_addrs))
|
||
|
|
success = False
|
||
|
|
try:
|
||
|
|
server = get_smtp_server()
|
||
|
|
server.sendmail(from_addr, to_addrs, msg.as_string())
|
||
|
|
server.quit()
|
||
|
|
success = True
|
||
|
|
except Exception:
|
||
|
|
logger.error('Unable to deliver mail for invoice %s', self.number)
|
||
|
|
return success
|
||
|
|
|
||
|
|
|
||
|
|
class InvoiceContact(ModelSQL, ModelView):
|
||
|
|
'Invoice Contact'
|
||
|
|
__name__ = 'account.invoice.invoice_contacts'
|
||
|
|
|
||
|
|
invoice = fields.Many2One('account.invoice', 'Invoice',
|
||
|
|
ondelete='CASCADE', select=True, required=True)
|
||
|
|
contact = fields.Many2One('party.address', 'Contact', required=True,
|
||
|
|
domain=[('invoice_contact', '=', True)])
|
||
|
|
|
||
|
|
def _credit(self):
|
||
|
|
credit = self.__class__()
|
||
|
|
for field in ('invoice', 'contact'):
|
||
|
|
setattr(credit, field, getattr(self, field))
|
||
|
|
return credit
|
||
|
|
|
||
|
|
|
||
|
|
class InvoiceLine:
|
||
|
|
__name__ = 'account.invoice.line'
|
||
|
|
__metaclass__ = PoolMeta
|
||
|
|
|
||
|
|
lims_service_party = fields.Function(fields.Many2One('party.party',
|
||
|
|
'Party', depends=['invoice_type'],
|
||
|
|
states={
|
||
|
|
'invisible': Or(Eval('_parent_invoice', {}).get('type') == 'in',
|
||
|
|
Eval('invoice_type') == 'in'),
|
||
|
|
}), 'get_fraction_field', searcher='search_fraction_field')
|
||
|
|
lims_service_entry = fields.Function(fields.Many2One('lims.entry',
|
||
|
|
'Entry', depends=['invoice_type'],
|
||
|
|
states={
|
||
|
|
'invisible': Or(Eval('_parent_invoice', {}).get('type') == 'in',
|
||
|
|
Eval('invoice_type') == 'in'),
|
||
|
|
}), 'get_fraction_field', searcher='search_fraction_field')
|
||
|
|
lims_service_sample = fields.Function(fields.Many2One('lims.sample',
|
||
|
|
'Sample', depends=['invoice_type'],
|
||
|
|
states={
|
||
|
|
'invisible': Or(Eval('_parent_invoice', {}).get('type') == 'in',
|
||
|
|
Eval('invoice_type') == 'in'),
|
||
|
|
}), 'get_fraction_field', searcher='search_fraction_field')
|
||
|
|
lims_service_results_reports = fields.Function(fields.Char(
|
||
|
|
'Results Reports', depends=['invoice_type'],
|
||
|
|
states={
|
||
|
|
'invisible': Or(Eval('_parent_invoice', {}).get('type') == 'in',
|
||
|
|
Eval('invoice_type') == 'in'),
|
||
|
|
}), 'get_results_reports', searcher='search_results_reports')
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
def __setup__(cls):
|
||
|
|
super(InvoiceLine, cls).__setup__()
|
||
|
|
cls.origin.states['readonly'] = True
|
||
|
|
cls._error_messages.update({
|
||
|
|
'delete_service_invoice': ('You can not delete an invoice line '
|
||
|
|
'related to a service ("%s")'),
|
||
|
|
})
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
def delete(cls, lines):
|
||
|
|
if not Transaction().context.get('delete_service', False):
|
||
|
|
cls.check_service_invoice(lines)
|
||
|
|
super(InvoiceLine, cls).delete(lines)
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
def check_service_invoice(cls, lines):
|
||
|
|
for line in lines:
|
||
|
|
if (line.origin and line.origin.__name__ == 'lims.service'
|
||
|
|
and not line.economic_offer):
|
||
|
|
cls.raise_user_error('delete_service_invoice',
|
||
|
|
(line.origin.rec_name,))
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
def get_fraction_field(cls, lines, names):
|
||
|
|
result = {}
|
||
|
|
for name in names:
|
||
|
|
result[name] = {}
|
||
|
|
for l in lines:
|
||
|
|
if l.origin and l.origin.__name__ == 'lims.service':
|
||
|
|
# name[13:]: remove 'lims_service_' from field name
|
||
|
|
field = getattr(l.origin.fraction, name[13:], None)
|
||
|
|
result[name][l.id] = field.id if field else None
|
||
|
|
else:
|
||
|
|
result[name][l.id] = None
|
||
|
|
return result
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
def search_fraction_field(cls, name, clause):
|
||
|
|
return [('origin.fraction.' + name[13:],) + tuple(clause[1:]) +
|
||
|
|
('lims.service',)]
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
def get_results_reports(cls, lines, name):
|
||
|
|
pool = Pool()
|
||
|
|
LimsNotebookLine = pool.get('lims.notebook.line')
|
||
|
|
result = {}
|
||
|
|
for l in lines:
|
||
|
|
reports = []
|
||
|
|
if l.origin and l.origin.__name__ == 'lims.service':
|
||
|
|
notebook_lines = LimsNotebookLine.search([
|
||
|
|
('service', '=', l.origin.id),
|
||
|
|
('results_report', '!=', None),
|
||
|
|
], limit=1)
|
||
|
|
if notebook_lines:
|
||
|
|
reports = [nl.results_report.rec_name for nl in
|
||
|
|
notebook_lines]
|
||
|
|
if reports:
|
||
|
|
result[l.id] = ', '.join([r for r in reports])
|
||
|
|
else:
|
||
|
|
result[l.id] = None
|
||
|
|
return result
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
def search_results_reports(cls, name, clause):
|
||
|
|
cursor = Transaction().connection.cursor()
|
||
|
|
pool = Pool()
|
||
|
|
ResultsReport = pool.get('lims.results_report')
|
||
|
|
NotebookLine = pool.get('lims.notebook.line')
|
||
|
|
|
||
|
|
value = clause[2]
|
||
|
|
cursor.execute('SELECT DISTINCT(nl.service) '
|
||
|
|
'FROM "' + ResultsReport._table + '" r '
|
||
|
|
'INNER JOIN "' + NotebookLine._table + '" nl '
|
||
|
|
'ON nl.results_report = r.id '
|
||
|
|
'WHERE r.number ILIKE %s', (value,))
|
||
|
|
services = [x[0] for x in cursor.fetchall()]
|
||
|
|
if not services:
|
||
|
|
return [('id', '=', -1)]
|
||
|
|
|
||
|
|
services_ids = ['lims.service,' + str(s) for s in services]
|
||
|
|
return [('origin', 'in', services_ids)]
|
||
|
|
|
||
|
|
@classmethod
|
||
|
|
def _get_origin(cls):
|
||
|
|
models = super(InvoiceLine, cls)._get_origin()
|
||
|
|
models.append('lims.service')
|
||
|
|
return models
|
||
|
|
|
||
|
|
|
||
|
|
class CreditInvoice:
|
||
|
|
__name__ = 'account.invoice.credit'
|
||
|
|
__metaclass__ = PoolMeta
|
||
|
|
|
||
|
|
def do_credit(self, action):
|
||
|
|
pool = Pool()
|
||
|
|
AccountInvoice = pool.get('account.invoice')
|
||
|
|
AccountInvoiceLine = pool.get('account.invoice.line')
|
||
|
|
|
||
|
|
action, data = super(CreditInvoice, self).do_credit(action)
|
||
|
|
|
||
|
|
if self.start.with_refund:
|
||
|
|
old_lines = []
|
||
|
|
invoices = AccountInvoice.browse(
|
||
|
|
Transaction().context['active_ids'])
|
||
|
|
for invoice in invoices:
|
||
|
|
for line in invoice.lines:
|
||
|
|
if line.origin and line.origin.__name__ == 'lims.service':
|
||
|
|
old_line = AccountInvoiceLine(line.id)
|
||
|
|
old_line.origin = None
|
||
|
|
old_lines.append(old_line)
|
||
|
|
if old_lines:
|
||
|
|
AccountInvoiceLine.save(old_lines)
|
||
|
|
|
||
|
|
return action, data
|