update.php 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138
  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. /* 修改现有数据 */
  35. $PDO->beginTransaction();
  36. $query="UPDATE sentence SET text= ? , status = ? , receive_time= ? , modify_time= ? where id= ? ";
  37. $sth = $PDO->prepare($query);
  38. foreach ($oldList as $data) {
  39. if(isset($data["id"])){
  40. if(isset($data["time"])){
  41. $modify_time = $data["time"];
  42. }
  43. else{
  44. $modify_time = mTime();
  45. }
  46. $sth->execute(array($data["text"], $data["status"], mTime(),$modify_time,$data["id"]));
  47. }
  48. }
  49. $PDO->commit();
  50. $respond=array("status"=>0,"message"=>"","insert_error"=>"","new_list"=>array());
  51. if (!$sth || ($sth && $sth->errorCode() != 0)) {
  52. /* 识别错误且回滚更改 */
  53. $PDO->rollBack();
  54. $error = PDO_ErrorInfo();
  55. $respond['status']=1;
  56. $respond['message']=$error[2];
  57. }
  58. else{
  59. $respond['status']=0;
  60. $respond['message']="成功";
  61. }
  62. /* 插入数据 */
  63. $PDO->beginTransaction();
  64. $query = "INSERT INTO sentence (id,
  65. parent,
  66. book,
  67. paragraph,
  68. begin,
  69. end,
  70. channal,
  71. tag,
  72. author,
  73. editor,
  74. text,
  75. language,
  76. ver,
  77. status,
  78. modify_time,
  79. receive_time
  80. )
  81. VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )";
  82. $sth = $PDO->prepare($query);
  83. $new_id = array();
  84. foreach ($newList as $data) {
  85. $uuid = UUID::v4();
  86. if($data["parent"]){
  87. $parent = $data["parent"];
  88. }
  89. else{
  90. $parent = "";
  91. }
  92. $sth->execute(array($uuid,
  93. $parent,
  94. $data["book"],
  95. $data["paragraph"],
  96. $data["begin"],
  97. $data["end"],
  98. $data["channal"],
  99. $data["tag"],
  100. $data["author"],
  101. $_COOKIE["userid"],
  102. $data["text"],
  103. $data["language"],
  104. 1,
  105. 7,
  106. mTime(),
  107. mTime()
  108. ));
  109. $new_id[] = array($uuid,$data["book"],$data["paragraph"],$data["begin"],$data["end"],$data["channal"]);
  110. }
  111. $PDO->commit();
  112. if (!$sth || ($sth && $sth->errorCode() != 0)) {
  113. /* 识别错误且回滚更改 */
  114. $PDO->rollBack();
  115. $error = PDO_ErrorInfo();
  116. $respond['insert_error']=$error[2];
  117. $respond['new_list']=array();
  118. }
  119. else{
  120. $respond['insert_error']=0;
  121. $respond['new_list']=$new_id;
  122. }
  123. echo json_encode($respond, JSON_UNESCAPED_UNICODE);
  124. ?>