|
package org.springblade.mdm.statreport.service;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import lombok.AllArgsConstructor;
|
import org.apache.commons.lang3.StringUtils;
|
import org.flowable.engine.HistoryService;
|
import org.flowable.engine.RuntimeService;
|
import org.flowable.engine.TaskService;
|
import org.flowable.engine.history.HistoricProcessInstance;
|
import org.flowable.engine.history.HistoricProcessInstanceQuery;
|
import org.flowable.engine.task.Comment;
|
import org.flowable.task.api.Task;
|
import org.flowable.task.api.TaskInfoQuery;
|
import org.flowable.task.api.TaskQuery;
|
import org.flowable.task.api.history.HistoricTaskInstance;
|
import org.flowable.task.api.history.HistoricTaskInstanceQuery;
|
import org.springblade.core.oss.OssTemplate;
|
import org.springblade.core.secure.utils.AuthUtil;
|
import org.springblade.core.tool.api.R;
|
import org.springblade.core.tool.utils.DateUtil;
|
import org.springblade.core.tool.utils.Func;
|
import org.springblade.mdm.basesetting.machine.entity.Machine;
|
import org.springblade.mdm.basesetting.machine.service.MachineService;
|
import org.springblade.mdm.commons.contants.DictBizConstants;
|
import org.springblade.mdm.commons.service.ParamService;
|
import org.springblade.mdm.flow.constants.FlowContants;
|
import org.springblade.mdm.flow.entity.FlowProgramFile;
|
import org.springblade.mdm.flow.entity.MdmFlowProcess;
|
import org.springblade.mdm.flow.entity.TaskDispatch;
|
import org.springblade.mdm.flow.service.FlowProgramFileService;
|
import org.springblade.mdm.flow.service.FlowProgramProperties;
|
import org.springblade.mdm.flow.util.MdmFlowCache;
|
import org.springblade.mdm.flow.vo.ApproveTableInfo;
|
import org.springblade.mdm.flow.vo.FlowVO;
|
import org.springblade.mdm.statreport.utils.WordReplaceUtil;
|
import org.springblade.system.feign.IDictBizClient;
|
import org.springblade.system.feign.IUserClient;
|
import org.springblade.system.pojo.entity.User;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.io.ByteArrayOutputStream;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.util.*;
|
|
/**
|
* 流程业务实现类
|
*
|
* @author Chill
|
*/
|
@Service
|
@AllArgsConstructor
|
public class ConfirmTablePrintService {
|
private final RuntimeService runtimeService;
|
private final IDictBizClient dictBizClient;
|
private final HistoryService historyService;
|
private final IUserClient userClient;
|
private final FlowProgramFileService flowProgramFileService;
|
@Autowired
|
private MachineService machineService;
|
@Autowired
|
private ParamService paramService;
|
@Autowired
|
private OssTemplate ossTemplate;
|
/**
|
* 导出word岸本
|
* @param dispatch 任务分派
|
* @param props 流程属性
|
*/
|
public ByteArrayOutputStream exportConfirmTableDoc(TaskDispatch dispatch, FlowProgramProperties props) throws IOException {
|
ByteArrayOutputStream os= new ByteArrayOutputStream();
|
String tplOssName = paramService.confirmTableTemplateOssFileName();
|
try(InputStream tplInputStream = ossTemplate.statFileStream(tplOssName);) {
|
WordReplaceUtil.convert(getData(dispatch, props), tplInputStream, os);
|
}
|
return os;
|
}
|
|
/**
|
* 获取填充数据
|
*/
|
|
Map<String,String> getData(TaskDispatch dispatch,FlowProgramProperties props){
|
//ApproveTableInfo approveInfo = approveInfoQueryService.getApproveInfo(props);
|
Machine machine;
|
String machineCode = props.getMachineCode();
|
machine = machineService.getByCode(machineCode);
|
|
if(dispatch == null){
|
dispatch = new TaskDispatch();//TODO 后面去掉
|
}
|
|
Map<String,String> dataMap = new HashMap<>();
|
|
dataMap.put("bh","不明确");
|
|
dataMap.put("drawingNo",props.getDrawingNo());
|
dataMap.put("processNo",props.getProcessNo());
|
dataMap.put("craftEdition",props.getCraftEdition());
|
dataMap.put("processEdition",props.getProcessEdition());
|
dataMap.put("machineMode",machine.getName());
|
|
String DATE_PATTERN = "yyyy-M-d";
|
|
String dispatchDateStr = " ";
|
|
String ctlSystem = "";
|
R<String> ctmR = dictBizClient.getValue(DictBizConstants.CONTROL_SYSTEM,machine.getControlSystem());
|
if(ctmR.isSuccess()){
|
ctlSystem = ctmR.getData();
|
}
|
dataMap.put("deviation",dispatch.getDeviation()==null?"":dispatch.getDeviation());
|
dataMap.put("controlSystem",ctlSystem);
|
dataMap.put("czz","操作者");
|
dataMap.put("jyy","检验员");
|
|
|
dataMap.put("programNo",dispatch.getProgramNo());
|
dataMap.put("fuhey",WordReplaceUtil.CHECKED);
|
dataMap.put("fuhen",WordReplaceUtil.UNCHECKED);
|
dataMap.put("jly",WordReplaceUtil.CHECKED);
|
dataMap.put("jln",WordReplaceUtil.UNCHECKED);
|
|
String bianzhiDateStr = "";//DateUtil.format(dispatch.getCreateTime(), DATE_PATTERN);
|
|
|
dataMap.put("bianzhi","编程员？/"+bianzhiDateStr);
|
dataMap.put("jiaodui","工艺校对？/时间不确定");
|
dataMap.put("shenhe","高师？/时间不确定");
|
|
dataMap.put("sendPath",machine.getProgSendDir()!=null?machine.getProgSendDir():"");
|
|
return dataMap;
|
}
|
|
/**
|
* 已完结的流程分页列表
|
* @param page 分页信息
|
* @param createTimeBegin
|
* @param createTimeEnd
|
* @param keyword 关键字
|
* @return
|
*/
|
public IPage<FlowVO> confirmTablePage(IPage<FlowVO> page, String drawingNo, String keyword,LocalDateTime createTimeBegin, LocalDateTime createTimeEnd) {
|
//固化里路村官
|
HistoricProcessInstanceQuery query = this.historyService.createHistoricProcessInstanceQuery().finished().processDefinitionKey(FlowContants.CURE_PROCESS_KEY).includeProcessVariables();
|
//.finished() // 只查询已完成的流程.unfinished() // 查询未完成的流程
|
query.variableNotExists(FlowContants.EXCEPTION);//非异常流程
|
if(createTimeBegin!=null) {
|
query.startedAfter(DateUtil.toDate(createTimeBegin));
|
}
|
if(createTimeEnd!=null) {
|
query.startedBefore(DateUtil.toDate(createTimeEnd));
|
}
|
if(Func.isNotEmpty(drawingNo)) {
|
String likeVal = "%" + drawingNo + "%";
|
query.variableValueLike(FlowContants.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;
|
}
|
/**
|
获取列表中的文件名
|
*/
|
String getFileString(String processInstanceId){
|
String result = "";
|
List<FlowProgramFile> fileList = flowProgramFileService.lambdaQuery().eq(FlowProgramFile::getProcessInstanceId, processInstanceId).list();
|
|
result = String.join(",",fileList.stream().map(FlowProgramFile::getName).toList());
|
|
return result;
|
}
|
|
}
|
