| | |
| | | private LambdaQueryWrapper<LiveStreaming> buildCondition(LiveStreaming liveStreaming) { |
| | | LambdaQueryWrapper<LiveStreaming> lqw = new LambdaQueryWrapper<>(); |
| | | // lqw.in(LiveStreaming::getFamilyId,familyIdList); |
| | | lqw.orderByDesc(LiveStreaming::getCreateTime); |
| | | lqw.orderByDesc(LiveStreaming::getId); |
| | | lqw.like(StringUtils.isNotEmpty(liveStreaming.getTitle()), LiveStreaming::getTitle, liveStreaming.getTitle()) |
| | | .like(StringUtils.isNotEmpty(liveStreaming.getApplyPerson()),LiveStreaming::getApplyPerson,liveStreaming.getApplyPerson()) |
| | | .like(StringUtils.isNotEmpty(liveStreaming.getContactPerson()),LiveStreaming::getContactPerson,liveStreaming.getContactPerson()) |
| | |
| | | if(list.size()>0){ |
| | | throw new RuntimeException("请勿新增重复数据"); |
| | | } |
| | | if (liveStreaming.getMaxPerson() > 120){ |
| | | throw new RuntimeException("可容纳人数暂时最多为120人"); |
| | | } |
| | | |
| | | if (save(liveStreaming)) { |
| | | EsModel esModel = new EsModel(); |
| | |
| | | esModel.setBy1(liveStreaming.getTitle()); |
| | | esModel.setBy2(liveStreaming.getApplyPerson()); |
| | | esModel.setBy3(liveStreaming.getRoomId()); |
| | | |
| | | //这里存储查询详情的路径 |
| | | esModel.setBy5("/zLiveStreaming"); |
| | | // esModel.setFid(familyId); |