blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/controller/ProgramOnMachineExportController.java
@@ -66,9 +66,10 @@ excel.setProcessEdition(Func.toStr(vars.get(FlowVariableConstant.PROCESS_EDITION))); excel.setMachineCode(Func.toStr(vars.get(FlowVariableConstant.MACHINE_CODE))); excel.setProcessInstanceId(record.getProcessInstanceId()); excel.setDeviation(Func.toStr(record.getVariables().get(FlowVariableConstant.DEVIATION))); list.add(excel); }); ExcelUtil.export(response, "ç°åºç¼å¶è®°å½" + DateUtil.time(), "æºåºæ°æ®è¡¨", list, ProgramOnMachineExcel.class); ExcelUtil.export(response, "ç°åºç¼å¶è®°å½" + DateUtil.time(), "ç°åºç¼å¶è®°å½", list, ProgramOnMachineExcel.class); } } blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/ProgramOnMachineExportService.java
@@ -8,8 +8,6 @@ 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; @@ -28,8 +26,6 @@ public class ProgramOnMachineExportService { private final HistoryService historyService; private final ParamService paramService; private final MachineService machineService; /** * * @param page åé¡µä¿¡æ¯ @@ -42,18 +38,7 @@ //.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())); } @@ -82,7 +67,6 @@ vo.setProcessCreateTime(processInstance.getStartTime()); vo.setHistoryTaskEndTime(processInstance.getEndTime()); //vo.setFile(getFileString(processInstance.getId())); records.add(vo); blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/vo/ProgramOnMachineExcel.java
@@ -20,6 +20,8 @@ private String processNo; @ExcelProperty("å·¥åºç次") private String processEdition; @ExcelProperty("ä¸´æ¶æ´æ¹å") private String deviation; @ColumnWidth(20) @ExcelProperty("æºåºç¼å·") blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/vo/TaskAssignVO.java
@@ -40,7 +40,7 @@ @Schema(description = "计åå¼å·¥æ¶é´") private LocalDate planStartTime; @Schema(description = "å离åå·") @Schema(description = "ä¸´æ¶æ´æ¹å") private String deviation; @Schema(description = "æ¯å¦ä¸´æ¶æµç¨ï¼å¼:Y/N") private String isTempFlow; blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/controller/ProgramOnMachineImportController.java
@@ -1,6 +1,7 @@ package org.springblade.mdm.program.controller; import com.baomidou.mybatisplus.core.metadata.IPage; import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.tags.Tag; @@ -10,13 +11,12 @@ import org.springblade.core.excel.util.ExcelUtil; import org.springblade.core.tenant.annotation.NonDS; import org.springblade.core.tool.api.R; import org.springblade.mdm.flow.vo.ProgramOnMachineExcel; import org.springblade.mdm.flow.vo.ProgramOnMachineQueryVO; import org.springblade.mdm.program.service.MdmProgramImportService; import org.springblade.mdm.program.service.ProgramOnMachineService; import org.springblade.mdm.program.vo.MdmProgramImportVO; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import org.springblade.mdm.program.vo.*; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import java.util.List; @@ -59,4 +59,11 @@ } } @Operation(summary = "å·¥æ§ç½ä¸åºç¼ç¨è®°å½å页æ¥è¯¢", description = "å·¥æ§ç½ä¸åºç¼ç¨è®°å½å页æ¥è¯¢") @GetMapping("/program-on-machine-page") public R<IPage<ProgramOnMachineVO>> page(ProgramOnMachineRecordQueryVO queryVO) { return R.data(programOnMachineService.pageQuery(queryVO)); } } blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/entity/ProgramOnMachine.java
@@ -41,6 +41,10 @@ private String processNo; /** * ä¸´æ¶æ´æ¹å */ private String deviation; /** * æµç¨å®ä¾id */ private String processInstanceId; blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/mapper/ProgramOnMachineMapper.java
@@ -1,9 +1,19 @@ package org.springblade.mdm.program.mapper; import com.baomidou.mybatisplus.core.metadata.IPage; import org.apache.ibatis.annotations.Param; import org.springblade.core.mp.mapper.BladeMapper; import org.springblade.mdm.program.entity.ProgramOnMachine; import org.springblade.mdm.program.vo.ProgramOnMachineRecordQueryVO; import org.springblade.mdm.program.vo.ProgramOnMachineVO; public interface ProgramOnMachineMapper extends BladeMapper<ProgramOnMachine> { /** * å¯¼å ¥è®°å½å页æ¥è¯¢ * @param page åé¡µä¿¡æ¯ * @param queryVO æ¥è¯¢æ æ® * @return åé¡µæ°æ® */ IPage<ProgramOnMachineVO> pageQuery(@Param("page")IPage<Object> page, @Param("query")ProgramOnMachineRecordQueryVO queryVO); } blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/mapper/ProgramOnMachineMapper.xml
@@ -3,4 +3,23 @@ <mapper namespace="org.springblade.mdm.program.mapper.ProgramOnMachineMapper"> <select id="pageQuery" resultType="org.springblade.mdm.program.vo.ProgramOnMachineVO"> select p.id,p.drawing_no,p.process_no,p.process_edition,p.deviation,p.machine_code,p.process_instance_id,p.create_time,u.name create_user_name from mdm_program_on_machine p left join blade_user u on p.create_user=u.id <where> p.is_deleted=0 <if test="query.drawingNo!=null and query.drawingNo!=''"> <bind name="dno" value="'%'+query.drawingNo+'%'"/> and p.drawing_no like #{dno} </if> <if test="query.createTimeBegin!=null"> and p.create_time >= #{query.createTimeBegin} </if> <if test="query.createTimeEnd!=null"> and p.create_time <= #{query.createTimeEnd} </if> </where> order by p.create_time desc; </select> </mapper> blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/ProgramOnMachineService.java
@@ -1,17 +1,19 @@ package org.springblade.mdm.program.service; import com.baomidou.mybatisplus.core.metadata.IPage; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springblade.core.excel.util.ExcelUtil; import org.springblade.core.mp.base.BizServiceImpl; import org.springblade.core.mp.support.Condition; import org.springblade.core.tool.utils.BeanUtil; import org.springblade.mdm.basesetting.machine.service.MachineService; import org.springblade.mdm.commons.service.ParamService; import org.springblade.mdm.flow.vo.ProgramOnMachineExcel; import org.springblade.mdm.program.entity.ProgramOnMachine; import org.springblade.mdm.program.mapper.ProgramOnMachineMapper; import org.springblade.mdm.program.vo.ProgramOnMachineRecordQueryVO; import org.springblade.mdm.program.vo.ProgramOnMachineVO; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; @@ -19,7 +21,7 @@ import java.util.*; /** * DNCåä¼ æä»¶å¤çæå¡ * ç°åºç¼ç¨è®°å½å¤çå¿ * * @author yangys */ @@ -43,6 +45,10 @@ return list.size(); } /** * æ¹éä¿å * @param list */ void batchSaveData(List<ProgramOnMachine> list) { for (ProgramOnMachine progOnMachine : list) { if(!existsByProcessInstanceId(progOnMachine.getProcessInstanceId())){ @@ -51,7 +57,21 @@ } } /** * æ ¹æ®æµç¨å®ä¾idå¤å®æ¯å¦åå¨ * @param processInstanceId æµç¨å®ä¾id * @return æ¯å¦åå¨ */ boolean existsByProcessInstanceId(String processInstanceId){ return this.lambdaQuery().eq(ProgramOnMachine::getProcessInstanceId,processInstanceId).count() > 0; } /** * ç°åºç¼ç¨å¯¼å ¥è®°å½æ¥è¯¢ * @param queryVO æ¥è¯¢æ æ® * @return åé¡µæ æ® */ public IPage<ProgramOnMachineVO> pageQuery(ProgramOnMachineRecordQueryVO queryVO) { return baseMapper.pageQuery(Condition.getPage(queryVO),queryVO);//IPage<ProgramOnMachineExcel>,queryVO } } blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/vo/ProgramOnMachineRecordQueryVO.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,25 @@ package org.springblade.mdm.program.vo; import io.swagger.v3.oas.annotations.media.Schema; import lombok.Getter; import lombok.Setter; import org.springblade.core.mp.support.Query; import org.springblade.core.tool.utils.DateUtil; import org.springframework.format.annotation.DateTimeFormat; import java.time.LocalDate; @Schema(description = "ç°åºç¼è¾è®°å½æ¥è¯¢å¯¹è±¡ï¼å·¥æ§ç½ï¼") @Setter @Getter public class ProgramOnMachineRecordQueryVO extends Query { @Schema(description = "é¶ç»ä»¶å·") private String drawingNo; @DateTimeFormat(pattern = DateUtil.PATTERN_DATE) @Schema(description = "审æ¹å®ææ¶é´å¼å§") private LocalDate createTimeBegin; @DateTimeFormat(pattern = DateUtil.PATTERN_DATE) @Schema(description = "审æ¹å®ææ¶é´æªæ¢") private LocalDate createTimeEnd; } blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/vo/ProgramOnMachineVO.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,46 @@ package org.springblade.mdm.program.vo; import io.swagger.v3.oas.annotations.media.Schema; import lombok.Getter; import lombok.Setter; import org.springblade.core.mp.support.Query; import org.springblade.core.tool.utils.DateUtil; import org.springblade.mdm.commons.vo.BaseVO; import org.springframework.format.annotation.DateTimeFormat; import java.time.LocalDate; @Schema(description = "ç°åºç¼è¾è®°å½æ¥è¯¢å¯¹è±¡ï¼å·¥æ§ç½ï¼") @Setter @Getter public class ProgramOnMachineVO extends BaseVO { @Schema(description = "é¶ç»ä»¶å·") private String drawingNo; /** * 设å¤ç¼å· */ private String machineCode; /** * å·¥åºç次 */ private String processEdition; /** * å·¥åºå· */ private String processNo; /** * ä¸´æ¶æ´æ¹å */ private String deviation; /** * æµç¨å®ä¾id */ private String processInstanceId; }