main.py 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661
  1. # -*- coding: utf-8 -*-
  2. from openerp import http
  3. from openerp.http import request
  4. from werkzeug.wrappers import Response
  5. from werkzeug.datastructures import Headers
  6. from datetime import datetime
  7. from dateutil.relativedelta import relativedelta as rd
  8. from dateutil.parser import parse
  9. from gzip import GzipFile
  10. from StringIO import StringIO as IO
  11. import simplejson as json
  12. import gzip
  13. import logging
  14. LOGGER = logging.getLogger(__name__)
  15. DATE_FORMAT = '%Y-%m-%d'
  16. DATETIME_FORMAT = '%Y-%m-%d %H:%m:%S'
  17. GZIP_COMPRESSION_LEVEL = 9
  18. class Purchases(http.Controller):
  19. '''
  20. Get server date to send
  21. '''
  22. def get_server_date(self):
  23. return datetime.now().strftime(DATE_FORMAT)
  24. '''
  25. Get current user information
  26. '''
  27. def get_user(self):
  28. user = request.env.user
  29. return {
  30. 'id': user.id,
  31. 'name': user.name,
  32. 'displayName': user.display_name,
  33. 'currency': {
  34. 'id': user.company_id.currency_id.id,
  35. 'name': user.company_id.currency_id.name,
  36. 'displayName': user.company_id.currency_id.display_name,
  37. 'symbol': user.company_id.currency_id.symbol
  38. },
  39. 'company': {
  40. 'id': user.company_id.id,
  41. 'name': user.company_id.name,
  42. 'displayName': user.company_id.display_name
  43. }
  44. }
  45. '''
  46. Get currencies
  47. '''
  48. def get_currencies(self):
  49. return [{
  50. 'id': currency.id,
  51. 'name': currency.name,
  52. 'displayName': currency.display_name,
  53. 'base': currency.base,
  54. 'accuracy': currency.accuracy,
  55. 'rateSilent': currency.rate_silent,
  56. 'rounding': currency.rounding,
  57. 'symbol': currency.symbol,
  58. 'position': currency.position,
  59. 'decimalSeparator': currency.decimal_separator,
  60. 'decimalPlaces': currency.decimal_places,
  61. 'thousandsSeparator': currency.thousands_separator
  62. } for currency in request.env['res.currency'].search([('active', '=', True)])]
  63. '''
  64. Get all active journals
  65. '''
  66. def get_journals(self):
  67. return [{
  68. 'id': journal.id,
  69. 'name': journal.name,
  70. 'displayName': journal.display_name,
  71. 'code': journal.code,
  72. 'cashControl': journal.cash_control,
  73. 'type': journal.type,
  74. 'currency': {
  75. 'id': journal.currency.id,
  76. 'name': journal.currency.name,
  77. 'displayName': journal.currency.display_name
  78. },
  79. 'defaultDebitAccount': {
  80. 'id': journal.default_debit_account_id.id,
  81. 'name': journal.default_debit_account_id.name,
  82. 'displayName': journal.default_debit_account_id.display_name,
  83. 'code': journal.default_debit_account_id.code,
  84. 'exchange_rate': journal.default_credit_account_id.exchange_rate,
  85. 'foreignBalance': journal.default_credit_account_id.foreign_balance,
  86. 'reconcile': journal.default_credit_account_id.reconcile,
  87. 'debit': journal.default_credit_account_id.debit,
  88. 'credit': journal.default_credit_account_id.credit,
  89. 'currencyMode': journal.default_credit_account_id.currency_mode,
  90. 'companyCurrency': {
  91. 'id': journal.default_credit_account_id.company_currency_id.id,
  92. 'name': journal.default_credit_account_id.company_currency_id.name,
  93. 'displayName': journal.default_credit_account_id.company_currency_id.display_name,
  94. },
  95. 'currency': {
  96. 'id': journal.default_credit_account_id.currency_id.id,
  97. 'name': journal.default_credit_account_id.currency_id.name,
  98. 'displayName': journal.default_credit_account_id.currency_id.display_name
  99. }
  100. }
  101. } for journal in request.env['account.journal'].search([('type', 'in', ['bank', 'cash']), ('default_debit_account_id.currency_id', '=', False), ('active', '=', True)], order='id')]
  102. '''
  103. Get all active suppliers
  104. '''
  105. def get_suppliers(self):
  106. return [{
  107. 'id': supplier.id,
  108. 'name': supplier.name,
  109. 'displayName': supplier.display_name,
  110. 'imageMedium': supplier.image_medium,
  111. 'phone': supplier.phone,
  112. 'mobile': supplier.mobile,
  113. 'email': supplier.email
  114. } for supplier in request.env['res.partner'].search([('supplier', '=', True), ('active', '=', True)])]
  115. '''
  116. Get all purchasable and active products
  117. '''
  118. def get_products(self):
  119. return [{
  120. 'id': product.id,
  121. 'name': product.name,
  122. 'displayName': product.display_name,
  123. 'ean13': product.ean13,
  124. 'imageMedium': product.image_medium,
  125. 'standardPrice': product.standard_price,
  126. 'variantCount': product.product_variant_count,
  127. 'quantity': 1,
  128. 'price': product.standard_price,
  129. 'variants': [{
  130. 'id': variant.id,
  131. 'name': variant.name,
  132. 'displayName': variant.display_name,
  133. 'ean13': variant.ean13,
  134. 'imageMedium': variant.image_medium,
  135. 'standardPrice': variant.standard_price,
  136. 'quantity': 1,
  137. 'price': variant.standard_price
  138. } for variant in product.product_variant_ids if variant.active]
  139. } for product in request.env['product.template'].search([('purchase_ok', '=', True), ('standard_price', '>=', 0), ('active', '=', True)])]
  140. '''
  141. Get all incoming and active picking types
  142. '''
  143. def get_picking_types(self):
  144. return [{
  145. 'id': picking_type.id,
  146. 'name': picking_type.name,
  147. 'displayName': picking_type.display_name
  148. } for picking_type in request.env['stock.picking.type'].search([('code', '=', 'incoming'), ('active', '=', True)])]
  149. '''
  150. Get all active payment terms
  151. '''
  152. def get_payment_terms(self):
  153. return [{
  154. 'id': payment_term.id,
  155. 'name': payment_term.name,
  156. 'displayName': payment_term.display_name,
  157. 'lines': [{
  158. 'id': line.id,
  159. 'days': line.days,
  160. 'days2': line.days2,
  161. 'value': line.value,
  162. 'valueAmount': line.value_amount
  163. } for line in payment_term.line_ids]
  164. } for payment_term in request.env['account.payment.term'].search([('active', '=', True)])]
  165. '''
  166. Make JSON response to send
  167. '''
  168. def make_response(self, data=None, status=200):
  169. return Response(json.dumps(data), status=status, content_type='application/json')
  170. '''
  171. Make GZIP to JSON response
  172. '''
  173. def make_gzip_response(self, data=None, status=200):
  174. gzip_buffer = IO()
  175. with GzipFile(mode='wb', compresslevel=GZIP_COMPRESSION_LEVEL, fileobj=gzip_buffer) as gzip_file:
  176. gzip_file.write(json.dumps(data))
  177. contents = gzip_buffer.getvalue()
  178. gzip_buffer.close()
  179. headers = Headers()
  180. headers.add('Content-Encoding', 'gzip')
  181. headers.add('Vary', 'Accept-Encoding')
  182. headers.add('Content-Length', len(contents))
  183. return Response(contents, status=status, headers=headers, content_type='application/json')
  184. '''
  185. '''
  186. def make_info_log(self, log):
  187. LOGGER.info('\033[1;34m[INFO] --> \033[m{}'.format(log))
  188. '''
  189. New purchase resource route
  190. '''
  191. @http.route('/eiru_purchases/init', auth='user', methods=['GET'], cors='*')
  192. def init_purchase(self, **kw):
  193. self.make_info_log('Sending JSON response')
  194. return self.make_gzip_response({
  195. 'date': self.get_server_date(),
  196. 'user': self.get_user(),
  197. 'currencies': self.get_currencies(),
  198. 'journals': self.get_journals(),
  199. 'suppliers': self.get_suppliers(),
  200. 'products': self.get_products(),
  201. 'pickingTypes': self.get_picking_types(),
  202. 'paymentTerms': self.get_payment_terms()
  203. })
  204. '''
  205. Create supplier and return data
  206. '''
  207. @http.route('/eiru_purchases/create_supplier', type='json', auth='user', methods=['POST'], cors='*')
  208. def create_supplier(self, **kw):
  209. self.make_info_log('Creating supplier')
  210. supplier = request.env['res.partner'].create({
  211. 'name': kw.get('name'),
  212. 'ruc': kw.get('ruc'),
  213. 'phone': kw.get('phone'),
  214. 'supplier': True,
  215. 'customer': False
  216. })
  217. return {
  218. 'id': supplier.id,
  219. 'name': supplier.name,
  220. 'displayName': supplier.display_name,
  221. 'imageMedium': supplier.image_medium,
  222. 'phone': supplier.phone,
  223. 'mobile': supplier.mobile,
  224. 'email': supplier.email
  225. }
  226. '''
  227. Create product and return data
  228. '''
  229. @http.route('/eiru_purchases/create_product', type='json', auth='user', methods=['POST'], cors='*')
  230. def create_product(self, **kw):
  231. self.make_info_log('Creating product')
  232. product = request.env['product.template'].create({
  233. 'name': kw.get('name'),
  234. 'standard_price': float(kw.get('price')),
  235. 'ean13': kw.get('ean13')
  236. })
  237. return {
  238. 'id': product.id,
  239. 'name': product.name,
  240. 'displayName': product.display_name,
  241. 'ean13': product.ean13,
  242. 'imageMedium': product.image_medium,
  243. 'listPrice': product.list_price,
  244. 'variantCount': product.product_variant_count,
  245. 'variants': [{
  246. 'id': variant.id,
  247. 'name': variant.name,
  248. 'displayName': variant.display_name,
  249. 'ean13': variant.ean13,
  250. 'imageMedium': variant.image_medium,
  251. 'standardPrice': variant.standard_price
  252. } for variant in product.product_variant_ids if variant.active]
  253. }
  254. '''
  255. Get currency id based on journal
  256. '''
  257. def get_currency_id(self, journal_id):
  258. journal = request.env['account.journal'].browse(journal_id)
  259. return journal.default_debit_account_id.currency_id.id or journal.default_debit_account_id.company_currency_id.id
  260. '''
  261. Check currency in pricelist and return it
  262. '''
  263. def get_pricelist_id(self, currency_id):
  264. pricelist = request.env['product.pricelist'].search([('active', '=', True), ('type', '=', 'sale')])
  265. if not True in pricelist.mapped(lambda p: p.currency_id.id == currency_id):
  266. pricelist = pricelist[0].copy()
  267. pricelist.write({
  268. 'currency_id': currency_id
  269. })
  270. else:
  271. pricelist = pricelist.filtered(lambda p: p.currency_id.id == currency_id)
  272. return pricelist.id
  273. '''
  274. Get default location
  275. '''
  276. def get_stock_location_id(self):
  277. stock_location = request.env['stock.location'].search([('usage', '=', 'internal')])
  278. return stock_location.id
  279. '''
  280. Create purchase order from cart and return id
  281. '''
  282. def create_purchase_order(self, supplier_id, cart_items, date_order, currency_id, pricelist_id, payment_term_id=None):
  283. return request.env['purchase.order'].create({
  284. 'name': '/',
  285. 'partner_id': supplier_id,
  286. 'order_line': [[0, False, {
  287. 'name': line.get('name'),
  288. 'date_planned': date_order,
  289. 'product_id': int(line.get('id')),
  290. 'product_qty': float(line.get('quantity')),
  291. 'price_unit': float(line.get('price'))
  292. }] for line in cart_items],
  293. 'date_order': datetime.now().strftime(DATETIME_FORMAT),
  294. 'currency_id': currency_id,
  295. 'pricelist_id': pricelist_id,
  296. 'payment_term_id': payment_term_id,
  297. 'location_id': self.get_stock_location_id(),
  298. 'invoice_method': 'order'
  299. })
  300. '''
  301. Confirm purchase order
  302. '''
  303. def confirm_purchase_order(self, purchase_order_id):
  304. purchase_order = request.env['purchase.order'].browse(purchase_order_id)
  305. purchase_order.action_purchase_confirm()
  306. for picking in purchase_order.picking_ids:
  307. picking.force_assign()
  308. picking.action_done()
  309. purchase_order.write({
  310. 'state': 'done'
  311. })
  312. '''
  313. Validate invoice
  314. '''
  315. def prepare_invoice(self, invoice_ids, currency_id, date_today):
  316. assert len(invoice_ids) == 1
  317. invoice = request.env['account.invoice'].browse(invoice_ids)
  318. date_due = parse(date_today) + rd(days=max(invoice.payment_term.line_ids.mapped(lambda x: x.days + x.days2)))
  319. invoice.write({
  320. 'currency_id': currency_id,
  321. 'date_invoice': date_today,
  322. 'date_due': date_due.strftime(DATE_FORMAT),
  323. 'state': 'open'
  324. })
  325. '''
  326. Create move lines
  327. '''
  328. def create_invoice_move_lines(self, invoice_ids, paid_amount, date_today):
  329. assert len(invoice_ids) == 1
  330. invoice = request.env['account.invoice'].browse(invoice_ids)
  331. is_purchase = False
  332. scoped_context = dict(request.context, lang=invoice.partner_id.lang)
  333. invoice_move_lines = invoice._get_analytic_lines()
  334. decimal_precision = request.env['decimal.precision'].precision_get('Account')
  335. compute_taxes = request.env['account.invoice.tax'].compute(invoice.with_context(lang=invoice.partner_id.lang))
  336. invoice.check_tax_lines(compute_taxes)
  337. invoice._recompute_tax_amount()
  338. invoice_move_lines += request.env['account.invoice.tax'].move_line_get(invoice.id)
  339. total, total_currency, invoice_move_lines = invoice.with_context(scoped_context).compute_invoice_totals(invoice.company_id.currency_id, invoice.reference, invoice_move_lines)
  340. if total < 0:
  341. total = total * -1
  342. is_purchase = True
  343. paid_percentage = abs(paid_amount / round(total, decimal_precision))
  344. distributed_percentage = -(paid_percentage / len(invoice.payment_term.line_ids))
  345. payment_lines = []
  346. for line in invoice.payment_term.line_ids:
  347. date_due = (parse(date_today) + rd(days=line.days + line.days2)).strftime(DATE_FORMAT)
  348. if paid_percentage and paid_percentage < 1.0:
  349. payment_lines.append([date_today, paid_percentage])
  350. paid_percentage = paid_amount = 0
  351. if date_due == date_today and line.value_amount:
  352. distributed_percentage = -((payment_lines[0][1] - line.value_amount) / (len(invoice.payment_term.line_ids) - 1))
  353. continue
  354. if line.value != 'balance':
  355. payment_lines.append([date_due, line.value_amount + distributed_percentage])
  356. continue
  357. payment_lines.append([date_due, line.value_amount])
  358. for payment_line in payment_lines:
  359. current_price = round(total * payment_line[1], decimal_precision)
  360. if current_price < 0.0:
  361. continue
  362. paid_amount = paid_amount + current_price
  363. price = current_price if payment_line[1] else round(total - paid_amount, decimal_precision) or total
  364. if is_purchase:
  365. price = price * -1
  366. invoice_move_lines.append({
  367. 'type': 'dest',
  368. 'name': '/',
  369. 'price': price,
  370. 'account_id': invoice.account_id.id,
  371. 'date_maturity': payment_line[0],
  372. 'amount_currency': invoice.company_id.currency_id.compute(payment_line[1], invoice.currency_id) if invoice.currency_id != invoice.company_id.currency_id else False,
  373. 'currency_id': invoice.currency_id != invoice.company_id.currency_id and invoice.currency_id.id,
  374. 'ref': invoice.type in ('in_invoice', 'in_refund') and invoice.reference or invoice.number
  375. })
  376. payment_lines = []
  377. return invoice_move_lines
  378. '''
  379. Create account move
  380. '''
  381. def create_account_move(self, invoice_ids, invoice_move_lines):
  382. assert len(invoice_ids) == 1
  383. invoice = request.env['account.invoice'].browse(invoice_ids)
  384. accounting_partner = request.env['res.partner']._find_accounting_partner(invoice.partner_id)
  385. move_line_values = [(0, 0, invoice.line_get_convert(line, accounting_partner.id, invoice.date_invoice)) for line in invoice_move_lines]
  386. move_line_values = invoice.group_lines(invoice_move_lines, move_line_values)
  387. move_line_values = invoice.finalize_invoice_move_lines(move_line_values)
  388. ctx = dict(request.context, lang=invoice.partner_id.lang, company_id=invoice.company_id.id)
  389. period = invoice.period_id
  390. if not period:
  391. period = period.with_context(ctx).find(invoice.date_invoice)[:1]
  392. if period:
  393. for line in move_line_values:
  394. line[2]['period_id'] = period.id
  395. ctx['invoice'] = invoice
  396. ctx_nolang = ctx.copy()
  397. ctx_nolang.pop('lang', None)
  398. account_move = request.env['account.move'].with_context(ctx_nolang).create({
  399. 'ref': invoice.reference or invoice.name,
  400. 'line_id': move_line_values,
  401. 'journal_id': invoice.journal_id.with_context(request.context, lang=invoice.partner_id.lang).id,
  402. 'date': invoice.date_invoice,
  403. 'narration': invoice.comment,
  404. 'company_id': invoice.company_id.id,
  405. 'period_id': period.id
  406. })
  407. invoice.with_context(ctx).write({
  408. 'move_id': account_move.id,
  409. 'period_id': account_move.period_id.id,
  410. 'move_name': account_move.name,
  411. })
  412. account_move.post()
  413. return account_move
  414. '''
  415. Number to invoice
  416. '''
  417. def validate_invoice(self, invoice_ids):
  418. assert len(invoice_ids) == 1
  419. invoice = request.env['account.invoice'].browse(invoice_ids)
  420. invoice.action_number()
  421. invoice.invoice_validate()
  422. '''
  423. Create voucher
  424. '''
  425. def create_account_voucher(self, account_move_id, journal_id, currency_id, paid_amount):
  426. account_move = request.env['account.move'].browse(account_move_id)
  427. account_journal = request.env['account.journal'].browse(journal_id)
  428. account_voucher = request.env['account.voucher'].create({
  429. 'reference': account_move.name,
  430. 'type': 'payment',
  431. 'journal_id': account_journal.id,
  432. 'company_id': account_move.company_id.id,
  433. 'pre_line': True,
  434. 'amount': paid_amount,
  435. 'period_id': account_move.period_id.id,
  436. 'date': account_move.date,
  437. 'partner_id': account_move.partner_id.id,
  438. 'account_id': account_journal.default_debit_account_id.id,
  439. 'currency_id': currency_id,
  440. 'line_dr_ids': [[0, False, {
  441. 'date_due': l.date_maturity,
  442. 'account_id': l.account_id.id,
  443. 'date_original': l.invoice.date_invoice,
  444. 'move_line_id': l.id,
  445. 'amount_original': abs(l.credit or l.debit or 0.0),
  446. 'amount_unreconciled': abs(l.amount_residual),
  447. 'amount': abs(l.credit) if account_move.date == l.date_maturity else 0.0,
  448. 'reconcile': account_move.date == l.date_maturity,
  449. 'currency_id': currency_id
  450. }] for l in account_move.line_id]
  451. })
  452. account_voucher.action_move_line_create()
  453. return account_voucher
  454. '''
  455. Close a invoice
  456. '''
  457. def close_invoice(self, invoice_ids):
  458. assert len(invoice_ids) == 1
  459. invoice = request.env['account.invoice'].browse(invoice_ids)
  460. if invoice.residual == 0:
  461. invoice.write({
  462. 'state': 'paid'
  463. })
  464. '''
  465. Create account bank statement
  466. '''
  467. def create_bank_statement(self, account_voucher_id, account_bank_statement_lines, date_today):
  468. account_voucher = request.env['account.voucher'].browse(account_voucher_id)
  469. account_bank_statement = request.env['account.bank.statement'].search([('journal_id', '=', account_voucher.journal_id.id), ('date', '=', date_today)])
  470. account_bank_statement_values = {
  471. 'date': date_today,
  472. 'user_id': request.env.user.id,
  473. 'journal_id': account_voucher.journal_id.id,
  474. 'period_id': account_voucher.period_id.id,
  475. 'line_ids': account_bank_statement_lines,
  476. 'state': 'open' if account_voucher.journal_id.type == 'cash' else 'draft'
  477. }
  478. if account_bank_statement:
  479. size = len(account_bank_statement)
  480. if size == 1:
  481. account_bank_statement.write(account_bank_statement_values)
  482. else:
  483. account_bank_statement[size - 1].write(account_bank_statement_values)
  484. else:
  485. account_bank_statement.create(account_bank_statement_values)
  486. return account_bank_statement
  487. '''
  488. Create account bank statement lines
  489. '''
  490. def create_bank_statement_lines(self, account_voucher_id, reference=None):
  491. account_voucher = request.env['account.voucher'].browse(account_voucher_id)
  492. amount = account_voucher.amount
  493. if account_voucher.type == 'payment':
  494. amount = amount * -1
  495. return [[0, False, {
  496. 'name': account_voucher.reference,
  497. 'amount': amount,
  498. 'partner_id': account_voucher.partner_id.id,
  499. 'voucher_id': account_voucher.id,
  500. 'journal_id': account_voucher.journal_id.id,
  501. 'account_id': account_voucher.account_id.id,
  502. 'journal_entry_id': account_voucher.move_id.id,
  503. 'currency_id': account_voucher.currency_id.id,
  504. 'ref': 'POS/' + (reference or '')
  505. }]]
  506. '''
  507. Purchase processing resource route
  508. '''
  509. @http.route('/eiru_purchases/process', type='json', auth='user', methods=['POST'], cors='*')
  510. def process_purchase(self, **kw):
  511. self.make_info_log('Processing purchase...')
  512. # Get date
  513. date_now = datetime.now().strftime(DATE_FORMAT)
  514. self.make_info_log('Getting date')
  515. # Get currency
  516. currency_id = self.get_currency_id(kw.get('journalId'))
  517. self.make_info_log('Getting currency')
  518. # Get pricelist
  519. pricelist_id = self.get_pricelist_id(currency_id)
  520. self.make_info_log('Product pricelist checked')
  521. # Create purchase order
  522. purchase_order = self.create_purchase_order(kw.get('supplierId'), kw.get('items'), date_now, currency_id, pricelist_id, kw.get('paymentTermId'))
  523. self.make_info_log('Purchase order created')
  524. # Confirm purchase
  525. self.confirm_purchase_order(purchase_order.id)
  526. self.make_info_log('Purchase order confirmed')
  527. # Validate invoice
  528. invoice_ids = purchase_order.invoice_ids.mapped(lambda x: x.id)
  529. self.prepare_invoice(invoice_ids, currency_id, date_now)
  530. self.make_info_log('Invoice prepared')
  531. # Create invoice move lines
  532. invoice_move_lines = self.create_invoice_move_lines(invoice_ids, float(kw.get('payment')), date_now)
  533. self.make_info_log('Invoice move lines created')
  534. # Create account move
  535. account_move = self.create_account_move(invoice_ids, invoice_move_lines)
  536. self.make_info_log('Account move created')
  537. # Validate invoice
  538. self.validate_invoice(invoice_ids)
  539. self.make_info_log('Invoice validated')
  540. # Create account voucher
  541. account_voucher = self.create_account_voucher(account_move.id, kw.get('journalId'), currency_id, float(kw.get('payment')))
  542. self.make_info_log('Account voucher created')
  543. # Close invoice
  544. self.close_invoice(invoice_ids)
  545. self.make_info_log('Attempt close invoice')
  546. # Create account bank statement lines
  547. account_bank_statement_lines = self.create_bank_statement_lines(account_voucher.id)
  548. self.make_info_log('Bank statement lines created')
  549. # Create account bank statement
  550. self.create_bank_statement(account_voucher.id, account_bank_statement_lines, date_now)
  551. self.make_info_log('Bank statement created')
  552. return {
  553. 'status': 'ok'
  554. }