From 3e02abec44a648f01174a4c3494a96ccb46a3b1a Mon Sep 17 00:00:00 2001
From: zqy <2522236926@qq.com>
Date: 星期二, 11 十一月 2025 21:39:20 +0800
Subject: [PATCH] 会员&充值相关模块
---
zhang-content/src/main/java/com/ruoyi/service/impl/LiveStreamingServiceImpl.java | 59 ++++++++++++++++++++++++++++++++++++++++++++++++++---------
1 files changed, 50 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..4120a90 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)) {
@@ -150,4 +182,13 @@
}
}
+ @Override
+ public AjaxResult deleteData(Long[] ids) {
+ List<LiveStreaming> liveStreaming = selectByIds(ids);
+ for (LiveStreaming liveStreaming1:liveStreaming) {
+ liveStreaming1.setStatus(1);
+ updateById(liveStreaming1);
+ }
+ return AjaxResult.success();
+}
}
--
Gitblit v1.9.1