# -*- coding: utf-8 -*- # License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl). from odoo import fields, models, api from odoo.exceptions import UserError, ValidationError from datetime import datetime, date, time, timedelta class SoongWorkflowCommentWizard(models.TransientModel): _name = "soong.workflow.comment.wizard" _description = "Soong Workflow Comment Wizard" _inherit = ['mail.thread.main.attachment', 'mail.activity.mixin'] name = fields.Char(string="name") res_model = fields.Char() res_id = fields.Integer() 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') node_link_len = fields.Char(string="转交2") comment_note_id = fields.Many2one('soong.note', string="意见") state_list = fields.Char(string="状态列表") record_id = fields.Integer() trans_link_id = fields.Many2one('trans.link', string='转交节点') return_link_id = fields.Many2one('trans.link', string='退回节点') 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', string="传阅人员", store=True) supervising_employee_ids = fields.Many2many('hr.employee', 'supervising_employee_rel', 'custom_id', 'employee_id', string="督办人员", store=True) is_automatic = fields.Boolean('是否自动匹配') @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 ['拟办', '申请人']: self.employee_ids = record_id.users_id.employee_id elif self.node_btn_name == '退回': next_list = [] workflow_id = self.return_link_id.node_button_id.workflow_id state_list = ['拟办' if i.node_name == 'start' else i.node_name for i in workflow_id.node_ids] self_state = state_list.index(ret.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), ('department_id', '=', record_id.department_id.id)]) self.employee_ids = employee_user_role_id else: employee_user_role_ids = self.env['hr.employee'].search( [('user_role_id', '=', btn.users_role_id.id)]) self.employee_ids = employee_user_role_ids @api.onchange('trans_link_id') def onchange_trans_employee_ids(self): record_id = self.env[self.res_model].search([('id', '=', self.res_id)]) for ret in self.trans_link_id: workflow_id = self.trans_link_id.node_button_id.workflow_id state_list = ['拟办' if i.node_name == 'start' else i.node_name for i in workflow_id.node_ids] link_users_id = workflow_id.node_ids.search( [('name', '=', self.trans_link_id.name), ('workflow_id', '=', workflow_id.id)]).button_ids[ 0].users_role_id next_is_automatic = workflow_id.node_ids.search( [('name', '=', self.trans_link_id.name), ('workflow_id', '=', workflow_id.id)]).button_ids[ 0].is_automatic # 不自动匹配 employee_user_role_ids = self.env['hr.employee'].search( ['|', ('user_role_id', '=', link_users_id.id), ('user_role_ids', 'in', link_users_id.id)]) # 自动匹配 employee_user_role_id = self.env['hr.employee'].search( ['|', ('user_role_id', '=', link_users_id.id), ('user_role_ids', 'in', link_users_id.id), '|', ('department_id', '=', record_id.department_id.id), ('department_ids', 'in', record_id.department_id.id), ('yuthon_company', '=', record_id.create_uid.employee_id.yuthon_company)]) self.employee_ids = employee_user_role_ids if not next_is_automatic else employee_user_role_id if self.node_btn_name == '退回': next_list = [] self_state = state_list.index(ret.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), ('department_id', '=', record_id.department_id.id)]) self.employee_ids = employee_user_role_id else: employee_user_role_ids = self.env['hr.employee'].search( [('user_role_id', '=', btn.users_role_id.id)]) self.employee_ids = employee_user_role_ids def add_comment(self): self.ensure_one() cx = self.env.context.copy() or {} record_id = self.env[self.res_model].search([('id', '=', self.res_id)]) # 抄送人员 if self.node_btn_name == '转交': self_node_id = record_id.workflow_id.node_ids.search( [('name', '=', record_id.state), ('workflow_id', '=', record_id.workflow_id.id)]) if self_node_id.is_carbon_copy: for employee in self_node_id.employee_ids: if not employee.wecom_userid: raise ("请同步{}的企业微信".format(employee.name)) url = "https://oa.thtzjt.com/mail/view?model={}&res_id={}".format(self.res_model, record_id.id) self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa', user_id=employee.wecom_userid, title=record_id._description, description="标题: {}\n".format( record_id.name) + self.env.user.name + ' ' + str( fields.Datetime.now() + timedelta( hours=8)), url=url, btntxt="查看详情") # partner_ids = self_node_id.employee_ids.user_id.partner_id.ids # self.with_context(lang=self.env.lang)._message_auto_subscribe_notify(partner_ids, 'soong_workflow.message_soong_workflow_distribute') # 转交逻辑--单线 if not self.node_link_len: state = self.node_btn_id.node_id.out_link_ids.name.split('-> ')[-1] record_id.write({'state': 'end' if state == '结束' else state}) # 转交逻辑--多线 if self.node_link_len: record_id.write({'state': 'end' if self.trans_link_id.name == '结束' else self.trans_link_id.name}) url = 'https://oa.thtzjt.com/mail/view?model={}&res_id={}'.format(self.res_model, self.res_id) 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="标题: {}\n".format( record_id.name) + self.env.user.name + ' ' + str( fields.Datetime.now() + timedelta( hours=8)), url=url, btntxt="查看详情") # 转交创建记录 log_obj = self.env["soong.workflow.log"] next_node_id = record_id.workflow_id.node_ids.search( [('name', '=', self.trans_link_id.name), ('workflow_id', '=', record_id.workflow_id.id)]) is_automatic = next_node_id.button_ids[0].is_automatic next_state = next_node_id.button_ids[0] employee_user_role_ids = self.env['hr.employee'].search( ['|', ('user_role_id', '=', next_state.users_role_id.id), ('user_role_ids', 'in', next_state.users_role_id.id)]) employee_user_role_id = self.env['hr.employee'].search( ['|', ('user_role_id', '=', next_state.users_role_id.id), ('user_role_ids', 'in', next_state.users_role_id.id), '|', ('department_id', '=', record_id.department_id.id), ('department_ids', 'in', record_id.department_id.id)]) employee_ids = employee_user_role_ids if not is_automatic else employee_user_role_id record_obj = log_obj.search([("model", "=", self.res_model), ("res_id", "=", self.res_id), ("node_id", "=", next_node_id.id), ("workflow_id", "=", record_id.workflow_id.id), # ("node_btn_id", "=", record_id.node_btn_id.id), ]) if not record_obj: record_obj = log_obj.create( { "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_ids[0].user_id.id, # "node_btn_id": self.node_btn_id.id, # "lase_click_date": fields.Datetime.now(), } ) record_obj.update({"approval_state": "0"}) # partner_ids = self.employee_ids.user_id.partner_id.ids # self.with_context(lang=self.env.lang)._message_auto_subscribe_notify(partner_ids, 'soong_workflow.message_soong_workflow_distribute') return self.node_btn_id.with_context(cx).run() if self.node_btn_name == '退回': record_id.write( {'state': 'start' if self.return_link_id.name in ['拟办', '申请人'] else self.return_link_id.name}) url = 'https://oa.thtzjt.com/mail/view?model={}&res_id={}'.format(self.res_model, self.res_id) 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="标题: {}\n".format( record_id.name) + self.env.user.name + ' ' + str( fields.Datetime.now() + timedelta( hours=8)), url=url, btntxt="查看详情") # partner_ids = self.employee_ids.user_id.partner_id.ids # self.with_context(lang=self.env.lang)._message_auto_subscribe_notify(partner_ids, 'soong_workflow.message_soong_workflow_distribute') return self.node_btn_id.with_context(cx).run() # # 填写审批记录 # if self.node_btn_name != '加签': # self.log_ids.write({"comment": self.comment_note_id.name}) # # 加签人员写入 # if self.node_btn_name == '加签': # record_id.approval_sign_ids = self.approval_users_ids if self.node_btn_name == '分发': if self.circulated_employee_ids: url = 'https://oa.thtzjt.com/mail/view?model={}&res_id={}'.format(self.res_model, self.res_id) for employee in self.circulated_employee_ids: self.sudo().env["wecom.apps"].sync_send_message_textcard(category='oa', user_id=employee.wecom_userid, title=record_id._description, description="标题: {}\n".format( record_id.name) + self.env.user.name + ' ' + str( fields.Datetime.now() + timedelta( hours=8)), url=url, btntxt="查看详情") # partner_ids = self.circulated_employee_ids.user_id.partner_id.ids # self.with_context(lang=self.env.lang)._message_auto_subscribe_notify(partner_ids,'soong_workflow.message_soong_workflow_distribute') if self.employee_ids: state = self.node_btn_id.node_id.out_link_ids.name.split('-> ')[-1] record_id.write({'state': 'end' if state == '结束' else state}) return self.node_btn_id.with_context(cx).run()