#EC_HJ2# 去掉测试开发的代码及使用配置文件替换代码固定的地址
parent
32b9414a31
commit
1d0118db4a
@ -1,573 +0,0 @@
|
||||
package com.customization.sendtodo;
|
||||
|
||||
import com.alibaba.fastjson.JSONArray;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import com.engine.core.cfg.annotation.CommandDynamicProxy;
|
||||
import com.engine.core.interceptor.AbstractCommandProxy;
|
||||
import com.engine.core.interceptor.Command;
|
||||
import com.engine.workflow.cmd.requestForm.ForwardSubmitCmd;
|
||||
import com.engine.workflow.cmd.requestForm.RequestSubmitCmd;
|
||||
import com.engine.workflow.entity.requestForm.RequestOperationResultBean;
|
||||
import weaver.conn.RecordSet;
|
||||
import weaver.general.BaseBean;
|
||||
import weaver.general.Util;
|
||||
import weaver.hrm.User;
|
||||
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
import java.util.Enumeration;
|
||||
import java.util.Map;
|
||||
|
||||
/***
|
||||
* 转发、转办、意见征询
|
||||
*/
|
||||
@CommandDynamicProxy(target = ForwardSubmitCmd.class, desc="流程转发后给门户发送代办消息")
|
||||
public class ForwardPortalTodoCmd extends AbstractCommandProxy<Map<String,Object>> {
|
||||
@Override
|
||||
public Map<String, Object> execute(Command<Map<String, Object>> targetCommand) {
|
||||
//获取到被代理对象
|
||||
ForwardSubmitCmd forwardSubmitCmd = (ForwardSubmitCmd)targetCommand;
|
||||
//获取被代理对象的参数
|
||||
//对参数做预处理
|
||||
//requestSubmitCmd.writeLog("requestSubmitCmd params222======"+params);
|
||||
|
||||
BaseBean bb = new BaseBean();
|
||||
HttpServletRequest request = forwardSubmitCmd.getRequest();
|
||||
|
||||
|
||||
Enumeration<String> parameterNames = request.getParameterNames();
|
||||
if (null != parameterNames) {
|
||||
while (parameterNames.hasMoreElements()) {
|
||||
String parameterName = parameterNames.nextElement();
|
||||
String parameterValue = request.getParameter(parameterName);
|
||||
bb.writeLog(String.format("%s%s%s%s", "Request Parameter:"+ parameterName, "=>"+ parameterValue));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
// Enumeration<String> headerNames = request.getHeaderNames();
|
||||
// if (null != headerNames) {
|
||||
// while (headerNames.hasMoreElements()) {
|
||||
// String headerName = headerNames.nextElement();
|
||||
// String headerValue = request.getHeader(headerName);
|
||||
// System.out.println(String.format("%s%s%s%s", "Request Header:", headerName, "=>", headerValue));
|
||||
// }
|
||||
// }
|
||||
|
||||
|
||||
String requestid = Util.null2String(request.getParameter("requestid")).trim();
|
||||
String src = Util.null2String(request.getParameter("src")).trim();
|
||||
String nodeid = Util.null2String(request.getParameter("nodeid"));
|
||||
User user = forwardSubmitCmd.getUser();
|
||||
bb.writeLog("requestid:"+requestid);
|
||||
bb.writeLog("src:"+src);
|
||||
bb.writeLog("nodeid:"+nodeid);
|
||||
|
||||
//参数回写
|
||||
//执行标准的业务处理
|
||||
Map<String, Object> result = nextExecute(targetCommand);
|
||||
//对返回值做加工处理
|
||||
|
||||
String executeResult = Util.null2String(result.get("success"));
|
||||
|
||||
if("SUCCESS".equals(executeResult)){
|
||||
sendTodoDataByCreater(requestid,user);
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
/***
|
||||
*
|
||||
* @param requestId
|
||||
* @param user
|
||||
*/
|
||||
public void sendTodoDataByCreater(String requestId,User user){
|
||||
|
||||
HttpReqUtils httpReqUtils = new HttpReqUtils();
|
||||
BaseBean bb = new BaseBean();
|
||||
RecordSet rs = new RecordSet();
|
||||
String center = "MCCM";
|
||||
String actionType = "0" ;
|
||||
String terminal = "1" ;
|
||||
String ticketType = center ;
|
||||
|
||||
JSONObject requestObject = new JSONObject();
|
||||
try {
|
||||
int userid = user.getUID();
|
||||
String sql =" select t1.requestname,t1.requestmark,t1.creater,t2.nodeid,t1.createdate,t1.createtime,h1.lastname,h1.loginid,\n" +
|
||||
" t1.requestid as taskcode,d1.nodename\n" +
|
||||
" from workflow_requestbase t1\n" +
|
||||
" inner join workflow_currentoperator t2 on t1.requestid = t2.requestid\n" +
|
||||
" inner join workflow_base t3 on t1.workflowid = t3.id\n" +
|
||||
" left join workflow_nodebase d1 on d1.id = t1.currentnodeid "+
|
||||
" left join (select id, lastname,loginid from hrmresource where status = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t1.creater\n" +
|
||||
" where t2.userid in ("+userid+") \n" +
|
||||
" and (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and ((t2.isremark = '0' and (t2.takisremark is null or t2.takisremark = 0)) or t2.isremark in ('1', '5', '8', '9', '7', '11'))\n" +
|
||||
" and (ifnull(t1.currentstatus, -1) = -1 or (ifnull(t1.currentstatus, -1) = 0 and t1.creater in ("+userid+"))) \n" +
|
||||
" and t2.islasttimes = 1 \n" +
|
||||
" and (t2.isprocessing = '' or t2.isprocessing is null) \n" +
|
||||
"and t2.requestid = "+requestId ;
|
||||
|
||||
rs.executeQuery(sql);
|
||||
if (rs.next()){
|
||||
|
||||
String title = Util.null2String(rs.getString("requestname")) ;
|
||||
String creator = Util.null2String(rs.getString("loginid")) ;
|
||||
String taskCode = Util.null2String(rs.getString("taskcode")) ;
|
||||
String nodeId = Util.null2String(rs.getString("nodeid")) ;
|
||||
|
||||
String createdate = Util.null2String(rs.getString("createdate")) ;
|
||||
String createtime = Util.null2String(rs.getString("createtime")) ;
|
||||
String messageTitle = Util.null2String(rs.getString("requestname")) ;
|
||||
String messageContent = Util.null2String(rs.getString("requestname")) ;
|
||||
|
||||
String taskType = "0";
|
||||
|
||||
String urlPc = "[newtab]http://172.16.25.133/bpm/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestId ;
|
||||
String urlApp = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestId;
|
||||
String urlDing = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestId;
|
||||
String nodeName = Util.null2String(rs.getString("nodeName")) ;
|
||||
|
||||
|
||||
|
||||
requestObject.put("center",center);
|
||||
requestObject.put("title",title);
|
||||
requestObject.put("creator",creator);
|
||||
requestObject.put("taskCode",taskCode);
|
||||
requestObject.put("nodeId",nodeId);
|
||||
requestObject.put("taskType",taskType);
|
||||
requestObject.put("actionType",actionType);
|
||||
requestObject.put("createDate",createdate+" "+createtime);
|
||||
requestObject.put("messageTitle",messageTitle);
|
||||
requestObject.put("messageContent",messageContent);
|
||||
requestObject.put("terminal",terminal);
|
||||
requestObject.put("urlPc",urlPc);
|
||||
requestObject.put("urlApp",urlApp);
|
||||
requestObject.put("urlDing",urlDing);
|
||||
requestObject.put("nodeName",nodeName);
|
||||
requestObject.put("ticketType",ticketType);
|
||||
|
||||
|
||||
JSONArray taskObjectList = new JSONArray();
|
||||
JSONObject taskObject = new JSONObject();
|
||||
String objectAction = "0" ;
|
||||
String objectType = "0";
|
||||
String objectCode = creator ;
|
||||
String objectId = "" ;
|
||||
String operatorCode = creator ;
|
||||
|
||||
taskObject.put("objectAction",objectAction);
|
||||
taskObject.put("objectType",objectType);
|
||||
taskObject.put("objectCode",objectCode);
|
||||
taskObject.put("objectId",objectId);
|
||||
taskObject.put("operatorCode",operatorCode);
|
||||
taskObjectList.add(taskObject);
|
||||
|
||||
requestObject.put("taskObjectList",taskObjectList);
|
||||
}
|
||||
|
||||
//String url,String jsonstr,String head_param
|
||||
|
||||
bb.writeLog("dataJsonnew:"+requestObject.toJSONString());
|
||||
|
||||
String username = "admin";
|
||||
String passwd = "Uportal_123";
|
||||
String todourl = "http://172.16.25.133/portal-web/centerTodo/sync" ;
|
||||
String auth = username + ":" + passwd;
|
||||
String msgdata = httpReqUtils.doPostByAuth2(requestObject.toJSONString());
|
||||
bb.writeLog("msgdata:"+msgdata);
|
||||
if(!"".equals(msgdata)){
|
||||
JSONObject msgObject = JSONObject.parseObject(msgdata);
|
||||
}
|
||||
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
/***
|
||||
*
|
||||
* @param requestid
|
||||
* @param noideid
|
||||
* @param user
|
||||
*/
|
||||
public void sendTodoDataByCreateNode(String requestid,String noideid,User user){
|
||||
|
||||
HttpReqUtils httpReqUtils = new HttpReqUtils();
|
||||
JSONObject requestObject = new JSONObject();
|
||||
|
||||
BaseBean bb = new BaseBean();
|
||||
bb.writeLog("sendTodoDataByCreateNode");
|
||||
RecordSet rs = new RecordSet();
|
||||
String center = "MCCM";
|
||||
String ticketType = center ;
|
||||
String terminal = "1" ;
|
||||
try {
|
||||
|
||||
String currentnodetype = "" ;
|
||||
String sql = " select currentnodetype from workflow_requestbase where requestid="+requestid;
|
||||
rs.executeQuery(sql);
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
if (rs.next()){
|
||||
currentnodetype = Util.null2String(rs.getString("CURRENTNODETYPE"));
|
||||
}
|
||||
bb.writeLog("sendTodoDataByNode--currentnodetype:"+currentnodetype);
|
||||
if("3".equals(currentnodetype)){
|
||||
String actionType = "3" ;
|
||||
|
||||
}else{
|
||||
|
||||
String actionType = "0" ;
|
||||
|
||||
JSONArray taskObjectList = new JSONArray();
|
||||
|
||||
sql = " select t1.requestname,t1.requestmark,t1.creater,t1.createdate,t1.createtime,h1.lastname,h1.loginid,\n" +
|
||||
" t1.requestid as taskCode,t1.currentnodeid as nodeid,d1.nodename\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 "+
|
||||
" left join (select id, lastname,loginid from hrmresource where status = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t1.creater\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and t1.requestid = "+requestid ;
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
if (rs.next()){
|
||||
|
||||
String title = Util.null2String(rs.getString("requestname")) ;
|
||||
String creator = Util.null2String(rs.getString("loginid")) ;
|
||||
String taskCode = Util.null2String(rs.getString("taskcode")) ;
|
||||
String nodeId = Util.null2String(rs.getString("nodeid")) ;
|
||||
|
||||
String createdate = Util.null2String(rs.getString("createdate")) ;
|
||||
String createtime = Util.null2String(rs.getString("createtime")) ;
|
||||
String messageTitle = Util.null2String(rs.getString("requestname")) ;
|
||||
String messageContent = Util.null2String(rs.getString("requestname")) ;
|
||||
|
||||
String taskType = "0";
|
||||
|
||||
String urlPc = "[newtab]http://172.16.25.133/bpm/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
|
||||
String urlApp = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid;
|
||||
String urlDing = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid;
|
||||
String nodeName = Util.null2String(rs.getString("nodeName")) ;
|
||||
|
||||
requestObject.put("center",center);
|
||||
requestObject.put("title",title);
|
||||
requestObject.put("creator",creator);
|
||||
requestObject.put("taskCode",taskCode);
|
||||
requestObject.put("nodeId",nodeId);
|
||||
requestObject.put("taskType",taskType);
|
||||
requestObject.put("actionType",actionType);
|
||||
requestObject.put("createDate",createdate+" "+createtime);
|
||||
requestObject.put("messageTitle",messageTitle);
|
||||
requestObject.put("messageContent",messageContent);
|
||||
requestObject.put("terminal",terminal);
|
||||
requestObject.put("urlPc",urlPc);
|
||||
requestObject.put("urlApp",urlApp);
|
||||
requestObject.put("urlDing",urlDing);
|
||||
requestObject.put("nodeName",nodeName);
|
||||
requestObject.put("ticketType",ticketType);
|
||||
}
|
||||
|
||||
sql = " select t2.userid,h1.loginid\n" +
|
||||
" from workflow_requestbase t1\n" +
|
||||
" inner join workflow_currentoperator t2 on t1.requestid = t2.requestid\n" +
|
||||
" left join (select id, lastname,loginid from hrmresource where STATUS = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t2.userid\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and ((t2.isremark = '0' and (t2.takisremark is null or t2.takisremark = 0)) or t2.isremark in ('1', '5', '8', '9', '7', '11'))\n" +
|
||||
" and t2.islasttimes = 1\n" +
|
||||
" and (t2.isprocessing = '' or t2.isprocessing is null)\n" +
|
||||
" and t2.REQUESTID = "+requestid;
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
while (rs.next()){
|
||||
|
||||
String usercode = Util.null2String(rs.getString("loginid")) ;
|
||||
JSONObject taskObject = new JSONObject();
|
||||
String objectAction = "0" ;
|
||||
String objectType = "0";
|
||||
String objectCode = usercode ;
|
||||
String objectId = "" ;
|
||||
String operatorCode = usercode ;
|
||||
|
||||
taskObject.put("objectAction",objectAction);
|
||||
taskObject.put("objectType",objectType);
|
||||
taskObject.put("objectCode",objectCode);
|
||||
taskObject.put("objectId",objectId);
|
||||
taskObject.put("operatorCode",operatorCode);
|
||||
taskObjectList.add(taskObject);
|
||||
}
|
||||
|
||||
requestObject.put("taskObjectList",taskObjectList);
|
||||
|
||||
|
||||
String username = "admin";
|
||||
String passwd = "Uportal_123";
|
||||
String todourl = "http://172.16.25.133/portal-web/centerTodo/sync" ;
|
||||
String auth = username + ":" + passwd;
|
||||
|
||||
bb.writeLog("requestObject:"+requestObject.toJSONString());
|
||||
String msgdata = httpReqUtils.doPostByAuth2(requestObject.toJSONString());
|
||||
bb.writeLog("msgdata:"+msgdata);
|
||||
if(!"".equals(msgdata)){
|
||||
JSONObject msgObject = JSONObject.parseObject(msgdata);
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
/***
|
||||
*
|
||||
* @param requestid
|
||||
* @param noideid
|
||||
* @param user
|
||||
*/
|
||||
public void sendTodoDataByNode(String requestid,String noideid,User user){
|
||||
|
||||
HttpReqUtils httpReqUtils = new HttpReqUtils();
|
||||
JSONObject requestObject = new JSONObject();
|
||||
|
||||
BaseBean bb = new BaseBean();
|
||||
bb.writeLog("sendTodoDataByNode");
|
||||
RecordSet rs = new RecordSet();
|
||||
String center = "MCCM";
|
||||
String ticketType = center ;
|
||||
String terminal = "1" ;
|
||||
try {
|
||||
|
||||
String currentnodetype = "" ;
|
||||
String sql = " select currentnodetype from workflow_requestbase where requestid="+requestid;
|
||||
rs.executeQuery(sql);
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
if (rs.next()){
|
||||
currentnodetype = Util.null2String(rs.getString("CURRENTNODETYPE"));
|
||||
}
|
||||
bb.writeLog("sendTodoDataByNode--currentnodetype:"+currentnodetype);
|
||||
if("3".equals(currentnodetype)){
|
||||
String actionType = "3" ;
|
||||
|
||||
}else{
|
||||
|
||||
String actionType = "" ;
|
||||
int count = 0 ;
|
||||
sql = " select t2.userid,h1.loginid\n" +
|
||||
" from workflow_requestbase t1\n" +
|
||||
" inner join workflow_currentoperator t2 on t1.requestid = t2.requestid\n" +
|
||||
" left join (select id, lastname,loginid from hrmresource where status = 1 union all select id,lastname,loginid from hrmresourcemanager ) h1 on h1.id = t2.userid\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and ((t2.isremark = '0' and (t2.takisremark is null or t2.takisremark = 0)) or t2.isremark in ('1', '5', '8', '9', '7', '11'))\n" +
|
||||
" and t2.islasttimes = 1\n" +
|
||||
" and (t2.isprocessing = '' or t2.isprocessing is null)\n" +
|
||||
" and t2.REQUESTID = "+requestid+
|
||||
" and t2.nodeid = " + noideid ;
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
while (rs.next()){
|
||||
count++;
|
||||
}
|
||||
bb.writeLog("sendTodoDataByNode--count:"+count);
|
||||
if(count >0){
|
||||
|
||||
JSONArray taskObjectList = new JSONArray();
|
||||
actionType = "1" ;
|
||||
|
||||
sql = " select t1.requestname,t1.requestmark,t1.creater,t1.createdate,t1.createtime,h1.lastname,h1.loginid,\n" +
|
||||
" t1.requestid as taskCode,t1.currentnodeid as nodeid,d1.nodename\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 "+
|
||||
" left join (select id, lastname,loginid from hrmresource where status = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t1.creater\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and t1.requestid = "+requestid +
|
||||
" and t1.currentnodeid = " + noideid ;
|
||||
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
|
||||
rs.executeQuery(sql);
|
||||
if (rs.next()){
|
||||
|
||||
String title = Util.null2String(rs.getString("requestname")) ;
|
||||
String creator = Util.null2String(rs.getString("loginid")) ;
|
||||
String taskCode = Util.null2String(rs.getString("taskcode")) ;
|
||||
String nodeId = Util.null2String(rs.getString("nodeid")) ;
|
||||
|
||||
String createdate = Util.null2String(rs.getString("createdate")) ;
|
||||
String createtime = Util.null2String(rs.getString("createtime")) ;
|
||||
String messageTitle = Util.null2String(rs.getString("requestname")) ;
|
||||
String messageContent = Util.null2String(rs.getString("requestname")) ;
|
||||
|
||||
String taskType = "0";
|
||||
|
||||
String urlPc = "[newtab]http://172.16.25.133/bpm/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
|
||||
String urlApp = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid;
|
||||
String urlDing = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid;
|
||||
String nodeName = Util.null2String(rs.getString("nodeName")) ;
|
||||
|
||||
|
||||
requestObject.put("center",center);
|
||||
requestObject.put("title",title);
|
||||
requestObject.put("creator",creator);
|
||||
requestObject.put("taskCode",taskCode);
|
||||
requestObject.put("nodeId",nodeId);
|
||||
requestObject.put("taskType",taskType);
|
||||
requestObject.put("actionType",actionType);
|
||||
requestObject.put("createDate",createdate+" "+createtime);
|
||||
requestObject.put("messageTitle",messageTitle);
|
||||
requestObject.put("messageContent",messageContent);
|
||||
requestObject.put("terminal",terminal);
|
||||
requestObject.put("urlPc",urlPc);
|
||||
requestObject.put("urlApp",urlApp);
|
||||
requestObject.put("urlDing",urlDing);
|
||||
requestObject.put("nodeName",nodeName);
|
||||
requestObject.put("ticketType",ticketType);
|
||||
}
|
||||
|
||||
JSONObject taskObject = new JSONObject();
|
||||
String objectAction = "1" ;
|
||||
String objectType = "0";
|
||||
String objectCode = user.getLoginid() ;
|
||||
String objectId = "" ;
|
||||
String operatorCode = user.getLoginid() ;
|
||||
|
||||
taskObject.put("objectAction",objectAction);
|
||||
taskObject.put("objectType",objectType);
|
||||
taskObject.put("objectCode",objectCode);
|
||||
taskObject.put("objectId",objectId);
|
||||
taskObject.put("operatorCode",operatorCode);
|
||||
taskObjectList.add(taskObject);
|
||||
requestObject.put("taskObjectList",taskObjectList);
|
||||
|
||||
}else{
|
||||
|
||||
JSONArray taskObjectList = new JSONArray();
|
||||
actionType = "2" ;
|
||||
|
||||
sql = " select t1.requestname,t1.requestmark,t1.creater,t1.createdate,t1.createtime,h1.lastname,h1.loginid,\n" +
|
||||
" t1.requestid as taskCode,t1.currentnodeid as nodeid,d1.nodename\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 "+
|
||||
" left join (select id, lastname,loginid from hrmresource where status = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t1.creater\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and t1.requestid = "+requestid ;
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
if (rs.next()){
|
||||
|
||||
String title = Util.null2String(rs.getString("requestname")) ;
|
||||
String creator = Util.null2String(rs.getString("loginid")) ;
|
||||
String taskCode = Util.null2String(rs.getString("taskcode")) ;
|
||||
String nodeId = Util.null2String(rs.getString("nodeid")) ;
|
||||
|
||||
String createdate = Util.null2String(rs.getString("createdate")) ;
|
||||
String createtime = Util.null2String(rs.getString("createtime")) ;
|
||||
String messageTitle = Util.null2String(rs.getString("requestname")) ;
|
||||
String messageContent = Util.null2String(rs.getString("requestname")) ;
|
||||
|
||||
String taskType = "0";
|
||||
|
||||
String urlPc = "[newtab]http://172.16.25.133/bpm/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
|
||||
String urlApp = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid;
|
||||
String urlDing = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid;
|
||||
String nodeName = Util.null2String(rs.getString("nodeName")) ;
|
||||
|
||||
requestObject.put("center",center);
|
||||
requestObject.put("title",title);
|
||||
requestObject.put("creator",creator);
|
||||
requestObject.put("taskCode",taskCode);
|
||||
requestObject.put("nodeId",nodeId);
|
||||
requestObject.put("taskType",taskType);
|
||||
requestObject.put("actionType",actionType);
|
||||
requestObject.put("createDate",createdate+" "+createtime);
|
||||
requestObject.put("messageTitle",messageTitle);
|
||||
requestObject.put("messageContent",messageContent);
|
||||
requestObject.put("terminal",terminal);
|
||||
requestObject.put("urlPc",urlPc);
|
||||
requestObject.put("urlApp",urlApp);
|
||||
requestObject.put("urlDing",urlDing);
|
||||
requestObject.put("nodeName",nodeName);
|
||||
requestObject.put("ticketType",ticketType);
|
||||
}
|
||||
|
||||
// sql = " select t2.userid,h1.loginid\n" +
|
||||
// " from workflow_requestbase t1\n" +
|
||||
// " inner join workflow_currentoperator t2 on t1.requestid = t2.requestid\n" +
|
||||
// " left join (select id, lastname,loginid from hrmresource where STATUS = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t2.userid\n" +
|
||||
// " where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
// " and t2.REQUESTID = "+requestid+
|
||||
// " and t2.nodeid = " + noideid ;
|
||||
// bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
// rs.executeQuery(sql);
|
||||
// while (rs.next()){
|
||||
// JSONObject taskObject = new JSONObject();
|
||||
// String objectAction = "1" ;
|
||||
// String objectType = "0";
|
||||
// String objectCode = user.getLoginid() ;
|
||||
// String objectId = "" ;
|
||||
// String operatorCode = user.getLoginid() ;
|
||||
//
|
||||
// taskObject.put("objectAction",objectAction);
|
||||
// taskObject.put("objectType",objectType);
|
||||
// taskObject.put("objectCode",objectCode);
|
||||
// taskObject.put("objectId",objectId);
|
||||
// taskObject.put("operatorCode",operatorCode);
|
||||
// taskObjectList.add(taskObject);
|
||||
// }
|
||||
|
||||
sql = " select t2.userid,h1.loginid\n" +
|
||||
" from workflow_requestbase t1\n" +
|
||||
" inner join workflow_currentoperator t2 on t1.requestid = t2.requestid\n" +
|
||||
" left join (select id, lastname,loginid from hrmresource where STATUS = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t2.userid\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and ((t2.isremark = '0' and (t2.takisremark is null or t2.takisremark = 0)) or t2.isremark in ('1', '5', '8', '9', '7', '11'))\n" +
|
||||
" and t2.islasttimes = 1\n" +
|
||||
" and (t2.isprocessing = '' or t2.isprocessing is null)\n" +
|
||||
" and t2.REQUESTID = "+requestid;
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
while (rs.next()){
|
||||
|
||||
String usercode = Util.null2String(rs.getString("loginid")) ;
|
||||
JSONObject taskObject = new JSONObject();
|
||||
String objectAction = "0" ;
|
||||
String objectType = "0";
|
||||
String objectCode = usercode ;
|
||||
String objectId = "" ;
|
||||
String operatorCode = usercode ;
|
||||
|
||||
taskObject.put("objectAction",objectAction);
|
||||
taskObject.put("objectType",objectType);
|
||||
taskObject.put("objectCode",objectCode);
|
||||
taskObject.put("objectId",objectId);
|
||||
taskObject.put("operatorCode",operatorCode);
|
||||
taskObjectList.add(taskObject);
|
||||
}
|
||||
|
||||
requestObject.put("taskObjectList",taskObjectList);
|
||||
}
|
||||
|
||||
String username = "admin";
|
||||
String passwd = "Uportal_123";
|
||||
String todourl = "http://172.16.25.133/portal-web/centerTodo/sync" ;
|
||||
String auth = username + ":" + passwd;
|
||||
|
||||
bb.writeLog("requestObject:"+requestObject.toJSONString());
|
||||
String msgdata = httpReqUtils.doPostByAuth2(requestObject.toJSONString());
|
||||
bb.writeLog("msgdata:"+msgdata);
|
||||
if(!"".equals(msgdata)){
|
||||
JSONObject msgObject = JSONObject.parseObject(msgdata);
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@ -1,563 +0,0 @@
|
||||
package com.customization.sendtodo;
|
||||
|
||||
import com.alibaba.fastjson.JSONArray;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import com.engine.core.cfg.annotation.CommandDynamicProxy;
|
||||
import com.engine.core.interceptor.AbstractCommandProxy;
|
||||
import com.engine.core.interceptor.Command;
|
||||
import com.engine.workflow.cmd.requestForm.RequestSubmitCmd;
|
||||
import com.engine.workflow.entity.requestForm.RequestOperationResultBean;
|
||||
import weaver.conn.RecordSet;
|
||||
import weaver.general.BaseBean;
|
||||
import weaver.general.Util;
|
||||
import weaver.hrm.User;
|
||||
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
import java.util.Map;
|
||||
|
||||
/***
|
||||
*
|
||||
*/
|
||||
@CommandDynamicProxy(target = RequestSubmitCmd.class, desc="流程提交后给门户发送代办消息")
|
||||
public class SubmitPortalTodoCmd extends AbstractCommandProxy<Map<String,Object>> {
|
||||
@Override
|
||||
public Map<String, Object> execute(Command<Map<String, Object>> targetCommand) {
|
||||
//获取到被代理对象
|
||||
RequestSubmitCmd requestSubmitCmd = (RequestSubmitCmd)targetCommand;
|
||||
//获取被代理对象的参数
|
||||
//对参数做预处理
|
||||
//requestSubmitCmd.writeLog("requestSubmitCmd params222======"+params);
|
||||
|
||||
BaseBean bb = new BaseBean();
|
||||
HttpServletRequest request = requestSubmitCmd.getRequest();
|
||||
String requestid = Util.null2String(request.getParameter("requestid")).trim();
|
||||
String workflowid = Util.null2String(request.getParameter("workflowid")).trim();
|
||||
String src = Util.null2String(request.getParameter("src")).trim();
|
||||
String nodeid = Util.null2String(request.getParameter("nodeid"));
|
||||
User user = requestSubmitCmd.getUser();
|
||||
bb.writeLog("requestid:"+requestid);
|
||||
bb.writeLog("workflowid:"+workflowid);
|
||||
bb.writeLog("src:"+src);
|
||||
bb.writeLog("nodeid:"+nodeid);
|
||||
|
||||
//参数回写
|
||||
//执行标准的业务处理
|
||||
Map<String, Object> result = nextExecute(targetCommand);
|
||||
//对返回值做加工处理
|
||||
RequestOperationResultBean resultBean = (RequestOperationResultBean) result.get("data");
|
||||
String executeResult = resultBean.getType().name();
|
||||
|
||||
String new_requestid = Util.null2String(resultBean.getResultInfo().get("requestid"));
|
||||
// String newRequestid = (String) result.get("newRequestid");
|
||||
bb.writeLog("new_requestid:"+new_requestid);
|
||||
// bb.writeLog("newRequestid:"+newRequestid);
|
||||
|
||||
if("SUCCESS".equals(executeResult)){
|
||||
|
||||
if(Util.getIntValue(requestid) == -1 && "save".equals(src)){
|
||||
sendTodoDataByCreater(new_requestid,user);
|
||||
}else if(Util.getIntValue(requestid) == -1 && "submit".equals(src)){
|
||||
sendTodoDataByCreateNode(new_requestid,nodeid,user);
|
||||
}else if(Util.getIntValue(requestid)> 0 && "submit".equals(src)){
|
||||
sendTodoDataByNode(requestid,nodeid,user);
|
||||
}
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
/***
|
||||
*
|
||||
* @param requestId
|
||||
* @param user
|
||||
*/
|
||||
public void sendTodoDataByCreater(String requestId,User user){
|
||||
|
||||
HttpReqUtils httpReqUtils = new HttpReqUtils();
|
||||
BaseBean bb = new BaseBean();
|
||||
RecordSet rs = new RecordSet();
|
||||
String center = "MCCM";
|
||||
String actionType = "0" ;
|
||||
String terminal = "1" ;
|
||||
String ticketType = center ;
|
||||
|
||||
JSONObject requestObject = new JSONObject();
|
||||
try {
|
||||
int userid = user.getUID();
|
||||
String sql =" select t1.requestname,t1.requestmark,t1.creater,t2.nodeid,t1.createdate,t1.createtime,h1.lastname,h1.loginid,\n" +
|
||||
" t1.requestid as taskcode,d1.nodename\n" +
|
||||
" from workflow_requestbase t1\n" +
|
||||
" inner join workflow_currentoperator t2 on t1.requestid = t2.requestid\n" +
|
||||
" inner join workflow_base t3 on t1.workflowid = t3.id\n" +
|
||||
" left join workflow_nodebase d1 on d1.id = t1.currentnodeid "+
|
||||
" left join (select id, lastname,loginid from hrmresource where status = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t1.creater\n" +
|
||||
" where t2.userid in ("+userid+") \n" +
|
||||
" and (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and ((t2.isremark = '0' and (t2.takisremark is null or t2.takisremark = 0)) or t2.isremark in ('1', '5', '8', '9', '7', '11'))\n" +
|
||||
" and (ifnull(t1.currentstatus, -1) = -1 or (ifnull(t1.currentstatus, -1) = 0 and t1.creater in ("+userid+"))) \n" +
|
||||
" and t2.islasttimes = 1 \n" +
|
||||
" and (t2.isprocessing = '' or t2.isprocessing is null) \n" +
|
||||
"and t2.requestid = "+requestId ;
|
||||
|
||||
rs.executeQuery(sql);
|
||||
if (rs.next()){
|
||||
|
||||
String title = Util.null2String(rs.getString("requestname")) ;
|
||||
String creator = Util.null2String(rs.getString("loginid")) ;
|
||||
String taskCode = Util.null2String(rs.getString("taskcode")) ;
|
||||
String nodeId = Util.null2String(rs.getString("nodeid")) ;
|
||||
|
||||
String createdate = Util.null2String(rs.getString("createdate")) ;
|
||||
String createtime = Util.null2String(rs.getString("createtime")) ;
|
||||
String messageTitle = Util.null2String(rs.getString("requestname")) ;
|
||||
String messageContent = Util.null2String(rs.getString("requestname")) ;
|
||||
|
||||
String taskType = "0";
|
||||
|
||||
String urlPc = "[newtab]http://172.16.25.133/bpm/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestId ;
|
||||
String urlApp = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestId;
|
||||
String urlDing = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestId;
|
||||
String nodeName = Util.null2String(rs.getString("nodeName")) ;
|
||||
|
||||
|
||||
|
||||
requestObject.put("center",center);
|
||||
requestObject.put("title",title);
|
||||
requestObject.put("creator",creator);
|
||||
requestObject.put("taskCode",taskCode);
|
||||
requestObject.put("nodeId",nodeId);
|
||||
requestObject.put("taskType",taskType);
|
||||
requestObject.put("actionType",actionType);
|
||||
requestObject.put("createDate",createdate+" "+createtime);
|
||||
requestObject.put("messageTitle",messageTitle);
|
||||
requestObject.put("messageContent",messageContent);
|
||||
requestObject.put("terminal",terminal);
|
||||
requestObject.put("urlPc",urlPc);
|
||||
requestObject.put("urlApp",urlApp);
|
||||
requestObject.put("urlDing",urlDing);
|
||||
requestObject.put("nodeName",nodeName);
|
||||
requestObject.put("ticketType",ticketType);
|
||||
|
||||
|
||||
JSONArray taskObjectList = new JSONArray();
|
||||
JSONObject taskObject = new JSONObject();
|
||||
String objectAction = "0" ;
|
||||
String objectType = "0";
|
||||
String objectCode = creator ;
|
||||
String objectId = "" ;
|
||||
String operatorCode = creator ;
|
||||
|
||||
taskObject.put("objectAction",objectAction);
|
||||
taskObject.put("objectType",objectType);
|
||||
taskObject.put("objectCode",objectCode);
|
||||
taskObject.put("objectId",objectId);
|
||||
taskObject.put("operatorCode",operatorCode);
|
||||
taskObjectList.add(taskObject);
|
||||
|
||||
requestObject.put("taskObjectList",taskObjectList);
|
||||
}
|
||||
|
||||
//String url,String jsonstr,String head_param
|
||||
|
||||
bb.writeLog("dataJsonnew:"+requestObject.toJSONString());
|
||||
|
||||
String username = "admin";
|
||||
String passwd = "Uportal_123";
|
||||
String todourl = "http://172.16.25.133/portal-web/centerTodo/sync" ;
|
||||
String auth = username + ":" + passwd;
|
||||
String msgdata = httpReqUtils.doPostByAuth2(requestObject.toJSONString());
|
||||
bb.writeLog("msgdata:"+msgdata);
|
||||
if(!"".equals(msgdata)){
|
||||
JSONObject msgObject = JSONObject.parseObject(msgdata);
|
||||
}
|
||||
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
/***
|
||||
*
|
||||
* @param requestid
|
||||
* @param noideid
|
||||
* @param user
|
||||
*/
|
||||
public void sendTodoDataByCreateNode(String requestid,String noideid,User user){
|
||||
|
||||
HttpReqUtils httpReqUtils = new HttpReqUtils();
|
||||
JSONObject requestObject = new JSONObject();
|
||||
|
||||
BaseBean bb = new BaseBean();
|
||||
bb.writeLog("sendTodoDataByCreateNode");
|
||||
RecordSet rs = new RecordSet();
|
||||
String center = "MCCM";
|
||||
String ticketType = center ;
|
||||
String terminal = "1" ;
|
||||
try {
|
||||
|
||||
String currentnodetype = "" ;
|
||||
String sql = " select currentnodetype from workflow_requestbase where requestid="+requestid;
|
||||
rs.executeQuery(sql);
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
if (rs.next()){
|
||||
currentnodetype = Util.null2String(rs.getString("CURRENTNODETYPE"));
|
||||
}
|
||||
bb.writeLog("sendTodoDataByNode--currentnodetype:"+currentnodetype);
|
||||
if("3".equals(currentnodetype)){
|
||||
String actionType = "3" ;
|
||||
|
||||
}else{
|
||||
|
||||
String actionType = "0" ;
|
||||
|
||||
JSONArray taskObjectList = new JSONArray();
|
||||
|
||||
sql = " select t1.requestname,t1.requestmark,t1.creater,t1.createdate,t1.createtime,h1.lastname,h1.loginid,\n" +
|
||||
" t1.requestid as taskCode,t1.currentnodeid as nodeid,d1.nodename\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 "+
|
||||
" left join (select id, lastname,loginid from hrmresource where status = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t1.creater\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and t1.requestid = "+requestid ;
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
if (rs.next()){
|
||||
|
||||
String title = Util.null2String(rs.getString("requestname")) ;
|
||||
String creator = Util.null2String(rs.getString("loginid")) ;
|
||||
String taskCode = Util.null2String(rs.getString("taskcode")) ;
|
||||
String nodeId = Util.null2String(rs.getString("nodeid")) ;
|
||||
|
||||
String createdate = Util.null2String(rs.getString("createdate")) ;
|
||||
String createtime = Util.null2String(rs.getString("createtime")) ;
|
||||
String messageTitle = Util.null2String(rs.getString("requestname")) ;
|
||||
String messageContent = Util.null2String(rs.getString("requestname")) ;
|
||||
|
||||
String taskType = "0";
|
||||
|
||||
String urlPc = "[newtab]http://172.16.25.133/bpm/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
|
||||
String urlApp = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid;
|
||||
String urlDing = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid;
|
||||
String nodeName = Util.null2String(rs.getString("nodeName")) ;
|
||||
|
||||
requestObject.put("center",center);
|
||||
requestObject.put("title",title);
|
||||
requestObject.put("creator",creator);
|
||||
requestObject.put("taskCode",taskCode);
|
||||
requestObject.put("nodeId",nodeId);
|
||||
requestObject.put("taskType",taskType);
|
||||
requestObject.put("actionType",actionType);
|
||||
requestObject.put("createDate",createdate+" "+createtime);
|
||||
requestObject.put("messageTitle",messageTitle);
|
||||
requestObject.put("messageContent",messageContent);
|
||||
requestObject.put("terminal",terminal);
|
||||
requestObject.put("urlPc",urlPc);
|
||||
requestObject.put("urlApp",urlApp);
|
||||
requestObject.put("urlDing",urlDing);
|
||||
requestObject.put("nodeName",nodeName);
|
||||
requestObject.put("ticketType",ticketType);
|
||||
}
|
||||
|
||||
sql = " select t2.userid,h1.loginid\n" +
|
||||
" from workflow_requestbase t1\n" +
|
||||
" inner join workflow_currentoperator t2 on t1.requestid = t2.requestid\n" +
|
||||
" left join (select id, lastname,loginid from hrmresource where STATUS = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t2.userid\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and ((t2.isremark = '0' and (t2.takisremark is null or t2.takisremark = 0)) or t2.isremark in ('1', '5', '8', '9', '7', '11'))\n" +
|
||||
" and t2.islasttimes = 1\n" +
|
||||
" and (t2.isprocessing = '' or t2.isprocessing is null)\n" +
|
||||
" and t2.REQUESTID = "+requestid;
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
while (rs.next()){
|
||||
|
||||
String usercode = Util.null2String(rs.getString("loginid")) ;
|
||||
JSONObject taskObject = new JSONObject();
|
||||
String objectAction = "0" ;
|
||||
String objectType = "0";
|
||||
String objectCode = usercode ;
|
||||
String objectId = "" ;
|
||||
String operatorCode = usercode ;
|
||||
|
||||
taskObject.put("objectAction",objectAction);
|
||||
taskObject.put("objectType",objectType);
|
||||
taskObject.put("objectCode",objectCode);
|
||||
taskObject.put("objectId",objectId);
|
||||
taskObject.put("operatorCode",operatorCode);
|
||||
taskObjectList.add(taskObject);
|
||||
}
|
||||
|
||||
requestObject.put("taskObjectList",taskObjectList);
|
||||
|
||||
|
||||
String username = "admin";
|
||||
String passwd = "Uportal_123";
|
||||
String todourl = "http://172.16.25.133/portal-web/centerTodo/sync" ;
|
||||
String auth = username + ":" + passwd;
|
||||
|
||||
bb.writeLog("requestObject:"+requestObject.toJSONString());
|
||||
String msgdata = httpReqUtils.doPostByAuth2(requestObject.toJSONString());
|
||||
bb.writeLog("msgdata:"+msgdata);
|
||||
if(!"".equals(msgdata)){
|
||||
JSONObject msgObject = JSONObject.parseObject(msgdata);
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
/***
|
||||
*
|
||||
* @param requestid
|
||||
* @param noideid
|
||||
* @param user
|
||||
*/
|
||||
public void sendTodoDataByNode(String requestid,String noideid,User user){
|
||||
|
||||
HttpReqUtils httpReqUtils = new HttpReqUtils();
|
||||
JSONObject requestObject = new JSONObject();
|
||||
|
||||
BaseBean bb = new BaseBean();
|
||||
bb.writeLog("sendTodoDataByNode");
|
||||
RecordSet rs = new RecordSet();
|
||||
String center = "MCCM";
|
||||
String ticketType = center ;
|
||||
String terminal = "1" ;
|
||||
try {
|
||||
|
||||
String currentnodetype = "" ;
|
||||
String sql = " select currentnodetype from workflow_requestbase where requestid="+requestid;
|
||||
rs.executeQuery(sql);
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
if (rs.next()){
|
||||
currentnodetype = Util.null2String(rs.getString("CURRENTNODETYPE"));
|
||||
}
|
||||
bb.writeLog("sendTodoDataByNode--currentnodetype:"+currentnodetype);
|
||||
if("3".equals(currentnodetype)){
|
||||
String actionType = "3" ;
|
||||
|
||||
}else{
|
||||
|
||||
String actionType = "" ;
|
||||
int count = 0 ;
|
||||
sql = " select t2.userid,h1.loginid\n" +
|
||||
" from workflow_requestbase t1\n" +
|
||||
" inner join workflow_currentoperator t2 on t1.requestid = t2.requestid\n" +
|
||||
" left join (select id, lastname,loginid from hrmresource where status = 1 union all select id,lastname,loginid from hrmresourcemanager ) h1 on h1.id = t2.userid\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and ((t2.isremark = '0' and (t2.takisremark is null or t2.takisremark = 0)) or t2.isremark in ('1', '5', '8', '9', '7', '11'))\n" +
|
||||
" and t2.islasttimes = 1\n" +
|
||||
" and (t2.isprocessing = '' or t2.isprocessing is null)\n" +
|
||||
" and t2.REQUESTID = "+requestid+
|
||||
" and t2.nodeid = " + noideid ;
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
while (rs.next()){
|
||||
count++;
|
||||
}
|
||||
bb.writeLog("sendTodoDataByNode--count:"+count);
|
||||
if(count >0){
|
||||
|
||||
JSONArray taskObjectList = new JSONArray();
|
||||
actionType = "1" ;
|
||||
|
||||
sql = " select t1.requestname,t1.requestmark,t1.creater,t1.createdate,t1.createtime,h1.lastname,h1.loginid,\n" +
|
||||
" t1.requestid as taskCode,t1.currentnodeid as nodeid,d1.nodename\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 "+
|
||||
" left join (select id, lastname,loginid from hrmresource where status = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t1.creater\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and t1.requestid = "+requestid +
|
||||
" and t1.currentnodeid = " + noideid ;
|
||||
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
|
||||
rs.executeQuery(sql);
|
||||
if (rs.next()){
|
||||
|
||||
String title = Util.null2String(rs.getString("requestname")) ;
|
||||
String creator = Util.null2String(rs.getString("loginid")) ;
|
||||
String taskCode = Util.null2String(rs.getString("taskcode")) ;
|
||||
String nodeId = Util.null2String(rs.getString("nodeid")) ;
|
||||
|
||||
String createdate = Util.null2String(rs.getString("createdate")) ;
|
||||
String createtime = Util.null2String(rs.getString("createtime")) ;
|
||||
String messageTitle = Util.null2String(rs.getString("requestname")) ;
|
||||
String messageContent = Util.null2String(rs.getString("requestname")) ;
|
||||
|
||||
String taskType = "0";
|
||||
|
||||
String urlPc = "[newtab]http://172.16.25.133/bpm/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
|
||||
String urlApp = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid;
|
||||
String urlDing = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid;
|
||||
String nodeName = Util.null2String(rs.getString("nodeName")) ;
|
||||
|
||||
|
||||
requestObject.put("center",center);
|
||||
requestObject.put("title",title);
|
||||
requestObject.put("creator",creator);
|
||||
requestObject.put("taskCode",taskCode);
|
||||
requestObject.put("nodeId",nodeId);
|
||||
requestObject.put("taskType",taskType);
|
||||
requestObject.put("actionType",actionType);
|
||||
requestObject.put("createDate",createdate+" "+createtime);
|
||||
requestObject.put("messageTitle",messageTitle);
|
||||
requestObject.put("messageContent",messageContent);
|
||||
requestObject.put("terminal",terminal);
|
||||
requestObject.put("urlPc",urlPc);
|
||||
requestObject.put("urlApp",urlApp);
|
||||
requestObject.put("urlDing",urlDing);
|
||||
requestObject.put("nodeName",nodeName);
|
||||
requestObject.put("ticketType",ticketType);
|
||||
}
|
||||
|
||||
JSONObject taskObject = new JSONObject();
|
||||
String objectAction = "1" ;
|
||||
String objectType = "0";
|
||||
String objectCode = user.getLoginid() ;
|
||||
String objectId = "" ;
|
||||
String operatorCode = user.getLoginid() ;
|
||||
|
||||
taskObject.put("objectAction",objectAction);
|
||||
taskObject.put("objectType",objectType);
|
||||
taskObject.put("objectCode",objectCode);
|
||||
taskObject.put("objectId",objectId);
|
||||
taskObject.put("operatorCode",operatorCode);
|
||||
taskObjectList.add(taskObject);
|
||||
requestObject.put("taskObjectList",taskObjectList);
|
||||
|
||||
}else{
|
||||
|
||||
JSONArray taskObjectList = new JSONArray();
|
||||
actionType = "2" ;
|
||||
|
||||
sql = " select t1.requestname,t1.requestmark,t1.creater,t1.createdate,t1.createtime,h1.lastname,h1.loginid,\n" +
|
||||
" t1.requestid as taskCode,t1.currentnodeid as nodeid,d1.nodename\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 "+
|
||||
" left join (select id, lastname,loginid from hrmresource where status = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t1.creater\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and t1.requestid = "+requestid ;
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
if (rs.next()){
|
||||
|
||||
String title = Util.null2String(rs.getString("requestname")) ;
|
||||
String creator = Util.null2String(rs.getString("loginid")) ;
|
||||
String taskCode = Util.null2String(rs.getString("taskcode")) ;
|
||||
String nodeId = Util.null2String(rs.getString("nodeid")) ;
|
||||
|
||||
String createdate = Util.null2String(rs.getString("createdate")) ;
|
||||
String createtime = Util.null2String(rs.getString("createtime")) ;
|
||||
String messageTitle = Util.null2String(rs.getString("requestname")) ;
|
||||
String messageContent = Util.null2String(rs.getString("requestname")) ;
|
||||
|
||||
String taskType = "0";
|
||||
|
||||
String urlPc = "[newtab]http://172.16.25.133/bpm/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
|
||||
String urlApp = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid;
|
||||
String urlDing = "[newtab]http://172.16.25.133/bpm/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid;
|
||||
String nodeName = Util.null2String(rs.getString("nodeName")) ;
|
||||
|
||||
requestObject.put("center",center);
|
||||
requestObject.put("title",title);
|
||||
requestObject.put("creator",creator);
|
||||
requestObject.put("taskCode",taskCode);
|
||||
requestObject.put("nodeId",nodeId);
|
||||
requestObject.put("taskType",taskType);
|
||||
requestObject.put("actionType",actionType);
|
||||
requestObject.put("createDate",createdate+" "+createtime);
|
||||
requestObject.put("messageTitle",messageTitle);
|
||||
requestObject.put("messageContent",messageContent);
|
||||
requestObject.put("terminal",terminal);
|
||||
requestObject.put("urlPc",urlPc);
|
||||
requestObject.put("urlApp",urlApp);
|
||||
requestObject.put("urlDing",urlDing);
|
||||
requestObject.put("nodeName",nodeName);
|
||||
requestObject.put("ticketType",ticketType);
|
||||
}
|
||||
|
||||
// sql = " select t2.userid,h1.loginid\n" +
|
||||
// " from workflow_requestbase t1\n" +
|
||||
// " inner join workflow_currentoperator t2 on t1.requestid = t2.requestid\n" +
|
||||
// " left join (select id, lastname,loginid from hrmresource where STATUS = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t2.userid\n" +
|
||||
// " where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
// " and t2.REQUESTID = "+requestid+
|
||||
// " and t2.nodeid = " + noideid ;
|
||||
// bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
// rs.executeQuery(sql);
|
||||
// while (rs.next()){
|
||||
// JSONObject taskObject = new JSONObject();
|
||||
// String objectAction = "1" ;
|
||||
// String objectType = "0";
|
||||
// String objectCode = user.getLoginid() ;
|
||||
// String objectId = "" ;
|
||||
// String operatorCode = user.getLoginid() ;
|
||||
//
|
||||
// taskObject.put("objectAction",objectAction);
|
||||
// taskObject.put("objectType",objectType);
|
||||
// taskObject.put("objectCode",objectCode);
|
||||
// taskObject.put("objectId",objectId);
|
||||
// taskObject.put("operatorCode",operatorCode);
|
||||
// taskObjectList.add(taskObject);
|
||||
// }
|
||||
|
||||
sql = " select t2.userid,h1.loginid\n" +
|
||||
" from workflow_requestbase t1\n" +
|
||||
" inner join workflow_currentoperator t2 on t1.requestid = t2.requestid\n" +
|
||||
" left join (select id, lastname,loginid from hrmresource where STATUS = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t2.userid\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and ((t2.isremark = '0' and (t2.takisremark is null or t2.takisremark = 0)) or t2.isremark in ('1', '5', '8', '9', '7', '11'))\n" +
|
||||
" and t2.islasttimes = 1\n" +
|
||||
" and (t2.isprocessing = '' or t2.isprocessing is null)\n" +
|
||||
" and t2.REQUESTID = "+requestid;
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
while (rs.next()){
|
||||
|
||||
String usercode = Util.null2String(rs.getString("loginid")) ;
|
||||
JSONObject taskObject = new JSONObject();
|
||||
String objectAction = "0" ;
|
||||
String objectType = "0";
|
||||
String objectCode = usercode ;
|
||||
String objectId = "" ;
|
||||
String operatorCode = usercode ;
|
||||
|
||||
taskObject.put("objectAction",objectAction);
|
||||
taskObject.put("objectType",objectType);
|
||||
taskObject.put("objectCode",objectCode);
|
||||
taskObject.put("objectId",objectId);
|
||||
taskObject.put("operatorCode",operatorCode);
|
||||
taskObjectList.add(taskObject);
|
||||
}
|
||||
|
||||
requestObject.put("taskObjectList",taskObjectList);
|
||||
}
|
||||
|
||||
String username = "admin";
|
||||
String passwd = "Uportal_123";
|
||||
String todourl = "http://172.16.25.133/portal-web/centerTodo/sync" ;
|
||||
String auth = username + ":" + passwd;
|
||||
|
||||
bb.writeLog("requestObject:"+requestObject.toJSONString());
|
||||
String msgdata = httpReqUtils.doPostByAuth2(requestObject.toJSONString());
|
||||
bb.writeLog("msgdata:"+msgdata);
|
||||
if(!"".equals(msgdata)){
|
||||
JSONObject msgObject = JSONObject.parseObject(msgdata);
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Loading…
Reference in New Issue