【分享】获取一下环节流程任务和通知

ecoolper

直接上代码

1. public class ProcessPushEngine  implements Interceptor{
   
2.         public static Logger logger = Logger.getLogger(ProcessPushEngine.class);
   
3.         public static final List<String> NAMES = new ArrayList<String>();
   
4.         static{
   
5.                 NAMES.add("advanceProcessAction");
   
6.                 NAMES.add("backProcessAction");
   
7.                 NAMES.add("transferTaskAction");
   
8.                 NAMES.add("withdrawTaskAction");
   
9.         };
   
10.        
    
11.         public void execute() {
    
12.                 ActionContext ac = ContextHelper.getActionContext();
    
13.                 Action action = ac.getAction();
    
14.                 if (NAMES.contains(action.getName())){
    
15.                         try{
    
16.                                 Set<Task> tasks = new HashSet<Task>();
    
17.                                 ProcessContext pc = ProcessUtils.getProcessContext();
    
18.                                 tasks.addAll(pc.getNewNotices());
    
19.                                 tasks.addAll(pc.getNewTasks());
    
20.                                
    
21.                                 for (Task t : tasks){
    
22.                                         String status = t.getStatus();
    
23.                                         if (TaskStatus.READY.equals(status) || TaskStatus.EXECUTING.equals(status)){
    
24.                                                 String name = t.getName();
    
25.                                                 String url = t.getEURL();
    
26.                                                 if (SystemUtils.isNotEmptyString(url)){
    
27.                                                         url += (url.contains("?") ? "&" : "?");
    
28.                                                         url = url + "task=" + t.getId() + "&process=" + t.getProcess() + "&activity=" + t.getActivity();
    
29.                                                        
    
30.                                                         if (url.startsWith("/")){
    
31.                                                                 url = JustepConfig.getUIServer() + url;
    
32.                                                         }
    
33.                                                         logger.info("message: " + name + ", url: " + url + ", person: " + t.getExecutorFID() + ", " + t.getExecutorFName());
    
34.                                                         Message msg = new Message(name, url, null);
    
35.                                                         Set<String> personIDs = new HashSet<String>();
    
36.                                                         personIDs.add(t.getExecutorFID());
    
37.                                                         MessageDispatcherFactory.createMessageDispatcher(JustepConfig.getMqttServer()).sendMessage(msg, personIDs);
    
38.                                                 }
    
39.                                         }
    
40.                                 }
    
41.                         }catch (Exception e){
    
42.                                 e.printStackTrace();
    
43.                                 logger.error(e.getMessage()+"", e);
    
44.                         }
    
45.                 }
    
46.         }
    
47. }

复制代码