pcs2db.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483
  1. <?php
  2. /*
  3. 转换pcs 到数据库格式
  4. */
  5. require_once "../path.php";
  6. require_once "../public/_pdo.php";
  7. require_once "../public/function.php";
  8. require_once '../studio/index_head.php';
  9. echo '<body id="file_list_body" >';
  10. echo '<div class="index_inner" style=" margin-left: 18em;margin-top: 5em;">';
  11. echo "<h2>转换PCS 到数据库格式</h2>";
  12. if ($_COOKIE["uid"]) {
  13. $uid = $_COOKIE["uid"];
  14. } else {
  15. echo "尚未登录";
  16. echo "<h3><a href='../ucenter/index.php?op=login'>登录</a>后才可以打开文档 </h3>";
  17. exit;
  18. }
  19. if (isset($_GET["doc_id"]) == false) {
  20. echo "没有 文档编号";
  21. exit;
  22. }
  23. PDO_Connect("" . _FILE_DB_FILEINDEX_);
  24. $doc_id = $_GET["doc_id"];
  25. $query = "SELECT * from fileindex where id= ? ";
  26. $Fetch = PDO_FetchAll($query, array($doc_id));
  27. $iFetch = count($Fetch);
  28. if ($iFetch > 0) {
  29. //文档信息
  30. $mbook = $Fetch[0]["book"];
  31. $paragraph = $Fetch[0]["paragraph"];
  32. }
  33. if (isset($_GET["channel"]) == false) {
  34. echo '<div class="file_list_block">';
  35. echo "<h2>选择一个空白的版风存储新的文档</h2>";
  36. echo "<form action='pcs2db.php' method='get'>";
  37. echo "<input type='hidden' name='doc_id' value='{$_GET["doc_id"]}' />";
  38. PDO_Connect("" . _FILE_DB_CHANNAL_);
  39. $query = "SELECT * from channal where owner = '{$_COOKIE["userid"]}' limit 0,100";
  40. $Fetch = PDO_FetchAll($query);
  41. $i = 0;
  42. foreach ($Fetch as $row) {
  43. echo '<div class="file_list_row" style="padding:5px;display:flex;">';
  44. echo '<div class="pd-10" style="max-width:2em;flex:1;">';
  45. echo '<input name="channel" value="' . $row["id"] . '" ';
  46. if ($i == 0) {
  47. echo "checked";
  48. }
  49. echo ' type="radio" />';
  50. echo '</div>';
  51. echo '<div class="title" style="flex:3;padding-bottom:5px;">' . $row["name"] . '</div>';
  52. echo '<div class="title" style="flex:3;padding-bottom:5px;">' . $row["lang"] . '</div>';
  53. echo '<div class="title" style="flex:2;padding-bottom:5px;">';
  54. PDO_Connect("" . _FILE_DB_USER_WBW_);
  55. $query = "select count(*) from wbw_block where channal = '{$row["id"]}' and book='{$mbook}' and paragraph in ({$paragraph}) limit 0,100";
  56. $FetchWBW = PDO_FetchOne($query);
  57. echo '</div>';
  58. echo '<div class="title" style="flex:2;padding-bottom:5px;">';
  59. if ($FetchWBW == 0) {
  60. echo $_local->gui->blank;
  61. } else {
  62. echo $FetchWBW . $_local->gui->para;
  63. echo "<a href='../studio/editor.php?op=openchannal&book=$book&para={$paraList}&channal={$row["id"]}'>open</a>";
  64. }
  65. echo '</div>';
  66. echo '<div class="title" style="flex:2;padding-bottom:5px;">';
  67. PDO_Connect("" . _FILE_DB_SENTENCE_);
  68. $query = "select count(*) from sentence where channal = '{$row["id"]}' and book='{$mbook}' and paragraph in ({$paragraph}) limit 0,100";
  69. $FetchWBW = PDO_FetchOne($query);
  70. echo '</div>';
  71. echo '<div class="title" style="flex:2;padding-bottom:5px;">';
  72. if ($FetchWBW == 0) {
  73. echo $_local->gui->blank;
  74. } else {
  75. echo $FetchWBW . $_local->gui->para;
  76. }
  77. echo '</div>';
  78. echo '<div class="summary" style="flex:1;padding-bottom:5px;">' . $row["status"] . '</div>';
  79. echo '<div class="author" style="flex:1;padding-bottom:5px;">' . $row["create_time"] . '</div>';
  80. echo '</div>';
  81. $i++;
  82. }
  83. echo "<input type='submit' />";
  84. echo "</form>";
  85. echo "</div>";
  86. exit;
  87. }
  88. $dir = _DIR_USER_DOC_ . '/' . $_COOKIE["userid"] . _DIR_MYDOCUMENT_;
  89. PDO_Connect("" . _FILE_DB_FILEINDEX_);
  90. $query = "SELECT file_name, doc_info, modify_time from fileindex where id=? ";
  91. $Fetch = PDO_FetchRow($query, array($_GET["doc_id"]));
  92. if ($Fetch === false) {
  93. echo "文件不存在";
  94. exit;
  95. } else {
  96. $file_modify_time = $Fetch["modify_time"];
  97. if (empty($Fetch["doc_info"])) {
  98. $file = $dir . '/' . $Fetch["file_name"];
  99. } else {
  100. echo "已经是数据库格式了。无需转换";
  101. exit;
  102. }
  103. }
  104. if (!file_exists($file)) {
  105. echo "文件不存在";
  106. exit;
  107. }
  108. $xml = simplexml_load_file($file);
  109. if ($xml == false) {
  110. echo "载入pcs文件错误";
  111. exit;
  112. }
  113. $xml_head = $xml->xpath('//head')[0];
  114. $strHead = "<head>";
  115. $strHead .= "<type>{$xml_head->type}</type>";
  116. $strHead .= "<mode>{$xml_head->mode}</mode>";
  117. $strHead .= "<ver>{$xml_head->ver}</ver>";
  118. $strHead .= "<toc>{$xml_head->toc}</toc>";
  119. $strHead .= "<style>{$xml_head->style}</style>";
  120. $strHead .= "<doc_title>{$xml_head->doc_title}</doc_title>";
  121. $strHead .= "<tag>{$xml_head->tag}</tag>";
  122. $strHead .= "<book>{$xml_head->book}</book>";
  123. $strHead .= "<paragraph>{$xml_head->paragraph}</paragraph>";
  124. $strHead .= "</head>";
  125. $dataBlock = $xml->xpath('//block');
  126. {
  127. //复制数据
  128. //打开逐词解析数据库
  129. $dns = "" . _FILE_DB_USER_WBW_;
  130. $dbhWBW = new PDO($dns, "", "", array(PDO::ATTR_PERSISTENT => true));
  131. $dbhWBW->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
  132. //打开译文数据库
  133. $dns = "" . _FILE_DB_SENTENCE_;
  134. $dbhSent = new PDO($dns, "", "", array(PDO::ATTR_PERSISTENT => true));
  135. $dbhSent->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
  136. //逐词解析新数据数组
  137. $arrNewBlock = array();
  138. $arrNewBlockData = array();
  139. $arrBlockTransform = array();
  140. //译文新数据数组
  141. $arrSentNewBlock = array();
  142. $arrSentNewBlockData = array();
  143. $arrSentBlockTransform = array();
  144. $newDocBlockList = array();
  145. foreach ($dataBlock as $block) {
  146. switch ($block->info->type) {
  147. case "translate":
  148. echo "wbw:" . $block->info->book . "<br>";
  149. break;
  150. case "wbw":
  151. echo "translate:" . $block->info->book . "<br>";
  152. break;
  153. }
  154. }
  155. foreach ($dataBlock as $block) {
  156. switch ($block->info->type) {
  157. case 1:
  158. break;
  159. case "translate":
  160. //译文
  161. $blockid = UUID::V4();
  162. //译文不加入块列表 因为译文用channel解决 不需要渲染译文块
  163. //$newDocBlockList[]=array('type' => 2,'block_id' => $blockid);
  164. $arrSentBlockTransform["{$blockid}"] = $blockid;
  165. //if(count($fBlock)>0)
  166. {
  167. array_push($arrSentNewBlock, array($blockid,
  168. "",
  169. $block->info->book,
  170. $block->info->paragraph,
  171. $_COOKIE["userid"],
  172. $block->info->language,
  173. $block->info->author,
  174. "",
  175. "",
  176. "1",
  177. $file_modify_time,
  178. mTime(),
  179. ));
  180. }
  181. foreach ($block->data->children() as $sen) {
  182. if (isset($sen->begin)) {
  183. $sent_begin = $sen->begin;
  184. } else {
  185. $sent_begin = "";
  186. }
  187. if (isset($sen->end)) {
  188. $sent_end = $sen->end;
  189. } else {
  190. $sent_end = "";
  191. }
  192. if (isset($sen->text) && strlen(trim($sen->text)) > 0) {
  193. $paraText = $sen->text;
  194. if ($block->info->level > 0 && $block->info->level < 8) {
  195. $toc .= $sen->text;
  196. }
  197. array_push($arrSentNewBlockData,
  198. array(UUID::V4(),
  199. $blockid,
  200. $block->info->book,
  201. $block->info->paragraph,
  202. $sent_begin,
  203. $sent_end,
  204. "",
  205. $block->info->author,
  206. $_COOKIE["userid"],
  207. $paraText,
  208. mb_strlen($paraText, "UTF-8"),
  209. $block->info->language,
  210. "1",
  211. "7",
  212. $file_modify_time,
  213. mTime(),
  214. mTime(),
  215. $_GET["channel"],
  216. ));
  217. }
  218. }
  219. break;
  220. case "wbw":
  221. $blockid = UUID::V4();
  222. $newDocBlockList[] = array('type' => 6, 'block_id' => $blockid);
  223. $arrBlockTransform["{$blockid}"] = $blockid;
  224. {
  225. array_push($arrNewBlock,
  226. array($blockid,
  227. "",
  228. $_GET["channel"],
  229. $_COOKIE["userid"],
  230. $block->info->book,
  231. $block->info->paragraph,
  232. "",
  233. $block->info->language,
  234. "",
  235. $file_modify_time,
  236. mTime(),
  237. ));
  238. }
  239. $currWordId = "";
  240. $currWordReal = "";
  241. $currWordStatus = "";
  242. $sWordData = "";
  243. $iWordCount = 0;
  244. foreach ($block->data->children() as $word) {
  245. $word_id = explode("-", $word->id)[2];
  246. $arrWordId = explode("_", $word_id);
  247. $realWordId = $arrWordId[0];
  248. if ($realWordId != $currWordId) {
  249. if ($iWordCount > 0) {
  250. array_push($arrNewBlockData, array(UUID::V4(),
  251. $blockid,
  252. $block->info->book,
  253. $block->info->paragraph,
  254. $currWordId,
  255. $currWordReal,
  256. $sWordData,
  257. $file_modify_time,
  258. mTime(),
  259. $currWordStatus,
  260. $_COOKIE["userid"],
  261. ));
  262. $sWordData = "";
  263. }
  264. $currWordId = $realWordId;
  265. $currWordReal = $word->real;
  266. $currWordStatus = $word->status;
  267. }
  268. $sWordData .= "<word>";
  269. $sWordData .= "<pali>{$word->pali}</pali>";
  270. $sWordData .= "<real>{$word->real}</real>";
  271. $sWordData .= "<id>{$word->id}</id>";
  272. $sWordData .= "<type status='0'>{$word->type}</type>";
  273. $sWordData .= "<gramma status='0'>{$word->gramma}</gramma>";
  274. $sWordData .= "<mean status='0'>{$word->mean}</mean>";
  275. $sWordData .= "<org status='0'>{$word->org}</org>";
  276. $sWordData .= "<om status='0'>{$word->om}</om>";
  277. $sWordData .= "<case status='0'>{$word->case}</case>";
  278. $sWordData .= "<note status='0'>{$word->note}</note>";
  279. $sWordData .= "<style>{$word->style}</style>";
  280. $sWordData .= "<status>{$word->status}</status>";
  281. $sWordData .= "<parent>{$word->parent}</parent>";
  282. if (isset($word->bmc)) {
  283. $sWordData .= "<bmc>{$word->bmc}</bmc>";
  284. }
  285. if (isset($word->bmt)) {
  286. $sWordData .= "<bmt>{$word->bmt}</bmt>";
  287. }
  288. if (isset($word->un)) {
  289. $sWordData .= "<un>{$word->un}</un>";
  290. }
  291. if (isset($word->lock)) {
  292. $sWordData .= "<lock>{$word->lock}</lock>";
  293. }
  294. $sWordData .= "</word>";
  295. $iWordCount++;
  296. }
  297. array_push($arrNewBlockData,
  298. array(UUID::V4(),
  299. $blockid,
  300. $block->info->book,
  301. $block->info->paragraph,
  302. $word_id,
  303. $word->real,
  304. $sWordData,
  305. $file_modify_time,
  306. mTime(),
  307. $word->status,
  308. $_COOKIE["userid"],
  309. ));
  310. break;
  311. case 2:
  312. break;
  313. }
  314. }
  315. //逐词解析block数据块结束
  316. #插入逐词解析块数据
  317. if (count($arrNewBlock) > 0) {
  318. $dbhWBW->beginTransaction();
  319. $query = "INSERT INTO wbw_block (
  320. 'id',
  321. 'parent_id',
  322. 'channal',
  323. 'owner',
  324. 'book',
  325. 'paragraph',
  326. 'style',
  327. 'lang',
  328. 'status',
  329. 'modify_time',
  330. 'receive_time'
  331. )
  332. VALUES (?,?,?,?,?,?,?,?,?,?,?)";
  333. $stmtNewBlock = $dbhWBW->prepare($query);
  334. foreach ($arrNewBlock as $oneParam) {
  335. $stmtNewBlock->execute($oneParam);
  336. }
  337. // 提交更改
  338. $dbhWBW->commit();
  339. if (!$stmtNewBlock || ($stmtNewBlock && $stmtNewBlock->errorCode() != 0)) {
  340. $error = $dbhWBW->errorInfo();
  341. echo "error - $error[2] <br>";
  342. } else {
  343. //逐词解析block块复刻成功
  344. $count = count($arrNewBlock);
  345. echo "wbw block $count recorders.<br/>";
  346. }
  347. }
  348. if (count($arrNewBlockData) > 0) {
  349. // 开始一个事务,逐词解析数据 关闭自动提交
  350. $dbhWBW->beginTransaction();
  351. $query = "INSERT INTO wbw ('id','block_id','book','paragraph','wid','word','data','modify_time','receive_time','status','owner') VALUES (?,?,?,?,?,?,?,?,?,?,?)";
  352. $stmtWbwData = $dbhWBW->prepare($query);
  353. foreach ($arrNewBlockData as $oneParam) {
  354. $stmtWbwData->execute($oneParam);
  355. }
  356. // 提交更改
  357. $dbhWBW->commit();
  358. if (!$stmtWbwData || ($stmtWbwData && $stmtWbwData->errorCode() != 0)) {
  359. $error = $dbhWBW->errorInfo();
  360. echo "error - $error[2] <br>";
  361. } else {
  362. //逐词解析 数据 复刻成功
  363. $count = count($arrNewBlockData);
  364. echo "new wbw $count recorders.";
  365. }
  366. }
  367. //译文 block数据块
  368. if (count($arrSentNewBlock) > 0) {
  369. $dbhSent->beginTransaction();
  370. $query = "INSERT INTO sent_block ('id','parent_id','book','paragraph','owner','lang','author','editor','tag','status','modify_time','receive_time') VALUES (?,?,?,?,?,?,?,?,?,?,?,?)";
  371. $stmtSentNewBlock = $dbhSent->prepare($query);
  372. foreach ($arrSentNewBlock as $oneParam) {
  373. //print_r($oneParam);
  374. $stmtSentNewBlock->execute($oneParam);
  375. }
  376. // 提交更改
  377. $dbhSent->commit();
  378. if (!$stmtSentNewBlock || ($stmtSentNewBlock && $stmtSentNewBlock->errorCode() != 0)) {
  379. $error = $dbhSent->errorInfo();
  380. echo "error - $error[2] <br>";
  381. } else {
  382. //译文 block块复刻成功
  383. $count = count($arrNewBlock);
  384. echo "wbw block $count recorders.<br/>";
  385. }
  386. }
  387. if (count($arrSentNewBlockData) > 0) {
  388. // 开始一个事务,逐词解析数据 关闭自动提交
  389. $dbhSent->beginTransaction();
  390. $query = "INSERT INTO sentence ('id','block_id','book','paragraph','begin','end','tag','author','editor','text','strlen','language','ver','status','modify_time','receive_time','create_time','channal') VALUES (? , ? , ? , ? , ? ,?, ? , ? , ? , ? , ? , ? , ? , ? , ?, ? , ? ,?)";
  391. $stmtSentData = $dbhSent->prepare($query);
  392. foreach ($arrSentNewBlockData as $oneParam) {
  393. $stmtSentData->execute($oneParam);
  394. }
  395. // 提交更改
  396. $dbhSent->commit();
  397. if (!$stmtSentData || ($stmtSentData && $stmtSentData->errorCode() != 0)) {
  398. $error = $dbhSent->errorInfo();
  399. echo "error - $error[2] <br>";
  400. } else {
  401. //译文 数据 复刻成功
  402. $count = count($arrSentNewBlockData);
  403. echo "new translation $count recorders.";
  404. }
  405. }
  406. //插入记录到文件索引
  407. $filesize = 0;
  408. //服务器端文件列表
  409. PDO_Connect("" . _FILE_DB_FILEINDEX_);
  410. $query = "INSERT INTO fileindex ('id',
  411. 'parent_id',
  412. 'user_id',
  413. 'book',
  414. 'paragraph',
  415. 'file_name',
  416. 'title',
  417. 'tag',
  418. 'status',
  419. 'create_time',
  420. 'modify_time',
  421. 'accese_time',
  422. 'file_size',
  423. 'share',
  424. 'doc_info',
  425. 'doc_block',
  426. 'receive_time'
  427. )
  428. VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
  429. $stmt = $PDO->prepare($query);
  430. $query = "UPDATE 'fileindex' SET 'doc_info' = ? , 'doc_block' = ? WHERE id = ? ";
  431. $stmt = $PDO->prepare($query);
  432. $newData = array(
  433. $strHead,
  434. json_encode($newDocBlockList, JSON_UNESCAPED_UNICODE),
  435. $_GET["doc_id"],
  436. );
  437. $stmt->execute($newData);
  438. if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
  439. $error = PDO_ErrorInfo();
  440. echo "error - $error[2] <br>";
  441. } else {
  442. //文档列表插入成功
  443. echo "doc list updata 1 recorders.";
  444. echo "<a href='../studio/editor.php?op=opendb&doc_id={$_GET["doc_id"]}'>在编辑器中打开</a>";
  445. }
  446. }
  447. ?>
  448. </div>
  449. </body>
  450. </html>