danci/www.hanlinyuanonline.com/Application/Cron/Controller/IndexController.class.php

<?php
namespace Cron\Controller;
use Common\Controller\CronController;
class IndexController extends CronController {
    public function index(){
        $res = M('PkRecord')->where(array('record_status'=>1,'operate_dt'=>array('ELT',strtotime('-1 minute'))))->field('record_id,user_id,ref_user_id')->select();
        if ($res==NULL){
            return FALSE;
        }
        foreach ($res as $row){
            M('PkRecord')->where(array('record_id'=>$row['record_id']))->save(array('record_status'=>3));
            M('User')->where(array('user_id'=>array('IN',array($row['ref_user_id'],$row['user_id']))))->save(array('user_status'=>0));
            $returnData = array('record_id'=>$$row['record_id'],'user_id'=>$row['user_id'],'ref_user_id'=>$row['ref_user_id']);
            $dataSoc = json_encode(array('code'=>0,'type'=>3,'msg'=>'未应战','data'=>$returnData));
            $this->pushMsg($dataSoc, array($row['user_id']));
            //$this->pushMsg($dataSoc, array($row['ref_user_id'],$row['user_id']));
        }
    }
    
    //修改一个小时之前的用户状态
    public function status(){
        $res = M('PkRecord')->where(array('record_status'=>array('IN','2,3,4,6'),'operate_dt'=>array('ELT',strtotime('-1 hours'))))->group('user_id,ref_user_id')->field('record_id,user_id,ref_user_id')->select();
        if ($res==NULL){
            return FALSE;
        }
        foreach ($res as $row){
            $info = M('User')->where(array('user_status'=>array('NEQ',1),'user_id'=>array('IN',array($row['user_id'],$row['ref_user_id'])),))->field('user_id')->find();
            foreach ($info as $r){
                M('User')->where(array('user_id'=>$r['user_id']))->save(array('user_status'=>0));
            }
        }
    }
}