diff --git a/src/weaver/interfaces/cxh/util/HttpUtil.java b/src/weaver/interfaces/cxh/util/HttpUtil.java new file mode 100644 index 0000000..420dc69 --- /dev/null +++ b/src/weaver/interfaces/cxh/util/HttpUtil.java @@ -0,0 +1,101 @@ +package weaver.interfaces.cxh.util; + +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.io.OutputStreamWriter; +import java.net.HttpURLConnection; +import java.net.URL; + +public class HttpUtil { + + public static String sendGet(String httpUrl) + { + + StringBuffer buffer = new StringBuffer(); + try { + //1.连接部分 + URL url = new URL(httpUrl); + // http协议传输 + HttpURLConnection httpUrlConn = (HttpURLConnection) url.openConnection(); + + httpUrlConn.setDoOutput(true); + httpUrlConn.setDoInput(true); + httpUrlConn.setUseCaches(false); + // 设置请求方式（GET/POST） + httpUrlConn.setRequestMethod("GET"); + httpUrlConn.setRequestProperty("content-type", "application/x-www-form-urlencoded"); + + //3.获取数据 + // 将返回的输入流转换成字符串 + InputStream inputStream = httpUrlConn.getInputStream(); + InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8"); + BufferedReader bufferedReader = new BufferedReader(inputStreamReader); + + String str = null; + while ((str = bufferedReader.readLine()) != null) { + buffer.append(str); + } + bufferedReader.close(); + inputStreamReader.close(); + // 释放资源 + inputStream.close(); + inputStream = null; + httpUrlConn.disconnect(); + } catch (Exception e) { + e.printStackTrace(); + } + return buffer.toString(); + } + + public static String sendPost(String url, String param) { + OutputStreamWriter out = null; + BufferedReader in = null; + String result = ""; + try { + URL realUrl = new URL(url); + HttpURLConnection conn = null; + // 打开和URL之间的连接 + conn = (HttpURLConnection) realUrl.openConnection(); + // 发送POST请求必须设置如下两行 + conn.setRequestMethod("POST"); // POST方法 + conn.setDoOutput(true); + conn.setDoInput(true); + // 设置通用的请求属性 + conn.setRequestProperty("accept", "*/*"); + conn.setRequestProperty("connection", "Keep-Alive"); + conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); + conn.setRequestProperty("Content-Type", "application/json"); + conn.connect(); + // 获取URLConnection对象对应的输出流 + out = new OutputStreamWriter(conn.getOutputStream(), "UTF-8"); + // 发送请求参数 + out.write(param); + // flush输出流的缓冲 + out.flush(); + // 定义BufferedReader输入流来读取URL的响应 + in = new BufferedReader(new InputStreamReader(conn.getInputStream(), "UTF-8")); + String line; + while ((line = in.readLine()) != null) { + result += line; + } + } catch (Exception e) { + } + // 使用finally块来关闭输出流、输入流 + finally { + try { + if (out != null) { + out.close(); + } + if (in != null) { + in.close(); + } + } catch (IOException ex) { + ex.printStackTrace(); + } + } + return result; + } + +} \ No newline at end of file diff --git a/src/weaver/interfaces/cxh/util/SendIMUtil.java b/src/weaver/interfaces/cxh/util/SendIMUtil.java new file mode 100644 index 0000000..0f3ddaa --- /dev/null +++ b/src/weaver/interfaces/cxh/util/SendIMUtil.java @@ -0,0 +1,70 @@ +package weaver.interfaces.cxh.util; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import org.apache.commons.codec.digest.DigestUtils; +import weaver.utils.DoPostUtil; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.Map; + +/** + * @title: SendMessage + * @Author zcqs + * @Date: 2022/8/30 10:51 + * @Version 1.0 + */ +public class SendIMUtil { + private static String url = "http://apis.njfu.edu.cn/mp_message_pocket_web-mp-restful-message-send/ProxyService/message_pocket_web-mp-restful-message-sendProxyService"; + private static String appId = "772056922b2065af"; + private static String accessToken = "f8818a51ccaf9bc323ba8566e646c8a6"; + + public boolean sendIM(String userId, String msg) { + + String content = msg; + String schoolCode = "10298"; + //String userId = "ampadmin"; + + Map headerMap = new HashMap<>(); + headerMap.put("appId", appId); + headerMap.put("accessToken", accessToken); + + Map params = new HashMap<>(); + params.put("appId", "772056922b2065af"); + params.put("subject", content); + params.put("content", content); + params.put("sendType", 0); + params.put("wxSendType", "text"); + params.put("sendNow", true); + params.put("tagId", 1012); + params.put("schoolCode", schoolCode); + + ArrayList> receivers = new ArrayList<>(); + HashMap receiverMap = new HashMap<>(); + receiverMap.put("userId", userId); + receiverMap.put("mobile", ""); + receiverMap.put("email", ""); + receiverMap.put("flag", 0); + receivers.add(receiverMap); + params.put("receivers", receivers); + + String sign = DigestUtils.md5Hex(accessToken + schoolCode + userId); + params.put("sign", sign); + Object json = JSON.toJSON(params); + System.out.println(json.toString()); + String s = DoPostUtil.doPost(url, new HashMap<>(), "application/json", headerMap, json.toString()); + System.out.println(s); + JSONObject jsonObject = JSON.parseObject(s); + int status = (int) jsonObject.get("status"); + String msg1 = (String) jsonObject.get("msg"); + System.out.println("status=== "+status); + System.out.println(msg1); + if (status == 200) { + return true; + } else { + return false; + } + } + +} diff --git a/src/weaver/interfaces/nl/job/ModifyJobActivityJob.java b/src/weaver/interfaces/nl/job/ModifyJobActivityJob.java index a32258e..598de91 100644 --- a/src/weaver/interfaces/nl/job/ModifyJobActivityJob.java +++ b/src/weaver/interfaces/nl/job/ModifyJobActivityJob.java @@ -26,10 +26,19 @@ public class ModifyJobActivityJob extends BaseCronJob { //获取处级正职的职务ID String divisionalPosition = Util.null2String(PropBean.getUfPropValue("DivisionalPosition"), "-1"); bb.writeLog("ModifyJobActivityJob divisionalPosition: " + divisionalPosition); + //获取不需要更新的部门ID + String noModifyDept = Util.null2String(PropBean.getUfPropValue("noModifyDept"), "-1"); + bb.writeLog("ModifyJobActivityJob noModifyDept: " + noModifyDept); if (StringUtils.isNotBlank(divisionalPosition) && !"-1".equals(divisionalPosition)) { Map map = new HashMap<>(); - String acqDeptSql = "select a.id, a.departmentid, d.departmentname " + + String sqlWhere = ""; + if (StringUtils.isNotBlank(noModifyDept)) { + if (!"0".equals(noModifyDept)) { + sqlWhere = "and d.supdepid not in (" + noModifyDept + ")"; + } + } + String acqDeptSql = "select a.id, d.supdepid, d.departmentname " + "from hrmresource a " + "left join hrmjobtitles b " + "on a.jobtitle = b.id " + @@ -37,12 +46,12 @@ public class ModifyJobActivityJob extends BaseCronJob { "on c.id = b.JOBACTIVITYid " + "left join hrmdepartment d " + "on d.id = a.departmentid " + - "where a.status in (0,1,2,3) and c.id in (" + divisionalPosition + ")"; + "where a.status in (0,1,2,3) and c.id in (" + divisionalPosition + ") " + sqlWhere; bb.writeLog("ModifyJobActivityJob acqDeptSql: " + acqDeptSql); rs.executeQuery(acqDeptSql); while (rs.next()) { String resId = Util.null2String(rs.getString("id")); - String departmentId = Util.null2String(rs.getString("departmentid")); + String departmentId = Util.null2String(rs.getString("supdepid")); if (map.containsKey(departmentId)) { String s = map.get(departmentId); s = s + "," + resId; @@ -79,10 +88,13 @@ public class ModifyJobActivityJob extends BaseCronJob { List modifyList = new ArrayList<>(); for( String depid : firstDepts) { String resId = Util.null2String(map.get(depid)); - List temp = new ArrayList(); - temp.add(resId); - temp.add(depid); - modifyList.add(temp); + if (StringUtils.isNotBlank(resId)) { + List temp = new ArrayList(); + temp.add(resId); + temp.add(depid); + modifyList.add(temp); + } + } bb.writeLog("ModifyJobActivityJob modifyList: " + modifyList); diff --git a/src/weaver/interfaces/nl/job/SendRequestForJZ.java b/src/weaver/interfaces/nl/job/SendRequestForJZ.java new file mode 100644 index 0000000..a373a5a --- /dev/null +++ b/src/weaver/interfaces/nl/job/SendRequestForJZ.java @@ -0,0 +1,724 @@ +package weaver.interfaces.nl.job; + +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import org.apache.http.HttpEntity; +import org.apache.http.NameValuePair; +import org.apache.http.client.entity.UrlEncodedFormEntity; +import org.apache.http.client.methods.CloseableHttpResponse; +import org.apache.http.client.methods.HttpPost; +import org.apache.http.impl.client.CloseableHttpClient; +import org.apache.http.impl.client.HttpClients; +import org.apache.http.message.BasicNameValuePair; +import weaver.conn.RecordSet; +import weaver.conn.RecordSetTrans; +import weaver.file.Prop; +import weaver.general.AES; +import weaver.general.TimeUtil; +import weaver.general.Util; +import weaver.hrm.User; +import weaver.integration.logging.Logger; +import weaver.integration.logging.LoggerFactory; +import weaver.interfaces.sso.cas.CasUtil; +import weaver.ofs.interfaces.SendRequestStatusDataInterfaces; +import weaver.workflow.request.todo.DataObj; +import weaver.workflow.request.todo.RequestStatusObj; +import weaver.interfaces.cxh.util.SendIMUtil; + +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStreamReader; +import java.io.OutputStreamWriter; +import java.net.URL; +import java.net.URLConnection; +import java.net.URLEncoder; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; +import java.util.regex.Matcher; +import java.util.regex.Pattern; + +public class SendRequestForJZ implements SendRequestStatusDataInterfaces { + //系统变量start + + /** + * 日志打印对象 + */ + private static Logger log = LoggerFactory.getLogger(SendRequestForJZ.class); + + /** + * 配置id + */ + private String id = ""; + + /** + * 系统编号 + */ + private String syscode = ""; + + /** + * 服务地址 + */ + private String serverurl = ""; + + /** + * 流程白名单 + */ + public ArrayList workflowwhitelist ; + + /** + * 人员白名单 + */ + public ArrayList userwhitelist ; + + /** + * settingid为ofs_sendinfo的id，实现类需要定义String id + * @return + */ + public String getId() { + return this.id; + } + + /** + * syscode为系统标识，实现类需要定义String syscode ; + * @return + */ + public String getSyscode() { + return this.syscode; + } + + /** + * serverurl为服务端访问url，实现类需要定义String serverurl ; + * @return + */ + public String getServerurl() { + return this.serverurl; + } + + /** + * 流程白名单 实现类需要定义ArrayList workflowwhitelist + * @return + */ + public ArrayList getWorkflowwhitelist() { + return this.workflowwhitelist; + } + + /** + * 人员白名单 实现类需要定义ArrayList userwhitelist + * @return + */ + public ArrayList getUserwhitelist() { + return this.userwhitelist; + } + + //系统变量end + ////////////////////////////////////////////////////////////////// + //接口变量start + + + //接口变量end + ////////////////////////////////////////////////////////////////// + + + private String oaaddress = "" ; + + private String accessToken = "" ; + + private String appId = "" ; + + private String bizDomain = "OA" ;//任务来源 --业务域：该工作流所在的业务域如学工、人事、教务、OA等（必填） + + private String processSource = "泛微OA" ;//流程来源，如："一表通平台"、"学工自定义状态机" + /** + * 发送接口数据 + * + * @param datas + */ + public void SendRequestStatusData(ArrayList datas) { + log.error("原始数据："+JSONObject.toJSONString(datas)); + if ("".equals(this.oaaddress)){ + RecordSet rsrtx = new RecordSet(); + String sqlStr = "select * from SystemSet"; + rsrtx.execute(sqlStr); + rsrtx.next(); + this.oaaddress = rsrtx.getString("oaaddress"); + } + + JSONObject json = new JSONObject() ; + + JSONArray insert = new JSONArray() ; + JSONArray update = new JSONArray() ; + + for (int i = 0; i < datas.size(); i++) { + DataObj obj = datas.get(i);//获取推送数据 + + //已办批量传输异构系统start + for (RequestStatusObj request:obj.getDonedatas()) { + if (!this.isPush(request)){ + continue; + } + + if (this.getIsSend(request)){ + update.add(this.getUpdate(request , 1)) ; + }else{ + insert.add(this.getInsert(request , 1)) ; + } + } + //已办批量传输异构系统end + //代办批量传输异构系统start + for (RequestStatusObj request:obj.getTododatas()) { + if (!this.isPush(request)){ + continue; + } + if (this.getIsSend(request)){ + update.add(this.getUpdate(request , 2)) ; + }else{ + insert.add(this.getInsert(request , 2)) ; + } + } + //代办批量传输异构系统end + //删除批量传输异构系统start + for (RequestStatusObj request:obj.getDeldatas()) { + if (!this.isPush(request)){ + continue; + } + if (this.getIsSend(request)){ + update.add(this.getUpdate(request , 3)) ; + }else{ + insert.add(this.getInsert(request , 3)) ; + } + } + + json.put("inserttasks" , insert) ; + json.put("updatetasks" , update) ; + + this.sendData(json); + //删除批量传输异构系统end + } + } + + private void sendData(JSONObject json){ + log.error("最终发送的数据为："+json.toJSONString()); + + + + /*JSONObject data = new JSONObject() ; + data.put("appId",this.appId) ; + data.put("taskInfo",json.toJSONString()) ;*/ + List params = new ArrayList(); + params.add(new BasicNameValuePair("appId", appId)); + params.add(new BasicNameValuePair("taskInfo", json.toJSONString())); + String result = null; + try { + result = this.post(this.serverurl , params); + } catch (Exception e) { + e.printStackTrace(); + } + log.error("返回结果 "+result); + + } + + + /** + * + * @param obj + * @return true 已发送过 false 未发送过 + */ + private boolean getIsSend(RequestStatusObj obj){ + RecordSetTrans rs = new RecordSetTrans(); + try{ + rs.executeQuery("select * from ofs_send_jz_log where cid = ? " , obj.getCid()) ; + if (rs.next()){ + return true ; + } + rs.executeUpdate("insert into ofs_send_jz_log (cid , request_id , workflow_id ,node_id,user_id,request_name,send_time)values(?,?,?,?,?,?,?) ", + obj.getCid() , obj.getRequestid() , obj.getWorkflowid() , obj.getNodeid() , obj.getUser().getUID() , obj.getRequestnamenew() , System.currentTimeMillis()) ; + return false ; + }catch (Exception e){ + e.printStackTrace(); + rs.rollback() ; + //插入数据失败按照 以发送过数据处理 + return true; + } + + } + + /** + * + * @param obj + * @param type + * @return + */ + private JSONObject getInsert(RequestStatusObj obj , int type){ + String createDepartmentName = this.getDepartmentName(obj.getCreator().getUserDepartment()) ; + String receiverDepartmentName = this.getDepartmentName(obj.getUser().getUserDepartment()) ;//候选人(任务审批人)部门 + String pcURL = this.getPcURL(obj.getRequestid() , obj.getUser().getUID() , 1) ; + String appURL = this.getAppURL(obj.getRequestid() , obj.getUser().getUID()) ; + + JSONObject json = new JSONObject() ; + json.put("app_id", appId); + json.put("task_id", appId+Util.null2String(obj.getCid())); + json.put("created_by_ids", obj.getCreator().getLoginid()); + json.put("created_by_names", obj.getCreator().getLastname()); + json.put("created_by_depts", Util.processBody(createDepartmentName, "7")); + json.put("subject", obj.getRequestnamenew()); + json.put("created_on", this.getDateTime(obj.getReceivedate() , obj.getReceivetime())); + + json.put("form_url", pcURL); + json.put("form_url_view", pcURL); + json.put("form_mobile_url", appURL); + json.put("form_mobile_url_view", appURL); + json.put("priority", this.getPriority(obj.getRequestlevel())) ;//1: 特急 2:紧急 3:一般 + json.put("biz_key", Util.null2String(obj.getRequestid())) ; + json.put("biz_domain", this.bizDomain) ;//任务来源 --业务域：该工作流所在的业务域如学工、人事、教务、OA等（必填） + json.put("biz_domain_subtype", Util.processBody(obj.getWorkflowname(), "7"));//所属类别 + json.put("is_merge_task", "0" ) ;//0:普通任务 1:合并型任务 固定值0 + json.put("merge_num", "");//合并任务数 + json.put("process_instance_id", Util.null2String(obj.getRequestid())) ;//流程实例ID（必填） + json.put("process_instance_initiator_id", obj.getCreator().getLoginid()) ;//流程实例发起人ID + json.put("process_instance_initiator" , obj.getCreator().getLastname()) ;//流程实例发起人姓名 + json.put("process_instance_initiator_dp" , createDepartmentName) ;//流程实例发起人所在部门 + + json.put("process_instance_start_date", this.getDateTime(obj.getCreatedate() , obj.getCreatetime())) ;//流程实例开始时间 + + json.put("process_instance_image_url", this.getPcURL(obj.getRequestid() , obj.getUser().getUID() , 2)) ;//流程图页面 + json.put("process_instance_subject" , obj.getRequestnamenew()) ;//流程实例主题（我发起的名称） + json.put("process_instance_form", pcURL) ;//流程实例查看表单 + json.put("process_instance_form_view", pcURL) ;//流程实例查看表单 + json.put("process_id", Util.null2String(obj.getWorkflowid())) ;//类型ID + json.put("process_source", this.processSource); + json.put("process_version", this.getProcessVersion(obj.getWorkflowid())) ;//流程版本 + json.put("process_name", Util.processBody(obj.getWorkflowname(), "7")) ;//流程定义名称 + json.put("task_delete_flag", "0"); + json.put("process_delete_flag", "0"); + + json.put("task_comment", this.getTaskComment(obj.getRequestid() , obj.getNodeid() , obj.getUser().getUID())); + json.put("node_name", obj.getNodename()); + json.put("node_id", obj.getNodeid()); + + + + if (type != 2){ + String endOn = this.getEndOn(obj.getRequestid()) ; + json.put("end_on", endOn); + json.put("process_instance_ent_date", endOn);//流程实例结束时间 + json.put("actual_owner_id", obj.getUser().getLoginid()); + json.put("actual_owner_name", obj.getUser().getLastname()); + json.put("actual_owner_dept", Util.processBody(receiverDepartmentName, "7")); + json.put("process_instance_status", "COMPLETE"); + json.put("status", "COMPLETE"); + }else{ + //待办 + json.put("process_instance_ent_date", "");//流程实例结束时间 + json.put("process_instance_status", "RUNNING"); + json.put("status", "ACTIVE"); + } + + json.put("assignments", this.getAssignments(obj.getUser().getLoginid() , obj.getUser().getLastname(), receiverDepartmentName)); + + //推送消息到今日校园 + new SendIMUtil().sendIM(obj.getUser().getLoginid(),obj.getRequestnamenew()); + return json ; + } + + /** + * + * @param obj + * @param type 1 已办 2 待办 3 删除 + * @return + */ + private JSONObject getUpdate(RequestStatusObj obj , int type){ + String createDepartmentName = this.getDepartmentName(obj.getCreator().getUserDepartment()) ; + String receiverDepartmentName = this.getDepartmentName(obj.getUser().getUserDepartment()) ;//候选人(任务审批人)部门 + + JSONObject json = new JSONObject() ; + json.put("app_id", this.appId); + json.put("task_id", appId+Util.null2String(obj.getCid())); + json.put("created_by_ids", obj.getCreator().getLoginid()); + json.put("created_by_names", obj.getCreator().getLastname()); + json.put("created_by_depts", Util.processBody(createDepartmentName, "7")); + json.put("subject", obj.getRequestnamenew()) ;//任务主题 + json.put("created_on", this.getDateTime(obj.getReceivedate() , obj.getReceivetime())) ; + if (type != 2){ + String endOn = this.getEndOn(obj.getRequestid()) ; + json.put("end_on", endOn); + json.put("actual_owner_id", obj.getUser().getLoginid()); + json.put("actual_owner_name", obj.getUser().getLastname()); + json.put("actual_owner_dept", Util.processBody(receiverDepartmentName, "7")); + } + json.put("task_comment", this.getTaskComment(obj.getRequestid() , obj.getNodeid() , obj.getUser().getUID())); + //删除需要的数据 + if (type == 3){ + //json.put("status", "ACTIVE"); + json.put("status", "COMPLETE"); + json.put("process_instance_status", "RUNNING"); + json.put("task_delete_flag", "1"); + json.put("process_delete_flag", "0"); + }else{ + if (type == 1){ + json.put("status", "COMPLETE"); + }else { + json.put("status", "ACTIVE"); + } + + json.put("process_name", Util.processBody(obj.getWorkflowname(), "7"));//流程定义名称 + json.put("process_version", this.getProcessVersion(obj.getWorkflowid())) ;//流程版本 + json.put("node_id", obj.getNodeid()); + json.put("node_name", obj.getNodename()); + + json.put("operate_on", this.getDateTime("","")); + json.put("operator_id", obj.getUser().getLoginid()); + json.put("operator_name", obj.getUser().getLastname()); + json.put("operator_dept", Util.processBody(receiverDepartmentName, "7")); + json.put("operate_type", "ACTIVE"); + } + + json.put("assignments", this.getAssignments(obj.getUser().getLoginid() , obj.getUser().getLastname(), receiverDepartmentName)); + return json ; + } + + private String getEndOn(int requestId){ + RecordSet rs = new RecordSet(); + rs.executeQuery("select * from workflow_requestbase where requestid = ?",requestId); + if(rs.next()){ + String nodeType = rs.getString("currentnodetype");//0：创建 1：审批 2：实现 3：归档 + if ("3".equals(nodeType)){ + return this.getDateTime(rs.getString("lastoperatedate") , rs.getString("lastoperatetime")); + } + } + return "" ; + } + + + private JSONArray getAssignments(String loginId , String name , String deptName){ + JSONArray list = new JSONArray() ; + JSONObject assignment = new JSONObject() ; + assignment.put("assign_dept" , Util.processBody(deptName, "7")) ;//候选人(任务审批人)部门 + assignment.put("assign_id" , loginId) ;//候选人(任务审批人)ID + assignment.put("assign_name" , name) ;//候选人(任务审批人)姓名 + list.add(assignment) ; + return list ; + } + + private String getProcessVersion(int workflowId){ + RecordSet rs = new RecordSet() ; + rs.executeQuery("select * from workflow_base where id= ? " , workflowId) ; + if (rs.next()){ + String processVersion = Util.null2String(rs.getString("version")); + if (!"".equals(processVersion)){ + return processVersion ; + } + } + return "1" ; + } + + /** + * 任务的紧急程度：用于任务排序，1: 特急 2:紧急 3:一般 + * 修改说明PS: 流程提供的 requestLevel 可以自定义 项目 定制了 4 特提 和5 普通，并且商议 后续在加的所以类型 默认都按照 一般处理。 + * @param requestLevel + * @return + */ + private String getPriority(int requestLevel){ + if (requestLevel == 1 || requestLevel == 2) + return "2"; + else if (requestLevel == 4) + return "1"; + else + return "3" ; + } + + + private String getDepartmentName(int departmentId){ + RecordSet rs = new RecordSet(); + rs.executeQuery("select departmentname from hrmdepartment where id = ?",departmentId); + if(rs.next()){ + return rs.getString("departmentname") ; + } + return "" ; + } + + + + private String getDateTime(String date , String time){ + StringBuilder dateTime = new StringBuilder() ; + if ("".equals(Util.null2String(date))){ + dateTime.append(TimeUtil.getCurrentDateString()) ; + }else { + dateTime.append(date) ; + } + dateTime.append(" ") ; + if ("".equals(Util.null2String(time))){ + dateTime.append(TimeUtil.getOnlyCurrentTimeString()) ; + }else { + dateTime.append(time) ; + } + return dateTime.toString().trim() ; + } + + + public String post(String url, List params) throws Exception { + CloseableHttpClient httpclient = HttpClients.createDefault(); + HttpPost httppost = new HttpPost(url); + System.out.println("url===== "+url); + httppost.setHeader("serviceId", syscode); + httppost.setHeader("appId", appId); + httppost.setHeader("accessToken", accessToken); + System.out.println("syscode===== "+syscode); + System.out.println("appId===== "+appId); + System.out.println("accessToken===== "+accessToken); + UrlEncodedFormEntity uefEntity; + StringBuilder sb = new StringBuilder(); + try { + if (params != null) { + uefEntity = new UrlEncodedFormEntity(params, "UTF-8"); + httppost.setEntity(uefEntity); + } + CloseableHttpResponse response = httpclient.execute(httppost); + BufferedReader in = null; + + try { + HttpEntity entity = response.getEntity(); + + in = new BufferedReader(new InputStreamReader(entity.getContent(), "UTF-8")); + String str = null; + while ((str = in.readLine()) != null) { + sb.append(str); + } + } finally { + response.close(); + in.close(); + } + } catch (Exception e) { + throw e; + } finally { + try { + httpclient.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + return sb.toString(); + } + + /** + * 将流程请求数据post出去 + * @param param + * @return + */ + private String postData(String url , String param) { + OutputStreamWriter out = null; + BufferedReader in = null; + String result = ""; + try { + URL realUrl = new URL(url); + // 打开和URL之间的连接 + URLConnection conn = realUrl.openConnection(); + // 设置通用的请求属性 + conn.setRequestProperty("accept", "*/*"); + conn.setRequestProperty("connection", "Keep-Alive"); + conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded"); + + conn.setRequestProperty("appId", this.appId); + conn.setRequestProperty("accessToken", this.accessToken); + // 发送POST请求必须设置如下两行 + conn.setDoOutput(true); + conn.setDoInput(true); + // 获取URLConnection对象对应的输出流 + out = new OutputStreamWriter(conn.getOutputStream(), "UTF-8"); + // 发送请求参数 + String encode = URLEncoder.encode(param, "UTF-8"); + out.write(encode); + // flush输出流的缓冲 + out.flush(); + // 定义BufferedReader输入流来读取URL的响应 + in = new BufferedReader( + new InputStreamReader(conn.getInputStream(),"UTF-8")); + String line; + while ((line = in.readLine()) != null) { + result += line; + } + } catch (Exception e) { + log.error("发送 POST 请求出现异常！",e); + e.printStackTrace(); + } + //使用finally块来关闭输出流、输入流 + finally{ + try{ + if(out!=null){ + out.close(); + } + if(in!=null){ + in.close(); + } + } + catch(IOException ex){ + ex.printStackTrace(); + } + } + return result ; + } + + /** + * 判定是否推送数据 + * @param obj + * @return + */ + private boolean isPush(RequestStatusObj obj){ + + String workflowid = obj.getWorkflowid()+""; + String requestid = obj.getRequestid()+""; + String resourceid = obj.getUser().getUID()+""; + + //判断该条流程是否需要发送异构系统 + if(this.workflowwhitelist==null){ + this.workflowwhitelist = new ArrayList(); + } + if(this.workflowwhitelist.size() > 0 && this.workflowwhitelist.indexOf(workflowid)==-1){//流程白名单 + log.info("Ecology统一待办数据推送：流程白名单中没有设置该流程，不需要发送，workflowid="+workflowid+"，requestid="+requestid); + return false; //不发送 + } + //判断该条人员是否需要发送异构系统或者 + if(this.userwhitelist==null){ + this.userwhitelist = new ArrayList(); + } + if(this.userwhitelist.size() > 0 && this.userwhitelist.indexOf(resourceid)==-1){//人员白名单 + log.info("Ecology统一待办数据推送：人员白名单中没有设置该用户，不需要发送，workflowid="+workflowid+", requestid="+requestid+"，userid="+resourceid); + return false; //不发送 + } + RecordSet rs = new RecordSet(); + rs.executeQuery("select status from hrmresource where id = ?",obj.getUser().getUID()); + if(rs.next()){ + int status = rs.getInt("status"); + if(status<4){ + return true; + }else{ + log.info("当前人员离职，不发送，userid："+obj.getUser().getUID()); + return false; //不发送 + } + }else{ + log.info("当前人员信息无效，不发送，userid："+obj.getUser().getUID()); + return false; //不发送 + } + } + + /** + * 构造PC地址 + * @param requestId + * @param userId + * @param type 1 流程地址 2流程图页面 + * @return + */ + private String getPcURL(int requestId , int userId , int type){ + + //StringBuffer url = new StringBuffer(this.oaaddress) ; + + StringBuilder tempURL = new StringBuilder(this.oaaddress); + if (type == 1){ + tempURL.append("/common/chatResource/view.html?resourcetype=0&resourceid=").append(requestId) + .append("&f_weaver_belongto_userid=").append(userId).append("&f_weaver_belongto_usertype=0"); + //tempURL.append("/workflow/request/ViewRequest.jsp"); + }else { + tempURL.append("/workflow/request/WorkflowRequestPictureInner.jsp"); + tempURL.append("?fromofs=1&requestid=").append(requestId) + .append("&f_weaver_belongto_userid=").append(userId).append("&f_weaver_belongto_usertype=0"); + } + + //没有开启cas 情况下 + //if (!isUseCas()){ + // String loginId = getMainLoginId(userId); + // tempURL.append("#").append(loginId) ; + // String password=Util.null2s(Prop.getPropValue("AESpassword", "pwd") , "1") ; + // url.append("/login/VerifySSoLogin.jsp?para=") + // .append(AES.encrypt(tempURL.toString(),password)) ; + //}else { + // url.append(tempURL) ; + //} + return tempURL.toString(); + } + + private String getAppURL(int requestId , int userId){ + String url = this.getURL(requestId , userId); + log.info("Ecology统一待办数据推送：getAppUrl(): result="+url); + return url; + } + + private String getURL(int requestId , int userId){ + StringBuilder url = new StringBuilder(this.oaaddress) ; + url.append("/wui/cas-entrance.jsp?path="); + url.append("https%3A%2F%2Fofficeauto.njfu.edu.cn%2Fspa%2Fworkflow%2Fstatic4mobileform%2Findex.html%3F_random%3D1640316447860%23%2Freq%3Frequestid%3D").append(requestId) + .append("%26f_weaver_belongto_userid%3D").append(userId).append("&f_weaver_belongto_usertype=0"); + return url.toString() ; + } + + private String getMainLoginId(int id){ + //判断是否是主账号 + RecordSet rs = new RecordSet(); + rs.executeQuery("select accounttype,belongto from hrmresource where id= ?" ,id); + if(rs.next()){ + String accounttype = Util.null2String(rs.getString("accounttype")); + if("1".equals(accounttype)){ + return new User(Util.getIntValue(rs.getString("belongto") , 1)).getLoginid() ; + } + } + return new User(id).getLoginid() ; + } + /** + * 是否使用CAS集成 + * + * @return + */ + private boolean isUseCas(){ + return new CasUtil().isUseCAS(); + } + + private String getTaskComment(int requestId , int nodeId , int userId){ + RecordSet rs = new RecordSet() ; + rs.executeQuery("select remark from workflow_requestlog where requestid=? and nodeid=? and operator= ?" , requestId , nodeId , userId) ; + if (rs.next()){ + return this.getTextFromHtml(Util.null2String(rs.getString("remark"))) ; + } + return "" ; + } + + /** + * 获取html代码中的文本 + * @param htmlStr + * @return + */ + private String getTextFromHtml(String htmlStr) { + htmlStr = this.delHTMLTag(htmlStr); + htmlStr = htmlStr.replaceAll(" ", ""); + + return htmlStr; + } + + /** + * 删除不需要的html代码 + * @param htmlStr + * @return + */ + private String delHTMLTag(String htmlStr) { + String regEx_script = "]*?>[\\s\\S]*?<\\/script>"; + String regEx_style = "]*?>[\\s\\S]*?<\\/style>"; + String regEx_html = "<[^>]+>"; + String regEx_space = "\\s*|\t|\r|\n"; + + Pattern p_script = Pattern.compile(regEx_script, 2); + Matcher m_script = p_script.matcher(htmlStr); + htmlStr = m_script.replaceAll(""); + + Pattern p_style = Pattern.compile(regEx_style, 2); + Matcher m_style = p_style.matcher(htmlStr); + htmlStr = m_style.replaceAll(""); + + Pattern p_html = Pattern.compile(regEx_html, 2); + Matcher m_html = p_html.matcher(htmlStr); + htmlStr = m_html.replaceAll(""); + + Pattern p_space = Pattern.compile(regEx_space, 2); + Matcher m_space = p_space.matcher(htmlStr); + htmlStr = m_space.replaceAll(""); + return htmlStr.trim(); + } + +}