更新cscd段落编号表

app/admin/db_update_cs6_para.php

@@ -2,6 +2,12 @@
 require_once "../public/_pdo.php";
 require_once "../path.php";
 
+$db_file = _FILE_DB_PALITEXT_;
+PDO_Connect("sqlite:$db_file");
+
+$query = "select * from books where 1";
+$books = PDO_FetchAll($query);
+
 
 	$db_file = _FILE_DB_PAGE_INDEX_;
 	PDO_Connect("sqlite:$db_file");
@@ -11,7 +17,7 @@ require_once "../path.php";
 	if(($fp=fopen("./cs6_para.csv", "r"))!==FALSE){
 		// 开始一个事务，关闭自动提交
 		$PDO->beginTransaction();
-		$query="INSERT INTO cs6_para ('book','para','book_name','cspara') VALUES (  ? , ? , ? , ? )";
+		$query="INSERT INTO cs6_para ('book','para','bookid','cspara','book_name') VALUES (  ? , ? , ? , ? , ? )";
 		$stmt = $PDO->prepare($query);
 
 		// 提交更改 
@@ -19,8 +25,16 @@ require_once "../path.php";
 			while(($data=fgetcsv($fp,0,','))!==FALSE){
 				$irow++;
 				if($irow>1){
+					$book_id=0;
+					foreach ($books as $key => $value) {
+						# code...
+						if($value["book"]==$data[0] && $data[1]>=$value["paragraph"]){
+							$book_id = $value["id"];
+							break;
+						}
+					}
 					if($data[3]==$data[4]){
-						$stmt->execute(array($data[0],$data[1],$data[2],$data[3]));
+						$stmt->execute(array($data[0],$data[1],$book_id,$data[3],$data[2]));
 					}
 					else{
 						$begin = (int)$data[3];
@@ -30,7 +44,7 @@ require_once "../path.php";
 							$arr1[] = $i;
 						}
 						foreach ($arr1 as $key => $value) {
-							$stmt->execute(array($data[0],$data[1],$data[2],$value));
+							$stmt->execute(array($data[0],$data[1],$book_id,$value,$data[2]));
 						}						
 					}