blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/CureFlowService.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,91 @@ package org.springblade.mdm.flow.service; import org.flowable.engine.IdentityService; import org.flowable.engine.RuntimeService; import org.flowable.engine.runtime.ProcessInstance; import org.springblade.core.secure.utils.AuthUtil; import org.springblade.mdm.flow.excution.AutoAssignUsersService; import org.springblade.mdm.flow.vo.TaskAssignVO; import org.springblade.mdm.program.entity.NcProgram; import org.springblade.mdm.program.service.NcProgramService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.HashMap; import java.util.Map; /** * åºåæµç¨æå¡ */ @Service public class CureFlowService { @Autowired private RuntimeService runtimeService; @Autowired private AutoAssignUsersService autoAssignUsersService; @Autowired private IdentityService identityService; @Autowired private NcProgramService ncProgramService; /** * åºåæµç¨çkey */ private static final String PROCESS_KEY = "program-cure"; public void start(long programId){ Map<String, Object> vars = new HashMap<>(); /* Map<String,Object> preAssignee = autoAssignUsersService.autoAssignUsers(startVO.getProducePlanId()); Map<String, Object> vars = new HashMap<>(preAssignee); vars.put("machineCode",startVO.getMachineCode()); vars.put("machineMode",startVO.getMachineMode()); vars.put("processNo",startVO.getProcessNo()); vars.put("processName",startVO.getProcessName()); vars.put("processEdition",startVO.getProcessEdition()); vars.put("craftEdition",startVO.getCraftEdition()); vars.put("planStartTime",startVO.getPlanStartTime()); vars.put("drawingNo",startVO.getDrawingNo()); vars.put("drawingNoEdition",startVO.getDrawingNoEdition()); vars.put("planLockDays",startVO.getPlanLockDays()); //é¶ç»ä»¶ä»£ç String partNo = generatePartNo(startVO); vars.put("partNo",partNo); NcProgram curedNcProgram = ncProgramService.getCuredNcProgram(partNo,startVO.getMachineCode()); vars.put("curedNcProgram",curedNcProgram); //设置æ¯å¦æåºåç¨åºæ è®° vars.put("hasCuredProgram",curedNcProgram != null ? "Y":"N"); */ String businessKey = "0";//ä¸å¡è¡¨key identityService.setAuthenticatedUserId(String.valueOf(AuthUtil.getUserId()));//设置æµç¨å起人 ProcessInstance pinst = runtimeService.startProcessInstanceByKey(PROCESS_KEY,businessKey,vars); int a=1; //log.info() } /** * çæé¶ç»ä»¶ç¼å· * å¾å·ãå¾å·ç次ãå·¥åºå·ãå·¥åºåç§°ãå·¥èºç次ãå·¥åºç次 ç»åèµ·æ¥è·å¾é¶ç»ä»¶å· * @param startVO * @return */ String generatePartNo(TaskAssignVO startVO){ //TODO è¿ä¸ªæ ¼å¼æªç¡®å®ï¼éè¦ç¡®è®¤ return String.format("%s-%s-%s-%s-%s-%s", startVO.getDrawingNo(), startVO.getDrawingNoEdition(), startVO.getProcessNo(), startVO.getProcessName(), startVO.getCraftEdition(), startVO.getProcessEdition()); } } blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/controller/DncSendBackController.java
@@ -29,22 +29,6 @@ public class DncSendBackController { private final DncSendBackService dncSendBackService; /** * dncåä¼ æä»¶å¯¼å ¥ * * @param file æµç¨æä»¶ */ /* @PostMapping("dnc-sendback-upload") @ApiOperationSupport(order = 4) @Operation(summary = "dncåä¼ æä»¶å¯¼å ¥", description = "dncåä¼ æä»¶å¯¼å ¥") public R dncSendBackUpload(@RequestParam MultipartFile file) { boolean temp = Objects.requireNonNull(file.getOriginalFilename()).endsWith("pkg"); temp = true;//ä¸´æ¶æ¾è¡ return R.data(Kv.create().set("name", file.getOriginalFilename()).set("success", temp)); } */ /** * ä¸ä¼ DNCåä¼ æä»¶ * blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/controller/NcNodeController.java
@@ -1,7 +1,6 @@ package org.springblade.mdm.program.controller; import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Parameter; import io.swagger.v3.oas.annotations.Parameters; @@ -10,7 +9,6 @@ import io.swagger.v3.oas.annotations.tags.Tag; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springblade.core.secure.BladeUser; import org.springblade.core.tenant.annotation.NonDS; import org.springblade.core.tool.api.R; import org.springblade.mdm.program.service.NcNodeService; @@ -18,7 +16,6 @@ import org.springframework.web.bind.annotation.*; import java.util.List; import java.util.Map; /** * ç¨åºèç¹ @@ -49,7 +46,7 @@ @PostMapping("/update") @Operation(summary = "ä¿®æ¹èç¹", description = "èç¹ä¿¡æ¯,å¿ é¡»ä¼ å ¥ID") public R<Boolean> update(@RequestBody NcNodeVO vo) { ncNodeService.updateNcCode(vo); ncNodeService.updateNcNode(vo); return R.<Boolean>status(true); } blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/DncSendBackService.java
@@ -35,6 +35,7 @@ import org.apache.commons.compress.utils.SeekableInMemoryByteChannel; import org.flowable.engine.*; import org.springblade.core.tool.utils.FileUtil; import org.springblade.core.tool.utils.Func; import org.springblade.mdm.program.vo.DncSendBackData; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; @@ -133,13 +134,19 @@ return datas; } /** * å ¥åºåä¼ æä»¶ * å ¥åºåä¼ æä»¶,å¹¶å¯å¨åºåæµç¨ * @param ids * @return */ public void dncFileAccept(String ids) { List<Long> idList = Func.toLongList(ids); for (Long id : idList) { //å¯å¨åºåæµç¨ } } } class ZipFileDirectoryScanner { blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/NcNodeService.java
@@ -1,15 +1,10 @@ package org.springblade.mdm.program.service; import com.fasterxml.jackson.databind.ObjectMapper; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.flowable.engine.*; import org.springblade.core.mp.base.BizServiceImpl; import org.springblade.core.secure.utils.AuthUtil; import org.springblade.core.tool.utils.Func; import org.springblade.mdm.basesetting.machine.MachineService; import org.springblade.mdm.basesetting.machine.entity.Machine; import org.springblade.mdm.program.entity.NcNode; import org.springblade.mdm.program.mapper.NcNodeMapper; import org.springblade.mdm.program.vo.NcNodeVO; @@ -38,8 +33,11 @@ this.save(ncNode); } public void updateNcCode(NcNodeVO vo) { /** * æ´æ°èç¹ * @param vo */ public void updateNcNode(NcNodeVO vo) { NcNode ncNode = this.getById(vo.getId()); ncNode.setName(vo.getName()); ncNode.setNodeType(vo.getNodeType());