提交 83ccd672 authored 作者: cherishsince's avatar cherishsince

- 重新优化:RPC 调用,暂时只公开 getAddress 和 getDefaultAddress

上级 5733a56e
package cn.iocoder.mall.user.rpc.api; package cn.iocoder.mall.user.rpc.api;
import cn.iocoder.mall.user.rpc.request.user.UserAddressAddRequest; import cn.iocoder.common.framework.vo.CommonResult;
import cn.iocoder.mall.user.rpc.request.user.UserAddressUpdateRequest;
import cn.iocoder.mall.user.rpc.response.user.UserAddressResponse; import cn.iocoder.mall.user.rpc.response.user.UserAddressResponse;
import java.util.List;
/** /**
* 用户地址 RPC * 用户地址 RPC
* *
...@@ -14,15 +11,19 @@ import java.util.List; ...@@ -14,15 +11,19 @@ import java.util.List;
*/ */
public interface UserAddressRPC { public interface UserAddressRPC {
void addAddress(UserAddressAddRequest userAddressAddRequest); /**
* 获取 - 根据id获取用户地址
void updateAddress(UserAddressUpdateRequest userAddressUpdateRequest); *
* @param id
void removeAddress(Integer userId, Integer addressId); * @return
*/
List<UserAddressResponse> addressList(Integer userId); CommonResult<UserAddressResponse> getAddress(Integer id);
UserAddressResponse getAddress(Integer id); /**
* 获取 - 获取用户默认地址
UserAddressResponse getDefaultAddress(Integer userId); *
* @param userId
* @return
*/
CommonResult<UserAddressResponse> getDefaultAddress(Integer userId);
} }
package cn.iocoder.mall.user.rpc.convert.user; package cn.iocoder.mall.user.rpc.convert.user;
import cn.iocoder.mall.user.biz.bo.user.UserAddressBO; import cn.iocoder.mall.user.biz.bo.user.UserAddressBO;
import cn.iocoder.mall.user.biz.dto.user.UserAddressAddDTO;
import cn.iocoder.mall.user.biz.dto.user.UserAddressUpdateDTO;
import cn.iocoder.mall.user.rpc.request.user.UserAddressAddRequest;
import cn.iocoder.mall.user.rpc.request.user.UserAddressUpdateRequest;
import cn.iocoder.mall.user.rpc.response.user.UserAddressResponse; import cn.iocoder.mall.user.rpc.response.user.UserAddressResponse;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.Mappings; import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;
import java.util.List;
/** /**
* user address convert * user address convert
* *
...@@ -23,19 +17,7 @@ public interface UserAddressRPCConvert { ...@@ -23,19 +17,7 @@ public interface UserAddressRPCConvert {
UserAddressRPCConvert INSTANCE = Mappers.getMapper(UserAddressRPCConvert.class); UserAddressRPCConvert INSTANCE = Mappers.getMapper(UserAddressRPCConvert.class);
// TODO DONE FROM 芋艿 to 小范:如果不用映射,可以不用 @Mappings 哈
// TODO FROM 芋艿 to 小范:如果不用映射,可以不用 @Mappings 哈
@Mappings({})
UserAddressAddDTO convert(UserAddressAddRequest userAddressAddRequest);
@Mappings({})
UserAddressUpdateDTO convert(UserAddressUpdateRequest userAddressUpdateRequest);
@Mappings({}) @Mappings({})
UserAddressResponse convert(UserAddressBO userAddressBO); UserAddressResponse convert(UserAddressBO userAddressBO);
@Mappings({})
List<UserAddressResponse> convert(List<UserAddressBO> addressBOS);
} }
package cn.iocoder.mall.user.rpc.rpc.user; package cn.iocoder.mall.user.rpc.rpc.user;
import cn.iocoder.common.framework.vo.CommonResult;
import cn.iocoder.mall.user.biz.service.user.UserAddressService; import cn.iocoder.mall.user.biz.service.user.UserAddressService;
import cn.iocoder.mall.user.rpc.api.UserAddressRPC; import cn.iocoder.mall.user.rpc.api.UserAddressRPC;
import cn.iocoder.mall.user.rpc.convert.user.UserAddressRPCConvert; import cn.iocoder.mall.user.rpc.convert.user.UserAddressRPCConvert;
import cn.iocoder.mall.user.rpc.request.user.UserAddressAddRequest;
import cn.iocoder.mall.user.rpc.request.user.UserAddressUpdateRequest;
import cn.iocoder.mall.user.rpc.response.user.UserAddressResponse; import cn.iocoder.mall.user.rpc.response.user.UserAddressResponse;
import org.apache.dubbo.config.annotation.Service; import org.apache.dubbo.config.annotation.Service;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import java.util.List; /**
* 用户地址 RPC
*
* author: sin
* time: 2020/5/1 10:26 上午
*/
@Service(version = "${dubbo.provider.UserAddressRPC.version}", validation = "true") @Service(version = "${dubbo.provider.UserAddressRPC.version}", validation = "true")
public class UserAddressRPCImpl implements UserAddressRPC { public class UserAddressRPCImpl implements UserAddressRPC {
...@@ -18,32 +21,12 @@ public class UserAddressRPCImpl implements UserAddressRPC { ...@@ -18,32 +21,12 @@ public class UserAddressRPCImpl implements UserAddressRPC {
private UserAddressService userAddressService; private UserAddressService userAddressService;
@Override @Override
public void addAddress(UserAddressAddRequest userAddressAddRequest) { public CommonResult<UserAddressResponse> getAddress(Integer id) {
userAddressService.addAddress(UserAddressRPCConvert.INSTANCE.convert(userAddressAddRequest)); return CommonResult.success(UserAddressRPCConvert.INSTANCE.convert(userAddressService.getAddress(id)));
}
@Override
public void updateAddress(UserAddressUpdateRequest userAddressUpdateRequest) {
userAddressService.updateAddress(UserAddressRPCConvert.INSTANCE.convert(userAddressUpdateRequest));
}
@Override
public void removeAddress(Integer userId, Integer addressId) {
userAddressService.removeAddress(userId, addressId);
}
@Override
public List<UserAddressResponse> addressList(Integer userId) {
return UserAddressRPCConvert.INSTANCE.convert(userAddressService.listAddress(userId));
}
@Override
public UserAddressResponse getAddress(Integer id) {
return UserAddressRPCConvert.INSTANCE.convert(userAddressService.getAddress(id));
} }
@Override @Override
public UserAddressResponse getDefaultAddress(Integer userId) { public CommonResult<UserAddressResponse> getDefaultAddress(Integer userId) {
return UserAddressRPCConvert.INSTANCE.convert(userAddressService.getDefaultAddress(userId)); return CommonResult.success(UserAddressRPCConvert.INSTANCE.convert(userAddressService.getDefaultAddress(userId)));
} }
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论