package com.xiaopeng.operation.controller;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.xiaopeng.api.dto.account.UserResourcesDto;
|
import com.xiaopeng.api.dto.map.RouteAndFareDto;
|
import com.xiaopeng.api.dto.operation.LonLatDto;
|
import com.xiaopeng.api.feignClient.account.UserResourcesClient;
|
import com.xiaopeng.api.model.operation.XpPricing;
|
import com.xiaopeng.api.model.operation.XpWhitelist;
|
import com.xiaopeng.api.vo.operation.RouteAndFareVo;
|
import com.xiaopeng.common.core.domain.R;
|
import com.xiaopeng.common.core.exception.ServiceException;
|
import com.xiaopeng.common.core.web.controller.BaseController;
|
import com.xiaopeng.common.core.web.page.PageInfo;
|
import com.xiaopeng.operation.constant.I18nKeyConstant;
|
import com.xiaopeng.operation.dto.PricingAddDTO;
|
import com.xiaopeng.operation.dto.PricingSetPriceDTO;
|
import com.xiaopeng.operation.dto.PricingSetRuleDTO;
|
import com.xiaopeng.operation.dto.XpOrderDto;
|
import com.xiaopeng.operation.query.PricingPageListQuery;
|
import com.xiaopeng.operation.service.IXpGeoQueryEntityService;
|
import com.xiaopeng.operation.service.IXpWhitelistService;
|
import com.xiaopeng.operation.service.XpPricingService;
|
import com.xiaopeng.operation.vo.PricingPageListVO;
|
import com.xiaopeng.operation.vo.SaveOrderVo;
|
import com.xiaopeng.unifiedverification.interceptor.XpClientCheck;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.validation.Valid;
|
|
/**
|
* <p>
|
* 费项管理 前端控制器
|
* </p>
|
*
|
* @author mitao
|
* @since 2026-02-03
|
*/
|
|
@Slf4j
|
@RestController
|
@RequestMapping("")
|
@Api(tags = "费用管理")
|
public class XpPricingController extends BaseController {
|
|
private final XpPricingService xpPricingService;
|
private final IXpGeoQueryEntityService xpGeoQueryEntityService;
|
private final UserResourcesClient userResourcesClient;
|
private final IXpWhitelistService xpWhitelistService;
|
|
|
public XpPricingController(XpPricingService xpPricingService, IXpGeoQueryEntityService xpGeoQueryEntityService, UserResourcesClient userResourcesClient, IXpWhitelistService xpWhitelistService) {
|
this.xpPricingService = xpPricingService;
|
this.xpGeoQueryEntityService = xpGeoQueryEntityService;
|
this.userResourcesClient = userResourcesClient;
|
this.xpWhitelistService = xpWhitelistService;
|
}
|
|
|
@PostMapping("/base/v1/mini-program/navigation/route-and-fare")
|
@ApiOperation(value = "导航-获取路线和费用", tags = {"小程序-获取路线和费用"}, response = RouteAndFareVo.class)
|
@XpClientCheck(checkToken = false, checkOtpToken = true)
|
public R<RouteAndFareVo> getRouteAndFare(@RequestBody @Valid RouteAndFareDto routeAndFareDto, HttpServletRequest request) {
|
// uid已通过拦截器otp校验，可以直接使用
|
String uid = request.getHeader("XP-Uid");
|
return R.ok(xpPricingService.getRouteAndFare(routeAndFareDto, uid));
|
}
|
|
// 根据开通城市 获取定价
|
@GetMapping("/base/v1/mini-program/getPricingByCityId/{cityId}")
|
public R<XpPricing> getPricingByCityId(@PathVariable("cityId") Long cityId) {
|
XpPricing pricing = xpPricingService.lambdaQuery().eq(XpPricing::getCityId, cityId).last("limit 1").one();
|
return R.ok(pricing);
|
}
|
// 根据开通城市 获取定价
|
@GetMapping("/base/v1/mini-program/getPricingByCid")
|
public R<XpPricing> getPricingByCid(@RequestParam Long cityId) {
|
XpPricing pricing = xpPricingService.lambdaQuery().eq(XpPricing::getCityId, cityId).last("limit 1").one();
|
return R.ok(pricing);
|
}
|
|
|
@GetMapping("/base/v1/mini-program/pricing/rules/{openCityId}")
|
@ApiOperation(value = "获取费用规则", tags = {"小程序-根据开通城市获取费用规则"}, response = String.class)
|
public R<?> getPricingRules(@PathVariable Long openCityId) {
|
XpPricing xpPricing = xpPricingService.getOne(new LambdaQueryWrapper<XpPricing>().eq(XpPricing::getCityId, openCityId).eq(XpPricing::getPricingType, 1).last("limit 1"));
|
if (xpPricing != null) {
|
return R.ok(xpPricing.getPriceRule());
|
}
|
return R.ok("");
|
}
|
|
|
/**
|
* 获取等待时间
|
* @param dto
|
* @return
|
*/
|
@PostMapping("/base/v1/mini-program/pricing/getWaitTime")
|
@ApiOperation(value = "获取等待时间", tags = {"小程序-获取等待时间"}, response = Integer.class)
|
public R<Integer> getWaitTime(@RequestBody LonLatDto dto) {
|
return R.ok(xpPricingService.getWaitTime(dto.getLongitude(), dto.getLatitude()));
|
}
|
|
|
/**
|
* 获取用户是否在白名单中
|
*/
|
@PostMapping("/base/v1/mini-program/pricing/isInWhiteList")
|
@ApiOperation(value = "获取用户是否在白名单中", tags = {"小程序-获取用户是否在白名单中"}, response = Boolean.class)
|
@XpClientCheck(checkToken = false, checkOtpToken = true)
|
public R<Boolean> isInWhiteList(HttpServletRequest request) {
|
String uid = request.getHeader("XP-Uid");
|
UserResourcesDto baseUserByUid = userResourcesClient.getBaseUserByUid(uid);
|
if (baseUserByUid!=null) {
|
try {
|
Object data = baseUserByUid.getData();
|
String phone = JSONObject.parseObject(data.toString()).getString("mobile");
|
long count = xpWhitelistService.count(new LambdaQueryWrapper<XpWhitelist>().eq(XpWhitelist::getAccount, phone).eq(XpWhitelist::getStatus, 1));
|
return R.ok(count>0);
|
}catch (Exception e){
|
log.error("获取用户信息失败: {}", e.getMessage());
|
return R.ok(false);
|
}
|
|
}
|
return R.ok(false);
|
}
|
|
|
/**
|
* 保存信息
|
* @param
|
* @return
|
*/
|
@PostMapping("/inner/updateXpGeoQueryEntity")
|
public R<?> updateXpGeoQueryEntity(@RequestParam String orderId) {
|
xpGeoQueryEntityService.updateByOrderId(orderId);
|
return R.ok();
|
}
|
|
|
/**
|
* 播单
|
*/
|
@PostMapping("/base/v1/mini-program/order/save")
|
@ApiOperation(value = "保存订单", tags = {"小程序-保存订单"})
|
@XpClientCheck(checkToken = false, checkOtpToken = true)
|
public R<SaveOrderVo> saveOrder(@RequestBody @Validated XpOrderDto dto, HttpServletRequest request) {
|
String uid = request.getHeader("XP-Uid");
|
Long l = xpPricingService.saveOrder(dto, uid);
|
SaveOrderVo saveOrderVo = new SaveOrderVo();
|
saveOrderVo.setOrderId(l);
|
return R.ok(saveOrderVo);
|
}
|
|
@PostMapping("/api/v1/pricing/pageList")
|
@ApiOperation(value = "管理后台-定价管理分页列表", tags = {"管理后台-定价管理"})
|
public R<PageInfo<PricingPageListVO>> pageList(@RequestBody PricingPageListQuery query) {
|
return R.ok(xpPricingService.pageList(query));
|
}
|
|
@GetMapping("/api/v1/pricing/queryById")
|
@ApiOperation(value = "管理后台-定价管理-详情", tags = {"管理后台-定价管理"}, response = XpPricing.class)
|
public R<XpPricing> queryById(@RequestParam Long id) {
|
XpPricing pricing = xpPricingService.getById(id);
|
if (pricing == null) {
|
throw new ServiceException("定价不存在", I18nKeyConstant.PRICING_NOT_EXIST);
|
}
|
return R.ok(pricing);
|
}
|
|
@PostMapping("/api/v1/pricing/add")
|
@ApiOperation(value = "管理后台-新增定价", tags = {"管理后台-定价管理"})
|
public R<?> add(@Valid @RequestBody PricingAddDTO dto) {
|
xpPricingService.add(dto);
|
return R.ok();
|
}
|
|
@PostMapping("/api/v1/pricing/setPrice")
|
@ApiOperation(value = "管理后台-定价管理-设置价格", tags = {"管理后台-定价管理"})
|
public R<?> setPrice(@Valid @RequestBody PricingSetPriceDTO dto) {
|
xpPricingService.setPrice(dto);
|
return R.ok();
|
}
|
|
@PostMapping("/api/v1/pricing/setRule")
|
@ApiOperation(value = "管理后台-计费规则富文本配置", tags = {"管理后台-定价管理"})
|
public R<?> setRule(@Valid @RequestBody PricingSetRuleDTO dto) {
|
xpPricingService.setRule(dto);
|
return R.ok();
|
}
|
|
@DeleteMapping("/api/v1/pricing/deleteById")
|
@ApiOperation(value = "管理后台-定价管理-删除", tags = {"管理后台-定价管理"})
|
public R<?> deleteById(@RequestParam Long id) {
|
XpPricing pricing = xpPricingService.getById(id);
|
if (pricing == null) {
|
throw new ServiceException("定价不存在", I18nKeyConstant.PRICING_NOT_EXIST);
|
}
|
xpPricingService.removeById(id);
|
return R.ok();
|
}
|
|
|
}
|
