009 springboot整合mybatis-plus 增删改查 ajax 登录退出accessToken

package com.example.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.example.entity.ReceiveAddress; import com.example.mapper.ReceiveAddressMapper; import com.example.service.IReceiveAddressService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.example.util.ServerResult; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.time.LocalDateTime; import java.util.List; /** * <p> * 服务实现类 * </p> * * @author dd * @since 2024-04-10 */ @Service public class ReceiveAddressServiceImpl implements IReceiveAddressService { @Autowired private ReceiveAddressMapper addressMapper; @Override public ServerResult getById(Integer addressId) { ReceiveAddress address = addressMapper.selectById(addressId); if(address != null){ return ServerResult.getSuccess(address); } return ServerResult.getFail(null); } //当前登录用户的有效地址 @Override public ServerResult getAll(Integer customerId){ //select * from QueryWrapper<ReceiveAddress> wrapper = new QueryWrapper<>(); wrapper.eq("cust_id",customerId).eq("status",1); List<ReceiveAddress> addressList = addressMapper.selectList(wrapper);//select * from table_name where cust_id= and if(addressList == null || addressList.size()==0) return ServerResult.getFail("暂无收件地址"); return ServerResult.getSuccess(addressList); } //添加 public ServerResult save(ReceiveAddress receiveAddress){//receiveAddress: 没有addr_id receiveAddress.setStatus(1); receiveAddress.setVersion(1); receiveAddress.setCreateTime(LocalDateTime.now()); System.out.println("尚未添加，从页面拿到的收件地址是:" + receiveAddress); int rows = addressMapper.insert(receiveAddress); if(rows > 0){ System.out.println("添加成功后:" + receiveAddress); return ServerResult.updateSuccess(receiveAddress);//若添加成功，会把数据库中自增的主键addr_id赋值到对象上 } return ServerResult.updateFail(receiveAddress); } //删除收件地址(实际修改status为0) @Override public ServerResult removeById(Integer addressId) { ReceiveAddress address = addressMapper.selectById(addressId); address.setStatus(0); address.setVersion(address.getVersion() + 1); int rows = addressMapper.updateById(address);//删除成功row =1,删除失败row=0 if(rows > 0) return ServerResult.updateSuccess(address); return ServerResult.updateFail(address); } @Override public ServerResult updateById(ReceiveAddress address) { System.out.println("put service"); int oldVersion = addressMapper.selectById(address.getAddrId()).getVersion();//旧的version值来自db address.setUpdateTime(LocalDateTime.now()); address.setVersion(oldVersion+1); int rows = addressMapper.updateById(address); if(rows > 0){ return ServerResult.updateSuccess(address); } return ServerResult.updateFail(address); } @Override public ServerResult getByPage(Integer pageNum,Integer customerId) { //select * from address where cust_id = 1 and status = 1 limit 0,3 //select * from address where cust_id = 1 and status = 1 limit 3,3 //select * from address where cust_id = 1 and status = 1 limit 6,3 QueryWrapper<ReceiveAddress> wrapper = new QueryWrapper<>(); wrapper.eq("cust_id",customerId).eq("status",1); //page:只有页面的信息(当前页码、每页显示记录数) Page<ReceiveAddress> page = new Page<>(pageNum,3); //page:页码的信息+数据 page = addressMapper.selectPage(page,wrapper); if (page.getRecords().size() > 0){ return ServerResult.getSuccess(page); } return ServerResult.getFail(page); } @Override public ServerResult getByCustId(Integer custId) { QueryWrapper<ReceiveAddress> queryWrapper = new QueryWrapper<>(); queryWrapper.eq("cust_id",custId); List<ReceiveAddress> receiveAddressList = addressMapper.selectList(queryWrapper); if(receiveAddressList.size() >0) return ServerResult.getSuccess(receiveAddressList); return ServerResult.getFail(null); } }