fork.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392
  1. <?php
  2. /*拷贝其他人的文件
  3. *
  4. *
  5. */
  6. require_once '../studio/index_head.php';
  7. ?>
  8. <body id="file_list_body" >
  9. <?php
  10. require_once "../public/_pdo.php";
  11. require_once "../public/function.php";
  12. require_once "../config.php";
  13. require_once '../studio/index_tool_bar.php';
  14. echo '<div class="index_inner" style=" margin-left: 18em;margin-top: 5em;">';
  15. if ($_COOKIE["uid"]) {
  16. $uid = $_COOKIE["uid"];
  17. } else {
  18. echo "尚未登录";
  19. echo "<h3><a href='../ucenter/index.php?op=login'>登录</a>后才可以打开文档 </h3>";
  20. exit;
  21. }
  22. if (isset($_GET["doc_id"]) == false) {
  23. echo "没有 文档编号";
  24. exit;
  25. }
  26. PDO_Connect("" . _FILE_DB_FILEINDEX_);
  27. $doc_id = $_GET["doc_id"];
  28. $query = "select * from fileindex where id= ? ";
  29. $Fetch = PDO_FetchAll($query, array($doc_id));
  30. $iFetch = count($Fetch);
  31. if ($iFetch > 0) {
  32. //文档信息
  33. $mbook = $Fetch[0]["book"];
  34. $paragraph = $Fetch[0]["paragraph"];
  35. }
  36. if (isset($_GET["channel"]) == false) {
  37. echo '<div class="file_list_block">';
  38. echo "<h2>选择一个空白的版风存储新的文档</h2>";
  39. echo "<form action='fork.php' method='get'>";
  40. echo "<input type='hidden' name='doc_id' value='{$_GET["doc_id"]}' />";
  41. PDO_Connect( _FILE_DB_CHANNAL_,_DB_USERNAME_,_DB_PASSWORD_);
  42. $query = "SELECT uid,name,lang,status,create_time from "._TABLE_CHANNEL_." where owner_uid = ? limit 100";
  43. $Fetch = PDO_FetchAll($query,$_COOKIE["user_uid"]);
  44. $i = 0;
  45. foreach ($Fetch as $row) {
  46. echo '<div class="file_list_row" style="padding:5px;display:flex;">';
  47. echo '<div class="pd-10" style="max-width:2em;flex:1;">';
  48. echo '<input name="channel" value="' . $row["uid"] . '" ';
  49. if ($i == 0) {
  50. echo "checked";
  51. }
  52. echo ' type="radio" />';
  53. echo '</div>';
  54. echo '<div class="title" style="flex:3;padding-bottom:5px;">' . $row["name"] . '</div>';
  55. echo '<div class="title" style="flex:3;padding-bottom:5px;">' . $row["lang"] . '</div>';
  56. echo '<div class="title" style="flex:2;padding-bottom:5px;">';
  57. PDO_Connect(_FILE_DB_USER_WBW_);
  58. $query = "SELECT count(*) from "._TABLE_USER_WBW_BLOCK_." where channel_uid = '{$row["uid"]}' and book_id='{$mbook}' and paragraph in ({$paragraph}) limit 100";
  59. $FetchWBW = PDO_FetchOne($query);
  60. echo '</div>';
  61. echo '<div class="title" style="flex:2;padding-bottom:5px;">';
  62. if ($FetchWBW == 0) {
  63. echo $_local->gui->blank;
  64. } else {
  65. echo $FetchWBW . $_local->gui->para;
  66. echo "<a href='../studio/editor.php?op=openchannal&book=$book&para={$paraList}&channal={$row["uid"]}'>open</a>";
  67. }
  68. echo '</div>';
  69. echo '<div class="title" style="flex:2;padding-bottom:5px;">';
  70. PDO_Connect(_FILE_DB_SENTENCE_,_DB_USERNAME_,_DB_PASSWORD_);
  71. $query = "SELECT count(*) from "._TABLE_SENTENCE_." where channel_uid = ? and book_id=? and paragraph in ({$paragraph}) limit 1000";
  72. $FetchWBW = PDO_FetchOne($query,array($row["uid"],$mbook));
  73. echo '</div>';
  74. echo '<div class="title" style="flex:2;padding-bottom:5px;">';
  75. if ($FetchWBW == 0) {
  76. echo $_local->gui->blank;
  77. } else {
  78. echo $FetchWBW . $_local->gui->para;
  79. }
  80. echo '</div>';
  81. echo '<div class="summary" style="flex:1;padding-bottom:5px;">' . $row["status"] . '</div>';
  82. echo '<div class="author" style="flex:1;padding-bottom:5px;">' . $row["create_time"] . '</div>';
  83. echo '</div>';
  84. $i++;
  85. }
  86. echo "<input type='submit' />";
  87. echo "</form>";
  88. echo "</div>";
  89. exit;
  90. }
  91. //if(isset($_GET["doc_id"]))
  92. {
  93. PDO_Connect( _FILE_DB_FILEINDEX_,_DB_USERNAME_,_DB_PASSWORD_);
  94. $doc_id = $_GET["doc_id"];
  95. $query = "SELECT * from fileindex where id= ? ";
  96. $Fetch = PDO_FetchAll($query, array($doc_id));
  97. $iFetch = count($Fetch);
  98. if ($iFetch > 0) {
  99. //文档信息
  100. $orgFileInfo = $Fetch[0];
  101. $owner = $Fetch[0]["user_id"];
  102. $filename = $Fetch[0]["file_name"];
  103. $title = $Fetch[0]["title"];
  104. $tag = $Fetch[0]["tag"];
  105. $mbook = $Fetch[0]["book"];
  106. $paragraph = $Fetch[0]["paragraph"];
  107. if ($owner == $uid) {
  108. //自己的文档
  109. echo "这是自己的文档,不能复刻。";
  110. } else {
  111. //别人的文档
  112. //查询自己是否以前打开过
  113. $query = "SELECT * from fileindex where parent_id='{$doc_id}' and user_id='{$uid}' ";
  114. $FetchSelf = PDO_FetchAll($query);
  115. $iFetchSelf = count($FetchSelf);
  116. if ($iFetchSelf > 0) {
  117. //以前打开过
  118. echo "文档已经复刻";
  119. echo "正在<a href='../studio/editor.php?op=opendb&doc_id={$doc_id}'>打开</a>文档";
  120. echo "<script>";
  121. echo "window.location.assign(\"../studio/editor.php?op=opendb&doc_id={$doc_id}\");";
  122. echo "</script>";
  123. } else {
  124. //以前没打开过
  125. echo "<h3>共享的文档,正在fork...</h3>";
  126. echo "<div style='display:none;'>";
  127. //获取文件路径
  128. PDO_Connect("" . _FILE_DB_USERINFO_);
  129. $query = "select userid from user where id='{$owner}'";
  130. $FetchUid = PDO_FetchOne($query);
  131. if ($FetchUid) {
  132. //$source=$dir_user_base.$FetchUid.$dir_mydocument.$filename;
  133. //$dest=$dir_user_base.$userid.$dir_mydocument.$filename;
  134. //复制数据
  135. //打开逐词解析数据库
  136. $dns = _FILE_DB_USER_WBW_;
  137. $dbhWBW = new PDO($dns, _DB_USERNAME_, _DB_PASSWORD_, array(PDO::ATTR_PERSISTENT => true));
  138. $dbhWBW->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
  139. //打开译文数据库
  140. $dns = _FILE_DB_SENTENCE_;
  141. $dbhSent = new PDO($dns, _DB_USERNAME_, _DB_PASSWORD_, array(PDO::ATTR_PERSISTENT => true));
  142. $dbhSent->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
  143. //逐词解析新数据数组
  144. $arrNewBlock = array();
  145. $arrNewBlockData = array();
  146. $arrBlockTransform = array();
  147. //译文新数据数组
  148. $arrSentNewBlock = array();
  149. $arrSentNewBlockData = array();
  150. $arrSentBlockTransform = array();
  151. $newDocBlockList = array();
  152. $blocks = json_decode($Fetch[0]["doc_block"]);
  153. for ($i = 0; $i < count($blocks); $i++) {
  154. switch ($blocks[$i]->type) {
  155. case 1:
  156. break;
  157. case 2:
  158. //译文
  159. $blockid = $blocks[$i]->block_id;
  160. $query = "SELECT * from "._TABLE_SENTENCE_BLOCK_." where uid= ? ";
  161. $stmt = $dbhSent->prepare($query);
  162. $stmt->execute(array($blockid));
  163. $fBlock = $stmt->fetchAll(PDO::FETCH_ASSOC);
  164. $newBlockId = UUID::V4();
  165. //不复刻译文
  166. //$newDocBlockList[]=array('type' => 2,'block_id' => $newBlockId);
  167. $arrSentBlockTransform[$fBlock[0]["id"]] = $newBlockId;
  168. if (count($fBlock) > 0) {
  169. array_push($arrSentNewBlock,
  170. array($newBlockId,
  171. $fBlock[0]["id"],
  172. $fBlock[0]["book"],
  173. $fBlock[0]["paragraph"],
  174. $_COOKIE["userid"],
  175. $fBlock[0]["lang"],
  176. $fBlock[0]["author"],
  177. $fBlock[0]["editor"],
  178. $fBlock[0]["tag"],
  179. $fBlock[0]["status"],
  180. mTime(),
  181. mTime(),
  182. ));
  183. }
  184. break;
  185. case 3:
  186. break;
  187. case 4:
  188. break;
  189. case 5:
  190. break;
  191. case 6:
  192. #逐词解析
  193. $blockid = $blocks[$i]->block_id;
  194. $query = "SELECT uid,book_id,paragraph,style,lang,status from "._TABLE_USER_WBW_BLOCK_." where uid= ? ";
  195. $stmt = $dbhWBW->prepare($query);
  196. $stmt->execute(array($blockid));
  197. $fBlock = $stmt->fetchAll(PDO::FETCH_ASSOC);
  198. $newBlockId = UUID::V4();
  199. $newDocBlockList[] = array('type' => 6, 'block_id' => $newBlockId);
  200. $arrBlockTransform[$fBlock[0]["id"]] = $newBlockId;
  201. if (count($fBlock) > 0) {
  202. array_push($arrNewBlock,
  203. array($newBlockId,
  204. $fBlock[0]["uid"],
  205. $_GET["channel"],
  206. $_COOKIE["userid"],
  207. $fBlock[0]["book_id"],
  208. $fBlock[0]["paragraph"],
  209. $fBlock[0]["style"],
  210. $fBlock[0]["lang"],
  211. $fBlock[0]["status"],
  212. mTime()
  213. ));
  214. }
  215. $query = "select * from "._TABLE_USER_WBW_." where block_id= ? ";
  216. $stmtWBW = $dbhWBW->prepare($query);
  217. $stmtWBW->execute(array($fBlock[0]["id"]));
  218. $fBlockData = $stmtWBW->fetchAll(PDO::FETCH_ASSOC);
  219. foreach ($fBlockData as $value) {
  220. array_push($arrNewBlockData,
  221. array(UUID::V4(),
  222. $arrBlockTransform[$value["block_id"]],
  223. $value["book"],
  224. $value["paragraph"],
  225. $value["wid"],
  226. $value["word"],
  227. $value["data"],
  228. mTime(),
  229. mTime(),
  230. $value["status"],
  231. $_COOKIE["userid"],
  232. ));
  233. }
  234. break;
  235. case 2:
  236. break;
  237. }
  238. }
  239. //逐词解析block数据块
  240. if (count($arrNewBlock) > 0) {
  241. $dbhWBW->beginTransaction();
  242. $query = "INSERT INTO "._TABLE_USER_WBW_BLOCK_." ( uid ,
  243. parent_id ,
  244. channel_uid ,
  245. creator_uid ,
  246. book_id ,
  247. paragraph ,
  248. style ,
  249. lang ,
  250. status ,
  251. modify_time ,
  252. updated_at)
  253. VALUES (?,?,?,?,?,?,?,?,?,?,now())";
  254. $stmtNewBlock = $dbhWBW->prepare($query);
  255. foreach ($arrNewBlock as $oneParam) {
  256. $stmtNewBlock->execute($oneParam);
  257. }
  258. // 提交更改
  259. $dbhWBW->commit();
  260. if (!$stmtNewBlock || ($stmtNewBlock && $stmtNewBlock->errorCode() != 0)) {
  261. $error = $dbhWBW->errorInfo();
  262. echo "error - $error[2] <br>";
  263. } else {
  264. //逐词解析block块复刻成功
  265. $count = count($arrNewBlock);
  266. echo "wbw block $count recorders.<br/>";
  267. }
  268. }
  269. if (count($arrNewBlockData) > 0) {
  270. // 开始一个事务,逐词解析数据 关闭自动提交
  271. $dbhWBW->beginTransaction();
  272. $query = "INSERT INTO "._TABLE_USER_WBW_." ('id','block_id','book','paragraph','wid','word','data','modify_time','receive_time','status','owner') VALUES (?,?,?,?,?,?,?,?,?,?,?)";
  273. $stmtWbwData = $dbhWBW->prepare($query);
  274. foreach ($arrNewBlockData as $oneParam) {
  275. $stmtWbwData->execute($oneParam);
  276. }
  277. // 提交更改
  278. $dbhWBW->commit();
  279. if (!$stmtWbwData || ($stmtWbwData && $stmtWbwData->errorCode() != 0)) {
  280. $error = $dbhWBW->errorInfo();
  281. echo "error - $error[2] <br>";
  282. } else {
  283. //逐词解析 数据 复刻成功
  284. $count = count($arrNewBlockData);
  285. echo "new wbw $count recorders.";
  286. }
  287. }
  288. //不复刻译文
  289. //插入记录到文件索引
  290. $filesize = 0;
  291. //服务器端文件列表
  292. PDO_Connect("" . _FILE_DB_FILEINDEX_);
  293. $query = "INSERT INTO fileindex ('id',
  294. 'parent_id',
  295. 'user_id',
  296. 'book',
  297. 'paragraph',
  298. 'file_name',
  299. 'title',
  300. 'tag',
  301. 'status',
  302. 'create_time',
  303. 'modify_time',
  304. 'accese_time',
  305. 'file_size',
  306. 'share',
  307. 'doc_info',
  308. 'doc_block',
  309. 'receive_time'
  310. )
  311. VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
  312. $stmt = $PDO->prepare($query);
  313. $newDocId = UUID::v4();
  314. $newDocInfo = $orgFileInfo;
  315. $newDocInfo["id"] = $newDocId;
  316. $newDocInfo["parent_id"] = $orgFileInfo["id"];
  317. $newDocInfo["user_id"] = $_COOKIE["uid"];
  318. $newDocInfo["doc_block"] = json_encode($newDocBlockList, JSON_UNESCAPED_UNICODE);
  319. $newData = array($newDocInfo["id"],
  320. $newDocInfo["parent_id"],
  321. $newDocInfo["user_id"],
  322. $newDocInfo["book"],
  323. $newDocInfo["paragraph"],
  324. $newDocInfo["file_name"],
  325. $newDocInfo["title"],
  326. $newDocInfo["tag"],
  327. $newDocInfo["status"],
  328. mTime(),
  329. mTime(),
  330. mTime(),
  331. $newDocInfo["file_size"],
  332. $newDocInfo["share"],
  333. $newDocInfo["doc_info"],
  334. $newDocInfo["doc_block"],
  335. mTime(),
  336. );
  337. $stmt->execute($newData);
  338. if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
  339. $error = PDO_ErrorInfo();
  340. echo "error - $error[2] <br>";
  341. } else {
  342. //文档列表插入成功
  343. echo "doc list updata 1 recorders.";
  344. echo "</div>";
  345. echo "<h3>复刻成功</h3>";
  346. echo "正在<a href='../studio/editor.php?op=opendb&doc_id={$newDocId}'>打开</a>文档";
  347. echo "<script>";
  348. echo "window.location.assign(\"../studio/editor.php?op=opendb&fileid={$newDocId}\");";
  349. echo "</script>";
  350. }
  351. } else {
  352. echo "无效的文档id";
  353. }
  354. }
  355. }
  356. }
  357. }
  358. echo "</div>";
  359. ?>
  360. </body>
  361. </html>