1246 lines
74 KiB
Python
1246 lines
74 KiB
Python
# -*- coding: utf-8 -*-
|
|
# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl).
|
|
from email.policy import default
|
|
|
|
from odoo import fields, models, api
|
|
from odoo.exceptions import UserError, ValidationError
|
|
from datetime import datetime, date, time, timedelta
|
|
import logging
|
|
_logger = logging.getLogger(__name__)
|
|
|
|
|
|
class SoongWorkflowCommentWizard(models.TransientModel):
|
|
_name = "soong.workflow.comment.wizard"
|
|
_description = "Soong Workflow Comment Wizard"
|
|
_inherit = ['mail.thread.main.attachment', 'mail.activity.mixin']
|
|
_transient_max_count = 0
|
|
|
|
name = fields.Char(string="name")
|
|
res_model = fields.Char()
|
|
res_id = fields.Integer()
|
|
code = fields.Char()
|
|
|
|
log_ids = fields.Many2many(comodel_name="soong.workflow.log")
|
|
node_btn_id = fields.Many2one(comodel_name="soong.workflow.node.button")
|
|
node_btn_name = fields.Char(string="动作名称", related='node_btn_id.name')
|
|
user_id = fields.Many2one('res.users', string='用户', default=lambda self: self.env.user)
|
|
user_role_ids = fields.Many2many('soong.user.role', string="角色", compute='_compute_user_role_ids', store=True)
|
|
node_link_len = fields.Char(string="转交2")
|
|
is_supervising = fields.Boolean(string="是否督办")
|
|
comment_note_id = fields.Many2one('soong.note', string="常用意见")
|
|
comment_note = fields.Text(string="意见")
|
|
illustrate = fields.Text(string="说明")
|
|
comment = fields.Char(compute='_compute_comment', store=True)
|
|
state_list = fields.Char(string="状态列表")
|
|
record_id = fields.Integer()
|
|
workflow_record_id = fields.Many2one('soong.workflow.record', string="流程")
|
|
is_selection = fields.Boolean(string="是否自动选择")
|
|
trans_link_id = fields.Many2one('trans.link', string='转交节点', ondelete='set null')
|
|
document_ids = fields.Many2many('ir.attachment', string="附件")
|
|
return_link_id = fields.Many2one('trans.link', string='退回节点', ondelete='set null')
|
|
invalid_link_ids = fields.Many2many(
|
|
'trans.link',
|
|
string='跳过相同人员',
|
|
help='跳过相同人员的节点'
|
|
)
|
|
|
|
employee_trans_domain_ids = fields.Many2many('hr.employee', 'employee_trans_domain_ids_rel', string="传阅人员", store=True)
|
|
employee_ids = fields.Many2many('hr.employee', 'employee_ids_rel', 'custom_id', 'employee_id', string="转交人员", store=True)
|
|
circulated_employee_ids = fields.Many2many('hr.employee', 'circulated_employee_rel', 'custom_id', 'employee_id', help='只可以看不可以评论，看过以后状态自动变为已阅', string="传阅人员", store=True)
|
|
dep_manager_employee_ids = fields.Many2many('hr.employee', 'dep_manager_employee_rel', 'custom_id', 'employee_id', string="承办", store=True)
|
|
add_employee_ids = fields.Many2many('hr.employee', 'add_employee_rel', 'custom_id', 'employee_id', string="加签人员", help='点击确认以后评论的人员', store=True)
|
|
supervising_employee_ids = fields.Many2many('hr.employee', 'supervising_employee_rel', 'custom_id', 'employee_id', string="督办人员", store=True)
|
|
approval_concatenation = fields.Selection([('chuan', '串申'), ('bing', '并申')], string="审批形式",
|
|
help='并：任何人均给意见，最后一个完成的人转交到下一节点.'
|
|
'串：都会收到消息，但任意一个人转交后，即到下一节点，其他人将不再显示，相当于收回.')
|
|
is_automatic = fields.Boolean('是否自动匹配')
|
|
company_id = fields.Many2one('res.company', '公司', default=lambda self: self.env.user.company_id)
|
|
scope_type = fields.Selection(
|
|
[
|
|
('company', '本公司'),
|
|
('group', '本集团'),
|
|
('department', '本部门'),
|
|
],
|
|
string='范围类型',
|
|
default='company',
|
|
required=True,
|
|
)
|
|
employee_ids1 = fields.Many2many('hr.employee', 'employee_ids1_rel', 'custom_id1', 'employee_id1', string="人员范围", store=True)
|
|
employee_ids2 = fields.Many2many('hr.employee', 'employee_ids2_rel', 'custom_id2', 'employee_id2', string="加签传阅人员过滤")
|
|
|
|
|
|
@api.onchange('is_selection', 'scope_type')
|
|
def _onchange_is_selection(self):
|
|
if not self.employee_ids1:
|
|
self.employee_ids = False
|
|
return
|
|
domain = [('id', 'in', self.employee_ids1.ids)]
|
|
if self.scope_type == 'company':
|
|
domain.append(('company_id', '=', self.company_id.id))
|
|
elif self.scope_type == 'group':
|
|
pass
|
|
elif self.scope_type == 'department':
|
|
department = self.env.user.department_id
|
|
if department:
|
|
all_depts = department.child_ids | department
|
|
domain.extend([
|
|
('company_id', '=', self.company_id.id),
|
|
'|',
|
|
('department_id', 'in', all_depts.ids),
|
|
('department_ids', 'in', all_depts.ids),
|
|
])
|
|
all_employees = self.env['hr.employee'].search(domain)
|
|
self.employee_ids = all_employees if self.is_selection else False
|
|
|
|
@api.onchange('scope_type', 'employee_ids1', 'department_id', 'company_id')
|
|
def _onchange_employee_ids1(self):
|
|
self.employee_ids = False
|
|
if not self.employee_ids1:
|
|
return
|
|
if not self.is_selection:
|
|
return
|
|
filtered_employees = self.employee_ids1
|
|
# 范围过滤
|
|
if self.scope_type == 'company':
|
|
filtered_employees = self.employee_ids1.filtered(
|
|
lambda e: e.company_id == self.company_id
|
|
)
|
|
elif self.scope_type == 'department':
|
|
department = self.env.user.department_id
|
|
if department:
|
|
all_depts = department.child_ids | department
|
|
filtered_employees = self.employee_ids1.filtered(
|
|
lambda e: e.department_id in all_depts or any(d in all_depts for d in e.department_ids)
|
|
)
|
|
self.employee_ids = filtered_employees
|
|
return
|
|
|
|
@api.onchange('scope_type', 'department_id', 'company_id')
|
|
def _onchange_employee_ids2(self):
|
|
domain = []
|
|
if self.scope_type == 'company':
|
|
domain.append(('company_id', '=', self.company_id.id))
|
|
elif self.scope_type == 'department':
|
|
department = self.env.user.department_id
|
|
if department:
|
|
all_depts = department.child_ids | department
|
|
domain.extend([
|
|
('company_id', '=', self.company_id.id),
|
|
'|',
|
|
('department_id', 'in', all_depts.ids),
|
|
('department_ids', 'in', all_depts.ids),
|
|
])
|
|
self.employee_ids2 = self.env['hr.employee'].search(domain)
|
|
|
|
@api.depends('comment_note_id', 'comment_note')
|
|
def _compute_comment(self):
|
|
for record in self:
|
|
comment_parts = []
|
|
if record.comment_note_id:
|
|
comment_parts.append(record.comment_note_id.name)
|
|
if record.comment_note:
|
|
comment_parts.append(record.comment_note)
|
|
record.comment = " ".join(comment_parts) if comment_parts else ""
|
|
|
|
@api.depends('user_id.employee_ids.user_role_ids', 'user_id.employee_ids.user_role_id')
|
|
def _compute_user_role_ids(self):
|
|
for record in self:
|
|
if record.user_id and record.user_id.employee_ids:
|
|
role_ids_from_employee = record.user_id.employee_ids.user_role_ids
|
|
role_id_from_field = record.user_id.employee_ids.user_role_id
|
|
if role_id_from_field:
|
|
record.user_role_ids = role_ids_from_employee | role_id_from_field
|
|
else:
|
|
record.user_role_ids = role_ids_from_employee
|
|
else:
|
|
record.user_role_ids = False
|
|
|
|
@api.onchange('record_id')
|
|
def _onchange_record_id(self):
|
|
record_id = self.env[self.res_model].search([('id', '=', self.res_id)])
|
|
self.record_id = record_id
|
|
|
|
@api.onchange('return_link_id')
|
|
def onchange_employee_ids(self):
|
|
record_id = self.env[self.res_model].search([('id', '=', self.res_id)])
|
|
for ret in self.return_link_id:
|
|
if ret.name in ['拟办', '申请人']:
|
|
if hasattr(record_id, 'user_id') and record_id.user_id:
|
|
employee_ids1 = self.env['hr.employee'].search([('user_id', '=', record_id.user_id.id)])
|
|
elif hasattr(record_id, 'users_id') and record_id.users_id:
|
|
employee_ids1 = self.env['hr.employee'].search([('user_id', '=', record_id.users_id.id)])
|
|
self.employee_ids1 = employee_ids1
|
|
elif self.node_btn_name == '退回':
|
|
target_log = record_id.log_ids.filtered(lambda l: l.name == ret.name)
|
|
if target_log and target_log.done_by:
|
|
if target_log.done_by:
|
|
employee = self.env['hr.employee'].sudo().search([('user_id', '=', target_log.done_by.id)], limit=1)
|
|
self.employee_ids1 = employee
|
|
else:
|
|
self.employee_ids1 = self.env['hr.employee']
|
|
|
|
# next_list = []
|
|
# workflow_id = self.return_link_id.node_button_id.workflow_id
|
|
# state_list = [i.node_name for i in workflow_id.node_ids]
|
|
# if ret.name == '询价':
|
|
# name = 'draft'
|
|
# else:
|
|
# name = ret.name
|
|
# self_state = state_list.index(name)
|
|
# button_ids = workflow_id.node_ids[self_state].button_ids
|
|
# for btn in button_ids:
|
|
# next_list.append(btn.name)
|
|
# if '转交' not in next_list:
|
|
# raise UserError('配置错误，请配置当前{}的转交按钮'.format(btn.name))
|
|
# else:
|
|
# if btn.is_automatic:
|
|
# employee_user_role_id = self.env['hr.employee'].search(
|
|
# ['|', ('user_role_id', '=', btn.users_role_id.id),
|
|
# ('user_role_id', 'in', btn.users_role_group_ids.user_role_ids.ids),
|
|
# ('department_id', '=', record_id.department_id.id)])
|
|
# self.employee_ids1 = employee_user_role_id
|
|
# else:
|
|
# employee_user_role_ids = self.env['hr.employee'].search(
|
|
# ['|', ('user_role_id', '=', btn.users_role_id.id),
|
|
# ('user_role_id', 'in', btn.users_role_group_ids.user_role_ids.ids),
|
|
# ])
|
|
# self.employee_ids1 = employee_user_role_ids
|
|
|
|
@api.onchange('trans_link_id')
|
|
def onchange_trans_employee_ids(self):
|
|
for record in self:
|
|
# 先清空
|
|
record_id = self.env[record.res_model].browse(record.res_id) if record.res_model and record.res_id else None
|
|
ctx_links = self.env.context.get('all_workflow_links', [])
|
|
valid_links = self.env['trans.link'].browse(ctx_links) if isinstance(ctx_links, (list, tuple)) else ctx_links
|
|
|
|
record.is_selection = False
|
|
if self.node_btn_name == '退回':
|
|
record.scope_type = 'group'
|
|
else:
|
|
record.scope_type = 'company'
|
|
if record.node_btn_id.employee_ids and record.node_btn_id.is_carbon_copy:
|
|
record.circulated_employee_ids = record.node_btn_id.employee_ids
|
|
|
|
if not record.trans_link_id:
|
|
continue
|
|
|
|
# 排除规则：流程退回 不限制
|
|
if record_id and record_id.workflow_id:
|
|
has_exclude_log = record_id.log_ids.filtered(lambda l: l.node_btn_name == '1')
|
|
if not has_exclude_log:
|
|
# 1. 从 valid_links 里 匹配出 当前流程会经过的【必经节点】
|
|
current_mandatory_nodes = self.env['soong.workflow.node']
|
|
for link in valid_links:
|
|
link_node = record_id.workflow_id.node_ids.search([
|
|
('name', '=', link.name),
|
|
('workflow_id', '=', record_id.workflow_id.id)
|
|
], limit=1)
|
|
if link_node and link_node.is_mandatory_node:
|
|
current_mandatory_nodes |= link_node
|
|
|
|
if current_mandatory_nodes:
|
|
# 2. 取第一个必经节点
|
|
first_mandatory = current_mandatory_nodes.sorted('sequence')[0]
|
|
# 3. 只允许选择 <= 第一个必经节点 的链接
|
|
allow_links = self.env['trans.link']
|
|
for link in valid_links:
|
|
link_node = record_id.workflow_id.node_ids.search([
|
|
('name', '=', link.name),
|
|
('workflow_id', '=', record_id.workflow_id.id)
|
|
], limit=1)
|
|
if link_node and link_node.sequence <= first_mandatory.sequence:
|
|
allow_links |= link
|
|
|
|
# 4. 校验：选了必经节点之后的 → 报错
|
|
if record.trans_link_id not in allow_links:
|
|
record.trans_link_id = False
|
|
raise UserError(f"节点【{first_mandatory.name}】是必经节点，不可跳过！")
|
|
|
|
for link in record.trans_link_id:
|
|
employee_user_role_ids = self.env['hr.employee']
|
|
if link.name == '印章管理员':
|
|
if hasattr(record_id, 'type_stamp_ids'):
|
|
stamp_types = record_id.type_stamp_ids
|
|
if stamp_types:
|
|
user_ids = self.env['res.users']
|
|
for stamp in stamp_types:
|
|
user_ids |= stamp.user_ids
|
|
if user_ids:
|
|
employee_user_role_ids = self.env['hr.employee'].sudo().search([
|
|
('user_id', 'in', user_ids.ids)
|
|
])
|
|
else:
|
|
employee_user_role_ids = record_id._get_approvers_for_link(link, record_id)
|
|
workflow_id = link.node_button_id.workflow_id
|
|
node = workflow_id.node_ids.search([
|
|
('name', '=', link.name),
|
|
('workflow_id', '=', workflow_id.id)
|
|
], limit=1)
|
|
if node:
|
|
record.approval_concatenation = node.approval_concatenation
|
|
record.employee_trans_domain_ids = employee_user_role_ids
|
|
record.employee_ids1 = employee_user_role_ids
|
|
workflow_id = link.node_button_id.workflow_id
|
|
node = workflow_id.node_ids.search([
|
|
('name', '=', link.name),
|
|
('workflow_id', '=', workflow_id.id)
|
|
])
|
|
button_priority_list = ["分发", "下发", "转交", "结束"]
|
|
button = False
|
|
if node.button_ids:
|
|
for btn_name in button_priority_list:
|
|
for btn in node.button_ids:
|
|
if btn.name == btn_name: # 匹配优先级按钮名称
|
|
is_in_scope = True
|
|
if not btn.is_review_invisible:
|
|
button = btn
|
|
break
|
|
if btn.is_review_invisible:
|
|
domain = eval(btn.invisible_expression)
|
|
model = record_id.env[record_id._name]
|
|
matched = model.search(domain + [('id', '=', record_id.id)])
|
|
is_in_scope = bool(matched)
|
|
if is_in_scope:
|
|
target_btn = btn
|
|
button = target_btn
|
|
break
|
|
if button:
|
|
if button.is_node_automatic:
|
|
record.is_selection = True
|
|
else:
|
|
record.is_selection = False
|
|
record._onchange_is_selection()
|
|
|
|
def _send_workflow_notifications(self, partners=None):
|
|
""" 通知前端刷新红点、播放音频
|
|
:param partners: 需要通知的用户(res.partner)，未传则通知所有
|
|
"""
|
|
bus_message = {'type': 'wkf_notify'}
|
|
notifications = [[partner, 'sun_badge_menu.reload_menu_data', [bus_message]] for partner in partners]
|
|
self.env["bus.bus"]._sendmany(notifications) # 浏览器叮咚
|
|
|
|
def add_comment(self):
|
|
self.ensure_one()
|
|
partners = self._get_all_employee_partners()
|
|
self._send_workflow_notifications(partners)
|
|
# 如果选择了常用意见，将使用信息追加到 soong.note 记录
|
|
if self.comment_note_id:
|
|
import pytz
|
|
from datetime import datetime
|
|
tz = pytz.timezone('Asia/Shanghai')
|
|
today = datetime.now(pytz.utc).astimezone(tz).strftime('%Y-%m-%d')
|
|
user_name = self.env.user.name
|
|
code = self.code or ''
|
|
note_name = self.comment_note_id.name or ''
|
|
new_line = f"{today} {code} {user_name} {note_name}"
|
|
old_info = self.comment_note_id.use_info or ''
|
|
updated_info = (old_info + '\n' + new_line) if old_info else new_line
|
|
self.comment_note_id.sudo().write({'use_info': updated_info})
|
|
cx = self.env.context.copy() or {}
|
|
record_id = self.env[self.res_model].search([('id', '=', self.res_id)])
|
|
is_admin = self.env.user.has_group('soong_workflow.group_soong_workflow_manager')
|
|
log_done_by_ids = [log.done_by.id for log in record_id.log_ids if log.done_by]
|
|
if self.node_btn_name == '转交':
|
|
if self.res_model == 'issue.approval':
|
|
if self.trans_link_id.name != '申请人':
|
|
if record_id.issue_approval_ids:
|
|
for issue_library in record_id.issue_approval_ids:
|
|
issue_library.issue_library_id.issue_state = 'to_draft'
|
|
has_comment_note = bool(self.comment_note_id)
|
|
has_comment = bool(self.comment and self.comment.strip())
|
|
if not has_comment_note and not has_comment:
|
|
raise UserError('请填写备注')
|
|
if not self.employee_ids:
|
|
raise UserError("必须有转交人员")
|
|
self_node_id = record_id.workflow_id.node_ids.search(
|
|
[('name', '=', record_id.state), ('workflow_id', '=', record_id.workflow_id.id)])
|
|
log = self.env['soong.workflow.log'].search([("model", "=", self.res_model),
|
|
("res_id", "=", self.res_id)])
|
|
query_user_id = self.env.user.id
|
|
if is_admin and record_id:
|
|
if hasattr(record_id, 'user_id') and record_id.user_id:
|
|
query_user_id = record_id.user_id.id
|
|
elif hasattr(record_id, 'users_id') and record_id.users_id:
|
|
query_user_id = record_id.users_id.id
|
|
if len(log) > 1 and is_admin:
|
|
current_node_log = self.sudo().env["soong.workflow.log"].search(
|
|
[("model", "=", self.res_model),
|
|
("res_id", "=", self.res_id),
|
|
("node_id", "=", self.node_btn_id.node_id.id)
|
|
],
|
|
order="lase_click_date DESC",
|
|
limit=1
|
|
)
|
|
else:
|
|
current_node_log = self.sudo().env["soong.workflow.log"].search(
|
|
[
|
|
("model", "=", self.res_model),
|
|
("res_id", "=", self.res_id),
|
|
("done_by", "=", query_user_id),
|
|
("node_id", "=", self.node_btn_id.node_id.id),
|
|
],
|
|
order="create_date DESC",
|
|
limit=1
|
|
)
|
|
# 创建或更新当前用户的审批记录
|
|
if not current_node_log:
|
|
self.sudo().env["soong.workflow.log"].create({
|
|
"code": self.code,
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"node_id": self.node_btn_id.node_id.id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"done_by": query_user_id,
|
|
"node_btn_name": "0",
|
|
"node_btn_id": self.node_btn_id.id,
|
|
"approval_state": "2", # 已完成
|
|
"lase_click_date": fields.Datetime.now(),
|
|
"comment": self.comment,
|
|
})
|
|
else:
|
|
current_node_log.write({
|
|
"comment": self.comment,
|
|
"approval_state": "2", # 已完成
|
|
'document_ids': [(6, 0, self.document_ids.ids)],
|
|
"lase_click_date": fields.Datetime.now()
|
|
})
|
|
if current_node_log.node_btn_name == '3':
|
|
other_node_logs = self.sudo().env["soong.workflow.log"].search(
|
|
[("model", "=", self.res_model),
|
|
("res_id", "=", self.res_id),
|
|
("id", "!=", current_node_log.id),
|
|
("node_id", "=", self.node_btn_id.node_id.id)
|
|
])
|
|
for other_node_log in other_node_logs:
|
|
other_node_log.unlink()
|
|
|
|
# 检查是否为并审模式
|
|
if self.approval_concatenation == 'bing': # 并审模式考勤异常
|
|
expected_employees = self.employee_ids
|
|
if record_id.log_ids2:
|
|
log_employee_ids = record_id.log_ids2.mapped('done_by.employee_id.id')
|
|
self.employee_ids = expected_employees.filtered(lambda emp: emp.id not in log_employee_ids)
|
|
|
|
# 查找下一个节点
|
|
next_node_id = record_id.workflow_id.node_ids.search([
|
|
('name', '=', self.trans_link_id.name),
|
|
('workflow_id', '=', record_id.workflow_id.id)
|
|
])
|
|
|
|
completed_logs = self.sudo().env["soong.workflow.log"].search([
|
|
("model", "=", self.res_model),
|
|
("res_id", "=", self.res_id),
|
|
("node_id", "=", self.node_btn_id.node_id.id),
|
|
("node_btn_name", "=", "4"),
|
|
("approval_state", "!=", "2")
|
|
])
|
|
all_completed = len(completed_logs) == 0
|
|
next_node_log_records = self.env["soong.workflow.log"]
|
|
if all_completed:
|
|
for employee in self.employee_ids:
|
|
# 检查该员工在下一节点是否已有记录
|
|
next_node_employee_log = self.sudo().env["soong.workflow.log"].search([
|
|
("model", "=", self.res_model),
|
|
("res_id", "=", self.res_id),
|
|
("node_id", "=", next_node_id.id),
|
|
('node_btn_name', '!=', '1'),
|
|
('approval_state', '!=', '2'),
|
|
("done_by", "=", employee.user_id.id)
|
|
])
|
|
if not next_node_employee_log:
|
|
# 创建初步记录，状态为"待审批"
|
|
next_node_employee_log = self.sudo().env["soong.workflow.log"].create({
|
|
"code": self.code,
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"node_id": next_node_id.id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"done_by": employee.user_id.id,
|
|
"node_btn_name": "4",
|
|
"approval_state": "0", # 待审批
|
|
})
|
|
next_node_log_records += next_node_employee_log
|
|
workflow_record_id = self.env['soong.workflow.record'].sudo().search([('res_id', '=', record_id.id),
|
|
('res_model', '=', record_id._name)
|
|
])
|
|
workflow_record_id.users_ids = [(4, employee.user_id.id) for employee in self.employee_ids if employee.user_id]
|
|
workflow_record_id.employee_ids = self.employee_ids.ids
|
|
workflow_record_id.approve_state = "pending" # 待审批
|
|
related_record = self.env[self.res_model].browse(self.res_id)
|
|
if hasattr(related_record, 'self_users_ids'):
|
|
user_ids = [employee.user_id.id for employee in self.employee_ids if employee.user_id]
|
|
related_record.self_users_ids = [(6, 0, user_ids)] if user_ids else [(5,)]
|
|
if not self.trans_link_id.name:
|
|
raise UserError('无转交节点')
|
|
record_id.write({'state': self.trans_link_id.name})
|
|
for employee in self.employee_ids:
|
|
action_id = self.env['ir.actions.act_window'].search([('res_model', '=', self.res_model)])[0]
|
|
target_url = f'https://oa.thtzjt.com/web#id={record_id.id}&cids=2&active_id={action_id.id}&model={record_id._name}&view_type=form'
|
|
url = self.sudo().env["wecom.apps"].generate_oauth_login_url(target_url, employee.user_id.id)
|
|
_logger.info(f"===================当前的url为{url}=============================")
|
|
title = record_id._description
|
|
if 'Purchase Order' == record_id._description:
|
|
title = '采购订单'
|
|
if 'Room Booking' == record_id._description:
|
|
title = '会议通知'
|
|
result_data = self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa', user_id=employee.wecom_userid, title=title,
|
|
description="标题: {}\n".format(record_id.name) + self.env.user.name + ' ' + str(
|
|
fields.Datetime.now() + timedelta(hours=8)),
|
|
url=url, btntxt="查看详情")
|
|
if result_data and 'msgid' in result_data[-1]:
|
|
msg_id = result_data[-1]['msgid']
|
|
target_logs = next_node_log_records.filtered(lambda l: l.done_by.id == employee.user_id.id)
|
|
if target_logs:
|
|
target_logs.msg_id = msg_id
|
|
|
|
else: # 串审模式 (沿用原有逻辑)
|
|
# 查找下一个节点
|
|
next_node_id = record_id.workflow_id.node_ids.search([
|
|
('name', 'ilike', self.trans_link_id.name),
|
|
('workflow_id', '=', record_id.workflow_id.id)
|
|
])
|
|
for employee_id in self.employee_ids:
|
|
# 创建下一节点的审批记录
|
|
self.sudo().env["soong.workflow.log"].create({
|
|
"code": self.code,
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"node_id": next_node_id.id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"done_by": employee_id.user_id.id if self.employee_ids else query_user_id,
|
|
"node_btn_name": "3",
|
|
"approval_state": "1", # 待审批
|
|
})
|
|
|
|
# 更新业务记录状态
|
|
related_record = self.env[self.res_model].browse(self.res_id)
|
|
if hasattr(related_record, 'self_users_ids'):
|
|
user_ids = [employee.user_id.id for employee in self.employee_ids if employee.user_id]
|
|
related_record.self_users_ids = [(6, 0, user_ids)] if user_ids else [(5,)]
|
|
record_id.write({'state': self.trans_link_id.name})
|
|
workflow_record_id = self.env['soong.workflow.record'].sudo().search([('res_id', '=', record_id.id),
|
|
('res_model', '=', record_id._name)
|
|
])
|
|
workflow_record_id.users_ids = [(4, employee.user_id.id) for employee in self.employee_ids if
|
|
employee.user_id]
|
|
workflow_record_id.employee_ids = self.employee_ids.ids
|
|
workflow_record_id.approve_state = "pending" # 待审批
|
|
|
|
for employee in self.circulated_employee_ids:
|
|
record_id = self.env[self.res_model].search([('id', '=', self.res_id)])
|
|
self.sudo().env["soong.workflow.record.copy"].create({
|
|
"code": record_id.code,
|
|
"name": record_id.name,
|
|
"res_model": self.res_model,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"res_id": self.res_id,
|
|
"done_by": employee.user_id.id,
|
|
"approval_state_copy": "0",
|
|
})
|
|
if employee.user_id.id not in log_done_by_ids:
|
|
self.sudo().env["soong.workflow.log2"].create({
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"node_id": self.node_btn_id.node_id.id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"done_by": employee.user_id.id,
|
|
"node_btn_id": self.node_btn_id.id,
|
|
"approval_state": "0",
|
|
})
|
|
|
|
if self.circulated_employee_ids:
|
|
action_id = self.env['ir.actions.act_window'].search([('res_model', '=', self.res_model)])[0]
|
|
workflow_record_id = self.env['soong.workflow.record'].sudo().search([('res_id', '=', record_id.id),
|
|
('res_model', '=', record_id._name)
|
|
])
|
|
workflow_record_id.is_log2 = True
|
|
description = "标题: {}\n".format(record_id.name) + self.env.user.name + ' ' + str(fields.Datetime.now() + timedelta(hours=8))
|
|
workflow_record_id.employee2_ids = [(6, 0, self.circulated_employee_ids.ids)]
|
|
for employee in self.circulated_employee_ids:
|
|
url = f'https://oa.thtzjt.com/web#id={record_id.id}&cids=2&menu_id={record_id.id}&action={action_id.id}&model={self.res_model}&view_type=form'
|
|
self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa',
|
|
user_id=employee.wecom_userid,
|
|
title=record_id._description + "传阅/抄送",
|
|
description=description, url=url,
|
|
btntxt="查看详情")
|
|
self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa',
|
|
user_id='18562027762',
|
|
title=record_id._description + '传阅/抄送，测试提醒',
|
|
description=description, url=url,
|
|
btntxt="查看详情")
|
|
self._handle_avoidance()
|
|
if self.node_btn_name == '退回':
|
|
if not self.return_link_id:
|
|
raise UserError('请选择退回节点')
|
|
if self.res_model == 'issue.approval':
|
|
if self.return_link_id.name == '申请人':
|
|
if record_id.issue_approval_ids:
|
|
for issue_library in record_id.issue_approval_ids:
|
|
issue_library.issue_library_id.issue_state = 'draft'
|
|
record_id.write({'state': self.return_link_id.name})
|
|
next_node_id = record_id.workflow_id.node_ids.search([('name', '=', self.return_link_id.name), ('workflow_id', '=', record_id.workflow_id.id)])
|
|
for next_link in record_id.workflow_id.link_ids:
|
|
if next_link.name.split('-> ')[0].strip() == self.return_link_id.name.strip():
|
|
next_node_id = next_link.node_from
|
|
|
|
user_log = record_id.log_ids.filtered(
|
|
lambda log: log.done_by == self.env.user and log.approval_state in ['0', '1'])
|
|
user_log.write({'approval_state': '2',
|
|
"lase_click_date": fields.Datetime.now(),
|
|
"comment": self.comment,
|
|
"node_btn_name": "1"})
|
|
target_names = user_log.mapped('name')
|
|
logs_to_delete = record_id.log_ids.filtered(
|
|
lambda log: (log.name in target_names) and
|
|
not log.comment and
|
|
log not in user_log
|
|
)
|
|
if logs_to_delete:
|
|
logs_to_delete.unlink()
|
|
self.sudo().env["soong.workflow.log"].create({
|
|
"code": self.code,
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"node_id": next_node_id.id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"done_by": self.employee_ids[0].user_id.id,
|
|
"approval_state": "0",
|
|
"node_btn_id": self.node_btn_id.id,
|
|
})
|
|
workflow_record_id = self.env['soong.workflow.record'].sudo().search([('res_id', '=', record_id.id),
|
|
('res_model', '=', record_id._name)
|
|
])
|
|
workflow_record_id.employee_ids = self.employee_ids
|
|
action_id = self.env['ir.actions.act_window'].search([('res_model', '=', self.res_model)])[0]
|
|
related_record = self.env[self.res_model].browse(self.res_id)
|
|
user_ids = [employee.user_id.id for employee in self.employee_ids if employee.user_id]
|
|
if hasattr(related_record, 'self_users_ids'):
|
|
related_record.self_users_ids = [(6, 0, user_ids)] if user_ids else [(5,)]
|
|
node_name = self.node_btn_id.node_id.name
|
|
description = f"您的{record_id.name}, 于当前{node_name}退回"
|
|
url = f'https://oa.thtzjt.com/web#id={record_id.id}&cids=2&menu_id={record_id.id}&action={action_id.id}&model={self.res_model}&view_type=form'
|
|
for employee in self.employee_ids:
|
|
self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa',
|
|
user_id=employee.wecom_userid,
|
|
title=record_id._description + "退回",
|
|
description=description, url=url, btntxt="查看详情")
|
|
|
|
|
|
if self.node_btn_name == '加签':
|
|
current_node_log = self.sudo().env["soong.workflow.log"].search(
|
|
[
|
|
("model", "=", self.res_model),
|
|
("res_id", "=", self.res_id),
|
|
("done_by", "=", self.env.user.id),
|
|
("approval_state", 'in', ['0','1']),
|
|
],
|
|
order="create_date DESC",
|
|
limit=1
|
|
)
|
|
current_node_log.write({
|
|
"comment": self.comment,
|
|
"approval_state": "2", # 已完成
|
|
'document_ids': [(6, 0, self.document_ids.ids)],
|
|
"lase_click_date": fields.Datetime.now()
|
|
})
|
|
if hasattr(record_id, 'user_id') and record_id.user_id:
|
|
query_user_id = record_id.user_id
|
|
elif hasattr(record_id, 'users_id') and record_id.users_id:
|
|
query_user_id = record_id.users_id
|
|
description = f"标题：{record_id.name}\n申请人：{query_user_id.name}"
|
|
action_id = self.env['ir.actions.act_window'].search([('res_model', '=', self.res_model)])[0]
|
|
for employee_id in self.add_employee_ids:
|
|
next_node_log_records = self.sudo().env["soong.workflow.log"].create({
|
|
'name': '加签',
|
|
"code": self.code,
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"node_id": self.node_btn_id.node_id.id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"done_by": employee_id.user_id.id,
|
|
"node_btn_id": self.node_btn_id.id,
|
|
"approval_state": "0",
|
|
})
|
|
url = f'https://oa.thtzjt.com/web#id={record_id.id}&cids=2&menu_id={record_id.id}&action={action_id.id}&model={self.res_model}&view_type=form'
|
|
result_data = self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa',
|
|
user_id=employee_id.wecom_userid,
|
|
title=record_id._description + "加签",
|
|
description=description, url=url,
|
|
btntxt="查看详情")
|
|
if result_data and 'msgid' in result_data[-1]:
|
|
msg_id = result_data[-1]['msgid']
|
|
target_logs = next_node_log_records.filtered(lambda l: l.done_by.id == employee_id.user_id.id)
|
|
if target_logs:
|
|
target_logs.msg_id = msg_id
|
|
|
|
workflow_record_id = self.env['soong.workflow.record'].sudo().search([('res_id', '=', record_id.id),
|
|
('res_model', '=', record_id._name)
|
|
])
|
|
workflow_record_id.employee_ids = self.add_employee_ids
|
|
workflow_record_id.users_ids = [(4, employee.user_id.id) for employee in self.add_employee_ids if
|
|
employee.user_id]
|
|
|
|
if self.node_btn_name == '加签确认':
|
|
if hasattr(record_id, 'user_id') and record_id.user_id:
|
|
query_user_id = record_id.user_id
|
|
elif hasattr(record_id, 'users_id') and record_id.users_id:
|
|
query_user_id = record_id.users_id
|
|
description = f"标题：{record_id.name}\n申请人：{query_user_id.name}"
|
|
action_id = self.env['ir.actions.act_window'].search([('res_model', '=', self.res_model)])[0]
|
|
user_log = record_id.log_ids.filtered(
|
|
lambda log: log.done_by == self.env.user.id and log.node_btn_name != '1' and log.approval_state in ['0',
|
|
'1']
|
|
)
|
|
current_node_log = self.sudo().env["soong.workflow.log"].search(
|
|
[
|
|
("model", "=", self.res_model),
|
|
("res_id", "=", self.res_id),
|
|
("done_by", "=", self.env.user.id),
|
|
("node_id", "=", self.node_btn_id.node_id.id),
|
|
],
|
|
order="create_date DESC",
|
|
limit=1
|
|
)
|
|
current_node_log.write({
|
|
"comment": self.comment,
|
|
"approval_state": "2", # 已完成
|
|
'document_ids': [(6, 0, self.document_ids.ids)],
|
|
"lase_click_date": fields.Datetime.now()
|
|
})
|
|
log_obj = self.sudo().env["soong.workflow.log"]
|
|
node_id = self.node_btn_id.node_id.id
|
|
last_sign_log = log_obj.search([
|
|
("model", "=", self.res_model),
|
|
("res_id", "=", self.res_id),
|
|
("name", "=", "归档"),
|
|
], order="create_date DESC", limit=1)
|
|
|
|
# 没找到归档，再取原来的最后一条（非加签）
|
|
if not last_sign_log:
|
|
last_sign_log = log_obj.search([
|
|
("model", "=", self.res_model),
|
|
("res_id", "=", self.res_id),
|
|
('approval_state', "=", '2'),
|
|
("name", "!=", "加签"),
|
|
], order="lase_click_date DESC")[0]
|
|
|
|
# 如果没有加签日志，直接跳过
|
|
if not last_sign_log:
|
|
return
|
|
|
|
# 最新加签的经办人
|
|
last_sign_user = last_sign_log.done_by
|
|
|
|
# 2. 找到当前节点所有日志（排除最新加签那条）
|
|
all_logs = log_obj.search([
|
|
("model", "=", self.res_model),
|
|
("res_id", "=", self.res_id),
|
|
("node_id", "=", node_id),
|
|
("name", "=", "加签"),
|
|
("id", "!=", user_log.id),
|
|
])
|
|
# 其他人是否都完成了
|
|
all_other_done = all(log.approval_state == "2" for log in all_logs)
|
|
# 4. 如果满足 → 创建一条新日志给【最新加签的经办人】
|
|
if all_other_done:
|
|
# 判断是否需要设置为归档
|
|
log_name = last_sign_log.name if last_sign_log.name == '归档' else False
|
|
log_vals = {
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"node_id": last_sign_log.node_id.id,
|
|
"done_by": last_sign_user.id,
|
|
"approval_state": "0",
|
|
"create_date": fields.Datetime.now(),
|
|
}
|
|
# 如果是归档，自动写入 name = 归档
|
|
if log_name:
|
|
log_vals["name"] = log_name
|
|
log_obj.create(log_vals)
|
|
workflow_record_id = self.env['soong.workflow.record'].sudo().search([('res_id', '=', record_id.id),
|
|
(
|
|
'res_model', '=', record_id._name)
|
|
])
|
|
url = f'https://oa.thtzjt.com/web#id={record_id.id}&cids=2&menu_id={record_id.id}&action={action_id.id}&model={self.res_model}&view_type=form'
|
|
self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa',
|
|
user_id=last_sign_user.employee_ids.wecom_userid,
|
|
title=record_id._description + '加签返回',
|
|
description=description, url=url,
|
|
btntxt="查看详情")
|
|
|
|
if self.node_btn_name in ['结束', '确认']:
|
|
title = record_id._description
|
|
current_comment = self.comment or ''
|
|
if 'Room Booking' == record_id._description:
|
|
title = '会议通知'
|
|
is_work_remind = False
|
|
current_user = self.env.user
|
|
current_datetime = fields.Datetime.now()
|
|
is_admin = current_user.has_group('base.group_system')
|
|
# 归档判断
|
|
last_log = record_id.log_ids.sorted(
|
|
key=lambda r: (not r.lase_click_date, r.lase_click_date or False, r.id)
|
|
)[-1] if record_id.log_ids else None
|
|
all_user = True if last_log and last_log.done_by == current_user else False
|
|
if last_log:
|
|
same_name_logs = record_id.log_ids.filtered(
|
|
lambda log: log.name == last_log.name and log.node_btn_name == '4' and log.id != last_log.id
|
|
)
|
|
all_approved = all(log.approval_state in ['2', '3'] for log in same_name_logs) or not same_name_logs
|
|
if all_approved and all_user:
|
|
workflow_record = self.env['soong.workflow.record'].sudo().search([('res_id', '=', record_id.id),
|
|
('res_model', '=',record_id._name),
|
|
('reclaim_state', '=', False),
|
|
])
|
|
has_archive_btn = any(btn_name.name == '归档' for btn_name in self.node_btn_id.node_id.button_ids)
|
|
if has_archive_btn:
|
|
log_id = record_id.log_ids.filtered(lambda l: l.name == '归档')
|
|
employee_id = self.env['hr.employee'].sudo().search(
|
|
[('user_id', '=', record_id.log_ids[0].done_by.id)], limit=1)
|
|
if workflow_record:
|
|
workflow_record.write({
|
|
'approve_state': 'end',
|
|
'employee_ids': [(6, 0, [employee_id.id])],
|
|
'soong_state': 'to_active',
|
|
'node_id': False,
|
|
})
|
|
if not log_id:
|
|
self.env["soong.workflow.log"].create({
|
|
'name': '归档',
|
|
"code": self.code,
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"done_by": record_id.log_ids[0].done_by.id,
|
|
"approval_state": "0",
|
|
"node_btn_id": self.node_btn_id.id,
|
|
})
|
|
is_work_remind = True
|
|
else:
|
|
log_id.write({
|
|
'document_ids': [(6, 0, self.document_ids.ids)],
|
|
"approval_state": "2",
|
|
'lase_click_date': fields.Datetime.now(),
|
|
})
|
|
workflow_record.write({
|
|
'approve_state': 'end',
|
|
'soong_state': 'active',
|
|
'employee_ids': False,
|
|
})
|
|
else:
|
|
if workflow_record and self.node_btn_name == '结束':
|
|
workflow_record.sudo().write({
|
|
'approve_state': 'end',
|
|
'employee_ids': False,
|
|
'node_id': False,
|
|
'soong_state': 'done',
|
|
})
|
|
record_id.work_end = True
|
|
# 自动设置审批结果为 不通过
|
|
if any(keyword in current_comment for keyword in ['不同意', '不批准', '不通过']):
|
|
if hasattr(record_id, 'approval_result'):
|
|
record_id.approval_result = 'fail'
|
|
else:
|
|
if hasattr(record_id, 'approval_result'):
|
|
record_id.approval_result = 'pass'
|
|
self.node_btn_id.with_context(cx).run()
|
|
|
|
if is_admin:
|
|
user_log = record_id.log_ids.filtered(
|
|
lambda log: log.done_by == current_user and log.node_btn_name != '1' and log.approval_state == '0'
|
|
)
|
|
if user_log:
|
|
user_log.write({
|
|
'comment': self.comment,
|
|
'approval_state': "2",
|
|
'lase_click_date': current_datetime,
|
|
'document_ids': [(6, 0, self.document_ids.ids)]
|
|
})
|
|
else:
|
|
last_log = record_id.log_ids[-1] if record_id.log_ids else None
|
|
if last_log and last_log.approval_state not in ['2', '3']:
|
|
last_log.sudo().write({
|
|
'comment': self.comment,
|
|
'approval_state': "2",
|
|
'lase_click_date': fields.Datetime.now() - timedelta(hours=8),
|
|
'document_ids': [(6, 0, self.document_ids.ids)]
|
|
})
|
|
self.env['soong.workflow.record'].search([('code', '=', record_id.code)]).write({'approve_state': 'end',
|
|
"employee_ids": False,
|
|
"node_id": False, })
|
|
record_id.work_end = True
|
|
else:
|
|
if record_id.log_ids:
|
|
user_log = record_id.log_ids.filtered(
|
|
lambda log: log.done_by == current_user and log.node_btn_name != '1' and log.approval_state in ['0', '1']
|
|
)
|
|
if user_log:
|
|
user_log.write({
|
|
'comment': self.comment,
|
|
'approval_state': "2",
|
|
'lase_click_date': current_datetime,
|
|
'document_ids': [(6, 0, self.document_ids.ids)]
|
|
})
|
|
if user_log.node_btn_name == '3':
|
|
other_node_logs = self.sudo().env["soong.workflow.log"].search(
|
|
[("model", "=", self.res_model),
|
|
("res_id", "=", self.res_id),
|
|
("id", "!=", user_log.id),
|
|
("node_id", "=", self.node_btn_id.node_id.id)
|
|
])
|
|
for other_node_log in other_node_logs:
|
|
other_node_log.unlink()
|
|
|
|
if (record_id.log_ids2 or record_id.log_ids.filtered(lambda log: log.name == '承办')) and self.node_btn_name == '确认':
|
|
user_log2 = record_id.log_ids2.filtered(lambda log: log.done_by == current_user)
|
|
user_log1 = record_id.log_ids.filtered(lambda log: log.done_by == current_user)
|
|
if user_log2:
|
|
user_log2.write({
|
|
'commit': self.comment,
|
|
'approval_state': "2",
|
|
'lase_click_date': current_datetime,
|
|
})
|
|
if user_log1:
|
|
user_log1.write({
|
|
'comment': self.comment,
|
|
'approval_state': "2",
|
|
'lase_click_date': current_datetime,
|
|
})
|
|
for employee in self.circulated_employee_ids:
|
|
action_id = self.env['ir.actions.act_window'].search([('res_model', '=', self.res_model)])[0]
|
|
url = f'https://oa.thtzjt.com/web#id={record_id.id}&cids=2&action={action_id.id}&model={self.res_model}&view_type=from&menu_id={record_id.id}'
|
|
description = "标题: {}\n".format(record_id.name) + self.env.user.name + ' ' + str(fields.Datetime.now() + timedelta(hours=8))
|
|
workflow_record_id = self.env['soong.workflow.record'].sudo().search([('res_id', '=', record_id.id),
|
|
('res_model', '=', record_id._name)
|
|
])
|
|
workflow_record_id.users_ids = [(4, employee.user_id.id) for employee in self.circulated_employee_ids if employee.user_id]
|
|
workflow_record_id.employee_ids = [(4, employee.id)]
|
|
record_id = self.env[self.res_model].search([('id', '=', self.res_id)])
|
|
self.sudo().env["soong.workflow.record.copy"].create({
|
|
"code": record_id.code,
|
|
"name": record_id.name,
|
|
"res_model": self.res_model,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"res_id": self.res_id,
|
|
"done_by": employee.user_id.id,
|
|
"approval_state_copy": "0",
|
|
})
|
|
if employee.user_id.id not in log_done_by_ids:
|
|
self.sudo().env["soong.workflow.log2"].create({
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"node_id": self.node_btn_id.node_id.id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"done_by": employee.user_id.id,
|
|
"node_btn_id": self.node_btn_id.id,
|
|
"approval_state": "0",
|
|
})
|
|
self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa', user_id=employee.wecom_userid,
|
|
title=record_id._description + "传阅/抄送",
|
|
description=description, url=url,
|
|
btntxt="查看详情")
|
|
|
|
# 给申请人发消息
|
|
if is_work_remind:
|
|
biz_record = self.env[self.res_model].browse(self.res_id)
|
|
if hasattr(biz_record, 'user_id') and biz_record.user_id:
|
|
employee = biz_record.user_id.employee_ids
|
|
elif hasattr(biz_record, 'users_id') and biz_record.users_id:
|
|
employee = biz_record.users_id.employee_ids
|
|
action_id = self.env['ir.actions.act_window'].search([('res_model', '=', self.res_model)])[0]
|
|
recipients = []
|
|
if self.node_btn_id.workflow_id.archive_type == 'applicant':
|
|
biz_record = self.env[self.res_model].browse(self.res_id)
|
|
if hasattr(biz_record, 'user_id') and biz_record.user_id:
|
|
employee = biz_record.user_id.employee_ids
|
|
elif hasattr(biz_record, 'users_id') and biz_record.users_id:
|
|
employee = biz_record.users_id.employee_ids
|
|
recipients.append(employee)
|
|
elif self.node_btn_id.workflow_id.archive_type == 'role':
|
|
role_ids = self.node_btn_id.workflow_id.role_ids
|
|
employees = self.env['hr.employee'].search([
|
|
'|',
|
|
('user_role_id', 'in', role_ids.ids),
|
|
('user_role_ids', 'in', role_ids.ids)
|
|
])
|
|
recipients = [emp for emp in employees]
|
|
else:
|
|
employees = self.node_btn_id.workflow_id.employee_ids
|
|
recipients = [emp for emp in employees]
|
|
for employee in recipients:
|
|
target_url = f'https://oa.thtzjt.com/web#id={record_id.id}&cids=2&active_id={action_id.id}&model={record_id._name}&view_type=form'
|
|
url = self.sudo().env["wecom.apps"].generate_oauth_login_url(target_url, employee.user_id.id)
|
|
if self.res_model == 'purchase.order':
|
|
self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa',
|
|
user_id=employee.wecom_userid,
|
|
title='采购审批单',
|
|
description=f"{record_id.name}审批结束，可采购入库",
|
|
url=url, btntxt="查看详情")
|
|
else:
|
|
self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa',
|
|
user_id=employee.wecom_userid,
|
|
title=title,
|
|
description=f"标题为{record_id.name}的{title}已结束，请归档",
|
|
url=url, btntxt="查看详情")
|
|
self._handle_avoidance()
|
|
if self.node_btn_name == "分发":
|
|
record_id.is_send = True
|
|
menu_id = self.env['ir.ui.menu'].search([('name', '=', '行政收文')], limit=1)
|
|
workflow_record_id = self.env['soong.workflow.record'].sudo().search([('res_id', '=', record_id.id),
|
|
('res_model', '=', record_id._name)
|
|
])
|
|
action_id = self.env['ir.actions.act_window'].search([('res_model', '=', self.res_model)])[0]
|
|
target_url = f'https://oa.thtzjt.com/web#id={record_id.id}&cids=2&menu_id={menu_id.id}&active_id={action_id.id}&model={record_id._name}&view_type=form'
|
|
description = "标题: {}\n".format(record_id.name) + self.env.user.name + ' ' + str(fields.Datetime.now() + timedelta(hours=8))
|
|
if self.employee_ids:
|
|
workflow_record_id.users_ids = [(4, employee.user_id.id) for employee in self.employee_ids if employee.user_id]
|
|
next_node_id = record_id.workflow_id.node_ids.search([('name', '=', '董事长'), ('workflow_id', '=', record_id.workflow_id.id)])
|
|
if record_id.log_ids:
|
|
record_id.log_ids[-1].write({"comment": self.comment, "approval_state": "2", "lase_click_date": fields.Datetime.now()})
|
|
log_id = self.sudo().env["soong.workflow.log"].create({
|
|
"code": self.code,
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"node_id": next_node_id.id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"done_by": self.employee_ids.user_id.id,
|
|
"node_btn_name": "0",
|
|
})
|
|
url = self.sudo().env["wecom.apps"].generate_oauth_login_url(target_url, self.employee_ids.user_id.id)
|
|
result_data = self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa', user_id=self.employee_ids.wecom_userid, title=record_id._description, description=description, url=url, btntxt="查看详情")
|
|
if result_data and 'msgid' in result_data[-1]:
|
|
msg_id = result_data[-1]['msgid']
|
|
log_id.msg_id = msg_id
|
|
for emp in self.dep_manager_employee_ids:
|
|
workflow_record_id.users_ids = [(4, employee.user_id.id) for employee in self.dep_manager_employee_ids if employee.user_id]
|
|
next_node_id = record_id.workflow_id.node_ids.search([('name', '=', '承办'), ('workflow_id', '=', record_id.workflow_id.id)])
|
|
log_id = self.sudo().env["soong.workflow.log"].create({
|
|
"code": self.code,
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"node_id": next_node_id.id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"done_by": emp.user_id.id,
|
|
"node_btn_name": "4",
|
|
})
|
|
url = self.sudo().env["wecom.apps"].generate_oauth_login_url(target_url, emp.user_id.id)
|
|
result_data = self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa', user_id=emp.wecom_userid, title=record_id._description + "承办", description=description, url=url, btntxt="查看详情")
|
|
if result_data and 'msgid' in result_data[-1]:
|
|
msg_id = result_data[-1]['msgid']
|
|
log_id.msg_id = msg_id
|
|
for employee in self.circulated_employee_ids:
|
|
workflow_record_id.users_ids = [(4, employee.user_id.id) for employee in self.circulated_employee_ids if employee.user_id]
|
|
record_id = self.env[self.res_model].search([('id', '=', self.res_id)])
|
|
self.sudo().env["soong.workflow.record.copy"].create({
|
|
"code": record_id.code,
|
|
"name": record_id.name,
|
|
"res_model": self.res_model,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"res_id": self.res_id,
|
|
"done_by": employee.user_id.id,
|
|
"approval_state_copy": "0",
|
|
})
|
|
if employee.user_id.id not in log_done_by_ids:
|
|
log2_domain = [
|
|
('model', '=', self.res_model),
|
|
('res_id', '=', self.res_id),
|
|
('node_id', '=', self.node_btn_id.node_id.id),
|
|
('done_by', '=', employee.user_id.id),
|
|
]
|
|
log2_id = self.sudo().env["soong.workflow.log2"].search(log2_domain, limit=1)
|
|
if not log2_id:
|
|
log2_id = self.sudo().env["soong.workflow.log2"].create({
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"node_id": self.node_btn_id.node_id.id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"done_by": employee.user_id.id,
|
|
"node_btn_id": self.node_btn_id.id,
|
|
"approval_state": "0",
|
|
})
|
|
url = self.sudo().env["wecom.apps"].generate_oauth_login_url(target_url, employee.user_id.id)
|
|
result_data = self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa', user_id=employee.wecom_userid, title=record_id._description + "传阅/抄送",description=description, url=url, btntxt="查看详情")
|
|
if result_data and 'msgid' in result_data[-1]:
|
|
msg_id = result_data[-1]['msgid']
|
|
log2_id.msg_id = msg_id
|
|
workflow_record_id.employee_ids = self.dep_manager_employee_ids + self.employee_ids + self.circulated_employee_ids
|
|
if record_id.log_ids:
|
|
record_id.log_ids[-1].write({"comment": self.comment, "approval_state": "2", "lase_click_date": fields.Datetime.now()})
|
|
if self.node_btn_name == "收回":
|
|
current_user = self.env.user
|
|
record = self.env[self.res_model].search([('id', '=', self.res_id)])
|
|
is_admin = current_user.has_group('base.group_system') or current_user.has_group('base.group_admin')
|
|
log_ids = record.log_ids.sorted('sequence')
|
|
last_normal_log = log_ids.filtered(lambda l: l.name != '加签').sorted('create_date')[-1:]
|
|
# 2. 如果有最后正常节点，只取【这个时间之后】的加签
|
|
if last_normal_log:
|
|
last_create_date = last_normal_log.create_date
|
|
has_sign_log = log_ids.filtered(lambda log:
|
|
log.name == '加签'
|
|
and log.node_id.name == record.state
|
|
and log.create_date > last_create_date # 关键：只取最后正常节点之后的加签
|
|
)
|
|
else:
|
|
has_sign_log = log_ids.filtered(lambda log: log.name == '加签' and log.node_id.name == record.state)
|
|
# 3. 判断这些加签是否已处理
|
|
if has_sign_log:
|
|
for log in has_sign_log:
|
|
if log.approval_state != '0':
|
|
raise UserError('加签流程已处理，不可收回！')
|
|
log_to_delete = has_sign_log
|
|
# 3. 删除后剩下的最后一条日志（取最后一个）
|
|
remaining_logs = log_ids - log_to_delete
|
|
if not remaining_logs:
|
|
raise UserError('无上级审批节点，无法收回')
|
|
prev_log = remaining_logs[-1] # 删除后的最后一条
|
|
# 4. 要删除的经办人 ID 列表
|
|
done_by_list = [log.done_by.id for log in log_to_delete]
|
|
else:
|
|
# 无加签日志
|
|
log_to_delete = log_ids.filtered(lambda log: log.name == record.state)
|
|
if self.res_model == 'yuthon.official.incoming.normal':
|
|
director_logs = log_ids.filtered(lambda log: '董事长' in (log.name or ''))
|
|
if len(director_logs) == 2:
|
|
log_to_delete = log_ids[-1:]
|
|
if not is_admin:
|
|
invalid_logs = log_to_delete.filtered(
|
|
lambda log: log.approval_state in ['1', '2'] and log.node_btn_name != '1'
|
|
)
|
|
if invalid_logs:
|
|
pass
|
|
total_log_count = len(log_ids)
|
|
deleted_log_count = len(log_to_delete)
|
|
prev_log_index = (total_log_count - deleted_log_count) - 1
|
|
other_log_index = total_log_count - deleted_log_count
|
|
if prev_log_index < 0 or prev_log_index >= len(log_ids):
|
|
raise UserError('无有效的上一级审批明细行，无法执行收回操作')
|
|
prev_log = log_ids[prev_log_index]
|
|
done_by_list = []
|
|
for index in range(other_log_index):
|
|
done_by_list.append(log_ids[index].done_by.id)
|
|
|
|
related_record = self.env[self.res_model].browse(self.res_id)
|
|
|
|
if hasattr(related_record, 'self_users_ids'):
|
|
related_record.self_users_ids = [(6, 0, [prev_log.done_by.id])]
|
|
|
|
# 核心写入：使用删除后的最后一条经办人
|
|
self.env['soong.workflow.record'].search([('code', '=', record.code)]).write({
|
|
"employee_ids": [(6, 0, [prev_log.done_by.employee_id.id])],
|
|
"users_ids": [(6, 0, done_by_list)] if not has_sign_log else [(3, user_id) for user_id in done_by_list],
|
|
'soong_state': 'to_do'
|
|
})
|
|
|
|
# 消息回退 + 删除日志
|
|
for log_delete in log_to_delete:
|
|
self.sudo().env["wecom.apps"].back_message(log_delete.msg_id, category='approval')
|
|
log_to_delete.unlink()
|
|
|
|
if record.log_ids2:
|
|
for log_id2 in record.log_ids2:
|
|
self.sudo().env["wecom.apps"].back_message(log_id2.msg_id, category='approval')
|
|
record.log_ids2.unlink()
|
|
|
|
# 把最后一条日志置为处理中
|
|
prev_log.write({'approval_state': '1'})
|
|
|
|
# 回退状态
|
|
if prev_log.name != '归档':
|
|
record.write({
|
|
'state': prev_log.name,
|
|
'work_end': False,
|
|
})
|
|
|
|
if self.node_btn_name == '归档':
|
|
menu_id = self.env['ir.ui.menu'].search([('name', '=', '行政收文')], limit=1)
|
|
action_id = self.env['ir.actions.act_window'].search([('res_model', '=', self.res_model)])[0]
|
|
target_url = f'https://oa.thtzjt.com/web#id={record_id.id}&cids=2&menu_id={menu_id.id}&active_id={action_id.id}&model={record_id._name}&view_type=form'
|
|
description = "标题: {}\n".format(record_id.name) + self.env.user.name + ' ' + str(fields.Datetime.now() + timedelta(hours=8))
|
|
record = self.env[self.res_model].search([('id', '=', self.res_id)])
|
|
if self.res_model == 'purchase.order':
|
|
record.write({'purchase_state': 'done'})
|
|
if record.log_ids:
|
|
_last_log = record.log_ids[-1]
|
|
_last_log.write({'is_active_operate': True,
|
|
'lase_click_date': fields.Datetime.now(),
|
|
'approval_state': '1'
|
|
})
|
|
workflow_record_id = self.env['soong.workflow.record'].sudo().search([('res_id', '=', record_id.id),
|
|
('res_model', '=', record_id._name)
|
|
])
|
|
if not self.circulated_employee_ids:
|
|
if record.log_ids:
|
|
_last_log = record.log_ids[-1]
|
|
_last_log.write({'approval_state': '2'})
|
|
if self.document_ids:
|
|
_last_log.write({'document_ids': [(6, 0, self.document_ids.ids)]})
|
|
_last_log.write({"comment": self.comment})
|
|
workflow_record_id.write({'soong_state': 'active',
|
|
'employee_ids':False
|
|
})
|
|
if self.circulated_employee_ids:
|
|
for employee in self.circulated_employee_ids:
|
|
if employee.user_id.id not in log_done_by_ids:
|
|
log2_domain = [
|
|
('model', '=', self.res_model),
|
|
('res_id', '=', self.res_id),
|
|
('node_id', '=', self.node_btn_id.node_id.id),
|
|
('done_by', '=', employee.user_id.id),
|
|
]
|
|
log2_id = self.sudo().env["soong.workflow.log2"].search(log2_domain, limit=1)
|
|
if not log2_id:
|
|
workflow_record_id.users_ids = [(4, employee.user_id.id) for employee in self.circulated_employee_ids if employee.user_id]
|
|
log2_id = self.sudo().env["soong.workflow.log2"].create({
|
|
"model": self.res_model,
|
|
"res_id": self.res_id,
|
|
"node_id": self.node_btn_id.node_id.id,
|
|
"workflow_id": self.node_btn_id.workflow_id.id,
|
|
"done_by": employee.user_id.id,
|
|
"node_btn_id": self.node_btn_id.id,
|
|
"approval_state": "0",
|
|
})
|
|
url = self.sudo().env["wecom.apps"].generate_oauth_login_url(target_url, employee.user_id.id)
|
|
result_data = self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa',
|
|
user_id=employee.wecom_userid,
|
|
title=record_id._description + "传阅/抄送",
|
|
description=description,
|
|
url=url,
|
|
btntxt="查看详情")
|
|
if result_data and 'msgid' in result_data[-1]:
|
|
msg_id = result_data[-1]['msgid']
|
|
log2_id.msg_id = msg_id
|
|
if self.node_btn_name != "收回":
|
|
tree_id = self.env.ref("soong_workflow.soong_workflow_record_my_tree").id
|
|
kanban_id = self.env.ref("soong_workflow.soong_workflow_record_kanban").id
|
|
# self.red_reload()
|
|
return {
|
|
'type': 'ir.actions.client',
|
|
'tag': 'flush_badge_wkf',
|
|
'params': {
|
|
'tree_id': tree_id,
|
|
'kanban_id': kanban_id,
|
|
'uid': self.env.uid,
|
|
}
|
|
}
|
|
|
|
def _get_all_employee_partners(self):
|
|
all_employees = self.env['hr.employee']
|
|
all_employees |= self.employee_trans_domain_ids
|
|
all_employees |= self.employee_ids
|
|
all_employees |= self.circulated_employee_ids
|
|
all_employees |= self.dep_manager_employee_ids
|
|
all_employees |= self.add_employee_ids
|
|
all_employees |= self.supervising_employee_ids
|
|
all_employees |= self.employee_ids1
|
|
partners = all_employees.filtered(lambda e: e.user_id and e.user_id.partner_id).mapped('user_id.partner_id')
|
|
return partners
|
|
|
|
|
|
def update_self_users_ids(self):
|
|
related_record = self.env[self.res_model].browse(self.res_id)
|
|
if hasattr(related_record, 'self_users_ids'):
|
|
user_ids = [employee.user_id.id for employee in self.employee_ids if employee.user_id]
|
|
related_record.self_users_ids = [(6, 0, user_ids)] if user_ids else [(5,)]
|