论坛风格切换
发帖 回复
返回列表
  • 4095阅读
  • 1回复

[常用修复工具]更新评分的工具 [复制链接]

 上一主题 下一主题
离线太史慈
荣誉会员
 

发帖
766
金币
626
威望
556
只看楼主 倒序阅读 使用道具 楼主  发表于: 2011-11-21
— 本帖被 云天河 从 项目开发 移动到本区(2011-11-21) —
从pw_pinglog表统计更新pw_threads的ifmark
保存成update_mark.php
楼主的版本是老版，1楼的版本是后来的更新版，效率高一点。

复制代码
  1. <?php
  2. error_reporting(0);
  3. define('P_W',1);
  4. define('PW_UPLOAD',1);
  5. define('R_P',getdirname(__FILE__));
  6. define('D_P',R_P);
  8. require_once(R_P.'require/common.php');
  9. include_once(D_P.'data/bbscache/config.php');
  10. //require_once(R_P.'admin/cache.php');
  12. @header("Content-Type:text/html; charset=$db_charset");
  14. include_once(D_P.'data/sql_config.php');
  15. //if ($database=='mysqli' && Pwloaddl('mysqli')===false) {
  16.     $database = 'mysql';
  17. //}
  18. require_once Pcv(R_P."require/db_$database.php");
  19. $db = new DB($dbhost,$dbuser,$dbpw,$dbname,$PW,$charset,$pconnect);
  21. $t_k = $_GET['t_k'];
  22. $action = $_GET['action'];
  23. $start = $_GET['start'];
  24. if(!$action){
  25.     $action = 1;
  26. }
  27. if(!$start){
  28.     $start = 0;
  29. }
  30. if(!$t_k){
  31.     $t_k = 0;
  32. }
  33. $percount = 1000;
  35. require_once R_P.'require/pingfunc.php';
  36. if ($action == '1')
  37. {
  38.     //根据评分信息来更新tmsgs的ifmark字段
  39.     $ifmark='';
  40.     echo '根据评分信息来更新tmsgs的ifmark字段';
  41.     echo '<br>';
  42.     echo "SELECT fid,tid FROM pw_threads WHERE tid>$start ORDER BY tid LIMIT $percount";
  43.     echo '<br>';
  44.     $query = $db->query("SELECT fid,tid FROM pw_threads WHERE tid>$start ORDER BY tid LIMIT $percount");
  45.     while ($t = $db->fetch_array($query))
  46.     {
  47.         $lastid = $t['tid'];
  48.         $count = $db->get_value("SELECT SUM(point) FROM pw_pinglog WHERE tid=".$t['tid']);
  49.         if($count){
  50.             $db->update("UPDATE pw_threads SET ifmark=$count WHERE tid=".$t['tid']);
  51.             update_markinfo($t['fid'],$t['tid'],0);
  52.         }else{
  53.             $db->update("UPDATE pw_threads SET ifmark=0 WHERE tid=".$t['tid']);
  54.             $db->update("UPDATE pw_tmsgs SET ifmark='' WHERE tid=".$t['tid']);
  55.         }
  56.         $s_c++;
  57.     }
  59.     $maxid = $db->get_value("SELECT max(tid) FROM pw_threads");
  60.     echo '当前pw_threads表最大tid '.$maxid;
  61.     if($maxid > $lastid)
  62.     {
  63.         echo "<meta http-equiv='refresh' content='0;url=update_mark.php?action=1&start=$lastid'>";
  64.     }
  65.     else{
  66.         echo "<meta http-equiv='refresh' content='0;url=update_mark.php?action=2'>";
  67.         //echo '根据评分信息来更新tmsgs的ifmark字段[结束]';exit;
  68.     }
  69. }
  70. elseif ($action == '2')
  71. {
  72.     $ptable = $_GET['ptable'];
  73.     if(!$ptable){
  74.         $ptable = 0;
  75.     }
  76.     //根据评分信息来更新posts的ifmark字段
  77.     if(!$ptable){
  78.         $pw_posts = 'pw_posts';
  79.     }else{
  80.         $pw_posts = 'pw_posts'.$ptable;
  81.     }
  82.     echo '根据评分信息来更新posts的ifmark字段';
  83.     echo '<br>';
  84.     echo "SELECT fid,tid,pid FROM $pw_posts WHERE pid>$start ORDER BY pid LIMIT $percount";
  85.     echo '<br>';
  86.     $query = $db->query("SELECT fid,tid,pid FROM $pw_posts WHERE pid>$start ORDER BY pid LIMIT $percount");
  87.     while ($p = $db->fetch_array($query))
  88.     {
  89.         $lastid = $p['pid'];
  90.         update_markinfo($p['fid'],$p['tid'],$p['pid']);
  91.         $s_c++;
  92.     }
  93.     $maxid = $db->get_value("SELECT max(pid) FROM $pw_posts");
  94.     echo '当前'.$pw_posts.'表最大pid '.$maxid;
  95.     if($maxid > $lastid)
  96.     {
  97.         echo "<meta http-equiv='refresh' content='0;url=update_mark.php?action=2&start=$lastid&ptable=$ptable&s_c=$s_c'>";
  98.     }
  99.     else{
  100.         $ptable++;
  101.         $ptable_check = $db->get_one("SHOW TABLE STATUS LIKE 'pw_posts{$ptable}'");
  102.         if($ptable_check){
  103.             echo "<meta http-equiv='refresh' content='0;url=update_mark.php?action=2&start=0&ptable=$ptable&s_c=$s_c'>";
  104.         }else{
  105.             echo '根据评分信息来更新回复的ifmark字段[结束]';exit;
  106.         }
  107.     }
  108. }
  110. function getdirname($path=null){
  111.     if (!empty($path)) {
  112.         if (strpos($path,'\\')!==false) {
  113.             return substr($path,0,strrpos($path,'\\')).'/';
  114.         } elseif (strpos($path,'/')!==false) {
  115.             return substr($path,0,strrpos($path,'/')).'/';
  116.         }
  117.     }
  118.     return './';
  119. }
  120. ?>
[url=http://www.phpwind.com]phpwind[/url]
回复
举报
离线太史慈
荣誉会员

发帖
766
金币
626
威望
556
只看该作者 沙发  发表于: 2011-11-21
复制代码
  1. <?php
  2. error_reporting(0);
  3. define('P_W',1);
  4. define('PW_UPLOAD',1);
  5. define('R_P',getdirname(__FILE__));
  6. define('D_P',R_P);
  8. require_once(R_P.'require/common.php');
  9. include_once(D_P.'data/bbscache/config.php');
  10. //require_once(R_P.'admin/cache.php');
  12. @header("Content-Type:text/html; charset=$db_charset");
  14. include_once(D_P.'data/sql_config.php');
  15. //if ($database=='mysqli' && Pwloaddl('mysqli')===false) {
  16.     $database = 'mysql';
  17. //}
  18. require_once Pcv(R_P."require/db_$database.php");
  19. $db = new DB($dbhost,$dbuser,$dbpw,$dbname,$PW,$charset,$pconnect);
  21. $t_k = $_GET['t_k'];
  22. $action = $_GET['action'];
  23. $start = $_GET['start'];
  24. if(!$action){
  25.     $action = 1;
  26. }
  27. if(!$start){
  28.     $start = 0;
  29. }
  30. if(!$t_k){
  31.     $t_k = 0;
  32. }
  33. $percount = 2000;
  35. require_once R_P.'require/pingfunc.php';
  36. if ($action == '1')
  37. {
  38.     if(!$start){
  39.         //$db->query("UPDATE pw_threads SET ifmark=''");
  40.         //$db->query("UPDATE pw_tmsgs SET ifmark=''");
  41.         //$db->query("UPDATE pw_posts SET ifmark=''");
  42.     }
  43.     $query = $db->query("SELECT * FROM pw_pinglog WHERE id>$start LIMIT $percount");
  44.     unset($lastid);
  45.     while ($rt = $db->fetch_array($query)){
  46.         $lastid = $rt['id'];
  47.         $ids = '';
  48.         $ifmark_threads = $db->get_value("SELECT ifmark FROM pw_threads WHERE tid=".$rt['tid']);
  49.         $ifmark_threads = $ifmark_threads+$rt['point'];
  50.         $db->update("UPDATE pw_threads SET ifmark = '$ifmark_threads' WHERE tid=".$rt['tid']);
  51.         if($rt['pid']==0){
  52.             $ifmark_tmsgs = $db->get_value("SELECT ifmark FROM pw_tmsgs WHERE tid=".$rt['tid']);
  53.             if(strpos($ifmark_tmsgs,":")){
  54.                 list($num,$ids) = explode(":",$ifmark_tmsgs);
  55.             }
  56.             if(!$ids){
  57.                 $num = 1;
  58.                 $ids = $rt['id'];
  59.                 $ifmark_tmsgs = $num.":".$ids;
  60.             }else{
  61.                 $idsarr = explode(",",$ids);
  62.                 if(!in_array($rt['id'],$idsarr)){
  63.                     $num++;
  64.                     $ids .= ','.$rt['id'];
  65.                     $ifmark_tmsgs = $num.":".$ids;
  66.                 }
  67.             }
  68.             $db->update("UPDATE pw_tmsgs SET ifmark = '$ifmark_tmsgs' WHERE tid=".$rt['tid']);
  69.         }else{
  70.             $ifmark_posts = $db->get_value("SELECT ifmark FROM pw_posts WHERE pid=".$rt['pid']);
  71.             if(strpos($ifmark_posts,":")){
  72.                 list($num,$ids) = explode(":",$ifmark_posts);
  73.             }
  74.             if(!$ids){
  75.                 $num = 1;
  76.                 $ids = $rt['id'];
  77.                 $ifmark_posts = $num.":".$ids;
  78.             }else{
  79.                 $idsarr = explode(",",$ids);
  80.                 if(!in_array($rt['id'],$idsarr)){
  81.                     $num++;
  82.                     $ids .= ','.$rt['id'];
  83.                     $ifmark_posts = $num.":".$ids;
  84.                 }
  85.             }
  86.             $db->update("UPDATE pw_posts SET ifmark = '$ifmark_posts' WHERE pid=".$rt['pid']);
  87.         }
  88.     }
  89.     $db->free_result($query);
  90.     $maxid = $db->get_value("SELECT max(id) FROM pw_pinglog");
  91.     empty($lastid) && $lastid = $end;
  93.     echo '最大id',$maxid,'<br>','最后id',$lastid;
  94.     if($lastid < $maxid){
  95.         echo "<meta http-equiv='refresh' content='0;url=update_mark.php?action=1&start=$lastid'>";
  96.     }else{
  97.         echo 111;exit;
  98.     }
  100. }
  101. elseif ($action == '2')
  102. {
  103.     //根据评分信息来更新tmsgs的ifmark字段
  104.     $ifmark='';
  105.     echo '根据评分信息来更新tmsgs的ifmark字段';
  106.     echo '<br>';
  107.     echo "SELECT fid,tid FROM pw_threads WHERE tid>$start ORDER BY tid LIMIT $percount";
  108.     echo '<br>';
  109.     $query = $db->query("SELECT fid,tid FROM pw_threads WHERE tid>$start ORDER BY tid LIMIT $percount");
  110.     while ($t = $db->fetch_array($query))
  111.     {
  112.         $lastid = $t['tid'];
  113.         $count = $db->get_value("SELECT SUM(point) FROM pw_pinglog WHERE tid=".$t['tid']);
  114.         if($count){
  115.             $db->update("UPDATE pw_threads SET ifmark=$count WHERE tid=".$t['tid']);
  116.             update_markinfo($t['fid'],$t['tid'],0);
  117.         }else{
  118.             $db->update("UPDATE pw_threads SET ifmark=0 WHERE tid=".$t['tid']);
  119.             $db->update("UPDATE pw_tmsgs SET ifmark='' WHERE tid=".$t['tid']);
  120.         }
  121.         $s_c++;
  122.     }
  124.     $maxid = $db->get_value("SELECT max(tid) FROM pw_threads");
  125.     echo '当前pw_threads表最大tid '.$maxid;
  126.     if($maxid > $lastid)
  127.     {
  128.         echo "<meta http-equiv='refresh' content='0;url=update_mark.php?action=1&start=$lastid'>";
  129.     }
  130.     else{
  131.         echo "<meta http-equiv='refresh' content='0;url=update_mark.php?action=2'>";
  132.         //echo '根据评分信息来更新tmsgs的ifmark字段[结束]';exit;
  133.     }
  134. }
  135. elseif ($action == '3')
  136. {
  137.     $ptable = $_GET['ptable'];
  138.     if(!$ptable){
  139.         $ptable = 0;
  140.     }
  141.     //根据评分信息来更新posts的ifmark字段
  142.     if(!$ptable){
  143.         $pw_posts = 'pw_posts';
  144.     }else{
  145.         $pw_posts = 'pw_posts'.$ptable;
  146.     }
  147.     echo '根据评分信息来更新posts的ifmark字段';
  148.     echo '<br>';
  149.     echo "SELECT fid,tid,pid FROM $pw_posts WHERE pid>$start ORDER BY pid LIMIT $percount";
  150.     echo '<br>';
  151.     $query = $db->query("SELECT fid,tid,pid FROM $pw_posts WHERE pid>$start ORDER BY pid LIMIT $percount");
  152.     while ($p = $db->fetch_array($query))
  153.     {
  154.         $lastid = $p['pid'];
  155.         update_markinfo($p['fid'],$p['tid'],$p['pid']);
  156.         $s_c++;
  157.     }
  158.     $maxid = $db->get_value("SELECT max(pid) FROM $pw_posts");
  159.     echo '当前'.$pw_posts.'表最大pid '.$maxid;
  160.     if($maxid > $lastid)
  161.     {
  162.         echo "<meta http-equiv='refresh' content='0;url=update_mark.php?action=2&start=$lastid&ptable=$ptable&s_c=$s_c'>";
  163.     }
  164.     else{
  165.         $ptable++;
  166.         $ptable_check = $db->get_one("SHOW TABLE STATUS LIKE 'pw_posts{$ptable}'");
  167.         if($ptable_check){
  168.             echo "<meta http-equiv='refresh' content='0;url=update_mark.php?action=2&start=0&ptable=$ptable&s_c=$s_c'>";
  169.         }else{
  170.             echo '根据评分信息来更新回复的ifmark字段[结束]';exit;
  171.         }
  172.     }
  173. }
  175. function getdirname($path=null){
  176.     if (!empty($path)) {
  177.         if (strpos($path,'\\')!==false) {
  178.             return substr($path,0,strrpos($path,'\\')).'/';
  179.         } elseif (strpos($path,'/')!==false) {
  180.             return substr($path,0,strrpos($path,'/')).'/';
  181.         }
  182.     }
  183.     return './';
  184. }
  185. ?>
[url=http://www.phpwind.com]phpwind[/url]
回复
举报
发帖 回复
返回列表
快速回复
限100 字节
批量上传需要先选择文件，再选择上传
 
提到某人：
选择好友
上一个 下一个