From 84450149ace9b29008e9a24166320d6b27bb370c Mon Sep 17 00:00:00 2001 From: zqy <2522236926@qq.com> Date: 星期一, 19 八月 2024 19:17:51 +0800 Subject: [PATCH] 直播删除 --- zhang-content/src/main/java/com/ruoyi/service/impl/LiveStreamingServiceImpl.java | 50 +++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 41 insertions(+), 9 deletions(-) diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/LiveStreamingServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/LiveStreamingServiceImpl.java index db59d66..720135c 100644 --- a/zhang-content/src/main/java/com/ruoyi/service/impl/LiveStreamingServiceImpl.java +++ b/zhang-content/src/main/java/com/ruoyi/service/impl/LiveStreamingServiceImpl.java @@ -28,17 +28,50 @@ @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){ @@ -52,7 +85,7 @@ } @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) @@ -71,6 +104,7 @@ LambdaQueryWrapper<LiveStreaming> lqw = buildCondition(liveStreaming); + Page<LiveStreaming> liveStreamingPage = new Page<>(pageNum, pageSize); Page<LiveStreaming> pageResult = page(liveStreamingPage, lqw); @@ -79,7 +113,6 @@ // List<LiveStreaming> dtoResult = markOwnData(familyId, beanRecords); HashMap<String, Object> data = MapUtils.getResult(pageResult, beanRecords); - return AjaxResult.success(data); @@ -104,7 +137,6 @@ 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); } @@ -119,7 +151,7 @@ if (liveStreaming.getMaxPerson() > 120){ throw new RuntimeException("鍙绾充汉鏁版殏鏃舵渶澶氫负120浜�"); } - + liveStreaming.setStatus(0); liveStreaming.setEndTime(getEndTime1(liveStreaming)); if (save(liveStreaming)) { -- Gitblit v1.9.1