<?php


class cron_model extends model
{

    /**
     * @desc 计划任务列表
     * @param array $whereData  查询条件
     * @param array $data       自定义处理数组
     * @return array|bool|false|string|void
     */
    public function getList($whereData = array(), $data = array())
    {

        $data['field'] = empty($data['field']) ? '*' : $data['field'];

        $list = array();

        $list = $this->select_all('cron', $whereData, $data['field']);

        if(!empty($list)){

            foreach ($list as $k => $v) {
                $list[$k]['src'] = Url('cron',array('id'=>$v['id']));
            }

        }
        

        return $list;
    }

    /**
     * @desc 单条计划任务列
     * @param $whereData    查询条件
     * @param array $data   自定义处理数组
     * @return array|bool|false|string|void
     */
    public function getInfo($whereData, $data = array())
    {

        $data['field'] = empty($data['field']) ? '*' : $data['field'];

        return $this->select_once('cron', $whereData, $data['field']);
    }

    /**
     * @desc 添加修改计划任务列表
     * @param array $data
     * @return string[]
     */
    public function addInfo($data = array())
    {
        if (!empty($data)) {

            $id =   $data["id"];
            unset($data["id"]);

            $data['nexttime']   =   strtotime($this->nextexe($data));

            if ($data['dir']) {
                $dirArr         =   explode('.', $data['dir']);

                if ($dirArr[0] == '' || strpos($dirArr[0], '/') !== false || end($dirArr) != 'php') {

                    return array('msg' => '无效的执行文件！', 'errcode' => '8');
                } else {

                    $data['dir']=   $dirArr[0].'.php';
                }
            } else {

                return array('msg' => '请填写计划任务执行文件！', 'errcode' => '8');
            }

            if ($data['type'] == 5) {
                if (trim($data['minu']) == '') {

                    return array('msg' => '请填写执行任务的间隔分钟数！', 'errcode' => '8');
                }
                $data['minute'] =   intval($data['minu']);
            }
            if ($data['type'] == 4) {
                if (trim($data['second']) == '') {

                    return array('msg' => '请填写执行任务的间隔秒数！', 'errcode' => '8');
                }
                $data['minute'] =   intval($data['second']);
            }

            if (!$id) {

                $data["ctime"]  =   time();

                $nbid           =   $this->insert_into('cron', $data);

                $return['msg']  =   "计划任务(id:" . $nbid . ")添加";
            } else {

                $nbid           =   $this->update_once('cron', $data, array('id' => $id));

                $return['msg']  =   "计划任务(ID:" . $id . ")修改";
            }

            $return['errcode']  =   $nbid ? '9' : '8';

            $return['msg']      =   $nbid ? $return['msg'] . '成功！' : $return['msg'] . '失败！';
        }

        return $return;
    }

    /**
     * @desc 删除计划任务列表
     * @param $delId
     * @return mixed
     */
    public function delInfo($delId)
    {
        if (!empty($delId)) {

            $nbid               =   $this->delete_all('cron', array('id' => $delId), '');
            $return['msg']      =   "计划任务(ID:" . $delId . ")";
            $return['errcode']  =   $nbid ? '9' : '8';
            $return['msg']      =   $nbid ? $return['msg'] . '删除成功！' : $return['msg'] . '删除失败！';
        }
        return $return;
    }

    function excron($cron, $id = '')
    {

        if (is_array($cron) && !empty($cron)) {

            foreach ($cron as $key => $value) {
                if ($id) {
                    if ($value['id'] == $id) {
                        $timestamp[$value['nexttime']] = $value;
                        $timestamp[$value['nexttime']]['cronkey'] = $key;
                        break;
                    }
                } else {

                    if ($value['nexttime'] <= time()) {
                        $timestamp[$value['nexttime']] = $value;
                        $timestamp[$value['nexttime']]['cronkey'] = $key;
                    }
                }
            }
            
            if ($timestamp) {

                $data['cron'] = ArrayToString($cron);
                $data['start'] = '1';
				$data['starttime'] = time();
                made_web_array(PLUS_PATH . 'cron.cache.php', $data);


                krsort($timestamp);
                $croncache = current($timestamp);

                set_time_limit(600);

                if (file_exists(LIB_PATH . 'cron/' . $croncache['dir'])) {
                    include(LIB_PATH . 'cron/' . $croncache['dir']);
                }

                $nexttime = $this->nextexe($croncache);

                $logdata = array(
                    'cid'=>$croncache['id'],
                    'ctime'=>time()
                );
                $this->addCronLog($logdata);

                $this->update_once("cron", array('nowtime' => time(), 'nexttime' => strtotime($nexttime)), array('id' => $croncache['id']));

                $cron[$croncache['cronkey']]['nexttime'] = strtotime($nexttime);
                $data['cron'] = ArrayToString($cron);

                $data['start'] = '0';
                made_web_array(PLUS_PATH . 'cron.cache.php', $data);
            }
        }
        return true;
    }

    function nextexe($value)
    {

        if ($value["type"] == '1' && $value["week"] > 0) {
            $W = date("w", time());
            if ($value["week"] >= $W) {
                $Day = date("Ymd", strtotime("+" . ($value["week"] - $W) . " days", time()));
            } else {
                $Day = date("Ymd", strtotime("+" . ($value["week"] - $W + 7) . " days", time()));
            }
        } elseif ($value['type'] == '2' && $value["month"] > 0) {
            if ($value["month"] < 10) {
                $Day = date('Ym') . "0" . $value["month"];
            } else {
                $Day = date('Ym') . "" . $value["month"];
            }
        } elseif ($value['type'] == '3') {
            $Day = date('Ymd');
        } else if($value['type'] == '5'){
            return date('YmdHis', time() + ($value['minute'] * 60));
        }else {
            return date('YmdHis', time() + $value['minute']);
        }

        $Date = $Day;

        if ($value["hour"] > 0) {
            if ($value["hour"] < 10) {
                $Date .= "0" . $value["hour"];
            } else {
                $Date .= $value["hour"];
            }
        } else {
            $Date .= '00';
        }
        if ($value["minute"] > 0) {
            if ($value["minute"] < 10) {
                $Date .= "0" . $value["minute"];
            } else {
                $Date .= $value["minute"];
            }
        } else {
            $Date .= '00';
        }


        if ($Date <= date('YmdHi')) {
            if ($value["type"] == '1' && $value["week"] > 0) {
                $Dates = date('Y-m-d', strtotime("+1 week", $Date));

            } elseif ($value['type'] == '2' && $value["month"] > 0) {
                $nextmonth = $this->GetMonth();
                if ($value["month"] < 10) {
                    $Dates = $nextmonth . '-0' . $value["month"];
                } else {
                    $Dates = $nextmonth . '-' . $value["month"];
                }
            } else {
                $Dates = date('Y-m-d', strtotime("+1 days", strtotime($Day)));
            }


            if ($value["hour"] > 0) {
                if ($value["hour"] < 10) {
                    $Dates .= ' 0' . $value["hour"];
                } else {
                    $Dates .= ' ' . $value["hour"];
                }
            } else {
                $Dates .= " 00";
            }

            if ($value["minute"] > 0) {
                if ($value["minute"] < 10) {
                    $Dates .= ':0' . $value["minute"];
                } else {
                    $Dates .= ':' . $value["minute"];
                }
            } else {
                $Dates .= ":00";
            }
            return $Dates;
        } else {
            return $Date;
        }
    }

    function GetMonth()
    {

        $tmp_date               =   date("Ym");
        $tmp_year               =   substr($tmp_date, 0, 4);
        $tmp_mon                =   substr($tmp_date, 4, 2);
        $tmp_nextmonth          =   mktime(0, 0, 0, $tmp_mon + 1, 1, $tmp_year);
        $tmp_forwardmonth       =   mktime(0, 0, 0, $tmp_mon - 1, 1, $tmp_year);
        return $fm_next_month   =   date("Y-m", $tmp_nextmonth);
    }

    function addCronLog($data=array()){

        $id = '';

        if(!empty($data)){

            $id =$this -> insert_into('cron_log', $data);

        }
        
        return $id;
    }

    function getCronLogs($where = array(), $data = array()){

        $logs   =   array();

        if (!empty($where)) {

            $field  =   $data['field'] ? $data['field'] : '*';

            unset($data['field']);

            $logs   =   $this->select_all('cron_log', $where, $field);

            if(!empty($logs)){

                $cid_arr = array();

                foreach ($logs as $key => $value) {
                    $cid_arr[] = $value['cid'];
                }

                $crons  =   $this->select_all('cron',array('id'=>array('in',pylode(',',$cid_arr))),'`id`,`name`');

                foreach ($logs as $k => $v) {

                    foreach ($crons as $ck => $cv) {

                        if($v['cid']==$cv['id']){

                            $logs[$k]['cron_name'] = $cv['name'];

                        }
                    }

                }


            }
        }

        return $logs;
    }
    function delCronlLog($whereData = array(), $data = array())
    {

        $return['layertype']    =   0;

        if (!empty($whereData)) {

            if (!empty($whereData['id']) && $whereData['id'][0] == 'in') {

                $return['layertype']    =   1;
            }

            if ($data['norecycle'] == '1') {  //  数据库清理，不插入回收站

                $return['id']   =   $this->delete_all('cron_log', $whereData, '', '', '1');
            } else {

                $return['id']   =   $this->delete_all('cron_log', $whereData, '');
            }

            $return['msg']      =   '计划任务日志';
            $return['errcode']  =   $return['id'] ? '9' : '8';
            $return['msg']      =   $return['id'] ? $return['msg'] . '删除成功！' : $return['msg'] . '删除失败！';
        } else {

            $return['msg']      =   '请选择您要删除的计划任务日志！';
            $return['errcode']  =   8;
        }

        return $return;
    }
}

?>