php投票系统简单实现源码

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

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

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

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

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

1. -- 
2. -- 表的结构 `count_voting` 
3. -- 
4.  
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='投票统计表'; 
15.  
16. -- -------------------------------------------------------- 
17.  
18. -- 
19. -- 表的结构 `ip_votes` 
20. -- 
21.  
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 ; 
33.  
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 ; 
43.  
44. -- -------------------------------------------------------- 
45.  
46. -- 
47. -- 表的结构 `user` 
48. -- 
49.  
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='用户表'; 
55.  
56. -- 
57. -- 转存表中的数据 `user` 
58. -- 
59.  
60. INSERT INTO `user` (`name`, `passwd`) VALUES 
61. ('ttxi', '700469ca1555900b18c641bf7b0a1fa1'), 
62. ('jitttanwa', 'adac5659956d68bcbc6f40aa5cd00d5c'); 
63.  
64. -- 
65. -- 限制导出的表 
66. -- 
67.  
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; 
14.  
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; 
6.  
7.     public function  __construct() 
8.     { 
9.         $this->odb = new OperatorDB(); 
10.     } 
11.     public function __destruct() 
12.     { 
13.         $this->odb = null; 
14.     } 
15.  
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.     } 
27.  
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.     } 
37.  
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.     } 
69.  
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.     } 
82.  
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.     } 
101.  
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. } 
26.  
27. function isLoginNow() 
28. { 
29.     if ($_COOKIE["user"]=='') 
30.     { 
31.         return false; 
32.     } 
33.     return true; 
34. } 
35.  
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. } 
63.  
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. } 
78.  
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. } 
13.  
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'; 
3.  
4.     if (!isLoginNow()) 
5.     { 
6.         goToPgae("./index.php"); 
7.     } 
8.  
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. } 
10.  
11. function goToPage1(url) 
12. { 
13.     window.location.href=url; 
14. } 

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

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