销售和排程添加消息推送

sf_message/models/sf_message_cam_program.py

@@ -3,4 +3,4 @@ from odoo import models, fields, api, _
 
 class SFMessageCamProgram(models.Model):
     _name = 'sf.cam.work.order.program.knife.plan'
-    _inherit = ['sf.cam.work.order.program.knife.plan', 'sf.message.template']
+    _inherit = ['sf.cam.work.order.program.knife.plan',  'jikimo.message.dispatch']

sf_message/models/sf_message_functional_tool_assembly.py

@@ -3,4 +3,4 @@ from odoo import models, fields, api, _
 
 class SFMessagefunctionalToolAssembly(models.Model):
     _name = 'sf.functional.tool.assembly'
-    _inherit = ['sf.functional.tool.assembly', 'sf.message.template']
+    _inherit = ['sf.functional.tool.assembly', 'jikimo.message.dispatch']

sf_message/models/sf_message_plan.py

@@ -1,6 +1,25 @@
+# -*- coding: utf-8 -*-
 from odoo import models, fields, api, _
 
 
 class SFMessagePlan(models.Model):
     _name = 'sf.production.plan'
-    _inherit = ['sf.production.plan', 'sf.message.template']
+    _inherit = ['sf.production.plan',  'jikimo.message.dispatch']
+
+    # def create(self, vals_list):
+    #     res = super(SFMessagePlan, self).create(vals_list)
+    #     if res:
+    #         try:
+    #             res.add_queue('待排程')
+    #         except Exception as e:
+    #             logging.info('add_queue error:%s' % e)
+    #     return res
+    #
+    # def _get_message(self):
+    #     res = super(SFMessagePlan, self)._get_message()
+    #     if res:
+    #         try:
+    #             res.add_queue('待排程')
+    #         except Exception as e:
+    #             logging.info('_get_message error:%s' % e)
+    #     return res

sf_message/models/sf_message_purchase.py

@@ -3,4 +3,4 @@ from odoo import models, fields, api, _
 
 class SFMessagePurchase(models.Model):
     _name = 'purchase.order'
-    _inherit = ['purchase.order', 'sf.message.template']
+    _inherit = ['purchase.order',  'jikimo.message.dispatch']

sf_message/models/sf_message_sale.py

@@ -1,11 +1,43 @@
+# -*- coding: utf-8 -*-
 from odoo import models, fields, api, _
 
 
 class SFMessageSale(models.Model):
     _name = 'sale.order'
-    _inherit = ['sale.order', 'sf.message.template']
+    _inherit = ['sale.order', 'jikimo.message.dispatch']
 
-    # def create(self):
-    #     res = super(SFMessageSale, self).create()
-    #     if res is True:
+    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('确认接单')
+            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):
+        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 = super(SFMessageSale, self)._get_message(message_queue_ids)
+        if res:
+            try:
+                res.add_queue('待排程')
+            except Exception as e:
+                logging.info('_get_message error:%s' % e)
+        return res

sf_message/models/sf_message_stock_picking.py

@@ -3,4 +3,4 @@ from odoo import models, fields, api, _
 
 class SFMessageStockPicking(models.Model):
     _name = 'stock.picking'
-    _inherit = ['stock.picking', 'sf.message.template']
+    _inherit = ['stock.picking',  'jikimo.message.dispatch']

sf_message/models/sf_message_template.py

@@ -4,31 +4,9 @@ from abc import ABC, abstractmethod
 
 
 class SfMessageTemplate(models.Model):
-    _name = "sf.message.template"
-    _description = u'消息模板'
+    _inherit = "jikimo.message.template"
 
-    name = fields.Char(string=u"名称", required=True)
-    description = fields.Char(string=u"描述")
-    content = fields.Html(string=u"内容", render_engine='qweb', translate=True, prefetch=True, sanitize=False)
-    msgtype = fields.Selection(
-        [('text', u'文字'), ('markdown', u'Markdown')], u'消息类型',
-        required=True, default='markdown')
-    notification_department_id = fields.Many2one('hr.department', u'通知部门', required=True)
-    notification_employee_ids = fields.Many2many('hr.employee', string=u'员工',
-                                                 domain="[('department_id', '=',notification_department_id)]",
-                                                 required=True)
-    is_send_time = fields.Boolean(string=u"定时发送", default=False)
-    send_time_1 = fields.Integer('发送时间点1')
-    send_time_2 = fields.Integer('发送时间点2')
-    active = fields.Boolean(string=u"是否有效", default=True)
-
-    @api.onchange('notification_department_id')
-    def _clear_employee_ids(self):
-        if self.notification_department_id:
-            self.notification_employee_ids = False
-
-    @abstractmethod
-    def dispatch(self, args):
-        """
-       强迫继承该类必走该抽象方法'
-        """
+    def _get_message_model(self):
+        res = super(SfMessageTemplate, self)._get_message_model()
+        res.append("sale.order")
+        return res

sf_message/models/sf_message_workorder.py

@@ -3,4 +3,4 @@ from odoo import models, fields, api, _
 
 class SFMessageWork(models.Model):
     _name = 'mrp.workorder'
-    _inherit = ['mrp.workorder', 'sf.message.template']
+    _inherit = ['mrp.workorder',  'jikimo.message.dispatch']