• 瑞吉外卖Day06

    1.用户地址

    1.1实体类

    1. /**
    2.  * 地址簿
    3.  */
    4. @Data
    5. public class AddressBook implements Serializable {
    6.  
    7.     private static final long serialVersionUID = 1L;
    8.  
    9.     private Long id;
    10.  
    11.  
    12.     //用户id
    13.     private Long userId;
    14.  
    15.  
    16.     //收货人
    17.     private String consignee;
    18.  
    19.  
    20.     //手机号
    21.     private String phone;
    22.  
    23.  
    24.     //性别 0 女 1 男
    25.     private String sex;
    26.  
    27.  
    28.     //省级区划编号
    29.     private String provinceCode;
    30.  
    31.  
    32.     //省级名称
    33.     private String provinceName;
    34.  
    35.  
    36.     //市级区划编号
    37.     private String cityCode;
    38.  
    39.  
    40.     //市级名称
    41.     private String cityName;
    42.  
    43.  
    44.     //区级区划编号
    45.     private String districtCode;
    46.  
    47.  
    48.     //区级名称
    49.     private String districtName;
    50.  
    51.  
    52.     //详细地址
    53.     private String detail;
    54.  
    55.  
    56.     //标签
    57.     private String label;
    58.  
    59.     //是否默认 0 否 1是
    60.     private Integer isDefault;
    61.  
    62.     //创建时间
    63.     @TableField(fill = FieldFill.INSERT)
    64.     private LocalDateTime createTime;
    65.  
    66.  
    67.     //更新时间
    68.     @TableField(fill = FieldFill.INSERT_UPDATE)
    69.     private LocalDateTime updateTime;
    70.  
    71.  
    72.     //创建人
    73.     @TableField(fill = FieldFill.INSERT)
    74.     private Long createUser;
    75.  
    76.  
    77.     //修改人
    78.     @TableField(fill = FieldFill.INSERT_UPDATE)
    79.     private Long updateUser;
    80.  
    81.  
    82.     //是否删除
    83.     private Integer isDeleted;
    84. }

    1.2mapper

    1. @Mapper
    2. public interface AddressBookMapper extends BaseMapper {
    3. }

    1.3service

    1. public interface AddressBookService extends IService {
    2. }
    1. @Service
    2. public class AddressBookServiceImpl extends ServiceImpl implements AddressBookService {
    3. }

    1.4controller

    1. /**
    2.  * 地址簿管理
    3.  */
    4. @Slf4j
    5. @RestController
    6. @RequestMapping("/addressBook")
    7. public class AddressBookController {
    8.  
    9.     @Autowired
    10.     private AddressBookService addressBookService;
    11.  
    12.     /**
    13.      * 新增
    14.      */
    15.     @PostMapping
    16.     public R save(@RequestBody AddressBook addressBook) {
    17.         Long userId = BaseContext.getCurrentId();
    18.         /*
    19.          * 这里留了个坑，我把数据库create_Id和更新时间等字段改成了非空了，算是遗留Bug
    20.          * 不知道为什么BaseContext拿不到用户Id数据，所以拿不到create_Id
    21.          *
    22.          * */
    23.         addressBook.setUserId(userId);
    24.         log.info("addressBook:{}", addressBook);
    25.         addressBookService.save(addressBook);
    26.         return R.success(addressBook);
    27.     }
    28.  
    29.     /**
    30.      * 设置默认地址
    31.      */
    32.     @PutMapping("default")
    33.     public R setDefault(@RequestBody AddressBook addressBook) {
    34.         log.info("addressBook:{}", addressBook);
    35.         LambdaUpdateWrapper wrapper = new LambdaUpdateWrapper<>();
    36.         wrapper.eq(AddressBook::getUserId, BaseContext.getCurrentId());
    37.         wrapper.set(AddressBook::getIsDefault, 0);
    38.         //SQL:update address_book set is_default = 0 where user_id = ?
    39.         addressBookService.update(wrapper);
    40.  
    41.         addressBook.setIsDefault(1);
    42.         //SQL:update address_book set is_default = 1 where id = ?
    43.         addressBookService.updateById(addressBook);
    44.         return R.success(addressBook);
    45.     }
    46.  
    47.     /**
    48.      * 根据id查询地址
    49.      */
    50.     @GetMapping("/{id}")
    51.     public R get(@PathVariable Long id) {
    52.         AddressBook addressBook = addressBookService.getById(id);
    53.         if (addressBook != null) {
    54.             return R.success(addressBook);
    55.         } else {
    56.             return R.error("没有找到该对象");
    57.         }
    58.     }
    59.  
    60.     /**
    61.      * 查询默认地址
    62.      */
    63.     @GetMapping("default")
    64.     public R getDefault() {
    65.         LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>();
    66.         queryWrapper.eq(AddressBook::getUserId, BaseContext.getCurrentId());
    67.         queryWrapper.eq(AddressBook::getIsDefault, 1);
    68.  
    69.         //SQL:select * from address_book where user_id = ? and is_default = 1
    70.         AddressBook addressBook = addressBookService.getOne(queryWrapper);
    71.  
    72.         if (null == addressBook) {
    73.             return R.error("没有找到该对象");
    74.         } else {
    75.             return R.success(addressBook);
    76.         }
    77.     }
    78.  
    79.     /**
    80.      * 查询指定用户的全部地址
    81.      */
    82.     @GetMapping("/list")
    83.     public R> list(AddressBook addressBook) {
    84.         addressBook.setUserId(BaseContext.getCurrentId());
    85.         log.info("addressBook:{}", addressBook);
    86.  
    87.         //条件构造器
    88.         LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>();
    89.         queryWrapper.eq(null != addressBook.getUserId(), AddressBook::getUserId, addressBook.getUserId());
    90.         queryWrapper.orderByDesc(AddressBook::getUpdateTime);
    91.  
    92.         //SQL:select * from address_book where user_id = ? order by update_time desc
    93.         return R .success(addressBookService.list(queryWrapper));
    94.     }
    95. }

    2.购物车

    2.1实体类

    1. /**
    2.  * 购物车
    3.  */
    4. @Data
    5. public class ShoppingCart implements Serializable {
    6.  
    7.     private static final long serialVersionUID = 1L;
    8.  
    9.     private Long id;
    10.  
    11.     //名称
    12.     private String name;
    13.  
    14.     //用户id
    15.     private Long userId;
    16.  
    17.     //菜品id
    18.     private Long dishId;
    19.  
    20.     //套餐id
    21.     private Long setmealId;
    22.  
    23.     //口味
    24.     private String dishFlavor;
    25.  
    26.     //数量
    27.     private Integer number;
    28.  
    29.     //金额
    30.     private BigDecimal amount;
    31.  
    32.     //图片
    33.     private String image;
    34.  
    35.     private LocalDateTime createTime;
    36. }

    2.2mapper

    1. @Mapper
    2. public interface ShoppingCartMapper extends BaseMapper {
    3. }

    2.3service

    1.  
    2. public interface ShoppingCartService extends IService {
    3. }
    1. @Service
    2. public class ShoppingCartServiceImpl extends ServiceImpl implements ShoppingCartService {
    3. }

    2.4controller 

    1. @Slf4j
    2. @RestController
    3. @RequestMapping("shoppingCart")
    4. public class ShoppingCartController {
    5.  
    6.     @Autowired
    7.     private ShoppingCartService shoppingCartService;
    8.  
    9.     /**
    10.      * 往购物车内部添加
    11.      * @param shoppingCart
    12.      * @return
    13.      */
    14.     @PostMapping("/add")
    15.     public R add(@RequestBody ShoppingCart shoppingCart) {
    16.         log.info("购物车数据:{}",shoppingCart.toString());
    17.         //解析一下接受的对象不难发现没有用户ID，所以我们得设置一下用户Id，也就是当前购物车是谁的
    18.         Long userId=BaseContext.getCurrentId();
    19.         shoppingCart.setUserId(userId);
    20.  
    21.         //判断当前传来的Id是菜品还是套餐，这两个肯定会有一个是Null
    22.         Long dishId=shoppingCart.getDishId();
    23.         Long setmealId = shoppingCart.getSetmealId();
    24.  
    25.         LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>();
    26.         lambdaQueryWrapper.eq(ShoppingCart::getUserId, userId);
    27.  
    28.         //动态拼接一下添加的查询条件
    29.         if (dishId!=null){
    30.             //传过来的是菜品而不是套餐
    31.             lambdaQueryWrapper.eq(ShoppingCart::getDishId, dishId);
    32.         }
    33.         if (setmealId!=null){
    34.             //传过来的是套餐而不是菜品
    35.             lambdaQueryWrapper.eq(ShoppingCart::getSetmealId, setmealId);
    36.         }
    37.         /*
    38.           SQL:select * from shopping_cart where user_Id=? and dish_Id=?/setmealId=?
    39.           如果可以查出来，说明购物车已经加入了相关菜品
    40.          */
    41.         ShoppingCart cartServiceOne=shoppingCartService.getOne(lambdaQueryWrapper);
    42.  
    43.         //已经存在在购物车里
    44.         if (cartServiceOne!=null){
    45.             //在数量原有基础上+1
    46.             Integer count = cartServiceOne.getNumber();
    47.             cartServiceOne.setNumber(count + 1);
    48.             /*
    49.                 update shopping_cart set number=（更新后数量）
    50.             */
    51.             shoppingCartService.updateById(cartServiceOne);
    52.         }else {
    53.             //尚未存在购物车，就添加到购物车
    54.             shoppingCart.setNumber(1);
    55.             /*
    56.                 insert into shopping_cart (ShoppingCart解析出来的字段) values (ShoppingCart解析出来的数据)
    57.             */
    58.             shoppingCart.setCreateTime(LocalDateTime.now());
    59.             shoppingCartService.save(shoppingCart);
    60.             //因为这个分支的cartServiceOne是null，所以要覆盖一下
    61.             cartServiceOne = shoppingCart;
    62.         }
    63.         return R.success(cartServiceOne);
    64.     }
    65.  
    66.     /**
    67.      * @return 购物车列表
    68.      */
    69.     @GetMapping("/list")
    70.     public R> list(){
    71.  
    72.         LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>();
    73.         queryWrapper.eq(BaseContext.getCurrentId()!=null,ShoppingCart::getUserId, BaseContext.getCurrentId());
    74.  
    75.         // 最晚下单的 菜品或套餐在购物车中最先展示
    76.         queryWrapper.orderByDesc(ShoppingCart::getCreateTime);
    77.         List list = shoppingCartService.list(queryWrapper);
    78.  
    79.         return R.success(list);
    80.     }
    81.  
    82.  
    83.     /**
    84.      * 一次性清空购物车
    85.      * @return
    86.      */
    87.     @DeleteMapping("/clean")
    88.     public R clean(){
    89.         //获取当前购物车用户Id
    90.         Long userId = BaseContext.getCurrentId();
    91.         LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper();
    92.         lambdaQueryWrapper.eq(ShoppingCart::getUserId, userId);
    93.         shoppingCartService.remove(lambdaQueryWrapper);
    94.         return R.success("清空成功");
    95.     }
    96. }

    3.用户下单

    3.1service

    1. @Service
    2. public class OrdersServiceImpl extends ServiceImpl implements OrdersService {
    3.     @Autowired
    4.     private ShoppingCartService shoppingCartService;
    5.  
    6.     @Autowired
    7.     private ShoppingCartController shoppingCartController;
    8.  
    9.     @Autowired
    10.     private UserService userService;
    11.  
    12.     @Autowired
    13.     private AddressBookService addressBookService;
    14.  
    15.     @Autowired
    16.     private OrderDetailService orderDetailService;
    17.  
    18.  
    19.     /**
    20.      * 订单提交（下单）
    21.      *
    22.      * @param orders
    23.      */
    24.     @Transactional
    25.     @Override
    26.     public void submit(Orders orders) {
    27.         //获取用户Id
    28.         Long userId = BaseContext.getCurrentId();
    29.         //根据用户Id查询所对应的购物车内容
    30.         LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>();
    31.         lambdaQueryWrapper.eq(userId != null, ShoppingCart::getUserId, userId);
    32.         List shoppingCartList = shoppingCartService.list(lambdaQueryWrapper);
    33.  
    34.         //如果订单是空就没必要下单了
    35.         if (shoppingCartList == null || shoppingCartList.size() == 0) {
    36.             throw new CustomException("购物车为空，不能下单");
    37.         }
    38.  
    39.         //拿到用户数据
    40.         User user = userService.getById(userId);
    41.  
    42.         //拿到用户的地址数据
    43.         Long addressId = orders.getAddressBookId();
    44.         AddressBook addressBook = addressBookService.getById(addressId);
    45.         if (addressBook == null) {
    46.             throw new CustomException("地址有误，不能下单");
    47.         }
    48.  
    49.         long orderId = IdWorker.getId();  // 订单号
    50.  
    51.         //遍历购物车列表，来算一下总金额
    52.         //  购物车中 商品 的总金额 需要保证在多线程的情况下 也是能计算正确的，故需要使用原子类
    53.         AtomicInteger amount = new AtomicInteger(0);
    54.  
    55.         List orderDetails = shoppingCartList.stream().map((item) -> {
    56.             OrderDetail orderDetail = new OrderDetail();
    57.  
    58.             orderDetail.setOrderId(orderId);
    59.             orderDetail.setName(item.getName());
    60.             orderDetail.setImage(item.getImage());
    61.  
    62.             orderDetail.setDishId(item.getDishId());
    63.             orderDetail.setSetmealId(item.getSetmealId());
    64.             orderDetail.setDishFlavor(item.getDishFlavor());
    65.             orderDetail.setNumber(item.getNumber());
    66.             orderDetail.setAmount(item.getAmount());
    67.  
    68.             amount.addAndGet(item.getAmount().multiply(new BigDecimal(item.getNumber())).intValue());
    69.  
    70.             return orderDetail;
    71.  
    72.         }).collect(Collectors.toList());
    73.  
    74.  
    75.         //填充订单对象信息（CV的）
    76.         orders.setId(orderId);
    77.         orders.setOrderTime(LocalDateTime.now());
    78.         orders.setCheckoutTime(LocalDateTime.now());
    79.         orders.setStatus(2);
    80.         orders.setAmount(new BigDecimal(amount.get()));//总金额，需要 遍历购物车，计算相关金额来得到
    81.         orders.setUserId(userId);
    82.         orders.setNumber(String.valueOf(orderId));
    83.         orders.setUserName(user.getName());
    84.         orders.setConsignee(addressBook.getConsignee());
    85.         orders.setPhone(addressBook.getPhone());
    86.         orders.setAddress((addressBook.getProvinceName() == null ? "" : addressBook.getProvinceName())
    87.                 + (addressBook.getCityName() == null ? "" : addressBook.getCityName())
    88.                 + (addressBook.getDistrictName() == null ? "" : addressBook.getDistrictName())
    89.                 + (addressBook.getDetail() == null ? "" : addressBook.getDetail()));
    90.  
    91.         // 向订单表插入数据,一条数据，插入数据之前，需要填充如上属性
    92.         this.save(orders);    //  --> ordersService.save(orders);
    93.  
    94.         // 向订单明细表插入数据，多条数据
    95.         orderDetailService.saveBatch(orderDetails);
    96.  
    97.         //调用接口清空购物车
    98.         shoppingCartController.clean();
    99.     }
    100.  
    101. }

    3.2controller

    1. @Slf4j
    2. @RestController
    3. @RequestMapping("/order")
    4. public class OrdersController {
    5.  
    6.     @Autowired
    7.     private OrdersService ordersService;
    8.  
    9.     @PostMapping("/submit")
    10.     public R submit(@RequestBody Orders orders){
    11.         //比较繁琐，在service实现
    12.         ordersService.submit(orders);
    13.         return R.success("下单成功");
    14.     }
    15. }

  • 相关阅读:
    iOS 面试题以及自我理解答案
    网络安全，下一个十年饭碗稳了！
    【树莓派不吃灰】Linux篇⑨ 学习 磁碟配额(Quota)与进阶文件系统管理（核心概念）
    Java获取数组最大值、Java8的Arrays.sort()原理
    Java 后端开发面试总结【25 个技术专题】
    Gartner 2023API管理市场指南重磅发布，得帆云iPaaS标杆入榜
    2022.8.11SAP目前为止学习总结
    软件包管理|npm【前端工具链】
    算法：（二）数组
    [随笔]Integer.parseInt转换二进制数为int整数异常
  • 原文地址：https://blog.csdn.net/dfdg345/article/details/134466175