# -*- coding: utf-8 -*-
import logging
import json
from odoo import http
from odoo.http import request


class Workpiece(http.Controller):

    @http.route('/agvApi/backfeed', type='json', auth='none', methods=['GET', 'POST'], csrf=False,
                cors="*")
    def backfeed(self, **kw):
        """
        agv小车反馈工单(工件)结果
        :param kw:
        :return:
        """
        logging.info('backfeed:%s' % kw)
        try:
            res = {'Succeed': True}
            datas = request.httprequest.data
            ret = json.loads(datas)
            logging.info('backfeed-ret:%s' % ret)
            if 'reqCode' in ret:
                if 'method' in ret:
                    if ret['method'] == 'end':
                        workpiece_delivery = request.env['sf.workpiece.delivery'].sudo().search(
                            [('production_id.name', '=', ret['reqCode']), ('agv_task_code'), '=', ret['taskCode']])
                        if workpiece_delivery:
                            workpiece_delivery.write({'status': '已配送', 'task_completion_time': ret['reqTime']})
                            if workpiece_delivery.type == '下产线':
                                workpiece_delivery_clear = request.env['sf.workpiece.delivery'].sudo().search(
                                    [('production_id.name', '=', ret['reqCode']), ('type', '=', '运送空料架')])
                                if workpiece_delivery_clear:
                                    workpiece_delivery_clear._delivery_avg()
                        else:
                            res = {'Succeed': False, 'ErrorCode': 203, 'Error': '该reqCode暂未查到对应的工件配送记录'}
                else:
                    res = {'Succeed': False, 'ErrorCode': 204, 'Error': '未传method字段'}
            else:
                res = {'Succeed': False, 'ErrorCode': 201, 'Error': '未传reqCode字段'}
        except Exception as e:
            res = {'Succeed': False, 'ErrorCode': 202, 'Error': e}
            logging.info('backfeed error:%s' % e)
        return json.JSONEncoder().encode(res)