main.py 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711
  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, type=None):
  447. assert len(invoice_ids) == 1
  448. invoice = request.env['account.invoice'].browse(invoice_ids)
  449. invoice.action_number()
  450. invoice.invoice_validate()
  451. if type != 'purchase':
  452. name = 'GASTO' + invoice.name[invoice.name.index('/'):]
  453. invoice.write({
  454. 'number': name,
  455. 'internal_number': name
  456. })
  457. '''
  458. Create voucher
  459. '''
  460. def create_account_voucher(self, account_move_id, journal_id, currency_id, paid_amount):
  461. account_move = request.env['account.move'].browse(account_move_id)
  462. account_journal = request.env['account.journal'].browse(journal_id)
  463. account_voucher = request.env['account.voucher'].create({
  464. 'reference': account_move.name,
  465. 'type': 'payment',
  466. 'journal_id': account_journal.id,
  467. 'company_id': account_move.company_id.id,
  468. 'pre_line': True,
  469. 'amount': paid_amount,
  470. 'period_id': account_move.period_id.id,
  471. 'date': account_move.date,
  472. 'partner_id': account_move.partner_id.id,
  473. 'account_id': account_journal.default_debit_account_id.id,
  474. 'currency_id': currency_id,
  475. 'line_dr_ids': [[0, False, {
  476. 'date_due': l.date_maturity,
  477. 'account_id': l.account_id.id,
  478. 'date_original': l.invoice.date_invoice,
  479. 'move_line_id': l.id,
  480. 'amount_original': abs(l.credit or l.debit or 0.0),
  481. 'amount_unreconciled': abs(l.amount_residual),
  482. 'amount': abs(l.credit) if account_move.date == l.date_maturity else 0.0,
  483. 'reconcile': account_move.date == l.date_maturity,
  484. 'currency_id': currency_id
  485. }] for l in account_move.line_id]
  486. })
  487. account_voucher.action_move_line_create()
  488. return account_voucher
  489. '''
  490. Close a invoice
  491. '''
  492. def close_invoice(self, invoice_ids):
  493. assert len(invoice_ids) == 1
  494. invoice = request.env['account.invoice'].browse(invoice_ids)
  495. if invoice.residual == 0:
  496. invoice.write({
  497. 'state': 'paid'
  498. })
  499. '''
  500. Create account bank statement
  501. '''
  502. def create_bank_statement(self, account_voucher_id, account_bank_statement_lines, date_today):
  503. account_voucher = request.env['account.voucher'].browse(account_voucher_id)
  504. account_bank_statement = request.env['account.bank.statement'].search([('journal_id', '=', account_voucher.journal_id.id), ('date', '=', date_today)])
  505. account_bank_statement_values = {
  506. 'date': date_today,
  507. 'user_id': request.env.user.id,
  508. 'journal_id': account_voucher.journal_id.id,
  509. 'period_id': account_voucher.period_id.id,
  510. 'line_ids': account_bank_statement_lines,
  511. 'state': 'open' if account_voucher.journal_id.type == 'cash' else 'draft'
  512. }
  513. if account_bank_statement:
  514. size = len(account_bank_statement)
  515. if size == 1:
  516. account_bank_statement.write(account_bank_statement_values)
  517. else:
  518. account_bank_statement[size - 1].write(account_bank_statement_values)
  519. else:
  520. account_bank_statement.create(account_bank_statement_values)
  521. return account_bank_statement
  522. '''
  523. Create account bank statement lines
  524. '''
  525. def create_bank_statement_lines(self, account_voucher_id, reference=None):
  526. account_voucher = request.env['account.voucher'].browse(account_voucher_id)
  527. amount = account_voucher.amount
  528. if account_voucher.type == 'payment':
  529. amount = amount * -1
  530. return [[0, False, {
  531. 'name': account_voucher.reference,
  532. 'amount': amount,
  533. 'partner_id': account_voucher.partner_id.id,
  534. 'voucher_id': account_voucher.id,
  535. 'journal_id': account_voucher.journal_id.id,
  536. 'account_id': account_voucher.account_id.id,
  537. 'journal_entry_id': account_voucher.move_id.id,
  538. 'currency_id': account_voucher.currency_id.id,
  539. 'ref': 'POS/' + (reference or '')
  540. }]]
  541. '''
  542. Purchase processing resource route
  543. '''
  544. @http.route('/eiru_purchases/process', type='json', auth='user', methods=['POST'], cors='*')
  545. def process_purchase(self, **kw):
  546. mode = kw.get('mode')
  547. self.make_info_log('Processing {}'.format(mode))
  548. # Get date
  549. date_now = datetime.now().strftime(DATE_FORMAT)
  550. self.make_info_log('Getting date')
  551. # Get currency
  552. currency_id = self.get_currency_id(kw.get('journalId'))
  553. self.make_info_log('Getting currency')
  554. # Get pricelist
  555. pricelist_id = self.get_pricelist_id(currency_id)
  556. self.make_info_log('Product pricelist checked')
  557. invoice = None
  558. if mode == 'purchase':
  559. # Create purchase order
  560. purchase_order = self.create_purchase_order(kw.get('supplierId'), kw.get('items'), date_now, currency_id, pricelist_id, kw.get('paymentTermId'))
  561. self.make_info_log('Purchase order created')
  562. # Confirm purchase
  563. self.confirm_purchase_order(purchase_order.id)
  564. self.make_info_log('Purchase order confirmed')
  565. invoice = purchase_order.invoice_ids
  566. else:
  567. invoice = self.create_invoice(kw.get('supplierId'), kw.get('items'), currency_id, kw.get('paymentTermId'))
  568. self.make_info_log('Invoice created')
  569. invoice_ids = invoice.mapped(lambda x: x.id)
  570. # Validate invoice
  571. self.prepare_invoice(invoice_ids, currency_id, date_now)
  572. self.make_info_log('Invoice prepared')
  573. # Create invoice move lines
  574. invoice_move_lines = self.create_invoice_move_lines(invoice_ids, float(kw.get('payment')), date_now)
  575. self.make_info_log('Invoice move lines created')
  576. # Create account move
  577. account_move = self.create_account_move(invoice_ids, invoice_move_lines)
  578. self.make_info_log('Account move created')
  579. # Validate invoice
  580. self.validate_invoice(invoice_ids, mode)
  581. self.make_info_log('Invoice validated')
  582. # Create account voucher
  583. account_voucher = self.create_account_voucher(account_move.id, kw.get('journalId'), currency_id, float(kw.get('payment')))
  584. self.make_info_log('Account voucher created')
  585. # Close invoice
  586. self.close_invoice(invoice_ids)
  587. self.make_info_log('Attempt close invoice')
  588. # Create account bank statement lines
  589. account_bank_statement_lines = self.create_bank_statement_lines(account_voucher.id)
  590. self.make_info_log('Bank statement lines created')
  591. # Create account bank statement
  592. self.create_bank_statement(account_voucher.id, account_bank_statement_lines, date_now)
  593. self.make_info_log('Bank statement created')
  594. return {
  595. 'status': 'ok'
  596. }