|
|
@@ -66,7 +66,28 @@ class MessageController extends AdminBaseController{
|
|
|
$cates = $fenpei['cates'];
|
|
|
$from = $fenpei['tiaoshu'];
|
|
|
$map[] = ['create_time','>',$fenpei['from_time']];
|
|
|
- $lists = Db::name('message')->where('catid','in',$cates)->where($map)->order('id')->limit(0,$from)->select();
|
|
|
+
|
|
|
+ //ppppp
|
|
|
+ if($fenpei['enable']==1){
|
|
|
+ $map2[] = ['p1.create_time','>',$fenpei['from_time']];
|
|
|
+ $field=['p1.*','concat(LEFT(p1.mobile,4),"****",RIGHT(p1.mobile,3))'=>'mobile','count(p2.id)'=> 'vid' ];
|
|
|
+ $lists = Db::name('message')
|
|
|
+ ->alias('p1')
|
|
|
+ ->leftJoin('mobile_log p2','p1.`id`=p2.`msg_id`')
|
|
|
+ ->group('p1.`id`')
|
|
|
+ ->field($field)->where('p1.catid','in',$cates)->where($map2)->limit(0,$from)->select();
|
|
|
+
|
|
|
+ }else{
|
|
|
+
|
|
|
+ $field=['*'];
|
|
|
+ $lists = Db::name('message')->field($field)->where('catid','in',$cates)->where($map)->order('id')->limit(0,$from)->select();
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ // $lists = Db::name('message')->field($field)->where('catid','in',$cates)->where($map)->order('id')->limit(0,$from)->select();
|
|
|
+ $this->assign('fenpei',$fenpei);
|
|
|
+ //ppppp
|
|
|
// if($from<20){
|
|
|
// $lists = Db::name('message')->where('catid','in',$cates)->where($map)->order('id desc')->limit(0,$from)->select();
|
|
|
|
|
|
@@ -82,10 +103,156 @@ class MessageController extends AdminBaseController{
|
|
|
}
|
|
|
return $this->fetch();
|
|
|
}
|
|
|
+
|
|
|
+ public function tomobile()
|
|
|
+ {
|
|
|
+
|
|
|
+ $param = $this->request->param();
|
|
|
+ $username = $_SESSION['think']['name'];
|
|
|
+ $userinfo = Db::name('user')->where('user_login',$username)->find();
|
|
|
+ $userid = $userinfo['id'];
|
|
|
+ //分配的信息id
|
|
|
+ $fenpei = Db::name('user_fp')->where('userid',$userid)->find();
|
|
|
+ $bol=0;
|
|
|
+ if(!empty($fenpei))
|
|
|
+ {
|
|
|
+ $cates = $fenpei['cates'];
|
|
|
+ $from = $fenpei['tiaoshu'];
|
|
|
+ $map[] = ['create_time','>',$fenpei['from_time']];
|
|
|
+ $fromid=['id'=>$param['id']];
|
|
|
+ $lists = Db::name('message')->field(['id'])->where('catid','in',$cates)->where($map)->order('id')->limit(0,$from)->select()->toArray();
|
|
|
+ $message = Db::name('message')->field(['id','mobile'])->where('catid','in',$cates)->where($map)->where($fromid)->limit(0,$from)->find();
|
|
|
+ // dump(Db::table('message')->getLastSql());
|
|
|
+ foreach ($lists as $value) {
|
|
|
+ if(in_array($message['id'], $value)){
|
|
|
+ $bol=$message['mobile'];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //检查记录
|
|
|
+ if(!empty($message)){
|
|
|
+ $mobile_where=['user_id'=>$userid,'msg_id'=>$message['id']];
|
|
|
+ $mobile_log=Db::name('mobile_log')->where($mobile_where)->find();
|
|
|
+ if(empty($mobile_log))
|
|
|
+ {
|
|
|
+ //如果为空则需要插入记录并在user_fp减少一个点数
|
|
|
+ //先判断是否还有点数
|
|
|
+ if($fenpei['points']>0){
|
|
|
+ $mobile_in['user_id']=$userid;
|
|
|
+ $mobile_in['msg_id']=$message['id'];
|
|
|
+ $mobile_in['create_time']=time();
|
|
|
+ $res=Db::name('mobile_log')->insert($mobile_in);
|
|
|
+ if($res){
|
|
|
+
|
|
|
+ Db::name('user_fp')->where('userid',$userid)->dec('points', 1)->update();
|
|
|
+ $this->success($message['mobile']);
|
|
|
+ }
|
|
|
+
|
|
|
+ }else{
|
|
|
+ $this->error('你的点数已经用尽');
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }else{
|
|
|
+ $this->success($message['mobile']);
|
|
|
+ }
|
|
|
+
|
|
|
+ }else{
|
|
|
+ $this->error('数据获取错误');
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
|
|
|
public function add(){
|
|
|
return $this->fetch();
|
|
|
}
|
|
|
+
|
|
|
+
|
|
|
+ public function export()
|
|
|
+ {
|
|
|
+ $map = array();
|
|
|
+ $username = $_SESSION['think']['name'];
|
|
|
+ $userinfo = Db::name('user')->where('user_login',$username)->find();
|
|
|
+ $userid = $userinfo['id'];
|
|
|
+ //分配的信息id
|
|
|
+ $fenpei = Db::name('user_fp')->where('userid',$userid)->find();
|
|
|
+ if(!empty($fenpei))
|
|
|
+ {
|
|
|
+ $cates = $fenpei['cates'];
|
|
|
+ $from = $fenpei['tiaoshu'];
|
|
|
+ $map[] = ['create_time','>',$fenpei['from_time']];
|
|
|
+ if($fenpei['enable']==1){
|
|
|
+ $map2[] = ['p1.create_time','>',$fenpei['from_time']];
|
|
|
+ $field=['p1.*','FROM_UNIXTIME(p1.create_time)'=>'create_time' ];
|
|
|
+ $data = Db::name('message')
|
|
|
+ ->alias('p1')
|
|
|
+ ->leftJoin('mobile_log p2','p1.`id`=p2.`msg_id`')
|
|
|
+ ->field($field)->where('p1.catid','in',$cates)->where($map2)->where('p2.user_id',$userid)->limit(0,$from)->select();
|
|
|
+
|
|
|
+
|
|
|
+ }else{
|
|
|
+
|
|
|
+ $field=['*'];
|
|
|
+ $data = Db::name('message')->field($field)->where('catid','in',$cates)->where($map)->order('id')->limit(0,$from)->select();
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+ $field = array(
|
|
|
+ 'A' => array('jm_title', '品牌'),
|
|
|
+ 'B' => array('news_kw', '新闻'),
|
|
|
+ 'C' => array('catname', '分类'),
|
|
|
+ 'D' => array('name', '姓名'),
|
|
|
+ 'E' => array('ip', 'IP'),
|
|
|
+ 'F' => array('area', '所在区域'),
|
|
|
+ 'G' => array('tzed', '投资额度'),
|
|
|
+ 'H' => array('mobile', '电话'),
|
|
|
+ 'I' => array('content', '留言内容'),
|
|
|
+ 'J' => array('create_time', '留言时间'),
|
|
|
+
|
|
|
+ );
|
|
|
+
|
|
|
+ $this->exportExcel($field, $data,date('Y-m-d'));
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ private function exportExcel($field, $list, $title='name')
|
|
|
+ {
|
|
|
+
|
|
|
+ $objPHPExcel = new \PHPExcel();
|
|
|
+ $objWriter = new \PHPExcel_Writer_Excel5($objPHPExcel); //设置保存版本格式
|
|
|
+ $objPHPExcel->getActiveSheet()->setTitle('用户信息表');
|
|
|
+ foreach ($list as $key => $value) {
|
|
|
+ foreach ($field as $k => $v) {
|
|
|
+ if ($key == 0) {
|
|
|
+ $objPHPExcel->getActiveSheet()->setCellValue($k . '1', $v[1]);
|
|
|
+ }
|
|
|
+ $i = $key + 2;
|
|
|
+ $objPHPExcel->getActiveSheet()->setCellValue($k . $i, $value[$v[0]]);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ ob_end_clean();
|
|
|
+ header("Pragma: public");
|
|
|
+ header("Expires: 0");
|
|
|
+ header("Cache-Control:must-revalidate, post-check=0, pre-check=0");
|
|
|
+ header("Content-Type:application/force-download");
|
|
|
+ header("Content-Type:application/vnd.ms-execl");
|
|
|
+ header("Content-Type:application/octet-stream");
|
|
|
+ header("Content-Type:application/download");;
|
|
|
+ header('Content-Disposition:attachment;filename='.$title.'.xls');
|
|
|
+ header("Content-Transfer-Encoding:binary");
|
|
|
+ $objWriter->save('php://output');
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
public function addPost(){
|
|
|
$param = $this->request->param();
|
|
|
@@ -97,6 +264,21 @@ class MessageController extends AdminBaseController{
|
|
|
$param['jm_title'] = $info['title'];
|
|
|
}
|
|
|
}
|
|
|
+ // ppppppppp
|
|
|
+ if($param['catname']){
|
|
|
+ $cat=Db::name('category')->where('catname',$param['catname'])->find();
|
|
|
+ if(!empty($cat)){
|
|
|
+
|
|
|
+ $param['catid']=$cat['id'];
|
|
|
+
|
|
|
+ }else{
|
|
|
+ $this->error('添加失败');
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+ // ppppppppp
|
|
|
+
|
|
|
$param['create_time'] = time();
|
|
|
$res = Db::name('message')->insert($param);
|
|
|
if($res){
|
|
|
@@ -162,7 +344,9 @@ class MessageController extends AdminBaseController{
|
|
|
public function editPost(){
|
|
|
$param = $this->request->param();
|
|
|
isset($param['id']) or $this->error('需要id');
|
|
|
+
|
|
|
//先删掉
|
|
|
+
|
|
|
Db::name('Message_fp')->where('msg_id',$param['id'])->delete();
|
|
|
foreach($param['members'] as $kk=>$vv){
|
|
|
$data = array(
|
|
|
@@ -190,7 +374,22 @@ class MessageController extends AdminBaseController{
|
|
|
$param = $this->request->param();
|
|
|
isset($param['id']) or $this->error('需要id');
|
|
|
//先删掉
|
|
|
-
|
|
|
+
|
|
|
+ // ppppppppp
|
|
|
+ if($param['catname']){
|
|
|
+ $cat=Db::name('category')->where('catname',$param['catname'])->find();
|
|
|
+ if(!empty($cat)){
|
|
|
+
|
|
|
+ $param['catid']=$cat['id'];
|
|
|
+
|
|
|
+ }else{
|
|
|
+ $this->error('添加失败,没有该分类');
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+ // ppppppppp
|
|
|
+
|
|
|
$res = Db::name('message')->update($param);
|
|
|
$this->success('修改成功');
|
|
|
}
|
|
|
@@ -302,11 +501,17 @@ class MessageController extends AdminBaseController{
|
|
|
$param['cates'] = implode(",",$param['cates']);
|
|
|
$param['from_time'] = strtotime($param['from_time']);
|
|
|
$param['end_time'] = strtotime($param['end_time']);
|
|
|
+ //pppppp
|
|
|
+ if(!$param['enable']){
|
|
|
+ $param['enable']='2';
|
|
|
+ }
|
|
|
+ //pppppp
|
|
|
if($param['ypz']==1){
|
|
|
//更新
|
|
|
unset($param['ypz']);
|
|
|
$param['update_time'] = time();
|
|
|
$res = Db::name('user_fp')->where('userid',$param['userid'])->update($param);
|
|
|
+
|
|
|
}else{
|
|
|
//添加
|
|
|
unset($param['ypz']);
|