mint/public/app/db/custom_book.php

<?php
require_once "../config.php";
require_once "../db/table.php";
require_once '../hostsetting/function.php';


class CustomBook extends Table
{
    function __construct($redis=false) {
		parent::__construct(_FILE_DB_USER_CUSTOM_BOOK_, _TABLE_CUSTOM_BOOK_, "", "",$redis);
    }

	public function new($title,$data,$lang)
	{
		$respond['status']=0;
		$respond['message']="";
		$respond['content']="";

		$sent = explode("\n",$data);
		if($sent && count($sent)>0){
			$setting =  new Hostsetting();
			$max_book = $setting->get("max_book_number");
			if($max_book){
				$currBook = $max_book+1;
				$setbooknum = $setting->set("max_book_number",$currBook);
				if($setbooknum==false){
					$respond["status"]=1;
					$respond["message"]="设置书号错误";
					return $respond;
				}
			}
			else{
				$respond["status"]=1;
				$respond["message"]="获取书号错误";
				return $respond;
			}

			$query="INSERT INTO {$this->table} 
            (
                id,
                book_id,
                title,
                owner,
                editor_id,
                lang,
                status
                ) VALUES (?,?, ?, ?, ?, ? , ?)";

			$stmt = $this->execute($query,array($this->SnowFlake->id(),$currBook,$title,$_COOKIE["user_uid"],$_COOKIE["user_id"],$lang,10));
			if($stmt){
				$CSent = new CustomBookSentence($this->redis);
				$respond = $CSent->insert($currBook,$sent,$lang);
			}
			else{
				$respond["status"]=1;
				$respond["message"]="插入新书失败";
			}
		}
		return $respond;
	}
}

class CustomBookSentence extends Table
{
    function __construct($redis=false) {
		parent::__construct(_FILE_DB_USER_CUSTOM_BOOK_, _TABLE_CUSTOM_BOOK_SENT_, "", "",$redis);
    }

	public function getAll($book,$para,$start,$end){
		$query="SELECT content as text,length,lang,modify_time,create_time,owner FROM {$this->table} WHERE book = ? AND paragraph = ? AND word_start = ? AND word_end = ?";
		$result = $this->fetch($query,array($book,$para,$start,$end));
		if($result){
			return $result;
		}
		else{
			return array("text"=>"","length"=>"","lang"=>"","modify_time"=>0,"create_time"=>0,"owner"=>"");
		}
	}

	#将句子插入数据库
	#包含句子识别算法，表格算一个句子，list算一个句子
	public function insert($book,$content,$lang)
	{
		$respond['status']=0;
		$respond['message']="";
		$respond['content']="";
		# 开始一个事务，关闭自动提交 
		$this->dbh->beginTransaction();
		$query="INSERT INTO {$this->table} 
        (
            id,
            book,
            paragraph,
            word_start,
            word_end,
            length,
            content,
            lang,
            owner,
            status,
            create_time,
            modify_time
        ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
		
		$sth = $this->dbh->prepare($query);
		
		$para = 1;
		$sentNum = 1;
		$newText =  "";
		$isTable=false;
		$isList=false;
		$newSent="";		
		foreach ($content as $data) {
            $listHead= "";
            $isList = false;

			$trimData = trim($data);
	
            # 判断是否为list
			$listLeft =strstr($data,"- ",true);
			if($listLeft !== FALSE){
                if(ctype_space($listLeft) || empty($listLeft)){
                    # - 左侧是空，判定为list
                    $isList=true;
                    $iListPos = mb_strpos($data,'- ',0,"UTF-8");
                    $listHead = mb_substr($data,0,$iListPos+2,"UTF-8");
                    $listBody = mb_substr($data,$iListPos+2,mb_strlen($data,"UTF-8")-$iListPos+2,"UTF-8");
                }
			}

            # TODO 判断是否为标题
            # [#]+\s
			
			if(mb_substr($trimData,0,1,"UTF-8")=="|"){
				$isTable=true;
			}
			if($trimData!="" && $isTable == true){
				$newSent .= "\n";
				continue;
			}
            if($isList == true){
                $newSent .= $listBody;
            }else{
                $newSent .= $trimData;
            }

			

		
			#生成句子编号
			if($trimData==""){
				#空行
				if(strlen($newSent)>0){
					//之前有内容
					{
					$newText .='{{'."{$book}-{$para}-{$sentNum}-{$sentNum}"."}}\n";
					$sth->execute(
							array(
                                $this->SnowFlake->id(),
								$book,
								$para,
								$sentNum,
								$sentNum,
								mb_strlen($data,"UTF-8"),
								$newSent,
								$lang,
								$_COOKIE["userid"],
								10,
								mTime(),
								mTime()
							)); 
						}
					$newSent="";				
				}
				#新的段落 不插入数据库
				$para++;
				$sentNum = 1;
				$newText .="\n";
				$isTable = false;
				$isList = false;			
				continue;
			}else{
				$sentNum=$sentNum+10;
			}

			if(mb_substr($trimData,0,2,"UTF-8")=="{{"){
				#已经有的句子链接不处理
				$newText .=$trimData."\n";
			}else{
                $newText .= $listHead;
				$newText .='{{'."{$book}-{$para}-{$sentNum}-{$sentNum}"."}}\n";
				$sth->execute(
						array(
                            $this->SnowFlake->id(),
							$book,
							$para,
							$sentNum,
							$sentNum,
							mb_strlen($data,"UTF-8"),
							$newSent,
							$lang,
							$_COOKIE["userid"],
							10,
							mTime(),
							mTime()
						));  
				$newSent="";              
			}

		}

		if(strlen($newSent)>0){
			//最后一行是表格结束
			{
			$newText .='{{'."{$book}-{$para}-{$sentNum}-{$sentNum}"."}}\n";
			$sth->execute(
					array(
                        $this->SnowFlake->id(),
						$book,
						$para,
						$sentNum,
						$sentNum,
						mb_strlen($data,"UTF-8"),
						$newSent,
						$lang,
						$_COOKIE["userid"],
						10,
						mTime(),
						mTime()
					)); 
				}
			$newSent="";				
		}
		$this->dbh->commit();
		
		if (!$sth || ($sth && $sth->errorCode() != 0)) {
			#  识别错误且回滚更改  
			$this->dbh->rollBack();
			$error = $this->dbh->errorInfo();
			$respond['status']=1;
			$respond['message']=$error[2];
			$respond['content']="";
		}
		else{
			$respond['status']=0;
			$respond['message']="成功";
			$respond['content']=$newText;
		}	

		return $respond;
	}

	public function getText($book,$para,$start,$end){
		$query="SELECT content  FROM {$this->table} WHERE book = ? AND paragraph = ? AND word_start=? AND word_end = ?";
		$result = $this->fetch($query,array($book,$para,$start,$end));
		if($result){
			return $result["content"];
		}
		else{
			return "unkow";
		}
	}

}

?>