#EC-HJ-10# 邮件发送及待办代码优化
parent
3603d8a03b
commit
3c7f2fe0c3
@ -0,0 +1,720 @@
|
||||
package com.customization.sendtodo;
|
||||
|
||||
import com.alibaba.fastjson.JSONArray;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import weaver.conn.RecordSet;
|
||||
import weaver.general.BaseBean;
|
||||
import weaver.general.Util;
|
||||
import weaver.hrm.User;
|
||||
import weaver.interfaces.util.SendMailUtil;
|
||||
|
||||
import java.util.regex.Matcher;
|
||||
import java.util.regex.Pattern;
|
||||
|
||||
public class SendPortalTodoRunnable implements Runnable{
|
||||
|
||||
public String EMAIL_REGEX_DEFAULT = "^([a-z0-9A-Z]+[-|\\.]?)+[a-z0-9A-Z]@([a-z0-9A-Z]+(-[a-z0-9A-Z]+)?\\.)+[a-zA-Z]{2,}$";
|
||||
|
||||
private String src;
|
||||
private String new_requestid;
|
||||
private String requestid;
|
||||
private String nodeid;
|
||||
private User user;
|
||||
|
||||
public SendPortalTodoRunnable(String src,String new_requestid,String requestid,String nodeid, User user){
|
||||
this.src = src;
|
||||
this.new_requestid = new_requestid;
|
||||
this.requestid = requestid;
|
||||
this.nodeid = nodeid;
|
||||
this.user = user;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run() {
|
||||
|
||||
BaseBean bb = new BaseBean();
|
||||
String portal_todourl = bb.getPropValue("PORTAL_INFO","portal_todourl");
|
||||
String username = bb.getPropValue("PORTAL_INFO","username");
|
||||
String passwd = bb.getPropValue("PORTAL_INFO","passwd");
|
||||
String center = bb.getPropValue("PORTAL_INFO","center");
|
||||
String bpm_workflowurl = bb.getPropValue("PORTAL_INFO","bpm_workflowurl");
|
||||
|
||||
|
||||
if(Util.getIntValue(requestid) == -1 && "save".equals(src)){
|
||||
sendTodoDataByCreater(new_requestid,user,portal_todourl,username,passwd,bpm_workflowurl,center);
|
||||
}else if(Util.getIntValue(requestid) == -1 && "submit".equals(src)){
|
||||
sendTodoDataByCreateNode(new_requestid,nodeid,user,portal_todourl,username,passwd,bpm_workflowurl,center);
|
||||
}else if(Util.getIntValue(requestid)> 0 && "submit".equals(src)){
|
||||
sendTodoDataByNode(requestid,nodeid,user,portal_todourl,username,passwd,bpm_workflowurl,center);
|
||||
}else if(Util.getIntValue(requestid)> 0 && "reject".equals(src)){
|
||||
sendTodoDataByReject(requestid,nodeid,user,portal_todourl,username,passwd,bpm_workflowurl,center);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/***
|
||||
*
|
||||
* @param requestId
|
||||
* @param user
|
||||
*/
|
||||
public void sendTodoDataByCreater(String requestId, User user, String portal_todourl, String username, String passwd, String bpm_workflowurl, String center){
|
||||
|
||||
//HttpReqUtils httpReqUtils = new HttpReqUtils();
|
||||
|
||||
SendPortalTodoUtil sendPortalTodoUtil = new SendPortalTodoUtil();
|
||||
SendMailUtil sendMailUtil = new SendMailUtil();
|
||||
BaseBean bb = new BaseBean();
|
||||
RecordSet rs = new RecordSet();
|
||||
|
||||
JSONArray emailArray = new JSONArray();
|
||||
|
||||
|
||||
String requestname = "";
|
||||
String requestremark = "" ;
|
||||
String actionType = "0" ;
|
||||
String terminal = "1" ;
|
||||
String taskType = "0";
|
||||
String ticketType = center ;
|
||||
Pattern regex = Pattern.compile(EMAIL_REGEX_DEFAULT);
|
||||
|
||||
JSONObject requestObject = new JSONObject();
|
||||
try {
|
||||
int userid = user.getUID();
|
||||
String sql =" select t1.requestname,t1.requestmark,t1.creater,t2.nodeid,t1.createdate,t1.createtime,h1.lastname,h1.loginid,\n" +
|
||||
" t1.requestid as taskcode,d1.nodename,h1.email\n" +
|
||||
" from workflow_requestbase t1\n" +
|
||||
" inner join workflow_currentoperator t2 on t1.requestid = t2.requestid\n" +
|
||||
" inner join workflow_base t3 on t1.workflowid = t3.id\n" +
|
||||
" left join workflow_nodebase d1 on d1.id = t1.currentnodeid "+
|
||||
" left join (select id, lastname,loginid,email from hrmresource where status = 1 union all select id,lastname,loginid,'' as email from hrmresourcemanager ) h1 on h1.id = t1.creater\n" +
|
||||
" where t2.userid in ("+userid+") \n" +
|
||||
" and (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and ((t2.isremark = '0' and (t2.takisremark is null or t2.takisremark = 0)) or t2.isremark in ('1', '5', '8', '9', '7', '11'))\n" +
|
||||
" and (ifnull(t1.currentstatus, -1) = -1 or (ifnull(t1.currentstatus, -1) = 0 and t1.creater in ("+userid+"))) \n" +
|
||||
" and t2.islasttimes = 1 \n" +
|
||||
" and (t2.isprocessing = '' or t2.isprocessing is null) \n" +
|
||||
" and t2.requestid = "+requestId ;
|
||||
|
||||
rs.executeQuery(sql);
|
||||
if (rs.next()){
|
||||
|
||||
String title = Util.null2String(rs.getString("requestname")) ;
|
||||
String creator = Util.null2String(rs.getString("loginid")) ;
|
||||
String taskCode = Util.null2String(rs.getString("taskcode")) ;
|
||||
String nodeId = Util.null2String(rs.getString("nodeid")) ;
|
||||
|
||||
String createdate = Util.null2String(rs.getString("createdate")) ;
|
||||
String createtime = Util.null2String(rs.getString("createtime")) ;
|
||||
String messageTitle = Util.null2String(rs.getString("requestname")) ;
|
||||
String messageContent = Util.null2String(rs.getString("requestname")) ;
|
||||
|
||||
String 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);
|
||||
|
||||
JSONArray taskObjectList = new JSONArray();
|
||||
JSONObject taskObject = new JSONObject();
|
||||
String objectAction = "0" ;
|
||||
String objectType = "0";
|
||||
String objectCode = creator ;
|
||||
String objectId = "" ;
|
||||
String operatorCode = creator ;
|
||||
|
||||
taskObject.put("objectAction",objectAction);
|
||||
taskObject.put("objectType",objectType);
|
||||
taskObject.put("objectCode",objectCode);
|
||||
taskObject.put("objectId",objectId);
|
||||
taskObject.put("operatorCode",operatorCode);
|
||||
taskObjectList.add(taskObject);
|
||||
|
||||
requestObject.put("taskObjectList",taskObjectList);
|
||||
|
||||
|
||||
String email = Util.null2String(rs.getString("email")) ;
|
||||
Matcher matcher = regex.matcher(email);
|
||||
if(matcher.matches()){
|
||||
emailArray.add(email);
|
||||
}
|
||||
}
|
||||
|
||||
bb.writeLog("dataJsonnew:"+requestObject.toJSONString());
|
||||
// String username = "admin";
|
||||
// String passwd = "Uportal_123";
|
||||
// String todourl = "http://172.16.25.133/portal-web/centerTodo/sync" ;
|
||||
String auth = username + ":" + passwd;
|
||||
String msgdata = sendPortalTodoUtil.doPostByAuth(portal_todourl,requestObject.toJSONString(),auth);
|
||||
bb.writeLog("msgdata:"+msgdata);
|
||||
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)){
|
||||
|
||||
System.out.println(emailArray.toJSONString());
|
||||
String notificationSubject = "";
|
||||
String notificationContent = "" ;
|
||||
sendMailUtil.sendMail(requestId,emailArray.toJSONString(),notificationSubject,notificationContent);
|
||||
|
||||
}else{
|
||||
sendPortalTodoUtil.doCreateSendPortalTodoErrorInfo();
|
||||
}
|
||||
}
|
||||
}
|
||||
} 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){
|
||||
|
||||
//HttpReqUtils httpReqUtils = new HttpReqUtils();
|
||||
SendPortalTodoUtil sendPortalTodoUtil = new SendPortalTodoUtil();
|
||||
SendMailUtil sendMailUtil = new SendMailUtil();
|
||||
|
||||
JSONObject requestObject = new JSONObject();
|
||||
|
||||
JSONArray emailArray = new JSONArray();
|
||||
BaseBean bb = new BaseBean();
|
||||
bb.writeLog("sendTodoDataByCreateNode");
|
||||
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 = "0" ;
|
||||
JSONArray taskObjectList = new JSONArray();
|
||||
sql = " select t1.requestname,t1.requestmark,t1.creater,t1.createdate,t1.createtime,h1.lastname,h1.loginid,\n" +
|
||||
" t1.requestid as taskCode,t1.currentnodeid as nodeid,d1.nodename,h1.email\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,email from hrmresource where status = 1 union all select id, lastname,loginid,'' as email from hrmresourcemanager ) h1 on h1.id = t1.creater\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and t1.requestid = "+requestid ;
|
||||
bb.writeLog("sendTodoDataByNode--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
if (rs.next()){
|
||||
|
||||
String title = Util.null2String(rs.getString("requestname")) ;
|
||||
String creator = Util.null2String(rs.getString("loginid")) ;
|
||||
String taskCode = Util.null2String(rs.getString("taskcode")) ;
|
||||
String nodeId = Util.null2String(rs.getString("nodeid")) ;
|
||||
|
||||
String createdate = Util.null2String(rs.getString("createdate")) ;
|
||||
String createtime = Util.null2String(rs.getString("createtime")) ;
|
||||
String messageTitle = Util.null2String(rs.getString("requestname")) ;
|
||||
String messageContent = Util.null2String(rs.getString("requestname")) ;
|
||||
|
||||
String taskType = "0";
|
||||
|
||||
String urlPc = "[newtab]"+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);
|
||||
|
||||
String email = Util.null2String(rs.getString("email")) ;
|
||||
emailArray.add(email);
|
||||
}
|
||||
|
||||
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);
|
||||
|
||||
String email = Util.null2String(rs.getString("email")) ;
|
||||
emailArray.add(email);
|
||||
}
|
||||
|
||||
requestObject.put("taskObjectList",taskObjectList);
|
||||
|
||||
String auth = username + ":" + passwd;
|
||||
bb.writeLog("requestObject:"+requestObject.toJSONString());
|
||||
String msgdata = sendPortalTodoUtil.doPostByAuth(portal_todourl,requestObject.toJSONString(),auth);
|
||||
bb.writeLog("msgdata:"+msgdata);
|
||||
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)){
|
||||
|
||||
System.out.println(emailArray.toJSONString());
|
||||
String notificationSubject = "";
|
||||
String notificationContent = "" ;
|
||||
sendMailUtil.sendMail(requestid,emailArray.toJSONString(),notificationSubject,notificationContent);
|
||||
|
||||
}else{
|
||||
sendPortalTodoUtil.doCreateSendPortalTodoErrorInfo();
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/***
|
||||
*
|
||||
* @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")) ;
|
||||
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")) ;
|
||||
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 sendTodoDataByReject(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("sendTodoDataByReject");
|
||||
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("sendTodoDataByReject--sql:"+sql);
|
||||
if (rs.next()){
|
||||
currentnodetype = Util.null2String(rs.getString("CURRENTNODETYPE"));
|
||||
}
|
||||
bb.writeLog("sendTodoDataByReject--currentnodetype:"+currentnodetype);
|
||||
if("3".equals(currentnodetype)){
|
||||
String actionType = "3" ;
|
||||
}else{
|
||||
|
||||
String actionType = "2" ;
|
||||
|
||||
JSONArray taskObjectList = new JSONArray();
|
||||
|
||||
sql = " select t1.requestname,t1.requestmark,t1.creater,t1.createdate,t1.createtime,h1.lastname,h1.loginid,\n" +
|
||||
" t1.requestid as taskCode,t1.currentnodeid as nodeid,d1.nodename\n" +
|
||||
" from workflow_requestbase t1\n" +
|
||||
" inner join workflow_base t3 on t1.workflowid = t3.id\n" +
|
||||
" left join workflow_nodebase d1 on d1.id = t1.currentnodeid "+
|
||||
" left join (select id, lastname,loginid from hrmresource where status = 1 union all select id, lastname,loginid from hrmresourcemanager ) h1 on h1.id = t1.creater\n" +
|
||||
" where (t1.deleted <> 1 or t1.deleted is null or t1.deleted = '')\n" +
|
||||
" and t1.requestid = "+requestid ;
|
||||
bb.writeLog("sendTodoDataByReject--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
if (rs.next()){
|
||||
|
||||
String title = Util.null2String(rs.getString("requestname")) ;
|
||||
String creator = Util.null2String(rs.getString("loginid")) ;
|
||||
String taskCode = Util.null2String(rs.getString("taskcode")) ;
|
||||
String nodeId = Util.null2String(rs.getString("nodeid")) ;
|
||||
|
||||
String createdate = Util.null2String(rs.getString("createdate")) ;
|
||||
String createtime = Util.null2String(rs.getString("createtime")) ;
|
||||
String messageTitle = Util.null2String(rs.getString("requestname")) ;
|
||||
String messageContent = Util.null2String(rs.getString("requestname")) ;
|
||||
|
||||
String taskType = "0";
|
||||
|
||||
String urlPc = "[newtab]"+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.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("sendTodoDataByReject--sql:"+sql);
|
||||
rs.executeQuery(sql);
|
||||
while (rs.next()){
|
||||
|
||||
String usercode = Util.null2String(rs.getString("loginid")) ;
|
||||
JSONObject taskObject = new JSONObject();
|
||||
String objectAction = "0" ;
|
||||
String objectType = "0";
|
||||
String objectCode = usercode ;
|
||||
String objectId = "" ;
|
||||
String operatorCode = usercode ;
|
||||
|
||||
taskObject.put("objectAction",objectAction);
|
||||
taskObject.put("objectType",objectType);
|
||||
taskObject.put("objectCode",objectCode);
|
||||
taskObject.put("objectId",objectId);
|
||||
taskObject.put("operatorCode",operatorCode);
|
||||
taskObjectList.add(taskObject);
|
||||
}
|
||||
|
||||
requestObject.put("taskObjectList",taskObjectList);
|
||||
|
||||
|
||||
// String username = "admin";
|
||||
// String passwd = "Uportal_123";
|
||||
// String todourl = "http://172.16.25.133/portal-web/centerTodo/sync" ;
|
||||
|
||||
String auth = username + ":" + passwd;
|
||||
bb.writeLog("requestObject:"+requestObject.toJSONString());
|
||||
String msgdata = httpReqUtils.doPostByAuth2(portal_todourl,requestObject.toJSONString(),auth);
|
||||
bb.writeLog("msgdata:"+msgdata);
|
||||
if(!"".equals(msgdata)){
|
||||
JSONObject msgObject = JSONObject.parseObject(msgdata);
|
||||
System.out.println(msgdata);
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,56 @@
|
||||
package com.customization.sendtodo;
|
||||
|
||||
import com.sun.jersey.core.util.Base64;
|
||||
import okhttp3.*;
|
||||
import weaver.general.BaseBean;
|
||||
|
||||
import java.io.IOException;
|
||||
|
||||
public class SendPortalTodoUtil {
|
||||
|
||||
/***
|
||||
*
|
||||
* @param portal_todourl
|
||||
* @param dataJson
|
||||
* @param auth
|
||||
* @return
|
||||
*/
|
||||
public String doPostByAuth(String portal_todourl,String dataJson,String auth){
|
||||
//"http://172.16.25.133/portal-web/centerTodo/sync"
|
||||
BaseBean bb = new BaseBean();
|
||||
|
||||
String authorization = "Basic "+new String(Base64.encode(auth));
|
||||
bb.writeLog("authorization:"+authorization);
|
||||
bb.writeLog("portal_todourl:"+portal_todourl);
|
||||
bb.writeLog("dataJson:"+dataJson);
|
||||
bb.writeLog("auth:"+auth);
|
||||
|
||||
String msgData = "" ;
|
||||
OkHttpClient client = new OkHttpClient().newBuilder().build();
|
||||
MediaType mediaType = MediaType.parse("application/json");
|
||||
RequestBody body = RequestBody.create(mediaType, dataJson);
|
||||
Request request = new Request.Builder()
|
||||
.url(portal_todourl)
|
||||
.method("POST", body)
|
||||
.addHeader("Authorization", authorization)
|
||||
.addHeader("Content-Type", "application/json")
|
||||
.build();
|
||||
try {
|
||||
Response response = client.newCall(request).execute();
|
||||
|
||||
bb.writeLog("response.code():"+response.code());
|
||||
bb.writeLog("response.body():"+response.body().string());
|
||||
|
||||
if(response!=null && response.code() == 200){
|
||||
msgData = response.body().string();
|
||||
}
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
return msgData;
|
||||
}
|
||||
|
||||
public void doCreateSendPortalTodoErrorInfo(){
|
||||
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,145 @@
|
||||
package weaver.interfaces.util;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import okhttp3.*;
|
||||
import org.apache.commons.lang.StringUtils;
|
||||
import weaver.general.BaseBean;
|
||||
import weaver.interfaces.iwhalecloud.util.RSAUtils;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.util.Date;
|
||||
|
||||
public class SendMailUtil {
|
||||
|
||||
public void sendMail(String requestid,String emails,String notificationSubject,String notificationContent){
|
||||
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("");
|
||||
BaseBean bb = new BaseBean();
|
||||
String emailUrl = bb.getPropValue("PORTAL_INFO","mailUrl");
|
||||
String emailMethod = bb.getPropValue("PORTAL_INFO","mailMethod");
|
||||
String eventCode = bb.getPropValue("PORTAL_INFO","eventCode");
|
||||
String notificationType = bb.getPropValue("PORTAL_INFO","notificationType");
|
||||
String channel = bb.getPropValue("PORTAL_INFO","channel");
|
||||
String version = bb.getPropValue("PORTAL_INFO","version");
|
||||
String triggerTime =sdf.format(new Date());
|
||||
|
||||
// {
|
||||
// "request":{
|
||||
// "eventCode":"",
|
||||
// "transId":"",
|
||||
// "triggerTime":"20221020094013",
|
||||
// "notificationType":"EMAIL",
|
||||
// "email":"798989044@qq.com",
|
||||
// "channel":"OA",
|
||||
// "notificationSubject":"新待办到达",
|
||||
// "notificationContent":"新待办到达，清及时处理"
|
||||
// }
|
||||
// }
|
||||
|
||||
JSONObject requestJson = new JSONObject();
|
||||
requestJson.put("eventCode",eventCode);
|
||||
requestJson.put("triggerTime",triggerTime);
|
||||
requestJson.put("notificationType",notificationType);
|
||||
requestJson.put("email",emails);
|
||||
requestJson.put("channel",channel);
|
||||
requestJson.put("notificationSubject",notificationSubject);
|
||||
requestJson.put("notificationContent",notificationContent);
|
||||
|
||||
try{
|
||||
String responseData = doGetAccessToken();
|
||||
String accessToken = "" ;
|
||||
if(StringUtils.isNotEmpty(responseData)){
|
||||
JSONObject responseObject = JSONObject.parseObject(responseData);
|
||||
if(responseObject.containsKey("resCode") && responseObject.containsKey("data")){
|
||||
String resCode = responseObject.getString("resCode");
|
||||
if("00000".equals(resCode)){
|
||||
JSONObject dataObject = responseObject.getJSONObject("data");
|
||||
if(dataObject.containsKey("accessToken")){
|
||||
accessToken = dataObject.getString("accessToken");
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if(StringUtils.isNotEmpty(accessToken)){
|
||||
|
||||
JSONObject jsonObject = new JSONObject();
|
||||
jsonObject.put("access_token",accessToken);
|
||||
jsonObject.put("method",emailMethod);
|
||||
jsonObject.put("version",version);
|
||||
jsonObject.put("content",requestJson);
|
||||
// "{\r\n \"access_token\": \"\",\r\n \"method\": \"sendNotification\",\r\n \"version\": \"1.0\",\r\n \"content\": {\"eventCode\":\"\", \r\n \"transId\":\"\", \r\n \"triggerTime\":\"20221020094013\",\r\n \"notificationType\":\"EMAIL\",\r\n \"email\":\"798989044@qq.com\", \r\n \"channel\":\"OA\", \r\n \"notificationSubject\":\"新待办到达\",\r\n \"notificationContent\":\"新待办到达，清及时处理\" }\r\n}"
|
||||
|
||||
System.out.println(jsonObject.toJSONString());
|
||||
|
||||
OkHttpClient client = new OkHttpClient().newBuilder()
|
||||
.build();
|
||||
MediaType mediaType = MediaType.parse("application/json");
|
||||
RequestBody body = RequestBody.create(mediaType,jsonObject.toJSONString());
|
||||
Request request = new Request.Builder()
|
||||
.url(emailUrl)
|
||||
.method("POST", body)
|
||||
.addHeader("Content-Type", "application/json")
|
||||
.build();
|
||||
Response response = client.newCall(request).execute();
|
||||
}
|
||||
}catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
}catch (Exception e){
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public String doGetAccessToken(){
|
||||
|
||||
String responseData = "" ;
|
||||
BaseBean bb = new BaseBean();
|
||||
RSAUtils RSAUtils = new RSAUtils();
|
||||
|
||||
String tokenUrl = bb.getPropValue("","") ; //"http://10.26.4.136:80/api/oauth2/apigAuthorize"
|
||||
String appCode = bb.getPropValue("","") ;
|
||||
String appSecret = bb.getPropValue("","") ;
|
||||
String responseType = bb.getPropValue("","") ; //token
|
||||
String privateKey = bb.getPropValue("","") ;
|
||||
|
||||
//String privateKey = "MIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQCt49VVhOmTZVpWPK/bB/ZvpoxrpXt3c9h8DJtHq9vWLGPVMS0a2l+v4U+g8zFpq6Rb6G6nnJ+pYXmojygQhqKG6izWxEojdAF2znt6URsikGe1wRxUpUewRbZVse7Rs0jvJmGZeVZ08gC1iKogyHtHeRinnHJNxC4v/5yhkOBpR6oe4t2IutKNFhSmHdJP5bEkei5gWAZ4xi15pvcWBcUSVEQliW7qRTX9yQUdCq1KzCLEGYNfm27SzKvFpRUAXpgjfFftmB3u7pZ9qhAn/25b0h9sE90Xjwg/UNmLqxUerNNDbIrqWy0x6g/+2Q/c4OXKLk5FlkkEURoBINNDbYgdAgMBAAECggEAAsfZ6XwuoATG5QojZcVC05Y+OJp01vwrQhCRixvccBhVoFsg9YT4cr+PnmtFJwNvpWiaHGQMyZCdeWyQn3MHtlCYVvbcmKSKQXQb1WDmpi7Y+bcU1OWvt8nlmIk34HKVf/2FIgcmssgL6ts8nTmXfxUYp9WAnm28r1fPEWZXsFdGNilFxg6Vymct+5hfnXUA5OMm1RgSvYR/12F4aqILz7kjMBjkF4IJAJpRqR4WlU3vhJ3+FGLnOqnAKRE+rkn10LaKpfOrWY6chm6C2ddNVzGyYaDAqH+TK+9C8qLYZLjbyD8a5LlCU4xdHYbG4VoVpHz7Pop4XQWzOkP7zagvoQKBgQD1MT9K4Kt/Ms3pw/zbv0a3Wvt45OfszMHiVBYXE7Fhp11zqK6wyTUU8ePLO3XxS5GbQwBRlfYhI2aF6nWxq2iphqemD5AqC03m0tJl4g2/q/+Mr0k7ClRJHV2cs80ij9aWdHcNlCW5G37ZXfjiQ9qkiIIr1RLngO59HAEP1ePZzwKBgQC1jgJeDpFRKDZ8SCYKowjnvMgPULZ97LDofS828hgwLSzSI+tOpHOrJnFgIC08JTVxYnB5gw3ybqvPLt9Tz+soledqayTynMwlpDz4WuoQw5mEPvURIqsxkrMFqYFcMLrBbIsyJFboKkfgLpTXlOFe6wv0oe0s37Sgz9IRMe/2UwKBgGQCGUnGR80TANAHg5xx8TsaXhXacAqzHaXeHEB/ZMtrA4AIXnB3MTKA0yPy9dFcvGAyvO+KFiFAGjInBqhYPNFgvgLKuEed4sFyXiT2RhtW4V4VpO3y8Zv84VDoOZSOTL2DdYfRVG2jHGM2pCxN9uFDWKzeNN6+RQg8ouY9nLkbAoGACme1IwbatTgEx2KrK3jkjcN4A8iwbM8f5HMoPZHqaPht1S1R0xQBvRFa9hNiBExtn63wnEYyim5lUl5xVjBYXd8ZgDPbzjvGR3H+PI2ZVJShO78P9Id0IEc0E2L/kvUH/wXlhF4ozO1/aQ3CYgiaUgJOkRqmqSe5Bm5ir7GY+xkCgYBkfmFhBI9m8AxljI3oJAGv43EGw2s6wZkrQXFBStYBSxTkkS9JHMbkNrKgKvsuzPLUCD0hmdTPREh/miO/0VNXZaa05L7xhgvakezI4f2BSY6tCMXHiBmnRXE8JL4+rEvWAKUaMCTynoyGRetl+JmooLZ5Fez1250hw5vWdSUudA==";
|
||||
//"{\"appCode\":\""+appCode+"\",\r\n\t\"appSecret\":\"9f5a519622a8790b\",\r\n\t\"responseType\":\"token\",\r\n\t\"timestamp\":\"1592212221795\",\r\n\t\"sign\":\"LE4MPesIy8BCxOa958cQxX0cW1ObvOfCn2dDUK6AzCukcvyS6EvFMLzSBFiCgcMT1w9cYAbSIOWL2SENvpC2qxXrgtWJd6B3J1dUmL5ZBtOEGZ6ymRz7IAQraA1TG82Y0ZTgVFhOGS/TtbTjdEhurwcclWdbSPEy6uZesoQpyF7MAW+hb5Y5ioqe1ky7RE15W/gwJDONgLifUoZnXhowjsJHBJ/xCwdfQi48/wu0CX+G46C+fSYHKncGbeeg7hFyaltNWsco0ScWLB/JjKA1qZv+pPFGaWGidfoTErq7Ux8fIYH3cRjRoSNknOcawi+zjy8GMBDjxIk9lX7+Oz1wYA==\"\r\n}"
|
||||
|
||||
|
||||
String timestamp = System.currentTimeMillis() + "";
|
||||
try {
|
||||
// 生成签名
|
||||
String sign = RSAUtils.generateSign("", appCode, appSecret, timestamp, privateKey);
|
||||
|
||||
System.out.println("sign == " + sign);
|
||||
|
||||
JSONObject jsonObject = new JSONObject();
|
||||
jsonObject.put("appCode",appCode);
|
||||
jsonObject.put("appSecret",appSecret);
|
||||
jsonObject.put("responseType",responseType);
|
||||
jsonObject.put("timestamp",timestamp);
|
||||
jsonObject.put("sign",timestamp);
|
||||
System.out.println(jsonObject.toJSONString());
|
||||
|
||||
OkHttpClient client = new OkHttpClient().newBuilder().build();
|
||||
MediaType mediaType = MediaType.parse("application/json");
|
||||
RequestBody body = RequestBody.create(mediaType, jsonObject.toJSONString());
|
||||
Request request = new Request.Builder()
|
||||
.url(tokenUrl)
|
||||
.method("POST", body)
|
||||
.addHeader("Content-Type", "application/json")
|
||||
.build();
|
||||
Response response = client.newCall(request).execute();
|
||||
bb.writeLog("response.code():"+response.code());
|
||||
bb.writeLog("response.body():"+response.body().string());
|
||||
responseData = response.body().string();
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
return responseData;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue