52 lines
2.3 KiB
Python
52 lines
2.3 KiB
Python
# -*- coding: utf-8 -*-
|
|
import logging
|
|
from odoo import models, fields, api, _
|
|
|
|
|
|
class SFMessageSale(models.Model):
|
|
_name = 'sale.order'
|
|
_inherit = ['sale.order', 'jikimo.message.dispatch']
|
|
|
|
def create(self, vals_list):
|
|
res = super(SFMessageSale, self).create(vals_list)
|
|
if res:
|
|
try:
|
|
res.add_queue('待接单')
|
|
except Exception as e:
|
|
logging.info('add_queue error:%s' % e)
|
|
return res
|
|
|
|
# 确认接单
|
|
def action_confirm(self):
|
|
res = super(SFMessageSale, self).action_confirm()
|
|
if res is True:
|
|
try:
|
|
self.add_queue('确认接单')
|
|
picking_ids = self.mrp_production_ids
|
|
purchase_order_id = []
|
|
if picking_ids:
|
|
for picking_id in picking_ids:
|
|
purchase_order_ids = (
|
|
picking_id.procurement_group_id.stock_move_ids.created_purchase_line_id.order_id | picking_id.procurement_group_id.stock_move_ids.move_orig_ids.purchase_line_id.order_id).ids
|
|
purchase_order_id.extend(purchase_order_ids)
|
|
if purchase_order_id:
|
|
purchase_order_list = self.env['purchase.order'].search([('id', 'in', purchase_order_id)])
|
|
for purchase_order_info in purchase_order_list:
|
|
purchase_order_info.add_queue('坯料采购提醒')
|
|
except Exception as e:
|
|
logging.info('add_queue error:%s' % e)
|
|
return res
|
|
|
|
# 继承并重写jikimo.message.dispatch的_get_message()
|
|
def _get_message(self, message_queue_ids):
|
|
res = super(SFMessageSale, self)._get_message(message_queue_ids)
|
|
if message_queue_ids.message_template_id.bussiness_node_id.name == '确认接单':
|
|
# sale_order = self.env['sale.order'].search([('id', '=', message_queue_ids.model.res_id)])
|
|
sale_order_line = self.env['sale.order.line'].search([('order_id', '=', int(message_queue_ids.res_id))])
|
|
if len(sale_order_line) == 1:
|
|
product = sale_order_line[0].product_id.name
|
|
elif len(sale_order_line) > 1:
|
|
product = '%s...' % sale_order_line[0].product_id.name
|
|
res[0] = res[0].replace('{{product_id}}', product)
|
|
return res
|