From 1d0118db4a98f96b0bf1d5ea130a503a2e03a099 Mon Sep 17 00:00:00 2001 From: shilei <798989044@qq.com> Date: Mon, 10 Oct 2022 11:50:20 +0800 Subject: [PATCH] =?UTF-8?q?#EC=5FHJ2#=20=E5=8E=BB=E6=8E=89=E6=B5=8B?= =?UTF-8?q?=E8=AF=95=E5=BC=80=E5=8F=91=E7=9A=84=E4=BB=A3=E7=A0=81=E5=8F=8A?= =?UTF-8?q?=E4=BD=BF=E7=94=A8=E9=85=8D=E7=BD=AE=E6=96=87=E4=BB=B6=E6=9B=BF?= =?UTF-8?q?=E6=8D=A2=E4=BB=A3=E7=A0=81=E5=9B=BA=E5=AE=9A=E7=9A=84=E5=9C=B0?= =?UTF-8?q?=E5=9D=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- WEB-INF/prop/PORTAL_INFO.properties | 15 + .../sendtodo/ForwardPortalTodoCmd.java | 573 ------------------ .../customization/sendtodo/HttpReqUtils.java | 19 +- .../sendtodo/SendPortalTodoCmd.java | 86 +-- .../sendtodo/SubmitPortalTodoCmd.java | 563 ----------------- 5 files changed, 72 insertions(+), 1184 deletions(-) delete mode 100644 src/com/customization/sendtodo/ForwardPortalTodoCmd.java delete mode 100644 src/com/customization/sendtodo/SubmitPortalTodoCmd.java diff --git a/WEB-INF/prop/PORTAL_INFO.properties b/WEB-INF/prop/PORTAL_INFO.properties index d1f9d11e..7936e7b3 100644 --- a/WEB-INF/prop/PORTAL_INFO.properties +++ b/WEB-INF/prop/PORTAL_INFO.properties @@ -21,3 +21,18 @@ topic = dataSync_topic_nj ##RocketMq的subExpression subExpression = BPM + +##门户待办接口 +portal_todourl = http://172.16.25.133/portal-web/centerTodo/sync + +##待办的用户名 +username = admin + +##待办接口的密码 +passwd = Uportal_123 + +##流程详情页的url +bpm_workflowurl = http://172.16.25.133/bpm + +## 门户待办类型 +center = MCCM \ No newline at end of file diff --git a/src/com/customization/sendtodo/ForwardPortalTodoCmd.java b/src/com/customization/sendtodo/ForwardPortalTodoCmd.java deleted file mode 100644 index 97618da4..00000000 --- a/src/com/customization/sendtodo/ForwardPortalTodoCmd.java +++ /dev/null @@ -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> { - @Override - public Map execute(Command> targetCommand) { - //获取到被代理对象 - ForwardSubmitCmd forwardSubmitCmd = (ForwardSubmitCmd)targetCommand; - //获取被代理对象的参数 - //对参数做预处理 - //requestSubmitCmd.writeLog("requestSubmitCmd params222======"+params); - - BaseBean bb = new BaseBean(); - HttpServletRequest request = forwardSubmitCmd.getRequest(); - - - Enumeration 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 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 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(); - } - - } -} - - diff --git a/src/com/customization/sendtodo/HttpReqUtils.java b/src/com/customization/sendtodo/HttpReqUtils.java index 7659a341..37b8c46a 100644 --- a/src/com/customization/sendtodo/HttpReqUtils.java +++ b/src/com/customization/sendtodo/HttpReqUtils.java @@ -1,5 +1,6 @@ package com.customization.sendtodo; +import com.sun.jersey.core.util.Base64; import okhttp3.*; import weaver.general.BaseBean; import java.io.IOException; @@ -11,24 +12,30 @@ public class HttpReqUtils extends BaseBean{ * @param dataJson * @return */ - public String doPostByAuth2(String dataJson){ + public String doPostByAuth2(String portal_todourl,String dataJson,String auth){ + //"http://172.16.25.133/portal-web/centerTodo/sync" BaseBean bb = new BaseBean(); + + String authorization = "Basic "+new String(Base64.encode(auth)); + bb.writeLog("authorization:"+authorization); + bb.writeLog("portal_todourl:"+portal_todourl); + bb.writeLog("dataJson:"+dataJson); + bb.writeLog("auth:"+auth); + String msgData = "" ; - OkHttpClient client = new OkHttpClient().newBuilder() - .build(); + OkHttpClient client = new OkHttpClient().newBuilder().build(); MediaType mediaType = MediaType.parse("application/json"); RequestBody body = RequestBody.create(mediaType, dataJson); Request request = new Request.Builder() - .url("http://172.16.25.133/portal-web/centerTodo/sync") + .url(portal_todourl) .method("POST", body) - .addHeader("Authorization", "Basic YWRtaW46VXBvcnRhbF8xMjM=") + .addHeader("Authorization", authorization) .addHeader("Content-Type", "application/json") .build(); try { Response response = client.newCall(request).execute(); bb.writeLog("response.code():"+response.code()); bb.writeLog("response.body():"+response.body().string()); - msgData = response.body().string(); } catch (IOException e) { e.printStackTrace(); diff --git a/src/com/customization/sendtodo/SendPortalTodoCmd.java b/src/com/customization/sendtodo/SendPortalTodoCmd.java index a7994055..fa8d1364 100644 --- a/src/com/customization/sendtodo/SendPortalTodoCmd.java +++ b/src/com/customization/sendtodo/SendPortalTodoCmd.java @@ -54,12 +54,19 @@ public class SendPortalTodoCmd extends AbstractCommandProxy> if("SUCCESS".equals(executeResult)){ + String portal_todourl = bb.getPropValue("PORTAL_INFO","portal_todourl"); + String username = bb.getPropValue("PORTAL_INFO","username"); + String passwd = bb.getPropValue("PORTAL_INFO","passwd"); + String center = bb.getPropValue("PORTAL_INFO","center"); + String bpm_workflowurl = bb.getPropValue("PORTAL_INFO","bpm_workflowurl"); + + if(Util.getIntValue(requestid) == -1 && "save".equals(src)){ - sendTodoDataByCreater(new_requestid,user); + sendTodoDataByCreater(new_requestid,user,portal_todourl,username,passwd,bpm_workflowurl,center); }else if(Util.getIntValue(requestid) == -1 && "submit".equals(src)){ - sendTodoDataByCreateNode(new_requestid,nodeid,user); + sendTodoDataByCreateNode(new_requestid,nodeid,user,portal_todourl,username,passwd,bpm_workflowurl,center); }else if(Util.getIntValue(requestid)> 0 && "submit".equals(src)){ - sendTodoDataByNode(requestid,nodeid,user); + sendTodoDataByNode(requestid,nodeid,user,portal_todourl,username,passwd,bpm_workflowurl,center); } } return result; @@ -70,12 +77,11 @@ public class SendPortalTodoCmd extends AbstractCommandProxy> * @param requestId * @param user */ - public void sendTodoDataByCreater(String requestId,User user){ + public void sendTodoDataByCreater(String requestId,User user,String portal_todourl,String username,String passwd,String bpm_workflowurl,String center){ HttpReqUtils httpReqUtils = new HttpReqUtils(); BaseBean bb = new BaseBean(); RecordSet rs = new RecordSet(); - String center = "MCCM"; String actionType = "0" ; String terminal = "1" ; String ticketType = center ; @@ -113,9 +119,9 @@ public class SendPortalTodoCmd extends AbstractCommandProxy> 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 urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestId ; + String urlApp = "[newtab]"+bpm_workflowurl+"/spa/workflow/static4mobileform/index.html#/req?requestid="+requestId; + String urlDing = "[newtab]"+bpm_workflowurl+"/spa/workflow/static4mobileform/index.html#/req?requestid="+requestId; String nodeName = Util.null2String(rs.getString("nodeName")) ; @@ -156,20 +162,17 @@ public class SendPortalTodoCmd extends AbstractCommandProxy> 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 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()); + String msgdata = httpReqUtils.doPostByAuth2(portal_todourl,requestObject.toJSONString(),auth); bb.writeLog("msgdata:"+msgdata); if(!"".equals(msgdata)){ JSONObject msgObject = JSONObject.parseObject(msgdata); + System.out.println(msgObject); } - } catch (Exception e) { e.printStackTrace(); } @@ -183,7 +186,7 @@ public class SendPortalTodoCmd extends AbstractCommandProxy> * @param noideid * @param user */ - public void sendTodoDataByCreateNode(String requestid,String noideid,User user){ + public void sendTodoDataByCreateNode(String requestid,String noideid,User user,String portal_todourl,String username,String passwd,String bpm_workflowurl,String center){ HttpReqUtils httpReqUtils = new HttpReqUtils(); JSONObject requestObject = new JSONObject(); @@ -191,7 +194,6 @@ public class SendPortalTodoCmd extends AbstractCommandProxy> BaseBean bb = new BaseBean(); bb.writeLog("sendTodoDataByCreateNode"); RecordSet rs = new RecordSet(); - String center = "MCCM"; String ticketType = center ; String terminal = "1" ; try { @@ -237,9 +239,9 @@ public class SendPortalTodoCmd extends AbstractCommandProxy> 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 urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ; + String urlApp = "[newtab]"+bpm_workflowurl+"/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid; + String urlDing = "[newtab]"+bpm_workflowurl+"/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid; String nodeName = Util.null2String(rs.getString("nodeName")) ; requestObject.put("center",center); @@ -292,16 +294,17 @@ public class SendPortalTodoCmd extends AbstractCommandProxy> 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; +// 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()); + String msgdata = httpReqUtils.doPostByAuth2(portal_todourl,requestObject.toJSONString(),auth); bb.writeLog("msgdata:"+msgdata); if(!"".equals(msgdata)){ JSONObject msgObject = JSONObject.parseObject(msgdata); + System.out.println(msgdata); } } } catch (Exception e) { @@ -317,15 +320,13 @@ public class SendPortalTodoCmd extends AbstractCommandProxy> * @param noideid * @param user */ - public void sendTodoDataByNode(String requestid,String noideid,User user){ - + public void sendTodoDataByNode(String requestid,String noideid,User user,String portal_todourl,String username,String passwd,String bpm_workflowurl,String center){ 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 { @@ -393,9 +394,9 @@ public class SendPortalTodoCmd extends AbstractCommandProxy> 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 urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ; + String urlApp = "[newtab]"+bpm_workflowurl+"/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid; + String urlDing = "[newtab]"+bpm_workflowurl+"/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid; String nodeName = Util.null2String(rs.getString("nodeName")) ; @@ -461,9 +462,9 @@ public class SendPortalTodoCmd extends AbstractCommandProxy> 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 urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ; + String urlApp = "[newtab]"+bpm_workflowurl+"/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid; + String urlDing = "[newtab]"+bpm_workflowurl+"/spa/workflow/static4mobileform/index.html#/req?requestid="+requestid; String nodeName = Util.null2String(rs.getString("nodeName")) ; requestObject.put("center",center); @@ -537,26 +538,27 @@ public class SendPortalTodoCmd extends AbstractCommandProxy> 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; +// String username = "admin"; +// String passwd = "Uportal_123"; +// String todourl = "http://172.16.25.133/portal-web/centerTodo/sync" ; + //"Basic YWRtaW46VXBvcnRhbF8xMjM=" + + String auth = username + ":" + passwd; bb.writeLog("requestObject:"+requestObject.toJSONString()); - String msgdata = httpReqUtils.doPostByAuth2(requestObject.toJSONString()); + String msgdata = httpReqUtils.doPostByAuth2(portal_todourl,requestObject.toJSONString(),auth); bb.writeLog("msgdata:"+msgdata); if(!"".equals(msgdata)){ JSONObject msgObject = JSONObject.parseObject(msgdata); + System.out.println(msgObject); } } } catch (Exception e) { e.printStackTrace(); } - } } diff --git a/src/com/customization/sendtodo/SubmitPortalTodoCmd.java b/src/com/customization/sendtodo/SubmitPortalTodoCmd.java deleted file mode 100644 index 5548ddba..00000000 --- a/src/com/customization/sendtodo/SubmitPortalTodoCmd.java +++ /dev/null @@ -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> { - @Override - public Map execute(Command> 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 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(); - } - - } -} - -