wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-2596-调整ExtAxProperty删除方式为物理删除

Browse Source
This commit is contained in:
yangqicheng 2024-07-19 23:31:07 +08:00
parent 5356549e48
commit aedfec0f31
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AbstractExecuteWithLockJobHandler.java
View File

@ -31,6 +31,7 @@ public abstract class AbstractExecuteWithLockJobHandler extends AbstractJobHandl
extAxProperty.setName(processInstanceId); extAxProperty.setName(processInstanceId);
extAxProperty.setValue(jobId); extAxProperty.setValue(jobId);
extAxPropertyService.add(extAxProperty); extAxPropertyService.add(extAxProperty);
log.info("job acquire lock success,processInstanceId:{},jobId:{}", processInstanceId, jobId);
executeInternal(job, configuration, variableScope, commandContext); executeInternal(job, configuration, variableScope, commandContext);
} catch (DuplicateKeyException e) { } catch (DuplicateKeyException e) {
log.error("executeWithLock error,lock by another job,jobId:{},processInstanceId:{}", job.getId(), job.getProcessInstanceId(), e); log.error("executeWithLock error,lock by another job,jobId:{},processInstanceId:{}", job.getId(), job.getProcessInstanceId(), e);

4
workflow-engine-core/src/main/java/cn/axzo/workflow/core/repository/entity/ExtAxProperty.java
View File

@ -1,6 +1,7 @@
package cn.axzo.workflow.core.repository.entity; package cn.axzo.workflow.core.repository.entity;
import cn.axzo.framework.data.mybatisplus.model.BaseEntity; import cn.axzo.framework.data.mybatisplus.model.BaseEntity;
import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@ -38,5 +39,6 @@ public class ExtAxProperty extends BaseEntity<ExtAxProperty> {
@TableField("value") @TableField("value")
private String value; private String value;
@TableField(value = "is_delete", fill = FieldFill.INSERT)
private Long isDelete = 0L;
} }