Compare commits
70 Commits
feature/66
...
feature/制造
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
65c67775fa | ||
|
|
8f2d214854 | ||
|
|
699e03ccda | ||
|
|
8f0ade7b43 | ||
|
|
50bc8786e8 | ||
|
|
0777e63bc7 | ||
|
|
128bebf338 | ||
|
|
7a71077aa7 | ||
|
|
10a1d43a17 | ||
|
|
87d351e9e9 | ||
|
|
d2daae1a8f | ||
|
|
5997c24895 | ||
|
|
df53989f22 | ||
|
|
9bab687080 | ||
|
|
a5ac8b8b84 | ||
|
|
2cde398e11 | ||
|
|
88026fea5d | ||
|
|
443a21a0cc | ||
|
|
e14646a6fc | ||
|
|
6a920be6d1 | ||
|
|
3811079a7f | ||
|
|
ad8e0b6af0 | ||
|
|
04cb910803 | ||
|
|
42292818af | ||
|
|
bcafd9cf38 | ||
|
|
12ebd87f1d | ||
|
|
bdef852b98 | ||
|
|
1d5fb747d4 | ||
|
|
8116e4f97d | ||
|
|
e3e5fcc378 | ||
|
|
879b5492db | ||
|
|
27b9a4f982 | ||
|
|
94007bae2b | ||
|
|
bf92028027 | ||
|
|
2b47e566d3 | ||
|
|
5aa2f1aa18 | ||
|
|
b7128ba81a | ||
|
|
49546f9d08 | ||
|
|
6959bd9a09 | ||
|
|
3a2babf2d5 | ||
|
|
d7d094c84d | ||
|
|
a06e24583d | ||
|
|
0cbd830901 | ||
|
|
4b29def105 | ||
|
|
582abb3f2e | ||
|
|
40137ba69c | ||
|
|
804f6a82b4 | ||
|
|
d16d47dfbe | ||
|
|
41cf9d5474 | ||
|
|
59aa6b4f10 | ||
|
|
a759106fdc | ||
|
|
8bb101c6b2 | ||
|
|
f02044b513 | ||
|
|
3d937b85c9 | ||
|
|
5a61b3b459 | ||
|
|
afccb5ee6a | ||
|
|
2b0648d9bc | ||
|
|
8ea3487044 | ||
|
|
b24ed5fe4c | ||
|
|
b801b265c3 | ||
|
|
27a67167fe | ||
|
|
8fa9534b4e | ||
|
|
db745e46b6 | ||
|
|
f598b6c71c | ||
|
|
dccb0b3fb0 | ||
|
|
83feb78f43 | ||
|
|
ac09794b10 | ||
|
|
3f88b11a18 | ||
|
|
b97acfb181 | ||
|
|
bff0ff9401 |
2
jikimo_printing/__init__.py
Normal file
2
jikimo_printing/__init__.py
Normal file
@@ -0,0 +1,2 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
from . import models
|
||||
18
jikimo_printing/__manifest__.py
Normal file
18
jikimo_printing/__manifest__.py
Normal file
@@ -0,0 +1,18 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
{
|
||||
'name': '机企猫 打印模块',
|
||||
'version': '1.0',
|
||||
'summary': """ 包含机台二维码,程序单打印等 """,
|
||||
'author': '机企猫',
|
||||
'website': 'https://www.jikimo.com',
|
||||
'category': '机企猫',
|
||||
'depends': ['sf_manufacturing', 'sf_maintenance', 'base_report_to_printer'],
|
||||
'data': [
|
||||
'views/maintenance_views.xml',
|
||||
],
|
||||
|
||||
'application': True,
|
||||
'installable': True,
|
||||
'auto_install': False,
|
||||
'license': 'LGPL-3',
|
||||
}
|
||||
5
jikimo_printing/models/__init__.py
Normal file
5
jikimo_printing/models/__init__.py
Normal file
@@ -0,0 +1,5 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
from . import jikimo_printing
|
||||
from . import maintenance_printing
|
||||
from . import workorder_printing
|
||||
|
||||
56
jikimo_printing/models/jikimo_printing.py
Normal file
56
jikimo_printing/models/jikimo_printing.py
Normal file
@@ -0,0 +1,56 @@
|
||||
from io import BytesIO
|
||||
import qrcode
|
||||
from reportlab.pdfgen import canvas
|
||||
from reportlab.lib.pagesizes import A4
|
||||
from PIL import Image
|
||||
from reportlab.lib.utils import ImageReader
|
||||
from odoo import models, fields, api
|
||||
|
||||
class JikimoPrinting(models.AbstractModel):
|
||||
_name = 'jikimo.printing'
|
||||
|
||||
def print_qr_code(self, data):
|
||||
"""
|
||||
打印二维码
|
||||
"""
|
||||
# 生成二维码
|
||||
qr = qrcode.QRCode(version=1, box_size=10, border=5)
|
||||
qr.add_data(data)
|
||||
qr.make(fit=True)
|
||||
qr_image = qr.make_image(fill_color="black", back_color="white")
|
||||
|
||||
# 将PIL Image转换为reportlab可用的格式
|
||||
temp_image = BytesIO()
|
||||
qr_image.save(temp_image, format="PNG")
|
||||
temp_image.seek(0)
|
||||
|
||||
# 创建PDF
|
||||
pdf_buffer = BytesIO()
|
||||
c = canvas.Canvas(pdf_buffer, pagesize=A4)
|
||||
|
||||
# 计算位置
|
||||
a4_width, a4_height = A4
|
||||
qr_width = 200
|
||||
qr_height = 200
|
||||
x = (a4_width - qr_width) / 2
|
||||
y = (a4_height - qr_height) / 2
|
||||
|
||||
# 直接从BytesIO绘制图片
|
||||
c.drawImage(ImageReader(Image.open(temp_image)), x, y, width=qr_width, height=qr_height)
|
||||
c.save()
|
||||
|
||||
# 获取PDF内容并打印
|
||||
pdf_content = pdf_buffer.getvalue()
|
||||
printer = self.env['printing.printer'].get_default()
|
||||
printer.print_document(report=None, content=pdf_content, doc_format='pdf')
|
||||
|
||||
# 清理资源
|
||||
pdf_buffer.close()
|
||||
temp_image.close()
|
||||
|
||||
def print_pdf(self, pdf_data):
|
||||
"""
|
||||
打印PDF
|
||||
"""
|
||||
printer = self.env['printing.printer'].get_default()
|
||||
printer.print_document(report=None, content = pdf_data, doc_format='pdf')
|
||||
69
jikimo_printing/models/maintenance_printing.py
Normal file
69
jikimo_printing/models/maintenance_printing.py
Normal file
@@ -0,0 +1,69 @@
|
||||
from odoo import models, fields, api
|
||||
|
||||
class MaintenancePrinting(models.Model):
|
||||
_inherit = 'maintenance.equipment'
|
||||
|
||||
def print_single_method(self):
|
||||
|
||||
print('self.name========== %s' % self.name)
|
||||
self.ensure_one()
|
||||
# maintenance_equipment_id = self.id
|
||||
# # host = "192.168.50.110" # 可以根据实际情况修改
|
||||
# # port = 9100 # 可以根据实际情况修改
|
||||
|
||||
# # 获取默认打印机配置
|
||||
# printer_config = self.env['printer.configuration'].sudo().search([('model', '=', self._name)], limit=1)
|
||||
# if not printer_config:
|
||||
# raise UserError('请先配置打印机')
|
||||
# host = printer_config.printer_id.ip_address
|
||||
# port = printer_config.printer_id.port
|
||||
# self.print_qr_code(maintenance_equipment_id, host, port)
|
||||
|
||||
# 切换成A4打印机
|
||||
|
||||
try:
|
||||
self.env['jikimo.printing'].print_qr_code(self.MTcode)
|
||||
except Exception as e:
|
||||
raise UserError(f"打印失败: {str(e)}")
|
||||
|
||||
|
||||
# def generate_zpl_code(self, code):
|
||||
# """生成ZPL代码用于打印二维码标签
|
||||
# Args:
|
||||
# code: 需要编码的内容
|
||||
# Returns:
|
||||
# str: ZPL指令字符串
|
||||
# """
|
||||
# zpl_code = "^XA\n" # 开始ZPL格式
|
||||
|
||||
# # 设置打印参数
|
||||
# zpl_code += "^LH0,0\n" # 设置标签起始位置
|
||||
# zpl_code += "^CI28\n" # 设置中文编码
|
||||
# zpl_code += "^PW400\n" # 设置打印宽度为400点
|
||||
# zpl_code += "^LL300\n" # 设置标签长度为300点
|
||||
|
||||
# # 打印标题
|
||||
# zpl_code += "^FO10,20\n" # 设置标题位置
|
||||
# zpl_code += "^A0N,30,30\n" # 设置字体大小
|
||||
# zpl_code += "^FD机床二维码^FS\n" # 打印标题文本
|
||||
|
||||
# # 打印二维码
|
||||
# zpl_code += "^FO50,60\n" # 设置二维码位置
|
||||
# zpl_code += f"^BQN,2,8\n" # 设置二维码参数:模式2,放大倍数8
|
||||
# zpl_code += f"^FDLA,{code}^FS\n" # 二维码内容
|
||||
|
||||
# # 打印编码文本
|
||||
# zpl_code += "^FO50,220\n" # 设置编码文本位置
|
||||
# zpl_code += "^A0N,25,25\n" # 设置字体大小
|
||||
# zpl_code += f"^FD编码: {code}^FS\n" # 打印编码文本
|
||||
|
||||
# # 打印日期
|
||||
# zpl_code += "^FO50,260\n"
|
||||
# zpl_code += "^A0N,20,20\n"
|
||||
# zpl_code += f"^FD打印日期: {fields.Date.today()}^FS\n"
|
||||
|
||||
# zpl_code += "^PQ1\n" # 打印1份
|
||||
# zpl_code += "^XZ\n" # 结束ZPL格式
|
||||
|
||||
# return zpl_code
|
||||
|
||||
@@ -1,8 +1,6 @@
|
||||
|
||||
import logging
|
||||
from io import BytesIO
|
||||
from odoo import models, fields, api
|
||||
from odoo.exceptions import UserError
|
||||
|
||||
_logger = logging.getLogger(__name__)
|
||||
|
||||
@@ -21,9 +19,7 @@ class MrpWorkorder(models.Model):
|
||||
if pdf_data:
|
||||
try:
|
||||
# 执行打印
|
||||
printer = self.env['printing.printer'].get_default()
|
||||
printer.print_document(report=None, content = pdf_data, doc_format='pdf')
|
||||
|
||||
self.env['jikimo.printing'].print_pdf(pdf_data)
|
||||
wo.production_id.product_id.is_print_program = True
|
||||
_logger.info(f"工单 {wo.name} 的PDF已成功打印")
|
||||
|
||||
19
jikimo_printing/views/maintenance_views.xml
Normal file
19
jikimo_printing/views/maintenance_views.xml
Normal file
@@ -0,0 +1,19 @@
|
||||
<?xml version="1.0"?>
|
||||
<odoo>
|
||||
<record id="sf_maintenance_equipment_view_form_qrcode_print" model="ir.ui.view">
|
||||
<field name="name">sf_equipment.form</field>
|
||||
<field name="model">maintenance.equipment</field>
|
||||
<field name="inherit_id" ref="sf_maintenance.sf_hr_equipment_view_form"/>
|
||||
<field name="arch" type="xml">
|
||||
<xpath expr="//field[@name='qr_code_image']" position="after">
|
||||
<label for="print_single_method"/>
|
||||
<div class="col-12 col-lg-6 o_setting_box" style="white-space: nowrap">
|
||||
<button type="object" class="oe_highlight" name='print_single_method' string="打印机床二维码"
|
||||
attrs="{'invisible': [('equipment_type', '!=', '机床')]}"/>
|
||||
</div>
|
||||
</xpath>
|
||||
</field>
|
||||
</record>
|
||||
</odoo>
|
||||
|
||||
|
||||
@@ -32,6 +32,7 @@ class PurchaseRequestLineMakePurchaseOrder(models.TransientModel):
|
||||
line.company_id,
|
||||
line.request_id.origin,
|
||||
)
|
||||
# po_data.update({'related_product':line.related_product.id})
|
||||
purchase = purchase_obj.create(po_data)
|
||||
|
||||
# Look for any other PO line in the selected PO with same
|
||||
@@ -63,6 +64,8 @@ class PurchaseRequestLineMakePurchaseOrder(models.TransientModel):
|
||||
po_line_data = self._prepare_purchase_order_line(purchase, item)
|
||||
if item.keep_description:
|
||||
po_line_data["name"] = item.name
|
||||
if line.related_product:
|
||||
po_line_data.update({'related_product': line.related_product.id})
|
||||
po_line = po_line_obj.create(po_line_data)
|
||||
po_line_product_uom_qty = po_line.product_uom._compute_quantity(
|
||||
po_line.product_uom_qty, alloc_uom
|
||||
|
||||
@@ -8,7 +8,6 @@
|
||||
'category': 'sf',
|
||||
'depends': ['base', 'sf_maintenance', 'jikimo_mini_program'],
|
||||
'data': [
|
||||
|
||||
],
|
||||
|
||||
'application': True,
|
||||
|
||||
@@ -1,21 +1,30 @@
|
||||
import json
|
||||
from odoo import http
|
||||
from odoo.http import request
|
||||
from odoo.addons.sf_machine_connect.models.ftp_operate import transfer_nc_files
|
||||
from odoo.addons.sf_machine_connect.models.ftp_operate import transfer_files
|
||||
from odoo.addons.sf_base.decorators.api_log import api_log
|
||||
|
||||
class MainController(http.Controller):
|
||||
|
||||
@http.route('/api/manual_download_program', type='json', methods=['POST'], auth='public', cors='*')
|
||||
@api_log('人工线下加工编程文件传输', requester='报工系统')
|
||||
def manual_download_program(self):
|
||||
"""
|
||||
人工线下加工传输编程文件
|
||||
"""
|
||||
data = json.loads(request.httprequest.data)
|
||||
maintenance_equipment_name = data.get('maintenance_equipment_name')
|
||||
maintenance_equipment_id = data.get('maintenance_equipment_id')
|
||||
model_id = data.get('model_id')
|
||||
if not maintenance_equipment_name or not model_id:
|
||||
if not maintenance_equipment_id or not model_id:
|
||||
return {'code': 400, 'message': '参数错误'}
|
||||
maintenance_equipment = request.env['maintenance.equipment'].sudo().search([('name', '=', maintenance_equipment_name)], limit=1)
|
||||
try:
|
||||
model_id = int(model_id)
|
||||
except Exception as e:
|
||||
return {'code': 400, 'message': '参数类型错误'}
|
||||
maintenance_equipment = request.env['maintenance.equipment'].sudo().search(
|
||||
[('MTcode', '=', maintenance_equipment_id), ('category_id.equipment_type', '=', '机床')],
|
||||
limit=1
|
||||
)
|
||||
if not maintenance_equipment:
|
||||
return {'code': 400, 'message': '机台不存在,请扫描正确的机台二维码'}
|
||||
product = request.env['product.template'].sudo().search([('model_id', '=', model_id)], limit=1)
|
||||
@@ -45,15 +54,15 @@ class MainController(http.Controller):
|
||||
}
|
||||
# 传输nc文件
|
||||
try:
|
||||
result = transfer_nc_files(
|
||||
result = transfer_files(
|
||||
source_ftp_info,
|
||||
target_ftp_info,
|
||||
'/' + str(model_id),
|
||||
'/',
|
||||
match_str=r'^\d*_\d*-' + tool_groups_id.name + r'-\w{2}-all\.nc$'
|
||||
)
|
||||
if result:
|
||||
return {'code': 200, 'message': 'success'}
|
||||
if len(result) > 0:
|
||||
return {'code': 200, 'message': '传输成功', 'file_list': result}
|
||||
else:
|
||||
return {'code': 404, 'message': '未找到编程文件'}
|
||||
except Exception as e:
|
||||
|
||||
@@ -141,7 +141,7 @@ class QualityCheck(models.Model):
|
||||
# # 出厂检验报告编号
|
||||
# report_number = fields.Char('出厂检验报告编号', compute='_compute_report_number', readonly=True)
|
||||
# 总数量,值为调拨单_产品明细_数量
|
||||
total_qty = fields.Char('总数量', compute='_compute_total_qty')
|
||||
total_qty = fields.Char('总数量', compute='_compute_total_qty', readonly=False, store=True)
|
||||
|
||||
column_nums = fields.Integer('测量值列数', default=1)
|
||||
|
||||
@@ -281,7 +281,42 @@ class QualityCheck(models.Model):
|
||||
"""
|
||||
pass
|
||||
|
||||
def check_total_quality(self):
|
||||
"""
|
||||
校验总数量是否等于拣货数量
|
||||
"""
|
||||
for record in self:
|
||||
if record.picking_id:
|
||||
for move in record.picking_id.move_ids_without_package:
|
||||
if move.product_id == record.product_id:
|
||||
picking_qty = int(move.product_uom_qty)
|
||||
if int(record.total_qty) != picking_qty:
|
||||
return True
|
||||
return False
|
||||
|
||||
def do_publish(self):
|
||||
"""打开二次确认弹窗"""
|
||||
self.ensure_one()
|
||||
if self.check_total_quality():
|
||||
return self._show_confirmation_wizard()
|
||||
else:
|
||||
return self._do_actual_publish()
|
||||
|
||||
def _show_confirmation_wizard(self):
|
||||
"""显示确认向导的通用方法"""
|
||||
return {
|
||||
'name': _('发布确认'),
|
||||
'type': 'ir.actions.act_window',
|
||||
'res_model': 'quality.check.publish.wizard',
|
||||
'view_mode': 'form',
|
||||
'target': 'new',
|
||||
'context': {
|
||||
'default_check_id': self.id,
|
||||
# 其他默认字段...
|
||||
}
|
||||
}
|
||||
|
||||
def _do_actual_publish(self):
|
||||
"""发布出厂检验报告"""
|
||||
self.ensure_one()
|
||||
self._check_part_number()
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
from odoo import api, fields, models, _
|
||||
|
||||
|
||||
class QualityCheckPublishWizard(models.TransientModel):
|
||||
_name = 'quality.check.publish.wizard'
|
||||
_description = '质检报告发布确认'
|
||||
@@ -12,7 +13,8 @@ class QualityCheckPublishWizard(models.TransientModel):
|
||||
measure_count = fields.Integer('测量件数', readonly=True)
|
||||
item_count = fields.Integer('检验项目数', readonly=True)
|
||||
old_report_name = fields.Char('旧出厂检验报告编号', readonly=True)
|
||||
publish_status = fields.Selection([('draft', '草稿'), ('published', '已发布'), ('canceled', '已撤销')], string='发布状态', readonly=True)
|
||||
publish_status = fields.Selection([('draft', '草稿'), ('published', '已发布'), ('canceled', '已撤销')], string='发布状态',
|
||||
readonly=True)
|
||||
|
||||
def action_confirm_publish(self):
|
||||
"""确认发布"""
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
from . import models
|
||||
from . import commons
|
||||
from . import controllers
|
||||
from . import decorators
|
||||
|
||||
@@ -25,7 +25,7 @@
|
||||
'views/menu_fixture_view.xml',
|
||||
'views/change_base_view.xml',
|
||||
'views/Printer.xml',
|
||||
|
||||
'views/api_log_views.xml',
|
||||
],
|
||||
'demo': [
|
||||
],
|
||||
|
||||
@@ -1,10 +1,11 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
import logging
|
||||
import json
|
||||
import base64
|
||||
import logging
|
||||
from odoo import http
|
||||
from odoo.http import request
|
||||
|
||||
_logger = logging.getLogger(__name__)
|
||||
|
||||
class Manufacturing_Connect(http.Controller):
|
||||
|
||||
|
||||
1
sf_base/decorators/__init__.py
Normal file
1
sf_base/decorators/__init__.py
Normal file
@@ -0,0 +1 @@
|
||||
from . import api_log
|
||||
59
sf_base/decorators/api_log.py
Normal file
59
sf_base/decorators/api_log.py
Normal file
@@ -0,0 +1,59 @@
|
||||
|
||||
import functools
|
||||
import json
|
||||
import logging
|
||||
from datetime import datetime
|
||||
from odoo.http import request
|
||||
|
||||
_logger = logging.getLogger(__name__)
|
||||
|
||||
def api_log(name=None, requester=None):
|
||||
"""记录API请求日志的装饰器"""
|
||||
def decorator(func):
|
||||
@functools.wraps(func)
|
||||
def wrapper(*args, **kwargs):
|
||||
start_time = datetime.now()
|
||||
|
||||
# 获取请求信息
|
||||
try:
|
||||
# 获取请求数据
|
||||
request_data = json.loads(request.httprequest.data) if request.httprequest.data else {}
|
||||
# 获取请求路径
|
||||
path = request.httprequest.path
|
||||
# 获取请求方法
|
||||
method = request.httprequest.method
|
||||
# 获取客户端IP
|
||||
remote_addr = request.httprequest.remote_addr
|
||||
|
||||
# 执行原始函数
|
||||
result = func(*args, **kwargs)
|
||||
|
||||
# 计算响应时间
|
||||
end_time = datetime.now()
|
||||
response_time = (end_time - start_time).total_seconds()
|
||||
|
||||
# 创建日志记录
|
||||
log_vals = {
|
||||
'name': name or func.__name__,
|
||||
'path': path,
|
||||
'method': method,
|
||||
'request_data': json.dumps(request_data, ensure_ascii=False),
|
||||
'response_data': json.dumps(result, ensure_ascii=False),
|
||||
'remote_addr': remote_addr,
|
||||
'response_time': response_time,
|
||||
'status': result.get('code', 500),
|
||||
'requester': requester,
|
||||
'responser': '智能工厂'
|
||||
}
|
||||
|
||||
# 异步创建日志记录
|
||||
request.env['api.request.log'].sudo().with_context(tracking_disable=True).create(log_vals)
|
||||
|
||||
return result
|
||||
|
||||
except Exception as e:
|
||||
_logger.error(f"API日志记录失败: {str(e)}")
|
||||
# 即使日志记录失败,也要返回原始结果
|
||||
return func(*args, **kwargs)
|
||||
return wrapper
|
||||
return decorator
|
||||
@@ -6,3 +6,4 @@ from . import functional_fixture
|
||||
from . import tool_other_features
|
||||
from . import basic_parameters_fixture
|
||||
from . import ir_sequence
|
||||
from . import api_log
|
||||
|
||||
18
sf_base/models/api_log.py
Normal file
18
sf_base/models/api_log.py
Normal file
@@ -0,0 +1,18 @@
|
||||
from odoo import models, fields, api
|
||||
|
||||
|
||||
class ApiRequestLog(models.Model):
|
||||
_name = 'api.request.log'
|
||||
_description = '接口请求日志'
|
||||
_order = 'id desc'
|
||||
|
||||
name = fields.Char('接口名称')
|
||||
path = fields.Char('请求路径')
|
||||
method = fields.Char('请求方法')
|
||||
request_data = fields.Text('请求数据')
|
||||
response_data = fields.Text('响应数据')
|
||||
remote_addr = fields.Char('客户端IP')
|
||||
response_time = fields.Float('响应时间(秒)', digits=(16, 6))
|
||||
status = fields.Integer('状态码')
|
||||
requester = fields.Char('请求方')
|
||||
responser = fields.Char('响应方')
|
||||
@@ -254,3 +254,6 @@ access_sf_machining_accuracy_admin,sf_machining_accuracy_admin,model_sf_machinin
|
||||
|
||||
access_sf_embryo_redundancy,sf_embryo_redundancy,model_sf_embryo_redundancy,base.group_user,1,0,0,0
|
||||
access_sf_embryo_redundancy_admin,sf_embryo_redundancy_admin,model_sf_embryo_redundancy,base.group_system,1,0,0,0
|
||||
|
||||
access_api_request_log_user,api.request.log.user,model_api_request_log,base.group_user,1,0,0,0
|
||||
access_api_request_log_admin,api.request.log.admin,model_api_request_log,base.group_system,1,1,1,1
|
||||
|
62
sf_base/views/api_log_views.xml
Normal file
62
sf_base/views/api_log_views.xml
Normal file
@@ -0,0 +1,62 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<odoo>
|
||||
<record id="view_api_request_log_tree" model="ir.ui.view">
|
||||
<field name="name">api.request.log.tree</field>
|
||||
<field name="model">api.request.log</field>
|
||||
<field name="arch" type="xml">
|
||||
<tree>
|
||||
<field name="create_date"/>
|
||||
<field name="name"/>
|
||||
<field name="path"/>
|
||||
<field name="method"/>
|
||||
<field name="remote_addr"/>
|
||||
<field name="response_time"/>
|
||||
<field name="status"/>
|
||||
</tree>
|
||||
</field>
|
||||
</record>
|
||||
|
||||
<record id="view_api_request_log_form" model="ir.ui.view">
|
||||
<field name="name">api.request.log.form</field>
|
||||
<field name="model">api.request.log</field>
|
||||
<field name="arch" type="xml">
|
||||
<form>
|
||||
<sheet>
|
||||
<group>
|
||||
<group>
|
||||
<field name="name"/>
|
||||
<field name="path"/>
|
||||
<field name="method"/>
|
||||
<field name="remote_addr"/>
|
||||
</group>
|
||||
<group>
|
||||
<field name="response_time"/>
|
||||
<field name="status"/>
|
||||
<field name="create_date" string="请求时间"/>
|
||||
</group>
|
||||
</group>
|
||||
<notebook>
|
||||
<page string="请求数据">
|
||||
<field name="request_data"/>
|
||||
</page>
|
||||
<page string="响应数据">
|
||||
<field name="response_data"/>
|
||||
</page>
|
||||
</notebook>
|
||||
</sheet>
|
||||
</form>
|
||||
</field>
|
||||
</record>
|
||||
|
||||
<record id="action_api_request_log" model="ir.actions.act_window">
|
||||
<field name="name">API请求日志</field>
|
||||
<field name="res_model">api.request.log</field>
|
||||
<field name="view_mode">tree,form</field>
|
||||
</record>
|
||||
|
||||
<menuitem id="menu_api_request_log"
|
||||
name="API请求日志"
|
||||
parent="base.next_id_9"
|
||||
action="action_api_request_log"
|
||||
sequence="100"/>
|
||||
</odoo>
|
||||
@@ -1298,10 +1298,7 @@ class Sf_Dashboard_Connect(http.Controller):
|
||||
conn = psycopg2.connect(**db_config)
|
||||
# 获取请求的机床数据
|
||||
machine_list = ast.literal_eval(kw['machine_list'])
|
||||
time_threshold = datetime.now() - timedelta(days=1)
|
||||
|
||||
alarm_last_24_time = 0.0
|
||||
alarm_all_time = 0.0
|
||||
time_threshold = datetime.now().replace(hour=0, minute=0, second=0, microsecond=0)
|
||||
|
||||
def fetch_result_as_dict(cursor):
|
||||
"""辅助函数:将查询结果转为字典"""
|
||||
@@ -1311,6 +1308,9 @@ class Sf_Dashboard_Connect(http.Controller):
|
||||
# 获取当前时间的时间戳
|
||||
current_timestamp = datetime.now().timestamp()
|
||||
for item in machine_list:
|
||||
alarm_last_24_time = 0.0
|
||||
alarm_all_time = 0.0
|
||||
|
||||
euipment_obj = request.env['maintenance.equipment'].sudo().search([('code', '=', item)])
|
||||
# 机床上线时间段
|
||||
first_online_duration = current_timestamp - euipment_obj.first_online_time.timestamp()
|
||||
@@ -1327,8 +1327,8 @@ class Sf_Dashboard_Connect(http.Controller):
|
||||
cur.execute("""
|
||||
SELECT * FROM device_data
|
||||
WHERE device_name = %s
|
||||
AND device_state in ('待机', '警告', '运行中') AND time >= %s AND process_time IS NOT NULL
|
||||
ORDER BY time ASC
|
||||
AND device_state in ('待机', '警告', '运行中') AND time <= %s AND process_time IS NOT NULL
|
||||
ORDER BY time DESC
|
||||
LIMIT 1;
|
||||
""", (item, time_threshold))
|
||||
last_24_time = fetch_result_as_dict(cur)
|
||||
@@ -1348,20 +1348,21 @@ class Sf_Dashboard_Connect(http.Controller):
|
||||
alarm_last_24_nums = []
|
||||
with conn.cursor() as cur:
|
||||
cur.execute("""
|
||||
SELECT DISTINCT ON (alarm_start_time) alarm_time, alarm_start_time
|
||||
SELECT DISTINCT ON (alarm_start_time, alarm_time) alarm_time, alarm_start_time
|
||||
FROM device_data
|
||||
WHERE device_name = %s
|
||||
AND alarm_start_time IS NOT NULL AND time >= %s;
|
||||
AND alarm_start_time IS NOT NULL AND alarm_start_time::timestamp >= %s;
|
||||
""", (item, time_threshold))
|
||||
results = cur.fetchall()
|
||||
logging.info("results============:%s" % results)
|
||||
for result in results:
|
||||
alarm_last_24_nums.append(result[1])
|
||||
if result[0]:
|
||||
if float(result[0]) >= 28800:
|
||||
continue
|
||||
alarm_last_24_time += float(result[0])
|
||||
alarm_last_24_time = float(result[0])
|
||||
else:
|
||||
alarm_last_24_time += 0.0
|
||||
alarm_last_24_time = 0.0
|
||||
|
||||
alarm_all_nums = []
|
||||
with conn.cursor() as cur:
|
||||
|
||||
@@ -9,8 +9,12 @@ _logger = logging.getLogger(__name__)
|
||||
|
||||
class FTP_P(FTP):
|
||||
"""
|
||||
重写FTP类,重写dirs方法
|
||||
重写FTP类,重写dirs方法,增加编码处理
|
||||
"""
|
||||
def __init__(self, host='', user='', passwd='', acct='', timeout=None, encoding='gbk'):
|
||||
"""初始化时指定编码方式"""
|
||||
super().__init__(host, user, passwd, acct, timeout)
|
||||
self.encoding = encoding
|
||||
|
||||
def dirs(self, *args):
|
||||
"""List a directory in long form.
|
||||
@@ -32,7 +36,50 @@ class FTP_P(FTP):
|
||||
tempdic['name'] = [file for file in r_files if file != "." and file != ".."]
|
||||
# 去除. ..
|
||||
return tempdic
|
||||
# return [file for file in r_files if file != "." and file != ".."]
|
||||
|
||||
def nlst(self, *args):
|
||||
"""Get a list of files in a directory."""
|
||||
files = []
|
||||
def append(line):
|
||||
try:
|
||||
if isinstance(line, bytes):
|
||||
files.append(line.decode(self.encoding))
|
||||
else:
|
||||
files.append(line)
|
||||
except UnicodeDecodeError:
|
||||
files.append(line.decode('utf-8', errors='replace'))
|
||||
cmd = 'NLST'
|
||||
if args:
|
||||
cmd = cmd + ' ' + args[0]
|
||||
self.retrlines(cmd, append)
|
||||
return files
|
||||
|
||||
def cwd(self, dirname):
|
||||
"""Change to a directory."""
|
||||
try:
|
||||
if isinstance(dirname, bytes):
|
||||
dirname = dirname.decode(self.encoding)
|
||||
return super().cwd(dirname)
|
||||
except UnicodeEncodeError:
|
||||
return super().cwd(dirname.encode(self.encoding).decode('utf-8'))
|
||||
|
||||
def storbinary(self, cmd, fp, blocksize=8192, callback=None, rest=None):
|
||||
"""Store a file in binary mode."""
|
||||
try:
|
||||
if isinstance(cmd, bytes):
|
||||
cmd = cmd.decode(self.encoding)
|
||||
return super().storbinary(cmd, fp, blocksize, callback, rest)
|
||||
except UnicodeEncodeError:
|
||||
return super().storbinary(cmd.encode(self.encoding).decode('utf-8'), fp, blocksize, callback, rest)
|
||||
|
||||
def retrbinary(self, cmd, callback, blocksize=8192, rest=None):
|
||||
"""Retrieve a file in binary mode."""
|
||||
try:
|
||||
if isinstance(cmd, bytes):
|
||||
cmd = cmd.decode(self.encoding)
|
||||
return super().retrbinary(cmd, callback, blocksize, rest)
|
||||
except UnicodeEncodeError:
|
||||
return super().retrbinary(cmd.encode(self.encoding).decode('utf-8'), callback, blocksize, rest)
|
||||
|
||||
|
||||
# FTP接口类
|
||||
@@ -133,7 +180,7 @@ class FtpController:
|
||||
|
||||
|
||||
|
||||
def transfer_nc_files(
|
||||
def transfer_files(
|
||||
source_ftp_info,
|
||||
target_ftp_info,
|
||||
source_dir,
|
||||
@@ -151,7 +198,7 @@ def transfer_nc_files(
|
||||
target_dir: str, 目标FTP上的目标目录
|
||||
keep_dir: bool, 是否保持目录结构,默认False
|
||||
"""
|
||||
trans_status = [False]
|
||||
transfered_file_list = []
|
||||
try:
|
||||
# 连接源FTP
|
||||
source_ftp = FtpController(
|
||||
@@ -217,7 +264,7 @@ def transfer_nc_files(
|
||||
with open(temp_path, 'rb') as f:
|
||||
target_ftp.ftp.storbinary(f'STOR {target_path}', f)
|
||||
|
||||
trans_status[0] = True
|
||||
transfered_file_list.append(item)
|
||||
# 删除临时文件
|
||||
os.remove(temp_path)
|
||||
logging.info(f"已传输文件: {item}")
|
||||
@@ -259,7 +306,7 @@ def transfer_nc_files(
|
||||
traverse_dir(source_dir)
|
||||
|
||||
logging.info("所有文件传输完成")
|
||||
return trans_status[0]
|
||||
return transfered_file_list
|
||||
|
||||
except Exception as e:
|
||||
logging.error(f"传输过程出错: {str(e)}")
|
||||
|
||||
@@ -4,4 +4,3 @@ from . import sf_maintenance_oee
|
||||
from . import sf_maintenance_logs
|
||||
from . import sf_equipment_maintenance_standards
|
||||
from . import sf_maintenance_requests
|
||||
from . import maintenance_printer
|
||||
|
||||
@@ -1,92 +0,0 @@
|
||||
import qrcode
|
||||
import base64
|
||||
from io import BytesIO
|
||||
from odoo import models, fields, api
|
||||
|
||||
class MaintenanceEquipment(models.Model):
|
||||
_name = 'maintenance.equipment'
|
||||
_inherit = ['maintenance.equipment', 'printing.utils']
|
||||
|
||||
qr_code_image = fields.Binary(string='二维码', compute='_generate_qr_code')
|
||||
|
||||
@api.depends('name')
|
||||
def _generate_qr_code(self):
|
||||
for record in self:
|
||||
# Generate QR code
|
||||
qr = qrcode.QRCode(
|
||||
version=1,
|
||||
error_correction=qrcode.constants.ERROR_CORRECT_L,
|
||||
box_size=10,
|
||||
border=4,
|
||||
)
|
||||
qr.add_data(record.name)
|
||||
qr.make(fit=True)
|
||||
qr_image = qr.make_image(fill_color="black", back_color="white")
|
||||
|
||||
# Encode the image data in base64
|
||||
image_stream = BytesIO()
|
||||
qr_image.save(image_stream, format="PNG")
|
||||
encoded_image = base64.b64encode(image_stream.getvalue())
|
||||
|
||||
record.qr_code_image = encoded_image
|
||||
|
||||
def print_single_method(self):
|
||||
|
||||
print('self.name========== %s' % self.name)
|
||||
self.ensure_one()
|
||||
qr_code_data = self.qr_code_image
|
||||
if not qr_code_data:
|
||||
raise UserError("没有找到二维码数据。")
|
||||
maintenance_equipment_name = self.name
|
||||
# host = "192.168.50.110" # 可以根据实际情况修改
|
||||
# port = 9100 # 可以根据实际情况修改
|
||||
|
||||
# 获取默认打印机配置
|
||||
printer_config = self.env['printer.configuration'].sudo().search([('model', '=', self._name)], limit=1)
|
||||
if not printer_config:
|
||||
raise UserError('请先配置打印机')
|
||||
host = printer_config.printer_id.ip_address
|
||||
port = printer_config.printer_id.port
|
||||
self.print_qr_code(maintenance_equipment_name, host, port)
|
||||
|
||||
|
||||
def generate_zpl_code(self, code):
|
||||
"""生成ZPL代码用于打印二维码标签
|
||||
Args:
|
||||
code: 需要编码的内容
|
||||
Returns:
|
||||
str: ZPL指令字符串
|
||||
"""
|
||||
zpl_code = "^XA\n" # 开始ZPL格式
|
||||
|
||||
# 设置打印参数
|
||||
zpl_code += "^LH0,0\n" # 设置标签起始位置
|
||||
zpl_code += "^CI28\n" # 设置中文编码
|
||||
zpl_code += "^PW400\n" # 设置打印宽度为400点
|
||||
zpl_code += "^LL300\n" # 设置标签长度为300点
|
||||
|
||||
# 打印标题
|
||||
zpl_code += "^FO10,20\n" # 设置标题位置
|
||||
zpl_code += "^A0N,30,30\n" # 设置字体大小
|
||||
zpl_code += "^FD机床二维码^FS\n" # 打印标题文本
|
||||
|
||||
# 打印二维码
|
||||
zpl_code += "^FO50,60\n" # 设置二维码位置
|
||||
zpl_code += f"^BQN,2,8\n" # 设置二维码参数:模式2,放大倍数8
|
||||
zpl_code += f"^FDLA,{code}^FS\n" # 二维码内容
|
||||
|
||||
# 打印编码文本
|
||||
zpl_code += "^FO50,220\n" # 设置编码文本位置
|
||||
zpl_code += "^A0N,25,25\n" # 设置字体大小
|
||||
zpl_code += f"^FD编码: {code}^FS\n" # 打印编码文本
|
||||
|
||||
# 打印日期
|
||||
zpl_code += "^FO50,260\n"
|
||||
zpl_code += "^A0N,20,20\n"
|
||||
zpl_code += f"^FD打印日期: {fields.Date.today()}^FS\n"
|
||||
|
||||
zpl_code += "^PQ1\n" # 打印1份
|
||||
zpl_code += "^XZ\n" # 结束ZPL格式
|
||||
|
||||
return zpl_code
|
||||
|
||||
@@ -2,6 +2,8 @@
|
||||
import json
|
||||
import base64
|
||||
import logging
|
||||
import qrcode
|
||||
from io import BytesIO
|
||||
from datetime import timedelta
|
||||
import requests
|
||||
from odoo.addons.sf_base.commons.common import Common
|
||||
@@ -831,6 +833,29 @@ class SfMaintenanceEquipment(models.Model):
|
||||
ftp_username = fields.Char('FTP 用户名')
|
||||
ftp_password = fields.Char('FTP 密码')
|
||||
|
||||
qr_code_image = fields.Binary(string='二维码', compute='_generate_qr_code')
|
||||
|
||||
@api.depends('name')
|
||||
def _generate_qr_code(self):
|
||||
for record in self:
|
||||
# Generate QR code
|
||||
qr = qrcode.QRCode(
|
||||
version=1,
|
||||
error_correction=qrcode.constants.ERROR_CORRECT_L,
|
||||
box_size=10,
|
||||
border=4,
|
||||
)
|
||||
qr.add_data(record.MTcode)
|
||||
qr.make(fit=True)
|
||||
qr_image = qr.make_image(fill_color="black", back_color="white")
|
||||
|
||||
# Encode the image data in base64
|
||||
image_stream = BytesIO()
|
||||
qr_image.save(image_stream, format="PNG")
|
||||
encoded_image = base64.b64encode(image_stream.getvalue())
|
||||
|
||||
record.qr_code_image = encoded_image
|
||||
|
||||
|
||||
class SfRobotAxisNum(models.Model):
|
||||
_name = 'sf.robot.axis.num'
|
||||
|
||||
@@ -1055,11 +1055,6 @@
|
||||
|
||||
<xpath expr="//group/field[@name='location']" position="after">
|
||||
<field name="qr_code_image" widget="image" readonly="1" attrs="{'invisible': [('equipment_type', '!=', '机床')]}" />
|
||||
<label for="print_single_method"/>
|
||||
<div class="col-12 col-lg-6 o_setting_box" style="white-space: nowrap">
|
||||
<button type="object" class="oe_highlight" name='print_single_method' string="打印机床二维码"
|
||||
attrs="{'invisible': [('equipment_type', '!=', '机床')]}"/>
|
||||
</div>
|
||||
</xpath>
|
||||
<xpath expr="//page[@name='maintenance']" position="after">
|
||||
<page name="network_config" string="网络配置" attrs="{'invisible': [('equipment_type', '!=', '机床')]}" >
|
||||
|
||||
@@ -18,4 +18,3 @@ from . import quick_easy_order
|
||||
from . import purchase_order
|
||||
from . import quality_check
|
||||
from . import purchase_request_line
|
||||
from . import workorder_printer
|
||||
|
||||
@@ -934,6 +934,7 @@ class MrpProduction(models.Model):
|
||||
cur_request_line.pop('group_id', None)
|
||||
cur_request_line.pop('production_name', None)
|
||||
self.env["purchase.request.line"].create(cur_request_line)
|
||||
pr.button_approved()
|
||||
|
||||
# 外协出入库单处理
|
||||
def get_subcontract_pick_purchase(self):
|
||||
@@ -961,7 +962,7 @@ class MrpProduction(models.Model):
|
||||
if not sorted_workorders:
|
||||
return
|
||||
for workorders in reversed(sorted_workorders):
|
||||
self.env['stock.picking'].create_outcontract_picking(workorders, production, sorted_workorders)
|
||||
# self.env['stock.picking'].create_outcontract_picking(workorders, production, sorted_workorders)
|
||||
# self.env['purchase.order'].get_purchase_order(workorders, production, product_id_to_production_names)
|
||||
purchase_request_line = purchase_request_line + self.env['purchase.order'].get_purchase_request(
|
||||
workorders, production)
|
||||
@@ -1821,7 +1822,7 @@ class MrpProduction(models.Model):
|
||||
logging.info('update_programming_state error:%s' % e)
|
||||
raise UserError("更新编程单状态失败,请联系管理员")
|
||||
|
||||
model_id = fields.Char('模型id', related='product_id.model_id')
|
||||
model_id = fields.Char('模型ID', related='product_id.model_id')
|
||||
|
||||
|
||||
# 编程记录
|
||||
|
||||
@@ -1243,7 +1243,8 @@ class ResMrpWorkOrder(models.Model):
|
||||
return workorders_values_str
|
||||
|
||||
def _process_compute_state(self):
|
||||
for workorder in self:
|
||||
sorted_workorders = sorted(self, key=lambda x: x.sequence)
|
||||
for workorder in sorted_workorders:
|
||||
# 如果工单的工序没有进行排序则跳出循环
|
||||
if workorder.production_id.workorder_ids.filtered(lambda wk: wk.sequence == 0):
|
||||
continue
|
||||
@@ -1302,13 +1303,6 @@ class ResMrpWorkOrder(models.Model):
|
||||
workorder.state = 'ready'
|
||||
elif workorder.state != 'waiting':
|
||||
workorder.state = 'waiting'
|
||||
# =========== 特殊工艺工单处理 ===================
|
||||
# if workorder.routing_type == '表面工艺' and workorder.is_subcontrac:
|
||||
# purchase_order = self.env['purchase.order'].search(
|
||||
# [('origin', 'ilike', workorder.production_id.name)])
|
||||
# if purchase_order.picking_ids.filtered(lambda p: p.state in ['waiting', 'confirmed', 'assigned']):
|
||||
# workorder.state = 'waiting'
|
||||
# continue
|
||||
if workorder.technology_design_id.routing_tag == 'special':
|
||||
if workorder.is_subcontract is False:
|
||||
workorder.state = 'ready'
|
||||
@@ -1330,6 +1324,7 @@ class ResMrpWorkOrder(models.Model):
|
||||
else:
|
||||
workorder.state = 'waiting'
|
||||
|
||||
|
||||
@api.depends('production_availability', 'blocked_by_workorder_ids', 'blocked_by_workorder_ids.state',
|
||||
'production_id.tool_state', 'production_id.schedule_state', 'sequence',
|
||||
'production_id.programming_state')
|
||||
@@ -1814,7 +1809,7 @@ class ResMrpWorkOrder(models.Model):
|
||||
lazy=lazy
|
||||
)
|
||||
|
||||
model_id = fields.Char('模型id', related='production_id.model_id')
|
||||
model_id = fields.Char('模型ID', related='production_id.model_id')
|
||||
|
||||
|
||||
class CNCprocessing(models.Model):
|
||||
|
||||
@@ -787,7 +787,7 @@ class ResProductMo(models.Model):
|
||||
glb_url = fields.Char('glb文件地址')
|
||||
area = fields.Float('表面积(m²)')
|
||||
auto_machining = fields.Boolean('自动化加工(模型识别)', default=False)
|
||||
model_id = fields.Char('模型id')
|
||||
model_id = fields.Char('模型ID')
|
||||
|
||||
|
||||
@api.depends('name')
|
||||
|
||||
@@ -59,15 +59,9 @@ class PurchaseOrder(models.Model):
|
||||
production_id = self.env['mrp.production'].search([('origin', 'in', origins)])
|
||||
purchase.production_count = len(production_id)
|
||||
|
||||
def button_confirm(self):
|
||||
for record in self:
|
||||
for line in record.order_line:
|
||||
if line.product_qty <= 0:
|
||||
raise UserError('请对【产品】中的【数量】进行输入')
|
||||
if line.price_unit <= 0:
|
||||
raise UserError('请对【产品】中的【单价】进行输入')
|
||||
if record.purchase_type == 'consignment':
|
||||
bom_line_id = record.order_line[0].purchase_request_lines.request_id.bom_id.bom_line_ids
|
||||
def process_replenish(self,production,total_qty):
|
||||
record = self
|
||||
bom_line_id = production.bom_id.bom_line_ids
|
||||
replenish = self.env['stock.warehouse.orderpoint'].search([
|
||||
('product_id', '=', bom_line_id.product_id.id),
|
||||
(
|
||||
@@ -82,7 +76,7 @@ class PurchaseOrder(models.Model):
|
||||
'sf_stock.stock_location_outsourcing_material_receiving_area').id,
|
||||
'route_id': self.env.ref('sf_stock.stock_route_process_outsourcing').id,
|
||||
'group_id': record.group_id.id,
|
||||
'qty_to_order': 1,
|
||||
'qty_to_order': total_qty,
|
||||
'origin': record.name,
|
||||
})
|
||||
else:
|
||||
@@ -92,11 +86,67 @@ class PurchaseOrder(models.Model):
|
||||
'sf_stock.stock_location_outsourcing_material_receiving_area').id,
|
||||
'route_id': self.env.ref('sf_stock.stock_route_process_outsourcing').id,
|
||||
'group_id': record.group_id.id,
|
||||
'qty_to_order': 1 + replenish.qty_to_order,
|
||||
'qty_to_order': total_qty + replenish.qty_to_order,
|
||||
'origin': record.name + ',' + replenish.origin,
|
||||
})
|
||||
replenish.action_replenish()
|
||||
|
||||
def outsourcing_service_replenishment(self):
|
||||
record = self
|
||||
if record.purchase_type != 'consignment':
|
||||
return
|
||||
grouped_lines = {}
|
||||
for line in record.order_line:
|
||||
if line.related_product.id not in grouped_lines:
|
||||
grouped_lines[line.related_product.id] = []
|
||||
grouped_lines[line.related_product.id].append(line)
|
||||
for product_id,lines in grouped_lines.items():
|
||||
production = self.env['mrp.production'].search([('product_id', '=', product_id)], limit=1)
|
||||
if not production:
|
||||
continue
|
||||
total_qty = sum(line.product_qty for line in lines)
|
||||
record.process_replenish(production,total_qty)
|
||||
for product_id,lines in grouped_lines.items():
|
||||
productions = self.env['mrp.production'].search([('product_id', '=', product_id)], limit=1)
|
||||
if not productions:
|
||||
continue
|
||||
# production.bom_id.bom_line_ids.product_id
|
||||
location_id = self.env['stock.location'].search([('name', '=', '制造前')])
|
||||
quants = self.env['stock.quant'].search([
|
||||
('product_id', '=', product_id),
|
||||
('location_id', '=', location_id.id)
|
||||
])
|
||||
total_qty = sum(quants.mapped('quantity')) # 计算该位置的总库存量
|
||||
is_available = total_qty > 0
|
||||
if not is_available:
|
||||
continue
|
||||
for production_id in productions:
|
||||
work_ids = production_id.workorder_ids.filtered(
|
||||
lambda wk: wk.state not in ['done', 'rework', 'cancel'])
|
||||
if not work_ids:
|
||||
continue
|
||||
min_sequence_wk = min(work_ids, key=lambda wk: wk.sequence)
|
||||
if min_sequence_wk.is_subcontract:
|
||||
picking_id = production_id.picking_ids.filtered(
|
||||
lambda wk: wk.location_id.name == '制造前' and wk.location_dest_id.name == '外协加工区')
|
||||
move_out = picking_id.move_id
|
||||
for mo in move_out:
|
||||
if mo.state != 'done':
|
||||
mo.write({'state': 'assigned', 'production_id': False})
|
||||
if not mo.move_line_ids:
|
||||
self.env['stock.move.line'].create(
|
||||
mo.get_move_line(production_id, min_sequence_wk))
|
||||
# product = self.env['mrp.production'].search([('product_id', '=', product_id)], limit=1)
|
||||
# match = re.search(r'(S\d{5}-\d)',product.name)
|
||||
# pass
|
||||
def button_confirm(self):
|
||||
for record in self:
|
||||
for line in record.order_line:
|
||||
if line.product_qty <= 0:
|
||||
raise UserError('请对【产品】中的【数量】进行输入')
|
||||
if line.price_unit <= 0:
|
||||
raise UserError('请对【产品】中的【单价】进行输入')
|
||||
record.outsourcing_service_replenishment()
|
||||
return super(PurchaseOrder, self).button_confirm()
|
||||
|
||||
|
||||
|
||||
@@ -110,12 +110,12 @@
|
||||
</xpath>
|
||||
<xpath expr="//sheet//group//group[2]//label" position="before">
|
||||
<!-- <field name="process_state"/> -->
|
||||
<field name="production_type" readonly="1"/>
|
||||
<field name="state" readonly="1"/>
|
||||
<!-- <field name="process_state"/> -->
|
||||
|
||||
</xpath>
|
||||
<xpath expr="//sheet//group//group//div[3]" position="after">
|
||||
<field name="production_type" readonly="1"/>
|
||||
<field name="production_product_type" invisible="1"/>
|
||||
<field name="manual_quotation" readonly="1"
|
||||
attrs="{'invisible': ['|', ('production_type', 'not in', ['自动化产线加工', '人工线下加工']), ('production_product_type', '!=', '成品')]}"/>
|
||||
@@ -455,7 +455,7 @@
|
||||
<field name="inherit_id" ref="mrp.mrp_production_workorder_tree_editable_view"/>
|
||||
<field name="arch" type="xml">
|
||||
<xpath expr="//tree" position="attributes">
|
||||
<attribute name="default_order">create_date desc</attribute>
|
||||
<attribute name="default_order">sequence,create_date desc</attribute>
|
||||
<attribute name="decoration-warning">delivery_warning == 'warning'</attribute>
|
||||
<attribute name="decoration-danger">delivery_warning == 'overdue'</attribute>
|
||||
</xpath>
|
||||
|
||||
@@ -1,15 +1,15 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<odoo>
|
||||
<!-- 工作中心看板 -->
|
||||
<record id="mrp_production_view_form_inherit_maintenance" model="ir.ui.view">
|
||||
<!-- <record id="mrp_production_view_form_inherit_maintenance" model="ir.ui.view">
|
||||
<field name="name">mrp.production.view.form.inherit.maintenance</field>
|
||||
<field name="model">mrp.production</field>
|
||||
<field name="inherit_id" ref="mrp.mrp_production_form_view"/>
|
||||
<field name="arch" type="xml">
|
||||
<field name="arch" type="xml"> -->
|
||||
<!-- <button name="action_cancel" position="before"> -->
|
||||
<!-- <button name="button_maintenance_req" type="object" string="维修请求"/> -->
|
||||
<!-- </button> -->
|
||||
<div name="button_box" position="inside">
|
||||
<!-- <div name="button_box" position="inside">
|
||||
<button name="open_maintenance_request_mo" type="object" class="oe_stat_button" icon="fa-wrench"
|
||||
attrs="{'invisible': [('maintenance_count', '=', 0)]}"
|
||||
context="{'search_default_production_id': active_id}">
|
||||
@@ -22,7 +22,7 @@
|
||||
</button>
|
||||
</div>
|
||||
</field>
|
||||
</record>
|
||||
</record> -->
|
||||
|
||||
<record id="custom_model_form_view_inherit" model="ir.ui.view">
|
||||
<field name="name">custom.model.form.view.inherit</field>
|
||||
@@ -451,6 +451,7 @@
|
||||
</div>
|
||||
<field name="product_id" position="after">
|
||||
<field name="model_file" string="产品模型" readonly="1" widget="Viewer3D" attrs="{'invisible': [('model_file', '=', False)]}"/>
|
||||
<field name="model_id" readonly="1"/>
|
||||
<field name="glb_url" widget="Viewer3D" string="模型" readonly="1" force_save="1"
|
||||
attrs="{'invisible': [('glb_url', '=', False)]}"/>
|
||||
</field>
|
||||
|
||||
@@ -4,10 +4,11 @@
|
||||
<record model="ir.ui.view" id="view_product_template_form_inherit_sf_manufacturing">
|
||||
<field name="name">product.template.product.form.inherit.sf_manufacture</field>
|
||||
<field name="model">product.template</field>
|
||||
<field name="inherit_id" ref="sf_dlm_management.view_product_template_only_form_inherit_sf"/>
|
||||
<field name="inherit_id" ref="sf_sale.view_product_template_form_inherit_sf"/>
|
||||
<field name="arch" type="xml">
|
||||
<xpath expr="//page[@name='general_information']/group/group[@name='group_standard_price']/field[@name='barcode']" position="after">
|
||||
<field name="model_id" readonly="1"/>
|
||||
<xpath expr="//page[@name='general_information']/group/group[@name='group_standard_price']/field[@name='product_tag_ids']" position="after">
|
||||
<field name="categ_type" invisible="1"/>
|
||||
<field name="model_id" readonly="1" attrs="{'invisible': [('categ_type', '!=', '成品')]}"/>
|
||||
</xpath>
|
||||
</field>
|
||||
</record>
|
||||
|
||||
@@ -26,6 +26,7 @@
|
||||
'views/quality_check_view.xml',
|
||||
'views/quality_company.xml',
|
||||
'wizard/check_picking_wizard_view.xml',
|
||||
'wizard/confirmation_wizard_views.xml',
|
||||
],
|
||||
|
||||
'assets': {
|
||||
|
||||
@@ -74,5 +74,6 @@ access_quality_cnc_test_group_quality_director,quality_cnc_test_group_quality_di
|
||||
access_quality_cnc_test_group_sf_equipment_user,quality_cnc_test_group_sf_equipment_user,model_quality_cnc_test,sf_base.group_sf_equipment_user,1,1,0,0
|
||||
|
||||
access_picking_validate_check_wizard,access.picking_validate_check_wizard,model_picking_validate_check_wizard,quality.group_quality_user,1,1,1,0
|
||||
access_confirmation_wizard,access.confirmation.wizard,model_confirmation_wizard,quality.group_quality_user,1,1,1,0
|
||||
|
||||
|
||||
|
||||
|
@@ -1 +1,2 @@
|
||||
from . import check_picking_wizard
|
||||
from . import confirmation_wizard
|
||||
|
||||
32
sf_quality/wizard/confirmation_wizard.py
Normal file
32
sf_quality/wizard/confirmation_wizard.py
Normal file
@@ -0,0 +1,32 @@
|
||||
from odoo import models, fields, api
|
||||
|
||||
|
||||
class ConfirmationWizard(models.TransientModel):
|
||||
_name = 'confirmation.wizard'
|
||||
_description = '二次确认向导'
|
||||
|
||||
# 可根据需要传递上下文参数
|
||||
check_id = fields.Many2one('quality.check', string='质检单', required=True)
|
||||
picking_name = fields.Char(string='拣货单', related='check_id.picking_id.name', store=True)
|
||||
number = fields.Char(string='数量', related='check_id.total_qty', store=True)
|
||||
picking_num = fields.Integer(string='拣货数量', compute='_compute_picking_num', store=True)
|
||||
|
||||
@api.depends('check_id.picking_id')
|
||||
def _compute_picking_num(self):
|
||||
for record in self.check_id:
|
||||
if record.picking_id:
|
||||
for move in record.picking_id.move_ids_without_package:
|
||||
if move.product_id == record.product_id:
|
||||
self.picking_num = int(move.product_uom_qty)
|
||||
else:
|
||||
self.picking_num = 0
|
||||
|
||||
button_text = fields.Char(string='确认按钮文字')
|
||||
|
||||
def action_confirm(self):
|
||||
self.ensure_one()
|
||||
|
||||
# 获取原始记录
|
||||
check = self.env['quality.check'].browse(self.check_id.id)
|
||||
# 调用实际发布方法
|
||||
return check._do_actual_publish()
|
||||
19
sf_quality/wizard/confirmation_wizard_views.xml
Normal file
19
sf_quality/wizard/confirmation_wizard_views.xml
Normal file
@@ -0,0 +1,19 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<odoo>
|
||||
<record id="view_confirmation_wizard_form" model="ir.ui.view">
|
||||
<field name="name">confirmation.wizard.form</field>
|
||||
<field name="model">confirmation.wizard</field>
|
||||
<field name="arch" type="xml">
|
||||
<form>
|
||||
<div class="alert alert-warning">
|
||||
<p>拣货调拨单号<strong><field name="picking_name" class="oe_inline"/></strong>需求数量为<strong><field name="picking_num" class="oe_inline"/></strong>,当前质量检查单产品数量为<strong><field name="number" class="oe_inline"/></strong>,数量不一致,是否确认继续?</p>
|
||||
</div>
|
||||
<footer>
|
||||
<button name="action_confirm" string="确定" type="object" class="btn-primary"/>
|
||||
<button string="取消" class="btn-secondary" special="cancel"/>
|
||||
</footer>
|
||||
</form>
|
||||
</field>
|
||||
</record>
|
||||
|
||||
</odoo>
|
||||
@@ -271,7 +271,7 @@ class ResaleOrderLine(models.Model):
|
||||
embryo_redundancy_id = fields.Many2one('sf.embryo.redundancy', '坯料冗余')
|
||||
manual_quotation = fields.Boolean('人工编程', default=False)
|
||||
model_url = fields.Char('模型文件地址')
|
||||
model_id = fields.Char('模型id')
|
||||
model_id = fields.Char('模型ID')
|
||||
|
||||
delivery_end_date = fields.Date('交货截止日期')
|
||||
|
||||
@@ -323,7 +323,7 @@ class RePurchaseOrder(models.Model):
|
||||
contract_summary = fields.Text(string='合同概况')
|
||||
|
||||
# 选择是否为紧急采购
|
||||
urgent_purchase = fields.Selection([('no', '否'), ('yes', '是')], string='紧急采购', default='no')
|
||||
urgent_purchase = fields.Selection([('no', '否'), ('yes', '是')], string='紧急采购', default='yes')
|
||||
|
||||
@api.depends('origin')
|
||||
def _compute_purchase_type(self):
|
||||
@@ -390,6 +390,7 @@ class RePurchaseOrder(models.Model):
|
||||
# route_ids
|
||||
result.append({
|
||||
"product_id": server_template.product_variant_id.id,
|
||||
'related_product':production.product_id.id,
|
||||
"name": production.procurement_group_id.name,
|
||||
"date_required": fields.Datetime.now(),
|
||||
"product_uom_id":server_template.uom_id.id,
|
||||
|
||||
@@ -107,6 +107,7 @@
|
||||
<field name="glb_url" widget="Viewer3D" optional="show"
|
||||
string="模型文件" readonly="1" attrs="{'column_invisible': [('parent.model_display_version', '!=', 'v2')], 'isInList': True}"/>
|
||||
<field name="part_name" optional="show"/>
|
||||
<field name="model_id" optional="hide"/>
|
||||
</xpath>
|
||||
<xpath expr="//field[@name='order_line']/tree/field[@name='price_subtotal']" position="after">
|
||||
<field name="remark"/>
|
||||
@@ -359,10 +360,10 @@
|
||||
<field name="categ_id" position="replace">
|
||||
<field name='categ_id' invisible="1"/>
|
||||
</field>
|
||||
<field name="product_tag_ids" position="after">
|
||||
<!-- <field name="product_tag_ids" position="after">
|
||||
<field name="default_code" attrs="{'invisible': [('product_variant_count', '>', 1)]}"/>
|
||||
<field name="barcode" attrs="{'invisible': [('product_variant_count', '>', 1)]}"/>
|
||||
</field>
|
||||
</field> -->
|
||||
</field>
|
||||
</record>
|
||||
<record id="sale.product_template_action" model="ir.actions.act_window">
|
||||
|
||||
Reference in New Issue
Block a user