218 lines
9.9 KiB
Python
218 lines
9.9 KiB
Python
# -*- coding: utf-8 -*-
|
||
import logging
|
||
import json
|
||
from odoo import http
|
||
from odoo.http import request
|
||
|
||
|
||
class Manufacturing_Connect(http.Controller):
|
||
|
||
@http.route('/AutoDeviceApi/GetWoInfo', type='json', auth='sf_token', methods=['GET', 'POST'], csrf=False,
|
||
cors="*")
|
||
def get_Work_Info(self, **kw):
|
||
"""
|
||
自动化传递工单号获取工单信息
|
||
:param kw:
|
||
:return:
|
||
"""
|
||
logging.info('get_Work_Info:%s' % kw)
|
||
try:
|
||
res = {'Succeed': True, 'Datas': []}
|
||
datas = request.httprequest.data
|
||
ret = json.loads(datas)
|
||
logging.info('RfidCode:%s' % ret['RfidCode'])
|
||
workorder = request.env['mrp.workorder'].sudo().search(
|
||
[('rfid_code', '=', ret['RfidCode']), ('routing_type', '=', '装夹预调')])
|
||
if workorder:
|
||
for item in workorder:
|
||
res['Datas'].append({
|
||
'BillId': item.production_id.name,
|
||
'ProductionLine': item.production_line,
|
||
'CraftName': item.name,
|
||
'Quantity': 1,
|
||
'MaterialId': item.product_id.default_code,
|
||
'MaterialName': item.product_id.name,
|
||
'Spec': '%s×%s×%s' % (item.move_raw_ids.materiel_length, item.move_raw_ids.materiel_width,
|
||
item.move_raw_ids.materiel_height),
|
||
'Material': item.product_id.materials_type_id.name
|
||
})
|
||
except Exception as e:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': e}
|
||
logging.info('get_Work_Info error:%s' % e)
|
||
return json.JSONEncoder().encode(res)
|
||
|
||
@http.route('/AutoDeviceApi/GetShiftPlan', type='json', auth='sf_token', methods=['GET', 'POST'], csrf=False,
|
||
cors="*")
|
||
def get_ShiftPlan(self, **kw):
|
||
"""
|
||
自动化每天获取机台日计划
|
||
:param kw:
|
||
:return:
|
||
"""
|
||
logging.info('get_ShiftPlan:%s' % kw)
|
||
try:
|
||
res = {'Succeed': True, 'Datas': []}
|
||
datas = request.httprequest.data
|
||
ret = json.loads(datas)
|
||
ret = json.loads(ret['result'])
|
||
logging.info('RfidCode:%s' % ret)
|
||
workorder = request.env['mrp.workorder'].sudo().search([('name', '=', ret['ProductionLine'])])
|
||
if workorder:
|
||
for item in workorder:
|
||
date_planned_start = ''
|
||
date_planned_finished = ''
|
||
if item.date_planned_start is not False:
|
||
planned_start = item.date_planned_start.strftime("%Y-%m-%d %H:%M:%S")
|
||
date_planned_start = request.env['sf.sync.common'].sudo().get_add_time(planned_start)
|
||
if item.date_planned_finished is not False:
|
||
planned_finished = item.date_planned_finished.strftime("%Y-%m-%d %H:%M:%S")
|
||
date_planned_finished = request.env['sf.sync.common'].sudo().get_add_time(planned_finished)
|
||
res['Datas'].append({
|
||
'BillId': item.production_id.name,
|
||
'RfidCode': item.RfidCode,
|
||
'CraftName': item.name,
|
||
'Quantity': 1,
|
||
'WortkStart': date_planned_start,
|
||
'WorkEnd': date_planned_finished,
|
||
'MaterialId': item.product_id.default_code,
|
||
'MaterialName': item.product_id.name,
|
||
# 'Spec':item.mat,
|
||
'Material': item.materials_type_id.name
|
||
})
|
||
except Exception as e:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': e}
|
||
logging.info('get_ShiftPlan error:%s' % e)
|
||
return json.JSONEncoder().encode(res)
|
||
|
||
@http.route('/AutoDeviceApi/QcCheck', type='json', auth='sf_token', methods=['GET', 'POST'], csrf=False,
|
||
cors="*")
|
||
def get_qcCheck(self, **kw):
|
||
"""
|
||
工件预调(前置三元检测)
|
||
1、前置三元检测在产线外：三元检测设备把测量信息上传给MES，
|
||
MES生成检测定位数据。中控系统传递RFID编号给MES获取测量偏置结果。（来源为三元检测工单上的字段）
|
||
:param kw:
|
||
:return:
|
||
"""
|
||
logging.info('get_qcCheck:%s' % kw)
|
||
try:
|
||
res = {'Succeed': True, 'Datas': []}
|
||
datas = request.httprequest.data
|
||
ret = json.loads(datas)
|
||
ret = json.loads(ret['result'])
|
||
logging.info('RfidCode:%s' % ret)
|
||
workorder = request.env['mrp.workorder'].sudo().search([('routing_type', '=', '前置三元定位检测')])
|
||
if workorder:
|
||
for item in workorder:
|
||
res['Datas'].append({
|
||
'XOffset': item.production_id.name,
|
||
'YOffset': item.RfidCode,
|
||
'ZOffet': item.name,
|
||
'COffset': 1
|
||
})
|
||
except Exception as e:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': e}
|
||
logging.info('get_qcCheck error:%s' % e)
|
||
return json.JSONEncoder().encode(res)
|
||
|
||
@http.route('/AutoDeviceApi/FeedBackStart', type='json', auth='none', methods=['GET', 'POST'], csrf=False,
|
||
cors="*")
|
||
def button_Work_START(self, **kw):
|
||
"""
|
||
工单任务开始
|
||
:param kw:
|
||
:return:
|
||
"""
|
||
logging.info('button_Work_START:%s' % kw)
|
||
try:
|
||
res = {'Succeed': True, 'Datas': []}
|
||
datas = request.httprequest.data
|
||
ret = json.loads(datas)
|
||
if not ret['BillId']:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': '未传制造订单号'}
|
||
return json.JSONEncoder().encode(res)
|
||
if not ret['CraftId']:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': '未传工序名称'}
|
||
return json.JSONEncoder().encode(res)
|
||
if not ret['DeviceId']:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': '未传设备号'}
|
||
return json.JSONEncoder().encode(res)
|
||
production_id = ret['BillId']
|
||
routing_type = ret['CraftId']
|
||
workorder = request.env['mrp.workorder'].sudo().search(
|
||
[('production_id', '=', production_id), ('routing_type', '=', routing_type)], limit=1)
|
||
workorder.button_start()
|
||
except Exception as e:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': e}
|
||
logging.info('button_Work_START error:%s' % e)
|
||
return json.JSONEncoder().encode(res)
|
||
|
||
@http.route('/AutoDeviceApi/FeedBackEnd', type='json', auth='none', methods=['GET', 'POST'], csrf=False,
|
||
cors="*")
|
||
def button_Work_End(self, **kw):
|
||
"""
|
||
工单任务结束
|
||
:param kw:
|
||
:return:
|
||
"""
|
||
logging.info('button_Work_End:%s' % kw)
|
||
try:
|
||
res = {'Succeed': True, 'Datas': []}
|
||
datas = request.httprequest.data
|
||
ret = json.loads(datas)
|
||
if not ret['BillId']:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': '未传制造订单号'}
|
||
return json.JSONEncoder().encode(res)
|
||
if not ret['CraftId']:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': '未传工序名称'}
|
||
return json.JSONEncoder().encode(res)
|
||
if not ret['DeviceId']:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': '未传设备号'}
|
||
return json.JSONEncoder().encode(res)
|
||
production_id = ret['BillId']
|
||
routing_type = ret['CraftId']
|
||
workorder = request.env['mrp.workorder'].sudo().search(
|
||
[('production_id', '=', production_id), ('routing_type', '=', routing_type)], limit=1)
|
||
workorder.button_finish()
|
||
except Exception as e:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': e}
|
||
logging.info('button_Work_End error:%s' % e)
|
||
return json.JSONEncoder().encode(res)
|
||
|
||
@http.route('/AutoDeviceApi/QcCheck', type='json', auth='none', methods=['GET', 'POST'], csrf=False,
|
||
cors="*")
|
||
def Workorder_QcCheck(self, **kw):
|
||
"""
|
||
零件质检
|
||
:param kw:
|
||
:return:
|
||
"""
|
||
logging.info('Workorder_QcCheck:%s' % kw)
|
||
try:
|
||
res = {'Succeed': True, 'Datas': []}
|
||
datas = request.httprequest.data
|
||
ret = json.loads(datas)
|
||
if not ret['BillId']:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': '未传制造订单号'}
|
||
return json.JSONEncoder().encode(res)
|
||
if not ret['CraftId']:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': '未传工序名称'}
|
||
return json.JSONEncoder().encode(res)
|
||
if not ret['DeviceId']:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': '未传设备号'}
|
||
return json.JSONEncoder().encode(res)
|
||
if not ret['Quality']:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': '未传检测结果'}
|
||
return json.JSONEncoder().encode(res)
|
||
if not ret['ReportPaht']:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': '未传检查报告文件(地址)'}
|
||
return json.JSONEncoder().encode(res)
|
||
production_id = ret['BillId']
|
||
routing_type = ret['CraftId']
|
||
request.env['mrp.workorder'].sudo().search(
|
||
[('production_id', '=', production_id), ('routing_type', '=', routing_type)], limit=1)
|
||
except Exception as e:
|
||
res = {'Succeed': False, 'ErrorCode': 202, 'Error': e}
|
||
logging.info('Workorder_QcCheck error:%s' % e)
|
||
return json.JSONEncoder().encode(res)
|