# -*- coding: utf-8 -*-
import logging
from odoo import models, fields, api, _


class SFMessageSale(models.Model):
    _name = 'sale.order'
    _inherit = ['sale.order', 'jikimo.message.dispatch']

    def create(self, vals_list):
        res = super(SFMessageSale, self).create(vals_list)
        if res:
            try:
                res.add_queue('待接单')
            except Exception as e:
                logging.info('add_queue error:%s' % e)
        return res

    # 确认接单
    def action_confirm(self):
        res = super(SFMessageSale, self).action_confirm()
        if res is True:
            try:
                self.add_queue('确认接单')
                picking_ids = self.mrp_production_ids
                purchase_order_id = []
                if picking_ids:
                    for picking_id in picking_ids:
                        purchase_order_ids = (
                                picking_id.procurement_group_id.stock_move_ids.created_purchase_line_id.order_id |
                                picking_id.procurement_group_id.stock_move_ids.move_orig_ids.purchase_line_id.order_id).ids
                        purchase_order_id.extend(purchase_order_ids)
                    if purchase_order_id:
                        purchase_order_list = self.env['purchase.order'].search([('id', 'in', purchase_order_id)])
                        for purchase_order_info in purchase_order_list:
                            purchase_order_info.add_queue('坯料采购提醒')
            except Exception as e:
                logging.info('add_queue error:%s' % e)
        return res

    # 继承并重写jikimo.message.dispatch的_get_message()
    def _get_message(self, message_queue_ids):
        contents = []
        url = self.env['ir.config_parameter'].get_param('web.base.url')
        for item in message_queue_ids:
            # 待接单的处理
            if item.message_template_id.bussiness_node_id.name == '待接单':
                content = super(SFMessageSale, self)._get_message(item)
                action_id = self.env.ref('sale.action_quotations_with_onboarding').id
                url = f"{url}/web#id={item.res_id}&view_type=form&action={action_id}"
                content = content[0].replace('{{url}}', url)
                contents.append(content)
            # 确认接单的处理
            elif item.message_template_id.bussiness_node_id.name == '确认接单':
                content = super(SFMessageSale, self)._get_message(item)
                sale_order_line = self.env['sale.order.line'].search([('order_id', '=', int(item.res_id))])
                product = sale_order_line[0].product_id.name if len(sale_order_line) == 1 else '%s...' % \
                                                                                               sale_order_line[
                                                                                                   0].product_id.name
                action_id = self.env.ref('sf_plan.sf_production_plan_action1').id
                url = f"{url}/web#view_type=list&action={action_id}"
                content = content[0].replace('{{product_id}}', product).replace('{{url}}', url)
                contents.append(content)
        return contents

        # # 销售订单逾期预警
    # def _overdue_warning_func(self):
    #     sale_order_
    #     return 1
    #
    # # 销售订单已逾期
    # def _overdue_func(self):
    #     return 1