activiti工作流引擎教程入门demo，新手参考的代码详情-代码-最代码

首页>代码>activiti工作流引擎教程入门demo，新手参考>/activiti-demo-master/src/main/java/TimerEntity.java
001/* Licensed under the Apache License, Version 2.0 (the "License");
002 * you may not use this file except in compliance with the License.
003 * You may obtain a copy of the License at
004 *
005 *      http://www.apache.org/licenses/LICENSE-2.0
006 *
007 * Unless required by applicable law or agreed to in writing, software
008 * distributed under the License is distributed on an "AS IS" BASIS,
009 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
010 * See the License for the specific language governing permissions and
011 * limitations under the License.
012 */
013package org.activiti.engine.impl.persistence.entity;
014 
015import java.util.Date;
016 
017import org.activiti.engine.impl.calendar.BusinessCalendar;
018import org.activiti.engine.impl.calendar.CycleBusinessCalendar;
019import org.activiti.engine.impl.context.Context;
020import org.activiti.engine.impl.interceptor.CommandContext;
021import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl;
022import org.slf4j.Logger;
023import org.slf4j.LoggerFactory;
024 
025 
026/**
027 * @author Tom Baeyens
028 */
029public class TimerEntity extends JobEntity {
030 
031  private static final long serialVersionUID = 1L;
032 
033  private static Logger log = LoggerFactory.getLogger(TimerEntity.class);
034 
035  protected String repeat;
036 
037  public TimerEntity() {
038  }
039 
040  public TimerEntity(TimerDeclarationImpl timerDeclaration) {
041    jobHandlerType = timerDeclaration.getJobHandlerType();
042    jobHandlerConfiguration = timerDeclaration.getJobHandlerConfiguration();
043    isExclusive = timerDeclaration.isExclusive();
044    repeat = timerDeclaration.getRepeat();
045    retries = timerDeclaration.getRetries();
046  }
047 
048  private TimerEntity(TimerEntity te) {
049    jobHandlerConfiguration = te.jobHandlerConfiguration;
050    jobHandlerType = te.jobHandlerType;
051    isExclusive = te.isExclusive;
052    repeat = te.repeat;
053    retries = te.retries;
054    executionId = te.executionId;
055    processInstanceId = te.processInstanceId;
056 
057  }
058 
059  @Override
060  public void execute(CommandContext commandContext) {
061 
062    super.execute(commandContext);
063 
064    if (repeat == null) {
065 
066      if (log.isDebugEnabled()) {
067        log.debug("Timer {} fired. Deleting timer.", getId());
068      }
069      delete();
070    } else {
071      delete();
072      Date newTimer = calculateRepeat();
073      System.out.println(repeat);
074      System.out.println(newTimer);
075      if (newTimer != null) {
076        TimerEntity te = new TimerEntity(this);
077        te.setDuedate(newTimer);
078        Context
079            .getCommandContext()
080            .getJobEntityManager()
081            .schedule(te);
082      }
083    }
084 
085  }
086 
087  private Date calculateRepeat() {
088    BusinessCalendar businessCalendar = Context
089        .getProcessEngineConfiguration()
090        .getBusinessCalendarManager()
091        .getBusinessCalendar(CycleBusinessCalendar.NAME);
092    return businessCalendar.resolveDuedate(repeat);
093  }
094 
095  public String getRepeat() {
096    return repeat;
097  }
098 
099  public void setRepeat(String repeat) {
100    this.repeat = repeat;
101  }
102}