diff --git a/src/com/api/recruit/controller/InductionManageController.java b/src/com/api/recruit/controller/InductionManageController.java new file mode 100644 index 0000000..ace2af3 --- /dev/null +++ b/src/com/api/recruit/controller/InductionManageController.java @@ -0,0 +1,12 @@ +package com.api.recruit.controller; + +import javax.ws.rs.Path; + +/** + * @author:dxfeng + * @createTime: 2023/10/23 + * @version: 1.0 + */ +@Path("/jcl/recruit/induction") +public class InductionManageController extends com.engine.recruit.controller.InductionManageController{ +} diff --git a/src/com/engine/recruit/conn/RecruitRecordSet.java b/src/com/engine/recruit/conn/RecruitRecordSet.java index 69a2037..a392ddb 100644 --- a/src/com/engine/recruit/conn/RecruitRecordSet.java +++ b/src/com/engine/recruit/conn/RecruitRecordSet.java @@ -4,6 +4,8 @@ import org.apache.commons.lang3.StringUtils; import weaver.common.DateUtil; import weaver.conn.RecordSet; import weaver.formmode.recruit.modeexpand.util.RecruitModeUtil; +import weaver.formmode.setup.ModeRightInfo; +import weaver.general.Util; import java.util.ArrayList; import java.util.List; @@ -70,4 +72,26 @@ public class RecruitRecordSet { mainDataMap.put("modedatacreatertype", "0"); } + /** + * 建模表数据权限重构 + * + * @param uuid + * @param modeTable + * @param formModeId + */ + public static int refreshRight(String uuid, String modeTable, int formModeId) { + RecordSet rs = new RecordSet(); + rs.executeQuery("select id from " + modeTable + " where modeuuid='" + uuid + "'"); + if (rs.next()) { + //建模数据的id + int bid = Util.getIntValue(rs.getString("id")); + ModeRightInfo modeRightInfo = new ModeRightInfo(); + modeRightInfo.setNewRight(true); + //新建的时候添加共享 + modeRightInfo.editModeDataShare(1, formModeId, bid); + return bid; + } + return -1; + } + } diff --git a/src/com/engine/recruit/controller/InductionManageController.java b/src/com/engine/recruit/controller/InductionManageController.java new file mode 100644 index 0000000..b68bece --- /dev/null +++ b/src/com/engine/recruit/controller/InductionManageController.java @@ -0,0 +1,55 @@ +package com.engine.recruit.controller; + +import com.engine.common.util.ParamUtil; +import com.engine.common.util.ServiceUtil; +import com.engine.recruit.util.ResponseResult; +import com.engine.recruit.wrapper.InductionManageWrapper; +import weaver.hrm.HrmUserVarify; +import weaver.hrm.User; + +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import javax.ws.rs.POST; +import javax.ws.rs.Path; +import javax.ws.rs.Produces; +import javax.ws.rs.core.Context; +import javax.ws.rs.core.MediaType; +import java.util.Map; + +/** + * @author:dxfeng + * @createTime: 2023/10/23 + * @version: 1.0 + */ +public class InductionManageController { + public InductionManageWrapper getInductionManageWrapper(User user) { + return ServiceUtil.getService(InductionManageWrapper.class, user); + } + + @POST + @Path("/updateInductionManageInfo") + @Produces(MediaType.APPLICATION_JSON) + public String updateInductionManageInfo(@Context HttpServletRequest request, @Context HttpServletResponse response) { + User user = HrmUserVarify.getUser(request, response); + Map params = ParamUtil.request2Map(request); + return new ResponseResult, Map>(user).run(getInductionManageWrapper(user)::updateInductionManageInfo, params); + } + + @POST + @Path("/sendCollectInfo") + @Produces(MediaType.APPLICATION_JSON) + public String sendCollectInfo(@Context HttpServletRequest request, @Context HttpServletResponse response) { + User user = HrmUserVarify.getUser(request, response); + Map params = ParamUtil.request2Map(request); + return new ResponseResult, Map>(user).run(getInductionManageWrapper(user)::sendCollectInfo, params); + } + + @POST + @Path("/checkLoginInfo") + @Produces(MediaType.APPLICATION_JSON) + public String checkLoginInfo(@Context HttpServletRequest request, @Context HttpServletResponse response) { + User user = HrmUserVarify.getUser(request, response); + Map params = ParamUtil.request2Map(request); + return new ResponseResult, Map>(user).run(getInductionManageWrapper(user)::checkLoginInfo, params); + } +} diff --git a/src/com/engine/recruit/enums/InfoCollectEnum.java b/src/com/engine/recruit/enums/InfoCollectEnum.java new file mode 100644 index 0000000..40eb62a --- /dev/null +++ b/src/com/engine/recruit/enums/InfoCollectEnum.java @@ -0,0 +1,40 @@ +package com.engine.recruit.enums; + +/** + * @author:dxfeng + * @createTime: 2023/10/24 + * @version: 1.0 + */ +public enum InfoCollectEnum { + /** + * 信息采集状态 + */ + NOT_SENT(0, "未发送"), + HAS_SENT(1, "已发送"), + NOT_SUBMITTED(2, "未提交"), + SUBMITTED(3, "已提交"); + + InfoCollectEnum(Integer id, String name) { + this.id = id; + this.name = name; + } + + private Integer id; + private String name; + + public Integer getId() { + return id; + } + + public void setId(Integer id) { + this.id = id; + } + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } +} diff --git a/src/com/engine/recruit/enums/PositionOperateEnum.java b/src/com/engine/recruit/enums/PositionOperateEnum.java new file mode 100644 index 0000000..828a2d4 --- /dev/null +++ b/src/com/engine/recruit/enums/PositionOperateEnum.java @@ -0,0 +1,48 @@ +package com.engine.recruit.enums; + +/** + * @author:dxfeng + * @createTime: 2023/10/23 + * @version: 1.0 + */ +public enum PositionOperateEnum { + /** + * 入职管理相关操作 + */ + PREPARE("prepare", "入职准备"), + HANDLE("prepare", "办理入职"), + ; + + PositionOperateEnum(String operateType, String operateDesc) { + this.operateType = operateType; + this.operateDesc = operateDesc; + } + + private String operateType; + private String operateDesc; + + public String getOperateType() { + return operateType; + } + + public void setOperateType(String operateType) { + this.operateType = operateType; + } + + public String getOperateDesc() { + return operateDesc; + } + + public void setOperateDesc(String operateDesc) { + this.operateDesc = operateDesc; + } + + public static PositionOperateEnum getOperateType(String operateType) { + for (PositionOperateEnum item : PositionOperateEnum.values()) { + if (item.operateType.equalsIgnoreCase(operateType)) { + return item; + } + } + throw new RuntimeException("不支持的操作类型"); + } +} diff --git a/src/com/engine/recruit/service/InductionManageService.java b/src/com/engine/recruit/service/InductionManageService.java new file mode 100644 index 0000000..753ec79 --- /dev/null +++ b/src/com/engine/recruit/service/InductionManageService.java @@ -0,0 +1,35 @@ +package com.engine.recruit.service; + +import java.util.Map; + +/** + * @author:dxfeng + * @createTime: 2023/10/23 + * @version: 1.0 + */ +public interface InductionManageService { + /** + * 更新入职管理信息 + * + * @param param 参数 + * @return + */ + Map updateInductionManageInfo(Map param); + + + /** + * 发送信息采集 + * + * @param param + * @return + */ + Map sendCollectInfo(Map param); + + /** + * 校验登录信息 + * + * @param param + * @return + */ + Map checkLoginInfo(Map param); +} diff --git a/src/com/engine/recruit/service/impl/InductionManageServiceImpl.java b/src/com/engine/recruit/service/impl/InductionManageServiceImpl.java new file mode 100644 index 0000000..8ea8c9f --- /dev/null +++ b/src/com/engine/recruit/service/impl/InductionManageServiceImpl.java @@ -0,0 +1,132 @@ +package com.engine.recruit.service.impl; + +import com.engine.core.impl.Service; +import com.engine.recruit.conn.RecruitDataMap; +import com.engine.recruit.conn.RecruitRecordSet; +import com.engine.recruit.enums.InfoCollectEnum; +import com.engine.recruit.enums.PositionOperateEnum; +import com.engine.recruit.service.InductionManageService; +import com.engine.recruit.util.RecruitMessageUtils; +import org.apache.commons.lang3.StringUtils; +import weaver.conn.RecordSet; +import weaver.formmode.recruit.modeexpand.util.RecruitModeUtil; +import weaver.general.Util; + +import java.util.*; + +/** + * @author:dxfeng + * @createTime: 2023/10/23 + * @version: 1.0 + */ +public class InductionManageServiceImpl extends Service implements InductionManageService { + @Override + public Map updateInductionManageInfo(Map param) { + String operateType = Util.null2String(param.get("operateType")); + + if (PositionOperateEnum.PREPARE.getOperateType().equals(operateType)) { + // 发起入职准备 + + // 反填流程信息到建模表 + + } + return null; + } + + @Override + public Map sendCollectInfo(Map param) { + String ids = Util.null2String(param.get("ids")); + String[] split = ids.split(","); + + RecordSet rs = new RecordSet(); + for (String billId : split) { + // 根据入职管理信息完善信息采集表单 + Map dataMap = new RecruitDataMap<>(); + String uuid = UUID.randomUUID().toString(); + dataMap.put("modeuuid", uuid); + int formModeId = -1; + rs.executeQuery("select id from modeinfo where formid =( select id from workflow_bill where tablename = 'uf_jcl_xxcj' )"); + if (rs.next()) { + formModeId = rs.getInt("id"); + } + dataMap.put("formmodeid", formModeId); + // 构建建模表基本数据 + RecruitRecordSet.buildModeBaseFields(dataMap, user.getUID()); + + rs.executeQuery("select * from uf_jcl_rzgl where id = ? ", billId); + if (rs.next()) { + dataMap.put("xm", RecruitModeUtil.parseBlankToNull(rs.getString("xm"))); + dataMap.put("sfzh", RecruitModeUtil.parseBlankToNull(rs.getString("sfzh"))); + dataMap.put("nl", RecruitModeUtil.parseBlankToNull(rs.getString("nl"))); + dataMap.put("xb", RecruitModeUtil.parseBlankToNull(rs.getString("xb"))); + dataMap.put("sjh", RecruitModeUtil.parseBlankToNull(rs.getString("sjhm"))); + dataMap.put("yx", RecruitModeUtil.parseBlankToNull(rs.getString("dzyx"))); + } + + + // 生成登录密码 + String password = generatePassword(); + dataMap.put("mm", password); + + + // 发送短信 + String mobile = Util.null2String(dataMap.get("sjh")); + String messageContent = RecruitModeUtil.getRecruitPropValue("COLLECT_MESSAGE_CONTENT"); + // TODO + if (StringUtils.isBlank(messageContent)) { + //throw new CustomizeRunTimeException("未获取到短信内容,请检查配置"); + } else { + RecruitMessageUtils.sendSMS(mobile, messageContent); + } + // 插入数据 + RecruitRecordSet.insertData(dataMap, "uf_jcl_xxcj"); + int id = RecruitRecordSet.refreshRight(uuid, "uf_jcl_xxcj", formModeId); + + // 更新状态为已发送,反填信息采集ID + rs.executeUpdate("update uf_jcl_rzgl set xxcj = ? ,xxcjid = ? where id = ? ", InfoCollectEnum.HAS_SENT, id, billId); + } + + return null; + } + + @Override + public Map checkLoginInfo(Map param) { + return null; + } + + /** + * 随机八位不重复登录密码，含数字、字母 + * + * @return 登录密码 + */ + private String generatePassword() { + String letters = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"; + String numbers = "0123456789"; + String characters = letters + numbers; + + List randomChars = new ArrayList<>(); + Random random = new Random(); + + // 随机取得一个字母 + randomChars.add(letters.charAt(random.nextInt(letters.length()))); + + // 随机取得一个数字 + randomChars.add(numbers.charAt(random.nextInt(numbers.length()))); + + // 随机取得六个字符（字母或数字） + for (int i = 0; i < 6; i++) { + randomChars.add(characters.charAt(random.nextInt(characters.length()))); + } + + // 打乱字符的顺序 + Collections.shuffle(randomChars); + + // 将字符列表转为字符串 + StringBuilder sb = new StringBuilder(); + for (char c : randomChars) { + sb.append(c); + } + + return sb.toString(); + } +} diff --git a/src/com/engine/recruit/util/RecruitMessageUtils.java b/src/com/engine/recruit/util/RecruitMessageUtils.java index 52f1553..04fa5ab 100644 --- a/src/com/engine/recruit/util/RecruitMessageUtils.java +++ b/src/com/engine/recruit/util/RecruitMessageUtils.java @@ -15,13 +15,20 @@ public class RecruitMessageUtils { String sendTo = Util.null2String(param.get("sendTo")); String emailTitle = Util.null2String(param.get("emailTitle")); String emailContent = Util.null2String(param.get("emailContent")); - //EmailWorkRunnable.threadModeReminder(sendTo, emailTitle, emailContent); - return MessageUtil.sendEmail(sendTo, emailTitle, emailContent); + return SendEmail(sendTo, emailTitle, emailContent); } public static boolean sendSMS(Map param) { String receiver = Util.null2String(param.get("receiver")); String content = Util.null2String(param.get("content")); + return sendSMS(receiver, content); + } + + public static boolean SendEmail(String sendTo, String emailTitle, String emailContent) { + return MessageUtil.sendEmail(sendTo, emailTitle, emailContent); + } + + public static boolean sendSMS(String receiver, String content) { return MessageUtil.sendSMS(receiver, content); } } diff --git a/src/com/engine/recruit/wrapper/InductionManageWrapper.java b/src/com/engine/recruit/wrapper/InductionManageWrapper.java new file mode 100644 index 0000000..efbf7b5 --- /dev/null +++ b/src/com/engine/recruit/wrapper/InductionManageWrapper.java @@ -0,0 +1,32 @@ +package com.engine.recruit.wrapper; + +import com.engine.common.util.ServiceUtil; +import com.engine.core.impl.Service; +import com.engine.recruit.service.InductionManageService; +import com.engine.recruit.service.impl.InductionManageServiceImpl; +import weaver.hrm.User; + +import java.util.Map; + +/** + * @author:dxfeng + * @createTime: 2023/10/23 + * @version: 1.0 + */ +public class InductionManageWrapper extends Service { + private InductionManageService getInductionManageService(User user) { + return ServiceUtil.getService(InductionManageServiceImpl.class, user); + } + + public Map updateInductionManageInfo(Map param) { + return getInductionManageService(user).updateInductionManageInfo(param); + } + + public Map sendCollectInfo(Map param) { + return getInductionManageService(user).sendCollectInfo(param); + } + + public Map checkLoginInfo(Map param) { + return getInductionManageService(user).checkLoginInfo(param); + } +}