A-A+

php投票系统简单实现源码

2019年02月27日 我爱编程 暂无评论

数据库的设计:设计三张表,投票结果统计表(count_voting),投票人记录表(ip_votes),用户表(user).

投票结果统计表用于统计最后的投票记录,我给它弄了4个字段:被投票项的名称(SelectName)，被投票项标签名(LabelName)(起到分类的作用),票数(CountVotes).

投票人记录表用于登记投票人的ip(IP),地理位置(Location),投票时间(VoteTime),被投票项名称(SelectName),然后我还给它加一个ID.

用户表主要用于给管理员用的,包含用户名(name)和密码(passwd).

生成表的sql脚本如下,代码如下:

  1. --
  2. -- 表的结构 `count_voting`
  3. --
  5. DROP TABLE IF EXISTS `count_voting`;
  6. CREATE TABLE IF NOT EXISTS `count_voting` (
  7.   `SelectName` varchar(40) NOT NULL,
  8.   `LabelName` varchar(40) NOT NULL,
  9.   `CountVotes` bigint(20) unsigned NOT NULL,
  10.   UNIQUE KEY `SelectName` (`SelectName`),
  11.   KEY `CountVotes` (`CountVotes`),
  12.   KEY `CountVotes_2` (`CountVotes`),
  13.   KEY `CountVotes_3` (`CountVotes`)
  14. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='投票统计表';
  16. -- --------------------------------------------------------
  18. --
  19. -- 表的结构 `ip_votes`
  20. --
  22. DROP TABLE IF EXISTS `ip_votes`;
  23. CREATE TABLE IF NOT EXISTS `ip_votes` (
  24.   `ID` bigint(20) unsigned NOT NULL auto_increment COMMENT '投票人序号：自增',
  25.   `IP` varchar(15) NOT NULL COMMENT '投票人IP',
  26.   `Location` varchar(40) NOT NULL COMMENT '投票人位置',
  27.   `VoteTime` datetime NOT NULL,
  28.   `SelectName` varchar(40) NOT NULL,
  29.   PRIMARY KEY  (`ID`),
  30.   KEY `ID` (`ID`),
  31.   KEY `SelectName` (`SelectName`)
  32. ) ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=4 ;
  34. --
  35. -- 触发器 `ip_votes`
  36. --
  37. DROP TRIGGER IF EXISTS `vote_count_after_insert_tr`;
  38. DELIMITER //
  39. CREATE TRIGGER `vote_count_after_insert_tr` AFTER INSERT ON `ip_votes`
  40.  FOR EACH ROW UPDATE count_voting SET CountVotes = CountVotes + 1 WHERE SelectName = NEW.SelectName
  41. //
  42. DELIMITER ;
  44. -- --------------------------------------------------------
  46. --
  47. -- 表的结构 `user`
  48. --
  50. DROP TABLE IF EXISTS `user`;
  51. CREATE TABLE IF NOT EXISTS `user` (
  52.   `name` varchar(10) NOT NULL COMMENT '管理员用户名',
  53.   `passwd` char(32) NOT NULL COMMENT '登录密码MD5值'
  54. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='用户表';
  56. --
  57. -- 转存表中的数据 `user`
  58. --
  60. INSERT INTO `user` (`name`, `passwd`) VALUES
  61. ('ttxi', '700469ca1555900b18c641bf7b0a1fa1'),
  62. ('jitttanwa', 'adac5659956d68bcbc6f40aa5cd00d5c');
  64. --
  65. -- 限制导出的表
  66. --
  68. --
  69. -- 限制表 `ip_votes`
  70. --
  71. ALTER TABLE `ip_votes`
  72.   ADD CONSTRAINT `ip_votes_ibfk_1` FOREIGN KEY (`SelectName`) REFERENCES `count_voting` (`SelectName`) ON DELETE CASCADE ON UPDATE CASCADE;

从脚本中可以看出,我创建了一个触发器,当往ip_votes表中插入数据的时候就给count_voting表中的CountVotes字段加1,还能后出最后一句是设置外部关联字.

框架设计:OperatorDB类用于操作数据库,OperatorVotingDB类用于该系统特定的操作集合,使用PDO操作数据库,我它简单的封装一下,代码如下:

  1. /**
  2.  * 操作数据库
  3.  * 封装PDO，使其方便自己的操作
  4.  */
  5. class OperatorDB
  6. {
  7.     //连接数据库的基本信息
  8.     private $dbms='mysql';       //数据库类型,对于开发者来说，使用不同的数据库，只要改这个.
  9.     private $host='localhost';       //数据库主机名
  10.     private $dbName='voting';     //使用的数据库
  11.     private $user='voting';       //数据库连接用户名
  12.     private $passwd='voting';     //对应的密码
  13.     private $pdo=null;
  15.     public function  __construct()
  16.     {
  17.         //dl("php_pdo.dll");
  18.         //dl("php_pdo_mysql.dll");
  19.         $this->dsn="$this->dbms:host=$this->host;dbname=$this->dbName";
  20.         try
  21.         {
  22.             $this->conn=new PDO($this->dsn,$this->user,$this->passwd);//初始化一个PDO对象，就是创建了数据库连接对象$db
  23.         }
  24.         catch(PDOException $e)
  25.         {
  26.             die("<br/>数据库连接失败(creater PDO Error！): ".$e->getMessage()."<br/>");
  27.         }
  28.     }
  29.     public function __destruct()
  30.     {
  31.         $this->pdo = null;
  32.     }
  33.     public function exec($sql)
  34.     {
  35.     }
  36.     public function query($sql)
  37.     {
  38.     }
  39. }

把连接数据库的信息封装进去方便后续的操作,代码如下:

  1. <?php
  2. require_once 'OperatorDB.php';
  3. class OperatorVotingDB
  4. {
  5.     private $odb;
  7.     public function  __construct()
  8.     {
  9.         $this->odb = new OperatorDB();
  10.     }
  11.     public function __destruct()
  12.     {
  13.         $this->odb = null;
  14.     }
  16.     /**
  17.      * 清空Voting数据中的所有表
  18.      *
  19.      * 调用数据库操作类，执行clear数据库的操作
  20.      */
  21.     public function clearTables()
  22.     {
  23.         $sqls = array("TRUNCATE ip_votes;","TRUNCATE count_voting;");
  24.         $this->odb->exec($sqls[0]);
  25.         $this->odb->exec($sqls[1]);
  26.     }
  28.     /**
  29.      * 重置count_voting表中的CountValues字段为0
  30.      *
  31.      */
  32.     public function resetCountValues()
  33.     {
  34.         $sql = "UPDATE count_voting SET CountVotes = 0;";
  35.         $this->odb->exec($sql);
  36.     }
  38.     /**
  39.      * 投票
  40.      * 将信息写入ip_votes表
  41.      * @param type $ip
  42.      * @param type $loc
  43.      * @param type $time
  44.      * @param type $name
  45.      */
  46.     public function vote($ip,$loc,$name)
  47.     {
  48.         $sql = "INSERT INTO ip_votes VALUES (NULL, '$ip', '$loc', NOW(), '$name')";
  49.         $subsql = "SELECT MAX(to_days(VoteTime)) FROM ip_votes WHERE IP='$ip'";
  50.         $stm = $this->odb->query($subsql);
  51.         if (count($row=$stm->fetchAll())==1)
  52.         {
  53.             $now = date("Y-m-d H:i:s");
  54.             $subsql = "SELECT to_days('$now');";
  55.             $stm = $this->odb->query($subsql)->fetch();
  56.             $time = $stm[0];//使用mysql计算出的today时间
  57. //            echo $time."<br>";
  58. //            echo $row[0][0];
  59.             if ($time-$row[0][0]<1)//表中最大的时间和现在的时间$time比较
  60.             {
  61.                 echo "投票失败，相同ip需要隔一天才能投票";
  62.                 return;
  63.             }
  64.         }
  65. //        echo $sql;
  66.         echo "投票成功!";
  67.         $this->odb->exec($sql);
  68.     }
  70.     /**
  71.      * 添加SelectName字段的行
  72.      *
  73.      * @param string $name
  74.      * @param string $label
  75.      * @param int $count
  76.      */
  77.     public function addSelectName($name, $label, $count=0)
  78.     {
  79.         $sql = "INSERT INTO count_voting VALUES ('$name', '$label', $count);";
  80.         $this->odb->exec($sql);
  81.     }
  83.     /**
  84.      * 获取总投票情况,按票数排序的结果
  85.      *
  86.      * 按CountVotes字段排序，返回count_voting表
  87.      *
  88.      * @param int $n
  89.      *
  90.      */
  91.     public function getVotesSortByCount($n=-1)
  92.     {
  93.         $sql = "SELECT * FROM count_voting ORDER BY CountVotes DESC LIMIT 0 , $n;";
  94.         if (-1 == $n)
  95.         {
  96.             $sql = "SELECT * FROM count_voting ORDER BY CountVotes DESC;";
  97.         }
  98. //        echo $sql;
  99.         return $this->odb->query($sql);
  100.     }
  102.     /**
  103.      * 获取投票情况,按票数排序并按标签分组的结果
  104.      *
  105.      * 按CountVotes字段排序并按LabelName字段分组，返回count_voting表
  106.      */
  107.     public function getVotesGroupByLabel()
  108.     {
  109.         $sql = "SELECT * FROM count_voting ORDER BY LabelName DESC;";//开源代码phpfensi.com
  110. //        echo $sql;
  111.         return $this->odb->query($sql);
  112.     }
  113. }
  114. ?>

下面还有需要的函数,代码如下:

  1. <?php
  2. /**
  3.  * 页面跳转函数
  4.  * 使用js实现
  5.  * @param string $url
  6.  */
  7. function goToPgae($url)
  8. {
  9.     echo "<script language='javascript' type='text/javascript'>";
  10.     echo "window.location.href='$url'";
  11.     echo "</script>";
  12. }
  13. function jsFunc($fun, $arg=null)
  14. {
  15.     echo "<script language='javascript' type='text/javascript'>";
  16.     echo $fun."('$arg');";
  17.     echo "</script>";
  18. }
  19. function jsFunc3($fun, $arg1=null,$arg2=null,$arg3=null)
  20. {
  21.     echo "<script language='javascript' type='text/javascript'>";
  22.     echo $fun."('$arg1','$arg2','$arg3');";
  23.     echo "</script>";
  24.     //echo $fun."('$arg1','$arg2','$arg3');";
  25. }
  27. function isLoginNow()
  28. {
  29.     if ($_COOKIE["user"]=='')
  30.     {
  31.         return false;
  32.     }
  33.     return true;
  34. }
  36. function getClientIP()
  37. {
  38.     if ($_SERVER["HTTP_X_FORWARDED_FOR"])
  39.     {
  40.         if ($_SERVER["HTTP_CLIENT_IP"])
  41.         {
  42.                 $proxy = $_SERVER["HTTP_CLIENT_IP"];
  43.         }
  44.         else
  45.         {
  46.             $proxy = $_SERVER["REMOTE_ADDR"];
  47.         }
  48.         $ip = $_SERVER["HTTP_X_FORWARDED_FOR"];
  49.     }
  50.     else
  51.     {
  52.         if ($_SERVER["HTTP_CLIENT_IP"])
  53.         {
  54.                 $ip = $_SERVER["HTTP_CLIENT_IP"];
  55.         }
  56.         else
  57.         {
  58.             $ip = $_SERVER["REMOTE_ADDR"];
  59.         }
  60.     }
  61.     return $ip;
  62. }
  64. //从123查获取ip
  65. function getIpfrom123cha($ip) {
  66.     $url = 'http://www.123cha.com/ip/?q='.$ip;
  67.         $content = file_get_contents($url);
  68.         $preg = '/(?<=本站主数据:</li><li style="width:450px;">)(.*)(?=</li>)/isU';
  69.         preg_match_all($preg, $content, $mb);
  70.         $str = strip_tags($mb[0][0]);
  71.         //$str = str_replace(' ', '', $str);
  72.         $address = $str;
  73.         if($address == '') {
  74.             $address = '未明';
  75.         }
  76.     return $address;
  77. }
  79. //从百度获取ip所在地
  80. function getIpfromBaidu($ip) {
  81.     $url = 'http://www.baidu.com/s?wd='.$ip;
  82.     $content = file_get_contents($url);
  83.     $preg = '/(?<=<p class="op_ip_detail">)(.*)(?=</p>)/isU';
  84.     preg_match_all($preg, $content, $mb);
  85.     $str = strip_tags($mb[0][1]);
  86.     $str = str_replace(' ', '', $str);
  87.     $address = substr($str, 7);
  88.     if($address == '') {
  89.         $address = '未明';
  90.     }
  91.     return $address;
  92. }
  93. ?>

然后就是后台管理员的操作怎么弄了,主要是添加投票项的功能,操作数据库上面已经实现,后面的基本上是页面怎么设置,关系到js,添加投票项的页面是动态的,代码如下:

  1. function addVote()
  2. {
  3.     right.innerHTML="<h2>添加投票项</h2>";
  4.     right.innerHTML+="<label>投票项标签<label>";
  5.     addInput("right","cLabelName","地区名");
  6.     right.innerHTML+="<br><label>投票项名称<label>";
  7.     addInput("right","cSelectName","学校名");
  8.     right.innerHTML+="<br>";
  9.     var args = ''./add.php','cSelectName','cLabelName'';
  10.     var str = '<input type=button value="u6dfb加" onclick="goToPage('+args+');"/>';
  11.     right.innerHTML+=str;
  12. }
  14. //添加文本框
  15. function addInput(parent,id,pla)
  16. {
  17.     //创建input
  18.     var input = document.createElement("input");
  19.     input.type = "text";
  20.     input.id = id;
  21.     input.placeholder = pla;
  22.     document.getElementById(parent).appendChild(input);
  23. }

添加投票项是通过url传递变量到add.php页面的,代码如下:

  1. <?php
  2.     require_once '../api/func.php';
  4.     if (!isLoginNow())
  5.     {
  6.         goToPgae("./index.php");
  7.     }
  9.     $name = $_GET["cSelectName"];
  10.     $label = $_GET["cLabelName"];
  11.     //echo $name."<br>".$label;
  12.     require_once '../api/OperatorVotingDB.php';
  13.     $ovdb=new OperatorVotingDB();
  14.     $ovdb->addSelectName($name,$label);
  15.     require './header.htm';
  16.     goToPgae("./admin.php?page=add&auto="."$label"."&id=cLabelName&foc=cSelectName&msg=添加成功");
  17. ?>

下面是两个跳转页面的函数,js的,上面func.php中的跳转页面函数也是通过js实现的,代码如下:

  1. //js
  2. function goToPage(url,arg1,arg2)
  3. {
  4.     var a = document.getElementById(arg1).value;
  5.     var b = document.getElementById(arg2).value;
  6.     url += '?'+arg1+'='+a;
  7.     url += '&'+arg2+'='+b;
  8.     window.location.href=url;
  9. }
  11. function goToPage1(url)
  12. {
  13.     window.location.href=url;
  14. }

还有修改删除功能没有实现,我应该不会去实现那个了吧,js的话和添加功能差不多.

登录模块的话网上很多,模仿的,就是提交表单,查找数据库,返回结果,成功则设置cookie,后台的每个页面都添加了检测cookie的功能的.

标签：

给我留言

Copyright © 四季博客 保留所有权利.   Theme  Ality

用户登录