# -*- coding: utf-8 -*- import logging import json from datetime import datetime from odoo.addons.sf_manufacturing.models.agv_scheduling import RepeatTaskException from odoo import http from odoo.http import request from odoo.addons.sf_base.decorators.api_log import api_log class Manufacturing_Connect(http.Controller): @http.route('/AutoDeviceApi/GetWoInfo', type='json', auth='sf_token', methods=['GET', 'POST'], csrf=False, cors="*") @api_log('获取工单', requester='中控系统') 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) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/GetWoInfo'}) logging.info('RfidCode:%s' % ret['RfidCode']) if 'RfidCode' in ret: workorder = request.env['mrp.workorder'].sudo().search( [('rfid_code', '=', ret['RfidCode']), ('state', '!=', 'rework')]) if workorder: for item in workorder: res['Datas'].append({ 'BillId': item.production_id.name, 'ProductionLine': item.production_id.production_line_id.id, 'SortId': item.sequence, '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 }) else: res = {'Succeed': False, 'ErrorCode': 203, 'Error': '该rfid暂未有对应的工单'} else: res = {'Succeed': False, 'ErrorCode': 201, 'Error': '未传RfidCode字段'} 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="*") @api_log('获取日计划', requester='中控系统') 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) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/GetShiftPlan'}) if 'ProductionLine' in ret: workorder_ids = request.env['mrp.workorder'].sudo().get_plan_workorder(ret['ProductionLine']) else: ProductionLine = False workorder_ids = request.env['mrp.workorder'].sudo().get_plan_workorder(ProductionLine) # todo 需要筛选出CNC工单 logging.info('RfidCode:%s' % ret) logging.info('workorder_ids:%s' % workorder_ids) workorder = request.env['mrp.workorder'].sudo().search(workorder_ids) if workorder: for item in workorder: date_planned_start = '' date_planned_finished = '' if item.date_planned_start is not False: logging.info('date_planned_start:%s' % item.date_planned_start) 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: logging.info('date_planned_finished:%s' % item.date_planned_finished) 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.rfid_code, '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.product_id.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="*") @api_log('工件预调(前置三元检测)', requester='中控系统') 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) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/QcCheck'}) logging.info('RfidCode:%s' % ret['RfidCode']) if 'RfidCode' in ret: workorder = request.env['mrp.workorder'].sudo().search( [('routing_type', '=', '装夹预调'), ('rfid_code', '=', ret['RfidCode']), ('state', '!=', 'rework')], limit=1, order='id asc') if workorder: for item in workorder: if item.material_center_point: offset = item.material_center_point[1:-1].split(",") res['Datas'].append({ 'XOffset': 0 if not item.material_center_point else offset[0], 'YOffset': 0 if not item.material_center_point else offset[1], 'ZOffset': 0 if not item.material_center_point else offset[2], 'COffset': 0, 'Coordinate': 'G54' }) else: res = {'Succeed': False, 'ErrorCode': 203, 'Error': '该rfid暂未有对应的工件预调(前置三元检测)工单'} else: res = {'Succeed': False, 'ErrorCode': 201, 'Error': '未传RfidCode字段'} 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="*") @api_log('工单开始', requester='中控系统') 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) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/FeedBackStart'}) production_id = ret['BillId'] routing_type = ret['CraftId'] equipment_id = ret["DeviceId"] workorder = request.env['mrp.workorder'].sudo().search( [('production_id', '=', production_id), ('routing_type', '=', routing_type), ('rfid_code', '!=', False), ('state', '!=', 'rework')], limit=1) if not workorder: res = {'Succeed': False, 'ErrorCode': 202, 'Error': '该工单不存在'} return json.JSONEncoder().encode(res) logging.info('workorder_state:%s' % workorder.state) if workorder.state != 'ready': res = {'Succeed': False, 'ErrorCode': 202, 'Error': '工单未就绪'} return json.JSONEncoder().encode(res) work_equipment_id = request.env['maintenance.equipment'].sudo().search([('name', '=', equipment_id)], limit=1) logging.info('work_equipment_id:%s' % work_equipment_id.name) if not work_equipment_id: res = {'Succeed': False, 'ErrorCode': 202, 'Error': '没有找到该加工设备'} return json.JSONEncoder().encode(res) workorder.equipment_id = work_equipment_id workorder.button_start() # 根据工单的实际开始时间修改排程单的开始时间、状态 if workorder.date_start: request.env['sf.production.plan'].sudo().search([('production_id', '=', production_id)]).write( {'actual_start_time': workorder.date_start, 'state': 'processing'}) res.update({'workorder_id': workorder.id}) 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="*") @api_log('工单结束', requester='中控系统') 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) logging.info('button_Work_End:%s' % ret) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/FeedBackEnd'}) production_id = ret['BillId'] routing_type = ret['CraftId'] workorder = request.env['mrp.workorder'].sudo().search( [('production_id', '=', production_id), ('routing_type', '=', routing_type), ('rfid_code', '!=', False), ('state', '!=', 'rework')], limit=1) if not workorder: res = {'Succeed': False, 'ErrorCode': 202, 'Error': '该工单不存在'} return json.JSONEncoder().encode(res) if workorder.state != 'progress': res = {'Succeed': False, 'ErrorCode': 202, 'Error': '该工单未开始'} return json.JSONEncoder().encode(res) # workorder.write({'date_finished': datetime.now()}) if ret['IsComplete'] is True: workorder.write({'date_finished': datetime.now()}) # workorder.process_state = '待解除装夹' # workorder.sudo().production_id.process_state = '待解除装夹' # 根据工单的实际结束时间修改排程单的结束时间、状态，同时修改销售订单的状态 # if workorder.date_finished: # request.env['sf.production.plan'].sudo().search([('production_id', '=', production_id)]).write( # {'actual_end_time': workorder.date_finished, # 'state': 'finished'}) # production_obj = request.env['mrp.production'].sudo().search([('name', '=', production_id)]) # if production_obj: # production_obj.sudo().work_order_state = '已完成' # production_obj.write({'state': 'done'}) # request.env['sale.order'].sudo().search( # [('name', '=', production_obj.origin)]).write({'schedule_status': 'to deliver'}) 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/PartQualityInspect', type='json', auth='none', methods=['GET', 'POST'], csrf=False, cors="*") @api_log('零件检测(后置三元检测)', requester='中控系统') def PartQualityInspect(self, **kw): """ 零件质检 :param kw: :return: """ logging.info('PartQualityInspect:%s' % kw) try: res = {'Succeed': True} datas = request.httprequest.data ret = json.loads(datas) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/PartQualityInspect'}) production_id = ret['BillId'] # routing_type = ret['CraftId'] workorder = request.env['mrp.workorder'].sudo().search( [('production_id', '=', production_id), ('routing_type', '=', 'CNC加工'), ('state', 'not in', ['rework', 'done', 'cancel'])], order='sequence asc', limit=1) if workorder: # workorder.test_results = ret['Quality'] logging.info('制造订单:%s' % workorder.production_id.name) if 'ReportPaht' in ret: if ret['ReportPaht'].find('.pdf') != -1: download_state = request.env['mrp.workorder'].with_user( request.env.ref("base.user_admin")).download_reportfile_tmp(workorder, ret['ReportPaht']) if download_state is True: detection_ret = request.env['mrp.workorder'].with_user( request.env.ref("base.user_admin")).get_detection_file(workorder, ret['ReportPaht']) logging.info('detection_ret:%s' % detection_ret) if detection_ret is False: res = {'Succeed': False, 'ErrorCode': 205, 'Error': '检测报告文件读取失败'} else: res = {'Succeed': False, 'ErrorCode': 204, 'Error': '检测报告文件从FTP拉取失败'} else: res = {'Succeed': False, 'ErrorCode': 203, 'Error': '未传ReportPaht字段'} else: res = {'Succeed': False, 'ErrorCode': 206, 'Error': '未查询到工单'} except Exception as e: res = {'Succeed': False, 'ErrorCode': 202, 'Error': e} logging.info('PartQualityInspect error:%s' % e) return json.JSONEncoder().encode(res) @http.route('/AutoDeviceApi/CMMProgDolod', type='json', auth='none', methods=['GET', 'POST'], csrf=False, cors="*") @api_log('CMM测量程序下载', requester='中控系统') def CMMProgDolod(self, **kw): """ 中控系统传递RFID编号给MES，获取测量程序文件。Ftp下载文件 :param kw: :return: """ logging.info('CMMProgDolod:%s' % kw) try: res = {'Succeed': True, 'Datas': []} datas = request.httprequest.data ret = json.loads(datas) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/CMMProgDolod'}) if 'RfidCode' in ret: logging.info('RfidCode:%s' % ret['RfidCode']) workorder = request.env['mrp.workorder'].sudo().search( [('rfid_code', '=', ret['RfidCode']), ('routing_type', '=', 'CNC加工'), ('state', '!=', 'rework')]) if workorder: for item in workorder.cmm_ids: if item.program_create_date is not False: program_create_date = item.program_create_date.strftime("%Y-%m-%d %H:%M:%S") program_date_str = request.env['sf.sync.common'].sudo().get_add_time(program_create_date) res['Datas'].append({ 'CraftId': workorder.id, 'CraftKey': workorder.name, 'ProgramDate': '' if not item.program_create_date else program_date_str, 'ProgramPath': item.program_path, 'PostProcessing': item.program_name, }) else: res = {'Succeed': False, 'ErrorCode': 203, 'Error': '暂无工单及对应的CNC程序数据'} else: res = {'Succeed': False, 'ErrorCode': 201, 'Error': '未传RfidCode字段'} except Exception as e: res = {'Succeed': False, 'ErrorCode': 202, 'Error': e} logging.info('CMMProgDolod error:%s' % e) return json.JSONEncoder().encode(res) @http.route('/AutoDeviceApi/NCProgDolod', type='json', auth='none', methods=['GET', 'POST'], csrf=False, cors="*") @api_log('CAM加工程序下载', requester='中控系统') def NCProgDolod(self, **kw): """ 中控系统传递RFID编号给MES，获取程序单及程序文件。Ftp下载文件 :param kw: :return: """ logging.info('NCProgDolod:%s' % kw) try: res = {'Succeed': True, 'Datas': []} datas = request.httprequest.data ret = json.loads(datas) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/NCProgDolod'}) if 'RfidCode' in ret: logging.info('RfidCode:%s' % ret['RfidCode']) workorder = request.env['mrp.workorder'].sudo().search( [('rfid_code', '=', ret['RfidCode']), ('routing_type', '=', 'CNC加工'), ('state', '!=', 'rework')]) if workorder: for item in workorder.cnc_ids: res['Datas'].append({ 'CraftId': workorder.id, 'CraftName': workorder.name, 'SortId': item.sequence_number, 'ProgramName': item.program_name, 'ToolId': item.cutting_tool_no, 'ToolName': item.cutting_tool_name, 'Depth': item.depth_of_processing_z, 'ProgramPath': item.program_path, 'ProgramTime': item.estimated_processing_time, }) else: res = {'Succeed': False, 'ErrorCode': 203, 'Error': '暂无工单及对应的CNC程序数据'} else: res = {'Succeed': False, 'ErrorCode': 201, 'Error': '未传RfidCode字段'} except Exception as e: res = {'Succeed': False, 'ErrorCode': 202, 'Error': e} logging.info('NCProgDolod error:%s' % e) return json.JSONEncoder().encode(res) @http.route('/AutoDeviceApi/LocationChange', type='json', auth='sf_token', methods=['GET', 'POST'], csrf=False, cors="*") @api_log('库位变更', requester='中控系统') def LocationChange(self, **kw): """ 库位变更 :param kw: :return: """ logging.info('LocationChange:%s' % kw) try: res = {'Succeed': True, 'Datas': []} datas = request.httprequest.data ret = json.loads(datas) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/LocationChange'}) logging.info('库位变更LocationChange_ret:%s' % ret) RfidCode = ret['RfidCode'] ChangeType = ret['ChangeType'] OldDeciveId = ret['OldDeciveId'] OldPosition = ret['OldPosition'] NewDeciveId = ret['NewDeciveId'] NewPosition = ret['NewPosition'] OldDeciveStart = ret['OldDeciveStart'] OldDeciveEnd = ret['OldDeciveEnd'] if ChangeType == 'Part': temp_val_sn_id = None old_localtion = None # if ChangeType == 'Part' or ChangeType == 'Tool': stock_lot_obj = request.env['stock.lot'].sudo().search( [('rfid', '=', RfidCode)], limit=1) logging.info('stock_lot_obj===========:%s' % stock_lot_obj) if not stock_lot_obj: res = {'Succeed': False, 'ErrorCode': 202, 'Error': '未根据RfidCode找到该产品'} return json.JSONEncoder().encode(res) if OldPosition: old_localtion = request.env['sf.shelf.location'].sudo().search( [('barcode', '=', OldPosition)], limit=1) logging.info('old_localtion===========:%s' % old_localtion) new_localtion = request.env['sf.shelf.location'].sudo().search( [('barcode', '=', NewPosition)], limit=1) logging.info('new_localtion===========:%s' % new_localtion) if not new_localtion: res = {'Succeed': False, 'ErrorCode': 202, 'Error': '没有该目标位置'} return json.JSONEncoder().encode(res) if old_localtion: temp_val_sn_id = old_localtion.product_sn_id logging.info('temp_val_sn_id===========:%s' % temp_val_sn_id) old_localtion.product_sn_id = None new_localtion.product_sn_id = temp_val_sn_id logging.info('====1======') else: new_localtion.product_sn_id = stock_lot_obj.id logging.info('=====2======') elif ChangeType == 'Tool': # 对功能刀具库位变更信息进行更改 def write_tool(DeciveId): if 'Tool' in DeciveId: shelfinfo = list(filter(lambda x: x.get('DeviceId') == DeciveId, request.env['sf.shelf.location'].sudo().get_sf_shelf_location_info( DeciveId))) request.env['sf.shelf.location.datasync'].sudo().set_shelf_location(shelfinfo) else: equipment_id = request.env['maintenance.equipment'].sudo().search([('name', '=', DeciveId)]) if equipment_id: equipment_id.sudo().register_equipment_tool() else: res_1 = {'Succeed': False, 'ErrorCode': 202, 'Error': f'设备【{DeciveId}】不存在'} return json.JSONEncoder().encode(res_1) if OldDeciveId: write_tool(OldDeciveId) elif NewDeciveId: write_tool(NewDeciveId) except Exception as e: res = {'Succeed': False, 'ErrorCode': 202, 'Error': e} logging.info('LocationChange error:%s' % e) return json.JSONEncoder().encode(res) @http.route('/AutoDeviceApi/AGVToProduct', type='json', auth='none', methods=['GET', 'POST'], csrf=False, cors="*") @api_log('AGV运送上产线', requester='中控系统') def AGVToProduct(self, **kw): """ AGV运送上产线（完成） :param kw: :return: """ logging.info('AGVToProduct:%s' % kw) try: res = {'Succeed': True} datas = request.httprequest.data ret = json.loads(datas) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/AGVToProduct'}) logging.info('ret:%s' % ret) if 'DeviceId' in ret: logging.info('DeviceId:%s' % ret['DeviceId']) if 'IsComplete' in ret: rfid_codes = [] workorder_ids = [] if ret['IsComplete'] is True or ret['IsComplete'] is False: for i in range(1, 5): logging.info('F-RfidCode:%s' % i) if f'RfidCode{i}' in ret: rfid_code = ret[f'RfidCode{i}'] logging.info('RfidCode:%s' % rfid_code) if rfid_code is not None and rfid_code != '': rfid_codes.append(rfid_code) domain = [ ('rfid_code', '=', rfid_code), ('routing_type', '=', 'CNC加工'), ('state', '!=', 'rework') ] workorder = request.env['mrp.workorder'].sudo().search(domain, order='id asc') if workorder: for order in workorder: workorder_ids.append(order.id) if order.production_line_state == '待上产线': logging.info( '工单产线状态:%s' % order.production_line_state) panel_workorder = request.env['mrp.workorder'].sudo().search( [('rfid_code', '=', rfid_code), ('state', '!=', 'rework'), ('processing_panel', '=', order.processing_panel)]) if panel_workorder: panel_workorder.write({'production_line_state': '已上产线'}) # workpiece_delivery = request.env['sf.workpiece.delivery'].sudo().search( # [ # ('rfid_code', '=', rfid_code), ('type', '=', '上产线'), # ('production_id', '=', order.production_id.id), # ('workorder_id', '=', order.id), # ('workorder_state', '=', 'done')]) # if workpiece_delivery.status == '待下发': # workpiece_delivery.write({'is_manual_work': True}) # 下发 else: res = {'Succeed': False, 'ErrorCode': 204, 'Error': 'DeviceId为%s没有对应的已配送工件数据' % ret['DeviceId']} if ret['IsComplete'] is True: # 向AGV任务调度下发运送空料架任务 workorders = request.env['mrp.workorder'].browse(workorder_ids) request.env['sf.agv.scheduling'].add_scheduling(ret['DeviceId'], '运送空料架', workorders) else: res = {'Succeed': False, 'ErrorCode': 203, 'Error': '未传IsComplete字段'} else: res = {'Succeed': False, 'ErrorCode': 201, 'Error': '未传DeviceId字段'} except RepeatTaskException as e: logging.info('AGVToProduct error:%s' % e) except Exception as e: res = {'Succeed': False, 'ErrorCode': 202, 'Error': str(e)} logging.info('AGVToProduct error:%s' % e) return json.JSONEncoder().encode(res) @http.route('/AutoDeviceApi/AGVDownProduct', type='json', auth='none', methods=['GET', 'POST'], csrf=False, cors="*") @api_log('AGV运送下产线', requester='中控系统') def AGVDownProduct(self, **kw): """ MES调度AGV，搬运零件AGV托盘到产线接驳站。 生产线接受到零件AGV托盘到位信号后，把生产合格或特采的零件，机器人搬运零件到AGV接驳站中，触发AGV运送下产线接口。 :param kw: :return: """ logging.info('AGVDownProduct:%s' % kw) try: res = {'Succeed': True} datas = request.httprequest.data ret = json.loads(datas) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/AGVDownProduct'}) logging.info('ret:%s' % ret) if 'DeviceId' in ret: logging.info('DeviceId:%s' % ret['DeviceId']) # delivery_Arr = [] workorder_ids = [] if 'IsComplete' in ret: if ret['IsComplete'] is True or ret['IsComplete'] is False: for i in range(1, 5): logging.info('F-RfidCode:%s' % i) if f'RfidCode{i}' in ret: rfid_code = ret[f'RfidCode{i}'] logging.info('RfidCode:%s' % rfid_code) if rfid_code is not None and rfid_code != '': domain = [ ('rfid_code', '=', rfid_code), ('routing_type', '=', 'CNC加工'), ('state', '!=', 'rework') ] workorder = request.env['mrp.workorder'].sudo().search(domain, order='id asc') if workorder: for order in workorder: workorder_ids.append(order.id) if order.production_line_state == '已上产线': logging.info( '工单产线状态:%s' % order.production_line_state) panel_workorder = request.env['mrp.workorder'].sudo().search( [('rfid_code', '=', rfid_code), ('state', '!=', 'rework'), ('processing_panel', '=', order.processing_panel)]) if panel_workorder: panel_workorder.write({'production_line_state': '已下产线'}) workorder.write({'state': 'to be detected'}) workorder.check_ids.filtered( lambda ch: ch.quality_state == 'waiting').write( {'quality_state': 'none'}) else: res = {'Succeed': False, 'ErrorCode': 204, 'Error': 'DeviceId为%s没有对应的已配送工件数据' % ret['DeviceId']} # if delivery_Arr: # logging.info('delivery_Arr:%s' % delivery_Arr) # delivery_workpiece = request.env['sf.workpiece.delivery'].sudo().search( # [('id', 'in', delivery_Arr)]) # if delivery_workpiece: # logging.info('开始向agv下发下产线任务') # agv_site = request.env['sf.agv.site'].sudo().search([]) # if agv_site: # has_site = agv_site.update_site_state() # if has_site is True: # is_free = delivery_workpiece._check_avgsite_state() # if is_free is True: # delivery_workpiece._delivery_avg() # logging.info('agv下发下产线任务下发完成') if ret['IsComplete'] is True: # 向AGV任务调度下发下产线任务 workorders = request.env['mrp.workorder'].browse(workorder_ids) request.env['sf.agv.scheduling'].add_scheduling(ret['DeviceId'], '下产线', workorders) else: res = {'Succeed': False, 'ErrorCode': 203, 'Error': '未传IsComplete字段'} except RepeatTaskException as e: logging.info('AGVToProduct error:%s' % e) except Exception as e: res = {'Succeed': False, 'ErrorCode': 202, 'Error': str(e)} logging.info('AGVDownProduct error:%s' % e) return json.JSONEncoder().encode(res) @http.route('/AutoDeviceApi/EquipmentBaseCoordinate', type='json', auth='sf_token', methods=['GET', 'POST'], csrf=False, cors="*") def PutEquipmentBaseCoordinate(self, **kw): """ 获取机床基坐标 :param kw: :return: """ logging.info('PutEquipmentBaseCoordinate:%s' % kw) try: res = {'Succeed': True} datas = request.httprequest.data ret = json.loads(datas) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/EquipmentBaseCoordinate'}) if 'DeviceId' in ret: equipment = request.env['maintenance.equipment'].sudo().search('name', '=', ret['DeviceId']) if equipment: equipment.sudo().write({ 'base_coordinate_fixture_model_id': ret['base_coordinate_fixture_model_id'], 'base_coordinate_g_coordinate': ret['base_coordinate_g_coordinate'], 'base_coordinate_x': ret['base_coordinate_x'], 'base_coordinate_y': ret['base_coordinate_y'], 'base_coordinate_z': ret['base_coordinate_z'], }) else: res = {'Succeed': False, 'ErrorCode': 203, 'Error': 'DeviceId为%s的设备不存在！' % ret['DeviceId']} else: res = {'Succeed': False, 'ErrorCode': 201, 'Error': '未传DeviceId字段'} except Exception as e: res = {'Succeed': False, 'ErrorCode': 202, 'Error': e} logging.info('AGVDownProduct error:%s' % e) return json.JSONEncoder().encode(res) @http.route('/AutoDeviceApi/AgvStationState', type='json', auth='public', methods=['GET', 'POST'], csrf=False, cors="*") def AGVStationState(self, **kw): """ 中控推送接驳站状态 :param kw: :return: """ logging.info('AGVStationState:%s' % kw) try: res = {'Succeed': True} datas = request.httprequest.data ret = json.loads(datas) request.env['center_control.interface.log'].sudo().create( {'content': ret, 'name': 'AutoDeviceApi/AGVStationState'}) logging.info('ret:%s' % ret) ret = ret['param'] params = {} for i in range(len(ret)): if 'DeviceId' in ret[i] and 'AtHome' in ret[i]: logging.info('DeviceId:%s, AtHome:%s' % (ret[i]['DeviceId'], ret[i]['AtHome'])) params[ret[i]['DeviceId']] = '占用' if ret[i]['AtHome'] else '空闲' if params: request.env['sf.agv.site'].update_site_state(params) except Exception as e: res = {'Succeed': False, 'ErrorCode': 202, 'Error': str(e)} logging.info('AGVDownProduct error:%s' % e) return json.JSONEncoder().encode(res)