<?php

require_once('mt/Item.php');
require_once('mt/Parameter.php');
require_once('mt/Language.php');
require_once('mt/MapMode.php');
require_once('models/InGameMall.php');

require_once('services/MailApiService.php');


use phpcommon\SqlHelper;
use models\InGameMall;

class TempToolsController extends BaseController {

    public function _handlePre()
    {
        parent::_handlePre();
    }

    public function test()
    {

    }

    public function getBattleData()
    {
        $targetId = getReqVal('target_id', '');
        $time = getReqVal('time', '');
        $conn = myself()->_getMysql($targetId);
        $data = array();
        $survivalTime = 0;
        $sameTimes = 0;
        $sessionChgTimes = 0;
        {
            $rows = SqlHelper::ormSelect(
                $conn,
                't_battle_record',
                array(
                    'account_id' => $targetId
                )
            );
            foreach ($rows as $row) {
                $reqObj = json_decode($row['request'], true);
                $reqObj['start_time'] = $reqObj['game_time'] -
                                      $reqObj['alive_time']/1000;
                $survivalTime += $reqObj['alive_time']/1000;
                array_push($data, $reqObj);
            }
        }
        usort($data, function ($a, $b) {
            return $a['start_time'] < $b['start_time'] ? -1 : 1;
        });
        $lastSessionId = '';
        {
            for ($i = 0; $i < count($data); ++$i){
                if ($i + 1 >= count($data)) {
                    break;
                }
                if ($data[$i]['start_time'] + $time > $data[$i + 1]['start_time']) {
                    ++$i;
                    ++$sameTimes;
                }
                if ($lastSessionId) {
                    if ($lastSessionId != $data[$i]['session_id']) {
                        ++$sessionChgTimes;
                        $lastSessionId = $data[$i]['session_id'];
                    }
                } else {
                    $lastSessionId = $data[$i]['session_id'];
                }
            }
        }
        myself()->_rspData(array(
            'battle_times' => count($data),
            'same_times' => $sameTimes,
            'session_chg_times' => $sessionChgTimes,
            'survival_time' => $survivalTime,
            'data' => $data
        ));
    }

    public function exportRankActivity()
    {
        $type = getReqVal('type', '');
        $count = getReqVal('count', '');
        $cond = getReqVal('cond', 0);
        $accounts = array();
        $conn = myself()->_getMysql('');
        {
            $rows = $conn->execQuery(
                'SELECT * FROM t_rank_activity ' .
                'WHERE type=:type AND channel=:channel AND value>=:value ' .
                'ORDER BY value DESC, modifytime ASC ' .
                "LIMIT ${count}",
                array(
                    ':type' => $type,
                    ':channel' => 6516,
                    ':value' => $cond
                )
            );
            $ranked = 1;
            foreach ($rows as $row) {
                array_push($accounts, array(
                    'account_id' => $row['account_id'],
                    'name' => '',
                    'ranked' => $ranked,
                    'score' => $row['value'],
                    'modifytime' => $row['modifytime']
                ));
                ++$ranked;
            }
        }
        {
            foreach ($accounts as &$account) {
                $row = SqlHelper::ormSelectone(
                    $conn,
                    't_user',
                    array(
                        'account_id' => $account['account_id']
                    )
                );
                $account['name'] = $row['name'];
            }
        }
        {
            foreach ($accounts as &$account) {
                $row = $conn->execQueryOne(
                    'SELECT MAX(hero_lv) AS max_hero_lv FROM t_hero WHERE account_id=:account_id',
                    array(
                        ':account_id' => $account['account_id'],
                    )
                );
                $account['max_hero_lv'] = $row['max_hero_lv'];
            }
        }
        {
            foreach ($accounts as &$account) {
                $row = $conn->execQueryOne(
                    'SELECT MAX(quality) AS max_hero_quality FROM t_hero WHERE account_id=:account_id',
                    array(
                        ':account_id' => $account['account_id'],
                    )
                );
                $account['max_hero_quality'] = $row['max_hero_quality'];
            }
        }
        echo 'account_id,name,rank,score,max_hero_lv,max_hero_quality,flag, time' . "\n";
        foreach ($accounts as $account) {
            $flag = 0;
            if ($type == 3) {
                $flag = $account['max_hero_lv'] != $account['score'] ? 1 : 0;
            }
            if ($type == 4) {
                $flag = $account['max_hero_quality'] != $account['score'] ? 1 : 0;
            }
            echo
                phpcommon\extractOpenId($account['account_id']) . ','
                . $account['name'] . ','
                . $account['ranked'] . ','
                . $account['score'] . ','
                . $account['max_hero_lv'] . ','
                . $account['max_hero_quality'] . ','
                . $flag . ','
                . phpcommon\timestamp_to_datetime($account['modifytime'])
                . "\n";
        }
    }

    public function getRiskAccounts()
    {
        $accounts = array();
        $conn = myself()->_getMysql('');
        {
            $count = 1000;
            $rows = $conn->execQuery(
                'SELECT * FROM t_rank_activity ' .
                'WHERE type=:type AND channel=:channel AND value>=:value ' .
                'ORDER BY value DESC, modifytime ASC ' .
                "LIMIT ${count}",
                array(
                    ':type' => 1,
                    ':channel' => 6516,
                    ':value' => 600
                )
            );
            $ranked = 1;
            foreach ($rows as $row) {
                array_push($accounts, array(
                    'account_id' => $row['account_id'],
                    'ranked' => $ranked
                ));
                ++$ranked;
            }
        }
        $riskAccountHash = array();
        foreach ($accounts as $account) {
            $rows = SqlHelper::ormSelect(
                $conn,
                't_battle_record',
                array(
                    'account_id' => $account['account_id']
                )
            );
            $sessionChgTimes = 0;
            $lastSessionId = '';
            foreach ($rows as $row) {
                $reqObj = json_decode($row['request'], true);
                if ($lastSessionId) {
                    if ($lastSessionId != $reqObj['session_id']) {
                        ++$sessionChgTimes;
                        $lastSessionId = $reqObj['session_id'];
                    }
                } else {
                    $lastSessionId = $reqObj['session_id'];
                }
            }
            $account['session_changed_times'] = $sessionChgTimes;
            array_push($riskAccountHash, $account);
        }
        usort($riskAccountHash, function ($a, $b) {
            return $a['session_changed_times'] > $b['session_changed_times'] ? -1 : 1;
        });
        echo 'account_id,rank,session_changed_times' . "\n";
        foreach ($riskAccountHash as $account) {
            echo $account['account_id'] . ',' . $account['ranked'] . ',' . $account['session_changed_times'] . "\n";
        }
    }

    public function exportData()
    {
        $type = getReqVal('type', '');
        if ($type == 1) {
            $this->exportData1();
        } else if($type == 2) {
            $this->exportData2();
        } else if($type == 3) {
            $this->exportData3();
        }
    }

    public function exportData1()
    {
        $type = getReqVal('type', '');
        $accounts = array();
        $conn = myself()->_getMysql('');
        {
            $rows = $conn->execQuery(
                'SELECT * FROM t_battle',
                array(
                )
            );
            echo 'account_id,first_battle_utc_time' . "\n";
            foreach ($rows as $row) {
                $channel = phpcommon\extractChannel($row['account_id']);
                if ($channel == 6516) {
                    echo phpcommon\extractOpenId($row['account_id'])
                        . ',' . phpcommon\timestamp_to_datetime($row['createtime']) . "\n";
                }
            }
        }
    }

    public function exportData2()
    {
        $type = getReqVal('type', '');
        $accounts = array();
        $conn = myself()->_getMysql('');
        {
            $rows = $conn->execQuery(
                'SELECT * FROM t_user',
                array(
                )
            );
            echo 'account_id' . "\n";
            foreach ($rows as $row) {
                $channel = phpcommon\extractChannel($row['account_id']);
                if ($channel == 6516) {
                    echo $row['account_id'] . "\n";
                }
            }
        }
    }

    public function exportData3()
    {
        $type = getReqVal('type', '');
        $accounts = array();
        $conn = myself()->_getMysql('');
        {
            $rows = $conn->execQuery(
                'SELECT * FROM t_dyndata WHERE x=:x AND y=:y',
                array(
                    ':x' => TN_ACTIVE,
                    ':y' => 0,
                )
            );
            echo 'account_id' . ",name,active>=10,active>=30,active>=50,active_value\n";
            foreach ($rows as $row) {
                $channel = phpcommon\extractChannel($row['account_id']);
                if ($channel == 6516) {
                    $userDb = SqlHelper::ormSelectone(
                        $conn,
                        't_user',
                        array(
                            'account_id' => $row['account_id']
                        )
                    );
                    echo
                        $row['account_id'] . ','
                        . ($userDb ? $userDb['name'] : '') . ','
                        . ($row['val'] >= 10 && $row['val'] < 30 ? 1 :0) . ','
                        . ($row['val'] >= 30 && $row['val'] < 50 ? 1 :0) . ','
                        . ($row['val'] >= 50 ? 1 :0) . ','
                        . $row['val'] . ','
                        . "\n";
                }
            }
        }
    }

    public function exportLock()
    {
        $beginTime = getReqVal('begin_time', '0');
        $endTime = getReqVal('end_time', '0');
        $type = getReqVal('type', '0');
        $bceventConn = null;
        $accountConn = null;
        {
            $mysql_conf = getMysqlConfig(crc32(''));
            if (SERVER_ENV == _ONLINE) {
                $mysql_conf['database'] = 'bcevent_prod_1';
            } else {
                $mysql_conf['database'] = 'bcevent_dev';
            }
            $bceventConn = new phpcommon\Mysql(array(
                'host' => $mysql_conf['host'],
                'port' => $mysql_conf['port'],
                'user' => $mysql_conf['user'],
                'passwd' => $mysql_conf['passwd'],
                'dbname' => $mysql_conf['database'],
            ));
        }
        {
            $mysql_conf = getMysqlConfig(crc32(''));
            if (SERVER_ENV == _ONLINE) {
                $mysql_conf['database'] = 'accountdb_prod_1';
            } else {
                $mysql_conf['database'] = 'accountdb1';
            }
            $accountConn = new phpcommon\Mysql(array(
                'host' => $mysql_conf['host'],
                'port' => $mysql_conf['port'],
                'user' => $mysql_conf['user'],
                'passwd' => $mysql_conf['passwd'],
                'dbname' => $mysql_conf['database'],
            ));
        }
        $heroContractAddress = '\"' . HERO_CONTRACT_ADDRESS . '\"';
        if ($type == 0) {
            $sql = "select lock_to, count(idx) as lock_count from t_nft_lock_event where createtime>=$beginTime and createtime<=$endTime and lower(JSON_EXTRACT(convert(return_values using utf8), '$.nft'))='$heroContractAddress' group by lock_to;";
        } else {
            $sql = "select lock_to, count(idx) as lock_count from t_nft_lock_event where createtime>=$beginTime and createtime<=$endTime group by lock_to;";
        }
        $rows = $bceventConn->execQuery($sql);
        foreach ($rows as $row) {
            $email = $this->getAddressEmail($accountConn, $row['lock_to']);
            echo $row['lock_to'] . ',' . $email . ',' . $row['lock_count'] . "\n";
        }
    }

    private function getAddressEmail($accountConn, $accountAddress)
    {
        $row = $accountConn->execQueryOne('select * from t_immutable_account where address=:address',
                                          array(
                                              'address' => $accountAddress
                                          ));
        //        error_log(json_encode($row));
        if (!empty($row)) {
            $dataJson = json_decode($row['data'], true);
            return $dataJson['decoded']['email'];
        } else {
            return '';
        }
    }

    public function repairInGameMallMail()
    {
        $gameDbConn = myself()->_getMysql('');
        $mailDbConn = myself()->_getMailMysql();
        $rows = $gameDbConn->execQuery(
            'SELECT * FROM t_ingame_mall WHERE status=:status AND buy_ok_time<:buy_ok_time',
            array(
                'status' => InGameMall::BUY_OK_STATE,
                'buy_ok_time' => myself()->_getNowDaySeconds(),
            )
        );
        $mailApiService = new \services\MailApiService();
        foreach ($rows as $row) {
            $goods = $row;
            $price = $row['price'];
            //发邮件给卖家
            $itemMeta = \mt\Item::get($goods['item_id']);
            $languageMeta = \mt\Language::get($itemMeta['name']);
            $itemName = $languageMeta ? $languageMeta['en'] : "The Item";
            $taxRate = \mt\Parameter::getVal("market_place_tax_rate",0.05);
            $taxGold = ceil($price*$taxRate);
            $falGold = $price - $taxGold;

            $mailContent = <<<EOD
    {$itemName} has been successfully sold
        Transaction price: + {$price} gold
            Service fee: - {$taxGold} gold
After selling {$itemName}, you received {$falGold} gold
EOD;
            $attachments = array(
                array(
                    'itemid' => V_ITEM_GOLD,
                    'itemnum' => $falGold
                )
            );
            echo $mailContent;
            $mailApiService->sendSellMail(
                $goods['order_id'],
                $goods['seller'],
                \services\MailApiService::SELL_MAIL_SUBJECT,
                $mailContent,
                $attachments
            );
        }
    }

    public function exportBattleLog()
    {
        $accountConn = null;
        {
            $mysql_conf = getMysqlConfig(crc32(''));
            if (SERVER_ENV == _ONLINE) {
                $mysql_conf['database'] = 'accountdb_prod_1';
            } else {
                $mysql_conf['database'] = 'accountdb1';
            }
            $accountConn = new phpcommon\Mysql(array(
                'host' => $mysql_conf['host'],
                'port' => $mysql_conf['port'],
                'user' => $mysql_conf['user'],
                'passwd' => $mysql_conf['passwd'],
                'dbname' => $mysql_conf['database'],
            ));
        }
        $data = file_get_contents('php://input');
        $array = explode("\r\n", $data);
        foreach ($array as $accountId) {
            $row = SqlHelper::ormSelectOne(
                $accountConn,
                't_immutable_account',
                array(
                    'account_id' => $accountId
                )
            );
            if (empty($row)) {
                echo "\n";
            } else {
                echo $row['address'] . "\n";
            }
        }
    }

    public function importRewardPunish()
    {
        $rewardHash = require('../res/reward070901@reward070901.php');
        $gameDbConn = myself()->_getMysql('');
        {
            foreach ($rewardHash as $item) {
                $userExists = false;
                {
                    $row = SqlHelper::ormSelectOne(
                        $gameDbConn,
                        't_user',
                        array(
                            'account_id' => $item['account_id']
                        )
                    );
                    $userExists = !empty($row);
                }
                SqlHelper::upsert(
                    $gameDbConn,
                    't_test_reward070901',
                    array(
                        'account_id' => $item['account_id'],
                    ),
                    array(),
                    array(
                        'account_id' => $item['account_id'],
                        'account_address' => $item['account_address'],
                        'enter_times' => $item['enter_times'],
                        'dec_times' => $item['dec_times'],
                        'return_num' => $item['return_num'],
                        'user_exists' => $userExists ? 1 : 0,
                        'createtime' => myself()->_getNowTime(),
                        'modifytime' => myself()->_getNowTime(),
                    )
                );
            }
        }
        $punishHash = require('../res/punish070901@punish070901.php');
        {
            foreach ($punishHash as $item) {
                $userExists = false;
                {
                    $row = SqlHelper::ormSelectOne(
                        $gameDbConn,
                        't_user',
                        array(
                            'account_id' => $item['account_id']
                        )
                    );
                    $userExists = !empty($row);
                }
                SqlHelper::upsert(
                    $gameDbConn,
                    't_test_punish070901',
                    array(
                        'account_id' => $item['account_id'],
                    ),
                    array(),
                    array(
                        'account_id' => $item['account_id'],
                        'account_address' => $item['account_address'],
                        'gold' => $item['gold'],
                        'user_exists' => $userExists ? 1 : 0,
                        'createtime' => myself()->_getNowTime(),
                        'modifytime' => myself()->_getNowTime(),
                    )
                );
            }
        }
        echo json_encode(array(
            'reward' => $rewardHash,
            'punish' => $punishHash,
        ));
    }

    public function punish()
    {
        return;
       $gameDbConn = myself()->_getMysql('');
        $rows = SqlHelper::ormSelect(
            $gameDbConn,
            't_test_punish070901',
            array(
            )
        );
        foreach ($rows as $row) {
            if ($row['user_exists'] && $row['gold'] > 0 && $row['pre_send'] == 0) {
                $itemNum = $row['gold'];
                $srcGold = $this->getUserGold($gameDbConn, $row['account_id']);
                echo $row['account_id'], $srcGold,1;
                SqlHelper::update(
                    $gameDbConn,
                    't_test_punish070901',
                    array(
                        'account_id' => $row['account_id'],
                    ),
                    array(
                        'pre_send' => 1,
                        'src_gold' => $srcGold,
                    )
                );
                SqlHelper::update(
                    $gameDbConn,
                    't_user',
                    array(
                        'account_id' => $row['account_id'],
                    ),
                    array(
                        'gold' => function () use($itemNum) {
                            return "gold - ${itemNum}";
                        },
                    )
                );
                SqlHelper::update(
                    $gameDbConn,
                    't_test_punish070901',
                    array(
                        'account_id' => $row['account_id'],
                    ),
                    array(
                        'post_send' => 1
                    )
                );
            }
        }
        echo 'ok';
    }

    private function getUserGold($gameDbConn, $accountId)
    {
        $row = SqlHelper::ormSelectOne(
            $gameDbConn,
            't_user',
            array(
                'account_id' => $accountId,
            )
        );
        return empty($row) ? 0 : $row['gold'];
    }

    public function reward()
    {
        return;
        $gameDbConn = myself()->_getMysql('');
        $rows = SqlHelper::ormSelect(
            $gameDbConn,
            't_test_reward070901',
            array(
            )
        );
        foreach ($rows as $row) {
            if ($row['pre_send'] == 0) {
                SqlHelper::update(
                    $gameDbConn,
                    't_test_reward070901',
                    array(
                        'account_id' => $row['account_id'],
                    ),
                    array(
                        'pre_send' => 1
                    )
                );
                $this->sendRewardMail($row['account_id'], $row['return_num']);
                SqlHelper::update(
                    $gameDbConn,
                    't_test_reward070901',
                    array(
                        'account_id' => $row['account_id'],
                    ),
                    array(
                        'post_send' => 1
                    )
                );
            }
        }
        echo 'ok';
    }

    private function sendRewardMail($to, $itemNum)
    {
        $unikey = 'reward:070901:' . $to;
        SqlHelper::upsert
            (myself()->_getMailMysql(),
             't_sys_mail',
             array(
                 'unikey' => $unikey
             ),
             array(
             ),
             array(
                 'unikey' => $unikey,
                 'subject' => 'reward',
                 'content' => 'reward',
                 'recipients' => json_encode(array(
                     $to
                 )),
                 'attachments' => json_encode(array(
                     array(
                         'itemid' => 900006,
                         'itemnum' => intval($itemNum),
                     )
                 )),
                 'tag1' => 1,
                 'tag2' => 2,
                 'sendtime' => myself()->_getNowTime(),
                 'expiretime' => myself()->_getNowTime() + 3600 * 24 * 365 * 20,
                 'user_reg_start_time' => 0,
                 'user_reg_end_time' => myself()->_getNowTime() + 3600 * 24 * 365 * 10,
                 'createtime' => myself()->_getNowTime(),
                 'modifytime' => myself()->_getNowTime()
             )
            );
    }

    public function returnGoldBullion()
    {
        $gameDbConn = myself()->_getMysql('');
        $data = file_get_contents('php://input');
        $array = explode("\r\n", $data);
        foreach ($array as $accountId) {
            $rows = SqlHelper::ormSelect(
                $gameDbConn,
                't_gold_bullion',
                array(
                    'src_account_id' => $accountId
                )
            );
            foreach ($rows as $row) {
                if (!$this->isReturnEd($row)) {
                    $this->doReturn($gameDbConn, $row);
                }
            }
        }
        echo 'ok';
    }

    private function isReturnEd($row)
    {
        if ($row['activated']) {
            return true;
        }
        if ($row['status']) {
            return true;
        }
        if ($row['returned']) {
            return true;
        }
        if ($row['open_status']) {
            return true;
        }
        if ($row['createtime'] > (myself()->_getNowTime() - 3600 * 25)) {
            return true;
        }
        return false;
    }

    private function doReturn($gameDbConn, $row)
    {
        echo json_encode($row);
        {
            $tmpRow = SqlHelper::ormSelectOne(
                $gameDbConn,
                't_gold_bullion_return',
                array(
                    'token_id' => $row['token_id'],
                )
            );
            if (!empty($tmpRow)) {
                return;
            }
        }
        {
            SqlHelper::upsert(
                $gameDbConn,
                't_gold_bullion_return',
                array(
                    'token_id' => $row['token_id'],
                ),
                array(),
                array(
                    'account_id' => $row['src_account_id'],
                    'token_id' => $row['token_id'],
                    'net_id' => $row['net_id'],
                    'item_id' => $row['item_id'],
                    'gold' => $row['gold'],
                    'createtime' => myself()->_getNowTime(),
                    'modifytime' => myself()->_getNowTime(),
                )
            );
        }
        {
            SqlHelper::update(
                $gameDbConn,
                't_gold_bullion',
                array(
                    'idx' => $row['idx'],
                ),
                array(
                    'return_status' => 1,
                    'returned' => 1,
                    'return_time' => myself()->_getNowTime(),
                )
            );
        }
        {
            $itemNum = $row['gold'];
            if ($itemNum < 0) {
                return;
            }
            SqlHelper::update(
                $gameDbConn,
                't_user',
                array(
                    'account_id' => $row['src_account_id'],
                ),
                array(
                    'gold' => function () use($itemNum) {
                        return "gold + ${itemNum}";
                    },
                )
            );
        }
        $this->sendReturnMail($row['src_account_id'], $row['token_id'], $row['gold']);
        {
            SqlHelper::update(
                $gameDbConn,
                't_gold_bullion',
                array(
                    'idx' => $row['idx'],
                ),
                array(
                    'return_status' => 2,
                )
            );
        }
    }

    private function sendReturnMail($to, $tokenId, $itemNum)
    {
        $unikey = 'gold_return:' . $to . ":" . $tokenId;
        SqlHelper::upsert
            (myself()->_getMailMysql(),
             't_sys_mail',
             array(
                 'unikey' => $unikey
             ),
             array(
             ),
             array(
                 'unikey' => $unikey,
                 'subject' => 'reward',
                 'content' => 'We regret to inform you that the minting of your Gold Card has failed. The gold has been refunded to your account. Please check your balance to confirm the refund.',
                 'recipients' => json_encode(array(
                     $to
                 )),
                 'attachments' => json_encode(array(
                 )),
                 'tag1' => 1,
                 'tag2' => 3,
                 'sendtime' => myself()->_getNowTime(),
                 'expiretime' => myself()->_getNowTime() + 3600 * 24 * 365 * 20,
                 'user_reg_start_time' => 0,
                 'user_reg_end_time' => myself()->_getNowTime() + 3600 * 24 * 365 * 10,
                 'createtime' => myself()->_getNowTime(),
                 'modifytime' => myself()->_getNowTime()
             )
            );
    }

    public function dumpSqlMigrate()
    {
        $conn = $this->_getMysql('');
        $heroSql = $this->dumpMigrateTable($conn, 't_hero', 'gamedb2006_prod_1_20240822.t_hero', 'WHERE activate=1');
        $mailSql = $this->dumpMigrateTable($conn, 't_mail', 'gamedb2006_prod_1_20240822.t_mail', '');
        $goldBullionSql = $this->dumpMigrateTable($conn, 't_gold_bullion', 'gamedb2006_prod_1_20240822.t_gold_bullion', '');
        echo $heroSql;
        echo "\n";
        echo $mailSql;
        echo "\n";
        echo $goldBullionSql;
    }

    public function testMapMode()
    {
        $modeId = getReqVal('mode_id', 0);
        $mapModeMeta = mt\MapMode::find($modeId);
        myself()->_rspData(array(
            'is_open' => mt\MapMode::checkLimitTime($mapModeMeta)
        ));
    }

    private function dumpMigrateTable($conn, $trgTblName, $srcTblName, $whereSql)
    {
        $Fields = $conn->execQuery("show columns from ${trgTblName}");
        $inited = false;
        $sql = "INSERT INTO ${trgTblName} (";
        foreach ($Fields as $field) {
            if ($field['Field'] == 'idx') {
                continue;
            }
            if (!$inited) {
                $inited = true;
                $sql .= $field['Field'];
            } else {
                $sql .= ',' . $field['Field'];
            }
        }
        $sql .= ') SELECT ';
        $inited = false;
        foreach ($Fields as $field) {
            if ($field['Field'] == 'idx') {
                continue;
            }
            if (!$inited) {
                $inited = true;
                $sql .= $field['Field'];
            } else {
                $sql .= ',' . $field['Field'];
            }
        }
        $sql .= " FROM ${srcTblName} " . $whereSql . ";";
        return $sql;
    }

}