diff --git a/src/main/java/com/weaver/seconddev/beisen/annotation/FieldConversion.java b/src/main/java/com/weaver/seconddev/beisen/annotation/FieldConversion.java new file mode 100644 index 0000000..d928b22 --- /dev/null +++ b/src/main/java/com/weaver/seconddev/beisen/annotation/FieldConversion.java @@ -0,0 +1,36 @@ +package com.weaver.seconddev.beisen.annotation; + +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; + +/** + * @author:dxfeng + * @createTime: 2025/07/24 + * @version: 1.0 + */ +@Target(ElementType.FIELD) +@Retention(RetentionPolicy.RUNTIME) +public @interface FieldConversion { + /** + * 关联的表名 + * + * @return 表名 + */ + String relatedTable(); + + /** + * 默认值 + * + * @return 默认值 + */ + String defaultValue() default ""; + + /** + * 备注 + * + * @return + */ + String remark() default ""; +} diff --git a/src/main/java/com/weaver/seconddev/beisen/entity/BeiSenOffer.java b/src/main/java/com/weaver/seconddev/beisen/entity/BeiSenOffer.java new file mode 100644 index 0000000..43b21cb --- /dev/null +++ b/src/main/java/com/weaver/seconddev/beisen/entity/BeiSenOffer.java @@ -0,0 +1,198 @@ +package com.weaver.seconddev.beisen.entity; + +import com.weaver.seconddev.beisen.annotation.FieldConversion; +import lombok.Data; + +import java.time.LocalDateTime; +import java.util.Map; + +/** + * @author:dxfeng + * @createTime: 2025/07/23 + * @version: 1.0 + */ +@Data +public class BeiSenOffer { + + private String userID; + private String approvalStatus; + private LocalDateTime acceptTime; + private LocalDateTime refuseTime; + private String offerSender; + private LocalDateTime offerSendTime; + private String offerSendDate; + private String remarks; + private String hrDutyUserId; + private String offerStatus; + private String offerTemplate; + private String copyEmailTo; + private String offerSource; + private Integer syncStatus; + private String syncMsg; + private String permissionBy; + private String referrerUserID; + private String blindCarbonCopy; + private String reasonOfRefuseID; + private String batchSendOfferResult; + private String entryChangeType; + private String sendOfferEmailTemplateType; + + private String name; + private Integer age; + private String backupMail; + private String emergencyContact; + private String emergencyContactPhone; + private String emergencyContactRelationship; + private String iDNumber; + private Integer iDType; + private String lastSchool; + private String lastSchoolCode; + private String major; + private String graduateDate; + private String workYearCompanyTotal; + private String workYearTotal; + private String mobilePhone; + private LocalDateTime birthday; + private String birthplace; + private String nationality; + @FieldConversion(relatedTable = "uf_mzlx") + private String nation; + private String registAddress; + @FieldConversion(relatedTable = "uf_zgxl_h") + private String educationLevel; + private LocalDateTime workDate; + @FieldConversion(relatedTable = "uf_c_hklb") + private String domicileType; + @FieldConversion(relatedTable = "uf_hyzklx_m") + private String marryCategory; + private String gender; + + private Long oIdDepartment; + private String pOIdEmpAdmin; + private String pOIdEmpReserve2; + private String employType; + private String employmentSource; + private String employmentForm; + private String employmentType; + private LocalDateTime entryDate; + private String oIdJobPosition; + private String oIdJobLevel; + private Long oIdOrganization; + private String isCharge; + private String oIdJobSequence; + + @FieldConversion(relatedTable = "uf_dqlx_a") + private String place; + private String oIdJobPost; + private String oidJobGrade; + private String oIdProfessionalLine; + private String probation; + private LocalDateTime probationStopDate; + private String firstParty; + private String firstPartyCode; + private String contactLength; + private LocalDateTime terminateDate; + private LocalDateTime signingDate; + @FieldConversion(relatedTable = "uf_htlx") + private String contractType; + private String contractDueTimeType; + private LocalDateTime effectiveDate; + private String code; + + private Long businessModifiedBy; + private LocalDateTime businessModifiedTime; + + private Double salaryAmount0; + private Double salaryAmount2; + private Double salaryAmount3; + private Double salaryAmount4; + private Double salaryAmount5; + private Double salaryAmount6; + private Double salaryAmount7; + private Double salaryAmount8; + private Double salaryAmount9; + private Double salaryAmount10; + private Double salaryAmount11; + private Double salaryAmount12; + private Double salaryAmount13; + private Double salaryAmount14; + private Double salaryAmount15; + private Double salaryAmount16; + private Double salaryAmount17; + private Double salaryAmount18; + private Double salaryAmount19; + private Double salaryAmount20; + + private Double basicSalaryBeforeFullTime; + private Double basicSalaryAfterFullTime; + private Double housingFundRadices; + private Double socialSecurityRadices; + private String salaryPackageID; + + private String salaryLevels0; + private String salaryRanks0; + private String socialSecurityPlanCID; + private String housingFundPlanCID; + + private Double salaryAmount2BeforeFullTime; + private Double salaryAmount2AfterFullTime; + private Double salaryAmount3BeforeFullTime; + private Double salaryAmount3AfterFullTime; + private Double salaryAmount4BeforeFullTime; + private Double salaryAmount4AfterFullTime; + private Double salaryAmount5BeforeFullTime; + private Double salaryAmount5AfterFullTime; + private Double salaryAmount6BeforeFullTime; + private Double salaryAmount6AfterFullTime; + private Double salaryAmount7BeforeFullTime; + private Double salaryAmount7AfterFullTime; + private Double salaryAmount8BeforeFullTime; + private Double salaryAmount8AfterFullTime; + private Double salaryAmount9BeforeFullTime; + private Double salaryAmount9AfterFullTime; + private Double salaryAmount10BeforeFullTime; + private Double salaryAmount10AfterFullTime; + private Double salaryAmount11BeforeFullTime; + private Double salaryAmount11AfterFullTime; + private Double salaryAmount12BeforeFullTime; + private Double salaryAmount12AfterFullTime; + private Double salaryAmount13BeforeFullTime; + private Double salaryAmount13AfterFullTime; + private Double salaryAmount14BeforeFullTime; + private Double salaryAmount14AfterFullTime; + private Double salaryAmount15BeforeFullTime; + private Double salaryAmount15AfterFullTime; + private Double salaryAmount16BeforeFullTime; + private Double salaryAmount16AfterFullTime; + private Double salaryAmount17BeforeFullTime; + private Double salaryAmount17AfterFullTime; + private Double salaryAmount18BeforeFullTime; + private Double salaryAmount18AfterFullTime; + private Double salaryAmount19BeforeFullTime; + private Double salaryAmount19AfterFullTime; + private Double salaryAmount20BeforeFullTime; + private Double salaryAmount20AfterFullTime; + + private String currency; + private String applicantId; + private String applicantPosition; + private String applicantPositionId; + private String applyChannel; + private LocalDateTime applyTime; + private String applicantIdV6; + private String applicantPositionIdV6; + private String applyIdV6; + private String recruitmentRequirement; + private String requireDepartment; + + private String objectId; + private Map customProperties; + private Object translateProperties; + private Object sysMartionProperties; + + private Long createdBy; + private LocalDateTime createdTime; + private Long modifiedBy; + private LocalDateTime modifiedTime; + private Boolean stdIsDeleted; +} diff --git a/src/main/java/com/weaver/seconddev/beisen/entity/FieldConversionInfo.java b/src/main/java/com/weaver/seconddev/beisen/entity/FieldConversionInfo.java new file mode 100644 index 0000000..0dbd705 --- /dev/null +++ b/src/main/java/com/weaver/seconddev/beisen/entity/FieldConversionInfo.java @@ -0,0 +1,19 @@ +package com.weaver.seconddev.beisen.entity; + +public class FieldConversionInfo { + private String relatedTable; + private String defaultValue; + + public FieldConversionInfo(String relatedTable, String defaultValue) { + this.relatedTable = relatedTable; + this.defaultValue = defaultValue; + } + + public String getRelatedTable() { + return relatedTable; + } + + public String getDefaultValue() { + return defaultValue; + } + } \ No newline at end of file diff --git a/src/main/java/com/weaver/seconddev/beisen/esb/SyncBeiSenOfferCronJob.java b/src/main/java/com/weaver/seconddev/beisen/esb/SyncBeiSenOfferCronJob.java new file mode 100644 index 0000000..ab6116f --- /dev/null +++ b/src/main/java/com/weaver/seconddev/beisen/esb/SyncBeiSenOfferCronJob.java @@ -0,0 +1,514 @@ +package com.weaver.seconddev.beisen.esb; + +import cn.hutool.core.convert.Convert; +import cn.hutool.http.HttpRequest; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.weaver.common.base.entity.result.WeaResult; +import com.weaver.common.hrm.dao.HrmCommonEmployeeDao; +import com.weaver.ebuilder.form.client.service.emobile.IEtFormDatasetService; +import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface; +import com.weaver.seconddev.beisen.annotation.FieldConversion; +import com.weaver.seconddev.beisen.entity.BeiSenOffer; +import com.weaver.seconddev.beisen.entity.FieldConversionInfo; +import com.weaver.seconddev.beisen.mapper.OfferMapper; +import com.weaver.seconddev.chapanda.beisen.constant.Constants; +import com.weaver.seconddev.chapanda.beisen.util.Token2BeiSenUtil; +import com.weaver.seconddev.portal.entity.param.BaseParam; +import com.weaver.seconddev.portal.mapper.EbuilderBaseMapper; +import com.weaver.seconddev.portal.util.DateUtil; +import com.weaver.seconddev.portal.util.PapiUtil; +import com.weaver.teams.domain.user.SimpleEmployee; +import com.weaver.workflow.common.cfg.org.service.DepartMentService; +import constant.ApplicationConfigConstant; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.lang.reflect.Field; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * @author:dxfeng + * @createTime: 2025/07/23 + * @version: 1.0 + */ +@Slf4j +@Service("SyncBeiSenOfferCronJob") +public class SyncBeiSenOfferCronJob implements EsbServerlessRpcRemoteInterface { + @Autowired + Token2BeiSenUtil http2BenSenUtil; + + @Autowired + IEtFormDatasetService etFormDatasetService; + + @Autowired + OfferMapper offerMapper; + + @Autowired + HrmCommonEmployeeDao hrmCommonEmployeeDao; + + @Autowired + DepartMentService departMentService; + @Autowired + EbuilderBaseMapper ebuilderBaseMapper; + + @Override + public WeaResult> execute(Map params) { + + //etFormDatasetService.deleteData( params) + + String startDate = String.valueOf(params.get("startDate")); + String startTime = String.valueOf(params.get("startTime")); + String endDate = String.valueOf(params.get("endDate")); + String endTime = String.valueOf(params.get("endTime")); + // TODO 测试数据 + if (StringUtils.isBlank(startDate)) { + startDate = "2025-06-01"; + } + if (StringUtils.isBlank(startTime)) { + startTime = "00:00:00"; + } + //endDate = "2025-07-24"; + //endTime = "00:00:00"; + + String token = http2BenSenUtil.getToken(); + List beiSenOfferData = getBeiSenOfferData(token, startDate, startTime, endDate, endTime); + + BaseParam baseParam = new BaseParam(); + JSONArray datas = new JSONArray(); + // 遍历offer数据，插入到EB表 + for (BeiSenOffer offer : beiSenOfferData) { + String objectId = offer.getObjectId(); + // 判断是否已存在该数据 存在即跳过 + Long offerIdByObjectId = offerMapper.getOfferIdByObjectId(baseParam, objectId); + if (offerIdByObjectId != null) { + log.info("已存在该数据，跳过数据写入,objectId===" + objectId); + continue; + } + + // 转换字段值 + BeiSenOffer convertOffer = convertObjectFields(baseParam, offer); + + + JSONObject mainDataObj = new JSONObject(); + mainDataObj.put("bsid", objectId); + // 默认值 + mainDataObj.put("personnel_status_jcl", "1"); + mainDataObj.put("lrfs", "0"); + mainDataObj.put("rzzt", "0"); + mainDataObj.put("native_place", "中国"); + // TODO 待确认 + mainDataObj.put("zxjssl", "1"); + + + // 注解转换方式 + mainDataObj.put("location", convertOffer.getPlace()); + mainDataObj.put("marital_status", convertOffer.getMarryCategory()); + mainDataObj.put("nation", convertOffer.getNation()); + mainDataObj.put("householdtype", convertOffer.getDomicileType()); + mainDataObj.put("education", convertOffer.getEducationLevel()); + mainDataObj.put("htlx", convertOffer.getContractType()); + + + // 直接写入北森数据 + mainDataObj.put("cor_offzt", convertOffer.getOfferStatus()); + mainDataObj.put("hjszd", convertOffer.getBirthplace()); + mainDataObj.put("zy", convertOffer.getMajor()); + mainDataObj.put("jjlxr", convertOffer.getEmergencyContact()); + mainDataObj.put("jjlxrdh", convertOffer.getEmergencyContactPhone()); + mainDataObj.put("username", convertOffer.getName()); + // TODO 待确认 + mainDataObj.put("sex", convertOffer.getGender()); + mainDataObj.put("mobile", convertOffer.getMobilePhone()); + mainDataObj.put("id_no", convertOffer.getIDNumber()); + mainDataObj.put("birthday", convertOffer.getBirthday()); + mainDataObj.put("age", convertOffer.getAge()); + mainDataObj.put("graduate_school", convertOffer.getLastSchool()); + mainDataObj.put("sl", convertOffer.getWorkYearCompanyTotal()); + mainDataObj.put("work_year", convertOffer.getWorkYearTotal()); + mainDataObj.put("zjlx", convertOffer.getIDType()); + mainDataObj.put("gryx", convertOffer.getBackupMail()); + mainDataObj.put("firstparty", convertOffer.getFirstParty()); + mainDataObj.put("qxlx", convertOffer.getContractDueTimeType()); + mainDataObj.put("htqxy", convertOffer.getContactLength()); + mainDataObj.put("lastSchoolCode", convertOffer.getLastSchoolCode()); + mainDataObj.put("sfbmfzr", convertOffer.getIsCharge()); + + + mainDataObj.put("gygx", convertOffer.getEmployType()); + // 薪酬数据 + mainDataObj.put("gjjjjjsh",convertOffer.getHousingFundRadices()); + mainDataObj.put("sbjjjsh",convertOffer.getSocialSecurityRadices()); + mainDataObj.put("xzba",convertOffer.getSalaryPackageID()); + mainDataObj.put("sbjjfan",convertOffer.getSocialSecurityPlanCID()); + mainDataObj.put("gjjjjfan",convertOffer.getHousingFundPlanCID()); + mainDataObj.put("zzqgwgzbz",convertOffer.getSalaryAmount2BeforeFullTime()); + mainDataObj.put("zzhgwgzbz",convertOffer.getSalaryAmount2AfterFullTime()); + mainDataObj.put("zzqjxgzbz",convertOffer.getSalaryAmount3BeforeFullTime()); + mainDataObj.put("zzhjxgzbz",convertOffer.getSalaryAmount3AfterFullTime()); + mainDataObj.put("zzqyjgzbz",convertOffer.getSalaryAmount4BeforeFullTime()); + mainDataObj.put("zzhyjgzbz",convertOffer.getSalaryAmount4AfterFullTime()); + mainDataObj.put("zzqzaqgzbtbz",convertOffer.getSalaryAmount5BeforeFullTime()); + mainDataObj.put("zzhnzaqgzbtbz",convertOffer.getSalaryAmount5AfterFullTime()); + mainDataObj.put("zzqgzbtbz",convertOffer.getSalaryAmount6BeforeFullTime()); + mainDataObj.put("zzhgzbtbz",convertOffer.getSalaryAmount6AfterFullTime()); + mainDataObj.put("qsfxrqi",convertOffer.getEffectiveDate()); + mainDataObj.put("bha",convertOffer.getCode()); + + + // 其他转换方式 + String probation = convertOffer.getProbation(); + mainDataObj.put("sfysyq", StringUtils.isBlank(probation) || "0".equals(probation) ? "1" : "0"); + mainDataObj.put("yjsyjsrq", DateUtil.formatDate(convertOffer.getProbationStopDate())); + /* + * 根据个人邮箱、证件号码、姓名判断，新入职人员，默认0：新增入职； + * 有入职信息，默认1：离职重聘 + */ + mainDataObj.put("rzlx", checkEntryType(baseParam, offer)); + String sqrEmpId = getEmployeeIdByOId(baseParam, convertOffer.getCreatedBy()); + mainDataObj.put("sqr", sqrEmpId); + // 根据人员获取HR系统部门ID写入 + String deptIdByEmpId = getDeptIdByEmpId(baseParam, sqrEmpId); + mainDataObj.put("sqbm", deptIdByEmpId); + + //mainDataObj.put("gj", ""); + mainDataObj.put("sqsj", DateUtil.formatDateTime(convertOffer.getCreatedTime())); + + + // TODO mainDataObj.put("jjlxrybrgx", convertOffer.getEmergencyContactRelationship()); + + // TODO mainDataObj.put("subcompany", convertOffer.getFirstParty()); + mainDataObj.put("personnel_status", "0".equals(probation) || StringUtils.isBlank(probation) ? "2" : "1"); + + String deptIdByOId = getDeptIdByOId(baseParam, convertOffer.getOIdDepartment()); + mainDataObj.put("department", deptIdByOId); + + String pOIdEmpAdmin = getEmployeeIdByOId(baseParam, convertOffer.getPOIdEmpAdmin()); + mainDataObj.put("superior", pOIdEmpAdmin); + + mainDataObj.put("graduate_date", Convert.toStr(convertOffer.getGraduateDate(), "").replace("/", "-")); + + mainDataObj.put("first_work_date", DateUtil.formatDate(convertOffer.getWorkDate())); + + // TODO mainDataObj.put("rylb", convertOffer.getEmploymentType()); + + String pOIdEmpReserve2 = getEmployeeIdByOId(baseParam, convertOffer.getPOIdEmpReserve2()); + mainDataObj.put("other_superior", pOIdEmpReserve2); + + // TODO mainDataObj.put("frgs", convertOffer.getFirstPartyCode()); + mainDataObj.put("htzzrq", DateUtil.formatDate(convertOffer.getTerminateDate())); + // TODO + + List deptListByLevel = new ArrayList<>(); + deptListByLevel.add(null); + deptListByLevel.add(null); + deptListByLevel.add(null); + deptListByLevel.add(null); + deptListByLevel.add(null); + deptListByLevel.add(null); + if (StringUtils.isNotBlank(deptIdByOId)) { + List deptListByLevel1 = getDeptListByLevel(Long.parseLong(deptIdByOId)); + deptListByLevel.addAll(0, deptListByLevel1); + } + + mainDataObj.put("yjbm", deptListByLevel.get(0)); + mainDataObj.put("ejbm", deptListByLevel.get(1)); + mainDataObj.put("sanbm", deptListByLevel.get(2)); + mainDataObj.put("sijbm", deptListByLevel.get(3)); + mainDataObj.put("wjbm", deptListByLevel.get(4)); + mainDataObj.put("ljbm", deptListByLevel.get(5)); + + + // TODO mainDataObj.put("employType", convertOffer.getEmployType()); + JSONObject dataObj = new JSONObject(); + dataObj.put("mainTable", mainDataObj); + log.error("dataObj===" + dataObj); + datas.add(dataObj); + } + Long objId = ebuilderBaseMapper.getObjIdByTableName(baseParam, "uf_jcl_rzgl"); + String userId = String.valueOf(params.get("userId")); + if (StringUtils.isBlank(userId)) { + return WeaResult.fail("参数userId获取异常", true); + } + String insertMsg = insertEbTable(datas, String.valueOf(objId), userId); + log.error("insertMsg===" + insertMsg); + + Map actionMap = new HashMap<>(); + actionMap.put("code", 200); + actionMap.put("msg", "SyncBeiSenOfferCronJob"); + //actionMap.put("offer",offerArray); + return WeaResult.success(actionMap); + } + + + /** + * 插入EB表数据 + * + * @param datas + * @return + */ + private String insertEbTable(JSONArray datas, String objId, String userId) { + JSONObject dataJson = new JSONObject(); + JSONObject operationinfo = new JSONObject(); + operationinfo.put("fieldNoFindIgnore", "true"); + operationinfo.put("doAction", "false"); + JSONObject header = new JSONObject(); + header.put("objId", objId); + + dataJson.put("datas", datas); + dataJson.put("header", header); + dataJson.put("operationinfo", operationinfo); + + JSONObject jsonObject = new JSONObject(); + jsonObject.put("datajson", dataJson); + jsonObject.put("userid", userId); + // 请求授权 + String papiCode = PapiUtil.getPapiCode(ApplicationConfigConstant.APP_URL, ApplicationConfigConstant.CORP_ID, "A1a"); + String papiToken = PapiUtil.getPapiToken(ApplicationConfigConstant.APP_URL, ApplicationConfigConstant.ORGANIZATION_APP_KEY, ApplicationConfigConstant.ORGANIZATION_APP_SECRET, papiCode); + jsonObject.put("access_token", papiToken); + + log.error("jsonObject===" + jsonObject); + + return HttpRequest.post(ApplicationConfigConstant.APP_URL + "/papi/openapi/api/ebuilder/form/dataset/v2/saveFormData") + .header("Content-Type", "application/json") + .body(jsonObject.toJSONString()) + .execute() + .body(); + } + + + /** + * 获取北森系统offer数据 + * + * @param token + * @param startDate + * @param startTime + * @param endDate + * @param endTime + * @return + */ + public static List getBeiSenOfferData(String token, String startDate, String startTime, String endDate, String endTime) { + List offerArray = new ArrayList<>(); + String scrollId = ""; + boolean hasMore = true; + + while (hasMore) { + JSONObject bodyJson = new JSONObject(); + bodyJson.put("startTime", startDate + "T" + startTime); + bodyJson.put("stopTime", endDate + "T" + endTime); + bodyJson.put("timeWindowQueryType", "1"); + if (StringUtils.isNotBlank(scrollId)) { + bodyJson.put("scrollId", scrollId); + } + + try { + String url = Constants.beishenHost + Constants.offerUrl; + + String resultStr = HttpRequest.post(url) + .header("Content-Type", "application/json") + .header("Authorization", "Bearer " + token) + .body(bodyJson.toJSONString()) + .execute() + //.charset("UTF-8") // 显式指定编码 + .body(); + // Bearer X4eTEiMr-1SzSRQHqY2MuRMnVgJbxp7kYKg3ZqTvwvYlD6CXfkfq-lGI_Rl3swX3E097-rkhE + + if (StringUtils.isNotBlank(resultStr)) { + try { + JSONObject returnJson = JSONObject.parseObject(resultStr); + if ("200".equals(returnJson.getString("code"))) { + JSONArray dataArray = returnJson.getJSONArray("data"); + List offerList = JSONArray.parseArray( + dataArray.toJSONString(), + BeiSenOffer.class + ); + offerArray.addAll(offerList); + scrollId = returnJson.getString("scrollId"); + hasMore = StringUtils.isNotBlank(scrollId) && dataArray.size() > 0; + } else { + log.error("接口返回非200: " + resultStr); + hasMore = false; + } + } catch (Exception e) { + log.error("解析 queryOfferByDateTime 响应失败: " + resultStr); + hasMore = false; + } + } else { + log.error("HTTP请求返回空响应"); + hasMore = false; + } + } catch (Exception e) { + log.error("HTTP请求异常: " + e.getMessage()); + hasMore = false; + } + } + + return offerArray; + } + + + /** + * 转换对象中带有@FieldConversion注解的字段值 + * + * @param baseParam 基础参数 + * @param obj 需要转换的对象 + * @return 转换后的对象 + */ + public T convertObjectFields(BaseParam baseParam, T obj) { + if (obj == null) { + return null; + } + + Class clazz = obj.getClass(); + Field[] fields = clazz.getDeclaredFields(); + + for (Field field : fields) { + // 检查字段是否有FieldConversion注解 + if (field.isAnnotationPresent(FieldConversion.class)) { + FieldConversion annotation = field.getAnnotation(FieldConversion.class); + String relatedTable = annotation.relatedTable(); + String defaultValue = annotation.defaultValue(); + + try { + field.setAccessible(true); + Object fieldValue = field.get(obj); + log.error("field: " + field); + log.error("fieldValue: " + fieldValue); + // 只处理String类型的字段 + if (fieldValue instanceof String) { + String convertedValue = convertFieldValue(baseParam, relatedTable, (String) fieldValue, defaultValue); + field.set(obj, convertedValue); + } + } catch (IllegalAccessException e) { + // 处理访问异常 + e.printStackTrace(); + } + } + } + + return obj; + } + + /** + * 根据表名和字段值进行转换 + * + * @param tableName 关联的表名 + * @param fieldValue 字段值 + * @param defaultValue 默认值 + * @return 转换后的值 + */ + private String convertFieldValue(BaseParam baseParam, String tableName, String fieldValue, String defaultValue) { + if (StringUtils.isBlank(fieldValue)) { + fieldValue = defaultValue; + } + if (StringUtils.isBlank(fieldValue)) { + return null; + } + log.error("tableName: " + tableName); + log.error("offerMapper is null: " + (offerMapper == null)); + return offerMapper.convertBeiSenField(baseParam, tableName, fieldValue); + } + + /** + * 获取字段的注解信息 + * + * @param obj 对象实例 + * @param fieldName 字段名 + * @return 注解信息 + */ + public static FieldConversionInfo getFieldConversionInfo(Object obj, String fieldName) { + if (obj == null || fieldName == null) { + return null; + } + + try { + Field field = obj.getClass().getDeclaredField(fieldName); + if (field.isAnnotationPresent(FieldConversion.class)) { + FieldConversion annotation = field.getAnnotation(FieldConversion.class); + return new FieldConversionInfo(annotation.relatedTable(), annotation.defaultValue()); + } + } catch (NoSuchFieldException e) { + e.printStackTrace(); + } + + return null; + } + + + /** + * 根据个人邮箱、证件号码、姓名判断，新入职人员， + * 默认0：新增入职； + * 有入职信息，默认1：离职重聘 + * + * @param offer + * @return + */ + public String checkEntryType(BaseParam baseParam, BeiSenOffer offer) { + String entryType = "0"; + Integer entryCount = offerMapper.getEntryCount(baseParam, offer); + if (entryCount > 0) { + entryType = "1"; + } + return entryType; + } + + /** + * 根据oId获取员工id + * + * @param baseParam + * @param oId + * @return + */ + public String getEmployeeIdByOId(BaseParam baseParam, Long oId) { + Long employeeId = offerMapper.getEmployeeIdByOId(baseParam, oId); + return employeeId == null ? null : employeeId.toString(); + } + + public String getEmployeeIdByOId(BaseParam baseParam, String oId) { + if (StringUtils.isNotBlank(oId)) { + Long employeeId = offerMapper.getEmployeeIdByOId(baseParam, Long.parseLong(oId)); + return employeeId == null ? null : employeeId.toString(); + } + return null; + } + + /** + * 根据员工id获取部门id + * + * @param baseParam + * @param empId + * @return + */ + public String getDeptIdByEmpId(BaseParam baseParam, String empId) { + if (StringUtils.isNotBlank(empId)) { + SimpleEmployee byId = hrmCommonEmployeeDao.getById(Long.parseLong(empId)); + if (null != byId) { + return byId.getDepartmentId().toString(); + } + } + return null; + } + + /** + * 根据oId获取部门id + * + * @param baseParam + * @param oId + * @return + */ + public String getDeptIdByOId(BaseParam baseParam, Long oId) { + Long deptId = offerMapper.getDepartmentIdByOId(baseParam, oId); + return deptId == null ? null : deptId.toString(); + } + + public List getDeptListByLevel(Long deptId) { + return departMentService.getAllSuperDepIds(deptId); + } + + +} diff --git a/src/main/java/com/weaver/seconddev/beisen/mapper/OfferMapper.java b/src/main/java/com/weaver/seconddev/beisen/mapper/OfferMapper.java new file mode 100644 index 0000000..05455b0 --- /dev/null +++ b/src/main/java/com/weaver/seconddev/beisen/mapper/OfferMapper.java @@ -0,0 +1,26 @@ +package com.weaver.seconddev.beisen.mapper; + +import com.weaver.seconddev.beisen.entity.BeiSenOffer; +import com.weaver.seconddev.portal.entity.param.BaseParam; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +/** + * @author:dxfeng + * @createTime: 2025/07/24 + * @version: 1.0 + */ +@Mapper +public interface OfferMapper { + + String convertBeiSenField(@Param("param") BaseParam param, @Param("tableName") String tableName, @Param("value") String value); + + Integer getEntryCount(@Param("param") BaseParam param,@Param("offer") BeiSenOffer offer); + + Long getEmployeeIdByOId(@Param("param") BaseParam param,@Param("oId") Long oId); + + Long getDepartmentIdByOId(@Param("param") BaseParam param,@Param("oId") Long oId); + + Long getOfferIdByObjectId(@Param("param") BaseParam param,@Param("objectId") String objectId); + +} diff --git a/src/main/resources/mapper/beisen/OfferMapper.xml b/src/main/resources/mapper/beisen/OfferMapper.xml new file mode 100644 index 0000000..62323a4 --- /dev/null +++ b/src/main/resources/mapper/beisen/OfferMapper.xml @@ -0,0 +1,46 @@ + + + + + + + + + + + + + +