|
|
@ -29,15 +29,15 @@ class HorsemanService implements HorsemanServiceInterface |
|
|
} |
|
|
} |
|
|
public function getOrderList() |
|
|
public function getOrderList() |
|
|
{ |
|
|
{ |
|
|
return '接入成功'; |
|
|
|
|
|
|
|
|
return OrderMain::query()->where('state',3)->limit(5)->get(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|
* 记录骑手坐标 |
|
|
* 记录骑手坐标 |
|
|
*/ |
|
|
*/ |
|
|
public function setHorsemanCoordinate($horsemanId,$coordinate){ |
|
|
|
|
|
|
|
|
public function setHorsemanCoordinate($employeesId,$coordinate){ |
|
|
$ssdb = ApplicationContext::getContainer()->get(SSDBTask::class); |
|
|
$ssdb = ApplicationContext::getContainer()->get(SSDBTask::class); |
|
|
if(false === $ssdb->exec('set', SsdbKeys::HORSEMAN_COORDINATE.$horsemanId,$coordinate)) { |
|
|
|
|
|
|
|
|
if(false === $ssdb->exec('set', SsdbKeys::HORSEMAN_COORDINATE.$employeesId,$coordinate)) { |
|
|
return false; |
|
|
return false; |
|
|
} |
|
|
} |
|
|
return true; |
|
|
return true; |
|
|
@ -46,9 +46,9 @@ class HorsemanService implements HorsemanServiceInterface |
|
|
/** |
|
|
/** |
|
|
* 获取骑手坐标 |
|
|
* 获取骑手坐标 |
|
|
*/ |
|
|
*/ |
|
|
public function getHorsemanCoordinate($horsemanId){ |
|
|
|
|
|
|
|
|
public function getHorsemanCoordinate($employeesId){ |
|
|
$ssdb = ApplicationContext::getContainer()->get(SSDBTask::class); |
|
|
$ssdb = ApplicationContext::getContainer()->get(SSDBTask::class); |
|
|
$params = $ssdb->exec('get', SsdbKeys::HORSEMAN_COORDINATE.$horsemanId); |
|
|
|
|
|
|
|
|
$params = $ssdb->exec('get', SsdbKeys::HORSEMAN_COORDINATE.$employeesId); |
|
|
|
|
|
|
|
|
if ((false === $params) || empty($params)) { |
|
|
if ((false === $params) || empty($params)) { |
|
|
throw new ErrorCodeException(ErrorCode::HORSEMAN_COORDINATE_FAIL, '获取骑手坐标失败'); |
|
|
throw new ErrorCodeException(ErrorCode::HORSEMAN_COORDINATE_FAIL, '获取骑手坐标失败'); |
|
|
|