707 lines
34 KiB
Python
707 lines
34 KiB
Python
# -*- coding: utf-8 -*-
|
||
import os
|
||
import json
|
||
import base64
|
||
import logging
|
||
from io import BytesIO
|
||
from zipfile import ZipFile
|
||
from datetime import datetime, timedelta
|
||
import requests
|
||
from odoo.http import request
|
||
from odoo import fields, models, api
|
||
from odoo.exceptions import UserError
|
||
from odoo.addons.sf_machine_connect.models import py2opcua, ftp_operate
|
||
|
||
_logger = logging.getLogger(__name__)
|
||
|
||
|
||
# ----------------------------------------------------------
|
||
# Models for client
|
||
# ----------------------------------------------------------
|
||
|
||
class FtpButton(models.Model):
|
||
_inherit = 'sf.cnc.processing'
|
||
|
||
user_permissions = fields.Boolean(string='权限', related='workorder_id.user_permissions')
|
||
state = fields.Selection(string='状态', related='workorder_id.state')
|
||
|
||
@api.onchange('users_ids')
|
||
def get_user_permissions(self):
|
||
uid = self.env.uid
|
||
for workorder in self:
|
||
if workorder.users_ids:
|
||
list_user_id = []
|
||
for item in workorder.users_ids:
|
||
list_user_id.append(item.id)
|
||
if uid in list_user_id:
|
||
workorder.user_permissions = True
|
||
else:
|
||
workorder.user_permissions = False
|
||
else:
|
||
workorder.user_permissions = False
|
||
|
||
def up(self):
|
||
"""
|
||
此函数用于将NC代码下发到机床
|
||
:return:
|
||
"""
|
||
# 点击下发按钮自动补偿三元检测偏差值
|
||
|
||
try:
|
||
try:
|
||
if self.sequence_number == '1':
|
||
self.check_compensation_before_up()
|
||
except Exception:
|
||
raise UserError("补偿值写入执行超时，请检查机床状态或者写入状态")
|
||
|
||
# host="192.168.2.158", port=8080, username="MITSUBISHI", password="CNC"
|
||
host = self.workorder_id.equipment_id.ftp_host
|
||
port = self.workorder_id.equipment_id.ftp_port
|
||
username = self.workorder_id.equipment_id.ftp_num
|
||
pwd = self.workorder_id.equipment_id.ftp_pwd
|
||
remote_path = self.workorder_id.equipment_id.ftp_remote_path
|
||
print(host, port, username, pwd, remote_path)
|
||
ftp = ftp_operate.FtpController(host, port, username, pwd)
|
||
# ftp.delAllfile('C://Users//马广威//Desktop//ftp')
|
||
a = self.cnc_id
|
||
datas = base64.standard_b64decode(a.datas)
|
||
|
||
# file_path = '{}\{}\{}'.format(a._filestore(), a.store_fname.split('/'[0]), a.display_name)
|
||
file_path_local = '{}/{}'.format('/nc2machine', a.display_name)
|
||
# file_path_remote = '{}\{}'.format('//M80(192,168,2,142)//DS', a.display_name)
|
||
file_path_remote = '{}\{}'.format(remote_path, a.display_name)
|
||
|
||
with open(file_path_local, mode='wb+') as file:
|
||
file.write(datas)
|
||
# 存在本地的文件下发到机床
|
||
ftp.upload_file(remotepath=file_path_remote, localpath=file_path_local)
|
||
_logger.info("======%s下发成功======" % a.display_name)
|
||
ftp.close_ftp()
|
||
|
||
up_time = str(datetime.now() + timedelta(hours=8))
|
||
self.env['delivery.record'].create({
|
||
'workorder_id': self.workorder_id.id,
|
||
'delivery_type': '单个下发',
|
||
'delivery_time': up_time,
|
||
'influence_record': self.sequence_number,
|
||
})
|
||
# self.workorder_id.delivery_records.sudo().create({
|
||
# 'delivery_type': '单个下发',
|
||
# 'delivery_time': 'up_time',
|
||
# 'influence_record': 'self.sequence_number',
|
||
# })
|
||
except Exception as e:
|
||
_logger.info("=====================================", e)
|
||
raise UserError('NC下发执行超时, 请检查下发状态')
|
||
|
||
# 补偿下发都执行完毕后，按钮标志位变为true
|
||
self.button_state = True
|
||
|
||
def check_compensation_before_up(self):
|
||
"""
|
||
下发NC代码前自动补偿三元检测偏差值
|
||
:return:
|
||
"""
|
||
hongbianliang550 = self.workorder_id.equipment_id.x_compensation_node
|
||
hongbianliang551 = self.workorder_id.equipment_id.y_compensation_node
|
||
try:
|
||
temp_dict = {}
|
||
temp_dict[hongbianliang550] = self.workorder_id.compensation_value_x
|
||
temp_dict[hongbianliang551] = self.workorder_id.compensation_value_y
|
||
temp = py2opcua.Py2opcua()
|
||
temp.write(temp_dict)
|
||
except Exception as e:
|
||
_logger.info("=====================================", e)
|
||
raise UserError('补偿值获取失败，或机床未连接，请检查')
|
||
|
||
|
||
class Machine_ftp(models.Model):
|
||
"""
|
||
数据采集类
|
||
"""
|
||
_inherit = 'maintenance.equipment'
|
||
|
||
# 机床首次上线时间(默认取值2024年08月01日零点)
|
||
|
||
def _get_default_online_time(self):
|
||
return datetime(2024, 1, 1, 0, 0, 0)
|
||
|
||
first_online_time = fields.Datetime(string='首次上线时间', default=_get_default_online_time)
|
||
|
||
# workorder_ids = fields.One2many('mrp.workorder', 'machine_tool_id', string='工单')
|
||
|
||
# # 机床配置项目
|
||
# # ftp相关
|
||
# ftp_num = fields.Char('ftp账号')
|
||
# ftp_pwd = fields.Char('ftp密码')
|
||
# ftp_host = fields.Char('ftp地址')
|
||
# ftp_port = fields.Integer('ftp端口')
|
||
# ftp_remote_path = fields.Char('机床ftp路径')
|
||
# # 补偿值写入相关
|
||
# x_compensation_node = fields.Char('x补偿值节点')
|
||
# y_compensation_node = fields.Char('y补偿值节点')
|
||
# # 数采配置相关
|
||
# machine_ip = fields.Char('机床IP')
|
||
# machine_signed = fields.Char('机床刷新间隔')
|
||
# machine_status = fields.Char('机床在线状态')
|
||
# machine_cnc_type = fields.Char('机床CNC型号')
|
||
# machine_axis_count = fields.Char('机床轴总数')
|
||
# machine_run_status = fields.Char('机床运行状态')
|
||
# machine_emg_status = fields.Char('机床急停状态')
|
||
# machine_cut_status = fields.Char('机床当前切削状态')
|
||
# machine_mode = fields.Char('机床当前操作模式')
|
||
# machine_spindle_load = fields.Char('机床主轴负载')
|
||
# machine_x_mach = fields.Char('机床X轴机械坐标')
|
||
# machine_x_abs_mach = fields.Char('机床X轴当前位置')
|
||
# machine_x_rel_mach = fields.Char('机床X轴相对工件坐标')
|
||
# machine_x_dis_mach = fields.Char('机床X轴目标距离')
|
||
# machine_x_axis_load = fields.Char('机床X轴伺服轴负载')
|
||
# machine_y_mach = fields.Char('机床Y轴机械坐标')
|
||
# machine_y_abs_mach = fields.Char('机床Y轴当前位置')
|
||
# machine_y_rel_mach = fields.Char('机床Y轴相对工件坐标')
|
||
# machine_y_dis_mach = fields.Char('机床Y轴目标距离')
|
||
# machine_y_axis_load = fields.Char('机床Y轴伺服轴负载')
|
||
# machine_z_mach = fields.Char('机床Z轴机械坐标')
|
||
# machine_z_abs_mach = fields.Char('机床Z轴当前位置')
|
||
# machine_z_rel_mach = fields.Char('机床Z轴相对工件坐标')
|
||
# machine_z_dis_mach = fields.Char('机床Z轴目标距离')
|
||
# machine_z_axis_load = fields.Char('机床Z轴伺服轴负载')
|
||
# machine_tool_num = fields.Char('机床当前刀位号')
|
||
# machine_program = fields.Char('机床主程序名称')
|
||
# machine_current_prg = fields.Char('机床当前执行指令')
|
||
# machine_prg_seq = fields.Char('机床当前执行语句号')
|
||
# machine_spindle_speed_set = fields.Char('机床设定主轴速度')
|
||
# machine_act_spindle_speed = fields.Char('机床实际主轴转速')
|
||
# machine_feed_speed_set = fields.Char('机床设定进给速度')
|
||
# machine_act_feed_speed = fields.Char('机床实际进给速度')
|
||
# machine_spindle_feed = fields.Char('机床主轴倍率')
|
||
# machine_feed_rate = fields.Char('机床进给倍率')
|
||
# machine_rapid_feed = fields.Char('机床快速移动倍率')
|
||
# machine_run_time = fields.Char('机床运行时间')
|
||
# machine_cut_time = fields.Char('机床切削时间')
|
||
# machine_keep_alive_time = fields.Char('机床上电时间')
|
||
# machine_circle_time = fields.Char('机床循环时间')
|
||
# machine_product_counts = fields.Char('机床加工件数')
|
||
# machine_system_date = fields.Char('机床系统日期')
|
||
# machine_system_time = fields.Char('机床系统时间')
|
||
# machine_alarm_msg = fields.Char('机床系统报警')
|
||
|
||
# # 刀位配置
|
||
# tool_num1 = fields.Char('刀位1')
|
||
# tool_num2 = fields.Char('刀位2')
|
||
# tool_num3 = fields.Char('刀位3')
|
||
# tool_num4 = fields.Char('刀位4')
|
||
# tool_num5 = fields.Char('刀位5')
|
||
# tool_num6 = fields.Char('刀位6')
|
||
# tool_num7 = fields.Char('刀位7')
|
||
# tool_num8 = fields.Char('刀位8')
|
||
# tool_num9 = fields.Char('刀位9')
|
||
# tool_num10 = fields.Char('刀位10')
|
||
# tool_num11 = fields.Char('刀位11')
|
||
# tool_num12 = fields.Char('刀位12')
|
||
# tool_num13 = fields.Char('刀位13')
|
||
# tool_num14 = fields.Char('刀位14')
|
||
# tool_num15 = fields.Char('刀位15')
|
||
# tool_num16 = fields.Char('刀位16')
|
||
# tool_num17 = fields.Char('刀位17')
|
||
# tool_num18 = fields.Char('刀位18')
|
||
# tool_num19 = fields.Char('刀位19')
|
||
# tool_num20 = fields.Char('刀位20')
|
||
# tool_num21 = fields.Char('刀位21')
|
||
# tool_num22 = fields.Char('刀位22')
|
||
# tool_num23 = fields.Char('刀位23')
|
||
# tool_num24 = fields.Char('刀位24')
|
||
|
||
# 机床采集项目
|
||
timestamp = fields.Datetime('时间戳', readonly=True)
|
||
status = fields.Boolean('机床在线状态', readonly=True)
|
||
# run_status = fields.Selection([('0', '空闲中'), ('1', '加工中'), ('2', '加工中'), ('3', '加工中')], string='机床运行状态',
|
||
# readonly=True, default='0')
|
||
run_status = fields.Char('机床运行状态', readonly=True)
|
||
run_time = fields.Char('机床累计运行时长', readonly=True)
|
||
# 机床系统日期
|
||
system_date = fields.Char('机床系统日期', readonly=True)
|
||
# 机床系统时间
|
||
system_time = fields.Char('机床系统时间', readonly=True)
|
||
cut_time = fields.Char('机床累计切削时间', readonly=True)
|
||
# cut_status = fields.Selection([('0', '未切削'), ('1', '切削中'), ('2', '切削中'), ('3', '切削中')], string='机床当前切削状态',
|
||
# readonly=True, default='0')
|
||
cut_status = fields.Char('机床当前切削状态', readonly=True)
|
||
# 当前程序名
|
||
program = fields.Char('机床当前程序', readonly=True)
|
||
# 当前刀具号
|
||
tool_num = fields.Integer('机床当前刀具号', readonly=True)
|
||
# 机床通电开机时间, 机床加工件数, 机床当前操作模式, 开始加工时间, 结束加工时间, 加工程序开始时间, 加工程序结束时间, 待机开始时间,
|
||
# 待机结束时间, 机床离线开始时间, 机床离线结束时间, 机床急停状态, 机床主程序名称, 程序运行的状态, 机床当前执行指令, 机床当前执行语句号
|
||
# 机床X轴当前位置, 机床Y轴当前位置, 机床Z轴当前位置
|
||
machine_power_on_time = fields.Char('机床通电开机时间', readonly=True)
|
||
product_counts = fields.Char('机床加工件数', readonly=True)
|
||
mode = fields.Char('机床当前操作模式', readonly=True)
|
||
start_time = fields.Char('开始加工时间', readonly=True)
|
||
end_time = fields.Char('结束加工时间', readonly=True)
|
||
program_start_time = fields.Char('加工程序开始时间', readonly=True)
|
||
program_end_time = fields.Char('加工程序结束时间', readonly=True)
|
||
standby_start_time = fields.Char('待机开始时间', readonly=True)
|
||
standby_end_time = fields.Char('待机结束时间', readonly=True)
|
||
offline_start_time = fields.Char('机床离线开始时间', readonly=True)
|
||
offline_end_time = fields.Char('机床离线结束时间', readonly=True)
|
||
emg_status = fields.Char('机床急停状态', readonly=True)
|
||
program_name = fields.Char('机床主程序名称', readonly=True)
|
||
program_status = fields.Char('程序运行状态', readonly=True)
|
||
current_program = fields.Char('机床当前执行指令', readonly=True)
|
||
current_program_seq = fields.Char('机床当前执行语句号', readonly=True)
|
||
x_abs_pos = fields.Char('机床X轴当前位置(mm)', readonly=True)
|
||
y_abs_pos = fields.Char('机床Y轴当前位置(mm)', readonly=True)
|
||
z_abs_pos = fields.Char('机床Z轴当前位置(mm)', readonly=True)
|
||
|
||
# 机床设定进给速度, 机床实际进给速度, 机床设定主轴转速, 机床实际主轴转速, 机床主轴负载, 机床X轴伺服轴负载, 机床Y轴伺服轴负载
|
||
# 机床Z轴伺服轴负载, 机床快速移动倍率, 机床进给倍率, 机床X轴机械坐标, 机床Y轴机械坐标, 机床Z轴机械坐标, 机床X轴相对工件坐标
|
||
# 机床Y轴相对工件坐标, 机床Z轴相对工件坐标, 机床X轴目标距离, 机床Y轴目标距离, 机床Z轴目标距离
|
||
feed_speed_set = fields.Char('机床设定进给速度(mm/min)', readonly=True)
|
||
act_feed_speed = fields.Char('机床实际进给速度(mm/min)', readonly=True)
|
||
spindle_speed_set = fields.Char('机床设定主轴转速(r/min)', readonly=True)
|
||
act_spindle_speed = fields.Char('机床实际主轴转速(r/min)', readonly=True)
|
||
spindle_load = fields.Char('机床主轴负载(%)', readonly=True)
|
||
x_axis_load = fields.Char('机床X轴伺服轴负载(%)', readonly=True)
|
||
y_axis_load = fields.Char('机床Y轴伺服轴负载(%)', readonly=True)
|
||
z_axis_load = fields.Char('机床Z轴伺服轴负载(%)', readonly=True)
|
||
rapid_feed = fields.Char('机床快速移动倍率(%)', readonly=True)
|
||
feed_rate = fields.Char('机床进给倍率(%)', readonly=True)
|
||
x_mach_coord = fields.Char('机床X轴机械坐标(mm)', readonly=True)
|
||
y_mach_coord = fields.Char('机床Y轴机械坐标(mm)', readonly=True)
|
||
z_mach_coord = fields.Char('机床Z轴机械坐标(mm)', readonly=True)
|
||
x_rel_coord = fields.Char('机床X轴相对工件坐标(mm)', readonly=True)
|
||
y_rel_coord = fields.Char('机床Y轴相对工件坐标(mm)', readonly=True)
|
||
z_rel_coord = fields.Char('机床Z轴相对工件坐标(mm)', readonly=True)
|
||
x_dis_coord = fields.Char('机床X轴目标距离(mm)', readonly=True)
|
||
y_dis_coord = fields.Char('机床Y轴目标距离(mm)', readonly=True)
|
||
z_dis_coord = fields.Char('机床Z轴目标距离(mm)', readonly=True)
|
||
|
||
# 故障报警时间, 故障报警信息, 故障消除时间(复原时间)
|
||
alarm_time = fields.Char('故障报警时间', readonly=True)
|
||
alarm_msg = fields.Char('故障报警信息', readonly=True)
|
||
clear_time = fields.Char('故障消除时间(复原时间)', readonly=True)
|
||
|
||
# # 开动率
|
||
run_rate = fields.Char('开动率', readonly=True)
|
||
|
||
# 同步CNC设备到oee
|
||
def sync_oee(self):
|
||
"""
|
||
同步CNC设备到oee
|
||
:return:
|
||
"""
|
||
for record in self:
|
||
record.ensure_one()
|
||
cnc_oee_dict = {
|
||
'equipment_id': record.id,
|
||
'type_id': record.type_id.id,
|
||
'machine_tool_picture': record.machine_tool_picture,
|
||
'equipment_code': record.code,
|
||
'function_type': record.function_type,
|
||
}
|
||
if self.env['maintenance.equipment.oee.logs'].search([('equipment_id', '=', record.id)]):
|
||
self.env['maintenance.equipment.oee.logs'].write(cnc_oee_dict)
|
||
else:
|
||
self.env['maintenance.equipment.oee.logs'].create(cnc_oee_dict)
|
||
|
||
|
||
class WorkCenterBarcode(models.Model):
|
||
"""
|
||
扫码托盘码可查到制造订单，由制造订单查工单
|
||
"""
|
||
_inherit = "mrp.workorder"
|
||
|
||
# barcode = fields.Binary(string='条码', default='UP-ALL')
|
||
compensation_value_x = fields.Float(string='X轴补偿值')
|
||
compensation_value_y = fields.Float(string='Y轴补偿值')
|
||
button_compensation_state = fields.Boolean(string='是否已经补偿', readonly=True)
|
||
button_up_all_state = fields.Boolean(string='是否已经全部下发', readonly=True)
|
||
machine_tool_id = fields.Many2one('sf.machine_tool.type', string='机床')
|
||
# machine_tool_name = fields.Char(string='机床名称', default='未知机床', compute='_run_info', readonly=True)
|
||
# machine_tool_type_id = fields.Char(string='机床型号', default='未知型号', compute='_run_info', readonly=True)
|
||
# machine_tool_status = fields.Boolean(string='在线状态', compute='_run_info', readonly=True)
|
||
# machine_tool_run_status = fields.Selection([('0', '关机中'), ('1', '加工中'), ('2', '加工中'), ('3', '加工中')],
|
||
# string='运行状态', compute='_run_info', readonly=True, default='0')
|
||
# machine_tool_timestamp = fields.Datetime('时间戳', compute='_run_info', readonly=True)
|
||
# machine_tool_time_on = fields.Char('总在线时长', compute='_run_info', readonly=True)
|
||
# machine_tool_time_on_now = fields.Char('本次在线时长', compute='_run_info', readonly=True)
|
||
# machine_tool_tool_num = fields.Integer('当前刀具', compute='_run_info', readonly=True)
|
||
# machine_tool_program = fields.Char('当前程序', compute='_run_info', readonly=True)
|
||
# machine_tool_machine_ip = fields.Char('机床IP', compute='_run_info', readonly=True)
|
||
# machine_tool_cut_status = fields.Selection([('0', '未切削'), ('1', '切削中'), ('2', '切削中'), ('3', '切削中')],
|
||
# string='切削状态', compute='_run_info', readonly=True, default='0')
|
||
# machine_tool_compensation_value_x = fields.Char('x补偿值', compute='_run_info', readonly=True)
|
||
# machine_tool_compensation_value_y = fields.Char('y补偿值', compute='_run_info', readonly=True)
|
||
|
||
machine_tool_name = fields.Char(string='机床名称', default='未知机床', readonly=True)
|
||
machine_tool_type_id = fields.Char(string='机床型号', default='未知型号', readonly=True)
|
||
machine_tool_status = fields.Boolean(string='在线状态', readonly=True)
|
||
machine_tool_run_status = fields.Selection([('0', '关机中'), ('1', '加工中'), ('2', '加工中'), ('3', '加工中')],
|
||
string='运行状态', readonly=True, default='0')
|
||
machine_tool_timestamp = fields.Datetime('时间戳', readonly=True)
|
||
machine_tool_time_on = fields.Char('总在线时长', readonly=True)
|
||
machine_tool_time_on_now = fields.Char('本次在线时长', readonly=True)
|
||
machine_tool_tool_num = fields.Integer('当前刀具', readonly=True)
|
||
machine_tool_program = fields.Char('当前程序', readonly=True)
|
||
machine_tool_machine_ip = fields.Char('机床IP', readonly=True)
|
||
machine_tool_cut_status = fields.Selection([('0', '未切削'), ('1', '切削中'), ('2', '切削中'), ('3', '切削中')],
|
||
string='切削状态', readonly=True, default='0')
|
||
machine_tool_compensation_value_x = fields.Char('x补偿值', readonly=True)
|
||
machine_tool_compensation_value_y = fields.Char('y补偿值', readonly=True)
|
||
|
||
# 工单状态
|
||
|
||
delivery_records = fields.One2many('delivery.record', 'workorder_id', string="下发记录")
|
||
|
||
@api.depends('equipment_id.timestamp')
|
||
def _run_info(self):
|
||
# self.machine_tool_name = '1号机床'
|
||
# self.machine_tool_name = self.equipment_id.name
|
||
# self.machine_tool_type_id = self.equipment_id.type_id.name
|
||
# self.machine_tool_status = self.equipment_id.status
|
||
# self.machine_tool_run_status = self.equipment_id.run_status
|
||
# self.machine_tool_timestamp = self.equipment_id.timestamp
|
||
# self.machine_tool_time_on = self.equipment_id.time_on
|
||
# self.machine_tool_time_on_now = self.equipment_id.time_on_now
|
||
# self.machine_tool_tool_num = self.equipment_id.tool_num
|
||
# self.machine_tool_program = self.equipment_id.program
|
||
# self.machine_tool_machine_ip = self.equipment_id.machine_ip
|
||
# self.machine_tool_cut_status = self.equipment_id.cut_status
|
||
# self.machine_tool_compensation_value_x = self.compensation_value_x
|
||
# self.machine_tool_compensation_value_y = self.compensation_value_y
|
||
pass
|
||
|
||
def compensation(self):
|
||
|
||
hongbianliang550 = self.equipment_id.x_compensation_node
|
||
hongbianliang551 = self.equipment_id.y_compensation_node
|
||
try:
|
||
temp_dict = {}
|
||
temp_dict[hongbianliang550] = self.compensation_value_x
|
||
temp_dict[hongbianliang551] = self.compensation_value_y
|
||
print("=================================")
|
||
print(temp_dict)
|
||
temp = py2opcua.Py2opcua()
|
||
temp.write(temp_dict)
|
||
except Exception as e:
|
||
_logger.info("=====================================", e)
|
||
raise UserError('补偿值获取失败，或机床未连接，请检查')
|
||
# 补偿执行完毕后，按钮标志位变为true
|
||
self.button_compensation_state = True
|
||
|
||
def up_all(self):
|
||
"""
|
||
此函数用于将NC代码全部下发到机床
|
||
:return:
|
||
"""
|
||
# 一键下发前删除机床上的全部程序
|
||
try:
|
||
filepath = '/nc2machine'
|
||
del_list = os.listdir(filepath)
|
||
_logger.info("=====================================%s" % del_list)
|
||
for f in del_list:
|
||
file_path = os.path.join(filepath, f)
|
||
if os.path.isfile(file_path):
|
||
os.remove(file_path)
|
||
except Exception as e:
|
||
_logger.info("=====================================", e)
|
||
raise UserError('程序删除失败，请重试')
|
||
# host="192.168.2.158", port=8080, username="MITSUBISHI", password="CNC"
|
||
try:
|
||
self.compensation()
|
||
except Exception:
|
||
raise UserError("补偿值写入执行超时，请检查机床状态或者写入状态")
|
||
sequence_collect = []
|
||
host = self.equipment_id.ftp_host
|
||
port = self.equipment_id.ftp_port
|
||
username = self.equipment_id.ftp_num
|
||
pwd = self.equipment_id.ftp_pwd
|
||
remote_path = self.equipment_id.ftp_remote_path
|
||
_logger.info("=====================1666666661111================%s,%s,%s,%s" % (host, port, username, pwd))
|
||
ftp = ftp_operate.FtpController(host, port, username, pwd)
|
||
_logger.info("=====================1777777777111================")
|
||
|
||
try:
|
||
for item in self.cnc_ids:
|
||
a = item.cnc_id
|
||
sequence_collect.append(item.sequence_number)
|
||
datas = base64.standard_b64decode(a.datas)
|
||
# file_path = '{}\{}\{}'.format(a._filestore(), a.store_fname.split('/'[0]), a.display_name)
|
||
file_path_local = '{}/{}'.format('/nc2machine', a.display_name)
|
||
# 本地测试一键下发
|
||
# file_path_local = '{}/{}'.format('D:\\jikimo', a.display_name)
|
||
# file_path_remote = '{}\{}'.format('//M80(192,168,2,142)//DS', a.display_name)
|
||
file_path_remote = '{}\{}'.format(remote_path, a.display_name)
|
||
|
||
with open(file_path_local, mode='wb+') as file:
|
||
file.write(datas)
|
||
# 存在本地的文件下发到机床
|
||
ftp.upload_file(remotepath=file_path_remote, localpath=file_path_local)
|
||
_logger.info("======%s下发成功======" % a.display_name)
|
||
item.button_state = True
|
||
ftp.close_ftp()
|
||
# 增加一键下发记录
|
||
up_time = str(datetime.now() + timedelta(hours=8))
|
||
sequence_str = ','.join(sequence_collect)
|
||
self.delivery_records.create({
|
||
'delivery_type': '一键下发',
|
||
'delivery_time': up_time,
|
||
'influence_record': sequence_str,
|
||
})
|
||
_logger.info("=====================22================")
|
||
except Exception as e:
|
||
_logger.info("=====================================", e)
|
||
raise UserError('NC下发执行超时, 请检查下发状态')
|
||
|
||
def up_merge_all(self):
|
||
"""
|
||
此函数用于将NC代码一键合并下发到机床
|
||
:return:
|
||
"""
|
||
# 一键合并下发前删除机床上的全部程序
|
||
try:
|
||
filepath = '/nc2machine'
|
||
del_list = os.listdir(filepath)
|
||
_logger.info("=====================================%s" % del_list)
|
||
for f in del_list:
|
||
file_path = os.path.join(filepath, f)
|
||
if os.path.isfile(file_path):
|
||
os.remove(file_path)
|
||
except Exception as e:
|
||
_logger.info("=====================================", e)
|
||
raise UserError('程序删除失败，请重试')
|
||
# host="192.168.2.158", port=8080, username="MITSUBISHI", password="CNC"
|
||
try:
|
||
self.compensation()
|
||
except Exception:
|
||
raise UserError("补偿值写入执行超时，请检查机床状态或者写入状态")
|
||
sequence_collect = []
|
||
host = self.equipment_id.ftp_host
|
||
port = self.equipment_id.ftp_port
|
||
username = self.equipment_id.ftp_num
|
||
pwd = self.equipment_id.ftp_pwd
|
||
remote_path = self.equipment_id.ftp_remote_path
|
||
_logger.info("=====================1666666661111================%s,%s,%s,%s" % (host, port, username, pwd))
|
||
ftp = ftp_operate.FtpController(host, port, username, pwd)
|
||
_logger.info("=====================1777777777111================")
|
||
file_path_local = ''
|
||
file_path_remote = ''
|
||
|
||
try:
|
||
# 给文件名
|
||
_logger.info('启动')
|
||
begin_name1 = self.cnc_ids[0].cnc_id.display_name.split('-')
|
||
_logger.info(begin_name1)
|
||
temp_name1 = begin_name1[-1].split('.')
|
||
final_name = '%s-ALL-MERGE.%s' % (begin_name1[0], temp_name1[-1])
|
||
_logger.info(final_name)
|
||
for item in self.cnc_ids:
|
||
a = item.cnc_id
|
||
sequence_collect.append(item.sequence_number)
|
||
datas = base64.standard_b64decode(a.datas)
|
||
# file_path = '{}\{}\{}'.format(a._filestore(), a.store_fname.split('/'[0]), a.display_name)
|
||
file_path_local = '{}/{}'.format('/nc2machine', final_name)
|
||
# 本地测试一键下发
|
||
# file_path_local = '{}/{}'.format('D:\\jikimo', a.display_name)
|
||
# file_path_remote = '{}\{}'.format('//M80(192,168,2,142)//DS', a.display_name)
|
||
file_path_remote = '{}\{}'.format(remote_path, final_name)
|
||
# 合并文件
|
||
with open(file_path_local, mode='ab+') as file:
|
||
file.write(datas)
|
||
item.button_state = True
|
||
_logger.info('========一键下发前合并成功===============')
|
||
|
||
# 去除合并文件中间部分的头尾
|
||
with open(file_path_local, mode='rb+') as f:
|
||
# _logger.info(f.read())
|
||
# content = f.read()
|
||
# _logger.info(content)
|
||
new_content = f.read().replace(b'\r\nM30\r\n%\r\n%\r\n', b'\r\n')
|
||
# _logger.info(new_content)
|
||
f.seek(0)
|
||
f.truncate()
|
||
f.write(new_content)
|
||
_logger.info('========二次合并成功===============')
|
||
|
||
# 存在本地的文件下发到机床
|
||
ftp.upload_file(remotepath=file_path_remote, localpath=file_path_local)
|
||
_logger.info("======%s一键合并下发成功======" % a.display_name)
|
||
ftp.close_ftp()
|
||
# 增加一键合并下发记录
|
||
up_time = str(datetime.now() + timedelta(hours=8))
|
||
sequence_str = ','.join(sequence_collect)
|
||
self.delivery_records.create({
|
||
'delivery_type': '一键合并下发',
|
||
'delivery_time': up_time,
|
||
'influence_record': sequence_str,
|
||
})
|
||
_logger.info("=====================22================")
|
||
except Exception as e:
|
||
for item in self.cnc_ids:
|
||
item.button_state = False
|
||
_logger.info("=====================================", e)
|
||
raise UserError('NC下发执行超时, 请检查下发状态')
|
||
|
||
def get__state(self):
|
||
# pay_time = str(datetime.now())
|
||
json = {
|
||
'params': {
|
||
'model_name': 'jikimo.process.order',
|
||
'field_name': 'name',
|
||
'default_code': 'PO-2022-1207-0020',
|
||
'state': '待付款',
|
||
# 'pay_time': pay_time,
|
||
# 'get_order_sf': 21,
|
||
},
|
||
}
|
||
# res_str = json.dumps(vals)
|
||
url = 'https://bfm.cs.jikimo.com/api/get/state'
|
||
requests.post(url, json=json, data=None)
|
||
|
||
def action_test(self, barcode=12345):
|
||
|
||
workorder_obj = self.env['mrp.workorder'].sudo().search([('tray_code', '=', barcode)])
|
||
action = {
|
||
'name': '工单',
|
||
# 'name': name,
|
||
'type': 'ir.actions.act_window',
|
||
# 'view_type': 'form',
|
||
'view_mode': 'form',
|
||
'res_model': 'mrp.workorder',
|
||
'view_id': self.env.ref('mrp.mrp_production_workorder_form_view_inherit').id,
|
||
'res_id': 1023,
|
||
'target': 'current',
|
||
'context': {'id': workorder_obj.id},
|
||
# 'flags': {'initial_mode': 'edit'},
|
||
}
|
||
return action
|
||
# result = request.env['ir.actions.act_window'].sudo().create(action).read()[0]
|
||
# action = {'action': action}
|
||
# return result
|
||
|
||
@api.model
|
||
def get_product_id_by_barcode(self, barcode, **kwargs):
|
||
print(kwargs)
|
||
print(barcode)
|
||
print('111111111111111111111')
|
||
workorder_obj_target = self.env['mrp.workorder'].sudo().search([('tray_code', '=', barcode)])
|
||
workorder_obj_current = self.env['mrp.workorder'].sudo().search([('id', '=', kwargs['current_id'])])
|
||
workorder_cnc = self.env['mrp.workorder'].sudo().search(
|
||
['&', ('production_id', '=', workorder_obj_target.production_id.id),
|
||
('name', '=', workorder_obj_current.name)])
|
||
print('222222222222222222222222')
|
||
if workorder_obj_target:
|
||
print(workorder_obj_target)
|
||
print(workorder_obj_target.id)
|
||
action = {
|
||
'name': '工单',
|
||
'type': 'ir.actions.act_window',
|
||
# 'view_type': 'form',
|
||
'views': [[False, 'form']],
|
||
'view_mode': 'form',
|
||
'res_model': 'mrp.workorder',
|
||
'view_id': request.env.ref('mrp.mrp_production_workorder_form_view_inherit').id,
|
||
'res_id': workorder_cnc.id,
|
||
'target': 'current',
|
||
'context': {'id': workorder_obj_target.id,
|
||
'clear_breadcrumbs': True, },
|
||
# 'flags': {'initial_mode': 'edit'},
|
||
}
|
||
action = {'result': action, 'error': '返回错误'}
|
||
action1 = json.dumps(action)
|
||
return action1
|
||
else:
|
||
return None
|
||
|
||
def cnc_file_download(self):
|
||
"""
|
||
一个下载当前cnc所有nc文件为一个zip包的功能
|
||
"""
|
||
self.ensure_one()
|
||
|
||
# 如果没有附件，直接返回
|
||
if not self.cnc_ids:
|
||
return None
|
||
|
||
# 处理第一个附件的文件名
|
||
first_attachment = self.cnc_ids[0].cnc_id
|
||
file_name = first_attachment.display_name.split('-')[0] + '.zip'
|
||
|
||
# 创建一个内存文件和一个zip文件
|
||
memory_file = BytesIO()
|
||
with ZipFile(memory_file, 'w') as zipf:
|
||
# 遍历需要下载的附件
|
||
for item in self.cnc_ids:
|
||
a = item.cnc_id
|
||
datas = base64.standard_b64decode(a.datas)
|
||
|
||
# 将nc文件写入zip文件
|
||
zipf.writestr(a.display_name, datas)
|
||
|
||
# 然后可以创建一个ir.attachment对象，将生成的zip文件保存为一个新的附件
|
||
memory_file.seek(0)
|
||
output = base64.b64encode(memory_file.read())
|
||
memory_file.close()
|
||
|
||
attachment_data = {
|
||
'name': file_name,
|
||
'type': 'binary',
|
||
'res_model': self._name,
|
||
'res_id': self.id,
|
||
'datas': output
|
||
}
|
||
attachment = self.env['ir.attachment'].create(attachment_data)
|
||
|
||
# 返回附件的下载链接
|
||
download_url = '/web/content/%s?download=true' % attachment.id
|
||
base_url = self.env['ir.config_parameter'].sudo().get_param('web.base.url')
|
||
return {
|
||
'type': 'ir.actions.act_url',
|
||
'url': str(base_url) + download_url,
|
||
'target': 'self',
|
||
}
|
||
|
||
|
||
# class CuttingTimeToolType(models.Model):
|
||
# _inherit = 'sf.cutting_tool.type'
|
||
# total_cut_time = fields.Char(string='总切削时长')
|
||
# predict_life_time = fields.Char(string='预估寿命')
|
||
# # 只能看到未被占用的刀位，或者有提示说占没占用
|
||
# tool_position = fields.Char(string='选择刀位')
|
||
# # cnc_ids = fields.One2many(string='选择机床')
|
||
# is_connect_tool_position = fields.Boolean(string='是否已绑定刀位', default=False)
|
||
#
|
||
# def tool_connect_machine(self):
|
||
# pass
|
||
#
|
||
# def tool_unconnect_machine(self):
|
||
# pass
|
||
|
||
|
||
class DeliveryRecord(models.Model):
|
||
"""
|
||
扫码托盘码可查到制造订单，由制造订单查工单
|
||
"""
|
||
_name = "delivery.record"
|
||
_description = "Delivery Record"
|
||
|
||
delivery_type = fields.Char(string='下发方式', readonly=True)
|
||
delivery_time = fields.Char(string='下发时间', readonly=True)
|
||
influence_record = fields.Char(string='影响记录', readonly=True)
|
||
workorder_id = fields.Many2one('mrp.workorder', string='工单')
|
||
sf_cnc_processing_id = fields.Many2one('sf.cnc.processing', string='NC')
|
||
|
||
# @api.model
|
||
# def create(self, values):
|
||
# try:
|
||
# values['order_code'] = self.env['ir.sequence'].next_by_code('sf_machine_connect.delivery.record')
|
||
# stock = self.env['sunrise.u.stock']
|
||
# if 'order_items' in values.keys():
|
||
# for item in values['order_items']:
|
||
# stock_commodity = stock.search([('commodity', '=', item[2]['commodity'])])
|
||
# stock_commodity.amount += item[2]['amount']
|
||
# return super().create(values)
|
||
# except:
|
||
# raise Exception('b_purchase_order.py:create()')
|