优化质量检测(加工检测)及消息推送

sf_message/models/__init__.py

@@ -7,3 +7,4 @@ from . import sf_message_functional_tool_assembly
 from . import sf_message_purchase
 from . import sf_message_workorder
 from . import sf_message_functional_tool_dismantle
+from . import sf_message_quality_cnc_test

sf_message/models/sf_message_quality_cnc_test.py

@@ -0,0 +1,36 @@
+# -*- coding: utf-8 -*-
+import logging
+from datetime import datetime, timedelta
+from odoo import models, fields, api, _
+
+
+class SFMessageQualityCncTest(models.Model):
+    _name = 'quality.cnc.test'
+    _inherit = ['quality.cnc.test', 'jikimo.message.dispatch']
+
+    def create(self, vals_list):
+        res = super(SFMessageQualityCncTest, self).create(vals_list)
+        if res:
+            try:
+                logging.info('add_queue res:%s' % res)
+                res.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):
+        contents = []
+        url = self.env['ir.config_parameter'].get_param('web.base.url')
+        i = 0
+        for item in message_queue_ids:
+            if item.message_template_id.bussiness_node_id.name == '待质量判定':
+                content = item.message_template_id.content
+                i += 1
+        if i >= 1:
+            action_id = self.env.ref('sf_quality.action_quality_cnc_test').id
+            url_with_id = f"{url}/web#view_type=list&action={action_id}"
+            content_template = content.replace('{{judge_num}}', str(i))
+            content_template = content_template.replace('{{url}}', url_with_id)
+            contents.append(content_template)
+        return contents

sf_message/models/sf_message_workorder.py

@@ -148,3 +148,8 @@ class SFMessageWork(models.Model):
                             args = [f'{item.routing_type}{overdue_message}']
                             # 获取add_queue方法并调用它，传入参数列表
                             getattr(item, queue_method_name)(*args)
+
+    def _recover_time_warning_func(self):
+        workorder_done = self.env['mrp.workorder'].search([("state", "=", "done")])
+        workorder_overdue = workorder_done.filtered(lambda x: x.delivery_warning == 'overdue')
+        workorder_overdue.write({'delivery_warning': 'normal'})