| | |
| | | @Resource |
| | | private EsService esSer; |
| | | |
| | | private LambdaQueryWrapper<LiveStreaming> buildCondition(LiveStreaming liveStreaming) { |
| | | private LambdaQueryWrapper<LiveStreaming> buildCondition(LiveStreaming liveStreaming) throws ParseException { |
| | | LambdaQueryWrapper<LiveStreaming> lqw = new LambdaQueryWrapper<>(); |
| | | // lqw.in(LiveStreaming::getFamilyId,familyIdList); |
| | | 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()) |
| | | .like(StringUtils.isNotEmpty(liveStreaming.getRoomId()),LiveStreaming::getRoomId,liveStreaming.getRoomId()); |
| | | lqw.between(liveStreaming.getHappenStartTime() != null && liveStreaming.getHappenEndTime() != null,LiveStreaming::getCreateTime,liveStreaming.getHappenStartTime(),liveStreaming.getHappenEndTime()); |
| | | .eq(LiveStreaming::getStatus,0); |
| | | |
| | | List<LiveStreaming> liveStreamingList = list(lqw); |
| | | for (LiveStreaming liveStreaming1: liveStreamingList) { |
| | | SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | Calendar nowTime = Calendar.getInstance(); |
| | | String currentTime = df.format(nowTime.getTime()); |
| | | Date date = df.parse(currentTime); |
| | | if(liveStreaming1.getStartTime() != null && liveStreaming1.getEndTime() != null){ |
| | | if (!belongCalendar(date,liveStreaming1.getStartTime(),liveStreaming1.getEndTime())){ |
| | | liveStreaming1.setStatus(1); |
| | | updateById(liveStreaming1); |
| | | }} |
| | | } |
| | | |
| | | return lqw; |
| | | } |
| | | |
| | | /**MaNongXF |
| | | * 判断时间是否处于某个时间段内 |
| | | * |
| | | * @param time 需要比较的时间 |
| | | * @param from 起始时间 |
| | | * @param to 结束时间 |
| | | * @return |
| | | */ |
| | | public static boolean belongCalendar(Date time, Date from, Date to) { |
| | | System.out.println("11111"+time+"222"+from+"333"+to); |
| | | Calendar date = Calendar.getInstance(); |
| | | date.setTime(time); |
| | | Calendar after = Calendar.getInstance(); |
| | | after.setTime(from); |
| | | Calendar before = Calendar.getInstance(); |
| | | before.setTime(to); |
| | | if (date.after(after) && date.before(before)) { |
| | | return true; |
| | | } else { |
| | | return false; |
| | | } |
| | | } |
| | | |
| | | private LambdaQueryWrapper<LiveStreaming> uniqueCondition(LiveStreaming liveStreaming){ |
| | |
| | | } |
| | | |
| | | @Override |
| | | public AjaxResult selectDataList(LiveStreaming liveStreaming, Integer pageNum, Integer pageSize) { |
| | | public AjaxResult selectDataList(LiveStreaming liveStreaming, Integer pageNum, Integer pageSize) throws ParseException { |
| | | //要查自己家庭的 |
| | | // ZInfoUser myself = zInfoUserService.getMyself(); |
| | | // if(myself==null) |
| | |
| | | LambdaQueryWrapper<LiveStreaming> lqw = buildCondition(liveStreaming); |
| | | |
| | | |
| | | |
| | | Page<LiveStreaming> liveStreamingPage = new Page<>(pageNum, pageSize); |
| | | Page<LiveStreaming> pageResult = page(liveStreamingPage, lqw); |
| | | |
| | |
| | | // List<LiveStreaming> dtoResult = markOwnData(familyId, beanRecords); |
| | | |
| | | HashMap<String, Object> data = MapUtils.getResult(pageResult, beanRecords); |
| | | |
| | | |
| | | |
| | | return AjaxResult.success(data); |
| | |
| | | nowTime.setTime(liveStreaming.getStartTime()); |
| | | nowTime.add(Calendar.MINUTE, liveStreaming.getDuration()); |
| | | String currentTime = df.format(nowTime.getTime()); |
| | | System.out.println("30分钟后的时间" + currentTime); |
| | | return df.parse(currentTime); |
| | | } |
| | | |
| | |
| | | if (liveStreaming.getMaxPerson() > 120){ |
| | | throw new RuntimeException("可容纳人数暂时最多为120人"); |
| | | } |
| | | |
| | | liveStreaming.setStatus(0); |
| | | liveStreaming.setEndTime(getEndTime1(liveStreaming)); |
| | | |
| | | if (save(liveStreaming)) { |
| | |
| | | |
| | | } |
| | | } |
| | | @Override |
| | | public AjaxResult deleteData(Long[] ids) { |
| | | List<LiveStreaming> liveStreaming = selectByIds(ids); |
| | | for (LiveStreaming liveStreaming1:liveStreaming) { |
| | | liveStreaming1.setStatus(1); |
| | | updateById(liveStreaming1); |
| | | } |
| | | return AjaxResult.success(); |
| | | } |
| | | } |