iapt-platform
/
mint
зеркало из https://github.com/iapt-platform/mint.git


			
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387
							<?php
/*拷贝其他人的文件
 *
 *
 */
require_once __DIR__."/../public/_pdo.php";
require_once __DIR__."/../public/function.php";
require_once __DIR__."/../config.php";
require_once __DIR__."/../public/snowflakeid.php";
$snowflake = new SnowFlakeId();
require_once __DIR__.'/../studio/index_head.php';

?>
<body id="file_list_body" >
<?php

require_once __DIR__."/../studio/index_tool_bar.php";

echo '<div class="index_inner" style="    margin-left: 18em;margin-top: 5em;">';

if ($_COOKIE["uid"]) {
    $uid = $_COOKIE["uid"];
} else {
    echo "尚未登录";
    echo "<h3><a href='../ucenter/index.php?op=login'>登录</a>后才可以打开文档 </h3>";
    exit;
}
if (isset($_GET["doc_id"]) == false) {
    echo "没有 文档编号";
    exit;
}
PDO_Connect( _FILE_DB_FILEINDEX_);
$doc_id = $_GET["doc_id"];
$query = "SELECT * from "._TABLE_FILEINDEX_." where uid= ? ";
$Fetch = PDO_FetchAll($query, array($doc_id));
$iFetch = count($Fetch);
if ($iFetch > 0) {
    //文档信息
    $mbook = $Fetch[0]["book"];
    $paragraph = $Fetch[0]["paragraph"];
}

if (isset($_GET["channel"]) == false) {
    echo '<div class="file_list_block">';
    echo "<h2>选择一个空白的版风存储新的文档</h2>";
    echo "<form action='fork.php' method='get'>";
    echo "<input type='hidden' name='doc_id' value='{$_GET["doc_id"]}' />";
    PDO_Connect( _FILE_DB_CHANNAL_,_DB_USERNAME_,_DB_PASSWORD_);
    $query = "SELECT uid,name,lang,status,create_time from "._TABLE_CHANNEL_." where owner_uid = ?   limit 100";
    $Fetch = PDO_FetchAll($query,$_COOKIE["user_uid"]);
    $i = 0;
    foreach ($Fetch as $row) {
        echo '<div class="file_list_row" style="padding:5px;display:flex;">';

        echo '<div class="pd-10"  style="max-width:2em;flex:1;">';
        echo '<input name="channel" value="' . $row["uid"] . '" ';
        if ($i == 0) {
            echo "checked";
        }
        echo ' type="radio" />';
        echo '</div>';
        echo '<div class="title" style="flex:3;padding-bottom:5px;">' . $row["name"] . '</div>';
        echo '<div class="title" style="flex:3;padding-bottom:5px;">' . $row["lang"] . '</div>';
        echo '<div class="title" style="flex:2;padding-bottom:5px;">';
        PDO_Connect(_FILE_DB_USER_WBW_);
        $query = "SELECT count(*) from "._TABLE_USER_WBW_BLOCK_." where channel_uid = '{$row["uid"]}' and book_id='{$mbook}' and paragraph in ({$paragraph})  limit 100";
        $FetchWBW = PDO_FetchOne($query);
        echo '</div>';
        echo '<div class="title" style="flex:2;padding-bottom:5px;">';
        if ($FetchWBW == 0) {
            echo $_local->gui->blank;
        } else {
            echo $FetchWBW . $_local->gui->para;
            echo "<a href='../studio/editor.php?op=openchannal&book=$book&para={$paraList}&channal={$row["uid"]}'>open</a>";
        }
        echo '</div>';

        echo '<div class="title" style="flex:2;padding-bottom:5px;">';
        PDO_Connect(_FILE_DB_SENTENCE_,_DB_USERNAME_,_DB_PASSWORD_);
        $query = "SELECT count(*) from "._TABLE_SENTENCE_." where channel_uid = ? and book_id=? and paragraph in ({$paragraph})  limit 1000";
        $FetchWBW = PDO_FetchOne($query,array($row["uid"],$mbook));
        echo '</div>';
        echo '<div class="title" style="flex:2;padding-bottom:5px;">';
        if ($FetchWBW == 0) {
            echo $_local->gui->blank;
        } else {
            echo $FetchWBW . $_local->gui->para;
        }
        echo '</div>';

        echo '<div class="summary"  style="flex:1;padding-bottom:5px;">' . $row["status"] . '</div>';
        echo '<div class="author"  style="flex:1;padding-bottom:5px;">' . $row["create_time"] . '</div>';

        echo '</div>';
        $i++;
    }
    echo "<input type='submit' />";
    echo "</form>";
    echo "</div>";
    exit;
}

//if(isset($_GET["doc_id"]))
{
    PDO_Connect( _FILE_DB_FILEINDEX_,_DB_USERNAME_,_DB_PASSWORD_);
    $doc_id = $_GET["doc_id"];
    $query = "SELECT * from "._TABLE_FILEINDEX_." where uid= ? ";
    $Fetch = PDO_FetchAll($query, array($doc_id));
    $iFetch = count($Fetch);
    if ($iFetch > 0) {
        //文档信息
        $orgFileInfo = $Fetch[0];
        $owner = $Fetch[0]["user_id"];
        $filename = $Fetch[0]["file_name"];
        $title = $Fetch[0]["title"];
        $tag = $Fetch[0]["tag"];
        $mbook = $Fetch[0]["book"];
        $paragraph = $Fetch[0]["paragraph"];

        if ($owner == $uid) {
            //自己的文档
            echo "这是自己的文档，不能复刻。";
        } else {
            //别人的文档
            //查询自己是否以前打开过
            $query = "SELECT * from "._TABLE_FILEINDEX_." where parent_id='{$doc_id}' and user_id='{$uid}' ";
            $FetchSelf = PDO_FetchAll($query);
            $iFetchSelf = count($FetchSelf);
            if ($iFetchSelf > 0) {
                //以前打开过
                echo "文档已经复刻";
                echo "正在<a href='../studio/editor.php?op=opendb&doc_id={$doc_id}'>打开</a>文档";
                echo "<script>";
                echo "window.location.assign(\"../studio/editor.php?op=opendb&doc_id={$doc_id}\");";
                echo "</script>";
            } else {
                //以前没打开过
                echo "<h3>共享的文档，正在fork...</h3>";
                echo "<div style='display:none;'>";
                //获取文件路径

                PDO_Connect( _FILE_DB_USERINFO_);
                $query = "SELECT userid from user where id='{$owner}'";
                $FetchUid = PDO_FetchOne($query);
                if ($FetchUid) {
                    //$source=$dir_user_base.$FetchUid.$dir_mydocument.$filename;
                    //$dest=$dir_user_base.$userid.$dir_mydocument.$filename;
                    //复制数据
                    //打开逐词解析数据库
                    $dns = _FILE_DB_USER_WBW_;
                    $dbhWBW = new PDO($dns, _DB_USERNAME_, _DB_PASSWORD_, array(PDO::ATTR_PERSISTENT => true));
                    $dbhWBW->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);

                    //打开译文数据库
                    $dns = _FILE_DB_SENTENCE_;
                    $dbhSent = new PDO($dns, _DB_USERNAME_, _DB_PASSWORD_, array(PDO::ATTR_PERSISTENT => true));
                    $dbhSent->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);

                    //逐词解析新数据数组
                    $arrNewBlock = array();
                    $arrNewBlockData = array();
                    $arrBlockTransform = array();

                    $newDocBlockList = array();

                    $blocks = json_decode($Fetch[0]["doc_block"]);
                    for ($i = 0; $i < count($blocks); $i++) {
                        switch ($blocks[$i]->type) {
                            case 1:
                                break;
                            case 2:
                                //不复刻译文
                                break;
                            case 3:
                                break;
                            case 4:
                                break;
                            case 5:
                                break;
                            case 6:
                                #逐词解析
                                $blockid = $blocks[$i]->block_id;
                                $query = "SELECT uid,book_id,paragraph,style,lang,status from "._TABLE_USER_WBW_BLOCK_." where uid= ? ";
                                $stmt = $dbhWBW->prepare($query);
                                $stmt->execute(array($blockid));
                                $fBlock = $stmt->fetchAll(PDO::FETCH_ASSOC);
                                $newBlockId = UUID::V4();
                                $newDocBlockList[] = array('type' => 6, 'block_id' => $newBlockId);
                                $arrBlockTransform[$fBlock[0]["id"]] = $newBlockId;
                                if (count($fBlock) > 0) {
                                    array_push($arrNewBlock,
                                        array(
                                            $snowflake->id(),
                                            $newBlockId,
                                            $fBlock[0]["uid"],
                                            $_GET["channel"],
                                            $_COOKIE["userid"],
                                            $fBlock[0]["book_id"],
                                            $fBlock[0]["paragraph"],
                                            $fBlock[0]["style"],
                                            $fBlock[0]["lang"],
                                            $fBlock[0]["status"],
                                            mTime()
                                        ));
                                }

                                $query = "select * from "._TABLE_USER_WBW_." where block_id= ? ";
                                $stmtWBW = $dbhWBW->prepare($query);
                                $stmtWBW->execute(array($fBlock[0]["id"]));
                                $fBlockData = $stmtWBW->fetchAll(PDO::FETCH_ASSOC);
                                foreach ($fBlockData as $value) {
                                    array_push($arrNewBlockData,
                                        array(
                                            $snowflake->id(),
                                            UUID::V4(),
                                            $arrBlockTransform[$value["block_id"]],
                                            $value["book"],
                                            $value["paragraph"],
                                            $value["wid"],
                                            $value["word"],
                                            $value["data"],
                                            mTime(),
                                            mTime(),
                                            $value["status"],
                                            $_COOKIE["userid"],
                                        ));

                                }
                                break;
                            case 2:

                                break;
                        }

                    }
                    //逐词解析block数据块

                    if (count($arrNewBlock) > 0) {
                        $dbhWBW->beginTransaction();
                        $query = "INSERT INTO "._TABLE_USER_WBW_BLOCK_." 
                                            ( 
                                                id,
                                                uid ,
                                                parent_id ,
                                                channel_uid ,
                                                creator_uid ,
                                                book_id ,
                                                paragraph ,
                                                style ,
                                                lang ,
                                                status ,
                                                modify_time ,
                                                updated_at
                                            )
                                            VALUES (?,?,?,?,?,?,?,?,?,?,?,now())";
                        $stmtNewBlock = $dbhWBW->prepare($query);
                        foreach ($arrNewBlock as $oneParam) {
                            $stmtNewBlock->execute($oneParam);
                        }
                        // 提交更改
                        $dbhWBW->commit();
                        if (!$stmtNewBlock || ($stmtNewBlock && $stmtNewBlock->errorCode() != 0)) {
                            $error = $dbhWBW->errorInfo();
                            echo "error - $error[2] <br>";
                        } else {
                            //逐词解析block块复刻成功
                            $count = count($arrNewBlock);
                            echo "wbw block $count recorders.<br/>";
                        }
                    }

                    if (count($arrNewBlockData) > 0) {
                        // 开始一个事务，逐词解析数据 关闭自动提交
                        $dbhWBW->beginTransaction();
                        $query = "INSERT INTO "._TABLE_USER_WBW_." 
                                    (
                                        'id',
                                        'uid',
                                        'block_id',
                                        'book',
                                        'paragraph',
                                        'wid',
                                        'word',
                                        'data',
                                        'create_time',
                                        'update_time',
                                        'status',
                                        'owner'
                                        ) VALUES (?,?,?,?,?,?,?,?,?,?,?,?)";
                        $stmtWbwData = $dbhWBW->prepare($query);
                        foreach ($arrNewBlockData as $oneParam) {
                            $stmtWbwData->execute($oneParam);
                        }
                        // 提交更改
                        $dbhWBW->commit();
                        if (!$stmtWbwData || ($stmtWbwData && $stmtWbwData->errorCode() != 0)) {
                            $error = $dbhWBW->errorInfo();
                            echo "error - $error[2] <br>";
                        } else {
                            //逐词解析 数据 复刻成功
                            $count = count($arrNewBlockData);
                            echo "new wbw $count recorders.";
                        }
                    }

                    //不复刻译文


                    //插入记录到文件索引
                    $filesize = 0;
                    //服务器端文件列表
                    PDO_Connect(_FILE_DB_FILEINDEX_);
                    $query = "INSERT INTO "._TABLE_FILEINDEX_." (
                                                        'id',
                                                        'uid',
                                                       'parent_id',
                                                       'user_id',
                                                       'book',
                                                       'paragraph',
                                                       'file_name',
                                                       'title',
                                                       'tag',
                                                       'status',
                                                       'create_time',
                                                       'modify_time',
                                                       'accese_time',
                                                       'file_size',
                                                       'share',
                                                       'doc_info',
                                                       'doc_block'
                                                       )
                                        VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
                    $stmt = $PDO->prepare($query);
                    $newDocId = UUID::v4();
                    $newDocInfo = $orgFileInfo;
                    $newDocInfo["id"] = $newDocId;
                    $newDocInfo["parent_id"] = $orgFileInfo["id"];
                    $newDocInfo["user_id"] = $_COOKIE["uid"];
                    $newDocInfo["doc_block"] = json_encode($newDocBlockList, JSON_UNESCAPED_UNICODE);
                    $newData = array(
                        $snowflake->id(),
                        $newDocInfo["id"],
                        $newDocInfo["parent_id"],
                        $newDocInfo["user_id"],
                        $newDocInfo["book"],
                        $newDocInfo["paragraph"],
                        $newDocInfo["file_name"],
                        $newDocInfo["title"],
                        $newDocInfo["tag"],
                        $newDocInfo["status"],
                        mTime(),
                        mTime(),
                        mTime(),
                        $newDocInfo["file_size"],
                        $newDocInfo["share"],
                        $newDocInfo["doc_info"],
                        $newDocInfo["doc_block"]
                    );
                    $stmt->execute($newData);
                    if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
                        $error = PDO_ErrorInfo();
                        echo "error - $error[2] <br>";
                    } else {
                        //文档列表插入成功

                        echo "doc list updata 1 recorders.";
                        echo "</div>";
                        echo "<h3>复刻成功</h3>";
                        echo "正在<a href='../studio/editor.php?op=opendb&doc_id={$newDocId}'>打开</a>文档";
                        echo "<script>";
                        echo "window.location.assign(\"../studio/editor.php?op=opendb&fileid={$newDocId}\");";
                        echo "</script>";
                    }
                } else {
                    echo "无效的文档id";
                }

            }
        }
    }
}

echo "</div>";
?>

</body>
</html>