iapt-platform
/
mint
oglindă de https://github.com/iapt-platform/mint.git


			
				
					
						
						
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314
							<?php

/*
*拷贝其他人的逐词解析数据
 *输入参数
 *src_channel
 *dest_channel
 *bookid
 *paragraph
*/
require_once '../studio/index_head.php';
?>
<body id="file_list_body" >
<?php
require_once __DIR__."/../config.php";
require_once __DIR__."/../public/_pdo.php";
require_once __DIR__."/../public/function.php";
require_once __DIR__."/../channal/function.php";
require_once __DIR__."/../redis/function.php";
require_once __DIR__."/../public/snowflakeid.php";
$snowflake = new SnowFlakeId();

$redis = redis_connect();

require_once '../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["para"])){
    $_para = json_decode($_GET["para"]);
}
else{
    echo "没有 para 编号";
    exit;
}

if (isset($_GET["src_channel"]) == false) {
    echo "没有 channel 编号";
    exit;
}
    //文档信息
    $mbook = $_GET["book"];
    $paragraph = implode(",",$_para);

if (isset($_GET["dest_channel"]) == false) {
    echo '<div class="file_list_block">';
    echo "<h2>选择一个空白的版风存储新的文档</h2>";
    echo "<div>原有版本中相同段落的数据将被覆盖</div>";
    echo "<form action='fork_channel.php' method='get'>";
    echo "<input type='hidden' name='book' value='{$_GET["book"]}' />";
    echo "<input type='hidden' name='para' value='{$_GET["para"]}' />";
    echo "<input type='hidden' name='src_channel' value='{$_GET["src_channel"]}' />";
    PDO_Connect(_FILE_DB_CHANNAL_,_DB_USERNAME_,_DB_PASSWORD_);
    $query = "SELECT uid,name,lang,status,create_time from "._TABLE_CHANNEL_." where owner_uid = '{$_COOKIE["user_uid"]}'   limit 100";
    $Fetch = PDO_FetchAll($query);
    $i = 0;
    PDO_Connect( _FILE_DB_USER_WBW_,_DB_USERNAME_,_DB_PASSWORD_);	
    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="dest_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;">';
        $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={$mbook}&para={$paragraph}&channal={$row["uid"]}'>open</a>";
        }
        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;
}

PDO_Connect( _FILE_DB_USER_WBW_,_DB_USERNAME_,_DB_PASSWORD_);	

$channelInfo= new Channal($redis);

$srcPower = (int)$channelInfo->getPower($_GET["src_channel"]);
{

        if ($srcPower == 30) {
            //自己的文档
            echo "这是自己的文档，不能复刻。";
        } else {
            //别人的文档
			{
                //以前没打开过
			echo "<h3>共享的文档，正在fork...</h3>";
			echo "<div style='display:none;'>";

		
			//复制数据
			//打开逐词解析数据库
			$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);

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

			$blocks = $_para;
			for ($i = 0; $i < count($blocks); $i++) {
				#查找是否有旧的wbw_block数据
				$query = "SELECT id,uid from "._TABLE_USER_WBW_BLOCK_." where book_id= ? and paragraph = ? and channel_uid = ? ";
				$stmt = $dbhWBW->prepare($query);
				$stmt->execute(array($_GET["book"],$blocks[$i],$_GET["dest_channel"]));
				$fDest = $stmt->fetch(PDO::FETCH_ASSOC);
				if($fDest){
					#旧的逐词解析数据块wbw_block id 
					$destUid = $fDest["uid"];
					$destId = $fDest["id"];
				}
				#复制源wbw_block
				$iPara = $blocks[$i];
				$query = "SELECT uid,book_id,paragraph,style,lang,status from "._TABLE_USER_WBW_BLOCK_." where book_id= ? and paragraph = ? and channel_uid = ? ";
				$stmt = $dbhWBW->prepare($query);
				$stmt->execute(array($_GET["book"],$iPara,$_GET["src_channel"]));
				$fSrcBlock = $stmt->fetch(PDO::FETCH_ASSOC);
				if(isset($destId)){
					#有旧的wbw_block uuid 使用旧的uuid
					$newBlockId = $destId;
					$newBlockUid = $destUid;
				}
				else{
					$newBlockId = $snowflake->id();
					$newBlockUid = UUID::V4();
				}
				
				if ($fSrcBlock) {
					$arrBlockTransform[$fSrcBlock["uid"]] = $newBlockId;
					array_push($arrNewBlock,
						array(
                            $newBlockId,
                            $newBlockUid,
							"",
							$_GET["dest_channel"],
							$_GET["src_channel"],
							$_COOKIE["user_uid"],
							$_COOKIE["user_id"],
							$fSrcBlock["book_id"],
							$fSrcBlock["paragraph"],
							$fSrcBlock["style"],
							$fSrcBlock["lang"],
							$fSrcBlock["status"],
							mTime(),
							mTime()
						));
				}
				#复制源数据
				$query = "SELECT block_uid, book_id,paragraph,wid,word,data,status from "._TABLE_USER_WBW_." where block_uid= ? ";
				$stmtWBW = $dbhWBW->prepare($query);
				$stmtWBW->execute(array($fSrcBlock["uid"]));
				$fBlockData = $stmtWBW->fetchAll(PDO::FETCH_ASSOC);
				foreach ($fBlockData as $value) {
					array_push($arrNewBlockData,
						array(
                            $snowflake->id(),
                            UUID::V4(),
							$newBlockUid,
							$newBlockId,
							$value["book_id"],
							$value["paragraph"],
							$value["wid"],
							$value["word"],
							$value["data"],
							mTime(),
							mTime(),
							$value["status"],
							$_COOKIE["user_uid"],
                            $_COOKIE["user_id"],
						));

				}

			}

			# 查找目标block是否存在

			//删除旧的逐词解析block数据块
			$query = "DELETE from "._TABLE_USER_WBW_BLOCK_." where  paragraph = ? AND book_id = ? AND channel_uid = ? ";
			$stmt = $dbhWBW->prepare($query);
			$stmt->execute(array($iPara,$_GET["book"],$_GET["dest_channel"]));
			
			//新增逐词解析block数据块
			if (count($arrNewBlock) > 0) {
				$dbhWBW->beginTransaction();
				$query = "INSERT INTO "._TABLE_USER_WBW_BLOCK_." 
                (
                    id,
                    uid , 
                    parent_id , 
                    channel_uid , 
                    parent_channel_uid , 
                    creator_uid , 
                    editor_id , 
                    book_id , 
                    paragraph , 
                    style , 
                    lang , 
                    status , 
                    modify_time , 
                    create_time 
                ) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
				$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>";
					exit;
				} else {
					//逐词解析block块复刻成功
					$count = count($arrNewBlock);
					echo "wbw block $count recorders.<br/>";
				}
			}

			//删除旧的wbw逐词解析数据块
			if(isset($destId)){
				$query = "DELETE from "._TABLE_USER_WBW_." where  block_uid = ? ";
				$stmt = $dbhWBW->prepare($query);
				$stmt->execute(array($destId));
			}
			
			if (count($arrNewBlockData) > 0) {
				// 开始一个事务，逐词解析数据 关闭自动提交
				$dbhWBW->beginTransaction();
				$query = "INSERT INTO "._TABLE_USER_WBW_." 
                ( 
                    id,
                    uid , 
                    block_uid , 
                    block_id , 
                    book_id , 
                    paragraph , 
                    wid , 
                    word , 
                    data , 
                    modify_time , 
                    create_time , 
                    status , 
                    creator_uid,
                    editor_id
                    ) 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>";
					exit;
				} else {
					//逐词解析 数据 复刻成功
					$count = count($arrNewBlockData);
					echo "new wbw $count recorders.";
				}
			}

			
			//成功
			echo "doc list updata 1 recorders.";
			echo "</div>";
			echo "<h3>复刻成功</h3>";
			echo "正在<a href='../studio/editor.php?op=openchannal&book={$_GET["book"]}&para={$_para[0]}&channal={$_GET["dest_channel"]}'>打开</a>文档";
			echo "<script>";
			echo "window.location.assign(\"../studio/editor.php?op=openchannal&book={$_GET["book"]}&para={$_para[0]}&channal={$_GET["dest_channel"]}\");";
			echo "</script>";
			
            }
        }
}

echo "</div>";
?>

</body>
</html>