最终效果

image.png

数据库表设计

用户地址单独为一张表，因为一个用户可能会设置多个收货地址
image.png

编写service

  1. package com.shiers.service;
  3. import com.shiers.pojo.UserAddress;
  4. import com.shiers.pojo.bo.AddressBO;
  6. import java.util.List;
  8. /**
  9.  * Demo class
  10.  *
  11.  * @author shierS
  12.  * @date 2021/5/29
  13.  */
  14. public interface AddressService {
  16.     /**
  17.      * 根据用户Id查询用户收货地址列表
  18.      * @param userId
  19.      * @return
  20.      */
  21.     public List<UserAddress> queryAll(String userId);
  24.     /**
  25.      * 用于新增用户地址
  26.      * @param addressBO
  27.      */
  28.     public void addNewUserAddress(AddressBO addressBO);
  30.     /**
  31.      * 用户修改地址
  32.      * @param addressBO
  33.      */
  34.     public void updateUserAddress(AddressBO addressBO);
  36.     /**
  37.      * 根据用户id和地址id，删除对应的地址信息
  38.      * @param userId
  39.      * @param addressId
  40.      */
  41.     public void deleteUserAddress(String userId,String addressId);
  43.     /**
  44.      * 根据用户id和地址id，设置默认地址
  45.      * @param userId
  46.      * @param addressId
  47.      */
  48.     public void updateUserAddressToBeDefault(String userId,String addressId);
  49. }
  1. package com.shiers.service.impl;
  3. import com.shiers.enums.YesOrNo;
  4. import com.shiers.mapper.UserAddressMapper;
  5. import com.shiers.pojo.UserAddress;
  6. import com.shiers.pojo.bo.AddressBO;
  7. import com.shiers.service.AddressService;
  8. import org.n3r.idworker.Sid;
  9. import org.springframework.beans.BeanUtils;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.stereotype.Service;
  12. import org.springframework.transaction.annotation.Propagation;
  13. import org.springframework.transaction.annotation.Transactional;
  15. import java.util.Date;
  16. import java.util.List;
  18. /**
  19.  * Demo class
  20.  *
  21.  * @author shierS
  22.  * @date 2021/5/29
  23.  */
  24. @Service
  25. public class AddressServiceImpl implements AddressService {
  27.     @Autowired
  28.     private UserAddressMapper userAddressMapper;
  29.     @Autowired
  30.     private Sid sid;
  32.     @Transactional(propagation = Propagation.SUPPORTS)
  33.     @Override
  34.     public List<UserAddress> queryAll(String userId) {
  36.         UserAddress ua = new UserAddress();
  37.         ua.setUserId(userId);
  39.         return userAddressMapper.select(ua);
  40.     }
  42.     @Transactional(propagation = Propagation.REQUIRED)
  43.     @Override
  44.     public void addNewUserAddress(AddressBO addressBO) {
  46.         //1、判断当前用户是否存在地址，如果没有，则新增为默认地址
  47.         Integer isDefault = 0;
  48.         List<UserAddress> addressList = this.queryAll(addressBO.getUserId());
  49.         if (addressList == null || addressList.isEmpty() || addressList.size() == 0) {
  50.             isDefault = 1;
  51.         }
  53.         //定义主键Id
  54.         String addressId = sid.nextShort();
  56.         //2、保存地址到数据库
  57.         UserAddress newAddress = new UserAddress();
  58.         //将addressBO中对应的属性字段填充到newAddress中
  59.         BeanUtils.copyProperties(addressBO,newAddress);
  60.         //填充剩余字段
  61.         newAddress.setId(addressId);
  62.         newAddress.setIsDefault(isDefault);
  63.         newAddress.setCreatedTime(new Date());
  64.         newAddress.setUpdatedTime(new Date());
  66.         userAddressMapper.insert(newAddress);
  67.     }
  69.     @Transactional(propagation = Propagation.REQUIRED)
  70.     @Override
  71.     public void updateUserAddress(AddressBO addressBO) {
  72.         String addressId = addressBO.getAddressId();
  74.         UserAddress pendingAddress = new UserAddress();
  75.         BeanUtils.copyProperties(addressBO,pendingAddress);
  77.         pendingAddress.setId(addressId);
  78.         pendingAddress.setUpdatedTime(new Date());
  80.         userAddressMapper.updateByPrimaryKeySelective(pendingAddress);
  82.     }
  84.     @Transactional(propagation = Propagation.REQUIRED)
  85.     @Override
  86.     public void deleteUserAddress(String userId, String addressId) {
  88.         UserAddress address = new UserAddress();
  90.         address.setId(addressId);
  91.         address.setUserId(userId);
  93.         userAddressMapper.delete(address);
  94.     }
  96.     @Transactional(propagation = Propagation.REQUIRED)
  97.     @Override
  98.     public void updateUserAddressToBeDefault(String userId, String addressId) {
  99.         //1.查找默认地址设置为不默认
  100.         UserAddress queryAddress = new UserAddress();
  101.         queryAddress.setUserId(userId);
  102.         queryAddress.setIsDefault(YesOrNo.YES.type);
  104.         //将为默认地址的数据都查询出来，主要是为了放置数据紊乱，有多个默认地址出现，这样可以解决数据紊乱，为一种保险措施
  105.         List<UserAddress> list = userAddressMapper.select(queryAddress);
  106.         for (UserAddress ua : list) {
  107.             ua.setIsDefault(YesOrNo.NO.type);
  108.             userAddressMapper.updateByPrimaryKeySelective(ua);
  109.         }
  111.         //2.根据地址id修改为默认地址
  112.         UserAddress defaultAddress = new UserAddress();
  113.         defaultAddress.setId(addressId);
  114.         defaultAddress.setUserId(userId);
  115.         defaultAddress.setIsDefault(YesOrNo.YES.type);
  116.         userAddressMapper.updateByPrimaryKeySelective(defaultAddress);
  117.     }
  118. }

编写Controller

  1. package com.shiers.controller;
  3. import com.shiers.pojo.UserAddress;
  4. import com.shiers.pojo.bo.AddressBO;
  5. import com.shiers.service.AddressService;
  6. import com.shiers.utils.MobileEmailUtils;
  7. import com.shiers.utils.MyJSONResult;
  8. import io.swagger.annotations.Api;
  9. import io.swagger.annotations.ApiOperation;
  10. import org.apache.commons.lang3.StringUtils;
  11. import org.springframework.beans.factory.annotation.Autowired;
  12. import org.springframework.web.bind.annotation.*;
  13. import springfox.documentation.annotations.ApiIgnore;
  15. import java.util.List;
  17. /**
  18.  * Demo classO
  19.  *
  20.  * @author shierS
  21.  * @date 2021/5/21
  22.  */
  23. @Api(value = "地址相关" ,tags = {"地址相关API接口"})
  24. @RequestMapping("address")
  25. @RestController
  26. public class AddressController {
  28.     /**
  29.      * 用户在确认订单页面，可以针对收货地址做如下操作：
  30.      * 1、查询用户所有收货地址列表
  31.      * 2、新增地址
  32.      * 3、删除地址
  33.      * 4、修改地址
  34.      * 5、设置默认地址
  35.      */
  37.     @Autowired
  38.     private AddressService addressService;
  40.     @ApiOperation(value = "根据用户id查询收货地址列表",notes = "根据用户id查询收货地址列表",httpMethod = "POST")
  41.     @PostMapping("/list")
  42.     public MyJSONResult list(@RequestParam String userId){
  44.         if (StringUtils.isBlank(userId)){
  45.             return MyJSONResult.errorMsg("");
  46.         }
  48.         List<UserAddress> list = addressService.queryAll(userId);
  50.         return MyJSONResult.ok(list);
  51.     }
  53.     @ApiOperation(value = "用户新增地址",notes = "用户新增地址",httpMethod = "POST")
  54.     @PostMapping("/add")
  55.     public MyJSONResult add(@RequestBody AddressBO addressBO) {
  57.         MyJSONResult checkRes = checkAddress(addressBO);
  58.         if (checkRes.getStatus() != 200) {
  59.             return checkRes;
  60.         }
  62.         addressService.addNewUserAddress(addressBO);
  64.         return MyJSONResult.ok();
  65.     }
  67.     private MyJSONResult checkAddress(AddressBO addressBO) {
  68.         String receiver = addressBO.getReceiver();
  69.         if (StringUtils.isBlank(receiver)) {
  70.             return MyJSONResult.errorMsg("收货人不能为空");
  71.         }
  72.         if (receiver.length() > 12) {
  73.             return MyJSONResult.errorMsg("收货人姓名不能太长");
  74.         }
  76.         String mobile = addressBO.getMobile();
  77.         if (StringUtils.isBlank(mobile)) {
  78.             return MyJSONResult.errorMsg("收货人手机号不能为空");
  79.         }
  80.         if (mobile.length() != 11) {
  81.             return MyJSONResult.errorMsg("收货人手机号长度不正确");
  82.         }
  83.         boolean isMobileOk = MobileEmailUtils.checkMobileIsOk(mobile);
  84.         if (!isMobileOk) {
  85.             return MyJSONResult.errorMsg("收货人手机号格式不正确");
  86.         }
  88.         String province = addressBO.getProvince();
  89.         String city = addressBO.getCity();
  90.         String district = addressBO.getDistrict();
  91.         String detail = addressBO.getDetail();
  92.         if (StringUtils.isBlank(province) ||
  93.             StringUtils.isBlank(city) ||
  94.             StringUtils.isBlank(district) ||
  95.             StringUtils.isBlank(detail)) {
  96.             return MyJSONResult.errorMsg("收货地址信息不能为空");
  97.         }
  99.         return MyJSONResult.ok();
  100.     }
  102.     @ApiOperation(value = "用户修改地址",notes = "用户修改地址",httpMethod = "POST")
  103.     @PostMapping("/update")
  104.     public MyJSONResult update(@RequestBody AddressBO addressBO) {
  106.         if (StringUtils.isBlank(addressBO.getAddressId())){
  107.             return MyJSONResult.errorMsg("修改地址错误：addressId不能为空");
  108.         }
  110.         MyJSONResult checkRes = checkAddress(addressBO);
  111.         if (checkRes.getStatus() != 200) {
  112.             return checkRes;
  113.         }
  115.         addressService.updateUserAddress(addressBO);
  117.         return MyJSONResult.ok();
  118.     }
  120.     @ApiOperation(value = "用户删除地址",notes = "用户删除地址",httpMethod = "POST")
  121.     @PostMapping("/delete")
  122.     public MyJSONResult delete(
  123.         @RequestParam String userId,
  124.         @RequestParam String addressId) {
  126.         if (StringUtils.isBlank(userId) || StringUtils.isBlank(addressId) ){
  127.             return MyJSONResult.errorMsg("");
  128.         }
  130.         addressService.deleteUserAddress(userId,addressId);
  132.         return MyJSONResult.ok();
  133.     }
  135.     @ApiOperation(value = "用户设置默认地址",notes = "用户设置默认地址",httpMethod = "POST")
  136.     @PostMapping("/setDefalut")
  137.     public MyJSONResult setDefalut(
  138.         @RequestParam String userId,
  139.         @RequestParam String addressId) {
  141.         if (StringUtils.isBlank(userId) || StringUtils.isBlank(addressId) ){
  142.             return MyJSONResult.errorMsg("");
  143.         }
  145.         addressService.updateUserAddressToBeDefault(userId,addressId);
  147.         return MyJSONResult.ok();
  148.     }
  149. }