main.py 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623
  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. GZIP_COMPRESSION_LEVEL = 9
  17. '''
  18. ___ ___ __ __ __ ___ __ __ ___ __ ___ __ __ __ __ __
  19. |__| | | |__) / ` / \ |\ | | |__) / \ | | |__ |__) |__ / \ |__) |__) / \ /__`
  20. | | | | | \__, \__/ | \| | | \ \__/ |___ |___ |___ | \ | \__/ | \ | \__/ .__/
  21. # Resource paths
  22. - /init: return json response gzip compressed contains values for sale operation
  23. - /create_product: create product on the fly POS and return it
  24. - /create_customer: create customer on the fly and return it
  25. - /process_sale: processing sale and return true if completed
  26. '''
  27. class PosSales(http.Controller):
  28. '''
  29. Get server date
  30. '''
  31. def get_server_date(self):
  32. return datetime.now().strftime(DATE_FORMAT)
  33. '''
  34. Get current user information
  35. '''
  36. def get_user(self):
  37. user = request.env.user
  38. return {
  39. 'id': user.id,
  40. 'name': user.name,
  41. 'displayName': user.display_name,
  42. 'currency': {
  43. 'id': user.company_id.currency_id.id,
  44. 'name': user.company_id.currency_id.name,
  45. 'displayName': user.company_id.currency_id.display_name,
  46. 'symbol': user.company_id.currency_id.symbol
  47. },
  48. 'company': {
  49. 'id': user.company_id.id,
  50. 'name': user.company_id.name,
  51. 'displayName': user.company_id.display_name
  52. }
  53. }
  54. '''
  55. Get currencies
  56. '''
  57. def get_currencies(self):
  58. return [{
  59. 'id': currency.id,
  60. 'name': currency.name,
  61. 'displayName': currency.display_name,
  62. 'base': currency.base,
  63. 'accuracy': currency.accuracy,
  64. 'rateSilent': currency.rate_silent,
  65. 'rounding': currency.rounding,
  66. 'symbol': currency.symbol,
  67. 'position': currency.position,
  68. 'decimalSeparator': currency.decimal_separator,
  69. 'decimalPlaces': currency.decimal_places,
  70. 'thousandsSeparator': currency.thousands_separator
  71. } for currency in request.env['res.currency'].search([('active', '=', True)])]
  72. '''
  73. Get all active journals
  74. '''
  75. def get_journals(self):
  76. return [{
  77. 'id': journal.id,
  78. 'name': journal.name,
  79. 'displayName': journal.display_name,
  80. 'code': journal.code,
  81. 'cashControl': journal.cash_control,
  82. 'type': journal.type,
  83. 'currency': {
  84. 'id': journal.currency.id,
  85. 'name': journal.currency.name,
  86. 'displayName': journal.currency.display_name
  87. },
  88. 'defaultCreditAccount': {
  89. 'id': journal.default_credit_account_id.id,
  90. 'name': journal.default_credit_account_id.name,
  91. 'displayName': journal.default_credit_account_id.display_name,
  92. 'code': journal.default_credit_account_id.code,
  93. 'exchangeRate': journal.default_credit_account_id.exchange_rate,
  94. 'foreignBalance': journal.default_credit_account_id.foreign_balance,
  95. 'reconcile': journal.default_credit_account_id.reconcile,
  96. 'debit': journal.default_credit_account_id.debit,
  97. 'credit': journal.default_credit_account_id.credit,
  98. 'currencyMode': journal.default_credit_account_id.currency_mode,
  99. 'companyCurrency': {
  100. 'id': journal.default_credit_account_id.company_currency_id.id,
  101. 'name': journal.default_credit_account_id.company_currency_id.name,
  102. 'displayName': journal.default_credit_account_id.company_currency_id.display_name,
  103. },
  104. 'currency': {
  105. 'id': journal.default_credit_account_id.currency_id.id,
  106. 'name': journal.default_credit_account_id.currency_id.name,
  107. 'displayName': journal.default_credit_account_id.currency_id.display_name
  108. },
  109. }
  110. } for journal in request.env['account.journal'].search([('type', 'in', ['bank', 'cash']), ('default_credit_account_id.currency_id', '=', False), ('active', '=', True)], order='id')]
  111. '''
  112. Get all active customers
  113. '''
  114. def get_customers(self):
  115. return [{
  116. 'id': customer.id,
  117. 'name': customer.name,
  118. 'displayName': customer.display_name,
  119. 'imageMedium': customer.image_medium,
  120. 'phone': customer.phone,
  121. 'mobile': customer.mobile,
  122. 'email': customer.email
  123. } for customer in request.env['res.partner'].search([('customer', '=', True), ('active', '=', True)])]
  124. '''
  125. Get all saleable and active products
  126. '''
  127. def get_products(self):
  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. 'listPrice': product.list_price,
  135. 'variantCount': product.product_variant_count,
  136. 'quantity': 1,
  137. 'price': product.list_price,
  138. 'discount': 0,
  139. 'variants': [{
  140. 'id': variant.id,
  141. 'name': variant.name,
  142. 'displayName': variant.display_name,
  143. 'ean13': variant.ean13,
  144. 'imageMedium': variant.image_medium,
  145. 'listPrice': variant.list_price,
  146. 'quantity': 1,
  147. 'price': variant.list_price,
  148. 'discount': 0,
  149. } for variant in product.product_variant_ids if variant.active]
  150. } for product in request.env['product.template'].search([('sale_ok', '=', True), ('list_price', '>', 0), ('active', '=', True)])]
  151. '''
  152. Get all active payment terms
  153. '''
  154. def get_payment_terms(self):
  155. return [{
  156. 'id': payment_term.id,
  157. 'name': payment_term.name,
  158. 'displayName': payment_term.display_name,
  159. 'lines': [{
  160. 'id': line.id,
  161. 'days': line.days,
  162. 'days2': line.days2,
  163. 'value': line.value,
  164. 'valueAmount': line.value_amount
  165. } for line in payment_term.line_ids]
  166. } for payment_term in request.env['account.payment.term'].search([('active', '=', True)])]
  167. '''
  168. Make JSON response
  169. '''
  170. def make_json_response(self, data=None, status=200):
  171. return Response(json.dumps(data), status=status, content_type='application/json')
  172. '''
  173. Make GZIP to JSON response
  174. '''
  175. def make_gzip_response(self, data=None, status=200):
  176. gzip_buffer = IO()
  177. with GzipFile(mode='wb', compresslevel=GZIP_COMPRESSION_LEVEL, fileobj=gzip_buffer) as gzip_file:
  178. gzip_file.write(json.dumps(data))
  179. contents = gzip_buffer.getvalue()
  180. gzip_buffer.close()
  181. headers = Headers()
  182. headers.add('Content-Encoding', 'gzip')
  183. headers.add('Vary', 'Accept-Encoding')
  184. headers.add('Content-Length', len(contents))
  185. return Response(contents, status=status, headers=headers, content_type='application/json')
  186. '''
  187. '''
  188. def make_info_log(self, log):
  189. LOGGER.info(log)
  190. '''
  191. New purchase resource route
  192. '''
  193. @http.route('/eiru_sales/init', auth='user', methods=['GET'], cors='*')
  194. def init_sale(self, **kw):
  195. self.make_info_log('Sending JSON response')
  196. return self.make_gzip_response({
  197. 'date': self.get_server_date(),
  198. 'user': self.get_user(),
  199. 'currencies': self.get_currencies(),
  200. 'journals': self.get_journals(),
  201. 'customers': self.get_customers(),
  202. 'products': self.get_products(),
  203. 'paymentTerms': self.get_payment_terms()
  204. })
  205. '''
  206. Create customer and return data
  207. '''
  208. @http.route('/eiru_sales/create_customer', type='json', auth='user', methods=['POST'], cors='*')
  209. def create_customer(self, **kw):
  210. self.make_info_log('Creating customer')
  211. customer = request.env['res.partner'].create({
  212. 'name': kw.get('name'),
  213. 'ruc': kw.get('ruc'),
  214. 'phone': kw.get('phone'),
  215. 'customer': True
  216. })
  217. return {
  218. 'id': customer.id,
  219. 'name': customer.name,
  220. 'displayName': customer.display_name,
  221. 'imageMedium': customer.image_medium,
  222. 'phone': customer.phone,
  223. 'mobile': customer.mobile,
  224. 'email': customer.email
  225. }
  226. '''
  227. Create product and return data
  228. '''
  229. @http.route('/eiru_sales/create_product', type='json', auth='user', methods=['POST'], cors='*')
  230. def create_product(self, **kw):
  231. self.make_info_log('Creating customer')
  232. product = request.env['product.template'].create({
  233. 'name': kw.get('name'),
  234. 'list_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. 'quantity': 1,
  246. 'price': product.list_price,
  247. 'discount': 0,
  248. 'variants': [{
  249. 'id': variant.id,
  250. 'name': variant.name,
  251. 'displayName': variant.display_name,
  252. 'ean13': variant.ean13,
  253. 'imageMedium': variant.image_medium,
  254. 'listPrice': variant.list_price,
  255. 'quantity': 1,
  256. 'price': variant.list_price,
  257. 'discount': 0,
  258. } for variant in product.product_variant_ids if variant.active]
  259. }
  260. '''
  261. Get currency from journal
  262. '''
  263. def get_currency(self, journal_id):
  264. journal = request.env['account.journal'].browse(journal_id)
  265. return journal.default_credit_account_id.currency_id.id or journal.default_credit_account_id.company_currency_id.id
  266. '''
  267. Check currency in pricelist and get it
  268. '''
  269. def get_pricelist(self, currency_id):
  270. pricelist = request.env['product.pricelist'].search([('active', '=', True), ('type', '=', 'sale')])
  271. if not True in pricelist.mapped(lambda p: p.currency_id.id == currency_id):
  272. pricelist = pricelist[0].copy()
  273. pricelist.write({
  274. 'currency_id': currency_id
  275. })
  276. else:
  277. pricelist = pricelist.filtered(lambda p: p.currency_id.id == currency_id)
  278. return pricelist
  279. '''
  280. Create sale order from cart items values
  281. '''
  282. def create_sale_from_cart(self, partner_id, cart_items, date_confirm, currency_id, pricelist_id, payment_term_id):
  283. return request.env['sale.order'].create({
  284. 'partner_id': partner_id,
  285. 'order_line': [[0, False, {
  286. 'product_id': int(line.get('id')),
  287. 'product_uom_qty': float(line.get('quantity')),
  288. 'price_unit': float(line.get('price'))
  289. }] for line in cart_items],
  290. 'picking_policy': 'direct',
  291. 'state': 'manual',
  292. 'date_confirm': date_confirm,
  293. 'currency_id': currency_id,
  294. 'pricelist_id': pricelist_id,
  295. 'payment_term': payment_term_id
  296. })
  297. '''
  298. Confirm sale order
  299. '''
  300. def confirm_sale_order(self, sale_order_id):
  301. return request.env['sale.order'].browse(sale_order_id).action_button_confirm()
  302. '''
  303. Create invoice from sale order
  304. '''
  305. def create_invoice(self, sale_order_id, currency_id, date_today):
  306. sale_order = request.env['sale.order'].browse(sale_order_id)
  307. invoice_id = sale_order.action_invoice_create()
  308. invoice = request.env['account.invoice'].browse(invoice_id)
  309. date_due = parse(date_today) + rd(days=max(invoice.payment_term.line_ids.mapped(lambda x: x.days + x.days2)))
  310. invoice.write({
  311. 'currency_id': currency_id,
  312. 'date_invoice': date_today,
  313. 'date_due': date_due.strftime(DATE_FORMAT),
  314. 'state': 'open'
  315. })
  316. return invoice
  317. '''
  318. Create move lines
  319. '''
  320. def create_invoice_move_lines(self, invoice_id, paid_amount, date_today):
  321. invoice = request.env['account.invoice'].browse(invoice_id)
  322. invoice_move_lines = invoice._get_analytic_lines()
  323. decimal_precision = request.env['decimal.precision'].precision_get('Account')
  324. compute_taxes = request.env['account.invoice.tax'].compute(invoice)
  325. invoice.check_tax_lines(compute_taxes)
  326. invoice._recompute_tax_amount()
  327. invoice_move_lines += request.env['account.invoice.tax'].move_line_get(invoice.id)
  328. total, total_currency, invoice_move_lines = invoice.compute_invoice_totals(invoice.company_id.currency_id, invoice.reference, invoice_move_lines)
  329. paid_percentage = paid_amount / round(total, decimal_precision)
  330. distributed_percentage = -(paid_percentage / len(invoice.payment_term.line_ids))
  331. payment_lines = []
  332. for line in invoice.payment_term.line_ids:
  333. date_due = (parse(date_today) + rd(days=line.days + line.days2)).strftime(DATE_FORMAT)
  334. if paid_percentage and paid_percentage < 1.0:
  335. payment_lines.append([date_today, paid_percentage])
  336. paid_percentage = paid_amount = 0
  337. if date_due == date_today and line.value_amount:
  338. distributed_percentage = -((payment_lines[0][1] - line.value_amount) / (len(invoice.payment_term.line_ids) - 1))
  339. continue
  340. if line.value != 'balance':
  341. payment_lines.append([date_due, line.value_amount + distributed_percentage])
  342. continue
  343. payment_lines.append([date_due, line.value_amount])
  344. for payment_line in payment_lines:
  345. current_price = round(total * payment_line[1], decimal_precision)
  346. if current_price < 0.0:
  347. continue
  348. paid_amount += current_price
  349. invoice_move_lines.append({
  350. 'type': 'dest',
  351. 'name': '/',
  352. 'price': current_price if payment_line[1] else round(total - paid_amount, decimal_precision) or total,
  353. 'account_id': invoice.account_id.id,
  354. 'date_maturity': payment_line[0],
  355. '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,
  356. 'currency_id': invoice.currency_id != invoice.company_id.currency_id and invoice.currency_id.id,
  357. 'ref': invoice.reference
  358. })
  359. payment_lines = []
  360. return invoice_move_lines
  361. '''
  362. Create account move
  363. '''
  364. def create_account_move(self, invoice_id, invoice_move_lines):
  365. invoice = request.env['account.invoice'].browse(invoice_id)
  366. accounting_partner = request.env['res.partner']._find_accounting_partner(invoice.partner_id)
  367. move_line_values = [(0, 0, invoice.line_get_convert(line, accounting_partner.id, invoice.date_invoice)) for line in invoice_move_lines]
  368. move_line_values = invoice.group_lines(invoice_move_lines, move_line_values)
  369. move_line_values = invoice.finalize_invoice_move_lines(move_line_values)
  370. ctx = dict(request.context, lang=invoice.partner_id.lang, company_id=invoice.company_id.id)
  371. period = invoice.period_id
  372. if not period:
  373. period = period.with_context(ctx).find(invoice.date_invoice)[:1]
  374. if period:
  375. for line in move_line_values:
  376. line[2]['period_id'] = period.id
  377. ctx['invoice'] = invoice
  378. ctx_nolang = ctx.copy()
  379. ctx_nolang.pop('lang', None)
  380. account_move = request.env['account.move'].with_context(ctx_nolang).create({
  381. 'ref': invoice.reference or invoice.name,
  382. 'line_id': move_line_values,
  383. 'journal_id': invoice.journal_id.id,
  384. 'date': invoice.date_invoice,
  385. 'narration': invoice.comment,
  386. 'company_id': invoice.company_id.id,
  387. 'period_id': period.id
  388. })
  389. invoice.with_context(ctx).write({
  390. 'move_id': account_move.id,
  391. 'period_id': account_move.period_id.id,
  392. 'move_name': account_move.name,
  393. })
  394. account_move.post()
  395. return account_move
  396. '''
  397. Number to invoice
  398. '''
  399. def number_invoice(self, invoice_id):
  400. request.env['account.invoice'].browse(invoice_id).action_number()
  401. '''
  402. Create voucher
  403. '''
  404. def create_account_voucher(self, account_move_id, journal_id, currency_id, paid_amount):
  405. account_move = request.env['account.move'].browse(account_move_id)
  406. account_journal = request.env['account.journal'].browse(journal_id)
  407. account_voucher = request.env['account.voucher'].create({
  408. 'reference': account_move.name,
  409. 'type': 'receipt',
  410. 'journal_id': account_journal.id,
  411. 'company_id': account_move.company_id.id,
  412. 'pre_line': True,
  413. 'amount': paid_amount,
  414. 'period_id': account_move.period_id.id,
  415. 'date': account_move.date,
  416. 'partner_id': account_move.partner_id.id,
  417. 'account_id': account_journal.default_credit_account_id.id,
  418. 'currency_id': currency_id,
  419. 'line_cr_ids': [[0, False, {
  420. 'date_due': l.date_maturity,
  421. 'account_id': l.account_id.id,
  422. 'date_original': l.invoice.date_invoice,
  423. 'move_line_id': l.id,
  424. 'amount_original': abs(l.credit or l.debit or 0.0),
  425. 'amount_unreconciled': abs(l.amount_residual),
  426. 'amount': abs(l.debit) if account_move.date == l.date_maturity else 0.0,
  427. 'reconcile': account_move.date == l.date_maturity,
  428. 'currency_id': currency_id
  429. }] for l in account_move.line_id]
  430. })
  431. account_voucher.action_move_line_create()
  432. return account_voucher
  433. '''
  434. Close a invoice
  435. '''
  436. def close_invoice(self, invoice_id):
  437. invoice = request.env['account.invoice'].browse(invoice_id)
  438. if invoice.residual == 0:
  439. invoice.write({
  440. 'state': 'paid'
  441. })
  442. '''
  443. Create account bank statement lines
  444. '''
  445. def create_bank_statement_lines(self, account_voucher_id, reference=None):
  446. account_voucher = request.env['account.voucher'].browse(account_voucher_id)
  447. return [[0, False, {
  448. 'name': account_voucher.reference,
  449. 'amount': account_voucher.amount,
  450. 'partner_id': account_voucher.partner_id.id,
  451. 'voucher_id': account_voucher.id,
  452. 'journal_id': account_voucher.journal_id.id,
  453. 'account_id': account_voucher.account_id.id,
  454. 'journal_entry_id': account_voucher.move_id.id,
  455. 'currency_id': account_voucher.currency_id.id,
  456. 'ref': 'POS/' + (reference or '')
  457. }]]
  458. '''
  459. Create account bank statement
  460. '''
  461. def create_bank_statement(self, account_voucher_id, account_bank_statement_lines, date_today):
  462. account_voucher = request.env['account.voucher'].browse(account_voucher_id)
  463. account_bank_statement = request.env['account.bank.statement'].search([('journal_id', '=', account_voucher.journal_id.id), ('date', '=', date_today)])
  464. account_bank_statement_values = {
  465. 'date': date_today,
  466. 'user_id': request.env.user.id,
  467. 'journal_id': account_voucher.journal_id.id,
  468. 'period_id': account_voucher.period_id.id,
  469. 'line_ids': account_bank_statement_lines,
  470. 'state': 'open' if account_voucher.journal_id.type == 'cash' else 'draft'
  471. }
  472. if account_bank_statement:
  473. size = len(account_bank_statement)
  474. if size == 1:
  475. account_bank_statement.write(account_bank_statement_values)
  476. else:
  477. account_bank_statement[size - 1].write(account_bank_statement_values)
  478. else:
  479. account_bank_statement.create(account_bank_statement_values)
  480. return account_bank_statement
  481. '''
  482. Process sale
  483. '''
  484. @http.route('/eiru_sales/process_sale', type='json', auth='user', methods=['POST'], cors='*')
  485. def process_sale(self, **kw):
  486. self.make_info_log('Processing sale...')
  487. # Get date
  488. date_now = datetime.now().strftime(DATE_FORMAT)
  489. self.make_info_log('[OK] Getting date')
  490. # Get currency
  491. currency_id = self.get_currency(kw.get('journalId'))
  492. self.make_info_log('[OK] Getting journal')
  493. # Get Pricelist
  494. pricelist = self.get_pricelist(currency_id)
  495. self.make_info_log('[OK] Getting product pricelist')
  496. # Create sale orde
  497. sale_order = self.create_sale_from_cart(kw.get('customerId'), kw.get('items'), date_now, currency_id, pricelist.id, kw.get('paymentTermId'))
  498. self.make_info_log('[OK] Creating sale order')
  499. # Confirm sale
  500. self.confirm_sale_order(sale_order.id)
  501. self.make_info_log('[OK] Confirm sale order')
  502. # Create invoice
  503. invoice = self.create_invoice(sale_order.id, currency_id, date_now)
  504. self.make_info_log('[OK] Creating invoice')
  505. # Create invoice move lines
  506. invoice_move_lines = self.create_invoice_move_lines(invoice.id, float(kw.get('payment')), date_now)
  507. self.make_info_log('[OK] Creating invoice move lines')
  508. # Create account move
  509. account_move = self.create_account_move(invoice.id, invoice_move_lines)
  510. self.make_info_log('[OK] Creating account move')
  511. # Number invoice
  512. self.number_invoice(invoice.id)
  513. self.make_info_log('[OK] Number invoice')
  514. # Create account voucher
  515. account_voucher = self.create_account_voucher(account_move.id, kw.get('journalId'), currency_id, float(kw.get('payment')))
  516. self.make_info_log('[OK] Creating account voucher')
  517. # Close invoice
  518. self.close_invoice(invoice.id)
  519. self.make_info_log('[OK] Closing invoice')
  520. # Create account bank statement lines
  521. account_bank_statement_lines = self.create_bank_statement_lines(account_voucher.id)
  522. self.make_info_log('[OK] Creating account bank statement lines')
  523. # Create bank statement
  524. self.create_bank_statement(account_voucher.id, account_bank_statement_lines, date_now)
  525. self.make_info_log('[OK] Creating account bank statement')
  526. return {
  527. 'process': True
  528. }