diff --git a/sf_demand_plan/__manifest__.py b/sf_demand_plan/__manifest__.py
index 663dba80..8a913e0b 100644
--- a/sf_demand_plan/__manifest__.py
+++ b/sf_demand_plan/__manifest__.py
@@ -13,8 +13,10 @@
'depends': ['sf_plan','jikimo_printing'],
'data': [
'security/ir.model.access.csv',
+ 'data/stock_route_group.xml',
'views/demand_plan_info.xml',
'views/demand_plan.xml',
+ 'views/stock_route.xml',
'views/sale_order_views.xml',
'wizard/sf_demand_plan_print_wizard_view.xml',
],
diff --git a/sf_demand_plan/data/stock_route_group.xml b/sf_demand_plan/data/stock_route_group.xml
new file mode 100644
index 00000000..1b4a0b84
--- /dev/null
+++ b/sf_demand_plan/data/stock_route_group.xml
@@ -0,0 +1,21 @@
+
+
+
+
+ 自动化产线加工
+ automation
+
+
+ 人工线下加工
+ manual
+
+
+ 外购
+ purchase
+
+
+ 委外加工
+ outsourcing
+
+
+
\ No newline at end of file
diff --git a/sf_demand_plan/models/__init__.py b/sf_demand_plan/models/__init__.py
index 544214d3..2952477c 100644
--- a/sf_demand_plan/models/__init__.py
+++ b/sf_demand_plan/models/__init__.py
@@ -3,3 +3,4 @@
from . import sf_demand_plan
from . import sf_production_demand_plan
from . import sale_order
+from . import stock_route
diff --git a/sf_demand_plan/models/sf_production_demand_plan.py b/sf_demand_plan/models/sf_production_demand_plan.py
index 99b1d1ef..118494fc 100644
--- a/sf_demand_plan/models/sf_production_demand_plan.py
+++ b/sf_demand_plan/models/sf_production_demand_plan.py
@@ -5,6 +5,7 @@ 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):
@@ -85,6 +86,9 @@ class SfProductionDemandPlan(models.Model):
string='订单状态',
related='sale_order_line_id.state')
route_id = fields.Many2one('stock.route', string='路线', related='sale_order_line_id.route_id', store=True)
+ route_ids = fields.Many2many('stock.route', 'stock_route_demand_plan', 'demand_plan_id', 'route_id', '路线',
+ domain=[('demand_plan_selectable', '=', True)], compute='_compute_route_ids',
+ 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)
@@ -142,6 +146,18 @@ class SfProductionDemandPlan(models.Model):
blank_arrival_date = fields.Date('采购计划到货(坯料)')
finished_product_arrival_date = fields.Date('采购计划到货(成品)')
+ @api.depends('supply_method')
+ def _compute_route_ids(self):
+ for pdp in self:
+ if pdp.supply_method:
+ group_id = self.env['stock.route.group'].sudo().search([('code', '=', pdp.supply_method)])
+ route_ids = self.env['stock.route'].sudo().search(
+ [('demand_plan_selectable', '=', True), ('stock_route_group_ids', '=', group_id.id)])
+ if route_ids:
+ pdp.route_ids = route_ids.ids
+ break
+ pdp.route_ids = None
+
@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):
diff --git a/sf_demand_plan/models/stock_route.py b/sf_demand_plan/models/stock_route.py
new file mode 100644
index 00000000..20e4b3c9
--- /dev/null
+++ b/sf_demand_plan/models/stock_route.py
@@ -0,0 +1,49 @@
+from odoo import models, fields, api, _
+
+
+class SfStockRoute(models.Model):
+ _inherit = 'stock.route'
+
+ demand_plan_selectable = fields.Boolean("需求计划行")
+ stock_route_group_ids = fields.Many2many('stock.route.group', 'route_to_group', string='路线组')
+ demand_plan_ids = fields.Many2many('sf.production.demand.plan', 'stock_route_demand_plan', 'route_id',
+ 'demand_plan_id', '需求计划', copy=False, compute='_compute_demand_plan_ids',
+ store=True)
+
+ @api.depends('demand_plan_selectable', 'stock_route_group_ids')
+ def _compute_demand_plan_ids(self):
+ for sr in self:
+ if sr.demand_plan_selectable:
+ stock_route_group = [srg.code for srg in sr.stock_route_group_ids]
+ demand_plan_ids = self.env['sf.production.demand.plan'].sudo().search(
+ [('supply_method', 'in', stock_route_group)])
+ if demand_plan_ids:
+ sr.demand_plan_ids = demand_plan_ids.ids
+ break
+ sr.demand_plan_ids = None
+
+ # def name_get(self):
+ # res = super().name_get()
+ # if self.env.context.get('demand_plan_search_stock_route_id'):
+ # demand_plan_id = self.env['sf.production.demand.plan'].sudo().browse(
+ # int(self.env.context.get('demand_plan_search_stock_route_id')))
+ # if demand_plan_id and demand_plan_id.supply_method:
+ # supply_method = self._set_supply_method(demand_plan_id.supply_method)
+ # res = [(item[0], f'{item[1]}-{supply_method}') for item in res if len(item) == 2]
+ # return res
+ #
+ # def _set_supply_method(self, supply_method):
+ # return {
+ # 'automation': "自动化产线加工",
+ # 'manual': "人工线下加工",
+ # 'purchase': "外购",
+ # 'outsourcing': "委外加工"
+ # }.get(supply_method)
+
+
+class SfStockRouteGroup(models.Model):
+ _name = 'stock.route.group'
+ _description = '路线组'
+
+ name = fields.Char('名称')
+ code = fields.Char('编码')
diff --git a/sf_demand_plan/security/ir.model.access.csv b/sf_demand_plan/security/ir.model.access.csv
index b588c8b6..5a35ba20 100644
--- a/sf_demand_plan/security/ir.model.access.csv
+++ b/sf_demand_plan/security/ir.model.access.csv
@@ -8,3 +8,6 @@ access_sf_demand_plan_print_wizard_for_dispatch,sf.demand.plan.print.wizard for
access_sf_demand_plan,sf.demand.plan,model_sf_demand_plan,base.group_user,1,0,0,0
access_sf_demand_plan_for_dispatch,sf.demand.plan for dispatch,model_sf_demand_plan,sf_base.group_plan_dispatch,1,1,0,0
+
+access_stock_route_group,stock.route.group,model_stock_route_group,base.group_user,1,0,0,0
+access_stock_route_group_dispatch,stock.route.group.dispatch,model_stock_route_group,sf_base.group_plan_dispatch,1,1,0,0
diff --git a/sf_demand_plan/views/demand_plan.xml b/sf_demand_plan/views/demand_plan.xml
index 8dff8149..4c63fb8e 100644
--- a/sf_demand_plan/views/demand_plan.xml
+++ b/sf_demand_plan/views/demand_plan.xml
@@ -28,7 +28,7 @@
-
+
@@ -38,7 +38,8 @@
-
+
diff --git a/sf_demand_plan/views/stock_route.xml b/sf_demand_plan/views/stock_route.xml
new file mode 100644
index 00000000..c4581acc
--- /dev/null
+++ b/sf_demand_plan/views/stock_route.xml
@@ -0,0 +1,21 @@
+
+
+
+ stock.route.form
+ stock.route
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/sf_machine_connect/controllers/controllers.py b/sf_machine_connect/controllers/controllers.py
index ba8ac697..96461902 100644
--- a/sf_machine_connect/controllers/controllers.py
+++ b/sf_machine_connect/controllers/controllers.py
@@ -639,6 +639,15 @@ class Sf_Dashboard_Connect(http.Controller):
if time_unit == 'hour':
+
+ # 计划量，目前只能从mail.message中筛选出
+ plan_order_messages = request.env['mail.message'].sudo().search([
+ ('model', '=', 'mrp.workorder'),
+ ('create_date', '>=', begin_time.strftime('%Y-%m-%d %H:%M:%S')),
+ ('create_date', '<=', end_time.strftime('%Y-%m-%d %H:%M:%S')),
+ ('tracking_value_ids.field_desc', '=', '状态'),
+ ('tracking_value_ids.new_value_char', '=', '就绪')
+ ])
for line in line_list:
date_field_name = 'date_finished' # 替换为你模型中的实际字段名
@@ -685,15 +694,6 @@ class Sf_Dashboard_Connect(http.Controller):
# time_count_dict[key] = len(orders)
time_count_dict[key] = sum(interval_orders.mapped('qty_produced'))
- # 计划量，目前只能从mail.message中筛选出
- plan_order_messages = request.env['mail.message'].sudo().search([
- ('model', '=', 'mrp.workorder'),
- ('create_date', '>=', begin_time.strftime('%Y-%m-%d %H:%M:%S')),
- ('create_date', '<=', end_time.strftime('%Y-%m-%d %H:%M:%S')),
- ('tracking_value_ids.field_desc', '=', '状态'),
- ('tracking_value_ids.new_value_char', '=', '就绪')
- ])
-
for time_interval in time_intervals:
start_time, end_time = time_interval
@@ -707,9 +707,11 @@ class Sf_Dashboard_Connect(http.Controller):
interval_plan_orders = plan_order_messages.filtered(
lambda o: o.create_date >= start_time
and o.create_date <= end_time
- )
+ )
- interval_orders = request.env['mrp.workorder'].sudo().browse(interval_plan_orders.mapped('res_id'))
+ interval_order_ids = set(interval_plan_orders.mapped('res_id'))
+
+ interval_orders = request.env['mrp.workorder'].sudo().browse(interval_order_ids)
if line == '业绩总览':
interval_orders = interval_orders.filtered(lambda o: o.routing_type in ['人工线下加工', 'CNC加工'])
elif line == '人工线下加工中心':
@@ -862,21 +864,37 @@ class Sf_Dashboard_Connect(http.Controller):
"""
# res = {'status': 1, 'message': '成功', 'not_done_data': [], 'done_data': []}
res = {'status': 1, 'message': '成功', 'data': {}}
+ # 解决产品名称取到英文的问题
+ request.update_context(lang='zh_CN')
plan_obj = request.env['sf.production.plan'].sudo()
work_order_obj = request.env['mrp.workorder'].sudo()
+ # 获取mrp.workorder的state字段的selection内容
+ state_dict = dict(request.env['mrp.workorder'].sudo()._fields['state'].selection)
line_list = ast.literal_eval(kw['line_list'])
begin_time_str = kw['begin_time'].strip('"')
end_time_str = kw['end_time'].strip('"')
begin_time = datetime.strptime(begin_time_str, '%Y-%m-%d %H:%M:%S')
end_time = datetime.strptime(end_time_str, '%Y-%m-%d %H:%M:%S')
# print('line_list: %s' % line_list)
- not_done_data = []
- done_data = []
final_data = {}
- not_done_index = 1
- done_index = 1
+
+ # 获取当前时间，并计算24小时前的时间
+ current_time = datetime.now()
+ time_48_hours_ago = current_time - timedelta(hours=48)
+
+ # # 计划量，目前只能从mail.message中筛选出
+ # plan_order_messages = request.env['mail.message'].sudo().search([
+ # ('model', '=', 'mrp.workorder'),
+ # ('create_date', '>=', time_48_hours_ago.strftime('%Y-%m-%d %H:%M:%S')),
+ # ('tracking_value_ids.field_desc', '=', '状态'),
+ # ('tracking_value_ids.new_value_char', 'in', ['就绪', '生产中'])
+ # ])
for line in line_list:
+ not_done_data = []
+ done_data = []
+ not_done_index = 1
+ done_index = 1
if line == '业绩总览':
work_order_domain = [('routing_type', 'in', ['人工线下加工', 'CNC加工'])]
@@ -892,21 +910,24 @@ class Sf_Dashboard_Connect(http.Controller):
# [('production_line_id.name', '=', line), ('state', 'not in', ['finished']),
# ('production_id.state', 'not in', ['cancel', 'done']), ('active', '=', True)
# ])
- not_done_orders = work_order_obj.search(work_order_domain +
- [('state', 'in', ['ready', 'progress'])], order='id asc'
+ not_done_orders = work_order_obj.search(work_order_domain + [
+ ('state', 'in', ['ready', 'progress']),
+ ('date_planned_start', '>=', time_48_hours_ago),
+ ('date_planned_start', '<=', current_time)
+ ], order='id asc'
)
# 完成订单
# 获取当前时间，并计算24小时前的时间
- current_time = datetime.now()
- time_24_hours_ago = current_time - timedelta(hours=24)
+ # current_time = datetime.now()
+ # time_24_hours_ago = current_time - timedelta(hours=24)
finish_orders = work_order_obj.search(work_order_domain + [
- ('state', 'in', ['finished']),
+ ('state', 'in', ['done']),
('production_id.state', 'not in', ['cancel']),
- ('date_finished', '>=', time_24_hours_ago)
+ ('date_finished', '>=', time_48_hours_ago)
], order='id asc')
- # print(finish_orders)
+ # logging.info('完成订单: %s' % finish_orders)
# 获取所有未完成订单的ID列表
order_ids = [order.id for order in not_done_orders]
@@ -942,14 +963,6 @@ class Sf_Dashboard_Connect(http.Controller):
material_match = re.search(material_pattern, blank_name)
material = material_match.group(1) if material_match else 'No match found'
- state_dict = {
- 'draft': '待排程',
- 'done': '已排程',
- 'processing': '生产中',
- 'finished': '已完成',
- 'ready': '待加工',
- 'progress': '生产中',
- }
line_dict = {
'sequence': not_done_index,
@@ -965,8 +978,6 @@ class Sf_Dashboard_Connect(http.Controller):
not_done_index += 1
for finish_order in finish_orders:
- if not finish_order.actual_end_time:
- continue
blank_name = ''
try:
blank_name = finish_order.production_id.move_raw_ids[0].product_id.name
@@ -982,13 +993,13 @@ class Sf_Dashboard_Connect(http.Controller):
line_dict = {
'sequence': done_index,
- 'workorder_name': finish_order.name,
+ 'workorder_name': finish_order.production_id.name,
'blank_name': blank_name,
'material': material,
'dimensions': dimensions,
- 'order_qty': order.qty_produced,
- 'finish_time': finish_order.actual_end_time.strftime(
- '%Y-%m-%d %H:%M:%S') if finish_order.actual_end_time else ' '
+ 'order_qty': finish_order.qty_produced,
+ 'finish_time': finish_order.date_finished.strftime(
+ '%Y-%m-%d %H:%M:%S') if finish_order.date_finished else ' '
}
done_data.append(line_dict)
diff --git a/sf_mrs_connect/models/mrp_production.py b/sf_mrs_connect/models/mrp_production.py
index ac3f6640..fe2682de 100644
--- a/sf_mrs_connect/models/mrp_production.py
+++ b/sf_mrs_connect/models/mrp_production.py
@@ -13,6 +13,8 @@ class MrpProduction(models.Model):
生成编程单
"""
productions = super().create(vals_list)
+ if not productions:
+ return self.browse()
# 定义变量存储编程单
grouped_product_programming_no = {}
# 定义产品拼接成的制造订单名称
diff --git a/sf_quality/models/stock.py b/sf_quality/models/stock.py
index add80f8a..3de28c7c 100644
--- a/sf_quality/models/stock.py
+++ b/sf_quality/models/stock.py
@@ -1,11 +1,41 @@
+import logging
+
from odoo import api, models
+from odoo.exceptions import ValidationError, UserError
class StockPicking(models.Model):
_inherit = 'stock.picking'
+ def _compute_check(self):
+ super()._compute_check()
+ for picking in self:
+ picking_to_quality = picking.get_picking_to_quality()
+ if not picking_to_quality:
+ picking.quality_check_todo = False
+ break
+ else:
+ need_quality_line = picking.get_need_quality_line(picking_to_quality)
+ if not need_quality_line or all(not line.get('need_done_check_ids') for line in need_quality_line):
+ picking.quality_check_todo = False
+
+ def check_quality(self):
+ self.ensure_one()
+ # checkable_products = self.mapped('move_line_ids').mapped('product_id')
+ # checks = self.check_ids.filtered(lambda check: check.quality_state == 'none' and (
+ # check.product_id in checkable_products or check.measure_on == 'operation'))
+ checks = self.env['quality.check']
+ picking_to_quality = self._get_picking_to_quality()
+ need_quality_line = self.get_need_quality_line(picking_to_quality)
+ if need_quality_line and any(line.get('need_done_check_ids') for line in need_quality_line):
+ for item in need_quality_line:
+ checks += item.get('need_done_check_ids')
+ if checks:
+ return checks.action_open_quality_check_wizard()
+ return False
+
def button_validate(self):
- """
+ """=
出厂检验报告上传
"""
@@ -17,43 +47,133 @@ class StockPicking(models.Model):
if not out_quality_check.is_factory_report_uploaded:
if out_quality_check and self.state == 'assigned':
out_quality_check.upload_factory_report()
+ quality_action = self.pinking_checkout_quality()
+ if quality_action:
+ return quality_action
+ res = super(StockPicking, self).button_validate()
+ return res
+ def pinking_checkout_quality(self):
"""
调拨单若关联了质量检查单，验证调拨单时，应校验是否有不合格品，若存在，应弹窗提示：
“警告：存在不合格产品XXXX n 件、YYYYY m件，继续调拨请点“确认”，否则请取消？”
"""
- context = self.env.context
- if not context.get('again_validate') and self.quality_check_ids.filtered(lambda qc: qc.quality_state == 'fail'):
- # 回滚事务，为二次确认/取消做准备
- self.env.cr.rollback()
- quality_check_ids = self.quality_check_ids.filtered(lambda qc: qc.quality_state == 'fail')
- product_list = list(set([quality_check_id.product_id for quality_check_id in quality_check_ids]))
- fail_check_text = ''
- for product_id in product_list:
- check_ids = quality_check_ids.filtered(lambda qc: qc.product_id == product_id)
- if all(check_id.measure_on == 'move_line' for check_id in check_ids):
- number = sum(check_ids.mapped('qty_line'))
- else:
- number = sum(self.move_ids_without_package.filtered(
- lambda ml: ml.product_id == product_id).mapped('quantity_done'))
- if number == 0:
- number = sum(self.move_ids_without_package.filtered(
- lambda ml: ml.product_id == product_id).mapped('reserved_availability'))
- if number == 0:
- number = sum(self.move_ids_without_package.filtered(
- lambda ml: ml.product_id == product_id).mapped('product_uom_qty'))
- fail_check_text = (f'{fail_check_text}、{product_id.display_name} {number}件'
- if fail_check_text != '' else f'{product_id.display_name} {number}件')
- return {
- 'type': 'ir.actions.act_window',
- 'res_model': 'picking.validate.check.wizard',
- 'name': '质检不合格提示',
- 'view_mode': 'form',
- 'target': 'new',
- 'context': {
- 'default_picking_id': self.id,
- 'default_fail_check_text': f'警告：存在不合格产品{fail_check_text}，继续调拨请点“确认”，否则请取消？',
- 'again_validate': True}
- }
- res = super(StockPicking, self).button_validate()
+ try:
+ self.ensure_one()
+ context = self.env.context
+ if not context.get('pinking_checkout_quality'):
+ picking_to_quality = self._get_picking_to_quality()
+ if not picking_to_quality: return False
+ need_quality_val = self.get_need_quality_line(picking_to_quality)
+ if any(line.get('fail_check_ids') for line in need_quality_val):
+ # 回滚事务，为二次确认/取消做准备
+ self.env.cr.rollback()
+ # 获取存在失败的 质检单 调拨单明细行
+ check_list = [item for item in need_quality_val if item.get('fail_check_ids')]
+ fail_check_text = ''
+ for item in check_list:
+ move_id, pre_done_qty = item.get('move_id'), item.get('pre_done_qty')
+ fail_check_text = (f'{fail_check_text}、{move_id.product_id.display_name} {pre_done_qty}件'
+ if fail_check_text != '' else f'{move_id.product_id.display_name} {pre_done_qty}件')
+ return {
+ 'type': 'ir.actions.act_window',
+ 'res_model': 'picking.validate.check.wizard',
+ 'name': '质检不合格提示',
+ 'view_mode': 'form',
+ 'target': 'new',
+ 'context': {
+ 'default_picking_id': self.id,
+ 'default_fail_check_text': f'警告：存在不合格产品{fail_check_text}，继续调拨请点“确认”，否则请取消？',
+ 'pinking_checkout_quality': True}
+ }
+ else:
+ return False
+ except Exception as e:
+ logging.info('pinking_checkout_quality()方法报错：%s' % e)
+ raise ValidationError('调拨单验证质检单是否合格时报错,请联系管理员处理！！')
+
+ def get_need_quality_line(self, picking_to_quality):
+ """
+ # 对需要进行质检，还没有质检完成的明细行进行统计
+ # 1、当【质量标准_控制方式】=“产品、作业”，仅校验“预完成数量”>0的产品行对应的质检单必须处理。
+ 2、当【质量标准_控制方式】=“数量”时，仅校验“预完成数量”>0的产品行对应的质检单必须处理：
+ 1）每一类的“总单数”=【调拨单_需求】时，则已处理的质检单“单数”≥“预完成数量”时，可执行调拨单验证；
+ 2）每一类的“总单数”<【调拨单_需求】时，则已处理的质检单“单数”≥0时，可执行调拨单验证；
+ """
+ res = []
+ for item in picking_to_quality:
+ need_done_check_ids = self.env['quality.check']
+ fail_check_ids = self.env['quality.check']
+ move_id, pre_done_qty, check_ids = item.values()
+ check_ids_1 = check_ids.filtered(lambda qc: qc.measure_on in ('operation', 'product'))
+ if check_ids_1:
+ check_ids_1_done = check_ids_1.filtered(lambda qc: qc.quality_state in ('pass', 'fail'))
+ check_ids_1_fail = check_ids_1.filtered(lambda qc: qc.quality_state == 'fail')
+ check_ids_1_none = check_ids_1.filtered(lambda qc: qc.quality_state == 'none')
+ if check_ids_1 and not check_ids_1_done:
+ need_done_check_ids += check_ids_1_none
+ if check_ids_1_fail:
+ fail_check_ids += check_ids_1_fail
+
+ check_ids_2 = check_ids.filtered(lambda qc: qc.measure_on == 'move_line')
+ if check_ids_2:
+ check_ids_2_done = check_ids_2.filtered(lambda qc: qc.quality_state in ('pass', 'fail'))
+ check_ids_2_fail = check_ids_2.filtered(lambda qc: qc.quality_state == 'fail')
+ check_ids_2_none = check_ids_2.filtered(lambda qc: qc.quality_state == 'none')
+ # 每一类的“总单数”=【调拨单_需求】时，则已处理的质检单“单数”≥“预完成数量”时，可执行调拨单验证；
+ if len(check_ids_2) >= move_id.product_uom_qty and len(check_ids_2_done) < pre_done_qty:
+ need_done_check_ids += check_ids_2_none
+ # 每一类的“总单数”<【调拨单_需求】时，则已处理的质检单“单数”≥0时，可执行调拨单验证
+ elif len(check_ids_2) < move_id.product_uom_qty and len(check_ids_2_done) == 0:
+ need_done_check_ids += check_ids_2_none
+ if check_ids_2_fail:
+ fail_check_ids += check_ids_2_fail
+
+ if need_done_check_ids or fail_check_ids:
+ res.append({'move_id': move_id,
+ 'pre_done_qty': pre_done_qty,
+ 'check_ids': check_ids,
+ 'fail_check_ids': fail_check_ids,
+ 'need_done_check_ids': need_done_check_ids})
return res
+
+ def get_picking_to_quality(self):
+ self.ensure_one()
+ return self._get_picking_to_quality()
+
+ def _get_picking_to_quality(self):
+ """
+ 对需要质检的明细行进行统计(针对“预完成数量”>0的行)
+ """
+ quality_piking_line_list = []
+ pre_done_qty_lines = self._get_pinking_pre_done_qty()
+ for line in pre_done_qty_lines:
+ move_id, pre_done_qty = line.values()
+ if pre_done_qty == 0:
+ continue
+ product_id = move_id.product_id
+ check_ids = self.check_ids.filtered(lambda c: c.product_id == product_id)
+ quality_piking_line_list.append({'move_id': move_id, 'pre_done_qty': pre_done_qty, 'check_ids': check_ids})
+ return quality_piking_line_list
+
+ def _get_pinking_pre_done_qty(self):
+ """
+ return: 明细行 及 预完成数量
+ 1、若调拨单所有明细行的【完成】=0，且任意行的【预留】<【需求】，则验证时将会话是否需创建欠单。
+ ---->此时“预完成数量”=【预留】
+ 2、若调拨单任意行的0<【完成】<【需求】，且则验证时将会话是否需创建欠单
+ ---->此时“预完成数量”=【完成】
+ """
+ # if all(move_id.quantity_done == 0 for move_id in self.move_ids_without_package):
+ # pre_done_qty = [{'move_id': move_id, 'pre_done_qty': move_id.reserved_availability} for move_id in
+ # self.move_ids_without_package]
+ # else:
+ # pre_done_qty = [{'move_id': move_id, 'pre_done_qty': move_id.quantity_done} for move_id in
+ # self.move_ids_without_package]
+ pre_done_qty = []
+ for move_id in self.move_ids_without_package:
+ if move_id.quantity_done > 0:
+ pre_done_qty.append({'move_id': move_id, 'pre_done_qty': move_id.quantity_done})
+ else:
+ pre_done_qty.append({'move_id': move_id, 'pre_done_qty': move_id.reserved_availability})
+ return pre_done_qty