bt使用crontab笔记！

2021-01-02 阅读:次

####Shell脚本

选择Shell脚本，执行周期设置每月17日9时0分，脚本内容是使用微信消息模板批量推送，用户数据太多，一次执行耗时太长。分成N个脚本同时处理，每次处理1/N缩短执行时间。任务名称1对应脚本执行记录的1.log.也可不用等时间到，直接点击执行。然后查看日志是否执行。

/www/server/php/56/bin/php /www/wwwroot/paijinhua/think notice 1 50000 >> /www/wwwlogs/1.log 2>&1

<?php
namespace app\admin\command;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use app\common\model\WxUser;
use app\common\service\WechatService;
use think\console\Input\Option;
use think\console\Input\Argument;
class Notice extends Command
{

    //定义任务名和描述
    protected function configure(){
        //设置参数
        $this->addArgument('s',Argument::REQUIRED,'s必填'); //必传参数
        $this->addArgument('e',Argument::REQUIRED,'e必填'); //必传参数
        $this->setName('notice')->setDescription("php think notice 通知"); //选项定义
    }

    //调用该类时,会自动运行execute方法
    protected function execute(Input $input, Output $output)
    {
        set_time_limit(0);
        ini_set('memory_limit','512M'); 
        $args = $input->getArguments();
        if(!$args['s'] || !$args['e']){
            exit("参数s or e不能为空");
        }


            $data = WxUser::field('id,userId uid,wxOpenid openid')
                ->where("wxOpenid !='' and  id >= {$args['s']} and id < {$args['e']} ")
                ->group('wxOpenid')
                 ->order('id asc')
                 ->select();
                foreach($data as $k=>$v){
                     $res =  WechatService::serviceTpl($v->openid);
                    $msg = ($res ? 'success':'failed').":".$v->id . '--' .$v->uid.'---'. $v->openid;
                    #dlog('wx—service', $msg); //脚本做了日志记录，这里就不用了
                    echo $msg . "\n";
                 }
    }


}

Shell脚本添加

脚本内容

######脚本列表

####访问URL

直接调用控制器方法，填入url，设置执行周期。如果分页通过缓存或者其它方式传值，也可设置多个url，通过url传参调用！

<?php
namespace app\app\controller;

use app\common\controller\Base;
use app\common\model\WxUser;
 
class Error extends Base
{
    public function __construct()
    {
        parent::__construct();
    }


    /**
     * 空控制器操作
     */
    public function notice()
    {
        set_time_limit(0);
        ini_set('memory_limit','1000M');

        $size = 100;
        $cache_page = cache('crontab_notice_page');
        $page = !$cache_page ? 1 : ($cache_page + 1);

        cache('crontab_notice_page',$page);
        WxUser::field('id,userId uid,wxOpenid openid')
            ->where("wxOpenid !='' ")
            ->group('wxOpenid')
            ->order('id asc')
            ->paginate($size, false, [
                'page' => $page
            ]);
        dlog('wx—service', WxUser::getLastSql());

    }
}