Compare commits
1 Commits
feature/67
...
release/re
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e9719a2b5b |
@@ -119,24 +119,13 @@ patch(ListRenderer.prototype, 'jikimo_frontend.ListRenderer', {
|
||||
this.listherHeaderBodyNum()
|
||||
})
|
||||
const treeModifiers = this.getFieldModifiers(this.props.archInfo.__rawArch);
|
||||
|
||||
if(treeModifiers) {
|
||||
if(treeModifiers.merge_fields) {
|
||||
this.props.merge_key = treeModifiers.merge_key;
|
||||
this.props.merge_fields = treeModifiers.merge_fields.split(',');
|
||||
const data = this.setColumns(this.props.merge_key);
|
||||
owl.onMounted(() => {
|
||||
this.mergeColumns(this.props.merge_fields, data)
|
||||
})
|
||||
}
|
||||
if(treeModifiers.pacthResize) {
|
||||
|
||||
owl.onPatched(() => {
|
||||
this.columnWidths = null;
|
||||
this.freezeColumnWidths();
|
||||
|
||||
})
|
||||
}
|
||||
this.props.merge_key = treeModifiers.merge_key;
|
||||
this.props.merge_fields = treeModifiers.merge_fields.split(',');
|
||||
const data = this.setColumns(this.props.merge_key);
|
||||
owl.onMounted(() => {
|
||||
this.mergeColumns(this.props.merge_fields, data)
|
||||
})
|
||||
}
|
||||
return this._super(...arguments);
|
||||
},
|
||||
|
||||
@@ -157,11 +157,11 @@ td.o_required_modifier {
|
||||
color: #aaa;
|
||||
}
|
||||
|
||||
// .o_kanban_primary_left {
|
||||
// display: flex;
|
||||
// flex-direction: row-reverse;
|
||||
// justify-content: flex-start;
|
||||
// }
|
||||
.o_kanban_primary_left {
|
||||
display: flex;
|
||||
flex-direction: row-reverse;
|
||||
justify-content: flex-start;
|
||||
}
|
||||
|
||||
.o_list_view .o_list_table thead {
|
||||
position: sticky;
|
||||
|
||||
@@ -1,2 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
from . import models
|
||||
@@ -1,18 +0,0 @@
|
||||
# -*- 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',
|
||||
}
|
||||
@@ -1,5 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
from . import jikimo_printing
|
||||
from . import maintenance_printing
|
||||
from . import workorder_printing
|
||||
|
||||
@@ -1,87 +0,0 @@
|
||||
from io import BytesIO
|
||||
import qrcode
|
||||
from reportlab.pdfgen import canvas
|
||||
from reportlab.lib.pagesizes import A4
|
||||
from PIL import Image
|
||||
import logging
|
||||
from reportlab.lib.utils import ImageReader
|
||||
from odoo import models, fields, api
|
||||
import base64
|
||||
|
||||
_logger = logging.getLogger(__name__)
|
||||
|
||||
class JikimoPrinting(models.AbstractModel):
|
||||
_name = 'jikimo.printing'
|
||||
|
||||
def print_qr_code(self, data):
|
||||
"""
|
||||
打印二维码
|
||||
"""
|
||||
printer = self.env['printing.printer'].get_default()
|
||||
if not printer:
|
||||
_logger.error("未找到默认打印机")
|
||||
return False
|
||||
|
||||
# 生成二维码
|
||||
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()
|
||||
# _logger.info(f"打印内容: {pdf_content}")
|
||||
printer.print_document(report=None, content=pdf_content, doc_format='pdf')
|
||||
|
||||
# 清理资源
|
||||
pdf_buffer.close()
|
||||
temp_image.close()
|
||||
|
||||
return True
|
||||
|
||||
def print_pdf(self, pdf_data):
|
||||
"""
|
||||
打印PDF
|
||||
"""
|
||||
printer = self.env['printing.printer'].get_default()
|
||||
if not printer:
|
||||
_logger.error("未找到默认打印机")
|
||||
return False
|
||||
|
||||
pdf_data_str = pdf_data.decode('ascii', errors='ignore')
|
||||
decoded_data = base64.b64decode(pdf_data_str)
|
||||
|
||||
# 处理二进制数据
|
||||
pdf_buffer = BytesIO()
|
||||
pdf_buffer.write(decoded_data)
|
||||
pdf_buffer.seek(0)
|
||||
|
||||
# 获取PDF内容
|
||||
pdf_content = pdf_buffer.getvalue()
|
||||
|
||||
printer.print_document(report=None, content=pdf_content, doc_format='pdf')
|
||||
# 清理资源
|
||||
pdf_buffer.close()
|
||||
|
||||
_logger.info("成功打印PDF")
|
||||
return True
|
||||
@@ -1,69 +0,0 @@
|
||||
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,31 +0,0 @@
|
||||
|
||||
import logging
|
||||
from odoo import models, fields, api
|
||||
|
||||
_logger = logging.getLogger(__name__)
|
||||
|
||||
class MrpWorkorder(models.Model):
|
||||
_name = 'mrp.workorder'
|
||||
_inherit = ['mrp.workorder']
|
||||
|
||||
def _compute_state(self):
|
||||
super(MrpWorkorder, self)._compute_state()
|
||||
for workorder in self:
|
||||
work_ids = workorder.production_id.workorder_ids.filtered(lambda w: w.routing_type == '装夹预调' or w.routing_type == '人工线下加工')
|
||||
for wo in work_ids:
|
||||
if wo.state == 'ready' and not wo.production_id.product_id.is_print_program:
|
||||
# 触发打印程序
|
||||
pdf_data = workorder.processing_drawing
|
||||
if pdf_data:
|
||||
try:
|
||||
# 执行打印
|
||||
self.env['jikimo.printing'].print_pdf(pdf_data)
|
||||
wo.production_id.product_id.is_print_program = True
|
||||
except Exception as e:
|
||||
_logger.error(f"工单 {wo.name} 的PDF打印失败: {str(e)}")
|
||||
|
||||
class ProductTemplate(models.Model):
|
||||
_inherit = 'product.template'
|
||||
|
||||
is_print_program = fields.Boolean(string='是否打印程序', default=False)
|
||||
|
||||
@@ -1,19 +0,0 @@
|
||||
<?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>
|
||||
|
||||
|
||||
@@ -8,21 +8,16 @@
|
||||
'category': 'purchase',
|
||||
'depends': ['sf_manufacturing', 'purchase_request'],
|
||||
'data': [
|
||||
'security/ir.model.access.csv',
|
||||
'views/sale_order_view.xml',
|
||||
'views/mrp_production.xml',
|
||||
'views/purchase_request_view.xml',
|
||||
'wizard/purchase_request_line_make_purchase_order_view.xml',
|
||||
'views/purchase_request_line_view.xml',
|
||||
'views/stock_picking_views.xml',
|
||||
'wizard/purchase_request_wizard_views.xml',
|
||||
'views/purchase_request_menu_views.xml',
|
||||
],
|
||||
'assets': {
|
||||
'web.assets_backend': [
|
||||
'jikimo_purchase_request/static/src/**/*'
|
||||
],
|
||||
},
|
||||
# 'assets': {
|
||||
# 'web.assets_backend': [
|
||||
# 'jikimo_purchase_request/static/src/**/*'
|
||||
# ],
|
||||
# },
|
||||
'application': True,
|
||||
'installable': True,
|
||||
'auto_install': False,
|
||||
|
||||
@@ -410,7 +410,7 @@ msgstr "显示名称"
|
||||
#: model_terms:ir.ui.view,arch_db:purchase_request.view_purchase_request_form
|
||||
#: model_terms:ir.ui.view,arch_db:purchase_request.view_purchase_request_search
|
||||
msgid "Done"
|
||||
msgstr "关闭"
|
||||
msgstr "完成"
|
||||
|
||||
#. module: purchase_request
|
||||
#: model:ir.model.fields,field_description:purchase_request.field_purchase_request_line__move_dest_ids
|
||||
@@ -1043,7 +1043,7 @@ msgstr "询价单"
|
||||
#. module: purchase_request
|
||||
#: model:ir.model.fields,field_description:purchase_request.field_purchase_request_line__purchased_qty
|
||||
msgid "RFQ/PO Qty"
|
||||
msgstr "已订购数"
|
||||
msgstr ""
|
||||
|
||||
#. module: purchase_request
|
||||
#. odoo-python
|
||||
|
||||
@@ -5,4 +5,3 @@ from . import sale_order
|
||||
from . import mrp_production
|
||||
from . import purchase_order
|
||||
from . import stock_rule
|
||||
from . import stock_picking
|
||||
|
||||
@@ -9,25 +9,18 @@ class MrpProduction(models.Model):
|
||||
@api.depends('state')
|
||||
def _compute_pr_mp_count(self):
|
||||
for item in self:
|
||||
if item.product_id.is_customer_provided:
|
||||
item.pr_mp_count = 0
|
||||
else:
|
||||
# 由于采购申请合并了所有销售订单行的采购,所以不区分产品
|
||||
mrp_names = self.env['mrp.production'].search([('origin', '=', item.origin)]).mapped('name')
|
||||
pr_ids = self.env['purchase.request'].sudo().search([('origin', 'in', mrp_names)])
|
||||
pr_ids = self.env['purchase.request'].sudo().search([('origin', 'like', item.name)])
|
||||
if pr_ids:
|
||||
item.pr_mp_count = len(pr_ids)
|
||||
# pr_ids = self.env['purchase.request'].sudo().search([('origin', 'like', item.name), ('is_subcontract', '!=', 'True')])
|
||||
else:
|
||||
item.pr_mp_count = 0
|
||||
|
||||
def action_view_pr_mp(self):
|
||||
"""
|
||||
采购请求
|
||||
"""
|
||||
self.ensure_one()
|
||||
|
||||
# 由于采购申请合并了所有销售订单行的采购,所以不区分产品
|
||||
mrp_names = self.env['mrp.production'].search([('origin', '=', self.origin)]).mapped('name')
|
||||
pr_ids = self.env['purchase.request'].sudo().search([('origin', 'in', mrp_names)])
|
||||
|
||||
pr_ids = self.env['purchase.request'].sudo().search([('origin', 'like', self.name)])
|
||||
action = {
|
||||
'res_model': 'purchase.request',
|
||||
'type': 'ir.actions.act_window',
|
||||
@@ -40,7 +33,7 @@ class MrpProduction(models.Model):
|
||||
else:
|
||||
action.update({
|
||||
'name': _("从 %s生成采购请求单", self.name),
|
||||
'domain': [('id', 'in', pr_ids.ids)],
|
||||
'domain': [('id', 'in', pr_ids)],
|
||||
'view_mode': 'tree,form',
|
||||
})
|
||||
return action
|
||||
|
||||
@@ -1,5 +1,4 @@
|
||||
from odoo import api, fields, models, _
|
||||
from odoo.tools import float_compare
|
||||
|
||||
|
||||
class PurchaseOrder(models.Model):
|
||||
@@ -14,51 +13,4 @@ class PurchaseOrder(models.Model):
|
||||
('done', '完成'),
|
||||
('cancel', '取消'),
|
||||
('rejected', '已驳回')
|
||||
], string='Status', readonly=True, index=True, copy=False, default='draft', tracking=True)
|
||||
|
||||
|
||||
def button_confirm(self):
|
||||
res = super(PurchaseOrder, self).button_confirm()
|
||||
# 取消反向调拨单
|
||||
reverse_move_ids = self.env['stock.move'].search([
|
||||
('origin', '=', self.name),
|
||||
('purchase_line_id', '=', False),
|
||||
('state', '!=', 'done')
|
||||
])
|
||||
if reverse_move_ids:
|
||||
reverse_move_ids.picking_id.action_cancel()
|
||||
return res
|
||||
|
||||
def button_cancel(self):
|
||||
"""
|
||||
1. 先将采购订单行与目标库存移动断开链接,避免采购单取消后,调拨单被调整为mts的问题
|
||||
2. 取消采购订单
|
||||
3. 将采购订单行与目标库存移动重新建立链接
|
||||
"""
|
||||
created_purchase_request_line_ids = {}
|
||||
if self.order_line.move_dest_ids.created_purchase_request_line_id:
|
||||
move_ids = self.order_line.move_dest_ids.filtered(lambda move: move.state != 'done' and not move.scrapped)
|
||||
created_purchase_request_line_ids = {move.id: move.created_purchase_request_line_id for move in move_ids}
|
||||
self.order_line.write({'move_dest_ids': [(5, 0, 0)]})
|
||||
res =super(PurchaseOrder, self).button_cancel()
|
||||
for move_id, created_purchase_request_line_id in created_purchase_request_line_ids.items():
|
||||
self.env['stock.move'].browse(move_id).created_purchase_request_line_id = created_purchase_request_line_id
|
||||
# if move_ids.mapped('created_purchase_request_line_id'):
|
||||
# move_ids.write({'state': 'waiting', 'is_done': False})
|
||||
return res
|
||||
|
||||
def write(self, vals):
|
||||
res = super(PurchaseOrder, self).write(vals)
|
||||
if 'state' in vals and vals['state'] == 'purchase':
|
||||
purchase_request = self.order_line.purchase_request_lines.request_id
|
||||
if purchase_request:
|
||||
finished = True
|
||||
# 判断该采购申请所有明细行是否都完成
|
||||
for purchase_request_line in purchase_request.line_ids:
|
||||
finished_qty = sum(purchase_request_line.purchase_lines.filtered(lambda line: line.state == 'purchase').mapped('product_qty'))
|
||||
if float_compare(finished_qty ,purchase_request_line.product_qty, precision_rounding=purchase_request_line.product_id.uom_id.rounding) < 0:
|
||||
finished = False
|
||||
break
|
||||
if finished:
|
||||
purchase_request.button_done()
|
||||
return res
|
||||
], string='Status', readonly=True, index=True, copy=False, default='draft', tracking=True)
|
||||
@@ -1,15 +1,13 @@
|
||||
import re
|
||||
import ast
|
||||
from odoo import models, fields, api, _
|
||||
from itertools import groupby
|
||||
from odoo.tools import float_compare
|
||||
from odoo import models, fields, api
|
||||
|
||||
|
||||
class PurchaseRequest(models.Model):
|
||||
_inherit = 'purchase.request'
|
||||
_description = '采购申请'
|
||||
|
||||
# 为state添加取消状态
|
||||
# 为state添加取消状态
|
||||
state = fields.Selection(
|
||||
selection_add=[('cancel', '已取消')],
|
||||
ondelete={'cancel': 'set default'} # 添加 ondelete 策略
|
||||
@@ -31,57 +29,6 @@ class PurchaseRequest(models.Model):
|
||||
action['context'] = origin_context
|
||||
return action
|
||||
|
||||
def button_done(self):
|
||||
product_qty_map = {key: sum(line.product_qty for line in group) for key, group in
|
||||
groupby(self.line_ids, key=lambda x: x.product_id.id)}
|
||||
lines = self.mapped("line_ids.purchase_lines.order_id")
|
||||
# 采购单产品和数量
|
||||
product_summary = {}
|
||||
product_rounding = {}
|
||||
if lines:
|
||||
for line in lines:
|
||||
for line_item in line.order_line:
|
||||
if line_item.state == 'purchase':
|
||||
product_id = line_item.product_id.id
|
||||
qty = line_item.product_qty
|
||||
product_rounding[product_id] = line_item.product_id.uom_id.rounding
|
||||
if product_id in product_summary:
|
||||
product_summary[product_id] += qty
|
||||
else:
|
||||
product_summary[product_id] = qty
|
||||
|
||||
# 校验产品数量
|
||||
discrepancies = []
|
||||
for product_id, qty in product_qty_map.items():
|
||||
if product_id in product_summary:
|
||||
if float_compare(product_summary[product_id], qty, precision_rounding=product_rounding[product_id]) < 0:
|
||||
discrepancies.append((product_id, qty, product_summary[product_id]))
|
||||
else:
|
||||
discrepancies.append((product_id, qty, 0))
|
||||
|
||||
if discrepancies:
|
||||
# 弹出提示框
|
||||
message = "产品与采购数量不一致:\n"
|
||||
for product_id, required_qty, order_qty in discrepancies:
|
||||
product_name = self.env['product.product'].browse(product_id).display_name # 获取产品名称
|
||||
message += f"产品 {product_name},需求数量 {required_qty},关联采购订单确认的数量 {order_qty}。\n"
|
||||
# 添加确认框
|
||||
message += "确认关闭?"
|
||||
return {
|
||||
'name': _('采购申请'),
|
||||
'type': 'ir.actions.act_window',
|
||||
'views': [(self.env.ref(
|
||||
'jikimo_purchase_request.purchase_request_wizard_wizard_form_view').id,
|
||||
'form')],
|
||||
'res_model': 'purchase.request.wizard',
|
||||
'target': 'new',
|
||||
'context': {
|
||||
'default_purchase_request_id': self.id,
|
||||
'default_message': message,
|
||||
}}
|
||||
return super(PurchaseRequest, self).button_done()
|
||||
|
||||
|
||||
class PurchaseRequestLine(models.Model):
|
||||
_inherit = 'purchase.request.line'
|
||||
_description = '采购申请明细'
|
||||
@@ -100,20 +47,6 @@ class PurchaseRequestLine(models.Model):
|
||||
('outsourcing', "委外加工"),
|
||||
], string='供货方式', compute='_compute_supply_method', store=True)
|
||||
|
||||
purchase_request_count = fields.Integer(string='采购申请数量', compute='_compute_purchase_request_count',
|
||||
readonly=True)
|
||||
purchase_count = fields.Integer(string="采购订单数量", compute="_compute_purchase_count", readonly=True)
|
||||
|
||||
@api.depends("purchase_lines")
|
||||
def _compute_purchase_count(self):
|
||||
for rec in self:
|
||||
rec.purchase_count = len(rec.mapped("purchase_lines.order_id"))
|
||||
|
||||
@api.depends('request_id')
|
||||
def _compute_purchase_request_count(self):
|
||||
for order in self:
|
||||
order.purchase_request_count = len(order.request_id)
|
||||
|
||||
@api.depends('origin')
|
||||
def _compute_supply_method(self):
|
||||
for prl in self:
|
||||
@@ -146,12 +79,10 @@ class PurchaseRequestLine(models.Model):
|
||||
continue
|
||||
if record.product_id.categ_id.name == '坯料':
|
||||
product_name = ''
|
||||
match = re.search(r'(S\d{5}-\d+)', record.product_id.name)
|
||||
match = re.search(r'(S\d{5}-\d)', record.product_id.name)
|
||||
# 如果匹配成功,提取结果
|
||||
if match:
|
||||
product_name = match.group(0)
|
||||
else:
|
||||
product_name = record.product_id.name
|
||||
sale_order_name = ''
|
||||
match_sale = re.search(r'S(\d+)', record.product_id.name)
|
||||
if match_sale:
|
||||
@@ -167,36 +98,3 @@ class PurchaseRequestLine(models.Model):
|
||||
else:
|
||||
record.part_number = record.product_id.part_number
|
||||
record.part_name = record.product_id.part_name
|
||||
|
||||
def _compute_qty_to_buy(self):
|
||||
for pr in self:
|
||||
qty_to_buy = sum(pr.mapped("product_qty"))
|
||||
if pr.purchase_count > 0:
|
||||
qty_to_buy -= sum(pr.mapped("purchase_lines").filtered(lambda po: po.state != 'cancel').mapped(
|
||||
"product_qty"))
|
||||
pr.qty_to_buy = qty_to_buy > 0.0
|
||||
pr.pending_qty_to_receive = qty_to_buy
|
||||
|
||||
def action_view_purchase_request(self):
|
||||
action = self.env["ir.actions.actions"]._for_xml_id("purchase_request.purchase_request_form_action")
|
||||
action.update({
|
||||
'res_id': self.request_id.id,
|
||||
'views': [[False, 'form']],
|
||||
})
|
||||
return action
|
||||
|
||||
def action_view_purchase_order(self):
|
||||
action = self.env["ir.actions.actions"]._for_xml_id("purchase.purchase_rfq")
|
||||
lines = self.mapped("purchase_lines.order_id")
|
||||
if len(lines) > 1:
|
||||
action["domain"] = [("id", "in", lines.ids)]
|
||||
elif lines:
|
||||
action["views"] = [
|
||||
(self.env.ref("purchase.purchase_order_form").id, "form")
|
||||
]
|
||||
action["res_id"] = lines.id
|
||||
origin_context = ast.literal_eval(action['context'])
|
||||
if 'search_default_draft' in origin_context:
|
||||
origin_context.pop('search_default_draft')
|
||||
action['context'] = origin_context
|
||||
return action
|
||||
|
||||
@@ -1,47 +0,0 @@
|
||||
from odoo import fields, api, models, _
|
||||
|
||||
|
||||
class StockPicking(models.Model):
|
||||
_inherit = "stock.picking"
|
||||
|
||||
purchase_request_count = fields.Integer('采购订单数量', compute='_compute_purchase_request')
|
||||
|
||||
@api.depends('name')
|
||||
def _compute_purchase_request(self):
|
||||
for record in self:
|
||||
purchase_request_ids = self.env['purchase.request'].search([('origin', '=', record.name)])
|
||||
record.purchase_request_count = len(purchase_request_ids)
|
||||
|
||||
def action_view_purchase_request(self):
|
||||
self.ensure_one()
|
||||
|
||||
purchase_request_ids = self.env['purchase.request'].search([('origin', '=', self.name)])
|
||||
|
||||
action = {
|
||||
'res_model': 'purchase.request',
|
||||
'type': 'ir.actions.act_window',
|
||||
}
|
||||
if len(purchase_request_ids) == 1:
|
||||
action.update({
|
||||
'view_mode': 'form',
|
||||
'res_id': purchase_request_ids[0].id,
|
||||
})
|
||||
else:
|
||||
action.update({
|
||||
'name': _("从 %s生成采购请求单", self.name),
|
||||
'domain': [('id', 'in', purchase_request_ids.ids)],
|
||||
'view_mode': 'tree,form',
|
||||
})
|
||||
return action
|
||||
|
||||
def _action_done(self):
|
||||
res = super(StockPicking, self)._action_done()
|
||||
# 将新产生的backorder对应上原来的采购申请明细行
|
||||
backorder_ids = self.backorder_ids
|
||||
if backorder_ids:
|
||||
purchase_request_lines = self.move_ids.move_orig_ids.purchase_line_id.purchase_request_lines
|
||||
if purchase_request_lines:
|
||||
purchase_request_lines.move_dest_ids = [
|
||||
(4, x.id) for x in backorder_ids.move_ids if x.product_id.id == purchase_request_lines.product_id.id
|
||||
]
|
||||
return res
|
||||
@@ -1,5 +1,4 @@
|
||||
from odoo import api, fields, models
|
||||
from collections import defaultdict
|
||||
|
||||
|
||||
class StockRule(models.Model):
|
||||
@@ -45,38 +44,13 @@ class StockRule(models.Model):
|
||||
purchase_request_line_model.create(request_line_data)
|
||||
|
||||
def _run_buy(self, procurements):
|
||||
# 如果补货组相同,并且产品相同,则合并
|
||||
procurements_dict = defaultdict()
|
||||
for procurement, rule in procurements:
|
||||
if (procurement.product_id.id, procurement.values['group_id'], rule.id) not in procurements_dict:
|
||||
procurements_dict[(procurement.product_id.id, procurement.values['group_id'], rule.id)] = {
|
||||
'product_id': procurement.product_id,
|
||||
'product_qty': procurement.product_qty,
|
||||
'product_uom': procurement.product_uom,
|
||||
'location_id': procurement.location_id,
|
||||
'name': procurement.name,
|
||||
'origin': procurement.origin,
|
||||
'company_id': procurement.company_id,
|
||||
'values': procurement.values,
|
||||
'rule': rule
|
||||
}
|
||||
else:
|
||||
procurements_dict[(procurement.product_id.id, procurement.values['group_id'], rule.id)]['product_qty'] += procurement.product_qty
|
||||
procurements_dict[(procurement.product_id.id, procurement.values['group_id'], rule.id)]['values']['move_dest_ids'] |= procurement.values['move_dest_ids']
|
||||
new_procurements = []
|
||||
for k, p in procurements_dict.items():
|
||||
new_procurements.append((
|
||||
self.env['procurement.group'].Procurement(
|
||||
product_id=p['product_id'],
|
||||
product_qty=p['product_qty'],
|
||||
product_uom=p['product_uom'],
|
||||
location_id=p['location_id'],
|
||||
name=p['name'],
|
||||
origin=p['origin'],
|
||||
company_id=p['company_id'],
|
||||
values=p['values']
|
||||
), p['rule'])
|
||||
)
|
||||
|
||||
res = super(StockRule, self)._run_buy(new_procurements)
|
||||
res = super(StockRule, self)._run_buy(procurements)
|
||||
# 判断是否根据规则生成新的采购申请单据,如果生成则修改状态为 approved
|
||||
origins = list(set([procurement[0].origin for procurement in procurements]))
|
||||
for origin in origins:
|
||||
pr_ids = self.env["purchase.request"].sudo().search(
|
||||
[('origin', 'like', origin), ('rule_new_add', '=', True), ('state', '=', 'draft')])
|
||||
if pr_ids:
|
||||
pr_ids.write({'need_validation': False})
|
||||
pr_ids.write({"state": "approved", 'need_validation': True, 'rule_new_add': False})
|
||||
return res
|
||||
|
||||
@@ -1,2 +0,0 @@
|
||||
id,name,model_id:id,group_id:id,perm_read,perm_write,perm_create,perm_unlink
|
||||
access_purchase_request_wizard_group_user,purchase.request.wizard,model_purchase_request_wizard,base.group_user,1,1,1,1
|
||||
|
@@ -1,3 +0,0 @@
|
||||
th[data-name=keep_description] {
|
||||
min-width: 220px;
|
||||
}
|
||||
@@ -1,22 +0,0 @@
|
||||
<odoo>
|
||||
<record id="purchase_request_line_form_sf" model="ir.ui.view">
|
||||
<field name="name">purchase.request.line.sf.form</field>
|
||||
<field name="model">purchase.request.line</field>
|
||||
<field name="inherit_id" ref="purchase_request.purchase_request_line_form"/>
|
||||
<field name="arch" type="xml">
|
||||
<xpath expr="//h1" position="before">
|
||||
<div class="oe_button_box" name="button_box">
|
||||
<button type="object" name="action_view_purchase_request" class="oe_stat_button"
|
||||
icon="fa-file">
|
||||
<field name="purchase_request_count" widget="statinfo" string="采购申请"/>
|
||||
</button>
|
||||
<button type="object" name="action_view_purchase_order" class="oe_stat_button"
|
||||
attrs="{'invisible': [('purchase_count', '=', 0)]}" icon="fa-shopping-cart">
|
||||
<field name="purchase_count" widget="statinfo" string="采购订单"/>
|
||||
</button>
|
||||
</div>
|
||||
</xpath>
|
||||
|
||||
</field>
|
||||
</record>
|
||||
</odoo>
|
||||
@@ -1,21 +0,0 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<odoo>
|
||||
<data>
|
||||
<record id="menu_purhcase_request" model="ir.ui.menu">
|
||||
<field name="name">采购申请</field>
|
||||
<field name="parent_id" ref="purchase.menu_purchase_root" />
|
||||
<field name="sequence">2</field>
|
||||
</record>
|
||||
|
||||
<record id="purchase_request.menu_purchase_request_pro_mgt" model="ir.ui.menu">
|
||||
<field name="sequence">1</field>
|
||||
<field name="parent_id" ref="jikimo_purchase_request.menu_purhcase_request"/>
|
||||
</record>
|
||||
|
||||
<record id="purchase_request.menu_purchase_request_line" model="ir.ui.menu">
|
||||
<field name="sequence">10</field>
|
||||
<field name="parent_id" ref="jikimo_purchase_request.menu_purhcase_request"/>
|
||||
</record>
|
||||
</data>
|
||||
</odoo>
|
||||
|
||||
@@ -15,26 +15,6 @@
|
||||
<field name="part_number"/>
|
||||
<field name="part_name"/>
|
||||
</xpath>
|
||||
<xpath expr="//button[@name='button_done']" position="attributes">
|
||||
<attribute name="class"/>
|
||||
</xpath>
|
||||
<xpath expr="//button[@name='button_in_progress']" position="attributes">
|
||||
<attribute name="invisible">1</attribute>
|
||||
</xpath>
|
||||
<xpath expr="//button[@name='%(purchase_request.action_purchase_request_line_make_purchase_order)d']" position="attributes">
|
||||
<attribute name="class">oe_highlight</attribute>
|
||||
</xpath>
|
||||
</field>
|
||||
</record>
|
||||
|
||||
<record id="view_purchase_request_tree_sf" model="ir.ui.view">
|
||||
<field name="name">purchase.request.sf.tree</field>
|
||||
<field name="model">purchase.request</field>
|
||||
<field name="inherit_id" ref="purchase_request.view_purchase_request_form"/>
|
||||
<field name="arch" type="xml">
|
||||
<xpath expr="//field[@name='activity_ids']" position="attributes">
|
||||
<attribute name="optional">hide</attribute>
|
||||
</xpath>
|
||||
</field>
|
||||
</record>
|
||||
|
||||
@@ -83,9 +63,4 @@
|
||||
</xpath>
|
||||
</field>
|
||||
</record>
|
||||
|
||||
<record model="ir.actions.act_window" id="purchase_request.purchase_request_form_action">
|
||||
<field name="name">Purchase Requests</field>
|
||||
<field name="context"></field>
|
||||
</record>
|
||||
</odoo>
|
||||
@@ -1,21 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8" ?>
|
||||
<odoo>
|
||||
<record id="stock_pikcing_inherited_form_jikimo_purchase_request" model="ir.ui.view">
|
||||
<field name="name">stock.pikcing.inherited.form.jikimo.purchase.request</field>
|
||||
<field name="model">stock.picking</field>
|
||||
<field name="inherit_id" ref="stock.view_picking_form"/>
|
||||
<field name="arch" type="xml">
|
||||
<xpath expr="//div[@name='button_box']/button" position="before">
|
||||
<button class="oe_stat_button" name="action_view_purchase_request" type="object" icon="fa-credit-card"
|
||||
attrs="{'invisible': [('purchase_request_count', '=', 0)]}">
|
||||
<div class="o_field_widget o_stat_info">
|
||||
<span class="o_stat_value">
|
||||
<field name="purchase_request_count"/>
|
||||
</span>
|
||||
<span class="o_stat_text">采购申请</span>
|
||||
</div>
|
||||
</button>
|
||||
</xpath>
|
||||
</field>
|
||||
</record>
|
||||
</odoo>
|
||||
@@ -1,4 +1,3 @@
|
||||
# License LGPL-3.0 or later (https://www.gnu.org/licenses/lgpl-3.0)
|
||||
|
||||
from . import purchase_request_line_make_purchase_order
|
||||
from . import purchase_request_wizard
|
||||
|
||||
@@ -32,7 +32,6 @@ 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
|
||||
@@ -64,8 +63,6 @@ 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
|
||||
@@ -103,27 +100,9 @@ class PurchaseRequestLineMakePurchaseOrder(models.TransientModel):
|
||||
def check_group(self, request_lines):
|
||||
# 去掉合并必须同一采购组的限制
|
||||
pass
|
||||
|
||||
def get_items(self, request_line_ids):
|
||||
request_line_obj = self.env["purchase.request.line"]
|
||||
items = []
|
||||
request_lines = request_line_obj.browse(request_line_ids).filtered(lambda line: line.pending_qty_to_receive > 0)
|
||||
self._check_valid_request_line(request_line_ids)
|
||||
self.check_group(request_lines)
|
||||
for line in request_lines:
|
||||
items.append([0, 0, self._prepare_item(line)])
|
||||
return items
|
||||
|
||||
|
||||
|
||||
class PurchaseRequestLineMakePurchaseOrderItem(models.TransientModel):
|
||||
_inherit = "purchase.request.line.make.purchase.order.item"
|
||||
|
||||
supply_method = fields.Selection(related='line_id.supply_method', string='供货方式')
|
||||
|
||||
wiz_id = fields.Many2one(
|
||||
comodel_name="purchase.request.line.make.purchase.order",
|
||||
string="Wizard",
|
||||
required=False,
|
||||
ondelete="cascade",
|
||||
readonly=True,
|
||||
)
|
||||
|
||||
@@ -1,12 +0,0 @@
|
||||
from odoo import models, fields, api
|
||||
|
||||
|
||||
class PurchaseRequestWizard(models.TransientModel):
|
||||
_name = 'purchase.request.wizard'
|
||||
_description = '采购申请向导'
|
||||
|
||||
purchase_request_id = fields.Many2one('purchase.request', string='采购申请')
|
||||
message = fields.Char(string='提示', readonly=True)
|
||||
|
||||
def confirm(self):
|
||||
return self.purchase_request_id.write({"state": "done"})
|
||||
@@ -1,22 +0,0 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<odoo>
|
||||
<record model="ir.ui.view" id="purchase_request_wizard_wizard_form_view">
|
||||
<field name="name">purchase.request.wizard.form.view</field>
|
||||
<field name="model">purchase.request.wizard</field>
|
||||
<field name="arch" type="xml">
|
||||
<form>
|
||||
<sheet>
|
||||
<div>
|
||||
<div style="white-space: pre-wrap;">
|
||||
<field name="message"/>
|
||||
</div>
|
||||
</div>
|
||||
<footer>
|
||||
<button string="确认" name="confirm" type="object" class="oe_highlight"/>
|
||||
<button string="取消" class="btn btn-secondary" special="cancel"/>
|
||||
</footer>
|
||||
</sheet>
|
||||
</form>
|
||||
</field>
|
||||
</record>
|
||||
</odoo>
|
||||
@@ -1,9 +1,10 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
{
|
||||
'name': "机企猫 采购申请审批流程",
|
||||
'name': "机企猫 采购审批流程",
|
||||
|
||||
'summary': """
|
||||
采购申请审批流程""",
|
||||
Short (1 phrase/line) summary of the module's purpose, used as
|
||||
subtitle on modules listing or apps.openerp.com""",
|
||||
|
||||
'description': """
|
||||
Long description of module's purpose
|
||||
|
||||
@@ -1,4 +1,3 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
|
||||
from . import models
|
||||
from . import stock_rule
|
||||
from . import models
|
||||
@@ -22,9 +22,3 @@ class PurchaseRequest(models.Model):
|
||||
self.state = 'approved'
|
||||
|
||||
return res
|
||||
|
||||
@api.model
|
||||
def _get_under_validation_exceptions(self):
|
||||
res = super(PurchaseRequest, self)._get_under_validation_exceptions()
|
||||
res.append("state")
|
||||
return res
|
||||
|
||||
@@ -1,16 +0,0 @@
|
||||
from odoo import models, api
|
||||
|
||||
class StockRule(models.Model):
|
||||
_inherit = 'stock.rule'
|
||||
|
||||
def _run_buy(self, procurements):
|
||||
res = super(StockRule, self)._run_buy(procurements)
|
||||
# 判断是否根据规则生成新的采购申请单据,如果生成则修改状态为 approved
|
||||
origins = list(set([procurement[0].origin for procurement in procurements]))
|
||||
for origin in origins:
|
||||
pr_ids = self.env["purchase.request"].sudo().search(
|
||||
[('origin', 'like', origin), ('rule_new_add', '=', True), ('state', '=', 'draft')])
|
||||
if pr_ids:
|
||||
pr_ids.write({'need_validation': False})
|
||||
pr_ids.write({"state": "approved", 'need_validation': True, 'rule_new_add': False})
|
||||
return res
|
||||
@@ -1,12 +1,12 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
{
|
||||
'name': "机企猫 采购审批流程",
|
||||
'name': "机企猫 采购申请审批流程",
|
||||
|
||||
'summary': """
|
||||
采购审批流程""",
|
||||
采购申请审批流程""",
|
||||
|
||||
'description': """
|
||||
采购审批流程""",
|
||||
采购申请审批流程""",
|
||||
|
||||
'author': "My Company",
|
||||
'website': "https://www.yourcompany.com",
|
||||
|
||||
@@ -1,2 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
from . import models
|
||||
@@ -1,18 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
{
|
||||
'name': 'Jikimo_test_generate_product_name',
|
||||
'version': '',
|
||||
'summary': """ Jikimo_test_generate_product_name Summary """,
|
||||
'author': '',
|
||||
'website': '',
|
||||
'category': '',
|
||||
'depends': ['sf_manufacturing'],
|
||||
'data': [
|
||||
|
||||
],
|
||||
|
||||
'application': True,
|
||||
'installable': True,
|
||||
'auto_install': False,
|
||||
'license': 'LGPL-3',
|
||||
}
|
||||
@@ -1,2 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
from . import product_template
|
||||
@@ -1,21 +0,0 @@
|
||||
from odoo import models
|
||||
|
||||
|
||||
class ProductTemplate(models.Model):
|
||||
_inherit = 'product.template'
|
||||
|
||||
def generate_product_name(self, order_id, item, i):
|
||||
"""生成成品名称"""
|
||||
# 3D文件名(去掉后缀,截取前40个字符)+“-”+模型ID
|
||||
product_name = '%s-%s' % ('.'.join(item['model_name'].split('.')[:-1])[:40], item['model_id'])
|
||||
return product_name
|
||||
|
||||
def generate_embryo_name(self, order_id, item, materials_id, materials_type_id, embryo_redundancy_id, i):
|
||||
"""生成坯料名称"""
|
||||
embryo_name = '%s-%s[%s * %s * %s]%s' % (materials_id.name, materials_type_id.name,
|
||||
self.format_float(item['model_long'] + embryo_redundancy_id.long),
|
||||
self.format_float(item['model_width'] + embryo_redundancy_id.width),
|
||||
self.format_float(item['model_height'] + embryo_redundancy_id.height),
|
||||
item['model_id'])
|
||||
return embryo_name
|
||||
|
||||
@@ -1,3 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
from . import controllers
|
||||
from . import models
|
||||
@@ -1,17 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
{
|
||||
'name': '机企猫 报工系统API',
|
||||
'version': '1.0.0',
|
||||
'summary': """ 机企猫 报工系统API """,
|
||||
'author': '机企猫',
|
||||
'website': 'https://xt.sf.jikimo.com',
|
||||
'category': 'sf',
|
||||
'depends': ['base', 'sf_maintenance', 'jikimo_mini_program'],
|
||||
'data': [
|
||||
],
|
||||
|
||||
'application': True,
|
||||
'installable': True,
|
||||
'auto_install': False,
|
||||
'license': 'LGPL-3',
|
||||
}
|
||||
@@ -1,2 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
from . import main
|
||||
@@ -1,69 +0,0 @@
|
||||
import json
|
||||
from odoo import http
|
||||
from odoo.http import request
|
||||
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='wechat_token', cors='*')
|
||||
@api_log('人工线下加工编程文件传输', requester='报工系统')
|
||||
def manual_download_program(self):
|
||||
"""
|
||||
人工线下加工传输编程文件
|
||||
"""
|
||||
data = json.loads(request.httprequest.data)
|
||||
maintenance_equipment_id = data.get('maintenance_equipment_id')
|
||||
model_id = data.get('model_id')
|
||||
if not maintenance_equipment_id or not model_id:
|
||||
return {'code': 400, 'message': '参数错误'}
|
||||
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)
|
||||
if not product:
|
||||
return {'code': 400, 'message': '请扫描正确的图纸'}
|
||||
# 获取刀具组
|
||||
tool_groups_id = request.env['sf.tool.groups'].sudo().search([('equipment_ids', 'in', maintenance_equipment.id)], limit=1)
|
||||
if not tool_groups_id:
|
||||
return {'code': 400, 'message': '刀具组不存在'}
|
||||
|
||||
ftp_resconfig = request.env['res.config.settings'].sudo().get_values()
|
||||
if not ftp_resconfig['ftp_host'] or not ftp_resconfig['ftp_port'] or not ftp_resconfig['ftp_user'] or not ftp_resconfig['ftp_password']:
|
||||
return {'code': 400, 'message': '编程文件FTP配置错误'}
|
||||
source_ftp_info = {
|
||||
'host': ftp_resconfig['ftp_host'],
|
||||
'port': int(ftp_resconfig['ftp_port']),
|
||||
'username': ftp_resconfig['ftp_user'],
|
||||
'password': ftp_resconfig['ftp_password']
|
||||
}
|
||||
if not maintenance_equipment.ftp_host or not maintenance_equipment.ftp_port or not maintenance_equipment.ftp_username or not maintenance_equipment.ftp_password:
|
||||
return {'code': 400, 'message': '机台FTP配置错误'}
|
||||
target_ftp_info = {
|
||||
'host': maintenance_equipment.ftp_host,
|
||||
'port': int(maintenance_equipment.ftp_port),
|
||||
'username': maintenance_equipment.ftp_username,
|
||||
'password': maintenance_equipment.ftp_password
|
||||
}
|
||||
# 传输nc文件
|
||||
try:
|
||||
result = transfer_files(
|
||||
source_ftp_info,
|
||||
target_ftp_info,
|
||||
'/' + str(model_id),
|
||||
'/',
|
||||
match_str=r'^\d*-' + tool_groups_id.name + r'-\w{2}-all\.nc$'
|
||||
)
|
||||
if len(result) > 0:
|
||||
return {'code': 200, 'message': '传输成功', 'file_list': result}
|
||||
else:
|
||||
return {'code': 404, 'message': '未找到编程文件'}
|
||||
except Exception as e:
|
||||
return {'code': 500, 'message': str(e)}
|
||||
@@ -1 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
@@ -4,7 +4,6 @@ import json
|
||||
import logging
|
||||
from odoo.addons.sf_mrs_connect.controllers.controllers import Sf_Mrs_Connect
|
||||
from odoo.addons.sf_manufacturing.controllers.controllers import Manufacturing_Connect
|
||||
from odoo.addons.sf_base.decorators.api_log import api_log
|
||||
from datetime import datetime
|
||||
|
||||
_logger = logging.getLogger(__name__)
|
||||
@@ -13,7 +12,6 @@ class WorkorderExceptionConroller(http.Controller):
|
||||
|
||||
@http.route('/AutoDeviceApi/BillError', type='json', auth='public', methods=['GET', 'POST'], csrf=False,
|
||||
cors="*")
|
||||
@api_log('工单对接错误', requester='中控系统')
|
||||
def workder_exception(self, **kw):
|
||||
"""
|
||||
记录工单异常
|
||||
|
||||
@@ -52,10 +52,10 @@ class JikimoWorkorderException(models.Model):
|
||||
|
||||
def _get_message(self, message_queue_ids):
|
||||
contents, _ = super(JikimoWorkorderException, self)._get_message(message_queue_ids)
|
||||
base_url = self.env['ir.config_parameter'].get_param('web.base.url')
|
||||
url = self.env['ir.config_parameter'].get_param('web.base.url')
|
||||
action_id = self.env.ref('mrp.mrp_production_action').id
|
||||
for index, content in enumerate(contents):
|
||||
exception_id = self.env['jikimo.workorder.exception'].browse(message_queue_ids[index].res_id)
|
||||
url = base_url + '/web#id=%s&view_type=form&action=%s' % (exception_id.workorder_id.production_id.id, action_id)
|
||||
url = url + '/web#id=%s&view_type=form&action=%s' % (exception_id.workorder_id.production_id.id, action_id)
|
||||
contents[index] = content.replace('{{url}}', url)
|
||||
return contents, message_queue_ids
|
||||
|
||||
@@ -133,7 +133,6 @@ class QualityCheck(models.Model):
|
||||
part_name = fields.Char('零件名称', related='product_id.part_name', readonly=False, store=True)
|
||||
part_number = fields.Char('零件图号', related='product_id.part_number', readonly=False, store=True)
|
||||
material_name = fields.Char('材料名称', compute='_compute_material_name')
|
||||
model_id = fields.Char('模型ID', related='product_id.model_id')
|
||||
|
||||
# # 总数量,值为调拨单_产品明细_数量
|
||||
# total_qty = fields.Float('总数量', compute='_compute_total_qty', readonly=True)
|
||||
@@ -142,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', store=True)
|
||||
total_qty = fields.Char('总数量', compute='_compute_total_qty')
|
||||
|
||||
column_nums = fields.Integer('测量值列数', default=1)
|
||||
|
||||
@@ -154,9 +153,9 @@ class QualityCheck(models.Model):
|
||||
for move in record.picking_id.move_ids_without_package:
|
||||
if move.product_id == record.product_id:
|
||||
total_qty = int(move.product_uom_qty)
|
||||
record.total_qty = total_qty if total_qty > 0 else 0
|
||||
record.total_qty = total_qty if total_qty > 0 else ''
|
||||
else:
|
||||
record.total_qty = 0
|
||||
record.total_qty = ''
|
||||
|
||||
# 检验数
|
||||
check_qty = fields.Integer('检验数', default=lambda self: self._get_default_check_qty())
|
||||
@@ -207,7 +206,7 @@ class QualityCheck(models.Model):
|
||||
('NG', 'NG')
|
||||
], string='出厂检验报告结果', default='OK')
|
||||
measure_operator = fields.Many2one('res.users', string='操机员')
|
||||
quality_manager = fields.Many2one('res.users', string='质检员', compute='_compute_quality_manager')
|
||||
quality_manager = fields.Many2one('res.users', string='质检员', compute='_compute_quality_manager', store=True)
|
||||
|
||||
@api.depends('measure_line_ids')
|
||||
def _compute_quality_manager(self):
|
||||
@@ -259,23 +258,6 @@ class QualityCheck(models.Model):
|
||||
line[field_name] = False
|
||||
self.column_nums = self.column_nums - 1
|
||||
|
||||
def upload_measure_line(self):
|
||||
"""
|
||||
上传测量值
|
||||
"""
|
||||
|
||||
for record in self:
|
||||
if not record.part_name or not record.part_number:
|
||||
raise UserError(_('零件名称和零件图号均不能为空'))
|
||||
|
||||
# 如果验证通过,返回原动作
|
||||
action = self.env.ref('quality_control.import_complex_model_wizard').read()[0]
|
||||
action['context'] = {
|
||||
'default_model_name': 'quality.check.measure.line',
|
||||
'default_check_id': self.id,
|
||||
}
|
||||
return action
|
||||
|
||||
def do_preview(self):
|
||||
"""
|
||||
预览出厂检验报告
|
||||
@@ -339,7 +321,7 @@ class QualityCheck(models.Model):
|
||||
|
||||
# 4. 获取报告动作并生成PDF(此时二维码将包含正确的文档ID)
|
||||
report_action = self.env.ref('sf_quality.action_report_quality_inspection')
|
||||
pdf_content, v = report_action._render_qweb_pdf(
|
||||
pdf_content, _ = report_action._render_qweb_pdf(
|
||||
report_ref=report_action.report_name,
|
||||
res_ids=self.ids
|
||||
)
|
||||
@@ -736,9 +718,8 @@ class QualityCheck(models.Model):
|
||||
def _compute_qty_to_test(self):
|
||||
for qc in self:
|
||||
if qc.is_lot_tested_fractionally:
|
||||
rounding = qc.product_id.uom_id.rounding if qc.product_id.uom_id else 0.01
|
||||
qc.qty_to_test = float_round(qc.qty_line * qc.testing_percentage_within_lot / 100,
|
||||
precision_rounding=rounding, rounding_method="UP")
|
||||
precision_rounding=self.product_id.uom_id.rounding, rounding_method="UP")
|
||||
else:
|
||||
qc.qty_to_test = qc.qty_line
|
||||
|
||||
|
||||
@@ -267,7 +267,7 @@
|
||||
<field name="company_id" invisible="1"/>
|
||||
<field name="categ_type" invisible="1"/>
|
||||
<field name="product_id" attrs="{'invisible' : [('measure_on', '=', 'operation')]}"/>
|
||||
<field name="part_name" attrs="{'invisible': [('categ_type', '!=', '成品')], 'readonly': [('publish_status', '=', 'published')]}"/>
|
||||
<field name="part_name" attrs="{'invisible': [('categ_type', '!=', '成品')]}"/>
|
||||
<field name="part_number" attrs="{'invisible': [('categ_type', '!=', '成品')], 'readonly': [('publish_status', '=', 'published')]}"/>
|
||||
<field name="material_name" attrs="{'invisible': [('categ_type', '!=', '成品')]}"/>
|
||||
<field name="total_qty" attrs="{'invisible': ['|', ('measure_on', '!=', 'product'), ('is_out_check', '=', False)]}"/>
|
||||
@@ -334,15 +334,11 @@
|
||||
<div class="o_row">
|
||||
<button name="add_measure_line" type="object" class="btn-primary" string="添加测量值" attrs="{'invisible': [('publish_status', '=', 'published')]}"/>
|
||||
<button name="remove_measure_line" type="object" class="btn-primary" string="删除测量值" attrs="{'invisible': [('publish_status', '=', 'published')]}"/>
|
||||
<!-- <button name="%(quality_control.import_complex_model_wizard)d" string="上传111" -->
|
||||
<!-- type="action" -->
|
||||
<!-- class="btn-primary" -->
|
||||
<!-- attrs="{'force_show':1, 'invisible': [('publish_status', '=', 'published')]}" -->
|
||||
<!-- context="{'default_model_name': 'quality.check.measure.line', 'default_check_id': id}"/> -->
|
||||
<button name="upload_measure_line" string="上传"
|
||||
type="object"
|
||||
<button name="%(quality_control.import_complex_model_wizard)d" string="上传"
|
||||
type="action"
|
||||
class="btn-primary"
|
||||
attrs="{'force_show':1, 'invisible': [('publish_status', '=', 'published')]}"/>
|
||||
attrs="{'force_show':1, 'invisible': [('publish_status', '=', 'published')]}"
|
||||
context="{'default_model_name': 'quality.check.measure.line', 'default_check_id': id}"/>
|
||||
</div>
|
||||
<br/>
|
||||
<div class="o_row">
|
||||
@@ -493,9 +489,6 @@
|
||||
<field name="picking_id"/>
|
||||
<field name="lot_id"/>
|
||||
<field name="team_id"/>
|
||||
<field name="part_number"/>
|
||||
<field name="part_name"/>
|
||||
<field name="model_id"/>
|
||||
<filter string="In Progress" name="progress" domain="[('quality_state', '=', 'none')]"/>
|
||||
<filter string="Passed" name="passed" domain="[('quality_state', '=', 'pass')]"/>
|
||||
<filter string="Failed" name="failed" domain="[('quality_state', '=', 'fail')]"/>
|
||||
|
||||
@@ -22,7 +22,6 @@ _logger = logging.getLogger(__name__)
|
||||
class ImportComplexModelWizard(models.TransientModel):
|
||||
_name = 'quality.check.import.complex.model.wizard'
|
||||
file_data = fields.Binary("数据文件")
|
||||
filename = fields.Char(string='文件名')
|
||||
model_name = fields.Char(string='Model Name')
|
||||
field_basis = fields.Char(string='Field Basis')
|
||||
check_id = fields.Many2one(string='质检单', comodel_name='quality.check')
|
||||
@@ -94,16 +93,11 @@ class ImportComplexModelWizard(models.TransientModel):
|
||||
|
||||
return repeats
|
||||
|
||||
def convert_float(self, value):
|
||||
if isinstance(value, float) and value.is_integer():
|
||||
return int(value)
|
||||
return value
|
||||
|
||||
def import_data(self):
|
||||
"""导入Excel数据"""
|
||||
if not self.file_data:
|
||||
raise UserError(_('请先上传Excel文件'))
|
||||
|
||||
|
||||
if self.check_id.measure_line_ids:
|
||||
self.sudo().check_id.measure_line_ids.unlink()
|
||||
|
||||
@@ -167,20 +161,6 @@ class ImportComplexModelWizard(models.TransientModel):
|
||||
|
||||
# 从第二行开始读取数据(跳过表头)
|
||||
max_columns = 1
|
||||
for row_index in range(1, sheet.nrows):
|
||||
row = sheet.row_values(row_index)
|
||||
# 检查行是否有数据
|
||||
if not any(row):
|
||||
continue
|
||||
|
||||
if row[2] == '':
|
||||
continue
|
||||
logging.info('================%s, %s==' % (row[1], type(row[1])))
|
||||
|
||||
compare_value = self.convert_float(row[1])
|
||||
if str(compare_value) != quality_check.part_number:
|
||||
print(sheet.row_values(row_index))
|
||||
raise UserError(_('上传内容图号错误,请修改'))
|
||||
for row_index in range(1, sheet.nrows):
|
||||
row = sheet.row_values(row_index)
|
||||
|
||||
@@ -197,14 +177,14 @@ class ImportComplexModelWizard(models.TransientModel):
|
||||
'sequence': len(quality_check.measure_line_ids) + 1,
|
||||
'product_name': str(row[0]) if row[0] else '', # 产品名称列
|
||||
'drawing_no': str(row[1]) if row[1] else '', # 图号列
|
||||
'measure_item': str(self.convert_float(row[2])) or '', # 检测项目列
|
||||
'measure_value1': str(self.convert_float(row[4])) if row[4] else '', # 测量值1
|
||||
'measure_value2': str(self.convert_float(row[5])) if row[5] else '', # 测量值2
|
||||
'measure_value3': str(self.convert_float(row[6])) if len(row) > 6 and row[6] else '', # 测量值3
|
||||
'measure_value4': str(self.convert_float(row[7])) if len(row) > 7 and row[7] else '', # 测量值4
|
||||
'measure_value5': str(self.convert_float(row[8])) if len(row) > 8 and row[8] else '', # 测量值5
|
||||
'measure_item': row[2] or '', # 检测项目列
|
||||
'measure_value1': str(row[4]) if row[4] else '', # 测量值1
|
||||
'measure_value2': str(row[5]) if row[5] else '', # 测量值2
|
||||
'measure_value3': str(row[6]) if len(row) > 6 and row[6] else '', # 测量值3
|
||||
'measure_value4': str(row[7]) if len(row) > 7 and row[7] else '', # 测量值4
|
||||
'measure_value5': str(row[8]) if len(row) > 8 and row[8] else '', # 测量值5
|
||||
'measure_result': 'NG' if row[9] == 'NG' else 'OK', # 判定列
|
||||
'remark': self.convert_float(row[10]) if len(row) > 10 and row[10] else '', # 备注列
|
||||
'remark': row[10] if len(row) > 10 and row[10] else '', # 备注列
|
||||
}
|
||||
|
||||
for i in range(1, 6):
|
||||
@@ -214,7 +194,7 @@ class ImportComplexModelWizard(models.TransientModel):
|
||||
|
||||
self.env['quality.check.measure.line'].create(measure_line_vals)
|
||||
valid_data_imported = True
|
||||
|
||||
|
||||
quality_check.column_nums = max_columns
|
||||
|
||||
# 检查是否有有效数据被导入
|
||||
@@ -444,8 +424,7 @@ class ImportComplexModelWizard(models.TransientModel):
|
||||
# )
|
||||
|
||||
def download_excel_template(self):
|
||||
base_url = self.env['ir.config_parameter'].sudo().get_param(
|
||||
'web.base.url') + '/quality_control/static/src/binary/出厂检验报告上传模版.xlsx'
|
||||
base_url = self.env['ir.config_parameter'].sudo().get_param('web.base.url') + '/quality_control/static/src/binary/出厂检验报告上传模版.xlsx'
|
||||
|
||||
# 只有当原始 URL 使用 http 时才替换为 https
|
||||
if base_url.startswith("http://"):
|
||||
|
||||
@@ -6,8 +6,7 @@
|
||||
<field name="arch" type="xml">
|
||||
<form>
|
||||
<group>
|
||||
<field name="file_data" widget="binary" filename="filename" options="{'accepted_file_extensions': '.xls,.xlsx'}"/>
|
||||
<field name="filename" invisible="1"/>
|
||||
<field name="file_data" widget="binary" options="{'accepted_file_extensions': '.xlsx'}"/>
|
||||
</group>
|
||||
<footer>
|
||||
<button string="确认导入" name="import_data" type="object" class="btn-primary"/>
|
||||
|
||||
@@ -23,8 +23,8 @@ class QualityCheckWizard(models.TransientModel):
|
||||
lot_name = fields.Char(related='current_check_id.lot_name')
|
||||
lot_line_id = fields.Many2one(related='current_check_id.lot_line_id')
|
||||
qty_line = fields.Float(related='current_check_id.qty_line')
|
||||
qty_to_test = fields.Float(related='current_check_id.qty_to_test', string='待检')
|
||||
qty_tested = fields.Float(related='current_check_id.qty_tested', string='已检', readonly=False)
|
||||
qty_to_test = fields.Float(related='current_check_id.qty_to_test')
|
||||
qty_tested = fields.Float(related='current_check_id.qty_tested', readonly=False)
|
||||
measure = fields.Float(related='current_check_id.measure', readonly=False)
|
||||
measure_on = fields.Selection(related='current_check_id.measure_on')
|
||||
quality_state = fields.Selection(related='current_check_id.quality_state')
|
||||
|
||||
@@ -1,7 +1,3 @@
|
||||
pystrich
|
||||
cpca==0.5.5
|
||||
wechatpy==1.8.18
|
||||
pycryptodome==3.22.0
|
||||
openupgradelib==3.10.0
|
||||
opcua==0.98.13
|
||||
openpyxl
|
||||
cpca
|
||||
pycryptodome==3.20
|
||||
|
||||
@@ -1,4 +1,3 @@
|
||||
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': [
|
||||
],
|
||||
|
||||
@@ -9,6 +9,7 @@ class Printer(models.Model):
|
||||
ip_address = fields.Char(string='IP 地址', required=True)
|
||||
port = fields.Integer(string='端口', default=9100)
|
||||
|
||||
|
||||
class TableStyle(models.Model):
|
||||
_name = 'table.style'
|
||||
_description = '标签样式'
|
||||
|
||||
@@ -2,16 +2,7 @@
|
||||
import time, datetime
|
||||
import hashlib
|
||||
from odoo import models
|
||||
from typing import Optional
|
||||
import socket
|
||||
import os
|
||||
import logging
|
||||
import qrcode
|
||||
from reportlab.pdfgen import canvas
|
||||
from reportlab.lib.units import inch
|
||||
from PyPDF2 import PdfFileReader, PdfFileWriter
|
||||
from reportlab.pdfbase import pdfmetrics
|
||||
from reportlab.pdfbase.ttfonts import TTFont
|
||||
|
||||
class Common(models.Model):
|
||||
_name = 'sf.sync.common'
|
||||
@@ -101,145 +92,3 @@ class PrintingUtils(models.AbstractModel):
|
||||
# host = "192.168.50.110" # 可以作为参数传入,或者在此配置
|
||||
# port = 9100 # 可以作为参数传入,或者在此配置
|
||||
self.send_to_printer(host, port, zpl_code)
|
||||
|
||||
|
||||
def add_qr_code_to_pdf(
|
||||
self,
|
||||
pdf_path:str,
|
||||
content:str,
|
||||
qr_code_buttom_text:Optional[str]=False,
|
||||
buttom_text:Optional[str]=False,
|
||||
):
|
||||
"""
|
||||
在PDF文件中添加二维码
|
||||
:param pdf_path: PDF文件路径
|
||||
:param content: 二维码内容
|
||||
:param qr_code_buttom_text: 二维码下方文字
|
||||
:param buttom_text: 正文下方文字
|
||||
:return: 是否成功
|
||||
"""
|
||||
if not os.path.exists(pdf_path):
|
||||
logging.warning(f'PDF文件不存在: {pdf_path}')
|
||||
return False
|
||||
|
||||
# 生成二维码
|
||||
qr = qrcode.QRCode(version=1, box_size=10, border=5)
|
||||
qr.add_data(str(content))
|
||||
qr.make(fit=True)
|
||||
qr_img = qr.make_image(fill_color="black", back_color="white")
|
||||
|
||||
# 保存二维码为临时文件
|
||||
qr_temp_path = '/tmp/qr_temp.png'
|
||||
qr_img.save(qr_temp_path)
|
||||
|
||||
# 创建一个临时PDF文件路径
|
||||
output_temp_path = '/tmp/output_temp.pdf'
|
||||
|
||||
try:
|
||||
# 使用reportlab创建一个新的PDF
|
||||
|
||||
|
||||
# 注册中文字体
|
||||
font_paths = [
|
||||
"/usr/share/fonts/chinese/simsun.ttc", # Windows系统宋体
|
||||
"c:/windows/fonts/simsun.ttc", # Windows系统宋体另一个位置
|
||||
"/usr/share/fonts/truetype/droid/DroidSansFallbackFull.ttf", # Linux Droid字体
|
||||
"/usr/share/fonts/truetype/wqy/wqy-zenhei.ttc", # 文泉驿正黑
|
||||
"/usr/share/fonts/chinese/TrueType/simsun.ttc", # 某些Linux发行版位置
|
||||
]
|
||||
|
||||
font_found = False
|
||||
for font_path in font_paths:
|
||||
if os.path.exists(font_path):
|
||||
try:
|
||||
pdfmetrics.registerFont(TTFont('SimSun', font_path))
|
||||
font_found = True
|
||||
break
|
||||
except:
|
||||
continue
|
||||
|
||||
# 读取原始PDF
|
||||
with open(pdf_path, "rb") as original_file:
|
||||
existing_pdf = PdfFileReader(original_file)
|
||||
output = PdfFileWriter()
|
||||
|
||||
# 处理最后一页
|
||||
last_page = existing_pdf.getNumPages() - 1
|
||||
page = existing_pdf.getPage(last_page)
|
||||
# 获取页面尺寸
|
||||
page_width = float(page.mediaBox.getWidth())
|
||||
page_height = float(page.mediaBox.getHeight())
|
||||
|
||||
# 创建一个新的PDF页面用于放置二维码
|
||||
c = canvas.Canvas(output_temp_path, pagesize=(page_width, page_height))
|
||||
|
||||
# 设置字体
|
||||
if font_found:
|
||||
c.setFont('SimSun', 10) # 增大字体大小到14pt
|
||||
else:
|
||||
# 如果没有找到中文字体,使用默认字体
|
||||
c.setFont('Helvetica', 10)
|
||||
logging.warning("未找到中文字体,将使用默认字体")
|
||||
|
||||
# 在右下角绘制二维码,预留边距
|
||||
qr_size = 1.5 * inch # 二维码大小为2英寸
|
||||
margin = 0.1 * inch # 边距为0.4英寸
|
||||
qr_y = margin + 20 # 将二维码向上移动一点,为文字留出空间
|
||||
c.drawImage(qr_temp_path, page_width - qr_size - margin, qr_y, width=qr_size, height=qr_size)
|
||||
|
||||
if qr_code_buttom_text:
|
||||
# 在二维码下方绘制文字
|
||||
text = qr_code_buttom_text
|
||||
text_width = c.stringWidth(text, "SimSun" if font_found else "Helvetica", 10) # 准确计算文字宽度
|
||||
text_x = page_width - qr_size - margin + (qr_size - text_width) / 2 # 文字居中对齐
|
||||
text_y = margin + 20 # 文字位置靠近底部
|
||||
c.drawString(text_x, text_y, text)
|
||||
|
||||
# 设置字体
|
||||
if font_found:
|
||||
c.setFont('SimSun', 12) # 增大字体大小到14pt
|
||||
else:
|
||||
# 如果没有找到中文字体,使用默认字体
|
||||
c.setFont('Helvetica', 120)
|
||||
logging.warning("未找到中文字体,将使用默认字体")
|
||||
|
||||
if buttom_text:
|
||||
# 在下方中间添加文字
|
||||
text = buttom_text
|
||||
text_width = c.stringWidth(text, "SimSun" if font_found else "Helvetica", 12) # 准确计算文字宽度
|
||||
text_x = (page_width - text_width) / 2 # 文字居中对齐
|
||||
text_y = margin + 20 # 文字位置靠近底部
|
||||
c.drawString(text_x, text_y, text)
|
||||
|
||||
c.save()
|
||||
|
||||
# 读取带有二维码的临时PDF
|
||||
with open(output_temp_path, "rb") as qr_file:
|
||||
qr_pdf = PdfFileReader(qr_file)
|
||||
qr_page = qr_pdf.getPage(0)
|
||||
|
||||
# 合并原始页面和二维码页面
|
||||
page.mergePage(qr_page)
|
||||
|
||||
# 添加剩余的页面
|
||||
for i in range(0, last_page):
|
||||
output.addPage(existing_pdf.getPage(i))
|
||||
|
||||
output.addPage(page)
|
||||
|
||||
# 保存最终的PDF到一个临时文件
|
||||
final_temp_path = pdf_path + '.tmp'
|
||||
with open(final_temp_path, "wb") as output_file:
|
||||
output.write(output_file)
|
||||
|
||||
# 替换原始文件
|
||||
os.replace(final_temp_path, pdf_path)
|
||||
|
||||
return True
|
||||
|
||||
finally:
|
||||
# 清理临时文件
|
||||
if os.path.exists(qr_temp_path):
|
||||
os.remove(qr_temp_path)
|
||||
if os.path.exists(output_temp_path):
|
||||
os.remove(output_temp_path)
|
||||
@@ -1,18 +1,15 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
import logging
|
||||
import json
|
||||
import logging
|
||||
import base64
|
||||
from odoo import http
|
||||
from odoo.http import request
|
||||
from odoo.addons.sf_base.decorators.api_log import api_log
|
||||
|
||||
_logger = logging.getLogger(__name__)
|
||||
|
||||
class Manufacturing_Connect(http.Controller):
|
||||
|
||||
@http.route('/AutoDeviceApi/MachineToolGroup', type='json', auth='sf_token', methods=['GET', 'POST'], csrf=False,
|
||||
cors="*")
|
||||
@api_log('机床刀具组', requester='中控系统')
|
||||
def get_maintenance_tool_groups_Info(self, **kw):
|
||||
"""
|
||||
机床刀具组接口
|
||||
|
||||
@@ -1 +0,0 @@
|
||||
from . import api_log
|
||||
@@ -1,65 +0,0 @@
|
||||
|
||||
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)
|
||||
origin_result = result
|
||||
if isinstance(result, str):
|
||||
result = json.loads(result)
|
||||
|
||||
# 计算响应时间
|
||||
end_time = datetime.now()
|
||||
response_time = (end_time - start_time).total_seconds()
|
||||
|
||||
# 获取响应状态
|
||||
status = result.get('code') if 'code' in result else result.get('ErrorCode') if 'ErrorCode' in result else 200
|
||||
|
||||
# 创建日志记录
|
||||
log_vals = {
|
||||
'name': name or func.__name__,
|
||||
'path': path,
|
||||
'method': method.upper(),
|
||||
'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': 200 if status == 0 else status,
|
||||
'requester': requester,
|
||||
'responser': '智能工厂'
|
||||
}
|
||||
|
||||
# 异步创建日志记录
|
||||
request.env['api.request.log'].sudo().with_context(tracking_disable=True).create(log_vals)
|
||||
|
||||
return origin_result
|
||||
|
||||
except Exception as e:
|
||||
_logger.error(f"API日志记录失败: {str(e)}")
|
||||
# 即使日志记录失败,也要返回原始结果
|
||||
return func(*args, **kwargs)
|
||||
return wrapper
|
||||
return decorator
|
||||
@@ -6,4 +6,3 @@ from . import functional_fixture
|
||||
from . import tool_other_features
|
||||
from . import basic_parameters_fixture
|
||||
from . import ir_sequence
|
||||
from . import api_log
|
||||
|
||||
@@ -1,72 +0,0 @@
|
||||
from odoo import models, fields, api
|
||||
import json, ast
|
||||
import logging
|
||||
import requests
|
||||
|
||||
_logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
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('响应方')
|
||||
|
||||
@api.model
|
||||
def log_request(self, method, url, name=None, responser=None, **kwargs):
|
||||
# Log the request
|
||||
request_headers = kwargs.get('headers', {})
|
||||
request_body = kwargs.get('json') or kwargs.get('params') or {}
|
||||
|
||||
_logger.info(f"Request: {method} {url} Headers: {request_headers} Body: {request_body}")
|
||||
|
||||
# Make the actual request
|
||||
response = requests.request(method, url, **kwargs)
|
||||
|
||||
# Log the response
|
||||
response_status = response.status_code
|
||||
response_headers = response.headers
|
||||
response_body = response.text
|
||||
response_time = response.elapsed.total_seconds()
|
||||
|
||||
_logger.info(f"Response: Status: {response_status} Headers: {response_headers} Body: {response_body}")
|
||||
|
||||
try:
|
||||
# 如果是字符串,先尝试用 ast.literal_eval 安全地转换成 Python 对象
|
||||
if isinstance(response_body, str):
|
||||
|
||||
response_body_obj = json.loads(response_body)
|
||||
else:
|
||||
response_body_obj = response_body
|
||||
|
||||
# 再使用 json.dumps 转换成标准的 JSON 字符串
|
||||
response_body = json.dumps(response_body_obj, ensure_ascii=False)
|
||||
except Exception as e:
|
||||
_logger.warning(f"转换 response_body 到标准 JSON 失败: {str(e)}")
|
||||
# 如果转换失败,保持原样
|
||||
|
||||
# Save to database
|
||||
self.sudo().create({
|
||||
'name': name,
|
||||
'path': url,
|
||||
'method': method.upper(),
|
||||
'request_data': request_body,
|
||||
'response_data': response_body,
|
||||
'remote_addr': None,
|
||||
'response_time': response_time,
|
||||
'status': response_status,
|
||||
'requester': '智能工厂',
|
||||
'responser': responser
|
||||
})
|
||||
|
||||
return response
|
||||
@@ -254,6 +254,3 @@ 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
|
||||
|
@@ -148,17 +148,12 @@ td.o_required_modifier {
|
||||
color: #aaa;
|
||||
}
|
||||
|
||||
// .o_kanban_primary_left {
|
||||
// display: flex;
|
||||
// flex-direction: row-reverse;
|
||||
// justify-content: flex-start;
|
||||
// }
|
||||
.o_list_button {
|
||||
min-width: 32px;
|
||||
}
|
||||
.o_list_record_remove {
|
||||
padding-left: 0px !important;
|
||||
.o_kanban_primary_left {
|
||||
display: flex;
|
||||
flex-direction: row-reverse;
|
||||
justify-content: flex-start;
|
||||
}
|
||||
|
||||
.diameter:before {
|
||||
content:"Ф";
|
||||
display:inline;
|
||||
|
||||
@@ -1,83 +0,0 @@
|
||||
<?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="name"/>
|
||||
<field name="path"/>
|
||||
<field name="method"/>
|
||||
<field name="remote_addr"/>
|
||||
<field name="response_time" sum="0"/>
|
||||
<field name="requester"/>
|
||||
<field name="responser"/>
|
||||
<field name="create_date" string="请求时间"/>
|
||||
<field name="status" sum="0"/>
|
||||
</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="requester"/>
|
||||
<field name="responser"/>
|
||||
<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 model="ir.ui.view" id="view_api_request_log_search">
|
||||
<field name="name">api.request.log.search</field>
|
||||
<field name="model">api.request.log</field>
|
||||
<field name="arch" type="xml">
|
||||
<search string="API请求日志">
|
||||
<field name="name"/>
|
||||
<field name="requester"/>
|
||||
<field name="responser"/>
|
||||
<group>
|
||||
<filter name="name" context="{'group_by':'name'}"/>
|
||||
<filter name="requester" context="{'group_by':'requester'}"/>
|
||||
<filter name="responser" context="{'group_by':'responser'}"/>
|
||||
</group>
|
||||
</search>
|
||||
</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>
|
||||
@@ -5,7 +5,7 @@
|
||||
<record model="ir.ui.view" id="mrs_production_process_parameter_tree">
|
||||
<field name="model">sf.production.process.parameter</field>
|
||||
<field name="arch" type="xml">
|
||||
<tree string="工艺可选参数" create="0" delete="0">
|
||||
<tree string="表面工艺可选参数" create="0" delete="0">
|
||||
<field name="code"/>
|
||||
<field name="name"/>
|
||||
<field name="gain_way"/>
|
||||
@@ -15,7 +15,7 @@
|
||||
<record model="ir.ui.view" id="mrs_production_process_parameter_form">
|
||||
<field name="model">sf.production.process.parameter</field>
|
||||
<field name="arch" type="xml">
|
||||
<form string="工艺可选参数" create="0" delete="0" >
|
||||
<form string="表面工艺可选参数" create="0" delete="0" >
|
||||
<sheet>
|
||||
<div class="oe_title">
|
||||
<h1>
|
||||
@@ -104,7 +104,7 @@
|
||||
<record model="ir.ui.view" id="sf_production_process_category_form">
|
||||
<field name="model">sf.production.process.category</field>
|
||||
<field name="arch" type="xml">
|
||||
<form string="工艺类别" create="0" edit="0" delete="1">
|
||||
<form string="表面工艺类别" create="0" edit="0" delete="1">
|
||||
<sheet>
|
||||
<div class="oe_title">
|
||||
<h1>
|
||||
@@ -120,7 +120,7 @@
|
||||
</group>
|
||||
</group>
|
||||
<notebook>
|
||||
<page string="工艺">
|
||||
<page string="表面工艺">
|
||||
<field name='production_process_ids' widget="ony2many">
|
||||
<tree editable="bottom">
|
||||
<field name="code" string="编码号" readonly="1" force_save="1"/>
|
||||
@@ -139,7 +139,7 @@
|
||||
<record model="ir.ui.view" id="sf_production_process_category_tree">
|
||||
<field name="model">sf.production.process.category</field>
|
||||
<field name="arch" type="xml">
|
||||
<tree string="工艺类别" default_order="sequence, id" create="0" edit="0" delete="1">
|
||||
<tree string="表面工艺类别" default_order="sequence, id" create="0" edit="0" delete="1">
|
||||
<field name="sequence" widget="handle" string="序号" readonly="1"/>
|
||||
<field name="code"/>
|
||||
<field name="name" string="名称"/>
|
||||
@@ -163,7 +163,7 @@
|
||||
<record model="ir.ui.view" id="sf_production_process_tree">
|
||||
<field name="model">sf.production.process</field>
|
||||
<field name="arch" type="xml">
|
||||
<tree string="工艺" create="0" edit="0" delete="0">
|
||||
<tree string="表面工艺" create="0" edit="0" delete="0">
|
||||
<field name="sequence" string="加工顺序" readonly="1"/>
|
||||
<field name="code"/>
|
||||
<field name="name" string="名称"/>
|
||||
@@ -175,7 +175,7 @@
|
||||
<record model="ir.ui.view" id="sf_production_process_form">
|
||||
<field name="model">sf.production.process</field>
|
||||
<field name="arch" type="xml">
|
||||
<form string="工艺" create="0" delete="0">
|
||||
<form string="表面工艺" create="0" delete="0">
|
||||
<sheet>
|
||||
<div class="oe_title">
|
||||
<h1>
|
||||
@@ -395,7 +395,7 @@
|
||||
<field name="view_mode">tree,form</field>
|
||||
</record>
|
||||
<record id="sf_production_process" model="ir.actions.act_window">
|
||||
<field name="name">工艺</field>
|
||||
<field name="name">表面工艺</field>
|
||||
<field name="type">ir.actions.act_window</field>
|
||||
<field name="res_model">sf.production.process</field>
|
||||
<field name="view_mode">tree,form</field>
|
||||
@@ -414,13 +414,13 @@
|
||||
<!-- </record>-->
|
||||
|
||||
<record id="sf_production_process_category" model="ir.actions.act_window">
|
||||
<field name="name">工艺类别</field>
|
||||
<field name="name">表面工艺类别</field>
|
||||
<field name="type">ir.actions.act_window</field>
|
||||
<field name="res_model">sf.production.process.category</field>
|
||||
<field name="view_mode">tree,form</field>
|
||||
</record>
|
||||
<record id="mrs_production_process_parameter_action" model="ir.actions.act_window">
|
||||
<field name="name">工艺可选参数</field>
|
||||
<field name="name">表面工艺可选参数</field>
|
||||
<field name="type">ir.actions.act_window</field>
|
||||
<field name="res_model">sf.production.process.parameter</field>
|
||||
<field name="view_mode">tree,form</field>
|
||||
|
||||
@@ -78,7 +78,7 @@
|
||||
|
||||
<menuitem
|
||||
id="menu_sf_production_process"
|
||||
name="工艺"
|
||||
name="表面工艺"
|
||||
parent="menu_sf_production_process_1"
|
||||
sequence="2"
|
||||
action="sf_production_process"
|
||||
@@ -86,7 +86,7 @@
|
||||
|
||||
<menuitem
|
||||
id="menu_sf_production_process_category"
|
||||
name="工艺类别"
|
||||
name="表面工艺类别"
|
||||
parent="menu_sf_production_process_1"
|
||||
sequence="1"
|
||||
action="sf_production_process_category"
|
||||
@@ -113,7 +113,7 @@
|
||||
|
||||
<menuitem
|
||||
id="mrs_production_process_parameter_view"
|
||||
name="工艺可选参数"
|
||||
name="表面工艺可选参数"
|
||||
parent="menu_sf_production_process_1"
|
||||
sequence="2"
|
||||
action="mrs_production_process_parameter_action"
|
||||
|
||||
@@ -2,7 +2,7 @@
|
||||
import logging
|
||||
from datetime import datetime, timedelta
|
||||
import hashlib
|
||||
from odoo import models, SUPERUSER_ID
|
||||
from odoo import models
|
||||
from odoo.http import request
|
||||
|
||||
__author__ = 'jinling.yang'
|
||||
@@ -48,7 +48,5 @@ class Http(models.AbstractModel):
|
||||
_logger.info('sf_secret_key:%s' % factory_secret.sf_secret_key)
|
||||
if check_sf_str != datas['HTTP_CHECKSTR']:
|
||||
raise AuthenticationError('数据校验不通过')
|
||||
# 设置管理员用户
|
||||
request.update_env(user=SUPERUSER_ID)
|
||||
else:
|
||||
raise AuthenticationError('请求参数中无token')
|
||||
|
||||
@@ -1,3 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
from . import models
|
||||
from . import wizard
|
||||
@@ -1,32 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
# Part of Odoo. See LICENSE file for full copyright and licensing details.
|
||||
{
|
||||
'name': '机企猫智能工厂 需求计划',
|
||||
'version': '1.0',
|
||||
'summary': '智能工厂计划管理',
|
||||
'sequence': 1,
|
||||
'description': """
|
||||
在本模块,支持齐套检查与下达生产
|
||||
""",
|
||||
'category': 'sf',
|
||||
'website': 'https://www.sf.jikimo.com',
|
||||
'depends': ['sf_plan', 'jikimo_printing'],
|
||||
'data': [
|
||||
'security/ir.model.access.csv',
|
||||
'views/demand_plan.xml',
|
||||
'wizard/sf_demand_plan_print_wizard_view.xml',
|
||||
],
|
||||
'demo': [
|
||||
],
|
||||
'assets': {
|
||||
'web.assets_qweb': [
|
||||
],
|
||||
'web.assets_backend': [
|
||||
'sf_demand_plan/static/src/scss/style.css',
|
||||
]
|
||||
},
|
||||
'license': 'LGPL-3',
|
||||
'installable': True,
|
||||
'application': False,
|
||||
'auto_install': False,
|
||||
}
|
||||
@@ -1,4 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
|
||||
from . import sf_production_demand_plan
|
||||
from . import sale_order
|
||||
@@ -1,29 +0,0 @@
|
||||
from odoo import models, fields, api, _
|
||||
|
||||
|
||||
class ReSaleOrder(models.Model):
|
||||
_inherit = 'sale.order'
|
||||
|
||||
mrp_production_ids = fields.Many2many(
|
||||
'mrp.production',
|
||||
compute='_compute_mrp_production_ids',
|
||||
string='与此销售订单相关联的制造订单',
|
||||
groups='mrp.group_mrp_user', store=True)
|
||||
|
||||
def sale_order_create_line(self, product, item):
|
||||
ret = super(ReSaleOrder, self).sale_order_create_line(product, item)
|
||||
vals = {
|
||||
'sale_order_id': ret.order_id.id,
|
||||
'sale_order_line_id': ret.id,
|
||||
}
|
||||
demand_plan = self.env['sf.production.demand.plan'].sudo().create(vals)
|
||||
if demand_plan.product_id.machining_drawings_name:
|
||||
filename_url = demand_plan.product_id.machining_drawings_name.rsplit('.', 1)[0]
|
||||
wizard_vals = {
|
||||
'demand_plan_id': demand_plan.id,
|
||||
'model_id': demand_plan.model_id,
|
||||
'filename_url': filename_url,
|
||||
'type': '1',
|
||||
}
|
||||
self.env['sf.demand.plan.print.wizard'].sudo().create(wizard_vals)
|
||||
return ret
|
||||
@@ -1,532 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
import ast
|
||||
import json
|
||||
from odoo import models, fields, api, _
|
||||
from odoo.exceptions import ValidationError
|
||||
from odoo.tools import float_compare
|
||||
from datetime import datetime, timedelta
|
||||
from odoo.exceptions import UserError
|
||||
|
||||
|
||||
class SfProductionDemandPlan(models.Model):
|
||||
_name = 'sf.production.demand.plan'
|
||||
_description = 'sf_production_demand_plan'
|
||||
|
||||
def _get_machining_precision(self):
|
||||
machinings = self.env['sf.machining.accuracy'].sudo().search([])
|
||||
list = [(m.sync_id, m.name) for m in machinings]
|
||||
return list
|
||||
|
||||
priority = fields.Selection([
|
||||
('1', '紧急'),
|
||||
('2', '高'),
|
||||
('3', '中'),
|
||||
('4', '低'),
|
||||
], string='优先级', default='3')
|
||||
status = fields.Selection([
|
||||
('10', '草稿'),
|
||||
('20', '待确认'),
|
||||
('30', '需求确认'),
|
||||
('50', '待下达生产'),
|
||||
('60', '已下达'),
|
||||
('100', '取消'),
|
||||
], string='状态', compute='_compute_status', store=True)
|
||||
sale_order_id = fields.Many2one(comodel_name="sale.order",
|
||||
string="销售订单", readonly=True)
|
||||
sale_order_line_id = fields.Many2one(comodel_name="sale.order.line",
|
||||
string="销售订单明细", readonly=True)
|
||||
sale_order_line_number = fields.Char(string='销售订单行', compute='_compute_sale_order_line_number', store=True)
|
||||
company_id = fields.Many2one(
|
||||
related='sale_order_id.company_id',
|
||||
store=True, index=True, precompute=True)
|
||||
partner_id = fields.Many2one(
|
||||
comodel_name='res.partner',
|
||||
related='sale_order_line_id.order_partner_id',
|
||||
string="客户",
|
||||
store=True, index=True)
|
||||
order_remark = fields.Text(related='sale_order_id.remark',
|
||||
string="订单备注", store=True)
|
||||
glb_url = fields.Char(related='sale_order_line_id.glb_url', string='glb文件地址')
|
||||
product_id = fields.Many2one(
|
||||
comodel_name='product.product',
|
||||
related='sale_order_line_id.product_id',
|
||||
string='产品', store=True, index=True)
|
||||
model_id = fields.Char('模型ID', related='product_id.model_id')
|
||||
part_name = fields.Char('零件名称', related='product_id.part_name')
|
||||
part_number = fields.Char('零件图号', compute='_compute_part_number', store=True)
|
||||
is_incoming_material = fields.Boolean('客供料', related='sale_order_line_id.is_incoming_material', store=True)
|
||||
supply_method = fields.Selection([
|
||||
('automation', "自动化产线加工"),
|
||||
('manual', "人工线下加工"),
|
||||
('purchase', "外购"),
|
||||
('outsourcing', "委外加工"),
|
||||
], string='供货方式', related='sale_order_line_id.supply_method', store=True)
|
||||
product_uom_qty = fields.Float(
|
||||
string="需求数量",
|
||||
related='sale_order_line_id.product_uom_qty', store=True)
|
||||
deadline_of_delivery = fields.Date('客户交期', related='sale_order_id.deadline_of_delivery', store=True)
|
||||
inventory_quantity_auto_apply = fields.Float(
|
||||
string="成品库存",
|
||||
compute='_compute_inventory_quantity_auto_apply'
|
||||
)
|
||||
qty_delivered = fields.Float(
|
||||
"交货数量", related='sale_order_line_id.qty_delivered')
|
||||
qty_to_deliver = fields.Float(
|
||||
"待交货数量", related='sale_order_line_id.qty_to_deliver')
|
||||
model_long = fields.Char('尺寸', compute='_compute_model_long')
|
||||
materials_id = fields.Char('材料', compute='_compute_materials_id', store=True)
|
||||
model_machining_precision = fields.Selection(selection=_get_machining_precision, string='精度',
|
||||
related='product_id.model_machining_precision')
|
||||
model_process_parameters_ids = fields.Many2many('sf.production.process.parameter',
|
||||
'plan_process_parameter_rel',
|
||||
string='表面工艺',
|
||||
compute='_compute_model_process_parameters_ids'
|
||||
, store=True
|
||||
)
|
||||
product_remark = fields.Char("产品备注", related='product_id.model_remark')
|
||||
order_code = fields.Char('E-SHOP订单号', related='sale_order_id.order_code')
|
||||
order_state = fields.Selection(
|
||||
string='订单状态',
|
||||
related='sale_order_line_id.state')
|
||||
route_id = fields.Many2one('stock.route', string='路线', related='sale_order_line_id.route_id', store=True)
|
||||
contract_date = fields.Date('合同日期', related='sale_order_id.contract_date')
|
||||
date_order = fields.Datetime('下单日期', related='sale_order_id.date_order')
|
||||
contract_code = fields.Char('合同号', related='sale_order_id.contract_code', store=True)
|
||||
plan_remark = fields.Text("计划备注")
|
||||
material_check = fields.Selection([
|
||||
('0', "未齐套"),
|
||||
('1', "已齐套"),
|
||||
], string='投料齐套检查', compute='_compute_material_check', store=True)
|
||||
processing_time = fields.Char('程序工时', readonly=True)
|
||||
planned_start_date = fields.Date('计划开工日期')
|
||||
actual_start_date = fields.Datetime('实际开工日期', compute='_compute_actual_start_date', store=True)
|
||||
actual_end_date = fields.Datetime('实际完工日期', compute='_compute_actual_end_date', store=True)
|
||||
print_count = fields.Char('打印次数', default='T0C0', readonly=True)
|
||||
sequence = fields.Integer('序号')
|
||||
|
||||
hide_action_open_mrp_production = fields.Boolean(
|
||||
string='显示待工艺确认按钮',
|
||||
compute='_compute_hid_button',
|
||||
default=False
|
||||
)
|
||||
|
||||
hide_action_purchase_orders = fields.Boolean(
|
||||
string='显示采购按钮',
|
||||
compute='_compute_hide_action_purchase_orders',
|
||||
default=False
|
||||
)
|
||||
|
||||
hide_action_stock_picking = fields.Boolean(
|
||||
string='显示调拨单按钮',
|
||||
compute='_compute_hide_action_stock_picking',
|
||||
default=False
|
||||
)
|
||||
|
||||
hide_action_outsourcing_stock_picking = fields.Boolean(
|
||||
string='委外显示调拨单按钮',
|
||||
compute='_compute_hide_action_stock_picking',
|
||||
default=False
|
||||
)
|
||||
|
||||
hide_action_view_programming = fields.Boolean(
|
||||
string='显示编程单按钮',
|
||||
compute='_compute_hid_button',
|
||||
default=False
|
||||
)
|
||||
|
||||
outsourcing_purchase_request = fields.Char('委外采购申请单')
|
||||
|
||||
@api.depends('sale_order_id.state', 'sale_order_id.mrp_production_ids.schedule_state', 'sale_order_id.order_line',
|
||||
'sale_order_id.mrp_production_ids.state')
|
||||
def _compute_status(self):
|
||||
for record in self:
|
||||
if record.sale_order_id:
|
||||
sale_order_state = record.sale_order_id.state
|
||||
if sale_order_state in ('draft', 'sent', 'supply method'):
|
||||
record.status = '20' # 待确认
|
||||
if record.supply_method in ('purchase', 'outsourcing') and sale_order_state in (
|
||||
'sale', 'processing', 'physical_distribution', 'delivered',
|
||||
'done') and sale_order_state != 'cancel':
|
||||
record.status = '60' # 已下达
|
||||
if record.supply_method in ('automation', 'manual'):
|
||||
if sale_order_state in (
|
||||
'sale', 'processing', 'physical_distribution', 'delivered',
|
||||
'done') and sale_order_state != 'cancel':
|
||||
record.status = '30' # 需求确认
|
||||
# 检查所有制造订单的排程单状态,有一个为待排程状态,就为待下达生产
|
||||
pending_productions = record.sale_order_id.mrp_production_ids.filtered(
|
||||
lambda p: p.state == 'confirmed' and p.product_id.id == record.product_id.id
|
||||
)
|
||||
if pending_productions:
|
||||
record.status = '50' # 待下达生产
|
||||
# 检查所有制造订单的排程单状态
|
||||
if record.sale_order_id.mrp_production_ids:
|
||||
product_productions = record.sale_order_id.mrp_production_ids.filtered(
|
||||
lambda p: p.product_id.id == record.product_id.id
|
||||
)
|
||||
if product_productions and all(order.schedule_state != '未排' for order in product_productions):
|
||||
record.status = '60' # 已下达
|
||||
if sale_order_state == 'cancel' or not record.sale_order_line_id:
|
||||
record.status = '100' # 取消
|
||||
|
||||
@api.depends('sale_order_line_id.product_id.name')
|
||||
def _compute_sale_order_line_number(self):
|
||||
for line in self:
|
||||
if line.product_id:
|
||||
line.sale_order_line_number = line.sale_order_line_id.product_id.name[-1]
|
||||
else:
|
||||
line.sale_order_line_number = None
|
||||
|
||||
@api.depends('product_id.part_number', 'product_id.model_name')
|
||||
def _compute_part_number(self):
|
||||
for line in self:
|
||||
if line.product_id:
|
||||
if line.product_id.part_number:
|
||||
line.part_number = line.product_id.part_number
|
||||
else:
|
||||
if line.product_id.model_name:
|
||||
line.part_number = line.product_id.model_name.rsplit('.', 1)[0]
|
||||
else:
|
||||
line.part_number = None
|
||||
|
||||
@api.depends('product_id.length', 'product_id.width', 'product_id.height')
|
||||
def _compute_model_long(self):
|
||||
for line in self:
|
||||
if line.product_id:
|
||||
line.model_long = f"{line.product_id.length}*{line.product_id.width}*{line.product_id.height}"
|
||||
else:
|
||||
line.model_long = None
|
||||
|
||||
@api.depends('product_id.materials_id')
|
||||
def _compute_materials_id(self):
|
||||
for line in self:
|
||||
if line.product_id:
|
||||
line.materials_id = f"{line.product_id.materials_id.name}/{line.product_id.materials_type_id.name}"
|
||||
else:
|
||||
line.materials_id = None
|
||||
|
||||
@api.depends('product_id.model_process_parameters_ids')
|
||||
def _compute_model_process_parameters_ids(self):
|
||||
for line in self:
|
||||
if line.product_id and line.product_id.model_process_parameters_ids:
|
||||
line.model_process_parameters_ids = [(6, 0, line.product_id.model_process_parameters_ids.ids)]
|
||||
else:
|
||||
line.model_process_parameters_ids = [(5, 0, 0)]
|
||||
|
||||
def _compute_inventory_quantity_auto_apply(self):
|
||||
location_id = self.env['stock.location'].search([('name', '=', '成品存货区')], limit=1).id
|
||||
product_ids = self.mapped('product_id').ids
|
||||
if product_ids:
|
||||
quant_data = self.env['stock.quant'].read_group(
|
||||
domain=[
|
||||
('product_id', 'in', product_ids),
|
||||
('location_id', '=', location_id)
|
||||
],
|
||||
fields=['product_id', 'inventory_quantity_auto_apply'],
|
||||
groupby=['product_id']
|
||||
)
|
||||
quantity_map = {item['product_id'][0]: item['inventory_quantity_auto_apply'] for item in quant_data}
|
||||
else:
|
||||
quantity_map = {}
|
||||
for line in self:
|
||||
if line.product_id:
|
||||
line.inventory_quantity_auto_apply = quantity_map.get(line.product_id.id, 0.0)
|
||||
else:
|
||||
line.inventory_quantity_auto_apply = 0.0
|
||||
|
||||
@api.depends('sale_order_id.mrp_production_ids.workorder_ids.date_start')
|
||||
def _compute_actual_start_date(self):
|
||||
for record in self:
|
||||
if record.sale_order_id and record.sale_order_id.mrp_production_ids:
|
||||
manufacturing_orders = record.sale_order_id.mrp_production_ids.filtered(
|
||||
lambda mo: mo.product_id == record.product_id)
|
||||
if manufacturing_orders:
|
||||
start_dates = [
|
||||
workorder.date_start for mo in manufacturing_orders
|
||||
for workorder in mo.workorder_ids if workorder.date_start
|
||||
]
|
||||
record.actual_start_date = min(start_dates) if start_dates else None
|
||||
else:
|
||||
record.actual_start_date = None
|
||||
else:
|
||||
record.actual_start_date = None
|
||||
|
||||
@api.depends('sale_order_id.mrp_production_ids.workorder_ids.state',
|
||||
'sale_order_id.mrp_production_ids.workorder_ids.date_finished')
|
||||
def _compute_actual_end_date(self):
|
||||
for record in self:
|
||||
if record.sale_order_id and record.sale_order_id.mrp_production_ids:
|
||||
manufacturing_orders = record.sale_order_id.mrp_production_ids.filtered(
|
||||
lambda mo: mo.product_id == record.product_id)
|
||||
finished_orders = manufacturing_orders.filtered(lambda mo: mo.state == 'done')
|
||||
sum_product_qty = sum(finished_orders.mapped('product_qty'))
|
||||
if finished_orders and float_compare(sum_product_qty, record.product_uom_qty,
|
||||
precision_rounding=record.product_id.uom_id.rounding) >= 0:
|
||||
end_dates = [
|
||||
workorder.date_finished for mo in finished_orders
|
||||
for workorder in mo.workorder_ids if workorder.date_finished
|
||||
]
|
||||
record.actual_end_date = max(end_dates) if end_dates else None
|
||||
else:
|
||||
record.actual_end_date = None
|
||||
else:
|
||||
record.actual_end_date = None
|
||||
|
||||
@api.depends('sale_order_id.mrp_production_ids.move_raw_ids.forecast_availability',
|
||||
'sale_order_id.mrp_production_ids.move_raw_ids.quantity_done')
|
||||
def _compute_material_check(self):
|
||||
for record in self:
|
||||
if record.sale_order_id and record.sale_order_id.mrp_production_ids:
|
||||
manufacturing_orders = record.sale_order_id.mrp_production_ids.filtered(
|
||||
lambda mo: mo.product_id == record.product_id)
|
||||
if manufacturing_orders and manufacturing_orders.move_raw_ids:
|
||||
total_forecast_availability = sum(manufacturing_orders.mapped('move_raw_ids.forecast_availability'))
|
||||
total_quantity_done = sum(manufacturing_orders.mapped('move_raw_ids.quantity_done'))
|
||||
total_sum = total_forecast_availability + total_quantity_done
|
||||
if float_compare(total_sum, record.product_uom_qty,
|
||||
precision_rounding=record.product_id.uom_id.rounding) >= 0:
|
||||
record.material_check = '1' # 已齐套
|
||||
else:
|
||||
record.material_check = '0' # 未齐套
|
||||
else:
|
||||
record.material_check = None
|
||||
else:
|
||||
record.material_check = None
|
||||
|
||||
@api.constrains('planned_start_date')
|
||||
def _check_planned_start_date(self):
|
||||
for record in self:
|
||||
if record.planned_start_date and record.planned_start_date < fields.Date.today():
|
||||
raise ValidationError("计划开工日期必须大于或等于今天。")
|
||||
|
||||
def release_production_order(self):
|
||||
if not self.planned_start_date:
|
||||
raise ValidationError("请先填写计划开工日期")
|
||||
pro_plan_list = self.env['sf.production.plan'].search(
|
||||
[('product_id', '=', self.product_id.id), ('state', '=', 'draft')])
|
||||
sf_production_line = self.env['sf.production.line'].sudo().search(
|
||||
[('name', '=', '1#CNC自动生产线')], limit=1)
|
||||
if sf_production_line:
|
||||
now = datetime.now()
|
||||
time_part = (now + timedelta(minutes=3)).time()
|
||||
date_part = fields.Date.from_string(self.planned_start_date)
|
||||
date_planned_start = datetime.combine(date_part, time_part)
|
||||
pro_plan_list.production_line_id = sf_production_line.id
|
||||
pro_plan_list.date_planned_start = date_planned_start
|
||||
for pro_plan in pro_plan_list:
|
||||
pro_plan.do_production_schedule()
|
||||
|
||||
def button_action_print(self):
|
||||
return {
|
||||
'res_model': 'sf.demand.plan.print.wizard',
|
||||
'type': 'ir.actions.act_window',
|
||||
'name': _("打印"),
|
||||
'domain': [('demand_plan_id', 'in', self.ids)],
|
||||
'views': [[self.env.ref('sf_demand_plan.action_plan_print_tree').id, 'list']],
|
||||
'target': 'new',
|
||||
}
|
||||
|
||||
@api.depends('sale_order_id.mrp_production_ids.state', 'sale_order_id.mrp_production_ids.programming_state')
|
||||
def _compute_hid_button(self):
|
||||
for record in self:
|
||||
mrp_production_ids = record.sale_order_id.mrp_production_ids.filtered(
|
||||
lambda p: p.state == 'technology_to_confirmed' and p.product_id.id == record.product_id.id
|
||||
)
|
||||
record.hide_action_open_mrp_production = bool(mrp_production_ids) and record.supply_method in (
|
||||
'automation', 'manual')
|
||||
programming_mrp_production_ids = record.sale_order_id.mrp_production_ids.filtered(
|
||||
lambda p: p.programming_state == '编程中' and p.product_id.id == record.product_id.id
|
||||
)
|
||||
record.hide_action_view_programming = bool(programming_mrp_production_ids)
|
||||
|
||||
def _compute_hide_action_purchase_orders(self):
|
||||
for record in self:
|
||||
record.hide_action_purchase_orders = False
|
||||
outsourcing_purchase_request = []
|
||||
if record.supply_method in ('automation',
|
||||
'manual') and record.material_check == '0' and not record.sale_order_line_id.is_incoming_material:
|
||||
mrp_production = record.sale_order_id.mrp_production_ids.filtered(
|
||||
lambda p: p.product_id.id == record.product_id.id
|
||||
).sorted(key=lambda p: p.id)
|
||||
if mrp_production:
|
||||
raw_materials = mrp_production.mapped('move_raw_ids.product_id')
|
||||
if raw_materials:
|
||||
purchase_orders = self.env['purchase.order'].sudo().search([
|
||||
('state', '=', 'purchase'),
|
||||
('order_line.product_id', 'in', raw_materials.ids)
|
||||
])
|
||||
total_purchase_quantity = sum(
|
||||
sum(
|
||||
order.order_line.filtered(
|
||||
lambda line: line.product_id in raw_materials
|
||||
).mapped('product_qty')
|
||||
)
|
||||
for order in purchase_orders
|
||||
)
|
||||
if float_compare(total_purchase_quantity, record.product_uom_qty,
|
||||
precision_rounding=record.product_id.uom_id.rounding) == -1:
|
||||
pr_ids = self.env['purchase.request'].sudo().search(
|
||||
[('line_ids.product_id', 'in', raw_materials.ids), ('state', '!=', 'done')])
|
||||
outsourcing_purchase_request.extend(pr_ids.ids)
|
||||
elif record.supply_method in ('purchase', 'outsourcing'):
|
||||
purchase_orders = self.env['purchase.order'].sudo().search([
|
||||
('state', 'in', ('purchase', 'done')),
|
||||
('order_line.product_id', '=', record.product_id.id)
|
||||
])
|
||||
total_purchase_quantity = sum(
|
||||
sum(
|
||||
order.order_line.filtered(
|
||||
lambda line: line.product_id in record.product_id
|
||||
).mapped('product_qty')
|
||||
)
|
||||
for order in purchase_orders
|
||||
)
|
||||
|
||||
if float_compare(total_purchase_quantity, record.product_uom_qty,
|
||||
precision_rounding=record.product_id.uom_id.rounding) == -1:
|
||||
pr_ids = self.env['purchase.request'].sudo().search(
|
||||
[('origin', 'like', record.sale_order_id.name), ('state', '!=', 'done')])
|
||||
outsourcing_purchase_request.extend(pr_ids.ids)
|
||||
if record.supply_method == 'outsourcing' and not record.sale_order_line_id.is_incoming_material:
|
||||
bom_line_ids = record.product_id.bom_ids.bom_line_ids
|
||||
# BOM_数量
|
||||
total_product_qty = sum(line.product_qty for line in bom_line_ids)
|
||||
bom_product_ids = bom_line_ids.mapped('product_id')
|
||||
product_purchase_orders = self.env['purchase.order'].sudo().search([
|
||||
('state', 'in', ('purchase', 'done')),
|
||||
('order_line.product_id', 'in', bom_product_ids.ids)
|
||||
])
|
||||
# 购订单_数量
|
||||
total_outsourcing_purchase_quantity = sum(
|
||||
sum(
|
||||
order.order_line.filtered(
|
||||
lambda line: line.product_id in bom_product_ids
|
||||
).mapped('product_qty')
|
||||
)
|
||||
for order in product_purchase_orders
|
||||
)
|
||||
quantity = total_outsourcing_purchase_quantity / total_product_qty
|
||||
if float_compare(quantity, record.product_uom_qty,
|
||||
precision_rounding=record.product_id.uom_id.rounding) == -1:
|
||||
purchase_request = self.env['purchase.request'].sudo().search(
|
||||
[('line_ids.product_id', 'in', bom_product_ids.ids),
|
||||
('line_ids.purchase_state', 'not in', ('purchase', 'done')), ('state', '!=', 'done')])
|
||||
outsourcing_purchase_request.extend(purchase_request.ids)
|
||||
record.outsourcing_purchase_request = json.dumps(outsourcing_purchase_request)
|
||||
if outsourcing_purchase_request:
|
||||
record.hide_action_purchase_orders = True
|
||||
|
||||
@api.depends('sale_order_id.mrp_production_ids.picking_ids.state', 'sale_order_id.picking_ids.state')
|
||||
def _compute_hide_action_stock_picking(self):
|
||||
for record in self:
|
||||
record.hide_action_stock_picking = False
|
||||
record.hide_action_outsourcing_stock_picking = False
|
||||
if record.supply_method in ('automation', 'manual'):
|
||||
manufacturing_orders = record.sale_order_id.mrp_production_ids.filtered(
|
||||
lambda p: p.product_id.id == record.product_id.id
|
||||
)
|
||||
record.hide_action_stock_picking = bool(manufacturing_orders.mapped('picking_ids').filtered(
|
||||
lambda p: p.state == 'assigned'))
|
||||
elif record.supply_method in ('purchase', 'outsourcing'):
|
||||
assigned_picking_ids = record.sale_order_id.picking_ids.filtered(
|
||||
lambda
|
||||
p: p.state == 'assigned' and p.picking_type_id.name != '发料出库' and p.move_line_ids.product_id in record.product_id)
|
||||
if record.supply_method == 'outsourcing':
|
||||
outsourcing_assigned_picking_ids = record.get_outsourcing_picking_ids()
|
||||
record.hide_action_outsourcing_stock_picking = outsourcing_assigned_picking_ids
|
||||
record.hide_action_stock_picking = assigned_picking_ids or outsourcing_assigned_picking_ids
|
||||
else:
|
||||
record.hide_action_stock_picking = assigned_picking_ids
|
||||
|
||||
def get_outsourcing_picking_ids(self):
|
||||
order_ids = self.env['purchase.order'].sudo().search(
|
||||
[('order_line.product_id', 'in', self.product_id.ids),
|
||||
('purchase_type', '=', 'outsourcing')])
|
||||
outsourcing_picking_ids = order_ids._get_subcontracting_resupplies()
|
||||
outsourcing_assigned_picking_ids = outsourcing_picking_ids.filtered(lambda p: p.state == 'assigned')
|
||||
return outsourcing_assigned_picking_ids
|
||||
|
||||
def action_open_sale_order(self):
|
||||
self.ensure_one()
|
||||
return {
|
||||
'type': 'ir.actions.act_window',
|
||||
'res_model': 'sale.order',
|
||||
'res_id': self.sale_order_id.id,
|
||||
'view_mode': 'form',
|
||||
}
|
||||
|
||||
def action_open_mrp_production(self):
|
||||
self.ensure_one()
|
||||
mrp_production_ids = self.sale_order_id.mrp_production_ids.filtered(
|
||||
lambda p: p.state == 'technology_to_confirmed' and p.product_id.id == self.product_id.id
|
||||
)
|
||||
action = {
|
||||
'res_model': 'mrp.production',
|
||||
'type': 'ir.actions.act_window',
|
||||
}
|
||||
if len(mrp_production_ids) == 1:
|
||||
action.update({
|
||||
'view_mode': 'form',
|
||||
'res_id': mrp_production_ids.id,
|
||||
})
|
||||
else:
|
||||
action.update({
|
||||
'name': _("制造订单列表"),
|
||||
'domain': [('id', 'in', mrp_production_ids.ids)],
|
||||
'view_mode': 'tree,form',
|
||||
})
|
||||
return action
|
||||
|
||||
def action_view_purchase_request(self):
|
||||
self.ensure_one()
|
||||
pr_ids = self.env['purchase.request'].sudo().search(
|
||||
[('id', 'in', ast.literal_eval(self.outsourcing_purchase_request))])
|
||||
action = {
|
||||
'res_model': 'purchase.request',
|
||||
'type': 'ir.actions.act_window',
|
||||
}
|
||||
if len(pr_ids) == 1:
|
||||
action.update({
|
||||
'view_mode': 'form',
|
||||
'res_id': pr_ids[0].id,
|
||||
})
|
||||
else:
|
||||
action.update({
|
||||
'name': _("采购申请"),
|
||||
'domain': [('id', 'in', pr_ids.ids)],
|
||||
'view_mode': 'tree,form',
|
||||
})
|
||||
return action
|
||||
|
||||
def action_view_stock_picking(self):
|
||||
self.ensure_one()
|
||||
action = self.env["ir.actions.actions"]._for_xml_id("stock.action_picking_tree_all")
|
||||
picking_ids = None
|
||||
if self.supply_method in ('automation', 'manual'):
|
||||
picking_ids = self.sale_order_id.mrp_production_ids.mapped('picking_ids').filtered(
|
||||
lambda p: p.state == 'assigned')
|
||||
elif self.supply_method in ('purchase', 'outsourcing'):
|
||||
picking_ids = self.sale_order_id.picking_ids.filtered(
|
||||
lambda
|
||||
p: p.state == 'assigned' and p.picking_type_id.name != '发料出库' and p.move_line_ids.product_id in self.product_id)
|
||||
if self.supply_method == 'outsourcing' and self.hide_action_outsourcing_stock_picking:
|
||||
picking_ids = picking_ids.union(self.get_outsourcing_picking_ids())
|
||||
if picking_ids:
|
||||
if len(picking_ids) > 1:
|
||||
action['domain'] = [('id', 'in', picking_ids.ids)]
|
||||
elif picking_ids:
|
||||
action['res_id'] = picking_ids.id
|
||||
action['views'] = [(self.env.ref('stock.view_picking_form').id, 'form')]
|
||||
if 'views' in action:
|
||||
action['views'] += [(state, view) for state, view in action['views'] if view != 'form']
|
||||
return action
|
||||
|
||||
def action_view_programming(self):
|
||||
self.ensure_one()
|
||||
programming_mrp_production_ids = self.sale_order_id.mrp_production_ids.filtered(
|
||||
lambda p: p.programming_state == '编程中' and p.product_id.id == self.product_id.id
|
||||
).mapped('programming_no')
|
||||
if programming_mrp_production_ids:
|
||||
programming_no = list(set(programming_mrp_production_ids))
|
||||
numbers_str = "、".join(programming_no)
|
||||
raise ValidationError(f"编程单号:{numbers_str},请去云平台处理")
|
||||
@@ -1,6 +0,0 @@
|
||||
id,name,model_id:id,group_id:id,perm_read,perm_write,perm_create,perm_unlink
|
||||
access_sf_production_demand_plan,sf.production.demand.plan,model_sf_production_demand_plan,base.group_user,1,0,0,0
|
||||
access_sf_production_demand_plan_for_dispatch,sf.production.demand.plan for dispatch,model_sf_production_demand_plan,sf_base.group_plan_dispatch,1,1,0,0
|
||||
|
||||
access_sf_demand_plan_print_wizard,sf.demand.plan.print.wizard,model_sf_demand_plan_print_wizard,base.group_user,1,0,0,0
|
||||
access_sf_demand_plan_print_wizard_for_dispatch,sf.demand.plan.print.wizard for dispatch,model_sf_demand_plan_print_wizard,sf_base.group_plan_dispatch,1,1,0,0
|
||||
|
@@ -1,11 +0,0 @@
|
||||
.demand_plan_tree .o_list_table_ungrouped th:not(.o_list_record_selector,.row_no,[data-name=sequence]) {
|
||||
min-width: 98px !important;
|
||||
}
|
||||
|
||||
.demand_plan_tree .o_list_table_grouped th:not(.o_list_record_selector,.row_no,[data-name=sequence]) {
|
||||
width: 98px !important;
|
||||
}
|
||||
|
||||
.demand_plan_tree .o_list_table_ungrouped {
|
||||
min-width: 1900px;
|
||||
}
|
||||
@@ -1,123 +0,0 @@
|
||||
<odoo>
|
||||
<record id="view_sf_production_demand_plan_tree" model="ir.ui.view">
|
||||
<field name="name">sf.production.demand.plan.tree</field>
|
||||
<field name="model">sf.production.demand.plan</field>
|
||||
<field name="arch" type="xml">
|
||||
<tree string="需求计划" default_order="sequence desc,create_date desc" editable="bottom"
|
||||
class="demand_plan_tree">
|
||||
<header>
|
||||
<button string="打印" name="button_action_print" type="object"
|
||||
class="btn-primary"/>
|
||||
</header>
|
||||
<field name="sequence" widget="handle"/>
|
||||
<field name="id" optional="hide"/>
|
||||
<field name="priority"/>
|
||||
<field name="status"/>
|
||||
<field name="partner_id"/>
|
||||
<field name="order_remark"/>
|
||||
<field name="glb_url" optional="hide"/>
|
||||
<field name="product_id"/>
|
||||
<field name="model_id" optional="hide"/>
|
||||
<field name="part_name"/>
|
||||
<field name="part_number"/>
|
||||
<field name="is_incoming_material"/>
|
||||
<field name="supply_method"/>
|
||||
<field name="product_uom_qty"/>
|
||||
<field name="deadline_of_delivery"/>
|
||||
<field name="inventory_quantity_auto_apply"/>
|
||||
<field name="qty_delivered"/>
|
||||
<field name="qty_to_deliver"/>
|
||||
<field name="model_long"/>
|
||||
<field name="materials_id"/>
|
||||
<field name="model_machining_precision"/>
|
||||
<field name="model_process_parameters_ids" widget="many2many_tags"/>
|
||||
<field name="product_remark" optional="hide"/>
|
||||
<field name="order_code" optional="hide"/>
|
||||
<field name="sale_order_id" optional="hide"/>
|
||||
<field name="sale_order_line_number" optional="hide"/>
|
||||
<field name="order_state"/>
|
||||
<field name="route_id" optional="hide"/>
|
||||
<field name="contract_date"/>
|
||||
<field name="date_order"/>
|
||||
<field name="contract_code"/>
|
||||
<field name="plan_remark"/>
|
||||
<field name="processing_time"/>
|
||||
<field name="material_check" optional="hide"/>
|
||||
<field name="hide_action_open_mrp_production" invisible="1"/>
|
||||
<field name="hide_action_purchase_orders" invisible="1"/>
|
||||
<field name="hide_action_stock_picking" invisible="1"/>
|
||||
<field name="hide_action_view_programming" invisible="1"/>
|
||||
<button name="action_open_sale_order" type="object" string="供货方式待确认" class="btn-secondary"
|
||||
attrs="{'invisible': [('supply_method', '!=', False)]}"/>
|
||||
<button name="action_open_mrp_production" type="object" string="待工艺确认" class="btn-secondary"
|
||||
attrs="{'invisible': [('hide_action_open_mrp_production', '=', False)]}"/>
|
||||
<button name="action_view_purchase_request" type="object" string="采购申请" class="btn-secondary"
|
||||
attrs="{'invisible': [('hide_action_purchase_orders', '=', False)]}"/>
|
||||
<button name="action_view_stock_picking" type="object" string="调拨单" class="btn-secondary"
|
||||
attrs="{'invisible': [('hide_action_stock_picking', '=', False)]}"/>
|
||||
<button name="action_view_programming" type="object" string="编程单" class="btn-secondary"
|
||||
attrs="{'invisible': [('hide_action_view_programming', '=', False)]}"/>
|
||||
<field name="planned_start_date"/>
|
||||
<field name="actual_start_date"/>
|
||||
<field name="actual_end_date"/>
|
||||
<field name="create_date" optional="hide" string="创建时间"/>
|
||||
<field name="create_uid" optional="hide" string="创建人"/>
|
||||
<field name="write_date" string="更新时间"/>
|
||||
<field name="write_uid" optional="hide" string="更新人"/>
|
||||
<field name="print_count"/>
|
||||
<button name="release_production_order" type="object" string="下达生产" class="btn-primary"
|
||||
attrs="{'invisible': ['|',('status', '!=', '50'), ('supply_method', 'not in', ['automation', 'manual'])]}"/>
|
||||
</tree>
|
||||
</field>
|
||||
</record>
|
||||
|
||||
<record id="view_sf_production_demand_plan_search" model="ir.ui.view">
|
||||
<field name="name">sf.production.demand.plan.search</field>
|
||||
<field name="model">sf.production.demand.plan</field>
|
||||
<field name="arch" type="xml">
|
||||
<search>
|
||||
<field name="order_remark"/>
|
||||
<field name="product_id"/>
|
||||
<field name="part_name"/>
|
||||
<field name="part_number"/>
|
||||
<field name="partner_id"/>
|
||||
<field name="supply_method"/>
|
||||
<field name="materials_id"/>
|
||||
<field name="model_process_parameters_ids"/>
|
||||
<field name="plan_remark"/>
|
||||
<field name="contract_code"/>
|
||||
<group expand="0" string="Group By">
|
||||
<filter name="group_by_priority" string="优先级" domain="[]" context="{'group_by': 'priority'}"/>
|
||||
<filter name="group_by_status" string="状态" domain="[]" context="{'group_by': 'status'}"/>
|
||||
<filter name="group_by_partner_id" string="客户" domain="[]" context="{'group_by': 'partner_id'}"/>
|
||||
<filter name="group_by_is_incoming_material" string="客供料" domain="[]"
|
||||
context="{'group_by': 'is_incoming_material'}"/>
|
||||
<filter name="group_by_supply_method" string="供货方式" domain="[]"
|
||||
context="{'group_by': 'supply_method'}"/>
|
||||
<filter name="group_by_deadline_of_delivery" string="客户交期" domain="[]"
|
||||
context="{'group_by': 'deadline_of_delivery'}"/>
|
||||
<filter name="group_by_materials_id" string="材料" domain="[]"
|
||||
context="{'group_by': 'materials_id'}"/>
|
||||
<filter name="group_by_contract_code" string="合同号" domain="[]"
|
||||
context="{'group_by': 'contract_code'}"/>
|
||||
</group>
|
||||
</search>
|
||||
</field>
|
||||
</record>
|
||||
|
||||
<record id="sf_production_demand_plan_action" model="ir.actions.act_window">
|
||||
<field name="name">需求计划</field>
|
||||
<field name="type">ir.actions.act_window</field>
|
||||
<field name="res_model">sf.production.demand.plan</field>
|
||||
<field name="view_mode">tree</field>
|
||||
</record>
|
||||
|
||||
|
||||
<menuitem
|
||||
id="demand_plan_menu"
|
||||
name="需求计划"
|
||||
sequence="140"
|
||||
action="sf_production_demand_plan_action"
|
||||
parent="sf_plan.sf_production_plan_menu"
|
||||
/>
|
||||
</odoo>
|
||||
@@ -1 +0,0 @@
|
||||
from . import sf_demand_plan_print_wizard
|
||||
@@ -1,79 +0,0 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
import logging
|
||||
from odoo import models, fields, api, _
|
||||
|
||||
_logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class SfDemandPlanPrintWizard(models.TransientModel):
|
||||
_name = 'sf.demand.plan.print.wizard'
|
||||
_description = u'打印向导'
|
||||
|
||||
demand_plan_id = fields.Many2one('sf.production.demand.plan', string='需求计划ID')
|
||||
product_id = fields.Many2one(
|
||||
comodel_name='product.product',
|
||||
related='demand_plan_id.product_id',
|
||||
string='产品', store=True, index=True)
|
||||
model_id = fields.Char('模型ID')
|
||||
filename_url = fields.Char('文件名/URL')
|
||||
type = fields.Selection([
|
||||
('1', '图纸'),
|
||||
('2', '程序单'),
|
||||
], string='类型')
|
||||
status = fields.Selection([
|
||||
('not_start', '未开始'),
|
||||
('success', '成功'),
|
||||
('fail', '失败'),
|
||||
], string='状态', default='not_start')
|
||||
machining_drawings = fields.Binary('2D加工图纸', related='product_id.machining_drawings', store=True)
|
||||
|
||||
workorder_id = fields.Many2one('mrp.workorder', string='工单')
|
||||
cnc_worksheet = fields.Binary('程序单')
|
||||
|
||||
def demand_plan_print(self):
|
||||
for record in self:
|
||||
pdf_data = record.machining_drawings if record.type == '1' else record.cnc_worksheet
|
||||
if pdf_data:
|
||||
try:
|
||||
# 执行打印
|
||||
self.env['jikimo.printing'].sudo().print_pdf(pdf_data)
|
||||
record.status = 'success'
|
||||
t_part, c_part = record.demand_plan_id.print_count.split('C')
|
||||
t_num = int(t_part[1:])
|
||||
c_num = int(c_part)
|
||||
if record.type == '1':
|
||||
t_num += 1
|
||||
elif record.type == '2':
|
||||
c_num += 1
|
||||
record.demand_plan_id.print_count = f"T{t_num}C{c_num}"
|
||||
except Exception as e:
|
||||
record.status = 'fail'
|
||||
_logger.error(f"文件{record.filename_url}打印失败: {str(e)}")
|
||||
|
||||
|
||||
class MrpWorkorder(models.Model):
|
||||
_inherit = 'mrp.workorder'
|
||||
|
||||
def write(self, vals):
|
||||
res = super(MrpWorkorder, self).write(vals)
|
||||
for record in self:
|
||||
if 'cnc_worksheet' in vals:
|
||||
demand_plan_print = self.env['sf.demand.plan.print.wizard'].sudo().search(
|
||||
[('workorder_id', '=', record.id)])
|
||||
if demand_plan_print:
|
||||
self.env['sf.demand.plan.print.wizard'].sudo().write(
|
||||
{'cnc_worksheet': record.cnc_worksheet, 'filename_url': record.cnc_worksheet_name})
|
||||
else:
|
||||
demand_plan = self.env['sf.production.demand.plan'].sudo().search(
|
||||
[('product_id', '=', record.product_id.id)])
|
||||
if demand_plan:
|
||||
wizard_vals = {
|
||||
'demand_plan_id': demand_plan.id,
|
||||
'model_id': demand_plan.model_id,
|
||||
'type': '2',
|
||||
'workorder_id': record.id,
|
||||
'cnc_worksheet': record.cnc_worksheet,
|
||||
'filename_url': record.cnc_worksheet_name
|
||||
}
|
||||
self.env['sf.demand.plan.print.wizard'].sudo().create(wizard_vals)
|
||||
return res
|
||||
@@ -1,17 +0,0 @@
|
||||
<?xml version="1.0" encoding="utf-8" ?>
|
||||
<odoo>
|
||||
<record id="action_plan_print_tree" model="ir.ui.view">
|
||||
<field name="name">sf.demand.plan.print.wizard.tree</field>
|
||||
<field name="model">sf.demand.plan.print.wizard</field>
|
||||
<field name="arch" type="xml">
|
||||
<tree string="打印">
|
||||
<field name="model_id"/>
|
||||
<field name="filename_url"/>
|
||||
<field name="type"/>
|
||||
<field name="machining_drawings" widget="adaptive_viewer"/>
|
||||
<field name="cnc_worksheet" widget="pdf_viewer"/>
|
||||
<field name="status"/>
|
||||
</tree>
|
||||
</field>
|
||||
</record>
|
||||
</odoo>
|
||||
@@ -14,12 +14,10 @@
|
||||
<field name="name">原材料</field>
|
||||
<field name="type">原材料</field>
|
||||
</record>
|
||||
|
||||
<record id="product_category_surface_technics_sf" model="product.category">
|
||||
<field name="name">表面工艺</field>
|
||||
<field name="type">表面工艺</field>
|
||||
<field name="parent_id" ref="sf_manufacturing.product_category_outsource_process"/>
|
||||
<field name="property_cost_method">fifo</field>
|
||||
<field name="property_valuation">manual_periodic</field>
|
||||
</record>
|
||||
|
||||
<record id="product_category_cutting_tool_sf" model="product.category">
|
||||
@@ -42,10 +40,10 @@
|
||||
<!-- <field name="company_id" ref="base.main_company"/>-->
|
||||
</record>
|
||||
|
||||
<!-- <record id="res_users_bfm" model="res.users">-->
|
||||
<!-- <field name="name">业务平台</field>-->
|
||||
<!--<!– <field name="partner_id" ref="res_partner_bfm"/>–>-->
|
||||
<!-- </record>-->
|
||||
<!-- <record id="res_users_bfm" model="res.users">-->
|
||||
<!-- <field name="name">业务平台</field>-->
|
||||
<!--<!– <field name="partner_id" ref="res_partner_bfm"/>–>-->
|
||||
<!-- </record>-->
|
||||
|
||||
<record id="product_functional_tool_sf" model="product.product">
|
||||
<field name="name">功能刀具</field>
|
||||
|
||||
@@ -17,7 +17,7 @@ class ResProductCategory(models.Model):
|
||||
class ResProductProduct(models.Model):
|
||||
_inherit = 'product.product'
|
||||
|
||||
# single_manufacturing = fields.Boolean(string="单个制造")
|
||||
single_manufacturing = fields.Boolean(string="单个制造")
|
||||
is_bfm = fields.Boolean('业务平台是否自动创建', default=False)
|
||||
|
||||
|
||||
|
||||
@@ -1 +0,0 @@
|
||||
from . import models
|
||||
@@ -9,9 +9,8 @@
|
||||
""",
|
||||
'category': 'sf',
|
||||
'website': 'https://www.sf.jikimo.com',
|
||||
'depends': ['sf_sale', 'sf_dlm', 'sf_manufacturing', 'jikimo_attachment_viewer'],
|
||||
'depends': ['sf_sale', 'sf_dlm', 'sf_manufacturing','jikimo_attachment_viewer'],
|
||||
'data': [
|
||||
'data/sequence.xml',
|
||||
'data/stock_data.xml',
|
||||
'views/product_template_management_view.xml',
|
||||
],
|
||||
|
||||
@@ -1,10 +0,0 @@
|
||||
<odoo>
|
||||
<data>
|
||||
<record id="sequence_production_process_parameter" model="ir.sequence">
|
||||
<field name="name">工艺可选参数编码序列</field>
|
||||
<field name="code">sf.production.process.parameter</field>
|
||||
<field name="padding">3</field>
|
||||
<field name="number_increment">1</field>
|
||||
</record>
|
||||
</data>
|
||||
</odoo>
|
||||
@@ -1,4 +1,2 @@
|
||||
# from . import product_template
|
||||
# from . import product_supplierinfo
|
||||
from . import sf_production_common
|
||||
from . import mrp_routing_workcenter
|
||||
@@ -1,16 +0,0 @@
|
||||
# import logging
|
||||
# from odoo import fields, models, api
|
||||
# from odoo.exceptions import UserError
|
||||
# from odoo.tools import str2bool
|
||||
|
||||
|
||||
# class ResMrpRoutingWorkcenter(models.Model):
|
||||
# _inherit = 'mrp.routing.workcenter'
|
||||
# def init(self):
|
||||
# super(ResMrpRoutingWorkcenter, self).init()
|
||||
# # 在模块初始化时触发计算字段的更新
|
||||
# records = self.search([])
|
||||
# if str2bool(self.env['ir.config_parameter'].get_param('sf.production.process.parameter.is_init_workcenter',default='False')):
|
||||
# return
|
||||
# records.optional_process_parameters_date()
|
||||
# self.env['ir.config_parameter'].set_param('sf.production.process.parameter.is_init_workcenter', True)
|
||||
@@ -1,85 +0,0 @@
|
||||
# # -*- coding: utf-8 -*-
|
||||
# import logging
|
||||
# from odoo import fields, models, api
|
||||
# from odoo.exceptions import UserError
|
||||
# from odoo.tools import str2bool
|
||||
|
||||
|
||||
# class SfProductionProcessParameter(models.Model):
|
||||
# _inherit = 'sf.production.process.parameter'
|
||||
|
||||
|
||||
# @api.model
|
||||
# def create(self, vals):
|
||||
# # if vals.get('code', '/') == '/' or vals.get('code', '/') is False:
|
||||
# # vals['code'] = '101'+self.routing_id.code +self.env['ir.sequence'].next_by_code('sf.production.process.parameter')
|
||||
# if vals.get('routing_id'):
|
||||
# # vals['gain_way'] = '外协'
|
||||
# routing_id = self.env['mrp.routing.workcenter'].browse(vals.get('routing_id'))
|
||||
# if routing_id.surface_technics_id and not vals.get('process_id'):
|
||||
# vals['process_id'] = routing_id.surface_technics_id.id
|
||||
# if vals.get('code', '/') == '/' or vals.get('code', '/') is False:
|
||||
# vals['code'] = '101' + routing_id.code + self.env['ir.sequence'].next_by_code(
|
||||
# 'sf.production.process.parameter')
|
||||
# obj = super(SfProductionProcessParameter, self).create(vals)
|
||||
# return obj
|
||||
# def create_service_product(self):
|
||||
# service_categ = self.env.ref(
|
||||
# 'sf_dlm.product_category_surface_technics_sf').sudo()
|
||||
|
||||
# product_name = f"{self.process_id.name}_{self.name}"
|
||||
# product_id = self.env['product.template'].search(
|
||||
# [("name", '=', product_name)])
|
||||
# if product_id:
|
||||
# product_id.server_product_process_parameters_id = self.id
|
||||
# else:
|
||||
# res_partner = self.env['res.partner'].search([('name','=','湖南傲派自动化设备有限公司')])
|
||||
# self.env['product.template'].create({
|
||||
# 'detailed_type': 'service',
|
||||
# 'name': product_name,
|
||||
# 'invoice_policy': 'delivery',
|
||||
# 'categ_id': service_categ.id,
|
||||
# 'description': f"基于{self.name}创建的服务产品",
|
||||
# 'sale_ok': True, # 可销售
|
||||
# 'purchase_ok': True, # 可采购
|
||||
# 'server_product_process_parameters_id': self.id,
|
||||
# 'seller_ids': [(0, 0, {
|
||||
# # 'delay': 1,
|
||||
# 'partner_id': res_partner.id,
|
||||
# 'price': 1, })],
|
||||
# })
|
||||
|
||||
# def create_work_center(self):
|
||||
# production_process_parameter = self
|
||||
# if not production_process_parameter.process_id:
|
||||
# return
|
||||
# if not production_process_parameter.routing_id:
|
||||
# workcenter_id = self.env['mrp.routing.workcenter'].search(
|
||||
# [("surface_technics_id", '=', production_process_parameter.process_id.id)])
|
||||
# if not workcenter_id:
|
||||
# outsourcing_work_center = self.env['mrp.workcenter'].search(
|
||||
# [("name", '=', '外协工作中心')])
|
||||
# routing_id = self.env['mrp.routing.workcenter'].create({
|
||||
# 'workcenter_ids': [(6, 0, outsourcing_work_center.ids)],
|
||||
# 'routing_tag': 'special',
|
||||
# 'routing_type': '表面工艺',
|
||||
# 'is_outsource': True,
|
||||
# 'surface_technics_id': production_process_parameter.process_id.id,
|
||||
# 'name': production_process_parameter.process_id.name,
|
||||
# })
|
||||
# production_process_parameter.routing_id = routing_id.id
|
||||
# else:
|
||||
# production_process_parameter.routing_id = workcenter_id.id
|
||||
|
||||
# def init(self):
|
||||
# super(SfProductionProcessParameter, self).init()
|
||||
# # 在模块初始化时触发计算字段的更新
|
||||
# records = self.search([])
|
||||
# if str2bool(self.env['ir.config_parameter'].get_param('sf.production.process.parameter.is_init_process',
|
||||
# default='False')):
|
||||
# return
|
||||
# for record in records:
|
||||
# if not record.outsourced_service_products:
|
||||
# record.create_service_product()
|
||||
# record.create_work_center()
|
||||
# self.env['ir.config_parameter'].set_param('sf.production.process.parameter.is_init_process', True)
|
||||
@@ -39,9 +39,9 @@
|
||||
attrs="{'invisible': [('categ_type', 'not in', ['成品','坯料', '原材料'])],'readonly': [('id', '!=', False)]}"/>
|
||||
<field name="materials_type_id" string="型号" placeholder="请选择" options="{'no_create': True}"
|
||||
attrs="{'invisible': [('categ_type', 'not in', ['成品','坯料', '原材料'])],'readonly': [('id', '!=', False)]}"/>
|
||||
<field name="server_product_process_parameters_id" string="工艺参数"
|
||||
<field name="server_product_process_parameters_id" string="表面工艺参数"
|
||||
options="{'no_create': True}"
|
||||
attrs="{'invisible': ['|',('detailed_type', '!=', 'service'),('detailed_type', '=', False)]}"/>
|
||||
attrs="{'invisible': ['|',('categ_type', '!=', '表面工艺'),('categ_type', '=', False)]}"/>
|
||||
<field name="cutting_tool_material_id" class="custom_required"
|
||||
options="{'no_create': True}"
|
||||
attrs="{'invisible': [('categ_type', '!=', '刀具')],'required': [('categ_type', '=', '刀具')],'readonly': [('id', '!=', False)]}"
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@@ -1,21 +1,15 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
import logging
|
||||
import os
|
||||
import re
|
||||
from ftplib import FTP, error_perm
|
||||
from ftplib import FTP
|
||||
|
||||
_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.
|
||||
By default list current directory to stdout.
|
||||
@@ -36,50 +30,7 @@ class FTP_P(FTP):
|
||||
tempdic['name'] = [file for file in r_files if file != "." and file != ".."]
|
||||
# 去除. ..
|
||||
return tempdic
|
||||
|
||||
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)
|
||||
# return [file for file in r_files if file != "." and file != ".."]
|
||||
|
||||
|
||||
# FTP接口类
|
||||
@@ -101,8 +52,8 @@ class FtpController:
|
||||
print(self.username, self.port, self.host, self.password)
|
||||
ftp = FTP_P()
|
||||
_logger.info("===================connect==================")
|
||||
# ftp.set_debuglevel(2) #打开调试级别2,显示详细信息
|
||||
# ftp.set_pasv(1) # 0主动模式 1 #被动模式
|
||||
# self.ftp.set_debuglevel(2) #打开调试级别2,显示详细信息
|
||||
ftp.set_pasv(0) # 0主动模式 1 #被动模式
|
||||
try:
|
||||
ftp.connect(self.host, self.port)
|
||||
ftp.login(self.username, self.password)
|
||||
@@ -177,187 +128,3 @@ class FtpController:
|
||||
:return:
|
||||
"""
|
||||
self.ftp.delete(delpath)
|
||||
|
||||
|
||||
|
||||
def transfer_files(
|
||||
source_ftp_info,
|
||||
target_ftp_info,
|
||||
source_dir,
|
||||
target_dir,
|
||||
end_with=None,
|
||||
match_str=None,
|
||||
keep_dir=False):
|
||||
"""
|
||||
从源FTP服务器下载所有{end_with}结尾的文件并上传到目标FTP服务器,保持目录结构
|
||||
|
||||
Args:
|
||||
source_ftp_info: dict, 源FTP连接信息 {host, port, username, password}
|
||||
target_ftp_info: dict, 目标FTP连接信息 {host, port, username, password}
|
||||
source_dir: str, 源FTP上的起始目录
|
||||
target_dir: str, 目标FTP上的目标目录
|
||||
keep_dir: bool, 是否保持目录结构,默认False
|
||||
"""
|
||||
transfered_file_list = []
|
||||
try:
|
||||
# 连接源FTP
|
||||
source_ftp = FtpController(
|
||||
source_ftp_info['host'],
|
||||
source_ftp_info['port'],
|
||||
source_ftp_info['username'],
|
||||
source_ftp_info['password']
|
||||
)
|
||||
if not source_ftp.ftp:
|
||||
raise Exception("编程文件FTP连接失败")
|
||||
source_ftp.ftp.set_pasv(1)
|
||||
|
||||
# 连接目标FTP
|
||||
target_ftp = FtpController(
|
||||
target_ftp_info['host'],
|
||||
target_ftp_info['port'],
|
||||
target_ftp_info['username'],
|
||||
target_ftp_info['password']
|
||||
)
|
||||
if not source_ftp.ftp:
|
||||
raise Exception("机床FTP连接失败")
|
||||
source_ftp.ftp.set_pasv(1)
|
||||
|
||||
# 递归遍历源目录
|
||||
def traverse_dir(current_dir, relative_path=''):
|
||||
source_ftp.ftp.cwd(current_dir)
|
||||
file_list = source_ftp.ftp.nlst()
|
||||
|
||||
for item in file_list:
|
||||
try:
|
||||
# 尝试进入目录
|
||||
source_ftp.ftp.cwd(f"{current_dir}/{item}")
|
||||
# 如果成功则是目录
|
||||
new_relative_path = os.path.join(relative_path, item)
|
||||
# 在目标FTP创建对应目录
|
||||
try:
|
||||
if keep_dir:
|
||||
target_ftp.ftp.mkd(f"{target_dir}/{new_relative_path}")
|
||||
except:
|
||||
pass # 目录可能已存在
|
||||
# 递归遍历子目录
|
||||
traverse_dir(f"{current_dir}/{item}", new_relative_path)
|
||||
source_ftp.ftp.cwd('..')
|
||||
except:
|
||||
matched = False
|
||||
# 文件名匹配字符串BT30-(两个字符)-all.nc, 例6667_20250422-BT30-ZM-all.nc
|
||||
if match_str and re.match(match_str, item):
|
||||
matched = True
|
||||
elif end_with and item.lower().endswith(end_with):
|
||||
matched = True
|
||||
|
||||
if matched:
|
||||
# 下载到临时文件
|
||||
temp_path = f"/tmp/{item}"
|
||||
with open(temp_path, 'wb') as f:
|
||||
source_ftp.ftp.retrbinary(f'RETR {item}', f.write)
|
||||
|
||||
# 上传到目标FTP对应目录
|
||||
if keep_dir:
|
||||
target_path = f"{target_dir}/{relative_path}/{item}"
|
||||
else:
|
||||
target_path = f"{target_dir}/{item}"
|
||||
|
||||
# 规范化路径
|
||||
target_path = target_path.replace('\\', '/').strip('/')
|
||||
|
||||
# 确保目标目录存在
|
||||
target_dir_path = '/'.join(target_path.split('/')[:-1])
|
||||
try:
|
||||
target_ftp.ftp.cwd('/') # 回到根目录
|
||||
for dir_part in target_dir_path.split('/'):
|
||||
if dir_part:
|
||||
try:
|
||||
target_ftp.ftp.cwd(dir_part)
|
||||
except:
|
||||
try:
|
||||
target_ftp.ftp.mkd(dir_part)
|
||||
target_ftp.ftp.cwd(dir_part)
|
||||
except Exception as e:
|
||||
logging.error(f"创建目录失败 {dir_part}: {str(e)}")
|
||||
raise
|
||||
except Exception as e:
|
||||
logging.error(f"处理目标目录失败: {str(e)}")
|
||||
raise
|
||||
|
||||
# 检查FTP连接状态
|
||||
try:
|
||||
target_ftp.ftp.voidcmd('NOOP')
|
||||
except:
|
||||
logging.error("FTP连接已断开,尝试重新连接")
|
||||
target_ftp.ftp.connect(target_ftp_info['host'], target_ftp_info['port'])
|
||||
target_ftp.ftp.login(target_ftp_info['username'], target_ftp_info['password'])
|
||||
|
||||
# 上传文件
|
||||
try:
|
||||
with open(temp_path, 'rb') as f:
|
||||
# 检查文件是否可读
|
||||
content = f.read()
|
||||
if not content:
|
||||
raise Exception("临时文件为空")
|
||||
f.seek(0) # 重置文件指针
|
||||
target_ftp.ftp.storbinary(f'STOR {target_path}', f)
|
||||
except Exception as e:
|
||||
logging.error(f"上传文件失败: {str(e)}")
|
||||
logging.error(f"目标路径: {target_path}")
|
||||
raise
|
||||
|
||||
transfered_file_list.append(item)
|
||||
# 删除临时文件
|
||||
os.remove(temp_path)
|
||||
logging.info(f"已传输文件: {item}")
|
||||
|
||||
# 清空目标目录下的所有内容
|
||||
# try:
|
||||
# target_ftp.ftp.cwd(target_dir)
|
||||
# files = target_ftp.ftp.nlst()
|
||||
|
||||
# for f in files:
|
||||
# try:
|
||||
# # 尝试删除文件
|
||||
# target_ftp.ftp.delete(f)
|
||||
# except:
|
||||
# try:
|
||||
# # 如果删除失败,可能是目录,递归删除目录
|
||||
# def remove_dir(path):
|
||||
# target_ftp.ftp.cwd(path)
|
||||
# sub_files = target_ftp.ftp.nlst()
|
||||
# for sf in sub_files:
|
||||
# try:
|
||||
# target_ftp.ftp.delete(sf)
|
||||
# except:
|
||||
# remove_dir(f"{path}/{sf}")
|
||||
# target_ftp.ftp.cwd('..')
|
||||
# target_ftp.ftp.rmd(path)
|
||||
|
||||
# remove_dir(f"{target_dir}/{f}")
|
||||
# except:
|
||||
# logging.error(f"无法删除 {f}")
|
||||
# pass
|
||||
|
||||
# logging.info(f"已清空目标目录 {target_dir}")
|
||||
# except Exception as e:
|
||||
# logging.error(f"清空目标目录失败: {str(e)}")
|
||||
# raise Exception(f"清空目标目录失败: {str(e)}")
|
||||
|
||||
# 开始遍历
|
||||
traverse_dir(source_dir)
|
||||
|
||||
logging.info("所有文件传输完成")
|
||||
return transfered_file_list
|
||||
|
||||
except Exception as e:
|
||||
logging.error(f"传输过程出错: {str(e)}")
|
||||
raise e
|
||||
|
||||
finally:
|
||||
# 关闭FTP连接
|
||||
try:
|
||||
source_ftp.ftp.quit()
|
||||
target_ftp.ftp.quit()
|
||||
except:
|
||||
pass
|
||||
@@ -2,8 +2,6 @@
|
||||
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
|
||||
@@ -828,34 +826,6 @@ class SfMaintenanceEquipment(models.Model):
|
||||
image_lq_id = fields.Many2many('maintenance.equipment.image', 'equipment_lq_id', string='冷却方式',
|
||||
domain="[('type', '=', '冷却方式')]")
|
||||
|
||||
ftp_host = fields.Char('FTP 主机')
|
||||
ftp_port = fields.Char('FTP 端口')
|
||||
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'
|
||||
|
||||
@@ -1053,21 +1053,6 @@
|
||||
</page>
|
||||
</xpath>
|
||||
|
||||
<xpath expr="//group/field[@name='location']" position="after">
|
||||
<field name="qr_code_image" widget="image" readonly="1" attrs="{'invisible': [('equipment_type', '!=', '机床')]}" />
|
||||
</xpath>
|
||||
<xpath expr="//page[@name='maintenance']" position="after">
|
||||
<page name="network_config" string="网络配置" attrs="{'invisible': [('equipment_type', '!=', '机床')]}" >
|
||||
<group>
|
||||
<group string="ftp配置">
|
||||
<field name="ftp_host" string="主机"/>
|
||||
<field name="ftp_port" string="端口"/>
|
||||
<field name="ftp_username" string="用户名"/>
|
||||
<field name="ftp_password" string="密码" password="True"/>
|
||||
</group>
|
||||
</group>
|
||||
</page>
|
||||
</xpath>
|
||||
</data>
|
||||
</field>
|
||||
</record>
|
||||
|
||||
@@ -10,8 +10,7 @@
|
||||
""",
|
||||
'category': 'sf',
|
||||
'website': 'https://www.sf.jikimo.com',
|
||||
'depends': ['sf_base', 'sf_maintenance', 'web_widget_model_viewer', 'sf_warehouse', 'jikimo_attachment_viewer',
|
||||
'jikimo_sale_multiple_supply_methods', 'product'],
|
||||
'depends': ['sf_base', 'sf_maintenance', 'web_widget_model_viewer', 'sf_warehouse','jikimo_attachment_viewer', 'jikimo_sale_multiple_supply_methods'],
|
||||
'data': [
|
||||
'data/cron_data.xml',
|
||||
'data/stock_data.xml',
|
||||
@@ -19,7 +18,6 @@
|
||||
'data/panel_data.xml',
|
||||
'data/sf_work_individuation_page.xml',
|
||||
'data/agv_scheduling_data.xml',
|
||||
'data/product_data.xml',
|
||||
'security/group_security.xml',
|
||||
'security/ir.model.access.csv',
|
||||
'wizard/workpiece_delivery_views.xml',
|
||||
@@ -30,7 +28,6 @@
|
||||
'wizard/mrp_workorder_batch_replan_wizard_views.xml',
|
||||
'wizard/sf_programming_reason_views.xml',
|
||||
'wizard/sale_order_cancel_views.xml',
|
||||
'wizard/process_outsourcing.xml',
|
||||
'views/mrp_views_menus.xml',
|
||||
'views/agv_scheduling_views.xml',
|
||||
'views/stock_lot_views.xml',
|
||||
@@ -47,8 +44,6 @@
|
||||
'views/sale_order_views.xml',
|
||||
'views/mrp_workorder_batch_replan.xml',
|
||||
'views/purchase_order_view.xml',
|
||||
'views/product_template_views.xml',
|
||||
# 'views/stock_warehouse_orderpoint.xml',
|
||||
],
|
||||
'assets': {
|
||||
|
||||
|
||||
@@ -6,14 +6,12 @@ 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):
|
||||
"""
|
||||
自动化传递工单号获取工单信息
|
||||
@@ -56,7 +54,6 @@ class Manufacturing_Connect(http.Controller):
|
||||
|
||||
@http.route('/AutoDeviceApi/GetShiftPlan', type='json', auth='sf_token', methods=['GET', 'POST'], csrf=False,
|
||||
cors="*")
|
||||
@api_log('获取日计划', requester='中控系统')
|
||||
def get_ShiftPlan(self, **kw):
|
||||
"""
|
||||
自动化每天获取机台日计划
|
||||
@@ -110,7 +107,6 @@ class Manufacturing_Connect(http.Controller):
|
||||
|
||||
@http.route('/AutoDeviceApi/QcCheck', type='json', auth='sf_token', methods=['GET', 'POST'], csrf=False,
|
||||
cors="*")
|
||||
@api_log('工件预调(前置三元检测)', requester='中控系统')
|
||||
def get_qcCheck(self, **kw):
|
||||
"""
|
||||
工件预调(前置三元检测)
|
||||
@@ -153,7 +149,6 @@ class Manufacturing_Connect(http.Controller):
|
||||
|
||||
@http.route('/AutoDeviceApi/FeedBackStart', type='json', auth='none', methods=['GET', 'POST'], csrf=False,
|
||||
cors="*")
|
||||
@api_log('工单开始', requester='中控系统')
|
||||
def button_Work_START(self, **kw):
|
||||
"""
|
||||
工单任务开始
|
||||
@@ -203,7 +198,6 @@ class Manufacturing_Connect(http.Controller):
|
||||
|
||||
@http.route('/AutoDeviceApi/FeedBackEnd', type='json', auth='none', methods=['GET', 'POST'], csrf=False,
|
||||
cors="*")
|
||||
@api_log('工单结束', requester='中控系统')
|
||||
def button_Work_End(self, **kw):
|
||||
"""
|
||||
工单任务结束
|
||||
@@ -255,7 +249,6 @@ class Manufacturing_Connect(http.Controller):
|
||||
|
||||
@http.route('/AutoDeviceApi/PartQualityInspect', type='json', auth='none', methods=['GET', 'POST'], csrf=False,
|
||||
cors="*")
|
||||
@api_log('零件检测(后置三元检测)', requester='中控系统')
|
||||
def PartQualityInspect(self, **kw):
|
||||
"""
|
||||
零件质检
|
||||
@@ -302,7 +295,6 @@ class Manufacturing_Connect(http.Controller):
|
||||
|
||||
@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下载文件
|
||||
@@ -343,7 +335,6 @@ class Manufacturing_Connect(http.Controller):
|
||||
|
||||
@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下载文件
|
||||
@@ -385,7 +376,6 @@ class Manufacturing_Connect(http.Controller):
|
||||
|
||||
@http.route('/AutoDeviceApi/LocationChange', type='json', auth='sf_token', methods=['GET', 'POST'], csrf=False,
|
||||
cors="*")
|
||||
@api_log('库位变更', requester='中控系统')
|
||||
def LocationChange(self, **kw):
|
||||
"""
|
||||
库位变更
|
||||
@@ -445,7 +435,32 @@ class Manufacturing_Connect(http.Controller):
|
||||
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)
|
||||
total_data = request.env['sf.shelf.location.datasync'].sudo().get_total_data()
|
||||
for item in shelfinfo:
|
||||
logging.info('货架已获取信息:%s' % item)
|
||||
shelf_barcode = request.env['sf.shelf.location.datasync'].sudo().find_our_code(
|
||||
total_data, item['Postion'])
|
||||
location_id = request.env['sf.shelf.location'].sudo().search(
|
||||
[('barcode', '=', shelf_barcode)],
|
||||
limit=1)
|
||||
if location_id:
|
||||
# 如果是线边刀库信息,则对功能刀具移动生成记录
|
||||
if 'Tool' in item['Postion']:
|
||||
tool = request.env['sf.functional.cutting.tool.entity'].sudo().search(
|
||||
[('rfid', '=', item['RfidCode']), ('functional_tool_status', '!=', '已拆除')])
|
||||
tool.sudo().tool_in_out_stock_location(location_id)
|
||||
if tool:
|
||||
location_id.product_sn_id = tool.barcode_id.id
|
||||
# 修改功能刀具状态
|
||||
if item.get('State') == '报警':
|
||||
if tool.functional_tool_status != item.get('State'):
|
||||
tool.write({
|
||||
'functional_tool_status': item['State']
|
||||
})
|
||||
else:
|
||||
location_id.product_sn_id = False
|
||||
if item['RfidCode']:
|
||||
logging.info('Rfid为【%s】的功能刀具在系统中不存在!' % item['RfidCode'])
|
||||
else:
|
||||
equipment_id = request.env['maintenance.equipment'].sudo().search([('name', '=', DeciveId)])
|
||||
if equipment_id:
|
||||
@@ -465,7 +480,6 @@ class Manufacturing_Connect(http.Controller):
|
||||
|
||||
@http.route('/AutoDeviceApi/AGVToProduct', type='json', auth='none', methods=['GET', 'POST'], csrf=False,
|
||||
cors="*")
|
||||
@api_log('AGV运送上产线', requester='中控系统')
|
||||
def AGVToProduct(self, **kw):
|
||||
"""
|
||||
AGV运送上产线(完成)
|
||||
@@ -538,7 +552,6 @@ class Manufacturing_Connect(http.Controller):
|
||||
|
||||
@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托盘到产线接驳站。
|
||||
|
||||
@@ -27,7 +27,7 @@ class JikimoSaleRoutePicking(Sf_Bf_Connect):
|
||||
bfm_process_order_list = json.loads(kw['bfm_process_order_list'])
|
||||
order_id = request.env['sale.order'].with_user(request.env.ref("base.user_admin")).sale_order_create(
|
||||
company_id, kw['delivery_name'], kw['delivery_telephone'], kw['delivery_address'],
|
||||
kw['delivery_end_date'], kw['payments_way'], kw['pay_way'], kw['order_number'], kw['remark'], state='draft',
|
||||
kw['delivery_end_date'], kw['payments_way'], kw['pay_way'], kw['order_number'], state='draft',
|
||||
model_display_version=kw.get('model_display_version'))
|
||||
i = 1
|
||||
# 给sale_order的default_code字段赋值
|
||||
@@ -45,9 +45,6 @@ class JikimoSaleRoutePicking(Sf_Bf_Connect):
|
||||
product.product_tmpl_id.is_customer_provided = True if item['embryo_redundancy_id'] else False
|
||||
order_id.with_user(request.env.ref("base.user_admin")).sale_order_create_line(product, item)
|
||||
i += 1
|
||||
if kw.get('contract_file_name') and kw.get('contract_file') and kw.get('contract_code'):
|
||||
order_id.create_sale_documents(kw.get('contract_file_name'), kw.get('contract_file'))
|
||||
order_id.write({'contract_code': kw.get('contract_code'), 'contract_date': kw.get('contract_date')})
|
||||
res['factory_order_no'] = order_id.name
|
||||
order_id.confirm_to_supply_method()
|
||||
except Exception as e:
|
||||
|
||||
@@ -1,23 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8" ?>
|
||||
<odoo>
|
||||
<data noupdate="1">
|
||||
<record id="product_category_service" model="product.category">
|
||||
<field name="name">服务</field>
|
||||
<field name="parent_id" ref="product.product_category_all"/>
|
||||
<field name="property_cost_method">fifo</field>
|
||||
<field name="property_valuation">manual_periodic</field>
|
||||
</record>
|
||||
<record id="product_category_outsource_process" model="product.category">
|
||||
<field name="name">工序外协</field>
|
||||
<field name="parent_id" ref="sf_manufacturing.product_category_service"/>
|
||||
<field name="property_cost_method">fifo</field>
|
||||
<field name="property_valuation">manual_periodic</field>
|
||||
</record>
|
||||
<record id="product_category_outsource_other_process" model="product.category">
|
||||
<field name="name">其他</field>
|
||||
<field name="parent_id" ref="sf_manufacturing.product_category_outsource_process"/>
|
||||
<field name="property_cost_method">fifo</field>
|
||||
<field name="property_valuation">manual_periodic</field>
|
||||
</record>
|
||||
</data>
|
||||
</odoo>
|
||||
@@ -16,6 +16,4 @@ from . import sf_production_common
|
||||
from . import sale_order
|
||||
from . import quick_easy_order
|
||||
from . import purchase_order
|
||||
from . import quality_check
|
||||
from . import purchase_request_line
|
||||
# from . import stock_warehouse_orderpoint
|
||||
from . import quality_check
|
||||
@@ -87,12 +87,11 @@ class AgvScheduling(models.Model):
|
||||
agv_route_type: AGV任务类型
|
||||
workorders: 工单
|
||||
"""
|
||||
scheduling = None
|
||||
_logger.info('创建AGV调度任务\r\n起点为【%s】,任务类型为【%s】,工单为【%s】' % (agv_start_site_name, agv_route_type, workorders))
|
||||
if not workorders:
|
||||
raise UserError(_('工单不能为空'))
|
||||
agv_start_sites = self.env['sf.agv.site'].sudo().search([('name', '=', agv_start_site_name)])
|
||||
if not agv_start_sites:
|
||||
agv_start_site = self.env['sf.agv.site'].sudo().search([('name', '=', agv_start_site_name)], limit=1)
|
||||
if not agv_start_site:
|
||||
raise UserError(_('不存在名称为【%s】的接驳站,请先创建!' % agv_start_site_name))
|
||||
# 如果存在相同任务类型工单的AGV调度任务,则提示错误
|
||||
agv_scheduling = self.sudo().search([
|
||||
@@ -108,32 +107,24 @@ class AgvScheduling(models.Model):
|
||||
(','.join(repetitive_workorders.mapped('production_id.name')), agv_scheduling.name)
|
||||
)
|
||||
|
||||
# 如果只有唯一任务路线,则自动赋予终点接驳站跟任务名称
|
||||
agv_routes = self.env['sf.agv.task.route'].sudo().search([
|
||||
('route_type', '=', agv_route_type),
|
||||
('start_site_id', 'in', agv_start_sites.ids)
|
||||
])
|
||||
vals = {
|
||||
'start_site_id': agv_start_site.id,
|
||||
'agv_route_type': agv_route_type,
|
||||
'workorder_ids': workorders.ids,
|
||||
# 'workpiece_delivery_ids': deliveries.mapped('id') if deliveries else [],
|
||||
'task_create_time': fields.Datetime.now()
|
||||
}
|
||||
# 如果只有唯一任务路线,则自动赋予终点接驳站跟任务名称
|
||||
agv_routes = self.env['sf.agv.task.route'].sudo().search([
|
||||
('route_type', '=', agv_route_type),
|
||||
('start_site_id', '=', agv_start_site.id)
|
||||
])
|
||||
if not agv_routes:
|
||||
raise UserError(_('不存在起点为【%s】的【%s】任务路线,请先创建!' % (agv_start_site_name, agv_route_type)))
|
||||
# 如果路线中包含起点与终点相同的接驳站,则不创建AGV调度任务
|
||||
if agv_routes.filtered(lambda r: r.start_site_id.name == r.end_site_id.name):
|
||||
return True
|
||||
# 配送类型相同的接驳站为同一个,取第一个即可
|
||||
vals.update({
|
||||
'start_site_id': agv_routes[0].start_site_id.id,
|
||||
})
|
||||
idle_route = None
|
||||
if len(agv_routes) == 1:
|
||||
idle_route = agv_routes[0]
|
||||
vals.update({
|
||||
'end_site_id': idle_route.end_site_id.id, 'agv_route_id': idle_route.id
|
||||
})
|
||||
vals.update({'end_site_id': idle_route.end_site_id.id, 'agv_route_id': idle_route.id})
|
||||
else:
|
||||
# 判断终点接驳站是否为空闲
|
||||
idle_routes = agv_routes.filtered(lambda r: r.end_site_id.state == '空闲')
|
||||
@@ -141,10 +132,7 @@ class AgvScheduling(models.Model):
|
||||
# 将空闲的路线按照终点接驳站名称排序
|
||||
idle_routes = sorted(idle_routes, key=lambda r: r.end_site_id.name)
|
||||
idle_route = idle_routes[0]
|
||||
vals.update({
|
||||
'end_site_id': idle_route.end_site_id.id, 'agv_route_id': idle_route.id
|
||||
})
|
||||
|
||||
vals.update({'end_site_id': idle_route.end_site_id.id, 'agv_route_id': idle_route.id})
|
||||
try:
|
||||
scheduling = self.env['sf.agv.scheduling'].sudo().create(vals)
|
||||
# 触发空闲接驳站状态更新,触发新任务下发
|
||||
@@ -154,7 +142,7 @@ class AgvScheduling(models.Model):
|
||||
except Exception as e:
|
||||
_logger.error('添加AGV调度任务失败: %s', e)
|
||||
raise UserError(_('添加AGV调度任务失败: %s', e))
|
||||
|
||||
|
||||
return scheduling
|
||||
|
||||
def on_site_state_change(self, agv_site_id, agv_site_state):
|
||||
|
||||
@@ -24,7 +24,7 @@ class AgvSetting(models.Model):
|
||||
|
||||
# name必须唯一
|
||||
_sql_constraints = [
|
||||
('name_uniq', 'unique (name, workcenter_id)', '同一工作中心的站点编号必须唯一!'),
|
||||
('name_uniq', 'unique (name)', '站点编号必须唯一!'),
|
||||
]
|
||||
|
||||
# def update_site_state(self):
|
||||
@@ -68,12 +68,11 @@ class AgvSetting(models.Model):
|
||||
"""
|
||||
if isinstance(agv_site_state_arr, dict):
|
||||
for agv_site_name, is_occupy in agv_site_state_arr.items():
|
||||
agv_sites = self.env['sf.agv.site'].sudo().search([('name', '=', agv_site_name)])
|
||||
if agv_sites:
|
||||
agv_sites.state = is_occupy
|
||||
agv_site = self.env['sf.agv.site'].sudo().search([('name', '=', agv_site_name)])
|
||||
if agv_site:
|
||||
agv_site.state = is_occupy
|
||||
if notify:
|
||||
for agv_site in agv_sites:
|
||||
self.env['sf.agv.scheduling'].on_site_state_change(agv_site.id, agv_site.state)
|
||||
self.env['sf.agv.scheduling'].on_site_state_change(agv_site.id, agv_site.state)
|
||||
else:
|
||||
_logger.error("更新失败:接驳站站点错误!%s" % agv_site_name)
|
||||
raise UserError("更新失败:接驳站站点错误!")
|
||||
|
||||
@@ -6,7 +6,6 @@ import json
|
||||
import os
|
||||
import re
|
||||
import traceback
|
||||
from operator import itemgetter
|
||||
|
||||
import requests
|
||||
from itertools import groupby
|
||||
@@ -239,8 +238,7 @@ class MrpProduction(models.Model):
|
||||
programming_no = fields.Char('编程单号')
|
||||
work_state = fields.Char('业务状态')
|
||||
programming_state = fields.Selection(
|
||||
[('编程中', '编程中'), ('已编程', '已编程'), ('已编程未下发', '已编程未下发'), ('已下发', '已下发'),
|
||||
('已取消', '已取消')],
|
||||
[('编程中', '编程中'), ('已编程', '已编程'), ('已编程未下发', '已编程未下发'), ('已下发', '已下发'), ('已取消', '已取消')],
|
||||
string='编程状态',
|
||||
tracking=True)
|
||||
glb_file = fields.Binary("glb模型文件")
|
||||
@@ -269,7 +267,6 @@ class MrpProduction(models.Model):
|
||||
quality_standard = fields.Binary('质检标准', related='product_id.quality_standard', readonly=True)
|
||||
|
||||
part_name = fields.Char(string='零件名称', compute='_compute_part_info', store=True)
|
||||
|
||||
@api.depends('product_id')
|
||||
def _compute_part_info(self):
|
||||
try:
|
||||
@@ -279,12 +276,10 @@ class MrpProduction(models.Model):
|
||||
production_id.part_name = production_id.product_id.part_name
|
||||
elif production_id.product_id.categ_id.type == '坯料':
|
||||
product_name = ''
|
||||
match = re.search(r'(S\d{5}-\d+)', production_id.product_id.name)
|
||||
match = re.search(r'(S\d{5}-\d)', production_id.product_id.name)
|
||||
# 如果匹配成功,提取结果
|
||||
if match:
|
||||
product_name = match.group(0)
|
||||
else:
|
||||
product_name = production_id.product_id.name
|
||||
if production_id.sale_order_id:
|
||||
sale_order = production_id.sale_order_id
|
||||
else:
|
||||
@@ -405,10 +400,8 @@ class MrpProduction(models.Model):
|
||||
and production.schedule_state == '已排' and production.is_rework is False):
|
||||
production.state = 'pending_cam'
|
||||
if any((wo.test_results == '返工' and wo.state == 'done' and
|
||||
(production.programming_state in ['已编程'] or (
|
||||
wo.individuation_page_list and 'PTD' in wo.individuation_page_list)))
|
||||
or (wo.is_rework is True and wo.state == 'done' and production.programming_state in ['编程中',
|
||||
'已编程'])
|
||||
(production.programming_state in ['已编程'] or(wo.individuation_page_list and 'PTD' in wo.individuation_page_list)))
|
||||
or (wo.is_rework is True and wo.state == 'done' and production.programming_state in ['编程中', '已编程'])
|
||||
for wo in production.workorder_ids) or production.is_rework is True:
|
||||
production.state = 'rework'
|
||||
if any(wo.test_results == '报废' and wo.state == 'done' for wo in production.workorder_ids):
|
||||
@@ -624,7 +617,7 @@ class MrpProduction(models.Model):
|
||||
for rp in reproduction:
|
||||
if rp.programming_no == item['programming_no']:
|
||||
rp.write({'programming_state': '已编程未下发' if item[
|
||||
'programming_state'] == '已编程' else '编程中'})
|
||||
'programming_state'] == '已编程' else '编程中'})
|
||||
|
||||
else:
|
||||
return item
|
||||
@@ -638,17 +631,13 @@ class MrpProduction(models.Model):
|
||||
# 增加触发时间参数
|
||||
def update_programming_state(self, trigger_time=None, reprogramming_reason=None):
|
||||
try:
|
||||
reason = ""
|
||||
manufacturing_type = None
|
||||
if self.is_scrap:
|
||||
manufacturing_type = 'scrap'
|
||||
reason = "报废"
|
||||
elif self.tool_state == '2':
|
||||
manufacturing_type = 'invalid_tool_rework'
|
||||
reason = "无效功能刀具"
|
||||
elif self.is_rework:
|
||||
manufacturing_type = 'rework'
|
||||
reason = "返工"
|
||||
res = {'programming_no': self.programming_no,
|
||||
'manufacturing_type': manufacturing_type,
|
||||
'trigger_time': trigger_time,
|
||||
@@ -663,16 +652,6 @@ class MrpProduction(models.Model):
|
||||
result = json.loads(ret['result'])
|
||||
logging.info('update_programming_state-ret:%s' % result)
|
||||
if result['status'] == 1:
|
||||
self.programming_record_ids.create({
|
||||
'number': len(self.programming_record_ids) + 1,
|
||||
'production_id': self.id,
|
||||
'reason': reason,
|
||||
'programming_method': False,
|
||||
'current_programming_count': False,
|
||||
'target_production_id': False,
|
||||
'apply_time': fields.Datetime.now(),
|
||||
'send_time': False,
|
||||
})
|
||||
self.write({'is_rework': True})
|
||||
else:
|
||||
raise UserError(ret['message'])
|
||||
@@ -803,17 +782,6 @@ class MrpProduction(models.Model):
|
||||
if ret['status'] == 1:
|
||||
self.write(
|
||||
{'programming_no': ret['programming_no'], 'programming_state': '编程中', 'work_state': '编程中'})
|
||||
# 生成编程记录
|
||||
self.programming_record_ids.create({
|
||||
'number': len(self.programming_record_ids) + 1,
|
||||
'production_id': self.id,
|
||||
'reason': '首次下发',
|
||||
'programming_method': False,
|
||||
'current_programming_count': False,
|
||||
'target_production_id': False,
|
||||
'apply_time': fields.Datetime.now(),
|
||||
'send_time': False,
|
||||
})
|
||||
else:
|
||||
raise UserError(ret['message'])
|
||||
except Exception as e:
|
||||
@@ -921,48 +889,11 @@ class MrpProduction(models.Model):
|
||||
workorders_values.append(
|
||||
self.env[
|
||||
'mrp.workorder']._json_workorder_surface_process_str(
|
||||
production, route, product_production_process.seller_ids[
|
||||
0].partner_id.id if product_production_process.seller_ids else False))
|
||||
production, route, product_production_process.seller_ids[0].partner_id.id))
|
||||
production.workorder_ids = workorders_values
|
||||
for workorder in production.workorder_ids:
|
||||
workorder.duration_expected = workorder._get_duration_expected()
|
||||
|
||||
# def _create_subcontract_purchase_request(self, purchase_request_line):
|
||||
# sorted_list = sorted(purchase_request_line, key=itemgetter('name'))
|
||||
# grouped_purchase_request_line = {
|
||||
# k: list(g)
|
||||
# for k, g in groupby(sorted_list, key=itemgetter('name'))
|
||||
# }
|
||||
# for name, request_line in grouped_purchase_request_line.items():
|
||||
# request_line_sorted_list = sorted(request_line, key=itemgetter('product_id'))
|
||||
# grouped_purchase_request_line_sorted_list = {
|
||||
# k: list(g)
|
||||
# for k, g in groupby(request_line_sorted_list, key=itemgetter('product_id'))
|
||||
# }
|
||||
# purchase_request_model = self.env["purchase.request"]
|
||||
# origin = ", ".join({item['production_name'] for item in request_line_sorted_list if item.get('production_name')})
|
||||
# pr = purchase_request_model.create({
|
||||
# "origin": origin,
|
||||
# "company_id": self.company_id.id,
|
||||
# "picking_type_id": self.env.ref('stock.picking_type_in').id,
|
||||
# "group_id": request_line[0].get('group_id'),
|
||||
# "requested_by": self.env.context.get("uid", self.env.uid),
|
||||
# "assigned_to": False,
|
||||
# "bom_id": self[0].bom_id.id,
|
||||
# "is_subcontract":True,
|
||||
# })
|
||||
# self[0].bom_id.bom_line_ids.product_id.route_ids = [(4,self.env.ref(
|
||||
# 'sf_stock.stock_route_process_outsourcing').id)]
|
||||
# for product_id, request_line_list in grouped_purchase_request_line_sorted_list.items():
|
||||
# cur_request_line = request_line_list[0]
|
||||
# # cur_request_line['product_qty'] = cur_request_line['product_qty']
|
||||
# cur_request_line['request_id'] = pr.id
|
||||
# cur_request_line['origin'] = ", ".join({item['production_name'] for item in request_line_list if item.get('production_name')})
|
||||
# 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):
|
||||
production_all = self.sorted(lambda x: x.id)
|
||||
@@ -972,8 +903,6 @@ class MrpProduction(models.Model):
|
||||
for product_id, pd in grouped_product_ids.items():
|
||||
product_id_to_production_names[product_id] = [p.name for p in pd]
|
||||
sorted_workorders = None
|
||||
purchase_request_line = []
|
||||
all_workorders = []
|
||||
for production in production_all:
|
||||
proc_workorders = []
|
||||
process_parameter_workorder = self.env['mrp.workorder'].search(
|
||||
@@ -991,12 +920,7 @@ class MrpProduction(models.Model):
|
||||
for workorders in reversed(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)
|
||||
# all_workorders += workorders
|
||||
# self._create_subcontract_purchase_request(purchase_request_line)
|
||||
# for workorder in all_workorders:
|
||||
# workorder._compute_pr_mp_count()
|
||||
|
||||
# 工单排序
|
||||
def _reset_work_order_sequence1(self, k):
|
||||
for rec in self:
|
||||
@@ -1417,7 +1341,7 @@ class MrpProduction(models.Model):
|
||||
'default_reprogramming_num': cloud_programming.get('reprogramming_num') if cloud_programming else '',
|
||||
'default_programming_state': cloud_programming.get('programming_state') if cloud_programming else '',
|
||||
'default_is_reprogramming': True if cloud_programming and (
|
||||
cloud_programming.get('programming_state') in ['已下发']) else False
|
||||
cloud_programming.get('programming_state') in ['已下发']) else False
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1799,12 +1723,12 @@ class MrpProduction(models.Model):
|
||||
"""
|
||||
检查前置条件:制造订单【状态】=“待排程、待加工”,制造订单的【编程状态】=“已编程”。
|
||||
"""
|
||||
print('申请编程')
|
||||
if len(self) > 1:
|
||||
raise UserError('仅支持选择单个制造订单进行编程申请,请重新选择')
|
||||
for production in self:
|
||||
if production.state not in ['confirmed', 'pending_cam'] or production.programming_state != '已编程':
|
||||
raise UserError(
|
||||
'不可操作。所选制造订单必须同时满足如下条件:\n1、制造订单状态:待排程 或 待加工;\n2、制造订单编程状态:已编程。\n请检查!')
|
||||
raise UserError('不可操作。所选制造订单必须同时满足如下条件:\n1、制造订单状态:待排程 或 待加工;\n2、制造订单编程状态:已编程。\n请检查!')
|
||||
cloud_programming = production._cron_get_programming_state()
|
||||
if cloud_programming['programming_state'] in ['待编程', '已编程', '编程中']:
|
||||
raise UserError("当前编程单正在重新编程,请注意查看当前制造订单的“编程记录”确认进度!")
|
||||
@@ -1847,8 +1771,6 @@ class MrpProduction(models.Model):
|
||||
except Exception as e:
|
||||
logging.info('update_programming_state error:%s' % e)
|
||||
raise UserError("更新编程单状态失败,请联系管理员")
|
||||
|
||||
model_id = fields.Char('模型ID', related='product_id.model_id')
|
||||
|
||||
|
||||
# 编程记录
|
||||
@@ -1867,7 +1789,6 @@ class sf_programming_record(models.Model):
|
||||
target_production_id = fields.Char('目标制造单号')
|
||||
apply_time = fields.Datetime('申请时间')
|
||||
send_time = fields.Datetime('下发时间')
|
||||
apply_uid = fields.Many2one('res.users', '申请人', default=lambda self: self.env.user)
|
||||
|
||||
|
||||
class sf_detection_result(models.Model):
|
||||
|
||||
@@ -1,7 +1,6 @@
|
||||
import logging
|
||||
from odoo import fields, models, api
|
||||
from odoo.exceptions import UserError
|
||||
# from odoo.tools import str2bool
|
||||
|
||||
|
||||
class ResMrpRoutingWorkcenter(models.Model):
|
||||
@@ -25,41 +24,10 @@ class ResMrpRoutingWorkcenter(models.Model):
|
||||
workcenter_ids = fields.Many2many('mrp.workcenter', 'rel_workcenter_route', required=True)
|
||||
bom_id = fields.Many2one('mrp.bom', required=False)
|
||||
surface_technics_id = fields.Many2one('sf.production.process', string="表面工艺")
|
||||
# optional_process_parameters = fields.One2many('sf.production.process.parameter','routing_id',string='可选工艺参数')
|
||||
reserved_duration = fields.Float('预留时长', default=30, tracking=True)
|
||||
is_outsource = fields.Boolean('外协', default=False)
|
||||
individuation_page_ids = fields.Many2many('sf.work.individuation.page', string='个性化记录')
|
||||
|
||||
# @api.onchange('surface_technics_id')
|
||||
# def optional_process_parameters_date(self):
|
||||
# for record in self:
|
||||
# if not record.surface_technics_id:
|
||||
# continue
|
||||
# parameter_ids = self.env['sf.production.process.parameter'].search([
|
||||
# ('process_id', '=', record.surface_technics_id.id),
|
||||
# ])
|
||||
# record.optional_process_parameters = parameter_ids.ids
|
||||
|
||||
# @api.model
|
||||
# def _auto_init(self):
|
||||
# # 先执行标准初始化
|
||||
# res = super(ResMrpRoutingWorkcenter, self)._auto_init()
|
||||
# # 然后执行自定义初始化
|
||||
# records = self.search([])
|
||||
# if str2bool(self.env['ir.config_parameter'].get_param('sf.production.process.parameter.is_init_workcenter',
|
||||
# default='False')):
|
||||
# return
|
||||
# records.optional_process_parameters_date()
|
||||
# self.env['ir.config_parameter'].set_param('sf.production.process.parameter.is_init_workcenter', True)
|
||||
# return res
|
||||
# def init(self):
|
||||
# super(ResMrpRoutingWorkcenter, self).init()
|
||||
# # 在模块初始化时触发计算字段的更新
|
||||
# records = self.search([])
|
||||
# if str2bool(self.env['ir.config_parameter'].get_param('sf.production.process.parameter.is_init_workcenter',default='False')):
|
||||
# return
|
||||
# records.optional_process_parameters_date()
|
||||
# self.env['ir.config_parameter'].set_param('sf.production.process.parameter.is_init_workcenter', True)
|
||||
def get_no(self):
|
||||
international_standards = self.search(
|
||||
[('code', '!=', ''), ('active', 'in', [True, False])],
|
||||
|
||||
@@ -21,16 +21,7 @@ class ResWorkcenter(models.Model):
|
||||
related='equipment_id.production_line_id', store=True)
|
||||
is_process_outsourcing = fields.Boolean('工艺外协')
|
||||
users_ids = fields.Many2many("res.users", 'users_workcenter', tracking=True)
|
||||
# @api.constrains('name')
|
||||
# def _check_unique_name_code(self):
|
||||
# for record in self:
|
||||
# # 检查是否已经存在相同的 name 和 code 组合
|
||||
# existing = self.search([
|
||||
# ('name', '=', record.name),
|
||||
# ('id', '!=', record.id) # 排除当前记录
|
||||
# ])
|
||||
# if existing:
|
||||
# raise ValueError('记录已存在')
|
||||
|
||||
def write(self, vals):
|
||||
if 'users_ids' in vals:
|
||||
old_users = self.users_ids
|
||||
@@ -256,12 +247,14 @@ class ResWorkcenter(models.Model):
|
||||
date_planned_end),
|
||||
('state', 'not in', ['draft', 'cancel'])])
|
||||
|
||||
sum_qty = sum([p.product_qty for p in plan_ids]) if plan_ids else count
|
||||
production_line_hour_capacity = self.production_line_hour_capacity
|
||||
if sum_qty > production_line_hour_capacity:
|
||||
message = '当前计划开始时间不能预约排程,超过生产线小时产能(%d件)%d件' % (
|
||||
production_line_hour_capacity, count)
|
||||
raise UserError(message)
|
||||
if plan_ids:
|
||||
sum_qty = sum([p.product_qty for p in plan_ids])
|
||||
production_line_hour_capacity = self.production_line_hour_capacity
|
||||
if sum_qty >= production_line_hour_capacity:
|
||||
message = '当前计划开始时间不能预约排程,超过生产线小时产能(%d件)%d件' % (
|
||||
production_line_hour_capacity, count)
|
||||
raise UserError(message)
|
||||
return False
|
||||
return True
|
||||
|
||||
|
||||
|
||||
@@ -19,8 +19,8 @@ from odoo.addons.sf_mrs_connect.models.ftp_operate import FtpController
|
||||
|
||||
class ResMrpWorkOrder(models.Model):
|
||||
_inherit = 'mrp.workorder'
|
||||
_order = 'sequence asc'
|
||||
_description = '工单'
|
||||
_order = 'sequence'
|
||||
|
||||
product_tmpl_name = fields.Char('坯料产品名称', related='production_bom_id.bom_line_ids.product_id.name')
|
||||
|
||||
@@ -70,21 +70,6 @@ class ResMrpWorkOrder(models.Model):
|
||||
delivery_warning = fields.Selection([('normal', '正常'), ('warning', '告警'), ('overdue', '逾期')], string='时效',
|
||||
tracking=True)
|
||||
back_button_display = fields.Boolean(default=False, compute='_compute_back_button_display', store=True)
|
||||
# pr_mp_count = fields.Integer('采购申请单数量', compute='_compute_pr_mp_count', store=True)
|
||||
|
||||
# @api.depends('state')
|
||||
# def _compute_pr_mp_count(self):
|
||||
# for item in self:
|
||||
# if not item.is_subcontract:
|
||||
# item.pr_mp_count = 0
|
||||
# continue
|
||||
# pr_ids = self.env['purchase.request'].sudo().search(
|
||||
# [('origin', 'like', item.production_id.name), ('is_subcontract', '=', 'True'),
|
||||
# ('state', '!=', 'rejected')])
|
||||
# if pr_ids:
|
||||
# item.pr_mp_count = len(pr_ids)
|
||||
# else:
|
||||
# item.pr_mp_count = 0
|
||||
|
||||
@api.depends('state')
|
||||
def _compute_back_button_display(self):
|
||||
@@ -121,33 +106,27 @@ class ResMrpWorkOrder(models.Model):
|
||||
record.back_button_display = False
|
||||
# tag_type
|
||||
if cur_workorder.is_subcontract or cur_workorder.routing_type == '解除装夹' or cur_workorder.routing_type == '切割' or any(
|
||||
detection_result.processing_panel == cur_workorder.processing_panel and
|
||||
detection_result.routing_type == cur_workorder.routing_type and
|
||||
cur_workorder.tag_type != '重新加工' and
|
||||
detection_result.test_results != '合格'
|
||||
for detection_result in cur_workorder.production_id.detection_result_ids
|
||||
detection_result.processing_panel == cur_workorder.processing_panel and
|
||||
detection_result.routing_type == cur_workorder.routing_type and
|
||||
cur_workorder.tag_type !='重新加工' and
|
||||
detection_result.test_results != '合格'
|
||||
for detection_result in cur_workorder.production_id.detection_result_ids
|
||||
):
|
||||
record.back_button_display = False
|
||||
else:
|
||||
next_workorder = sorted_workorders[position + 1]
|
||||
# 持续获取下一个工单,直到找到一个不是返工的工单
|
||||
while next_workorder and next_workorder.state == 'rework':
|
||||
position += 1
|
||||
if position + 1 < len(sorted_workorders):
|
||||
next_workorder = sorted_workorders[position + 1]
|
||||
else:
|
||||
next_workorder = None
|
||||
if next_workorder and (next_workorder.state == 'ready' or (
|
||||
next_state = next_workorder.state
|
||||
if (next_state == 'ready' or (
|
||||
next_workorder.state == 'waiting' and next_workorder.is_subcontract)) and cur_workorder.state == 'done':
|
||||
record.back_button_display = True
|
||||
else:
|
||||
record.back_button_display = False
|
||||
if cur_workorder.is_subcontract or cur_workorder.routing_type == '解除装夹' or cur_workorder.routing_type == '切割' or any(
|
||||
detection_result.processing_panel == cur_workorder.processing_panel and
|
||||
detection_result.routing_type == cur_workorder.routing_type and
|
||||
cur_workorder.tag_type != '重新加工' and
|
||||
detection_result.test_results != '合格'
|
||||
for detection_result in cur_workorder.production_id.detection_result_ids
|
||||
detection_result.processing_panel == cur_workorder.processing_panel and
|
||||
detection_result.routing_type == cur_workorder.routing_type and
|
||||
cur_workorder.tag_type !='重新加工' and
|
||||
detection_result.test_results != '合格'
|
||||
for detection_result in cur_workorder.production_id.detection_result_ids
|
||||
):
|
||||
record.back_button_display = False
|
||||
|
||||
@@ -227,30 +206,22 @@ class ResMrpWorkOrder(models.Model):
|
||||
# finish_move.move_dest_ids.move_line_ids.reserved_uom_qty = 0
|
||||
else:
|
||||
next_workorder = sorted_workorders[position + 1]
|
||||
# 持续获取下一个工单,直到找到一个不是返工的工单
|
||||
while next_workorder and next_workorder.state == 'rework':
|
||||
position += 1
|
||||
if position + 1 < len(sorted_workorders):
|
||||
next_workorder = sorted_workorders[position + 1]
|
||||
next_state = next_workorder.state
|
||||
if next_state not in ['pending', 'waiting', 'ready']:
|
||||
raise UserError('下工序已经开始,无法回退')
|
||||
if next_workorder.is_subcontract:
|
||||
next_workorder.picking_ids.write({'state': 'waiting'})
|
||||
next_workorder.state = 'pending'
|
||||
self.time_ids.date_end = None
|
||||
cur_workorder.state = 'progress'
|
||||
cur_workorder.production_id.state = 'progress'
|
||||
quality_check = self.env['quality.check'].search(
|
||||
[('workorder_id', '=', self.id)])
|
||||
for check_order in quality_check:
|
||||
if check_order.point_id.is_inspect:
|
||||
check_order.quality_state = 'waiting'
|
||||
else:
|
||||
next_workorder = None
|
||||
if next_workorder:
|
||||
next_state = next_workorder.state
|
||||
if next_state not in ['pending', 'waiting', 'ready']:
|
||||
raise UserError('下工序已经开始,无法回退')
|
||||
if next_workorder.is_subcontract:
|
||||
next_workorder.picking_ids.write({'state': 'waiting'})
|
||||
next_workorder.state = 'pending'
|
||||
self.time_ids.date_end = None
|
||||
cur_workorder.state = 'progress'
|
||||
cur_workorder.production_id.state = 'progress'
|
||||
quality_check = self.env['quality.check'].search(
|
||||
[('workorder_id', '=', self.id)])
|
||||
for check_order in quality_check:
|
||||
if check_order.point_id.is_inspect:
|
||||
check_order.quality_state = 'waiting'
|
||||
else:
|
||||
check_order.quality_state = 'none'
|
||||
check_order.quality_state = 'none'
|
||||
|
||||
def _compute_working_users(self):
|
||||
super()._compute_working_users()
|
||||
@@ -334,7 +305,6 @@ class ResMrpWorkOrder(models.Model):
|
||||
|
||||
tag_type = fields.Selection([("重新加工", "重新加工")], string="标签", tracking=True)
|
||||
technology_design_id = fields.Many2one('sf.technology.design')
|
||||
cnc_worksheet_name = fields.Char('工作指令文件名', readonly=True)
|
||||
|
||||
def _compute_default_construction_period_status(self):
|
||||
need_list = ['pending', 'waiting', 'ready', 'progress', 'to be detected', 'done']
|
||||
@@ -455,15 +425,13 @@ class ResMrpWorkOrder(models.Model):
|
||||
action['context'] = dict(self._context, default_origin=self.name)
|
||||
return action
|
||||
|
||||
@api.depends('state', 'production_id.name')
|
||||
def _compute_surface_technics_purchase_ids(self):
|
||||
for order in self:
|
||||
if order.routing_type == '表面工艺' and order.state not in ['cancel']:
|
||||
domain = [('purchase_type', '=', 'consignment'),
|
||||
('origin', 'like', '%' + self.production_id.name + '%'),
|
||||
('state', '!=', 'cancel')]
|
||||
# domain = [('purchase_type', '=', 'consignment'),
|
||||
# ('origin', 'like', '%' + self.production_id.name + '%'),
|
||||
# ('state', '!=', 'cancel')]
|
||||
purchase = self.env['purchase.order'].search(domain)
|
||||
order.surface_technics_purchase_count = 0
|
||||
if not purchase:
|
||||
@@ -476,31 +444,6 @@ class ResMrpWorkOrder(models.Model):
|
||||
else:
|
||||
order.surface_technics_purchase_count = 0
|
||||
|
||||
# def action_view_pr_mrp_workorder(self):
|
||||
# """
|
||||
# 采购请求
|
||||
# """
|
||||
# self.ensure_one()
|
||||
# pr_ids = self.env['purchase.request'].sudo().search(
|
||||
# [('origin', 'like', self.production_id.name), ('is_subcontract', '=', 'True'),
|
||||
# ('state', '!=', 'rejected')])
|
||||
# action = {
|
||||
# 'res_model': 'purchase.request',
|
||||
# 'type': 'ir.actions.act_window',
|
||||
# }
|
||||
# if len(pr_ids) == 1:
|
||||
# action.update({
|
||||
# 'view_mode': 'form',
|
||||
# 'res_id': pr_ids[0].id,
|
||||
# })
|
||||
# else:
|
||||
# action.update({
|
||||
# 'name': _("从 %s生成采购请求单", self.name),
|
||||
# 'domain': [('id', 'in', pr_ids)],
|
||||
# 'view_mode': 'tree,form',
|
||||
# })
|
||||
# return action
|
||||
|
||||
def action_view_surface_technics_purchase(self):
|
||||
self.ensure_one()
|
||||
# if self.routing_type == '表面工艺':
|
||||
@@ -529,16 +472,14 @@ class ResMrpWorkOrder(models.Model):
|
||||
return result
|
||||
|
||||
def _get_surface_technics_purchase_ids(self):
|
||||
domain = [('origin', 'like', '%' + self.production_id.name + '%'), ('purchase_type', '=', 'consignment'),
|
||||
('state', '!=', 'cancel')]
|
||||
# domain = [('origin', 'like', '%' + self.production_id.name + '%'), ('purchase_type', '=', 'consignment')]
|
||||
# domain = [('group_id', '=', self.production_id.procurement_group_id.id), ('purchase_type', '=', 'consignment')]
|
||||
purchase_orders = self.env['purchase.order'].search(domain, order='id desc')
|
||||
domain = [('origin', 'like', '%' + self.production_id.name + '%'), ('purchase_type', '=', 'consignment')]
|
||||
purchase_orders = self.env['purchase.order'].search(domain)
|
||||
purchase_orders_id = self.env['purchase.order']
|
||||
for po in purchase_orders:
|
||||
for line in po.order_line:
|
||||
if line.product_id.server_product_process_parameters_id == self.surface_technics_parameters_id:
|
||||
purchase_orders_id = line.order_id
|
||||
if line.product_qty == 1:
|
||||
purchase_orders_id = line.order_id
|
||||
return purchase_orders_id
|
||||
|
||||
supplier_id = fields.Many2one('res.partner', string='外协供应商')
|
||||
@@ -753,25 +694,21 @@ class ResMrpWorkOrder(models.Model):
|
||||
# self.workpiece_delivery_ids[0].write({'rfid_code': self.rfid_code})
|
||||
|
||||
def get_plan_workorder(self, production_line):
|
||||
tomorrow = (date.today() + timedelta(days=1)).strftime("%Y-%m-%d")
|
||||
tomorrow_start = f"{tomorrow} 00:00:00"
|
||||
tomorrow_end = f"{tomorrow} 23:59:59"
|
||||
tomorrow = (date.today() + timedelta(days=+1)).strftime("%Y-%m-%d")
|
||||
tomorrow_start = tomorrow + ' 00:00:00'
|
||||
tomorrow_end = tomorrow + ' 23:59:59'
|
||||
logging.info('tomorrow:%s' % tomorrow)
|
||||
sql = """
|
||||
SELECT *
|
||||
FROM mrp_workorder
|
||||
WHERE state!='rework'
|
||||
AND (date_planned_start + interval '8 hours') >= %s::timestamp
|
||||
AND (date_planned_finished + interval '8 hours') <= %s::timestamp
|
||||
to_char(date_planned_start::timestamp + '8 hour','YYYY-MM-DD HH:mm:SS')>= %s
|
||||
AND to_char(date_planned_finished::timestamp + '8 hour','YYYY-MM-DD HH:mm:SS')<= %s
|
||||
"""
|
||||
params = [tomorrow_start, tomorrow_end]
|
||||
if production_line:
|
||||
line = self.env['sf.production.line'].search(
|
||||
[('name', '=', production_line)], limit=1)
|
||||
if not line:
|
||||
raise ValueError(f"生产线'{production_line}'不存在")
|
||||
sql += "AND production_line_id = %s"
|
||||
params.append(line.id)
|
||||
params.append(production_line)
|
||||
self.env.cr.execute(sql, params)
|
||||
ids = [t[0] for t in self.env.cr.fetchall()]
|
||||
return [('id', 'in', ids)]
|
||||
@@ -1263,17 +1200,8 @@ class ResMrpWorkOrder(models.Model):
|
||||
'cmm_ids': production.workorder_ids.filtered(lambda t: t.routing_type == 'CNC加工').cmm_ids,
|
||||
}]
|
||||
return workorders_values_str
|
||||
|
||||
# def check_lot_exists(self, picking_id, lot_id):
|
||||
# return bool(
|
||||
# picking_id.move_ids.move_line_ids.filtered(
|
||||
# lambda line: line.lot_id.id == lot_id
|
||||
# )
|
||||
# )
|
||||
|
||||
def _process_compute_state(self):
|
||||
sorted_workorders = sorted(self, key=lambda x: x.sequence)
|
||||
for workorder in sorted_workorders:
|
||||
for workorder in self:
|
||||
# 如果工单的工序没有进行排序则跳出循环
|
||||
if workorder.production_id.workorder_ids.filtered(lambda wk: wk.sequence == 0):
|
||||
continue
|
||||
@@ -1292,18 +1220,11 @@ class ResMrpWorkOrder(models.Model):
|
||||
workorder.state = 'pending'
|
||||
continue
|
||||
# ================= 如果制造订单制造类型为【人工线下加工】==========================
|
||||
# lot_id = workorder.production_id.move_raw_ids.move_line_ids.lot_id
|
||||
# picking_ids = workorder.production_id.picking_ids.filtered(
|
||||
# lambda wk: wk.location_id.name == '外协收料区' and wk.location_dest_id.name == '制造前')
|
||||
# exists = any(
|
||||
# move_line.lot_id == lot_id
|
||||
# for picking in picking_ids
|
||||
# for move in picking.move_ids
|
||||
# for move_line in move.move_line_ids
|
||||
# )
|
||||
if (workorder.production_id.production_type == '人工线下加工'
|
||||
and workorder.production_id.schedule_state == '已排'):
|
||||
# and workorder.production_id.programming_state == '已编程'
|
||||
and workorder.production_id.schedule_state == '已排'
|
||||
and len(workorder.production_id.picking_ids.filtered(
|
||||
lambda w: w.state not in ['done', 'cancel'])) == 0):
|
||||
# and workorder.production_id.programming_state == '已编程'
|
||||
if workorder.is_subcontract is True:
|
||||
if workorder.production_id.state == 'rework':
|
||||
workorder.state = 'waiting'
|
||||
@@ -1311,9 +1232,6 @@ class ResMrpWorkOrder(models.Model):
|
||||
purchase_orders_id = self._get_surface_technics_purchase_ids()
|
||||
if purchase_orders_id.state == 'purchase':
|
||||
workorder.state = 'ready'
|
||||
# picking_id = workorder.production_id.picking_ids.filtered(
|
||||
# lambda wk: wk.location_id.name == '制造前' and wk.location_dest_id.name == '外协加工区')
|
||||
# move_out = picking_id.move_ids
|
||||
move_out = workorder.move_subcontract_workorder_ids[1]
|
||||
for mo in move_out:
|
||||
if mo.state != 'done':
|
||||
@@ -1342,6 +1260,13 @@ 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'
|
||||
@@ -1354,10 +1279,6 @@ class ResMrpWorkOrder(models.Model):
|
||||
if purchase_orders_id.state == 'purchase':
|
||||
workorder.state = 'ready'
|
||||
move_out = workorder.move_subcontract_workorder_ids[1]
|
||||
# picking_id = workorder.production_id.picking_ids.filtered(
|
||||
# lambda
|
||||
# wk: wk.location_id.name == '制造前' and wk.location_dest_id.name == '外协加工区')
|
||||
# move_out = picking_id.move_ids
|
||||
for mo in move_out:
|
||||
if mo.state != 'done':
|
||||
mo.write({'state': 'assigned', 'production_id': False})
|
||||
@@ -1366,7 +1287,6 @@ class ResMrpWorkOrder(models.Model):
|
||||
mo.get_move_line(workorder.production_id, workorder))
|
||||
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')
|
||||
@@ -1381,7 +1301,6 @@ class ResMrpWorkOrder(models.Model):
|
||||
for check_id in workorder.check_ids:
|
||||
if not check_id.is_inspect:
|
||||
check_id.quality_state = 'none'
|
||||
|
||||
# 重写工单开始按钮方法
|
||||
def button_start(self):
|
||||
# 判断工单状态是否为等待组件
|
||||
@@ -1398,11 +1317,11 @@ class ResMrpWorkOrder(models.Model):
|
||||
# 判断是否有坯料的序列号信息
|
||||
boolean = False
|
||||
if self.production_id.move_raw_ids:
|
||||
if self.production_id.move_raw_ids[0].product_id.categ_type == '坯料' and \
|
||||
self.production_id.move_raw_ids[0].product_id.tracking == 'serial':
|
||||
if self.production_id.move_raw_ids[0].product_id.categ_type == '坯料':
|
||||
if self.production_id.move_raw_ids[0].move_line_ids:
|
||||
if self.production_id.move_raw_ids[0].move_line_ids[0].lot_id.name:
|
||||
boolean = True
|
||||
if self.production_id.move_raw_ids[0].move_line_ids:
|
||||
if self.production_id.move_raw_ids[0].move_line_ids[0].lot_id.name:
|
||||
boolean = True
|
||||
else:
|
||||
boolean = True
|
||||
if not boolean:
|
||||
@@ -1432,10 +1351,6 @@ class ResMrpWorkOrder(models.Model):
|
||||
if self.routing_type == '表面工艺':
|
||||
if self.is_subcontract is True:
|
||||
move_out = self.move_subcontract_workorder_ids[1]
|
||||
# picking_id = self.production_id.picking_ids.filtered(
|
||||
# lambda wk: wk.location_id.name == '制造前' and wk.location_dest_id.name == '外协加工区')
|
||||
# move_out = picking_id.move_ids
|
||||
# move_out = self.move_subcontract_workorder_ids[1]
|
||||
# move_out = self.env['stock.move'].search(
|
||||
# [('location_id', '=', self.env['stock.location'].search(
|
||||
# [('barcode', 'ilike', 'WH-PREPRODUCTION')]).id),
|
||||
@@ -1601,17 +1516,25 @@ class ResMrpWorkOrder(models.Model):
|
||||
len(done_workorder) == len(
|
||||
record.production_id.workorder_ids.filtered(lambda wo: wo.state != 'cancel'))):
|
||||
is_production_id = True
|
||||
|
||||
if record.routing_type in ['解除装夹']:
|
||||
rfid_code = record.rfid_code
|
||||
work_ids = record.production_id.workorder_ids.filtered(
|
||||
lambda wo: wo.processing_panel == record.processing_panel and wo.state != 'rework')
|
||||
work_ids.write({'rfid_code_old': rfid_code, 'rfid_code': False})
|
||||
self.env['stock.lot'].sudo().search([('rfid', '=', rfid_code)]).write(
|
||||
{'tool_material_status': '可用'})
|
||||
if any(wo.rfid_code for wo in work_ids):
|
||||
raise ValidationError(f'【{record.name}】工单解绑失败,请重新点击完成按钮!!!')
|
||||
logging.info('work_ids.rfid_code:%s' % [wo.rfid_code for wo in work_ids])
|
||||
if record.routing_type in ['解除装夹'] or (
|
||||
record.is_rework is True and record.routing_type in ['装夹预调']):
|
||||
for workorder in record.production_id.workorder_ids:
|
||||
if workorder.processing_panel == record.processing_panel:
|
||||
rfid_code = workorder.rfid_code
|
||||
if record.is_rework is not True:
|
||||
workorder.write({'rfid_code_old': rfid_code, 'rfid_code': False})
|
||||
elif workorder.routing_type != '装夹预调' and workorder.state != 'rework':
|
||||
workorder.write({'rfid_code_old': False, 'rfid_code': False})
|
||||
elif workorder.routing_type == '装夹预调' and workorder.state != 'rework':
|
||||
workorder.write({'rfid_code_old': rfid_code, 'rfid_code': False})
|
||||
self.env['stock.lot'].sudo().search([('rfid', '=', rfid_code)]).write(
|
||||
{'tool_material_status': '可用'})
|
||||
if workorder.rfid_code:
|
||||
raise ValidationError(f'【{workorder.name}】工单解绑失败,请重新点击完成按钮!!!')
|
||||
# workorder.rfid_code_old = rfid_code
|
||||
# workorder.rfid_code = False
|
||||
logging.info('workorder.rfid_code:%s' % workorder.rfid_code)
|
||||
|
||||
if is_production_id is True:
|
||||
logging.info('product_qty:%s' % record.production_id.product_qty)
|
||||
for move_raw_id in record.production_id.move_raw_ids:
|
||||
@@ -1629,8 +1552,7 @@ class ResMrpWorkOrder(models.Model):
|
||||
# 如果工单包含了外协工序,需要预留数量
|
||||
if self.move_raw_ids.move_orig_ids.subcontract_workorder_id:
|
||||
location_id = self.move_raw_ids.location_id
|
||||
quant = self.move_raw_ids.lot_ids.quant_ids.filtered(
|
||||
lambda q: q.location_id.id == location_id.id)
|
||||
quant = self.move_raw_ids.lot_ids.quant_ids.filtered(lambda q: q.location_id.id == location_id.id)
|
||||
if quant.reserved_quantity == 0:
|
||||
self.env['stock.quant']._update_reserved_quantity(
|
||||
self.move_raw_ids.product_id,
|
||||
@@ -1784,8 +1706,7 @@ class ResMrpWorkOrder(models.Model):
|
||||
store=True, string='工序作业')
|
||||
individuation_page_ids = fields.Many2many('sf.work.individuation.page', string='个性化记录',
|
||||
related='routing_work_center_id.individuation_page_ids')
|
||||
individuation_page_list = fields.Char('个性化记录', default='', compute='_compute_individuation_page_ids',
|
||||
store=True)
|
||||
individuation_page_list = fields.Char('个性化记录', default='', compute='_compute_individuation_page_ids', store=True)
|
||||
|
||||
@api.depends('name')
|
||||
def _compute_routing_work_center_id(self):
|
||||
@@ -1806,7 +1727,6 @@ class ResMrpWorkOrder(models.Model):
|
||||
individuation_page_list = [item.code for item in mw.individuation_page_ids]
|
||||
if individuation_page_list:
|
||||
mw.individuation_page_list = list(set(individuation_page_list))
|
||||
|
||||
# =============================================================================================
|
||||
|
||||
is_inspect = fields.Boolean('需送检', compute='_compute_is_inspect', store=True, default=False)
|
||||
@@ -1830,25 +1750,6 @@ class ResMrpWorkOrder(models.Model):
|
||||
self.check_ids.filtered(lambda ch: ch.is_inspect is True and ch.quality_state == 'waiting').write(
|
||||
{'quality_state': 'none'})
|
||||
|
||||
@api.model
|
||||
def read_group(self, domain, fields, groupby, offset=0, limit=None, orderby=False, lazy=True):
|
||||
aggregate_field = 'create_date:max'
|
||||
if aggregate_field not in fields:
|
||||
fields.append(aggregate_field)
|
||||
orderby = "create_date desc"
|
||||
|
||||
return super(ResMrpWorkOrder, self).read_group(
|
||||
domain,
|
||||
fields,
|
||||
groupby,
|
||||
offset=offset,
|
||||
limit=limit,
|
||||
orderby=orderby,
|
||||
lazy=lazy
|
||||
)
|
||||
|
||||
model_id = fields.Char('模型ID', related='production_id.model_id')
|
||||
|
||||
|
||||
class CNCprocessing(models.Model):
|
||||
_name = 'sf.cnc.processing'
|
||||
@@ -2139,7 +2040,6 @@ class WorkPieceDelivery(models.Model):
|
||||
|
||||
def _get_agv_route_type_selection(self):
|
||||
return self.env['sf.agv.task.route'].fields_get(['route_type'])['route_type']['selection']
|
||||
|
||||
type = fields.Selection(selection=_get_agv_route_type_selection, string='类型')
|
||||
delivery_duration = fields.Float('配送时长', compute='_compute_delivery_duration')
|
||||
status = fields.Selection(
|
||||
|
||||
@@ -10,8 +10,8 @@ from odoo.exceptions import ValidationError, UserError
|
||||
from odoo.modules import get_resource_path
|
||||
|
||||
|
||||
# from OCC.Extend.DataExchange import read_step_file
|
||||
# from OCC.Extend.DataExchange import write_stl_file
|
||||
from OCC.Extend.DataExchange import read_step_file
|
||||
from OCC.Extend.DataExchange import write_stl_file
|
||||
|
||||
|
||||
class ResProductMo(models.Model):
|
||||
@@ -51,7 +51,7 @@ class ResProductMo(models.Model):
|
||||
# domain="[('materials_id', '=', materials_id)]")
|
||||
# cutting_tool_model_id.material_model_id
|
||||
server_product_process_parameters_id = fields.Many2one('sf.production.process.parameter',
|
||||
string='工艺参数(服务产品)')
|
||||
string='表面工艺参数(服务产品)')
|
||||
model_process_parameters_ids = fields.Many2many('sf.production.process.parameter', 'process_parameter_rel',
|
||||
string='表面工艺参数')
|
||||
|
||||
@@ -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')
|
||||
@@ -795,12 +795,10 @@ class ResProductMo(models.Model):
|
||||
for record in self:
|
||||
if record.categ_id.name == '坯料':
|
||||
product_name = ''
|
||||
match = re.search(r'(S\d{5}-\d+)', record.name)
|
||||
match = re.search(r'(S\d{5}-\d)', record.name)
|
||||
# 如果匹配成功,提取结果
|
||||
if match:
|
||||
product_name = match.group(0)
|
||||
else:
|
||||
product_name = record.name
|
||||
sale_order_name = ''
|
||||
match_sale = re.search(r'S(\d+)', record.name)
|
||||
if match_sale:
|
||||
@@ -892,9 +890,8 @@ class ResProductMo(models.Model):
|
||||
embryo_redundancy_id = item.get('embryo_redundancy')
|
||||
if not embryo_redundancy_id:
|
||||
raise UserError('请先配置模型类型内的坯料冗余')
|
||||
product_name = self.generate_product_name(order_id, item, i)
|
||||
vals = {
|
||||
'name': product_name,
|
||||
'name': '%s-%s-%s' % ('P', order_id.name, i),
|
||||
'model_long': self.format_float(item['model_long'] + embryo_redundancy_id.long),
|
||||
'model_width': self.format_float(item['model_width'] + embryo_redundancy_id.width),
|
||||
'model_height': self.format_float(item['model_height'] + embryo_redundancy_id.height),
|
||||
@@ -1015,9 +1012,12 @@ class ResProductMo(models.Model):
|
||||
if not embryo_redundancy_id:
|
||||
raise UserError('请先配置模型类型内的坯料冗余')
|
||||
logging.info('no_bom_copy_product_supplier-vals:%s' % supplier)
|
||||
embryo_name = self.generate_embryo_name(order_id, item, materials_id, materials_type_id, embryo_redundancy_id, i)
|
||||
vals = {
|
||||
'name': embryo_name,
|
||||
'name': '%s-%s-%s [%s %s-%s * %s * %s]' % ('R',
|
||||
order_id.name, i, materials_id.name, materials_type_id.name,
|
||||
self.format_float(item['model_long'] + embryo_redundancy_id.long),
|
||||
self.format_float(item['model_width'] + embryo_redundancy_id.width),
|
||||
self.format_float(item['model_height'] + embryo_redundancy_id.height)),
|
||||
'length': self.format_float(item['model_long'] + embryo_redundancy_id.long),
|
||||
'width': self.format_float(item['model_width'] + embryo_redundancy_id.width),
|
||||
'height': self.format_float(item['model_height'] + embryo_redundancy_id.height),
|
||||
@@ -1030,7 +1030,6 @@ class ResProductMo(models.Model):
|
||||
'single_manufacturing': product_id.single_manufacturing,
|
||||
'is_bfm': True,
|
||||
'active': True,
|
||||
'tracking': finish_product.tracking, # 坯料的跟踪方式跟随成品
|
||||
}
|
||||
# 外协和采购生成的坯料需要根据材料型号绑定供应商
|
||||
if route_type == 'subcontract' or route_type == 'purchase':
|
||||
@@ -1068,8 +1067,7 @@ class ResProductMo(models.Model):
|
||||
raise UserError('产品名称【%s】已存在' % item.name)
|
||||
if item.categ_type == '表面工艺':
|
||||
if len(self.search([('server_product_process_parameters_id', '=',
|
||||
item.server_product_process_parameters_id.id),('server_product_process_parameters_id', '!=',
|
||||
False)])) > 1:
|
||||
item.server_product_process_parameters_id.id)])) > 1:
|
||||
raise UserError('表面工艺参数为【%s】的产品已存在' % item.server_product_process_parameters_id.name)
|
||||
if "create_product_product" not in self._context:
|
||||
templates._create_variant_ids()
|
||||
@@ -1119,19 +1117,7 @@ class ResProductMo(models.Model):
|
||||
|
||||
# 增加产品表面积
|
||||
|
||||
def generate_product_name(self, order_id, item, i):
|
||||
"""生成成品名称"""
|
||||
product_name = '%s-%s-%s' % ('P', order_id.name, i)
|
||||
return product_name
|
||||
|
||||
def generate_embryo_name(self, order_id, item, materials_id, materials_type_id, embryo_redundancy_id, i):
|
||||
"""生成坯料名称"""
|
||||
embryo_name = '%s-%s-%s [%s %s-%s * %s * %s]' % ('R',
|
||||
order_id.name, i, materials_id.name, materials_type_id.name,
|
||||
self.format_float(item['model_long'] + embryo_redundancy_id.long),
|
||||
self.format_float(item['model_width'] + embryo_redundancy_id.width),
|
||||
self.format_float(item['model_height'] + embryo_redundancy_id.height))
|
||||
return embryo_name
|
||||
|
||||
class ResProductFixture(models.Model):
|
||||
_inherit = 'product.template'
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user