上线包

path/20250815/server/deploy/easweb.ear/shr_web.war/addon/custom/js/adminOrgEx.js

@@ -0,0 +1,16 @@
+shr.defineClass("shr.org.adminOrgListEx", shr.org.adminOrgList, {
+    initalizeDOM : function () {
+        shr.org.adminOrgListEx.superClass.initalizeDOM.call(this);
+      },
+      synchronousOrgAction:function(){
+		var selectedIds = this.getSelectedIds();
+		if (!selectedIds) {
+			return;
+		}
+		this.doRemoteWithBatchAction({
+				method: "synchronousOrg",
+				id: selectedIds
+		});
+		
+      }
+})

path/20250815/server/deploy/easweb.ear/shr_web.war/addon/custom/js/beisen/syncperson/employeeDynListEx.js

@@ -0,0 +1,53 @@
+/**
+ * 北森应聘者
+ */
+shr.defineClass("shr.custom.EmployeeDynListEx", shr.emp.EmployeeDynList, {
+	initalizeDOM: function () {
+		shr.custom.EmployeeDynListEx.superClass.initalizeDOM.call(this);
+		var _self = this;
+	},
+	/**
+	 * 同步人员至北森
+	 */
+	syncPersonToBeisenAction: function () {
+		var that = this;
+		var $grid = $(this.gridId);
+		var billIds = $("#grid").jqGrid("getSelectedRows");
+		if (billIds.length <= 0) {
+			shr.showWarning({
+				message: "请先选中一行数据！",
+				hideAfter: 5
+			})
+			return;
+		}
+		shr.showConfirm("是否确认同步！！", function () {
+			// that.remoteCall({
+			// 	method: 'syncPersonToBeisen',
+			// 	param: {
+			// 		billId: billIds.toString(),
+			// 	},
+			// 	success: function (data) {
+			// 		$grid.jqGrid("reloadGrid");
+			// 	}
+			// });
+			// shr.showSuccess({
+			// 	message: "正在后台执行，请稍后....",
+			// 	hideAfter: 5
+			// })
+			that.defaultBatchActionHandle("syncPersonToBeisen");
+
+		});
+		
+	},
+	synBeiSenPersonAction:function(){
+		var selectedIds = this.getSelectedIds();
+		if (!selectedIds) {
+			return;
+		}
+		this.doRemoteWithBatchAction({
+				method: "synBeiSenPerson",
+				ids: selectedIds
+		});
+	}
+});
+

websrc/com/kingdee/eas/custom/beisen/syncperson/service/SyncPersonToBeisenService.java

@@ -0,0 +1,452 @@
+package com.kingdee.eas.custom.beisen.syncperson.service;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.kingdee.bos.BOSException;
+import com.kingdee.bos.Context;
+import com.kingdee.bos.bsf.service.app.IHRMsfService;
+import com.kingdee.bos.metadata.entity.*;
+import com.kingdee.bos.metadata.query.util.CompareType;
+import com.kingdee.eas.base.permission.IUser;
+import com.kingdee.eas.base.permission.UserCollection;
+import com.kingdee.eas.base.permission.UserFactory;
+import com.kingdee.eas.base.permission.UserInfo;
+import com.kingdee.eas.basedata.org.AdminOrgUnitInfo;
+import com.kingdee.eas.basedata.org.PositionInfo;
+import com.kingdee.eas.basedata.person.IPerson;
+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.custom.beisen.utils.BeisenApiClient;
+import com.kingdee.eas.custom.beisen.utils.BeisenParamByPropertiesUtil;
+import com.kingdee.eas.hr.ats.AtsUtil;
+import com.kingdee.eas.hr.base.*;
+import com.kingdee.eas.hr.emp.*;
+import com.kingdee.eas.util.app.DbUtil;
+import com.kingdee.jdbc.rowset.IRowSet;
+import com.kingdee.util.DateTimeUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.log4j.Logger;
+
+import java.io.IOException;
+import java.net.URLEncoder;
+import java.nio.charset.StandardCharsets;
+import java.sql.SQLException;
+import java.util.*;
+
+/**
+ * @ClassName SyncPersonToBeisenService
+ * @Description 同步人员信息数据到北森
+ * @Author 青梧
+ * @Date 2025/7/17 10:50
+ * @Version 1.0
+ **/
+public class SyncPersonToBeisenService implements IHRMsfService {
+    private static Logger logger = Logger.getLogger(SyncPersonToBeisenService.class);
+    private BeisenApiClient beisenApiClient = null;
+
+    public SyncPersonToBeisenService() {
+        beisenApiClient = BeisenApiClient.getInstance();
+    }
+
+    @Override
+    public Object process(Context ctx, Map map) throws EASBizException, BOSException {
+        Integer day = (Integer) map.get("day");
+        String personId = (String) map.get("personId");
+        // 获取到所有需要的personid
+        Set<String> personSet = new HashSet();
+        // 获取当前日期
+        Date now = new Date();
+        // 获取指定天数前的日期
+        Date dayBefore = getDayBefore(now, day);
+        FilterInfo filterInfo = new FilterInfo();
+        FilterItemCollection filterItems = filterInfo.getFilterItems();
+        filterItems.add(new FilterItemInfo("lastUpdateTime", dayBefore, CompareType.GREATER_EQUALS));
+        filterItems.add(new FilterItemInfo("lastUpdateTime", now, CompareType.LESS_EQUALS));
+        SelectorItemCollection sic = new SelectorItemCollection();
+        sic.add(new SelectorItemInfo("id"));
+        IPerson iPerson = PersonFactory.getLocalInstance(ctx);
+        EntityViewInfo entityViewInfo = EntityViewInfo.getInstance(filterInfo, sic, null);
+        PersonCollection personCol = iPerson.getPersonCollection(entityViewInfo);
+        // 循环获取所有人员id
+        for (int i = 0; i < personCol.size(); i++) {
+            PersonInfo personInfo = personCol.get(i);
+            personSet.add(personInfo.getId().toString());
+        }
+
+        sic = new SelectorItemCollection();
+        sic.add(new SelectorItemInfo("person.id"));
+        entityViewInfo = EntityViewInfo.getInstance(filterInfo, sic, null);
+        // 获取员工变动记录的personid
+        IEmpPosOrgRelation empIns = EmpPosOrgRelationFactory.getLocalInstance(ctx);
+        EmpPosOrgRelationCollection empCol = empIns.getEmpPosOrgRelationCollection(entityViewInfo);
+        // 循环获取所有人员id
+        for (int i = 0; i < empCol.size(); i++) {
+            EmpPosOrgRelationInfo empPosOrgRelation = empCol.get(i);
+            String personIdStr = empPosOrgRelation.getPerson().getId().toString();
+            personSet.add(personIdStr);
+        }
+        // 同步到beisen
+        String s = convertSetToString(personSet);
+        return _syncPerson(ctx, personId, day);
+
+    }
+
+    public static String convertSetToString(Set set) {
+        if (set != null && set.size() > 0) {
+            Iterator iter = set.iterator();
+            StringBuffer sql = new StringBuffer();
+
+            while (iter.hasNext()) {
+//                sql.append("'");
+                sql.append(iter.next());
+//                sql.append("',");
+                sql.append(",");
+            }
+
+            sql.deleteCharAt(sql.length() - 1);
+            return sql.toString();
+        } else {
+            return "''";
+        }
+    }
+
+    /**
+     * 同步人员信息
+     *
+     * @param ctx
+     * @param personId
+     * @throws BOSException
+     * @throws EASBizException
+     */
+    protected JSONArray _syncPerson(Context ctx, String personId, int day) {
+        JSONArray jsonArray = new JSONArray();
+        FilterInfo filterInfo = new FilterInfo();
+        FilterItemCollection filterItems = filterInfo.getFilterItems();
+        Set personIds = new HashSet();
+        SelectorItemCollection sic = getSelectorItemCollection();
+        // 如果为空查询所有数据
+        if (!StringUtils.isEmpty(personId)) {
+            personIds = AtsUtil.toSet(personId);
+            logger.error("syncPersonToIot---personIds---" + personIds);
+            filterItems.add(new FilterItemInfo("person", personIds, CompareType.INCLUDE));
+        }
+        try {
+            BeisenParamByPropertiesUtil beisenParamByProperties = new BeisenParamByPropertiesUtil("/server/properties/beisen/BeiSenConfig.properties");
+            Map<String, String> config = beisenParamByProperties.getConfig();
+            logger.error("config---" + config.size());
+            // 查询所有人的user用户
+            IUser iUser = UserFactory.getLocalInstance(ctx);
+            UserCollection userCollection = iUser.getUserCollection();
+            Map userMap = new HashMap();
+            for (int i = 0; i < userCollection.size(); i++) {
+                UserInfo userInfo = userCollection.get(i);
+                PersonInfo person = userInfo.getPerson();
+                if (person != null) {
+                    String userName = userInfo.getName();
+                    userMap.put(person.getId(), userName);
+                }
+            }
+            // 查询所有人的直接上级
+            Map personParentMap = getPersonParent(ctx);
+            IPersonPosition iPersonPosition = PersonPositionFactory.getLocalInstance(ctx);
+            EntityViewInfo entityViewInfo = EntityViewInfo.getInstance(filterInfo, sic, null);
+            PersonPositionCollection personPositionCollection = iPersonPosition.getPersonPositionCollection(entityViewInfo);
+            if (personPositionCollection.isEmpty()) {
+                jsonArray.add("[" + personId + "]未查询到人员信息数据，请检查参数是否url编码");
+            }
+            for (int i = 0; i < personPositionCollection.size(); i++) {
+                Map msgMap = new HashMap();
+                JSONObject personJson = new JSONObject();
+                PersonPositionInfo personPositionInfo = personPositionCollection.get(i);
+                PersonInfo person = personPositionInfo.getPerson();
+                // 入职ID
+                Object bsUserId = person.get("bsUserId");
+                Object beisenId = person.get("beisenId");
+                logger.error("bsUserId--" + bsUserId);
+                logger.error("beisenId--" + beisenId);
+                String originalId = URLEncoder.encode(person.getId().toString(), StandardCharsets.UTF_8.name());
+                String nCell = person.getNCell();
+                String name = person.getName();
+                msgMap.put("number", person.getNumber());
+                msgMap.put("name", name);
+                msgMap.put("originalId", originalId);
+                msgMap.put("bsUserId", bsUserId);
+                msgMap.put("beisenId", beisenId);
+                EmployeeTypeInfo employeeType = person.getEmployeeType();
+                EmployeeTypeEnum inServiceEnum = employeeType.getInService();
+                String email = person.getEmail();
+                if (StringUtils.isEmpty(email)) {
+                    // throw new BOSException(person.getName() + "同步失败:邮箱不能为空，请维护！！");
+                    msgMap.put("message", person.getName() + "同步失败:邮箱不能为空，请维护！！");
+                    jsonArray.add(msgMap);
+                    continue;
+                }
+                personJson.put("email", email);// 邮箱
+                personJson.put("userName", email);// 用户名
+                personJson.put("name", name);// 姓名
+                personJson.put("originalId", person.getId().toString());// 来源方用户ID
+                // 来源（创建更新必填字段） 员工创建时的业务来源。0：其他；1：平台；2：测评；3：招聘；4：360；5：自由注册；6：Tita；7：Tita移动端；1001：PeopleSoft
+                personJson.put("origin", 1);
+                personJson.put("mobile", nCell);// 手机号
+                personJson.put(config.get("EMPLOYEETYPENUMBER"), employeeType.getNumber());// 用工关系状态
+                AdminOrgUnitInfo personDep = personPositionInfo.getPersonDep();
+                personJson.put("departmentOriginalId", personDep.getId());// 部门外部标识
+                personJson.put(config.get("HIREDATE"), DateTimeUtils.format(person.getHireDate()));// 入职日期
+                Object lineManagerOriginalId = personParentMap.get(personId) == null ? null : URLEncoder.encode(personParentMap.get(personId).toString(), StandardCharsets.UTF_8.name());
+                personJson.put(config.get("lineManagerOriginalId"), lineManagerOriginalId);//  直线上级外部标识
+                PositionInfo primaryPosition = personPositionInfo.getPrimaryPosition();
+                personJson.put(config.get("positionNumber"), primaryPosition.getNumber());//  岗位编码
+                personJson.put(config.get("positionName"), primaryPosition.getName());//  岗位名称
+                // 判断是否在北森存在 如果beisenId为空并且是在职状态需要再北森创建员工
+                if (beisenId == null) {
+                    // 判断是否在职
+                    if (inServiceEnum.getValue() == 2) {
+                        msgMap.put("message", person.getName() + "已离职无需同步北森！！");
+                        jsonArray.add(msgMap);
+                        continue;
+                    }
+                    // 创建员工信息
+                    String staffsPost = config.get("STAFFSPOST");
+                    logger.error("personJson--" + personJson);
+                    JSONObject staffs = beisenApiClient.callApi(staffsPost, personJson);
+                    if (!"200".equals(staffs.getString("code"))) {
+                        msgMap.put("message", "创建员工信息失败,原因:" + staffs.get("message"));
+                        jsonArray.add(msgMap);
+                        continue;
+                    }
+                    String data = staffs.getString("data");
+                    // 更新bsUserId
+                    updatePersonBensenId(ctx, person, data);
+                    msgMap.put("bsUserId", data);
+                    msgMap.put("创建员工信息：", staffs.get("message"));
+                } else {
+                    // 查询待入职人员信息 通过beisenId 入职员工ID获取入职记录guid和userId
+                    Map<String, String> result = getGuid(config, beisenId);
+                    logger.error("result--" + result);
+                    if (result == null || result.isEmpty()) {
+                        msgMap.put("message", "入职ID[" + beisenId + "]未查询到入职信息！");
+                        jsonArray.add(msgMap);
+                        continue;
+                    }
+                    String userId = result.get("userID");
+                    // 判断userid是否等于shr员工信息维护的北森id,如果不等于通过bsUserId修改北森用户管理的外部Id
+                    logger.error("bsUserId == null" + bsUserId == null);
+                    if (bsUserId == null) {
+                        bsUserId = userId;
+                    }
+                    logger.error(person.getName() + ":" + userId + "--" + bsUserId);
+                    msgMap.put("userID", userId);
+                    if (userId != bsUserId) {
+                        updateBeisenOriginalIdByUserId(msgMap, config, bsUserId);
+                        // 更新bsUserId
+                        updatePersonBensenId(ctx, person, (String) bsUserId);
+                    }
+                    // 通过OriginalId更新员工信息
+                    JSONObject udpatePersonJson = personJson;
+                    // 删除用户名，不修改用户名
+                    udpatePersonJson.remove("userName");
+                    String putbyuserid = config.get("PUTBYUSERID") + "?userId=" + userId;
+                    logger.error("putbyuserid--" + putbyuserid);
+                    logger.error("udpatePersonJson--" + udpatePersonJson);
+                    JSONObject updateStaffs = beisenApiClient.callPutApi(putbyuserid, udpatePersonJson);
+                    msgMap.put("通过userId更新员工信息：", updateStaffs.get("message"));
+                    // 更新bsUserId
+                    updatePersonBensenId(ctx, person, userId);
+                    // 更新待入职人员信息
+                    if (beisenId != null) {
+                        JSONObject updateStaffInfo = new JSONObject();
+                        JSONObject staffInfos = new JSONObject();
+                        staffInfos.put("id", beisenId);
+                        staffInfos.put("name", name);
+                        // staffInfos.put("email", email);
+                        staffInfos.put("mobilePhone", nCell);
+                        staffInfos.put("staffStatus", 1);
+                        updateStaffInfo.put("staffInfos", staffInfos);
+                        logger.error("updateStaffInfo--" + updateStaffInfo);
+                        JSONObject updateStaffRet = beisenApiClient.callApi(config.get("UPDATESTAFFURL"), updateStaffInfo);
+                        msgMap.put("更新待入职人员信息：", updateStaffRet.get("code"));
+                    }
+                    // 通过userId更新员工信息
+                    if (inServiceEnum.getValue() == 2 || inServiceEnum.getValue() == 0) {
+                        // 通过OriginalId设置员工离职
+                        String putSetdimission = config.get("PUTSETDIMISSION") + "=" + originalId;
+                        logger.error("putSetdimission--" + putSetdimission);
+                        JSONObject setdimission = beisenApiClient.callPutApi(putSetdimission, new JSONObject());
+                        msgMap.put("通过OriginalId设置员工离职：", setdimission.get("message"));
+                        // 入职管理设置离职
+                        String recruitOnBoardingPost = config.get("RECRUITONBOARDINGPOST") + "?entryId=" + result.get("guid");
+                        logger.error("recruitOnBoardingPost--" + recruitOnBoardingPost);
+                        JSONObject recruitOnBoarding = beisenApiClient.callApi(recruitOnBoardingPost, new JSONObject());
+                        msgMap.put("入职单设置离职：", recruitOnBoarding.get("message"));
+                    } else if (inServiceEnum.getValue() == 1) {
+                        // 入职管理设置已入职  需求变更无需调用该接口
+                        // 设置员工在职
+                        String putSetinduction = config.get("PUTSETINDUCTION") + "?originalId=" + originalId + "&accountEnable=true";
+                        logger.error("putSetinduction--" + putSetinduction);
+                        JSONObject setinduction = beisenApiClient.callPutApi(putSetinduction, new JSONObject());
+                        msgMap.put("设置员工在职：", setinduction.get("message"));
+                    }
+                }
+                jsonArray.add(msgMap);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            logger.error(e.getMessage());
+            jsonArray.add(e.getMessage());
+            // throw new RuntimeException(e);
+        }
+        logger.error("jsonArray--" + jsonArray);
+        return jsonArray;
+    }
+
+    /**
+     * 通过bsUserId修改北森用户管理的外部Id
+     *
+     * @param bsUserId
+     */
+    public void updateBeisenOriginalIdByUserId(Map map, Map config, Object bsUserId) throws IOException {
+        String putbyuserid = config.get("PUTBYUSERID") + "?userId=" + bsUserId;
+        JSONObject udpatePersonJson = new JSONObject();
+        udpatePersonJson.put("originalId", "");
+        udpatePersonJson.put("email", "");
+        JSONObject json = beisenApiClient.callPutApi(putbyuserid, udpatePersonJson);
+        map.put("修改北森用户管理的外部Id：", json.get("message"));
+    }
+
+    /**
+     * @param person
+     * @throws BOSException
+     * @throws EASBizException
+     */
+    private static void updatePersonBensenId(Context ctx, PersonInfo person, String bsUserId) throws BOSException, EASBizException {
+        // 员工
+        IPerson iPerson = PersonFactory.getLocalInstance(ctx);
+        person.put("bsUserId", bsUserId);
+        SelectorItemCollection personUpdSic = new SelectorItemCollection();
+        personUpdSic.add("bsUserId");
+        iPerson.updatePartial(person, personUpdSic);
+    }
+
+    /**
+     * 查询待入职人员信息 通过beisenId 入职员工ID获取入职记录guid
+     *
+     * @param config
+     * @param beisenId
+     * @return
+     */
+    public Map getGuid(Map<String, String> config, Object beisenId) {
+        Map<String, String> result = null;
+        try {
+            result = new HashMap<>();
+            String guid = null;
+            JSONArray jsonArray = new JSONArray();
+            jsonArray.add(beisenId);
+            JSONObject staffInfos = beisenApiClient.callApi(config.get("GETSTAFFINFOS"), jsonArray);
+            logger.error("staffInfos--" + staffInfos);
+            if (staffInfos.getInteger("code") == 200) {
+                JSONArray data = staffInfos.getJSONArray("data");
+                for (int i = 0; i < data.size(); i++) {
+                    JSONObject dataJson = data.getJSONObject(i);
+                    logger.error("dataJson--" + dataJson);
+                    // entryRecord 入职记录
+                    JSONArray entryRecord = dataJson.getJSONArray("entryRecord");
+                    for (int j = 0; j < entryRecord.size(); j++) {
+                        JSONObject entry = entryRecord.getJSONObject(j);
+                        if (entry.getInteger("status") == 1 || entry.getInteger("status") == 0) {
+                            guid = entry.getString("id");
+                            result.put("guid", guid);
+                        }
+                    }
+                    // 任职记录
+                    Long dataTime = 0l;
+                    JSONArray employmentRecord = dataJson.getJSONArray("employmentRecord");
+                    for (int q = 0; q < employmentRecord.size(); q++) {
+                        JSONObject employment = employmentRecord.getJSONObject(q);
+                        String entryDate = employment.getString("entryDate");
+                        logger.debug("entryDate--" + entryDate);
+                        // 处理entryDate为空的数据必须要保存一条数据，如果不为空则保存最新的一条数据
+                        result.put("userID", employment.getString("userID"));
+                        if (!StringUtils.isEmpty(entryDate) && DateTimeUtils.parseDate(entryDate).getTime() > dataTime) {
+                            result.put("userID", employment.getString("userID"));
+                        }
+                    }
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+        return result;
+    }
+
+    /**
+     * 获取指定日期前 x 天的日期的方法。
+     *
+     * @param specifiedDay 指定日期
+     * @param x            天数
+     * @return 指定日期前 x 天的日期
+     */
+    public Date getDayBefore(Date specifiedDay, int x) {
+        // 获取 Calendar 实例
+        Calendar c = Calendar.getInstance();
+        // 设置 Calendar 的时间为指定日期
+        c.setTime(specifiedDay);
+        // 将日期向前移动 x 天
+        c.add(Calendar.DATE, -x);
+        // 返回移动后的日期
+        return c.getTime();
+    }
+
+    /**
+     * 获取所有人的直接上级
+     *
+     * @return
+     */
+    public Map getPersonParent(Context ctx) throws BOSException, SQLException {
+        Map personParentMap = new HashMap();
+        StringBuffer sb = new StringBuffer();
+        sb.append("select person.fid as personId , personParent.fid as personParentId\n").append("\n");
+        sb.append("from T_ORG_PositionMember positioonMenber\n").append("\n");
+        sb.append("left join T_ORG_Position position on position.fid = positioonMenber.FPositionID\n").append("\n");
+        sb.append("left join T_ORG_Position positionParent on position.fid = positionParent.FPARENTID\n").append("\n");
+        sb.append("left join T_HR_EmpOrgRelation empOrgRelation on empOrgRelation.FPOSITIONID = positionParent.fid\n").append("\n");
+        sb.append("left join t_Bd_person person on person.fid = empOrgRelation.FPERSONID and empOrgRelation.FIsSystem='1'\n").append("\n");
+        sb.append("left join t_Bd_person personParent on personParent.fid = positioonMenber.FPERSONID").append("\n");
+        IRowSet iRowSet = DbUtil.executeQuery(ctx, sb.toString());
+        while (iRowSet.next()) {
+            personParentMap.put(iRowSet.getString("personId"), iRowSet.getString("personParentId"));
+        }
+        return personParentMap;
+    }
+
+    /**
+     * 查询字段
+     *
+     * @return
+     */
+    public SelectorItemCollection getSelectorItemCollection() {
+        SelectorItemCollection sic = new SelectorItemCollection();
+        sic.add("*");
+        sic.add("person.number");
+        sic.add("person.name");
+        sic.add("person.beisenId");
+        sic.add("person.bsUserId");
+        sic.add("person.id");
+        sic.add("person.hireDate");
+        sic.add("person.nCell");
+        sic.add("person.gender");
+        sic.add("person.email");
+        sic.add("person.employeeType.name");
+        sic.add("person.employeeType.number");
+        sic.add("person.employeeType.inService");
+        sic.add("personDep.name");
+        sic.add("personDep.number");
+        sic.add("personDep.id");
+        sic.add("personDep.parent.id");
+        sic.add("primaryPosition.name");
+        sic.add("primaryPosition.number");
+        return sic;
+    }
+}