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

Commit 45933bcc authored by 张国柄's avatar 张国柄

~API.kylin.inner.cache.member;

parent ba246dbe
......@@ -211,11 +211,11 @@ public class AdamMemberOrderAdminServiceImpl extends ServiceImpl<AdamMemberOrder
}
try {
String reqKylinUrl = serviceKylinUrl + "/inner/cache/member?uid=".concat(memberOrder.getUid());
String reqKylinUrl = serviceKylinUrl + "/inner/cache/member/".concat(memberOrder.getUid());
log.info("reqKylinUrl={}", reqKylinUrl);
HttpUtil.post(reqKylinUrl, CollectionUtil.linkedMultiValueMapStringString());
HttpUtil.get(reqKylinUrl, CollectionUtil.linkedMultiValueMapStringString());
} catch (Exception e) {
log.error("会员管理:会员订单:退款:同步Kylin会员缓存异常[UID={}]", memberOrder.getUid());
log.error("购买会员支付回调处理成功:同步Kylin会员缓存异常[UID={}]", memberOrder.getUid(), e);
}
LinkedMultiValueMap<String, String> linkedMultiValueMap = new LinkedMultiValueMap<>();
......
......@@ -389,9 +389,9 @@ public class AdamMemberOrderServiceImpl implements IAdamMemberOrderService {
);
try {
HttpUtil.post(serviceKylinUrl + "/inner/cache/member?uid=".concat(handleMemberOrderVo.getUid()), CollectionUtil.linkedMultiValueMapStringString());
HttpUtil.get(serviceKylinUrl + "/inner/cache/member/".concat(handleMemberOrderVo.getUid()), CollectionUtil.linkedMultiValueMapStringString());
} catch (Exception e) {
log.error("购买会员支付回调处理成功:同步Kylin会员缓存异常[UID={}]", handleMemberOrderVo.getUid());
log.error("购买会员支付回调处理成功:同步Kylin会员缓存异常[UID={}]", handleMemberOrderVo.getUid(), e);
}
return ResponseDto.success();
} catch (Exception e) {
......
......@@ -4,28 +4,23 @@ import com.fasterxml.jackson.core.type.TypeReference;
import com.liquidnet.commons.lang.util.CollectionUtil;
import com.liquidnet.commons.lang.util.HttpUtil;
import com.liquidnet.commons.lang.util.JsonUtils;
import com.liquidnet.service.adam.dto.vo.AdamEntersVo;
import com.liquidnet.service.adam.dto.vo.AdamUserMemberVo;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.feign.adam.api.FeignAdamBaseClient;
import com.liquidnet.service.kylin.utils.DataUtils;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.util.MultiValueMap;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import javax.validation.constraints.NotBlank;
import java.time.LocalDateTime;
import java.time.temporal.ChronoUnit;
import java.util.List;
@Api(tags = "内部接口")
@RestController
......@@ -37,14 +32,11 @@ public class InnerController {
@Value("${liquidnet.adam.url}")
private String adamUrl;
@PostMapping("cache/member")
@GetMapping("cache/member/{uid}")
@ApiOperation("获取会员相关数据")
@ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "uid", value = "会员id"),
})
public void cacheMember(@RequestParam("uid") String uid) {
public void cacheMember(@NotBlank @PathVariable(value = "uid") String uid) {
try {
log.info("同步 接口被调用");
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);
......
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