头一次做这种带评论带积分的公众号,记录一下,如果有大神看出漏洞了求指教23333
1.操作积分方法函数:
public function makeIntegral($openid,$cate,$num,$remark,$a_id=''){ $uid = $this->getUserId($openid); $oldScore = Db::name('member')->where(['id'=>$uid])->value('integral'); Db::startTrans(); try{ $map = [ 'u_id' =>$uid, #用户id 'openid' =>$openid, #用户openid 'cate' =>$cate, # 1+ 2- 'num' =>$num, #分值 'remark' =>$remark, #文字记录 'ctime' =>time(), #积分操作时间 'status' =>1, #数据状态 'a_id' =>$a_id ]; if($cate==1){ $newScore = $oldScore+$num; }else{ $newScore = $oldScore-$num; #新的积分不能为负数 否则返回扣分失败 if($newScore<0){ Log::write('积分扣除失败,您没有足够的积分。时间:'.date('Y-m-d H:i:s').',openid:'.$openid,'info'); return ['code'=>500,'msg'=>'积分扣除失败,您没有足够的积分。']; } } $add = Db::name('integral')->insert($map); $Add = Db::name('member')->where(['openid'=>$openid])->update(['integral'=>$newScore]); Db::commit(); if($add && $Add){ return ['code'=>200,'msg'=>'积分操作成功']; }else{ return ['code'=>500,'msg'=>'积分操作失败']; } }catch(\Exception $e){ Db::rollback(); return ['code'=>500,'msg'=>'错误']; } }
这个方法中要操作两张表,一张是积分表,新增数据,一张是用户表,修改用户的积分值,所以用了tp5的事务,操作错误的时候方便回滚。cate是分数操作类别,1是加分操作,2是减分操作。
2.签到方法
/** * 签到方法 * @return \think\response\Json */ public function sign_in(){ $pub=new PublicModel(); $openid = session('userInfo.openid'); $u_id = $pub->getUserId($openid); $today = date('Y-m-d'); #今天的年月日 $signList = $pub->getSignRecored($u_id); #之前签到的时间戳 $continueDay = Db::name('member') ->where(['openid'=>$openid,'status'=>1]) ->value('day'); #连续多少天 if(($continueDay+1)%7==0 && ($continueDay+1)<=7){ #满一周 $today_sign_integral=10; }else if(($continueDay+1)%15==0 && ($continueDay+1)/15==1){ #第一次满15天 $today_sign_integral=20; }else if(($continueDay+1)%30==0 && ($continueDay+1)/30==1){ #第一次满30天 $today_sign_integral=50; }else{ $today_sign_integral=($continueDay%7)+1; } if(!empty($signList)){ #如果签到列表不为空,则查询今天是否完成签到 foreach ($signList as $k=>$v){ $date = date('Y-m-d',$v['ctime']); if($date==$today){ #今天签到过 $arr = ['code'=>300,'msg'=>'您今天已经完成签到']; return json($arr); } } } Db::startTrans(); try{ $data = [ 'u_id'=>$u_id, 'ctime'=>time(), 'integral'=>$today_sign_integral ]; $signIn = Db::name('sign_in')->insert($data);#签到表添加 $addScore = $pub->makeIntegral($openid,1,$today_sign_integral,'签到加分','');#积分记录修改 $addContinueDay = Db::name('member')->where(['status'=>1,'openid'=>$openid])->update(['day'=>($continueDay+1)]); Db::commit(); if($signIn&&$addScore&&$addContinueDay){ return json(['code'=>200,'msg'=>'签到成功','num'=>$today_sign_integral]); }else{ return json(['code'=>500,'msg'=>'操作异常']); } }catch (\Exception $e){ Db::rollback(); return json(['code'=>'500','msg'=>'false']); } }
甲方粑粑要求签到积分,一周一轮,第一天签到+1分,连续第二天签到+2分,连续第三天签到+3分 以此类推,第一次满连续七天签到的当天可获得10分,第一次满连续签到15天的当天可获得20分,第一次满连续签到30天的当天可获得50分。所以我在用户表里给了个字段记录签到天数,有个检查是否断签的方法,断签就把字段清零。签到在签到表里记录,然后加分。
3.检查是否断签
/** * 检查是否断签 * @return array * @throws \think\Exception * @throws \think\exception\PDOException */ public function checkContinueSign($openid){ $pub = new PublicModel(); $u_id = $pub->getUserId($openid); try{ #判断上一次的签到是否在昨天之内 $signList = Db::name('sign_in')->where(['u_id'=>$u_id,'status'=>1])->order(['ctime'=>'desc'])->select(); if(!$signList){ $arr = ['code'=>400,'msg'=>'第一天签到']; return $arr; } $last_sign = Db::name('sign_in')->where(['u_id'=>$u_id,'status'=>1])->order(['ctime'=>'desc'])->limit(0,1)->value('ctime'); /**昨天的时间戳时间范围*/ $t = time(); $last_start_time = mktime(0,0,0,date("m",$t),date("d",$t)-1,date("Y",$t)); $last_end_time = mktime(23,59,59,date("m",$t),date("d",$t)-1,date("Y",$t)); /**今天的时间戳时间范围*/ $now_start_time = mktime(0,0,0,date("m",$t),date("d",$t),date("Y",$t)); $now_end_time = mktime(23,59,59,date("m",$t),date("d",$t),date("Y",$t)); if($last_sign>$last_start_time && $last_sign < $last_end_time){ #昨天签到了 $arr = ['code'=>200,'msg'=>'连续签到']; }elseif($last_sign>$now_start_time && $last_sign < $now_end_time){ #今天的签到已完成 $arr = ['code'=>300,'msg'=>'您今天已经完成签到']; }else{ #今天没签到,断签 Db::name('member')->where(['id'=>$u_id,'status'=>1])->update(['day'=>0]); $arr = ['code'=>500,'msg'=>'检测为断签']; } return $arr; }catch (Exception $e){ return ['code'=>$e->getCode(),'msg'=>$e->getMessage()]; } }
4.评论方法
/** * 评论 */ if(request()->isPost()){ $openid = session('userInfo.openid'); $pub = new PublicModel(); $u_id = $pub->getUserId($openid); $map = input('post.'); $data = [ 'ctime'=>time(), 'a_id'=>$map['a_id'], 'u_id'=>$u_id, 'content'=>$map['comment'], 'status'=>1 ]; list($start, $end) = Time::today(); $todayTopComment = Db::name('comment')->where(['status'=>1,'ctime'=>['<',$end],'u_id'=>$u_id])->where(['ctime'=>['>',$start]])->where(['back'=>null])->count(); if($todayTopComment<10){ Db::name('comment')->insert($data); $res = $pub->makeIntegral($openid,1,1,'发表评论',$map['a_id']);#加分 return json($res); }else{ $res = Db::name('comment')->insert($data); if($res){ return json(['code'=>2019,'msg'=>'评论成功,今日评论加分已到达上限']); }else{ return json(['code'=>500,'msg'=>'评论失败']); } } }
甲方爸爸要求用户每评论一个就加一个积分,每天上限10分,我自己给文章设置了一篇文章值只能发表一个评论,当前用户可以删除自己的评论,然后重新发。
5.点赞,取消
/** * 文章点赞/取消 * @return \think\response\Json */ public function dianzan(){ try{ $openid = session('userInfo.openid'); $pub = new PublicModel(); $data = input('post.'); $u_id = $pub->getUserId($openid); if($data['cate']==1){ #点赞 $map = [ 'dz_time'=>time(), 'u_id' =>$u_id, 'a_id' =>$data['a_id'], 'status' =>1 ]; }else{ #取消 $map = [ 'qx_time'=>time(), 'status' =>0 ]; } $isZanRecord = Db::name('zan')->where(['u_id'=>$u_id,'a_id'=>$data['a_id']])->find(); if(!$isZanRecord){ $res = Db::name('zan')->insert($map); if($res){ $num = Db::name('zan')->where(['a_id'=>$data['a_id'],'status'=>1])->count(); $arr = ['code'=>200,'data'=>'/static/home/images/article/07.png','msg'=>'点赞成功','num'=>$num,'zan'=>0]; }else{ $arr = ['code'=>500,'data'=>'','msg'=>'点赞失败']; } }else{ $res = Db::name('zan')->where(['u_id'=>$u_id,'a_id'=>$data['a_id']])->update($map); if($res){ $num = Db::name('zan')->where(['a_id'=>$data['a_id'],'status'=>1])->count(); if($data['cate']==1){ $arr = ['code'=>200,'data'=>'/static/home/images/article/07.png','msg'=>'点赞成功','num'=>$num,'zan'=>0]; }else{ $arr = ['code'=>200,'data'=>'/static/home/images/article/06.png','msg'=>'取消成功','num'=>$num,'zan'=>1]; } }else{ $arr = ['code'=>500,'data'=>'','msg'=>'点赞失败']; } } }catch (\Exception $e) { $arr = ['code'=>$e->getCode(),'data'=>'','msg'=>$e->getMessage()]; } return json($arr); }