import json
import base64
import requests
import logging
from odoo import models, api
from odoo.addons.sf_base.commons.common import Common
from odoo.exceptions import UserError


class StockLot(models.Model):
    _inherit = 'stock.lot'
    _description = '夹具物料序列号注册'

    def sync_enroll_fixture_material_stock_all(self):
        logging.info("调用 sync_enroll_fixture_material_stock_all 同步接口")
        sf_sync_config = self.env['res.config.settings'].get_values()
        token = sf_sync_config['token']
        sf_secret_key = sf_sync_config['sf_secret_key']
        headers = Common.get_headers(self, token, sf_secret_key)
        str_url = sf_sync_config['sf_url'] + "/api/fixture_material_stock/create"
        product_ids = self.env['product.product'].sudo().search([('categ_type', '=', '夹具')]).ids
        objs_all = self.env['stock.lot'].search([('rfid', '!=', False), ('product_id', 'in', product_ids)])
        fixture_material_stock_list = []
        try:
            if objs_all:
                for item in objs_all:
                    val = {
                        'name': item.name,
                        'tool_material_status': item.tool_material_status,
                        'location': [] if not item.quant_ids else item.quant_ids[-1].location_id.name,
                        'fixture_material_search_id': item.fixture_material_search_id.id,
                    }
                    fixture_material_stock_list.append(val)
                kw = json.dumps(fixture_material_stock_list, ensure_ascii=False)
                r = requests.post(str_url, json={}, data={'kw': kw, 'token': token}, headers=headers)
                ret = r.json()
                if ret.get('code') == 200:
                    logging.info("夹具物料序列号每日同步成功")
                    return '夹具物料序列号注册成功'
            else:
                logging.info("没有注册夹具物料序列号信息")
        except Exception as e:
            logging.info("夹具物料序列号同步失败:%s" % e)


class FixtureMaterialSearch(models.Model):
    _inherit = 'sf.fixture.material.search'
    _description = '夹具物料搜索注册'

    crea_url = "/api/fixture_material/create"

    def sync_enroll_fixture_material_all(self):
        logging.info("调用 sync_enroll_fixture_material_all 同步接口")
        sf_sync_config = self.env['res.config.settings'].get_values()
        token = sf_sync_config['token']
        sf_secret_key = sf_sync_config['sf_secret_key']
        headers = Common.get_headers(self, token, sf_secret_key)
        str_url = sf_sync_config['sf_url'] + self.crea_url
        objs_all = self.search([])
        fixture_material_list = []
        try:
            if objs_all:
                for obj in objs_all:
                    val = {
                        'name': obj.name,
                        'id': obj.id,
                        'fixture_material_code': obj.fixture_material_id.code,
                        'fixture_model_code': obj.fixture_model_id.code,
                        'specification_name': obj.specification_fixture_id.name,
                        'image': '' if not obj.image else base64.b64encode(obj.image).decode('utf-8'),
                        'number': obj.number,
                        'usable_num': obj.usable_num,
                        'have_been_used_num': obj.have_been_used_num,
                        'scrap_num': obj.scrap_num
                    }
                    fixture_material_list.append(val)
                kw = json.dumps(fixture_material_list, ensure_ascii=False)
                r = requests.post(str_url, json={}, data={'kw': kw, 'token': token}, headers=headers)
                ret = r.json()
                if ret.get('code') == 200:
                    logging.info("夹具物料每日同步成功")
                    return '夹具物料注册成功'
            else:
                logging.info("没有注册夹具物料信息")
        except Exception as e:
            logging.info("夹具物料同步失败:%s" % e)

    # @api.model_create_multi
    # def create(self, vals_list):
    #     records = super(FixtureMaterialSearch, self).create(vals_list)
    #     for record in records:
    #         if record:
    #             record.enroll_fixture_material()
    #     return records