工作流对接文档

CREATE 
    ALGORITHM = UNDEFINED 
    DEFINER = `root`@`%` 
    SQL SECURITY DEFINER
VIEW `ACT_ID_USER` AS
    SELECT 
        `newfiber_standard`.`sys_user`.`user_id` AS `ID_`,
        1 AS `REV_`,
        `newfiber_standard`.`sys_user`.`nick_name` AS `FIRST_`,
        `newfiber_standard`.`sys_user`.`nick_name` AS `LAST_`,
        `newfiber_standard`.`sys_user`.`user_name` AS `DISPLAY_NAME_`,
        `newfiber_standard`.`sys_user`.`email` AS `EMAIL_`,
        '123456' AS `PWD_`,
        NULL AS `PICTURE_ID_`,
        NULL AS `TENANT_ID_`
    FROM
        `newfiber_standard`.`sys_user`
    WHERE
        (`newfiber_standard`.`sys_user`.`del_flag` = 0)

flowable:
  database-schema: newfiber_standard_workflow
  driver-class-name: com.mysql.cj.jdbc.Driver
  url: jdbc:mysql://127.0.0.1/newfiber_standard_workflow?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&nullCatalogMeansCurrent=true
  username: root
  password: 123456

<!-- Newfiber Common Workflow -->
<dependency>
     <groupId>com.newfiber</groupId>
     <artifactId>newfiber-common-workflow</artifactId>
</dependency>

// 加入工作流模块路径："com.newfiber.workflow"
@SpringBootApplication(
        scanBasePackages = {"com.newfiber.business", "com.newfiber.workflow"})
public class WorkflowParentApplication {

    public static void main(String[] args) {
        SpringApplication.run(WorkflowParentApplication.class, args);
    }

}

public interface IWorkflowDefinition {

    /**
     * 工作流编号
     * @return 工作流编号
     */
    String getWorkflowKey();

    /**
     * 工作流名称
     * @return 工作流名称
     */
    String getWorkflowName();

    /**
     * 业务实体表名，用于分页查询业务数据
     * @return 业务实体表名
     */
    default String getTableName() {
        return "t";
    }

    /**
     * 业务实体表主键类型，用于分页查询业务数据
     * @return 业务实体表主键类型
     */
    default Class<?> getTableIdType(){
        return String.class;
    }
}

public enum EWorkflowDefinition implements IWorkflowDefinition {
  /** */
  PatrolApply("PatrolApply", "巡查申请", "t", Integer.class);

  EWorkflowDefinition(
      String workflowKey, String workflowName, String tableName, Class<?> tableIdType) {
    this.workflowKey = workflowKey;
    this.workflowName = workflowName;
    this.tableName = tableName;
    this.tableIdType = tableIdType;
  }

  private final String workflowKey;

  private final String workflowName;

  private final String tableName;

  private final Class<?> tableIdType;

  @Override
  public String getWorkflowKey() {
    return workflowKey;
  }

  @Override
  public String getWorkflowName() {
    return workflowName;
  }

  @Override
  public String getTableName() {
    return tableName;
  }

  @Override
  public Class<?> getTableIdType() {
    return tableIdType;
  }
}

public interface IWorkflowCallback<T> {

    /**
     * 业务实体类型
     * @return 业务实体类型
     */
    default Class<?> getEntityClass(){
        return ReflectionKit.getInterfaceGeneric(this);
    }

    /**
     * 工作流定义
     * @return 工作流定义
     */
    IWorkflowDefinition getWorkflowDefinition();

    /**
     * 更新业务实体的工作流实体编号
     * @param businessKey 业务实体编号
     * @param workflowInstanceId 工作流实体编号
     */
    void refreshWorkflowInstanceId(Object businessKey, String workflowInstanceId);

    /**
     * 更新业务数据状态
     * @param businessKey 业务实体编号
     * @param status 状态
     */
    void refreshStatus(Object businessKey, String status);

}

@Service
public class PurchaseApplyServiceImpl implements IWorkflowCallback<PurchaseApply> {

  @Override
  public IWorkflowDefinition getWorkflowDefinition() {
    return EWorkflowDefinition.PurchaseApply;
  }

  @Override
  public void refreshWorkflowInstanceId(Object businessKey, String workflowInstanceId) {
    PurchaseApply condition = new PurchaseApply();
    condition.setId(Integer.parseInt(businessKey.toString()));
    condition.setWorkflowInstanceId(workflowInstanceId);
    updateById(condition);
  }

  @Override
  public void refreshStatus(Object businessKey, String status) {
    PurchaseApply condition = new PurchaseApply();
    condition.setId(Integer.parseInt(businessKey.toString()));
    condition.setStatus(status);
    updateById(condition);
  }
}

    /**
     * 启动工作流
     * @param workflowCallback 回调接口
     * @param businessKey 业务编号
     * @param startReq 启动参数
     * @return 工作流实体编号
     */
    String startWorkflow(IWorkflowCallback<?> workflowCallback, Object businessKey, WorkflowStartReq startReq);

    /**
     * 提交工作流
     * @param callback 回调接口
     * @param businessKey 业务编号
     * @param submitReq 提交结果
     * @return 业务编号
     */
    String submitWorkflow(IWorkflowCallback<?> callback, Object businessKey, WorkflowSubmitReq submitReq);

@Service
public class PatrolApplyServiceImpl implements PatrolApplyService, IWorkflowCallback<PatrolApply> {

  @Resource 
  private ActivitiProcessService activitiProcessService;

  @Override
  @Transactional(rollbackFor = Exception.class)
  public void create(PatrolApplyCreateReq req) {
    PatrolApply patrolApply = new PatrolApply();
    BeanUtils.copyProperties(req, patrolApply);
    this.save(patrolApply);

    // 启动工作流
    activitiProcessService.startWorkflow(this, patrolApply.getId(), req);
  }

  @Override
  public void approve(PatrolApplyApproveReq req) {
    // 提交工作流
    activitiProcessService.submitWorkflow(this, req.getId(), req);
  }
}

		/**
     * 开始分页
     * @param pageNum 开始页数
     * @param pageSize 每页数量
     * @param orderBy 排序字段
     * @param userId 用户编号
     * @param taskKey 任务编号，对应相应的状态节点
     * @param workflowCallback 回调接口
     * @return 分页参数实体
     */
    public static <E> Page<E> startPage(int pageNum, int pageSize, String orderBy, Object userId, String taskKey, IWorkflowCallback<?> workflowCallback)

    /**
     * 开始分页
     * @param workflowPageReq 分页接口参数
     * @param workflowCallback 回调接口
     * @return 分页参数实体
     */
    public static <E> Page<E> startPage(WorkflowPageReq workflowPageReq, IWorkflowCallback<?> workflowCallback)

@Override
  public PageInfo<PatrolApply> page(PatrolApplyPageReq req) {
    PatrolApply condition = new PatrolApply();
    BeanUtils.copyProperties(req, condition);
    
    // 执行分页操作
    WorkflowPageHelper.startPage(req, this);

    List<PatrolApply> list = patrolApplyDao.selectByCondition(condition);
    return new PageInfo<>(list);
  }

spring:
    mail:
        host: smtp.exmail.qq.com
        username: xiongkai@chinhangroup.com
        password: 123456
        properties:
            mail:
                smtp:
                    auth: true

public interface IWorkflowEmailNotification extends IWorkflowNotification{

    /**
     * 通知模板
     * @return 通知模板
     */
    String getNotificationTemplate();

}

public interface IWorkflowSmsNotification extends IWorkflowNotification{

    /**
     * 短信签名
     * @return 短信签名
     */
    default String getSmsSign(){
        return null;
    }

    /**
     * 短信模板编号
     * @return 短信模板编号
     */
    default String getSmsTemplateCode(){
        return null;
    }
}

public enum ECountersignNotification implements IWorkflowEmailNotification, IWorkflowSmsNotification {
    /**
     *
     */
    AfterApprove("AfterApprove", "[%s]您有一条待办任务:[%s],请在[%s]前完成", 
                 "新钜物联","10945341");

    private final String notificationTask;

    private final String notificationTemplate;

    private final String smsSign;

    private final String smsTemplateCode;

    ECountersignNotification(String notificationTask, String notificationTemplate, String smsSign, String smsTemplateCode) {
        this.notificationTask = notificationTask;
        this.notificationTemplate = notificationTemplate;
        this.smsSign = smsSign;
        this.smsTemplateCode = smsTemplateCode;
    }

    @Override
    public String getNotificationTask() {
        return notificationTask;
    }

    @Override
    public String getNotificationTemplate() {
        return notificationTemplate;
    }

    @Override
    public String getSmsSign() {
        return smsSign;
    }

    @Override
    public String getSmsTemplateCode() {
        return smsTemplateCode;
    }

}

public interface IWorkflowCallback<T> {

    /**
     * 工作流通知
     * @return 工作流通知
     */
    default IWorkflowNotification[] getWorkflowNotification(){
        return null;
    }
}

public class CountersignServiceImpl implements IWorkflowCallback<Countersign> {

    @Override
    public IWorkflowNotification[] getWorkflowNotification() {
        return ECountersignNotification.values();
    }
}

public interface ActivitiProcessService {
    /**
     * 发送邮件通知
     * @param email 邮箱
     * @param content 内容
     * @return 是否成功
     */
    boolean sendEmailNotification(String email, String content);

    /**
     * 发送短信通知
     * @param mobile 手机号
     * @param smsSign 短信签名
     * @param smsTemplateCode 短息模板编号
     * @param templateArgs 模板参数
     * @return 是否成功
     */
    boolean sendSmsNotification(String mobile, String smsSign, String smsTemplateCode, List<String> templateArgs);
}

    <dependencies>

        <!-- Mysql Connector -->
<!--        <dependency>-->
<!--            <groupId>mysql</groupId>-->
<!--            <artifactId>mysql-connector-java</artifactId>-->
<!--        </dependency>-->

        <!-- Druid -->
<!--        <dependency>-->
<!--            <groupId>com.alibaba</groupId>-->
<!--            <artifactId>druid-spring-boot-starter</artifactId>-->
<!--        </dependency>-->

        <!-- Kingbase Connector -->
        <dependency>
            <groupId>cn.com.kingbase</groupId>
            <artifactId>kingbase8</artifactId>
        </dependency>

      <!--    DM Connector  -->
<!--        <dependency>-->
<!--            <groupId>com.dameng</groupId>-->
<!--            <artifactId>DmJdbcDriver18</artifactId>-->
<!--        </dependency>-->
      
    </dependencies>

spring:
  datasource:
    driver-class-name: com.kingbase8.Driver
    url: jdbc:kingbase8://192.168.30.91:54321/newfiber_standard
    username: system
    password: system2023

datasource:
 	driver-class-name: dm.jdbc.driver.DmDriver
  url: jdbc:dm://192.168.30.93:5236/newfiber_standard?schema=newfiber_standard
  username: SYSDBA
  password: SYSDBA

SELECT RES.* from ACT_HI_TASKINST RES WHERE RES.END_TIME_ is not null and 
( EXISTS(select LINK.ID_ from ACT_HI_IDENTITYLINK LINK where LINK.USER_ID_ = 1 and LINK.TASK_ID_ = RES.ID_) 
or RES.ASSIGNEE_ = 1 or RES.OWNER_ = 1 ) 
and exists ( select 1 from ACT_RE_PROCDEF D 
WHERE RES.PROC_DEF_ID_ = D.ID_ and D.KEY_ like 'PatrolCase' ) order by RES.ID_ asc;

SELECT RES.* from ACT_HI_TASKINST RES 
left join ACT_RE_PROCDEF D on RES.PROC_DEF_ID_ = D.ID_
where D.KEY_ = 'PatrolCase'

SELECT RES.* from ACT_RU_TASK RES WHERE exists ( select 1 from ACT_RE_PROCDEF D 
WHERE RES.PROC_DEF_ID_ = D.ID_ and D.KEY_ = 'projectQualityReformRecord' ) 
and (RES.ASSIGNEE_ = 1 or ( RES.ASSIGNEE_ is null and 
exists(select LINK.ID_ from ACT_RU_IDENTITYLINK LINK 
where LINK.TASK_ID_ = RES.ID_ and LINK.TYPE_ = 'candidate' 
and (LINK.USER_ID_ = 1 or ( LINK.GROUP_ID_ IN ( 89010001 ) ) )))) order by RES.ID_ asc