Package com.starflow.wf.engine.model

Examples of com.starflow.wf.engine.model.ProcessDefine

66
67
68
69
70
71
72
73
  }

  public void setProcessInstance(ProcessInstance processInstance) {
    this.processInstance = processInstance;
    IProcessDefineRepository procDefFacade = this.getApplicationContext().getBean(IProcessDefineRepository.class);
    ProcessDefine processDefine = procDefFacade.findProcessDefine(processInstance.getProcessDefId());
    processXml = processDefine.getProcessObject();
  }
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
  }
 
  public void deleteProcessDefine(long processDefId) {
    this.getJdbcTemplate().update(deleteProcessDefineSQL, processDefId);
   
    ProcessDefine processDefine = getCacheValue("prodef-" + processDefId);
    if(processDefine != null) {
      cache.evict("prodef-" + processDefine.getProcessDefId());
      cache.evict("prodef-" + processDefine.getProcessDefName());
    }
  }
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
      cache.evict("prodef-" + processDefine.getProcessDefName());
    }
  }
 
  public ProcessDefine findProcessDefine(long processDefId) {
    ProcessDefine processDefine = getCacheValue("prodef-" + processDefId);
    if(processDefine == null || processDefine.getProcessObject() == null) {
      processDefine = this.getJdbcTemplate().queryForObject(findProcessDefineSQL, new ProcessDefineRowMapper(), processDefId);
     
      ProcessElement processXml = ProcessDefineParser.createProcessXml(processDefine.getProcessDefContent());
      processDefine.setProcessObject(processXml);
      cache.put("prodef-" + processDefine.getProcessDefId(), processDefine);
    }
    return processDefine;
  }
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
    }
    return processDefine;
  }
 
  public ProcessDefine findPublishProcessDefine(String processDefName) {
    ProcessDefine processDefine = getCacheValue("prodef-" + processDefName);
    if(processDefine == null) {
      processDefine = this.getJdbcTemplate().queryForObject(findPublishProcessDefineSQL, new ProcessDefineRowMapper(), processDefName);
     
      ProcessElement processXml = ProcessDefineParser.createProcessXml(processDefine.getProcessDefContent());
      processDefine.setProcessObject(processXml);
      cache.put("prodef-" + processDefine.getProcessDefId(), processDefine);
      cache.put("prodef-" + processDefine.getProcessDefName(), processDefine);
    }
    return processDefine;
  }
View Full Code Here
119
120
121
122
123
124
125
126
127
128
  }
 
  public void updateProcessDefineUnPublishStatus(String processDefName) {
    this.getJdbcTemplate().update(updateProcessDefineUnPublishStatusSQL, processDefName);
   
    ProcessDefine processDefine = getCacheValue("prodef-" + processDefName);
    if(processDefine != null) {
      cache.evict("prodef-" + processDefine.getProcessDefName());
    }
  }
View Full Code Here
128
129
130
131
132
133
134
135
136
137
  }
 
  public void updateProcessDefinePublishStatus(long processDefId) {
    this.getJdbcTemplate().update(updateProcessDefinePublishStatusSQL, processDefId);
   
    ProcessDefine processDefine = findProcessDefine(processDefId);
    if(processDefine != null) {
      cache.evict("prodef-" + processDefine.getProcessDefName());
    }
  }
View Full Code Here
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
    return this.getJdbcTemplate().query(findProcessDefinesSQL, new RowMapper<ProcessDefine>(){

      @Override
      public ProcessDefine mapRow(ResultSet resultSet, int index)
          throws SQLException {
        ProcessDefine processDefine = new ProcessDefine();
        processDefine.setProcessDefId(resultSet.getLong("processDefId"));
        processDefine.setProcessDefName(resultSet.getString("processDefName"));
        processDefine.setProcessCHName(resultSet.getString("processCHName"));
        processDefine.setCurrentState(resultSet.getInt("currentState"));
        processDefine.setVersionSign(resultSet.getString("versionSign"));
        return processDefine;
      }
     
    }, processDefName);
  }
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
 
  private static class ProcessDefineRowMapper implements RowMapper<ProcessDefine> {
    @Override
    public ProcessDefine mapRow(ResultSet resultSet, int index)
        throws SQLException {
      ProcessDefine processDefine = new ProcessDefine();
      processDefine.setProcessDefId(resultSet.getLong("processDefId"));
      processDefine.setProcessDefName(resultSet.getString("processDefName"));
      processDefine.setProcessCHName(resultSet.getString("processCHName"));
      processDefine.setCurrentState(resultSet.getInt("currentState"));
      processDefine.setVersionSign(resultSet.getString("versionSign"));
      processDefine.setDescription(resultSet.getString("description"));
      processDefine.setCreateTime(resultSet.getDate("createTime"));
      processDefine.setCreator(resultSet.getString("creator"));
      processDefine.setUpdateTime(resultSet.getDate("updateTime"));
      processDefine.setUpdator(resultSet.getString("updator"));
      processDefine.setLimitTime(resultSet.getLong("limitTime"));
      processDefine.setProcessDefContent(resultSet.getString("processDefContent"));
      return processDefine;
    }
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
  public void deployProcessXML(final String processDefContent) {
    transactionTemplate.execute(new TransactionCallbackWithoutResult() {
      @Override
      public void doInTransactionWithoutResult(TransactionStatus status) {
        ProcessDefine processDefine = new ProcessDefine();
        long id = PrimaryKeyUtil.getPrimaryKey(Keys.PROCESSDEFID);
        processDefine.setProcessDefId(id);
       
        processDefine.setProcessDefContent(processDefContent);
        Dom4jProcDefParser.parserProcessInfo(processDefine);
        processDefine.setCreateTime(new Date());
        processDefine.setCurrentState(StarFlowState.PROCESS_DEF_PUBLISH);
       
        procDefRep.inertProcessDefine(processDefine);
      }
    });
  }
View Full Code Here
143
144
145
146
147
148
149
150
151
152
  public Map<String, String> getProcessProperties(final Long processDefId) {
    return transactionTemplate.execute(new TransactionCallback<Map<String, String>>() {

      @Override
      public Map<String, String> doInTransaction(TransactionStatus status) {
        ProcessDefine processDefine = procDefRep.findProcessDefine(processDefId);
        return processDefine.getProcessObject().getProperties();
      }
    });
  }
View Full Code Here
TOP

Related Classes of com.starflow.wf.engine.model.ProcessDefine

  • com.starflow.wf.engine.event.AbstractFlowEvent
  • com.starflow.wf.engine.repository.impl.ProcessDefineRepositoryImpl
  • com.starflow.wf.engine.repository.impl.ProcessDefineRepositoryImpl$ProcessDefineRowMapper
  • com.starflow.wf.engine.service.impl.ActivityInstService
  • com.starflow.wf.engine.service.impl.FreeFlowService
  • com.starflow.wf.engine.service.impl.ProcessDefineService
  • com.starflow.wf.engine.service.impl.ProcessInstanceService
  • com.starflow.wf.engine.service.impl.WorkItemService
    • 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.