tengda/websrc/com/kingdee/eas/custom/webbeisen/thirdpartysystemsyn/utils/AssistSynchronizingUtils.java

package com.kingdee.eas.custom.webbeisen.thirdpartysystemsyn.utils;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.kingdee.bos.BOSException;
import com.kingdee.bos.BOSObjectFactory;
import com.kingdee.bos.Context;
import com.kingdee.bos.dao.IObjectCollection;
import com.kingdee.bos.dao.IObjectValue;
import com.kingdee.bos.dao.query.IQueryExecutor;
import com.kingdee.bos.dao.query.QueryExecutorFactory;
import com.kingdee.bos.metadata.MetaDataPK;
import com.kingdee.bos.metadata.data.SortType;
import com.kingdee.bos.metadata.entity.*;
import com.kingdee.bos.metadata.query.util.CompareType;
import com.kingdee.bos.sql.ParserException;
import com.kingdee.bos.util.BOSObjectType;
import com.kingdee.bos.util.BOSUuid;
import com.kingdee.eas.common.EASBizException;
import com.kingdee.eas.custom.thirdpartysystemsyn.config.viewconfig.*;
import com.kingdee.eas.custom.thirdpartysystemsyn.enumerationset.DataTypeEnum;
import com.kingdee.eas.custom.thirdpartysystemsyn.enumerationset.EntityAttributeEnum;
import com.kingdee.eas.framework.CoreBaseCollection;
import com.kingdee.eas.framework.CoreBaseInfo;
import com.kingdee.eas.framework.ICoreBase;
import com.kingdee.shr.attachment.SHRAttachmentExtCollection;
import com.kingdee.shr.attachment.SHRAttachmentExtFactory;
import com.kingdee.shr.attachment.SHRAttachmentExtInfo;
import com.kingdee.shr.base.syssetting.MSFServiceFacadeFactory;
import com.kingdee.shr.base.syssetting.context.SHRContext;
import com.kingdee.shr.base.syssetting.exception.SHRWebException;
import com.kingdee.shr.base.syssetting.exception.ShrWebBizException;
import com.kingdee.shr.base.syssetting.model.VirtualDataFetcher;
import com.kingdee.shr.base.syssetting.util.MetaDataUtil;
import com.kingdee.util.Uuid;
import com.kingdee.util.enums.EnumUtils;
import org.apache.log4j.Logger;

import java.util.*;

public class AssistSynchronizingUtils {
    // 日志记录器，用于记录系统操作日志
    private static final Logger logger = Logger.getLogger("com.kingdee.eas.custom.webbeisen.thirdpartysystemsyn.utils.AssistSynchronizingUtils");

    /**
     * 重写父类方法，根据配置编号和过滤条件获取数据
     * 该方法主要执行以下步骤：
     * 1. 解析过滤条件JSON字符串
     * 2. 获取头部配置信息
     * 3. 构建查询条件并执行查询
     * 4. 处理查询结果并转换为JSON格式
     * 5. 处理分录数据（如果存在）
     *
     * @param ctx 上下文对象
     * @param configNumber 配置编号，用于定位具体的同步配置
     * @param filterInfos 过滤条件信息，JSON格式字符串
     * @return 处理后的结果数据，JSON格式字符串
     * @throws BOSException 当操作过程中发生业务异常时抛出
     */
    public JSONArray getData(Context ctx, String configNumber, String filterInfos) throws BOSException {
        // 记录方法调用日志，包含入参信息
        logger.info("Starting getData method with configNumber: " + configNumber + ", filterInfos: " + filterInfos);

        // 用于记录处理统计信息
        int totalRecords = 0;
        int successRecords = 0;
        int failedRecords = 0;
        JSONArray errorDetails = new JSONArray();

        // 解析过滤条件JSON字符串为JSONObject
        JSONObject jsonObject = JSONObject.parseObject(filterInfos);
        JSONArray resultArray = new JSONArray(); // 创建结果数组

        try {
            // 获取头部配置信息
            logger.debug("Getting head configuration for configNumber: " + configNumber);
            EntityViewInfo headEntry = createEntityViewInfo(configNumber, EntityAttributeEnum.HEAD_VALUE);
            ConfigInfoEntryCollection entries = ConfigInfoEntryFactory.getLocalInstance(ctx).getConfigInfoEntryCollection(headEntry);

            // 验证条目信息是否唯一
            if (entries.size() != 1) {
                String errorMsg = "头部信息配置异常，期望1条配置但找到" + entries.size() + "条";
                logger.error(errorMsg);
                throw new RuntimeException(errorMsg); // 抛出配置异常
            }

            // 获取唯一的条目信息
            ConfigInfoEntryInfo configInfoEntryInfo = entries.get(0);
            String entityName = configInfoEntryInfo.getEntityName(); // 获取实体名称
            logger.debug("Found entity: " + entityName + " for configNumber: " + configNumber);

            // 创建实体查询视图并设置查询条件
            EntityViewInfo headEntityViewInfo = new EntityViewInfo();
            String filterExpr = jsonObject.getString(entityName); // 获取实体对应的过滤条件
            if (filterExpr != null && !filterExpr.trim().isEmpty()) { // 检查过滤条件是否非空
                headEntityViewInfo.setFilter(filterExpr); // 设置过滤条件
                logger.debug("Set filter for entity " + entityName + ": " + filterExpr);
            }

            // 设置查询字段
            ConfigInfoEntryFieldCollection fields = configInfoEntryInfo.getFields();
            SelectorItemCollection selectorItem = getSelectorItem(fields); // 获取选择器项目
            headEntityViewInfo.setSelector(selectorItem); // 设置选择器
            logger.debug("Set selector with " + selectorItem.size() + " fields");

            // 设置排序
            String sortField = configInfoEntryInfo.getSortField(); // 获取排序字段
            SorterItemCollection sorterItemCollection = sorterProcessing(sortField); // 处理排序字段
            if (sorterItemCollection != null) {
                headEntityViewInfo.setSorter(sorterItemCollection); // 设置排序器
                logger.debug("Set sorter with " + sorterItemCollection.size() + " fields");
            }

            // 执行查询获取数据集合
            boolean isQuery = configInfoEntryInfo.isIsQuery(); // 判断是否为查询类型
            CoreBaseCollection collection; // 声明数据集合
            if (isQuery) {
                logger.debug("Initializing collection using query for entity: " + entityName);
                collection = this.initCollection(entityName, headEntityViewInfo, ctx); // 初始化集合
            } else {
                String bosType = configInfoEntryInfo.getBosType(); // 获取BOS类型
                BOSObjectType bosObjectType = BOSObjectType.create(bosType); // 创建BOS对象类型
                logger.debug("Getting collection using BOS object type: " + bosType);
                // 根据BOS类型创建对应的业务对象实例
                ICoreBase bosObject = (ICoreBase) BOSObjectFactory.createBOSObject(ctx, bosObjectType);
                collection = bosObject.getCollection(headEntityViewInfo); // 获取数据集合
            }

            totalRecords = collection.size();
            logger.info("Retrieved " + totalRecords + " records for processing");

            // 处理查询结果
            processCollectionData(ctx, configNumber, jsonObject, resultArray, collection,
                    configInfoEntryInfo, fields, errorDetails);

            successRecords = resultArray.size();
            failedRecords = totalRecords - successRecords;

            logger.info("Data processing completed. Success: " + successRecords +
                    ", Failed: " + failedRecords + ", Total: " + totalRecords);

        } catch (Exception e) {
            e.printStackTrace();
            String errorMsg = "Error occurred while getting data for configNumber: " + configNumber;
            logger.error(errorMsg, e);

            // 创建错误详情记录
            JSONObject errorDetail = new JSONObject();
            errorDetail.put("configNumber", configNumber);
            errorDetail.put("errorType", "MAIN_PROCESS_ERROR");
            errorDetail.put("errorMessage", e.getMessage());
            errorDetail.put("stackTrace", Arrays.toString(e.getStackTrace()));
            errorDetails.add(errorDetail);

            failedRecords = totalRecords; // 所有记录都标记为失败
            successRecords = 0;

            throw new BOSException("数据获取失败: " + e.getMessage(), e); // 抛出业务异常
        } finally {
            // 记录最终处理结果统计
            JSONObject processSummary = new JSONObject();
            processSummary.put("configNumber", configNumber);
            processSummary.put("totalRecords", totalRecords);
            processSummary.put("successRecords", successRecords);
            processSummary.put("failedRecords", failedRecords);
            processSummary.put("errorDetails", errorDetails);

            logger.info("Process summary: " + processSummary.toJSONString());
        }

        logger.info("Successfully retrieved data, result size: " + resultArray.size());
        return resultArray;
    }


    public void saveData(Context ctx, String configNumber, String controllerBeanEx) throws BOSException {
        EntityViewInfo headEntry = createEntityViewInfo(configNumber, EntityAttributeEnum.HEAD_VALUE);
        ConfigInfoEntryCollection entries = ConfigInfoEntryFactory.getLocalInstance(ctx).getConfigInfoEntryCollection(headEntry);

        // 验证条目信息是否唯一
        if (entries.size() != 1) {
            String errorMsg = "头部信息配置异常，期望1条配置但找到" + entries.size() + "条";
            logger.error(errorMsg);
            throw new RuntimeException(errorMsg); // 抛出配置异常
        }

        // 获取唯一的条目信息
        ConfigInfoEntryInfo configInfoEntryInfo = entries.get(0);
        String entityName = configInfoEntryInfo.getEntityName(); // 获取实体名称
        logger.debug("Found entity: " + entityName + " for configNumber: " + configNumber);
        ConfigInfoInfo parent = configInfoEntryInfo.getParent();
        //osf服务名
        String osfName = parent.getOsfName();
        String osfParam = parent.getOsfParam();
        Object o = null;
        try {
            o = MSFServiceFacadeFactory.getLocalInstance(ctx).processService(osfName, this.getOSFParam(osfParam));

        } catch (EASBizException e) {
            throw new RuntimeException(e);
        }
        JSONArray osfReturnData = JSONArray.parseArray(o.toString());
        for (int i = 0; i < osfReturnData.size(); i++) {
            JSONObject osfReturnDataEntry = osfReturnData.getJSONObject(i);
            //处理头部信息
            boolean isCreateData = configInfoEntryInfo.isIsCreateData();//是否创建数据

            String thirdUniqueValue = configInfoEntryInfo.getThirdUniqueValue();//第三方唯一值
            String hrUniqueValue = configInfoEntryInfo.getHrUniqueValue();//hr唯一值
            String bosType = configInfoEntryInfo.getBosType();
            Class objectValueClass1 = null;
            try {
                objectValueClass1 = MetaDataUtil.getObjectValueClass(entityName);
                // 创建对应的实体对象
                CoreBaseInfo coreBaseInfo = (CoreBaseInfo) MetaDataUtil.newInstance(objectValueClass1, entityName);
                if (!isCreateData){
                    String value = getThirdUniqueValue(osfReturnDataEntry, thirdUniqueValue);
                    if (value!=null){
                        CoreBaseInfo coreBaseInfo1 = findCoreBaseInfo(ctx, coreBaseInfo.getBOSType(), value, hrUniqueValue);
                        if (coreBaseInfo1!=null){
                            coreBaseInfo = coreBaseInfo1;
                        }
                    }
                }
            } catch (ShrWebBizException e) {
                throw new RuntimeException(e);
            }
        }
    }
    public String getThirdUniqueValue(JSONObject jsonObject,String thirdUniqueValue){
        String[] split = thirdUniqueValue.split("\\.");
        Object value = null;
        for (int i = 0; i < split.length; i++) {
            String s = split[i];
            value = jsonObject.get(s);
            if (value instanceof JSONArray){
                JSONArray jsonArray = jsonObject.getJSONArray(s);
                value = jsonArray.get(0);
            }
        }
        return value==null?null:value.toString();
    }


    public CoreBaseInfo findCoreBaseInfo(Context ctx,BOSObjectType bosObjectType,
                                         String thirdUniqueValue,
                                         String hrUniqueValue) throws BOSException {

        ICoreBase bosObject =  (ICoreBase) (BOSObjectFactory.createBOSObject(ctx,bosObjectType));
        CoreBaseCollection collection = bosObject.getCollection("where " + hrUniqueValue + " = '" + thirdUniqueValue + "' ");
        if (collection.size()>1){
            throw new RuntimeException("");
        } else if (collection.size()==0) {
            return null;
        }else {
            return collection.get(0);
        }
    }

    public Map<String,Object> getOSFParam(String jsonData){
        if (jsonData!=null&&!jsonData.equals("")){
            JSONObject param = JSONObject.parseObject(jsonData);
            Set<String> strings = param.keySet();
            Iterator<String> iterator = strings.iterator();
            Map<String,Object> map = new HashMap<String,Object>();
            while (iterator.hasNext()){
                String next = iterator.next();
                map.put(next,param.get(next));
            }
            return map;
        }else {
            return null;
        }
    }

    /**
     * 处理查询结果集合数据
     * 遍历集合中的每个CoreBaseInfo对象，将其转换为JSON格式，并处理相关的分录数据
     *
     * @param ctx 上下文对象
     * @param configNumber 配置编号
     * @param jsonObject 过滤条件JSON对象
     * @param resultArray 结果数组
     * @param collection 查询结果集合
     * @param configInfoEntryInfo 配置条目信息
     * @param fields 字段配置集合
     * @param errorDetails 错误详情数组，用于记录处理过程中的错误
     * @throws BOSException 业务异常
     * @throws ClassNotFoundException 类未找到异常
     * @throws ParserException 解析异常
     * @throws SHRWebException SHR Web异常
     */
    public void processCollectionData(Context ctx, String configNumber, JSONObject jsonObject,
                                      JSONArray resultArray, CoreBaseCollection collection,
                                      ConfigInfoEntryInfo configInfoEntryInfo,
                                      ConfigInfoEntryFieldCollection fields,
                                      JSONArray errorDetails)
            throws BOSException, ClassNotFoundException, ParserException, SHRWebException {
        for (int i = 0; i < collection.size(); i++) { // 遍历集合中的每个元素
            String recordId = "unknown";
            try {
                CoreBaseInfo coreBaseInfo = collection.get(i); // 获取当前元素
                recordId = coreBaseInfo.getId() != null ? coreBaseInfo.getId().toString() : "unknown";
                logger.debug("Processing record " + (i+1) + "/" + collection.size() + ", ID: " + recordId);
                JSONObject resultData = new JSONObject(); // 创建结果数据对象
                JSONObject mainData = new JSONObject(); // 创建主数据对象
                // 处理单条数据，转换为JSON格式
                dataProcessing(mainData, coreBaseInfo, fields, recordId, ctx);
                String name = configInfoEntryInfo.getName(); // 获取配置名称
                resultData.put(name, mainData); // 将主数据添加到结果数据
                // 处理分录数据
                processEntryData(ctx, configNumber, jsonObject, resultData, coreBaseInfo, recordId, errorDetails);
                resultArray.add(resultData); // 将结果数据添加到结果数组
                logger.debug("Successfully processed record ID: " + recordId);
            } catch (Exception e) {
                e.printStackTrace();
                String errorMsg = "Error processing record " + (i+1) + "/" + collection.size() + ", ID: " + recordId;
                logger.error(errorMsg, e);
                // 创建错误详情记录
                JSONObject errorDetail = new JSONObject();
                errorDetail.put("configNumber", configNumber);
                errorDetail.put("recordId", recordId);
                errorDetail.put("recordIndex", i);
                errorDetail.put("errorType", "RECORD_PROCESSING_ERROR");
                errorDetail.put("errorMessage", e.getMessage());
                errorDetail.put("stackTrace", Arrays.toString(e.getStackTrace()));
                errorDetails.add(errorDetail);
                // 继续处理下一条记录
                continue;
            }
        }
    }

    /**
     * 处理分录数据
     * 获取配置中的分录信息，根据关联字段查询相关的分录数据，并将其转换为JSON格式
     *
     * @param ctx 上下文对象
     * @param configNumber 配置编号
     * @param jsonObject 过滤条件JSON对象
     * @param resultData 结果数据对象
     * @param coreBaseInfo 核心基础信息对象
     * @param recordId 当前处理的主记录ID
     * @param errorDetails 错误详情数组，用于记录处理过程中的错误
     * @throws BOSException 业务异常
     * @throws ClassNotFoundException 类未找到异常
     * @throws ParserException 解析异常
     * @throws SHRWebException SHR Web异常
     */
    public void processEntryData(Context ctx, String configNumber, JSONObject jsonObject,
                                 JSONObject resultData, CoreBaseInfo coreBaseInfo,
                                 String recordId, JSONArray errorDetails)
            throws BOSException, ClassNotFoundException, ParserException, SHRWebException {
        try {
            // 获取分录为 boy类型的配置
            EntityViewInfo boyEntry = createEntityViewInfo(configNumber, EntityAttributeEnum.BOY_VALUE);
            ConfigInfoEntryCollection entryCollection = ConfigInfoEntryFactory.getLocalInstance(ctx).getConfigInfoEntryCollection(boyEntry);

            for (int j = 0; j < entryCollection.size(); j++) { // 遍历分录配置集合
                ConfigInfoEntryInfo configInfoEntryInfo1 = entryCollection.get(j); // 获取当前分录配置
                String boyEntityName = configInfoEntryInfo1.getEntityName(); // 获取分录实体名称
                ConfigInfoEntryFieldCollection boyFields = configInfoEntryInfo1.getFields(); // 获取分录字段配置
                logger.debug("Processing entry data for entity: " + boyEntityName + ", main record ID: " + recordId);
                // 创建分录查询视图
                EntityViewInfo boyEntityViewInfo = new EntityViewInfo();
                String boyFilterExpr = jsonObject.getString(boyEntityName); // 获取分录过滤条件
                // 设置关联字段过滤条件
                String crelatedField = configInfoEntryInfo1.getCrelatedField(); // 获取关联字段
                FilterInfo filter = new FilterInfo(); // 创建过滤器
                String id = coreBaseInfo.getId().toString(); // 获取主数据ID
                filter.getFilterItems().add(new FilterItemInfo(crelatedField, id, CompareType.EQUALS)); // 添加关联字段过滤条件
                if (boyFilterExpr != null && !boyFilterExpr.trim().isEmpty()) { // 检查分录过滤条件是否非空
                    filter.getFilterItems().add(new FilterItemInfo(boyFilterExpr)); // 添加分录过滤条件
                }
                boyEntityViewInfo.setFilter(filter); // 设置过滤器
                // 设置查询字段
                SelectorItemCollection boySelectorItem = getSelectorItem(boyFields); // 获取分录选择器
                boyEntityViewInfo.setSelector(boySelectorItem); // 设置选择器
                // 执行查询获取分录数据
                boolean isQuery1 = configInfoEntryInfo1.isIsQuery(); // 判断是否为查询类型
                CoreBaseCollection boyCollection; // 声明分录数据集合
                if (isQuery1) {
                    boyCollection = this.initCollection(boyEntityName, boyEntityViewInfo, ctx); // 初始化分录集合
                } else {
                    String boyDosType = configInfoEntryInfo1.getBosType(); // 获取分录BOS类型
                    BOSObjectType boyBosObjectType = BOSObjectType.create(boyDosType); // 创建BOS对象类型
                    ICoreBase boyBosObject = (ICoreBase) BOSObjectFactory.createBOSObject(ctx, boyBosObjectType); // 创建业务对象
                    boyCollection = boyBosObject.getCollection(boyEntityViewInfo); // 获取分录数据集合
                }
                logger.debug("Retrieved " + boyCollection.size() + " entry records for entity: " +
                        boyEntityName + ", main record ID: " + recordId);
                // 处理分录数据
                JSONArray entryDataArray = new JSONArray(); // 创建分录数据数组
                for (int k = 0; k < boyCollection.size(); k++) { // 遍历分录数据集合
                    try {
                        CoreBaseInfo coreBaseInfo1 = boyCollection.get(k); // 获取当前分录数据
                        String entryRecordId = coreBaseInfo1.getId() != null ? coreBaseInfo1.getId().toString() : "unknown";

                        JSONObject entryData = new JSONObject(); // 创建分录数据对象
                        dataProcessing(entryData, coreBaseInfo1, boyFields, entryRecordId, ctx); // 处理分录数据
                        entryDataArray.add(entryData); // 将分录数据添加到数组

                        logger.debug("Processed entry record " + (k+1) + "/" + boyCollection.size() +
                                ", ID: " + entryRecordId + " for main record ID: " + recordId);
                    } catch (Exception e) {
                        e.printStackTrace();
                        String errorMsg = "Error processing entry record " + (k+1) + "/" + boyCollection.size() +
                                " for main record ID: " + recordId;
                        logger.error(errorMsg, e);

                        // 创建错误详情记录
                        JSONObject errorDetail = new JSONObject();
                        errorDetail.put("configNumber", configNumber);
                        errorDetail.put("mainRecordId", recordId);
                        errorDetail.put("entryEntity", boyEntityName);
                        errorDetail.put("entryIndex", k);
                        errorDetail.put("errorType", "ENTRY_RECORD_PROCESSING_ERROR");
                        errorDetail.put("errorMessage", e.getMessage());
                        errorDetail.put("stackTrace", Arrays.toString(e.getStackTrace()));
                        errorDetails.add(errorDetail);
                        // 继续处理下一条分录记录
                        continue;
                    }
                }
                String name1 = configInfoEntryInfo1.getName(); // 获取分录配置名称
                resultData.put(name1, entryDataArray); // 将分录数据添加到结果数据
                logger.debug("Completed processing entry data for entity: " + boyEntityName +
                        ", main record ID: " + recordId + ", records: " + entryDataArray.size());
            }
        } catch (Exception e) {
            e.printStackTrace();
            String errorMsg = "Error processing entry data for main record ID: " + recordId;
            logger.error(errorMsg, e);
            // 创建错误详情记录
            JSONObject errorDetail = new JSONObject();
            errorDetail.put("configNumber", configNumber);
            errorDetail.put("mainRecordId", recordId);
            errorDetail.put("errorType", "ENTRY_PROCESSING_ERROR");
            errorDetail.put("errorMessage", e.getMessage());
            errorDetail.put("stackTrace", Arrays.toString(e.getStackTrace()));
            errorDetails.add(errorDetail);
            // 抛出异常，由上层处理
            throw new RuntimeException(e);
        }
    }

    /**
     * 处理单条CoreBaseInfo数据，将其字段信息转换为JSONObject
     * 根据字段类型的不同，采用不同的处理方式：
     * 1. 枚举类型：获取枚举列表和当前值的别名
     * 2. 对象值类型：提取对象的名称和编号
     * 3. 对象集合类型：提取集合中每个对象的名称和编号
     * 4. 其他类型：直接使用字段值
     * 5. 最后处理附件信息
     *
     * @param jsonObject 用于存储处理后数据的JSON对象
     * @param coreBaseInfo 待处理的业务数据对象
     * @param fieldCollection 配置的字段集合，包含需要处理的字段信息
     * @param recordId 当前处理的记录ID，用于日志记录
     * @param context 上下文对象，用于获取附件信息
     * @throws ClassNotFoundException 当枚举类找不到时抛出
     */
    public void dataProcessing(JSONObject jsonObject, CoreBaseInfo coreBaseInfo,
                               ConfigInfoEntryFieldCollection fieldCollection, String recordId, Context context)
            throws ClassNotFoundException {
        for (int i = 0; i < fieldCollection.size(); i++) { // 遍历字段配置集合
            String fieldName = "unknown";

            try {
                ConfigInfoEntryFieldInfo configInfoEntryFieldInfo = fieldCollection.get(i); // 获取当前字段配置
                ConfigInfoEntryInfo parent = configInfoEntryFieldInfo.getParent1(); // 获取父配置信息
                fieldName = configInfoEntryFieldInfo.getFieldName(); // 获取字段名称
                Object fieldValue = coreBaseInfo.get(fieldName); // 获取字段值
                logger.debug("Processing field: " + fieldName + " for record ID: " + recordId);
                // 封装字段信息为JSON对象
                JSONObject fieldJson = createFieldJson(configInfoEntryFieldInfo, fieldValue);
                // 将字段JSON对象存入结果JSON中
                jsonObject.put(fieldName, fieldJson);
                logger.debug("Successfully processed field: " + fieldName + " for record ID: " + recordId);
            } catch (Exception e) {
                e.printStackTrace();
                String errorMsg = "Error processing field: " + fieldName + " for record ID: " + recordId;
                logger.error(errorMsg, e);
                // 创建错误字段标记
                JSONObject errorField = new JSONObject();
                errorField.put("fieldName", fieldName);
                errorField.put("error", true);
                errorField.put("errorMessage", e.getMessage());
                jsonObject.put(fieldName, errorField);
                // 继续处理下一个字段
                continue;
            }
        }
        // 处理附件信息
        String id = coreBaseInfo.getId().toString();
        fileProcessor(id, jsonObject, context);
    }

    /**
     * 处理业务对象的附件信息
     * 根据业务对象ID查询关联的附件信息，并将附件详情添加到结果JSON对象中
     * 该方法通常在dataProcessing方法的最后调用，用于补充附件数据
     *
     * 处理流程：
     * 1. 根据业务ID查询关联的附件信息
     * 2. 提取附件名称和ID等关键信息
     * 3. 将附件信息组织成JSON格式并添加到结果集中
     * 4. 异常情况下记录错误日志并添加错误标记
     *
     * @param id 业务对象ID，用于查询关联的附件
     * @param jsonObject 结果数据集，附件信息将添加到该对象的"file"字段中
     * @param context 上下文对象，用于获取数据库连接和执行环境
     */
    public void fileProcessor(String id, JSONObject jsonObject, Context context) {
        JSONArray jsonArray = new JSONArray();
        try {
            JSONObject file = new JSONObject();
            // 查询与业务对象ID关联的所有附件信息
            SHRAttachmentExtCollection shrAttachmentExtCollection = SHRAttachmentExtFactory
                    .getLocalInstance(context)
                    .getSHRAttachmentExtCollection("select *,attachment.* where boid = '" + id + "'");

            // 遍历所有附件，提取关键信息
            for (int i = 0; i < shrAttachmentExtCollection.size(); i++) {
                SHRAttachmentExtInfo shrAttachmentExtInfo = shrAttachmentExtCollection.get(i);
                file.put("name", shrAttachmentExtInfo.getName()); // 附件名称
                file.put("id", shrAttachmentExtInfo.getAttachment().getId().toString()); // 附件ID
                jsonArray.add(file);
            }

            // 将附件信息数组添加到结果集
            jsonObject.put("file", jsonArray);
        } catch (BOSException e) {
            e.printStackTrace();
            // 记录附件处理错误日志
            String errorMsg = "Error processing file for business object ID: " + id;
            logger.error(errorMsg, e);

            // 创建错误字段标记，便于前端识别和处理
            JSONObject errorField = new JSONObject();
            errorField.put("field", "file");
            errorField.put("error", true);
            errorField.put("errorMessage", e.getMessage());
            jsonObject.put("file", errorField);
        }
    }

    /**
     * 创建字段JSON对象
     * 包含字段的基本信息（名称、别名、第三方字段名）和类型信息，以及根据类型处理后的字段值
     *
     * @param configInfoEntryFieldInfo 配置信息条目字段信息
     * @param fieldValue 字段值
     * @return 字段JSON对象
     * @throws ClassNotFoundException 当枚举类找不到时抛出
     */
    public JSONObject createFieldJson(ConfigInfoEntryFieldInfo configInfoEntryFieldInfo, Object fieldValue)
            throws ClassNotFoundException {
        JSONObject fieldJson = new JSONObject(); // 创建字段JSON对象
        String fieldName = configInfoEntryFieldInfo.getFieldName(); // 获取字段名称
        String fieldAlias = configInfoEntryFieldInfo.getFieldAlias(); // 获取字段别名
        DataTypeEnum fieldType = configInfoEntryFieldInfo.getFieldType(); // 获取字段类型
        String thirdField = configInfoEntryFieldInfo.getThirdField(); // 获取第三方字段名

        fieldJson.put("fieldName", fieldName); // 添加字段名称
        fieldJson.put("fieldAlias", fieldAlias); // 添加字段别名
        fieldJson.put("thirdField", thirdField); // 添加第三方字段名

        // 添加字段类型信息
        JSONObject fieldTypeJson = new JSONObject(); // 创建字段类型JSON对象
        fieldTypeJson.put("alias", fieldType.getAlias()); // 添加类型别名
        fieldTypeJson.put("name", fieldType.getName()); // 添加类型名称
        fieldTypeJson.put("value", fieldType.getValue()); // 添加类型值
        fieldJson.put("fieldType", fieldTypeJson); // 添加字段类型信息

        // 根据字段类型处理字段值
        processFieldValueByType(configInfoEntryFieldInfo, fieldValue, fieldJson);

        return fieldJson; // 返回字段JSON对象
    }

    /**
     * 根据字段类型处理字段值
     * 针对不同类型的数据采用不同的处理策略，确保数据格式符合预期
     *
     * @param configInfoEntryFieldInfo 配置信息条目字段信息
     * @param fieldValue 字段值
     * @param fieldJson 字段JSON对象
     * @throws ClassNotFoundException 当枚举类找不到时抛出
     */
    public void processFieldValueByType(ConfigInfoEntryFieldInfo configInfoEntryFieldInfo,
                                        Object fieldValue, JSONObject fieldJson)
            throws ClassNotFoundException {
        DataTypeEnum fieldType = configInfoEntryFieldInfo.getFieldType(); // 获取字段类型
        String typeAlias = fieldType.getAlias(); // 获取类型别名

        if ("Enum".equals(typeAlias)) { // 处理枚举类型
            processEnumFieldValue(configInfoEntryFieldInfo, fieldValue, fieldJson);
        } else if ("ObjectValue".equals(typeAlias)) { // 处理对象值类型
            processObjectValueFieldValue(fieldValue, fieldJson);
        } else if ("ObjectCollection".equals(typeAlias)) { // 处理对象集合类型
            processObjectCollectionFieldValue(fieldValue, fieldJson);
        } else { // 处理其他类型
            fieldJson.put("value", fieldValue); // 直接添加字段值
        }
    }

    /**
     * 处理枚举类型字段值
     * 获取枚举类的所有可能值列表，并将当前字段值转换为对应的枚举别名
     *
     * @param configInfoEntryFieldInfo 配置信息条目字段信息
     * @param fieldValue 字段值
     * @param fieldJson 字段JSON对象
     * @throws ClassNotFoundException 当枚举类找不到时抛出
     */
    public void processEnumFieldValue(ConfigInfoEntryFieldInfo configInfoEntryFieldInfo,
                                      Object fieldValue, JSONObject fieldJson)
            throws ClassNotFoundException {
        String source = configInfoEntryFieldInfo.getSource(); // 获取枚举源
        List<?> enumList = EnumUtils.getEnumList(source); // 获取枚举列表
        fieldJson.put("source", enumList); // 添加枚举源信息

        if (fieldValue != null) { // 检查字段值是否为空
            Integer value = (Integer) fieldValue; // 转换字段值为整数
            fieldJson.put("value", EnumUtils.getEnum(Class.forName(source), value).getAlias()); // 添加枚举值别名
        }
    }

    /**
     * 处理对象值类型字段值
     * 提取对象的名称和编号属性，构建简化的对象表示
     *
     * @param fieldValue 字段值
     * @param fieldJson 字段JSON对象
     */
    public void processObjectValueFieldValue(Object fieldValue, JSONObject fieldJson) {
        if (fieldValue instanceof CoreBaseInfo) { // 检查字段值是否为CoreBaseInfo类型
            CoreBaseInfo sourceCoreBaseInfo = (CoreBaseInfo) fieldValue; // 转换字段值
            JSONObject sourceJSONObject = new JSONObject(); // 创建源JSON对象
            sourceJSONObject.put("name", sourceCoreBaseInfo.get("name")); // 添加名称属性
            sourceJSONObject.put("number", sourceCoreBaseInfo.get("number")); // 添加编号属性
            fieldJson.put("value", sourceJSONObject); // 添加源对象信息
        }
    }

    /**
     * 处理对象集合类型字段值
     * 遍历集合中的每个对象，提取名称和编号属性，构建对象数组
     *
     * @param fieldValue 字段值
     * @param fieldJson 字段JSON对象
     */
    public void processObjectCollectionFieldValue(Object fieldValue, JSONObject fieldJson) {
        if (fieldValue instanceof IObjectCollection) { // 检查字段值是否为对象集合类型
            IObjectCollection collection = (IObjectCollection) fieldValue; // 转换字段值
            JSONArray jsonArray = new JSONArray(); // 创建JSON数组

            for (int j = 0; j < collection.size(); j++) { // 遍历集合
                Object object = collection.getObject(j); // 获取当前对象
                if (object instanceof CoreBaseInfo) { // 检查对象是否为CoreBaseInfo类型
                    CoreBaseInfo coreBaseInfo = (CoreBaseInfo) object; // 转换对象
                    JSONObject sourceJSONObject = new JSONObject(); // 创建源JSON对象
                    sourceJSONObject.put("name", coreBaseInfo.get("name")); // 添加名称属性
                    sourceJSONObject.put("number", coreBaseInfo.get("number")); // 添加编号属性
                    jsonArray.add(sourceJSONObject); // 将源对象添加到数组
                }
            }

            fieldJson.put("value", jsonArray); // 添加对象数组
        }
    }

    /**
     * 根据配置的字段集合构建查询选择器，指定查询时需要返回的字段
     * 对于对象值类型的字段，额外添加相关字段（名称、编号和所有字段）
     *
     * @param fields 配置的字段集合
     * @return 包含所有需要查询的字段的选择器集合
     */
    public SelectorItemCollection getSelectorItem(ConfigInfoEntryFieldCollection fields) {
        SelectorItemCollection selectorItemCollection = new SelectorItemCollection(); // 创建选择器集合

        for (int i = 0; i < fields.size(); i++) { // 遍历字段配置集合
            ConfigInfoEntryFieldInfo configInfoEntryFieldInfo = fields.get(i); // 获取当前字段配置
            String fieldName = configInfoEntryFieldInfo.getFieldName(); // 获取字段名称
            DataTypeEnum fieldType = configInfoEntryFieldInfo.getFieldType(); // 获取字段类型

            // 添加字段到选择器
            selectorItemCollection.add(fieldName); // 添加字段名称

            // 对于对象值类型，额外添加相关字段
            if ("ObjectValue".equals(fieldType.getAlias())) { // 检查是否为对象值类型
                selectorItemCollection.add(fieldName + ".name"); // 添加名称字段
                selectorItemCollection.add(fieldName + ".number"); // 添加编号字段
                selectorItemCollection.add(fieldName + ".*"); // 添加所有字段
            }
        }
        selectorItemCollection.add("id"); // 添加ID字段
        return selectorItemCollection; // 返回选择器集合
    }

    /**
     * 创建实体视图查询条件，用于查询配置信息
     * 根据配置编号和实体属性类型过滤配置信息，并指定需要返回的字段
     *
     * @param configNumber 配置编号，用于精确匹配配置
     * @param type 实体属性类型（如HEAD/ENTRY），用于过滤特定类型的配置
     * @return 构建好的实体查询视图
     */
    public EntityViewInfo createEntityViewInfo(String configNumber, String type) {
        EntityViewInfo entityViewInfo = new EntityViewInfo(); // 创建实体视图信息

        // 创建过滤条件
        FilterInfo filterInfo = new FilterInfo(); // 创建过滤器
        filterInfo.getFilterItems().add(new FilterItemInfo("parent.number", configNumber, CompareType.EQUALS)); // 添加父级编号过滤条件
        filterInfo.getFilterItems().add(new FilterItemInfo("entityAttribute", type, CompareType.EQUALS)); // 添加实体属性过滤条件
        entityViewInfo.setFilter(filterInfo); // 设置过滤器

        // 构建查询选择器，指定需要返回的字段
        SelectorItemCollection selectorItemCollection = new SelectorItemCollection(); // 创建选择器集合
        selectorItemCollection.add("parent.*"); // 添加父表所有字段
        selectorItemCollection.add("*"); // 添加条目表所有字段
        selectorItemCollection.add("Fields.*"); // 添加字段配置表所有字段
        entityViewInfo.setSelector(selectorItemCollection); // 设置选择器

        return entityViewInfo; // 返回实体视图信息
    }

    /**
     * 处理排序字段字符串，转换为排序器集合
     * 支持以下格式：
     * 1. "field1 ASC, field2 DESC" - 明确指定排序方向
     * 2. "field1, field2" - 默认使用升序
     *
     * @param sortField 排序字段字符串，格式如 "field1 ASC, field2 DESC"
     * @return 排序器集合，如果排序字段为空则返回null
     */
    public SorterItemCollection sorterProcessing(String sortField) {
        if (sortField == null || sortField.trim().isEmpty()) { // 检查排序字段是否为空
            return null; // 返回空值
        }

        SorterItemCollection sorterItemCollection = new SorterItemCollection(); // 创建排序器集合
        String[] sortFields = sortField.split(","); // 分割排序字段

        for (String field : sortFields) { // 遍历排序字段数组
            SorterItemInfo sorterItemInfo = new SorterItemInfo(); // 创建排序器信息
            String trimmedField = field.trim().toLowerCase(); // 去除空格并转换为小写

            if (trimmedField.contains("asc")) { // 检查是否包含升序关键字
                String propertyName = trimmedField.replace("asc", "").trim(); // 移除升序关键字
                sorterItemInfo.setPropertyName(propertyName); // 设置属性名称
                sorterItemInfo.setSortType(SortType.ASCEND); // 设置升序排序
            } else if (trimmedField.contains("desc")) { // 检查是否包含降序关键字
                String propertyName = trimmedField.replace("desc", "").trim(); // 移除降序关键字
                sorterItemInfo.setPropertyName(propertyName); // 设置属性名称
                sorterItemInfo.setSortType(SortType.DESCEND); // 设置降序排序
            } else { // 默认情况
                sorterItemInfo.setPropertyName(trimmedField); // 设置属性名称
                sorterItemInfo.setSortType(SortType.ASCEND); // 设置升序排序
            }
            sorterItemCollection.add(sorterItemInfo); // 添加排序器到集合
        }

        return sorterItemCollection; // 返回排序器集合
    }

    /**
     * 初始化集合数据
     * 通过业务接口获取指定实体的数据集合
     *
     * @param entityName 实体名称
     * @param entityViewInfo 实体视图信息
     * @param context 上下文对象
     * @return 核心基础集合
     * @throws SHRWebException SHR Web异常
     * @throws ParserException 解析异常
     * @throws BOSException 业务异常
     */
    public CoreBaseCollection initCollection(String entityName, EntityViewInfo entityViewInfo, Context context)
            throws SHRWebException, ParserException, BOSException {
        IQueryExecutor queryExecutor = this.getQueryExecutor(context, entityViewInfo, entityName); // 获取查询执行器
        Uuid uuid = queryExecutor.openQuery(); // 打开查询
        VirtualDataFetcher vdf = VirtualDataFetcher.createInstance(queryExecutor, uuid, 0, 1000); // 创建虚拟数据获取器
        List<Map<String, Object>> data = vdf.getData(); // 获取数据
        CoreBaseCollection collection = new CoreBaseCollection(); // 创建核心基础集合

        for (int i = 0; i < data.size(); i++) { // 遍历数据
            Map<String, Object> stringObjectMap = data.get(i); // 获取当前数据项
            String string = stringObjectMap.get("id").toString(); // 获取ID字符串
            BOSUuid read = BOSUuid.read(string); // 读取BOS UUID
            EntityObjectInfo entityObject = MetaDataUtil.getEntityObjectByBosType(read.getType()); // 获取实体对象信息
            String fullName = entityObject.getFullName(); // 获取完整类名
            Class<?> targetClass = MetaDataUtil.getObjectValueClass(fullName); // 获取目标类
            CoreBaseInfo coreBaseInfo = (CoreBaseInfo) MetaDataUtil.newInstance(targetClass, fullName); // 创建核心基础信息实例
            SelectorItemCollection selector = entityViewInfo.getSelector(); // 获取选择器

            for (int j = 0; j < selector.size(); j++) { // 遍历选择器
                SelectorItemInfo selectorItemInfo = selector.get(j); // 获取当前选择器项
                String propertyName = selectorItemInfo.getPropertyName(); // 获取属性名称
                coreBaseInfo.put(propertyName, stringObjectMap.get(propertyName)); // 设置属性值
            }
            collection.add(coreBaseInfo); // 添加到集合
        }
        return collection; // 返回集合
    }

    /**
     * 获取查询执行器
     * 创建并配置查询执行器，用于执行数据查询操作
     *
     * @param context 上下文对象
     * @param entityViewInfo 实体视图信息
     * @param query 查询字符串
     * @return 查询执行器
     * @throws SHRWebException SHR Web异常
     * @throws ShrWebBizException 业务异常
     * @throws BOSException 业务异常
     * @throws ParserException 解析异常
     */
    public IQueryExecutor getQueryExecutor(Context context,
                                           EntityViewInfo entityViewInfo,
                                           String query) throws SHRWebException, ShrWebBizException, BOSException, ParserException {
        IQueryExecutor exec = QueryExecutorFactory.getLocalInstance(context, MetaDataPK.create(query)); // 创建查询执行器
        exec.setObjectView(entityViewInfo); // 设置对象视图
        exec.option().isIgnoreOrder = true; // 设置忽略排序
        exec.option().isAutoIgnoreZero = true; // 设置自动忽略零值
        exec.option().isAutoTranslateBoolean = true; // 设置自动转换布尔值
        exec.option().isAutoTranslateEnum = true; // 设置自动转换枚举
        exec.option().isIgnorePermissionCheck = false; // 设置不忽略权限检查
        return exec; // 返回查询执行器
    }

    /**
     * 获取业务接口
     * 根据实体名称获取对应的业务接口实例
     *
     * @param entityName 实体名称
     * @return 核心基础接口
     * @throws SHRWebException SHR Web异常
     */
    public ICoreBase getBizInterface(String entityName) throws SHRWebException {
        if (entityName == null) { // 检查实体名称是否为空
            return null; // 返回空值
        }
        try {
            return MetaDataUtil.getBizInterface(SHRContext.getInstance().getContext(), entityName); // 获取业务接口
        } catch (BOSException e) {
            e.printStackTrace();
            throw new SHRWebException(e); // 抛出SHR Web异常
        }
    }

    /**
     * 给CoreBaseInfo类型对象设置属性值，支持级联属性
     * 支持"主属性.子属性"格式的属性路径，可以设置嵌套对象的属性值
     *
     * @param ctx 上下文对象，用于获取元数据信息
     * @param coreBaseInfo 要设置属性值的目标对象
     * @param name 属性名称，支持"主属性.子属性"格式的级联属性
     * @param value 要设置的属性值
     * @throws BOSException 当操作过程中发生业务异常时抛出
     */
    public void setCoreBaseInfo(Context ctx, IObjectValue coreBaseInfo, String name, Object value) throws BOSException {
        // 判断是否为级联属性
        if (name.contains(".")) { // 检查是否包含点号
            String[] split = name.split("\\."); // 分割属性名称
            Object parentValue = coreBaseInfo.get(split[0]); // 获取父属性值

            // 获取实体元数据信息
            EntityObjectInfo entityObject = MetaDataUtil.getEntityObjectByBosType(coreBaseInfo.getBOSType()); // 获取实体对象信息
            PropertyCollection properties = entityObject.getInheritedNoDuplicatedProperties(); // 获取属性集合
            PropertyInfo propertyInfo = (PropertyInfo) properties.getObject(split[0]); // 获取属性信息
            // 处理关联属性
            if (propertyInfo instanceof LinkPropertyInfo) { // 检查是否为链接属性
                LinkPropertyInfo linkProperty = (LinkPropertyInfo) propertyInfo; // 转换属性信息
                RelationshipInfo relationship = linkProperty.getRelationship(); // 获取关系信息
                String targetFullName = relationship.getSupplierObject().getFullName(); // 获取目标完整名称
                try {
                    Class<?> targetClass = MetaDataUtil.getObjectValueClass(targetFullName); // 获取目标类
                    CoreBaseInfo childObject = getOrCreateChildObject(parentValue, targetClass, targetFullName); // 获取或创建子对象
                    // 给子对象设置级联属性的子属性值
                    if (childObject != null) { // 检查子对象是否为空
                        childObject.put(split[1], value); // 设置子属性值
                    }
                } catch (ShrWebBizException e) {
                    e.printStackTrace();
                    throw new BOSException("获取目标类失败: " + e.getMessage(), e); // 抛出业务异常
                }
            }
        } else {
            // 非级联属性，直接设置值
            coreBaseInfo.put(name, value); // 设置属性值
        }
    }

    /**
     * 获取或创建子对象
     * 根据父属性值的类型（集合或单个对象），获取现有子对象或创建新的子对象
     *
     * @param parentValue 父属性值
     * @param targetClass 目标类
     * @param targetFullName 目标全名
     * @return 子对象
     */
    public CoreBaseInfo getOrCreateChildObject(Object parentValue, Class<?> targetClass, String targetFullName) {
        CoreBaseInfo childObject = null; // 初始化子对象

        if (parentValue instanceof IObjectCollection) { // 检查父属性值是否为对象集合
            IObjectCollection collection = (IObjectCollection) parentValue; // 转换父属性值
            if (collection.size() == 0) { // 检查集合是否为空
                childObject = (CoreBaseInfo) MetaDataUtil.newInstance(targetClass, targetFullName); // 创建新实例
                collection.addObject(childObject); // 添加到集合
            } else {
                childObject = (CoreBaseInfo) collection.getObject(0); // 获取第一个对象
            }
        } else if (parentValue instanceof CoreBaseInfo) { // 检查父属性值是否为CoreBaseInfo
            if (parentValue == null) { // 检查是否为空
                childObject = (CoreBaseInfo) MetaDataUtil.newInstance(targetClass, targetFullName); // 创建新实例
            } else {
                childObject = (CoreBaseInfo) parentValue; // 使用现有对象
            }
        }

        return childObject; // 返回子对象
    }

    /**
     * 主方法，用于本地测试
     * 可以在此添加测试代码，验证类的功能
     *
     * @param args 命令行参数
     */
    public static void main(String[] args) {
        // 测试代码可以在这里添加
        System.out.println("AssistSynchronizingFacadeControllerBean main method"); // 输出主方法信息
    }
}