ApiSys/backend/Server/Web/Dao/AutomatedTestCaseGroupDao.class.php

<?php

/**
 * @name eolinker ams open source，eolinker开源版本
 * @link https://www.eolinker.com/
 * @package eolinker
 * @author www.eolinker.com 广州银云信息科技有限公司 ©2015-2018
 * eoLinker是目前全球领先、国内最大的在线API接口管理平台，提供自动生成API文档、API自动化测试、Mock测试、团队协作等功能，旨在解决由于前后端分离导致的开发效率低下问题。
 * 如在使用的过程中有任何问题，欢迎加入用户讨论群进行反馈，我们将会以最快的速度，最好的服务态度为您解决问题。
 *
 * eoLinker AMS开源版的开源协议遵循Apache License 2.0，如需获取最新的eolinker开源版以及相关资讯，请访问:https://www.eolinker.com/#/os/download
 *
 * 官方网站：https://www.eolinker.com/
 * 官方博客以及社区：http://blog.eolinker.com/
 * 使用教程以及帮助：http://help.eolinker.com/
 * 商务合作邮箱：market@eolinker.com
 * 用户讨论QQ群：284421832
 */
class AutomatedTestCaseGroupDao
{

    /**
     * 添加分组
     * @param $project_id
     * @param $group_name
     * @return bool
     */
    public function addGroup(&$project_id, &$group_name)
    {
        $db = getDatabase();

        $db->prepareExecute('INSERT INTO eo_project_test_case_group (eo_project_test_case_group.groupName,eo_project_test_case_group.projectID) VALUES (?,?);', array(
            $group_name,
            $project_id,
        ));

        if ($db->getAffectRow() > 0)
            return $db->getLastInsertID();
        else
            return FALSE;
    }


    /**
     * 添加子分组
     * @param $project_id
     * @param $group_name
     * @param $parent_group_id
     * @return bool
     */
    public function addChildGroup(&$project_id, &$group_name, &$parent_group_id)
    {
        $db = getDatabase();

        $db->prepareExecute('INSERT INTO eo_project_test_case_group (eo_project_test_case_group.groupName,eo_project_test_case_group.projectID,eo_project_test_case_group.parentGroupID,eo_project_test_case_group.isChild) VALUES (?,?,?,1);', array(
            $group_name,
            $project_id,
            $parent_group_id
        ));

        if ($db->getAffectRow() > 0)
            return $db->getLastInsertID();
        else
            return FALSE;
    }

    /**
     * 删除用例分组
     * @param $project_id
     * @param $group_id
     * @return bool
     */
    public function deleteGroup(&$project_id, &$group_id)
    {
        $db = getDatabase();
        try {
            $db->beginTransaction();
            $db->prepareExecuteAll('DELETE FROM eo_project_test_case_group WHERE eo_project_test_case_group.groupID = ? AND eo_project_test_case_group.projectID = ?;', array($group_id, $project_id));
            if ($db->getAffectRow() < 1)
                throw new \PDOException('delete error');
            $db->prepareExecuteAll('DELETE FROM eo_project_test_case_single WHERE eo_project_test_case_single.caseID IN (SELECT eo_project_test_case.caseID FROM eo_project_test_case WHERE eo_project_test_case.groupID = ?);', array(
                $group_id
            ));
            $db->prepareExecuteAll("DELETE FROM eo_project_test_case WHERE eo_project_test_case.groupID = ?;", array($group_id));
            $db->prepareExecuteAll('DELETE eo_project_test_case FROM eo_project_test_case INNER JOIN eo_project_test_case_group ON eo_project_test_case.groupID = eo_project_test_case_group.groupID  WHERE eo_project_test_case_group.parentGroupID = ?;', array($group_id));
            $db->prepareExecuteAll('DELETE FROM eo_project_test_case_group WHERE eo_project_test_case_group.parentGroupID = ?;', array($group_id));
            $db->commit();
            return TRUE;
        } catch (\PDOException $e) {
            $db->rollback();
            return FALSE;
        }
    }

    /**
     * 获取用例分组
     * @param $project_id
     * @return bool|array
     */
    public function getGroupList(&$project_id)
    {
        $db = getDatabase();
        $result = array();
        $group_list = $db->prepareExecuteAll('SELECT eo_project_test_case_group.groupID,eo_project_test_case_group.groupName FROM eo_project_test_case_group WHERE eo_project_test_case_group.projectID = ? AND eo_project_test_case_group.isChild = 0 ORDER BY  eo_project_test_case_group.groupName ASC;', array($project_id));

        //检查是否含有子分组
        if (is_array($group_list)) {
            foreach ($group_list as &$parentGroup) {
                $parentGroup['childGroupList'] = array();
                $childGroup = $db->prepareExecuteAll('SELECT eo_project_test_case_group.groupID,eo_project_test_case_group.groupName,eo_project_test_case_group.parentGroupID FROM eo_project_test_case_group WHERE eo_project_test_case_group.projectID = ? AND eo_project_test_case_group.isChild = 1 AND eo_project_test_case_group.parentGroupID = ? ORDER BY eo_project_test_case_group.groupName ASC;', array(
                    $project_id,
                    $parentGroup['groupID']
                ));

                //判断是否有子分组
                if (!empty($childGroup))
                    $parentGroup['childGroupList'] = $childGroup;
            }
        }

        $result['groupList'] = $group_list;
        $group_order = $db->prepareExecute('SELECT eo_project_test_case_group_order.orderList FROM eo_project_test_case_group_order WHERE eo_project_test_case_group_order.projectID = ?;', array(
            $project_id
        ));
        $result['groupOrder'] = $group_order['orderList'];

        if (empty($group_list))
            return FALSE;
        else
            return $result;
    }

    /**
     * 修改用例分组
     * @param $project_id
     * @param $group_id
     * @param $group_name
     * @param $parent_group_id
     * @return bool
     */
    public function editGroup(&$project_id, &$group_id, &$group_name, &$parent_group_id)
    {
        $db = getDatabase();

        //如果没有父分组
        if ($parent_group_id <= 0) {
            $db->prepareExecute('UPDATE eo_project_test_case_group SET eo_project_test_case_group.groupName = ?,eo_project_test_case_group.parentGroupID = 0,eo_project_test_case_group.isChild = 0 WHERE eo_project_test_case_group.groupID = ? AND eo_project_test_case_group.projectID = ?;', array(
                $group_name,
                $group_id,
                $project_id
            ));
        } else {
            //有父分组
            $db->prepareExecute('UPDATE eo_project_test_case_group SET eo_project_test_case_group.groupName = ?,eo_project_test_case_group.parentGroupID = ?,eo_project_test_case_group.isChild = 1 WHERE eo_project_test_case_group.groupID = ? AND eo_project_test_case_group.projectID = ?;', array(
                $group_name,
                $parent_group_id,
                $group_id,
                $project_id
            ));
        }

        if ($db->getAffectRow() > 0)
            return TRUE;
        else
            return FALSE;
    }

    /**
     * 获取分组名称
     * @param $group_id
     * @return bool
     */
    public function getGroupName($group_id)
    {
        $db = getDatabase();
        $result = $db->prepareExecute("SELECT eo_project_test_case_group.groupName FROM eo_project_test_case_group WHERE eo_project_test_case_group.groupID = ?;", array($group_id));

        if (empty($result))
            return FALSE;
        else
            return $result['groupName'];
    }

    /**
     * 更新分组排序
     * @param $project_id
     * @param $order_list
     * @return bool
     */
    public function updateGroupOrder(&$project_id, &$order_list)
    {
        $db = getDatabase();
        $db->prepareExecute("REPLACE INTO eo_project_test_case_group_order(projectID,orderList)VALUES(?,?);", array($project_id, $order_list));
        if ($db->getAffectRow() > 0)
            return TRUE;
        else
            return FALSE;

    }

    /**
     * 检查分组权限
     * @param $group_id
     * @param $user_id
     * @return bool
     */
    public function checkAutomatedTestCaseGroupPermission(&$group_id, &$user_id)
    {
        $db = getDatabase();
        $result = $db->prepareExecute('SELECT eo_conn_project.projectID FROM eo_project_test_case_group INNER JOIN eo_conn_project ON eo_project_test_case_group.projectID = eo_conn_project.projectID WHERE eo_project_test_case_group.groupID = ? AND eo_conn_project.userID = ?;', array($group_id, $user_id));
        if (empty($result)) {
            return FALSE;
        } else {
            return $result['projectID'];
        }
    }

    /**
     * 获取用例分组数据
     * @param $group_id
     * @return array
     */
    public function getTestCaseGroupData(&$group_id)
    {
        $db = getDatabase();
        $result = array();
        $group_info = $db->prepareExecute('SELECT eo_project_test_case_group.groupName,eo_project_test_case_group.isChild FROM eo_project_test_case_group WHERE eo_project_test_case_group.groupID = ?;', array(
            $group_id
        ));
        $case_list = $db->prepareExecuteAll('SELECT eo_project_test_case.caseID,eo_project_test_case.caseName,eo_project_test_case.caseDesc,eo_project_test_case.caseType,eo_project_test_case.caseCode FROM eo_project_test_case WHERE eo_project_test_case.groupID = ?;', array(
            $group_id
        ));
        $result['groupName'] = $group_info['groupName'];
        if (is_array($case_list)) {
            foreach ($case_list as &$case) {
                $sing_case_list = $db->prepareExecuteAll('SELECT eo_project_test_case_single.connID,eo_project_test_case_single.caseData,eo_project_test_case_single.caseCode,eo_project_test_case_single.statusCode,eo_project_test_case_single.matchType,eo_project_test_case_single.matchRule,eo_project_test_case_single.apiName,eo_project_test_case_single.apiURI,eo_project_test_case_single.apiRequestType,eo_project_test_case_single.orderNumber FROM eo_project_test_case_single WHERE eo_project_test_case_single.caseID = ?;', array(
                    $case['caseID']
                ));
                $case['caseSingleList'] = $sing_case_list;
            }
            $result['caseList'] = $case_list;
        } else {
            $result['caseList'] = array();
        }
        $child_group_list = array();
        if ($group_info['isChild'] == 0) {
            $child_group_list = $db->prepareExecuteAll('SELECT eo_project_test_case_group.groupID,eo_project_test_case_group.groupName FROM eo_project_test_case_group WHERE eo_project_test_case_group.parentGroupID = ?;', array(
                $group_id
            ));
            if (is_array($child_group_list)) {
                foreach ($child_group_list as &$child_group_info) {
                    $child_case_list = $db->prepareExecuteAll('SELECT eo_project_test_case.caseID,eo_project_test_case.caseName,eo_project_test_case.caseDesc,eo_project_test_case.caseType,eo_project_test_case.caseCode FROM eo_project_test_case WHERE eo_project_test_case.groupID = ?;', array(
                        $child_group_info['groupID']
                    ));
                    if (is_array($child_case_list)) {
                        foreach ($child_case_list as &$child_case) {
                            $child_single_case_list = $db->prepareExecuteAll('SELECT eo_project_test_case_single.connID,eo_project_test_case_single.caseData,eo_project_test_case_single.caseCode,eo_project_test_case_single.statusCode,eo_project_test_case_single.matchType,eo_project_test_case_single.matchRule,eo_project_test_case_single.apiName,eo_project_test_case_single.apiURI,eo_project_test_case_single.apiRequestType,eo_project_test_case_single.orderNumber FROM eo_project_test_case_single WHERE eo_project_test_case_single.caseID = ?;', array(
                                $child_case['caseID']
                            ));
                            $child_case['caseSingleList'] = $child_single_case_list;
                        }
                        $child_group_info['caseList'] = $child_case_list;
                    } else {
                        $child_group_info['caseList'] = array();
                    }
                }
            } else {
                $child_group_list = array();
            }
        }
        $result['childGroupList'] = $child_group_list;
        return $result;
    }

    /**
     * 导入测试用例分组数据
     * @param $project_id
     * @param $user_id
     * @param $data
     * @return bool
     */
    public function importTestCaseGroup(&$project_id, &$user_id, &$data)
    {
        $db = getDatabase();
        try {
            $db->beginTransaction();
            $db->prepareExecute('INSERT INTO eo_project_test_case_group (groupName,projectID) VALUES (?,?);', array(
                $data['groupName'],
                $project_id
            ));
            if ($db->getAffectRow() < 1) {
                throw new \PDOException('insert group error');
            }
            $group_id = $db->getLastInsertID();
            if ($data['caseList']) {
                foreach ($data['caseList'] as $case) {
                    $db->prepareExecute('INSERT INTO eo_project_test_case(eo_project_test_case.projectID,eo_project_test_case.userID,eo_project_test_case.caseName,eo_project_test_case.caseDesc,eo_project_test_case.createTime,eo_project_test_case.updateTime,eo_project_test_case.caseType,eo_project_test_case.groupID,eo_project_test_case.caseCode)VALUES(?,?,?,?,?,?,?,?,?);', array(
                        $project_id,
                        $user_id,
                        $case['caseName'],
                        $case['caseDesc'],
                        date('Y-m-d H:i:s', time()),
                        date('Y-m-d H:i:s', time()),
                        $case['caseType'],
                        $group_id,
                        $case['caseCode']
                    ));

                    if ($db->getAffectRow() < 1)
                        throw new \PDOException("insert test case error");
                    $case_id = $db->getLastInsertID();
                    if ($case['caseSingleList']) {
                        foreach ($case['caseSingleList'] as $single_case) {
                            if ($single_case['matchType'] == 2) {
                                $match = array();
                                // 匹配<response[]>，当没有匹配结果的时候跳过
                                if (preg_match_all('#<response\[(\d+)\]#', $single_case['caseData'], $match) > 0) {
                                    // 遍历匹配结果，对原字符串进行多次替换
                                    foreach ($match[1] as $response_id) {
                                        for ($i = 0; $i < count($case['caseSingleList']); $i++) {
                                            if ($case['caseSingleList'][$i]['connID'] == $response_id) {
                                                $result = $db->prepareExecute("SELECT eo_project_test_case_single.connID FROM eo_project_test_case_single.eo_project_test_case_single WHERE eo_project_test_case_single.apiName = ? AND eo_project_test_case_single.apiURI = ? AND eo_project_test_case_single.caseID = ?;", array(
                                                    $case['caseSingleList'][$i]['apiName'],
                                                    $case['caseSingleList'][$i]['apiURI'],
                                                    $case_id
                                                ));
                                                $single_case['caseData'] = str_replace("<response[" . $response_id, "<response[" . $result['connID'], $single_case['caseData']);
                                            }
                                        }
                                    }
                                }
                            }
                            $db->prepareExecute('INSERT INTO eo_project_test_case_single(eo_project_test_case_single.caseID,eo_project_test_case_single.caseData,eo_project_test_case_single.caseCode,eo_project_test_case_single.statusCode,eo_project_test_case_single.matchType,eo_project_test_case_single.matchRule, eo_project_test_case_single.apiName, eo_project_test_case_single.apiURI, eo_project_test_case_single.apiRequestType,eo_project_test_case_single.orderNumber) VALUES (?,?,?,?,?,?,?,?,?,?);', array(
                                $case_id,
                                $single_case['caseData'],
                                $single_case['caseCode'],
                                $single_case['statusCode'],
                                $single_case['matchType'],
                                $single_case['matchRule'],
                                $single_case['apiName'],
                                $single_case['apiURI'],
                                $single_case['apiRequestType'],
                                $single_case['orderNumber']
                            ));
                            if ($db->getAffectRow() < 1)
                                throw new \PDOException('insert single test case error');
                        }
                    }
                }
            }
            if ($data['childGroupList']) {
                $group_id_parent = $group_id;
                foreach ($data['childGroupList'] as $child_group) {
                    // 插入分组
                    $db->prepareExecute('INSERT INTO eo_project_test_case_group (eo_project_test_case_group.projectID,eo_project_test_case_group.groupName,eo_project_test_case_group.parentGroupID,eo_project_test_case_group.isChild) VALUES (?,?,?,?);', array(
                        $project_id,
                        $child_group['groupName'],
                        $group_id_parent,
                        1
                    ));
                    if ($db->getAffectRow() < 1) {
                        throw new \PDOException("inset child group error");
                    }

                    $group_id = $db->getLastInsertID();
                    if ($child_group['caseList']) {
                        // 插入状态码
                        foreach ($child_group['caseList'] as $case) {
                            $db->prepareExecute('INSERT INTO eo_project_test_case(eo_project_test_case.projectID,eo_project_test_case.userID,eo_project_test_case.caseName,eo_project_test_case.caseDesc,eo_project_test_case.createTime,eo_project_test_case.updateTime,eo_project_test_case.caseType,eo_project_test_case.groupID,eo_project_test_case.caseCode)VALUES(?,?,?,?,?,?,?,?,?);', array(
                                $project_id,
                                $user_id,
                                $case['caseName'],
                                $case['caseDesc'],
                                date('Y-m-d H:i:s', time()),
                                date('Y-m-d H:i:s', time()),
                                $case['caseType'],
                                $group_id,
                                $case['caseCode']
                            ));

                            if ($db->getAffectRow() < 1)
                                throw new \PDOException("insert child test case error");
                            $case_id = $db->getLastInsertID();
                            if ($case['caseSingleList']) {
                                foreach ($case['caseSingleList'] as $single_case) {
                                    if ($single_case['matchType'] == 2) {
                                        $match = array();
                                        // 匹配<response[]>，当没有匹配结果的时候跳过
                                        if (preg_match_all('#<response\[(\d+)\]#', $single_case['caseData'], $match) > 0) {
                                            // 遍历匹配结果，对原字符串进行多次替换
                                            foreach ($match[1] as $response_id) {
                                                for ($i = 0; $i < count($case['caseSingleList']); $i++) {
                                                    if ($case['caseSingleList'][$i]['connID'] == $response_id) {
                                                        $result = $db->prepareExecute("SELECT eo_project_test_case_single.connID FROM eo_project_test_case_single WHERE eo_project_test_case_single.apiName = ? AND eo_project_test_case_single.apiURI = ? AND eo_project_test_case_single.caseID = ?;", array(
                                                            $case['caseSingleList'][$i]['apiName'],
                                                            $case['caseSingleList'][$i]['apiURI'],
                                                            $case_id
                                                        ));
                                                        $single_case['caseData'] = str_replace("<response[" . $response_id, "<response[" . $result['connID'], $single_case['caseData']);
                                                    }
                                                }
                                            }
                                        }
                                    }
                                    $db->prepareExecute('INSERT INTO eo_project_test_case_single(eo_project_test_case_single.caseID,eo_project_test_case_single.caseData,eo_project_test_case_single.caseCode,eo_project_test_case_single.statusCode,eo_project_test_case_single.matchType,eo_project_test_case_single.matchRule, eo_project_test_case_single.apiName, eo_project_test_case_single.apiURI, eo_project_test_case_single.apiRequestType,eo_project_test_case_single.orderNumber) VALUES (?,?,?,?,?,?,?,?,?,?);', array(
                                        $case_id,
                                        $single_case['caseData'],
                                        $single_case['caseCode'],
                                        $single_case['statusCode'],
                                        $single_case['matchType'],
                                        $single_case['matchRule'],
                                        $single_case['apiName'],
                                        $single_case['apiURI'],
                                        $single_case['apiRequestType'],
                                        $single_case['orderNumber']
                                    ));
                                    if ($db->getAffectRow() < 1)
                                        throw new \PDOException('insert child single test case error');
                                }
                            }
                        }
                    }
                }
            }
            $db->commit();
            return TRUE;
        } catch (\PDOException $e) {
            $db->rollback();
            return FALSE;
        }
    }
}