1411 lines
68 KiB
Python
1411 lines
68 KiB
Python
# -*- coding: utf-8 -*-
|
||
|
||
from dateutil.relativedelta import relativedelta
|
||
from pypinyin import pinyin, lazy_pinyin, STYLE_FIRST_LETTER
|
||
from odoo.osv import expression
|
||
from odoo import api, fields, models
|
||
from datetime import date, datetime
|
||
from odoo.exceptions import UserError, ValidationError
|
||
import math
|
||
from datetime import timedelta
|
||
|
||
nation_list = [('a', '汉族'), ('b', '壮族'), ('v', '满族'), ('d', '回族'), ('e', '苗族'), ('f', '维吾尔族'),
|
||
('g', '土家族'), ('h', '彝族'), ('i', '蒙古族'), ('j', '藏族'), ('k', '布依族'), ('l', '侗族'),
|
||
('m', '瑶族'), ('n', '朝鲜族'), ('o', '白族'), ('p', '哈尼族'), ('q', '哈萨克族'), ('r', '黎族'),
|
||
('s', '傣族'), ('t', '畲族'), ('u', '傈僳族'), ('v', '仡佬族'), ('w', '东乡族'), ('x', '拉祜族'),
|
||
('y', '水族'), ('z', '佤族'), ('a1', '纳西族'), ('b1', '羌族'), ('c1', '仫佬族'), ('d1', '锡伯族'),
|
||
('e1', '柯尔克孜族'), ('f1', '达斡尔族'), ('g1', '景颇族'), ('h1', '毛南族'), ('i1', '撒拉族'),
|
||
('j1', '布朗族'), ('k1', '塔吉克族'), ('l1', '阿昌族'), ('m1', '普米族'), ('n1', '鄂温克族'), ('o1', '怒族'),
|
||
('p1', '京族'), ('q1', '基诺族'), ('r1', '德昂族'), ('s1', '保安族'), ('t1', '俄罗斯族'), ('u1', '裕固族'),
|
||
('v1', '乌孜别克族'), ('w1', '门巴族'), ('x1', '鄂伦春族'), ('y1', '独龙族'), ('z1', '塔塔尔族'), ('a2', '赫哲族'),
|
||
('b2', '高山族'), ('c2', '珞巴族'), ('d2', '壮族')]
|
||
|
||
|
||
class YuthonHrEmployee(models.Model):
|
||
"""
|
||
对原模型数据的隐藏，字段的开发和添加
|
||
"""
|
||
_inherit = "hr.employee"
|
||
_order = 'number asc'
|
||
|
||
# name = fields.CharWithPinyin(default_export_compatible=True)
|
||
user_role_ids_changed = fields.Boolean(string="xxx") # bug
|
||
compress_image = fields.Binary(string="压缩头像", attachment=True)
|
||
wecom_userid = fields.Char(string="成员UserID", related="user_id.oauth_uid")
|
||
company_ids = fields.Many2many('res.company', related="user_id.company_ids")
|
||
role_allowed_company_ids = fields.Many2many('res.company', compute='_compute_role_allowed_company_ids')
|
||
|
||
@api.depends('company_ids')
|
||
def _compute_role_allowed_company_ids(self):
|
||
thtz = self.env['res.company'].search([('name', '=', '天河投资集团')], limit=1)
|
||
for rec in self:
|
||
companies = rec.company_ids
|
||
if thtz and thtz not in companies:
|
||
companies |= thtz
|
||
rec.role_allowed_company_ids = companies
|
||
|
||
number = fields.Char(string="序号", store=True)
|
||
is_soldiers = fields.Boolean(string="是否为退伍军人")
|
||
user_number = fields.Char(string="员工编号", default=lambda self: self.env['ir.sequence'].next_by_code('employee_code'))
|
||
use_user_type = fields.Selection([('formal_one', '正式合同(一签)'), ('labor', '劳务协议'), ('formal_two', '正式合同(二签)'),
|
||
('formal_none', '正式合同(无固定)'),
|
||
('part_time', '兼职协议'), ('employment', '用工协议'), ('internship', '实习协议')], string="用工形式")
|
||
contract_type_id = fields.Many2one(related='contract_id.contract_type_id', string="用工形式")
|
||
date_end = fields.Date(string="合同结束日期", compute='_compute_date_end')
|
||
# version = fields.Char(related='contract_id.version', string="版本")
|
||
end_comparison = fields.Selection([('red', '小于30天'), ('yellow', '小于60天'), ('blue', '小于90天')], string="结束时间对比(颜色)",
|
||
compute='_compute_end_comparison', store=True)
|
||
|
||
# 个人信息
|
||
user_salary = fields.Float(string="基本工资")
|
||
home_address = fields.Char(string="家庭住址")
|
||
job_lv_salary = fields.Float(string="职级工资")
|
||
user_sex = fields.Selection([('girl', '女'), ('boy', '男')], string="性别")
|
||
user_state = fields.Selection([('in', '在职'), ('leave', '离职'), ('withdraw', '退休'), ('borrow', '借调'),
|
||
('expatriate', '外派'), ('adjunct', '在职（兼职）')],
|
||
string="员工状态", default='in')
|
||
user_number_start_time = fields.Date(string="身份证开始时间")
|
||
user_role_id = fields.Many2one('soong.user.role', string="主角色")
|
||
user_role_ids = fields.Many2many('soong.user.role', string="辅助角色")
|
||
role_group_ids = fields.Many2many('soong.user.role.group', string='角色组')
|
||
department_ids = fields.Many2many('hr.department', string="辅助部门")
|
||
user_number_end_time = fields.Date(string="身份证到期时间")
|
||
is_identification = fields.Boolean(string="是否填写身份证")
|
||
card_documents_id = fields.Many2one('ir.attachment', string="身份证正面")
|
||
card_back_documents_id = fields.Many2one('ir.attachment', string="身份证反面")
|
||
hukou_documents_id = fields.Many2one('ir.attachment', string="户口本")
|
||
marriage_documents_id = fields.Many2one('ir.attachment', string="结婚证")
|
||
nation = fields.Selection(nation_list, string="民族")
|
||
old = fields.Integer(string="年龄", compute='_compute_info', store=True)
|
||
birthday = fields.Date(string="出生年月", compute='_compute_info', tracking=False)
|
||
birthday_month = fields.Integer(string="生日月份", compute='_compute_info')
|
||
user_type = fields.Char(string="人员类别")
|
||
retire_date = fields.Date(string="退休日期")
|
||
retire_years = fields.Integer(string="离退休年限", compute='_compute_retire_years')
|
||
political_aspects = fields.Selection([('cpc_dang', '中共党员'), ('nld', '民盟'),
|
||
('league_member', '共青团员'), ('people', '群众')], string="政治面貌")
|
||
dang_data = fields.Date(string="入团(党)时间")
|
||
user_origin = fields.Char(string="籍贯")
|
||
user_location = fields.Char(string="户口所在地")
|
||
is_location = fields.Boolean(string="是否本地")
|
||
bank_account = fields.Char(string="银行卡号")
|
||
user_location_type = fields.Selection([('formal', '本地农业'), ('labor', '本地非农业'),
|
||
('part_time', '外地农业'), ('practice', '外地非农业')], string="户籍类型")
|
||
is_local_location = fields.Char(
|
||
string="是否外地",
|
||
compute='_compute_is_local_location',
|
||
)
|
||
|
||
@api.depends('user_location_type')
|
||
def _compute_is_local_location(self):
|
||
for rec in self:
|
||
if rec.user_location_type in ('formal', 'labor'):
|
||
rec.is_local_location = '否'
|
||
else:
|
||
rec.is_local_location = '是'
|
||
duty_replacement_card = fields.Integer(string="值班补卡次数（月）")
|
||
# 工作信息
|
||
entry_date = fields.Date(string="入职日期")
|
||
confirmation_date = fields.Date(string="转正日期")
|
||
company_old = fields.Char(string="司龄", compute='_compute_company_old')
|
||
company_old_year = fields.Integer(string="司龄（年）", compute='_compute_company_old')
|
||
regularization_year = fields.Integer(string="转正（年）", compute='_compute_regularization_year')
|
||
open_start_time = fields.Date(string="参加工作时间")
|
||
is_membership = fields.Boolean(string="工会会员")
|
||
cumulative_work_month = fields.Integer(string="累计工作月数", compute='_compute_social_insurance_info')
|
||
cumulative_work_years = fields.Char(string="累计工作年限", compute='_compute_cumulative_work_years')
|
||
interrupt_work_month = fields.Integer(string="中断工作月数")
|
||
compute_char = fields.Char(string="工龄", compute='_compute_social_insurance_info')
|
||
compute_month = fields.Integer(string="工龄(月)")
|
||
social_insurance_date = fields.Date(string="缴纳社保日期")
|
||
social_insurance_time = fields.Char(string="社保时长", compute='_compute_social_insurance_info', store=True)
|
||
|
||
# 教育
|
||
high_degree = fields.Char(string="最高学历")
|
||
high_degree2 = fields.Char(string="最高学位")
|
||
graduate_school = fields.Char(string="毕业院校")
|
||
profession = fields.Char(string="专业")
|
||
graduate_date = fields.Date(string="毕业时间")
|
||
job_lv_date = fields.Char(string="职级等级/签发日期（人事员）")
|
||
job_lv = fields.Char(string="专业技术/技能等级(劳动局)")
|
||
job_qualification_date = fields.Date(string="职业资格/考取日期")
|
||
job_lv_change = fields.Char(string="职级变动")
|
||
move_note_date = fields.Text(string="异动情况/移动日期")
|
||
# 紧急
|
||
emergency_contacts_name = fields.Char(string="称谓")
|
||
# 其他
|
||
archiving_agency = fields.Char(string="存档机构")
|
||
over_data_time = fields.Datetime(string="最后更新数据时间")
|
||
# 工作信息 -- page
|
||
normal_overtime_hours = fields.Float(string="本月正常加班时间(h)")
|
||
weekend_overtime_hours = fields.Float(string="本月周末加班时间(h)")
|
||
holiday_overtime_hours = fields.Float(string="本月节假日加班时间(h)")
|
||
normal_overtime_hours1 = fields.Float(string="上月正常加班时间(h)")
|
||
weekend_overtime_hours1 = fields.Float(string="上月周末加班时间(h)")
|
||
holiday_overtime_hours1 = fields.Float(string="上月节假日加班时间(h)")
|
||
overtime_this_month = fields.Float(string="本月加班时", compute='_compute_overtime_this_month', store=True)
|
||
overtime_last_month = fields.Float(string="上月加班时")
|
||
result_overtime = fields.Float(string="结算时")
|
||
holiday_hours = fields.Float(string="假期额度")
|
||
all_overtime_hours = fields.Float(string="总加班小时", compute="_compute_all_overtime_hours", store=True)
|
||
replacement_card_count = fields.Integer(string="补卡次数")
|
||
is_annual_salary = fields.Boolean(string="是否年薪")
|
||
is_accum_salary = fields.Boolean(string="是否公积金")
|
||
# 假期
|
||
user_year= fields.Float(string="已用年假")
|
||
remainder_year = fields.Float(string="剩余年假", compute="_compute_remainder_year", store=True)
|
||
cumulative_hours = fields.Float(string="累计剩余探亲假")
|
||
all_year = fields.Float(string="年假总数(小时)")
|
||
previous_balance = fields.Float(string="上年结余")
|
||
quota_issued = fields.Float(string="本年发放额度")
|
||
deadline = fields.Date(string="截止日期")
|
||
late_allowed = fields.Float(string="允许迟到次数")
|
||
|
||
# 其他信息
|
||
employment_registration = fields.Text(string="就业登记办理情况")
|
||
seniority_prize_pick_up_status = fields.Text(string="工龄相关年功奖领取情况")
|
||
|
||
# 考勤机信息
|
||
att_lot_ids = fields.One2many('attendance.iot.user', 'employee_id', string="考勤机信息")
|
||
|
||
# 紧急联系人
|
||
emergency_contact_ids = fields.One2many('yuthon.emergency.contact.line', 'employee_id', string="紧急联系人明细行")
|
||
# 工作经历
|
||
work_experience_ids = fields.One2many('yuthon.work.experience.line', 'employee_id', string="工作经历明细行")
|
||
# 教育经历
|
||
education_experience_ids = fields.One2many('yuthon.education.experience.line', 'employee_id', string="教育经历明细行")
|
||
# 技能证书管理
|
||
skills_certificates_ids = fields.One2many('yuthon.skills.certificates.line', 'employee_id', string="教育经历明细行")
|
||
# 专项扣除
|
||
care_line_ids = fields.One2many('child.care.line', 'employee_id', string="婴幼儿照护明细行")
|
||
education_line_ids = fields.One2many('child.education.line', 'employee_id', string="子女教育明细行")
|
||
support_line_ids = fields.One2many('elderly.support.line', 'employee_id', string="赡养老人明细行")
|
||
hospital_name = fields.Char(string="姓名")
|
||
hospital_related = fields.Char(string="与纳税人关系")
|
||
original_amount = fields.Float(string='个人负担金额')
|
||
|
||
education_name = fields.Char(string="姓名")
|
||
education_end_date = fields.Date(string="结束时间")
|
||
education_deduction = fields.Float(string='扣除金额')
|
||
|
||
loan_name = fields.Char(string="姓名")
|
||
loan_end_date = fields.Date(string="结束时间")
|
||
loan_deduction = fields.Float(string='扣除金额')
|
||
|
||
rent_name = fields.Char(string="姓名")
|
||
rent_end_date = fields.Date(string="结束时间")
|
||
rent_deduction = fields.Float(string='扣除金额')
|
||
|
||
meal_number = fields.Integer(string="误餐费次数")
|
||
meal_supplement = fields.Float(string="餐补")
|
||
|
||
pinyin_name = fields.Char(string="拼音名称", compute='_compute_pinyin', index=True, store=True)
|
||
pinyin_min = fields.Char(string='拼音缩写', compute='_compute_pinyin', index=True, store=True)
|
||
|
||
# 工资计算分组
|
||
salary_group_id = fields.Many2one('yuthon.salary.group', string="工资单分组", store=True)
|
||
salary_date = fields.Date(string="薪资计算时间", store=True)
|
||
salary_month = fields.Selection([('1', '一月'), ('2', '二月'), ('3', '三月'), ('4', '四月'),
|
||
('5', '五月'), ('6', '六月'), ('7', '七月'), ('8', '八月'),
|
||
('9', '九月'), ('10', '十月'), ('11', '十一月'),
|
||
('12', '十二月')], string='薪资计算月份')
|
||
salary_year_jin_ids = fields.Many2many(
|
||
'hr.employee',
|
||
relation='hr_employee_salary_year_jin_rel',
|
||
column1='employee_id',
|
||
column2='related_employee_id',
|
||
string='薪资计算年金人员'
|
||
)
|
||
salary_year = fields.Integer(compute='_compute_salary_year', store=True)
|
||
is_create = fields.Boolean(string='是否已创建转正流程审批')
|
||
last_year_salary = fields.Float(string="年金基数")
|
||
converted = fields.Float(string="折算实际系数")
|
||
conversion_factor = fields.Float(string="上年有效计算")
|
||
cumulative_year = fields.Float()
|
||
total_coefficients = fields.Float(string="系数合计", compute='_compute_total_coefficients', store=True)
|
||
calculation_totals = fields.Float(string="有效计算合计", compute='_compute_total_coefficients', store=True)
|
||
efficient_calculations = fields.Float(string="有效计算")
|
||
social_base_on = fields.Float(string="1-6月公积金基数")
|
||
social_base_off = fields.Float(string="7-12月公积金基数")
|
||
is_salary = fields.Boolean(string="是否薪资计算", default=True)
|
||
# 薪资计算 基数
|
||
salary_medical_insurance = fields.Float(string='薪资医疗费基数', compute='_compute_insurance_salary')
|
||
salary_insurance = fields.Float(string='薪资养老费基数', compute='_compute_insurance_salary')
|
||
salary_work_injury_insurance = fields.Float(string='薪资保险金基数', compute='_compute_insurance_salary')
|
||
salary_housing_fund = fields.Float(string='薪资公积金基数', compute='_compute_insurance_salary')
|
||
# 显示基数
|
||
medical_insurance_base = fields.Float(string='基本医疗费基数', compute='_compute_insurance_bases')
|
||
pension_insurance_base = fields.Float(string='基本养老费基数', compute='_compute_insurance_bases')
|
||
work_injury_insurance_base = fields.Float(string='失业保险金基数', compute='_compute_insurance_bases')
|
||
housing_fund_base = fields.Float(string='住房公积金基数', compute='_compute_insurance_bases')
|
||
is_company = fields.Boolean(string="本公司", default=True, compute='_compute_is_company', search='_search_part_of_company')
|
||
department_id = fields.Many2one(related='contract_id.department_id', string="部门", store=True)
|
||
job_id = fields.Many2one(related='contract_id.job_id', string="工作岗位", store=True)
|
||
resource_calendar_id = fields.Many2one(compute='_compute_resource_calendar_id', string="工作时间", store=True)
|
||
|
||
subsidy_amount = fields.Float(string="岗位补贴金额", compute='_compute_subsidy_amount', store=True)
|
||
security_amount = fields.Float(string="安全委员会金额", compute='_compute_subsidy_amount', store=True)
|
||
quality_inspector_amount = fields.Float(string="质检员金额", compute='_compute_subsidy_amount', store=True)
|
||
|
||
last_month_base_salary_deduction = fields.Float(string="上月基本薪资扣款")
|
||
last_month_performance_deduction = fields.Float(string="上月绩效扣款")
|
||
last_month_commuting_deduction = fields.Float(string='上月通信扣款')
|
||
last_attendance = fields.Boolean(string="上月全勤", store=True)
|
||
last_month_overtime = fields.Float(string="上月加班时数")
|
||
|
||
# 请假记录
|
||
done_leave = fields.Float(string='年假')
|
||
done_working_overtime = fields.Float(string='加班时')
|
||
compensatory_leave = fields.Integer(string="调休")
|
||
leave_of_absence = fields.Float(string="事假")
|
||
statutory_leave = fields.Integer(string="加班时(法定)")
|
||
cop_leave = fields.Float(string='补休')
|
||
duty_off_leave = fields.Integer(string='值班调休')
|
||
marriage_leave = fields.Integer(string='婚假')
|
||
maternity_leave = fields.Integer(string='产假')
|
||
paternity_leave = fields.Integer(string='陪产假')
|
||
family_planning_leave = fields.Integer(string='计生假')
|
||
bereavement_leave = fields.Float(string='丧假')
|
||
home_visit_leave = fields.Integer(string='探亲假')
|
||
parents_meeting_leave = fields.Integer(string='家长会假')
|
||
general_sick_leave = fields.Float(string='病假(普通)')
|
||
hospital_sick_leave = fields.Float(string='病假(住院期)')
|
||
recovery_sick_leave = fields.Float(string='病假(出院恢复期)')
|
||
exam_leave = fields.Integer(string='考试假')
|
||
|
||
marital = fields.Selection([
|
||
('single', '未婚'),
|
||
('married', 'Married'),
|
||
('cohabitant', 'Legal Cohabitant'),
|
||
('widower', 'Widower'),
|
||
('divorced', 'Divorced')
|
||
], string='Marital Status', groups="hr.group_hr_user", default='single', tracking=True)
|
||
|
||
def get_contract_count(self):
|
||
return self.env['hr.employee'].search_count([('end_comparison', 'in', ['red', 'yellow', 'blue'])])
|
||
|
||
def update_role_group_ids(self):
|
||
employee_ids = self.env["hr.employee"].browse(
|
||
self._context.get("active_ids", self._context.get("active_id"))
|
||
)
|
||
for employee in employee_ids:
|
||
employee._onchange_user_roles()
|
||
|
||
def task_contract(self):
|
||
today = fields.Date.today()
|
||
contract_employees = self.search([('end_comparison', 'in', ['red', 'yellow', 'blue'])])
|
||
menu_id = self.env['ir.ui.menu'].search([('name', '=', '合同')], limit=1)
|
||
hr_specialists = self.env['soong.user.role'].search([
|
||
('name', '=', '人事专员'),
|
||
'|', ('company_id.name', 'in', ['集团本部', '天河粮储']), ('company_id', '=', 3)
|
||
])
|
||
# 构建「公司名称: 人事专员wecom_userid」映射
|
||
company_hr_map = {}
|
||
for role in hr_specialists:
|
||
company_name = role.company_id.name
|
||
if role.personnel_ids and len(role.personnel_ids) > 0:
|
||
hr_wecom_id = role.personnel_ids[0].wecom_userid # 取第一个人事专员的企微ID
|
||
company_hr_map[company_name] = hr_wecom_id
|
||
|
||
for employee in contract_employees:
|
||
if not employee.contract_id or not employee.contract_id.date_end:
|
||
continue
|
||
|
||
end_date = employee.contract_id.date_end
|
||
delta = relativedelta(end_date, today)
|
||
total_months = delta.years * 12 + delta.months
|
||
remaining_days = delta.days
|
||
remind_flag = False
|
||
remind_desc = ""
|
||
|
||
if end_date == today:
|
||
remind_flag = True
|
||
remind_desc = f"员工【{employee.name}】的合同今日到期（到期日：{end_date}），请尽快处理"
|
||
elif total_months == 3 and remaining_days == 0:
|
||
remind_flag = True
|
||
remind_desc = f"员工【{employee.name}】的合同还有3个月到期，到期日为{end_date}，请尽快处理"
|
||
elif total_months == 2 and remaining_days == 0:
|
||
remind_flag = True
|
||
remind_desc = f"员工【{employee.name}】的合同还有2个月到期，到期日为{end_date}，请尽快处理"
|
||
elif total_months == 1 and remaining_days == 0:
|
||
remind_flag = True
|
||
remind_desc = f"员工【{employee.name}】的合同还有1个月到期，到期日为{end_date}，请尽快处理"
|
||
|
||
if remind_flag:
|
||
employee_company_name = employee.company_id.name if employee.company_id else ""
|
||
hr_wecom_id = company_hr_map.get(employee_company_name)
|
||
target_url = f'https://oa.thtzjt.com/web#action=509&model=hr.contract&view_type=list&menu_id=11009&cids=2-1-3-4'
|
||
url = self.sudo().env["wecom.apps"].generate_oauth_login_url(target_url, employee.user_id.id if employee.user_id else 0)
|
||
self.sudo().env["wecom.apps"].sync_send_message_textcard(
|
||
category='oa',
|
||
user_id=hr_wecom_id,
|
||
title="合同到期提醒",
|
||
description=remind_desc,
|
||
url=url,
|
||
btntxt="详细信息"
|
||
)
|
||
|
||
|
||
@api.onchange('user_role_id', 'user_role_ids')
|
||
def _onchange_user_roles(self):
|
||
selected_role_ids = []
|
||
if self.user_role_id:
|
||
selected_role_ids.append(self.user_role_id.id)
|
||
|
||
if self.user_role_ids:
|
||
selected_role_ids += self.user_role_ids.ids
|
||
if not selected_role_ids:
|
||
self.role_group_ids = [(5,)]
|
||
return
|
||
role_groups = self.env['soong.user.role.group'].search([
|
||
('user_role_ids', 'in', selected_role_ids)
|
||
])
|
||
if role_groups:
|
||
self.role_group_ids = [(6, 0, role_groups.ids)]
|
||
else:
|
||
self.role_group_ids = [(5,)]
|
||
|
||
@api.constrains('user_role_id', 'user_role_ids', 'role_group_ids')
|
||
def _sync_roles_to_res_groups(self):
|
||
"""
|
||
当员工的主角色(user_role_id)、辅助角色(user_role_ids)或角色组(role_group_ids)发生变更时，
|
||
仅将该员工的关联用户写入对应权限组的用户列表，不修改 res.groups 的角色/角色组字段配置。
|
||
匹配规则：
|
||
- 员工的主角色/辅助角色 与 res.groups.user_role_ids 有交集 → 写入该组用户列表
|
||
- 员工的角色组 与 res.groups.users_role_group_ids 有交集 → 写入该组用户列表
|
||
"""
|
||
for employee in self:
|
||
if not employee.user_id:
|
||
continue
|
||
|
||
# 收集该员工所有角色ID（主角色 + 辅助角色）
|
||
role_ids = []
|
||
if employee.user_role_id:
|
||
role_ids.append(employee.user_role_id.id)
|
||
if employee.user_role_ids:
|
||
role_ids += employee.user_role_ids.ids
|
||
|
||
# 收集该员工所有角色组ID
|
||
role_group_ids = employee.role_group_ids.ids
|
||
|
||
# 1. 找到 res.groups.user_role_ids 与员工角色有交集的权限组，仅追加用户
|
||
if role_ids:
|
||
groups_by_role = self.env['res.groups'].search([
|
||
('user_role_ids', 'in', role_ids)
|
||
])
|
||
groups_by_role.write({'users': [(4, employee.user_id.id)]})
|
||
|
||
# 2. 找到 res.groups.users_role_group_ids 与员工角色组有交集的权限组，仅追加用户
|
||
if role_group_ids:
|
||
groups_by_role_group = self.env['res.groups'].search([
|
||
('users_role_group_ids', 'in', role_group_ids)
|
||
])
|
||
groups_by_role_group.write({'users': [(4, employee.user_id.id)]})
|
||
|
||
def write(self, vals):
|
||
"""覆盖 write，user_role_id / user_role_ids 变更时反向同步到角色的 personnel_ids，
|
||
并正向同步到 res.groups 的用户明细行"""
|
||
role_fields = {'user_role_id', 'user_role_ids'}
|
||
if not role_fields.intersection(vals.keys()):
|
||
return super().write(vals)
|
||
# 记录变更前的角色状态
|
||
old_role_id_map = {emp.id: emp.user_role_id.id for emp in self}
|
||
old_role_ids_map = {emp.id: set(emp.user_role_ids.ids) for emp in self}
|
||
result = super().write(vals)
|
||
for emp in self:
|
||
# --- 主角色反向同步 ---
|
||
if 'user_role_id' in vals:
|
||
old_rid = old_role_id_map.get(emp.id)
|
||
new_rid = emp.user_role_id.id if emp.user_role_id else False
|
||
if old_rid and old_rid != new_rid:
|
||
old_role = self.env['soong.user.role'].browse(old_rid)
|
||
if emp.id in old_role.personnel_ids.ids:
|
||
old_role.write({'personnel_ids': [(3, emp.id)]})
|
||
if new_rid and new_rid != old_rid:
|
||
new_role = self.env['soong.user.role'].browse(new_rid)
|
||
if emp.id not in new_role.personnel_ids.ids:
|
||
new_role.write({'personnel_ids': [(4, emp.id)]})
|
||
# --- 辅助角色反向同步 ---
|
||
if 'user_role_ids' in vals:
|
||
old_rids = old_role_ids_map.get(emp.id, set())
|
||
new_rids = set(emp.user_role_ids.ids)
|
||
added = new_rids - old_rids
|
||
removed = old_rids - new_rids
|
||
for rid in added:
|
||
role = self.env['soong.user.role'].browse(rid)
|
||
if emp.id not in role.personnel_ids.ids:
|
||
role.write({'personnel_ids': [(4, emp.id)]})
|
||
for rid in removed:
|
||
role = self.env['soong.user.role'].browse(rid)
|
||
if emp.id in role.personnel_ids.ids:
|
||
role.write({'personnel_ids': [(3, emp.id)]})
|
||
|
||
# --- 权限组同步 ---
|
||
if not emp.user_id:
|
||
continue
|
||
|
||
# 收集当前所有角色ID（主角色 + 辅助角色）
|
||
current_role_ids = set()
|
||
if emp.user_role_id:
|
||
current_role_ids.add(emp.user_role_id.id)
|
||
if emp.user_role_ids:
|
||
current_role_ids.update(emp.user_role_ids.ids)
|
||
|
||
# 收集被移除的角色ID
|
||
removed_role_ids = set()
|
||
if 'user_role_id' in vals:
|
||
old_rid = old_role_id_map.get(emp.id)
|
||
new_rid = emp.user_role_id.id if emp.user_role_id else False
|
||
if old_rid and old_rid != new_rid:
|
||
removed_role_ids.add(old_rid)
|
||
if 'user_role_ids' in vals:
|
||
old_rids_set = old_role_ids_map.get(emp.id, set())
|
||
new_rids_set = set(emp.user_role_ids.ids)
|
||
removed_role_ids.update(old_rids_set - new_rids_set)
|
||
|
||
# 收集被添加的角色ID
|
||
added_role_ids = set()
|
||
if 'user_role_id' in vals:
|
||
old_rid = old_role_id_map.get(emp.id)
|
||
new_rid = emp.user_role_id.id if emp.user_role_id else False
|
||
if new_rid and new_rid != old_rid:
|
||
added_role_ids.add(new_rid)
|
||
if 'user_role_ids' in vals:
|
||
old_rids_set = old_role_ids_map.get(emp.id, set())
|
||
new_rids_set = set(emp.user_role_ids.ids)
|
||
added_role_ids.update(new_rids_set - old_rids_set)
|
||
|
||
# 1. 新增角色对应的权限组：把员工的用户加进去
|
||
if added_role_ids:
|
||
groups_to_add = self.env['res.groups'].sudo().search([
|
||
('user_role_ids', 'in', list(added_role_ids))
|
||
])
|
||
for group in groups_to_add:
|
||
if emp.user_id.id not in group.users.ids:
|
||
group.sudo().write({'users': [(4, emp.user_id.id)]})
|
||
|
||
# 2. 移除角色对应的权限组：若员工在该组不再有任何角色交集，则把用户移除
|
||
if removed_role_ids:
|
||
groups_to_check = self.env['res.groups'].sudo().search([
|
||
('user_role_ids', 'in', list(removed_role_ids))
|
||
])
|
||
for group in groups_to_check:
|
||
group_role_ids = set(group.user_role_ids.ids)
|
||
if not (group_role_ids & current_role_ids):
|
||
if emp.user_id.id in group.users.ids:
|
||
group.sudo().write({'users': [(3, emp.user_id.id)]})
|
||
return result
|
||
|
||
def update_trade_union(self):
|
||
records = self.env['hr.employee'].search([('is_membership', '=', True)])
|
||
for record in records:
|
||
if record.contract_id.termination_date:
|
||
if record.contract_id.termination_date <= date.today() + timedelta(days=8):
|
||
record.is_membership = False
|
||
if record.contract_id.date_end <= date.today() + timedelta(days=8):
|
||
record.is_membership = False
|
||
|
||
def update_end_comparison(self):
|
||
employees = self.env['hr.employee'].search([])
|
||
for employee in employees:
|
||
employee._compute_end_comparison()
|
||
|
||
@api.depends('date_end')
|
||
def _compute_end_comparison(self):
|
||
for record in self:
|
||
now = date.today()
|
||
if record.date_end:
|
||
if record.date_end > now:
|
||
delta = record.date_end - now
|
||
if 60 <= delta.days < 90:
|
||
record.end_comparison = 'blue'
|
||
elif 30 <= delta.days < 60:
|
||
record.end_comparison = 'yellow'
|
||
elif delta.days < 30:
|
||
record.end_comparison = 'red'
|
||
else:
|
||
record.end_comparison = None
|
||
elif record.date_end < now:
|
||
record.end_comparison = 'red'
|
||
else:
|
||
record.end_comparison = None
|
||
else:
|
||
record.end_comparison = None
|
||
|
||
@api.depends('contract_id')
|
||
def _compute_date_end(self):
|
||
for record in self:
|
||
if record.contract_id:
|
||
if record.contract_id.contract_type_id.name == '正式合同（无固定）':
|
||
record.date_end = record.retire_date
|
||
else:
|
||
record.date_end = record.contract_id.date_end
|
||
else:
|
||
record.date_end = None
|
||
|
||
def renew(self):
|
||
employee_ids = self.env["hr.employee"].browse(
|
||
self._context.get("active_ids", self._context.get("active_id"))
|
||
)
|
||
for record in employee_ids:
|
||
if len(record) > 1:
|
||
raise UserError("只能选择一个员工续签")
|
||
return {
|
||
"name": "续签",
|
||
"type": "ir.actions.act_window",
|
||
"res_model": "yuthon.renewal.approval",
|
||
"view_mode": "form",
|
||
"context": {
|
||
"default_employee_id": self.id,
|
||
"default_current_status": self.contract_id.date_end,
|
||
"default_department1_id": self.department_id.id,
|
||
"default_contract_id": self.contract_id.id,
|
||
},
|
||
}
|
||
|
||
|
||
|
||
def update_social_base(self):
|
||
current_year = fields.Date.today().year
|
||
group_company = self.env['res.company'].search([('name', '=', '集团本部')], limit=1)
|
||
official_contract_type = self.env['hr.contract.type'].search(
|
||
[('name', '=', '正式合同（一签）')],
|
||
limit=1
|
||
)
|
||
eligible_employees = self.env['hr.contract'].search([
|
||
('employee_id.company_id', '=', group_company.id),
|
||
('contract_type_id', '=', official_contract_type.id),
|
||
('date_start', '>=', f'{current_year}-01-01'),
|
||
('date_start', '<=', f'{current_year}-12-31')
|
||
]).mapped('employee_id')
|
||
eighty_percent_items = [
|
||
'基本工资',
|
||
'职级工资',
|
||
'月绩效奖金'
|
||
]
|
||
full_amount_items = [
|
||
'通讯补贴',
|
||
'工龄工资'
|
||
]
|
||
for employee in eligible_employees:
|
||
if employee.contract_id.state == 'open':
|
||
payslip_id = self.env['hr.payslip'].create({
|
||
'employee_id': employee.id,
|
||
'name': f"{employee.name}的薪资单-{fields.Date.today().strftime('%Y%m')}",
|
||
})
|
||
payslip_id.compute_sheet()
|
||
eighty_lines = payslip_id.line_ids.filtered(
|
||
lambda l: l.name in eighty_percent_items
|
||
)
|
||
full_lines = payslip_id.line_ids.filtered(
|
||
lambda l: l.name in full_amount_items
|
||
)
|
||
eighty_sum = sum(eighty_lines.mapped('amount'))
|
||
total_eighty_part = math.ceil(eighty_sum * 0.8)
|
||
total_full_part = sum(full_lines.mapped('amount')) if full_lines else 0
|
||
final_total = total_eighty_part + total_full_part + 200
|
||
employee.write({
|
||
'last_year_salary': final_total,
|
||
'social_base_on': final_total,
|
||
'social_base_off': final_total
|
||
})
|
||
payslip_id.action_payslip_cancel()
|
||
payslip_id.unlink()
|
||
|
||
def get_my_employee_action(self):
|
||
current_user = self.env.user
|
||
my_employee = self.search([('user_id', '=', current_user.id)], limit=1)
|
||
return {
|
||
'type': 'ir.actions.act_window',
|
||
'name': '个人基础信息',
|
||
'res_model': 'hr.employee',
|
||
'res_id': my_employee.id,
|
||
'view_mode': 'form',
|
||
'view_type': 'form',
|
||
'target': 'current',
|
||
'view_id': self.env.ref('yuthon_hr_employee.view_basic_personal_information').id,
|
||
}
|
||
|
||
def change_password_wizard(self):
|
||
return {
|
||
'name': '修改密码',
|
||
'type': 'ir.actions.act_window',
|
||
'res_model': 'reset.password.wizard',
|
||
'view_mode': 'form',
|
||
'target': 'new',
|
||
'context': {'default_employee_id': self.env.user.employee_ids.id
|
||
|
||
},
|
||
}
|
||
|
||
def compute_late_allowed(self):
|
||
employee = self.env["hr.employee"].search([('company_id', '=', 3)])
|
||
for employee_id in employee:
|
||
employee_id.late_allowed = 3
|
||
|
||
@api.onchange('user_role_id')
|
||
def onchange_user_role_id(self):
|
||
if self.user_role_id:
|
||
user_id = self.env['soong.user.role'].search([('id', '=', self.user_role_id.id)])
|
||
user_id.write({'personnel_ids': [(4, self.id.origin)]})
|
||
|
||
@api.depends('quota_issued', 'user_year')
|
||
def _compute_remainder_year(self):
|
||
for record in self:
|
||
if record.quota_issued > record.user_year:
|
||
record.remainder_year = record.quota_issued - record.user_year
|
||
else:
|
||
record.remainder_year = 0
|
||
|
||
@api.depends('user_role_ids', 'user_role_id', 'department_id', 'skills_certificates_ids')
|
||
def _compute_subsidy_amount(self):
|
||
for record in self:
|
||
amount = 0
|
||
quality_amount = 0
|
||
# 获取主角色名称
|
||
primary_role_name = record.user_role_id.name if record.user_role_id else ''
|
||
# 获取所有辅助角色名称列表
|
||
secondary_role_names = record.user_role_ids.mapped('name')
|
||
# 获取部门名称
|
||
department_name = record.department_id.name if record.department_id else ''
|
||
# 1. 财务部会计、出纳每月有100元补贴
|
||
if '会计岗' in (primary_role_name, *secondary_role_names) or '出纳' in (
|
||
primary_role_name, *secondary_role_names):
|
||
amount += 100
|
||
# 2. 司机分别有600元补贴（仅司机）
|
||
if '司机' in (primary_role_name, *secondary_role_names):
|
||
amount += 600
|
||
# 3. 运行班、高压班员工补贴200元/月
|
||
if department_name in ['运行班', '高压班']:
|
||
amount += 200
|
||
# 4. 宿舍管理长会有100元/月补贴
|
||
if '宿舍长' in (primary_role_name, *secondary_role_names):
|
||
amount += 100
|
||
# 5. 消防安全证的保安有50元/月补贴
|
||
has_fire_certificate = any(
|
||
cert.rank_name == '消防安全证'
|
||
for cert in record.skills_certificates_ids
|
||
)
|
||
if has_fire_certificate:
|
||
amount += 50
|
||
quality = any(
|
||
cert.rank_name == '质检证书'
|
||
for cert in record.skills_certificates_ids
|
||
)
|
||
if quality and department_name == '仓储组':
|
||
quality_amount += 100
|
||
|
||
if department_name == '领导班子':
|
||
record.security_amount = 0
|
||
elif '安全委员会' in (primary_role_name, *secondary_role_names):
|
||
record.security_amount = 320
|
||
else:
|
||
record.security_amount = 0
|
||
|
||
record.subsidy_amount = amount
|
||
record.quality_inspector_amount = quality_amount
|
||
|
||
@api.depends('converted', 'salary_year_jin_ids')
|
||
def _compute_total_coefficients(self):
|
||
for record in self:
|
||
company_employees = self.env['hr.employee'].search([])
|
||
record.total_coefficients = sum(employee.converted for employee in self.salary_year_jin_ids)
|
||
record.calculation_totals = sum(employee.conversion_factor for employee in company_employees)
|
||
|
||
@api.depends('contract_id')
|
||
def _compute_resource_calendar_id(self):
|
||
for employee in self:
|
||
employee.resource_calendar_id = employee.contract_id.resource_calendar_id.id
|
||
|
||
@api.depends_context('uid', 'company')
|
||
@api.depends('company_id')
|
||
def _compute_is_company(self):
|
||
active_company_ids = self.env.companies
|
||
for employee in self:
|
||
employee.is_company = employee.company_id in active_company_ids
|
||
|
||
def _search_part_of_company(self, operator, value):
|
||
if operator not in ('=', '!=') or not isinstance(value, bool):
|
||
raise UserError(('Operation not supported'))
|
||
company_ids = self.env.companies.ids # 获取公司ID列表
|
||
# 处理反向操作符
|
||
if not value:
|
||
operator = '!=' if operator == '=' else '='
|
||
# 使用company_id in company_ids的结构
|
||
if operator == '=':
|
||
return [('company_id', 'in', company_ids)]
|
||
else: # operator == '!='
|
||
return [('company_id', 'not in', company_ids)]
|
||
|
||
@api.depends('normal_overtime_hours', 'weekend_overtime_hours', 'holiday_overtime_hours')
|
||
def _compute_overtime_this_month(self):
|
||
for employee in self:
|
||
employee.overtime_this_month = employee.normal_overtime_hours + employee.weekend_overtime_hours + employee.holiday_overtime_hours
|
||
# 根据当前月份来选择具体的值
|
||
@api.depends('social_base_on', 'social_base_off')
|
||
def _compute_insurance_bases(self):
|
||
current_month = datetime.now().month
|
||
insurance_names = {
|
||
'基本医疗保险费': 'medical_insurance_base',
|
||
'基本养老保险费': 'pension_insurance_base',
|
||
'失业保险费': 'work_injury_insurance_base',
|
||
'住房公积金': 'housing_fund_base'
|
||
}
|
||
insurance_records = self.env['yuthon.payroll.insurances'].search([('name', 'in', list(insurance_names.keys()))])
|
||
for record in self:
|
||
# 初始化所有保险基数为0
|
||
for field_name in insurance_names.values():
|
||
setattr(record, field_name, 0)
|
||
base = record.social_base_on if 1 <= current_month <= 6 else record.social_base_off
|
||
for insurance in insurance_records:
|
||
field_name = insurance_names[insurance.name]
|
||
# 特殊处理：只有这两个人的住房公积金设为4000
|
||
if field_name == 'housing_fund_base' and record.name in ['郭爱娣', '黄炎方']:
|
||
record.housing_fund_base = 4000
|
||
continue # 跳过住房公积金的正常计算
|
||
|
||
# 正常计算其他保险和普通人的住房公积金
|
||
if base > insurance.employee_base_ceiling:
|
||
setattr(record, field_name, insurance.employee_base_ceiling)
|
||
elif base < insurance.employee_base_floor:
|
||
setattr(record, field_name, insurance.employee_base_floor)
|
||
else:
|
||
setattr(record, field_name, base)
|
||
|
||
# 根据薪资计算选择的月份 来获取确定的值
|
||
@api.depends('social_base_on', 'social_base_off', 'salary_month')
|
||
def _compute_insurance_salary(self):
|
||
insurance_names = {
|
||
'薪资医疗保险费': 'salary_medical_insurance',
|
||
'薪资养老保险费': 'salary_insurance',
|
||
'薪资保险费': 'salary_work_injury_insurance',
|
||
'薪资公积金': 'salary_housing_fund'
|
||
}
|
||
name_mapping = {
|
||
'基本医疗保险费': '薪资医疗保险费',
|
||
'基本养老保险费': '薪资养老保险费',
|
||
'失业保险费': '薪资保险费',
|
||
'住房公积金': '薪资公积金'
|
||
}
|
||
insurance_records = self.env['yuthon.payroll.insurances'].search([('name', 'in',['基本医疗保险费', '基本养老保险费', '失业保险费', '住房公积金'])])
|
||
for record in self:
|
||
for field_name in insurance_names.values():
|
||
setattr(record, field_name, 0)
|
||
base = record.social_base_on if 1 <= int(record.salary_month) <= 6 else record.social_base_off
|
||
for insurance in insurance_records:
|
||
insurance_name_key = name_mapping.get(insurance.name)
|
||
field_name = insurance_names.get(insurance_name_key)
|
||
if field_name == 'housing_fund_base' and record.name in ['郭爱娣', '黄炎方']:
|
||
record.housing_fund_base = 4000
|
||
continue
|
||
if base > insurance.employee_base_ceiling:
|
||
setattr(record, field_name, insurance.employee_base_ceiling)
|
||
elif base < insurance.employee_base_floor:
|
||
setattr(record, field_name, insurance.employee_base_floor)
|
||
else:
|
||
setattr(record, field_name, base)
|
||
|
||
@api.onchange('job_id')
|
||
def _onchange_job_id(self):
|
||
if self.job_id:
|
||
personnel_id = self.env['hr.job'].search([('job_personnel_ids', 'in', self.id.origin)])
|
||
job_id = self.env['hr.job'].search([('id', '=', self.job_id.id)])
|
||
if personnel_id:
|
||
# 如果找到，从 job_personnel_ids 中移除当前记录的人员
|
||
personnel_id.write({'job_personnel_ids': [(3, self.id.origin)]})
|
||
job_id.write({'job_personnel_ids': [(4, self.id.origin)]})
|
||
else:
|
||
job_id.write({'job_personnel_ids': [(4, self.id.origin)]})
|
||
|
||
@api.onchange('user_location')
|
||
def _onchange_user_location(self):
|
||
if self.user_location:
|
||
self.is_location = True
|
||
else:
|
||
self.is_location = False
|
||
|
||
@api.model_create_multi
|
||
def create(self, vals_list):
|
||
recs = super().create(vals_list)
|
||
for record in recs:
|
||
try:
|
||
if record.department_id:
|
||
record.department_id.do_department_to_res_groups()
|
||
if record.user_role_id:
|
||
record.user_role_id.do_role_to_res_groups()
|
||
except Exception as e:
|
||
pass
|
||
return recs
|
||
|
||
# def write(self, values):
|
||
# for record in self:
|
||
# try:
|
||
# if "department_id" in values:
|
||
# record.do_group_department_id(values.get("department_id"))
|
||
# if "user_role_id" in values:
|
||
# record.do_group_user_role_id(values.get("user_role_id"))
|
||
# except Exception as e:
|
||
# pass
|
||
# return super().write(values)
|
||
|
||
def do_group_department_id(self, department_id):
|
||
user_ids = self.user_id.ids
|
||
# 移除原来的数据
|
||
old_res_groups_objs = self.sudo().env["res.groups"].search([("department_ids", "in", self.department_id.ids)])
|
||
if old_res_groups_objs:
|
||
for res_groups_obj in old_res_groups_objs:
|
||
res_groups_obj.sudo().write({
|
||
"users": [(3, id) for id in user_ids]
|
||
})
|
||
# 增加新的元素
|
||
department_obj = self.sudo().env["hr.department"].search([("id", "=", department_id)], limit=1)
|
||
res_groups_objs = self.sudo().env["res.groups"].search([("department_ids", "in", department_obj.ids)])
|
||
if res_groups_objs:
|
||
for res_groups_obj in res_groups_objs:
|
||
res_groups_obj.sudo().write({
|
||
"users": [(4, id) for id in user_ids]
|
||
})
|
||
|
||
# def do_group_user_role_id(self, user_role_id):
|
||
# # 移除原来的数据
|
||
# user_ids = self.user_id.ids
|
||
# old_res_groups_objs = self.sudo().env["res.groups"].search([("user_role_ids", "in", self.user_role_id.ids)])
|
||
# if old_res_groups_objs:
|
||
# for res_groups_obj in old_res_groups_objs:
|
||
# res_groups_obj.sudo().write({"users": [(3, id) for id in user_ids]})
|
||
# # 增加新的元素
|
||
# role_obj = self.sudo().env["soong.user.role"].search([("id", "=", user_role_id)], limit=1)
|
||
# res_groups_objs = self.sudo().env["res.groups"].search([("user_role_ids", "in", role_obj.ids)])
|
||
# if res_groups_objs:
|
||
# for res_groups_obj in res_groups_objs:
|
||
# res_groups_obj.sudo().write({
|
||
# "users": [(4, id) for id in user_ids]
|
||
# })
|
||
|
||
@api.onchange('number')
|
||
def onchange_number(self):
|
||
for num in self:
|
||
if num.department_id.department_code:
|
||
num.number = num.department_id.department_code + num.number
|
||
else:
|
||
num.number = ''
|
||
|
||
def action_batch_fix_resource_calendar(self):
|
||
"""根据所属公司批量修复员工工作时间"""
|
||
company_calendar_map = {
|
||
3: '行政考勤-物管',
|
||
'集团本部': '行政考勤-本部',
|
||
'天河粮储': '行政考勤-粮储',
|
||
}
|
||
updated_count = 0
|
||
skipped_count = 0
|
||
failed_employees = []
|
||
|
||
# 预加载所有需要的 resource.calendar
|
||
calendar_names = list(company_calendar_map.values())
|
||
calendars = self.env['resource.calendar'].search([('name', 'in', calendar_names)])
|
||
calendar_map = {cal.name: cal for cal in calendars}
|
||
|
||
for employee in self:
|
||
company_name = employee.company_id.name if employee.company_id else False
|
||
if not employee.company_id or (employee.company_id.id not in company_calendar_map and company_name not in company_calendar_map):
|
||
skipped_count += 1
|
||
continue
|
||
|
||
calendar_name = company_calendar_map.get(company_name) or company_calendar_map.get(employee.company_id.id)
|
||
calendar = calendar_map.get(calendar_name)
|
||
|
||
if not calendar:
|
||
skipped_count += 1
|
||
continue
|
||
|
||
if not employee.contract_id:
|
||
skipped_count += 1
|
||
continue
|
||
|
||
try:
|
||
employee.contract_id.write({'resource_calendar_id': calendar.id})
|
||
updated_count += 1
|
||
except Exception as e:
|
||
failed_employees.append('%s(%s)' % (employee.name, employee.id))
|
||
continue
|
||
|
||
parts = ['成功更新 %d 条记录，跳过 %d 条。' % (updated_count, skipped_count)]
|
||
if failed_employees:
|
||
parts.append('失败 %d 条：%s' % (len(failed_employees), ', '.join(failed_employees[:5])))
|
||
if len(failed_employees) > 5:
|
||
parts.append('...等共 %d 条' % len(failed_employees))
|
||
message = '\n'.join(parts)
|
||
|
||
return {
|
||
'type': 'ir.actions.client',
|
||
'tag': 'display_notification',
|
||
'params': {
|
||
'title': '批量修复工作时间完成',
|
||
'message': message,
|
||
'type': 'success',
|
||
'sticky': False,
|
||
}
|
||
}
|
||
|
||
def action_hr_employee(self):
|
||
return {
|
||
"type": "ir.actions.act_window",
|
||
"name": "批量更新员工",
|
||
"res_model": "yuthon.hr.employee.wizard",
|
||
"view_mode": "form",
|
||
"target": "new",
|
||
}
|
||
|
||
def action_hr_time_form(self):
|
||
return {
|
||
"type": "ir.actions.act_window",
|
||
"name": "批量更新时间表",
|
||
"res_model": "yuthon.hr.employee.time.wizard",
|
||
"view_mode": "form",
|
||
"target": "new",
|
||
}
|
||
|
||
def action_hr_state(self):
|
||
employee = self.env["hr.employee"].browse(
|
||
self._context.get('active_ids', self._context.get('active_id')))
|
||
for employee_id in employee:
|
||
employee_id.onchange_user_role_id()
|
||
|
||
@api.depends('confirmation_date')
|
||
def _compute_regularization_year(self):
|
||
for record in self:
|
||
if record.confirmation_date:
|
||
record.regularization_year = fields.Date.today().year - record.confirmation_date.year
|
||
else:
|
||
record.regularization_year = 0
|
||
|
||
@api.depends('entry_date', 'salary_date')
|
||
def _compute_salary_year(self):
|
||
"""基于薪资计算时间的司龄年份计算"""
|
||
for record in self:
|
||
if record.entry_date and record.salary_date:
|
||
# 获取薪资计算时间和入职日期
|
||
salary_date = record.salary_date
|
||
entry_date = record.entry_date
|
||
years_diff = salary_date.year - entry_date.year
|
||
# 检查月份和日期，如果薪资计算时间的月份和日期早于入职日期，则减去1年
|
||
if (salary_date.month, salary_date.day) < (entry_date.month, entry_date.day):
|
||
years_diff -= 1
|
||
record.salary_year = max(0, years_diff)
|
||
else:
|
||
record.salary_year = 0
|
||
|
||
@api.depends('entry_date')
|
||
def _compute_company_old(self):
|
||
"""司龄计算"""
|
||
for record in self:
|
||
if record.entry_date:
|
||
today = datetime.now().date()
|
||
record.company_old_year = today.year - record.entry_date.year + 1
|
||
# 原有的完整年月计算保持不变
|
||
years_diff = today.year - record.entry_date.year
|
||
months_diff = today.month - record.entry_date.month
|
||
if today.month < record.entry_date.month:
|
||
years_diff -= 1
|
||
months_diff += 12
|
||
record.company_old = str(years_diff) + '年' + str(months_diff) + '月'
|
||
else:
|
||
record.company_old = None
|
||
record.company_old_year = 0
|
||
|
||
@api.depends('open_start_time', 'interrupt_work_month')
|
||
def _compute_social_insurance_info(self):
|
||
for record in self:
|
||
cumulative_months = 0
|
||
if record.open_start_time:
|
||
today = datetime.now().date()
|
||
delta = relativedelta(today, record.open_start_time)
|
||
cumulative_months = delta.years * 12 + delta.months
|
||
record.cumulative_work_month = cumulative_months
|
||
total_months = cumulative_months - record.interrupt_work_month
|
||
record.compute_month = total_months
|
||
if total_months <= 0:
|
||
social_insurance_time_str = "0个月"
|
||
else:
|
||
years = total_months // 12
|
||
months = total_months % 12
|
||
social_insurance_time_str = f"{years}年{months}个月" if years > 0 and months > 0 else (
|
||
f"{years}年" if years > 0 else f"{months}个月")
|
||
record.social_insurance_time = social_insurance_time_str
|
||
record.compute_char = social_insurance_time_str
|
||
|
||
@api.depends('cumulative_work_month')
|
||
def _compute_cumulative_work_years(self):
|
||
for record in self:
|
||
if record.cumulative_work_month:
|
||
if record.cumulative_work_month <= 0:
|
||
record.social_insurance_time = "0个月"
|
||
years = record.cumulative_work_month // 12
|
||
months = record.cumulative_work_month % 12
|
||
if years > 0:
|
||
result_str = f"{years}年"
|
||
if months > 0:
|
||
result_str += f"{months}个月"
|
||
else:
|
||
result_str = f"{months}个月"
|
||
record.cumulative_work_years = result_str
|
||
else:
|
||
record.cumulative_work_years = None
|
||
|
||
@api.depends('identification_id') # 只依赖身份证号码
|
||
def _compute_info(self):
|
||
for record in self:
|
||
if record.identification_id:
|
||
self.is_identification = True
|
||
id_number = record.identification_id.upper()
|
||
if len(id_number) != 18:
|
||
record._clear_info()
|
||
# raise UserError("身份证号码长度应为18位")
|
||
# try:
|
||
if not (all(c.isdigit() for c in id_number[:-1]) and (
|
||
id_number[-1].isdigit() or id_number[-1] == 'X')):
|
||
raise ValueError("身份证号码包含无效字符")
|
||
|
||
year = int(id_number[6:10])
|
||
month = int(id_number[10:12])
|
||
day = int(id_number[12:14])
|
||
record.birthday = date(year, month, day)
|
||
record.birthday_month = month
|
||
|
||
today = date.today()
|
||
if year is not None:
|
||
record.old = today.year - year - ((today.month, today.day) < (month, day))
|
||
else:
|
||
record.old = 0
|
||
gender_code = int(id_number[-2])
|
||
record.user_sex = 'girl' if gender_code % 2 == 0 else 'boy'
|
||
|
||
# except ValueError as e:
|
||
# record._clear_info()
|
||
# raise UserError(str(e) or "身份证号码格式不正确")
|
||
else:
|
||
record._clear_info()
|
||
self.is_identification = False
|
||
|
||
def _clear_info(self):
|
||
self.birthday = False
|
||
self.birthday_month = False
|
||
self.old = 0
|
||
self.user_sex = False
|
||
|
||
@api.depends('retire_date')
|
||
def _compute_retire_years(self):
|
||
"""离退休年限计算"""
|
||
for record in self:
|
||
if record.retire_date:
|
||
today = datetime.now().date()
|
||
years_diff = today.year - record.retire_date.year
|
||
compute = years_diff
|
||
if compute < 0:
|
||
record.retire_years = -1 * compute
|
||
else:
|
||
record.retire_years = 0
|
||
else:
|
||
record.retire_years = 0
|
||
|
||
@api.depends('normal_overtime_hours', 'weekend_overtime_hours')
|
||
def _compute_all_overtime_hours(self):
|
||
for record in self:
|
||
record.all_overtime_hours = record.normal_overtime_hours + record.weekend_overtime_hours
|
||
|
||
def hr_employee_time(self):
|
||
for record in self:
|
||
record.duty_replacement_card = 0
|
||
|
||
@api.depends('name')
|
||
def _compute_pinyin(self):
|
||
for employee in self:
|
||
employee.pinyin_name = ''.join(lazy_pinyin(employee.name)) if employee.name else ''
|
||
employee.pinyin_min = ''.join(lazy_pinyin(employee.name, style=STYLE_FIRST_LETTER)) if employee.name else ''
|
||
|
||
@api.model
|
||
def _name_search(self, name, domain=None, operator='ilike', limit=None, order=None):
|
||
domain = domain or []
|
||
if name:
|
||
has_chinese = any('\u4e00' <= char <= '\u9fff' for char in name)
|
||
if has_chinese:
|
||
# 包含中文：使用模糊匹配
|
||
search_domain = [('name', operator, name)]
|
||
else:
|
||
# 纯字母/数字：使用精确匹配
|
||
search_domain = ['|',
|
||
('pinyin_name', operator, name),
|
||
('name', '=', name)]
|
||
domain = expression.AND([search_domain, domain])
|
||
return self._search(domain, limit=limit, order=order)
|
||
|
||
|
||
def employee_log(self):
|
||
vacation_id = self.env['yuthon.vacation.reports'].search([('employee_id', '=', self.id)])
|
||
if vacation_id:
|
||
return {
|
||
'name': '休假记录',
|
||
'type': 'ir.actions.act_window',
|
||
'res_model': 'yuthon.vacation.reports',
|
||
'view_mode': 'form',
|
||
'res_id': vacation_id.id,
|
||
'target': 'new'
|
||
}
|
||
|
||
def update_parental_leave(self):
|
||
today = datetime.now().date()
|
||
# 如果 self 有具体员工（个人调用），只查该员工的合同；否则（定时任务）查全部
|
||
if self:
|
||
active_contracts = self.env['hr.contract'].search([
|
||
('state', '=', 'open'),
|
||
('contract_type_id.name', 'ilike', '正式合同'),
|
||
('employee_id', 'in', self.ids)
|
||
])
|
||
else:
|
||
active_contracts = self.env['hr.contract'].search([
|
||
('state', '=', 'open'),
|
||
('contract_type_id.name', 'ilike', '正式合同'),
|
||
('employee_id', '!=', False)
|
||
])
|
||
allocate_config = self.env['yuthon.parenting.allocate'].search([], limit=1)
|
||
valid_limit = allocate_config.valid_limit # 截至年龄（如3）
|
||
cycle_years = allocate_config.cycle_years # 周期年数（如1）
|
||
distribute = allocate_config.distribute #
|
||
if not active_contracts:
|
||
return
|
||
employees = active_contracts.mapped('employee_id')
|
||
for employee in employees:
|
||
child_contacts = employee.emergency_contact_ids.filtered(
|
||
lambda line: line.user_relationship in ['boys', 'daughter']
|
||
and line.user_sfz
|
||
)
|
||
if not child_contacts:
|
||
continue
|
||
|
||
# 解析子女出生日期，判断是否符合条件（≤3岁）
|
||
for contact in child_contacts:
|
||
sfz = contact.user_sfz.strip()
|
||
if not sfz:
|
||
continue
|
||
try:
|
||
if len(sfz) == 18:
|
||
birth_str = sfz[6:14]
|
||
birth_date = datetime.strptime(birth_str, '%Y%m%d').date()
|
||
else:
|
||
continue
|
||
except (ValueError, IndexError):
|
||
continue
|
||
|
||
valid_end_date = birth_date + relativedelta(years=valid_limit)
|
||
if today > valid_end_date:
|
||
continue
|
||
cycle_list = []
|
||
current_cycle_start = birth_date
|
||
total_cycles = int(valid_limit / cycle_years)
|
||
|
||
for i in range(1, total_cycles + 1):
|
||
current_cycle_end = current_cycle_start + relativedelta(years=cycle_years)
|
||
cycle_list.append({
|
||
'cycle_num': i,
|
||
'start': current_cycle_start,
|
||
'end': current_cycle_end
|
||
})
|
||
current_cycle_start = current_cycle_end
|
||
|
||
date_from = birth_date
|
||
date_to = valid_end_date - timedelta(days=1)
|
||
for cycle in cycle_list:
|
||
if today <= cycle['end']:
|
||
date_from = cycle['start']
|
||
date_to = cycle['end'] - timedelta(days=1)
|
||
break
|
||
|
||
total_days = distribute
|
||
if total_days <= 0:
|
||
continue
|
||
|
||
holiday_status_id = self.env['hr.leave.type'].search([('name', '=', '育儿假')], limit=1)
|
||
|
||
# 检查是否已存在相同分配记录，避免重复
|
||
existing_allocation = self.env['hr.leave.allocation'].search([
|
||
('employee_id', '=', employee.id),
|
||
('name', '=', '育儿假分配'),
|
||
('allocation_type', '=', 'regular'),
|
||
('date_from', '=', date_from),
|
||
('date_to', '=', date_to),
|
||
], limit=1)
|
||
if not existing_allocation:
|
||
self.env['hr.leave.allocation'].create({
|
||
'name': '育儿假分配',
|
||
'allocation_type': 'regular',
|
||
'employee_id': employee.id,
|
||
'date_from': date_from,
|
||
'date_to': date_to,
|
||
'holiday_status_id': holiday_status_id.id,
|
||
'number_of_days': total_days,
|
||
})
|
||
|
||
reports_id = self.env['yuthon.vacation.reports'].search([
|
||
('employee_id', '=', employee.id),
|
||
('vacation_date', '=', fields.Date.today().replace(day=1))
|
||
], limit=1) #
|
||
if reports_id:
|
||
existing_report_line = reports_id.parenting_line_ids.search([
|
||
('vacation_id', '=', reports_id.id),
|
||
('employee_id', '=', employee.id),
|
||
('update_date', '=', date_from),
|
||
('end_date', '=', date_to),
|
||
('text','in', ['育儿假分配', '上月额度继承'])
|
||
], limit=1)
|
||
if not existing_report_line:
|
||
reports_id.parenting_line_ids.sudo().create({
|
||
'vacation_id': reports_id.id,
|
||
'employee_id': employee.id,
|
||
'update_date': date_from,
|
||
'lines': total_days,
|
||
'end_date': date_to,
|
||
'text': '育儿假分配'
|
||
})
|
||
|
||
|
||
def regularization_task(self):
|
||
today = fields.Date.today()
|
||
target_date = today + timedelta(days=15)
|
||
eligible_employees = self.search([
|
||
('is_create', '=', False),
|
||
('contract_id.is_probation', '=', True),
|
||
('contract_id.end_date', '=', target_date),
|
||
('contract_id', '!=', False)
|
||
])
|
||
if not eligible_employees:
|
||
return
|
||
|
||
for employee in eligible_employees:
|
||
contract_structure_type = employee.contract_id.structure_type_id
|
||
approval_name = f"转正申请表-{employee.name}"
|
||
self.env['yuthon.regularization.approval'].create({
|
||
'name': approval_name,
|
||
'users_id': employee.user_id.id,
|
||
'create_uid': employee.user_id.id,
|
||
'structure_type_id': contract_structure_type.id,
|
||
'structure_type_id1': contract_structure_type.id,
|
||
'is_adjust': False,
|
||
})
|
||
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.regularization.approval&view_type=list&menu_id={menu_id.id}'
|
||
self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa',
|
||
user_id=employee.wecom_userid,
|
||
title="转正申请",
|
||
description=f"""您好！近期即将开展您的转正流程，现就转正申请事宜温馨提醒如下，确保流程顺利推进:
|
||
待办工作流：已为您生成「转正申请审批单」待办任务，可登录 OA 查看处理；
|
||
提交时限：请于试用期截止前 1 周（即{employee.contract_id.end_date.year}年{employee.contract_id.end_date.month}月{employee.contract_id.end_date.day}日）完成审批单提交，逾期可能影响转正进度；
|
||
材料准备：需同步上传《转正申请书》（可向人事部门索取，企业微信联系人事对接人）。""",
|
||
url=url, btntxt="详细信息")
|
||
|
||
employee.write({'is_create': True})
|
||
|
||
def _get_notify_users(self, task_config):
|
||
"""从 task_config 获取需要通知的用户列表.
|
||
"""
|
||
user_ids = set(task_config.user_ids.ids)
|
||
role_ids = set(task_config.users_role_group_ids.mapped('user_role_ids').ids)
|
||
if task_config.users_role_id:
|
||
role_ids.add(task_config.users_role_id.id)
|
||
if role_ids:
|
||
all_target_roles = self.env['soong.user.role'].browse(list(role_ids))
|
||
role_employees = self.env['hr.employee'].search([
|
||
'|',
|
||
('user_role_id', 'in', all_target_roles.ids),
|
||
('user_role_ids', 'in', all_target_roles.ids),
|
||
('user_id', '!=', False),
|
||
])
|
||
for emp in role_employees:
|
||
user_ids.add(emp.user_id.id)
|
||
return self.env['res.users'].browse(list(user_ids))
|
||
|
||
def task_retire_reminder(self):
|
||
today = fields.Date.today()
|
||
target_date = today + timedelta(days=30)
|
||
employees = self.search([
|
||
('retire_date', '=', target_date),
|
||
('user_state', 'in', ['in', 'borrow', 'expatriate', 'adjunct']),
|
||
])
|
||
if not employees:
|
||
return
|
||
task_config = self.env['yuthon.hr.task'].search([('cron_id.name', '=', '定时任务:退休提醒')], limit=1)
|
||
if not task_config:
|
||
return
|
||
notify_users = self._get_notify_users(task_config)
|
||
if not notify_users:
|
||
return
|
||
count = len(employees)
|
||
for user in notify_users:
|
||
hr_employee = user.employee_ids.filtered(lambda e: e.wecom_userid)[:1]
|
||
if not hr_employee:
|
||
continue
|
||
result_data = self.sudo().env['wecom.apps'].sync_send_message_textcard(
|
||
category='oa',
|
||
user_id=hr_employee.wecom_userid,
|
||
title='退休提醒',
|
||
description=f"提醒：有{count}个人即将退休，请移至工作台查看。",
|
||
url='https://oa.thtzjt.com/web?debug=1#action=3584&cids=1&menu_id=9668',
|
||
btntxt='详细信息',
|
||
)
|
||
confirm = self.env['yuthon.task.confirm'].create({
|
||
'task_id': task_config.id,
|
||
'user_id': user.id,
|
||
'state': 'read',
|
||
})
|
||
if result_data and len(result_data) > 1:
|
||
msg_id = result_data[1].get('msgid')
|
||
if msg_id:
|
||
confirm.sudo().write({'msg_id': msg_id})
|
||
|
||
def task_separation_reminder(self):
|
||
today = fields.Date.today()
|
||
target_date = today + timedelta(days=30)
|
||
workflow_records = self.env['soong.workflow.record'].search([
|
||
('workflow_id.name', '=', '离职申请'),
|
||
('approve_state', '=', 'end'),
|
||
('reclaim_state', '=', False),
|
||
])
|
||
leaving_ids = []
|
||
for record in workflow_records:
|
||
try:
|
||
leaving = self.env[record.res_model].browse(record.res_id)
|
||
if leaving and leaving.separation_date == target_date and not leaving.is_execution:
|
||
leaving_ids.append(leaving)
|
||
except Exception:
|
||
continue
|
||
if not leaving_ids:
|
||
return
|
||
task_config = self.env['yuthon.hr.task'].search([('cron_id.name', '=', '定时任务:离职提醒')], limit=1)
|
||
if not task_config:
|
||
return
|
||
notify_users = self._get_notify_users(task_config)
|
||
if not notify_users:
|
||
return
|
||
count = len(leaving_ids)
|
||
for user in notify_users:
|
||
hr_employee = user.employee_ids.filtered(lambda e: e.wecom_userid)[:1]
|
||
if not hr_employee:
|
||
continue
|
||
result_data = self.sudo().env['wecom.apps'].sync_send_message_textcard(
|
||
category='oa',
|
||
user_id=hr_employee.wecom_userid,
|
||
title='离职提醒',
|
||
description=f"提醒：有{count}个人即将离职，请移至工作台查看。",
|
||
url='https://oa.thtzjt.com/web?debug=1#action=3584&cids=1&menu_id=9668',
|
||
btntxt='详细信息',
|
||
)
|
||
confirm = self.env['yuthon.task.confirm'].create({
|
||
'task_id': task_config.id,
|
||
'user_id': user.id,
|
||
'state': 'read',
|
||
})
|
||
if result_data and len(result_data) > 1:
|
||
msg_id = result_data[1].get('msgid')
|
||
if msg_id:
|
||
confirm.sudo().write({'msg_id': msg_id})
|