crontab 定时任务

发表于 | 分类于 | | 热度: |
crontab创建定时任务，本篇介绍是用代码和数据库去更优操作

php计划任务管理实现

  • 主程序
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255

<?php
class ScheduleModel{
	private $model;
	private $schedule		= array();
	private $scheduleList 	= array();
	private $redisKey = 'scheduleList';//redis保存表里面数据的key值
	/**
	 * @desc 执行计划任务列表
	 * */
	public function Run(){
		//锁定自动执行 修正一下
		$lockfile = $this->getLogPath() . '/schedule.lock';
		//锁定未过期 - 返回
		if( file_exists($lockfile) && ( (filemtime($lockfile))+60 > $_SERVER['REQUEST_TIME'] )){
			return;
		} else {
			//重新生成锁文件
			touch($lockfile);
		}
		//执行计划任务
		$this->runScheduleList($this->getScheduleList());
		//解除锁定
		unlink($lockfile);
		return;
	}
	
	/**
	 * @desc 执行计划任务列表
	 * ***/
	public function runScheduleList($scheduleList) {
		foreach( $scheduleList as $key => $schedule ) {
			$date = $this->calculateNextRunTime($schedule);
			if( $date != false && $date <= time()) {
				$this->runSchedule($schedule);
			}else {
				continue;
			}
		}
		return true;
	}	
	
	/**
	 * @desc 运行计划任务
	 * **/
	public function runSchedule($schedule) {
		// 获取后台配置的计划任务
		$checkScheduleList = $this->getScheduleList();
		$checkScheduleList = $this->getSubByKey($checkScheduleList, 'task_to_run');
		if (!in_array($schedule['task_to_run'], $checkScheduleList)) {
			$str_log = "schedule_id = {$schedule['id']} 的任务不合法。";
			$this->_log($str_log);
			return false;
		}
		//解析task类型, 并运行task
		$task_to_run = explode('/',$schedule['task_to_run']);
		$modelStr = "D('{$task_to_run[0]}')->{$task_to_run[1]}();";
		/**-----这里开始处理任务模型------**/
		eval($modelStr);
		/**-----这里结束处理任务模型下面开始更新数据表------**/
		if(strtoupper($schedule['schedule_type']) == 'ONCE') {
			//ONCE类型的计划任务，将end_datetime设置为当前时间
			if(empty($schedule['last_run_time'])){
				$schedule['last_run_time'] = date('Y-m-d H:i:s');
			}else{
				return false;
			}
		}else {
			//非ONCE类型的计划任务， 防止由程序执行导致的启动时间的漂移
			if(in_array($schedule['schedule_type'], array('MINUTE', 'HOURLY'))) {
				//将last_run_time设置为当前时间（秒数设为0）
				$schedule['last_run_time'] = date('Y-m-d H:i:s',$this->setSecondToZero());
			}else {
				//将last_run_time设置为当前日期+预定时间
				$now_date = date('Y-m-d');
				$fixed_time = date('H:i:s', strtotime($schedule['start_datetime']));
				$schedule['last_run_time'] = $now_date . ' ' . $fixed_time;
			}
		}
		$this->saveSchedule($schedule);
		$str_log = "schedule_id = {$schedule['id']} 的任务已运行。";
		$this->_log($str_log);
	}
	
	/**
	 * @desc 计算定时任务下次执行时间
	 * @return 'Y-m-d H:i:s'
	 * ***/
	public function  calculateNextRunTime($schedule){
		//已过期
		if( (strtotime($schedule['end_datetime'])>0) && (strtotime($schedule['end_datetime']) < strtotime(date('Y-m-d H:i:s'))) ) {
			return false;
		}
		//还未启动
		if( strtotime($schedule['start_datetime']) > strtotime(date('Y-m-d H:i:s')) ) {
			return false;
		}
		//已执行
		if( strtotime($schedule['last_run_time']) > strtotime(date('Y-m-d H:i:s')) ) {
			return false;
		}
		$modifier = empty($schedule['modifier']) ? 1 : $schedule['modifier'];
		if( !empty($schedule['last_run_time']) && (strtotime($schedule['last_run_time']) > strtotime($schedule['start_datetime']))) {
			$date = is_string($schedule['last_run_time']) ? strtotime($schedule['last_run_time']) : $schedule['last_run_time'];
		}else {//如果没有执行过则默认为开始时间执行
			$date = $this->_getStartDateTime($schedule);
		}
		$type = $schedule['schedule_type'];
		switch($type){
			case 'ONCE':
				if(!empty($schedule['last_run_time'])){
					return false;
				}
				$datetime =  $this->_getStartDateTime($schedule);
				break;
			case 'MINUTE':
				if($modifier>=1 && $modifier<=60){
					$datetime =  mktime(date('H',$date),date('i',$date) + $modifier,date('s',$date),date('m',$date),date('d',$date),date('Y',$date));
				}else{
					$str_log = "schedule_id = {$schedule['id']} 的任务不合法，MINUTE类型，执行的频率必须为1-60的数字。";
					$this->_log($str_log);
					return false;
				}
				break;
			case 'HOURLY':
				if($modifier>=1 && $modifier<=24){
					$datetime = mktime(date('H',$date) + $modifier,date('i',$date),date('s',$date),date('m',$date),date('d',$date),date('Y',$date));
				}else{
					$str_log = "schedule_id = {$schedule['id']} 的任务不合法，HOURLY类型执行的频率必须为1-24的数字。";
					$this->_log($str_log);
					return false;
				}
				break;
			case 'DAILY':
				if($modifier>=1 && $modifier<=31){
					$datetime = mktime(date('H',$date),date('i',$date),date('s',$date),date('m',$date),date('d',$date) + $modifier,date('Y',$date));
				}else{
					$str_log = "schedule_id = {$schedule['id']} 的任务不合法，DAILY类型执行的频率必须为1-31的数字。";
					$this->_log($str_log);
					return false;
				}				
				break;
			case 'MONTHLY':
				if($modifier>=1 && $modifier<=12){
					$datetime = mktime(date('H',$date),date('i',$date),date('s',$date),date('m',$date)+$modifier,date('d',$date),date('Y',$date));
				}else{
					$str_log = "schedule_id = {$schedule['id']} 的任务不合法，MONTHLY类型执行的频率必须为1-12的数字。";
					$this->_log($str_log);
					return false;
				}
				break;
			default:
				return false;
		}
		return $datetime;
	}
	
	/*
	 *@desc 设置定时任务文件目录
	*/
	public function getLogPath(){
		$logPath = './Public/schedule_log';
		if(!is_dir($logPath))
			@mkdir($logPath,0777);
		return $logPath;
	}
	
	/**
	 * @desc 检测定时任务写入执行情况
	 * **/
	protected function _log($str){
		$filename = $this->getLogPath() . '/schedule_' . date('Y-m-d') . '.log';
		$str = '[' . date('Y-m-d H:i:s') . '] ' . $str;
		$str .= "\r\n";
		$handle = fopen($filename, 'a');
		fwrite($handle, $str);
		fclose($handle);
	}
	
	//获取开始时间
	//@return timestamp
	protected function _getStartDateTime($schedule) {
		if( !empty($schedule['start_datetime']) ) {
			return strtotime($schedule['start_datetime']);
		}else {
			return false;
		}
	}
	
	/***
	 *@desc 将给定时间的秒数置为0; 参数为空时，使用当前时间
	 * ***/
	protected function setSecondToZero($date_time = NULL) {
		if(empty($date_time)) {
			$date_time = date('Y-m-d H:i:s');
		}
		$date_time = is_string($date_time) ? strtotime($date_time) : $date_time;
		return mktime(date('H', $date_time),date('i', $date_time),0,date('m', $date_time),date('d', $date_time),date('Y', $date_time));
	}
	
	/**
	 * 取一个二维数组中的每个数组的固定的键知道的值来形成一个新的一维数组
	 * @param $pArray 一个二维数组
	 * @param $pKey 数组的键的名称
	 * @return 返回新的一维数组
	 */
	public function getSubByKey($pArray, $pKey="", $pCondition=""){
		$result = array();
		if(is_array($pArray)){
			foreach($pArray as $temp_array){
				if(is_object($temp_array)){
					$temp_array = (array) $temp_array;
				}
				if((""!=$pCondition && $temp_array[$pCondition[0]]==$pCondition[1]) || ""==$pCondition) {
					$result[] = (""==$pKey) ? $temp_array : isset($temp_array[$pKey]) ? $temp_array[$pKey] : "";
				}
			}
			return $result;
		}else{
			return false;
		}
	}
	
	/***
	 * @desc 修改计划任务本次执行时间
	 * **/
	public function saveSchedule($schedule){
		if(empty($schedule)){
			return array();
		}
		$data = array('id'=>$schedule['id'],'last_run_time'=>$schedule['last_run_time'],);
		return $this->save($data);
	}
	
	/**
	 * @desc 获取定时任务列表信息
	 * **/
	public function getScheduleList(){
		$where['status'] = 1;//开启
		$infoArr = $this->where($where)->select();
		return $infoArr;
		/*$redis = redis();
		$redInfo = $redis->get($this->redisKey);
		if($redInfo){
			return unserialize($redInfo);
		}else{
			$where['status'] = 0;
			$infoArr = $this->where($where)->select();
			$info = serialize($infoArr);
			$redis->set($this->redisKey,$info,300);
			return $infoArr;
		}*/
	}
}
?>
  • sh脚本
1
2
3
#!/bin/bash
cd /data/wwwroot/workplace/
/data/local/php/bin/php do.php
  • 数据库
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
ET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for `b2b_schedule`
-- ----------------------------
DROP TABLE IF EXISTS `b2b_schedule`;
CREATE TABLE `b2b_schedule` (
`id`  int(11) NOT NULL ,
`task_to_run`  varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '计划任务执行方法' ,
`schedule_type`  varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '执行频率' ,
`modifier`  varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '执行频率,类型为MONTHLY时必须；ONCE时无效；其他时为可选，默认为1' ,
`start_datetime`  datetime NOT NULL COMMENT '开始时间' ,
`end_datetime`  datetime NULL DEFAULT NULL COMMENT '结束时间' ,
`last_run_time`  datetime NULL DEFAULT NULL COMMENT '最近执行时间' ,
`info`  varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '对计划任务的简要描述' ,
`status`  tinyint(1) NULL DEFAULT 0 COMMENT '0关闭，1开启' ,
PRIMARY KEY (`id`)
)
ENGINE=MyISAM
DEFAULT CHARACTER SET=utf8 COLLATE=utf8_general_ci
COMMENT='计划任务管理表'

;
谢谢您请我喝咖啡！