88 lines
4.5 KiB
Python
88 lines
4.5 KiB
Python
import logging
|
|
from itertools import groupby
|
|
from odoo import models, fields, api, _
|
|
|
|
|
|
class StockRuleInherit(models.Model):
|
|
_inherit = 'stock.rule'
|
|
|
|
# @api.model
|
|
# def _run_buy(self, procurements):
|
|
# # 判断补货组的采购类型
|
|
# procurements_group = {'standard': [], 'outsourcing': []}
|
|
# for procurement, rule in procurements:
|
|
# is_outsourcing = False
|
|
# product = procurement.product_id
|
|
# # 获取主 BOM
|
|
# bom = self.env['mrp.bom'].search([('product_tmpl_id', '=', product.product_tmpl_id.id)], limit=1)
|
|
#
|
|
# if bom:
|
|
# # 遍历 BOM 中的组件（即坯料等）
|
|
# for line in bom.bom_line_ids:
|
|
# raw_material = line.product_id
|
|
# # 检查路线
|
|
# for route in raw_material.route_ids:
|
|
# # print('route.name:', route.name)
|
|
# if route.name == '按订单补给外包商':
|
|
# is_outsourcing = True
|
|
#
|
|
# if is_outsourcing:
|
|
# procurements_group['outsourcing'].append((procurement, rule))
|
|
# else:
|
|
# procurements_group['standard'].append((procurement, rule))
|
|
#
|
|
# for key, value in procurements_group.items():
|
|
# super(StockRuleInherit, self)._run_buy(value)
|
|
#
|
|
# if key == 'outsourcing':
|
|
# for procurement, rule in value:
|
|
# supplier = procurement.values.get('supplier')
|
|
# if supplier:
|
|
# domain = rule._make_po_get_domain(procurement.company_id, procurement.values,
|
|
# supplier.partner_id)
|
|
# logging.info("domain=============: %s", domain)
|
|
# po = self.env['purchase.order'].sudo().search([
|
|
# ('partner_id', '=', supplier.partner_id.id),
|
|
# ('company_id', '=', procurement.company_id.id), # 保证公司一致
|
|
# ('origin', 'like', procurement.origin), # 根据来源匹配
|
|
# ('state', '=', 'draft') # 状态为草稿
|
|
# ], limit=1)
|
|
# logging.info("po=: %s", po)
|
|
# if po:
|
|
# po.write({'purchase_type': 'outsourcing'})
|
|
|
|
# # 首先调用父类的 _run_buy 方法，以保留原有逻辑
|
|
# super(StockRuleInherit, self)._run_buy(procurements)
|
|
|
|
# 然后在这里添加自定义的逻辑
|
|
# for procurement, rule in procurements:
|
|
# product = procurement.product_id
|
|
# # 获取主 BOM
|
|
# bom = self.env['mrp.bom'].search([('product_tmpl_id', '=', product.product_tmpl_id.id)], limit=1)
|
|
|
|
# if bom:
|
|
# # 遍历 BOM 中的组件（即坯料等）
|
|
# for line in bom.bom_line_ids:
|
|
# raw_material = line.product_id
|
|
# # 检查路线
|
|
# for route in raw_material.route_ids:
|
|
# # print('route.name:', route.name)
|
|
# if route.name == '按订单补给外包商': # 或者用 route.id 检查精确的路线
|
|
# print("按订单补给外包商============是")
|
|
# # 使用 procurement.values['supplier'] 获取供应商
|
|
# supplier = procurement.values.get('supplier')
|
|
# if supplier:
|
|
# domain = rule._make_po_get_domain(procurement.company_id, procurement.values,
|
|
# supplier.partner_id)
|
|
# logging.info("domain=============: %s", domain)
|
|
# po = self.env['purchase.order'].sudo().search([
|
|
# ('partner_id', '=', supplier.partner_id.id),
|
|
# ('company_id', '=', procurement.company_id.id), # 保证公司一致
|
|
# ('origin', '=', procurement.origin), # 根据来源匹配
|
|
# ('state', '=', 'draft') # 状态为草稿
|
|
# ], limit=1)
|
|
# logging.info("po=: %s", po)
|
|
# if po:
|
|
# po.write({'purchase_type': 'outsourcing'})
|
|
# break
|