1 # -*- coding: utf-8 -*-
2 ##############################################################################
4 # OpenERP, Open Source Management Solution
5 # Copyright (C) 2004-2009 Tiny SPRL (<http://tiny.be>).
7 # This program is free software: you can redistribute it and/or modify
8 # it under the terms of the GNU Affero General Public License as
9 # published by the Free Software Foundation, either version 3 of the
10 # License, or (at your option) any later version.
12 # This program is distributed in the hope that it will be useful,
13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 # GNU Affero General Public License for more details.
17 # You should have received a copy of the GNU Affero General Public License
18 # along with this program. If not, see <http://www.gnu.org/licenses/>.
20 ##############################################################################
24 from datetime import datetime
27 from osv import fields, osv
28 from openerp.modules.registry import RegistryManager
29 from openerp import SUPERUSER_ID
30 from base_status.base_stage import base_stage
31 from tools.translate import _
33 _logger = logging.getLogger(__name__)
37 ('cancel', 'Refused'),
38 ('open', 'In Progress'),
39 ('pending', 'Pending'),
43 AVAILABLE_PRIORITIES = [
52 class hr_recruitment_source(osv.osv):
53 """ Sources of HR Recruitment """
54 _name = "hr.recruitment.source"
55 _description = "Source of Applicants"
57 'name': fields.char('Source Name', size=64, required=True, translate=True),
60 class hr_recruitment_stage(osv.osv):
61 """ Stage of HR Recruitment """
62 _name = "hr.recruitment.stage"
63 _description = "Stage of Recruitment"
66 'name': fields.char('Name', size=64, required=True, translate=True),
67 'sequence': fields.integer('Sequence', help="Gives the sequence order when displaying a list of stages."),
68 'department_id':fields.many2one('hr.department', 'Specific to a Department', help="Stages of the recruitment process may be different per department. If this stage is common to all departments, keep this field empty."),
69 'state': fields.selection(AVAILABLE_STATES, 'State', required=True, help="The related state for the stage. The state of your document will automatically change according to the selected stage. Example, a stage is related to the state 'Close', when your document reach this stage, it will be automatically closed."),
70 'fold': fields.boolean('Hide in views if empty', help="This stage is not visible, for example in status bar or kanban view, when there are no records in that stage to display."),
71 'requirements': fields.text('Requirements'),
79 class hr_recruitment_degree(osv.osv):
80 """ Degree of HR Recruitment """
81 _name = "hr.recruitment.degree"
82 _description = "Degree of Recruitment"
84 'name': fields.char('Name', size=64, required=True, translate=True),
85 'sequence': fields.integer('Sequence', help="Gives the sequence order when displaying a list of degrees."),
91 ('name_uniq', 'unique (name)', 'The name of the Degree of Recruitment must be unique!')
94 class hr_applicant(base_stage, osv.Model):
95 _name = "hr.applicant"
96 _description = "Applicant"
98 _inherit = ['ir.needaction_mixin', 'mail.thread']
99 _mail_compose_message = True
101 def _get_default_department_id(self, cr, uid, context=None):
102 """ Gives default department by checking if present in the context """
103 return (self._resolve_department_id_from_context(cr, uid, context=context) or False)
105 def _get_default_stage_id(self, cr, uid, context=None):
106 """ Gives default stage_id """
107 department_id = self._get_default_department_id(cr, uid, context=context)
108 return self.stage_find(cr, uid, [], department_id, [('state', '=', 'draft')], context=context)
110 def _resolve_department_id_from_context(self, cr, uid, context=None):
111 """ Returns ID of department based on the value of 'default_department_id'
112 context key, or None if it cannot be resolved to a single
117 if type(context.get('default_department_id')) in (int, long):
118 return context.get('default_department_id')
119 if isinstance(context.get('default_department_id'), basestring):
120 department_name = context['default_department_id']
121 department_ids = self.pool.get('hr.department').name_search(cr, uid, name=department_name, context=context)
122 if len(department_ids) == 1:
123 return int(department_ids[0][0])
126 def _read_group_stage_ids(self, cr, uid, ids, domain, read_group_order=None, access_rights_uid=None, context=None):
127 access_rights_uid = access_rights_uid or uid
128 stage_obj = self.pool.get('hr.recruitment.stage')
129 order = stage_obj._order
130 # lame hack to allow reverting search, should just work in the trivial case
131 if read_group_order == 'stage_id desc':
132 order = "%s desc" % order
133 # retrieve section_id from the context and write the domain
134 # - ('id', 'in', 'ids'): add columns that should be present
135 # - OR ('department_id', '=', False), ('fold', '=', False): add default columns that are not folded
136 # - OR ('department_id', 'in', department_id), ('fold', '=', False) if department_id: add department columns that are not folded
137 department_id = self._resolve_department_id_from_context(cr, uid, context=context)
140 search_domain += ['|', '&', ('department_id', '=', department_id), ('fold', '=', False)]
141 search_domain += ['|', ('id', 'in', ids), '&', ('department_id', '=', False), ('fold', '=', False)]
142 stage_ids = stage_obj._search(cr, uid, search_domain, order=order, access_rights_uid=access_rights_uid, context=context)
143 result = stage_obj.name_get(cr, access_rights_uid, stage_ids, context=context)
144 # restore order of the search
145 result.sort(lambda x,y: cmp(stage_ids.index(x[0]), stage_ids.index(y[0])))
148 def _compute_day(self, cr, uid, ids, fields, args, context=None):
150 @param cr: the current row, from the database cursor,
151 @param uid: the current user’s ID for security checks,
152 @param ids: List of Openday’s IDs
153 @return: difference between current date and log date
154 @param context: A standard dictionary for contextual values
157 for issue in self.browse(cr, uid, ids, context=context):
164 if field in ['day_open']:
166 date_create = datetime.strptime(issue.create_date, "%Y-%m-%d %H:%M:%S")
167 date_open = datetime.strptime(issue.date_open, "%Y-%m-%d %H:%M:%S")
168 ans = date_open - date_create
169 date_until = issue.date_open
171 elif field in ['day_close']:
172 if issue.date_closed:
173 date_create = datetime.strptime(issue.create_date, "%Y-%m-%d %H:%M:%S")
174 date_close = datetime.strptime(issue.date_closed, "%Y-%m-%d %H:%M:%S")
175 date_until = issue.date_closed
176 ans = date_close - date_create
178 duration = float(ans.days)
179 res[issue.id][field] = abs(float(duration))
183 'name': fields.char('Subject', size=128, required=True),
184 'active': fields.boolean('Active', help="If the active field is set to false, it will allow you to hide the case without removing it."),
185 'description': fields.text('Description'),
186 'email_from': fields.char('Email', size=128, help="These people will receive email."),
187 'email_cc': fields.text('Watchers Emails', size=252, help="These email addresses will be added to the CC field of all inbound and outbound emails for this record before being sent. Separate multiple email addresses with a comma"),
188 'probability': fields.float('Probability'),
189 'partner_id': fields.many2one('res.partner', 'Contact'),
190 'create_date': fields.datetime('Creation Date', readonly=True, select=True),
191 'write_date': fields.datetime('Update Date', readonly=True),
192 'stage_id': fields.many2one ('hr.recruitment.stage', 'Stage',
193 domain="['|', ('department_id', '=', department_id), ('department_id', '=', False)]"),
194 'state': fields.related('stage_id', 'state', type="selection", store=True,
195 selection=AVAILABLE_STATES, string="State", readonly=True,
196 help='The state is set to \'Draft\', when a case is created.\
197 If the case is in progress the state is set to \'Open\'.\
198 When the case is over, the state is set to \'Done\'.\
199 If the case needs to be reviewed then the state is \
200 set to \'Pending\'.'),
201 'categ_ids': fields.many2many('hr.applicant_category', string='Categories'),
202 'company_id': fields.many2one('res.company', 'Company'),
203 'user_id': fields.many2one('res.users', 'Responsible'),
205 'date_closed': fields.datetime('Closed', readonly=True, select=True),
206 'date_open': fields.datetime('Opened', readonly=True, select=True),
207 'date': fields.datetime('Date'),
208 'date_action': fields.date('Next Action Date'),
209 'title_action': fields.char('Next Action', size=64),
210 'priority': fields.selection(AVAILABLE_PRIORITIES, 'Appreciation'),
211 'job_id': fields.many2one('hr.job', 'Applied Job'),
212 'salary_proposed_extra': fields.char('Proposed Salary Extra', size=100, help="Salary Proposed by the Organisation, extra advantages"),
213 'salary_expected_extra': fields.char('Expected Salary Extra', size=100, help="Salary Expected by Applicant, extra advantages"),
214 'salary_proposed': fields.float('Proposed Salary', help="Salary Proposed by the Organisation"),
215 'salary_expected': fields.float('Expected Salary', help="Salary Expected by Applicant"),
216 'availability': fields.integer('Availability'),
217 'partner_name': fields.char("Applicant's Name", size=64),
218 'partner_phone': fields.char('Phone', size=32),
219 'partner_mobile': fields.char('Mobile', size=32),
220 'type_id': fields.many2one('hr.recruitment.degree', 'Degree'),
221 'department_id': fields.many2one('hr.department', 'Department'),
222 'survey': fields.related('job_id', 'survey_id', type='many2one', relation='survey', string='Survey'),
223 'response': fields.integer("Response"),
224 'reference': fields.char('Referred By', size=128),
225 'source_id': fields.many2one('hr.recruitment.source', 'Source'),
226 'day_open': fields.function(_compute_day, string='Days to Open', \
227 multi='day_open', type="float", store=True),
228 'day_close': fields.function(_compute_day, string='Days to Close', \
229 multi='day_close', type="float", store=True),
230 'color': fields.integer('Color Index'),
231 'emp_id': fields.many2one('hr.employee', 'employee'),
232 'user_email': fields.related('user_id', 'email', type='char', string='User Email', readonly=True),
236 'active': lambda *a: 1,
237 'user_id': lambda s, cr, uid, c: uid,
238 'email_from': lambda s, cr, uid, c: s._get_default_email(cr, uid, c),
239 'stage_id': lambda s, cr, uid, c: s._get_default_stage_id(cr, uid, c),
240 'department_id': lambda s, cr, uid, c: s._get_default_department_id(cr, uid, c),
241 'priority': lambda *a: '',
242 'company_id': lambda s, cr, uid, c: s.pool.get('res.company')._company_default_get(cr, uid, 'hr.applicant', context=c),
247 'stage_id': _read_group_stage_ids
250 def onchange_job(self,cr, uid, ids, job, context=None):
254 job_obj = self.pool.get('hr.job')
255 result['department_id'] = job_obj.browse(cr, uid, job, context=context).department_id.id
256 return {'value': result}
257 return {'value': {'department_id': False}}
259 def onchange_department_id(self, cr, uid, ids, department_id=False, context=None):
260 obj_recru_stage = self.pool.get('hr.recruitment.stage')
261 stage_ids = obj_recru_stage.search(cr, uid, ['|',('department_id','=',department_id),('department_id','=',False)], context=context)
262 stage_id = stage_ids and stage_ids[0] or False
263 return {'value': {'stage_id': stage_id}}
265 def stage_find(self, cr, uid, cases, section_id, domain=[], order='sequence', context=None):
266 """ Override of the base.stage method
267 Parameter of the stage search taken from the lead:
268 - department_id: if set, stages must belong to this section or
271 if isinstance(cases, (int, long)):
272 cases = self.browse(cr, uid, cases, context=context)
273 # collect all section_ids
276 department_ids.append(section_id)
278 if case.department_id:
279 department_ids.append(case.department_id.id)
280 # OR all section_ids and OR with case_default
283 search_domain += ['|', ('department_id', 'in', department_ids)]
284 search_domain.append(('department_id', '=', False))
285 # AND with the domain in parameter
286 search_domain += list(domain)
287 # perform search, return the first found
288 stage_ids = self.pool.get('hr.recruitment.stage').search(cr, uid, search_domain, order=order, context=context)
293 def action_makeMeeting(self, cr, uid, ids, context=None):
294 """ This opens Meeting's calendar view to schedule meeting on current applicant
295 @return: Dictionary value for created Meeting view
297 applicant = self.browse(cr, uid, ids[0], context)
298 category = self.pool.get('ir.model.data').get_object(cr, uid, 'hr_recruitment', 'categ_meet_interview', context)
299 res = self.pool.get('ir.actions.act_window').for_xml_id(cr, uid, 'base_calendar', 'action_crm_meeting', context)
301 'default_partner_ids': applicant.partner_id and [applicant.partner_id.id] or False,
302 'default_user_id': uid,
303 'default_state': 'open',
304 'default_name': applicant.name,
305 'default_categ_ids': category and [category.id] or False,
309 def action_print_survey(self, cr, uid, ids, context=None):
311 If response is available then print this response otherwise print survey form(print template of the survey).
313 @param self: The object pointer
314 @param cr: the current row, from the database cursor,
315 @param uid: the current user’s ID for security checks,
316 @param ids: List of Survey IDs
317 @param context: A standard dictionary for contextual values
318 @return: Dictionary value for print survey form.
322 record = self.browse(cr, uid, ids, context=context)
323 record = record and record[0]
324 context.update({'survey_id': record.survey.id, 'response_id': [record.response], 'response_no': 0, })
325 value = self.pool.get("survey").action_print_survey(cr, uid, ids, context=context)
328 def message_new(self, cr, uid, msg, custom_values=None, context=None):
329 """ Overrides mail_thread message_new that is called by the mailgateway
330 through message_process.
331 This override updates the document according to the email.
333 if custom_values is None: custom_values = {}
334 custom_values.update({
335 'name': msg.get('subject') or _("No Subject"),
336 'description': msg.get('body_text'),
337 'email_from': msg.get('from'),
338 'email_cc': msg.get('cc'),
341 if msg.get('priority'):
342 custom_values['priority'] = msg.get('priority')
343 custom_values.update(self.message_partner_by_email(cr, uid, msg.get('from', False), context=context))
344 return super(hr_applicant,self).message_new(cr, uid, msg, custom_values=custom_values, context=context)
346 def message_update(self, cr, uid, ids, msg, update_vals=None, context=None):
347 """ Override mail_thread message_update that is called by the mailgateway
348 through message_process.
349 This method updates the document according to the email.
351 if isinstance(ids, (str, int, long)):
353 if update_vals is None: vals = {}
356 'description': msg.get('body'),
357 'email_from': msg.get('from'),
358 'email_cc': msg.get('cc'),
360 if msg.get('priority'):
361 update_vals['priority'] = msg.get('priority')
364 'cost': 'planned_cost',
365 'revenue': 'planned_revenue',
366 'probability': 'probability',
368 for line in msg.get('body_text', '').split('\n'):
370 res = tools.misc.command_re.match(line)
371 if res and maps.get(res.group(1).lower(), False):
372 key = maps.get(res.group(1).lower())
373 update_vals[key] = res.group(2).lower()
375 return super(hr_applicant, self).message_update(cr, uids, ids, update_vals=update_vals, context=context)
377 def create(self, cr, uid, vals, context=None):
378 obj_id = super(hr_applicant, self).create(cr, uid, vals, context=context)
379 self.create_send_note(cr, uid, [obj_id], context=context)
382 def case_open(self, cr, uid, ids, context=None):
384 open Request of the applicant for the hr_recruitment
386 res = super(hr_applicant, self).case_open(cr, uid, ids, context)
387 date = self.read(cr, uid, ids, ['date_open'])[0]
388 if not date['date_open']:
389 self.write(cr, uid, ids, {'date_open': time.strftime('%Y-%m-%d %H:%M:%S'),})
392 def case_close(self, cr, uid, ids, context=None):
393 res = super(hr_applicant, self).case_close(cr, uid, ids, context)
396 def case_close_with_emp(self, cr, uid, ids, context=None):
399 hr_employee = self.pool.get('hr.employee')
400 model_data = self.pool.get('ir.model.data')
401 act_window = self.pool.get('ir.actions.act_window')
403 for applicant in self.browse(cr, uid, ids, context=context):
405 if applicant.partner_id:
406 address_id = applicant.partner_id.address_get(['contact'])['contact']
408 applicant.job_id.write({'no_of_recruitment': applicant.job_id.no_of_recruitment - 1})
409 emp_id = hr_employee.create(cr,uid,{'name': applicant.partner_name or applicant.name,
410 'job_id': applicant.job_id.id,
411 'address_home_id': address_id,
412 'department_id': applicant.department_id.id
414 self.write(cr, uid, [applicant.id], {'emp_id': emp_id}, context=context)
415 self.case_close(cr, uid, [applicant.id], context)
417 raise osv.except_osv(_('Warning!'),_('You must define Applied Job for this applicant.'))
419 action_model, action_id = model_data.get_object_reference(cr, uid, 'hr', 'open_view_employee_list')
420 dict_act_window = act_window.read(cr, uid, action_id, [])
422 dict_act_window['res_id'] = emp_id
423 dict_act_window['view_mode'] = 'form,tree'
424 return dict_act_window
426 def case_cancel(self, cr, uid, ids, context=None):
427 """Overrides cancel for crm_case for setting probability
429 res = super(hr_applicant, self).case_cancel(cr, uid, ids, context)
430 self.write(cr, uid, ids, {'probability' : 0.0})
433 def case_pending(self, cr, uid, ids, context=None):
434 """Marks case as pending"""
435 res = super(hr_applicant, self).case_pending(cr, uid, ids, context)
436 self.write(cr, uid, ids, {'probability' : 0.0})
439 def case_reset(self, cr, uid, ids, context=None):
440 """Resets case as draft
442 res = super(hr_applicant, self).case_reset(cr, uid, ids, context)
443 self.write(cr, uid, ids, {'date_open': False, 'date_closed': False})
446 def set_priority(self, cr, uid, ids, priority, *args):
447 """Set applicant priority
449 return self.write(cr, uid, ids, {'priority' : priority})
451 def set_high_priority(self, cr, uid, ids, *args):
452 """Set applicant priority to high
454 return self.set_priority(cr, uid, ids, '1')
456 def set_normal_priority(self, cr, uid, ids, *args):
457 """Set applicant priority to normal
459 return self.set_priority(cr, uid, ids, '3')
461 # -------------------------------------------------------
462 # OpenChatter methods and notifications
463 # -------------------------------------------------------
465 def message_get_monitored_follower_fields(self, cr, uid, ids, context=None):
466 """ Add 'user_id' to the monitored fields """
467 res = super(hr_applicant, self).message_get_monitored_follower_fields(cr, uid, ids, context=context)
468 return res + ['user_id']
470 def stage_set_send_note(self, cr, uid, ids, stage_id, context=None):
471 """ Override of the (void) default notification method. """
472 if not stage_id: return True
473 stage_name = self.pool.get('hr.recruitment.stage').name_get(cr, uid, [stage_id], context=context)[0][1]
474 return self.message_append_note(cr, uid, ids, body= _("Stage changed to <b>%s</b>.") % (stage_name), context=context)
476 def case_get_note_msg_prefix(self, cr, uid, id, context=None):
479 def case_open_send_note(self, cr, uid, ids, context=None):
480 message = _("Applicant has been set <b>in progress</b>.")
481 return self.message_append_note(cr, uid, ids, body=message, context=context)
483 def case_close_send_note(self, cr, uid, ids, context=None):
486 for applicant in self.browse(cr, uid, ids, context=context):
488 message = _("Applicant has been <b>hired</b> and created as an employee.")
489 self.message_append_note(cr, uid, [applicant.id], body=message, context=context)
491 message = _("Applicant has been <b>hired</b>.")
492 self.message_append_note(cr, uid, [applicant.id], body=message, context=context)
495 def case_cancel_send_note(self, cr, uid, ids, context=None):
496 msg = 'Applicant <b>refused</b>.'
497 return self.message_append_note(cr, uid, ids, body=msg, context=context)
499 def case_reset_send_note(self, cr, uid, ids, context=None):
500 message =_("Applicant has been set as <b>new</b>.")
501 return self.message_append_note(cr, uid, ids, body=message, context=context)
503 def create_send_note(self, cr, uid, ids, context=None):
504 message = _("Applicant has been <b>created</b>.")
505 return self.message_append_note(cr, uid, ids, body=message, context=context)
508 class hr_job(osv.osv):
511 _inherits = {'mail.alias': 'alias_id'}
513 'survey_id': fields.many2one('survey', 'Interview Form', help="Choose an interview form for this job position and you will be able to print/answer this interview from all applicants who apply for this job"),
514 'alias_id': fields.many2one('mail.alias', 'Alias', ondelete="cascade", required=True,
515 help="Email alias for this job position. New emails will automatically "
516 "create new applicants for this job position."),
520 'alias_domain': False, # always hide alias during creation
523 def _auto_init(self, cr, context=None):
524 """Installation hook to create aliases for all jobs and avoid constraint errors."""
526 # disable the unique alias_id not null constraint, to avoid spurious warning during
527 # super.auto_init. We'll reinstall it afterwards.
528 self._columns['alias_id'].required = False
530 super(hr_job,self)._auto_init(cr, context=context)
532 registry = RegistryManager.get(cr.dbname)
533 mail_alias = registry.get('mail.alias')
534 hr_jobs = registry.get('hr.job')
535 jobs_no_alias = hr_jobs.search(cr, SUPERUSER_ID, [('alias_id', '=', False)])
536 # Use read() not browse(), to avoid prefetching uninitialized inherited fields
537 for job_data in hr_jobs.read(cr, SUPERUSER_ID, jobs_no_alias, ['name']):
538 alias_id = mail_alias.create_unique_alias(cr, SUPERUSER_ID, {'alias_name': 'job+'+job_data['name'],
539 'alias_defaults': {'job_id': job_data['id']}},
540 model_name='hr.applicant')
541 hr_jobs.write(cr, SUPERUSER_ID, job_data['id'], {'alias_id': alias_id})
542 _logger.info('Mail alias created for hr.job %s (uid %s)', job_data['name'], job_data['id'])
544 # Finally attempt to reinstate the missing constraint
546 cr.execute('ALTER TABLE hr_job ALTER COLUMN alias_id SET NOT NULL')
548 _logger.warning("Table '%s': unable to set a NOT NULL constraint on column '%s' !\n"\
549 "If you want to have it, you should update the records and execute manually:\n"\
550 "ALTER TABLE %s ALTER COLUMN %s SET NOT NULL",
551 self._table, 'alias_id', self._table, 'alias_id')
553 self._columns['alias_id'].required = True
555 def create(self, cr, uid, vals, context=None):
556 mail_alias = self.pool.get('mail.alias')
557 if not vals.get('alias_id'):
558 vals.pop('alias_name', None) # prevent errors during copy()
559 alias_id = mail_alias.create_unique_alias(cr, uid,
560 # Using '+' allows using subaddressing for those who don't
561 # have a catchall domain setup.
562 {'alias_name': 'jobs+'+vals['name']},
563 model_name="hr.applicant",
565 vals['alias_id'] = alias_id
566 res = super(hr_job, self).create(cr, uid, vals, context)
567 mail_alias.write(cr, uid, [vals['alias_id']], {"alias_defaults": {'job_id': res}}, context)
570 def unlink(self, cr, uid, ids, context=None):
571 # Cascade-delete mail aliases as well, as they should not exist without the job position.
572 mail_alias = self.pool.get('mail.alias')
573 alias_ids = [job.alias_id.id for job in self.browse(cr, uid, ids, context=context) if job.alias_id]
574 res = super(hr_job, self).unlink(cr, uid, ids, context=context)
575 mail_alias.unlink(cr, uid, alias_ids, context=context)
578 def action_print_survey(self, cr, uid, ids, context=None):
582 record = self.browse(cr, uid, ids, context=context)[0]
584 datas['ids'] = [record.survey_id.id]
585 datas['model'] = 'survey.print'
586 context.update({'response_id': [0], 'response_no': 0,})
588 'type': 'ir.actions.report.xml',
589 'report_name': 'survey.form',
595 class applicant_category(osv.osv):
596 """ Category of applicant """
597 _name = "hr.applicant_category"
598 _description = "Category of applicant"
600 'name': fields.char('Name', size=64, required=True, translate=True),
603 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: