main.py 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703
  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, type=None):
  119. product_obj = request.env['product.template']
  120. domain = [('standard_price', '>=', 0), ('active', '=', True)]
  121. if type == 'purchase':
  122. domain.append(('purchase_ok', '=', True))
  123. else:
  124. if product_obj.fields_get('hr_expense_ok'):
  125. domain.append(('hr_expense_ok', '=', True))
  126. else:
  127. return []
  128. return [{
  129. 'id': product.id,
  130. 'name': product.name,
  131. 'displayName': product.display_name,
  132. 'ean13': product.ean13,
  133. 'imageMedium': product.image_medium,
  134. 'standardPrice': product.standard_price,
  135. 'variantCount': product.product_variant_count,
  136. 'quantity': 1,
  137. 'price': product.standard_price,
  138. 'variants': [{
  139. 'id': variant.id,
  140. 'name': variant.name,
  141. 'displayName': variant.display_name,
  142. 'ean13': variant.ean13,
  143. 'imageMedium': variant.image_medium,
  144. 'standardPrice': variant.standard_price,
  145. 'quantity': 1,
  146. 'price': variant.standard_price
  147. } for variant in product.product_variant_ids if variant.active]
  148. } for product in product_obj.search(domain)]
  149. '''
  150. Get all incoming and active picking types
  151. '''
  152. def get_picking_types(self):
  153. return [{
  154. 'id': picking_type.id,
  155. 'name': picking_type.name,
  156. 'displayName': picking_type.display_name
  157. } for picking_type in request.env['stock.picking.type'].search([('code', '=', 'incoming'), ('active', '=', True)])]
  158. '''
  159. Get all active payment terms
  160. '''
  161. def get_payment_terms(self):
  162. return [{
  163. 'id': payment_term.id,
  164. 'name': payment_term.name,
  165. 'displayName': payment_term.display_name,
  166. 'lines': [{
  167. 'id': line.id,
  168. 'days': line.days,
  169. 'days2': line.days2,
  170. 'value': line.value,
  171. 'valueAmount': line.value_amount
  172. } for line in payment_term.line_ids]
  173. } for payment_term in request.env['account.payment.term'].search([('active', '=', True)])]
  174. '''
  175. Make JSON response to send
  176. '''
  177. def make_response(self, data=None, status=200):
  178. return Response(json.dumps(data), status=status, content_type='application/json')
  179. '''
  180. Make GZIP to JSON response
  181. '''
  182. def make_gzip_response(self, data=None, status=200):
  183. gzip_buffer = IO()
  184. with GzipFile(mode='wb', compresslevel=GZIP_COMPRESSION_LEVEL, fileobj=gzip_buffer) as gzip_file:
  185. gzip_file.write(json.dumps(data))
  186. contents = gzip_buffer.getvalue()
  187. gzip_buffer.close()
  188. headers = Headers()
  189. headers.add('Content-Encoding', 'gzip')
  190. headers.add('Vary', 'Accept-Encoding')
  191. headers.add('Content-Length', len(contents))
  192. return Response(contents, status=status, headers=headers, content_type='application/json')
  193. '''
  194. '''
  195. def make_info_log(self, log):
  196. LOGGER.info('\033[1;34m[INFO] --> \033[m{}'.format(log))
  197. '''
  198. New purchase resource route
  199. '''
  200. @http.route('/eiru_purchases/init', auth='user', methods=['GET'], cors='*')
  201. def init_purchase(self, **kw):
  202. self.make_info_log('Preparing data to {}'.format(kw.get('mode')))
  203. return self.make_gzip_response({
  204. 'date': self.get_server_date(),
  205. 'user': self.get_user(),
  206. 'currencies': self.get_currencies(),
  207. 'journals': self.get_journals(),
  208. 'suppliers': self.get_suppliers(),
  209. 'products': self.get_products(kw.get('mode')),
  210. 'pickingTypes': self.get_picking_types(),
  211. 'paymentTerms': self.get_payment_terms()
  212. })
  213. '''
  214. Create supplier and return data
  215. '''
  216. @http.route('/eiru_purchases/create_supplier', type='json', auth='user', methods=['POST'], cors='*')
  217. def create_supplier(self, **kw):
  218. self.make_info_log('Creating supplier')
  219. supplier = request.env['res.partner'].create({
  220. 'name': kw.get('name'),
  221. 'ruc': kw.get('ruc'),
  222. 'phone': kw.get('phone'),
  223. 'supplier': True,
  224. 'customer': False
  225. })
  226. return {
  227. 'id': supplier.id,
  228. 'name': supplier.name,
  229. 'displayName': supplier.display_name,
  230. 'imageMedium': supplier.image_medium,
  231. 'phone': supplier.phone,
  232. 'mobile': supplier.mobile,
  233. 'email': supplier.email
  234. }
  235. '''
  236. Create product and return data
  237. '''
  238. @http.route('/eiru_purchases/create_product', type='json', auth='user', methods=['POST'], cors='*')
  239. def create_product(self, **kw):
  240. self.make_info_log('Creating product')
  241. product = request.env['product.template'].create({
  242. 'name': kw.get('name'),
  243. 'standard_price': float(kw.get('price')),
  244. 'ean13': kw.get('ean13')
  245. })
  246. return {
  247. 'id': product.id,
  248. 'name': product.name,
  249. 'displayName': product.display_name,
  250. 'ean13': product.ean13,
  251. 'imageMedium': product.image_medium,
  252. 'listPrice': product.list_price,
  253. 'variantCount': product.product_variant_count,
  254. 'variants': [{
  255. 'id': variant.id,
  256. 'name': variant.name,
  257. 'displayName': variant.display_name,
  258. 'ean13': variant.ean13,
  259. 'imageMedium': variant.image_medium,
  260. 'standardPrice': variant.standard_price
  261. } for variant in product.product_variant_ids if variant.active]
  262. }
  263. '''
  264. Get currency id based on journal
  265. '''
  266. def get_currency_id(self, journal_id):
  267. journal = request.env['account.journal'].browse(journal_id)
  268. return journal.default_debit_account_id.currency_id.id or journal.default_debit_account_id.company_currency_id.id
  269. '''
  270. Check currency in pricelist and return it
  271. '''
  272. def get_pricelist_id(self, currency_id):
  273. pricelist = request.env['product.pricelist'].search([('active', '=', True), ('type', '=', 'sale')])
  274. if not True in pricelist.mapped(lambda p: p.currency_id.id == currency_id):
  275. pricelist = pricelist[0].copy()
  276. pricelist.write({
  277. 'currency_id': currency_id
  278. })
  279. else:
  280. pricelist = pricelist.filtered(lambda p: p.currency_id.id == currency_id)
  281. return pricelist.id
  282. '''
  283. Get default location
  284. '''
  285. def get_stock_location_id(self):
  286. stock_location = request.env['stock.location'].search([('usage', '=', 'internal')])
  287. return stock_location.id
  288. '''
  289. Create purchase order from cart and return id
  290. '''
  291. def create_purchase_order(self, supplier_id, cart_items, date_order, currency_id, pricelist_id, payment_term_id=None):
  292. return request.env['purchase.order'].create({
  293. 'name': '/',
  294. 'partner_id': supplier_id,
  295. 'order_line': [[0, False, {
  296. 'name': line.get('name'),
  297. 'date_planned': date_order,
  298. 'product_id': int(line.get('id')),
  299. 'product_qty': float(line.get('quantity')),
  300. 'price_unit': float(line.get('price'))
  301. }] for line in cart_items],
  302. 'date_order': datetime.now().strftime(DATETIME_FORMAT),
  303. 'currency_id': currency_id,
  304. 'pricelist_id': pricelist_id,
  305. 'payment_term_id': payment_term_id,
  306. 'location_id': self.get_stock_location_id(),
  307. 'invoice_method': 'order'
  308. })
  309. '''
  310. Confirm purchase order
  311. '''
  312. def confirm_purchase_order(self, purchase_order_id):
  313. purchase_order = request.env['purchase.order'].browse(purchase_order_id)
  314. purchase_order.action_purchase_confirm()
  315. for picking in purchase_order.picking_ids:
  316. picking.force_assign()
  317. picking.action_done()
  318. purchase_order.write({
  319. 'state': 'done'
  320. })
  321. '''
  322. Create invoice
  323. '''
  324. def create_invoice(self, supplier_id, cart_items, currency_id, payment_term_id=None):
  325. partner = request.env['res.partner'].browse(supplier_id)
  326. journal = request.env['account.journal'].search([('type', 'in', ['purchase']), ('company_id', '=', partner.company_id.id)])
  327. return request.env['account.invoice'].create({
  328. 'name': '/',
  329. 'partner_id': partner.id,
  330. 'invoice_line': [[0, False, {
  331. 'name': line.get('name'),
  332. 'product_id': int(line.get('id')),
  333. 'quantity': float(line.get('quantity')),
  334. 'price_unit': float(line.get('price'))
  335. }] for line in cart_items],
  336. 'account_id': journal.id,
  337. 'currency_id': currency_id,
  338. 'payment_term': payment_term_id,
  339. 'type': 'in_invoice'
  340. })
  341. '''
  342. Validate invoice
  343. '''
  344. def prepare_invoice(self, invoice_ids, currency_id, date_today):
  345. assert len(invoice_ids) == 1
  346. invoice = request.env['account.invoice'].browse(invoice_ids)
  347. date_due = parse(date_today) + rd(days=max(invoice.payment_term.line_ids.mapped(lambda x: x.days + x.days2)))
  348. invoice.write({
  349. 'currency_id': currency_id,
  350. 'date_invoice': date_today,
  351. 'date_due': date_due.strftime(DATE_FORMAT),
  352. 'state': 'open'
  353. })
  354. '''
  355. Create move lines
  356. '''
  357. def create_invoice_move_lines(self, invoice_ids, paid_amount, date_today):
  358. assert len(invoice_ids) == 1
  359. invoice = request.env['account.invoice'].browse(invoice_ids)
  360. is_purchase = False
  361. scoped_context = dict(request.context, lang=invoice.partner_id.lang)
  362. invoice_move_lines = invoice._get_analytic_lines()
  363. decimal_precision = request.env['decimal.precision'].precision_get('Account')
  364. compute_taxes = request.env['account.invoice.tax'].compute(invoice.with_context(lang=invoice.partner_id.lang))
  365. invoice.check_tax_lines(compute_taxes)
  366. invoice._recompute_tax_amount()
  367. invoice_move_lines += request.env['account.invoice.tax'].move_line_get(invoice.id)
  368. total, total_currency, invoice_move_lines = invoice.with_context(scoped_context).compute_invoice_totals(invoice.company_id.currency_id, invoice.reference, invoice_move_lines)
  369. if total < 0:
  370. total = total * -1
  371. is_purchase = True
  372. paid_percentage = abs(paid_amount / round(total, decimal_precision))
  373. distributed_percentage = -(paid_percentage / len(invoice.payment_term.line_ids))
  374. payment_lines = []
  375. for line in invoice.payment_term.line_ids:
  376. date_due = (parse(date_today) + rd(days=line.days + line.days2)).strftime(DATE_FORMAT)
  377. if paid_percentage and paid_percentage < 1.0:
  378. payment_lines.append([date_today, paid_percentage])
  379. paid_percentage = paid_amount = 0
  380. if date_due == date_today and line.value_amount:
  381. distributed_percentage = -((payment_lines[0][1] - line.value_amount) / (len(invoice.payment_term.line_ids) - 1))
  382. continue
  383. if line.value != 'balance':
  384. payment_lines.append([date_due, line.value_amount + distributed_percentage])
  385. continue
  386. payment_lines.append([date_due, line.value_amount])
  387. for payment_line in payment_lines:
  388. current_price = round(total * payment_line[1], decimal_precision)
  389. if current_price < 0.0:
  390. continue
  391. paid_amount = paid_amount + current_price
  392. price = current_price if payment_line[1] else round(total - paid_amount, decimal_precision) or total
  393. if is_purchase:
  394. price = price * -1
  395. invoice_move_lines.append({
  396. 'type': 'dest',
  397. 'name': '/',
  398. 'price': price,
  399. 'account_id': invoice.account_id.id,
  400. 'date_maturity': payment_line[0],
  401. '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,
  402. 'currency_id': invoice.currency_id != invoice.company_id.currency_id and invoice.currency_id.id,
  403. 'ref': invoice.type in ('in_invoice', 'in_refund') and invoice.reference or invoice.number
  404. })
  405. payment_lines = []
  406. return invoice_move_lines
  407. '''
  408. Create account move
  409. '''
  410. def create_account_move(self, invoice_ids, invoice_move_lines):
  411. assert len(invoice_ids) == 1
  412. invoice = request.env['account.invoice'].browse(invoice_ids)
  413. accounting_partner = request.env['res.partner']._find_accounting_partner(invoice.partner_id)
  414. move_line_values = [(0, 0, invoice.line_get_convert(line, accounting_partner.id, invoice.date_invoice)) for line in invoice_move_lines]
  415. move_line_values = invoice.group_lines(invoice_move_lines, move_line_values)
  416. move_line_values = invoice.finalize_invoice_move_lines(move_line_values)
  417. ctx = dict(request.context, lang=invoice.partner_id.lang, company_id=invoice.company_id.id)
  418. period = invoice.period_id
  419. if not period:
  420. period = period.with_context(ctx).find(invoice.date_invoice)[:1]
  421. if period:
  422. for line in move_line_values:
  423. line[2]['period_id'] = period.id
  424. ctx['invoice'] = invoice
  425. ctx_nolang = ctx.copy()
  426. ctx_nolang.pop('lang', None)
  427. account_move = request.env['account.move'].with_context(ctx_nolang).create({
  428. 'ref': invoice.reference or invoice.name,
  429. 'line_id': move_line_values,
  430. 'journal_id': invoice.journal_id.with_context(request.context, lang=invoice.partner_id.lang).id,
  431. 'date': invoice.date_invoice,
  432. 'narration': invoice.comment,
  433. 'company_id': invoice.company_id.id,
  434. 'period_id': period.id
  435. })
  436. invoice.with_context(ctx).write({
  437. 'move_id': account_move.id,
  438. 'period_id': account_move.period_id.id,
  439. 'move_name': account_move.name,
  440. })
  441. account_move.post()
  442. return account_move
  443. '''
  444. Number to invoice
  445. '''
  446. def validate_invoice(self, invoice_ids):
  447. assert len(invoice_ids) == 1
  448. invoice = request.env['account.invoice'].browse(invoice_ids)
  449. invoice.action_number()
  450. invoice.invoice_validate()
  451. '''
  452. Create voucher
  453. '''
  454. def create_account_voucher(self, account_move_id, journal_id, currency_id, paid_amount):
  455. account_move = request.env['account.move'].browse(account_move_id)
  456. account_journal = request.env['account.journal'].browse(journal_id)
  457. account_voucher = request.env['account.voucher'].create({
  458. 'reference': account_move.name,
  459. 'type': 'payment',
  460. 'journal_id': account_journal.id,
  461. 'company_id': account_move.company_id.id,
  462. 'pre_line': True,
  463. 'amount': paid_amount,
  464. 'period_id': account_move.period_id.id,
  465. 'date': account_move.date,
  466. 'partner_id': account_move.partner_id.id,
  467. 'account_id': account_journal.default_debit_account_id.id,
  468. 'currency_id': currency_id,
  469. 'line_dr_ids': [[0, False, {
  470. 'date_due': l.date_maturity,
  471. 'account_id': l.account_id.id,
  472. 'date_original': l.invoice.date_invoice,
  473. 'move_line_id': l.id,
  474. 'amount_original': abs(l.credit or l.debit or 0.0),
  475. 'amount_unreconciled': abs(l.amount_residual),
  476. 'amount': abs(l.credit) if account_move.date == l.date_maturity else 0.0,
  477. 'reconcile': account_move.date == l.date_maturity,
  478. 'currency_id': currency_id
  479. }] for l in account_move.line_id]
  480. })
  481. account_voucher.action_move_line_create()
  482. return account_voucher
  483. '''
  484. Close a invoice
  485. '''
  486. def close_invoice(self, invoice_ids):
  487. assert len(invoice_ids) == 1
  488. invoice = request.env['account.invoice'].browse(invoice_ids)
  489. if invoice.residual == 0:
  490. invoice.write({
  491. 'state': 'paid'
  492. })
  493. '''
  494. Create account bank statement
  495. '''
  496. def create_bank_statement(self, account_voucher_id, account_bank_statement_lines, date_today):
  497. account_voucher = request.env['account.voucher'].browse(account_voucher_id)
  498. account_bank_statement = request.env['account.bank.statement'].search([('journal_id', '=', account_voucher.journal_id.id), ('date', '=', date_today)])
  499. account_bank_statement_values = {
  500. 'date': date_today,
  501. 'user_id': request.env.user.id,
  502. 'journal_id': account_voucher.journal_id.id,
  503. 'period_id': account_voucher.period_id.id,
  504. 'line_ids': account_bank_statement_lines,
  505. 'state': 'open' if account_voucher.journal_id.type == 'cash' else 'draft'
  506. }
  507. if account_bank_statement:
  508. size = len(account_bank_statement)
  509. if size == 1:
  510. account_bank_statement.write(account_bank_statement_values)
  511. else:
  512. account_bank_statement[size - 1].write(account_bank_statement_values)
  513. else:
  514. account_bank_statement.create(account_bank_statement_values)
  515. return account_bank_statement
  516. '''
  517. Create account bank statement lines
  518. '''
  519. def create_bank_statement_lines(self, account_voucher_id, reference=None):
  520. account_voucher = request.env['account.voucher'].browse(account_voucher_id)
  521. amount = account_voucher.amount
  522. if account_voucher.type == 'payment':
  523. amount = amount * -1
  524. return [[0, False, {
  525. 'name': account_voucher.reference,
  526. 'amount': amount,
  527. 'partner_id': account_voucher.partner_id.id,
  528. 'voucher_id': account_voucher.id,
  529. 'journal_id': account_voucher.journal_id.id,
  530. 'account_id': account_voucher.account_id.id,
  531. 'journal_entry_id': account_voucher.move_id.id,
  532. 'currency_id': account_voucher.currency_id.id,
  533. 'ref': 'POS/' + (reference or '')
  534. }]]
  535. '''
  536. Purchase processing resource route
  537. '''
  538. @http.route('/eiru_purchases/process', type='json', auth='user', methods=['POST'], cors='*')
  539. def process_purchase(self, **kw):
  540. self.make_info_log('Processing purchase...')
  541. # Get date
  542. date_now = datetime.now().strftime(DATE_FORMAT)
  543. self.make_info_log('Getting date')
  544. # Get currency
  545. currency_id = self.get_currency_id(kw.get('journalId'))
  546. self.make_info_log('Getting currency')
  547. # Get pricelist
  548. pricelist_id = self.get_pricelist_id(currency_id)
  549. self.make_info_log('Product pricelist checked')
  550. invoice = None
  551. if kw.get('mode') == 'purchase':
  552. # Create purchase order
  553. purchase_order = self.create_purchase_order(kw.get('supplierId'), kw.get('items'), date_now, currency_id, pricelist_id, kw.get('paymentTermId'))
  554. self.make_info_log('Purchase order created')
  555. # Confirm purchase
  556. self.confirm_purchase_order(purchase_order.id)
  557. self.make_info_log('Purchase order confirmed')
  558. invoice = purchase_order.invoice_ids
  559. else:
  560. invoice = self.create_invoice(kw.get('supplierId'), kw.get('items'), currency_id, kw.get('paymentTermId'))
  561. self.make_info_log('Invoice created')
  562. invoice_ids = invoice.mapped(lambda x: x.id)
  563. # Validate invoice
  564. self.prepare_invoice(invoice_ids, currency_id, date_now)
  565. self.make_info_log('Invoice prepared')
  566. # Create invoice move lines
  567. invoice_move_lines = self.create_invoice_move_lines(invoice_ids, float(kw.get('payment')), date_now)
  568. self.make_info_log('Invoice move lines created')
  569. # Create account move
  570. account_move = self.create_account_move(invoice_ids, invoice_move_lines)
  571. self.make_info_log('Account move created')
  572. # Validate invoice
  573. self.validate_invoice(invoice_ids)
  574. self.make_info_log('Invoice validated')
  575. # Create account voucher
  576. account_voucher = self.create_account_voucher(account_move.id, kw.get('journalId'), currency_id, float(kw.get('payment')))
  577. self.make_info_log('Account voucher created')
  578. # Close invoice
  579. self.close_invoice(invoice_ids)
  580. self.make_info_log('Attempt close invoice')
  581. # Create account bank statement lines
  582. account_bank_statement_lines = self.create_bank_statement_lines(account_voucher.id)
  583. self.make_info_log('Bank statement lines created')
  584. # Create account bank statement
  585. self.create_bank_statement(account_voucher.id, account_bank_statement_lines, date_now)
  586. self.make_info_log('Bank statement created')
  587. return {
  588. 'status': 'ok'
  589. }