更多ruoyi-nbcio功能请看演示系统
gitee源代码地址
前后端代码: https://gitee.com/nbacheng/ruoyi-nbcio
演示地址:RuoYi-Nbcio后台管理系统
更多nbcio-boot功能请看演示系统
gitee源代码地址
后端代码: https://gitee.com/nbacheng/nbcio-boot
前端代码:https://gitee.com/nbacheng/nbcio-vue.git
在线演示(包括H5) : http://122.227.135.243:9888
今天在用流程启动的时候出现错误,结果相应的事务没有回滚,我主要是用下面语句
@Override
@Transactional(rollbackFor = Exception.class)
public R<Void> startProcessByDataId(String dataId, String serviceName, Map<String, Object> variables) {
//提交审批的时候进行流程实例关联初始化
if (serviceName==null){
return R.fail("未找到serviceName:"+serviceName);
}
WfCustomForm wfCustomForm = wfCustomFormService.selectSysCustomFormByServiceName(serviceName);
if(wfCustomForm ==null){
return R.fail("未找到sysCustomForm:"+serviceName);
}
//优先考虑自定义业务表是否关联流程,再看通用的表单流程关联表
ProcessDefinition processDefinition;
String deployId = wfCustomForm.getDeployId();
if(StringUtils.isEmpty(deployId)) {
WfDeployForm sysDeployForm = deployFormMapper.selectSysDeployFormByFormId("key_"+String.valueOf(wfCustomForm.getId()));
if(sysDeployForm ==null){
return R.fail("自定义表单也没关联流程定义表,流程没定义关联自定义表单"+wfCustomForm.getId());
}
processDefinition = repositoryService.createProcessDefinitionQuery()
.parentDeploymentId(sysDeployForm.getDeployId()).latestVersion().singleResult();
}
else {
processDefinition = repositoryService.createProcessDefinitionQuery()
.parentDeploymentId(deployId).latestVersion().singleResult();
}
try {
LambdaQueryWrapper<WfMyBusiness> wfMyBusinessLambdaQueryWrapper = new LambdaQueryWrapper<>();
wfMyBusinessLambdaQueryWrapper.eq(WfMyBusiness::getDataId, dataId);
WfMyBusiness business = wfMyBusinessService.getOne(wfMyBusinessLambdaQueryWrapper);
if (business==null){
if(processDefinition==null) {
return R.fail("自定义表单也没关联流程定义表,流程没定义关联自定义表单"+wfCustomForm.getId());
}
boolean binit = wfCommonService.initActBusiness(wfCustomForm.getBusinessName(), dataId, serviceName,
processDefinition.getKey(), processDefinition.getId(), wfCustomForm.getRouteName());
if(!binit) {
return R.fail("自定义表单也没关联流程定义表,流程没定义关联自定义表单"+wfCustomForm.getId());
}
WfMyBusiness businessnew = wfMyBusinessService.getOne(wfMyBusinessLambdaQueryWrapper);
//流程实例关联初始化结束
if (StrUtil.isNotBlank(businessnew.getProcessDefinitionId())){
return this.startProcessByDefId(businessnew.getProcessDefinitionId(),variables);
}
return this.startProcessByDefKey(businessnew.getProcessDefinitionKey(),variables);
}
else {
return R.fail("已经存在这个dataid实例,不要重复申请:"+dataId);
}
} catch (Exception e) {
e.printStackTrace();
return R.fail("流程启动错误");
}
}
结果实际数据没有回滚。
根据相关资料,由于异常被catch, 不阻断整个事务执行。所以应该是这里出现问题
可以不用try catch,或者就是需要修改如下:文章来源:https://www.toymoban.com/news/detail-819530.html
@Override
@Transactional(rollbackFor = Exception.class)
public R<Void> startProcessByDataId(String dataId, String serviceName, Map<String, Object> variables) {
//提交审批的时候进行流程实例关联初始化
if (serviceName==null){
return R.fail("未找到serviceName:"+serviceName);
}
WfCustomForm wfCustomForm = wfCustomFormService.selectSysCustomFormByServiceName(serviceName);
if(wfCustomForm ==null){
return R.fail("未找到sysCustomForm:"+serviceName);
}
//优先考虑自定义业务表是否关联流程,再看通用的表单流程关联表
ProcessDefinition processDefinition;
String deployId = wfCustomForm.getDeployId();
if(StringUtils.isEmpty(deployId)) {
WfDeployForm sysDeployForm = deployFormMapper.selectSysDeployFormByFormId("key_"+String.valueOf(wfCustomForm.getId()));
if(sysDeployForm ==null){
return R.fail("自定义表单也没关联流程定义表,流程没定义关联自定义表单"+wfCustomForm.getId());
}
processDefinition = repositoryService.createProcessDefinitionQuery()
.parentDeploymentId(sysDeployForm.getDeployId()).latestVersion().singleResult();
}
else {
processDefinition = repositoryService.createProcessDefinitionQuery()
.parentDeploymentId(deployId).latestVersion().singleResult();
}
try {
LambdaQueryWrapper<WfMyBusiness> wfMyBusinessLambdaQueryWrapper = new LambdaQueryWrapper<>();
wfMyBusinessLambdaQueryWrapper.eq(WfMyBusiness::getDataId, dataId);
WfMyBusiness business = wfMyBusinessService.getOne(wfMyBusinessLambdaQueryWrapper);
if (business==null){
if(processDefinition==null) {
return R.fail("自定义表单也没关联流程定义表,流程没定义关联自定义表单"+wfCustomForm.getId());
}
boolean binit = wfCommonService.initActBusiness(wfCustomForm.getBusinessName(), dataId, serviceName,
processDefinition.getKey(), processDefinition.getId(), wfCustomForm.getRouteName());
if(!binit) {
return R.fail("自定义表单也没关联流程定义表,流程没定义关联自定义表单"+wfCustomForm.getId());
}
WfMyBusiness businessnew = wfMyBusinessService.getOne(wfMyBusinessLambdaQueryWrapper);
//流程实例关联初始化结束
if (StrUtil.isNotBlank(businessnew.getProcessDefinitionId())){
return this.startProcessByDefId(businessnew.getProcessDefinitionId(),variables);
}
return this.startProcessByDefKey(businessnew.getProcessDefinitionKey(),variables);
}
else {
return R.fail("已经存在这个dataid实例,不要重复申请:"+dataId);
}
} catch (Exception e) {
e.printStackTrace();
throw new RuntimeException();
}
}
在catch里扔出throw new RuntimeException();,这样就可以回滚成功。文章来源地址https://www.toymoban.com/news/detail-819530.html
到了这里,关于springboot数据库回滚失败原因的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!