洞察在数字化转型过程中,信创推动企业有效整合资源,实现低成本、高效率的跨平台小程序运营。
961
2022-11-27
yii2的Console定时任务创建
Yii2的定时任务可以有两种写法,原理都是通过服务器的定时任务去调用
1.通过调用指定的URL访问 就相当于在浏览器中访问
2.通过console调用
下面我们就来说说Console 是如何实现定时任务的
一、首先在创建Controlle 并继承 yii\console\Controller;
在yii根目录下,命令行执行
1 | |
如果是class AaaBbbController function ActionAaaBbb
1 | |
linux下,运行crontab -e
1 | |
二、用命令行cmd测试是否成功
(一定要看好路径去执行 yii 这个文件 一定要写绝对路径)
/你的文件夹路径/yii 你的文件夹路径/console/test(控制器)/index(方法)
或者进入的你的项目目录下,例如 D:\wamp\crontab/copy-db,你需要配置你的php环境变量
下例为 在console文件夹下执行控制器和方法
三、设置定时任务
linux下,运行crontab -e
30 21 * * * /usr/local/php/bin/php /your_project_path/yii test/test
*/1 * * * * /usr/local/php/bin/php /home/crontab/copydb
这里根据自己需求填写
上面的例子表示每晚的21:30执行上面的定时程序
下面是定时任务设置的一些基本介绍
基本格式 :
* * * * * command
分 时 日 月 周 命令
第1列表示分钟1~59 每分钟用*或者 */1表示
第2列表示小时1~23(0表示0点)
第3列表示日期1~31
第4列表示月份1~12
第5列标识号星期0~6(0表示星期天)
第6列要运行的命令
crontab文件的一些例子:
30 21 * * * /usr/local/etc/rc.d/ligrestart #上面的例子表示每晚的21:30重启apache。
45 4 1,10,22 * * /usr/local/etc/rc.d/ligrestart #上面的例子表示每月1、10、22日的4 : 45重启apache。
10 1 * * 6,0 /usr/local/etc/rc.d/ligrestart #上面的例子表示每周六、周日的1 : 10重启apache。
0,30 18-23 * * * /usr/local/etc/rc.d/ligrestart #上面的例子表示在每天18 : 00至23 : 00之间每隔30分钟重启apache。
0 23 * * 6 /usr/local/etc/rc.d/ligrestart #上面的例子表示每星期六的11 : 00 pm重启apache。
0 */1 * * * /usr/local/etc/rc.d/ligrestart #每一小时重启apache
例子:
*/1 * * * * /usr/local/php/bin/php /home/crontab/copy-db>>/home/ */1 * * * *php目录 /usr/local/php/bin/php项目目录 /home/ yii crontab/copy-db结果值写入那个文件 /home/上跟windows类似
/usr/local/php/bin/php /home/crontab/copy-db
/usr/local/php/bin/php你的linux下的php环境位置 /home/crontab/copy-db你的项目目录
给个php代码例子
mongodb->getCollection('publish_message'); $i = 1; while ($time_begin < $time_end){ $date = date("Y-m-d", $time_begin); $start_time = strtotime($date." 00:00:00"); $end_time = strtotime($date." 23:30:00"); //清除每天23:30前的数据 $where = [ "between","payload.timestamp", $start_time, $end_time ]; $time_begin +=24*3600;// var_dump(new \MongoDB\BSON\UTCDateTime($end_time.'000'));die; $data = $query->from('publish_message')->where($where)->orderBy('created asc')->all();// $primaryVal = new \yii\mongodb\MongoId('000000000000000000000001');// dump($primaryVal);die;// $collection = \Yii::$app->mongodb->getCollection('publish_message'); // var_dump((string) new \yii\MongoDB\BSON\ObjectId('000000000000000000000001'));// $data = $collection->find([]); foreach ($data as $v){// var_dump($v); $oid = (string)$v['_id']; echo $i.'-'.$oid.' '; $collection->remove(['_id' => $v['_id']]); $i++; } } die; } /** * 定时任务获取mondb内故障消息 * create dahai * time 2018/07/18 */ public function actionCopyDb(){ $query = new \yii\mongodb\Query(); //先获取上一次的结束时间 $last_result = $query->select(['end_time'])->from('timed_task')->orderBy('_id desc')->limit(1)->one(); $last_time = $last_result['end_time']; $start_time = $last_time; $end_time = time(); $collection = \Yii::$app->mongodb->getCollection('timed_task'); $collection->insert(['end_time' => $end_time]); $query->andWhere([ "between","payload.timestamp", $start_time, $end_time ]); $query->andWhere(['in', 'payload.desired.arrays.0.status.event', [1,2,3,4,5,6,7]]); $result = $query->select(['created', 'payload'])->from('publish_message')->orderBy('created asc')->all(); if ($result){ //故障类型,设备别称,开关别称,故障时间 foreach ($result as $k => $l) { //对应相关用户通知故障消息 $deviceid = $l['payload']['deviceid']; $Equipment= \app\models\Equipment::find()->select('id')->where(['serial_number'=>$deviceid])->one(); $EquipmentUser =\app\models\EquipmentUser::find()->select('user_id')->where(['equipment_id'=>$Equipment->id])->asArray()->all(); $user_ids = array_column($EquipmentUser,'user_id'); $created = $l['payload']['timestamp'] > 0 ? date('Y-m-d H:i', $l['payload']['timestamp']) : '---'; $event_desc = \app\services\VStatusLog::$event[$l['payload']['desired']['arrays'][0]['status']['event']]; //查询别名 $eAlias = \app\models\Alias::findOne(['type'=>1,'extend_id'=>$l['payload']['deviceid'],'user_id'=>$this->uid]); //设备别名 $sAlias = \app\models\Alias::findOne(['type'=>2,'extend_id'=>$l['payload']['desired']['arrays'][0]['device']['id'],'user_id'=>$this->uid]);//开关别名 $alias1 = $eAlias?$eAlias['alias']:$l['payload']['deviceid']; $alias2 = $sAlias?$eAlias['alias']:'开关'.$l['payload']['desired']['arrays'][0]['device']['index']; while ($user_id = array_shift($user_ids)){ $FaultMessage = new \app\models\FaultMessage(); $FaultMessage->user_id = $user_id; $FaultMessage->message_id = ($l['_id'])->__toString(); $FaultMessage->created = $created; $FaultMessage->event = $l['payload']['desired']['arrays'][0]['status']['event']; $FaultMessage->event_desc = $event_desc; $FaultMessage->equipment_alias = $alias1; $FaultMessage->switch_alias = $alias2; $FaultMessage->create_time = time(); $FaultMessage->save(); } } }else{ echo "没有".date("Y-m-d H:i:s")."\n"; return "没有东西"; } echo "有".date("Y-m-d H:i:s")."\n"; return "有东西"; }}
yii2中,关于你加载了一些数据库或者扩展依赖,你需要在添加config-console.php添加你在web.php相同的配置即可
例如我这个报错:yii\di\ServiceLocator->get('mongodb') yii\mongodb\Query->all()就是因为这个导致
版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。
发表评论
暂时没有评论,来抢沙发吧~