修改抄送等bug
parent
208942e0b7
commit
86112e6511
@ -0,0 +1,141 @@
|
||||
<%@ page import="weaver.hrm.User" %>
|
||||
<%@ page import="weaver.general.BaseBean" %>
|
||||
<%@ page import="com.customization.dito.sendtodo.SendPortalErrorUtil" %>
|
||||
<%@ page import="com.customization.dito.sendtodo.HttpRequestUtil" %>
|
||||
<%@ page import="weaver.conn.RecordSet" %>
|
||||
<%@ page import="weaver.interfaces.dito.comInfo.PropBean" %>
|
||||
<%@ page import="com.time.util.DateUtil" %>
|
||||
<%@ page import="weaver.general.Util" %>
|
||||
<%@ page import="org.apache.commons.lang.StringUtils" %>
|
||||
<%@ page import="java.net.URLEncoder" %>
|
||||
<%@ page import="java.io.UnsupportedEncodingException" %>
|
||||
<%@ page import="com.alibaba.fastjson.JSONObject" %>
|
||||
<%@ page import="weaver.hrm.HrmUserVarify" %>
|
||||
<%@ page import="java.util.Map" %>
|
||||
<%@ page import="java.util.List" %>
|
||||
<%@ page import="com.alibaba.fastjson.JSONArray" %>
|
||||
<%@ page import="java.util.HashMap" %>
|
||||
<%@ page language="java" contentType="text/html; charset=UTF-8" %>
|
||||
|
||||
<%
|
||||
String bpm_app_workflowurl = PropBean.getUfPropValue("bpm_app_workflowurl");
|
||||
|
||||
String bpm_app_requesturl = PropBean.getUfPropValue("bpm_app_requesturl");
|
||||
String username = PropBean.getUfPropValue("username");
|
||||
String passwd = PropBean.getUfPropValue("passwd");
|
||||
String bpm_workflowurl = PropBean.getUfPropValue("bpm_workflowurl");
|
||||
String requestid = request.getParameter("requestId");
|
||||
String nodeid = request.getParameter("nodeid");
|
||||
String userId = request.getParameter("userId");
|
||||
|
||||
String portal_doneurl = PropBean.getUfPropValue("portal_doneurl");
|
||||
|
||||
sendPortalDoneData(requestid,nodeid,userId,portal_doneurl,bpm_app_workflowurl,username,passwd,bpm_workflowurl,bpm_app_requesturl);
|
||||
%>
|
||||
|
||||
<%!
|
||||
public void sendPortalDoneData(String requestid, String nodeid, String userId, String portal_doneurl, String bpm_app_workflowurl, String username, String passwd, String bpm_workflowurl, String bpm_app_requesturl) {
|
||||
BaseBean bb = new BaseBean();
|
||||
bb.writeLog("sendPortalDoneData");
|
||||
SendPortalErrorUtil sendPortalErrorUtil = new SendPortalErrorUtil();
|
||||
HttpRequestUtil httpRequestUtil = new HttpRequestUtil();
|
||||
RecordSet rs = new RecordSet();
|
||||
|
||||
String mobileJumpUrl = PropBean.getUfPropValue("mobileJumpUrl");
|
||||
|
||||
try {
|
||||
|
||||
String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss");
|
||||
String isRecall = "1";
|
||||
String actionType = "0";
|
||||
String userid = userId;
|
||||
String workcode = "";
|
||||
String sql = "select loginid from hrmresource where id = '" + userid + "'";
|
||||
rs.execute(sql);
|
||||
while (rs.next()) {
|
||||
workcode = Util.null2String(rs.getString("loginid"));
|
||||
}
|
||||
|
||||
String center = PropBean.getUfPropValue("center");
|
||||
|
||||
String urlPc = "[newtab]" + bpm_workflowurl + "/workflow/request/ViewRequestForwardSPA.jsp?requestid=" + requestid;
|
||||
|
||||
// String urlApp = "[newtab]" + bpm_app_workflowurl + "/interface/mobilelogin/loginsso.jsp?em_auth_usercode=" + workcode + "&forwardurl=" + app_requestUrl;
|
||||
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)){
|
||||
try {
|
||||
urlApp += "&returnUrl="+URLEncoder.encode(mobileJumpUrl,"UTF-8");
|
||||
urlDing += "&returnUrl="+URLEncoder.encode(mobileJumpUrl,"UTF-8");
|
||||
} catch (UnsupportedEncodingException unsupportedEncodingException) {
|
||||
unsupportedEncodingException.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
String requestname = "";
|
||||
String workflowname = "";
|
||||
String nodeName = "" ;
|
||||
|
||||
sql = " select t1.requestname,t3.workflowname\n" +
|
||||
" from workflow_requestbase t1\n" +
|
||||
" inner join workflow_base t3 on t1.workflowid = t3.id\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and t1.requestid = " + requestid;
|
||||
rs.execute(sql);
|
||||
if (rs.next()) {
|
||||
requestname = Util.null2String(rs.getString("requestname"));
|
||||
workflowname = Util.null2String(rs.getString("workflowname"));
|
||||
}
|
||||
|
||||
sql = " select nodename from workflow_nodebase wn where wn.id = "+nodeid ;
|
||||
rs.execute(sql);
|
||||
if (rs.next()) {
|
||||
nodeName = Util.null2String(rs.getString("nodename"));
|
||||
}
|
||||
|
||||
JSONObject requestObject = new JSONObject();
|
||||
requestObject.put("center", center);
|
||||
requestObject.put("taskCode", requestid);
|
||||
requestObject.put("nodeId", nodeid+userid);
|
||||
requestObject.put("ticketType", workflowname);
|
||||
requestObject.put("title", requestname);
|
||||
requestObject.put("creator", workcode);
|
||||
requestObject.put("processStaff", workcode);
|
||||
requestObject.put("processTime", processTime);
|
||||
requestObject.put("isRecall", isRecall);
|
||||
requestObject.put("actionType", actionType);
|
||||
requestObject.put("urlPC", urlPc);
|
||||
requestObject.put("urlApp", urlApp);
|
||||
requestObject.put("urlDing",urlDing);
|
||||
|
||||
String userids = userid+"" ;
|
||||
String auth = username + ":" + passwd;
|
||||
bb.writeLog("done requestObject:" + requestObject.toJSONString());
|
||||
String msgdata = httpRequestUtil.doPostByAuth(portal_doneurl, requestObject.toJSONString(), auth);
|
||||
bb.writeLog("done msgdata:" + msgdata);
|
||||
if(StringUtils.isNotEmpty(msgdata))
|
||||
{
|
||||
JSONObject msgObject = JSONObject.parseObject(msgdata);
|
||||
//{"resultCode":"1","resultMsg":"No Result"}
|
||||
if(msgObject.containsKey("resultCode")){
|
||||
String resultCode = msgObject.getString("resultCode");
|
||||
if(!"0".equals(resultCode)){
|
||||
String resultmsg = msgObject.getString("resultMsg");
|
||||
sendPortalErrorUtil.doRecordPortalErrorInfo(requestid,nodeid,nodeName,userids,requestObject.toJSONString(),resultCode,resultmsg);
|
||||
}
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
bb.writeLog("done Exception");
|
||||
bb.writeLog(e.getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
%>
|
||||
|
||||
@ -0,0 +1,177 @@
|
||||
<%@ page import="weaver.hrm.User" %>
|
||||
<%@ page import="weaver.general.BaseBean" %>
|
||||
<%@ page import="com.customization.dito.sendtodo.SendPortalErrorUtil" %>
|
||||
<%@ page import="com.customization.dito.sendtodo.HttpRequestUtil" %>
|
||||
<%@ page import="weaver.conn.RecordSet" %>
|
||||
<%@ page import="weaver.interfaces.dito.comInfo.PropBean" %>
|
||||
<%@ page import="com.time.util.DateUtil" %>
|
||||
<%@ page import="weaver.general.Util" %>
|
||||
<%@ page import="org.apache.commons.lang.StringUtils" %>
|
||||
<%@ page import="java.net.URLEncoder" %>
|
||||
<%@ page import="java.io.UnsupportedEncodingException" %>
|
||||
<%@ page import="com.alibaba.fastjson.JSONObject" %>
|
||||
<%@ page import="weaver.hrm.HrmUserVarify" %>
|
||||
<%@ page import="java.util.Map" %>
|
||||
<%@ page import="java.util.List" %>
|
||||
<%@ page import="com.alibaba.fastjson.JSONArray" %>
|
||||
<%@ page import="java.util.HashMap" %>
|
||||
<%@ page language="java" contentType="text/html; charset=UTF-8" %>
|
||||
|
||||
<%
|
||||
String bpm_app_workflowurl = PropBean.getUfPropValue("bpm_app_workflowurl");
|
||||
String portal_todourl = PropBean.getUfPropValue("portal_todourl");
|
||||
String bpm_app_requesturl = PropBean.getUfPropValue("bpm_app_requesturl");
|
||||
String username = PropBean.getUfPropValue("username");
|
||||
String passwd = PropBean.getUfPropValue("passwd");
|
||||
String bpm_workflowurl = PropBean.getUfPropValue("bpm_workflowurl");
|
||||
String requestid = request.getParameter("requestId");
|
||||
String userId = request.getParameter("userId");
|
||||
String center = PropBean.getUfPropValue("center");
|
||||
|
||||
sendTodoDataByNode(requestid,userId,username,passwd,center,portal_todourl,bpm_workflowurl,bpm_app_workflowurl,bpm_app_requesturl);
|
||||
%>
|
||||
|
||||
<%!
|
||||
|
||||
|
||||
public void sendTodoDataByNode(String requestid, String userId, String username, String passwd, String center, String portal_todourl, String bpm_workflowurl, String bpm_app_workflowurl, String bpm_app_requesturl){
|
||||
HttpRequestUtil httpRequestUtil = new HttpRequestUtil();
|
||||
|
||||
String mobileJumpUrl = PropBean.getUfPropValue("mobileJumpUrl");
|
||||
|
||||
JSONObject requestObject = new JSONObject();
|
||||
RecordSet rs = new RecordSet();
|
||||
|
||||
BaseBean bb = new BaseBean();
|
||||
bb.writeLog("SendPortalQithRawRunnable--sendTodoDataByNode");
|
||||
|
||||
String terminal = "1" ;
|
||||
String taskType = "0";
|
||||
String actionType = "1" ;
|
||||
String objectAction = "1" ;
|
||||
String objectType = "0";
|
||||
|
||||
try {
|
||||
String sql = "";
|
||||
|
||||
String processTime = DateUtil.getCurrentTime("yyyy-MM-dd HH:mm:ss");
|
||||
|
||||
String urlPc = "[newtab]"+bpm_workflowurl+"/workflow/request/ViewRequestForwardSPA.jsp?requestid="+requestid ;
|
||||
String replace = bpm_app_workflowurl.replace("/bpm", "");
|
||||
String urlDing = replace+bpm_app_requesturl+requestid;
|
||||
String urlApp = replace+bpm_app_requesturl+requestid;
|
||||
|
||||
if(StringUtils.isNotEmpty(mobileJumpUrl)){
|
||||
urlDing += "&returnUrl="+ URLEncoder.encode(mobileJumpUrl,"UTF-8");
|
||||
urlApp += "&returnUrl="+URLEncoder.encode(mobileJumpUrl,"UTF-8");
|
||||
}
|
||||
bb.writeLog("urlDing", urlDing);
|
||||
|
||||
|
||||
String requestname = "" ;
|
||||
String workflowname = "" ;
|
||||
String nodeId = "" ;
|
||||
String nodeName = "" ;
|
||||
String lastName = "";
|
||||
sql =" select t1.requestname,t1.currentnodeid as nodeid,d1.nodename,t3.workflowname,h2.lastname"+
|
||||
" 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 ) h2 on h2.id = t1.creater \n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and t1.requestid = "+requestid ;
|
||||
|
||||
bb.writeLog("sendTodoDataByNode--sql2:"+sql);
|
||||
|
||||
rs.executeQuery(sql);
|
||||
if (rs.next()){
|
||||
requestname = Util.null2String(rs.getString("requestname")) ;
|
||||
workflowname = Util.null2String(rs.getString("workflowname")) ;
|
||||
nodeId = Util.null2String(rs.getString("nodeid")) ;
|
||||
nodeName = Util.null2String(rs.getString("nodeName")) ;
|
||||
lastName = Util.null2String(rs.getString("lastname")) ;
|
||||
}
|
||||
|
||||
requestObject.put("center",center);
|
||||
requestObject.put("title",requestname);
|
||||
requestObject.put("creator",lastName);
|
||||
requestObject.put("taskCode",requestid);
|
||||
requestObject.put("nodeId",nodeId);
|
||||
requestObject.put("taskType",taskType);
|
||||
requestObject.put("actionType",actionType);
|
||||
requestObject.put("createDate",processTime);
|
||||
requestObject.put("messageTitle",getShortMessageTitle(requestname));
|
||||
requestObject.put("messageContent",requestname);
|
||||
requestObject.put("terminal",terminal);
|
||||
requestObject.put("urlPc",urlPc);
|
||||
requestObject.put("urlApp",urlApp);
|
||||
requestObject.put("urlDing",urlDing);
|
||||
requestObject.put("nodeName",nodeName);
|
||||
requestObject.put("ticketType",workflowname);
|
||||
|
||||
|
||||
JSONArray taskObjectList = new JSONArray();
|
||||
String cus_staff = PropBean.getUfPropValue("cus_staff") ;
|
||||
String scopeid = "-1";
|
||||
String scope = "HrmCustomFieldByInfoType" ;
|
||||
|
||||
|
||||
|
||||
String userSql = "select a."+cus_staff+" as staffid,b.loginid from cus_fielddata a,hrmresource b where a.scopeid=-1 and a.scope='HrmCustomFieldByInfoType' and a.id=b.id and a.id=?";
|
||||
rs.executeQuery(userSql,userId);
|
||||
requestObject.put("nodeId",requestObject.getString("nodeId")+userId);
|
||||
|
||||
if (rs.next()){
|
||||
String staffid = Util.null2String(rs.getString("staffid"));
|
||||
String loginid = Util.null2String(rs.getString("loginid"));
|
||||
if("sysadmin".equals(loginid)){
|
||||
loginid = "Admin";
|
||||
}
|
||||
|
||||
JSONObject taskObject = new JSONObject();
|
||||
|
||||
taskObject.put("objectAction",objectAction);
|
||||
taskObject.put("objectType",objectType);
|
||||
taskObject.put("objectCode",loginid);
|
||||
taskObject.put("objectId",staffid);
|
||||
taskObject.put("operatorCode",loginid);
|
||||
taskObjectList.add(taskObject);
|
||||
}
|
||||
|
||||
|
||||
requestObject.put("taskObjectList",taskObjectList);
|
||||
|
||||
String auth = username + ":" + passwd;
|
||||
bb.writeLog("sendTodoDataByNode---requestObject:"+requestObject.toJSONString());
|
||||
String msgdata = httpRequestUtil.doPostByAuth(portal_todourl,requestObject.toJSONString(),auth);
|
||||
bb.writeLog("msgdata:"+msgdata);
|
||||
Map<String,Object> map = new HashMap<>();
|
||||
if(!"".equals(msgdata)){
|
||||
JSONObject msgObject = JSONObject.parseObject(msgdata);
|
||||
//{"resultCode":"1","resultMsg":"No Result"}
|
||||
if(msgObject.containsKey("resultCode")){
|
||||
String resultCode = msgObject.getString("resultCode");
|
||||
if("0".equals(resultCode)){
|
||||
map.put("resultCode","0");
|
||||
}else{
|
||||
bb.writeLog(msgObject.get("resultMsg"));
|
||||
// sendPortalErrorUtil.doCreateSendPortalTodoErrorInfo();
|
||||
map.put("resultCode",resultCode);
|
||||
map.put("resultMsg",msgObject.get("resultMsg"));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
private String getShortMessageTitle(String messageTitle) {
|
||||
if (messageTitle.length() > 20) {
|
||||
messageTitle = messageTitle.substring(0, 17) + "...";
|
||||
}
|
||||
return messageTitle;
|
||||
}
|
||||
%>
|
||||
|
||||
@ -0,0 +1,18 @@
|
||||
import com.google.common.collect.Lists;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
public class TestMain {
|
||||
public static void main(String[] args) {
|
||||
List<String> list = Lists.newArrayList();
|
||||
list.add("11");
|
||||
list.add("22");
|
||||
list.add("11");
|
||||
for (String str : list){
|
||||
if ("22".equals(str)){
|
||||
return;
|
||||
}
|
||||
System.out.println(str);
|
||||
}
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue