From 62654cb7d3e23074278c7c061bef8f6cbee90d73 Mon Sep 17 00:00:00 2001
From: ludc
Date: 星期五, 10 十一月 2023 09:48:21 +0800
Subject: [PATCH] 修改历史数据导入时限制单次导入通过配置做限制，开启多线程分批并行执行insert，注解开启事务回滚失效，对象方式开启事务实现手动提交事务，异常回滚事务
---
Source/UBCS/ubcs-ops/ubcs-flow/src/main/java/com/vci/ubcs/flow/engine/envent/FlowStatusListener.java | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/Source/UBCS/ubcs-ops/ubcs-flow/src/main/java/com/vci/ubcs/flow/engine/envent/FlowStatusListener.java b/Source/UBCS/ubcs-ops/ubcs-flow/src/main/java/com/vci/ubcs/flow/engine/envent/FlowStatusListener.java
index f932e49..ffe275d 100644
--- a/Source/UBCS/ubcs-ops/ubcs-flow/src/main/java/com/vci/ubcs/flow/engine/envent/FlowStatusListener.java
+++ b/Source/UBCS/ubcs-ops/ubcs-flow/src/main/java/com/vci/ubcs/flow/engine/envent/FlowStatusListener.java
@@ -29,6 +29,7 @@
import org.springframework.web.client.HttpClientErrorException;
import org.springframework.web.client.RestTemplate;
+import java.util.List;
import java.util.Map;
@Slf4j
@@ -62,13 +63,13 @@
String restURL = remoteMethod.getExpressionText();
String status = statusValue.getExpressionText();
//鑾峰彇涓氬姟鏁版嵁淇℃伅
- String oids = (String) taskVariable.get(FlowEngineConstant.OIDS);
+ List<String> oids = (List<String>) taskVariable.get(FlowEngineConstant.OIDS);
String btmType = (String) taskVariable.get(FlowEngineConstant.BTMTYPE);
taskVariable.put(FlowEngineConstant.REMOTE_METHOD,restURL);
taskVariable.put(FlowEngineConstant.STATUS_VALUE,status);
- if(StringUtils.isEmpty(oids)){
+ if(CollectionUtils.isEmpty(oids)){
throw new VciBaseException("鎵ц鐘舵�佷慨鏀逛簨浠舵椂锛屼笟鍔℃暟鎹畂id涓虹┖锛�");
}
if(StringUtils.isEmpty(btmType)){
@@ -86,7 +87,7 @@
FlowStatusDTO flowStatusDTO = new FlowStatusDTO();
flowStatusDTO.setBtmType(btmType);
- flowStatusDTO.setOids(VciBaseUtil.str2List(oids));
+ flowStatusDTO.setOids(oids);
flowStatusDTO.setVariableMap(taskVariable);
flowStatusDTO.setTaskHisVOList(FlowableUtils.listTaskHistory(delegateTask.getProcessInstanceId(),historyService,taskService));
@@ -115,7 +116,6 @@
if(CollectionUtils.isEmpty(result) && !(Boolean) result.get("success")){
throw new VciBaseException((String) result.get("message"));
}
-
}
}
--
Gitblit v1.9.3