~opt;

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/InnerController.java

@@ -36,27 +36,29 @@ public class InnerController {
     @ApiOperation("获取会员相关数据")
     public void cacheMember(@NotBlank @PathVariable(value = "uid") String uid) {
         try {
-            log.info("同步 接口被调用,uid={}", uid);
             MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
             header.add("Accept", "application/json;charset=UTF-8");
             String returnData = HttpUtil.get(adamUrl + "/adam/rsc/inquire/member?uid=" + uid, null, header);
-            ResponseDto<AdamUserMemberVo> memberVo = JsonUtils.fromJson(returnData, new TypeReference<ResponseDto<AdamUserMemberVo>>() {
+            ResponseDto<AdamUserMemberVo> responseDto = JsonUtils.fromJson(returnData, new TypeReference<ResponseDto<AdamUserMemberVo>>() {
             });
-            log.info("调用 user = "+returnData);
-            AdamUserMemberVo userMemberVo = memberVo.getData();
-            if (userMemberVo.getState() == 1) {
-                long second = ChronoUnit.SECONDS.between(LocalDateTime.now(), userMemberVo.getExpiryAt());
-                log.debug("过期时间="+second);
-                if (userMemberVo.isOldMember()) {
-                    dataUtils.saveMember(uid, 2, second);
-                } else {
-                    dataUtils.saveMember(uid, 1, second);
+            if (null != responseDto) {
+                AdamUserMemberVo userMemberVo = responseDto.getData();
+                if (null != userMemberVo) {
+                    if (userMemberVo.getState() == 1) {
+                        long second = ChronoUnit.SECONDS.between(LocalDateTime.now(), userMemberVo.getExpiryAt());
+                        log.debug("过期时间="+second);
+                        if (userMemberVo.isOldMember()) {
+                            dataUtils.saveMember(uid, 2, second);
+                        } else {
+                            dataUtils.saveMember(uid, 1, second);
+                        }
+                    } else {
+                        dataUtils.delMember(uid);
+                    }
                 }
-            } else {
-                dataUtils.delMember(uid);
             }
         } catch (Exception e) {
-            log.error("会员信息error", e);
+            log.error("会员信息error[uid={}]", uid, e);
         }
     }