addons/hr_recruitment/hr_recruitment.py

   1 # -*- coding: utf-8 -*-
   2 ##############################################################################
   3 #
   4 #    OpenERP, Open Source Management Solution
   5 #    Copyright (C) 2004-2009 Tiny SPRL (<http://tiny.be>).
   6 #
   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.
  11 #
  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.
  16 #
  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/>.
  19 #
  20 ##############################################################################
  21
  22 import time
  23 from datetime import datetime, timedelta
  24
  25 from osv import fields, osv
  26 from crm import crm
  27 import tools
  28 import collections
  29 import binascii
  30 import tools
  31 from tools.translate import _
  32
  33 AVAILABLE_STATES = [
  34     ('draft', 'New'),
  35     ('open', 'In Progress'),
  36     ('cancel', 'Refused'),
  37     ('done', 'Hired'),
  38     ('pending', 'Pending')
  39 ]
  40
  41 AVAILABLE_PRIORITIES = [
  42     ('5', 'Not Good'),
  43     ('4', 'On Average'),
  44     ('3', 'Good'),
  45     ('2', 'Very Good'),
  46     ('1', 'Excellent')
  47 ]
  48
  49 class hr_recruitment_stage(osv.osv):
  50     """ Stage of HR Recruitment """
  51     _name = "hr.recruitment.stage"
  52     _description = "Stage of Recruitment"
  53     _order = 'sequence'
  54     _columns = {
  55         'name': fields.char('Name', size=64, required=True, translate=True),
  56         'sequence': fields.integer('Sequence', help="Gives the sequence order when displaying a list of stages."),
  57         'department_id':fields.many2one('hr.department', 'Department'),
  58         'requirements': fields.text('Requirements')
  59     }
  60     _defaults = {
  61         'sequence': 1,
  62     }
  63 hr_recruitment_stage()
  64
  65 class hr_recruitment_degree(osv.osv):
  66     """ Degree of HR Recruitment """
  67     _name = "hr.recruitment.degree"
  68     _description = "Degree of Recruitment"
  69     _columns = {
  70         'name': fields.char('Name', size=64, required=True, translate=True),
  71         'sequence': fields.integer('Sequence', help="Gives the sequence order when displaying a list of degrees."),
  72     }
  73     _defaults = {
  74         'sequence': 1,
  75     }
  76 hr_recruitment_degree()
  77
  78 class hr_applicant(crm.crm_case, osv.osv):
  79     _name = "hr.applicant"
  80     _description = "Applicant"
  81     _order = "id desc"
  82     _inherit = ['mailgate.thread']
  83
  84     def _compute_day(self, cr, uid, ids, fields, args, context=None):
  85         """
  86         @param cr: the current row, from the database cursor,
  87         @param uid: the current user’s ID for security checks,
  88         @param ids: List of Openday’s IDs
  89         @return: difference between current date and log date
  90         @param context: A standard dictionary for contextual values
  91         """
  92         res = {}
  93         for issue in self.browse(cr, uid, ids, context=context):
  94             for field in fields:
  95                 res[issue.id] = {}
  96                 duration = 0
  97                 ans = False
  98                 hours = 0
  99
 100                 if field in ['day_open']:
 101                     if issue.date_open:
 102                         date_create = datetime.strptime(issue.create_date, "%Y-%m-%d %H:%M:%S")
 103                         date_open = datetime.strptime(issue.date_open, "%Y-%m-%d %H:%M:%S")
 104                         ans = date_open - date_create
 105                         date_until = issue.date_open
 106
 107                 elif field in ['day_close']:
 108                     if issue.date_closed:
 109                         date_create = datetime.strptime(issue.create_date, "%Y-%m-%d %H:%M:%S")
 110                         date_close = datetime.strptime(issue.date_closed, "%Y-%m-%d %H:%M:%S")
 111                         date_until = issue.date_closed
 112                         ans = date_close - date_create
 113                 if ans:
 114                     duration = float(ans.days)
 115                     res[issue.id][field] = abs(float(duration))
 116         return res
 117
 118     _columns = {
 119         'name': fields.char('Name', size=128, required=True),
 120         'message_ids': fields.one2many('mailgate.message', 'res_id', 'Messages', domain=[('model','=',_name)]),
 121         'active': fields.boolean('Active', help="If the active field is set to false, it will allow you to hide the case without removing it."),
 122         'description': fields.text('Description'),
 123         'email_from': fields.char('Email', size=128, help="These people will receive email."),
 124         '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"),
 125         'probability': fields.float('Probability'),
 126         'partner_id': fields.many2one('res.partner', 'Partner'),
 127         'partner_address_id': fields.many2one('res.partner.address', 'Partner Contact', \
 128                                  domain="[('partner_id','=',partner_id)]"),
 129         'create_date': fields.datetime('Creation Date', readonly=True),
 130         'write_date': fields.datetime('Update Date', readonly=True),
 131         'stage_id': fields.many2one ('hr.recruitment.stage', 'Stage'),
 132         'state': fields.selection(AVAILABLE_STATES, 'State', size=16, readonly=True,
 133                                   help='The state is set to \'Draft\', when a case is created.\
 134                                   \nIf the case is in progress the state is set to \'Open\'.\
 135                                   \nWhen the case is over, the state is set to \'Done\'.\
 136                                   \nIf the case needs to be reviewed then the state is set to \'Pending\'.'),
 137         'company_id': fields.many2one('res.company', 'Company'),
 138         'user_id': fields.many2one('res.users', 'Responsible'),
 139         # Applicant Columns
 140         'date_closed': fields.datetime('Closed', readonly=True),
 141         'date_open': fields.datetime('Opened', readonly=True),
 142         'date': fields.datetime('Date'),
 143         'date_action': fields.date('Next Action Date'),
 144         'title_action': fields.char('Next Action', size=64),
 145         'priority': fields.selection(AVAILABLE_PRIORITIES, 'Appreciation'),
 146         'job_id': fields.many2one('hr.job', 'Applied Job'),
 147         'salary_proposed': fields.float('Proposed Salary', help="Salary Proposed by the Organisation"),
 148         'salary_expected': fields.float('Expected Salary', help="Salary Expected by Applicant"),
 149         'availability': fields.integer('Availability (Days)'),
 150         'partner_name': fields.char("Applicant's Name", size=64),
 151         'partner_phone': fields.char('Phone', size=32),
 152         'partner_mobile': fields.char('Mobile', size=32),
 153         'type_id': fields.many2one('hr.recruitment.degree', 'Degree'),
 154         'department_id': fields.many2one('hr.department', 'Department'),
 155         'state': fields.selection(AVAILABLE_STATES, 'State', size=16, readonly=True),
 156         'survey': fields.related('job_id', 'survey_id', type='many2one', relation='survey', string='Survey'),
 157         'response': fields.integer("Response"),
 158         'reference': fields.char('Reference', size=128),
 159         'day_open': fields.function(_compute_day, string='Days to Open', \
 160                                 method=True, multi='day_open', type="float", store=True),
 161         'day_close': fields.function(_compute_day, string='Days to Close', \
 162                                 method=True, multi='day_close', type="float", store=True),
 163     }
 164
 165     def _get_stage(self, cr, uid, context=None):
 166         ids = self.pool.get('hr.recruitment.stage').search(cr, uid, [], context=context)
 167         return ids and ids[0] or False
 168
 169     _defaults = {
 170         'active': lambda *a: 1,
 171         'stage_id': _get_stage,
 172         'user_id':  lambda self, cr, uid, context: uid,
 173         'email_from': crm.crm_case. _get_default_email,
 174         'state': lambda *a: 'draft',
 175         'company_id': lambda s, cr, uid, c: s.pool.get('res.company')._company_default_get(cr, uid, 'crm.helpdesk', context=c),
 176         'priority': lambda *a: crm.AVAILABLE_PRIORITIES[2][0],
 177     }
 178
 179     def onchange_job(self,cr, uid, ids, job, context=None):
 180         result = {}
 181
 182         if job:
 183             job_obj = self.pool.get('hr.job')
 184             result['department_id'] = job_obj.browse(cr, uid, job, context=context).department_id.id
 185             return {'value': result}
 186         return {'value': {'department_id': False}}
 187
 188     def stage_previous(self, cr, uid, ids, context=None):
 189         """This function computes previous stage for case from its current stage
 190              using available stage for that case type
 191         @param self: The object pointer
 192         @param cr: the current row, from the database cursor,
 193         @param uid: the current user’s ID for security checks,
 194         @param ids: List of case IDs
 195         @param context: A standard dictionary for contextual values"""
 196         stage_obj = self.pool.get('hr.recruitment.stage')
 197         for case in self.browse(cr, uid, ids, context=context):
 198             department = (case.department_id.id or False)
 199             st = case.stage_id.id  or False
 200             stage_ids = stage_obj.search(cr, uid, ['|',('department_id','=',department),('department_id','=',False)], context=context)
 201             if st and stage_ids.index(st):
 202                 self.write(cr, uid, [case.id], {'stage_id': stage_ids[stage_ids.index(st)-1]}, context=context)
 203         return True
 204
 205     def stage_next(self, cr, uid, ids, context=None):
 206         """This function computes next stage for case from its current stage
 207              using available stage for that case type
 208         @param self: The object pointer
 209         @param cr: the current row, from the database cursor,
 210         @param uid: the current user’s ID for security checks,
 211         @param ids: List of case IDs
 212         @param context: A standard dictionary for contextual values"""
 213         stage_obj = self.pool.get('hr.recruitment.stage')
 214         for case in self.browse(cr, uid, ids, context=context):
 215             department = (case.department_id.id or False)
 216             st = case.stage_id.id  or False
 217             stage_ids = stage_obj.search(cr, uid, ['|',('department_id','=',department),('department_id','=',False)], context=context)
 218             if st and len(stage_ids) != stage_ids.index(st)+1:
 219                 self.write(cr, uid, [case.id], {'stage_id': stage_ids[stage_ids.index(st)+1]}, context=context)
 220         return True
 221
 222     def action_makeMeeting(self, cr, uid, ids, context=None):
 223         """
 224         This opens Meeting's calendar view to schedule meeting on current Opportunity
 225         @param self: The object pointer
 226         @param cr: the current row, from the database cursor,
 227         @param uid: the current user’s ID for security checks,
 228         @param ids: List of Opportunity to Meeting IDs
 229         @param context: A standard dictionary for contextual values
 230
 231         @return: Dictionary value for created Meeting view
 232         """
 233         data_obj = self.pool.get('ir.model.data')
 234         if context is None:
 235             context = {}
 236         value = {}
 237         for opp in self.browse(cr, uid, ids, context=context):
 238             # Get meeting views
 239             result = data_obj._get_id(cr, uid, 'crm', 'view_crm_case_meetings_filter')
 240             res = data_obj.read(cr, uid, result, ['res_id'], context=context)
 241             id1 = data_obj._get_id(cr, uid, 'crm', 'crm_case_calendar_view_meet')
 242             id2 = data_obj._get_id(cr, uid, 'crm', 'crm_case_form_view_meet')
 243             id3 = data_obj._get_id(cr, uid, 'crm', 'crm_case_tree_view_meet')
 244             if id1:
 245                 id1 = data_obj.browse(cr, uid, id1, context=context).res_id
 246             if id2:
 247                 id2 = data_obj.browse(cr, uid, id2, context=context).res_id
 248             if id3:
 249                 id3 = data_obj.browse(cr, uid, id3, context=context).res_id
 250
 251             context = {
 252                 'default_opportunity_id': opp.id,
 253                 'default_partner_id': opp.partner_id and opp.partner_id.id or False,
 254                 'default_email_from': opp.email_from,
 255                 'default_state': 'open',
 256                 'default_name': opp.name
 257             }
 258             value = {
 259                 'name': ('Meetings'),
 260                 'domain': "[('user_id','=',%s)]" % (uid),
 261                 'context': context,
 262                 'view_type': 'form',
 263                 'view_mode': 'calendar,form,tree',
 264                 'res_model': 'crm.meeting',
 265                 'view_id': False,
 266                 'views': [(id1, 'calendar'), (id2, 'form'), (id3, 'tree')],
 267                 'type': 'ir.actions.act_window',
 268                 'search_view_id': res['res_id'],
 269                 'nodestroy': True
 270             }
 271         return value
 272
 273     def action_print_survey(self, cr, uid, ids, context=None):
 274         """
 275         If response is available then print this response otherwise print survey form(print template of the survey).
 276
 277         @param self: The object pointer
 278         @param cr: the current row, from the database cursor,
 279         @param uid: the current user’s ID for security checks,
 280         @param ids: List of Survey IDs
 281         @param context: A standard dictionary for contextual values
 282         @return: Dictionary value for print survey form.
 283         """
 284         if context is None:
 285             context = {}
 286         record = self.browse(cr, uid, ids, context=context)
 287         record = record and record[0]
 288         context.update({'survey_id': record.survey.id, 'response_id': [record.response], 'response_no': 0, })
 289         value = self.pool.get("survey").action_print_survey(cr, uid, ids, context=context)
 290         return value
 291
 292     def message_new(self, cr, uid, msg, context=None):
 293         """
 294         Automatically calls when new email message arrives
 295
 296         @param self: The object pointer
 297         @param cr: the current row, from the database cursor,
 298         @param uid: the current user’s ID for security checks
 299         """
 300         mailgate_pool = self.pool.get('email.server.tools')
 301         attach_obj = self.pool.get('ir.attachment')
 302
 303         subject = msg.get('subject')
 304         body = msg.get('body')
 305         msg_from = msg.get('from')
 306         priority = msg.get('priority')
 307
 308         vals = {
 309             'name': subject,
 310             'email_from': msg_from,
 311             'email_cc': msg.get('cc'),
 312             'description': body,
 313             'user_id': False,
 314         }
 315         if msg.get('priority', False):
 316             vals['priority'] = priority
 317
 318         res = mailgate_pool.get_partner(cr, uid, msg.get('from'))
 319         if res:
 320             vals.update(res)
 321         res = self.create(cr, uid, vals, context=context)
 322
 323         attachents = msg.get('attachments', [])
 324         for attactment in attachents or []:
 325             data_attach = {
 326                 'name': attactment,
 327                 'datas':binascii.b2a_base64(str(attachents.get(attactment))),
 328                 'datas_fname': attactment,
 329                 'description': 'Mail attachment',
 330                 'res_model': self._name,
 331                 'res_id': res,
 332             }
 333             attach_obj.create(cr, uid, data_attach, context=context)
 334
 335         return res
 336
 337     def message_update(self, cr, uid, ids, vals={}, msg="", default_act='pending', context=None):
 338         """
 339         @param self: The object pointer
 340         @param cr: the current row, from the database cursor,
 341         @param uid: the current user’s ID for security checks,
 342         @param ids: List of update mail’s IDs
 343         """
 344
 345         if isinstance(ids, (str, int, long)):
 346             ids = [ids]
 347
 348         msg_from = msg['from']
 349         vals.update({
 350             'description': msg['body']
 351         })
 352         if msg.get('priority', False):
 353             vals['priority'] = msg.get('priority')
 354
 355         maps = {
 356             'cost':'planned_cost',
 357             'revenue': 'planned_revenue',
 358             'probability':'probability'
 359         }
 360         vls = { }
 361         for line in msg['body'].split('\n'):
 362             line = line.strip()
 363             res = tools.misc.command_re.match(line)
 364             if res and maps.get(res.group(1).lower(), False):
 365                 key = maps.get(res.group(1).lower())
 366                 vls[key] = res.group(2).lower()
 367
 368         vals.update(vls)
 369         res = self.write(cr, uid, ids, vals, context=context)
 370         return res
 371
 372     def msg_send(self, cr, uid, id, *args, **argv):
 373         """ Send The Message
 374             @param self: The object pointer
 375             @param cr: the current row, from the database cursor,
 376             @param uid: the current user’s ID for security checks,
 377             @param ids: List of email’s IDs
 378             @param *args: Return Tuple Value
 379             @param **args: Return Dictionary of Keyword Value
 380         """
 381         return True
 382
 383     def case_open(self, cr, uid, ids, *args):
 384         """
 385         @param self: The object pointer
 386         @param cr: the current row, from the database cursor,
 387         @param uid: the current user’s ID for security checks,
 388         @param ids: List of case's Ids
 389         @param *args: Give Tuple Value
 390         """
 391         res = super(hr_applicant, self).case_open(cr, uid, ids, *args)
 392         date = self.read(cr, uid, ids, ['date_open'])[0]
 393         if not date['date_open']:
 394             self.write(cr, uid, ids, {'date_open': time.strftime('%Y-%m-%d %H:%M:%S'),})
 395         for (id, name) in self.name_get(cr, uid, ids):
 396             message = _("The job request '%s' has been set 'in progress'.") % name
 397             self.log(cr, uid, id, message)
 398         return res
 399
 400     def case_close(self, cr, uid, ids, *args):
 401         """
 402         @param self: The object pointer
 403         @param cr: the current row, from the database cursor,
 404         @param uid: the current user’s ID for security checks,
 405         @param ids: List of case's Ids
 406         @param *args: Give Tuple Value
 407         """
 408         employee_obj = self.pool.get('hr.employee')
 409         job_obj = self.pool.get('hr.job')
 410         res = super(hr_applicant, self).case_close(cr, uid, ids, *args)
 411         for (id, name) in self.name_get(cr, uid, ids):
 412             message = _("Applicant '%s' is being hired.") % name
 413             self.log(cr, uid, id, message)
 414
 415         applicant = self.browse(cr, uid, ids)[0]
 416         if applicant.job_id:
 417             emp_id = employee_obj.create(cr,uid,{'name': applicant.name,'job_id': applicant.job_id.id})
 418         return res
 419
 420     def case_reset(self, cr, uid, ids, *args):
 421         """Resets case as draft
 422         @param self: The object pointer
 423         @param cr: the current row, from the database cursor,
 424         @param uid: the current user’s ID for security checks,
 425         @param ids: List of case Ids
 426         @param *args: Tuple Value for additional Params
 427         """
 428
 429         res = super(hr_applicant, self).case_reset(cr, uid, ids, *args)
 430         self.write(cr, uid, ids, {'date_open': False, 'date_closed': False})
 431         return res
 432
 433
 434 hr_applicant()
 435
 436 class hr_job(osv.osv):
 437     _inherit = "hr.job"
 438     _name = "hr.job"
 439     _columns = {
 440         'survey_id': fields.many2one('survey', 'Survey'),
 441     }
 442 hr_job()
 443
 444 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: