|
package org.springblade.mdm.flow.service;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import lombok.AllArgsConstructor;
|
import org.flowable.engine.HistoryService;
|
import org.flowable.engine.history.HistoricProcessInstance;
|
import org.flowable.engine.history.HistoricProcessInstanceQuery;
|
import org.springblade.core.tool.utils.DateUtil;
|
import org.springblade.core.tool.utils.Func;
|
import org.springblade.mdm.basesetting.machine.service.MachineService;
|
import org.springblade.mdm.commons.service.ParamService;
|
import org.springblade.mdm.flow.constants.FlowConstant;
|
import org.springblade.mdm.flow.constants.FlowVariableConstant;
|
import org.springblade.mdm.flow.vo.FlowVO;
|
import org.springblade.mdm.flow.vo.ProgramOnMachineQueryVO;
|
import org.springframework.stereotype.Service;
|
|
import java.util.*;
|
|
/**
|
* 流程业务实现类
|
*
|
* @author Chill
|
*/
|
@Service
|
@AllArgsConstructor
|
public class ProgramOnMachineExportService {
|
|
private final HistoryService historyService;
|
private final ParamService paramService;
|
private final MachineService machineService;
|
/**
|
*
|
* @param page 分页信息
|
* @param queryVO 查询数据对象
|
* @return
|
*/
|
public IPage<FlowVO> finishedPage(IPage<FlowVO> page, ProgramOnMachineQueryVO queryVO) {
|
//固化里路村官
|
HistoricProcessInstanceQuery query = this.historyService.createHistoricProcessInstanceQuery().finished().processDefinitionKey(FlowConstant.TRY_PROCESS_KEY).includeProcessVariables();
|
//.finished() // 只查询已完成的流程.unfinished() // 查询未完成的流程
|
query.variableNotExists(FlowVariableConstant.EXCEPTION);//非异常流程
|
query.variableValueEquals(FlowVariableConstant.PROGRAM_ON_MACHINE, FlowConstant.Y);//选择现场编制的
|
/*
|
//车床或者选择现场编制的程序
|
String turnVal = paramService.turninngValue();
|
List<Machine> machines = machineService.lambdaQuery().eq(Machine::getMachineSpec,turnVal).eq(Machine::getStatus,Machine.STATUS_ENABLE).list();
|
List<String> turnMachineCodes = machines.stream().map(Machine::getCode).toList();
|
query.or();
|
for(String mCode : turnMachineCodes){
|
query.variableValueEquals(FlowVariableContants.MACHINE_CODE, mCode);
|
}
|
|
query.endOr();
|
*/
|
if(queryVO.getEndTimeBegin()!=null) {
|
query.finishedAfter(DateUtil.toDate(queryVO.getEndTimeBegin()));
|
}
|
if(queryVO.getEndTimeEnd()!=null) {
|
query.finishedBefore(DateUtil.toDate(queryVO.getEndTimeEnd()));
|
}
|
if(Func.isNotEmpty(queryVO.getDrawingNo())) {
|
String likeVal = "%" + queryVO.getDrawingNo() + "%";
|
query.variableValueLike(FlowVariableConstant.DRAWING_NO,likeVal);
|
}
|
query.orderByProcessInstanceEndTime().desc(); // 按结束时间降序排列
|
page.setTotal(query.count());
|
|
long firstResult = (page.getCurrent()-1) * page.getSize();
|
List<HistoricProcessInstance> processes = query
|
.listPage((int)firstResult, (int)page.getSize());
|
|
List<FlowVO> records = new LinkedList<>();
|
|
for(HistoricProcessInstance processInstance : processes) {
|
FlowVO vo = new FlowVO();
|
vo.setProcessDefinitionKey(processInstance.getProcessDefinitionKey());
|
vo.setProcessInstanceId(processInstance.getId());
|
vo.setProcessDefinitionName(processInstance.getProcessDefinitionName());
|
vo.setVariables(processInstance.getProcessVariables());
|
|
vo.setProcessCreateTime(processInstance.getStartTime());
|
vo.setHistoryTaskEndTime(processInstance.getEndTime());
|
|
|
//vo.setFile(getFileString(processInstance.getId()));
|
records.add(vo);
|
}
|
|
page.setRecords(records);
|
|
return page;
|
}
|
|
}
|
