dzx преди 1 година
родител
ревизия
9bfe78178d
променени са 1 файла, в които са добавени 12 реда и са изтрити 1 реда
  1. 12 1
      src/main/java/com/xjrsoft/module/workflow/service/impl/WorkflowExecuteServiceImpl.java

+ 12 - 1
src/main/java/com/xjrsoft/module/workflow/service/impl/WorkflowExecuteServiceImpl.java

@@ -1223,7 +1223,6 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
         List<ProcessParamConfig> processParamConfigs = workflowSchemaConfig.getProcessConfig().getProcessParamConfigs();
 
         long count = historyService.createHistoricProcessInstanceQuery().count();
-
         Map<String, Object> processParam = WorkFlowUtil.getProcessParam(processParamConfigs, workflowSchema, count + 1, null);
 
         //表单赋值
@@ -1294,6 +1293,10 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
                     session.quietRollback();
                 }
                 throw new MyException("【表单id: " + formConfig.getFormId() + "】 提交错误, 请联系管理员!");
+            }finally {
+                for (Session session : sessionList) {
+                    session.close();
+                }
             }
 
         }
@@ -1455,6 +1458,10 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
                     session.quietRollback();
                 }
                 throw new MyException("【表单id: " + formConfig.getFormId() + "】 提交错误, 请联系管理员!");
+            }finally {
+                for (Session session : sessionList) {
+                    session.close();
+                }
             }
 
         }
@@ -2432,6 +2439,10 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
             } else {
                 throw new MyException("表单提交错误, 请联系系统管理员!");
             }
+        }finally {
+            for (Session session : sessionList) {
+                session.close();
+            }
         }