package com.kingdee.eas.custom.attendance.service; import com.aliyun.odps.utils.StringUtils; import com.kingdee.bos.BOSException; import com.kingdee.bos.Context; import com.kingdee.bos.bsf.service.app.IHRMsfService; import com.kingdee.bos.util.BOSUuid; import com.kingdee.eas.basedata.hraux.FolkFactory; import com.kingdee.eas.basedata.hraux.FolkInfo; import com.kingdee.eas.basedata.org.*; import com.kingdee.eas.basedata.person.Genders; import com.kingdee.eas.basedata.person.PersonCollection; import com.kingdee.eas.basedata.person.PersonFactory; import com.kingdee.eas.basedata.person.PersonInfo; import com.kingdee.eas.common.EASBizException; import com.kingdee.eas.hr.affair.*; import com.kingdee.eas.hr.base.*; import com.kingdee.eas.hr.emp.*; import com.kingdee.eas.hr.org.JobGradeInfo; import com.kingdee.eas.hr.org.JobLevelFactory; import com.kingdee.eas.hr.org.JobLevelInfo; import com.kingdee.shr.ats.web.util.SHRBillUtil; import jodd.util.StringUtil; import org.apache.log4j.Logger; import java.sql.Timestamp; import java.text.SimpleDateFormat; import java.time.LocalDate; import java.time.ZoneId; import java.util.Date; import java.util.HashMap; import java.util.Map; /** * 入职 */ public class SaveEmpEnrollBizBillService implements IHRMsfService { private static Logger logger = Logger.getLogger(SHRBillUtil.class); @Override public Object process(Context context, Map map) throws EASBizException, BOSException { Map result = new HashMap(); StringBuilder errLog = new StringBuilder(); try { System.out.println("SaveEmpEnrollBizBillService" + map); SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd"); String orgTop = "00000000-0000-0000-0000-000000000000CCE7AED4"; //必填 String createPerson = (String)map.get("createPerson"); //申请人 String personName = (String)map.get("personName"); //名称 String gender = (String)map.get("gender"); // 性别 String positionNumber = (String)map.get("position"); // 职位编码 String telNum = (String)map.get("telNum"); //电话号码 String personNumber = (String)map.get("personNumber"); //编码 String bizDate = (String)map.get("bizData"); //入职日期 bizDate String oaUserName = (String)map.get("oaUserName"); //oa用户名 //选填 String idCard = (String)map.get("idCard"); // 身份证号码 String passport = (String)map.get("passport"); // 护照号码 String isEnrollAgain = (String)map.get("isEnrollAgain"); //是否在入职 String oldNub = (String)map.get("oldNub"); //再次入职 原员工编码 //非必填 String createDate = (String)map.get("createDate"); //申请日期 String jobLevelNumber = (String)map.get("jobLevelNumber"); //职级 String empTypeNumber = (String)map.get("empType"); // 用工关系状态 String cardAddress = (String)map.get("cardAddress"); // 身份证地址 String probation = (String)map.get("probation"); // 试用月 String affType = (String)map.get("affType"); // 变动类型 String hrBizDefine = (String)map.get("hrBizDefine"); // 变动操作 String varReason = (String)map.get("varReason"); // 变动原因 String myFolk = (String)map.get("myFolk"); //民族 String naPlace = (String)map.get("naPlace"); //籍贯 String email = (String)map.get("email"); //电子邮件 String jobStrDate = (String)map.get("jobStrDate"); //参加工作日期 String globAlr = (String)map.get("globAlr"); //国际区号 String description = (String)map.get("description"); //国际区号 if (StringUtils.isBlank(createPerson)){ errLog.append("申请人不能为空！"); } if (StringUtils.isBlank(personName)){ errLog.append("员工名称不能为空！"); } if (StringUtils.isBlank(gender)){ errLog.append("性别不能为空！"); } if (StringUtils.isBlank(positionNumber)){ errLog.append("职位编码不能为空！"); } if (StringUtils.isBlank(telNum)){ errLog.append("电话号码不能为空！"); } if (StringUtils.isBlank(personNumber)){ errLog.append("员工工号不能为空！"); } if (StringUtils.isBlank(bizDate)){ errLog.append("入职日期不能为空！"); } if (StringUtils.isBlank(oaUserName)){ errLog.append("oa用户名不能为空！"); } if (StringUtils.isBlank(idCard) && StringUtils.isBlank(passport)){ errLog.append("身份证号码和护照不能同时为空！"); } if (StringUtils.isNotBlank(isEnrollAgain)){ if (StringUtils.isBlank(oldNub)){ errLog.append("再次入职时原员工工号不能为空！"); } } if (errLog.length() >0 ){ result.put("msgType", "0"); result.put("msg", errLog.toString()); }else { EmpEnrollBizBillInfo billInfo = new EmpEnrollBizBillInfo(); //申请人工号 PersonCollection presonCollection = PersonFactory.getLocalInstance(context).getPersonCollection("where number='" + createPerson + "'"); if (presonCollection.size() > 0){ PersonInfo personInfo = presonCollection.get(0); billInfo.setApplier(personInfo); }else { errLog.append("制单人工号为" + createPerson + "不存在;"); } //管理单元 CtrlUnitInfo cu = new CtrlUnitInfo(); //uuid生成规则 cu.setId(BOSUuid.read(orgTop)); billInfo.setCU(cu); //hr组织 HROrgUnitInfo hrOrgUnitInfo = new HROrgUnitInfo(); hrOrgUnitInfo.setId(BOSUuid.read(orgTop)); billInfo.setHrOrgUnit(hrOrgUnitInfo); billInfo.setBizDate(new Date()); //业务时间 //入职单分录 EmpEnrollBizBillEntryInfo entry = new EmpEnrollBizBillEntryInfo(); entry.setBill(billInfo); entry.setEmpName(personName);//姓名 entry.setEmpNumber(personNumber);//员工编码 Genders anEnum = Genders.getEnum(Integer.parseInt(gender)); entry.setGender(anEnum);//性别 PositionCollection positionCollection = PositionFactory.getLocalInstance(context).getPositionCollection("where number = '" + positionNumber + "'"); if (presonCollection.size() > 0){ PositionInfo positionInfo = positionCollection.get(0); AdminOrgUnitInfo adminOrgUnit = positionInfo.getAdminOrgUnit(); JobInfo job = positionInfo.getJob(); entry.setPosition(positionInfo);//目标职位 entry.setAdminOrg(adminOrgUnit);//目标组织 entry.setJob(job);//职务 entry.setReplaceAdminOrg(adminOrgUnit);//续存组织 billInfo.setAdminOrg(adminOrgUnit); //行政组织 }else { throw new Exception("入职职位编码" + positionNumber + "不存在;"); } entry.setTelNum(telNum);//电话号码 entry.setBizDate(simpleDateFormat.parse(bizDate));//生效日期 entry.setEnrollDate(simpleDateFormat.parse(bizDate));//入职日期 entry.put("oaUserName",oaUserName); if (StringUtils.isNotBlank(createDate)){ billInfo.setApplyDate(simpleDateFormat.parse(createDate));//申请日期 }else { billInfo.setApplyDate(new Date()); } if (StringUtil.isNotBlank(jobLevelNumber)){ JobLevelInfo jobLevelInfo = JobLevelFactory.getLocalInstance(context).getJobLevelInfo("where number = '" + jobLevelNumber + "'"); JobGradeInfo jobGrade = jobLevelInfo.getJobGrade(); entry.setJobLevel(jobLevelInfo);//目标职级 entry.setJobGrade(jobGrade);//目标职等 } if (StringUtils.isNotBlank(empTypeNumber)){ //用工关系状态 empTypeNumber = "002"; } EmployeeTypeInfo employeeTypeInfo = EmployeeTypeFactory.getLocalInstance(context).getEmployeeTypeInfo("where number = '" + empTypeNumber + "'"); entry.setEmpType(employeeTypeInfo); //目标员工状态 if (StringUtils.isNotBlank(idCard)){ entry.setIDCardNo(idCard); //身份证 } if (StringUtils.isNotBlank(passport)){ entry.setPassportNo(passport);//护照号码 } if (StringUtils.isNotBlank(cardAddress)){ entry.setIdCardAddress(cardAddress); //身份证地址 } if (StringUtils.isNotBlank(probation)){// 试用月 entry.setProbation(Integer.parseInt(probation)); LocalDate parse = LocalDate.parse(bizDate); LocalDate newDate = parse.plusMonths(Integer.parseInt(probation)); Date from = Date.from(newDate.atStartOfDay(ZoneId.systemDefault()).toInstant()); entry.setPlanFormalDate(from);//预计转正日期 } if (StringUtil.isNotBlank(isEnrollAgain)){ if ("1".equals(isEnrollAgain)){ entry.setEnrollAgain(false);// 是否再入职 }else { entry.setEnrollAgain(true);// 是否再入职 PersonCollection pCol = PersonFactory.getLocalInstance(context).getPersonCollection("where number='" + oldNub + "'"); if (presonCollection.size() > 0){ PersonInfo personInfo = pCol.get(0); PersonPositionInfo ppInfo = getAdminOrgUnitByPersonId(context, personInfo.getId().toString()); PersonInfo person = ppInfo.getPerson(); entry.setExistPersonID(person.getId());//再入职人员ID entry.setUseOldNumber(false);//再入职应用原员工编码 entry.setOldEmpType(person.getEmployeeType());//原员工状态 AdminOrgUnitInfo personDep = ppInfo.getPersonDep(); entry.setOldAdminOrg(personDep);//原组织 PositionInfo primaryPosition = ppInfo.getPrimaryPosition(); entry.setOldPosition(primaryPosition);//原职位 }else { errLog.append("再次入职原员工工号" + oldNub + "不存在;"); } } } entry.setIsPrimary(true);//是否主要任职 if (StringUtils.isBlank(affType)){ affType = "0101"; } AffairActionReasonInfo affairActionReasonInfo = AffairActionReasonFactory.getLocalInstance(context).getAffairActionReasonInfo("where number ='" + affType + "'"); entry.setAffairActionReason(affairActionReasonInfo);//变动类型 if (StringUtils.isBlank(hrBizDefine)){ hrBizDefine = "SHR01"; } HRBizDefineInfo hrBizDefineInfo = HRBizDefineFactory.getLocalInstance(context).getHRBizDefineInfo("where number ='" + hrBizDefine + "'"); entry.setHrBizDefine(hrBizDefineInfo);// 变动操作 if (StringUtils.isBlank(varReason)){ varReason = "RZ08"; } VariationReasonInfo variationReasonInfo = VariationReasonFactory.getLocalInstance(context).getVariationReasonInfo("where number ='" + varReason + "'"); entry.setVariationReason(variationReasonInfo);// 变动原因 if (StringUtils.isNotBlank(myFolk)){ FolkInfo folkInfo = FolkFactory.getLocalInstance(context).getFolkInfo("where number ='" + myFolk + "'"); entry.setMyFolk(folkInfo);//民族 } if (StringUtils.isNotBlank(naPlace)){ entry.setNativePlace(naPlace);//籍贯 } if (StringUtils.isNotBlank(email)){ entry.setEmail(email);//电子邮件 } if (StringUtils.isNotBlank(jobStrDate)){ entry.setJobStartDate(simpleDateFormat.parse(jobStrDate));//参加工作日期 } entry.setEmployerUnit(hrOrgUnitInfo);//用工单位 //entry.setCompany(hrOrgUnitInfo); //公司 //entry.setHrBizDefine(hrBizDefineInfo);//HR组织 entry.setIdCardLongEffect(true);//身份证是否长期有效 entry.setNCell(telNum); entry.setGlobalRoaming(globAlr); //国际区号 String a = bizDate + " 00:00:00"; entry.setBizTime(Timestamp.valueOf(a));//生效日期(时区) billInfo.getEntrys().add(entry); EmpEnrollBizBillFactory.getLocalInstance(context).submitEffect(billInfo); result.put("msgType", "1"); result.put("msg", "success"); result.put("fnumber", billInfo.getNumber()); } } catch (Exception e) { errLog.append(e.getMessage()); result.put("msgType", "0"); result.put("msg", errLog.toString()); } return result; } public static PersonPositionInfo getAdminOrgUnitByPersonId(Context ctx, String personID) { if (personID == null) { return null; } else { PersonPositionInfo personPositionInfo = null; StringBuffer oqlb = new StringBuffer(); oqlb.append("select "); oqlb.append("id,"); oqlb.append("person.number,"); oqlb.append("person.name,"); oqlb.append("personDep.id,"); oqlb.append("personDep.name,"); oqlb.append("personDep.number,"); oqlb.append("personDep.employeeType,"); oqlb.append("personDep.longnumber,"); oqlb.append("personDep.displayName,"); oqlb.append("primaryPosition.id,"); oqlb.append("primaryPosition.name,"); oqlb.append("primaryPosition.number"); oqlb.append(" where person.id='"); oqlb.append(personID); oqlb.append("'"); PersonPositionCollection c = null; try { c = PersonPositionFactory.getLocalInstance(ctx).getPersonPositionCollection(oqlb.toString()); } catch (BOSException var6) { logger.error("SHRBillUtil.getAdminOrgUnit err", var6); } if (c != null && c.size() > 0) { personPositionInfo = c.get(0); } return personPositionInfo; } } }