Files
gzth/yuthon_issue/models/issue_library.py
T
2026-05-18 16:43:02 +08:00

984 lines
46 KiB
Python

# -*- coding: utf-8 -*-
from email.policy import default
from odoo import api, fields, models, tools
from odoo.exceptions import UserError, ValidationError
from datetime import datetime, timedelta, date
class IssueLibrary(models.Model):
_name = "issue.library"
_description = '议题总库'
_inherit = ['mail.thread.main.attachment', 'mail.activity.mixin']
_rec_name = 'name'
name = fields.Char(string='议题名称')
name_text = fields.Text(string='议题名称', compute='_compute_name', readonly=False, store=True)
depart_opinions = fields.Text(string='部门意见')
topic_content = fields.Text(string='事项背景')
will_based = fields.Text(string='上会依据')
deliberation_content = fields.Text(string='请示事项', default='建议同意')
handling_situation = fields.Text(string='办理情况', help="(存在问题)")
is_invisible_workflow = fields.Boolean(string="流程隐藏的判断")
code = fields.Char(string='编号', required=True, copy=False,
default=lambda self: self.env['ir.sequence'].next_by_code('issue_library_code'))
its_original_state = fields.Char(string='原议题状态')
supporting_department = fields.Text(string='协办部门/单位')
topic_type = fields.Selection([('scrutiny', '审议'), ('learn', '学习'), ('report', '汇报')], string='议题类型', default='scrutiny')
issue_state = fields.Selection([
('to_do', '待推送'),
('draft', '待申报'),
('to_draft', '申报中'),
('to_approval', '待上会审批'),
('approval', '上会审批中'),
('on_approval', '已上会审批'),
('cancel', '已取消'),
('to_modify', '待修改')
], default='to_do', string="议题状态")
is_confirm = fields.Boolean(string="确认")
original_issue_state = fields.Selection([
('to_do', '待推送'),
('draft', '待申报'),
('to_draft', '申报中'),
('to_approval', '待上会审批'),
('approval', '上会审批中'),
('on_approval', '已上会审批'),
('cancel', '已取消')
], string="原始议题状态", help="存储切换到待修改前的原始状态,用于修改完成后还原")
issue_state_party = fields.Selection([('',''), ('will', '待上会'), ('meeting', '上会中'), ('on_meet', '已上会')],
default='will', string="会议状态")
issue_state_class = fields.Selection([('',''), ('will', '待上会'), ('meeting', '上会中'), ('on_meet', '已上会')],
default='will', string="会议状态")
issue_state_boss = fields.Selection([('',''), ('will', '待上会'), ('meeting', '上会中'), ('on_meet', '已上会')],
default='will', string="会议状态")
is_party = fields.Boolean(string="党总支", store=True)
party_char = fields.Char(string=' ')
is_class = fields.Boolean(string="班子会", store=True)
class_char = fields.Char(string=' ')
is_boss = fields.Boolean(string="董事会", store=True)
boss_char = fields.Char(string=' ')
is_note = fields.Boolean(string="上级单位",store=True)
is_district_state = fields.Boolean(string="区国资局", store=True)
is_district_government = fields.Boolean(string="区政府", store=True)
is_district_party = fields.Boolean(string="区委组织部", store=True)
creart_datetime = fields.Date(string="创建日期", default=fields.Datetime.now)
documents_ids = fields.Many2many('ir.attachment', string='议题附件')
issue_type_id = fields.Many2one('issue.type', string="议题类型")
relevancy_type = fields.Selection([('none', '无')], string="关联流程类型")
issue_approval_id = fields.Many2one('issue.approval', string="关联议题审批")
issue_library_line_ids = fields.One2many('issue.library.line', 'issue_library_id', string="决策明细")
issue_library_approval_line_ids = fields.One2many('issue.library.approval.line', 'issue_library_id', string='流程记录')
approval_decision_sequence = fields.Char(string="决策清单事项")
is_booking = fields.Boolean(string="是否上会")
issues_result = fields.Html(string="会议结果")
cs_party = fields.Char(string='党支部会')
cs_class = fields.Char(string='班子会')
cs_boss = fields.Char(string='董事会')
issue_library_room_line_ids = fields.One2many('issue.library.room.line', 'issue_library_id', string="关联会议明细行")
# 权限相关隐藏字段
employee_id = fields.Many2one('hr.employee', string='创建人', default=lambda self: self.env.user.employee_id)
department_id = fields.Many2one('hr.department', string='部门', related='employee_id.department_id')
users_role_ids = fields.Many2many('soong.user.role', string='角色范围', related='employee_id.user_role_ids')
company_id = fields.Many2one('res.company', string='公司', related='employee_id.company_id', store=True)
is_legal_trial = fields.Selection([('no', '否'), ('yes', '是')], string="是否法审", default='no')
co_organizer_dept = fields.Char(string="协办部门/单位")
workflow_id = fields.Many2one('soong.workflow.record', string="流程")
department_personnel_ids = fields.Many2many('res.users', string='部门人员')
is_external_person = fields.Selection([('no', '否'), ('yes', '是')], string="外部人员参会", default='no')
is_admin = fields.Boolean(string='是否管理员', compute='_compute_is_admin')
issue_attendee_line_ids = fields.One2many('issue.library.attendee.line', 'issue_library_id', string='列席人员信息')
issue_external_person_line_ids = fields.One2many('issue.library.external.person.line', 'issue_library_id', string='外部参会人员')
approval_name = fields.Char(string="审批标题")
meeting_place = fields.Char(string="会议地点")
meeting_name = fields.Char(string="会议名称")
active = fields.Boolean('Active', default=True, tracking=True)
urgency_level = fields.Selection([('normal', '普件'), ('urgent', '急件'), ('emergency', '特急件')], string='紧急度',
default='normal')
work_end = fields.Boolean(string="结束")
member_of_department = fields.Boolean("是否是本部门数据", compute='_compute_part_of_department',
search='_search_part_of_department')
is_modify = fields.Boolean(string="是否修改")
is_party_passed = fields.Selection([('',''), ('pass', '通过'), ('reject', '未通过')])
is_class_passed = fields.Selection([('',''), ('pass', '通过'), ('reject', '未通过')])
is_boss_passed = fields.Selection([('',''), ('pass', '通过'), ('reject', '未通过')])
push_invisible = fields.Boolean(string="推送隐藏")
is_push_party = fields.Boolean(string="党推送")
is_push_class = fields.Boolean(string="班子推送")
is_push_boss = fields.Boolean(string="董事推送")
is_push_depart = fields.Boolean(string="部门推送")
is_meeting = fields.Boolean(string="已过会", compute='_compute_meeting', store=True)
def correction_confirm(self):
for rec in self:
rec.is_confirm = False
@api.depends('is_party', 'is_party_passed', 'is_class', 'is_class_passed', 'is_boss', 'is_boss_passed')
def _compute_meeting(self):
for rec in self:
rec.is_meeting = False
enabled = []
rec.is_party and enabled.append(rec.is_party_passed == 'pass')
rec.is_class and enabled.append(rec.is_class_passed == 'pass')
rec.is_boss and enabled.append(rec.is_boss_passed == 'pass')
if enabled and all(enabled):
rec.is_meeting = True
def all_issue_library_line_ids(self):
issue_active_ids = self.env["issue.library"].browse(
self._context.get('active_ids', self._context.get('active_id'))
)
for record in issue_active_ids:
record._compute_meeting()
def meeting_record(self):
self.ensure_one()
domain = [
('id', 'in', self.env['issue.meeting.line'].search([
('issue_library_id', '=', self.id)
]).mapped('meeting_booking_id.id'))
]
return {
'name': '会议详情',
'type': 'ir.actions.act_window',
'view_mode': 'tree,form',
'res_model': 'room.booking',
'domain': domain,
'target': 'current',
}
def action_is_modify(self):
for rec in self:
rec.issue_state = rec.original_issue_state
rec.original_issue_state = False
def issue_party_approval(self):
issue_active_ids = self.env["issue.library"].browse(
self._context.get('active_ids', self._context.get('active_id'))
)
line_list = []
for record in issue_active_ids:
if record.issue_state != 'to_approval':
raise UserError("该议题状态不能审批")
record.issue_state = 'approval'
line_list.append((0, 0, {
'issue_id': record.id,
'name': record.name,
'will_based': record.will_based,
'department_id': record.department_id.id,
}))
return {
'type': 'ir.actions.act_window',
'name': '党议题审批',
"target": "current",
'res_model': 'issue.party.approval',
'view_mode': 'form',
'context': {
'default_state':'申请人',
'default_name_title': '党总支议题审批',
'default_line_ids': line_list,
}
}
def issue_party1_approval(self):
issue_active_ids = self.env["issue.library"].browse(
self._context.get('active_ids', self._context.get('active_id'))
)
line_list = []
for record in issue_active_ids:
if record.issue_state != 'to_approval':
raise UserError("该议题状态不能审批")
record.issue_state = 'approval'
line_list.append((0, 0, {
'issue_id': record.id,
'name': record.name,
'will_based': record.will_based,
'department_id': record.department_id.id,
}))
return {
'type': 'ir.actions.act_window',
'name': '党议题审批',
"target": "current",
'res_model': 'issue.party.approval',
'view_mode': 'form',
'context': {
'default_state':'申请人',
'default_name_title': '党支部议题审批',
'default_line_ids': line_list,
}
}
def refunded(self):
for rec in self:
refund_update_vals = {}
if rec.is_party and (rec.is_party_passed == 'reject' or not rec.is_party_passed):
refund_update_vals['is_push_party'] = False
elif rec.is_class and (rec.is_class_passed == 'reject' or not rec.is_class_passed):
refund_update_vals['is_push_class'] = False
elif rec.is_boss and (rec.is_boss_passed == 'reject' or not rec.is_boss_passed):
refund_update_vals['is_push_boss'] = False
if refund_update_vals:
rec.push_invisible = False
rec.write(refund_update_vals)
def issue_class_approval(self):
issue_active_ids = self.env["issue.library"].browse(
self._context.get('active_ids', self._context.get('active_id'))
)
line_list = []
for record in issue_active_ids:
if record.issue_state != 'to_approval':
raise UserError("该议题状态不能审批")
record.issue_state = 'approval'
line_list.append((0, 0, {
'issue_id': record.id,
'name': record.name,
'will_based': record.will_based,
'department_id': record.department_id.id,
}))
return {
'type': 'ir.actions.act_window',
'name': '班子议题审批',
"target": "current",
'res_model': 'issue.class.approval',
'view_mode': 'form',
'context': {
'default_state': '申请人',
'default_line_ids': line_list,
}
}
def issue_boss_approval(self):
issue_active_ids = self.env["issue.library"].browse(
self._context.get('active_ids', self._context.get('active_id'))
)
line_list = []
for record in issue_active_ids:
if record.issue_state != 'to_approval':
raise UserError("该议题状态不能审批")
record.issue_state = 'approval'
line_list.append((0, 0, {
'issue_id': record.id,
'name': record.name,
'will_based': record.will_based,
'department_id': record.department_id.id,
}))
return {
'type': 'ir.actions.act_window',
'name': '董事议题审批',
"target": "current",
'res_model': 'issue.boss.approval',
'view_mode': 'form',
'context': {
'default_state': '申请人',
'default_line_ids': line_list,
}
}
@api.onchange('issue_library_line_ids',
'issue_library_line_ids.issue_approval_decision_id',
'issue_library_line_ids.district_state_id',
'issue_library_line_ids.district_government_id',
'issue_library_line_ids.district_party_id')
def _onchange_will_based(self):
for record in self:
will_based_lines = []
# 遍历明细行,保留原有逻辑,仅调整触发方式
for idx, line in enumerate(record.issue_library_line_ids, start=1):
# 获取各字段值,无值则为空字符串
decision_name = line.issue_approval_decision_id.specifics or ""
district_state_name = line.district_state_id.name or ""
district_government_name = line.district_government_id.name or ""
district_party_name = line.district_party_id.name or ""
field_parts = []
# 按规则拼接字段内容
if decision_name:
field_parts.append(decision_name)
if district_state_name:
field_parts.append(f"区国资局({district_state_name})")
if district_government_name:
field_parts.append(f"区政府({district_government_name})")
if district_party_name:
field_parts.append(f"区委组织部({district_party_name})")
if field_parts:
line_content = f"{idx}.{','.join(field_parts)}"
will_based_lines.append(line_content)
record.will_based = "\n".join(will_based_lines)
def correction(self):
for rec in self:
menu_id = self.env['ir.ui.menu'].search([('name', '=', '我的议题')])
url = f'https://oa.thtzjt.com/web#id={self.id}&cids=2&action={menu_id.action.id}&model=yuthon.notice&view_type=list&menu_id={menu_id.id}'
self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa',
user_id=rec.employee_id.wecom_userid,
title="议题修正",
description="您有待修正的议题,请尽快修正",
url=url, btntxt="详细信息")
rec.write({
'original_issue_state': rec.issue_state,
'issue_state': 'to_modify',
'is_confirm': True,
})
def depart_push(self):
for rec in self:
rec.is_push_depart = True
rec.issue_state = 'draft'
def library_push(self):
for rec in self:
push_update_vals = {}
if rec.is_party and (rec.is_party_passed == 'reject' or not rec.is_party_passed):
push_update_vals['is_push_party'] = True
push_update_vals['issue_state_party'] = False
elif rec.is_class and (rec.is_class_passed == 'reject' or not rec.is_class_passed):
push_update_vals['is_push_class'] = True
push_update_vals['issue_state_class'] = False
elif rec.is_boss and (rec.is_boss_passed == 'reject' or not rec.is_boss_passed):
push_update_vals['is_push_boss'] = True
push_update_vals['issue_state_boss'] = False
if push_update_vals:
rec.push_invisible = True
rec.write(push_update_vals)
def _compute_is_admin(self):
is_admin = self.env.user.has_group('base.group_system')
for rec in self:
rec.is_admin = is_admin
@api.onchange('is_legal_trial')
def _onchange_is_legal_trial(self):
self.department_personnel_ids = [(5, 0, 0)]
if self.is_legal_trial:
if self.department_id:
target_department_ids = self.env['hr.department'].search([
('id', 'child_of', self.department_id.id)
]).ids
target_employees = self.env['hr.employee'].search([
('department_id', 'in', target_department_ids),
('user_state', '=', 'in')
])
self.department_personnel_ids = [(6, 0, target_employees.user_id.ids)]
else:
self.department_personnel_ids = [(5, 0, 0)]
def add_workflow(self):
return {
'name': '流程添加弹窗',
'type': 'ir.actions.act_window',
'view_mode': 'form',
'res_model': 'issue.line.add.wizard',
"target": "new",
'context': {
'default_issue_id': self.id,
},
}
@api.depends_context('uid', 'company')
@api.depends('department_id')
def _compute_part_of_department(self):
is_manager = self.env.user.has_group('soong_workflow.group_soong_workflow_manager')
if is_manager:
# 管理员可以看到所有数据,全部标记为 True
for employee in self:
employee.member_of_department = True
return
user_employee = self._get_valid_employee_for_user()
active_department = user_employee.department_id
if active_department:
department_ids = self.env['hr.department'].search([
('id', 'child_of', active_department.id)
]).ids
else:
department_ids = []
for employee in self:
employee.member_of_department = employee.department_id.id in department_ids
def _get_valid_employee_for_user(self):
user = self.env.user
employee = user.employee_ids
if not employee:
user_employees = user.employee_id.sudo().search([
('user_id', '=', user.id)
])
employee = user_employees.filtered(lambda r: r.company_id == user.company_id) or user_employees[:1]
return employee
def _search_part_of_department(self, operator, value):
# 检查当前用户是否属于管理员群组
is_manager = self.env.user.has_group('soong_workflow.group_soong_workflow_manager')
if is_manager:
# 管理员搜索时返回所有数据(domain 为空)
if (operator == '=' and value) or (operator == '!=' and not value):
return []
# 如果搜索条件是 False,则返回空数据
elif (operator == '=' and not value) or (operator == '!=' and value):
return [('id', '=', False)]
user_employee = self._get_valid_employee_for_user()
active_department = user_employee.department_id
if active_department:
base_domain = [('department_id', 'child_of', active_department.id)]
else:
base_domain = [('department_id', '=', False)]
return (['!'] if operator == '!=' else []) + base_domain
def _get_default_name_title(self):
return '我的议题'
name_title = fields.Char(default=_get_default_name_title)
def read_number(self):
return self.search_count([
('issue_state', '=', 'draft'),
('employee_id.user_id', '=', self.env.user.id)
])
@api.onchange('issue_library_line_ids')
def onchange_approval_decision_sequence(self):
for dec in self:
specifics_list = []
for line in dec.issue_library_line_ids:
if line.issue_approval_decision_id.specifics:
specifics_list.append(line.issue_approval_decision_id.specifics)
dec.approval_decision_sequence = ';'.join(specifics_list) if specifics_list else ''
def revoke(self):
self.write({'is_push_depart': False,
'issue_state': 'to_do'})
if self.issue_approval_id:
issue_line_records = self.env['issue.approval.line'].search([
('issue_approval_id', '=', self.issue_approval_id.id)
])
if issue_line_records:
issue_line_records.unlink()
workflow_id = self.env['soong.workflow.record'].search([('res_model', '=', 'issue.approval'),
('res_id', '=', self.issue_approval_id.id)], limit=1)
if workflow_id:
workflow_id.sudo().unlink()
self.issue_approval_id.unlink()
def all_issue_pull(self):
# 1. 获取选中的议题库记录
issue_active_ids = self.env["issue.library"].browse(
self._context.get('active_ids', self._context.get('active_id'))
)
# 校验选中记录的状态(非草稿不允许提交)
for i in issue_active_ids:
if i.issue_state != 'draft':
raise UserError("当前状态不允许提交")
# 2. 查找已存在的关联 issue.approval 记录
existing_approval = self.env['issue.approval'].search([
('issue_approval_ids.issue_library_id', 'in', issue_active_ids.ids),
], limit=1)
# 3. 拼接审批单名称
specifics_list = [rec.name for rec in issue_active_ids]
name = ','.join(specifics_list) if len(specifics_list) > 1 else (
self.name or specifics_list[0] if specifics_list else "")
if existing_approval:
issue_approval_id = existing_approval
# 获取已有审批单中已关联的议题库 ID
existing_issue_ids = issue_approval_id.issue_approval_ids.mapped('issue_library_id').ids
# 筛选出选中但未关联的议题库记录
new_issue_records = issue_active_ids.filtered(lambda r: r.id not in existing_issue_ids)
if new_issue_records:
new_lines = []
for issue_record in new_issue_records:
new_lines.append((0, 0, {
'issue_library_id': issue_record.id,
'approval_decision_sequence': issue_record.approval_decision_sequence,
'employee_id': issue_record.employee_id.id
}))
# 追加新行到已有审批单
issue_approval_id.write({
'issue_approval_ids': new_lines,
'name': name
})
self.issue_approval_id = issue_approval_id
else:
issue_decision_lines = []
for issue_record in issue_active_ids:
issue_decision_lines.append((0, 0, {
'issue_library_id': issue_record.id,
'approval_decision_sequence': issue_record.approval_decision_sequence,
'employee_id': issue_record.employee_id.id
}))
issue_approval_id = self.env['issue.approval'].create({
'issue_approval_ids': issue_decision_lines,
'name': name,
})
self.issue_approval_id = issue_approval_id
form_id = self.env.ref("yuthon_issue.issue_library_approval_form").id
return {
"type": "ir.actions.act_window",
"name": "提交议题申报",
"res_model": "issue.approval",
"views": [[form_id, "form"]],
"res_id": issue_approval_id.id,
"context": {
"id": issue_approval_id.id,
"is_issue": True,
}
}
def single_issue_pull(self):
if self.issue_state != 'draft':
raise UserError("当前状态不允许提交")
form_id = self.env.ref("yuthon_issue.issue_library_approval_form").id
issue_decision_lines = [(0, 0, {
'issue_library_id': self.id,
'approval_decision_sequence': self.approval_decision_sequence,
'employee_id': self.employee_id.id
})]
issue_approval_id = self.env['issue.approval'].create({
'issue_approval_ids': issue_decision_lines,
'name': self.name,
'employee_id': self.employee_id.id,
})
self.write({"issue_state": "approval"})
self.issue_approval_id = issue_approval_id
return {
"type": "ir.actions.act_window",
"name": "提交审批",
"res_model": "issue.approval",
"views": [[form_id, "form"]],
"res_id": issue_approval_id.id,
"context": {
"id": issue_approval_id.id,
"is_issue": True,
}
}
def issue_cancel(self):
self.write({"issue_state": "cancel"})
def all_meeting_issue(self):
issue_active_ids = self.env["issue.library"].browse(
self._context.get('active_ids', self._context.get('active_id', [])))
current_user = self.env.user
user_company_name = current_user.company_id.name if current_user.company_id else ""
action_id = self._context.get('from_action')
for ras in issue_active_ids:
issue_details = []
target_meeting_type_id = False
meeting_priority = [
('is_party', 'is_party_passed', None),
('is_class', 'is_class_passed', '班子'),
('is_boss', 'is_boss_passed', '董事'),
]
def get_all_sub_departments(department):
dept_ids = [department.id]
sub_depts = self.env['hr.department'].search([('parent_id', '=', department.id)])
for sub_dept in sub_depts:
dept_ids += get_all_sub_departments(sub_dept)
return dept_ids
all_dept_ids = get_all_sub_departments(ras.department_id)
target_employees = self.env['hr.employee'].search([
('department_id', 'in', all_dept_ids),
('active', '=', True)
])
# 先匹配出最终会议类型(原有逻辑)
for issue in issue_active_ids:
if target_meeting_type_id:
continue
# 按「党→班子→董事」优先级匹配
for idx, (field_flag, field_passed, keyword) in enumerate(meeting_priority):
if not getattr(issue, field_flag, False):
continue
passed_result = getattr(issue, field_passed, '')
if passed_result in (False, 'reject'):
if idx == 0:
party_meeting_name = "党总支" if user_company_name == "集团本部" else "党支委"
meeting_type = self.env['room.meeting.type'].search([('name', 'ilike', party_meeting_name)],
limit=1)
else:
meeting_type = self.env['room.meeting.type'].search([('name', 'ilike', keyword)], limit=1)
if meeting_type:
target_meeting_type_id = meeting_type.id
break
elif passed_result == 'pass':
continue
# 天河粮储 套会逻辑
if len(issue_active_ids) == 2 and all(ras.company_id.name == "天河粮储" for ras in issue_active_ids):
record_a, record_b = issue_active_ids
condition = ((getattr(record_a, 'is_party', False) and not getattr(record_b, 'is_party',
False) and getattr(record_b,
'is_class',
False))
or (getattr(record_b, 'is_party', False) and not getattr(record_a, 'is_party',
False) and getattr(record_a,
'is_class',
False)))
all_char_empty = (
not getattr(record_a, 'party_char', '') and not getattr(record_a, 'class_char', '')
and not getattr(record_b, 'party_char', '') and not getattr(record_b, 'class_char', ''))
if condition and all_char_empty:
meeting_type_with_tao = self.env['room.meeting.type'].search([('name', 'ilike', '套')], limit=1)
if meeting_type_with_tao:
target_meeting_type_id = meeting_type_with_tao.id
# ====================== 核心新增:判断会议名称是否含「党」 ======================
meeting_type_has_dang = False
if target_meeting_type_id:
meeting_type = self.env['room.meeting.type'].browse(target_meeting_type_id)
# 判断会议类型名称是否包含 "党" 字
if meeting_type.name and '党' in meeting_type.name:
meeting_type_has_dang = True
# 生成议题明细,根据是否含党字设置 is_sanda
for issue in issue_active_ids:
dept_manager = self.env['hr.employee'].sudo().search([
('active', '=', True),
'|',
('user_role_id.name', '=', '部门经理'),
('user_role_ids.name', '=', '部门经理'),
'|',
('department_id', '=', issue.department_id.id),
('department_ids', 'in', [issue.department_id.id])
], limit=1)
# 关键:会议名称含党 → is_sanda=True,否则 False
issue_details.append((0, 0, {
'issue_library_id': issue.id,
'employee_id': dept_manager.id if dept_manager else False,
'designated_person_ids': [(6, 0, target_employees.ids)],
'is_sanda': meeting_type_has_dang, # 自动赋值
}))
form_id = self.env.ref("room.room_booking_view_form", raise_if_not_found=False)
return {
"type": "ir.actions.act_window",
"name": "批量上会",
"res_model": "room.booking",
"views": [[form_id.id, "form"]],
"context": {
'default_is_issue': True,
'default_state': '申请人',
'default_meeting_type_id': target_meeting_type_id,
'default_start_datetime': fields.Datetime.now() + timedelta(hours=8),
'default_issue_meeting_line_ids': issue_details,
},
}
def single_meeting_issue(self):
issue = self.env["issue.library"].browse(self.id)
current_user = self.env.user
user_company_name = current_user.company_id.name if current_user.company_id else ""
issue_details = []
target_meeting_type_id = False
meeting_priority = [
('is_party', 'is_party_passed', None), # 党总支:动态匹配名称(集团本部=党总支/其他=党支委)
('is_class', 'is_class_passed', '班子'), # 班子会:匹配含「班子」的名称
('is_boss', 'is_boss_passed', '董事'), # 董事会:匹配含「董事」的名称
]
def get_all_sub_departments(department):
dept_ids = [department.id]
sub_depts = self.env['hr.department'].search([('parent_id', '=', department.id)])
for sub_dept in sub_depts:
dept_ids += get_all_sub_departments(sub_dept)
return dept_ids
all_dept_ids = get_all_sub_departments(self.department_id)
target_employees = self.env['hr.employee'].search([
('department_id', 'in', all_dept_ids),
('active', '=', True)
])
target_dept_names = ['办公室', '财务部', '风控法务部', '纪检审计部', '综合办公室']
target_managers = self.env['hr.employee'].search([
('company_id', '=', current_user.company_id.id),
('department_id.name', 'in', target_dept_names),
('active', '=', True),
'|',
('user_role_id.name', '=', '部门经理'),
('user_role_ids.name', '=', '部门经理'),
])
manager_employee = self.env['hr.employee'].search([
('id', 'in', target_managers.ids),
'|',
('user_role_id.name', '=', '部门经理'),
('user_role_ids.name', '=', '部门经理')
], limit=1)
attendees_ids = []
if target_managers and manager_employee:
attendees_ids = target_managers.filtered(lambda emp: emp.id != manager_employee.id).ids
elif target_managers:
attendees_ids = target_managers.id
# 先匹配会议类型
for issue in self:
if target_meeting_type_id:
continue
# 按「党→班子→董事」优先级匹配
for idx, (field_flag, field_passed, keyword) in enumerate(meeting_priority):
if not getattr(issue, field_flag, False):
continue
passed_result = getattr(issue, field_passed, '')
if passed_result in (False, 'reject'):
if idx == 0:
if user_company_name == "集团本部":
party_meeting_name = "党总支"
else:
party_meeting_name = "党支委"
meeting_type = self.env['room.meeting.type'].search([
('name', 'ilike', party_meeting_name)
], limit=1)
else:
meeting_type = self.env['room.meeting.type'].search([
('name', 'ilike', keyword)
], limit=1)
if meeting_type:
target_meeting_type_id = meeting_type.id
break
elif passed_result == 'pass':
continue
meeting_type_has_dang = False
if target_meeting_type_id:
meeting_type = self.env['room.meeting.type'].browse(target_meeting_type_id)
if meeting_type.name and '党' in meeting_type.name:
meeting_type_has_dang = True
for issue in self:
issue_details.append((0, 0, {
'issue_library_id': issue.id,
'employee_id': manager_employee.id if manager_employee else False,
'designated_person_ids': [(6, 0, target_employees.ids)],
'attendees_ids': [(6, 0, attendees_ids)],
'is_sanda': meeting_type_has_dang,
}))
form_id = self.env.ref("room.room_booking_view_form").id
return {
"type": "ir.actions.act_window",
"name": "单个上会",
"res_model": "room.booking",
"views": [[form_id, "form"]],
"context": {
'default_is_issue': True,
'default_state': '申请人',
'default_meeting_type_id': target_meeting_type_id,
'default_start_datetime': fields.Datetime.now() + timedelta(hours=8),
'default_issue_meeting_line_ids': issue_details,
}
}
def approval_details(self):
self.ensure_one()
for record in self:
if not record.issue_approval_id:
raise UserError('请提交审批后查看')
form_id = self.env.ref("yuthon_issue.issue_library_approval_form").id
return{
"type": "ir.actions.act_window",
"name": "审批详情",
"res_model": "issue.approval",
"views": [[form_id, "form"]],
"res_id": record.issue_approval_id.id
}
@api.onchange('issue_library_line_ids')
def _onchange_issue_library_line_ids(self):
for record in self:
record.is_party = bool(record.issue_library_line_ids.filtered(lambda rec: rec.council_id))
record.is_class = bool(record.issue_library_line_ids.filtered(lambda rec: rec.team_meet_id))
record.is_boss = bool(record.issue_library_line_ids.filtered(lambda rec: rec.board_meet_id))
record.is_district_state = bool(record.issue_library_line_ids.filtered(lambda rec: rec.district_state_id))
record.is_district_government = bool(
record.issue_library_line_ids.filtered(lambda rec: rec.district_government_id))
record.is_district_party = bool(record.issue_library_line_ids.filtered(lambda rec: rec.district_party_id))
record.is_note = any([
bool(record.issue_library_line_ids.filtered(
lambda rec: rec.issue_approval_decision_id and rec.issue_approval_decision_id.district_state_id)),
bool(record.issue_library_line_ids.filtered(
lambda
rec: rec.issue_approval_decision_id and rec.issue_approval_decision_id.district_government_id)),
bool(record.issue_library_line_ids.filtered(
lambda rec: rec.issue_approval_decision_id and rec.issue_approval_decision_id.district_party_id))
])
def unlink(self):
for i in self:
if i.issue_state == 'on_meet':
raise UserError('议题已上会,不能删除')
return super().unlink()
def my_unlink(self):
is_admin = self.env.user.has_group('base.group_system')
current_user = self.env.user
for i in self:
if i.issue_state == 'on_meet':
raise UserError('议题已上会,不能删除')
if not is_admin:
if i.employee_id.user_id != current_user:
raise UserError('只能删除自己的记录,无权删除他人数据')
@api.depends('name')
def _compute_name(self):
for record in self:
record.name_text = record.name
@api.model
def name_search(self, name='', args=None, operator='ilike', limit=100):
args = args or []
domain = []
if name:
domain = ['|', '|', ('name', operator, name), ('code', operator, name), ('name_text', operator, name)]
return self.search(domain + args, limit=limit).name_get()
@api.onchange('issue_library_room_line_ids')
def _onchange_issue_library_room_line_ids(self):
for record in self.issue_library_room_line_ids:
if record.meeting_type_id.name == '党委会':
self.cs_party = record.room_booking_id.name
elif record.meeting_type_id.name == '班子会':
self.cs_class = record.room_booking_id.name
elif record.meeting_type_id.name == '董事会':
self.cs_boss = record.room_booking_id.name
@api.onchange('is_booking')
def _onchange_is_booking(self):
if self.is_booking:
issue_id = self.env['issue.library'].create({'name': self.name})
self.related_issues_id = issue_id.id
workflow_record_id = self.env["soong.workflow.record"].search(
[("res_model", "=", self._name), ("res_id", "=", self.id)])
self.env['issue.library.approval.line'].create({
'issue_library_id': issue_id.id,
'workflow_record_id': workflow_record_id.id,
'approval_type': workflow_record_id.workflow_id.id,
'code': self.code,
'approval_date': fields.Datetime.now(),
})
elif self.related_issues_id:
raise UserError("已经创建了相关的上会记录,不能取消勾选")
class IssueLibraryLine(models.Model):
_name = "issue.library.line"
_description = '决策清单明细'
issue_library_id = fields.Many2one('issue.library')
issue_approval_decision_id = fields.Many2one('issue.approval.decision', string="上会依据")
council_id = fields.Many2one(related='issue_approval_decision_id.council_id', string='党总支')
team_meet_id = fields.Many2one(related='issue_approval_decision_id.team_meet_id', string='经营班子会')
board_meet_id = fields.Many2one(related='issue_approval_decision_id.board_meet_id', string='董事会')
district_state_id = fields.Many2one(related='issue_approval_decision_id.district_state_id', string="区国资局")
district_government_id = fields.Many2one(related='issue_approval_decision_id.district_government_id', string="区政府")
district_party_id = fields.Many2one(related='issue_approval_decision_id.district_party_id', string="区委组织部")
ordinal = fields.Char(related='issue_approval_decision_id.sequence', string='序号')
remarks = fields.Text(related='issue_approval_decision_id.remarks', string="备注")
class IssueLibraryApprovalLine(models.Model):
_name = "issue.library.approval.line"
_description = '关联流程明细'
_order = 'approval_date desc'
issue_library_id = fields.Many2one('issue.library', string="关联议题")
workflow_name = fields.Char(string="标题", compute='compute_issue_soong')
code = fields.Char(string="流程编号")
approval_type = fields.Char(string="类型", compute='compute_issue_soong')
approval_date = fields.Datetime(string="创建日期")
res_model = fields.Char(string="模型", compute='compute_issue_soong')
res_id = fields.Char(string="id", compute='compute_issue_soong')
department_id = fields.Many2one('hr.department', string='部门', compute='compute_issue_soong')
@api.depends('code')
def compute_issue_soong(self):
for rec in self:
workflow_record_id = self.env['soong.workflow.record'].search([('code', '=', rec.code)], limit=1)
if workflow_record_id:
rec.approval_type = workflow_record_id.workflow_id.name
rec.res_model = workflow_record_id.res_model
rec.res_id = workflow_record_id.res_id
rec.workflow_name = workflow_record_id.name
record_id = self.env[workflow_record_id.res_model].search([('id', '=', workflow_record_id.res_id)])
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
rec.department_id = query_user_id.employee_ids.department_id.id
else:
rec.approval_type = ''
rec.res_model = ''
rec.res_id = ''
rec.department_id = ''
rec.workflow_name = ''
def open_record(self):
return {
"type": "ir.actions.act_window",
"res_model": self.res_model,
"res_id": int(self.res_id),
"name": self.workflow_name,
"view_mode": "form",
}
class IssueLibraryAttendeeLine(models.Model):
_name = "issue.library.attendee.line"
_description = '列席人员信息明细'
issue_library_id = fields.Many2one('issue.library', string="关联议题")
attendee_name = fields.Char(string='姓名')
company_id = fields.Many2one('res.company', string='公司')
department_id = fields.Many2one('hr.department', string='部门')
job_position = fields.Char(string='岗位')
class IssueLibraryExternalPersonLine(models.Model):
_name = "issue.library.external.person.line"
_description = '外部参会人员明细'
issue_library_id = fields.Many2one('issue.library', string="关联议题")
person_name = fields.Char(string='姓名')
company_unit = fields.Char(string='单位/公司')
job_title = fields.Char(string='职务')
phone = fields.Char(string='联系电话')
class IssueLibraryRoomLine(models.Model):
_name = "issue.library.room.line"
_description = '关联会议明细'
issue_library_id = fields.Many2one('issue.library', string="关联议题")
room_booking_id = fields.Many2one('room.booking', string="会议名称")
room_id = fields.Many2one('room.room', string="会议地点")
meeting_type_id = fields.Many2one('room.meeting.type', string="会议类型")
approval_date = fields.Datetime(string="创建日期")
def open_record(self):
self.ensure_one()
return {
'type': 'ir.actions.act_window',
'res_model': 'room.booking',
'res_id': self.room_booking_id.id,
'view_mode': 'form',
'target': 'current',
}