BikeController.php 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: Mead
  5. * Date: 2019/8/19
  6. * Time: 2:11 PM
  7. */
  8. namespace App\Http\Controllers\V1;
  9. use App\Handlers\Activities\RidingCardActivityHandler;
  10. use App\Handlers\BikeControl;
  11. use App\Handlers\BikeHandler;
  12. use App\Handlers\BikeStatusInfoSyncHandler;
  13. use App\Handlers\ConvertHandler;
  14. use App\Http\Requests\BikeCloseOrderRequest;
  15. use App\Http\Requests\BikeNoRequest;
  16. use App\Http\Requests\BikeOpenStoreOrderRequest;
  17. use App\Http\Requests\LocationRequest;
  18. use App\Jobs\BikeTemporaryWaitOverThirtyAutoCloseOrderJob;
  19. use App\Jobs\SendSMSBikeTemporaryWaitOverThirtyJob;
  20. use App\Maps\CacheMap;
  21. use App\Models\Area;
  22. use App\Models\AreaSetting;
  23. use App\Models\Bike;
  24. use App\Models\Order;
  25. use App\Models\OrderBikeOperate;
  26. use App\Models\User;
  27. use App\Repositories\AreaRepository;
  28. use App\Repositories\AreaSettingRepository;
  29. use App\Repositories\BikeRepository;
  30. use App\Repositories\LocationLogRepository;
  31. use App\Repositories\OrderRepository;
  32. use App\Repositories\ParkingRepository;
  33. use App\Repositories\PunishmentOrderRepository;
  34. use App\Repositories\RentOrderRepository;
  35. use App\Repositories\UserRepository;
  36. use App\Transformers\AreaTransformer;
  37. use App\Transformers\BikeTransformer;
  38. use App\Transformers\OrderTransformer;
  39. use Carbon\Carbon;
  40. use Illuminate\Support\Facades\Cache;
  41. use Illuminate\Support\Facades\DB;
  42. use Illuminate\Support\Facades\Log;
  43. use Illuminate\Support\Facades\Redis;
  44. use Symfony\Component\HttpKernel\Exception\HttpException;
  45. class BikeController extends BaseController
  46. {
  47. /**
  48. * 获取附近车
  49. * @param LocationRequest $request
  50. * @return mixed
  51. * User: Mead
  52. */
  53. public function index(LocationRequest $request)
  54. {
  55. $lat = $request->get('lat');
  56. $lng = $request->get('lng');
  57. try {
  58. // 查找最近车的bike_no
  59. $options = ['WITHDIST' => true, 'SORT' => 'ASC', 'WITHCOORD' => true];
  60. $redis = Redis::connection();
  61. $nearby_bikes = $redis->georadius(Bike::REDIS_BIKE_LOCATION_TAG, $lng, $lat, 1, 'km', $options);
  62. $bikes = [];
  63. if (count($nearby_bikes)) {
  64. $bikes = array_map(function ($val) {
  65. return [
  66. 'bike_no' => $val[0],
  67. 'distance' => $val[1],
  68. 'latitude' => $val[2][1],
  69. 'longitude' => $val[2][0],
  70. 'iconPath' => 'http://resource.weilaibike.com/bluebike.png',
  71. 'width' => 24,
  72. 'height' => 28,
  73. 'zIndex' => 1111,
  74. 'id' => $val[0]
  75. ];
  76. }, $nearby_bikes);
  77. $options = ['SORT' => 'ASC', 'COUNT' => 1];
  78. $redis = Redis::connection();
  79. $area_ids = $redis->georadius(Area::REDIS_AREAS_LOCATION_TAG, $lng, $lat, 30, 'km', $options);
  80. if (count($area_ids) === 1) {
  81. $area_id = $area_ids[0];
  82. $bike_nos = array_column($bikes, 'bike_no');
  83. $batteryPower = (new AreaSettingRepository(new AreaSetting()))->byAreaIdGetBatteryPower($area_id);
  84. if ($batteryPower) {
  85. $b_nos = Bike::whereIn('bike_no', $bike_nos)->where('battery_power', '<=', $batteryPower)->pluck('bike_no');
  86. if (count($bike_nos)) {
  87. foreach ($b_nos as $b_no) {
  88. $key = array_search($b_no, $bike_nos);
  89. unset($bikes[$key]);
  90. }
  91. // foreach ($bikes as $key => $bike) {
  92. // if (in_array($bike['bike_no'], $b_nos->toArray())) {
  93. // unset($bikes[$key]);
  94. // }
  95. // }
  96. }
  97. }
  98. $bikes = array_values($bikes);
  99. }
  100. }
  101. return $this->response->array($bikes);
  102. } catch (\Exception $exception) {
  103. $this->errorException($exception->getMessage());
  104. }
  105. }
  106. /**
  107. * 获取单个车的信息
  108. * @param $bike_no
  109. * @param BikeRepository $bikeRepository
  110. * @return \Dingo\Api\Http\Response
  111. * User: Mead
  112. */
  113. public function show($bike_no, BikeRepository $bikeRepository)
  114. {
  115. try {
  116. $bike = $bikeRepository->byBikeNo($bike_no);
  117. return $this->response->item($bike, BikeTransformer::class);
  118. } catch (\Exception $exception) {
  119. return $this->errorException('获取单车数据异常');
  120. }
  121. }
  122. /**
  123. * 响铃
  124. * @param BikeNoRequest $request
  125. * @return mixed
  126. * User: Mead
  127. */
  128. public function findBike($bike_no, BikeRepository $bikeRepository)
  129. {
  130. try {
  131. if (!$bikeRepository->byNoIsBikeCanRide($bike_no)) {
  132. return $this->errorNoValidation('车找不到或车暂停使用');
  133. }
  134. $box_no = $bikeRepository->byNoGetBoxNO($bike_no);
  135. $re = BikeControl::bellBike($box_no);
  136. return $this->response->array([
  137. 'is_ok' => $re
  138. ]);
  139. } catch (\Exception $exception) {
  140. return $this->errorException($exception->getMessage());
  141. }
  142. }
  143. /**
  144. * 用车订单(开车)
  145. * User: Mead
  146. */
  147. public function openLock(BikeOpenStoreOrderRequest $request, OrderRepository $orderRepository, BikeRepository $bikeRepository, RentOrderRepository $rentOrderRepository, AreaSettingRepository $areaSettingRepository, PunishmentOrderRepository $punishmentOrderRepository, AreaRepository $areaRepository, UserRepository $userRepository)
  148. {
  149. $bike_no = $request->get('bike_no');
  150. $bike_id = $bikeRepository->byBikeNoGetId($bike_no);
  151. $area_id = $request->get('area_id');
  152. $lat = $request->get('lat');
  153. $lng = $request->get('lng');
  154. $cache_key = "RIDE_ORDER_{$bike_no}";
  155. if (Cache::has($cache_key)) {
  156. return $this->errorNoValidation('您提交的太频繁了,请一会再提交!');
  157. }
  158. Cache::put($cache_key, 1, Carbon::now()->addSeconds(5));
  159. if (!$bike_id) {
  160. return $this->errorNoValidation('非法请求');
  161. }
  162. // 判断用户押金,授权,认证,手机号状态是否正常
  163. $user = $this->user;
  164. if ((int)$user->is_deposit === User::DEPOSIT_NO) {
  165. return $this->errorNoValidation('请您先交纳押金');
  166. }
  167. // if ((int)$user->deposit_type === User::DEPOSIT_CARD && (int)$user->is_deposit === User::DEPOSIT_OK) {
  168. // // 押金类型为免押金卡 判断是否过期
  169. // if (!$userRepository->isDepositCardExpired($user->id)) {
  170. // return $this->errorNoValidation('免押金卡已到期,请您先交纳押金');
  171. // }
  172. // }
  173. if ((int)$user->is_bind_mobile === User::BIND_MOBILE_NO) {
  174. return $this->errorNoValidation('请先绑定您的手机号');
  175. }
  176. if ((int)$user->is_card_certified === User::CARD_NO) {
  177. return $this->errorNoValidation('请您先完善实名认证');
  178. }
  179. if ((int)$user->is_match_ride_age === User::RIDE_BIKE_AGE_NO) {
  180. return $this->errorNoValidation('未成年人禁止骑车');
  181. }
  182. // $area = $areaRepository->byIdGetModelRedis($area_id);
  183. // if ($area) {
  184. // return $this->errorNoValidation('暂无运营区域!');
  185. // }
  186. $punish = $punishmentOrderRepository->checkNoPayModel($user->id);
  187. if (!$punish) return $this->errorNoValidation('您有罚单未支付,请先处理');
  188. $setting = $areaSettingRepository->byAreaId($area_id);
  189. if ($setting['is_advance_recharge'] && $user->wallet_money <= 0) {
  190. return $this->errorNoValidation('余额不足,请先充值');
  191. }
  192. // 判断用户是否有为支付的订单
  193. if ($orderRepository->byUserIdCheckIsExistRideOrder($user->id)) {
  194. return $this->errorNoValidation('您有未完成的订单,请先处理');
  195. }
  196. if ($setting['is_open_day_rent'] && $rentOrderRepository->byUserIdCheckIsExistNoPayOrder($user->id)) {
  197. return $this->errorNoValidation('您有未支付的租车订单,请先处理');
  198. }
  199. // 判断车的状态是正常
  200. if (!$bikeRepository->isBikeCanRide($bike_id)) {
  201. return $this->errorNoValidation('该车暂不能用');
  202. }
  203. // 判断用户是否在车的距离范围内
  204. $bike = $bikeRepository->byIdGetModel($bike_id);
  205. //以车的区域为主
  206. if ($bike->put_area_id !== $area_id) {
  207. $area_id = $bike->put_area_id;
  208. $setting = $areaSettingRepository->byAreaId($area_id);
  209. if ($setting['is_advance_recharge'] && $user->wallet_money <= 0) {
  210. return $this->errorNoValidation('余额不足,请先充值');
  211. }
  212. if ($setting['is_open_day_rent'] && $rentOrderRepository->byUserIdCheckIsExistNoPayOrder($user->id)) {
  213. return $this->errorNoValidation('您有未支付的租车订单,请先处理');
  214. }
  215. }
  216. $options = ['SORT' => 'ASC'];
  217. $redis = Redis::connection();
  218. $nearby_bikes = $redis->georadius(Bike::REDIS_BIKE_LOCATION_TAG, $lng, $lat, 1, 'km', $options);
  219. if (!in_array($bike->bike_no, $nearby_bikes)) {
  220. return $this->errorNoValidation('小主,咱俩有点远!');
  221. }
  222. $box_no = $bikeRepository->byNoGetBoxNO($bike_no);
  223. try {
  224. $order = DB::transaction(function () use ($bikeRepository, $user, $bike_no, $bike_id, $area_id, $lat, $lng, $box_no) {
  225. $users = User::find($user['id']);
  226. // 创建订单
  227. $data = [
  228. 'user_id' => $user['id'],
  229. 'no' => Order::makeNo(),
  230. 'bike_no' => $bike_no,
  231. 'bike_id' => $bike_id,
  232. 'area_id' => $area_id,
  233. 'phone_detail' => $users->userPhoneDetail->detail ?? '',
  234. 'start_use_bike_time' => now(),
  235. 'start_use_bike_location' => [
  236. 'latitude' => $lat,
  237. 'longitude' => $lng,
  238. ],
  239. 'status' => Order::STATUS_RIDE_BIKE
  240. ];
  241. $order = Order::create($data);
  242. // 开锁
  243. BikeControl::openLock($box_no);
  244. // 记录日志信息
  245. OrderBikeOperate::log($order->id, OrderBikeOperate::TYPE_OPEN_BIKE, $bike_id, $user->id, $lat, $lng);
  246. // 更新车的信息(真在骑行中)
  247. $bikeRepository->byIdUpdateRideOk($bike_id);
  248. // 更新orders redis
  249. (new BikeStatusInfoSyncHandler())->toBikeRideStatus(BikeStatusInfoSyncHandler::ROLE_USER, $bike_no, [
  250. 'id' => $order->id,
  251. 'bike_id' => $order->bike_id,
  252. 'area_id' => $order->area_id
  253. ]);
  254. return $order;
  255. });
  256. BikeControl::openLock($box_no);
  257. if (!$user->register_area_id) {
  258. $user->register_area_id = $area_id;
  259. $user->save();
  260. }
  261. } catch (\Exception $exception) {
  262. return $this->errorNoValidation($exception->getMessage());
  263. }
  264. return $this->response->item($order, OrderTransformer::class);
  265. }
  266. /**
  267. * 结束订单
  268. * User: Mead
  269. */
  270. public function closeLock(BikeCloseOrderRequest $request, OrderRepository $orderRepository, AreaSettingRepository $areaSettingRepository, BikeRepository $bikeRepository, LocationLogRepository $locationLogRepository)
  271. {
  272. try {
  273. $bike_no = $request->get('bike_no');
  274. $order_no = $request->get('order_no');
  275. $lat = $request->get('lat');
  276. $lng = $request->get('lng');
  277. $order = $orderRepository->byNoGetRideOrder($order_no);
  278. if (!$order) {
  279. return $this->errorNoValidation('订单不存在或订单已结算');
  280. }
  281. $user_id = $this->user->id;
  282. $cache_key = "RIDE_CLOSE_ORDER_{$user_id}";
  283. if (Cache::has($cache_key)) {
  284. return $this->errorNoValidation('您提交的太频繁了,请一会再提交!');
  285. }
  286. Cache::put($cache_key, 1, Carbon::now()->addSeconds(3));
  287. // 30秒内关车,关闭订单
  288. $second = Carbon::now()->diffInSeconds(Carbon::parse($order->start_use_bike_time));
  289. if ($second < AreaSetting::CLOSE_BIKE_TIME) {
  290. // 检查用户是否恶意临时关锁
  291. if ($orderRepository->checkUserMoreCloseOrder($this->user->id)) {
  292. return $this->errorNoValidation('您今天太频繁操作车辆');
  293. }
  294. }
  295. $box_no = $bikeRepository->byNoGetBoxNO($order->bike_no);
  296. //获取车的最后位置
  297. $location = $locationLogRepository->byBikeNoGetLastLocation($order->bike_no);
  298. //运动中不能锁车
  299. if ($location['speed']) {
  300. BikeControl::nowBikeLocation($box_no);
  301. // return $this->errorNoValidation('运动中不能关锁', 450);
  302. }
  303. // 更新车的信息
  304. $bikeModel = $bikeRepository->byIdGetModel($order->bike_id);
  305. $bikeModel->is_riding = Bike::RIDING_NO;
  306. $bikeModel->last_use_bike_end_time = date('Y-m-d H:i:s');
  307. $bikeModel->save();
  308. // 删除redis订单
  309. if ($location['lat'] <= 0) {
  310. $location['lat'] = $lat;
  311. $location['lng'] = $lng;
  312. }
  313. // 删除临时停车key
  314. $key = sprintf(CacheMap::BIKE_TEM_WAIT, $bike_no);
  315. app()->redis->del($key);
  316. // 判断是否经常这样操作(未做)
  317. if ($second <= AreaSetting::CLOSE_BIKE_TIME) {
  318. BikeControl::closeLock($box_no);
  319. // 记录日志信息
  320. OrderBikeOperate::log($order->id, OrderBikeOperate::TYPE_CLONE_BIKE, $order->bike_id, $this->user->id, $lat, $lng);
  321. // 关闭订单
  322. $order->status = Order::STATUS_CLOSE_ORDER;
  323. $order->end_use_bike_time = now();
  324. $order->end_use_bike_location = [
  325. 'latitude' => $lat,
  326. 'longitude' => $lng,
  327. ];
  328. $order->save();
  329. //更新redis状态
  330. (new BikeStatusInfoSyncHandler())->toBikeWaitRideStatus($bike_no, $location['lng'], $location['lat']);
  331. // 记录临时关锁
  332. return $this->response->item($order, OrderTransformer::class);
  333. } else {
  334. BikeControl::closeLock($box_no);
  335. // 记录日志信息
  336. OrderBikeOperate::log($order->id, OrderBikeOperate::TYPE_CLONE_BIKE, $order->bike_id, $this->user->id, $lat, $lng);
  337. }
  338. // 保存轨迹信息
  339. // 结束订单
  340. $setting = $areaSettingRepository->byAreaId($order->area_id);
  341. // 是否处于临时停车的状态
  342. if ((int)$order->status === Order::STATUS_PAUSE_BIKE) {
  343. $order->pause_bike_time_length += Carbon::now()->diffInMinutes(Carbon::parse($order->pause_bike_time));
  344. }
  345. $order->status = Order::STATUS_CLOSE_BIKE;
  346. $order->end_use_bike_time = now();
  347. $order->end_use_bike_location = [
  348. 'latitude' => $lat,
  349. 'longitude' => $lng,
  350. ];
  351. //计算用车时间
  352. $order->use_bike_time_length = ceil($second / 60);
  353. // 计算价格
  354. if (bccomp($setting->starting_price_time, $order->use_bike_time_length) >= 0) {
  355. // 起步价时间内只收起步价
  356. $time_money = $setting->starting_price;
  357. } else {
  358. $time_money = $setting->per_money * ceil(bcsub($order->use_bike_time_length, $setting->starting_price_time) / $setting->per_minute);
  359. $time_money = bcadd($time_money, $setting->starting_price, 2);
  360. }
  361. // $time_money = $setting->per_money * ceil($order->use_bike_time_length / $setting->per_minute);
  362. // 计算是否在免费分钟内
  363. if ($setting->is_minute_free == AreaSetting::FREE_MINUTE_OK && $setting->many_minute_free >= $order->use_bike_time_length) {
  364. if ($setting->minute_free_times == 0) {
  365. $time_money = 0;
  366. if ($order->preferential_type == 0) {
  367. $order->preferential_type = arr2str([Order::PREFERENTIAL_FREE_MINUTE], '-');
  368. } else {
  369. $arr = str2arr($order->preferential_type, '-');
  370. $order->preferential_type = arr2str(array_merge($arr, [Order::PREFERENTIAL_FREE_MINUTE]), '-');
  371. }
  372. } else {
  373. $key = sprintf(CacheMap::FREE_MINUTE_USER_ID, $order->user_id);
  374. app()->redis->sadd($key, $order->id);
  375. app()->redis->expireat($key, Carbon::tomorrow()->timestamp);
  376. if (app()->redis->scard($key) <= $setting->minute_free_times) {
  377. $time_money = 0;
  378. if ($order->preferential_type == 0) {
  379. $order->preferential_type = arr2str([Order::PREFERENTIAL_FREE_MINUTE], '-');
  380. } else {
  381. $arr = str2arr($order->preferential_type, '-');
  382. $order->preferential_type = arr2str(array_merge($arr, [Order::PREFERENTIAL_FREE_MINUTE]), '-');
  383. }
  384. }
  385. }
  386. }
  387. if ($time_money < 0) {
  388. $time_money = 0;
  389. }
  390. //计算骑行距离
  391. $order->use_bike_distance_length = bcdiv($location['mileage'], 1000, 2);
  392. // 根据起始点计算
  393. // $order->use_bike_distance_length = getDistance($order->start_use_bike_location['longitude'], $order->start_use_bike_location['latitude'], $order->end_use_bike_location['longitude'], $order->end_use_bike_location['latitude']);
  394. // 判断车是否在停车的区域
  395. $order->dispatch_money = 0;
  396. if ($areaSettingRepository->byAreaIdGetIsWholeAreaHuanche($order->area_id) === AreaSetting::WHOLE_AREA_HUANCHE_NO) {
  397. $BikeHandler = new BikeHandler();
  398. $is_huanche = $BikeHandler->byLocationCheckIsInStopParking($location['lat'], $location['lng'], $order->area_id, $lat, $lng);
  399. $bikeModel->is_in_parking = Bike::IN_PARKING_YES;
  400. if (!$is_huanche['status']) {
  401. // 不在还车点
  402. $dispatch_money = $BikeHandler->byDistanceGetDistanceMoney($is_huanche['distance'], $setting);
  403. $order->dispatch_money = $dispatch_money;
  404. $bikeModel->is_in_parking = Bike::IN_PARKING_NO;
  405. }
  406. } else {
  407. //全区域内可停
  408. $bikeModel->is_in_parking = Bike::IN_PARKING_YES;
  409. }
  410. $order->time_money = $time_money;
  411. $order->pause_money = 0;
  412. $order->preferential_money = 0;
  413. $order->order_money = bcadd($time_money, $order->dispatch_money, 2);
  414. $order->pay_money = $order->order_money;
  415. $order->pay_type = Order::PAY_STATUS_NO;
  416. $order->total_money = bcadd($time_money, $order->dispatch_money, 2);
  417. $order->save();
  418. $bikeModel->save();
  419. //更新redis状态
  420. (new BikeStatusInfoSyncHandler())->toBikeWaitRideStatus($bike_no, $location['lng'], $location['lat']);
  421. //关锁
  422. BikeControl::closeLock($box_no);
  423. // 记录日志信息
  424. // OrderBikeOperate::log($order->id, OrderBikeOperate::TYPE_CLONE_BIKE, $order->bike_id, $this->user->id, $lat, $lng);
  425. return $this->response->item($order, OrderTransformer::class);
  426. } catch (HttpException $exception) {
  427. return $this->errorNoValidation($exception->getMessage(), $exception->getStatusCode());
  428. }
  429. }
  430. /**
  431. * 临时关锁
  432. * User: Mead
  433. */
  434. public function temporaryCloseLock(BikeCloseOrderRequest $request, OrderRepository $orderRepository, BikeRepository $bikeRepository, LocationLogRepository $locationLogRepository)
  435. {
  436. $bike_no = $request->get('bike_no');
  437. $order_no = $request->get('order_no');
  438. $lat = $request->get('lat');
  439. $lng = $request->get('lng');
  440. try {
  441. $user = $this->user;
  442. $order = $orderRepository->byNoGetRideOrder($order_no);
  443. if (!$order) {
  444. return $this->errorBadRequest('请求非法');
  445. }
  446. $user_id = $this->user->id;
  447. $cache_key = "ORDER_TEMPORARY_CLOSE_BIKE_{$user_id}";
  448. if (Cache::has($cache_key)) {
  449. return $this->errorNoValidation('您提交的太频繁了,请一会再提交!');
  450. }
  451. Cache::put($cache_key, 1, Carbon::now()->addSeconds(3));
  452. //获取车的最后位置
  453. $location = $locationLogRepository->byBikeNoGetLastLocation($order->bike_no, CacheMap::IS_OPEN_MONGODB_DUG);
  454. $box_no = $bikeRepository->byNoGetBoxNO($order->bike_no);
  455. // //运动中不能锁车
  456. if ($location['speed']) {
  457. BikeControl::nowBikeLocation($box_no);
  458. // return $this->errorNoValidation('运动中不能关锁', 450);
  459. }
  460. $order->status = Order::STATUS_PAUSE_BIKE;
  461. $order->pause_bike_time = now();
  462. $order->save();
  463. // 关锁
  464. BikeControl::temporaryCloseLock($box_no);
  465. // 记录日志信息
  466. OrderBikeOperate::log($order->id, OrderBikeOperate::TYPE_PAUSE_CLONE_BIKE, $order->bike_id, $user->id, $lat, $lng);
  467. //修改rides
  468. (new BikeStatusInfoSyncHandler())->toBikeTemporaryWaitRideStatus($bike_no);
  469. // 延迟分发一个临时停车超过30分 提醒队列
  470. $key = sprintf(CacheMap::BIKE_TEM_WAIT, $bike_no);
  471. app()->redis->setex($key, CacheMap::BIKE_TEM_WAIT_TIME, Carbon::now());
  472. $mobile = $user->mobile;
  473. $start_use_time = $order->start_use_bike_time;
  474. $this->dispatch(new SendSMSBikeTemporaryWaitOverThirtyJob($mobile, $bike_no, $start_use_time, $key, Carbon::now()->addMinutes(30)));
  475. $this->dispatch(new BikeTemporaryWaitOverThirtyAutoCloseOrderJob($mobile, $bike_no, $start_use_time, $key, Carbon::now()->addMinutes(60)));
  476. return $this->response->array([
  477. 'is_close_lock' => true
  478. ]);
  479. } catch (HttpException $exception) {
  480. return $this->errorNoValidation($exception->getMessage(), $exception->getStatusCode());
  481. }
  482. }
  483. /**
  484. * 临时开锁
  485. * User: Mead
  486. */
  487. public function temporaryOpenLock(BikeCloseOrderRequest $request, OrderRepository $orderRepository, BikeRepository $bikeRepository)
  488. {
  489. try {
  490. $bike_no = $request->get('bike_no');
  491. $order_no = $request->get('order_no');
  492. $lat = $request->get('lat');
  493. $lng = $request->get('lng');
  494. $user = $this->user;
  495. $order = $orderRepository->byNoGetRideOrder($order_no);
  496. if (!$order) {
  497. return $this->errorNoValidation('订单不存在或订单已结算');
  498. }
  499. $user_id = $this->user->id;
  500. $cache_key = "ORDER_TEMPORARY_OPEN_BIKE_{$user_id}";
  501. if (Cache::has($cache_key)) {
  502. return $this->errorNoValidation('您提交的太频繁了,请一会再提交!');
  503. }
  504. Cache::put($cache_key, 1, Carbon::now()->addSeconds(3));
  505. $order->status = Order::STATUS_RIDE_BIKE;
  506. $order->pause_bike_time_length += Carbon::now()->diffInMinutes(Carbon::parse($order->pause_bike_time));
  507. $order->save();
  508. // 开锁
  509. $box_no = $bikeRepository->byNoGetBoxNO($bike_no);
  510. BikeControl::temporaryOpnLock($box_no);
  511. // 记录日志信息
  512. OrderBikeOperate::log($order->id, OrderBikeOperate::TYPE_PAUSE_OPEN_BIKE, $order->bike_id, $user->id, $lat, $lng);
  513. (new BikeStatusInfoSyncHandler())->toBikeTemporaryRideStatus($bike_no);
  514. // 删除临时停车时得缓存key
  515. $key = sprintf(CacheMap::BIKE_TEM_WAIT, $bike_no);
  516. app()->redis->del($key);
  517. return $this->response->array([
  518. 'is_open_lock' => true
  519. ]);
  520. } catch (HttpException $exception) {
  521. return $this->errorNoValidation($exception->getMessage(), $exception->getStatusCode());
  522. }
  523. }
  524. /**
  525. * 判断是否在运营范围
  526. * Author: Mead
  527. */
  528. public function checkBikeIsRidingArea(BikeCloseOrderRequest $request, BikeRepository $bikeRepository, OrderRepository $orderRepository, LocationLogRepository $locationLogRepository, AreaRepository $areaRepository)
  529. {
  530. $bike_no = $request->get('bike_no');
  531. $order_no = $request->get('order_no');
  532. $lat = $request->get('lat');
  533. $lng = $request->get('lng');
  534. try {
  535. $order = $orderRepository->byNo($order_no);
  536. if (!$order) return $this->errorBadRequest('非法请求');
  537. $second = Carbon::now()->diffInSeconds(Carbon::parse($order->start_use_bike_time));
  538. if ($second < AreaSetting::CLOSE_BIKE_TIME) {
  539. //小于60秒直接锁车
  540. return [
  541. 'is_close_order' => true,
  542. ];
  543. }
  544. $user_id = $this->user['id'];
  545. $cache_key = "ORDER_CHECK_BIKE_IS_RIDINGAREA_{$user_id}";
  546. if (Cache::has($cache_key)) {
  547. return $this->errorNoValidation('您提交的太频繁了,请一会再提交!');
  548. }
  549. Cache::put($cache_key, 1, Carbon::now()->addSeconds(3));
  550. $box_no = $bikeRepository->byNoGetBoxNO($order->bike_no);
  551. BikeControl::nowBikeLocation($box_no);
  552. $location = $locationLogRepository->byBikeNoGetLastLocation($order->bike_no, CacheMap::IS_OPEN_MONGODB_DUG);
  553. if ($location['lat'] <= 0) {
  554. $location['lat'] = $lat;
  555. $location['lng'] = $lng;
  556. }
  557. $area = $areaRepository->byIdGetModelRedis($order->area_id);
  558. //检查是否有运营区域
  559. if (!$area) {
  560. return $this->errorNoValidation('暂无运营区域!');
  561. }
  562. //检查是否在骑行区域
  563. $is_out_area = $this->isOutArea($location['lat'], $location['lng'], $area);
  564. if (!$is_out_area) {
  565. return $this->errorNoValidation('超出骑行区域,暂不能锁车');
  566. }
  567. $BikeHandler = new BikeHandler();
  568. //检查是否在禁停区
  569. $is_ban_stop_bike = $BikeHandler->byLocationCheckIsInBanStopParking($location['lat'], $location['lng'], $order->area_id, $lat, $lng);
  570. if ($is_ban_stop_bike) {
  571. return $this->errorNoValidation('禁停区域内禁止停车!');
  572. }
  573. return [
  574. 'is_close_order' => false,
  575. ];
  576. } catch (HttpException $exception) {
  577. return $this->errorNoValidation($exception->getMessage());
  578. }
  579. }
  580. /**
  581. * 检查是否在还车点
  582. * @param BikeCloseOrderRequest $request
  583. * @param OrderRepository $orderRepository
  584. * @param ParkingRepository $parkingRepository
  585. * @param AreaSettingRepository $areaSettingRepository
  586. * User: Mead
  587. */
  588. public function checkBikeIsInStopParking(BikeCloseOrderRequest $request, BikeRepository $bikeRepository, OrderRepository $orderRepository, AreaSettingRepository $areaSettingRepository, LocationLogRepository $locationLogRepository, AreaRepository $areaRepository)
  589. {
  590. $bike_no = $request->get('bike_no');
  591. $order_no = $request->get('order_no');
  592. $lat = $request->get('lat');
  593. $lng = $request->get('lng');
  594. try {
  595. $order = $orderRepository->byNo($order_no);
  596. if (!$order) return $this->errorBadRequest('非法请求');
  597. $user_id = $this->user['id'];
  598. $cache_key = "ORDER_CHECK_BIKE_IS_PARK_{$user_id}";
  599. if (Cache::has($cache_key)) {
  600. return $this->errorNoValidation('您提交的太频繁了,请一会再提交!');
  601. }
  602. Cache::put($cache_key, 1, Carbon::now()->addSeconds(3));
  603. $box_no = $bikeRepository->byNoGetBoxNO($order->bike_no);
  604. BikeControl::nowBikeLocation($box_no);
  605. $setting = $areaSettingRepository->byAreaId($order->area_id);
  606. $location = $locationLogRepository->byBikeNoGetLastLocation($order->bike_no, CacheMap::IS_OPEN_MONGODB_DUG);
  607. if ($location['lat'] <= 0) {
  608. $location['lat'] = $lat;
  609. $location['lng'] = $lng;
  610. }
  611. // // 判断是否在运动中
  612. // if ($location['speed']) {
  613. // return $this->errorNoValidation('运动中不能关锁', 450);
  614. // }
  615. $area = $areaRepository->byIdGetModelRedis($order->area_id);
  616. //检查是否有运营区域
  617. if (!$area) {
  618. return $this->errorNoValidation('暂无运营区域!');
  619. }
  620. //检查是否在骑行区域
  621. $is_out_area = $this->isOutArea($location['lat'], $location['lng'], $area);
  622. if (!$is_out_area) {
  623. return $this->errorNoValidation('超出骑行区域,暂不能锁车');
  624. }
  625. $BikeHandler = new BikeHandler();
  626. //检查是否在禁停区
  627. $is_ban_stop_bike = $BikeHandler->byLocationCheckIsInBanStopParking($location['lat'], $location['lng'], $order->area_id, $lat, $lng);
  628. if ($is_ban_stop_bike) {
  629. return $this->errorNoValidation('禁停区域内禁止停车!');
  630. }
  631. //判断是否全区域内可停
  632. if ($areaSettingRepository->byAreaIdGetIsWholeAreaHuanche($order->area_id) === AreaSetting::WHOLE_AREA_HUANCHE_OK) {
  633. return [
  634. 'is_dispatch' => true,
  635. 'is_stop_bike' => true,
  636. 'dispatch_money' => 0,
  637. ];
  638. }
  639. // 判断是否在停车点
  640. $is_huanche = $BikeHandler->byLocationCheckIsInStopParking($location['lat'], $location['lng'], $order->area_id, $lat, $lng);
  641. if (!$is_huanche['status']) {
  642. BikeControl::nowBikeLocation($box_no);
  643. // 不在还车点
  644. $dispatch_money = $BikeHandler->byDistanceGetDistanceMoney($is_huanche['distance'], $setting);
  645. return [
  646. 'is_dispatch' => false,
  647. 'is_stop_bike' => false,
  648. 'dispatch_money' => $dispatch_money,
  649. ];
  650. }
  651. return [
  652. 'is_dispatch' => true,
  653. 'is_stop_bike' => true,
  654. 'dispatch_money' => 0,
  655. ];
  656. } catch (HttpException $exception) {
  657. return $this->errorNoValidation($exception->getMessage());
  658. }
  659. }
  660. /**
  661. * 判断是否在骑行区
  662. * @param $lat
  663. * @param $lng
  664. * @param $box_no
  665. * User: Mead
  666. */
  667. private function isOutArea($lat, $lng, $area)
  668. {
  669. try {
  670. $location = [
  671. 'latitude' => $lat,
  672. 'longitude' => $lng,
  673. ];
  674. $fences = $area['area_fence'];
  675. $centre = $area['area_centre'];
  676. $radius = $area['area_radius'];
  677. $area_fushe_fence = $area['area_fushe_fence'];
  678. // 判断是否在骑行区域
  679. $ConvertHandler = (new ConvertHandler());
  680. $is_out_area = $ConvertHandler->is_point_in_polygon($location, $fences);
  681. return $is_out_area;
  682. } catch (\Exception $exception) {
  683. return $this->errorNoValidation($exception->getMessage());
  684. }
  685. // // 判断是否骑出辐射范围
  686. // $is_out_area_nearby = true;
  687. // if (!$is_out_area) {
  688. // $is_out_area_nearby = $ConvertHandler->is_point_in_polygon($location, $area_fushe_fence);
  689. // }
  690. //
  691. // return [
  692. // 'is_out_area' => $is_out_area,
  693. // 'is_out_area_nearby' => $is_out_area_nearby
  694. // ];
  695. }
  696. }