diff --git a/src/main/java/neatlogic/module/cmdb/api/attr/GetCiAttrListApi.java b/src/main/java/neatlogic/module/cmdb/api/attr/GetCiAttrListApi.java
index b7e3a1115a1b04e6d2067b92ad1933c693ee9e80..6613192ce0c3b0511961ebb3e250eaa33631221a 100644
--- a/src/main/java/neatlogic/module/cmdb/api/attr/GetCiAttrListApi.java
+++ b/src/main/java/neatlogic/module/cmdb/api/attr/GetCiAttrListApi.java
@@ -16,6 +16,7 @@
 
 package neatlogic.module.cmdb.api.attr;
 
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import neatlogic.framework.auth.core.AuthAction;
 import neatlogic.framework.cmdb.attrvaluehandler.core.AttrValueHandlerFactory;
@@ -33,6 +34,7 @@ import neatlogic.framework.restful.core.privateapi.PrivateApiComponentBase;
 import neatlogic.module.cmdb.dao.mapper.ci.AttrMapper;
 import neatlogic.module.cmdb.dao.mapper.ci.CiMapper;
 import neatlogic.module.cmdb.dao.mapper.ci.CiViewMapper;
+import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 
@@ -76,7 +78,9 @@ public class GetCiAttrListApi extends PrivateApiComponentBase {
             @Param(name = "showType", type = ApiParamType.ENUM, rule = "all,list,detail", desc = "common.displaytype"),
             @Param(name = "allowEdit", type = ApiParamType.INTEGER, rule = "1,0", desc = "term.cmdb.allowedit"),
             @Param(name = "isRequired", type = ApiParamType.INTEGER, rule = "1,0", desc = "common.isrequired"),
-            @Param(name = "isSimple", type = ApiParamType.BOOLEAN, rule = "true,false", desc = "term.cmdb.issimpleattribute")
+            @Param(name = "isSimple", type = ApiParamType.BOOLEAN, rule = "true,false", desc = "term.cmdb.issimpleattribute"),
+            @Param(name = "defaultValue", type = ApiParamType.JSONARRAY, desc = "common.defaultvalue")
+
     })
     @Output({
             @Param(name = "Return", explode = AttrVo[].class)
@@ -84,6 +88,12 @@ public class GetCiAttrListApi extends PrivateApiComponentBase {
     @Description(desc = "nmcaa.getciattrlistapi.getname")
     @Override
     public Object myDoService(JSONObject jsonObj) throws Exception {
+        JSONArray defaultValue = jsonObj.getJSONArray("defaultValue");
+        if (CollectionUtils.isNotEmpty(defaultValue)) {
+            List<Long> idList = defaultValue.toJavaList(Long.class);
+            List<AttrVo> attrList = attrMapper.getAttrByIdList(idList);
+            return attrList;
+        }
         Long ciId = jsonObj.getLong("ciId");
         if (ciId == null) {
             String ciName = jsonObj.getString("ciName");
diff --git a/src/main/java/neatlogic/module/cmdb/api/customview/GetCustomViewAttrApi.java b/src/main/java/neatlogic/module/cmdb/api/customview/GetCustomViewAttrApi.java
index 4f2b9e5b8f646e20f36b36d8191628bbc3398776..9b49fa889bd162ce4bfbe745b8496c6bda3605a3 100644
--- a/src/main/java/neatlogic/module/cmdb/api/customview/GetCustomViewAttrApi.java
+++ b/src/main/java/neatlogic/module/cmdb/api/customview/GetCustomViewAttrApi.java
@@ -16,16 +16,19 @@
 
 package neatlogic.module.cmdb.api.customview;
 
+import com.alibaba.fastjson.JSONArray;
 import neatlogic.framework.auth.core.AuthAction;
 import neatlogic.framework.cmdb.dto.customview.CustomViewAttrVo;
 import neatlogic.framework.cmdb.dto.customview.CustomViewConstAttrVo;
 import neatlogic.framework.common.constvalue.ApiParamType;
+import neatlogic.framework.exception.type.ParamNotExistsException;
 import neatlogic.framework.restful.annotation.*;
 import neatlogic.framework.restful.constvalue.OperationTypeEnum;
 import neatlogic.framework.restful.core.privateapi.PrivateApiComponentBase;
 import neatlogic.framework.cmdb.auth.label.CMDB_BASE;
 import neatlogic.module.cmdb.dao.mapper.customview.CustomViewMapper;
 import com.alibaba.fastjson.JSONObject;
+import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -41,7 +44,7 @@ public class GetCustomViewAttrApi extends PrivateApiComponentBase {
 
     @Override
     public String getName() {
-        return "获取自定义视图属性列表";
+        return "nmcac.getcustomviewattrapi.getname";
     }
 
     @Override
@@ -49,12 +52,30 @@ public class GetCustomViewAttrApi extends PrivateApiComponentBase {
         return null;
     }
 
-    @Input({@Param(name = "id", type = ApiParamType.LONG, desc = "视图id", isRequired = true), @Param(name = "isHidden", type = ApiParamType.INTEGER, desc = "属性是否隐藏，1是，0否")})
-    @Output({@Param(name = "attrList", explode = CustomViewAttrVo[].class), @Param(name = "constAttrList", explode = CustomViewConstAttrVo[].class)})
-    @Description(desc = "获取自定义视图属性列表接口")
+    @Input({
+            @Param(name = "id", type = ApiParamType.LONG, desc = "common.id"),
+            @Param(name = "isHidden", type = ApiParamType.INTEGER, desc = "common.ishidden，", help = "1是，0否"),
+            @Param(name = "defaultValue", type = ApiParamType.JSONARRAY, desc = "common.defaultvalue")
+    })
+    @Output({
+            @Param(name = "attrList", explode = CustomViewAttrVo[].class),
+            @Param(name = "constAttrList", explode = CustomViewConstAttrVo[].class)
+    })
+    @Description(desc = "nmcac.getcustomviewattrapi.getname")
     @Override
     public Object myDoService(JSONObject paramObj) throws Exception {
+        JSONArray defaultValue = paramObj.getJSONArray("defaultValue");
+        if (CollectionUtils.isNotEmpty(defaultValue)) {
+            List<String> uuidList = defaultValue.toJavaList(String.class);
+            List<CustomViewAttrVo> attrList = customViewMapper.getCustomViewAttrByUuidList(uuidList);
+            JSONObject returnObj = new JSONObject();
+            returnObj.put("attrList", attrList);
+            return returnObj;
+        }
         Long id = paramObj.getLong("id");
+        if (id == null) {
+            throw new ParamNotExistsException("id");
+        }
         Integer isHidden = paramObj.getInteger("isHidden");
         CustomViewConstAttrVo customViewConstAttrVo = new CustomViewConstAttrVo(id);
         CustomViewAttrVo customViewAttrVo = new CustomViewAttrVo(id);
diff --git a/src/main/java/neatlogic/module/cmdb/dao/mapper/customview/CustomViewMapper.java b/src/main/java/neatlogic/module/cmdb/dao/mapper/customview/CustomViewMapper.java
index c048eab7fb33ff11942628c7a467843efe9cf120..319e30f3d2effc68a96b2ac076080f1e714ab704 100644
--- a/src/main/java/neatlogic/module/cmdb/dao/mapper/customview/CustomViewMapper.java
+++ b/src/main/java/neatlogic/module/cmdb/dao/mapper/customview/CustomViewMapper.java
@@ -42,6 +42,8 @@ public interface CustomViewMapper {
 
     List<CustomViewAttrVo> getCustomViewAttrByCustomViewId(CustomViewAttrVo customViewAttrVo);
 
+    List<CustomViewAttrVo> getCustomViewAttrByUuidList(List<String> uuidList);
+
     List<CustomViewConstAttrVo> getCustomViewConstAttrByCustomViewId(CustomViewConstAttrVo customViewConstAttrVo);
 
     List<CustomViewLinkVo> getCustomViewLinkByCustomViewId(Long customViewId);
diff --git a/src/main/java/neatlogic/module/cmdb/dao/mapper/customview/CustomViewMapper.xml b/src/main/java/neatlogic/module/cmdb/dao/mapper/customview/CustomViewMapper.xml
index f4a78ce0ca811f782e681ca11e12a96563da0439..6fbc90d8f292e93bfe143dd5d287d24d1eac9d07 100644
--- a/src/main/java/neatlogic/module/cmdb/dao/mapper/customview/CustomViewMapper.xml
+++ b/src/main/java/neatlogic/module/cmdb/dao/mapper/customview/CustomViewMapper.xml
@@ -177,6 +177,34 @@
         ORDER BY a.sort
     </select>
 
+    <select id="getCustomViewAttrByUuidList" parameterType="java.lang.String" resultMap="customViewAttrMap">
+        SELECT
+        a.customview_id AS customViewId,
+        a.customview_ci_uuid AS customViewCiUuid,
+        a.uuid,
+        a.attr_id AS attrId,
+        a.alias,
+        a.sort,
+        a.is_hidden AS isHidden,
+        a.is_primary AS isPrimary,
+        a.`condition` AS conditionStr,
+        a.`name` AS name,
+        b.`name` AS attrName,
+        b.`label` AS attrLabel,
+        b.`ci_id` AS ciId,
+        b.`type` AS attrType,
+        b.`target_ci_id` AS targetCiId,
+        b.`config` AS configStr
+        FROM `cmdb_customview_attr` a
+        JOIN `cmdb_attr` b ON a.attr_id = b.id
+        JOIN `cmdb_customview_ci` c ON a.customview_ci_uuid = c.uuid AND c.is_hidden = 0
+        WHERE a.uuid IN
+        <foreach collection="list" item="uuid" open="(" separator="," close=")">
+            #{uuid}
+        </foreach>
+        ORDER BY a.sort
+    </select>
+
     <select id="getCustomViewByName" parameterType="java.lang.String" resultMap="customViewMap">
         SELECT a.id,
                a.name,
diff --git a/src/main/java/neatlogic/module/cmdb/service/cientity/CiEntityServiceImpl.java b/src/main/java/neatlogic/module/cmdb/service/cientity/CiEntityServiceImpl.java
index 8ca2981fd6082ab37ef3d97fd9c9057d86847cf3..8cc0960835ccc0dbef58d9fa2bf39f81249fe8db 100644
--- a/src/main/java/neatlogic/module/cmdb/service/cientity/CiEntityServiceImpl.java
+++ b/src/main/java/neatlogic/module/cmdb/service/cientity/CiEntityServiceImpl.java
@@ -120,10 +120,27 @@ public class CiEntityServiceImpl implements CiEntityService, ICiEntityCrossoverS
 
     @Override
     public List<CiEntityVo> getCiEntityBaseInfoByName(Long ciId, String name) {
-        CiEntityVo ciEntityVo = new CiEntityVo();
-        ciEntityVo.setCiId(ciId);
-        ciEntityVo.setName(name);
-        return ciEntityMapper.getCiEntityBaseInfoByName(ciEntityVo);
+//        CiEntityVo ciEntityVo = new CiEntityVo();
+//        ciEntityVo.setCiId(ciId);
+//        ciEntityVo.setName(name);
+//        return ciEntityMapper.getCiEntityBaseInfoByName(ciEntityVo);
+        CiVo ciVo = ciMapper.getCiById(ciId);
+        if (ciVo == null) {
+            return new ArrayList<>();
+        }
+        CiEntityVo search = new CiEntityVo();
+        search.setName(name);
+        if (ciVo.getIsVirtual().equals(0)) {
+            // 非虚拟模型
+            List<CiVo> downwardCiList = ciMapper.getDownwardCiListByLR(ciVo.getLft(), ciVo.getRht());
+            Map<Long, CiVo> downwardCiMap = downwardCiList.stream().collect(Collectors.toMap(e -> e.getId(), e -> e));
+            search.setIdList(new ArrayList<>(downwardCiMap.keySet()));
+            return ciEntityMapper.getCiEntityListByCiIdListAndName(search);
+        } else {
+            // 虚拟模型
+            search.setCiId(ciVo.getId());
+            return ciEntityMapper.getVirtualCiEntityBaseInfoByName(search);
+        }
     }
 
     /**
diff --git a/src/main/java/neatlogic/module/cmdb/workerdispatcher/exception/CmdbDispatcherDispatchFailedException.java b/src/main/java/neatlogic/module/cmdb/workerdispatcher/exception/CmdbDispatcherDispatchFailedException.java
new file mode 100644
index 0000000000000000000000000000000000000000..0acff5fa2513fab651326e457efaf956189eb3e6
--- /dev/null
+++ b/src/main/java/neatlogic/module/cmdb/workerdispatcher/exception/CmdbDispatcherDispatchFailedException.java
@@ -0,0 +1,43 @@
+package neatlogic.module.cmdb.workerdispatcher.exception;
+
+import com.alibaba.fastjson.JSONObject;
+import neatlogic.framework.cmdb.dto.ci.CiVo;
+import neatlogic.framework.cmdb.dto.cientity.AttrFilterVo;
+import neatlogic.framework.cmdb.dto.cientity.CiEntityVo;
+import neatlogic.framework.cmdb.dto.customview.CustomViewConditionFilterVo;
+import neatlogic.framework.cmdb.dto.customview.CustomViewVo;
+import neatlogic.framework.process.exception.processtask.ProcessTaskException;
+
+import java.util.List;
+import java.util.Map;
+
+public class CmdbDispatcherDispatchFailedException extends ProcessTaskException {
+
+    public CmdbDispatcherDispatchFailedException(Long id) {
+        super("nmcwe.cmdbdispatcherdispatchfailedexception.cmdbdispatcherdispatchfailedexception_a", id);
+    }
+
+    public CmdbDispatcherDispatchFailedException(CiEntityVo ciEntity) {
+        super("nmcwe.cmdbdispatcherdispatchfailedexception.cmdbdispatcherdispatchfailedexception_b", JSONObject.toJSONString(ciEntity));
+    }
+
+    public CmdbDispatcherDispatchFailedException(Map<String, Object> data) {
+        super("nmcwe.cmdbdispatcherdispatchfailedexception.cmdbdispatcherdispatchfailedexception_b", JSONObject.toJSONString(data));
+    }
+
+    public CmdbDispatcherDispatchFailedException(CiVo ci, List<AttrFilterVo> attrFilterList) {
+        super("nmcwe.cmdbdispatcherdispatchfailedexception.cmdbdispatcherdispatchfailedexception_c", ci.getLabel(), ci.getName(), JSONObject.toJSONString(attrFilterList));
+    }
+
+    public CmdbDispatcherDispatchFailedException(CiVo ci, List<AttrFilterVo> attrFilterList, int size) {
+        super("nmcwe.cmdbdispatcherdispatchfailedexception.cmdbdispatcherdispatchfailedexception_d", ci.getLabel(), ci.getName(), JSONObject.toJSONString(attrFilterList), size);
+    }
+
+    public CmdbDispatcherDispatchFailedException(CustomViewVo customView, List<CustomViewConditionFilterVo> attrFilterList) {
+        super("nmcwe.cmdbdispatcherdispatchfailedexception.cmdbdispatcherdispatchfailedexception_e", customView.getName(), JSONObject.toJSONString(attrFilterList));
+    }
+
+    public CmdbDispatcherDispatchFailedException(CustomViewVo customView, List<CustomViewConditionFilterVo> attrFilterList, int size) {
+        super("nmcwe.cmdbdispatcherdispatchfailedexception.cmdbdispatcherdispatchfailedexception_f", customView.getName(), JSONObject.toJSONString(attrFilterList), size);
+    }
+}
diff --git a/src/main/java/neatlogic/module/cmdb/workerdispatcher/handler/CiEntityFormDispatcher.java b/src/main/java/neatlogic/module/cmdb/workerdispatcher/handler/CiEntityFormDispatcher.java
deleted file mode 100644
index 32f22fdc3b6ba2d9b22f751ac59cc5848dfa6977..0000000000000000000000000000000000000000
--- a/src/main/java/neatlogic/module/cmdb/workerdispatcher/handler/CiEntityFormDispatcher.java
+++ /dev/null
@@ -1,64 +0,0 @@
-package neatlogic.module.cmdb.workerdispatcher.handler;
-
-import neatlogic.framework.asynchronization.threadlocal.UserContext;
-import neatlogic.framework.process.dto.ProcessTaskStepVo;
-import neatlogic.framework.process.workerdispatcher.core.WorkerDispatcherBase;
-import neatlogic.framework.process.workerdispatcher.core.WorkerDispatcherForm;
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import org.springframework.stereotype.Service;
-
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-
-@Service
-public class CiEntityFormDispatcher extends WorkerDispatcherBase {
-
-    @Override
-    public String getName() {
-        return "配置项表单分派器";
-    }
-
-    @Override
-    protected List<String> myGetWorker(ProcessTaskStepVo processTaskStepVo, JSONObject configObj) {
-        List<String> resultList = new ArrayList<>();
-        resultList.add(UserContext.get().getUserUuid());
-        return resultList;
-    }
-
-    @Override
-    public String getHelp() {
-        return "根据所选表单组件，查询CMDB配置项中某一列的值作为当前步骤的处理人";
-    }
-
-    @Override
-    public JSONArray getConfig() {
-        JSONArray resultArray = new JSONArray();
-        /** 选择表单组件 **/
-        {
-            JSONObject jsonObj = new JSONObject();
-            jsonObj.put("type", WorkerDispatcherForm.FORM_SELECT.getValue());
-            jsonObj.put("name", "form");
-            jsonObj.put("label", "配置项");
-            jsonObj.put("validateList", Collections.singletonList("required"));
-            jsonObj.put("multiple", false);
-            jsonObj.put("value", "");
-            jsonObj.put("defaultValue", "");
-            resultArray.add(jsonObj);
-        }
-        /** 选择ciEntity **/
-        {
-            JSONObject jsonObj = new JSONObject();
-            jsonObj.put("type", WorkerDispatcherForm.TEXT.getValue());
-            jsonObj.put("name", "owner");
-            jsonObj.put("label", "配置项属性名");
-            jsonObj.put("validateList", Collections.singletonList("required"));
-            jsonObj.put("value", "");
-            jsonObj.put("defaultValue", "");
-            resultArray.add(jsonObj);
-        }
-        return resultArray;
-    }
-
-}
diff --git a/src/main/java/neatlogic/module/cmdb/workerdispatcher/handler/CmdbDispatcher.java b/src/main/java/neatlogic/module/cmdb/workerdispatcher/handler/CmdbDispatcher.java
new file mode 100644
index 0000000000000000000000000000000000000000..7a7c80d08fc2696b828b3485fb2ea8cf74a7f5bf
--- /dev/null
+++ b/src/main/java/neatlogic/module/cmdb/workerdispatcher/handler/CmdbDispatcher.java
@@ -0,0 +1,451 @@
+package neatlogic.module.cmdb.workerdispatcher.handler;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import neatlogic.framework.cmdb.dto.ci.AttrVo;
+import neatlogic.framework.cmdb.dto.ci.CiVo;
+import neatlogic.framework.cmdb.dto.cientity.AttrEntityVo;
+import neatlogic.framework.cmdb.dto.cientity.AttrFilterVo;
+import neatlogic.framework.cmdb.dto.cientity.CiEntityVo;
+import neatlogic.framework.cmdb.dto.customview.CustomViewAttrVo;
+import neatlogic.framework.cmdb.dto.customview.CustomViewConditionFilterVo;
+import neatlogic.framework.cmdb.dto.customview.CustomViewConditionVo;
+import neatlogic.framework.cmdb.dto.customview.CustomViewVo;
+import neatlogic.framework.cmdb.enums.SearchExpression;
+import neatlogic.framework.common.constvalue.GroupSearch;
+import neatlogic.framework.crossover.CrossoverServiceFactory;
+import neatlogic.framework.dao.mapper.RoleMapper;
+import neatlogic.framework.dao.mapper.TeamMapper;
+import neatlogic.framework.dao.mapper.UserMapper;
+import neatlogic.framework.dto.RoleVo;
+import neatlogic.framework.dto.TeamVo;
+import neatlogic.framework.dto.UserVo;
+import neatlogic.framework.form.constvalue.FormHandler;
+import neatlogic.framework.form.service.IFormCrossoverService;
+import neatlogic.framework.process.constvalue.ProcessUserType;
+import neatlogic.framework.process.dao.mapper.ProcessTaskMapper;
+import neatlogic.framework.process.dao.mapper.SelectContentByHashMapper;
+import neatlogic.framework.process.dto.ProcessTaskFormAttributeDataVo;
+import neatlogic.framework.process.dto.ProcessTaskFormVo;
+import neatlogic.framework.process.dto.ProcessTaskStepVo;
+import neatlogic.framework.process.dto.ProcessTaskStepWorkerVo;
+import neatlogic.framework.process.exception.processtask.ProcessTaskException;
+import neatlogic.framework.process.workerdispatcher.core.WorkerDispatcherBase;
+import neatlogic.module.cmdb.dao.mapper.ci.AttrMapper;
+import neatlogic.module.cmdb.dao.mapper.ci.CiMapper;
+import neatlogic.module.cmdb.dao.mapper.customview.CustomViewMapper;
+import neatlogic.module.cmdb.service.cientity.CiEntityService;
+import neatlogic.module.cmdb.service.customview.CustomViewDataService;
+import neatlogic.module.cmdb.workerdispatcher.exception.CmdbDispatcherDispatchFailedException;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@Component
+public class CmdbDispatcher extends WorkerDispatcherBase {
+
+    @Resource
+    private CiMapper ciMapper;
+
+    @Resource
+    private AttrMapper attrMapper;
+
+    @Resource
+    private CustomViewMapper customViewMapper;
+
+    @Resource
+    private ProcessTaskMapper processTaskMapper;
+
+    @Resource
+    private SelectContentByHashMapper selectContentByHashMapper;
+
+    @Resource
+    private CiEntityService ciEntityService;
+
+    @Resource
+    private CustomViewDataService customViewDataService;
+
+    @Resource
+    private UserMapper userMapper;
+
+    @Resource
+    private TeamMapper teamMapper;
+
+    @Resource
+    private RoleMapper roleMapper;
+
+    @Override
+    public String getName() {
+        return "nmcwh.cmdbdispatcher.getname";
+    }
+
+    @Override
+    public JSONArray getConfig() {
+        return new JSONArray();
+    }
+
+    @Override
+    public String getHelp() {
+        StringBuilder stringBuilder = new StringBuilder();
+        stringBuilder.append("数据类型：单选；默认选择配置项");
+        stringBuilder.append("\n");
+        stringBuilder.append("数据来源：");
+        stringBuilder.append("\n");
+        stringBuilder.append("【数据类型】为配置项时，此处的选项为所有配置项的名称");
+        stringBuilder.append("\n");
+        stringBuilder.append("【数据类型】为视图时，此处的选项为所有CMDB自定义视图的名称");
+        stringBuilder.append("\n");
+        stringBuilder.append("匹配映射：");
+        stringBuilder.append("\n");
+        stringBuilder.append("配置模型或视图的属性，等于表单某个属性，过滤数据；");
+        stringBuilder.append("\n");
+        stringBuilder.append("支持多组条件的配置；");
+        stringBuilder.append("\n");
+        stringBuilder.append("多组之间的关系为AND关系");
+        stringBuilder.append("\n");
+        stringBuilder.append("处理人：");
+        stringBuilder.append("\n");
+        stringBuilder.append("从配置模型或视图中，选择一个或多个字段，作为处理人；");
+        stringBuilder.append("\n");
+        stringBuilder.append(" 必填，支持多选");
+        stringBuilder.append("\n");
+        stringBuilder.append("需要考虑分组、角色");
+        stringBuilder.append("\n");
+        stringBuilder.append("优先级：");
+        stringBuilder.append("\n");
+        stringBuilder.append(" 优先级中的选项，即【处理人】的选中项。可通过拖拽排序。比如下图，运维人员A这个字段为空时，则向下找运维人员B，依次类推");
+        stringBuilder.append("\n");
+        return stringBuilder.toString();
+    }
+
+    @Override
+    protected List<ProcessTaskStepWorkerVo> myGetWorker(ProcessTaskStepVo processTaskStepVo, JSONObject configObj) throws ProcessTaskException {
+        List<ProcessTaskStepWorkerVo> workerList = new ArrayList<>();
+        JSONArray filterList = configObj.getJSONArray("filterList");
+        JSONArray priorityArray = configObj.getJSONArray("priorityList");
+        String type = configObj.getString("type");
+        if (Objects.equals(type, "ci")) {
+            Long ciId = configObj.getLong("ciId");
+            if (ciId == null) {
+                throw new CmdbDispatcherDispatchFailedException(ciId);
+            }
+            CiVo ci = ciMapper.getCiById(ciId);
+            if (ci == null) {
+                throw new CmdbDispatcherDispatchFailedException(ciId);
+            }
+            List<AttrVo> attrList = attrMapper.getAttrByCiId(ciId);
+            Map<Long, AttrVo> attrMap = attrList.stream().collect(Collectors.toMap(e -> e.getId(), e -> e));
+
+            CiEntityVo ciEntityConditionVo = new CiEntityVo();
+            ciEntityConditionVo.setCiId(ciId);
+            List<Long> priorityList = priorityArray.toJavaList(Long.class);
+            ciEntityConditionVo.setAttrIdList(priorityList);
+            ciEntityConditionVo.setRelIdList(new ArrayList<Long>() {{
+                this.add(0L);
+            }});
+            if (CollectionUtils.isNotEmpty(filterList)) {
+                Map<String, Object> formAttributeDataMap = formAttributeDataMap(processTaskStepVo.getProcessTaskId());
+                for (int i = 0; i < filterList.size(); i++) {
+                    JSONObject filterObj = filterList.getJSONObject(i);
+                    Long key = filterObj.getLong("key");
+                    if (key == null) {
+                        continue;
+                    }
+                    if (!attrMap.containsKey(key)) {
+                        continue;
+                    }
+                    String formAttributeUuid = filterObj.getString("formAttributeUuid");
+                    if (StringUtils.isBlank(formAttributeUuid)) {
+                        continue;
+                    }
+                    Object value = formAttributeDataMap.get(formAttributeUuid);
+                    if (value == null) {
+                        continue;
+                    }
+                    List<String> valueList = new ArrayList<>();
+                    if (value instanceof List) {
+                        List list = (List) value;
+                        for (Object e : list) {
+                            valueList.add(e.toString());
+                        }
+                    } else {
+                        valueList.add(value.toString());
+                    }
+                    AttrFilterVo filterVo = new AttrFilterVo();
+                    filterVo.setAttrId(key);
+                    filterVo.setExpression(SearchExpression.EQ.getExpression());
+                    filterVo.setValueList(valueList);
+                    ciEntityConditionVo.addAttrFilter(filterVo);
+                }
+            }
+            List<CiEntityVo> checkList = ciEntityService.searchCiEntity(ciEntityConditionVo);
+            if (CollectionUtils.isEmpty(checkList)) {
+                throw new CmdbDispatcherDispatchFailedException(ci, ciEntityConditionVo.getAttrFilterList());
+            }
+            if (checkList.size() > 1) {
+                throw new CmdbDispatcherDispatchFailedException(ci, ciEntityConditionVo.getAttrFilterList(), checkList.size());
+            }
+            CiEntityVo ciEntity = checkList.get(0);
+            for (Long attrId : priorityList) {
+                AttrVo attrVo = attrMap.get(attrId);
+                if (attrVo == null) {
+                    continue;
+                }
+                AttrEntityVo attrEntity = ciEntity.getAttrEntityByAttrId(attrId);
+                if (attrEntity == null) {
+                    continue;
+                }
+                JSONArray valueList = attrEntity.getValueList();
+                if (CollectionUtils.isEmpty(valueList)) {
+                    continue;
+                }
+                workerList = getWorkerList(processTaskStepVo, attrVo, valueList);
+                if (CollectionUtils.isNotEmpty(workerList)) {
+                    return workerList;
+                }
+            }
+            if (CollectionUtils.isEmpty(workerList)) {
+                throw new CmdbDispatcherDispatchFailedException(ciEntity);
+            }
+        } else if (Objects.equals(type, "customView")) {
+            Long customViewId = configObj.getLong("customViewId");
+            if (customViewId == null) {
+                throw new CmdbDispatcherDispatchFailedException(customViewId);
+            }
+            CustomViewVo customView = customViewMapper.getCustomViewById(customViewId);
+            if (customView == null) {
+                throw new CmdbDispatcherDispatchFailedException(customViewId);
+            }
+            CustomViewAttrVo customViewAttrVo = new CustomViewAttrVo(customViewId);
+            List<CustomViewAttrVo> attrList = customViewMapper.getCustomViewAttrByCustomViewId(customViewAttrVo);
+            Map<String, CustomViewAttrVo> attrMap = attrList.stream().collect(Collectors.toMap(e -> e.getUuid(), e -> e));
+            CustomViewConditionVo customViewConditionVo = new CustomViewConditionVo();
+            if (CollectionUtils.isNotEmpty(filterList)) {
+                Map<String, Object> formAttributeDataMap = formAttributeDataMap(processTaskStepVo.getProcessTaskId());
+                for (int i = 0; i < filterList.size(); i++) {
+                    JSONObject filterObj = filterList.getJSONObject(i);
+                    String key = filterObj.getString("key");
+                    if (StringUtils.isBlank(key)) {
+                        continue;
+                    }
+                    if (!attrMap.containsKey(key)) {
+                        continue;
+                    }
+                    String formAttributeUuid = filterObj.getString("formAttributeUuid");
+                    if (StringUtils.isBlank(formAttributeUuid)) {
+                        continue;
+                    }
+                    Object value = formAttributeDataMap.get(formAttributeUuid);
+                    if (value == null) {
+                        continue;
+                    }
+                    JSONArray valueList = new JSONArray();
+                    if (value instanceof List) {
+                        valueList.addAll((List) value);
+                    } else {
+                        valueList.add(value);
+                    }
+                    CustomViewConditionFilterVo filterVo = new CustomViewConditionFilterVo();
+                    filterVo.setAttrUuid(key);
+                    filterVo.setType("attr");
+                    filterVo.setExpression(SearchExpression.EQ.getExpression());
+                    filterVo.setValueList(valueList);
+                    customViewConditionVo.addAttrFilter(filterVo);
+                }
+            }
+            customViewConditionVo.setCustomViewId(customViewId);
+            List<Map<String, Object>> dataList = customViewDataService.searchCustomViewData(customViewConditionVo);
+            if (CollectionUtils.isEmpty(dataList)) {
+                throw new CmdbDispatcherDispatchFailedException(customView, customViewConditionVo.getAttrFilterList());
+            }
+            if (dataList.size() > 1) {
+                throw new CmdbDispatcherDispatchFailedException(customView, customViewConditionVo.getAttrFilterList(), dataList.size());
+            }
+            Map<String, Object> data = dataList.get(0);
+            List<String> priorityList = priorityArray.toJavaList(String.class);
+            for (String attrUuid : priorityList) {
+                CustomViewAttrVo customViewAttr = attrMap.get(attrUuid);
+                if (customViewAttr == null) {
+                    continue;
+                }
+                Object obj = data.get(attrUuid);
+                if (obj == null) {
+                    continue;
+                }
+                String str = obj.toString();
+                if (StringUtils.isBlank(str)) {
+                    continue;
+                }
+                String[] split = str.split(",");
+                JSONArray valueList = new JSONArray();
+                for (String value : split) {
+                    valueList.add(value);
+                }
+                AttrVo attrVo = customViewAttr.getAttrVo();
+                workerList = getWorkerList(processTaskStepVo, attrVo, valueList);
+                if (CollectionUtils.isNotEmpty(workerList)) {
+                    return workerList;
+                }
+            }
+            if (CollectionUtils.isEmpty(workerList)) {
+                throw new CmdbDispatcherDispatchFailedException(data);
+            }
+        }
+        return workerList;
+    }
+
+    private List<ProcessTaskStepWorkerVo> getWorkerList(ProcessTaskStepVo processTaskStepVo, AttrVo attrVo, JSONArray valueList) {
+        List<ProcessTaskStepWorkerVo> workerList = new ArrayList<>();
+        if (attrVo.getTargetCiId() != null) {
+            List<Long> idList = new ArrayList<>();
+            List<Long> longValueList = new ArrayList<>();
+            List<String> stringValueList = new ArrayList<>();
+            for (int i = 0; i < valueList.size(); i++) {
+                Object valueObj = valueList.get(i);
+                if (valueObj instanceof Long) {
+                    longValueList.add((Long) valueObj);
+                } else if (valueObj instanceof String) {
+                    String valueStr = valueObj.toString();
+                    try {
+                        Integer.valueOf(valueStr);
+                        stringValueList.add(valueStr);
+                    } catch (NumberFormatException e1) {
+                        try {
+                            longValueList.add(Long.valueOf(valueStr));
+                        } catch (NumberFormatException e2) {
+                            stringValueList.add(valueStr);
+                        }
+                    }
+                }
+            }
+            if (CollectionUtils.isNotEmpty(longValueList)) {
+                idList.addAll(longValueList);
+            }
+            if (CollectionUtils.isNotEmpty(stringValueList)) {
+                for (String name : stringValueList) {
+                    List<CiEntityVo> ciEntityList = ciEntityService.getCiEntityBaseInfoByName(attrVo.getTargetCiId(), name);
+                    idList.addAll(ciEntityList.stream().map(CiEntityVo::getId).collect(Collectors.toList()));
+                }
+            }
+            List<UserVo> userList = userMapper.getUserByIdList(idList);
+            if (CollectionUtils.isNotEmpty(userList)) {
+                for (UserVo user : userList) {
+                    ProcessTaskStepWorkerVo worker = new ProcessTaskStepWorkerVo(processTaskStepVo.getProcessTaskId(), processTaskStepVo.getId(), GroupSearch.USER.getValue(), user.getUuid(), ProcessUserType.MAJOR.getValue());
+                    workerList.add(worker);
+                }
+            } else {
+                List<TeamVo> teamList = teamMapper.getTeamByIdList(idList);
+                if (CollectionUtils.isNotEmpty(teamList)) {
+                    for (TeamVo team : teamList) {
+                        ProcessTaskStepWorkerVo worker = new ProcessTaskStepWorkerVo(processTaskStepVo.getProcessTaskId(), processTaskStepVo.getId(), GroupSearch.TEAM.getValue(), team.getUuid(), ProcessUserType.MAJOR.getValue());
+                        workerList.add(worker);
+                    }
+                } else {
+                    List<RoleVo> roleList = roleMapper.getRoleByIdList(idList);
+                    if (CollectionUtils.isNotEmpty(roleList)) {
+                        for (RoleVo role : roleList) {
+                            ProcessTaskStepWorkerVo worker = new ProcessTaskStepWorkerVo(processTaskStepVo.getProcessTaskId(), processTaskStepVo.getId(), GroupSearch.ROLE.getValue(), role.getUuid(), ProcessUserType.MAJOR.getValue());
+                            workerList.add(worker);
+                        }
+                    }
+                }
+            }
+        } else {
+            for (int i = 0; i < valueList.size(); i++) {
+                String name = valueList.getString(i);
+                UserVo userVo = userMapper.getUserByUserId(name);
+                if (userVo != null) {
+                    ProcessTaskStepWorkerVo worker = new ProcessTaskStepWorkerVo(processTaskStepVo.getProcessTaskId(), processTaskStepVo.getId(), GroupSearch.USER.getValue(), userVo.getUuid(), ProcessUserType.MAJOR.getValue());
+                    workerList.add(worker);
+                } else {
+                    List<String> userUuidList = userMapper.getUserUuidListByUserName(name);
+                    if (CollectionUtils.isNotEmpty(userUuidList)) {
+//                        List<UserVo> userList = userMapper.getUserByUserUuidList(userUuidList);
+                        for (String userUuid : userUuidList) {
+                            ProcessTaskStepWorkerVo worker = new ProcessTaskStepWorkerVo(processTaskStepVo.getProcessTaskId(), processTaskStepVo.getId(), GroupSearch.USER.getValue(), userUuid, ProcessUserType.MAJOR.getValue());
+                            workerList.add(worker);
+                        }
+                    } else {
+                        List<String> teamUuidList = teamMapper.getTeamUuidByName(name);
+                        if (CollectionUtils.isNotEmpty(teamUuidList)) {
+//                            List<TeamVo> teamList = teamMapper.getTeamByUuidList(teamUuidList);
+                            for (String teamUuid : teamUuidList) {
+                                ProcessTaskStepWorkerVo worker = new ProcessTaskStepWorkerVo(processTaskStepVo.getProcessTaskId(), processTaskStepVo.getId(), GroupSearch.TEAM.getValue(), teamUuid, ProcessUserType.MAJOR.getValue());
+                                workerList.add(worker);
+                            }
+                        } else {
+                            List<String> roleUuidList = roleMapper.getRoleUuidByName(name);
+                            if (CollectionUtils.isNotEmpty(roleUuidList)) {
+//                                List<RoleVo> roleList = roleMapper.getRoleByUuidList(roleUuidList);
+                                for (String roleUuid : roleUuidList) {
+                                    ProcessTaskStepWorkerVo worker = new ProcessTaskStepWorkerVo(processTaskStepVo.getProcessTaskId(), processTaskStepVo.getId(), GroupSearch.ROLE.getValue(), roleUuid, ProcessUserType.MAJOR.getValue());
+                                    workerList.add(worker);
+                                }
+                            }
+                        }
+                    }
+                }
+            }
+        }
+        return workerList;
+    }
+
+    private Map<String, Object> formAttributeDataMap(Long processTaskId) {
+        Map<String, Object> formAttributeDataMap = new HashMap<>();
+        String formConfig = null;
+        // 如果工单有表单信息，则查询出表单配置及数据
+        ProcessTaskFormVo processTaskFormVo = processTaskMapper.getProcessTaskFormByProcessTaskId(processTaskId);
+        if (processTaskFormVo != null) {
+            formConfig = selectContentByHashMapper.getProcessTaskFromContentByHash(processTaskFormVo.getFormContentHash());
+            List<ProcessTaskFormAttributeDataVo> processTaskFormAttributeDataList = processTaskMapper.getProcessTaskStepFormAttributeDataByProcessTaskId(processTaskId);
+            if (CollectionUtils.isNotEmpty(processTaskFormAttributeDataList)) {
+                for (ProcessTaskFormAttributeDataVo attributeDataVo : processTaskFormAttributeDataList) {
+                    Object dataObj = formAttributeDataAdaptsToCmdb(attributeDataVo.getAttributeUuid(), attributeDataVo.getDataObj(), formConfig);
+                    if (dataObj == null) {
+                        continue;
+                    }
+                    formAttributeDataMap.put(attributeDataVo.getAttributeUuid(), dataObj);
+                }
+            }
+        }
+        return formAttributeDataMap;
+    }
+
+    /**
+     * 表单数据适配CMDB数据
+     * @param attributeUuid 表单属性uuid
+     * @param originalValue 表单属性值
+     * @param formConfig 表单配置信息
+     * @return
+     */
+    private Object formAttributeDataAdaptsToCmdb(String attributeUuid, Object originalValue, String formConfig) {
+        if (originalValue == null) {
+            return null;
+        }
+        IFormCrossoverService formCrossoverService = CrossoverServiceFactory.getApi(IFormCrossoverService.class);
+        String handler = formCrossoverService.getFormAttributeHandler(attributeUuid, formConfig);
+        if (Objects.equals(handler, FormHandler.FORMUPLOAD.getHandler())) {
+            JSONArray resultList = new JSONArray();
+            if (originalValue instanceof JSONArray) {
+                JSONArray dataArray = (JSONArray) originalValue;
+                for (int m = 0; m < dataArray.size(); m++) {
+                    JSONObject data = dataArray.getJSONObject(m);
+                    Long id = data.getLong("id");
+                    if (id != null) {
+                        resultList.add(id);
+                    }
+                }
+            }
+            return resultList;
+        } else if (Objects.equals(handler, FormHandler.FORMRADIO.getHandler())
+                || Objects.equals(handler, FormHandler.FORMCHECKBOX.getHandler())
+                || Objects.equals(handler, FormHandler.FORMSELECT.getHandler())) {
+            return formCrossoverService.getFormSelectAttributeValueByOriginalValue(originalValue);
+        }
+        return originalValue;
+    }
+}