update.php 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150
  1. <?php
  2. /*
  3. get xml doc from db
  4. */
  5. include "../path.php";
  6. include "../public/_pdo.php";
  7. include "../public/function.php";
  8. $aData=json_decode($_POST["data"],TRUE);
  9. PDO_Connect("sqlite:"._FILE_DB_SENTENCE_);
  10. //查询没有id的哪些是数据库里已经存在的,防止多次提交同一条记录造成一个句子 多个channal
  11. $newList = array();
  12. $oldList = array();
  13. $query = "SELECT id FROM sentence WHERE book = ? and paragraph = ? and begin = ? and end = ? and channal = ? limit 0 , 1 ";
  14. foreach ($aData as $data) {
  15. if(!isset($data["id"]) || empty($data["id"])){
  16. $id = PDO_FetchOne($query,array($data["book"],
  17. $data["paragraph"],
  18. $data["begin"],
  19. $data["end"],
  20. $data["channal"]
  21. ));
  22. if(empty($id)){
  23. $newList[] = $data;
  24. }
  25. else{
  26. $data["id"] = $id;
  27. $oldList[] = $data;
  28. }
  29. }
  30. else{
  31. $oldList[] = $data;
  32. }
  33. }
  34. $update_list = array(); //已经成功修改数据库的数据列表 回传客户端
  35. /* 修改现有数据 */
  36. $PDO->beginTransaction();
  37. $query="UPDATE sentence SET text= ? , status = ? , strlen = ? , receive_time= ? , modify_time= ? where id= ? ";
  38. $sth = $PDO->prepare($query);
  39. foreach ($oldList as $data) {
  40. if(isset($data["id"])){
  41. if(isset($data["time"])){
  42. $modify_time = $data["time"];
  43. }
  44. else{
  45. $modify_time = mTime();
  46. }
  47. $sth->execute(array($data["text"], $data["status"], mb_strlen($data["text"],"UTF-8"), mTime(),$modify_time,$data["id"]));
  48. }
  49. }
  50. $PDO->commit();
  51. $respond=array("status"=>0,"message"=>"","insert_error"=>"","new_list"=>array());
  52. if (!$sth || ($sth && $sth->errorCode() != 0)) {
  53. /* 识别错误且回滚更改 */
  54. $PDO->rollBack();
  55. $error = PDO_ErrorInfo();
  56. $respond['status']=1;
  57. $respond['message']=$error[2];
  58. }
  59. else{
  60. $respond['status']=0;
  61. $respond['message']="成功";
  62. foreach ($oldList as $key => $value) {
  63. $update_list[] = array("id" => $value["id"],"text" => $value["text"]);
  64. }
  65. }
  66. /* 插入新数据 */
  67. $PDO->beginTransaction();
  68. $query = "INSERT INTO sentence (id,
  69. parent,
  70. book,
  71. paragraph,
  72. begin,
  73. end,
  74. channal,
  75. tag,
  76. author,
  77. editor,
  78. text,
  79. language,
  80. ver,
  81. status,
  82. strlen,
  83. modify_time,
  84. receive_time,
  85. create_time
  86. )
  87. VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )";
  88. $sth = $PDO->prepare($query);
  89. foreach ($newList as $data) {
  90. $uuid = UUID::v4();
  91. if($data["parent"]){
  92. $parent = $data["parent"];
  93. }
  94. else{
  95. $parent = "";
  96. }
  97. $sth->execute(array($uuid,
  98. $parent,
  99. $data["book"],
  100. $data["paragraph"],
  101. $data["begin"],
  102. $data["end"],
  103. $data["channal"],
  104. $data["tag"],
  105. $data["author"],
  106. $_COOKIE["userid"],
  107. $data["text"],
  108. $data["language"],
  109. 1,
  110. 7,
  111. mb_strlen($data["text"],"UTF-8"),
  112. mTime(),
  113. mTime(),
  114. mTime()
  115. ));
  116. $new_id[] = array($uuid,$data["book"],$data["paragraph"],$data["begin"],$data["end"],$data["channal"]);
  117. }
  118. $PDO->commit();
  119. if (!$sth || ($sth && $sth->errorCode() != 0)) {
  120. /* 识别错误且回滚更改 */
  121. $PDO->rollBack();
  122. $error = PDO_ErrorInfo();
  123. $respond['insert_error']=$error[2];
  124. $respond['new_list']=array();
  125. }
  126. else{
  127. $respond['insert_error']=0;
  128. foreach ($newList as $key => $value) {
  129. $update_list[] = array("id" => $value[0],"text" => $value["text"]);
  130. }
  131. }
  132. $respond['update']=$update_list;
  133. echo json_encode($respond, JSON_UNESCAPED_UNICODE);
  134. ?>