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 ##############################################################################
23 from datetime import datetime, timedelta
25 from osv import fields, osv
31 from tools.translate import _
32 from crm import wizard
34 wizard.mail_compose_message.SUPPORTED_MODELS.append('hr.applicant')
38 ('open', 'In Progress'),
39 ('cancel', 'Refused'),
41 ('pending', 'Pending')
44 AVAILABLE_PRIORITIES = [
53 class hr_recruitment_source(osv.osv):
54 """ Sources of HR Recruitment """
55 _name = "hr.recruitment.source"
56 _description = "Source of Applicants"
58 'name': fields.char('Source Name', size=64, required=True, translate=True),
60 hr_recruitment_source()
63 class hr_recruitment_stage(osv.osv):
64 """ Stage of HR Recruitment """
65 _name = "hr.recruitment.stage"
66 _description = "Stage of Recruitment"
69 'name': fields.char('Name', size=64, required=True, translate=True),
70 'sequence': fields.integer('Sequence', help="Gives the sequence order when displaying a list of stages."),
71 '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 tempy this field."),
72 'requirements': fields.text('Requirements')
77 hr_recruitment_stage()
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!')
93 hr_recruitment_degree()
95 class hr_applicant(crm.crm_case, osv.osv):
96 _name = "hr.applicant"
97 _description = "Applicant"
99 _inherit = ['mail.thread']
101 def _compute_day(self, cr, uid, ids, fields, args, context=None):
103 @param cr: the current row, from the database cursor,
104 @param uid: the current user’s ID for security checks,
105 @param ids: List of Openday’s IDs
106 @return: difference between current date and log date
107 @param context: A standard dictionary for contextual values
110 for issue in self.browse(cr, uid, ids, context=context):
117 if field in ['day_open']:
119 date_create = datetime.strptime(issue.create_date, "%Y-%m-%d %H:%M:%S")
120 date_open = datetime.strptime(issue.date_open, "%Y-%m-%d %H:%M:%S")
121 ans = date_open - date_create
122 date_until = issue.date_open
124 elif field in ['day_close']:
125 if issue.date_closed:
126 date_create = datetime.strptime(issue.create_date, "%Y-%m-%d %H:%M:%S")
127 date_close = datetime.strptime(issue.date_closed, "%Y-%m-%d %H:%M:%S")
128 date_until = issue.date_closed
129 ans = date_close - date_create
131 duration = float(ans.days)
132 res[issue.id][field] = abs(float(duration))
136 'name': fields.char('Name', size=128, required=True),
137 'message_ids': fields.one2many('mail.message', 'res_id', 'Messages', domain=[('model','=',_name)]),
138 'active': fields.boolean('Active', help="If the active field is set to false, it will allow you to hide the case without removing it."),
139 'description': fields.text('Description'),
140 'email_from': fields.char('Email', size=128, help="These people will receive email."),
141 '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"),
142 'probability': fields.float('Probability'),
143 'partner_id': fields.many2one('res.partner', 'Partner'),
144 'partner_address_id': fields.many2one('res.partner.address', 'Partner Contact', \
145 domain="[('partner_id','=',partner_id)]"),
146 'create_date': fields.datetime('Creation Date', readonly=True, select=True),
147 'write_date': fields.datetime('Update Date', readonly=True),
148 'stage_id': fields.many2one ('hr.recruitment.stage', 'Stage'),
149 'state': fields.selection(AVAILABLE_STATES, 'State', size=16, readonly=True,
150 help='The state is set to \'Draft\', when a case is created.\
151 \nIf the case is in progress the state is set to \'Open\'.\
152 \nWhen the case is over, the state is set to \'Done\'.\
153 \nIf the case needs to be reviewed then the state is set to \'Pending\'.'),
154 'company_id': fields.many2one('res.company', 'Company'),
155 'user_id': fields.many2one('res.users', 'Responsible'),
157 'date_closed': fields.datetime('Closed', readonly=True, select=True),
158 'date_open': fields.datetime('Opened', readonly=True, select=True),
159 'date': fields.datetime('Date'),
160 'date_action': fields.date('Next Action Date'),
161 'title_action': fields.char('Next Action', size=64),
162 'priority': fields.selection(AVAILABLE_PRIORITIES, 'Appreciation'),
163 'job_id': fields.many2one('hr.job', 'Applied Job'),
164 'salary_proposed_extra': fields.char('Proposed Salary Extra', size=100, help="Salary Proposed by the Organisation, extra advantages"),
165 'salary_expected_extra': fields.char('Expected Salary Extra', size=100, help="Salary Expected by Applicant, extra advantages"),
166 'salary_proposed': fields.float('Proposed Salary', help="Salary Proposed by the Organisation"),
167 'salary_expected': fields.float('Expected Salary', help="Salary Expected by Applicant"),
168 'availability': fields.integer('Availability (Days)'),
169 'partner_name': fields.char("Applicant's Name", size=64),
170 'partner_phone': fields.char('Phone', size=32),
171 'partner_mobile': fields.char('Mobile', size=32),
172 'type_id': fields.many2one('hr.recruitment.degree', 'Degree'),
173 'department_id': fields.many2one('hr.department', 'Department'),
174 'survey': fields.related('job_id', 'survey_id', type='many2one', relation='survey', string='Survey'),
175 'response': fields.integer("Response"),
176 'reference': fields.char('Refered By', size=128),
177 'source_id': fields.many2one('hr.recruitment.source', 'Source'),
178 'day_open': fields.function(_compute_day, string='Days to Open', \
179 multi='day_open', type="float", store=True),
180 'day_close': fields.function(_compute_day, string='Days to Close', \
181 multi='day_close', type="float", store=True),
182 'color': fields.integer('Color Index'),
183 'emp_id': fields.many2one('hr.employee', 'employee'),
184 'user_email': fields.related('user_id', 'user_email', type='char', string='User Email', readonly=True),
188 'active': lambda *a: 1,
189 'user_id': lambda self, cr, uid, context: uid,
190 'email_from': crm.crm_case. _get_default_email,
191 'state': lambda *a: 'draft',
192 'priority': lambda *a: '',
193 'company_id': lambda s, cr, uid, c: s.pool.get('res.company')._company_default_get(cr, uid, 'crm.helpdesk', context=c),
197 def _read_group_stage_ids(self, cr, uid, ids, domain, read_group_order=None, access_rights_uid=None, context=None):
198 access_rights_uid = access_rights_uid or uid
199 stage_obj = self.pool.get('hr.recruitment.stage')
200 order = stage_obj._order
201 if read_group_order == 'stage_id desc':
202 # lame hack to allow reverting search, should just work in the trivial case
203 order = "%s desc" % order
204 stage_ids = stage_obj._search(cr, uid, ['|',('id','in',ids),('department_id','=',False)], order=order,
205 access_rights_uid=access_rights_uid, context=context)
206 result = stage_obj.name_get(cr, access_rights_uid, stage_ids, context=context)
207 # restore order of the search
208 result.sort(lambda x,y: cmp(stage_ids.index(x[0]), stage_ids.index(y[0])))
212 'stage_id': _read_group_stage_ids
216 def onchange_job(self,cr, uid, ids, job, context=None):
220 job_obj = self.pool.get('hr.job')
221 result['department_id'] = job_obj.browse(cr, uid, job, context=context).department_id.id
222 return {'value': result}
223 return {'value': {'department_id': False}}
225 def onchange_department_id(self, cr, uid, ids, department_id=False, context=None):
226 if not department_id:
227 return {'value': {'stage_id': False}}
228 obj_recru_stage = self.pool.get('hr.recruitment.stage')
229 stage_ids = obj_recru_stage.search(cr, uid, ['|',('department_id','=',department_id),('department_id','=',False)], context=context)
230 stage_id = stage_ids and stage_ids[0] or False
231 return {'value': {'stage_id': stage_id}}
233 def stage_previous(self, cr, uid, ids, context=None):
234 """This function computes previous stage for case from its current stage
235 using available stage for that case type
236 @param self: The object pointer
237 @param cr: the current row, from the database cursor,
238 @param uid: the current user’s ID for security checks,
239 @param ids: List of case IDs
240 @param context: A standard dictionary for contextual values"""
241 stage_obj = self.pool.get('hr.recruitment.stage')
242 for case in self.browse(cr, uid, ids, context=context):
243 department = (case.department_id.id or False)
244 st = case.stage_id.id or False
245 stage_ids = stage_obj.search(cr, uid, ['|',('department_id','=',department),('department_id','=',False)], context=context)
246 if st and stage_ids.index(st):
247 self.write(cr, uid, [case.id], {'stage_id': stage_ids[stage_ids.index(st)-1]}, context=context)
249 self.write(cr, uid, [case.id], {'stage_id': False}, context=context)
252 def stage_next(self, cr, uid, ids, context=None):
253 """This function computes next stage for case from its current stage
254 using available stage for that case type
255 @param self: The object pointer
256 @param cr: the current row, from the database cursor,
257 @param uid: the current user’s ID for security checks,
258 @param ids: List of case IDs
259 @param context: A standard dictionary for contextual values"""
260 stage_obj = self.pool.get('hr.recruitment.stage')
261 for case in self.browse(cr, uid, ids, context=context):
262 department = (case.department_id.id or False)
263 st = case.stage_id.id or False
264 stage_ids = stage_obj.search(cr, uid, ['|',('department_id','=',department),('department_id','=',False)], context=context)
266 if st and len(stage_ids) != stage_ids.index(st)+1:
267 val = stage_ids[stage_ids.index(st)+1]
268 elif (not st) and stage_ids:
272 self.write(cr, uid, [case.id], {'stage_id': val}, context=context)
275 def action_makeMeeting(self, cr, uid, ids, context=None):
277 This opens Meeting's calendar view to schedule meeting on current Opportunity
278 @param self: The object pointer
279 @param cr: the current row, from the database cursor,
280 @param uid: the current user’s ID for security checks,
281 @param ids: List of Opportunity to Meeting IDs
282 @param context: A standard dictionary for contextual values
284 @return: Dictionary value for created Meeting view
286 data_obj = self.pool.get('ir.model.data')
290 for opp in self.browse(cr, uid, ids, context=context):
292 result = data_obj._get_id(cr, uid, 'crm', 'view_crm_case_meetings_filter')
293 res = data_obj.read(cr, uid, result, ['res_id'], context=context)
294 id1 = data_obj._get_id(cr, uid, 'crm', 'crm_case_calendar_view_meet')
295 id2 = data_obj._get_id(cr, uid, 'crm', 'crm_case_form_view_meet')
296 id3 = data_obj._get_id(cr, uid, 'crm', 'crm_case_tree_view_meet')
298 id1 = data_obj.browse(cr, uid, id1, context=context).res_id
300 id2 = data_obj.browse(cr, uid, id2, context=context).res_id
302 id3 = data_obj.browse(cr, uid, id3, context=context).res_id
305 'default_partner_id': opp.partner_id and opp.partner_id.id or False,
306 'default_email_from': opp.email_from,
307 'default_state': 'open',
308 'default_name': opp.name
311 'name': ('Meetings'),
312 'domain': "[('user_id','=',%s)]" % (uid),
315 'view_mode': 'calendar,form,tree',
316 'res_model': 'crm.meeting',
318 'views': [(id1, 'calendar'), (id2, 'form'), (id3, 'tree')],
319 'type': 'ir.actions.act_window',
320 'search_view_id': res['res_id'],
325 def action_print_survey(self, cr, uid, ids, context=None):
327 If response is available then print this response otherwise print survey form(print template of the survey).
329 @param self: The object pointer
330 @param cr: the current row, from the database cursor,
331 @param uid: the current user’s ID for security checks,
332 @param ids: List of Survey IDs
333 @param context: A standard dictionary for contextual values
334 @return: Dictionary value for print survey form.
338 record = self.browse(cr, uid, ids, context=context)
339 record = record and record[0]
340 context.update({'survey_id': record.survey.id, 'response_id': [record.response], 'response_no': 0, })
341 value = self.pool.get("survey").action_print_survey(cr, uid, ids, context=context)
344 def message_new(self, cr, uid, msg, custom_values=None, context=None):
345 """Automatically called when new email message arrives"""
346 res_id = super(hr_applicant,self).message_new(cr, uid, msg, custom_values=custom_values, context=context)
347 subject = msg.get('subject') or _("No Subject")
348 body = msg.get('body_text')
349 msg_from = msg.get('from')
350 priority = msg.get('priority')
353 'email_from': msg_from,
354 'email_cc': msg.get('cc'),
359 vals['priority'] = priority
360 vals.update(self.message_partner_by_email(cr, uid, msg.get('from', False)))
361 self.write(cr, uid, [res_id], vals, context)
364 def message_update(self, cr, uid, ids, msg, vals=None, default_act='pending', context=None):
365 if isinstance(ids, (str, int, long)):
369 msg_from = msg['from']
371 'description': msg['body_text']
373 if msg.get('priority', False):
374 vals['priority'] = msg.get('priority')
377 'cost':'planned_cost',
378 'revenue': 'planned_revenue',
379 'probability':'probability'
382 for line in msg['body_text'].split('\n'):
384 res = tools.misc.command_re.match(line)
385 if res and maps.get(res.group(1).lower(), False):
386 key = maps.get(res.group(1).lower())
387 vls[key] = res.group(2).lower()
390 res = self.write(cr, uid, ids, vals, context=context)
391 self.message_append_dict(cr, uid, ids, msg, context=context)
394 def _case_open_notification(self, case, context=None):
395 message = _("Changed Status to <b>in Progress<b>.")
396 case.message_append_note('' ,message, type='notification')
399 def _case_close_notification(self, case, context=None):
400 case[0].message_mark_done(context)
402 message = _("Applicant is <b>hired</b> and employee created.")
403 case[0].message_append_note('' ,message, type='notification')
405 message = _("Applicant is <b>hired</b>.")
406 case[0].message_append_note('' ,message, type='notification')
409 def _case_cancel_notification(self, case, context=None):
410 case[0].message_mark_done(context=context)
411 message = _("Applicant is <b>cancelled<b>.")
412 case[0].message_append_note('' ,message, type="notification")
415 def _case_pending_notification(self, case, context=None):
416 message = _("Changed Status to <b>pending<b>.")
417 case[0].message_append_note('' ,message, type='notification')
420 def _case_reset_notification(self, cr, uid, ids, context=None):
421 for obj in self.browse(cr, uid, ids, context=context):
422 self.message_append_note(cr, uid, ids, _('System notification'),
423 _("Changed Status to <b>new<b>."), type='notification', need_action_user_id=obj.user_id.id, context=context)
426 def create_notificate(self, cr, uid, ids, context=None):
427 for obj in self.browse(cr, uid, ids, context=context):
428 self.message_subscribe(cr, uid, ids, [obj.user_id.id], context=context)
429 self.message_append_note(cr, uid, ids, _('System notification'),
430 _("Applicant is <b>created</b>."), type='notification', need_action_user_id=obj.user_id.id, context=context)
433 def create(self, cr, uid, vals, context=None):
434 obj_id = super(hr_applicant, self).create(cr, uid, vals, context=context)
435 self.create_notificate(cr, uid, [obj_id], context=context)
438 def case_open(self, cr, uid, ids, context=None):
440 open Request of the applicant for the hr_recruitment
442 res = super(hr_applicant, self).case_open(cr, uid, ids, context)
443 date = self.read(cr, uid, ids, ['date_open'])[0]
444 if not date['date_open']:
445 self.write(cr, uid, ids, {'date_open': time.strftime('%Y-%m-%d %H:%M:%S'),})
448 def case_close(self, cr, uid, ids, context=None):
449 res = super(hr_applicant, self).case_close(cr, uid, ids, context)
452 def case_close_with_emp(self, cr, uid, ids, context=None):
453 hr_employee = self.pool.get('hr.employee')
454 model_data = self.pool.get('ir.model.data')
455 act_window = self.pool.get('ir.actions.act_window')
457 for applicant in self.browse(cr, uid, ids):
459 if applicant.partner_id:
460 address_id = applicant.partner_id.address_get(['contact'])['contact']
462 applicant.job_id.write({'no_of_recruitment': applicant.job_id.no_of_recruitment - 1})
463 emp_id = hr_employee.create(cr,uid,{'name': applicant.partner_name or applicant.name,
464 'job_id': applicant.job_id.id,
465 'address_home_id': address_id,
466 'department_id': applicant.department_id.id
468 self.write(cr, uid, [applicant.id], {'emp_id': emp_id})
469 self.case_close(cr, uid, [applicant.id], context)
471 raise osv.except_osv(_('Warning!'),_('You must define Applied Job for this applicant.'))
473 action_model, action_id = model_data.get_object_reference(cr, uid, 'hr', 'open_view_employee_list')
474 dict_act_window = act_window.read(cr, uid, action_id, [])
476 dict_act_window['res_id'] = emp_id
477 dict_act_window['view_mode'] = 'form,tree'
478 return dict_act_window
480 def case_cancel(self, cr, uid, ids, context=None):
481 """Overrides cancel for crm_case for setting probability
483 res = super(hr_applicant, self).case_cancel(cr, uid, ids, context)
484 self.write(cr, uid, ids, {'probability' : 0.0})
487 def case_pending(self, cr, uid, ids, context=None):
488 """Marks case as pending"""
489 res = super(hr_applicant, self).case_pending(cr, uid, ids, context)
490 self.write(cr, uid, ids, {'probability' : 0.0})
493 def case_reset(self, cr, uid, ids, context=None):
494 """Resets case as draft
496 res = super(hr_applicant, self).case_reset(cr, uid, ids, context)
497 self.write(cr, uid, ids, {'date_open': False, 'date_closed': False})
498 self._case_reset_notification(cr, uid, ids, context)
501 def set_priority(self, cr, uid, ids, priority, *args):
502 """Set applicant priority
504 return self.write(cr, uid, ids, {'priority' : priority})
506 def set_high_priority(self, cr, uid, ids, *args):
507 """Set applicant priority to high
509 return self.set_priority(cr, uid, ids, '1')
511 def set_normal_priority(self, cr, uid, ids, *args):
512 """Set applicant priority to normal
514 return self.set_priority(cr, uid, ids, '3')
516 def write(self, cr, uid, ids, vals, context=None):
517 if 'stage_id' in vals and vals['stage_id']:
518 stage = self.pool.get('hr.recruitment.stage').browse(cr, uid, vals['stage_id'], context=context)
519 self.message_append_note(cr, uid, ids, _('System notification'),
520 _("Changed stage to <b>%s</b>.") % stage.name, type='notification')
521 return super(hr_applicant,self).write(cr, uid, ids, vals, context=context)
525 class hr_job(osv.osv):
529 '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"),
533 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: