Skip to content

Instantly share code, notes, and snippets.

@summic

summic/gist:1022971

Created June 13, 2011 15:20
Show Gist options
  • Save summic/1022971 to your computer and use it in GitHub Desktop.
Save summic/1022971 to your computer and use it in GitHub Desktop.
Download ZIP
commentModel
Raw
gistfile1.php
<?php
//日记操作类
class commentModel{
function __construct(){
global $db,$user,$IN;
$this->db = $db;
$this->user = $user;
$this->input = $IN;
$error_msg = '';
}
//添加评论的时候，全局应该有spammer的数据库，并可以学习，被加入到spammer次数达到一定阀值，就认为是垃圾。
public function add($id,$type,$uid){
$data = array(
'uid' => $uid,
'id' => $id,
'type' => $type,
'author_id' => $this->user->uid,
'author_name' => $this->user->uid ? $this->user->session['username'] : $this->input->post('author'),
'author_email' => $this->user->uid ? $user->session['email'] : $this->input->post('email'),
'author_url' => $this->user->uid ? $user->session['domain'] : $this->input->post('url'),
'author_ip' => $this->input->ip_address(),
'status' => $this->user->uid ? 1 : 1, //TODO 非站内用户的评论需审核
'dateline' => time(),
'comment' => nl2br($this->input->post('comment')),
);
//未登录、无名
if(!$this->user->uid && empty($data['author_name'])){
$this->set_error('name','好汉留名！');
}
//未登录，无email
if(!$this->user->uid && empty($data['author_email'])){
$this->set_error('email','邮件不写怎么联系你呢?');
}
//无内容
if(empty($data['comment'])){
$this->set_error('comment','什么也不写就提交？那是无效的！');
}
//禁止包含链接
if(strpos($data['comment'],'http://')) {
$this->set_error('comment','评论中不允许包含链接！');
}
//如果有错退出
if($this->error_msg) {
//给出临时数据
$this->setTemp($_POST);
return false;
}
//检查数据库中是否已存在相同数据，防止重复提交
$query = $this->db->query("SELECT cid FROM ".tname('comment')." WHERE id ='".$data['id']."' AND author_ip='".$data['author_ip']."' AND comment = '".$data['comment']."'");
//写入cookie
setcookie('author', $data['author_name'], 2145916800, '/');
setcookie('email', $data['author_email'], 2145916800, '/');
setcookie('url', $data['author_url'], 2145916800, '/');
if($this->db->num_rows($query)) {
$this->set_error('say','相同的评论您已经提交过一次了！');
return false;
}else{
$cid = inserttable('comment', $data, 1);
if($data['status'] == 1) {
$this->syncCommentsNum($id,$type);
}else{
$this->set_error('say','您的评论需要审核后才能显示！');
}
return $cid;
}
return false;
}
public function edit($blog_id){
$blogData = array();
$blogData['user_id'] = $this->user->uid;
$blogData['subject'] = $this->input->post('subject', 1);
$blogData['message'] = nl2br($this->input->post('content', 1));
$blogData['blog_privacy'] = $this->input->post('privacy');
$blogData['blog_commenter'] = $this->input->post('commenter');
$blogData['blog_tags'] = $this->formatTags($this->input->post('tags'), str);
$blogData['blog_upddt'] = now();
//检查标题是否为空
if(empty($blogData['subject'])){
$this->set_error('标题必须填写');
return FALSE;
}
//检查内容是否为空
if(empty($blogData['blog_content'])){
$this->set_error('内容必须填写');
return FALSE;
}
$query = $this->db->query("
UPDATE ".tname('blog')."
SET subject = '" . $blogData['subject'] ."',
message = '" . $blogData['message']."',
blog_privacy = '" . $blogData['blog_privacy'] ."',
blog_commenter = '" . $blogData['blog_commenter'] . "',
blog_exclude = '" . $blogData['blog_exclude'] ."',
blog_tags = '" . $blogData['blog_tags'] ."',
blog_upddt = '" . $blogData['blog_upddt'] ."'
WHERE blogid = '".$blogData['blog_id']."'
AND uid = '".$blogData['user_id']."'
LIMIT 1
");
if($query){
//更新tags是个比较麻烦的问题
//$this->addTags($blogData['blog_tags'], $blog_id);
return $blog_id;
}else{
$this->set_error('修改日记失败，您没有权限修改这篇日记');
return FALSE;
}
return FALSE;
}
public function operation($opt, $id){
switch($opt) {
case 'delete':
$query = $this->db->query("DELETE FROM ".tname('comment')." WHERE cid = '".$id."' AND uid = '".$this->user->uid."'", 'UNBUFFERED');
break;
case 'approve':
$query = $this->db->query("UPDATE ".tname('comment')." SET `status` = '1' WHERE cid ='".$id."' AND uid = '".$this->user->uid."' LIMIT 1 ;");
break;
case 'unapprove':
$query = $this->db->query("UPDATE ".tname('comment')." SET `status` = '0' WHERE cid ='".$id."' AND uid = '".$this->user->uid."' LIMIT 1 ;");
break;
case 'spam':
$query = $this->db->query("UPDATE ".tname('comment')." SET `status` = '2' WHERE cid ='".$id."' AND uid = '".$this->user->uid."' LIMIT 1 ;");
break;
}
if($query){
Return TRUE;
}else{
$this->set_error('操作失败');
return FALSE;
}
}
//id 目标的id，$type 类型，1=log,2=set,3=pic, $uid = 所属用户id，$perpage 每页数目
function get($id,$type,$uid, $perpage = 30, $targetpage = ''){
//分页处理
$page = max(1, intval($this->input->get('p')));
$offset = ($page - 1) * $perpage;
$data = $this->db->fetch_first("SELECT COUNT(*) as num FROM ".tname('comment')." WHERE id ='".$id."' AND type = $type AND status = 1");
$total = $data['num'];
unset($data);
if($targetpage != 'inline') {
self::setPagination($page, $total, $perpage, $targetpage);
}
//查询并预处理数据
$query = $this->db->query("SELECT * FROM ".tname('comment')." WHERE id ='".$id."' AND type = $type AND status = 1 ORDER BY dateline ASC LIMIT $offset,$perpage");
$comments = array();
while($data = $this->db->fetch_array($query)){
if($data['author_id']){
$data['avatar'] = 'http://www.denglin.com/static/s1/p/1001_n.jpg';
}else{
$data['avatar'] = 'http://www.gravatar.com/avatar/'.md5($data['author_email']).'?s=32&d=monsterid';
}
$data['dateline'] = strElapsed($data['dateline']);
$comments[] = $data;
}
return $comments;
}
//后台读取所有自己收到的的评论
function getAll($uid,$status='all', $perpage = 15, $targetpage = ''){
$cond = "uid ='$uid'";
switch($status) {
case 'unapproved':
$cond .= " AND status =0";
break;
case 'approved':
$cond .= " AND status =1";
break;
case 'spam':
$cond .= " AND status =2";
break;
case 'all':
$cond .= " AND status !=2";
}
//分页处理
$page = max(1, intval($this->input->get('p')));
$offset = ($page - 1) * $perpage;
$data = $this->db->fetch_first("SELECT COUNT(*) as num FROM ".tname('comment')." WHERE $cond");
$total = $data['num'];
unset($data);
if($targetpage != 'inline') {
self::setPagination($page, $total, $perpage, $targetpage);
}
//查询并预处理数据
$query = $this->db->query("SELECT * FROM ".tname('comment')." WHERE $cond ORDER BY dateline DESC LIMIT $offset,$perpage");
$comments = array();
while($data = $this->db->fetch_array($query)){
$data['author_avatar'] = 'http://www.gravatar.com/avatar/'.md5($data['author_email']).'?s=32';
$data['dateline'] = strElapsed($data['dateline']);
$comments[] = $data;
}
return $comments;
}
public function getMine($uid, $perpage = 30) {
$cond = "author_id ='$uid'";
//分页处理
$page = max(1, intval($this->input->get('p')));
$offset = ($page - 1) * $perpage;
$data = $this->db->fetch_first("SELECT COUNT(*) as num FROM ".tname('comment')." WHERE $cond");
$total = $data['num'];
unset($data);
if($targetpage != 'inline') {
self::setPagination($page, $total, $perpage, $targetpage);
}
//查询并预处理数据
$query = $this->db->query("SELECT * FROM ".tname('comment')." WHERE $cond ORDER BY dateline DESC LIMIT $offset,$perpage");
$comments = array();
while($data = $this->db->fetch_array($query)){
$data['author_avatar'] = 'http://www.gravatar.com/avatar/'.md5($data['author_email']).'?s=32';
$data['dateline'] = strElapsed($data['dateline']);
$comments[] = $data;
}
return $comments;
}
//同步评论数
function syncCommentsNum($id,$type,$op='plus') {
switch($type) {
case 1:
$table = 'blog';
$id_name = 'blogid';
break;
case 2:
$table = 'album';
$id_name = 'albumid';
break;
case 3:
$table = 'pic';
$id_name = 'picid';
break;
}
$do = $op == 'plus' ? '+1':'-1';
$this->db->query("UPDATE LOW_PRIORITY ".tname($table)." SET comments=comments".$do." WHERE $id_name='$id'");
}
//
private function setPagination($page, $num, $offset,$targetpage) {
$this->pagination = '';//清除上次的数据（如果一个页面有两个分页的话）
$this->pagination = pagination($page, $num, $offset,$targetpage);
}
public function getPagination() {
return $this->pagination;
}
// 记录错误信息
private function set_error($name,$msg)
{
$this->error_msg[$name] = $msg;
}
// 输出错误信息
public function display_errors($open = '<span class="error">', $close = '</span>')
{
if(empty($this->error_msg)) return;
if(!is_array($this->error_msg) && !empty($this->error_msg)){
return $open.$this->error_msg.$close;
}
foreach ($this->error_msg as $key => $val)
{
$str[$key] = $open.$val.$close;
}
return $str;
}
private function setTemp($data) {
$this->tmpData = $data;
}
public function getTemp() {
return $this->tmpData;
}
};
?>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment