提交 e75671a2 编写于 作者: chenzhehao's avatar chenzhehao

fegin外部调用名称修改

上级 69969634
package com.pica.cloud.wechat.yunqueyilian.server.client;
import com.pica.cloud.foundation.entity.PicaResponse;
import com.pica.cloud.wechat.yunqueyilian.server.client.impl.UserServiceFailFactory;
import com.pica.cloud.wechat.yunqueyilian.server.client.impl.WechatsServiceFailFactory;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
......@@ -15,9 +15,9 @@ import java.util.Map;
* @Description:
* @date: 2018/8/9 13:15
*/
@FeignClient(value = "10102-PICA-CLOUD-WECHAT", fallbackFactory = UserServiceFailFactory.class)
@FeignClient(value = "10102-PICA-CLOUD-WECHAT", fallbackFactory = WechatsServiceFailFactory.class)
@RequestMapping(value = "/wechats", headers = "sysCode=21", produces = "application/json;charset=UTF-8")
public interface IUserServiceClient {
public interface IWechatsServiceClient {
@RequestMapping(method = RequestMethod.GET, value = "/users")
PicaResponse<Map<String, Object>> users(@RequestParam(value = "wechatName") String wechatName, @RequestParam(value = "openId") String openId);
}
......@@ -2,13 +2,12 @@ package com.pica.cloud.wechat.yunqueyilian.server.client.impl;
import com.pica.cloud.foundation.entity.PicaResponse;
import com.pica.cloud.foundation.entity.PicaResultCode;
import com.pica.cloud.wechat.yunqueyilian.server.client.IUserServiceClient;
import com.pica.cloud.wechat.yunqueyilian.server.client.IWechatsServiceClient;
import feign.hystrix.FallbackFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.Map;
/**
......@@ -18,19 +17,19 @@ import java.util.Map;
* @date: 2018/8/10 10:57
*/
@Component
public class UserServiceFailFactory implements FallbackFactory<IUserServiceClient> {
public static final Logger logger = LoggerFactory.getLogger(UserServiceFailFactory.class);
public class WechatsServiceFailFactory implements FallbackFactory<IWechatsServiceClient> {
public static final Logger logger = LoggerFactory.getLogger(WechatsServiceFailFactory.class);
@Override
public IUserServiceClient create(Throwable cause) {
public IWechatsServiceClient create(Throwable cause) {
PicaResponse response = (new PicaResponse.Builder<Map<String, Object>>()).build();
response.setCode(PicaResultCode.INTERFACE_INVOKE_ERROR.code());
response.setMessage(PicaResultCode.INTERFACE_INVOKE_ERROR.message());
return new IUserServiceClient() {
return new IWechatsServiceClient() {
@Override
public PicaResponse users(String wechatName, String openId) {
logger.error("service:IUserServiceClient interface:users 触发熔断机制fallback", cause);
logger.error("service:IWechatsServiceClient interface:users 触发熔断机制fallback", cause);
return response;
}
};
......
......@@ -7,7 +7,7 @@ import com.pica.cloud.foundation.utils.utils.StringUtil;
import com.pica.cloud.wechat.yunqueyilian.common.CommonUtils;
import com.pica.cloud.wechat.yunqueyilian.common.Constants;
import com.pica.cloud.wechat.yunqueyilian.common.req.TextMessage;
import com.pica.cloud.wechat.yunqueyilian.server.client.IUserServiceClient;
import com.pica.cloud.wechat.yunqueyilian.server.client.IWechatsServiceClient;
import com.pica.cloud.wechat.yunqueyilian.server.entity.PWechatUser;
import com.pica.cloud.wechat.yunqueyilian.server.mapper.PWechatUserMapper;
import com.pica.cloud.wechat.yunqueyilian.server.service.CoreService;
......@@ -30,7 +30,7 @@ public class CoreServiceImpl implements CoreService {
private static Logger logger = LoggerFactory.getLogger(CoreServiceImpl.class);
@Autowired
IUserServiceClient userServiceClient;
IWechatsServiceClient userServiceClient;
@Autowired
PWechatUserMapper wechatUserMapper;
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册