package com.kingdee.eas.custom.integration.weaveroa.utils; import com.kingdee.bos.BOSException; import com.kingdee.bos.Context; import com.kingdee.bos.dao.ormapping.ObjectUuidPK; import com.kingdee.bos.dao.ormapping.SQLAccessException; import com.kingdee.bos.metadata.entity.*; import com.kingdee.bos.util.BOSObjectType; import com.kingdee.bos.util.BOSUuid; import com.kingdee.eas.base.message.AssignReadFactory; import com.kingdee.eas.base.message.AssignReadInfo; import com.kingdee.eas.base.message.IAssignRead; import com.kingdee.eas.base.message.MsgStatus; import com.kingdee.eas.base.message.webservice.WSMessage; import com.kingdee.eas.base.message.webservice.WfrAssignMessage; import com.kingdee.eas.base.message.webservice.WfrProcMessage; import com.kingdee.eas.base.permission.IUser; import com.kingdee.eas.base.permission.UserFactory; import com.kingdee.eas.base.permission.UserInfo; import com.kingdee.eas.basedata.org.HROrgUnitInfo; import com.kingdee.eas.common.EASBizException; import com.kingdee.eas.custom.integration.base.util.EncryptUtil; import com.kingdee.eas.custom.integration.base.util.SHRApiUtils; import com.kingdee.eas.custom.integration.weaveroa.*; import com.kingdee.eas.custom.integration.weaveroa.bizEnum.InstanceStatusEnum; import com.kingdee.eas.custom.integration.weaveroa.bizEnum.IsRemarkEnum; import com.kingdee.eas.custom.integration.weaveroa.bizEnum.ViewTypeEnum; import com.kingdee.eas.hr.base.AbstractHRBillBaseInfo; import com.kingdee.eas.hr.base.HRBillStateEnum; import com.kingdee.shr.base.syssetting.util.BaseMetaDataUtil; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.util.UriComponentsBuilder; import java.io.UnsupportedEncodingException; import java.net.URLEncoder; import java.nio.charset.StandardCharsets; import java.sql.Time; /** * @Description 泛微OA消息工具类 * @Date 2026/3/10 16:08 * @Created by HeYuan */ public class WeaverOAMessageUtils { private static Logger logger = LoggerFactory.getLogger(WeaverOAMessageUtils.class); //HR组织 private static final HROrgUnitInfo HRORGUNITINFO = new HROrgUnitInfo(); static { HRORGUNITINFO.setId(BOSUuid.read("00000000-0000-0000-0000-000000000000CCE7AED4")); } /** * 流程任务完成 * * @param wfrMmessage * @return */ public static boolean completedApproveMessage(WfrProcMessage wfrMmessage) { logger.error("completedApproveMessage 开始"); try { Context ctx = SHRApiUtils.getContext(wfrMmessage.getCtx()); // String billID = wfrMmessage.getBillID(); BOSObjectType bosType = BOSUuid.read(billID).getType(); AbstractHRBillBaseInfo billInfo = (AbstractHRBillBaseInfo) BaseMetaDataUtil.getBizInterface(ctx, bosType).getValue(new ObjectUuidPK(billID)); //单据状态 HRBillStateEnum billState = billInfo.getBillState(); IWeaverOAApprovalInstance iWeaverOAApprovalInstance = WeaverOAApprovalInstanceFactory.getLocalInstance(ctx); FilterInfo filterInfo = new FilterInfo(); filterInfo.getFilterItems().add(new FilterItemInfo("instanceId", wfrMmessage.getProcInstId())); SelectorItemCollection sic = new SelectorItemCollection(); sic.add("*"); sic.add("taskList.*"); EntityViewInfo viewInfo = EntityViewInfo.getInstance(filterInfo, sic, null); WeaverOAApprovalInstanceCollection instanceCollection = iWeaverOAApprovalInstance.getWeaverOAApprovalInstanceCollection(viewInfo); if (!instanceCollection.isEmpty()) { WeaverOAApprovalInstanceInfo instanceInfo = instanceCollection.get(0); if (HRBillStateEnum.AUDITED.equals(billState)) { //审批通过 instanceInfo.setInstanceStatus(InstanceStatusEnum.APPROVED); } else if (HRBillStateEnum.AUDITEND.equals(billState)) { //审批不通过 instanceInfo.setInstanceStatus(InstanceStatusEnum.REJECTED); } WeaverOAApprovalInstanceTaskListCollection taskList = instanceInfo.getTaskList(); for (int i = 0; i < taskList.size(); i++) { WeaverOAApprovalInstanceTaskListInfo instanceTaskListInfo = taskList.get(i); instanceTaskListInfo.setViewtype(ViewTypeEnum.READ); instanceTaskListInfo.setIsremark(IsRemarkEnum.COMPLETED); //流程结束,需要将所有节点更新为归档 instanceTaskListInfo.setNodename("归档"); } //保存 iWeaverOAApprovalInstance.save(instanceInfo); } } catch (Exception e) { e.printStackTrace(); logger.error("流程任务完成 completedApprovMessage 报错: {}", e.getMessage(), e); return false; } return true; } /** * 更新节点消息查看类型 * * @param ctx * @return */ public static boolean updateNodeMessageViewType(String id, MsgStatus msgStatus, Context ctx) { logger.error("updateNodeMessageViewType 开始, id {} , msgStatus {}", id, msgStatus.getAlias()); ctx = SHRApiUtils.getContext(ctx); String bosType = BOSUuid.read(id).getType().toString(); logger.error("updateNodeMessageViewType bosType {}", bosType); if ("9623EB51".equals(bosType)) { try { //任务阅读表 IAssignRead assignReadIns = AssignReadFactory.getLocalInstance(ctx); AssignReadInfo assignReadInfo = assignReadIns.getAssignReadInfo(new ObjectUuidPK(id)); //节点任务id String assignId = assignReadInfo.getAssignID().toString(); IWeaverOAApprovalInstance iWeaverOAApprovalInstance = WeaverOAApprovalInstanceFactory.getLocalInstance(ctx); IWeaverOAApprovalInstanceTaskList iWeaverOAApprovalInstanceTaskList = WeaverOAApprovalInstanceTaskListFactory.getLocalInstance(ctx); FilterInfo filterInfo = new FilterInfo(); filterInfo.getFilterItems().add(new FilterItemInfo("flowid", assignId)); SelectorItemCollection sic = new SelectorItemCollection(); sic.add("*"); sic.add("parent.instanceStatus"); sic.add("parent.id"); EntityViewInfo viewInfo = EntityViewInfo.getInstance(filterInfo, sic, null); //审批实例任务列表 WeaverOAApprovalInstanceTaskListCollection instanceTaskListCol = iWeaverOAApprovalInstanceTaskList.getWeaverOAApprovalInstanceTaskListCollection(viewInfo); if (!instanceTaskListCol.isEmpty()) { WeaverOAApprovalInstanceTaskListInfo instanceTaskListInfo = instanceTaskListCol.get(0); WeaverOAApprovalInstanceInfo parent = instanceTaskListInfo.getParent(); //流程实例状态 if (InstanceStatusEnum.PENDING.equals(parent.getInstanceStatus())) { if (MsgStatus.READED.equals(msgStatus)) { //已读 instanceTaskListInfo.setViewtype(ViewTypeEnum.READ); } else { //未读 instanceTaskListInfo.setViewtype(ViewTypeEnum.UNREAD); } SelectorItemCollection updateSic = new SelectorItemCollection(); updateSic.add("viewtype"); //更新 iWeaverOAApprovalInstanceTaskList.updatePartial(instanceTaskListInfo, updateSic); //触发同步审批实例 iWeaverOAApprovalInstance.syncApprovalInstance(parent.getId().toString()); } } } catch (Exception e) { e.printStackTrace(); logger.error("updateNodeMessageViewType 报错: {}", e.getMessage(), e); return false; } } return true; } /** * 节点任务取消 * * @param wfrMmessage * @return */ public static boolean nodeCanceledApproveMessage(WfrAssignMessage wfrMmessage) { logger.error("nodeCanceledApproveMessage 开始"); try { Context ctx = SHRApiUtils.getContext(wfrMmessage.getCtx()); // //流程任务id String assignId = wfrMmessage.getAssignId(); IWeaverOAApprovalInstance iWeaverOAApprovalInstance = WeaverOAApprovalInstanceFactory.getLocalInstance(ctx); IWeaverOAApprovalInstanceTaskList iWeaverOAApprovalInstanceTaskList = WeaverOAApprovalInstanceTaskListFactory.getLocalInstance(ctx); FilterInfo filterInfo = new FilterInfo(); filterInfo.getFilterItems().add(new FilterItemInfo("flowid", assignId)); SelectorItemCollection sic = new SelectorItemCollection(); sic.add("*"); sic.add("parent.instanceStatus"); sic.add("parent.id"); EntityViewInfo viewInfo = EntityViewInfo.getInstance(filterInfo, sic, null); //审批实例任务列表 WeaverOAApprovalInstanceTaskListCollection instanceTaskListCol = iWeaverOAApprovalInstanceTaskList.getWeaverOAApprovalInstanceTaskListCollection(viewInfo); if (!instanceTaskListCol.isEmpty()) { WeaverOAApprovalInstanceTaskListInfo instanceTaskListInfo = instanceTaskListCol.get(0); WeaverOAApprovalInstanceInfo parent = instanceTaskListInfo.getParent(); //流程实例状态 if (InstanceStatusEnum.PENDING.equals(parent.getInstanceStatus())) { //已办 instanceTaskListInfo.setIsremark(IsRemarkEnum.PROCESSED); //已读 instanceTaskListInfo.setViewtype(ViewTypeEnum.READ); //保存 iWeaverOAApprovalInstanceTaskList.save(instanceTaskListInfo); //触发同步审批实例 iWeaverOAApprovalInstance.syncApprovalInstance(parent.getId().toString()); } } } catch (Exception e) { e.printStackTrace(); logger.error("节点任务转交 nodeCanceledApproveMessage 报错: {}", e.getMessage(), e); return false; } return true; } /** * 节点任务完成 * * @param wfrMmessage * @return */ public static boolean nodeCompletedApproveMessage(WfrAssignMessage wfrMmessage) { logger.error("nodeCompletedApproveMessage 开始"); try { Context ctx = SHRApiUtils.getContext(wfrMmessage.getCtx()); //流程任务id String assignId = wfrMmessage.getAssignId(); IWeaverOAApprovalInstance iWeaverOAApprovalInstance = WeaverOAApprovalInstanceFactory.getLocalInstance(ctx); IWeaverOAApprovalInstanceTaskList iWeaverOAApprovalInstanceTaskList = WeaverOAApprovalInstanceTaskListFactory.getLocalInstance(ctx); FilterInfo filterInfo = new FilterInfo(); filterInfo.getFilterItems().add(new FilterItemInfo("flowid", assignId)); SelectorItemCollection sic = new SelectorItemCollection(); sic.add("*"); sic.add("parent.instanceStatus"); sic.add("parent.id"); EntityViewInfo viewInfo = EntityViewInfo.getInstance(filterInfo, sic, null); //审批实例任务列表 WeaverOAApprovalInstanceTaskListCollection instanceTaskListCol = iWeaverOAApprovalInstanceTaskList.getWeaverOAApprovalInstanceTaskListCollection(viewInfo); if (!instanceTaskListCol.isEmpty()) { WeaverOAApprovalInstanceTaskListInfo instanceTaskListInfo = instanceTaskListCol.get(0); WeaverOAApprovalInstanceInfo parent = instanceTaskListInfo.getParent(); //流程实例状态 if (InstanceStatusEnum.PENDING.equals(parent.getInstanceStatus())) { //已办 instanceTaskListInfo.setIsremark(IsRemarkEnum.PROCESSED); //已读 instanceTaskListInfo.setViewtype(ViewTypeEnum.READ); //保存 iWeaverOAApprovalInstanceTaskList.save(instanceTaskListInfo); //触发同步审批实例 iWeaverOAApprovalInstance.syncApprovalInstance(parent.getId().toString()); } } } catch (Exception e) { e.printStackTrace(); logger.error("节点任务完成 nodeCompletedApprovMessage 报错: {}", e.getMessage(), e); return false; } return true; } /** * 撤销流程 * * @param wfrProcMessage * @return */ public static boolean abortedApproveMessage(WfrProcMessage wfrProcMessage) { logger.error("abortedApproveMessage 开始"); try { Context ctx = SHRApiUtils.getContext(wfrProcMessage.getCtx()); IWeaverOAApprovalInstance iWeaverOAApprovalInstance = WeaverOAApprovalInstanceFactory.getLocalInstance(ctx); //审批实例 FilterInfo filterInfo = new FilterInfo(); filterInfo.getFilterItems().add(new FilterItemInfo("instanceId", wfrProcMessage.getProcInstId())); SelectorItemCollection sic = new SelectorItemCollection(); sic.add("*"); sic.add("taskList.*"); EntityViewInfo viewInfo = EntityViewInfo.getInstance(filterInfo, sic, null); WeaverOAApprovalInstanceCollection instanceCollection = iWeaverOAApprovalInstance.getWeaverOAApprovalInstanceCollection(viewInfo); if (!instanceCollection.isEmpty()) { WeaverOAApprovalInstanceInfo instanceInfo = instanceCollection.get(0); WeaverOAApprovalInstanceTaskListCollection taskList = instanceInfo.getTaskList(); for (int i = 0; i < taskList.size(); i++) { WeaverOAApprovalInstanceTaskListInfo instanceTaskListInfo = taskList.get(i); //流程处理状态 IsRemarkEnum isremark = instanceTaskListInfo.getIsremark(); if (!IsRemarkEnum.COMPLETED.equals(isremark)) { //流程任务处理状态设置为办结 instanceTaskListInfo.setIsremark(IsRemarkEnum.COMPLETED); //流程查看状态 设置为已读 instanceTaskListInfo.setViewtype(ViewTypeEnum.READ); } //流程结束,需要将所有节点更新为归档 instanceTaskListInfo.setNodename("归档"); } //流程状态更新为 审批人撤销 instanceInfo.setInstanceStatus(InstanceStatusEnum.CANCELED); //保存 iWeaverOAApprovalInstance.save(instanceInfo); } } catch (Exception e) { e.printStackTrace(); logger.error("撤销流程 abortedApprovMessage 报错: {}", e.getMessage(), e); return false; } return true; } /** * 发送审批消息 * * @param message * @return */ public static boolean addApproveMessage(WSMessage message) { logger.error("addApproveMessage 开始"); //流程实例id String procInstId = message.getProcInstId(); try { Context ctx = SHRApiUtils.getContext(message.getContext()); //飞书应用默认配置 WeaverOAConfigInfo defaultConfig = WeaverOAUtil.getDefaultConfig(); //接收人账号 String recieveNumber = message.getRecieveNumber(); logger.info("addApproveMessage 账号加密前: {}", recieveNumber); String encryptRecieveNumber = EncryptUtil.encryptStr(recieveNumber); logger.info("addApproveMessage 账号加密后: {}", encryptRecieveNumber); //PC 端的三方审批实例跳转链接。 String pcLink = getPcLink(defaultConfig, message, encryptRecieveNumber); //移动端的三方审批实例跳转链接。 String mobileLink = getMobileLink(defaultConfig, message, encryptRecieveNumber); //发起人 IUser iUser = UserFactory.getLocalInstance(ctx); UserInfo sender = iUser.getUserInfo("where number='" + message.getSenderNumber() + "'"); IWeaverOAApprovalInstance iWeaverOAApprovalInstance = WeaverOAApprovalInstanceFactory.getLocalInstance(ctx); WeaverOAApprovalInstanceCollection instanceCol = getApprovalInstanceCollection(procInstId, iWeaverOAApprovalInstance); WeaverOAApprovalInstanceInfo instanceInfo = null; //标题 String title = message.getTitle().replace("\r", "\\r").replace("\n", "\\n"); if (instanceCol.isEmpty()) { //没有,新增 instanceInfo = new WeaverOAApprovalInstanceInfo(); instanceInfo.setInstanceId(procInstId); instanceInfo.setHrOrgUnit(HRORGUNITINFO); //审批实例状态 instanceInfo.setInstanceStatus(InstanceStatusEnum.PENDING); //标题 instanceInfo.setTitle(title); //发起人 instanceInfo.setSender(sender); //获取单据对象 EntityObjectInfo entityObjectInfo = BaseMetaDataUtil.getEntityObjectInfo(ctx, BOSUuid.read(message.getBillId()).getType()); //单据类型 instanceInfo.setBillType(entityObjectInfo.getDisplayName()); //异构系统标识 instanceInfo.setSyscode(defaultConfig.getSyscode()); try { //保存 iWeaverOAApprovalInstance.save(instanceInfo); } catch (SQLAccessException e) { logger.error("addApproveMessage 保存审批实例报错: {}", e.getMessage(), e); if (!e.getMessage().contains("IX_CT_WEA_WeaverOAAI")) { throw e; } //并发场景下 实例id重复,说明已经存在实例数据. instanceCol = getApprovalInstanceCollection(procInstId, iWeaverOAApprovalInstance); if (instanceCol.isEmpty()) { throw new RuntimeException("并发情况下未能获取审批实例: " + procInstId); } //审批实例 instanceInfo = instanceCol.get(0); } catch (Exception e) { logger.error("addApproveMessage 保存审批实例报错: {}", e.getMessage(), e); throw e; } } else { //审批实例 instanceInfo = instanceCol.get(0); } //当前节点 String actName = message.getActName(); //保存任务列表 IWeaverOAApprovalInstanceTaskList iWeaverOAApprovalInstanceTaskList = WeaverOAApprovalInstanceTaskListFactory.getLocalInstance(ctx); WeaverOAApprovalInstanceTaskListCollection weaverOAApprovalInstanceTaskList = iWeaverOAApprovalInstanceTaskList.getWeaverOAApprovalInstanceTaskListCollection( "where parent.id='" + instanceInfo.getId() + "' and nodename <> '" + actName + "'" ); if (!weaverOAApprovalInstanceTaskList.isEmpty()) { SelectorItemCollection updateSic = new SelectorItemCollection(); updateSic.add("nodename"); for (int i = 0; i < weaverOAApprovalInstanceTaskList.size(); i++) { WeaverOAApprovalInstanceTaskListInfo weaverOAApprovalInstanceTaskListInfo = weaverOAApprovalInstanceTaskList.get(i); weaverOAApprovalInstanceTaskListInfo.setNodename(actName); //更新现有节点的节点名称 iWeaverOAApprovalInstanceTaskList.updatePartial(weaverOAApprovalInstanceTaskListInfo, updateSic); } } WeaverOAApprovalInstanceTaskListInfo task = createTask(ctx, message, pcLink, mobileLink); task.setParent(instanceInfo); iWeaverOAApprovalInstanceTaskList.save(task); //同步 iWeaverOAApprovalInstance.syncApprovalInstance(instanceInfo.getId().toString()); } catch (Exception e) { e.printStackTrace(); return false; } return true; } /** * 根据实例id获取审批实例 * * @param procInstId * @param iWeaverOAApprovalInstance * @return * @throws BOSException */ private static WeaverOAApprovalInstanceCollection getApprovalInstanceCollection( String procInstId, IWeaverOAApprovalInstance iWeaverOAApprovalInstance ) throws BOSException { FilterInfo filterInfo = new FilterInfo(); filterInfo.getFilterItems().add(new FilterItemInfo("instanceId", procInstId)); EntityViewInfo viewInfo = EntityViewInfo.getInstance(filterInfo, null, null); WeaverOAApprovalInstanceCollection instanceCol = iWeaverOAApprovalInstance.getWeaverOAApprovalInstanceCollection(viewInfo); return instanceCol; } /** * 创建任务数据 * * @param ctx * @param message * @param pcLink * @param mobileLink * @return * @throws BOSException * @throws EASBizException */ private static WeaverOAApprovalInstanceTaskListInfo createTask( Context ctx, WSMessage message, String pcLink, String mobileLink ) throws BOSException, EASBizException { IUser iUser = UserFactory.getLocalInstance(ctx); //标题 String title = message.getTitle().replace("\r", "\\r").replace("\n", "\\n"); //发送时间 Time sendTime = new Time(message.getSendTime().getTime()); //审批人 UserInfo reciever = iUser.getUserByID(new ObjectUuidPK(message.getRecieverID())); //发送人 UserInfo sender = iUser.getUserInfo("where number='" + message.getSenderNumber() + "'"); //接收时间 Time receiveTime = new Time(message.getReceiveTime().getTime()); WeaverOAApprovalInstanceTaskListInfo taskListInfo = new WeaverOAApprovalInstanceTaskListInfo(); //任务id taskListInfo.setFlowid(message.getSourceID()); //标题 taskListInfo.setRequestname(title); //获取单据对象 EntityObjectInfo entityObjectInfo = BaseMetaDataUtil.getEntityObjectInfo(ctx, BOSUuid.read(message.getBillId()).getType()); //流程类型名称 taskListInfo.setWorkflowname(entityObjectInfo.getDisplayName()); //步骤名称（节点名称） taskListInfo.setNodename(message.getActName()); //PC端链接 taskListInfo.setPcurl(pcLink); //移动端链接 taskListInfo.setAppurl(mobileLink); //流程处理状态 待办 taskListInfo.setIsremark(IsRemarkEnum.TODO); //流程查看状态 taskListInfo.setViewtype(ViewTypeEnum.UNREAD); //创建人 taskListInfo.setCreator(sender); //创建日期时间 taskListInfo.setCreatedatetime(sendTime); //接收人 taskListInfo.setReceiver(reciever); //接收日期时间 taskListInfo.setReceivedatetime(receiveTime); return taskListInfo; } /** * 获取pc待办地址 * * @param message * @return * @throws UnsupportedEncodingException * @throws BOSException * @throws EASBizException */ private static String getPcLink( WeaverOAConfigInfo defaultConfig, WSMessage message, String encryptRecieveNumber ) throws BOSException { try { String shrServerName = defaultConfig.getSHRServerName(); String utf8String = StandardCharsets.UTF_8.toString(); //构建重定向地址 String redirectUrl = UriComponentsBuilder.fromUriString(shrServerName + "/easweb/webviews/workflow/transferApprove.jsp") .queryParam("AssignmentId", URLEncoder.encode(message.getSourceID(), utf8String))//任务id .queryParam("billID", URLEncoder.encode(message.getBillId(), utf8String))//单据id .build(true) .toUriString(); //构建pc端链接 String targetUrl = UriComponentsBuilder.fromUriString(shrServerName + "/qy/weaverOA/V9/ssoSHRByNumber/") .queryParam("number", URLEncoder.encode(encryptRecieveNumber, utf8String)) .queryParam("redirectUrl", URLEncoder.encode(redirectUrl, utf8String)) .queryParam("platform", "pc")//平台 .build(true) .toUriString(); logger.error("getPcLink targetUrl: {}", targetUrl); return targetUrl; } catch (Exception e) { e.printStackTrace(); throw new BOSException(e.getMessage()); } } /** * 获取移动端待办地址 * * @param message * @return * @throws BOSException * @throws EASBizException * @throws UnsupportedEncodingException */ private static String getMobileLink( WeaverOAConfigInfo defaultConfig, WSMessage message, String encryptRecieveNumber ) throws BOSException { try { String shrServerName = defaultConfig.getSHRServerName(); String utf8String = StandardCharsets.UTF_8.toString(); //构建重定向地址 String redirectUrl = UriComponentsBuilder.fromUriString("https://mbos.kdeascloud.com/mbos/mbosw/getWorkflowUrl") .queryParam("assignId", URLEncoder.encode(message.getSourceID(), utf8String))//任务id .queryParam("eid", URLEncoder.encode(defaultConfig.getMEid(), utf8String))//mbos企业id .queryParam("storeEid", "21231") .queryParam("name", URLEncoder.encode("approveui.navui", utf8String)) .queryParam("billID", URLEncoder.encode(message.getBillId(), utf8String)) .build(true) .toUriString(); //构建移动端链接 String targetUrl = UriComponentsBuilder.fromUriString(shrServerName + "/qy/weaverOA/V9/ssoSHRByNumber/") .queryParam("number", URLEncoder.encode(encryptRecieveNumber, utf8String)) .queryParam("redirectUrl", URLEncoder.encode(redirectUrl, utf8String)) .queryParam("platform", "mobile")//平台 .build(true) .toUriString(); logger.error("getMobileLink targetUrl : {}", targetUrl); return targetUrl; } catch (Exception e) { e.printStackTrace(); throw new BOSException(e.getMessage()); } } }