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


class Sf_Mrs_Connect(http.Controller):

    @http.route('/api/cnc_processing/create', type='json', auth='sf_token', methods=['GET', 'POST'], csrf=False,
                cors="*")
    def get_cnc_processing_create(self, **kw):
        """
        获取mrs下发的编程单
        :param kw:
        :return:
        """
        logging.info('get_cnc_processing_create:%s' % kw)
        try:
            res = {'status': 1, 'message': '成功'}
            datas = request.httprequest.data
            ret = json.loads(datas)
            ret = json.loads(ret['result'])
            logging.info('下发编程单:%s' % ret)
            # 查询状态为进行中且类型为获取CNC加工程序的工单
            cnc_production = request.env['mrp.production'].with_user(
                request.env.ref("base.user_admin")).search([('name', '=', ret['production_order_no'])])
            logging.info('制造订单号:%s' % cnc_production.name)
            if cnc_production:
                if ret['glb_file']:
                    cnc_production.glb_file = base64.b64encode(ret['glb_file'])
                # 拉取所有加工面的程序文件
                # i = 1

                for r in ret['processing_panel']:
                    download_state = request.env['sf.cnc.processing'].with_user(
                        request.env.ref("base.user_admin")).download_file_tmp(
                        ret['folder_name'], r)
                    if download_state == 0:
                        res['status'] = -2
                        res['message'] = '制造订单号为%s的CNC程序文件从FTP拉取失败' % (cnc_production.name)
                        return json.JSONEncoder().encode(res)
                logging.info('创建cnc工单')
                program_path_tmp = os.path.join('/tmp', ret['folder_name'], 'return', r)
                files = os.listdir(program_path_tmp)
                for f in files:
                    program_path = os.path.join(program_path_tmp, f)
                    logging.info('cnc程序路径 :%s' % program_path)
                    request.env['sf.cnc.processing'].with_user(
                        request.env.ref("base.user_admin")).cnc_processing_create(cnc_production, ret, program_path,program_path_tmp)
                return json.JSONEncoder().encode(res)
            else:
                res = {'status': 0, 'message': '该制造订单暂未开始'}
                return json.JSONEncoder().encode(res)
        except Exception as e:
            res = {'status': -1, 'message': '系统解析失败'}
            logging.info('get_cnc_processing_create error:%s' % e)
            return json.JSONEncoder().encode(res)