1 # -*- coding: utf-8 -*-
13 import openerp.addons.hw_proxy.controllers.main as hw_proxy
16 from threading import Thread, Lock
17 from Queue import Queue, Empty
26 from ..escpos import printer
27 from ..escpos import supported_devices
29 escpos = printer = None
33 from openerp import http
34 from openerp.http import request
35 from openerp.addons.web.controllers.main import manifest_list, module_boot, html_template
36 from openerp.tools.translate import _
38 _logger = logging.getLogger(__name__)
41 class EscposDriver(Thread):
46 self.status = {'status':'connecting', 'messages':[]}
48 def connected_usb_devices(self):
51 for device in supported_devices.device_list:
52 if usb.core.find(idVendor=device['vendor'], idProduct=device['product']) != None:
53 connected.append(device)
56 def lockedstart(self):
58 if not self.isAlive():
62 def get_escpos_printer(self):
64 printers = self.connected_usb_devices()
66 self.set_status('connected','Connected to '+printers[0]['name'])
67 return escpos.printer.Usb(printers[0]['vendor'], printers[0]['product'])
69 self.set_status('disconnected','Printer Not Found')
71 except Exception as e:
72 self.set_status('error',str(e))
76 self.push_task('status')
81 def open_cashbox(self,printer):
85 def set_status(self, status, message = None):
86 if status == self.status['status']:
87 if message != None and message != self.status['messages'][-1]:
88 self.status['messages'].append(message)
90 self.status['status'] = status
92 self.status['messages'] = [message]
94 self.status['messages'] = []
96 if status == 'error' and message:
97 _logger.error('ESC/POS Error: '+message)
98 elif status == 'disconnected' and message:
99 _logger.warning('ESC/POS Device Disconnected: '+message)
103 _logger.error('ESC/POS cannot initialize, please verify system dependencies.')
107 timestamp, task, data = self.queue.get(True)
109 printer = self.get_escpos_printer()
113 self.queue.put((timestamp,task,data))
116 elif task == 'receipt':
117 if timestamp >= time.time() - 1 * 60 * 60:
118 self.print_receipt_body(printer,data)
120 elif task == 'xml_receipt':
121 if timestamp >= time.time() - 1 * 60 * 60:
122 printer.receipt(data)
123 elif task == 'cashbox':
124 if timestamp >= time.time() - 12:
125 self.open_cashbox(printer)
126 elif task == 'printstatus':
127 self.print_status(printer)
128 elif task == 'status':
131 except Exception as e:
132 self.set_status('error', str(e))
133 errmsg = str(e) + '\n' + '-'*60+'\n' + traceback.format_exc() + '-'*60 + '\n'
134 _logger.error(errmsg);
136 def push_task(self,task, data = None):
138 self.queue.put((time.time(),task,data))
140 def print_status(self,eprint):
141 localips = ['0.0.0.0','127.0.0.1','127.0.1.1']
142 ips = [ c.split(':')[1].split(' ')[0] for c in commands.getoutput("/sbin/ifconfig").split('\n') if 'inet addr' in c ]
143 ips = [ ip for ip in ips if ip not in localips ]
145 eprint.set(align='center',type='b',height=2,width=2)
146 eprint.text('PosBox Status\n')
148 eprint.set(align='center')
151 eprint.text('ERROR: Could not connect to LAN\n\nPlease check that the PosBox is correc-\ntly connected with a network cable,\n that the LAN is setup with DHCP, and\nthat network addresses are available')
153 eprint.text('IP Address:\n'+ips[0]+'\n')
155 eprint.text('IP Addresses:\n')
160 eprint.text('\nHomepage:\nhttp://'+ips[0]+':8069\n')
165 def print_receipt_body(self,eprint,receipt):
168 return string != True and bool(string) and string.strip()
171 return ("{0:."+str(receipt['precision']['price'])+"f}").format(amount)
174 return ("{0:."+str(receipt['precision']['money'])+"f}").format(amount)
176 def quantity(amount):
177 if math.floor(amount) != amount:
178 return ("{0:."+str(receipt['precision']['quantity'])+"f}").format(amount)
182 def printline(left, right='', width=40, ratio=0.5, indent=0):
183 lwidth = int(width * ratio)
184 rwidth = width - lwidth
185 lwidth = lwidth - indent
188 if len(left) != lwidth:
189 left = left + ' ' * (lwidth - len(left))
191 right = right[-rwidth:]
192 if len(right) != rwidth:
193 right = ' ' * (rwidth - len(right)) + right
195 return ' ' * indent + left + right + '\n'
198 taxes = receipt['tax_details']
200 eprint.text(printline(tax['tax']['name'],price(tax['amount']), width=40,ratio=0.6))
203 if receipt['company']['logo']:
204 eprint.set(align='center')
205 eprint.print_base64_image(receipt['company']['logo'])
208 eprint.set(align='center',type='b',height=2,width=2)
209 eprint.text(receipt['company']['name'] + '\n')
211 eprint.set(align='center',type='b')
212 if check(receipt['shop']['name']):
213 eprint.text(receipt['shop']['name'] + '\n')
214 if check(receipt['company']['contact_address']):
215 eprint.text(receipt['company']['contact_address'] + '\n')
216 if check(receipt['company']['phone']):
217 eprint.text('Tel:' + receipt['company']['phone'] + '\n')
218 if check(receipt['company']['vat']):
219 eprint.text('VAT:' + receipt['company']['vat'] + '\n')
220 if check(receipt['company']['email']):
221 eprint.text(receipt['company']['email'] + '\n')
222 if check(receipt['company']['website']):
223 eprint.text(receipt['company']['website'] + '\n')
224 if check(receipt['header']):
225 eprint.text(receipt['header']+'\n')
226 if check(receipt['cashier']):
227 eprint.text('-'*32+'\n')
228 eprint.text('Served by '+receipt['cashier']+'\n')
232 eprint.set(align='center')
233 for line in receipt['orderlines']:
234 pricestr = price(line['price_display'])
235 if line['discount'] == 0 and line['unit_name'] == 'Unit(s)' and line['quantity'] == 1:
236 eprint.text(printline(line['product_name'],pricestr,ratio=0.6))
238 eprint.text(printline(line['product_name'],ratio=0.6))
239 if line['discount'] != 0:
240 eprint.text(printline('Discount: '+str(line['discount'])+'%', ratio=0.6, indent=2))
241 if line['unit_name'] == 'Unit(s)':
242 eprint.text( printline( quantity(line['quantity']) + ' x ' + price(line['price']), pricestr, ratio=0.6, indent=2))
244 eprint.text( printline( quantity(line['quantity']) + line['unit_name'] + ' x ' + price(line['price']), pricestr, ratio=0.6, indent=2))
246 # Subtotal if the taxes are not included
248 if money(receipt['subtotal']) != money(receipt['total_with_tax']):
249 eprint.text(printline('','-------'));
250 eprint.text(printline(_('Subtotal'),money(receipt['subtotal']),width=40, ratio=0.6))
252 #eprint.text(printline(_('Taxes'),money(receipt['total_tax']),width=40, ratio=0.6))
257 eprint.text(printline('','-------'));
258 eprint.set(align='center',height=2)
259 eprint.text(printline(_(' TOTAL'),money(receipt['total_with_tax']),width=40, ratio=0.6))
263 eprint.set(align='center')
264 for line in receipt['paymentlines']:
265 eprint.text(printline(line['journal'], money(line['amount']), ratio=0.6))
268 eprint.set(align='center',height=2)
269 eprint.text(printline(_(' CHANGE'),money(receipt['change']),width=40, ratio=0.6))
270 eprint.set(align='center')
274 if receipt['total_discount'] != 0:
275 eprint.text(printline(_('Discounts'),money(receipt['total_discount']),width=40, ratio=0.6))
278 #eprint.text(printline(_('Taxes'),money(receipt['total_tax']),width=40, ratio=0.6))
281 if check(receipt['footer']):
282 eprint.text('\n'+receipt['footer']+'\n\n')
283 eprint.text(receipt['name']+'\n')
284 eprint.text( str(receipt['date']['date']).zfill(2)
285 +'/'+ str(receipt['date']['month']+1).zfill(2)
286 +'/'+ str(receipt['date']['year']).zfill(4)
287 +' '+ str(receipt['date']['hour']).zfill(2)
288 +':'+ str(receipt['date']['minute']).zfill(2) )
291 driver = EscposDriver()
293 driver.push_task('printstatus')
295 hw_proxy.drivers['escpos'] = driver
297 class EscposProxy(hw_proxy.Proxy):
299 @http.route('/hw_proxy/open_cashbox', type='json', auth='none', cors='*')
300 def open_cashbox(self):
301 _logger.info('ESC/POS: OPEN CASHBOX')
302 driver.push_task('cashbox')
304 @http.route('/hw_proxy/print_receipt', type='json', auth='none', cors='*')
305 def print_receipt(self, receipt):
306 _logger.info('ESC/POS: PRINT RECEIPT')
307 driver.push_task('receipt',receipt)
309 @http.route('/hw_proxy/print_xml_receipt', type='json', auth='none', cors='*')
310 def print_receipt(self, receipt):
311 _logger.info('ESC/POS: PRINT XML RECEIPT')
312 driver.push_task('xml_receipt',receipt)