法规清单-数据迁移的流程重置功能开发对接。

jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/controller/ProjectLawsInventoryEOController.java

@@ -493,4 +493,11 @@ public class ProjectLawsInventoryEOController extends JeroController<ProjectLaws
 	public Result<?> regulationOwnerReturned(@RequestBody JSONObject json) {
 		return this.projectLawsInventoryEOService.regulationOwnerReturned(json);
 	}
+
+	@AutoLog(value = "流程重置-迁移法规清单流程历史数据专用")
+	@ApiOperation(value="流程重置-迁移法规清单流程历史数据专用", notes="流程重置-迁移法规清单流程历史数据专用")
+	@PostMapping(value = "/resetFlowTemp")
+	public Result<?> resetFlowTemp(@RequestBody JSONObject params) {
+		return this.projectLawsInventoryEOService.resetFlowTemp(params);
+	}
 }

jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/service/IProjectLawsInventoryEOService.java

@@ -242,4 +242,6 @@ public interface IProjectLawsInventoryEOService extends IService<ProjectLawsInve
 	 * @param currentUser
 	 */
     void createQueryPermission(int isProjectRole, LoginUser currentUser, QueryWrapper<ProjectLawsInventoryEO> projectLawsInventoryEOQueryWrapper);
+
+	Result<?> resetFlowTemp(JSONObject parmas);
 }

jero-boot/jero-boot-modules/src/main/java/com/jero/modules/project/service/impl/ProjectLawsInventoryEOServiceImpl.java

@@ -11687,4 +11687,64 @@ public class ProjectLawsInventoryEOServiceImpl extends ServiceImpl<ProjectLawsIn
 			msgList.add(errorMsg);
 		}
 	}
+
+
+	@Override
+	public Result<?> resetFlowTemp(JSONObject parmas) {
+		String ids = parmas.getString("ids");
+		String projectLibraryId = parmas.getString("projectLibraryId");
+		if(StringUtils.isNotEmpty(ids)){
+
+			QueryWrapper<ProjectLawsInventoryEO> queryWrapper = new QueryWrapper<>();
+			queryWrapper.lambda().in(ProjectLawsInventoryEO::getId, Arrays.asList(ids.split(",")));
+			queryWrapper.lambda().eq(ProjectLawsInventoryEO::getProjectLibraryId,projectLibraryId);
+			List<ProjectLawsInventoryEO> projectLawsInventoryEOS = this.list(queryWrapper);
+
+			List<String> idList = Arrays.asList(ids.split(","));
+			String projectLawsInventoryIds = ids;
+			String pIds = "";
+
+			ProjectLawsInventoryEO projectLawsInventoryEO = new ProjectLawsInventoryEO();
+			projectLawsInventoryEO.setInventoryAffirmStatus(InventoryAffirmStatusEnum.NOT_STARTED.getValue());
+			projectLawsInventoryEO.setTaskAffirmStatus(TaskAffirmStatusEnum.NOT_STARTED.getValue());
+			//清单、任务确认初始化。
+			LambdaUpdateWrapper<ProjectLawsInventoryEO> updateWrapper = new LambdaUpdateWrapper<>();
+			updateWrapper.in(ProjectLawsInventoryEO::getId,idList);
+			updateWrapper.set(ProjectLawsInventoryEO::getRegulationOwnerSubmitStatus,null);
+			updateWrapper.set(ProjectLawsInventoryEO::getHomologationEngineerSubmitStatus,null);
+			updateWrapper.set(ProjectLawsInventoryEO::getSendMsgFlag,null);
+			updateWrapper.set(ProjectLawsInventoryEO::getSendMsgCurrentFlag,null);
+			updateWrapper.set(ProjectLawsInventoryEO::getInventoryAffirmDueDate,null);
+			updateWrapper.set(ProjectLawsInventoryEO::getTaskAffirmDueDate,null);
+			updateWrapper.set(ProjectLawsInventoryEO::getDesignFlowStatus,ComplianceFlowStatusEnum.LIST_TO_BE_RELEASED.getValue());
+			updateWrapper.set(ProjectLawsInventoryEO::getVerifyFlowStatus,ComplianceFlowStatusEnum.LIST_TO_BE_RELEASED.getValue());
+			super.update(projectLawsInventoryEO, updateWrapper);
+
+			QueryWrapper<ProcessInfoEO> processInfoQueryWrap = new QueryWrapper<>();
+			processInfoQueryWrap.lambda().in(ProcessInfoEO::getProjectLawsInventoryId,idList);
+			List<ProcessInfoEO> processInfoEOList = this.processInfoEOService.list(processInfoQueryWrap);
+			List<String> actiProcInstIdList = processInfoEOList.stream().filter(processInfo -> {
+				boolean flag = false;
+				if (StringUtils.equals(processInfo.getFlowType(), FlowTypeEnum.SJFHXSHLC.getValue()) || StringUtils.equals(processInfo.getFlowType(), FlowTypeEnum.YZFHXSCLC.getValue())) {
+					flag = true;
+				}
+				return flag;
+			}).map(ProcessInfoEO::getActiProcInstId).distinct().collect(Collectors.toList());
+
+			pIds = actiProcInstIdList.stream().map(String::valueOf).collect(Collectors.joining(","));
+			JSONObject params = new JSONObject();
+			params.put("projectLawsInventoryIds",projectLawsInventoryIds);
+			params.put("pIds",pIds);
+			//根据流程实例id 、 法规清单id  删除相关流程。
+			workFlowFeignClient.deleteProcessInstanceByProjectLawsInventoryIds(params);
+
+			//清除流程中心对应的数据
+			params.put("ids",ids);
+			this.processInfoEOService.change(params);
+
+			// 删除流程历史数据
+			this.processHistoryEOService.deleteBiActiProcInstIdList(actiProcInstIdList);
+		}
+		return Result.OK("变更成功！");
+	}
 }