|
@@ -24,6 +24,7 @@ import com.xjrsoft.module.workflow.entity.WorkflowExtra;
|
|
|
import com.xjrsoft.module.workflow.entity.WorkflowFormRelation;
|
|
import com.xjrsoft.module.workflow.entity.WorkflowFormRelation;
|
|
|
import com.xjrsoft.module.workflow.entity.WorkflowRecord;
|
|
import com.xjrsoft.module.workflow.entity.WorkflowRecord;
|
|
|
import com.xjrsoft.module.workflow.mapper.WorkflowExtraMapper;
|
|
import com.xjrsoft.module.workflow.mapper.WorkflowExtraMapper;
|
|
|
|
|
+import com.xjrsoft.module.workflow.mapper.WorkflowFormRelationMapper;
|
|
|
import com.xjrsoft.module.workflow.mapper.WorkflowRecordMapper;
|
|
import com.xjrsoft.module.workflow.mapper.WorkflowRecordMapper;
|
|
|
import lombok.AllArgsConstructor;
|
|
import lombok.AllArgsConstructor;
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
@@ -52,6 +53,8 @@ public class WfSubscriptionServiceImpl extends MPJBaseServiceImpl<WfSubscription
|
|
|
|
|
|
|
|
private WorkflowExtraMapper workflowExtraMapper;
|
|
private WorkflowExtraMapper workflowExtraMapper;
|
|
|
|
|
|
|
|
|
|
+ private WorkflowFormRelationMapper workflowFormRelationMapper;
|
|
|
|
|
+
|
|
|
@Override
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public Boolean add(WfSubscription wfSubscription) {
|
|
public Boolean add(WfSubscription wfSubscription) {
|
|
@@ -134,10 +137,17 @@ public class WfSubscriptionServiceImpl extends MPJBaseServiceImpl<WfSubscription
|
|
|
.eq(WorkflowFormRelation::getFormKeyValue, id)
|
|
.eq(WorkflowFormRelation::getFormKeyValue, id)
|
|
|
);
|
|
);
|
|
|
info.setWorkflowRecordList(BeanUtil.copyToList(recordList, WorkflowRecordVo.class));
|
|
info.setWorkflowRecordList(BeanUtil.copyToList(recordList, WorkflowRecordVo.class));
|
|
|
- info.setProcessId(recordList.get(0).getProcessId());
|
|
|
|
|
|
|
+ List<WorkflowFormRelation> relations = workflowFormRelationMapper.selectList(new QueryWrapper<WorkflowFormRelation>().lambda().eq(WorkflowFormRelation::getFormKeyValue, id));
|
|
|
|
|
+
|
|
|
|
|
+ info.setProcessId(relations.get(0).getProcessId());
|
|
|
|
|
|
|
|
//查询最后一个节点的taskId
|
|
//查询最后一个节点的taskId
|
|
|
- workflowExtraMapper.selectList(new QueryWrapper<WorkflowExtra>().lambda().eq(WorkflowExtra::getProcessId, info.getProcessId()));
|
|
|
|
|
|
|
+ List<WorkflowExtra> taskList = workflowExtraMapper.selectList(
|
|
|
|
|
+ new QueryWrapper<WorkflowExtra>().lambda()
|
|
|
|
|
+ .eq(WorkflowExtra::getProcessId, info.getProcessId())
|
|
|
|
|
+ .orderByDesc(WorkflowExtra::getStartTime)
|
|
|
|
|
+ );
|
|
|
|
|
+ info.setTaskId(taskList.get(0).getTaskId());
|
|
|
return info;
|
|
return info;
|
|
|
}
|
|
}
|
|
|
|
|
|