From 35281781c21f2f14a061f989daff1a03b77f47eb Mon Sep 17 00:00:00 2001 From: shilei <798989044@qq.com> Date: Tue, 31 Oct 2023 10:00:18 +0800 Subject: [PATCH] =?UTF-8?q?#EC=5FHJ115#=20cmd=E4=BB=A3=E7=90=86=E5=81=9C?= =?UTF-8?q?=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sendtodo/SendRemarkOperateTodoCmd.java | 912 +++++++++--------- 1 file changed, 456 insertions(+), 456 deletions(-) diff --git a/src/com/customization/dito/sendtodo/SendRemarkOperateTodoCmd.java b/src/com/customization/dito/sendtodo/SendRemarkOperateTodoCmd.java index 47e335cb..7f3dc861 100644 --- a/src/com/customization/dito/sendtodo/SendRemarkOperateTodoCmd.java +++ b/src/com/customization/dito/sendtodo/SendRemarkOperateTodoCmd.java @@ -1,495 +1,495 @@ -package com.customization.dito.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 org.apache.commons.lang.StringUtils; -import weaver.conn.RecordSet; -import weaver.file.FileUpload; -import weaver.general.BaseBean; -import weaver.general.Util; -import weaver.hrm.User; -import weaver.interfaces.dito.comInfo.PropBean; - -import javax.servlet.http.HttpServletRequest; -import java.net.URLEncoder; -import java.util.Map; - - -/** - * 转发、转办、意见征询等提交待办推送 - * - * @author wangj - * @version 1.00版本 - * @Date 2022/10/11 - */ -@CommandDynamicProxy(target = ForwardSubmitCmd.class, desc = "流程转发、转办、意见征询等提交后给门户发送代办消息") -public class SendRemarkOperateTodoCmd extends AbstractCommandProxy> { - @Override - public Map execute(Command> targetCommand) { - //获取到被代理对象 - ForwardSubmitCmd forwardSubmitCmd = (ForwardSubmitCmd) targetCommand; - //获取被代理对象的参数 - //对参数做预处理 - BaseBean bb = new BaseBean(); - bb.writeLog("-----------SendRemarkOperateTodoCmd------start--"); - HttpServletRequest request = forwardSubmitCmd.getRequest(); - FileUpload fu = new FileUpload(request); - String requestid = Util.null2String(fu.getParameter("requestid")); - int forwardflag = 1; - forwardflag = Util.getIntValue(fu.getParameter("forwardflag")); - if (forwardflag != 2 && forwardflag != 3 && forwardflag != 5) { - forwardflag = 1; // 2 征求意见；3 转办 ；1 转发; 5 征询转办 - } - //参数回写 - //执行标准的业务处理 - Map result = nextExecute(targetCommand); - - boolean status = (boolean) result.get("success"); - - if (status) { - RecordSet recordSet = new RecordSet(); - recordSet.executeSql("select * from workflow_requestbase where requestid =" + requestid); - int workflowid = -1; - String currnodetype0 = ""; - String nodeid = ""; - String requestname = ""; - if (recordSet.next()) { - nodeid = Util.null2String(recordSet.getString("currentnodeid")); - } - User user = forwardSubmitCmd.getUser(); - //执行推送代办 - String portal_todourl = PropBean.getUfPropValue("portal_todourl"); - String username = PropBean.getUfPropValue("username"); - String passwd = PropBean.getUfPropValue("passwd"); - String center = PropBean.getUfPropValue("center"); - String bpm_workflowurl = PropBean.getUfPropValue("bpm_workflowurl"); - - if (Util.getIntValue(requestid) > 0) { - sendTodoDataByCreateNode(requestid, nodeid, user, portal_todourl, username, passwd, bpm_workflowurl, center); - } - } - bb.writeLog("-----------SendRemarkOperateTodoCmd------end--"); - return result; - } - - /*** - * - * @param requestid - * @param noideid - * @param user - */ -// public void sendTodoDataByNode(String requestid, String noideid, User user, String portal_todourl, String username, String passwd, String bpm_workflowurl, String center) { +//package com.customization.dito.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 org.apache.commons.lang.StringUtils; +//import weaver.conn.RecordSet; +//import weaver.file.FileUpload; +//import weaver.general.BaseBean; +//import weaver.general.Util; +//import weaver.hrm.User; +//import weaver.interfaces.dito.comInfo.PropBean; +// +//import javax.servlet.http.HttpServletRequest; +//import java.net.URLEncoder; +//import java.util.Map; +// +// +///** +// * 转发、转办、意见征询等提交待办推送 +// * +// * @author wangj +// * @version 1.00版本 +// * @Date 2022/10/11 +// */ +//@CommandDynamicProxy(target = ForwardSubmitCmd.class, desc = "流程转发、转办、意见征询等提交后给门户发送代办消息") +//public class SendRemarkOperateTodoCmd extends AbstractCommandProxy> { +// @Override +// public Map execute(Command> targetCommand) { +// //获取到被代理对象 +// ForwardSubmitCmd forwardSubmitCmd = (ForwardSubmitCmd) targetCommand; +// //获取被代理对象的参数 +// //对参数做预处理 +// BaseBean bb = new BaseBean(); +// bb.writeLog("-----------SendRemarkOperateTodoCmd------start--"); +// HttpServletRequest request = forwardSubmitCmd.getRequest(); +// FileUpload fu = new FileUpload(request); +// String requestid = Util.null2String(fu.getParameter("requestid")); +// int forwardflag = 1; +// forwardflag = Util.getIntValue(fu.getParameter("forwardflag")); +// if (forwardflag != 2 && forwardflag != 3 && forwardflag != 5) { +// forwardflag = 1; // 2 征求意见；3 转办 ；1 转发; 5 征询转办 +// } +// //参数回写 +// //执行标准的业务处理 +// Map result = nextExecute(targetCommand); +// +// boolean status = (boolean) result.get("success"); +// +// if (status) { +// RecordSet recordSet = new RecordSet(); +// recordSet.executeSql("select * from workflow_requestbase where requestid =" + requestid); +// int workflowid = -1; +// String currnodetype0 = ""; +// String nodeid = ""; +// String requestname = ""; +// if (recordSet.next()) { +// nodeid = Util.null2String(recordSet.getString("currentnodeid")); +// } +// User user = forwardSubmitCmd.getUser(); +// //执行推送代办 +// String portal_todourl = PropBean.getUfPropValue("portal_todourl"); +// String username = PropBean.getUfPropValue("username"); +// String passwd = PropBean.getUfPropValue("passwd"); +// String center = PropBean.getUfPropValue("center"); +// String bpm_workflowurl = PropBean.getUfPropValue("bpm_workflowurl"); +// +// if (Util.getIntValue(requestid) > 0) { +// sendTodoDataByCreateNode(requestid, nodeid, user, portal_todourl, username, passwd, bpm_workflowurl, center); +// } +// } +// bb.writeLog("-----------SendRemarkOperateTodoCmd------end--"); +// return result; +// } +// +// /*** +// * +// * @param requestid +// * @param noideid +// * @param 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 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")); +////// messageTitle = getShortMessageTitle(messageTitle); +//// String messageContent = Util.null2String(rs.getString("requestname")); +//// +//// String taskType = "0"; +//// +//// 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); +//// 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")); +////// messageTitle = getShortMessageTitle(messageTitle); +//// String messageContent = Util.null2String(rs.getString("requestname")); +//// +//// String taskType = "0"; +//// +//// 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); +//// 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" ; +//// +//// //"Basic YWRtaW46VXBvcnRhbF8xMjM=" +//// +//// String auth = username + ":" + passwd; +//// bb.writeLog("requestObject:" + 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(); +//// } +//// } +// +// /*** +// * +// * @param requestid +// * @param noideid +// * @param user +// */ +// public void sendTodoDataByCreateNode(String requestid,String noideid,User user,String portal_todourl,String username,String passwd,String bpm_workflowurl,String center){ +// String bpm_app_workflowurl = PropBean.getUfPropValue("bpm_app_workflowurl"); +// String bpm_app_requesturl = PropBean.getUfPropValue("bpm_app_requesturl"); // HttpReqUtils httpReqUtils = new HttpReqUtils(); // JSONObject requestObject = new JSONObject(); -// +// String mobileJumpUrl = PropBean.getUfPropValue("mobileJumpUrl"); // BaseBean bb = new BaseBean(); -// bb.writeLog("sendTodoDataByNode"); +// bb.writeLog("sendTodoDataByCreateNode"); // RecordSet rs = new RecordSet(); -// String ticketType = center; -// String terminal = "1"; +// String ticketType = center ; +// String terminal = "1" ; +// String scopeid = "-1"; +// String scope = "HrmCustomFieldByInfoType" ; +// String cus_staff = PropBean.getUfPropValue("cus_staff") ; // try { // -// String currentnodetype = ""; -// String sql = " select currentnodetype from workflow_requestbase where requestid=" + requestid; +// String currentnodetype = "" ; +// String sql = " select currentnodetype from workflow_requestbase where requestid="+requestid; // rs.executeQuery(sql); -// bb.writeLog("sendTodoDataByNode--sql:" + sql); -// if (rs.next()) { +// 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"; +// bb.writeLog("sendTodoDataByNode--currentnodetype:"+currentnodetype); +// if("3".equals(currentnodetype)){ +// String actionType = "3" ; +// }else{ +// +// String actionType = "1" ; +// // String actionType = "0" ; +// JSONArray taskObjectList = new JSONArray(); +// +// sql = " select t1.requestname,t1.requestmark,t1.creater,t1.createdate,t1.createtime,h1.lastname,h1.loginid,h1.id,\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 userId = Util.null2String(rs.getString("id")) ; +// 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 = getShortMessageTitle(rs.getString("requestname")) ; +// String messageContent = Util.null2String(rs.getString("requestname")) ; +// +// String taskType = "0"; +// +// String urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ; +// String replace = bpm_app_workflowurl.replace("/bpm", ""); +// String urlDing = replace + bpm_app_requesturl + requestid; +// String urlApp = replace + bpm_app_requesturl + requestid; +// +// if(StringUtils.isNotEmpty(mobileJumpUrl)){ +// urlDing += "&returnUrl="+ URLEncoder.encode(mobileJumpUrl,"UTF-8"); +// urlApp += "&returnUrl="+URLEncoder.encode(mobileJumpUrl,"UTF-8"); +// } +// +// +// +// String nodeName = Util.null2String(rs.getString("nodeName")) ; // -// } else { +// requestObject.put("center",center); +// requestObject.put("title",title); +// requestObject.put("creator",creator); +// //requestObject.put("taskCode",taskCode+"_zf_"+userId); +// requestObject.put("taskCode","weaver"+taskCode); +// requestObject.put("nodeId",nodeId+userId); +// 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); +// } // -// String actionType = ""; -// int count = 0; -// sql = " select t2.userid,h1.loginid\n" + +// sql = " select t2.userid,h1.loginid,c1."+cus_staff+" as staffid "+ // " 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" + +// " left join cus_fielddata c1 on c1.id = t2.userid and c1.scopeid= "+scopeid+" and c1.scope = '"+scope+"' "+ +// " 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.isremark = '1' \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); +// " 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")); -//// messageTitle = getShortMessageTitle(messageTitle); -// String messageContent = Util.null2String(rs.getString("requestname")); -// -// String taskType = "0"; -// -// 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); -// 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); -// } +// while (rs.next()){ // +// String usercode = Util.null2String(rs.getString("loginid")) ; // JSONObject taskObject = new JSONObject(); -// String objectAction = "1"; +// String objectAction = "0" ; // 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); +// String objectCode = usercode ; +// String objectId = rs.getString("staffid") ; +// 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); -// -// } 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")); -//// messageTitle = getShortMessageTitle(messageTitle); -// String messageContent = Util.null2String(rs.getString("requestname")); -// -// String taskType = "0"; -// -// 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); -// 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); -//// } +// requestObject.put("taskObjectList",taskObjectList); // -// 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" ; // -// //"Basic YWRtaW46VXBvcnRhbF8xMjM=" -// // String auth = username + ":" + passwd; -// bb.writeLog("requestObject:" + requestObject.toJSONString()); -// String msgdata = httpReqUtils.doPostByAuth2(portal_todourl, requestObject.toJSONString(), auth); -// bb.writeLog("msgdata:" + msgdata); -// if (!"".equals(msgdata)) { +// bb.writeLog("requestObject:"+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); +// if(msgObject.containsKey("resultCode")){ +// String resultCode = msgObject.getString("resultCode"); +// if("0".equals(resultCode)){ +// +// }else{ +// +// } +// } // } // } // } catch (Exception e) { // e.printStackTrace(); // } +// // } - - /*** - * - * @param requestid - * @param noideid - * @param user - */ - public void sendTodoDataByCreateNode(String requestid,String noideid,User user,String portal_todourl,String username,String passwd,String bpm_workflowurl,String center){ - String bpm_app_workflowurl = PropBean.getUfPropValue("bpm_app_workflowurl"); - String bpm_app_requesturl = PropBean.getUfPropValue("bpm_app_requesturl"); - HttpReqUtils httpReqUtils = new HttpReqUtils(); - JSONObject requestObject = new JSONObject(); - String mobileJumpUrl = PropBean.getUfPropValue("mobileJumpUrl"); - BaseBean bb = new BaseBean(); - bb.writeLog("sendTodoDataByCreateNode"); - RecordSet rs = new RecordSet(); - String ticketType = center ; - String terminal = "1" ; - String scopeid = "-1"; - String scope = "HrmCustomFieldByInfoType" ; - String cus_staff = PropBean.getUfPropValue("cus_staff") ; - 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 = "1" ; - // String actionType = "0" ; - JSONArray taskObjectList = new JSONArray(); - - sql = " select t1.requestname,t1.requestmark,t1.creater,t1.createdate,t1.createtime,h1.lastname,h1.loginid,h1.id,\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 userId = Util.null2String(rs.getString("id")) ; - 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 = getShortMessageTitle(rs.getString("requestname")) ; - String messageContent = Util.null2String(rs.getString("requestname")) ; - - String taskType = "0"; - - String urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ; - String replace = bpm_app_workflowurl.replace("/bpm", ""); - String urlDing = replace + bpm_app_requesturl + requestid; - String urlApp = replace + bpm_app_requesturl + requestid; - - if(StringUtils.isNotEmpty(mobileJumpUrl)){ - urlDing += "&returnUrl="+ URLEncoder.encode(mobileJumpUrl,"UTF-8"); - urlApp += "&returnUrl="+URLEncoder.encode(mobileJumpUrl,"UTF-8"); - } - - - - String nodeName = Util.null2String(rs.getString("nodeName")) ; - - requestObject.put("center",center); - requestObject.put("title",title); - requestObject.put("creator",creator); - //requestObject.put("taskCode",taskCode+"_zf_"+userId); - requestObject.put("taskCode","weaver"+taskCode); - requestObject.put("nodeId",nodeId+userId); - 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,c1."+cus_staff+" as staffid "+ - " from workflow_requestbase t1\n" + - " inner join workflow_currentoperator t2 on t1.requestid = t2.requestid\n" + - " left join cus_fielddata c1 on c1.id = t2.userid and c1.scopeid= "+scopeid+" and c1.scope = '"+scope+"' "+ - " 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 = '1' \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()){ - - String usercode = Util.null2String(rs.getString("loginid")) ; - JSONObject taskObject = new JSONObject(); - String objectAction = "0" ; - String objectType = "0"; - String objectCode = usercode ; - String objectId = rs.getString("staffid") ; - 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(portal_todourl,requestObject.toJSONString(),auth); - bb.writeLog("msgdata:"+msgdata); - if(!"".equals(msgdata)){ - JSONObject msgObject = JSONObject.parseObject(msgdata); - if(msgObject.containsKey("resultCode")){ - String resultCode = msgObject.getString("resultCode"); - if("0".equals(resultCode)){ - - }else{ - - } - } - } - } - } catch (Exception e) { - e.printStackTrace(); - } - - } -// private String getShortMessageTitle(String messageTitle){ -// if(messageTitle.length()>20){ -// messageTitle = messageTitle.substring(0,17)+"..."; +//// private String getShortMessageTitle(String messageTitle){ +//// if(messageTitle.length()>20){ +//// messageTitle = messageTitle.substring(0,17)+"..."; +//// } +//// return messageTitle; +//// } +// private String getShortMessageTitle(String messageTitle) { +// if (messageTitle.length() > 20) { +// messageTitle = messageTitle.substring(0, 17) + "..."; // } // return messageTitle; // } - private String getShortMessageTitle(String messageTitle) { - if (messageTitle.length() > 20) { - messageTitle = messageTitle.substring(0, 17) + "..."; - } - return messageTitle; - } - -} +// +//}