diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java index e052c43a..af5d4bf0 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java @@ -101,5 +101,11 @@ public class BusProcessNewController extends BaseAction { public List getSarBussionStandPageNo(@RequestBody List rows) { return iBusProcessNewService.getSarBussionStandPageNo(rows); } + + @ApiOperation(value = "福企标制修订计划流程变更 在合并 延期 取消 更名 流程变更 批准则结束") + @GetMapping("/endPrcName") + public String endPrcName(@RequestParam("prcName")String prcName,@RequestParam("esId") String esId) { + return iBusProcessNewService.endPrcName(prcName,esId); + } } diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java index a3a7ab95..5fc43b59 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java @@ -53,4 +53,6 @@ public interface IBusProcessNewService extends IService { ResponseMessage updateBusProcessNew(String id, String mags); List getSarBussionStandPageNo(List rows); + + String endPrcName(String prcName,String esId); } diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java index db67ef9c..8919c5ca 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java @@ -14,9 +14,14 @@ import com.ydw.bat.wkflow.business_main.datas.mapper.BusProcessNewMapper; import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNewService; import com.ydw.bat.wkflow.business_oa.webService.service.impl.WebServiceOAServiceImpl; import com.ydw.bat.wkflow.config.ScheduledJobEsPlan; +import com.ydw.bat.wkflow.util.activiti.DeleteTaskCommond; import com.ydw.bat.wkflow.util.http.ResponseMessage; import com.ydw.bat.wkflow.util.http.Result; +import org.activiti.engine.ProcessEngine; +import org.activiti.engine.RuntimeService; import org.activiti.engine.TaskService; +import org.activiti.engine.impl.ProcessEngineImpl; +import org.activiti.engine.runtime.ProcessInstanceQuery; import org.activiti.engine.task.Task; import org.activiti.engine.task.TaskQuery; import org.apache.commons.lang.StringUtils; @@ -40,6 +45,9 @@ public class BusProcessNewServiceImpl extends ServiceImpl busProcessNewQueryWrapper = new QueryWrapper<>(); + busProcessNewQueryWrapper.eq("PRC_NAME",prcName); + List busProcessNews = baseMapper.selectList(busProcessNewQueryWrapper); + if(!busProcessNews.isEmpty()){ + for (BusProcessNew newData:busProcessNews){ + //判断是否是同一条企标计划 + JSONObject jsonObject = JSON.parseObject(newData.getMesg()); + String esIdMesg = jsonObject.getString("esId"); + if(StringUtils.isNotBlank(esIdMesg)){ + if(esId.equals(esIdMesg)){ + //是同一条企标计划 删除当前待办 是否是起草页面 + //删除OA待办任务 + // taskService.deleteTask(newData.getTaskId()); + runtimeService.deleteProcessInstance(newData.getPId(),"原始数据已被更改"); + } + } + } + } + return "成功"; + } + public void taskInfo(List busProcessNews){ }