From dcba5c39f340ac3d1e3bf94b7be83f74a4886714 Mon Sep 17 00:00:00 2001 From: dxfeng Date: Thu, 7 Aug 2025 14:17:36 +0800 Subject: [PATCH] =?UTF-8?q?refactor(entry):=20=E6=96=B0=E5=A2=9E=E7=BC=96?= =?UTF-8?q?=E5=88=B6=E6=A0=A1=E9=AA=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 招需流程-增加编制校验动作流 --- .../controller/EntryManageController.java | 34 ------- .../staff/action/StaffCheckAction.java | 98 +++++++++++++++++++ 2 files changed, 98 insertions(+), 34 deletions(-) create mode 100644 src/main/java/com/weaver/seconddev/staff/action/StaffCheckAction.java diff --git a/src/main/java/com/weaver/seconddev/entry/controller/EntryManageController.java b/src/main/java/com/weaver/seconddev/entry/controller/EntryManageController.java index 7828cf0..cd9bca7 100644 --- a/src/main/java/com/weaver/seconddev/entry/controller/EntryManageController.java +++ b/src/main/java/com/weaver/seconddev/entry/controller/EntryManageController.java @@ -1,22 +1,13 @@ package com.weaver.seconddev.entry.controller; -import com.alibaba.fastjson.JSON; import com.weaver.common.authority.annotation.WeaPermission; import com.weaver.common.base.entity.result.WeaResult; import com.weaver.seconddev.entry.service.EntryManageService; -import com.weaver.teams.hrapp.dto.est.HrComEstEmpDto; -import com.weaver.teams.hrapp.dto.est.HrComEstOrgValResDto; -import com.weaver.teams.hrapp.dto.est.param.HrComEstCheckParam; import com.weaver.teams.hrapp.service.HrComEstService; -import com.weaver.teams.security.context.UserContext; -import com.weaver.teams.security.user.User; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; import java.util.Map; /** @@ -45,29 +36,4 @@ public class EntryManageController { return entryManageService.uploadFiles(params); } - @PostMapping("/testStaff") - private WeaResult> testStaff(@RequestBody HrComEstCheckParam checkParam) { - //return entryManageService.testStaff(params); - User currentUser = UserContext.getCurrentUser(); - log.error("checkParam==={}", JSON.toJSONString(checkParam)); - log.error("currentUser==={}", JSON.toJSONString(currentUser)); - Map map = new HashMap<>(); - - HrComEstOrgValResDto hrComEstOrgValResDto = hrComEstService.estValidate(currentUser.getTenantKey(), currentUser.getEmployeeId(), checkParam); - log.error("hrComEstOrgValResDto==={}", JSON.toJSONString(hrComEstOrgValResDto)); - - map.put("currentUser", JSON.toJSONString(currentUser)); - map.put("checkParam", JSON.toJSONString(checkParam)); - map.put("hrComEstOrgValResDto", JSON.toJSONString(hrComEstOrgValResDto)); - return WeaResult.success(map); - } - - public static void main(String[] args) { - HrComEstCheckParam checkParam = new HrComEstCheckParam(); - List empList = new ArrayList<>(); - HrComEstEmpDto emp = new HrComEstEmpDto(); - emp.setNewDepartmentId(1151352978370437120L); - - - } } diff --git a/src/main/java/com/weaver/seconddev/staff/action/StaffCheckAction.java b/src/main/java/com/weaver/seconddev/staff/action/StaffCheckAction.java new file mode 100644 index 0000000..b28a893 --- /dev/null +++ b/src/main/java/com/weaver/seconddev/staff/action/StaffCheckAction.java @@ -0,0 +1,98 @@ +package com.weaver.seconddev.staff.action; + +import cn.hutool.core.convert.Convert; +import cn.hutool.http.HttpRequest; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.weaver.common.base.entity.result.WeaResult; +import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface; +import com.weaver.seconddev.portal.constant.ApplicationConfigConstant; +import com.weaver.seconddev.portal.util.PapiUtil; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang.StringUtils; +import org.springframework.stereotype.Service; + +import java.util.ArrayList; +import java.util.Date; +import java.util.List; +import java.util.Map; + +/** + * 招聘需求流程提交时，根据年、月、部门、岗位、招需人数三个条件，判断是否超编，超编前端提醒并阻止流程提交，不超编，流转流转。 + * + * @author:dxfeng + * @createTime: 2025/08/07 + * @version: 1.0 + */ +@Slf4j +@Service("StaffCheckAction") +public class StaffCheckAction implements EsbServerlessRpcRemoteInterface { + @Override + public WeaResult> execute(Map params) { + log.error("StaffCheckAction==params=={}", params); + // 部门id + Long departmentId = Convert.toLong(params.get("departmentId")); + // 岗位id + Long positionId = Convert.toLong(params.get("positionId")); + // 办公地点id + Long locationId = Convert.toLong(params.get("locationId")); + // 职称 + Long jobCallId = Convert.toLong(params.get("jobCallId")); + // 职级 + Long gradeId = Convert.toLong(params.get("gradeId")); + // 职等 + Long jobsetLevelId = Convert.toLong(params.get("jobsetLevelId")); + // 入职日期 + String hiredate = Convert.toStr(params.get("hiredate")); + if (StringUtils.isNotBlank(hiredate) && hiredate.length() == 7) { + hiredate = hiredate + "-01"; + } + Date date = Convert.toDate(hiredate); + // 人员状态 + Long personnelStatus = Convert.toLong(params.get("personnelStatus")); + // 需求人数 + Integer requiredNumber = Convert.toInt(params.get("requiredNumber"), 0); + + if (requiredNumber < 1) { + // 需求人数小于1,不做校验 + return WeaResult.success(); + } + + 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); + List empList = new ArrayList<>(); + JSONObject jsonObject = new JSONObject(); + + // 赵普西 + for (int i = 0; i < requiredNumber; i++) { + JSONObject obj = new JSONObject(); + obj.put("departmentId", departmentId); + obj.put("positionId", positionId); + obj.put("locationId", locationId); + obj.put("jobCallId", jobCallId); + obj.put("gradeId", gradeId); + obj.put("jobsetLevelId", jobsetLevelId); + obj.put("hiredate", date); + obj.put("personnelStatus", personnelStatus); + empList.add(obj); + } + jsonObject.put("empList", empList); + jsonObject.put("source", "addEmp"); + jsonObject.put("access_token", papiToken); + log.error("validate==jsonObject=={}", JSON.toJSONString(jsonObject)); + String response = HttpRequest.post(ApplicationConfigConstant.APP_URL + "/papi/openapi/api/hr/hrapi/est/validate") + .header("Content-Type", "application/json") + .body(jsonObject.toJSONString()) + .execute() + .body(); + log.error("validate>>response===" + response); + + JSONObject responseJson = JSONObject.parseObject(response); + JSONObject data = responseJson.getJSONObject("data"); + if (data != null && !data.getBoolean("checkResult")) { + // 验证失败 + return WeaResult.fail(data.getString("errContent"), true); + } + return WeaResult.success(); + } +}