添加调拨单的质检完成的消息通知

sf_message/models/sf_message_stock_picking.py

@@ -9,6 +9,8 @@ class SFMessageStockPicking(models.Model):
     _description = "库存调拨"
     _inherit = ['stock.picking', 'jikimo.message.dispatch']
 
+    quality_check_ids = fields.One2many('quality.check', 'picking_id', '质量检测单')
+
     @api.model_create_multi
     def create(self, vals):
         result = super(SFMessageStockPicking, self).create(vals)
@@ -20,7 +22,8 @@ class SFMessageStockPicking(models.Model):
             logging.info('add_queue调拨入库 error:%s' % e)
         return result
 
-    @api.depends('move_type', 'immediate_transfer', 'move_ids.state', 'move_ids.picking_id')
+    @api.depends('move_type', 'immediate_transfer', 'move_ids.state', 'move_ids.picking_id',
+                 'quality_check_ids.quality_state')
     def _compute_state(self):
         super(SFMessageStockPicking, self)._compute_state()
         try:
@@ -48,6 +51,8 @@ class SFMessageStockPicking(models.Model):
                     all_ready_or_done = all(picking.state in ['assigned', 'done'] for picking in stock_picking_list)
                     if all_ready_or_done:
                         mrp_production.add_queue('工序外协发料通知')
+                if all(qc.quality_state in ['pass', 'fail'] for qc in record.quality_check_ids):
+                    record.add_queue('调拨单质检完成提醒')
         except Exception as e:
             logging.info('add_queue_compute_state error:%s' % e)
 
@@ -83,6 +88,11 @@ class SFMessageStockPicking(models.Model):
                 content = self.deal_stock_picking_sfp(message_queue_id)
                 if content:
                     contents.append(content)
+            elif message_queue_id.message_template_id.name == '调拨单质检完成提醒':
+                content = message_queue_id.message_template_id.content
+                content = content.replace('{{picking_type_name}}', self.picking_type_id.name).replace(
+                        '{{name}}', self.name)
+                contents.append(content)
             return contents, message_queue_ids
 
     def get_special_url(self, id, tmplate_name, special_name, model_id):