shilei
/
haojing
1
1
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

#EC_HJ109# 流程监控删除功能优化

Browse Source
main
shilei 2 years ago
parent 21962bf8c9
commit e7c0c0aea3
3 changed files with 627 additions and 508 deletions
Show Stats Download Patch File Download Diff File

226
src/com/customization/dito/sendtodo/SendPortalWithDeleteCmd.java
Unescape Escape View File

@ -2,6 +2,7 @@ package com.customization.dito.sendtodo;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.constant.Constants;
import com.engine.common.biz.AbstractCommonCommand; import com.engine.common.biz.AbstractCommonCommand;
import com.engine.common.entity.BizLogContext; import com.engine.common.entity.BizLogContext;
import com.engine.core.cfg.annotation.CommandDynamicProxy; import com.engine.core.cfg.annotation.CommandDynamicProxy;
@ -19,6 +20,7 @@ import weaver.interfaces.dito.comInfo.PropBean;
import java.net.URLEncoder; import java.net.URLEncoder;
import java.util.HashMap; import java.util.HashMap;
import java.util.List;
import java.util.Map; import java.util.Map;
/** /**
@ -33,65 +35,65 @@ public class SendPortalWithDeleteCmd {
public Map<String, Object> execute(CommandContext commandContext) { public Map<String, Object> execute(CommandContext commandContext) {
String requestid = Util.null2String(params.get("requestid")); String requestid = Util.null2String(params.get("requestid"));
String bpm_app_workflowurl = PropBean.getUfPropValue("bpm_app_workflowurl");
String bpm_app_requesturl = PropBean.getUfPropValue("bpm_app_requesturl");
String portal_todourl = PropBean.getUfPropValue("portal_todourl");
String username = PropBean.getUfPropValue("username");
String passwd = PropBean.getUfPropValue("passwd");
String center = PropBean.getUfPropValue("center");
String bpm_workflowurl = PropBean.getUfPropValue("bpm_workflowurl");
sendTodoDataByNode(requestid,username,passwd,center,portal_todourl,bpm_workflowurl,bpm_app_workflowurl,bpm_app_requesturl); String currentUserId = "1";
SendPortalWithDeleteTodo(requestid,currentUserId);
List<Map<String,String>> deleteRemarkDatas = (List<Map<String,String>>)(params.get("deleteRemarkDatas"));
for(int i=0;i<deleteRemarkDatas.size();i++){
Map<String,String> deleteRemarkMap = deleteRemarkDatas.get(i);
return null; String userid = deleteRemarkMap.get("userid");
} String lcid = deleteRemarkMap.get("requestid");
private String getShortMessageTitle(String messageTitle) { SendPortalWithDeleteToRead(lcid,currentUserId,userid);
if (messageTitle.length() > 20) {
messageTitle = messageTitle.substring(0, 17) + "...";
} }
return messageTitle;
return null;
} }
/** /**
* *
* @param username * @param requestid
* @param passwd * @param currentUserId
* @param portal_todourl
* @param bpm_workflowurl
* @param bpm_app_workflowurl
* @param bpm_app_requesturl
*/ */
public void sendTodoDataByNode(String requestid,String username,String passwd,String center,String portal_todourl,String bpm_workflowurl,String bpm_app_workflowurl,String bpm_app_requesturl){ public void SendPortalWithDeleteTodo(String requestid,String currentUserId){
String portal_todourl = Constants.portal_todourl;
String bpm_app_workflowurl = Constants.bpm_app_workflowurl;
String username = Constants.username;
String passwd = Constants.passwd;
String bpm_workflowurl = Constants.bpm_workflowurl;
String center = Constants.center;
String bpm_app_requesturl = Constants.bpm_app_requesturl;
HttpRequestUtil httpRequestUtil = new HttpRequestUtil(); HttpRequestUtil httpRequestUtil = new HttpRequestUtil();
String mobileJumpUrl = PropBean.getUfPropValue("mobileJumpUrl"); String zhjkbs = "com.customization.dito.sendtodo.SendPortalWithDeleteCmd.SendPortalWithDeleteTodo" ;
String mobileJumpUrl = PropBean.getUfPropValue("mobileJumpUrl");
JSONObject requestObject = new JSONObject(); JSONObject requestObject = new JSONObject();
RecordSet rs = new RecordSet(); RecordSet rs = new RecordSet();
BaseBean bb = new BaseBean(); BaseBean bb = new BaseBean();
bb.writeLog("SendPortalQithRawRunnable--sendTodoDataByNode"); bb.writeLog("SendPortalWithDeleteCmd--SendPortalWithDeleteTodo");
String terminal = "1" ; String terminal = "1" ;
String taskType = "0"; String taskType = "0";
String actionType = "3" ; String actionType = "3" ;
String objectAction = "0" ;
String objectType = "0";
try { SendPortalErrorUtil sendPortalErrorUtil = new SendPortalErrorUtil();
String sql="";
// int userid = user.getUID();
//String workcode = "";
// String sql = " select * from (select id, lastname,loginid from hrmresource where status = 1 union all select id, lastname,loginid from hrmresourcemanager ) w where w.id = '" + userid + "'";
// rs.executeQuery(sql);
// while (rs.next()) {
// workcode = Util.null2String(rs.getString("loginid"));
// }
String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss"); String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss");
try {
String urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ; String urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
String replace = bpm_app_workflowurl.replace("/bpm", ""); String replace = bpm_app_workflowurl.replace("/bpm", "");
String urlDing = replace+bpm_app_requesturl+requestid; String urlDing = replace+bpm_app_requesturl+requestid;
@ -103,33 +105,32 @@ public class SendPortalWithDeleteCmd {
} }
bb.writeLog("urlDing", urlDing); bb.writeLog("urlDing", urlDing);
String requestname = "" ; String requestname = "" ;
String workflowname = "" ; String workflowname = "" ;
String nodeId = "" ; String currentNodeId = "" ;
String nodeName = "" ; String currentNodeName = "" ;
sql =" select t1.requestname,t1.currentnodeid as nodeid,d1.nodename,t3.workflowname\n" +
String sql =" select t1.requestname,t1.currentnodeid as nodeid,d1.nodename,t3.workflowname\n" +
" from workflow_requestbase t1\n" + " from workflow_requestbase t1\n" +
" inner join workflow_base t3 on t1.workflowid = t3.id\n" + " inner join workflow_base t3 on t1.workflowid = t3.id\n" +
" left join workflow_nodebase d1 on d1.id = t1.currentnodeid "+ " left join workflow_nodebase d1 on d1.id = t1.currentnodeid "+
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" + " where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
" and t1.requestid = "+requestid ; " and t1.requestid = "+requestid ;
bb.writeLog("sendTodoDataByNode--sql2:"+sql); bb.writeLog("SendPortalWithDeleteTodo--sql2:"+sql);
rs.executeQuery(sql); rs.executeQuery(sql);
if (rs.next()){ if (rs.next()){
requestname = Util.null2String(rs.getString("requestname")) ; requestname = Util.null2String(rs.getString("requestname")) ;
workflowname = Util.null2String(rs.getString("workflowname")) ; workflowname = Util.null2String(rs.getString("workflowname")) ;
nodeId = Util.null2String(rs.getString("nodeid")) ; currentNodeId = Util.null2String(rs.getString("nodeid")) ;
nodeName = Util.null2String(rs.getString("nodeName")) ; currentNodeName = Util.null2String(rs.getString("nodeName")) ;
} }
requestObject.put("center",center); requestObject.put("center",center);
requestObject.put("title",requestname); requestObject.put("title",requestname);
//requestObject.put("creator",workcode);
requestObject.put("taskCode","weaver"+requestid); requestObject.put("taskCode","weaver"+requestid);
requestObject.put("nodeId",nodeId); requestObject.put("nodeId",currentNodeId);
requestObject.put("taskType",taskType); requestObject.put("taskType",taskType);
requestObject.put("actionType",actionType); requestObject.put("actionType",actionType);
requestObject.put("createDate",processTime); requestObject.put("createDate",processTime);
@ -139,45 +140,144 @@ public class SendPortalWithDeleteCmd {
requestObject.put("urlPc",urlPc); requestObject.put("urlPc",urlPc);
requestObject.put("urlApp",urlApp); requestObject.put("urlApp",urlApp);
requestObject.put("urlDing",urlDing); requestObject.put("urlDing",urlDing);
requestObject.put("nodeName",nodeName); requestObject.put("nodeName",currentNodeName);
requestObject.put("ticketType",workflowname); requestObject.put("ticketType",workflowname);
String auth = username + ":" + passwd;
bb.writeLog("SendPortalWithDeleteTodo---requestObject:"+requestObject.toJSONString());
String msgdata = httpRequestUtil.doPostByAuth(portal_todourl,requestObject.toJSONString(),auth);
if (!"".equals(msgdata)) {
JSONObject msgObject = JSONObject.parseObject(msgdata);
if (msgObject.containsKey("resultCode")) {
String resultCode = msgObject.getString("resultCode");
if ("0".equals(resultCode)) {
sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,currentNodeId,currentNodeName,currentUserId,requestObject.toJSONString(),resultCode,"",zhjkbs);
}else{
String resultmsg = msgObject.getString("resultMsg");
sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,currentNodeId,currentNodeName,currentUserId,requestObject.toJSONString(),resultCode,resultmsg,zhjkbs);
}
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
/**
*
* @param requestid
* @param currentUserId
*/
public void SendPortalWithDeleteToRead(String requestid,String currentUserId,String userid){
String portal_todourl = Constants.portal_todourl;
String bpm_app_workflowurl = Constants.bpm_app_workflowurl;
String username = Constants.username;
String passwd = Constants.passwd;
String bpm_workflowurl = Constants.bpm_workflowurl;
String center = Constants.center;
String bpm_app_requesturl = Constants.bpm_app_requesturl;
HttpRequestUtil httpRequestUtil = new HttpRequestUtil();
String zhjkbs = "com.customization.dito.sendtodo.SendPortalWithDeleteCmd.SendPortalWithDeleteToRead" ;
String mobileJumpUrl = PropBean.getUfPropValue("mobileJumpUrl");
JSONObject requestObject = new JSONObject();
RecordSet rs = new RecordSet();
BaseBean bb = new BaseBean();
bb.writeLog("SendPortalWithDeleteCmd--SendPortalWithDeleteToRead");
String terminal = "1" ;
String taskType = "0";
String actionType = "3" ;
SendPortalErrorUtil sendPortalErrorUtil = new SendPortalErrorUtil();
String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss");
try {
String urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
String replace = bpm_app_workflowurl.replace("/bpm", "");
String urlDing = replace+bpm_app_requesturl+requestid;
String urlApp = replace+bpm_app_requesturl+requestid;
if(StringUtils.isNotEmpty(mobileJumpUrl)){
urlDing += "&returnUrl="+ URLEncoder.encode(mobileJumpUrl,"UTF-8");
urlApp += "&returnUrl="+URLEncoder.encode(mobileJumpUrl,"UTF-8");
}
bb.writeLog("urlDing", urlDing);
String requestname = "" ;
String workflowname = "" ;
String currentNodeId = "" ;
String currentNodeName = "" ;
String sql =" select t1.requestname,t1.currentnodeid as nodeid,d1.nodename,t3.workflowname\n" +
" from workflow_requestbase t1\n" +
" inner join workflow_base t3 on t1.workflowid = t3.id\n" +
" left join workflow_nodebase d1 on d1.id = t1.currentnodeid "+
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
" and t1.requestid = "+requestid ;
// JSONArray taskObjectList = new JSONArray(); bb.writeLog("SendPortalWithDeleteToRead--sql2:"+sql);
// JSONObject taskObject = new JSONObject();
// taskObject.put("objectAction",objectAction);
// taskObject.put("objectType",objectType);
// taskObject.put("objectCode",workcode);
// taskObject.put("objectId","");
// taskObject.put("operatorCode",workcode);
// taskObjectList.add(taskObject);
// requestObject.put("taskObjectList",taskObjectList); rs.executeQuery(sql);
if (rs.next()){
requestname = Util.null2String(rs.getString("requestname")) ;
workflowname = Util.null2String(rs.getString("workflowname")) ;
currentNodeId = Util.null2String(rs.getString("nodeid")) ;
currentNodeName = Util.null2String(rs.getString("nodeName")) ;
}
requestObject.put("center",center);
requestObject.put("title",requestname);
requestObject.put("taskCode", requestid+"_cs_"+userid);
requestObject.put("nodeId",currentNodeId);
requestObject.put("taskType",taskType);
requestObject.put("actionType",actionType);
requestObject.put("createDate",processTime);
requestObject.put("messageTitle",getShortMessageTitle(requestname));
requestObject.put("messageContent",requestname);
requestObject.put("terminal",terminal);
requestObject.put("urlPc",urlPc);
requestObject.put("urlApp",urlApp);
requestObject.put("urlDing",urlDing);
requestObject.put("nodeName",currentNodeName);
requestObject.put("ticketType",workflowname);
String auth = username + ":" + passwd; String auth = username + ":" + passwd;
bb.writeLog("sendTodoDataByNode---requestObject:"+requestObject.toJSONString()); bb.writeLog("SendPortalWithDeleteToRead---requestObject:"+requestObject.toJSONString());
String msgdata = httpRequestUtil.doPostByAuth(portal_todourl,requestObject.toJSONString(),auth); String msgdata = httpRequestUtil.doPostByAuth(portal_todourl,requestObject.toJSONString(),auth);
bb.writeLog("msgdata:"+msgdata);
Map<String,Object> map = new HashMap<>();
if (!"".equals(msgdata)) { if (!"".equals(msgdata)) {
JSONObject msgObject = JSONObject.parseObject(msgdata); JSONObject msgObject = JSONObject.parseObject(msgdata);
//{"resultCode":"1","resultMsg":"No Result"}
if (msgObject.containsKey("resultCode")) { if (msgObject.containsKey("resultCode")) {
String resultCode = msgObject.getString("resultCode"); String resultCode = msgObject.getString("resultCode");
if ("0".equals(resultCode)) { if ("0".equals(resultCode)) {
map.put("resultCode","0"); sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,currentNodeId,currentNodeName,currentUserId,requestObject.toJSONString(),resultCode,"",zhjkbs);
}else{ }else{
bb.writeLog(msgObject.get("resultMsg")); String resultmsg = msgObject.getString("resultMsg");
// sendPortalErrorUtil.doCreateSendPortalTodoErrorInfo(); sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,currentNodeId,currentNodeName,currentUserId,requestObject.toJSONString(),resultCode,resultmsg,zhjkbs);
map.put("resultCode",resultCode);
map.put("resultMsg",msgObject.get("resultMsg"));
} }
} }
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
} }
private String getShortMessageTitle(String messageTitle) {
if (messageTitle.length() > 20) {
messageTitle = messageTitle.substring(0, 17) + "...";
}
return messageTitle;
}
} }

18
src/com/engine/workflow/web/RequestMonitorListAction.java
Unescape Escape View File

@ -184,12 +184,10 @@ public class RequestMonitorListAction {
String className = "weaver.interfaces.dito.monitor.SendPortalMonitorUtil" ; String className = "weaver.interfaces.dito.monitor.SendPortalMonitorUtil" ;
String methodName = "monitorDelete" ; String methodName = "monitorDelete" ;
Class<?> clazz = Class.forName(className); Class<?> clazz = Class.forName(className);
if(clazz.getMethod(methodName,String.class) != null) {
Method method = clazz.getMethod(methodName, String.class,String.class); Method method = clazz.getMethod(methodName, String.class,String.class);
Object newInstance = clazz.newInstance(); Object newInstance = clazz.newInstance();
method.invoke(newInstance,requestid,userid); method.invoke(newInstance,requestid,userid);
} }
}
}catch (ClassNotFoundException | NoSuchMethodException e){ }catch (ClassNotFoundException | NoSuchMethodException e){
e.printStackTrace(); e.printStackTrace();
bb.writeLog("deleteRequestById-ClassNotFoundException"+e); bb.writeLog("deleteRequestById-ClassNotFoundException"+e);
@ -227,22 +225,20 @@ public class RequestMonitorListAction {
try{ try{
String requestid = Util.null2String(request.getParameter("multiRequestIds")); String requestid = Util.null2String(request.getParameter("multiRequestIds"));
String userid = user.getUID()+"" ; String userid = user.getUID()+"" ;
bb.writeLog("deleteRequestById-requestid"+requestid); bb.writeLog("archivingRequestById-requestid"+requestid);
bb.writeLog("deleteRequestById-userid"+userid); bb.writeLog("archivingRequestById-userid"+userid);
if(StringUtils.isNotEmpty(requestid)){ if(StringUtils.isNotEmpty(requestid)){
String className = "weaver.interfaces.dito.monitor.SendPortalMonitorUtil" ; String className = "weaver.interfaces.dito.monitor.SendPortalMonitorUtil" ;
String methodName = "monitorArchived" ; String methodName = "monitorArchived" ;
Class<?> clazz = Class.forName(className); Class<?> clazz = Class.forName(className);
if(clazz.getMethod(methodName,String.class) != null) {
Method method = clazz.getMethod(methodName, String.class,String.class); Method method = clazz.getMethod(methodName, String.class,String.class);
Object newInstance = clazz.newInstance(); Object newInstance = clazz.newInstance();
method.invoke(newInstance,requestid,userid); method.invoke(newInstance,requestid,userid);
} }
}
}catch (ClassNotFoundException | NoSuchMethodException e){ }catch (ClassNotFoundException | NoSuchMethodException e){
e.printStackTrace(); e.printStackTrace();
bb.writeLog("deleteRequestById-ClassNotFoundException"+e); bb.writeLog("archivingRequestById-ClassNotFoundException"+e);
} }
}catch(Exception e){ }catch(Exception e){
@ -359,22 +355,20 @@ public class RequestMonitorListAction {
try{ try{
String requestid = Util.null2String(request.getParameter("multiRequestIds")); String requestid = Util.null2String(request.getParameter("multiRequestIds"));
String userid = user.getUID()+"" ; String userid = user.getUID()+"" ;
bb.writeLog("deleteRequestById-requestid"+requestid); bb.writeLog("repossessedRequestById-requestid"+requestid);
bb.writeLog("deleteRequestById-userid"+userid); bb.writeLog("repossessedRequestById-userid"+userid);
if(StringUtils.isNotEmpty(requestid)){ if(StringUtils.isNotEmpty(requestid)){
String className = "weaver.interfaces.dito.monitor.SendPortalMonitorUtil" ; String className = "weaver.interfaces.dito.monitor.SendPortalMonitorUtil" ;
String methodName = "monitorPossessed" ; String methodName = "monitorPossessed" ;
Class<?> clazz = Class.forName(className); Class<?> clazz = Class.forName(className);
if(clazz.getMethod(methodName,String.class) != null) {
Method method = clazz.getMethod(methodName,String.class,String.class); Method method = clazz.getMethod(methodName,String.class,String.class);
Object newInstance = clazz.newInstance(); Object newInstance = clazz.newInstance();
method.invoke(newInstance,requestid,userid); method.invoke(newInstance,requestid,userid);
} }
}
}catch (ClassNotFoundException | NoSuchMethodException e){ }catch (ClassNotFoundException | NoSuchMethodException e){
e.printStackTrace(); e.printStackTrace();
bb.writeLog("deleteRequestById-ClassNotFoundException"+e); bb.writeLog("repossessedRequestById-ClassNotFoundException"+e);
} }
}catch(Exception e){ }catch(Exception e){

139
src/weaver/interfaces/dito/monitor/SendPortalMonitorUtil.java
Unescape Escape View File

@ -6,7 +6,7 @@ import com.constant.Constants;
import com.customization.dito.sendtodo.HttpRequestUtil; import com.customization.dito.sendtodo.HttpRequestUtil;
import com.customization.dito.sendtodo.SendPortalErrorUtil; import com.customization.dito.sendtodo.SendPortalErrorUtil;
import com.time.util.DateUtil; import com.time.util.DateUtil;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang3.StringUtils;
import weaver.conn.RecordSet; import weaver.conn.RecordSet;
import weaver.general.BaseBean; import weaver.general.BaseBean;
import weaver.general.Util; import weaver.general.Util;
@ -22,10 +22,10 @@ public class SendPortalMonitorUtil {
/*** /***
* 流程删除 * 流程删除
* @param requestid * @param requestids
* @param userid * @param userid
*/ */
public void monitorDelete(String requestid,String userid){ public void monitorDelete(String requestids,String userid){
String portal_todourl = Constants.portal_todourl; String portal_todourl = Constants.portal_todourl;
@ -36,7 +36,6 @@ public class SendPortalMonitorUtil {
String center = Constants.center; String center = Constants.center;
String bpm_app_requesturl = Constants.bpm_app_requesturl; String bpm_app_requesturl = Constants.bpm_app_requesturl;
String zhjkbs = "weaver.interfaces.dito.monitor.SendPortalMonitorUtil.monitorDelete" ; String zhjkbs = "weaver.interfaces.dito.monitor.SendPortalMonitorUtil.monitorDelete" ;
SendPortalErrorUtil sendPortalErrorUtil = new SendPortalErrorUtil(); SendPortalErrorUtil sendPortalErrorUtil = new SendPortalErrorUtil();
@ -49,9 +48,13 @@ public class SendPortalMonitorUtil {
String terminal = "1" ; String terminal = "1" ;
String taskType = "0"; String taskType = "0";
String actionType = "3" ; String actionType = "3" ;
try {
String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss"); String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss");
if(StringUtils.isNotBlank(requestids)) {
String[] lcids = requestids.split(",");
for (int i = 0; i < lcids.length; i++) {
String requestid = lcids[i];
try {
String urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ; String urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
String replace = bpm_app_workflowurl.replace("/bpm", ""); String replace = bpm_app_workflowurl.replace("/bpm", "");
String urlDing = replace+bpm_app_requesturl+requestid; String urlDing = replace+bpm_app_requesturl+requestid;
@ -63,7 +66,6 @@ public class SendPortalMonitorUtil {
} }
bb.writeLog("monitorDelete-urlDing", urlDing); bb.writeLog("monitorDelete-urlDing", urlDing);
String requestname = "" ; String requestname = "" ;
String workflowname = "" ; String workflowname = "" ;
String nodeId = "" ; String nodeId = "" ;
@ -118,7 +120,7 @@ public class SendPortalMonitorUtil {
String resultmsg = msgObject.getString("resultMsg"); String resultmsg = msgObject.getString("resultMsg");
sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,nodeId,nodeName,userid,requestObject.toJSONString(),resultCode,resultmsg,zhjkbs); sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,nodeId,nodeName,userid,requestObject.toJSONString(),resultCode,resultmsg,zhjkbs);
againMonitorDelete(requestid,userid,3); // againMonitorDelete(requestid,userid,3);
} }
} }
@ -127,6 +129,8 @@ public class SendPortalMonitorUtil {
e.printStackTrace(); e.printStackTrace();
} }
} }
}
}
/*** /***
@ -242,15 +246,16 @@ public class SendPortalMonitorUtil {
* 流程强制归档 * 流程强制归档
*/ */
public void monitorArchived(String requestid,String userid){ public void monitorArchived(String requestid,String userid){
monitorArchivedByTodo(requestid,userid); monitorArchivedByTodo(requestid,userid);
monitorArchivedByToRead(requestid,userid); monitorArchivedByToRead(requestid,userid);
} }
/*** /***
* 强制归档后，处理待办，推送到门户的todo * 强制归档后，处理待办，推送到门户的todo
* @param requestid * @param requestids
*/ */
public void monitorArchivedByTodo(String requestid,String userid){ public void monitorArchivedByTodo(String requestids,String currentUserId){
String portal_todourl = Constants.portal_todourl; String portal_todourl = Constants.portal_todourl;
String bpm_app_workflowurl = Constants.bpm_app_workflowurl; String bpm_app_workflowurl = Constants.bpm_app_workflowurl;
@ -260,7 +265,6 @@ public class SendPortalMonitorUtil {
String center = Constants.center; String center = Constants.center;
String bpm_app_requesturl = Constants.bpm_app_requesturl; String bpm_app_requesturl = Constants.bpm_app_requesturl;
String zhjkbs = "weaver.interfaces.dito.monitor.SendPortalMonitorUtil.monitorArchivedByTodo" ; String zhjkbs = "weaver.interfaces.dito.monitor.SendPortalMonitorUtil.monitorArchivedByTodo" ;
SendPortalErrorUtil sendPortalErrorUtil = new SendPortalErrorUtil(); SendPortalErrorUtil sendPortalErrorUtil = new SendPortalErrorUtil();
@ -273,13 +277,18 @@ public class SendPortalMonitorUtil {
String terminal = "1" ; String terminal = "1" ;
String taskType = "0"; String taskType = "0";
String actionType = "2" ; String actionType = "2" ;
try {
String cus_staff = PropBean.getUfPropValue("cus_staff") ; String cus_staff = PropBean.getUfPropValue("cus_staff") ;
String scopeid = "-1"; String scopeid = "-1";
String scope = "HrmCustomFieldByInfoType" ; String scope = "HrmCustomFieldByInfoType" ;
String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss"); String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss");
if(StringUtils.isNotBlank(requestids)){
String[] lcids = requestids.split(",");
for(int i=0;i<lcids.length;i++){
String requestid = lcids[i];
try {
String urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ; String urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
String replace = bpm_app_workflowurl.replace("/bpm", ""); String replace = bpm_app_workflowurl.replace("/bpm", "");
String urlDing = replace+bpm_app_requesturl+requestid; String urlDing = replace+bpm_app_requesturl+requestid;
@ -311,8 +320,8 @@ public class SendPortalMonitorUtil {
String requestname = "" ; String requestname = "" ;
String workflowname = "" ; String workflowname = "" ;
String nodeId = "" ; String currentNodeId = "" ;
String nodeName = "" ; String currentNodeName = "" ;
String sql =" select t1.requestname,t1.currentnodeid as nodeid,d1.nodename,t3.workflowname\n" + String sql =" select t1.requestname,t1.currentnodeid as nodeid,d1.nodename,t3.workflowname\n" +
" from workflow_requestbase t1\n" + " from workflow_requestbase t1\n" +
" inner join workflow_base t3 on t1.workflowid = t3.id\n" + " inner join workflow_base t3 on t1.workflowid = t3.id\n" +
@ -326,13 +335,13 @@ public class SendPortalMonitorUtil {
if (rs.next()){ if (rs.next()){
requestname = Util.null2String(rs.getString("requestname")) ; requestname = Util.null2String(rs.getString("requestname")) ;
workflowname = Util.null2String(rs.getString("workflowname")) ; workflowname = Util.null2String(rs.getString("workflowname")) ;
nodeId = Util.null2String(rs.getString("nodeid")) ; currentNodeId = Util.null2String(rs.getString("nodeid")) ;
nodeName = Util.null2String(rs.getString("nodeName")) ; currentNodeName = Util.null2String(rs.getString("nodeName")) ;
} }
requestObject.put("center",center); requestObject.put("center",center);
requestObject.put("title",requestname); requestObject.put("title",requestname);
requestObject.put("taskCode","weaver"+requestid); requestObject.put("taskCode","weaver"+requestid);
requestObject.put("nodeId",nodeId); requestObject.put("nodeId",currentNodeId);
requestObject.put("taskType",taskType); requestObject.put("taskType",taskType);
requestObject.put("actionType",actionType); requestObject.put("actionType",actionType);
requestObject.put("createDate",processTime); requestObject.put("createDate",processTime);
@ -342,7 +351,7 @@ public class SendPortalMonitorUtil {
requestObject.put("urlPc",urlPc); requestObject.put("urlPc",urlPc);
requestObject.put("urlApp",urlApp); requestObject.put("urlApp",urlApp);
requestObject.put("urlDing",urlDing); requestObject.put("urlDing",urlDing);
requestObject.put("nodeName",nodeName); requestObject.put("nodeName",currentNodeName);
requestObject.put("ticketType",workflowname); requestObject.put("ticketType",workflowname);
JSONArray taskObjectList = new JSONArray(); JSONArray taskObjectList = new JSONArray();
@ -389,10 +398,10 @@ public class SendPortalMonitorUtil {
if (msgObject.containsKey("resultCode")) { if (msgObject.containsKey("resultCode")) {
String resultCode = msgObject.getString("resultCode"); String resultCode = msgObject.getString("resultCode");
if ("0".equals(resultCode)) { if ("0".equals(resultCode)) {
sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,nodeId,nodeName,userid,requestObject.toJSONString(),resultCode,"",zhjkbs); sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,currentNodeId,currentNodeName,currentUserId,requestObject.toJSONString(),resultCode,"",zhjkbs);
}else{ }else{
String resultmsg = msgObject.getString("resultMsg"); String resultmsg = msgObject.getString("resultMsg");
sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,nodeId,nodeName,userid,requestObject.toJSONString(),resultCode,resultmsg,zhjkbs); sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,currentNodeId,currentNodeName,currentUserId,requestObject.toJSONString(),resultCode,resultmsg,zhjkbs);
} }
} }
} }
@ -400,14 +409,15 @@ public class SendPortalMonitorUtil {
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
}
}
} }
/*** /***
* 强制归档后，处理抄送人员，推送到门户的toread * 强制归档后，处理抄送人员，推送到门户的toread
* @param requestid * @param requestids
*/ */
public void monitorArchivedByToRead(String requestid,String userid){ public void monitorArchivedByToRead(String requestids,String currentUserId){
String portal_todourl = Constants.portal_todourl; String portal_todourl = Constants.portal_todourl;
String bpm_app_workflowurl = Constants.bpm_app_workflowurl; String bpm_app_workflowurl = Constants.bpm_app_workflowurl;
@ -421,13 +431,13 @@ public class SendPortalMonitorUtil {
bb.writeLog("sendOverTimeSubmitBytoRead"); bb.writeLog("sendOverTimeSubmitBytoRead");
RecordSet rs = new RecordSet(); RecordSet rs = new RecordSet();
String zhjkbs = "weaver.interfaces.dito.overtime.SendPortalOverTimeSubmitUtil.sendOverTimeSubmitBytoRead" ; String zhjkbs = "weaver.interfaces.dito.monitor.SendPortalMonitorUtil.monitorArchivedByToRead" ;
SendPortalErrorUtil sendPortalErrorUtil = new SendPortalErrorUtil(); SendPortalErrorUtil sendPortalErrorUtil = new SendPortalErrorUtil();
HttpRequestUtil httpRequestUtil = new HttpRequestUtil(); HttpRequestUtil httpRequestUtil = new HttpRequestUtil();
String mobileJumpUrl = PropBean.getUfPropValue("mobileJumpUrl"); String mobileJumpUrl = PropBean.getUfPropValue("mobileJumpUrl");
JSONObject requestObject = new JSONObject(); JSONObject requestObject = new JSONObject();
bb.writeLog("SendPortalOverTimeSubmitUtil--sendOverTimeSubmit"); bb.writeLog("SendPortalMonitorUtil--monitorArchivedByToRead");
String terminal = "1" ; String terminal = "1" ;
String taskType = "1"; String taskType = "1";
String actionType = "2" ; String actionType = "2" ;
@ -435,13 +445,17 @@ public class SendPortalMonitorUtil {
String objectAction = "0"; String objectAction = "0";
String objectType = "0"; String objectType = "0";
try {
String cus_staff = PropBean.getUfPropValue("cus_staff") ; String cus_staff = PropBean.getUfPropValue("cus_staff") ;
String scopeid = "-1"; String scopeid = "-1";
String scope = "HrmCustomFieldByInfoType" ; String scope = "HrmCustomFieldByInfoType" ;
String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss"); String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss");
if(StringUtils.isNotBlank(requestids)) {
String[] lcids = requestids.split(",");
for (int i = 0; i < lcids.length; i++) {
String requestid = lcids[i];
try {
String urlPc = "[newtab]"+ bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ; String urlPc = "[newtab]"+ bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
String replace = bpm_app_workflowurl.replace("/bpm", ""); String replace = bpm_app_workflowurl.replace("/bpm", "");
String urlDing = replace+bpm_app_requesturl+requestid; String urlDing = replace+bpm_app_requesturl+requestid;
@ -455,8 +469,8 @@ public class SendPortalMonitorUtil {
String requestname = "" ; String requestname = "" ;
String workflowname = "" ; String workflowname = "" ;
String nodeId = "" ; String currentNodeId = "" ;
String nodeName = "" ; String currentNodeName = "" ;
String sql =" select t1.requestname,t1.currentnodeid as nodeid,d1.nodename,t3.workflowname\n" + String sql =" select t1.requestname,t1.currentnodeid as nodeid,d1.nodename,t3.workflowname\n" +
" from workflow_requestbase t1\n" + " from workflow_requestbase t1\n" +
" inner join workflow_base t3 on t1.workflowid = t3.id\n" + " inner join workflow_base t3 on t1.workflowid = t3.id\n" +
@ -470,13 +484,13 @@ public class SendPortalMonitorUtil {
if (rs.next()){ if (rs.next()){
requestname = Util.null2String(rs.getString("requestname")) ; requestname = Util.null2String(rs.getString("requestname")) ;
workflowname = Util.null2String(rs.getString("workflowname")) ; workflowname = Util.null2String(rs.getString("workflowname")) ;
nodeId = Util.null2String(rs.getString("nodeid")) ; currentNodeId = Util.null2String(rs.getString("nodeid")) ;
nodeName = Util.null2String(rs.getString("nodeName")) ; currentNodeName = Util.null2String(rs.getString("nodeName")) ;
} }
requestObject.put("center",center); requestObject.put("center",center);
requestObject.put("title",requestname); requestObject.put("title",requestname);
requestObject.put("taskCode","weaver"+requestid); requestObject.put("taskCode","weaver"+requestid);
requestObject.put("nodeId",nodeId); requestObject.put("nodeId",currentNodeId);
requestObject.put("taskType",taskType); requestObject.put("taskType",taskType);
requestObject.put("actionType",actionType); requestObject.put("actionType",actionType);
requestObject.put("createDate",processTime); requestObject.put("createDate",processTime);
@ -486,7 +500,7 @@ public class SendPortalMonitorUtil {
requestObject.put("urlPc",urlPc); requestObject.put("urlPc",urlPc);
requestObject.put("urlApp",urlApp); requestObject.put("urlApp",urlApp);
requestObject.put("urlDing",urlDing); requestObject.put("urlDing",urlDing);
requestObject.put("nodeName",nodeName); requestObject.put("nodeName",currentNodeName);
requestObject.put("ticketType",workflowname); requestObject.put("ticketType",workflowname);
JSONArray taskObjectList = new JSONArray(); JSONArray taskObjectList = new JSONArray();
@ -530,10 +544,10 @@ public class SendPortalMonitorUtil {
if (msgObject.containsKey("resultCode")) { if (msgObject.containsKey("resultCode")) {
String resultCode = msgObject.getString("resultCode"); String resultCode = msgObject.getString("resultCode");
if ("0".equals(resultCode)) { if ("0".equals(resultCode)) {
sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,nodeId,nodeName,userid,requestObject.toJSONString(),resultCode,"",zhjkbs); sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,currentNodeId,currentNodeName,currentUserId,requestObject.toJSONString(),resultCode,"",zhjkbs);
}else{ }else{
String resultmsg = msgObject.getString("resultMsg"); String resultmsg = msgObject.getString("resultMsg");
sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,nodeId,nodeName,userid,requestObject.toJSONString(),resultCode,resultmsg,zhjkbs); sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,currentNodeId,currentNodeName,currentUserId,requestObject.toJSONString(),resultCode,resultmsg,zhjkbs);
} }
} }
} }
@ -541,12 +555,14 @@ public class SendPortalMonitorUtil {
e.printStackTrace(); e.printStackTrace();
} }
} }
}
}
/*** /***
* 流程强制收回 * 流程强制收回
*/ */
public void monitorPossessed(String requestid,String userid){ public void monitorPossessed(String requestids,String currentUserId){
String portal_todourl = Constants.portal_todourl; String portal_todourl = Constants.portal_todourl;
String bpm_app_workflowurl = Constants.bpm_app_workflowurl; String bpm_app_workflowurl = Constants.bpm_app_workflowurl;
@ -569,13 +585,19 @@ public class SendPortalMonitorUtil {
String terminal = "1" ; String terminal = "1" ;
String taskType = "0"; String taskType = "0";
String actionType = "2" ; String actionType = "2" ;
try {
String cus_staff = PropBean.getUfPropValue("cus_staff") ; String cus_staff = PropBean.getUfPropValue("cus_staff") ;
String scopeid = "-1"; String scopeid = "-1";
String scope = "HrmCustomFieldByInfoType" ; String scope = "HrmCustomFieldByInfoType" ;
String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss"); String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss");
if(StringUtils.isNotBlank(requestids)) {
String[] lcids = requestids.split(",");
for (int i = 0; i < lcids.length; i++) {
String requestid = lcids[i];
try {
String urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ; String urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
String replace = bpm_app_workflowurl.replace("/bpm", ""); String replace = bpm_app_workflowurl.replace("/bpm", "");
String urlDing = replace+bpm_app_requesturl+requestid; String urlDing = replace+bpm_app_requesturl+requestid;
@ -607,8 +629,8 @@ public class SendPortalMonitorUtil {
String requestname = "" ; String requestname = "" ;
String workflowname = "" ; String workflowname = "" ;
String nodeId = "" ; String currentNodeId = "" ;
String nodeName = "" ; String currentNodeName = "" ;
String sql =" select t1.requestname,t1.currentnodeid as nodeid,d1.nodename,t3.workflowname\n" + String sql =" select t1.requestname,t1.currentnodeid as nodeid,d1.nodename,t3.workflowname\n" +
" from workflow_requestbase t1\n" + " from workflow_requestbase t1\n" +
@ -623,15 +645,15 @@ public class SendPortalMonitorUtil {
if (rs.next()){ if (rs.next()){
requestname = Util.null2String(rs.getString("requestname")) ; requestname = Util.null2String(rs.getString("requestname")) ;
workflowname = Util.null2String(rs.getString("workflowname")) ; workflowname = Util.null2String(rs.getString("workflowname")) ;
nodeId = Util.null2String(rs.getString("nodeid")) ; currentNodeId = Util.null2String(rs.getString("nodeid")) ;
nodeName = Util.null2String(rs.getString("nodeName")) ; currentNodeName = Util.null2String(rs.getString("nodeName")) ;
} }
requestObject.put("center",center); requestObject.put("center",center);
requestObject.put("title",requestname); requestObject.put("title",requestname);
requestObject.put("taskCode","weaver"+requestid); requestObject.put("taskCode","weaver"+requestid);
requestObject.put("nodeId",nodeId); requestObject.put("nodeId",currentNodeId);
requestObject.put("taskType",taskType); requestObject.put("taskType",taskType);
requestObject.put("actionType",actionType); requestObject.put("actionType",actionType);
requestObject.put("createDate",processTime); requestObject.put("createDate",processTime);
@ -641,7 +663,7 @@ public class SendPortalMonitorUtil {
requestObject.put("urlPc",urlPc); requestObject.put("urlPc",urlPc);
requestObject.put("urlApp",urlApp); requestObject.put("urlApp",urlApp);
requestObject.put("urlDing",urlDing); requestObject.put("urlDing",urlDing);
requestObject.put("nodeName",nodeName); requestObject.put("nodeName",currentNodeName);
requestObject.put("ticketType",workflowname); requestObject.put("ticketType",workflowname);
JSONArray taskObjectList = new JSONArray(); JSONArray taskObjectList = new JSONArray();
@ -688,10 +710,10 @@ public class SendPortalMonitorUtil {
if (msgObject.containsKey("resultCode")) { if (msgObject.containsKey("resultCode")) {
String resultCode = msgObject.getString("resultCode"); String resultCode = msgObject.getString("resultCode");
if ("0".equals(resultCode)) { if ("0".equals(resultCode)) {
sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,nodeId,nodeName,userid,requestObject.toJSONString(),resultCode,"",zhjkbs); sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,currentNodeId,currentNodeName,currentUserId,requestObject.toJSONString(),resultCode,"",zhjkbs);
}else{ }else{
String resultmsg = msgObject.getString("resultMsg"); String resultmsg = msgObject.getString("resultMsg");
sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,nodeId,nodeName,userid,requestObject.toJSONString(),resultCode,resultmsg,zhjkbs); sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,currentNodeId,currentNodeName,currentUserId,requestObject.toJSONString(),resultCode,resultmsg,zhjkbs);
} }
} }
} }
@ -700,13 +722,15 @@ public class SendPortalMonitorUtil {
e.printStackTrace(); e.printStackTrace();
} }
} }
}
}
/*** /***
* intervention * intervention
*/ */
public void monitorIntervention(String requestid,String userid){ public void monitorIntervention(String requestid,String currentUserId){
String portal_todourl = Constants.portal_todourl; String portal_todourl = Constants.portal_todourl;
String bpm_app_workflowurl = Constants.bpm_app_workflowurl; String bpm_app_workflowurl = Constants.bpm_app_workflowurl;
@ -766,8 +790,9 @@ public class SendPortalMonitorUtil {
String requestname = "" ; String requestname = "" ;
String workflowname = "" ; String workflowname = "" ;
String nodeId = "" ; String currentNodeId = "" ;
String nodeName = "" ; String currentNodeName = "" ;
String sql =" select t1.requestname,t1.currentnodeid as nodeid,d1.nodename,t3.workflowname\n" + String sql =" select t1.requestname,t1.currentnodeid as nodeid,d1.nodename,t3.workflowname\n" +
" from workflow_requestbase t1\n" + " from workflow_requestbase t1\n" +
" inner join workflow_base t3 on t1.workflowid = t3.id\n" + " inner join workflow_base t3 on t1.workflowid = t3.id\n" +
@ -781,14 +806,14 @@ public class SendPortalMonitorUtil {
if (rs.next()){ if (rs.next()){
requestname = Util.null2String(rs.getString("requestname")) ; requestname = Util.null2String(rs.getString("requestname")) ;
workflowname = Util.null2String(rs.getString("workflowname")) ; workflowname = Util.null2String(rs.getString("workflowname")) ;
nodeId = Util.null2String(rs.getString("nodeid")) ; currentNodeId = Util.null2String(rs.getString("nodeid")) ;
nodeName = Util.null2String(rs.getString("nodeName")) ; currentNodeName = Util.null2String(rs.getString("nodeName")) ;
} }
requestObject.put("center",center); requestObject.put("center",center);
requestObject.put("title",requestname); requestObject.put("title",requestname);
requestObject.put("taskCode","weaver"+requestid); requestObject.put("taskCode","weaver"+requestid);
requestObject.put("nodeId",nodeId); requestObject.put("nodeId",currentNodeId);
requestObject.put("taskType",taskType); requestObject.put("taskType",taskType);
requestObject.put("actionType",actionType); requestObject.put("actionType",actionType);
requestObject.put("createDate",processTime); requestObject.put("createDate",processTime);
@ -798,7 +823,7 @@ public class SendPortalMonitorUtil {
requestObject.put("urlPc",urlPc); requestObject.put("urlPc",urlPc);
requestObject.put("urlApp",urlApp); requestObject.put("urlApp",urlApp);
requestObject.put("urlDing",urlDing); requestObject.put("urlDing",urlDing);
requestObject.put("nodeName",nodeName); requestObject.put("nodeName",currentNodeName);
requestObject.put("ticketType",workflowname); requestObject.put("ticketType",workflowname);
JSONArray taskObjectList = new JSONArray(); JSONArray taskObjectList = new JSONArray();
@ -843,10 +868,10 @@ public class SendPortalMonitorUtil {
if (msgObject.containsKey("resultCode")) { if (msgObject.containsKey("resultCode")) {
String resultCode = msgObject.getString("resultCode"); String resultCode = msgObject.getString("resultCode");
if ("0".equals(resultCode)) { if ("0".equals(resultCode)) {
sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,nodeId,nodeName,userid,requestObject.toJSONString(),resultCode,"",zhjkbs); sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,currentNodeId,currentNodeName,currentUserId,requestObject.toJSONString(),resultCode,"",zhjkbs);
}else{ }else{
String resultmsg = msgObject.getString("resultMsg"); String resultmsg = msgObject.getString("resultMsg");
sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,nodeId,nodeName,userid,requestObject.toJSONString(),resultCode,resultmsg,zhjkbs); sendPortalErrorUtil.doRecordPortalErrorInfo4Phase2(requestid,currentNodeId,currentNodeName,currentUserId,requestObject.toJSONString(),resultCode,resultmsg,zhjkbs);
} }
} }
} }

Write Preview
Loading…
Cancel
Save