shulang
/
webman
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: 在 Task 类中增加异常处理和日志记录，优化验证码收取逻辑

This commit is contained in:
lingling 2025-03-07 18:14:53 +08:00
parent 85a9d33b16
commit 1106edcb7f
1 changed files with 12 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
process/Task.php
View File

@ -7,6 +7,7 @@ use app\model\UserPhone;
use app\dao\UserRewardDao; use app\dao\UserRewardDao;
use Workerman\Crontab\Crontab; use Workerman\Crontab\Crontab;
use app\model\GetLodeLog; use app\model\GetLodeLog;
use support\Log;
/** /**
* 查询用户是否在线类 * 查询用户是否在线类
@ -15,46 +16,21 @@ class Task
{ {
public function onWorkerStart() public function onWorkerStart()
{ {
// // 每秒钟执行一次
// new Crontab('*/1 * * * * *', function(){
// echo date('Y-m-d H:i:s')."\n";
// });
// // 每5秒执行一次
// new Crontab('*/5 * * * * *', function(){
// echo date('Y-m-d H:i:s')."\n";
// });
// // 每分钟执行一次
// new Crontab('0 */1 * * * *', function(){
// echo date('Y-m-d H:i:s')."\n";
// });
// // 每5分钟执行一次
// new Crontab('0 */5 * * * *', function(){
// echo date('Y-m-d H:i:s')."\n";
// });
// // 每分钟的第一秒执行
// new Crontab('1 * * * * *', function(){
// echo date('Y-m-d H:i:s')."\n";
// });
// // 每天的7点50执行，注意这里省略了秒位
// new Crontab('50 7 * * *', function(){
// echo date('Y-m-d H:i:s')."\n";
// });
// 每1秒执行一次 收取验证码 // 每1秒执行一次 收取验证码
new Crontab('*/1 * * * * *', function () { new Crontab('*/1 * * * * *', function () {
$GetLodeLog = GetLodeLog::where('status', 0)->get(); $GetLodeLog = GetLodeLog::where('status', 0)->get();
foreach ($GetLodeLog as $key => $value) { foreach ($GetLodeLog as $key => $value) {
$res = SendCode::get_code($value->phone); try {
// var_dump($res); $res = SendCode::get_code($value->phone);
if ($res['status'] == 1 && $res['scanCode'] != null) { // var_dump($res);
$value->status = 1; if ($res['status'] == 1 && $res['scanCode'] != null) {
$value->code = $res['scanCode']; $value->status = 1;
$value->save(); $value->code = $res['scanCode'];
$value->save();
}
} catch (\Exception $e) {
// 记录错误日志，避免任务中断
Log::error("Error processing phone {$value->phone}: " . $e->getMessage());
} }
} }
}); });