# -*- coding: utf-8 -*-
import json
import requests
from odoo import models, fields, api

from odoo.exceptions import UserError
import logging
from odoo.tools import date_utils

_logger = logging.getLogger(__name__)


class StockPicking(models.Model):
    _inherit = 'stock.picking'

    # 重写验证，下发发货到bfm
    def button_validate(self):
        info = super(StockPicking, self).button_validate()
        if self.picking_type_code == 'outgoing':
            self.send_to_bfm()
        return info

    def deal_move_ids(self, send_move_ids, send_move_line_ids):
        move_ids = []  # 本次发货单
        move_line_ids = []  # 本次发货单行
        if send_move_ids:
            for item in send_move_ids:
                val = {
                    'name': item.product_id.upload_model_file.display_name,
                    'quantity_done': item.quantity_done,
                    'date': date_utils.json_default(item.date) if item.date else None,
                    'description_picking': item.description_picking,
                    'date_deadline': date_utils.json_default(item.date_deadline) if item.date_deadline else None,
                    'product_uom_qty': item.product_uom_qty,
                    'sequence': item.sequence,
                    'price_unit': item.price_unit,
                    'priority': item.priority,
                    'state': item.state,
                }
                move_ids.append(val)
            for item in send_move_line_ids:
                val = {
                    'qty_done': item.qty_done,
                    'reserved_qty': item.reserved_qty,
                    'reserved_uom_qty': item.reserved_uom_qty,
                    'date': date_utils.json_default(item.date) if item.date else None,
                    'description_picking': item.description_picking,
                    'state': item.state,
                }
                move_line_ids.append(val)
        return move_ids, move_line_ids

    def deal_send_backorder_id(self, backorder_ids1):
        backorder_ids = []

        if backorder_ids1:
            for item in backorder_ids1:
                move_ids, move_line_ids = self.deal_move_ids(item.move_ids, item.move_line_ids)
                val = {
                    'receiverName': item.receiverName,
                    'name': item.sale_id.default_code,
                    'send_no': item.name,
                    'scheduled_date': date_utils.json_default(item.scheduled_date) if item.scheduled_date else None,
                    'date': date_utils.json_default(item.date) if item.date else None,
                    'date_deadline': date_utils.json_default(item.date_deadline) if item.date_deadline else None,
                    'date_done': date_utils.json_default(item.date_done) if item.date_done else None,
                    'move_ids': move_ids,
                    'move_line_ids': move_line_ids,
                    'state': item.state,
                    'move_type': item.move_type,
                }
                backorder_ids.append(val)
        return backorder_ids

    def send_to_bfm(self):
        skip_backorder = self.env.context.get('skip_backorder')
        cancel_backorder_ids = self.env.context.get('picking_ids_not_to_backorder')

        # 下发发货到bfm
        config = self.env['res.config.settings'].get_values()
        move_ids, move_line_ids = self.deal_move_ids(self.move_ids, self.move_line_ids)
        data = {
            'params': {
                'receiverName': self.receiverName,
                'priority': self.priority,
                'name': self.sale_id.default_code,
                'send_no': self.name,
                'scheduled_date': date_utils.json_default(self.scheduled_date) if self.scheduled_date else None,
                'date': date_utils.json_default(self.date) if self.date else None,
                'date_deadline': date_utils.json_default(self.date_deadline) if self.date_deadline else None,
                'date_done': date_utils.json_default(self.date_done) if self.date_done else None,
                'move_ids': move_ids,
                'move_line_ids': move_line_ids,
                'state': self.state,
                'backorder_id': self.deal_send_backorder_id(self.backorder_id),
                'backorder_ids': self.deal_send_backorder_id(self.backorder_ids),
                'cancel_backorder_ids': True if skip_backorder and cancel_backorder_ids else False,  # 没有欠单判断
                'move_type': self.move_type,
            },
        }
        url1 = config['bfm_url_new'] + '/api/stock/deliver_goods'
        json_str = json.dumps(data)
        logging.info('json_str= %s', json_str)
        r = requests.post(url1, json=data, data=None)
        if r.status_code == 200:
            result = json.loads(r.json()['result'])
            if result['code'] != 200:
                raise UserError(result['message'] or '工厂发货下发bfm失败')
        else:
            raise UserError('工厂发货下发bfm失败')