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 d0638029..cad134c6 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
@@ -1,6 +1,7 @@
 package com.ydw.bat.wkflow.business_main.datas.controller;
 
 
+import com.baomidou.mybatisplus.extension.api.R;
 import com.tmsps.fk.common.base.action.BaseAction;
 import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
 import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNewService;
@@ -61,6 +62,12 @@ public class BusProcessNewController extends BaseAction {
         return findtodotask;
     }
 
+    @ApiOperation(value = "首页流程计划立项查询mesg")
+    @GetMapping("/selectBusProcessNew")
+    public String selectBusProcessNew(String taskId) {
+        return iBusProcessNewService.selectBusProcessNew(taskId);
+    }
+
 
 }
 
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 96d479ee..2a6378cf 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
@@ -36,4 +36,5 @@ public interface IBusProcessNewService extends IService<BusProcessNew> {
     List<BusProcessNew> everyDayTenOlock();
     List<BusProcessNew> everyDayTenOlockSAM();
 
+    String selectBusProcessNew(String taskId);
 }
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 539cb7f2..b36fd699 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
@@ -1,5 +1,6 @@
 package com.ydw.bat.wkflow.business_main.datas.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
 import com.ydw.bat.wkflow.business_main.datas.mapper.BusProcessNewMapper;
@@ -9,10 +10,7 @@ import org.activiti.engine.TaskService;
 import org.activiti.engine.task.Task;
 import org.springframework.stereotype.Service;
 
-import java.util.ArrayList;
-import java.util.Comparator;
-import java.util.List;
-import java.util.TreeSet;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -89,4 +87,21 @@ public class BusProcessNewServiceImpl extends ServiceImpl<BusProcessNewMapper, B
         return baseMapper.everyDayTenOlockSAM();
     }
 
+    @Override
+    public String selectBusProcessNew(String taskId) {
+          QueryWrapper<BusProcessNew> busProcessNewQueryWrapper = new QueryWrapper<>();
+          busProcessNewQueryWrapper.eq("TASK_id",taskId);
+          BusProcessNew busProcessNew = baseMapper.selectOne(busProcessNewQueryWrapper);
+          if(busProcessNew!=null){
+              Map mapType = JSON.parseObject(busProcessNew.getMesg(),Map.class);
+              Object nowEsIdObject = mapType.get("nowEsId");
+              if(nowEsIdObject!=null){
+                   String nowEsId = nowEsIdObject.toString();
+                   return nowEsId;
+              }
+          }
+
+        return null;
+    }
+
 }