糊涂工具类真是场景下请求http接口的案例

举报
穆雄雄 发表于 2022/12/06 20:17:15 2022/12/06
【摘要】 大家好,我是雄雄,欢迎关注微信公众号:雄雄的小课堂现在是:2022年7月7日13:46:07 前言今天有个这样的需求,PC端需要查看一下哪些天有数据,但是哪些有有没有数据我这边还看不出来,得请求别的系统的接口去看。且团组和会员请求的接口和请求方式均不一样。前端说为了方便,团组和个人都走一个接口吧,让我这边封装一下…… 实现 如何区分前台请求的是会员的还是团组的让前台这样传,如果不传group...

大家好,我是雄雄,欢迎关注微信公众号:雄雄的小课堂

现在是:2022年7月7日13:46:07

前言

今天有个这样的需求,PC端需要查看一下哪些天有数据,但是哪些有有没有数据我这边还看不出来,得请求别的系统的接口去看。且团组和会员请求的接口和请求方式均不一样。
前端说为了方便,团组和个人都走一个接口吧,让我这边封装一下……

实现

如何区分前台请求的是会员的还是团组的

让前台这样传,如果不传groupId,传memberId,则我就知道了,请求的是查询会员的信息。反之则请求的是团组的接口。
代码如下:

	if(Strings.isNotBlank(groupId)){
			//是团组
			//查询这个团组下面的人
			LambdaQueryWrapper<GroupUser> groupUserLambdaQueryWrapper = new LambdaQueryWrapper<>();
			groupUserLambdaQueryWrapper.eq(GroupUser::getGroupId, groupId);
			List<GroupUser> groupUserList = groupUserService.list(groupUserLambdaQueryWrapper);
			List<Long> userList = new ArrayList<>();
			groupUserList.forEach(group->{
				userList.add(group.getUserId());
			});
			//集合去重
			List<Long> memberIdList =
				userList
					.stream()
					.distinct()
					.collect(Collectors.toList());
			url = ServicePathConstant.HBV_GATAWAY+"/doctor/api/doctor/getMemberDataDays";
			body = HttpUtil.createPost(url)
				.contentType("application/json")
				.body(JSON.toJSONString(memberIdList)).execute().body();
		}else if(Strings.isNotBlank(memberId)){
			//是会员
			url = ServicePathConstant.HBV_GATAWAY+"/doctor/api/doctor/getMemberDataDays/"+memberId;
			body = HttpUtil.createGet(url).execute().body();
		}

里面涉及到了些别的代码,集合去重:

	//集合去重
			List<Long> memberIdList =
				userList
					.stream()
					.distinct()
					.collect(Collectors.toList());

还别说,这个地方用的还挺多的,不过每次用到了之后都是翻之前的代码。。。。。

完整代码如下:

	/**
	 * 获取有日期的报告吗,返回一个集合
	 * @param groupId
	 * @return
	 */
	@GetMapping("/getReportHaveDateList")
	public Object getReportHaveDateList(String groupId,String memberId) {
		cn.hutool.json.JSONObject jsonObjectResult = new cn.hutool.json.JSONObject();
		//请求接口地址
		String url = "";
		String body = "";
		if(Strings.isNotBlank(groupId)){
			//是团组
			//查询这个团组下面的人
			LambdaQueryWrapper<GroupUser> groupUserLambdaQueryWrapper = new LambdaQueryWrapper<>();
			groupUserLambdaQueryWrapper.eq(GroupUser::getGroupId, groupId);
			List<GroupUser> groupUserList = groupUserService.list(groupUserLambdaQueryWrapper);
			List<Long> userList = new ArrayList<>();
			groupUserList.forEach(group->{
				userList.add(group.getUserId());
			});
			//集合去重
			List<Long> memberIdList =
				userList
					.stream()
					.distinct()
					.collect(Collectors.toList());
			url = ServicePathConstant.HBV_GATAWAY+"/doctor/api/doctor/getMemberDataDays";
			body = HttpUtil.createPost(url)
				.contentType("application/json")
				.body(JSON.toJSONString(memberIdList)).execute().body();
		}else if(Strings.isNotBlank(memberId)){
			//是会员
			url = ServicePathConstant.HBV_GATAWAY+"/doctor/api/doctor/getMemberDataDays/"+memberId;
			body = HttpUtil.createGet(url).execute().body();
		}
		if (StringUtils.isBlank(body)) {
			jsonObjectResult.putOpt("code", 500);
			jsonObjectResult.putOpt("data", null);
			jsonObjectResult.putOpt("msg", "操作失败");
			return jsonObjectResult;
		}
		cn.hutool.json.JSONObject obj = JSONUtil.parseObj(body);
		if (obj == null) {
			jsonObjectResult.putOpt("code", 500);
			jsonObjectResult.putOpt("data", null);
			jsonObjectResult.putOpt("msg", "操作失败");
			return jsonObjectResult;
		}
		String code = obj.get("code").toString();
		String msg = obj.get("msg").toString();
		System.out.println("调用doctor系统返回的信息:"+msg);
		if ("200".equals(code)) {
			jsonObjectResult.putOpt("code", 200);
			jsonObjectResult.putOpt("data", obj.get("data"));
			jsonObjectResult.putOpt("msg", "操作成功");
			//标记有没有记录
			jsonObjectResult.putOpt("count", obj.getJSONArray("data").size());
			return jsonObjectResult;
		}else{
			jsonObjectResult.putOpt("code", 200);
			jsonObjectResult.putOpt("data", new ArrayList<String>());
			jsonObjectResult.putOpt("msg", "操作成功");
			//标记有没有记录
			jsonObjectResult.putOpt("count", 0);
			return jsonObjectResult;
		}
	}

顺便在记录一下糊涂工具类请求接口的几种方式吧:

  1. post方法form传参:
	//接口地址
	String url = "";
	//请求参数
	Map<String, Object> paramMap = new HashMap<>();
	map.put("groupId", "1506254142554785");
	//请求头
	HashMap<String, String> headers = new HashMap<>();
	headers.put("Authorization", token);
	String result= HttpUtil.createPost(url).addHeaders(headers).form(map).execute().body();

  1. post方法json传参:
	//接口地址
	String url = "";
	//请求参数
	Map<String, Object> paramMap = new HashMap<>();
	map.put("groupId", "1506254142554785");
	//请求头
	HashMap<String, String> headers = new HashMap<>();
	headers.put("Authorization", token);
	String body = HttpUtil.createPost(url)
				.contentType("application/json")
				.body(JSON.toJSONString(projectVo)).execute().body();

projectVo就是一个json格式的数据。

  1. get方法form传参:
	//接口地址
	String url = "";
	//请求参数
	Map<String, Object> paramMap = new HashMap<>();
	map.put("groupId", "1506254142554785");
	//请求头
	HashMap<String, String> headers = new HashMap<>();
	headers.put("Authorization", token);
	String body = HttpUtil.createGet(url).header("Authorization", token).form(paramMap).execute().body();

这就是今天分享的内容,谢谢大家的捧场!!!

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。