jikimo/test
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

将sf_manufacturing模块中stock.py的_run_manufacture方法进行拆分

Browse Source
This commit is contained in:
胡尧
2025-06-18 09:25:44 +08:00
parent 5c7e6e969f
commit 92f591c3e7
6 changed files with 368 additions and 222 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
sf_manufacturing/models/mrp_production.py
View File

@@ -1709,7 +1709,77 @@ class MrpProduction(models.Model):
vals['procurement_group_id'] = product_group_id[product_id.id] vals['procurement_group_id'] = product_group_id[product_id.id]
else: else:
vals['procurement_group_id'] = is_custemer_group_id[key] vals['procurement_group_id'] = is_custemer_group_id[key]
return super(MrpProduction, self).create(vals_list)
productions = super(MrpProduction, self).create(vals_list)
# 查询成品工序排序（自动化产线加工）,供后续使用
product_model_type_routing_sorts = self.env['sf.product.model.type.routing.sort'].search([], order='sequence asc')
# 查询成品工序排序（人工线下加工）,供后续使用
manual_product_model_type_routing_sorts = self.env['sf.manual.product.model.type.routing.sort'].search([], order='sequence asc')
# 查询坯料工序排序，供后续使用
embryo_model_type_routing_sorts = self.env['sf.embryo.model.type.routing.sort'].search([], order='sequence asc')
for production in productions:
# 生成序列号
production.action_generate_serial()
# 创建工序模板
technology_design_values = []
i = 0
if production.product_id.categ_id.type == '成品':
# 根据加工面板的面数及成品工序模板生成工序设计
if production.production_type == '自动化产线加工':
product_routing_workcenter = product_model_type_routing_sorts.filtered(
lambda s: s.product_model_type_id.id == production.product_id.product_model_type_id.id
)
else:
product_routing_workcenter = manual_product_model_type_routing_sorts.filtered(
lambda s: s.manual_product_model_type_id.id == production.product_id.product_model_type_id.id
)
if production.production_type == '自动化产线加工':
for k in (production.product_id.model_processing_panel.split(',')):
for route in product_routing_workcenter:
i += 1
technology_design_values.append(
self.env['sf.technology.design'].json_technology_design_str(k, route, i, False)
)
elif production.production_type == '人工线下加工':
for route in product_routing_workcenter:
i += 1
technology_design_values.append(
self.env['sf.technology.design'].json_technology_design_str('ZM', route, i, False)
)
else:
for route in product_routing_workcenter:
i += 1
technology_design_values.append(
self.env['sf.technology.design'].json_technology_design_str(False, route, i, False)
)
elif production.product_id.categ_id.type == '坯料':
embryo_routing_workcenter = embryo_model_type_routing_sorts.filtered(
lambda s: s.embryo_model_type_id.id == production.product_id.embryo_model_type_id.id
)
for route_embryo in embryo_routing_workcenter:
i += 1
technology_design_values.append(
self.env['sf.technology.design'].json_technology_design_str(False, route_embryo, i, False)
)
# 处理表面工艺
for item in production.product_id.product_model_type_id.surface_technics_routing_tmpl_ids:
if item.route_workcenter_id.surface_technics_id.id:
for process_param in production.product_id.model_process_parameters_ids:
if item.route_workcenter_id.surface_technics_id == process_param.process_id:
technology_design_values.append(
self.env['sf.technology.design'].json_technology_design_str(
False,
item.route_workcenter_id,
i,
process_param
)
)
production.technology_design_ids = technology_design_values
# 设置制造订单状态为待工艺确认
productions.write({'state': 'technology_to_confirmed'})
return productions
@api.depends('procurement_group_id.stock_move_ids.created_purchase_line_id.order_id', @api.depends('procurement_group_id.stock_move_ids.created_purchase_line_id.order_id',
'procurement_group_id.stock_move_ids.move_orig_ids.purchase_line_id.order_id') 'procurement_group_id.stock_move_ids.move_orig_ids.purchase_line_id.order_id')

435
sf_manufacturing/models/stock.py
View File

@@ -95,35 +95,36 @@ class StockRule(models.Model):
precision_rounding=proc[ precision_rounding=proc[
0].product_uom.rounding) > 0) 0].product_uom.rounding) > 0)
list2 = [] list2 = []
for item in procurements: for procurement, rule in procurements:
num = int(item[0].product_qty) num = int(procurement.product_qty)
product = self.env['product.product'].search( warehouse_id = rule.warehouse_id
[("id", '=', item[0].product_id.id)]) if not warehouse_id:
product_tmpl = self.env['product.template'].search( warehouse_id = rule.location_dest_id.warehouse_id
["&", ("id", '=', product.product_tmpl_id.id), ('single_manufacturing', "!=", False)]) manu_rule = rule.route_id.rule_ids.filtered(lambda r: r.action == 'manufacture' and r.warehouse_id == warehouse_id)
if product_tmpl:
if procurement.product_id.product_tmpl_id.single_manufacturing and manu_rule:
if num > 1: if num > 1:
for no in range(1, num + 1): for no in range(1, num + 1):
Procurement = namedtuple('Procurement', ['product_id', 'product_qty', Procurement = namedtuple('Procurement', ['product_id', 'product_qty',
'product_uom', 'location_id', 'name', 'origin', 'product_uom', 'location_id', 'name', 'origin',
'company_id', 'company_id',
'values']) 'values'])
s = Procurement(product_id=item[0].product_id, product_qty=1.0, product_uom=item[0].product_uom, s = Procurement(product_id=procurement.product_id, product_qty=1.0, product_uom=procurement.product_uom,
location_id=item[0].location_id, location_id=procurement.location_id,
name=item[0].name, name=procurement.name,
origin=item[0].origin, origin=procurement.origin,
company_id=item[0].company_id, company_id=procurement.company_id,
values=item[0].values, values=procurement.values,
) )
item1 = list(item) # item1 = list(item)
item1[0] = s # item1[0] = s
list2.append(tuple(item1)) list2.append((s, rule))
else: else:
list2.append(item) list2.append((procurement, rule))
else: else:
list2.append(item) list2.append((procurement, rule))
for procurement, rule in list2: for procurement, rule in list2:
procure_method = rule.procure_method procure_method = rule.procure_method
@@ -162,215 +163,203 @@ class StockRule(models.Model):
[('res_id', '=', res_id), ('res_field', '=', res_field)], limit=1) [('res_id', '=', res_id), ('res_field', '=', res_field)], limit=1)
attachment_info.write({'name': name}) attachment_info.write({'name': name})
@api.model # @api.model
def _run_manufacture(self, procurements): # def _run_manufacture(self, procurements):
productions_values_by_company = defaultdict(list) # productions_values_by_company = defaultdict(list)
errors = [] # errors = []
for procurement, rule in procurements: # for procurement, rule in procurements:
if float_compare(procurement.product_qty, 0, precision_rounding=procurement.product_uom.rounding) <= 0: # if float_compare(procurement.product_qty, 0, precision_rounding=procurement.product_uom.rounding) <= 0:
# If procurement contains negative quantity, don't create a MO that would be for a negative value. # # If procurement contains negative quantity, don't create a MO that would be for a negative value.
continue # continue
bom = rule._get_matching_bom(procurement.product_id, procurement.company_id, procurement.values) # bom = rule._get_matching_bom(procurement.product_id, procurement.company_id, procurement.values)
productions_values_by_company[procurement.company_id.id].append(rule._prepare_mo_vals(*procurement, bom)) # productions_values_by_company[procurement.company_id.id].append(rule._prepare_mo_vals(*procurement, bom))
if errors: # if errors:
raise ProcurementException(errors) # raise ProcurementException(errors)
for company_id, productions_values in productions_values_by_company.items(): # for company_id, productions_values in productions_values_by_company.items():
# create the MO as SUPERUSER because the current user may not have the rights to do it # # create the MO as SUPERUSER because the current user may not have the rights to do it
# (mto product launched by a sale for example) # # (mto product launched by a sale for example)
'''创建制造订单''' # '''创建制造订单'''
productions = self.env['mrp.production'].with_user(SUPERUSER_ID).sudo().with_company(company_id).create( # productions = self.env['mrp.production'].with_user(SUPERUSER_ID).sudo().with_company(company_id).create(
productions_values) # productions_values)
# 将这一批制造订单的采购组根据成品设置为不同的采购组
# product_group_id = {} # '''
# for index, production in enumerate(productions): # 创建工单
# if production.product_id.id not in product_group_id.keys(): # '''
# product_group_id[production.product_id.id] = production.procurement_group_id.id # # productions._create_workorder()
# #
# # self.env['stock.move'].sudo().create(productions._get_moves_finished_values())
# productions.filtered(lambda p: (not p.orderpoint_id and p.move_raw_ids) or \
# (
# p.move_dest_ids.procure_method != 'make_to_order' and not
# p.move_raw_ids and not p.workorder_ids)).action_confirm()
# # 处理 根据制造订单生成的采购单坯料入库时到原材料库，手动将原材料位置该为坯料存货区
# for production in productions:
# if production.picking_ids:
# product_type_id = production.picking_ids[0].move_ids[0].product_id.categ_id
# if product_type_id.name == '坯料':
# location_id = self.env['stock.location'].search([('name', '=', '坯料存货区')])
# if not location_id:
# logging.info(f'没有搜索到【坯料存货区】: {location_id}')
# break
# for picking_id in production.picking_ids:
# if picking_id.picking_type_id.name == '内部调拨':
# if picking_id.location_dest_id.product_type != product_type_id:
# picking_id.location_dest_id = location_id.id
# elif picking_id.picking_type_id.name == '生产发料':
# if picking_id.location_id.product_type != product_type_id:
# picking_id.location_id = location_id.id
# for production in productions:
# '''
# 创建制造订单时生成序列号
# '''
# # production.action_generate_serial()
# origin_production = production.move_dest_ids and production.move_dest_ids[
# 0].raw_material_production_id or False
# orderpoint = production.orderpoint_id
# if orderpoint and orderpoint.create_uid.id == SUPERUSER_ID and orderpoint.trigger == 'manual':
# production.message_post(
# body=_('This production order has been created from Replenishment Report.'),
# message_type='comment',
# subtype_xmlid='mail.mt_note')
# elif orderpoint:
# production.message_post_with_view(
# 'mail.message_origin_link',
# values={'self': production, 'origin': orderpoint},
# subtype_id=self.env.ref('mail.mt_note').id)
# elif origin_production:
# production.message_post_with_view(
# 'mail.message_origin_link',
# values={'self': production, 'origin': origin_production},
# subtype_id=self.env.ref('mail.mt_note').id)
# '''
# 创建生产计划
# '''
# # 工单耗时
# # workorder_duration = 0
# # for workorder in production.workorder_ids:
# # workorder_duration += workorder.duration_expected
# # sale_order = self.env['sale.order'].sudo().search([('name', '=', production.origin)])
# # # 如果订单为空，则获取来源制造订单的销售单
# # if not sale_order:
# # mrp_production = self.env['mrp.production'].sudo().search([('name', '=', production.origin)],
# # limit=1)
# # if mrp_production:
# # sale_order = self.env['sale.order'].sudo().search([('name', '=', mrp_production.origin)])
# # else:
# # mrp_production = production
# # # if sale_order:
# # # sale_order.write({'schedule_status': 'to schedule'})
# # self.env['sf.production.plan'].sudo().with_company(company_id).create({
# # 'name': production.name,
# # 'order_deadline': sale_order.deadline_of_delivery,
# # 'production_id': production.id,
# # 'date_planned_start': production.date_planned_start,
# # 'origin': mrp_production.origin,
# # 'product_qty': production.product_qty,
# # 'product_id': production.product_id.id,
# # 'state': 'draft',
# # })
# all_production = productions
# grouped_product_ids = {k: list(g) for k, g in groupby(all_production, key=lambda x: x.product_id.id)}
# # 初始化一个字典来存储每个product_id对应的生产订单名称列表
# product_id_to_production_names = {}
# # 对于每个product_id，获取其所有生产订单的名称
# for product_id, all_production in grouped_product_ids.items():
# # 为同一个product_id创建一个生产订单名称列表
# product_id_to_production_names[product_id] = [production.name for production in all_production]
# for production_item in productions:
# technology_design_values = []
# # production_programming = self.env['mrp.production'].search(
# # [('product_id.id', '=', production_item.product_id.id),
# # ('origin', '=', production_item.origin)],
# # limit=1, order='id asc')
# # if production_item.product_id.id in product_id_to_production_names:
# # # 同一个产品多个制造订单对应一个编程单和模型库
# # # 只调用一次fetchCNC，并将所有生产订单的名称作为字符串传递
# # if not production_item.programming_no and production_item.production_type in ['自动化产线加工',
# # '人工线下加工']:
# # if not production_programming.programming_no:
# # production_item.fetchCNC(
# # ', '.join(product_id_to_production_names[production_item.product_id.id]))
# # else:
# # production_item.write({'programming_no': production_programming.programming_no,
# # 'programming_state': '编程中'})
# i = 0
# if production_item.product_id.categ_id.type == '成品':
# # 根据加工面板的面数及成品工序模板生成工序设计
# if production_item.production_type == '自动化产线加工':
# model = 'sf.product.model.type.routing.sort'
# domain = [
# ('product_model_type_id', '=', production_item.product_id.product_model_type_id.id)]
# else: # else:
# productions_values[index].update({'name': production.name}) # model = 'sf.manual.product.model.type.routing.sort'
# procurement_group_vals = production._prepare_procurement_group_vals(productions_values[index]) # domain = [('manual_product_model_type_id', '=',
# production.procurement_group_id = self.env["procurement.group"].create(procurement_group_vals).id # production_item.product_id.product_model_type_id.id)]
# product_routing_workcenter = self.env[model].search(domain, order='sequence asc')
# self.env['stock.move'].sudo().create(productions._get_moves_raw_values()) # if production_item.production_type == '自动化产线加工':
# self.env['stock.move'].sudo().create(productions._get_moves_finished_values()) # for k in (production_item.product_id.model_processing_panel.split(',')):
# for route in product_routing_workcenter:
''' # i += 1
创建工单 # technology_design_values.append(
''' # self.env['sf.technology.design'].json_technology_design_str(k, route, i, False))
# productions._create_workorder() # elif production_item.production_type == '人工线下加工':
# # for route in product_routing_workcenter:
# self.env['stock.move'].sudo().create(productions._get_moves_finished_values()) # i += 1
productions.filtered(lambda p: (not p.orderpoint_id and p.move_raw_ids) or \ # technology_design_values.append(
( # self.env['sf.technology.design'].json_technology_design_str('ZM', route, i, False))
p.move_dest_ids.procure_method != 'make_to_order' and not # else:
p.move_raw_ids and not p.workorder_ids)).action_confirm() # for route in product_routing_workcenter:
# 处理 根据制造订单生成的采购单坯料入库时到原材料库，手动将原材料位置该为坯料存货区 # i += 1
for production in productions: # technology_design_values.append(
if production.picking_ids: # self.env['sf.technology.design'].json_technology_design_str(False, route, i, False))
product_type_id = production.picking_ids[0].move_ids[0].product_id.categ_id # elif production_item.product_id.categ_id.type == '坯料':
if product_type_id.name == '坯料': # embryo_routing_workcenter = self.env['sf.embryo.model.type.routing.sort'].search(
location_id = self.env['stock.location'].search([('name', '=', '坯料存货区')]) # [('embryo_model_type_id', '=', production_item.product_id.embryo_model_type_id.id)],
if not location_id: # order='sequence asc'
logging.info(f'没有搜索到【坯料存货区】: {location_id}') # )
break # for route_embryo in embryo_routing_workcenter:
for picking_id in production.picking_ids: # i += 1
if picking_id.picking_type_id.name == '内部调拨': # technology_design_values.append(
if picking_id.location_dest_id.product_type != product_type_id: # self.env['sf.technology.design'].json_technology_design_str(False, route_embryo, i,
picking_id.location_dest_id = location_id.id # False))
elif picking_id.picking_type_id.name == '生产发料': # surface_technics_arr = []
if picking_id.location_id.product_type != product_type_id: # route_workcenter_arr = []
picking_id.location_id = location_id.id # for item in production_item.product_id.product_model_type_id.surface_technics_routing_tmpl_ids:
# if item.route_workcenter_id.surface_technics_id.id:
for production in productions: # for process_param in production_item.product_id.model_process_parameters_ids:
''' # if item.route_workcenter_id.surface_technics_id == process_param.process_id:
创建制造订单时生成序列号 # surface_technics_arr.append(
''' # item.route_workcenter_id.surface_technics_id.id)
production.action_generate_serial() # route_workcenter_arr.append(item.route_workcenter_id.id)
origin_production = production.move_dest_ids and production.move_dest_ids[ # if surface_technics_arr:
0].raw_material_production_id or False # production_process = self.env['sf.production.process'].search(
orderpoint = production.orderpoint_id # [('id', 'in', surface_technics_arr)],
if orderpoint and orderpoint.create_uid.id == SUPERUSER_ID and orderpoint.trigger == 'manual': # order='sequence asc'
production.message_post( # )
body=_('This production order has been created from Replenishment Report.'), # for p in production_process:
message_type='comment', # logging.info('production_process:%s' % p.name)
subtype_xmlid='mail.mt_note') # process_parameters = production_item.product_id.model_process_parameters_ids.filtered(
elif orderpoint: # lambda pm: pm.process_id.id == p.id)
production.message_post_with_view( # for process_parameter in process_parameters:
'mail.message_origin_link', # i += 1
values={'self': production, 'origin': orderpoint}, # route_production_process = self.env[
subtype_id=self.env.ref('mail.mt_note').id) # 'mrp.routing.workcenter'].search(
elif origin_production: # [('surface_technics_id', '=', p.id),
production.message_post_with_view( # ('id', 'in', route_workcenter_arr)])
'mail.message_origin_link', # technology_design_values.append(
values={'self': production, 'origin': origin_production}, # self.env['sf.technology.design'].json_technology_design_str(False,
subtype_id=self.env.ref('mail.mt_note').id) # route_production_process,
# i,
''' # process_parameter))
创建生产计划 # production_item.technology_design_ids = technology_design_values
''' # productions.write({'state': 'technology_to_confirmed'})
# 工单耗时 # return True
workorder_duration = 0
for workorder in production.workorder_ids:
workorder_duration += workorder.duration_expected
sale_order = self.env['sale.order'].sudo().search([('name', '=', production.origin)])
# 如果订单为空，则获取来源制造订单的销售单
if not sale_order:
mrp_production = self.env['mrp.production'].sudo().search([('name', '=', production.origin)],
limit=1)
if mrp_production:
sale_order = self.env['sale.order'].sudo().search([('name', '=', mrp_production.origin)])
else:
mrp_production = production
# if sale_order:
# sale_order.write({'schedule_status': 'to schedule'})
self.env['sf.production.plan'].sudo().with_company(company_id).create({
'name': production.name,
'order_deadline': sale_order.deadline_of_delivery,
'production_id': production.id,
'date_planned_start': production.date_planned_start,
'origin': mrp_production.origin,
'product_qty': production.product_qty,
'product_id': production.product_id.id,
'state': 'draft',
})
all_production = productions
grouped_product_ids = {k: list(g) for k, g in groupby(all_production, key=lambda x: x.product_id.id)}
# 初始化一个字典来存储每个product_id对应的生产订单名称列表
product_id_to_production_names = {}
# 对于每个product_id，获取其所有生产订单的名称
for product_id, all_production in grouped_product_ids.items():
# 为同一个product_id创建一个生产订单名称列表
product_id_to_production_names[product_id] = [production.name for production in all_production]
for production_item in productions:
technology_design_values = []
production_programming = self.env['mrp.production'].search(
[('product_id.id', '=', production_item.product_id.id),
('origin', '=', production_item.origin)],
limit=1, order='id asc')
if production_item.product_id.id in product_id_to_production_names:
# 同一个产品多个制造订单对应一个编程单和模型库
# 只调用一次fetchCNC，并将所有生产订单的名称作为字符串传递
if not production_item.programming_no and production_item.production_type in ['自动化产线加工',
'人工线下加工']:
if not production_programming.programming_no:
production_item.fetchCNC(
', '.join(product_id_to_production_names[production_item.product_id.id]))
else:
production_item.write({'programming_no': production_programming.programming_no,
'programming_state': '编程中'})
i = 0
if production_item.product_id.categ_id.type == '成品':
# 根据加工面板的面数及成品工序模板生成工序设计
if production_item.production_type == '自动化产线加工':
model = 'sf.product.model.type.routing.sort'
domain = [
('product_model_type_id', '=', production_item.product_id.product_model_type_id.id)]
else:
model = 'sf.manual.product.model.type.routing.sort'
domain = [('manual_product_model_type_id', '=',
production_item.product_id.product_model_type_id.id)]
product_routing_workcenter = self.env[model].search(domain, order='sequence asc')
if production_item.production_type == '自动化产线加工':
for k in (production_item.product_id.model_processing_panel.split(',')):
for route in product_routing_workcenter:
i += 1
technology_design_values.append(
self.env['sf.technology.design'].json_technology_design_str(k, route, i, False))
elif production_item.production_type == '人工线下加工':
for route in product_routing_workcenter:
i += 1
technology_design_values.append(
self.env['sf.technology.design'].json_technology_design_str('ZM', route, i, False))
else:
for route in product_routing_workcenter:
i += 1
technology_design_values.append(
self.env['sf.technology.design'].json_technology_design_str(False, route, i, False))
elif production_item.product_id.categ_id.type == '坯料':
embryo_routing_workcenter = self.env['sf.embryo.model.type.routing.sort'].search(
[('embryo_model_type_id', '=', production_item.product_id.embryo_model_type_id.id)],
order='sequence asc'
)
for route_embryo in embryo_routing_workcenter:
i += 1
technology_design_values.append(
self.env['sf.technology.design'].json_technology_design_str(False, route_embryo, i,
False))
surface_technics_arr = []
route_workcenter_arr = []
for item in production_item.product_id.product_model_type_id.surface_technics_routing_tmpl_ids:
if item.route_workcenter_id.surface_technics_id.id:
for process_param in production_item.product_id.model_process_parameters_ids:
if item.route_workcenter_id.surface_technics_id == process_param.process_id:
surface_technics_arr.append(
item.route_workcenter_id.surface_technics_id.id)
route_workcenter_arr.append(item.route_workcenter_id.id)
if surface_technics_arr:
production_process = self.env['sf.production.process'].search(
[('id', 'in', surface_technics_arr)],
order='sequence asc'
)
for p in production_process:
logging.info('production_process:%s' % p.name)
process_parameters = production_item.product_id.model_process_parameters_ids.filtered(
lambda pm: pm.process_id.id == p.id)
for process_parameter in process_parameters:
i += 1
route_production_process = self.env[
'mrp.routing.workcenter'].search(
[('surface_technics_id', '=', p.id),
('id', 'in', route_workcenter_arr)])
technology_design_values.append(
self.env['sf.technology.design'].json_technology_design_str(False,
route_production_process,
i,
process_parameter))
production_item.technology_design_ids = technology_design_values
productions.write({'state': 'technology_to_confirmed'})
return True
class ProductionLot(models.Model): class ProductionLot(models.Model):

1
sf_mrs_connect/models/__init__.py
View File

@@ -2,3 +2,4 @@ from . import ftp_operate
from . import res_config_setting from . import res_config_setting
from . import sync_common from . import sync_common
from . import order_price from . import order_price
from . import mrp_production

44
sf_mrs_connect/models/mrp_production.py Normal file
View File

@@ -0,0 +1,44 @@
from itertools import groupby
from odoo import models, api
from odoo.tools.misc import OrderedSet
class MrpProduction(models.Model):
_inherit = 'mrp.production'
@api.model_create_multi
def create(self, vals_list):
"""
生成编程单
"""
productions = super().create(vals_list)
# 定义变量存储编程单
grouped_product_programming_no = {}
# 定义产品拼接成的制造订单名称
grouped_product_production_name = {}
# 查出所有的制造订单，为了适配通过补货生成的制造订单
all_productions = self.env['mrp.production'].search([('origin', '=', productions[0].origin)])
# 将不同产品的制造订单进行分组
grouped_product_productions = {k: list(g) for k, g in groupby(all_productions, key=lambda x: x.product_id.id)}
for product_id, grouped_productions in grouped_product_productions.items():
# 产品对应的编程单号
if product_id not in grouped_product_programming_no:
# 使用列表推导式获取非空的programming_no
programming_nos = [p.programming_no for p in grouped_productions if p.programming_no if p.programming_no is not False]
if programming_nos:
grouped_product_programming_no[product_id] = programming_nos[0]
grouped_product_production_name[product_id] = ','.join(list(map(lambda p:p.name, grouped_productions)))
# 同一个产品的制造订单只请求一次CNC编程
for production in productions:
if not production.programming_no and production.production_type in ['自动化产线加工','人工线下加工']:
if production.product_id.id not in grouped_product_programming_no:
production.fetchCNC(grouped_product_production_name[production.product_id.id])
grouped_product_programming_no[production.product_id.id] = production.programming_no
else:
production.write({
'programming_no': grouped_product_programming_no[production.product_id.id],
'programming_state': '编程中'
})
return productions

1
sf_plan/models/__init__.py
View File

@@ -3,3 +3,4 @@
from . import custom_plan from . import custom_plan
from . import change_manufactuing from . import change_manufactuing
from . import mrp_production

41
sf_plan/models/mrp_production.py Normal file
View File

@@ -0,0 +1,41 @@
from odoo import models, api
class MrpProduction(models.Model):
_inherit = 'mrp.production'
@api.model_create_multi
def create(self, vals_list):
"""
创建生产计划
"""
productions = super().create(vals_list)
for production in productions:
# 工单耗时
workorder_duration = 0
for workorder in production.workorder_ids:
workorder_duration += workorder.duration_expected
sale_order = self.env['sale.order'].sudo().search([('name', '=', production.origin)])
# 如果订单为空，则获取来源制造订单的销售单
if not sale_order:
mrp_production = self.env['mrp.production'].sudo().search([('name', '=', production.origin)],
limit=1)
if mrp_production:
sale_order = self.env['sale.order'].sudo().search([('name', '=', mrp_production.origin)])
else:
mrp_production = production
# if sale_order:
# sale_order.write({'schedule_status': 'to schedule'})
self.env['sf.production.plan'].sudo().with_company(production.company_id).create({
'name': production.name,
'order_deadline': sale_order.deadline_of_delivery,
'production_id': production.id,
'date_planned_start': production.date_planned_start,
'origin': mrp_production.origin,
'product_qty': production.product_qty,
'product_id': production.product_id.id,
'state': 'draft',
})
return productions