package com.supersavedriving.user.modular.api;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.supersavedriving.user.core.common.annotion.ServiceLog;
|
import com.supersavedriving.user.core.util.ToolUtil;
|
import com.supersavedriving.user.modular.system.model.*;
|
import com.supersavedriving.user.modular.system.service.*;
|
import com.supersavedriving.user.modular.system.util.GaoDe.MapUtil;
|
import com.supersavedriving.user.modular.system.util.GaoDe.model.District;
|
import com.supersavedriving.user.modular.system.util.MallBook.model.InterfaceResponse;
|
import com.supersavedriving.user.modular.system.util.MallBook.model.Receive;
|
import com.supersavedriving.user.modular.system.util.MallBook.model.ReceiveUser;
|
import com.supersavedriving.user.modular.system.util.MallBook.util.RSASignature;
|
import com.supersavedriving.user.modular.system.util.MallBook.util.TrhRequest;
|
import com.supersavedriving.user.modular.system.util.MiniAppPay;
|
import com.supersavedriving.user.modular.system.util.PayMoneyUtil;
|
import com.supersavedriving.user.modular.system.util.ResultUtil;
|
import com.supersavedriving.user.modular.system.util.StrUtil;
|
import com.supersavedriving.user.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.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.PrintWriter;
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 订单控制器
|
* @author pzb
|
* @Date 2023/2/28 11:24
|
*/
|
@RestController
|
@RequestMapping("")
|
public class OrderController {
|
|
Logger logger = LoggerFactory.getLogger(OrderController.class);
|
|
@Autowired
|
private IOrderService orderService;
|
|
@Autowired
|
private IAppUserService appUserService;
|
|
@Autowired
|
private PayMoneyUtil payMoneyUtil;
|
|
@Autowired
|
private IBillService billService;
|
|
@Autowired
|
private IRevenueService revenueService;
|
|
@Autowired
|
private IDriverService driverService;
|
|
@Autowired
|
private IBranchOfficeService branchOfficeService;
|
@Autowired
|
private ITBranchOfficeAreaService branchOfficeAreaService;
|
|
@Autowired
|
private ISystemConfigService systemConfigService;
|
|
@Autowired
|
private IRechargeRecordService rechargeRecordService;
|
|
|
@Autowired
|
private IDivisionRecordService divisionRecordService;
|
|
@Autowired
|
private TOrderCheckService orderCheckService;
|
|
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/queryServerPrice")
|
@ApiOperation(value = "根据定位获取恶劣天气+节假日信息", tags = {"用户端-首页"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."),
|
@ApiImplicitParam(value = "纬度", name = "lat", required = true, dataType = "String"),
|
@ApiImplicitParam(value = "经度", name = "lon", required = true, dataType = "String"),
|
})
|
public ResponseWarpper<Integer> queryServerPrice(String lat,String lon){
|
try {
|
Integer i =0; // 0为不能接单 1为恶劣天气 2为节假日 3为恶劣+节假日
|
District geocode = MapUtil.geocode(lon, lat);
|
String districtCode = geocode.getDistrictCode();
|
TBranchOfficeArea branchOfficeArea = branchOfficeAreaService.selectOne(new EntityWrapper<TBranchOfficeArea>().eq("areaCode", districtCode)
|
.last("LIMIT 1"));
|
// List<BranchOffice> districtCode1 = branchOfficeService.selectList(new EntityWrapper<BranchOffice>().eq("districtCode", districtCode).eq("status",1));
|
if(Objects.nonNull(branchOfficeArea)){
|
BranchOffice branchOffice = branchOfficeService.selectById(branchOfficeArea.getBranchOfficeId());
|
// BranchOffice branchOffice = districtCode1.get(0);
|
Integer id = branchOffice.getId();
|
SystemConfig systemConfig = systemConfigService.selectOne(new EntityWrapper<SystemConfig>().eq("type", 8).eq("companyId", id));
|
if(systemConfig!=null){
|
String content = systemConfig.getContent();
|
JSONObject jsonObject = JSONObject.parseObject(content);
|
String num1 = jsonObject.get("num1").toString();
|
String num9 = jsonObject.get("num3").toString();
|
if("1".equals(num1)){
|
i=1;
|
}
|
if("1".equals(num9)){
|
i=2;
|
}
|
if("1".equals(num1)&&"1".equals(num9)){
|
i=3;
|
}
|
}
|
if(i == 0){
|
i = 4;
|
}
|
}
|
return ResponseWarpper.success(i);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/queryServerOrder")
|
@ApiOperation(value = "获取正在进行中的订单id", tags = {"用户端-首页"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<List<Long>> queryServerOrder(){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
AppUser appUser = appUserService.selectById(uid);
|
List<Integer> list = Arrays.asList(101, 102, 103, 104, 105, 106, 107, 201, 401);
|
List<Order> orders = orderService.selectList(new EntityWrapper<Order>().eq("userPhone", appUser.getPhone()).eq("status", 1).in("state", list));
|
List<Long> collect = orders.stream().map(Order::getId).collect(Collectors.toList());
|
return ResponseWarpper.success(collect);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
@ResponseBody
|
@PostMapping("/api/order/queryServerCheckOrder")
|
@ApiOperation(value = "获取正在进行中的车检订单id", tags = {"用户端-首页(车检)"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<List<Integer>> queryServerCheckOrder(){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
AppUser appUser = appUserService.selectById(uid);
|
List<Integer> list = Arrays.asList(101, 102, 104, 105, 106, 107, 108);
|
List<TOrderCheck> orders = orderCheckService.selectList(new EntityWrapper<TOrderCheck>().eq("userPhone", appUser.getPhone()).eq("status", 1).in("state", list));
|
List<Integer> collect = orders.stream().map(TOrderCheck::getId).collect(Collectors.toList());
|
return ResponseWarpper.success(collect);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/getEstimatedCosts")
|
@ApiOperation(value = "获取预估费用", tags = {"用户端-首页"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<EstimatedCostsWarpper> getEstimatedCosts(EstimatedCosts estimatedCosts){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
ResultUtil<EstimatedCostsWarpper> estimatedCosts1 = orderService.getEstimatedCosts(uid, estimatedCosts);
|
return ResponseWarpper.success(estimatedCosts1);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/travelOrder")
|
@ApiOperation(value = "用户下单/扫码下单", tags = {"用户端-首页"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper travelOrder(TravelOrder travelOrder){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
ResultUtil resultUtil = orderService.travelOrder(uid, travelOrder);
|
return ResponseWarpper.success(resultUtil);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/checkOrder")
|
@ApiOperation(value = "用户下单(车检)", tags = {"用户端-首页(车检)"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper checkOrder(CheckOrder checkOrder){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
ResultUtil resultUtil = orderCheckService.travelOrder(uid, checkOrder);
|
return ResponseWarpper.success(resultUtil);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
@ResponseBody
|
@GetMapping("/api/order/getCheckOrderInfo")
|
@ApiOperation(value = "用户下单获取(车检)说明", tags = {"用户端-首页(车检)"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper getCheckOrderInfo(String userLat,String userLng){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
ResultUtil resultUtil = orderCheckService.getCheckOrderInfo(userLat, userLng);
|
return ResponseWarpper.success(resultUtil);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
@ResponseBody
|
@PostMapping("/api/order/cancelCheckOrder")
|
@ApiOperation(value = "用户取消(车检)订单", tags = {"用户端-首页(车检)"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper cancelCheckOrder(Long orderId){
|
if(null == orderId){
|
return ResponseWarpper.success(ResultUtil.paranErr("orderId"));
|
}
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
ResultUtil resultUtil = orderCheckService.cancelOrder(uid, orderId);
|
return ResponseWarpper.success(resultUtil);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
@ResponseBody
|
@PostMapping("/api/order/payCheckOrder")
|
@ApiOperation(value = "用户支付车检订单费用", tags = {"用户端-首页(车检)"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper payCheckOrder(PayCheckOrder payCheckOrder){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
ResultUtil resultUtil = orderCheckService.payCheckOrder(uid, payCheckOrder);
|
return ResponseWarpper.success(resultUtil);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/cancelOrder")
|
@ApiOperation(value = "用户取消订单", tags = {"用户端-首页"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"),
|
@ApiImplicitParam(value = "取消原因", name = "cause", required = true, dataType = "string"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper cancelOrder(Long orderId, String cause){
|
if(null == orderId){
|
return ResponseWarpper.success(ResultUtil.paranErr("orderId"));
|
}
|
if(ToolUtil.isEmpty(cause)){
|
return ResponseWarpper.success(ResultUtil.paranErr("cause"));
|
}
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
ResultUtil resultUtil = orderService.cancelOrder(uid, orderId, cause);
|
return ResponseWarpper.success(resultUtil);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/queryOrderInfo")
|
@ApiOperation(value = "获取订单详情", tags = {"用户端-首页"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<OrderInfoWarpper> queryOrderInfo(Long orderId){
|
if(null == orderId){
|
return ResponseWarpper.success(ResultUtil.paranErr("orderId"));
|
}
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
OrderInfoWarpper orderInfoWarpper = orderService.queryOrderInfo(uid, orderId);
|
return ResponseWarpper.success(orderInfoWarpper);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
@ResponseBody
|
@PostMapping("/base/order/queryShareOrderInfo")
|
@ApiOperation(value = "获取订单详情", tags = {"用户端-分享"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"),
|
})
|
public ResponseWarpper<OrderInfoWarpper> queryOrderInfo1(Long orderId){
|
if(null == orderId){
|
return ResponseWarpper.success(ResultUtil.paranErr("orderId"));
|
}
|
try {
|
OrderInfoWarpper orderInfoWarpper = orderService.queryOrderInfo(null, orderId);
|
return ResponseWarpper.success(orderInfoWarpper);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/editOrderEndAddress")
|
@ApiOperation(value = "修改终点", tags = {"用户端-首页"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper editOrderEndAddress(EditOrderEndAddress editOrderEndAddress){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
ResultUtil resultUtil = orderService.editOrderEndAddress(uid, editOrderEndAddress);
|
return ResponseWarpper.success(resultUtil);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
@ResponseBody
|
@PostMapping("/api/order/queryOrderPrice")
|
@ApiOperation(value = "获取订单费用明细", tags = {"用户端-首页"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<OrderPriceInfoWarpper> queryOrderPrice(Long orderId){
|
if(null == orderId){
|
return ResponseWarpper.success(ResultUtil.paranErr("orderId"));
|
}
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
OrderPriceInfoWarpper orderPriceWarpper = orderService.queryOrderPrice(uid, orderId);
|
return ResponseWarpper.success(orderPriceWarpper);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
@ResponseBody
|
@PostMapping("/api/order/queryCheckOrderInfo")
|
@ApiOperation(value = "获取(车检)订单详情", tags = {"司机端-服务中(车检)"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<CheckOrderInfoWarpper> queryCheckOrderInfo(Long orderId){
|
if(null == orderId){
|
return ResponseWarpper.success(ResultUtil.paranErr("orderId"));
|
}
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
CheckOrderInfoWarpper orderInfoWarpper = orderCheckService.queryOrderInfo(uid, orderId);
|
return ResponseWarpper.success(orderInfoWarpper);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
@ResponseBody
|
@PostMapping("/api/order/calculationOfExpenses")
|
@ApiOperation(value = "重新计算待支付页面订单费用明细", tags = {"用户端-首页"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"),
|
@ApiImplicitParam(value = "优惠券id", name = "couponId", required = true, dataType = "int"),
|
@ApiImplicitParam(value = "是否使用余额抵扣（0=否，1=是）", name = "payType", required = true, dataType = "int"),
|
@ApiImplicitParam(value = "抵扣金额", name = "balance", required = true, dataType = "double"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<OrderPriceWarpper> calculationOfExpenses(Long orderId, Integer couponId, Integer payType, Double balance){
|
if(null == orderId){
|
return ResponseWarpper.success(ResultUtil.paranErr("orderId"));
|
}
|
if(null == payType){
|
return ResponseWarpper.success(ResultUtil.paranErr("payType"));
|
}
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
OrderPriceWarpper orderPriceWarpper = orderService.calculationOfExpenses(uid, orderId, couponId, payType, balance);
|
return ResponseWarpper.success(orderPriceWarpper);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/queryPayCouponList")
|
@ApiOperation(value = "获取支付页面优惠券选择列表", tags = {"用户端-首页"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<List<CouponWarpper>> queryPayCouponList(Long orderId){
|
if(null == orderId){
|
return ResponseWarpper.success(ResultUtil.paranErr("orderId"));
|
}
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
List<CouponWarpper> list = orderService.queryPayCouponList(uid, orderId);
|
return ResponseWarpper.success(list);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
@ResponseBody
|
@PostMapping("/api/order/queryPayCheckCouponList")
|
@ApiOperation(value = "获取支付页面车检优惠券选择列表", tags = {"用户端-首页(车检)"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<List<CheckCouponWarpper>> queryPayCheckCouponList(Long orderId){
|
if(null == orderId){
|
return ResponseWarpper.success(ResultUtil.paranErr("orderId"));
|
}
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
|
List<CheckCouponWarpper> list = orderCheckService.queryPayCouponList(uid, orderId);
|
return ResponseWarpper.success(list);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/orderPayment")
|
@ApiOperation(value = "订单完成后的支付操作", tags = {"用户端-首页"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper orderPayment(OrderPayment orderPayment){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
ResultUtil resultUtil = orderService.orderPayment(uid, orderPayment);
|
return ResponseWarpper.success(resultUtil);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
/**
|
* 订单微信支付回调处理
|
*/
|
@ResponseBody
|
@PostMapping("/base/order/orderPayCallback")
|
public String orderPayCallback(@RequestBody JSONObject req) {
|
try {
|
|
|
Map<String, Object> params = req.toJavaObject(Map.class);
|
|
//验证异步通知请求签名
|
Boolean verify = StrUtil.verify(params, MiniAppPay.MD5_KEY);
|
|
if (verify) {
|
//TODO 业务系统处理订单支付结果逻辑
|
String code = (String) params.get("mchOrderNo");
|
String state = (String) params.get("state");
|
String extParam = (String) params.get("extParam");
|
|
if (2 != Integer.parseInt(state)) {
|
// Order order = orderService.selectOne(new EntityWrapper<Order>().eq("code",code));
|
// AccountChangeDetail accountChangeDetail = accountChangeDetailService.selectById(parameter2);
|
// Double m = new BigDecimal(accountChangeDetail.getOldData()).subtract(new BigDecimal(accountChangeDetail.getNewData())).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
|
// AppUser appUser1 = appUserService.selectById(order.getUserId());
|
// appUser1.setAccountBalance(new BigDecimal(appUser1.getAccountBalance()).add(new BigDecimal(m)).setScale(2, RoundingMode.HALF_EVEN).doubleValue());
|
// appUserService.updateById(appUser1);
|
// accountChangeDetailService.deleteById(accountChangeDetail.getId());
|
System.err.println("支付失败");
|
return "false";
|
}
|
if (2 == Integer.parseInt(state)) {
|
// String merOrderId = jsonObject.getString("merOrderId");
|
if(extParam==null){
|
Order order = orderService.selectOne(new EntityWrapper<Order>().eq("code", code));
|
ResultUtil resultUtil = orderService.orderPayCallback(String.valueOf(order.getId()), "");
|
}else {
|
if("1".equals(extParam)){
|
TOrderCheck checkCode = orderCheckService.selectOne(new EntityWrapper<TOrderCheck>().eq("checkCode", code));
|
ResultUtil resultUtil = orderCheckService.orderPayCallback(1,checkCode, "");
|
}else if("2".equals(extParam)){
|
TOrderCheck checkCode = orderCheckService.selectOne(new EntityWrapper<TOrderCheck>().eq("code", code));
|
ResultUtil resultUtil = orderCheckService.orderPayCallback(2,checkCode, "");
|
}
|
}
|
return "success";
|
}
|
|
|
}
|
|
//返回success字符串，否则支付系统将重复推送通知，间隔通知频率为0/30/60/90/120/150,单位：秒
|
return "false";
|
|
|
// 验签
|
// boolean verify = RSASignature.validate(interfaceResponse.content(), interfaceResponse.getSign());
|
// if (verify) {//验签成功业务处理逻辑
|
// if("0000".equals(interfaceResponse.getCode())){
|
// JSONObject jsonObject = JSON.parseObject(interfaceResponse.getResult());
|
// Integer status = jsonObject.getInteger("status");
|
// String orderId = jsonObject.getString("parameter1");
|
// String parameter2 = jsonObject.getString("parameter2");
|
// if(2 == status){
|
// Order order = orderService.selectById(orderId);
|
// AccountChangeDetail accountChangeDetail = accountChangeDetailService.selectById(parameter2);
|
// Double m = new BigDecimal(accountChangeDetail.getOldData()).subtract(new BigDecimal(accountChangeDetail.getNewData())).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
|
// AppUser appUser1 = appUserService.selectById(order.getUserId());
|
// appUser1.setAccountBalance(new BigDecimal(appUser1.getAccountBalance()).add(new BigDecimal(m)).setScale(2, RoundingMode.HALF_EVEN).doubleValue());
|
// appUserService.updateById(appUser1);
|
// accountChangeDetailService.deleteById(accountChangeDetail.getId());
|
// System.err.println("支付失败");
|
// }
|
// if(1 == status){
|
// String merOrderId = jsonObject.getString("merOrderId");
|
// ResultUtil resultUtil = orderService.orderPayCallback(orderId, merOrderId);
|
// if(resultUtil.getCode() == 10000){
|
// response.setStatus(200);
|
// PrintWriter out = response.getWriter();
|
// out.print("OK");
|
// out.flush();
|
// out.close();
|
// }
|
// }
|
// }
|
// } else {//验签失败业务处理逻辑
|
// System.err.println("支付回调验签失败");
|
// }
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return "false";
|
}
|
|
|
|
/**
|
* 转账回调
|
* @param execute
|
* @param response
|
*/
|
@ResponseBody
|
@PostMapping("/base/order/zhaunzhangCallback")
|
public void zhaunzhangCallback(@RequestBody InterfaceResponse execute, HttpServletResponse response){
|
try {
|
if("0000".equals(execute.getCode())){
|
JSONObject jsonObject = JSON.parseObject(execute.getResult());
|
Integer status = jsonObject.getInteger("status");//0：待处理；1：成功；2：失败
|
if(2 == status){
|
logger.warn("转账失败");
|
return;
|
}
|
String parameter1 = jsonObject.getString("parameter1");
|
RechargeRecord rechargeRecord = rechargeRecordService.selectById(parameter1);
|
|
|
response.setStatus(200);
|
PrintWriter out = response.getWriter();
|
out.print("OK");
|
out.flush();
|
out.close();
|
}else{
|
logger.warn("转账失败：" + execute.getMsg());
|
return;
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
|
|
|
/**
|
* 异步分账回调
|
*/
|
@ResponseBody
|
@PostMapping("/base/order/ledgerCallback")
|
public void ledgerCallback(@RequestBody InterfaceResponse execute, HttpServletResponse response){
|
try{
|
// 验签
|
boolean verify = RSASignature.validate(execute.content(), execute.getSign());
|
if (verify) {//验签成功业务处理逻辑
|
if("0000".equals(execute.getCode())){
|
JSONObject jsonObject = JSON.parseObject(execute.getResult());
|
Integer status = jsonObject.getInteger("status");
|
if(2 == status){
|
logger.warn("异步分账回调异常");
|
return;
|
}
|
String merOrderId = jsonObject.getString("merOrderId");
|
String divisionRecordId = jsonObject.getString("parameter1");
|
DivisionRecord divisionRecord = divisionRecordService.selectById(divisionRecordId);
|
if(divisionRecord.getState() == 2){
|
|
}
|
|
//确认收货
|
new Timer().schedule(new TimerTask() {
|
@Override
|
public void run() {
|
Receive receive = new Receive();//确认收货
|
receive.setOriginalMerOrderId(merOrderId);
|
receive.setRcvAmount(new BigDecimal(divisionRecord.getAmount()).multiply(new BigDecimal(100)).setScale(0, RoundingMode.HALF_EVEN).longValue() + "");
|
List<ReceiveUser> splitList = new ArrayList<>();
|
ReceiveUser receiveUser = new ReceiveUser();
|
receiveUser.setSplitUserId(divisionRecord.getMerchantNumber());
|
receiveUser.setRcvSplitAmount(new BigDecimal(divisionRecord.getAmount()).multiply(new BigDecimal(100)).setScale(0, RoundingMode.HALF_EVEN).longValue() + "");
|
splitList.add(receiveUser);
|
receive.setSplitList(splitList);
|
TrhRequest<Receive> request1 = new TrhRequest();
|
InterfaceResponse execute = request1.execute(receive, Receive.SERVICE_CODE);
|
if(!"0000".equals(execute.getCode())){
|
logger.warn("确认收货" + execute.getMsg());
|
}
|
JSONObject jsonObject = JSON.parseObject(execute.getResult());
|
String status = jsonObject.getString("status");
|
if("2".equals(status)){
|
logger.warn("确认收货失败");
|
}
|
if("0".equals(status)){
|
logger.warn("确认收货处理中");
|
}
|
}
|
}, 60000);
|
response.setStatus(200);
|
PrintWriter out = response.getWriter();
|
out.print("OK");
|
out.flush();
|
out.close();
|
}
|
} else {//验签失败业务处理逻辑
|
System.err.println("支付回调验签失败");
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/orderAppraise")
|
@ApiOperation(value = "订单评价操作", tags = {"用户端-首页"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"),
|
@ApiImplicitParam(value = "评分", name = "score", required = true, dataType = "int"),
|
@ApiImplicitParam(value = "评价内容", name = "content", required = true, dataType = "string"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper orderAppraise(Long orderId, Integer score, String content){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
ResultUtil resultUtil = orderService.orderAppraise(uid, orderId, score, content);
|
return ResponseWarpper.success(resultUtil);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
@ResponseBody
|
@PostMapping("/api/order/checkOrderAppraise")
|
@ApiOperation(value = "车检订单评价操作", tags = {"用户端-首页(车检)"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"),
|
@ApiImplicitParam(value = "评分", name = "score", required = true, dataType = "int"),
|
@ApiImplicitParam(value = "评价内容", name = "content", required = true, dataType = "string"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper checkOrderAppraise(Long orderId, Integer score, String content){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
ResultUtil resultUtil = orderCheckService.orderAppraise(uid, orderId, score, content);
|
return ResponseWarpper.success(resultUtil);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
@ResponseBody
|
@PostMapping("/api/order/queryMyOrder")
|
@ApiOperation(value = "获取我的行程", tags = {"用户端-个人中心"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "页码，首页1", name = "pageNum", required = true, dataType = "int"),
|
@ApiImplicitParam(value = "页条数", name = "pageSize", required = true, dataType = "int"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<List<OrderListWarpper>> queryMyOrder(Integer pageNum, Integer pageSize){
|
if(null == pageNum){
|
return ResponseWarpper.success(ResultUtil.paranErr("pageNum"));
|
}
|
if(null == pageSize){
|
return ResponseWarpper.success(ResultUtil.paranErr("pageSize"));
|
}
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
List<OrderListWarpper> orderListWarppers = orderService.queryMyOrder(uid, pageNum, pageSize);
|
return ResponseWarpper.success(orderListWarppers);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
@ResponseBody
|
@PostMapping("/api/order/queryNotInvoiceOrder")
|
@ApiOperation(value = "获取未开票订单列表", tags = {"用户端-个人中心"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<List<OrderListWarpper>> queryNotInvoiceOrder(NotInvoiceOrder notInvoiceOrder){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
List<OrderListWarpper> orderListWarppers = orderService.queryNotInvoiceOrder(uid, notInvoiceOrder);
|
return ResponseWarpper.success(orderListWarppers);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/invoicing")
|
@ApiOperation(value = "开票操作", tags = {"用户端-个人中心"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper invoicing(Invoicing invoicing){
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
ResultUtil invoicing1 = billService.invoicing(uid, invoicing);
|
return ResponseWarpper.success(invoicing1);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/queryBillList")
|
@ApiOperation(value = "获取开票历史", tags = {"用户端-个人中心"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "页码，首页1", name = "pageNum", required = true, dataType = "int"),
|
@ApiImplicitParam(value = "页条数", name = "pageSize", required = true, dataType = "int"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<List<BillWarpper>> queryBillList(Integer pageNum, Integer pageSize){
|
if(null == pageNum){
|
return ResponseWarpper.success(ResultUtil.paranErr("pageNum"));
|
}
|
if(null == pageSize){
|
return ResponseWarpper.success(ResultUtil.paranErr("pageSize"));
|
}
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
List<BillWarpper> billWarppers = billService.queryBillList(uid, pageNum, pageSize);
|
return ResponseWarpper.success(billWarppers);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
@ResponseBody
|
@PostMapping("/api/order/queryrCheckOrderList")
|
@ApiOperation(value = "获取用户车检订单列表(2.0)", tags = {"用户端-个人中心"}, notes = "")
|
@ApiImplicitParams({
|
@ApiImplicitParam(value = "订单状态（1服务中 2已完成 3 已取消 全部不传）", name = "state", required = true, dataType = "int"),
|
@ApiImplicitParam(value = "页码，首页1", name = "pageNum", required = true, dataType = "int"),
|
@ApiImplicitParam(value = "页条数", name = "pageSize", required = true, dataType = "int"),
|
@ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")
|
})
|
public ResponseWarpper<List<CheckOrderListWarpper>> queryrCheckOrderList(Integer state, Integer pageNum, Integer pageSize){
|
if(null == pageNum){
|
return ResponseWarpper.success(ResultUtil.paranErr("pageNum"));
|
}
|
if(null == pageSize){
|
return ResponseWarpper.success(ResultUtil.paranErr("pageSize"));
|
}
|
try {
|
Integer uid = appUserService.getUserByRequest();
|
if(null == uid){
|
return ResponseWarpper.success(ResultUtil.tokenErr());
|
}
|
List<CheckOrderListWarpper> checkOrderListWarppers = orderCheckService.queryCheckOrderList(uid, state, pageNum, pageSize);
|
return ResponseWarpper.success(checkOrderListWarppers);
|
}catch (Exception e){
|
e.printStackTrace();
|
return new ResponseWarpper(500, e.getMessage());
|
}
|
}
|
|
|
|
|
|
|
}
|
