package com.iotechn.unimall.app.api.address;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.dobbinsoft.fw.core.exception.AppServiceException;
|
import com.dobbinsoft.fw.core.exception.ServiceException;
|
import com.iotechn.unimall.data.domain.AddressDO;
|
import com.iotechn.unimall.data.exception.ExceptionDefinition;
|
import com.iotechn.unimall.data.mapper.AddressMapper;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.Date;
|
import java.util.List;
|
|
/*
|
@author kbq
|
@date 2019/7/4 - 22:07
|
*/
|
@Service
|
public class AddressServiceImpl implements AddressService {
|
|
@Autowired
|
private AddressMapper addressMapper;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public String create(String province, String city, String county, String address, Integer defaultAddress, Long userId, String phone, String consignee) throws ServiceException {
|
Integer addressCount = addressMapper.selectCount(new QueryWrapper<AddressDO>().eq("user_id", userId));
|
AddressDO addressDO = new AddressDO();
|
addressDO.setProvince(province);
|
addressDO.setCity(city);
|
addressDO.setCounty(county);
|
addressDO.setAddress(address);
|
addressDO.setUserId(userId);
|
addressDO.setPhone(phone);
|
addressDO.setConsignee(consignee);
|
if (addressCount == 0) {
|
// 若没有地址，把当前增加的地址设为默认地址
|
addressDO.setDefaultAddress(1);
|
} else {
|
// 若有地址
|
if (defaultAddress != 0) {
|
// 若这个地址需要是默认地址，则将其他的地址设置为非默认状态
|
AddressDO preDefault = new AddressDO();
|
preDefault.setDefaultAddress(0);
|
addressMapper.update(preDefault, new QueryWrapper<AddressDO>()
|
.eq("user_id", userId)
|
.eq("default_address", 1));
|
addressDO.setDefaultAddress(1);
|
} else {
|
addressDO.setDefaultAddress(0);
|
}
|
}
|
Date now = new Date();
|
addressDO.setGmtCreate(now);
|
addressDO.setGmtUpdate(now);
|
if (addressMapper.insert(addressDO) > 0) {
|
return "ok";
|
}
|
throw new AppServiceException(ExceptionDefinition.ADDRESS_DATABASE_QUERY_FAILED);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public String delete(Long addressId, Long userId) throws ServiceException {
|
Integer defaultNum = addressMapper.selectCount(new QueryWrapper<AddressDO>()
|
.eq("user_id", userId)
|
.eq("id", addressId)
|
.eq("default_address", 1));
|
if (defaultNum == 0) {
|
// 若不是默认地址，则直接删除
|
if (addressMapper.delete(new QueryWrapper<AddressDO>()
|
.eq("id", addressId)
|
.eq("user_id", userId)) > 0) {
|
return "ok";
|
}
|
throw new AppServiceException(ExceptionDefinition.ADDRESS_DATABASE_QUERY_FAILED);
|
} else {
|
// 若是默认地址，需要将其他1个设置为默认地址
|
if (addressMapper.delete(new QueryWrapper<AddressDO>()
|
.eq("id", addressId)
|
.eq("user_id", userId)) <= 0) {
|
throw new AppServiceException(ExceptionDefinition.ADDRESS_DATABASE_QUERY_FAILED);
|
} else {
|
List<AddressDO> addressDOS = addressMapper.selectList(new QueryWrapper<AddressDO>().eq("user_id", userId));
|
if (!CollectionUtils.isEmpty(addressDOS)) {
|
AddressDO addressDO = addressDOS.get(0);
|
addressDO.setDefaultAddress(1);
|
if (addressMapper.updateById(addressDO) > 0) {
|
return "ok";
|
}
|
}
|
throw new AppServiceException(ExceptionDefinition.ADDRESS_DATABASE_QUERY_FAILED);
|
}
|
}
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public String edit(Long addressId, String province, String city, String county, String address, Integer defaultAddress, Long userId, String phone, String consignee) throws ServiceException {
|
AddressDO addressDO = new AddressDO();
|
addressDO.setProvince(province);
|
addressDO.setCity(city);
|
addressDO.setCounty(county);
|
addressDO.setAddress(address);
|
addressDO.setUserId(userId);
|
addressDO.setPhone(phone);
|
addressDO.setConsignee(consignee);
|
addressDO.setDefaultAddress(defaultAddress);
|
Date now = new Date();
|
if (defaultAddress != 0) {
|
defaultAddress = 1;
|
// 将所有地址更新为非默认
|
AddressDO updateAddressDO = new AddressDO();
|
updateAddressDO.setDefaultAddress(0);
|
addressMapper.update(updateAddressDO, new QueryWrapper<AddressDO>().eq("user_id", userId));
|
}
|
addressDO.setDefaultAddress(defaultAddress);
|
addressDO.setGmtUpdate(now);
|
if (addressMapper.update(addressDO,
|
new QueryWrapper<AddressDO>()
|
.eq("id", addressId)
|
.eq("user_id", userId)) > 0) {
|
return "ok";
|
}
|
throw new AppServiceException(ExceptionDefinition.ADDRESS_DATABASE_QUERY_FAILED);
|
}
|
|
@Override
|
public List<AddressDO> list(Long userId) throws ServiceException {
|
return addressMapper.selectList(new QueryWrapper<AddressDO>()
|
.eq("user_id", userId));
|
}
|
|
@Override
|
public AddressDO getAddressById(Long userId, Long addressId) throws ServiceException {
|
return addressMapper.selectOne(
|
new QueryWrapper<AddressDO>()
|
.eq("id", addressId)
|
.eq("user_id", userId));
|
}
|
|
@Override
|
public AddressDO getDefAddress(Long userId) throws ServiceException {
|
List<AddressDO> addressDOS = addressMapper.selectList(
|
new QueryWrapper<AddressDO>()
|
.eq("user_id", userId)
|
.eq("default_address", 1));
|
if (CollectionUtils.isEmpty(addressDOS)) {
|
AddressDO addressDO = new AddressDO();
|
addressDO.setCity("XXX");
|
addressDO.setProvince("XXX");
|
addressDO.setCounty("XXX");
|
addressDO.setAddress("请点击此处完善收货地址");
|
addressDO.setConsignee("匿名");
|
addressDO.setPhone("XXXXXXXXXXX");
|
return addressDO;
|
} else {
|
return addressDOS.get(0);
|
}
|
}
|
|
}
|
