外卖平台后端资源,基于微信小程序的ssm后端开发

package com.sky.service.impl; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.github.pagehelper.Page; import com.github.pagehelper.PageHelper; import com.sky.constant.MessageConstant; import com.sky.context.BaseContext; import com.sky.dto.OrdersPageQueryDTO; import com.sky.dto.OrdersPaymentDTO; import com.sky.dto.OrdersSubmitDTO; import com.sky.entity.*; import com.sky.exception.AddressBookBusinessException; import com.sky.exception.OrderBusinessException; import com.sky.exception.ShoppingCartBusinessException; import com.sky.mapper.*; import com.sky.result.PageResult; import com.sky.service.OrdersService; import com.sky.utils.HttpClientUtil; import com.sky.utils.WeChatPayUtil; import com.sky.vo.OrderPaymentVO; import com.sky.vo.OrderSubmitVO; import com.sky.vo.OrderVO; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import javax.annotation.Resource; import java.math.BigDecimal; import java.time.LocalDateTime; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; /** * @author Ms SUN * @date 2023/4/16 */ @Slf4j @Service @Transactional public class OrdersServiceImpl implements OrdersService { @Resource private OrderMapper orderMapper; @Resource private UserMapper userMapper; @Resource private ShoppingCartMapper shoppingCartMapper; @Resource private OrderDetailMapper orderDetailMapper; @Resource private AddressBookMapper addressBookMapper; @Autowired private WeChatPayUtil weChatPayUtil; @Autowired private StringRedisTemplate redisTemplate; /** * 订单提交 * * @param ordersSubmitDTO * @return */ @Override public OrderSubmitVO orderSubmit(OrdersSubmitDTO ordersSubmitDTO) { //根据ID查找地址 AddressBook addressBook = addressBookMapper.getById(ordersSubmitDTO.getAddressBookId()); if (addressBook == null) { throw new AddressBookBusinessException(MessageConstant.ADDRESS_BOOK_IS_NULL); } //判断是否超出派送范围 checkOutAddress(addressBook.getCityName()+addressBook.getDistrictName()+addressBook.getDetail()); Orders orders = new Orders(); //属性拷贝赋值 BeanUtils.copyProperties(ordersSubmitDTO, orders); //赋值当前用户 Long userId = BaseContext.getCurrentId(); orders.setUserId(userId); User user = userMapper.selectById(userId); orders.setUserName(user.getName()); orders.setPhone(addressBook.getPhone()); orders.setConsignee(addressBook.getConsignee()); orders.setAddress(addressBook.getDetail()); //订单号--系统当前时间唯一 orders.setNumber(String.valueOf(System.currentTimeMillis())); //订单状态 orders.setStatus(Orders.PENDING_PAYMENT); //订单提交时间 orders.setOrderTime(LocalDateTime.now()); //支付状态 orders.setPayStatus(Orders.UN_PAID); //向订单表中插入数据 orderMapper.inserOerder(orders); //购物车 ShoppingCart shoppingCart = new ShoppingCart(); shoppingCart.setUserId(userId); //查询并判断购物车是否为空 List<ShoppingCart> shoppingCartList = shoppingCartMapper.selectList(shoppingCart); if (CollectionUtils.isEmpty(shoppingCartList)) { //抛出购物车为空异常 throw new ShoppingCartBusinessException(MessageConstant.SHOPPING_CART_IS_NULL); } List<OrderDetail> orderDetailLists = shoppingCartList.stream().map(cart -> { OrderDetail orderDetail = new OrderDetail(); //属性拷贝赋值 BeanUtils.copyProperties(cart, orderDetail, "id"); //设置订单ID orderDetail.setOrderId(orders.getId()); return orderDetail; }).collect(Collectors.toList()); //向订单明细表中插入数据 orderDetailMapper.insertBatch(orderDetailLists); //提交订单后清空当前登录用户购物车 shoppingCartMapper.delShoppingCartById(userId); //构建OrderDetailVO返回，供支付界面使用 OrderSubmitVO orderSubmitVO = OrderSubmitVO.builder() .id(orders.getId()) .orderNumber(orders.getNumber()) .orderAmount(orders.getAmount()) .orderTime(orders.getOrderTime()) .build(); return orderSubmitVO; } @Value("${sky.shop.address}") private String shopAddress; @Value("${sky.baidu.ak}") private String ak; /** * 校验是否超出配送范围 * * @param address */ private void checkOutAddress(String address) { Map map = new HashMap(); map.put("address",shopAddress); map.put("output","json"); map.put("ak",ak); //请求百度地图地址 String shop= HttpClientUtil.doGet("https://api.map.baidu.com/geocoding/v3",map); //解析店铺坐标 JSONObject jsonObject = JSON.parseObject(shop); if (!jsonObject.getString("status").equals("0")) { //店铺地址解析失败，抛出异常 throw new OrderBusinessException("店铺坐标解析失败"); } //解析地址 JSONObject location = jsonObject.getJSONObject("result").getJSONObject("location"); //纬度 String lat = location.getString("lat"); //经度 String lng = location.getString("lng"); //拼接店铺经纬度 String shopLoc = lat + "," + lng; map.put("address",address); //请求百度地图地址 String userLocation= HttpClientUtil.doGet("https://api.map.baidu.com/geocoding/v3",map); //解析用户坐标 jsonObject = JSON.parseObject(userLocation); if (!jsonObject.getString("status").equals("0")) { //地址解析失败，抛出异常 throw new OrderBusinessException("用户坐标解析失败"); } //解析地址 location = jsonObject.getJSONObject("result").getJSONObject("location"); //纬度 lat = location.getString("lat"); //经度 lng = location.getString("lng"); //拼接用户经纬度 String userLoc = lat + "," + lng; map.put("origin", shopLoc); map.put("destination", userLoc); map.put("steps_info","0"); //路线 //请求百度地图地址 String dev= HttpClientUtil.doGet("https://api.map.baidu.com/directionlite/v1/driving",map); //解析驾车路线坐标 jsonObject = JSON.parseObject(dev); if (!jsonObject.getString("status").equals("0")) { //地址解析失败，抛出异常 throw new OrderBusinessException("派送路线有误"); } //解析 JSONObject result= jsonObject.getJSONObject("result"); JSONArray jsonArray= (JSONArray) result.get("routes"); JSONObject jsonObjects= (JSONObject)jsonArray.get(0); Integer distance = (Integer) jsonObjects.get("distance"); if (distance>5000) { throw new OrderBusinessException("订单超出派送