diff --git a/com/engine/workflow/cmd/requestForm/FunctionManageCmd.java b/com/engine/workflow/cmd/requestForm/FunctionManageCmd.java index 5b3e0e9..d8ffb0f 100644 --- a/com/engine/workflow/cmd/requestForm/FunctionManageCmd.java +++ b/com/engine/workflow/cmd/requestForm/FunctionManageCmd.java @@ -43,6 +43,7 @@ import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.text.SimpleDateFormat; import java.util.*; +import java.util.stream.Collectors; /** * 功能管理 @@ -242,6 +243,7 @@ public class FunctionManageCmd extends AbstractCommonCommand> bb.writeLog("查询出的workflowid和currentnodeid不为空"); int cnt = 0; int touchnodeid = 0; + List touchnodeids = new ArrayList<>(); //查询配置表 String sczlc = "select COUNT(1) as cnt,touchnodeid,workflowid from uf_sczlc where workflowid=" + lcWorkflowid + " and nodeid=" + lcCurrentnodeid + " group by touchnodeid,workflowid"; @@ -252,8 +254,11 @@ public class FunctionManageCmd extends AbstractCommonCommand> while (rs.next()) { int workflowid1 = rs.getInt("workflowid"); if(workflowid==workflowid1) { - cnt = rs.getInt("cnt"); + // cnt = rs.getInt("cnt"); + cnt++; touchnodeid = rs.getInt("touchnodeid"); + touchnodeids.add(touchnodeid); + } } } catch (Exception e) { @@ -268,7 +273,10 @@ public class FunctionManageCmd extends AbstractCommonCommand> // select COUNT(*) as cnt from workflow_requestbase where mainrequestid=239239 List> subList = new ArrayList<>(); // String subWorkflowSql="select * from Workflow_SubwfSet where mainWorkflowId="+lcWorkflowid+" and triggerNodeId="+lcCurrentnodeid; - String subworkflowsql1 = "select workflowid subWorkflowId from workflow_requestbase where requestid in (select subrequestid from workflow_subwfrequest where subrequestid in (select requestid from workflow_requestbase where mainrequestid="+requestid+" and triggernode = "+touchnodeid+"))"; + String result = touchnodeids.stream() + .map(String::valueOf) + .collect(Collectors.joining(", ")); + String subworkflowsql1 = "select workflowid subWorkflowId from workflow_requestbase where requestid in (select subrequestid from workflow_subwfrequest where subrequestid in (select requestid from workflow_requestbase where mainrequestid="+requestid+" and triggernode in( "+result+" )))"; //String subWorkflowSql="select subWorkflowId from Workflow_SubwfSet where mainWorkflowId="+lcWorkflowid+" and triggerNodeId="+touchnodeid; bb.writeLog("subWorkflowSql-->"+subworkflowsql1); try { diff --git a/weaver/interfaces/workflow/action/javacode/Action20230911062023.java b/weaver/interfaces/workflow/action/javacode/Action20230911062023.java index 4852f5c..6212a2a 100644 --- a/weaver/interfaces/workflow/action/javacode/Action20230911062023.java +++ b/weaver/interfaces/workflow/action/javacode/Action20230911062023.java @@ -15,6 +15,7 @@ import weaver.general.StringUtil; import weaver.hrm.User; import weaver.interfaces.workflow.action.Action; import weaver.general.BaseBean; +import weaver.interfaces.workflow.action.WorkflowToDoc; import weaver.soa.workflow.request.RequestInfo; import java.io.*; @@ -32,6 +33,7 @@ public class Action20230911062023 extends BaseBean implements Action { */ @Override public String execute(RequestInfo request) { + new WorkflowToDoc().execute(request); writeLog("推送商旅节点后附加操作====>"); // if(error) { // request.getRequestManager().setMessageid("90001"); diff --git a/weavernorth/com/getCockpit.jsp b/weavernorth/com/getCockpit.jsp new file mode 100644 index 0000000..51441b3 --- /dev/null +++ b/weavernorth/com/getCockpit.jsp @@ -0,0 +1,472 @@ +<%-- + Created by IntelliJ IDEA. + User: xvshanshan + Date: 2023/7/3 + Time: 9:23 + To change this template use File | Settings | File Templates. +--%> +<%@ page import="weaver.conn.RecordSet" %> +<%@ page import="weaver.general.BaseBean" %> +<%@ page import="weaver.general.Util" %> +<%@ page import="com.alibaba.fastjson.JSONObject" %> +<%@ page import="com.alibaba.fastjson.JSONArray" %> +<%@ page import="java.util.regex.Pattern" %> +<%@ page import="java.util.regex.Matcher" %> +<%@ page import="java.io.*" %> +<%@ page import="weaver.hrm.User" %> +<%@ page import="java.text.SimpleDateFormat" %> +<%@ page import="java.util.*" %> +<%@ page language="java" contentType="text/html; charset=UTF-8"%> +<%@ page import="org.apache.http.impl.client.CloseableHttpClient" %> +<%@ page import="org.apache.http.impl.client.HttpClients" %> +<%@ page import="org.apache.http.client.methods.HttpPost" %> +<%@ page import="com.alibaba.fastjson.JSON" %> +<%@ page import="org.apache.http.entity.StringEntity" %> +<%@ page import="org.apache.http.client.methods.CloseableHttpResponse" %> +<%@ page import="org.apache.http.HttpStatus" %> +<%@ page import="org.apache.http.HttpEntity" %> +<%@ page import="org.apache.http.util.EntityUtils" %> +<%@ page import="org.apache.http.client.ClientProtocolException" %> +<%@ page import="weaver.hrm.HrmUserVarify" %> +<%@ page import="java.net.URL" %> +<%@ page import="java.net.HttpURLConnection" %> +<%@ page import="org.apache.http.HttpException" %> +<%@ page import="org.apache.http.client.HttpClient" %> +<%@ page import="org.apache.commons.httpclient.methods.PostMethod" %> +<%@ page import="org.apache.commons.httpclient.params.HttpMethodParams" %> +<%@ page import="org.apache.http.NameValuePair" %> +<%@ page import="org.apache.http.message.BasicNameValuePair" %> +<%@ page import="org.apache.http.client.entity.UrlEncodedFormEntity" %> +<%! + //获取分页sql + public static String getPaginationSql(String sql, String orderby, int pageNo, int pageSize) { + String execSql = ""; + + RecordSet rs = new RecordSet(); + String dbType = rs.getDBType(); +// String dbType = "oracle"; +// String dbType = "sqlserver"; + int firstResult = 0; + int endResult = 0; + // 返回分页sql + if("oracle".equals(dbType)){ // rownum + firstResult = pageNo * pageSize + 1; + endResult = (pageNo - 1) * pageSize; + execSql = " select * from ( select tabUN2.*,rownum as my_rownum from ( select tableUN.*,rownum as r from ( " + sql + + orderby + ") tableUN " + ") tabUN2 where r < " + firstResult + " ) where my_rownum > " + endResult; + }else if("sqlserver".equals(dbType)){ + sql="select *,row_number()OVER("+orderby+") as rn from ("+sql+") newt"; + execSql = "select * from ( " + + sql+")fy " + + " where rn between ("+pageNo+"-1)*"+pageSize+"+1 and "+pageNo+"*"+pageSize+" "; + }else { // 使用 ROW_NUMBER OVER()分页 + firstResult = pageNo * pageSize + 1; + endResult = (pageNo - 1) * pageSize; + execSql = " select * from ( select tabUN2.*,rownum as my_rownum from ( select tableUN.*,rownum as r from ( " + sql + + orderby +") tableUN ) tabUN2 where r < " + firstResult + " ) where my_rownum > " + endResult; + } + rs.writeLog("execSql---->"+execSql); + return execSql; + } + + + private boolean isEmpty(String str) { + if ("".equals(str) ||"(null)".equals(str) || str == null) { + return true; + } else { + return false; + } + } + + /** + * 获取指定类型的src值的集合 + * @param htmlStr + * @param type 标签名称 + * @return + */ + public static Set getSrcStr(String htmlStr, String type) { + Set srcs = new HashSet(); + String src = ""; + Pattern p_src; + Matcher m_src; +// String regEx_img = "]*?>"; //图片链接地址 + String regEx_src = "<"+type+".*src\\s*=\\s*(.*?)[^>]*?>"; + p_src = Pattern.compile + (regEx_src, Pattern.CASE_INSENSITIVE); + m_src = p_src.matcher(htmlStr); + while (m_src.find()) { +// 得到数据 + src = m_src.group(); +// 匹配中的src数据 + Matcher m = Pattern.compile("src\\s*=\\s*\"?(.*?)(\"|>|\\s+)").matcher(src); + while (m.find()) { + srcs.add(m.group(1)); + } + } + return srcs; + } + + + public String httpPostRequest(String param,String url,String token){ + BaseBean baseBean = new BaseBean(); + JSONObject jsonObject = new JSONObject(); + String responseBody=""; + try { + CloseableHttpClient httpClient = HttpClients.createDefault(); + HttpPost httpPost = new HttpPost(url); + JSONObject jsonString = JSON.parseObject(param); + + //设置请求体参数 + StringEntity entity = new StringEntity(param,"utf-8"); + baseBean.writeLog("entity-param->"+param); + baseBean.writeLog("entity-->"+entity); + entity.setContentEncoding("utf-8"); + baseBean.writeLog("entity-utf-8->"+entity); + httpPost.setEntity(entity); + //设置请求头部 + httpPost.setHeader("Content-Type", "application/json"); + if(token != null && !"".equals(token)){ + httpPost.setHeader("Authorization",token); + } + //执行请求，返回请求响应 + CloseableHttpResponse response = httpClient.execute(httpPost); + //请求返回状态码 + int statusCode = response.getStatusLine().getStatusCode(); + baseBean.writeLog("statusCode状态码->"+statusCode); + //请求成功 + if (statusCode == HttpStatus.SC_OK && statusCode <= HttpStatus.SC_TEMPORARY_REDIRECT) { + //取出响应体 + HttpEntity entity2 = response.getEntity(); + //从响应体中解析出token + responseBody = EntityUtils.toString(entity2, "utf-8"); +// jsonObject = JSONObject.parseObject(responseBody); + baseBean.writeLog("responseBody->"+responseBody); +// baseBean.writeLog("jsonObject->"+jsonObject); + //token = jsonObject.getString("access_token"); + } else { + //请求失败 + throw new ClientProtocolException("请求失败，响应码为：" + statusCode); + } + } catch (Exception e) { + e.printStackTrace(); + } + return responseBody; + } + + /** + * 向指定URL发送GET方法的请求 + * + * @param url 发送请求的URL + * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。 + * @return URL 所代表远程资源的响应结果 + */ + public static String sendGet(String url, String param) { + BaseBean bb = new BaseBean(); + String result = ""; + String responseMessage=""; + BufferedReader in = null; + HttpURLConnection connection = null; + try { + URL getUrl = new URL(url + "?" + param); + bb.writeLog("getUrl-->"+getUrl); + // 打开和URL之间的连接 + connection = (HttpURLConnection) getUrl.openConnection(); + + // 在connect之前，设置通用的请求属性 + connection.setRequestProperty("accept", "*/*"); + connection.setRequestProperty("connection", "Keep-Alive"); + connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); + connection.setRequestProperty("Charsert", "UTF-8"); + + // 配置本次连接的Content-type，form表单是"application/x-www-form-urlencoded"，json是"application/json"等 + // 根据需求自己调整Content-type + connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded"); + // 设置连接主机服务器的超时时间：15000毫秒 + connection.setConnectTimeout(15000); + // 设置读取远程返回的数据时间：60000毫秒 + connection.setReadTimeout(60000); + // 设置连接方式：get + connection.setRequestMethod("GET"); + // 建立实际的连接，可不写，注意connection.getOutputStream会隐含的进行connect。 + connection.connect(); + + // 获取所有响应头字段 + Map> map = connection.getHeaderFields(); + // 遍历所有的响应头字段 + for (String key : map.keySet()) { + bb.writeLog(key + "--->" + map.get(key)); + } + + + // 定义BufferedReader输入流来读取URL的响应 + if (connection.getResponseCode() == 200) { + in = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8")); + String line; + while ((line = in.readLine()) != null) { + result += line; + } + } + } catch (Exception e) { + bb.writeLog("发送GET请求出现异常！" + e); + e.printStackTrace(); + } + // 使用finally块来关闭输入流 + finally { + try { + if (in != null) { + in.close(); + } + if (connection != null) { + //关闭连接 + connection.disconnect(); + } + } catch (Exception e2) { + e2.printStackTrace(); + } + } + return result; + } + + /** + * 向指定 URL 发送POST方法的请求 + * + * @param url 发送请求的 URL + * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。 + * @return 所代表远程资源的响应结果 + */ + public static String sendPost(String url, String param) { + BaseBean bb = new BaseBean(); + String result = ""; + PrintWriter out = null; + BufferedReader in = null; + HttpURLConnection connection = null; + try { + URL postUrl = new URL(url); + bb.writeLog("getUrl-->"+postUrl); + // 打开和URL之间的连接 + connection = (HttpURLConnection) postUrl.openConnection(); + + // 在connect之前，设置通用的请求属性 + connection.setRequestProperty("accept", "*/*"); + connection.setRequestProperty("connection", "Keep-Alive"); + connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); + connection.setRequestProperty("Charsert", "UTF-8"); + + connection.setConnectTimeout(15000); + connection.setReadTimeout(60000); + // 发送POST请求必须设置如下两行，参数要放在http正文内 + connection.setDoOutput(true); + connection.setDoInput(true); + // 默认是 GET方式 + connection.setRequestMethod("POST"); + // Post 请求不使用缓存 + connection.setUseCaches(false); + // 配置本次连接的Content-type，form表单是"application/x-www-form-urlencoded"，json是"application/json"等 + connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded"); + connection.connect(); + + // 参数要放在http正文内 + //1.获取URLConnection对象对应的输出流 + out = new PrintWriter(connection.getOutputStream()); + //2.中文有乱码的需要将PrintWriter改为如下 + //out=new OutputStreamWriter(conn.getOutputStream(),"UTF-8") + out.print(param); + out.flush(); + //也可以使用DataOutputStream +// DataOutputStream dos=new DataOutputStream(httpConn.getOutputStream()); +// dos.writeBytes(param); +// dos.flush(); +// dos.close(); + + // 定义BufferedReader输入流来读取URL的响应 + if (connection.getResponseCode() == 200) { + in = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8")); + String line; + while ((line = in.readLine()) != null) { + result += line; + } + } + } catch (Exception e) { + bb.writeLog("发送 POST 请求出现异常！" + e); + e.printStackTrace(); + } finally { + try { + if (out != null) { + out.close(); + } + if (in != null) { + in.close(); + } + if (connection != null) { + //关闭连接 + connection.disconnect(); + } + } catch (IOException ex) { + ex.printStackTrace(); + } + } + return result; + } + + + /** + * 发送 http post 请求，参数以form表单键值对的形式提交。 + */ + public static String httpPostForm(String url,Map params, Map headers,String encode){ + BaseBean bb = new BaseBean(); + if(encode == null){ + encode = "utf-8"; + } + + String content = null; + CloseableHttpResponse httpResponse = null; + CloseableHttpClient closeableHttpClient = null; + try { + + closeableHttpClient = HttpClients.createDefault(); + HttpPost httpost = new HttpPost(url); + + //设置header + if (headers != null && headers.size() > 0) { + for (Map.Entry entry : headers.entrySet()) { + httpost.setHeader(entry.getKey(),entry.getValue()); + } + } + bb.writeLog("url="+url+"header="+headers+"encode="+encode); + bb.writeLog("params="+params); + //组织请求参数 + List paramList = new ArrayList (); + if(params != null && params.size() > 0){ + Set keySet = params.keySet(); + for(String key : keySet) { + paramList.add(new BasicNameValuePair(key, params.get(key))); + } + } + httpost.setEntity(new UrlEncodedFormEntity(paramList, encode)); + + httpResponse = closeableHttpClient.execute(httpost); + HttpEntity entity = httpResponse.getEntity(); + content = EntityUtils.toString(entity, encode); + } catch (Exception e) { + e.printStackTrace(); + }finally{ + try { + httpResponse.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + try { //关闭连接、释放资源 + closeableHttpClient.close(); + } catch (IOException e) { + e.printStackTrace(); + } + return content; + } + +%> +<% + RecordSet rs = new RecordSet(); + BaseBean bb=new BaseBean(); + Map params = new HashMap<>();//参数 + Map headers = new HashMap<>();//headers + JSONArray array = new JSONArray(); + String ST ="";//获取ST + bb.writeLog("进入getCockpit.jap-->"); + + User user = HrmUserVarify.getUser(request, response); + int uid = user.getUID(); + session = request.getSession(true); + String certified_token = Util.null2String(session.getAttribute("certified_token")); + bb.writeLog("获取sessionTGT=="+certified_token); + bb.writeLog("uid-->"+uid); + //查询邮箱号 + //http://${单点系统地址}/sso_server/api/v1/thirdSystem/getList + +// String httpPostRequest="https://www.baidu.com/"; + String API_KEY = Util.null2String(bb.getPropValue("tjbankEMobileSSO","key")); + String url = Util.null2String(bb.getPropValue("tjbankEMobileSSO","stUrl"));//获取ST的url + String cockpitUrl = Util.null2String(bb.getPropValue("tjbankEMobileSSO","cockpitUrl")); + String thirdUrl = Util.null2String(bb.getPropValue("tjbankEMobileSSO","thirdUrl"));//获取下流系统 + //thirdUrl + //获取ST，带着下游系统 + if (!isEmpty(certified_token)){ + params = new HashMap<>();//参数 + params.put("tgt",certified_token); + + headers = new HashMap<>();//headers + headers.put("API_KEY",API_KEY); + headers.put("MACH_ID","123"); + headers.put("MACH_TYPE","0"); + headers.put("MACH_IP","127.0.0.1"); + String result = httpPostForm(thirdUrl,params,headers,null); + org.json.JSONObject thirdMsg = new org.json.JSONObject(result); + bb.writeLog("进入thirdMsg-->"+thirdMsg); + + //String addressUrl="http://${单点系统地址}/sso_server/api/v1/tickets/createST"; + params = new HashMap<>();//参数 + params.put("tgt",certified_token); + params.put("service",cockpitUrl); + bb.writeLog("==STparams-->"+params); + + headers = new HashMap<>();//headers + headers.put("API_KEY",API_KEY); + headers.put("MACH_ID","123"); + headers.put("MACH_TYPE","0"); + headers.put("MACH_IP","127.0.0.1"); +// String param="?user_at_domain%3D"+email; + String responseInfo = httpPostForm(url,params,headers,null); + bb.writeLog("进入TGT-->"+certified_token); + bb.writeLog("进入接口地址-->"+url); + bb.writeLog("进入responseInfo-->"+responseInfo); + if (isEmpty(responseInfo)){ + out.print("单点系统接口返回值为null"); + return; + }else { + org.json.JSONObject stMsg = new org.json.JSONObject(responseInfo); + if(stMsg.has("ST")){ + ST = Util.null2String(stMsg.get("ST").toString()); + }else{ + out.print(Util.null2String(stMsg.getString("message"))); + return; + } + + String loginUrl = ""; + boolean isEm = Util.null2String(request.getHeader("user-agent")).indexOf("E-Mobile") > -1; + if(isEm == true){ + bb.writeLog("是否进来了"); + //loginUrl="http://123.151.115.199:8080/bi/APPFW?proc=1&action=viewer&hback=true&db=%E6%99%BA%E6%85%A7%E6%96%B9%E7%95%A5/%E5%89%8D%E7%BD%AE%E9%A1%B5.db?ticket="+ST; + loginUrl="http://168.5.72.9:8080/bi/APPFW?ticket="+ST; + bb.writeLog("是否进来了loginUrl=="+loginUrl); + } + } + //String loginUrl="http://10.16.103.18:9900/coremail/main.jsp?sid="+sid; +// httpPostRequest = httpPostRequest(null, loginUrl, null); + bb.writeLog("loginUrl-->"+loginUrl); +// bb.writeLog("跳转路径-->"+httpPostRequest); + out.print("跳转路径-->"+loginUrl); + out.print("进入驾驶舱成功"); + response.sendRedirect(loginUrl); +// return; + } + }else { + out.print("进入驾驶舱系统失败,请先获取标识"); +// response.sendRedirect(httpPostRequest); + return; + } + +%> + +　 diff --git a/weavernorth/com/getCockpitBak.jsp b/weavernorth/com/getCockpitBak.jsp new file mode 100644 index 0000000..448d9f9 --- /dev/null +++ b/weavernorth/com/getCockpitBak.jsp @@ -0,0 +1,61 @@ +<%@ page import="weaver.conn.RecordSet" %> +<%@ page import="weaver.general.BaseBean" %> +<%@ page import="com.alibaba.fastjson.JSONObject" %> +<%@ page import="com.alibaba.fastjson.JSONArray" %> +<%@ page language="java" contentType="text/html; charset=UTF-8"%> +<%! + private boolean isEmpty(String str) { + if ("".equals(str) ||"(null)".equals(str) || str == null) { + return true; + } else { + return false; + } + } +%> +<% + RecordSet rs = new RecordSet(); + BaseBean bb=new BaseBean(); + JSONArray array = new JSONArray(); + JSONObject json = new JSONObject(); + bb.writeLog("进入getdeleCount.jsp-->"); + String resquestid=request.getParameter("resquestid"); + int count=0; + String mainWorkflowid = "0"; + String touchnodeid = "0"; + if (!isEmpty(resquestid)){ + String queryMainWorkflowidSql = "select workflowid from workflow_requestbase where requestid="+resquestid; + bb.writeLog("queryMainWorkflowidSql-->"+queryMainWorkflowidSql); + rs.execute(queryMainWorkflowidSql); + if(rs.next()){ + mainWorkflowid = rs.getString(1); + } + + String queryTouchNodeidSql = "select touchnodeid from uf_sczlc where workflowid="+mainWorkflowid; + bb.writeLog("queryTouchNodeidSql-->"+queryTouchNodeidSql); + rs.execute(queryTouchNodeidSql); + if(rs.next()){ + touchnodeid = rs.getString(1); + } + + String sql="select COUNT(*) as cnt from workflow_requestbase where mainrequestid="+resquestid+" and workflowid in (select workflowid subWorkflowId from workflow_requestbase where requestid in (select subrequestid from workflow_subwfrequest where subrequestid in (select requestid from workflow_requestbase where mainrequestid="+resquestid+" and triggernode = "+touchnodeid+")))"; + bb.writeLog("sql-->"+sql); + rs.execute(sql); + if (rs.next()){ + count=rs.getInt("cnt"); + json.put("code",0); + json.put("count",count); + array.add(json); + out.print(array.toJSONString()); + }else { + json.put("code",1); + json.put("errMsg","查无此resquestid"); + array.add(json); + out.print(array.toJSONString()); + } + }else { + json.put("code",1); + json.put("errMsg","resquestid为空"); + array.add(json); + out.print(array.toJSONString()); + } +%> diff --git a/weavernorth/com/getdeleCount.jsp b/weavernorth/com/getdeleCount.jsp new file mode 100644 index 0000000..ce8c1ff --- /dev/null +++ b/weavernorth/com/getdeleCount.jsp @@ -0,0 +1,62 @@ +<%@ page import="weaver.conn.RecordSet" %> +<%@ page import="weaver.general.BaseBean" %> +<%@ page import="com.alibaba.fastjson.JSONObject" %> +<%@ page import="com.alibaba.fastjson.JSONArray" %> +<%@ page language="java" contentType="text/html; charset=UTF-8"%> +<%! + private boolean isEmpty(String str) { + if ("".equals(str) ||"(null)".equals(str) || str == null) { + return true; + } else { + return false; + } + } +%> +<% + RecordSet rs = new RecordSet(); + BaseBean bb=new BaseBean(); + JSONArray array = new JSONArray(); + JSONObject json = new JSONObject(); + bb.writeLog("进入getdeleCount.jsp-->"); + String resquestid=request.getParameter("resquestid"); + int count=0; + String mainWorkflowid = "0"; + String touchnodeid = "0"; + if (!isEmpty(resquestid)){ + String queryMainWorkflowidSql = "select workflowid from workflow_requestbase where requestid="+resquestid; + bb.writeLog("queryMainWorkflowidSql-->"+queryMainWorkflowidSql); + rs.execute(queryMainWorkflowidSql); + if(rs.next()){ + mainWorkflowid = rs.getString(1); + } + + String queryTouchNodeidSql = "select touchnodeid from uf_sczlc where workflowid="+mainWorkflowid; + bb.writeLog("queryTouchNodeidSql-->"+queryTouchNodeidSql); + rs.execute(queryTouchNodeidSql); + if(rs.next()){ + touchnodeid = rs.getString(1); + } + + String sql="select COUNT(*) as cnt from workflow_requestbase where mainrequestid="+resquestid+" and workflowid in (select workflowid subWorkflowId from workflow_requestbase where requestid in (select subrequestid from workflow_subwfrequest where subrequestid in (select requestid from workflow_requestbase where mainrequestid="+resquestid+" and triggernode = "+touchnodeid+")))"; + bb.writeLog("sql-->"+sql); + rs.execute(sql); + if (rs.next()){ + count=rs.getInt("cnt"); + json.put("code",0); + json.put("count",count); + array.add(json); + out.print(array.toJSONString()); + }else { + json.put("code",1); + json.put("errMsg","查无此resquestid"); + array.add(json); + out.print(array.toJSONString()); + } + }else { + json.put("code",1); + json.put("errMsg","resquestid为空"); + array.add(json); + out.print(array.toJSONString()); + } +%> + diff --git a/weavernorth/com/getdeleType.jsp b/weavernorth/com/getdeleType.jsp new file mode 100644 index 0000000..3909e09 --- /dev/null +++ b/weavernorth/com/getdeleType.jsp @@ -0,0 +1,92 @@ +<%@ page import="weaver.conn.RecordSet" %> +<%@ page import="weaver.general.BaseBean" %> +<%@ page import="weaver.general.Util" %> +<%@ page import="com.alibaba.fastjson.JSONObject" %> +<%@ page import="com.alibaba.fastjson.JSONArray" %> +<%@ page import="java.util.regex.Pattern" %> +<%@ page import="java.util.regex.Matcher" %> +<%@ page import="java.io.*" %> +<%@ page import="weaver.docs.webservices.DocInfo" %> +<%@ page import="weaver.docs.webservices.DocAttachment" %> +<%@ page import="org.apache.axis.encoding.Base64" %> +<%@ page import="weaver.docs.webservices.DocServiceImpl" %> +<%@ page import="weaver.hrm.User" %> +<%@ page import="java.text.SimpleDateFormat" %> +<%@ page import="java.util.*" %> +<%@ page import="org.apache.commons.lang.StringUtils" %> +<%@ page language="java" contentType="text/html; charset=UTF-8"%> +<%@ page import="org.apache.http.impl.client.CloseableHttpClient" %> +<%@ page import="org.apache.http.impl.client.HttpClients" %> +<%@ page import="org.apache.http.client.methods.HttpPost" %> +<%@ page import="com.alibaba.fastjson.JSON" %> +<%@ page import="org.apache.http.entity.StringEntity" %> +<%@ page import="org.apache.http.client.methods.CloseableHttpResponse" %> +<%@ page import="org.apache.http.HttpStatus" %> +<%@ page import="org.apache.http.HttpEntity" %> +<%@ page import="org.apache.http.util.EntityUtils" %> +<%@ page import="org.apache.http.client.ClientProtocolException" %> +<%@ page import="weaver.hrm.HrmUserVarify" %> +<%@ page import="java.net.URL" %> +<%@ page import="java.net.HttpURLConnection" %> +<%@ page import="org.apache.http.HttpException" %> +<%@ page import="org.apache.http.client.HttpClient" %> +<%@ page import="org.apache.commons.httpclient.methods.PostMethod" %> +<%@ page import="org.apache.commons.httpclient.params.HttpMethodParams" %> +<%! + private boolean isEmpty(String str) { + if ("".equals(str) ||"(null)".equals(str) || str == null) { + return true; + } else { + return false; + } + } +%> +<% + RecordSet rs = new RecordSet(); + BaseBean bb=new BaseBean(); + JSONArray array = new JSONArray(); + JSONObject json = new JSONObject(); + bb.writeLog("进入getdeleType.jsp-->"); + String workflowid=request.getParameter("workflowid"); + String nodeid="-1"; + String requestid=request.getParameter("requestid"); + rs.execute("select lastnodeid from workflow_requestbase where requestid = "+requestid); + if(rs.next()){ + nodeid = rs.getString(1); + } + if (!isEmpty(workflowid) && !isEmpty(nodeid)) { + bb.writeLog("workflowid和nodeid不为空"); + int cnt = 0; + //查询配置表 + String sczlc = "select COUNT(*) as cnt from uf_sczlc where workflowid=" + workflowid + " and nodeid=" + nodeid; + bb.writeLog("sczlcSql-->" + sczlc); + try { + rs.execute(sczlc); + bb.writeLog("sczlc查询数据-->"); + if (rs.next()) { + cnt = rs.getInt("cnt"); + } + } catch (Exception e) { + e.printStackTrace(); + } + bb.writeLog("cnt结果-->" + cnt); + if (cnt>0){ + json.put("code",0); + json.put("count",cnt); + array.add(json); + out.print(array.toJSONString()); + }else { + json.put("code",1); + json.put("errMsg","查无此workflowid或nodeid数据"); + array.add(json); + out.print(array.toJSONString()); + } + }else { + json.put("code",1); + json.put("errMsg","workflowid或nodeid为空"); + array.add(json); + out.print(array.toJSONString()); + } + +%> +