| @@ 103-114 (lines=12) @@ | ||
| 100 | } |
|
| 101 | ||
| 102 | ||
| 103 | if (false === $resultData[SmsWorker::P_RESULT_DATA_SUCCESS]) { |
|
| 104 | ||
| 105 | if (!$job->isSync()) { |
|
| 106 | // redirect result for new root gateway class |
|
| 107 | $gatewayClass = static::getConfig(SmsWorker::GATEWAY_DISPATCH_CLASS); |
|
| 108 | $job->addDebug(['set_gateway' => $gatewayClass]); |
|
| 109 | $job->setWorkerClass($gatewayClass)->save(); |
|
| 110 | throw new ResultException(ResultException::RETRY_GATEWAY_DISPATCH_CLASS); |
|
| 111 | } |
|
| 112 | ||
| 113 | throw new ResultException(ResultException::R_FAILURE, $resultData); |
|
| 114 | } |
|
| 115 | ||
| 116 | throw new ResultException(ResultException::R_SUCCESS, $resultData); |
|
| 117 | } |
|
| @@ 133-144 (lines=12) @@ | ||
| 130 | } |
|
| 131 | ||
| 132 | ||
| 133 | if (false === $resultData[SmsWorker::P_RESULT_DATA_SUCCESS]) { |
|
| 134 | ||
| 135 | if (!$job->isSync()) { |
|
| 136 | // redirect result for new root gateway class |
|
| 137 | $gatewayClass = static::getConfig(SmsWorker::GATEWAY_DISPATCH_CLASS); |
|
| 138 | $job->addDebug(['set_gateway' => $gatewayClass]); |
|
| 139 | $job->setWorkerClass($gatewayClass)->save(); |
|
| 140 | throw new ResultException(ResultException::RETRY_GATEWAY_DISPATCH_CLASS); |
|
| 141 | } |
|
| 142 | ||
| 143 | throw new ResultException(ResultException::R_FAILURE, $resultData); |
|
| 144 | } |
|
| 145 | ||
| 146 | throw new ResultException(ResultException::R_SUCCESS, $resultData); |
|
| 147 | } |
|