From 0ff2e00a417677d15f6d26f28102daea6bb096a8 Mon Sep 17 00:00:00 2001 From: dxfeng Date: Mon, 12 Aug 2024 14:06:06 +0800 Subject: [PATCH] =?UTF-8?q?=E9=9D=A2=E8=AF=95=E3=80=81offer=E6=93=8D?= =?UTF-8?q?=E4=BD=9C=EF=BC=8C=E6=B7=BB=E5=8A=A0=E6=98=AF=E5=90=A6=E9=9C=80?= =?UTF-8?q?=E8=A6=81=E5=8F=8D=E9=A6=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../RecruitMobileModeController.java | 14 ++ .../recruit/enums/RecordOperateEnum.java | 4 +- .../service/RecruitInterviewService.java | 18 ++ .../impl/RecruitInterviewServiceImpl.java | 161 ++++++++++++++++++ .../wrapper/RecruitInterviewWrapper.java | 24 +++ .../BatchAddInterviewResultModeExpand.java | 17 +- .../interview/CreateInterviewModeExpand.java | 91 ++++++---- .../offer/CreateOfferModeExpand.java | 14 ++ .../modeexpand/util/RecruitModeUtil.java | 86 ++++------ 9 files changed, 345 insertions(+), 84 deletions(-) create mode 100644 src/com/engine/recruit/service/RecruitInterviewService.java create mode 100644 src/com/engine/recruit/service/impl/RecruitInterviewServiceImpl.java create mode 100644 src/com/engine/recruit/wrapper/RecruitInterviewWrapper.java diff --git a/src/com/engine/recruit/controller/RecruitMobileModeController.java b/src/com/engine/recruit/controller/RecruitMobileModeController.java index f532c8b..4945bdf 100644 --- a/src/com/engine/recruit/controller/RecruitMobileModeController.java +++ b/src/com/engine/recruit/controller/RecruitMobileModeController.java @@ -5,6 +5,7 @@ import com.engine.common.util.ServiceUtil; import com.engine.recruit.util.ResponseResult; import com.engine.recruit.wrapper.InductionManageWrapper; import com.engine.recruit.wrapper.OfferWrapper; +import com.engine.recruit.wrapper.RecruitInterviewWrapper; import weaver.hrm.HrmUserVarify; import weaver.hrm.User; @@ -29,6 +30,10 @@ public class RecruitMobileModeController { return ServiceUtil.getService(InductionManageWrapper.class, user); } + public RecruitInterviewWrapper getRecruitInterviewWrapper(User user) { + return ServiceUtil.getService(RecruitInterviewWrapper.class, user); + } + @POST @Path("/getOfferContent") @Produces(MediaType.APPLICATION_JSON) @@ -63,4 +68,13 @@ public class RecruitMobileModeController { User user = HrmUserVarify.getUser(request, response); return new ResponseResult>(user).run(getInductionManageWrapper(user)::infoSubmit, id); } + + @POST + @Path("/updateInterviewStatus") + @Produces(MediaType.APPLICATION_JSON) + public String updateInterviewStatus(@Context HttpServletRequest request, @Context HttpServletResponse response) { + User user = HrmUserVarify.getUser(request, response); + Map param = ParamUtil.request2Map(request); + return new ResponseResult, Map>(user).run(getRecruitInterviewWrapper(user)::updateInterviewStatus, param); + } } diff --git a/src/com/engine/recruit/enums/RecordOperateEnum.java b/src/com/engine/recruit/enums/RecordOperateEnum.java index a71ad2c..7390e08 100644 --- a/src/com/engine/recruit/enums/RecordOperateEnum.java +++ b/src/com/engine/recruit/enums/RecordOperateEnum.java @@ -324,8 +324,8 @@ public enum RecordOperateEnum implements RecordOperateAdapter { xm = rs.getString("xm"); zt = rs.getString("zt"); } - int modeId = ApplicantCommonInfo.getModeIdByTableName("uf_jcl_offer"); - String selectName = ApplicantCommonInfo.getSelectName(String.valueOf(modeId), "zt", zt); + int formId = ApplicantCommonInfo.getFormIdByTableName("uf_jcl_offer"); + String selectName = ApplicantCommonInfo.getSelectName(String.valueOf(formId), "zt", zt); String content = "offer反馈：" + selectName; recordPo.setContent(content); diff --git a/src/com/engine/recruit/service/RecruitInterviewService.java b/src/com/engine/recruit/service/RecruitInterviewService.java new file mode 100644 index 0000000..c54f970 --- /dev/null +++ b/src/com/engine/recruit/service/RecruitInterviewService.java @@ -0,0 +1,18 @@ +package com.engine.recruit.service; + +import java.util.Map; + +/** + * @author:dxfeng + * @createTime: 2023/11/28 + * @version: 1.0 + */ +public interface RecruitInterviewService { + /** + * 更新面试状态 + * + * @param param + * @return + */ + Map updateInterviewStatus(Map param); +} diff --git a/src/com/engine/recruit/service/impl/RecruitInterviewServiceImpl.java b/src/com/engine/recruit/service/impl/RecruitInterviewServiceImpl.java new file mode 100644 index 0000000..9305b31 --- /dev/null +++ b/src/com/engine/recruit/service/impl/RecruitInterviewServiceImpl.java @@ -0,0 +1,161 @@ +package com.engine.recruit.service.impl; + +import com.engine.core.impl.Service; +import com.engine.recruit.conn.RecruitRecordSet; +import com.engine.recruit.entity.record.ApplicantRecordPo; +import com.engine.recruit.enums.RecordOperateEnum; +import com.engine.recruit.service.RecruitInterviewService; +import com.weaver.formmodel.data.model.Formfield; +import org.apache.commons.lang3.StringUtils; +import weaver.common.DateUtil; +import weaver.conn.RecordSet; +import weaver.formmode.recruit.modeexpand.util.RecruitModeUtil; +import weaver.general.Util; + +import java.util.*; +import java.util.stream.Collectors; + +/** + * @author:dxfeng + * @createTime: 2023/11/28 + * @version: 1.0 + */ +public class RecruitInterviewServiceImpl extends Service implements RecruitInterviewService { + @Override + public Map updateInterviewStatus(Map param) { + Map returnMap = new HashMap<>(3); + String status = Util.null2String(param.get("status")); + String uuid = Util.null2String(param.get("uuid")); + String type = Util.null2String(param.get("type")); + if ("offer".equals(type)) { + return updateOfferStatus(status, uuid); + } + returnMap.put("type", "error"); + returnMap.put("message", "反馈失败"); + + if (StringUtils.isBlank(status) || StringUtils.isBlank(uuid)) { + returnMap.put("description", "反馈失败，请直接点击邮件/短信中的链接地址访问，请勿修改链接内容。"); + return returnMap; + } + + RecordSet rs = new RecordSet(); + rs.executeQuery("select * from uf_jcl_ms where modeuuid = ? ", uuid); + Map mainDataMap = RecruitRecordSet.getSingleRecordMap(rs); + String sfcj = ""; + if (!mainDataMap.isEmpty()) { + sfcj = Util.null2String(mainDataMap.get("sfcj")); + } else { + returnMap.put("description", "反馈失败，面试信息有误，请联系相应HR确认"); + return returnMap; + } + + + if (StringUtils.isNotBlank(sfcj)) { + returnMap.put("description", "您已成功反馈面试，请勿重复反馈。"); + return returnMap; + } + + List fieldList = RecruitModeUtil.getFieldList("uf_jcl_ms"); + Map fieldMap = fieldList.stream().collect(Collectors.toMap(Formfield::getFieldname, item -> item, (k1, k2) -> k1)); + String interviewMessageType = RecruitModeUtil.getRecruitPropValue("INTERVIEW_MESSAGE_TYPE"); + // 参加 + if ("0".equals(status)) { + returnMap.put("type", "success"); + returnMap.put("message", "已确认参加面试"); + returnMap.put("description", "您已接受面试，感谢您的应聘，请按期准备面试，如有问题可以联系相应HR"); + + rs.executeUpdate("update uf_jcl_ms set sfcj = ? , zt = 0 where modeuuid = ? ", 0, uuid); + + + String msgContent = "应聘者：$ypz$，确认参加面试，请知悉。
" + + "面试时间：$msrq$；面试官：$msg$"; + msgContent = RecruitModeUtil.getMsgReplaceStr(msgContent, fieldMap, mainDataMap); + Set userIdSet = new HashSet<>(); + userIdSet.add(Util.null2String(mainDataMap.get("modedatacreater"))); + RecruitModeUtil.messagePush(interviewMessageType, "面试反馈通知", msgContent, userIdSet, 1); + } else if ("1".equals(status)) { + returnMap.put("type", "info"); + returnMap.put("message", "已取消参加面试"); + returnMap.put("description", "您已取消参加面试，感谢您的应聘。希望您能够找到真正适合自己的工作。"); + + rs.executeUpdate("update uf_jcl_ms set sfcj = ? , qxyy = 2 , zt = 4 where modeuuid = ? ", 1, uuid); + + + String msgContent = "应聘者：$ypz$，反馈不参加面试，面试已取消，请知悉。
" + + "面试时间：$msrq$；面试官：$msg$"; + msgContent = RecruitModeUtil.getMsgReplaceStr(msgContent, fieldMap, mainDataMap); + String msg = Util.null2String(mainDataMap.get("msg")); + Set userIdSet = new HashSet<>(); + userIdSet.add(Util.null2String(mainDataMap.get("modedatacreater"))); + userIdSet.addAll(Arrays.asList(msg.split(","))); + RecruitModeUtil.messagePush(interviewMessageType, "面试反馈通知", msgContent, userIdSet, 1); + } + + return returnMap; + } + + public Map updateOfferStatus(String status, String uuid) { + Map returnMap = new HashMap<>(3); + returnMap.put("type", "error"); + returnMap.put("message", "反馈失败"); + + if (StringUtils.isBlank(status) || StringUtils.isBlank(uuid)) { + returnMap.put("description", "反馈失败，请直接点击邮件/短信中的链接地址访问，请勿修改链接内容。"); + return returnMap; + } + + RecordSet rs = new RecordSet(); + rs.executeQuery("select * from uf_jcl_offer where modeuuid = ? ", uuid); + Map mainDataMap = RecruitRecordSet.getSingleRecordMap(rs); + String sxrq = ""; + String zt = ""; + String billId = ""; + if (!mainDataMap.isEmpty()) { + sxrq = Util.null2String(mainDataMap.get("sxrq")); + zt = Util.null2String(mainDataMap.get("zt")); + billId = Util.null2String(mainDataMap.get("billId")); + } else { + returnMap.put("description", "反馈失败，offer信息有误，请联系相应HR确认"); + return returnMap; + } + + // 判断当前offer是否失效 + String currentDate = DateUtil.getCurrentDate(); + int compDate = DateUtil.compDate(currentDate, sxrq); + // 当前日期>失效日期，更新状态为逾期未回复 + if (compDate < 0) { + returnMap.put("description", "offer已失效"); + return returnMap; + } + + if ("2".equals(zt) || "3".equals(zt)) { + returnMap.put("description", "此反馈已提交，请勿重复提交"); + return returnMap; + } + + // 参加 + if ("0".equals(status)) { + returnMap.put("type", "success"); + returnMap.put("message", "已确认接受offer"); + returnMap.put("description", "您已接受offer，感谢您的应聘，如有问题可以联系相应HR"); + + rs.executeUpdate("update uf_jcl_offer set fksj = ? , zt = 3 where modeuuid = ? ", DateUtil.getDateTime(), uuid); + } else if ("1".equals(status)) { + returnMap.put("type", "info"); + returnMap.put("message", "已确认拒绝offer"); + returnMap.put("description", "您已拒绝offer，感谢您的应聘。希望您能够找到真正适合自己的工作。"); + // 更新反馈状态、反馈时间 + rs.executeUpdate("update uf_jcl_offer set fksj = ? , zt = 2 where modeuuid = ? ", DateUtil.getDateTime(), uuid); + } + // 记录应聘过程 + ApplicantRecordPo recordPo = ApplicantRecordPo.builder() + .billId(String.valueOf(billId)) + .operateTime(DateUtil.getDateTime()) + .user(user) + .recordOperateType(RecordOperateEnum.OFFER_FEEDBACK) + .build(); + recordPo.execute(); + + return returnMap; + } +} diff --git a/src/com/engine/recruit/wrapper/RecruitInterviewWrapper.java b/src/com/engine/recruit/wrapper/RecruitInterviewWrapper.java new file mode 100644 index 0000000..b42cd18 --- /dev/null +++ b/src/com/engine/recruit/wrapper/RecruitInterviewWrapper.java @@ -0,0 +1,24 @@ +package com.engine.recruit.wrapper; + +import com.engine.common.util.ServiceUtil; +import com.engine.core.impl.Service; +import com.engine.recruit.service.RecruitInterviewService; +import com.engine.recruit.service.impl.RecruitInterviewServiceImpl; +import weaver.hrm.User; + +import java.util.Map; + +/** + * @author:dxfeng + * @createTime: 2023/11/28 + * @version: 1.0 + */ +public class RecruitInterviewWrapper extends Service { + private RecruitInterviewService getRecruitInterviewService(User user) { + return ServiceUtil.getService(RecruitInterviewServiceImpl.class, user); + } + + public Map updateInterviewStatus(Map param) { + return getRecruitInterviewService(user).updateInterviewStatus(param); + } +} diff --git a/src/weaver/formmode/recruit/modeexpand/interview/BatchAddInterviewResultModeExpand.java b/src/weaver/formmode/recruit/modeexpand/interview/BatchAddInterviewResultModeExpand.java index 2b11529..c7caf2b 100644 --- a/src/weaver/formmode/recruit/modeexpand/interview/BatchAddInterviewResultModeExpand.java +++ b/src/weaver/formmode/recruit/modeexpand/interview/BatchAddInterviewResultModeExpand.java @@ -40,12 +40,14 @@ public class BatchAddInterviewResultModeExpand extends AbstractModeExpandJavaCod private final String title; private final String infoCollectUrl; + private final String INTERVIEW_FEEDBACK_URL; public BatchAddInterviewResultModeExpand() { super(); messageType = RecruitModeUtil.getRecruitPropValue("INTERVIEW_MESSAGE_TYPE"); title = RecruitModeUtil.getRecruitPropValue("INTERVIEW_ADD_MESSAGE_TITLE"); infoCollectUrl = RecruitModeUtil.getRecruitPropValue("INTERVIEW_INFO_COLLECT_URL"); + INTERVIEW_FEEDBACK_URL = RecruitModeUtil.getRecruitPropValue("INTERVIEW_FEEDBACK_URL"); } @Override @@ -62,6 +64,10 @@ public class BatchAddInterviewResultModeExpand extends AbstractModeExpandJavaCod for (Property property : properties) { mainDataMap.put(property.getName(), RecruitModeUtil.parseBlankToNull(property.getValue())); } + + // 需要应聘者反馈 + boolean needFeedback = "1".equals(Util.null2String(mainDataMap.get("sfxyfk"))); + User user = (User) param.get("user"); // 填充建模数据基本信息 mainDataMap.put("formmodeid", formModeId); @@ -123,15 +129,20 @@ public class BatchAddInterviewResultModeExpand extends AbstractModeExpandJavaCod String yx = Util.null2String(detailDataMap.get("dzyx")); String sjh = Util.null2String(detailDataMap.get("sjhm")); if (sendEmail) { + String emailContent = msgContent; boolean needCollectInfo = "1".equals(Util.null2String(mainDataMap.get("sfsjxx"))); if (needCollectInfo) { Object ypz = detailDataMap.get("ypz"); String collectUrl = infoCollectUrl + "?interviewId=" + bid + "&candidateId=" + ypz + "&"; String collectLink = "{应聘登记表}"; - msgContent = msgContent.replace("{应聘登记表}", collectLink); + emailContent = emailContent.replace("{应聘登记表}", collectLink); } - RecruitMessageUtils.sendEmail(yx, emailTitle, msgContent); - + if (needFeedback) { + String confirmUrl = INTERVIEW_FEEDBACK_URL + "?type=interview&uuid=" + uuid; + emailContent += "
请您答复是否参加此次邀请？ 参加 不参加
"; + // 邮件内容拼接确认信息 + } + RecruitMessageUtils.sendEmail(yx, emailTitle, emailContent); } if (sendSms) { RecruitMessageUtils.sendSMS(sjh, msgContent); diff --git a/src/weaver/formmode/recruit/modeexpand/interview/CreateInterviewModeExpand.java b/src/weaver/formmode/recruit/modeexpand/interview/CreateInterviewModeExpand.java index 036242a..12e03dd 100644 --- a/src/weaver/formmode/recruit/modeexpand/interview/CreateInterviewModeExpand.java +++ b/src/weaver/formmode/recruit/modeexpand/interview/CreateInterviewModeExpand.java @@ -5,6 +5,7 @@ import com.engine.recruit.enums.InterviewOperateTypeEnum; import com.engine.recruit.util.RecruitMessageUtils; import com.weaver.formmodel.data.model.Formfield; import org.apache.commons.lang3.StringUtils; +import weaver.conn.RecordSet; import weaver.formmode.customjavacode.AbstractModeExpandJavaCodeNew; import weaver.formmode.recruit.modeexpand.util.RecruitModeUtil; import weaver.general.BaseBean; @@ -39,6 +40,8 @@ public class CreateInterviewModeExpand extends AbstractModeExpandJavaCodeNew { private String infoCollectUrl; + private String interviewFeedbackUrl; + @Override public Map doModeExpand(Map params) { Map result = new HashMap<>(); @@ -69,37 +72,15 @@ public class CreateInterviewModeExpand extends AbstractModeExpandJavaCodeNew { messageType = RecruitModeUtil.getRecruitPropValue("INTERVIEW_MESSAGE_TYPE"); title = RecruitModeUtil.getRecruitPropValue("INTERVIEW_ADD_MESSAGE_TITLE"); infoCollectUrl = RecruitModeUtil.getRecruitPropValue("INTERVIEW_INFO_COLLECT_URL"); + interviewFeedbackUrl = RecruitModeUtil.getRecruitPropValue("INTERVIEW_FEEDBACK_URL"); + // 消息提醒 arrangeInterview(user, mainDataMap); - String tzypz = Util.null2String(mainDataMap.get("tzypz")); - String yjnr = Util.null2String(mainDataMap.get("yjnr")); - String yjtzmb = Util.null2String(mainDataMap.get("yjtzmb")); - List sendTypeList = Arrays.asList(tzypz.split(",")); - boolean sendEmail = sendTypeList.contains("0"); - boolean sendSms = sendTypeList.contains("1"); - String emailTitle = RecruitModeUtil.getEmailTitle(yjtzmb); - - List fieldList = RecruitModeUtil.getFieldList("uf_jcl_ms"); - Map> fieldMapList = fieldList.stream().collect(Collectors.groupingBy(Formfield::getLabelName)); - // 发送邮件 - String msgContent = RecruitModeUtil.getReplaceContent(yjnr, fieldMapList, mainDataMap); - String yx = Util.null2String(mainDataMap.get("dzyx")); - String sjh = Util.null2String(mainDataMap.get("sjhm")); - if (sendEmail) { - boolean needCollectInfo = "1".equals(Util.null2String(mainDataMap.get("sfsjxx"))); - if(needCollectInfo) { - Object ypz = mainDataMap.get("ypz"); - String collectUrl = infoCollectUrl + "?interviewId=" + billId + "&candidateId=" + ypz + "&"; - String collectLink = "{应聘登记表}"; - msgContent = msgContent.replace("{应聘登记表}", collectLink); - } - RecruitMessageUtils.sendEmail(yx, emailTitle, msgContent); - - } - if (sendSms) { - RecruitMessageUtils.sendSMS(sjh, msgContent); - } + // 需要应聘者反馈 + boolean needFeedback = "1".equals(Util.null2String(mainDataMap.get("sfxyfk"))); + boolean needCollectInfo = "1".equals(Util.null2String(mainDataMap.get("sfsjxx"))); + // 发送邮件、短信 + sendEmailAndMsg(mainDataMap, billId, needFeedback, needCollectInfo); } - } } } catch (Exception e) { @@ -141,4 +122,56 @@ public class CreateInterviewModeExpand extends AbstractModeExpandJavaCodeNew { RecruitModeUtil.messagePush(messageType, title, msgBuilder.toString(), userIdSet, user.getUID()); } + + private void sendEmailAndMsg(Map mainDataMap, int billId, boolean needFeedback, boolean needCollectInfo) { + String tzypz = Util.null2String(mainDataMap.get("tzypz")); + String yjnr = Util.null2String(mainDataMap.get("yjnr")); + String yjtzmb = Util.null2String(mainDataMap.get("yjtzmb")); + List sendTypeList = Arrays.asList(tzypz.split(",")); + boolean sendEmail = sendTypeList.contains("0"); + boolean sendSms = sendTypeList.contains("1"); + String emailTitle = RecruitModeUtil.getEmailTitle(yjtzmb); + + List fieldList = RecruitModeUtil.getFieldList("uf_jcl_ms"); + Map> fieldMapList = fieldList.stream().collect(Collectors.groupingBy(Formfield::getLabelName)); + // 发送邮件 + String msgContent = RecruitModeUtil.getReplaceContent(yjnr, fieldMapList, mainDataMap); + String yx = Util.null2String(mainDataMap.get("dzyx")); + String sjh = Util.null2String(mainDataMap.get("sjhm")); + RecordSet rs = new RecordSet(); + rs.executeQuery("select modeuuid from uf_jcl_ms where id = ? ", billId); + String uuid = ""; + if (rs.next()) { + uuid = rs.getString("modeuuid"); + } + String confirmUrl = interviewFeedbackUrl + "?type=interview&uuid=" + uuid; + + if (needCollectInfo) { + Object ypz = mainDataMap.get("ypz"); + String collectUrl = infoCollectUrl + "?interviewId=" + billId + "&candidateId=" + ypz + "&"; + String collectLink = "{应聘登记表}"; + msgContent = msgContent.replace("{应聘登记表}", collectLink); + } + if (sendEmail) { + if (needFeedback) { + String emailContent = "
请您答复是否参加此次邀请？ 参加 不参加
"; + // 邮件内容拼接确认信息 + emailContent = msgContent + emailContent; + RecruitMessageUtils.sendEmail(yx, emailTitle, emailContent); + // 勾选了需要反馈，则需要将是否参加置空，且需要可以再次反馈 + rs.executeUpdate("update uf_jcl_ms set sfcj = null,zt = null where id = ? ", billId); + } else { + RecruitMessageUtils.sendEmail(yx, emailTitle, msgContent); + } + } + if (sendSms) { + if (needFeedback) { + String messageContent = "请您答复是否参加此次邀请？" + confirmUrl; + messageContent = msgContent + messageContent; + RecruitMessageUtils.sendSMS(sjh, messageContent); + } else { + RecruitMessageUtils.sendSMS(sjh, msgContent); + } + } + } } diff --git a/src/weaver/formmode/recruit/modeexpand/offer/CreateOfferModeExpand.java b/src/weaver/formmode/recruit/modeexpand/offer/CreateOfferModeExpand.java index 9e9c826..fe53e82 100644 --- a/src/weaver/formmode/recruit/modeexpand/offer/CreateOfferModeExpand.java +++ b/src/weaver/formmode/recruit/modeexpand/offer/CreateOfferModeExpand.java @@ -68,6 +68,20 @@ public class CreateOfferModeExpand extends AbstractModeExpandJavaCodeNew { if (sendEmail) { String offerAttach = RecruitModeUtil.getImageFileIdsByDocIds(Util.null2String(mainDataMap.get("offerfj"))); + boolean needFeedback = "1".equals(Util.null2String(mainDataMap.get("sfxyfk"))); + if(needFeedback){ + String uuid = ""; + RecordSet rs = new RecordSet(); + rs.executeQuery("select modeuuid from uf_jcl_offer where id = ? ", billId); + if (rs.next()) { + uuid = rs.getString("modeuuid"); + } + String confirmUrl = RecruitModeUtil.getRecruitPropValue("INTERVIEW_FEEDBACK_URL") + "?type=offer&uuid=" + uuid; + String emailContent = "
请您答复是否接接受此offer？ 接受 拒绝
"; + // 邮件内容拼接确认信息 + msgContent = msgContent + emailContent; + } + RecruitMessageUtils.sendEmailWithFile(yx, emailTitle, msgContent, offerAttach); } if (sendSms) { diff --git a/src/weaver/formmode/recruit/modeexpand/util/RecruitModeUtil.java b/src/weaver/formmode/recruit/modeexpand/util/RecruitModeUtil.java index 7ad715d..791e41b 100644 --- a/src/weaver/formmode/recruit/modeexpand/util/RecruitModeUtil.java +++ b/src/weaver/formmode/recruit/modeexpand/util/RecruitModeUtil.java @@ -28,7 +28,6 @@ import java.nio.charset.StandardCharsets; import java.util.*; import java.util.regex.Matcher; import java.util.regex.Pattern; -import java.util.stream.Collectors; /** * @author:dxfeng @@ -36,7 +35,15 @@ import java.util.stream.Collectors; * @version: 1.0 */ public class RecruitModeUtil { - private static final Pattern MSG_PATTERN = Pattern.compile(Pattern.quote("{") + "(.*?)" + Pattern.quote("}")); + /** + * 邮件、短信发送，替换内容正则表达式 + */ + private static final Pattern EMAIL_PATTERN = Pattern.compile(Pattern.quote("{") + "(.*?)" + Pattern.quote("}")); + /** + * 消息中心，替换内容正则表达式 + */ + private static final Pattern MSG_PATTERN = Pattern.compile(Pattern.quote("$") + "(.*?)" + Pattern.quote("$")); + /** * 消息推送 @@ -146,13 +153,13 @@ public class RecruitModeUtil { return FormInfoManager.getInstance().getAllField(formId); } - public static String getFieldShowName(Formfield formfield, String fieldName) { + public static String getFieldShowName(Formfield formfield, String fieldValue) { User user = new User(1); - return FieldHandler.getFieldValue(fieldName, formfield, true, user); + return FieldHandler.getFieldValue(fieldValue, formfield, true, user); } public static String getReplaceContent(String content, Map> fieldMapList, Map paramsData) { - Matcher matcher = MSG_PATTERN.matcher(content); + Matcher matcher = EMAIL_PATTERN.matcher(content); // 指定要匹配的字符串 StringBuffer sb = new StringBuffer(); while (matcher.find()) { @@ -172,6 +179,30 @@ public class RecruitModeUtil { return sb.toString(); } + /** + * 消息中心，替换消息内容 + * + * @param content + * @param fieldMap + * @param paramsData + * @return + */ + public static String getMsgReplaceStr(String content, Map fieldMap, Map paramsData) { + Matcher matcher = MSG_PATTERN.matcher(content); + // 指定要匹配的字符串 + StringBuffer sb = new StringBuffer(); + while (matcher.find()) { + String replace = matcher.group(1); + + Formfield formfield = fieldMap.get(replace); + String replaceValue = Util.null2String(paramsData.get(formfield.getFieldname().toLowerCase())); + String fieldShowName = RecruitModeUtil.getFieldShowName(formfield, replaceValue).replaceAll("<[^>]*>", ""); + matcher.appendReplacement(sb, Util.null2String(fieldShowName)); + } + matcher.appendTail(sb); + return sb.toString(); + } + /** * 附件imageFieldId生成docId * @@ -266,51 +297,6 @@ public class RecruitModeUtil { return StringUtils.join(imageFileIds, ","); } - - /** - * @Author ml - * @Date 2023/10/23 18:21 - * @Description 根据建模表名称获取列名称 - * @Param [tableName] - * @Return Map>> - */ - public static Map getModeColumns(String tableName) { - RecordSet rs = new RecordSet(); - List> mapList = new ArrayList<>(); - Map tmpMap = new HashMap<>(16); - rs.executeQuery("select b.FIELDNAME,b.VIEWTYPE from workflow_bill a left join workflow_billfield b on a.id = b.BILLID where a.TABLENAME = ?", tableName); - while (rs.next()) { - tmpMap.put("fieldname", rs.getString("FIELDNAME")); - tmpMap.put("viewtype", rs.getString("VIEWTYPE")); - mapList.add(tmpMap); - } - Map>> dataMap = mapList.stream().collect(Collectors.groupingBy(item -> item.get("viewtype"))); - Map resMap = new HashMap<>(); - for (String key : dataMap.keySet()) { - resMap.put(key, dataMap.get(key).stream().map(Map -> Map.get("fieldname")).collect(Collectors.toList())); - } - return resMap; - } - - - public static String getQuerySql(String tableName) { - Map params = getModeColumns(tableName); - String fieldSql = ""; - StringBuilder whereSql = new StringBuilder(); - whereSql.append(tableName).append(" t0"); - for (String key : params.keySet()) { - List oldlist = (List) params.get(key); - List list = new ArrayList<>(); - oldlist.forEach(field -> list.add("t" + key + "." + field)); - fieldSql = StringUtils.join(list, ","); - if ("0".equals(key)) { - continue; - } - whereSql.append(" left join ").append(tableName).append("_dt").append(key).append(" ").append("t").append(key).append(" on t0.id=").append("t").append(key).append(".mainid"); - } - return "select " + fieldSql + " from " + whereSql + " where t0.id=?"; - } - /** * 获取邮件模板主题 *