增加判断泳道图回填发布日期字段\单条发送待阅增加任务状态代码
This commit is contained in:
parent
4b5d0d6628
commit
ebd83ebb42
Binary file not shown.
@ -129,6 +129,8 @@ public class ApplyTasAfterkComplete extends ExecuteListener implements ExecuteLi
|
|||||||
attrId = "form_effective_date";
|
attrId = "form_effective_date";
|
||||||
} else if ("control.policy".equals(method)) {
|
} else if ("control.policy".equals(method)) {
|
||||||
attrId = "effective_date";
|
attrId = "effective_date";
|
||||||
|
} else if("process.flowchart".equals(method)){
|
||||||
|
attrId = "effective_date";
|
||||||
}
|
}
|
||||||
if (UtilString.isEmpty(attrId)) {
|
if (UtilString.isEmpty(attrId)) {
|
||||||
return false;
|
return false;
|
||||||
|
|||||||
@ -82,6 +82,15 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
|
|||||||
//用户点击确认发布按钮后进行触发推送任务
|
//用户点击确认发布按钮后进行触发推送任务
|
||||||
Boolean isConfirmRelease = SDK.getTaskAPI().isChoiceActionMenu(ext.getTaskInstance(), "确认发布");
|
Boolean isConfirmRelease = SDK.getTaskAPI().isChoiceActionMenu(ext.getTaskInstance(), "确认发布");
|
||||||
if(isConfirmRelease==true){
|
if(isConfirmRelease==true){
|
||||||
|
ProcessInstance boProcessInstance = SDK.getProcessAPI()
|
||||||
|
.createBOProcessInstance("obj_7946c848674f422fbe2817ad5d047337", ext.getUserContext().getUID(), "OA任务状态记录");
|
||||||
|
BO executiveTaskBO=new BO();
|
||||||
|
executiveTaskBO.set("TASKTITLE",ext.getProcessInstance().getTitle());
|
||||||
|
executiveTaskBO.set("TASKID",ext.getProcessInstance().getId());
|
||||||
|
executiveTaskBO.set("TASKSTATUS",1);
|
||||||
|
executiveTaskBO.set("ISTASKEND",1);
|
||||||
|
SDK.getBOAPI().create("BO_ACT_EXECUTIVE_TASK",executiveTaskBO,boProcessInstance.getId(),"");
|
||||||
|
|
||||||
ExecutorService service = Executors.newFixedThreadPool(1);
|
ExecutorService service = Executors.newFixedThreadPool(1);
|
||||||
service.execute(new Runnable() {
|
service.execute(new Runnable() {
|
||||||
@Override
|
@Override
|
||||||
@ -391,6 +400,22 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
|
|||||||
createReadLog(processExecutionContext, jsonObject, sendList, startTime, endTimes);
|
createReadLog(processExecutionContext, jsonObject, sendList, startTime, endTimes);
|
||||||
System.err.println(instanceById.getTitle() + "推送OA待阅执行完毕====>" + "用时:"
|
System.err.println(instanceById.getTitle() + "推送OA待阅执行完毕====>" + "用时:"
|
||||||
+ (endTimes - startTime) / 1000 / 60 + "分钟");
|
+ (endTimes - startTime) / 1000 / 60 + "分钟");
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
//发送消息通知
|
||||||
|
List<BO> readCountBO=SDK.getBOAPI().query("BO_EU_READ_COUNT").addQuery("PROCESSID=",processExecutionContext.getProcessInstance().getId()).list();
|
||||||
|
if(readCountBO.size()>0){
|
||||||
|
SDK.getNotificationAPI().sendMessage("admin", "admin", "文件名称:"+processExecutionContext.getProcessInstance().getTitle()+"文件有失败记录,请及时处理!!!");
|
||||||
|
}
|
||||||
|
|
||||||
|
//更新任务状态
|
||||||
|
int r1 = DBSql.update("UPDATE BO_ACT_EXECUTIVE_TASK SET ISTASKEND='2' WHERE TASKID ='" + processExecutionContext.getProcessInstance().getId() + "'");
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user