品牌建站,学网络工程师培训学校,网站推广的方法有sem推广,用手机自创游戏TaskPHP是一个基于PHP的定时任务框架#xff0c;它提供了一个简单、灵活且易于使用的解决方案#xff0c;用于在PHP环境中执行定时任务。下面是对TaskPHP框架的简要介绍#xff1a;
简单易用#xff1a;TaskPHP的设计目标是让定时任务的创建和管理变得简单。通过简单的配置…TaskPHP是一个基于PHP的定时任务框架它提供了一个简单、灵活且易于使用的解决方案用于在PHP环境中执行定时任务。下面是对TaskPHP框架的简要介绍
简单易用TaskPHP的设计目标是让定时任务的创建和管理变得简单。通过简单的配置和编写任务代码即可轻松实现定时任务的执行。高性能TaskPHP采用高效的任务调度算法确保任务能够按照预定的时间准确执行。同时它还支持并发执行多个任务提高了任务的执行效率。灵活配置TaskPHP允许用户通过配置文件或代码来定义任务的执行时间、执行间隔、执行次数等参数。用户可以根据自己的需求灵活配置任务。可扩展性TaskPHP框架具有良好的扩展性用户可以根据自己的需求添加自定义的任务类型或扩展功能。此外它还支持与其他PHP框架或库进行集成方便用户在现有项目中使用。日志记录TaskPHP提供了日志记录功能可以记录任务的执行过程、执行结果以及错误信息等。这有助于用户监控任务的执行情况及时发现问题并进行处理。任务管理框架提供了任务管理的功能用户可以查看当前正在执行的任务、已完成的任务以及任务执行的历史记录。这有助于用户对任务进行监控和管理。
TaskPHP是一个功能强大、易于使用的PHP定时任务框架适用于各种需要定时执行任务的场景。无论是简单的定时发送邮件、定时更新数据还是复杂的定时爬虫、定时数据分析等任务TaskPHP都能提供有效的解决方案。
关键环境感知任务记录
?phpnamespace cron;use taskphp\Utils;require taskDb.php;class Service2
{/** 关键环境安全-定时任务* $service_id,定时任务服务路由ID* */public static function getTask($service_id){global $CONF, $serviceArr;$CONF require ../conf/config.php;require ../conf/config.service.php;$serviceArr getByServiceId($lock_service, $service_id);Utils::log(Task-ID: . $service_id);//数据信息$school_id $serviceArr[school_id];$school_type $serviceArr[school_type];$school_attribute $serviceArr[school_attribute];$school_short_name $serviceArr[school_short_name];$service_group $serviceArr[service_group];$service_protocol $serviceArr[service_protocol];$service_url $serviceArr[service_url];$url $service_protocol . $service_url . /service/page/sensor/simple.json;$dataPramas [group_id $service_group];$res curlIotOnlyAPI($url, 1, 1000, $CONF[iot_token], $dataPramas);//Utils::log(Task-content: . $res);$reArr json_decode($res, true);if ($reArr $reArr[data] $reArr[data][data] $reArr[data][data][0]) {$keyData $reArr[data][data];$environment_area $reArr[data][data][0][device];//插入数据库;Utils::db()-table(environment)-ifInsert(array(task_code encodeId($school_id . - . $service_id),service_id $service_id,school_id $school_id,school_type $school_type,school_attribute $school_attribute,school_short_name $school_short_name,environment_area $environment_area,environment_temperature getSDataByPropertyType($keyData, 温度),environment_temperature_state getStatusBySensorStatus($keyData, 温度),environment_humidity getSDataByPropertyType($keyData, 湿度),environment_humidity_state getStatusBySensorStatus($keyData, 湿度),environment_air getSDataByPropertyType($keyData, 空质),environment_air_state getStatusBySensorStatus($keyData, 空质),environment_time time()),array(service_id $service_id,school_id $school_id,school_type $school_type,school_attribute $school_attribute,school_short_name $school_short_name,environment_area $environment_area,environment_temperature getSDataByPropertyType($keyData, 温度),environment_temperature_state getStatusBySensorStatus($keyData, 温度),environment_humidity getSDataByPropertyType($keyData, 湿度),environment_humidity_state getStatusBySensorStatus($keyData, 湿度),environment_air getSDataByPropertyType($keyData, 空质),environment_air_state getStatusBySensorStatus($keyData, 空质),environment_time time()));//系统日志Utils::db()-table(task_log)-add(array(school_short_name $school_short_name,task_name 关键环境安全,task_status 服务路由ID( . $service_id . )API组ID( . $service_group . )-数据更新成功STATUS:OK,task_time time()));} else {//系统日志Utils::db()-table(task_log)-add(array(school_short_name $school_short_name,task_name 关键环境安全,task_status API组ID . $service_group . 接口出错无法爬取数据STATUS:Fail,task_time time()));die();}//返回数据;return true;}
}用电计量管理任务记录
?phpnamespace cron;use taskphp\Utils;require taskDb.php;class Service3
{/** 用电计量管理-定时任务* $service_id,定时任务服务路由ID* */public static function getTask($service_id){global $CONF, $serviceArr;$CONF require ../conf/config.php;require ../conf/config.service.php;$serviceArr getByServiceId($lock_service, $service_id);Utils::log(Task-ID: . $service_id);//数据信息$school_id $serviceArr[school_id];$school_type $serviceArr[school_type];$school_attribute $serviceArr[school_attribute];$school_short_name $serviceArr[school_short_name];$service_group $serviceArr[service_group];$service_protocol $serviceArr[service_protocol];$service_url $serviceArr[service_url];$url $service_protocol . $service_url . /service/page/sensor/calc/data.json;$dataPramas [group_id $service_group, propertyTypeVal 电量];$res curlIotOnlyAPI($url, 1, 1000, $CONF[iot_token], $dataPramas);//Utils::log(Task-content: . $res);$reArr json_decode($res, true);if ($reArr $reArr[data] $reArr[data][data] $reArr[data][data][0]) {$powerData $reArr[data][data][0][odata];$MonthsArr generatePastMonths(13);//月份$powerArr [formatNumber($powerData[prev_0_month_val_diff]),formatNumber($powerData[prev_1_month_val_diff]),formatNumber($powerData[prev_2_month_val_diff]),formatNumber($powerData[prev_3_month_val_diff]),formatNumber($powerData[prev_4_month_val_diff]),formatNumber($powerData[prev_5_month_val_diff]),formatNumber($powerData[prev_6_month_val_diff]),formatNumber($powerData[prev_7_month_val_diff]),formatNumber($powerData[prev_8_month_val_diff]),formatNumber($powerData[prev_9_month_val_diff]),formatNumber($powerData[prev_10_month_val_diff]),formatNumber($powerData[prev_11_month_val_diff]),formatNumber($powerData[prev_12_month_val_diff])];//对应月份的数据//插入数据库;/* Utils::db()-table(electricity)-ifInsert(array(school_id $school_id,school_type $school_type,school_attribute $school_attribute,school_short_name $school_short_name,electricity_month $MonthsArr[0],electricity_norm $powerArr[0],electricity_time time()),array(school_type $school_type,school_attribute $school_attribute,school_short_name $school_short_name,electricity_norm $powerArr[0],electricity_time time()));*/for ($i 0; $i count($MonthsArr); $i) {$row_sec Utils::db()-table(electricity)-where(array(school_id $school_id, electricity_month $MonthsArr[$i]))-limit(1)-order(school_id DESC)-select();if (!$row_sec) {//插入数据Utils::db()-table(electricity)-add(array(school_id $school_id,service_id $service_id,school_type $school_type,school_attribute $school_attribute,school_short_name $school_short_name,electricity_month $MonthsArr[$i],electricity_norm $powerArr[$i],electricity_time time()));} else {//更新数据Utils::db()-table(electricity)-where(array(school_id $school_id, electricity_month $MonthsArr[$i]))-update(array(service_id $service_id,school_type $school_type,school_attribute $school_attribute,school_short_name $school_short_name,electricity_norm $powerArr[$i],electricity_time time()));}}//系统日志Utils::db()-table(task_log)-add(array(school_short_name $school_short_name,task_name 用电计量管理,task_status 服务路由ID( . $service_id . )API组ID( . $service_group . )-数据更新成功STATUS:OK,task_time time()));} else {//系统日志Utils::db()-table(task_log)-add(array(school_short_name $school_short_name,task_name 用电计量管理,task_status API组ID . $service_group . 接口出错无法爬取数据STATUS:Fail,task_time time()));die();}//返回数据;return true;}
}用水计量管理任务记录
?phpnamespace cron;use taskphp\Utils;require taskDb.php;class Service4
{/** 用水计量管理-定时任务* $service_id,定时任务服务路由ID* */public static function getTask($service_id){global $CONF, $serviceArr;$CONF require ../conf/config.php;require ../conf/config.service.php;$serviceArr getByServiceId($lock_service, $service_id);Utils::log(Task-ID: . $service_id);//数据信息$school_id $serviceArr[school_id];$school_type $serviceArr[school_type];$school_attribute $serviceArr[school_attribute];$school_short_name $serviceArr[school_short_name];$service_group $serviceArr[service_group];$service_protocol $serviceArr[service_protocol];$service_url $serviceArr[service_url];$url $service_protocol . $service_url . /service/page/sensor/calc/data.json;$dataPramas [group_id $service_group, propertyTypeVal 总流量];$res curlIotOnlyAPI($url, 1, 1000, $CONF[iot_token], $dataPramas);//Utils::log(Task-content: . $res);$reArr json_decode($res, true);if ($reArr $reArr[data] $reArr[data][data] $reArr[data][data][0]) {$powerData $reArr[data][data][0][odata];$MonthsArr generatePastMonths(13);//月份$powerArr [formatNumber($powerData[prev_0_month_val_diff]),formatNumber($powerData[prev_1_month_val_diff]),formatNumber($powerData[prev_2_month_val_diff]),formatNumber($powerData[prev_3_month_val_diff]),formatNumber($powerData[prev_4_month_val_diff]),formatNumber($powerData[prev_5_month_val_diff]),formatNumber($powerData[prev_6_month_val_diff]),formatNumber($powerData[prev_7_month_val_diff]),formatNumber($powerData[prev_8_month_val_diff]),formatNumber($powerData[prev_9_month_val_diff]),formatNumber($powerData[prev_10_month_val_diff]),formatNumber($powerData[prev_11_month_val_diff]),formatNumber($powerData[prev_12_month_val_diff])];//插入数据库;for ($i 0; $i count($MonthsArr); $i) {$row_sec Utils::db()-table(water)-where(array(school_id $school_id, water_month $MonthsArr[$i]))-limit(1)-order(school_id DESC)-select();if (!$row_sec) {//插入数据Utils::db()-table(water)-add(array(school_id $school_id,service_id $service_id,school_type $school_type,school_attribute $school_attribute,school_short_name $school_short_name,water_month $MonthsArr[$i],water_norm $powerArr[$i],water_time time()));} else {//更新数据Utils::db()-table(water)-where(array(school_id $school_id, water_month $MonthsArr[$i]))-update(array(service_id $service_id,school_type $school_type,school_attribute $school_attribute,school_short_name $school_short_name,water_norm $powerArr[$i],water_time time()));}}//系统日志Utils::db()-table(task_log)-add(array(school_short_name $school_short_name,task_name 用水计量管理,task_status 服务路由ID( . $service_id . )API组ID( . $service_group . )-数据更新成功STATUS:OK,task_time time()));} else {//系统日志Utils::db()-table(task_log)-add(array(school_short_name $school_short_name,task_name 用水计量管理,task_status API组ID . $service_group . 接口出错无法爬取数据STATUS:Fail,task_time time()));die();}//返回数据;return true;}
}记录日志
使用第三方爬中仅记录启动和结束任务日志
[2024-03-29 20:22:54.83456200][DEBUG]:distribute_listen daemon pid:383131 Start
[2024-03-29 20:22:55.83205600][DEBUG]:worker_listen daemon pid:383134 Start
[2024-03-29 20:22:56.83395000][DEBUG]:worker_listen daemon pid:383135 Start
[2024-03-29 20:22:57.83637100][DEBUG]:worker_listen daemon pid:383136 Start
[2024-03-29 20:22:58.83940500][DEBUG]:worker_listen daemon pid:383137 Start
[2024-03-29 20:22:59.83934000][DEBUG]:worker_listen daemon pid:383138 Start
[2024-03-29 20:23:00.84222100][DEBUG]:worker_listen daemon pid:383139 Start
[2024-03-29 20:23:01.84334700][DEBUG]:worker_listen daemon pid:383140 Start
[2024-03-29 20:23:02.84479600][DEBUG]:worker_listen daemon pid:383141 Start
[2024-03-29 20:30:01.04360000][DEBUG]:cron\Task14::run [--START--]
[2024-03-29 20:30:01.04501700][DEBUG]:Service-ID: 31
[2024-03-29 20:30:07.56411000][DEBUG]:cron\Task14::run [--END--][RunTime:6.520488s]
[2024-03-29 20:31:01.07364600][DEBUG]:cron\Task15::run [--START--]
[2024-03-29 20:31:01.07523800][DEBUG]:Service-ID: 30
[2024-03-29 20:31:01.85611800][DEBUG]:cron\Task15::run [--END--][RunTime:0.782444s]
[2024-03-29 20:32:01.12884500][DEBUG]:cron\Task6::run [--START--]
[2024-03-29 20:32:01.13076100][DEBUG]:Service-ID: 34
[2024-03-29 20:32:01.69706000][DEBUG]:cron\Task6::run [--END--][RunTime:0.568220s]taskPHP自带Utils工具会产生具体的日志记录
[2024-03-28 00:03:01.41235800][DEBUG]:cron\Task14::run [--START--]
[2024-03-28 00:03:01.41251000][DEBUG]:Task-ID: 31
[2024-03-28 00:03:07.83297000][DEBUG]:cron\Task14::run [--END--][RunTime:6.420764s]
[2024-03-28 00:05:00.89040200][DEBUG]:cron\Task10::run [--START--]
[2024-03-28 00:05:00.89097900][DEBUG]:Task-ID: 35
[2024-03-28 00:05:01.04386100][DEBUG]:cron\Task6::run [--START--]
[2024-03-28 00:05:01.04441500][DEBUG]:Task-ID: 34
[2024-03-28 00:05:01.42001300][DEBUG]:SQL:DESC po_environment[bind_value:null][RunTime:0.059952s]
[2024-03-28 00:05:01.49280500][DEBUG]:SQL:INSERT INTO po_environment SET task_code:task_code,service_id:service_id,school_id:school_id,school_type:school_type,school_attribute:school_attribute,school_short_name:school_short_name,environment_area:environment_area,environment_temperature:environment_temperature,environment_temperature_state:environment_temperature_state,environment_humidity:environment_humidity,environment_humidity_state:environment_humidity_state,environment_air:environment_air,environment_air_state:environment_air_state,environment_time:environment_time ON DUPLICATE KEY UPDATE service_id:service_id_1,school_id:school_id_2,school_type:school_type_3,school_attribute:school_attribute_4,school_short_name:school_short_name_5,environment_area:environment_area_6,environment_temperature:environment_temperature_7,environment_temperature_state:environment_temperature_state_8,environment_humidity:environment_humidity_9,environment_humidity_state:environment_humidity_state_10,environment_air:environment_air_11,environment_air_state:environment_air_state_12,environment_time:environment_time_13[bind_value:null][RunTime:0.072542s]漏刻有时
