user info 迁移到 pg

app/Models/SentHistory.php

@@ -8,4 +8,5 @@ use Illuminate\Database\Eloquent\Model;
 class SentHistory extends Model
 {
     use HasFactory;
+    const UPDATED_AT = null;
 }

public/app/admin/setting.php

@@ -82,8 +82,8 @@ switch ($currSettingItem) {
 <?php
 switch ($currSettingItem) {
     case "account":
-        PDO_Connect("" . _FILE_DB_USERINFO_);
-        $query = "SELECT * from 'user' where 1 limit 0,1000";
+        PDO_Connect(_FILE_DB_USERINFO_);
+        $query = "SELECT * from "._TABLE_USER_INFO_." where 1 limit 0,1000";
         $user_info = PDO_FetchAll($query);
         echo "<table>";
         echo "<tr><th>id</th><th>user name</th><th>nick name</th></tr>";
@@ -153,4 +153,4 @@ foreach ($Fetch as $album) {
 	</div>
 
 </body>
-</html>
+</html>

public/app/course/teacher_list.php

@@ -7,7 +7,7 @@ require_once '../public/load_lang.php';
 require_once '../ucenter/function.php';
 
 global $PDO;
-PDO_Connect("" . _FILE_DB_COURSE_);
+PDO_Connect( _FILE_DB_COURSE_);
 $query = "SELECT teacher,count(*) as co from course where 1 group by teacher order by co DESC limit 0,4";
 $Fetch = PDO_FetchAll($query);
 
@@ -17,7 +17,8 @@ foreach ($Fetch as $value) {
     echo '<div class="teacher_text">';
     echo '<div class="title"><a href="../uhome/course.php?userid=' . $value['teacher'] . '">' . ucenter_getA($value['teacher']) . '</a></div>';
     echo '<div class="teacher_intro">';
-    PDO_Connect("" . _FILE_DB_USERINFO_);
+    /*
+    PDO_Connect(_FILE_DB_USERINFO_);
     $query = "SELECT bio from profile where user_id = ? limit 0,10";
     $Fetch = PDO_FetchAll($query,array($value['teacher']));
     if($Fetch){
@@ -26,6 +27,7 @@ foreach ($Fetch as $value) {
     else{
         echo "";
     }
+    */
     echo '</div>';
 
     echo '</div>';

public/app/db/user.php

@@ -30,7 +30,7 @@ CREATE TABLE users (
 class PCD_User extends Table
 {
     function __construct($redis=false) {
-		parent::__construct(_FILE_DB_USERINFO_, "user", "", "",$redis);
+		parent::__construct(_FILE_DB_USERINFO_, _TABLE_USER_INFO_, _DB_USERNAME_,_DB_PASSWORD_,$redis);
     }
 
 	public function  index(){

public/app/doc/coopfilelist.php

@@ -15,7 +15,7 @@ else{
 	exit;
 }
 
-    PDO_Connect(""._FILE_DB_FILEINDEX_);
+    PDO_Connect(_FILE_DB_FILEINDEX_);
     $query = "SELECT * from power where user = ? order by modify_time DESC";
     $Fetch = PDO_FetchAll($query,array($_COOKIE["userid"]));
     $result=array();
@@ -35,5 +35,5 @@ else{
         }
     }
 	echo json_encode($result, JSON_UNESCAPED_UNICODE);
-	
-?>
+
+?>

public/app/install/install_head.php

@@ -11,7 +11,7 @@ set_error_handler("customError");
 
 function user_db_is_exist()
 {
-    $PDO = new PDO("" . _FILE_DB_USERINFO_, "", "");
+    $PDO = new PDO( _FILE_DB_USERINFO_, _DB_USERNAME_,_DB_PASSWORD_);
     $PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
     $stmt = $PDO->query("SELECT count(*) as co FROM sqlite_master WHERE type=\"table\" AND name = \"user\"");
 

public/app/studio/project.php

@@ -62,7 +62,7 @@ if ($_COOKIE["uid"]) {
 }
 if(isset($_POST["channal"])){
     $channelClass = new Channal(redis_connect());
-    $channelInfo = $channelClass->getChannal($_POST["channal"]); 
+    $channelInfo = $channelClass->getChannal($_POST["channal"]);
 }
 
 
@@ -172,14 +172,14 @@ switch ($op) {
                                     $block_data[] = array
 									(
 										$snowId,
-										$block_id, 
-										"", 
-										$_POST["channal"], 
-										$_COOKIE['userid'], 
-										$_COOKIE['uid'], 
-										$book, 
-										$iPar, 
-										"_none_", 
+										$block_id,
+										"",
+										$_POST["channal"],
+										$_COOKIE['userid'],
+										$_COOKIE['uid'],
+										$book,
+										$iPar,
+										"_none_",
 										$channelInfo["lang"],
 										$channelInfo["status"],
 										mTime(),
@@ -223,16 +223,16 @@ switch ($op) {
                                         $wbw_data[] = array
 										(
 											$snowflake->id(),
-											UUID::v4(), 
-											$block_id, 
-											$book, 
-											$iPar, 
-											$result["wid"], 
-											$result["real"], 
-											$strXml, 
-											mTime(), 
-											mTime(), 
-											0, 
+											UUID::v4(),
+											$block_id,
+											$book,
+											$iPar,
+											$result["wid"],
+											$result["real"],
+											$strXml,
+											mTime(),
+											mTime(),
+											0,
 											$_COOKIE['userid'],
 											$_COOKIE['uid']
 										);
@@ -246,22 +246,22 @@ switch ($op) {
                             PDO_Connect(_FILE_DB_USER_WBW_,_DB_USERNAME_,_DB_PASSWORD_);
                             $PDO->beginTransaction();
 
-                            $query = "INSERT INTO "._TABLE_USER_WBW_BLOCK_." 
-									( 
+                            $query = "INSERT INTO "._TABLE_USER_WBW_BLOCK_."
+									(
 										id,
-										uid , 
-										parent_id , 
-										channel_uid , 
-									 	creator_uid , 
+										uid ,
+										parent_id ,
+										channel_uid ,
+									 	creator_uid ,
 										editor_id,
-										book_id , 
-										paragraph , 
-									  	style , 
-									  	lang , 
-									  	status , 
+										book_id ,
+										paragraph ,
+									  	style ,
+									  	lang ,
+									  	status ,
 									  	create_time ,
-									  	modify_time 
-									) 
+									  	modify_time
+									)
 									  VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?)";
                             $stmt = $PDO->prepare($query);
                             foreach ($block_data as $oneParam) {
@@ -280,19 +280,19 @@ switch ($op) {
                             // 开始一个事务，关闭自动提交
 
                             $PDO->beginTransaction();
-                            $query = "INSERT INTO "._TABLE_USER_WBW_." 
-										( 
+                            $query = "INSERT INTO "._TABLE_USER_WBW_."
+										(
 										  id,
-										  uid , 
-										  block_uid , 
-										  book_id , 
-										  paragraph , 
-										  wid , 
-										  word , 
-										  data , 
-										  create_time , 
-										  modify_time , 
-										  status , 
+										  uid ,
+										  block_uid ,
+										  book_id ,
+										  paragraph ,
+										  wid ,
+										  word ,
+										  data ,
+										  create_time ,
+										  modify_time ,
+										  status ,
 										  creator_uid ,
 										  editor_id
 										)
@@ -315,7 +315,7 @@ switch ($op) {
                             $PDO_File = new PDO(_FILE_DB_FILEINDEX_,_DB_USERNAME_,_DB_PASSWORD_,array(PDO::ATTR_PERSISTENT=>true));
                             $PDO_File->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
 
-                            $queryInsert = "INSERT INTO \""._TABLE_FILEINDEX_."\"  
+                            $queryInsert = "INSERT INTO \""._TABLE_FILEINDEX_."\"
  (
                                     id,
 									uid,
@@ -337,7 +337,7 @@ switch ($op) {
 									accese_time,
 									accesed_at,
 									updated_at,
-									created_at) 
+									created_at)
 									VALUES (? , ? , ? , ? , ?, ? ,? , ? , ? , ?, ? ,? , ? , ? , ?, ? ,? , ? , ? , ?, ? )";
                             $stmtDEST = $PDO_File->prepare($queryInsert);
                             $doc_id = UUID::v4();
@@ -369,17 +369,17 @@ switch ($op) {
                                     $created_at
                                 );
                             try{
-                                $stmtDEST->execute($commitData); 
+                                $stmtDEST->execute($commitData);
                                 echo "成功新建一个文件.";
                                 echo "<a href=\"editor.php?op=opendb&doc_id={$doc_id}\">{$_local->gui->open}</a>";
                             }catch(PDOException $e){
                                 echo($e->getMessage().PHP_EOL);
                                 echo "<pre>";
                                 print_r($commitData);
-                                echo "</pre>";                                
+                                echo "</pre>";
                                 exit;
                             }
-                            
+
 
                         }
                         break;
@@ -1009,7 +1009,7 @@ exit;
                                 //获取文件路径
                                 echo "共享的文档，复制并打开...";
                                 PDO_Connect(_FILE_DB_USERINFO_);
-                                $query = "select userid from user where id='$owner'";
+                                $query = "SELECT userid from "._TABLE_USER_INFO_." where id='$owner'";
                                 $FetchUid = PDO_FetchOne($query);
                                 if ($FetchUid) {
                                     $source = _DIR_USER_DOC_ . "/" . $FetchUid . _DIR_MYDOCUMENT_ . "/" . $filename;
@@ -1113,4 +1113,4 @@ exit;
         break;
 }
 ?>
-</body>
+</body>

public/app/ucenter/card.php

@@ -9,7 +9,7 @@ require_once '../ucenter/function.php';
 if (isset($_GET["id"])) {
 	$output["id"]=$_GET["id"];
 	PDO_Connect( _FILE_DB_USERINFO_);
-    $query = "SELECT userid as id ,username,nickname,create_time FROM user WHERE userid=?";
+    $query = "SELECT userid as id ,username,nickname,create_time FROM "._TABLE_USER_INFO_." WHERE userid=?";
 	$channel = PDO_FetchRow($query, array($_GET["id"]));
 	$strData="";
 	if ($channel) {
@@ -27,4 +27,4 @@ if (isset($_GET["id"])) {
 }
 echo json_encode($output, JSON_UNESCAPED_UNICODE);
 
-?>
+?>

public/app/ucenter/function.php

@@ -4,7 +4,7 @@ require_once __DIR__.'/../config.php';
 function ucenter_get($userid, $fields = "username")
 {
     //打开数据库
-    $dns = "" . _FILE_DB_USERINFO_;
+    $dns = _FILE_DB_USERINFO_;
     $dbh = new PDO($dns, _DB_USERNAME_,_DB_PASSWORD_, array(PDO::ATTR_PERSISTENT => true));
     $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
     $query = "SELECT username from "._TABLE_USER_INFO_." where id= ? ";

public/app/ucenter/get.php

@@ -3,7 +3,7 @@ require_once '../config.php';
 
 //打开数据库
 
-$dbh = new PDO(_FILE_DB_USERINFO_, "", "", array(PDO::ATTR_PERSISTENT => true));
+$dbh = new PDO(_FILE_DB_USERINFO_, _DB_USERNAME_,_DB_PASSWORD_, array(PDO::ATTR_PERSISTENT => true));
 $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
 if (isset($_GET["id"])) {
 	if(isset($_GET["bio"])){
@@ -12,7 +12,7 @@ if (isset($_GET["id"])) {
 	else{
 		$query = "SELECT userid as id ,username,nickname from user where userid = ? ";
 	}
-    
+
     $stmt = $dbh->prepare($query);
     $stmt->execute(array($_GET["id"]));
     $fUser = $stmt->fetchAll(PDO::FETCH_ASSOC);

public/app/ucenter/pwd_set.php

@@ -8,9 +8,9 @@ if (!isset($_COOKIE["userid"])) {
     if (isset($_POST["pwd_set"])) {
         if ($_POST["password"] == $_POST["repassword"]) {
             $md5_password = md5($_POST["password"]);
-            $PDO = new PDO("" . _FILE_DB_USERINFO_, "", "");
+            $PDO = new PDO(_FILE_DB_USERINFO_, _DB_USERNAME_,_DB_PASSWORD_);
             $PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
-            $query = "UPDATE user SET password = ? WHERE userid = ? ";
+            $query = "UPDATE "._TABLE_USER_INFO_." SET password = ? WHERE userid = ? ";
             $stmt = $PDO->prepare($query);
             $stmt->execute(array($md5_password, $_COOKIE["userid"]));
             if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
@@ -50,4 +50,4 @@ if (!isset($_COOKIE["userid"])) {
 
 }
 
-?>
+?>

public/app/ucenter/set_setting.php

@@ -4,9 +4,9 @@ require_once "../public/_pdo.php";
 require_once '../public/function.php';
 
 global $PDO;
-PDO_Connect("" . _FILE_DB_USERINFO_);
+PDO_Connect(_FILE_DB_USERINFO_);
 
-$query = "UPDATE user SET  setting = ? where  userid = ?  ";
+$query = "UPDATE "._TABLE_USER_INFO_." SET  setting = ? where  userid = ?  ";
 $sth = $PDO->prepare($query);
 
 $sth->execute(array($_POST["data"], $_COOKIE["userid"]));

public/app/ucenter/setting_function.php

@@ -8,11 +8,11 @@ function get_setting()
     } else {
         $setting = json_decode(file_get_contents("../ucenter/default.json"), true);
         //打开数据库
-        $dns = "" . _FILE_DB_USERINFO_;
-        $dbh = new PDO($dns, "", "", array(PDO::ATTR_PERSISTENT => true));
+        $dns = _FILE_DB_USERINFO_;
+        $dbh = new PDO($dns, _DB_USERNAME_,_DB_PASSWORD_, array(PDO::ATTR_PERSISTENT => true));
         $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
 
-        $query = "select setting from user where userid = ? ";
+        $query = "SELECT setting from "._TABLE_USER_INFO_." where userid = ? ";
         $stmt = $dbh->prepare($query);
         $stmt->execute(array($_COOKIE["userid"]));
         $fUser = $stmt->fetchAll(PDO::FETCH_ASSOC);