OA待阅补发推送代码更新
This commit is contained in:
parent
a209efb3d3
commit
419028cf17
@ -88,9 +88,9 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
|
||||
String publshId = byProcess.getString("PUBLISHUSPROSSINSID");
|
||||
// 发布流程发布节点任务Id
|
||||
String sql = "SELECT ID FROM WFH_TASK WHERE PROCESSINSTID = '" + publshId
|
||||
+ "' AND ACTIVITYDEFID = 'obj_c9e5a3144b200001b68cffa01ed0153e' ";
|
||||
String taskInd = DBSql.getString(sql);
|
||||
TaskInstance taskInst = SDK.getTaskAPI().getInstanceById(taskInd);
|
||||
+ "' AND ACTIVITYDEFID = 'obj_c9e5a3144b200001b68cffa01ed0153e' order by ENDTIME desc";
|
||||
List<RowMap> taskInd = DBSql.getMaps(sql);
|
||||
TaskInstance taskInst = SDK.getTaskAPI().getInstanceById(taskInd.get(0).getString("ID"));
|
||||
|
||||
BO publishBo = SDK.getBOAPI().getByProcess("BO_ACT_COE_PUBLISH", publshId);
|
||||
// 发送岗位
|
||||
@ -248,69 +248,6 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
|
||||
}
|
||||
|
||||
}
|
||||
/* // 按人员推送
|
||||
String fsUserIds = byProcess.getString("PUBLISHTOUSER");
|
||||
if (UtilString.isNotEmpty(fsUserIds)) {
|
||||
String[] split = fsUserIds.split(",");
|
||||
for (String uid : split) {
|
||||
arr.add(uid);
|
||||
UserModel user = SDK.getORGAPI().getUser(uid);
|
||||
if (user != null) {
|
||||
String positionNo = user.getPositionNo();
|
||||
postSb.append(positionNo).append(",");
|
||||
}
|
||||
}
|
||||
|
||||
if (UtilString.isNotEmpty(post)) {
|
||||
newPost = post + "," + postSb.toString();
|
||||
} else {
|
||||
newPost = postSb.toString();
|
||||
}
|
||||
System.err.println("补充推送岗位权限========》" + newPost);
|
||||
} else {
|
||||
// 按部门补充推送
|
||||
String depIds = byProcess.getString("PUBLISHTODEPT");
|
||||
if (UtilString.isNotEmpty(depIds)) {
|
||||
if (UtilString.isNotEmpty(org)) {
|
||||
newOrg = org + "," + depIds;
|
||||
} else {
|
||||
newOrg = depIds;
|
||||
}
|
||||
System.err.println("补充推送部门权限==========》" + newOrg);
|
||||
if (UtilString.isNotEmpty(depIds)) {
|
||||
String[] split = depIds.split(",");
|
||||
for (String depId : split) {
|
||||
getUserList(arr, depId);
|
||||
}
|
||||
}
|
||||
}
|
||||
// 按岗位推送
|
||||
String s_post = byProcess.getString("POSTPERM");
|
||||
if (UtilString.isNotEmpty(s_post)) {
|
||||
if (UtilString.isNotEmpty(post)) {
|
||||
newPost = post + "," + s_post;
|
||||
} else {
|
||||
newPost = s_post;
|
||||
}
|
||||
System.err.println("补充推送岗位权限==========》" + newOrg);
|
||||
ArrayList<String> sendPost = sendPost(s_post, arr, publshId);
|
||||
arr = sendPost;
|
||||
}
|
||||
|
||||
// 按职级补充推送
|
||||
String s_level = byProcess.getString("LEVELPERM");
|
||||
if (UtilString.isNotEmpty(s_level)) {
|
||||
if (UtilString.isNotEmpty(level)) {
|
||||
newLevel = level + "," + s_level;
|
||||
} else {
|
||||
newLevel = s_level;
|
||||
}
|
||||
System.err.println("补充推送部门权限==========》" + newOrg);
|
||||
ArrayList<String> sendLevel = sendLevel(s_level, arr, publshId);
|
||||
arr = sendLevel;
|
||||
}
|
||||
|
||||
}*/
|
||||
|
||||
/* // 重新添加权限
|
||||
if (UtilString.isNotEmpty(newOrg) || UtilString.isNotEmpty(newPost) || UtilString.isNotEmpty(newLevel)) {
|
||||
@ -610,9 +547,10 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
|
||||
Element result = rootElement.element("Body").element("serviceResponse").element("out");
|
||||
String resultString = result.getData().toString();
|
||||
JSONObject jsonObject1 = JSON.parseObject(resultString);
|
||||
System.out.println("Data>>>>>>>>>>>>>"+jsonObject1);
|
||||
String datas = jsonObject1.getString("data");
|
||||
String status = jsonObject1.getString("status");
|
||||
// System.out.println("推送》》》》》》》》》》》" + status);
|
||||
System.out.println("推送》》》》》》》》》》》" + status);
|
||||
if ("false".equals(status)) {
|
||||
System.out.println(processInstance.getTitle() + "待阅推送失败:" + userId);
|
||||
try {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user