Package org.fireflow.engine.impl

Examples of org.fireflow.engine.impl.WorkItem

737
738
739
740
741
742
743
744
745
746
747
748
749
   */
  public IWorkItem findWorkItemById(String id)
  {
    String workItemSql = " select * from t_ff_rt_workitem where id=? ";

    WorkItem workItem = (WorkItem) super.getJdbcTemplate().queryForObject(workItemSql, new Object[] { id },
        new WorkItemRowMapper());
    String taskInstanceSql = "select * from t_ff_rt_taskinstance where id=? ";
    TaskInstance taskInstance = (TaskInstance) super.getJdbcTemplate().queryForObject(taskInstanceSql,
        new Object[] { workItem.getTaskInstanceId() }, new TaskInstanceRowMapper());
    workItem.setTaskInstance(taskInstance);
    return workItem;
  }
View Full Code Here
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
  public final WorkItem createWorkItem(IWorkflowSession currentSession,
      IProcessInstance processInstance, ITaskInstance taskInstance,
      String actorId) throws EngineException {
    IPersistenceService persistenceService = rtCtx.getPersistenceService();

    WorkItem wi = new WorkItem();
    wi.setTaskInstance(taskInstance);
    wi.setActorId(actorId);
    wi.setState(IWorkItem.INITIALIZED);
    wi.setCreatedTime(rtCtx.getCalendarService().getSysDate());
    wi.setRuntimeContext(rtCtx);
    wi.setCurrentWorkflowSession(currentSession);
    // 保存到数据库
    persistenceService.saveOrUpdateWorkItem(wi);

    // 触发事件
    // 触发相应的事件
View Full Code Here
1815
1816
1817
1818
1819
1820
1821
1822
1823
1824
1825
1826
1827
1828
1829
  /* (non-Javadoc)
   * @see org.fireflow.engine.taskinstance.ITaskInstanceManager#reassignWorkItemTo(org.fireflow.engine.IWorkItem, java.lang.String, java.lang.String)
   */
  public IWorkItem reassignWorkItemTo(IWorkItem workItem, String actorId,
      String comments) {
    WorkItem newWorkItem = new WorkItem();
    BeanUtils.copyProperties(workItem, newWorkItem);
    newWorkItem.setId(null);
    newWorkItem.setActorId(actorId);
    newWorkItem.setCreatedTime(rtCtx.getCalendarService().getSysDate());
    rtCtx.getPersistenceService().saveOrUpdateWorkItem(newWorkItem);

    ((WorkItem) workItem).setState(IWorkItem.CANCELED);
    ((WorkItem) workItem).setEndTime(rtCtx.getCalendarService()
        .getSysDate());
View Full Code Here
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
* @author wmj2003
*/
public class WorkItemRowMapper implements RowMapper {

  public Object mapRow(ResultSet rs, int rowNum) throws SQLException  {
    WorkItem workItem = new WorkItem();

    workItem.setId(rs.getString("id"));
    workItem.setState(rs.getInt("state"));
    workItem.setCreatedTime(rs.getTimestamp("created_time"));
    workItem.setClaimedTime(rs.getTimestamp("claimed_time"));
    workItem.setEndTime(rs.getTimestamp("end_time"));

    workItem.setActorId(rs.getString("actor_id"));
    workItem.setTaskInstanceId(rs.getString("taskinstance_id"));
    workItem.setComments(rs.getString("comments"));
    return workItem;
  }
View Full Code Here
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
        System.out.println("--------saveOrUpdateWorkItem--------");

        IWorkItem workItem1 = (IWorkItem) transactionTemplate.execute(new TransactionCallback() {

            public Object doInTransaction(TransactionStatus arg0) {
                WorkItem wi = new WorkItem();
                wi.setActorId(actorId);
                wi.setComments(comments);
                wi.setCreatedTime(createdTime);
                wi.setEndTime(endTime);
                wi.setClaimedTime(claimedTime);
                wi.setState(state);
                wi.setTaskInstance(taskInstance);

                persistenceService.saveOrUpdateWorkItem(wi);
                return wi;
            }
        });
View Full Code Here
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
    public void testFindDeadWorkItemsWithoutJoinForTaskInstance() {
        System.out.println("--------findDeadWorkItemsWithoutJoinForTaskInstance--------");
        IWorkItem workItem1 = (IWorkItem) transactionTemplate.execute(new TransactionCallback() {

            public Object doInTransaction(TransactionStatus arg0) {
                WorkItem wi = new WorkItem();
                wi.setActorId(actorId);
                wi.setComments(comments);
                wi.setCreatedTime(createdTime);
                wi.setEndTime(endTime);
                wi.setClaimedTime(claimedTime);
                wi.setState(IWorkItem.COMPLETED);
                wi.setTaskInstance(taskInstance);

                persistenceService.saveOrUpdateWorkItem(wi);
                return wi;
            }
        });
View Full Code Here
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
        System.out.println("--------cancelAliveWorkItemsForTaskInstance--------");

        IWorkItem workItem1 = (IWorkItem) transactionTemplate.execute(new TransactionCallback() {

            public Object doInTransaction(TransactionStatus arg0) {
                WorkItem wi = new WorkItem();
                wi.setActorId(actorId);
                wi.setComments(comments);
                wi.setCreatedTime(createdTime);
                wi.setEndTime(endTime);
                wi.setClaimedTime(claimedTime);
                wi.setState(state);
                wi.setTaskInstance(taskInstance);

                persistenceService.saveOrUpdateWorkItem(wi);
                return wi;
            }
        });
View Full Code Here
TOP

Related Classes of org.fireflow.engine.impl.WorkItem

  • org.fireflow.engine.IWorkItem
  • org.fireflow.engine.persistence.hibernate.PersistenceServiceHibernateImplTest
  • org.fireflow.engine.persistence.springjdbc.PersistenceServiceSpringJdbcImpl
  • org.fireflow.engine.persistence.springjdbc.WorkItemRowMapper
  • org.fireflow.engine.taskinstance.BasicTaskInstanceManager
  • org.fireflow.engine.taskinstance.ITaskInstanceManager
  • org.fireflow.engine.EngineException
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.