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 ##############################################################################
25 from base_status.base_stage import base_stage
26 from datetime import datetime
27 from osv import fields, osv
28 from tools.translate import _
32 ('cancel', 'Refused'),
33 ('open', 'In Progress'),
34 ('pending', 'Pending'),
38 AVAILABLE_PRIORITIES = [
47 class hr_recruitment_source(osv.osv):
48 """ Sources of HR Recruitment """
49 _name = "hr.recruitment.source"
50 _description = "Source of Applicants"
52 'name': fields.char('Source Name', size=64, required=True, translate=True),
55 class hr_recruitment_stage(osv.osv):
56 """ Stage of HR Recruitment """
57 _name = "hr.recruitment.stage"
58 _description = "Stage of Recruitment"
61 'name': fields.char('Name', size=64, required=True, translate=True),
62 'sequence': fields.integer('Sequence', help="Gives the sequence order when displaying a list of stages."),
63 '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."),
64 '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."),
65 '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."),
66 'requirements': fields.text('Requirements'),
74 class hr_recruitment_degree(osv.osv):
75 """ Degree of HR Recruitment """
76 _name = "hr.recruitment.degree"
77 _description = "Degree of Recruitment"
79 'name': fields.char('Name', size=64, required=True, translate=True),
80 'sequence': fields.integer('Sequence', help="Gives the sequence order when displaying a list of degrees."),
86 ('name_uniq', 'unique (name)', 'The name of the Degree of Recruitment must be unique!')
89 class hr_applicant(base_stage, osv.Model):
90 _name = "hr.applicant"
91 _description = "Applicant"
93 _inherit = ['ir.needaction_mixin', 'mail.thread']
94 _mail_compose_message = True
96 def _get_default_department_id(self, cr, uid, context=None):
97 """ Gives default department by checking if present in the context """
98 return (self._resolve_department_id_from_context(cr, uid, context=context) or False)
100 def _get_default_stage_id(self, cr, uid, context=None):
101 """ Gives default stage_id """
102 department_id = self._get_default_department_id(cr, uid, context=context)
103 return self.stage_find(cr, uid, [], department_id, [('state', '=', 'draft')], context=context)
105 def _resolve_department_id_from_context(self, cr, uid, context=None):
106 """ Returns ID of department based on the value of 'default_department_id'
107 context key, or None if it cannot be resolved to a single
112 if type(context.get('default_department_id')) in (int, long):
113 return context.get('default_department_id')
114 if isinstance(context.get('default_department_id'), basestring):
115 department_name = context['default_department_id']
116 department_ids = self.pool.get('hr.department').name_search(cr, uid, name=department_name, context=context)
117 if len(department_ids) == 1:
118 return int(department_ids[0][0])
121 def _read_group_stage_ids(self, cr, uid, ids, domain, read_group_order=None, access_rights_uid=None, context=None):
122 access_rights_uid = access_rights_uid or uid
123 stage_obj = self.pool.get('hr.recruitment.stage')
124 order = stage_obj._order
125 # lame hack to allow reverting search, should just work in the trivial case
126 if read_group_order == 'stage_id desc':
127 order = "%s desc" % order
128 # retrieve section_id from the context and write the domain
129 # - ('id', 'in', 'ids'): add columns that should be present
130 # - OR ('department_id', '=', False), ('fold', '=', False): add default columns that are not folded
131 # - OR ('department_id', 'in', department_id), ('fold', '=', False) if department_id: add department columns that are not folded
132 department_id = self._resolve_department_id_from_context(cr, uid, context=context)
135 search_domain += ['|', '&', ('department_id', '=', department_id), ('fold', '=', False)]
136 search_domain += ['|', ('id', 'in', ids), '&', ('department_id', '=', False), ('fold', '=', False)]
137 stage_ids = stage_obj._search(cr, uid, search_domain, order=order, access_rights_uid=access_rights_uid, context=context)
138 result = stage_obj.name_get(cr, access_rights_uid, stage_ids, context=context)
139 # restore order of the search
140 result.sort(lambda x,y: cmp(stage_ids.index(x[0]), stage_ids.index(y[0])))
143 def _compute_day(self, cr, uid, ids, fields, args, context=None):
145 @param cr: the current row, from the database cursor,
146 @param uid: the current user’s ID for security checks,
147 @param ids: List of Openday’s IDs
148 @return: difference between current date and log date
149 @param context: A standard dictionary for contextual values
152 for issue in self.browse(cr, uid, ids, context=context):
159 if field in ['day_open']:
161 date_create = datetime.strptime(issue.create_date, "%Y-%m-%d %H:%M:%S")
162 date_open = datetime.strptime(issue.date_open, "%Y-%m-%d %H:%M:%S")
163 ans = date_open - date_create
164 date_until = issue.date_open
166 elif field in ['day_close']:
167 if issue.date_closed:
168 date_create = datetime.strptime(issue.create_date, "%Y-%m-%d %H:%M:%S")
169 date_close = datetime.strptime(issue.date_closed, "%Y-%m-%d %H:%M:%S")
170 date_until = issue.date_closed
171 ans = date_close - date_create
173 duration = float(ans.days)
174 res[issue.id][field] = abs(float(duration))
178 'name': fields.char('Subject', size=128, required=True),
179 'active': fields.boolean('Active', help="If the active field is set to false, it will allow you to hide the case without removing it."),
180 'description': fields.text('Description'),
181 'email_from': fields.char('Email', size=128, help="These people will receive email."),
182 '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"),
183 'probability': fields.float('Probability'),
184 'partner_id': fields.many2one('res.partner', 'Contact'),
185 'create_date': fields.datetime('Creation Date', readonly=True, select=True),
186 'write_date': fields.datetime('Update Date', readonly=True),
187 'stage_id': fields.many2one ('hr.recruitment.stage', 'Stage',
188 domain="['|', ('department_id', '=', department_id), ('department_id', '=', False)]"),
189 'state': fields.related('stage_id', 'state', type="selection", store=True,
190 selection=AVAILABLE_STATES, string="State", readonly=True,
191 help='The state is set to \'Draft\', when a case is created.\
192 If the case is in progress the state is set to \'Open\'.\
193 When the case is over, the state is set to \'Done\'.\
194 If the case needs to be reviewed then the state is \
195 set to \'Pending\'.'),
196 'categ_ids': fields.many2many('hr.applicant_category', string='Categories'),
197 'company_id': fields.many2one('res.company', 'Company'),
198 'user_id': fields.many2one('res.users', 'Responsible'),
200 'date_closed': fields.datetime('Closed', readonly=True, select=True),
201 'date_open': fields.datetime('Opened', readonly=True, select=True),
202 'date': fields.datetime('Date'),
203 'date_action': fields.date('Next Action Date'),
204 'title_action': fields.char('Next Action', size=64),
205 'priority': fields.selection(AVAILABLE_PRIORITIES, 'Appreciation'),
206 'job_id': fields.many2one('hr.job', 'Applied Job'),
207 'salary_proposed_extra': fields.char('Proposed Salary Extra', size=100, help="Salary Proposed by the Organisation, extra advantages"),
208 'salary_expected_extra': fields.char('Expected Salary Extra', size=100, help="Salary Expected by Applicant, extra advantages"),
209 'salary_proposed': fields.float('Proposed Salary', help="Salary Proposed by the Organisation"),
210 'salary_expected': fields.float('Expected Salary', help="Salary Expected by Applicant"),
211 'availability': fields.integer('Availability'),
212 'partner_name': fields.char("Applicant's Name", size=64),
213 'partner_phone': fields.char('Phone', size=32),
214 'partner_mobile': fields.char('Mobile', size=32),
215 'type_id': fields.many2one('hr.recruitment.degree', 'Degree'),
216 'department_id': fields.many2one('hr.department', 'Department'),
217 'survey': fields.related('job_id', 'survey_id', type='many2one', relation='survey', string='Survey'),
218 'response': fields.integer("Response"),
219 'reference': fields.char('Referred By', size=128),
220 'source_id': fields.many2one('hr.recruitment.source', 'Source'),
221 'day_open': fields.function(_compute_day, string='Days to Open', \
222 multi='day_open', type="float", store=True),
223 'day_close': fields.function(_compute_day, string='Days to Close', \
224 multi='day_close', type="float", store=True),
225 'color': fields.integer('Color Index'),
226 'emp_id': fields.many2one('hr.employee', 'employee'),
227 'user_email': fields.related('user_id', 'email', type='char', string='User Email', readonly=True),
231 'active': lambda *a: 1,
232 'user_id': lambda s, cr, uid, c: uid,
233 'email_from': lambda s, cr, uid, c: s._get_default_email(cr, uid, c),
234 'stage_id': lambda s, cr, uid, c: s._get_default_stage_id(cr, uid, c),
235 'department_id': lambda s, cr, uid, c: s._get_default_department_id(cr, uid, c),
236 'priority': lambda *a: '',
237 'company_id': lambda s, cr, uid, c: s.pool.get('res.company')._company_default_get(cr, uid, 'hr.applicant', context=c),
242 'stage_id': _read_group_stage_ids
245 def onchange_job(self,cr, uid, ids, job, context=None):
249 job_obj = self.pool.get('hr.job')
250 result['department_id'] = job_obj.browse(cr, uid, job, context=context).department_id.id
251 return {'value': result}
252 return {'value': {'department_id': False}}
254 def onchange_department_id(self, cr, uid, ids, department_id=False, context=None):
255 obj_recru_stage = self.pool.get('hr.recruitment.stage')
256 stage_ids = obj_recru_stage.search(cr, uid, ['|',('department_id','=',department_id),('department_id','=',False)], context=context)
257 stage_id = stage_ids and stage_ids[0] or False
258 return {'value': {'stage_id': stage_id}}
260 def stage_find(self, cr, uid, cases, section_id, domain=[], order='sequence', context=None):
261 """ Override of the base.stage method
262 Parameter of the stage search taken from the lead:
263 - department_id: if set, stages must belong to this section or
266 if isinstance(cases, (int, long)):
267 cases = self.browse(cr, uid, cases, context=context)
268 # collect all section_ids
271 department_ids.append(section_id)
273 if case.department_id:
274 department_ids.append(case.department_id.id)
275 # OR all section_ids and OR with case_default
278 search_domain += ['|', ('department_id', 'in', department_ids)]
279 search_domain.append(('department_id', '=', False))
280 # AND with the domain in parameter
281 search_domain += list(domain)
282 # perform search, return the first found
283 stage_ids = self.pool.get('hr.recruitment.stage').search(cr, uid, search_domain, order=order, context=context)
288 def action_makeMeeting(self, cr, uid, ids, context=None):
289 """ This opens Meeting's calendar view to schedule meeting on current applicant
290 @return: Dictionary value for created Meeting view
292 applicant = self.browse(cr, uid, ids[0], context)
293 category = self.pool.get('ir.model.data').get_object(cr, uid, 'hr_recruitment', 'categ_meet_interview', context)
294 res = self.pool.get('ir.actions.act_window').for_xml_id(cr, uid, 'base_calendar', 'action_crm_meeting', context)
296 'default_partner_ids': applicant.partner_id and [applicant.partner_id.id] or False,
297 'default_user_id': uid,
298 'default_state': 'open',
299 'default_name': applicant.name,
300 'default_categ_ids': category and [category.id] or False,
304 def action_print_survey(self, cr, uid, ids, context=None):
306 If response is available then print this response otherwise print survey form(print template of the survey).
308 @param self: The object pointer
309 @param cr: the current row, from the database cursor,
310 @param uid: the current user’s ID for security checks,
311 @param ids: List of Survey IDs
312 @param context: A standard dictionary for contextual values
313 @return: Dictionary value for print survey form.
317 record = self.browse(cr, uid, ids, context=context)
318 record = record and record[0]
319 context.update({'survey_id': record.survey.id, 'response_id': [record.response], 'response_no': 0, })
320 value = self.pool.get("survey").action_print_survey(cr, uid, ids, context=context)
323 def message_new(self, cr, uid, msg, custom_values=None, context=None):
324 """ Overrides mail_thread message_new that is called by the mailgateway
325 through message_process.
326 This override updates the document according to the email.
328 if custom_values is None: custom_values = {}
329 custom_values.update({
330 'name': msg.get('subject') or _("No Subject"),
331 'description': msg.get('body_text'),
332 'email_from': msg.get('from'),
333 'email_cc': msg.get('cc'),
336 if msg.get('priority'):
337 custom_values['priority'] = msg.get('priority')
338 custom_values.update(self.message_partner_by_email(cr, uid, msg.get('from', False), context=context))
339 return super(hr_applicant,self).message_new(cr, uid, msg, custom_values=custom_values, context=context)
341 def message_update(self, cr, uid, ids, msg, update_vals=None, context=None):
342 """ Override mail_thread message_update that is called by the mailgateway
343 through message_process.
344 This method updates the document according to the email.
346 if isinstance(ids, (str, int, long)):
348 if update_vals is None: vals = {}
351 'description': msg.get('body'),
352 'email_from': msg.get('from'),
353 'email_cc': msg.get('cc'),
355 if msg.get('priority'):
356 update_vals['priority'] = msg.get('priority')
359 'cost': 'planned_cost',
360 'revenue': 'planned_revenue',
361 'probability': 'probability',
363 for line in msg.get('body_text', '').split('\n'):
365 res = tools.misc.command_re.match(line)
366 if res and maps.get(res.group(1).lower(), False):
367 key = maps.get(res.group(1).lower())
368 update_vals[key] = res.group(2).lower()
370 return super(hr_applicant, self).message_update(cr, uids, ids, update_vals=update_vals, context=context)
372 def create(self, cr, uid, vals, context=None):
373 obj_id = super(hr_applicant, self).create(cr, uid, vals, context=context)
374 self.create_send_note(cr, uid, [obj_id], context=context)
377 def case_open(self, cr, uid, ids, context=None):
379 open Request of the applicant for the hr_recruitment
381 res = super(hr_applicant, self).case_open(cr, uid, ids, context)
382 date = self.read(cr, uid, ids, ['date_open'])[0]
383 if not date['date_open']:
384 self.write(cr, uid, ids, {'date_open': time.strftime('%Y-%m-%d %H:%M:%S'),})
387 def case_close(self, cr, uid, ids, context=None):
388 res = super(hr_applicant, self).case_close(cr, uid, ids, context)
391 def case_close_with_emp(self, cr, uid, ids, context=None):
394 hr_employee = self.pool.get('hr.employee')
395 model_data = self.pool.get('ir.model.data')
396 act_window = self.pool.get('ir.actions.act_window')
398 for applicant in self.browse(cr, uid, ids, context=context):
400 if applicant.partner_id:
401 address_id = applicant.partner_id.address_get(['contact'])['contact']
403 applicant.job_id.write({'no_of_recruitment': applicant.job_id.no_of_recruitment - 1})
404 emp_id = hr_employee.create(cr,uid,{'name': applicant.partner_name or applicant.name,
405 'job_id': applicant.job_id.id,
406 'address_home_id': address_id,
407 'department_id': applicant.department_id.id
409 self.write(cr, uid, [applicant.id], {'emp_id': emp_id}, context=context)
410 self.case_close(cr, uid, [applicant.id], context)
412 raise osv.except_osv(_('Warning!'),_('You must define Applied Job for this applicant.'))
414 action_model, action_id = model_data.get_object_reference(cr, uid, 'hr', 'open_view_employee_list')
415 dict_act_window = act_window.read(cr, uid, action_id, [])
417 dict_act_window['res_id'] = emp_id
418 dict_act_window['view_mode'] = 'form,tree'
419 return dict_act_window
421 def case_cancel(self, cr, uid, ids, context=None):
422 """Overrides cancel for crm_case for setting probability
424 res = super(hr_applicant, self).case_cancel(cr, uid, ids, context)
425 self.write(cr, uid, ids, {'probability' : 0.0})
428 def case_pending(self, cr, uid, ids, context=None):
429 """Marks case as pending"""
430 res = super(hr_applicant, self).case_pending(cr, uid, ids, context)
431 self.write(cr, uid, ids, {'probability' : 0.0})
434 def case_reset(self, cr, uid, ids, context=None):
435 """Resets case as draft
437 res = super(hr_applicant, self).case_reset(cr, uid, ids, context)
438 self.write(cr, uid, ids, {'date_open': False, 'date_closed': False})
441 def set_priority(self, cr, uid, ids, priority, *args):
442 """Set applicant priority
444 return self.write(cr, uid, ids, {'priority' : priority})
446 def set_high_priority(self, cr, uid, ids, *args):
447 """Set applicant priority to high
449 return self.set_priority(cr, uid, ids, '1')
451 def set_normal_priority(self, cr, uid, ids, *args):
452 """Set applicant priority to normal
454 return self.set_priority(cr, uid, ids, '3')
456 # -------------------------------------------------------
457 # OpenChatter methods and notifications
458 # -------------------------------------------------------
460 def message_get_monitored_follower_fields(self, cr, uid, ids, context=None):
461 """ Add 'user_id' to the monitored fields """
462 res = super(hr_applicant, self).message_get_monitored_follower_fields(cr, uid, ids, context=context)
463 return res + ['user_id']
465 def stage_set_send_note(self, cr, uid, ids, stage_id, context=None):
466 """ Override of the (void) default notification method. """
467 if not stage_id: return True
468 stage_name = self.pool.get('hr.recruitment.stage').name_get(cr, uid, [stage_id], context=context)[0][1]
469 return self.message_append_note(cr, uid, ids, body= _("Stage changed to <b>%s</b>.") % (stage_name), context=context)
471 def case_get_note_msg_prefix(self, cr, uid, id, context=None):
474 def case_open_send_note(self, cr, uid, ids, context=None):
475 message = _("Applicant has been set <b>in progress</b>.")
476 return self.message_append_note(cr, uid, ids, body=message, context=context)
478 def case_close_send_note(self, cr, uid, ids, context=None):
481 for applicant in self.browse(cr, uid, ids, context=context):
483 message = _("Applicant has been <b>hired</b> and created as an employee.")
484 self.message_append_note(cr, uid, [applicant.id], body=message, context=context)
486 message = _("Applicant has been <b>hired</b>.")
487 self.message_append_note(cr, uid, [applicant.id], body=message, context=context)
490 def case_cancel_send_note(self, cr, uid, ids, context=None):
491 msg = 'Applicant <b>refused</b>.'
492 return self.message_append_note(cr, uid, ids, body=msg, context=context)
494 def case_reset_send_note(self, cr, uid, ids, context=None):
495 message =_("Applicant has been set as <b>new</b>.")
496 return self.message_append_note(cr, uid, ids, body=message, context=context)
498 def create_send_note(self, cr, uid, ids, context=None):
499 message = _("Applicant has been <b>created</b>.")
500 return self.message_append_note(cr, uid, ids, body=message, context=context)
503 class hr_job(osv.osv):
506 _inherits = {'mail.alias': 'alias_id'}
508 '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"),
509 'alias_id': fields.many2one('mail.alias', 'Alias', ondelete="cascade", required=True,
510 help="Email alias for this job position. New emails will automatically "
511 "create new applicants for this job position."),
515 'alias_domain': False, # always hide alias during creation
518 def _auto_init(self, cr, context=None):
519 """Installation hook to create aliases for all jobs and avoid constraint errors."""
520 self.pool.get('mail.alias').migrate_to_alias(cr, self._name, self._table, super(hr_job,self)._auto_init,
521 self._columns['alias_id'], 'name', alias_prefix='job+', alias_defaults={'job_id': 'id'}, context=context)
523 def create(self, cr, uid, vals, context=None):
524 mail_alias = self.pool.get('mail.alias')
525 if not vals.get('alias_id'):
526 vals.pop('alias_name', None) # prevent errors during copy()
527 alias_id = mail_alias.create_unique_alias(cr, uid,
528 # Using '+' allows using subaddressing for those who don't
529 # have a catchall domain setup.
530 {'alias_name': 'jobs+'+vals['name']},
531 model_name="hr.applicant",
533 vals['alias_id'] = alias_id
534 res = super(hr_job, self).create(cr, uid, vals, context)
535 mail_alias.write(cr, uid, [vals['alias_id']], {"alias_defaults": {'job_id': res}}, context)
538 def unlink(self, cr, uid, ids, context=None):
539 # Cascade-delete mail aliases as well, as they should not exist without the job position.
540 mail_alias = self.pool.get('mail.alias')
541 alias_ids = [job.alias_id.id for job in self.browse(cr, uid, ids, context=context) if job.alias_id]
542 res = super(hr_job, self).unlink(cr, uid, ids, context=context)
543 mail_alias.unlink(cr, uid, alias_ids, context=context)
546 def action_print_survey(self, cr, uid, ids, context=None):
550 record = self.browse(cr, uid, ids, context=context)[0]
552 datas['ids'] = [record.survey_id.id]
553 datas['model'] = 'survey.print'
554 context.update({'response_id': [0], 'response_no': 0,})
556 'type': 'ir.actions.report.xml',
557 'report_name': 'survey.form',
563 class applicant_category(osv.osv):
564 """ Category of applicant """
565 _name = "hr.applicant_category"
566 _description = "Category of applicant"
568 'name': fields.char('Name', size=64, required=True, translate=True),
571 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: