正在显示
1 个修改的文件
包含
8 行增加
和
2 行删除
| @@ -47,8 +47,14 @@ class WorkchatMessageSend extends Command | @@ -47,8 +47,14 @@ class WorkchatMessageSend extends Command | ||
| 47 | $task->status = MessagePush::STATUS_SUCCESS; | 47 | $task->status = MessagePush::STATUS_SUCCESS; |
| 48 | }catch (ConnectionException $e){ | 48 | }catch (ConnectionException $e){ |
| 49 | $this->output('推送消息' . $task->id . '超时'); | 49 | $this->output('推送消息' . $task->id . '超时'); |
| 50 | - $task->status = MessagePush::STATUS_ERROR; | ||
| 51 | - $task->remark = '请求超时'; | 50 | + if ($task->retry < 3) { |
| 51 | + $task->status = MessagePush::STATUS_PENDING; | ||
| 52 | + $task->retry = $task->retry + 1; | ||
| 53 | + $task->send_time = date('Y-m-d H:i:s', strtotime('+ ' . $task->retry . ' minute')); | ||
| 54 | + } else { | ||
| 55 | + $task->status = MessagePush::STATUS_ERROR; | ||
| 56 | + $task->remark = '请求超时'; | ||
| 57 | + } | ||
| 52 | }catch (\Exception $e){ | 58 | }catch (\Exception $e){ |
| 53 | $this->output('推送消息' . $task->id . '失败:' . $e->getMessage()); | 59 | $this->output('推送消息' . $task->id . '失败:' . $e->getMessage()); |
| 54 | $task->status = MessagePush::STATUS_ERROR; | 60 | $task->status = MessagePush::STATUS_ERROR; |
-
请 注册 或 登录 后发表评论