jikimo/test
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

编写sf生产完工入库提醒，订单发货提醒代码

Browse Source
This commit is contained in:
hujiaying
2024-10-10 15:52:14 +08:00
parent a1b9f2dd3b
commit 49cbeee261
6 changed files with 118 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
sf_message/models/sf_message_stock_picking.py
View File

@@ -23,6 +23,31 @@ class SFMessageStockPicking(models.Model):
if record.state == 'assigned' and record.check_in == 'PC':
record.add_queue('坯料发料提醒')
if record.picking_type_id.sequence_code == 'SFP' and record.state == 'done':
stock_picking_sfp = record.env['stock.picking'].search(
[('origin', '=', record.origin), ('state', '!=', 'done'),
('picking_type_id.sequence_code', '=', 'SFP')])
if not stock_picking_sfp:
stock_picking_send = self.env["jikimo.message.queue"].search([('res_id', '=', record.id)])
if not stock_picking_send:
record.add_queue('订单发货提醒')
def deal_stock_picking_sfp(self, message_queue_ids): # 处理订单发货提醒
contents = []
for message_queue_id in message_queue_ids:
if message_queue_id.message_template_id.name == '订单发货提醒':
content = message_queue_id.message_template_id.content
stock_picking = self.env['stock.picking'].search([('id', '=', int(message_queue_id.res_id))])
stock_picking_out = self.env['stock.picking'].search(
[('origin', '=', stock_picking.origin), ('state', '=', 'assigned'),
('picking_type_id.sequence_code', '=', 'OUT')])
if stock_picking_out and len(stock_picking_out) > 0:
url = self.request_url()
content = content.replace('{{name}}', stock_picking_out.name).replace(
'{{sale_order_name}}', stock_picking_out.origin).replace('{{request_url}}', url)
contents.append(content)
return contents
def _get_message(self, message_queue_ids):
contents = []
product_id = []
@@ -48,8 +73,7 @@ class SFMessageStockPicking(models.Model):
contents.append(content)
return contents
else:
res = super(SFMessageStockPicking, self)._get_message(message_queue_id)
return res
return self.deal_stock_picking_sfp(message_queue_ids)
def request_url(self):
url = self.env['ir.config_parameter'].get_param('web.base.url')