记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 37d632b9 authored by 胡佳晨's avatar 胡佳晨
Browse files
Options

修改 config 和 adam的redis

parent 864d64ed
Show whitespace changes
Inline Side-by-side
Showing with 17 additions and 8 deletions
liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/utils/OrderUtils.java
View file @ 37d632b9
...@@ -27,6 +27,8 @@ public class OrderUtils { ...@@ -27,6 +27,8 @@ public class OrderUtils {
private DataUtils dataUtils; private DataUtils dataUtils;
@Value("${liquidnet.adam.url}") @Value("${liquidnet.adam.url}")
private String adamUrl; private String adamUrl;
@Autowired
private RedisUtil redisUtil;
public String judgeOrderLimit( public String judgeOrderLimit(
int type, int type,
...@@ -117,23 +119,30 @@ public class OrderUtils { ...@@ -117,23 +119,30 @@ public class OrderUtils {
} }
public boolean isMember(String uid) { public boolean isMember(String uid) {
String resultData = HttpUtil.get("/adam/member/check/depth?uid=" + uid, null); // String resultData = HttpUtil.get("/adam/member/check/depth?uid=" + uid, null);
AdamUserMemberVo vo = JsonUtils.fromJson(resultData, AdamUserMemberVo.class); // AdamUserMemberVo vo = JsonUtils.fromJson(resultData, AdamUserMemberVo.class);
String rk = AdamRedisConst.INFO_USER_MEMBER.concat(uid);
AdamUserMemberVo vo = (AdamUserMemberVo) redisUtil.get(rk);
return null != vo && vo.isActive(); return null != vo && vo.isActive();
} }
public AdamAddressesVo getAddress(String uid, String addressesId) { public AdamAddressesVo getAddress(String uid, String addressesId) {
String resultData = HttpUtil.get("/adam/addr/query/depth?uid=" + uid + "&addrId=" + addressesId, null); // String resultData = HttpUtil.get("/adam/addr/query/depth?uid=" + uid + "&addrId=" + addressesId, null);
List<AdamAddressesVo> vos = JsonUtils.fromJson(resultData, new TypeReference<List<AdamAddressesVo>>() { // List<AdamAddressesVo> vos = JsonUtils.fromJson(resultData, new TypeReference<List<AdamAddressesVo>>() {
}); // });
String rk = AdamRedisConst.INFO_ADDRESSES.concat(uid);
List<AdamAddressesVo> vos = (List<AdamAddressesVo>) redisUtil.get(rk);
return vos.stream().filter(r -> r.getAddressesId().equals(addressesId)).findAny().orElse(null); return vos.stream().filter(r -> r.getAddressesId().equals(addressesId)).findAny().orElse(null);
} }
public AdamEntersVo getEnters(String uid, String entersId) { public AdamEntersVo getEnters(String uid, String entersId) {
String resultData = HttpUtil.get("/adam/enters/query/depth?uid=" + uid + "&entersId=" + entersId, null); // String resultData = HttpUtil.get("/adam/enters/query/depth?uid=" + uid + "&entersId=" + entersId, null);
List<AdamEntersVo> vos = JsonUtils.fromJson(resultData, new TypeReference<List<AdamEntersVo>>() { // List<AdamEntersVo> vos = JsonUtils.fromJson(resultData, new TypeReference<List<AdamEntersVo>>() {
}); // });
String rk = AdamRedisConst.INFO_ENTERS.concat(uid);
List<AdamEntersVo> vos = (List<AdamEntersVo>) redisUtil.get(rk);
return vos.stream().filter(r -> r.getEntersId().equals(entersId)).findAny().orElse(null); return vos.stream().filter(r -> r.getEntersId().equals(entersId)).findAny().orElse(null);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment