9169-php/Application/Bibidd/Controller/WxShareTaskController.class.php

<?php

namespace bibidd\Controller;
use Bibidd\Controller\TaskManagerController;

/**
 *  微信分享
 */
class WxShareTaskController extends TaskManagerController
{

    /**
     * 微信分享提交
     * @return void
     */
    public function submit_task_for_wx()
    {
        $this->addHeaders(); //添加头部请求
        $user_info = $this->checkUserIsExist($_POST['uid']); //检查用户
        $task_id = $_POST['taskId'];
        $pt_id = $_POST['ptId'];//微信分享名字
        $wcrwImg = $_POST['images'];// 截图
        $pt = $_POST['pt'];// 平台
        $video_url = $_POST['videoUrl'];//访问url
        $sucai_number = $_POST['sucaiNumber'];// 素材编码
        $uid=$user_info['id'];
        if (empty($task_id)|| empty($pt) || empty($pt_id)  || empty($wcrwImg) || empty($video_url))
        {
            $this->returnDataAndSendMsg("微信分享名或截图信息不能为空，请正确添加交单内容");
            die();
        }

        //非空检查
        $task_info = M("dy_ks_task")->where("id='$task_id'")->find();
        if(empty($task_info))
        {
            $this->returnDataAndSendMsg("任务已不存在");
            die();
        }

        //判断用户是否被封禁了
        $task_type = $task_info['type'];
        $task_id = $task_info['id'];

        $context_num = M("dy_ks_orders")->field("id")
            ->where("uid = '$uid' AND status_ >=3 AND appeal_result in ('虚假垃圾达到1次，账号已被封','被驳回，账号已被封') AND type='$task_type'")
            ->count();
        if($context_num>0)
        {
            $this->returnDataAndSendMsg("虚假垃圾达到1次<br>已永久禁止做微信群分享任务");
            die();
        }

        //判断是否有其他用户提交相同微信名
        $order_check = M("dy_ks_orders")->where("uid != '$uid' AND pt_id = '$pt_id' AND type='$task_type'")->find();
        if(!empty($order_check))
        {
            $this->returnDataAndSendMsg("已有其他用户提交该信息");
            die();
        }

        //3天内不允许提交同一个分享任务,自然日
        $order_check = M("dy_ks_orders")->where("uid = '$uid'  AND type='$task_type' AND t_id = '$task_id' AND DATE(apply_date) >= CURDATE() - INTERVAL 3 DAY")->find();
        if(!empty($order_check))
        {
            $this->returnDataAndSendMsg("3天内不能做同一个分享任务");
            die();
        }


        $add_info['uid']=$user_info['id'];
        $add_info['t_id']=$task_id;
        $add_info['type']=$task_type;
        $add_info['amount']=$task_info['amount'];
        $add_info['pt']=$pt;
        $add_info['pt_id']=trim($pt_id);
        $add_info['wc_rw_img']=$wcrwImg;
        $add_info['video_url']=$video_url;
        $add_info['apply_date']=date('Y-m-d H:i:s');
        $add_info['pt_and_id']=$pt.$pt_id;
        $add_info['sucai_id']=$task_info['sc_id'];
        $add_info['sucai_number']=$sucai_number;

        $rs = M("dy_ks_orders")->add($add_info);

        $data['code'] = '200';
        $data['message'] = 'ok';
        $data['data'] = $rs;
        echo json_encode($data);
    }

    /**
     *  3天内是否提交过当前任务
     * @return void
     */
    public function has_3days_submit()
    {
        $this->addHeaders(); //添加头部请求
        $user_info = $this->checkUserIsExist($_POST['uid']); //检查用户
        $task_id = $_POST['taskId'];
        $uid=$user_info['id'];

        //非空检查
        $task_info = M("dy_ks_task")->where("id='$task_id'")->find();
        if(empty($task_info))
        {
            $this->returnDataAndSendMsg("任务已不存在");
            die();
        }

        $task_type = $task_info['type'];
        $task_id = $task_info['id'];

        //3天内不允许提交同一个分享任务,自然日
        $order_check = M("dy_ks_orders")->where("uid = '$uid'  AND type='$task_type' AND t_id = '$task_id' AND DATE(apply_date) >= CURDATE() - INTERVAL 3 DAY")->find();
        if(!empty($order_check))
        {
            $data['code'] = '200';
            $data['message'] = 'ok';
            $data['data'] = "yes";
            echo json_encode($data);
            die();
        }

        $data['code'] = '200';
        $data['message'] = 'ok';
        $data['data'] = "no";
        echo json_encode($data);
    }


    /**
     * 素材下载
     * @return void
     */
    public function down_sucai_for_wx()
    {
        $this->addHeaders(); //添加头部请求
        $user_info = $this->checkUserIsExist($_POST['uid']); //检查用户
        $scId = $_POST['scId']; //素材ID
        $type = $_POST['type']; //任务类型
        $task_id = $_POST['taskId']; //任务ID
        $uid = $user_info["id"];
        $weixin_name = $_POST['wxName']; //微信号
        if(empty($scId))
        {
            $this->returnDataAndSendMsg("素材ID不能为空.");
            die();
        }

        if(empty($task_id))
        {
            $this->returnDataAndSendMsg("任务ID不能为空");
            die();
        }
        if(empty($type))
        {
            $this->returnDataAndSendMsg("任务类型不能为空");
            die();
        }

        if(empty($weixin_name))
        {
            $this->returnDataAndSendMsg("微信分享名字不能为空");
            die();
        }
        $type_info = M("dy_ks_task_type")->where("type='$type'")->find();
        if(empty($type_info))
        {
            $this->returnDataAndSendMsg("该任务类型已不存在");
            die();
        }

        //判断用户是否被封禁了
        $is_fenjin = $this->is_check_shipinhao($uid,$type,TaskManagerController::WX_SHARE_SU_CAI_BIAO_NAME,"微信分享");
        if(!empty($is_fenjin) && $is_fenjin["isFengjin"])
        {
            $this->returnDataAndSendMsg($is_fenjin["descripe"]);
            die();
        }

        //判断时间，需要再结束时间倒退30分钟
        $start_time = strtotime(date("Y-m-d")." ".$type_info["start_time"]);
        $end_time = strtotime('-30 minutes', strtotime(date("Y-m-d")." ".$type_info["end_time"]));
        $curent_data = strtotime(date('Y-m-d H:i:s'));

        if($curent_data<$start_time || $curent_data>$end_time)
        {
            //不在做任务时间
            //$this->returnDataAndSendMsg("每天19:00~1:30开启，请下次再来.");
            //die();
        }

        //判断用户是否已经在做任务
        $this->check_task_ing($uid,TaskManagerController::WX_SHARE_SU_CAI_BIAO_NAME);

        //获取素材库
        $app_info = M("dy_wx_sucaiku")->field("id")->where("appid='$scId'")->find();
        $scId=$app_info['id'];
        $sucai_info = M("dy_wx_sucai_video")->where("status = 0 AND is_lock=0 AND sc_id='$scId'")->find();
        if(empty($sucai_info))
        {
            //没有有效素材
            $this->returnDataAndSendMsg("素材已被抢空<br>请稍后再来下载吧");
            die();
        }

        $sucai_info["down_date"]=date('Y-m-d H:i:s');
        $sucai_info["is_lock"]=1;
        $sucai_info["uid"]=$uid;
        $sucai_info["task_id"]=$task_id;
        $sucai_info["weixinhao_name"]=$weixin_name;
        M(TaskManagerController::WX_SHARE_SU_CAI_BIAO_NAME)->save($sucai_info);

        $data['code'] = '200';
        $data['message'] = 'ok';
        $data['data'] = $sucai_info;
        echo json_encode($data);
    }

    /**
     * 通过ID查询素材
     * @return void
     */
    public function get_wx_sucai_by_id()
    {
        $this->addHeaders(); //添加头部请求
        $user_info = $this->checkUserIsExist($_POST['uid']); //检查用户
        $id = $_POST['id'];

        $data['code'] = '200';
        $data['message'] = 'ok';
        $data['data'] = M("dy_wx_sucai_video")->where("id='$id'")->find();
        echo json_encode($data);
    }

    /**
     * 检查微信分享任务是否还有素材库
     * @return void
     */
    public function has_sucai_by_task_id()
    {
        $this->addHeaders(); //添加头部请求
        $user_info = $this->checkUserIsExist($_POST['uid']); //检查用户
        $taskId=$_POST['taskId'];
        if(empty($taskId))
        {
            $this->returnDataAndSendMsg("任务ID不能为空");
            die();
        }

        $task_info = M("dy_ks_task")->where("id='$taskId' AND status=0")->find();
        if(empty($task_info))
        {
            $this->returnDataAndSendMsg("此任务已不存在");
            die();
        }

        $ret_flg =0;
        $app_id = $task_info['sc_id'];
        $sucai_info = M("dy_wx_sucaiku")->where("appid='$app_id'")->field("id")->find();
        if(empty($sucai_info))
        {
            $this->returnDataAndSendMsg("素材库[appid]已不存在");
            die();
        }
        $sucai_id=$sucai_info['id'];
        $ret_flg = M("dy_wx_sucai_video")->where("sc_id=$sucai_id AND `status` =0 AND is_lock=0")->count();

        $data['code'] = '200';
        $data['message'] = 'ok';
        $data['data'] = $ret_flg;
        echo json_encode($data);
    }
}