2. 程式人生 > >你明白什麼是會籤？工作流+會籤應用

你明白什麼是會籤？工作流+會籤應用

阿新 • • 發佈：2019-02-20

1.什麼是會籤?

在流程業務管理中，任務是通常都是由一個人去處理的，而多個人同時處理一個任務，這種任務我們稱之為會籤任務。這種業務需求很常見，如一個請款單，領導審批環節中，就需要多個部門領導簽字。在流程業務中，我們可以把每個領導簽字的環節都定義為任務，並且這個會籤的人員是不固定的，若固定的我們可以通過Activiti的並行任務或序列任務來處理。會籤的引入說明，無非就是為了流程流轉至某一環節點，其審批的人員是動態的，並且需要根據會籤審批的結果實現流程的不同流轉。

2.中國特色的會籤需求是什麼？

會籤需求主要有以下兩方面：

  1. 會籤的參與人員
  2. 會籤審批的順序
  3. 會籤審批的結果
  4. 動態加簽

以下我們就是圍繞以上的需求進行擴充套件實現的

3.Activiti對於會籤的實現

BPMN2的標準中並沒有對以上這種情景提供完善的支援，因此要在Activiti中實現會籤審批，我們需要結合Activiti提供的流程任務的多例項特性，進行一些必要的擴充套件，以支援我們的中國特色的會籤需求。
會籤任務也是一種人工任務，其在activiti的定義中，也是使用UserTask來定義，但在屬性上我們需要對這個定義的型別進行特殊的配置，即為多工例項型別（並行或序列）任何一種。另外需要定義會籤的參與人員，再定義會籤的完成條件（若不定義，表示其是所有參與人均完成後，流程才往下跳轉）。

3.1.多例項的人工任務配置

通過在UserTask節點的屬性上配置，如下所示：

1.png

其生成的BPMN的配置檔案如下所示：

 <userTask id=”sid-78A17A9B-1185-48AA-A1CA-611421251D52″ name=”經理會籤”>
<multiInstanceLoopCharacteristics isSequential=”false” activiti:collection=”${counterSignService.getUsers(execution)}”>
<completionCondition>${counterSignService.isComplete(execution)}</completionCondition>
</multiInstanceLoopCharacteristics>
</userTask>

【說明】：

  1. isSequential=”false” 表示這是非序列會籤，即為並行會籤，如三個人蔘與會籤，是三個人同時收到待辦，任務例項是同時產生的。
  2. activiti:collection 表示是會籤的參與人員集合，使用者可以通過定義自身的服務類來獲取
  3. completionCondition  表示是任務往下跳轉的完成條件，返回true是，表示條件成立，流程會跳至下一審批環節。

我們就是圍繞著這幾點來實現中國式的流程會籤的

3.2 會籤任務的人員集合計算處理

我們在Spring容器中定義一個會籤服務類(counterSignService）裡面提供兩個api介面，一個是獲得任務的人員集合，另一個是判斷當前任務是否已經完成了會籤的計算，其參考程式碼如下所示：

package com.redxun.bpm.core.service.sign;

import java.lang.reflect.Array;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Set;

import javax.annotation.Resource;

import org.activiti.engine.impl.pvm.delegate.ActivityExecution;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import com.redxun.bpm.activiti.util.ProcessHandleHelper;
import com.redxun.bpm.core.entity.BpmDestNode;
import com.redxun.bpm.core.entity.BpmRuPath;
import com.redxun.bpm.core.entity.BpmSignData;
import com.redxun.bpm.core.entity.IExecutionCmd;
import com.redxun.bpm.core.entity.ProcessMessage;
import com.redxun.bpm.core.entity.config.MultiTaskConfig;
import com.redxun.bpm.core.entity.config.TaskVotePrivConfig;
import com.redxun.bpm.core.entity.config.UserTaskConfig;
import com.redxun.bpm.core.identity.service.BpmIdentityCalService;
import com.redxun.bpm.core.manager.BpmNodeSetManager;
import com.redxun.bpm.core.manager.BpmSignDataManager;
import com.redxun.bpm.enums.TaskOptionType;
import com.redxun.org.api.model.IdentityInfo;
import com.redxun.sys.org.entity.OsGroup;
import com.redxun.sys.org.entity.OsRelType;
import com.redxun.sys.org.entity.OsUser;
import com.redxun.sys.org.manager.OsGroupManager;
import com.redxun.sys.org.manager.OsUserManager;

/**
 * 會籤配置服務類
 * @author csx
 *
 */
public class CounterSignService {
@Resource
private BpmSignDataManager bpmSignDataManager;
@Resource
private BpmNodeSetManager bpmNodeSetManager;
@Resource
 BpmIdentityCalService bpmIdentityCalService;
@Resource
private OsGroupManager osGroupManager;
@Resource
private OsUserManager osUserManager;

private Log logger=LogFactory.getLog(CounterSignService.class);
/**
  * 獲得會籤任務中的人員計算集合
  * @param execution
  * @return
  */
public Set<String> getUsers(ActivityExecution execution){
  
  logger.debug("enter the CounterSignService ");
  
  Set<String> userIds=new LinkedHashSet<String>();
  String nodeId=execution.getActivity().getId();
  //1.回退處理通過
  BpmRuPath backRuPath=ProcessHandleHelper.getBackPath();
  if(backRuPath!=null && "YES".equals(backRuPath.getIsMultiple())){
   String uIds=backRuPath.getUserIds();
   userIds.addAll(Arrays.asList(uIds.split("[,]"))); 
   execution.setVariable("signUserIds_"+nodeId,uIds);
   return userIds;
  }

  //2.通過變數來判斷是否第一次進入該方法
  String signUserIds=(String)execution.getVariable("signUserIds_"+nodeId);
  
  if(StringUtils.isNotEmpty(signUserIds)){
   String[]uIds=signUserIds.split("[,]");
   userIds.addAll(Arrays.asList(uIds));
   return userIds;
  }
  
  //3.從介面中的提交變數取使用者
  IExecutionCmd nextCmd=ProcessHandleHelper.getProcessCmd();
  BpmDestNode bpmDestNode=nextCmd.getNodeUserMap().get(nodeId);

  if(bpmDestNode!=null && StringUtils.isNotEmpty(bpmDestNode.getUserIds())){
   //加至流程變數中，以使後續繼續不需要從執行緒及資料庫中獲取
   execution.setVariable("signUserIds_"+nodeId,bpmDestNode.getUserIds());
   execution.setVariable("priority_"+nodeId,bpmDestNode.getPriority());
   execution.setVariable("expiretime_"+nodeId, bpmDestNode.getExpireTime());
   
   String[]uIds=bpmDestNode.getUserIds().split("[,]");
   userIds.addAll(Arrays.asList(uIds));
   return userIds;
  }
  
  //4.從資料庫中讀取節點人員配置獲得參與人員列表
  Collection<IdentityInfo> idInfoList=bpmIdentityCalService.calNodeUsersOrGroups(execution.getProcessDefinitionId(), execution.getCurrentActivityId(),execution.getVariables());
  
  for(IdentityInfo identityInfo:idInfoList){
   if(IdentityInfo.IDENTIFY_TYPE_USER.equals(identityInfo.getIdentityType())){
    userIds.add(identityInfo.getIdentityInfoId());
   }else{
    List<OsUser> users= osUserManager.getByGroupIdRelTypeId(identityInfo.getIdentityInfoId(), OsRelType.REL_CAT_GROUP_USER_BELONG_ID);
    for(OsUser u:users){
     userIds.add(u.getUserId());
    }
   }
  }
  if(userIds.size()>0){
   StringBuffer sb=new StringBuffer();
   for(String uId:userIds){
    sb.append(uId).append(",");
   }
   if(sb.length()>0){
    sb.deleteCharAt(sb.length()-1);
   }
   execution.setVariable("signUserIds_"+nodeId,sb.toString());
  }else{
   String name=(String)execution.getActivity().getProperty("name");
   ProcessMessage msg=ProcessHandleHelper.getProcessMessage();
   msg.getErrorMsges().add("會籤節點["+name+"]沒有設定執行人員，請聯絡管理員！");
  }
   
  
  
  return userIds;
}

/**
  * 會籤是否計算完成
  * @param execution
  * @return
  */
public boolean isComplete(ActivityExecution execution){
  //完成會籤的次數
  Integer completeCounter=(Integer)execution.getVariable("nrOfCompletedInstances");
  //總迴圈次數
  Integer instanceOfNumbers=(Integer)execution.getVariable("nrOfInstances");
  
  String solId=(String)execution.getVariable("solId");
  String nodeId=execution.getActivity().getId();
  UserTaskConfig taskConfig=bpmNodeSetManager.getTaskConfig(solId, nodeId);
  
  //獲得任務及其多例項的配置,則任務不進行任何投票的設定及處理，即需要所有投票完成後來才跳至下一步。
  if(taskConfig.getMultiTaskConfig()==null){
   return completeCounter==instanceOfNumbers;
  }

  //獲得會籤的資料
  List<BpmSignData> bpmSignDatas=bpmSignDataManager.getByInstIdNodeId(execution.getProcessInstanceId(), nodeId);
  MultiTaskConfig multiTask=taskConfig.getMultiTaskConfig();
  //通過票數
  int passCount=0;
  //反對票數
  int refuseCount=0;
  //棄權票數
  int abstainCount=0;
  
  for(BpmSignData data:bpmSignDatas){
   int calCount=1;
   //棄權不作票數統計
   if(TaskOptionType.ABSTAIN.name().equals(data.getVoteStatus())){
    abstainCount++;
    continue;
   }
   String userId=data.getUserId();
   //檢查是否有特權的處理
   if(multiTask.getVotePrivConfigs().size()>0){
    //計算使用者的使用者組
    List<OsGroup> osGroups=osGroupManager.getBelongGroups(userId);
    
    for(TaskVotePrivConfig voteConfig:multiTask.getVotePrivConfigs()){
     //是否在特權裡
     boolean isInPriv=false;
     //為使用者型別
     if(TaskVotePrivConfig.USER.equals(voteConfig.getIdentityType()) 
       && voteConfig.getIdentityIds().contains(userId)){
      isInPriv=true;
     }else{//為使用者組型別
      for(OsGroup osGroup:osGroups){
       if(voteConfig.getIdentityIds().contains(osGroup.getGroupId())){
        isInPriv=true;
        break;
       }
      }
     }
     //若找到特權，則計算其值
     if(isInPriv){
      calCount=voteConfig.getVoteNums();
      break;
     }
    }
   }
   //統計同意票數
   if(TaskOptionType.AGREE.name().equals(data.getVoteStatus())){
    passCount+=calCount;
   }else{//統計反對票數
    refuseCount+=calCount;
   }
  }
  
  logger.debug("==============================passCount:"+passCount
    +" refuseCount:" + refuseCount +" abstainCount:"+abstainCount);
  //是否可以跳出會籤
  boolean isNext=false;
  String result=null;
  
  //按投票通過數進行計算
  if(MultiTaskConfig.VOTE_TYPE_PASS.equals(multiTask.getVoteResultType())){
   //計算是否通過
   //按投票數進行統計
   if(MultiTaskConfig.CAL_TYPE_NUMS.equals(multiTask.getCalType())){
    //代表通過
    if(passCount>=multiTask.getVoteValue()){
     isNext=true;
     result="PASS";
    }
   }else{//按百分比進行計算
    int resultPercent=new Double(passCount*100/(passCount+refuseCount+abstainCount)).intValue();
    //代表通過
    if(resultPercent>=multiTask.getVoteValue()){
     isNext=true;
     result="PASS";
    }
   }
  }else{//按投票反對數進行計算
   //計算是否通過
   //按投票數進行統計
   if(MultiTaskConfig.CAL_TYPE_NUMS.equals(multiTask.getCalType())){
    //代表通過
    if(refuseCount>=multiTask.getVoteValue()){
     isNext=true;
     result="REFUSE";
    }
   }else{//按百分比進行計算
    int resultPercent=new Double(refuseCount*100/(passCount+refuseCount+abstainCount)).intValue();
    //代表通過
    if(resultPercent>=multiTask.getVoteValue()){
     isNext=true;
     result="REFUSE";
    }
   }
  }
  
  if((MultiTaskConfig.HANDLE_TYPE_DIRECT.equals(multiTask.getHandleType())&& isNext)//直接處理
    || (MultiTaskConfig.HANDLE_TYPE_WAIT_TO.equals(multiTask.getHandleType()) && completeCounter==instanceOfNumbers)){//等待所有的處理完
   execution.setVariable("voteResult_"+nodeId, result);
   //刪除該節點的會籤資料
   for(BpmSignData data:bpmSignDatas){
    bpmSignDataManager.deleteObject(data);
   }
   return true;
  }
  
  return false;
  
}
}

【說明】
以上的程式碼的人員計算有幾個來源：

  1. 流程回退時獲得原來參與的人員
  2. 直接從流程變數中獲取
  3. 從介面中的提交變數取使用者
  4. 從資料庫中讀取節點人員配置獲得參與人員列表

會籤的投票處理結果放至流程變數中去，供後續的分支條件來處理，我們把會籤的配置設定管理如下：

我們提供了按票數、百分比的投票處理，同時允許有特權的使用者的投票規則以支援靈活的會簽結果運算。

諮詢瞭解

QQ: 1950148199

手機:18620763495

電話:020-29026351

相關推薦

你明白什麼是會籤？工作流+會籤應用

1.什麼是會籤?在流程業務管理中，任務是通常都是由一個人去處理的，而多個人同時處理一個任務，這種任務我們稱之為會籤任務。這種業務需求很常見，如一個請款單，領導審批環節中，就需要多個部門領導簽字。在流程業務中，我們可以把每個領導簽字的環節都定義為任務，並且這個會籤的人員是不固定

activit工作流-會籤流程（多例項）

使用工作流的時候有時會遇到這樣的一種情況就是一個任務需要幾個人一起審批，人數不定。這時常規的使用者任務就無法滿足要求，我們稱這種任務為會籤任務。 下面是我開發中的遇到的一個業務好遇到這種情況，記錄一下，以便小白參考。 流程圖： 說明：這是一個公文流轉（收文）流程，先是“

Activiti工作流--流程變數應用之一：選擇連線--之七

流程的業務描述 財務報賬審批流程: 如果財務主管接到審批任務,發現金額只有500時,自己審批完流程結束 如果財務主管接到審批任務,發現金額是1000時,審批完以後轉給財務經理繼續審批,財務經理審批完流程結束 先獲取連線 private ProcessEngi

簡易OA漫談之工作流設計(四,怎麼支援會籤)

會籤：就是一個步驟要所有人都審批完成才能完成。 上一步提交到會籤步驟時，該步驟的每個人都能收到一條待辦任務， 會籤審批人每次提交時都檢查該步驟所有會籤人是否已經審批，如果全部審批就產生下一手任務。 演示：http://wftest.bomye.cn/ 1、先建一個使用者組 2、給使用者組加兩個成

activiti工作流,駁回問題詳細解析(尤其會籤的駁回問題)

最近因為專案需要,所以研究了一下工作流,然而,我們都知道,國外的工作流框架,是不支援駁回問題的!這是其一!第二!專案的工作流要實現任意節點的流轉,這也是國外工作流框架所不具備的!因此,國外的工作流框架是沒有一個可以真正滿足我們的業務要求的,然而國內的工作流架構,我也沒有聽說過哪個可以支援中國式工作流!因此,在

Activiti工作流引擎添新丁：Flowable6.0(聽說無縫連線你會換嗎？)

如果你在還糾結該選擇JPMB還是Acitiviti的時候，或者還在糾結於是否該從JPMB遷移到Activiti的陣營中的時候，很不幸地告訴你，Flowable6.0已經發布了。 　　是不是變得更糾結啦？！又多了一種選擇。 　　1、 什麼是Flowable？ 　　

企業微信與微信打通，會實現工作生活分離嗎？馬化騰這樣回答！江西德迅為你分解

分享 用戶 用戶數 通過 F12 中國 版本更新 數字 信任 4月12日，2018年中國“互聯網+”數字經濟峰會舉行，此次峰會迎來了騰訊、京東等眾多互聯網大企。在本次峰會上馬化騰發表演講，就早前企業微信與私人微信打通的話題，提出了自己的看法。此前內測版企業微信將與私人微信打

【本人禿頂程式設計師】三分鐘讓你明白 Activity工作流（java運用）

←←←←←←←←←←←← 我都禿頂了，還不點關注！ 一. 什麼是工作流 以請假為例，現在大多數公司的請假流程是這樣的 員工打電話（或網聊）向上級提出請假申請——上級口頭同意——上級將請假記錄下來——月底將請假記錄上交公司——公司將請假錄入電腦 採用工作流技術的公司的請假流程是

你明白工作流是什麼、怎麼用了嗎？

·概念 　　今天小編將和大家分享一個新的知識點——工作流。我們可以將工作流理解為工作流程，它在IT領域不算是“新人”了，工作流思想在上世紀60年代就有人提出過；70年代就有人開始嘗試，但是由於當時許多的限制，工作流一直沒有成功的被實現；80年代才出現第一批成功的工作流系統；

真是沒想到 Springboot + Flowable 工作流開發會這麼簡單

>本文收錄在個人部落格：[www.chengxy-nds.top](http://www.chengxy-nds.top)，技術資料共享，同進步 **程式設計師是塊磚，哪裡需要哪裡搬** 公司內部的OA系統最近要升級改造，由於人手不夠就把我借調過去了，但說真的我還沒做過這方面的功能，第一次接觸工作流的開發

全開源ASP.NET工作流快速開發平臺，你想要的強大工作流引擎就在這裏！

名詞 全面 節點 eight 想要 stat 生活 委托 的人 現在辦公要流程化，營銷也有流程，流程現在已經是各種生活活動不可缺少的一部分了。就像這句耳熟能詳的話：“凡事，我們先走個流程嘛！”，在信息化、流程化的背景下。工作流引擎，這個名詞就出現了！那麽，什麽是工作流引擎呢

如果你是一個老板，你會選用Python還是會選用Java技術

java python web項目 本文主要是對網上觀點的綜合與歸納。如果想在Java與Python之間選擇一種技術來實現Web，老板會選擇哪樣技術呢？老板考慮問題自然是從商業角度上來考慮，對於生意人而言，技術只是獲取商業利益的手段。Python目前偏重在數據處理，自動化運維，web開發。孤立比較

程序員找工作面試會遇到哪些坑

更多 怎麽 方向 沒有 作用 一般來說 推薦 關註 很大的 前言 我在JD工作已經有四個多月了，加班一直都比較多，不是因為工作量太大，而是因為自己不會的東西太多。電商行業的確是一個很鍛煉人的地方。 2018年4月份，我寫的那篇文章《裸辭兩個月，海投一個月，從Android轉

[已解決]IE按F12工作列會出現“開發人員工具”按鈕，但視窗不顯示

原創內容： 說實話這個問題是我去年碰到了，怎麼都搜不到解決方案，當時有個網友說是被移動到螢幕以外去了，但沒說怎麼解決，網上常見的解決辦法（N多複製貼上的，真無聊）有： ctrl+p會把這個弄到瀏覽器裡面，不好用 右擊工作列按鈕把他最大化，但是想用指標選取瀏覽器中的元素時不方便 &nb

輸入輸出流讀取本機txt文件：不能將中文字元流轉化為char 因為char一個位元組，中文在UTF-8的情況下是三個位元組，會出現字元流擷取

package interview; import org.junit.Test; import java.io.*; public class TestInOrOutStream { class m { @Test void x(){ Sys

你的Spring事務為什麼不會自動回滾？

Spring的事務傳播行為有七種，當前我說的是預設的那種。我們知道Spring的宣告式事務是基於AOP的，那麼就是AOP玩的又是代理物件，那你是不是就知道了，這個事務的大概實現原理了。。。 首先我們要明確RuntimeException與Exception之間的關係與他們分別的含義：

帶你瞭解什麼是Activiti工作流，Activiti工作流資料庫表詳細介紹（23張表）

帶你五分鐘瞭解工作流 什麼是工作流 說到工作流,一圖勝萬言。 工作流 Georgakopoulos給出的工作流定義是：工作流是將一組任務組織起來以完成某個經營過程：定義了任務的觸發順序和觸發條件，每個任務可以由一個或多個軟體系統完成，也可以由一個或一組人完成，還可以由一個或多個

液壓剪板機使用等工作中會涉及哪些問題?

液壓數控剪板機我們來進行這方面的知識講解，主要是一些新知識，以便大家能讓自己通過學習來有些收穫和啟發。 　　1.液壓剪板機其具體是用閘式還是擺式的，應怎樣來決定?　　液壓剪板機，其具體是用閘式還是擺式的，這個的話，主要是看裝置的具體型號，以及其相應配置等。此外，在用途這一點上，還不能忽略。不過，通常來講

Git 簡單工作流，幫你快速使用 Git

安裝 Installing on Mac 通過 Homerew 安裝 brew install git 其它平臺安裝可以參考：Installing Git 建立新倉庫 建立新資料夾，進入，然後執行： git init 檢出倉庫 // 從本地 git c

分分鐘鍾明白Activity工作流 -- java運用

一、 什麼是工作流 以請假為例，現在大多數公司的請假流程是這樣的 員工打電話（或網聊）向上級提出請假申請——上級口頭同意——上級將請假記錄下來——月底將請假記錄上交公司——公司將請假錄入電腦 採用工作流技術的公司的請假流程是這樣的 員工使用賬戶登入系統——點選請