from .. import controller from odoo import http, fields from odoo.http import request, Response from pytz import timezone from datetime import datetime import json import logging _logger = logging.getLogger(__name__) class StockPicking(controller.Controller): prefix = '/api/v1/' PREFIX_PARTNER = prefix + 'partner//' @http.route(PREFIX_PARTNER + 'stock-picking', auth='public', method=['GET', 'OPTIONS']) @controller.Controller.must_authorized(private=True, private_key='partner_id') def get_partner_stock_picking(self, **kw): get_params = self.get_request_params(kw, { 'partner_id': ['number'], 'q': [], 'status': [], 'limit': ['default:0', 'number'], 'offset': ['default:0', 'number'] }) if not get_params['valid']: return self.response(code=400, description=get_params) params = get_params['value'] partner_id = params['partner_id'] limit = params['limit'] offset = params['offset'] child_ids = request.env['res.partner'].browse(partner_id).get_child_ids() pending_domain = [('driver_departure_date', '=', False), ('driver_arrival_date', '=', False)] shipment_domain = [('driver_departure_date', '!=', False), ('driver_arrival_date', '=', False)] shipment_domain2 = [('driver_departure_date', '!=', False), ('sj_return_date', '=', False)] completed_domain = [('driver_departure_date', '!=', False), '|', ('driver_arrival_date', '!=', False), ('sj_return_date', '!=', False)] completed_domain2 = [('driver_departure_date', '!=', False), ('sj_return_date', '!=', False)] picking_model = request.env['stock.picking'] domain = [ ('partner_id', 'in', child_ids), ('sale_id', '!=', False), ('origin', 'ilike', 'SO%'), ('state', '!=', 'cancel'), ('name', 'ilike', 'BU/OUT%') ] if params['q']: query_like = '%' + params['q'].replace(' ', '%') + '%' domain += ['|', '|', ('name', 'ilike', query_like), ('sale_id.client_order_ref', 'ilike', query_like), ('delivery_tracking_no', 'ilike', query_like) ] default_domain = domain.copy() if params['status'] == 'pending': domain += pending_domain elif params['status'] == 'shipment': domain += shipment_domain + shipment_domain2 elif params['status'] == 'completed': domain += completed_domain stock_pickings = picking_model.search(domain, offset=offset, limit=limit, order='create_date desc') res_pickings = [] for picking in stock_pickings: manifests = picking.get_manifests() res_pickings.append({ 'id': picking.id, 'name': picking.name, 'date': self.time_to_str(picking.create_date, '%d/%m/%Y'), 'tracking_number': picking.delivery_tracking_no or '', 'sale_order': { 'id': picking.sale_id.id, 'name': picking.sale_id.name, 'client_order_ref': picking.sale_id.client_order_ref or '' }, 'delivered': picking.waybill_id.delivered or picking.driver_arrival_date != False or picking.sj_return_date != False, 'status': picking.shipping_status, 'carrier_name': picking.carrier_id.name or '', 'last_manifest': next(iter(manifests), None) }) return self.response({ 'summary': { 'pending_count': picking_model.search_count(default_domain + pending_domain), 'shipment_count': picking_model.search_count(default_domain + shipment_domain + shipment_domain2), 'completed_count': picking_model.search_count(default_domain + completed_domain) }, 'picking_total': picking_model.search_count(domain), 'pickings': res_pickings }) @http.route(PREFIX_PARTNER + 'stock-picking//tracking', auth='public', method=['GET', 'OPTIONS']) @controller.Controller.must_authorized(private=True, private_key='partner_id') def get_partner_stock_picking_detail_tracking(self, **kw): id = int(kw.get('id', 0)) picking_model = request.env['stock.picking'] picking = picking_model.browse(id) if not picking: return self.response(None) return self.response(picking.get_tracking_detail()) @http.route(prefix + 'stock-picking//tracking', auth='public', method=['GET', 'OPTIONS']) @controller.Controller.must_authorized() def get_partner_stock_picking_detail_tracking_iman(self, **kw): id = int(kw.get('id', 0)) picking_model = request.env['stock.picking'] picking = picking_model.browse(id) if not picking: return self.response(None) return self.response(picking.get_tracking_detail()) @http.route(prefix + 'stock-picking//documentation', auth='public', methods=['PUT', 'OPTIONS'], csrf=False) @controller.Controller.must_authorized() def write_partner_stock_picking_documentation(self, scanid, **kw): env = request.env Picking = env['stock.picking'].sudo() SjDoc = env['stock.picking.sj.document'].sudo() paket_document = kw.get('paket_document') dispatch_document = kw.get('dispatch_document') self_pu = kw.get('self_pu') # ===== Cari picking (FAST PATH) ===== picking = False if scanid.isdigit(): picking = Picking.browse(int(scanid)) if not picking.exists(): picking = False if not picking: picking = Picking.search([('picking_code', '=', scanid)], limit=1) if not picking: return self.response(code=403, description='picking not found') # ===== Ambil SJ list ===== form = request.httprequest.form or {} sj_list = form.getlist('sj_documentations') if not sj_list and kw.get('sj_documentations'): sj_list = [kw.get('sj_documentations')] # ===== Prepare write params ===== params = {} now = fields.Datetime.now() if paket_document: params['paket_documentation'] = paket_document params['driver_arrival_date'] = now if dispatch_document: params['dispatch_documentation'] = dispatch_document if sj_list and self_pu: params['driver_arrival_date'] = now if params: picking.write(params) # ===== BULK CREATE SJ (BIG WIN) ===== if sj_list: seq = (picking.sj_documentations[:1].sequence or 10) if picking.sj_documentations else 10 vals_list = [] for b64 in sj_list: if not b64: continue vals_list.append({ 'picking_id': picking.id, 'sequence': seq, 'image': b64, }) seq += 10 if vals_list: SjDoc.create(vals_list) return self.response({'name': picking.name}) # @http.route(prefix + 'stock-picking//documentation', auth='public', methods=['PUT', 'OPTIONS'], csrf=False) # @controller.Controller.must_authorized() # def write_partner_stock_picking_documentation(self, scanid, **kw): # paket_document = kw.get('paket_document') if 'paket_document' in kw else None # dispatch_document = kw.get('dispatch_document') if 'dispatch_document' in kw else None # self_pu = kw.get('self_pu') if 'self_pu' in kw else None # # ===== Cari picking by id / picking_code ===== # picking = False # # if scanid.isdigit() and int(scanid) < 2147483646: # # picking = request.env['stock.picking'].search([('id', '=', int(scanid))], limit=1) # # if not picking: # # picking = request.env['stock.picking'].search([('picking_code', '=', scanid)], limit=1) # if scanid.isdigit(): # picking = request.env['stock.picking'].browse(int(scanid)) # if not picking.exists(): # picking = False # if not picking: # picking = request.env['stock.picking'].search( # [('picking_code', '=', scanid)], # limit=1 # ) # if not picking: # return self.response(code=403, description='picking not found') # # ===== Ambil MULTIPLE SJ dari form: sj_documentations=...&sj_documentations=... ===== # form = request.httprequest.form or {} # sj_list = form.getlist('sj_documentations') # list of base64 strings # # fallback: kalau FE kirim single dengan nama yang sama (bukan list) # if not sj_list and 'sj_documentations' in kw and kw.get('sj_documentations'): # sj_list = [kw.get('sj_documentations')] # params = {} # if paket_document: # params['paket_documentation'] = paket_document # params['driver_arrival_date'] = datetime.utcnow() # if dispatch_document: # params['dispatch_documentation'] = dispatch_document # if sj_list and self_pu: # params['driver_arrival_date'] = datetime.utcnow() # if params: # picking.write(params) # vals_list = [] # for b64 in sj_list: # if not b64: # continue # vals_list.append({ # 'picking_id': picking.id, # 'sequence': seq, # 'image': b64, # }) # seq += 10 # if vals_list: # Child.create(vals_list) # return self.response({'name': picking.name}) # @http.route(prefix + 'stock-picking//documentation', auth='public', methods=['PUT', 'OPTIONS'], csrf=False) # @controller.Controller.must_authorized() # def write_partner_stock_picking_documentation(self, scanid, **kw): # sj_document = kw.get('sj_document') if 'sj_document' in kw else None # paket_document = kw.get('paket_document') if 'paket_document' in kw else None # dispatch_document = kw.get('dispatch_document') if 'dispatch_document' in kw else None # self_pu= kw.get('self_pu') if 'self_pu' in kw else None # # # ===== Cari picking by id / picking_code ===== # picking_data = False # if scanid.isdigit() and int(scanid) < 2147483646: # picking_data = request.env['stock.picking'].search([('id', '=', int(scanid))], limit=0) # # if not picking_data: # picking_data = request.env['stock.picking'].search([('picking_code', '=', scanid)], limit=0) # # if not picking_data: # return self.response(code=403, description='picking not found') # # params = {} # if sj_document: # params['sj_documentation'] = sj_document # if self_pu: # params['driver_arrival_date'] = datetime.utcnow() # if paket_document: # params['paket_documentation'] = paket_document # params['driver_arrival_date'] = datetime.utcnow() # if dispatch_document: # params['dispatch_documentation'] = dispatch_document # # picking_data.write(params) # return self.response({'name': picking_data.name}) @http.route(prefix + 'webhook/biteship', type='json', auth='public', methods=['POST'], csrf=False) def update_status_from_biteship(self, **kw): _logger.info("Biteship Webhook: Request received at controller start (type='json').") try: # Karena type='json', Odoo secara otomatis akan mem-parsing JSON untuk Anda. # 'data' akan berisi dictionary Python dari payload JSON Biteship. data = request.jsonrequest # Log ini akan menunjukkan payload yang diterima (sudah dalam bentuk dict) _logger.info(f"Biteship Webhook: Parsed JSON data from request.jsonrequest: {json.dumps(data)}") event = data.get('event') if event: _logger.info(f"Biteship Webhook: Processing event: {event}") if event == "order.status": self.process_order_status(data) elif event == "order.price": self.process_order_price(data) elif event == "order.waybill_id": self.process_order_waybill(data) # Tambahkan logika untuk event lain jika ada else: _logger.info("Biteship Webhook: No specific event in payload. Likely an installation/verification ping or unknown event type.") # Untuk route type='json', Anda cukup mengembalikan dictionary Python. # Odoo akan secara otomatis mengonversinya menjadi respons JSON yang valid. return {'status': 'ok'} except Exception as e: _logger.error(f"Biteship Webhook: Unhandled error during processing: {e}", exc_info=True) # Untuk error, kembalikan dictionary error juga, Odoo akan mengonversinya ke JSON return {'status': 'error', 'message': str(e)} def process_order_status(self, data): picking = request.env['stock.picking'].sudo().search([ ('biteship_id', '=', data.get('order_id')) ], limit=1) if not picking: _logger.warning(f"[Webhook] Tidak ditemukan picking untuk order_id {data.get('order_id')}") return status = data.get('status') timestamp = data.get('updated_at') or datetime.utcnow().isoformat() description = picking._get_biteship_status_description(status, { "courier": {"company": data.get("courier_company", "")}, "destination": {"contact_name": picking.partner_id.name or ""} }) # Tambahkan extra data dari webhook extra_data = { "courier_driver_name": data.get("courier_driver_name"), "courier_driver_phone": data.get("courier_driver_phone"), "courier_driver_plate_number": data.get("courier_driver_plate_number"), "courier_link": data.get("courier_link"), "order_price": data.get("order_price"), "status": data.get("status"), } picking.log_biteship_event_from_webhook(status, timestamp, description, extra_data=extra_data) def process_order_price(self, data): picking = request.env['stock.picking'].sudo().search([('biteship_id', '=', data.get('order_id'))], limit=1) if not picking: _logger.warning(f"Tidak ditemukan picking untuk order_id {data.get('order_id')}") return picking.log_biteship_event_from_webhook( status='order.price', timestamp=data.get('updated_at') or datetime.utcnow().isoformat(), description='Biaya pengiriman telah diperbarui berdasarkan informasi terbaru dari Biteship.', extra_data={ "order_price": data.get("price") } ) def process_order_waybill(self, data): picking = request.env['stock.picking'].sudo().search([ ('biteship_id', '=', data.get('order_id')) ], limit=1) if not picking: _logger.warning(f"Tidak ditemukan picking untuk order_id {data.get('order_id')}") return picking.log_biteship_event_from_webhook( status='order.waybill_id', timestamp=data.get('updated_at') or datetime.utcnow().isoformat(), description="Nomor waybill dan tracking diperbarui melalui Biteship.", extra_data={ "tracking_id": data.get("courier_tracking_id"), "waybill_id": data.get("courier_waybill_id") } )