From 540dbf34218f9c3983af8e8762d22d243ed3a43b Mon Sep 17 00:00:00 2001 From: dxfeng Date: Mon, 18 Sep 2023 10:36:38 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8B=9B=E8=81=98=E9=9C=80=E6=B1=82=E6=B5=81?= =?UTF-8?q?=E7=A8=8B=E8=BD=AC=E5=BB=BA=E6=A8=A1-=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E6=8F=90=E9=86=92?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../action/RecruitFlowToModeAction.java | 173 +++++++++++++++++- 1 file changed, 169 insertions(+), 4 deletions(-) diff --git a/src/weaver/interfaces/recruit/action/RecruitFlowToModeAction.java b/src/weaver/interfaces/recruit/action/RecruitFlowToModeAction.java index bd36531..800ce29 100644 --- a/src/weaver/interfaces/recruit/action/RecruitFlowToModeAction.java +++ b/src/weaver/interfaces/recruit/action/RecruitFlowToModeAction.java @@ -1,5 +1,8 @@ package weaver.interfaces.recruit.action; +import com.cloudstore.dev.api.bean.MessageBean; +import com.cloudstore.dev.api.bean.MessageType; +import com.cloudstore.dev.api.util.Util_Message; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; import weaver.common.DateUtil; @@ -8,9 +11,11 @@ import weaver.conn.RecordSetTrans; import weaver.formmode.setup.ModeRightInfo; import weaver.general.BaseBean; import weaver.general.Util; +import weaver.hrm.resource.ResourceComInfo; import weaver.interfaces.workflow.action.Action; import weaver.soa.workflow.request.*; +import java.io.IOException; import java.util.*; /** @@ -22,6 +27,14 @@ import java.util.*; */ public class RecruitFlowToModeAction implements Action { + private static String messageType; + + private static String title; + + private static String linkUrl; + + private static String linkMobileUrl; + /** * 建模台账表表名(uf_jcl_zp_zpxq) */ @@ -30,6 +43,8 @@ public class RecruitFlowToModeAction implements Action { @Override public String execute(RequestInfo requestInfo) { MainTableInfo mainTableInfo = requestInfo.getMainTableInfo(); + int billId = requestInfo.getRequestManager().getBillid(); + int formid = requestInfo.getRequestManager().getFormid(); DetailTableInfo detailTableInfo = requestInfo.getDetailTableInfo(); DetailTable detailTable = detailTableInfo.getDetailTable(0); @@ -59,6 +74,11 @@ public class RecruitFlowToModeAction implements Action { mainMap.put("modedatamodifydatetime", dateTime); mainMap.put("modedatacreatertype", "0"); + Map messageMap = new HashMap<>(); + messageMap.put("billId", String.valueOf(billId)); + messageMap.put("formId", String.valueOf(formid)); + messageMap.put("modeId", String.valueOf(formModeId)); + List> insertList = new ArrayList<>(); Row[] rows = detailTable.getRow(); for (Row row : rows) { @@ -79,14 +99,32 @@ public class RecruitFlowToModeAction implements Action { String sql = " insert into " + MODE_TABLE_NAME + "(modeuuid,modedatacreatertype,formmodeid,modedatacreater,modedatacreatedate,modedatacreatetime,modedatamodifier,modedatamodifydatetime,xqsplc,xqzt,sqr,sqsj,sqbm,nd,spfs,xqlx,bz,xqmc,zpyy,zpxqfzr,szfb,szbm,gw,gwzz,rzyq,zwxz,gzdd,gznx,zdxlyq,zprs,qwdgsj)" + " values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"; try { - List> paramList = new ArrayList<>(); - // 构建插入参数集合 - buildParamList(insertList, paramList); - for (List objects : paramList) { + + for (Map map : insertList) { + List objects = buildParamList(map); String uuid = UUID.randomUUID().toString(); objects.add(0, uuid); rst.executeUpdate(sql, objects); refreshRight(rst, uuid, formModeId); + + // 申请人ID + String applicant = Util.null2String(map.get("sqr")); + // 申请人名称 + String applicantName = new ResourceComInfo().getLastname(applicant); + // 需求名称 + String requirementName = Util.null2String(map.get("xqmc")); + // 招聘需求负责人ID + String manager = Util.null2String(map.get("zpxqfzr")); + // 申请人集合 + Set applicantSet = new HashSet<>(); + applicantSet.add(applicant); + // 需求负责人集合 + Set managerSet = new HashSet<>(); + managerSet.add(manager); + + // 消息提醒 + messagePush(applicantName + "，你申请的“" + requirementName + "”招聘需求，正在进行中，请知悉。", messageMap, applicantSet); + messagePush("您有一个新的”" + requirementName + "“招聘需求，请查收。", messageMap, managerSet); } rst.commit(); } catch (Exception e) { @@ -168,6 +206,65 @@ public class RecruitFlowToModeAction implements Action { } } + private List buildParamList(Map map) { + List param = new ArrayList<>(); + // 填充建模表相关字段 + param.add(map.get("modedatacreatertype")); + param.add(map.get("formmodeid")); + param.add(map.get("modedatacreater")); + param.add(map.get("modedatacreatedate")); + param.add(map.get("modedatacreatetime")); + param.add(map.get("modedatamodifier")); + param.add(map.get("modedatamodifydatetime")); + // 需求审批流程 + param.add(map.get("xqsplc")); + // 需求状态 + param.add(map.get("xqzt")); + // 申请人 + param.add(map.get("sqr")); + // 申请时间 + param.add(map.get("sqsj")); + // 申请部门 + param.add(map.get("sqbm")); + // 年度 + param.add(map.get("nd")); + // 审批方式 + param.add(map.get("spfs")); + // 需求类型 + param.add(map.get("xqlx")); + // 备注 + param.add(map.get("bz")); + // 需求名称 + param.add(map.get("xqmc")); + // 招聘原因 + param.add(map.get("zpyy")); + // 招聘需求负责人 + param.add(map.get("zpxqfzr")); + // 所属分部 + param.add(map.get("szfb")); + // 所属部门 + param.add(map.get("szbm")); + // 岗位 + param.add(map.get("gw")); + // 岗位职责 + param.add(map.get("gwzz")); + // 任职要求 + param.add(map.get("rzyq")); + // 职位性质 + param.add(map.get("zwxz")); + // 工作地点 + param.add(map.get("gzdd")); + // 工作年限 + param.add(map.get("gznx")); + // 最低学历要求 + param.add(map.get("zdxlyq")); + // 招聘人数 + param.add(map.get("zprs")); + // 期望到岗时间 + param.add(map.get("qwdgsj")); + return param; + } + /** * 将空字符串转化为NULL * @@ -197,4 +294,72 @@ public class RecruitFlowToModeAction implements Action { modeRightInfo.editModeDataShare(1, formModeId, bid); } } + + /** + * 消息推送 + * + * @param context 消息内容 + * @param messageMap 消息 相关key + * @param userIdList 消息接收人ID集合 + */ + private static void messagePush(String context, Map messageMap, Set userIdList) { + + // 替换context内容信息; + + // 替换URL内容信息 + linkUrl = replaceUrlKeys(linkUrl, messageMap); + linkMobileUrl = replaceUrlKeys(linkMobileUrl, messageMap); + + MessageType message = MessageType.newInstance(Integer.parseInt(messageType)); + try { + MessageBean messageBean = Util_Message.createMessage(message, userIdList, title, context, linkUrl, linkMobileUrl); + messageBean.setCreater(1); + //message.setBizState("0");// 需要修改消息为已处理等状态时传入,表示消息最初状态为待处理 + Util_Message.store(messageBean); + } catch (IOException e) { + e.printStackTrace(); + } + } + + /** + * 替换url的相关key + * + * @param url 链接地址 + * @param messageMap key集合 + */ + private static String replaceUrlKeys(String url, Map messageMap) { + return url.replace("$modeId$", messageMap.get("modeId")).replace("$formId$", messageMap.get("formId")).replace("$billid$", messageMap.get("billId")); + } + + public static String getMessageType() { + return messageType; + } + + public static void setMessageType(String messageType) { + RecruitFlowToModeAction.messageType = messageType; + } + + public static String getTitle() { + return title; + } + + public static void setTitle(String title) { + RecruitFlowToModeAction.title = title; + } + + public static String getLinkUrl() { + return linkUrl; + } + + public static void setLinkUrl(String linkUrl) { + RecruitFlowToModeAction.linkUrl = linkUrl; + } + + public static String getLinkMobileUrl() { + return linkMobileUrl; + } + + public static void setLinkMobileUrl(String linkMobileUrl) { + RecruitFlowToModeAction.linkMobileUrl = linkMobileUrl; + } }