java中复杂业务情况下的集合操作（增减集合同步数据）

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

现在是：2022年7月5日16:14:28

前言

今天分享个案例，需求是这样的：一个团组中是可以包含多个会员，在给团组创建训练方案时，本质上是给每个会员分别制定了一套训练方案。那么会有个问题，比如创建一个团组A，里面有会员1，会员2，会员3，然后给团组A创建了个方案，那么对应的三个会员都有训练方案，此时，将会员4拉到团组A中，此时会员4是没有任何方案的，所以我们现在要做的就是将会员4也同步上团组A的方案。

思路

在给团组新建完方案之后，通过团组管理是可以对该团组中的成员增加或者减少的，就像微信群聊一样，既可以重新邀人，也可以踢人出去。只是我们的业务里面加入了方案的概念。

新加的人就需要同步训练方案，删除的人就需要删掉他的方案，这个地方我是这样处理的：

  1. 通过java中集合的方法，找出哪些是新加的人，哪些是减去的人。
  2. 将团组和两个集合（新加的人的集合和减少的人的集合）传入到处理方案的方法中去操作
  3. 涉及到两个系统，一个是我方系统，一个是训练方案系统，并且都是我写的，所以接口操作起来就比较方便。

具体代码

团组管理

		/*** 修改团组 团组里面编辑成员时，更新对应的训练方案*/@PostMapping("/updateGroup")@ApiOperationSupport(order = 2)@ApiOperation(value = "app-新增团组", notes = "传入teamGroup")public R updateGroup(@RequestBody TeamGroup teamGroup) {//1.先把原来的人放在一个集合中List<Long> userListOld = new ArrayList<>();LambdaQueryWrapper<GroupUser> groupUserLambdaQueryWrapper = new LambdaQueryWrapper<>();groupUserLambdaQueryWrapper.eq(GroupUser::getGroupId, teamGroup.getId());//集合去重List<GroupUser> groupUserList =groupUserService.list(groupUserLambdaQueryWrapper).stream().distinct().collect(Collectors.toList());for (GroupUser groupUser : groupUserList) {//将原来的用户添加到这个集合中userListOld.add(groupUser.getUserId());}//拿到人员集合，把关联表中的数据，根据团组id把之前的数据都删掉，//然后再重新添加新获得的人员集合.groupUserService.remove(groupUserLambdaQueryWrapper);//2.将新更新过来的人放在一个集合中List<Long> userListNew = new ArrayList<>();if (teamGroup.getUserIds() != null && !"".equals(teamGroup.getUserIds())) {userListNew = CommonUtil.transLongList(teamGroup.getUserIds());//设置团组人数teamGroup.setNumPeople(userListNew.size());//把人员和团组在关联表中维护起来.for (int i = 0; i < userListNew.size(); i++) {GroupUser groupUser = new GroupUser();groupUser.setGroupId(teamGroup.getId());User user = userService.getUserById(userListNew.get(i));groupUser.setUserId(user.getId());groupUser.setUserName(user.getName());groupUser.setIsDeleted(0);groupUserService.save(groupUser);}}//3.两个集合比较哪些是新增的，哪些是删除的//新增的会员List<Long> userListAdd = new ArrayList<>(userListNew);userListAdd.removeAll(userListOld);//输出集合中的元素System.out.println("新增了的会员：");userListAdd.forEach(System.out::println);//删除了的会员List<Long> userListDel = new ArrayList<>(userListOld);userListDel.removeAll(userListNew);//输出集合中的元素System.out.println("删除了的会员：");userListDel.forEach(System.out::println);//传给训练方案系统，团组id,要删除的会员集合，要新增的会员集合--2022年7月5日13:56:15 updateer:穆雄雄R r = trainingSchemeUrlService.updateProgrammeByGroupIdAndOldUserIdAndNewUserId(teamGroup.getId(),userListAdd,userListDel);if(r.getCode()!=200){return R.fail("同步团组训练方案失败");}//更新团组的基础信息return R.status(teamGroupService.updateById(teamGroup));}

代码中基本都有注释，下面我来分析一下关键的代码，比较两个集合中哪些是新增的，哪些是删除的？

	//新增的会员List<Long> userListAdd = new ArrayList<>(userListNew);userListAdd.removeAll(userListOld);//输出集合中的元素System.out.println("新增了的会员：");userListAdd.forEach(System.out::println);//删除了的会员List<Long> userListDel = new ArrayList<>(userListOld);userListDel.removeAll(userListNew);//输出集合中的元素System.out.println("删除了的会员：");userListDel.forEach(System.out::println);

接下来就是在本系统中调用训练方案系统的同步方案接口了，具体代码如下：

Service接口层：

		/*** 团组更新成员时，方案也跟着同步* @param* @param* @param* @return*/R  updateProgrammeByGroupIdAndOldUserIdAndNewUserId(Long groupId, List<Long> userListAdd, List<Long>userListDel);

ServiceImpl实现类：

	@Overridepublic R updateProgrammeByGroupIdAndOldUserIdAndNewUserId(Long groupId, List<Long> userListAdd, List<Long> userListDel) {//请求接口地址String url = TrainingSchemeConstant.updateProgrammeByGroupIdAndOldUserIdAndNewUserId;JSONObject jsonObject = new JSONObject();jsonObject.putOpt("groupId", groupId);jsonObject.putOpt("userListAdd", userListAdd);jsonObject.putOpt("userListDel", userListDel);try {String body = HttpRequest.post(url).header("Content-Type", "application/json").body(jsonObject.toString()).execute().body();if (StringUtils.isBlank(body)) {return R.fail("操作失败");}JSONObject obj = JSONUtil.parseObj(body);if (obj == null) {return R.fail("操作失败");}String code = obj.get("code").toString();if ("200".equals(code)) {return R.success("操作成功");}} catch (Exception e) {e.printStackTrace();}return null;}

接口地址工具类：

	/*** 根据会员Id 状态 时间,查询所有动作*/public String updateProgrammeByGroupIdAndOldUserIdAndNewUserId = TRAINING_PROGRAMME+"/api/trainingprogramev3/updateProgrammeByGroupIdAndOldUserIdAndNewUserId";

训练方案系统中同步团组方案

	/*** 根据团组id，新老用户的id编辑方案* 2022年5月31日22:16:01* 穆雄雄** @return*/@PostMapping(value = "/updateProgrammeByGroupIdAndOldUserIdAndNewUserId")public String updateProgrammeByGroupIdAndOldUserIdAndNewUserId(@RequestBody GroupUpdateUser groupUpdateUser) {JSONObject jsonObject = new JSONObject();if (groupUpdateUser.getGroupId() == null) {jsonObject.put("code", 500);jsonObject.put("success", false);jsonObject.put("msg", "团组id不能为空");}//先从redis里面取一下，如果redis里面没有的话，就执行下面的内容Map<String, Object> programmeMap = bladeRedis.get("createGroupProgramme:" + groupUpdateUser.getGroupId());System.out.println("团组在编辑会员的时候，redis中的数据是：" + programmeMap);Programme programme = null;TeamGroup teamGroup = null;//方案的集合List<Programme> programmeList = new ArrayList<>();//时间戳Long timechuo = null;//缓存里面没有QueryWrapper<TeamGroup> teamGroupQueryWrapper = new QueryWrapper<>();teamGroupQueryWrapper.eq("group_id", groupUpdateUser.getGroupId()).orderByDesc("id").last("limit 1");teamGroup = teamGroupService.getOne(teamGroupQueryWrapper);//判断如果缓存里面没有的话，查询一下实际的if (programmeMap == null) {//没有方案的话if (teamGroup == null) {jsonObject.put("code", 200);jsonObject.put("success", true);jsonObject.put("msg", "操作成功");return jsonObject.toJSONString();}//将peibeizhu的值修改一下//根据方案的id查询出来方案信息programme = programmeService.getById(teamGroup.getProgrammeId());timechuo = programme.getTimechuo();System.out.println("编辑方案时，redis缓存里面没有数据");}else{//获取缓存中的时间戳timechuo = (Long) programmeMap.get("timechuo");System.out.println("编辑方案时，redis缓存里面有数据");}//aid的集合，最后放在pbeizhu里面去List<Long> pBeiZhuAidList = new ArrayList<>();//根据时间戳查询出所有方案LambdaQueryWrapper<Programme> programmeLambdaQueryWrapper = new LambdaQueryWrapper<>();programmeLambdaQueryWrapper.eq(Programme::getTimechuo, timechuo);List<Programme> programmeListByTimeChuo = programmeService.list(programmeLambdaQueryWrapper);programmeListByTimeChuo.forEach(pro -> {//重新赋值pbeizhu的值pBeiZhuAidList.add(pro.getPaid());programmeList.add(pro);});//运动员主键id集合List<Long> aidList = new ArrayList<>();//同步一下新加的用户信息if (groupUpdateUser.getUserListAdd().size() > 0) {for (Long aid : groupUpdateUser.getUserListAdd()) {Athletes athletes = new Athletes();LambdaQueryWrapper<Athletes> athletesLambdaQueryWrapper = new LambdaQueryWrapper<>();athletesLambdaQueryWrapper.eq(Athletes::getWorkcode, aid);List<Athletes> athleteList = athletesService.list(athletesLambdaQueryWrapper);if (athleteList.size() > 0) {//找到了athletes = athleteList.get(0);} else {//没有找到athletes.setAname(aid.toString());athletes.setWorkcode(aid.toString());athletesService.save(athletes);}aidList.add(athletes.getId());}}//加上了的成员for (Long aid : aidList) {//根据时间戳和用户id查询方案，有则添加，无则不用LambdaQueryWrapper<Programme> programmeWrapper = new LambdaQueryWrapper<>();programmeWrapper.eq(Programme::getPaid, aid).eq(Programme::getTimechuo, timechuo).last("limit 1");List<Programme> programmeQueryList = programmeService.list(programmeWrapper);if (programmeQueryList.size() == 0) {if(programme==null){programme = programmeList.get(0);}//远动员主键programme.setPaid(aid);//是否是团组方案 0是 1 不是programme.setIsGroupProgramme(0);//给用户保存方案programmeService.save(programme);}}//将运动员的主键拿到放在集合里面（删除方案）--暂时先不删除了。因为怕误删掉个人的方案 2022年7月4日21:23:19if (groupUpdateUser.getUserListDel().size() > 0) {//删除了的成员for (Long uid : groupUpdateUser.getUserListDel()) {//去运动员表卡里面查询这个人的编号LambdaQueryWrapper<Athletes> athletesLambdaQueryWrapper = new LambdaQueryWrapper<>();athletesLambdaQueryWrapper.select(Athletes::getId).eq(Athletes::getWorkcode, uid).last("limit 1");Athletes athletes = athletesService.getOne(athletesLambdaQueryWrapper);if (athletes != null) {//（遗留了bug，如果这个人正好是这个团组的最后一个方案的话，删掉之后，会导致团组和方案关联表中的方案id在方案里面找不到）//将方案表中的paid是这个人的都删掉Map<String, Object> map = new HashMap<>();map.put("paid", athletes.getId());map.put("timechuo", programme.getTimechuo());//map.put("is_group_programme",0);//物理删除programmeService.delProgrammeByAid(map);}}}//把集合中的String pbeizhu = StringUtils.join(pBeiZhuAidList, ",");programmeListByTimeChuo.forEach(pro -> {//重新赋值pbeizhu的值pro.setPbeizhu(pbeizhu);//修改pbiezhu的信息programmeService.updateById(pro);});//重新修改团组和方案关联表的方案idif (programmeList.size() > 0) {//将最后一个方案的Id修改到teamGroup.setProgrammeId(programmeList.get(programmeList.size() - 1).getId().longValue());teamGroupService.updateById(teamGroup);}jsonObject.put("code", 200);jsonObject.put("success", true);jsonObject.put("msg", "操作成功");return jsonObject.toJSONString();}

代码中使用了redis，刚开始将方案的信息放在了redis中，在操作方案的时候先从redis中取，如果缓存中没有，则从库里面查询，如果有，则直接使用。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/323578.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

springboot整合spring @Cache和Redis

springboot整合spring @Cache和Redis

转载自 springboot整合spring Cache和Redis spring基于注解的缓存 对于缓存声明&#xff0c;spring的缓存提供了一组java注解: Cacheable:触发缓存写入。CacheEvict:触发缓存清除。CachePut:更新缓存(不会影响到方法的运行)。Caching:重新组合要应用于方法的多个缓存操作。…
阅读更多...
段落分开

段落分开

分三段 <!DOCTYPE html> <html><head></head><body><p>This is a paragraph.</p> <p>This is another paragraph.</p> <p>这是网页设计中定义段落的标记&#xff0c;称为开始标记&#xff0c;称为结束标记。把一…
阅读更多...
辞旧迎新，新工作感悟！

辞旧迎新，新工作感悟！

大家好&#xff0c;我是雄雄&#xff0c;欢迎关注微信公众号&#xff1a;雄雄的小课堂 现在是&#xff1a;2022年6月21日22:33:34 公众号又好久没有更新啦。从以前的日更&#xff0c;到后来的周更&#xff0c;再到后来的月更……不知道会不会到不更的结局。。。 最近换工作了…
阅读更多...
ASPNET Core 2.x中的Kestrel服务器

ASPNET Core 2.x中的Kestrel服务器

Kestrel是一个基于libuv的跨平台ASP.NET Core web服务器&#xff0c;libuv是一个跨平台的异步I/O库。ASP.NET Core模板项目使用Kestrel作为默认的web服务器。 Kestrel支持以下功能&#xff1a; HTTPS用于启用不透明升级的WebSockets位于Nginx之后的高性能Unix sockets Kestr…
阅读更多...
全文搜索！收藏这篇Solr ElasticSearch 长文就可以搞定

全文搜索！收藏这篇Solr ElasticSearch 长文就可以搞定

转载自 全文搜索&#xff01;收藏这篇Solr ElasticSearch 长文就可以搞定 摘自&#xff1a;JaJian博кē Java后端技术编者说&#xff1a;文章从浅到深&#xff0c;描述了什么是全文搜索&#xff0c;为什么要使用全文搜索&#xff0c;Solr和ElasticSearch的发展和比较。文章比…
阅读更多...
网页弹框弹出

网页弹框弹出

完成这个功能需要在 弹框弹出 点击之后 才会显示内容 <!DOCTYPE html> <html><head><title>对话框测试</title><script>alert("对话框测试");</script></head><body>对话框测试&#xff1a;</body> …
阅读更多...
Azure School与开源

Azure School与开源

距离Azure School(https://school.azure.cn/) 的正式上线时间&#xff0c;2017.8.3&#xff0c;已经过去了20多天了。这20多天得到了很多有帮助的建议和反馈&#xff0c;小伙伴们都很给力&#xff0c;互相帮助扶持&#xff0c;调整产品不正确的地方&#xff0c;快速迭代新的功能…
阅读更多...
select count(*)底层究竟干了啥么？

select count(*)底层究竟干了啥么？

转载自 select count(*)底层究竟干了啥么&#xff1f; “SELECT COUNT( * ) FROM t” 是个再常见不过的 SQL 需求了。在 MySQL 的使用规范中&#xff0c;我们一般使用事务引擎 InnoDB 作为(一般业务)表的存储引擎&#xff0c;在此前提下&#xff0c;COUNT( * )操作的时间复杂…
阅读更多...
为什么不应该重写service方法

为什么不应该重写service方法

转载自 为什么不应该重写service方法 故事通常是这样开始的&#xff1a; 从前&#xff0c;有一个程序猿&#xff0c;他语重心长地对孙子说&#xff1a;“孩子&#xff0c;要是你以后写servlet&#xff0c;最好不要重写service方法啊” 孙子大为不解&#xff0c;程序猿又说&…
阅读更多...
.net core之ACG小站爬虫（二）

.net core之ACG小站爬虫（二）

紧跟着上一节说的文章&#xff0c;虽然已经放出了所写的全代码&#xff0c;但还是再解释一下另外一个页面的请求和分析过程吧。PS&#xff1a;又可以愉快的水一章了&#xff0c;咕嘿嘿。页面分析上回说到下载按钮的href属性是javascript:;伪协议&#xff0c;导致了新打开的页面…
阅读更多...
.net core之ACG小站爬虫（一）

.net core之ACG小站爬虫（一）

想到好久没写过.net的代码了&#xff0c;因此就尝试来写一写.net的代码。此外&#xff0c;也想要熟悉一下Phantomjs。环境配置.net core下载。可选的可以下载宇宙大IDEVisual Studio&#xff0c;当然更加推荐使用Visual Studio Code进行代码的书写。Phantomjs。这个不用说了&am…
阅读更多...
数组：完成等差等比数列，及其他数列

数组：完成等差等比数列，及其他数列

有没有想过用c语言来编写一些数列呢&#xff0c;编写数列&#xff0c;数组是最好的选择。 等差&#xff1a; #include<stdio.h> main(){ int a[1000],b,i;a[0]1;scanf("%d",&b);for(i0;i<b;i){a[i1]a[i]2;}for(i0;i<b;i){printf("a%d%-8d\t&q…
阅读更多...
Spring MVC竟然有5种参数绑定的方式？你知道几种？

Spring MVC竟然有5种参数绑定的方式？你知道几种？

转载自 Spring MVC竟然有5种参数绑定的方式&#xff1f;你知道几种&#xff1f; SpringMVC参数绑定&#xff0c;简单来说就是将客户端请求的key/value数据绑定到controller方法的形参上&#xff0c;然后就可以在controller中使用该参数了下面通过5个常用的注解演示下如何进行参…
阅读更多...
微服务中如何切换配置文件、部署

微服务中如何切换配置文件、部署

大家好&#xff0c;我是雄雄&#xff0c;欢迎关注微信公众号&#xff1a;雄雄的小课堂 最近改了个微服务的项目&#xff0c;在本身的业务上加上一个演示的业务。 以前没有弄过微服务的项目&#xff0c;这次改完之后&#xff0c;部署花了不少时间&#xff0c;一方面是因为服务器…
阅读更多...
asp.net core mvc View Component 应用

asp.net core mvc View Component 应用

ViewComponent1、View 组件介绍在ASP.NET CORE MVC中,View组件有点类似于partial views,但是他们更强大&#xff0c;View组件不能使用model binding,当你调用它的时候仅仅依赖与你提供的数据一个View组件特点&#xff1a;.呈现一大块而不是一个整体的响应。 .包含在控制器和视…
阅读更多...
分离三位数

分离三位数

#include<stdio.h> main(){ int k,l,m,n;printf("请输入一个三位数"); scanf("%d",&k);lk/100;mk/10%10;nk%10;printf("这个三位数的百位是:%d\n",l);printf("这个三位数的十位是:%d\n",m);printf("这个三位数的个位是…
阅读更多...
大湾区第二次.NET技术交流会圆满成功

大湾区第二次.NET技术交流会圆满成功

2017年9月16日的深圳阳光明媚&#xff0c;一场为庆祝.NET Core 2.0发布和.NET 社区大会&#xff08;https://www.dotnetconf.net/&#xff09; 的召开的本地社区活动&#xff0c;这次活动还得到如鹏网杨中科老师的大力支持开通网上直播&#xff0c;网上有300多位参与活动&#…
阅读更多...
五分钟轻松了解Hbase面向列的存储

五分钟轻松了解Hbase面向列的存储

转载自 五分钟轻松了解Hbase面向列的存储 说明&#xff1a;从严格的列式存储的定义来看&#xff0c;Hbase并不属于列式存储&#xff0c;有人称它为面向列的存储&#xff0c;请各位看官注意这一点。 行式存储 传统的数据库是关系型的&#xff0c;且是按行来存储的。如下图&a…
阅读更多...
jeecg微服务项目调用接口报错Token验证失效的解决方法

jeecg微服务项目调用接口报错Token验证失效的解决方法

大家好&#xff0c;我是雄雄。 前言 今天&#xff0c;记录一篇啼笑皆非的问题。 昨晚上在做微信公众号开发时&#xff0c;遇到了个解决好久的问题&#xff0c;即&#xff1a;微信公众号上配置服务器信息之后&#xff0c;回调服务器接口总是报错token验证失败。 剧透&#xf…
阅读更多...
是时候开始用C#快速开发移动应用了

是时候开始用C#快速开发移动应用了

从2015年接触Xamarin到至今已经2个年头&#xff0c;我对Xamarin的技能没有长进多少&#xff0c;但它却已经足够成熟到在跨平台移动开发工具中占有一席之地。在扫了一些资料之后&#xff0c;突然发现国外有很多移动端的应用已经是用Xamarin开发&#xff0c;Telerik还有专门的团队…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023