@Test
public void testUpdate4() throws DAOException {
    SQLParameter parameter = new SQLParameter();
    parameter.addParam("btax_test5");
    parameter.addParam("0000026a-f46f-4eee-98a7-ff4d4114bcf3");
    parameter.addParam("2022-07-21 18:45:09.0");
    baseDAO.update("update ipuquotation_test set btax=? where ipuquotaionid=? and pubts=? ", parameter);
}

@Test
public void testSaveWithPk() throws DAOException {
    //IpuQuotation quotation = baseDAO.queryByPK(IpuQuotation.class, "2", new String[]{"ipuquotaionid", "btax"});
    IpuQuotation quotation1 = new IpuQuotation();
    quotation1.setBtax("btax_test");
    quotation1.setIpuquotaionid("5");
    baseDAO.insertWithPK(quotation1);
}

@Test
public void testSave() throws DAOException {
    IpuQuotation quotation = new IpuQuotation();
    quotation.setBtax("btax_test1");
    quotation.setIpuquotaionid("test_save12");
    baseDAO.insert(quotation);
}

@Test
public void testDelete() throws DAOException {
    final IpuQuotation ipuQuotation = new IpuQuotation();
    ipuQuotation.setIpuquotaionid("test2");
    final IpuQuotation ipuQuotation2 = new IpuQuotation();
    ipuQuotation2.setIpuquotaionid("test1");
    baseDAO.remove(new ArrayList<IpuQuotation>() {
        {
            add(ipuQuotation);
            add(ipuQuotation2);
        }
    });
}

@Test
public void testQueryAll() throws DAOException {
    IpuQuotation ipuQuotation = new IpuQuotation();
    List<IpuQuotation> quotation = baseDAO.queryAll(ipuQuotation);
    System.out.println(quotation.size());
}

@Test
public void testQueryByClause2() throws DAOException {
    SQLParameter parameter = new SQLParameter();
    parameter.addParam("btax_test");
    IpuQuotation ipuQuotation = new IpuQuotation();
    List<IpuQuotation> ipuQuotations =
            baseDAO.queryByClause(ipuQuotation, "select * from ipuquotation_test" + " where btax=?",
                    parameter);
    System.out.println(ipuQuotations.size());
}

@Test
public void testQueryByClause2() throws DAOException {
    SQLParameter parameter = new SQLParameter();
    parameter.addParam("btax_test");
    IpuQuotation ipuQuotation = new IpuQuotation();
    List<IpuQuotation> ipuQuotations =
            baseDAO.queryByClause(ipuQuotation, "select * from ipuquotation_test" + " where btax=?",
                    parameter);
    System.out.println(ipuQuotations.size());
}

@Test
public void testUpdate() throws DAOException {
    IpuQuotation ipuQuotation = new IpuQuotation();
    IpuQuotation quotation = baseDAO.queryByPK(ipuQuotation, "2");
    quotation.setBtax("btax_test4");
    baseDAO.update(quotation, new String[]{"btax"});
}

/**
 * 根据PK查询指定VO
 *
 * @param baseEntity
 * @param pk        主键
 */
@Override
public <T> T queryByPK(BaseEntity baseEntity, ID pk) throws DAOException {
    return queryByPK(baseEntity, pk, null);
}

/**
 * 根据主键返回指定列的VO对象
 */
@Override
public <T> T queryByPK(BaseEntity baseEntity, ID pk, String[] selectedFields) throws DAOException {
    try {
        manager = createPersistenceManager();
        return (T) manager.retrieveByPK(baseEntity, pk, selectedFields);
    } catch (Exception e) {
        logger.error(e.getMessage(), e);
        throw new DAOException(e.getMessage());
    }
}

/**
 * 根据主键查询
 */
public <T, ID> T retrieveByPK(BaseEntity baseEntity, ID pk, String[] selectedFields) throws Exception {
    if (pk == null) {
        throw new IllegalArgumentException("pk is null");
    }
    T result = null;
    boolean ormAttributeSign = BeanDataOperateHelper.initOrmAttributeSign(baseEntity);
    Map<String, Object> resultMap = null;
    SQLParameter param = new SQLParameter();
    param.addParam(pk);
    Class clz = baseEntity.getClass();
    String fullName = baseEntity.getFullName();
    Map<String, ORMColumnInfo> types = findColumnInfo(clz, fullName);
    Entity entity = MetaEntityHelper.getMetaEntity(fullName);
    List<Property> elasticAttributes = entity.getElasticAttributes();
    //buildSQL
    for (Property elasticProperty : elasticAttributes) {
        types.remove(elasticProperty.columnName());
    }
    StringBuffer columnsForQuery = new StringBuffer();
    for (String columnName : types.keySet()) {
        columnsForQuery.append(columnName).append(",");
    }
    columnsForQuery.delete(columnsForQuery.length() - 1, columnsForQuery.length());

    List<OneToOneType> parallelTypes = BizMetaHelper.getOneToOneField(baseEntity, null, null);
    List<OneToOneType> characteristicTypes = BeanProcessorHelper.getCharacteristicOneToOneField(fullName);
    String condition = BeanProcessorHelper.getPkColumn(baseEntity.getClass(), baseEntity.getFullName()) + "=?";

    if (CollectionUtils.isEmpty(parallelTypes) && CollectionUtils.isEmpty(characteristicTypes)) {
        String pkName = BeanProcessorHelper.getPkColumn(clz, fullName);
        boolean hasPKField = false;
        StringBuffer mainSQL = new StringBuffer();
        String tableName = BeanProcessorHelper.getTableName(clz, fullName);
        if (selectedFields == null) {
            mainSQL.append("SELECT ").append(columnsForQuery).append(" FROM ").append(tableName);
        } else {

            selectedFields = transPropertyNameToFieldNames(clz, fullName, selectedFields);
            String[] columns = getValidNames(fullName, clz, types, baseEntity, selectedFields);
            mainSQL.append("SELECT ");
            for (int i = 0; i < columns.length; i++) {
                if (columns[i] != null) {
                    mainSQL.append(columns[i]).append(",");
                    if (columns[i].equalsIgnoreCase(pkName)) {
                        hasPKField = true;
                    }
                }
            }
            if (!hasPKField) {
                mainSQL.append(pkName).append(",");
            }
            mainSQL.setLength(mainSQL.length() - 1);
            mainSQL.append(" FROM ").append(tableName);
        }
        mainSQL.append(" WHERE ").append(condition);
        BaseProcessor processor = new BeanListProcessor(baseEntity);
        List<T> results = getJdbcSession().executeQuery(mainSQL.toString(), param, processor);
        if (results.size() >= 1) {
            result = results.get(0);
        }
    } else {
        if (logger.isDebugEnabled()) {
            logger.debug("query for oneToOne .. {} ", clz.getClasses());
        }
        Field[] fields = baseEntity.getClass().getDeclaredFields();
        String[] propNames = new String[fields.length];
        for (int i = 0; i < fields.length; i++) {
            propNames[i] = fields[i].getName();
        }
        String pkName = BeanProcessorHelper.getPkColumn(clz, fullName);
        boolean hasPKField = false;
        StringBuffer mainSQL = new StringBuffer();
        String tableName = BeanProcessorHelper.getTableName(clz, fullName);
        StringBuilder mapSQL = new StringBuilder();
        mapSQL.append("SELECT * FROM ").append(tableName).append(" WHERE ").append(condition);
        List<Map> mapList = getJdbcSession().executeQuery(mapSQL.toString(), param, new MapListProcessor());
        if (mapList.size() >= 1) {
            resultMap = mapList.get(0);
        } else {
            logger.debug("查询结果为空！");
            return null;
        }
        if (selectedFields == null) {
            mainSQL.append("SELECT ").append(columnsForQuery).append(" FROM ").append(tableName).append(" WHERE ").append(condition);
            List<T> results = getJdbcSession().executeQuery(mainSQL.toString(), param, new BeanListProcessor(baseEntity));
            if (results.size() >= 1) {
                result = results.get(0);
            }
            //特征
            for (OneToOneType oneToOneType : characteristicTypes) {
                String childSQL = buildSQLWithoutSelectFields(oneToOneType, clz, fullName, resultMap);
                if (StringUtils.isNotEmpty(childSQL)) {
                    characteristicEntityHandler(baseEntity, childSQL, fullName, result, ormAttributeSign);
                }
            }
            //平行
            for (OneToOneType oneToOneType : parallelTypes) {
                String childTable = BeanProcessorHelper.getTableName(oneToOneType.getTargetEntity(), oneToOneType.getTargetFullName());
                String childSQL = buildSQLWithoutSelectFields(oneToOneType, clz, fullName, resultMap);
                if (StringUtils.isNotEmpty(childSQL)) {
                    parallelEntityHandler(baseEntity, childSQL, childTable, result, ormAttributeSign);
                }
            }

        } else {
            String[] filterFileds = transPropertyNameToFieldNames(clz, fullName, selectedFields);
            Set<String> filerdFieldSet = new HashSet<>();
            filerdFieldSet.addAll(Arrays.asList(filterFileds));
            StringBuilder columnBuilder = new StringBuilder();
            for (int i = 0; i < filterFileds.length; i++) {
                if (filterFileds[i] != null) {
                    columnBuilder.append(filterFileds[i]).append(",");
                    if (filterFileds[i].equalsIgnoreCase(pkName)) {
                        hasPKField = true;
                    }
                }
            }
            columnBuilder.append("pubts").append(",");
            columnBuilder.append("dr");
            if (!hasPKField) {
                columnBuilder.append(",").append(pkName);
            }
            StringBuilder sql = new StringBuilder();
            sql.append("SELECT ").append(columnBuilder).append(" FROM ").append(tableName).append(" WHERE ").append(condition);
            BaseProcessor processor = new BeanListProcessor(baseEntity);
            List<T> results = getJdbcSession().executeQuery(sql.toString(), param, processor);
            if (results.size() >= 1) {
                result = results.get(0);
            }

            //特征
            for (OneToOneType oneToOneType : characteristicTypes) {
                Class childClz = oneToOneType.getTargetEntity();
                String childTable = BeanProcessorHelper.getTableName(childClz, oneToOneType.getTargetFullName());
                String childSQL = buildSQLWithSelectedFields(oneToOneType, clz, fullName, selectedFields, resultMap, childTable);
                if (StringUtils.isNotEmpty(childSQL)) {
                    characteristicEntityHandler(baseEntity, childSQL, fullName, result, ormAttributeSign);
                }
            }
            //平行
            for (OneToOneType oneToOneType : parallelTypes) {
                Class childClz = oneToOneType.getTargetEntity();
                String childTable = BeanProcessorHelper.getTableName(childClz, oneToOneType.getTargetFullName());
                String childSQL = buildSQLWithSelectedFields(oneToOneType, clz, fullName, selectedFields, resultMap, childTable);
                if (StringUtils.isNotEmpty(childSQL)) {
                    parallelEntityHandler(baseEntity, childSQL, childTable, result, ormAttributeSign);
                }
            }
        }

    }

    return result;
}

/**
 * 根据fullName获取元数据信息
 *
 * @param fullName
 * @return
 */
public static Entity getMetaEntity(String fullName) {
    Entity entity = BizContext.getMetaRepository().entity(fullName);
    if (entity == null) {
        throw new IllegalArgumentException("can't get the meta info of" + fullName);
    }
    return entity;
}

/**
 * 根据Map查询数据，只返回指定字段的数据
 * @param baseEntity
 * @param unionKeyMap
 * @param selectedFields
 * @param <T>
 * @return
 * @throws BusinessException
 */
public <T> T queryByUnionKeyMap(BaseEntity baseEntity, Map<String,Object> unionKeyMap, String[] selectedFields) throws BusinessException;

/**
 * 根据主键列表查询数据，查询指定VO
 * @param baseEntity
 * @param unionKeyMap
 * @param <T>
 * @return
 * @throws BusinessException
 */
public <T> T queryByUnionKeyMap(BaseEntity baseEntity, Map<String, Object> unionKeyMap) throws BusinessException {
    return queryByUnionKeyMap(baseEntity, unionKeyMap, null);
}

/**
 * 根据主键列表查询数据，返回指定列的VO对象
 * @param baseEntity
 * @param unionKeyMap
 * @param selectedFields
 * @param <T>
 * @return
 * @throws BusinessException
 */
@Override
public <T> T queryByUnionKeyMap(BaseEntity baseEntity, Map<String, Object> unionKeyMap, String[] selectedFields) throws BusinessException {
    try {
        manager = createPersistenceManager();
        return (T) manager.retrieveByUnionKeyMap(baseEntity, unionKeyMap, selectedFields);
    } catch (Exception e) {
        logger.error(e.getMessage(), e);
        throw new DAOException(e.getMessage());
    }
}

/**
 * 根据主键查询
 */
public <T, ID> T retrieveByPK(BaseEntity baseEntity, ID pk) throws Exception {
    return retrieveByPK(baseEntity, pk, null);
}

/**
 * 根据主键查询
 */
public <T, ID> T retrieveByPK(BaseEntity baseEntity, ID pk, String[] selectedFields) throws Exception {
    if (pk == null) {
        throw new IllegalArgumentException("pk is null");
    }
    T result = null;

    Map<String, Object> unionKeyMap = new HashMap<>();
    unionKeyMap.put(BeanProcessorHelper.getPkColumn(baseEntity.getClass(), baseEntity.getFullName()), pk);
    //直接调用联合查询方法
    result = retrieveByUnionKeyMap(baseEntity, unionKeyMap, selectedFields);

    return result;
}


/**
 * 联合查询，返回指定字段数据
 */
public <T> T retrieveByUnionKeyMap(BaseEntity baseEntity, Map<String, Object> unionKeyMap) throws Exception {
    return retrieveByUnionKeyMap(baseEntity, unionKeyMap, null);
}


/**
 * 联合查询，返回指定字段数据
 */
public <T> T retrieveByUnionKeyMap(BaseEntity baseEntity, Map<String, Object> unionKeyMap, String[] selectedFields) throws Exception {
    //先判断传入的unionKeyMap是否为空，如果为空返回
    if (unionKeyMap == null) {
        throw new IllegalArgumentException("unionKeyMap is null"); //pk改为unionKeyMap
    }
    T result = null;
    boolean ormAttributeSign = BeanDataOperateHelper.initOrmAttributeSign(baseEntity);
    Map<String, Object> resultMap = null;
    SQLParameter param = new SQLParameter();

    //遍历Map的Key和Value，Key加入到临时conditionList中，Value加入到param.paramList中
    List<String> conditionList = new ArrayList<>();
    for(Map.Entry<String, Object> entry : unionKeyMap.entrySet()){
        conditionList.add(entry.getKey());
        param.addParam(entry.getValue());
    }

    Class clz = baseEntity.getClass();
    String fullName = baseEntity.getFullName();
    Map<String, ORMColumnInfo> types = findColumnInfo(clz, fullName);
    Entity entity = MetaEntityHelper.getMetaEntity(fullName);
    List<Property> elasticAttributes = entity.getElasticAttributes();

    //buildSQL
    for (Property elasticProperty : elasticAttributes) {
        types.remove(elasticProperty.columnName());
    }
    StringBuffer columnsForQuery = new StringBuffer();
    for (String columnName : types.keySet()) {
        columnsForQuery.append(columnName).append(",");
    }
    //删掉最后一个逗号
    columnsForQuery.delete(columnsForQuery.length() - 1, columnsForQuery.length());

    List<OneToOneType> parallelTypes = BizMetaHelper.getOneToOneField(baseEntity, null, null);
    List<OneToOneType> characteristicTypes = BeanProcessorHelper.getCharacteristicOneToOneField(fullName);
    //改前：condition仅包括主键
    //String condition = BeanProcessorHelper.getPkColumn(baseEntity.getClass(), baseEntity.getFullName()) + "=?";
    //改后：condition包括unionKeyMap中的所有Key值
    StringBuffer condition = new StringBuffer();
    for(String s : conditionList){
        condition.append(s + "=? and ");
    }
    condition.delete(condition.length() - 5, condition.length());

    if (CollectionUtils.isEmpty(parallelTypes) && CollectionUtils.isEmpty(characteristicTypes)) {
        String pkName = BeanProcessorHelper.getPkColumn(clz, fullName);
        boolean hasPKField = false;
        StringBuffer mainSQL = new StringBuffer();
        String tableName = BeanProcessorHelper.getTableName(clz, fullName);
        if (selectedFields == null) {
            mainSQL.append("SELECT ").append(columnsForQuery).append(" FROM ").append(tableName);
        } else {
            selectedFields = transPropertyNameToFieldNames(clz, fullName, selectedFields);
            String[] columns = getValidNames(fullName, clz, types, baseEntity, selectedFields);
            mainSQL.append("SELECT ");
            for (int i = 0; i < columns.length; i++) {
                if (columns[i] != null) {
                    mainSQL.append(columns[i]).append(",");
                    if (columns[i].equalsIgnoreCase(pkName)) {
                        hasPKField = true;
                    }
                }
            }
            if (!hasPKField) {
                mainSQL.append(pkName).append(",");
            }
            mainSQL.setLength(mainSQL.length() - 1);
            mainSQL.append(" FROM ").append(tableName);
        }
        mainSQL.append(" WHERE ").append(condition);
        BaseProcessor processor = new BeanListProcessor(baseEntity);
        List<T> results = getJdbcSession().executeQuery(mainSQL.toString(), param, processor);
        if (results.size() >= 1) {
            result = results.get(0);
        }
    } else {
        if (logger.isDebugEnabled()) {
            logger.debug("query for oneToOne .. {} ", clz.getClasses());
        }
        Field[] fields = baseEntity.getClass().getDeclaredFields();
        String[] propNames = new String[fields.length];
        for (int i = 0; i < fields.length; i++) {
            propNames[i] = fields[i].getName();
        }
        String pkName = BeanProcessorHelper.getPkColumn(clz, fullName);
        boolean hasPKField = false;
        StringBuffer mainSQL = new StringBuffer();
        String tableName = BeanProcessorHelper.getTableName(clz, fullName);
        StringBuilder mapSQL = new StringBuilder();
        mapSQL.append("SELECT * FROM ").append(tableName).append(" WHERE ").append(condition);
        List<Map> mapList = getJdbcSession().executeQuery(mapSQL.toString(), param, new MapListProcessor());
        if (mapList.size() >= 1) {
            resultMap = mapList.get(0);
        } else {
            logger.debug("查询结果为空！");
            return null;
        }
        if (selectedFields == null) {
            mainSQL.append("SELECT ").append(columnsForQuery).append(" FROM ").append(tableName).append(" WHERE ").append(condition);
            List<T> results = getJdbcSession().executeQuery(mainSQL.toString(), param, new BeanListProcessor(baseEntity));
            if (results.size() >= 1) {
                result = results.get(0);
            }
            //特征
            for (OneToOneType oneToOneType : characteristicTypes) {
                String childSQL = buildSQLWithoutSelectFields(oneToOneType, clz, fullName, resultMap);
                if (StringUtils.isNotEmpty(childSQL)) {
                    characteristicEntityHandler(baseEntity, childSQL, fullName, result, ormAttributeSign);
                }
            }
            //平行
            for (OneToOneType oneToOneType : parallelTypes) {
                String childTable = BeanProcessorHelper.getTableName(oneToOneType.getTargetEntity(), oneToOneType.getTargetFullName());
                String childSQL = buildSQLWithoutSelectFields(oneToOneType, clz, fullName, resultMap);
                if (StringUtils.isNotEmpty(childSQL)) {
                    parallelEntityHandler(baseEntity, childSQL, childTable, result, ormAttributeSign);
                }
            }

        } else {
            String[] filterFileds = transPropertyNameToFieldNames(clz, fullName, selectedFields);
            Set<String> filerdFieldSet = new HashSet<>();
            filerdFieldSet.addAll(Arrays.asList(filterFileds));
            StringBuilder columnBuilder = new StringBuilder();
            for (int i = 0; i < filterFileds.length; i++) {
                if (filterFileds[i] != null) {
                    columnBuilder.append(filterFileds[i]).append(",");
                    if (filterFileds[i].equalsIgnoreCase(pkName)) {
                        hasPKField = true;
                    }
                }
            }
            columnBuilder.append("pubts").append(",");
            columnBuilder.append("dr");
            if (!hasPKField) {
                columnBuilder.append(",").append(pkName);
            }
            StringBuilder sql = new StringBuilder();
            sql.append("SELECT ").append(columnBuilder).append(" FROM ").append(tableName).append(" WHERE ").append(condition);
            BaseProcessor processor = new BeanListProcessor(baseEntity);
            List<T> results = getJdbcSession().executeQuery(sql.toString(), param, processor);
            if (results.size() >= 1) {
                result = results.get(0);
            }

            //特征
            for (OneToOneType oneToOneType : characteristicTypes) {
                Class childClz = oneToOneType.getTargetEntity();
                String childTable = BeanProcessorHelper.getTableName(childClz, oneToOneType.getTargetFullName());
                String childSQL = buildSQLWithSelectedFields(oneToOneType, clz, fullName, selectedFields, resultMap, childTable);
                if (StringUtils.isNotEmpty(childSQL)) {
                    characteristicEntityHandler(baseEntity, childSQL, fullName, result, ormAttributeSign);
                }
            }
            //平行
            for (OneToOneType oneToOneType : parallelTypes) {
                Class childClz = oneToOneType.getTargetEntity();
                String childTable = BeanProcessorHelper.getTableName(childClz, oneToOneType.getTargetFullName());
                String childSQL = buildSQLWithSelectedFields(oneToOneType, clz, fullName, selectedFields, resultMap, childTable);
                if (StringUtils.isNotEmpty(childSQL)) {
                    parallelEntityHandler(baseEntity, childSQL, childTable, result, ormAttributeSign);
                }
            }
        }

    }

    return result;
}

@Service("fillPKRule")
public class FillPKRule extends AbstractCommonRule {
    public FillPKRule() {
    }

    public RuleExecuteResult execute(BillContext billContext, Map<String, Object> paramMap) throws Exception {
        //列表查询dto:查询条件、分页、汇总显示
        BillDataDto billData = (BillDataDto)this.getParam(paramMap);
        
        List<BizObject> bills = this.getBills(billContext, paramMap);
        FillFkDao.execute(billContext.getFullname(), bills);
        return new RuleExecuteResult();
    }
}

###  com.yonyou.ucf.mdd.ext.dao.meta.biz.FillFkDao

public static <T extends BizObject> void execute(String fullname, List<T> bills) throws Exception {
    initIPKGeneratorConfig();
    Map<String, KeyIterator> insertEntityPK = ipkGeneratorConfig.configMap();


    Entity entity=MetaDaoHelper.getEntity(fullname);
    // 遍历所有对象
    for (BizObject bill : bills) {

        ObjectHierarchyBuilder.build(bill, entity);
        // 设置主键
        //20200722 只支持number 类型 ObjectPKWalker pkWalker = new ObjectPKWalker(insertEntityPK);
        MddObjectPKWalker pkWalker = new MddObjectPKWalker(insertEntityPK);
        ObjectWalker.walk(pkWalker, bill, fullname);

        // 设置关联关系字段值（主子实体中，子对象外键）
        ObjectFKWalker fkWalker = new ObjectFKWalker();
        // 在一次遍历中通过next可以设置多个walker
        // ChainWalker<Association, BizObject> otherWalker = new ...;
        // fkWalker.setNext(otherWalker);
        ObjectWalker.walk(fkWalker, bill, fullname);
    }

}

@Service("checkUniqueRule")
public class CheckUniqueRule extends AbstractCommonRule {
    private static final Logger log = LoggerFactory.getLogger(CheckUniqueRule.class);

    public CheckUniqueRule() {
    }

    public RuleExecuteResult execute(BillContext billContext, Map<String, Object> paramMap) throws Exception {
        if (billContext == null) {
            return new RuleExecuteResult();
        } else {
            List<BizObject> bills = this.getBills(billContext, paramMap);
            if (null != bills && bills.size() != 0) {
                Entity entity = MetaDaoHelper.getEntity(billContext.getFullname());
                if (null == entity) {
                    throw new Exception("查询元数据失败:" + billContext.getFullname());
                } else {
                    ServiceSupportHolder holder = new ServiceSupportHolder(billContext, paramMap, bills, entity);
                    String config = this.getConfig();
                    holder.setConfig(config);
                    BillDataDto billDataDto = (BillDataDto)this.getParam(paramMap);
                    holder.setBillData(billDataDto);
                    IServiceSupportApi iServiceSupportApi = (IServiceSupportApi)AppContext.getBean(CheckUniqueSupportService.class);
                    return (RuleExecuteResult)iServiceSupportApi.execute(holder);
                }
            } else {
                return new RuleExecuteResult();
            }
        }
    }
}


### com.yonyou.ucf.mdd.support.abs.AbstractServiceSupport
public Object execute(ServiceSupportHolder holder) throws Exception {
    beforeHandler(holder);	//空
    Object resultHandler = doExecute(holder);
    afterExecute(holder, resultHandler);	//空
    return resultHandler;
}

### com.yonyou.ucf.mdd.support.support.CheckUniqueSupportService
	@Override
    protected Object doExecute(ServiceSupportHolder holder) throws Exception {
        IDoBillService iDoBillService = getBeanDo(ServiceSupportStatic.CheckUnique.DO);
        return iDoBillService.doExecute(holder);
    }

### com.yonyou.ucf.mdd.support.support.check.checkunique.DoExecuteCheckUniqueService
@Override
public Object doExecute(ServiceSupportHolder holder) throws Exception {
    BillDataDto item = holder.getBillData();
    //是否check具体某个属性比如check_name,check_code
    boolean isHasItem = null == item.getItem() ? false : true;
    if (isHasItem) {
        CheckItem checkItem = new Gson().fromJson(item.getItem(), CheckItem.class);
        if (null == checkItem || checkItem.getKey() == null) {
            return new RuleExecuteResult();
        }
    }
    Entity entity = holder.getEntity();
    //构建检查唯一性的BO对象
    CheckUnionBO checkUnionBO = createCheckUnionBO(holder);
    //待回滚的参数 并发唯一了
    List<String> needRollList = new ArrayList<>();
    List<BizObject> bills = holder.getBillList();
    //是否支持内存check
    try {
        boolean autoCode = checkUnionBO.isAutoCode();
        List<Map<String, Object>> codeTempDataCaches = new ArrayList<>();
        // 自动编码下需要把编码换成UUID，防止并发时被唯一校验控制，在UpdateBillCodeRule由编码规则统一控制
        if (!isHasItem && autoCode) {
            codeTempDataCaches = checkUniqueCodeService.writeTempCode(bills, entity, holder.getBillContext(), holder.getParamMap());
        }
        //内存+redis检查
        checkLocalUniqueService.checkUnionKeyObJVM(holder.getBillContext(), entity, checkUnionBO, bills, needRollList);
        //数据库检查 联合唯一性校验， 当校验参数为 null 用 is null 拼接条件
        UniqueCheckWalker uniqueCheckWalker = new UniqueCheckWalker(AppContext.getPartitionContextData(entity, true), false);
        if (!isHasItem) {
            checkDbUniqueService.checkUnionWithOutItem(holder, bills, entity, checkUnionBO.isCheckChild(), uniqueCheckWalker);
            if (autoCode) {
                checkUniqueCodeService.reWriteCode(codeTempDataCaches, bills, autoCode);
            }
        } else {
            checkDbUniqueService.checkUnionWithItem(holder.getBillContext(), bills, item, entity, uniqueCheckWalker);
        }
    } finally {
        if (null != needRollList && needRollList.size() > 0) {
            if (TransactionSynchronizationManager.isActualTransactionActive()) {
                TransactionSynchronizationManager.registerSynchronization(new DoExecuteAfterTransactionCompletion(needRollList));
            }
        }
    }
    return new RuleExecuteResult();
}

@Service("saveBillRule")
public class SaveBillRule extends AbstractCommonRule {
    private static final Logger log = LoggerFactory.getLogger(SaveBillRule.class);

    public SaveBillRule() {
    }

    @ResubmitAnnotations
    public RuleExecuteResult execute(BillContext billContext, Map<String, Object> paramMap) throws Exception {
        return this.executeCommon(billContext, paramMap);
    }

    public RuleExecuteResult executeCommon(BillContext billContext, Map<String, Object> paramMap) throws Exception {
        List<BizObject> bills = this.getBills(billContext, paramMap);
        Entity entity = StringUtils.isBlank(billContext.getFullname()) ? null : IMetaUtils.entity(billContext.getFullname());
        ServiceSupportHolder holder = new ServiceSupportHolder(billContext, paramMap, bills, entity);
        holder.setcBillNo(billContext.getBillnum());
        this.extendEnhance(holder);
        IServiceSupportApi iServiceSupportApi = (IServiceSupportApi)AppContext.getBean(SaveBillSupportService.class);
        return (RuleExecuteResult)iServiceSupportApi.execute(holder);
    }

    protected void extendEnhance(ServiceSupportHolder holder) {
        holder.getAttribute().setAttr("saveRealAutoCode", false);
    }
}


### com.yonyou.ucf.mdd.support.abs.AbstractServiceSupport
    public Object execute(ServiceSupportHolder holder) throws Exception {
        beforeHandler(holder);
        Object resultHandler = doExecute(holder);
        afterExecute(holder, resultHandler);
        return resultHandler;
    }

    protected abstract Object doExecute(ServiceSupportHolder holder) throws Exception;


### com.yonyou.ucf.mdd.support.support.SaveBillSupportService
    @Override
    protected Object doExecute(ServiceSupportHolder holder) throws Exception {
        IDoBillService iDoBillService = getBeanDo(ServiceSupportStatic.Save.DO);
        return iDoBillService.doExecute(holder);
    }

### com.yonyou.ucf.mdd.support.support.save.DoExecuteSaveBillService
     /**
     *
     * @param holder
     * @return
     * @throws Exception
     *
     * @author Seraph
     * @date 2021/5/2710:57 PM
     */
    @Override
    public Object doExecute(ServiceSupportHolder holder) throws Exception {
        List<BizObject> bills = holder.getBillList();
        for (BizObject bill : bills) {
            checkRelevantRuleVerify(holder,bill);
            executeOneBill(holder, bill);
        }
        return new RuleExecuteResult();
    }

    /**
     *
     * @param holder
     * @param bill
     * @throws Exception
     *
     * @author Seraph
     * @date 2021/5/2710:57 PM
     */
    @Override
    public void executeOneBill(ServiceSupportHolder holder, BizObject bill) throws Exception {
        BillContext billContext = holder.getBillContext();
        boolean isInsert = EntityStatus.Insert == bill.getEntityStatus() ? true : false;
        setAudit(isInsert, bill, holder.getEntity().fullname());
        BarCodeSupport.generateBarCode(billContext, holder.getEntity(), bill);//处理条形码
        setStatusInfoWhenInsert(holder,Status.newopen, bill, isInsert); //设置单据状态
        dealSupportBpm(bill, billContext, isInsert);//处理工作流
        String code = getAndDealCode(holder, billContext, bill, isInsert); //获取处置编码规则

        //保存业务逻辑
        Object result = saveBillServiceImpl.executeSave(billContext, bill, holder.getParamMap(), holder.getEntity(), isInsert);

        //重置编码规则
        if (null != code) {
            bill.set("code", code);
        }

        BillSaveResult billSaveResult = (BillSaveResult) result;
        String partitionWhereCondition = saveBillServiceImpl.buildQueryWhere4UpdateTree(holder.getEntity(), billContext); //构建扩展分词条件
        updateTree(bill, billContext.getFullname(), AppContext.getTenantId(), billSaveResult, partitionWhereCondition);    //更新树
//        sendTimeLineSnapshot(billContext, bill, holder.getParamMap(), isInsert);  //新增时上传时间轴快照
    }


### com.yonyou.ucf.mdd.ext.bill.service.SaveBillServiceImpl
    /**
     * @see SaveBillServiceImpl#executeSave(com.yonyou.ucf.mdd.ext.model.BillContext, org.imeta.orm.base.BizObject, java.util.Map, org.imeta.core.model.Entity, java.lang.Boolean)
     * @see InsertSqlExecutor#execute(org.imeta.core.model.Entity, java.util.List)
     * @see UpdateSqlExecutor#execute(org.imeta.core.model.Entity, java.util.List)
     *
     * <p>
     *      execute insert or update with _statis value <code>String</code>
     * </p>
     *
     * @param billContext billContext is one thread context {@link BillContext} in the variable has props  context {@link Map} <code>null</code>save Resubmit key and other So.
     *      *             fullname : metaUri of metaServer  is the index of entity of meta
     * @param bill  business data in {@link com.yonyou.ucf.mdd.ext.bill.dto.BillDataDto}
     * @param paramMap Singleton instance in rule china {@link Map} ,the request DTO in paramMap when in rule ,the DTO is instance of {@link BizObject} Array
     *      *          when complete this rule  set paramMap for return
     * @param entity meta entity in metaServer
     * @param isInert _statis value <code>String</code>  insert or update
     *
     * @return execute result
     * @throws Exception
     */
    @Override
    public Object executeSave(BillContext billContext, BizObject bill, Map<String, Object> paramMap, Entity entity, Boolean isInert) throws Exception {
        try {
            if (isInert) {
                return executeInsert(billContext, bill, paramMap, entity);
            }
            return executeUpdate(billContext, bill, entity);
        }catch (MddZeroResultMsgException zr){
            throw new MddVouchStateMsgException(MsgExceptionCode.BILL_CHANGED_PLEASE_REFRESH);
        }
    }

    /**
     * @see SaveBillServiceImpl#executeSave(com.yonyou.ucf.mdd.ext.model.BillContext, org.imeta.orm.base.BizObject, java.util.Map, org.imeta.core.model.Entity, java.lang.Boolean)
     * @see InsertSqlExecutor#execute(org.imeta.core.model.Entity, java.util.List)
     *
     * <p>
     *      execute insert or update with _statis value <code>String</code>
     * </p>
     *
     * @param billContext billContext is one thread context {@link BillContext} in the variable has props  context {@link Map} <code>null</code>save Resubmit key and other So.
     *      *             fullname : metaUri of metaServer  is the index of entity of meta
     * @param bill  business data in {@link com.yonyou.ucf.mdd.ext.bill.dto.BillDataDto}
     * @param paramMap Singleton instance in rule china {@link Map} ,the request DTO in paramMap when in rule ,the DTO is instance of {@link BizObject} Array
     *      *          when complete this rule  set paramMap for return
     * @param entity meta entity in metaServer
     *
     * @return execute result
     * @throws Exception
     */
    private Object executeInsert(BillContext billContext, BizObject bill, Map<String, Object> paramMap, Entity entity) throws Exception {
        fillPubts4Insert(bill);
        //开始递归插入数据
        new InsertSqlExecutor(AppContext.getSqlSession()).execute(entity, bill);
        //check project is open config of timeline and this bill is opened in timeline server
        //sendTimeLineSnapshot(billContext, bill, paramMap);
        return new BillSaveResult();
    }


### com.yonyou.ucf.mdd.ext.dao.meta.crud.InsertSqlExecutor
 /**
 * 元数据crud封装的insert实现
 *
 * @author Bob
 */
@SuppressWarnings("DuplicatedCode")
public class InsertSqlExecutor extends MetaDaoSupport {
    
    ...
        
    public <T extends BizObject> void execute(Entity entity, T data) throws Exception {
        List<T> list = new ArrayList<T>(1);
        list.add(data);
        execute(entity, list, true);
    }

    private <T extends BizObject> void execute(Entity entity, List<T> list, boolean isPartition) throws Exception {
        if (true) {//强制切换到InsertSqlExecutorNew
            new InsertSqlExecutorNew(getSqlSession()).execute(entity, list);
            return;
        }
        printLogWHenEntityNull(entity, list);
        //传递多语开关配置到元数据上下文
        String fullname = entity.fullname();
        MddMultilingualUtil.setEnableI18n2Imeta();
        //提前将insert插入，为yTenant 判断做准备
        EntityStatusWalker statusWalker = new EntityStatusWalker();
        for (BizObject bill : list) {
            bill.setEntityStatus(EntityStatus.Insert);
            ObjectWalker.walk(statusWalker, bill, fullname);
        }
        if (isPartition) {
            setTenantandCorpWhenSave(entity, list);
        }

        InsertCheckWalker insertCheck = new InsertCheckWalker();
        insertCheck.setNext(new FormatCheckWalker());
        // 构造SQL语句
        SqlBuilder<BizObject> builder = new InsertSqlBuilder();
        for (BizObject bill : list) {
            ObjectHierarchyBuilder.build(bill, entity);
            ObjectFullWalker.walk(insertCheck, bill, fullname);
            try {
                batchSaveExecute(builder.build(entity, bill));
            } catch (Throwable throwable) {
                logger.error(throwable.getMessage());
                throw new MddOrmErrorException(throwable.getMessage(),throwable);
            }
        }
    }

@Order(2147483647)
@Service("saveBusinessLogRule")
public class SaveBusinessLogRule extends AbstractCommonRule {
    private static final Logger logger = LoggerFactory.getLogger(SaveBusinessLogRule.class);
    private ExecutorService taskExecutor;
    private AuditLogSender auditLogSender;

    public SaveBusinessLogRule() {
    }

    public RuleExecuteResult execute(final BillContext billContext, final Map<String, Object> paramMap) {
        final List<BizObject> bills = this.getCloneBills(billContext, paramMap);
        final String token = InvocationInfoProxy.getYhtAccessToken();
        final String clientIp = (String)InvocationInfoProxy.getExtendAttribute("clientIp");
        final String serviceCode = (String)InvocationInfoProxy.getExtendAttribute("serviceCode");
        if (StringUtils.isBlank(serviceCode)) {
            try {
                BillDataDto billDataDto = (BillDataDto)this.getParam(paramMap);
                if (null != billDataDto) {
                    Map<String, Object> externalData = BillUtils.getExternalData(billDataDto);
                    serviceCode = (String)externalData.get("serviceCode");
                }
            } catch (Exception var10) {
                if (logger.isErrorEnabled()) {
                    logger.error("从BillDataDto扩展参数中获取serviceCode失败");
                }
            }
        }

        if (!CollectionUtils.isEmpty(bills)) {
            if (TransactionSynchronizationManager.isSynchronizationActive()) {
                TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
                    public void afterCompletion(int status) {
                        if (0 == status) {
                            SaveBusinessLogRule.this.getTaskExecutor().execute(() -> {
                                SaveBusinessLogRule.this.executeAsync(billContext, paramMap, token, clientIp, bills, serviceCode);
                            });
                        }

                    }
                });
            } else {
                logger.warn("业务日志异步执行，未开启事务。");
                this.getTaskExecutor().execute(() -> {
                    this.executeAsync(billContext, paramMap, token, clientIp, bills, serviceCode);
                });
            }
        } else {
            JsonFormatter formatter = new JsonFormatter(BizContext.getMetaRepository());
            String json = formatter.toJson(bills, billContext.getFullname(), false, 32).toString();
            logger.error("业务日志getCloneBills为空: 参数---billContext:{},bills:{}", JSONObject.toJSONString(billContext), json);
        }

        return new RuleExecuteResult();
    }

@Service("refreshTsRule")
public class RefreshTsRule extends AbstractCommonRule {
    public RefreshTsRule() {
    }

    public RuleExecuteResult execute(BillContext billContext, Map<String, Object> paramMap) throws Exception {
        String fullname = billContext.getFullname();
        List<BizObject> bills = this.getBills(billContext, paramMap);
        String refreshField = (String)this.getParam(paramMap, "refreshField");
        if (null != bills && bills.size() > 0) {
            Iterator var6 = bills.iterator();

            while(var6.hasNext()) {
                BizObject bill = (BizObject)var6.next();
                BillInfoUtils.refreshTs(fullname, bill, refreshField, AppContext.getTenantId());
                DataCleanWalker dataCleanWalker = new DataCleanWalker();
                dataCleanWalker.setNext(new ParallelTableWalker());
                ObjectFullWalker.walk(dataCleanWalker, bill, fullname);
            }

            LogicDeleteHelper.removeLogicDelete(fullname, bills);
            if (bills.size() == 1) {
                this.putParam(paramMap, "return", bills.get(0));
            } else {
                this.putParam(paramMap, "return", bills);
            }
        }

        return new RuleExecuteResult();
    }
}

public RuleExecuteResult execute(BillContext billContext, Map<String, Object> paramMap) throws Exception {
    RuleExecuteResult result = new RuleExecuteResult();
    LogUtil.log("业务流：BizFlowWriteBackRule start! ");

    try {
        this.doWriteBack(billContext, paramMap);
        LogUtil.log("业务流：BizFlowWriteBackRule end! ");
    } catch (Exception var5) {
        LogUtil.log("业务流：BizFlowWriteBackRule error!", var5);
    }

    return result;
}

private void doWriteBack(BillContext billContext, Map<String, Object> paramMap) throws Exception {
    BillDataDto reqDto = (BillDataDto)paramMap.get("param");
    String domain = BizFlowUtil.getDomain(billContext);
    String billNum = BizFlowUtil.getBillNum(reqDto);
    String tenantId = BizFlowUtil.getTenantId();
    String token = InvocationInfoProxy.getYhtAccessToken();
    String operate = billContext.getAction();
    String subId = billContext.getSubid();
    List<JSONObject> bills = BizFlowUtil.getBills(reqDto);
    Iterator var11 = bills.iterator();

    while(var11.hasNext()) {
        JSONObject bill = (JSONObject)var11.next();
        if (this.noNeedWriteBackConvert(bill, domain, operate)) {
            LogUtil.log("业务流：BizFlowWriteBackRule skip bill: " + bill);
        } else {
            LogUtil.log("业务流：BizFlowWriteBackRule bill: " + bill);
            ConvertParam convertParam = new ConvertParam();
            convertParam.setTenantId(tenantId);
            convertParam.setBillNum(billNum);
            convertParam.setBillId(bill.getString("id"));
            convertParam.addBill(bill);
            convertParam.setToken(token);
            convertParam.setOperate(operate);
            convertParam.setSubId(subId);
            convertParam.setDomain(domain);
            LogUtil.log("业务流：BizFlowWriteBackRule convert PARAM: " + JSON.toJSONString(convertParam));
            ConvertResult convertResult = BizFlowUtil.doWriteBackConvert(convertParam);
            LogUtil.log("业务流：BizFlowWriteBackRule convert result: " + JSON.toJSONString(convertResult));
        }
    }

}

private boolean noNeedWriteBackConvert(JSONObject bill, String domain, String action) {
    if (!"audit".equalsIgnoreCase(action) && !"unaudit".equalsIgnoreCase(action)) {
        String flowId = ObjectUtil.getString(bill, "bizFlowId");
        if ("developplatform".equalsIgnoreCase(domain) && ObjectUtil.isEmpty(flowId)) {
            return true;
        } else {
            String writeBackSign = ObjectUtil.getString(bill, "bizFlowWriteBackSign");
            return "bizFlowWriteBackSign".equals(writeBackSign);
        }
    } else {
        return false;
    }
}

private static final Logger log = LoggerFactory.getLogger(BizFlowPushRule.class);
@Autowired
IYpdBillDataService iYpdBillDataService;
@Autowired
MdfTemplateRunTimeServiceImpl mdfTemplateRunTimeService;

public BizFlowPushRule() {
}

public RuleExecuteResult execute(BillContext billContext, Map<String, Object> paramMap) throws Exception {
    BizFlowRuleResult result = new BizFlowRuleResult();
    LogUtil.log("业务流：bizFlowPush start! ");

    try {
        BillDataDto reqDto = (BillDataDto)paramMap.get("param");
        Map<String, Object> cusMap = reqDto.getCustMap();
        String billNum = BizFlowUtil.removeSuffix(reqDto.getBillnum());
        List<JSONObject> bills = BizFlowUtil.getBills(reqDto);
        String domain = BizFlowUtil.getDomain(billContext);
        ConvertResult convertResult = BizFlowUtil.doPush(billNum, bills, cusMap, billContext.getSubid(), domain, billContext.getAction());
        if (Boolean.TRUE.equals(AppContext.getCurrentUser().getNewArch())) {
            this.busObjToUIData(billContext, paramMap, convertResult);
        }

        paramMap.put("bizFlowReturn", convertResult);
        result.setConvertResult(convertResult);
        LogUtil.log("业务流：bizFlowPush end! ");
    } catch (Exception var10) {
        LogUtil.log("业务流：bizFlowPush error!", var10);
    }

    return result;
}

@Component("stockServiceTccRule")
public class StockSer  viceTccRule extends AbstractCommonRule implements ITccRule {
// private static final String URI = "XMFYGJ102.XMFYGJ102.bookstock_yts";
   //日常
   private static final String URI = "GT52146AT26.GT52146AT26.bookstock_yts";

   private static final String PRODUCTID = "sproductid";
   private static final String ITOTAL = "itotal";
   private static final String INUMBER = "inumber";
   private static final String IONWAY = "ionway";
   private static final String SNAME = "sname";

   protected final static Logger logger = LoggerFactory.getLogger(StockServiceTccRule.class);

   @Autowired
    IOrderService orderService;

   @Autowired
   private RedisTemplate redisTemplate;

   @Override
   public RuleExecuteResult execute(BillContext billContext, Map<String, Object> map) throws Exception {
      logger.info("StockServiceRule running!");
      List<BizObject> bills = this.getBills(billContext, map);
      boolean hasTccFlag = false;
      for (BizObject bizObject : bills) {
         String name = bizObject.get(SNAME);
         if (!StringUtils.isEmpty(name) && name.toLowerCase(Locale.ENGLISH).indexOf("iris") != -1) {
            hasTccFlag = true;
         }
      }
      for (BizObject bizObject : bills) {
         String ProductId = bizObject.get(PRODUCTID);
         if (null == ProductId) {
            throw new RuntimeException("商品ID不能为空");
         }
         // 下单数量
         Integer num = bizObject.get(INUMBER);
         if (null == num || num <= 0) {
            throw new RuntimeException("数量不能为空或小于0");
         }
         BizObject stock = MetaDaoHelper.findById(URI, ProductId);
         stock.put("_status", EntityStatus.Update);
         // tcc模式，正向先扣库存
         Integer oldItotal = (Integer)stock.get(ITOTAL);
         if (num > oldItotal) {
            throw new RuntimeException("库存不足");
         }
         stock.put(ITOTAL, oldItotal - num);
         // 增加在途库存
         Integer oldIonway = (Integer)stock.get(IONWAY);
         stock.put(IONWAY, oldIonway + num);
         
         Transaction yts = YtsContext.currentTransaction();
         if (null != yts) {
            stock.put("gtxid", yts.getGtxId());
            stock.put("ptxid", yts.getPtxId());
            stock.put("txid", yts.getTxId());
         }

         //将sorderid存入redis
         String sorderid = bizObject.get("sorderid");
         redisTemplate.opsForValue().set(sorderid,yts.getGtxId(),30l, TimeUnit.MINUTES);
         
         MetaDaoHelper.update(URI, stock);
         
      }
      if (hasTccFlag) {
         TourOrder order = new TourOrder();
         order.setUserId(UUID.randomUUID().toString());
         order.setTourOrderId(UUID.randomUUID().toString());
         order.setOrderName("订单号:" + order.getOrderName());
         order.setUserName("yongyou");

         TourOrder norder = orderService.sagas(order);
         try {
            logger.info("order: {}", JSON.toJSONString(norder));
         } catch (Throwable e) {
            logger.warn("toJSONString error ", e);
         }
      }
      return  new RuleExecuteResult();
   }

   @Override
   public RuleExecuteResult confirm(BillContext billContext, Map<String, Object> paramMap) throws Exception {
      logger.info("StockServiceRule rollback!");
      List<BizObject> bills = this.getBills(billContext, paramMap);
      for (BizObject bizObject : bills) {
         String ProductId = bizObject.get(PRODUCTID);
         if (null == ProductId) {
            throw new RuntimeException("商品ID不能为空");
         }
         // 下单数量
         Integer num = bizObject.get(INUMBER);
         if (null == num || num <= 0) {
            throw new RuntimeException("数量不能为空或小于0");
         }
         // tcc模式成功，减去在途库存,交易完成
         BizObject stock = MetaDaoHelper.findById(URI, ProductId);
         stock.put("_status", EntityStatus.Update);
         Integer oldIonway = (Integer)stock.get(IONWAY);
         stock.put(IONWAY, oldIonway - num);
         
         MetaDaoHelper.update(URI, stock);
      }
      return new RuleExecuteResult();
   }

   @Override
   public RuleExecuteResult cancel(BillContext billContext, Map<String, Object> map) throws Exception {
      logger.info("StockServiceRule rollback!");
      List<BizObject> bills = this.getBills(billContext, map);
      for (BizObject bizObject : bills) {
         String ProductId = bizObject.get(PRODUCTID);
         if (null == ProductId) {
            throw new RuntimeException("商品ID不能为空");
         }
         // 下单数量
         Integer num = bizObject.get(INUMBER);
         if (null == num || num <= 0) {
            throw new RuntimeException("数量不能为空或小于0");
         }
         // tcc模式失败，将在途库存加回可用库存
         BizObject stock = MetaDaoHelper.findById(URI, ProductId);
         stock.put("_status", EntityStatus.Update);
         Integer oldItotal = (Integer)stock.get(ITOTAL);
         stock.put(ITOTAL, oldItotal + num);
         
         Integer oldIonway = (Integer)stock.get(IONWAY);
         stock.put(IONWAY, oldIonway - num);
         
         MetaDaoHelper.update(URI, stock);
      }
      return new RuleExecuteResult();
   }

}

@Component("payServiceTccRule")
public class PayServiceTccRule extends AbstractCommonRule implements ITccRule {
// private static final String URI = "XMFYGJ103.XMFYGJ103.bookpay_yts";
   //日常
   private static final String URI = "GT52131AT25.GT52131AT25.bookpay_yts";

   private static final String SUSERID = "sbuyer";
   private static final String FTOTAL = "ftotal";
   private static final String FAVAILABLE = "favailable";
   private static final String FONWAY = "fonway";
   private static final String SNAME = "sname";

   
   @Autowired
   IOrderService orderService;
   
   protected final static Logger logger = LoggerFactory.getLogger(PayServiceTccRule.class);

   @Override
   public RuleExecuteResult execute(BillContext billContext, Map<String, Object> map) throws Exception {
      logger.info("PayServiceRule running!");
      List<BizObject> bills = this.getBills(billContext, map);
      boolean hasTccFlag = false;
      for (BizObject bizObject : bills) {
         String name = bizObject.get(SNAME);
         if (!StringUtils.isEmpty(name) && name.toLowerCase(Locale.ENGLISH).indexOf("tcc") != -1) {
            hasTccFlag = true;
         }
      }
      /*if(hasTccFlag) {
         TourOrder order = new TourOrder();
         order.setUserId(UUID.randomUUID().toString());
         order.setTourOrderId(UUID.randomUUID().toString());
         order.setOrderName("订单号:" + order.getOrderName());
         order.setUserName("yongyou");
         orderService.tcc(order);
      }*/

      for (BizObject bizObject : bills) {
         // 账户
         String UserId = bizObject.get(SUSERID);
         if (null == UserId) {
            throw new RuntimeException("账户ID不能为空");
         }
         // 待支付金额
         BigDecimal total = bizObject.get(FTOTAL);
         if (null == total || total.floatValue() <= 0) {
            throw new RuntimeException("支付金额不能为空或小于0");
         }
         BizObject pay = MetaDaoHelper.findById(URI, UserId);
         pay.put("_status", EntityStatus.Update);
         // 账户可用金额
         BigDecimal oldFavailable =  pay.get(FAVAILABLE);
         if (total.floatValue() > oldFavailable.floatValue()) {
            throw new RuntimeException("当前账户余额不足");
         }
          
         pay.put(FAVAILABLE, oldFavailable.subtract(total));
         // 账户在途金额，增加待付金额
         BigDecimal oldOnway =  pay.get(FONWAY);
         pay.put(FONWAY, oldOnway.add(total));
         
         Transaction yts = YtsContext.currentTransaction();
         if (null != yts) {
            pay.put("gtxid", yts.getGtxId());
            pay.put("ptxid", yts.getPtxId());
            pay.put("txid", yts.getTxId());
         }
         MetaDaoHelper.update(URI, pay);    
      }

      return  new RuleExecuteResult();
   }

   @Override
   public RuleExecuteResult confirm(BillContext billContext, Map<String, Object> map) throws Exception {
      logger.info("PayServiceRule rollback!");
      List<BizObject> bills = this.getBills(billContext, map);
      for (BizObject bizObject : bills) {
         // 账户
         String UserId = bizObject.get(SUSERID);
         if (null == UserId) {
            throw new RuntimeException("账户ID不能为空");
         }
         // 待支付金额
         BigDecimal total = bizObject.get(FTOTAL);
         if (null == total || total.floatValue() <= 0) {
            throw new RuntimeException("支付金额不能为空或小于0");
         }
         BizObject pay = MetaDaoHelper.findById(URI, UserId);
         pay.put("_status", EntityStatus.Update);

         // 成功则把在途金额减掉，交易完成    
         BigDecimal oldOnway =  pay.get(FONWAY);
         pay.put(FONWAY, oldOnway.subtract(total));
         
         MetaDaoHelper.update(URI, pay);    
      }
      return new RuleExecuteResult();
   }

   @Override
   public RuleExecuteResult cancel(BillContext billContext, Map<String, Object> map) throws Exception {
      logger.info("PayServiceRule rollback!");
      List<BizObject> bills = this.getBills(billContext, map);
      for (BizObject bizObject : bills) {
         // 账户
         String UserId = bizObject.get(SUSERID);
         if (null == UserId) {
            throw new RuntimeException("账户ID不能为空");
         }
         // 待支付金额
         BigDecimal total = bizObject.get(FTOTAL);
         if (null == total || total.floatValue() <= 0) {
            throw new RuntimeException("支付金额不能为空或小于0");
         }
         BizObject pay = MetaDaoHelper.findById(URI, UserId);
         pay.put("_status", EntityStatus.Update);

         // 失败则把在途金额加回可用金额
         BigDecimal old = pay.get(FAVAILABLE);
         pay.put(FAVAILABLE, old.add(total));
      
         BigDecimal oldOnway =  pay.get(FONWAY);
         pay.put(FONWAY, oldOnway.subtract(total));
         
         MetaDaoHelper.update(URI, pay);    
      }
      return new RuleExecuteResult();
   }

}