待质检提醒

sf_message/models/sf_message_quality_check.py

@@ -0,0 +1,34 @@
+# -*- coding: utf-8 -*-
+import logging
+from odoo import models, fields, api, _
+
+
+class SFMessageQualityCheck(models.Model):
+    _name = 'quality.check'
+    _inherit = ['quality.check', 'jikimo.message.dispatch']
+
+    @api.model_create_multi
+    def create(self, vals_list):
+        result = super().create(vals_list)
+        try:
+            # 判断是否为web页面创建请求
+            is_web_request = self.env.context.get('is_web_request', False)
+            if not is_web_request:
+                for obj in result:
+                    jikimo_message_queue = self.get_message_queue(obj.product_id.id)
+                    if not jikimo_message_queue:
+                        obj.product_id.add_queue('待质检提醒')
+        except Exception as e:
+            logging.info('add_queue待质检提醒 error:%s' % e)
+        return result
+
+    def get_message_queue(self, res_id):
+        business_node_id = self.env.ref('sf_message.bussiness_quality_check').id
+        message_template = self.env["jikimo.message.template"].sudo().search([
+            ("model", "=", self._name),
+            ("bussiness_node_id", "=", business_node_id)
+        ], limit=1)
+        jikimo_message_queue = self.env['jikimo.message.queue'].sudo().search(
+            [('res_id', '=', res_id), ("message_status", "in", ("pending", "sent")),
+             ('message_template_id', '=', message_template.id)])
+        return jikimo_message_queue