diff --git a/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussLibraryC3After.java b/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussLibraryC3After.java
index 50b52381..c16b9578 100644
--- a/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussLibraryC3After.java
+++ b/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussLibraryC3After.java
@@ -43,12 +43,11 @@ public class BussLibraryC3After implements TaskListener{
         List<BusProcessNew> list = busBean.list(queryWrapper1);
         if(!list.isEmpty()){
             BusProcessNew one = list.get(0);
-            JSONObject object =  JSONObject.parseObject(one.getMesg());
             List<String> nextUserList = new ArrayList();
 
-            if(StringUtils.isNotBlank(object.getString("bzhUserId"))){
-                delegateTask.setVariable("bzhUserId",object.getString("bzhUserId"));
-                nextUserList.add(object.getString("bzhUserId"));
+            if(StringUtils.isNotBlank(objectNew.getString("bzhUserId"))){
+                delegateTask.setVariable("bzhUserId",objectNew.getString("bzhUserId"));
+                nextUserList.add(objectNew.getString("bzhUserId"));
             }else {
                 throw new ActivitiException("1#2标准化员不存在,请配置相关人员");
             }
diff --git a/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussLibraryC6After.java b/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussLibraryC6After.java
index 6e9fa663..32523156 100644
--- a/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussLibraryC6After.java
+++ b/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussLibraryC6After.java
@@ -43,12 +43,11 @@ public class BussLibraryC6After implements TaskListener{
         List<BusProcessNew> list = busBean.list(queryWrapper1);
         if(!list.isEmpty()){
             BusProcessNew one = list.get(0);
-            JSONObject object =  JSONObject.parseObject(one.getMesg());
             List<String> nextUserList = new ArrayList();
 
-            if(StringUtils.isNotBlank(object.getString("fggcsUserId"))){
-                delegateTask.setVariable("fggcsUserId",object.getString("fggcsUserId"));
-                nextUserList.add(object.getString("fggcsUserId"));
+            if(StringUtils.isNotBlank(objectNew.getString("fggcsUserId"))){
+                delegateTask.setVariable("fggcsUserId",objectNew.getString("fggcsUserId"));
+                nextUserList.add(objectNew.getString("fggcsUserId"));
             }else {
                 throw new ActivitiException("1#2标准化员不存在,请配置相关人员");
             }