From 4ba348b700fd7f461f754a283eaeeba3fc9ff36c Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期六, 25 二月 2023 16:16:33 +0800 Subject: [PATCH] 新增加司机端接口 --- driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java | 106 +++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 102 insertions(+), 4 deletions(-) diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java index f7b0cc5..6d6a58b 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java @@ -9,16 +9,17 @@ import com.supersavedriving.driver.modular.system.util.ResultUtil; import com.supersavedriving.driver.modular.system.util.SMSUtil; import com.supersavedriving.driver.modular.system.util.UUIDUtil; -import com.supersavedriving.driver.modular.system.warpper.DriverRegisterWarpper; -import com.supersavedriving.driver.modular.system.warpper.OpenCityWarpper; -import com.supersavedriving.driver.modular.system.warpper.ResponseWarpper; -import com.supersavedriving.driver.modular.system.warpper.TokenWarpper; +import com.supersavedriving.driver.modular.system.warpper.*; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.geo.GeoJsonPoint; +import org.springframework.data.mongodb.core.query.Criteria; +import org.springframework.data.mongodb.core.query.Query; +import org.springframework.data.mongodb.core.query.Update; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; @@ -26,6 +27,7 @@ import javax.servlet.http.HttpServletRequest; import java.util.List; +import java.util.Objects; /** * 司机控制器 @@ -165,6 +167,35 @@ } + @ResponseBody + @PostMapping("/base/driver/driverPassLogin") + @ServiceLog(name = "司机密码登录", url = "/base/driver/driverPassLogin") + @ApiOperation(value = "司机密码登录", tags = {"司机端-登录注册"}, notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(value = "国家代码+86", name = "receiver", required = true, dataType = "string"), + @ApiImplicitParam(value = "电话号码", name = "phone", required = true, dataType = "string"), + @ApiImplicitParam(value = "密码", name = "password", required = true, dataType = "string"), + }) + public ResponseWarpper<TokenWarpper> driverPassLogin(String receiver, String phone, String password){ + if(ToolUtil.isEmpty(receiver)){ + return ResponseWarpper.success(ResultUtil.paranErr("receiver")); + } + if(ToolUtil.isEmpty(phone)){ + return ResponseWarpper.success(ResultUtil.paranErr("phone")); + } + if(ToolUtil.isEmpty(password)){ + return ResponseWarpper.success(ResultUtil.paranErr("password")); + } + try { + ResultUtil<TokenWarpper> tokenWarpper = driverService.driverPassLogin(receiver, phone, password); + return ResponseWarpper.success(tokenWarpper); + }catch (Exception e){ + e.printStackTrace(); + return new ResponseWarpper(500, e.getMessage()); + } + } + + @ResponseBody @PostMapping("/api/driver/flushedToken") @@ -214,4 +245,71 @@ } } + + + @ResponseBody + @PostMapping("/api/driver/queryDriverPosition") + @ServiceLog(name = "获取5公里范围内的司机", url = "/api/driver/queryDriverPosition") + @ApiOperation(value = "获取5公里范围内的司机", tags = {"司机端-首页"}, notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") + }) + public ResponseWarpper<List<String>> queryDriverPosition(HttpServletRequest request){ + try { + Integer uid = driverService.getUserByRequset(request); + if(null == uid){ + return ResponseWarpper.success(ResultUtil.tokenErr()); + } + ResultUtil<List<String>> listResultUtil = driverService.queryDriverPosition(uid); + return ResponseWarpper.success(listResultUtil); + }catch (Exception e){ + e.printStackTrace(); + return new ResponseWarpper(500, e.getMessage()); + } + } + + + + + + @ResponseBody + @PostMapping("/base/driver/addDriverPosition") + @ServiceLog(name = "存储司机实时位置", url = "/base/driver/addDriverPosition") + public ResponseWarpper addDriverPosition(DriverPositionWarpper driverPositionWarpper) { + try { + driverService.addDriverPosition(driverPositionWarpper); + return ResponseWarpper.success(); + }catch (Exception e){ + e.printStackTrace(); + return new ResponseWarpper(500, e.getMessage()); + } + } + + + + @ResponseBody + @PostMapping("/api/driver/queryPromotionQRCode") + @ServiceLog(name = "获取司机推广二维码", url = "/api/driver/queryPromotionQRCode") + @ApiOperation(value = "获取司机推广二维码", tags = {"司机端-个人中心"}, notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") + }) + public ResponseWarpper<PromotionWarpper> queryPromotionQRCode(HttpServletRequest request) { + try { + Integer uid = driverService.getUserByRequset(request); + if (null == uid) { + return ResponseWarpper.success(ResultUtil.tokenErr()); + } + PromotionWarpper promotionWarpper = driverService.queryPromotionQRCode(uid); + return ResponseWarpper.success(promotionWarpper); + } catch (Exception e) { + e.printStackTrace(); + return new ResponseWarpper(500, e.getMessage()); + } + } + + + + + } -- Gitblit v1.7.1